|
|
|
|
@ -0,0 +1,125 @@
|
|
|
|
|
using DS.Module.Core;
|
|
|
|
|
using DS.Module.RedisModule;
|
|
|
|
|
using DS.Module.SqlSugar;
|
|
|
|
|
using DS.Module.UserModule;
|
|
|
|
|
using DS.WMS.Core.Code.Interface;
|
|
|
|
|
using DS.WMS.Core.Code.Method;
|
|
|
|
|
using DS.WMS.Core.Map.Interface;
|
|
|
|
|
using DS.WMS.Core.Map.Method;
|
|
|
|
|
using DS.WMS.Core.Sys.Interface;
|
|
|
|
|
using DS.WMS.Core.Sys.Method;
|
|
|
|
|
using DS.WMS.Core.TaskPlat.Dtos;
|
|
|
|
|
using DS.WMS.Core.TaskPlat.Entity;
|
|
|
|
|
using DS.WMS.Core.TaskPlat.Interface;
|
|
|
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
|
|
|
using SqlSugar;
|
|
|
|
|
using System;
|
|
|
|
|
using System.Collections.Generic;
|
|
|
|
|
using System.Linq;
|
|
|
|
|
using System.Text;
|
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
using Mapster;
|
|
|
|
|
using DS.Module.DjyServiceStatus;
|
|
|
|
|
using Microsoft.AspNetCore.Identity;
|
|
|
|
|
using DS.WMS.Core.Op.Interface;
|
|
|
|
|
using Masuit.Tools;
|
|
|
|
|
using DS.WMS.Core.Op.Dtos;
|
|
|
|
|
using DS.WMS.Core.Sys.Entity;
|
|
|
|
|
using HtmlAgilityPack;
|
|
|
|
|
using Microsoft.AspNetCore.Mvc;
|
|
|
|
|
using Amazon.Runtime.Internal.Util;
|
|
|
|
|
using Newtonsoft.Json;
|
|
|
|
|
using NLog;
|
|
|
|
|
using DS.Module.Core.Helpers;
|
|
|
|
|
using System.Text.Json.Nodes;
|
|
|
|
|
using LanguageExt.Pipes;
|
|
|
|
|
using DS.WMS.Core.Op.Entity;
|
|
|
|
|
using Org.BouncyCastle.Asn1.X9;
|
|
|
|
|
using DS.WMS.Core.Op.EDI;
|
|
|
|
|
using DS.WMS.Core.Sys.Dtos;
|
|
|
|
|
using DS.WMS.Core.Code.Dtos;
|
|
|
|
|
using DS.Module.Core.Data;
|
|
|
|
|
|
|
|
|
|
namespace DS.WMS.Core.TaskPlat.Method
|
|
|
|
|
{
|
|
|
|
|
public class TaskPOLContainerNotPickUpService : ITaskPOLContainerNotPickUpService
|
|
|
|
|
{
|
|
|
|
|
private readonly IServiceProvider _serviceProvider;
|
|
|
|
|
private readonly ISqlSugarClient db;
|
|
|
|
|
private readonly IUser user;
|
|
|
|
|
private readonly ISaasDbService saasService;
|
|
|
|
|
private readonly ISeaExportService _seaExportService;
|
|
|
|
|
private readonly IConfigService _configService;
|
|
|
|
|
private readonly IUserService _userService;
|
|
|
|
|
|
|
|
|
|
private static readonly NLog.Logger Logger = LogManager.GetCurrentClassLogger();
|
|
|
|
|
|
|
|
|
|
public TaskPOLContainerNotPickUpService(IServiceProvider serviceProvider)
|
|
|
|
|
{
|
|
|
|
|
_serviceProvider = serviceProvider;
|
|
|
|
|
db = _serviceProvider.GetRequiredService<ISqlSugarClient>();
|
|
|
|
|
user = _serviceProvider.GetRequiredService<IUser>();
|
|
|
|
|
saasService = _serviceProvider.GetRequiredService<ISaasDbService>();
|
|
|
|
|
_seaExportService = _serviceProvider.GetRequiredService<ISeaExportService>();
|
|
|
|
|
_configService = _serviceProvider.GetRequiredService<IConfigService>();
|
|
|
|
|
_userService = _serviceProvider.GetRequiredService<IUserService>();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#region 通过任务主键获取起运港未提箱详情
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 通过任务主键获取起运港未提箱详情
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="taskPKId">起运港未提箱任务主键</param>
|
|
|
|
|
/// <returns>返回回执</returns>
|
|
|
|
|
public async Task<DataResult<List<TaskPOLContainerNotPickUpShowDto>>> GetInfoByTaskId(long taskPKId)
|
|
|
|
|
{
|
|
|
|
|
List<TaskPOLContainerNotPickUpShowDto> list = new List<TaskPOLContainerNotPickUpShowDto>();
|
|
|
|
|
|
|
|
|
|
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
|
|
|
|
|
//任务不考虑OrgId,这里去掉
|
|
|
|
|
tenantDb.QueryFilter.Clear<IOrgId>();
|
|
|
|
|
|
|
|
|
|
var queryList = await tenantDb.Queryable<TaskBaseInfo>()
|
|
|
|
|
.InnerJoin<TaskPolContainerNotPickup>((a, b) => a.Id == b.TASK_ID)
|
|
|
|
|
.Where((a, b) => a.Id == taskPKId)
|
|
|
|
|
.Select((a, b) => new { Base = a, Pol = b })
|
|
|
|
|
.ToListAsync();
|
|
|
|
|
|
|
|
|
|
//任务主键{taskPkId}无法获取业务信息
|
|
|
|
|
if (queryList.Count == 0)
|
|
|
|
|
throw new Exception(string.Format(MultiLanguageConst.GetDescription(nameof(MultiLanguageConst.TaskBaseInfoFromTaskIdNull)), taskPKId));
|
|
|
|
|
|
|
|
|
|
if (queryList.Count > 0)
|
|
|
|
|
{
|
|
|
|
|
list = queryList.Select(a => a.Pol.Adapt<TaskPOLContainerNotPickUpShowDto>()).ToList();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return DataResult<List<TaskPOLContainerNotPickUpShowDto>>.Success(list);
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region 检索对应的订舱订单并保存订舱ID
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 检索对应的订舱订单并保存订舱ID
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="taskPKId">起运港未提箱任务主键</param>
|
|
|
|
|
/// <returns>返回回执</returns>
|
|
|
|
|
public async Task<DataResult<SeaExportOrderExtension>> SearchAndMarkBookingOrder(long taskPKId)
|
|
|
|
|
{
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region 发送邮件通知给客户
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 发送邮件通知给客户
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="taskPKId">起运港未提箱主键</param>
|
|
|
|
|
/// <returns>返回回执</returns>
|
|
|
|
|
public async Task<DataResult> SendEmailToCustomer(long taskPKId)
|
|
|
|
|
{
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
}
|
|
|
|
|
}
|
jianghaiqing
3 months ago