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 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 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 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