From 23018acef8989eb358455d08f27fdfeecfb1d672 Mon Sep 17 00:00:00 2001
From: SuiXxx <1752599835@qq.com>
Date: Wed, 25 Sep 2024 20:38:17 +0800
Subject: [PATCH 1/5] =?UTF-8?q?fix():=E4=BF=AE=E6=94=B9=E8=BD=A6=E8=BE=86?=
 =?UTF-8?q?=E7=AE=A1=E7=90=86=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/muyu/domain/resp/SysCarVo.java   |  2 +-
 .../java/com/muyu/mapper/SysCarMapper.java    |  6 +++++
 .../muyu/service/impl/SysCarServiceImpl.java  |  4 ++--
 .../main/resources/mapper/SysCarMapper.xml    | 23 +++++++++++++++++++
 4 files changed, 32 insertions(+), 3 deletions(-)

diff --git a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/domain/resp/SysCarVo.java b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/domain/resp/SysCarVo.java
index 19663ed..966e77c 100644
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/domain/resp/SysCarVo.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/domain/resp/SysCarVo.java
@@ -16,7 +16,7 @@ public class SysCarVo extends SysCar {
     @Excel(name = "车辆类型名称")
     private String typeName;
     @Excel(name = "策略名称")
-    private Long strategyName;
+    private String strategyName;
 
 
 
diff --git a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/mapper/SysCarMapper.java b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/mapper/SysCarMapper.java
index b78d8b3..aa60480 100644
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/mapper/SysCarMapper.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/mapper/SysCarMapper.java
@@ -21,4 +21,10 @@ public interface SysCarMapper extends BaseMapper<SysCar> {
 
     List<SysCarFaultLogVo> findFenceByCarVin(@Param("carVin") String carVin);
 
+    //修改车辆
+    Integer updSysCarById(SysCar sysCar);
+
+    //添加车辆信息
+    Integer addSysCar(SysCar sysCar);
+
 }
diff --git a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/service/impl/SysCarServiceImpl.java b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/service/impl/SysCarServiceImpl.java
index ffec01c..e68b549 100644
--- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/service/impl/SysCarServiceImpl.java
+++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/service/impl/SysCarServiceImpl.java
@@ -30,7 +30,7 @@ public class SysCarServiceImpl extends ServiceImpl<SysCarMapper,SysCar>  impleme
 
     @Override
     public int addSysCar(SysCar sysCar) {
-        return sysCarMapper.insert(sysCar);
+        return sysCarMapper.addSysCar(sysCar);
     }
 
     @Override
@@ -40,7 +40,7 @@ public class SysCarServiceImpl extends ServiceImpl<SysCarMapper,SysCar>  impleme
 
     @Override
     public int updateSysCar(SysCar sysCar) {
-        return sysCarMapper.updateById(sysCar);
+        return sysCarMapper.updSysCarById(sysCar);
     }
 
     @Override
diff --git a/cloud-modules/cloud-modules-car/src/main/resources/mapper/SysCarMapper.xml b/cloud-modules/cloud-modules-car/src/main/resources/mapper/SysCarMapper.xml
index 6f7d444..e095fcd 100644
--- a/cloud-modules/cloud-modules-car/src/main/resources/mapper/SysCarMapper.xml
+++ b/cloud-modules/cloud-modules-car/src/main/resources/mapper/SysCarMapper.xml
@@ -3,6 +3,29 @@
         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.muyu.mapper.SysCarMapper">
+    <insert id="addSysCar">
+        INSERT INTO `four`.`sys_car`
+        ( `car_vin`, `car_type_id`, `state`, `car_motor_manufacturer`, `car_motor_model`,
+          `car_battery_manufacturer`, `car_battery_model`, `strategy_id`, `create_by`, `create_time`, `update_by`, `update_time`, `remark`)
+        VALUES (#{carVin}, #{carTypeId}, '1', #{carMotorManufacturer}, #{carMotorModel},
+                #{carBatteryManufacturer}, #{carBatteryModel}, #{strategyId},#{createBy}, #{createTime}, #{updateBy}, #{updateTime}, #{remark})
+    </insert>
+    <update id="updSysCarById">
+        UPDATE `four`.`sys_car`
+        SET `car_vin` = #{carVin},
+            `car_type_id` = #{carTypeId},
+            `state` = #{state},
+            `car_motor_manufacturer` = #{carMotorManufacturer},
+            `car_motor_model` = #{carMotorModel},
+            `car_battery_manufacturer` = #{carBatteryManufacturer},
+            `car_battery_model` = #{carBatteryModel},
+            `strategy_id` = #{strategyId},
+            `create_by` = #{createBy},
+            `create_time` = #{createTime},
+            `update_by` = #{updateBy},
+            `update_time` = #{updateTime},
+            `remark` = #{remark} WHERE `id` = #{id}
+    </update>
     <select id="selectSysCarVoList" resultType="com.muyu.domain.resp.SysCarVo">
         SELECT * ,car_type.type_name,warn_strategy.strategy_name
         FROM `sys_car`

From eacd2806b8d72b7cb5d59887743402f573cdb221 Mon Sep 17 00:00:00 2001
From: Number7 <1845377266@qq.com>
Date: Wed, 25 Sep 2024 21:06:31 +0800
Subject: [PATCH 2/5] =?UTF-8?q?=E6=8A=A5=E6=96=87=E6=A8=A1=E7=89=88?=
 =?UTF-8?q?=E5=AD=98=E5=82=A8=E5=88=B0Redis?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/template/mapper/TemplateMapper.java   |  3 +
 .../com/template/service/TemplateService.java |  3 +
 .../service/impl/TemplateServiceImpl.java     |  4 ++
 .../template/util/SynchronizingTemplate.java  | 62 +++++++++++++++++++
 .../mapper/message/TemplateMapper.xml         |  8 +++
 5 files changed, 80 insertions(+)
 create mode 100644 cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java

diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/mapper/TemplateMapper.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/mapper/TemplateMapper.java
index 0ba2238..28d6565 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/mapper/TemplateMapper.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/mapper/TemplateMapper.java
@@ -1,5 +1,6 @@
 package com.template.mapper;
 
+import com.template.domain.MessageTemplateType;
 import com.template.domain.Template;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -20,4 +21,6 @@ public interface TemplateMapper {
 
     Template findTemplateByName(@Param("typeName") String typeName);
 
+    List<MessageTemplateType> findTemplateById(@Param("templateId") Integer templateId);
+
 }
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/TemplateService.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/TemplateService.java
index 92d0b51..4f26538 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/TemplateService.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/TemplateService.java
@@ -1,5 +1,6 @@
 package com.template.service;
 
+import com.template.domain.MessageTemplateType;
 import com.template.domain.Template;
 import org.apache.iotdb.rpc.IoTDBConnectionException;
 import org.apache.iotdb.rpc.StatementExecutionException;
@@ -20,4 +21,6 @@ public interface TemplateService {
 
     void messageParsing(String templateMessage) throws SQLException, IoTDBConnectionException, ClassNotFoundException, StatementExecutionException;
 
+    List<MessageTemplateType> findTemplateById(Integer templateId);
+
 }
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
index 15b8259..ed68963 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
@@ -91,6 +91,10 @@ public class TemplateServiceImpl implements TemplateService{
         }
     }
 
+    @Override
+    public List<MessageTemplateType> findTemplateById(Integer templateId) {
+        return templateMapper.findTemplateById(templateId);
+    }
 
 
     public void insertIoTDB(JSONObject jsonObject) throws SQLException, ClassNotFoundException, IoTDBConnectionException, StatementExecutionException {
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
new file mode 100644
index 0000000..ff1955c
--- /dev/null
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
@@ -0,0 +1,62 @@
+package com.template.util;
+
+import com.template.domain.MessageTemplateType;
+import com.template.domain.Template;
+import com.template.service.TemplateService;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.ListOperations;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * @Author：liuxinyue
+ * @Package：com.template.util
+ * @Project：cloud-server
+ * @name：SynchronizingTemplate
+ * @Date：2024/9/25 20:03
+ */
+@Component
+@Log4j2
+public class SynchronizingTemplate {
+
+
+    //调用报文模版列表接口
+    @Resource
+    private TemplateService templateService;
+
+
+    //redis
+    @Resource
+    private RedisTemplate redisTemplate;
+
+    @PostConstruct
+    public void synchronizeTemplate() {
+        //获取所有报文模版的ID
+        log.info("获取所有报文模版的ID");
+        List<Template> templates = templateService.templateList();
+        templates.forEach(template -> {
+            log.info("每个报文模版的ID");
+            Integer templateId = template.getTemplateId();
+            log.info("根据模版ID去查报文模版中谁属于这个类型的报文");
+            List<MessageTemplateType> list=templateService.findTemplateById(templateId);
+            ListOperations<String,Object> listOperations = redisTemplate.opsForList();
+            log.info("清除redis中的值");
+            redisTemplate.delete(template.getTemplateName());
+            log.info("将报文模版名称作为key,将list作为值");
+            listOperations.leftPushAll(template.getTemplateName(), list);
+            List<Object> range = listOperations.range(template.getTemplateName(), 0, -1);
+            log.info(range);
+            for (Object o : range) {
+                log.info("数据为:"+o);
+            }
+        });
+
+
+    }
+}
diff --git a/cloud-modules/cloud-modules-template/src/main/resources/mapper/message/TemplateMapper.xml b/cloud-modules/cloud-modules-template/src/main/resources/mapper/message/TemplateMapper.xml
index be28634..c4b20d8 100644
--- a/cloud-modules/cloud-modules-template/src/main/resources/mapper/message/TemplateMapper.xml
+++ b/cloud-modules/cloud-modules-template/src/main/resources/mapper/message/TemplateMapper.xml
@@ -11,5 +11,13 @@
     <select id="findTemplateByName" resultType="com.template.domain.Template">
         select * from t_template where template_name=#{typeName}
     </select>
+    <select id="findTemplateById" resultType="com.template.domain.MessageTemplateType">
+        SELECT
+            *
+        FROM
+            message_template_type
+        WHERE
+            template_id = #{templateId}
+    </select>
 
 </mapper>

From 50f9dcbff5c08f1dbf967ca83be4608427d11b6e Mon Sep 17 00:00:00 2001
From: Number7 <1845377266@qq.com>
Date: Wed, 25 Sep 2024 21:29:28 +0800
Subject: [PATCH 3/5] =?UTF-8?q?=E5=88=A0=E9=99=A4=E4=B8=8D=E5=BF=85?=
 =?UTF-8?q?=E8=A6=81=E7=9A=84=E5=B7=A5=E5=85=B7=E7=B1=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/ServiceController.java         | 55 --------------
 .../service/impl/TemplateServiceImpl.java     |  8 +-
 .../template/util/IOTDBConnectionTets.java    | 22 ------
 .../com/template/util/IOTdbJDBCUtils.java     | 62 ---------------
 .../com/template/util/StringCutterUtils.java  | 53 +++++++++++++
 .../template/util/SynchronizingTemplate.java  |  8 --
 .../main/java/com/template/util/ToIoTDB.java  | 36 ---------
 .../java/com/template/util/ToIoTDBTest.java   | 76 -------------------
 8 files changed, 59 insertions(+), 261 deletions(-)
 delete mode 100644 cloud-modules/cloud-modules-template/src/main/java/com/template/controller/ServiceController.java
 delete mode 100644 cloud-modules/cloud-modules-template/src/main/java/com/template/util/IOTDBConnectionTets.java
 delete mode 100644 cloud-modules/cloud-modules-template/src/main/java/com/template/util/IOTdbJDBCUtils.java
 create mode 100644 cloud-modules/cloud-modules-template/src/main/java/com/template/util/StringCutterUtils.java
 delete mode 100644 cloud-modules/cloud-modules-template/src/main/java/com/template/util/ToIoTDB.java
 delete mode 100644 cloud-modules/cloud-modules-template/src/main/java/com/template/util/ToIoTDBTest.java

diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/controller/ServiceController.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/controller/ServiceController.java
deleted file mode 100644
index fadb1f0..0000000
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/controller/ServiceController.java
+++ /dev/null
@@ -1,55 +0,0 @@
-package com.template.controller;
-import lombok.extern.log4j.Log4j2;
-import java.sql.DriverManager;
-import java.sql.SQLException;
-/**
- * @Author：liuxinyue
- * @Package：com.template.controller
- * @Project：cloud-server
- * @name：ServiceController
- * @Date：2024/9/22 22:12
- */
-@Log4j2
-public class ServiceController {
-
-    private final String IOTDB_DRIVER="org.apache.iotdb.jdbc.IoTDBDriver";
-    private static final String url="jdbc:iotdb://47.116.173.119:6667/";
-    private static final String userName="root";
-    private static final String passWord="root";
-
-  public void ToIoTDB(String url, String userName, String passWord){
-   log.info("Connecting to IoTDB");
-   log.info("地址是:"+url);
-   log.info("用户名是:"+userName);
-   log.info("密码是:"+passWord);
-   log.info("红红火火恍恍惚惚");
-  }
-
-    public static void main(String[] args) {
-        try{
-            Class.forName("org.apache.iotdb.jdbc.IoTDBDriver");
-            DriverManager.getConnection(url,userName,passWord);
-        }catch(SQLException e){
-            log.error("SQLException: " + e.getMessage());
-            log.error("SQLState: " + e.getSQLState());
-            log.error("VendorError: " + e.getErrorCode());
-        } catch (ClassNotFoundException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-  private void createConnection() throws ClassNotFoundException, SQLException {
-
-      try{
-          Class.forName(IOTDB_DRIVER);
-          DriverManager.getConnection(url,userName,passWord);
-      }catch(SQLException e){
-          log.error("SQLException: " + e.getMessage());
-          log.error("SQLState: " + e.getSQLState());
-          log.error("VendorError: " + e.getErrorCode());
-      }
-
-
-  }
-
-}
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
index ed68963..62b6eb5 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
@@ -5,7 +5,7 @@ import com.template.mapper.TemplateMapper;
 import com.template.service.CarService;
 import com.template.service.MessageTemplateTypeService;
 import com.template.service.TemplateService;
-import com.template.util.ToIoTDB;
+
 import lombok.extern.log4j.Log4j2;
 import org.apache.iotdb.rpc.IoTDBConnectionException;
 import org.apache.iotdb.rpc.StatementExecutionException;
@@ -14,6 +14,7 @@ import org.apache.iotdb.session.SessionDataSet;
 import org.apache.iotdb.session.util.Version;
 import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 import java.sql.*;
 import java.util.ArrayList;
@@ -39,8 +40,11 @@ public class TemplateServiceImpl implements TemplateService{
     @Autowired
     private MessageTemplateTypeService messageTemplateTypeService;
 
+
+
+
     @Autowired
-    private ToIoTDB toIoTDB;
+    private RedisTemplate redisTemplate;
 
     @Override
     public List<Template> templateList() {
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/IOTDBConnectionTets.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/IOTDBConnectionTets.java
deleted file mode 100644
index f710b32..0000000
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/IOTDBConnectionTets.java
+++ /dev/null
@@ -1,22 +0,0 @@
-package com.template.util;
-import java.sql.Connection;
-/**
- * @Author：liuxinyue
- * @Package：com.template.util
- * @Project：cloud-server
- * @name：IOTDBConnectionTets
- * @Date：2024/9/24 10:34
- */
-public class IOTDBConnectionTets {
-
-    private static final String url = "jdbc:iotdb://47.116.173.119:6667/";
-    private static final String username = "root";
-    private static final String password = "root";
-
-    public static void main(String[] args) {
-        Connection conn = new IOTdbJDBCUtils(url, username, password).getConnection();
-        System.out.println(conn != null ? "打开连接成功!" : "打开连接失败!");
-        IOTdbJDBCUtils.close(conn);
-    }
-
-}
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/IOTdbJDBCUtils.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/IOTdbJDBCUtils.java
deleted file mode 100644
index f620902..0000000
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/IOTdbJDBCUtils.java
+++ /dev/null
@@ -1,62 +0,0 @@
-package com.template.util;
-
-
-
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.SQLException;
-
-/**
- * @Author：liuxinyue
- * @Package：com.template.util
- * @Project：cloud-server
- * @name：IOTdbJDBCUtils
- * @Date：2024/9/24 10:18
- */
-public class IOTdbJDBCUtils {
-    private static final String driver = "org.apache.iotdb.jdbc.IoTDBDriver";
-    private final String url;
-    private final String username;
-    private final String password;
-
-    public IOTdbJDBCUtils(String url, String username, String password) {
-        this.url = url;
-        this.username = username;
-        this.password = password;
-    }
-
-    static {
-        try {
-            Class.forName(driver);
-        } catch (ClassNotFoundException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-            System.out.println("当前加载的驱动不存在........,请检查后重试!");
-        }
-    }
-
-    public Connection getConnection() {
-        Connection connection = null;
-        try {
-            connection = DriverManager.getConnection(url, username, password);
-        } catch (SQLException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        }
-        return connection;
-    }
-
-    public static void close(Connection conn) {
-        if (conn != null) {
-            try {
-                conn.close();
-            } catch (SQLException e) {
-                // TODO Auto-generated catch block
-                e.printStackTrace();
-            } catch (Exception e) {
-                throw new RuntimeException(e);
-            }
-        }
-    }
-
-}
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/StringCutterUtils.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/StringCutterUtils.java
new file mode 100644
index 0000000..417d4cc
--- /dev/null
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/StringCutterUtils.java
@@ -0,0 +1,53 @@
+package com.template.util;
+
+import lombok.extern.log4j.Log4j2;
+
+import java.nio.charset.StandardCharsets;
+
+/**
+ * @Author：liuxinyue
+ * @Package：com.template.util
+ * @Project：cloud-server
+ * @name：StringCutterUtils
+ * @Date：2024/9/25 21:18
+ */
+@Log4j2
+public class StringCutterUtils {
+
+    public static String hexadecimalCharacter(String s){
+        StringBuilder stringBuilder = new StringBuilder();
+        int len = s.length();
+        for (int i = 0; i < len; i++) {
+            char c = s.charAt(i);
+            String hexString = Integer.toHexString(c);
+            stringBuilder.append(hexString+" ");
+        }
+        return stringBuilder.toString();
+    }
+
+
+    public static void main(String[] args) {
+
+        String s = hexadecimalCharacter("3C3F786D6C2076657273696F6E3D22312E30223F3E0D0A3C6D6F6E69746F72526F6F7420747970653D22706172616D223E3C73796E6368726F6E697A65537970746F6D206576656E743D22302220696E697469616C3D2274727565223E3C416374696F6E5F4543473E3C52687974686D3E53696E75733C2F52687974686D3E3C48523E38303C2F48523E3C454D443E4E6F204368616E67653C2F454D443E3C436F6E647563743E303C2F436F6E647563743E3C2F416374696F6E5F4543473E3C416374696F6E5F4F7361742076616C75653D2239342220697352656C617469766550657263656E743D2266616C7365222F3E3C416374696F6E5F425020697352656C617469766550657263656E743D2266616C7365223E3C536872696E6B2076616C75653D22313230222F3E3C537472657463682076616C75653D223830222F3E3C2F416374696F6E5F42503E3C416374696F6E5F5265737020627265617468547970653D224E6F726D616C222076616C75653D2231342220697352656C617469766550657263656E743D2266616C7365222F3E3C416374696F6E5F6574434F322076616C75653D2233342220697352656C617469766550657263656E743D2266616C7365222F3E3C416374696F6E5F54656D70657261747572652076616C75653D2233352E32222F3E3C416374696F6E5F4356502076616C75653D22362E30222F3E3C416374696F6E5F5041504469612076616C75653D223130222F3E3C416374696F6E5F5041505379732076616C75653D223235222F3E3C416374696F6E5F57502076616C75653D2239222F3E3C2F73796E6368726F6E697A65537970746F6D3E3C2F6D6F6E69746F72526F6F743E0D0A");
+        String string = toString(s);
+        log.info(string);
+    }
+
+    public static String toString(String s){
+
+        if(s==null || s.equals("")){
+        return null;
+        }
+        log.info("将字符串中的空格去除");
+         s = s.replace(" ", "");
+        byte[] bytes = new byte[s.length() / 2];
+        for (int i = 0; i < bytes.length; i++) {
+            bytes[i] = (byte) (0xff & Integer.parseInt(s.substring(i*2,i*2+2), 16));
+        }
+
+        s=new String(bytes, StandardCharsets.UTF_8);
+        return s;
+    }
+
+
+}
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
index ff1955c..e852eb4 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
@@ -1,19 +1,14 @@
 package com.template.util;
-
 import com.template.domain.MessageTemplateType;
 import com.template.domain.Template;
 import com.template.service.TemplateService;
 import lombok.extern.log4j.Log4j2;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.ListOperations;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
-
 import javax.annotation.PostConstruct;
 import javax.annotation.Resource;
-import java.util.HashMap;
 import java.util.List;
-
 /**
  * @Author：liuxinyue
  * @Package：com.template.util
@@ -30,7 +25,6 @@ public class SynchronizingTemplate {
     @Resource
     private TemplateService templateService;
 
-
     //redis
     @Resource
     private RedisTemplate redisTemplate;
@@ -56,7 +50,5 @@ public class SynchronizingTemplate {
                 log.info("数据为:"+o);
             }
         });
-
-
     }
 }
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/ToIoTDB.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/ToIoTDB.java
deleted file mode 100644
index 4cf1e34..0000000
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/ToIoTDB.java
+++ /dev/null
@@ -1,36 +0,0 @@
-package com.template.util;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.context.annotation.Configuration;
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.SQLException;
-/**
- * @Author：liuxinyue
- * @Package：com.template.util
- * @Project：cloud-server
- * @name：ToIoTDB 连接IoTDB数据库
- * @Date：2024/9/20 19:40
- */
-@Log4j2
-@Configuration
-public class ToIoTDB {
-
-    private final String IOTDB_DRIVER="org.apache.iotdb.jdbc.IoTDBDriver";
-    private static final String url="jdbc:iotdb://47.116.173.119:6667/";
-    private static final String userName="root";
-    private static final String passWord="root";
-
-    public Connection getConnection()  throws ClassNotFoundException, SQLException {
-        Connection connection=null;
-        try{
-            Class.forName(IOTDB_DRIVER);
-             connection = DriverManager.getConnection(url, userName, passWord);
-        }catch(SQLException e){
-            log.error("SQLException: " + e.getMessage());
-            log.error("SQLState: " + e.getSQLState());
-            log.error("VendorError: " + e.getErrorCode());
-        }
-        return connection;
-    }
-
-}
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/ToIoTDBTest.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/ToIoTDBTest.java
deleted file mode 100644
index 6dd9f7f..0000000
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/ToIoTDBTest.java
+++ /dev/null
@@ -1,76 +0,0 @@
-package com.template.util;
-
-import org.springframework.beans.factory.annotation.Autowired;
-
-import java.sql.*;
-
-/**
- * @Author：liuxinyue
- * @Package：com.template.util
- * @Project：cloud-server
- * @name：ToIoTDBTest
- * @Date：2024/9/24 10:12
- */
-public class ToIoTDBTest {
-
-    private static final String host = "47.116.173.119";
-    private static final String url = "jdbc:iotdb://" + host + ":6667/";
-    private static final String username = "root";
-    private static final String password = "root";
-
-
-    public static void main(String[] args) throws SQLException, ClassNotFoundException {
-
-        ToIoTDB toIoTDB = new ToIoTDB();
-        Connection connection = toIoTDB.getConnection();
-//      Connection connection = (Connection) new IOTdbJDBCUtils(url, username, password).getConnection();
-        System.out.println(connection!=null?"打开连接成功！":"打开连接失败！");
-
-        ResultSet rs=null;
-        String storgeGroup="root.test";
-        Statement statement = connection.createStatement();
-        String sql=String.format("set storage group to %s",storgeGroup);
-        statement = connection.createStatement();
-        int i = statement.executeUpdate(sql);
-        System.out.println("当前创建组的结果为:"+i);
-
-        //查看创建的组是否存在
-        sql="SHOW STORAGE GROUPS"; //查看所有的存储组
-        rs= statement.executeQuery(sql);
-        outputResult(rs);
-
-        sql=String.format("show storage group  %s",storgeGroup);
-        rs=statement.executeQuery(sql);
-        outputResult(rs);
-        //统计存在的数量
-        sql=String.format("count storage group %s",storgeGroup);
-        rs=statement.executeQuery(sql);
-        outputResult(rs);
-    }
-
-    private static void outputResult(ResultSet resultSet) throws SQLException {
-        if (resultSet != null) {
-            System.out.println("--------------------------");
-            final ResultSetMetaData metaData = resultSet.getMetaData();
-            final int columnCount = metaData.getColumnCount();
-            for (int i = 0; i < columnCount; i++) {
-                System.out.print(metaData.getColumnLabel(i + 1) + ", ");
-            }
-            System.out.println();
-            while (resultSet.next()) {
-                for (int i = 1;; i++) {
-                    System.out.print(resultSet.getString(i));
-                    if (i < columnCount) {
-                        System.out.print(", ");
-                    } else {
-                        System.out.println();
-                        break;
-                    }
-                }
-            }
-            System.out.println("--------------------------\n");
-        }
-    }
-
-
-}

From 208f5e5e208d2837b87b668ede7749b7d9f34deb Mon Sep 17 00:00:00 2001
From: Number7 <1845377266@qq.com>
Date: Wed, 25 Sep 2024 22:20:35 +0800
Subject: [PATCH 4/5] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8A=A5=E6=96=87?=
 =?UTF-8?q?=E6=A8=A1=E7=89=88=E5=AD=98=E5=85=A5redis=E7=9A=84=E6=96=B9?=
 =?UTF-8?q?=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/template/domain/resp/CarTypeResp.java | 22 ++++++++++++++
 .../java/com/template/mapper/CarMapper.java   |  4 +++
 .../java/com/template/service/CarService.java |  6 ++++
 .../template/service/impl/CarServiceImpl.java |  9 ++++++
 .../service/impl/TemplateServiceImpl.java     |  3 --
 .../template/util/SynchronizingTemplate.java  | 29 ++++++++++---------
 .../resources/mapper/message/CarMapper.xml    | 10 +++++++
 7 files changed, 66 insertions(+), 17 deletions(-)
 create mode 100644 cloud-modules/cloud-modules-template/src/main/java/com/template/domain/resp/CarTypeResp.java

diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/domain/resp/CarTypeResp.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/domain/resp/CarTypeResp.java
new file mode 100644
index 0000000..a878870
--- /dev/null
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/domain/resp/CarTypeResp.java
@@ -0,0 +1,22 @@
+package com.template.domain.resp;
+
+import com.template.domain.CarType;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author：liuxinyue
+ * @Package：com.template.domain.resp
+ * @Project：cloud-server
+ * @name：CarTypeResp
+ * @Date：2024/9/25 22:09
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class CarTypeResp extends CarType{
+
+    private String templateName;
+
+}
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/mapper/CarMapper.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/mapper/CarMapper.java
index 68146c4..e7c56e8 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/mapper/CarMapper.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/mapper/CarMapper.java
@@ -2,9 +2,12 @@ package com.template.mapper;
 
 import com.template.domain.CarType;
 import com.template.domain.SysCar;
+import com.template.domain.resp.CarTypeResp;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 /**
  * @Author：liuxinyue
  * @Package：com.template.mapper
@@ -19,4 +22,5 @@ public interface CarMapper {
 
     CarType carMapper(@Param("carTypeId") Long carTypeId);
 
+    List<CarTypeResp> findAllCars();
 }
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/CarService.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/CarService.java
index 97cba3b..76989ce 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/CarService.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/CarService.java
@@ -2,6 +2,9 @@ package com.template.service;
 
 import com.template.domain.CarType;
 import com.template.domain.SysCar;
+import com.template.domain.resp.CarTypeResp;
+
+import java.util.List;
 
 /**
  * @Author：liuxinyue
@@ -15,4 +18,7 @@ public interface CarService {
 
     CarType findCarTypeById(Long carTypeId);
 
+    List<CarTypeResp> findAllCars();
+
+
 }
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/CarServiceImpl.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/CarServiceImpl.java
index f065806..2160b51 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/CarServiceImpl.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/CarServiceImpl.java
@@ -2,11 +2,14 @@ package com.template.service.impl;
 
 import com.template.domain.CarType;
 import com.template.domain.SysCar;
+import com.template.domain.resp.CarTypeResp;
 import com.template.mapper.CarMapper;
 import com.template.service.CarService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * @Author：liuxinyue
  * @Package：com.template.service.impl
@@ -31,4 +34,10 @@ public class CarServiceImpl implements CarService {
         return carMapper.carMapper(carTypeId);
     }
 
+    @Override
+    public List<CarTypeResp> findAllCars() {
+        return carMapper.findAllCars();
+    }
+
+
 }
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
index 62b6eb5..7cab657 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
@@ -40,9 +40,6 @@ public class TemplateServiceImpl implements TemplateService{
     @Autowired
     private MessageTemplateTypeService messageTemplateTypeService;
 
-
-
-
     @Autowired
     private RedisTemplate redisTemplate;
 
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
index e852eb4..0b12216 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
@@ -1,8 +1,12 @@
 package com.template.util;
 import com.template.domain.MessageTemplateType;
+import com.template.domain.SysCar;
 import com.template.domain.Template;
+import com.template.domain.resp.CarTypeResp;
+import com.template.service.CarService;
 import com.template.service.TemplateService;
 import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.ListOperations;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
@@ -29,26 +33,23 @@ public class SynchronizingTemplate {
     @Resource
     private RedisTemplate redisTemplate;
 
+    @Autowired
+    private CarService carService;
+
+
     @PostConstruct
     public void synchronizeTemplate() {
         //获取所有报文模版的ID
         log.info("获取所有报文模版的ID");
         List<Template> templates = templateService.templateList();
         templates.forEach(template -> {
-            log.info("每个报文模版的ID");
-            Integer templateId = template.getTemplateId();
-            log.info("根据模版ID去查报文模版中谁属于这个类型的报文");
-            List<MessageTemplateType> list=templateService.findTemplateById(templateId);
-            ListOperations<String,Object> listOperations = redisTemplate.opsForList();
-            log.info("清除redis中的值");
-            redisTemplate.delete(template.getTemplateName());
-            log.info("将报文模版名称作为key,将list作为值");
-            listOperations.leftPushAll(template.getTemplateName(), list);
-            List<Object> range = listOperations.range(template.getTemplateName(), 0, -1);
-            log.info(range);
-            for (Object o : range) {
-                log.info("数据为:"+o);
-            }
+            Integer templateId = template.getTemplateId(); //报文模版ID
+            List<MessageTemplateType> list=templateService.findTemplateById(templateId); //根据报文模版ID查询所有的报文模版
+            ListOperations<String,Object> listOperations = redisTemplate.opsForList(); //将报文信息存储到redis中
+            redisTemplate.delete(template.getTemplateName());//因为每一次添加缓存的时候不会覆盖之前的数据 所有将数据先清空
+            List<CarTypeResp> allCars = carService.findAllCars();//查询所有车辆 里面有模版名称
+            redisTemplate.opsForList().leftPushAll("VehicleType", allCars);//将车辆类型放入列表
+            listOperations.leftPushAll(template.getTemplateName(), list); //将报文信息存储到redis中
         });
     }
 }
diff --git a/cloud-modules/cloud-modules-template/src/main/resources/mapper/message/CarMapper.xml b/cloud-modules/cloud-modules-template/src/main/resources/mapper/message/CarMapper.xml
index 828fe75..b475c1e 100644
--- a/cloud-modules/cloud-modules-template/src/main/resources/mapper/message/CarMapper.xml
+++ b/cloud-modules/cloud-modules-template/src/main/resources/mapper/message/CarMapper.xml
@@ -10,4 +10,14 @@
     <select id="carMapper" resultType="com.template.domain.CarType">
         select * from car_type where id=#{carTypeId}
     </select>
+    <select id="findAllCars" resultType="com.template.domain.resp.CarTypeResp">
+        SELECT
+            car_type.*,
+            t_template.template_name
+        FROM
+            car_type
+                LEFT JOIN t_template ON car_type.template_id = t_template.template_id
+    </select>
+
+
 </mapper>

From 61e8d5903a0b0169f3ee07482a26dc686e81ba33 Mon Sep 17 00:00:00 2001
From: Number7 <1845377266@qq.com>
Date: Wed, 25 Sep 2024 22:36:16 +0800
Subject: [PATCH 5/5] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8A=A5=E6=96=87?=
 =?UTF-8?q?=E8=A7=A3=E6=9E=90=E6=8E=A5=E5=8F=A3=E7=9A=84=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/template/service/impl/TemplateServiceImpl.java  | 5 +++++
 .../main/java/com/template/util/SynchronizingTemplate.java   | 5 +++++
 2 files changed, 10 insertions(+)

diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
index 7cab657..58e2c78 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/service/impl/TemplateServiceImpl.java
@@ -75,6 +75,11 @@ public class TemplateServiceImpl implements TemplateService{
             CarType carTypeById = carService.findCarTypeById(carByVin.getCarTypeId());
             //查询报文模版
             Template templateDate=templateMapper.findTemplateByName(carTypeById.getTypeName());
+            log.info("取出Redis中对象报文模版信息");
+            List range = redisTemplate.opsForList().range("VehicleType", 0, -1);
+            range.forEach(o -> {
+
+            });
             //根据报文模版的ID查询对应的模版
             List<MessageTemplateType> messageByTemplateName = messageTemplateTypeService.findMessageByTemplateName(templateDate.getTemplateId());
             //将模版里面有的配置进行循环
diff --git a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
index 0b12216..0af6c23 100644
--- a/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
+++ b/cloud-modules/cloud-modules-template/src/main/java/com/template/util/SynchronizingTemplate.java
@@ -50,6 +50,11 @@ public class SynchronizingTemplate {
             List<CarTypeResp> allCars = carService.findAllCars();//查询所有车辆 里面有模版名称
             redisTemplate.opsForList().leftPushAll("VehicleType", allCars);//将车辆类型放入列表
             listOperations.leftPushAll(template.getTemplateName(), list); //将报文信息存储到redis中
+            List range = redisTemplate.opsForList().range("VehicleType", 0, -1);
+            range.forEach(o -> {
+                log.info("数据为:"+o);
+            });
+
         });
     }
 }