JC23WMS-2.git - Gitblit

			@@ -27,8 +27,8 @@
			{
			public class RcsServer:IRcsServer
			{
			private readonly object GetPalleLock = new object();
			private readonly object ApplyLocatLock = new object();
			private static readonly object GetPalleLock = new object();
			private static readonly object ApplyLocatLock = new object();

			private static readonly SqlSugarScope Db = DataContext.Db;
			/// <summary>
			@@ -38,7 +38,7 @@
			/// <param name="url"></param>
			/// <param name="taskNo"></param>
			/// <exception cref="Exception"></exception>
			public void GetPalletNo(Pallnetmsg model, string url, out string taskNo)
			public void GetPalletNo(Pallnetmsg model, string url,string urlMes, out string taskNo)
			{
			lock (GetPalleLock)
			{
			@@ -60,7 +60,6 @@
			//叫桶设备所在储位信息（目标储位）
			var endLoction = new SysStorageLocat();

			var urlMes = "";//回传MES的接口地址
			var noticeNo = "0";//出入库单据明细ID

			//所有待分配的桶
			@@ -252,36 +251,28 @@
			foreach (var item in palletList)
			{
			#region 去掉MES
			//string jsonReq = JsonConvert.SerializeObject(item.PalletNo);
			//var response = HttpHelper.DoPost(urlMes, jsonReq, "回传MES脏桶编号", "RCS").ToString();
			//var obj = JsonConvert.DeserializeObject<ReMes>(response);//解析返回数据
			//if (obj.Success == "0")
			//{
			// if (obj.Result != "1")//不可清洗，将脏桶冻结
			// {
			// item.Status = "5";//异常冻结
			// //修改该桶库存状态
			// Db.Updateable(item).ExecuteCommand();
			var reObj = new
			{
			devive = item.PackagNo
			};
			string jsonReq = JsonConvert.SerializeObject(reObj);
			var response = HttpHelper.DoPost(urlMes, jsonReq, "回传MES脏桶编号判断是否可清洗", "MES").ToString();
			var obj = JsonConvert.DeserializeObject<ReMes>(response);//解析返回数据
			if (obj.state == "200")
			{
			if (obj.data != "1")//不可清洗，将脏桶冻结
			{
			item.Status = "5";//异常冻结
			//修改该桶库存状态
			Db.Updateable(item).ExecuteCommand();

			// continue;
			// }
			// //下发小车任务
			// var task2 = new TaskDetial
			// {
			// Startport = item.LocatNo,
			// Endport = model.Location,
			// Pallno = item.PalletNo,
			// Type = model.Type,
			// Crtype = "1",
			// Noticedetailno = int.Parse(noticeno),
			// };
			// CreateLotTask(task2);
			// return;
			//}
			//else
			//{
			// throw new Exception("回传MES净桶编号失败！");
			//}
			continue;
			}
			}
			else
			{
			throw new Exception("叫脏桶回传MES判断失败！");
			}
			#endregion

			item.Status = "2";//分配状态 0:待分配，1：部分分配， 2:已分配
			@@ -783,7 +774,7 @@
			Db.BeginTran();

			//查找是否有空余脏桶位
			var endLocat = Db.Queryable<SysStorageLocat>().First(w => w.WareHouseNo == detail.WareHouseNo && w.AreaNo.Contains("04") && w.Status == "0" && w.Flag=="0");
			var endLocat = Db.Queryable<SysStorageLocat>().First(w => w.WareHouseNo == detail.WareHouseNo && w.AreaNo.Contains("04") && w.Status == "0" && w.Flag == "0");
			if (endLocat == null)
			{
			detail.Status = "5";//异常锁定
			@@ -831,22 +822,97 @@
			{
			try
			{
			//桶信息
			var detail = Db.Queryable<DataStockDetail>().First(w => w.PalletNo == pallnetmsg.PalletNo && w.PalletStatus == "3");
			if (detail == null)
			{
			throw new Exception($"库存中不存在桶号为：{pallnetmsg.PalletNo}的库存!");
			}
			//下发小车任务
			//设备信息
			var deviceInfo = Db.Queryable<SysStorageArea>().First(w => w.IsDel == "0" && w.DeviceCode.Contains(pallnetmsg.Location));
			if (deviceInfo == null)
			{
			throw new Exception($"不存在设备号为：{pallnetmsg.Location}的设备!");
			}
			//目标储位信息
			var endLoction = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.WareHouseNo == deviceInfo.WareHouseNo && w.AreaNo == deviceInfo.AreaNo && w.Column == 1);// Column=1 清洗储位，Column=2 清洗完料储位
			if (endLoction == null)
			{
			throw new Exception("叫桶设备目标储位信息不存在");
			}

			detail.Status = "2";//分配状态 0:待分配，1：部分分配， 2:已分配
			//更新桶库存明细
			Db.Updateable(detail).ExecuteCommand();

			//起始储位地址信息
			var startLoction = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == detail.LocatNo);
			if (startLoction == null)
			{
			throw new Exception($"桶号：{detail.PalletNo}储位信息{detail.LocatNo}不存在");
			}

			var taskNo = new Common().GetMaxNo("TN");//任务号
			var logTaskEntry = new LogTask
			{
			TaskNo = taskNo,
			Sender = "WMS",
			Receiver = "RCS",
			//IsSuccess = 1, //是否下发成功 0失败 1成功
			SendDate = DateTime.Now, //发送时间
			//BackDate = DateTime.Now, //返回时间
			StartLocat = startLoction.LocatNo,//起始位置
			EndLocat = endLoction.LocatNo,//目标位置
			PalletNo = detail.PalletNo,//托盘码
			IsSend = 1,//是否可再次下发
			IsCancel = 1,//是否可取消
			IsFinish = 1,//是否可完成
			Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务
			OrderType = "3",//单据类型 0 入库 1 出库 3 移库
			Status = "0",//任务状态0：等待执行1正在执行2执行完成
			NoticeDetailNo = 0,
			Msg = $"MES下发清洗指定脏桶，桶号:{pallnetmsg.PalletNo},设备号：{pallnetmsg.Location}", //关键信息
			LotNo = ""//批次号
			};
			//组织下发小车任务信息
			var task = new TaskDetial
			{
			Startport = detail.LocatNo,
			Endport = pallnetmsg.Location,
			Pallno = detail.PalletNo,
			Crtype = "1",
			Taskno = taskNo,//任务号
			Startport = startLoction.LocatNo,//起始位置
			Endport = endLoction.LocatNo,//目标位置
			Pallno = detail.PalletNo,//桶号
			Crtype = "1",//叫桶
			WareHouseNo = detail.WareHouseNo//车间编码
			};
			string taskNo = "";
			string agvMsg = string.Empty;
			CreateTaskForAgv(task, url, out agvMsg);
			//给下车下发任务
			logTaskEntry.SendDate = DateTime.Now;//发送时间
			string agvMsg=string.Empty;
			var agvResult = CreateTaskForAgv(task, url, out agvMsg);
			if (agvResult)//成功
			{
			//请求成功修改任务表相应字段状态
			logTaskEntry.IsSuccess = 1;
			logTaskEntry.IsSend = 0;
			//logTaskEntry.IsCancel = 0;
			logTaskEntry.BackDate = DateTime.Now;
			logTaskEntry.Status = "1";//正在执行
			Db.Insertable(logTaskEntry).ExecuteCommand();

			startLoction.Status = "3";//出库中
			Db.Updateable(startLoction).ExecuteCommand();

			endLoction.Status = "2";//入库中
			Db.Updateable(endLoction).ExecuteCommand();
			}
			else//失败
			{
			logTaskEntry.IsSuccess = 0;
			logTaskEntry.Information = agvMsg;
			Db.Insertable(logTaskEntry).ExecuteCommand();

			}
			//提交事务
			Db.CommitTran();
			}
			catch (Exception ex)
			{
			@@ -1294,33 +1360,42 @@
			agvTask.taskTyp = "Z5";
			}

			// 正式运行程序放开
			var jsonData = JsonConvert.SerializeObject(agvTask);
			string response = HttpHelper.DoPost(url, jsonData, "下发给AGV转运命令", "AGV");
			//解析返回数据
			var agvModel = JsonConvert.DeserializeObject<OutCommanAgvDto>(response);
			if (agvModel.Code == "0")

			if (string.IsNullOrEmpty(url))//测试系统
			{
			result = true;//给下车下发任务成功

			result = true;
			agvMsg = "";
			}
			else
			else//正式系统
			{
			string logMsg = "";
			if (taskDetial.Crtype == "1")//叫桶（桶出库）
			var jsonData = JsonConvert.SerializeObject(agvTask);
			string response = HttpHelper.DoPost(url, jsonData, "下发给AGV转运命令", "AGV");
			//解析返回数据
			var agvModel = JsonConvert.DeserializeObject<OutCommanAgvDto>(response);
			if (agvModel.Code == "0")
			{
			logMsg = "申请叫桶";
			}
			else if (taskDetial.Crtype == "0")//申请储位（桶入库）
			{
			logMsg = "申请储位";
			}
			var logStr = $@".\log\AGV\AGV{logMsg}" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
			LogFile.SaveLogToFile($"AGV{logMsg}异常：( {agvModel.Message} ),", logStr);
			result = true;//给下车下发任务成功

			agvMsg = agvModel.Message;
			agvMsg = "";
			}
			else
			{
			string logMsg = "";
			if (taskDetial.Crtype == "1")//叫桶（桶出库）
			{
			logMsg = "申请叫桶";
			}
			else if (taskDetial.Crtype == "0")//申请储位（桶入库）
			{
			logMsg = "申请储位";
			}
			var logStr = $@".\log\AGV\AGV{logMsg}" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
			LogFile.SaveLogToFile($"AGV{logMsg}异常：( {agvModel.Message} ),", logStr);

			agvMsg = agvModel.Message;
			}
			}

			return result;
			#endregion
			}