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 74ee3c6..4515b5b 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 @@ -164,6 +164,9 @@ public abstract class SyncAccountsJobAbstract { endTimeMap.put("value",endTime); List> timeRange = Arrays.asList(startTimeMap, endTimeMap); String queryKey = String.format("%s.AuditedTime",getQueryKey()); + if (AppType.SYNC_CJT_SALE_DISPATCH_DATA_TO_MULTI_TABLE.equals(syncLarkAppType())){ + queryKey = String.format("%s.createdtime",getQueryKey()); + } jsonObject.put(queryKey,timeRange); return jsonObject; @@ -312,10 +315,12 @@ public abstract class SyncAccountsJobAbstract { larkKey = respBody.getRecord().getRecordId(); relationList.add(buildErpLarkRelation(uniqueKey,larkKey)); }else { - //根据本地保留映射,确认飞书的更新行,更新后防止影响后续更新,需要将行id进行置空 - addRecordRequest.setRecord(larkKey); - larkTableHelper.updateTableRecord(addRecordRequest); - addRecordRequest.setRecord(null); + if (!AppType.SYNC_CJT_SALE_DISPATCH_DATA_TO_MULTI_TABLE.equals(syncLarkAppType())){ + //根据本地保留映射,确认飞书的更新行,更新后防止影响后续更新,需要将行id进行置空 + addRecordRequest.setRecord(larkKey); + larkTableHelper.updateTableRecord(addRecordRequest); + addRecordRequest.setRecord(null); + } } }catch (Exception e){ log.error("{} addOrUpdate exception {}", this.getClassName(),uniqueKey, e);