src/Sharing.Api/Controllers/HotlineMessageReceiveController.cs

@@ -45,6 +45,7 @@ namespace Sharing.Api.Controllers
         private readonly IRevokeCaseInfoRepository _revokeCaseInfoRepository;
         private readonly IRemindCaseInfoRepository _remindCaseInfoRepository;
         private readonly IGetKnowledgeInfoSendRepository _getKnowledgeInfoSendRepository;
+        private readonly IGetKnowledgeInfoUpdateRepository _getKnowledgeInfoUpdateRepository;
 
         /// <summary>
         /// 
@@ -78,7 +79,8 @@ namespace Sharing.Api.Controllers
             , ISubmitVisitInfoRepository submitVisitInfoRepository, ISubmitCaseRecordRepository submitCaseRecordRepository
             , ISubmitCaseTotalRepository submitCaseTotalRepository, ISendCaseInfoRepository sendCaseInfoRepository
             , ISupplyCaseInfoSendRepository supplyCaseInfoSendRepository, IRevokeCaseInfoRepository revokeCaseInfoRepository
-            , IRemindCaseInfoRepository remindCaseInfoRepository, IGetKnowledgeInfoSendRepository getKnowledgeInfoSendRepository)
+            , IRemindCaseInfoRepository remindCaseInfoRepository, IGetKnowledgeInfoSendRepository getKnowledgeInfoSendRepository
+            , IGetKnowledgeInfoUpdateRepository getKnowledgeInfoUpdateRepository)
         {
             _mediator = mediator;
             _logger = logger;
@@ -101,6 +103,7 @@ namespace Sharing.Api.Controllers
             _revokeCaseInfoRepository = revokeCaseInfoRepository;
             _remindCaseInfoRepository = remindCaseInfoRepository;
             _getKnowledgeInfoSendRepository = getKnowledgeInfoSendRepository;
+            _getKnowledgeInfoUpdateRepository = getKnowledgeInfoUpdateRepository;
         }
         #endregion
 
@@ -673,7 +676,7 @@ namespace Sharing.Api.Controllers
 
         #endregion
 
-
+        #region 协同-第四批次-知识库
         /// <summary>
         /// 知识库上报
         /// </summary>
@@ -692,5 +695,27 @@ namespace Sharing.Api.Controllers
             //信息上报
             await _mediator.Publish(new GetKnowledgeInfoSendNotification(data));
         }
+
+        /// <summary>
+        /// 知识库变更
+        /// </summary>
+        /// <param name="dto"></param>
+        /// <returns></returns>
+        [NonAction]
+        //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineKnowledgeInfoUpdate)]
+        public async Task GetKnowledgeInfoUpdate(GetKnowledgeInfoUpdateInfo dto)
+        {
+            var data = _mapper.Map<GetKnowledgeInfoUpdate>(dto);
+
+            //将上报信息写入本地库
+            var id = await IGetKnowledgeInfoUpdateRepository.AddAsync(data);
+
+            data.Id = id;
+            //信息上报
+            await _mediator.Publish(new GetKnowledgeInfoUpdateNotification(data));
+        } 
+
+
+        #endregion
     }
 }