ShenChanTimer.java 9.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188
  1. //package com.huimv.admin.timer;
  2. //
  3. //
  4. //import cn.hutool.core.codec.Base64;
  5. //import cn.hutool.core.date.DateTime;
  6. //import cn.hutool.core.date.DateUtil;
  7. //import cn.hutool.core.util.ObjectUtil;
  8. //import cn.hutool.json.JSONObject;
  9. //import cn.hutool.json.JSONUtil;
  10. //import com.alibaba.fastjson.JSON;
  11. //import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  12. //import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  13. //import com.huimv.admin.common.utils.Digests;
  14. //import com.huimv.admin.common.utils.HttpClientSSLUtils;
  15. //import com.huimv.admin.entity.*;
  16. //import com.huimv.admin.entity.zengxindto.*;
  17. //import com.huimv.admin.service.*;
  18. //import org.springframework.beans.factory.annotation.Autowired;
  19. //import org.springframework.context.annotation.Configuration;
  20. //import org.springframework.http.*;
  21. //import org.springframework.scheduling.annotation.EnableScheduling;
  22. //import org.springframework.scheduling.annotation.Scheduled;
  23. //import org.springframework.transaction.annotation.Transactional;
  24. //import org.springframework.web.bind.annotation.GetMapping;
  25. //import org.springframework.web.client.RestTemplate;
  26. //
  27. //import java.time.LocalDate;
  28. //import java.util.*;
  29. //
  30. //@Configuration
  31. //@EnableScheduling
  32. //public class ShenChanTimer {
  33. //
  34. // //生产数据
  35. // @Autowired
  36. // private RestTemplate restTemplate;
  37. // @Autowired
  38. // private IProdStockService prodStockService;
  39. //
  40. //
  41. // @Scheduled(cron = "0 0 */4 * * ? ")
  42. //// @Scheduled(cron = "0 * * * * ?")
  43. // @GetMapping("/test")
  44. // private void getShenChan() throws Exception {
  45. // Integer farmId = 21;
  46. // List<Integer> farmIds = new ArrayList();
  47. // farmIds.add(21);
  48. // farmIds.add(23);
  49. // farmIds.add(24);
  50. // String time = LocalDate.now().toString();
  51. // String token = login();
  52. //// System.out.println("token"+token);
  53. // DateTime dateTime = DateUtil.beginOfDay(new Date());
  54. // System.out.println(token);
  55. //
  56. // String url = "http://test.htpig.cn/rest/db/storedproc";
  57. // Map<String, Object> map = new HashMap<String, Object>();
  58. // map.put("db_name","MSSQL");
  59. // map.put("proc_name","rep_yz_kc_hz");
  60. // map.put("method","open_proc");
  61. // HashMap<String, Object> maps = new HashMap<>();
  62. // List list = new ArrayList();
  63. // maps.put("name","@fdate");
  64. // maps.put("value",time);
  65. // list.add(maps);
  66. //
  67. // map.put("params",list);
  68. // String params = JSON.toJSONString(map);
  69. // System.out.println(" ====== getStock请求参数:【" + params + "】");
  70. // String data = HttpClientSSLUtils.doPost(url+"?token="+token+"&data=", params);
  71. // ProdStockDto prodStockDto = JSONUtil.toBean(data, ProdStockDto.class);
  72. // List<List<Object>> stockData = prodStockDto.getData();
  73. // System.out.println(prodStockDto.toString());
  74. // for (Integer id : farmIds) {
  75. // ProdStock prodStock = prodStockService.getOne(new QueryWrapper<ProdStock>().ge("creat_time",dateTime).eq("farm_id", id).orderByDesc("creat_time").last("limit 1"));
  76. //
  77. // for (List stock : stockData) {
  78. // if ("正康".equals(stock.get(0))){
  79. // if (ObjectUtil.isNotEmpty(prodStock)){
  80. // prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
  81. // prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
  82. // prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
  83. // prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
  84. // prodStock.setCreatTime(new Date());
  85. // prodStock.setFarmId(21);
  86. // prodStockService.updateById(prodStock);
  87. // }else {
  88. // prodStock = new ProdStock();
  89. // prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
  90. // prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
  91. // prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
  92. // prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
  93. // prodStock.setMzcl(100);
  94. // prodStock.setGzcl(200);
  95. // prodStock.setBrzcl(452);
  96. // prodStock.setHbzcl(100);
  97. // prodStock.setRszcl(30);
  98. // prodStock.setBrmzcl(20);
  99. // prodStock.setKhzcl(212);
  100. // prodStock.setSpzcl(1020);
  101. // prodStock.setCreatTime(new Date());
  102. // prodStock.setFarmId(21);
  103. // prodStockService.save(prodStock);
  104. // }
  105. //
  106. // }
  107. //
  108. // if ("东阳".equals(stock.get(0))){
  109. // if (ObjectUtil.isNotEmpty(prodStock)){
  110. //// prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
  111. // prodStock.setZzcl(5433);
  112. //// prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
  113. // prodStock.setByzcl(6760);
  114. //// prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
  115. // prodStock.setYfzcl(4361);
  116. //// prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
  117. // prodStock.setZcl(16554);
  118. // prodStock.setCreatTime(new Date());
  119. // prodStock.setFarmId(24);
  120. // prodStockService.updateById(prodStock);
  121. // System.out.println("东阳--》");
  122. // }else {
  123. // prodStock = new ProdStock();
  124. // // prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
  125. // prodStock.setZzcl(5433);
  126. //// prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
  127. // prodStock.setByzcl(6760);
  128. //// prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
  129. // prodStock.setYfzcl(4361);
  130. //// prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
  131. // prodStock.setZcl(16554);
  132. // prodStock.setMzcl(100);
  133. // prodStock.setGzcl(200);
  134. // prodStock.setBrzcl(452);
  135. // prodStock.setHbzcl(100);
  136. // prodStock.setRszcl(30);
  137. // prodStock.setBrmzcl(20);
  138. // prodStock.setKhzcl(212);
  139. // prodStock.setSpzcl(1020);
  140. // prodStock.setCreatTime(new Date());
  141. // prodStock.setFarmId(24);
  142. // prodStockService.save(prodStock);
  143. // System.out.println("东阳");
  144. // }
  145. // }
  146. // if ("浦江".equals(stock.get(0))){
  147. // if (ObjectUtil.isNotEmpty(prodStock)){
  148. // prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
  149. // prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
  150. // prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
  151. // prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
  152. // prodStock.setCreatTime(new Date());
  153. // prodStock.setFarmId(23);
  154. // prodStockService.updateById(prodStock);
  155. // }else {
  156. // prodStock = new ProdStock();
  157. // prodStock.setZzcl(Integer.parseInt(stock.get(11).toString()));
  158. // prodStock.setByzcl(Integer.parseInt(stock.get(13).toString()));
  159. // prodStock.setYfzcl(Integer.parseInt(stock.get(14).toString()));
  160. // prodStock.setZcl(Integer.parseInt(stock.get(15).toString()));
  161. // prodStock.setMzcl(100);
  162. // prodStock.setGzcl(200);
  163. // prodStock.setBrzcl(452);
  164. // prodStock.setHbzcl(100);
  165. // prodStock.setRszcl(30);
  166. // prodStock.setBrmzcl(20);
  167. // prodStock.setKhzcl(212);
  168. // prodStock.setSpzcl(1020);
  169. // prodStock.setCreatTime(new Date());
  170. // prodStock.setFarmId(23);
  171. // prodStockService.save(prodStock);
  172. // }
  173. //
  174. // }
  175. // }
  176. // }
  177. // }
  178. //
  179. //
  180. // private String login() throws Exception {
  181. // StockLoginDto stockLoginDto = restTemplate.getForObject("http://test.htpig.cn/rest/user/login?user_name=test&password=e10adc3949ba59abbe56e057f20f883e&db_name=MSSQL", StockLoginDto.class);
  182. // if (stockLoginDto.getStatus() != 0){
  183. // return null;
  184. // }
  185. // return stockLoginDto.getToken();
  186. // }
  187. //
  188. //}