#region << 版 本 注 释 >>
|
/*----------------------------------------------------------------
|
* 命名空间：WIDESEA_TaskInfoService
|
* 创建者：胡童庆
|
* 创建时间：2024/8/2 16:13:36
|
* 版本：V1.0.0
|
* 描述：
|
*
|
* ----------------------------------------------------------------
|
* 修改人：
|
* 修改时间：
|
* 版本：V1.0.1
|
* 修改说明：
|
*
|
*----------------------------------------------------------------*/
|
#endregion << 版 本 注 释 >>
|
|
using AutoMapper;
|
using MailKit.Search;
|
using Newtonsoft.Json;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
|
using Org.BouncyCastle.Asn1.Tsp;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.ComponentModel;
|
using System.Diagnostics.CodeAnalysis;
|
using System.Linq;
|
using System.Reflection;
|
using System.Reflection.Metadata;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_Common;
|
using WIDESEA_Core;
|
using WIDESEA_Core.BaseRepository;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_Core.Enums;
|
using WIDESEA_Core.Helper;
|
using WIDESEA_DTO.Inbound;
|
using WIDESEA_DTO.Stock;
|
using WIDESEA_IBasicRepository;
|
using WIDESEA_IBasicService;
|
using WIDESEA_IInboundService;
|
using WIDESEA_IOutboundRepository;
|
using WIDESEA_IOutboundService;
|
using WIDESEA_IRecordService;
|
using WIDESEA_IStockRepository;
|
using WIDESEA_IStockService;
|
using WIDESEA_ITaskInfoRepository;
|
using WIDESEA_ITaskInfoService;
|
using WIDESEA_Model.Models;
|
using WIDESEA_StockRepository;
|
using WIDESEA_TaskInfoRepository;
|
using static WIDESEA_Common.Authentication;
|
using static WIDESEA_Common.HouseInboundPassBack;
|
using static WIDESEA_Common.HouseoutboundPassBack;
|
using static WIDESEA_Common.InventoryAllocate;
|
using static WIDESEA_ITaskInfoService.ITaskService;
|
using Parameter = WIDESEA_Common.Parameter;
|
|
namespace WIDESEA_TaskInfoService
|
{
|
public partial class TaskService : ServiceBase<Dt_Task, ITaskRepository>, ITaskService
|
{
|
private readonly IMapper _mapper;
|
private readonly IUnitOfWorkManage _unitOfWorkManage;
|
private readonly IStockRepository _stockRepository;
|
private readonly IBasicService _basicService;
|
private readonly IOutboundService _outboundService;
|
private readonly IInboundService _inboundService;
|
private readonly IInboundOrderDetailService _inboundOrderDetailService;
|
private readonly IRecordService _recordService;
|
private readonly IStockService _stockService;
|
private readonly ITask_HtyService _taskHtyService;
|
private readonly ILocationInfoService _locationInfoService;
|
private readonly ITaskService _taskService;
|
private readonly IMaterielInfoService _materielInfoService;
|
|
public ITaskRepository Repository => BaseDal;
|
|
public TaskService(ITaskRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, IMaterielInfoService materielInfoService, IStockRepository stockRepository, IInboundOrderDetailService inboundOrderDetailService, IBasicService basicService, IOutboundService outboundService, IInboundService inboundService, IRecordService recordService, IStockService stockService, ITask_HtyService taskHtyService, ILocationInfoService locationInfoService) : base(BaseDal)
|
{
|
_mapper = mapper;
|
_stockRepository = stockRepository;
|
_unitOfWorkManage = unitOfWorkManage;
|
_basicService = basicService;
|
_outboundService = outboundService;
|
_inboundService = inboundService;
|
_recordService = recordService;
|
_stockService = stockService;
|
_taskHtyService = taskHtyService;
|
_locationInfoService = locationInfoService;
|
_inboundOrderDetailService = inboundOrderDetailService;
|
_materielInfoService = materielInfoService;
|
}
|
|
public string ReceiveWMSTaskin = WIDESEA_Core.Helper.AppSettings.Configuration["ReceiveWMSTaskin"];
|
public string ReceiveWMSTaskout = WIDESEA_Core.Helper.AppSettings.Configuration["ReceiveWMSTaskout"];
|
public string ReceiveWMSTaskAUT = WIDESEA_Core.Helper.AppSettings.Configuration["ReceiveWMSTaskAUT"];
|
public string ReceiveWMSTaskAllocatein = WIDESEA_Core.Helper.AppSettings.Configuration["ReceiveWMSTaskAllocatein"];
|
|
/// <summary>
|
/// 任务完成
|
/// </summary>
|
/// <param name="taskNum">任务号</param>
|
/// <returns>返回处理结果</returns>
|
public WebResponseContent TaskCompleted(int taskNum)
|
{
|
try
|
{
|
Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
|
if (task == null)
|
{
|
return WebResponseContent.Instance.Error("未找到任务信息");
|
}
|
MethodInfo? methodInfo = GetType().GetMethod(((TaskTypeEnum)task.TaskType) + "TaskCompleted");
|
if (methodInfo != null)
|
{
|
WebResponseContent? responseContent = (WebResponseContent?)methodInfo.Invoke(this, new object[] { task });
|
if (responseContent != null)
|
{
|
return responseContent;
|
}
|
}
|
return WebResponseContent.Instance.Error("未找到任务类型对应业务处理逻辑");
|
}
|
catch (Exception ex)
|
{
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
|
}
|
|
public WebResponseContent InboundTaskCompleted(int taskNum)
|
{
|
try
|
{
|
Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
|
if (task == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到该任务");
|
}
|
if (task.TaskType != TaskTypeEnum.Inbound.ObjToInt())
|
{
|
return WebResponseContent.Instance.Error($"任务类型错误");
|
}
|
Dt_StockInfo dt_StockInfo = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.PalletCode == task.PalletCode).Includes(x => x.Details).First();
|
if (dt_StockInfo == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到托盘对应的组盘信息");
|
}
|
|
if (!string.IsNullOrEmpty(dt_StockInfo.LocationCode))
|
{
|
return WebResponseContent.Instance.Error($"该托盘已绑定货位");
|
}
|
|
if (dt_StockInfo.Details == null || dt_StockInfo.Details.Count == 0)
|
{
|
return WebResponseContent.Instance.Error($"未找到该托盘库存明细信息");
|
}
|
Dt_LocationInfo dt_LocationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == task.TargetAddress);
|
if (dt_LocationInfo == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到目标货位信息");
|
}
|
|
if (dt_LocationInfo.LocationStatus == LocationStatusEnum.InStock.ObjToInt())
|
{
|
return WebResponseContent.Instance.Error($"货位状态不正确");
|
}
|
|
int lastStatus = dt_LocationInfo.LocationStatus;
|
dt_LocationInfo.LocationStatus = LocationStatusEnum.InStock.ObjToInt();
|
|
if (task.TaskType == TaskTypeEnum.Outbound.ObjToInt())
|
{
|
dt_StockInfo.StockStatus = StockStatusEmun.入库完成未建出库单.ObjToInt();
|
dt_StockInfo.Details.ForEach(x =>
|
{
|
x.Status = StockStatusEmun.入库完成.ObjToInt();
|
});
|
}
|
else
|
{
|
dt_StockInfo.StockStatus = StockStatusEmun.入库完成.ObjToInt();
|
|
}
|
dt_StockInfo.LocationCode = dt_LocationInfo.LocationCode;
|
|
_unitOfWorkManage.BeginTran();
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId > 0 ? OperateType.人工完成 : OperateType.自动完成);
|
|
_basicService.LocationInfoService.Repository.UpdateData(dt_LocationInfo);
|
_stockRepository.StockInfoRepository.UpdateData(dt_StockInfo);
|
_stockRepository.StockInfoDetailRepository.UpdateData(dt_StockInfo.Details);
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(dt_LocationInfo, lastStatus, StockChangeType.Inbound.ObjToInt(), "", task.TaskNum);
|
_recordService.StockQuantityChangeRecordService.AddStockChangeRecord(dt_StockInfo, dt_StockInfo.Details, dt_StockInfo.Details.Sum(x => x.StockQuantity), dt_StockInfo.Details.Sum(x => x.StockQuantity), StockChangeType.Inbound);
|
_unitOfWorkManage.CommitTran();
|
Dt_StockInfoDetail stockInfoDetail = _stockRepository.StockInfoDetailRepository.Db.Queryable<Dt_StockInfoDetail>().Where(x => x.StockId == dt_StockInfo.Id).First();
|
Dt_InboundOrder inboundOrder = _inboundService.InbounOrderService.Db.Queryable<Dt_InboundOrder>().Where(x => x.OrderNo == stockInfoDetail.OrderNo).First();
|
Dt_InboundOrderDetail inboundOrderDetail = _inboundService.InboundOrderDetailService.Repository.QueryFirst(x => x.OrderId == inboundOrder.Id);
|
|
|
Dt_InboundOrder_Hty inboundOrder_Hty = new Dt_InboundOrder_Hty
|
{
|
OrderStatus = inboundOrder.OrderStatus,
|
CreateType = inboundOrder.CreateType,
|
//SourceId = oldOutboundOrder.SourceId,
|
UpperOrderNo = inboundOrder.UpperOrderNo,
|
OrderNo = inboundOrder.OrderNo,
|
OutWareHouse = inboundOrder.OutWareHouse,
|
TransactionCode = inboundOrder.TransactionCode,
|
InoutType = inboundOrder.InoutType,
|
OrderType = inboundOrder.OrderType,
|
Creater = "WMS",
|
CreateDate = DateTime.Now,
|
};
|
_inboundService.InboundOrder_HtyService.AddData(inboundOrder_Hty);
|
|
Dt_InboundOrderDetail_Hty dt_InboundOrderDetail_Hty = new Dt_InboundOrderDetail_Hty
|
{
|
OrderId = inboundOrderDetail.OrderId,
|
MaterielCode = inboundOrderDetail.MaterielCode,
|
MaterielName = inboundOrderDetail.MaterielName,
|
BatchNo = inboundOrderDetail.BatchNo,
|
OrderQuantity = inboundOrderDetail.OrderQuantity,
|
ReceiptQuantity = inboundOrderDetail.ReceiptQuantity,
|
OverInQuantity = inboundOrderDetail.OverInQuantity,
|
OrderDetailStatus = inboundOrderDetail.OrderDetailStatus,
|
};
|
_inboundService.InboundOrderDetail_HtyService.AddData(dt_InboundOrderDetail_Hty);
|
_inboundService.InbounOrderService.DeleteData(inboundOrder);
|
_inboundService.InboundOrderDetailService.DeleteData(inboundOrderDetail);
|
if (inboundOrder.OrderType == 0)
|
{
|
HouseInboundPassBack houseInboundPassBack = new HouseInboundPassBack();
|
houseInboundPassBack.ApiType = "AsnController";
|
houseInboundPassBack.Method = "AsrsGroudingAsn";
|
|
data data = new data();
|
data.data1 data1 = new data.data1();
|
data1.AsnNo = task.OrderNo;
|
data1.InWarehouse = task.Roadway;
|
data1.TransactionCode = inboundOrder.TransactionCode;
|
data1.InoutType = inboundOrder.OrderType;
|
data1.OrderType = inboundOrder.InoutType;
|
data.data1.Inbound inbound = new data.data1.Inbound();
|
inbound.LinId = stockInfoDetail.LinId;
|
inbound.MaterielCode = stockInfoDetail.MaterielCode;
|
inbound.OrderQuantity = stockInfoDetail.StockQuantity;
|
inbound.BatchNo = stockInfoDetail.BatchNo;
|
inbound.FinishQty = stockInfoDetail.StockQuantity;
|
inbound.LocationName = task.TargetAddress;
|
data.Value.Add(data1);
|
data1.DetailList.Add(inbound);
|
houseInboundPassBack.Parameters.Add(data);
|
Authentication authentication = new Authentication()
|
{
|
ApiType = "AuthenticationController",
|
Parameters = new List<Parameter>
|
{
|
new Parameter { Value = "LKAdmin"},
|
new Parameter { Value = "LKAdmin"},
|
},
|
Method = "Login",
|
};
|
var responses1 = HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskAUT, authentication, "登录WMS账号");
|
var Ticket = responses1.Context["Ticket"].ToString();
|
var InvOrgId = responses1.Context["InvOrgId"].ToString();
|
if (Ticket != null)
|
{
|
houseInboundPassBack.Context = new Dictionary<string, string>();
|
houseInboundPassBack.Context.Add("Ticket", Ticket);
|
houseInboundPassBack.Context.Add("InvOrgId", InvOrgId);
|
var responses = HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskin, houseInboundPassBack, "立库入库数量回传WMS");
|
}
|
}
|
else
|
{
|
InventoryAllocate inventoryAllocate = new InventoryAllocate();
|
inventoryAllocate.ApiType = "InventoryAllocateController";
|
inventoryAllocate.Method = "AsrsFinishedStockCount";
|
|
Allocate allocate = new Allocate();
|
|
Allocate.data1 data1 = new Allocate.data1();
|
data1.No = task.OrderNo;
|
data1.InWarehouse = task.Roadway;
|
data1.TransactionCode = inboundOrder.TransactionCode;
|
data1.InoutType = inboundOrder.OrderType;
|
data1.OrderType = inboundOrder.InoutType;
|
Allocate.data1.Inventory inbound = new Allocate.data1.Inventory();
|
inbound.LinId = stockInfoDetail.LinId;
|
inbound.MaterielCode = stockInfoDetail.MaterielCode;
|
inbound.OrderQuantity = stockInfoDetail.StockQuantity;
|
inbound.BatchNo = stockInfoDetail.BatchNo;
|
inbound.FinishQty = stockInfoDetail.StockQuantity;
|
inbound.LocationName = task.TargetAddress;
|
allocate.Value.Add(data1);
|
data1.DetailList.Add(inbound);
|
inventoryAllocate.Parameters.Add(allocate);
|
Authentication authentication = new Authentication()
|
{
|
ApiType = "AuthenticationController",
|
Parameters = new List<Parameter>
|
{
|
new Parameter { Value = "LKAdmin"},
|
new Parameter { Value = "LKAdmin"},
|
},
|
Method = "Login",
|
};
|
var responses1 = HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskAUT, authentication, "登录WMS账号");
|
var Ticket = responses1.Context["Ticket"].ToString();
|
var InvOrgId = responses1.Context["InvOrgId"].ToString();
|
if (Ticket != null)
|
{
|
inventoryAllocate.Context = new Dictionary<string, string>();
|
inventoryAllocate.Context.Add("Ticket", Ticket);
|
inventoryAllocate.Context.Add("InvOrgId", InvOrgId);
|
var responses = HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskAllocatein, inventoryAllocate, "调拨入库数量回传WMS");
|
}
|
}
|
|
|
return WebResponseContent.Instance.OK();
|
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
|
public WebResponseContent OutboundTaskCompleted(int taskNum)
|
{
|
try
|
{
|
Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
|
if (task == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到任务信息");
|
}
|
|
Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.GetStockInfo(task.PalletCode);
|
|
Dt_LocationInfo locationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == task.SourceAddress);
|
if (stockInfo == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到库存信息");
|
}
|
if (locationInfo == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到货位信息");
|
}
|
|
List<Dt_OutStockLockInfo> outStockLockInfos = _outboundService.OutboundStockLockInfoService.Repository.QueryData(x => x.TaskNum == taskNum);
|
if (outStockLockInfos == null || outStockLockInfos.Count == 0)
|
{
|
return WebResponseContent.Instance.Error($"未找到出库详情信息");
|
}
|
|
List<Dt_OutboundOrderDetail> outboundOrderDetails = new List<Dt_OutboundOrderDetail>();
|
for (int i = 0; i < outStockLockInfos.Count; i++)
|
{
|
Dt_OutboundOrderDetail outboundOrderDetail = _outboundService.OutboundOrderDetailService.Repository.QueryFirst(x => x.Id == outStockLockInfos[i].OrderDetailId);
|
if (outboundOrderDetail != null)
|
{
|
outboundOrderDetail.OverOutQuantity = outboundOrderDetail.LockQuantity;
|
if (outboundOrderDetail.LockQuantity == outboundOrderDetail.OrderQuantity)
|
{
|
outboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt();
|
}
|
outboundOrderDetails.Add(outboundOrderDetail);
|
}
|
}
|
|
_unitOfWorkManage.BeginTran();
|
_outboundService.OutboundOrderDetailService.Repository.UpdateData(outboundOrderDetails);
|
|
stockInfo.LocationCode = locationInfo.LocationCode;
|
stockInfo.StockStatus = StockStatusEmun.出库完成.ObjToInt();
|
_stockService.StockInfoService.Repository.UpdateData(stockInfo);
|
|
int beforeStatus = locationInfo.LocationStatus;
|
locationInfo.LocationStatus = LocationStatusEnum.Free.ObjToInt();
|
_basicService.LocationInfoService.Repository.UpdateData(locationInfo);
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockChangeType.Outbound.ObjToInt(), stockInfo.Details.FirstOrDefault()?.OrderNo ?? "", task.TaskNum);
|
_unitOfWorkManage.CommitTran();
|
Dt_StockInfoDetail stockInfoDetail = _stockRepository.StockInfoDetailRepository.Db.Queryable<Dt_StockInfoDetail>().Where(x => x.StockId == stockInfo.Id).First();
|
Dt_OutboundOrderDetail outDetail = _outboundService.OutboundOrderDetailService.Db.Queryable<Dt_OutboundOrderDetail>().Where(x => x.BatchNo == stockInfoDetail.BatchNo).First();
|
Dt_OutboundOrder outboundOrder = _outboundService.OutboundOrderService.Db.Queryable<Dt_OutboundOrder>().Where(x => x.Id == outDetail.OrderId).First();
|
if (outboundOrder.OrderType == 1)
|
{
|
HouseoutboundPassBack houseInboundPassBack = new HouseoutboundPassBack();
|
houseInboundPassBack.ApiType = "ShippingOrderController";
|
houseInboundPassBack.Method = "AsrsOutboundSO";
|
datas datas = new datas();
|
datas.data1 data1 = new datas.data1();
|
data1.No = outboundOrder.OrderNo;
|
data1.OutWareHouse = task.Roadway;
|
data1.TransactionCode = outboundOrder.TransactionCode;
|
data1.InoutType = outboundOrder.OrderType;
|
data1.OrderType = outboundOrder.InoutType;
|
|
datas.data1.Inbound inbound = new datas.data1.Inbound();
|
inbound.LinId = outDetail.LinId;
|
inbound.MaterielCode = stockInfoDetail.MaterielCode;
|
inbound.OrderQuantity = stockInfoDetail.OutboundQuantity;
|
inbound.BatchNo = stockInfoDetail.BatchNo;
|
inbound.FinishQty = stockInfoDetail.OutboundQuantity;
|
inbound.LocationName = task.SourceAddress;
|
datas.Value.Add(data1);
|
data1.DetailList.Add(inbound);
|
houseInboundPassBack.Parameters.Add(datas);
|
Authentication authentication = new Authentication()
|
{
|
ApiType = "AuthenticationController",
|
Parameters = new List<Parameter>
|
{
|
new Parameter { Value = "LKAdmin"},
|
new Parameter { Value = "LKAdmin"},
|
},
|
Method = "Login",
|
};
|
var responses1 = HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskAUT, authentication, "登录WMS账号");
|
var Ticket = responses1.Context["Ticket"].ToString();
|
var InvOrgId = responses1.Context["InvOrgId"].ToString();
|
if (Ticket != null)
|
{
|
houseInboundPassBack.Context = new Dictionary<string, string>();
|
houseInboundPassBack.Context.Add("Ticket", Ticket);
|
houseInboundPassBack.Context.Add("InvOrgId", InvOrgId);
|
var responses = HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskout, houseInboundPassBack, "立库出库数量回传WMS");
|
}
|
}
|
else
|
{
|
InventoryAllocate inventoryAllocate = new InventoryAllocate();
|
inventoryAllocate.ApiType = "InventoryAllocateController";
|
inventoryAllocate.Method = "AsrsFinishedStockCount";
|
|
Allocate allocate = new Allocate();
|
|
Allocate.data1 data1 = new Allocate.data1();
|
data1.No = outboundOrder.OrderNo;
|
data1.InWarehouse = task.Roadway;
|
data1.TransactionCode = outboundOrder.TransactionCode;
|
data1.InoutType = outboundOrder.OrderType;
|
data1.OrderType = outboundOrder.InoutType;
|
Allocate.data1.Inventory inbound = new Allocate.data1.Inventory();
|
inbound.LinId = outDetail.LinId;
|
inbound.MaterielCode = stockInfoDetail.MaterielCode;
|
inbound.OrderQuantity = stockInfoDetail.StockQuantity;
|
inbound.BatchNo = stockInfoDetail.BatchNo;
|
inbound.FinishQty = stockInfoDetail.StockQuantity;
|
inbound.LocationName = task.SourceAddress;
|
allocate.Value.Add(data1);
|
data1.DetailList.Add(inbound);
|
inventoryAllocate.Parameters.Add(allocate);
|
Authentication authentication = new Authentication()
|
{
|
ApiType = "AuthenticationController",
|
Parameters = new List<Parameter>
|
{
|
new Parameter { Value = "LKAdmin"},
|
new Parameter { Value = "LKAdmin"},
|
},
|
Method = "Login",
|
};
|
var responses1 = HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskAUT, authentication, "登录WMS账号");
|
var Ticket = responses1.Context["Ticket"].ToString();
|
var InvOrgId = responses1.Context["InvOrgId"].ToString();
|
if (Ticket != null)
|
{
|
inventoryAllocate.Context = new Dictionary<string, string>();
|
inventoryAllocate.Context.Add("Ticket", Ticket);
|
inventoryAllocate.Context.Add("InvOrgId", InvOrgId);
|
var responses = HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskAllocatein, inventoryAllocate, "调拨出库数量回传WMS");
|
}
|
}
|
|
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
|
}
|
}
|
