| | |
|---|
| | | // 查出重点点位、普通点位的处理时间 |
|---|
| | | SysConfig important = configMapper.checkConfigKeyUnique("important.wordkorder.time"); |
|---|
| | | SysConfig normal = configMapper.checkConfigKeyUnique("normal.wordkorder.alarm.time"); |
|---|
| | | // 如果即将生成工单，但是设备国标码查不到点位，则不添加？ |
|---|
| | | List<WorkOrder> notAddList = new ArrayList<>(); |
|---|
| | | for (WorkOrder workOrder : waitAddList) { |
|---|
| | | YwPoint point = pointMapping.get(workOrder.getSerialNumber()); |
|---|
| | | if (Objects.isNull(point)) { |
|---|
| | | notAddList.add(workOrder); |
|---|
| | | } |
|---|
| | | workOrder.setWorkOrderNo(IdUtils.timeAddRandomNO(5)); |
|---|
| | | workOrder.setUnitId(Math.toIntExact(point.getUnitId())); |
|---|
| | | if (point.getImportantTag() || point.getImportantCommandImageTag()) { |
|---|
| | |
|---|
| | | workOrder.setProcessingPeriod(Integer.valueOf(normal.getConfigValue())); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | waitAddList.removeAll(notAddList); |
|---|
| | | this.saveBatch(waitAddList); |
|---|
| | | // 如果是直接下发，添加下发记录 |
|---|
| | | if (WorkOrderStatusEnum.DISTRIBUTED.equals(waitAddList.get(0).getStatus())) { |
|---|
| | |
|---|
| | | public Result distributePage(DistributeWorkOrderQuery query) { |
|---|
| | | IPage<WorkOrderVO> page = PageUtil.getPage(query, WorkOrderVO.class); |
|---|
| | | baseMapper.distributePage(page, query); |
|---|
| | | page.getRecords().stream().forEach(workOrder -> { |
|---|
| | | if (StringUtils.hasText(workOrder.getPointTag()) && workOrder.getPointTag().contains(IMPORTANT)) { |
|---|
| | | workOrder.setImportant(Boolean.TRUE); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | return Result.ok().data(page).total(page.getTotal()); |
|---|
| | | } |
|---|
| | | |
|---|
