feat: 设备指令下发

guzijian
1 parent 5598699e
Showing 74 changed files with 3596 additions and 2 deletions
Bsth-admin/pom.xml
Bsth-admin/src/main/java/com/ruoyi/common/global/IDeviceException.java
Bsth-admin/src/main/java/com/ruoyi/system/client/ClientHandler.java
Bsth-admin/src/main/java/com/ruoyi/system/client/NettyClientDemoMain.java
Bsth-admin/src/main/java/com/ruoyi/system/controller/DeviceCommandController.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/active/ActiveBase.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/active/Sos.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/active/UploadGpsTime.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/active/WhiteListPeople.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/Bluetooth.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/BluetoothInfo.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/DeviceAlarm.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/GpsInfo.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/HealthInfo.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/ImageInfo.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/KeepLiveInfo.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/PowerAlarm.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/SpeechInfo.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/WearingState.java
Bsth-admin/src/main/java/com/ruoyi/system/domain/command/WifiInfo.java
@@ -74,6 +74,12 @@
             <artifactId>mysql-connector-j</artifactId>
             <version>8.0.33</version>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.101.Final</version>
+        </dependency>
  
         <!-- 核心模块-->
         <dependency>
+package com.ruoyi.common.global;
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * 设备异常
+ * @author 20412
+ */
+@Data
+@NoArgsConstructor
+public class IDeviceException extends RuntimeException{
+    private String msg;
+    private ResultCode code;
+
+    public IDeviceException(ResultCode code, String msg) {
+        this.msg = msg;
+        this.code = code;
+    }
+}
+package com.ruoyi.system.client;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.util.CharsetUtil;
+
+import java.util.Scanner;
+
+/**
+ * 测试类 模拟手表设备
+ */
+public class ClientHandler extends ChannelInboundHandlerAdapter {
+//    @Override
+//    public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
+//        ctx.writeAndFlush(Unpooled.copiedBuffer("IWAP00353456789012345#", CharsetUtil.UTF_8));
+////        super.channelRegistered(ctx);
+//    }
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        ByteBuf byteBuf = (ByteBuf) msg;
+        String str = byteBuf.toString(CharsetUtil.UTF_8);
+        System.out.println("收到服务端" + ctx.channel().remoteAddress() + "的消息：" + byteBuf.toString(CharsetUtil.UTF_8));
+
+        // 判断是否需要发送
+        if (str.startsWith("IWBP12")) {
+            String replace = str.replace(",353456789012345","").replace("IWBP12", "IWAP12");
+            System.out.println("客户端响应" + ctx.channel().remoteAddress() + "的消息：" + byteBuf.toString(CharsetUtil.UTF_8));
+            ctx.channel().writeAndFlush(Unpooled.copiedBuffer(replace, CharsetUtil.UTF_8));
+        }
+        if (str.startsWith("IWBP15")) {
+            String replace = str.replace(",353456789012345","").replace("IWBP15", "IWAP15");
+            System.out.println("客户端响应" + ctx.channel().remoteAddress() + "的消息：" + byteBuf.toString(CharsetUtil.UTF_8));
+            ctx.channel().writeAndFlush(Unpooled.copiedBuffer(replace, CharsetUtil.UTF_8));
+        }
+//        else {
+//            Scanner sc = new Scanner(System.in);
+//            String line = sc.nextLine();
+//            ctx.channel().writeAndFlush(Unpooled.copiedBuffer(line, CharsetUtil.UTF_8));
+//        }
+    }
+
+
+//    @Override
+//    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+//        ctx.writeAndFlush(Unpooled.copiedBuffer("歪比巴卜~茉莉~Are you good~马来西亚~", CharsetUtil.UTF_8));
+//    }
+
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        ctx.writeAndFlush(Unpooled.copiedBuffer("IWAP00353456789012345#", CharsetUtil.UTF_8));
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        System.out.println(cause.getMessage());
+    }
+
+
+}
+package com.ruoyi.system.client;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+
+
+public class NettyClientDemoMain {
+    public static void main(String[] args) throws Exception {
+        NioEventLoopGroup eventExecutors = new NioEventLoopGroup();
+        ChannelFuture channelFuture = null;
+        try {
+            //创建bootstrap对象，配置参数
+            Bootstrap bootstrap = new Bootstrap();
+            //设置线程组
+            bootstrap.group(eventExecutors)
+                    //设置客户端的通道实现类型
+                    .channel(NioSocketChannel.class)
+                    //使用匿名内部类初始化通道
+                    .handler(new ChannelInitializer<SocketChannel>() {
+                        @Override
+                        protected void initChannel(SocketChannel ch) throws Exception {
+                            //添加客户端通道的处理器
+                            ch.pipeline().addLast(new ClientHandler());
+                        }
+                    });
+            System.out.println("客户端准备就绪，随时可以起飞~");
+            //连接服务端
+            channelFuture = bootstrap.connect("127.0.0.1", 8989).sync();
+            channelFuture.channel().closeFuture().sync();
+
+        } finally {
+            //关闭线程组
+            eventExecutors.shutdownGracefully();
+        }
+    }
+}
+
+package com.ruoyi.system.controller;
+
+import com.ruoyi.common.global.Result;
+import com.ruoyi.system.domain.active.Sos;
+import com.ruoyi.system.domain.active.UploadGpsTime;
+import com.ruoyi.system.domain.active.WhiteListPeople;
+import com.ruoyi.system.service.IDeviceService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/command/send")
+public class DeviceCommandController {
+    @Autowired
+    private IDeviceService deviceService;
+
+    @PostMapping("/settingSos")
+    public Result<?> settingSos(@RequestBody Sos sos) {
+        return deviceService.settingSos(sos);
+    }
+
+
+    @PostMapping("/settingWhiteList")
+    public Result<?> settingWhiteList(@RequestBody WhiteListPeople wlp) {
+        return deviceService.settingWhiteList(wlp);
+    }
+
+    @PostMapping("/settingGpsUploadTime")
+    public Result<?> settingGpsUploadTime(@RequestBody UploadGpsTime ugt) {
+        return deviceService.settingGpsUploadTime(ugt);
+    }
+}
+package com.ruoyi.system.domain.active;
+
+public class ActiveBase {
+    private String imei;
+
+    public String getImei() {
+        return imei;
+    }
+
+    public void setImei(String imei) {
+        this.imei = imei;
+    }
+}
+package com.ruoyi.system.domain.active;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * sos信息设置
+ * @author 20412
+ */
+@Data
+public class Sos extends ActiveBase{
+    private List<String> calls;
+}
+package com.ruoyi.system.domain.active;
+
+import lombok.Data;
+
+/**
+ * @author 20412
+ */
+@Data
+public class UploadGpsTime  extends ActiveBase{
+    private Integer seconds;
+}
+package com.ruoyi.system.domain.active;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 联系人白名单
+ * @author 20412
+ */
+@Data
+public class WhiteListPeople extends ActiveBase {
+    private List<Contact> contacts;
+    @Data
+    public static class Contact {
+        private String name;
+        private String tell;
+    }
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class Bluetooth {
+    /** 蓝牙名称 */
+    private String name;
+    /** mac 地址 */
+    private String mac;
+    /** 信号强度 */
+    private String signalStrong;
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class BluetoothInfo {
+    private String imei;
+    private List<Bluetooth> bluetoothList;
+    private String mac;
+    private String timestamp;
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.Data;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 设备报警
+ * @author 20412
+ */
+@Data
+public class DeviceAlarm {
+    private String imei;
+    private Date createTime;
+    private String deviceDate;
+    private String gpsLabel;
+    /** 地址是否有效 A 还是V */
+    private String addressCheck;
+    /** ddmm.mmmm维度 */
+    private String gpsN;
+    /** dddmm.mmmm 经度 */
+    private String gpsE;
+    private String speed;
+    private String deviceTime;
+    private String direction;
+    private String gms;
+    /** 参与定位的卫星数 */
+    private String gpsSatelliteCount;
+    private String power;
+    private String placeholder;
+    /** 是否设防 01 设防 00 未设置 */
+    private String isSafety;
+    /** 是否为工作模式 02 工作模式 */
+    private String isWork;
+    private String mcc;
+    private String mnc;
+    private String lac;
+    private String cid;
+    /** 告警值
+     *  01	SOS	        02	低电	        03	摘除手表
+     *  04	预留	        05	防拆表带打开	06	跌倒
+     *  07	无效的心率值	08	心率过高	    09	心率过低
+     *  10	舒张压过高	11	舒张压过低	12	收缩压过高
+     *  13	收缩压过低	14	久坐	        15	预留
+     *  16	防拆表带锁上	17	体温过高	    18	体温过低
+     *  19	关机	        20	离开电子围栏	21	进入电子围栏
+     *  22	消息已阅读 */
+    private String alarmValue;
+    /** 设备语言 */
+    private String deviceLanguage;
+    /** 设备标志位 */
+    private String alarmInfoLabel;
+    private List<WifiInfo> wifiInfo;
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.Data;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * gps信息
+ * @author 20412
+ */
+@Data
+public class GpsInfo {
+    private String imei;
+    private String commandLabel;
+    /** 地址是否有效 A 还是V */
+    private String addressCheck;
+    private Date createTime;
+    private String deviceDate;
+    private String gpsLabel;
+    /** ddmm.mmmm维度 */
+    private String gpsN;
+    /** dddmm.mmmm 经度 */
+    private String gpsE;
+    /** 速度 */
+    private String speed;
+    private String deviceTime;
+    private String direction;
+    private String gms;
+    /** 参与定位的卫星数 */
+    private String gpsSatelliteCount;
+    private String power;
+    private String placeholder;
+    /** 是否设防 01 设防 00 未设置 */
+    private String isSafety;
+    /** 是否为工作模式 02 工作模式 */
+    private String isWork;
+    private String mcc;
+    private String mnc;
+    private String lac;
+    private String cid;
+    /** 网络识别码 */
+    private String sid;
+    /** 网络识别码 */
+    private String nid;
+    /** 小区唯一识别码 */
+    private String bid;
+    /** 信号强度 */
+    private Integer signal;
+    private List<WifiInfo> wifiInfoList;
+
+    private String languageLabel;
+    private String replyLabel;
+    /** 基站组数 */
+    private Integer baseStationGroups;
+    /** 基站集合 */
+    private List<BaseStation> baseStations;
+    /** wifi组数 */
+    private Integer wifiGroups;
+
+    private String remark;
+
+    @Data
+    public static class BaseStation {
+        private String lac;
+        private String cid;
+        /** 信号强度 */
+        private String dbm;
+    }
+
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @author 20412
+ */
+@Data
+public class HealthInfo {
+    private String imei;
+    private String commandLabel;
+    private String power;
+    private String uploadTime;
+    /** 1:健康数据类型,取值1表示血压，取值2表示心率，取值3表示体温，4表示血氧 */
+    private String healthType;
+    // 691120:健康数值,根据类型不同数据内容有不同。691120表示,舒张压(低压)69,收缩压(高 压)120,中间的1为多个参数分隔符。
+    // 当健康数据类型为3时，后面的健康数值是体温，36.19是具体的温度值，单位为摄氏度
+    // 若只有一个参数则无需分隔符,例如心率:80,则包为:WAPJK,2021-05-29100:00,2,80#
+    private String heartRate;
+    /** 高压 */
+    private Integer highPressure;
+    /** 低压 */
+    private Integer lowPressure;
+    /** 体温 */
+    private Float temperature;
+    /** 血氧 */
+    private String bloodOxygen;
+    /** 血糖 */
+    private String bloodSugar;
+    /** 手腕温度 */
+    private String handTemperature;
+    private Date createTime;
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @author 20412
+ */
+@Data
+public class ImageInfo {
+    private String imei;
+    private String imageUrl;
+    private String uploadTime;
+    private Date createTime;
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 心跳包
+ * @author 20412
+ */
+@Data
+public class KeepLiveInfo {
+    private String imei;
+    private String commandLabel;
+    private Date createTime;
+    private String gsm;
+    private String satelliteCount;
+    private String power;
+    private String placeholder;
+    private String isSafety;
+    private String isWork;
+    /** 计步数 */
+    private String step;
+    /** 翻滚次数 */
+    private String rollingCount;
+    /** 定位间隔 */
+    private String gpsInterval;
+    private String remark;
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 电源警告
+ * @author 20412
+ */
+@Data
+public class PowerAlarm {
+    private String power;
+    private Date createTime;
+    private String imei;
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 语音包
+ * @author 20412
+ */
+@Data
+public class SpeechInfo {
+    private String imei;
+    private String speechUrl;
+    private String uploadTime;
+    private Date createTime;
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 佩戴状态
+ * @author 20412
+ */
+@Data
+public class WearingState {
+    private String imei;
+    private String state;
+    private Long timestamp;
+    private Date createTime;
+}
+package com.ruoyi.system.domain.command;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class WifiInfo {
+    private String ssid;
+    private String mac;
+    private String signal;
+}
+package com.ruoyi.system.domain.entity;
+
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class Device {
+    /**
+     * 设备号
+     */
+    private String imei;
+
+    private String ip;
+
+    private String version;
+
+    /**
+     * MCC 标识移动通信网络所属国家或地区的代码
+     */
+    private String mcc;
+
+    /**
+     * MNC 标识移动网络运营商的代码
+     */
+    private String mnc;
+
+    /**
+     * APN 建立移动网络数据连接的配置信息
+     */
+    private String apn;
+
+    //，通过将 IMSI 存储在 SIM 卡中，并将 ICCID 与 IMSI 关联，可以实现对移动网络用户和 SIM 卡的管理和追踪
+
+    /**
+     * ICCID 用于唯一标识 SIM 卡 可以用于激活、注册、识别和管理 SIM 卡
+     */
+    private String iccId;
+
+    /**
+     * IMSI 用于唯一标识移动网络用户
+     */
+    private String imsi;
+
+
+    private Date createTime;
+
+    private Date updateTime;
+    private String id;
+
+    private String remark;
+    private Integer state;
+
+}
+package com.ruoyi.system.domain.response;
+
+import lombok.Data;
+
+import javax.xml.bind.annotation.XmlAccessType;
+import javax.xml.bind.annotation.XmlAccessorType;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlRootElement;
+
+@Data
+@XmlRootElement(name = "response")
+@XmlAccessorType(value = XmlAccessType.FIELD)
+public class BaseStationResponse {
+    @XmlElement(name="errcode")
+    private String errcode;
+    @XmlElement(name="lat")
+    private String lat = "00.000000";
+    @XmlElement(name="lon")
+    private String lon = "000.000000";
+    @XmlElement(name="radius")
+    private String radius;
+    @XmlElement(name="address")
+    private String address;
+}
+package com.ruoyi.system.domain.response;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class WeatherResponse {
+    private String code;
+
+    private String updateTime;
+
+    private String fxLink;
+
+    private List<Daily> daily;
+
+    private Refer refer;
+    @Data
+    public static class Daily
+    {
+        private String fxDate;
+
+        private String sunrise;
+
+        private String sunset;
+
+        private String moonrise;
+
+        private String moonset;
+
+        private String moonPhase;
+
+        private String moonPhaseIcon;
+
+        private String tempMax;
+
+        private String tempMin;
+
+        private String iconDay;
+
+        private String textDay;
+
+        private String iconNight;
+
+        private String textNight;
+
+        private String wind360Day;
+
+        private String windDirDay;
+
+        private String windScaleDay;
+
+        private String windSpeedDay;
+
+        private String wind360Night;
+
+        private String windDirNight;
+
+        private String windScaleNight;
+
+        private String windSpeedNight;
+
+        private String humidity;
+
+        private String precip;
+
+        private String pressure;
+
+        private String vis;
+
+        private String cloud;
+
+        private String uvIndex;
+    }
+
+    @Data
+    public static class Refer
+    {
+        private List<String> sources;
+
+        private List<String> license;
+    }
+
+
+}
+package com.ruoyi.system.handler;
+
+import com.ruoyi.common.global.IDeviceException;
+import com.ruoyi.common.global.Result;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+/**
+ * @author 20412
+ */
+@RestControllerAdvice
+public class DeviceExceptionHandler {
+    private static final Logger log = LoggerFactory.getLogger(DeviceExceptionHandler.class);
+
+    @ExceptionHandler(IDeviceException.class)
+    public Result<?> handlerDeviceException(IDeviceException e) {
+        log.error(e.getMsg());
+        return Result.ERROR(e.getCode(), e.getMsg());
+    }
+}
+package com.ruoyi.system.handler;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.strategy.CommandStrategy;
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SocketServerHandler extends ChannelInboundHandlerAdapter {
+    CommandStrategy strategy;
+    private static final Logger log = LoggerFactory.getLogger(SocketServerHandler.class);
+
+    public SocketServerHandler() {
+        this.strategy = new CommandStrategy();
+    }
+
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        ByteBuf buf = (ByteBuf) msg;
+        // 处理指令
+        strategy.handler(buf.toString(CharsetUtil.UTF_8), ctx);
+    }
+
+    @Override
+    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+//        System.out.println(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).get());
+        super.channelReadComplete(ctx);
+    }
+
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        String imei = AttributeKey.valueOf(ThinkraceUtil.IMEI).toString();
+        // 发生异常触发
+        ThinkraceUtil.removeDevice(imei);
+        log.info("发生未知错误，设备:{}将关闭连接,原因:{}", imei, cause.getMessage());
+        ctx.close();
+    }
+
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+//        ctx.channel().close();
+        super.channelActive(ctx);
+    }
+
+    @Override
+    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        log.info("设备断开连接了，设备号为：{}", imei);
+    }
+}
+package com.ruoyi.system.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.system.domain.entity.Device;
+
+/**
+ * deviceMapper接口
+ * 
+ * @author bsth
+ * @date 2024-04-17
+ */
+public interface DeviceMapper extends BaseMapper<Device>
+{
+
+}
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.ruoyi.system.mapper.DeviceMapper">
+    
+    <resultMap type="Device" id="DeviceResult">
+        <result property="id"    column="id"    />
+        <result property="imei"    column="imei"    />
+        <result property="ip"    column="ip"    />
+        <result property="version"    column="version"    />
+        <result property="mcc"    column="mcc"    />
+        <result property="mnc"    column="mnc"    />
+        <result property="apn"    column="apn"    />
+        <result property="iccId"    column="iccId"    />
+        <result property="imsi"    column="imsi"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateTime"    column="update_time"    />
+        <result property="remark"    column="remark"    />
+        <result property="state"    column="state"    />
+    </resultMap>
+
+</mapper>
 \ No newline at end of file
+package com.ruoyi.system.protocol;
+
+import com.ruoyi.common.core.redis.RedisCache;
+import com.ruoyi.common.global.IDeviceException;
+import com.ruoyi.common.global.ResultCode;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.Channel;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.TimeUnit;
+
+public class ThinkraceUtil {
+    // 命令过期时间
+    private static final Integer COMMAND_TTL = 300;
+
+    private static final String COMMAND_SN = "command:sn";
+    private static final String COMMAND_SEND = "command:send:";
+    public static final Integer COMMAND_LABEL_SURE = 1;
+    public static final Integer COMMAND_LABEL_INIT = 0;
+    private static final Long SN_LENGTH = 1000000L;
+    private static RedisCache REDIS_CACHE;
+    /**
+     * 指令列表
+     */
+    private static final Map<String, ICommandAdapter> REGEX_MAP = new HashMap<>();
+
+    /**
+     * 时区
+     */
+    public static String UTC_8 = "8";
+    /**
+     * 命令结束符
+     */
+    public static String END_SYMBOL = "#";
+    /**
+     * 设备号
+     */
+    public static String IMEI = "IMEI";
+
+    public static String generatorSn() {
+        Long commandSn;
+        // 防止出现线程安全 重复覆盖值的情况
+        synchronized (ThinkraceUtil.class) {
+            // 指令流水号是6位的 不足补0
+            commandSn = REDIS_CACHE.increment(COMMAND_SN);
+            if (commandSn == null || commandSn > SN_LENGTH) {
+                commandSn = 0L;
+                REDIS_CACHE.setCacheObject(COMMAND_SN, commandSn.intValue());
+            }
+        }
+        String commandSnStr = commandSn.toString();
+        int snLen = (SN_LENGTH.toString().length() - 1) - commandSnStr.length();
+        StringBuilder sb = new StringBuilder();
+        //长度不足6位补零
+        for (int i = 0; i < snLen; i++) {
+            sb.append("0");
+        }
+        return sb + commandSnStr;
+    }
+
+    public static String commandLabelInit(String imei, String sn) {
+        // 存入redis处理会有网络io的消耗  所以redis和服务器最好是在同一台服务器 原则是30s 增加容错
+        String key = getCommandKey(imei, sn);
+        REDIS_CACHE.expire(key, COMMAND_LABEL_INIT, COMMAND_TTL, TimeUnit.SECONDS);
+        return key;
+    }
+
+    private static String getCommandKey(String imei, String sn) {
+        return COMMAND_SEND + imei + ":" + sn;
+    }
+
+    public static Integer getCommandSn(String key) {
+        return REDIS_CACHE.getCacheObject(key);
+    }
+
+
+    public static class REQ {
+        /**
+         * 登陆包
+         */
+        public static final String LOGIN_REQ = "IWAP00";
+        public static final String GPS_REQ = "IWAP01";
+        public static final String MORE_GPS_REQ = "IWAP02";
+        public static final String KEEPLIVE_REQ = "IWAP03";
+        /**
+         * 电量报警
+         */
+        public static final String POWER_REQ = "IWAP04";
+        /**
+         * 这个可能在文档内是被划线了的可能没有启用过 语音传输没有在设备找到按钮
+         */
+        @Deprecated
+        public static final String SPEECH_REQ = "IWAP05";
+        /**
+         * 语音上行
+         */
+        public static final String SPEECH_UP_REQ = "IWAP07";
+        /**
+         * 设备报警与地址回复包
+         */
+        public static final String ALARM_REQ = "IWAP10";
+        public static final String IMAGE_REQ = "IWAP42";
+        public static final String HEART_REQ = "IWAP49";
+        public static final String TEMPERATURE_50_REQ = "IWAP50";
+        public static final String QUERY_BLUETOOTH_REQ = "IWAP51";
+        public static final String CDMA_GPS_REQ = "IWAP91";
+        public static final String CDMA_WIFI_GPS_REQ = "IWAP92";
+        public static final String BLUETOOTH_REQ = "IWAPBL";
+        public static final String HEART_BLOOD_REQ = "IWAPHT";
+        public static final String HEALTH_REQ = "IWAPJK";
+        public static final String TEMPERATURE_REQ = "IWAPTP";
+        public static final String VERSION_REQ = "IWAPVR";
+        public static final String WEARING_REQ = "IWAPWR";
+        /**
+         * 12	上传心率、血压、血氧、血糖
+         */
+        public static final String HEART_RATE_BLOOD_PRESSURE_OXYGEN_SUGAR_REQ = "IWAPHP";
+        public static final String BASE_STATION_TIMING_GPS_REQ = "IWAPTM";
+        /**
+         * 14	同步天气
+         */
+        public static final String WEATHER_REQ = "IWAPWT";
+        /**
+         * 确认已读文字
+         */
+        public static final String SURE_TEXT_REQ = "IWAP94";
+        public static final String ECG_DATA_REQ = "IWAPHD";
+        /**
+         * 设备响应
+         */
+        public static final String CONTACT_REQ = "IWAP14";
+        public static final String SOS_REQ = "IWAP12";
+
+
+        public static final String UPLOAD_GPS_TIME_REQ = "IWAP15";
+
+    }
+
+    public static class RES {
+        /**
+         * 登陆包
+         */
+        public static final String LOGIN_RES = "IWBP00";
+        /**
+         * 定位
+         */
+        public static final String GPS_RES = "IWBP01";
+        /**
+         * 多基站GPS定位
+         */
+        public static final String MORE_GPS_RES = "IWBP02";
+        /**
+         * 心跳
+         */
+        public static final String KEEPLIVE_RES = "IWBP03";
+        public static final String HEART_RES = "IWBP49";
+        public static final String TEMPERATURE_50_RES = "IWBP50";
+        public static final String QUERY_BLUETOOTH_RES = "IWBP51";
+        public static final String CDMA_GPS_RES = "IWBP91";
+
+        public static final String CDMA_WIFI_GPS_RES = "IWBP92";
+        /**
+         * 电源报警
+         */
+        public static final String POWER_RES = "IWBP04";
+        /**
+         * 设备报警与地址回复包
+         */
+        public static final String ALARM_RES = "IWBP10";
+        public static final String IMAGE_RES = "IWBP42";
+        public static final String BLUETOOTH_RES = "IWBPBL";
+        public static final String HEART_BLOOD_RES = "IWBPHT";
+        public static final String HEALTH_RES = "IWBPJK";
+        public static final String TEMPERATURE_RES = "IWBPTP";
+        public static final String HEART_RATE_BLOOD_PRESSURE_OXYGEN_SUGAR_RES = "IWBPHP";
+        /**
+         * 基站校时并获取经纬度协议
+         */
+        public static final String BASE_STATION_TIMING_GPS_RES = "IWBPTM";
+        ;
+        /**
+         * 确认已读文字
+         */
+        public static final String SURE_TEXT_RES = "IWBP94";
+        public static final String ECG_DATA_RES = "IWBPHD";
+        @Deprecated
+        public static final String SPEECH_RES = "IWBP05";
+        public static final String SPEECH_UP_RES = "IWBP07";
+        public static final String WEATHER_RES = "IWBPWT";
+    }
+
+    /**
+     * 下发指令集
+     */
+    public static class ACTIVE {
+        public static final String CONTACT_ACTIVE = "IWBP14";
+        public static final String UPLOAD_GPS_TIME_ACTIVE = "IWBP15";
+        public static final String SOS_ACTIVE = "IWBP12";
+    }
+
+
+    public static ICommandAdapter getAdapter(String key) {
+        return REGEX_MAP.get(key);
+    }
+
+    public static void addAdapter(String key, ICommandAdapter adapter) {
+        REGEX_MAP.put(key, adapter);
+    }
+
+    public static void removeDevice(String imei) {
+        DeviceManager.removeDevice(imei);
+    }
+
+    public static boolean hasDevice(Channel channel) {
+        return DeviceManager.hasDevice(channel);
+    }
+
+    public static void sendCommand(String imei, String command) {
+        DeviceManager.sendCommand(imei, command);
+    }
+
+    public static boolean askCommand(String txt, String imei, String command, String commandSn, ICommandAdapter adapter) {
+        return DeviceManager.askCommand(txt, imei, command, commandSn, adapter);
+    }
+
+    public static void setDevice(String imei, ChannelHandlerContext ctx) {
+        DeviceManager.onlineDevice(imei, ctx);
+    }
+
+
+    /**
+     * 管理设备
+     *
+     * @author 20412
+     */
+    protected static class DeviceManager {
+
+        private static final Logger log = LoggerFactory.getLogger(DeviceManager.class);
+        private static final ConcurrentHashMap<String, Channel> DEVICE_MAP = new ConcurrentHashMap<>();
+
+        /**
+         * 设备上线
+         *
+         * @param imei 设备号
+         * @param ctx  当前连接的处理器上下文
+         */
+        public static void onlineDevice(String imei, ChannelHandlerContext ctx) {
+            if (DEVICE_MAP.containsKey(imei)) {
+                // 关闭之前的连接
+                Channel channel = DEVICE_MAP.get(imei);
+                channel.close();
+            }
+            // 为当前连接设置id
+            Channel channel = ctx.channel();
+            channel.attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).set(imei);
+            // 继续传递事件给下一个 ChannelHandler
+            ctx.fireChannelActive();
+            init(imei, channel);
+            log.info("设备上线：设备号为：{}", imei);
+        }
+
+        /**
+         * 移除设备 以及资源管理器
+         *
+         * @param imei 设备号
+         */
+        public static void removeDevice(String imei) {
+            if (DEVICE_MAP.containsKey(imei)) {
+                clean(imei);
+                log.info("设备离线，设备号为：{}", imei);
+            }
+        }
+
+        /**
+         * 向设备发送指令
+         *
+         * @param imei    设备号
+         * @param command 指令
+         * @return obj      处理结果
+         */
+        public static void sendCommand(String imei, String command) {
+            log.info("服务器发起:{}", command);
+            Channel channel = DEVICE_MAP.get(imei);
+            if (Objects.isNull(channel)) {
+                throw new IDeviceException(ResultCode.CODE_207, "设备" + imei + "不在线");
+            }
+            channel.writeAndFlush(Unpooled.copiedBuffer(command, CharsetUtil.UTF_8));
+        }
+
+        /**
+         * 判断信道内是否有设备注册
+         *
+         * @param channel 通道
+         * @return result 如果存在返回 --true 如果不存在返回 --false
+         */
+        public static boolean hasDevice(Channel channel) {
+            AttributeKey<String> key = AttributeKey.valueOf(ThinkraceUtil.IMEI);
+            //netty移除了这个map的remove方法,这里的判断谨慎一点
+            return (channel.hasAttr(key) || channel.attr(key).get() != null);
+        }
+
+
+        // 设备上线 创建资源管理器
+        private static void init(String imei, Channel channel) {
+            // 设备上线
+            DEVICE_MAP.put(imei, channel);
+        }
+
+        // 离线删除创建的资源管理器
+        private static void clean(String imei) {
+            DEVICE_MAP.remove(imei);
+        }
+
+        /**
+         * 指令响应
+         *
+         * @param imei      设备号 可以为 -- null
+         * @param command   指令
+         * @param commandSn 指令流水号
+         * @param adapter   适配器  -- 调用适配器的更新方法
+         * @return obj 处理结果
+         */
+        public static boolean askCommand(String txt, String imei, String command, String commandSn, ICommandAdapter adapter) {
+            log.info("{}:设备:{},命令流水号:{},响应命令：{}", txt, imei, commandSn, command);
+            // 通过事件通知 另外单独一个类通知
+            String key = getCommandKey(imei, commandSn);
+            REDIS_CACHE.expire(key, COMMAND_LABEL_SURE, COMMAND_TTL, TimeUnit.SECONDS);
+            return true;
+        }
+    }
+
+
+    public static void initRedisThinkraceCommandParam(RedisCache redisCache) {
+        REDIS_CACHE = redisCache;
+        REDIS_CACHE.setNx(COMMAND_SN, 0);
+    }
+
+}
+package com.ruoyi.system.protocol.adapter;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.device.ILoginPacketAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * 命令适配器基类
+ *
+ * @author 20412
+ */
+public abstract class ICommandAdapter {
+    protected static final Logger log = LoggerFactory.getLogger(ICommandAdapter.class);
+
+
+    /**
+     * 指令解析
+     *
+     * @param command 指令
+     * @param ctx     netty处理器上下文
+     * @return obj 处理结果
+     */
+    public abstract Object resolveCommand(String command, ChannelHandlerContext ctx);
+
+    /**
+     * 指令下发
+     *
+     * @return obj 处理结果
+     */
+    public abstract CommandListen sendCommand(Object params);
+
+
+    /**
+     * 生成命令序列号
+     *
+     * @return commandSn
+     */
+    protected String generatorSn() {
+        return ThinkraceUtil.generatorSn();
+    }
+
+    /**
+     * 设置命令
+     *
+     * @param sn   命令流水号
+     * @param imei 设备号
+     * @return
+     */
+    private CommandListen syncCommandSnAsk(String imei, String sn) {
+        String key = ThinkraceUtil.commandLabelInit(imei, sn);
+        return new CommandListenImpl(key);
+    }
+
+    protected CommandListen syncSendCommand(String imei, String sn, String command) {
+        ThinkraceUtil.sendCommand(imei, command);
+        return syncCommandSnAsk(imei, sn);
+    }
+
+
+    public interface CommandListen {
+        /**
+         * 监听应答
+         *
+         * @return 应答结果
+         */
+        boolean listenAsk();
+    }
+
+    protected class CommandListenImpl implements CommandListen {
+        private String key;
+
+        protected CommandListenImpl(String key) {
+            this.key = key;
+        }
+
+        @Override
+        public boolean listenAsk() {
+            // 循环读取
+            try {
+                Thread.sleep(100);
+                Integer val = ThinkraceUtil.getCommandSn(this.key);
+                while (val != null) {
+                    if (!val.equals(ThinkraceUtil.COMMAND_LABEL_SURE)) {
+                        return true;
+                    }
+                    Thread.sleep(100);
+                    val = ThinkraceUtil.getCommandSn(this.key);
+                }
+                return false;
+            } catch (Exception e) {
+                System.out.println("等待命令响应出现异常：" + e.getMessage());
+                return false;
+            }
+        }
+    }
+
+    protected void responseLog(String imei, String response) {
+        log.info("设备:{},命令解析完毕,返回响应:{}", imei, response);
+    }
+}
+package com.ruoyi.system.protocol.adapter.active;
+
+import com.ruoyi.system.domain.active.WhiteListPeople;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.utils.IUnicodeUtils;
+import io.netty.channel.ChannelHandlerContext;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author 20412
+ * 白名单
+ */
+@Service(ThinkraceUtil.ACTIVE.CONTACT_ACTIVE)
+public class IActiveContactPeopleWhitePacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        // 设置10个联系人白名单
+        // IWBP14,IMEI,指令流水号,联系人1名称|联系人1电话,联系人2名称|联系人2电话,联系人3名称|联系人3电话,联系人4名称|联系人4电话,联系人5名称|联系人5电话,联系人6名称|联系人6电话,联系人7名称|联系人7电话,联系人8名称|联系人8电话,联系人9名称|联系人9电话,联系人10名称|联系人10电话#
+        WhiteListPeople wlp = (WhiteListPeople) params;
+        String commandSn = generatorSn();
+        StringBuilder command = new StringBuilder();
+        command.append(ThinkraceUtil.ACTIVE.CONTACT_ACTIVE).append(",");
+        command.append(wlp.getImei()).append(",");
+        command.append(commandSn).append(",");
+        for (WhiteListPeople.Contact contact : wlp.getContacts()) {
+            command.append(IUnicodeUtils.toUnicode(contact.getName())).append("|").append(contact.getTell()).append(",");
+        }
+        command.deleteCharAt(command.length() - 1).append(ThinkraceUtil.END_SYMBOL);
+        // 发送指令
+        return syncSendCommand(wlp.getImei(), commandSn, command.toString());
+    }
+}
+package com.ruoyi.system.protocol.adapter.active;
+
+import com.ruoyi.system.domain.active.Sos;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+
+
+/**
+ * 下发指令 设置sos联系方式
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.ACTIVE.SOS_ACTIVE)
+public class IActiveSettingSosPacketAdapter extends ICommandAdapter {
+
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        // 格式：IWBP12,IMEI,指令流水号,SOS1,SOS2,SOS3#
+        // 示例：IWBP12,353456789012345,080835,1XXXXXXXX,2XXXXXXXX,3XXXXXXXX#
+        Sos sos = (Sos) params;
+        List<String> commands = new ArrayList<>();
+        commands.add(ThinkraceUtil.ACTIVE.SOS_ACTIVE);
+        commands.add(sos.getImei());
+        commands.add(generatorSn());
+        commands.addAll(sos.getCalls());
+        String command = commands.stream().collect(Collectors.joining(",")) + ThinkraceUtil.END_SYMBOL;
+        return syncSendCommand(sos.getImei(), commands.get(2), command);
+    }
+}
+package com.ruoyi.system.protocol.adapter.active;
+
+import com.ruoyi.system.domain.active.UploadGpsTime;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import org.springframework.stereotype.Service;
+
+
+/**
+ * 下发指令 设置sos联系方式
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.ACTIVE.UPLOAD_GPS_TIME_ACTIVE)
+public class IActiveUploadGpsTimePacketAdapter extends ICommandAdapter {
+
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        // 格式：IWBP15,IMEI,指令流水号,定位间隔#
+        // 示例：IWBP15,353456789012345,080835,300#
+        UploadGpsTime ugt = (UploadGpsTime) params;
+        String sn = generatorSn();
+        StringBuilder command = new StringBuilder();
+        command.append(ThinkraceUtil.ACTIVE.UPLOAD_GPS_TIME_ACTIVE).append(",");
+        command.append(ugt.getImei()).append(",");
+        command.append(sn).append(",");
+        command.append(ugt.getSeconds());
+        command.append(ThinkraceUtil.END_SYMBOL);
+        return syncSendCommand(ugt.getImei(), sn, command.toString());
+    }
+}
+package com.ruoyi.system.protocol.adapter.callback;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author 20412
+ * 白名单
+ */
+@Service(ThinkraceUtil.REQ.CONTACT_REQ)
+public class ICallbackContactPeopleWhitePacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // IWAP14,080835, D3590D54|135xxxxxxxxxx,
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        String[] params = command.split(",");
+        return ThinkraceUtil.askCommand("设置联系人白名单", imei, command, params[1], this);
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.callback;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.SOS_REQ)
+public class ICallbackSettingSosPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // IWAP12,指令流水号,SOS1,SOS2, SOS3#
+        // IWAP12,080835, 1XXXXXXXX,2XXXXXXXX,3XXXXXXXX #
+        // 080835: 终端响应的时候带上响应流水号
+        // 1XXXXXXXX,2XXXXXXXX,3XXXXXXXX
+        String[] params = command.split(",");
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        // 命令确认应答
+        return ThinkraceUtil.askCommand("设置sos命令响应",imei, command, params[1], this);
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.callback;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.UPLOAD_GPS_TIME_REQ)
+public class ICallbackUploadGpsTimePacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        //IWAP15,指令流水号,定位间隔#
+        String[] params = command.split(",");
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        // 命令确认应答
+        return ThinkraceUtil.askCommand("GPS定位数据上传时间间隔命令响应", imei, command, params[1], this);
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.response.BaseStationResponse;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.utils.ConstDateUtil;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+import javax.xml.bind.JAXBContext;
+import javax.xml.bind.Unmarshaller;
+import java.io.StringReader;
+import java.time.ZoneOffset;
+
+/**
+ * 13	通过基站校时并获取经纬度命令
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.BASE_STATION_TIMING_GPS_REQ)
+public class IBaseStationTimeGpsPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // IWAPTM,460,0,9750,3613#
+        String[] params = command.substring(0, command.length() - 1).split(",");
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        log.info("设备:{},通过基站校时并获取经纬度命令:{}", imei, command);
+        // IWBPTM,20160225090909,22.123456,113.654321#
+        //返回时间，格式为：yyyyMMddHHmmss ，为UTC0 时间
+        String mcc = params[1];
+        String mnc = params[2];
+        String lac = params[3];
+        String cid = params[4];
+        BaseStationResponse obs = getLocation(mcc, mnc, lac, cid);
+        // 这个坐标解析
+        String response = ThinkraceUtil.RES.BASE_STATION_TIMING_GPS_RES + "," + ConstDateUtil.formatDate("yyyyMMddHHmmss", ZoneOffset.UTC)
+                + "," + obs.getLat() + "," + obs.getLon() + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(imei, response);
+        return null;
+    }
+
+    private BaseStationResponse getLocation(String mcc, String mnc, String lac, String cid) {
+        BaseStationResponse result = null;
+        try {
+            StringBuilder sb = new StringBuilder();
+            sb.append("http://api.cellocation.com:84/cell/?");
+            sb.append("mnc=").append(mnc);
+            sb.append("&mcc=").append(mcc);
+            sb.append("&lac=").append(lac);
+            sb.append("&ci=").append(cid);
+            sb.append("&output=xml");
+            RestTemplate restTemplate = new RestTemplate();
+            ResponseEntity<String> response = restTemplate.exchange(sb.toString(), HttpMethod.GET, null, String.class);
+            String xmlData = response.getBody();
+            // 创建JAXB上下文对象，并指定要绑定的根类
+            JAXBContext jaxbContext = JAXBContext.newInstance(BaseStationResponse.class);
+            // 创建Unmarshaller对象，用于将XML数据转换为Java对象
+            Unmarshaller unmarshaller = jaxbContext.createUnmarshaller();
+            // 调用unmarshal方法将XML字符串转换为Java对象
+            result = (BaseStationResponse) unmarshaller.unmarshal(new StringReader(xmlData));
+        } catch (Exception e) {
+            log.error("根据基站获取信息api调用异常:{}", e.getMessage());
+            //若没取到则返回 0 TODO
+            return new BaseStationResponse();
+        }
+        return result;
+
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.GpsInfo;
+import com.ruoyi.system.domain.command.WifiInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.system.protocol.property.DeviceProperty;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * 3.	CDMA GPS定位数据包
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.CDMA_GPS_REQ)
+public class ICdmaGpsPacketAdapter extends ICommandAdapter {
+
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        log.info("CDMA GPS定位数据包:{}", command);
+        // 格式GPS+LBS+状态+基站+WIFI合并包
+        // 示例：IWAP91080524A2232.9806N11404.9355E000.1061830323.8700908000102,
+        // 13824,1,1838,-52,Home|74-DE-2B-44-88-8C|97& Home1|74-DE-2B-44-88-8C|97&Home2|74-DE-2B-44-88-8C|97& Home3|74-DE-2B-44-88-8C|97#
+        GpsInfo gpsCommand = resolveGpsCommand(command);
+        // 返回响应 IWBP91#
+        String response = ThinkraceUtil.RES.CDMA_GPS_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        // 响应log
+        responseLog(imei, response);
+        return gpsCommand;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+
+    /**
+     * 格式GPS+LBS+状态+基站+WIFI合并包
+     * 示例：IWAP91080524A2232.9806N11404.9355E000.1061830323.8700908000102,
+     * 13824,1,1838,-52,Home|74-DE-2B-44-88-8C|97& Home1|74-DE-2B-44-88-8C|97&Home2|74-DE-2B-44-88-8C|97& Home3|74-DE-2B-44-88-8C|97#
+     *
+     * @param command 指令
+     */
+    private GpsInfo resolveGpsCommand(String command) {
+        String conditionRegex = ThinkraceUtil.REQ.CDMA_GPS_REQ + "([0-9]{6})([AV])";
+        // 数据分段
+        String[] sc = command.split(",");
+        String str1 = sc[0];
+        // TODO 判断定位是否有效 匹配 "IWAP01" 后的数字，直到遇到大写字母 "A" 而是V的话 就是不合法
+        Pattern pattern = Pattern.compile(conditionRegex);
+        Matcher matcher = pattern.matcher(str1);
+        GpsInfo gps = new GpsInfo();
+        if (matcher.find()) {
+            // 位置信息合法 todo
+            String addressAndOtherRegex = conditionRegex + "([0-9]{4}.[0-9]{4}N)([0-9]{5}.[0-9]{4}E)(\\d+.[0-9]{1})([0-9]{6})(\\d+.[0-9]{2})([0-9]{3})([0-9]{3})([0-9]{1})([0-9]{2})([0-9]{2})";
+            pattern = Pattern.compile(addressAndOtherRegex);
+            matcher = pattern.matcher(str1);
+            if (matcher.find()) {
+                // 设备时间
+                gps.setDeviceDate(matcher.group(1));
+                gps.setAddressCheck(matcher.group(2));
+                if (DeviceProperty.AddressProperty.INVALID.equals(gps.getAddressCheck())) {
+                    log.info("gps数据V无效,命令为：{}", command);
+                }
+                // ddmm.mmmm维度
+                gps.setGpsN(matcher.group(3));
+                // dddmm.mmmm 经度
+                gps.setGpsE(matcher.group(4));
+                gps.setSpeed(matcher.group(5));
+                gps.setDeviceTime(matcher.group(6));
+                gps.setDirection(matcher.group(7));
+//                gps.setGms(matcher.group(7));
+                // 参与定位的卫星数
+                gps.setGpsSatelliteCount(matcher.group(8));
+                gps.setPower(matcher.group(9));
+                gps.setPlaceholder(matcher.group(10));
+                // 是否设防 01 设防 00 未设置
+                gps.setIsSafety(matcher.group(11));
+                // 是否为工作模式 02 工作模式
+                gps.setIsWork(matcher.group(12));
+                gps.setSid(sc[1]);
+                gps.setNid(sc[2]);
+                gps.setBid(sc[3]);
+                gps.setSignal(Integer.parseInt(sc[4]));
+                // WIFI 信息
+                List<WifiInfo> wifiGroups = new ArrayList<>();
+                gps.setWifiInfoList(wifiGroups);
+                if (sc.length > 5) {
+                    String[] wifiSpilt = sc[5].replace(ThinkraceUtil.END_SYMBOL, "")
+                            .replaceAll(" ", "")
+                            .split("&");
+                    for (String wifi : wifiSpilt) {
+                        String[] wifiInfo = wifi.split("\\|");
+                        wifiGroups.add(new WifiInfo(wifiInfo[0], wifiInfo[1], wifiInfo[2]));
+                    }
+                }
+            }
+        }
+
+        return gps;
+
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.GpsInfo;
+import com.ruoyi.system.domain.command.WifiInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * CDMA基站wifi定位数据包
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.CDMA_WIFI_GPS_REQ)
+public class ICdmaWifiPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // IWAP92,zh_cn,0, 13824,1,1838,-52,4,1|D8-24-BD-79-FA-1F|59&2|3C-46-D8-6D-CE-01|81&3|0C-4C-39-1A-7C-65|69&4|70-A8-E3-5D-D7-C0|65#
+        GpsInfo gi = new GpsInfo();
+        gi.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        log.info("设备:{},CDMA基站wifi定位数据包:{}", gi.getImei(), command);
+        String sub = command.substring(0, command.length() - 1);
+        String[] params = sub.split(",");
+        gi.setCommandLabel(params[0]);
+        gi.setLanguageLabel(params[1]);
+        gi.setReplyLabel(params[2]);
+        gi.setSid(params[3]);
+        gi.setNid(params[4]);
+        gi.setBid(params[5]);
+        gi.setSignal(Integer.parseInt(params[6]));
+        gi.setWifiGroups(Integer.parseInt(params[7]));
+        List<WifiInfo> wifiInfoList = new ArrayList<>();
+        gi.setWifiInfoList(wifiInfoList);
+        String[] wifiInfo = params[8].split("&");
+        for (String baseWifi : wifiInfo) {
+            String[] param = baseWifi.split("\\|");
+            WifiInfo wi = new WifiInfo(param[0], param[1], param[2]);
+            wifiInfoList.add(wi);
+        }
+
+        // 响应 IWBP92#
+        String response = ThinkraceUtil.RES.CDMA_WIFI_GPS_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(gi.getImei(), response);
+        return gi;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.DeviceAlarm;
+import com.ruoyi.system.domain.command.WifiInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.system.protocol.property.DeviceProperty;
+import com.ruoyi.utils.IUnicodeUtils;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * 报警与地址回复包
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.ALARM_REQ)
+public class IDeviceAlarmPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+
+        // IWAP10+时间+GPS位置有效性标志+纬度+经度+速度+定位数据产生时间+方向角+参数,基站数据,报警值,终端语言,标志位,Wi-Fi信息#
+        // 示例：IWAP10080524A2232.9806N11404.9355E000.1061830323.8706000908000502,460,0,9520,3671,00,zh-cn,00,
+        String regex = ThinkraceUtil.REQ.ALARM_REQ + "([0-9]{6})([AV])";
+        // 数据分段
+        String[] sc = command.split(",");
+        String str1 = sc[0];
+        // TODO 判断定位是否有效 匹配 "IWAP01" 后的数字，直到遇到大写字母 "A" 而是V的话 就是不合法
+        Pattern pattern = Pattern.compile(regex);
+        Matcher matcher = pattern.matcher(str1);
+        DeviceAlarm alarm = new DeviceAlarm();
+        alarm.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        log.info("设备:{},报警与地址回复:{}", alarm.getImei(), command);
+        // 匹配是否有效
+        if (matcher.find()) {
+            // 位置信息合法 todo
+            String addressAndOtherRegex = regex + "([0-9]{4}.[0-9]{4}N)([0-9]{5}.[0-9]{4}E)(\\d+.[0-9]{1})([0-9]{6})(\\d+.[0-9]{2})([0-9]{3})([0-9]{3})([0-9]{3})([0-9]{1})([0-9]{2})([0-9]{2})";
+            pattern = Pattern.compile(addressAndOtherRegex);
+            matcher = pattern.matcher(str1);
+            if (matcher.find()) {
+                // 设备时间
+                alarm.setDeviceDate(matcher.group(1));
+                alarm.setAddressCheck(matcher.group(2));
+                if (DeviceProperty.AddressProperty.INVALID.equals(alarm.getAddressCheck())) {
+                    log.info("gps数据V无效,命令为：{}", command);
+                }
+                // ddmm.mmmm维度
+                alarm.setGpsN(matcher.group(3));
+                // dddmm.mmmm 经度
+                alarm.setGpsE(matcher.group(4));
+                alarm.setSpeed(matcher.group(5));
+                alarm.setDeviceTime(matcher.group(6));
+                alarm.setDirection(matcher.group(7));
+                alarm.setGms(matcher.group(8));
+                // 参与定位的卫星数
+                alarm.setGpsSatelliteCount(matcher.group(9));
+                alarm.setPower(matcher.group(10));
+                alarm.setPlaceholder(matcher.group(11));
+                // 是否设防 01 设防 00 未设置
+                alarm.setIsSafety(matcher.group(12));
+                // 是否为工作模式 02 工作模式
+                alarm.setIsWork(matcher.group(13));
+                alarm.setMcc(sc[1]);
+                alarm.setMnc(sc[2]);
+                alarm.setLac(sc[3]);
+                alarm.setCid(sc[4]);
+                // 01	SOS	        02	低电	        03	摘除手表
+                // 04	预留	        05	防拆表带打开	06	跌倒
+                // 07	无效的心率值	08	心率过高	    09	心率过低
+                // 10	舒张压过高	11	舒张压过低	12	收缩压过高
+                // 13	收缩压过低	14	久坐	        15	预留
+                // 16	防拆表带锁上	17	体温过高	    18	体温过低
+                // 19	关机	        20	离开电子围栏	21	进入电子围栏
+                // 22	消息已阅读
+                alarm.setAlarmValue(sc[5]);
+                alarm.setDeviceLanguage(sc[6]);
+                // 第一个0:是否需要回复地址信息标志,取值为0表示不需要回复,取值为1表示需要回复.
+                // 第二个0:地址信息中是否包含手机超链接, 取值为0表示不包含,取值为1表示包含. TODO 什么手机超链接
+                alarm.setAlarmInfoLabel(sc[7]);
+                // WIFI 信息
+                List<WifiInfo> infoList = new ArrayList<>();
+                alarm.setWifiInfo(infoList);
+                String[] wifiSpilt = sc[sc.length - 1].replace(ThinkraceUtil.END_SYMBOL, "")
+                        .replaceAll(" ", "")
+                        .split("&");
+                for (String wifi : wifiSpilt) {
+                    String[] wifiInfo = wifi.split("\\|");
+                    infoList.add(new WifiInfo(wifiInfo[0], wifiInfo[1], wifiInfo[2]));
+                }
+            }
+        }
+        // 返回响应
+        backCommand(ctx, alarm);
+        return alarm;
+    }
+
+    private void backCommand(ChannelHandlerContext ctx, DeviceAlarm alarm) {
+        char isBackAddress = alarm.getAlarmInfoLabel().charAt(0);
+        String response = "";
+        if (isBackAddress == '1') {
+            // TODO 返回地址 判断是否需要返回超链接  地址是解析好的设备传过来的地址还是服务器预留的地址以及连接。
+            String unicode = IUnicodeUtils.toUnicode("深圳市南山区南海大道1079号http://www.gps.com/map.aspx?lat=23.123&lng=113.123");
+            response = ThinkraceUtil.RES.ALARM_RES + unicode + ThinkraceUtil.END_SYMBOL;
+        } else {
+            response = ThinkraceUtil.RES.ALARM_RES + ThinkraceUtil.END_SYMBOL;
+        }
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        // 打印日志
+        responseLog(alarm.getImei(), response);
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+/**
+ * ECG 数据
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.ECG_DATA_REQ)
+public class IEcgDatePacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // IWAPHD,20140818064408,6,1,1.3,20.2,1,1000,1024,XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX#
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        log.info("设备:{},ECG数据命令:{}", imei, command);
+
+        // 响应IWBPHD,0, 98, 59, 156, 296, 369,7aa660275fc35f8b4e0d9f50|623f98a4 #
+        String response = "IWBPHD,0, 98, 59, 156, 296, 369,7aa660275fc35f8b4e0d9f50|623f98a4 #";
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(imei, response);
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.GpsInfo;
+import com.ruoyi.system.domain.command.WifiInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.system.protocol.property.DeviceProperty;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+@Service(ThinkraceUtil.REQ.GPS_REQ)
+public class IGpsPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        log.info("定位数据包：{}", command);
+        // 处理指令 获取gps信息
+        GpsInfo gpsInfo = resolveGpsCommand(command);
+        gpsInfo.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        // 返回响应
+        String response = ThinkraceUtil.RES.GPS_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        // 打印日志
+        responseLog(gpsInfo.getImei(), response);
+        return gpsInfo;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+
+    private GpsInfo resolveGpsCommand(String command) {
+        String conditionRegex = ThinkraceUtil.REQ.GPS_REQ + "([0-9]{6})([AV])";
+        // 数据分段
+        String[] sc = command.split(",");
+        String str1 = sc[0];
+        // TODO 判断定位是否有效 匹配 "IWAP01" 后的数字，直到遇到大写字母 "A" 而是V的话 就是不合法
+        Pattern pattern = Pattern.compile(conditionRegex);
+        Matcher matcher = pattern.matcher(str1);
+        GpsInfo gps = new GpsInfo();
+        if (matcher.find()) {
+            // 位置信息合法 todo
+            String addressAndOtherRegex = conditionRegex + "([0-9]{4}.[0-9]{4}N)([0-9]{5}.[0-9]{4}E)(\\d+.[0-9]{1})([0-9]{6})(\\d+.[0-9]{2})([0-9]{3})([0-9]{3})([0-9]{3})([0-9]{1})([0-9]{2})([0-9]{2})";
+            pattern = Pattern.compile(addressAndOtherRegex);
+            matcher = pattern.matcher(str1);
+            if (matcher.find()) {
+                // 设备时间
+                gps.setDeviceDate(matcher.group(1));
+                gps.setAddressCheck(matcher.group(2));
+                if (DeviceProperty.AddressProperty.INVALID.equals(gps.getAddressCheck())) {
+                    log.info("gps数据V无效,命令为：{}", command);
+                }
+                // ddmm.mmmm维度
+                gps.setGpsN(matcher.group(3));
+                // dddmm.mmmm 经度
+                gps.setGpsE(matcher.group(4));
+                gps.setSpeed(matcher.group(5));
+                gps.setDeviceTime(matcher.group(6));
+                gps.setDirection(matcher.group(7));
+                gps.setGms(matcher.group(8));
+                // 参与定位的卫星数
+                gps.setGpsSatelliteCount(matcher.group(9));
+                gps.setPower(matcher.group(10));
+                gps.setPlaceholder(matcher.group(11));
+                // 是否设防 01 设防 00 未设置
+                gps.setIsSafety(matcher.group(12));
+                // 是否为工作模式 02 工作模式
+                gps.setIsWork(matcher.group(13));
+                gps.setMcc(sc[1]);
+                gps.setMnc(sc[2]);
+                gps.setLac(sc[3]);
+                gps.setCid(sc[4]);
+                // WIFI 信息
+                List<WifiInfo> infoList = new ArrayList<>();
+                gps.setWifiInfoList(infoList);
+                if (sc.length > 5) {
+                    String[] wifiSpilt = sc[5].replace(ThinkraceUtil.END_SYMBOL, "")
+                            .replaceAll(" ", "")
+                            .split("&");
+                    for (String wifi : wifiSpilt) {
+                        String[] wifiInfo = wifi.split("\\|");
+                        infoList.add(new WifiInfo(wifiInfo[0], wifiInfo[1], wifiInfo[2]));
+                    }
+                }
+            }
+        }
+        return gps;
+
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.HealthInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+import static com.ruoyi.system.protocol.property.DeviceProperty.HealthProperty.*;
+
+/**
+ * @author 20412健康
+ */
+@Service(ThinkraceUtil.REQ.HEALTH_REQ)
+public class IHealthPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // 格式：IWAPJK,产生健康数据的时间,健康数据类型,健康数值#
+        // 示例：IWAPJK,2021-05-29 13:00:00,1,691120# 或
+        // IWAPJK,2024-03-28 14:21:09,3,36.19#
+        String[] params = command.split(",");
+        HealthInfo info = new HealthInfo();
+        info.setCreateTime(new Date());
+        info.setCommandLabel(params[0]);
+        info.setUploadTime(params[1]);
+        info.setHealthType(params[2]);
+//        info.setHealthValue(params[3].replace(ThinkraceUtil.END_SYMBOL,""));
+        // 1:健康数据类型,取值1表示血压，取值2表示心率，取值3表示体温，4表示血氧。
+        //691120:健康数值,根据类型不同数据内容有不同。691120表示,舒张压(低压)69,收缩压(高 压)120,中间的1为多个参数分隔符。
+        //当健康数据类型为3时，后面的健康数值是体温，36.19是具体的温度值，单位为摄氏度。
+        //若只有一个参数则无需分隔符,例如心率:80,则包为:WAPJK,2021-05-29100:00,2,80#
+        switch (info.getHealthType()) {
+            case BLOOD_PRESSURE:
+                info.setLowPressure(Integer.parseInt(params[3].substring(0, 2)));
+                info.setHighPressure(Integer.parseInt(params[3].substring(3, 6)));
+                break;
+            case HEART_RATE:
+                info.setHeartRate(params[3]);
+                break;
+            case TEMPERATURE:
+                info.setTemperature(Float.parseFloat(params[3].replace(ThinkraceUtil.END_SYMBOL, "")));
+                break;
+            case BLOOD_OXYGEN:
+                info.setBloodOxygen(params[3]);
+                break;
+        }
+        String response = ThinkraceUtil.RES.HEALTH_RES + "," + info.getHealthType() + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(info.getImei(), response);
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.HealthInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 12	上传心率、血压、血氧、血糖
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.HEART_RATE_BLOOD_PRESSURE_OXYGEN_SUGAR_REQ)
+public class IHeartRateBloodPressureOxygenSugarResPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // IWAPHP,60,130,85,95,90,36.5,,,,,,,#
+        // IWAPHP,83,119,80,,,,,,,,,,#
+        // IWAPHP,,,,98,,,,,,,,,#
+        //IW：标识符
+        //APHT : 命令字符
+        //60 : 表示心率
+        //130: 血压高压 [收缩压]
+        //85 : 血压低压 [舒张压]
+        //95：血氧
+        //90：血糖
+        //36.5: 体温
+        // ,分割
+        List<String> params = new ArrayList<>();
+        StringBuilder sb = new StringBuilder();
+        for (char ch : command.toCharArray()) {
+            if (',' == ch) {
+                params.add(sb.toString());
+                sb = new StringBuilder();
+                continue;
+            }
+            sb.append(ch);
+        }
+        HealthInfo health = new HealthInfo();
+        health.setCommandLabel(params.get(0));
+        health.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        log.info("设备:{},上传心率、血压、血氧、血糖命令:{}", health.getImei(), command);
+        health.setHeartRate(params.get(1));
+        health.setHighPressure(params.get(2).length() != 0 ? Integer.parseInt(params.get(2)) : null);
+        health.setLowPressure(params.get(3).length() != 0 ? Integer.parseInt(params.get(3)) : null);
+        health.setBloodOxygen(params.get(4));
+        health.setBloodSugar(params.get(5));
+        health.setTemperature(params.get(6).length() != 0 ? Float.parseFloat(params.get(6)) : null);
+        String response = ThinkraceUtil.RES.HEART_RATE_BLOOD_PRESSURE_OXYGEN_SUGAR_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(health.getImei(), response);
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.HealthInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+@Service(ThinkraceUtil.REQ.HEART_REQ)
+public class IHeartRatePacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // 格式：IWAP49,心率值#
+        // 示例：IWAP49,68#
+        HealthInfo rateInfo = new HealthInfo();
+        String[] params = command.substring(0, command.length() - 1).split(",");
+        rateInfo.setCommandLabel(params[0]);
+        rateInfo.setHeartRate(params[1]);
+        rateInfo.setCreateTime(new Date());
+        rateInfo.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        log.info("设备:{},心率数据上传命令:{}", rateInfo.getImei(), command);
+        // 返回响应
+        String response = ThinkraceUtil.RES.HEART_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        // 打印日志
+        responseLog(rateInfo.getImei(), response);
+        return rateInfo;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.ImageInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.system.protocol.property.DeviceProperty;
+import com.ruoyi.utils.PathToolUtil;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+/**
+ * 设备图片指令
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.IMAGE_REQ)
+public class IImagePacketAdapter extends ICommandAdapter {
+
+    @Value("${netty.socket.catalogue.image}")
+    private String catalogue;
+
+
+    /**
+     * 图片上行指令
+     *
+     * @param command 指令
+     * @param ctx
+     * @return
+     */
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // TODO 记录表状态  给出耗时 给出当前上传进度 超时机制  重传机制
+        ImageInfo imageInfo = new ImageInfo();
+        imageInfo.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        String[] params = command.substring(0, command.length() - 1).split(",");
+        String count = params[2];
+        String current = params[3];
+        log.info("设备:{},图片上传命令:{},共:{}个包,当前第:{}个包,字节数据:{}", imageInfo.getImei(), command, count, current, params[5]);
+        boolean result = uploadImage(imageInfo.getImei(), params, ctx);
+        // 响应示例
+        // IWBP42, 终端产生图片的时间+图片包总数+当前收到的包号+接收成功标志#
+        // IWBP42,20140818064408,6,1,1#
+        String response = ThinkraceUtil.RES.IMAGE_RES + "," + params[1] + "," + params[2] + "," + params[3] + "," +
+                (result ? DeviceProperty.ImageProperty.UPLOAD_SUCCESS : DeviceProperty.ImageProperty.UPLOAD_FAIL)
+                + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        // TODO 更新写入日志 on key 可以使用mysql的key存在时更新操作把新的文件写入进去
+//        String count = params[2];
+        responseLog(imageInfo.getImei(), response);
+        return imageInfo;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+
+    private boolean uploadImage(String imei, String[] params, ChannelHandlerContext ctx) {
+        // IWAP42,终端产生图片的时间,图片包总数,当前包号,当前包长度,当前包图片数据#
+        // IWAP42,20140818064408,6,1,1024,XXXXXXXXXXXXXXXXXXXXXXXXX#
+        // 数据存入集合全部集齐后写入
+        String uploadTime = params[1];
+        // TODO 当前是否为第一个包 判断资源是否存在
+        String count = params[2];
+        String current = params[3];
+        String packetLength = params[4];
+        String data = params[5];
+        // TODO 写入数据库
+        // 追加数据包
+        boolean result = PathToolUtil.generateRelativeImagePath(catalogue, imei, uploadTime, data.getBytes());
+        return true;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.KeepLiveInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * 心跳包处理
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.KEEPLIVE_REQ)
+public class IKeepLivePacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        KeepLiveInfo heart = handlerHeartPacket(command);
+        heart.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        log.info("设备:{},心跳包:{}", heart.getImei(), command);
+        // 返回响应
+        String response = ThinkraceUtil.RES.KEEPLIVE_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        return heart;
+    }
+
+    private KeepLiveInfo handlerHeartPacket(String command) {
+        String[] params = command.substring(0, command.length() - 1).split(",");
+        KeepLiveInfo heart = new KeepLiveInfo();
+        heart.setCommandLabel(params[0]);
+        // 处理指令
+        String regex = "([0-9]{3})([0-9]{3})([0-9]{3})([0-9]{1})([0-9]{2})([0-9]{2})";
+        Pattern pattern = Pattern.compile(regex);
+        Matcher matcher = pattern.matcher(command);
+        if (matcher.find()) {
+            heart.setGsm(matcher.group(1));
+            heart.setSatelliteCount(matcher.group(2));
+            heart.setPower(matcher.group(3));
+            heart.setPlaceholder(matcher.group(4));
+            heart.setIsSafety(matcher.group(5));
+            heart.setIsWork(matcher.group(6));
+        }
+        // TODO 判断是那种形式的心跳包
+        // IWAP03,06300706800008,0,00,8,600#
+        // IWAP03,GSM信号值+定位卫星数+电池电量+保留位+设防状态+工作模式,计步数值,翻滚次数,工作模式,定位间隔#
+        if (params.length == 6) {
+            heart.setStep(params[2]);
+            heart.setRollingCount(params[3]);
+            heart.setGpsInterval(params[5]);
+        }
+        // IWAP03,06000908000102,5555,30#
+        // IWAP03,GSM信号值+定位卫星数+电池电量+保留位+设防状态+工作模式,计步数,翻滚次数#
+        else {
+            heart.setStep(params[2]);
+            heart.setRollingCount(params[3]);
+        }
+        return heart;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.entity.Device;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.utils.ConstDateUtil;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * @author 20412
+ */
+
+/**
+ * 处理登录包
+ */
+@Service(ThinkraceUtil.REQ.LOGIN_REQ)
+public class ILoginPacketAdapter extends ICommandAdapter {
+
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        Device device = getDeviceInfo(command);
+        ThinkraceUtil.setDevice(device.getImei(), ctx);
+        String response = ThinkraceUtil.RES.LOGIN_RES + "," + ConstDateUtil.formatDate("yyyyMMddHHmmss") + ThinkraceUtil.UTC_8 + ThinkraceUtil.END_SYMBOL;
+        // 返回响应
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(device.getImei(), response);
+        return device;
+    }
+
+    /**
+     * 返回响应
+     *
+     * @return command 指令
+     */
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+
+
+    Device getDeviceInfo(String command) {
+        String[] params = command.split(",");
+        Device device = new Device();
+        device.setCreateTime(new Date());
+        String pattern = ThinkraceUtil.REQ.LOGIN_REQ + "([0-9]{15})";
+        Pattern regex = Pattern.compile(pattern);
+        //格式IWAP00+IMEI#  或者 IWAP00+IMEI,MCC|MNC|APN名称# 或者 IWAP00+IMEI,ICCID,IMSI#
+        if (params.length == 1) {
+            Matcher matcher = regex.matcher(command);
+            if (matcher.find()) {
+                String imei = matcher.group(1);
+                device.setImei(imei);
+            }
+            return device;
+        }
+        // 格式 IWAP00+IMEI,MCC|MNC|APN名称#
+        else if (params.length == 2) {
+            Matcher matcher = regex.matcher(params[0]);
+            if (matcher.find()) {
+                String imei = matcher.group(1);
+                device.setImei(imei);
+            }
+            String[] mma = params[1].split("\\|");
+            device.setMcc(mma[0]);
+            device.setMnc(mma[1]);
+            device.setApn(mma[2].replace(ThinkraceUtil.END_SYMBOL, ""));
+            return device;
+        }
+        // 格式 IWAP00+IMEI,ICCID,IMSI#
+        else {
+            Matcher matcher = regex.matcher(params[0]);
+            if (matcher.find()) {
+                String imei = matcher.group(1);
+                device.setImei(imei);
+            }
+            device.setIccId(params[1]);
+            device.setImsi(params[2].replace(ThinkraceUtil.END_SYMBOL, ""));
+            return device;
+        }
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.GpsInfo;
+import com.ruoyi.system.domain.command.WifiInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 4.	多基站定位数据包
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.MORE_GPS_REQ)
+public class IMoreBaseGpsPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        GpsInfo mgi = new GpsInfo();
+        mgi.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        log.info("设备:{},基站定位数据包:{}", mgi.getImei(), command);
+        // IWAP02,zh_cn,0,7,460,0,9520|3671|13,9520|3672|12,9520|3673|11,9520|3674|10,9520|3675|9,9520|3676|8,9520|3677|7,4,1|D8-24-BD-79-FA-1F|59&2|3C-46-D8-6D-CE-01|81&3|0C-4C-39-1A-7C-65|69&4|70-A8-E3-5D-D7-C0|65#
+        String sub = command.substring(0, command.length() - 1);
+        String[] params = sub.split(",");
+        mgi.setLanguageLabel(params[1]);
+        // 回复标识:回复标识，为0时不回复地址，为 1 时，服务器回复地址信息(目前一定是0)
+        mgi.setReplyLabel(params[2]);
+        mgi.setBaseStationGroups(Integer.parseInt(params[3]));
+        mgi.setMcc(params[4]);
+        mgi.setMnc(params[5]);
+        List<GpsInfo.BaseStation> bsList = new ArrayList<>(mgi.getBaseStationGroups());
+        mgi.setBaseStations(bsList);
+        // 基站数据
+        for (int i = 0; i < mgi.getBaseStationGroups(); i++) {
+            GpsInfo.BaseStation bs = new GpsInfo.BaseStation();
+            String baseParam = params[6 + i];
+            String[] param = baseParam.split("\\|");
+            bs.setLac(param[0]);
+            bs.setCid(param[1]);
+            bs.setDbm(param[2]);
+            bsList.add(bs);
+        }
+        mgi.setWifiGroups(Integer.parseInt(params[6 + mgi.getBaseStationGroups()]));
+        List<WifiInfo> wifiInfoList = new ArrayList<>(mgi.getWifiGroups());
+        mgi.setWifiInfoList(wifiInfoList);
+        // WiFi数据
+        String baseParam = params[7 + mgi.getBaseStationGroups()];
+        String[] param = baseParam.split("&");
+        for (int i = 0; i < param.length; i++) {
+            String[] baseWifi = param[i].split("\\|");
+            WifiInfo wi = new WifiInfo();
+            wi.setSsid(baseWifi[0]);
+            wi.setMac(baseWifi[1]);
+            wi.setSignal(baseWifi[2]);
+            wifiInfoList.add(wi);
+        }
+        String response = ThinkraceUtil.RES.MORE_GPS_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        // 响应日志
+        responseLog(mgi.getImei(), response);
+        return mgi;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.PowerAlarm;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * 低电量报警上报
+ *
+ * @author guzijian
+ */
+@Service(ThinkraceUtil.REQ.POWER_REQ)
+public class IPowerAlarmPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // IWAP04+电池电量#
+        // IWAP04075#
+        PowerAlarm power = handlerPower(command, ctx);
+        // 返回响应
+        String response = ThinkraceUtil.RES.POWER_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        return power;
+    }
+
+    private PowerAlarm handlerPower(String command, ChannelHandlerContext ctx) {
+        String regex = ThinkraceUtil.REQ.POWER_REQ + "(\\d+)";
+        Pattern pattern = Pattern.compile(regex);
+        Matcher matcher = pattern.matcher(command);
+        if (matcher.find()) {
+            PowerAlarm pa = new PowerAlarm();
+            pa.setPower(matcher.group(1));
+            pa.setCreateTime(new Date());
+            pa.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).get().toString());
+            return pa;
+        }
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+/**
+ * 10	查询手表对应的蓝牙温度计SN
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.QUERY_BLUETOOTH_REQ)
+public class IQueryBluetoothPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        log.info("设备:{},查询手表对应的蓝牙温度计SN命令:{}", imei, command);
+        // IWBP51,123456#
+        String response = ThinkraceUtil.RES.QUERY_BLUETOOTH_RES + "," + 123456 + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(imei, response);
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.SPEECH_REQ)
+@Deprecated
+public class ISpeechPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        log.info("设备:{},语音查询接收协议命令:{},未作处理。", imei, command);
+        // TODO
+        // 响应 IWBP05,6#
+        String response = ThinkraceUtil.RES.SPEECH_RES + "," + 6 + ThinkraceUtil.END_SYMBOL;
+        responseLog(imei, response);
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.system.protocol.property.DeviceProperty;
+import com.ruoyi.utils.PathToolUtil;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+/**
+ * 语音上行
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.SPEECH_UP_REQ)
+public class ISpeechUpPacketAdapter extends ICommandAdapter {
+
+    @Value("${netty.socket.catalogue.speech}")
+    private String catalogue;
+
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        // 传输的是字节流 需要处理字节流的数据
+        String[] params = command.substring(0, command.length() - 1).split(",");
+        String count = params[2];
+        String current = params[3];
+        log.info("设备:{},图片上传命令:{},共:{}个包,当前第:{}个包,字节数据:{}", imei, command, count, current, params[5]);
+        boolean result = uploadSpeech(imei, params, ctx);
+
+        // 返回响应 IWBP07,20140818064408,6,1,1#
+        String response = ThinkraceUtil.RES.SPEECH_UP_RES + "," + params[1] + "," + count + "," + current + "," +
+                (result ? DeviceProperty.SpeechProperty.UPLOAD_SUCCESS : DeviceProperty.SpeechProperty.UPLOAD_FAIL) + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(imei, response);
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+
+    private boolean uploadSpeech(String imei, String[] params, ChannelHandlerContext ctx) {
+        // IWAP42,终端产生语音的时间,图片包总数,当前包号,当前包长度,当前包语音数据#
+        // IWAP42,20140818064408,6,1,1024,XXXXXXXXXXXXXXXXXXXXXXXXX#
+        // 数据存入集合全部集齐后写入
+        String uploadTime = params[1];
+        // TODO 当前是否为第一个包 判断资源是否存在
+        String count = params[2];
+        String current = params[3];
+        String packetLength = params[4];
+        String data = params[5];
+        // TODO 写入数据库
+        // 追加数据包
+        PathToolUtil.generateRelativeSpeechPath(catalogue, imei, uploadTime, data.getBytes());
+        return true;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+/**
+ * 确认已读文字
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.SURE_TEXT_REQ)
+public class ISureReadTextPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        //TODO
+        // IWAP94,123456,1#
+        // IWAP94：标识符
+        // APHCI: 命令字符
+        // 123456: 文字来源系统流水号
+        // 1:确认阅读、0：取消阅读
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        log.info("设备:{},确认已读文字命令:{},未作处理。", imei, command);
+        String response = ThinkraceUtil.RES.SURE_TEXT_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(imei, response);
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.ruoyi.system.domain.response.WeatherResponse;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.utils.ConstDateUtil;
+import com.ruoyi.utils.IUnicodeUtils;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.util.Comparator;
+import java.util.List;
+import java.util.zip.GZIPInputStream;
+
+/**
+ * 同步天气
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.WEATHER_REQ)
+public class ISyncWeatherPacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        String imei = ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString();
+        log.info("设备:{},同步天气指令:{}", imei, command);
+        // 三天api https://devapi.qweather.com/v7/weather/3d?{查询参数}
+        // 天气api请求示例 'https://devapi.qweather.com/v7/weather/3d?location=116.41,39.92&key=9ee551aeac884cca8c68d70086708b44'
+        // TODO 后续完善   没有获取设备位置
+        // 先从表中获取当前设备位置 获取指定位置的天气 响应示例 unicode
+        String location = "116.41,39.92";
+        WeatherResponse weather = getWeather(location);
+        // IWBPWT, 深圳, 2018-12-24 16:45:5, 2018-12-25,1, 3,1,晴, 2018-12-26, -1,4,2, 阴, 2018-12-27,3,7, 3,小雨#
+        // IWBPWT, 6df15733, 2018-12-24 16:45:5, 2018-12-25,1, 3, 1, 6674, 2018-12-26, -1,4, 2,9634, 2018-12-27,3,7, 3, 5c0f96e8#
+        String weatherStr = transString("深圳", weather);
+        String response = ThinkraceUtil.RES.WEATHER_RES + weatherStr;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(imei, response);
+        return null;
+    }
+
+    private String transString(String localName, WeatherResponse weather) {
+        StringBuilder sb = new StringBuilder();
+        List<WeatherResponse.Daily> daily = weather.getDaily();
+        sb.append(",").append(IUnicodeUtils.toUnicode(localName));
+        sb.append(",").append(ConstDateUtil.formatDate("yyyy-MM-dd HH:mm:ss"));
+        sb.append(",").append(daily.get(0).getFxDate());
+        sb.append(",").append(daily.get(0).getTempMin());
+        sb.append(",").append(daily.get(0).getTempMax());
+        sb.append(",").append(enumTrans(daily.get(0).getTextDay()));
+        sb.append(",").append(IUnicodeUtils.toUnicode(daily.get(0).getTextDay()));
+
+        sb.append(",").append(daily.get(1).getFxDate());
+        sb.append(",").append(daily.get(1).getTempMin());
+        sb.append(",").append(daily.get(1).getTempMax());
+        sb.append(",").append(enumTrans(daily.get(1).getTextDay()));
+        sb.append(",").append(IUnicodeUtils.toUnicode(daily.get(1).getTextDay()));
+
+        sb.append(",").append(daily.get(2).getFxDate());
+        sb.append(",").append(daily.get(2).getTempMin());
+        sb.append(",").append(daily.get(2).getTempMax());
+        sb.append(",").append(enumTrans(daily.get(2).getTextDay()));
+        sb.append(",").append(IUnicodeUtils.toUnicode(daily.get(2).getTextDay()));
+
+        sb.append(ThinkraceUtil.END_SYMBOL);
+        return sb.toString();
+    }
+
+    private String enumTrans(String str) {
+        switch (str) {
+            case "晴":
+                return "1";
+            case "多云":
+            case "阴":
+                return "2";
+            case "雨":
+                return "3";
+            case "雪":
+                return "4";
+            default:
+                return "5";
+        }
+    }
+
+    private WeatherResponse getWeather(String location) {
+        WeatherResponse weather = null;
+        try {
+            String url = "https://devapi.qweather.com/v7/weather/3d?location=" + location + "&key=9ee551aeac884cca8c68d70086708b44";
+            weather = JSONObject.parseObject(sendGetRequest(url), WeatherResponse.class);
+            weather.getDaily().sort(Comparator.comparing(WeatherResponse.Daily::getFxDate));
+        } catch (Exception e) {
+            log.info(e.getMessage());
+        }
+        return weather;
+    }
+
+    // 发送GET请求并获取响应数据（包括Gzip解压缩）
+    private static String sendGetRequest(String url) throws IOException {
+        HttpURLConnection connection = null;
+        try {
+            URL requestUrl = new URL(url);
+            connection = (HttpURLConnection) requestUrl.openConnection();
+            connection.setRequestMethod("GET");
+            // 请求Gzip压缩
+            connection.setRequestProperty("Accept-Encoding", "gzip");
+
+            int responseCode = connection.getResponseCode();
+            if (responseCode == HttpURLConnection.HTTP_OK) {
+                InputStream inputStream = connection.getInputStream();
+                String contentEncoding = connection.getContentEncoding();
+
+                if (contentEncoding != null && contentEncoding.equalsIgnoreCase("gzip")) {
+                    inputStream = new GZIPInputStream(inputStream);
+                }
+
+                BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
+                StringBuilder response = new StringBuilder();
+                String line;
+                while ((line = reader.readLine()) != null) {
+                    response.append(line);
+                }
+
+                reader.close();
+                return response.toString();
+            } else {
+                throw new IOException("GET request failed with response code: " + responseCode);
+            }
+        } finally {
+            if (connection != null) {
+                connection.disconnect();
+            }
+        }
+    }
+
+    // 解压缩Gzip数据
+    private static byte[] decompressGzip(byte[] compressedData) throws IOException {
+        ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(compressedData);
+        GZIPInputStream gzipInputStream = new GZIPInputStream(byteArrayInputStream);
+        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
+
+        byte[] buffer = new byte[1024];
+        int len;
+        while ((len = gzipInputStream.read(buffer)) > 0) {
+            byteArrayOutputStream.write(buffer, 0, len);
+        }
+
+        gzipInputStream.close();
+        byteArrayOutputStream.close();
+
+        return byteArrayOutputStream.toByteArray();
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.HealthInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+/**
+ * 9	温度数据上传
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.TEMPERATURE_50_REQ)
+public class ITemperature50PacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // IWAP50,36.7,90#
+        String sub = command.substring(0, command.length() - 1);
+        String[] params = sub.split(",");
+        HealthInfo hi = new HealthInfo();
+        hi.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        log.info("设备:{},温度数据上传命令:{}", hi.getImei(), command);
+        hi.setTemperature(Float.parseFloat(params[1]));
+        hi.setPower(params[2]);
+        // IWBP50#
+        String response = ThinkraceUtil.RES.TEMPERATURE_50_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(hi.getImei(), response);
+        return hi;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.HealthInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import com.ruoyi.system.protocol.property.DeviceProperty;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+/**
+ * 上报体温
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.TEMPERATURE_REQ)
+public class ITemperaturePacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // 格式：IWAPTP,体温,腕温#
+        // 示例：IWAPTP,36.0,33,0#
+        String[] params = command.split(",");
+        HealthInfo health = new HealthInfo();
+        health.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        log.info("设备:{},上报体温命令:{}", health.getImei(), command);
+        health.setHealthType(DeviceProperty.HealthProperty.TEMPERATURE);
+        health.setCommandLabel(params[0]);
+        health.setTemperature(Float.parseFloat(params[1]));
+        health.setHandTemperature(params[2].replace(ThinkraceUtil.END_SYMBOL, ""));
+        // 返回响应
+        String response = ThinkraceUtil.RES.TEMPERATURE_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(health.getImei(), response);
+        return health;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.Bluetooth;
+import com.ruoyi.system.domain.command.BluetoothInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.BLUETOOTH_REQ)
+public class IUploadBluetoothAdapter extends ICommandAdapter {
+
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // 格式：IWAPBL,IMEI,周围的蓝牙参数,终端自身MAC地址,时间戳#
+        // 示例：IWAPBL,355932600029362,TraxBean064|BF:0C:B8:3F:2F:37|-30&VG05|F0:49:32:83:F9:9E|-52,28:05:31:16:02:04,1711512576683#
+        String[] params = command.split(",");
+        BluetoothInfo bluetooth = new BluetoothInfo();
+        bluetooth.setImei(params[1]);
+        bluetooth.setMac(params[3]);
+        bluetooth.setTimestamp(params[4].replace(ThinkraceUtil.END_SYMBOL, ""));
+        String[] btInfo = params[2].split("&");
+        List<Bluetooth> bluetoothList = new ArrayList<>(btInfo.length);
+        for (String bti : btInfo) {
+            String[] bts = bti.split("\\|");
+            Bluetooth bt = new Bluetooth(bts[0], bts[1], bts[2]);
+            bluetoothList.add(bt);
+        }
+        bluetooth.setBluetoothList(bluetoothList);
+        // TODO 信息入表
+        // 返回响应
+        // IWBPBL#
+        String response = ThinkraceUtil.RES.BLUETOOTH_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(bluetooth.getImei(), response);
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.entity.Device;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import org.springframework.stereotype.Service;
+
+/**
+ * 设备上传固件版本
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.VERSION_REQ)
+public class IUploadDeviceVersionPacketAdapter extends ICommandAdapter {
+
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // 格式：IWAPVR,IMEI,固件版本号#
+        // 示例：IWAPVR,357653050858997,C42F-l005l005-EU-P1-V0.3.38.20210906.182655#
+        String[] params = command.split(",");
+        Device device = new Device();
+        device.setImei(params[1]);
+        device.setVersion(params[2].replace(ThinkraceUtil.END_SYMBOL, ""));
+        // 无需响应
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.HealthInfo;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.util.AttributeKey;
+import io.netty.util.CharsetUtil;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+/**
+ * 处理血样血压
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.HEART_BLOOD_REQ)
+public class IUploadHeartRateBloodOxygenPacketAdapter extends ICommandAdapter {
+
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // 格式：IWAPHT,心率值,收缩压值,舒张压值#
+        // 示例：IWAPHT,60,130,85#
+        String[] params = command.substring(0, command.length() - 1).split(",");
+        HealthInfo info = new HealthInfo();
+        info.setImei(ctx.channel().attr(AttributeKey.valueOf(ThinkraceUtil.IMEI)).toString());
+        info.setCommandLabel(params[0]);
+        info.setHeartRate(params[1]);
+        info.setHighPressure(Integer.parseInt(params[2]));
+        // 去掉结束符
+        info.setLowPressure(Integer.parseInt(params[3]));
+        info.setCreateTime(new Date());
+        // TODO 记录表 info
+        // 返回响应
+        // IWBPHT#
+        String response = ThinkraceUtil.RES.HEART_BLOOD_RES + ThinkraceUtil.END_SYMBOL;
+        ctx.channel().writeAndFlush(Unpooled.copiedBuffer(response, CharsetUtil.UTF_8));
+        responseLog(info.getImei(), response);
+        return info;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.adapter.device;
+
+import com.ruoyi.system.domain.command.WearingState;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import org.springframework.stereotype.Service;
+import java.util.Date;
+
+/**
+ * 佩戴状态
+ *
+ * @author 20412
+ */
+@Service(ThinkraceUtil.REQ.WEARING_REQ)
+public class IWearingStatePacketAdapter extends ICommandAdapter {
+
+    @Override
+    public Object resolveCommand(String command, ChannelHandlerContext ctx) {
+        // 格式：IWAPWR, IMEI,佩戴标志位,时间戳#
+        // 示例：IWAPVR,357653050858997,1,xxxxxx#
+        String[] params = command.split(",");
+        WearingState ws = new WearingState();
+        ws.setImei(params[1]);
+        ws.setState(params[2]);
+        ws.setTimestamp(Long.parseLong(params[3].replace(ThinkraceUtil.END_SYMBOL, "")));
+        ws.setCreateTime(new Date());
+        // TODO 入表
+        // 无需响应
+        return null;
+    }
+
+    @Override
+    public CommandListen sendCommand(Object params) {
+        return null;
+    }
+}
+package com.ruoyi.system.protocol.property;
+
+/**
+ * 设备配置
+ * @author 20412
+ */
+public class DeviceProperty {
+    public static class RedisProperty {
+        public static String UPLOAD_IMAGE_PRE = "device:image:upload:";
+    }
+
+    public static class ImageProperty {
+        public static final String UPLOAD_SUCCESS = "1";
+        public static final String UPLOAD_FAIL = "0";
+    }
+
+    public static class SpeechProperty {
+        public static final String UPLOAD_SUCCESS = "1";
+        public static final String UPLOAD_FAIL = "0";
+    }
+
+    public static class AddressProperty {
+        public static final String VALID = "A";
+        public static final String INVALID = "V";
+    }
+
+
+
+    public static class HealthProperty {
+        /** 血压 */
+        public static final String BLOOD_PRESSURE = "1";
+        /** 心率*/
+        public static final String HEART_RATE = "2";
+        /** 体温 */
+        public static final String TEMPERATURE = "3";
+        /** 血氧 */
+        public static final String BLOOD_OXYGEN = "4";
+    }
+
+    public static class WearingState {
+        /** 血压 */
+        public static final String HAND = "1";
+        /** 血压 */
+        public static final String NOT = "0";
+    }
+}
+package com.ruoyi.system.server;
+
+import com.ruoyi.common.core.redis.RedisCache;
+import com.ruoyi.system.handler.SocketServerHandler;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelOption;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.context.ApplicationContext;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PreDestroy;
+import java.util.Map;
+
+/**
+ * @author 20412
+ */
+@Component
+public class SocketServer implements CommandLineRunner {
+    @Autowired
+    private ApplicationContext applicationContext;
+
+    @Autowired
+    private RedisCache redisCache;
+
+    private static final Logger log = LoggerFactory.getLogger(SocketServer.class);
+    EventLoopGroup bossGroup = null;
+    EventLoopGroup workerGroup = null;
+    @Value("${netty.socket.port:8989}")
+    private Integer port;
+    
+    @Value("${netty.enabled:false}")
+    private Boolean enabled;
+
+    @Override
+    public void run(String... args) throws Exception {
+        if (enabled) {
+            // 创建一个线程启动netty  这个CommandLineRunner 接口在主服务基本启动完后会调用使用的是主线程 netty启动会占用线程一直监听端口
+            Thread thread = new Thread(new NettyServer());
+            log.info("netty server active...");
+            thread.start();
+            // 初始化命令适配器
+            log.info("command adapter init...");
+            initCommandAdapter();
+        }
+    }
+
+    private void initCommandAdapter() {
+        // 把所有适配器注入到工具类中管理
+        Map<String, ICommandAdapter> implementations = applicationContext.getBeansOfType(ICommandAdapter.class);
+        for (Map.Entry<String, ICommandAdapter> entry : implementations.entrySet()) {
+            ThinkraceUtil.addAdapter(entry.getKey(), entry.getValue());
+        }
+        ThinkraceUtil.initRedisThinkraceCommandParam(redisCache);
+    }
+
+    /**
+     * 销毁方法
+     *
+     * @throws Exception
+     */
+    @PreDestroy
+    public void destroy() throws Exception {
+        if (bossGroup != null) {
+            bossGroup.shutdownGracefully();
+        }
+        if (workerGroup != null) {
+            workerGroup.shutdownGracefully();
+        }
+        log.info("netty server destroy...");
+    }
+
+    class NettyServer implements Runnable {
+        @Override
+        public void run() {
+            try {
+                bossGroup = new NioEventLoopGroup();
+                workerGroup = new NioEventLoopGroup();
+                //创建服务端的启动对象，设置参数
+                ServerBootstrap bootstrap = new ServerBootstrap();
+                //设置两个线程组boosGroup和workerGroup
+                bootstrap.group(bossGroup, workerGroup)
+                        //设置服务端通道实现类型
+                        .channel(NioServerSocketChannel.class)
+                        //设置线程队列得到连接个数
+                        .option(ChannelOption.SO_BACKLOG, 128)
+                        //设置保持活动连接状态
+                        .childOption(ChannelOption.SO_KEEPALIVE, true)
+                        //使用匿名内部类的形式初始化通道对象
+                        .childHandler(new ChannelInitializer<SocketChannel>() {
+                            @Override
+                            protected void initChannel(SocketChannel socketChannel) throws Exception {
+                                //给pipeline管道设置处理器
+                                socketChannel.pipeline().addLast(new SocketServerHandler());
+                            }
+                        });//给workerGroup的EventLoop对应的管道设置处理器
+                //绑定端口号，启动服务端
+                ChannelFuture channelFuture = bootstrap.bind(port).sync();
+                //对关闭通道进行监听
+                channelFuture.channel().closeFuture().sync();
+            } catch (InterruptedException e) {
+                log.error("SocketServer at line 71:" + e.getMessage());
+            }
+        }
+    }
+
+}
+package com.ruoyi.system.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.common.global.Result;
+import com.ruoyi.system.domain.active.Sos;
+import com.ruoyi.system.domain.active.UploadGpsTime;
+import com.ruoyi.system.domain.active.WhiteListPeople;
+import com.ruoyi.system.domain.entity.Device;
+
+/**
+ * deviceService接口
+ * 
+ * @author bsth
+ * @date 2024-04-17
+ */
+public interface IDeviceService extends IService<Device>
+{
+
+    Result<?> settingSos(Sos sos);
+
+    Result<?> settingWhiteList(WhiteListPeople wlp);
+
+    Result<?> settingGpsUploadTime(UploadGpsTime ugt);
+}
+package com.ruoyi.system.service;
+
+/**
+ * @author 20412
+ */
+public interface ITimedTaskService {
+}
+package com.ruoyi.system.service.impl;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+import com.ruoyi.common.global.Result;
+import com.ruoyi.system.domain.active.Sos;
+import com.ruoyi.system.domain.active.UploadGpsTime;
+import com.ruoyi.system.domain.active.WhiteListPeople;
+import com.ruoyi.system.domain.entity.Device;
+import com.ruoyi.system.mapper.DeviceMapper;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.service.IDeviceService;
+import org.springframework.stereotype.Service;
+
+/**
+ * deviceService业务层处理
+ * 
+ * @author bsth
+ * @date 2024-04-17
+ */
+@Service
+public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> implements IDeviceService
+{
+
+
+    @Override
+    public Result<?> settingSos(Sos sos) {
+        boolean result = ThinkraceUtil
+                .getAdapter(ThinkraceUtil.ACTIVE.SOS_ACTIVE)
+                .sendCommand(sos)
+                .listenAsk();
+        return Result.OK((result ? "设备成功响应" :"设备无响应"));
+    }
+
+    @Override
+    public Result<?> settingWhiteList(WhiteListPeople wlp) {
+        boolean result = ThinkraceUtil
+                .getAdapter(ThinkraceUtil.ACTIVE.CONTACT_ACTIVE)
+                .sendCommand(wlp)
+                .listenAsk();
+        return Result.OK((result ? "设备成功响应" :"设备无响应"));
+    }
+
+    @Override
+    public Result<?> settingGpsUploadTime(UploadGpsTime ugt) {
+        boolean result = ThinkraceUtil
+                .getAdapter(ThinkraceUtil.ACTIVE.UPLOAD_GPS_TIME_ACTIVE)
+                .sendCommand(ugt)
+                .listenAsk();
+        return Result.OK((result ? "设备成功响应" :"设备无响应"));
+    }
+}
+package com.ruoyi.system.service.impl;
+
+import com.ruoyi.system.service.ITimedTaskService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author 20412
+ */
+@Service
+@Slf4j
+public class ITimedTaskServiceImpl implements ITimedTaskService {
+
+
+}
+package com.ruoyi.system.strategy;
+
+import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.system.protocol.ThinkraceUtil;
+import com.ruoyi.system.protocol.adapter.ICommandAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static com.ruoyi.system.protocol.ThinkraceUtil.REQ.LOGIN_REQ;
+
+/**
+ * 命令观察者模式
+ *
+ * @author 20412
+ */
+public class CommandStrategy {
+    private static final Logger log = LoggerFactory.getLogger(CommandStrategy.class);
+
+    public CommandStrategy() {
+    }
+
+    public void handler(String command, ChannelHandlerContext ctx) {
+        processor(command, ctx);
+    }
+
+    private void processor(String command, ChannelHandlerContext ctx) {
+        if (StringUtils.isNotEmpty(command) && command.length() > 6) {
+            String key = command.substring(0, 6);
+            // 未上传登录包无法使用对应指令
+            ICommandAdapter adapter = ThinkraceUtil.getAdapter(key);
+            if (filterCommand(key, ctx) && adapter != null) {
+                adapter.resolveCommand(command, ctx);
+                return;
+            }
+            log.error("设备传来未知指令:{}", command);
+        }
+    }
+
+    private boolean filterCommand(String key, ChannelHandlerContext ctx) {
+        return LOGIN_REQ.equals(key) || ThinkraceUtil.hasDevice(ctx.channel());
+    }
+}
@@ -46,6 +46,11 @@ public class ConstDateUtil {
         SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
         return simpleDateFormat.format(new Date());
     }
+    public static String formatDate(String pattern,ZoneOffset utc){
+        LocalDateTime currentTime = LocalDateTime.now(utc);
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
+        return formatter.format(currentTime);
+    }
  
     public static Date parseDate(String date){
         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+package com.ruoyi.utils;
+
+import org.apache.commons.lang3.StringUtils;
+
+/**
+ * @author 20412
+ */
+public class IUnicodeUtils {
+
+    /**
+     * @param str content
+     * @return unicode
+     */
+    public static String toUnicode(String str) {
+        StringBuilder outStr = new StringBuilder();
+        if (StringUtils.isNotEmpty(str)) {
+            for (int i = 0; i < str.length(); i++) {
+                String outStr2 = Integer.toHexString(str.charAt(i));
+                outStr.append(StringUtils.leftPad(outStr2, 4, '0'));
+            }
+        }
+        return outStr.toString();
+    }
+}
+package com.ruoyi.utils;
+
+import com.ruoyi.common.utils.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.RandomAccessFile;
+
+public class PathToolUtil {
+
+    private static final Logger log = LoggerFactory.getLogger(PathToolUtil.class);
+
+    // 维护写入队列 不停的遍历队列内的任务来完成写入 提高指令的响应速度
+
+//    private static LinkedList<Runnable> runnableList = new LinkedList<>();
+
+    public static boolean generateRelativeImagePath(String catalogue, String imei, String uploadTime, byte[] bits) {
+//        runnableList.push();
+        String resourceDirectory = "Bsth-admin/src/main/resources";
+        String path = StringUtils.format("{}/{}/{}/{}.{}", resourceDirectory,
+                catalogue, imei, uploadTime, "jpg");
+        File file = new File(path);
+        RandomAccessFile raf = null;
+        if (!file.exists()) {
+            if (!file.getParentFile().exists()) {
+                file.getParentFile().mkdirs();
+            }
+        }
+        try {
+            // 创建RandomAccessFile对象，并以读写模式打开文件
+            raf = new RandomAccessFile(file, "rw");
+
+            // 将文件指针移动到文件末尾
+            raf.seek(file.length());
+
+            // 写入数据
+            raf.write(bits);
+
+        } catch (Exception e) {
+            log.error("图片写入出错:{}", e.getMessage());
+            // TODO 第三次返回true
+        } finally {
+            try {
+                if (raf != null) {
+                    raf.close();
+                }
+            } catch (Exception e) {
+                log.info(e.getMessage());
+            }
+            return true;
+        }
+    }
+
+
+    public static boolean generateRelativeSpeechPath(String catalogue, String imei, String uploadTime, byte[] bits) {
+//        runnableList.push();
+        String resourceDirectory = "Bsth-admin/src/main/resources";
+        String path = StringUtils.format("{}/{}/{}/{}.{}", resourceDirectory,
+                catalogue, imei, uploadTime, "mp3");
+        File file = new File(path);
+        RandomAccessFile raf = null;
+        if (!file.exists()) {
+            if (!file.getParentFile().exists()) {
+                file.getParentFile().mkdirs();
+            }
+        }
+        try {
+            // 创建RandomAccessFile对象，并以读写模式打开文件
+            raf = new RandomAccessFile(file, "rw");
+
+            // 将文件指针移动到文件末尾
+            raf.seek(file.length());
+
+            // 写入数据
+            raf.write(bits);
+
+        } catch (Exception e) {
+            log.error("图片写入出错:{}", e.getMessage());
+            // TODO 第三次返回true
+        } finally {
+            try {
+                if (raf != null) {
+                    raf.close();
+                }
+            } catch (Exception e) {
+                log.info(e.getMessage());
+            }
+            return true;
+        }
+    }
+
+
+
+    public static void main(String[] args) {
+
+        try {
+            int count = 0;
+            FileInputStream fis = new FileInputStream("C:\\Users\\20412\\Desktop\\Bsth\\岗前检查\\Bsth\\Bsth-admin\\src\\main\\resources\\564.jpg");
+            byte[] bits = new byte[1024];
+            int len;
+            while ((len = fis.read(bits)) != -1) {
+                count++;
+                for (int i = 0; i < len; i++) {
+                    System.out.print(bits[i]);
+                }
+                System.out.println("分片");
+            }
+            System.out.println("共" + count + "片");
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+
+    }
+
+
+}
@@ -97,7 +97,7 @@ spring:
     redis:
         # 地址
 #            host: 121.41.83.61
-        host: 192.168.168.124
+        host: localhost
         database: 14
 #            password: "guzijian"
         port: 6379
@@ -182,3 +182,12 @@ log:
     path: D:/ruoyi/logs
 server:
     port: 8100
+netty:
+    # 是否开启netty服务
+    enabled: false
+    socket:
+        # 相对路径 classpath
+        catalogue:
+            image: device/image
+            speech: device/speech
+        port: 8989
 \ No newline at end of file
@@ -206,3 +206,13 @@ api:
         people:
             url: https://api.dingtalk.com/v1.0/yida/forms/instances/search
  
+
+netty:
+    # 是否开启netty服务
+    enabled: false
+    socket:
+        # 相对路径 classpath
+        catalogue:
+            image: device/image
+            speech: device/speech
+        port: 8989
 \ No newline at end of file
@@ -198,4 +198,13 @@ api:
     people:
       url: https://api.dingtalk.com/v1.0/yida/forms/instances/search
 log:
-  path: /home/sign/logs
 \ No newline at end of file
+  path: /home/sign/logs
+netty:
+  # 是否开启netty服务
+  enabled: false
+  socket:
+    # 相对路径 classpath
+    catalogue:
+      image: device/image
+      speech: device/speech
+    port: 8989
 \ No newline at end of file
@@ -69,6 +69,18 @@ public class RedisCache {
      * @param unit    时间单位
      * @return true=设置成功；false=设置失败
      */
+    public void expire(final String key,Object val ,final long timeout, final TimeUnit unit) {
+        redisTemplate.opsForValue().set(key, val,timeout, unit);
+    }
+
+    /**
+     * 设置有效时间
+     *
+     * @param key     Redis键
+     * @param timeout 超时时间
+     * @param unit    时间单位
+     * @return true=设置成功；false=设置失败
+     */
     public boolean expire(final String key, final long timeout, final TimeUnit unit) {
         return redisTemplate.expire(key, timeout, unit);
     }
@@ -283,4 +295,14 @@ public class RedisCache {
     public <T> Set<T> getHashKeys(String key){
         return redisTemplate.opsForHash().keys(key);
     }
+
+    public boolean setNx(String key, Object val) {
+        Boolean result = redisTemplate.opsForValue().setIfAbsent(key, val);
+        return result != null && result;
+    }
+
+    public Long increment(String key) {
+        Long increment = redisTemplate.opsForValue().increment(key);
+        return increment;
+    }
 }