From 1ea29cda849279aa65eb7948c4f51393ebf590a1 Mon Sep 17 00:00:00 2001
From: wangzhijiang <12345678>
Date: Thu, 16 Jun 2022 09:55:22 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E8=AE=A1=E3=80=81=E9=AA=8C=E8=AF=81?=
 =?UTF-8?q?=E3=80=81prehomo=E6=B5=81=E7=A8=8B=EF=BC=8C=E6=9B=B4=E6=96=B0?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E7=8A=B6=E6=80=81=E6=97=B6=EF=BC=8C=E5=8F=91?=
 =?UTF-8?q?=E9=80=81websocket?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ProjectTaskInventoryDetailEOController.java     | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectTaskInventoryDetailEOController.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectTaskInventoryDetailEOController.java
index 07d1f6af1..8eff915fc 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectTaskInventoryDetailEOController.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectTaskInventoryDetailEOController.java
@@ -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());
+	 }
+
 }