WCSNet6.git - Gitblit

			@@ -1,4 +1,8 @@
			using Elastic.Clients.Elasticsearch;
			using DocumentFormat.OpenXml.Presentation;
			using Elastic.Clients.Elasticsearch;
			using Furion.Logging;
			using Newtonsoft.Json;
			using System;
			using System.Diagnostics.CodeAnalysis;
			using System.Linq;
			using System.Text;
			@@ -81,7 +85,7 @@
			result.Msg = "任务:" + models.TaskNo + ";已存在!";
			return result;
			}
			if (models.TaskType == "0")
			if (models.TaskType == "0" && models.TaskType == "0")
			{
			models.Order = 1;
			}
			@@ -89,11 +93,30 @@
			{
			models.Order = 2;
			}
			Enum type;
			var bale = "0";
			if (models.TaskType == "0" )
			{
			type = TaskTypeEnum.In;
			}
			else if (models.TaskType == "1")
			{
			type = TaskTypeEnum.Out;
			}
			else if (models.TaskType == "3")
			{
			type = TaskTypeEnum.In;
			bale = "1";//裹包
			}
			else
			{
			type = TaskTypeEnum.Move;
			}
			//新增任务
			var taskAdd = new WcsTask()
			{
			TaskNo = models.TaskNo,
			TaskType = TaskTypeEnum.Out,
			TaskType = (TaskTypeEnum?)type,
			Status = TaskStatusEnum.Wait,
			//IsSuccess =TaskSuccessEnum.Success,
			Levels = 999,
			@@ -103,6 +126,8 @@
			EndLocate = models.EndLocate,
			EndRoadway= models.EndRoadway,
			PalletNo = models.PalletNo,
			IsBale = bale,


			//LotNo =models.LotNo,
			//SkuNo=models.SkuNo,
			@@ -120,7 +145,7 @@
			}

			/// <summary>
			/// WCS接收WMS下发的入库单任务
			/// WCS接收WMS下发的出入库单任务
			/// </summary>
			/// <param name="models"></param>
			/// <returns></returns>
			@@ -159,4 +184,160 @@
			}
			}


			/// <summary>
			/// WCS接受赋码系统推送的箱码信息
			/// </summary>
			/// <param name="models">箱码信息</param>
			/// <returns>反馈信息</returns>
			[HttpPost]
			[AllowAnonymous]
			public ResponseFuMaModel AddHttpBoxInfo(FumaBoxInfoInput models)
			{

			try
			{
			string str = JsonConvert.SerializeObject(models);
			Log.Information("接收赋码推送的箱码信息："+str);
			if (models.Origin != "赋码")
			{
			throw new Exception("来源未识别");
			}
			var num = _db.Queryable<WcsBoxInfo>().Where(m=>m.BoxNo == models.BoxNo && m.IsDelete == false).ToList();
			var type = "add";
			if (num.Count>0)
			{
			//WCS存在箱码信息，更新箱码信息(需判断箱码是否已组盘入库)
			var num2 = num.Count(m => m.Status != "0" \|\| !string.IsNullOrWhiteSpace(m.PalletNo));
			if (num2 > 0)
			{
			throw new Exception("该箱已入盘入库，不可更新信息");
			}
			type = "edit";
			}

			if (models.DelistList.Count == 0)
			{
			throw new Exception("盒码集合不能为空");
			}

			var listBox = new List<WcsBoxInfo>();
			foreach (var item in models.DelistList)
			{
			var level = "3";
			if (string.IsNullOrWhiteSpace(item.BoxNo2))
			{
			level = "2";
			}
			if (item.DelistList2.Count == 0)
			{
			throw new Exception("支码集合不能为空");
			}
			//二级码
			foreach (var item2 in item.DelistList2)
			{
			if (string.IsNullOrWhiteSpace(models.ProductionTime) \|\| string.IsNullOrWhiteSpace(models.ExpirationTime))
			{
			throw new Exception("生产日期或失效日期不能为空");
			}
			DateTime proTime;
			DateTime expTime;
			var isValid = DateTime.TryParse(models.ProductionTime, out proTime);
			var isValid2 = DateTime.TryParse(models.ExpirationTime, out expTime);
			if (!isValid \|\| !isValid2)
			{
			throw new Exception("生产日期或失效日期格式错误");
			};
			DateTime? stortime = null;
			if (!string.IsNullOrWhiteSpace(models.StoreTime))
			{
			stortime = DateTime.Parse(models.StoreTime);
			}

			var boxAdd = new WcsBoxInfo()
			{
			BoxNo = models.BoxNo,
			//OrderNo = models.OrderNo,
			SkuNo = models.SkuNo,
			SkuName = models.SkuName,
			Standard = models.Standard,
			LotNo = models.LotNo,
			Qty = item2.Qty,
			FullQty = models.FullQty,
			//SupplierLot = models.SupplierLot,
			InsPectMark = models.InsPectMark,
			BitBoxMark = models.BitBoxMark,
			//InspectStatus = models.InspectStatus，
			ProductionTime = proTime,
			ExpirationTime = expTime,
			StoreTime = stortime,
			EndLotFlag = string.IsNullOrWhiteSpace(models.EndBatchMark) ? "0" : models.EndBatchMark,

			BoxNo2 = item.BoxNo2,
			BoxNo3 = item2.BoxNo3,
			QtyCount = item2.QtyCount,
			QtyOrd = item2.QtyOrd,

			Status = "0",
			Level = level,

			IsDelete = false
			};
			listBox.Add(boxAdd);
			}

			}
			_db.Insertable(listBox).ExecuteCommand();
			if (type == "edit")
			{
			//gen
			_db.Deleteable(num).ExecuteCommand();
			return new ResponseFuMaModel() { Success = "0", Message = "更新成功" };
			}
			return new ResponseFuMaModel() { Success = "0", Message = "插入成功" };
			}
			catch (Exception ex)
			{
			return new ResponseFuMaModel() { Success = "-1", Message = ex.Message };
			}
			}

			/// <summary>
			/// WCS接受赋码系统推送的箱码移除
			/// </summary>
			/// <param name="models">箱码信息</param>
			/// <returns>反馈信息</returns>
			[HttpPost]
			[AllowAnonymous]
			public ResponseFuMaModel DelgatesHttpBoxInfo(FumaBoxInfoInput models)
			{

			try
			{
			string str = JsonConvert.SerializeObject(models);
			Log.Information("接收赋码推送的箱码移除：" + str);
			var num = _db.Queryable<WcsBoxInfo>().Where(m => m.BoxNo == models.BoxNo && m.IsDelete == false).ToList();
			if (num.Count > 0)
			{
			//WCS存在箱码信息，更新箱码信息(需判断箱码是否已组盘入库)
			var num2 = num.Count(m => m.Status != "0" \|\| !string.IsNullOrWhiteSpace(m.PalletNo));
			if (num2 > 0)
			{
			throw new Exception("该箱已盘入库，不可更新信息");
			}
			}
			if (num.Count == 0)
			{
			throw new Exception("未找到该箱码，箱码移除失败！");
			}

			_db.Deleteable(num).ExecuteCommand();
			return new ResponseFuMaModel() { Success = "0", Message = "移除箱码成功" };
			}
			catch (Exception ex)
			{
			return new ResponseFuMaModel() { Success = "-1", Message = ex.Message };
			}
			}

			}