存栏

huimv-admin/src/main/java/com/huimv/admin/entity/ProdStock.java

@@ -83,6 +83,18 @@ public class ProdStock implements Serializable {
     /**
      * 商品猪存栏
      */
+
+    private Integer zzcl;
+
+    /**
+     * 仔猪存栏
+     */
+
+    private Integer zcl;
+
+    /**
+     * 总存栏
+     */
     @JsonFormat(pattern = "yyyy-MM",timezone = "GMT+8")
     private LocalDateTime creatTime;
 

huimv-admin/src/main/java/com/huimv/admin/entity/zengxindto/ProdStockDto.java

@@ -3,11 +3,14 @@ package com.huimv.admin.entity.zengxindto;
 import lombok.Data;
 
 import java.util.List;
+import java.util.Map;
 
 @Data
 public class ProdStockDto {
     private Integer status;
     private String message;
-    private List<Object> params;
-    private List<List<Object>> meta;
+    private Integer rowsAffected;
+    private List<Map<String,String>> params;
+    private List<Map<String,Object>> meta;
+    private List<List<Object>> data;
 }

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

@@ -34,40 +34,18 @@ public class ShenChanTimer {
     private RestTemplate restTemplate;
     @Autowired
     private IProdStockService prodStockService;
-    //
-    String username = "test";
-    String password = "123456";
-    String passwordMD5 = "e10adc3949ba59abbe56e057f20f883e";
-    String dbName = "MSSQL";
 
 
-    @Scheduled(cron = "0 0/11 * * * ? ")
+//    @Scheduled(cron = "0 0/11 * * * ? ")
+    @Scheduled(cron = "0 1 */1 * * ?")
     private void getShenChan() throws Exception {
-        //自己生成
-//        if (false){
-
-
-//        }else {
-            //没接口，暂时没有
-//        }
-        //目前是这家
-      //  /rest/db/storedproc?token=B6A0EA2A2E7D44A7AFFC53194B220CAD&data={"db_name":"MSSQL","proc_name":"rep_yz_kc_hz","method":"open_proc","params":[{"name":"@fdate","value":"2023-02-13"}]}
         Integer farmId = 21;
+        String time = LocalDate.now().toString();
         String token = login();
         System.out.println("token"+token);
-        ProdStock prodStock = prodStockService.getOne(new QueryWrapper<ProdStock>().eq("farm_id", farmId));
-    }
+        ProdStock prodStock = prodStockService.getOne(new QueryWrapper<ProdStock>().eq("farm_id", farmId).orderByDesc("creat_time").last("limit 1"));
 
-    public static void main(String[] args) throws Exception {
-        RestTemplate restTemplate = new RestTemplate();
-        String time = LocalDate.now().toString();
-        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();
         System.out.println(token);
-        //http://test.htpig.cn/rest/db/storedproc?token=" + token + "&data={\"db_name\":\"MSSQL\",\"proc_name\":\"rep_yz_kc_hz\",\"method\":\"open_proc\",\"params\":[{\"name\":\"@fdate\",\"value\":\"" + time + "\"}]}
-//        String getStr ="\"db_name\":\"MSSQL\",\"proc_name\":\"rep_yz_kc_hz\",\"method\":\"open_proc\",\"params\":[{\"name\":\"@fdate\",\"value\":\"2023-02-13\"}]";
-
-
 
         String url = "http://test.htpig.cn/rest/db/storedproc";
         Map<String, Object> map = new HashMap<String, Object>();
@@ -77,29 +55,35 @@ public class ShenChanTimer {
         HashMap<String, Object> maps = new HashMap<>();
         List list = new ArrayList();
         maps.put("name","@fdate");
-        maps.put("value","2023-02-13");
+        maps.put("value",time);
         list.add(maps);
 
         map.put("params",list);
         String params = JSON.toJSONString(map);
-        System.out.println(" ====== getCameras请求参数：【" + params + "】");
-        String data = HttpClientSSLUtils.doPost(url+"?token="+token, params);
-        System.out.println(" ====== getCameras请求返回结果：【{" + data + "}】");
-        ProdStockDto loginDto = JSONUtil.toBean(data, ProdStockDto.class);
-
-        System.out.println(loginDto.toString());
+        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 (List stock : stockData) {
+            if ("正康".equals(stock.get(0))){
+                prodStock.setZzcl(Integer.parseInt(stock.get(11).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()));
+                prodStockService.updateById(prodStock);
+            }
+        }
 
     }
 
+
     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;
         }
         return stockLoginDto.getToken();
-        //        LoginOnlyDto loginDto = JSONUtil.toBean(s, LoginOnlyDto.class);
-//        LonginOnlyDtoToken token = loginDto.getData().getToken();
-//        return Base64.encode(token.getUserId() + "_" + token.getToken());
     }
 
 }