修改查询分页

ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java

@@ -64,7 +64,7 @@ public abstract class SyncAccountsJobAbstract {
     /**
      * 分页条数
      */
-    protected static final Integer PAGE_SIZE = 50;
+    protected static final Integer PAGE_SIZE = 200;
 
     public static final String RETRY_KEY = "RETRY_CJT:%s:%s";
 
@@ -86,10 +86,10 @@ public abstract class SyncAccountsJobAbstract {
         int hour = now.getHour();
         if ((hour == 0 && CjtAccountEnum.ONE.getCode().equals(cjt))
                 || (hour == 1 && CjtAccountEnum.TWO.getCode().equals(cjt))) {
-            //目前只给畅捷通账号二加工单开补偿劝降
-            if ((AppType.SYNC_CJT_MANUFACTURE_ORDER_DATA_TO_MULTI_TABLE.getCode().equals(syncLarkAppType().getCode())
-                    && CjtAccountEnum.TWO.getCode().equals(cjt)) || (AppType.SYNC_CJT_SALE_DISPATCH_DATA_TO_MULTI_TABLE.getCode().equals(syncLarkAppType().getCode())
-                    && CjtAccountEnum.ONE.getCode().equals(cjt))) {
+            //目前只给畅捷通账号二加工单开补偿
+//            if ((AppType.SYNC_CJT_MANUFACTURE_ORDER_DATA_TO_MULTI_TABLE.getCode().equals(syncLarkAppType().getCode())
+//                    && CjtAccountEnum.TWO.getCode().equals(cjt)) || (AppType.SYNC_CJT_SALE_DISPATCH_DATA_TO_MULTI_TABLE.getCode().equals(syncLarkAppType().getCode())
+//                    && CjtAccountEnum.ONE.getCode().equals(cjt))) {
                 String asynchronous = getAsynchronousKey(cjt);
                 Object cacheObject = redisCache.getCacheObject(asynchronous);
                 if (cacheObject != null) {
@@ -97,9 +97,9 @@ public abstract class SyncAccountsJobAbstract {
                 }
                 redisCache.setCacheObject(asynchronous, asynchronous, 2, TimeUnit.HOURS);
                 return Boolean.TRUE;
-            } else {
-                return false;
-            }
+//            } else {
+//                return false;
+//            }
         }
         return false;
     }
@@ -486,13 +486,14 @@ public abstract class SyncAccountsJobAbstract {
                 errorKey.add(String.format("【%s,%s】", uniqueKey, e.getMessage()));
             }
         }
+        if (!CollectionUtils.isEmpty(relationList)) {
+            erpLarkRelationMapper.batchInsert(relationList);
+        }
         if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(waitUpdateList)) {
             addRecordRequest.setAppTableRecords(waitUpdateList.toArray(new AppTableRecord[0]));
             updateTableRecordBatch(addRecordRequest);
         }
-        if (!CollectionUtils.isEmpty(relationList)) {
-            erpLarkRelationMapper.batchInsert(relationList);
-        }
+
         return errorKey;
     }