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 5cf33800..dcdba98b 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
@@ -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()));
diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java
index ae2fec8a..55f1cdf7 100644
--- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java
+++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java
@@ -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);