EditOwnerCmd.java
13.8 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
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
/**
* 业主信息编辑命令类
*
* 该类负责处理业主信息的修改操作，包括业主基本信息、账户信息、属性信息和绑定用户信息的更新。
* 主要用于第三方系统（如招商系统）同步业主信息到本系统。
*
* @author 吴学文
* @version 1.0
* @see Cmd
*/
package com.java110.user.cmd.owner;
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.account.AccountDto;
import com.java110.dto.file.FileDto;
import com.java110.dto.file.FileRelDto;
import com.java110.dto.owner.OwnerAppUserDto;
import com.java110.dto.owner.OwnerDto;
import com.java110.intf.acct.IAccountInnerServiceSMO;
import com.java110.intf.common.IFileInnerServiceSMO;
import com.java110.intf.common.IFileRelInnerServiceSMO;
import com.java110.intf.user.*;
import com.java110.po.account.AccountPo;
import com.java110.po.file.FileRelPo;
import com.java110.po.owner.OwnerAppUserPo;
import com.java110.po.owner.OwnerAttrPo;
import com.java110.po.owner.OwnerPo;
import com.java110.po.user.UserPo;
import com.java110.utils.cache.MappingCache;
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.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
@Java110CmdDoc(title = "修改业主",
description = "第三方系统，比如招商系统同步业主信息",
httpMethod = "post",
url = "http://{ip}:{port}/app/owner.editOwner",
resource = "userDoc",
author = "吴学文",
serviceCode = "owner.editOwner",
seq = 10)
@Java110ParamsDoc(params = {
@Java110ParamDoc(name = "communityId", length = 30, remark = "小区ID"),
@Java110ParamDoc(name = "name", length = 64, remark = "业主名称"),
@Java110ParamDoc(name = "link", length = 11, remark = "业主手机号"),
@Java110ParamDoc(name = "idCard", length = 30, remark = "业主身份证号"),
@Java110ParamDoc(name = "address", length = 512, remark = "地址"),
@Java110ParamDoc(name = "sex", length = 12, remark = "性别 男 1 女 0"),
@Java110ParamDoc(name = "ownerTypeCd", length = 12, remark = "业主类型 1001 业主 2002 家庭成员 家庭成员 需要传业主的ownerId"),
@Java110ParamDoc(name = "remark", length = 512, remark = "备注"),
@Java110ParamDoc(name = "memberId", length = 30, remark = "业主ID"),
@Java110ParamDoc(name = "ownerPhoto", length = -1, 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\"name\": \"王王\",\n" +
"\t\"age\": \"\",\n" +
"\t\"link\": \"18909718888\",\n" +
"\t\"address\": \"张三\",\n" +
"\t\"sex\": \"0\",\n" +
"\t\"ownerTypeCd\": \"1001\",\n" +
"\t\"remark\": \"\",\n" +
"\t\"memberId\": 123123123,\n" +
"\t\"ownerPhoto\": \"\",\n" +
"\t\"idCard\": \"\",\n" +
"\t\"communityId\": \"2022121921870161\"\n" +
"}",
resBody = "{\"code\":0,\"msg\":\"成功\"}"
)
@Java110Cmd(serviceCode = "owner.editOwner")
public class EditOwnerCmd extends Cmd {
@Autowired
private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl;
@Autowired
private IOwnerAttrInnerServiceSMO ownerAttrInnerServiceSMOImpl;
@Autowired
private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
@Autowired
private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMOImpl;
@Autowired
private IOwnerAppUserV1InnerServiceSMO ownerAppUserV1InnerServiceSMOImpl;
@Autowired
private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl;
@Autowired
private IFileInnerServiceSMO fileInnerServiceSMOImpl;
@Autowired
private IAccountInnerServiceSMO accountInnerServiceSMOImpl;
@Autowired
private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;
/**
* 请求参数验证方法
*
* 验证请求参数的有效性，包括必填字段检查、手机号重复性检查、身份证号处理等
*
* @param event 命令事件对象
* @param cmdDataFlowContext 命令数据流上下文
* @param reqJson 请求JSON对象
* @throws CmdException 当参数验证失败时抛出异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
// 验证必填字段是否存在
Assert.jsonObjectHaveKey(reqJson, "memberId", "请求报文中未包含ownerId");
Assert.jsonObjectHaveKey(reqJson, "name", "请求报文中未包含name");
Assert.jsonObjectHaveKey(reqJson, "link", "请求报文中未包含link");
Assert.jsonObjectHaveKey(reqJson, "communityId", "请求报文中未包含communityId");
Assert.judgeAttrValue(reqJson);
// 处理手机号中的掩码字符（*），如果有掩码则清空手机号
String link = reqJson.getString("link");
if (!StringUtil.isEmpty(link) && link.contains("*")) {
reqJson.put("link", "");
}
// 处理身份证号中的掩码字符（*），如果有掩码则清空身份证号
String idCard = reqJson.getString("idCard");
if (!StringUtil.isEmpty(idCard) && idCard.contains("*")) {
reqJson.put("idCard", "");
}
// 处理业主照片URL，检查长度并设置人脸URL
if (reqJson.containsKey("ownerPhotoUrl")) {
String ownerPhotoUrl = reqJson.getString("ownerPhotoUrl");
if (!StringUtil.isEmpty(ownerPhotoUrl) && ownerPhotoUrl.length() > 500) {
throw new CmdException("图片地址太长");
}
if (!StringUtil.isEmpty(ownerPhotoUrl)) {
reqJson.put("faceUrl", ownerPhotoUrl);
}
}
// 检查用户验证配置，如果未开启验证则直接返回
String userValidate = MappingCache.getValue("USER_VALIDATE");
if (!"ON".equals(userValidate)) {
return;
}
// 根据业主ID查询当前业主信息，确保存在且唯一
OwnerDto curOwner = new OwnerDto();
curOwner.setMemberId(reqJson.getString("memberId"));
List<OwnerDto> curOwners = ownerInnerServiceSMOImpl.queryOwners(curOwner);
Assert.listOnlyOne(curOwners, "未查询到业主信息或查询到多条");
// 检查手机号是否重复
OwnerDto ownerDto = new OwnerDto();
ownerDto.setLink(link);
ownerDto.setCommunityId(reqJson.getString("communityId"));
List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryAllOwners(ownerDto);
if (ownerDtos != null && ownerDtos.size() > 1) {
throw new IllegalArgumentException("手机号重复，请重新输入");
} else if (ownerDtos != null && ownerDtos.size() == 1) {
for (OwnerDto owner : ownerDtos) {
// 如果手机号已被其他业主使用，则抛出异常
if (!reqJson.getString("memberId").equals(owner.getMemberId())) {
throw new IllegalArgumentException("手机号重复，请重新输入");
}
}
}
}
/**
* 执行业主信息编辑命令
*
* 主要功能包括：
* 1. 更新业主基本信息
* 2. 更新业主账户信息
* 3. 处理业主属性信息（新增或修改）
* 4. 更新业主绑定的APP用户信息
*
* @param event 命令事件对象
* @param cmdDataFlowContext 命令数据流上下文
* @param reqJson 请求JSON对象
* @throws CmdException 当操作失败时抛出异常
*/
@Override
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
// 更新业主基本信息
OwnerPo ownerPo = BeanConvertUtil.covertBean(reqJson, OwnerPo.class);
int flag = ownerV1InnerServiceSMOImpl.updateOwner(ownerPo);
if (flag < 1) {
throw new CmdException("修改业主失败");
}
// 更新业主账户信息
updateAccount(reqJson);
// 处理业主属性信息
JSONArray attrs = reqJson.getJSONArray("attrs");
if (ListUtil.isNull(attrs)) {
return;
}
JSONObject attr = null;
for (int attrIndex = 0; attrIndex < attrs.size(); attrIndex++) {
attr = attrs.getJSONObject(attrIndex);
// 设置属性关联的业主ID和小区ID
attr.put("memberId", reqJson.getString("memberId"));
attr.put("communityId", reqJson.getString("communityId"));
// 判断属性ID是否存在，如果不存在则生成新的属性ID并新增属性
if (!attr.containsKey("attrId") || StringUtil.isEmpty(attr.getString("attrId")) || attr.getString("attrId").startsWith("-")) {
attr.put("attrId", GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_attrId));
OwnerAttrPo ownerAttrPo = BeanConvertUtil.covertBean(attr, OwnerAttrPo.class);
flag = ownerAttrInnerServiceSMOImpl.saveOwnerAttr(ownerAttrPo);
if (flag < 1) {
throw new CmdException("添加业主属性失败");
}
continue;
}
// 更新已存在的属性信息
OwnerAttrPo ownerAttrPo = BeanConvertUtil.covertBean(attr, OwnerAttrPo.class);
flag = ownerAttrInnerServiceSMOImpl.updateOwnerAttrInfoInstance(ownerAttrPo);
if (flag < 1) {
throw new CmdException("修改业主属性失败");
}
}
// 更新业主绑定的APP用户信息
updateOwnerAppUser(reqJson);
}
/**
* 更新业主账户信息
*
* 检查业主手机号和账户手机号是否一致，如果不一致则更新账户信息
*
* @param paramInJson 请求参数JSON对象
*/
public void updateAccount(JSONObject paramInJson) {
// 查询业主对应的账户信息
AccountDto accountDto = new AccountDto();
accountDto.setObjId(paramInJson.getString("memberId"));
accountDto.setPartId(paramInJson.getString("communityId"));
List<AccountDto> accountDtos = accountInnerServiceSMOImpl.queryAccounts(accountDto);
// 如果没有账户信息则直接返回
if (ListUtil.isNull(accountDtos)) {
return;
}
// 查询更新后的业主信息
OwnerDto owner = new OwnerDto();
owner.setMemberId(paramInJson.getString("memberId"));
List<OwnerDto> owners = ownerInnerServiceSMOImpl.queryOwnerMembers(owner);
Assert.listOnlyOne(owners, "未查询到业主信息或查询到多条");
// 如果账户的手机号或姓名与业主信息不一致，则更新账户信息
if (!accountDtos.get(0).getLink().equals(owners.get(0).getLink()) || !accountDtos.get(0).getAcctName().equals(owners.get(0).getName())) {
AccountPo accountPo = new AccountPo();
accountPo.setAcctName(owners.get(0).getName());
accountPo.setoLink(owners.get(0).getLink());
accountPo.setAcctId(accountDtos.get(0).getAcctId());
accountInnerServiceSMOImpl.updateAccount(accountPo);
}
}
/**
* 更新业主绑定的APP用户信息
*
* 如果业主绑定了APP用户，则更新绑定用户的手机号信息
*
* @param reqJson 请求JSON对象
*/
private void updateOwnerAppUser(JSONObject reqJson) {
// 查询业主绑定的APP用户信息
OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
ownerAppUserDto.setMemberId(reqJson.getString("memberId"));
List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
// 如果没有绑定信息则直接返回
if (ListUtil.isNull(ownerAppUserDtos)) {
return;
}
// 遍历所有绑定的APP用户，更新手机号信息
for (OwnerAppUserDto ownerAppUser : ownerAppUserDtos) {
OwnerAppUserPo ownerAppUserPo = BeanConvertUtil.covertBean(ownerAppUser, OwnerAppUserPo.class);
ownerAppUserPo.setLink(reqJson.getString("link"));
ownerAppUserV1InnerServiceSMOImpl.updateOwnerAppUser(ownerAppUserPo);
// 如果用户ID为空或为临时ID，则跳过用户信息更新
if (StringUtil.isEmpty(ownerAppUser.getUserId())) {
continue;
}
if (ownerAppUser.getUserId().startsWith("-")) {
continue;
}
// 更新用户基本信息中的手机号
UserPo userPo = new UserPo();
userPo.setUserId(ownerAppUserDtos.get(0).getUserId());
userPo.setTel(reqJson.getString("link"));
userV1InnerServiceSMOImpl.updateUser(userPo);
}
}
}