src/Sharing.Api/Controllers/HotlineMessageReceiveController.cs

@@ -40,6 +40,7 @@ namespace Sharing.Api.Controllers
         private readonly ISendCaseInfoRepository _sendCaseInfoRepository;
         private readonly ISupplyCaseInfoSendRepository _supplyCaseInfoSendRepository;
         private readonly IRevokeCaseInfoRepository _revokeCaseInfoRepository;
+        private readonly IRemindCaseInfoRepository _remindCaseInfoRepository;
 
         /// <summary>
         /// 
@@ -60,6 +61,10 @@ namespace Sharing.Api.Controllers
         /// <param name="submitVisitInfoRepository"></param>
         /// <param name="submitCaseRecordRepository"></param>
         /// <param name="submitCaseTotalRepository"></param>
+        /// <param name="sendCaseInfoRepository"></param>
+        /// <param name="supplyCaseInfoSendRepository"></param>
+        /// <param name="revokeCaseInfoRepository"></param>
+        /// <param name="remindCaseInfoRepository"></param>
         public HotlineMessageReceiveController(IMediator mediator, ILogger<HotlineMsgReceiver> logger, IMapper mapper
             , IGetCaseResultReceiveRepository getCaseResultReceiveRepository, IGetCaseProcessReceiveRepository getCaseProcessReceiveRepository
             , IGetVisitInfoReceiveRepository getVisitInfoReceiveRepository, IGetCaseBackApplyRepository getCaseBackApplyRepository
@@ -68,7 +73,8 @@ namespace Sharing.Api.Controllers
             , ISubmitCaseResultRepository submitCaseResultRepository, ISubmitCaseProcessRepository submitCaseProcessRepository
             , ISubmitVisitInfoRepository submitVisitInfoRepository, ISubmitCaseRecordRepository submitCaseRecordRepository
             , ISubmitCaseTotalRepository submitCaseTotalRepository, ISendCaseInfoRepository sendCaseInfoRepository
-            , ISupplyCaseInfoSendRepository supplyCaseInfoSendRepository, IRevokeCaseInfoRepository revokeCaseInfoRepository)
+            , ISupplyCaseInfoSendRepository supplyCaseInfoSendRepository, IRevokeCaseInfoRepository revokeCaseInfoRepository
+            , IRemindCaseInfoRepository remindCaseInfoRepository)
         {
             _mediator = mediator;
             _logger = logger;
@@ -89,6 +95,7 @@ namespace Sharing.Api.Controllers
             _sendCaseInfoRepository = sendCaseInfoRepository;
             _supplyCaseInfoSendRepository = supplyCaseInfoSendRepository;
             _revokeCaseInfoRepository = revokeCaseInfoRepository;
+            _remindCaseInfoRepository = remindCaseInfoRepository;
         }
         #endregion
 
@@ -627,7 +634,7 @@ namespace Sharing.Api.Controllers
         /// <returns></returns>
         [NonAction]
         //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderCreated)]
-        public async Task RevokeCaseInfo(RevokeCaseInfoInfo dto)
+        public async Task SendRevokeCaseInfo(RevokeCaseInfoInfo dto)
         {
             var data = _mapper.Map<RevokeCaseInfo>(dto);
             data.Direction = "1";
@@ -639,6 +646,24 @@ namespace Sharing.Api.Controllers
             await _mediator.Publish(new SendRevokeCaseInfoNotification(data));
         }
 
+        /// <summary>
+        /// 服务工单催单
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <returns></returns>
+        [NonAction]
+        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderCreated)]
+        public async Task SendRemindCaseInfo(RemindCaseInfoInfo dto)
+        {
+            var data = _mapper.Map<RemindCaseInfo>(dto);
+            data.Direction = "1";
+            //将上报信息写入本地库
+            var id = await _remindCaseInfoRepository.AddAsync(data);
+
+            data.Id = id;
+            //信息上报
+            await _mediator.Publish(new SendRemindCaseInfoNotification(data));
+        }
 
 
     }