UpdateRoomCmd.java
14.1 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
package com.java110.community.cmd.room;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.annotation.Java110Transactional;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.doc.annotation.*;
import com.java110.dto.data.DatabusDataDto;
import com.java110.dto.room.RoomDto;
import com.java110.dto.unit.UnitDto;
import com.java110.dto.owner.OwnerRoomRelDto;
import com.java110.intf.community.*;
import com.java110.intf.job.IDataBusInnerServiceSMO;
import com.java110.intf.user.IOwnerRoomRelInnerServiceSMO;
import com.java110.po.owner.OwnerRoomRelPo;
import com.java110.po.room.RoomAttrPo;
import com.java110.po.room.RoomPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.*;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.Date;
import java.util.List;
/**
* 房屋信息更新命令类
* 负责处理房屋信息的修改操作，包括房屋基本信息更新、房屋属性维护、租期信息修改等业务功能
* 对应后台系统的房屋修改功能
*
* @author 吴学文
* @version 1.0
* @since 2023
*/
@Java110CmdDoc(title = "修改房屋",
description = "对应后台 修改房屋功能",
httpMethod = "post",
url = "http://{ip}:{port}/app/room.updateRoom",
resource = "communityDoc",
author = "吴学文",
serviceCode = "room.updateRoom",
seq = 14
)
@Java110ParamsDoc(params = {
@Java110ParamDoc(name = "communityId", length = 30, remark = "小区ID"),
@Java110ParamDoc(name = "roomNum", length = 64, remark = "房号"),
@Java110ParamDoc(name = "layer", length = 12, remark = "层数"),
@Java110ParamDoc(name = "unitId", length = 30, remark = "单元ID"),
@Java110ParamDoc(name = "roomId", length = 30, remark = "单元ID"),
@Java110ParamDoc(name = "section", length = 12, remark = "房屋个数"),
@Java110ParamDoc(name = "apartment", length = 12, remark = "固定 10102"),
@Java110ParamDoc(name = "builtUpArea", length = 12, remark = "建筑面积"),
@Java110ParamDoc(name = "feeCoefficient", length = 12, remark = "算费系数 固定1"),
@Java110ParamDoc(name = "roomSubType", length = 12, remark = "房屋类型 110\t住宅\n" +
"120\t办公室\n" +
"119\t宿舍"),
@Java110ParamDoc(name = "roomArea", length = 12, remark = "室内面积"),
@Java110ParamDoc(name = "roomRent", length = 12, remark = "办公室 或者宿舍 时租金"),
@Java110ParamDoc(name = "remark", length = 512, remark = "备注"),
})
@Java110ResponseDoc(
params = {
@Java110ParamDoc(name = "code", type = "int", length = 11, defaultValue = "0", remark = "返回编号，0 成功 其他失败"),
@Java110ParamDoc(name = "msg", type = "String", length = 250, defaultValue = "成功", remark = "描述"),
}
)
@Java110ExampleDoc(
reqBody = "{\n" +
"\t\"roomNum\": \"88488\",\n" +
"\t\"layer\": \"1\",\n" +
"\t\"unitId\":\"123123123\",\n" +
"\t\"section\": \"0\",\n" +
"\t\"apartment\": \"10102\",\n" +
"\t\"builtUpArea\": \"110\",\n" +
"\t\"feeCoefficient\": \"1.00\",\n" +
"\t\"roomId\": \"123123123123\",\n" +
"\t\"remark\": \"sdf\",\n" +
"\t\"roomSubType\": \"110\",\n" +
"\t\"roomArea\": \"110\",\n" +
"\t\"roomRent\": \"0\",\n" +
"\t\"communityId\": \"2022121921870161\",\n" +
"}",
resBody = "{\"code\":0,\"msg\":\"成功\"}"
)
@Java110Cmd(serviceCode = "room.updateRoom")
public class UpdateRoomCmd extends Cmd {
@Autowired
private IUnitInnerServiceSMO unitInnerServiceSMOImpl;
@Autowired
private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl;
@Autowired
private IRoomAttrV1InnerServiceSMO roomAttrV1InnerServiceSMOImpl;
@Autowired
private IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMOImpl;
@Autowired
private IDataBusInnerServiceSMO dataBusInnerServiceSMOImpl;
/**
* 参数校验方法
* 验证请求参数的有效性和完整性，包括必填字段检查、数据格式验证、业务规则校验等
*
* @param event 命令事件对象
* @param cmdDataFlowContext 数据流上下文，包含请求和响应数据
* @param reqJson 请求参数JSON对象
* @throws CmdException 当参数校验失败时抛出异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
// 校验必填字段
Assert.jsonObjectHaveKey(reqJson, "roomId", "请求报文中未包含roomId节点");
Assert.jsonObjectHaveKey(reqJson, "communityId", "请求报文中未包含communityId节点");
Assert.jsonObjectHaveKey(reqJson, "roomNum", "请求报文中未包含roomNum节点");
Assert.jsonObjectHaveKey(reqJson, "layer", "请求报文中未包含layer节点");
/*Assert.jsonObjectHaveKey(paramIn, "section", "请求报文中未包含section节点");*/
Assert.jsonObjectHaveKey(reqJson, "builtUpArea", "请求报文中未包含builtUpArea节点");
// 校验金额格式
if (reqJson.containsKey("builtUpArea")) {
Assert.isMoney(reqJson.getString("builtUpArea"), "建筑面积数据格式错误");
}
if (reqJson.containsKey("feeCoefficient")) {
Assert.isMoney(reqJson.getString("feeCoefficient"), "算费系数数据格式错误");
}
// 获取房屋状态并校验租期时间
String state = reqJson.getString("state");
if (RoomDto.STATE_SHOP_FIRE.equals(state)) { //已出租
// 获取起租时间和截租时间
Date startTime = null;
Date endTime = null;
if (reqJson.containsKey("startTime") && !StringUtil.isEmpty(reqJson.getString("startTime"))
&& reqJson.containsKey("endTime") && !StringUtil.isEmpty(reqJson.getString("endTime"))) {
try {
// 解析时间字符串
startTime = DateUtil.getDateFromString(reqJson.getString("startTime"), DateUtil.DATE_FORMATE_STRING_B);
endTime = DateUtil.getDateFromString(reqJson.getString("endTime"), DateUtil.DATE_FORMATE_STRING_B);
} catch (Exception e) {
throw new CmdException(e.getMessage());
}
// 校验起租时间不能大于截租时间
if (startTime.getTime() > endTime.getTime()) {
throw new IllegalArgumentException("起租时间不能大于截租时间！");
}
}
}
// 校验单元ID是否属于该小区
UnitDto unitDto = new UnitDto();
unitDto.setCommunityId(reqJson.getString("communityId"));
unitDto.setUnitId(reqJson.getString("unitId"));
// 查询小区下的单元信息
List<UnitDto> units = unitInnerServiceSMOImpl.queryUnitsByCommunityId(unitDto);
if (ListUtil.isNull(units)) {
throw new IllegalArgumentException("传入单元ID不是该小区的单元");
}
// 校验属性值
Assert.judgeAttrValue(reqJson);
}
/**
* 执行房屋更新命令
* 主要业务逻辑包括：更新房屋基本信息、修改租期信息、同步数据到IOT系统、维护房屋属性信息
*
* @param event 命令事件对象
* @param cmdDataFlowContext 数据流上下文
* @param reqJson 请求参数JSON对象
* @throws CmdException 当业务操作失败时抛出异常
*/
@Override
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
// 更新房屋基本信息
updateShellRoom(reqJson, cmdDataFlowContext);
// todo 修改租期
modifyRoomRateTime(reqJson,cmdDataFlowContext);
// 同步数据到IOT系统
JSONObject data = new JSONObject();
data.put("roomId",reqJson.getString("roomId"));
dataBusInnerServiceSMOImpl.databusData(new DatabusDataDto(DatabusDataDto.BUSINESS_TYPE_SEND_ROOM_DATA_TO_IOT,data));
// 处理房屋属性信息
if (!reqJson.containsKey("attrs")) {
return;
}
JSONArray attrs = reqJson.getJSONArray("attrs");
if (ListUtil.isNull(attrs)) {
return;
}
// 遍历属性数组，逐个处理房屋属性
JSONObject attr = null;
int flag = 0;
for (int attrIndex = 0; attrIndex < attrs.size(); attrIndex++) {
attr = attrs.getJSONObject(attrIndex);
attr.put("roomId", reqJson.getString("roomId"));
// 新增属性处理：当属性ID为空或以"-"开头时，视为新增属性
if (!attr.containsKey("attrId") || attr.getString("attrId").startsWith("-") || StringUtil.isEmpty(attr.getString("attrId"))) {
RoomAttrPo roomAttrPo = new RoomAttrPo();
roomAttrPo.setAttrId(GenerateCodeFactory.getAttrId()); // 生成属性ID
roomAttrPo.setRoomId(attr.getString("roomId"));
roomAttrPo.setSpecCd(attr.getString("specCd"));
roomAttrPo.setValue(attr.getString("value"));
flag = roomAttrV1InnerServiceSMOImpl.saveRoomAttr(roomAttrPo);
if (flag < 1) {
throw new CmdException("保存单元失败");
}
continue;
}
// 更新已有属性
RoomAttrPo roomAttrPo = new RoomAttrPo();
roomAttrPo.setAttrId(attr.getString("attrId"));
roomAttrPo.setRoomId(attr.getString("roomId"));
roomAttrPo.setSpecCd(attr.getString("specCd"));
roomAttrPo.setValue(attr.getString("value"));
flag = roomAttrV1InnerServiceSMOImpl.updateRoomAttr(roomAttrPo);
if (flag < 1) {
throw new CmdException("保存单元失败");
}
}
}
/**
* 修改房屋租期信息
* 根据房屋状态和租期信息更新业主房屋关系表中的租期数据
*
* @param reqJson 请求参数JSON对象
* @param cmdDataFlowContext 数据流上下文
*/
private void modifyRoomRateTime(JSONObject reqJson, ICmdDataFlowContext cmdDataFlowContext) {
// 查询房屋的业主关系信息
OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
ownerRoomRelDto.setRoomId(reqJson.getString("roomId"));
List<OwnerRoomRelDto> ownerRoomRelDtoList = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
// 如果没有业主房屋关系记录，直接返回
if(ListUtil.isNull(ownerRoomRelDtoList)){
return ;
}
String state = reqJson.getString("state");
// 处理已出租状态的房屋租期信息
if (RoomDto.STATE_SHOP_FIRE.equals(state)) { //已出租
OwnerRoomRelPo ownerRoomRelPo = BeanConvertUtil.covertBean(ownerRoomRelDtoList.get(0), OwnerRoomRelPo.class);
ownerRoomRelPo.setStartTime(reqJson.getString("startTime"));
ownerRoomRelPo.setEndTime(reqJson.getString("endTime"));
ownerRoomRelInnerServiceSMOImpl.updateOwnerRoomRels(ownerRoomRelPo);
return;
}
// 处理其他状态的房屋截租时间
String endTime = reqJson.getString("endTime");
if(!StringUtil.isEmpty(endTime)){
OwnerRoomRelPo ownerRoomRelPo = BeanConvertUtil.covertBean(ownerRoomRelDtoList.get(0), OwnerRoomRelPo.class);
ownerRoomRelPo.setEndTime(endTime);
ownerRoomRelInnerServiceSMOImpl.updateOwnerRoomRels(ownerRoomRelPo);
}
}
/**
* 更新房屋基本信息
* 将请求参数转换为房屋PO对象并执行更新操作，同时处理房屋分区逻辑
*
* @param paramInJson 接口调用方传入的参数
* @param cmdDataFlowContext 数据上下文
*/
public void updateShellRoom(JSONObject paramInJson, ICmdDataFlowContext cmdDataFlowContext) {
JSONObject businessUnit = new JSONObject();
businessUnit.putAll(paramInJson);
RoomPo roomPo = BeanConvertUtil.covertBean(businessUnit, RoomPo.class);
// 根据apartment1参数设置房屋分区(section)
// 将apartment1的数值映射到对应的分区编号
if (paramInJson.containsKey("apartment1") && paramInJson.getString("apartment1").equals("10")) {
roomPo.setSection("1");
} else if (paramInJson.containsKey("apartment1") && paramInJson.getString("apartment1").equals("20")) {
roomPo.setSection("2");
} else if (paramInJson.containsKey("apartment1") && paramInJson.getString("apartment1").equals("30")) {
roomPo.setSection("3");
} else if (paramInJson.containsKey("apartment1") && paramInJson.getString("apartment1").equals("40")) {
roomPo.setSection("4");
} else if (paramInJson.containsKey("apartment1") && paramInJson.getString("apartment1").equals("50")) {
roomPo.setSection("5");
} else if (paramInJson.containsKey("apartment1") && paramInJson.getString("apartment1").equals("60")) {
roomPo.setSection("6");
} else if (paramInJson.containsKey("apartment1") && paramInJson.getString("apartment1").equals("70")) {
roomPo.setSection("7");
} else if (paramInJson.containsKey("apartment1") && paramInJson.getString("apartment1").equals("80")) {
roomPo.setSection("8");
}
// 执行房屋信息更新操作
int flag = roomV1InnerServiceSMOImpl.updateRoom(roomPo);
if (flag < 1) {
throw new CmdException("修改房屋失败");
}
}
}