|
@@ -26,20 +26,7 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
{
|
|
|
#region 注入
|
|
|
private readonly IMapper _mapper;
|
|
|
- private readonly ICapPublisher _capPublisher;
|
|
|
private readonly IMediator _mediator;
|
|
|
- private readonly IRepository<DsReceiveCaseInfo> _receiveCaseInfoRepository;
|
|
|
- private readonly IRepository<DsGetCaseBackResult> _getCaseBackResultRepository;
|
|
|
- private readonly IRepository<DsDelayCaseResult> _delayCaseResultRepository;
|
|
|
- private readonly IRepository<DsSupplyCaseInfo> _supplyCaseInfoRepository;
|
|
|
- private readonly IRepository<DsRevokeCaseInfo> _revokeCaseInfoRepository;
|
|
|
- private readonly IRepository<DsRemindCaseInfo> _remindCaseInfoRepository;
|
|
|
- private readonly IRepository<DsSendWarnInfo> _sendWarnInfoRepository;
|
|
|
- private readonly IRepository<DsSendSuperviseInfo> _sendSuperviseInfoRepository;
|
|
|
- private readonly IRepository<DsScreenCaseResultReceive> _screenCaseResultReceiveRepository;
|
|
|
- private readonly IRepository<DsSendCaseEvlResult> _sendCaseEvlResultRepository;
|
|
|
- private readonly IRepository<DsGetCaseReultSend> _getCaseReultSendRepository;
|
|
|
- private readonly IRepository<DsGetVisitInfoSend> _getVisitInfoSendRepository;
|
|
|
private readonly IRepository<DsFormEnvironMent> _formEnvironMentRepository;
|
|
|
private readonly IRepository<DsFormTraffic> _formTrafficRepository;
|
|
|
private readonly IRepository<DsFormExpressWay> _formExpressWayRepository;
|
|
@@ -55,27 +42,14 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
private readonly IRepository<DsSendCaseInfo> _sendCaseInfoRepository;
|
|
|
private readonly IRepository<DsGetCaseBackApply> _getCaseBackApplyRepository;
|
|
|
private readonly IChannelConfigurationManager _channelConfigurationManager;
|
|
|
- private readonly IHttpClientFactory _httpClientFactory;
|
|
|
+ private readonly IRepository<DsReceiveProvinceData> _dsReceiveProvinceDataRepository;
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
///
|
|
|
/// </summary>
|
|
|
/// <param name="mapper"></param>
|
|
|
- /// <param name="capPublisher"></param>
|
|
|
/// <param name="mediator"></param>
|
|
|
- /// <param name="receiveCaseInfoRepository"></param>
|
|
|
- /// <param name="getCaseBackResultRepository"></param>
|
|
|
- /// <param name="delayCaseResultRepository"></param>
|
|
|
- /// <param name="supplyCaseInfoRepository"></param>
|
|
|
- /// <param name="revokeCaseInfoRepository"></param>
|
|
|
- /// <param name="remindCaseInfoRepository"></param>
|
|
|
- /// <param name="sendWarnInfoRepository"></param>
|
|
|
- /// <param name="sendSuperviseInfoRepository"></param>
|
|
|
- /// <param name="screenCaseResultReceiveRepository"></param>
|
|
|
- /// <param name="sendCaseEvlResultRepository"></param>
|
|
|
- /// <param name="getCaseReultSendRepository"></param>
|
|
|
- /// <param name="getVisitInfoSendRepository"></param>
|
|
|
/// <param name="formEnvironMentRepository"></param>
|
|
|
/// <param name="formTrafficRepository"></param>
|
|
|
/// <param name="formExpressWayRepository"></param>
|
|
@@ -91,21 +65,9 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
/// <param name="sendCaseInfoRepository"></param>
|
|
|
/// <param name="getCaseBackApplyRepository"></param>
|
|
|
/// <param name="channelConfigurationManager"></param>
|
|
|
+ /// <param name="dsReceiveProvinceDataRepository"></param>
|
|
|
public ProvinceController(IMapper mapper,
|
|
|
- ICapPublisher capPublisher,
|
|
|
IMediator mediator,
|
|
|
- IRepository<DsReceiveCaseInfo> receiveCaseInfoRepository,
|
|
|
- IRepository<DsGetCaseBackResult> getCaseBackResultRepository,
|
|
|
- IRepository<DsDelayCaseResult> delayCaseResultRepository,
|
|
|
- IRepository<DsSupplyCaseInfo> supplyCaseInfoRepository,
|
|
|
- IRepository<DsRevokeCaseInfo> revokeCaseInfoRepository,
|
|
|
- IRepository<DsRemindCaseInfo> remindCaseInfoRepository,
|
|
|
- IRepository<DsSendWarnInfo> sendWarnInfoRepository,
|
|
|
- IRepository<DsSendSuperviseInfo> sendSuperviseInfoRepository,
|
|
|
- IRepository<DsScreenCaseResultReceive> screenCaseResultReceiveRepository,
|
|
|
- IRepository<DsSendCaseEvlResult> sendCaseEvlResultRepository,
|
|
|
- IRepository<DsGetCaseReultSend> getCaseReultSendRepository,
|
|
|
- IRepository<DsGetVisitInfoSend> getVisitInfoSendRepository,
|
|
|
IRepository<DsFormEnvironMent> formEnvironMentRepository,
|
|
|
IRepository<DsFormTraffic> formTrafficRepository,
|
|
|
IRepository<DsFormExpressWay> formExpressWayRepository,
|
|
@@ -121,23 +83,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
IRepository<DsSendCaseInfo> sendCaseInfoRepository,
|
|
|
IRepository<DsGetCaseBackApply> getCaseBackApplyRepository,
|
|
|
IChannelConfigurationManager channelConfigurationManager,
|
|
|
- IHttpClientFactory httpClientFactory)
|
|
|
+ IRepository<DsReceiveProvinceData> dsReceiveProvinceDataRepository)
|
|
|
{
|
|
|
_mapper = mapper;
|
|
|
- _capPublisher = capPublisher;
|
|
|
_mediator = mediator;
|
|
|
- _receiveCaseInfoRepository = receiveCaseInfoRepository;
|
|
|
- _getCaseBackResultRepository = getCaseBackResultRepository;
|
|
|
- _delayCaseResultRepository = delayCaseResultRepository;
|
|
|
- _supplyCaseInfoRepository = supplyCaseInfoRepository;
|
|
|
- _revokeCaseInfoRepository = revokeCaseInfoRepository;
|
|
|
- _remindCaseInfoRepository = remindCaseInfoRepository;
|
|
|
- _sendWarnInfoRepository = sendWarnInfoRepository;
|
|
|
- _sendSuperviseInfoRepository = sendSuperviseInfoRepository;
|
|
|
- _screenCaseResultReceiveRepository = screenCaseResultReceiveRepository;
|
|
|
- _sendCaseEvlResultRepository = sendCaseEvlResultRepository;
|
|
|
- _getCaseReultSendRepository = getCaseReultSendRepository;
|
|
|
- _getVisitInfoSendRepository = getVisitInfoSendRepository;
|
|
|
_formEnvironMentRepository = formEnvironMentRepository;
|
|
|
_formTrafficRepository = formTrafficRepository;
|
|
|
_formExpressWayRepository = formExpressWayRepository;
|
|
@@ -153,7 +102,7 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
_sendCaseInfoRepository = sendCaseInfoRepository;
|
|
|
_getCaseBackApplyRepository = getCaseBackApplyRepository;
|
|
|
_channelConfigurationManager = channelConfigurationManager;
|
|
|
- _httpClientFactory = httpClientFactory;
|
|
|
+ _dsReceiveProvinceDataRepository = dsReceiveProvinceDataRepository;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
@@ -178,10 +127,8 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsReceiveCaseInfo>(receiveCaseInfo.paras);
|
|
|
-
|
|
|
- //添加数据
|
|
|
- var id = await _receiveCaseInfoRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var dto = receiveCaseInfo.paras;
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "receive_case_info", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
//处理组装数据,推送数据
|
|
|
var data = _mapper.Map<AddOrderDto>(dto);
|
|
@@ -252,9 +199,6 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
var result = await _mediator.Send(new ReceiveOrderNotify { AddOrderDto = data }, HttpContext.RequestAborted);
|
|
|
if (result != null && !string.IsNullOrEmpty(result.Id))
|
|
|
{
|
|
|
- dto.Id = id;
|
|
|
- dto.OrderId = result.Id;
|
|
|
- await _receiveCaseInfoRepository.UpdateAsync(dto, HttpContext.RequestAborted);
|
|
|
return OpenResponse.Ok(Reponse.Success("您已成功提交数据!"));
|
|
|
}
|
|
|
else
|
|
@@ -283,14 +227,14 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsGetCaseBackResult>(receiveBackResult.paras);
|
|
|
+ var dto = receiveBackResult.paras;
|
|
|
|
|
|
var data = await _getCaseBackApplyRepository.GetAsync(p => p.CaseSerial == dto.CaseSerial, HttpContext.RequestAborted);
|
|
|
if (data == null)
|
|
|
return OpenResponse.Ok(Reponse.Failed("接口调用失败!"));
|
|
|
|
|
|
//添加数据
|
|
|
- var id = await _getCaseBackResultRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "get_case_back_result", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -300,7 +244,7 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
{
|
|
|
Id = data.OrderSendBackId,
|
|
|
Reason = dto.BackReason,
|
|
|
- Result = dto.Result == true ? 1 : 0
|
|
|
+ Result = dto.Result == "1" ? 1 : 0
|
|
|
}
|
|
|
}, HttpContext.RequestAborted);
|
|
|
return OpenResponse.Ok(Reponse.Success("您已成功提交数据!"));
|
|
@@ -327,11 +271,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsSendSuperviseInfo>(receiveSendSuperviseInfo.paras);
|
|
|
+ var dto = receiveSendSuperviseInfo.paras;
|
|
|
|
|
|
//添加数据
|
|
|
- var id = await _sendSuperviseInfoRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
-
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "send_supervise_info", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
|
//向业务系统推送消息
|
|
@@ -361,10 +304,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsRemindCaseInfo>(receiveRemindCaseInfo.paras);
|
|
|
- dto.Direction = "2";
|
|
|
+ var dto = receiveRemindCaseInfo.paras;
|
|
|
//添加数据
|
|
|
- var id = await _remindCaseInfoRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "remind_case_info", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
+ // var id = await _remindCaseInfoRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -395,10 +338,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsScreenCaseResultReceive>(receiveScreenCaseResultReceive.paras);
|
|
|
+ var dto = receiveScreenCaseResultReceive.paras;
|
|
|
|
|
|
//添加数据
|
|
|
- var id = await _screenCaseResultReceiveRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "screen_case_result_receive", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -428,10 +371,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsDelayCaseResult>(receiveDelayCaseResult.paras);
|
|
|
+ var dto = receiveDelayCaseResult.paras;
|
|
|
|
|
|
//添加数据
|
|
|
- var id = await _delayCaseResultRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "delay_case_result_receive", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -461,11 +404,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsSupplyCaseInfo>(receiveSupplyCaseInfo.paras);
|
|
|
+ var dto = receiveSupplyCaseInfo.paras;
|
|
|
|
|
|
//添加数据
|
|
|
- var id = await _supplyCaseInfoRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
-
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "supply_case_info_receive", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -496,10 +438,9 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsRevokeCaseInfo>(receiveRevokeCaseInfo.paras);
|
|
|
- dto.Direction = "2";
|
|
|
+ var dto = receiveRevokeCaseInfo.paras;
|
|
|
//添加数据
|
|
|
- var id = await _revokeCaseInfoRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "revoke_case_info", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -529,10 +470,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsSendWarnInfo>(receiveSendWarnInfo.paras);
|
|
|
+ var dto =receiveSendWarnInfo.paras;
|
|
|
|
|
|
//添加数据
|
|
|
- var id = await _sendWarnInfoRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, null, "send_warn_info", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -562,10 +503,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsSendCaseEvlResult>(receiveSendCaseEvlResult.paras);
|
|
|
+ var dto = receiveSendCaseEvlResult.paras;
|
|
|
|
|
|
//添加数据
|
|
|
- var id = await _sendCaseEvlResultRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, null, "send_case_evl_result", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -595,10 +536,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsGetCaseReultSend>(receiveGetCaseReultSend.paras);
|
|
|
+ var dto =receiveGetCaseReultSend.paras;
|
|
|
|
|
|
//添加数据
|
|
|
- var id = await _getCaseReultSendRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "get_case_result_send", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -637,10 +578,10 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
//转换数据
|
|
|
- var dto = _mapper.Map<DsGetVisitInfoSend>(receiveGetVisitInfoSend.paras);
|
|
|
+ var dto = receiveGetVisitInfoSend.paras;
|
|
|
|
|
|
//添加数据
|
|
|
- var id = await _getVisitInfoSendRepository.AddAsync(dto, HttpContext.RequestAborted);
|
|
|
+ var id = await InitReceiveProvinceData(dto.CaseSerial, dto.CliengGuid, "get_visit_info_send", System.Text.Json.JsonSerializer.Serialize(dto));
|
|
|
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
@@ -671,18 +612,8 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
return OpenResponse.Ok(Reponse.Failed(strResult));
|
|
|
|
|
|
var data = receiveCaseExtendsRequest.paras;
|
|
|
-
|
|
|
- //扩展主表信息
|
|
|
- DsReceiveCaseExtends receiveCaseExtends = new()
|
|
|
- {
|
|
|
- CaseSerial = data.CaseSerial,
|
|
|
- FormType = data.FormType,
|
|
|
- SyncState = "1",
|
|
|
- Direction = "2"
|
|
|
- };
|
|
|
- var id = await _receiveCaseExtendsRepository.AddAsync(receiveCaseExtends, HttpContext.RequestAborted);
|
|
|
- if (!string.IsNullOrEmpty(id))
|
|
|
- return OpenResponse.Ok(Reponse.Failed("数据提交失败"));
|
|
|
+ //添加数据
|
|
|
+ var id = await InitReceiveProvinceData(data.CaseSerial, null, "receive_case_extends", System.Text.Json.JsonSerializer.Serialize(data));
|
|
|
|
|
|
OrderExtensionDto orderExtension = new()
|
|
|
{
|
|
@@ -694,92 +625,52 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
{
|
|
|
case "yl"://医疗表单
|
|
|
//转换数据
|
|
|
- var dtoyl = _mapper.Map<DsFormMedical>(data.FormMedical);
|
|
|
- dtoyl.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formMedicalRepository.AddAsync(dtoyl, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtoyl);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormMedical);
|
|
|
orderExtension.OrderType = "医疗服务中心受理单";
|
|
|
break;
|
|
|
case "zwfw"://四川政务服务网技术工单
|
|
|
//转换数据
|
|
|
- var dtozwfw = _mapper.Map<DsFormNetWorktec>(data.FormNetWorktec);
|
|
|
- dtozwfw.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formNetWorktecRepository.AddAsync(dtozwfw, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtozwfw);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormNetWorktec);
|
|
|
orderExtension.OrderType = "四川政务服务网技术中心受理单";
|
|
|
break;
|
|
|
case "th"://电视购物及商铺购买退换货工单
|
|
|
//转换数据
|
|
|
- var dtoth = _mapper.Map<DsFormReturnexChange>(data.FormReturnexChange);
|
|
|
- dtoth.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formReturnexChangeRepository.AddAsync(dtoth, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtoth);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormReturnexChange);
|
|
|
orderExtension.OrderType = "电视购物及商铺购买退换货中心受理单";
|
|
|
break;
|
|
|
case "gsgl"://高速公路工单
|
|
|
//转换数据
|
|
|
- var dtogsgl = _mapper.Map<DsFormExpressWay>(data.FormExpressWay);
|
|
|
- dtogsgl.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formExpressWayRepository.AddAsync(dtogsgl, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtogsgl);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormExpressWay);
|
|
|
orderExtension.OrderType = "高速公路投诉中心受理单";
|
|
|
break;
|
|
|
case "xjgg"://电视台虚假广告工单
|
|
|
//转换数据
|
|
|
- var dtoxjgg = _mapper.Map<DsFormShamPub>(data.FormShamPub);
|
|
|
- dtoxjgg.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formShamPubRepository.AddAsync(dtoxjgg, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtoxjgg);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormShamPub);
|
|
|
orderExtension.OrderType = "电视台虚假广告中心受理单";
|
|
|
break;
|
|
|
case "swfwsq"://12366热线诉求交办
|
|
|
//转换数据
|
|
|
- var dtoswfwsq = _mapper.Map<DsFormTaxationComplaint>(data.FormTaxationComplaint);
|
|
|
- dtoswfwsq.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formTaxationComplaintRepository.AddAsync(dtoswfwsq, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtoswfwsq);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormTaxationComplaint);
|
|
|
orderExtension.OrderType = "四川省12366热线诉求交办单";
|
|
|
break;
|
|
|
case "swfwzx"://12366热线咨询交办
|
|
|
//转换数据
|
|
|
- var dtoswfwzx = _mapper.Map<DsFormTaxationConsulting>(data.FormTaxationConsulting);
|
|
|
- dtoswfwzx.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formTaxationConsultingRepository.AddAsync(dtoswfwzx, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtoswfwzx);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormTaxationConsulting);
|
|
|
orderExtension.OrderType = "四川省12366热线咨询交办单";
|
|
|
break;
|
|
|
case "jtfwjd"://12328服务监督
|
|
|
//转换数据
|
|
|
- var dtojtfwjd = _mapper.Map<DsFormTraffic>(data.FormTraffic);
|
|
|
- dtojtfwjd.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formTrafficRepository.AddAsync(dtojtfwjd, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtojtfwjd);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormTraffic);
|
|
|
orderExtension.OrderType = "12328服务监督中心受理单";
|
|
|
break;
|
|
|
case "yzxf"://邮政业消费者申诉
|
|
|
//转换数据
|
|
|
- var dtoyzxf = _mapper.Map<DsFormPost>(data.FormPost);
|
|
|
- dtoyzxf.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formPostRepository.AddAsync(dtoyzxf, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtoyzxf);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormPost);
|
|
|
orderExtension.OrderType = "邮政业消费者申诉受理单";
|
|
|
break;
|
|
|
case "hbjb"://环保举报业务
|
|
|
//转换数据
|
|
|
- var dtohbjb = _mapper.Map<DsFormEnvironMent>(data.FormEnvironMent);
|
|
|
- dtohbjb.RCEId = id;
|
|
|
- //添加数据
|
|
|
- await _formEnvironMentRepository.AddAsync(dtohbjb, HttpContext.RequestAborted);
|
|
|
- orderExtension = _mapper.Map<OrderExtensionDto>(dtohbjb);
|
|
|
+ orderExtension = _mapper.Map<OrderExtensionDto>(data.FormEnvironMent);
|
|
|
orderExtension.OrderType = "环保举报业务受理单";
|
|
|
break;
|
|
|
case "scjgj"://12315个性化表单
|
|
@@ -787,7 +678,7 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
if (!string.IsNullOrEmpty(id))
|
|
|
{
|
|
|
//向业务系统推送消息
|
|
@@ -870,7 +761,7 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
public async Task<OpenResponse> GetCaseMaterialInfotest([FromForm] string @params, List<IFormFile> files)
|
|
|
{
|
|
|
return OpenResponse.Ok(Reponse.Failed("数据解析失败"));
|
|
|
- // return OpenResponse.Ok("ok");
|
|
|
+ // return OpenResponse.Ok("ok");
|
|
|
//var businessFile = _channelConfigurationManager.GetConfigurationBusinessFile();
|
|
|
|
|
|
//string result = "";
|
|
@@ -972,6 +863,26 @@ namespace Hotline.Api.Controllers.DataSharing
|
|
|
}
|
|
|
|
|
|
#region 私有方法
|
|
|
+ /// <summary>
|
|
|
+ /// 将数据写入表格
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="CaseSerial">工单编号</param>
|
|
|
+ /// <param name="CliengGuid">材料标识</param>
|
|
|
+ /// <param name="ServiceInterface">接口名称</param>
|
|
|
+ /// <param name="ReceiveData">数据</param>
|
|
|
+ /// <returns></returns>
|
|
|
+ public async Task<string> InitReceiveProvinceData(string CaseSerial, string CliengGuid, string ServiceInterface, string ReceiveData)
|
|
|
+ {
|
|
|
+ DsReceiveProvinceData dsReceive = new DsReceiveProvinceData()
|
|
|
+ {
|
|
|
+ CaseSerial = CaseSerial,
|
|
|
+ CliengGuid = CliengGuid,
|
|
|
+ ServiceInterface = ServiceInterface,
|
|
|
+ ReceiveData = ReceiveData
|
|
|
+ };
|
|
|
+ return await _dsReceiveProvinceDataRepository.AddAsync(dsReceive, HttpContext.RequestAborted);
|
|
|
+ }
|
|
|
+
|
|
|
/// <summary>
|
|
|
/// 将文件流上传到附件服务器
|
|
|
/// </summary>
|