测试推送

Waste.Application/Test/TestAppService.cs

@@ -9,6 +9,7 @@ using System.Linq;
 using System.Net.Http;
 using System.Text;
 using System.Threading.Tasks;
+using Waste.Application.SubscribeInfo;
 
 namespace Waste.Application
 {
@@ -23,10 +24,12 @@ namespace Waste.Application
         private static string ApiSecretHash = App.Configuration["SZDevPlatSetting:ApiSecretHash"];
         private readonly IHttpClientFactory _clientFactory;
         private readonly ILoggerService _loggerService;
-        public TestAppService(ILoggerService loggerService, IHttpClientFactory clientFactory)
+        private readonly ISubscribeService _subscribeService;
+        public TestAppService(ILoggerService loggerService, IHttpClientFactory clientFactory, ISubscribeService subscribeService)
         {
             _loggerService = loggerService;
             _clientFactory = clientFactory;
+            _subscribeService = subscribeService;
         }
         /// <summary>
         /// 接收测试
@@ -47,6 +50,29 @@ namespace Waste.Application
         {
 
         }
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <returns></returns>
+        [HttpGet]
+        public async Task TestThirdSendAsync()
+        {
+            await _subscribeService.SeedThirdMessageAsync(new SendThirdMessageSubscriDto { 
+                Url= "https://localhost:44335/api/test/recv",
+                WasteType= "\u0000\u0000\u0000\u0000纸壳",
+                Weight="20.9",
+                TrashCode="0",
+                Time= 1653033312,
+                Body="",
+                DeviceId= Guid.Parse("39fcdce8-9e54-b87f-fc8e-616a9072c224")
+            });
+        }
+
+        [HttpPost]
+        public void Recv(SendMessageToThirdS2CDto input)
+        {
+            var a = input;
+        }
 
         [HttpGet]
         public async Task TestSendAsync()

Waste.Application/ThirdApiInfo/OpenAppService.cs

@@ -9,10 +9,8 @@ using Microsoft.Net.Http.Headers;
 using Nirvana.Common;
 using Nirvana.Common.File;
 using System;
-using System.Collections.Generic;
 using System.IO;
 using System.Linq;
-using System.Text;
 using System.Threading.Tasks;
 using Waste.Application.SubscribeInfo;
 

Waste.Application/Waste.Application.xml

@@ -2163,6 +2163,11 @@
             额外信息
             </summary>
         </member>
+        <member name="P:Waste.Application.SubscribeInfo.SendMessageToThirdS2CDto.DeviceId">
+            <summary>
+            设备ID
+            </summary>
+        </member>
         <member name="T:Waste.Application.SubscribeInfo.ISubscribeService">
             <summary>
             CAP订阅相关接口
@@ -2556,6 +2561,12 @@
             <param name="data"></param>
             <returns></returns>
         </member>
+        <member name="M:Waste.Application.TestAppService.TestThirdSendAsync">
+            <summary>
+            
+            </summary>
+            <returns></returns>
+        </member>
         <member name="T:Waste.Application.ThirdApiInfo.DevHeartRequestDto">
             <summary>
             心跳包上报数据