|
|
@ -4,7 +4,6 @@ import com.alibaba.fastjson.JSONObject; |
|
|
|
import com.elink.esua.epdc.commons.tools.constant.RocketMqConstant; |
|
|
|
import com.elink.esua.epdc.modules.archives.service.ArchivesService; |
|
|
|
import com.elink.esua.epdc.modules.archivesdept.service.ArchivesDeptService; |
|
|
|
import com.elink.esua.epdc.modules.dept.service.DeptInfoService; |
|
|
|
import com.elink.esua.epdc.modules.reportissue.service.ReportIssueService; |
|
|
|
import com.elink.esua.epdc.modules.rocketmq.dto.OrganizationModifyDTO; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
@ -33,9 +32,6 @@ public class OrganizationModifyConsumer implements RocketMQListener<MessageExt> |
|
|
|
@Autowired |
|
|
|
private ArchivesDeptService archivesDeptService; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private DeptInfoService deptInfoService; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private ReportIssueService reportIssueService; |
|
|
|
|
|
|
@ -50,8 +46,6 @@ public class OrganizationModifyConsumer implements RocketMQListener<MessageExt> |
|
|
|
archivesService.modifyOrganizationInfo(dto); |
|
|
|
// 档案部门修改组织机构信息
|
|
|
|
archivesDeptService.modifyOrganizationInfo(dto); |
|
|
|
// 部门信息表修改组织机构信息
|
|
|
|
deptInfoService.modifyOrganizationInfo(dto); |
|
|
|
// 我要举报修改组织机构信息
|
|
|
|
reportIssueService.modifyOrganizationInfo(dto); |
|
|
|
log.info("EPDC-CUSTOM-SERVER消费消息END:{topic:{}, msgId:{}, body:{}}", RocketMqConstant.MQ_TOPIC_ORGANIZATION, messageExt.getMsgId(), body); |
|
|
|