TrainingRepairTemplate.java
6.52 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
package com.java110.job.task.repair;
import com.java110.core.factory.CallApiServiceFactory;
import com.java110.intf.community.IRepairInnerServiceSMO;
import com.java110.intf.community.IRepairTypeUserInnerServiceSMO;
import com.java110.dto.app.AppDto;
import com.java110.dto.community.CommunityDto;
import com.java110.dto.repair.RepairDto;
import com.java110.dto.repair.RepairTypeUserDto;
import com.java110.dto.repair.RepairUserDto;
import com.java110.dto.task.TaskDto;
import com.java110.job.quartz.TaskSystemQuartz;
import com.java110.utils.cache.CommonCache;
import com.java110.utils.constant.ServiceCodeRepairDispatchStepConstant;
import com.java110.utils.util.ListUtil;
import com.java110.utils.util.StringUtil;
import org.slf4j.Logger;
import com.java110.core.log.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @program: MicroCommunity
* @description: 定时任务 轮训派单
* @author: wuxw
* @create: 2020-06-15 13:35
**/
@Component
public class TrainingRepairTemplate extends TaskSystemQuartz {
private static Logger logger = LoggerFactory.getLogger(TrainingRepairTemplate.class);
private static final int EXPIRE_IN = 7200;
@Autowired
private IRepairInnerServiceSMO repairInnerServiceSMOImpl;
@Autowired
private IRepairTypeUserInnerServiceSMO repairTypeUserInnerServiceSMOImpl;
@Override
protected void process(TaskDto taskDto) {
logger.debug("开始执行微信模板信息推送" + taskDto.toString());
// 获取小区
List<CommunityDto> communityDtos = getAllCommunity();
for (CommunityDto communityDto : communityDtos) {
try {
trainingRepair(taskDto, communityDto);
} catch (Exception e) {
logger.error("推送消息失败", e);
}
}
}
/**
* 轮训派单
*
* @param taskDto
* @param communityDto
*/
private void trainingRepair(TaskDto taskDto, CommunityDto communityDto) {
RepairDto repairDto = new RepairDto();
repairDto.setCommunityId(communityDto.getCommunityId());
repairDto.setState(RepairDto.STATE_WAIT);
repairDto.setRepairWay(RepairDto.REPAIR_WAY_TRAINING);
//查询需要程序轮训派单 订单
List<RepairDto> repairDtos = repairInnerServiceSMOImpl.queryRepairs(repairDto);
for (RepairDto tmpRepairDto : repairDtos) {
RepairTypeUserDto repairTypeUserDto = new RepairTypeUserDto();
repairTypeUserDto.setCommunityId(communityDto.getCommunityId());
repairTypeUserDto.setRepairType(tmpRepairDto.getRepairType());
repairTypeUserDto.setState(RepairTypeUserDto.STATE_ONLINE); //派单给在线员工
List<RepairTypeUserDto> repairTypeUserDtos = repairTypeUserInnerServiceSMOImpl.queryRepairTypeUsers(repairTypeUserDto);
//没有设置 处理师傅 无法派单
if (ListUtil.isNull(repairTypeUserDtos)) {
continue;
}
doTrainingRepair(tmpRepairDto, repairTypeUserDtos);
}
}
/**
* 将改订单 派给下面 师傅
*
* @param tmpRepairDto
* @param repairTypeUserDtos
*/
private void doTrainingRepair(RepairDto tmpRepairDto, List<RepairTypeUserDto> repairTypeUserDtos) {
if (repairTypeUserDtos.size() == 1) {
RepairUserDto repairUserDto = new RepairUserDto();
repairUserDto.setUserId(repairTypeUserDtos.get(0).getStaffId());
repairUserDto.setUserName(repairTypeUserDtos.get(0).getStaffName());
repairUserDto.setCommunityId(repairTypeUserDtos.get(0).getCommunityId());
repairUserDto.setRepairId(tmpRepairDto.getRepairId());
CallApiServiceFactory.postForApi(AppDto.WEB_APP_ID, repairUserDto, ServiceCodeRepairDispatchStepConstant.BINDING_GRABBING_REPAIR, RepairUserDto.class);
return;
}
String sizeStr = CommonCache.getValue(tmpRepairDto.getRepairType() + "-" + tmpRepairDto.getCommunityId() + "-staff-size");
if (StringUtil.isEmpty(sizeStr)) {
CommonCache.setValue(tmpRepairDto.getRepairType() + "-" + tmpRepairDto.getCommunityId() + "-staff-size", repairTypeUserDtos.size() + "", EXPIRE_IN);
sizeStr = repairTypeUserDtos.size() + "";
}
int size = Integer.parseInt(sizeStr);
//总数不一致从新设置 随机判断就好
if (size != repairTypeUserDtos.size()) {
size = repairTypeUserDtos.size();
CommonCache.setValue(tmpRepairDto.getRepairType() + "-" + tmpRepairDto.getCommunityId() + "-staff-size", size + "", EXPIRE_IN);
int index = (int) (Math.random() * repairTypeUserDtos.size());
RepairUserDto repairUserDto = new RepairUserDto();
repairUserDto.setUserId(repairTypeUserDtos.get(index).getStaffId());
repairUserDto.setUserName(repairTypeUserDtos.get(index).getStaffName());
repairUserDto.setCommunityId(repairTypeUserDtos.get(index).getCommunityId());
repairUserDto.setRepairId(tmpRepairDto.getRepairId());
CallApiServiceFactory.postForApi(AppDto.WEB_APP_ID, repairUserDto, ServiceCodeRepairDispatchStepConstant.BINDING_GRABBING_REPAIR, RepairUserDto.class);
return;
}
String repairIndexStr = CommonCache.getValue(tmpRepairDto.getRepairType() + "-" + tmpRepairDto.getCommunityId() + "-staff-index");
if (StringUtil.isEmpty(repairIndexStr)) {
CommonCache.setValue(tmpRepairDto.getRepairType() + "-" + tmpRepairDto.getCommunityId() + "-staff-index", "0", EXPIRE_IN);
repairIndexStr = "0";
}
int repairIndex = Integer.parseInt(repairIndexStr);
if (repairIndex < size - 1) {
repairIndex += 1;
} else {
repairIndex = 0;
}
CommonCache.setValue(tmpRepairDto.getRepairType() + "-" + tmpRepairDto.getCommunityId() + "-staff-index", repairIndex + "", EXPIRE_IN);
RepairUserDto repairUserDto = new RepairUserDto();
repairUserDto.setUserId(repairTypeUserDtos.get(repairIndex).getStaffId());
repairUserDto.setUserName(repairTypeUserDtos.get(repairIndex).getStaffName());
repairUserDto.setCommunityId(repairTypeUserDtos.get(repairIndex).getCommunityId());
repairUserDto.setRepairId(tmpRepairDto.getRepairId());
CallApiServiceFactory.postForApi(AppDto.WEB_APP_ID, repairUserDto, ServiceCodeRepairDispatchStepConstant.BINDING_GRABBING_REPAIR, RepairUserDto.class);
}
}