QueryParkingSpacesCmd.java
7.96 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
/**
* 停车位查询命令类
*
* 该类负责处理停车位查询相关的业务逻辑，支持按条件分页查询停车位信息，
* 同时支持根据车牌号查询对应的停车位信息
*
* @author Java110
* @version 1.0
* @since 2023
*/
package com.java110.community.cmd.parkingSpace;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
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.OwnerCarDto;
import com.java110.dto.parking.ParkingSpaceDto;
import com.java110.intf.community.IParkingSpaceInnerServiceSMO;
import com.java110.intf.user.IOwnerCarInnerServiceSMO;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.utils.util.StringUtil;
import com.java110.vo.api.ApiParkingSpaceDataVo;
import com.java110.vo.api.ApiParkingSpaceVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import java.util.ArrayList;
import java.util.List;
@Java110Cmd(serviceCode = "parkingSpace.queryParkingSpaces")
public class QueryParkingSpacesCmd extends Cmd {
@Autowired
private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl;
@Autowired
private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl;
/**
* 请求参数验证方法
*
* 验证请求中是否包含必要的参数，包括分页参数和社区ID
*
* @param event 命令事件对象
* @param cmdDataFlowContext 命令数据流上下文
* @param reqJson 请求的JSON数据对象
* @throws CmdException 当参数验证失败时抛出异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
// 验证请求中必须包含page参数
Assert.jsonObjectHaveKey(reqJson, "page", "请求中未包含page信息");
// 验证请求中必须包含row参数
Assert.jsonObjectHaveKey(reqJson, "row", "请求中未包含row信息");
// 验证请求中必须包含communityId参数
Assert.jsonObjectHaveKey(reqJson, "communityId", "请求中未包含communityId信息");
// 验证page参数是否为有效数字
Assert.isInteger(reqJson.getString("page"), "不是有效数字");
// 验证row参数是否为有效数字
Assert.isInteger(reqJson.getString("row"), "不是有效数字");
}
/**
* 执行停车位查询命令
*
* 根据请求参数查询停车位信息，支持按车牌号查询和普通条件查询两种方式
*
* @param event 命令事件对象
* @param cmdDataFlowContext 命令数据流上下文
* @param reqJson 请求的JSON数据对象
* @throws CmdException 当命令执行过程中发生错误时抛出异常
*/
@Override
public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
// 如果请求中包含车牌号且不为空，则按车牌号查询停车位
if (reqJson.containsKey("carNum") && !StringUtil.isEmpty(reqJson.getString("carNum"))) {
queryParkingSpaceByCarNum(reqJson, cmdDataFlowContext);
return;
}
// 获取每页显示条数
int row = reqJson.getInteger("row");
// 创建返回VO对象
ApiParkingSpaceVo apiParkingSpaceVo = new ApiParkingSpaceVo();
// 将请求参数转换为停车位DTO对象
ParkingSpaceDto parkingSpaceDto = BeanConvertUtil.covertBean(reqJson, ParkingSpaceDto.class);
// 查询总记录数
int total = parkingSpaceInnerServiceSMOImpl.queryParkingSpacesCount(parkingSpaceDto);
apiParkingSpaceVo.setTotal(total);
// 如果存在记录，则查询详细数据
if (total > 0) {
List<ParkingSpaceDto> parkingSpaceDtoList = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(BeanConvertUtil.covertBean(reqJson, ParkingSpaceDto.class));
// 将DTO列表转换为VO列表
apiParkingSpaceVo.setParkingSpaces(BeanConvertUtil.covertBeanList(parkingSpaceDtoList, ApiParkingSpaceDataVo.class));
}
// 计算总页数
apiParkingSpaceVo.setRecords((int) Math.ceil((double) total / (double) row));
// 构建响应实体并设置到上下文
ResponseEntity<String> responseEntity = new ResponseEntity<String>(JSONObject.toJSONString(apiParkingSpaceVo), HttpStatus.OK);
cmdDataFlowContext.setResponseEntity(responseEntity);
}
/**
* 根据车牌号查询停车位信息
*
* 通过车牌号查询对应的业主车辆信息，再根据车辆关联的停车位ID查询停车位详情
*
* @param reqJson 请求报文数据对象
* @param cmdDataFlowContext 命令数据流上下文对象
*/
private void queryParkingSpaceByCarNum(JSONObject reqJson, ICmdDataFlowContext cmdDataFlowContext) {
ApiParkingSpaceVo apiParkingSpaceVo = new ApiParkingSpaceVo();
// 获取每页显示条数
int row = reqJson.getInteger("row");
// 将请求参数转换为业主车辆DTO对象
OwnerCarDto ownerCarDto = BeanConvertUtil.covertBean(reqJson, OwnerCarDto.class);
// 根据车牌号查询业主车辆信息
List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
// 设置总记录数
apiParkingSpaceVo.setTotal(ownerCarDtos.size());
// 如果查询到车辆信息，则查询对应的停车位信息
if (ownerCarDtos.size() > 0) {
ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();
// 获取所有停车位ID
parkingSpaceDto.setPsIds(getPsIds(ownerCarDtos));
// 根据停车位ID列表查询停车位详情
List<ParkingSpaceDto> parkingSpaceDtoList = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
// 将停车位DTO列表转换为VO列表
apiParkingSpaceVo.setParkingSpaces(BeanConvertUtil.covertBeanList(parkingSpaceDtoList, ApiParkingSpaceDataVo.class));
}
// 计算总页数
apiParkingSpaceVo.setRecords((int) Math.ceil((double) ownerCarDtos.size() / (double) row));
// 构建响应实体并设置到上下文
ResponseEntity<String> responseEntity = new ResponseEntity<String>(JSONObject.toJSONString(apiParkingSpaceVo), HttpStatus.OK);
cmdDataFlowContext.setResponseEntity(responseEntity);
}
/**
* 从业主车辆信息中提取停车位ID数组
*
* 遍历业主车辆列表，收集所有关联的停车位ID
*
* @param ownerCarDtos 业主车辆信息列表
* @return 停车位ID数组
*/
private String[] getPsIds(List<OwnerCarDto> ownerCarDtos) {
List<String> psIds = new ArrayList<String>();
// 遍历业主车辆列表，提取停车位ID
for (OwnerCarDto ownerCarDto : ownerCarDtos) {
psIds.add(ownerCarDto.getPsId());
}
// 将List转换为数组返回
return psIds.toArray(new String[psIds.size()]);
}
/**
* 请求数据处理方法
*
* 对请求参数进行预处理，主要处理状态参数的转换
*
* @param reqJson 请求数据对象
*/
private void refreshReqJson(JSONObject reqJson) {
// 如果请求中不包含state参数，直接返回
if (!reqJson.containsKey("state")) {
return;
}
// 如果state参数值为"SH"，则转换为包含"S"和"H"的数组
if ("SH".equals(reqJson.getString("state"))) {
reqJson.put("states", new String[]{"S", "H"});
// 移除原始的state参数
reqJson.remove("state");
}
}
}