根据流程ID查询流程

Author: mumushuiding

workflow-controller/processController.go

@@ -3,6 +3,7 @@ package controller
 import (
 	"fmt"
 	"net/http"
+	"strconv"
 
 	"github.com/go-workflow/go-workflow/workflow-engine/model"
 
@@ -213,3 +214,23 @@ func MoveFinishedProcInstToHistory(writer http.ResponseWriter, request *http.Req
 	}
 	util.ResponseOk(writer)
 }
+
+// FindProcInstByID 根据流程ID查询流程
+func FindProcInstByID(writer http.ResponseWriter, request *http.Request) {
+	request.ParseForm()
+	if len(request.Form["id"]) == 0 {
+		util.ResponseErr(writer, "字段 id 不能为空")
+		return
+	}
+	id, err := strconv.Atoi(request.Form["id"][0])
+	if err != nil {
+		util.ResponseErr(writer, err)
+		return
+	}
+	data, err := service.FindProcInstByID(id)
+	if err != nil {
+		util.ResponseErr(writer, err)
+		return
+	}
+	util.Response(writer, data, true)
+}

workflow-engine/model/ACT_HI_PROCINST.go

@@ -66,6 +66,16 @@ func StartByMyself(userID, company string, pageIndex, pageSize int) ([]*ProcInst
 	return findProcInsts(maps, pageIndex, pageSize)
 }
 
+// FindProcInstByID FindProcInstByID
+func FindProcInstByID(id int) (*ProcInst, error) {
+	var data = ProcInst{}
+	err := db.Where("id=?", id).Find(&data).Error
+	if err != nil {
+		return nil, err
+	}
+	return &data, nil
+}
+
 // FindProcNotify 查询抄送我的流程
 func FindProcNotify(userID, company string, groups []string, pageIndex, pageSize int) ([]*ProcInst, int, error) {
 	var datas []*ProcInst

workflow-engine/service/procInstService.go

@@ -15,6 +15,7 @@ import (
 // ProcessReceiver 接收页面传递参数
 type ProcessReceiver struct {
 	UserID     string             `json:"userId"`
+	ProcInstID string             `json:"procInstID"`
 	Username   string             `json:"username"`
 	Company    string             `json:"company"`
 	ProcName   string             `json:"procName"`
@@ -29,11 +30,12 @@ type ProcessPageReceiver struct {
 	// 我分管的部门
 	Departments []string `json:"departments"`
 	// 我所属于的用户组或者角色
-	Groups   []string `josn:"groups"`
-	UserID   string   `json:"userID"`
-	Username string   `json:"username"`
-	Company  string   `json:"company"`
-	ProcName string   `json:"procName"`
+	Groups     []string `josn:"groups"`
+	UserID     string   `json:"userID"`
+	Username   string   `json:"username"`
+	Company    string   `json:"company"`
+	ProcName   string   `json:"procName"`
+	ProcInstID string   `json:"procInstID"`
 }
 
 var copyLock sync.Mutex
@@ -51,6 +53,15 @@ func findAll(pr *ProcessPageReceiver) ([]*model.ProcInst, int, error) {
 	return model.FindProcInsts(pr.UserID, pr.ProcName, pr.Company, pr.Groups, pr.Departments, pr.PageIndex, pr.PageSize)
 }
 
+// FindProcInstByID FindProcInstByID
+func FindProcInstByID(id int) (string, error) {
+	data, err := model.FindProcInstByID(id)
+	if err != nil {
+		return "", err
+	}
+	return util.ToJSONStr(data)
+}
+
 // FindAllPageAsJSON FindAllPageAsJSON
 func FindAllPageAsJSON(pr *ProcessPageReceiver) (string, error) {
 	datas, count, err := findAll(pr)

workflow-router/router.go

@@ -36,6 +36,7 @@ func setMux() {
 	Mux.HandleFunc("/api/v1/workflow/process/start", intercept(controller.StartProcessInstance))               // 启动流程
 	Mux.HandleFunc("/api/v1/workflow/process/startByToken", intercept(controller.StartProcessInstanceByToken)) // 启动流程
 	Mux.HandleFunc("/api/v1/workflow/process/findTask", intercept(controller.FindMyProcInstPageAsJSON))        // 查询需要我审批的流程
+	Mux.HandleFunc("/api/v1/workflow/process/findById", intercept(controller.FindProcInstByID))                // 根据id查询流程实例
 	Mux.HandleFunc("/api/v1/workflow/process/findTaskByToken", intercept(controller.FindMyProcInstByToken))
 	Mux.HandleFunc("/api/v1/workflow/process/startByMyself", intercept(controller.StartByMyself))   // 查询我启动的流程
 	Mux.HandleFunc("/api/v1/workflow/process/FindProcNotify", intercept(controller.FindProcNotify)) // 查询抄送我的流程