Merge branch 'dev'

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

@@ -155,6 +155,7 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently
             logger.info("consumer projectChanged msg success,{}",aBoolean);
 
             //发送项目数据上报的mq消息
+            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())) {
@@ -167,6 +168,7 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently
                     DisputeProcessMQMsg msg = new DisputeProcessMQMsg(customerId, projectList, type);
                     SpringContextUtils.getBean(ScreenProjectDataService.class).sendProjectChangeMq(msg);
                 }
+            }
         } catch (RenException e) {
             // 如果是我们手动抛出的异常，说明在业务可控范围内。目前不需要MQ重试
             logger.error("【RocketMQ】消费项目变动消息失败:",e);