还原admin模块mq相关配置

esua-epdc/epdc-admin/epdc-admin-server/pom.xml

@@ -150,8 +150,8 @@
                 <work.wx.ma.appId>wx29b074840ef4bfd9</work.wx.ma.appId>
                 <work.wx.ma.secret>4adb1afccc69f205cdf5b521d74e2aca</work.wx.ma.secret>
                 <!--RocketMQ-->
-                <!--<rocketmq.name.server>47.104.85.99:9876;114.215.125.123:9876</rocketmq.name.server>
-                <rocketmq.producer.group>jinshui-organizationGroup</rocketmq.producer.group>-->
+                <rocketmq.name.server>47.104.85.99:9876;114.215.125.123:9876</rocketmq.name.server>
+                <rocketmq.producer.group>jinshui-organizationGroup</rocketmq.producer.group>
             </properties>
         </profile>
         <profile>
@@ -175,8 +175,8 @@
                 <work.wx.ma.appId>wx9f20a46906ab2c3e</work.wx.ma.appId>
                 <work.wx.ma.secret>dc13065f79429979d9f687d249eb5c4e</work.wx.ma.secret>
                 <!--RocketMQ-->
-                <!--<rocketmq.name.server>47.104.85.99:9876;114.215.125.123:9876</rocketmq.name.server>
-                <rocketmq.producer.group>jinshui-organizationGroup</rocketmq.producer.group>-->
+                <rocketmq.name.server>47.104.85.99:9876;114.215.125.123:9876</rocketmq.name.server>
+                <rocketmq.producer.group>jinshui-organizationGroup</rocketmq.producer.group>
             </properties>
         </profile>
         <profile>

esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/rocketmq/producer/OrganizationModifyProducer.java

@@ -18,8 +18,8 @@ import org.springframework.stereotype.Component;
 @Component
 public class OrganizationModifyProducer {
 
-//    @Autowired
-//    private RocketMQTemplate rocketMQTemplate;
+    @Autowired
+    private RocketMQTemplate rocketMQTemplate;
 
     /**
      *
@@ -31,13 +31,13 @@ public class OrganizationModifyProducer {
      * @since 2020/3/6 21:09
      */
     public void sendMessage(String topic, String tag, String keys, String body) {
-//        Message message = new Message(topic, tag, keys, body.getBytes());
-//        try {
-//            SendResult sendResult = rocketMQTemplate.getProducer().send(message);
-//            log.info("EPDC-ADMIN-SERVER发送消息结果：{sendStatus:{}, topic:{}, msgId:{}}", sendResult.getSendStatus(), topic, sendResult.getMsgId());
-//        } catch (Exception e) {
-//            log.error("EPDC-ADMIN-SERVER发送消息异常：{topic:{}, tag:{}, keys:{}, body:{}}", topic, tag, keys, body);
-//            e.printStackTrace();
-//        }
+        Message message = new Message(topic, tag, keys, body.getBytes());
+        try {
+            SendResult sendResult = rocketMQTemplate.getProducer().send(message);
+            log.info("EPDC-ADMIN-SERVER发送消息结果：{sendStatus:{}, topic:{}, msgId:{}}", sendResult.getSendStatus(), topic, sendResult.getMsgId());
+        } catch (Exception e) {
+            log.error("EPDC-ADMIN-SERVER发送消息异常：{topic:{}, tag:{}, keys:{}, body:{}}", topic, tag, keys, body);
+            e.printStackTrace();
+        }
     }
 }

esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/SysDeptServiceImpl.java

@@ -749,15 +749,15 @@ public class SysDeptServiceImpl extends BaseServiceImpl<SysDeptDao, SysDeptEntit
      */
     private void sendMqMessage(SysDeptDTO dto) {
         // 获取旧信息
-//        SysDeptEntity entity = baseDao.getById(dto.getId());
-//        if (!dto.getName().equals(entity.getName())) {
-//            OrganizationModifyDTO body = new OrganizationModifyDTO();
-//            body.setDeptId(dto.getId());
-//            body.setOldDeptName(entity.getName());
-//            body.setNewDeptName(dto.getName());
-//            body.setTypeKey(entity.getTypeKey());
-//            organizationModifyProducer.sendMessage(RocketMqConstant.MQ_TOPIC_ORGANIZATION, RocketMqConstant.MQ_TAG_ORGANIZATION,
-//                    dto.getId().toString(), JSONObject.toJSONString(body));
-//        }
+        SysDeptEntity entity = baseDao.getById(dto.getId());
+        if (!dto.getName().equals(entity.getName())) {
+            OrganizationModifyDTO body = new OrganizationModifyDTO();
+            body.setDeptId(dto.getId());
+            body.setOldDeptName(entity.getName());
+            body.setNewDeptName(dto.getName());
+            body.setTypeKey(entity.getTypeKey());
+            organizationModifyProducer.sendMessage(RocketMqConstant.MQ_TOPIC_ORGANIZATION, RocketMqConstant.MQ_TAG_ORGANIZATION,
+                    dto.getId().toString(), JSONObject.toJSONString(body));
+        }
     }
 }