模版信息同步到redis中

beacon-cache/src/main/java/com/mashibing/cache/contorller/CacheController.java

@@ -5,6 +5,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -38,5 +39,4 @@ public class CacheController {
 
     }
 
-
 }

beacon-test/src/main/java/com/mashibing/test/entity/ClientTemplate.java

@@ -8,6 +8,29 @@ public class ClientTemplate {
   private String templateText;
   private long templateType;
   private long templateState;
+
+  @Override
+  public String toString() {
+    return "ClientTemplate{" +
+            "id=" + id +
+            ", signId=" + signId +
+            ", templateText='" + templateText + '\'' +
+            ", templateType=" + templateType +
+            ", templateState=" + templateState +
+            ", useId=" + useId +
+            ", useWeb='" + useWeb + '\'' +
+            ", created=" + created +
+            ", createId=" + createId +
+            ", updated=" + updated +
+            ", updateId=" + updateId +
+            ", isDelete=" + isDelete +
+            ", extend1='" + extend1 + '\'' +
+            ", extend2='" + extend2 + '\'' +
+            ", extend3='" + extend3 + '\'' +
+            ", extend4='" + extend4 + '\'' +
+            '}';
+  }
+
   private long useId;
   private String useWeb;
   private java.sql.Timestamp created;

beacon-test/src/main/java/com/mashibing/test/mapper/ClientTemplateMapper.java

@@ -14,4 +14,6 @@ import java.util.List;
 public interface ClientTemplateMapper {
     @Select("select * from client_template where sign_id = #{signId}")
     List<ClientTemplate> findBySignId(@Param("signId") Long signId);
+
+
 }

beacon-test/src/test/java/com/mashibing/test/mapper/ClientTemplateMapperTest.java

@@ -0,0 +1,52 @@
+package com.mashibing.test.mapper;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.mashibing.test.client.CacheClient;
+import com.mashibing.test.entity.ClientTemplate;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import static org.junit.Assert.*;
+
+/**
+ * @author kezhen
+ * @date 2022/12/28
+ * @description
+ */
+@SpringBootTest
+@RunWith(SpringRunner.class)
+public class ClientTemplateMapperTest {
+
+    @Autowired
+    private ClientTemplateMapper clientTemplateMapper;
+
+    @Autowired
+    private CacheClient cacheClient;
+
+    @Test
+    public void findBySignId() {
+        List<ClientTemplate> clientTemplateList = clientTemplateMapper.findBySignId(15L);
+        List<ClientTemplate> clientTemplateList2 = clientTemplateMapper.findBySignId(24L);
+        for (ClientTemplate clientTemplate : clientTemplateList) {
+            System.out.println("clientTemplate = " + clientTemplate);
+        }
+        ObjectMapper objectMapper = new ObjectMapper();
+        List<Map> value = clientTemplateList.stream().map(clientTemplate -> {
+            try {
+                return objectMapper.readValue(objectMapper.writeValueAsString(clientTemplate), Map.class);
+            } catch (JsonProcessingException e) {
+                e.printStackTrace();
+                return null;
+            }
+        }).collect(Collectors.toList());
+        cacheClient.sadd("client_template:15", value.toArray(new Map[]{}));
+    }
+}