From 6d9d53ae35b915346360855fe3a79e9d7afa93b1 Mon Sep 17 00:00:00 2001 From: yanglin Date: Thu, 27 Feb 2025 15:59:46 +0800 Subject: [PATCH] =?UTF-8?q?REQ-3300:=20=E8=B0=83=E6=95=B4=E4=BF=A1?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ess/server/ess/mq/EssBroadcaster.java | 27 ++++++++++++++----- 1 file changed, 20 insertions(+), 7 deletions(-) diff --git a/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/EssBroadcaster.java b/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/EssBroadcaster.java index 4199c895..d6f0c9e3 100644 --- a/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/EssBroadcaster.java +++ b/ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/EssBroadcaster.java @@ -1,6 +1,8 @@ package cn.axzo.nanopart.ess.server.ess.mq; +import org.springframework.stereotype.Component; + import cn.axzo.basics.common.BeanMapper; import cn.axzo.framework.rocketmq.Event; import cn.axzo.framework.rocketmq.EventProducer; @@ -11,7 +13,6 @@ import cn.axzo.nanopart.ess.api.mq.EssContractStateChangeMessage; import cn.axzo.nanopart.ess.server.dao.EssContractDao; import cn.axzo.nanopart.ess.server.entity.EssContract; import lombok.RequiredArgsConstructor; -import org.springframework.stereotype.Component; /** * @author yanglin @@ -29,18 +30,30 @@ public class EssBroadcaster { return; EssContractStateChangeMessage message = new EssContractStateChangeMessage(); message.setContract(BeanMapper.copyBean(reload, EssContractInfo.class)); - eventProducer.send(Event.builder().eventCode(MQEvent.ESS_CONTRACT_STATE_CHANGE.getEventCode()).shardingKey( - contract.getEssContractId()).targetId(contract.getEssContractId()).targetType("ess-contract").data( - message).build()); + // @formatter:off + eventProducer.send(Event.builder() + .eventCode(MQEvent.ESS_CONTRACT_STATE_CHANGE.getEventCode()) + .shardingKey(contract.getEssContractId()) + .targetId(contract.getEssContractId()) + .targetType("ess-contract") + .data(message) + .build()); + // @formatter:on } public void fireDownloadContractPDF(EssContract contract, boolean retryDownload) { EssContractDownloadPDFEvent message = new EssContractDownloadPDFEvent(); message.setContract(BeanMapper.copyBean(contract, EssContractInfo.class)); message.setRetryDownload(retryDownload); - eventProducer.send(Event.builder().eventCode(MQEvent.ESS_CONTRACT_DOWNLOAD_PDF.getEventCode()).shardingKey( - contract.getEssContractId()).targetId(contract.getEssContractId()).targetType("ess-contract").data( - message).build()); + // @formatter:off + eventProducer.send(Event.builder() + .eventCode(MQEvent.ESS_CONTRACT_DOWNLOAD_PDF.getEventCode()) + .shardingKey(contract.getEssContractId()) + .targetId(contract.getEssContractId()) + .targetType("ess-contract") + .data(message) + .build()); + // @formatter:on } }