PhoneUrgeRepairCmd.java
7.83 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
package com.java110.community.cmd.repair;
import com.alibaba.fastjson.JSONObject;
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.factory.GenerateCodeFactory;
import com.java110.dto.data.DatabusDataDto;
import com.java110.dto.privilege.BasePrivilegeDto;
import com.java110.dto.repair.RepairDto;
import com.java110.dto.repair.RepairUserDto;
import com.java110.dto.repairEvent.RepairEventDto;
import com.java110.dto.user.UserDto;
import com.java110.intf.community.IRepairEventV1InnerServiceSMO;
import com.java110.intf.community.IRepairInnerServiceSMO;
import com.java110.intf.community.IRepairUserInnerServiceSMO;
import com.java110.intf.job.IDataBusInnerServiceSMO;
import com.java110.intf.order.IPrivilegeInnerServiceSMO;
import com.java110.intf.user.IUserV1InnerServiceSMO;
import com.java110.po.repairEvent.RepairEventPo;
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 org.springframework.beans.factory.annotation.Autowired;
import java.text.ParseException;
import java.util.List;
/**
* 用户催单命令处理类
* 负责处理用户对报修工单的催单操作，生成催单事件并通知相关人员
*
* @author Java110
* @version 1.0
* @since 2023
*/
@Java110Cmd(serviceCode = "repair.phoneUrgeRepair")
public class PhoneUrgeRepairCmd extends Cmd {
@Autowired
private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;
@Autowired
private IRepairInnerServiceSMO repairInnerServiceSMOImpl;
@Autowired
private IRepairEventV1InnerServiceSMO repairEventV1InnerServiceSMOImpl;
@Autowired
private IPrivilegeInnerServiceSMO privilegeInnerServiceSMOImpl;
@Autowired
private IRepairUserInnerServiceSMO repairUserInnerServiceSMOImpl;
@Autowired
private IDataBusInnerServiceSMO dataBusInnerServiceSMOImpl;
/**
* 参数校验方法
* 验证请求参数中是否包含必要的工单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 {
// 校验请求参数中必须包含工单ID
Assert.hasKeyAndValue(reqJson, "repairId", "未包含工单ID");
// 校验请求参数中必须包含小区ID
Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区信息");
}
/**
* 命令执行方法
* 处理用户催单请求，创建催单事件并发送数据总线通知
*
* @param event 命令事件对象
* @param context 命令数据流上下文
* @param reqJson 请求参数JSON对象
* @throws CmdException 命令异常
* @throws ParseException 解析异常
*/
@Override
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
// 从上下文中获取当前用户ID
String userId = CmdContextUtils.getUserId(context);
// 查询用户信息
UserDto userDto = new UserDto();
userDto.setUserId(userId);
List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
// 验证用户信息唯一性
Assert.listOnlyOne(userDtos, "用户未登录");
// 根据工单ID和用户电话查询报修工单
RepairDto repairDto = new RepairDto();
repairDto.setRepairId(reqJson.getString("repairId"));
repairDto.setTel(userDtos.get(0).getTel());
List<RepairDto> repairDtos = repairInnerServiceSMOImpl.queryRepairs(repairDto);
// 验证报修工单存在且唯一
Assert.listOnlyOne(repairDtos, "报修不存在");
// 创建催单事件对象
RepairEventPo repairEventPo = new RepairEventPo();
// 生成事件ID
repairEventPo.setEventId(GenerateCodeFactory.getGeneratorId("11"));
// 设置工单ID
repairEventPo.setRepairId(repairDtos.get(0).getRepairId());
// 设置催单备注信息
repairEventPo.setRemark("用户着急催单了，请尽快处理！");
// 设置事件类型为催单类型
repairEventPo.setEventType(RepairEventDto.EVENT_TYPE_URGE);
// 设置小区ID
repairEventPo.setCommunityId(repairDtos.get(0).getCommunityId());
// 查询并设置处理人员信息
queryStaff(repairEventPo, repairDtos.get(0));
// 保存催单事件到数据库
repairEventV1InnerServiceSMOImpl.saveRepairEvent(repairEventPo);
// 发送数据总线通知，通知相关人员有催单事件
dataBusInnerServiceSMOImpl.databusData(new DatabusDataDto(DatabusDataDto.BUSINESS_TYPE_REPAIR_URGE, BeanConvertUtil.beanCovertJson(repairEventPo)));
}
/**
* 查询处理人员信息
* 根据报修工单状态查询对应的处理人员（派单人员或维修师傅）
*
* @param repairEventPo 报修事件对象，用于设置处理人员信息
* @param repairDto 报修工单对象，包含工单状态等信息
*/
private void queryStaff(RepairEventPo repairEventPo, RepairDto repairDto) {
// 如果工单状态为待处理状态，查询派单人员
if (RepairDto.STATE_WAIT.equals(repairDto.getState())) {
BasePrivilegeDto basePrivilegeDto = new BasePrivilegeDto();
basePrivilegeDto.setResource("/wechatRepairRegistration");
basePrivilegeDto.setCommunityId(repairDto.getCommunityId());
// 查询具有报修登记权限的用户
List<UserDto> userDtos = privilegeInnerServiceSMOImpl.queryPrivilegeUsers(basePrivilegeDto);
// 如果没有找到有权限的用户，设置默认值
if (ListUtil.isNull(userDtos)) {
repairEventPo.setStaffId("-1");
repairEventPo.setStaffName("未找到派单人员");
return;
}
// 查询用户详细信息
UserDto userDto = new UserDto();
userDto.setUserId(userDtos.get(0).getUserId());
List<UserDto> tmpUserDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
// 如果用户详细信息不存在，设置默认值
if (ListUtil.isNull(tmpUserDtos)) {
repairEventPo.setStaffId("-1");
repairEventPo.setStaffName("未找到派单人员");
return;
}
// 设置派单人员信息
repairEventPo.setStaffId(tmpUserDtos.get(0).getUserId());
repairEventPo.setStaffName("派单人员-" + tmpUserDtos.get(0).getName());
return;
}
// 如果工单不是待处理状态，查询正在处理的维修师傅
RepairUserDto repairUserDto = new RepairUserDto();
repairUserDto.setRepairId(repairDto.getRepairId());
repairUserDto.setState(RepairUserDto.STATE_DOING);
List<RepairUserDto> repairUserDtos = repairUserInnerServiceSMOImpl.queryRepairUsers(repairUserDto);
// 如果没有找到正在处理的维修师傅，设置默认值
if(ListUtil.isNull(repairUserDtos)){
repairEventPo.setStaffId("-1");
repairEventPo.setStaffName("未找到报修师傅");
return;
}
// 设置维修师傅信息
repairEventPo.setStaffId(repairUserDtos.get(0).getStaffId());
repairEventPo.setStaffName(repairUserDtos.get(0).getStaffName());
}
}