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

添加事务标记

Browse Source
This commit is contained in:
Guava
2023-07-05 12:28:18 +08:00
parent 313d8c2c56
commit 41223f0ba5
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -15,6 +15,7 @@ import org.apache.commons.collections4.CollectionUtils;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.time.LocalDateTime; import java.time.LocalDateTime;
@@ -31,6 +32,7 @@ import java.util.stream.Collectors;
*/ */
@Service @Service
@Slf4j @Slf4j
@Transactional
public class AsyncSendCasesRecommendService { public class AsyncSendCasesRecommendService {
@Resource @Resource
@@ -50,7 +52,7 @@ public class AsyncSendCasesRecommendService {
@Async @Async
public void sendCasesRecommend(CasesRecommend casesRecommend) { public void sendCasesRecommend(CasesRecommend casesRecommend) {
log.info("异步推送任务开始了 {}",casesRecommend.getId()); log.info("异步推送任务开始了 {}", casesRecommend.getId());
List<Integer> pushStatusList = new ArrayList<>(); List<Integer> pushStatusList = new ArrayList<>();
pushStatusList.add(CasesPushStatusEnum.WAIT_PUSH.getStatus()); pushStatusList.add(CasesPushStatusEnum.WAIT_PUSH.getStatus());
List<CasesRecommendPushRecord> casesRecommendPushRecords = casesRecommendPushRecordDao.findList(FieldFilters.in("pushStatus", pushStatusList), FieldFilters.eqField("recommendId", casesRecommend.getId())); List<CasesRecommendPushRecord> casesRecommendPushRecords = casesRecommendPushRecordDao.findList(FieldFilters.in("pushStatus", pushStatusList), FieldFilters.eqField("recommendId", casesRecommend.getId()));
@@ -69,7 +71,7 @@ public class AsyncSendCasesRecommendService {
} }
//修改为推送完成 --- 无数据 无需推送 //修改为推送完成 --- 无数据 无需推送
updateProcessStatus(casesRecommend.getId(), CasesPushStatusEnum.PUSH_SUCCESS.getStatus()); updateProcessStatus(casesRecommend.getId(), CasesPushStatusEnum.PUSH_SUCCESS.getStatus());
log.info("异步推送任务结束了 {}",casesRecommend.getId()); log.info("异步推送任务结束了 {}", casesRecommend.getId());
} }
/** /**