oracle数据同步代码

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDataV_MEDICAL_RECORD_HOMEPAGEJob.java

@@ -48,10 +48,8 @@ public class XCFYDataV_MEDICAL_RECORD_HOMEPAGEJob implements Job {
             }
 
 
-            sql = String.format(sql, whereSql);
-
-
-            Integer count = xcfyDataTransferService.transferDataList(sql, insertSql, paramMap, new TransferDataCallFunction() {
+            String querySql = String.format(sql, whereSql);
+            Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
                 @Override
                 public void transferData(Map<String, Object> dataMap) throws Exception {
                     dataMap.put("CREATE_BY", "auto");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDataV_OPERATIONJob.java

@@ -53,9 +53,9 @@ public class XCFYDataV_OPERATIONJob implements Job {
                 whereSql = "and operation_end_time>:OPERATION_END_TIME";
                 paramMap.put("OPERATION_END_TIME", opEndDate);
             }
-            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");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDataV_OPERATIVE_ITEMSJob.java

@@ -40,12 +40,8 @@ public class XCFYDataV_OPERATIVE_ITEMSJob implements Job {
         while (true) {
             log.info("开始同步V_OPERATIVE_ITEMS数据 startRows:{} endRows:{}", startRows, endRows);
             Map<String, Object> paramMap = new HashMap<>();
-
-
-            sql = String.format(sql, startRows, endRows);
-
-
-            Integer count = xcfyDataTransferService.transferDataList(sql, insertSql, paramMap, new TransferDataCallFunction() {
+            String queyrSql = String.format(sql, startRows, endRows);
+            Integer count = xcfyDataTransferService.transferDataList(queyrSql, insertSql, paramMap, new TransferDataCallFunction() {
                 @Override
                 public void transferData(Map<String, Object> dataMap) throws Exception {
                     dataMap.put("CREATE_BY", "auto");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDataV_PRESCRIPTION_ORDERJob.java

@@ -52,11 +52,8 @@ public class XCFYDataV_PRESCRIPTION_ORDERJob implements Job {
                 whereSql = "and ORDER_TIME>:ORDER_TIME";
                 paramMap.put("ORDER_TIME", orderTime);
             }
-
-
-            sql = String.format(sql, whereSql);
-
-            Integer count = xcfyDataTransferService.transferDataList(sql, insertSql, paramMap, new TransferDataCallFunction() {
+            String querySql = String.format(sql, whereSql);
+            Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
                 @Override
                 public void transferData(Map<String, Object> dataMap) throws Exception {
                     dataMap.put("CREATE_BY", "auto");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDataV_STAFF_INFOJob.java

@@ -40,10 +40,8 @@ public class XCFYDataV_STAFF_INFOJob implements Job {
                 whereSql = "and DOCTOR_ID>:DOCTOR_ID";
                 paramMap.put("DOCTOR_ID", hsdId);
             }
-
-
-            sql = String.format(sql, whereSql);
-            Integer count = xcfyDataTransferService.transferDataList(sql, insertSql, paramMap, new TransferDataCallFunction() {
+            String querySql = String.format(sql, whereSql);
+            Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
                 @Override
                 public void transferData(Map<String, Object> dataMap) throws Exception {
                     dataMap.put("CREATE_BY", "auto");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDataV_TREATMENT_ITEMSJob.java

@@ -43,12 +43,8 @@ public class XCFYDataV_TREATMENT_ITEMSJob implements Job {
         while (true) {
             log.info("开始同步V_TREATMENT_ITEMS数据 startRows:{} endRows:{}", startRows, endRows);
             Map<String, Object> paramMap = new HashMap<>();
-
-
-            sql = String.format(sql, startRows, endRows);
-
-
-            Integer count = xcfyDataTransferService.transferDataList(sql, insertSql, paramMap, new TransferDataCallFunction() {
+            String querySql = String.format(sql, startRows, endRows);
+            Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
                 @Override
                 public void transferData(Map<String, Object> dataMap) throws Exception {
                     dataMap.put("CREATE_BY", "auto");

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

@@ -22,8 +22,7 @@ import java.util.Map;
  * 每个小时执行一次
  */
 @Slf4j
-@Component
-public class XCFYDatav_check_listJob {
+public class XCFYDatav_check_listJob implements Job{
 
     @Autowired
     XCFYDataTransferService xcfyDataTransferService;
@@ -32,7 +31,7 @@ public class XCFYDatav_check_listJob {
 
     String insertSql = "INSERT INTO check_list (id, hisid, patient_id, gender, age, department, inp_outpatient_number, check_list_num, item_id, item_name, check_time, create_time, create_by, report_time) VALUES (:ID,:HISID,:PATIENT_ID,:GENDER,:AGE,:DEPARTMENT,:INP_OUTPATIENT_NUMBER,:CHECK_LIST_NUM,:ITEM_ID,:ITEM_NAME,:CHECK_TIME,:CREATE_TIME,:CREATE_BY,:REPORT_TIME)";
 
-
+    @Override
     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
         String sql = "select * from V_CHECK_LIST where rownum<1000 %s";
         while (true) {
@@ -45,9 +44,7 @@ public class XCFYDatav_check_listJob {
                 whereSql = "and ID>:ID";
                 paramMap.put("ID", hsdId);
             }
-
             String querySql = String.format(sql, whereSql);
-
             Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
                 @Override
                 public void transferData(Map<String, Object> dataMap) throws Exception {

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDatav_diagnose_itemsJob.java

@@ -41,15 +41,15 @@ public class XCFYDatav_diagnose_itemsJob implements Job {
             Long hsdId = getLastId();
             log.info("开始同步v_diagnose_items数据,获取上个同步记录访问最大主键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");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDatav_his_patientJob.java

@@ -47,9 +47,9 @@ public class XCFYDatav_his_patientJob implements Job {
                 paramMap.put("ID", id);
             }
 
-            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");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDatav_hospitalizatio_settle_detailJob.java

@@ -45,9 +45,9 @@ public class XCFYDatav_hospitalizatio_settle_detailJob implements Job {
             }
 
 
-            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");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDatav_master_admission_billJob.java

@@ -56,9 +56,9 @@ public class XCFYDatav_master_admission_billJob implements Job {
                 paramMap.put("ID", id);
             }
 
-            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");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDatav_material_itemsJob.java

@@ -40,12 +40,8 @@ public class XCFYDatav_material_itemsJob implements Job {
         while (true) {
             log.info("开始同步v_material_items数据 startRows:{} endRows:{}", startRows, endRows);
             Map<String, Object> paramMap = new HashMap<>();
-
-
-            sql = String.format(sql, startRows, endRows);
-
-
-            Integer count = xcfyDataTransferService.transferDataList(sql, insertSql, paramMap, new TransferDataCallFunction() {
+            String querySql = String.format(sql, startRows, endRows);
+            Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
                 @Override
                 public void transferData(Map<String, Object> dataMap) throws Exception {
                     dataMap.put("CREATE_BY", "auto");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDatav_medical_insurance_drugsJob.java

@@ -42,10 +42,10 @@ public class XCFYDatav_medical_insurance_drugsJob implements Job {
                 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");

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDatav_outpatient_settle_detailsJob.java

@@ -49,10 +49,8 @@ public class XCFYDatav_outpatient_settle_detailsJob implements Job {
                 whereSql = "and ID>:ID";
                 paramMap.put("ID", hsdId);
             }
-
-
-            sql = String.format(sql, whereSql);
-            Integer count = xcfyDataTransferService.transferDataList(sql, insertSql, paramMap, new TransferDataCallFunction() {
+            String querySql = String.format(sql, whereSql);
+            Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
                 @Override
                 public void transferData(Map<String, Object> dataMap) throws Exception {
                     dataMap.put("CREATE_BY", "auto");