入账检核-手动新增2

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/CommissionServiceImpl.java

@@ -865,17 +865,24 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
 
 
             commissionList.add(commission);
             commissionList.add(commission);
         }
         }
-        // 提交事务，保存数据
+        // 1. 先保存主数据
         saveOrUpdateBatch(commissionList);
         saveOrUpdateBatch(commissionList);
 
 
-        // 开启新事务，比对数据
-        try {
-            commissionAsyncService.commissionCompareBatch(commissionList);
-        } catch (Exception e) {
-            // 比对失败不影响主事务，记录日志即可
-            e.printStackTrace();
-            log.error("批量新增, 比对操作执行失败, error: {}", e.getMessage());
-        }
+        // 2. 事务提交后执行比对
+        TransactionSynchronizationManager.registerSynchronization(
+                new TransactionSynchronization() {
+                    @Override
+                    public void afterCommit() {
+                        try {
+                            // 这里会开启新事务执行更新
+                            commissionAsyncService.commissionCompareBatch(commissionList);
+                        } catch (Exception e) {
+                            log.error("比对更新失败", e);
+                            // 可以发送告警或记录失败任务
+                        }
+                    }
+                }
+        );
 
 
         return commissionList;
         return commissionList;
     }
     }