QueryPhoneRepairsCmd.java
9.34 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
/**
* 手机端报修查询命令类
*
* 该类负责处理手机端报修查询请求，包括查询用户报修记录、计算报修评分、统计处理时长等功能
* 通过注解@Java110Cmd(serviceCode = "repair.queryPhoneRepairs")标识为命令处理器
*
* @author Java110
* @version 1.0
* @since 2023
*/
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.CommunitySettingFactory;
import com.java110.dto.privilege.BasePrivilegeDto;
import com.java110.dto.repair.RepairDto;
import com.java110.dto.user.UserDto;
import com.java110.intf.community.IMenuInnerServiceSMO;
import com.java110.intf.community.IRepairInnerServiceSMO;
import com.java110.intf.community.IRepairUserInnerServiceSMO;
import com.java110.intf.user.IUserV1InnerServiceSMO;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.MappingConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.*;
import com.java110.vo.ResultVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import java.math.BigDecimal;
import java.text.ParseException;
import java.util.*;
@Java110Cmd(serviceCode = "repair.queryPhoneRepairs")
public class QueryPhoneRepairsCmd extends Cmd {
/**
* 报修服务接口
*/
@Autowired
private IRepairInnerServiceSMO repairInnerServiceSMOImpl;
/**
* 报修用户关系服务接口
*/
@Autowired
private IRepairUserInnerServiceSMO repairUserInnerServiceSMOImpl;
/**
* 菜单服务接口
*/
@Autowired
private IMenuInnerServiceSMO menuInnerServiceSMOImpl;
/**
* 用户服务接口
*/
@Autowired
private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;
/**
* 公共域常量
*/
public static final String DOMAIN_COMMON = "DOMAIN.COMMON";
/**
* 员工报修列表视图常量
*/
public static final String VIEW_LIST_STAFF_REPAIRS = "VIEW_LIST_STAFF_REPAIRS";
/**
* 参数验证方法
*
* 验证请求参数是否完整，包括分页信息和必要的项目ID
*
* @param event 命令事件对象，包含请求相关信息
* @param context 数据流上下文对象，用于获取和设置上下文数据
* @param reqJson 请求JSON对象，包含前端传递的参数
* @throws CmdException 当参数验证失败时抛出命令异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
// 调用父类方法验证分页信息
super.validatePageInfo(reqJson);
// 验证请求中必须包含项目ID
Assert.hasKeyAndValue(reqJson, "communityId", "请求中未包含项目ID");
}
/**
* 执行命令方法
*
* 处理手机端报修查询请求，查询用户的报修记录，计算评分和处理时长，返回查询结果
*
* @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, "用户未登录");
// 将请求参数转换为报修DTO对象
RepairDto ownerRepairDto = BeanConvertUtil.covertBean(reqJson, RepairDto.class);
// 设置查询条件中的电话号码为当前用户的电话号码
ownerRepairDto.setTel(userDtos.get(0).getTel());
// 如果请求中包含报修状态参数，设置状态查询条件
if (reqJson.containsKey("repairStates")) {
String[] states = reqJson.getString("repairStates").split(",");
ownerRepairDto.setStatess(states);
}
// 查询符合条件的报修记录总数
int count = repairInnerServiceSMOImpl.queryRepairsCount(ownerRepairDto);
List<RepairDto> repairDtos;
// 如果有查询结果，获取报修列表并计算评分
if (count > 0) {
repairDtos = repairInnerServiceSMOImpl.queryRepairs(ownerRepairDto);
computeRepairScore(repairDtos);
} else {
// 没有查询结果时返回空列表
repairDtos = new ArrayList<>();
}
// 构建响应实体，包含分页信息和查询结果
ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(
(int) Math.ceil((double) count / (double) reqJson.getInteger("row")), // 计算总页数
count, // 总记录数
repairDtos // 报修数据列表
);
context.setResponseEntity(responseEntity);
}
/**
* 计算报修评分方法
*
* 对报修记录进行综合评分计算，包括：
* 1. 综合评分、上门速度评分、维修员服务评分的计算和格式化
* 2. 平均分的计算和四舍五入处理
* 3. 处理时长计算和超时判断
*
* @param repairDtos 报修数据对象列表
*/
private void computeRepairScore(List<RepairDto> repairDtos) {
// 如果报修列表为空，直接返回
if (ListUtil.isNull(repairDtos)) {
return;
}
Date finishTime = null;
String submitHour;
Date timeout = null;
// 遍历所有报修记录，逐条计算评分
for (RepairDto repairDto : repairDtos) {
// 获取综合评价得分并转换为整数（向上取整）
String appraiseScoreNumber = repairDto.getAppraiseScore();
Double appraiseScoreNum = 0.0;
if (!StringUtil.isEmpty(appraiseScoreNumber)) {
appraiseScoreNum = Double.parseDouble(appraiseScoreNumber);
}
int appraiseScore = (int) Math.ceil(appraiseScoreNum);
// 获取上门速度评分并转换为整数（向上取整）
String doorSpeedScoreNumber = repairDto.getDoorSpeedScore();
Double doorSpeedScoreNum = 0.0;
if (!StringUtil.isEmpty(doorSpeedScoreNumber)) {
doorSpeedScoreNum = Double.parseDouble(doorSpeedScoreNumber);
}
int doorSpeedScore = (int) Math.ceil(doorSpeedScoreNum);
// 获取维修员服务评分并转换为整数（向上取整）
String repairmanServiceScoreNumber = repairDto.getRepairmanServiceScore();
Double repairmanServiceScoreNum = 0.0;
if (!StringUtil.isEmpty(repairmanServiceScoreNumber)) {
repairmanServiceScoreNum = Double.parseDouble(repairmanServiceScoreNumber);
}
int repairmanServiceScore = (int) Math.ceil(repairmanServiceScoreNum);
// 计算三个评分的平均值，保留两位小数（四舍五入）
double averageNumber = (appraiseScoreNum + doorSpeedScoreNum + repairmanServiceScoreNum) / 3.0;
BigDecimal averageNum = new BigDecimal(averageNumber);
Double average = averageNum.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
// 将计算后的评分设置回报修对象
repairDto.setAppraiseScore(String.valueOf(appraiseScore));
repairDto.setDoorSpeedScore(String.valueOf(doorSpeedScore));
repairDto.setRepairmanServiceScore(String.valueOf(repairmanServiceScore));
repairDto.setAverage(String.valueOf(average));
// 计算提单时长和处理超时判断
finishTime = DateUtil.getCurrentDate(); // 获取当前时间作为完成时间
repairDto.setTimeoutFlag("N"); // 默认设置为未超时
// 如果报修记录有完成时间，使用完成时间计算
if (!StringUtil.isEmpty(repairDto.getFinishTime())) {
finishTime = DateUtil.getDateFromStringA(repairDto.getFinishTime());
} else {
// 如果没有完成时间，判断是否超时
timeout = DateUtil.getDateFromStringA(repairDto.getTimeout());
// 如果当前时间超过超时时间，标记为超时
if (finishTime.getTime() > timeout.getTime()) {
repairDto.setStateName(repairDto.getStateName() + "(超时)");
repairDto.setTimeoutFlag("Y");
}
}
// 计算从创建时间到完成时间的时长差
submitHour = DateUtil.calculateTimeDifference(repairDto.getCreateTime(), finishTime);
repairDto.setSubmitHours(submitHour);
}
}
}