package org.jeecg.modules.eam.service.impl; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.flowable.engine.TaskService; import org.flowable.task.api.Task; import org.jeecg.common.api.vo.Result; import org.jeecg.common.constant.CommonConstant; import org.jeecg.common.constant.DataBaseConstant; import org.jeecg.common.exception.JeecgBootException; import org.jeecg.common.system.vo.LoginUser; import org.jeecg.common.util.oConvertUtils; import org.jeecg.modules.eam.aspect.annotation.EquipmentHistoryLog; import org.jeecg.modules.eam.constant.*; import org.jeecg.modules.eam.dto.EamRepairOrderDto; import org.jeecg.modules.eam.dto.EamRepairOrderExport; import org.jeecg.modules.eam.entity.EamEquipment; import org.jeecg.modules.eam.entity.EamRepairOrder; import org.jeecg.modules.eam.entity.EamRepairPerson; import org.jeecg.modules.eam.entity.EamReportRepair; import org.jeecg.modules.eam.mapper.EamRepairOrderMapper; import org.jeecg.modules.eam.request.EamRepairOrderQuery; import org.jeecg.modules.eam.request.EamRepairOrderRequest; import org.jeecg.modules.eam.request.EamRepairOrderResponse; import org.jeecg.modules.eam.request.EamReportRepairQuery; import org.jeecg.modules.eam.service.*; import org.jeecg.modules.eam.util.DateUtils; import org.jeecg.modules.flowable.apithird.business.entity.FlowMyBusiness; import org.jeecg.modules.flowable.apithird.business.service.IFlowMyBusinessService; import org.jeecg.modules.flowable.apithird.service.FlowCallBackServiceI; import org.jeecg.modules.flowable.apithird.service.FlowCommonService; import org.jeecg.modules.flowable.service.IFlowDefinitionService; import org.jeecg.modules.flowable.service.IFlowTaskService; import org.jeecg.modules.flowable.util.TimeUtil; import org.jeecg.modules.system.entity.BaseFactory; import org.jeecg.modules.system.entity.BaseFactoryUser; import org.jeecg.modules.system.service.IBaseFactoryService; import org.jeecg.modules.system.service.IBaseFactoryUserService; import org.jeecg.modules.system.service.ISysBusinessCodeRuleService; import org.jeecg.modules.system.service.ISysUserService; import org.jeecg.modules.system.vo.UserSelector; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.*; import java.util.stream.Collectors; /** * @Description: 维修工单 * @Author: Lius * @Date: 2025-04-03 */ @Service("IEamRepairOrderService") public class EamRepairOrderServiceImpl extends ServiceImpl implements IEamRepairOrderService, FlowCallBackServiceI { @Resource private FlowCommonService flowCommonService; @Resource private IEamReportRepairService eamReportRepairService; @Resource private IFlowDefinitionService flowDefinitionService; @Resource private IEamEquipmentService eamEquipmentService; @Resource private IFlowMyBusinessService flowMyBusinessService; @Resource private TaskService taskService; @Resource private IFlowTaskService flowTaskService; @Resource private IEamEquipmentExtendService eamEquipmentExtendService; @Autowired private ISysUserService sysUserService; @Autowired private IBaseFactoryService baseFactoryService; @Autowired private IBaseFactoryUserService baseFactoryUserService; @Autowired private IEamRepairPersonService iEamRepairPersonService; /** * 分页列表 * * @param page * @param query * @return */ @Override public IPage pageList(Page page, EamRepairOrderQuery query) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("wmo.del_flag", CommonConstant.DEL_FLAG_0); //用户数据权限 LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); if (sysUser == null) { return page; } if (StringUtils.isNotBlank(sysUser.getEamEquipmentIds())) { //选择了设备，根据设备id过滤设备 List equipArr = Arrays.asList(sysUser.getEamEquipmentIds().split(",")); queryWrapper.in("e.equipment_code", equipArr); } else { //没有选择设备，根据中心过滤设备 List baseFactoryUserList = baseFactoryUserService. list(new LambdaQueryWrapper().eq(BaseFactoryUser::getUserId, sysUser.getId())); if (!CollectionUtils.isEmpty(baseFactoryUserList)) { Set factoryIds = baseFactoryUserList.stream().map(BaseFactoryUser::getFactoryId).collect(Collectors.toSet()); Set factoryCode = baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet()); queryWrapper.in("e.factory_org_code", factoryCode); } else { return page; } } //查询条件过滤 if (query != null) { if (StringUtils.isNotBlank(query.getEquipmentId())) { queryWrapper.eq("wmo.equipment_id", query.getEquipmentId()); } if (StringUtils.isNotBlank(query.getEquipmentCode())) { queryWrapper.like("e.equipment_code", query.getEquipmentCode()); } if (StringUtils.isNotBlank(query.getEquipmentName())) { queryWrapper.like("e.equipment_name", query.getEquipmentName()); } if (StringUtils.isNotBlank(query.getRepairStatus())) { queryWrapper.eq("wmo.repair_status", query.getRepairStatus()); } if (StringUtils.isNotBlank(query.getRepairCode())) { queryWrapper.like("wmo.repair_code", query.getRepairCode()); } //排序 if (StringUtils.isNotBlank(query.getColumn()) && StringUtils.isNotBlank(query.getOrder())) { String column = query.getColumn(); if (column.endsWith(CommonConstant.DICT_TEXT_SUFFIX)) { column = column.substring(0, column.lastIndexOf(CommonConstant.DICT_TEXT_SUFFIX)); } if (DataBaseConstant.SQL_ASC.equalsIgnoreCase(query.getOrder())) { queryWrapper.orderByAsc("wmo." + oConvertUtils.camelToUnderline(column)); } else { queryWrapper.orderByDesc("wmo." + oConvertUtils.camelToUnderline(column)); } } else { queryWrapper.orderByDesc("wmo.create_time"); } } else { queryWrapper.orderByDesc("wmo.create_time"); } return baseMapper.queryPageList(page, queryWrapper); } /** * 填报详情 * @param id */ @Override public List queryByReportId(String id){ List eamRepairOrders=this.list( new QueryWrapper().eq("id",id)); List eamRepairOrderDtoList=new ArrayList<>(); if (CollectionUtils.isEmpty(eamRepairOrders)) { return null; }else { eamRepairOrders.forEach(eamRepairOrder->{ EamRepairOrderDto eamRepairOrderDto=new EamRepairOrderDto(); BeanUtils.copyProperties(eamRepairOrder,eamRepairOrderDto); List eamRepairPersonList=iEamRepairPersonService.list( new QueryWrapper().eq("repair_id",eamRepairOrder.getId())); eamRepairOrderDto.setEamRepairPersonList(eamRepairPersonList); eamRepairOrderDtoList.add(eamRepairOrderDto); }); } return eamRepairOrderDtoList; } /** * 填报维修工单 * @param eamRepairOrderDto */ @Override @Transactional(rollbackFor = Exception.class) public boolean report(EamRepairOrderDto eamRepairOrderDto){ EamRepairOrder eamRepairOrder=this.getById(eamRepairOrderDto.getId()); if (eamRepairOrder==null){ return false; } BeanUtils.copyProperties(eamRepairOrderDto,eamRepairOrder); eamRepairOrder.setRepairStatus(EamRepairOrderRepairStatusEnum.UNDER_MAINTENANCE.name()); eamRepairOrder.setActualEndTime(new Date()); // 计算维修时间与故障时间 Date startTime; Date endTime; // 1. 计算维修时长（维修结束时间-维修开始时间） if (eamRepairOrder.getActualStartTime() != null && eamRepairOrder.getActualEndTime() != null) { startTime = eamRepairOrder.getActualStartTime(); endTime = eamRepairOrder.getActualEndTime(); // 确保结束时间在开始时间之后 if (endTime.after(startTime)) { long time = endTime.getTime() - startTime.getTime(); double hours = (double) time / (1000 * 60 * 60); eamRepairOrder.setRepairDuration(String.format("%.2f", hours)); } else { // 时间顺序错误处理 eamRepairOrder.setRepairDuration("0.00"); } } else { // 处理缺失时间的情况 eamRepairOrder.setRepairDuration("0.00"); } // 2. 计算故障时长（维修结束时间-故障开始时间） EamReportRepair eamReportRepair = eamReportRepairService.getById(eamRepairOrder.getReportId()); if (eamReportRepair != null && eamReportRepair.getFaultStartTime() != null && eamRepairOrder.getActualEndTime() != null) { startTime = eamReportRepair.getFaultStartTime(); endTime = eamRepairOrder.getActualEndTime(); if (endTime.after(startTime)) { long time = endTime.getTime() - startTime.getTime(); double hours = (double) time / (1000 * 60 * 60); eamRepairOrder.setFaultDuration(String.format("%.2f", hours)); } else { eamRepairOrder.setFaultDuration("0.00"); } } else { eamRepairOrder.setFaultDuration("0.00"); } eamRepairOrder.setFaultStartTime(new Date()); this.updateById(eamRepairOrder); eamReportRepair.setReportStatus(EamRepairOrderRepairStatusEnum.UNDER_MAINTENANCE.name()); eamReportRepairService.updateById(eamReportRepair); List eamRepairPersonList=new ArrayList<>(); iEamRepairPersonService.remove(new QueryWrapper().eq("repair_id",eamRepairOrderDto.getId())); if (CollectionUtils.isNotEmpty(eamRepairOrderDto.getEamRepairPersonList())) { eamRepairOrderDto.getEamRepairPersonList().forEach(eamRepairPerson -> { eamRepairPerson.setId(null); eamRepairPerson.setRepairId(eamRepairOrder.getId()); eamRepairPerson.setDelFlag(CommonConstant.DEL_FLAG_0); eamRepairPersonList.add(eamRepairPerson); }); iEamRepairPersonService.saveBatch(eamRepairPersonList); } return true; } @Override @Transactional(rollbackFor = Exception.class) public void saveRepairOrder(String id) { EamRepairOrder eamRepairOrder = this.getById(id); List eamRepairPersonList=iEamRepairPersonService.list( new QueryWrapper().eq("repair_id",eamRepairOrder.getId())); if (CollectionUtils.isEmpty(eamRepairPersonList)) { throw new RuntimeException("维修人员不能为空"); } if (StrUtil.isEmpty(eamRepairOrder.getRepairCode())) { throw new RuntimeException("工单编号为空"); } if (StrUtil.isEmpty(eamRepairOrder.getFaultReason())){ throw new RuntimeException("故障原因为空"); } if (StrUtil.isEmpty(eamRepairOrder.getFaultAnalysis())){ throw new RuntimeException("故障分析为空"); } if (StrUtil.isEmpty(eamRepairOrder.getFaultProcess())){ throw new RuntimeException("排故过程为空"); } if (StrUtil.isEmpty(eamRepairOrder.getFaultPrevent())){ throw new RuntimeException("故障预防为空"); } LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal(); EamEquipment eamEquipment = eamEquipmentService.getById(eamRepairOrder.getEquipmentId()); List userSelectorList = sysUserService.selectOperatorList(eamEquipment.getEquipmentCode(), eamEquipment.getFactoryOrgCode(), BusinessCodeConst.PCR0001); // 启动维修流程 flowCommonService.initActBusiness("工单号：" + eamRepairOrder.getRepairCode() + ", 设备编号：" + eamEquipment.getEquipmentCode()+"发起维修流程", eamRepairOrder.getId(), "IEamRepairOrderService", "repair_work_order", null); Map variables = new HashMap<>(); variables.put("dataId", eamRepairOrder.getId()); variables.put("organization", "维修工单启动流程"); variables.put("comment", "维修工单启动流程"); variables.put("proofreading", true); if (CollectionUtils.isEmpty(userSelectorList)) { throw new JeecgBootException("设备未存在操作员，无法进入下级审批！"); }else { List usernameList = userSelectorList.stream().map(UserSelector::getUsername).collect(Collectors.toList()); variables.put("NextAssignee", usernameList); } Result result = flowDefinitionService.startProcessInstanceByKey("repair_work_order", variables); if (!result.isSuccess()) { super.removeById(eamRepairOrder); } else { eamRepairOrder.setRepairConfirm(user.getUsername()); eamRepairOrder.setRepairConfirmTime(new Date()); eamRepairOrder.setRepairStatus(EamRepairOrderRepairStatusEnum.PENDING_CONFIRMATION.name()); this.updateById(eamRepairOrder); EamReportRepair eamReportRepair=eamReportRepairService.getById(eamRepairOrder.getReportId()); eamReportRepair.setReportStatus(EamRepairOrderRepairStatusEnum.UNDER_MAINTENANCE.name()); eamReportRepairService.updateById(eamReportRepair); //更新设备维修状态 eamEquipmentExtendService.updateEquipmentRepairStatus(eamRepairOrder.getEquipmentId(), EquipmentRepairStatus.UNDER_REPAIR.name()); } } /** * 流程操作 * * @param request * @return */ @Override @Transactional(rollbackFor = Exception.class) @EquipmentHistoryLog(operationTag = EquipmentOperationTagEnum.REPAIRED, businessTable = "eam_repair_order") public EamRepairOrder perform(EamRepairOrderRequest request) { EamRepairOrder order = this.baseMapper.selectById(request.getId()); if (order == null) { throw new JeecgBootException("维修工单不存在，请刷新重试！"); } // 获取当前登录用户 LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal(); if (user == null || StrUtil.isBlank(user.getId())) { throw new JeecgBootException("未获取到登录用户，请重新登录后再试！"); } request.setAssignee(user.getUsername()); // 获取流程业务记录 FlowMyBusiness flowMyBusiness = flowMyBusinessService.getFlowMyBusiness(request.getInstanceId()); if (flowMyBusiness == null) { throw new JeecgBootException("流程实例不存在，请刷新后重试！"); } boolean userAuthorized = isUserAuthorized(flowMyBusiness, user); if (!userAuthorized) { throw new JeecgBootException("用户无权操作此任务，请刷新后重试！"); } // 认领任务 if (!claimTask(flowMyBusiness.getTaskId(), user)) { throw new JeecgBootException("任务不存在、已完成或已被他人认领！"); } EamEquipment equipment = eamEquipmentService.getById(request.getEquipmentId()); if (equipment == null) { throw new JeecgBootException("设备不存在，请检查！"); } //流程变量 Map values = new HashMap<>(); values.put("dataId", request.getId()); values.put("assignee", user.getId()); values.put("organization", request.getConfirmComment()); values.put("comment", request.getConfirmComment()); request.setComment(request.getConfirmComment()); request.setValues(values); // 完成流程任务 Result result = flowTaskService.complete(request); if (!result.isSuccess()) { throw new JeecgBootException("审批失败，请刷新查看！"); } //保存工单 if (request.getConfirmResult() != null) { if ("1".equals(request.getConfirmResult())) { order.setRepairStatus(EamRepairOrderRepairStatusEnum.REPAIR_COMPLETED.name()); }else { order.setRepairStatus(EamRepairOrderRepairStatusEnum.REJECTED.name()); } } order.setConfirmer(user.getUsername()); order.setConfirmTime(new Date()); order.setConfirmResult(request.getConfirmResult()); order.setConfirmComment(request.getConfirmComment()); this.baseMapper.updateById(order); EamReportRepair eamReportRepair=eamReportRepairService.getById(order.getReportId()); eamReportRepair.setReportStatus(order.getRepairStatus()); eamReportRepairService.updateById(eamReportRepair); return order; } @Override public EamRepairOrderResponse findById(String id) { EamRepairOrderResponse eamRepairOrderResponse = new EamRepairOrderResponse(); EamRepairOrder eamRepairOrder = this.baseMapper.selectById(id); BeanUtils.copyProperties(eamRepairOrder, eamRepairOrderResponse); EamReportRepair eamReportRepair = eamReportRepairService.getById(eamRepairOrder.getReportId()); BeanUtils.copyProperties(eamReportRepair, eamRepairOrderResponse); return eamRepairOrderResponse; } /** * 维修工单导出 * @param eamRepairOrderQuery * @return */ @Override public List exportList(EamRepairOrderQuery eamRepairOrderQuery){ QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("wmo.del_flag", CommonConstant.DEL_FLAG_0); //用户数据权限 LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); if (sysUser == null) { return new ArrayList<>(); } if (StringUtils.isNotBlank(sysUser.getEamEquipmentIds())) { //选择了设备，根据设备id过滤设备 List equipArr = Arrays.asList(sysUser.getEamEquipmentIds().split(",")); queryWrapper.in("e.equipment_code", equipArr); } else { //没有选择设备，根据中心过滤设备 List baseFactoryUserList = baseFactoryUserService. list(new LambdaQueryWrapper().eq(BaseFactoryUser::getUserId, sysUser.getId())); if (!CollectionUtils.isEmpty(baseFactoryUserList)) { Set factoryIds = baseFactoryUserList.stream().map(BaseFactoryUser::getFactoryId).collect(Collectors.toSet()); Set factoryCode = baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet()); queryWrapper.in("e.factory_org_code", factoryCode); } else { return new ArrayList<>(); } } //查询条件过滤 if (eamRepairOrderQuery != null) { if (StringUtils.isNotBlank(eamRepairOrderQuery.getEquipmentId())) { queryWrapper.eq("wmo.equipment_id", eamRepairOrderQuery.getEquipmentId()); } if (StringUtils.isNotBlank(eamRepairOrderQuery.getEquipmentCode())) { queryWrapper.like("e.equipment_code", eamRepairOrderQuery.getEquipmentCode()); } if (StringUtils.isNotBlank(eamRepairOrderQuery.getEquipmentName())) { queryWrapper.like("e.equipment_name", eamRepairOrderQuery.getEquipmentName()); } if (StringUtils.isNotBlank(eamRepairOrderQuery.getRepairStatus())) { queryWrapper.eq("wmo.repair_status", eamRepairOrderQuery.getRepairStatus()); } if (StringUtils.isNotBlank(eamRepairOrderQuery.getRepairCode())) { queryWrapper.like("wmo.repair_code", eamRepairOrderQuery.getRepairCode()); } //排序 if (StringUtils.isNotBlank(eamRepairOrderQuery.getColumn()) && StringUtils.isNotBlank(eamRepairOrderQuery.getOrder())) { String column = eamRepairOrderQuery.getColumn(); if (column.endsWith(CommonConstant.DICT_TEXT_SUFFIX)) { column = column.substring(0, column.lastIndexOf(CommonConstant.DICT_TEXT_SUFFIX)); } if (DataBaseConstant.SQL_ASC.equalsIgnoreCase(eamRepairOrderQuery.getOrder())) { queryWrapper.orderByAsc("wmo." + oConvertUtils.camelToUnderline(column)); } else { queryWrapper.orderByDesc("wmo." + oConvertUtils.camelToUnderline(column)); } } else { queryWrapper.orderByDesc("wmo.create_time"); } } else { queryWrapper.orderByDesc("wmo.create_time"); } return this.baseMapper.queryExportList(queryWrapper); } private boolean claimTask(String taskId, LoginUser user) { Task task = taskService.createTaskQuery().taskId(taskId).singleResult(); if (task == null) { return false; } if (task.getAssignee() != null && !task.getAssignee().equals(user.getUsername())) { return false; } taskService.claim(taskId, user.getUsername()); return true; } /** * 判断用户是否拥有此权限 * @param flowMyBusiness * @param user * @return */ private boolean isUserAuthorized(FlowMyBusiness flowMyBusiness, LoginUser user) { List todoUsers = JSON.parseArray(flowMyBusiness.getTodoUsers(), String.class); return todoUsers != null && todoUsers.contains(user.getUsername()); } @Override public void afterFlowHandle(FlowMyBusiness business) { } @Override public Object getBusinessDataById(String dataId) { return null; } @Override public Map flowValuesOfTask(String taskNameId, Map values) { return Collections.emptyMap(); } @Override public List flowCandidateUsernamesOfTask(String taskNameId, Map values) { //获取下一步处理人 Object object = values.get("NextAssignee"); return (List) object; } }