WMSPrjInstance/HH-0129_ZhongCeJinTan.git

			@@ -4,9 +4,11 @@
			using HH.WCS.ZhongCeJinTan.util;
			using HH.WCS.ZhongCeJinTan.wms;
			using Newtonsoft.Json;
			using SqlSugar;
			using System;
			using System.Collections.Generic;
			using System.Linq;
			using System.Reflection;
			using System.Text;
			using System.Threading;
			using System.Threading.Tasks;
			@@ -51,14 +53,22 @@
			var tasks = db.Queryable<WMSTask>().Where(p => p.S_OP_CODE == operation.S_CODE).ToList();



			if (tasks.Count > 1 && tasks.Count(p => p.N_B_STATE == 3) == 1)
			{
			operation.S_B_STATE = "完成一半";
			operation.T_MODIFY = DateTime.Now;
			db.Updateable(operation).UpdateColumns(it => new { it.S_B_STATE, it.T_MODIFY }).ExecuteCommand();
			}

			if (tasks.Count == tasks.Count(p => p.N_B_STATE == 3))
			{
			operation.N_B_STATE = 2;
			operation.S_B_STATE = "完成";
			operation.T_MODIFY = DateTime.Now;
			operation.T_END_TIME = DateTime.Now;
			db.Updateable(operation).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE,it.T_MODIFY,it.T_END_TIME }).ExecuteCommand();

			db.Updateable(operation).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE, it.T_MODIFY, it.T_END_TIME }).ExecuteCommand();

			}
			else if (tasks.Count(p => p.N_B_STATE == 5) > 0)
			{
			@@ -72,8 +82,191 @@
			}
			}

			//出库任务动作码有1无3 每隔一段时间提高一次优先级

			public static void UpdateOutTaskPriority()
			{
			//var ts1 = DateTime.Now.Subtract(datetime).TotalMinutes;


			}

			/// <summary>
			/// 自动出库空托
			/// </summary>
			public static void ktAuto() {
			var db = new SqlHelper<object>().GetInstance();

			try
			{
			var ktTaskList = db.Queryable<MesKtTask>().Where(a => a.Status == "N" ).ToList();
			foreach (var kt in ktTaskList)
			{
			if (DateTime.Now.Subtract(kt.CreateDate).TotalMinutes < 1)
			{
			continue;
			}

			var workFlow = TaskHelper.selectWorkFlowByType(kt.BUSI_TYPE, kt.TOOLS_TPYE);


			if (workFlow == null)
			{
			LogHelper.Info($"空托出库任务下发失败，流程编号:{kt.BUSI_TYPE},工装类型{kt.TOOLS_TPYE},没找到对应作业流程", "空托出库");
			throw new Exception($"BUSI_TYpe:{kt.BUSI_TYPE},没找到对应作业流程");
			}
			else
			{
			LogHelper.Info($"空托出库作业流程信息" + JsonConvert.SerializeObject(workFlow), "空托出库");
			}



			//出库任务

			//接驳位
			var connection = "";

			//接驳位库区
			var connectionArea = "";


			//查找给定终点
			var end = LocationHelper.GetLoc(kt.Location_To);
			LogHelper.Info($"空托出库任务下发终点信息" + JsonConvert.SerializeObject(end), "空托出库");


			if (end == null)
			{
			LogHelper.Info($"空托出库任务下发失败，终点:{kt.Location_To},没找到", "空托出库");
			throw new Exception($"终点:{kt.Location_To},没找到");
			}





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

			Location start = null;


			if (!string.IsNullOrEmpty(workFlow.ZONECODE))
			{
			strrtList = LocationHelper.GetZoneLoc(workFlow.ZONECODE);
			}
			else
			{
			strrtList = LocationHelper.GetAllLocList2(workFlow.STARTAREA);
			}




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


			LogHelper.Info($"空托出库任务下发起点信息" + JsonConvert.SerializeObject(start), "空托出库");

			if (start == null)
			{
			LogHelper.Info($"空托出库任务下发失败，起点库区{workFlow.STARTAREA},没找到起点", "空托出库");
			throw new Exception($"起点库区{workFlow.STARTAREA},没找到起点");
			}




			//获取托盘码
			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)
			{
			connection = item.loc.S_CODE;
			connectionArea = item.loc.S_AREA_Name;
			LogHelper.Info($"空托出库任务下发寻找到可用接驳位{connection}", "空托出库");
			break;
			}
			}

			if (connection == "")
			{
			LogHelper.Info($"空托出库任务下发寻找接驳位失败", "Mes任空托出库务下发");
			throw new Exception($"空托出库任务下发寻找接驳位失败");
			}
			}


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

			var taskType = int.Parse(workFlow.FLOWCODE);

			var operation = new WmsWork
			{
			// 作业号
			S_CODE = kt.task_no,
			// 作业类型
			N_TYPE = taskType,
			// 作业类型
			S_TYPE = workFlow.FLOWNAME,
			// 起点货位
			S_START_LOC = start.S_CODE,
			// 起点库区编码
			S_START_AREA = start.S_AREA_CODE,
			//接驳位
			CONNECTION = connection,
			// 终点货位
			S_END_LOC = end.S_CODE,
			// 终点库区编码
			S_END_AREA = end.S_AREA_CODE,
			// 容器编码
			S_CNTR_CODE = cntrCode,
			// 作业定义名称
			S_OP_DEF_NAME = workFlow.FLOWNAME,
			//优先级
			N_PRIORITY = kt.Priority,
			//工装类型
			TOOLSTYPE = kt.TOOLS_TPYE,
			//起点库区名称
			S_START_AREA_NAME = start.S_AREA_Name,
			//起点库区名称
			S_END_AREA_NAME = end.S_AREA_Name,
			//起点库区名称
			CONNECTION_AREA = connectionArea
			};

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

			LogHelper.Info($"空托出库作业创建成功{operation.S_CODE}", "空托出库");
			}
			else
			{
			LogHelper.Info($"空托出库任务下发创建作业失败", "空托出库");
			throw new Exception($"空托出库任务下发创建作业失败");
			}

			}


			}
			catch (Exception ex)
			{

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