|
|
|
@ -0,0 +1,173 @@
|
|
|
|
|
using Furion.DependencyInjection;
|
|
|
|
|
using Furion.DynamicApiController;
|
|
|
|
|
using Microsoft.AspNetCore.Mvc;
|
|
|
|
|
using Microsoft.Extensions.Logging;
|
|
|
|
|
using Myshipping.Application.Entity;
|
|
|
|
|
using Myshipping.Core.Entity;
|
|
|
|
|
using Myshipping.Core.Service;
|
|
|
|
|
using Myshipping.Core;
|
|
|
|
|
using System;
|
|
|
|
|
using System.Collections.Generic;
|
|
|
|
|
using System.Linq;
|
|
|
|
|
using System.Text;
|
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
using Furion.FriendlyException;
|
|
|
|
|
using NPOI.POIFS.Storage;
|
|
|
|
|
using Yitter.IdGenerator;
|
|
|
|
|
using Furion.DistributedIDGenerator;
|
|
|
|
|
using System.Text.RegularExpressions;
|
|
|
|
|
using Furion;
|
|
|
|
|
using Myshipping.Application.Helper;
|
|
|
|
|
using HtmlAgilityPack;
|
|
|
|
|
using Myshipping.Application.ConfigOption;
|
|
|
|
|
using Myshipping.Application.Enum;
|
|
|
|
|
using System.IO;
|
|
|
|
|
using StackExchange.Profiling.Internal;
|
|
|
|
|
using Furion.JsonSerialization;
|
|
|
|
|
using MySqlX.XDevAPI.Common;
|
|
|
|
|
using Furion.RemoteRequest.Extensions;
|
|
|
|
|
using Newtonsoft.Json;
|
|
|
|
|
using System.Net.Http;
|
|
|
|
|
using NPOI.Util;
|
|
|
|
|
|
|
|
|
|
namespace Myshipping.Application
|
|
|
|
|
{
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 货物运输计划已变更
|
|
|
|
|
/// </summary>
|
|
|
|
|
[ApiDescriptionSettings("Application", Name = "TaskTransPlanHasChange", Order = 10)]
|
|
|
|
|
public class TaskTransPlanHasChangeService : ITaskTransPlanHasChangeService, IDynamicApiController, ITransient
|
|
|
|
|
{
|
|
|
|
|
private readonly ISysCacheService _cache;
|
|
|
|
|
private readonly ILogger<TaskCautionNoticeService> _logger;
|
|
|
|
|
private readonly SqlSugarRepository<TaskBaseInfo> _taskBaseRepository;
|
|
|
|
|
private readonly SqlSugarRepository<TaskTransPlanHasChangeInfo> _taskTransPlanHasChangeInfoRepository;
|
|
|
|
|
private readonly SqlSugarRepository<TaskTransPlanHasChangeDetailInfo> _taskTransPlanHasChangeDetailInfoRepository;
|
|
|
|
|
private readonly SqlSugarRepository<DjyUserMailAccount> _djyUserMailAccount;
|
|
|
|
|
private readonly SqlSugarRepository<BookingOrder> _bookingOrderRepository;
|
|
|
|
|
private readonly SqlSugarRepository<BookingOrderContact> _bookingOrderContactRepository;
|
|
|
|
|
private readonly SqlSugarRepository<SysUser> _sysUserRepository;
|
|
|
|
|
private readonly SqlSugarRepository<BookingPrintTemplate> _repPrintTemplate;
|
|
|
|
|
private readonly SqlSugarRepository<TaskFileInfo> _taskFileRepository;
|
|
|
|
|
|
|
|
|
|
public TaskTransPlanHasChangeService(ISysCacheService cache, ILogger<TaskCautionNoticeService> logger,
|
|
|
|
|
SqlSugarRepository<TaskBaseInfo> taskBaseRepository,
|
|
|
|
|
SqlSugarRepository<TaskTransPlanHasChangeInfo> taskTransPlanHasChangeInfoRepository,
|
|
|
|
|
SqlSugarRepository<TaskTransPlanHasChangeDetailInfo> taskTransPlanHasChangeDetailInfoRepository,
|
|
|
|
|
SqlSugarRepository<DjyUserMailAccount> djyUserMailAccount,
|
|
|
|
|
SqlSugarRepository<BookingOrderContact> bookingOrderContactRepository,
|
|
|
|
|
SqlSugarRepository<SysUser> sysUserRepository,
|
|
|
|
|
SqlSugarRepository<BookingPrintTemplate> repPrintTemplate,
|
|
|
|
|
SqlSugarRepository<TaskFileInfo> taskFileRepository,
|
|
|
|
|
SqlSugarRepository<BookingOrder> bookingOrderRepository)
|
|
|
|
|
{
|
|
|
|
|
_cache = cache;
|
|
|
|
|
_logger = logger;
|
|
|
|
|
|
|
|
|
|
_taskBaseRepository = taskBaseRepository;
|
|
|
|
|
_taskTransPlanHasChangeInfoRepository = taskTransPlanHasChangeInfoRepository;
|
|
|
|
|
_taskTransPlanHasChangeDetailInfoRepository = taskTransPlanHasChangeDetailInfoRepository;
|
|
|
|
|
_djyUserMailAccount = djyUserMailAccount;
|
|
|
|
|
_bookingOrderRepository = bookingOrderRepository;
|
|
|
|
|
_bookingOrderContactRepository = bookingOrderContactRepository;
|
|
|
|
|
_sysUserRepository = sysUserRepository;
|
|
|
|
|
|
|
|
|
|
_repPrintTemplate = repPrintTemplate;
|
|
|
|
|
_taskFileRepository = taskFileRepository;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#region 获取货物运输计划已变更详情
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 获取货物运输计划已变更详情
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="taskPkId">货物运输计划已变更任务主键</param>
|
|
|
|
|
/// <returns>返回详情</returns>
|
|
|
|
|
[HttpGet("/TaskTransPlanHasChange/GetInfoByTaskId")]
|
|
|
|
|
public async Task<TaskTransPlanHasChangeShowDto> GetInfoByTaskId(string taskPkId)
|
|
|
|
|
{
|
|
|
|
|
TaskTransPlanHasChangeShowDto dto = new TaskTransPlanHasChangeShowDto();
|
|
|
|
|
|
|
|
|
|
var taskBase = _taskBaseRepository.AsQueryable().First(a => a.PK_ID == taskPkId);
|
|
|
|
|
|
|
|
|
|
if (taskBase == null)
|
|
|
|
|
throw Oops.Oh($"任务主键{taskPkId}无法获取业务信息");
|
|
|
|
|
|
|
|
|
|
var entityInfo = _taskTransPlanHasChangeInfoRepository.AsQueryable().First(a => a.TASK_ID == taskBase.PK_ID);
|
|
|
|
|
|
|
|
|
|
if (entityInfo == null)
|
|
|
|
|
throw Oops.Oh($"货物运输计划已变更主键{taskPkId}无法获取业务信息");
|
|
|
|
|
|
|
|
|
|
var detailList = _taskTransPlanHasChangeDetailInfoRepository.AsQueryable()
|
|
|
|
|
.Where(a => a.P_ID == entityInfo.PK_ID).ToList();
|
|
|
|
|
|
|
|
|
|
if(detailList.Count > 0)
|
|
|
|
|
{
|
|
|
|
|
var ctnList = detailList.Where(a => a.COLUMN_TYPE.Equals("CTN", StringComparison.OrdinalIgnoreCase)).ToList();
|
|
|
|
|
|
|
|
|
|
dto.ContaNoList = ctnList.Select(a => a.CONTA_NO).ToList();
|
|
|
|
|
|
|
|
|
|
var fromList = detailList.Where(a => !string.IsNullOrWhiteSpace(a.PLAN_TYPE) && a.PLAN_TYPE.Equals("FROM", StringComparison.OrdinalIgnoreCase)).ToList();
|
|
|
|
|
|
|
|
|
|
dto.From = new TaskTransportPlanHasChangeDetailShow
|
|
|
|
|
{
|
|
|
|
|
portList = new List<TaskTransPlanHasChangePortShow>(),
|
|
|
|
|
dateList = new List<TaskTransPlanHasChangeDateShow>(),
|
|
|
|
|
vesselList = new List<TaskTransPlanHasChangeVesselShow>()
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
dto.From.portList = fromList.Where(a => !string.IsNullOrWhiteSpace(a.COLUMN_TYPE) && a.COLUMN_TYPE.Equals("PORT", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
.Select(a =>
|
|
|
|
|
{
|
|
|
|
|
return new TaskTransPlanHasChangePortShow
|
|
|
|
|
{
|
|
|
|
|
Indx = a.SORT_NO,
|
|
|
|
|
PortName = a.PORTLOAD,
|
|
|
|
|
//CountryCode = a.
|
|
|
|
|
};
|
|
|
|
|
}).ToList();
|
|
|
|
|
|
|
|
|
|
var toList = detailList.Where(a => !string.IsNullOrWhiteSpace(a.PLAN_TYPE) && a.PLAN_TYPE.Equals("TO", StringComparison.OrdinalIgnoreCase)).ToList();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return dto;
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region 自动转发货物运输计划已变更
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 自动转发货物运输计划已变更
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="taskPKId">货物运输计划已变更任务主键</param>
|
|
|
|
|
/// <returns>返回回执</returns>
|
|
|
|
|
public async Task<TaskManageOrderResultDto> AutoTransferNotice(string taskPKId)
|
|
|
|
|
{
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region 检索对应的订舱订单
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 检索对应的订舱订单
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="taskPKId">货物运输计划已变更任务主键</param>
|
|
|
|
|
/// <returns>返回回执</returns>
|
|
|
|
|
public async Task<TaskManageOrderResultDto> QueryVBookingOrder(string taskPKId)
|
|
|
|
|
{
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#region 发送邮件通知给客户
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 发送邮件通知给客户
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="taskPKId">货物运输计划已变更主键</param>
|
|
|
|
|
/// <returns>返回回执</returns>
|
|
|
|
|
public async Task<TaskManageOrderResultDto> SendEmailToCustomer(string taskPKId)
|
|
|
|
|
{
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
}
|
|
|
|
|
}
|