新单跟进v2

yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiExpectedFortuneServiceImpl.java

@@ -206,14 +206,23 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService
             return result;
         } catch (Exception e) {
             // 抛出异常，销毁redis缓存
+            try {
                 redisUtil.deleteObject(RedisConstants.EXPECTED_FORTUNE + request.getPolicyNo());
+            } catch (Exception redisEx) {
+                log.error("删除Redis缓存失败: {}", redisEx.getMessage(), redisEx);
+            }
             // 保存预计发佣日志记录（失败）
+            try {
                 apiExpectedFortuneLogService.saveExpectedFortuneLog(ApiExpectedFortuneLogDto.builder()
                         .errorMsg(e.getMessage())
                         .policyNo(request.getPolicyNo())
                         .status(1)
                         .build());
-            return Result.fail(e.getMessage());
+            } catch (Exception logEx) {
+                log.error("保存预计发佣日志失败: {}", logEx.getMessage(), logEx);
+            }
+            // 重新抛出原始异常，确保上层事务能够回滚
+            throw e;
         }
     }
 
@@ -237,14 +246,23 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService
             return result;
         } catch (Exception e) {
             // 抛出异常，销毁redis缓存
+            try {
                 redisUtil.deleteObject(RedisConstants.EXPECTED_FORTUNE + request.getPolicyNo());
+            } catch (Exception redisEx) {
+                log.error("删除Redis缓存失败: {}", redisEx.getMessage(), redisEx);
+            }
             // 保存预计发佣日志记录（失败）
+            try {
                 apiExpectedFortuneLogService.saveExpectedFortuneLog(ApiExpectedFortuneLogDto.builder()
                         .errorMsg(e.getMessage())
                         .policyNo(request.getPolicyNo())
                         .status(1)
                         .build());
-            throw new BusinessException(e.getMessage());
+            } catch (Exception logEx) {
+                log.error("保存预计发佣日志失败: {}", logEx.getMessage(), logEx);
+            }
+            // 重新抛出原始异常，确保上层事务能够回滚
+            throw e;
         }
     }