From bf4bab696aeaaf94b6d95781e7607f17771f3d5c Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期三, 08 六月 2022 09:55:33 +0800
Subject: [PATCH] 优化小区无法同步 问题
---
service-community/src/main/java/com/java110/community/smo/impl/ImportOwnerRoomInnerServiceSMOImpl.java | 35 ++++++++++++++++++++---------------
1 files changed, 20 insertions(+), 15 deletions(-)
diff --git a/service-community/src/main/java/com/java110/community/smo/impl/ImportOwnerRoomInnerServiceSMOImpl.java b/service-community/src/main/java/com/java110/community/smo/impl/ImportOwnerRoomInnerServiceSMOImpl.java
index 5d6c84c..a712b4e 100644
--- a/service-community/src/main/java/com/java110/community/smo/impl/ImportOwnerRoomInnerServiceSMOImpl.java
+++ b/service-community/src/main/java/com/java110/community/smo/impl/ImportOwnerRoomInnerServiceSMOImpl.java
@@ -143,7 +143,7 @@
ownerPo.setLink(importOwnerRoomDto.getTel());
ownerPo.setMemberId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId));
ownerPo.setRemark("鎴夸骇瀵煎叆");
- ownerPo.setUserId("-1");
+ ownerPo.setUserId(importOwnerRoomDto.getUserId());
flag = ownerV1InnerServiceSMOImpl.saveOwner(ownerPo);
if (flag < 1) {
@@ -164,7 +164,7 @@
ownerPo.setLink(importOwnerRoomDto.getTel());
ownerPo.setMemberId(ownerDtos.get(0).getMemberId());
ownerPo.setRemark("鎴夸骇瀵煎叆");
- ownerPo.setUserId("-1");
+ ownerPo.setUserId(importOwnerRoomDto.getUserId());
flag = ownerV1InnerServiceSMOImpl.updateOwner(ownerPo);
if (flag < 1) {
throw new IllegalArgumentException("瀵煎叆涓氫富澶辫触");
@@ -205,7 +205,7 @@
ownerPo.setLink(importOwnerRoomDto.getTel());
ownerPo.setMemberId(ownerPo.getOwnerId());
ownerPo.setRemark("鎴夸骇瀵煎叆");
- ownerPo.setUserId("-1");
+ ownerPo.setUserId(importOwnerRoomDto.getUserId());
flag = ownerV1InnerServiceSMOImpl.saveOwner(ownerPo);
if (flag < 1) {
@@ -229,7 +229,7 @@
ownerPo.setLink(importOwnerRoomDto.getTel());
ownerPo.setMemberId(ownerPo.getOwnerId());
ownerPo.setRemark("鎴夸骇瀵煎叆");
- ownerPo.setUserId("-1");
+ ownerPo.setUserId(importOwnerRoomDto.getUserId());
flag = ownerV1InnerServiceSMOImpl.updateOwner(ownerPo);
if (flag < 1) {
throw new IllegalArgumentException("瀵煎叆涓氫富澶辫触");
@@ -246,7 +246,7 @@
}
OwnerRoomRelPo ownerRoomRelPo = new OwnerRoomRelPo();
- ownerRoomRelPo.setUserId("-1");
+ ownerRoomRelPo.setUserId(importOwnerRoomDto.getUserId());
ownerRoomRelPo.setbId("-1");
ownerRoomRelPo.setRelId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_relId));
ownerRoomRelPo.setState("2001");
@@ -273,7 +273,8 @@
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(StringUtil.isEmpty(importOwnerRoomDto.getOwnerName()) ? RoomDto.STATE_FREE : RoomDto.STATE_SELL);
+ roomPo.setState(importOwnerRoomDto.getRoomState());
roomPo.setRoomId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_roomId));
roomPo.setApartment(importOwnerRoomDto.getSection());
roomPo.setSection("1");
@@ -288,7 +289,7 @@
roomPo.setRoomType("0".equals(importOwnerRoomDto.getUnitNum()) ? RoomDto.ROOM_TYPE_SHOPS : RoomDto.ROOM_TYPE_ROOM);
roomPo.setUnitId(unitId);
roomPo.setRemark("鎴夸骇瀵煎叆");
- roomPo.setUserId("-1");
+ roomPo.setUserId(importOwnerRoomDto.getUserId());
flag = roomV1InnerServiceSMOImpl.saveRoom(roomPo);
if (flag < 1) {
@@ -315,7 +316,7 @@
roomPo.setRoomType("0".equals(importOwnerRoomDto.getUnitNum()) ? RoomDto.ROOM_TYPE_SHOPS : RoomDto.ROOM_TYPE_ROOM);
roomPo.setUnitId(unitId);
roomPo.setRemark("鎴夸骇瀵煎叆");
- roomPo.setUserId("-1");
+ roomPo.setUserId(importOwnerRoomDto.getUserId());
flag = roomV1InnerServiceSMOImpl.updateRoom(roomPo);
if (flag < 1) {
throw new IllegalArgumentException("瀵煎叆鎴垮眿澶辫触");
@@ -351,15 +352,16 @@
unitPo.setLift(importOwnerRoomDto.getLift());
unitPo.setUnitId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_unitId));
unitPo.setUnitArea("1");
+ unitPo.setUnitNum(importOwnerRoomDto.getUnitNum());
unitPo.setRemark("鎴夸骇瀵煎叆");
- unitPo.setUserId("-1");
+ unitPo.setUserId(importOwnerRoomDto.getUserId());
flag = unitV1InnerServiceSMOImpl.saveUnit(unitPo);
if (flag < 1) {
throw new IllegalArgumentException("瀵煎叆鍗曞厓澶辫触");
}
- unitId = unitPo.getFloorId();
+ unitId = unitPo.getUnitId();
} else {
unitId = unitDtos.get(0).getUnitId();
if (OwnerDto.OWNER_TYPE_CD_OWNER.equals(importOwnerRoomDto.getOwnerTypeCd()) || StringUtil.isEmpty(importOwnerRoomDto.getOwnerName())) {
@@ -369,8 +371,9 @@
unitPo.setLift(importOwnerRoomDto.getLift());
unitPo.setUnitId(unitId);
unitPo.setUnitArea("1");
+ unitPo.setUnitNum(importOwnerRoomDto.getUnitNum());
unitPo.setRemark("鎴夸骇瀵煎叆");
- unitPo.setUserId("-1");
+ unitPo.setUserId(importOwnerRoomDto.getUserId());
flag = unitV1InnerServiceSMOImpl.updateUnit(unitPo);
if (flag < 1) {
throw new IllegalArgumentException("瀵煎叆鍗曞厓澶辫触");
@@ -402,8 +405,9 @@
floorPo.setFloorArea("1");
floorPo.setFloorId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_floorId));
floorPo.setFloorNum(importOwnerRoomDto.getFloorNum());
+ floorPo.setName(importOwnerRoomDto.getFloorNum()+"鏍�");
floorPo.setRemark("鎴夸骇瀵煎叆");
- floorPo.setUserId("-1");
+ floorPo.setUserId(importOwnerRoomDto.getUserId());
flag = floorV1InnerServiceSMOImpl.saveFloor(floorPo);
if (flag < 1) {
@@ -415,13 +419,14 @@
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.setbId("-1");
floorPo.setCommunityId(importOwnerRoomDto.getCommunityId());
- floorPo.setFloorArea("1");
+ //floorPo.setFloorArea("1");
floorPo.setFloorId(floorId);
floorPo.setFloorNum(importOwnerRoomDto.getFloorNum());
+ floorPo.setName(importOwnerRoomDto.getFloorNum()+"鏍�");
floorPo.setRemark("鎴夸骇瀵煎叆");
- floorPo.setUserId("-1");
+ floorPo.setUserId(importOwnerRoomDto.getUserId());
flag = floorV1InnerServiceSMOImpl.updateFloor(floorPo);
if (flag < 1) {
throw new IllegalArgumentException("瀵煎叆妤兼爧澶辫触");
--
Gitblit v1.8.0