只有平阴客户上报事件

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java

@@ -155,17 +155,19 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently
             logger.info("consumer projectChanged msg success,{}",aBoolean);
 
             //发送项目数据上报的mq消息
-            if ("issue_shift_project".equals(msgObj.getOperation()) || "created".equals(msgObj.getOperation()) || "close".equals(msgObj.getOperation())) {
-                String type;
-                if ("issue_shift_project".equals(msgObj.getOperation()) || "created".equals(msgObj.getOperation())) {
-                    type = SystemMessageType.PROJECT_ADD;
-                } else {
-                    type = SystemMessageType.PROJECT_EDIT;
+            if ("6f203e30de1a65aab7e69c058826cd80".equals(customerId)) {
+                if ("issue_shift_project".equals(msgObj.getOperation()) || "created".equals(msgObj.getOperation()) || "close".equals(msgObj.getOperation())) {
+                    String type;
+                    if ("issue_shift_project".equals(msgObj.getOperation()) || "created".equals(msgObj.getOperation())) {
+                        type = SystemMessageType.PROJECT_ADD;
+                    } else {
+                        type = SystemMessageType.PROJECT_EDIT;
+                    }
+                    List<String> projectList = new ArrayList<>();
+                    projectList.add(msgObj.getProjectId());
+                    DisputeProcessMQMsg msg = new DisputeProcessMQMsg(customerId, projectList, type);
+                    SpringContextUtils.getBean(ScreenProjectDataService.class).sendProjectChangeMq(msg);
                 }
-                List<String> projectList = new ArrayList<>();
-                projectList.add(msgObj.getProjectId());
-                DisputeProcessMQMsg msg = new DisputeProcessMQMsg(customerId, projectList, type);
-                SpringContextUtils.getBean(ScreenProjectDataService.class).sendProjectChangeMq(msg);
             }
         } catch (RenException e) {
             // 如果是我们手动抛出的异常，说明在业务可控范围内。目前不需要MQ重试