|
@@ -1,13 +1,12 @@
|
|
|
-using DotNetCore.CAP;
|
|
|
-using Hotline.DataSharing;
|
|
|
+using Hotline.DataSharing;
|
|
|
using Hotline.DataSharing.Province;
|
|
|
-using Hotline.DataSharing.Province.Extend;
|
|
|
using Hotline.DataSharing.Province.Notifications;
|
|
|
using Hotline.DataSharing.Province.XieTong.Receive;
|
|
|
using Hotline.DataSharing.Province.XieTong.Send;
|
|
|
using Hotline.Share.Dtos.DataSharing;
|
|
|
using Hotline.Share.Dtos.DataSharing.Province;
|
|
|
using Hotline.Share.Dtos.DataSharing.Province.XieTong.Receive;
|
|
|
+using Hotline.Share.Dtos.File;
|
|
|
using Hotline.Share.Dtos.Order;
|
|
|
using Hotline.Share.Enums.Order;
|
|
|
using MapsterMapper;
|
|
@@ -27,40 +26,17 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
#region 注入
|
|
|
private readonly IMapper _mapper;
|
|
|
private readonly IMediator _mediator;
|
|
|
- private readonly IRepository<DsFormEnvironMent> _formEnvironMentRepository;
|
|
|
- private readonly IRepository<DsFormTraffic> _formTrafficRepository;
|
|
|
- private readonly IRepository<DsFormExpressWay> _formExpressWayRepository;
|
|
|
- private readonly IRepository<DsFormMedical> _formMedicalRepository;
|
|
|
- private readonly IRepository<DsFormNetWorktec> _formNetWorktecRepository;
|
|
|
- private readonly IRepository<DsFormPost> _formPostRepository;
|
|
|
- private readonly IRepository<DsFormReturnexChange> _formReturnexChangeRepository;
|
|
|
- private readonly IRepository<DsFormShamPub> _formShamPubRepository;
|
|
|
- private readonly IRepository<DsFormTaxationComplaint> _formTaxationComplaintRepository;
|
|
|
- private readonly IRepository<DsFormTaxationConsulting> _formTaxationConsultingRepository;
|
|
|
- private readonly IRepository<DsReceiveCaseExtends> _receiveCaseExtendsRepository;
|
|
|
private readonly IRepository<DsGetCaseMaterialInfo> _getCaseMaterialInfoRepository;
|
|
|
private readonly IRepository<DsSendCaseInfo> _sendCaseInfoRepository;
|
|
|
private readonly IRepository<DsGetCaseBackApply> _getCaseBackApplyRepository;
|
|
|
private readonly IChannelConfigurationManager _channelConfigurationManager;
|
|
|
private readonly IRepository<DsReceiveProvinceData> _dsReceiveProvinceDataRepository;
|
|
|
|
|
|
-
|
|
|
/// <summary>
|
|
|
///
|
|
|
/// </summary>
|
|
|
/// <param name="mapper"></param>
|
|
|
/// <param name="mediator"></param>
|
|
|
- /// <param name="formEnvironMentRepository"></param>
|
|
|
- /// <param name="formTrafficRepository"></param>
|
|
|
- /// <param name="formExpressWayRepository"></param>
|
|
|
- /// <param name="formMedicalRepository"></param>
|
|
|
- /// <param name="formNetWorktecRepository"></param>
|
|
|
- /// <param name="formPostRepository"></param>
|
|
|
- /// <param name="formReturnexChangeRepository"></param>
|
|
|
- /// <param name="formShamPubRepository"></param>
|
|
|
- /// <param name="formTaxationComplaintRepository"></param>
|
|
|
- /// <param name="formTaxationConsultingRepository"></param>
|
|
|
- /// <param name="receiveCaseExtendsRepository"></param>
|
|
|
/// <param name="getCaseMaterialInfoRepository"></param>
|
|
|
/// <param name="sendCaseInfoRepository"></param>
|
|
|
/// <param name="getCaseBackApplyRepository"></param>
|
|
@@ -68,17 +44,6 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
/// <param name="dsReceiveProvinceDataRepository"></param>
|
|
|
public ProvinceController(IMapper mapper,
|
|
|
IMediator mediator,
|
|
|
- IRepository<DsFormEnvironMent> formEnvironMentRepository,
|
|
|
- IRepository<DsFormTraffic> formTrafficRepository,
|
|
|
- IRepository<DsFormExpressWay> formExpressWayRepository,
|
|
|
- IRepository<DsFormMedical> formMedicalRepository,
|
|
|
- IRepository<DsFormNetWorktec> formNetWorktecRepository,
|
|
|
- IRepository<DsFormPost> formPostRepository,
|
|
|
- IRepository<DsFormReturnexChange> formReturnexChangeRepository,
|
|
|
- IRepository<DsFormShamPub> formShamPubRepository,
|
|
|
- IRepository<DsFormTaxationComplaint> formTaxationComplaintRepository,
|
|
|
- IRepository<DsFormTaxationConsulting> formTaxationConsultingRepository,
|
|
|
- IRepository<DsReceiveCaseExtends> receiveCaseExtendsRepository,
|
|
|
IRepository<DsGetCaseMaterialInfo> getCaseMaterialInfoRepository,
|
|
|
IRepository<DsSendCaseInfo> sendCaseInfoRepository,
|
|
|
IRepository<DsGetCaseBackApply> getCaseBackApplyRepository,
|
|
@@ -87,17 +52,6 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
{
|
|
|
_mapper = mapper;
|
|
|
_mediator = mediator;
|
|
|
- _formEnvironMentRepository = formEnvironMentRepository;
|
|
|
- _formTrafficRepository = formTrafficRepository;
|
|
|
- _formExpressWayRepository = formExpressWayRepository;
|
|
|
- _formMedicalRepository = formMedicalRepository;
|
|
|
- _formNetWorktecRepository = formNetWorktecRepository;
|
|
|
- _formPostRepository = formPostRepository;
|
|
|
- _formReturnexChangeRepository = formReturnexChangeRepository;
|
|
|
- _formShamPubRepository = formShamPubRepository;
|
|
|
- _formTaxationComplaintRepository = formTaxationComplaintRepository;
|
|
|
- _formTaxationConsultingRepository = formTaxationConsultingRepository;
|
|
|
- _receiveCaseExtendsRepository = receiveCaseExtendsRepository;
|
|
|
_getCaseMaterialInfoRepository = getCaseMaterialInfoRepository;
|
|
|
_sendCaseInfoRepository = sendCaseInfoRepository;
|
|
|
_getCaseBackApplyRepository = getCaseBackApplyRepository;
|
|
@@ -470,7 +424,7 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto =receiveSendWarnInfo.paras;
|
|
|
+ var dto = receiveSendWarnInfo.paras;
|
|
|
|
|
|
//添加数据
|
|
|
var id = await InitReceiveProvinceData(dto.CaseSerial, null, "send_warn_info", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
@@ -536,7 +490,7 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto =receiveGetCaseReultSend.paras;
|
|
|
+ var dto = receiveGetCaseReultSend.paras;
|
|
|
|
|
|
//添加数据
|
|
|
var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "get_case_result_send", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
@@ -678,7 +632,7 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
|
//向业务系统推送消息
|
|
@@ -864,7 +818,31 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
|
|
|
#region 私有方法
|
|
|
|
|
|
- // public async Task<List<FileDto>>
|
|
|
+ /// <summary>
|
|
|
+ /// 根据附件Id,工单编号查询所有附件
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="CliengGuid">材料标识ID</param>
|
|
|
+ /// <param name="CaseSerial">工单编号</param>
|
|
|
+ /// <param name="Classify">材料分类</param>
|
|
|
+ /// <returns></returns>
|
|
|
+ private async Task<List<FileDto>> GetFileData(string CliengGuid, string CaseSerial, string Classify)
|
|
|
+ {
|
|
|
+ var list = await _getCaseMaterialInfoRepository.Queryable().Where(p => p.CliengGuid == CliengGuid && p.CaseSerial == CaseSerial).ToListAsync();
|
|
|
+
|
|
|
+ List<FileDto> fileDtos = new List<FileDto>();
|
|
|
+ foreach (var item in list)
|
|
|
+ {
|
|
|
+ fileDtos.Add(new FileDto()
|
|
|
+ {
|
|
|
+ Name = item.FileName,
|
|
|
+ Type = item.Type,
|
|
|
+ Classify = Classify,
|
|
|
+ Additions = item.Additions,
|
|
|
+ Path = item.Path
|
|
|
+ });
|
|
|
+ }
|
|
|
+ return fileDtos;
|
|
|
+ }
|
|
|
|
|
|
/// <summary>
|
|
|
/// 将数据写入表格
|