SaveOwnerRepairCmd.java
15.1 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
package com.java110.community.cmd.ownerRepair;
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.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.doc.annotation.*;
import com.java110.dto.fee.FeeConfigDto;
import com.java110.dto.fee.FeeDto;
import com.java110.dto.file.FileDto;
import com.java110.dto.file.FileRelDto;
import com.java110.dto.repair.RepairDto;
import com.java110.dto.repair.RepairSettingDto;
import com.java110.dto.repair.RepairUserDto;
import com.java110.dto.user.UserDto;
import com.java110.intf.common.IFileInnerServiceSMO;
import com.java110.intf.common.IFileRelInnerServiceSMO;
import com.java110.intf.community.IRepairPoolV1InnerServiceSMO;
import com.java110.intf.community.IRepairSettingV1InnerServiceSMO;
import com.java110.intf.community.IRepairUserV1InnerServiceSMO;
import com.java110.intf.fee.IFeeConfigInnerServiceSMO;
import com.java110.intf.fee.IFeeInnerServiceSMO;
import com.java110.intf.user.INotepadV1InnerServiceSMO;
import com.java110.intf.user.IUserV1InnerServiceSMO;
import com.java110.po.file.FileRelPo;
import com.java110.po.notepad.NotepadPo;
import com.java110.po.owner.RepairPoolPo;
import com.java110.po.owner.RepairUserPo;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.FeeTypeConstant;
import com.java110.utils.constant.MappingConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.*;
import com.java110.vo.ResultVo;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import java.text.ParseException;
import java.util.Date;
import java.util.List;
/**
* 业主提交报修命令类
* 处理业主报修相关业务逻辑，包括报修信息验证、报修单创建、费用检查、图片保存等功能
* 请求地址为/app/ownerRepair.saveOwnerRepair
* @author 张峰
* @version 1.0
* @since 2023
*/
@Java110CmdDoc(title = "业主报修",
description = "主要用于业主报修",
httpMethod = "post",
url = "http://{ip}:{port}/app/ownerRepair.saveOwnerRepair",
resource = "communityDoc",
author = "张峰",
serviceCode = "ownerRepair.saveOwnerRepair",
seq = 23
)
//入参要求
@Java110ParamsDoc(params = {
@Java110ParamDoc(name = "communityId", length = 30, remark = "项目编码"),
@Java110ParamDoc(name = "appointmentTime", length = 30, remark = "预约时间"),
@Java110ParamDoc(name = "context", length = 30, remark = "报修内容"),
@Java110ParamDoc(name = "photos", length = 30, remark = "报修图片"),
@Java110ParamDoc(name = "repairName", length = 30, remark = "报修人姓名"),
@Java110ParamDoc(name = "repairObjName", length = 30, remark = "报修人住址"),
@Java110ParamDoc(name = "repairObjName", length = 30, remark = "报修人所在项目"),
@Java110ParamDoc(name = "roomId", length = 30, remark = "房屋id"),
@Java110ParamDoc(name = "tel", length = 30, remark = "报修联系电话"),
@Java110ParamDoc(name = "userName", length = 30, remark = "业主或成员姓名"),
@Java110ParamDoc(name = "repairChannel", length = 30, remark = "报修渠道"),
@Java110ParamDoc(name = "repairType", length = 30, remark = "派单类型"),
@Java110ParamDoc(name = "repairObjType", length = 30, 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 = "{\"repairName\":\"测试\",\"repairType\":\"102022081592760001\",\"appointmentTime\":\"2022-11-26 15:18:00\",\"tel\":\"15239726115\",\"roomId\":\"752022090312040033\",\"photos\":[],\"context\":\"反反复复烦烦烦\",\"userId\":\"302022102708350644\",\"userName\":\"测试\",\"communityId\":\"2022032267510001\",\"bindDate\":\"2022-11-26\",\"bindTime\":\"15:18\",\"repairObjType\":\"004\",\"repairChannel\":\"Z\",\"repairObjId\":\"752022090312040033\",\"repairObjName\":\"1号楼1单元202室\"}",
resBody = "{\"code\":0,\"msg\":\"成功\",\"page\":0,\"records\":0,\"rows\":0,\"total\":0}"
)
@Java110Cmd(serviceCode = "ownerRepair.saveOwnerRepair")
public class SaveOwnerRepairCmd extends Cmd {
@Autowired
private IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl;
@Autowired
private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
@Autowired
private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;
@Autowired
private IRepairPoolV1InnerServiceSMO repairPoolV1InnerServiceSMOImpl;
@Autowired
private IRepairUserV1InnerServiceSMO repairUserV1InnerServiceSMOImpl;
@Autowired
private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl;
@Autowired
private IFileInnerServiceSMO fileInnerServiceSMOImpl;
@Autowired
private INotepadV1InnerServiceSMO notepadV1InnerServiceSMOImpl;
@Autowired
private IRepairSettingV1InnerServiceSMO repairSettingV1InnerServiceSMOImpl;
//域
public static final String DOMAIN_COMMON = "DOMAIN.COMMON";
//键(报修业主未处理费用条数)
public static final String REPAIR_FEE_NUMBER = "REPAIR_FEE_NUMBER";
/**
* 验证报修请求参数
* 检查必填参数、用户信息、费用状态等
* @param event 命令事件
* @param context 数据流上下文
* @param reqJson 请求JSON对象
* @throws CmdException 参数验证失败时抛出异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
// 验证必填参数
Assert.hasKeyAndValue(reqJson, "repairType", "必填，请选择报修类型");
Assert.hasKeyAndValue(reqJson, "repairName", "必填，请填写报修人名称");
Assert.hasKeyAndValue(reqJson, "tel", "必填，请填写报修人手机号");
Assert.hasKeyAndValue(reqJson, "repairObjType", "必填，请填写报修对象类型");
Assert.hasKeyAndValue(reqJson, "repairObjId", "必填，请填写报修对象ID");
Assert.hasKeyAndValue(reqJson, "repairObjName", "必填，请填写报修对象名称");
Assert.hasKeyAndValue(reqJson, "appointmentTime", "必填，请填写预约时间");
Assert.hasKeyAndValue(reqJson, "context", "必填，请填写报修内容");
Assert.hasKeyAndValue(reqJson, "communityId", "必填，请填写项目ID");
// 获取并验证用户信息
String userId = CmdContextUtils.getUserId(context);
UserDto userDto = new UserDto();
userDto.setUserId(userId);
userDto.setPage(1);
userDto.setRow(1);
List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
Assert.listOnlyOne(userDtos, "未查询到用户");
// 将用户信息添加到请求参数中
reqJson.put("userId", userDtos.get(0).getUserId());
reqJson.put("userName", userDtos.get(0).getName());
// 查询默认费用项配置
FeeConfigDto feeConfigDto = new FeeConfigDto();
feeConfigDto.setCommunityId(reqJson.getString("communityId"));
feeConfigDto.setFeeTypeCd(FeeTypeConstant.FEE_TYPE_REPAIR); // 设置费用类型为报修费
feeConfigDto.setIsDefault(FeeConfigDto.DEFAULT_FEE_CONFIG); // 查询默认配置
List<FeeConfigDto> feeConfigDtos = feeConfigInnerServiceSMOImpl.queryFeeConfigs(feeConfigDto);
if (ListUtil.isNull(feeConfigDtos)) {
return; // 没有配置默认费用项，直接返回
}
// 查询处理中的报修费用
FeeDto feeDto = new FeeDto();
feeDto.setConfigId(feeConfigDtos.get(0).getConfigId()); // 使用第一个默认配置
feeDto.setPayerObjId(reqJson.getString("repairObjId")); // 设置缴费对象ID
feeDto.setState(FeeDto.STATE_DOING); // 查询处理中的费用
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
if (ListUtil.isNull(feeDtos)) {
return; // 没有处理中的费用，允许报修
}
// 检查未处理费用条数限制
String repairFeeNumber = MappingCache.getValue(MappingConstant.REPAIR_DOMAIN, REPAIR_FEE_NUMBER);
if (!StringUtil.isInteger(repairFeeNumber)) {
return; // 配置值不是数字，不进行限制
}
// 如果未处理费用超过配置的限制数量，抛出异常
if (feeDtos.size() >= Integer.parseInt(repairFeeNumber)) {
throw new CmdException("该房屋存在" + Integer.parseInt(repairFeeNumber) + "条未处理的费用，请缴费后再进行报修！");
}
}
/**
* 执行报修命令
* 创建报修单、报修用户记录、保存图片等
* @param event 命令事件
* @param context 数据流上下文
* @param reqJson 请求JSON对象
* @throws CmdException 业务处理失败时抛出异常
* @throws ParseException 时间解析异常
*/
@Override
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
// 查询报修设置信息
RepairSettingDto repairSettingDto = new RepairSettingDto();
repairSettingDto.setCommunityId(reqJson.getString("communityId"));
repairSettingDto.setRepairType(reqJson.getString("repairType"));
List<RepairSettingDto> repairSettingDtos = repairSettingV1InnerServiceSMOImpl.queryRepairSettings(repairSettingDto);
if (ListUtil.isNull(repairSettingDtos)) {
throw new CmdException("报销刘类型不存在");
}
// 创建报修池记录
RepairPoolPo repairPoolPo = BeanConvertUtil.covertBean(reqJson, RepairPoolPo.class);
repairPoolPo.setRepairId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_repairId));
repairPoolPo.setState(RepairDto.STATE_WAIT); // 设置初始状态为等待处理
// 计算超时时间
String appointmentTime = repairPoolPo.getAppointmentTime();
Date sAppTime = DateUtil.getDateFromStringA(appointmentTime);
String timeout = DateUtil.getAddHoursStringA(sAppTime, repairSettingDtos.get(0).getDoTime());
repairPoolPo.setTimeout(timeout);
// 保存报修池记录
int flag = repairPoolV1InnerServiceSMOImpl.saveRepairPoolNew(repairPoolPo);
if (flag < 1) {
throw new CmdException("修改失败");
}
// 创建报修用户记录
RepairUserPo repairUserPo = BeanConvertUtil.covertBean(reqJson, RepairUserPo.class);
repairUserPo.setContext("订单提交");
repairUserPo.setPreStaffId("-1"); // 设置前一个处理人员ID为默认值
repairUserPo.setPreStaffName("-1");
repairUserPo.setPreRuId("-1");
repairUserPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); // 设置开始时间为当前时间
repairUserPo.setRepairEvent(RepairUserDto.REPAIR_EVENT_START_USER); // 设置报修事件类型
repairUserPo.setStaffId(reqJson.getString("userId")); // 设置当前处理人员
repairUserPo.setStaffName(reqJson.getString("userName"));
repairUserPo.setRepairId(repairPoolPo.getRepairId()); // 关联报修ID
repairUserPo.setState(RepairUserDto.STATE_SUBMIT); // 设置状态为已提交
repairUserPo.setEndTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); // 设置结束时间为当前时间
repairUserPo.setRuId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ruId));
// 保存报修用户记录
flag = repairUserV1InnerServiceSMOImpl.saveRepairUserNew(repairUserPo);
if (flag < 1) {
throw new CmdException("修改用户失败");
}
// 保存报修图片
saveRepairPhoto(reqJson, repairPoolPo.getRepairId());
// 如果存在记事本ID，更新记事本关联
if (StringUtil.jsonHasKayAndValue(reqJson, "noteId")) {
NotepadPo notepadPo = new NotepadPo();
notepadPo.setNoteId(reqJson.getString("noteId"));
notepadPo.setThridId(repairPoolPo.getRepairId()); // 关联报修ID
flag = notepadV1InnerServiceSMOImpl.updateNotepad(notepadPo);
if (flag < 1) {
throw new CmdException("修改业主反馈失败");
}
}
}
/**
* 保存报修图片
* 处理报修相关的图片上传和关联关系
* @param reqJson 请求JSON对象，包含图片信息
* @param repairId 报修ID，用于关联图片
*/
private void saveRepairPhoto(JSONObject reqJson, String repairId) {
int flag;
JSONArray photos = reqJson.getJSONArray("photos");
if (ListUtil.isNull(photos)) {
return; // 没有图片，直接返回
}
// 遍历所有图片
for (int _photoIndex = 0; _photoIndex < photos.size(); _photoIndex++) {
String _photo = photos.getString(_photoIndex);
// 跳过无效的图片值
if (_photo == null || _photo.isEmpty() || "null".equals(_photo)) {
continue;
}
// 如果图片内容过长（base64编码），先保存到文件系统
if (_photo.length() > 512) {
FileDto fileDto = new FileDto();
fileDto.setFileId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_file_id));
fileDto.setFileName(fileDto.getFileId());
fileDto.setContext(_photo); // 图片内容
fileDto.setSuffix("jpeg"); // 设置文件后缀
fileDto.setCommunityId(reqJson.getString("communityId"));
_photo = fileInnerServiceSMOImpl.saveFile(fileDto); // 保存文件并返回文件路径
}
// 创建文件关联记录
JSONObject businessUnit = new JSONObject();
businessUnit.put("fileRelId", GenerateCodeFactory.getGeneratorId("12"));
businessUnit.put("relTypeCd", FileRelDto.REL_TYPE_CD_REPAIR); // 设置关联类型为报修
businessUnit.put("saveWay", "ftp"); // 设置保存方式
businessUnit.put("objId", repairId); // 关联报修ID
businessUnit.put("fileRealName", _photo.toString());
businessUnit.put("fileSaveName", _photo.toString());
FileRelPo fileRelPo = BeanConvertUtil.covertBean(businessUnit, FileRelPo.class);
flag = fileRelInnerServiceSMOImpl.saveFileRel(fileRelPo);
if (flag < 1) {
throw new CmdException("保存图片失败");
}
}
}
}