| | |
|---|
| | | )).values().stream().collect(Collectors.toList()); |
|---|
| | | List<String> serialNumberList = workOrderList.stream().map(WorkOrder::getSerialNumber).collect(Collectors.toList()); |
|---|
| | | // 查出数据库中国标码对应的未完成的工单 |
|---|
| | | List<WorkOrder> inDatabaseWorkOrderList = new LambdaQueryChainWrapper<>(baseMapper) |
|---|
| | | .select(WorkOrder::getId, WorkOrder::getSerialNumber, WorkOrder::getStatus, WorkOrder::getWorkOrderNo) |
|---|
| | | .in(WorkOrder::getSerialNumber, serialNumberList) |
|---|
| | | .ne(WorkOrder::getStatus, WorkOrderStatusEnum.AUDITING_SUCCESS) |
|---|
| | | .list(); |
|---|
| | | List<WorkOrder> inDatabaseWorkOrderList = baseMapper.getNotFinishedWorkOrders(serialNumberList); |
|---|
| | | inDatabaseWorkOrderList.stream().forEach(item -> { |
|---|
| | | if (StringUtils.hasText(item.getErrorType())) { |
|---|
| | | item.setErrorTypeList(List.of(item.getErrorType().split(","))); |
|---|
| | | } else { |
|---|
| | | item.setErrorTypeList(new ArrayList<>(1)); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | Map<String, WorkOrder> mapping = inDatabaseWorkOrderList.stream().collect((Collectors.toMap(WorkOrder::getSerialNumber, workOrder -> workOrder))); |
|---|
| | | List<WorkOrder> waitAddList = new ArrayList<>(48); |
|---|
| | | List<WorkOrderErrorType> waitAddErrorTypeList = new ArrayList<>(48); |
|---|
| | |
|---|
| | | for (WorkOrder workOrder : workOrderList) { |
|---|
| | | WorkOrder databaseWorkOrder = mapping.get(workOrder.getSerialNumber()); |
|---|
| | | if (Objects.nonNull(databaseWorkOrder)) { |
|---|
| | | List<String> errorNameList = workOrderErrorTypeService.getBaseMapper().getNotFinishWorkOrderErrors(databaseWorkOrder.getWorkOrderNo()); |
|---|
| | | List<String> errorNameList = databaseWorkOrder.getErrorTypeList(); |
|---|
| | | List<String> errorTypes = workOrder.getErrorTypeList(); |
|---|
| | | if (errorNameList.containsAll(errorTypes)) { |
|---|
| | | // 如果，国标码、故障类型都一样，则跳过不处理 |
|---|
