|
|
|
@ -25,6 +25,7 @@ using Myshipping.Application.Helper;
|
|
|
|
|
using Myshipping.Application.Service.BookingOrder;
|
|
|
|
|
using Myshipping.Application.Service.BookingSlot.Dto;
|
|
|
|
|
using Myshipping.Application.Service.ExpressDelivery.Dto.SF;
|
|
|
|
|
using Myshipping.Application.Service.TaskManagePlat;
|
|
|
|
|
using Myshipping.Application.Service.TaskManagePlat.Interface;
|
|
|
|
|
using Myshipping.Core;
|
|
|
|
|
using Myshipping.Core.Const;
|
|
|
|
@ -136,7 +137,8 @@ namespace Myshipping.Application
|
|
|
|
|
private readonly SqlSugarRepository<TaskPOLContainerNotPickUpInfo> _taskPOLContainerNotPickUpInfoRepository;
|
|
|
|
|
|
|
|
|
|
private readonly SqlSugarRepository<TaskFlowTenant> _taskFlowTenant;
|
|
|
|
|
|
|
|
|
|
private readonly SqlSugarRepository<TaskVerifyCopyBL> _taskVerifyCopyBLRepository;
|
|
|
|
|
private readonly SqlSugarRepository<TaskVerifyCopyBLCtn> _taskVerifyCopyBLCtnRepository;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private readonly IDjyWebsiteAccountConfigService _webAccountConfig;
|
|
|
|
@ -157,6 +159,7 @@ namespace Myshipping.Application
|
|
|
|
|
private readonly INamedServiceProvider<IBookingLabelService> _namedBookingLabelServiceServiceProvider;
|
|
|
|
|
private readonly INamedServiceProvider<ITaskManagePODDischargeGateoutFullService> _namedPODDischargeGateoutFullProvider;
|
|
|
|
|
private readonly INamedServiceProvider<ITaskManageVGMService> _namedVGMServiceProvider;
|
|
|
|
|
private readonly INamedServiceProvider<ITaskVerifyCopyBLService> _namedtaskVerifyCopyBLServiceProvider;
|
|
|
|
|
|
|
|
|
|
private readonly IBookingValueAddedService _bookingValueAddedService;
|
|
|
|
|
|
|
|
|
@ -215,6 +218,8 @@ namespace Myshipping.Application
|
|
|
|
|
SqlSugarRepository<TaskTransPlanHasChangeInfo> taskTransPlanHasChangeInfoRepository,
|
|
|
|
|
SqlSugarRepository<TaskTransPlanHasChangeDetailInfo> taskTransPlanHasChangeDetailInfoRepository,
|
|
|
|
|
SqlSugarRepository<TaskPOLContainerNotPickUpInfo> taskPOLContainerNotPickUpInfoRepository,
|
|
|
|
|
SqlSugarRepository<TaskVerifyCopyBL> taskVerifyCopyBLRepository,
|
|
|
|
|
SqlSugarRepository<TaskVerifyCopyBLCtn> taskVerifyCopyBLCtnRepository,
|
|
|
|
|
INamedServiceProvider<IBookingOrderService> namedBookingOrderServiceProvider,
|
|
|
|
|
IDjyWebsiteAccountConfigService webAccountConfig,
|
|
|
|
|
ISysCacheService cache,
|
|
|
|
@ -232,6 +237,7 @@ namespace Myshipping.Application
|
|
|
|
|
INamedServiceProvider<IBookingLabelService> namedBookingLabelServiceServiceProvider,
|
|
|
|
|
INamedServiceProvider<ITaskManagePODDischargeGateoutFullService> namedPODDischargeGateoutFullProvider,
|
|
|
|
|
INamedServiceProvider<ITaskManageVGMService> namedVGMServiceProvider,
|
|
|
|
|
INamedServiceProvider<ITaskVerifyCopyBLService> namedtaskVerifyCopyBLServiceProvider,
|
|
|
|
|
ILogger<BookingOrderService> logger, BookingOrderAutoService bookingOrderAuto,
|
|
|
|
|
SqlSugarRepository<TaskFlowTenant> taskFlowTenant)
|
|
|
|
|
{
|
|
|
|
@ -308,6 +314,10 @@ namespace Myshipping.Application
|
|
|
|
|
_namedBookingLabelServiceServiceProvider = namedBookingLabelServiceServiceProvider;
|
|
|
|
|
_namedPODDischargeGateoutFullProvider = namedPODDischargeGateoutFullProvider;
|
|
|
|
|
_namedVGMServiceProvider = namedVGMServiceProvider;
|
|
|
|
|
_taskVerifyCopyBLRepository = taskVerifyCopyBLRepository;
|
|
|
|
|
_taskVerifyCopyBLCtnRepository = taskVerifyCopyBLCtnRepository;
|
|
|
|
|
|
|
|
|
|
_namedtaskVerifyCopyBLServiceProvider = namedtaskVerifyCopyBLServiceProvider;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#region 创建任务
|
|
|
|
@ -556,6 +566,12 @@ namespace Myshipping.Application
|
|
|
|
|
|
|
|
|
|
fileCategory = TaskFileCategoryEnum.ADVISORY.ToString();
|
|
|
|
|
}
|
|
|
|
|
else if (TaskBaseTypeEnum.VERIFY_COPY.ToString() == taskInfo.TASK_BASE_TYPE)
|
|
|
|
|
{
|
|
|
|
|
attachFileType = "verifycopayfiles";
|
|
|
|
|
|
|
|
|
|
fileCategory = TaskFileCategoryEnum.VERIFY_COPY.ToString();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (info.Main.FileList == null)
|
|
|
|
|
{
|
|
|
|
@ -1915,6 +1931,75 @@ namespace Myshipping.Application
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region 验证副本入库
|
|
|
|
|
//验证副本入库
|
|
|
|
|
if (info.Main.TaskType == TaskBaseTypeEnum.VERIFY_COPY)
|
|
|
|
|
{
|
|
|
|
|
if (info.Main.VerifyCopyBL == null)
|
|
|
|
|
throw Oops.Oh($"任务类型={info.Main.TaskType.ToString()} VerifyCopyBL信息必传");
|
|
|
|
|
|
|
|
|
|
TaskVerifyCopyBL taskVerifyCopyBL = info.Main.VerifyCopyBL.Adapt<TaskVerifyCopyBL>();
|
|
|
|
|
|
|
|
|
|
taskVerifyCopyBL.PK_ID = IDGen.NextID().ToString();
|
|
|
|
|
taskVerifyCopyBL.TASK_ID = taskInfo.PK_ID;
|
|
|
|
|
|
|
|
|
|
taskVerifyCopyBL.CreatedTime = taskInfo.CreatedTime;
|
|
|
|
|
taskVerifyCopyBL.UpdatedTime = taskInfo.CreatedTime;
|
|
|
|
|
|
|
|
|
|
taskVerifyCopyBL.CreatedUserId = taskInfo.CreatedUserId;
|
|
|
|
|
taskVerifyCopyBL.CreatedUserName = taskInfo.CreatedUserName;
|
|
|
|
|
taskVerifyCopyBL.TenantId = taskInfo.TenantId;
|
|
|
|
|
taskVerifyCopyBL.TenantName = taskInfo.TenantName;
|
|
|
|
|
|
|
|
|
|
_taskVerifyCopyBLRepository.Insert(taskVerifyCopyBL);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//验证副本箱信息入库
|
|
|
|
|
if (info.Main.VerifyCopyBL.ContaList != null && info.Main.VerifyCopyBL.ContaList.Count > 0)
|
|
|
|
|
{
|
|
|
|
|
var ediCtnList = _cache.GetAllCodeCtn().GetAwaiter().GetResult();
|
|
|
|
|
|
|
|
|
|
info.Main.VerifyCopyBL.ContaList.ForEach(ctn =>
|
|
|
|
|
{
|
|
|
|
|
var contaInfo = ctn.Adapt<TaskVerifyCopyBLCtn>();
|
|
|
|
|
|
|
|
|
|
contaInfo.PK_ID = IDGen.NextID().ToString();
|
|
|
|
|
contaInfo.P_PKID = taskVerifyCopyBL.PK_ID;
|
|
|
|
|
|
|
|
|
|
contaInfo.CreatedTime = taskInfo.CreatedTime;
|
|
|
|
|
contaInfo.UpdatedTime = taskInfo.CreatedTime;
|
|
|
|
|
|
|
|
|
|
contaInfo.CreatedUserId = taskInfo.CreatedUserId;
|
|
|
|
|
contaInfo.CreatedUserName = taskInfo.CreatedUserName;
|
|
|
|
|
contaInfo.TenantId = taskInfo.TenantId;
|
|
|
|
|
contaInfo.TenantName = taskInfo.TenantName;
|
|
|
|
|
|
|
|
|
|
if (string.IsNullOrWhiteSpace(contaInfo.CTNCODE) && !string.IsNullOrWhiteSpace(contaInfo.CTNALL))
|
|
|
|
|
{
|
|
|
|
|
if (ediCtnList != null && ediCtnList.Count > 0)
|
|
|
|
|
{
|
|
|
|
|
var ctnCodeInfo = ediCtnList.FirstOrDefault(x => !string.IsNullOrWhiteSpace(x.Name)
|
|
|
|
|
&& x.Name.Equals(contaInfo.CTNALL, StringComparison.OrdinalIgnoreCase));
|
|
|
|
|
|
|
|
|
|
if (ctnCodeInfo != null)
|
|
|
|
|
{
|
|
|
|
|
contaInfo.CTNCODE = ctnCodeInfo.Code;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
_taskVerifyCopyBLCtnRepository.Insert(contaInfo);
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var siService = _namedtaskVerifyCopyBLServiceProvider
|
|
|
|
|
.GetService<ITransient>(nameof(TaskVerifyCopyBLService));
|
|
|
|
|
|
|
|
|
|
await siService.ProcessVerifyCopyBL(taskVerifyCopyBL.TASK_ID);
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region 黑名单
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|