This commit is contained in:
Mr. Lan 2020-07-26 01:11:47 +08:00
parent 4620c91730
commit 5cb6f9d094

View File

@ -661,6 +661,21 @@ func (h *Handle) HandleWorkOrder(
return return
} }
bodyData := notify.BodyData{
SendTo: map[string]interface{}{
"userList": sendToUserList,
},
Subject: sendSubject,
Description: sendDescription,
Classify: noticeList,
ProcessId: h.workOrderDetails.Process,
Id: h.workOrderDetails.Id,
Title: h.workOrderDetails.Title,
Creator: currentUserInfo.NickName,
Priority: h.workOrderDetails.Priority,
CreatedAt: h.workOrderDetails.CreatedAt.Format("2006-01-02 15:04:05"),
}
// 判断目标是否是结束节点 // 判断目标是否是结束节点
if h.targetStateValue["clazz"] == "end" && h.endHistory == true { if h.targetStateValue["clazz"] == "end" && h.endHistory == true {
sendSubject = "您的工单已处理完成" sendSubject = "您的工单已处理完成"
@ -679,33 +694,26 @@ func (h *Handle) HandleWorkOrder(
h.tx.Rollback() h.tx.Rollback()
return return
} }
if len(noticeList) > 0 {
// 查询工单创建人信息 // 查询工单创建人信息
err = h.tx.Model(&system.SysUser{}). err = h.tx.Model(&system.SysUser{}).
Where("user_id = ?", h.workOrderDetails.Creator). Where("user_id = ?", h.workOrderDetails.Creator).
Find(&sendToUserList).Error Find(&sendToUserList).Error
if err != nil { if err != nil {
return return
}
// 发送通知
go func() {
bodyData := notify.BodyData{
SendTo: map[string]interface{}{
"userList": sendToUserList,
},
Subject: sendSubject,
Description: sendDescription,
Classify: noticeList,
ProcessId: h.workOrderDetails.Process,
Id: h.workOrderDetails.Id,
Title: h.workOrderDetails.Title,
Creator: currentUserInfo.NickName,
Priority: h.workOrderDetails.Priority,
CreatedAt: h.workOrderDetails.CreatedAt.Format("2006-01-02 15:04:05"),
} }
bodyData.SendNotify()
}() bodyData.SendTo = map[string]interface{}{
"userList": sendToUserList,
}
bodyData.Subject = sendSubject
bodyData.Description = sendDescription
// 发送通知
go func(bodyData notify.BodyData) {
bodyData.SendNotify()
}(bodyData)
}
} }
h.tx.Commit() // 提交事务 h.tx.Commit() // 提交事务
@ -717,24 +725,16 @@ func (h *Handle) HandleWorkOrder(
return return
} }
bodyData.SendTo = map[string]interface{}{
"userList": sendToUserList,
}
bodyData.Subject = sendSubject
bodyData.Description = sendDescription
// 发送通知 // 发送通知
go func() { go func(bodyData notify.BodyData) {
bodyData := notify.BodyData{
SendTo: map[string]interface{}{
"userList": sendToUserList,
},
Subject: sendSubject,
Description: sendDescription,
Classify: noticeList,
ProcessId: h.workOrderDetails.Process,
Id: h.workOrderDetails.Id,
Title: h.workOrderDetails.Title,
Creator: currentUserInfo.NickName,
Priority: h.workOrderDetails.Priority,
CreatedAt: h.workOrderDetails.CreatedAt.Format("2006-01-02 15:04:05"),
}
bodyData.SendNotify() bodyData.SendNotify()
}() }(bodyData)
} }
// 执行流程公共任务及节点任务 // 执行流程公共任务及节点任务