#region << 版 本 注 释 >>
|
/*----------------------------------------------------------------
|
* 命名空间：WIDESEA_TaskInfoService
|
* 创建者：胡童庆
|
* 创建时间：2024/8/2 16:13:36
|
* 版本：V1.0.0
|
* 描述：
|
*
|
* ----------------------------------------------------------------
|
* 修改人：
|
* 修改时间：
|
* 版本：V1.0.1
|
* 修改说明：
|
*
|
*----------------------------------------------------------------*/
|
#endregion << 版 本 注 释 >>
|
|
using AutoMapper;
|
using MailKit.Search;
|
using Microsoft.AspNetCore.SignalR;
|
using Newtonsoft.Json;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.Database;
|
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_BasicRepository;
|
using WIDESEA_Common;
|
using WIDESEA_Common.OrderEnum;
|
using WIDESEA_Common.TaskEnum;
|
using WIDESEA_Core;
|
using WIDESEA_Core.BaseRepository;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_Core.Enums;
|
using WIDESEA_Core.Helper;
|
using WIDESEA_Core.TaskEnum;
|
using WIDESEA_DTO.Basic;
|
using WIDESEA_DTO.Inbound;
|
using WIDESEA_DTO.Stock;
|
using WIDESEA_DTO.Task;
|
using WIDESEA_IBasicRepository;
|
using WIDESEA_IBasicService;
|
using WIDESEA_IInboundRepository;
|
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_Model.Models.Inbound;
|
using WIDESEA_StockRepository;
|
using WIDESEA_TaskInfoRepository;
|
using static WIDESEA_Common.Authentication;
|
using static WIDESEA_Common.HouseBackboundPassBack;
|
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;
|
using WIDESEA_DTO.ERP;
|
using WIDESEA_OutboundRepository;
|
using System.ComponentModel.DataAnnotations;
|
using System;
|
using System.IO;
|
using System.Net.Http;
|
using System.Threading.Tasks;
|
using Spire.Pdf;
|
using WIDESEA_InboundRepository;
|
using System.Drawing.Printing;
|
using System;
|
using WIDESEA_Common.Log;
|
using static WIDESEA_Common.HouseInboundPassBack.data.data1;
|
|
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 IBasicRepository _basicRepository;
|
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;
|
private readonly IInboundOrder_HtyService _inboundOrder_HtyService;
|
private readonly IInboundOrderDetail_HtyService _inboundOrderDetail_HtyService;
|
private readonly IOutboundOrder_HtyService _outboundOrder_HtyService;
|
private readonly IOutboundOrderDetail_HtyService _outboundOrderDetail_HtyService;
|
private readonly IPalletTypeInfoRepository _palletTypeInfoRepository;
|
private readonly IOutboundOrderDetailRepository _outboundOrderDetailRepository;
|
private readonly INewOutboundOrderDetailRepository _newOutboundOrderDetailRepository;
|
private readonly IStockInfoDetailRepository _stockInfoDetailRepository;
|
private readonly IReturnOrderRepository _returnOrderRepository;
|
private readonly IProductionRepository _productionRepository;
|
private readonly IInboundRepository _inboundRepository;
|
private readonly ITakeStockOrderCPRepository _takeStockOrderCPRepository;
|
private readonly ITakeStockOrderDetailCPRepository _takeStockOrderDetailCPRepository;
|
public ITaskRepository Repository => BaseDal;
|
|
public TaskService(ITaskRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, IMaterielInfoService materielInfoService, IInboundOrderDetail_HtyService inboundOrderDetail_HtyService, IOutboundOrder_HtyService outboundOrder_HtyService, IOutboundOrderDetail_HtyService outboundOrderDetail_HtyService, IInboundOrder_HtyService inboundOrder_HtyService, IStockRepository stockRepository, IInboundOrderDetailService inboundOrderDetailService, IBasicService basicService, IOutboundService outboundService, IInboundService inboundService, IRecordService recordService, IStockService stockService, ITask_HtyService taskHtyService, ILocationInfoService locationInfoService, IOutboundOrderDetailRepository outboundOrderDetailRepository, IBasicRepository basicRepository, IStockInfoDetailRepository stockInfoDetailRepository, IPalletTypeInfoRepository palletTypeInfoRepository, IReturnOrderRepository returnOrderRepository, IProductionRepository productionRepository, IInboundRepository inboundRepository, INewOutboundOrderDetailRepository newOutboundOrderDetailRepository, ITakeStockOrderCPRepository takeStockOrderCPRepository, ITakeStockOrderDetailCPRepository takeStockOrderDetailCPRepository) : 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;
|
_inboundOrder_HtyService = inboundOrder_HtyService;
|
_inboundOrderDetail_HtyService = inboundOrderDetail_HtyService;
|
_outboundOrder_HtyService = outboundOrder_HtyService;
|
_outboundOrderDetail_HtyService = outboundOrderDetail_HtyService;
|
_outboundOrderDetailRepository = outboundOrderDetailRepository;
|
_basicRepository = basicRepository;
|
_stockInfoDetailRepository = stockInfoDetailRepository;
|
_palletTypeInfoRepository = palletTypeInfoRepository;
|
_returnOrderRepository = returnOrderRepository;
|
_productionRepository = productionRepository;
|
_inboundRepository = inboundRepository;
|
_newOutboundOrderDetailRepository = newOutboundOrderDetailRepository;
|
_takeStockOrderCPRepository = takeStockOrderCPRepository;
|
_takeStockOrderDetailCPRepository = takeStockOrderDetailCPRepository;
|
}
|
|
public string ReceiveWMSTaskin = WIDESEA_Core.Helper.AppSettings.Configuration["ReceiveWMSTaskin"];
|
public string ReceiveWMSTaskreturn = WIDESEA_Core.Helper.AppSettings.Configuration["ReceiveWMSTaskreturn"];
|
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"];
|
public string ReceiveERPTaskout = WIDESEA_Core.Helper.AppSettings.Configuration["ReceiveERPTaskout"];
|
public string InMaterialWarehousingCallback = WIDESEA_Core.Helper.AppSettings.Configuration["InMaterialWarehousingCallback"];
|
|
|
/// <summary>
|
/// 任务信息推送至WCS
|
/// </summary>
|
/// <returns></returns>
|
public WebResponseContent PushTasksToWCS(List<Dt_Task> tasks, string agvDescription = "")
|
{
|
try
|
{
|
List<WMSTaskDTO> taskDTOs = _mapper.Map<List<WMSTaskDTO>>(tasks);
|
taskDTOs.ForEach(x =>
|
{
|
x.AGVArea = agvDescription;
|
});
|
string url = AppSettings.app("WCS");
|
if (string.IsNullOrEmpty(url))
|
{
|
return WebResponseContent.Instance.Error($"未找到WCSApi地址,请检查配置文件");
|
}
|
string response = HttpHelper.Post($"{url}/api/Task/ReceiveTask", taskDTOs.Serialize());
|
|
return JsonConvert.DeserializeObject<WebResponseContent>(response) ?? WebResponseContent.Instance.Error("返回错误");
|
}
|
catch (Exception ex)
|
{
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
|
public WebResponseContent PushTasksWCS(List<Dt_Task> tasks, string agvDescription = "")
|
{
|
try
|
{
|
List<WMSTaskDTO> taskDTOs = _mapper.Map<List<WMSTaskDTO>>(tasks);
|
taskDTOs.ForEach(x =>
|
{
|
x.AGVArea = agvDescription;
|
});
|
string url = AppSettings.app("WCS");
|
if (string.IsNullOrEmpty(url))
|
{
|
return WebResponseContent.Instance.Error($"未找到WCSApi地址,请检查配置文件");
|
}
|
string response = HttpHelper.Post($"{url}/api/Task/ReceiveCPTask", taskDTOs.Serialize());
|
|
return JsonConvert.DeserializeObject<WebResponseContent>(response) ?? WebResponseContent.Instance.Error("返回错误");
|
}
|
catch (Exception ex)
|
{
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
|
public WebResponseContent FeedBackWCSTaskCompleted(int taskNum)
|
{
|
try
|
{
|
Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
|
if (task == null)
|
{
|
return WebResponseContent.Instance.Error("未找到该任务信息");
|
}
|
string url = AppSettings.app("WCS");
|
if (string.IsNullOrEmpty(url))
|
{
|
return WebResponseContent.Instance.Error($"未找到WCSApi地址,请检查配置文件");
|
}
|
string response = HttpHelper.Post($"{url}/api/Task/RecWMSTaskCompleted?taskNum=" + taskNum);
|
|
return JsonConvert.DeserializeObject<WebResponseContent>(response) ?? WebResponseContent.Instance.Error("返回错误");
|
}
|
catch (Exception ex)
|
{
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
/// <summary>
|
/// 放货完成
|
/// </summary>
|
/// <param name="code"></param>
|
/// <returns></returns>
|
public WebResponseContent PutFinish(string code)
|
{
|
try
|
{
|
string url = AppSettings.app("WCS");
|
if (string.IsNullOrEmpty(url))
|
{
|
return WebResponseContent.Instance.Error($"未找到WCSAApi地址,请检查配置文件");
|
}
|
string response = HttpHelper.Post($"{url}/api/CTU_AGV/PutFinish?code=" + code);
|
|
return JsonConvert.DeserializeObject<WebResponseContent>(response) ?? WebResponseContent.Instance.Error("返回错误");
|
}
|
catch (Exception ex)
|
{
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 任务完成
|
/// </summary>
|
/// <param name="taskNum">任务号</param>
|
/// <returns>返回处理结果</returns>
|
public async Task<WebResponseContent> TaskCompleted(int taskNum)
|
{
|
try
|
{
|
Dt_Task task = await Repository.QueryFirstAsync(x => x.TaskNum == taskNum);
|
if (task == null)
|
{
|
return await Task.FromResult(WebResponseContent.Instance.Error($"未找到任务信息"));
|
}
|
if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
|
{
|
return await Task.FromResult(InboundTaskCompleted(taskNum));
|
}
|
else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
|
{
|
return await Task.FromResult(OutboundTaskCompleted(taskNum));
|
}
|
//else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.RelocationGroup)
|
//{
|
// return await Task.FromResult(RelocationTaskCompleted(task));
|
//}
|
else
|
{
|
return await Task.FromResult(WebResponseContent.Instance.Error($"未找到该类型任务,任务类型:{task.TaskType}"));
|
}
|
}
|
catch (Exception ex)
|
{
|
return await Task.FromResult(WebResponseContent.Instance.Error(ex.Message));
|
}
|
}
|
|
|
|
/// <summary>
|
/// 修改任务状态
|
/// </summary>
|
/// <param name="task"></param>
|
/// <returns></returns>
|
public WebResponseContent UpdateTaskInfo(WCSTaskDTO task)
|
{
|
try
|
{
|
Dt_Task wmsTask = BaseDal.QueryFirst(x => x.TaskNum == task.TaskNum);
|
if (wmsTask != null)
|
{
|
wmsTask.TaskStatus = task.TaskState;
|
wmsTask.CurrentAddress = task.CurrentAddress;
|
wmsTask.NextAddress = task.NextAddress;
|
wmsTask.Dispatchertime = task.Dispatchertime;
|
BaseDal.UpdateData(wmsTask);
|
}
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
|
|
public WebResponseContent UpdateTaskStatus(int taskNum, int tasktype)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum && x.TaskType == tasktype);
|
if (task == null) return WebResponseContent.Instance.Error("未找到任务信息");
|
if (TaskEnumHelper.GetTaskTypeGroup(task.TaskType) == TaskTypeGroup.InboundGroup)
|
{
|
task.TaskStatus = TaskInStatusEnum.InFinish.ObjToInt();
|
content = UpdateTaskStatusInFinish(task);
|
}
|
}
|
catch (Exception)
|
{
|
|
throw;
|
}
|
return content;
|
}
|
|
public WebResponseContent UpdateTaskStatusInFinish(Dt_Task task)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.GetStockInfo(task.PalletCode);//组盘库存
|
Dt_LocationInfo locationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == task.TargetAddress);//货位
|
var result = CheckCompleted(stockInfo, locationInfo);
|
if (!result.Item1)
|
{
|
throw new Exception(result.Item2);
|
}
|
|
if (stockInfo.StockStatus != StockStatusEmun.入库中.ObjToInt()) throw new Exception($"托盘[{task.PalletCode}],该组盘状态不可入库");
|
Dt_StockInfoDetail stockInfoDetail = stockInfo.Details.FirstOrDefault(x => x.StockId == stockInfo.Id);
|
|
List<Dt_StockInfo> stockInfos = _stockService.StockInfoService.Repository.LocationCodesGetStockInfos(new List<string> { stockInfo.LocationCode }).Where(x => x.StockStatus == (int)StockStatusEmun.已入库.ObjToInt()).ToList();
|
if (task.TaskType == TaskTypeEnum.Inbound.ObjToInt())
|
{
|
stockInfo.SerialNumber = stockInfos.Count + 1;
|
stockInfo.InDate = DateTime.Now;
|
stockInfo.StockStatus = StockStatusEmun.已入库.ObjToInt();
|
stockInfoDetail.Status = StockStatusEmun.已入库.ObjToInt();
|
locationInfo.LocationStatus = LocationStatusEnum.Pallet.ObjToInt();
|
task.CurrentAddress = task.NextAddress;
|
task.NextAddress = string.Empty;
|
Db.Ado.BeginTran();
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
_basicService.LocationInfoService.Repository.UpdateData(locationInfo);
|
_stockService.StockInfoService.Repository.UpdateData(stockInfo);
|
_stockService.StockInfoDetailService.Repository.UpdateData(stockInfoDetail);
|
Db.Ado.CommitTran();
|
return content;
|
}
|
#region 入库单
|
Dt_InboundOrder inboundOrder = _inboundService.InbounOrderService.GetInboundOrder(stockInfoDetail.OrderNo);
|
if (inboundOrder != null || inboundOrder.Details.Count < 1) throw new Exception($"未找到托盘[{task.PalletCode}]的入库单明细信息");
|
Dt_InboundOrderDetail inboundOrderDetail = inboundOrder.Details.FirstOrDefault(x => x.BatchNo == stockInfoDetail.BatchNo && x.MaterielCode == stockInfoDetail.MaterielCode);
|
inboundOrderDetail.OrderDetailStatus = inboundOrderDetail.OverInQuantity == inboundOrderDetail.OrderQuantity ? OrderDetailStatusEnum.Over.ObjToInt() : OrderDetailStatusEnum.GroupAndInbound.ObjToInt();
|
if (inboundOrder.Details.FirstOrDefault(x => x.OrderDetailStatus != OrderDetailStatusEnum.Over.ObjToInt()) == null)
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.入库完成.ObjToInt();
|
}
|
else if (inboundOrder.OrderStatus == InboundStatusEnum.未开始.ObjToInt())
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.入库中.ObjToInt();
|
}
|
stockInfo.SerialNumber = stockInfos.Count + 1;
|
stockInfo.InDate = DateTime.Now;
|
stockInfo.StockStatus = StockStatusEmun.已入库.ObjToInt();
|
stockInfoDetail.Status = StockStatusEmun.已入库.ObjToInt();
|
locationInfo.LocationStatus = LocationStatusEnum.InStock.ObjToInt();
|
task.CurrentAddress = task.NextAddress;
|
task.NextAddress = string.Empty;
|
Db.Ado.BeginTran();
|
#region 任务和入库单
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
if (inboundOrder.OrderStatus != InboundStatusEnum.入库完成.ObjToInt())
|
{
|
_inboundService.InbounOrderService.Repository.UpdateData(inboundOrder);
|
_inboundService.InboundOrderDetailService.Repository.UpdateData(inboundOrderDetail);
|
}
|
else
|
{
|
List<Dt_InboundOrderDetail> orderDetails = inboundOrder.Details;
|
inboundOrder.Details = null;
|
_inboundService.InbounOrderService.Repository.DeleteAndMoveIntoHty(inboundOrder, OperateType.自动完成);
|
_inboundService.InboundOrderDetailService.Repository.DeleteAndMoveIntoHty(orderDetails, OperateType.自动完成);
|
}
|
#endregion
|
_basicService.LocationInfoService.Repository.UpdateData(locationInfo);
|
_stockService.StockInfoService.Repository.UpdateData(stockInfo);
|
_stockService.StockInfoDetailService.Repository.UpdateData(stockInfoDetail);
|
//_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockChangeType.Inbound.ObjToInt(), stockInfo.Details.FirstOrDefault()?.OrderNo ?? "", task.TaskNum);
|
Db.Ado.CommitTran();
|
SendInboundInfoToWMS(task, inboundOrder, stockInfo);
|
#endregion
|
}
|
catch (Exception ex)
|
{
|
Db.Ado.RollbackTran();
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
|
/// <summary>
|
/// 验证数据
|
/// </summary>
|
/// <param name="stockInfo"></param>
|
/// <param name="locationInfo"></param>
|
/// <returns></returns>
|
private (bool, string) CheckCompleted(Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo, bool isCheckStockDetail = true)
|
{
|
if (stockInfo == null)
|
{
|
return (false, "未找到组盘信息");
|
}
|
|
if (locationInfo == null)
|
{
|
return (false, "未找到货位信息");
|
}
|
|
if (isCheckStockDetail && (stockInfo.Details == null || stockInfo.Details.Count == 0))
|
{
|
return (false, "未找到组盘明细信息");
|
}
|
|
return (true, "成功");
|
}
|
|
#region 入库任务完成
|
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.GetTaskTypeGroup() != TaskTypeGroup.InboundGroup)
|
{
|
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();
|
Dt_Warehouse warehouse = _basicService.WarehouseService.Repository.QueryFirst(x => x.WarehouseId == task.WarehouseId);
|
|
dt_StockInfo.LocationCode = dt_LocationInfo.LocationCode;
|
if (task.TaskType == TaskTypeEnum.InSyncretism.ObjToInt())
|
{
|
int laststatus = dt_LocationInfo.LocationStatus;
|
dt_LocationInfo.LocationStatus = LocationStatusEnum.InStock.ObjToInt();
|
///更新库存状态
|
dt_StockInfo.StockStatus = StockStatusEmun.入库完成.ObjToInt();
|
// 更新库存明细状态
|
dt_StockInfo.Details.ForEach(x => x.Status = StockStatusEmun.入库完成.ObjToInt());
|
|
_unitOfWorkManage.BeginTran();
|
|
// 更新任务状态
|
UpdateTaskStatus(task);
|
|
// 更新货位状态
|
UpdateLocationStatus(dt_LocationInfo, laststatus);
|
|
// 更新库存信息
|
UpdateStockInfo(dt_StockInfo);
|
|
AddRecords(task, dt_StockInfo, dt_LocationInfo, laststatus);
|
|
//返回smom库存移动数据。。。。
|
|
_unitOfWorkManage.CommitTran();
|
}
|
else
|
{
|
if (warehouse.WarehouseCode.Contains("CP"))
|
{
|
|
if (task.TaskType == TaskTypeEnum.SurplusReturn.ObjToInt() || task.TaskType == TaskTypeEnum.ReverseIn.ObjToInt())
|
{
|
int lastStatus = dt_LocationInfo.LocationStatus;
|
dt_LocationInfo.LocationStatus = LocationStatusEnum.InStock.ObjToInt();
|
Dt_ReturnOrder returnOrder = _returnOrderRepository.QueryFirst(x => x.LPNNo == dt_StockInfo.PalletCode);
|
if (returnOrder == null)
|
{
|
return WebResponseContent.Instance.Error("未找到回库单信息");
|
}
|
return SurplusReturnInbound(task, dt_StockInfo, dt_LocationInfo, lastStatus, returnOrder);
|
}
|
// 1. 获取入库单信息
|
Dt_InboundOrder? inboundOrder = null;
|
if (!string.IsNullOrEmpty(dt_StockInfo.Details.FirstOrDefault()?.OrderNo))
|
{
|
inboundOrder = _inboundService.InbounOrderService.Db.Queryable<Dt_InboundOrder>()
|
.Where(x => x.OrderNo == dt_StockInfo.Details.FirstOrDefault().OrderNo)
|
.Includes(x => x.Details)
|
.First();
|
}
|
|
// 3. 处理入库逻辑
|
if (task.TaskType == TaskTypeEnum.Inbound.ObjToInt())
|
{
|
int lastStatus = dt_LocationInfo.LocationStatus;
|
dt_LocationInfo.LocationStatus = LocationStatusEnum.InStock.ObjToInt();
|
|
if (task.TaskType == TaskTypeEnum.Inbound.ObjToInt() && inboundOrder == null)
|
{
|
return WebResponseContent.Instance.Error("未找到入库单信息");
|
}
|
var allBoxCodesForDetail = BaseDal.Db.Queryable<Dt_StockInfoDetailCP>()
|
.Where(x => x.StockDetailId == dt_StockInfo.Details.FirstOrDefault().Id)
|
.Select(x => x.BoxCode)
|
.ToList();
|
|
// 2. 获取托盘下的所有箱号
|
var boxCodes = new List<string>();
|
|
// 方法1：从库存明细的BoxCodes字段获取（组盘时保存的）
|
foreach (var detail in allBoxCodesForDetail)
|
{
|
if (!string.IsNullOrEmpty(detail))
|
{
|
var codes = detail.Split(',', StringSplitOptions.RemoveEmptyEntries);
|
boxCodes.AddRange(codes);
|
}
|
}
|
|
// 根据托盘明细获取对应的入库单明细
|
List<Dt_InboundOrderDetail> inboundOrderDetails = new List<Dt_InboundOrderDetail>();
|
|
// 处理多个库存明细的情况
|
foreach (var stockDetail in dt_StockInfo.Details)
|
{
|
if (!string.IsNullOrEmpty(stockDetail.OrderNo))
|
{
|
var detail = inboundOrder.Details.FirstOrDefault(x => x.LinId == stockDetail.LinId && x.BatchNo == stockDetail.BatchNo);
|
|
if (detail != null && !inboundOrderDetails.Any(x => x.Id == detail.Id))
|
{
|
inboundOrderDetails.Add(detail);
|
}
|
}
|
}
|
|
if (!inboundOrderDetails.Any())
|
{
|
return WebResponseContent.Instance.Error($"未找到对应的入库单明细");
|
}
|
|
// 更新入库单明细状态
|
foreach (var inboundOrderDetail in inboundOrderDetails)
|
{
|
// 检查该明细是否已全部入库
|
decimal totalStockQuantity = dt_StockInfo.Details
|
.Where(x => x.LinId == inboundOrderDetail.LinId && x.BatchNo == inboundOrderDetail.BatchNo)
|
.Sum(x => x.StockQuantity);
|
|
decimal orderQuantity = Convert.ToDecimal(inboundOrderDetail.OrderQuantity);
|
decimal receiptQuantity = Convert.ToDecimal(inboundOrderDetail.ReceiptQuantity);
|
decimal overInQuantity = Convert.ToDecimal(inboundOrderDetail.OverInQuantity);
|
|
// 更新收货数量
|
inboundOrderDetail.OverInQuantity = totalStockQuantity += overInQuantity;
|
|
// 检查是否全部完成
|
if (inboundOrderDetail.OverInQuantity == inboundOrderDetail.OrderQuantity)
|
{
|
inboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt();
|
}
|
else
|
{
|
inboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.Inbounding.ObjToInt();
|
}
|
}
|
|
///更新库存状态
|
dt_StockInfo.StockStatus = StockStatusEmun.入库完成.ObjToInt();
|
// 更新库存明细状态
|
dt_StockInfo.Details.ForEach(x => x.Status = StockStatusEmun.入库完成.ObjToInt());
|
|
// 3. 查询成品入库明细（CP入库单明细）
|
List<Dt_CPInboundOrderDetail> cpInboundDetails = new List<Dt_CPInboundOrderDetail>();
|
if (boxCodes.Any())
|
{
|
cpInboundDetails = BaseDal.Db.Queryable<Dt_CPInboundOrderDetail>()
|
.Where(x => boxCodes.Contains(x.BoxCode))
|
.ToList();
|
}
|
|
// 更新成品入库明细状态
|
if (cpInboundDetails.Any())
|
{
|
foreach (var cpDetail in cpInboundDetails)
|
{
|
cpDetail.CPOrderDetailStatus = InboundStatusEnum.入库完成.ObjToInt();
|
}
|
}
|
|
// 4. 查询并更新成品库存明细（如果有单独的成品库存表）
|
List<Dt_StockInfoDetailCP> cpStockDetails = new List<Dt_StockInfoDetailCP>();
|
if (boxCodes.Any())
|
{
|
cpStockDetails = BaseDal.Db.Queryable<Dt_StockInfoDetailCP>()
|
.Where(x => boxCodes.Contains(x.BoxCode))
|
.ToList();
|
|
// 更新成品库存明细状态
|
foreach (var cpStockDetail in cpStockDetails)
|
{
|
cpStockDetail.CPStockDetailStatus = StockStatusEmun.入库完成.ObjToInt();
|
}
|
}
|
|
try
|
{
|
_unitOfWorkManage.BeginTran();
|
|
// 更新任务状态
|
UpdateTaskStatus(task);
|
|
// 更新货位状态
|
UpdateLocationStatus(dt_LocationInfo, lastStatus);
|
|
// 更新库存信息
|
UpdateStockInfo(dt_StockInfo);
|
|
// 添加记录
|
AddRecords(task, dt_StockInfo, dt_LocationInfo, lastStatus);
|
|
// 更新入库单明细
|
if (inboundOrderDetails.Any())
|
{
|
BaseDal.Db.Updateable(inboundOrderDetails).ExecuteCommand();
|
|
// 检查入库单是否全部完成
|
bool allCompleted = inboundOrder.Details.All(x =>
|
x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt());
|
|
if (allCompleted)
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.入库完成.ObjToInt();
|
foreach (var item in inboundOrderDetails)
|
{
|
BaseDal.Db.Deleteable(item.CPDetails).ExecuteCommand();
|
}
|
}
|
else
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.入库中.ObjToInt();
|
}
|
}
|
|
// 更新入库单
|
UpdateInboundOrder(inboundOrder, inboundOrderDetails.FirstOrDefault());
|
|
// 更新成品入库明细状态
|
if (cpInboundDetails.Any())
|
{
|
BaseDal.Db.Updateable(cpInboundDetails).ExecuteCommand();
|
}
|
|
// 更新成品库存明细状态
|
if (cpStockDetails.Any())
|
{
|
BaseDal.Db.Updateable(cpStockDetails).ExecuteCommand();
|
}
|
|
// 单据数量全部上架完成，处理WMS回传
|
if (inboundOrderDetails.Any(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()) && inboundOrder.System.Equals("ERP"))
|
{
|
foreach (var detail in inboundOrderDetails.Where(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()))
|
{
|
FeedBackInboundERP(inboundOrder.UpperOrderNo, detail.LinId);
|
}
|
}
|
if (inboundOrder.OrderStatus == InboundStatusEnum.入库完成.ObjToInt() && inboundOrder.OrderType == 0 && inboundOrder.System.Equals("SMOM"))
|
{
|
List<Dt_StockInfo> StockInfos = _stockRepository.StockInfoRepository.Db
|
.Queryable<Dt_StockInfo>()
|
.Includes(x => x.Details, d => d.StockDetails)
|
.Where(x => x.WarehouseId == task.WarehouseId &&
|
x.Details.Any(v => v.OrderNo == inboundOrder.OrderNo))
|
.ToList();
|
|
if (StockInfos.Count == 0) throw new Exception("未找到库存信息");
|
var houseInboundPassBack = new HouseInboundPassBack
|
{
|
ApiType = "AsnController",
|
Method = "AsrsGroudingAsn",
|
Parameters = new List<HouseInboundPassBack.data>
|
{
|
new HouseInboundPassBack.data
|
{
|
Value = new List<data.data1>
|
{
|
new data.data1
|
{
|
AsnNo = inboundOrder.OrderNo,
|
//InWarehouse = task.Roadway,
|
TransactionCode = inboundOrder.TransactionCode,
|
InoutType = inboundOrder.OrderType,
|
OrderType = inboundOrder.InoutType,
|
// 遍历所有库存明细，添加到 DetailList
|
DetailList = StockInfos
|
.SelectMany(pallet => pallet.Details, (pallet, detail) => new { Pallet = pallet, Detail = detail })
|
.GroupBy(x => new
|
{
|
x.Pallet.PalletCode,
|
x.Detail.MaterielCode,
|
x.Detail.BatchNo,
|
x.Detail.LinId
|
})
|
.Select(g => new data.data1.Inbound
|
{
|
LinId = g.Key.LinId ?? "",
|
MaterielCode = g.Key.MaterielCode ?? "",
|
OrderQuantity = g.Sum(x => x.Detail.StockQuantity),
|
BatchNo = g.Key.BatchNo,
|
LPNNo = g.Key.PalletCode,
|
FinishQty = g.Sum(x => x.Detail.StockQuantity),
|
LocationName = g.First().Pallet.LocationCode,
|
LabelList = g.SelectMany(x => x.Detail.StockDetails ?? new List<Dt_StockInfoDetailCP>())
|
.Where(sd => !string.IsNullOrEmpty(sd?.BoxCode))
|
.Select(sd => sd.BoxCode)
|
.Distinct()
|
.ToList()
|
})
|
.ToList()
|
}
|
}
|
}
|
}
|
};
|
|
var authResult = AuthenticateWithWMS();
|
if (authResult.IsSuccess)
|
{
|
houseInboundPassBack.Context = new Dictionary<string, string>
|
{
|
{ "Ticket", authResult.Ticket },
|
{ "InvOrgId", authResult.InvOrgId }
|
};
|
|
var response = HttpHelper.Post<MomRequestContent>(ReceiveWMSTaskin, houseInboundPassBack, "立库入库数量回传WMS");
|
// 判断Success的值
|
if (!response.Success)
|
{
|
throw new Exception($"操作失败: {response.Message ?? "未提供错误信息"}");
|
}
|
|
}
|
|
}
|
else if (inboundOrder.OrderStatus == InboundStatusEnum.入库完成.ObjToInt() && inboundOrder.OrderType == 2 && inboundOrder.System.Equals("SMOM"))
|
{
|
List<Dt_StockInfo> StockInfos = _stockRepository.StockInfoRepository.Db
|
.Queryable<Dt_StockInfo>()
|
.Includes(x => x.Details, d => d.StockDetails)
|
.Where(x => x.WarehouseId == task.WarehouseId &&
|
x.Details.Any(v => v.OrderNo == inboundOrder.OrderNo))
|
.ToList();
|
if (StockInfos.Count == 0) throw new Exception("未找到库存信息");
|
var inventoryAllocate = new InventoryAllocate
|
{
|
ApiType = "InventoryAllocateController",
|
Method = "AsrsFinishedStockCount",
|
Parameters = new List<InventoryAllocate.Allocate>
|
{
|
new InventoryAllocate.Allocate
|
{
|
Value = new List<Allocate.data1>
|
{
|
new Allocate.data1
|
{
|
No = inboundOrder.OrderNo,
|
//InWarehouse = task.Roadway,
|
TransactionCode = inboundOrder.TransactionCode,
|
InoutType = inboundOrder.OrderType,
|
OrderType = inboundOrder.InoutType,
|
ActiveType=1,
|
|
DetailList = StockInfos
|
.SelectMany(pallet => pallet.Details, (pallet, detail) => new { Pallet = pallet, Detail = detail })
|
.GroupBy(x => new
|
{
|
x.Pallet.PalletCode,
|
x.Detail.MaterielCode,
|
x.Detail.BatchNo,
|
x.Detail.LinId
|
})
|
.Select(g => new Allocate.data1.Inventory
|
{
|
LinId = g.Key.LinId ?? "",
|
MaterielCode = g.Key.MaterielCode ?? "",
|
OrderQuantity = g.Sum(x => x.Detail.StockQuantity),
|
BatchNo = g.Key.BatchNo,
|
LPNNo = g.Key.PalletCode,
|
FinishQty = g.Sum(x => x.Detail.StockQuantity),
|
LocationName = g.First().Pallet.LocationCode,
|
OrinalLocation = g.First().Detail?.OrinalLocation,
|
LabelList = g.SelectMany(x => x.Detail.StockDetails ?? new List<Dt_StockInfoDetailCP>())
|
.Where(sd => !string.IsNullOrEmpty(sd?.BoxCode))
|
.Select(sd => sd.BoxCode)
|
.Distinct()
|
.ToList()
|
})
|
.ToList()
|
}
|
}
|
}
|
}
|
};
|
|
var authResult = AuthenticateWithWMS();
|
if (authResult.IsSuccess)
|
{
|
inventoryAllocate.Context = new Dictionary<string, string>
|
{
|
{ "Ticket", authResult.Ticket },
|
{ "InvOrgId", authResult.InvOrgId }
|
};
|
|
var response = HttpHelper.Post<MomRequestContent>(ReceiveWMSTaskAllocatein, inventoryAllocate, "调拨入库数量回传WMS");
|
if (!response.Success)
|
{
|
throw new Exception($"操作失败：{response.Message ?? "未提供错误信息"}");
|
}
|
}
|
}
|
|
_unitOfWorkManage.CommitTran();
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
throw new Exception($"入库处理失败：{ex.Message}", ex);
|
}
|
}
|
}
|
else
|
{
|
Dt_InboundOrder? inboundOrder = _inboundService.InbounOrderService.Db.Queryable<Dt_InboundOrder>().Where(x => x.OrderNo == dt_StockInfo.Details.FirstOrDefault().OrderNo).Includes(x => x.Details).First();
|
Dt_InboundOrderDetail? inboundOrderDetail = null;
|
|
// 3. 处理入库逻辑
|
if (task.TaskType == TaskTypeEnum.Inbound.ObjToInt())
|
{
|
return ProcessInbound(task, dt_StockInfo, dt_LocationInfo);
|
}
|
if (task.TaskType == TaskTypeEnum.SurplusReturn.ObjToInt() || task.TaskType == TaskTypeEnum.ReverseIn.ObjToInt())
|
{
|
return ReturnInbound(task, dt_StockInfo, dt_LocationInfo);
|
}
|
if (task.TaskType == TaskTypeEnum.InInventory.ObjToInt())
|
{
|
int lastStatus = dt_LocationInfo.LocationStatus;
|
dt_LocationInfo.LocationStatus = LocationStatusEnum.InStock.ObjToInt();
|
dt_StockInfo.StockStatus = StockStatusEmun.入库完成.ObjToInt();
|
// 更新库存明细状态
|
dt_StockInfo.Details.ForEach(x => x.Status = StockStatusEmun.入库完成.ObjToInt());
|
_unitOfWorkManage.BeginTran();
|
UpdateTaskStatus(task);
|
UpdateLocationStatus(dt_LocationInfo, lastStatus);
|
UpdateStockInfo(dt_StockInfo);
|
AddRecords(task, dt_StockInfo, dt_LocationInfo, lastStatus);
|
_unitOfWorkManage.CommitTran();
|
return WebResponseContent.Instance.OK();
|
|
}
|
}
|
}
|
|
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
|
private WebResponseContent ProcessInbound(Dt_Task task, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo)
|
{
|
int lastStatus = locationInfo.LocationStatus;
|
locationInfo.LocationStatus = LocationStatusEnum.InStock.ObjToInt();
|
|
Dt_InboundOrder inboundOrder = _inboundService.InbounOrderService.Db.Queryable<Dt_InboundOrder>()
|
.Where(x => x.OrderNo == stockInfo.Details.FirstOrDefault().OrderNo)
|
.Includes(x => x.Details)
|
.First();
|
|
if (task.TaskType == TaskTypeEnum.Inbound.ObjToInt() && inboundOrder == null)
|
{
|
return WebResponseContent.Instance.Error("未找到入库单信息");
|
}
|
Dt_InboundOrderDetail inboundOrderDetail = inboundOrder.Details
|
.FirstOrDefault(x => x.LinId == stockInfo.Details.FirstOrDefault()?.LinId);
|
//if (inboundOrder != null && stockInfo.StockStatus == StockStatusEmun.入库确认.ObjToInt())
|
//{
|
//入库数量回传
|
return ProcessNormalInbound(task, stockInfo, locationInfo, lastStatus, inboundOrder, inboundOrderDetail);
|
//}
|
//else
|
//{
|
// //调拨出入库任务数量回传
|
// return ProcessAllocateInbound(task, stockInfo, locationInfo, lastStatus, inboundOrder, inboundOrderDetail);
|
//}
|
}
|
private WebResponseContent ReturnInbound(Dt_Task task, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo)
|
{
|
int lastStatus = locationInfo.LocationStatus;
|
locationInfo.LocationStatus = LocationStatusEnum.InStock.ObjToInt();
|
|
Dt_ReturnOrder returnOrder = _returnOrderRepository.QueryFirst(x => x.OrderNo == stockInfo.Details.FirstOrDefault().OrderNo);
|
if (returnOrder == null)
|
{
|
return WebResponseContent.Instance.Error("未找到回库单信息");
|
}
|
//if (inboundOrder != null && stockInfo.StockStatus == StockStatusEmun.入库确认.ObjToInt())
|
//{
|
//入库数量回传
|
return SurplusReturnInbound(task, stockInfo, locationInfo, lastStatus, returnOrder);
|
//}
|
//else
|
//{
|
// //调拨出入库任务数量回传
|
// return ProcessAllocateInbound(task, stockInfo, locationInfo, lastStatus, inboundOrder, inboundOrderDetail);
|
//}
|
}
|
|
|
//其他入库
|
private WebResponseContent ProcessNormalInbound(Dt_Task task, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo,
|
int lastStatus, Dt_InboundOrder inboundOrder, Dt_InboundOrderDetail inboundOrderDetail)
|
{
|
// 更新入库单明细状态
|
UpdateInboundOrderDetails(stockInfo, inboundOrder, ref inboundOrderDetail);
|
///更新库存状态
|
stockInfo.StockStatus = StockStatusEmun.入库完成.ObjToInt();
|
// 更新库存明细状态
|
stockInfo.Details.ForEach(x => x.Status = StockStatusEmun.入库完成.ObjToInt());
|
|
try
|
{
|
_unitOfWorkManage.BeginTran();
|
|
// 更新任务状态
|
UpdateTaskStatus(task);
|
|
// 更新货位状态
|
UpdateLocationStatus(locationInfo, lastStatus);
|
|
// 更新库存信息
|
UpdateStockInfo(stockInfo);
|
|
// 添加记录
|
AddRecords(task, stockInfo, locationInfo, lastStatus);
|
|
// 更新入库单
|
UpdateInboundOrder(inboundOrder, inboundOrderDetail);
|
|
// 单据数量全部上架完成，处理WMS回传
|
if (inboundOrderDetail.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt() && inboundOrder.System.Equals("ERP"))
|
{
|
FeedBackInboundERP(inboundOrder.UpperOrderNo, inboundOrderDetail.LinId);
|
}
|
if (inboundOrder.OrderStatus == InboundStatusEnum.入库完成.ObjToInt() && inboundOrder.OrderType == 0 && inboundOrder.System.Equals("SMOM"))
|
{
|
//SendInboundInfoToWMS(task, inboundOrder, stockInfo);
|
}
|
else if (inboundOrder.OrderStatus == InboundStatusEnum.入库完成.ObjToInt() && inboundOrder.OrderType == 2 && inboundOrder.System.Equals("SMOM"))
|
{
|
SendAllocateInfoToWMS(task, inboundOrder, stockInfo);
|
}
|
|
_unitOfWorkManage.CommitTran();
|
return WebResponseContent.Instance.OK();
|
}
|
catch
|
{
|
_unitOfWorkManage.RollbackTran();
|
throw;
|
}
|
}
|
//回库逻辑处理并上报WMS
|
private WebResponseContent SurplusReturnInbound(Dt_Task task, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo,
|
int lastStatus, Dt_ReturnOrder returnOrder)
|
{
|
returnOrder.OrderStatus = InOrderStatusEnum.入库完成.ObjToInt();
|
|
if (task.TaskType == TaskTypeEnum.ReverseIn.ObjToInt())
|
{
|
foreach (var item in stockInfo.Details)
|
{
|
item.StockQuantity = returnOrder.OrderQuantity;
|
returnOrder.OverInQuantity = returnOrder.OrderQuantity;
|
}
|
}
|
else
|
{
|
foreach (var item in stockInfo.Details)
|
{
|
returnOrder.OverInQuantity += item.StockQuantity;
|
}
|
}
|
///更新库存状态
|
stockInfo.StockStatus = StockStatusEmun.入库完成.ObjToInt();
|
// 更新库存明细状态
|
stockInfo.Details.ForEach(x => x.Status = StockStatusEmun.入库完成.ObjToInt());
|
|
try
|
{
|
_unitOfWorkManage.BeginTran();
|
|
// 更新任务状态
|
UpdateTaskStatus(task);
|
|
// 更新货位状态
|
UpdateLocationStatus(locationInfo, lastStatus);
|
|
// 更新库存信息
|
UpdateStockInfo(stockInfo);
|
|
// 添加记录
|
AddRecords(task, stockInfo, locationInfo, lastStatus);
|
|
//更新回库单
|
_returnOrderRepository.UpdateData(returnOrder);
|
|
if (returnOrder.OrderType == OrderTypeEnum.反拣回库单.ObjToInt() && (returnOrder.LocationCode == null || returnOrder.LocationCode == ""))
|
{
|
SurplusReturnInboundToWMS(task, returnOrder, stockInfo, locationInfo);
|
}
|
_unitOfWorkManage.CommitTran();
|
return WebResponseContent.Instance.OK();
|
}
|
catch
|
{
|
_unitOfWorkManage.RollbackTran();
|
throw;
|
}
|
}
|
////调拨入库
|
//private WebResponseContent ProcessAllocateInbound(Dt_Task task, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo,
|
// int lastStatus, Dt_InboundOrder inboundOrder, Dt_InboundOrderDetail inboundOrderDetail)
|
//{
|
// // 更新入库单明细状态
|
// UpdateInboundOrderDetails(stockInfo, inboundOrder, ref inboundOrderDetail);
|
|
// // 更新库存明细状态
|
// stockInfo.Details.ForEach(x => x.Status = StockStatusEmun.入库完成.ObjToInt());
|
|
// try
|
// {
|
// _unitOfWorkManage.BeginTran();
|
|
// // 更新任务状态
|
// UpdateTaskStatus(task);
|
|
// // 更新货位状态
|
// UpdateLocationStatus(locationInfo, lastStatus);
|
|
// // 更新库存信息
|
// UpdateStockInfo(stockInfo);
|
|
// // 添加记录
|
// AddRecords(task, stockInfo, locationInfo, lastStatus);
|
|
// // 更新入库单
|
// UpdateInboundOrder(inboundOrder, inboundOrderDetail);
|
|
// // 单据数量全部上架完成，处理WMS回传
|
// if (inboundOrderDetail.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt())
|
// {
|
// var stockInfoDetail = stockInfo.Details.FirstOrDefault();
|
// SendInboundInfoToWMS(task, inboundOrder, stockInfo);
|
// }
|
|
// _unitOfWorkManage.CommitTran();
|
// return WebResponseContent.Instance.OK();
|
// }
|
// catch
|
// {
|
// _unitOfWorkManage.RollbackTran();
|
// throw;
|
// }
|
//}
|
|
#region Helper Methods
|
|
private void UpdateInboundOrderDetails(Dt_StockInfo stockInfo, Dt_InboundOrder inboundOrder,
|
ref Dt_InboundOrderDetail inboundOrderDetail)
|
{
|
int overCount = inboundOrder.Details.Count(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt());
|
inboundOrderDetail = inboundOrder.Details.FirstOrDefault(x => x.LinId == stockInfo.Details.FirstOrDefault()?.LinId);
|
|
foreach (var item in stockInfo.Details)
|
{
|
if (inboundOrderDetail == null) continue;
|
|
inboundOrderDetail.OverInQuantity += item.StockQuantity;
|
|
if (inboundOrderDetail.OverInQuantity == inboundOrderDetail.OrderQuantity)
|
{
|
inboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt();
|
overCount++;
|
}
|
else if (inboundOrderDetail.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt())
|
{
|
inboundOrderDetail.OrderDetailStatus = InboundStatusEnum.入库中.ObjToInt();
|
inboundOrder.OrderStatus = InboundStatusEnum.入库中.ObjToInt();
|
}
|
}
|
if (inboundOrder.Details.Count == overCount)
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.入库完成.ObjToInt();
|
}
|
}
|
|
private void UpdateTaskStatus(Dt_Task task)
|
{
|
task.TaskStatus = TaskStatusEnum.Finish.ObjToInt();
|
FeedBackWCSTaskCompleted(task.TaskNum);
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId > 0 ? OperateType.人工完成 : OperateType.自动完成);
|
}
|
|
private void UpdateLocationStatus(Dt_LocationInfo locationInfo, int lastStatus)
|
{
|
_basicService.LocationInfoService.Repository.UpdateData(locationInfo);
|
}
|
|
private void UpdateStockInfo(Dt_StockInfo stockInfo)
|
{
|
_stockRepository.StockInfoRepository.UpdateData(stockInfo);
|
_stockRepository.StockInfoDetailRepository.UpdateData(stockInfo.Details);
|
}
|
|
private void AddRecords(Dt_Task task, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo, int lastStatus)
|
{
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(
|
locationInfo, lastStatus, StockChangeType.Inbound.ObjToInt(), "", task.TaskNum);
|
|
_recordService.StockQuantityChangeRecordService.AddStockChangeRecord(
|
stockInfo, stockInfo.Details,
|
stockInfo.Details.Sum(x => x.StockQuantity),
|
stockInfo.Details.Sum(x => x.StockQuantity),
|
StockChangeType.Inbound, task.TaskNum);
|
}
|
|
private void UpdateInboundOrder(Dt_InboundOrder inboundOrder, Dt_InboundOrderDetail inboundOrderDetail)
|
{
|
if (inboundOrder != null)
|
{
|
_inboundService.InbounOrderService.UpdateData(inboundOrder);
|
_inboundService.InboundOrderDetailService.UpdateData(inboundOrderDetail);
|
}
|
}
|
|
private WebResponseContent SendInboundInfoToWMS(Dt_Task task, Dt_InboundOrder inboundOrder, Dt_StockInfo stockInfo)
|
{
|
|
|
List<Dt_StockInfo> StockInfos = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.WarehouseId == task.WarehouseId).Includes(x => x.Details).Where(x => x.Details.Any(v => v.OrderNo == inboundOrder.OrderNo)).ToList();
|
//var dt_StockInfo = _stockRepository.StockInfoRepository.QueryData(x => x.Id == stockInfo.Id).ToList();
|
//List<Dt_StockInfo> StockInfos = new List<Dt_StockInfo>();
|
//foreach (var item in dt_StockInfo)
|
//{
|
// Dt_StockInfo StockInfo = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.Id == item.Id).Includes(x => x.Details).First();
|
// StockInfos.Add(StockInfo);
|
//}
|
|
if (StockInfos.Count == 0) throw new Exception("未找到库存信息");
|
var houseInboundPassBack = new HouseInboundPassBack
|
{
|
ApiType = "AsnController",
|
Method = "AsrsGroudingAsn",
|
Parameters = new List<HouseInboundPassBack.data>
|
{
|
new HouseInboundPassBack.data
|
{
|
Value = new List<data.data1>
|
{
|
new data.data1
|
{
|
AsnNo = inboundOrder.OrderNo,
|
//InWarehouse = task.Roadway,
|
TransactionCode = inboundOrder.TransactionCode,
|
InoutType = inboundOrder.OrderType,
|
OrderType = inboundOrder.InoutType,
|
// 遍历所有库存明细，添加到 DetailList
|
DetailList = StockInfos.Select(d => new data.data1.Inbound
|
{
|
LinId = d.Details.FirstOrDefault()?.LinId?? "",
|
MaterielCode = d.Details.FirstOrDefault()?.MaterielCode?? "",
|
OrderQuantity = d.Details.FirstOrDefault().StockQuantity,
|
BatchNo = d.BatchNo,
|
LPNNo = d.PalletCode,
|
FinishQty = d.Details.FirstOrDefault().StockQuantity,
|
LocationName = d.LocationCode
|
}).ToList()
|
}
|
}
|
}
|
}
|
};
|
|
var authResult = AuthenticateWithWMS();
|
if (authResult.IsSuccess)
|
{
|
houseInboundPassBack.Context = new Dictionary<string, string>
|
{
|
{ "Ticket", authResult.Ticket },
|
{ "InvOrgId", authResult.InvOrgId }
|
};
|
|
var response = HttpHelper.Post<MomRequestContent>(ReceiveWMSTaskin, houseInboundPassBack, "立库入库数量回传WMS");
|
// 判断Success的值
|
if (response.Success)
|
{
|
// 如果Success为true，返回需要的值（这里以返回整个响应对象为例）
|
return WebResponseContent.Instance.OK();
|
}
|
else
|
{
|
// 如果Success为false，抛出异常并包含错误信息
|
throw new Exception($"操作失败: {response.Message ?? "未提供错误信息"}");
|
}
|
|
}
|
return WebResponseContent.Instance.OK();
|
}
|
|
private WebResponseContent SurplusReturnInboundToWMS(Dt_Task task, Dt_ReturnOrder returnOrder, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo)
|
{
|
List<Dt_StockInfo> StockInfos = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.WarehouseId == task.WarehouseId).Includes(x => x.Details).Where(x => x.Details.Any(v => v.OrderNo == returnOrder.OrderNo)).ToList();
|
Dt_Warehouse warehouse = _basicService.WarehouseService.Repository.QueryFirst(x => x.WarehouseId == task.WarehouseId);
|
if (StockInfos.Count == 0) throw new Exception("未找到库存信息");
|
var houseReturnOrders = new HouseBackboundPassBack
|
{
|
ApiType = "ShippingOrderController",
|
Method = "returnShippingOrderUnPickingToAsrsCallback",
|
Parameters = new List<HouseBackboundPassBack.backdata>
|
{
|
new HouseBackboundPassBack.backdata
|
{
|
Value= new List<backdata.backdata1>
|
{
|
new backdata.backdata1
|
{
|
OrderType = returnOrder.OrderType,
|
MaterielCode = returnOrder.MaterielCode,
|
MaterielName = returnOrder.MaterielName,
|
MaterieSpec = returnOrder.MaterieSpec,
|
BatchNo = returnOrder.BatchNo,
|
OrderQuantity = returnOrder.OrderQuantity,
|
Remark = returnOrder.Remark,
|
LinId = returnOrder.LinId,
|
LPNNo = returnOrder.LPNNo,
|
LocationCode = locationInfo.LocationCode,
|
WarehouseCode = returnOrder.WarehouseCode,
|
System = returnOrder.System,
|
}
|
}
|
}
|
}
|
};
|
var authResult = AuthenticateWithWMS();
|
if (authResult.IsSuccess)
|
{
|
houseReturnOrders.Context = new Dictionary<string, string>
|
{
|
{ "Ticket", authResult.Ticket },
|
{ "InvOrgId", authResult.InvOrgId }
|
};
|
var response = HttpHelper.Post<MomRequestContent>(ReceiveWMSTaskreturn, houseReturnOrders, "取消发货后立库反拣入库回传WMS");
|
// 判断Success的值
|
if (response.Success)
|
{
|
// 如果Success为true，返回需要的值（这里以返回整个响应对象为例）
|
return WebResponseContent.Instance.OK();
|
}
|
else
|
{
|
// 如果Success为false，抛出异常并包含错误信息
|
throw new Exception($"操作失败: {response.Message ?? "未提供错误信息"}");
|
}
|
|
}
|
return WebResponseContent.Instance.OK();
|
}
|
|
private void ProcessAllocateInboundOrder(Dt_InboundOrder inboundOrder, Dt_InboundOrderDetail inboundOrderDetail)
|
{
|
// 添加历史记录
|
var history = new Dt_InboundOrder_Hty
|
{
|
OrderStatus = inboundOrder.OrderStatus,
|
CreateType = inboundOrder.CreateType,
|
UpperOrderNo = inboundOrder.UpperOrderNo,
|
OrderNo = inboundOrder.OrderNo,
|
TransactionCode = inboundOrder.TransactionCode,
|
InoutType = inboundOrder.InoutType,
|
OrderType = inboundOrder.OrderType,
|
Creater = "WMS",
|
CreateDate = DateTime.Now,
|
};
|
_inboundOrder_HtyService.AddData(history);
|
|
// 添加明细历史记录
|
var detailHistory = 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,
|
Creater = "WMS",
|
CreateDate = DateTime.Now,
|
};
|
_inboundOrderDetail_HtyService.AddData(detailHistory);
|
|
// 删除原数据
|
_inboundService.InbounOrderService.DeleteData(inboundOrder);
|
_inboundService.InboundOrderDetailService.DeleteData(inboundOrderDetail);
|
}
|
|
private void SendAllocateInfoToWMS(Dt_Task task, Dt_InboundOrder inboundOrder, Dt_StockInfo stockInfos)
|
{
|
|
List<Dt_StockInfo> StockInfos = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.WarehouseId == task.WarehouseId).Includes(x => x.Details).Where(x => x.Details.Any(v => v.OrderNo == inboundOrder.OrderNo)).ToList();
|
//var dt_StockInfo = _stockRepository.StockInfoRepository.QueryData(x => x.Id == stockInfo.Id).ToList();
|
//List<Dt_StockInfo> StockInfos = new List<Dt_StockInfo>();
|
//foreach (var item in dt_StockInfo)
|
//{
|
// Dt_StockInfo StockInfo = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.Id == item.Id).Includes(x => x.Details).First();
|
// StockInfos.Add(StockInfo);
|
//}
|
|
if (StockInfos.Count == 0) throw new Exception("未找到库存信息");
|
var inventoryAllocate = new InventoryAllocate
|
{
|
ApiType = "InventoryAllocateController",
|
Method = "AsrsFinishedStockCount",
|
Parameters = new List<InventoryAllocate.Allocate>
|
{
|
new InventoryAllocate.Allocate
|
{
|
Value = new List<Allocate.data1>
|
{
|
new Allocate.data1
|
{
|
No = inboundOrder.OrderNo,
|
//InWarehouse = task.Roadway,
|
TransactionCode = inboundOrder.TransactionCode,
|
InoutType = inboundOrder.OrderType,
|
OrderType = inboundOrder.InoutType,
|
// 遍历所有库存明细，添加到 DetailList
|
DetailList = StockInfos.Select(d => new Allocate.data1.Inventory
|
{
|
LinId = d.Details.FirstOrDefault()?.LinId?? "",
|
MaterielCode = d.Details.FirstOrDefault()?.MaterielCode?? "",
|
OrderQuantity = d.Details.FirstOrDefault().StockQuantity,
|
BatchNo = d.BatchNo,
|
LPNNo = d.PalletCode,
|
FinishQty = d.Details.FirstOrDefault().StockQuantity,
|
LocationName = d.LocationCode
|
}).ToList()
|
}
|
}
|
}
|
}
|
};
|
|
var authResult = AuthenticateWithWMS();
|
if (authResult.IsSuccess)
|
{
|
inventoryAllocate.Context = new Dictionary<string, string>
|
{
|
{ "Ticket", authResult.Ticket },
|
{ "InvOrgId", authResult.InvOrgId }
|
};
|
|
HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskAllocatein, inventoryAllocate, "调拨入库数量回传WMS");
|
}
|
}
|
|
private void AddInboundOrderDetailHistory(Dt_InboundOrderDetail inboundOrderDetail)
|
{
|
var history = 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,
|
Creater = "WMS",
|
CreateDate = DateTime.Now,
|
};
|
_inboundOrderDetail_HtyService.AddData(history);
|
_inboundService.InboundOrderDetailService.DeleteData(inboundOrderDetail);
|
}
|
|
private (bool IsSuccess, string Ticket, string InvOrgId) AuthenticateWithWMS()
|
{
|
var authentication = new Authentication
|
{
|
ApiType = "AuthenticationController",
|
Parameters = new List<Parameter>
|
{
|
new Parameter { Value = "LK-Admin" },
|
new Parameter { Value = "LK-Admin" }
|
},
|
Method = "Login",
|
};
|
|
var response = HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskAUT, authentication, "登录WMS账号");
|
|
if (response.Context != null)
|
{
|
return (true, response.Context["Ticket"].ToString(), response.Context["InvOrgId"].ToString());
|
}
|
|
return (false, null, null);
|
}
|
|
#endregion
|
#endregion
|
|
|
|
|
#region//出库任务完成
|
public WebResponseContent OutboundTaskCompleted(int taskNum)
|
{
|
try
|
{
|
// 1. 验证任务和获取基础数据
|
var validationResult = ValidateAndGetBaseData(taskNum, out var task, out var stockInfo,
|
out var locationInfo, out var outStockLockInfos);
|
if (!validationResult.Status) return validationResult;
|
|
int lastStatus = locationInfo.LocationStatus;
|
|
///盘点出库任务完成逻辑
|
if (task.TaskType == TaskTypeEnum.OutInventory.ObjToInt() && stockInfo.System == "SMOM")
|
{
|
return SMOMOutInventoryCompleted(task, stockInfo, locationInfo);
|
}
|
else if (task.TaskType == TaskTypeEnum.OutInventory.ObjToInt())
|
{
|
return OutInventoryCompleted(task, stockInfo, locationInfo);
|
}
|
if (task.TaskType == TaskTypeEnum.OutSyncretism.ObjToInt())
|
{
|
stockInfo.StockStatus = StockStatusEmun.合托出库完成.ObjToInt();
|
stockInfo.Details.ForEach(x =>
|
{
|
x.Status = StockStatusEmun.合托出库完成.ObjToInt();
|
});
|
_unitOfWorkManage.BeginTran();
|
_stockRepository.StockInfoRepository.UpdateData(stockInfo);
|
_stockRepository.StockInfoDetailRepository.UpdateData(stockInfo.Details);
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
_unitOfWorkManage.CommitTran();
|
}
|
else
|
{
|
Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseId == task.WarehouseId);
|
|
if (warehouse.WarehouseCode.Contains("CP"))
|
{
|
try
|
{
|
Dt_NewOutboundOrder outboundOrder = _outboundService.NewOutboundOrderService.Db.Queryable<Dt_NewOutboundOrder>()
|
.Where(x => x.OrderNo == task.OrderNo)
|
.Includes(x => x.Details)
|
.First();
|
|
List<Dt_NewOutboundOrderDetail> outboundOrderDetails = _outboundService.NewOutboundOrderDetailService.Db.Queryable<Dt_NewOutboundOrderDetail>()
|
.Where(x => x.OrderId == outboundOrder.Id &&
|
x.LocationName == stockInfo.LocationCode &&
|
x.LPNNo == stockInfo.PalletCode)
|
.ToList();
|
|
if (outboundOrderDetails == null || outboundOrderDetails.Count == 0)
|
{
|
throw new Exception($"未找到托盘 {stockInfo.PalletCode} 在货位 {stockInfo.LocationCode} 上的出库单明细");
|
}
|
|
// 获取库存明细
|
var stockInfoDetails = stockInfo.Details.ToList();
|
|
int overCount = outboundOrder.Details.Count(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt());
|
|
foreach (var stockDetail in stockInfoDetails)
|
{
|
var matchingOrderDetails = outboundOrderDetails
|
.Where(x => x.MaterielCode == stockDetail.MaterielCode &&
|
x.BatchNo == stockDetail.BatchNo)
|
.ToList();
|
|
if (matchingOrderDetails.Count == 0)
|
{
|
continue;
|
}
|
|
// 计算需要分配的数量
|
decimal remainingStock = stockDetail.OutboundQuantity;
|
|
foreach (var orderDetail in matchingOrderDetails)
|
{
|
if (remainingStock <= 0) break;
|
|
if (orderDetail.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt())
|
continue;
|
|
// 计算本次可以分配的数量
|
decimal availableOrderQty = orderDetail.OrderQuantity - orderDetail.OverOutQuantity;
|
decimal allocateQty = Math.Min(remainingStock, availableOrderQty);
|
|
if (allocateQty > 0)
|
{
|
orderDetail.OverOutQuantity += allocateQty;
|
remainingStock -= allocateQty;
|
|
// 检查是否完成
|
if (Math.Abs(orderDetail.OverOutQuantity - orderDetail.OrderQuantity) < 0.001m)
|
{
|
orderDetail.OrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt();
|
overCount++;
|
}
|
}
|
}
|
}
|
// 更新订单状态
|
if (outboundOrder.Details.Count == overCount)
|
{
|
outboundOrder.OrderStatus = OutboundStatusEnum.出库完成.ObjToInt();
|
}
|
_unitOfWorkManage.BeginTran();
|
|
try
|
{
|
// 更新出库单
|
_outboundService.NewOutboundOrderService.Repository.UpdateData(outboundOrder);
|
|
_outboundService.NewOutboundOrderDetailService.Repository.UpdateData(outboundOrderDetails);
|
|
|
AddCPRetrueOrder(stockInfo, outboundOrder, outboundOrderDetails);
|
|
// 区分单据数据来源更新货位状态
|
if (outboundOrder.System == null)
|
{
|
return WebResponseContent.Instance.Error("出库单数据源为空");
|
}
|
|
if (!outboundOrder.System.Equals("SMOM"))
|
{
|
UpdateLocationStatus(locationInfo);
|
}
|
|
// 处理任务完成
|
CompleteTask(task);
|
|
// 添加状态变更记录
|
AddStatusChangeRecord(task, stockInfo, locationInfo);
|
|
string path = "http://fr.mankun.com:8080/webroot/decision/view/report?viewlet=fr-report\\SMOM/Product/Produce/OutBoundDetileReport.cpt&op=write&format=pdf";
|
string fullPath = AppDomain.CurrentDomain.BaseDirectory;
|
var url = Path.Combine(fullPath, "wwwroot", "Reports");
|
string savePath = Path.Combine(url, "本次出库.pdf");
|
|
// ERP系统反馈
|
if (outboundOrder.System.Equals("ERP"))
|
{
|
// 为每个完成的明细反馈ERP
|
foreach (var orderDetail in outboundOrderDetails.Where(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()))
|
{
|
FeedBackOutERP(outboundOrder.OrderNo, orderDetail.LinId);
|
}
|
|
// 如果有完成的明细，下载报表
|
if (outboundOrderDetails.Any(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()))
|
{
|
DownloadReport(path, savePath, outboundOrderDetails.First().Id);
|
}
|
}
|
|
// 单据完成推送SMOM系统
|
if (outboundOrder.OrderStatus == OutboundStatusEnum.出库完成.ObjToInt() && outboundOrder.System.Equals("SMOM"))
|
{
|
var outStockLockInfoList = _outboundService.OutboundStockLockInfoService.Repository
|
.QueryData(x => x.OrderNo == outboundOrder.OrderNo);
|
|
if (outStockLockInfoList.Count == 0)
|
throw new Exception($"订单 {outboundOrder.OrderNo} 托盘 {stockInfo.PalletCode} 未找到库存锁定信息");
|
|
// 采购出库
|
if (outboundOrder.OrderType == 1)
|
{
|
var passBack = new HouseoutboundPassBack
|
{
|
ApiType = "ShippingOrderController",
|
Method = "AsrsOutboundSO",
|
Parameters = new List<HouseoutboundPassBack.datas>
|
{
|
new HouseoutboundPassBack.datas
|
{
|
Value = new List<HouseoutboundPassBack.datas.data1>
|
{
|
new HouseoutboundPassBack.datas.data1
|
{
|
No = outboundOrder.OrderNo,
|
OutWareHouse = task.Roadway,
|
TransactionCode = outboundOrder.TransactionCode,
|
InoutType = outboundOrder.OrderType,
|
OrderType = outboundOrder.InoutType,
|
DetailList = outStockLockInfoList.Select(d => new HouseoutboundPassBack.datas.data1.Inbound
|
{
|
LinId = d.LinId?? "",
|
LPN_No = d.PalletCode,
|
MaterielCode = d.MaterielCode?? "",
|
OrderQuantity = d.OrderQuantity,
|
BatchNo = d.BatchNo,
|
FinishQty = d.OrderQuantity,
|
LocationName = d.LocationCode
|
})
|
.ToList()
|
}
|
}
|
}
|
}
|
};
|
|
//调用SMOM接口...
|
var authResult = AuthenticateWithWMS();
|
if (authResult.IsSuccess)
|
{
|
passBack.Context = new Dictionary<string, string>
|
{
|
{ "Ticket", authResult.Ticket },
|
{ "InvOrgId", authResult.InvOrgId }
|
};
|
var response = HttpHelper.Post<MomRequestContent>(ReceiveWMSTaskout, passBack, "立库出库数量回传WMS");
|
if (!response.Success)
|
{
|
throw new Exception($"操作失败: {response.Message ?? "未提供错误信息"}");
|
}
|
}
|
}
|
|
// 调拨出库
|
if (outboundOrder.OrderType == 2)
|
{
|
var allocate = new InventoryAllocate
|
{
|
ApiType = "InventoryAllocateController",
|
Method = "AsrsFinishedStockCount",
|
Parameters = new List<Allocate>
|
{
|
new Allocate
|
{
|
Value = new List<Allocate.data1>
|
{
|
new Allocate.data1
|
{
|
No = outboundOrder.OrderNo,
|
InWarehouse = task.Roadway,
|
TransactionCode = outboundOrder.TransactionCode,
|
InoutType = outboundOrder.OrderType,
|
OrderType = outboundOrder.InoutType,
|
ActiveType = 2,
|
DetailList = outStockLockInfoList.Select(item =>
|
{
|
return new Allocate.data1.Inventory
|
{
|
LinId = item.LinId,
|
LPNNo = item.PalletCode,
|
MaterielCode = item.MaterielCode,
|
OrderQuantity = item.OrderQuantity,
|
BatchNo = item.BatchNo,
|
FinishQty = item.OrderQuantity,
|
LocationName = task.SourceAddress
|
};
|
}).ToList()
|
}
|
}
|
}
|
}
|
};
|
|
// 调用SMOM接口...
|
var authResult = AuthenticateWithWMS();
|
if (authResult.IsSuccess)
|
{
|
allocate.Context = new Dictionary<string, string>
|
{
|
{ "Ticket", authResult.Ticket },
|
{ "InvOrgId", authResult.InvOrgId }
|
};
|
var response = HttpHelper.Post<MomRequestContent>(ReceiveWMSTaskin, allocate, "立库入库数量回传WMS");
|
if (!response.Success)
|
{
|
throw new Exception($"操作失败: {response.Message ?? "未提供错误信息"}");
|
}
|
}
|
}
|
}
|
|
if (outboundOrder.OrderType == 240) // 盘点出库
|
{
|
// 盘点出库特殊处理逻辑
|
}
|
|
_unitOfWorkManage.CommitTran();
|
return WebResponseContent.Instance.OK();
|
}
|
catch
|
{
|
_unitOfWorkManage.RollbackTran();
|
throw;
|
}
|
}
|
catch (Exception ex)
|
{
|
return WebResponseContent.Instance.Error($"处理失败: {ex.Message}");
|
}
|
}
|
else
|
{
|
Dt_OutboundOrder inboundOrder = _outboundService.OutboundOrderService.Db.Queryable<Dt_OutboundOrder>()
|
.Where(x => x.OrderNo == task.OrderNo)
|
.Includes(x => x.Details)
|
.First();
|
|
if (inboundOrder == null) return WebResponseContent.Instance.Error("未找到出库单信息");
|
|
Dt_OutboundOrderDetail outboundOrderDetails = _outboundService.OutboundOrderService.Db.Queryable<Dt_OutboundOrderDetail>()
|
.Where(x => x.OrderId == inboundOrder.Id && x.BatchNo == stockInfo.Details.FirstOrDefault().BatchNo)
|
.First();
|
if (outboundOrderDetails.LocationName != null && outboundOrderDetails.LocationName != "")
|
{
|
outboundOrderDetails = _outboundService.OutboundOrderService.Db.Queryable<Dt_OutboundOrderDetail>()
|
.Where(x => x.OrderId == inboundOrder.Id && x.BatchNo == stockInfo.Details.FirstOrDefault().BatchNo && x.LocationName == stockInfo.LocationCode)
|
.First();
|
}
|
if (outboundOrderDetails == null) return WebResponseContent.Instance.Error("未找到出库单信息");
|
UpdateOutboundOrderDetails(stockInfo, inboundOrder, ref outboundOrderDetails);
|
// 3. 执行核心出库逻辑
|
return ExecuteOutboundLogic(task, stockInfo, locationInfo, outboundOrderDetails, inboundOrder);
|
}
|
}
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
|
#region 私有方法
|
|
private WebResponseContent ValidateAndGetBaseData(int taskNum, out Dt_Task task,
|
out Dt_StockInfo stockInfo, out Dt_LocationInfo locationInfo,
|
out List<Dt_OutStockLockInfo> outStockLockInfos)
|
{
|
task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
|
if (task == null)
|
{
|
stockInfo = null;
|
locationInfo = null;
|
outStockLockInfos = null;
|
return WebResponseContent.Instance.Error("未找到任务信息");
|
}
|
var SourceAddress = task.SourceAddress;
|
stockInfo = _stockService.StockInfoService.Repository.GetStockInfo(task.PalletCode);
|
locationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == SourceAddress);
|
outStockLockInfos = _outboundService.OutboundStockLockInfoService.Repository.QueryData(x => x.TaskNum == taskNum);
|
|
if (stockInfo == null) return WebResponseContent.Instance.Error("未找到库存信息");
|
if (locationInfo == null) return WebResponseContent.Instance.Error("未找到货位信息");
|
if ((outStockLockInfos == null || outStockLockInfos.Count == 0) && task.TaskType != TaskTypeEnum.OutInventory.ObjToInt())
|
return WebResponseContent.Instance.Error("未找到出库详情信息");
|
|
return WebResponseContent.Instance.OK();
|
}
|
|
//private List<Dt_OutboundOrderDetail> ProcessOutboundOrderDetails(List<Dt_OutStockLockInfo> outStockLockInfos)
|
//{
|
// var outboundOrderDetails = new List<Dt_OutboundOrderDetail>();
|
|
// foreach (var lockInfo in outStockLockInfos)
|
// {
|
// List<Dt_OutboundOrderDetail> detail = _outboundService.OutboundOrderDetailService.Repository.QueryData(x => x.Id == lockInfo.Id);
|
// if (detail != null)
|
// {
|
// detail.OverOutQuantity = lockInfo.OriginalQuantity;
|
// if (detail.LockQuantity == detail.OrderQuantity)
|
// {
|
// detail.OrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt();
|
// }
|
// outboundOrderDetails.Add(detail);
|
// }
|
// }
|
|
// return outboundOrderDetails;
|
//}
|
|
private WebResponseContent ExecuteOutboundLogic(Dt_Task task, Dt_StockInfo stockInfo,
|
Dt_LocationInfo locationInfo, Dt_OutboundOrderDetail outboundOrderDetails, Dt_OutboundOrder inboundOrder)
|
{
|
try
|
{
|
_unitOfWorkManage.BeginTran();
|
///更新出库单
|
_outboundService.OutboundOrderService.Repository.UpdateData(inboundOrder);
|
// 更新出库订单详情
|
_outboundService.OutboundOrderDetailService.Repository.UpdateData(outboundOrderDetails);
|
|
// 更新库存状态 回库单
|
AddRetrueOrder(stockInfo, inboundOrder);
|
|
// 区分单据数据来源更新货位状态
|
if (inboundOrder.System == null)
|
{
|
return WebResponseContent.Instance.Error("出库单数据源为空");
|
}
|
if (!inboundOrder.System.Equals("SMOM"))
|
{
|
UpdateLocationStatus(locationInfo);
|
}
|
// 处理任务完成
|
CompleteTask(task);
|
|
// 添加状态变更记录
|
AddStatusChangeRecord(task, stockInfo, locationInfo);
|
|
// 根据订单类型处理不同逻辑
|
|
var outboundOrder = _outboundService.OutboundOrderService.Db.Queryable<Dt_OutboundOrder>()
|
.Where(x => x.OrderNo == inboundOrder.OrderNo).First();
|
var outDetail = _outboundService.OutboundOrderDetailService.Db.Queryable<Dt_OutboundOrderDetail>()
|
.Where(x => x.OrderId == outboundOrder.Id && x.BatchNo == outboundOrderDetails.BatchNo).First();
|
|
string path = "http://fr.mankun.com:8080/webroot/decision/view/report?viewlet=fr-report\\SMOM/Product/Produce/OutBoundDetileReport.cpt&op=write&format=pdf";
|
string fullPath = AppDomain.CurrentDomain.BaseDirectory;
|
var url = Path.Combine(fullPath, "wwwroot", "Reports");
|
string savePath = Path.Combine(url, "本次出库.pdf");
|
|
|
if (outboundOrderDetails.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt() && inboundOrder.System.Equals("ERP"))
|
{
|
FeedBackOutERP(outboundOrder.OrderNo, outboundOrderDetails.LinId);
|
DownloadReport(path, savePath, outboundOrderDetails.Id);
|
}
|
///单据完成推送SMOM系统
|
if (outboundOrder.OrderStatus == OutboundStatusEnum.出库完成.ObjToInt() && inboundOrder.System.Equals("SMOM"))
|
{
|
var stockInfoDetail = stockInfo.Details.FirstOrDefault();
|
ProcessNormalOutbound(task, stockInfo, outboundOrder, outDetail);
|
//DownloadReport(path, savePath, outboundOrderDetails.Id);
|
//printTest(savePath);
|
//SendNormalOutboundToWMS(task, outboundOrder, stockInfoDetail, outDetail);
|
}
|
|
if (outboundOrder.OrderType == 240) // 盘点出库
|
{
|
// 盘点出库特殊处理逻辑
|
}
|
|
_unitOfWorkManage.CommitTran();
|
return WebResponseContent.Instance.OK();
|
}
|
catch
|
{
|
_unitOfWorkManage.RollbackTran();
|
throw;
|
}
|
}
|
private void UpdateOutboundOrderDetails(Dt_StockInfo stockInfo, Dt_OutboundOrder inboundOrder, ref Dt_OutboundOrderDetail inboundOrderDetail)
|
{
|
int overCount = inboundOrder.Details.Count(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt());
|
//inboundOrderDetail = inboundOrder.Details.FirstOrDefault(x => x.BatchNo == stockInfo.Details.FirstOrDefault()?.BatchNo&&x.LPNNo==stockInfo.PalletCode);
|
|
foreach (var item in stockInfo.Details)
|
{
|
if (inboundOrderDetail == null) continue;
|
|
inboundOrderDetail.OverOutQuantity += item.OutboundQuantity;
|
|
if (inboundOrderDetail.OverOutQuantity == inboundOrderDetail.OrderQuantity)
|
{
|
inboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt();
|
overCount++;
|
}
|
else if (inboundOrderDetail.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt())
|
{
|
inboundOrderDetail.OrderDetailStatus = OutboundStatusEnum.出库中.ObjToInt();
|
inboundOrder.OrderStatus = OutboundStatusEnum.出库中.ObjToInt();
|
}
|
}
|
if (inboundOrder.Details.Count == overCount)
|
{
|
inboundOrder.OrderStatus = OutboundStatusEnum.出库完成.ObjToInt();
|
}
|
}
|
|
private void DeleteAndMoveIntoHtStockStatus(Dt_StockInfo stockInfo)
|
{
|
_stockService.StockInfoService.Repository.DeleteAndMoveIntoHty(stockInfo, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
_stockService.StockInfoDetailService.Repository.DeleteAndMoveIntoHty(stockInfo.Details, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
}
|
|
private void UpdateLocationStatus(Dt_LocationInfo locationInfo)
|
{
|
int beforeStatus = locationInfo.LocationStatus;
|
locationInfo.LocationStatus = LocationStatusEnum.Free.ObjToInt();
|
_basicService.LocationInfoService.Repository.UpdateData(locationInfo);
|
}
|
|
private void CompleteTask(Dt_Task task)
|
{
|
task.TaskStatus = TaskStatusEnum.Finish.ObjToInt();
|
FeedBackWCSTaskCompleted(task.TaskNum);
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
}
|
|
private void AddStatusChangeRecord(Dt_Task task, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo)
|
{
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(
|
locationInfo,
|
locationInfo.LocationStatus,
|
StockChangeType.Outbound.ObjToInt(),
|
stockInfo.Details.FirstOrDefault()?.OrderNo ?? "",
|
task.TaskNum);
|
}
|
|
private void ProcessNormalOutbound(Dt_Task task, Dt_StockInfo stockInfo,
|
Dt_OutboundOrder outboundOrder, Dt_OutboundOrderDetail outDetail)
|
{
|
var stockInfoDetail = _stockRepository.StockInfoDetailRepository.Db.Queryable<Dt_StockInfoDetail>()
|
.Where(x => x.StockId == stockInfo.Id).First();
|
|
//if (outboundOrder.OrderStatus == OutboundStatusEnum.出库完成.ObjToInt())
|
//{
|
// var history = new Dt_OutboundOrder_Hty
|
// {
|
// OrderStatus = outboundOrder.OrderStatus,
|
// CreateType = outboundOrder.CreateType,
|
// UpperOrderNo = outboundOrder.UpperOrderNo,
|
// OrderNo = outboundOrder.OrderNo,
|
// OutWareHouse = outboundOrder.OutWareHouse,
|
// TransactionCode = outboundOrder.TransactionCode,
|
// InoutType = outboundOrder.InoutType,
|
// OrderType = outboundOrder.OrderType,
|
// Creater = "WMS",
|
// CreateDate = DateTime.Now,
|
// };
|
// _outboundOrder_HtyService.AddData(history);
|
// _outboundService.OutboundOrderService.DeleteData(outboundOrder);
|
//}
|
|
//MoveOutboundDetailToHistory(outDetail);
|
|
// 发送出库信息到WMS
|
if (outboundOrder.OrderStatus == OutboundStatusEnum.出库完成.ObjToInt() && outboundOrder.OrderType == 1)
|
{
|
//SendNormalOutboundToWMS(task, outboundOrder, stockInfoDetail, outDetail);
|
}
|
else if (outboundOrder.OrderStatus == OutboundStatusEnum.出库完成.ObjToInt() && outboundOrder.OrderType == 2)
|
{
|
SendAllocateOutboundToWMS(task, outboundOrder, stockInfoDetail, outDetail);
|
}
|
|
|
// 删除库存信息
|
//DeleteStockInfo(stockInfo);
|
}
|
|
private void ProcessAllocateOutbound(Dt_Task task, Dt_StockInfo stockInfo,
|
Dt_OutboundOrder outboundOrder, Dt_OutboundOrderDetail outDetail)
|
{
|
var relatedStockInfos = _stockService.StockInfoService.Repository.QueryData(x => x.BatchNo == outDetail.BatchNo);
|
|
if (outboundOrder.Details.Count == 1)
|
{
|
var history = new Dt_OutboundOrder_Hty
|
{
|
OrderStatus = outboundOrder.OrderStatus,
|
CreateType = outboundOrder.CreateType,
|
UpperOrderNo = outboundOrder.UpperOrderNo,
|
OrderNo = outboundOrder.OrderNo,
|
OutWareHouse = outboundOrder.OutWareHouse,
|
TransactionCode = outboundOrder.TransactionCode,
|
InoutType = outboundOrder.InoutType,
|
OrderType = outboundOrder.OrderType,
|
Creater = "WMS",
|
CreateDate = DateTime.Now,
|
};
|
_outboundOrder_HtyService.AddData(history);
|
_outboundService.OutboundOrderService.DeleteData(outboundOrder);
|
}
|
|
MoveOutboundDetailToHistory(outDetail);
|
|
// 发送调拨出库信息到WMS
|
|
|
// 删除库存信息
|
DeleteStockInfo(stockInfo);
|
}
|
|
|
private void MoveOutboundDetailToHistory(Dt_OutboundOrderDetail outDetail)
|
{
|
var detailHistory = new Dt_OutboundOrderDetail_Hty
|
{
|
OrderId = outDetail.OrderId,
|
MaterielCode = outDetail.MaterielCode,
|
MaterielName = outDetail.MaterielName,
|
BatchNo = outDetail.BatchNo,
|
OrderQuantity = outDetail.OrderQuantity,
|
OrderDetailStatus = outDetail.OrderDetailStatus,
|
Creater = "WMS",
|
CreateDate = DateTime.Now,
|
};
|
_outboundOrderDetail_HtyService.AddData(detailHistory);
|
_outboundService.OutboundOrderService.DeleteData(outDetail);
|
}
|
|
private WebResponseContent SendNormalOutboundToWMS(Dt_Task task, Dt_OutboundOrder outboundOrder,
|
Dt_StockInfoDetail stockInfoDetail, Dt_OutboundOrderDetail outDetail)
|
{
|
|
//List<Dt_StockInfo> StockInfos = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.WarehouseId == task.WarehouseId).Includes(x => x.Details).Where(x => x.Details.Any(v => v.BatchNo == outDetail.BatchNo)).ToList();
|
List<Dt_OutStockLockInfo> outStockLockInfos = _outboundService.OutboundStockLockInfoService.Repository.QueryData(x => x.OrderNo == outboundOrder.OrderNo);
|
|
if (outStockLockInfos.Count == 0) throw new Exception("未找到库存信息");
|
|
// 构建回传数据，将所有匹配的库存明细加入 DetailList
|
var passBack = new HouseoutboundPassBack
|
{
|
ApiType = "ShippingOrderController",
|
Method = "AsrsOutboundSO",
|
Parameters = new List<HouseoutboundPassBack.datas>
|
{
|
new HouseoutboundPassBack.datas
|
{
|
Value = new List<HouseoutboundPassBack.datas.data1>
|
{
|
new HouseoutboundPassBack.datas.data1
|
{
|
No = outboundOrder.OrderNo,
|
OutWareHouse = task.Roadway,
|
TransactionCode = outboundOrder.TransactionCode,
|
InoutType = outboundOrder.OrderType,
|
OrderType = outboundOrder.InoutType,
|
DetailList = outStockLockInfos.Select(d => new HouseoutboundPassBack.datas.data1.Inbound
|
{
|
LinId = d.LinId?? "",
|
LPN_No = d.PalletCode,
|
MaterielCode = d.MaterielCode?? "",
|
OrderQuantity = d.OrderQuantity,
|
BatchNo = d.BatchNo,
|
FinishQty = d.OrderQuantity,
|
LocationName = d.LocationCode
|
})
|
.ToList()
|
|
}
|
}
|
}
|
}
|
};
|
|
var authResult = AuthenticateWithWMS();
|
if (authResult.IsSuccess)
|
{
|
passBack.Context = new Dictionary<string, string>
|
{
|
{ "Ticket", authResult.Ticket },
|
{ "InvOrgId", authResult.InvOrgId }
|
};
|
|
var response = HttpHelper.Post<MomRequestContent>(ReceiveWMSTaskout, passBack, "立库出库数量回传WMS");
|
// 判断Success的值
|
if (response.Success)
|
{
|
// 如果Success为true，返回需要的值（这里以返回整个响应对象为例）
|
return WebResponseContent.Instance.OK();
|
}
|
else
|
{
|
// 如果Success为false，抛出异常并包含错误信息
|
throw new Exception($"操作失败: {response.Message ?? "未提供错误信息"}");
|
}
|
|
}
|
return WebResponseContent.Instance.OK();
|
}
|
|
private void SendAllocateOutboundToWMS(Dt_Task task, Dt_OutboundOrder outboundOrder,
|
Dt_StockInfoDetail stockInfoDetail, Dt_OutboundOrderDetail outDetail)
|
{
|
List<Dt_OutStockLockInfo> outStockLockInfos = _outboundService.OutboundStockLockInfoService.Repository.QueryData(x => x.OrderNo == outboundOrder.OrderNo);
|
|
|
if (outStockLockInfos.Count == 0) throw new Exception("未找到库存信息");
|
var allocate = new InventoryAllocate
|
{
|
ApiType = "InventoryAllocateController",
|
Method = "AsrsFinishedStockCount",
|
Parameters = new List<Allocate>
|
{
|
new Allocate
|
{
|
Value = new List<Allocate.data1>
|
{
|
new Allocate.data1
|
{
|
No = outboundOrder.OrderNo,
|
InWarehouse = task.Roadway,
|
TransactionCode = outboundOrder.TransactionCode,
|
InoutType = outboundOrder.OrderType,
|
OrderType = outboundOrder.InoutType,
|
DetailList = outStockLockInfos.Select(item =>
|
{
|
//var detail = _stockService.StockInfoDetailService.Repository.QueryFirst(x => x.StockId == item.StockId);
|
return new Allocate.data1.Inventory
|
{
|
LinId = outDetail.LinId,
|
LPNNo = item.PalletCode,
|
MaterielCode = outDetail.MaterielCode,
|
OrderQuantity = outDetail.OrderQuantity,
|
BatchNo = outDetail.BatchNo,
|
FinishQty = outDetail.OrderQuantity,
|
LocationName = task.SourceAddress
|
};
|
}).ToList()
|
}
|
}
|
}
|
}
|
};
|
|
var authResult = AuthenticateWithWMS();
|
if (authResult.IsSuccess)
|
{
|
allocate.Context = new Dictionary<string, string>
|
{
|
{ "Ticket", authResult.Ticket },
|
{ "InvOrgId", authResult.InvOrgId }
|
};
|
|
HttpHelper.Post<WebResponseContent>(ReceiveWMSTaskin, allocate, "立库入库数量回传WMS");
|
}
|
}
|
|
private void DeleteStockInfo(Dt_StockInfo stockInfo)
|
{
|
_stockService.StockInfoService.Repository.DeleteAndMoveIntoHty(stockInfo,
|
App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
_stockService.StockInfoDetailService.Repository.DeleteAndMoveIntoHty(stockInfo.Details,
|
App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
}
|
|
private void AddRetrueOrder(Dt_StockInfo stockInfo, Dt_OutboundOrder outboundOrder)
|
{
|
Dt_StockInfoDetail stockInfoDetail = _stockService.StockInfoDetailService.Db.Queryable<Dt_StockInfoDetail>()
|
.Where(x => x.StockId == stockInfo.Id)
|
.First();
|
if (stockInfoDetail == null)
|
{
|
throw new Exception("建立回库单时，未找到该库存信息");
|
}
|
if (outboundOrder.OrderType == OrderTypeEnum.反拣出库单.ObjToInt())
|
{
|
Dt_ReturnOrder returnOrder = _returnOrderRepository.QueryFirst(x => x.LPNNo == stockInfo.PalletCode && x.LocationCode == stockInfo.LocationCode && x.OrderStatus == InOrderStatusEnum.未开始.ObjToInt());
|
if (returnOrder == null)
|
{
|
throw new Exception("反拣出库后，未找到对应反拣回库单信息");
|
}
|
stockInfo.LocationCode = "";
|
stockInfo.StockStatus = StockStatusEmun.反拣入库.ObjToInt();
|
stockInfo.Remark = "反拣入库";
|
stockInfoDetail.OutboundQuantity = 0;
|
stockInfoDetail.StockQuantity += returnOrder.OrderQuantity;
|
stockInfoDetail.OrderNo = returnOrder.OrderNo;
|
}
|
else
|
{
|
decimal returnQuantity = stockInfoDetail.StockQuantity - stockInfoDetail.OutboundQuantity;
|
if (returnQuantity > 0)
|
{
|
Dt_ReturnOrder returnOrder = new Dt_ReturnOrder
|
{
|
MaterielCode = stockInfoDetail.MaterielCode,
|
MaterielName = stockInfoDetail.MaterielName,
|
BatchNo = stockInfoDetail.BatchNo,
|
OrderQuantity = returnQuantity,
|
ReceiptQuantity = returnQuantity,
|
OrderStatus = InOrderStatusEnum.未开始.ObjToInt(),
|
LinId = stockInfoDetail.LinId,
|
LPNNo = stockInfo.PalletCode,
|
Creater = "LK",
|
CreateDate = DateTime.Now,
|
OrderType = OrderTypeEnum.余料回库单.ObjToInt(),
|
System = "WMS"
|
};
|
if (outboundOrder.System == "SMOM" && stockInfo.LocationCode != null)
|
{
|
returnOrder.LocationCode = stockInfo.LocationCode;
|
}
|
_unitOfWorkManage.BeginTran();
|
_returnOrderRepository.AddData(returnOrder);
|
stockInfo.LocationCode = "";
|
stockInfo.StockStatus = StockStatusEmun.余料退库.ObjToInt();
|
stockInfo.Remark = "余料退库";
|
stockInfoDetail.OutboundQuantity = 0;
|
stockInfoDetail.StockQuantity = returnQuantity;
|
stockInfoDetail.OrderNo = returnOrder.OrderNo;
|
_stockService.StockInfoService.Repository.UpdateData(stockInfo);
|
_stockService.StockInfoDetailService.Repository.UpdateData(stockInfoDetail);
|
_unitOfWorkManage.CommitTran();
|
}
|
else
|
{
|
DeleteAndMoveIntoHtStockStatus(stockInfo);
|
}
|
}
|
|
}
|
|
//成品回库单
|
private void AddCPRetrueOrder(Dt_StockInfo stockInfo, Dt_NewOutboundOrder outboundOrder, List<Dt_NewOutboundOrderDetail> outboundOrderDetails)
|
{
|
List<Dt_StockInfoDetail> stockInfoDetails = _stockService.StockInfoDetailService.Db.Queryable<Dt_StockInfoDetail>()
|
.Where(x => x.StockId == stockInfo.Id)
|
.ToList();
|
|
if (stockInfoDetails == null || stockInfoDetails.Count == 0)
|
{
|
throw new Exception("建立回库单时，未找到该库存信息");
|
}
|
_unitOfWorkManage.BeginTran();
|
try
|
{
|
if (outboundOrder.OrderType == OrderTypeEnum.反拣出库单.ObjToInt())
|
{
|
Dt_ReturnOrder returnOrder = _returnOrderRepository.QueryFirst(x =>
|
x.LPNNo == stockInfo.PalletCode &&
|
x.LocationCode == stockInfo.LocationCode &&
|
x.OrderStatus == InOrderStatusEnum.未开始.ObjToInt());
|
|
if (returnOrder == null)
|
{
|
throw new Exception("反拣出库后，未找到对应反拣回库单信息");
|
}
|
foreach (var outDetail in outboundOrderDetails)
|
{
|
var matchedStockDetail = stockInfoDetails.FirstOrDefault(x => x.MaterielCode == outDetail.MaterielCode && x.BatchNo == outDetail.BatchNo);
|
if (matchedStockDetail == null)
|
{
|
matchedStockDetail = stockInfoDetails.FirstOrDefault(x =>
|
x.MaterielCode == outDetail.MaterielCode);
|
|
if (matchedStockDetail == null)
|
{
|
throw new Exception($"未找到匹配的库存明细信息，物料:{outDetail.MaterielCode}, 批次:{outDetail.BatchNo}");
|
}
|
}
|
// 只减去单据明细中的数量
|
matchedStockDetail.OutboundQuantity = 0;
|
matchedStockDetail.StockQuantity = outDetail.OrderQuantity;
|
matchedStockDetail.OrderNo = returnOrder.OrderNo;
|
// 更新匹配的明细
|
_stockService.StockInfoDetailService.Repository.UpdateData(matchedStockDetail);
|
}
|
|
|
// 更新库存状态
|
stockInfo.LocationCode = "";
|
stockInfo.StockStatus = StockStatusEmun.反拣入库.ObjToInt();
|
stockInfo.Remark = "反拣入库";
|
_stockService.StockInfoService.Repository.UpdateData(stockInfo);
|
}
|
else
|
{
|
var groupedDetails = outboundOrderDetails
|
.GroupBy(d => new { d.MaterielCode, d.BatchNo })
|
.ToList();
|
List<Dt_StockInfoDetail> processedStockDetails = new List<Dt_StockInfoDetail>();
|
List<Dt_ReturnOrder> returnOrders = new List<Dt_ReturnOrder>();
|
|
decimal totalOutboundQuantity = outboundOrderDetails.Sum(x => x.OrderQuantity);
|
decimal totalStockQuantity = stockInfoDetails.Sum(x => x.StockQuantity);
|
|
foreach (var groupeDetail in groupedDetails)
|
{
|
var outboundDetail = groupeDetail.First();
|
decimal totalOrderQuantity = groupeDetail.Sum(x => x.OrderQuantity);
|
var matchedStockDetail = stockInfoDetails.FirstOrDefault(x => x.MaterielCode == outboundDetail.MaterielCode && x.BatchNo == outboundDetail.BatchNo);
|
if (matchedStockDetail == null)
|
{
|
matchedStockDetail = stockInfoDetails.FirstOrDefault(x =>
|
x.MaterielCode == outboundDetail.MaterielCode);
|
|
if (matchedStockDetail == null)
|
{
|
throw new Exception($"未找到匹配的库存明细信息，物料:{outboundDetail.MaterielCode}, 批次:{outboundDetail.BatchNo}");
|
}
|
}
|
// 计算当前批次的剩余数量
|
decimal remainingQuantity = matchedStockDetail.StockQuantity - totalOrderQuantity;
|
|
if (remainingQuantity > 0)
|
{
|
Dt_ReturnOrder returnOrder = new Dt_ReturnOrder
|
{
|
MaterielCode = matchedStockDetail.MaterielCode,
|
MaterielName = matchedStockDetail.MaterielName,
|
BatchNo = matchedStockDetail.BatchNo,
|
OrderQuantity = remainingQuantity,
|
ReceiptQuantity = remainingQuantity,
|
OrderStatus = InOrderStatusEnum.未开始.ObjToInt(),
|
LinId = matchedStockDetail.LinId,
|
LPNNo = stockInfo.PalletCode,
|
Creater = "LK",
|
CreateDate = DateTime.Now,
|
OrderType = OrderTypeEnum.余料回库单.ObjToInt(),
|
System = "WMS",
|
Remark = "多批次返库" // 添加备注标识
|
};
|
|
if (outboundOrder.System == "SMOM" && stockInfo.LocationCode != null)
|
{
|
returnOrder.LocationCode = stockInfo.LocationCode;
|
}
|
|
// 添加返库单
|
returnOrders.Add(returnOrder);
|
|
// 更新当前批次明细：只保留出库数量，其余返库
|
matchedStockDetail.StockQuantity = outboundDetail.OrderQuantity;
|
matchedStockDetail.OutboundQuantity = outboundDetail.OrderQuantity;
|
//matchedStockDetail.OrderNo = returnOrder.OrderNo;
|
}
|
else if (remainingQuantity == 0)
|
{
|
// 当前批次正好出完
|
matchedStockDetail.OutboundQuantity = matchedStockDetail.StockQuantity;
|
if (matchedStockDetail.StockQuantity == totalOrderQuantity)
|
{
|
_stockService.StockInfoDetailService.Repository.DeleteAndMoveIntoHty(
|
matchedStockDetail, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
}
|
else
|
{
|
matchedStockDetail.StockQuantity = 0;
|
_stockService.StockInfoDetailService.Repository.UpdateData(matchedStockDetail);
|
}
|
}
|
else
|
{
|
throw new Exception($"出库数量 {outboundDetail.OrderQuantity} 大于库存数量 {matchedStockDetail.StockQuantity}");
|
}
|
processedStockDetails.Add(matchedStockDetail);
|
}
|
|
// 处理其他批次的库存明细（全部返库）
|
var otherBatchDetails = stockInfoDetails
|
.Where(x => !processedStockDetails.Contains(x) && x.StockQuantity > 0)
|
.ToList();
|
|
if (otherBatchDetails.Count > 0)
|
{
|
decimal totalOtherQuantity = otherBatchDetails.Sum(x => x.StockQuantity);
|
|
// 为其他批次创建返库单（只创建一个，包含所有批次）
|
var firstOtherDetail = otherBatchDetails.First();
|
Dt_ReturnOrder otherReturnOrder = new Dt_ReturnOrder
|
{
|
MaterielCode = firstOtherDetail.MaterielCode,
|
MaterielName = firstOtherDetail.MaterielName,
|
BatchNo = firstOtherDetail.BatchNo,
|
OrderQuantity = totalOtherQuantity,
|
ReceiptQuantity = totalOtherQuantity,
|
OrderStatus = InOrderStatusEnum.未开始.ObjToInt(),
|
LinId = firstOtherDetail.LinId,
|
LPNNo = stockInfo.PalletCode,
|
Creater = "LK",
|
CreateDate = DateTime.Now,
|
OrderType = OrderTypeEnum.余料回库单.ObjToInt(),
|
System = "WMS",
|
Remark = $"多批次返库，共{otherBatchDetails.Count}个批次"
|
};
|
|
if (outboundOrder.System == "SMOM" && !string.IsNullOrEmpty(stockInfo.LocationCode))
|
{
|
otherReturnOrder.LocationCode = stockInfo.LocationCode;
|
}
|
|
|
returnOrders.Add(otherReturnOrder);
|
}
|
|
// 批量更新已处理的库存明细
|
var updateDetails = processedStockDetails.Where(x => x.StockQuantity > 0).ToList();
|
if (updateDetails.Any())
|
{
|
_stockService.StockInfoDetailService.Repository.UpdateData(updateDetails);
|
}
|
|
// 添加返库单
|
if (returnOrders.Any())
|
{
|
_returnOrderRepository.AddData(returnOrders);
|
}
|
|
// 更新库存主表状态
|
decimal returnQuantity = totalStockQuantity - totalOutboundQuantity;
|
if (returnQuantity == 0)
|
{
|
if (outboundOrder.System == "SMOM" && stockInfo.LocationCode != null)
|
{
|
Dt_LocationInfo dt_LocationInfo = _locationInfoService.Repository.QueryFirst(x => x.LocationCode == stockInfo.LocationCode);
|
dt_LocationInfo.LocationStatus = LocationStatusEnum.Free.ObjToInt();
|
_basicRepository.LocationInfoRepository.UpdateData(dt_LocationInfo);
|
}
|
// 全部出库，删除库存
|
DeleteAndMoveIntoHtStockStatus(stockInfo);
|
foreach (var item in stockInfo.Details)
|
{
|
BaseDal.Db.Deleteable(item.StockDetails).ExecuteCommand();
|
}
|
}
|
else if (returnQuantity > 0)
|
{
|
// 有余料返库
|
stockInfo.LocationCode = "";
|
stockInfo.StockStatus = StockStatusEmun.余料退库.ObjToInt();
|
stockInfo.Remark = $"余料退库，共{returnOrders.Count}个返库单";
|
_stockService.StockInfoService.Repository.UpdateData(stockInfo);
|
}
|
|
}
|
_unitOfWorkManage.CommitTran();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
throw;
|
}
|
|
}
|
|
/// <summary>
|
/// 单据明细出库完成回调ERP(表单提交)
|
/// </summary>
|
/// <param name="outboundOrder"></param>
|
/// <param name="outboundOrderDetail"></param>
|
/// <returns></returns>
|
/// <exception cref="Exception"></exception>
|
public WebResponseContent FeedBackOutERP(string orderNO, string linId)
|
{
|
Dt_OutStockLockInfo outStockLockInfos = _outboundService.OutboundStockLockInfoService.Repository.QueryFirst(x => x.OrderNo == orderNO && x.LinId == linId);
|
if (outStockLockInfos == null)
|
{
|
return WebResponseContent.Instance.Error("未找到出库库存信息");
|
}
|
var postContent = new MultipartFormDataContent();
|
postContent.Headers.Add("ContentType", $"multipart/form-data");
|
postContent.Add(new StringContent(outStockLockInfos.LinId), "ids");
|
string result = string.Empty;
|
HttpClient client = null;
|
try
|
{
|
using (client = new HttpClient())
|
{
|
HttpResponseMessage response = client.PostAsync(ReceiveERPTaskout, postContent)
|
.ConfigureAwait(false).GetAwaiter().GetResult();
|
|
// 确保响应成功
|
response.EnsureSuccessStatusCode();
|
|
result = response.Content.ReadAsStringAsync()
|
.ConfigureAwait(false).GetAwaiter().GetResult();
|
}
|
|
// 假设ERP返回成功时返回成功响应
|
return WebResponseContent.Instance.OK(result);
|
}
|
catch (HttpRequestException ex)
|
{
|
// 处理HTTP请求相关异常
|
return WebResponseContent.Instance.Error($"HTTP请求错误: {ex.Message}");
|
}
|
catch (Exception ex)
|
{
|
// 处理其他异常
|
return WebResponseContent.Instance.Error($"处理失败: {ex.Message}");
|
}
|
|
|
}
|
|
public WebResponseContent FeedBackInboundERP(string upperOrderNo, string linId)
|
{
|
if (upperOrderNo == null)
|
{
|
return WebResponseContent.Instance.Error("未找到入库单信息");
|
}
|
List<FeedbackInboundOrderERP> feedbackInboundOrderERPs = new List<FeedbackInboundOrderERP>();
|
|
FeedbackInboundOrderERP feedbackInboundOrder = new FeedbackInboundOrderERP()
|
{
|
code = upperOrderNo,
|
itemId = linId,
|
success = true
|
|
};
|
feedbackInboundOrderERPs.Add(feedbackInboundOrder);
|
var response = HttpHelper.Post<WebResponseContent>(InMaterialWarehousingCallback, feedbackInboundOrderERPs, "入库单完成回传ERP");
|
// 判断Success的值
|
if (response.Code == 0)
|
{
|
// 如果Success为true，返回需要的值（这里以返回整个响应对象为例）
|
return WebResponseContent.Instance.OK();
|
}
|
else
|
{
|
// 如果Success为false，抛出异常并包含错误信息
|
throw new Exception($"操作失败: {response.Message ?? "未提供错误信息"}");
|
}
|
}
|
// 方法声明添加 async 关键字，返回值改为 Task<string>
|
public async Task<string> DownloadReport(string path, string savePath, int orderId)
|
{
|
string reportUrl = path + "&orderId=" + orderId;
|
|
try
|
{
|
string directory = Path.GetDirectoryName(savePath);
|
Console.WriteLine($"下载地址: {reportUrl}");
|
Console.WriteLine($"保存路径: {savePath}");
|
|
// 确保目录存在
|
if (!Directory.Exists(directory))
|
{
|
Directory.CreateDirectory(directory);
|
Console.WriteLine($"已创建目录: {directory}");
|
}
|
|
// 清理目录下现有文件
|
if (File.Exists(savePath))
|
{
|
File.Delete(savePath);
|
Console.WriteLine($"已删除旧文件: {savePath}");
|
}
|
|
// 使用临时文件名下载，下载完成后再重命名
|
string tempFilePath = savePath + ".tmp";
|
|
// 异步下载文件
|
using (var httpClient = new HttpClient())
|
{
|
httpClient.Timeout = TimeSpan.FromMinutes(5);
|
|
using (var response = await httpClient.GetAsync(reportUrl, HttpCompletionOption.ResponseHeadersRead).ConfigureAwait(false))
|
{
|
response.EnsureSuccessStatusCode();
|
|
using (var contentStream = await response.Content.ReadAsStreamAsync().ConfigureAwait(false))
|
{
|
Console.WriteLine($"开始写入临时文件: {tempFilePath}");
|
|
using (var fileStream = new FileStream(
|
tempFilePath,
|
FileMode.Create,
|
FileAccess.Write,
|
FileShare.None,
|
bufferSize: 4096,
|
useAsync: true
|
))
|
{
|
await contentStream.CopyToAsync(fileStream).ConfigureAwait(false);
|
await fileStream.FlushAsync().ConfigureAwait(false);
|
Console.WriteLine($"临时文件写入完成: {tempFilePath}");
|
}
|
}
|
}
|
}
|
|
// 关键优化：确保文件完全写入磁盘
|
await EnsureFileCompletelyWritten(tempFilePath);
|
|
// 重命名为目标文件
|
File.Move(tempFilePath, savePath, true);
|
Console.WriteLine($"文件重命名完成: {savePath}");
|
|
// 验证文件可访问
|
await ValidateFileAccessible(savePath);
|
|
// 打印文件
|
PrintTestDirect(savePath);
|
|
return savePath;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"下载失败: {ex.Message}");
|
throw new InvalidOperationException($"文件下载异常: {ex.Message}", ex);
|
}
|
}
|
|
/// <summary>
|
/// 确保文件完全写入磁盘
|
/// </summary>
|
private async Task EnsureFileCompletelyWritten(string filePath)
|
{
|
const int maxRetries = 5;
|
const int delayMs = 500;
|
|
for (int i = 0; i < maxRetries; i++)
|
{
|
try
|
{
|
// 尝试以读取模式打开文件，确保文件没有被占用
|
using (var fs = new FileStream(filePath,
|
FileMode.Open,
|
FileAccess.Read,
|
FileShare.Read,
|
bufferSize: 4096,
|
useAsync: true))
|
{
|
// 验证文件有内容
|
if (fs.Length > 0)
|
{
|
Console.WriteLine($"文件验证成功: 大小={fs.Length}字节 (尝试 {i + 1}/{maxRetries})");
|
return;
|
}
|
else
|
{
|
Console.WriteLine($"警告: 文件大小为0 (尝试 {i + 1}/{maxRetries})");
|
}
|
}
|
}
|
catch (IOException ex)
|
{
|
Console.WriteLine($"文件可能仍在写入中 (尝试 {i + 1}/{maxRetries}): {ex.Message}");
|
}
|
|
if (i < maxRetries - 1)
|
{
|
await Task.Delay(delayMs);
|
}
|
}
|
|
throw new IOException($"文件写入未完成或无法访问: {filePath}");
|
}
|
|
/// <summary>
|
/// 验证文件可访问且不为空
|
/// </summary>
|
private async Task ValidateFileAccessible(string filePath)
|
{
|
const int maxRetries = 3;
|
const int delayMs = 300;
|
|
for (int i = 0; i < maxRetries; i++)
|
{
|
try
|
{
|
if (!File.Exists(filePath))
|
{
|
throw new FileNotFoundException($"文件不存在: {filePath}");
|
}
|
|
var fileInfo = new FileInfo(filePath);
|
|
// 验证文件大小大于0
|
if (fileInfo.Length == 0)
|
{
|
throw new InvalidDataException($"文件大小为0: {filePath}");
|
}
|
|
// 验证文件不是完全由空字符组成（可选检查）
|
await ValidateFileContent(filePath);
|
|
Console.WriteLine($"文件验证通过: {filePath} (大小={fileInfo.Length}字节)");
|
return;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"文件验证失败 (尝试 {i + 1}/{maxRetries}): {ex.Message}");
|
|
if (i == maxRetries - 1)
|
{
|
throw;
|
}
|
|
await Task.Delay(delayMs);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 验证文件内容（可选）
|
/// </summary>
|
private async Task ValidateFileContent(string filePath)
|
{
|
try
|
{
|
// 读取文件前几个字节，确保不是完全由空字符组成
|
using (var fs = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.Read, 4096, true))
|
{
|
byte[] buffer = new byte[Math.Min(1024, fs.Length)];
|
int bytesRead = await fs.ReadAsync(buffer, 0, buffer.Length);
|
|
// 检查是否都是0（空文件）
|
if (bytesRead > 0 && buffer.All(b => b == 0))
|
{
|
throw new InvalidDataException("文件内容异常: 全部为0字节");
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"文件内容验证异常: {ex.Message}");
|
// 可以选择是否抛出异常
|
}
|
}
|
|
public virtual void PrintTestDirect(string fullPath)
|
{
|
const int maxRetryCount = 3;
|
const int retryDelayMs = 1000;
|
|
if (!File.Exists(fullPath))
|
{
|
Console.WriteLine($"打印失败：文件不存在 {fullPath}");
|
return;
|
}
|
|
// 获取打印机名称
|
string printerName = AppSettings.app("PrinterName");
|
|
PrintUsingSpireSimple(fullPath, printerName);
|
|
|
Console.WriteLine("所有打印方法都失败");
|
}
|
|
|
private void PrintUsingSpireSimple(string filePath, string printerName)
|
{
|
try
|
{
|
using (Spire.Pdf.PdfDocument pdf = new Spire.Pdf.PdfDocument())
|
{
|
// 加载文件
|
pdf.LoadFromFile(filePath);
|
|
// 获取实际的打印机名称
|
string actualPrinterName = GetActualPrinterName(printerName);
|
|
Console.WriteLine($"配置的打印机名称: {printerName}");
|
Console.WriteLine($"实际使用的打印机名称: {actualPrinterName}");
|
|
// 如果找不到实际打印机，使用默认打印机
|
if (!string.IsNullOrEmpty(actualPrinterName) && IsPrinterInstalled(actualPrinterName))
|
{
|
pdf.PrintSettings.PrinterName = actualPrinterName;
|
Console.WriteLine($"✓ 已设置打印机: {actualPrinterName}");
|
}
|
else
|
{
|
Console.WriteLine($"⚠️ 打印机 '{actualPrinterName}' 未找到，使用默认打印机");
|
}
|
|
// 直接打印
|
pdf.Print();
|
Console.WriteLine("✓ 打印任务已提交成功");
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"✗ Spire.PDF打印失败: {ex.Message}");
|
|
// 输出所有可用打印机，帮助调试
|
Console.WriteLine("\n系统所有可用打印机:");
|
foreach (string printer in System.Drawing.Printing.PrinterSettings.InstalledPrinters)
|
{
|
Console.WriteLine($" - {printer}");
|
}
|
|
throw;
|
}
|
}
|
|
/// <summary>
|
/// 从配置的友好名称获取实际的打印机名称
|
/// </summary>
|
private string GetActualPrinterName(string displayName)
|
{
|
if (string.IsNullOrEmpty(displayName))
|
return string.Empty;
|
|
// 如果配置的是 "192.168.99.3 上的 Lenovo M7605D"
|
if (displayName.Contains("192.168.99.3 上的 Lenovo M7605D"))
|
{
|
// 在系统中查找实际的打印机名称
|
return FindActualPrinterForIP("192.168.99.3");
|
}
|
|
// 如果直接配置的是IP地址
|
if (displayName.Contains("192.168.99.3"))
|
{
|
return FindActualPrinterForIP("192.168.99.3");
|
}
|
|
// 如果已经是实际的打印机名称，直接返回
|
if (IsPrinterInstalled(displayName))
|
{
|
return displayName;
|
}
|
|
// 默认返回原名称
|
return displayName;
|
}
|
|
/// <summary>
|
/// 查找IP地址对应的实际打印机名称
|
/// </summary>
|
private string FindActualPrinterForIP(string ipAddress)
|
{
|
try
|
{
|
// 获取所有打印机
|
var allPrinters = new List<string>();
|
foreach (string printer in System.Drawing.Printing.PrinterSettings.InstalledPrinters)
|
{
|
allPrinters.Add(printer);
|
}
|
|
Console.WriteLine($"查找IP地址 {ipAddress} 对应的打印机...");
|
Console.WriteLine("系统打印机列表:");
|
foreach (var printer in allPrinters)
|
{
|
Console.WriteLine($" - {printer}");
|
}
|
|
// 优先查找包含IP地址的打印机
|
foreach (string printer in allPrinters)
|
{
|
if (printer.Contains(ipAddress))
|
{
|
Console.WriteLine($"✓ 找到包含IP的打印机: {printer}");
|
return printer;
|
}
|
}
|
|
// 查找联想打印机
|
foreach (string printer in allPrinters)
|
{
|
if (printer.Contains("M7605D", StringComparison.OrdinalIgnoreCase)
|
{
|
Console.WriteLine($"✓ 找到联想打印机: {printer}");
|
return printer;
|
}
|
}
|
|
|
// 返回第一个可用的打印机
|
if (allPrinters.Any())
|
{
|
Console.WriteLine($"⚠️ 未找到精确匹配，使用第一个打印机: {allPrinters.First()}");
|
return allPrinters.First();
|
}
|
|
return string.Empty;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"查找打印机失败: {ex.Message}");
|
return string.Empty;
|
}
|
}
|
|
/// <summary>
|
/// 检查打印机是否已安装
|
/// </summary>
|
private bool IsPrinterInstalled(string printerName)
|
{
|
try
|
{
|
foreach (string printer in System.Drawing.Printing.PrinterSettings.InstalledPrinters)
|
{
|
if (printer.Equals(printerName, StringComparison.OrdinalIgnoreCase))
|
{
|
return true;
|
}
|
}
|
return false;
|
}
|
catch
|
{
|
return false;
|
}
|
}
|
/// <summary>
|
/// 使用原始打印命令
|
/// </summary>
|
private void PrintUsingRawCommand(string filePath, string printerName)
|
{
|
try
|
{
|
var processStartInfo = new System.Diagnostics.ProcessStartInfo
|
{
|
FileName = filePath,
|
Verb = "print", // 使用"print"动词
|
UseShellExecute = true, // 关键：启用Shell执行
|
CreateNoWindow = true,
|
WindowStyle = System.Diagnostics.ProcessWindowStyle.Hidden
|
};
|
|
// 设置打印机（可选，系统通常会使用默认打印机）
|
// processStartInfo.Arguments = $"/t \"{filePath}\" \"{printerName}\"";
|
|
System.Diagnostics.Process.Start(processStartInfo);
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"打印失败: {ex.Message}");
|
// 可以尝试其他方法
|
//TryAlternativePrintMethod(filePath, printerName);
|
}
|
}
|
|
|
/// <summary>
|
/// 检查文件是否可访问
|
/// </summary>
|
private bool IsFileAccessible(string filePath)
|
{
|
try
|
{
|
using (FileStream fs = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
|
{
|
return fs.Length > 0;
|
}
|
}
|
catch
|
{
|
return false;
|
}
|
}
|
|
/// <summary>
|
/// 尝试强制垃圾回收，释放可能存在的文件句柄
|
/// </summary>
|
private void TryForceGarbageCollection()
|
{
|
try
|
{
|
GC.Collect();
|
GC.WaitForPendingFinalizers();
|
Console.WriteLine("已执行垃圾回收");
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"垃圾回收失败: {ex.Message}");
|
}
|
}
|
|
|
/// <summary>
|
/// 盘点出库完成
|
/// </summary>
|
public WebResponseContent OutInventoryCompleted(Dt_Task task, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
//获取对应盘点单
|
Dt_TakeStockOrder takeStockOrder = _inboundRepository.TakeStockOrderRepository.Db.Queryable<Dt_TakeStockOrder>().Where(x => x.OrderNo == task.OrderNo).Includes(x => x.Details).First();
|
if (takeStockOrder == null)
|
{
|
return content.Error($"盘点单{task.OrderNo}不存在");
|
}
|
if (takeStockOrder.TakeStockStatus != TakeStockStatusEnum.盘点中.ObjToInt())
|
{
|
return content.Error($"盘点单{task.OrderNo}盘点已完成或未开始");
|
}
|
if (stockInfo.StockStatus != StockStatusEmun.出库锁定.ObjToInt())
|
{
|
return content.Error($"{stockInfo.PalletCode}库存状态不正确");
|
}
|
if (locationInfo.LocationStatus != LocationStatusEnum.Lock.ObjToInt())
|
{
|
return content.Error($"{locationInfo.LocationCode}货位状态不正确");
|
}
|
//根据任务托盘查盘点明细
|
Dt_TakeStockOrderDetail? takeStockOrderDetail = takeStockOrder.Details.FirstOrDefault(x => x.TakePalletCode == stockInfo.PalletCode);
|
if (takeStockOrderDetail == null)
|
{
|
return content.Error($"{stockInfo.PalletCode}未找到对应盘点明细");
|
}
|
if (takeStockOrderDetail.TakeDetalStatus != TakeStockDetailStatusEnum.盘点出库中.ObjToInt())
|
{
|
return content.Error($"{stockInfo.PalletCode}盘点明细状态不正确");
|
}
|
takeStockOrderDetail.TakeDetalStatus = TakeStockDetailStatusEnum.盘点出库完成.ObjToInt();
|
stockInfo.StockStatus = StockStatusEmun.盘点出库完成.ObjToInt();
|
stockInfo.Details.ForEach(x =>
|
{
|
x.Status = StockStatusEmun.盘点出库完成.ObjToInt();
|
});
|
stockInfo.LocationCode = "";
|
task.TaskStatus = TaskStatusEnum.Finish.ObjToInt();
|
int beforeStatus = locationInfo.LocationStatus;
|
locationInfo.LocationStatus = LocationStatusEnum.Free.ObjToInt();
|
_unitOfWorkManage.BeginTran();
|
//货位变动记录
|
_basicService.LocationInfoService.UpdateData(locationInfo);
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, LocationStatusEnum.Free.ObjToInt(), LocationChangeType.OutboundCompleted.ObjToInt(), takeStockOrder?.OrderNo ?? "", task.TaskNum);
|
_inboundRepository.TakeStockOrderDetailRepository.UpdateData(takeStockOrderDetail);
|
_stockRepository.StockInfoRepository.UpdateData(stockInfo);
|
_stockRepository.StockInfoDetailRepository.UpdateData(stockInfo.Details);
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
_unitOfWorkManage.CommitTran();
|
content.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
|
/// <summary>
|
/// SMOM盘点单完成
|
/// </summary>
|
/// <param name="task"></param>
|
/// <param name="stockInfo"></param>
|
/// <param name="locationInfo"></param>
|
/// <returns></returns>
|
public WebResponseContent SMOMOutInventoryCompleted(Dt_Task task, Dt_StockInfo stockInfo, Dt_LocationInfo locationInfo)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
//获取对应盘点单
|
Dt_TakeStockOrderCP takeStockOrder = _inboundRepository.TakeStockOrderRepository.Db.Queryable<Dt_TakeStockOrderCP>().Where(x => x.OrderNo == task.OrderNo).Includes(x => x.Details).First();
|
if (takeStockOrder == null)
|
{
|
return content.Error($"盘点单{task.OrderNo}不存在");
|
}
|
if (takeStockOrder.TakeStockStatus != TakeStockStatusEnum.盘点中.ObjToInt())
|
{
|
return content.Error($"盘点单{task.OrderNo}盘点已完成或未开始");
|
}
|
if (stockInfo.StockStatus != StockStatusEmun.出库锁定.ObjToInt())
|
{
|
return content.Error($"{stockInfo.PalletCode}库存状态不正确");
|
}
|
if (locationInfo.LocationStatus != LocationStatusEnum.Lock.ObjToInt())
|
{
|
return content.Error($"{locationInfo.LocationCode}货位状态不正确");
|
}
|
//根据任务托盘查盘点明细
|
Dt_TakeStockOrderDetailCP? takeStockOrderDetail = takeStockOrder.Details.FirstOrDefault(x => x.TakePalletCode == stockInfo.PalletCode);
|
if (takeStockOrderDetail == null)
|
{
|
return content.Error($"{stockInfo.PalletCode}未找到对应盘点明细");
|
}
|
if (takeStockOrderDetail.TakeDetalStatus != TakeStockDetailStatusEnum.盘点出库中.ObjToInt())
|
{
|
return content.Error($"{stockInfo.PalletCode}盘点明细状态不正确");
|
}
|
takeStockOrderDetail.TakeDetalStatus = TakeStockDetailStatusEnum.盘点出库完成.ObjToInt();
|
stockInfo.StockStatus = StockStatusEmun.盘点出库完成.ObjToInt();
|
stockInfo.Details.ForEach(x =>
|
{
|
x.Status = StockStatusEmun.盘点出库完成.ObjToInt();
|
});
|
stockInfo.LocationCode = "";
|
task.TaskStatus = TaskStatusEnum.Finish.ObjToInt();
|
int beforeStatus = locationInfo.LocationStatus;
|
locationInfo.LocationStatus = LocationStatusEnum.Lock.ObjToInt();
|
Dt_ReturnOrder returnOrder = new Dt_ReturnOrder
|
{
|
MaterielCode = stockInfo.Details.FirstOrDefault()?.MaterielCode,
|
MaterielName = stockInfo.Details.FirstOrDefault()?.MaterielName,
|
BatchNo = stockInfo.Details.FirstOrDefault()?.BatchNo,
|
OrderQuantity = stockInfo.Details.Sum(x => x.StockQuantity),
|
ReceiptQuantity = stockInfo.Details.Sum(x => x.StockQuantity),
|
OrderStatus = InOrderStatusEnum.未开始.ObjToInt(),
|
LinId = stockInfo.Details.FirstOrDefault()?.LinId,
|
LocationCode = stockInfo.LocationCode,
|
LPNNo = stockInfo.PalletCode,
|
Creater = "LK",
|
CreateDate = DateTime.Now,
|
OrderType = OrderTypeEnum.盘点回库单.ObjToInt(),
|
System = "WMS"
|
};
|
|
_unitOfWorkManage.BeginTran();
|
//货位变动记录
|
_basicService.LocationInfoService.UpdateData(locationInfo);
|
_returnOrderRepository.AddData(returnOrder);
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, LocationStatusEnum.Lock.ObjToInt(), LocationChangeType.OutboundCompleted.ObjToInt(), takeStockOrder?.OrderNo ?? "", task.TaskNum);
|
_takeStockOrderDetailCPRepository.UpdateData(takeStockOrderDetail);
|
_stockRepository.StockInfoRepository.UpdateData(stockInfo);
|
_stockRepository.StockInfoDetailRepository.UpdateData(stockInfo.Details);
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
_unitOfWorkManage.CommitTran();
|
content.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
}
|
#endregion
|
#endregion
|
|
|
|
|
|
#region
|
//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();
|
// Dt_Warehouse warehouse = _basicService.WarehouseService.Repository.QueryFirst(x => x.WarehouseId == task.WarehouseId);
|
|
// dt_StockInfo.LocationCode = dt_LocationInfo.LocationCode;
|
|
|
// Dt_InboundOrder? inboundOrder = _inboundService.InbounOrderService.Db.Queryable<Dt_InboundOrder>().Where(x => x.InboundOrderNo == dt_StockInfo.Details.FirstOrDefault().OrderNo).Includes(x => x.Details).First();
|
// Dt_InboundOrderDetail? inboundOrderDetail = null;
|
// //判断单据类型是入库还是调拨入库。。。入库
|
// if (inboundOrder.OrderType == 0 && inboundOrder != null && dt_StockInfo.StockStatus == StockStatusEmun.入库确认.ObjToInt())
|
// {
|
// #region //判断入库单据明细只有最后一条完成时删除入库单
|
// //查询原完成的入库明细数量
|
// int overCount = inboundOrder.Details.Where(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()).ToList().Count;
|
// //明细id查询
|
// inboundOrderDetail = inboundOrder.Details.FirstOrDefault(x => x.LinId == dt_StockInfo.Details.FirstOrDefault()?.LinId);
|
// foreach (var item in dt_StockInfo.Details)
|
// {
|
// if (inboundOrderDetail == null)
|
// {
|
// continue;
|
// }
|
// inboundOrderDetail.OverInQuantity += item.StockQuantity;
|
// if (inboundOrderDetail.OverInQuantity == inboundOrderDetail.OrderQuantity)
|
// {
|
// inboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt();
|
// overCount += 1;
|
// }
|
// else if (inboundOrderDetail.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt())
|
// {
|
// inboundOrderDetail.OrderDetailStatus = InboundStatusEnum.入库中.ObjToInt();
|
// }
|
// }
|
// dt_StockInfo.Details.ForEach(x =>
|
// {
|
// x.Status = StockStatusEmun.入库完成.ObjToInt();
|
// });
|
|
// _unitOfWorkManage.BeginTran();
|
// task.TaskStatus = InTaskStatusEnum.InFinish.ObjToInt();
|
// 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, task.TaskNum);
|
// if (inboundOrder != null)
|
// {
|
// _inboundService.InbounOrderService.UpdateData(inboundOrder);
|
// _inboundService.InboundOrderDetailService.UpdateData(inboundOrderDetail);
|
// }
|
// _unitOfWorkManage.CommitTran();
|
|
|
|
|
// if (inboundOrder.Details.Count == 1)
|
// {
|
// var stockInfoDetail = dt_StockInfo.Details.FirstOrDefault();
|
|
// #region//入库信息返回上位WMS。。立库入库数量回传
|
// 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
|
// {
|
// LinId = stockInfoDetail.LinId,
|
// MaterielCode = stockInfoDetail.MaterielCode,
|
// OrderQuantity = stockInfoDetail.StockQuantity,
|
// BatchNo = stockInfoDetail.BatchNo,
|
// FinishQty = stockInfoDetail.StockQuantity,
|
// 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");
|
// }
|
// #endregion
|
// }
|
// }
|
// else
|
// {
|
// #region //判断调拨入库单据明细只有最后一条完成时删除入库单并一次返回入库明细信息
|
// if (inboundOrder.Details.Count == 1)
|
// {
|
// List<Dt_StockInfo> StockInfo = _stockService.StockInfoService.Repository.QueryData(x => x.BatchNo == inboundOrderDetail.BatchNo);
|
// 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,
|
// };
|
// _inboundOrder_HtyService.AddData(inboundOrder_Hty);
|
// _inboundService.InbounOrderService.DeleteData(inboundOrder);
|
// Dt_InboundOrderDetail_Hty dt_InboundOrderDetail_HtyS = 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,
|
// Creater = "WMS",
|
// CreateDate = DateTime.Now,
|
// };
|
// _inboundOrderDetail_HtyService.AddData(dt_InboundOrderDetail_HtyS);
|
// _inboundService.InboundOrderDetailService.DeleteData(inboundOrderDetail);
|
// #endregion
|
// #region//调拨任务数量回传WMS
|
// 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;
|
// foreach (var item in StockInfo)
|
// {
|
// Dt_StockInfoDetail detail = _stockService.StockInfoDetailService.Repository.QueryFirst(x => x.StockId == item.Id);
|
// Allocate.data1.Inventory inbound = new Allocate.data1.Inventory();
|
// inbound.LinId = detail.LinId;
|
// inbound.LPN_No = item.PalletCode;
|
// inbound.MaterielCode = detail.MaterielCode;
|
// inbound.OrderQuantity = detail.StockQuantity;
|
// inbound.BatchNo = detail.BatchNo;
|
// inbound.FinishQty = detail.StockQuantity;
|
// inbound.LocationName = item.LocationCode;
|
// data1.DetailList.Add(inbound);
|
// }
|
// allocate.Value.Add(data1);
|
// 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");
|
// }
|
// }
|
// #endregion
|
// 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,
|
// Creater = "WMS",
|
// CreateDate = DateTime.Now,
|
// };
|
// _inboundOrderDetail_HtyService.AddData(dt_InboundOrderDetail_Hty);
|
// _inboundService.InboundOrderDetailService.DeleteData(inboundOrderDetail);
|
// }
|
// return WebResponseContent.Instance.OK();
|
// }
|
// catch (Exception ex)
|
// {
|
// _unitOfWorkManage.RollbackTran();
|
// return WebResponseContent.Instance.Error(ex.Message);
|
// }
|
//}
|
#endregion
|
#region
|
//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.LPNNo == stockInfo.PalletCode).First();
|
// Dt_OutboundOrder outboundOrder = _outboundService.OutboundOrderService.Db.Queryable<Dt_OutboundOrder>().Where(x => x.Id == outDetail.OrderId).Includes(x => x.Details).First();
|
// //判断单据类型是出库还是调拨出库。。。出库
|
// if (outboundOrder.OrderType == 1)
|
// {
|
// #region //判断出库单据明细只有最后一条完成时删除出库单
|
// if (outboundOrder.Details.Count == 1)
|
// {
|
// Dt_OutboundOrder_Hty inboundOrder_Hty = new Dt_OutboundOrder_Hty
|
// {
|
// OrderStatus = outboundOrder.OrderStatus,
|
// CreateType = outboundOrder.CreateType,
|
// //SourceId = oldOutboundOrder.SourceId,
|
// UpperOrderNo = outboundOrder.UpperOrderNo,
|
// OrderNo = outboundOrder.OrderNo,
|
// OutWareHouse = outboundOrder.OutWareHouse,
|
// TransactionCode = outboundOrder.TransactionCode,
|
// InoutType = outboundOrder.InoutType,
|
// OrderType = outboundOrder.OrderType,
|
// Creater = "WMS",
|
// CreateDate = DateTime.Now,
|
// };
|
// _outboundOrder_HtyService.AddData(inboundOrder_Hty);
|
// _outboundService.OutboundOrderService.DeleteData(outboundOrder);
|
// }
|
// Dt_OutboundOrderDetail_Hty dt_InboundOrderDetail_Hty = new Dt_OutboundOrderDetail_Hty
|
// {
|
// OrderId = outDetail.OrderId,
|
// MaterielCode = outDetail.MaterielCode,
|
// MaterielName = outDetail.MaterielName,
|
// BatchNo = outDetail.BatchNo,
|
// OrderQuantity = outDetail.OrderQuantity,
|
// //ReceiptQuantity = outDetail.ReceiptQuantity,
|
// //OverInQuantity = outDetail.OverInQuantity,
|
// OrderDetailStatus = outDetail.OrderDetailStatus,
|
// Creater = "WMS",
|
// CreateDate = DateTime.Now,
|
// };
|
// _outboundOrderDetail_HtyService.AddData(dt_InboundOrderDetail_Hty);
|
// _outboundService.OutboundOrderService.DeleteData(outDetail);
|
// #endregion
|
// #region//出库信息返回上位WMS。。。立库出库数量回传
|
// 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.LPN_No = task.PalletCode;
|
// 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");
|
// }
|
// #endregion
|
// //删除库存信息
|
// _stockService.StockInfoService.Repository.DeleteAndMoveIntoHty(stockInfo, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
// _stockService.StockInfoDetailService.Repository.DeleteAndMoveIntoHty(stockInfo.Details, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
// }
|
// else if (outboundOrder.OrderType == 240)
|
// {
|
// //盘点出库任务完成、、、、、、、、、不能删除库存等逻辑
|
// }
|
// else
|
// {
|
|
// List<Dt_StockInfo> StockInfo = _stockService.StockInfoService.Repository.QueryData(x => x.BatchNo == outDetail.BatchNo);
|
// if (outboundOrder.Details.Count == 1)
|
// {
|
// Dt_OutboundOrder_Hty inboundOrder_Hty = new Dt_OutboundOrder_Hty
|
// {
|
// OrderStatus = outboundOrder.OrderStatus,
|
// CreateType = outboundOrder.CreateType,
|
// //SourceId = oldOutboundOrder.SourceId,
|
// UpperOrderNo = outboundOrder.UpperOrderNo,
|
// OrderNo = outboundOrder.OrderNo,
|
// OutWareHouse = outboundOrder.OutWareHouse,
|
// TransactionCode = outboundOrder.TransactionCode,
|
// InoutType = outboundOrder.InoutType,
|
// OrderType = outboundOrder.OrderType,
|
// Creater = "WMS",
|
// CreateDate = DateTime.Now,
|
// };
|
// _outboundOrder_HtyService.AddData(inboundOrder_Hty);
|
// _outboundService.OutboundOrderService.DeleteData(outboundOrder);
|
// }
|
// Dt_OutboundOrderDetail_Hty dt_InboundOrderDetail_Hty = new Dt_OutboundOrderDetail_Hty
|
// {
|
// OrderId = outDetail.OrderId,
|
// MaterielCode = outDetail.MaterielCode,
|
// MaterielName = outDetail.MaterielName,
|
// BatchNo = outDetail.BatchNo,
|
// OrderQuantity = outDetail.OrderQuantity,
|
// //ReceiptQuantity = outDetail.ReceiptQuantity,
|
// //OverInQuantity = outDetail.OverInQuantity,
|
// OrderDetailStatus = outDetail.OrderDetailStatus,
|
// Creater = "WMS",
|
// CreateDate = DateTime.Now,
|
// };
|
// _outboundOrderDetail_HtyService.AddData(dt_InboundOrderDetail_Hty);
|
// _outboundService.OutboundOrderService.DeleteData(outDetail);
|
|
// 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;
|
|
// foreach (var item in StockInfo)
|
// {
|
// Dt_StockInfoDetail detail = _stockService.StockInfoDetailService.Repository.QueryFirst(x => x.StockId == item.Id);
|
// Allocate.data1.Inventory inbound = new Allocate.data1.Inventory();
|
// inbound.LinId = outDetail.LinId;
|
// inbound.LPN_No = item.PalletCode;
|
// inbound.MaterielCode = detail.MaterielCode;
|
// inbound.OrderQuantity = detail.OutboundQuantity;
|
// inbound.BatchNo = detail.BatchNo;
|
// inbound.FinishQty = detail.OutboundQuantity;
|
// inbound.LocationName = task.SourceAddress;
|
// data1.DetailList.Add(inbound);
|
// }
|
|
|
// allocate.Value.Add(data1);
|
// 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");
|
// }
|
// _stockService.StockInfoService.Repository.DeleteAndMoveIntoHty(stockInfo, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
// _stockService.StockInfoDetailService.Repository.DeleteAndMoveIntoHty(stockInfo.Details, App.User.UserId == 0 ? OperateType.自动完成 : OperateType.人工完成);
|
// }
|
// return WebResponseContent.Instance.OK();
|
// }
|
// catch (Exception ex)
|
// {
|
// _unitOfWorkManage.RollbackTran();
|
// return WebResponseContent.Instance.Error(ex.Message);
|
// }
|
//}
|
#endregion
|
}
|
