From b3cc369a3c0e4b8e92ce7607629aaa3c40e19fb6 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期四, 30 七月 2020 15:31:23 +0800
Subject: [PATCH] #当前本版十分完美、冻结
---
src/main/java/com/zy/common/utils/excel/matcode/MatCodeExcelListener.java | 51 +++++++++++++++++++++++++++++++++++++++------------
1 files changed, 39 insertions(+), 12 deletions(-)
diff --git a/src/main/java/com/zy/common/utils/excel/matcode/MatCodeExcelListener.java b/src/main/java/com/zy/common/utils/excel/matcode/MatCodeExcelListener.java
index e648b9d..b8636f2 100644
--- a/src/main/java/com/zy/common/utils/excel/matcode/MatCodeExcelListener.java
+++ b/src/main/java/com/zy/common/utils/excel/matcode/MatCodeExcelListener.java
@@ -2,13 +2,16 @@
import com.alibaba.excel.context.AnalysisContext;
import com.alibaba.excel.event.AnalysisEventListener;
-import com.alibaba.fastjson.JSON;
import com.core.common.SpringUtils;
+import com.core.exception.CoolException;
+import com.zy.asrs.entity.MatCode;
import com.zy.asrs.service.MatCodeService;
+import com.zy.asrs.utils.VersionUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.ArrayList;
+import java.util.Date;
import java.util.List;
import java.util.Map;
@@ -19,19 +22,28 @@
private static final Logger LOGGER = LoggerFactory.getLogger(MatCodeExcelListener.class);
+ private int total = 0;
+ private Long userId;
+
+ public MatCodeExcelListener() {
+ }
+
+ public MatCodeExcelListener(Long userId) {
+ this.userId = userId;
+ }
+
/**
* 姣忛殧5鏉″瓨鍌ㄦ暟鎹簱锛屽疄闄呬娇鐢ㄤ腑鍙互3000鏉★紝鐒跺悗娓呯悊list 锛屾柟渚垮唴瀛樺洖鏀�
*/
- private static final int BATCH_COUNT = 5;
+ private static final int BATCH_COUNT = 50;
- private List<MatCodeExcel> list = new ArrayList<>();
+ private final List<MatCode> list = new ArrayList<>();
/**
* 杩欓噷浼氫竴琛岃鐨勮繑鍥炲ご
*/
@Override
public void invokeHeadMap(Map<Integer, String> headMap, AnalysisContext context) {
- LOGGER.info("瑙ｆ瀽鍒颁竴鏉″ご鏁版嵁:{}", JSON.toJSONString(headMap));
}
/**
@@ -39,14 +51,25 @@
*/
@Override
public void invoke(MatCodeExcel data, AnalysisContext ctx) {
- LOGGER.info("瑙ｆ瀽鍒颁竴鏉℃暟鎹�:{}", JSON.toJSONString(data));
- list.add(data);
- // 杈惧埌BATCH_COUNT浜嗭紝闇�瑕佸幓瀛樺偍涓�娆℃暟鎹簱锛岄槻姝㈡暟鎹嚑涓囨潯鏁版嵁鍦ㄥ唴瀛橈紝瀹规槗OOM
- if (list.size() >= BATCH_COUNT) {
- MatCodeService matCodeService = SpringUtils.getBean(MatCodeService.class);
- // 瀛樺偍瀹屾垚娓呯悊 list
- list.clear();
+ MatCodeService matCodeService = SpringUtils.getBean(MatCodeService.class);
+ if (matCodeService.selectById(data.getMatNo()) == null) {
+ MatCode matCode = new MatCode();
+ VersionUtils.setMatCode(matCode, data);
+ matCode.setModiTime(new Date());
+ matCode.setModiUser(this.userId);
+ matCode.setAppeTime(new Date());
+ matCode.setAppeUser(this.userId);
+ if (!matCodeService.insert(matCode)) {
+ throw new CoolException("瀵煎叆鏁版嵁寮傚父");
+ }
+ total ++;
}
+ // 杈惧埌BATCH_COUNT浜嗭紝闇�瑕佸幓瀛樺偍涓�娆℃暟鎹簱锛岄槻姝㈡暟鎹嚑涓囨潯鏁版嵁鍦ㄥ唴瀛橈紝瀹规槗OOM
+// if (list.size() >= BATCH_COUNT) {
+//
+// // 瀛樺偍瀹屾垚娓呯悊 list
+// list.clear();
+// }
}
/**
@@ -55,6 +78,10 @@
*/
@Override
public void doAfterAllAnalysed(AnalysisContext ctx) {
- LOGGER.info("鎵�鏈夋暟鎹В鏋愬畬鎴愶紒");
+ LOGGER.info("鏂板{}鏉＄墿鏂欎俊鎭紒", total);
+ }
+
+ public int getTotal() {
+ return total;
}
}
--
Gitblit v1.9.1