From 83dfb5640c1e11634dd6c4fae0d078494f0c0190 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期一, 05 六月 2023 17:08:48 +0800
Subject: [PATCH] 开发Voc文件异步入库定时程序
---
src/main/java/com/yssh/scheduled/ReadCsvTask.java | 13 ++++++++++++-
1 files changed, 12 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/yssh/scheduled/ReadCsvTask.java b/src/main/java/com/yssh/scheduled/ReadCsvTask.java
index 89732a4..36df3aa 100644
--- a/src/main/java/com/yssh/scheduled/ReadCsvTask.java
+++ b/src/main/java/com/yssh/scheduled/ReadCsvTask.java
@@ -1,11 +1,13 @@
package com.yssh.scheduled;
-
import java.io.File;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
+import com.yssh.entity.VocVals;
+import com.yssh.service.VocValsService;
+import com.yssh.utils.VocParser;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -23,6 +25,7 @@
import com.yssh.utils.DateUtils;
import com.yssh.utils.TableStrategy;
+import javax.annotation.Resource;
@Component
public class ReadCsvTask {
@@ -34,6 +37,9 @@
@Autowired
private SuYuanServiceImpl suYuanService;
+
+ @Resource
+ private VocValsService vocValsService;
@Autowired
private IDictRecordService dictRecordService;
@@ -62,7 +68,12 @@
continue;
}
+ int count = vocValsService.countByTime(time);
+ if (count > 0) {
+ continue;
+ }
+ EasyCsv.read(filePath, VocVals.class, new VocParser(vocValsService, calendar.getTime())).doRead();
}
}
--
Gitblit v1.9.3