流程 - 提交任务 发送webSocket消息。

jero-boot/jero-boot-modules/src/main/java/com/jero/modules/wkflow/controller/workFlowController.java

@@ -2,7 +2,9 @@ package com.jero.modules.wkflow.controller;
 
 import com.jero.common.api.vo.Result;
 import com.jero.common.aspect.annotation.AutoLog;
+import com.jero.common.constant.WebsocketConst;
 import com.jero.common.system.vo.LoginUser;
+import com.jero.modules.message.websocket.WebSocket;
 import com.jero.modules.project.entity.ConditionAssessmentEO;
 import com.jero.modules.project.enums.CurrentProjectStatusEnum;
 import com.jero.modules.project.enums.ProjectRoleEnum;
@@ -36,6 +38,9 @@ public class workFlowController {
     @Autowired
     private IConditionAssessmentEOService conditionAssessmentEOService;
 
+    @Autowired
+    private WebSocket webSocket;
+
     public Result activiti_define_start(@RequestBody JSONObject jsonObject){
         return  workFlowFeignClient.activiti_define_start(jsonObject);
     }
@@ -80,9 +85,18 @@ public class workFlowController {
         if(str.getCode() == 500){
             str.setSuccess(false);
         }
+        sendWebsocket(busMes.getTaskId(),busMes.getTaskId());
         return str;
     }
 
+    public void sendWebsocket(String msgId, String msgTet) {
+        com.alibaba.fastjson.JSONObject obj = new com.alibaba.fastjson.JSONObject();
+        obj.put(WebsocketConst.MSG_CMD, WebsocketConst.CMD_TOPIC);
+        obj.put(WebsocketConst.MSG_ID, msgId);
+        obj.put(WebsocketConst.MSG_TXT, msgTet);
+        webSocket.sendMessage(obj.toJSONString());
+    }
+
     @AutoLog(value = "通过流程实例id查询当前待办的流程实例是否结束")
     @ApiOperation(value="通过流程实例id查询当前待办的流程实例是否结束", notes="通过流程实例id查询当前待办的流程实例是否结束")
     @GetMapping("/queryTaskWhetherToEnd")