QueryAdminRoomCmd.java
7.82 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
/**
* 管理员房屋查询命令类
*
* 该类负责处理管理员对房屋信息的查询请求，支持按业主信息、楼栋单元房屋编号等条件进行查询，
* 并返回包含统计信息的房屋数据列表。实现了Cmd接口，通过注解@Java110Cmd声明服务代码。
*
* @author Java110
* @version 1.0
* @see Cmd
*/
package com.java110.community.cmd.room;
import com.alibaba.fastjson.JSONObject;
import com.java110.community.bmo.room.IQueryRoomStatisticsBMO;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.context.CmdContextUtils;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.dto.owner.OwnerRoomRelDto;
import com.java110.dto.room.RoomDto;
import com.java110.intf.community.IRoomInnerServiceSMO;
import com.java110.intf.user.IOwnerRoomRelV1InnerServiceSMO;
import com.java110.intf.user.IStaffCommunityV1InnerServiceSMO;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.utils.util.ListUtil;
import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.List;
@Java110Cmd(serviceCode = "room.queryAdminRoom")
public class QueryAdminRoomCmd extends Cmd {
@Autowired
private IRoomInnerServiceSMO roomInnerServiceSMOImpl;
@Autowired
private IQueryRoomStatisticsBMO queryRoomStatisticsBMOImpl;
@Autowired
private IOwnerRoomRelV1InnerServiceSMO ownerRoomRelV1InnerServiceSMOImpl;
@Autowired
private IStaffCommunityV1InnerServiceSMO staffCommunityV1InnerServiceSMOImpl;
/**
* 请求参数验证方法
*
* 验证管理员权限和分页信息，确保请求的合法性
*
* @param event 命令事件对象，包含事件相关信息
* @param context 命令数据流上下文，包含请求和响应数据
* @param reqJson 请求参数的JSON对象
* @throws CmdException 当命令执行出现异常时抛出
* @throws ParseException 当参数解析出现异常时抛出
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
// 验证管理员权限
super.validateAdmin(context);
// 验证分页信息
super.validatePageInfo(reqJson);
}
/**
* 命令执行方法
*
* 处理房屋查询请求，根据条件查询房屋信息并返回结果
*
* @param event 命令事件对象
* @param context 命令数据流上下文
* @param reqJson 请求参数的JSON对象
* @throws CmdException 当命令执行出现异常时抛出
* @throws ParseException 当参数解析出现异常时抛出
*/
@Override
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
// 将请求参数转换为RoomDto对象
RoomDto roomDto = BeanConvertUtil.covertBean(reqJson, RoomDto.class);
// 根据业主信息计算房屋ID条件
computeOwnerRoomIds(reqJson, roomDto);
// 解析楼栋单元房屋编号条件
computeFloorUnitRoomNum(reqJson, roomDto);
// 获取当前用户ID
String staffId = CmdContextUtils.getUserId(context);
// 查询用户管理的社区ID列表
List<String> communityIds = staffCommunityV1InnerServiceSMOImpl.queryStaffCommunityIds(staffId);
// 如果用户有管理的社区，设置社区ID条件
if (!ListUtil.isNull(communityIds)) {
roomDto.setCommunityIds(communityIds.toArray(new String[communityIds.size()]));
}
// 查询符合条件的房屋总数
int count = roomInnerServiceSMOImpl.queryRoomsCount(roomDto);
List<RoomDto> roomDtos = null;
// 如果有符合条件的房屋，查询详细数据并添加统计信息
if (count > 0) {
roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto);
// 查询房屋统计数据并合并到结果中
roomDtos = queryRoomStatisticsBMOImpl.querySimple(roomDtos);
} else {
// 没有符合条件的房屋，返回空列表
roomDtos = new ArrayList<>();
}
// 构造返回结果对象，包含分页信息和数据
ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, roomDtos);
// 构造HTTP响应实体
ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
// 设置响应数据
context.setResponseEntity(responseEntity);
}
/**
* 根据业主信息计算房屋ID条件
*
* 根据业主姓名和电话查询关联的房屋ID，并设置到查询条件中
*
* @param reqJson 请求参数的JSON对象
* @param roomDto 房屋查询条件对象
*/
private void computeOwnerRoomIds(JSONObject reqJson, RoomDto roomDto) {
// 获取业主姓名和电话查询条件
String ownerNameLike = reqJson.getString("ownerNameLike");
String ownerTel = reqJson.getString("ownerTel");
// 如果业主姓名和电话都为空，则不进行业主关联查询
if (StringUtil.isEmpty(ownerNameLike) && StringUtil.isEmpty(ownerTel)) {
return;
}
// 构造业主房屋关联查询条件
OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
ownerRoomRelDto.setOwnerNameLike(reqJson.getString("ownerNameLike"));
ownerRoomRelDto.setLink(ownerTel);
// 查询业主房屋关联信息
List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelV1InnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
// 如果没有找到关联的房屋，设置roomId为-1确保查询无结果
if (ListUtil.isNull(ownerRoomRelDtos)) {
roomDto.setRoomId("-1");
return;
}
// 提取所有关联的房屋ID
List<String> roomIds = new ArrayList<>();
for (OwnerRoomRelDto tOwnerRoomRelDto : ownerRoomRelDtos) {
roomIds.add(tOwnerRoomRelDto.getRoomId());
}
// 设置房屋ID查询条件
roomDto.setRoomIds(roomIds.toArray(new String[roomIds.size()]));
}
/**
* 计算楼栋单元房屋编号
*
* 解析房间编号字符串，将其拆分为楼栋号、单元号和房间号
* 支持格式：楼栋号-单元号-房间号
*
* @param reqJson 请求参数的JSON对象
* @param roomDto 房屋查询条件对象
*/
private static void computeFloorUnitRoomNum(JSONObject reqJson, RoomDto roomDto) {
// 检查是否包含房间编号参数
if (!reqJson.containsKey("roomNum") || StringUtil.isEmpty(reqJson.getString("roomNum"))) {
// 如果没有房间编号参数，清空相关查询条件
roomDto.setUnitNum("");
roomDto.setFloorNum("");
roomDto.setRoomNum("");
return;
}
// 按"-"分割房间编号字符串
String[] roomNums = reqJson.getString("roomNum").split("-", 3);
// 如果分割后有三部分，分别设置为楼栋号、单元号、房间号
if (roomNums.length == 3) {
roomDto.setFloorNum(roomNums[0]);
roomDto.setUnitNum(roomNums[1]);
roomDto.setRoomNum(roomNums[2]);
return;
}
// 如果分割后不是三部分，直接设置为房间号
roomDto.setRoomNum(reqJson.getString("roomNum"));
}
}