日志

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/config/Config.java

+package com.gic.haoban.manage.service.config;
+
+import com.ctrip.framework.apollo.spring.annotation.EnableApolloConfig;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * Created by tgs on 2020/2/23.
+ */
+@Configuration
+@EnableApolloConfig
+public class Config {
+    @Value("${corpid}")
+    private String corpid;
+    @Value("${suiteid}")
+    private String suiteId;
+    @Value("${host}")
+    private String host;
+    @Value("${wxSuiteid}")
+    private String wxSuiteid;
+
+    public String getCorpid() {
+        return corpid;
+    }
+
+    public void setCorpid(String corpid) {
+        this.corpid = corpid;
+    }
+
+    public String getSuiteId() {
+        return suiteId;
+    }
+
+    public void setSuiteId(String suiteId) {
+        this.suiteId = suiteId;
+    }
+
+    public String getHost() {
+        return host;
+    }
+
+    public void setHost(String host) {
+        this.host = host;
+    }
+
+    public String getWxSuiteid() {
+        return wxSuiteid;
+    }
+
+    public void setWxSuiteid(String wxSuiteid) {
+        this.wxSuiteid = wxSuiteid;
+    }
+}

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/MessageApiServiceImpl.java

@@ -17,6 +17,7 @@ import com.gic.haoban.manage.api.enums.WxEditType;
 import com.gic.haoban.manage.api.service.DepartmentApiService;
 import com.gic.haoban.manage.api.service.MessageApiService;
 import com.gic.haoban.manage.api.service.StaffApiService;
+import com.gic.haoban.manage.service.config.Config;
 import com.gic.haoban.manage.service.entity.*;
 import com.gic.haoban.manage.service.service.*;
 import com.gic.mq.sdk.GicMQClient;
@@ -53,6 +54,8 @@ public class MessageApiServiceImpl implements MessageApiService {
     private StaffApiService staffApiService;
     @Autowired
     private WxApplicationService wxApplicationService;
+    @Autowired
+    private Config config;
 
     @Override
     public void gicMessageReceive(GicMessageDTO gicMessageDTO) {
@@ -69,8 +72,10 @@ public class MessageApiServiceImpl implements MessageApiService {
     public void wxMessageReceive(QywxCallBackDTO qywxCallBackDTO) {
         GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
         try {
-            log.info("发送消息到dealWxMessageMq，{}", JSON.toJSONString(qywxCallBackDTO));
-            clientInstance.sendMessage("dealWxMessageMq", JSON.toJSONString(qywxCallBackDTO));
+            if(config.getSuiteId().equals(qywxCallBackDTO.getSuiteId())){
+                log.info("发送消息到dealWxMessageMq，{}", JSON.toJSONString(qywxCallBackDTO));
+                clientInstance.sendMessage("dealWxMessageMq", JSON.toJSONString(qywxCallBackDTO));
+            }
         } catch (Exception e) {
             e.printStackTrace();
         }

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/config/Config.java

@@ -16,6 +16,8 @@ public class Config {
     private String suiteId;
     @Value("${host}")
     private String host;
+    @Value("${wxSuiteid}")
+    private String wxSuiteid;
 
     public String getCorpid() {
         return corpid;
@@ -40,4 +42,12 @@ public class Config {
     public void setHost(String host) {
         this.host = host;
     }
+
+    public String getWxSuiteid() {
+        return wxSuiteid;
+    }
+
+    public void setWxSuiteid(String wxSuiteid) {
+        this.wxSuiteid = wxSuiteid;
+    }
 }