diff --git a/.idea/encodings.xml b/.idea/encodings.xml
index b066421..29f4707 100644
--- a/.idea/encodings.xml
+++ b/.idea/encodings.xml
@@ -1,6 +1,8 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="Encoding">
+    <file url="file://$PROJECT_DIR$/beacon-cache/src/main/java" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/beacon-common/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/beancon-api/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
diff --git a/beacon-cache/pom.xml b/beacon-cache/pom.xml
new file mode 100644
index 0000000..4d560c7
--- /dev/null
+++ b/beacon-cache/pom.xml
@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.mashibing</groupId>
+        <artifactId>beacon-cloud</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>beacon-cache</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+<!--        web项目-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+<!--        nacos注册中心-->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
+        </dependency>
+<!--        nacos配置中心-->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
+        </dependency>
+<!--        data系列的redis依赖-->
+<!--        <dependency>-->
+<!--            <groupId>org.springframework.boot</groupId>-->
+<!--            <artifactId>spring-boot-starter-data-redis</artifactId>-->
+<!--        </dependency>-->
+        <dependency>
+            <groupId>com.msb.cloud</groupId>
+            <artifactId>horse-framework-starter-redis</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file
diff --git a/beacon-cache/src/main/java/com/mashibing/cache/CacheStarterApp.java b/beacon-cache/src/main/java/com/mashibing/cache/CacheStarterApp.java
new file mode 100755
index 0000000..ff0ba31
--- /dev/null
+++ b/beacon-cache/src/main/java/com/mashibing/cache/CacheStarterApp.java
@@ -0,0 +1,18 @@
+package com.mashibing.cache;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+
+/**
+ * @author kezhen
+ * @date 2022/12/25
+ * @description
+ */
+@SpringBootApplication
+@EnableDiscoveryClient
+public class CacheStarterApp {
+    public static void main(String[] args) {
+        SpringApplication.run(CacheStarterApp.class, args);
+    }
+}
diff --git a/beacon-cache/src/main/java/com/mashibing/cache/config/RedisConfig.java b/beacon-cache/src/main/java/com/mashibing/cache/config/RedisConfig.java
new file mode 100644
index 0000000..8a432af
--- /dev/null
+++ b/beacon-cache/src/main/java/com/mashibing/cache/config/RedisConfig.java
@@ -0,0 +1,68 @@
+package com.mashibing.cache.config;
+
+import com.fasterxml.jackson.databind.Module;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer;
+import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
+import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateSerializer;
+import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.RedisSerializer;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * @author kezhen
+ * @date 2022/12/25
+ * @description 设置redisTemplate的序列化方式
+ */
+@Configuration
+public class RedisConfig {
+//    @Bean
+//    public <T> RedisTemplate<String ,T> redisTemplate(RedisConnectionFactory factory,RedisSerializer<Object> redisSerializer){
+//        RedisTemplate<String, T> redisTemplate = new RedisTemplate<>();
+//        redisTemplate.setConnectionFactory(factory);
+//        redisTemplate.setKeySerializer(RedisSerializer.string());
+//        redisTemplate.setHashKeySerializer(RedisSerializer.string());
+//
+//        redisTemplate.setValueSerializer(redisSerializer);
+//        redisTemplate.setHashValueSerializer(redisSerializer);
+//
+//        redisTemplate.afterPropertiesSet();
+//        return redisTemplate;
+//    }
+//
+//    @Bean
+//    public RedisSerializer<Object> redisSerializer(){
+//        ObjectMapper objectMapper = new ObjectMapper();
+//
+//        DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+//        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+//
+//        Module timeModule = new JavaTimeModule()
+//                .addDeserializer(LocalDate.class,new LocalDateDeserializer(dateFormatter))
+//                .addDeserializer(LocalDateTime.class,new LocalDateTimeDeserializer(dateTimeFormatter))
+//                .addSerializer(LocalDate.class,new LocalDateSerializer(dateFormatter))
+//                .addSerializer(LocalDateTime.class,new LocalDateTimeSerializer(dateTimeFormatter));
+//        objectMapper.registerModules(timeModule);
+//
+//        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
+//
+//        jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
+//
+//        return jackson2JsonRedisSerializer;
+//
+//
+//    }
+
+}
+
+
+
diff --git a/beacon-cache/src/main/java/com/mashibing/cache/contorller/TestController.java b/beacon-cache/src/main/java/com/mashibing/cache/contorller/TestController.java
new file mode 100644
index 0000000..7772fb9
--- /dev/null
+++ b/beacon-cache/src/main/java/com/mashibing/cache/contorller/TestController.java
@@ -0,0 +1,37 @@
+package com.mashibing.cache.contorller;
+
+import com.msb.framework.redis.RedisClient;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * @author kezhen
+ * @date 2022/12/25
+ * @description
+ */
+@RestController
+public class TestController {
+//    @Autowired
+//    @Resource
+//    private RedisTemplate<String, Objects> redisTemplate;
+
+    @Resource
+    private RedisClient redisClient;
+    @PostMapping("/test/set/{key}")
+    public String set(@PathVariable String key, @RequestBody Map map){
+        System.out.println("TestController.set");
+        redisClient.putMap(key,map);
+        return "ok";
+    }
+
+    @GetMapping("/text/get/{key}")
+    public Map get(@PathVariable String key) {
+        Map<String, Object> result = redisClient.getMap(key);
+        return result;
+    }
+}
diff --git a/beacon-cache/src/main/resources/bootstrap.yml b/beacon-cache/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..e802b24
--- /dev/null
+++ b/beacon-cache/src/main/resources/bootstrap.yml
@@ -0,0 +1,13 @@
+spring:
+  application:
+    name: beacon-cache
+  profiles:
+    active: dev
+  cloud:
+    nacos:
+      config:
+        server-addr: 192.168.1.8:8848
+        file-extension: yml
+#        beacon-cache-dev.yml
+      discovery:
+        server-addr: 192.168.1.8:8848
\ No newline at end of file
diff --git a/beacon-common/pom.xml b/beacon-common/pom.xml
new file mode 100644
index 0000000..b489014
--- /dev/null
+++ b/beacon-common/pom.xml
@@ -0,0 +1,27 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.mashibing</groupId>
+        <artifactId>beacon-cloud</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>beacon-common</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file
diff --git a/beacon-common/src/main/java/com/mashibing/common/model/StandardSubmit.java b/beacon-common/src/main/java/com/mashibing/common/model/StandardSubmit.java
new file mode 100644
index 0000000..628a9fc
--- /dev/null
+++ b/beacon-common/src/main/java/com/mashibing/common/model/StandardSubmit.java
@@ -0,0 +1,56 @@
+package com.mashibing.common.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+import java.time.LocalDateTime;
+
+/**
+ * @author kezhen
+ * @date 2022/12/24
+ * @description 在策略模块-短信网关模块
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@ToString
+public class StandardSubmit {
+    //针对当前短信的唯一标识，雪花算法
+    private Long sequenceId;
+    //客户端ID
+    private Long cliendId;
+    //客户的ip白名单
+    private String ip;
+    //客户业务内的uid，客户请求传递的
+    private String uid;
+    //目标手机号
+    private String mobile;
+    //短信内容的签名
+    private String sign;
+    //短信内容
+    private String text;
+    //短信的发送时间，当前系统时间
+    private LocalDateTime sendTime;
+    //当前短信的费用，计算短信内容的文字，70个字一条，超过部分，67字一条
+    private Long fee;
+    // 目标手机号的运营商（策略模块）
+    private Integer operatorId;
+    //目标手机号的归属区号（策略模块）
+    private Integer areaCode;
+    //区域名称，目标手机号的归属地（策略模块）
+    private String area;
+    //通道下发的源号码 eg:1069123412341234 （策略模块）
+    private String srcNumber;
+    /**
+     * 通道的id信息 （策略模块）
+     */
+    private Long channelId;
+    /**
+     * 短信的发送状态，0-等待/发送ing，1-成功，2-失败，默认情况就是0
+     */
+    private int reportState;
+
+    //后续再做封装
+}
diff --git a/beancon-api/pom.xml b/beancon-api/pom.xml
index 6480e16..a0172bd 100644
--- a/beancon-api/pom.xml
+++ b/beancon-api/pom.xml
@@ -52,6 +52,12 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-validation</artifactId>
         </dependency>
+<!--        一些公公共的组件会放到当前的common中-->
+        <dependency>
+            <groupId>com.mashibing</groupId>
+            <artifactId>beacon-common</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
     </dependencies>
 
     <properties>
diff --git a/beancon-api/src/main/java/com/mashibing/api/controller/SmsController.java b/beancon-api/src/main/java/com/mashibing/api/controller/SmsController.java
index 343c76c..0eac82f 100644
--- a/beancon-api/src/main/java/com/mashibing/api/controller/SmsController.java
+++ b/beancon-api/src/main/java/com/mashibing/api/controller/SmsController.java
@@ -5,6 +5,7 @@ import com.mashibing.api.from.SingleSendForm;
 import com.mashibing.api.util.R;
 import com.mashibing.api.vo.ResultVO;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.util.StringUtils;
 import org.springframework.validation.BindingResult;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -12,6 +13,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.servlet.http.HttpServletRequest;
+
 /**
  * @author kezhen
  * @date 2022/12/23
@@ -27,14 +30,55 @@ public class SmsController {
      * @return
      */
     @PostMapping(value = "/single_send", produces = "application/json;charset=utf-8")
-    public ResultVO signleSend(@RequestBody @Validated SingleSendForm singleSendForm, BindingResult bindingResult) {
+    public ResultVO signleSend(@RequestBody @Validated SingleSendForm singleSendForm, BindingResult bindingResult, HttpServletRequest request) {
         System.out.println(singleSendForm);
         System.out.println("SmsController.signleSend");
         if (bindingResult.hasErrors()) {
             String message = bindingResult.getFieldError().getDefaultMessage();
             log.info("【接口模块-单条短信Contorller】 参数不合法，msg = {}", message);
-            return R.error(SmsCodeEnum.PARAMETER_ERROR.getCode(),message);
+            return R.error(SmsCodeEnum.PARAMETER_ERROR.getCode(), message);
         }
+        //===============构建StandardSubmit==================
+
+        String ip = this.getRealIP(request);
+        System.out.println("ip = " + ip);
+
+
+        //===============发送到MQ，交给策略模块处理==================
+
         return R.ok();
     }
+
+    /**
+     * 获取客户端真实的IP地址
+     *
+     * @param request
+     * @return
+     */
+    private String getRealIP(HttpServletRequest request) {
+        String ip;
+        String ips = request.getHeader("x-forwarded-for");
+        if (StringUtils.isEmpty(ips) || "unknow".equalsIgnoreCase(ips)) {
+            return ips.substring(0, ips.indexOf(","));
+        }
+
+        ip = request.getHeader("x-real-ip");
+        if (StringUtils.isEmpty(ip) || "unknow".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("Proxy-client-ip");
+
+        }
+        if (StringUtils.isEmpty(ip) || "unknow".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("wl-proxy-client-ip");
+        }
+        if (StringUtils.isEmpty(ip) || "unknow".equalsIgnoreCase(ip)) {
+            //7. 基于其他代理服务器的方式获取请求头的IP地址
+            ip = request.getHeader("http_client_ip");
+        }
+        if (StringUtils.isEmpty(ip) || "unknow".equalsIgnoreCase(ip)) {
+            //8. 基于传统方式获取IP
+            ip = request.getRemoteAddr();
+        }
+
+        return ip;
+    }
 }
diff --git a/pom.xml b/pom.xml
index 185cb85..b27b633 100644
--- a/pom.xml
+++ b/pom.xml
@@ -17,14 +17,14 @@
     <packaging>pom</packaging>
     <modules>
         <module>beancon-api</module>
+        <module>beacon-common</module>
+        <module>beacon-cache</module>
     </modules>
 
     <properties>
         <spring.cloud-version>Hoxton.SR12</spring.cloud-version>
         <spring.cloud.alibaba-version>2.2.6.RELEASE</spring.cloud.alibaba-version>
-        <maven.compiler.source>8</maven.compiler.source>
-        <maven.compiler.target>8</maven.compiler.target>
-        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <horse-version>1.0.0</horse-version>
     </properties>
 
     <dependencyManagement>
@@ -43,6 +43,13 @@
                 <type>pom</type>
                 <scope>import</scope>
             </dependency>
+            <dependency>
+                <groupId>com.msb.cloud</groupId>
+                <artifactId>horse-framework-starters</artifactId>
+                <version>${horse-version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
         </dependencies>
     </dependencyManagement>