oracle数据同步代码

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/entity/CheckList.java

@@ -52,7 +52,7 @@ public class CheckList implements Serializable {
 	/**年龄*/
 	@Excel(name = "年龄", width = 15)
     @ApiModelProperty(value = "年龄")
-    private java.lang.Integer age;
+    private java.lang.String age;
 	/**科室*/
 	@Excel(name = "科室", width = 15)
     @ApiModelProperty(value = "科室")

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

@@ -10,6 +10,7 @@ import org.quartz.Job;
 import org.quartz.JobExecutionContext;
 import org.quartz.JobExecutionException;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
 
 import java.util.Date;
 import java.util.HashMap;
@@ -21,7 +22,8 @@ import java.util.Map;
  * 每个小时执行一次
  */
 @Slf4j
-public class XCFYDatav_check_listJob implements Job {
+@Component
+public class XCFYDatav_check_listJob {
 
     @Autowired
     XCFYDataTransferService xcfyDataTransferService;
@@ -30,9 +32,9 @@ public class XCFYDatav_check_listJob implements Job {
 
     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";
+        String sql = "select * from V_CHECK_LIST where rownum<1000 %s";
         while (true) {
             log.info("开始同步v_check_list数据");
             String whereSql = "";

jeecg-module-system/jeecg-system-start/src/test/java/org/jeecg/AfterwardsAuditDataTest.java

@@ -11,6 +11,7 @@ import org.jeecg.modules.medical.entity.MedicalInsRuleInfo;
 import org.jeecg.modules.medical.entity.SttlMasterBill;
 import org.jeecg.modules.medical.entity.SttlMasterDetailBill;
 import org.jeecg.modules.medical.job.AfterWaringLogTestJob;
+import org.jeecg.modules.medical.job.XCFYDatav_check_listJob;
 import org.jeecg.modules.medical.ruleengine.RuleEngine;
 import org.jeecg.modules.medical.ruleengine.SPELUtil;
 import org.jeecg.modules.medical.service.IAfterwardsAuditDetailService;
@@ -104,6 +105,17 @@ public class AfterwardsAuditDataTest {
     IMedicalInsRuleInfoService medicalInsRuleInfoService;
     @Autowired
     RedisTemplate redisTemplate;
+    @Autowired
+    org.jeecg.modules.medical.job.XCFYDatav_check_listJob XCFYDatav_check_listJob;
+
+    @Test
+    public void testXCFYDatav_check_listJob(){
+        try {
+            XCFYDatav_check_listJob.execute(null);
+        } catch (JobExecutionException e) {
+            e.printStackTrace();
+        }
+    }
 
     @Test
     public void testMAB() {

jeecg-module-system/jeecg-system-start/src/test/java/org/jeecg/spel/SPELTest.java

@@ -20,6 +20,7 @@ public class SPELTest {
 
 
     public void testMap(){
+
 //        Map<String,Object> paramMap = paramMapTheadLocal.get();
 //        Object testListObject = paramMap.get("112122");
 //        if(testListObject instanceof List){
@@ -94,18 +95,8 @@ public class SPELTest {
 
 
     public static void main(String[] args) {
-        SPELTest spelTest = new SPELTest();
-        spelTest.testMap();
-        String test = "select * from dual where %s and %s";
-        List<String> testList = new ArrayList<>();
-        testList.add("11");
-        testList.add("22");
-        String sql = String.format(test,testList.toArray(new String[0]));
-        System.out.println(sql);
-        ExpressionParser parser = new SpelExpressionParser();
-        StandardEvaluationContext ctx = new StandardEvaluationContext();
-        Expression expression3 = parser.parseExpression("1==1");
-        Boolean value3 = expression3.getValue(ctx, Boolean.class);
-        System.out.println("value3:"+value3);
+        String s = "sfsdfsdf %s";
+        s = String.format(s, "where ");
+        System.out.println(s);
     }
 }