SaveRoomCmd.java
12.3 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
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.room.RoomDto;
import com.java110.dto.unit.UnitDto;
import com.java110.intf.community.IRoomAttrV1InnerServiceSMO;
import com.java110.intf.community.IRoomV1InnerServiceSMO;
import com.java110.intf.community.IUnitInnerServiceSMO;
import com.java110.intf.user.IOwnerRoomRelV1InnerServiceSMO;
import com.java110.po.owner.OwnerRoomRelPo;
import com.java110.po.room.RoomAttrPo;
import com.java110.po.room.RoomPo;
import com.java110.utils.constant.CommonConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.utils.util.DateUtil;
import com.java110.utils.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
/**
* 房屋管理命令类 - 负责处理房屋添加相关业务逻辑
*
* @Java110CmdDoc 注解定义了该命令的接口文档信息，包括接口标题、描述、请求方式、URL等
* @author 吴学文
* @version 1.0
* @since 2023
*/
@Java110CmdDoc(title = "添加房屋",
description = "对应后台 添加房屋功能",
httpMethod = "post",
url = "http://{ip}:{port}/app/room.saveRoom",
resource = "communityDoc",
author = "吴学文",
serviceCode = "room.saveRoom",
seq = 13
)
@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 = "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 = "state", length = 12, remark = "状态 2002\t未销售"),
@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\"state\": \"2002\",\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.saveRoom")
public class SaveRoomCmd extends Cmd {
@Autowired
private IUnitInnerServiceSMO unitInnerServiceSMOImpl;
@Autowired
private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl;
@Autowired
private IOwnerRoomRelV1InnerServiceSMO ownerRoomRelV1InnerServiceSMOImpl;
@Autowired
private IRoomAttrV1InnerServiceSMO roomAttrV1InnerServiceSMOImpl;
/**
* 参数验证方法 - 验证请求参数的完整性和有效性
*
* @param event 命令事件对象
* @param context 数据流上下文，包含请求和响应信息
* @param reqJson 请求参数的JSON对象
* @throws CmdException 当参数验证失败时抛出异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
// 验证必需参数是否存在
Assert.jsonObjectHaveKey(reqJson, "communityId", "请求报文中未包含communityId节点");
Assert.jsonObjectHaveKey(reqJson, "unitId", "请求报文中未包含unitId节点");
Assert.jsonObjectHaveKey(reqJson, "roomNum", "请求报文中未包含roomNum节点");
Assert.jsonObjectHaveKey(reqJson, "layer", "请求报文中未包含layer节点");
Assert.jsonObjectHaveKey(reqJson, "section", "请求报文中未包含section节点");
Assert.jsonObjectHaveKey(reqJson, "apartment", "请求报文中未包含apartment节点");
Assert.jsonObjectHaveKey(reqJson, "state", "请求报文中未包含state节点");
Assert.jsonObjectHaveKey(reqJson, "builtUpArea", "请求报文中未包含builtUpArea节点");
Assert.jsonObjectHaveKey(reqJson, "feeCoefficient", "请求报文中未包含feeCoefficient节点");
// 验证数字类型参数格式
Assert.isInteger(reqJson.getString("section"), "房间数不是有效数字");
Assert.isMoney(reqJson.getString("builtUpArea"), "建筑面积数据格式错误");
Assert.isMoney(reqJson.getString("feeCoefficient"), "房屋单价数据格式错误");
// 设置默认值
if (!reqJson.containsKey("roomSubType")) {
reqJson.put("roomSubType", RoomDto.ROOM_SUB_TYPE_PERSON);
}
if (!reqJson.containsKey("roomRent")) {
reqJson.put("roomRent", "0");
}
if (!reqJson.containsKey("roomArea")) {
reqJson.put("roomRent", reqJson.getString("builtUpArea"));
}
// 验证房屋状态和业主信息
if (!RoomDto.STATE_FREE.equals(reqJson.getString("state"))) {
Assert.hasKeyAndValue(reqJson, "ownerId", "未包含业主信息");
}
/*if (!"1010".equals(reqJson.getString("apartment")) && !"2020".equals(reqJson.getString("apartment"))) {
throw new IllegalArgumentException("不是有效房屋户型 传入数据错误");
}*/
// 验证房屋状态值是否有效
if (!"2001".equals(reqJson.getString("state"))
&& !"2002".equals(reqJson.getString("state"))
&& !"2003".equals(reqJson.getString("state"))
&& !"2004".equals(reqJson.getString("state"))
&& !"2005".equals(reqJson.getString("state"))
&& !"2009".equals(reqJson.getString("state"))) {
throw new IllegalArgumentException("不是有效房屋状态 传入数据错误");
}
// 验证单元ID是否属于该小区
UnitDto unitDto = new UnitDto();
unitDto.setCommunityId(reqJson.getString("communityId"));
unitDto.setUnitId(reqJson.getString("unitId"));
// 校验小区楼ID和小区是否有对应关系
List<UnitDto> units = unitInnerServiceSMOImpl.queryUnitsByCommunityId(unitDto);
if (units == null || units.size() < 1) {
throw new IllegalArgumentException("传入单元ID不是该小区的单元");
}
// 将单元编号添加到请求参数中
reqJson.put("unitNum", units.get(0).getUnitNum());
}
/**
* 执行命令方法 - 处理房屋添加的核心业务逻辑
* 包括房屋信息保存、业主房屋关系绑定、房屋属性处理等
*
* @param event 命令事件对象
* @param context 数据流上下文
* @param reqJson 请求参数的JSON对象
* @throws CmdException 当业务处理失败时抛出异常
*/
@Override
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
// 根据单元编号确定房屋类型（商铺或普通房屋）
if ("0".equals(reqJson.getString("unitNum"))) { // 处理为商铺
reqJson.put("roomType", RoomDto.ROOM_TYPE_SHOPS);
} else {
reqJson.put("roomType", RoomDto.ROOM_TYPE_ROOM);
}
// 生成房屋ID并设置创建用户
reqJson.put("roomId", GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_roomId));
reqJson.put("userId", context.getReqHeaders().get(CommonConstant.HTTP_USER_ID));
// 保存房屋基本信息
RoomPo roomPo = BeanConvertUtil.covertBean(reqJson, RoomPo.class);
roomV1InnerServiceSMOImpl.saveRoom(roomPo);
// 如果房屋状态为空闲状态，则不进行业主绑定
if (RoomDto.STATE_FREE.equals(roomPo.getState())) {
return;
}
// 设置业主房屋关系的起止时间
if (!reqJson.containsKey("startTime")) {
reqJson.put("startTime", DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
}
if (!reqJson.containsKey("endTime")) {
reqJson.put("endTime", "2037-01-01 00:00:00");
}
// 创建并保存业主房屋关系
OwnerRoomRelPo ownerRoomRelPo = new OwnerRoomRelPo();
ownerRoomRelPo.setRelId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_relId));
ownerRoomRelPo.setRoomId(roomPo.getRoomId());
ownerRoomRelPo.setOwnerId(reqJson.getString("ownerId"));
ownerRoomRelPo.setStartTime(reqJson.getString("startTime"));
ownerRoomRelPo.setEndTime(reqJson.getString("endTime"));
ownerRoomRelPo.setState("2001"); // 有效状态
ownerRoomRelPo.setRemark("添加房屋直接绑定");
ownerRoomRelPo.setOperate("ADD");
ownerRoomRelPo.setUserId("-1"); // 系统用户
int flag = ownerRoomRelV1InnerServiceSMOImpl.saveOwnerRoomRel(ownerRoomRelPo);
if (flag < 1) {
throw new CmdException("添加业主房屋关系");
}
// 处理房屋属性信息
JSONArray attrs = reqJson.getJSONArray("attrs");
if (attrs == null || attrs.size() < 1) {
return;
}
JSONObject attr = null;
int count = 0;
// 遍历所有房屋属性
for (int attrIndex = 0; attrIndex < attrs.size(); attrIndex++) {
attr = attrs.getJSONObject(attrIndex);
attr.put("roomId", reqJson.getString("roomId"));
// 判断是新增属性还是更新属性
if (!attr.containsKey("attrId") || attr.getString("attrId").startsWith("-") || StringUtil.isEmpty(attr.getString("attrId"))) {
// 新增房屋属性
RoomAttrPo roomAttrPo = new RoomAttrPo();
roomAttrPo.setAttrId(GenerateCodeFactory.getAttrId());
roomAttrPo.setRoomId(attr.getString("roomId"));
roomAttrPo.setSpecCd(attr.getString("specCd"));
roomAttrPo.setValue(attr.getString("value"));
count = roomAttrV1InnerServiceSMOImpl.saveRoomAttr(roomAttrPo);
if (count < 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"));
count = roomAttrV1InnerServiceSMOImpl.updateRoomAttr(roomAttrPo);
if (count < 1) {
throw new CmdException("保存单元失败");
}
}
}
}