package com.java110.community.smo.impl;
|
|
import com.java110.core.base.smo.BaseServiceSMO;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.dto.FloorDto;
|
import com.java110.dto.RoomDto;
|
import com.java110.dto.UnitDto;
|
import com.java110.dto.owner.OwnerDto;
|
import com.java110.dto.owner.OwnerRoomRelDto;
|
import com.java110.entity.assetImport.ImportOwnerRoomDto;
|
import com.java110.intf.community.*;
|
import com.java110.po.floor.FloorPo;
|
import com.java110.po.owner.OwnerPo;
|
import com.java110.po.owner.OwnerRoomRelPo;
|
import com.java110.po.room.RoomPo;
|
import com.java110.po.unit.UnitPo;
|
import com.java110.utils.util.DateUtil;
|
import com.java110.utils.util.StringUtil;
|
import org.slf4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* 小区服务内部类
|
*/
|
@RestController
|
public class ImportOwnerRoomInnerServiceSMOImpl extends BaseServiceSMO implements IImportOwnerRoomInnerServiceSMO {
|
private static Logger logger = LoggerFactory.getLogger(CommunityServiceSMOImpl.class);
|
|
|
@Autowired
|
private IFloorV1InnerServiceSMO floorV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IUnitV1InnerServiceSMO unitV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerRoomRelV1InnerServiceSMO ownerRoomRelV1InnerServiceSMOImpl;
|
|
@Override
|
public int saveOwnerRooms(@RequestBody List<ImportOwnerRoomDto> importOwnerRoomDtos) {
|
|
int successCount = 0;
|
if (importOwnerRoomDtos == null || importOwnerRoomDtos.size() < 1) {
|
return 0;
|
}
|
|
List<ImportOwnerRoomDto> importOwnerRoomDtosed = new ArrayList<>();
|
// 1.0 查看 楼栋是否存在
|
for (ImportOwnerRoomDto importOwnerRoomDto : importOwnerRoomDtos) {
|
successCount += doSaveOwnerRooms(importOwnerRoomDto, importOwnerRoomDtosed);
|
}
|
|
|
return successCount;
|
}
|
|
/**
|
* 导入数据
|
*
|
* @param importOwnerRoomDto
|
* @param importOwnerRoomDtosed
|
* @return
|
*/
|
private int doSaveOwnerRooms(ImportOwnerRoomDto importOwnerRoomDto, List<ImportOwnerRoomDto> importOwnerRoomDtosed) {
|
|
//1.0 保存楼栋信息
|
String floorId = doSaveFloor(importOwnerRoomDto);
|
|
|
//2.0 保存单元信息
|
String unitId = doSaveUnit(importOwnerRoomDto, floorId);
|
|
//3.0 保存 房屋
|
String roomId = doSaveRoom(importOwnerRoomDto, unitId);
|
|
//没有业主
|
if (StringUtil.isEmpty(importOwnerRoomDto.getOwnerName())) {
|
return 1;
|
}
|
|
//4.0 保存业主
|
if (OwnerDto.OWNER_TYPE_CD_OWNER.equals(importOwnerRoomDto.getOwnerTypeCd())) {
|
doSaveOwner(importOwnerRoomDto, roomId);
|
} else {
|
doSaveOwnerMember(importOwnerRoomDto, roomId);
|
}
|
|
return 1;
|
|
}
|
|
/**
|
* 保存业主成员
|
*
|
* @param importOwnerRoomDto
|
* @param roomId
|
*/
|
private void doSaveOwnerMember(ImportOwnerRoomDto importOwnerRoomDto, String roomId) {
|
|
// 查询房屋和业主是否有关系
|
OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
|
ownerRoomRelDto.setCommunityId(importOwnerRoomDto.getCommunityId());
|
ownerRoomRelDto.setRoomId(roomId);
|
List<OwnerRoomRelDto> roomRelDtos = ownerRoomRelV1InnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
|
if (roomRelDtos == null || roomRelDtos.size() < 1) {
|
throw new IllegalArgumentException(importOwnerRoomDto.getOwnerName() + "成员未找到对应业主信息");
|
}
|
|
OwnerDto ownerDto = new OwnerDto();
|
ownerDto.setCommunityId(importOwnerRoomDto.getCommunityId());
|
ownerDto.setName(importOwnerRoomDto.getOwnerName());
|
ownerDto.setLink(importOwnerRoomDto.getTel());
|
ownerDto.setOwnerId(roomRelDtos.get(0).getOwnerId());
|
ownerDto.setOwnerTypeCd(importOwnerRoomDto.getOwnerTypeCd());
|
List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
|
OwnerPo ownerPo = null;
|
|
int flag = 0;
|
if (ownerDtos == null || ownerDtos.size() < 1) {
|
ownerPo = new OwnerPo();
|
ownerPo.setState(OwnerDto.STATE_FINISH);
|
ownerPo.setOwnerFlag(OwnerDto.OWNER_FLAG_TRUE);
|
ownerPo.setbId("-1");
|
ownerPo.setOwnerTypeCd(importOwnerRoomDto.getOwnerTypeCd());
|
ownerPo.setCommunityId(importOwnerRoomDto.getCommunityId());
|
ownerPo.setOwnerId(roomRelDtos.get(0).getOwnerId());
|
ownerPo.setName(importOwnerRoomDto.getOwnerName());
|
ownerPo.setIdCard(importOwnerRoomDto.getIdCard());
|
ownerPo.setAge(importOwnerRoomDto.getAge());
|
ownerPo.setSex(importOwnerRoomDto.getSex());
|
ownerPo.setLink(importOwnerRoomDto.getTel());
|
ownerPo.setMemberId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId));
|
ownerPo.setRemark("房产导入");
|
ownerPo.setUserId("-1");
|
flag = ownerV1InnerServiceSMOImpl.saveOwner(ownerPo);
|
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入业主失败");
|
}
|
} else {
|
ownerPo = new OwnerPo();
|
ownerPo.setState(OwnerDto.STATE_FINISH);
|
ownerPo.setOwnerFlag(OwnerDto.OWNER_FLAG_TRUE);
|
ownerPo.setbId("-1");
|
ownerPo.setOwnerTypeCd(importOwnerRoomDto.getOwnerTypeCd());
|
ownerPo.setCommunityId(importOwnerRoomDto.getCommunityId());
|
ownerPo.setOwnerId(ownerDtos.get(0).getOwnerId());
|
ownerPo.setName(importOwnerRoomDto.getOwnerName());
|
ownerPo.setIdCard(importOwnerRoomDto.getIdCard());
|
ownerPo.setAge(importOwnerRoomDto.getAge());
|
ownerPo.setSex(importOwnerRoomDto.getSex());
|
ownerPo.setLink(importOwnerRoomDto.getTel());
|
ownerPo.setMemberId(ownerDtos.get(0).getMemberId());
|
ownerPo.setRemark("房产导入");
|
ownerPo.setUserId("-1");
|
flag = ownerV1InnerServiceSMOImpl.updateOwner(ownerPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入业主失败");
|
}
|
}
|
}
|
|
/**
|
* 保存业主
|
*
|
* @param importOwnerRoomDto
|
* @param roomId
|
*/
|
private void doSaveOwner(ImportOwnerRoomDto importOwnerRoomDto, String roomId) {
|
|
OwnerDto ownerDto = new OwnerDto();
|
ownerDto.setCommunityId(importOwnerRoomDto.getCommunityId());
|
ownerDto.setName(importOwnerRoomDto.getOwnerName());
|
ownerDto.setLink(importOwnerRoomDto.getTel());
|
ownerDto.setOwnerTypeCd(importOwnerRoomDto.getOwnerTypeCd());
|
List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
|
OwnerPo ownerPo = null;
|
String ownerId = "";
|
|
int flag = 0;
|
if (ownerDtos == null || ownerDtos.size() < 1) {
|
ownerPo = new OwnerPo();
|
ownerPo.setState(OwnerDto.STATE_FINISH);
|
ownerPo.setOwnerFlag(OwnerDto.OWNER_FLAG_TRUE);
|
ownerPo.setbId("-1");
|
ownerPo.setOwnerTypeCd(importOwnerRoomDto.getOwnerTypeCd());
|
ownerPo.setCommunityId(importOwnerRoomDto.getCommunityId());
|
ownerPo.setOwnerId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId));
|
ownerPo.setName(importOwnerRoomDto.getOwnerName());
|
ownerPo.setIdCard(importOwnerRoomDto.getIdCard());
|
ownerPo.setAge(importOwnerRoomDto.getAge());
|
ownerPo.setSex(importOwnerRoomDto.getSex());
|
ownerPo.setLink(importOwnerRoomDto.getTel());
|
ownerPo.setMemberId(ownerPo.getOwnerId());
|
ownerPo.setRemark("房产导入");
|
ownerPo.setUserId("-1");
|
flag = ownerV1InnerServiceSMOImpl.saveOwner(ownerPo);
|
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入业主失败");
|
}
|
|
ownerId = ownerPo.getOwnerId();
|
} else {
|
ownerId = ownerDtos.get(0).getOwnerId();
|
ownerPo = new OwnerPo();
|
ownerPo.setState(OwnerDto.STATE_FINISH);
|
ownerPo.setOwnerFlag(OwnerDto.OWNER_FLAG_TRUE);
|
ownerPo.setbId("-1");
|
ownerPo.setOwnerTypeCd(importOwnerRoomDto.getOwnerTypeCd());
|
ownerPo.setCommunityId(importOwnerRoomDto.getCommunityId());
|
ownerPo.setOwnerId(ownerId);
|
ownerPo.setName(importOwnerRoomDto.getOwnerName());
|
ownerPo.setIdCard(importOwnerRoomDto.getIdCard());
|
ownerPo.setAge(importOwnerRoomDto.getAge());
|
ownerPo.setSex(importOwnerRoomDto.getSex());
|
ownerPo.setLink(importOwnerRoomDto.getTel());
|
ownerPo.setMemberId(ownerPo.getOwnerId());
|
ownerPo.setRemark("房产导入");
|
ownerPo.setUserId("-1");
|
flag = ownerV1InnerServiceSMOImpl.updateOwner(ownerPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入业主失败");
|
}
|
}
|
// 查询房屋和业主是否有关系
|
OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
|
ownerRoomRelDto.setCommunityId(importOwnerRoomDto.getCommunityId());
|
ownerRoomRelDto.setRoomId(roomId);
|
ownerRoomRelDto.setOwnerId(ownerId);
|
List<OwnerRoomRelDto> roomRelDtos = ownerRoomRelV1InnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
|
if (roomRelDtos != null && roomRelDtos.size() > 0) {
|
return;
|
}
|
|
OwnerRoomRelPo ownerRoomRelPo = new OwnerRoomRelPo();
|
ownerRoomRelPo.setUserId("-1");
|
ownerRoomRelPo.setbId("-1");
|
ownerRoomRelPo.setRelId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_relId));
|
ownerRoomRelPo.setState("2001");
|
ownerRoomRelPo.setRoomId(roomId);
|
ownerRoomRelPo.setOwnerId(ownerId);
|
ownerRoomRelPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B));
|
ownerRoomRelPo.setEndTime(DateUtil.LAST_TIME);
|
|
flag = ownerRoomRelV1InnerServiceSMOImpl.saveOwnerRoomRel(ownerRoomRelPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入业主房屋关系失败");
|
}
|
}
|
|
private String doSaveRoom(ImportOwnerRoomDto importOwnerRoomDto, String unitId) {
|
RoomDto roomDto = new RoomDto();
|
roomDto.setCommunityId(importOwnerRoomDto.getCommunityId());
|
roomDto.setRoomNum(importOwnerRoomDto.getRoomNum());
|
roomDto.setUnitId(unitId);
|
List<RoomDto> roomDtos = roomV1InnerServiceSMOImpl.queryRooms(roomDto);
|
RoomPo roomPo = null;
|
String roomId = "";
|
|
int flag = 0;
|
if (roomDtos == null || roomDtos.size() < 1) {
|
roomPo = new RoomPo();
|
roomPo.setState(StringUtil.isEmpty(importOwnerRoomDto.getOwnerName()) ? RoomDto.STATE_FREE : RoomDto.STATE_SELL);
|
roomPo.setRoomId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_roomId));
|
roomPo.setApartment(importOwnerRoomDto.getSection());
|
roomPo.setSection("1");
|
roomPo.setCommunityId(importOwnerRoomDto.getCommunityId());
|
roomPo.setBuiltUpArea(importOwnerRoomDto.getBuiltUpArea());
|
roomPo.setFeeCoefficient("1.00");
|
roomPo.setLayer(importOwnerRoomDto.getLayer());
|
roomPo.setRoomArea(importOwnerRoomDto.getRoomArea());
|
roomPo.setRoomNum(importOwnerRoomDto.getRoomNum());
|
roomPo.setRoomRent(importOwnerRoomDto.getRoomRent());
|
roomPo.setRoomSubType(importOwnerRoomDto.getRoomSubType());
|
roomPo.setRoomType("0".equals(importOwnerRoomDto.getUnitNum()) ? RoomDto.ROOM_TYPE_SHOPS : RoomDto.ROOM_TYPE_ROOM);
|
roomPo.setUnitId(unitId);
|
roomPo.setRemark("房产导入");
|
roomPo.setUserId("-1");
|
flag = roomV1InnerServiceSMOImpl.saveRoom(roomPo);
|
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入房屋失败");
|
}
|
|
roomId = roomPo.getRoomId();
|
} else {
|
roomId = roomDtos.get(0).getRoomId();
|
if (OwnerDto.OWNER_TYPE_CD_OWNER.equals(importOwnerRoomDto.getOwnerTypeCd()) || StringUtil.isEmpty(importOwnerRoomDto.getOwnerName())) {
|
roomPo = new RoomPo();
|
roomPo.setState(StringUtil.isEmpty(importOwnerRoomDto.getOwnerName()) ? RoomDto.STATE_FREE : RoomDto.STATE_SELL);
|
roomPo.setRoomId(roomId);
|
roomPo.setApartment(importOwnerRoomDto.getSection());
|
roomPo.setSection("1");
|
roomPo.setCommunityId(importOwnerRoomDto.getCommunityId());
|
roomPo.setBuiltUpArea(importOwnerRoomDto.getBuiltUpArea());
|
roomPo.setFeeCoefficient("1.00");
|
roomPo.setLayer(importOwnerRoomDto.getLayer());
|
roomPo.setRoomArea(importOwnerRoomDto.getRoomArea());
|
roomPo.setRoomNum(importOwnerRoomDto.getRoomNum());
|
roomPo.setRoomRent(importOwnerRoomDto.getRoomRent());
|
roomPo.setRoomSubType(importOwnerRoomDto.getRoomSubType());
|
roomPo.setRoomType("0".equals(importOwnerRoomDto.getUnitNum()) ? RoomDto.ROOM_TYPE_SHOPS : RoomDto.ROOM_TYPE_ROOM);
|
roomPo.setUnitId(unitId);
|
roomPo.setRemark("房产导入");
|
roomPo.setUserId("-1");
|
flag = roomV1InnerServiceSMOImpl.updateRoom(roomPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入房屋失败");
|
}
|
}
|
}
|
return roomId;
|
|
}
|
|
/**
|
* 保存单元信息
|
*
|
* @param importOwnerRoomDto
|
* @param floorId
|
* @return
|
*/
|
private String doSaveUnit(ImportOwnerRoomDto importOwnerRoomDto, String floorId) {
|
|
UnitDto unitDto = new UnitDto();
|
unitDto.setCommunityId(importOwnerRoomDto.getCommunityId());
|
unitDto.setUnitNum(importOwnerRoomDto.getUnitNum());
|
unitDto.setFloorId(floorId);
|
List<UnitDto> unitDtos = unitV1InnerServiceSMOImpl.queryUnits(unitDto);
|
UnitPo unitPo = null;
|
String unitId = "";
|
|
int flag = 0;
|
if (unitDtos == null || unitDtos.size() < 1) {
|
unitPo = new UnitPo();
|
unitPo.setFloorId(floorId);
|
unitPo.setLayerCount(importOwnerRoomDto.getLayerCount());
|
unitPo.setLift(importOwnerRoomDto.getLift());
|
unitPo.setUnitId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_unitId));
|
unitPo.setUnitArea("1");
|
unitPo.setUnitNum(importOwnerRoomDto.getUnitNum());
|
unitPo.setRemark("房产导入");
|
unitPo.setUserId("-1");
|
flag = unitV1InnerServiceSMOImpl.saveUnit(unitPo);
|
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入单元失败");
|
}
|
|
unitId = unitPo.getFloorId();
|
} else {
|
unitId = unitDtos.get(0).getUnitId();
|
if (OwnerDto.OWNER_TYPE_CD_OWNER.equals(importOwnerRoomDto.getOwnerTypeCd()) || StringUtil.isEmpty(importOwnerRoomDto.getOwnerName())) {
|
unitPo = new UnitPo();
|
unitPo.setFloorId(floorId);
|
unitPo.setLayerCount(importOwnerRoomDto.getLayerCount());
|
unitPo.setLift(importOwnerRoomDto.getLift());
|
unitPo.setUnitId(unitId);
|
unitPo.setUnitArea("1");
|
unitPo.setUnitNum(importOwnerRoomDto.getUnitNum());
|
unitPo.setRemark("房产导入");
|
unitPo.setUserId("-1");
|
flag = unitV1InnerServiceSMOImpl.updateUnit(unitPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入单元失败");
|
}
|
}
|
}
|
return unitId;
|
}
|
|
/**
|
* 保存楼栋信息
|
*
|
* @param importOwnerRoomDto
|
* @return
|
*/
|
private String doSaveFloor(ImportOwnerRoomDto importOwnerRoomDto) {
|
FloorDto floorDto = new FloorDto();
|
floorDto.setCommunityId(importOwnerRoomDto.getCommunityId());
|
floorDto.setFloorNum(importOwnerRoomDto.getFloorNum());
|
List<FloorDto> floorDtos = floorV1InnerServiceSMOImpl.queryFloors(floorDto);
|
FloorPo floorPo = null;
|
String floorId = "";
|
|
int flag = 0;
|
if (floorDtos == null || floorDtos.size() < 1) {
|
floorPo = new FloorPo();
|
floorPo.setbId("-1");
|
floorPo.setCommunityId(importOwnerRoomDto.getCommunityId());
|
floorPo.setFloorArea("1");
|
floorPo.setFloorId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_floorId));
|
floorPo.setFloorNum(importOwnerRoomDto.getFloorNum());
|
floorPo.setName(importOwnerRoomDto.getFloorNum()+"栋");
|
floorPo.setRemark("房产导入");
|
floorPo.setUserId("-1");
|
flag = floorV1InnerServiceSMOImpl.saveFloor(floorPo);
|
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入楼栋失败");
|
}
|
|
floorId = floorPo.getFloorId();
|
} else {
|
floorId = floorDtos.get(0).getFloorId();
|
if (OwnerDto.OWNER_TYPE_CD_OWNER.equals(importOwnerRoomDto.getOwnerTypeCd()) || StringUtil.isEmpty(importOwnerRoomDto.getOwnerName())) {
|
floorPo = new FloorPo();
|
floorPo.setbId("-1");
|
floorPo.setCommunityId(importOwnerRoomDto.getCommunityId());
|
floorPo.setFloorArea("1");
|
floorPo.setFloorId(floorId);
|
floorPo.setFloorNum(importOwnerRoomDto.getFloorNum());
|
floorPo.setName(importOwnerRoomDto.getFloorNum()+"栋");
|
floorPo.setRemark("房产导入");
|
floorPo.setUserId("-1");
|
flag = floorV1InnerServiceSMOImpl.updateFloor(floorPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入楼栋失败");
|
}
|
}
|
}
|
return floorId;
|
}
|
|
|
}
|
