using HH.WCS.Mobox3.KeKou.util;
|
using HH.WCS.Mobox3.KeKou.wms;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Reflection;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WCS.Mobox3.KeKou.core
|
{
|
internal class WMSCore
|
{
|
/// <summary>
|
/// 遍历定版的发货单，生产分拣单主表和子表（也可以手动调接口触发）
|
/// </summary>
|
internal static void CheckShippingOrder()
|
{
|
//1.0、获取已经定版的发货单，生产分拣单子表和主表，设置【发货单】的业务状态 N_B_STATE = 1（待分拣）
|
//2.0、如果发货单C_AUTO_SORTING=Y，则自动将分拣单状态设置为开始配货
|
|
}
|
/// <summary>
|
/// 开始配货创建分拣单明细(改成调接口触发)
|
/// </summary>
|
internal static void CheckSortingOrder()
|
{
|
//new SortingOrder().N_B_STATE
|
//1.0、获取 N_B_STATE = 1 (开始配货)状态的分拣单
|
//2.0、遍历分拣单子表，创建分拣单明细，更新分拣单子表的明细汇总F_ACC_S_QTY
|
//3.0、全部分拣单子表的明细创建完毕，子表明细汇总和子表数量一致，更新分拣单状态，N_B_STATE = 2配货完成
|
//4.0、如果分拣单是自动作业，就直接更新到 N_B_STATE = 3开始作业
|
//WMSHelper.GetWaitingSortingOrderList();
|
|
}
|
|
/// <summary>
|
/// 遍历分拣单明细创建出库作业
|
/// </summary>
|
internal static void CheckSortingTask()
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
//new SortingOrder().N_B_STATE
|
//遍历N_B_STATE = 3的分拣单创建作业
|
//或 遍历分拣单明细创建分拣作业，因为一个分拣单里面的明细都是批量生成的
|
var list = WMSHelper.GetWaitingSortingOperationList();
|
LogHelper.Info($"获取配盘数量 {list.Count}");
|
if (list.Count > 0)
|
{
|
list.ForEach(a =>
|
{
|
var startloc = db.Queryable<Location>().Where(it => it.S_CODE == a.S_LOC_CODE).First();
|
if (startloc != null && startloc.S_LOCK_STATE == "其它锁")
|
{
|
|
Location endbit = null;
|
|
//计算托盘进行出库
|
|
if (endbit != null)
|
{
|
var optask = new WMSTask
|
{
|
S_CODE = WMSHelper.GenerateTaskNo(),
|
S_START_LOC = a.S_LOC_CODE,
|
S_START_AREA = startloc.S_AREA_CODE,
|
S_START_WH = startloc.S_WH_CODE,
|
S_END_LOC = endbit.S_CODE,
|
S_END_AREA = endbit.S_AREA_CODE,
|
S_END_WH = endbit.S_WH_CODE,
|
// S_STATION_LOC = a.S_OUT_TO,
|
S_TYPE = "出库",
|
N_TYPE = 2,
|
N_B_STATE = 0,
|
S_CNTR_CODE = a.S_CNTR_CODE,
|
S_OP_DEF_NAME = a.S_BS_TYPE
|
};
|
var note = Settings.Tasktypes.Where(it => it.StartArea == optask.S_START_AREA && it.EndArea == optask.S_END_AREA).FirstOrDefault();
|
if (note != null)
|
{
|
optask.S_NOTE = note.TaskType;
|
}
|
var res = db.Insertable(optask).ExecuteCommand() > 0;
|
if (res)
|
{
|
startloc.N_LOCK_STATE = 2;
|
startloc.S_LOCK_STATE = "出库锁";
|
db.Updateable(startloc).UpdateColumns(it => new { it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
|
LocationHelper.LockLoc(endbit.S_CODE, 1);
|
a.N_B_STATE = 2;
|
a.S_B_STATE = "作业启动";
|
db.Updateable(a).UpdateColumns(it => new { it.S_B_STATE, it.N_B_STATE }).ExecuteCommand();
|
}
|
}
|
else LogHelper.Info($"配盘 未找到可用分拣货位");
|
}
|
else LogHelper.Info($"配盘 未找到出库口库区编码{a.S_EXIT_AREA_CODE} 对应的配置文件");
|
|
});
|
}
|
|
|
}
|
internal static void TransportTask()
|
{
|
var db = new SqlHelper<object>().GetInstance();
|
string taskType = "自动转运";
|
var transportInfos = Settings.transportInfos.Where(a => a.enable == 1).ToList();
|
transportInfos.ForEach(it =>
|
{
|
try
|
{
|
LogHelper.Info($"转运 起点库区{it.startArea} 终点库区{it.endArea} 起点密集型{it.startAreaRowLock} 终点密集型{it.endAreaRowLock} 产线号{it.deviceName}");
|
var startItemCode = ""; //起点物料编码 为空则为空框 废料转运到废料区
|
var startDeviceName = "";//产线号
|
var endArea = it.endArea;
|
var endAreaRowLock = it.endAreaRowLock;
|
var trayNo = "";
|
Location startLoc = null;
|
Location endLoc = null;
|
var deviceNameBol = true;
|
if (!string.IsNullOrEmpty(it.deviceName))
|
{
|
deviceNameBol = db.Queryable<WorkOrder>().Where(a => a.S_BP_CODE == it.deviceName && a.S_WOB_STATE == "执行中").First() != null;
|
}
|
if (deviceNameBol)
|
{
|
if (it.startAreaRowLock == "0")
|
{
|
//起点不为密集型库区
|
startLoc = db.Queryable<Location>()
|
.Where(a =>
|
a.S_AREA_CODE == it.startArea &&
|
a.N_LOCK_STATE == 0 &&
|
a.N_CURRENT_NUM > 0)
|
.Includes(a => a.LocCntrRel)
|
.First();
|
|
|
if (startLoc != null)
|
{
|
if (startLoc.LocCntrRel != null)
|
{
|
trayNo = startLoc.LocCntrRel.S_CNTR_CODE;
|
var itemInfo = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == trayNo).First();
|
if (itemInfo != null)
|
{
|
startItemCode = itemInfo.S_ITEM_CODE;
|
startDeviceName = itemInfo.S_BP_CODE;
|
}
|
}
|
else
|
{
|
LogHelper.Info($"判断调试{startLoc.S_CODE}未找到绑定托盘");
|
}
|
}
|
}
|
else
|
{
|
var startList = db.Queryable<Location>()
|
.Where(a =>
|
a.S_AREA_CODE == it.startArea &&
|
a.N_LOCK_STATE == 0 &&
|
a.N_CURRENT_NUM > 0)
|
.PartitionBy(a => a.N_ROW)
|
.OrderByDescending(a => a.N_COL)
|
.Includes(a => a.LocCntrRel)
|
.Take(1)
|
.ToList();
|
if (it.startLocCreatTime == "1")
|
{
|
//按创建时间出
|
var item = startList.OrderBy(a => a.LocCntrRel.T_CREATE).FirstOrDefault();
|
if (item != null)
|
{
|
var startLock = db.Queryable<Location>()
|
.Where(a =>
|
a.S_AREA_CODE == item.S_AREA_CODE &&
|
a.N_ROW == item.N_ROW &&
|
a.N_LOCK_STATE != 0)
|
.First();
|
if (startLock == null && item.LocCntrRel != null)
|
{
|
startLoc = item;
|
trayNo = item.LocCntrRel.S_CNTR_CODE;
|
}
|
}
|
else
|
{
|
LogHelper.Info($"搭建框无空框数据");
|
}
|
}
|
else
|
{
|
foreach (var item in startList)
|
{
|
LogHelper.Info($"不按创建时间出{item.S_AREA_CODE},{item.N_ROW}");
|
//排除这一排是否有锁定的货位 如果没有选取最外面的货位
|
var startLock = db.Queryable<Location>()
|
.Where(a =>
|
a.S_AREA_CODE == item.S_AREA_CODE &&
|
a.N_ROW == item.N_ROW &&
|
a.N_LOCK_STATE != 0)
|
.First();
|
if (startLock == null && item.LocCntrRel != null)
|
{
|
startLoc = item;
|
trayNo = item.LocCntrRel.S_CNTR_CODE;
|
break;
|
}
|
}
|
}
|
}
|
LogHelper.Info($"判断{trayNo}");
|
if (startLoc != null && !string.IsNullOrEmpty(trayNo))
|
{
|
//可增加废料流程自动转运
|
|
var itemInfo = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == trayNo).First();
|
if (itemInfo != null && itemInfo.S_ITEM_CODE == "废料")
|
{
|
LogHelper.Info($"托盘{trayNo} 判定为废料 物料编码{itemInfo.S_ITEM_CODE}");
|
endArea = "Flq";
|
endAreaRowLock = "0";
|
taskType = "废料自动转运";
|
}
|
|
|
//满框流程自动转运
|
//获取终点
|
if (endAreaRowLock == "0")
|
{
|
//终点非密集型
|
endLoc = db.Queryable<Location>()
|
.Where(a =>
|
a.S_AREA_CODE == endArea &&
|
a.N_CURRENT_NUM == 0 &&
|
a.N_LOCK_STATE == 0)
|
.First();
|
LogHelper.Info($"终点非密集型{endArea}");
|
}
|
else
|
{
|
LogHelper.Info($"终点密集型{endArea}");
|
|
if (!string.IsNullOrEmpty(startItemCode) && !string.IsNullOrEmpty(startDeviceName))
|
{
|
//转运到满框库区
|
var endList = db.Queryable<Location>()
|
.Where(a =>
|
a.S_AREA_CODE == endArea &&
|
a.N_CURRENT_NUM > 0)
|
.PartitionBy(a => a.N_ROW)
|
.OrderByDescending(a => a.N_COL)
|
.Includes(a => a.LocCntrRel)
|
.Take(1)
|
.ToList();
|
bool ass = endList.Count > 0;
|
LogHelper.Info($"终点密集型{ass},{startItemCode}，{startDeviceName}");
|
foreach (var item in endList)
|
{
|
var endLock = db.Queryable<Location>()
|
.Where(a =>
|
a.S_AREA_CODE == item.S_AREA_CODE &&
|
a.N_ROW == item.N_ROW &&
|
a.N_LOCK_STATE != 0)
|
.First();
|
if (endLock == null)
|
{
|
var ssss = item.LocCntrRel == null;
|
LogHelper.Info($"匹配物料是否和这一排的物料相同{ssss}");
|
//匹配物料是否和这一排的物料相同
|
if (item.LocCntrRel != null)
|
{
|
var cntr = item.LocCntrRel.S_CNTR_CODE;
|
var isUse = db.Queryable<CntrItemRel>()
|
.Where(a =>
|
a.S_CNTR_CODE == cntr &&
|
a.S_ITEM_CODE == startItemCode &&
|
a.S_BP_CODE == startDeviceName)
|
.First();
|
var ssss1 = isUse == null;
|
LogHelper.Info($"匹配isUse相同{ssss1},{cntr},{startItemCode},{startDeviceName}");
|
if (isUse != null)
|
{
|
//该排可用
|
endLoc = db.Queryable<Location>()
|
.Where(a =>
|
a.S_AREA_CODE == item.S_AREA_CODE &&
|
a.N_ROW == item.N_ROW &&
|
a.N_CURRENT_NUM == 0)
|
.OrderBy(a => a.N_COL)
|
.First();
|
if (endLoc != null) break;
|
}
|
}
|
else
|
{
|
LogHelper.Info($"匹配物料和这一排的物料不相同");
|
}
|
}
|
}
|
if (endLoc == null)
|
{
|
//寻找空排进行存放
|
var RowList = db.Queryable<Location>()
|
.Where(a =>
|
a.S_AREA_CODE == endArea &&
|
a.N_CURRENT_NUM == 0)
|
.PartitionBy(a => a.N_ROW)
|
.OrderBy(a => a.N_COL)
|
.Take(1)
|
.ToList();
|
endLoc = RowList.Where(a => a.N_COL == 1 && a.N_LOCK_STATE == 0).FirstOrDefault();
|
}
|
}
|
else
|
{
|
LogHelper.Info($"容器编码{trayNo} 物料编码{startItemCode}，产线号{startDeviceName}为空");
|
}
|
}
|
|
if (endLoc != null)
|
{
|
LogHelper.Info($"创建作业");
|
//创建作业
|
WMSHelper.CreatOpenation(startLoc, endLoc, trayNo, taskType, 3);
|
}
|
else
|
{
|
LogHelper.Info($"终点库区{endArea} 未获取到可用货位存放");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"起点库区{it.startArea} 未获取到可搬运托盘");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"{it.deviceName}工单未执行 无法开始转运任务");
|
}
|
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"自动转运流程异常 起点库区{it.startArea} 终点库区{it.endArea} 异常信息{ex.Message}", ex);
|
}
|
});
|
}
|
|
/// <summary>
|
/// 作业启动，创建子任务
|
/// </summary>
|
internal static void Start()
|
{
|
LogHelper.Info($"作业启动 创建子任务");
|
var db = new SqlHelper<object>().GetInstance();
|
List<WMSTask> list = WMSHelper.GetWaitingOperationList();
|
LogHelper.Info($"获取任务数据 数量{list.Count}");
|
if (list.Count > 0)
|
{
|
//如果是出库的作业锁定托盘的时候已经明确起点了，如果发货单或分拣单指定了终点，
|
//如果没有作业、任务的顺序限制就可以启动，创建子任务了
|
foreach (var a in list)
|
{
|
try
|
{
|
if (a.N_TYPE == 1)
|
{
|
//查询托盘所在位置
|
//计算终点
|
Location end = WMSHelper.GetEnd(a);
|
if (end != null)
|
{
|
LogHelper.Info($"作业{a.S_CODE} 获取终点成功 任务终点{end.S_CODE}");
|
WMSHelper.UpdateTaskEnd(a);
|
LocationHelper.LockLoc(end.S_CODE, 1);
|
var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == a.S_START_LOC).First();
|
var endinfo = db.Queryable<Location>().Where(it => it.S_CODE == end.S_CODE).First();
|
var wcsTask = new WCSTask
|
{
|
S_OP_CODE = a.S_CODE,
|
S_OP_NAME = a.S_OP_DEF_NAME,
|
S_CODE = WCSHelper.GenerateTaskNo(),
|
S_TYPE = a.S_TYPE,
|
S_START_LOC = a.S_START_LOC,
|
S_START_AREA = startinfo.S_AREA_CODE,
|
S_START_WH = startinfo.S_WH_CODE,
|
S_END_LOC = end.S_CODE,
|
S_END_AREA = endinfo.S_AREA_CODE,
|
S_END_WH = endinfo.S_WH_CODE,
|
S_SCHEDULE_TYPE = "NDC",
|
N_CNTR_COUNT = 1,
|
S_CNTR_CODE = a.S_CNTR_CODE,
|
};
|
if (WCSHelper.CreateTask(wcsTask))
|
{
|
//更新作业状态为执行
|
a.N_B_STATE = 1;
|
a.S_B_STATE = "执行";
|
WMSHelper.UpdateTaskState(a);
|
}
|
}
|
else
|
{
|
LogHelper.Info($"作业{a.S_CODE} 获取终点失败");
|
}
|
}
|
else if (a.N_TYPE == 2)
|
{
|
//通过托盘获取到对应的分拣单 通过分拣单查找发货单上的终点库区 如果是备货出库的话 从配置文件中找一个空闲的点位
|
//计算终点
|
Location end = WMSHelper.GetEnd(a);
|
if (end != null)
|
{
|
WMSHelper.UpdateTaskEnd(a);
|
LocationHelper.LockLoc(end.S_CODE, 1);
|
|
|
|
var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == a.S_START_LOC).First();
|
var endinfo = db.Queryable<Location>().Where(it => it.S_CODE == end.S_CODE).First();
|
//创建wcs任务
|
var wcsTask = new WCSTask
|
{
|
S_OP_CODE = a.S_CODE,
|
S_OP_NAME = a.S_OP_DEF_NAME,
|
S_CODE = WCSHelper.GenerateTaskNo(),
|
S_TYPE = a.S_TYPE,
|
S_START_LOC = a.S_START_LOC,
|
S_START_AREA = startinfo.S_AREA_CODE,
|
S_START_WH = startinfo.S_WH_CODE,
|
S_END_LOC = end.S_CODE,
|
S_END_AREA = endinfo.S_AREA_CODE,
|
S_END_WH = endinfo.S_WH_CODE,
|
S_SCHEDULE_TYPE = "NDC",
|
N_CNTR_COUNT = 1,
|
S_CNTR_CODE = a.S_CNTR_CODE,
|
};
|
|
if (WCSHelper.CreateTask(wcsTask))
|
{
|
//更新作业状态为执行
|
a.N_B_STATE = 1;
|
a.S_B_STATE = "执行";
|
WMSHelper.UpdateTaskState(a);
|
}
|
}
|
else
|
{
|
LogHelper.Info($"作业{a.S_CODE} 获取终点失败");
|
}
|
}
|
else if (a.N_TYPE == 3)
|
{
|
var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == a.S_START_LOC).First();
|
var endinfo = db.Queryable<Location>().Where(it => it.S_CODE == a.S_END_LOC).First();
|
//创建wcs任务
|
var wcsTask = new WCSTask
|
{
|
S_OP_CODE = a.S_CODE,
|
S_OP_NAME = a.S_OP_DEF_NAME,
|
S_CODE = WCSHelper.GenerateTaskNo(),
|
S_TYPE = a.S_TYPE,
|
S_START_LOC = a.S_START_LOC,
|
S_START_AREA = startinfo.S_AREA_CODE,
|
S_START_WH = startinfo.S_WH_CODE,
|
S_END_LOC = endinfo.S_CODE,
|
S_END_AREA = endinfo.S_AREA_CODE,
|
S_END_WH = endinfo.S_WH_CODE,
|
S_SCHEDULE_TYPE = "NDC",
|
N_CNTR_COUNT = 1,
|
S_CNTR_CODE = a.S_CNTR_CODE,
|
};
|
|
if (WCSHelper.CreateTask(wcsTask))
|
{
|
//更新作业状态为执行
|
a.N_B_STATE = 1;
|
a.S_B_STATE = "执行";
|
WMSHelper.UpdateTaskState(a);
|
}
|
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"作业启动异常 异常信息={ex.Message}", ex);
|
}
|
}
|
}
|
}
|
}
|
}
|
