| | |
|---|
| | | workOrderList.stream().filter(item -> { |
|---|
| | | return StringUtils.hasText(item.getSerialNumber()) && Objects.nonNull(item.getStatus()) && StringUtils.hasText(item.getErrorType()); |
|---|
| | | }); |
|---|
| | | if (CollectionUtils.isEmpty(workOrderList)) { |
|---|
| | | return Boolean.TRUE; |
|---|
| | | } |
|---|
| | | List<String> serialNumberList = workOrderList.stream().map(WorkOrder::getSerialNumber).collect(Collectors.toList()); |
|---|
| | | // 查出数据库中国标码对应的未完成的工单 |
|---|
| | | List<WorkOrder> inDatabaseWorkOrderList = new LambdaQueryChainWrapper<>(baseMapper) |
|---|
| | |
|---|
| | | YwPoint point = pointMapping.get(workOrder.getSerialNumber()); |
|---|
| | | if (Objects.isNull(point)) { |
|---|
| | | notAddList.add(workOrder); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | workOrder.setWorkOrderNo(IdUtils.timeAddRandomNO(5)); |
|---|
| | | workOrder.setUnitId(Math.toIntExact(point.getUnitId())); |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | waitAddList.removeAll(notAddList); |
|---|
| | | if (CollectionUtils.isEmpty(waitAddList)) { |
|---|
| | | return Boolean.TRUE; |
|---|
| | | } |
|---|
| | | this.saveBatch(waitAddList); |
|---|
| | | // 如果是直接下发，添加下发记录 |
|---|
| | | if (WorkOrderStatusEnum.DISTRIBUTED.equals(waitAddList.get(0).getStatus())) { |
|---|
