添加任务处理消息

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

@@ -10,9 +10,12 @@ import com.dingding.mid.dto.json.UserInfo;
 import com.dingding.mid.entity.Users;
 import com.dingding.mid.enums.AssigneeTypeEnums;
 import com.dingding.mid.exception.WorkFlowException;
+import com.dingding.mid.mqtt.CloudMessage;
+import com.dingding.mid.service.SendMessageService;
 import com.dingding.mid.service.UserService;
 import com.dingding.mid.utils.SpringContextHolder;
 import lombok.extern.slf4j.Slf4j;
+import org.checkerframework.checker.units.qual.C;
 import org.flowable.bpmn.model.Process;
 import org.flowable.bpmn.model.UserTask;
 import org.flowable.engine.RepositoryService;
@@ -21,6 +24,7 @@ import org.flowable.engine.delegate.ExecutionListener;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -41,6 +45,10 @@ public class CounterSignListener implements ExecutionListener {
     private RepositoryService repositoryService;
     @Resource
     private UserService userService;
+
+    @Resource
+    private SendMessageService sendMessageService;
+
     @Override
     public void notify(DelegateExecution execution) {
 
@@ -183,8 +191,10 @@ public class CounterSignListener implements ExecutionListener {
                 execution.setVariable(variable,assigneeList);
             }
         }
-        else{
 
-        }
+        // 消息处理
+        CloudMessage cloudMessage = new CloudMessage();
+        cloudMessage.setTaskId(execution.toString());
+        sendMessageService.publish("message/deal/workflow",cloudMessage);
     }
 }

src/main/java/com/dingding/mid/mqtt/CloudMessage.java

@@ -109,4 +109,10 @@ public class CloudMessage implements Serializable{
     @ApiModelProperty(value="扩展信息")
     private String extend;
 
+    /**
+     * 任务id
+     */
+    @ApiModelProperty(value="任务id")
+    private String taskId;
+
 }

src/main/java/com/dingding/mid/service/SendMessageService.java

@@ -22,9 +22,9 @@ public class SendMessageService {
     @Autowired
     private MqttClientTemplate client;
 
-    public boolean publish(String topic, MqttMessage mqttMessage) {
+    public boolean publish(String topic,JSONObject mqttMessage) {
         JSONObject jsonObject = JSONUtil.parseObj(mqttMessage);
-        //client.publish(topic, JSONUtil.toJsonStr(jsonObject).getBytes(StandardCharsets.UTF_8));
+        client.publish(topic, JSONUtil.toJsonStr(jsonObject).getBytes(StandardCharsets.UTF_8));
         return true;
     }