WMSPrjInstance/HH-0129_ZhongCeJinTan.git

			@@ -14,6 +14,7 @@
			using System.Threading;
			using System.Threading.Tasks;
			using System.Web.Services.Description;
			using Top.Api;
			using static HH.WCS.ZhongCeJinTan.api.ApiModel;

			namespace HH.WCS.ZhongCeJinTan.core
			@@ -23,6 +24,8 @@
			/// </summary>
			internal class Monitor
			{
			private static object CreateTaskLocker = new object();

			/// <summary>
			/// 根据作业创建对应任务
			/// </summary>
			@@ -30,12 +33,18 @@
			{
			var db = new SqlHelper<object>().GetInstance();

			// 获取所有等待中的作业
			var operations = db.Queryable<WmsWork>().Where(p => p.N_B_STATE == 0).ToList();
			foreach (var operation in operations)
			lock (CreateTaskLocker)
			{
			TaskHelper.CreateTask(operation);
			// 获取所有等待中的作业
			var operations = db.Queryable<WmsWork>().Where(p => p.N_B_STATE == 0).ToList();

			foreach (var operation in operations)
			{
			TaskHelper.CreateTask(operation);
			}
			}


			}


			@@ -88,22 +97,33 @@
			public static void UpdateOutTaskPriority()
			{
			var db = new SqlHelper<object>().GetInstance();
			var st = Settings.outMinutePriority;
			//var st = Settings.outMinutePriority;

			var st = TaskHelper.GetOutMinutePriority();

			if (st==null)
			{
			return;
			}

			var list = TaskHelper.GetWcsTaskListByState("执行", "agv", "出库");

			foreach (var item in list)
			{
			var action = db.Queryable<WmsTaskAction>().Where(p => p.S_TASK_CODE==item.S_CODE && p.N_ACTION_CODE == 1).First();
			if (action != null)
			{
			var action3 = db.Queryable<WmsTaskAction>().Where(p => p.S_TASK_CODE == item.S_CODE && p.N_ACTION_CODE == 3).First();
			if (action3 == null)
			var wcsTask = TaskHelper.GetTaskByState("完成", "wcs", item.S_OP_CODE, "出库");
			if (wcsTask != null) {
			var action = db.Queryable<WmsTaskAction>().Where(p => p.S_TASK_CODE == item.S_CODE && p.N_ACTION_CODE == 1).First();
			if (action != null)
			{
			if (DateTime.Now.Subtract(action.T_CREATE).TotalMinutes > st.Minute)
			var action3 = db.Queryable<WmsTaskAction>().Where(p => p.S_TASK_CODE == item.S_CODE && p.N_ACTION_CODE == 3).First();
			if (action3 == null)
			{
			item.N_PRIORITY += st.Priority;
			db.Updateable(item).UpdateColumns(it => new { it.N_PRIORITY }).ExecuteCommand();
			NDCApi.ChangeOrderPri(item.S_CODE, item.N_PRIORITY);
			if (DateTime.Now.Subtract(action.T_CREATE).TotalMinutes > st.Minute)
			{
			item.N_PRIORITY += st.Priority;
			db.Updateable(item).UpdateColumns(it => new { it.N_PRIORITY }).ExecuteCommand();
			NDCApi.ChangeOrderPri(item.S_CODE, item.N_PRIORITY);
			}
			}
			}
			}
			@@ -154,6 +174,7 @@
			TaskHelper.UpdateStatus(wmsTask, "取货完成");
			LocationHelper.UnLockLoc(wmsTask.S_START_LOC);
			TaskProcess.OperateStatus(wmsTask, 4);
			TaskHelper.opMesTask(wmsTask, 1);
			break;
			case 5:
			TaskHelper.UpdateStatus(wmsTask, "开始卸货");
			@@ -179,38 +200,109 @@
			TaskHelper.End(wmsTask);
			break;
			case 7:

			var wcsTask1 = TaskHelper.GetTaskByWorkNo(wmsTask.S_OP_CODE, "wcs");
			if (wcsTask1 != null)
			TaskProcess.OperateStatus(wmsTask, 7);
			WmsTaskAction ac4 = TaskHelper.GetActionRecord(wmsTask.S_CODE, "4");
			//已经取货完成
			if (ac4 != null)
			{
			//agv执行通知 wcs取消
			WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no);
			if (!TaskHelper.CheckActionRecordExist(wcsTask1.S_CODE, "6"))
			TaskHelper.End(wmsTask);
			//如果是二段任务则下发立库任务
			var wcsTask2 = TaskHelper.GetTaskByState("未执行", "wcs", wmsTask.S_OP_CODE, "入库");
			if (wcsTask2 != null)
			{
			TaskHelper.Fail(wcsTask1);
			TaskProcess.OperateStatus(wcsTask1, 7);
			LocationHelper.LockLoc(wcsTask2.S_START_LOC, "出库锁", 2);
			WcsTask.WcsTaskEntity(wcsTask2);
			}
			}
			else {
			TaskHelper.Fail(wmsTask);
			if (!LocationHelper.GetErroArea(wmsTask.S_END_AREA))
			{
			TaskHelper.opMesTask(wmsTask, 3);
			}
			else
			{
			ContainerHelper.delCntr(wmsTask.S_CNTR_CODE);
			ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE);
			ContainerHelper.delCntrLoc(wmsTask.S_CNTR_CODE);
			}
			}

			TaskHelper.Fail(wmsTask);
			TaskProcess.OperateStatus(wmsTask, 7);
			//入库或者回库任务取消删除托盘物料
			if (wmsTask.S_TYPE.Contains("入库") \|\| wmsTask.S_TYPE.Contains("回库"))
			var wcsTask1 = TaskHelper.GetTaskByWorkNo(wmsTask.S_OP_CODE, "wcs");
			if (wcsTask1 != null)
			{
			TaskProcess.OperateStatus(wcsTask1, 7);

			if (wmsTask.S_TYPE.Contains("出库"))
			{
			var ac1101 = TaskHelper.GetWcsSafety(wmsTask.S_CODE, "1101");
			var ac1102 = TaskHelper.GetWcsSafety(wmsTask.S_CODE, "1102");
			if ((ac1101 != null))
			{
			if (ac1102 == null)
			{
			//agv执行通知 wcs取消
			WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no.ToString());
			}
			}
			}
			else
			{
			var ac1103 = TaskHelper.GetWcsSafety(wmsTask.S_CODE, "1103");
			var ac1104 = TaskHelper.GetWcsSafety(wmsTask.S_CODE, "1104");

			if ((ac1103 != null))
			{
			if (ac1104 == null)
			{
			//agv执行通知 wcs取消
			WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no.ToString());
			}
			}
			}
			}


			WmsTaskAction ac6 = TaskHelper.GetActionRecord(wmsTask.S_CODE, "6");
			if (ac6==null)
			{
			ContainerHelper.delCntr(wmsTask.S_CNTR_CODE);
			ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE);
			//入库或者回库任务取消删除托盘物料
			if (wmsTask.S_TYPE.Contains("入库") \|\| wmsTask.S_TYPE.Contains("回库"))
			{
			ContainerHelper.delCntr(wmsTask.S_CNTR_CODE);
			ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE);
			ContainerHelper.delCntrLoc(wmsTask.S_CNTR_CODE);
			}
			}

			//出库取消判断接驳位是否有货，有货需要解绑
			if (!WcsTask.WcsCvstate(wmsTask))
			if (wmsTask.S_TYPE.Contains("出库"))
			{
			LogHelper.Info($"Wcs立库接驳位无货，解绑货位:{wmsTask.S_START_LOC}", "立库");
			TaskProcess.OperateStatus(wmsTask, 4);
			ContainerHelper.delCntr(wmsTask.S_CNTR_CODE);
			ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE);
			//出库取消判断接驳位是否有货，有货需要解绑
			var wmsWork = TaskHelper.GetWmsWork(wmsTask.S_OP_CODE);
			if (wmsWork != null)
			{
			if (!string.IsNullOrEmpty(wmsWork.CONNECTION))
			{
			var agvTask = LocationHelper.GetConnectionTask(wmsWork.CONNECTION, "agv",wmsTask.T_CREATE);
			LogHelper.Info($"取消任务{wmsTask.S_CODE}，当前接驳位{wmsWork.CONNECTION}，第一个agv任务信息" + JsonConvert.SerializeObject(agvTask), "agv动作缓存");
			if (agvTask != null)
			{
			WmsTaskAction qh = TaskHelper.GetActionRecord(agvTask.S_CODE, "4");
			//已经取货完成
			if (qh != null)
			{
			if (WcsTask.WcsCvstate(wmsTask))
			{
			LogHelper.Info($"Wcs立库接驳位有货，解绑货位:{wmsTask.S_END_LOC}", "是否有货");
			ContainerHelper.delCntr(wmsTask.S_CNTR_CODE);
			ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE);
			}
			}
			}
			}
			}
			}
			break;

			}
			TaskHelper.AddActionRecord(wmsTask.S_CODE, model.state, model.forklift_no, model.ext_data);
			}
			@@ -320,7 +412,7 @@


			//寻找立库区空托
			start = LocationHelper.FindStartcolByLoclistAndcntr(strrtList, workFlow.STARTAREA);
			start = LocationHelper.FindStartcolByLoclistAndcntr(strrtList, workFlow.STARTAREA,workFlow.CONNECTION);


			LogHelper.Info($"空托{kt.task_no}出库任务下发起点信息" + JsonConvert.SerializeObject(start), "空托出库");
			@@ -342,23 +434,20 @@
			var cntrCode = LocationHelper.GetLocCntrCode(start.S_CODE);

			if (workFlow.SENDWCS == "Y")
			{

			//正式代码，调用接口寻找可用接驳位
			{
			var connectionList = LocationHelper.GetConnectionList(workFlow.CONNECTION);

			//根据接驳位任务数量获取均衡接驳位集合优先任务数少的接驳位
			var balanceConnectionList = LocationHelper.GetBalanceConnectionList(connectionList);
			foreach (var item in balanceConnectionList)
			{
			if (item.loc.N_CURRENT_NUM < 2)
			if (item.loc.CONNEC_ROADWAY == start.N_ROADWAY)
			{
			connection = item.loc.S_CODE;
			connectionArea = item.loc.S_AREA_Name;
			LogHelper.Info($"空托{kt.task_no}出库任务下发寻找到可用接驳位{connection}", "空托出库");
			LogHelper.Info($"ZCSendTask出库任务下发寻找到可用接驳位{connection}", "Mes任务下发");
			break;
			}
			}

			if (connection == "")
			{
			LogHelper.Info($"空托{kt.task_no}出库任务下发寻找接驳位失败", "Mes任空托出库务下发");
			@@ -374,9 +463,6 @@
			continue;
			}



			LocationHelper.LockLoc(start.S_CODE, "出库锁", 2);



			@@ -418,10 +504,16 @@
			CONNECTION_AREA = connectionArea
			};


			//创建作业
			if (WMSHelper.CreateWmsWork(operation) && TaskHelper.ChangeMesKtTask(kt))
			{

			if (connection != "")
			{
			LocationHelper.LockLoc(operation.S_START_LOC, "出库锁", 2);
			LocationHelper.LockLoc(operation.S_END_LOC, "入库锁", 1);
			LocationHelper.LockLoc(operation.CONNECTION, "入库锁", 1);
			}
			LogHelper.Info($"空托{kt.task_no}出库作业创建成功{operation.S_CODE}", "空托出库");
			}
			else