QueryAppOwnerCarsCmd.java
6.08 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
package com.java110.user.cmd.owner;
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.OwnerAppUserDto;
import com.java110.dto.owner.OwnerCarDto;
import com.java110.dto.owner.OwnerDto;
import com.java110.intf.user.IOwnerAppUserInnerServiceSMO;
import com.java110.intf.user.IOwnerCarInnerServiceSMO;
import com.java110.intf.user.IOwnerV1InnerServiceSMO;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
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.ResponseEntity;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.List;
/**
* 查询业主车辆命令类
* 该命令用于处理移动端查询业主车辆信息的请求，包括验证用户权限和查询车辆数据
*
* @author Java110
* @version 1.0
* @serviceCode owner.queryAppOwnerCars
*/
@Java110Cmd(serviceCode = "owner.queryAppOwnerCars")
public class QueryAppOwnerCarsCmd extends Cmd {
/**
* 业主应用用户内部服务接口
* 用于查询业主与用户的绑定关系
*/
@Autowired
private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMOImpl;
/**
* 业主V1内部服务接口
* 用于查询业主基本信息
*/
@Autowired
private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
/**
* 业主车辆内部服务接口
* 用于查询业主车辆信息
*/
@Autowired
private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl;
/**
* 验证请求参数和用户权限
* 该方法用于验证用户是否绑定业主身份，并获取业主ID用于后续查询
*
* @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.validatePageInfo(reqJson);
// 从请求头中获取用户ID
String userId = context.getReqHeaders().get("user-id");
// 构建业主应用用户查询条件
OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
ownerAppUserDto.setUserId(userId);
ownerAppUserDto.setCommunityId(reqJson.getString("communityId"));
ownerAppUserDto.setMemberId(reqJson.getString("memberId"));
// 查询用户与业主的绑定关系
List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
// 检查是否绑定业主，未绑定则抛出异常
if (ListUtil.isNull(ownerAppUserDtos)) {
throw new CmdException("未绑定业主");
}
String memberId = "";
// 遍历绑定关系，查找有效的成员ID
for (OwnerAppUserDto tmpOwnerAppUserDto : ownerAppUserDtos) {
// 跳过无效的成员ID（-1表示无效）
if ("-1".equals(tmpOwnerAppUserDto.getMemberId())) {
continue;
}
memberId = tmpOwnerAppUserDto.getMemberId();
}
// 检查是否找到有效的成员ID
if (StringUtil.isEmpty(memberId)) {
throw new CmdException("未绑定业主");
}
// 构建业主查询条件
OwnerDto ownerDto = new OwnerDto();
ownerDto.setCommunityId(reqJson.getString("communityId"));
ownerDto.setMemberId(memberId);
// 查询业主信息
List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
// 验证业主信息存在且唯一
Assert.listOnlyOne(ownerDtos, "业主不存在");
// 将业主ID设置到请求参数中，供后续查询使用
reqJson.put("ownerId", ownerDtos.get(0).getOwnerId());
}
/**
* 执行查询业主车辆命令
* 该方法根据验证后的参数查询业主车辆信息，并返回分页结果
*
* @param event 命令事件对象
* @param context 命令数据流上下文
* @param reqJson 包含验证后参数的JSON对象
* @throws CmdException 当命令执行失败时抛出命令异常
* @throws ParseException 当解析数据时发生错误抛出解析异常
*/
@Override
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
// 将请求参数转换为业主车辆查询对象
OwnerCarDto ownerCarDto = BeanConvertUtil.covertBean(reqJson, OwnerCarDto.class);
// 查询业主车辆总数
int total = ownerCarInnerServiceSMOImpl.queryOwnerCarsCount(ownerCarDto);
List<OwnerCarDto> ownerCarDtos = null;
// 根据查询结果数量决定是否查询详细数据
if (total > 0) {
// 查询业主车辆详细列表
ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
} else {
// 如果没有数据，返回空列表
ownerCarDtos = new ArrayList<>();
}
// 获取每页显示行数
int row = reqJson.getIntValue("row");
// 计算总页数并创建响应实体
// 使用Math.ceil确保向上取整，正确处理余数
ResponseEntity<String> responseEntity = ResultVo.createResponseEntity((int) Math.ceil((double) total / (double) row),
total, ownerCarDtos);
// 设置响应实体到上下文
context.setResponseEntity(responseEntity);
}
}