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.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 (repairTypeUserDtos == null || repairTypeUserDtos.size() < 1) {
|
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);
|
|
|
}
|
|
|
}
|
