| | |
|---|
| | | private final TMonitorMapper monitorMapper; |
|---|
| | | private final SysConfigMapper configMapper; |
|---|
| | | private final ServerConfig serverConfig; |
|---|
| | | private final ReportMapper reportMapper; |
|---|
| | | |
|---|
| | | @Value("${rtsp.server:http://127.0.0.1:7788}") |
|---|
| | | private String rtspServer; |
|---|
| | |
|---|
| | | Map<String, WorkOrder> mapping = inDatabaseWorkOrderList.stream().collect((Collectors.toMap(WorkOrder::getSerialNumber, workOrder -> workOrder))); |
|---|
| | | List<WorkOrder> waitAddList = new ArrayList<>(48); |
|---|
| | | Integer updateNum = 0; |
|---|
| | | // TODO 查询是否报备过，更新故障类型 |
|---|
| | | |
|---|
| | | for (WorkOrder workOrder : workOrderList) { |
|---|
| | | WorkOrder databaseWorkOrder = mapping.get(workOrder.getSerialNumber()); |
|---|
| | | if (Objects.nonNull(databaseWorkOrder)) { |
|---|
| | |
|---|
| | | databaseWorkOrder.setUpdateTime(now); |
|---|
| | | baseMapper.updateById(databaseWorkOrder); |
|---|
| | | updateNum++; |
|---|
| | | // 同时新增一个运维处理信息，表明此工单被调整 TODO |
|---|
| | | // 同时新增一个运维处理信息，表明此工单被调整 |
|---|
| | | WorkOrderYwConditionRecord ywRecord = new WorkOrderYwConditionRecord(); |
|---|
| | | ywRecord.setWorkOrderId(databaseWorkOrder.getId()); |
|---|
| | | ywRecord.setCommitUser(1); |
|---|
| | | ywRecord.setYwCondition("故障类型更新，工单状态调整为待处理"); |
|---|
| | | ywRecord.setCreateTime(new Date()); |
|---|
| | | workOrderYwConditionRecordMapper.insert(ywRecord); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | workOrder.setCreateTime(new Date()); |
|---|
| | | workOrder.setUpdateTime(new Date()); |
|---|
| | | // 如果报备过，使用最新报备的错误类型 |
|---|
| | | Report report = reportMapper.checkPointReported(workOrder.getSerialNumber()); |
|---|
| | | if (Objects.nonNull(report)) { |
|---|
| | | workOrder.setErrorType(report.getErrorType()); |
|---|
| | | } |
|---|
| | | waitAddList.add(workOrder); |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | workOrderYwConditionRecord.setCommitUser(SecurityUtils.getLoginUser().getUserId().intValue()); |
|---|
| | | workOrderYwConditionRecord.setYwCondition(form.getYwCondition()); |
|---|
| | | workOrderYwConditionRecord.setYwProofMaterials(form.getYwProofMaterials()); |
|---|
| | | workOrderYwConditionRecord.setSysMsg(Boolean.FALSE); |
|---|
| | | workOrderYwConditionRecordMapper.insert(workOrderYwConditionRecord); |
|---|
| | | return Result.ok("操作成功"); |
|---|
| | | } |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public Result selectYwConditionByYwId(Integer id) { |
|---|
| | | List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(id); |
|---|
| | | ywConditionList.stream().forEach(item -> { |
|---|
| | | if (Objects.nonNull(item.getSysMsg()) && item.getSysMsg()) { |
|---|
| | | item.setCommitUserName("系统消息"); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | return Result.ok().data(ywConditionList); |
|---|
| | | } |
|---|
| | | |
|---|
