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

修改异步推送

Browse Source
This commit is contained in:
Guava
2023-07-06 13:51:36 +08:00
parent 3b5a411541
commit 8f5660eff2
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/AsyncSendCasesRecommendService.java
View File

@@ -32,7 +32,6 @@ import java.util.stream.Collectors;
*/
@Service
@Slf4j
@Transactional
public class AsyncSendCasesRecommendService {
@Resource
@@ -51,6 +50,7 @@ public class AsyncSendCasesRecommendService {
@Async
@Transactional(rollbackFor = Exception.class)
public void sendCasesRecommend(CasesRecommend casesRecommend) {
log.info("异步推送任务开始了 {}", casesRecommend.getId());
List<CasesRecommendPushRecord> casesRecommendPushRecords = casesRecommendPushRecordDao.findList(FieldFilters.eq("pushStatus", CasesPushStatusEnum.WAIT_PUSH.getStatus()), FieldFilters.eq("recommendId", casesRecommend.getId()));

2
servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java
View File

@@ -141,9 +141,11 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
}
}
if (CollectionUtil.isNotEmpty(pushRecords)) {
log.info("本次推送纪录条数 {}", pushRecords.size());
casesRecommendPushRecordDao.saveList(pushRecords);
}
try {
log.info("发送推送案例消息 {}", JSONUtil.toJsonStr(casesRecommend));
//发送推送案例消息
asyncSendCasesRecommendService.sendCasesRecommend(casesRecommend);
log.info("执行完成耗时 {} 秒 ", (System.currentTimeMillis() - t1) / 1000);