diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/domain/MqDataInfo.java b/ruoyi-system/src/main/java/com/ruoyi/business/domain/MqDataInfo.java
index ee94014..232ea82 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/business/domain/MqDataInfo.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/business/domain/MqDataInfo.java
@@ -4,12 +4,11 @@ import java.time.LocalDateTime;
 
 public class MqDataInfo{
 
-    private String content;
+    private String storeCode;
     private String channel;
 
     private BusOrderInfo busOrderInfo;
     private BusAgentInfo agentInfo;
-    private BusStoreInfo storeInfo;
 
     private BusStoreConfigInfo busStoreConfigInfo;
 
@@ -37,12 +36,12 @@ public class MqDataInfo{
         this.busOrderInfo = busOrderInfo;
     }
 
-    public String getContent() {
-        return content;
+    public String getStoreCode() {
+        return storeCode;
     }
 
-    public void setContent(String content) {
-        this.content = content;
+    public void setStoreCode(String storeCode) {
+        this.storeCode = storeCode;
     }
 
     public String getChannel() {
@@ -53,11 +52,4 @@ public class MqDataInfo{
         this.channel = channel;
     }
 
-    public BusStoreInfo getStoreInfo() {
-        return storeInfo;
-    }
-
-    public void setStoreInfo(BusStoreInfo storeInfo) {
-        this.storeInfo = storeInfo;
-    }
 }
diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java
index 9acec2c..12b2777 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java
@@ -65,7 +65,9 @@ public class AiConsumer {
             long startTime = System.currentTimeMillis();
             System.out.println("开始======="+startTime);
             BusAgentInfo agentInfo = mqDataInfo.getAgentInfo();
-            BusStoreInfo busStoreInfo = mqDataInfo.getStoreInfo();
+            BusStoreInfo busStoreInfo = new BusStoreInfo();
+            busStoreInfo.setStoreCode(mqDataInfo.getStoreCode());
+            busStoreInfo.setMarketingChannels(mqDataInfo.getChannel());
             BusOrderInfo busOrderInfo = mqDataInfo.getBusOrderInfo();
             BusStoreConfigInfo busStoreConfigInfo = mqDataInfo.getBusStoreConfigInfo();
             try {
diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java
index a73ab12..dae0206 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java
@@ -289,9 +289,16 @@ public class AiServiceImpl implements IAiService {
                         continue;
                     }
                     MqDataInfo mqDataInfo = new MqDataInfo();
+                    agentInfo.setAgentName(null);
                     mqDataInfo.setAgentInfo(agentInfo);
-                    mqDataInfo.setStoreInfo(busStoreInfo);
+                    mqDataInfo.setStoreCode(storeInfo.getStoreCode());
+                    mqDataInfo.setChannel(storeInfo.getMarketingChannels());
+                    busOrderInfo.setOrderStatus(null);
+                    busOrderInfo.setStoreName(null);
+                    busOrderInfo.setRecipientPhone(null);
+                    busOrderInfo.setRecipientBindedPhone(null);
                     mqDataInfo.setBusOrderInfo(busOrderInfo);
+                    busStoreConfigInfo.setStoreName(null);
                     mqDataInfo.setBusStoreConfigInfo(busStoreConfigInfo);
                     // 调用
                     aiProducer.sendInfo(mqDataInfo);