WMSPrjInstance/HH-0129_ZhongCeJinTan.git

			@@ -23,6 +23,8 @@
			/// </summary>
			internal class Monitor
			{
			private static object CreateTaskLocker = new object();

			/// <summary>
			/// 根据作业创建对应任务
			/// </summary>
			@@ -30,12 +32,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 +96,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);
			}
			}
			}
			}
			@@ -111,6 +130,139 @@
			int sp = st.Minute * 60000;
			Thread.Sleep(sp);
			}

			private static object locker1 = new object();


			/// <summary>
			/// agv动作缓存处理
			/// </summary>
			/// <param name="model"></param>
			public static void agvActionManage()
			{

			var db = new SqlHelper<object>().GetInstance();


			try
			{
			lock (locker1)
			{
			var operations = db.Queryable<AgvActionState>().OrderBy(a => a.T_CREATE).ToList().Take(50);
			foreach (var model in operations)
			{
			var wmsTask = TaskHelper.GetTask(model.task_no);
			LogHelper.Info("agvActionManage--任务信息" + JsonConvert.SerializeObject(wmsTask), "agv动作缓存");
			LogHelper.Info("agvActionManage--参数信息" + JsonConvert.SerializeObject(model), "agv动作缓存");
			if (wmsTask != null)
			{
			if (model.state <= 7)
			{
			//有任务号请求
			switch (model.state)
			{
			case 1:
			TaskHelper.opMesTask(wmsTask, 1);
			TaskHelper.Begin(wmsTask, model.forklift_no);
			//胎面交互
			TaskHelper.TmSafety(wmsTask);
			break;
			case 3:
			TaskHelper.UpdateStatus(wmsTask, "开始取货");
			break;
			case 4:
			TaskHelper.UpdateStatus(wmsTask, "取货完成");
			LocationHelper.UnLockLoc(wmsTask.S_START_LOC);
			TaskProcess.OperateStatus(wmsTask, 4);
			break;
			case 5:
			TaskHelper.UpdateStatus(wmsTask, "开始卸货");
			break;
			case 6:
			TaskHelper.UpdateStatus(wmsTask, "卸货完成");
			LocationHelper.UnLockLoc(wmsTask.S_END_LOC);
			TaskProcess.OperateStatus(wmsTask, 6);

			//如果是二段任务则下发立库任务
			var wcsTask = TaskHelper.GetTaskByState("未执行", "wcs", wmsTask.S_OP_CODE, "入库");
			if (wcsTask != null)
			{
			LocationHelper.LockLoc(wcsTask.S_START_LOC, "出库锁", 2);
			WcsTask.WcsTaskEntity(wcsTask);
			}
			break;
			case 2:
			//空托出或者满托出任务完成判断是否要提高入库优先级

			LogHelper.Info($"任务{wmsTask.S_CODE}完成，判断入库优先级", "入库优先级");
			TaskProcess.inPri(wmsTask);
			TaskHelper.End(wmsTask);

			break;
			case 7:
			if (!LocationHelper.GetErroArea(wmsTask.S_END_AREA)) {
			TaskHelper.opMesTask(wmsTask, 3);
			}

			var wcsTask1 = TaskHelper.GetTaskByWorkNo(wmsTask.S_OP_CODE, "wcs");
			if (wcsTask1 != null)
			{
			//agv执行通知 wcs取消
			WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no.ToString());
			TaskHelper.Fail(wcsTask1);
			TaskProcess.OperateStatus(wcsTask1, 7);
			}


			TaskHelper.Fail(wmsTask);
			TaskProcess.OperateStatus(wmsTask, 7);
			//入库或者回库任务取消删除托盘物料
			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);
			}
			else {
			//出库取消判断接驳位是否有货，有货需要解绑
			if (!WcsTask.WcsCvstate(wmsTask))
			{
			LogHelper.Info($"Wcs立库接驳位无货，解绑货位:{wmsTask.S_START_LOC}", "立库");
			TaskProcess.OperateStatus(wmsTask, 4);
			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);
			}
			else
			{
			//安全请求等
			TaskProcess.OperateReq(model.task_no, model.state, model.forklift_no, model.ext_data);
			}
			db.Deleteable(model).ExecuteCommand();
			}
			}
			}
			}
			catch (Exception ex)
			{
			LogHelper.Info("agvActionManage--异常信息" + ex.Message, "agv动作缓存");
			throw;
			}

			}








			@@ -176,8 +328,8 @@



			//查找起点
			List<Location> strrtList;
			//查找起点
			List<Location> strrtList;

			Location start = null;

			@@ -217,15 +369,14 @@
			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.N_CURRENT_NUM < 2 && item.loc.CONNEC_ROADWAY == start.N_ROADWAY)
			{
			connection = item.loc.S_CODE;
			connectionArea = item.loc.S_AREA_Name;
			@@ -248,6 +399,12 @@
			LogHelper.Info($"空托{kt.task_no}出库任务下发失败，起点{start.S_CODE}有执行中任务{startTask.S_CODE}", "空托出库");
			continue;
			}



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



			//起点终点查找成功，创建作业

			@@ -304,7 +461,6 @@
			}
			catch (Exception ex)
			{

			LogHelper.Info($"空托出库异常信息" + ex.Message, "空托出库");
			}
			}