package com.java110.community.smo.impl;
|
|
import com.java110.core.base.smo.BaseServiceSMO;
|
import com.java110.core.factory.AuthenticationFactory;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.dto.community.CommunityDto;
|
import com.java110.dto.floor.FloorDto;
|
import com.java110.dto.importData.OwnerCollectionDto;
|
import com.java110.dto.owner.OwnerAppUserDto;
|
import com.java110.dto.room.RoomDto;
|
import com.java110.dto.unit.UnitDto;
|
import com.java110.dto.owner.OwnerDto;
|
import com.java110.dto.owner.OwnerRoomRelDto;
|
import com.java110.dto.importData.ImportOwnerRoomDto;
|
import com.java110.intf.community.*;
|
import com.java110.intf.user.IOwnerAppUserV1InnerServiceSMO;
|
import com.java110.intf.user.IOwnerRoomRelV1InnerServiceSMO;
|
import com.java110.intf.user.IOwnerV1InnerServiceSMO;
|
import com.java110.intf.user.IUserV1InnerServiceSMO;
|
import com.java110.po.floor.FloorPo;
|
import com.java110.po.owner.OwnerAppUserPo;
|
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.po.user.UserPo;
|
import com.java110.utils.cache.MappingCache;
|
import com.java110.utils.constant.MappingConstant;
|
import com.java110.utils.constant.UserLevelConstant;
|
import com.java110.utils.exception.CmdException;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.DateUtil;
|
import com.java110.utils.util.ListUtil;
|
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(ImportOwnerRoomInnerServiceSMOImpl.class);
|
|
|
@Autowired
|
private IFloorV1InnerServiceSMO floorV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IUnitV1InnerServiceSMO unitV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerRoomRelV1InnerServiceSMO ownerRoomRelV1InnerServiceSMOImpl;
|
|
|
@Autowired
|
private IOwnerAppUserV1InnerServiceSMO ownerAppUserV1InnerServiceSMOImpl;
|
|
@Autowired
|
private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
|
@Autowired
|
private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;
|
|
@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;
|
}
|
|
@Override
|
public int saveOwnerRoom(@RequestBody ImportOwnerRoomDto importOwnerRoomDto) {
|
|
|
if (importOwnerRoomDto == null) {
|
return 0;
|
}
|
|
List<ImportOwnerRoomDto> importOwnerRoomDtosed = new ArrayList<>();
|
// 1.0 查看 楼栋是否存在
|
return doSaveOwnerRooms(importOwnerRoomDto, importOwnerRoomDtosed);
|
|
|
}
|
@Override
|
public int saveOwnerCollection(@RequestBody OwnerCollectionDto ownerCollectionDto){
|
|
if (ownerCollectionDto == null) {
|
return 0;
|
}
|
|
return ownerV1InnerServiceSMOImpl.saveOwnerCollection(ownerCollectionDto);
|
}
|
|
/**
|
* 导入数据
|
*
|
* @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 (ListUtil.isNull(ownerDtos)) {
|
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(importOwnerRoomDto.getUserId());
|
ownerPo.setPersonType(importOwnerRoomDto.getPersonType());
|
ownerPo.setPersonRole(importOwnerRoomDto.getPersonRole());
|
ownerPo.setConcactPerson(importOwnerRoomDto.getConcactPerson());
|
ownerPo.setConcactLink(importOwnerRoomDto.getConcactLink());
|
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(importOwnerRoomDto.getUserId());
|
ownerPo.setPersonType(importOwnerRoomDto.getPersonType());
|
ownerPo.setPersonRole(importOwnerRoomDto.getPersonRole());
|
ownerPo.setConcactPerson(importOwnerRoomDto.getConcactPerson());
|
ownerPo.setConcactLink(importOwnerRoomDto.getConcactLink());
|
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);
|
String ownerId = "";
|
int flag = 0;
|
if (ListUtil.isNull(ownerDtos)) {
|
ownerId = doSaveOwnerInfo(importOwnerRoomDto);
|
} else {
|
ownerId = ownerDtos.get(0).getOwnerId();
|
doUpdateOwnerInfo(importOwnerRoomDto, ownerId);
|
}
|
// 查询房屋和业主是否有关系
|
OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
|
ownerRoomRelDto.setCommunityId(importOwnerRoomDto.getCommunityId());
|
ownerRoomRelDto.setRoomId(roomId);
|
ownerRoomRelDto.setOwnerId(ownerId);
|
List<OwnerRoomRelDto> roomRelDtos = ownerRoomRelV1InnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
|
if (!ListUtil.isNull(roomRelDtos)) {
|
return;
|
}
|
|
OwnerRoomRelPo ownerRoomRelPo = new OwnerRoomRelPo();
|
ownerRoomRelPo.setUserId(importOwnerRoomDto.getUserId());
|
ownerRoomRelPo.setbId("-1");
|
ownerRoomRelPo.setRelId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_relId));
|
ownerRoomRelPo.setState(importOwnerRoomDto.getRoomState());
|
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 void doUpdateOwnerInfo(ImportOwnerRoomDto importOwnerRoomDto, String ownerId) {
|
OwnerPo ownerPo;
|
int flag;
|
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(importOwnerRoomDto.getUserId());
|
ownerPo.setPersonType(importOwnerRoomDto.getPersonType());
|
ownerPo.setPersonRole(importOwnerRoomDto.getPersonRole());
|
ownerPo.setConcactPerson(importOwnerRoomDto.getConcactPerson());
|
ownerPo.setConcactLink(importOwnerRoomDto.getConcactLink());
|
flag = ownerV1InnerServiceSMOImpl.updateOwner(ownerPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入业主失败");
|
}
|
}
|
|
private String doSaveOwnerInfo(ImportOwnerRoomDto importOwnerRoomDto) {
|
int flag;
|
OwnerPo 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());
|
if (importOwnerRoomDto.getOwnerId() == null) {
|
ownerPo.setOwnerId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId));
|
}else{
|
ownerPo.setOwnerId(importOwnerRoomDto.getOwnerId());
|
}
|
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(importOwnerRoomDto.getUserId());
|
ownerPo.setPersonType(importOwnerRoomDto.getPersonType());
|
ownerPo.setPersonRole(importOwnerRoomDto.getPersonRole());
|
ownerPo.setConcactPerson(importOwnerRoomDto.getConcactPerson());
|
|
ownerPo.setPropertyCertificateNo(importOwnerRoomDto.getPropertyCertificateNo());
|
ownerPo.setIsEvChargerInstalled(importOwnerRoomDto.getIsEvChargerInstalled());
|
ownerPo.setHouseholdPoliceStation(importOwnerRoomDto.getHouseholdPoliceStation());
|
|
ownerPo.setConcactLink(importOwnerRoomDto.getConcactLink());
|
flag = ownerV1InnerServiceSMOImpl.saveOwner(ownerPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入业主失败");
|
}
|
|
String autoUser = MappingCache.getValue(MappingConstant.DOMAIN_SYSTEM_SWITCH, "AUTO_GENERATOR_OWNER_USER");
|
|
if (!"ON".equals(autoUser)) {
|
return ownerPo.getOwnerId();
|
}
|
|
CommunityDto communityDto = new CommunityDto();
|
communityDto.setCommunityId(ownerPo.getCommunityId());
|
List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto);
|
Assert.listNotNull(communityDtos, "未包含小区信息");
|
CommunityDto tmpCommunityDto = communityDtos.get(0);
|
|
UserPo userPo = new UserPo();
|
userPo.setUserId(GenerateCodeFactory.getUserId());
|
userPo.setName(ownerPo.getName());
|
userPo.setTel(ownerPo.getLink());
|
userPo.setPassword(AuthenticationFactory.passwdMd5("888888"));
|
userPo.setLevelCd(UserLevelConstant.USER_LEVEL_ORDINARY);
|
userPo.setAge(ownerPo.getAge());
|
userPo.setAddress(ownerPo.getAddress());
|
userPo.setSex(ownerPo.getSex());
|
flag = userV1InnerServiceSMOImpl.saveUser(userPo);
|
if (flag < 1) {
|
throw new CmdException("注册失败");
|
}
|
|
OwnerAppUserPo ownerAppUserPo = new OwnerAppUserPo();
|
//状态类型，10000 审核中， 11000 待认证 ,12000 审核成功，13000 审核失败
|
ownerAppUserPo.setState(OwnerAppUserDto.STATE_NOT_AUDIT);
|
ownerAppUserPo.setAppTypeCd("10010");
|
ownerAppUserPo.setAppUserId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_appUserId));
|
ownerAppUserPo.setMemberId(ownerPo.getMemberId());
|
ownerAppUserPo.setCommunityName(tmpCommunityDto.getName());
|
ownerAppUserPo.setCommunityId(ownerPo.getCommunityId());
|
ownerAppUserPo.setAppUserName(ownerPo.getName());
|
ownerAppUserPo.setIdCard(ownerPo.getIdCard());
|
ownerAppUserPo.setAppType("WECHAT");
|
ownerAppUserPo.setLink(ownerPo.getLink());
|
ownerAppUserPo.setUserId(userPo.getUserId());
|
ownerAppUserPo.setOpenId("-1");
|
ownerAppUserPo.setOwnerTypeCd(ownerPo.getOwnerTypeCd());
|
|
flag = ownerAppUserV1InnerServiceSMOImpl.saveOwnerAppUser(ownerAppUserPo);
|
if (flag < 1) {
|
throw new CmdException("添加用户业主关系失败");
|
}
|
|
return ownerPo.getOwnerId();
|
}
|
|
private String doSaveRoom(ImportOwnerRoomDto importOwnerRoomDto, String unitId) {
|
RoomDto roomDto = new RoomDto();
|
roomDto.setCommunityId(importOwnerRoomDto.getCommunityId());
|
roomDto.setRoomNum(importOwnerRoomDto.getRoomNum());
|
roomDto.setUnitId(unitId);
|
roomDto.setPropertyAddress(importOwnerRoomDto.getPropertyAddress());
|
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.setState(importOwnerRoomDto.getRoomState());
|
if (importOwnerRoomDto.getRoomId() == null) {
|
roomPo.setRoomId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_roomId));
|
}else{
|
roomPo.setRoomId(importOwnerRoomDto.getRoomId());
|
}
|
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(importOwnerRoomDto.getUserId());
|
roomPo.setDoorRoomNum(importOwnerRoomDto.getDoorRoomNum());
|
roomPo.setPropertyType(importOwnerRoomDto.getPropertyType());
|
roomPo.setPropertyAddress(importOwnerRoomDto.getPropertyAddress());
|
roomPo.setHouseCertificateNo(importOwnerRoomDto.getHouseCertificateNo());
|
roomPo.setRoadName(importOwnerRoomDto.getRoadName());
|
roomPo.setSellDate(importOwnerRoomDto.getSellDate());
|
roomPo.setBuyDate(importOwnerRoomDto.getBuyDate());
|
roomPo.setSellState(importOwnerRoomDto.getSellState());
|
roomPo.setEoc(importOwnerRoomDto.getEoc());
|
roomPo.setRoomBuyer(importOwnerRoomDto.getRoomBuyer());
|
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(importOwnerRoomDto.getRoomState());
|
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(importOwnerRoomDto.getUserId());
|
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(importOwnerRoomDto.getUserId());
|
flag = unitV1InnerServiceSMOImpl.saveUnit(unitPo);
|
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入单元失败");
|
}
|
|
unitId = unitPo.getUnitId();
|
} 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(importOwnerRoomDto.getUserId());
|
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 seq = 1;
|
if (StringUtil.isNumber(importOwnerRoomDto.getFloorNum())) {
|
seq = Integer.parseInt(importOwnerRoomDto.getFloorNum());
|
}
|
|
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(importOwnerRoomDto.getUserId());
|
floorPo.setSeq(seq);
|
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(importOwnerRoomDto.getUserId());
|
flag = floorV1InnerServiceSMOImpl.updateFloor(floorPo);
|
if (flag < 1) {
|
throw new IllegalArgumentException("导入楼栋失败");
|
}
|
}
|
}
|
return floorId;
|
}
|
|
|
}
|
