From f962534ae431779f3e341365af2e30fdd0afeb0f Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期日, 13 十月 2024 16:20:13 +0800
Subject: [PATCH] 点位在线率恢复为取优云和海康数据

---
 ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java |   24 +++++++++++++++---------
 1 files changed, 15 insertions(+), 9 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 4d824fa..0438581 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
@@ -240,9 +240,6 @@
                 notAddList.add(workOrder);
                 continue;
             }
-            //鏁板瓧鍓嶉潰琛�0
-            workOrderNum++;
-            workOrder.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum)));
             if (Objects.nonNull(point.getUnitId())) {
                 workOrder.setUnitId(Math.toIntExact(point.getUnitId()));
             }
@@ -265,7 +262,12 @@
         if (CollectionUtils.isEmpty(waitAddList)) {
             return Boolean.TRUE;
         }
-        //璁板綍宸ュ崟鏁�
+        //璁板綍宸ュ崟鏁�,琛ュ厖宸ュ崟鍙�
+        for (WorkOrder workOrder : waitAddList) {
+            //鏁板瓧鍓嶉潰琛�0
+            workOrderNum++;
+            workOrder.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum)));
+        }
         redisCache.setCacheObject(RedisConstant.WORKORDER_NUM, workOrderNum);
         redisCache.releaseLock(RedisConstant.WORKORDER_NUM_LOCK, requestId);
         // 淇濆瓨宸ュ崟鍜屾晠闅滅被鍨�
@@ -766,11 +768,15 @@
     public synchronized String getFrameImgByDevice(String deviceId, String channelId, String workOrderNo) throws Exception {
         String url = String.format(this.rtspServer + "/api/play/start/img/%s/%s", deviceId, channelId);
         String result = HttpUtils.sendGet(url);
-        JSONObject jsonObject = JSON.parseObject(result);
-        Object imgUrl = jsonObject.get("data");
-        imgUrl = Objects.isNull(imgUrl) ? "" : imgUrl;
-        log.info("鎷垮埌鍙栨祦鍥剧墖鍝嶅簲缁撴灉锛�" + imgUrl);
-        return (String) imgUrl;
+        log.info("鎷垮埌鍙栨祦鍥剧墖鍝嶅簲缁撴灉锛�" + result);
+        WVPResult wvpResult = JSON.parseObject(result, WVPResult.class);
+        if(wvpResult.getCode() == 0) {
+            Object imgUrl = (Object) wvpResult.getData();
+            imgUrl = Objects.isNull(imgUrl) ? "" : imgUrl;
+            log.info("鎷垮埌鍙栨祦鍥剧墖锛�" + imgUrl);
+            return (String) imgUrl;
+        }
+        return null;
 //        WVPResult wvpResult = JSON.parseObject(result, WVPResult.class);
 //        String imgUrl = null;
 //        if (wvpResult.getCode() == 0) {

--
Gitblit v1.8.0