diff --git a/esua-epdc/epdc-admin/epdc-admin-server/pom.xml b/esua-epdc/epdc-admin/epdc-admin-server/pom.xml index 25fb339e..b80db976 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 525d70f8..fa04810c 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 71f67d30..65438dec 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