using Admin.NET.Application;
|
using Admin.NET.Core.TaskModule.Enum;
|
using iWareCC.Common.Helper;
|
using iWareCommon;
|
using iWareCommon.Common.Globle;
|
using iWareCommon.Utils;
|
using iWareModel.Entity.WCS;
|
using iWareSql.DataAccess;
|
using iWareSql.MyDbContext;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.ComponentModel;
|
using System.Data.Entity;
|
using System.Linq;
|
using System.Threading;
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement;
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement.StartPanel;
|
|
namespace iWareCC
|
{
|
/// <summary>
|
/// WCS任务完成线程（平库）
|
/// </summary>
|
public static class TaskFinishHandler
|
{
|
public static void Handler()
|
{
|
while (true)
|
{
|
|
Thread.Sleep(2000);//休眠2秒
|
try
|
{
|
if (SystemValue.isAllowRuning_PingKuTaskFinish && SystemValue.isStartedModel)
|
{
|
using (MyDbContext dbContext = new MyDbContext())
|
{
|
//只查询平库
|
|
var models = dbContext.wms_task
|
.Where(x => x.TaskStatus == (int)TaskStatusEnum.已下发)
|
.Where(x => (x.IsDelete == false)
|
// && (x.AreaType == (int)AreaTypeEnum.平库)
|
).ToList();
|
|
if (models != null && models.Count > 0)
|
{
|
FinishTask(dbContext,models);
|
}
|
SystemWarningMsg._lbl_Alert_PingKuTaskFinish = "";
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
SystemWarningMsg._lbl_Alert_PingKuTaskFinish = "WCS任务完成线程（平库） 出现异常:" + ex.Message;
|
Log4NetHelper.WriteErrorLog(LogType.PingKuTaskFinish, "WCS任务完成线程（平库） 出现异常：" + ex.Message, ex);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 模拟完成任务调度
|
/// </summary>
|
/// <param name="mycontext"></param>
|
/// <returns></returns>
|
public static void FinishTask(MyDbContext dbContext, List<wms_task> taskList)
|
{
|
string errMsg = string.Empty;
|
try
|
{
|
|
|
|
|
//处理调度任务
|
foreach (var singleTask in taskList)
|
{
|
|
OrderMovementFinishTask(dbContext, singleTask, ref errMsg);
|
|
if (!string.IsNullOrEmpty(errMsg))
|
{
|
SystemWarningMsg._lbl_Alert_OutPlanTaskHandler += "任务号" + singleTask.TaskNo + "模拟完成任务失败," + errMsg;
|
}
|
|
}
|
|
|
|
}
|
catch (Exception ex)
|
{
|
SystemWarningMsg._lbl_Alert_OutPlanTaskHandler = "错误信息：" + ex;
|
}
|
}
|
|
|
/// <summary>
|
/// 模拟完成 上、下架
|
/// </summary>
|
/// <param name="mycontext"></param>
|
/// <param name="singleTask"></param>
|
/// <param name="errMsg"></param>
|
/// <returns></returns>
|
private static int OrderMovementFinishTask(MyDbContext mycontext, wms_task singleTask, ref string errMsg)
|
{
|
|
try
|
{
|
|
//获取移动单
|
var moveOrder = BaseInfoHelper.GetOrderMovement(mycontext, singleTask, ref errMsg);
|
var moveOrderDetails = BaseInfoHelper.GetMoveOrderDetails(mycontext, singleTask, moveOrder, ref errMsg);
|
|
//获取业务类型
|
var wmsBusinessType = BusinessTypeHelper.GetBusinessTypeInfoFromDB(moveOrder.BusinessType, mycontext);
|
|
|
|
//查询库位
|
//目标库位校验
|
var toPlace =BaseInfoHelper.GetPlace(mycontext, singleTask.ToPlaceCode, "目标库位", ref errMsg);
|
//目标库区
|
|
var toArea = BaseInfoHelper.GetArea(mycontext, singleTask.ToAreaCode, "目标库区", ref errMsg);
|
|
////源库位校验
|
var sourcePlace = BaseInfoHelper.GetPlace(mycontext, singleTask.SourcePlaceCode, "源库位", ref errMsg);
|
|
|
//解锁起始、目标库位
|
sourcePlace.PlaceStatus = (int)PlaceStatusEnum.正常;
|
toPlace.PlaceStatus = (int)PlaceStatusEnum.正常;
|
|
//查询容器
|
var container = BaseInfoHelper.GetContainer(mycontext, singleTask.ContainerCode, ref errMsg);
|
|
//更新库位容器绑定关系
|
UpdaeContainerPlace(mycontext, singleTask, container, toPlace, ref errMsg);
|
|
|
//更新库存
|
//上架更新库存状态=》已上架
|
//下架更新冻结状态=》未冻结
|
//创建事务记录
|
//非下架、上架仅创建事务记录（因为变更了库位）
|
UpdateStockQuan(mycontext, wmsBusinessType, singleTask, moveOrder, container, toPlace, toArea, ref errMsg);
|
|
#region 处理移动单
|
//处理移动单（上架单、下架单）
|
|
//上架单或下架单业务类型设置了 自动完成 就 自动完成单据
|
bool isFinish = false;
|
if (wmsBusinessType.UpDownShelvesType == (int)UpDownShelvesTypeEnum.上架 || wmsBusinessType.BusinessTypeValue==(int)BusinessTypeEnum.盘点下架||
|
wmsBusinessType.DownShelvesIsAutoFinish == true)
|
{
|
isFinish = true;
|
}
|
|
if (isFinish)
|
{
|
if (moveOrderDetails.Any(a => string.IsNullOrWhiteSpace(a.ContainerCode)))
|
{
|
errMsg = $"{moveOrder.OrderTypeName}类型移动单{moveOrder.OrderNo}存在容器为空的移动单明细";
|
return 3;
|
}
|
//上架调度任务自动完成上架单
|
var updateMoveOrderDetails = moveOrderDetails.Where(w => w.ContainerCode.Equals(container.ContainerCode)).ToList();
|
|
if (updateMoveOrderDetails?.Count <= 0)
|
{
|
errMsg = $"{moveOrder.OrderTypeName}类型移动单{moveOrder.OrderNo}不存在容器为{container.ContainerCode}的移动单明细";
|
return 3;
|
}
|
foreach (var item in updateMoveOrderDetails)
|
{
|
item.OrderStatus = (int)OrderStatusEnum.已完成;
|
item.OrderStatusName = OrderStatusEnum.已完成.ToString();
|
item.UpdateTime = DateTime.Now;
|
item.UpdateUserId = 0;
|
item.UpdateUserName =FormCC.WcsSysUserName;
|
}
|
|
//更新移动单时间信息
|
UpdatOrderMovementStatus(moveOrderDetails, moveOrder, ref errMsg);
|
}
|
|
//盘点下架以外的下架不处理下架单，PDA分拣或自动完成分拣后完成下架单
|
|
#endregion
|
|
singleTask.TaskStatus = (int)TaskStatusEnum.已完成;//更新任务状态为 已完成
|
singleTask.TaskStatusName = TaskStatusEnum.已完成.ToString();
|
singleTask.UpdateTime = DateTime.Now;
|
singleTask.TaskMsg = "任务完成";
|
singleTask.FinishedTime = DateTime.Now;
|
|
mycontext.SaveChanges();
|
return 3;
|
}
|
catch (Exception ex)
|
{
|
SystemWarningMsg._lbl_Alert_OutPlanTaskHandler = "错误信息：" + ex;
|
return 2;
|
}
|
|
}
|
|
// <summary>
|
/// 公共更新 移动单的 状态
|
/// </summary>
|
/// <param name="wmsOrderAsnDetails"></param>
|
/// <param name="wmsOrderAsn"></param>
|
public static void UpdatOrderMovementStatus(List<wms_order_movement_details> wmsOrderMovementDetails, wms_order_movement wmsOrderMovement, ref string errMsg)
|
{
|
|
var wmsOrderMovementDetailsAll = wmsOrderMovementDetails.Where(x => x.MovementId == wmsOrderMovement.Id && x.IsDelete == false).ToList();
|
if (wmsOrderMovementDetailsAll?.Count <= 0)
|
{
|
errMsg = $"{wmsOrderMovement.OrderTypeName}类型移动单{wmsOrderMovement.OrderNo}更新状态，未获取到明细！";
|
}
|
else
|
{
|
int sttaus = (int)OrderStatusEnum.已完成;
|
//汇总已完成的明细
|
var totalOffShelvesCount = wmsOrderMovementDetailsAll.Count(o => o.OrderStatus == sttaus);
|
//单据有所明细数量
|
var totalTount = wmsOrderMovementDetailsAll.Count();
|
|
|
if (totalOffShelvesCount == totalTount) //单据完结
|
{
|
|
wmsOrderMovement.OrderStatus = (int)OrderStatusEnum.已完成;
|
wmsOrderMovement.OrderStatusName = OrderStatusEnum.已完成.ToString();
|
|
//更新时间信息
|
wmsOrderMovement.UpdateTime = DateTime.Now;
|
wmsOrderMovement.UpdateUserId = 0;
|
wmsOrderMovement.UpdateUserName =FormCC.WcsSysUserName;
|
}
|
|
|
|
}
|
}
|
|
|
|
/// <summary>
|
/// 更新库存
|
/// </summary>
|
/// <param name="mycontext"></param>
|
/// <param name="wmsBusinessType"></param>
|
/// <param name="singleTask"></param>
|
/// <param name="moveOrder"></param>
|
/// <param name="updateStockList"></param>
|
/// <param name="updateStockViewList"></param>
|
/// <param name="toPlace"></param>
|
/// <param name="toArea"></param>
|
/// <param name="errMsg"></param>
|
/// <exception cref="Exception"></exception>
|
private static void UpdateStockQuan(MyDbContext mycontext, wms_base_business_type wmsBusinessType, wms_task singleTask, wms_order_movement moveOrder, wms_base_container container, wms_base_place toPlace, wms_base_area toArea, ref string errMsg)
|
{
|
|
//不是 上架，不是下架 不处理库存，仅操作库位转移
|
|
string remark = singleTask.BusinessTypeName + "-完成调度任务";
|
|
var updateStockList = GetWmsStockQuanList(mycontext, container, ref errMsg);
|
var updateStockViewList = GetWmsStockQuanViewList(mycontext, updateStockList, ref errMsg);
|
|
|
|
|
foreach (var currentStock in updateStockList)
|
{
|
//再次之前库存的库位已经发生了变更
|
|
//上架
|
if (wmsBusinessType.UpDownShelvesType== (int)UpDownShelvesTypeEnum.上架)
|
{
|
// 待上架的库存，上架操作完成后变成 已上架
|
if (currentStock.StockStatus == (int)StockStatusEnum.待上架)
|
{
|
currentStock.StockStatus = (int)StockStatusEnum.已上架;
|
currentStock.StockStatusName = StockStatusEnum.已上架.ToString();
|
|
}
|
|
}
|
//下架
|
else if (wmsBusinessType.UpDownShelvesType == (int)UpDownShelvesTypeEnum.下架)
|
{
|
|
//盘点上架或 盘点下架 不解冻库存 调差解冻
|
//下架任务完成不解冻库存，分拣完成后操作解冻
|
//没有分拣环节的 业务类型需要配置 自动完成单据，这里就解冻
|
if (wmsBusinessType.DownShelvesIsAutoFinish == true && moveOrder.BusinessType != (int)BusinessTypeEnum.盘点下架)
|
{
|
LockInfo freezeInfo = new LockInfo()
|
{
|
LockReason = "调度任务完成",
|
LockTime = DateTime.Now,
|
LockUser =FormCC.WcsSysUserName,
|
LockStatus = LockStatusEnum.未锁定,//
|
};
|
StockQuanHelper.UpdateStockLockStatus(currentStock, freezeInfo);
|
}
|
|
}
|
|
|
//在此之前库存的库位已经发生了变更
|
//更新时间信息
|
currentStock.UpdateTime = DateTime.Now;
|
currentStock.UpdateUserId = 0;
|
currentStock.UpdateUserName =FormCC.WcsSysUserName;
|
|
#region 添加调度任务
|
|
var currentStockQuanView = updateStockViewList.FirstOrDefault(f => f.SNCode.Equals(currentStock.SNCode));
|
if (currentStockQuanView == null)
|
{
|
errMsg = $"跟踪码{currentStock.SNCode}没有获取到库存信息";
|
throw new Exception(errMsg);
|
}
|
wms_record_trans addWmsRecordTrans = CreateRecordTransInfo(moveOrder, currentStockQuanView, singleTask, currentStock, toPlace, toArea, remark);
|
mycontext.wms_record_trans.Add(addWmsRecordTrans);
|
#endregion
|
|
}
|
|
|
}
|
|
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="order"></param>
|
/// <param name="currentStockQuanView"></param>
|
/// <param name="task"></param>
|
/// <param name="StockModel"></param>
|
/// <param name="recordTransRemarks"></param>
|
/// <returns></returns>
|
private static wms_record_trans CreateRecordTransInfo(wms_order_movement order, v_wms_stock_quan currentStockQuanView, wms_task task , wms_stock_quan StockModel, wms_base_place toPlace, wms_base_area toArea, string recordTransRemarks)
|
{
|
|
try
|
{
|
|
|
TransferOtherDetail transferOtherDetail = new TransferOtherDetail()
|
{
|
RelationNo = order.OrderNo,//上架单号
|
RelationNoLineNumber = string.Empty,//上架 关联单行号 无法精准获取
|
Remarks = recordTransRemarks,
|
|
};
|
|
|
|
//源信息
|
//新增的库存源信息都
|
TransferDetail sourceDetail = new TransferDetail()
|
{
|
SNCode = currentStockQuanView.SNCode,//源跟踪码
|
Quantity = currentStockQuanView.Quantity,//源库存数
|
StockStatus = currentStockQuanView.StockStatus,//源库存状态
|
StockStatusName = currentStockQuanView.StockStatusName,//源库存状态名称
|
StockQcStatus = currentStockQuanView.QCStatus,//源质量状态
|
StockQcStatusName = currentStockQuanView.QCStatusName,//源质量状态名称
|
ContainerCode = currentStockQuanView.ContainerCode,//源容器编号
|
ContainerName = currentStockQuanView.ContainerCode,//源容器名称
|
AreaCode = currentStockQuanView.AreaCode,//源库区编号
|
AreaName = currentStockQuanView.AreaName,//源库区名称
|
PlaceCode = currentStockQuanView.PlaceCode,//源库位编号
|
PlaceName = currentStockQuanView.PlaceName//源库位名称
|
|
};
|
//目标信息 确认质检产生的心得库存 库区、库位 容器跟源库存一样
|
TransferDetail targetDetail = new TransferDetail()
|
{
|
SNCode = StockModel.SNCode,//目标跟踪码
|
Quantity = StockModel.Quantity,//目标库存数
|
StockStatus = StockModel.StockStatus,//目标库存状态
|
StockStatusName = StockModel.StockStatusName,//目标库存状态名称
|
StockQcStatus = StockModel.QCStatus,//目标质量状态
|
StockQcStatusName = StockModel.QCStatusName,//目标质量状态名称
|
ContainerCode = StockModel.ContainerCode,//目标容器编号
|
ContainerName = StockModel.ContainerCode,//目标容器名称
|
AreaCode = toArea.AreaCode,//目标库区编号
|
AreaName = toArea.AreaName,//目标库区名称
|
PlaceCode = toPlace.PlaceCode,//目标库位编号
|
PlaceName = toPlace.PlaceName//目标库位名称
|
};
|
|
wms_record_trans addWmsRecordTrans = LogRecordHelper.CreateWmsRecordTrans(task, currentStockQuanView, sourceDetail, targetDetail, transferOtherDetail);
|
|
|
return addWmsRecordTrans;
|
}
|
catch (Exception ex)
|
{
|
|
throw ex;
|
|
|
}
|
}
|
|
|
/// <summary>
|
/// 更新容器库位关系
|
/// </summary>
|
/// <param name="mycontext"></param>
|
/// <param name="singleTask"></param>
|
/// <param name="container"></param>
|
/// <param name="toPlace"></param>
|
/// <param name="errMsg"></param>
|
private static void UpdaeContainerPlace(MyDbContext mycontext, wms_task singleTask, wms_base_container container, wms_base_place toPlace, ref string errMsg)
|
{
|
var containerPlaceList = mycontext.wms_container_place.Where(f => f.ContainerCode == singleTask.ContainerCode).ToList();
|
if (containerPlaceList?.Count <= 0)
|
{
|
//新增库位关系绑定到目标容器
|
wms_container_place addContainerPlace = new wms_container_place()
|
{
|
Id = Yitter.IdGenerator.YitIdHelper.NextId(),
|
PlaceCode = toPlace.PlaceCode,
|
PlaceName = toPlace.PlaceName,
|
PlaceId = toPlace.Id,
|
ContainerName = container.ContainerName,
|
ContainerId = container.Id,
|
ContainerCode = singleTask.ContainerCode
|
};
|
addContainerPlace.PlaceCode = singleTask.ToPlaceCode;
|
addContainerPlace.PlaceName = toPlace.PlaceName;
|
addContainerPlace.PlaceId = toPlace.Id;
|
|
|
addContainerPlace.CreateTime = DateTime.Now;
|
addContainerPlace.CreateUserId = 0;
|
addContainerPlace.CreateUserName =FormCC.WcsSysUserName;
|
//addContainerPlace.UpdateTime = DateTime.Now;
|
//addContainerPlace.UpdateUserId = 0;
|
//addContainerPlace.UpdateUserName =FormCC.WcsSysUserName;
|
|
mycontext.wms_container_place.Add(addContainerPlace);
|
}
|
else
|
{
|
if (containerPlaceList.Count > 1)
|
{
|
errMsg = $"库位号{singleTask.ToPlaceCode},容器{singleTask.ContainerCode}有{containerPlaceList.Count}条绑定关系";
|
throw new Exception(errMsg);
|
}
|
else
|
{
|
containerPlaceList.First().PlaceId = toPlace.Id;
|
containerPlaceList.First().PlaceCode = toPlace.PlaceCode;
|
containerPlaceList.First().PlaceName = toPlace.PlaceName;
|
|
containerPlaceList.First().UpdateTime = DateTime.Now;
|
containerPlaceList.First().UpdateUserId = 0;
|
containerPlaceList.First().UpdateUserName =FormCC.WcsSysUserName;
|
}
|
}
|
|
|
}
|
|
/// <summary>
|
/// 获取库存详情信息-查询wms_stock_quan（表）
|
/// </summary>
|
/// <param name="mycontext"></param>
|
/// <param name="container"></param>
|
/// <param name="errMsg"></param>
|
/// <returns></returns>
|
private static List<wms_stock_quan> GetWmsStockQuanList(MyDbContext mycontext,wms_base_container container, ref string errMsg)
|
{
|
|
var updateStockList = mycontext.wms_stock_quan.Where(f => container.ContainerCode.Equals(f.ContainerCode)).ToList();
|
if (updateStockList?.Count <= 0)
|
{
|
errMsg = $"容器{container.ContainerCode}库存不存在";
|
throw new Exception(errMsg);
|
|
}
|
|
return updateStockList;
|
}
|
|
/// <summary>
|
/// 获取库存详情信息-查询v_wms_stock_quan（视图）
|
/// </summary>
|
/// <param name="mycontext"></param>
|
/// <param name="updateStockList"></param>
|
/// <param name="errMsg"></param>
|
/// <returns></returns>
|
private static List<v_wms_stock_quan> GetWmsStockQuanViewList(MyDbContext mycontext, List<wms_stock_quan> updateStockList, ref string errMsg)
|
{
|
|
var snCodeList = updateStockList.Select(s => s.SNCode).ToList();
|
|
var updateStockViewList = mycontext.v_wms_stock_quan.Where(f => snCodeList.Contains(f.SNCode)).ToList();
|
if (updateStockViewList?.Count <= 0)
|
{
|
errMsg = $"根据库存跟踪码没有获取到库存详情";
|
throw new Exception(errMsg);
|
|
}
|
|
return updateStockViewList;
|
}
|
|
|
|
}
|
}
|
