JC34WMS.git - Gitblit

			@@ -1,8 +1,14 @@
			using SqlSugar;
			using Model.InterFaceModel;
			using SqlSugar;
			using System;
			using System.Collections.Generic;
			using System.Linq;
			using System.Text;
			using WMS.BLL.Logic;
			using WMS.BLL.LogServer;
			using WMS.DAL;
			using WMS.Entity.BllAsnEntity;
			using WMS.Entity.BllSoEntity;
			using WMS.Entity.Context;
			using WMS.Entity.DataEntity;
			using WMS.Entity.LogEntity;
			@@ -16,6 +22,338 @@
			private static readonly SqlSugarScope Db = DataContext.Db;
			public HttpServer() { }

			/// <summary>
			/// 申请储位（立体库）
			/// </summary>
			/// <param name="palletNo"></param>
			/// <param name="houseNo"></param>
			/// <param name="roadwayNo"></param>
			/// <returns></returns>
			/// <exception cref="Exception"></exception>
			public OutCommandDto RequestLocation(string palletNo, string houseNo)
			{
			try
			{
			//验证托盘条码是否为空
			if (string.IsNullOrEmpty(palletNo))
			{
			throw new Exception("请输入要申请的托盘条码");
			}
			//验证所属仓库是否为空
			if (string.IsNullOrEmpty(houseNo))
			{
			throw new Exception("请选择所属仓库");
			}
			//验证是否为平库入库
			var houseType = Db.Queryable<SysWareHouse>().First(a => a.WareHouseNo == houseNo);//获取仓库类型
			//验证是否为立体库入库
			if (houseType.Type != "1")
			{
			throw new Exception("仓库类型错误，请选择立体库仓库");
			}

			OutCommandDto comDto;//返回wcs的入库命令

			var stock = Db.Queryable<SysPallets>().First(a => a.PalletNo == palletNo);//托盘信息

			//判断托盘条码是否有效
			if (stock == null)
			throw new Exception("托盘条码不受WMS管理，不可入库！");

			#region
			var upShelfOld = Db.Queryable<BllPalletUpShelf>().First(m => m.IsDel == "0" && m.PalletNo == palletNo && (m.Status == "0" \|\| m.Status == "1"));

			var skuList = Db.Queryable<SysMaterials>().Where(m => m.IsDel == "0").ToList();
			//物料类别信息
			var skuCategoryList = Db.Queryable<SysMaterialCategory>().Where(m => m.IsDel == "0").ToList();

			var skuNo = ""; //入库物料
			var starLocate = ""; // 起始储位
			var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.PalletNo == palletNo).ToList();
			//验证物料是否有成品
			foreach (var item in stockDetail)
			{
			var skuItem = skuList.First(m => m.SkuNo == item.SkuNo);
			if (skuItem.Type == "2")
			{
			throw new Exception("成品物料请入成品库");
			}
			}
			if (upShelfOld != null) //查询到入库信息
			{
			var beingTask = Db.Queryable<LogTask>().First(m => m.IsDel == "0" && m.TaskNo == upShelfOld.TaskNo);
			if (beingTask == null)
			{
			throw new Exception("该托盘正在入库，但未查询到任务信息");
			}
			if (!string.IsNullOrWhiteSpace(beingTask.EndLocat))
			{
			comDto = new OutCommandDto()
			{
			PalletNo = palletNo,//托盘号
			StartRoadway = beingTask.StartRoadway, // 起始巷道
			StartLocate = beingTask.StartLocat, // 起始位置
			EndLocate = beingTask.EndLocat, // 目标位置
			EndRoadway = beingTask.EndRoadway, // 目标巷道
			TaskNo = beingTask.TaskNo, // 任务号
			TaskType = "0",// 任务类型 (出库)
			OutMode = "", //目标地址
			Order = 1
			};
			if (beingTask.IsSuccess == 0)
			{
			beingTask.IsSuccess = 1;
			}
			beingTask.Status = "1";
			Db.Updateable(beingTask).ExecuteCommand();
			if (upShelfOld.Status == "0")
			{
			upShelfOld.Status = "1";
			Db.Updateable(upShelfOld).ExecuteCommand();
			}
			return comDto;
			}
			else
			{
			throw new Exception("查询到任务但目的储位为空");
			}
			}
			else //申请入库
			{
			if (stockDetail.Count == 0)
			{
			throw new Exception($"{palletNo}托盘条码不具有箱码信息，不可入库！");
			}
			if (stockDetail.Count(m => !string.IsNullOrWhiteSpace(m.LocatNo)) == 0)
			{
			throw new Exception("当前托盘没有在平库储位上，请核实");
			}
			starLocate = stockDetail.First().LocatNo;

			var pingAreaStr = Db.Queryable<SysStorageArea>().Where(m => m.IsDel == "0" && m.WareHouseNo == "W04" && m.AreaNo != "B06" && m.AreaNo != "B07").Select(m => m.AreaNo).ToList();
			var pingLocateInfo = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == starLocate && pingAreaStr.Contains(m.AreaNo) && m.IsDel == "0");
			if (pingLocateInfo == null)
			{
			throw new Exception("当前托盘所在的储位没有在系统中找到信息");
			}
			if (pingLocateInfo.Status != "1")
			{
			throw new Exception("当前托盘所在的储位状态错误，不是空储位");
			}
			skuNo = stockDetail.First().SkuNo;

			var beingTask = Db.Queryable<LogTask>().First(m => m.IsDel == "0"
			&& (m.Status == "0" \|\| m.Status == "1") && m.PalletNo == palletNo && m.Type == "0");
			if (beingTask != null)
			{
			if (!string.IsNullOrWhiteSpace(beingTask.EndLocat))
			{
			comDto = new OutCommandDto()
			{
			PalletNo = palletNo,//托盘号
			StartRoadway = beingTask.StartRoadway, // 起始巷道
			StartLocate = beingTask.StartLocat, // 起始位置
			EndLocate = beingTask.EndLocat, // 目标位置
			EndRoadway = beingTask.EndRoadway, // 目标巷道
			TaskNo = beingTask.TaskNo, // 任务号
			TaskType = "0",// 任务类型 (出库)
			OutMode = "", //目标地址
			Order = 1,
			Type = PLCTypeEnum.AGV
			};
			if (beingTask.IsSuccess == 0)
			{
			beingTask.IsSuccess = 1;

			}
			beingTask.Status = "1";
			Db.Updateable(beingTask).ExecuteCommand();
			return comDto;
			}
			else
			{
			throw new Exception("查询到任务但目的储位为空");
			}
			}

			//获取对应回库规则
			var function = Db.Queryable<SysFunSetting>().First(a => a.IsDel == "0" && a.FunSetName == "托盘回库验证" && a.IsEnable == "NO");
			#region 托盘回库规则

			if (function != null)
			{
			//拣货完成后允许托盘回库
			if (function.SetValue == "CompletePick")
			{
			var allot = Db.Queryable<BllExportAllot>().First(a => a.IsDel == "0" && a.LotNo == stockDetail[0].LotNo && a.PalletNo == palletNo && a.SkuNo == stockDetail[0].SkuNo);

			//验证拣货明细是否存在
			if (allot != null)
			{
			//验证当前托盘拣货信息是否已完成
			if (allot.Status != "5")
			{
			throw new Exception("当前托盘拣货信息未完成，请完成后回库！");
			}
			}
			}
			}
			#endregion
			}

			var allotLocate = new AllotLocation();

			#region 申请储位

			SysStorageLocat locate;
			var sku = skuList.FirstOrDefault(m => m.SkuNo == skuNo);
			if (sku == null)
			{
			throw new Exception("物料信息中未查询到入库单明细包含的物料信息，不可入库");
			}
			//判断物料是否含有类别信息
			if (string.IsNullOrWhiteSpace(sku.CategoryNo))
			{
			throw new Exception($"物料：{sku.SkuNo}未查询到类别信息");
			}

			var skuCategory = skuCategoryList.FirstOrDefault(m => m.CategoryNo == sku.CategoryNo);
			if (skuCategory == null)
			{
			throw new Exception($"未在类别信息中查询到物料：{sku.SkuNo}包含的类别");
			}

			var areaStr = skuCategory.AreaNo.Split(",");
			var areaList = new List<string>();
			foreach (var item in areaStr)
			{
			areaList.Add(item);
			}

			locate = allotLocate.GetSuiTableLocate(houseNo, areaList, "");


			#endregion

			Db.BeginTran();
			try
			{


			//添加巷道使用记录
			var log = new SysRoadwayUseLog
			{
			RoadwayNo = locate.RoadwayNo,
			WareHouseNo = houseNo,
			Row = 0,
			Column = 0,
			Layer = 0,
			};
			Db.Insertable(log).ExecuteCommand();
			var taskNo = new Common().GetMaxNo("TK");
			var exTask = new LogTask //入库任务
			{
			TaskNo = taskNo,
			Sender = "WMS",
			Receiver = "WCS",
			IsSuccess = 1, //是否下发成功 0失败 1成功
			SendDate = DateTime.Now, //发送时间
			BackDate = DateTime.Now, //返回时间
			StartRoadway = "", // 起始巷道
			StartLocat = starLocate,//起始位置
			EndLocat = locate.LocatNo,//目标位置
			EndRoadway = locate.RoadwayNo, // 目标巷道
			PalletNo = palletNo,//托盘码
			IsSend = 1,//是否可再次下发
			IsCancel = 1,//是否可取消
			IsFinish = 1,//是否可完成
			Type = "0",//任务类型 0 入库任务 1 出库任务 2 移库任务
			Status = "1",//任务状态0：等待执行1正在执行2执行完成
			OrderType = "0",//0 入库单 1 出库单 2 盘点单 3 移库单
			Msg = "入库口到=>>" + locate.LocatNo + "的入库任务", //关键信息

			};
			Db.Insertable(exTask).ExecuteCommand();
			var asnNo = "";
			// 添加托盘绑定表托盘入库任务号 liudl
			foreach (DataStockDetail stockModel in stockDetail)
			{
			var bindModel = Db.Queryable<BllPalletBind>().First(m => m.IsDel == "0" && m.Status == "2"
			&& m.PalletNo == stockModel.PalletNo && m.ASNNo == stockModel.ASNNo && m.ASNDetailNo == stockModel.ASNDetailNo);
			if (bindModel != null && string.IsNullOrWhiteSpace(bindModel.TaskNo))
			{
			bindModel.TaskNo = taskNo;
			bindModel.WareHouseNo = locate.WareHouseNo;
			bindModel.RoadwayNo = locate.RoadwayNo;
			bindModel.LocatNo = locate.LocatNo;
			Db.Updateable(bindModel).ExecuteCommand();
			asnNo = stockModel.ASNNo;
			}
			}
			foreach (DataStockDetail stockModel in stockDetail)
			{
			//添加托盘上架记录
			var upShelf = new BllPalletUpShelf()
			{
			TaskNo = exTask.TaskNo,
			TraceNo = asnNo,
			PalletNo = palletNo,
			SkuNo = stockModel.SkuNo,
			SkuName = stockModel.SkuName,
			LotNo = stockModel.LotNo,
			Status = "1",

			WareHouseNo = houseNo,
			RoadwayNo = locate.RoadwayNo,
			AreaNo = locate.AreaNo,
			LocatNo = locate.LocatNo,

			CreateUser = 0,
			};
			Db.Insertable(upShelf).ExecuteCommand();
			}


			locate.Status = "2";
			Db.Updateable(locate).ExecuteCommand();

			Db.CommitTran();
			comDto = new OutCommandDto()
			{
			PalletNo = palletNo,//托盘号
			StartRoadway = "",
			StartLocate = starLocate, // 起始位置
			EndLocate = locate.LocatNo, // 目标位置
			EndRoadway = locate.RoadwayNo, // 目标巷道
			TaskNo = taskNo, // 任务号
			TaskType = "0",// 任务类型 (出库)
			OutMode = "", //目标地址
			Order = 1,
			Type = PLCTypeEnum.AGV
			};

			}
			catch (Exception ex)
			{
			Db.RollbackTran();
			throw new Exception(ex.Message);
			}
			#endregion


			return comDto;
			}
			catch (Exception e)
			{
			throw new Exception(e.Message);
			}
			}

			/// <summary>
			/// agv走出储位修改储位信息，仅限平库储位
			/// </summary>
			/// <param name="taskNo"></param>
			/// <param name="userId"></param>
			public void UpLocateByAgvOut(string taskNo, int userId)
			{
			try
			@@ -55,5 +393,89 @@
			throw new Exception(e.Message);
			}
			}

			/// <summary>
			/// 入库任务完成JC34
			/// </summary>
			/// <param name="taskNo"></param>
			/// <param name="userId"></param>
			/// <exception cref="Exception"></exception>
			public void ArrivalSuccess2(string taskNo, int userId)
			{
			try
			{
			//正常入库
			var task = Db.Queryable<LogTask>().First(m => m.IsDel == "0" && m.TaskNo == taskNo);
			if (task == null)
			{
			throw new Exception("未查询到任务信息");
			}
			if (task.Status == "2")
			{
			throw new Exception("当前任务已完成");
			}

			var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.PalletNo == task.PalletNo).ToList();
			var upShelf = Db.Queryable<BllPalletUpShelf>().First(m => m.TaskNo == taskNo);
			if (upShelf == null)
			{
			throw new Exception("没有找到托盘上架信息");
			}
			//当前任务中的储位信息
			var locate = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == task.EndLocat);
			if (locate == null)
			{
			throw new Exception($"未查询到任务中的储位信息");
			}
			Db.BeginTran();

			task.Status = "2";//任务状态
			task.IsSend = 0;
			task.IsCancel = 0;
			task.IsFinish = 0;
			task.FinishDate = DateTime.Now;//完成时间
			Db.Updateable(task).ExecuteCommand();
			if (userId != 0)
			{
			//添加操作日志记录
			var k = new OperationASNServer().AddLogOperationAsn("入库作业", "入库日志", taskNo, "完成", $"点击完成按钮、完成任务号为：{taskNo}的任务", userId);
			}

			//判断是否是回流入库完成
			if (stockDetail.Any())
			{
			throw new Exception("没有查询到库存信息");
			}

			foreach (var item in stockDetail)
			{
			item.WareHouseNo = locate.WareHouseNo;
			item.RoadwayNo = locate.RoadwayNo;
			item.AreaNo = locate.AreaNo;
			item.LocatNo = locate.LocatNo;
			item.UpdateTime = DateTime.Now;
			if (userId != 0)
			{
			item.UpdateUser = userId;
			}
			}
			upShelf.Status = "2";
			Db.Updateable(upShelf).ExecuteCommand();

			locate.Status = "1";
			Db.Updateable(locate).ExecuteCommand();
			Db.Updateable(stockDetail).ExecuteCommand();
			Db.CommitTran();

			}
			catch (Exception e)
			{
			throw new Exception(e.Message);
			}
			}




			}
			}