From a9eaa5e41f4fe84fd10178d61bcc5f9e7a740743 Mon Sep 17 00:00:00 2001
From: xiaolipro <2357729423@qq.com>
Date: Fri, 27 Dec 2024 10:36:57 +0800
Subject: [PATCH] review

---
 .../Services/Broadcasting/BroadcastingService.cs           | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/SJZY.Track.Application/Services/Broadcasting/BroadcastingService.cs b/src/SJZY.Track.Application/Services/Broadcasting/BroadcastingService.cs
index ad52c841..de070657 100644
--- a/src/SJZY.Track.Application/Services/Broadcasting/BroadcastingService.cs
+++ b/src/SJZY.Track.Application/Services/Broadcasting/BroadcastingService.cs
@@ -63,7 +63,8 @@ public class BroadcastingService : ITransientDependency
             else
                 data.Option = 3;
 
-            _rabbitClientBus.Publish(GlobalConst.TrackChangeExchange, $"TrackChange.{content.SubSystemCode}", Encoding.UTF8.GetBytes(data.ToJson()));
+            _rabbitClientBus.Publish(GlobalConst.TrackChangeExchange, $"TrackChange.{content.SubSystemCode}",
+                Encoding.UTF8.GetBytes(data.ToJson()));
             return Task.CompletedTask;
         });
     }
@@ -75,6 +76,7 @@ public class BroadcastingService : ITransientDependency
     /// <returns></returns>
     public Task TrackPushCompletedPublicTopicAsync(TrackPushRecordIndex log)
     {
+        // todo: 不需要异步
         return Task.Run(() =>
         {
             var data = new TrackPushCompletedEvent
@@ -97,7 +99,8 @@ public class BroadcastingService : ITransientDependency
                 Extra = log.Extra
             };
 
-            _rabbitClientBus.Publish(GlobalConst.TrackPushExchange, $"TrackPush.{log.SubSystemCode}", Encoding.UTF8.GetBytes(data.ToJson()));
+            _rabbitClientBus.Publish(GlobalConst.TrackPushExchange, $"TrackPush.{log.SubSystemCode}",
+                Encoding.UTF8.GetBytes(data.ToJson()));
             return Task.CompletedTask;
         });
     }