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();