修改推送回调

src/yibin/Push.YiBin/PushDomainService.cs

@@ -214,12 +214,13 @@ public class PushDomainService : IPushDomainService, IScopeDependency
 
         await _messageRepository.AddAsync(message, cancellation); //写入本地数据库
 
-        //if (message.ClientId == "Hotline")
-        //{
-        //    var data = _mapper.Map<PushMessageDto>(message);
-        //    data.Type = "0";
-        //    await _capPublisher.PublishAsync(Push.Share.EventNames.UpdateSendSmsState, data, cancellationToken: cancellation);
-        //}
+        //如果使用http推送状态，这里注释
+        if (message.ClientId == "Hotline")
+        {
+            var data = _mapper.Map<PushMessageDto>(message);
+            data.Type = "0";
+            await _capPublisher.PublishAsync(Push.Share.EventNames.UpdateSendSmsState, data, cancellationToken: cancellation);
+        }
     }
 
     #endregion
@@ -301,7 +302,8 @@ public class PushDomainService : IPushDomainService, IScopeDependency
                 {
                     var dataPush = _mapper.Map<PushMessageDto>(data);
                     dataPush.Type = "1";
-                    await _fwClient.RequestNoTokenAsync<Reponse>("api/v1/PushMessage/update-send-sms-state", "Post", System.Text.Json.JsonSerializer.Serialize(dataPush), cancellationToken: default);
+                    await _capPublisher.PublishAsync(Push.Share.EventNames.UpdateSendSmsState, dataPush, cancellationToken: default);
+                    //    await _fwClient.RequestNoTokenAsync<Reponse>("api/v1/PushMessage/update-send-sms-state", "Post", System.Text.Json.JsonSerializer.Serialize(dataPush), cancellationToken: default);
                 }
             }
             catch (Exception)
@@ -354,7 +356,8 @@ public class PushDomainService : IPushDomainService, IScopeDependency
                 {
                     var dataPush = _mapper.Map<PushMessageDto>(data);
                     dataPush.Type = "2";
-                    await _fwClient.RequestNoTokenAsync<Reponse>("api/v1/PushMessage/update-send-sms-state", "Post", System.Text.Json.JsonSerializer.Serialize(dataPush), cancellationToken: default);
+                    await _capPublisher.PublishAsync(Push.Share.EventNames.UpdateSendSmsState, dataPush, cancellationToken: default);
+                    //    await _fwClient.RequestNoTokenAsync<Reponse>("api/v1/PushMessage/update-send-sms-state", "Post", System.Text.Json.JsonSerializer.Serialize(dataPush), cancellationToken: default);
                 }
             }
             catch (Exception)