生物防控人员

huimv-admin/src/main/java/com/huimv/admin/timer/ShenChanTimer.java

@@ -38,25 +38,81 @@ public class ShenChanTimer {
     private IProdStockService prodStockService;
 
 
-    @Scheduled(cron = "0 0 */4 * * ? ")
-//    @Scheduled(cron = "0 * * * * ?")
-    @GetMapping("/test")
+//    @Scheduled(cron = "0 0 */4 * * ? ")
+    @Scheduled(cron = "0 0 * * * ?")
+//    @GetMapping("/test")
     private void getShenChan() throws Exception {
-        Integer farmId = 21;
-        List<Integer> farmIds = new ArrayList();
-        farmIds.add(21);
-        farmIds.add(23);
-        farmIds.add(24);
-        farmIds.add(26);
-        farmIds.add(27);
-        farmIds.add(28);
-        farmIds.add(29);
-        String time = LocalDate.now().toString();
         String token = login();
-//        System.out.println("token"+token);
         DateTime dateTime = DateUtil.beginOfDay(new Date());
-        System.out.println(token);
+        String data =   getList(token);
+        ProdStockDto prodStockDto = JSONUtil.toBean(data, ProdStockDto.class);
+        List<List<Object>> stockData = prodStockDto.getData();
+
+        for (List stock : stockData) {
+            switch (stock.get(0).toString()) {
+                case "正康":
+                    saveProdStrok(21,stock,dateTime);
+                    break;
+                case "东阳":
+                    saveProdStrok(24,stock,dateTime);
+                    break;
+                case "浦江":
+                    saveProdStrok(23,stock,dateTime);
+                    break;
+                case "横路":
+                    saveProdStrok(26,stock,dateTime);
+                    break;
+                case "天台":
+                    saveProdStrok(27,stock,dateTime);
+                    break;
+                case "平望":
+                    saveProdStrok(28,stock,dateTime);
+                    break;
+                case "张村":
+                    saveProdStrok(29,stock,dateTime);
+                    break;
+                default:
+                    break;
+            }
+        }
+    }
+    //保存存栏
+    private void saveProdStrok(Integer farmId,List stock,DateTime dateTime) {
+        ProdStock prodStock = prodStockService.getOne(new QueryWrapper<ProdStock>().ge("creat_time", dateTime).eq("farm_id", farmId).orderByDesc("creat_time").last("limit 1"));
+        Boolean isNew = false;
+        if(ObjectUtil.isEmpty(prodStock)){
+            prodStock = new ProdStock();
+             isNew = true;
+        }
+        prodStock.setHbzcl(Integer.parseInt(stock.get(3).toString()));
+        prodStock.setGzcl(Integer.parseInt(stock.get(4).toString()));
+        prodStock.setKhzcl(Integer.parseInt(stock.get(6).toString()));
+
+        prodStock.setZzcl(Integer.parseInt(stock.get(12).toString()));
+        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
+        prodStock.setYfzcl(Integer.parseInt(stock.get(15).toString()));
+        prodStock.setZcl(Integer.parseInt(stock.get(16).toString()));
+
+        if (isNew) {
+            prodStock.setMzcl(100);
+            prodStock.setBrzcl(452);
+            prodStock.setRszcl(30);
+            prodStock.setBrmzcl(20);
+            prodStock.setSpzcl(1020);
+            prodStock.setCreatTime(new Date());
+            prodStock.setDisplayType(0);
+            prodStock.setFarmId(farmId);
+            prodStockService.save(prodStock);
+        } else {
+
+            prodStockService.updateById(prodStock);
+        }
+
+    }
 
+    //获取数据
+    private String getList(String token) throws Exception {
+        String time = LocalDate.now().toString();
         String url = "http://test.htpig.cn/rest/db/storedproc";
         Map<String, Object> map = new HashMap<String, Object>();
         map.put("db_name", "MSSQL");
@@ -67,292 +123,11 @@ public class ShenChanTimer {
         maps.put("name", "@fdate");
         maps.put("value", time);
         list.add(maps);
-
         map.put("params", list);
         String params = JSON.toJSONString(map);
-        System.out.println(" ====== getStock请求参数：【" + params + "】");
         String data = HttpClientSSLUtils.doPost(url + "?token=" + token + "&data=", params);
-        ProdStockDto prodStockDto = JSONUtil.toBean(data, ProdStockDto.class);
-        List<List<Object>> stockData = prodStockDto.getData();
-        System.out.println(prodStockDto.toString());
-        for (Integer id : farmIds) {
-            ProdStock prodStock = prodStockService.getOne(new QueryWrapper<ProdStock>().ge("creat_time", dateTime).eq("farm_id", id).orderByDesc("creat_time").last("limit 1"));
-
-            for (List stock : stockData) {
-                if ("正康".equals(stock.get(0))) {
-                    if (ObjectUtil.isNotEmpty(prodStock)) {
-                        prodStock.setZzcl(Integer.parseInt(stock.get(12).toString()));
-                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setFarmId(21);
-                        prodStock.setDisplayType(0);
-                        prodStockService.updateById(prodStock);
-                    } else {
-                        prodStock = new ProdStock();
-                        prodStock.setZzcl(Integer.parseInt(stock.get(12).toString()));
-                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setMzcl(100);
-                        prodStock.setGzcl(200);
-                        prodStock.setBrzcl(452);
-                        prodStock.setHbzcl(100);
-                        prodStock.setRszcl(30);
-                        prodStock.setBrmzcl(20);
-                        prodStock.setKhzcl(212);
-                        prodStock.setSpzcl(1020);
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setDisplayType(0);
-                        prodStock.setFarmId(21);
-                        prodStockService.save(prodStock);
-                    }
-
-                }
-
-                if ("东阳".equals(stock.get(0))) {
-                    if (ObjectUtil.isNotEmpty(prodStock)) {
-                        prodStock.setGzcl(Integer.parseInt(stock.get(1).toString()));
-                        prodStock.setMzcl(Integer.parseInt(stock.get(2).toString()));
-                        prodStock.setHbzcl(Integer.parseInt(stock.get(3).toString()));
-                        prodStock.setKhzcl(Integer.parseInt(stock.get(6).toString()));
-                        prodStock.setZzcl(Integer.parseInt(stock.get(12).toString()));
-                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setFarmId(24);
-                        prodStockService.updateById(prodStock);
-                        System.out.println("东阳--》");
-                    } else {
-                        prodStock = new ProdStock();
-                        prodStock.setZzcl(5433);
-                        prodStock.setByzcl(6760);
-                        prodStock.setYfzcl(4361);
-                        prodStock.setZcl(16554);
-                        prodStock.setMzcl(100);
-                        prodStock.setGzcl(200);
-                        prodStock.setBrzcl(452);
-                        prodStock.setHbzcl(100);
-                        prodStock.setRszcl(30);
-                        prodStock.setBrmzcl(20);
-                        prodStock.setKhzcl(212);
-                        prodStock.setSpzcl(1020);
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setFarmId(24);
-                        prodStockService.save(prodStock);
-                        System.out.println("东阳");
-                    }
-                }
-                if ("浦江".equals(stock.get(0))) {
-                    if (ObjectUtil.isNotEmpty(prodStock)) {
-                        prodStock.setGzcl(Integer.parseInt(stock.get(1).toString()));
-                        prodStock.setMzcl(Integer.parseInt(stock.get(2).toString()));
-                        prodStock.setHbzcl(Integer.parseInt(stock.get(3).toString()));
-                        prodStock.setKhzcl(Integer.parseInt(stock.get(6).toString()));
-                        prodStock.setZzcl(Integer.parseInt(stock.get(12).toString()));
-                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setFarmId(23);
-                        prodStock.setDisplayType(0);
-                        prodStockService.updateById(prodStock);
-                        System.out.println("浦江--》");
-                    } else {
-                        prodStock = new ProdStock();
-//                        prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
-                        prodStock.setZzcl(9980);
-//                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setByzcl(16384);
-//                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setYfzcl(32999);
-//                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setZcl(66381);
-                        prodStock.setMzcl(100);
-                        prodStock.setGzcl(200);
-                        prodStock.setBrzcl(452);
-                        prodStock.setHbzcl(100);
-                        prodStock.setRszcl(30);
-                        prodStock.setBrmzcl(20);
-                        prodStock.setKhzcl(212);
-                        prodStock.setSpzcl(1020);
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setDisplayType(0);
-                        prodStock.setFarmId(23);
-                        prodStockService.save(prodStock);
-                        System.out.println("浦江--》");
-                    }
-
-                }
-
-                if ("横路".equals(stock.get(0))) {
-                    if (ObjectUtil.isNotEmpty(prodStock)) {
-                        prodStock.setGzcl(Integer.parseInt(stock.get(1).toString()));
-                        prodStock.setMzcl(Integer.parseInt(stock.get(2).toString()));
-                        prodStock.setHbzcl(Integer.parseInt(stock.get(3).toString()));
-                        prodStock.setKhzcl(Integer.parseInt(stock.get(6).toString()));
-                        prodStock.setZzcl(Integer.parseInt(stock.get(12).toString()));
-                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setFarmId(26);
-                        prodStock.setDisplayType(0);
-                        prodStockService.updateById(prodStock);
-                        System.out.println("横路--》");
-                    } else {
-                        prodStock = new ProdStock();
-//                        prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
-                        prodStock.setZzcl(9980);
-//                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setByzcl(16384);
-//                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setYfzcl(32999);
-//                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setZcl(66381);
-                        prodStock.setMzcl(100);
-                        prodStock.setGzcl(200);
-                        prodStock.setBrzcl(452);
-                        prodStock.setHbzcl(100);
-                        prodStock.setRszcl(30);
-                        prodStock.setBrmzcl(20);
-                        prodStock.setKhzcl(212);
-                        prodStock.setSpzcl(1020);
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setFarmId(26);
-                        prodStock.setDisplayType(0);
-                        prodStockService.save(prodStock);
-                        System.out.println("横路--》");
-                    }
+        return data;
 
-                }
-                if ("天台".equals(stock.get(0))) {
-                    if (ObjectUtil.isNotEmpty(prodStock)) {
-                        prodStock.setGzcl(Integer.parseInt(stock.get(1).toString()));
-                        prodStock.setMzcl(Integer.parseInt(stock.get(2).toString()));
-                        prodStock.setHbzcl(Integer.parseInt(stock.get(3).toString()));
-                        prodStock.setKhzcl(Integer.parseInt(stock.get(6).toString()));
-                        prodStock.setZzcl(Integer.parseInt(stock.get(12).toString()));
-                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setDisplayType(0);
-                        prodStock.setFarmId(27);
-                        prodStockService.updateById(prodStock);
-                        System.out.println("天台--》");
-                    } else {
-                        prodStock = new ProdStock();
-//                        prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
-                        prodStock.setZzcl(9980);
-//                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setByzcl(16384);
-//                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setYfzcl(32999);
-//                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setZcl(66381);
-                        prodStock.setMzcl(100);
-                        prodStock.setGzcl(200);
-                        prodStock.setBrzcl(452);
-                        prodStock.setHbzcl(100);
-                        prodStock.setRszcl(30);
-                        prodStock.setBrmzcl(20);
-                        prodStock.setKhzcl(212);
-                        prodStock.setSpzcl(1020);
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setFarmId(27);
-                        prodStock.setDisplayType(0);
-                        prodStockService.save(prodStock);
-                        System.out.println("天台--》");
-                    }
-
-                }
-                if ("平望".equals(stock.get(0))) {
-                    if (ObjectUtil.isNotEmpty(prodStock)) {
-                        prodStock.setGzcl(Integer.parseInt(stock.get(1).toString()));
-                        prodStock.setMzcl(Integer.parseInt(stock.get(2).toString()));
-                        prodStock.setHbzcl(Integer.parseInt(stock.get(3).toString()));
-                        prodStock.setKhzcl(Integer.parseInt(stock.get(6).toString()));
-                        prodStock.setZzcl(Integer.parseInt(stock.get(12).toString()));
-                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setDisplayType(0);
-                        prodStock.setFarmId(28);
-                        prodStockService.updateById(prodStock);
-                        System.out.println("平望--》");
-                    } else {
-                        prodStock = new ProdStock();
-//                        prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
-                        prodStock.setZzcl(9980);
-//                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setByzcl(16384);
-//                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setYfzcl(32999);
-//                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setZcl(66381);
-                        prodStock.setMzcl(100);
-                        prodStock.setGzcl(200);
-                        prodStock.setBrzcl(452);
-                        prodStock.setHbzcl(100);
-                        prodStock.setRszcl(30);
-                        prodStock.setBrmzcl(20);
-                        prodStock.setKhzcl(212);
-                        prodStock.setSpzcl(1020);
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setFarmId(28);
-                        prodStock.setDisplayType(0);
-                        prodStockService.save(prodStock);
-                        System.out.println("平望--》");
-                    }
-
-                }
-                if ("张村".equals(stock.get(0))) {
-                    if (ObjectUtil.isNotEmpty(prodStock)) {
-                        prodStock.setGzcl(Integer.parseInt(stock.get(1).toString()));
-                        prodStock.setMzcl(Integer.parseInt(stock.get(2).toString()));
-                        prodStock.setHbzcl(Integer.parseInt(stock.get(3).toString()));
-                        prodStock.setKhzcl(Integer.parseInt(stock.get(6).toString()));
-                        prodStock.setZzcl(Integer.parseInt(stock.get(12).toString()));
-                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setDisplayType(0);
-                        prodStock.setFarmId(29);
-                        prodStockService.updateById(prodStock);
-                        System.out.println("张村--》");
-                    } else {
-                        prodStock = new ProdStock();
-//                        prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
-                        prodStock.setZzcl(9980);
-//                        prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
-                        prodStock.setByzcl(16384);
-//                        prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
-                        prodStock.setYfzcl(32999);
-//                        prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
-                        prodStock.setZcl(66381);
-                        prodStock.setMzcl(100);
-                        prodStock.setGzcl(200);
-                        prodStock.setBrzcl(452);
-                        prodStock.setHbzcl(100);
-                        prodStock.setRszcl(30);
-                        prodStock.setBrmzcl(20);
-                        prodStock.setKhzcl(212);
-                        prodStock.setSpzcl(1020);
-                        prodStock.setCreatTime(new Date());
-                        prodStock.setFarmId(29);
-                        prodStock.setDisplayType(0);
-                        prodStockService.save(prodStock);
-                        System.out.println("张村--》");
-                    }
-
-                }
-            }
-        }
     }
 
 
@@ -361,8 +136,6 @@ public class ShenChanTimer {
         StockLoginDto stockLoginDto = restTemplate.getForObject("http://test.htpig.cn/rest/user/login?user_name=test&password=e10adc3949ba59abbe56e057f20f883e&db_name=MSSQL", StockLoginDto.class);
         String token = stockLoginDto.getToken();
         String time = LocalDate.now().toString();
-        System.out.println(token);
-
         String url = "http://test.htpig.cn/rest/db/storedproc";
         Map<String, Object> map = new HashMap<String, Object>();
         map.put("db_name", "MSSQL");
@@ -379,10 +152,9 @@ public class ShenChanTimer {
         System.out.println(" ====== getStock请求参数：【" + params + "】");
         String data = HttpClientSSLUtils.doPost(url + "?token=" + token + "&data=", params);
         ProdStockDto prodStockDto = JSONUtil.toBean(data, ProdStockDto.class);
-        System.out.println(prodStockDto.toString());
     }
 
-    private String login() throws Exception {
+    private  String login() throws Exception {
         StockLoginDto stockLoginDto = restTemplate.getForObject("http://test.htpig.cn/rest/user/login?user_name=test&password=e10adc3949ba59abbe56e057f20f883e&db_name=MSSQL", StockLoginDto.class);
         if (stockLoginDto.getStatus() != 0) {
             return null;