From 5b17ccbbe08971f861ff097c62241d2b79e4b5f6 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期五, 16 六月 2023 15:34:41 +0800
Subject: [PATCH] 1

---
 src/main/java/com/yssh/scheduled/ReadCsvTask.java |   25 +++++++++++++++----------
 1 files changed, 15 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/yssh/scheduled/ReadCsvTask.java b/src/main/java/com/yssh/scheduled/ReadCsvTask.java
index cd76a01..4c984bb 100644
--- a/src/main/java/com/yssh/scheduled/ReadCsvTask.java
+++ b/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());
 		}
 	}

--
Gitblit v1.9.3