diff --git a/esua-epdc/epdc-admin/epdc-admin-server/pom.xml b/esua-epdc/epdc-admin/epdc-admin-server/pom.xml index b80db976..25fb339e 100644 --- a/esua-epdc/epdc-admin/epdc-admin-server/pom.xml +++ b/esua-epdc/epdc-admin/epdc-admin-server/pom.xml @@ -150,8 +150,8 @@ wx29b074840ef4bfd9 4adb1afccc69f205cdf5b521d74e2aca - + 47.104.85.99:9876;114.215.125.123:9876 + jinshui-organizationGroup @@ -175,8 +175,8 @@ wx9f20a46906ab2c3e dc13065f79429979d9f687d249eb5c4e - + 47.104.85.99:9876;114.215.125.123:9876 + jinshui-organizationGroup diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/rocketmq/producer/OrganizationModifyProducer.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/rocketmq/producer/OrganizationModifyProducer.java index fa04810c..525d70f8 100644 --- a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/rocketmq/producer/OrganizationModifyProducer.java +++ b/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(); + } } } diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/SysDeptServiceImpl.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/SysDeptServiceImpl.java index 65438dec..71f67d30 100644 --- a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/SysDeptServiceImpl.java +++ b/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