From ba57740f33eacb8a1d514093633e8179e6100815 Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Fri, 24 May 2024 19:16:53 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 src/main/java/org/springblade/modules/disputeRecord/service/impl/DisputeRecordServiceImpl.java |   35 ++++++++++++++++++++++++++++++-----
 1 files changed, 30 insertions(+), 5 deletions(-)

diff --git a/src/main/java/org/springblade/modules/disputeRecord/service/impl/DisputeRecordServiceImpl.java b/src/main/java/org/springblade/modules/disputeRecord/service/impl/DisputeRecordServiceImpl.java
index 9001447..47c54d5 100644
--- a/src/main/java/org/springblade/modules/disputeRecord/service/impl/DisputeRecordServiceImpl.java
+++ b/src/main/java/org/springblade/modules/disputeRecord/service/impl/DisputeRecordServiceImpl.java
@@ -85,8 +85,18 @@
 	 */
 	@Override
 	@Transactional(rollbackFor = Exception.class)
-	public void importDisputeRecord(List<DisputeRecordExcel> data, Boolean isCovered) {
+	public String importDisputeRecord(List<DisputeRecordExcel> data, Boolean isCovered) {
+		int totalNum = data.size();
+		int importNum = 0;
+		int updateNum = 0;
+		int errorNum = 0;
 		for (DisputeRecordExcel disputeRecordExcel : data) {
+			// 判断地址,时间
+			if (Strings.isBlank(disputeRecordExcel.getAddress())
+			) {
+				errorNum++;
+				continue;
+			}
 			// 获取转换数据对象
 			DisputeRecordEntity disputeRecordEntity
 				= Objects.requireNonNull(BeanUtil.copy(disputeRecordExcel, DisputeRecordEntity.class));
@@ -158,15 +168,30 @@
 			// 查询
 			List<DisputeRecordEntity> list = list(queryWrapper);
 			if (list.size()>0){
-				// 更新
-				disputeRecordEntity.setId(list.get(0).getId());
-				// 更新
-				updateById(disputeRecordEntity);
+				updateNum++;
+				if (isCovered) {
+					// 更新
+					disputeRecordEntity.setId(list.get(0).getId());
+					// 更新
+					updateById(disputeRecordEntity);
+					importNum++;
+				}
 			}else {
 				// 插入
 				save(disputeRecordEntity);
+				importNum ++;
 			}
 		}
+		StringBuilder builder = new StringBuilder("导入完成!");
+		builder.append("其中本次表格共有 ").append(totalNum).append(" 条数据,")
+			.append("成功导入 ").append(importNum).append(" 条数据。");
+		if (updateNum>0) {
+			builder.append("其中有 ").append(updateNum).append(" 条数据已存在。");
+		}
+		if (errorNum>0){
+			builder.append("共有 ").append(errorNum).append(" 条数据由于无地址信息未导入!");
+		}
+		return builder.toString();
 	}
 
 	/**

--
Gitblit v1.9.3