From 5a7766fa272460771e619a91f76cbfe51900d12d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E8=BF=9C?= <460289628@qq.com> Date: Tue, 9 Sep 2025 09:15:36 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E8=BF=9BSmqMessage=EF=BC=8C=E8=A1=8C?= =?UTF-8?q?=E4=B8=9A=E7=9B=B4=E6=8E=A5=E6=A0=B9=E6=8D=AE=E5=85=AC=E5=8F=B8?= =?UTF-8?q?=E5=88=AB=E6=9D=A5=E8=8E=B7=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/cn/cerc/mis/queue/SmqGroup.java | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) 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 d1be85b6..47199bdf 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 queue = (AbstractObjectQueue) SpringBean.get(clazz); return this.addMessage(queue.setData(data), corpNo); } + } -- Gitee