From 44cd2d171062c9b07a0eb047cd0ac80d06188e8c Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期三, 16 十月 2024 11:58:18 +0800 Subject: [PATCH] 工单bug,数据中心在线率增加存ping状态 --- ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java | 47 ++++++++++++++++++++++++----------------------- 1 files changed, 24 insertions(+), 23 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java index 0438581..dba4383 100644 --- a/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java +++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java @@ -211,6 +211,25 @@ List<WorkOrder> notAddList = new ArrayList<>(); //鏌edis浠婃棩宸ュ崟鏁伴噺 int workOrderNum = 0; + for (WorkOrder workOrder : waitAddList) { + YwPoint point = pointMapping.get(workOrder.getSerialNumber()); + if (Objects.isNull(point)) { + notAddList.add(workOrder); + continue; + } + if (Objects.nonNull(point.getUnitId())) { + workOrder.setUnitId(Math.toIntExact(point.getUnitId())); + } + if (point.getImportantTag() || point.getImportantCommandImageTag()) { + workOrder.setProcessingPeriod(Integer.valueOf(important.getConfigValue())); + } else { + workOrder.setProcessingPeriod(Integer.valueOf(normal.getConfigValue())); + } + } + waitAddList.removeAll(notAddList); + if (CollectionUtils.isEmpty(waitAddList)) { + return Boolean.TRUE; + } //UUID浣滀负value锛屼繚璇佷笂閿佺殑绾跨▼鑷繁瑙i攣 String requestId = IdUtils.fastSimpleUUID(); try { @@ -234,20 +253,11 @@ log.error("鑾峰彇閿佸紓甯�"); return Boolean.FALSE; } + //璁板綍宸ュ崟鏁�,琛ュ厖宸ュ崟鍙� for (WorkOrder workOrder : waitAddList) { - YwPoint point = pointMapping.get(workOrder.getSerialNumber()); - if (Objects.isNull(point)) { - notAddList.add(workOrder); - continue; - } - if (Objects.nonNull(point.getUnitId())) { - workOrder.setUnitId(Math.toIntExact(point.getUnitId())); - } - if (point.getImportantTag() || point.getImportantCommandImageTag()) { - workOrder.setProcessingPeriod(Integer.valueOf(important.getConfigValue())); - } else { - workOrder.setProcessingPeriod(Integer.valueOf(normal.getConfigValue())); - } + //鏁板瓧鍓嶉潰琛�0 + workOrderNum++; + workOrder.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum))); // 淇濆瓨閿欒绫诲瀷 for (String errorType : workOrder.getErrorTypeList()) { WorkOrderErrorType workOrderErrorType = new WorkOrderErrorType(); @@ -257,16 +267,7 @@ workOrderErrorType.setErrorName(errorType); waitAddErrorTypeList.add(workOrderErrorType); } - } - waitAddList.removeAll(notAddList); - if (CollectionUtils.isEmpty(waitAddList)) { - return Boolean.TRUE; - } - //璁板綍宸ュ崟鏁�,琛ュ厖宸ュ崟鍙� - for (WorkOrder workOrder : waitAddList) { - //鏁板瓧鍓嶉潰琛�0 - workOrderNum++; - workOrder.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum))); + log.info("鍗冲皢鐢熸垚鐨勫伐鍗�:{}",workOrder); } redisCache.setCacheObject(RedisConstant.WORKORDER_NUM, workOrderNum); redisCache.releaseLock(RedisConstant.WORKORDER_NUM_LOCK, requestId); -- Gitblit v1.8.0