测试数据

ruoyi-quartz/src/main/java/com/ruoyi/quartz/domain/CJTJobContext.java

@@ -20,6 +20,8 @@ public class CJTJobContext implements Serializable {
     private String appKey;
     private String appSecret;
     private String contentType;
+    private String queryFromTime;
+    private String queryToTime;
 
     public CJTJobContext(String appKey, String appSecret) {
         this.appKey = appKey;

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

@@ -31,8 +31,8 @@ public class ManufactureOrderSyncJob extends SyncAccountsJobAbstract{
     }
 
     @Override
-    public void executeSync() {
-        super.executeSync();
+    public void executeSync(String queryFromTime,String queryToTime) {
+        super.executeSync(queryFromTime,queryToTime);
     }
 
     @Override

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

@@ -35,8 +35,8 @@ public class PurchaseArrivalOpenSyncJob extends SyncAccountsJobAbstract{
     }
 
     @Override
-    public void executeSync() {
-        super.executeSync();
+    public void executeSync(String queryFromTime,String queryToTime) {
+        super.executeSync(queryFromTime,queryToTime);
     }
 
     @Override

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

@@ -35,8 +35,8 @@ public class PurchaseOrderSyncJob extends SyncAccountsJobAbstract{
     }
 
     @Override
-    public void executeSync() {
-        super.executeSync();
+    public void executeSync(String queryFromTime,String queryToTime) {
+        super.executeSync(queryFromTime,queryToTime);
     }
 
     @Override

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

@@ -35,8 +35,8 @@ public class SaleDeliverySyncJob extends SyncAccountsJobAbstract{
     }
 
     @Override
-    public void executeSync() {
-        super.executeSync();
+    public void executeSync(String queryFromTime,String queryToTime) {
+        super.executeSync(queryFromTime,queryToTime);
     }
 
     @Override

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

@@ -35,8 +35,8 @@ public class SaleDispatchSyncJob extends SyncAccountsJobAbstract{
     }
 
     @Override
-    public void executeSync() {
-        super.executeSync();
+    public void executeSync(String queryFromTime,String queryToTime) {
+        super.executeSync(queryFromTime,queryToTime);
     }
 
     @Override

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

@@ -35,8 +35,8 @@ public class SaleOrderSyncJob extends SyncAccountsJobAbstract{
     }
 
     @Override
-    public void executeSync() {
-        super.executeSync();
+    public void executeSync(String queryFromTime,String queryToTime) {
+        super.executeSync(queryFromTime,queryToTime);
     }
 
     @Override

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

@@ -1,5 +1,6 @@
 package com.ruoyi.quartz.task.CJT;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.lark.oapi.service.bitable.v1.model.CreateAppTableRecordRespBody;
 import com.ruoyi.common.constant.RedisConstants;
@@ -80,8 +81,10 @@ public abstract class SyncAccountsJobAbstract {
      */
     private static final String CERTIFICATE = "OXYwHSWAc22UPHxfIUM0SSFZwziCLmBfOzBaN+PCNp0SNfV3ewYIaWLJCCrYToCU46x3PJO8t4TXV57bGpbiqClld5DiAkQ3EX1qqxoyaE9J0HAsfnp/PkPurKMQewBHICM2oEPRyLU5GUQjTCucfLvO4xT3DKlelbjBsIkKLqs=";
 
-    public void executeSync() {
+    public void executeSync(String queryFromTime,String queryToTime) {
         CJTJobContext context = new CJTJobContext(CJT_APP_KEY, CJT_APP_SECRET);
+        context.setQueryFromTime(queryFromTime);
+        context.setQueryToTime(queryToTime);
         try {
             log.info("===================== {} strat ======================",this.getClassName());
             //重置ticket
@@ -136,11 +139,17 @@ public abstract class SyncAccountsJobAbstract {
      * 获取查询条件
      */
     protected abstract String getQueryKey();
-    protected JSONObject getQueryCondition(){
+    protected JSONObject getQueryCondition(CJTJobContext context){
         JSONObject jsonObject = new JSONObject();
         LocalDateTime now = LocalDateTime.now();
-        String startTime = DateUtils.ldt2str(now.minusHours(10L), DateUtils.YYYY_MM_DD_HH_MM_SS);
-        String endTime = DateUtils.ldt2str(now, DateUtils.YYYY_MM_DD_HH_MM_SS);
+        String startTime = context.getQueryFromTime();
+        if (StringUtils.isEmpty(startTime)){
+            startTime = DateUtils.ldt2str(now.minusMinutes(2L), DateUtils.YYYY_MM_DD_HH_MM_SS);
+        }
+        String endTime = context.getQueryToTime();
+        if (StringUtils.isEmpty(endTime)){
+            endTime = DateUtils.ldt2str(now, DateUtils.YYYY_MM_DD_HH_MM_SS);
+        }
         Map<String, String> startTimeMap = new HashMap<>();
         startTimeMap.put("text",startTime);
         startTimeMap.put("value",startTime);
@@ -150,6 +159,9 @@ public abstract class SyncAccountsJobAbstract {
         List<Map<String, String>> timeRange = Arrays.asList(startTimeMap, endTimeMap);
         String queryKey = String.format("%s.AuditedTime",getQueryKey());
         jsonObject.put(queryKey,timeRange);
+
+        log.info("++++++++++++++++++++++++");
+        log.info(jsonObject.toJSONString());
         return jsonObject;
     }
 
@@ -173,11 +185,11 @@ public abstract class SyncAccountsJobAbstract {
         LarkCompanyRelation companyRelation = context.getCompanyRelation();
         LarkTableRelation tableRelation = context.getTableRelation();
         LarkTableRequest addRecordRequest = new LarkTableRequest(companyRelation.getAppId(), companyRelation.getSecret(), tableRelation.getToAppToken(), tableRelation.getToTableId());
-        while (page <= total) {
+//        while (page <= total) {
             try {
                 //初始化数据
                 if (cjtRequestBody == null) {
-                    cjtRequestBody = new CJTRequestBody(page, PAGE_SIZE, getQueryFields(), getQueryCondition());
+                    cjtRequestBody = new CJTRequestBody(page, PAGE_SIZE, getQueryFields(), getQueryCondition(context));
                 } else {
                     cjtRequestBody.setPageIndex(page);
                 }
@@ -191,6 +203,8 @@ public abstract class SyncAccountsJobAbstract {
                 total = response.getTotalPageNum();
                 //实际返回数据
                 List<List<String>> rows = response.getRows();
+                log.info(String.valueOf(total));
+                log.info(JSONArray.toJSONString(rows));
                 if (CollectionUtils.isEmpty(rows)){
                     return;
                 }
@@ -207,7 +221,7 @@ public abstract class SyncAccountsJobAbstract {
             } finally {
                 page++;
             }
-        }
+//        }
     }
 
     private List<String> getUniqueKey(List<String> keyList,List<List<String>> rows) {