diff --git a/src/main/java/com/celnet/datadump/service/impl/DataDumpSpecialServiceImpl.java b/src/main/java/com/celnet/datadump/service/impl/DataDumpSpecialServiceImpl.java index 770e271..b816025 100644 --- a/src/main/java/com/celnet/datadump/service/impl/DataDumpSpecialServiceImpl.java +++ b/src/main/java/com/celnet/datadump/service/impl/DataDumpSpecialServiceImpl.java @@ -262,8 +262,9 @@ public class DataDumpSpecialServiceImpl implements DataDumpSpecialService { // 判断是否存在要排除的id salesforceParam.setMaxId(maxId); salesforceParam.setBeginModifyDate(dataObject.getLastUpdateDate()); + salesforceParam.setUpdateField(dataFieldService.returnUpdateDateField(dataObject.getName())); map.put("param", salesforceParam); - String sql = SqlUtil.showSql("com.celnet.datadump.mapper.SalesforceMapper.listOrderByIdNew", map); + String sql = SqlUtil.showSql("com.celnet.datadump.mapper.SalesforceMapper.listOrderByIdShare", map); log.info("query sql: {}", sql); XxlJobLogger.log("query sql: {}", sql); QueryResult queryResult = connect.queryAll(sql); diff --git a/src/main/resources/mapper/SalesforceMapper.xml b/src/main/resources/mapper/SalesforceMapper.xml index 45ad41a..585eac0 100644 --- a/src/main/resources/mapper/SalesforceMapper.xml +++ b/src/main/resources/mapper/SalesforceMapper.xml @@ -238,4 +238,43 @@ + + +