一、基本属性准备
1、主题注解
2、解析报文协议
二、自动创建维修工单
1、根据算法获取前一天维修工单最少的人，获取其用户id
其中最主要的是 为该工单分配一个 执行人，该执行人(前一天维修工单最少的人)
所以算出这个人的Id，就迎刃而解了
/*
* 根据区域Id获取当前区域今天工单量最少的人
* */
private Integer getMinCountUserId(Long regionId) {
//获取区域内的运维人员列表
List<UserVO> userVOList = userService.getOperators(regionId + "");
if (CollectionUtils.isEmpty(userVOList)) {
throw new LogicException("该区域没有运维人员");
}
//获取该区域用户列表
ArrayList<Integer> userIdList = new ArrayList<>();
for (UserVO vo : userVOList) {
userIdList.add(vo.getUserId());
}
//查询当天每个维修人员的工单数量
DateTime begin = DateUtil.beginOfDay(new Date());
DateTime end = DateUtil.endOfDay(new Date());
//当天运维工单
List<TaskEntity> taskEntityList= taskService.getUserTask(begin,end);
// 按用户id 对工单进行分组
Map<Integer, List<TaskEntity>> userCount = taskEntityList.stream().collect(Collectors.groupingBy(TaskEntity::getUserId));
//为当前用户设置工单数量
List<UserTaskCount> userTaskCountList = userIdList.stream().map(userId -> {
UserTaskCount userTaskCount = new UserTaskCount();
userTaskCount.setUserId(userId);
//拿到当前用户的工单列表
List<TaskEntity> taskEntityListNow = userCount.get(userId);
if (CollectionUtils.isEmpty(taskEntityListNow)) {
userTaskCount.setCount(0);
} else {
userTaskCount.setCount(taskEntityListNow.size());
}
return userTaskCount;
}).sorted(((o1, o2) -> o1.getCount() - o2.getCount())).limit(1).collect(Collectors.toList());
Integer userId = userTaskCountList.get(0).getUserId();
return userId;
}
2、自动创建工单
//自动进行创建工单
@Override
public boolean AutoSaveTask(VmStatusContract vmStatusContract) {
TaskEntity taskEntity = new TaskEntity();
//工单编号
String taskCode = getId();
taskEntity.setTaskCode(taskCode);
//工单类型封装
taskEntity.setTaskStatus(VMSystem.TASK_STATUS_CREATE);
//创建类型
taskEntity.setCreateType(VMSystem.ORDER_STATUS_CREATE);
//售货机编号
String innerCode = vmStatusContract.getInnerCode();
taskEntity.setInnerCode(innerCode);
//发起feign调用，去售货机微服务中获取售货机信息
VmVO vmInfo = vmService.getVMInfo(innerCode);
//获区域Id
Long regionId = vmInfo.getRegionId();
if (regionId==null){
throw new LogicException("区域Id不存在");
}
taskEntity.setRegionId(regionId);
//描述
taskEntity.setDesc("自动创建");
//封装工单类型
taskEntity.setProductTypeId(VMSystem.TASK_TYPE_REPAIR);
//封装地址
String nodeAddr = vmInfo.getNodeAddr();
taskEntity.setAddr(nodeAddr);
//封装用户Id,该用户Id根据算法算出
Integer userId = getMinCountUserId(regionId);
//调用用户微服务获取用户姓名
UserVO user = userService.getUser(userId);
//封装用户姓名
taskEntity.setUserName(user.getUserName());
taskEntity.setUserId(userId);
//创建工单
taskService.save(taskEntity);
return true;
}
