文件系统，设备升级

iot-access/access-api/src/main/java/com/njcn/access/enums/AccessResponseEnum.java

@@ -75,7 +75,15 @@ public enum AccessResponseEnum {
     FILE_CHECK_ERROR("A0312","文件校验码不一致!"),
 
     CLD_MODEL_EXIST("A0313","云前置模板已存在,请先删除再录入!"),
-    ;
+
+    /**
+     * A3001 ~ A3099 用于zlevent模块的枚举
+     * <p>
+     */
+    FILE_DOWNLOAD_FAIL("A3002", "文件下载失败！"),
+    UNKNOWN_BUSINESS_TYPE_CODE("A3003", "未知业务type码"),
+    FILE_UPLOAD_FAIL("A3004", "文件上传失败！"),
+    TIME_OUT("A3005", "前置响应超时！"),;
 
     private final String code;
 

iot-access/access-api/src/main/java/com/njcn/access/enums/TypeEnum.java

@@ -45,6 +45,19 @@ public enum TypeEnum {
     TYPE_29("9217","设备心跳请求"),
     TYPE_30("4865","设备数据主动上送"),
     TYPE_31("8503","设备控制命令"),
+    READ_FILE_DIR("1101", "读取文件目录"),
+    FILE_DOWNLOAD("1102", "文件下载"),
+    FIXED_VALUE("1103", "定值读取/写入"),
+    INNER_FIXED_VALUE("1104", "内部定值读取/写入"),
+
+    WORKING_LOG("1111","设备运行日志"),
+    DEVICE_VERSION("1112","设备版本信息"),
+    DEVICE_REBOOT("1114","设备重启"),
+    DEVICE_UPGRADE("1115","设备升级"),
+    FILE_UPLOAD("1116","文件上传"),
+    FILE_DELETE("1117","文件删除"),
+    MKDIR("1118","目录创建"),
+    DIR_DELETE("1119","目录删除"),
 
     /**
      * 数据类型

iot-access/access-api/src/main/java/com/njcn/access/utils/SendMessageUtil.java

@@ -1,7 +1,11 @@
 package com.njcn.access.utils;
 
 import com.alibaba.nacos.shaded.com.google.gson.Gson;
+import com.njcn.access.enums.AccessResponseEnum;
 import com.njcn.access.pojo.dto.NoticeUserDto;
+import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.redis.pojo.enums.AppRedisKey;
+import com.njcn.redis.utils.RedisUtil;
 import lombok.AllArgsConstructor;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -25,6 +29,7 @@ import java.nio.charset.StandardCharsets;
 @AllArgsConstructor
 @RequiredArgsConstructor
 public class SendMessageUtil {
+    private final RedisUtil redisUtil;
 
     @Value("${app.sendUrl:https://fc-mp-ff7b310f-94c9-4468-8260-109111c0a6b2.next.bspapp.com/push}")
     private String appSendUrl;
@@ -67,4 +72,27 @@ public class SendMessageUtil {
             e.getMessage();
         }
     }
+
+    /**
+     * 轮询 Redis 等待响应
+     */
+    public String waitForResponse(String guid, int timeoutSeconds) {
+        long startTime = System.currentTimeMillis();
+        while (System.currentTimeMillis() - startTime < timeoutSeconds * 1000L) {
+            String response = redisUtil.getStringByKey(AppRedisKey.COMMON_RESOPNSE + guid);
+            if (response != null) {
+                redisUtil.delete(AppRedisKey.COMMON_REQUEST + guid);
+                redisUtil.delete(AppRedisKey.COMMON_RESOPNSE + guid);
+                return response;
+            }
+            try {
+                Thread.sleep(100); // 100ms 轮询一次
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+                break;
+            }
+        }
+        throw new BusinessException(AccessResponseEnum.TIME_OUT);
+    }
+
 }

iot-access/access-boot/pom.xml

@@ -20,6 +20,10 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>com.github.tocrhz</groupId>
+            <artifactId>mqtt-spring-boot-starter</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.eclipse.paho</groupId>

iot-analysis/analysis-rt/rt-boot/pom.xml

@@ -21,6 +21,10 @@
   </properties>
 
   <dependencies>
+    <dependency>
+      <groupId>com.github.tocrhz</groupId>
+      <artifactId>mqtt-spring-boot-starter</artifactId>
+    </dependency>
     <dependency>
       <groupId>com.njcn</groupId>
       <artifactId>common-web</artifactId>

iot-analysis/analysis-stat/stat-boot/pom.xml

@@ -21,6 +21,10 @@
   </properties>
 
   <dependencies>
+    <dependency>
+      <groupId>com.github.tocrhz</groupId>
+      <artifactId>mqtt-spring-boot-starter</artifactId>
+    </dependency>
     <dependency>
       <groupId>com.njcn</groupId>
       <artifactId>common-web</artifactId>

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/CommonBaseMessage.java

@@ -0,0 +1,46 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.fasterxml.jackson.annotation.JsonAlias;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.njcn.middle.rocket.domain.BaseMessage;
+import lombok.Data;
+
+/**
+ * @author caozehui
+ * @data 2026-03-31
+ */
+@Data
+public class CommonBaseMessage extends BaseMessage {
+    /**
+     * 消息请求的唯一标识
+     */
+    @JsonProperty("guid")
+    @JsonAlias({"guid"})
+    private String guid;
+
+    /**
+     * 设备Mac
+     */
+    @JsonProperty("devMac")
+    @JsonAlias({"Dev_mac"})
+    private String devMac;
+
+    /**
+     * 前置Id
+     */
+    @JsonProperty("frontId")
+    @JsonAlias({"FrontId"})
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JsonProperty("node")
+    @JsonAlias({"Node"})
+    private Integer node;
+
+    @JsonProperty("detail")
+    @JsonAlias({"Detail"})
+    private Object detail;
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/DevVersionResponeDTO.java

@@ -0,0 +1,205 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * @author caozehui
+ * @data 2026-03-16
+ */
+@Data
+public class DevVersionResponeDTO extends CommonBaseMessage {
+
+    @JsonProperty("Detail")
+    private DevVersionResponeDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JsonProperty("Type")
+        private Integer type;
+
+        @JsonProperty("Msg")
+        private DevVersionResponeDTO.Msg msg;
+    }
+
+    @Data
+    public static class Msg {
+
+        @JsonProperty("Code")
+        private Integer code;
+
+
+        @JsonProperty("VersionInfo")
+        private VersionInfo versionInfo;
+    }
+
+    @Data
+    public static class VersionInfo {
+        /**
+         * 装置基础型号（只用于程序升级鉴别）
+         */
+        @JsonProperty("BaseModel")
+        private String baseModel;
+
+        /**
+         * 云服务协议版本
+         */
+        @JsonProperty("CloudProtocolVer")
+        private String cloudProtocolVer;
+
+        /**
+         * 应用程序版本号
+         */
+        @JsonProperty("AppVersion")
+        private String appVersion;
+
+        /**
+         * 应用程序版本日期
+         */
+        @JsonProperty("AppDate")
+        private LocalDate appDate;
+
+        /**
+         * 应用程序校验码
+         */
+        @JsonProperty("AppChecksum")
+        private String appChecksum;
+
+        /**
+         * 电压接线方式（0-星1-三角2-V）
+         */
+        @JsonProperty("VoltageWiring")
+        private String voltageWiring;
+
+        /**
+         * 电流B相是否合成（0-否1-是）
+         */
+        @JsonProperty("CurrentBSynthetic")
+        private String currentBSynthetic;
+
+        /**
+         * 数据统计时间间隔（单位分钟）
+         */
+        @JsonProperty("DataStatInterval")
+        private Integer dataStatInterval;
+
+        /**
+         * 额定电压（二次值，单位V）
+         */
+        @JsonProperty("RatedVoltage")
+        private Double ratedVoltage;
+
+        /**
+         * PT变比
+         */
+        @JsonProperty("PTRatio")
+        private Integer ptRatio;
+
+        /**
+         * CT变比
+         */
+        @JsonProperty("CTRatio")
+        private Integer ctRatio;
+
+        /**
+         * sntp对时IP
+         */
+        @JsonProperty("SntpIP")
+        private String sntpIP;
+
+        /**
+         * sntp对时端口
+         */
+        @JsonProperty("SntpPort")
+        private Integer sntpPort;
+
+        /**
+         * sntp对时间隔（单位分钟）
+         */
+        @JsonProperty("SntpInterval")
+        private Integer sntpInterval;
+
+        /**
+         * Web端口
+         */
+        @JsonProperty("WebPort")
+        private Integer webPort;
+
+        /**
+         * FTP端口
+         */
+        @JsonProperty("FtpPort")
+        private Integer ftpPort;
+
+        /**
+         * Pqdif文件时间间隔（单位小时）
+         */
+        @JsonProperty("PqdifInterval")
+        private Integer pqdifInterval;
+
+        /**
+         * 录波文件包含文件类型数
+         */
+        @JsonProperty("WaveFileTypeCount")
+        private Integer waveFileTypeCount;
+
+        /**
+         * 特殊程序版本信息
+         */
+        @JsonProperty("SpecialVersion")
+        private String specialVersion;
+
+        /**
+         * 装置型号（具体型号全称）
+         */
+        @JsonProperty("DeviceModel")
+        private String deviceModel;
+
+        /**
+         * 谐波电度版本标志（0-否1-是）
+         */
+        @JsonProperty("HarmonicEnergyFlag")
+        private Integer harmonicEnergyFlag;
+
+        /**
+         * 物理设备名称（仅用于上位机录波文件拼接）
+         */
+        @JsonProperty("PhysicalName")
+        private String physicalName;
+
+        /**
+         * 录波LD名称（仅用于上位机录波文件拼接）
+         */
+        @JsonProperty("WaveLDName")
+        private String waveLDName;
+
+        /**
+         * 高频谐波功能标志（0-否1-是）
+         */
+        @JsonProperty("HighFreqHarmonicFlag")
+        private Integer highFreqHarmonicFlag;
+
+        /**
+         * 投入的通讯协议（2字节十六进制数）
+         */
+        @JsonProperty("CommProtocols")
+        private Integer commProtocols;
+
+        /**
+         * 投入的对时方式选择（2字节十六进制数）
+         */
+        @JsonProperty("TimeSyncMethods")
+        private Integer timeSyncMethods;
+
+        /**
+         * 装置功能配置（2字节十六进制数）
+         */
+        @JsonProperty("DeviceFunctions")
+        private Integer deviceFunctions;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/DeviceVersionRequestDTO.java

@@ -0,0 +1,55 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author caozehui
+ * @data 2026-04-01
+ */
+@Data
+public class DeviceVersionRequestDTO {
+    /**
+     * 消息请求的唯一标识
+     */
+    @JSONField(name = "guid")
+    private String guid;
+
+    /**
+     * 设备ID
+     */
+    @JSONField(name = "Dev_id")
+    private String devId;
+
+    /**
+     * 前置Id
+     */
+    @JSONField(name = "FrontId")
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JSONField(name = "Node")
+    private Integer node;
+
+    @JSONField(name = "Detail")
+    private DeviceVersionRequestDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JSONField(name = "Type")
+        private Integer type;
+
+        /**
+         * 详情
+         */
+        @JSONField(name = "Msg")
+        private Map<String, Object> msg;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/FileDownloadRequestDTO.java

@@ -0,0 +1,60 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * @author caozehui
+ * @data 2026-03-16
+ */
+@Data
+public class FileDownloadRequestDTO {
+
+    /**
+     * 消息请求的唯一标识
+     */
+    @JSONField(name = "guid")
+    private String guid;
+
+    /**
+     * 设备ID
+     */
+    @JSONField(name = "Dev_id")
+    private String devId;
+
+    /**
+     * 前置Id
+     */
+    @JSONField(name = "FrontId")
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JSONField(name = "Node")
+    private Integer node;
+
+    @JSONField(name = "Detail")
+    private FileDownloadRequestDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JSONField(name = "Type")
+        private Integer type;
+
+        @JSONField(name = "Msg")
+        private FileDownloadRequestDTO.Msg msg;
+    }
+
+    @Data
+    public static class Msg {
+        /**
+         * 设备的文件名，例如：/etc/vol1_stat.txt
+         */
+        @JSONField(name = "Name")
+        private String name;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/FileDownloadResponeDTO.java

@@ -0,0 +1,42 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * @author caozehui
+ * @data 2026-03-16
+ */
+@Data
+public class FileDownloadResponeDTO extends CommonBaseMessage {
+
+    @JsonProperty("Detail")
+    private FileDownloadResponeDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JsonProperty("Type")
+        private Integer type;
+
+        @JsonProperty("Msg")
+        private FileDownloadResponeDTO.Msg msg;
+    }
+
+    @Data
+    public static class Msg {
+        /**
+         * 文件名称，例如 /etc/vol1_stat.txt
+         */
+        @JsonProperty("Name")
+        private String name;
+
+        /**
+         * 远端文件名，例如 /download/vol1_stat.txt
+         */
+        @JsonProperty("RemoteName")
+        private String remoteName;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/FileInfoRequestDTO.java

@@ -0,0 +1,57 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * @author caozehui
+ * @data 2026-03-18
+ */
+@Data
+public class FileInfoRequestDTO {
+    /**
+     * 消息请求的唯一标识
+     */
+    @JSONField(name = "guid")
+    private String guid;
+
+    /**
+     * 设备ID
+     */
+    @JSONField(name = "Dev_id")
+    private String devId;
+
+    /**
+     * 前置Id
+     */
+    @JSONField(name = "FrontId")
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JSONField(name = "Node")
+    private Integer node;
+
+    @JSONField(name = "Detail")
+    private FileInfoRequestDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JSONField(name = "Type")
+        private Integer type;
+
+        @JSONField(name = "Msg")
+        private FileInfoRequestDTO.Msg msg;
+    }
+
+    @Data
+    public static class Msg {
+
+        @JSONField(name = "Name")
+        private String name;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/FileInfoResponseDTO.java

@@ -0,0 +1,79 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.fasterxml.jackson.annotation.JsonAlias;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author caozehui
+ * @data 2026-03-18
+ */
+@Data
+public class FileInfoResponseDTO extends CommonBaseMessage {
+
+    @JsonProperty("detail")
+    @JsonAlias({"Detail"})
+    private FileInfoResponseDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JsonProperty("type")
+        @JsonAlias({"Type"})
+        private Integer type;
+
+        /**
+         * 消息主体
+         */
+        @JsonProperty("msg")
+        @JsonAlias({"Msg"})
+        private FileInfoResponseDTO.Msg msg;
+
+        /**
+         * 响应码
+         */
+        @JsonProperty("code")
+        @JsonAlias({"Code"})
+        private Integer code;
+    }
+
+    @Data
+    public static class Msg {
+        /**
+         * 目录信息数组
+         */
+        @JsonProperty("dirInfo")
+        @JsonAlias({"DirInfo"})
+        private List<FileInfoResponseDTO.ResourceElement> dirInfo;
+    }
+
+    @Data
+    public static class ResourceElement {
+        /**
+         * 文件名/文件夹名称
+         */
+        @JsonProperty("name")
+        @JsonAlias({"Name"})
+        private String name;
+
+        /**
+         * 类型，文件/文件夹
+         */
+        @JsonProperty("type")
+        @JsonAlias({"Type"})
+        private String type;
+
+        /**
+         * 目录信息数组单个元素的数据成员大小
+         */
+        @JsonProperty("size")
+        @JsonAlias({"Size"})
+        private Integer size;
+
+        private String prjDataPath;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/FileOrDirDeleteRequestDTO.java

@@ -0,0 +1,58 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * @author caozehui
+ * @data 2026-04-01
+ */
+@Data
+public class FileOrDirDeleteRequestDTO {
+
+    /**
+     * 消息请求的唯一标识
+     */
+    @JSONField(name = "guid")
+    private String guid;
+
+    /**
+     * 设备ID
+     */
+    @JSONField(name = "Dev_id")
+    private String devId;
+
+    /**
+     * 前置Id
+     */
+    @JSONField(name = "FrontId")
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JSONField(name = "Node")
+    private Integer node;
+
+    @JSONField(name = "Detail")
+    private FileOrDirDeleteRequestDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JSONField(name = "Type")
+        private Integer type;
+
+        @JSONField(name = "Msg")
+        private FileOrDirDeleteRequestDTO.Msg msg;
+    }
+
+    @Data
+    public static class Msg {
+
+        @JSONField(name = "Name")
+        private String name;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/FileOrDirDeleteResponeDTO.java

@@ -0,0 +1,39 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author caozehui
+ * @data 2026-03-30
+ */
+@Data
+public class FileOrDirDeleteResponeDTO extends CommonBaseMessage {
+
+    @JsonProperty("Detail")
+    private FileOrDirDeleteResponeDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JsonProperty("Type")
+        private Integer type;
+
+        /**
+         * 响应主体
+         */
+        @JsonProperty("Msg")
+        private Map<String, Object> msg;
+
+        /**
+         * 响应码
+         */
+        @JsonProperty("Code")
+        private Integer code;
+    }
+
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/FileUploadRequestDTO.java

@@ -0,0 +1,60 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * @author caozehui
+ * @data 2026-03-18
+ */
+@Data
+public class FileUploadRequestDTO {
+    /**
+     * 消息请求的唯一标识
+     */
+    @JSONField(name = "guid")
+    private String guid;
+
+    /**
+     * 设备ID
+     */
+    @JSONField(name = "Dev_id")
+    private String devId;
+
+    /**
+     * 前置Id
+     */
+    @JSONField(name = "FrontId")
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JSONField(name = "Node")
+    private Integer node;
+
+    @JSONField(name = "Detail")
+    private FileUploadRequestDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JSONField(name = "Type")
+        private Integer type;
+
+        @JSONField(name = "Msg")
+        private FileUploadRequestDTO.Msg msg;
+    }
+
+    @Data
+    public static class Msg {
+
+        @JSONField(name = "Name")
+        private String name;
+
+        @JSONField(name = "RemoteName")
+        private String remoteName;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/FileUploadResponeDTO.java

@@ -0,0 +1,39 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author caozehui
+ * @data 2026-03-30
+ */
+@Data
+public class FileUploadResponeDTO extends CommonBaseMessage {
+
+    @JsonProperty("Detail")
+    private FileUploadResponeDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JsonProperty("Type")
+        private Integer type;
+
+        /**
+         * 响应主体
+         */
+        @JsonProperty("Msg")
+        private Map<String, Object> msg;
+
+        /**
+         * 响应码
+         */
+        @JsonProperty("Code")
+        private Integer code;
+    }
+
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/MkdirRequestDTO.java

@@ -0,0 +1,57 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * @author caozehui
+ * @data 2026-03-18
+ */
+@Data
+public class MkdirRequestDTO {
+    /**
+     * 消息请求的唯一标识
+     */
+    @JSONField(name = "guid")
+    private String guid;
+
+    /**
+     * 设备ID
+     */
+    @JSONField(name = "Dev_id")
+    private String devId;
+
+    /**
+     * 前置Id
+     */
+    @JSONField(name = "FrontId")
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JSONField(name = "Node")
+    private Integer node;
+
+    @JSONField(name = "Detail")
+    private MkdirRequestDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JSONField(name = "Type")
+        private Integer type;
+
+        @JSONField(name = "Msg")
+        private MkdirRequestDTO.Msg msg;
+    }
+
+    @Data
+    public static class Msg {
+
+        @JSONField(name = "Name")
+        private String name;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/MkdirResponeDTO.java

@@ -0,0 +1,39 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author caozehui
+ * @data 2026-03-30
+ */
+@Data
+public class MkdirResponeDTO extends CommonBaseMessage {
+
+    @JsonProperty("Detail")
+    private MkdirResponeDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JsonProperty("Type")
+        private Integer type;
+
+        /**
+         * 响应主体
+         */
+        @JsonProperty("Msg")
+        private Map<String, Object> msg;
+
+        /**
+         * 响应码
+         */
+        @JsonProperty("Code")
+        private Integer code;
+    }
+
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/RebootRequestDTO.java

@@ -0,0 +1,55 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author caozehui
+ * @data 2026-04-01
+ */
+@Data
+public class RebootRequestDTO {
+    /**
+     * 消息请求的唯一标识
+     */
+    @JSONField(name = "guid")
+    private String guid;
+
+    /**
+     * 设备ID
+     */
+    @JSONField(name = "Dev_id")
+    private String devId;
+
+    /**
+     * 前置Id
+     */
+    @JSONField(name = "FrontId")
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JSONField(name = "Node")
+    private Integer node;
+
+    @JSONField(name = "Detail")
+    private RebootRequestDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JSONField(name = "Type")
+        private Integer type;
+
+        /**
+         * 详情
+         */
+        @JSONField(name = "Msg")
+        private Map<String, Object> msg;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/RebootResponeDTO.java

@@ -0,0 +1,39 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author caozehui
+ * @data 2026-03-30
+ */
+@Data
+public class RebootResponeDTO extends CommonBaseMessage {
+
+    @JsonProperty("Detail")
+    private RebootResponeDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JsonProperty("Type")
+        private Integer type;
+
+        /**
+         * 响应主体
+         */
+        @JsonProperty("Msg")
+        private Map<String, Object> msg;
+
+        /**
+         * 响应码
+         */
+        @JsonProperty("Code")
+        private Integer code;
+    }
+
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/UpgradeRequestDTO.java

@@ -0,0 +1,55 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author caozehui
+ * @data 2026-04-01
+ */
+@Data
+public class UpgradeRequestDTO {
+    /**
+     * 消息请求的唯一标识
+     */
+    @JSONField(name = "guid")
+    private String guid;
+
+    /**
+     * 设备ID
+     */
+    @JSONField(name = "Dev_id")
+    private String devId;
+
+    /**
+     * 前置Id
+     */
+    @JSONField(name = "FrontId")
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JSONField(name = "Node")
+    private Integer node;
+
+    @JSONField(name = "Detail")
+    private UpgradeRequestDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JSONField(name = "Type")
+        private Integer type;
+
+        /**
+         * 详情
+         */
+        @JSONField(name = "Msg")
+        private Map<String, Object> msg;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/UpgradeResponeDTO.java

@@ -0,0 +1,39 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author caozehui
+ * @data 2026-03-30
+ */
+@Data
+public class UpgradeResponeDTO extends CommonBaseMessage {
+
+    @JsonProperty("Detail")
+    private UpgradeResponeDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JsonProperty("Type")
+        private Integer type;
+
+        /**
+         * 响应主体
+         */
+        @JsonProperty("Msg")
+        private Map<String, Object> msg;
+
+        /**
+         * 响应码
+         */
+        @JsonProperty("Code")
+        private Integer code;
+    }
+
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/WorkingLogRequestDTO.java

@@ -0,0 +1,55 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author caozehui
+ * @data 2026-03-30
+ */
+@Data
+public class WorkingLogRequestDTO {
+    /**
+     * 消息请求的唯一标识
+     */
+    @JSONField(name = "guid")
+    private String guid;
+
+    /**
+     * 设备ID
+     */
+    @JSONField(name = "Dev_id")
+    private String devId;
+
+    /**
+     * 前置Id
+     */
+    @JSONField(name = "FrontId")
+    private String frontId;
+
+    /**
+     * 前置进程号
+     */
+    @JSONField(name = "Node")
+    private Integer node;
+
+    @JSONField(name = "Detail")
+    private WorkingLogRequestDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JSONField(name = "Type")
+        private Integer type;
+
+        /**
+         * 详情
+         */
+        @JSONField(name = "Msg")
+        private Map<String, Object> msg;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/dto/WorkingLogResponeDTO.java

@@ -0,0 +1,101 @@
+package com.njcn.zlevent.pojo.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+/**
+ * @author caozehui
+ * @data 2026-03-30
+ */
+@Data
+public class WorkingLogResponeDTO extends CommonBaseMessage {
+
+    @JsonProperty("Detail")
+    private WorkingLogResponeDTO.Detail detail;
+
+    @Data
+    public static class Detail {
+        /**
+         * 数据类型，代表特定功能
+         */
+        @JsonProperty("Type")
+        private Integer type;
+
+        /**
+         * 响应主体
+         */
+        @JsonProperty("Msg")
+        private WorkingLogResponeDTO.Msg msg;
+
+        /**
+         * 响应码
+         */
+        @JsonProperty("Code")
+        private Integer code;
+    }
+
+    @Data
+    public static class Msg {
+        /**
+         * 时标
+         */
+        @JsonProperty("Time")
+        private LocalDateTime time;
+
+        /**
+         * CPU负荷（单位%）	39_38(双核，单核的为一个)
+         */
+        @JsonProperty("CpuLoad")
+        private String cpuLoad;
+
+        /**
+         * 装置剩余内存（单位MB）
+         */
+        @JsonProperty("FreeMemory")
+        private String freeMemory;
+
+        /**
+         * 装置总内存（单位MB）
+         */
+        @JsonProperty("TotalMemory")
+        private String totalMemory;
+
+        /**
+         * 装置主存储器剩余空间(单位GB)
+         */
+        @JsonProperty("FreeStorage")
+        private String freeStorage;
+
+        /**
+         * 装置主存储器总空间（单位GB）
+         */
+        @JsonProperty("TotalStorage")
+        private String totalStorage;
+
+        /**
+         * 硬对时最后时标（B码或秒秒冲）
+         */
+        @JsonProperty("HardTimeSync")
+        private LocalDateTime hardTimeSync;
+
+        /**
+         * Sntp对时最后时标
+         */
+        @JsonProperty("SntpTimeSync")
+        private LocalDateTime sntpTimeSync;
+
+        /**
+         * 云服务协议对时最后时标
+         */
+        @JsonProperty("CloudTimeSync")
+        private LocalDateTime cloudTimeSync;
+
+        /**
+         * 无线模块信号强度
+         */
+        @JsonProperty("SignalStrength")
+        private String signalStrength;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-api/src/main/java/com/njcn/zlevent/pojo/param/FileParam.java

@@ -0,0 +1,13 @@
+package com.njcn.zlevent.pojo.param;
+
+import lombok.Data;
+
+/**
+ * @author caozehui
+ * @data 2026-03-17
+ */
+@Data
+public class FileParam {
+    private String filePath;
+    private String devId;
+}

iot-analysis/analysis-zl-event/zl-event-boot/pom.xml

@@ -20,6 +20,10 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>com.github.tocrhz</groupId>
+            <artifactId>mqtt-spring-boot-starter</artifactId>
+        </dependency>
         <dependency>
             <groupId>com.baomidou</groupId>
             <artifactId>dynamic-datasource-spring-boot-starter</artifactId>

iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/config/TaskSchedulerConfig.java

@@ -0,0 +1,63 @@
+package com.njcn.zlevent.config;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.njcn.zlevent.service.IDeviceService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.TaskScheduler;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+
+import java.time.Instant;
+import java.util.Date;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ScheduledFuture;
+
+@Slf4j
+@Configuration
+public class TaskSchedulerConfig {
+
+    @Autowired
+    private IDeviceService deviceService;
+
+    private final Map<String, ScheduledFuture<?>> scheduledTasks = new ConcurrentHashMap<>();
+
+    private final TaskScheduler taskScheduler;
+
+    public TaskSchedulerConfig() {
+        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
+        scheduler.setPoolSize(3);
+        scheduler.setThreadNamePrefix("device-task-");
+        scheduler.setWaitForTasksToCompleteOnShutdown(true);
+        scheduler.initialize();
+        this.taskScheduler = scheduler;
+    }
+
+    public void startTask(String devId, long intervalSeconds) {
+        if (scheduledTasks.containsKey(devId)) {
+            return;
+        }
+
+        ScheduledFuture<?> future = taskScheduler.schedule(
+                () -> deviceService.getWorkingLog(devId),
+                triggerContext -> Date.from(Instant.now().plusSeconds(intervalSeconds))
+        );
+
+        scheduledTasks.put(devId, future);
+        log.info("启动设备 {} 的定时任务成功，间隔={}秒", devId, intervalSeconds);
+    }
+
+    public void stopTask(String devId) {
+        ScheduledFuture<?> future = scheduledTasks.remove(devId);
+        if (ObjectUtil.isNotNull(future)) {
+            future.cancel(false);
+            log.info("停止设备 {} 的定时任务成功", devId);
+        }
+    }
+
+    public boolean isTaskRunning(String devId) {
+        ScheduledFuture<?> future = scheduledTasks.get(devId);
+        return ObjectUtil.isNotNull(future) && !future.isDone() && !future.isCancelled();
+    }
+}

iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/controller/DeviceController.java

@@ -0,0 +1,80 @@
+package com.njcn.zlevent.controller;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.web.controller.BaseController;
+import com.njcn.zlevent.service.IDeviceService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * @author caozehui
+ * @data 2026-03-20
+ */
+@Slf4j
+@RestController
+@RequestMapping("/device")
+@Api(tags = "操作设备")
+@AllArgsConstructor
+public class DeviceController extends BaseController {
+
+    private IDeviceService deviceService;
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @GetMapping("/workingLog")
+    @ApiOperation("开始获取装置运行日志")
+    public HttpResult<Boolean> startWorkingLog(@RequestParam("devId") String devId) {
+        String methodDescribe = getMethodDescribe("startWorkingLog");
+        deviceService.startWorkingLog(devId);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @GetMapping("/stopWorkingLog")
+    @ApiOperation("停止获取装置运行日志")
+    public HttpResult<Boolean> stopWorkingLog(@RequestParam("devId") String devId) {
+        String methodDescribe = getMethodDescribe("stopWorkingLog");
+        deviceService.stopWorkingLogTask(devId);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @GetMapping("/upgrade")
+    @ApiOperation("装置升级")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "devId", value = "设备ID", required = true),
+            @ApiImplicitParam(name = "edDataId", value = "程序版本Id", required = true)
+    })
+    public HttpResult<Boolean> upgrade(@RequestParam("devId") String devId, @RequestParam("edDataId") String edDataId) {
+        String methodDescribe = getMethodDescribe("upgrade");
+        boolean res = deviceService.upgrade(devId, edDataId);
+        return HttpResultUtil.assembleCommonResponseResult(res ? CommonResponseEnum.SUCCESS : CommonResponseEnum.FAIL, res, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @GetMapping("/reboot")
+    @ApiOperation("装置重启")
+    public HttpResult<Boolean> reboot(@RequestParam("devId") String devId) {
+        String methodDescribe = getMethodDescribe("reboot");
+        boolean res = deviceService.reboot(devId);
+        return HttpResultUtil.assembleCommonResponseResult(res ? CommonResponseEnum.SUCCESS : CommonResponseEnum.FAIL, res, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @GetMapping("/timeSync")
+    @ApiOperation("装置对时")
+    public HttpResult<Boolean> timeSync(@RequestParam("devId") String devId) {
+        String methodDescribe = getMethodDescribe("listDir");
+        boolean res = deviceService.timeSync(devId);
+        return HttpResultUtil.assembleCommonResponseResult(res ? CommonResponseEnum.SUCCESS : CommonResponseEnum.FAIL, res, methodDescribe);
+    }
+}

iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/controller/FileController.java

@@ -7,13 +7,20 @@ import com.njcn.common.pojo.response.HttpResult;
 import com.njcn.common.utils.HttpResultUtil;
 import com.njcn.mq.message.AppFileMessage;
 import com.njcn.web.controller.BaseController;
+import com.njcn.zlevent.pojo.dto.FileInfoResponseDTO;
+import com.njcn.zlevent.pojo.param.FileParam;
 import com.njcn.zlevent.service.IFileService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
 
 /**
  * 类的介绍：
@@ -61,4 +68,53 @@ public class FileController extends BaseController {
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
     }
 
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/listDir")
+    @ApiOperation("获取目录列表")
+    @ApiImplicitParam(name = "fileParam", value = "文件路径", required = true)
+    public HttpResult<List<FileInfoResponseDTO.ResourceElement>> listDir(@RequestBody FileParam fileParam) {
+        String methodDescribe = getMethodDescribe("listDir");
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, fileService.listDir(fileParam.getFilePath(), fileParam.getDevId()), methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/downloadFileFromFront")
+    @ApiOperation("下载文件")
+    @ApiImplicitParam(name = "fileParam", value = "文件参数", required = true)
+    public void downloadFileFromFront(@RequestBody FileParam fileParam, HttpServletResponse response) {
+        fileService.downloadFileFromFront(fileParam.getFilePath(), fileParam.getDevId(), response);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/mkdir")
+    @ApiOperation("创建目录")
+    @ApiImplicitParam(name = "fileParam", value = "文件参数", required = true)
+    public HttpResult<Boolean> mkdir(@RequestBody FileParam fileParam) {
+        String methodDescribe = getMethodDescribe("mkdir");
+        boolean res = fileService.mkdir(fileParam.getFilePath(), fileParam.getDevId());
+        return HttpResultUtil.assembleCommonResponseResult(res ? CommonResponseEnum.SUCCESS : CommonResponseEnum.FAIL, res, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/uploadFileToFront")
+    @ApiOperation("上传文件")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "file", value = "文件", required = true),
+            @ApiImplicitParam(name = "devId", value = "设备ID", required = true),
+            @ApiImplicitParam(name = "dirPath", value = "文件所在路径", required = true)
+    })
+    public HttpResult<Boolean> uploadFileToFront(@RequestPart("file") MultipartFile file, @RequestParam("devId") String devId, @RequestParam("dirPath") String dirPath) {
+        boolean res = fileService.uploadFileToFront(file, devId, dirPath);
+        return HttpResultUtil.assembleCommonResponseResult(res ? CommonResponseEnum.SUCCESS : CommonResponseEnum.FAIL, res, getMethodDescribe("uploadFileToFront"));
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/delete")
+    @ApiOperation("删除文件/目录")
+    @ApiImplicitParam(name = "fileParam", value = "文件参数", required = true)
+    public HttpResult<Boolean> delete(@RequestBody FileParam fileParam) {
+        boolean res = fileService.delete(fileParam.getFilePath(), fileParam.getDevId());
+        return HttpResultUtil.assembleCommonResponseResult(res ? CommonResponseEnum.SUCCESS : CommonResponseEnum.FAIL, res, getMethodDescribe("delete"));
+    }
+
 }

iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/producer/CommonProducer.java

@@ -0,0 +1,33 @@
+package com.njcn.zlevent.producer;
+
+import com.njcn.middle.rocket.domain.BaseMessage;
+import com.njcn.middle.rocket.template.RocketMQEnhanceTemplate;
+import com.njcn.mq.constant.BusinessTopic;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author caozehui
+ * @data 2026-03-16
+ */
+@Component
+public class CommonProducer extends RocketMQEnhanceTemplate {
+
+
+    public CommonProducer(RocketMQTemplate template) {
+        super(template);
+    }
+
+    /**
+     * @param message
+     * @param frontId
+     * @return
+     */
+    public SendResult send(BaseMessage message, String frontId) {
+        return send(BusinessTopic.CLOUD_TOPIC, frontId, message);
+    }
+    public SendResult send(BaseMessage message) {
+        return send(BusinessTopic.CLOUD_REPLY_TOPIC, message);
+    }
+}

iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/IDeviceService.java

@@ -0,0 +1,67 @@
+package com.njcn.zlevent.service;
+
+import com.njcn.zlevent.pojo.dto.DevVersionResponeDTO;
+import com.njcn.zlevent.pojo.dto.DeviceVersionRequestDTO;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * @author caozehui
+ * @data 2026-03-20
+ */
+public interface IDeviceService {
+
+    /**
+     * 开始运行日志任务
+     *
+     * @param devId 设备id
+     */
+    void startWorkingLog(String devId);
+
+    /**
+     * 停止运行日志任务
+     *
+     * @param devId
+     */
+    void stopWorkingLogTask(String devId);
+
+    /**
+     * 运行日志任务是否正在运行
+     *
+     * @param devId
+     * @return
+     */
+    boolean isWorkingLogTaskRunning(String devId);
+
+    void getWorkingLog(String devId);
+
+    /**
+     * 设备对时
+     *
+     * @param devId
+     * @return
+     */
+    boolean timeSync(String devId);
+
+    /**
+     * 获取设备版本信息
+     *
+     * @param devId
+     * @return
+     */
+    DevVersionResponeDTO.VersionInfo getDeviceVersion(String devId);
+
+    /**
+     * 设备升级
+     *
+     * @param devId
+     * @param edDataId
+     */
+    boolean upgrade(String devId, String edDataId);
+
+    /**
+     * 重启设备
+     *
+     * @param devId
+     */
+    boolean reboot(String devId);
+}

iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/IFileService.java

@@ -1,6 +1,11 @@
 package com.njcn.zlevent.service;
 
 import com.njcn.mq.message.AppFileMessage;
+import com.njcn.zlevent.pojo.dto.FileInfoResponseDTO;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
 
 /**
  * 类的介绍：
@@ -16,12 +21,14 @@ public interface IFileService {
      * 解析文件流之前需要获取文件的信息,可能要特殊处理
      * 1.文件过大要分片获取(单次请求文件大小不超过50k)
      * 2.校验文件(md5或者crc)
+     *
      * @param appFileMessage
      */
     void analysisFileInfo(AppFileMessage appFileMessage);
 
     /**
      * 获取文件流，解析文件
+     *
      * @param appFileMessage
      */
     void analysisFileStream(AppFileMessage appFileMessage);
@@ -30,4 +37,35 @@ public interface IFileService {
      * 下载补召文件
      */
     void downloadMakeUpFile(String nDid);
+
+    /**
+     * 获取目录列表
+     *
+     * @param filePath
+     * @param devId
+     * @return
+     */
+    List<FileInfoResponseDTO.ResourceElement> listDir(String filePath, String devId);
+
+    /**
+     * 从前置下载文件
+     *
+     * @param filePath
+     * @param devId
+     * @param response
+     */
+    void downloadFileFromFront(String filePath, String devId, HttpServletResponse response);
+
+    /**
+     * 上传文件到文件服务器
+     *
+     * @param file
+     * @param devId
+     * @param dirPath
+     */
+    boolean uploadFileToFront(MultipartFile file, String devId, String dirPath);
+
+    boolean mkdir(String filePath, String devId);
+
+    boolean delete(String filePath, String devId);
 }

iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/DeviceServiceImpl.java

@@ -0,0 +1,289 @@
+package com.njcn.zlevent.service.impl;
+
+import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSON;
+import com.github.tocrhz.mqtt.publisher.MqttPublisher;
+import com.njcn.access.enums.TypeEnum;
+import com.njcn.access.utils.SendMessageUtil;
+import com.njcn.csdevice.api.CsEdDataFeignClient;
+import com.njcn.csdevice.api.CsSoftInfoFeignClient;
+import com.njcn.csdevice.api.EquipmentFeignClient;
+import com.njcn.csdevice.pojo.dto.CsEquipmentDeliveryDTO;
+import com.njcn.csdevice.pojo.po.CsSoftInfoPO;
+import com.njcn.csdevice.pojo.vo.CsEdDataVO;
+import com.njcn.middle.rocket.domain.BaseMessage;
+import com.njcn.oss.utils.FileStorageUtil;
+import com.njcn.redis.pojo.enums.AppRedisKey;
+import com.njcn.redis.utils.RedisUtil;
+import com.njcn.zlevent.config.TaskSchedulerConfig;
+import com.njcn.zlevent.pojo.dto.*;
+import com.njcn.zlevent.producer.CommonProducer;
+import com.njcn.zlevent.service.IDeviceService;
+import lombok.AllArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.time.ZoneId;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * @author caozehui
+ * @data 2026-03-20
+ */
+@Service
+@AllArgsConstructor
+public class DeviceServiceImpl implements IDeviceService {
+
+    private final EquipmentFeignClient equipmentFeignClient;
+    private final CsSoftInfoFeignClient csSoftInfoFeignClient;
+    private final CsEdDataFeignClient csEdDataFeignClient;
+
+    private final CommonProducer commonProducer;
+    private final SendMessageUtil sendMessageUtil;
+    private final TaskSchedulerConfig taskSchedulerConfig;
+    private final RedisUtil redisUtil;
+    private final MqttPublisher publisher;
+    private final FileStorageUtil fileStorageUtil;
+
+    @Override
+    public void startWorkingLog(String devId) {
+        taskSchedulerConfig.startTask(devId, 5);
+    }
+
+    @Override
+    public void stopWorkingLogTask(String devId) {
+        taskSchedulerConfig.stopTask(devId);
+    }
+
+    @Override
+    public boolean isWorkingLogTaskRunning(String devId) {
+        return taskSchedulerConfig.isTaskRunning(devId);
+    }
+
+    public void getWorkingLog(String devId) {
+        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+
+        WorkingLogRequestDTO requestDTO = new WorkingLogRequestDTO();
+        requestDTO.setDevId(devId);
+        requestDTO.setGuid(IdUtil.simpleUUID());
+        requestDTO.setNode(listHttpResult.get(0).getNodeProcess());
+        requestDTO.setFrontId(listHttpResult.get(0).getNodeId());
+
+        WorkingLogRequestDTO.Detail detail = new WorkingLogRequestDTO.Detail();
+        detail.setType(Integer.valueOf(TypeEnum.WORKING_LOG.getCode()));
+        detail.setMsg(new HashMap<>());
+
+        requestDTO.setDetail(detail);
+        BaseMessage message = new BaseMessage();
+        message.setMessageBody(JSON.toJSONString(requestDTO));
+
+        // 使用 Redis 存储 guid 用于后续查询
+        redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_REQUEST + requestDTO.getGuid(), "pending", 120L);
+
+        // 发送
+        commonProducer.send(message, requestDTO.getFrontId());
+
+        // 轮询 Redis 等待响应
+        WorkingLogResponeDTO workingLogResponeDTO = JSON.parseObject(sendMessageUtil.waitForResponse(requestDTO.getGuid(), 10), WorkingLogResponeDTO.class);
+
+        WorkingLogResponeDTO.Detail detail1 = workingLogResponeDTO.getDetail();
+        WorkingLogResponeDTO.Msg msg1 = detail1.getMsg();
+
+        //mqtt推送给前端
+        publisher.send("/afafaidfasd", JSON.toJSONString(msg1), 1, false);
+    }
+
+
+    @Override
+    public boolean timeSync(String devId) {
+//        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+//
+//        BaseMessage message = new BaseMessage();
+//        FileDownloadRequestDTO requestDTO = new FileDownloadRequestDTO();
+//        requestDTO.setGuid(listHttpResult.get(0).getNodeId());
+//        requestDTO.setNode(listHttpResult.get(0).getNodeProcess());
+
+
+//        BaseRequestDTO message = new BaseRequestDTO<>();
+//        message.setGuid(IdUtil.simpleUUID());
+//        message.setFrontId(listHttpResult.get(0).getNodeId());
+//        message.setNode(listHttpResult.get(0).getNodeProcess());
+//        message.setDevId(devId);
+//        BaseRequestDTO.Detail<FileInfoRequestDTO> detail = new BaseRequestDTO.Detail<>();
+//        detail.setType(1113);
+//        detail.setMsg(null);
+//        message.setDetail(detail);
+
+        // pendingResponsesMap.put(message.getGuid(), new CompletableFuture<>());
+
+        // 发送
+        //deviceProducer.send(message);
+
+//        BaseMessage baseMessage = null;
+//        CompletableFuture<BaseMessage> future = pendingResponsesMap.get(message.getGuid());
+//        try {
+//            baseMessage = future.get(5, TimeUnit.SECONDS);
+//        } catch (Exception e) {
+//            throw new BusinessException(ZleventResoponseEnum.RESPONSE_ERROR);
+//        } finally {
+//            pendingResponsesMap.remove(message.getGuid());
+//        }
+//
+//        Integer code = baseMessage.getDetail().getCode();
+
+//        return code == 200;
+        return true;
+    }
+
+    @Override
+    public DevVersionResponeDTO.VersionInfo getDeviceVersion(String devId) {
+        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+        CsEquipmentDeliveryDTO csEquipmentDeliveryDTO = listHttpResult.get(0);
+        // 先询问一下旧的版本信息
+        DeviceVersionRequestDTO deviceVersionRequestDTO = new DeviceVersionRequestDTO();
+        deviceVersionRequestDTO.setDevId(devId);
+        deviceVersionRequestDTO.setGuid(IdUtil.simpleUUID());
+        deviceVersionRequestDTO.setNode(csEquipmentDeliveryDTO.getNodeProcess());
+        deviceVersionRequestDTO.setFrontId(csEquipmentDeliveryDTO.getNodeId());
+
+        DeviceVersionRequestDTO.Detail detail1 = new DeviceVersionRequestDTO.Detail();
+        detail1.setMsg(new HashMap<>());
+        detail1.setType(Integer.parseInt(TypeEnum.DEVICE_VERSION.getCode()));
+        deviceVersionRequestDTO.setDetail(detail1);
+
+        BaseMessage message = new BaseMessage();
+        message.setMessageBody(JSON.toJSONString(deviceVersionRequestDTO));
+
+        // 使用 Redis 存储 guid 用于后续查询
+        redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_REQUEST + deviceVersionRequestDTO.getGuid(), "pending", 120L);
+
+        // 发送
+        commonProducer.send(message, deviceVersionRequestDTO.getFrontId());
+
+        // 轮询 Redis 等待响应
+        DevVersionResponeDTO responseDTO = JSON.parseObject(sendMessageUtil.waitForResponse(deviceVersionRequestDTO.getGuid(), 10), DevVersionResponeDTO.class);
+        DevVersionResponeDTO.Detail detail2 = responseDTO.getDetail();
+
+        if (detail2.getMsg().getCode() == 200) {
+            DevVersionResponeDTO.VersionInfo versionInfo = detail2.getMsg().getVersionInfo();
+            return versionInfo;
+        }
+        return null;
+    }
+
+    @Override
+    public boolean upgrade(String devId, String edDataId) {
+        // 先获取旧的版本信息
+        //DevVersionResponeDTO.VersionInfo oldVersionInfo = this.getDeviceVersion(devId);
+
+        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+        CsEquipmentDeliveryDTO csEquipmentDeliveryDTO = listHttpResult.get(0);
+
+        CsEdDataVO csEdDataVO = csEdDataFeignClient.findByDevTypeId(edDataId).getData();
+        String filePath = csEdDataVO.getFilePath();
+
+        FileUploadRequestDTO fileUploadRequestDTO = new FileUploadRequestDTO();
+        fileUploadRequestDTO.setDevId(devId);
+        fileUploadRequestDTO.setGuid(IdUtil.simpleUUID());
+        fileUploadRequestDTO.setNode(csEquipmentDeliveryDTO.getNodeProcess());
+        fileUploadRequestDTO.setFrontId(csEquipmentDeliveryDTO.getNodeId());
+
+        FileUploadRequestDTO.Detail detail1 = new FileUploadRequestDTO.Detail();
+        detail1.setType(Integer.parseInt(TypeEnum.FILE_UPLOAD.getCode()));
+
+        FileUploadRequestDTO.Msg msg = new FileUploadRequestDTO.Msg();
+        msg.setName(filePath);
+        msg.setRemoteName("");
+        detail1.setMsg(msg);
+
+        fileUploadRequestDTO.setDetail(detail1);
+
+        BaseMessage message1 = new BaseMessage();
+        message1.setMessageBody(JSON.toJSONString(fileUploadRequestDTO));
+
+        // 使用 Redis 存储 guid 用于后续查询
+        redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_REQUEST + fileUploadRequestDTO.getGuid(), "pending", 120L);
+
+        // 发送
+        commonProducer.send(message1, fileUploadRequestDTO.getFrontId());
+
+        // 轮询 Redis 等待响应
+        FileUploadResponeDTO responseDTO = JSON.parseObject(sendMessageUtil.waitForResponse(fileUploadRequestDTO.getGuid(), 10), FileUploadResponeDTO.class);
+        FileUploadResponeDTO.Detail detail2 = responseDTO.getDetail();
+
+        if (detail2.getCode() == 200) {
+            UpgradeRequestDTO requestDTO = new UpgradeRequestDTO();
+            requestDTO.setDevId(devId);
+            requestDTO.setGuid(IdUtil.simpleUUID());
+            requestDTO.setNode(csEquipmentDeliveryDTO.getNodeProcess());
+            requestDTO.setFrontId(csEquipmentDeliveryDTO.getNodeId());
+
+            UpgradeRequestDTO.Detail detail3 = new UpgradeRequestDTO.Detail();
+            detail3.setType(Integer.valueOf(TypeEnum.DEVICE_UPGRADE.getCode()));
+            detail3.setMsg(new HashMap<>());
+
+            requestDTO.setDetail(detail3);
+            BaseMessage message2 = new BaseMessage();
+            message2.setMessageBody(JSON.toJSONString(requestDTO));
+
+            // 使用 Redis 存储 guid 用于后续查询
+            redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_REQUEST + requestDTO.getGuid(), "pending", 120L);
+
+            // 发送
+            commonProducer.send(message2, requestDTO.getFrontId());
+
+            // 轮询 Redis 等待响应
+            UpgradeResponeDTO responeDTO = JSON.parseObject(sendMessageUtil.waitForResponse(requestDTO.getGuid(), 10), UpgradeResponeDTO.class);
+            UpgradeResponeDTO.Detail detail4 = responeDTO.getDetail();
+
+            if (detail4.getCode() == 200) {
+                // 修改数据库记录
+                String softinfoId = csEquipmentDeliveryDTO.getSoftinfoId();
+
+                CsSoftInfoPO softInfoPO = null;
+                if (StrUtil.isNotBlank(softinfoId)) {
+                    csSoftInfoFeignClient.removeSoftInfo(softinfoId);
+                }
+                softInfoPO = new CsSoftInfoPO();
+                softInfoPO.setId(IdUtil.fastSimpleUUID());
+                softInfoPO.setAppCheck(csEdDataVO.getCrc());
+                softInfoPO.setAppDate(csEdDataVO.getVersionDate().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
+                softInfoPO.setAppVersion(csEdDataVO.getVersionNo());
+                softInfoPO.setOpAttr("r");
+                softInfoPO.setOsName("VxWorks");
+                softInfoPO.setOsVersion("VxWorks");
+                softInfoPO.setSoftUpdate("yes");
+                csSoftInfoFeignClient.saveSoftInfo(softInfoPO);
+                equipmentFeignClient.updateSoftInfo(csEquipmentDeliveryDTO.getNdid(), softInfoPO.getId());
+
+                // 重新获取升级后的版本信息
+                DevVersionResponeDTO.VersionInfo newVersionInfo = this.getDeviceVersion(devId);
+                if (newVersionInfo.getAppVersion().equals(csEdDataVO.getVersionNo()) && newVersionInfo.getCloudProtocolVer().equals(csEdDataVO.getVersionAgreement())) {
+                    // 修改数据库记录
+                    equipmentFeignClient.updateSoftInfo(csEquipmentDeliveryDTO.getNdid(), softInfoPO.getId());
+                    return true;
+                }
+                return false;
+            } else {
+                return false;
+            }
+        } else {
+            return false;
+        }
+    }
+
+    @Override
+    public boolean reboot(String devId) {
+        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+
+        RebootRequestDTO requestDTO = new RebootRequestDTO();
+        requestDTO.setDevId(devId);
+        requestDTO.setGuid(IdUtil.simpleUUID());
+        requestDTO.setNode(listHttpResult.get(0).getNodeProcess());
+        requestDTO.setFrontId(listHttpResult.get(0).getNodeId());
+
+        return true;
+    }
+}

iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/FileServiceImpl.java

@@ -2,6 +2,7 @@ package com.njcn.zlevent.service.impl;
 
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.text.StrPool;
+import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.nacos.shaded.com.google.gson.Gson;
@@ -12,19 +13,18 @@ import com.njcn.access.enums.AccessResponseEnum;
 import com.njcn.access.enums.TypeEnum;
 import com.njcn.access.pojo.dto.ReqAndResDto;
 import com.njcn.access.pojo.dto.file.FileDto;
-import com.njcn.access.utils.CRC32Utils;
+import com.njcn.access.utils.*;
-import com.njcn.access.utils.ChannelObjectUtil;
-import com.njcn.access.utils.FileCommonUtils;
-import com.njcn.access.utils.MqttUtil;
 import com.njcn.common.config.GeneralInfo;
 import com.njcn.common.pojo.exception.BusinessException;
 import com.njcn.csdevice.api.DeviceFtpFeignClient;
 import com.njcn.csdevice.api.EquipmentFeignClient;
 import com.njcn.csdevice.api.PortableOffLogFeignClient;
 import com.njcn.csdevice.enums.AlgorithmResponseEnum;
+import com.njcn.csdevice.pojo.dto.CsEquipmentDeliveryDTO;
 import com.njcn.csharmonic.api.WavePicFeignClient;
 import com.njcn.csharmonic.enums.CsHarmonicResponseEnum;
 import com.njcn.csharmonic.pojo.dto.DownloadMakeUpDto;
+import com.njcn.middle.rocket.domain.BaseMessage;
 import com.njcn.mq.message.AppFileMessage;
 import com.njcn.oss.constant.GeneralConstant;
 import com.njcn.oss.constant.OssPath;
@@ -32,11 +32,10 @@ import com.njcn.oss.utils.FileStorageUtil;
 import com.njcn.redis.pojo.enums.AppRedisKey;
 import com.njcn.redis.utils.RedisUtil;
 import com.njcn.zlevent.param.CsEventParam;
-import com.njcn.zlevent.pojo.dto.FileInfoDto;
+import com.njcn.zlevent.pojo.dto.*;
-import com.njcn.zlevent.pojo.dto.FileStreamDto;
-import com.njcn.zlevent.pojo.dto.WaveTimeDto;
 import com.njcn.zlevent.pojo.po.CsEventFileLogs;
 import com.njcn.zlevent.pojo.po.CsWave;
+import com.njcn.zlevent.producer.CommonProducer;
 import com.njcn.zlevent.service.ICsEventFileLogsService;
 import com.njcn.zlevent.service.ICsEventService;
 import com.njcn.zlevent.service.ICsWaveService;
@@ -46,12 +45,16 @@ import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import net.sf.json.JSONObject;
 import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
 
+import javax.servlet.http.HttpServletResponse;
 import java.io.*;
+import java.net.URLEncoder;
 import java.nio.file.Files;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
 
 /**
  * 类的介绍：
@@ -83,6 +86,11 @@ public class FileServiceImpl implements IFileService {
     private final DeviceFtpFeignClient deviceFtpFeignClient;
     private final PortableOffLogFeignClient portableOffLogFeignClient;
 
+    private final CommonProducer commonProducer;
+    private final SendMessageUtil sendMessageUtil;
+    public final static String UPLOAD_PATH = "upload";
+
+
     @Override
     public void analysisFileInfo(AppFileMessage appFileMessage) {
         if (Objects.equals(appFileMessage.getCode(), AccessEnum.SUCCESS.getCode())) {
@@ -458,6 +466,332 @@ public class FileServiceImpl implements IFileService {
         }
     }
 
+    @Override
+    public List<FileInfoResponseDTO.ResourceElement> listDir(String filePath, String devId) {
+        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+
+        FileInfoRequestDTO requestDTO = new FileInfoRequestDTO();
+        requestDTO.setGuid(IdUtil.simpleUUID());
+        requestDTO.setFrontId(listHttpResult.get(0).getNodeId());
+        requestDTO.setNode(listHttpResult.get(0).getNodeProcess());
+        requestDTO.setDevId(devId);
+
+        FileInfoRequestDTO.Detail detail = new FileInfoRequestDTO.Detail();
+        detail.setType(Integer.parseInt(TypeEnum.READ_FILE_DIR.getCode()));
+
+        FileInfoRequestDTO.Msg msg = new FileInfoRequestDTO.Msg();
+        msg.setName(filePath);
+        detail.setMsg(msg);
+
+        requestDTO.setDetail(detail);
+
+        BaseMessage message = new BaseMessage();
+        message.setMessageBody(JSON.toJSONString(requestDTO));
+
+        // 使用 Redis 存储 guid 用于后续查询
+        redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_REQUEST + requestDTO.getGuid(), "pending", 120L);
+
+        // 发送
+        commonProducer.send(message, requestDTO.getFrontId());
+        //this.simulation1(requestDTO.getGuid());
+
+        // 轮询 Redis 等待响应
+        FileInfoResponseDTO responseDTO = JSON.parseObject(sendMessageUtil.waitForResponse(requestDTO.getGuid(), 10), FileInfoResponseDTO.class);
+
+        FileInfoResponseDTO.Detail detail1 = responseDTO.getDetail();
+        FileInfoResponseDTO.Msg msg1 = detail1.getMsg();
+        msg1.getDirInfo().forEach(resourceElement -> {
+            resourceElement.setPrjDataPath(StrUtil.SLASH.equals(filePath) ? resourceElement.getName() : filePath + StrUtil.SLASH + resourceElement.getName());
+        });
+
+        return msg1.getDirInfo();
+    }
+
+
+    private void simulation1(String guid) {
+        // 模拟异步处理，实际场景中应由消息队列或回调触发
+        CompletableFuture.runAsync(() -> {
+            // 模拟耗时操作，例如等待设备响应
+            try {
+                Thread.sleep(3000);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+
+            FileInfoResponseDTO message = new FileInfoResponseDTO();
+            List<FileInfoResponseDTO.ResourceElement> dirInfo = new ArrayList<>();
+
+            FileInfoResponseDTO.ResourceElement resourceElement1 = new FileInfoResponseDTO.ResourceElement();
+            resourceElement1.setName("/ram0");
+            resourceElement1.setType("dir");
+            resourceElement1.setSize(1);
+            dirInfo.add(resourceElement1);
+
+            FileInfoResponseDTO.ResourceElement resourceElement2 = new FileInfoResponseDTO.ResourceElement();
+            resourceElement2.setName("/etc");
+            resourceElement2.setType("dir");
+            resourceElement2.setSize(1);
+            dirInfo.add(resourceElement2);
+
+            FileInfoResponseDTO.ResourceElement resourceElement3 = new FileInfoResponseDTO.ResourceElement();
+            resourceElement3.setName("/sd0:1");
+            resourceElement3.setType("dir");
+            resourceElement3.setSize(1);
+            dirInfo.add(resourceElement3);
+
+            FileInfoResponseDTO.ResourceElement resourceElement4 = new FileInfoResponseDTO.ResourceElement();
+            resourceElement4.setName("1773986668375094.xls");
+            resourceElement4.setType("file");
+            resourceElement4.setSize(1000);
+            dirInfo.add(resourceElement4);
+
+            FileInfoResponseDTO.Detail detail = new FileInfoResponseDTO.Detail();
+            FileInfoResponseDTO.Msg msg = new FileInfoResponseDTO.Msg();
+            msg.setDirInfo(dirInfo);
+            detail.setMsg(msg);
+            detail.setCode(200);
+            detail.setType(4657);
+            detail.setMsg(msg);
+
+            message.setGuid(guid);
+            message.setFrontId("sdghsfdhfdhdfhdfghd234234534534");
+            message.setNode(1);
+            message.setDevMac("A0BC7B4A5D8A");
+            message.setDetail(detail);
+
+
+            BaseMessage baseMessage = new BaseMessage();
+            baseMessage.setSendTime(LocalDateTime.now());
+            baseMessage.setMessageBody(JSON.toJSONString(message));
+            commonProducer.send(baseMessage);
+        });
+    }
+
+    private void simulation2(String guid) {
+        // 模拟异步处理，实际场景中应由消息队列或回调触发
+        CompletableFuture.runAsync(() -> {
+            // 模拟耗时操作，例如等待设备响应
+            try {
+                Thread.sleep(3000);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+
+            FileDownloadResponeDTO message = new FileDownloadResponeDTO();
+            message.setGuid(guid);
+            message.setFrontId("sdghsfdhfdhdfhdfghd234234534534");
+            message.setNode(1);
+            message.setDevMac("A0BC7B4A5D8A");
+
+            FileDownloadResponeDTO.Detail detail = new FileDownloadResponeDTO.Detail();
+            detail.setType(Integer.parseInt(TypeEnum.FILE_DOWNLOAD.getCode()));
+            FileDownloadResponeDTO.Msg msg = new FileDownloadResponeDTO.Msg();
+            msg.setName("a.txt");
+            msg.setRemoteName("https://www.jswsrc.com.cn/data/upload/ueditor/file/20260320/1773986668375094.xls");
+            detail.setMsg(msg);
+
+            message.setDetail(detail);
+
+            BaseMessage baseMessage = new BaseMessage();
+            baseMessage.setSendTime(LocalDateTime.now());
+            baseMessage.setMessageBody(JSON.toJSONString(message));
+            commonProducer.send(baseMessage);
+        });
+    }
+
+    @Override
+    public void downloadFileFromFront(String filePath, String devId, HttpServletResponse response) {
+        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+
+        FileDownloadRequestDTO requestDTO = new FileDownloadRequestDTO();
+        requestDTO.setGuid(IdUtil.simpleUUID());
+        requestDTO.setFrontId(listHttpResult.get(0).getNodeId());
+        requestDTO.setNode(listHttpResult.get(0).getNodeProcess());
+        requestDTO.setDevId(devId);
+
+        FileDownloadRequestDTO.Detail detail = new FileDownloadRequestDTO.Detail();
+        detail.setType(Integer.parseInt(TypeEnum.FILE_DOWNLOAD.getCode()));
+
+        FileDownloadRequestDTO.Msg msg = new FileDownloadRequestDTO.Msg();
+        msg.setName(filePath);
+        detail.setMsg(msg);
+
+        requestDTO.setDetail(detail);
+
+        BaseMessage message = new BaseMessage();
+        message.setMessageBody(JSON.toJSONString(requestDTO));
+
+        // 使用 Redis 存储 guid 用于后续查询
+        redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_REQUEST + requestDTO.getGuid(), "pending", 120L);
+
+        // 发送
+        commonProducer.send(message, requestDTO.getFrontId());
+        //this.simulation2(requestDTO.getGuid());
+
+        // 轮询 Redis 等待响应
+        FileDownloadResponeDTO responseDTO = JSON.parseObject(sendMessageUtil.waitForResponse(requestDTO.getGuid(), 10), FileDownloadResponeDTO.class);
+
+
+        String remoteName = responseDTO.getDetail().getMsg().getRemoteName();
+//        String remoteName = "https://yunpan.360.cn/uploads/20230710/037ca576a421eb0bc23d717a7b076c5f.jpg";
+//        String remoteName = "/PQ_PQLD1_001429_20251010_143805_792.dat";
+        String fileName = remoteName.substring(remoteName.lastIndexOf(StrUtil.SLASH) + 1);
+
+
+        try {
+            response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(fileName, "UTF-8") + "\";filename*=UTF-8''" + URLEncoder.encode(fileName, "UTF-8"));
+            fileStorageUtil.downloadStream(response, remoteName);
+            // 下载完后删除文件
+            //fileStorageUtil.deleteFile(filePath);
+        } catch (Exception e) {
+            throw new BusinessException(AccessResponseEnum.FILE_DOWNLOAD_FAIL);
+        }
+    }
+
+    @Override
+    public boolean uploadFileToFront(MultipartFile file, String devId, String dirPath) {
+        dirPath = (dirPath.endsWith(StrUtil.SLASH) ? dirPath : dirPath + StrUtil.SLASH);
+        String remotePath = StrUtil.SLASH + UPLOAD_PATH + StrUtil.SLASH + devId + dirPath;
+        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+        String frontId = listHttpResult.get(0).getNodeId();
+        try {
+            fileStorageUtil.uploadMultipart(file, remotePath, true);
+        } catch (Exception e) {
+            throw new BusinessException(AccessResponseEnum.FILE_UPLOAD_FAIL);
+        }
+        // 告诉前置上传文件所在的路径、设备等信息
+        FileUploadRequestDTO requestDTO = new FileUploadRequestDTO();
+        requestDTO.setGuid(IdUtil.simpleUUID());
+        requestDTO.setFrontId(frontId);
+        requestDTO.setNode(listHttpResult.get(0).getNodeProcess());
+        requestDTO.setDevId(devId);
+
+        FileUploadRequestDTO.Detail detail = new FileUploadRequestDTO.Detail();
+        detail.setType(Integer.parseInt(TypeEnum.FILE_UPLOAD.getCode()));
+
+        FileUploadRequestDTO.Msg msg = new FileUploadRequestDTO.Msg();
+        msg.setName(remotePath + file.getOriginalFilename());
+        msg.setRemoteName(dirPath + file.getOriginalFilename());
+        detail.setMsg(msg);
+
+        requestDTO.setDetail(detail);
+
+        BaseMessage message = new BaseMessage();
+        message.setMessageBody(JSON.toJSONString(requestDTO));
+
+        // 使用 Redis 存储 guid 用于后续查询
+        redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_REQUEST + requestDTO.getGuid(), "pending", 120L);
+
+        // 发送
+        commonProducer.send(message, requestDTO.getFrontId());
+
+        // 轮询 Redis 等待响应
+        FileUploadResponeDTO responseDTO = JSON.parseObject(sendMessageUtil.waitForResponse(requestDTO.getGuid(), 10), FileUploadResponeDTO.class);
+
+        FileUploadResponeDTO.Detail detail1 = responseDTO.getDetail();
+
+        return detail1.getCode()==200;
+    }
+
+    @Override
+    public boolean mkdir(String filePath, String devId) {
+        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+        String frontId = listHttpResult.get(0).getNodeId();
+
+        // 告诉前置上传文件所在的路径、设备等信息
+        MkdirRequestDTO requestDTO = new MkdirRequestDTO();
+        requestDTO.setGuid(IdUtil.simpleUUID());
+        requestDTO.setFrontId(frontId);
+        requestDTO.setNode(listHttpResult.get(0).getNodeProcess());
+        requestDTO.setDevId(devId);
+
+        MkdirRequestDTO.Detail detail = new MkdirRequestDTO.Detail();
+        detail.setType(Integer.parseInt(TypeEnum.MKDIR.getCode()));
+
+        MkdirRequestDTO.Msg msg = new MkdirRequestDTO.Msg();
+        msg.setName(filePath.endsWith(StrUtil.SLASH) ? filePath : filePath + StrUtil.SLASH);
+        detail.setMsg(msg);
+
+        requestDTO.setDetail(detail);
+
+        BaseMessage message = new BaseMessage();
+        message.setMessageBody(JSON.toJSONString(requestDTO));
+
+        // 使用 Redis 存储 guid 用于后续查询
+        redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_REQUEST + requestDTO.getGuid(), "pending", 120L);
+
+        // 发送
+        commonProducer.send(message, requestDTO.getFrontId());
+
+        // 轮询 Redis 等待响应
+        MkdirResponeDTO responseDTO = JSON.parseObject(sendMessageUtil.waitForResponse(requestDTO.getGuid(), 10), MkdirResponeDTO.class);
+
+        MkdirResponeDTO.Detail detail1 = responseDTO.getDetail();
+
+        return detail1.getCode()==200;
+    }
+
+    @Override
+    public boolean delete(String filePath, String devId) {
+        boolean isDir = isDirectory(filePath);
+
+        List<CsEquipmentDeliveryDTO> listHttpResult = equipmentFeignClient.queryDeviceById(Collections.singletonList(devId)).getData();
+        String frontId = listHttpResult.get(0).getNodeId();
+
+        // 告诉前置上传文件所在的路径、设备等信息
+        FileOrDirDeleteRequestDTO requestDTO = new FileOrDirDeleteRequestDTO();
+        requestDTO.setGuid(IdUtil.simpleUUID());
+        requestDTO.setFrontId(frontId);
+        requestDTO.setNode(listHttpResult.get(0).getNodeProcess());
+        requestDTO.setDevId(devId);
+
+        FileOrDirDeleteRequestDTO.Detail detail = new FileOrDirDeleteRequestDTO.Detail();
+        detail.setType(Integer.parseInt(isDir ? TypeEnum.DIR_DELETE.getCode() : TypeEnum.FILE_DELETE.getCode()));
+
+        FileOrDirDeleteRequestDTO.Msg msg = new FileOrDirDeleteRequestDTO.Msg();
+        msg.setName(isDir ? (filePath.endsWith(StrUtil.SLASH) ? filePath : filePath + StrUtil.SLASH) : filePath);
+        detail.setMsg(msg);
+
+        requestDTO.setDetail(detail);
+
+        BaseMessage message = new BaseMessage();
+        message.setMessageBody(JSON.toJSONString(requestDTO));
+
+        // 使用 Redis 存储 guid 用于后续查询
+        redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_REQUEST + requestDTO.getGuid(), "pending", 120L);
+
+        // 发送
+        commonProducer.send(message, requestDTO.getFrontId());
+
+        // 轮询 Redis 等待响应
+        FileOrDirDeleteResponeDTO responseDTO = JSON.parseObject(sendMessageUtil.waitForResponse(requestDTO.getGuid(), 10), FileOrDirDeleteResponeDTO.class);
+
+        FileOrDirDeleteResponeDTO.Detail detail1 = responseDTO.getDetail();
+
+        return detail1.getCode()==200;
+    }
+
+    /**
+     * 根据文件扩展名判断是文件还是目录
+     * 规则：包含小数点的是文件，否则是目录
+     *
+     * @param filePath 文件路径
+     * @return true=目录，false=文件
+     */
+    private boolean isDirectory(String filePath) {
+        String fileName = filePath.substring(filePath.lastIndexOf("/") + 1);
+
+        // 判断文件名中是否包含小数点（从第二个字符开始，排除隐藏文件的情况）
+        // 例如：.gitignore 是文件，不是目录
+        if (fileName.startsWith(".")) {
+            // 隐藏文件/目录：判断除第一个点外是否还有其他点
+            return !fileName.substring(1).contains(".");
+        } else {
+            // 普通文件/目录：直接判断是否包含点
+            return !fileName.contains(".");
+        }
+    }
+
     /**
      * 处理补召文件
      */
@@ -680,6 +1014,7 @@ public class FileServiceImpl implements IFileService {
         public MyObjectOutputStream(OutputStream out) throws IOException {
             super(out);
         }
+
         @Override
         protected void writeStreamHeader() throws IOException {
             //重写读取头部信息方法：不写入头部信息
@@ -691,6 +1026,7 @@ public class FileServiceImpl implements IFileService {
         public MyObjectInputStream(InputStream in) throws IOException {
             super(in);
         }
+
         @Override
         protected void readStreamHeader() throws IOException {
             //重写读取头部信息方法：什么也不做

iot-analysis/analysis-zl-event/zl-event-boot/src/test/java/com/njcn/zlevent/FileDownloadTest.java

@@ -0,0 +1,33 @@
+package com.njcn.zlevent;
+
+import org.springframework.boot.test.context.SpringBootTest;
+
+/**
+ * @author caozehui
+ * @data 2026-03-17
+ */
+@SpringBootTest
+public class FileDownloadTest {
+
+//    @Resource
+//    private FileDownloadProducer fileDownloadProducer;
+//
+//    @Test
+//    public void testSend() {
+//        BaseRequestDTO<FileDownloadRequestDTO> message = new BaseRequestDTO<>();
+//        message.setGuid(IdUtil.simpleUUID());
+//        message.setNode(1);
+//        message.setDevId("167456737637374567");
+//        message.setFrontId("dhdfhdfghd2342");
+//        // 设置 detail（重要！）
+//        BaseRequestDTO.Detail<FileDownloadRequestDTO> detail = new BaseRequestDTO.Detail<>();
+//        detail.setType(8498);  // 设置类型
+//        FileDownloadRequestDTO fileDownloadRequestDTO = new FileDownloadRequestDTO();
+//        fileDownloadRequestDTO.setName("/etc/vol1_stat.txt");
+//        detail.setMsg(fileDownloadRequestDTO);  // 设置消息体
+//        message.setDetail(detail);
+//        SendResult send = fileDownloadProducer.send(message);
+//        System.out.println(JSON.toJSON(send));
+//    }
+
+}

iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldDevRunFlagConsumer.java

@@ -49,7 +49,7 @@ public class CldDevRunFlagConsumer extends EnhanceConsumerMessageHandler<CldDevi
     protected void handleMessage(CldDeviceRunFlagMessage cldDeviceRunFlagMessage) {
         log.info("分发至翻转设备状态");
         int status = Objects.equals(cldDeviceRunFlagMessage.getStatus(),"0") ? 1 : 2;
-        equipmentFeignClient.flipCldDevStatus(cldDeviceRunFlagMessage.getDate(),cldDeviceRunFlagMessage.getId(), status);
+        //equipmentFeignClient.flipCldDevStatus(cldDeviceRunFlagMessage.getDate(),cldDeviceRunFlagMessage.getId(), status);
     }
 
 

iot-message/message-boot/src/main/java/com/njcn/message/consumer/CommonConsumer.java

@@ -0,0 +1,133 @@
+package com.njcn.message.consumer;
+
+import com.alibaba.fastjson.JSON;
+import com.njcn.middle.rocket.constant.EnhanceMessageConstant;
+import com.njcn.middle.rocket.handler.EnhanceConsumerMessageHandler;
+import com.njcn.mq.constant.BusinessTopic;
+import com.njcn.mq.constant.MessageStatus;
+import com.njcn.redis.pojo.enums.AppRedisKey;
+import com.njcn.redis.pojo.enums.RedisKeyEnum;
+import com.njcn.redis.utils.RedisUtil;
+import com.njcn.system.api.RocketMqLogFeignClient;
+import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
+import com.njcn.zlevent.pojo.dto.CommonBaseMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Objects;
+
+/**
+ * @author caozehui
+ * @data 2026-03-18
+ */
+@Service
+@RocketMQMessageListener(
+        topic = BusinessTopic.CLOUD_REPLY_TOPIC,
+        consumerGroup = BusinessTopic.CLOUD_REPLY_TOPIC,
+        consumeThreadNumber = 10,
+        enableMsgTrace = true
+)
+@Slf4j
+public class CommonConsumer extends EnhanceConsumerMessageHandler<CommonBaseMessage> implements RocketMQListener<CommonBaseMessage> {
+
+    @Resource
+    private RedisUtil redisUtil;
+
+    @Resource
+    private RocketMqLogFeignClient rocketMqLogFeignClient;
+
+    @Override
+    protected void handleMessage(CommonBaseMessage message) throws Exception {
+        log.info("@@@@@处理Common信息");
+        System.out.println(JSON.toJSON(message));
+        String guid = message.getGuid();
+
+        // 将响应结果存入 Redis
+        redisUtil.saveByKeyWithExpire(AppRedisKey.COMMON_RESOPNSE + guid, JSON.toJSONString(message), 120L);
+    }
+
+    /***
+     * 通过redis分布式锁判断当前消息所处状态
+     * 1、null 查不到该key的数据，属于第一次消费，放行
+     * 2、fail 上次消息消费时发生异常，放行
+     * 3、being processed 正在处理，打回去
+     * 4、success 最近72小时消费成功，避免重复消费，打回去
+     */
+    @Override
+    protected boolean filter(CommonBaseMessage message) {
+        String keyStatus = redisUtil.getStringByKey(AppRedisKey.RMQ_FILE_CONSUME_KEY.concat(message.getKey()));
+        if (Objects.isNull(keyStatus) || keyStatus.equalsIgnoreCase(MessageStatus.FAIL)) {
+            redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_FILE_CONSUME_KEY.concat(message.getKey()), MessageStatus.BEING_PROCESSED, 60L);
+            return false;
+        }
+        return true;
+    }
+
+    /**
+     * 消费成功，缓存到redis72小时，避免重复消费
+     */
+    @Override
+    protected void consumeSuccess(CommonBaseMessage message) {
+        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_FILE_CONSUME_KEY.concat(message.getKey()), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+    }
+
+    /**
+     * 发生异常时，进行错误信息入库保存
+     * 默认没有实现类，子类可以实现该方法，调用feign接口进行入库保存
+     */
+    @Override
+    protected void saveExceptionMsgLog(CommonBaseMessage message, String identity, Exception exception) {
+        redisUtil.saveByKeyWithExpire(AppRedisKey.RMQ_FILE_CONSUME_KEY.concat(message.getKey()), MessageStatus.FAIL, RedisKeyEnum.ROCKET_MQ_KEY.getTime());
+        RocketmqMsgErrorLog rocketmqMsgErrorLog = new RocketmqMsgErrorLog();
+        rocketmqMsgErrorLog.setMsgKey(message.getKey());
+        rocketmqMsgErrorLog.setResource(message.getSource());
+        if (identity.equalsIgnoreCase(EnhanceMessageConstant.IDENTITY_SINGLE)) {
+            //数据库字段配置长度200，避免插入失败，大致分析异常原因
+            String exceptionMsg = exception.getMessage();
+            if (exceptionMsg.length() > 200) {
+                exceptionMsg = exceptionMsg.substring(0, 180);
+            }
+            rocketmqMsgErrorLog.setRecord(exceptionMsg);
+            //如果是当前消息重试的则略过
+            if (!message.getSource().startsWith(EnhanceMessageConstant.RETRY_PREFIX)) {
+                //单次消费异常
+                rocketMqLogFeignClient.add(rocketmqMsgErrorLog);
+            }
+        } else {
+            rocketmqMsgErrorLog.setRecord("重试消费" + super.getMaxRetryTimes() + "次，依旧消费失败。");
+            //重试N次后，依然消费异常
+            rocketMqLogFeignClient.add(rocketmqMsgErrorLog);
+        }
+    }
+
+
+    /***
+     * 处理失败后，是否重试
+     * 一般开启
+     */
+    @Override
+    protected boolean isRetry() {
+        return true;
+    }
+
+
+    /***
+     * 消费失败是否抛出异常，抛出异常后就不再消费了
+     */
+    @Override
+    protected boolean throwException() {
+        return false;
+    }
+
+
+    /***
+     * 调用父类handler处理消息的元信息
+     */
+    @Override
+    public void onMessage(CommonBaseMessage message) {
+        super.dispatchMessage(message);
+    }
+}

pom.xml

@@ -47,10 +47,10 @@
 
     <!--103线上-->
     <middle.server.url>192.168.1.103</middle.server.url>
-    <service.server.url>192.168.1.103</service.server.url>
+    <service.server.url>192.168.2.124</service.server.url>
     <docker.server.url>192.168.1.103</docker.server.url>
     <nacos.url>${middle.server.url}:18848</nacos.url>
-    <nacos.namespace></nacos.namespace>
+    <nacos.namespace>cb3a03dd-47f6-4a83-9408-b3182b3d0619</nacos.namespace>
 
 <!--    <middle.server.url>192.168.1.22</middle.server.url>-->
 <!--    <service.server.url>192.168.1.126</service.server.url>-->