|
@@ -47,6 +47,7 @@ namespace Sharing.Api.Controllers
|
|
|
private readonly IGetKnowledgeInfoSendRepository _getKnowledgeInfoSendRepository;
|
|
|
private readonly IGetKnowledgeInfoUpdateRepository _getKnowledgeInfoUpdateRepository;
|
|
|
private readonly IGetKnowledgeInfoAbandonRepository _getKnowledgeInfoAbandonRepository;
|
|
|
+ private readonly ISendRealTimeStatusRepository _sendRealTimeStatusRepository;
|
|
|
|
|
|
/// <summary>
|
|
|
///
|
|
@@ -71,6 +72,10 @@ namespace Sharing.Api.Controllers
|
|
|
/// <param name="supplyCaseInfoSendRepository"></param>
|
|
|
/// <param name="revokeCaseInfoRepository"></param>
|
|
|
/// <param name="remindCaseInfoRepository"></param>
|
|
|
+ /// <param name="getKnowledgeInfoSendRepository"></param>
|
|
|
+ /// <param name="getKnowledgeInfoUpdateRepository"></param>
|
|
|
+ /// <param name="getKnowledgeInfoAbandonRepository"></param>
|
|
|
+ /// <param name="sendRealTimeStatusRepository"></param>
|
|
|
public HotlineMessageReceiveController(IMediator mediator, ILogger<HotlineMsgReceiver> logger, IMapper mapper
|
|
|
, IGetCaseResultReceiveRepository getCaseResultReceiveRepository, IGetCaseProcessReceiveRepository getCaseProcessReceiveRepository
|
|
|
, IGetVisitInfoReceiveRepository getVisitInfoReceiveRepository, IGetCaseBackApplyRepository getCaseBackApplyRepository
|
|
@@ -81,7 +86,8 @@ namespace Sharing.Api.Controllers
|
|
|
, ISubmitCaseTotalRepository submitCaseTotalRepository, ISendCaseInfoRepository sendCaseInfoRepository
|
|
|
, ISupplyCaseInfoSendRepository supplyCaseInfoSendRepository, IRevokeCaseInfoRepository revokeCaseInfoRepository
|
|
|
, IRemindCaseInfoRepository remindCaseInfoRepository, IGetKnowledgeInfoSendRepository getKnowledgeInfoSendRepository
|
|
|
- , IGetKnowledgeInfoUpdateRepository getKnowledgeInfoUpdateRepository, IGetKnowledgeInfoAbandonRepository getKnowledgeInfoAbandonRepository)
|
|
|
+ , IGetKnowledgeInfoUpdateRepository getKnowledgeInfoUpdateRepository, IGetKnowledgeInfoAbandonRepository getKnowledgeInfoAbandonRepository
|
|
|
+ , ISendRealTimeStatusRepository sendRealTimeStatusRepository)
|
|
|
{
|
|
|
_mediator = mediator;
|
|
|
_logger = logger;
|
|
@@ -106,6 +112,7 @@ namespace Sharing.Api.Controllers
|
|
|
_getKnowledgeInfoSendRepository = getKnowledgeInfoSendRepository;
|
|
|
_getKnowledgeInfoUpdateRepository = getKnowledgeInfoUpdateRepository;
|
|
|
_getKnowledgeInfoAbandonRepository = getKnowledgeInfoAbandonRepository;
|
|
|
+ _sendRealTimeStatusRepository = sendRealTimeStatusRepository;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
@@ -736,10 +743,27 @@ namespace Sharing.Api.Controllers
|
|
|
data.Id = id;
|
|
|
//信息上报
|
|
|
await _mediator.Publish(new GetKnowledgeInfoAbandonNotification(data));
|
|
|
- }
|
|
|
+ }
|
|
|
#endregion
|
|
|
|
|
|
+ /// <summary>
|
|
|
+ /// 实时服务上报
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="dto"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ [NonAction]
|
|
|
+ //[CapSubscribe(Hotline.Share.Mq.EventNames.HotlineSendRealTimeStatus)]
|
|
|
+ public async Task SendRealTimeStatus(SendRealTimeStatusInfo dto)
|
|
|
+ {
|
|
|
+ var data = _mapper.Map<SendRealTimeStatus>(dto);
|
|
|
+
|
|
|
+ //将上报信息写入本地库
|
|
|
+ var id = await _sendRealTimeStatusRepository.AddAsync(data);
|
|
|
|
|
|
+ data.Id = id;
|
|
|
+ //信息上报
|
|
|
+ await _mediator.Publish(new SendRealTimeStatusNotification(data));
|
|
|
+ }
|
|
|
#endregion
|
|
|
}
|
|
|
}
|