From 0f24a1b96c99e8c28ae9572efe9507b3eafbf079 Mon Sep 17 00:00:00 2001
From: "1378012178@qq.com" <1378012178@qq.com>
Date: Wed, 29 Apr 2026 10:29:25 +0800
Subject: [PATCH] =?UTF-8?q?tplink=E4=B8=8A=E4=BC=A0=E5=AE=9A=E6=97=B6?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=94=B9=E4=B8=BA=E4=BC=A0=E5=88=B0=E8=B5=84?=
 =?UTF-8?q?=E6=BA=90=E6=9C=8D=E5=8A=A1=E5=99=A8=E4=B8=AD=EF=BC=88=E5=8E=9F?=
 =?UTF-8?q?=EF=BC=9A=E4=BC=A0=E5=88=B0COS=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/CameraInfoJobServiceImpl.java        | 12 +--
 .../order/job/DirectiveOrderEndTplinkJob.java | 81 +++++++++++--------
 2 files changed, 52 insertions(+), 41 deletions(-)

diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/service/impl/CameraInfoJobServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/service/impl/CameraInfoJobServiceImpl.java
index 7c2e0a9b..15cd8e01 100644
--- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/service/impl/CameraInfoJobServiceImpl.java
+++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/service/impl/CameraInfoJobServiceImpl.java
@@ -70,7 +70,7 @@ public class CameraInfoJobServiceImpl extends ServiceImpl<CameraInfoMapper, Came
             String process = result.getStr("process");
             resultMap.put("result", "success");
             resultMap.put("process", process);
-            resultMap.put("url",result.getStr("url"));
+            resultMap.put("url", result.getStr("url"));
             return resultMap;
         } else {
             String errMsg = jsonObject.getStr("msg");
@@ -106,7 +106,7 @@ public class CameraInfoJobServiceImpl extends ServiceImpl<CameraInfoMapper, Came
             String process = result.getStr("process");
             resultMap.put("result", "success");
             resultMap.put("process", process);
-            resultMap.put("url",result.getStr("url"));
+            resultMap.put("url", result.getStr("url"));
             return resultMap;
         } else {
             String errMsg = jsonObject.getStr("msg");
@@ -204,7 +204,7 @@ public class CameraInfoJobServiceImpl extends ServiceImpl<CameraInfoMapper, Came
             ftpUploadpath = cameraInfo.getFtpUploadpath();
         }
         //文件夹不存在就创建 上传到COS不需要管这个问题了
-//        mkdirsFolder(ftpUploadpath);
+        mkdirsFolder(ftpUploadpath);
         String deviceIndex = cameraInfo.getDeviceIndex();
         String parentId = cameraInfo.getParentId();
         String fileName = cameraInfo.getFileName();
@@ -228,8 +228,8 @@ public class CameraInfoJobServiceImpl extends ServiceImpl<CameraInfoMapper, Came
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         Date date = sdf.parse(cameraInfo.getStartTime());
         Date date2 = sdf.parse(cameraInfo.getEndTime());
-        long startTime = date.getTime() / 1000;
-        long endTime = date2.getTime() / 1000;
+        long startTime = date.getTime() / 1000 - 1;
+        long endTime = date2.getTime() / 1000 + 1;
 //        long startTime = 1765993096;
 //        long endTime = 1765993156;
         sb.append("\"startTime\"").append(":").append(startTime).append(",");
@@ -247,7 +247,7 @@ public class CameraInfoJobServiceImpl extends ServiceImpl<CameraInfoMapper, Came
         JSONObject jsonObject = new JSONObject(res);
         String errorCode = jsonObject.getStr("error_code");
         Map<String, Object> resultMap = Maps.newHashMap();
-        resultMap.put("tplinkParams",sb.toString());
+        resultMap.put("tplinkParams", sb.toString());
         if (errorCode.equals("0")) {
             JSONObject result = jsonObject.getJSONObject("result");
             String taskId = result.getStr("taskId");
diff --git a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/order/job/DirectiveOrderEndTplinkJob.java b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/order/job/DirectiveOrderEndTplinkJob.java
index e6930acc..9097698f 100644
--- a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/order/job/DirectiveOrderEndTplinkJob.java
+++ b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/biz/order/job/DirectiveOrderEndTplinkJob.java
@@ -60,46 +60,57 @@ public class DirectiveOrderEndTplinkJob implements Job {
         //机构编码
         JSONObject deptInfo = sysBaseAPI.getDeptInfo();
         String orgCode = deptInfo.getString("code");
-        //任务一：COS上传进度查询
+
+        //任务一：根据taskId查询tplink进度
         {
-            //已完成的视频
-            List<String> finishPathList = Lists.newArrayList();
-            //查询上传中的进度 cos_status = 1的
             List<DirectiveOrder> directiveOrderList = directiveOrderService.getUploadingTplink();
             directiveOrderList.forEach(order -> {
-                try {
-                    CosFileInfoEntity cosResult = cosFileUtil.checkFileStatus(order.getTplinkPath());
-                    if (cosResult.isExists()) {
-                        //上传完了
-                        order.setCosStatus("2");//上传成功
-                        order.setOrderEndTime(new Date());//工单结束时间
-                        order.setTplinkCrc64(cosResult.getCrc64());//视频切片crc64
-                        order.setCosLen(cosResult.getFileSize() + "");
-                        //记录需要进行CDN预热的文件
-                        finishPathList.add(order.getTplinkPath());
-                    } else if (cosResult.isSuccess()) {
-                        //传输中
-                        order.setCosStatus("1");//上传中
-                    } else {
-                        //失败了
-                        order.setCosStatus("3");//上传失败
-                    }
-                    //更新工单数据
-                    directiveOrderService.updateById(order);
-                } catch (Exception e) {
-                    e.printStackTrace();
-                }
+                Map<String, Object> result = tplinkService.getUploadToServerProcess(order.getTplinkTaskId());
+                System.out.println("↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓");
+                System.out.println(result.toString());
+                System.out.println("↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑");
             });
-            //本轮所有文件都查询完结果之后
-            try {
-                if (cdnEnabled && !CollectionUtils.isEmpty(finishPathList)) {
-                    //CDN预热
-                    cosFileUtil.batchPreloadCdn(finishPathList);
-                }
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
         }
+//        //任务一：COS上传进度查询
+//        {
+//            //已完成的视频
+//            List<String> finishPathList = Lists.newArrayList();
+//            //查询上传中的进度 cos_status = 1的
+//            List<DirectiveOrder> directiveOrderList = directiveOrderService.getUploadingTplink();
+//            directiveOrderList.forEach(order -> {
+//                try {
+//                    CosFileInfoEntity cosResult = cosFileUtil.checkFileStatus(order.getTplinkPath());
+//                    if (cosResult.isExists()) {
+//                        //上传完了
+//                        order.setCosStatus("2");//上传成功
+//                        order.setOrderEndTime(new Date());//工单结束时间
+//                        order.setTplinkCrc64(cosResult.getCrc64());//视频切片crc64
+//                        order.setCosLen(cosResult.getFileSize() + "");
+//                        //记录需要进行CDN预热的文件
+//                        finishPathList.add(order.getTplinkPath());
+//                    } else if (cosResult.isSuccess()) {
+//                        //传输中
+//                        order.setCosStatus("1");//上传中
+//                    } else {
+//                        //失败了
+//                        order.setCosStatus("3");//上传失败
+//                    }
+//                    //更新工单数据
+//                    directiveOrderService.updateById(order);
+//                } catch (Exception e) {
+//                    e.printStackTrace();
+//                }
+//            });
+//            //本轮所有文件都查询完结果之后
+//            try {
+//                if (cdnEnabled && !CollectionUtils.isEmpty(finishPathList)) {
+//                    //CDN预热
+//                    cosFileUtil.batchPreloadCdn(finishPathList);
+//                }
+//            } catch (Exception e) {
+//                e.printStackTrace();
+//            }
+//        }
 
 
         //任务二：处理tplink上传