1

13693261870

2023-06-16 5b17ccbbe08971f861ff097c62241d2b79e4b5f6

 src/main/java/com/yssh/scheduled/ReadCsvTask.java

@@ -49,7 +49,7 @@
   private int cronMax = 48;

   @Value("${csv.voc_max}")
   private int vocMax = 192;
   private int vocMax = 120;

   private final static List<String> md5List = new ArrayList<>();

@@ -88,7 +88,7 @@

         try {
            logger.info("loadVocSync: " + filePath);
            Date date = (Date)calendar.getTime().clone();
            Date date = (Date) calendar.getTime().clone();
            EasyCsv.read(filePath, VocVals.class, new VocParser(vocValsService, date)).doRead();

            // Thread.sleep(3 * 1000);
@@ -127,18 +127,23 @@
         }

         suYuanService.createNewTable(newTableName);
         dictRecordService.insertDictRecord(new DictRecord(1L, newTableName, Long.parseLong(time), ""));

         Long createTime = Long.parseLong(time);
         DictRecord dr = dictRecordService.selectByCreateTime(createTime);
         if (null == dr) {
            dictRecordService.insertDictRecord(new DictRecord(1L, newTableName, Long.parseLong(time), ""));
         }

         logger.info("loadCsvSync: " + filePath);
         EasyCsv.read(filePath, SuYuan.class, new CsvParser(suYuanService, time)).doRead();

         try {
            // 计算预警/报警,并且进行入库操作
            Thread.sleep(2 * 60 * 1000);
         } catch (InterruptedException e) {
            logger.error("睡眠一分钟后执行预警/报警计算,并且进行入库操作出现异常，异常原因是：", e);
            e.printStackTrace();
         }
//         try {
//            // 计算预警/报警,并且进行入库操作
//            Thread.sleep(2 * 60 * 1000);
//         } catch (InterruptedException e) {
//            logger.error("睡眠一分钟后执行预警/报警计算,并且进行入库操作出现异常，异常原因是：", e);
//            e.printStackTrace();
//         }
         warningAnalyseService.warningOperationStorage(calendar.getTime());
      }
   }