hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-10 19:36:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

案例同步增加事件消息

Browse Source
This commit is contained in:
daihh
2022-10-29 12:13:03 +08:00
parent 7738938864
commit 281e9c387a
2 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
servers/boe-server-case/pom.xml
View File

@@ -28,6 +28,11 @@
<artifactId>xboe-redis</artifactId> <artifactId>xboe-redis</artifactId>
<version>1.0.0</version> <version>1.0.0</version>
</dependency> </dependency>
<dependency>
<groupId>com.xboe</groupId>
<artifactId>xboe-module-event</artifactId>
<version>1.0.0</version>
</dependency>
<dependency> <dependency>
<groupId>com.boe</groupId> <groupId>com.boe</groupId>
<artifactId>httpsdk</artifactId> <artifactId>httpsdk</artifactId>

12
servers/boe-server-case/src/main/java/com/xboe/casetask/service/impl/CaseSyncServiceImpl.java
View File

@@ -1,15 +1,14 @@
package com.xboe.casetask.service.impl; package com.xboe.casetask.service.impl;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.HashSet;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set;
import javax.annotation.Resource; import javax.annotation.Resource;
import javax.transaction.Transactional; import javax.transaction.Transactional;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.xboe.casetask.dao.CaseSyncCustomizeDao; 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.casetask.service.ICaseSyncService;
import com.xboe.common.OrderCondition; import com.xboe.common.OrderCondition;
import com.xboe.common.PageList; import com.xboe.common.PageList;
import com.xboe.core.event.IEventDataSender;
import com.xboe.core.orm.FieldFilters; import com.xboe.core.orm.FieldFilters;
import com.xboe.core.orm.QueryBuilder; import com.xboe.core.orm.QueryBuilder;
import com.xboe.core.orm.UpdateBuilder; import com.xboe.core.orm.UpdateBuilder;
@@ -46,6 +46,9 @@ public class CaseSyncServiceImpl implements ICaseSyncService{
@Resource @Resource
private UserDao userDao; private UserDao userDao;
@Autowired(required = false)
private IEventDataSender eventSender;
// @Override // @Override
// @Transactional // @Transactional
@@ -227,6 +230,11 @@ public class CaseSyncServiceImpl implements ICaseSyncService{
} }
} }
recordDao.updateFieldById(csr.getId(), "caseId", c.getId()); 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("未配置事件消息发送的实现");
}
} }