From dde162ffb34f2cc0ece4ca9cfcd09e2cb42ace6d Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Fri, 17 May 2024 18:13:11 +0800
Subject: [PATCH] 租户导入导出

---
 src/main/java/org/springblade/modules/disputeRecord/service/impl/DisputeRecordServiceImpl.java |   68 ++++++++++++++++++++++++++++++++++
 1 files changed, 68 insertions(+), 0 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 c33ccca..9001447 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
@@ -5,14 +5,20 @@
 import org.apache.logging.log4j.util.Strings;
 import org.springblade.common.param.CommonParamSet;
 import org.springblade.common.param.GridSet;
+import org.springblade.common.utils.SpringUtils;
 import org.springblade.core.tool.utils.BeanUtil;
 import org.springblade.modules.backblast.entity.BackblastWarnHanRecEntity;
+import org.springblade.modules.community.dto.CommunityDTO;
 import org.springblade.modules.disputeRecord.entity.DisputeRecordEntity;
 import org.springblade.modules.disputeRecord.excel.DisputeRecordExcel;
 import org.springblade.modules.disputeRecord.excel.ExportDisputeRecordExcel;
 import org.springblade.modules.disputeRecord.vo.DisputeRecordVO;
 import org.springblade.modules.disputeRecord.mapper.DisputeRecordMapper;
 import org.springblade.modules.disputeRecord.service.IDisputeRecordService;
+import org.springblade.modules.system.entity.DictBiz;
+import org.springblade.modules.system.service.IDictBizService;
+import org.springblade.modules.task.entity.ECallEventEntity;
+import org.springblade.modules.task.service.IECallEventService;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import org.springframework.transaction.annotation.Transactional;
@@ -105,6 +111,24 @@
 					disputeRecordEntity.setInjuryFlag(0);
 				}
 			}
+			// 当事人1性别 1:男 2:女
+			if (!Strings.isBlank(disputeRecordExcel.getGenderOne())) {
+				if (disputeRecordExcel.getGenderOne().contains("男")){
+					disputeRecordEntity.setGenderOne(1);
+				}
+				if (disputeRecordExcel.getGenderOne().contains("女")){
+					disputeRecordEntity.setGenderOne(2);
+				}
+			}
+			// 当事人2性别 1:男 2:女
+			if (!Strings.isBlank(disputeRecordExcel.getGenderTwo())) {
+				if (disputeRecordExcel.getGenderTwo().contains("男")){
+					disputeRecordEntity.setGenderTwo(1);
+				}
+				if (disputeRecordExcel.getGenderTwo().contains("女")){
+					disputeRecordEntity.setGenderTwo(2);
+				}
+			}
 			// 处理结果 1:已化解 2:未化解 3:移送e呼即办
 			if (!Strings.isBlank(disputeRecordExcel.getHandleResult())) {
 				if (disputeRecordExcel.getHandleResult().equals("已化解")) {
@@ -159,4 +183,48 @@
 				commonParamSet.getRegionChildCodesList(),
 				commonParamSet.getGridCodeList());
 	}
+
+	/**
+	 * e呼即办数据临时转换到矛盾纠纷
+	 */
+	@Override
+	@Transactional(rollbackFor = Exception.class)
+	public void eCallToDis() {
+		// 查询所有的e 呼即办数据
+		IECallEventService callEventService = SpringUtils.getBean(IECallEventService.class);
+		IDictBizService dictBizService = SpringUtils.getBean(IDictBizService.class);
+		// 查询所有
+		QueryWrapper<ECallEventEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("is_deleted",0);
+		List<ECallEventEntity> eCallEventEntityList = callEventService.list(queryWrapper);
+		// 遍历处理
+		for (ECallEventEntity eCallEventEntity : eCallEventEntityList) {
+			if (eCallEventEntity.getName().contains("纠纷")) {
+				DisputeRecordEntity disputeRecordEntity = new DisputeRecordEntity();
+				disputeRecordEntity.setAddress(eCallEventEntity.getAddress());
+				disputeRecordEntity.setLng(eCallEventEntity.getLng());
+				disputeRecordEntity.setLat(eCallEventEntity.getLat());
+				disputeRecordEntity.setEventTime(eCallEventEntity.getOccurrenceTime());
+				disputeRecordEntity.setDisputeContent(eCallEventEntity.getRemark());
+				disputeRecordEntity.setAddress(eCallEventEntity.getAddress());
+				// 设置处置结果,暂时放在受伤结果里面
+				disputeRecordEntity.setInjuryDesc(eCallEventEntity.getDisRes());
+				// 设置网格,警格编号
+				GridSet gridSet
+					= new GridSet().invoke(DisputeRecordEntity.class, disputeRecordEntity, "lng", "lat", "gridCode", "jwGridCode");
+				// 纠纷类型转换
+				QueryWrapper<DictBiz> wrapper = new QueryWrapper<>();
+				wrapper.eq("code", "disputeType").eq("is_deleted", 0).eq("dict_value", eCallEventEntity.getName());
+				DictBiz one = dictBizService.getOne(wrapper);
+				if (null!=one){
+					disputeRecordEntity.setDisputeType(Integer.parseInt(one.getDictKey()));
+				}else {
+					// 设置为其他纠纷
+					disputeRecordEntity.setDisputeType(8);
+				}
+				// 保存
+				save(disputeRecordEntity);
+			}
+		}
+	}
 }

--
Gitblit v1.9.3