run_cache.go 718 B

1234567891011121314151617181920212223
  1. package work_flow_service
  2. import (
  3. flowModel "gfast/app/model/admin/wf_flow"
  4. "gfast/app/model/admin/wf_flow_process"
  5. "gfast/app/model/admin/wf_run_cache"
  6. "github.com/gogf/gf/database/gdb"
  7. "github.com/gogf/gf/os/gtime"
  8. "github.com/gogf/gf/util/gconv"
  9. )
  10. func AddWorkflowCache(runId int64, flowInfo *flowModel.Entity, process *wf_flow_process.Entity, wfFid int, tx *gdb.TX) error {
  11. data := &wf_run_cache.AddData{
  12. RunId: gconv.Uint(runId),
  13. FormId: gconv.Uint(wfFid),
  14. FlowId: flowInfo.Id,
  15. RunForm: "",
  16. RunFlow: gconv.String(flowInfo),
  17. RunFlowProcess: gconv.String(process),
  18. Dateline: gconv.Uint(gtime.Timestamp()),
  19. }
  20. return wf_run_cache.Add(data, tx)
  21. }