| | |
| | | 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; |
| | |
| | | OwnerPo ownerPo = null; |
| | | |
| | | int flag = 0; |
| | | if (ownerDtos == null || ownerDtos.size() < 1) { |
| | | if (ListUtil.isNull(ownerDtos)) { |
| | | ownerPo = new OwnerPo(); |
| | | ownerPo.setState(OwnerDto.STATE_FINISH); |
| | | ownerPo.setOwnerFlag(OwnerDto.OWNER_FLAG_TRUE); |
| | |
| | | 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) { |
| | |
| | | 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("导入业主失败"); |
| | |
| | | List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto); |
| | | String ownerId = ""; |
| | | int flag = 0; |
| | | if (ownerDtos == null || ownerDtos.size() < 1) { |
| | | if (ListUtil.isNull(ownerDtos)) { |
| | | ownerId = doSaveOwnerInfo(importOwnerRoomDto); |
| | | } else { |
| | | ownerId = ownerDtos.get(0).getOwnerId(); |
| | |
| | | ownerRoomRelDto.setRoomId(roomId); |
| | | ownerRoomRelDto.setOwnerId(ownerId); |
| | | List<OwnerRoomRelDto> roomRelDtos = ownerRoomRelV1InnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto); |
| | | if (roomRelDtos != null && roomRelDtos.size() > 0) { |
| | | if (!ListUtil.isNull(roomRelDtos)) { |
| | | return; |
| | | } |
| | | |
| | |
| | | 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("导入业主失败"); |
| | |
| | | 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.saveOwner(ownerPo); |
| | | if (flag < 1) { |
| | | throw new IllegalArgumentException("导入业主失败"); |
| | |
| | | ownerAppUserPo.setLink(ownerPo.getLink()); |
| | | ownerAppUserPo.setUserId(userPo.getUserId()); |
| | | ownerAppUserPo.setOpenId("-1"); |
| | | ownerAppUserPo.setOwnerTypeCd(ownerPo.getOwnerTypeCd()); |
| | | |
| | | flag = ownerAppUserV1InnerServiceSMOImpl.saveOwnerAppUser(ownerAppUserPo); |
| | | if (flag < 1) { |