src/Sharing.Api/Controllers/HotlineMessageReceiveController.cs

@@ -123,7 +123,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderGetCaseResultReceive)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderGetCaseResultReceive)]
         public async Task GetCaseResultReceive(GetCaseResultReceiveInfo dto)
         {
             var data = _mapper.Map<GetCaseResultReceive>(dto);
@@ -143,7 +143,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderGetCaseProcessReceive)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderGetCaseProcessReceive)]
         public async Task GetCaseProcessReceive(GetCaseProcessReceiveInfo dto)
         {
             var data = _mapper.Map<GetCaseProcessReceive>(dto);

src/Sharing.Application/Sharing.Application.csproj

@@ -7,7 +7,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Hotline.Share" Version="1.0.0" />
+    <PackageReference Include="Hotline.Share" Version="1.0.1" />
     <PackageReference Include="XF.EasyCaching" Version="1.0.0" />
   </ItemGroup>
 

src/Sharing.Province/Controllers/ProvinceController.cs

@@ -3,11 +3,13 @@ using MapsterMapper;
 using MediatR;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
+using Sharing.Notifications.HuiJu;
 using Sharing.Notifications.Knowledge;
 using Sharing.Province.Dtos;
 using Sharing.Province.Dtos.HuiJu.Send;
 using Sharing.Province.Dtos.XieTong.Knowledge;
 using Sharing.Province.Dtos.XieTong.Send;
+using Sharing.Province.HuiJu.Send;
 using Sharing.Province.XieTong.Knowledge;
 using Sharing.WebCore;
 
@@ -55,6 +57,8 @@ namespace Sharing.Province.Controllers
         [AllowAnonymous]
         public async Task<string> GetCaseResultReceive([FromBody] KnowledgeInfoSendInfo dto)
         {
+            await _mediator.Publish(new OrderCreatedNotification(new SubmitCaseInfo()));
+
             var data = _mapper.Map<GetKnowledgeInfoSend>(dto);
 
             //将上报信息写入本地库
@@ -62,7 +66,7 @@ namespace Sharing.Province.Controllers
 
             data.Id = id;
             //信息上报
-             _mediator.Publish(new GetKnowledgeInfoSendNotification(data));
+            await _mediator.Publish(new GetKnowledgeInfoSendNotification(data));
             return id;
             //var data = _mapper.Map<GetCaseResultReceive>(dto);