From 2a7d61412cc1d76401092260062d123a4a2379b9 Mon Sep 17 00:00:00 2001
From: wangxianzhang <ZHANGYUGE6666>
Date: Tue, 29 Mar 2022 14:06:33 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=201.=E5=B1=85=E6=B0=91?=
 =?UTF-8?q?=E5=AF=BC=E5=85=A5=EF=BC=8C=E6=8E=A8=E9=80=81mq=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=EF=BC=8C=E8=BF=9B=E8=A1=8C=E7=9B=B8=E5=85=B3=E5=8A=A8?=
 =?UTF-8?q?=E4=BD=9C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/controller/IcResiUserController.java     | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
index 08930bbb75..c7e6bad9df 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
@@ -24,6 +24,7 @@ import com.alibaba.excel.write.metadata.fill.FillWrapper;
 import com.epmet.commons.rocketmq.messages.IcResiUserAddMQMsg;
 import com.epmet.commons.tools.annotation.LoginUser;
 import com.epmet.commons.tools.aop.NoRepeatSubmit;
+import com.epmet.commons.tools.constant.AppClientConstant;
 import com.epmet.commons.tools.constant.Constant;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.constant.StrConstant;
@@ -486,6 +487,15 @@ public class IcResiUserController implements ResultDataResolver {
                 } catch (IOException e) {
                     log.error("【导入居民信息失败】清理上传的文件失败：{}", ExceptionUtils.getErrorStackTrace(e));
                 }
+
+                //推送MQ事件
+                IcResiUserAddMQMsg mqMsg = new IcResiUserAddMQMsg();
+                mqMsg.setCustomerId(EpmetRequestHolder.getHeader(AppClientConstant.CUSTOMER_ID));
+                //mqMsg.setIcResiUser(resiUserId);
+                SystemMsgFormDTO form = new SystemMsgFormDTO();
+                form.setMessageType(SystemMessageType.IC_RESI_USER_ADD);
+                form.setContent(mqMsg);
+                epmetMessageOpenFeignClient.sendSystemMsgByMQ(form);
             }
         });