1

13693261870

2024-11-01 2b75d84cabc3416d903f425239c713b65a98503f

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

@@ -58,23 +58,34 @@
   @Value("${email.enable}")
   private Boolean enableEmail;

   private static boolean flag = false;

   private static final Object OBJ = new Object();

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

   private final static SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHH");

   public void corpReserveDataSync() {
      loadVocSync();
      //loadVocSync();
      loadCsvSync();
   }

   @Scheduled(cron = "${csv.cron}")
   private void loadCsvSync() {
      synchronized (OBJ) {
         if (flag) return;
         flag = true;
      }

      logger.info("***************** 开始执行CSV入库 *****************" + "\n");
      Calendar calendar = getCalendar(1);
      calendar.add(Calendar.HOUR, -cronMax);
      for (int i = 0; i < cronMax; i++) {
         try {
            calendar.add(Calendar.HOUR, -1);
            calendar.add(Calendar.HOUR, 1);
            String time = format.format(calendar.getTime());
            System.out.println(time);
            String filePath = csvFilePathConfig.getFilePath() + File.separator + time + ".csv";

            File file = new File(filePath);
@@ -102,6 +113,7 @@
         }
      }
      logger.info("***************** CSV入库执行完成 *****************" + "\n");
      flag = false;
   }

   public Calendar getCalendar(int start) {