DayGetController.java 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
  1. package io.renren.modules.common;
  2. import com.opencsv.CSVReader;
  3. import io.renren.modules.aspen.entity.TDashboarddayelecEntity;
  4. import io.renren.modules.aspen.service.TDashboarddayelecService;
  5. import io.renren.modules.sys.controller.AbstractController;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.context.annotation.Configuration;
  8. import org.springframework.scheduling.annotation.EnableScheduling;
  9. import org.springframework.scheduling.annotation.Scheduled;
  10. import org.springframework.stereotype.Component;
  11. import java.io.FileReader;
  12. import java.io.IOException;
  13. import java.math.BigDecimal;
  14. import java.util.Calendar;
  15. import java.util.Date;
  16. @Component
  17. @Configuration //1.主要用于标记配置类,兼备Component的效果。
  18. @EnableScheduling // 2.开启定时任务
  19. public class DayGetController extends AbstractController {
  20. @Autowired
  21. private TDashboarddayelecService tDashboarddayelecService;
  22. // @Scheduled(cron = "0/30 * * * * ?")
  23. // @Scheduled(cron = "0 */15 * * * ?")
  24. //每日0:00触发
  25. @Scheduled(cron = "0 0 0 * * ?" )
  26. public void getExcelData(){
  27. logger.info("实时获取数据");
  28. // String csvFile = "D://ssyFile/物料.csv";
  29. String csvFile = "D://elecdashboardaspen/elecDashboardData1.csv";
  30. TDashboarddayelecEntity tDashboarddayelecEntity = new TDashboarddayelecEntity();
  31. CSVReader reader = null;
  32. try {
  33. reader = new CSVReader(new FileReader(csvFile));
  34. String[] line;
  35. //定义行数
  36. int i = 0;
  37. while ((line = reader.readNext()) != null) {
  38. i++;
  39. if (i == 2) {
  40. logger.info("第" + i + "行");
  41. for (int j = 2; j < 7; j++) {
  42. logger.info("读数:" + line[j]);
  43. if (line[j].equals("")) {
  44. line[j] = "0.0";
  45. }else {
  46. if (!Character.isDigit(line[j].charAt(0))) {
  47. line[j] = "0.0";
  48. }else {
  49. BigDecimal b = new BigDecimal(Double.parseDouble(line[j]));
  50. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  51. line[j] = String.valueOf(f);
  52. }
  53. }
  54. logger.info(line[j]);
  55. }
  56. tDashboarddayelecEntity.setGtg1Lv(line[2]);
  57. tDashboarddayelecEntity.setGtg2Lv(line[3]);
  58. tDashboarddayelecEntity.setGtg3Lv(line[4]);
  59. tDashboarddayelecEntity.setStg1Lv(line[5]);
  60. tDashboarddayelecEntity.setMwhLv(line[6]);
  61. }
  62. if (i == 3) {
  63. logger.info("第" + i + "行");
  64. for (int j = 0; j < 6; j++) {
  65. logger.info("读数:" + line[j]);
  66. if (line[j].equals("")) {
  67. line[j] = "0.0";
  68. }else {
  69. if (!Character.isDigit(line[j].charAt(0))) {
  70. line[j] = "0.0";
  71. }else {
  72. BigDecimal b = new BigDecimal(Double.parseDouble(line[j]));
  73. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  74. line[j] = String.valueOf(f);
  75. }
  76. }
  77. logger.info(line[j]);
  78. }
  79. tDashboarddayelecEntity.setGtg1Wr(line[2]);
  80. tDashboarddayelecEntity.setGtg2Wr(line[3]);
  81. tDashboarddayelecEntity.setGtg3Wr(line[4]);
  82. tDashboarddayelecEntity.setStg1Wr(line[5]);
  83. }
  84. if (i == 4) {
  85. logger.info("第" + i + "行");
  86. for (int j = 0; j < 6; j++) {
  87. logger.info("读数:" + line[j]);
  88. if (line[j].equals("")) {
  89. line[j] = "0.0";
  90. }else {
  91. if (!Character.isDigit(line[j].charAt(0))) {
  92. line[j] = "0.0";
  93. }else {
  94. BigDecimal b = new BigDecimal(Double.parseDouble(line[j]));
  95. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  96. line[j] = String.valueOf(f);
  97. }
  98. }
  99. logger.info(line[j]);
  100. }
  101. tDashboarddayelecEntity.setMwhWr(line[6]);
  102. }
  103. if (i == 6) {
  104. logger.info("第" + i + "行");
  105. for (int j = 2; j < 7; j++) {
  106. logger.info("读数:" + line[j]);
  107. if (line[j].equals("")) {
  108. line[j] = "0";
  109. }else {
  110. if (!Character.isDigit(line[j].charAt(0))) {
  111. line[j] = "0";
  112. }else {
  113. BigDecimal b = new BigDecimal(Double.parseDouble(line[j]));
  114. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  115. line[j] = String.valueOf(f);
  116. }
  117. }
  118. logger.info(line[j]);
  119. }
  120. tDashboarddayelecEntity.setHhp(line[2]);
  121. tDashboarddayelecEntity.setHp(line[3]);
  122. tDashboarddayelecEntity.setLp(line[4]);
  123. tDashboarddayelecEntity.setMp(line[5]);
  124. tDashboarddayelecEntity.setTotalConsumption(line[6]);
  125. }
  126. if (i == 9) {
  127. logger.info("第" + i + "行");
  128. for (int j = 2; j < 6; j++) {
  129. logger.info("读数:" + line[j]);
  130. if (line[j].equals("")) {
  131. line[j] = "0.0";
  132. }else {
  133. if (!Character.isDigit(line[j].charAt(0))) {
  134. line[j] = "0.0";
  135. }else {
  136. BigDecimal b = new BigDecimal(Double.parseDouble(line[j]));
  137. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  138. line[j] = String.valueOf(f);
  139. }
  140. }
  141. logger.info(line[j]);
  142. }
  143. // Integer HhpNum=new Integer(line[2]).intValue();
  144. // Integer HpNum=new Integer(line[3]).intValue();
  145. // Integer LpNum=new Integer(line[4]).intValue();
  146. // Integer MpNum=new Integer(line[5]).intValue();
  147. tDashboarddayelecEntity.setHhpNum(line[2]);
  148. tDashboarddayelecEntity.setHpNum(line[3]);
  149. tDashboarddayelecEntity.setLpNum(line[4]);
  150. tDashboarddayelecEntity.setMpNum(line[5]);
  151. }
  152. if (i == 10) {
  153. logger.info("第" + i + "行");
  154. for (int j = 2; j < 6; j++) {
  155. logger.info("读数:" + line[j]);
  156. if (line[j].equals("")) {
  157. line[j] = "0";
  158. }else {
  159. if (!Character.isDigit(line[j].charAt(0))) {
  160. line[j] = "0";
  161. }else {
  162. BigDecimal b = new BigDecimal(Double.parseDouble(line[j]));
  163. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  164. line[j] = String.valueOf(f);
  165. }
  166. }
  167. logger.info(line[j]);
  168. }
  169. tDashboarddayelecEntity.setHhpTemp(line[2]);
  170. tDashboarddayelecEntity.setHpTemp(line[3]);
  171. tDashboarddayelecEntity.setLpTemp(line[4]);
  172. tDashboarddayelecEntity.setMpTemp(line[5]);
  173. }
  174. /* SS */
  175. if (i == 13) {
  176. logger.info("第" + i + "行");
  177. for(int j=2;j<5;j++){
  178. if (line[j].equals("")) {
  179. line[j] = "0.0";
  180. }else {
  181. if (!Character.isDigit(line[j].charAt(0))) {
  182. line[j] = "0.0";
  183. }else {
  184. BigDecimal b = new BigDecimal(Double.parseDouble(line[j]));
  185. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  186. line[j] = String.valueOf(f);
  187. }
  188. }
  189. logger.info(line[j]);
  190. }
  191. tDashboarddayelecEntity.setShihua(line[2]);
  192. tDashboarddayelecEntity.setShiyou(line[3]);
  193. tDashboarddayelecEntity.setShunshiliang(line[4]);
  194. }
  195. if (i == 18) {
  196. logger.info("第" + i + "行");
  197. for(int j=2;j<6;j++){
  198. if (line[j].equals("")) {
  199. line[j] = "0.0";
  200. }else {
  201. if (!Character.isDigit(line[j].charAt(0))) {
  202. line[j] = "0.0";
  203. }else {
  204. BigDecimal b = new BigDecimal(Double.parseDouble(line[j]));
  205. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  206. line[j] = String.valueOf(f);
  207. }
  208. }
  209. logger.info(line[j]);
  210. }
  211. tDashboarddayelecEntity.setYpg(line[2]);
  212. tDashboarddayelecEntity.setDaodianliang(line[3]);
  213. tDashboarddayelecEntity.setEveLec(line[4]);
  214. tDashboarddayelecEntity.setFenggucha(rounding(line[5]));
  215. }
  216. if (i == 20) {
  217. logger.info("第" + i + "行");
  218. for(int j=2;j<4;j++){
  219. if (line[j].equals("")) {
  220. line[j] = "0.0";
  221. }else {
  222. if (!Character.isDigit(line[j].charAt(0))) {
  223. line[j] = "0.0";
  224. }else {
  225. BigDecimal b = new BigDecimal(Double.parseDouble(line[j]));
  226. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  227. line[j] = String.valueOf(f);
  228. }
  229. }
  230. logger.info(line[j]);
  231. }
  232. tDashboarddayelecEntity.setBycElec(line[2]);
  233. tDashboarddayelecEntity.setBocElec(line[3]);
  234. }
  235. }
  236. tDashboarddayelecEntity.setCreatedate(new Date());
  237. tDashboarddayelecEntity.setDataDate(new Date());
  238. Calendar now = Calendar.getInstance();
  239. tDashboarddayelecEntity.setDateDay(String.valueOf(now.get(Calendar.DAY_OF_MONTH)));
  240. logger.info("dashboardData:" + tDashboarddayelecEntity);
  241. tDashboarddayelecService.save(tDashboarddayelecEntity);
  242. } catch (IOException e) {
  243. e.printStackTrace();
  244. }
  245. }
  246. public String rounding(String lineNum) {
  247. try {
  248. logger.info("读数:" + lineNum);
  249. if (lineNum.equals("")) {
  250. lineNum = "0.0";
  251. }else {
  252. if (!Character.isDigit(lineNum.charAt(0))) {
  253. if ("-".equals(lineNum.substring(0,1))){
  254. BigDecimal b = new BigDecimal(Double.parseDouble(lineNum));
  255. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  256. lineNum = String.valueOf(f);
  257. }else {
  258. lineNum = "0.0";
  259. }
  260. }else {
  261. BigDecimal b = new BigDecimal(Double.parseDouble(lineNum));
  262. double f = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
  263. lineNum = String.valueOf(f);
  264. }
  265. }
  266. logger.info(lineNum);
  267. return lineNum;
  268. }catch (Exception e) {
  269. logger.error(String.valueOf(e));
  270. return "0.0";
  271. }
  272. }
  273. }