/*
|
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
|
*
|
* Redistribution and use in source and binary forms, with or without
|
* modification, are permitted provided that the following conditions are met:
|
*
|
* Redistributions of source code must retain the above copyright notice,
|
* this list of conditions and the following disclaimer.
|
* Redistributions in binary form must reproduce the above copyright
|
* notice, this list of conditions and the following disclaimer in the
|
* documentation and/or other materials provided with the distribution.
|
* Neither the name of the dreamlu.net developer nor the names of its
|
* contributors may be used to endorse or promote products derived from
|
* this software without specific prior written permission.
|
* Author: Chill 庄骞 (smallchill@163.com)
|
*/
|
package org.springblade.modules.house.service.impl;
|
|
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;
|
import org.springblade.modules.house.mapper.HouseMapper;
|
import org.springblade.modules.house.service.IHouseService;
|
import org.springblade.modules.house.excel.HouseExcel;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* 房屋 服务实现类
|
*
|
* @author BladeX
|
* @since 2023-10-28
|
*/
|
@Service
|
public class HouseServiceImpl extends ServiceImpl<HouseMapper, HouseEntity> implements IHouseService {
|
|
|
@Autowired
|
private IGridService gridService;
|
|
@Autowired
|
private IHouseholdService householdService;
|
|
@Override
|
public IPage<HouseVO> selectHousePage(IPage<HouseVO> page, HouseVO house) {
|
return page.setRecords(baseMapper.selectHousePage(page, house));
|
}
|
|
/**
|
* 房屋自定义详情查询
|
* @param house
|
* @return
|
*/
|
@Override
|
public HouseVO getHouseDetail(HouseVO house) {
|
return baseMapper.getHouseDetail(house);
|
}
|
|
/**
|
* 房屋自定义新增或修改
|
* @param house
|
* @return
|
*/
|
@Override
|
public boolean saveOrUpdateHouse(HouseEntity house) {
|
// 查询是否已存在房屋数据
|
QueryWrapper<HouseEntity> wrapper = new QueryWrapper<>();
|
wrapper.eq("house_code",house.getHouseCode());
|
HouseEntity one = getOne(wrapper);
|
if (null != one){
|
house.setId(one.getId());
|
// 更新数据
|
return updateById(house);
|
}
|
//插入数据
|
return save(house);
|
}
|
|
|
/**
|
* 导入房屋数据
|
* @param data
|
* @param isCovered
|
*/
|
@Override
|
public void importUserHouse(List<HouseExcel> data, Boolean isCovered) {
|
data.forEach(houseExcel -> {
|
HouseEntity HouseEntity = Objects.requireNonNull(BeanUtil.copy(houseExcel, HouseEntity.class));
|
this.save(HouseEntity);
|
});
|
}
|
|
@Override
|
public List<HouseExcel> export(HouseVO household) {
|
List<HouseExcel> houseExcels = baseMapper.export(household);
|
return houseExcels;
|
}
|
|
/**
|
* 查询房屋树
|
* @param houseParam
|
* @return
|
*/
|
@Override
|
public List<HouseTree> getHouseTree(HouseParam houseParam) {
|
List<String> houseCodeList = getHouseCodeList(houseParam);
|
return NodeTreeUtil.getHouseTree(baseMapper.getHouseTree(houseParam,houseCodeList));
|
}
|
|
|
/**
|
* 根据角色获取地址编号集合
|
* @param houseParam
|
* @return
|
*/
|
private List<String> getHouseCodeList(HouseParam houseParam) {
|
List<String> stringList = new ArrayList<>();
|
if (null != houseParam.getRoleName() && !houseParam.getRoleName().equals("")) {
|
if (houseParam.getRoleName().equals("网格员")) {
|
// 查询对应的房屋地址code
|
stringList = gridService.getAddressCodeListByUserId(AuthUtil.getUserId());
|
}
|
}
|
return stringList;
|
}
|
|
/**
|
* 人房数据导入
|
* @param data
|
* @param isCovered
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void importHouseAndHold(List<HouseAndHoldExcel> data, Boolean isCovered) {
|
for (HouseAndHoldExcel houseAndHoldExcel : data) {
|
// System.out.println("houseAndHoldExcel = " + houseAndHoldExcel);
|
// 保存房屋数据--一个一个插入，防止一个表格中存在多个地址编号相同的数据
|
saveHouseData(houseAndHoldExcel);
|
// 保存住户数据（包含标签）--一个一个插入，防止一个表格中存在多个地址编号相同的数据
|
saveHouseholdData(houseAndHoldExcel);
|
// 保存租户数据
|
}
|
}
|
|
/**
|
* 保存房屋数据
|
* @param houseAndHoldExcel
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public 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());
|
if (!Strings.isBlank(houseAndHoldExcel.getFloor())){
|
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
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public 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()));
|
}
|
// 性别
|
if (!Strings.isBlank(houseAndHoldExcel.getGender())){
|
householdEntity.setGender(Short.parseShort(houseAndHoldExcel.getGender()));
|
}
|
householdEntity.setIdCard(houseAndHoldExcel.getIdCard());
|
// 党员
|
if (!Strings.isBlank(houseAndHoldExcel.getPartyEmber())){
|
householdEntity.setPartyEmber(Integer.parseInt(houseAndHoldExcel.getPartyEmber()));
|
}
|
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.setOtherContact(houseAndHoldExcel.getOtherContact());
|
householdEntity.setDisabilityCert(houseAndHoldExcel.getDisabilityCert());
|
householdEntity.setRemark(houseAndHoldExcel.getRemarks());
|
householdEntity.setCreateTime(new Date());
|
householdEntity.setCreateUser(AuthUtil.getUserId());
|
householdEntity.setUpdateTime(new Date());
|
householdEntity.setUpdateUser(AuthUtil.getUserId());
|
// 新增
|
householdService.save(householdEntity);
|
}
|
}
|
}
|
