优化

slibra-admin/src/main/java/com/slibra/web/controller/business/HandleDataController.java

@@ -50,224 +50,227 @@ public class HandleDataController extends BaseController
     @Autowired
     private TXinyiRobotMapper xinyiRobotMapper;
 
-//    public static final String[] queryTags = {"信义污水厂JS_COD_Value","信义污水厂JS_PH_Value","信义污水厂JS_SS_Value","信义污水厂JS_ZL_Value","信义污水厂JS_ZA_Value","信义污水厂JS_AD_Value","信义污水厂JS_T_Value","信义污水厂进水泵房液位","信义污水厂出水瞬时流量","信义污水厂升级出水COD","信义污水厂升级出水PH","信义污水厂升级出水SS","信义污水厂升级出水TN","信义污水厂升级出水TP","信义污水厂升级出水氨氮","信义污水厂AIT202_Value","信义污水厂AIT203_Value","信义污水厂AIT207_Value","信义污水厂AIT206_Value","信义污水厂AIT209_Value","信义污水厂AIT210_Value","信义污水厂进水TDS","信义污水厂FT101_Value","信义污水厂SWCHHYHLB1_R_Value","信义污水厂SWCHHYHLB2_R_Value","信义污水厂SWCHHYHLB3_R_Value","信义污水厂SWCHHYHLB4_R_Value","信义污水厂SWCHHYHLB5_R_Value","信义污水厂SWCHHYHLB6_R_Value","信义污水厂SWCWNHLB1_R_Value","信义污水厂SWCWNHLB2_R_Value","信义污水厂SWCWNHLB3_R_Value","信义污水厂SWCWNHLB4_R_Value","信义污水厂SWCWNHLB5_R_Value","信义污水厂GFJ1_R_Value","信义污水厂GFJ2_R_Value","信义污水厂GFJ3_R_Value","信义污水厂GFJ4_R_Value","信义污水厂GFJ5_R_Value","信义污水厂GFJ6_R_Value","信义污水厂GFJ1_KQLL_Value","信义污水厂GFJ2_KQLL_Value","信义污水厂GFJ3_KQLL_Value","信义污水厂GFJ4_KQLL_Value","信义污水厂GFJ5_KQLL_Value","信义污水厂GFJ6_KQLL_Value"};
+    public static final String[] queryTags = {"信义污水厂JS_COD_Value","信义污水厂JS_PH_Value","信义污水厂JS_SS_Value","信义污水厂JS_ZL_Value","信义污水厂JS_ZA_Value","信义污水厂JS_AD_Value","信义污水厂JS_T_Value","信义污水厂进水泵房液位","信义污水厂出水瞬时流量","信义污水厂升级出水COD","信义污水厂升级出水PH","信义污水厂升级出水SS","信义污水厂升级出水TN","信义污水厂升级出水TP","信义污水厂升级出水氨氮","信义污水厂AIT202_Value","信义污水厂AIT203_Value","信义污水厂AIT207_Value","信义污水厂AIT206_Value","信义污水厂AIT209_Value","信义污水厂AIT210_Value","信义污水厂进水TDS","信义污水厂FT101_Value","信义污水厂SWCHHYHLB1_R_Value","信义污水厂SWCHHYHLB2_R_Value","信义污水厂SWCHHYHLB3_R_Value","信义污水厂SWCHHYHLB4_R_Value","信义污水厂SWCHHYHLB5_R_Value","信义污水厂SWCHHYHLB6_R_Value","信义污水厂SWCWNHLB1_R_Value","信义污水厂SWCWNHLB2_R_Value","信义污水厂SWCWNHLB3_R_Value","信义污水厂SWCWNHLB4_R_Value","信义污水厂SWCWNHLB5_R_Value","信义污水厂GFJ1_R_Value","信义污水厂GFJ2_R_Value","信义污水厂GFJ3_R_Value","信义污水厂GFJ4_R_Value","信义污水厂GFJ5_R_Value","信义污水厂GFJ6_R_Value","信义污水厂GFJ1_KQLL_Value","信义污水厂GFJ2_KQLL_Value","信义污水厂GFJ3_KQLL_Value","信义污水厂GFJ4_KQLL_Value","信义污水厂GFJ5_KQLL_Value","信义污水厂GFJ6_KQLL_Value"};
+
+    @GetMapping("/dateAdd")
+    public String dateAdd() {
+
+
+        // 给定时间段的起始时间和结束时间
+        LocalDateTime startTime = LocalDateTime.parse("2024-04-13T16:00:00");
+        LocalDateTime endTime = LocalDateTime.parse("2024-04-13T17:00:00");
+
+
+        /*LocalDateTime startTime = LocalDateTime.parse("2024-02-26T00:00:00");
+        LocalDateTime endTime = LocalDateTime.parse("2024-02-27T00:00:00");*/
+
+        // 每个小时的时间格式
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+        // 循环按小时分割
+        LocalDateTime currentHour = startTime;
+        while (currentHour.isBefore(endTime)) {
+            String begin = currentHour.format(formatter);
+            String end = currentHour.plusMinutes(10).format(formatter);
+            // 输出当前小时的起始时间和结束时间
+            System.out.println("起始时间：" + begin);
+            System.out.println("结束时间：" + end);
+
+            // 当前小时加一小时，作为下一个小时的起始时间
+            currentHour = currentHour.plusMinutes(10);
+
+            //每个小时查询一次数据
+            String url = "http://10.0.0.27:4568/api/v1/khquerydata";
+            HashMap<String, Object> req = new HashMap<>();
+            req.put("tagNames", queryTags);
+            req.put("startTime", begin);
+            req.put("endTime", end);
+            req.put("recordNumbers", 100000);
+            String body = HttpRequest.post(url).header("Authorization", "c2E6c2E=").header("clientName", "hongshan").body(JSON.toJSONString(req)).execute().body();
+//            System.out.println("body = " + body);
+            List<HashMap<String, String>> list = new ArrayList<>();
+
+            //行转列数据处理
+            for (String queryTag : queryTags) {
+                JSONArray array = JSON.parseObject(body).getJSONArray(queryTag);
+                //特殊数据处理一
+                if(Objects.isNull(array) || array.isEmpty()){
+                    System.out.println(queryTag + "查询到了空的数据，跳过本次循环");
+                    continue;
+                }
+                int size = array.size();
+                //特殊数据处理二
+                if("0".equals(array.get(1) + "")){
+                    System.out.println(queryTag + "查询到了数据，但是数据集合只有一条，且都是0");
+                    continue;
+                }
+                //结合至少62个数据才满足条件(有可能获取不到)
+                /*if(size < 62){
+                    System.out.println(queryTag + "查询到了不符合条件的数据，跳过本次循环");
+                    continue;
+                }*/
+
+                //存放的数据集
+                //利用map去重
+                HashMap<String, String> map = new LinkedHashMap<>();
+                for (int i = 2; i < size; i++) {
+//            System.out.println(i + "" + array.get(i));
+                    JSONArray oneRecord = JSON.parseArray(JSON.toJSONString(array.get(i)));
+                    //处理为空或者为0的数据
+                    Object timeStampValue = oneRecord.get(2);
+                    if(Objects.isNull(timeStampValue) || "0".equals(timeStampValue + ""))
+                        continue;
+                    BigDecimal value = Objects.isNull(oneRecord.get(0)) ? null : new BigDecimal(oneRecord.get(0) + "");
+                    long timestamp = (long) timeStampValue;
+                    String format = DateUtil.format(new Date(timestamp), DateUtils.YYYYMMDDHHMM_TS);
+                    map.put(format, queryTag + "-" + value);
+                }
+                list.add(map);
+            }
+//        System.out.println("list = " + list);
+            //先构造对象（list中任意一个map遍历的key个数）  因为合并完并不是1分钟60条，参考上面筛选区间，有时候会有几个值获取不到
+            /*HashMap<String, String> oneRow = list.get(0);
+            Set<String> set = oneRow.keySet();
+            List<Industry> result = new ArrayList<>(set.size());
+            set.forEach(s -> {
+                Industry industry = new Industry();
+                industry.setTestTime(s);
+                result.add(industry);
+            });*/
+            Set<String> recordTimeSet = new HashSet<>();
+            Map<String, TXinyiIndustry> recordMap = new HashMap<>();
+            for (int i = 0; i < list.size(); i++) {
+                HashMap<String, String> map = list.get(i);
+                int finalJ = i;
+                map.forEach((k, v) ->{
+                    TXinyiIndustry industry = null;
+                    if(!recordTimeSet.contains(k)){//第一次
+                        industry = new TXinyiIndustry();
+                        recordTimeSet.add(k);
+                        recordMap.put(k, industry);
+                    }else{
+                        industry = recordMap.get(k);
+                    }
+                    industry.setTestTime(k);
+                    //2024年4月15日11:19:52  额外增加2个字段
+                    industry.setTestDate(k.substring(0,10));
+                    industry.setTestHour(k.substring(0,13));
+                    //解析值
+                    String[] split = v.split("-");
+                    String type = split[0];
+                    BigDecimal value = new BigDecimal(split[1]);
+                    if ("信义污水厂JS_COD_Value".equals(type)) {
+                        industry.setJsCod(value);
+                    } else if ("信义污水厂JS_PH_Value".equals(type)) {
+                        industry.setJsPh(value);
+                    } else if ("信义污水厂JS_SS_Value".equals(type)) {
+                        industry.setJsSs(value);
+                    } else if ("信义污水厂JS_ZL_Value".equals(type)) {
+                        industry.setJsTp(value);
+                    } else if ("信义污水厂JS_ZA_Value".equals(type)) {
+                        industry.setJsTn(value);
+                    } else if ("信义污水厂JS_AD_Value".equals(type)) {
+                        industry.setJsNh3(value);
+                    } else if ("信义污水厂JS_T_Value".equals(type)) {
+                        industry.setJsSwPh(value);
+                    } else if ("信义污水厂进水泵房液位".equals(type)) {
+                        industry.setJsBfyw(value);
+                    } else if ("信义污水厂出水瞬时流量".equals(type)) {
+                        industry.setCsSlqc(value);
+                    } else if ("信义污水厂升级出水COD".equals(type)) {
+                        industry.setCsCod(value);
+                    } else if ("信义污水厂升级出水PH".equals(type)) {
+                        industry.setCsPh(value);
+                    } else if ("信义污水厂升级出水SS".equals(type)) {
+                        industry.setCsSs(value);
+                    } else if ("信义污水厂升级出水TN".equals(type)) {
+                        industry.setCsTn(value);
+                    } else if ("信义污水厂升级出水TP".equals(type)) {
+                        industry.setCsTp(value);
+                    } else if ("信义污水厂升级出水氨氮".equals(type)) {
+                        industry.setCsNh3(value);
+                    } else if ("信义污水厂AIT202_Value".equals(type)) {
+                        industry.setOneHyzdDo(value);
+                    } else if ("信义污水厂AIT203_Value".equals(type)) {
+                        industry.setOneHymdDo(value);
+                    } else if ("信义污水厂AIT207_Value".equals(type)) {
+                        industry.setTwoHyzdDo(value);
+                    } else if ("信义污水厂AIT206_Value".equals(type)) {
+                        industry.setTwoHymdDo(value);
+                    } else if ("信义污水厂AIT209_Value".equals(type)) {
+                        industry.setOneMlss(value);
+                    } else if ("信义污水厂AIT210_Value".equals(type)) {
+                        industry.setTwoMlss(value);
+                    } else if ("信义污水厂进水TDS".equals(type)) {
+                        industry.setJsTds(value);
+                    } else if ("信义污水厂FT101_Value".equals(type)) {
+                        industry.setJsSlq(value);
+                    } else if ("信义污水厂SWCHHYHLB1_R_Value".equals(type)) {
+                        industry.setNHlbOneGp(value);
+                    } else if ("信义污水厂SWCHHYHLB2_R_Value".equals(type)) {
+                        industry.setNHlbTwoGp(value);
+                    } else if ("信义污水厂SWCHHYHLB3_R_Value".equals(type)) {
+                        industry.setNHlbThreeGp(value);
+                    } else if ("信义污水厂SWCHHYHLB4_R_Value".equals(type)) {
+                        industry.setNHlbFourGp(value);
+                    } else if ("信义污水厂SWCHHYHLB5_R_Value".equals(type)) {
+                        industry.setNhlBFiveGp(value);
+                    } else if ("信义污水厂SWCHHYHLB6_R_Value".equals(type)) {
+                        industry.setNHlbSixGp(value);
+                    } else if ("信义污水厂SWCWNHLB1_R_Value".equals(type)) {
+                        industry.setWHlbOneGp(value);
+                    } else if ("信义污水厂SWCWNHLB2_R_Value".equals(type)) {
+                        industry.setWHlbTwoGp(value);
+                    } else if ("信义污水厂SWCWNHLB3_R_Value".equals(type)) {
+                        industry.setWHlbThreeGp(value);
+                    } else if ("信义污水厂SWCWNHLB4_R_Value".equals(type)) {
+                        industry.setWHlbFourGp(value);
+                    } else if ("信义污水厂SWCWNHLB5_R_Value".equals(type)) {
+                        industry.setWHlbFiveGp(value);
+                    } else if ("信义污水厂GFJ1_R_Value".equals(type)) {
+                        industry.setFjOne(value);
+                    } else if ("信义污水厂GFJ2_R_Value".equals(type)) {
+                        industry.setFjTwo(value);
+                    } else if ("信义污水厂GFJ3_R_Value".equals(type)) {
+                        industry.setFjThree(value);
+                    } else if ("信义污水厂GFJ4_R_Value".equals(type)) {
+                        industry.setFjFour(value);
+                    } else if ("信义污水厂GFJ5_R_Value".equals(type)) {
+                        industry.setFjFive(value);
+                    } else if ("信义污水厂GFJ6_R_Value".equals(type)) {
+                        industry.setFjSix(value);
+                    } else if ("信义污水厂GFJ1_KQLL_Value".equals(type)) {
+                        industry.setKqllOne(value);
+                    } else if ("信义污水厂GFJ2_KQLL_Value".equals(type)) {
+                        industry.setKqllTwo(value);
+                    } else if ("信义污水厂GFJ3_KQLL_Value".equals(type)) {
+                        industry.setKqllThree(value);
+                    } else if ("信义污水厂GFJ4_KQLL_Value".equals(type)) {
+                        industry.setKqllFour(value);
+                    } else if ("信义污水厂GFJ5_KQLL_Value".equals(type)) {
+                        industry.setKqllFive(value);
+                    } else if ("信义污水厂GFJ6_KQLL_Value".equals(type)) {
+                        industry.setKqllSix(value);
+                    }else if ("信义污水厂实际碳源加药量".equals(type)) {
+                        industry.setSJTYJLY(value);
+                    }else if ("信义污水厂除磷加药瞬时流量".equals(type)) {
+                        industry.setCLJYSSLL(value);
+                    }
+                    //只有最后一次才执行数据库添加
+                    if(finalJ == list.size()-1){
+                        //插入数据库
+                        xinyiIndustryMapper.insertTXinyiIndustry(industry);
+                    }
+                });
 
-//    @GetMapping("/dateAdd")
-//    public String dateAdd() {
-//
-//
-//        // 给定时间段的起始时间和结束时间
-//        LocalDateTime startTime = LocalDateTime.parse("2024-04-09T12:00:00");
-//        LocalDateTime endTime = LocalDateTime.parse("2024-04-12T17:30:00");
-//
-//
-//        /*LocalDateTime startTime = LocalDateTime.parse("2024-02-26T00:00:00");
-//        LocalDateTime endTime = LocalDateTime.parse("2024-02-27T00:00:00");*/
-//
-//        // 每个小时的时间格式
-//        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
-//
-//        // 循环按小时分割
-//        LocalDateTime currentHour = startTime;
-//        while (currentHour.isBefore(endTime)) {
-//            String begin = currentHour.format(formatter);
-//            String end = currentHour.plusMinutes(10).format(formatter);
-//            // 输出当前小时的起始时间和结束时间
-//            System.out.println("起始时间：" + begin);
-//            System.out.println("结束时间：" + end);
-//
-//            // 当前小时加一小时，作为下一个小时的起始时间
-//            currentHour = currentHour.plusMinutes(10);
-//
-//            //每个小时查询一次数据
-//            String url = "http://10.0.0.27:4568/api/v1/khquerydata";
-//            HashMap<String, Object> req = new HashMap<>();
-//            req.put("tagNames", queryTags);
-//            req.put("startTime", begin);
-//            req.put("endTime", end);
-//            req.put("recordNumbers", 100000);
-//            String body = HttpRequest.post(url).header("Authorization", "c2E6c2E=").header("clientName", "hongshan").body(JSON.toJSONString(req)).execute().body();
-////            System.out.println("body = " + body);
-//            List<HashMap<String, String>> list = new ArrayList<>();
-//
-//            //行转列数据处理
-//            for (String queryTag : queryTags) {
-//                JSONArray array = JSON.parseObject(body).getJSONArray(queryTag);
-//                //特殊数据处理一
-//                if(Objects.isNull(array) || array.isEmpty()){
-//                    System.out.println(queryTag + "查询到了空的数据，跳过本次循环");
-//                    continue;
-//                }
-//                int size = array.size();
-//                //特殊数据处理二
-//                if("0".equals(array.get(1) + "")){
-//                    System.out.println(queryTag + "查询到了数据，但是数据集合只有一条，且都是0");
-//                    continue;
-//                }
-//                //结合至少62个数据才满足条件(有可能获取不到)
-//                /*if(size < 62){
-//                    System.out.println(queryTag + "查询到了不符合条件的数据，跳过本次循环");
-//                    continue;
-//                }*/
-//
-//                //存放的数据集
-//                //利用map去重
-//                HashMap<String, String> map = new LinkedHashMap<>();
-//                for (int i = 2; i < size; i++) {
-////            System.out.println(i + "" + array.get(i));
-//                    JSONArray oneRecord = JSON.parseArray(JSON.toJSONString(array.get(i)));
-//                    //处理为空或者为0的数据
-//                    Object timeStampValue = oneRecord.get(2);
-//                    if(Objects.isNull(timeStampValue) || "0".equals(timeStampValue + ""))
-//                        continue;
-//                    BigDecimal value = Objects.isNull(oneRecord.get(0)) ? null : new BigDecimal(oneRecord.get(0) + "");
-//                    long timestamp = (long) timeStampValue;
-//                    String format = DateUtil.format(new Date(timestamp), DateUtils.YYYYMMDDHHMM_TS);
-//                    map.put(format, queryTag + "-" + value);
-//                }
-//                list.add(map);
-//            }
-////        System.out.println("list = " + list);
-//            //先构造对象（list中任意一个map遍历的key个数）  因为合并完并不是1分钟60条，参考上面筛选区间，有时候会有几个值获取不到
-//            /*HashMap<String, String> oneRow = list.get(0);
-//            Set<String> set = oneRow.keySet();
-//            List<Industry> result = new ArrayList<>(set.size());
-//            set.forEach(s -> {
-//                Industry industry = new Industry();
-//                industry.setTestTime(s);
-//                result.add(industry);
-//            });*/
-//            Set<String> recordTimeSet = new HashSet<>();
-//            Map<String, TXinyiIndustry> recordMap = new HashMap<>();
-//            for (int i = 0; i < list.size(); i++) {
-//                HashMap<String, String> map = list.get(i);
-//                int finalJ = i;
-//                map.forEach((k, v) ->{
-//                    TXinyiIndustry industry = null;
-//                    if(!recordTimeSet.contains(k)){//第一次
-//                        industry = new TXinyiIndustry();
-//                        recordTimeSet.add(k);
-//                        recordMap.put(k, industry);
-//                    }else{
-//                        industry = recordMap.get(k);
-//                    }
-//                    industry.setTestTime(k);
-//                    //解析值
-//                    String[] split = v.split("-");
-//                    String type = split[0];
-//                    BigDecimal value = new BigDecimal(split[1]);
-//                    if ("信义污水厂JS_COD_Value".equals(type)) {
-//                        industry.setJsCod(value);
-//                    } else if ("信义污水厂JS_PH_Value".equals(type)) {
-//                        industry.setJsPh(value);
-//                    } else if ("信义污水厂JS_SS_Value".equals(type)) {
-//                        industry.setJsSs(value);
-//                    } else if ("信义污水厂JS_ZL_Value".equals(type)) {
-//                        industry.setJsTp(value);
-//                    } else if ("信义污水厂JS_ZA_Value".equals(type)) {
-//                        industry.setJsTn(value);
-//                    } else if ("信义污水厂JS_AD_Value".equals(type)) {
-//                        industry.setJsNh3(value);
-//                    } else if ("信义污水厂JS_T_Value".equals(type)) {
-//                        industry.setJsSwPh(value);
-//                    } else if ("信义污水厂进水泵房液位".equals(type)) {
-//                        industry.setJsBfyw(value);
-//                    } else if ("信义污水厂出水瞬时流量".equals(type)) {
-//                        industry.setCsSlqc(value);
-//                    } else if ("信义污水厂升级出水COD".equals(type)) {
-//                        industry.setCsCod(value);
-//                    } else if ("信义污水厂升级出水PH".equals(type)) {
-//                        industry.setCsPh(value);
-//                    } else if ("信义污水厂升级出水SS".equals(type)) {
-//                        industry.setCsSs(value);
-//                    } else if ("信义污水厂升级出水TN".equals(type)) {
-//                        industry.setCsTn(value);
-//                    } else if ("信义污水厂升级出水TP".equals(type)) {
-//                        industry.setCsTp(value);
-//                    } else if ("信义污水厂升级出水氨氮".equals(type)) {
-//                        industry.setCsNh3(value);
-//                    } else if ("信义污水厂AIT202_Value".equals(type)) {
-//                        industry.setOneHyzdDo(value);
-//                    } else if ("信义污水厂AIT203_Value".equals(type)) {
-//                        industry.setOneHymdDo(value);
-//                    } else if ("信义污水厂AIT207_Value".equals(type)) {
-//                        industry.setTwoHyzdDo(value);
-//                    } else if ("信义污水厂AIT206_Value".equals(type)) {
-//                        industry.setTwoHymdDo(value);
-//                    } else if ("信义污水厂AIT209_Value".equals(type)) {
-//                        industry.setOneMlss(value);
-//                    } else if ("信义污水厂AIT210_Value".equals(type)) {
-//                        industry.setTwoMlss(value);
-//                    } else if ("信义污水厂进水TDS".equals(type)) {
-//                        industry.setJsTds(value);
-//                    } else if ("信义污水厂FT101_Value".equals(type)) {
-//                        industry.setJsSlq(value);
-//                    } else if ("信义污水厂SWCHHYHLB1_R_Value".equals(type)) {
-//                        industry.setNHlbOneGp(value);
-//                    } else if ("信义污水厂SWCHHYHLB2_R_Value".equals(type)) {
-//                        industry.setNHlbTwoGp(value);
-//                    } else if ("信义污水厂SWCHHYHLB3_R_Value".equals(type)) {
-//                        industry.setNHlbThreeGp(value);
-//                    } else if ("信义污水厂SWCHHYHLB4_R_Value".equals(type)) {
-//                        industry.setNHlbFourGp(value);
-//                    } else if ("信义污水厂SWCHHYHLB5_R_Value".equals(type)) {
-//                        industry.setNhlBFiveGp(value);
-//                    } else if ("信义污水厂SWCHHYHLB6_R_Value".equals(type)) {
-//                        industry.setNHlbSixGp(value);
-//                    } else if ("信义污水厂SWCWNHLB1_R_Value".equals(type)) {
-//                        industry.setWHlbOneGp(value);
-//                    } else if ("信义污水厂SWCWNHLB2_R_Value".equals(type)) {
-//                        industry.setWHlbTwoGp(value);
-//                    } else if ("信义污水厂SWCWNHLB3_R_Value".equals(type)) {
-//                        industry.setWHlbThreeGp(value);
-//                    } else if ("信义污水厂SWCWNHLB4_R_Value".equals(type)) {
-//                        industry.setWHlbFourGp(value);
-//                    } else if ("信义污水厂SWCWNHLB5_R_Value".equals(type)) {
-//                        industry.setWHlbFiveGp(value);
-//                    } else if ("信义污水厂GFJ1_R_Value".equals(type)) {
-//                        industry.setFjOne(value);
-//                    } else if ("信义污水厂GFJ2_R_Value".equals(type)) {
-//                        industry.setFjTwo(value);
-//                    } else if ("信义污水厂GFJ3_R_Value".equals(type)) {
-//                        industry.setFjThree(value);
-//                    } else if ("信义污水厂GFJ4_R_Value".equals(type)) {
-//                        industry.setFjFour(value);
-//                    } else if ("信义污水厂GFJ5_R_Value".equals(type)) {
-//                        industry.setFjFive(value);
-//                    } else if ("信义污水厂GFJ6_R_Value".equals(type)) {
-//                        industry.setFjSix(value);
-//                    } else if ("信义污水厂GFJ1_KQLL_Value".equals(type)) {
-//                        industry.setKqllOne(value);
-//                    } else if ("信义污水厂GFJ2_KQLL_Value".equals(type)) {
-//                        industry.setKqllTwo(value);
-//                    } else if ("信义污水厂GFJ3_KQLL_Value".equals(type)) {
-//                        industry.setKqllThree(value);
-//                    } else if ("信义污水厂GFJ4_KQLL_Value".equals(type)) {
-//                        industry.setKqllFour(value);
-//                    } else if ("信义污水厂GFJ5_KQLL_Value".equals(type)) {
-//                        industry.setKqllFive(value);
-//                    } else if ("信义污水厂GFJ6_KQLL_Value".equals(type)) {
-//                        industry.setKqllSix(value);
-//                    }else if ("信义污水厂实际碳源加药量".equals(type)) {
-//                        industry.setSJTYJLY(value);
-//                    }else if ("信义污水厂除磷加药瞬时流量".equals(type)) {
-//                        industry.setCLJYSSLL(value);
-//                    }
-//                    //只有最后一次才执行数据库添加
-//                    if(finalJ == list.size()-1){
-//                        //插入数据库
-//                        xinyiIndustryMapper.insertTXinyiIndustry(industry);
-//                    }
-//                });
-//
-//
-//
-//
-//            }
-//
-//        }
-//        return "ok";
-//    }
+
+
+
+            }
+
+        }
+        return "ok";
+    }
 
 //    @GetMapping("/dateUpdateCL")
 //    public String dateUpdateCL() {

slibra-admin/src/test/java/com/slibra/MyTest.java

@@ -151,7 +151,7 @@ public class MyTest {
         //主
         if(!CollectionUtils.isEmpty(tXinyiRobots)){
             for (TXinyiRobot tXinyiRobot : tXinyiRobots) {
-                tXinyiRobot.setvDateTime(tXinyiRobot.getvDate() + tXinyiRobot.getvTime());
+                tXinyiRobot.setVDateTime(tXinyiRobot.getVDate() + tXinyiRobot.getVTime());
                 tXinyiRobot.setCreatedTime(new Date());
                 this.xinyiRobotMapper.insertTXinyiRobot(tXinyiRobot);
             }