WL/laws_weilai
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

设计、验证、prehomo流程，更新任务状态时，发送websocket

Browse Source
This commit is contained in:
wangzhijiang
2022-06-16 09:55:22 +08:00
parent 08eec96bcd
commit 1ea29cda84
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectTaskInventoryDetailEOController.java
+13
View File
@@ -6,7 +6,9 @@ import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.alibaba.fastjson.JSONObject;
import com.jero.common.api.vo.Result;
import com.jero.common.constant.WebsocketConst;
import com.jero.common.system.query.QueryGenerator;
import com.jero.modules.message.websocket.WebSocket;
import com.jero.modules.project.entity.ProjectTaskInventoryDetailEO;
import com.jero.modules.project.service.IProjectTaskInventoryDetailEOService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -36,6 +38,8 @@ import com.jero.common.aspect.annotation.AutoLog;
public class ProjectTaskInventoryDetailEOController extends JeroController<ProjectTaskInventoryDetailEO, IProjectTaskInventoryDetailEOService> {
@Autowired
private IProjectTaskInventoryDetailEOService projectTaskInventoryDetailEOService;
@Autowired
private WebSocket webSocket;
/**
* 分页列表查询
@@ -97,6 +101,7 @@ public class ProjectTaskInventoryDetailEOController extends JeroController<Proje
@PutMapping(value = "/edit")
public Result<?> edit(@Validated @RequestBody ProjectTaskInventoryDetailEO projectTaskInventoryDetailEO) {
projectTaskInventoryDetailEOService.editById(projectTaskInventoryDetailEO);
sendWebsocket(projectTaskInventoryDetailEO.getId(),projectTaskInventoryDetailEO.getId());
return Result.OK("编辑成功!");
}
@@ -182,4 +187,12 @@ public class ProjectTaskInventoryDetailEOController extends JeroController<Proje
return this.projectTaskInventoryDetailEOService.queryByActiProcInstId(actiProcInstId, taskDefinitionKey);
}
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());
}
}