深圳肿瘤医院温控接口(开发中)

GetDataByView/src/main/java/com/jyxt/getdatabyview/GetDataByViewApplication.java

@@ -1,12 +1,13 @@
 package com.jyxt.getdatabyview;
 
-import com.jyxt.getdatabyview.view.QualityIndicator;
-import com.jyxt.getdatabyview.view.repository.LISViewRepository;
-import com.jyxt.getdatabyview.view.repository.QualityIndicatorRepository;
+import com.jyxt.getdatabyview.view.HuaTuRepository;
 
+import com.jyxt.getdatabyview.view.IBPSRepository;
+import com.jyxt.getdatabyview.view.entity.WSDEntity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -20,10 +21,10 @@ public class GetDataByViewApplication implements CommandLineRunner{
     private static final Logger log = LoggerFactory.getLogger(GetDataByViewApplication.class);
 
     @Autowired
-    private LISViewRepository lisViewRepository;
+    private HuaTuRepository huaTuRepository;
 
     @Autowired
-    private QualityIndicatorRepository qualityIndicatorRepository;
+    private IBPSRepository ibpsRepository;
 
     public static void main(String[] args) {
         SpringApplication.run(GetDataByViewApplication.class, args);
@@ -35,25 +36,24 @@ public class GetDataByViewApplication implements CommandLineRunner{
     @Autowired
     private ConfigurableApplicationContext context;
 
+    @Value("${config.run_mode}")
+    private String run_mode;
+
     @Override
     public void run(String... args) throws Exception {
 //        System.out.println("in run");
         log.info("<-------------new turn start...------------->");
-        List<QualityIndicator> qiList = qualityIndicatorRepository.query();
-        if(qiList != null){
-            for (QualityIndicator qi : qiList) {
-                try {
-                    String pingjiaId = qi.getId();
-                    String zhiliangzhibia = qi.getzhiliangzhibia();
-                    String bianzhishijian = qi.getbianzhishijian();
-                    String yuanshishuju = qi.getYuanshishuju();
-                    handleData.startHandleData(pingjiaId,zhiliangzhibia,bianzhishijian,yuanshishuju);
-
-                }catch (Exception ex){
-                    log.error(ex.getMessage());
-                }
+        if(run_mode.equals("1")){
+            log.info("run_mode=1,qry and insert new data");
+            List<WSDEntity> wsdEntityList = huaTuRepository.query(ibpsRepository.getExistID());
+            if(wsdEntityList != null){
+                handleData.startHandleData(wsdEntityList);
             }
+        } else if(run_mode.equals("0")){
+            log.info("run_mode=0,qry uncontrol judge");
+            handleData.unControlJudge();
         }
+
         log.info("<-------------this turn finish...------------->");
         context.close(); // 直接关闭上下文
     }

GetDataByView/src/main/java/com/jyxt/getdatabyview/HandleData.java

@@ -1,5 +1,7 @@
 package com.jyxt.getdatabyview;
 
+import com.jyxt.getdatabyview.view.IBPSRepository;
+import com.jyxt.getdatabyview.view.entity.WSDEntity;
 import com.jyxt.getdatabyview.view.repository.LISViewRepository;
 import com.jyxt.getdatabyview.view.repository.QualityIndicatorRepository;
 import org.slf4j.Logger;
@@ -15,112 +17,26 @@ public class HandleData {
     private static final Logger log = LoggerFactory.getLogger(GetDataByViewApplication.class);
 
     @Autowired
-    private LISViewRepository lisViewRepository;
+    private IBPSRepository ibpsRepository;
+
 
-    @Autowired
-    private QualityIndicatorRepository qualityIndicatorRepository;
 
     private static final String RESULT_DELIMITER = "\\^";
 
-    private static final List<String> qualityIndicatorList = Collections.unmodifiableList(
-            Arrays.asList(
-                    "总标本不合格率",                // 0
-                    "抗凝标本凝集率",                // 1
-                    "标本类型错误率",                // 2
-                    "标本容器错误率",                // 3
-                    "标本溶血率",                   // 4
-                    "标本采集量错误率",              // 5
-                    "急诊常规实验室内TAT中位数",      // 6
-                    "急诊生化免疫实验室内TAT中位数",   // 7
-                    "急诊凝血实验室内TAT中位数",      // 8
-                    "急诊血常规检验前周转时间中位数",   // 9
-                    "急诊血常规实验室内周转时间中位数", // 10
-                    "常规检验报告发放TAT时间符合率",   // 11
-                    "检验报告不正确率",              // 12
-                    "危急值通报率",                 // 13
-                    "危急值通报及时率",              // 14
-                    "标本合格率",                   // 15
-                    "TAT时间合格率",                // 16
-                    "报告准确率",                   // 17
-                    "危急值通报符合率"               // 18
-            )
-    );
 
-    public void startHandleData(String pingjiaId,String zhiliangzhibia,String bianzhishijian, String yuanshishuju) {
 
-        if (qualityIndicatorList.contains(zhiliangzhibia)){
-//            System.out.println(output);
-            log.info("ID: {}, zhiliangzhibia: {}, bianzhishijian: {}", pingjiaId, zhiliangzhibia, bianzhishijian);
-            int QIIndex = qualityIndicatorList.indexOf(zhiliangzhibia);
-            String DataDetail = "";
-            String dateRange = DateRangeUtil.getDateRange(bianzhishijian);
-            String[] resultParts = lisViewRepository.query(QIIndex,dateRange).split(RESULT_DELIMITER);
-//            String[] resultParts = new String[] {"", "", ""};
-//            if (pingjiaId.equals("1367710945618427904")) {
-//                resultParts = new String[] {"100", "10000", "10000"};
-//            }
-            String resultValue = resultParts[0];
-            if (resultValue.startsWith(".")) {
-                resultValue = "0" + resultValue;
-            }
-            String IsQualified = null;
-            if ((!Objects.equals(resultValue, ""))){
-                IsQualified = ValueEvaluator.evaluateValue(resultValue,yuanshishuju);
-            }
-            //总数统计
-            if (resultParts.length==2){
-                String total = resultParts[1];
-                if ((!Objects.equals(resultValue, ""))&&(!Objects.equals(resultValue,null))&&(!Objects.equals(resultValue,"-1"))) {
-//                System.out.println("output:"+ResultValue);
-                    log.info("Get LIS RetVal:{},zhiliangzhibiao:{},bianzhishijian:{}",resultParts,zhiliangzhibia,bianzhishijian);
-                    if (QIIndex==6){
-                        DataDetail = "同期临检(住院)及临检(门诊)的三大常规(血、尿、便)标本共 "+resultParts[1]+" 例";
-                    } else if (QIIndex==7){
-                        DataDetail = "同期临检急诊组的急诊生化、免疫标本共 "+resultParts[1]+" 例";
-                    } else if (QIIndex==8){
-                        DataDetail = "同期临检(住院)及临检(门诊) 的急诊血凝标本共 "+resultParts[1]+" 例";
-                    } else if ((QIIndex==9)||(QIIndex==10)){
-                        DataDetail = "同期临检(住院)及临检(门诊) 的急诊血常规标本共 "+resultParts[1]+" 例";
-                    }
-//                    qualityIndicatorRepository.save(pingjiaId, resultValue,total,DataDetail,IsQualified);
-                    //分子不需要整数
-                    qualityIndicatorRepository.save(pingjiaId, resultValue,resultValue,DataDetail,IsQualified);
-                }
-            } else if (resultParts.length==3){
-                String numerator = resultParts[1];
-                String denominator = resultParts[2];
-                if ((!Objects.equals(resultValue, ""))&&(!Objects.equals(resultValue,null))&&(!Objects.equals(resultValue,"-1"))){
-                    log.info("Get LIS RetVal:{},zhiliangzhibiao:{},bianzhishijian:{}",resultParts,zhiliangzhibia,bianzhishijian);
-                    if (QIIndex==0){
-                        DataDetail = "不合格标本数 "+resultParts[1]+" 例,同期标本总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==1){
-                        DataDetail = "凝集的标本数 "+resultParts[1]+" 例,同期需抗凝的标本总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==2){
-                        DataDetail = "类型错误或不适当的标本数 "+resultParts[1]+" 例,同期标本总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==3){
-                        DataDetail = "采集容器错误的标本数 "+resultParts[1]+" 例,同期标本总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==4){
-                        DataDetail = "溶血的标本 "+resultParts[1]+" 例,同期标本总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==5){
-                        DataDetail = "量不足或过多(抗凝标本)的标本数 "+resultParts[1]+" 例,同期标本总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==12){
-                        DataDetail = "实验室发出的不正确报告数 "+resultParts[1]+" 例,报告总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==13){
-                        DataDetail = "已通报危急值数 "+resultParts[1]+" 例,同期需要通报危急值总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==14){
-                        DataDetail = "危急值通报时间(从结果确认到与临床医生交流的时间)满足规定时间的检验项目数 "+resultParts[1]+" 例,同期需要危急值通报的检验项目总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==15){
-                        DataDetail = "全年合格标本总数 "+resultParts[1]+" 例,全年标本总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==17){
-                        DataDetail = "实验室发出的正确报告数 "+resultParts[1]+" 例,同期实验室发出报告总数 "+resultParts[2]+" 例";
-                    } else if (QIIndex==18){
-                        DataDetail = "危急值通报时间(从结果确认到与临床医生交流的时间)满足规定时间的检验项目数 "+resultParts[1]+" 例,同期需要危急值通报的检验项目总数 "+resultParts[2]+" 例";
-                    }
-                    qualityIndicatorRepository.save(pingjiaId,resultValue,numerator,denominator,DataDetail,IsQualified);
-                }
-            } else {
-                log.info("no result to save:zhiliangzhibiao:{},bianzhishijian:{}",zhiliangzhibia,bianzhishijian);
+    public void startHandleData(List<WSDEntity> wsdEntityList) {
+        for (WSDEntity wsdEntity : wsdEntityList) {
+            try {
+//                log.info("wsdEntity:"+wsdEntity.getCollectName());
+                ibpsRepository.save(wsdEntity);
+            }catch (Exception ex){
+                log.error(ex.getMessage());
             }
         }
     }
+
+    public void unControlJudge(){
+
+    }
 }

GetDataByView/src/main/java/com/jyxt/getdatabyview/Test.java

@@ -0,0 +1,45 @@
+package com.jyxt.getdatabyview;
+
+import java.io.*;
+import java.util.ArrayList;
+import java.util.regex.*;
+
+public class Test {
+    public static void main(String[] args) {
+        String desktopPath = System.getProperty("user.home") + "/Desktop/";
+        String inputFile = desktopPath + "sql.txt";
+        String outputFile = desktopPath + "sql_converted.txt";
+
+        try (BufferedReader reader = new BufferedReader(new FileReader(inputFile));
+             BufferedWriter writer = new BufferedWriter(new FileWriter(outputFile))) {
+
+            Pattern pattern = Pattern.compile("'(.*?)'");
+            String line;
+
+            while ((line = reader.readLine()) != null) {
+                 System.out.println("read line: " + line);
+                // 匹配所有单引号包裹的内容（非贪婪模式）
+                Matcher matcher = pattern.matcher(line);
+                ArrayList<String> matches = new ArrayList<>();
+
+                // 收集所有匹配结果
+                while (matcher.find()) {
+                    matches.add(matcher.group(1));
+                }
+                // 检查是否至少有7个匹配项
+                if (matches.size() >= 7) {
+                    String curTimeStap =  matches.get(matches.size() - 7);
+                    String convertedLine = line.replace(curTimeStap,"FROM_UNIXTIME("+curTimeStap+"/1000)");
+                    writer.write(convertedLine + "\n");
+                    System.out.println("convert line: " + convertedLine);
+                } else {
+                    throw new IllegalArgumentException("字符串中单引号包裹的值少于7个");
+                }
+            }
+
+            System.out.println("转换完成，输出文件已保存到桌面: " + outputFile);
+        } catch (IOException e) {
+            System.err.println("处理文件时出错: " + e.getMessage());
+        }
+    }
+}

GetDataByView/src/main/java/com/jyxt/getdatabyview/view/HuaTuRepository.java

@@ -0,0 +1,182 @@
+package com.jyxt.getdatabyview.view;
+
+import com.jyxt.getdatabyview.view.entity.CollectorEntity;
+import com.jyxt.getdatabyview.view.entity.EquipResult;
+import com.jyxt.getdatabyview.view.entity.ToLoggerInfo;
+import com.jyxt.getdatabyview.view.entity.WSDEntity;
+import com.jyxt.getdatabyview.view.repository.LISViewRepository;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.stereotype.Repository;
+import org.springframework.beans.factory.annotation.Value;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+
+
+@Repository
+public class HuaTuRepository {
+
+    private static final Logger log = LoggerFactory.getLogger(LISViewRepository.class);
+
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
+    @Value("${fetch.condition}")
+    private String condition;
+
+
+    public List<WSDEntity> query(List<String> existIDList) throws ParseException {
+        /**
+         * 正式启用开启这一段
+         String sqlStr ="select LOGGER_SN as LOGSN,GROUP_ID,LOGGER_NAME as LOGNAME,LOGGER_CHNUM as CHNUM,"+
+                        "CHONE_TYPE as TYPE1,CHONE_HIGH as HIGH1,CHONE_LOW as LOW1,CHONE_DOT as DOT1,"+
+                        "CHTWO_TYPE as TYPE2,CHTWO_HIGH as HIGH2,CHTWO_LOW as LOW2,CHTWO_DOT as DOT2,"+
+                        "CHTHR_TYPE as TYPE3,CHTHR_HIGH as HIGH3,CHTHR_LOW as LOW3,CHTHR_DOT as DOT3,"+
+                        "CHFOU_TYPE as TYPE4,CHFOU_HIGH as HIGH4,CHFOU_LOW as LOW4,CHFOU_DOT as DOT4 "+
+                        "from TO_LOGGER_INFO where LOGGER_STATE='1'"
+
+        * */
+        String sql = "select * from TO_LOGGER_INFO";
+        log.info("excute sql:" + sql);
+        RowMapper<ToLoggerInfo> infoRowMapper = new BeanPropertyRowMapper<>(ToLoggerInfo.class);
+        RowMapper<EquipResult> humitureRowMapper = new BeanPropertyRowMapper<>(EquipResult.class);
+        RowMapper<CollectorEntity> collectorRowMapper = new BeanPropertyRowMapper<>(CollectorEntity.class);
+        String collectorSql = "select id_,DeviceID,DeviceNo,DeviceName,DeviceType,CollectID,CollectName from equip_relation where enable='1'";
+        List<CollectorEntity> collectorList = jdbcTemplate.query(collectorSql, collectorRowMapper);
+        List<ToLoggerInfo> equipList = jdbcTemplate.query(sql, infoRowMapper);
+        Set<WSDEntity> wsdSet = new LinkedHashSet<>();
+
+
+        SimpleDateFormat saveToIDFormat = new SimpleDateFormat("yyyyMMddHHmm");
+        SimpleDateFormat saveToDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+        // 创建SimpleDateFormat对象并指定格式
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        // 格式化当前日期为字符串
+        String formattedDate = sdf.format(new Date());
+        // 将格式化后的字符串解析回Date对象
+        Date currentDate = sdf.parse(formattedDate);
+        for (ToLoggerInfo toLoggerInfo : equipList) {
+            String equipSn = toLoggerInfo.getLOGSN();
+            /**
+             * 正式启用开启这一段
+             String subSql = "SELECT * FROM LOGS_"+equipSn+" WHERE "+condition + " order by LOGS_TIME";
+             **/
+            String subSql = "SELECT * FROM LOGS_" + equipSn + " WHERE DATE(LOGS_TIME) = CURDATE()-5 ORDER BY LOGS_TIME";
+            log.info("Execute SQL: " + subSql);
+            /**
+             * 正式启用开启这一段
+             String sqlQry = "SELECT COUNT(*) as result FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'huatu' AND TABLE_NAME = 'LOGS_"+ equipSn +"'";
+             **/
+            String sqlQry = "SELECT COUNT(*) as result FROM information_schema.tables WHERE table_schema = 'klims-ibps3' AND table_name = 'LOGS_"+ equipSn +"'";
+            List<String> hastable = jdbcTemplate.queryForList(sqlQry, String.class);
+//            log.info("hastable: " + hastable.get(0));
+            if (Objects.equals(hastable.get(0), "1")) {
+                List<EquipResult> equipResultList = jdbcTemplate.query(subSql, humitureRowMapper);
+                for (EquipResult equipResult : equipResultList) {
+                    String curDate = "";
+                    try {
+                        curDate = saveToDateFormat.format(equipResult.getLogsTime());
+                    } catch (Exception e) {
+                        log.warn("时间格式化异常{},设备编号：{}",equipResult.getLogsTime(),equipSn);
+                        e.printStackTrace();
+                    }
+                    WSDEntity wsdEntity = new WSDEntity();
+                    wsdEntity.setId(equipSn+"-"+saveToIDFormat.format(equipResult.getLogsTime()));
+                    wsdEntity.setCollectID(equipSn);
+                    wsdEntity.setCollectName(toLoggerInfo.getLOGNAME());
+                    wsdEntity.setCollectTime(equipResult.getLogsTime());
+                    wsdEntity.setCreateTime(currentDate);
+                    List<CollectorEntity> currentCollectorList = getDeviceInfo(equipSn, collectorList);
+                    if(!currentCollectorList.isEmpty()){
+                        for (CollectorEntity collectorEntity : currentCollectorList) {
+                            wsdEntity.setDeviceID(collectorEntity.getDeviceID());
+                            wsdEntity.setDeviceNo(collectorEntity.getDeviceNo());
+                            wsdEntity.setDeviceName(collectorEntity.getDeviceName());
+                            wsdEntity.setDeviceID(collectorEntity.getDeviceID());
+                        }
+                    }
+                    if (toLoggerInfo.getCHNUM()==1){
+                        Integer type1 = toLoggerInfo.getTYPE1();
+                        //0 温度 1 湿度
+                        if (type1==0){
+                            wsdEntity.setType("温度计");
+                            wsdEntity.setTemperature(equipResult.getLogsChone());
+                            wsdEntity.setTemperatureHigh(String.valueOf(toLoggerInfo.getHIGH1()));
+                            wsdEntity.setTemperatureLow(String.valueOf(toLoggerInfo.getLOW1()));
+                        }
+                        if (type1==1){
+                            wsdEntity.setType("湿度计");
+                            wsdEntity.setHumidity(equipResult.getLogsChone());
+                            wsdEntity.setHumidityHigh(String.valueOf(toLoggerInfo.getHIGH1()));
+                            wsdEntity.setHumidityLow(String.valueOf(toLoggerInfo.getLOW1()));
+                        }
+                    } else if (toLoggerInfo.getCHNUM()==2){
+                        Integer type1 = toLoggerInfo.getTYPE1();
+                        //0 温度 1 湿度
+                        if (type1==0){
+//                            wsdEntity.setType("温度计");
+                            wsdEntity.setTemperature(equipResult.getLogsChone());
+                            wsdEntity.setTemperatureHigh(String.valueOf(toLoggerInfo.getHIGH1()));
+                            wsdEntity.setTemperatureLow(String.valueOf(toLoggerInfo.getLOW1()));
+                        }
+                        if (type1==1){
+//                            wsdEntity.setType("湿度计");
+                            wsdEntity.setHumidity(equipResult.getLogsChone());
+                            wsdEntity.setHumidityHigh(String.valueOf(toLoggerInfo.getHIGH1()));
+                            wsdEntity.setHumidityLow(String.valueOf(toLoggerInfo.getLOW1()));
+                        }
+                        Integer type2 = toLoggerInfo.getTYPE2();
+                        //0 温度 1 湿度
+                        if (type2==0){
+                            if (type1==0){
+                                wsdEntity.setType("温度计");
+                            } else if (type1==1){
+                                wsdEntity.setType("温湿度计");
+                            }
+                            wsdEntity.setTemperature(equipResult.getLogsChtwo());
+                            wsdEntity.setTemperatureHigh(String.valueOf(toLoggerInfo.getHIGH2()));
+                            wsdEntity.setTemperatureLow(String.valueOf(toLoggerInfo.getLOW2()));
+                        }
+                        if (type2==1){
+                            if (type1==0){
+                                wsdEntity.setType("温湿度计");
+                            } else if (type1==1){
+                                wsdEntity.setType("湿度计");
+                            }
+                            wsdEntity.setHumidity(equipResult.getLogsChtwo());
+                            wsdEntity.setHumidityHigh(String.valueOf(toLoggerInfo.getHIGH2()));
+                            wsdEntity.setHumidityLow(String.valueOf(toLoggerInfo.getLOW2()));
+                        }
+                    }else if (toLoggerInfo.getCHNUM()==3){
+                        //暂时没发现有
+                    }
+                    wsdSet.add(wsdEntity);
+                }
+            }else{
+                log.info("table:LOGS_"+equipSn+" not exist!");
+            }
+        }
+        return new ArrayList<>(wsdSet);
+    }
+
+
+    public List<CollectorEntity> getDeviceInfo(String CollectID, List<CollectorEntity> collectorList){
+        List<CollectorEntity> retEntity = new ArrayList<>();
+        for (CollectorEntity collectorEntity:collectorList){
+            if(Objects.equals(collectorEntity.getCollectID(), CollectID)){
+                retEntity.add(collectorEntity);
+            }
+        }
+        return retEntity;
+    }
+
+
+}

GetDataByView/src/main/java/com/jyxt/getdatabyview/view/IBPSRepository.java

@@ -0,0 +1,69 @@
+package com.jyxt.getdatabyview.view;
+
+import com.jyxt.getdatabyview.view.entity.WSDEntity;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.PreparedStatementCreator;
+import org.springframework.stereotype.Repository;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+import java.sql.Date;
+
+@Repository
+public class IBPSRepository {
+
+    @Autowired
+    @Qualifier("secondJdbcTemplate")
+    private JdbcTemplate jdbcTemplate;
+
+    public List<String> getExistID(){
+        List<String> existIDList = new ArrayList<String>();
+        /**
+         * 正式启用开启这一段
+         * String existSql = "select id from t_dsfwdjlb where Date(collectTime) = CURDATE()"
+         */
+        String existSql = "select id from t_dsfwdjlb where Date(collectTime) = CURDATE()-5";
+        existIDList = jdbcTemplate.queryForList(existSql, String.class);
+        return existIDList;
+    }
+
+
+    public void save(final WSDEntity wsdEntity){
+        //sql语句
+        final String sql =  "insert into t_dsfwdjlb (id,createTime,collectTime,temperature,humidity,deviceID,deviceNo,deviceName,collectID, "+
+                            "collectName,temperatureHigh,temperatureLow,humidityHigh,humidityLow,shiYanZu,shiYanZuID,type,area,diDian,room)  "+
+                            " values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)                                                                            ";
+        jdbcTemplate.update(new PreparedStatementCreator() {
+            public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
+                PreparedStatement prepareStatement = connection.prepareStatement(sql);
+                prepareStatement.setString(1,wsdEntity.getId());
+                prepareStatement.setTimestamp(2, new java.sql.Timestamp(wsdEntity.getCreateTime().getTime()));
+                prepareStatement.setTimestamp(3, new java.sql.Timestamp(wsdEntity.getCollectTime().getTime()));
+                prepareStatement.setString(4,wsdEntity.getTemperature());
+                prepareStatement.setString(5,wsdEntity.getHumidity());
+                prepareStatement.setString(6,wsdEntity.getDeviceID());
+                prepareStatement.setString(7,wsdEntity.getDeviceNo());
+                prepareStatement.setString(8,wsdEntity.getDeviceName());
+                prepareStatement.setString(9,wsdEntity.getCollectID());
+                prepareStatement.setString(10,wsdEntity.getCollectName());
+                prepareStatement.setString(11,wsdEntity.getTemperatureHigh());
+                prepareStatement.setString(12,wsdEntity.getTemperatureLow());
+                prepareStatement.setString(13,wsdEntity.getHumidityHigh());
+                prepareStatement.setString(14,wsdEntity.getHumidityLow());
+                prepareStatement.setString(15,wsdEntity.getShiYanZu());
+                prepareStatement.setString(16,wsdEntity.getShiYanZuID());
+                prepareStatement.setString(17,wsdEntity.getType());
+                prepareStatement.setString(18,wsdEntity.getArea());
+                prepareStatement.setString(19,wsdEntity.getDiDian());
+                prepareStatement.setString(20,wsdEntity.getRoom());
+                return prepareStatement;
+            }
+        });
+    }
+
+}

GetDataByView/src/main/java/com/jyxt/getdatabyview/view/entity/CollectorEntity.java

@@ -0,0 +1,73 @@
+package com.jyxt.getdatabyview.view.entity;
+
+public class CollectorEntity {
+    private String DeviceID;
+
+    private String DeviceNo;
+
+    private String DeviceName;
+
+    private String DeviceType;
+
+    private String CollectID;
+
+    private String CollectName;
+
+    private String Enable;
+
+    public String getDeviceID() {
+        return DeviceID;
+    }
+
+    public void setDeviceID(String deviceID) {
+        DeviceID = deviceID;
+    }
+
+    public String getDeviceNo() {
+        return DeviceNo;
+    }
+
+    public void setDeviceNo(String deviceNo) {
+        DeviceNo = deviceNo;
+    }
+
+    public String getDeviceName() {
+        return DeviceName;
+    }
+
+    public void setDeviceName(String deviceName) {
+        DeviceName = deviceName;
+    }
+
+    public String getDeviceType() {
+        return DeviceType;
+    }
+
+    public void setDeviceType(String deviceType) {
+        DeviceType = deviceType;
+    }
+
+    public String getCollectID() {
+        return CollectID;
+    }
+
+    public void setCollectID(String collectID) {
+        CollectID = collectID;
+    }
+
+    public String getCollectName() {
+        return CollectName;
+    }
+
+    public void setCollectName(String collectName) {
+        CollectName = collectName;
+    }
+
+    public String getEnable() {
+        return Enable;
+    }
+
+    public void setEnable(String enable) {
+        Enable = enable;
+    }
+}

GetDataByView/src/main/java/com/jyxt/getdatabyview/view/entity/EquipResult.java

@@ -0,0 +1,55 @@
+package com.jyxt.getdatabyview.view.entity;
+
+import java.util.Date;
+
+public class EquipResult {
+    private Date logsTime;
+
+    private String logsChone;
+
+    private String logsChtwo;
+
+    private String logsChthr;
+
+    private String logsChfou;
+
+    public Date getLogsTime() {
+        return logsTime;
+    }
+
+    public void setLogsTime(Date logsTime) {
+        this.logsTime = logsTime;
+    }
+
+    public String getLogsChone() {
+        return logsChone;
+    }
+
+    public void setLogsChone(String logsChone) {
+        this.logsChone = logsChone;
+    }
+
+    public String getLogsChtwo() {
+        return logsChtwo;
+    }
+
+    public void setLogsChtwo(String logsChtwo) {
+        this.logsChtwo = logsChtwo;
+    }
+
+    public String getLogsChthr() {
+        return logsChthr;
+    }
+
+    public void setLogsChthr(String logsChthr) {
+        this.logsChthr = logsChthr;
+    }
+
+    public String getLogsChfou() {
+        return logsChfou;
+    }
+
+    public void setLogsChfou(String logsChfou) {
+        this.logsChfou = logsChfou;
+    }
+}

GetDataByView/src/main/java/com/jyxt/getdatabyview/view/entity/ToLoggerInfo.java

@@ -0,0 +1,203 @@
+package com.jyxt.getdatabyview.view.entity;
+
+public class ToLoggerInfo {
+    private String LOGSN;
+
+    private Integer GROUPID;
+
+    private String LOGNAME;
+
+    private Integer CHNUM;
+
+    private Integer TYPE1;
+
+    private float HIGH1;
+
+    private float LOW1;
+
+    private String DOT1;
+
+    private Integer TYPE2;
+
+    private float HIGH2;
+
+    private float LOW2;
+
+    private String DOT2;
+
+    private Integer TYPE3;
+
+    private float HIGH3;
+
+    private float LOW3;
+
+    private String DOT3;
+
+    private Integer TYPE4;
+
+    private float HIGH4;
+
+    private float LOW4;
+
+    private String DOT4;
+
+    public String getLOGSN() {
+        return LOGSN;
+    }
+
+    public void setLOGSN(String LOGSN) {
+        this.LOGSN = LOGSN;
+    }
+
+    public Integer getGROUPID() {
+        return GROUPID;
+    }
+
+    public void setGROUPID(Integer GROUPID) {
+        this.GROUPID = GROUPID;
+    }
+
+    public String getLOGNAME() {
+        return LOGNAME;
+    }
+
+    public void setLOGNAME(String LOGNAME) {
+        this.LOGNAME = LOGNAME;
+    }
+
+    public Integer getCHNUM() {
+        return CHNUM;
+    }
+
+    public void setCHNUM(Integer CHNUM) {
+        this.CHNUM = CHNUM;
+    }
+
+    public Integer getTYPE1() {
+        return TYPE1;
+    }
+
+    public void setTYPE1(Integer TYPE1) {
+        this.TYPE1 = TYPE1;
+    }
+
+    public float getHIGH1() {
+        return HIGH1;
+    }
+
+    public void setHIGH1(float HIGH1) {
+        this.HIGH1 = HIGH1;
+    }
+
+    public float getLOW1() {
+        return LOW1;
+    }
+
+    public void setLOW1(float LOW1) {
+        this.LOW1 = LOW1;
+    }
+
+    public String getDOT1() {
+        return DOT1;
+    }
+
+    public void setDOT1(String DOT1) {
+        this.DOT1 = DOT1;
+    }
+
+    public Integer getTYPE2() {
+        return TYPE2;
+    }
+
+    public void setTYPE2(Integer TYPE2) {
+        this.TYPE2 = TYPE2;
+    }
+
+    public float getHIGH2() {
+        return HIGH2;
+    }
+
+    public void setHIGH2(float HIGH2) {
+        this.HIGH2 = HIGH2;
+    }
+
+    public float getLOW2() {
+        return LOW2;
+    }
+
+    public void setLOW2(float LOW2) {
+        this.LOW2 = LOW2;
+    }
+
+    public String getDOT2() {
+        return DOT2;
+    }
+
+    public void setDOT2(String DOT2) {
+        this.DOT2 = DOT2;
+    }
+
+    public Integer getTYPE3() {
+        return TYPE3;
+    }
+
+    public void setTYPE3(Integer TYPE3) {
+        this.TYPE3 = TYPE3;
+    }
+
+    public float getHIGH3() {
+        return HIGH3;
+    }
+
+    public void setHIGH3(float HIGH3) {
+        this.HIGH3 = HIGH3;
+    }
+
+    public float getLOW3() {
+        return LOW3;
+    }
+
+    public void setLOW3(float LOW3) {
+        this.LOW3 = LOW3;
+    }
+
+    public String getDOT3() {
+        return DOT3;
+    }
+
+    public void setDOT3(String DOT3) {
+        this.DOT3 = DOT3;
+    }
+
+    public Integer getTYPE4() {
+        return TYPE4;
+    }
+
+    public void setTYPE4(Integer TYPE4) {
+        this.TYPE4 = TYPE4;
+    }
+
+    public float getHIGH4() {
+        return HIGH4;
+    }
+
+    public void setHIGH4(float HIGH4) {
+        this.HIGH4 = HIGH4;
+    }
+
+    public float getLOW4() {
+        return LOW4;
+    }
+
+    public void setLOW4(float LOW4) {
+        this.LOW4 = LOW4;
+    }
+
+    public String getDOT4() {
+        return DOT4;
+    }
+
+    public void setDOT4(String DOT4) {
+        this.DOT4 = DOT4;
+    }
+}

GetDataByView/src/main/java/com/jyxt/getdatabyview/view/entity/WSDEntity.java

@@ -0,0 +1,205 @@
+package com.jyxt.getdatabyview.view.entity;
+
+import java.util.Date;
+
+public class WSDEntity {
+    private String id;
+
+    private Date createTime;
+
+    private Date collectTime;
+
+    private String temperature;
+
+    private String humidity;
+
+    private String deviceID;
+
+    private String deviceNo;
+
+    private String deviceName;
+
+    private String collectID;
+
+    private String collectName;
+
+    private String temperatureHigh;
+
+    private String temperatureLow;
+
+    private String humidityHigh;
+
+    private String humidityLow;
+
+    private String shiYanZu;
+
+    private String shiYanZuID;
+
+    private String type;
+
+    private String area;
+
+    private String diDian;
+
+    private String room;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public Date getCollectTime() {
+        return collectTime;
+    }
+
+    public void setCollectTime(Date collectTime) {
+        this.collectTime = collectTime;
+    }
+
+    public String getTemperature() {
+        return temperature;
+    }
+
+    public void setTemperature(String temperature) {
+        this.temperature = temperature;
+    }
+
+    public String getHumidity() {
+        return humidity;
+    }
+
+    public void setHumidity(String humidity) {
+        this.humidity = humidity;
+    }
+
+    public String getDeviceID() {
+        return deviceID;
+    }
+
+    public void setDeviceID(String deviceID) {
+        this.deviceID = deviceID;
+    }
+
+    public String getDeviceNo() {
+        return deviceNo;
+    }
+
+    public void setDeviceNo(String deviceNo) {
+        this.deviceNo = deviceNo;
+    }
+
+    public String getDeviceName() {
+        return deviceName;
+    }
+
+    public void setDeviceName(String deviceName) {
+        this.deviceName = deviceName;
+    }
+
+    public String getCollectID() {
+        return collectID;
+    }
+
+    public void setCollectID(String collectID) {
+        this.collectID = collectID;
+    }
+
+    public String getCollectName() {
+        return collectName;
+    }
+
+    public void setCollectName(String collectName) {
+        this.collectName = collectName;
+    }
+
+    public String getTemperatureHigh() {
+        return temperatureHigh;
+    }
+
+    public void setTemperatureHigh(String temperatureHigh) {
+        this.temperatureHigh = temperatureHigh;
+    }
+
+    public String getTemperatureLow() {
+        return temperatureLow;
+    }
+
+    public void setTemperatureLow(String temperatureLow) {
+        this.temperatureLow = temperatureLow;
+    }
+
+    public String getHumidityHigh() {
+        return humidityHigh;
+    }
+
+    public void setHumidityHigh(String humidityHigh) {
+        this.humidityHigh = humidityHigh;
+    }
+
+    public String getHumidityLow() {
+        return humidityLow;
+    }
+
+    public void setHumidityLow(String humidityLow) {
+        this.humidityLow = humidityLow;
+    }
+
+    public String getShiYanZu() {
+        return shiYanZu;
+    }
+
+    public void setShiYanZu(String shiYanZu) {
+        this.shiYanZu = shiYanZu;
+    }
+
+    public String getShiYanZuID() {
+        return shiYanZuID;
+    }
+
+    public void setShiYanZuID(String shiYanZuID) {
+        this.shiYanZuID = shiYanZuID;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public String getArea() {
+        return area;
+    }
+
+    public void setArea(String area) {
+        this.area = area;
+    }
+
+    public String getDiDian() {
+        return diDian;
+    }
+
+    public void setDiDian(String diDian) {
+        this.diDian = diDian;
+    }
+
+    public String getRoom() {
+        return room;
+    }
+
+    public void setRoom(String room) {
+        this.room = room;
+    }
+}

GetDataByView/src/main/java/com/jyxt/getdatabyview/view/repository/QualityIndicatorRepository.java

@@ -21,85 +21,85 @@ import java.util.Objects;
 
 @Repository
 public class QualityIndicatorRepository {
-    @Autowired
-    @Qualifier("secondJdbcTemplate")
-    private JdbcTemplate jdbcTemplate;
-
-
-    private static final Logger log = LoggerFactory.getLogger(QualityIndicatorRepository.class);
-    @Value("${fetch.sqlGetUndo}")
-    private String sql;
-
-    @Value("${config.qrymode}")
-    private String qryMode;
-
-    public List<QualityIndicator> query() {
-        log.info("excute sql:" + sql);
-//        System.out.println(sql);
-        List<QualityIndicator> result = jdbcTemplate.query(
-                sql,
-                new RowMapper<QualityIndicator>() {
-                    @Override
-                    public QualityIndicator mapRow(ResultSet rs, int rowNum) throws SQLException {
-                        QualityIndicator qi = new QualityIndicator();
-                        qi.setId(rs.getString("id_"));
-                        qi.setbianzhishijian(rs.getString("bian_zhi_shi_jian"));
-                        qi.setzhiliangzhibia(rs.getString("zhi_liang_zhi_bia"));
-                        qi.setYuanshishuju(rs.getString("yuan_shi_shu_ju_"));
-                        return qi;
-                    }
-                }
-        );
-        if (result.isEmpty()) {
-            log.info("-------------no data finded,nothing to do...-------------");
-        }
-        return result;
-    }
-
-
-    public void save(String Id, String resultValue, String total, String DataDetail, String IsQualified){
-        //sql语句
-        final String sql = "update t_zlzbpjzb set shi_ji_shu_zhi_=?, fen_zi_=?,zhuang_tai_='已完成', bei_zhu_2_='自动导入',bei_zhu_='自动导入',shu_ju_xiang_qing=?,da_biao_qing_kuan=? where id_=? ";
-//        System.out.println("Id:"+Id+",ResultValue:"+ResultValue);
-//        System.out.println("Ready to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+ResultValue);
-        if (Objects.equals(qryMode, "0")){
-            log.info("Ready to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+resultValue+",total:"+total+",DataDetail:"+DataDetail+",IsQualified:"+IsQualified);
-            jdbcTemplate.update(new PreparedStatementCreator() {
-                public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
-                    PreparedStatement prepareStatement = connection.prepareStatement(sql);
-                    prepareStatement.setString(1, resultValue);
-                    prepareStatement.setString(2, total);
-                    prepareStatement.setString(3, DataDetail);
-                    prepareStatement.setString(4, IsQualified);
-                    prepareStatement.setString(5, Id);
-                    return prepareStatement;
-                }
-            });
-        } else{
-            log.info("qryMode=1,pretend to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+resultValue+",total:"+total+",DataDetail:"+DataDetail+",IsQualified:"+IsQualified);
-        }
-    }
-
-    public void save(String Id, String resultValue, String numerator, String denominator,String DataDetail, String IsQualified){
-        //sql语句
-        final String sql = "update t_zlzbpjzb set shi_ji_shu_zhi_=?, fen_zi_=?,fen_mu_=?,zhuang_tai_='已完成', bei_zhu_2_='自动导入',bei_zhu_='自动导入',shu_ju_xiang_qing=?,da_biao_qing_kuan=? where id_=? ";
-//        System.out.println("Id:"+Id+",ResultValue:"+ResultValue);
-        if (Objects.equals(qryMode, "0")){
-            log.info("Ready to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+resultValue+",Numerator:"+numerator+",Denominator:"+denominator+",DataDetail:"+DataDetail+",IsQualified:"+IsQualified);
-            jdbcTemplate.update(new PreparedStatementCreator() {
-                public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
-                    PreparedStatement prepareStatement = connection.prepareStatement(sql);
-                    prepareStatement.setString(1, resultValue);
-                    prepareStatement.setString(2, numerator);
-                    prepareStatement.setString(3, denominator);
-                    prepareStatement.setString(4, DataDetail);
-                    prepareStatement.setString(5, IsQualified);
-                    prepareStatement.setString(6, Id);
-                    return prepareStatement;
-                }
-            });
-        } else{
-            log.info("qryMode=1,pretend to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+resultValue+",Numerator:"+numerator+",Denominator:"+denominator+",DataDetail:"+DataDetail+",IsQualified:"+IsQualified);
-        }
-    }
+//    @Autowired
+//    @Qualifier("secondJdbcTemplate")
+//    private JdbcTemplate jdbcTemplate;
+//
+//
+//    private static final Logger log = LoggerFactory.getLogger(QualityIndicatorRepository.class);
+//    @Value("${fetch.sqlGetUndo}")
+//    private String sql;
+//
+//    @Value("${config.qrymode}")
+//    private String qryMode;
+//
+//    public List<QualityIndicator> query() {
+//        log.info("excute sql:" + sql);
+////        System.out.println(sql);
+//        List<QualityIndicator> result = jdbcTemplate.query(
+//                sql,
+//                new RowMapper<QualityIndicator>() {
+//                    @Override
+//                    public QualityIndicator mapRow(ResultSet rs, int rowNum) throws SQLException {
+//                        QualityIndicator qi = new QualityIndicator();
+//                        qi.setId(rs.getString("id_"));
+//                        qi.setbianzhishijian(rs.getString("bian_zhi_shi_jian"));
+//                        qi.setzhiliangzhibia(rs.getString("zhi_liang_zhi_bia"));
+//                        qi.setYuanshishuju(rs.getString("yuan_shi_shu_ju_"));
+//                        return qi;
+//                    }
+//                }
+//        );
+//        if (result.isEmpty()) {
+//            log.info("-------------no data finded,nothing to do...-------------");
+//        }
+//        return result;
+//    }
+//
+//
+//    public void save(String Id, String resultValue, String total, String DataDetail, String IsQualified){
+//        //sql语句
+//        final String sql = "update t_zlzbpjzb set shi_ji_shu_zhi_=?, fen_zi_=?,zhuang_tai_='已完成', bei_zhu_2_='自动导入',bei_zhu_='自动导入',shu_ju_xiang_qing=?,da_biao_qing_kuan=? where id_=? ";
+////        System.out.println("Id:"+Id+",ResultValue:"+ResultValue);
+////        System.out.println("Ready to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+ResultValue);
+//        if (Objects.equals(qryMode, "0")){
+//            log.info("Ready to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+resultValue+",total:"+total+",DataDetail:"+DataDetail+",IsQualified:"+IsQualified);
+//            jdbcTemplate.update(new PreparedStatementCreator() {
+//                public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
+//                    PreparedStatement prepareStatement = connection.prepareStatement(sql);
+//                    prepareStatement.setString(1, resultValue);
+//                    prepareStatement.setString(2, total);
+//                    prepareStatement.setString(3, DataDetail);
+//                    prepareStatement.setString(4, IsQualified);
+//                    prepareStatement.setString(5, Id);
+//                    return prepareStatement;
+//                }
+//            });
+//        } else{
+//            log.info("qryMode=1,pretend to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+resultValue+",total:"+total+",DataDetail:"+DataDetail+",IsQualified:"+IsQualified);
+//        }
+//    }
+//
+//    public void save(String Id, String resultValue, String numerator, String denominator,String DataDetail, String IsQualified){
+//        //sql语句
+//        final String sql = "update t_zlzbpjzb set shi_ji_shu_zhi_=?, fen_zi_=?,fen_mu_=?,zhuang_tai_='已完成', bei_zhu_2_='自动导入',bei_zhu_='自动导入',shu_ju_xiang_qing=?,da_biao_qing_kuan=? where id_=? ";
+////        System.out.println("Id:"+Id+",ResultValue:"+ResultValue);
+//        if (Objects.equals(qryMode, "0")){
+//            log.info("Ready to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+resultValue+",Numerator:"+numerator+",Denominator:"+denominator+",DataDetail:"+DataDetail+",IsQualified:"+IsQualified);
+//            jdbcTemplate.update(new PreparedStatementCreator() {
+//                public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
+//                    PreparedStatement prepareStatement = connection.prepareStatement(sql);
+//                    prepareStatement.setString(1, resultValue);
+//                    prepareStatement.setString(2, numerator);
+//                    prepareStatement.setString(3, denominator);
+//                    prepareStatement.setString(4, DataDetail);
+//                    prepareStatement.setString(5, IsQualified);
+//                    prepareStatement.setString(6, Id);
+//                    return prepareStatement;
+//                }
+//            });
+//        } else{
+//            log.info("qryMode=1,pretend to update t_zlzbpjzb:Id:"+Id+",ResultValue:"+resultValue+",Numerator:"+numerator+",Denominator:"+denominator+",DataDetail:"+DataDetail+",IsQualified:"+IsQualified);
+//        }
+//    }
 }

GetDataByView/src/main/resources/application.properties

@@ -1,21 +1,19 @@
 spring.application.name=GetDataByView
-#spring.datasource.jdbc-url=jdbc:oracle:thin:@192.168.15.212:1521/SYHIS
-#spring.datasource.username=JYXT
-#spring.datasource.password=Jy#6688xt
-#spring.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver
-spring.datasource.jdbc-url=jdbc:sqlserver://localhost:1433;databaseName=your_db
-spring.datasource.username=sa
-spring.datasource.password=your_password
-spring.datasource.driver-class-name=com.microsoft.sqlserver.jdbc.SQLServerDriver
+#spring.datasource.jdbc-url=jdbc:sqlserver://localhost:1433;databaseName=huatu
+#spring.datasource.username=sa
+#spring.datasource.password=your_password
+#spring.datasource.driver-class-name=com.microsoft.sqlserver.jdbc.SQLServerDriver
+spring.datasource.jdbc-url=jdbc:mysql://localhost:3306/klims-ibps3?characterEncoding=utf8&useSSL=false
+spring.datasource.username=root
+spring.datasource.password=test001
+spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
 spring.second-datasource.jdbc-url = jdbc:mysql://localhost:3306/klims-ibps3?characterEncoding=utf8&useSSL=false
 spring.second-datasource.username = root
 spring.second-datasource.password = test001
 spring.second-datasource.driver-class-name = com.mysql.cj.jdbc.Driver
-fetch.sql=select * from v_jt_lisrequesttest
-fetch.sqlGetUndo=select id_,bian_zhi_shi_jian,zhi_liang_zhi_bia,yuan_shi_shu_ju_ from t_zlzbpjzb where zhuang_tai_='\u5f85\u5904\u7406'
-fetch.QualityIndicatorStr = ;???????????-??????-????; 
 logging.file.name=logs/GetDataByView.log
+fetch.condition=DATEDIFF(day, LOGS_TIME, GETDATE()) = 0
 # level:TRACE < DEBUG < INFO < WARN < ERROR < FATAL
 logging.level.root=INFO
-#1 or 0,1 means only qry,0 means update
-config.qrymode=1
+#1 or 0,1 means qry and insert new data,0 means qry uncontrol judge
+config.run_mode=1