销售出库单数据采用创建时间查询,且不更新数据
continuous-integration/drone/push Build is passing Details

沃森川job同步飞书
YXY 1 year ago
parent d36d06ce89
commit 996bcefc98

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

Loading…
Cancel
Save