From 281e9c387a4fd9e26f72180f8bb554ce0889d94d Mon Sep 17 00:00:00 2001
From: daihh <seastar@bjxask.com>
Date: Sat, 29 Oct 2022 12:13:03 +0800
Subject: [PATCH] =?UTF-8?q?=E6=A1=88=E4=BE=8B=E5=90=8C=E6=AD=A5=E5=A2=9E?=
 =?UTF-8?q?=E5=8A=A0=E4=BA=8B=E4=BB=B6=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 servers/boe-server-case/pom.xml                      |  5 +++++
 .../casetask/service/impl/CaseSyncServiceImpl.java   | 12 ++++++++++--
 2 files changed, 15 insertions(+), 2 deletions(-)

diff --git a/servers/boe-server-case/pom.xml b/servers/boe-server-case/pom.xml
index 918aef1f..87dda106 100644
--- a/servers/boe-server-case/pom.xml
+++ b/servers/boe-server-case/pom.xml
@@ -28,6 +28,11 @@
 			<artifactId>xboe-redis</artifactId>
 			<version>1.0.0</version>
 		</dependency>
+		<dependency>
+			<groupId>com.xboe</groupId>
+			<artifactId>xboe-module-event</artifactId>
+			<version>1.0.0</version>
+		</dependency>
 		<dependency>
 			<groupId>com.boe</groupId>
 			<artifactId>httpsdk</artifactId>
diff --git a/servers/boe-server-case/src/main/java/com/xboe/casetask/service/impl/CaseSyncServiceImpl.java b/servers/boe-server-case/src/main/java/com/xboe/casetask/service/impl/CaseSyncServiceImpl.java
index 1f9a546d..d415b56b 100644
--- a/servers/boe-server-case/src/main/java/com/xboe/casetask/service/impl/CaseSyncServiceImpl.java
+++ b/servers/boe-server-case/src/main/java/com/xboe/casetask/service/impl/CaseSyncServiceImpl.java
@@ -1,15 +1,14 @@
 package com.xboe.casetask.service.impl;
 
 import java.time.LocalDateTime;
-import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
-import java.util.Set;
 
 import javax.annotation.Resource;
 import javax.transaction.Transactional;
 
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import com.xboe.casetask.dao.CaseSyncCustomizeDao;
@@ -25,6 +24,7 @@ import com.xboe.casetask.entity.DictItem;
 import com.xboe.casetask.service.ICaseSyncService;
 import com.xboe.common.OrderCondition;
 import com.xboe.common.PageList;
+import com.xboe.core.event.IEventDataSender;
 import com.xboe.core.orm.FieldFilters;
 import com.xboe.core.orm.QueryBuilder;
 import com.xboe.core.orm.UpdateBuilder;
@@ -46,6 +46,9 @@ public class CaseSyncServiceImpl implements ICaseSyncService{
 	
 	@Resource
 	private UserDao userDao;
+	
+	@Autowired(required = false)
+	private IEventDataSender eventSender;
 
 //	@Override
 //	@Transactional
@@ -227,6 +230,11 @@ public class CaseSyncServiceImpl implements ICaseSyncService{
             	}
             }
             recordDao.updateFieldById(csr.getId(), "caseId", c.getId());
+            if(eventSender!=null) {
+            	eventSender.send("发布案例", "SyncCase",c.getTitle(), c.getId(), "3",c.getTitle(),c.getSysCreateAid(), c.getSysCreateBy(),"");
+            }else {
+            	System.out.print("未配置事件消息发送的实现");
+            }
        
 		}