DeleteOwnerMemberCmd.java
8.63 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
/**
* 删除业主成员命令类
*
* 该命令类用于处理第三方系统（如招商系统）删除业主成员信息的请求。
* 主要功能包括验证请求参数的有效性，删除业主成员信息以及相关的APP用户关联信息。
* 使用事务保证数据操作的一致性。
*
* @author 吴学文
* @version 1.0
* @since 2023
*/
package com.java110.user.cmd.owner;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.annotation.Java110Transactional;
import com.java110.core.context.CmdContextUtils;
import com.java110.core.context.Environment;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.doc.annotation.*;
import com.java110.dto.owner.OwnerAppUserDto;
import com.java110.dto.owner.OwnerCarDto;
import com.java110.dto.owner.OwnerDto;
import com.java110.dto.room.RoomDto;
import com.java110.intf.community.IRoomInnerServiceSMO;
import com.java110.intf.user.*;
import com.java110.po.owner.OwnerAppUserPo;
import com.java110.po.owner.OwnerPo;
import com.java110.user.cmd.question.ListUserQuestionAnswerCmd;
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 java.util.List;
@Java110CmdDoc(title = "删除业主成员",
description = "第三方系统，比如招商系统删除业主信息",
httpMethod = "post",
url = "http://{ip}:{port}/app/owner.deleteOwnerMember",
resource = "userDoc",
author = "吴学文",
serviceCode = "owner.deleteOwnerMember",
seq = 11
)
@Java110ParamsDoc(params = {
@Java110ParamDoc(name = "communityId", length = 30, remark = "项目ID"),
@Java110ParamDoc(name = "memberId", length = 30, remark = "业主ID"),
})
@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\"memberId\": 123123123,\n" +
"\t\"communityId\": \"2022121921870161\"\n" +
"}",
resBody = "{\"code\":0,\"msg\":\"成功\"}"
)
@Java110Cmd(serviceCode = "owner.deleteOwnerMember")
public class DeleteOwnerMemberCmd extends Cmd {
@Autowired
private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl; // 业主信息服务接口
@Autowired
private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl; // 业主V1版本服务接口
@Autowired
private IRoomInnerServiceSMO roomInnerServiceSMOImpl; // 房间信息服务接口
@Autowired
private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMOImpl; // 业主车辆信息服务接口
@Autowired
private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMOImpl; // 业主APP用户信息服务接口
@Autowired
private IOwnerAppUserV1InnerServiceSMO ownerAppUserV1InnerServiceSMOImpl; // 业主APP用户V1版本服务接口
@Autowired
private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl; // 用户V1版本服务接口
/**
* 验证请求参数的有效性
*
* 该方法用于验证删除业主成员请求的合法性，包括：
* 1. 检查当前环境是否为开发环境
* 2. 验证当前用户权限
* 3. 检查请求参数是否完整
* 4. 验证业主成员是否存在
*
* @param event 命令事件对象，包含请求相关信息
* @param cmdDataFlowContext 命令数据流上下文，用于获取请求上下文信息
* @param reqJson 请求的JSON数据对象
* @throws CmdException 当验证失败时抛出异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
// 检查当前环境是否为开发环境
Environment.isDevEnv();
// 从上下文中获取当前用户ID
String userId = CmdContextUtils.getUserId(cmdDataFlowContext);
// 构建业主APP用户查询条件
OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
ownerAppUserDto.setUserId(userId);
ownerAppUserDto.setCommunityId(reqJson.getString("communityId"));
// 查询当前用户的业主APP用户信息
List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserV1InnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
// 验证业主APP用户是否存在
if (ListUtil.isNull(ownerAppUserDtos)) {
throw new CmdException("业主不存在");
}
// 验证业主成员ID是否为空
if (StringUtil.isEmpty(ownerAppUserDtos.get(0).getMemberId())) {
throw new CmdException("业主不存在");
}
// 验证请求参数中是否包含必要的字段
Assert.jsonObjectHaveKey(reqJson, "memberId", "请求报文中未包含memberId");
Assert.jsonObjectHaveKey(reqJson, "communityId", "请求报文中未包含communityId");
// 构建业主成员查询条件
OwnerDto ownerDto = new OwnerDto();
ownerDto.setMemberId(reqJson.getString("memberId")); // 设置要删除的成员ID
ownerDto.setCommunityId(reqJson.getString("communityId")); // 设置项目ID
ownerDto.setOwnerId(ownerAppUserDtos.get(0).getMemberId()); // 设置业主ID
ownerDto.setOwnerTypeCds(new String[]{OwnerDto.OWNER_TYPE_CD_MEMBER}); // 设置业主类型为成员
// 查询业主成员信息
List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwnerMembers(ownerDto);
// 验证业主成员是否存在且唯一
Assert.listOnlyOne(ownerDtos, "业主成员不存在");
}
/**
* 执行删除业主成员操作
*
* 该方法用于实际执行删除业主成员的操作，包括：
* 1. 删除业主成员信息
* 2. 删除相关的APP用户关联信息
* 3. 使用事务保证数据一致性
*
* @param event 命令事件对象，包含请求相关信息
* @param cmdDataFlowContext 命令数据流上下文，用于获取请求上下文信息
* @param reqJson 请求的JSON数据对象
* @throws CmdException 当删除操作失败时抛出异常
*/
@Override
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
// 构建业主删除业务对象
JSONObject businessOwner = new JSONObject();
businessOwner.put("memberId", reqJson.getString("memberId"));
businessOwner.put("communityId", reqJson.getString("communityId"));
// 将JSON对象转换为PO对象
OwnerPo ownerPo = BeanConvertUtil.covertBean(businessOwner, OwnerPo.class);
// 执行删除业主操作
int flag = ownerV1InnerServiceSMOImpl.deleteOwner(ownerPo);
// 检查删除操作是否成功
if (flag < 1) {
throw new CmdException("删除失败");
}
// 构建业主APP用户查询条件
OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
ownerAppUserDto.setMemberId(reqJson.getString("memberId"));
ownerAppUserDto.setCommunityId(reqJson.getString("communityId"));
// 查询关联的APP用户信息
List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
// 如果没有关联的APP用户，直接返回
if (ownerAppUserDtos == null && ownerAppUserDtos.size() < 1) {
return;
}
// 遍历所有关联的APP用户，逐个删除
for (OwnerAppUserDto ownerAppUser : ownerAppUserDtos) {
// 将DTO对象转换为PO对象
OwnerAppUserPo ownerAppUserPo = BeanConvertUtil.covertBean(ownerAppUser, OwnerAppUserPo.class);
// 执行删除APP用户操作
flag = ownerAppUserV1InnerServiceSMOImpl.deleteOwnerAppUser(ownerAppUserPo);
// 检查删除操作是否成功
if (flag < 1) {
throw new CmdException("删除失败");
}
// TODO: 应该删除用户，但目前注释掉了相关代码
// UserPo userPo = new UserPo();
// userPo.setUserId(ownerAppUser.getUserId());
// userV1InnerServiceSMOImpl.deleteUser(userPo);
}
}
}