using iWareSda_QQJF.SRM.SrmService;
|
using iWareSda_QQJF.SRMTRAN.SrmTranService;
|
using iWareSda_QQJF.SrmTranModel;
|
using iWareSda_QQJF.WCSNEW.EDM;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Data.Entity;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
|
namespace iWareSda_QQJF.WCSNEW.生成主任务
|
{
|
public static class CreateMainTask
|
{
|
public static Dictionary<int, string> InErrorMsg = new Dictionary<int, string>()
|
{
|
{47,""},
|
{48,""},
|
{61,""},
|
{65,""},
|
{32,""},
|
{15,""},
|
|
};
|
public static bool[] needMove = { false, false, false, false, false, false, false, false, false };
|
static Dictionary<int, string> oldContainerName = new Dictionary<int, string>();
|
static Dictionary<int, int> times = new Dictionary<int, int>();
|
/// <summary>
|
/// 生成入库任务
|
/// </summary>
|
/// <param name="obj"></param>
|
public static void CreatInTask(object obj)
|
{
|
try
|
{
|
while (true)
|
{
|
string erromsg = "";
|
|
#region 准备数据
|
int tranObj = (int)obj;
|
int tranId = 0;
|
//int tranObj = 0;
|
SRMTRAN.SrmTranService.SrmTranService srv = new SRMTRAN.SrmTranService.SrmTranService();
|
//for (int i = 0; i < 6; i++)
|
//{
|
//tranObj = i;
|
List<int> hasGoodList = srv.HasTranGoods();
|
if (hasGoodList == null || hasGoodList.Count == 0)
|
{
|
continue;
|
}
|
if (hasGoodList[tranObj] == 1)
|
{
|
switch (tranObj)
|
{
|
case 0: tranId = 47; break;
|
case 1: tranId = 48; break;
|
case 2: tranId = 61; break;
|
case 3: tranId = 65; break;
|
case 4: tranId = 32; break;
|
case 5: tranId = 15; break;
|
default: break;
|
}
|
}
|
else
|
{
|
continue;
|
}
|
//}
|
if (tranId == 0)
|
{
|
continue;
|
}
|
//srv.GetSrmConveyorStationInfo(tranId);
|
EntitySrmTranView TranInfo = JsonConvert.DeserializeObject<EntitySrmTranView>(srv.GetSrmConveyorStationInfo(tranId));
|
string containerName = TranInfo.Code;//扫码扫到的
|
decimal weightGet = (decimal)TranInfo.weihgt;
|
if (oldContainerName.ContainsKey(tranId) && times.ContainsKey(tranId))
|
{
|
if (containerName != oldContainerName[tranId])
|
{
|
oldContainerName[tranId] = containerName;
|
times[tranId] = 0;
|
continue;
|
}
|
else
|
{
|
times[tranId]++;
|
if (times[tranId] < 10)
|
{
|
continue;
|
}
|
else
|
{
|
times[tranId] = 0;
|
}
|
}
|
}
|
else
|
{
|
if (!oldContainerName.ContainsKey(tranId))
|
{
|
oldContainerName.Add(tranId, containerName);
|
}
|
if (!times.ContainsKey(tranId))
|
{
|
times.Add(tranId, 0);
|
}
|
continue;
|
}
|
#endregion
|
|
using (Model db = new Model())
|
{
|
|
var container = db.BASE_CONTAINER.FirstOrDefault(x => x.CONTAINERNAME == containerName && x.ENABLE == 1);
|
decimal totalWeightAll = 0;
|
decimal difference = 0;
|
if (container == null || container.ISLOCK == 1)
|
{
|
Helper.Speaking("输送线" + tranId.ToString() + "号器具不可用");
|
InErrorMsg[tranId] = "器具不可用";
|
Thread.Sleep(5000);
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "生成入库任务", "输送线" + tranId.ToString() + "号器具不可用");
|
continue;
|
}
|
if (container != null)
|
{
|
//判断是否已入库
|
BASE_PLACE_VS_CONTAINER pvcOfContainer = db.BASE_PLACE_VS_CONTAINER.FirstOrDefault(x => x.CONTAINERID == container.ID && x.ENABLE == 1);
|
TASK_TASK taskOfContainer = db.TASK_TASK.FirstOrDefault(x => x.CONTAINERID == container.ID && x.ENABLE == 1 && x.HASFINISHED == 0);
|
if (pvcOfContainer != null || taskOfContainer != null)
|
{
|
//重复入库
|
Helper.Speaking("输送线" + tranId.ToString() + "号重复入库");
|
InErrorMsg[tranId] = "重复入库";
|
Thread.Sleep(5000);
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "生成入库任务", "输送线" + tranId.ToString() + "号重复入库");
|
continue;
|
}
|
List<BASE_CONTAINER_VS_ITEM> cviList = container.BASE_CONTAINER_VS_ITEM.Where(x => x.ENABLE == 1).ToList();
|
////最大库容
|
//bool needContinue = false;
|
//foreach (var i in cviList)
|
//{
|
// int num = db.View_BASE_PLACE_VS_CONTAINER.Where(x => x.itemName == i.BASE_ITEM.ITEMNAME).Sum(x => (x.itemNum ?? 0));
|
// if ((i.BASE_ITEM.MAXSTORAGE ?? 0) < num)
|
// {
|
// Helper.Speaking("零件" + i.BASE_ITEM.ITEMNAME + "超出最大库容");
|
// Thread.Sleep(5000);
|
// needContinue = true;
|
// break;
|
// }
|
//}
|
//if (needContinue)
|
//{
|
// continue;
|
//}
|
//称重
|
totalWeightAll = totalWeightAll + container.WEIGHT ?? 0;
|
difference = difference + container.WEIGHTDIFFERENCE ?? 0;
|
foreach (var i in cviList)
|
{
|
totalWeightAll = totalWeightAll + i.TOTALWEIGHT ?? 0;//计算理论重量
|
difference = difference + (i.ITEMNUM ?? 0) * (i.BASE_ITEM.WEIGHTDIFFERENCE ?? 0);//理论总公差
|
}
|
if (totalWeightAll + difference > weightGet && totalWeightAll - difference < weightGet)//符合称重
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("重量:" + weightGet, "器具：" + container.CONTAINERNAME, "输送线：" + tranId.ToString());
|
}
|
else
|
{
|
//超重
|
//WZ.Useful.Commons.LogTextHelper.WriteLine("超重", "器具："+ container.CONTAINERNAME, "输送线："+tranId.ToString());
|
Helper.Speaking("输送线" + tranId.ToString() + "号超重" + "器具" + container.CONTAINERNAME + "称重" + weightGet.ToString());
|
InErrorMsg[tranId] = "超重";
|
Thread.Sleep(5000);
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "生成入库任务", "输送线" + tranId.ToString() + "号超重" + "器具" + container.CONTAINERNAME + "称重" + weightGet.ToString());
|
continue;
|
}
|
|
BASE_PLACE to_place = CreateIn(container.CONTAINERNAME);
|
BASE_CONTAINER_VS_ITEM cvi = db.BASE_CONTAINER_VS_ITEM.FirstOrDefault(x => (x.CONTAINERID ?? 0) == container.ID && x.ENABLE == 1);
|
int userId = 1;
|
if (cvi != null)
|
{
|
userId = cvi.CREATEUSERID ?? 1;
|
}
|
if (to_place != null)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("满入记录日志：第一次找库位" + to_place.PLACE + "；器具号-" + container.CONTAINERNAME);
|
TASK_TASK task = new TASK_TASK()
|
{
|
CONTAINERID = container.ID,
|
CREATETIME = DateTime.Now,
|
CREATEUSERID = userId,
|
ENABLE = 1,
|
ERRORDEVICEID = 0,
|
ERRORMSG = 0,
|
HASFINISHED = 0,
|
HASREADED = 0,
|
ISERROR = 0,
|
OUTTYPE = 0,
|
ISNEEDREDIRECT = 0,
|
TASKLEVEL = 0,
|
//ORDERID = 0,
|
TASKSTATUS = "新建",
|
TASKTYPE = 1,//入库
|
SOURCEPLACE = tranId.ToString(),//待填,根据扫码枪扫的位置口确定入库口
|
TOPLACE = to_place.PLACE,
|
LASTWEIGHT = weightGet.ToString(),
|
};
|
db.TASK_TASK.Add(task);
|
if (db.SaveChanges() > 0)
|
{
|
InErrorMsg[tranId] = "";
|
CreateTaskRecord(task);
|
srv.ClearTranGoods(tranId);//复位
|
}
|
}
|
else
|
{
|
erromsg = "没有充足的空库位！";
|
InErrorMsg[tranId] = "没有充足的空库位";
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "生成入库任务", container.CONTAINERNAME + "没有充足的空库位");
|
|
}
|
}
|
else
|
{
|
erromsg = "未识别到该托盘号！";
|
InErrorMsg[tranId] = "未识别到该托盘号";
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "生成入库任务", container.CONTAINERNAME + "未识别到该托盘号");
|
}
|
}
|
Thread.Sleep(1000);
|
}
|
}
|
catch (Exception ex)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "生成入库任务", ex.ToString());
|
throw;
|
}
|
}
|
|
/// <summary>
|
/// 根据出库单确定要出库库位并生成主任务
|
/// 任务分解
|
/// </summary>
|
/// <param name="obj"></param>
|
public static void CreatOutTask(object obj)
|
{
|
|
while (true)
|
{
|
try
|
{
|
using (Model db = new Model())
|
{
|
var outOrdePlan = db.ORDER_OUTORDER.OrderBy(x => x.DOTIME).FirstOrDefault(x => (x.CHECKOUTNUM ?? 0) < x.TOTALOUTNUM && x.ENABLE == 1 && x.ORDERSTATUS == "执行中");
|
if (outOrdePlan != null)
|
{
|
if (outOrdePlan.ORDERTYPE != "空器具出库")
|
{
|
string itemname = outOrdePlan.BASE_ITEM.ITEMNAME;
|
int planeOutCount = (int)outOrdePlan.TOTALOUTNUM - (int)outOrdePlan.CHECKOUTNUM;
|
|
int errorCount = 0;
|
int taskCount = 0;
|
View_BASE_PLACE_VS_CONTAINER pvcOut = CreateOut(itemname, planeOutCount, outOrdePlan.ORDERTYPE, out errorCount, out taskCount);
|
if (pvcOut != null)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("", pvcOut.place, (pvcOut.isLock ?? 0).ToString());
|
BASE_CONTAINER_VS_ITEM cvi = db.BASE_CONTAINER_VS_ITEM.FirstOrDefault(x => x.BASE_CONTAINER.CONTAINERNAME == pvcOut.containerName && x.ENABLE == 1 && x.BASE_ITEM.ITEMNAME == pvcOut.itemName);
|
if (CreateTask(db, pvcOut, outOrdePlan))
|
{
|
cvi.ORDER_OUTORDER = outOrdePlan;
|
outOrdePlan.CHECKOUTNUM = outOrdePlan.CHECKOUTNUM + pvcOut.itemNum;
|
if (outOrdePlan.CHECKOUTNUM >= outOrdePlan.TOTALOUTNUM)
|
{
|
//outOrdePlan.ORDERSTATUS = "完成";
|
outOrdePlan.ISFINISH = 1;
|
}
|
}
|
|
db.SaveChanges();
|
}
|
else
|
{
|
string status = "库存不足 ";
|
//无可用库位
|
if (errorCount != 9)
|
{
|
status = status + "设备异常 ";
|
}
|
if (taskCount != 0)
|
{
|
status = status + "任务占用 ";
|
}
|
outOrdePlan.ISFINISH = 1;
|
outOrdePlan.ORDERSTATUS = status;
|
db.SaveChanges();
|
}
|
}
|
else
|
{//表示 该出库计划是 空器具出库类型的
|
try
|
{
|
List<TASK_TASK> taskList = db.TASK_TASK.Where(x => x.HASFINISHED == 0 && x.ENABLE == 1).ToList();
|
List<string> containerNameList = new List<string>();
|
foreach (var i in taskList)
|
{
|
containerNameList.Add(i.BASE_CONTAINER.CONTAINERNAME);
|
}
|
//排除故障设备的库位
|
List<int> errorList = new List<int>();
|
SrmService srmService = new SrmService();
|
for (int i = 0; i < 9; i++)
|
{
|
if (srmService.IsNotAlarm(i + 1))
|
{
|
errorList.Add(i + 1);
|
}
|
}
|
var list = outOrdePlan.BASE_ITEM.USECONTAINERTYPE.Split(',').ToList();
|
List<BASE_PLACE_VS_CONTAINER> pvcList = db.BASE_PLACE_VS_CONTAINER.Where(x => list.Contains(x.BASE_CONTAINER.CONTAINERTYPE) && x.ENABLE == 1 && x.BASE_CONTAINER.BASE_CONTAINER_VS_ITEM.Count() == 0 && !containerNameList.Contains(x.BASE_CONTAINER.CONTAINERNAME) && errorList.Contains((x.BASE_PLACE.SRMID ?? 0)) && (x.BASE_PLACE.ISLOCK ?? 0) != 1).ToList();
|
var group = pvcList.GroupBy(x => x.BASE_PLACE.SRMID);
|
int srmid = 0;
|
int count = 0;
|
foreach (var i in group)
|
{
|
if (i.Count() > count || srmid == 0)
|
{
|
count = i.Count();
|
srmid = i.Key ?? 0;
|
}
|
}
|
BASE_PLACE_VS_CONTAINER pvc = pvcList.OrderByDescending(x => x.BASE_PLACE.PLACELEVEL).FirstOrDefault(x => x.BASE_PLACE.SRMID == srmid);
|
if (pvc != null)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("", pvc.BASE_PLACE.PLACE, (pvc.BASE_PLACE.ISLOCK ?? 0).ToString());
|
if (CreateTask(db, pvc, outOrdePlan))
|
{
|
//cvi.ORDER_OUTORDER = outOrdePlan;
|
outOrdePlan.CHECKOUTNUM = outOrdePlan.CHECKOUTNUM + 1;
|
if (outOrdePlan.CHECKOUTNUM >= outOrdePlan.TOTALOUTNUM)
|
{
|
//outOrdePlan.ORDERSTATUS = "完成";
|
outOrdePlan.ISFINISH = 1;
|
}
|
}
|
}
|
else
|
{
|
string status = "库存不足 ";
|
//无可用库位
|
if (errorList.Count != 9)
|
{
|
status = status + "设备异常 ";
|
}
|
if (taskList.Count != 0)
|
{
|
status = status + "任务占用 ";
|
}
|
outOrdePlan.ISFINISH = 1;
|
outOrdePlan.ORDERSTATUS = status;
|
db.SaveChanges();
|
|
}
|
|
db.SaveChanges();
|
}
|
catch (Exception ex)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "生成空器具出库任务", ex.ToString());
|
}
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "生成出库任务", ex.ToString());
|
}
|
Thread.Sleep(1000);
|
|
}
|
|
}
|
|
/// <summary>
|
/// 创建主任务
|
/// </summary>
|
/// <param name="db"></param>
|
/// <param name="pvcvi"></param>
|
/// <returns></returns>
|
private static bool CreateTask(Model db, View_BASE_PLACE_VS_CONTAINER pvcvi, ORDER_OUTORDER order)
|
{
|
try
|
{
|
string tranLine = (order.TRANLINE ?? 0).ToString();
|
if (string.IsNullOrEmpty(tranLine) || tranLine == "0")
|
{
|
tranLine = "67";
|
}
|
using (Model edm = new Model())
|
{
|
//获取每个口的任务占用数量
|
int tranNum1 = edm.TASK_TASK.Where(x => x.TOPLACE == "67" && x.HASFINISHED == 0).Count();//东分拣
|
int tranNum2 = edm.TASK_TASK.Where(x => x.TOPLACE == "51" && x.HASFINISHED == 0).Count();//东冲压1
|
int tranNum3 = edm.TASK_TASK.Where(x => x.TOPLACE == "64" && x.HASFINISHED == 0).Count();//东冲压2
|
int tranNum4 = edm.TASK_TASK.Where(x => x.TOPLACE == "34" && x.HASFINISHED == 0).Count();//西分拣
|
int tranNum5 = edm.TASK_TASK.Where(x => x.TOPLACE == "12" && x.HASFINISHED == 0).Count();//西空托盘
|
int tranNum6 = edm.TASK_TASK.Where(x => x.TOPLACE == "19" && x.HASFINISHED == 0).Count();//西焊装1
|
int tranNum7 = edm.TASK_TASK.Where(x => x.TOPLACE == "30" && x.HASFINISHED == 0).Count();//西焊装2
|
|
if ((order.TRANLINE ?? 0) == 999)
|
{
|
//if (tranNum6 <= tranNum7)
|
if (int.Parse(pvcvi.place.Substring(0, 1)) > 5)//5号巷道以上走19
|
{
|
tranLine = "19";
|
}
|
else
|
{
|
tranLine = "30";
|
}
|
}
|
else if ((order.TRANLINE ?? 0) == 997)
|
{
|
//if (tranNum2 <= tranNum3 && tranNum2 <= tranNum1)
|
if (int.Parse(pvcvi.place.Substring(0, 1)) >= 5)//5号巷道以上走51
|
{
|
tranLine = "51";
|
}
|
//else if (tranNum3 <= tranNum1)
|
//{
|
// tranLine = "64";
|
//}
|
//else
|
//{
|
// tranLine = "67";
|
//}
|
else
|
{
|
tranLine = "64";
|
}
|
}
|
|
}
|
if (pvcvi != null)
|
{
|
var container = db.BASE_CONTAINER.FirstOrDefault(x => x.CONTAINERNAME == pvcvi.containerName);
|
//创建叉车任务
|
TASK_TASK task = new TASK_TASK()
|
{
|
|
CONTAINERID = container.ID,
|
CREATETIME = DateTime.Now,
|
CREATEUSERID = order.CREATORID,
|
ENABLE = 1,
|
ERRORDEVICEID = 0,
|
ERRORMSG = 0,
|
HASFINISHED = 0,
|
HASREADED = 0,
|
ISERROR = 0,
|
OUTTYPE = 0,
|
ISNEEDREDIRECT = 0,
|
TASKLEVEL = 0,
|
ORDERID = order.ID,
|
TASKSTATUS = "新建",
|
TASKTYPE = 2,//出库
|
SOURCEPLACE = pvcvi.place,
|
TOPLACE = tranLine,//待填根据ordertype是焊装还是调价，在选择出库口的位置
|
};
|
db.TASK_TASK.Add(task);
|
|
db.SaveChanges();
|
CreateTaskRecord(task);
|
}
|
return true;
|
}
|
catch (Exception ex)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "CreateTask", ex.ToString());
|
return false;
|
}
|
}
|
|
|
/// <summary>
|
/// 创建主任务
|
/// </summary>
|
/// <param name="db"></param>
|
/// <param name="pvc"></param>
|
/// <returns></returns>
|
private static bool CreateTask(Model db, BASE_PLACE_VS_CONTAINER pvc, ORDER_OUTORDER order)
|
{
|
try
|
{
|
string tranLine = order.TRANLINE.ToString();
|
using (Model edm = new Model())
|
{
|
//获取每个口的任务占用数量
|
int tranNum1 = edm.TASK_TASK.Where(x => x.TOPLACE == "67" && x.HASFINISHED == 0).Count();//东分拣
|
int tranNum2 = edm.TASK_TASK.Where(x => x.TOPLACE == "51" && x.HASFINISHED == 0).Count();//东冲压1
|
int tranNum3 = edm.TASK_TASK.Where(x => x.TOPLACE == "64" && x.HASFINISHED == 0).Count();//东冲压2
|
int tranNum4 = edm.TASK_TASK.Where(x => x.TOPLACE == "34" && x.HASFINISHED == 0).Count();//西分拣
|
int tranNum5 = edm.TASK_TASK.Where(x => x.TOPLACE == "12" && x.HASFINISHED == 0).Count();//西空托盘
|
int tranNum6 = edm.TASK_TASK.Where(x => x.TOPLACE == "19" && x.HASFINISHED == 0).Count();//西焊装1
|
int tranNum7 = edm.TASK_TASK.Where(x => x.TOPLACE == "30" && x.HASFINISHED == 0).Count();//西焊装2
|
int tranNum8 = edm.TASK_TASK.Where(x => x.TOPLACE == "68" && x.HASFINISHED == 0).Count();//东冲压3,[Editby kejj,20230614]
|
|
if ((order.TRANLINE ?? 0) == 999)
|
{
|
//if (tranNum6 <= tranNum7)
|
if (int.Parse(pvc.BASE_PLACE.PLACE.Substring(0, 1)) > 5)//5号巷道以上走19
|
{
|
tranLine = "19";
|
}
|
else
|
{
|
tranLine = "30";
|
}
|
}
|
else if ((order.TRANLINE ?? 0) == 997)
|
{
|
//if (tranNum2 <= tranNum3 && tranNum2 <= tranNum1)
|
if (int.Parse(pvc.BASE_PLACE.PLACE.Substring(0, 1)) >= 5)//5号巷道以上走51
|
{
|
tranLine = "51";
|
}
|
//else if (tranNum3 <= tranNum1)
|
//{
|
// tranLine = "64";
|
//}
|
//else
|
//{
|
// tranLine = "67";
|
//}
|
else
|
{
|
tranLine = "64";
|
}
|
}
|
//else if ((order.TRANLINE ?? 0) == 1000)
|
//{
|
// tranLine = "68";
|
//}
|
}
|
if (pvc != null)
|
{
|
var container = pvc.BASE_CONTAINER;
|
TASK_TASK task = new TASK_TASK()
|
{
|
|
CONTAINERID = container.ID,
|
CREATETIME = DateTime.Now,
|
CREATEUSERID = order.CREATORID,
|
ENABLE = 1,
|
ERRORDEVICEID = 0,
|
ERRORMSG = 0,
|
HASFINISHED = 0,
|
HASREADED = 0,
|
ISERROR = 0,
|
OUTTYPE = 0,
|
ISNEEDREDIRECT = 0,
|
TASKLEVEL = 0,
|
ORDERID = order.ID,
|
TASKSTATUS = "新建",
|
TASKTYPE = 2,//出库
|
SOURCEPLACE = pvc.BASE_PLACE.PLACE,
|
TOPLACE = tranLine,//待填根据ordertype是焊装还是调价，在选择出库口的位置
|
};
|
db.TASK_TASK.Add(task);
|
//创建叉车任务
|
//去掉验证PDA上选择目的地才能生成叉车任务的限制 【Editby shaocx,2023-06-07】
|
//我靠，还不能直接 去掉验证PDA上选择目的地才能生成叉车任务的限制，因为会在这一行报错 carTask.TODESTINATION = order.BASE_PRODUCTIONLINE.PRODUCTIONLINENAME; 【Editby shaocx,2023-06-11】
|
//if ((order.TOLINEID ?? 0) != 0)[Editby kejj,20230621]
|
//{
|
//CAR_CARTASK carTask = new CAR_CARTASK();
|
////通过出库口找目的地
|
//BASE_PRODUCTIONLINE pl = db.BASE_PRODUCTIONLINE.FirstOrDefault(x => x.PRODUCTIONLINECODE == task.TOPLACE);
|
//string detail = "";
|
//foreach (var i in task.BASE_CONTAINER.BASE_CONTAINER_VS_ITEM)
|
//{
|
// if (!string.IsNullOrEmpty(i.BASE_ITEM.ITEMDES))
|
// {
|
// detail = detail + i.BASE_ITEM.ITEMNAME + " " + i.BASE_ITEM.ITEMDES + ":" + i.ITEMNUM + "个;\n";
|
// }
|
//}
|
//if (pl != null)
|
//{
|
// carTask.CARTASKNAME = IWareDataAccess.Car.CARTASK.CarTaskSqlFunc.GetCode();
|
// carTask.FROMDESTINATION = pl.PRODUCTIONLINENAME;
|
// carTask.TODESTINATION = order.BASE_PRODUCTIONLINE?.PRODUCTIONLINENAME;
|
// carTask.CONTAINERID = task.CONTAINERID;
|
// carTask.TASKSTATUS = "新建";
|
// carTask.ENABLE = 1;
|
// carTask.UPDATETIME = DateTime.Now;
|
// carTask.CREATORID = order.CREATORID;
|
// carTask.ORDER_OUTORDER = order;
|
// carTask.ITEMDETAIL = detail;
|
// db.CAR_CARTASK.Add(carTask);
|
//}
|
//}
|
db.SaveChanges();
|
//创建任务记录
|
CreateTaskRecord(task);
|
return true;
|
|
}
|
return false;
|
|
}
|
catch (Exception ex)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("WCS", "CreateTask", ex.ToString());
|
return false;
|
}
|
}
|
|
/// <summary>
|
/// 找出出库库存
|
/// </summary>
|
/// <param name="itemName"></param>
|
/// <param name="itemNum"></param>
|
/// <returns></returns>
|
public static View_BASE_PLACE_VS_CONTAINER CreateOut(string itemName, int itemNum, string type, out int errorCount, out int taskCount)
|
{
|
errorCount = 0;
|
taskCount = 0;
|
using (Model edm = new Model())
|
{
|
//筛选任务中的
|
List<TASK_TASK> taskList = edm.TASK_TASK.Where(x => x.HASFINISHED == 0 && x.ENABLE == 1).ToList();
|
List<string> containerNameList = new List<string>();
|
foreach (var i in taskList)
|
{
|
containerNameList.Add(i.BASE_CONTAINER.CONTAINERNAME);
|
}
|
|
//排除故障设备的库位
|
List<string> errorList = new List<string>();
|
SrmService srmService = new SrmService();
|
for (int i = 1; i < 10; i++)
|
{
|
|
if (srmService.IsNotAlarm(i))
|
{
|
errorList.Add((i).ToString());
|
}
|
//*/
|
//模拟，暂时写死 [Editby shaocx,2022-10-08]
|
//errorList.Add((i).ToString());
|
}
|
|
List<View_BASE_PLACE_VS_CONTAINER> pvcList = new List<View_BASE_PLACE_VS_CONTAINER>();
|
if (type != null && (type.Contains("冲压待返修") || type.Contains("焊装待返修")))
|
{
|
pvcList = edm.View_BASE_PLACE_VS_CONTAINER.Where(x => x.itemName == itemName && x.enable == 1 && x.status == "IN" && !containerNameList.Contains(x.containerName) && (x.isLock ?? 0) == 0 && errorList.Contains(x.place.Substring(0, 1)) && (x.inType != null && x.inType == type)).ToList();
|
}
|
else
|
{
|
pvcList = edm.View_BASE_PLACE_VS_CONTAINER.Where(x => x.itemName == itemName && x.enable == 1 && x.status == "IN" && !containerNameList.Contains(x.containerName) && (x.isLock ?? 0) == 0 && errorList.Contains(x.place.Substring(0, 1)) && (x.inType == null || !x.inType.Contains("返修"))).ToList();
|
}
|
//优先余料回库
|
List<View_BASE_PLACE_VS_CONTAINER> pvcReturnList = pvcList.Where(x => x.inType == "余料回库").ToList();
|
if (pvcReturnList.Count != 0)//存在
|
{
|
View_BASE_PLACE_VS_CONTAINER pvcReturnOut = pvcReturnList.OrderBy(x => x.itemNum).ThenByDescending(x => x.placeLevel).FirstOrDefault();
|
return pvcReturnOut;
|
}
|
|
//选择零件数量大的巷道
|
var group = pvcList.GroupBy(x => x.place.Substring(0, 1)).ToList();
|
string srmid = "";
|
int count = 0;
|
foreach (var i in group)
|
{
|
if (i.Count() < count || srmid == "")
|
{
|
count = i.Count();
|
srmid = i.Key;
|
}
|
}
|
//判断是否故障
|
|
List<View_BASE_PLACE_VS_CONTAINER> pvcSrmList = edm.View_BASE_PLACE_VS_CONTAINER.Where(x =>
|
x.place.Substring(0, 1) == srmid &&
|
x.itemName == itemName &&
|
x.enable == 1 &&
|
(x.isLock ?? 0) == 0 &&
|
(x.isFull ?? 0) == 1 &&
|
!containerNameList.Contains(x.containerName)).ToList();
|
//View_BASE_PLACE_VS_CONTAINER pvcOut = pvcSrmList.OrderByDescending(x => x.placeLevel).FirstOrDefault(x => x.itemNum >= itemNum);
|
//if (pvcOut != null)
|
//{
|
// //存在一箱满足
|
//}
|
//else
|
//{
|
// //不存在一箱满足，则出最少
|
// pvcOut = pvcSrmList.OrderByDescending(x => x.itemNum).ThenByDescending(x => x.placeLevel).FirstOrDefault();
|
//}
|
|
//优先出少的
|
DateTime timeNow = DateTime.Now;
|
|
View_BASE_PLACE_VS_CONTAINER pvcOut = pvcSrmList.OrderBy(x => x.CVIUpdateTime).ThenBy(x => x.itemNum).ThenByDescending(x => x.placeLevel).FirstOrDefault(x => (timeNow - (x.CVIUpdateTime ?? DateTime.Now)).TotalDays > 5);
|
if (pvcOut == null)
|
{
|
pvcOut = pvcSrmList.OrderBy(x => x.itemNum).ThenByDescending(x => x.placeLevel).FirstOrDefault();
|
}
|
errorCount = errorList.Count;
|
taskCount = taskList.Count;
|
return pvcOut;
|
}
|
}
|
|
|
#region 寻找空库位，原先的方法
|
/// <summary>
|
/// 找出入库库位（寻找空库位）
|
/// </summary>
|
//public static BASE_PLACE CreateIn(string containerName)
|
//{
|
// using (Model edm = new Model())
|
// {
|
// BASE_CONTAINER container = edm.BASE_CONTAINER.FirstOrDefault(x => x.CONTAINERNAME == containerName);
|
// //排除故障设备的库位
|
// List<int> goodSrmList = new List<int>();//可用的堆垛机集合 [Editby shaocx,2022-10-08]
|
// SrmService srmService = new SrmService();
|
// for (int i = 1; i < 10; i++)
|
// {
|
// if (srmService.IsNotAlarm(i))
|
// {
|
// goodSrmList.Add(i);
|
// }
|
// }
|
|
// //注意：表BASE_PALLET的PALLETTYPE 要对应 表BASE_PLACETYPE的PlaceType字段
|
// //下面是根据托盘类型去寻找 能存放该托盘类型的库区
|
// //例如：2巷道和4巷道，都是能存放托盘类型 G和H的
|
// List<BASE_PLACE> placeList = edm.BASE_PLACE.Where(x => container.BASE_PALLET.PALLETTYPE.Contains(x.BASE_PLACETYPE.PLACETYPE) && (x.ISLOCK ?? 0) == 0 && (x.ISFULL ?? 0) == 0 && goodSrmList.Contains((x.SRMID ?? 0))).ToList();
|
// //记录任务中的占用数量
|
// List<TASK_TASK> taskList = edm.TASK_TASK.Where(x => x.HASFINISHED == 0 && x.TASKTYPE == 1 && x.BASE_CONTAINER.BASE_PALLET.PALLETTYPE == container.BASE_PALLET.PALLETTYPE && x.TASKTYPE == 1).ToList();
|
// var groupTask = taskList.GroupBy(x => x.TOPLACE.Substring(0, 1)).ToList();//当前未结束的、指定托盘类型的入库任务目标位置的分组集合
|
|
// //计算此种的数量
|
// BASE_CONTAINER_VS_ITEM cvi = edm.BASE_CONTAINER_VS_ITEM.FirstOrDefault(x => x.BASE_CONTAINER.CONTAINERNAME == containerName);
|
// List<View_BASE_PLACE_VS_CONTAINER> placeFullList = new List<View_BASE_PLACE_VS_CONTAINER>();
|
// if (cvi == null)//空器具
|
// {
|
// placeFullList = edm.View_BASE_PLACE_VS_CONTAINER.Where(x => x.containerName.Contains(container.CONTAINERTYPE) && string.IsNullOrEmpty(x.itemName)).ToList();
|
|
// }
|
// else
|
// {
|
// placeFullList = edm.View_BASE_PLACE_VS_CONTAINER.Where(x => x.itemName == cvi.BASE_ITEM.ITEMNAME).ToList();
|
// }
|
|
// //数量少的先
|
// var groupFull = placeFullList.GroupBy(x => x.place.Substring(0, 1)).ToList();
|
|
// var groupSrmList = placeList.GroupBy(x => x.SRMID).ToList();//按照可用的堆垛机分组的库位集合
|
// int srmid = 0;//要寻找空库位的堆垛机区域
|
// List<string> fullPlaceList = new List<string>();
|
// int count = 0;
|
// int countFull = 0;
|
|
// foreach (var groupSrm in groupSrmList)
|
// {
|
// int placeCount = 0;//可用的 库位数量
|
// var task = groupTask.FirstOrDefault(x => x.Key == groupSrm.Key.ToString());
|
// if (task != null)
|
// {
|
// placeCount = groupSrm.Count() - task.Count();
|
// foreach (var z in task)
|
// {
|
// fullPlaceList.Add(z.TOPLACE);
|
// }
|
// }
|
// else
|
// {
|
// placeCount = groupSrm.Count();
|
// }
|
// if (placeCount > 2)//避免满库
|
// {
|
|
// //器具=数量比较
|
// var groupFullOne = groupFull.FirstOrDefault(x => x.Key == (groupSrm.Key ?? 0).ToString());
|
// int fullPlaceCount = 0;
|
// if (groupFullOne != null)
|
// {
|
// fullPlaceCount = groupFullOne.Count();
|
// }
|
// //int fullPlaceCount = groupFull[(i.Key ?? 0)].Count();
|
// if (fullPlaceCount < countFull || srmid == 0)
|
// {
|
// if (fullPlaceCount == countFull)
|
// {
|
// if (placeCount > count)
|
// {
|
// countFull = fullPlaceCount;
|
// srmid = groupSrm.Key ?? 0;
|
// count = placeCount;
|
// }
|
// }
|
// else
|
// {
|
// countFull = fullPlaceCount;
|
// srmid = groupSrm.Key ?? 0;
|
// count = placeCount;
|
// }
|
|
// }
|
// ////空库位比较
|
// //if (placeCount > count || srmid == 0)
|
// //{
|
// // count = placeCount;
|
// // srmid = i.Key ?? 0;
|
// //}
|
// }
|
// }
|
// ////兼容
|
// BASE_PLACE finPlace = placeList.OrderBy(x => x.PLACELEVEL).ThenBy(x => x.LAYER).ThenBy(x => System.Math.Abs((x.COL ?? 0) - 9)).FirstOrDefault(x => x.SRMID == srmid && !fullPlaceList.Contains(x.PLACE));
|
// if (finPlace == null)
|
// {
|
|
// if (container.BASE_PALLET.PALLETTYPE.Contains("H"))
|
// {
|
|
// List<BASE_PLACE> placeList2 = edm.BASE_PLACE.Where(x => x.BASE_PLACETYPE.PLACETYPE.Contains("G") && (x.ISLOCK ?? 0) == 0 && (x.ISFULL ?? 0) == 0 && goodSrmList.Contains((x.SRMID ?? 0))).ToList();
|
// //记录任务中的占用数量
|
// List<TASK_TASK> taskList2 = edm.TASK_TASK.Where(x => x.HASFINISHED == 0 && x.TASKTYPE == 1 && x.BASE_CONTAINER.BASE_PALLET.PALLETTYPE == container.BASE_PALLET.PALLETTYPE && x.TASKTYPE == 1).ToList();
|
// var groupTask2 = taskList2.GroupBy(x => x.TOPLACE.Substring(0, 1)).ToList();
|
|
// var group2 = placeList2.GroupBy(x => x.SRMID).ToList();
|
// int srmid2 = 0;
|
// List<string> fullPlaceList2 = new List<string>();
|
// count = 0;
|
// countFull = 0;
|
|
// foreach (var i in group2)
|
// {
|
// int placeCount = 0;
|
// var task = groupTask2.FirstOrDefault(x => x.Key == i.Key.ToString());
|
// if (task != null)
|
// {
|
// placeCount = i.Count() - task.Count();
|
// foreach (var z in task)
|
// {
|
// fullPlaceList2.Add(z.TOPLACE);
|
// }
|
// }
|
// else
|
// {
|
// placeCount = i.Count();
|
// }
|
// if (placeCount > 2)//避免满库
|
// {
|
|
// //器具=数量比较
|
// var groupFullOne = groupFull.FirstOrDefault(x => x.Key == (i.Key ?? 0).ToString());
|
// int fullPlaceCount = 0;
|
// if (groupFullOne != null)
|
// {
|
// fullPlaceCount = groupFullOne.Count();
|
// }
|
// //int fullPlaceCount = groupFull[(i.Key ?? 0)].Count();
|
// if (fullPlaceCount < countFull || srmid2 == 0)
|
// {
|
// if (fullPlaceCount == countFull)
|
// {
|
// if (placeCount > count)
|
// {
|
// countFull = fullPlaceCount;
|
// srmid2 = i.Key ?? 0;
|
// count = placeCount;
|
// }
|
// }
|
// else
|
// {
|
// countFull = fullPlaceCount;
|
// srmid2 = i.Key ?? 0;
|
// count = placeCount;
|
// }
|
|
// }
|
// ////空库位比较
|
// //if (placeCount > count || srmid2 == 0)
|
// //{
|
// // count = placeCount;
|
// // srmid2 = i.Key ?? 0;
|
// //}
|
// }
|
// }
|
// finPlace = placeList2.OrderBy(x => x.PLACELEVEL).ThenBy(x => x.LAYER).ThenBy(x => System.Math.Abs((x.COL ?? 0) - 9)).FirstOrDefault(x => x.SRMID == srmid2 && !fullPlaceList2.Contains(x.PLACE));
|
// }
|
// }
|
// return finPlace;
|
// }
|
//}
|
#endregion
|
|
#region 寻找空库位，现在的方法
|
/// <summary>
|
/// 找出入库库位（寻找空库位）
|
/// </summary>
|
public static BASE_PLACE CreateIn(string containerName, int iSrm = 0)
|
{
|
using (Model edm = new Model())
|
{
|
#region 组织数据
|
|
BASE_CONTAINER container = edm.BASE_CONTAINER.FirstOrDefault(x => x.CONTAINERNAME == containerName);
|
|
//排除故障设备的库位
|
List<int> goodSrmList = new List<int>();//可用的堆垛机集合 [Editby shaocx,2022-10-08]
|
SrmService srmService = new SrmService();
|
if (iSrm == 0)
|
{
|
for (int i = 1; i < 10; i++)
|
{
|
|
if (srmService.IsNotAlarm(i))
|
{
|
goodSrmList.Add(i);
|
}
|
//*/
|
//模拟，暂时写死 [Editby shaocx,2022-10-08]
|
//goodSrmList.Add(i);
|
}
|
}
|
else
|
{
|
goodSrmList.Add(iSrm);
|
}
|
|
//计算此种的数量
|
BASE_CONTAINER_VS_ITEM cvi = edm.BASE_CONTAINER_VS_ITEM.FirstOrDefault(x => x.BASE_CONTAINER.CONTAINERNAME == containerName);
|
List<View_BASE_PLACE_VS_CONTAINER> pvcList = new List<View_BASE_PLACE_VS_CONTAINER>();//PVC列表
|
if (cvi == null)
|
{//表示该托盘没有被物料绑定
|
//寻找 库存中，托盘类型一致，并且没有绑定物料的 PVC列表
|
pvcList = edm.View_BASE_PLACE_VS_CONTAINER.Where(x => x.containerName.Contains(container.CONTAINERTYPE) && string.IsNullOrEmpty(x.itemName)).ToList();
|
}
|
else
|
{//表示该托盘已经被物料绑定
|
//寻找 库存中，绑定该中物料的 PVC列表
|
pvcList = edm.View_BASE_PLACE_VS_CONTAINER.Where(x => x.itemName == cvi.BASE_ITEM.ITEMNAME).ToList();
|
}
|
|
//数量少的先
|
var groupPvcList = pvcList.GroupBy(x => x.place.Substring(0, 1)).ToList();//按照巷道分组的PVC分组
|
|
|
//记录任务中的占用数量
|
List<TASK_TASK> doingTaskList = edm.TASK_TASK.Where(x => x.HASFINISHED == 0 && x.TASKTYPE == 1 && x.BASE_CONTAINER.BASE_PALLET.PALLETTYPE == container.BASE_PALLET.PALLETTYPE && x.TASKTYPE == 1).ToList();
|
var groupDoingTask = doingTaskList.GroupBy(x => x.TOPLACE.Substring(0, 1)).ToList();//当前未结束的、指定托盘类型的入库任务目标位置的分组集合
|
|
|
#endregion
|
|
//第一次获取空库位
|
//注意：表BASE_PALLET的PALLETTYPE 要对应 表BASE_PLACETYPE的PlaceType字段
|
//下面是根据托盘类型去寻找 能存放该托盘类型的库区
|
//例如：2巷道和4巷道，都是能存放托盘类型 G和H的
|
List<BASE_PLACE> emptyPlaceList = edm.BASE_PLACE.Where(x => container.BASE_PALLET.PALLETTYPE.Contains(x.BASE_PLACETYPE.PLACETYPE) && (x.ISLOCK ?? 0) == 0 && (x.ISFULL ?? 0) == 0 && goodSrmList.Contains((x.SRMID ?? 0))).ToList();
|
|
|
BASE_PLACE finPlace = null;
|
|
bool isContainsH = container.BASE_PALLET.PALLETTYPE.Contains("H");
|
finPlace = CommonGetEmptyPlace(emptyPlaceList, groupDoingTask, groupPvcList);
|
if (finPlace == null)
|
{
|
if (isContainsH)
|
{
|
List<BASE_PLACE> emptyPlaceList2 = edm.BASE_PLACE.Where(x => x.BASE_PLACETYPE.PLACETYPE.Contains("G") && (x.ISLOCK ?? 0) == 0 && (x.ISFULL ?? 0) == 0 && goodSrmList.Contains((x.SRMID ?? 0))).ToList();
|
|
|
finPlace = CommonGetEmptyPlace(emptyPlaceList2, groupDoingTask, groupPvcList);
|
}
|
}
|
return finPlace;
|
}
|
}
|
|
/// <summary>
|
/// 通用获取空库位方法
|
/// </summary>
|
/// <param name="emptyPlaceList"></param>
|
/// <param name="groupDoingTask"></param>
|
/// <param name="groupPvcList"></param>
|
/// <returns></returns>
|
private static BASE_PLACE CommonGetEmptyPlace(List<BASE_PLACE> emptyPlaceList, List<IGrouping<string, TASK_TASK>> groupDoingTask, List<IGrouping<string, View_BASE_PLACE_VS_CONTAINER>> groupPvcList)
|
{
|
var groupEmptyPlaceList = emptyPlaceList.GroupBy(x => x.SRMID).ToList();//按照可用的堆垛机分组的库位集合
|
int srmid = 0;//要寻找空库位的堆垛机区域
|
List<string> fullPlaceList = new List<string>();
|
int last_empty_placeCount = 0;//循环的上个巷道的可用空库位的个数
|
int last_fullPlaceCount = 0;//循环的上个巷道的满库位个数
|
|
foreach (var groupEmptyPlace in groupEmptyPlaceList)
|
{
|
int empty_placeCount = 0;//可用的 库位数量
|
int fullPlaceCount = 0;//本巷道的已经有托盘占用的个数
|
|
//获取剩余空闲库位数
|
CommonGetEmpty_placeCount(ref empty_placeCount, ref fullPlaceList, ref fullPlaceCount, groupDoingTask, groupEmptyPlace, groupPvcList);
|
|
if (empty_placeCount > 4)//避免满库,由2修改为4，2024/1/9
|
{//这里为什么要判断必须空库位数量大于2，因为必须要留2个位置用于 双伸位的，转运功能！
|
|
//if (fullPlaceCount == 0)
|
//{//说明该巷道没有满库位的情况啊，要优先入他 【Editby shaocx,2022-11-8】
|
// CommonSetCountValue(fullPlaceCount, groupEmptyPlace, empty_placeCount, ref last_fullPlaceCount, ref srmid, ref last_empty_placeCount);
|
// break;//终止循环
|
//}
|
//int fullPlaceCount = groupFull[(i.Key ?? 0)].Count();
|
if (srmid == 0)
|
{//第一次循环
|
CommonSetCountValue(fullPlaceCount, groupEmptyPlace, empty_placeCount, ref last_fullPlaceCount, ref srmid, ref last_empty_placeCount);
|
continue;
|
}
|
if (empty_placeCount > last_empty_placeCount)
|
{//如果本巷道可用空库位的数量 大于 循环的上个巷道的可用空库位的个数
|
//即一个原则：哪个巷道的空库位多，就放哪个巷道！
|
CommonSetCountValue(fullPlaceCount, groupEmptyPlace, empty_placeCount, ref last_fullPlaceCount, ref srmid, ref last_empty_placeCount);
|
}
|
|
//if (fullPlaceCount < last_fullPlaceCount)
|
//{//如果是第一次循环 或者是 本巷道的满库位的个数 小于 循环的上个巷道的满库位个数
|
// if (fullPlaceCount == last_fullPlaceCount)
|
// {//如果本次巷道的满库位个数 等于 循环的上个巷道的满库位个数
|
// if (empty_placeCount > last_empty_placeCount)
|
// {//如果本巷道可用空库位的数量 大于 循环的上个巷道的可用空库位的个数
|
// //last_countFull = fullPlaceCount;
|
// //srmid = groupSrm.Key ?? 0;
|
// //last_count = placeCount;
|
// CommonSetCountValue(fullPlaceCount, groupEmptyPlace, empty_placeCount, ref last_fullPlaceCount, ref srmid, ref last_empty_placeCount);
|
// }
|
// }
|
// else
|
// {
|
// //last_countFull = fullPlaceCount;
|
// //srmid = groupSrm.Key ?? 0;
|
// //last_count = placeCount;
|
// CommonSetCountValue(fullPlaceCount, groupEmptyPlace, empty_placeCount, ref last_fullPlaceCount, ref srmid, ref last_empty_placeCount);
|
// }
|
|
//}
|
////空库位比较
|
//if (placeCount > count || srmid == 0)
|
//{
|
// count = placeCount;
|
// srmid = i.Key ?? 0;
|
//}
|
}
|
}
|
//优先查询 指定srmid的库区
|
BASE_PLACE finPlace = CommonQueryPlace(emptyPlaceList, srmid, fullPlaceList);
|
return finPlace;
|
}
|
|
/// <summary>
|
/// 获取空库位数
|
/// </summary>
|
/// <param name="empty_placeCount"></param>
|
/// <param name="fullPlaceList"></param>
|
/// <param name="fullPlaceCount"></param>
|
/// <param name="groupDoingTask"></param>
|
/// <param name="groupEmptyPlace"></param>
|
/// <param name="groupPvcList"></param>
|
private static void CommonGetEmpty_placeCount(ref int empty_placeCount, ref List<string> fullPlaceList, ref int fullPlaceCount,
|
List<IGrouping<string, TASK_TASK>> groupDoingTask, IGrouping<int?, BASE_PLACE> groupEmptyPlace, List<IGrouping<string, View_BASE_PLACE_VS_CONTAINER>> groupPvcList)
|
{
|
//此处再增加筛选，去掉有库存的、和正在有任务占用的，防止满入 【EditBy shaocx,2022-11-09】
|
var doingTasks = groupDoingTask.FirstOrDefault(x => x.Key == groupEmptyPlace.Key.ToString());
|
if (doingTasks != null)
|
{
|
empty_placeCount = groupEmptyPlace.Count() - doingTasks.Count();
|
foreach (var z in doingTasks)
|
{
|
fullPlaceList.Add(z.TOPLACE);//正在有任务占用的
|
}
|
}
|
else
|
{
|
empty_placeCount = groupEmptyPlace.Count();
|
}
|
//过滤有PVC数据的
|
var groupFullOne = groupPvcList.FirstOrDefault(x => x.Key == (groupEmptyPlace.Key ?? 0).ToString());//寻找该巷道的PVC分组
|
if (groupFullOne != null)
|
{
|
foreach (var z in groupFullOne)
|
{
|
fullPlaceList.Add(z.place);//有库存的
|
}
|
//empty_placeCount = empty_placeCount - groupFullOne.Count();
|
|
fullPlaceCount = groupFullOne.Count();
|
}
|
}
|
|
private static BASE_PLACE CommonQueryPlace(List<BASE_PLACE> placeList, int srmid, List<string> fullPlaceList)
|
{
|
BASE_PLACE finPlace = placeList.OrderBy(x => x.PLACELEVEL).ThenBy(x => x.LAYER).ThenBy(x => System.Math.Abs((x.COL ?? 0) - 9)).FirstOrDefault(x => x.SRMID == srmid && !fullPlaceList.Contains(x.PLACE));
|
return finPlace;
|
}
|
|
/// <summary>
|
/// 统一设置数值
|
/// </summary>
|
/// <param name="fullPlaceCount"></param>
|
/// <param name="groupEmptyPlace"></param>
|
/// <param name="empty_placeCount"></param>
|
/// <param name="last_fullPlaceCount"></param>
|
/// <param name="srmid"></param>
|
/// <param name="last_empty_placeCount"></param>
|
private static void CommonSetCountValue(int fullPlaceCount, IGrouping<int?, BASE_PLACE> groupEmptyPlace, int empty_placeCount, ref int last_fullPlaceCount, ref int srmid, ref int last_empty_placeCount)
|
{
|
last_fullPlaceCount = fullPlaceCount;
|
srmid = groupEmptyPlace.Key ?? 0;
|
last_empty_placeCount = empty_placeCount;
|
}
|
#endregion
|
|
|
|
/// <summary>
|
/// 创建任务记录
|
/// </summary>
|
/// <param name="db"></param>
|
/// <param name="pvc"></param>
|
/// <param name="order"></param>
|
public static bool CreateTaskRecord(TASK_TASK task)
|
{
|
using (Model edm = new Model())
|
{
|
if (task.BASE_CONTAINER.BASE_CONTAINER_VS_ITEM.Count != 0)
|
{
|
foreach (var i in task.BASE_CONTAINER.BASE_CONTAINER_VS_ITEM)
|
{
|
ORDER_OUTORDER order = edm.ORDER_OUTORDER.FirstOrDefault(x => x.ID == (task.ORDERID ?? 0));
|
TASK_RECORD taskRecord = new TASK_RECORD()
|
{
|
|
TYPE = task.TASKTYPE ?? 0,
|
CREATETIME = DateTime.Now,
|
ITEMID = i.BASE_ITEM.ID,
|
CONTAINERID = task.BASE_CONTAINER.ID,
|
TASKID = task.ID,
|
ENABLE = 1,
|
ITEMCOUNT = i.ITEMNUM ?? 0,
|
ISMAINOUT = 0,
|
CREATEUSERID = task.CREATEUSERID ?? 1
|
};
|
if (order != null)
|
{
|
taskRecord.OUTORDERCODE = order.OUTORDERCODE;
|
if (order.ITEMID == taskRecord.ITEMID)
|
{
|
taskRecord.ISMAINOUT = 1;//属于主要出库零件
|
}
|
}
|
edm.TASK_RECORD.Add(taskRecord);
|
}
|
}
|
else
|
{
|
ORDER_OUTORDER order = edm.ORDER_OUTORDER.FirstOrDefault(x => x.ID == (task.ORDERID ?? 0));
|
TASK_RECORD taskRecord = new TASK_RECORD()
|
{
|
|
TYPE = task.TASKTYPE ?? 0,
|
CREATETIME = DateTime.Now,
|
CONTAINERID = task.BASE_CONTAINER.ID,
|
TASKID = task.ID,
|
ENABLE = 1,
|
ISMAINOUT = 0,
|
CREATEUSERID = task.CREATEUSERID ?? 1
|
};
|
if (order != null)
|
{
|
taskRecord.OUTORDERCODE = order.OUTORDERCODE;
|
}
|
edm.TASK_RECORD.Add(taskRecord);
|
}
|
|
if (edm.SaveChanges() > 0)
|
{
|
return true;
|
}
|
else
|
{
|
return false;
|
}
|
}
|
}
|
|
/// <summary>
|
/// 闲时优化
|
/// </summary>
|
public static void CreateMove(object obj)
|
{
|
SrmService srmService = new SrmService();
|
while (true)
|
{
|
Thread.Sleep(5000);
|
int srmId = (int)obj;
|
if (needMove[srmId - 1] && srmService.IsNotUse(srmId))
|
{
|
using (Model edm = new Model())
|
{
|
if (srmId == 2 || srmId == 3 || srmId == 4 || srmId == 6 || srmId == 7 || srmId == 8 || srmId == 9)
|
{
|
BASE_PLACE_VS_CONTAINER pvcFrom = edm.BASE_PLACE_VS_CONTAINER.FirstOrDefault(x => x.BASE_PLACE.ROW == 2 || x.BASE_PLACE.ROW == 3);
|
if (pvcFrom != null)
|
{
|
BASE_PLACE nextPlace = pvcFrom.BASE_PLACE;
|
if (nextPlace != null && nextPlace.ISFULL == 1)//需要移库
|
{
|
TASK_TASK task = new TASK_TASK();
|
task.SOURCEPLACE = nextPlace.PLACE;
|
|
BASE_PLACE newPlace = edm.BASE_PLACE.OrderBy(x => x.PLACELEVEL).ThenBy(x => x.LAYER).ThenBy(x => x.COL).FirstOrDefault(x => x.SRMID == srmId && (x.ISFULL ?? 0) == 0 && (x.ISLOCK ?? 0) == 0 && x.BASE_PLACETYPE.PLACETYPE == nextPlace.BASE_PLACETYPE.PLACETYPE);
|
if (newPlace != null)
|
{
|
task.TOPLACE = newPlace.PLACE;
|
task.HASREADED = 0;
|
task.HASFINISHED = 0;
|
task.TASKTYPE = 3;
|
//task.CREATEUSERID = 1;
|
task.TASKSTATUS = "新建";
|
task.TASKLEVEL = 0;
|
task.CONTAINERID = pvcFrom.CONTAINERID;
|
task.ENABLE = 1;
|
BASE_PLACE_VS_CONTAINER nextPvc = edm.BASE_PLACE_VS_CONTAINER.FirstOrDefault(x => x.BASE_PLACE.PLACE == nextPlace.PLACE && x.ENABLE == 1);
|
if (nextPvc == null)
|
{
|
nextPlace.ISFULL = 0;
|
edm.SaveChanges();
|
continue;//自动校正
|
}
|
edm.TASK_TASK.Add(task);
|
edm.SaveChanges();
|
continue;
|
}
|
else
|
{
|
//无库位可移库
|
continue;
|
}
|
}
|
}
|
|
}
|
}
|
}
|
}
|
}
|
|
public static void UpdateCarTask()
|
{
|
while (true)
|
{
|
try
|
{
|
using (Model model = new Model())
|
{
|
var carTaskList = model.CAR_CARTASK.Where(u => DbFunctions.DiffHours(u.UPDATETIME, DateTime.Now) > 23 && u.TASKSTATUS == "新建").ToList();
|
foreach (var item in carTaskList)
|
{
|
item.TASKSTATUS = "完成";
|
}
|
model.SaveChanges();
|
}
|
}
|
catch (Exception ex)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("更新叉车任务异常", "UpdateCarTask", ex.ToString());
|
}
|
Thread.Sleep(20000);
|
}
|
}
|
}
|
}
|
