|
@@ -1,198 +1,198 @@
|
|
|
-package com.huimv.admin.timer;
|
|
|
-
|
|
|
-
|
|
|
-import cn.hutool.core.codec.Base64;
|
|
|
-import cn.hutool.core.date.DateTime;
|
|
|
-import cn.hutool.core.date.DateUtil;
|
|
|
-import cn.hutool.core.util.ObjectUtil;
|
|
|
-import cn.hutool.json.JSONObject;
|
|
|
-import cn.hutool.json.JSONUtil;
|
|
|
-import com.alibaba.fastjson.JSON;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
-import com.huimv.admin.common.utils.Digests;
|
|
|
-import com.huimv.admin.common.utils.HttpClientSSLUtils;
|
|
|
-import com.huimv.admin.entity.*;
|
|
|
-import com.huimv.admin.entity.zengxindto.*;
|
|
|
-import com.huimv.admin.service.*;
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.context.annotation.Configuration;
|
|
|
-import org.springframework.http.*;
|
|
|
-import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
-import org.springframework.scheduling.annotation.Scheduled;
|
|
|
-import org.springframework.transaction.annotation.Transactional;
|
|
|
-import org.springframework.web.bind.annotation.GetMapping;
|
|
|
-import org.springframework.web.client.RestTemplate;
|
|
|
-
|
|
|
-import java.time.LocalDate;
|
|
|
-import java.util.*;
|
|
|
-
|
|
|
-@Configuration
|
|
|
-@EnableScheduling
|
|
|
-public class ShenChanTimer {
|
|
|
-
|
|
|
- //生产数据
|
|
|
- @Autowired
|
|
|
- private RestTemplate restTemplate;
|
|
|
- @Autowired
|
|
|
- private IProdStockService prodStockService;
|
|
|
-
|
|
|
-
|
|
|
- @Scheduled(cron = "0 0 */4 * * ? ")
|
|
|
-// @Scheduled(cron = "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);
|
|
|
- String time = LocalDate.now().toString();
|
|
|
- String token = login();
|
|
|
-// System.out.println("token"+token);
|
|
|
- DateTime dateTime = DateUtil.beginOfDay(new Date());
|
|
|
- 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");
|
|
|
- map.put("proc_name","rep_yz_kc_hz");
|
|
|
- map.put("method","open_proc");
|
|
|
- HashMap<String, Object> maps = new HashMap<>();
|
|
|
- List list = new ArrayList();
|
|
|
- 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(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()));
|
|
|
- prodStock.setCreatTime(new Date());
|
|
|
- prodStock.setFarmId(21);
|
|
|
- prodStockService.updateById(prodStock);
|
|
|
- }else {
|
|
|
- prodStock = new ProdStock();
|
|
|
- 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()));
|
|
|
- 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(21);
|
|
|
- prodStockService.save(prodStock);
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- if ("东阳".equals(stock.get(0))){
|
|
|
- if (ObjectUtil.isNotEmpty(prodStock)){
|
|
|
-// prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
|
|
|
- prodStock.setZzcl(5433);
|
|
|
-// prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
|
|
|
- prodStock.setByzcl(6760);
|
|
|
-// prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
|
|
|
- prodStock.setYfzcl(4361);
|
|
|
-// prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
|
|
|
- prodStock.setZcl(16554);
|
|
|
- prodStock.setCreatTime(new Date());
|
|
|
- prodStock.setFarmId(24);
|
|
|
- prodStockService.updateById(prodStock);
|
|
|
- System.out.println("东阳--》");
|
|
|
- }else {
|
|
|
- prodStock = new ProdStock();
|
|
|
- // prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
|
|
|
- prodStock.setZzcl(5433);
|
|
|
-// prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
|
|
|
- prodStock.setByzcl(6760);
|
|
|
-// prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
|
|
|
- prodStock.setYfzcl(4361);
|
|
|
-// prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
|
|
|
- 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)){
|
|
|
+//package com.huimv.admin.timer;
|
|
|
+//
|
|
|
+//
|
|
|
+//import cn.hutool.core.codec.Base64;
|
|
|
+//import cn.hutool.core.date.DateTime;
|
|
|
+//import cn.hutool.core.date.DateUtil;
|
|
|
+//import cn.hutool.core.util.ObjectUtil;
|
|
|
+//import cn.hutool.json.JSONObject;
|
|
|
+//import cn.hutool.json.JSONUtil;
|
|
|
+//import com.alibaba.fastjson.JSON;
|
|
|
+//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+//import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
+//import com.huimv.admin.common.utils.Digests;
|
|
|
+//import com.huimv.admin.common.utils.HttpClientSSLUtils;
|
|
|
+//import com.huimv.admin.entity.*;
|
|
|
+//import com.huimv.admin.entity.zengxindto.*;
|
|
|
+//import com.huimv.admin.service.*;
|
|
|
+//import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+//import org.springframework.context.annotation.Configuration;
|
|
|
+//import org.springframework.http.*;
|
|
|
+//import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
+//import org.springframework.scheduling.annotation.Scheduled;
|
|
|
+//import org.springframework.transaction.annotation.Transactional;
|
|
|
+//import org.springframework.web.bind.annotation.GetMapping;
|
|
|
+//import org.springframework.web.client.RestTemplate;
|
|
|
+//
|
|
|
+//import java.time.LocalDate;
|
|
|
+//import java.util.*;
|
|
|
+//
|
|
|
+//@Configuration
|
|
|
+//@EnableScheduling
|
|
|
+//public class ShenChanTimer {
|
|
|
+//
|
|
|
+// //生产数据
|
|
|
+// @Autowired
|
|
|
+// private RestTemplate restTemplate;
|
|
|
+// @Autowired
|
|
|
+// private IProdStockService prodStockService;
|
|
|
+//
|
|
|
+//
|
|
|
+// @Scheduled(cron = "0 0 */4 * * ? ")
|
|
|
+//// @Scheduled(cron = "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);
|
|
|
+// String time = LocalDate.now().toString();
|
|
|
+// String token = login();
|
|
|
+//// System.out.println("token"+token);
|
|
|
+// DateTime dateTime = DateUtil.beginOfDay(new Date());
|
|
|
+// 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");
|
|
|
+// map.put("proc_name","rep_yz_kc_hz");
|
|
|
+// map.put("method","open_proc");
|
|
|
+// HashMap<String, Object> maps = new HashMap<>();
|
|
|
+// List list = new ArrayList();
|
|
|
+// 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(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.setCreatTime(new Date());
|
|
|
- prodStock.setFarmId(23);
|
|
|
- prodStockService.updateById(prodStock);
|
|
|
- System.out.println("浦江--》");
|
|
|
- }else {
|
|
|
- prodStock = new ProdStock();
|
|
|
+// prodStock.setCreatTime(new Date());
|
|
|
+// prodStock.setFarmId(21);
|
|
|
+// prodStockService.updateById(prodStock);
|
|
|
+// }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(23);
|
|
|
- prodStockService.save(prodStock);
|
|
|
- System.out.println("浦江--》");
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- 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();
|
|
|
- }
|
|
|
-
|
|
|
-}
|
|
|
+// 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(21);
|
|
|
+// prodStockService.save(prodStock);
|
|
|
+// }
|
|
|
+//
|
|
|
+// }
|
|
|
+//
|
|
|
+// if ("东阳".equals(stock.get(0))){
|
|
|
+// if (ObjectUtil.isNotEmpty(prodStock)){
|
|
|
+//// prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
|
|
|
+// prodStock.setZzcl(5433);
|
|
|
+//// prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
|
|
|
+// prodStock.setByzcl(6760);
|
|
|
+//// prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
|
|
|
+// prodStock.setYfzcl(4361);
|
|
|
+//// prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
|
|
|
+// prodStock.setZcl(16554);
|
|
|
+// prodStock.setCreatTime(new Date());
|
|
|
+// prodStock.setFarmId(24);
|
|
|
+// prodStockService.updateById(prodStock);
|
|
|
+// System.out.println("东阳--》");
|
|
|
+// }else {
|
|
|
+// prodStock = new ProdStock();
|
|
|
+// // prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
|
|
|
+// prodStock.setZzcl(5433);
|
|
|
+//// prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
|
|
|
+// prodStock.setByzcl(6760);
|
|
|
+//// prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
|
|
|
+// prodStock.setYfzcl(4361);
|
|
|
+//// prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
|
|
|
+// 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.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.setCreatTime(new Date());
|
|
|
+// prodStock.setFarmId(23);
|
|
|
+// 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(23);
|
|
|
+// prodStockService.save(prodStock);
|
|
|
+// System.out.println("浦江--》");
|
|
|
+// }
|
|
|
+//
|
|
|
+// }
|
|
|
+// }
|
|
|
+// }
|
|
|
+// }
|
|
|
+//
|
|
|
+//
|
|
|
+// 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();
|
|
|
+// }
|
|
|
+//
|
|
|
+//}
|