From 0fd1d87f4fb92eaae63dea9b744f025462295817 Mon Sep 17 00:00:00 2001
From: 18201612589 <2746733890@qq.com>
Date: Thu, 9 Dec 2021 14:46:03 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=BF=9B=E5=88=B6=E8=BD=AC?=
 =?UTF-8?q?=E6=8D=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/muyu/controller/VehicleOperateController.java   | 2 +-
 src/main/java/com/muyu/netty/operate/NettyClientMsg.java     | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/muyu/controller/VehicleOperateController.java b/src/main/java/com/muyu/controller/VehicleOperateController.java
index 794b9af..726849f 100644
--- a/src/main/java/com/muyu/controller/VehicleOperateController.java
+++ b/src/main/java/com/muyu/controller/VehicleOperateController.java
@@ -72,7 +72,7 @@ public class VehicleOperateController {
         vehicleData.setLongitude(split[0]);
         vehicleData.setLatitude(split[1]);
 
-        NettyClientMsg.sendMsg(Config.VEHICLE_MSG_SUF + "7E " + ConversionUtil.strToSixteen(vehicleData.getMsg()) + "7E " + "7E") ;
+        NettyClientMsg.sendMsg(Config.VEHICLE_MSG_SUF + vehicleData.getMsg()) ;
         NettyClientLogQueue.add(vehicleData.getVehicleMsgLog());
         return Response.success();
     }
diff --git a/src/main/java/com/muyu/netty/operate/NettyClientMsg.java b/src/main/java/com/muyu/netty/operate/NettyClientMsg.java
index 11bed79..ee4e500 100644
--- a/src/main/java/com/muyu/netty/operate/NettyClientMsg.java
+++ b/src/main/java/com/muyu/netty/operate/NettyClientMsg.java
@@ -2,6 +2,7 @@ package com.muyu.netty.operate;
 
 
 import com.muyu.common.Config;
+import com.muyu.utils.ConversionUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -22,7 +23,7 @@ public class NettyClientMsg {
      */
     public static void sendMsg(String msg){
         log.info("客户端发送消息：{}",msg);
-        Config.ctx.writeAndFlush(msg + Config.DATA_PACK_SEPARATOR);
+        Config.ctx.writeAndFlush(ConversionUtil.strToSixteen(msg) + Config.DATA_PACK_SEPARATOR);
     }
 
     /**
@@ -30,7 +31,7 @@ public class NettyClientMsg {
      */
     public static void destroy(){
         log.info("发送断开连接消息："+Config.NETTY_CLOSE);
-        Config.ctx.writeAndFlush(Config.NETTY_WILL_CLOSE+ Config.VIN + Config.DATA_PACK_SEPARATOR);
+        sendMsg(Config.NETTY_WILL_CLOSE + Config.VIN);
         Config.ctx = null;
     }