ZhiHuiQiCe/FangCangZhiNeng.git

			@@ -1,5 +1,6 @@
			ï»¿using HslCommunication;
			using MailKit.Search;
			using Microsoft.AspNetCore.Mvc;
			using Newtonsoft.Json;
			using SqlSugar;
			using System;
			@@ -7,12 +8,19 @@
			using System.Linq;
			using System.Text;
			using System.Threading.Tasks;
			using WIDESEA_Common;
			using WIDESEA_Common.LocationEnum;
			using WIDESEA_Common.OrderEnum;
			using WIDESEA_Common.StockEnum;
			using WIDESEA_Common.TaskEnum;
			using WIDESEA_Core;
			using WIDESEA_Core.BaseRepository;
			using WIDESEA_Core.BaseServices;
			using WIDESEA_Core.Enums;
			using WIDESEA_Core.Helper;

			using WIDESEA_IBasicService;
			using WIDESEA_ISquareCabinServices;
			using WIDESEA_IWMsInfoServices;
			using WIDESEA_Model.Models;

			using static System.Net.WebRequestMethods;
			@@ -24,113 +32,216 @@
			{
			public class CabinOrderServices : ServiceBase<Dt_CabinOrder, IRepository<Dt_CabinOrder>>, ICabinOrderServices
			{

			static string SearchDate = "";
			private readonly IBasicService _basicService;
			private readonly IMedicineGoodsServices _medicineGoodsServices;
			private readonly IUnitOfWorkManage _unitOfWorkManage;
			private readonly IInventory_BatchServices _inventory_BatchServices;
			private readonly IInventoryInfoService _inventoryInfoService;
			private readonly ICabinOrderDetailServices _cabinOrderDetailServices;
			private readonly ISupplyTaskService _supplyTaskService;
			public IRepository<Dt_CabinOrder> Repository => BaseDal;

			public CabinOrderServices(IRepository<Dt_CabinOrder> BaseDal) : base(BaseDal)
			public CabinOrderServices(IRepository<Dt_CabinOrder> BaseDal, IBasicService basicService, IMedicineGoodsServices medicineGoodsServices, IUnitOfWorkManage unitOfWorkManage, IInventory_BatchServices inventory_BatchServices, IInventoryInfoService inventoryInfoService, ICabinOrderDetailServices cabinOrderDetailServices, ICabinOrderHtyServices cabinOrderHtyServices, ICabinOrderDetailHtyServices cabinOrderDetailHtyServices, ISupplyTaskService supplyTaskService) : base(BaseDal)
			{
			_basicService = basicService;
			_medicineGoodsServices = medicineGoodsServices;
			_unitOfWorkManage = unitOfWorkManage;
			_inventory_BatchServices = inventory_BatchServices;
			_inventoryInfoService = inventoryInfoService;
			_cabinOrderDetailServices = cabinOrderDetailServices;
			_supplyTaskService = supplyTaskService;
			}



			public WebResponseContent GetCabinOrders(SaveModel saveModel)
			{
			WebResponseContent content = new WebResponseContent();
			try
			{
			int pageNo = saveModel.MainData["pageNo"].ObjToInt();
			string warehouseCode = saveModel.MainData["warehouseId"].ToString();
			string orderNo = saveModel.MainData["orderNo"].ToString();
			List<Dt_CabinOrder> dt_ReceiveOrders = new List<Dt_CabinOrder>();
			if (string.IsNullOrEmpty(orderNo))
			{
			dt_ReceiveOrders = Db.Queryable<Dt_CabinOrder>().Where(x => (x.OdrderStatus == "æ°å»º" \|\| x.OdrderStatus == "å¼å§") && x.Warehouse_no == warehouseCode).Includes(x => x.Details).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 5);
			}
			else
			{
			dt_ReceiveOrders = Db.Queryable<Dt_CabinOrder>().Where(x => (x.Order_no.Contains(orderNo) \|\| x.Supplier_no.Contains(orderNo)) && (x.OdrderStatus == "æ°å»º" \|\| x.OdrderStatus == "å¼å§") && x.Warehouse_no == warehouseCode).OrderByDescending(x => x.CreateDate).Includes(x => x.Details).ToPageList(pageNo, 5);
			}

			content.OK(data: dt_ReceiveOrders);
			}
			catch (Exception)
			{

			throw;
			}
			return content;
			}
			public WebResponseContent GetCabinOrderDetail(int pageNo, string orderNo)
			{
			WebResponseContent content = new WebResponseContent();
			Dt_CabinOrder cabinOrder = Db.Queryable<Dt_CabinOrder>().Includes(x => x.Details).First(x => x.Order_no == orderNo);
			List<Dt_CabinOrderDetail> cabinOrderDetails = cabinOrder.Details.Where(x => x.Reservoirarea == pageNo.ToString()).ToList();
			content.OK(data: cabinOrderDetails);
			return content;
			}
			public WebResponseContent FeedbackIn([FromBody] SaveModel saveModel)
			{
			WebResponseContent content = new WebResponseContent();
			try
			{
			var LocationCode = saveModel.MainData["LocationCode"].ToString();
			var orderNo = saveModel.MainData["orderNo"].ToString();
			var batchNo = saveModel.MainData["batchNo"].ToString();
			var Inqty = saveModel.MainData["Inqty"].ObjToInt();
			var warehouseCode = saveModel.MainData["warehouseCode"].ToString();
			Dt_CabinOrder cabinOrder = BaseDal.Db.Queryable<Dt_CabinOrder>().Where(x => x.Order_no == orderNo && x.Warehouse_no == warehouseCode).Includes(x => x.Details).First();
			if (cabinOrder == null) return WebResponseContent.Instance.Error($"å¥åºåå·²å®æ");
			Dt_CabinOrderDetail cabinOrderDetail = cabinOrder.Details.Where(x => x.Batch_num == batchNo && x.Reservoirarea == warehouseCode).First();
			if (cabinOrderDetail == null) return WebResponseContent.Instance.Error($"å¥åºåæç»å·²å®æ");
			Dt_MaterielInfo materielInfo = _basicService.MaterielInfoService.Repository.QueryFirst(x => x.MaterielCode == cabinOrderDetail.Goods_no);
			if (materielInfo == null) return WebResponseContent.Instance.Error($"è¯·ç»´æ¤ç©æç¼å·ã{cabinOrderDetail.Goods_no}ãçç©æä¿¡æ¯");
			cabinOrderDetail.Order_Inqty += Inqty;
			if (cabinOrderDetail.Order_Inqty > cabinOrderDetail.Order_qty)
			return WebResponseContent.Instance.Error($"å¥åºæ°éä¸å¯è¶åºåæ®æ°é");

			#region å¤çå¥åºåï¼è´§ä½ï¼åºåï¼åºåæ¹æ¬¡ä¿¡æ¯
			_unitOfWorkManage.BeginTran();

			#region å¥åºå
			cabinOrder.OdrderStatus = "å¼å§";
			cabinOrderDetail.OrderDetailStatus = "å¼å§";
			if (cabinOrderDetail.Order_Inqty == cabinOrderDetail.Order_qty)
			{
			cabinOrderDetail.OrderDetailStatus = "å·²å®æ";
			_cabinOrderDetailServices.Repository.DeleteAndMoveIntoHty(cabinOrderDetail, OperateTypeEnum.èªå¨å®æ);
			}
			else
			{
			_cabinOrderDetailServices.Repository.UpdateData(cabinOrderDetail);
			}
			var cabinOrder1 = BaseDal.Db.Queryable<Dt_CabinOrder>().Where(x => x.Order_no == cabinOrder.Order_no).Includes(x => x.Details).First();
			if (cabinOrder1.Details == null \|\| cabinOrder1.Details.Count < 1) cabinOrder.OdrderStatus = "å·²å®æ";
			Repository.UpdateData(cabinOrder);
			#endregion

			#region è´§ä½
			var location = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == LocationCode);
			if (location == null) return WebResponseContent.Instance.Error($"è¯·ç»´æ¤è´§ä½ç¼å·ã{LocationCode}ãçè´§ä½ä¿¡æ¯");
			if (location.EnableStatus == EnableStatusEnum.Disable.ObjToInt())
			return WebResponseContent.Instance.Error($"è´§ä½ç¼å·ã{LocationCode}ãå·²ç¦ç¨ï¼è¯·æ¢å¤æ£å¸¸åä½¿ç¨");
			if (location.LocationStatus != LocationStatusEnum.InStock.ObjToInt())
			{
			location.LocationStatus = LocationStatusEnum.InStock.ObjToInt();
			_basicService.LocationInfoService.UpdateData(location);
			}
			#endregion

			#region åºå
			Dt_InventoryInfo inventoryInfo = _inventoryInfoService.Repository.QueryFirst(x => x.BatchNo == cabinOrderDetail.Batch_num && x.MaterielCode == cabinOrderDetail.Goods_no && x.LocationCode == LocationCode);
			if (inventoryInfo != null)
			{
			inventoryInfo.StockQuantity += Inqty;
			_inventoryInfoService.UpdateData(inventoryInfo);
			}
			else
			{
			inventoryInfo = new Dt_InventoryInfo()
			{
			LocationCode = LocationCode,
			MaterielCode = materielInfo.MaterielCode,
			MaterielName = materielInfo.MaterielName,
			MaterielSpec = materielInfo.MaterielSpec,
			OutboundQuantity = 0,
			StockQuantity = Inqty,
			StockStatus = StockStatusEmun.å¥åºå®æ.ObjToInt(),
			ValidityPeriod = cabinOrderDetail.Exp_date,
			WarehouseCode = cabinOrderDetail.Reservoirarea,
			SupplyQuantity = 0,
			InDate = DateTime.Now,
			BatchNo = cabinOrderDetail.Batch_num,
			Creater = App.User.UserName,
			CreateDate = DateTime.Now,
			};
			_inventoryInfoService.AddData(inventoryInfo);
			}
			#endregion

			#region ä»»å¡è®°å½
			Dt_SupplyTask supplyTask = new Dt_SupplyTask()
			{
			WarehouseCode = cabinOrderDetail.Reservoirarea,
			TaskNum = cabinOrderDetail.Id,
			TaskStatus = SupplyStatusEnum.InFinish.ObjToInt(),
			BatchNo = inventoryInfo.BatchNo,
			MaterielName = inventoryInfo.MaterielName,
			MaterielCode = inventoryInfo.MaterielCode,
			MaterielSpec = inventoryInfo.MaterielSpec,
			TaskType = TaskTypeEnum.InPick.ObjToInt(),
			CreateDate = DateTime.Now,
			Creater = App.User.UserName,
			LocationCode = location.LocationCode,
			OrderNo = cabinOrder.Order_no,
			StockQuantity = Inqty,
			SupplyQuantity = 0,
			Remark = "å¥åº"
			};
			_supplyTaskService.AddData(supplyTask);
			#endregion

			#region åºåæ¹æ¬¡
			Dt_Inventory_Batch inventory_Batch = _inventory_BatchServices.Repository.QueryFirst(x => x.BatchNo == inventoryInfo.BatchNo && x.MaterielCode == inventoryInfo.MaterielCode);
			if (inventory_Batch != null)
			{
			inventory_Batch.StockQuantity += Inqty;
			_inventory_BatchServices.UpdateData(inventory_Batch);
			}
			else
			{
			inventory_Batch = new Dt_Inventory_Batch()
			{
			BatchNo = inventoryInfo.BatchNo,
			CreateDate = inventoryInfo.CreateDate,
			Creater = inventoryInfo.Creater,
			MaterielCode = inventoryInfo.MaterielCode,
			ERPStockQuantity = 0,
			MaterielName = inventoryInfo.MaterielName,
			MaterielSpec = inventoryInfo.MaterielSpec,
			OutboundQuantity = inventoryInfo.OutboundQuantity,
			ProductionDate = inventoryInfo.ProductionDate,
			Status = false,
			StockQuantity = inventoryInfo.StockQuantity,
			ValidityPeriod = inventoryInfo.ValidityPeriod,
			SupplyQuantity = inventoryInfo.SupplyQuantity,
			};
			_inventory_BatchServices.AddData(inventory_Batch);
			}
			#endregion

			_unitOfWorkManage.CommitTran();
			#endregion

			content.OK(cabinOrderDetail.Order_Inqty.ToString());
			}
			catch (Exception ex)
			{
			_unitOfWorkManage.RollbackTran();
			content.Error(ex.Message);
			}
			return content;
			}


			/// <summary>
			/// è·åä¸æ¸¸ç³»ç»çå¥åºå
			/// </summary>
			/// <param name="searchDate"></param>
			/// <returns></returns>
			//public WebResponseContent GetUpstreamOrder(DateTime searchDate)
			//{
			// var responseContent = new WebResponseContent();

			// try
			// {
			// // è¯·æ±å°å
			// var url = "http://127.0.0.1:9090/GYZ2/95fck/inOrder";

			// //// è¯·æ±åæ°
			// var requestData = new
			// {
			// searchDate = searchDate.ToString("yyyy-MM-dd HH:mm:ss")
			// };

			// // åèµ·è¯·æ±
			// var result = HttpHelper.Post(url, requestData.ToJsonString());

			// // ååºåå
			// var response = JsonConvert.DeserializeObject<UpstreamResponse<UpstreamOrderInfo>>(result);

			// if (response.resultCode != "0")
			// {
			// // è°ç¨å¼å¸¸æ¥å£
			// SendErrorToUpstream(1, "", response.resultMsg ?? "ä¸æ¸¸æ¥å£è¿åå¤±è´¥", "");
			// return responseContent.Error(response.resultMsg ?? "ä¸æ¸¸æ¥å£è¿åå¤±è´¥");
			// }

			// if (response.data == null \|\| !response.data.Any())
			// {
			// return responseContent.OK("æ æ°å¥åºåæ°æ®");
			// }

			// Db.Ado.BeginTran();
			// List<Dt_CabinOrder> _CabinOrders = new List<Dt_CabinOrder>();
			// foreach (var order in response.data)
			// {
			// try
			// {
			// // æå¥å¥åºåè¡¨
			// var entityOrder = new Dt_CabinOrder
			// {

			// Order_no = order.order_no,
			// Order_type = order.order_type,
			// Supplier_no = order.supplier_no,
			// Account_tiem = order.account_time,
			// OdrderStatus = "æ°å»º",
			// };
			// //var orderId = Db.Insertable(entityOrder).ExecuteReturnIdentity(); //å°±æ¯è¿åä¸»é®IDã

			// // æå¥å¥åºæç»è¡¨
			// var detailEntities = order.details.Select(d => new Dt_CabinOrderDetail
			// {
			// //OrderId= orderId,
			// Goods_no = d.goods_no,
			// Order_qty = d.order_qty,
			// Batch_num = d.batch_num,
			// Exp_date = d.exp_date,
			// Warehouse_no = d.warehouse_no,
			// Status = 0,
			// }).ToList();
			// entityOrder.Details.AddRange(detailEntities); //å»ºç«ä¸»å¯¹è±¡ä¸åå¯¹è±¡çå³èå³ç³»
			// _CabinOrders.Add(entityOrder);

			// //èªå·±
			// /// Db.Insertable(detailEntities).ExecuteCommand();

			// //è¿éè¦è°ç¨ä¸ä¸ªæ¥å£å°ä¸é¢çä¿¡æ¯ä¼ ç»wcsï¼ç¶åæ¹åç¶æ
			// }
			// catch (Exception innerEx)
			// {
			// // éå¯¹ææ¡è®¢åæ¥éæ¶ï¼æ¨éå¼å¸¸ç»ä¸æ¸¸
			// SendErrorToUpstream(1, order.order_no, innerEx.Message, "");
			// throw; // æåºå¼å¸¸ï¼è®©å¤å±æè·åæ»
			// }
			// }
			// // æ¹éæå¥ï¼SqlSugarèªå¨å¤çä¸»å¤é®å³ç³»ï¼
			// Db.Insertable(_CabinOrders).ExecuteCommand();
			// Db.Ado.CommitTran();

			// //å¦æEdiInå®æé£ä¹å°±è°ç¨CompleteOrderæ¥å£

			// return responseContent.OK("åæ¥å¥åºåæå");
			// }
			// catch (Exception ex)
			// {
			// // å¨å±å¼å¸¸æ¶ï¼ä¹æ¨éå¼å¸¸ç»ä¸æ¸¸
			// SendErrorToUpstream(1, "", ex.Message, "");
			// Db.Ado.RollbackTran();
			// return responseContent.Error("åæ¥å¤±è´¥: " + ex.Message);
			// }
			//}


			public WebResponseContent GetUpstreamOrder()
			{
			var responseContent = new WebResponseContent();
			@@ -187,6 +298,7 @@

			foreach (var order in newOrders)
			{
			bool skipOrder = false;//æ è®°æ¯å¦è·³è¿è¯¥å¥åºå
			var entityOrder = new Dt_CabinOrder
			{
			Order_no = order.order_no,
			@@ -195,28 +307,145 @@
			Supplier_no = order.supplier_no,
			Account_tiem = order.account_time,
			OdrderStatus = "æ°å»º",
			Supplier_name=order.supplier_name,
			Supplier_name = order.supplier_name,
			Warehouse_no = order.warehouse_no,
			Details = order.details.Select(d => new Dt_CabinOrderDetail
			{
			//OrderId è¦æ¿å°å¥åºåè¡¨ä¸çidï¼å¦ä½æ¿ä¸å°å°±å°è¿ä¸ªåæ®µæ¹äºï¼æ¹æå¥åºåå·
			// SqlSugar InsertNavå·¥ä½åçåæå¥ä¸»è¡¨ (Dt_CabinOrder)//è·åçæçä¸»é®ID//èªå¨è®¾ç½®åè¡¨çå³èåæ®µ (OrderId)//åæå¥(Dt_CabinOrderDetail)
			Goods_no = d.goods_no,
			Order_qty = d.order_qty,
			Batch_num = d.batch_num,
			Exp_date = d.exp_date,
			OrderDetailStatus="æ°å»º",
			Status = order.warehouse_no== "001" ? 0 : 2, //å¦ææ¯001æ¿é£ä¹å°±æ¯æªåæ¥ç¶æï¼å¦æä¸æ¯001æ¿é£ä¹å°±æ¯æ éåæ¥ç¶æ
			}).ToList()
			Details = new List<Dt_CabinOrderDetail>()
			//Details = order.details.Select(d => new Dt_CabinOrderDetail
			//{
			// //OrderId è¦æ¿å°å¥åºåè¡¨ä¸çidï¼å¦ä½æ¿ä¸å°å°±å°è¿ä¸ªåæ®µæ¹äºï¼æ¹æå¥åºåå·
			// // SqlSugar InsertNavå·¥ä½åçåæå¥ä¸»è¡¨ (Dt_CabinOrder)//è·åçæçä¸»é®ID//èªå¨è®¾ç½®åè¡¨çå³èåæ®µ (OrderId)//åæå¥(Dt_CabinOrderDetail)
			// Goods_no = d.goods_no,
			// Order_qty = d.order_qty,
			// Batch_num = d.batch_num,
			// Exp_date = d.exp_date,
			// OrderDetailStatus = "æ°å»º",
			// Status = order.warehouse_no == "001" ? 0 : 2, //å¦ææ¯001æ¿é£ä¹å°±æ¯æªåæ¥ç¶æï¼å¦æä¸æ¯001æ¿é£ä¹å°±æ¯æ éåæ¥ç¶æ
			//}).ToList()
			};
			foreach (var item in order.details)
			{
			// å°ä¸æ¸¸å¥åºæ°éè½¬ä¸ºæ£æ°
			item.order_qty = Math.Abs(item.order_qty);
			#region æ ¹æ®ç©æç¼ç æ¥è¯¢ç©æä¿¡æ¯
			Dt_MaterielInfo materielInfo = _basicService.MaterielInfoService.Repository.QueryFirst(x => x.MaterielCode == item.goods_no);
			//å¦æç©æä¿¡æ¯ä¸åå¨ï¼è·³è¿æ´ä¸ªå¥åºå
			if (materielInfo == null)
			{
			skipOrder = true;
			Console.WriteLine($"è·³è¿å¥åºå {order.order_no}ï¼åå ï¼æªæ¾å°åå [{item.goods_no}] çç©æä¿¡æ¯ã");
			break;
			}

			// è¥ç©æä¸åå¨æ MaterielSourceType ä¸ºç©ºï¼åè·³è¿æ´ä¸ªå¥åºå
			if (materielInfo == null \|\| !Enum.IsDefined(typeof(MaterielSourceTypeEnum), materielInfo.MaterielSourceType))
			{
			skipOrder = true;
			break;
			}
			//Dt_MedicineGoods materielInfo = BaseDal.Db.Queryable<Dt_MedicineGoods>().Where(x => x.Goods_no == item.goods_no).First();
			///æ ¹æ®ç©æä¿¡æ¯å¤§å°ä»¶å±æ§åºåæ¯å¦å¥ç«åº //å¤§ä»¶å¥å¹³åº
			if (materielInfo.MaterielSourceType == MaterielSourceTypeEnum.PurchasePart)
			{
			Dt_CabinOrderDetail orderDetail = new Dt_CabinOrderDetail()
			{
			Reservoirarea = order.warehouse_no,
			Goods_no = item.goods_no,
			Order_qty = item.order_qty,
			Batch_num = item.batch_num,
			Exp_date = item.exp_date,
			OrderDetailStatus = "æ°å»º",
			Status = 2
			};
			entityOrder.Details.Add(orderDetail);
			}
			else
			{
			Dt_CabinOrderDetail orderDetail = null;
			var ys = item.order_qty % materielInfo.BoxQty; //ä¸è½æ´é¤ç®±è§çæ£ä»¶æ°
			var xs = item.order_qty / materielInfo.BoxQty;//æ´ç®±æ°é
			#region çæç«åºå¥åºå

			#region å¤ææ¯å¦ææ£ä»¶
			if (ys > 0)
			{
			orderDetail = new Dt_CabinOrderDetail()
			{
			Reservoirarea = order.warehouse_no,
			Goods_no = item.goods_no,
			Order_qty = ys,
			Batch_num = item.batch_num,
			Exp_date = item.exp_date,
			OrderDetailStatus = "æ°å»º",
			Status = 0
			};
			materielInfo.Business_qty += ys;
			}
			#endregion

			#region å¤æç«åºåºåæ¯å¦å¤§äºç«åºæä½åºåæ°
			while (materielInfo.Business_qty < materielInfo.MinQty && xs > 0)
			{
			xs--;
			if (orderDetail == null)
			{
			orderDetail = new Dt_CabinOrderDetail()
			{
			Reservoirarea = order.warehouse_no,
			Goods_no = item.goods_no,
			Order_qty = materielInfo.BoxQty,
			Batch_num = item.batch_num,
			Exp_date = item.exp_date,
			OrderDetailStatus = "æ°å»º",
			Status = 0
			};
			materielInfo.Business_qty += materielInfo.BoxQty;
			}
			else
			{
			orderDetail.Order_qty += materielInfo.BoxQty;
			materielInfo.Business_qty += materielInfo.BoxQty;
			}
			}
			#endregion

			if (orderDetail != null) entityOrder.Details.Add(orderDetail);
			#endregion

			#region å©ä½æ´ä»¶å¥å¹³åº
			if (xs > 0)
			{
			orderDetail = new Dt_CabinOrderDetail()
			{
			Reservoirarea = order.warehouse_no,
			Goods_no = item.goods_no,
			Order_qty = materielInfo.BoxQty * xs,
			Batch_num = item.batch_num,
			Exp_date = item.exp_date,
			OrderDetailStatus = "æ°å»º",
			Status = 2
			};
			entityOrder.Details.Add(orderDetail);
			}
			#endregion
			}
			_basicService.MaterielInfoService.Repository.UpdateData(materielInfo);
			//_medicineGoodsServices.Db.Updateable(materielInfo).ExecuteCommand();
			#endregion
			}
			// âå¦æè·³è¿è¯¥åï¼åç´æ¥continueï¼ä¸ä¿å
			if (skipOrder)
			{
			Console.WriteLine($"è·³è¿å¥åºå {order.order_no}ï¼å ä¸ºåå¨æªå®ä¹ç©æå±æ§çååã");
			continue;
			}
			_CabinOrders.Add(entityOrder);
			orderNos.Add(order.order_no);
			};
			BaseDal.Db.InsertNav(_CabinOrders).Include(x => x.Details).ExecuteCommand();

			//å¨ä¸åç»wcs
			//var reslut= EdiIn(); //åç»ä¸æ¸¸
			//å¦æè¿ä¸ªæ¹æ³æåäºï¼é£ä¹å°±è°ç¨CompleteOrderæ¥å£ï¼ç¶åæ¹å
			//var reslut= EdiIn(); //åç»ä¸æ¸¸
			//å¦æè¿ä¸ªæ¹æ³æåäºï¼é£ä¹å°±è°ç¨CompleteOrderæ¥å£ï¼ç¶åæ¹å
			Db.Ado.CommitTran();
			return responseContent.OK("åæ¥å¥åºåæå");
			}
			@@ -230,6 +459,214 @@
			catch (Exception ex)
			{
			// å¨å±å¼å¸¸æ¶ï¼ä¹æ¨éå¼å¸¸ç»ä¸æ¸¸
			SendErrorToUpstream(1, "", ex.Message, "");
			return responseContent.Error("åæ¥å¤±è´¥: " + ex.Message);
			}
			}

			/// <summary>
			/// å¯¹æ²¡æè¿è¡ç»´æ¤ååä¿¡æ¯è¡¨çå¥åºåè¿è¡è¿æ»¤å¤ç
			/// </summary>
			/// <returns></returns>
			public WebResponseContent GetUpstreamOrder2()
			{
			var responseContent = new WebResponseContent();
			try
			{
			// è¯·æ±å°å
			var url = "http://121.37.118.63:80/GYZ2/95fck/inOrder";
			//if (string.IsNullOrEmpty(SearchDate)) SearchDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
			//// è¯·æ±åæ°
			var requestData = new
			{
			//searchDate = SearchDate
			searchDate = "2020-10-10 20:45:16" // æ£ç¡®çæ ¼å¼
			};
			//SearchDate = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd HH:mm:ss");

			var result = HttpHelper.Post(url, requestData.ToJsonString());
			var response = JsonConvert.DeserializeObject<UpstreamResponse<UpstreamOrderInfo>>(result);

			if (response.resultCode != "0")
			{
			SendErrorToUpstream(1, "", response.resultMsg ?? "ä¸æ¸¸æ¥å£è¿åå¤±è´¥", "");
			return responseContent.Error(response.resultMsg ?? "ä¸æ¸¸æ¥å£è¿åå¤±è´¥");
			}

			if (response.data == null \|\| !response.data.Any())
			return responseContent.OK("æ æ°å¥åºåæ°æ®");

			var existingOrderNos = BaseDal.Db.Queryable<Dt_CabinOrder>()
			.Select(x => x.Order_no)
			.ToList();

			var newOrders = response.data
			.Where(order => !existingOrderNos.Contains(order.order_no))
			.ToList();

			if (!newOrders.Any())
			return responseContent.OK("ææå¥åºåå·²åå¨ï¼æ éæ°å¢");

			Db.Ado.BeginTran();
			try
			{
			List<Dt_CabinOrder> _CabinOrders = new();
			List<string> orderNos = new();

			foreach (var order in newOrders)
			{
			bool skipOrder = false; // æ è®°æ¯å¦è·³è¿è¯¥å¥åºå
			var entityOrder = new Dt_CabinOrder
			{
			Order_no = order.order_no,
			Order_type = order.order_type,
			Supplier_no = order.supplier_no,
			Account_tiem = order.account_time,
			OdrderStatus = "æ°å»º",
			Supplier_name = order.supplier_name,
			Warehouse_no = order.warehouse_no,
			Details = new List<Dt_CabinOrderDetail>()
			};

			foreach (var item in order.details)
			{
			item.order_qty = Math.Abs(item.order_qty);

			// æ¥è¯¢ç©æä¿¡æ¯
			var materielInfo = BaseDal.Db.Queryable<Dt_MedicineGoods>()
			.Where(x => x.Goods_no == item.goods_no)
			.First();


			//å¦æç©æä¿¡æ¯ä¸åå¨ï¼è·³è¿æ´ä¸ªå¥åºå
			if (materielInfo == null)
			{
			skipOrder = true;
			Console.WriteLine($"è·³è¿å¥åºå {order.order_no}ï¼åå ï¼æªæ¾å°åå [{item.goods_no}] çç©æä¿¡æ¯ã");
			break;
			}

			// è¥ç©æä¸åå¨æ MaterielSourceType ä¸ºç©ºï¼åè·³è¿æ´ä¸ªå¥åºå
			if (materielInfo == null \|\| !Enum.IsDefined(typeof(MaterielSourceTypeEnum), materielInfo.MaterielSourceType))
			{
			skipOrder = true;
			break;
			}

			// åºåå¤§ä»¶/å°ä»¶
			if (materielInfo.MaterielSourceType == MaterielSourceTypeEnum.PurchasePart)
			{
			var detail = new Dt_CabinOrderDetail
			{
			Reservoirarea = order.warehouse_no,
			Goods_no = item.goods_no,
			Order_qty = item.order_qty,
			Batch_num = item.batch_num,
			Exp_date = item.exp_date,
			OrderDetailStatus = "æ°å»º",
			Status = 2
			};
			entityOrder.Details.Add(detail);
			}
			else
			{
			Dt_CabinOrderDetail orderDetail = null;
			var ys = item.order_qty % materielInfo.BoxQty; // ä¸è½æ´é¤çæ£ä»¶
			var xs = item.order_qty / materielInfo.BoxQty; // æ´ç®±æ°é

			// ææ£ä»¶
			if (ys > 0)
			{
			orderDetail = new Dt_CabinOrderDetail
			{
			Reservoirarea = order.warehouse_no,
			Goods_no = item.goods_no,
			Order_qty = ys,
			Batch_num = item.batch_num,
			Exp_date = item.exp_date,
			OrderDetailStatus = "æ°å»º",
			Status = 0
			};
			materielInfo.Business_qty += ys;
			}

			// ä¸è¶³æä½åºåæ¶è¡¥å¥ç«åº
			while (materielInfo.Business_qty < materielInfo.MinQty && xs > 0)
			{
			xs--;
			if (orderDetail == null)
			{
			orderDetail = new Dt_CabinOrderDetail
			{
			Reservoirarea = order.warehouse_no,
			Goods_no = item.goods_no,
			Order_qty = materielInfo.BoxQty,
			Batch_num = item.batch_num,
			Exp_date = item.exp_date,
			OrderDetailStatus = "æ°å»º",
			Status = 0
			};
			}
			else
			{
			orderDetail.Order_qty += materielInfo.BoxQty;
			}
			materielInfo.Business_qty += materielInfo.BoxQty;
			}

			if (orderDetail != null) entityOrder.Details.Add(orderDetail);

			// å©ä½æ´ç®±å¥å¹³åº
			if (xs > 0)
			{
			entityOrder.Details.Add(new Dt_CabinOrderDetail
			{
			Reservoirarea = order.warehouse_no,
			Goods_no = item.goods_no,
			Order_qty = materielInfo.BoxQty * xs,
			Batch_num = item.batch_num,
			Exp_date = item.exp_date,
			OrderDetailStatus = "æ°å»º",
			Status = 2
			});
			}
			}

			_medicineGoodsServices.Db.Updateable(materielInfo).ExecuteCommand();
			}

			// âå¦æè·³è¿è¯¥åï¼åç´æ¥continueï¼ä¸ä¿å
			if (skipOrder)
			{
			Console.WriteLine($"è·³è¿å¥åºå {order.order_no}ï¼å ä¸ºåå¨æªå®ä¹ç©æå±æ§çååã");
			continue;
			}

			_CabinOrders.Add(entityOrder);
			orderNos.Add(order.order_no);
			}

			if (_CabinOrders.Any())
			{
			BaseDal.Db.InsertNav(_CabinOrders).Include(x => x.Details).ExecuteCommand();
			Db.Ado.CommitTran();
			return responseContent.OK($"æååæ¥ {_CabinOrders.Count} æ¡å¥åºå");
			}
			else
			{
			Db.Ado.RollbackTran();
			return responseContent.OK("æ å¯å¤ççå¥åºåï¼ååå±æ§æªå®ä¹ææªæ¾å°ï¼");
			}
			}
			catch (Exception ex)
			{
			Db.Ado.RollbackTran();
			SendErrorToUpstream(1, "", ex.Message, "");
			return responseContent.Error("åæ¥å¤±è´¥: " + ex.Message);
			}
			}
			catch (Exception ex)
			{
			SendErrorToUpstream(1, "", ex.Message, "");
			return responseContent.Error("åæ¥å¤±è´¥: " + ex.Message);
			}
			@@ -264,7 +701,7 @@
			Console.WriteLine("æ²¡æç¬¦åæ¡ä»¶çè®¢åéè¦æ¨é");
			return WebResponseContent.Instance.Error("æ²¡æç¬¦åæ¡ä»¶çè®¢åéè¦æ¨é");
			}



			// 4. éåè®¢åï¼ç»è£ DTO å¹¶æ¨é
			foreach (var order in orders)
			@@ -272,10 +709,10 @@
			string materialCode = "YY";//é»è®¤å¼
			//è·åå½åè®¢åçç¬¬ä¸ä¸ªæç»é¡¹
			var firstDetail = order.Details.FirstOrDefault();
			if (firstDetail?.MedicineGoods != null && !string.IsNullOrEmpty(firstDetail.MedicineGoods.MaterialCode))
			if (firstDetail?.MedicineGoods != null && !string.IsNullOrEmpty(firstDetail.MedicineGoods.MaterielErpType))
			{
			//å¦ææ¡ä»¶æ»¡è¶³ï¼å°ç©æä»£ç è®¾ç½®ä¸ºç¬¬ä¸ä¸ªæç»é¡¹å¯¹åºçè¯åç©æä»£ç
			materialCode = firstDetail.MedicineGoods.MaterialCode;
			materialCode = firstDetail.MedicineGoods.MaterielErpType;
			}

			var ediDto = new ToediInInfo
			@@ -300,9 +737,9 @@
			//äº§å
			productCode = d.Goods_no,
			//skuåç§°
			productName = d.MedicineGoods?.Goods_spm,
			productName = d.MedicineGoods?.MaterielName,
			//skuè§æ ¼
			productSpecifications = d.MedicineGoods?.Model,
			productSpecifications = d.MedicineGoods?.MaterielSpec,
			//æ°é
			quantity = (int)d.Order_qty,
			//ææ
			@@ -333,10 +770,10 @@
			if (resp != null && resp.code == "0")
			{
			// æ´æ°è¡¨å¤´ç¶æ
			BaseDal.Db.Updateable<Dt_CabinOrder>()
			.SetColumns(o => new Dt_CabinOrder { OdrderStatus = "å¼å§" })
			.Where(o => o.Id == order.Id)
			.ExecuteCommand();
			BaseDal.Db.Updateable<Dt_CabinOrder>()
			.SetColumns(o => new Dt_CabinOrder { OdrderStatus = "å¼å§" })
			.Where(o => o.Id == order.Id)
			.ExecuteCommand();

			// æ´æ°æç»ç¶æä¸ºå·²åæ¥
			BaseDal.Db.Updateable<Dt_CabinOrderDetail>()
			@@ -357,7 +794,7 @@
			}
			catch (Exception ex)
			{


			Console.WriteLine("EdiIn å¼å¸¸ï¼" + ex.Message);
			return new WebResponseContent { Status = false, Message = ex.Message };
			}
			@@ -444,7 +881,7 @@
			Exp_date = d.Exp_date,
			OrderDetailStatus = d.OrderDetailStatus,
			Status = d.Status,


			}).ToList();

			BaseDal.Db.Insertable(detailsHistory).ExecuteCommand();
			@@ -486,7 +923,7 @@
			}






			/// <summary>
			@@ -518,7 +955,7 @@







			}