|
|
@@ -1,575 +0,0 @@
|
|
|
-package wfclient
|
|
|
-
|
|
|
-import (
|
|
|
- "encoding/base64"
|
|
|
- "encoding/json"
|
|
|
- "encoding/xml"
|
|
|
- "errors"
|
|
|
- "fmt"
|
|
|
- "net/http"
|
|
|
- "strconv"
|
|
|
- "strings"
|
|
|
-
|
|
|
- "git.qianqiusoft.com/qianqiusoft/light-apiengine/config"
|
|
|
- "git.qianqiusoft.com/qianqiusoft/light-apiengine/entitys"
|
|
|
- "git.qianqiusoft.com/qianqiusoft/light-apiengine/utils"
|
|
|
-)
|
|
|
-
|
|
|
-type Filter struct {
|
|
|
- GroupOp string `json:"groupOp"`
|
|
|
- Rules []*FilterField `json:"rules"`
|
|
|
-}
|
|
|
-
|
|
|
-type FilterField struct {
|
|
|
- Field string `json:"field"`
|
|
|
- Op string `json:"op"`
|
|
|
- Data string `json:"data"`
|
|
|
-}
|
|
|
-
|
|
|
-type WFClient struct {
|
|
|
- endpoint string
|
|
|
- authorization string
|
|
|
- userId string
|
|
|
- username string
|
|
|
- token string
|
|
|
- domain string
|
|
|
-}
|
|
|
-
|
|
|
-var _wfendpoint = ""
|
|
|
-
|
|
|
-func init() {
|
|
|
- _wfendpoint = config.AppConfig.GetKey("wfendpoint")
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: single instance
|
|
|
- */
|
|
|
-func NewWFClient(c *entitys.CtrlContext) *WFClient {
|
|
|
- tk, _ := c.Ctx.Get("token")
|
|
|
- token := tk.(*entitys.Token)
|
|
|
- instance := &WFClient{}
|
|
|
- instance.endpoint = _wfendpoint
|
|
|
- instance.authorization, _ = instance.createAuthorization(token.LoginID, token.AccessToken, token.Domain)
|
|
|
- instance.userId = token.UserId
|
|
|
- instance.token = token.AccessToken
|
|
|
- HttpClientInstance().setRequestInterseptor(instance.wfReqInterseptor)
|
|
|
- return instance
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: init
|
|
|
- * @param1 endpoint: endpoint of wf service, do not end with /; such as http://wf.qianqiusoft.com
|
|
|
- * @param2 userId: user's id
|
|
|
- * @param3 username: username
|
|
|
- * @param4 token: token
|
|
|
- * @param5 domain: domain, its default value is qianqiusoft.com
|
|
|
- * @return1: information of error, nil if everything is all right
|
|
|
- */
|
|
|
-func (w *WFClient) Init(endpoint, userId, username, token, domain string) error {
|
|
|
- if w.token == token && w.authorization != "" {
|
|
|
- fmt.Println("wfclient token", w.token, "does already exist, token is", w.authorization)
|
|
|
- return nil
|
|
|
- }
|
|
|
-
|
|
|
- var err error = nil
|
|
|
- w.endpoint = endpoint
|
|
|
- w.userId = userId
|
|
|
- w.authorization, err = w.createAuthorization(username, token, domain)
|
|
|
- w.token = token
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- } else {
|
|
|
- return nil
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: create or update the define,
|
|
|
- * @param1 defineId: id of define, if the define with id does already exist, update the define
|
|
|
- * @param2 defineName: name of define
|
|
|
- * @param3 defineDesc: description of define
|
|
|
- * @param4 diagram: diagram of define
|
|
|
- * @param5 formName: name of the form
|
|
|
- * @return1 information of error
|
|
|
- */
|
|
|
-func (w *WFClient) CreateOrUpdateDefine(defineId, defineName, defineDesc, diagram, formName, tag, code string) ([]byte, error) {
|
|
|
- if defineId == "" {
|
|
|
- defineId = utils.NewUUID()
|
|
|
- }
|
|
|
- url := w.getFullUrl(fmt.Sprintf("api/wf_define/%s", defineId))
|
|
|
- fmt.Println("----url:", url)
|
|
|
- params := make(map[string]string)
|
|
|
- params["define_id"] = defineId
|
|
|
- params["name"] = defineName
|
|
|
- params["descript"] = defineDesc
|
|
|
- params["data"] = diagram
|
|
|
- params["form"] = formName
|
|
|
- params["code"] = code
|
|
|
- params["tag"] = tag
|
|
|
-
|
|
|
- return HttpClientInstance().post(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-func (w *WFClient) FetchDefine(defineId string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("api/wf_define/" + defineId)
|
|
|
-
|
|
|
- fmt.Println(url)
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, nil, nil)
|
|
|
-}
|
|
|
-
|
|
|
-func (w *WFClient) FetchAllDefines() ([]byte, error) {
|
|
|
- url := w.getFullUrl("api/wf_define/all")
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, nil, nil)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: get the flow define by tag
|
|
|
- * @param1 tag: tag of the define, split by ,
|
|
|
- * @return1: content of response
|
|
|
- * @return2: information of error, nil if everything is all right
|
|
|
- */
|
|
|
-func (w *WFClient) FetchDefinesByTag(tag string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("api/wf_define/list/tag")
|
|
|
- params := make(map[string]string)
|
|
|
- params["tag"] = tag
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: get the flow design diagram
|
|
|
- * @param1 id: id of flow define
|
|
|
- * @return1: content of response
|
|
|
- * @return2: information of error, nil if everything is all right
|
|
|
- */
|
|
|
-func (w *WFClient) FetchDesignDiagram(defineId string) ([]byte, error) {
|
|
|
- url := w.getFullUrl(fmt.Sprintf("api/wf_define/designer/%s", defineId))
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, nil, nil)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: create a wf instance
|
|
|
- * @param1 defineId: id of wf define
|
|
|
- * @param2 name: name of instance
|
|
|
- * @param3 formData: data to submit
|
|
|
- * @return1: content of response
|
|
|
- * @return2: error
|
|
|
- */
|
|
|
-func (w *WFClient) CreateInstance(defineId, name, formData string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("api/wf_instance")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["define_id"] = defineId
|
|
|
- params["name"] = name
|
|
|
- params["form_data"] = formData
|
|
|
-
|
|
|
- return HttpClientInstance().post(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-// 更新流程实例表单
|
|
|
-func (w *WFClient) UpdateInstanceForm(instanceId, formData string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("api/wf_instance/updateFormData")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["instance_id"] = instanceId
|
|
|
- params["form_data"] = formData
|
|
|
-
|
|
|
- return HttpClientInstance().post(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-type Choice struct {
|
|
|
- XMLName xml.Name `xml:"choice"json:"-"`
|
|
|
- Name string `json:"name"xml:"name"`
|
|
|
- Trans Transition `json:"trans"xml:"transition"`
|
|
|
-}
|
|
|
-
|
|
|
-type Transition struct {
|
|
|
- XMLName xml.Name `xml:"transition"json:"-"`
|
|
|
- Name string `json:"name"xml:"name"`
|
|
|
- To string `json:"to"xml:"to"`
|
|
|
- Points string `json:"-"xml:"points"`
|
|
|
- Conditions []*Condition `json:"conditions,omitempty"`
|
|
|
- Callback string `json:"callback"xml:"callback"`
|
|
|
-}
|
|
|
-
|
|
|
-type Condition struct {
|
|
|
- Operator string `json:"operator"xml:"operator"`
|
|
|
- DataKey string `json:"data_key"xml:"data_key"`
|
|
|
- Value string `json:"value"xml:"value"`
|
|
|
- Logic string `json:"logic"xml:"logic"`
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: run the wf instance
|
|
|
- * @param1 instanceId: id of instance
|
|
|
- * @param2 userId: approver id
|
|
|
- * @param3 choice: choice
|
|
|
- * @param4 options: options
|
|
|
- * @return1 content of response
|
|
|
- * @return2 error
|
|
|
- */
|
|
|
-func (w *WFClient) Run(instanceId, userId, choice, options, nextStep string, c *entitys.CtrlContext) ([]byte, error) {
|
|
|
- url := w.getFullUrl("api/wf_instance/run")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["instance_id"] = instanceId
|
|
|
- params["users"] = userId
|
|
|
- if choice != "" {
|
|
|
- params["choice"] = choice
|
|
|
- }
|
|
|
- if options != "" {
|
|
|
- params["opinion"] = options
|
|
|
- }
|
|
|
- if nextStep != "" {
|
|
|
- params["nextStep"] = nextStep
|
|
|
- }
|
|
|
-
|
|
|
- var RunRespInfo struct {
|
|
|
- DefineId string `json:"define_id"`
|
|
|
- InstanceId string `json:"instance_id"`
|
|
|
- DefineName string `json:"define_name"`
|
|
|
- InstanceName string `json:"instance_name"`
|
|
|
- Choices []*Choice `json:"choices"`
|
|
|
- Transition *Transition `json:"transition"`
|
|
|
- StepType string `json:"step_type"`
|
|
|
- FormData string `json:"form_data"`
|
|
|
- StepName string `json:"step_name"`
|
|
|
- ActorType string `json:"actor_type"`
|
|
|
- Executor string `json:"executor"`
|
|
|
- StartCallback string `json:"start_callback"`
|
|
|
- }
|
|
|
-
|
|
|
- bytess, err := HttpClientInstance().post(url, params, nil)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
- //fmt.Println("------------->>>>>--------", string(bytess))
|
|
|
- err = json.Unmarshal(bytess, &RunRespInfo)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- fmt.Println("------------------------------------->121", RunRespInfo.StartCallback)
|
|
|
-
|
|
|
- // 节点回调
|
|
|
- callbacks := strings.Split(RunRespInfo.StartCallback, ",")
|
|
|
- for _, callbackKye := range callbacks {
|
|
|
- callWFCallback(callbackKye, &CallbackArg{
|
|
|
- DefineId: RunRespInfo.DefineId,
|
|
|
- InstanceId: RunRespInfo.InstanceId,
|
|
|
- DefineName: RunRespInfo.DefineName,
|
|
|
- InstanceName: RunRespInfo.InstanceName,
|
|
|
- FormData: RunRespInfo.FormData,
|
|
|
- Choice: choice,
|
|
|
- Executor: RunRespInfo.Executor,
|
|
|
- UserId: w.userId,
|
|
|
- Context: c,
|
|
|
- })
|
|
|
- }
|
|
|
-
|
|
|
- // 连线回调
|
|
|
- linkCallbacks := []string{}
|
|
|
- if RunRespInfo.StepType == "begin" || RunRespInfo.StepType == "normal" {
|
|
|
- linkCallbacks = strings.Split(RunRespInfo.Transition.Callback, ",")
|
|
|
- } else {
|
|
|
- for _, c := range RunRespInfo.Choices {
|
|
|
- if c.Name == choice {
|
|
|
- linkCallbacks = strings.Split(c.Trans.Callback, ",")
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- for _, callbackKye := range linkCallbacks {
|
|
|
- callWFCallback(callbackKye, &CallbackArg{
|
|
|
- DefineId: RunRespInfo.DefineId,
|
|
|
- InstanceId: RunRespInfo.InstanceId,
|
|
|
- DefineName: RunRespInfo.DefineName,
|
|
|
- InstanceName: RunRespInfo.InstanceName,
|
|
|
- FormData: RunRespInfo.FormData,
|
|
|
- Choice: choice,
|
|
|
- Executor: RunRespInfo.Executor,
|
|
|
- UserId: w.userId,
|
|
|
- Context: c,
|
|
|
- })
|
|
|
- }
|
|
|
-
|
|
|
- return []byte{}, nil
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: run the wf instance
|
|
|
- * @param1 instanceId: id of instance
|
|
|
- * @param2 userId: approver id
|
|
|
- * @param3 choice: choice
|
|
|
- * @param4 options: options
|
|
|
- * @return1 content of response
|
|
|
- * @return2 error
|
|
|
- */
|
|
|
-func (w *WFClient) NewStep(instanceId, userId, choice, options, nextStep string, c *entitys.CtrlContext) ([]byte, error) {
|
|
|
- url := w.getFullUrl("api/wf_instance/newstep")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["instance_id"] = instanceId
|
|
|
- params["users"] = userId
|
|
|
- if choice != "" {
|
|
|
- params["choice"] = choice
|
|
|
- }
|
|
|
- if options != "" {
|
|
|
- params["opinion"] = options
|
|
|
- }
|
|
|
- if nextStep != "" {
|
|
|
- params["nextStep"] = nextStep
|
|
|
- }
|
|
|
-
|
|
|
- bytess, err := HttpClientInstance().post(url, params, nil)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
-
|
|
|
- return bytess, err
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: pre the wf instance
|
|
|
- * @param1 instanceId: id of instance
|
|
|
- * @param2 choice: choice of step
|
|
|
- * @return1 content of response
|
|
|
- * @return2 error
|
|
|
- */
|
|
|
-func (w *WFClient) PreRun(instanceId, choice string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("api/wf_instance/prerun")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["instance_id"] = instanceId
|
|
|
- params["choice"] = choice
|
|
|
-
|
|
|
- return HttpClientInstance().post(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: fetch my instances
|
|
|
- * @param1 page: page num, start from 1
|
|
|
- * @param2 rows: count per page, its default value is 10000
|
|
|
- * @return1: content of response
|
|
|
- * @return2: information of error
|
|
|
- */
|
|
|
-func (w *WFClient) FetchMyInstances(page, rows int) ([]byte, error) {
|
|
|
- url := w.getFullUrl("/api/wf_instance/mime")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["page"] = strconv.FormatInt(int64(page), 10)
|
|
|
- params["pageSize"] = strconv.FormatInt(int64(rows), 10)
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: fetch current step of login user
|
|
|
- * @param1 instanceId: id of instance
|
|
|
- * @return1 content of response
|
|
|
- * @return2 error
|
|
|
- */
|
|
|
-func (w *WFClient) FetchCurrentStepByLoginUser(instanceId string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("/api/wf_instance/user/current")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["instance_id"] = instanceId
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: fetch current step of instance
|
|
|
- * @param1 instanceId: id of instance
|
|
|
- * @return1 content of response
|
|
|
- * @return2 error
|
|
|
- */
|
|
|
-func (w *WFClient) FetchCurrentStep(instanceId string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("/api/wf_instance/current")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["instance_id"] = instanceId
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: fetch my to do list
|
|
|
- * @param1 page: page num, start from 1
|
|
|
- * @param2 rows: count per page, its default value is 10000
|
|
|
- * @return1: content of response
|
|
|
- * @return2: information of error
|
|
|
- */
|
|
|
-func (w *WFClient) FetchToDoList(page, rows int) ([]byte, error) {
|
|
|
- url := w.getFullUrl("/api/wf_instance/todo")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["page"] = strconv.FormatInt(int64(page), 10)
|
|
|
- params["pageSize"] = strconv.FormatInt(int64(rows), 10)
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: fetch my done list
|
|
|
- * @param1 page: page num, start from 1
|
|
|
- * @param2 rows: count per page, its default value is 10000
|
|
|
- * @return1: content of response
|
|
|
- * @return2: information of error
|
|
|
- */
|
|
|
-func (w *WFClient) FetchDoneList(page, rows int) ([]byte, error) {
|
|
|
- url := w.getFullUrl("/api/wf_instance/done")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["page"] = strconv.FormatInt(int64(page), 10)
|
|
|
- params["pageSize"] = strconv.FormatInt(int64(rows), 10)
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-func (w *WFClient) FetchWFINstances(page, rows int, filters, sidx, sord string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("/api/wf_instance/list")
|
|
|
- fmt.Println("wf url: ", url)
|
|
|
- params := make(map[string]string)
|
|
|
- params["page"] = strconv.FormatInt(int64(page), 10)
|
|
|
- params["rows"] = strconv.FormatInt(int64(rows), 10)
|
|
|
- params["sidx"] = sidx
|
|
|
- params["sord"] = sord
|
|
|
- params["filters"] = filters
|
|
|
-
|
|
|
- return HttpClientInstance().get(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: wf req interseptor
|
|
|
- * @param1 r: http req
|
|
|
- */
|
|
|
-func (w *WFClient) wfReqInterseptor(r *http.Request) {
|
|
|
- //r.Header.Add("Authorization", w.authorization)
|
|
|
- fmt.Println("header add token", w.token)
|
|
|
- r.Header.Add("token", w.token)
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: create the authorization by username, token and domain
|
|
|
- * @param2 username: username
|
|
|
- * @param3 token: token
|
|
|
- * @param4 domain: domain, its default value is qianqiusoft.com
|
|
|
- * @return1 authorization, such as Bearer adfeadfsdfsdffds
|
|
|
- * @return2 information of error, nil if everything is all right
|
|
|
- */
|
|
|
-func (w *WFClient) createAuthorization(username, token, domain string) (string, error) {
|
|
|
- if username == "" || token == "" {
|
|
|
- return "", errors.New("username or token is empty")
|
|
|
- }
|
|
|
- if domain == "" {
|
|
|
- domain = "qianqiusoft.com"
|
|
|
- }
|
|
|
- w.username = username
|
|
|
- w.token = token
|
|
|
- w.domain = domain
|
|
|
-
|
|
|
- tstr := fmt.Sprintf("%s:%s:%s", username, token, domain)
|
|
|
- tbase64str := base64.StdEncoding.EncodeToString([]byte(tstr))
|
|
|
-
|
|
|
- finalStr := "sso-auth-token:" + tbase64str
|
|
|
- return "Bearer " + base64.StdEncoding.EncodeToString([]byte(finalStr)), nil
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * @brief: get full url
|
|
|
- * @param1 path: api path, such as /api/wf_instance/done
|
|
|
- * @return1 url with query params
|
|
|
- */
|
|
|
-func (w *WFClient) getFullUrl(path string) string {
|
|
|
- path = strings.TrimLeft(path, "/")
|
|
|
- return fmt.Sprintf("%s/%s", w.endpoint, path)
|
|
|
-}
|
|
|
-
|
|
|
-//撤回
|
|
|
-func (w *WFClient) Recall(definedId string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("/api/wf_instance/recall")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["instance_id"] = definedId
|
|
|
-
|
|
|
- return HttpClientInstance().post(url, params, nil)
|
|
|
-}
|
|
|
-
|
|
|
-//终止
|
|
|
-func (w *WFClient) Interrupt(definedId string, formData map[string]interface{}, c *entitys.CtrlContext) ([]byte, error) {
|
|
|
- url := w.getFullUrl("/api/wf_instance/interrupt")
|
|
|
- params := make(map[string]string)
|
|
|
- params["instance_id"] = definedId
|
|
|
- var RunRespInfo struct {
|
|
|
- DefineId string `json:"define_id"`
|
|
|
- InstanceId string `json:"instance_id"`
|
|
|
- DefineName string `json:"define_name"`
|
|
|
- InstanceName string `json:"instance_name"`
|
|
|
- Choices []*Choice `json:"choices"`
|
|
|
- Transition *Transition `json:"transition"`
|
|
|
- StepType string `json:"step_type"`
|
|
|
- FormData string `json:"form_data"`
|
|
|
- StepName string `json:"step_name"`
|
|
|
- ActorType string `json:"actor_type"`
|
|
|
- Executor string `json:"executor"`
|
|
|
- StartCallback string `json:"start_callback"`
|
|
|
- }
|
|
|
- bytess, err := HttpClientInstance().post(url, params, nil)
|
|
|
- if err != nil {
|
|
|
- return nil, err
|
|
|
- }
|
|
|
- callWFCallback("interrupt", &CallbackArg{
|
|
|
- DefineId: RunRespInfo.DefineId,
|
|
|
- InstanceId: definedId,
|
|
|
- DefineName: RunRespInfo.DefineName,
|
|
|
- InstanceName: RunRespInfo.InstanceName,
|
|
|
- FormData: formData["form_data"].(string),
|
|
|
- Executor: RunRespInfo.Executor,
|
|
|
- UserId: w.userId,
|
|
|
- Context: c,
|
|
|
- })
|
|
|
- return bytess, err
|
|
|
-}
|
|
|
-
|
|
|
-//同步修复回调
|
|
|
-func (w *WFClient) RepairSync(definedId string, formData map[string]interface{}, c *entitys.CtrlContext) ([]byte, error) {
|
|
|
- var RunRespInfo struct {
|
|
|
- DefineId string `json:"define_id"`
|
|
|
- InstanceId string `json:"instance_id"`
|
|
|
- DefineName string `json:"define_name"`
|
|
|
- InstanceName string `json:"instance_name"`
|
|
|
- Choices []*Choice `json:"choices"`
|
|
|
- Transition *Transition `json:"transition"`
|
|
|
- StepType string `json:"step_type"`
|
|
|
- FormData string `json:"form_data"`
|
|
|
- StepName string `json:"step_name"`
|
|
|
- ActorType string `json:"actor_type"`
|
|
|
- Executor string `json:"executor"`
|
|
|
- StartCallback string `json:"start_callback"`
|
|
|
- }
|
|
|
- callWFCallback("repairSync", &CallbackArg{
|
|
|
- DefineId: RunRespInfo.DefineId,
|
|
|
- InstanceId: definedId,
|
|
|
- DefineName: RunRespInfo.DefineName,
|
|
|
- InstanceName: RunRespInfo.InstanceName,
|
|
|
- FormData: formData["form_data"].(string),
|
|
|
- Executor: RunRespInfo.Executor,
|
|
|
- UserId: w.userId,
|
|
|
- Context: c,
|
|
|
- })
|
|
|
- return []byte{}, nil
|
|
|
-}
|
|
|
-
|
|
|
-//撤回
|
|
|
-func (w *WFClient) Delete(definedId string) ([]byte, error) {
|
|
|
- url := w.getFullUrl("/api/wf_define/delete")
|
|
|
-
|
|
|
- params := make(map[string]string)
|
|
|
- params["define_id"] = definedId
|
|
|
-
|
|
|
- return HttpClientInstance().post(url, params, nil)
|
|
|
-}
|
paddy