using iWareSql;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using iWareSql.DBModel;
|
using XiGang.Core.Model;
|
using iWareSql.DataAccess;
|
using iWareCommon.Common.Globle;
|
using System.Threading;
|
using iWareCommon.Utils;
|
using iWareModel;
|
|
namespace iWareCC
|
{
|
/// <summary>
|
/// 虚拟出库处理，并且不在出库计划任务中的线程
|
/// </summary>
|
public class VirtualTaskNoOutPlanTaskHandler
|
{
|
/// <summary>
|
/// 处理【虚拟出库处理】的出库计划任务
|
/// </summary>
|
public static void Handler()
|
{
|
var errMsg = "";
|
while (true)
|
{
|
try
|
{
|
if (SystemValue.isAllowRuning_DataProcess_RobotBuffer_FinishTask && SystemValue.isStartedModel)
|
{
|
errMsg = "";//重置
|
using (DbModel mycontext = new DbModel())
|
{
|
try
|
{
|
SingleOutPlanTaskHandler(mycontext, ref errMsg);
|
if (string.IsNullOrEmpty(errMsg))
|
{
|
SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = "成功处理";
|
}
|
else
|
{
|
SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = errMsg;
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.OutPlanTask, "处理【虚拟出库处理】的出库计划任务=>" + errMsg + ",异常:" + ex.Message, ex);
|
SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = "处理【虚拟出库处理】的出库计划任务=>" + errMsg + ",异常:" + ex.Message;
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = "出现异常:" + ex.Message;
|
Log4NetHelper.WriteErrorLog(LogType.DataProcess_RobotBuffer_FinishTask, "VirtualTaskNoOutPlanTaskHandler出现异常：" + ex.Message, ex);
|
}
|
Thread.Sleep(10 * 1000);//休眠10秒
|
}
|
}
|
|
private static void SingleOutPlanTaskHandler(DbModel context, ref string errMsg)
|
{
|
errMsg = "";
|
List<Wms_VirtualStore> noPlanTaskList = new List<Wms_VirtualStore>();
|
//当前虚拟库存
|
var virtualStroeList = context.Wms_VirtualStore.ToList();
|
if (virtualStroeList != null && virtualStroeList.Count > 0)
|
{
|
var queryState1 = (int)OutTaskDetailStateEnum.等待中;
|
var queryState2 = (int)OutTaskDetailStateEnum.缺料;
|
var detaiList = context.Plan_OutTaskDetail.Where(x => x.OutTaskDetailState == queryState1 || x.OutTaskDetailState == queryState2).ToList();
|
if (detaiList != null && detaiList.Count > 0)
|
{
|
foreach (var virtualStroe in virtualStroeList)
|
{
|
var isExist = false;
|
//判断这些计划是否有符合 虚拟库存中的
|
foreach (var planDetail in detaiList)
|
{
|
var queliaoReason = "";
|
var findStore = StoreHandler.FindStoreForOutPlan(context, planDetail, ref errMsg, ref queliaoReason);
|
if (findStore != null)
|
{
|
isExist = true;
|
break;
|
}
|
}
|
if (isExist == false)
|
{
|
noPlanTaskList.Add(virtualStroe);
|
}
|
}
|
|
//处理 不再出库计划中的虚拟库存,将他们统统认定为人工出库
|
foreach (var item in noPlanTaskList)
|
{
|
SingleTaskHandlerForVirtual(context, item, ref errMsg);
|
}
|
}
|
else
|
{
|
//不予处理
|
}
|
}
|
}
|
|
/// <summary>
|
/// 单个处理出库-虚拟库存中处理 [Editby shaocx,2022-07-28]
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="outTask"></param>
|
/// <param name="outDetailTask"></param>
|
/// <param name="errMsg"></param>
|
/// <returns></returns>
|
private static bool SingleTaskHandlerForVirtual(DbModel context, Wms_VirtualStore findVirtualStore, ref string errMsg)
|
{
|
errMsg = "";
|
var remark = "消费虚拟库存，让他人工出库";
|
|
#region 事务处理
|
|
using (var trans = context.Database.BeginTransaction())
|
{
|
try
|
{
|
//1、库存移除
|
context.Wms_VirtualStore.Remove(findVirtualStore);
|
//findVirtualStore.IsDeleted = true;
|
//findVirtualStore.ModifyBy = "";
|
//findVirtualStore.OperationRemark = remark + "[锁定库存]";
|
//findVirtualStore.ModifyTime = DateTime.Now;
|
|
//2、创建虚拟出库任务，注意：任务状态必须是已完成，因为是虚拟出库
|
FunRetEntity addOutStoreTaskResult = MainTaskHandler.AddOutStoreTaskForVirtual(null, findVirtualStore, context, MainTaskTypeEnum.手动出库, new SysUser()
|
{
|
ID = 0,
|
Name = SysGloble.WCSSystem
|
});
|
if (addOutStoreTaskResult.result == false)
|
{
|
errMsg = addOutStoreTaskResult.resMsg;
|
throw new Exception(errMsg);
|
}
|
|
//4、更新出库明细表
|
var mainTask = addOutStoreTaskResult.resData as Task_Main;
|
if (mainTask == null)
|
{
|
errMsg = "新建的主任务对象为NULL";
|
throw new Exception(errMsg);
|
}
|
|
//保存数据库
|
context.SaveChanges();
|
|
trans.Commit();
|
|
return true;
|
}
|
catch (Exception ex)
|
{
|
trans.Rollback();
|
SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask = "SingleTaskHandlerForVirtual出现异常:" + ex.Message;
|
Log4NetHelper.WriteErrorLog(LogType.DataProcess_RobotBuffer_FinishTask, "SingleTaskHandlerForVirtual 出现异常：" + ex.Message, ex);
|
throw ex;
|
}
|
}
|
|
#endregion
|
}
|
|
}
|
}
|
