1

13693261870

2024-11-20 8185e5cdc2bbdf7fb4ca46a10864106893a01ed3

 src/main/java/com/yssh/config/ScheduleConfig.java

@@ -149,12 +149,12 @@

         //String md5 = FileUtils.getFileMd5(filePath);
         //if (null != md5 && md5List.contains(md5)) {
         //   continue; // csv已入库
         //   continue;
         //}

         int count = vocValsService.countByTime(time);
         if (count > 0) {
            //vocValsService.deleteByTime(time); // 删除已入库
            //vocValsService.deleteByTime(time);
            continue;
         }

@@ -178,7 +178,7 @@
   }

   private void loadCsv_old() {
      Date date = DateUtils.getNowDate();
      Date date = InitConfig.getDate();
      String time = DateUtils.parseDateToStr(DateUtils.YYYYMMDDHH, date);
      String filePath = csvFilePathConfig.getFilePath() + "\\\\" + time + ".csv";
      File file = new File(filePath);
@@ -186,12 +186,12 @@
         logger.info(file.getAbsolutePath() + " is not exist ！");
         return;
      }
      //创建表

      String newTableName = TableStrategy.getTableStrategy(time);
      suYuanService.createNewTable(newTableName);
      dictRecordService.insertDictRecord(new DictRecord(1L, newTableName, Long.parseLong(time), ""));
      EasyCsv.read(filePath, SuYuan.class, new CsvParser(suYuanService, time)).doRead();
      //计算预警/报警,并且进行入库操作

      try {
         Thread.sleep(60 * 1000);
      } catch (InterruptedException e) {
@@ -201,9 +201,6 @@
      warningAnalyseService.warningOperationStorage(date);
   }

   /**
    * 创建日报：每日0时1分
    */
   @Scheduled(cron = "0 1 0 * * ?")
   public void createDayReport() {
      Calendar calendar = getCalendar(1);
@@ -218,9 +215,6 @@
      }
   }

   /**
    * 创建周报：每周一0时5分
    */
   @Scheduled(cron = "0 5 0 ? * MON")
   public void createWeekReport() {
      Calendar calendar = getCalendar(7 * 24);
@@ -235,9 +229,6 @@
      }
   }

   /**
    * 创建月报：每月1日0时9分
    */
   @Scheduled(cron = "0 9 0 1 * ?")
   public void createMonthReport() {
      Calendar calendar = Calendar.getInstance();
@@ -254,7 +245,7 @@
      }
   }

   @Scheduled(cron = "${email.times}")
   //@Scheduled(cron = "${email.times}")
   public void autoCalcData() {
      if (enableEmail) {
         //System.out.println("${email.times}");