src/Sharing.Api/Controllers/HotlineMessageReceiveController.cs

@@ -8,6 +8,7 @@ using Sharing.Application;
 using Sharing.Notifications.HuiJu;
 using Sharing.Notifications.XieTong;
 using Sharing.Orders;
+using Sharing.Province.Dtos.HuiJu.Send;
 using Sharing.Province.Dtos.XieTong.Send;
 using Sharing.Province.HuiJu.Send;
 using Sharing.Province.XieTong.Send;
@@ -32,6 +33,7 @@ namespace Sharing.Api.Controllers
         private readonly ISendSuperviseProcessInfoRepository _sendSuperviseProcessInfoRepository;
         private readonly ISendSuperviseResultInfoRepository _sendSuperviseResultInfoRepository;
         private readonly ISubmitCaseInfoRepository _submitCaseInfoRepository;
+        private readonly ISubmitCaseResultRepository _submitCaseResultRepository;
 
         /// <summary>
         /// 
@@ -52,7 +54,8 @@ namespace Sharing.Api.Controllers
             , IGetCaseResultReceiveRepository getCaseResultReceiveRepository, IGetCaseProcessReceiveRepository getCaseProcessReceiveRepository
             , IGetVisitInfoReceiveRepository getVisitInfoReceiveRepository, IGetCaseBackApplyRepository getCaseBackApplyRepository
             , IDelayCaseInfoSendRepository delayCaseInfoSendRepository, ISendSuperviseProcessInfoRepository sendSuperviseProcessInfoRepository
-            , ISendSuperviseResultInfoRepository sendSuperviseResultInfoRepository, ISubmitCaseInfoRepository submitCaseInfoRepository)
+            , ISendSuperviseResultInfoRepository sendSuperviseResultInfoRepository, ISubmitCaseInfoRepository submitCaseInfoRepository
+            , ISubmitCaseResultRepository submitCaseResultRepository)
         {
             _dataOrderRepository = dataOrderRepository;
             _mediator = mediator;
@@ -66,6 +69,7 @@ namespace Sharing.Api.Controllers
             _sendSuperviseProcessInfoRepository = sendSuperviseProcessInfoRepository;
             _sendSuperviseResultInfoRepository = sendSuperviseResultInfoRepository;
             _submitCaseInfoRepository = submitCaseInfoRepository;
+            _submitCaseResultRepository = submitCaseResultRepository;
         }
         #endregion
 
@@ -362,5 +366,24 @@ namespace Sharing.Api.Controllers
             await _mediator.Publish(new OrderCreatedNotification(submitCaseInfo));
         }
 
+        /// <summary>
+        /// 服务工单处理结果
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <returns></returns>
+        [NonAction]
+        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderCreated)]
+        public async Task SubmitCaseResult(CaseResult dto)
+        {
+            var data = _mapper.Map<SubmitCaseResult>(dto);
+
+            //将上报信息写入本地库
+            var id = await _submitCaseResultRepository.AddAsync(data);
+
+            data.Id = id;
+            //信息上报
+            await _mediator.Publish(new SubmitCaseResultNotification(data));
+
+        }
     }
 }