diff --git a/summer-controller/src/main/java/cn/cerc/mis/queue/SmqGroup.java b/summer-controller/src/main/java/cn/cerc/mis/queue/SmqGroup.java
index d1be85b654a95822bdc004e4b3b5608f25b80a18..47199bdfc7d11ba07b7a3bd4e21efccd84b5b651 100644
--- a/summer-controller/src/main/java/cn/cerc/mis/queue/SmqGroup.java
+++ b/summer-controller/src/main/java/cn/cerc/mis/queue/SmqGroup.java
@@ -15,7 +15,6 @@ import com.mongodb.client.MongoCollection;
 import com.mongodb.client.model.Filters;
 import com.mongodb.client.model.Sorts;
 
-import cn.cerc.db.core.ConfigReader;
 import cn.cerc.db.core.DataRow;
 import cn.cerc.db.core.Datetime;
 import cn.cerc.db.core.Datetime.DateType;
@@ -62,13 +61,9 @@ public class SmqGroup extends Handle {
     }
 
     public SmqMessage addMessage(SmqQueue target, String corpNo) {
-        ConfigReader configReader = SpringBean.get(ConfigReader.class);
-        String industry = configReader.getAppName();
-        if (!corpNo.equals(this.getCorpNo())) {
-            // industry = SpringBean.get(OurInfoList.class).getOriginal(corpNo);
-            CorpIndustryFind corpIndustryFind = SpringBean.get(CorpIndustryFind.class);
-            industry = corpIndustryFind.getIndustry(corpNo);
-        }
+        // industry = SpringBean.get(OurInfoList.class).getOriginal(corpNo);
+        CorpIndustryFind corpIndustryFind = SpringBean.get(CorpIndustryFind.class);
+        String industry = corpIndustryFind.getIndustry(corpNo);
         var message = new SmqMessage(this, corpNo, industry);
         message.setTarget(target);
         message.setToken(this.getSession().getToken());
@@ -397,4 +392,5 @@ public class SmqGroup extends Handle {
         AbstractObjectQueue<T> queue = (AbstractObjectQueue<T>) SpringBean.get(clazz);
         return this.addMessage(queue.setData(data), corpNo);
     }
+
 }