udpate

risk-control-core/src/main/java/com/tzld/piaoquan/risk/control/job/BlacklistSyncJobHandler.java

@@ -43,7 +43,7 @@ public class BlacklistSyncJobHandler {
         MDC.put("logTraceId", traceId);
 
         try {
-            log.info("开始执行黑名单同步任务检查，traceId: {}", traceId);
+            log.info("开始执行黑名单同步任务检查，traceId: {}, params: {}", traceId, params);
 
             // 记录任务开始时间
             long startTime = System.currentTimeMillis();
@@ -52,9 +52,12 @@ public class BlacklistSyncJobHandler {
             String configInfo = apolloConfigService.getConfigInfo();
             log.info("当前配置信息: {}", configInfo);
             log.info("XXL-JOB任务开始执行，配置信息: {}", configInfo);
-            
+            Long value = null;
+            if (params != null) {
+                value = Long.valueOf(params);
+            }
             // 执行智能同步检查
-            blacklistSyncService.intelligentSyncCheck();
+            blacklistSyncService.intelligentSyncCheck(value);
             
             // 记录任务结束时间和耗时
             long endTime = System.currentTimeMillis();

risk-control-core/src/main/java/com/tzld/piaoquan/risk/control/service/sync/BlacklistSyncService.java

@@ -15,7 +15,7 @@ public interface BlacklistSyncService {
      * 
      * 遍历所有企业，基于时间间隔和随机概率进行智能同步决策
      */
-    void intelligentSyncCheck();
+    void intelligentSyncCheck(Long corpId);
     
     /**
      * 强制同步指定企业

risk-control-core/src/main/java/com/tzld/piaoquan/risk/control/service/sync/impl/BlacklistSyncServiceImpl.java

@@ -43,9 +43,14 @@ public class BlacklistSyncServiceImpl implements BlacklistSyncService {
     private static final int SLEEP_TIME = 1500; // 1.5秒
     
     @Override
-    public void intelligentSyncCheck() {
+    public void intelligentSyncCheck(Long corpIdParam) {
         // 1. 获取所有企业ID
-        List<Long> corpIds = blacklistDataService.getAllCorpIds();
+        List<Long> corpIds = new ArrayList<>();
+        if (corpIdParam == null) {
+            corpIds = blacklistDataService.getAllCorpIds();
+        }else {
+            corpIds.add(corpIdParam);
+        }
         log.info("开始智能同步检查，共{}个企业", corpIds.size());
         
         int syncCount = 0;