diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java index 682a5f8..f2cd170 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java +++ b/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; }