Kaynağa Gözat

oracle数据同步代码

0027005599 2 yıl önce
ebeveyn
işleme
1c6097df62

+ 3 - 3
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDatav_check_listJob.java

@@ -41,14 +41,14 @@ public class XCFYDatav_check_listJob {
             Long hsdId = getLastId();
             log.info("开始同步v_check_list数据,获取上个同步记录访问最大主键ID:{}", hsdId);
             Map<String, Object> paramMap = new HashMap<>();
-            if (null != hsdId && hsdId > 0) {
+            if (null != hsdId) {
                 whereSql = "and ID>:ID";
                 paramMap.put("ID", hsdId);
             }
 
-            sql = String.format(sql, whereSql);
+            String querySql = String.format(sql, whereSql);
 
-            Integer count = xcfyDataTransferService.transferDataList(sql, insertSql, paramMap, new TransferDataCallFunction() {
+            Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
                 @Override
                 public void transferData(Map<String, Object> dataMap) throws Exception {
                     dataMap.put("CREATE_BY", "auto");