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] =?UTF-8?q?=E6=8A=A5=E6=96=87=E6=A8=A1=E7=89=88=E5=AD=98?=
 =?UTF-8?q?=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>