QueryAdminOwnerAccountCmd.java
8.01 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
package com.java110.acct.cmd.account;
import com.alibaba.fastjson.JSONObject;
import com.java110.acct.bmo.account.IGetAccountBMO;
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.core.smo.IOwnerGetDataCheck;
import com.java110.dto.account.AccountDto;
import com.java110.dto.contract.ContractDto;
import com.java110.dto.fee.FeeDto;
import com.java110.dto.owner.OwnerCarDto;
import com.java110.dto.owner.OwnerDto;
import com.java110.dto.owner.OwnerRoomRelDto;
import com.java110.intf.fee.IFeeInnerServiceSMO;
import com.java110.intf.store.IContractInnerServiceSMO;
import com.java110.intf.user.IOwnerCarInnerServiceSMO;
import com.java110.intf.user.IOwnerRoomRelInnerServiceSMO;
import com.java110.intf.user.IStaffCommunityV1InnerServiceSMO;
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 org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import java.text.ParseException;
import java.util.List;
/**
* 查询账户命令类
* 用于处理管理员查询业主账户信息的请求，支持通过业主ID、费用ID等多种方式查询账户信息
* 该类继承自Cmd基类，实现了命令模式的验证和执行逻辑
*/
@Java110Cmd(serviceCode = "account.queryAdminOwnerAccount")
public class QueryAdminOwnerAccountCmd extends Cmd {
@Autowired
private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
@Autowired
private IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMOImpl;
@Autowired
private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl;
@Autowired
private IContractInnerServiceSMO contractInnerServiceSMOImpl;
@Autowired
private IOwnerGetDataCheck ownerGetDataCheckImpl;
@Autowired
private IGetAccountBMO getAccountBMOImpl;
@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.validatePageInfo(reqJson);
// 验证管理员权限
super.validateAdmin(context);
}
/**
* 执行查询账户命令
* 根据请求参数构建查询条件，调用BMO层查询业主账户信息
*
* @param event 命令事件对象
* @param context 命令数据流上下文
* @param reqJson 请求的JSON数据
* @throws CmdException 命令异常
* @throws ParseException 解析异常
*/
@Override
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
// 将请求JSON转换为AccountDto对象
AccountDto accountDto = BeanConvertUtil.covertBean(reqJson, AccountDto.class);
// 获取当前用户ID
String staffId = CmdContextUtils.getUserId(context);
// 查询用户管理的社区ID列表
List<String> communityIds = staffCommunityV1InnerServiceSMOImpl.queryStaffCommunityIds(staffId);
// 如果用户有管理的社区，设置到查询条件中
if (!ListUtil.isNull(communityIds)) {
accountDto.setCommunityIds(communityIds.toArray(new String[communityIds.size()]));
}
// 处理费用ID参数，获取对应的业主ID
hasFeeId(reqJson, accountDto);
// 处理直接传递的业主ID参数
String ownerId = reqJson.getString("ownerId");
if (!StringUtil.isEmpty(ownerId)) {
accountDto.setObjId(ownerId);
}
// 设置查询条件：对象类型为个人，分区ID为社区ID
accountDto.setObjType(AccountDto.OBJ_TYPE_PERSON);
accountDto.setPartId(reqJson.getString("communityId"));
// 处理账户类型参数
String acctTypes = reqJson.getString("acctTypes");
if (!StringUtil.isNullOrNone(acctTypes)) {
accountDto.setAcctTypes(acctTypes.split(","));
}
// TODO: 业主账户安全性校验（待实现）
// ownerGetDataCheckImpl.checkOwnerAccount(appId, userId, BeanConvertUtil.beanCovertJson(accountDto));
// 构建业主查询条件
OwnerDto ownerDto = new OwnerDto();
ownerDto.setOwnerId(accountDto.getObjId());
ownerDto.setCommunityId(reqJson.getString("communityId"));
ownerDto.setLink(reqJson.getString("link"));
ownerDto.setIdCard(reqJson.getString("idCard"));
// 调用BMO层查询业主账户信息
ResponseEntity<String> responseEntity = getAccountBMOImpl.queryOwnerAccount(accountDto, ownerDto);
context.setResponseEntity(responseEntity);
}
/**
* 判断参数中是否有feeId，并根据feeId获取对应的业主ID
* 支持房屋、车位、合同等多种付费对象类型
*
* @param reqJson 请求的JSON数据
* @param accountDto 账户数据传输对象
*/
private void hasFeeId(JSONObject reqJson, AccountDto accountDto) {
// 检查请求中是否包含feeId参数
if (!reqJson.containsKey("feeId")) {
return;
}
String feeId = reqJson.getString("feeId");
// 如果feeId为空，直接返回
if (StringUtil.isEmpty(feeId)) {
return;
}
String ownerId = "";
// 根据feeId查询费用信息
FeeDto feeDto = new FeeDto();
feeDto.setFeeId(feeId);
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
// 验证查询结果唯一性
Assert.listOnlyOne(feeDtos, "查询费用信息错误！");
// 获取付费对象类型和ID
String payerObjType = feeDtos.get(0).getPayerObjType(); // 3333 房屋 6666 是车位
String payerObjId = feeDtos.get(0).getPayerObjId();
// 根据不同的付费对象类型处理
if (FeeDto.PAYER_OBJ_TYPE_ROOM.equals(payerObjType)) {
// 房屋类型：查询房屋与业主的关系
OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
ownerRoomRelDto.setRoomId(payerObjId);
List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
if (ListUtil.isNull(ownerRoomRelDtos)) {
throw new CmdException("房屋未绑定业主关系");
}
ownerId = ownerRoomRelDtos.get(0).getOwnerId();
} else if (FeeDto.PAYER_OBJ_TYPE_CAR.equals(payerObjType)) {
// 车位类型：查询车位与业主的关系
OwnerCarDto ownerCarDto = new OwnerCarDto();
ownerCarDto.setCarId(payerObjId);
List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
ownerId = ownerCarDtos.get(0).getOwnerId();
} else if (FeeDto.PAYER_OBJ_TYPE_CONTRACT.equals(payerObjType)) {
// 合同类型：查询合同信息
ContractDto contractDto = new ContractDto();
contractDto.setContractId(payerObjId);
List<ContractDto> contractDtos = contractInnerServiceSMOImpl.queryContracts(contractDto);
ownerId = contractDtos.get(0).getObjId();
} else {
// 其他类型：设置默认值
ownerId = "-1";
}
// 将获取到的业主ID设置到账户DTO中
accountDto.setObjId(ownerId);
}
}