src/Sharing.Api/Controllers/HotlineMessageReceiveController.cs

@@ -162,7 +162,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderGetVisitInfoReceive)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderGetVisitInfoReceive)]
         public async Task GetVisitInfoReceive(GetVisitInfoReceiveInfo dto)
         {
             var data = _mapper.Map<GetVisitInfoReceive>(dto);
@@ -181,7 +181,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderGetCaseBackApply)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderGetCaseBackApply)]
         public async Task GetCaseBackApply(GetCaseBackApplyInfo dto)
         {
             var data = _mapper.Map<GetCaseBackApply>(dto);
@@ -200,7 +200,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderDelayCaseInfoSend)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderDelayCaseInfoSend)]
         public async Task DelayCaseInfoSend(DelayCaseInfoSendInfo dto)
         {
             var data = _mapper.Map<DelayCaseInfoSend>(dto);
@@ -219,7 +219,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSendSuperviseProcessInfo)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSendSuperviseProcessInfo)]
         public async Task SendSuperviseProcessInfo(SendSuperviseProcessInfoInfo dto)
         {
             var data = _mapper.Map<SendSuperviseProcessInfo>(dto);
@@ -238,7 +238,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSendSuperviseResultInfo)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSendSuperviseResultInfo)]
         public async Task SendSuperviseResultInfo(SendSuperviseResultInfoInfo dto)
         {
             var data = _mapper.Map<SendSuperviseResultInfo>(dto);
@@ -412,7 +412,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitCaseResult)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitCaseResult)]
         public async Task SubmitCaseResult(CaseResult dto)
         {
             var data = _mapper.Map<SubmitCaseResult>(dto);
@@ -431,7 +431,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitCaseProcess)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitCaseProcess)]
         public async Task SubmitCaseProcess(CaseProcess dto)
         {
             var data = _mapper.Map<SubmitCaseProcess>(dto);
@@ -450,7 +450,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitVisitInfo)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitVisitInfo)]
         public async Task SubmitVisitInfo(VisitInfo dto)
         {
             var data = _mapper.Map<SubmitVisitInfo>(dto);
@@ -469,7 +469,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitCaseRecord)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitCaseRecord)]
         public async Task SubmitCaseRecord(CaseRecord dto)
         {
             var data = _mapper.Map<SubmitCaseRecord>(dto);
@@ -488,7 +488,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitCaseTotal)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderSubmitCaseTotal)]
         public async Task SubmitCaseTotal(CaseTotal dto)
         {
             var data = _mapper.Map<SubmitCaseTotal>(dto);
@@ -509,7 +509,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        // [CapSubscribe(Hotline.Share.Mq.EventNames.SendCaseInfo)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.SendCaseInfo)]
         public async Task SendCaseInfo(OrderDto dto)
         {
             //处理数据
@@ -628,7 +628,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.SupplyCaseInfoSend)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.SupplyCaseInfoSend)]
         public async Task SupplyCaseInfoSend(SupplyCaseInfoSendInfo dto)
         {
             var data = _mapper.Map<SupplyCaseInfoSend>(dto);
@@ -647,7 +647,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.SendRevokeCaseInfo)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.SendRevokeCaseInfo)]
         public async Task SendRevokeCaseInfo(RevokeCaseInfoInfo dto)
         {
             var data = _mapper.Map<RevokeCaseInfo>(dto);
@@ -666,7 +666,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.SendRemindCaseInfo)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.SendRemindCaseInfo)]
         public async Task SendRemindCaseInfo(RemindCaseInfoInfo dto)
         {
             var data = _mapper.Map<RemindCaseInfo>(dto);
@@ -690,7 +690,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoSend)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoSend)]
         public async Task GetKnowledgeInfoSend(KnowledgeInfoSendInfo dto)
         {
             var data = _mapper.Map<GetKnowledgeInfoSend>(dto);
@@ -709,7 +709,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoUpdate)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoUpdate)]
         public async Task GetKnowledgeInfoUpdate(GetKnowledgeInfoUpdateInfo dto)
         {
             var data = _mapper.Map<GetKnowledgeInfoUpdate>(dto);
@@ -728,7 +728,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoAbandon)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoAbandon)]
         public async Task GetKnowledgeInfoAbandon(GetKnowledgeInfoAbandonInfo dto)
         {
             var data = _mapper.Map<GetKnowledgeInfoAbandon>(dto);
@@ -748,7 +748,7 @@ namespace Sharing.Api.Controllers
         /// <param name="dto"></param>
         /// <returns></returns>
         [NonAction]
-        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineSendRealTimeStatus)]
+        [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineSendRealTimeStatus)]
         public async Task SendRealTimeStatus(SendRealTimeStatusInfo dto)
         {
             var data = _mapper.Map<SendRealTimeStatus>(dto);

src/Sharing.Province/Controllers/ProvinceController.cs

@@ -57,15 +57,21 @@ namespace Sharing.Province.Controllers
         [AllowAnonymous]
         public async Task<string> GetCaseResultReceive([FromBody] KnowledgeInfoSendInfo dto)
         {
-            var data = _mapper.Map<GetKnowledgeInfoSend>(dto);
 
-            //将上报信息写入本地库
-            var id = await _getKnowledgeInfoSendRepository.AddAsync(data);
+            await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoSend, dto, cancellationToken: HttpContext.RequestAborted);
 
-            data.Id = id;
-            //信息上报
-            await _mediator.Publish(new GetKnowledgeInfoSendNotification(data));
-            return id;
+            await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoUpdate, dto, cancellationToken: HttpContext.RequestAborted);
+
+            await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoAbandon, dto, cancellationToken: HttpContext.RequestAborted);
+            //var data = _mapper.Map<GetKnowledgeInfoSend>(dto);
+
+            ////将上报信息写入本地库
+            //var id = await _getKnowledgeInfoSendRepository.AddAsync(data);
+
+            //data.Id = id;
+            ////信息上报
+            //await _mediator.Publish(new GetKnowledgeInfoSendNotification(data));
+            return "";
             //var data = _mapper.Map<GetCaseResultReceive>(dto);
 
             //var pusher = _pusherProvider.CreatePusher(_channelConfigurationManager);