mirror of
https://github.com/tiger1103/gfast.git
synced 2026-09-21 18:20:47 +00:00
328 lines
9.5 KiB
Go
328 lines
9.5 KiB
Go
// ============================================================================
|
|
// This is auto-generated by gf cli tool only once. Fill this file as you wish.
|
|
// ============================================================================
|
|
|
|
package wf_flow_process
|
|
|
|
import (
|
|
"github.com/gogf/gf/container/garray"
|
|
"github.com/gogf/gf/database/gdb"
|
|
"github.com/gogf/gf/encoding/gjson"
|
|
"github.com/gogf/gf/errors/gerror"
|
|
"github.com/gogf/gf/frame/g"
|
|
"github.com/gogf/gf/os/gtime"
|
|
"github.com/gogf/gf/text/gstr"
|
|
"github.com/gogf/gf/util/gconv"
|
|
)
|
|
|
|
type ProcessData struct {
|
|
Id int `json:"id"`
|
|
Mode string `json:"mode"`
|
|
Name string `json:"name"`
|
|
FlowId uint `json:"flow_id"`
|
|
ProcessName string `json:"process_name"`
|
|
ProcessTo string `json:"process_to"`
|
|
Style string `json:"style"`
|
|
Process *Entity `json:"process"`
|
|
}
|
|
|
|
//流程转出信息
|
|
type ProcessStepData struct {
|
|
PrevId int `json:"prev_id"`
|
|
Id int `json:"id"`
|
|
ProcessName string `json:"process_name"`
|
|
ProcessType string `json:"process_type"`
|
|
Condition []string `json:"condition"`
|
|
}
|
|
|
|
type SaveProcessReq struct {
|
|
Id int `p:"id" v:"required#流程ID不能为空"`
|
|
Left string `p:"left" v:"required#流程坐标left不能为空"`
|
|
Top string `p:"top" v:"required#流程坐标top不能为空"`
|
|
ProcessTo string `p:"process_to" `
|
|
}
|
|
|
|
type SaveProcessReqBatch struct {
|
|
Data []*SaveProcessReq `p:"data" v:"required#数据不能为空"`
|
|
}
|
|
|
|
type SaveAttrReq struct {
|
|
FlowId int `p:"flow_id" v:"required#工作流id不能为空"`
|
|
ProcessId int `p:"process_id" v:required#流程id不能为空`
|
|
ProcessName string `p:"process_name" v:required#流程名称不能为空`
|
|
StyleWidth string `p:"style_width"`
|
|
StyleHeight string `p:"style_height"`
|
|
ProcessType string `p:"process_type"`
|
|
WfAction string `p:"wf_action"`
|
|
IsSing string `p:"is_sing"`
|
|
IsBack string `p:"is_back"`
|
|
AutoPerson string `p:"auto_person"`
|
|
RangeUserIds string `p:"range_user_ids"`
|
|
RangeUserText string `p:"range_user_text"`
|
|
AutoSponsorIds string `p:"auto_sponsor_ids"`
|
|
AutoSponsorText string `p:"auto_sponsor_text"`
|
|
AutoRoleIds string `p:"auto_role_ids"`
|
|
AutoRoleText string `p:"auto_role_text"`
|
|
WorkText string `p:"work_text"`
|
|
WorkIds string `p:"work_ids"`
|
|
WfMode string `p:"wf_mode"`
|
|
ProcessInSet []ProcessInSetReq `p:"process_in_set"`
|
|
WorkSql string `p:"work_sql"`
|
|
WorkMsg string `p:"work_msg"`
|
|
ProcessCondition string `p:"process_condition"`
|
|
}
|
|
|
|
type ProcessInSetReq struct {
|
|
Id int `p:"id"`
|
|
Condition []string `p:"condition"`
|
|
}
|
|
|
|
//流程管理表字段信息
|
|
type FlowTableField struct {
|
|
FieldName string `json:"field_name"`
|
|
FieldText string `json:"field_text"`
|
|
}
|
|
|
|
type DeleteProcessReq struct {
|
|
ProcessId int `p:"process_id" v:"required#流程ID不能为空" json:"process_id"`
|
|
FlowId int `p:"flow_id" v:"required#工作流Id不能为空" json:"flow_id"`
|
|
}
|
|
|
|
//获取流程下所有步骤信息
|
|
func ProcessAll(flowId int64) (total int64, processData []*ProcessData, err error) {
|
|
var list []*Entity
|
|
list, err = Model.Where("flow_id", flowId).Where("is_del", 0).Order("id asc").FindAll()
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
err = gerror.New("获取流程数据失败")
|
|
return
|
|
}
|
|
processData = make([]*ProcessData, len(list))
|
|
for k, entity := range list {
|
|
total += 1
|
|
style := gjson.New(entity.Style)
|
|
model := `<span style="color:red">未设置</span>`
|
|
name := `<span style="color:red">未设置</span>`
|
|
var work map[string]string
|
|
if entity.AutoPerson == 3 {
|
|
model = "办理人员"
|
|
name = entity.RangeUserText
|
|
}
|
|
if entity.AutoPerson == 4 {
|
|
model = "办理人员"
|
|
name = entity.AutoSponsorText
|
|
}
|
|
if entity.AutoPerson == 5 {
|
|
model = "办理角色"
|
|
name = entity.AutoRoleText
|
|
}
|
|
if entity.AutoPerson == 6 {
|
|
work = map[string]string{
|
|
"1": "制单人员",
|
|
"2": "制单人员领导",
|
|
}
|
|
model = `<span style="color:blue">事务处理</span>`
|
|
name = work[entity.WorkIds]
|
|
}
|
|
nameAttr := ""
|
|
if entity.ProcessType == "is_one" {
|
|
nameAttr = `<span style="color:blue">[开始]</span>`
|
|
} else {
|
|
if entity.WfMode == 0 {
|
|
nameAttr = "[直线]"
|
|
} else if entity.WfMode == 1 {
|
|
nameAttr = `<span style="color:lightgreen">[转出]</span>`
|
|
} else {
|
|
nameAttr = `<span style="color:red">[同步]</span>`
|
|
}
|
|
}
|
|
heightUnit := "px"
|
|
if style.GetString("height") == "auto" {
|
|
heightUnit = ""
|
|
}
|
|
processData[k] = &ProcessData{
|
|
Id: entity.Id,
|
|
Mode: model,
|
|
Name: name,
|
|
FlowId: entity.FlowId,
|
|
ProcessName: nameAttr + entity.ProcessName,
|
|
ProcessTo: entity.ProcessTo,
|
|
Style: "width:" + style.GetString("width") + "px;height:" + style.GetString("height") +
|
|
heightUnit + ";line-height:30px;color:#0e76a8;left:" + gconv.String(entity.Setleft) + "px;top:" + gconv.String(entity.Settop) + "px;",
|
|
Process: entity,
|
|
}
|
|
}
|
|
return
|
|
}
|
|
|
|
//保存流程步骤
|
|
func ProcessAdd(flowId int64) error {
|
|
processList, err := Model.Order("id desc").FindAll("flow_id", flowId)
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
return gerror.New("获取流程数据失败")
|
|
}
|
|
processCount := len(processList)
|
|
processType := "is_step"
|
|
var processSetLeft uint = 100
|
|
var processSetTop uint = 100
|
|
if processCount == 0 {
|
|
processType = "is_one"
|
|
processSetLeft = 100
|
|
processSetTop = 100
|
|
} else {
|
|
//新建步骤显示在上一个步骤下方
|
|
processType = "is_step"
|
|
processSetLeft = processList[0].Setleft + 30
|
|
processSetTop = processList[0].Settop + 30
|
|
}
|
|
|
|
style := gjson.New(nil)
|
|
style.Set("width", "120")
|
|
style.Set("height", "auto")
|
|
style.Set("color", "#0e76a8")
|
|
entity := &Entity{
|
|
FlowId: gconv.Uint(flowId),
|
|
Setleft: processSetLeft,
|
|
Settop: processSetTop,
|
|
ProcessType: processType,
|
|
Style: style.MustToJsonString(),
|
|
AutoPerson: 4,
|
|
ProcessName: "步骤",
|
|
IsSing: 1,
|
|
IsBack: 1,
|
|
WfAction: "view",
|
|
}
|
|
_, err = Model.Save(entity)
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
return gerror.New("保存流程步骤失败")
|
|
}
|
|
return nil
|
|
}
|
|
|
|
//保存设计
|
|
func SaveProcess(req *SaveProcessReqBatch) error {
|
|
if req != nil && req.Data != nil {
|
|
tx, err := g.DB().Begin()
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
return gerror.New("保存失败")
|
|
}
|
|
entities := make([]*Entity, len(req.Data))
|
|
for k, rq := range req.Data {
|
|
entity, err := Model.FindOne(rq.Id)
|
|
if err != nil || entity == nil {
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
}
|
|
tx.Rollback()
|
|
return gerror.New("不存在的流程信息，请刷新重试。")
|
|
}
|
|
entity.Setleft = gconv.Uint(rq.Left)
|
|
entity.Settop = gconv.Uint(rq.Top)
|
|
entity.ProcessTo = rq.ProcessTo
|
|
entities[k] = entity
|
|
}
|
|
_, err = Model.TX(tx).Data(entities).Save()
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
tx.Rollback()
|
|
return gerror.New("保存数据失败")
|
|
}
|
|
tx.Commit()
|
|
}
|
|
return nil
|
|
}
|
|
|
|
//获取流程管理表字段信息
|
|
func GetFlowTableFields(dbPrefix, database, tableName string) (fields []*FlowTableField, err error) {
|
|
sql := "SELECT COLUMN_NAME as field_name,column_comment as field_text FROM INFORMATION_SCHEMA.COLUMNS WHERE table_name = ? " +
|
|
"AND table_schema = ? "
|
|
var result gdb.Result
|
|
result, err = g.DB().GetAll(sql, dbPrefix+tableName, database)
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
err = gerror.New("查询表字段数据失败")
|
|
}
|
|
result.Structs(&fields)
|
|
return
|
|
}
|
|
|
|
//删除流程节点
|
|
func ProcessDelete(req *DeleteProcessReq) error {
|
|
tx, err := g.DB().Begin()
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
return gerror.New("开启处理事务失败")
|
|
}
|
|
_, err = Model.TX(tx).Delete(g.Map{
|
|
Columns.Id: req.ProcessId,
|
|
Columns.FlowId: req.FlowId,
|
|
Columns.IsDel: 0,
|
|
})
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
tx.Rollback()
|
|
return gerror.New("删除失败")
|
|
}
|
|
list, err := Model.Where(Columns.FlowId, req.FlowId).Where(Columns.IsDel, 0).
|
|
Where("FIND_IN_SET(?,process_to)", gconv.String(req.ProcessId)).FindAll()
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
return gerror.New("获取节点连接失败")
|
|
}
|
|
if list != nil {
|
|
for _, value := range list {
|
|
s := gstr.Split(value.ProcessTo, ",")
|
|
arr := garray.NewStrArrayFrom(s)
|
|
key := arr.Search(gconv.String(req.ProcessId))
|
|
arr.Remove(key)
|
|
processTo := ""
|
|
if arr.Len() > 0 {
|
|
processTo = arr.Join(",")
|
|
}
|
|
value.Updatetime = gconv.Uint(gtime.Timestamp())
|
|
value.ProcessTo = processTo
|
|
_, err := Model.TX(tx).Save(value)
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
tx.Rollback()
|
|
return gerror.New("删除节点连线失败")
|
|
}
|
|
}
|
|
}
|
|
tx.Commit()
|
|
return nil
|
|
}
|
|
|
|
//通过ID获取流程步骤信息
|
|
func GetProcessInfoById(id uint) (entity *Entity, err error) {
|
|
entity, err = Model.FindOne(id)
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
err = gerror.New("查询流程信息失败")
|
|
}
|
|
return
|
|
}
|
|
|
|
//查询流程信息
|
|
func GetProcessesByMap(where g.Map) (entities []*Entity, err error) {
|
|
entities, err = Model.Where(where).FindAll()
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
err = gerror.New("查询流程信息失败")
|
|
}
|
|
return
|
|
}
|
|
|
|
//通过ids获取多条流程步骤信息
|
|
func GetProcessInfosByIds(ids []uint) (entities []*Entity, err error) {
|
|
entities, err = Model.Where("id in (?)", ids).FindAll()
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
err = gerror.New("查询流程信息失败")
|
|
}
|
|
return
|
|
}
|