wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3300: 调整信息

Browse Source
This commit is contained in:
yanglin 2025-02-27 15:59:46 +08:00
parent 06bfea2a4e
commit 6d9d53ae35
1 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/mq/EssBroadcaster.java
View File

@ -1,6 +1,8 @@
package cn.axzo.nanopart.ess.server.ess.mq; package cn.axzo.nanopart.ess.server.ess.mq;
import org.springframework.stereotype.Component;
import cn.axzo.basics.common.BeanMapper; import cn.axzo.basics.common.BeanMapper;
import cn.axzo.framework.rocketmq.Event; import cn.axzo.framework.rocketmq.Event;
import cn.axzo.framework.rocketmq.EventProducer; 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.dao.EssContractDao;
import cn.axzo.nanopart.ess.server.entity.EssContract; import cn.axzo.nanopart.ess.server.entity.EssContract;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
/** /**
* @author yanglin * @author yanglin
@ -29,18 +30,30 @@ public class EssBroadcaster {
return; return;
EssContractStateChangeMessage message = new EssContractStateChangeMessage(); EssContractStateChangeMessage message = new EssContractStateChangeMessage();
message.setContract(BeanMapper.copyBean(reload, EssContractInfo.class)); message.setContract(BeanMapper.copyBean(reload, EssContractInfo.class));
eventProducer.send(Event.builder().eventCode(MQEvent.ESS_CONTRACT_STATE_CHANGE.getEventCode()).shardingKey( // @formatter:off
contract.getEssContractId()).targetId(contract.getEssContractId()).targetType("ess-contract").data( eventProducer.send(Event.builder()
message).build()); .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) { public void fireDownloadContractPDF(EssContract contract, boolean retryDownload) {
EssContractDownloadPDFEvent message = new EssContractDownloadPDFEvent(); EssContractDownloadPDFEvent message = new EssContractDownloadPDFEvent();
message.setContract(BeanMapper.copyBean(contract, EssContractInfo.class)); message.setContract(BeanMapper.copyBean(contract, EssContractInfo.class));
message.setRetryDownload(retryDownload); message.setRetryDownload(retryDownload);
eventProducer.send(Event.builder().eventCode(MQEvent.ESS_CONTRACT_DOWNLOAD_PDF.getEventCode()).shardingKey( // @formatter:off
contract.getEssContractId()).targetId(contract.getEssContractId()).targetType("ess-contract").data( eventProducer.send(Event.builder()
message).build()); .eventCode(MQEvent.ESS_CONTRACT_DOWNLOAD_PDF.getEventCode())
.shardingKey(contract.getEssContractId())
.targetId(contract.getEssContractId())
.targetType("ess-contract")
.data(message)
.build());
// @formatter:on
} }
} }