From c5653fe5b8249eef42edda8ca719e9eadf894dc2 Mon Sep 17 00:00:00 2001
From: zhaoqiaobo <583671871@qq.com>
Date: Wed, 18 Dec 2024 11:19:29 +0800
Subject: [PATCH] =?UTF-8?q?feat(all):=20=E9=85=8D=E9=80=81=E6=98=8E?=
 =?UTF-8?q?=E7=BB=86=E6=8A=A5=E8=A1=A8-=E8=A3=85=E8=BD=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

1 添加事务控制
---
 .../distribution/receiver/report/LoadingReportListener.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/LoadingReportListener.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/LoadingReportListener.java
index d620e9b32..1fd9864bf 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/LoadingReportListener.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/report/LoadingReportListener.java
@@ -23,6 +23,7 @@ import org.springblade.common.model.DistributionLoadVO;
 import org.springblade.common.model.NodeFanoutMsg;
 import org.springblade.common.model.PackageData;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.util.HashMap;
@@ -48,6 +49,7 @@ public class LoadingReportListener implements ReportService {
 	@Resource
 	private DistributionProperties destinationProperties;
 
+	@Transactional
 	public void buildReport(String msg) {
 		NodeFanoutMsg bean = JSONUtil.toBean(msg, NodeFanoutMsg.class);
 		Object main = bean.getMain();