添加任务处理消息

src/main/java/com/dingding/mid/controller/WorkspaceProcessController.java

@@ -18,6 +18,7 @@ import com.dingding.mid.entity.Users;
 import com.dingding.mid.entity.WorkflowConfig;
 import com.dingding.mid.enums.RefuseEnums;
 import com.dingding.mid.exception.WorkFlowException;
+import com.dingding.mid.mqtt.CloudMessage;
 import com.dingding.mid.mqtt.WorkFlowMessage;
 import com.dingding.mid.service.*;
 import com.dingding.mid.utils.MinioUploadUtil;
@@ -499,6 +500,10 @@ public class WorkspaceProcessController {
 
 
         taskService.complete(task.getId());
+        // 消息处理
+        CloudMessage cloudMessage = new CloudMessage();
+        cloudMessage.setTaskId(taskId);
+        sendMessageService.publish("message/deal/workflow",cloudMessage);
         return Result.OK();
     }
 
@@ -651,6 +656,10 @@ public class WorkspaceProcessController {
             }
             // TODO: 2024/3/8 给发起人发送拒绝信息
         }
+        // 消息处理
+        CloudMessage cloudMessage = new CloudMessage();
+        cloudMessage.setTaskId(taskId);
+        sendMessageService.publish("message/deal/workflow",cloudMessage);
 
         return Result.OK();
     }

src/main/java/com/dingding/mid/listener/CounterSignListener.java

@@ -191,10 +191,5 @@ public class CounterSignListener implements ExecutionListener {
                 execution.setVariable(variable,assigneeList);
             }
         }
-
-        // 消息处理
-        CloudMessage cloudMessage = new CloudMessage();
-        cloudMessage.setTaskId(execution.toString());
-        sendMessageService.publish("message/deal/workflow",cloudMessage);
     }
 }

src/main/java/com/dingding/mid/listener/TaskCreatedListener.java

@@ -85,6 +85,7 @@ public class TaskCreatedListener implements TaskListener {
                                         .setMessageStatus(0)
                                         .setMessageTypeId(4)
                                         .setTypeName(dataFrom)
+                                        .setTaskId(delegateTask.getId())
                                         .setTitle(delegateTask.getName() + "消息");
                                 log.info(" 操作人:{}",delegateTask.getAssignee());
                                 sendMessageService.publish("message/sys/workflow",cloudMessage);