From 2661a8170daa9ecc447f8799a862b13ce57255b7 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Mon, 20 Nov 2023 14:01:52 +0800
Subject: [PATCH] 房屋人员导入调整

---
 src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java |  115 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 115 insertions(+), 0 deletions(-)

diff --git a/src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java b/src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java
index 35e5bd4..dc5174f 100644
--- a/src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java
+++ b/src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java
@@ -18,11 +18,15 @@
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.apache.logging.log4j.util.Strings;
 import org.springblade.common.utils.NodeTreeUtil;
 import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.utils.BeanUtil;
 import org.springblade.modules.grid.service.IGridService;
 import org.springblade.modules.house.entity.HouseEntity;
+import org.springblade.modules.house.entity.HouseholdEntity;
+import org.springblade.modules.house.excel.HouseAndHoldExcel;
+import org.springblade.modules.house.service.IHouseholdService;
 import org.springblade.modules.house.vo.HouseParam;
 import org.springblade.modules.house.vo.HouseTree;
 import org.springblade.modules.house.vo.HouseVO;
@@ -34,6 +38,7 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 import java.util.Objects;
 
@@ -49,6 +54,9 @@
 
 	@Autowired
 	private IGridService gridService;
+
+	@Autowired
+	private IHouseholdService householdService;
 
 	@Override
 	public IPage<HouseVO> selectHousePage(IPage<HouseVO> page, HouseVO house) {
@@ -132,4 +140,111 @@
 		}
 		return stringList;
 	}
+
+	/**
+	 * 人房数据导入
+	 * @param data
+	 * @param isCovered
+	 */
+	@Override
+	public void importHouseAndHold(List<HouseAndHoldExcel> data, Boolean isCovered) {
+		for (HouseAndHoldExcel houseAndHoldExcel : data) {
+			System.out.println("houseAndHoldExcel = " + houseAndHoldExcel);
+			// 保存房屋数据--一个一个插入,防止一个表格中存在多个地址编号相同的数据
+			saveHouseData(houseAndHoldExcel);
+			// 保存住户数据(包含标签)--一个一个插入,防止一个表格中存在多个地址编号相同的数据
+			saveHouseholdData(houseAndHoldExcel);
+			// 保存租户数据
+		}
+	}
+
+	/**
+	 * 保存房屋数据
+	 * @param houseAndHoldExcel
+	 */
+	private void saveHouseholdData(HouseAndHoldExcel houseAndHoldExcel) {
+		// 查询库中是否已存在
+		QueryWrapper<HouseEntity> wrapper = new QueryWrapper<>();
+		wrapper.eq("house_code",houseAndHoldExcel.getHouseCode())
+		.eq("is_deleted",0);
+		HouseEntity one = getOne(wrapper);
+		// 不存在则插入,存在则不操作
+		if (null == one){
+			HouseEntity houseEntity = new HouseEntity();
+			houseEntity.setHouseCode(houseAndHoldExcel.getHouseCode());
+			houseEntity.setHouseName(houseAndHoldExcel.getHouseName());
+			houseEntity.setDistrictName(houseAndHoldExcel.getDistrictName());
+			houseEntity.setUnit(houseAndHoldExcel.getUnit());
+			houseEntity.setFloor(houseAndHoldExcel.getFloor());
+			houseEntity.setRoom(houseAndHoldExcel.getRoom());
+			houseEntity.setBuilding(houseAndHoldExcel.getBuilding());
+			houseEntity.setArea(houseAndHoldExcel.getArea());
+			houseEntity.setPropertyPrice(houseAndHoldExcel.getPropertyPrice());
+			houseEntity.setServiceDue(houseAndHoldExcel.getServiceDue());
+			houseEntity.setRemark(houseAndHoldExcel.getRemark());
+			houseEntity.setCreateTime(new Date());
+			houseEntity.setCreateUser(AuthUtil.getUserId().toString());
+			houseEntity.setUpdateTime(new Date());
+			houseEntity.setUpdateUser(AuthUtil.getUserId().toString());
+			// 新增
+			save(houseEntity);
+		}
+	}
+
+	/**
+	 * 保存住户数据
+	 * @param houseAndHoldExcel
+	 */
+	private void saveHouseData(HouseAndHoldExcel houseAndHoldExcel) {
+		// 查询库中是否已存在
+		QueryWrapper<HouseholdEntity> wrapper = new QueryWrapper<>();
+		wrapper.eq("house_code",houseAndHoldExcel.getHouseCode())
+			.eq("is_deleted",0)
+			.eq("phone_number",houseAndHoldExcel.getPhoneNumber());
+		HouseholdEntity one = householdService.getOne(wrapper);
+		// 不存在则插入,存在则不操作
+		if (null == one){
+			HouseholdEntity householdEntity = new HouseholdEntity();
+			householdEntity.setHouseCode(houseAndHoldExcel.getHouseCode());
+			householdEntity.setName(houseAndHoldExcel.getName());
+			householdEntity.setPhoneNumber(houseAndHoldExcel.getPhoneNumber());
+			if (!Strings.isBlank(houseAndHoldExcel.getRoleType())){
+				householdEntity.setRoleType(Integer.parseInt(houseAndHoldExcel.getRoleType()));
+			}
+			if (!Strings.isBlank(houseAndHoldExcel.getRelationship())){
+				householdEntity.setRelationship(Integer.parseInt(houseAndHoldExcel.getRelationship()));
+			}
+			if (!Strings.isBlank(houseAndHoldExcel.getIsPrimaryContact())){
+				householdEntity.setIsPrimaryContact(Integer.parseInt(houseAndHoldExcel.getIsPrimaryContact()));
+			}
+			if (!Strings.isBlank(houseAndHoldExcel.getResidentialStatus())){
+				householdEntity.setResidentialStatus(Integer.parseInt(houseAndHoldExcel.getResidentialStatus()));
+			}
+			householdEntity.setIdCard(houseAndHoldExcel.getIdCard());
+			householdEntity.setHkmtPass(houseAndHoldExcel.getHkmtPass());
+			householdEntity.setPassport(houseAndHoldExcel.getPassport());
+			if (!Strings.isBlank(houseAndHoldExcel.getEthnicity())){
+				householdEntity.setEthnicity(Integer.parseInt(houseAndHoldExcel.getEthnicity()));
+			}
+			if (!Strings.isBlank(houseAndHoldExcel.getEducation())){
+				householdEntity.setEducation(Integer.parseInt(houseAndHoldExcel.getEducation()));
+			}
+			householdEntity.setHukouRegistration(houseAndHoldExcel.getHukouRegistration());
+			if (!Strings.isBlank(houseAndHoldExcel.getWorkStatus())){
+				householdEntity.setWorkStatus(Integer.parseInt(houseAndHoldExcel.getWorkStatus()));
+			}
+			householdEntity.setEmployer(houseAndHoldExcel.getEmployer());
+			if (!Strings.isBlank(houseAndHoldExcel.getMaritalStatus())){
+				householdEntity.setMaritalStatus(Integer.parseInt(houseAndHoldExcel.getMaritalStatus()));
+			}
+			householdEntity.setCardNumber(houseAndHoldExcel.getCardNumber());
+			householdEntity.setRemark(houseAndHoldExcel.getRemarks());
+			householdEntity.setCreateTime(new Date());
+			householdEntity.setCreateUser(AuthUtil.getUserId());
+			householdEntity.setUpdateTime(new Date());
+			householdEntity.setUpdateUser(AuthUtil.getUserId());
+			// 新增
+			householdService.save(householdEntity);
+		}
+	}
 }

--
Gitblit v1.9.3