From 41223f0ba53ca782db03bfed41978a38e9b29736 Mon Sep 17 00:00:00 2001 From: Guava Date: Wed, 5 Jul 2023 12:28:18 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=BA=8B=E5=8A=A1=E6=A0=87?= =?UTF-8?q?=E8=AE=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/AsyncSendCasesRecommendService.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/AsyncSendCasesRecommendService.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/AsyncSendCasesRecommendService.java index 956c1820..09f5a3c8 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/AsyncSendCasesRecommendService.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/AsyncSendCasesRecommendService.java @@ -15,6 +15,7 @@ import org.apache.commons.collections4.CollectionUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.time.LocalDateTime; @@ -31,6 +32,7 @@ import java.util.stream.Collectors; */ @Service @Slf4j +@Transactional public class AsyncSendCasesRecommendService { @Resource @@ -50,7 +52,7 @@ public class AsyncSendCasesRecommendService { @Async public void sendCasesRecommend(CasesRecommend casesRecommend) { - log.info("异步推送任务开始了 {}",casesRecommend.getId()); + log.info("异步推送任务开始了 {}", casesRecommend.getId()); List pushStatusList = new ArrayList<>(); pushStatusList.add(CasesPushStatusEnum.WAIT_PUSH.getStatus()); List 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()); - log.info("异步推送任务结束了 {}",casesRecommend.getId()); + log.info("异步推送任务结束了 {}", casesRecommend.getId()); } /**