MingHeZhiNeng/DuiDuoJiLiKu.git

			@@ -1,4 +1,5 @@
			ï»¿using MailKit.Search;
			ï»¿using AngleSharp.Dom;
			using MailKit.Search;
			using Masuit.Tools;
			using Microsoft.Extensions.Hosting;
			using Microsoft.Extensions.Logging;
			@@ -30,10 +31,13 @@
			private readonly ISys_ConfigService _configService;
			private readonly ILocationInfoRepository _locationRepository;
			private readonly IDt_InboundOrderRepository _inboundOrderRepository;
			private readonly IDt_ProductionOutboundOrderRepository _productionoutboundorderRepository;
			private readonly IDt_AllocateOutboundOrderRepository _allocateoutboundorderRepository;
			private readonly IUnitOfWorkManage _unitOfWorkManage;

			private Timer _timer;

			public MyBackgroundService(ILogger<MyBackgroundService> logger, ILocationInfoRepository locationRepository, IStockInfoRepository stockInfoRepository, IDt_AreaInfoRepository areaInfoRepository, IDt_TaskRepository taskRepository, IDt_StationManagerRepository stationManagerRepository, ISys_ConfigService configService,IDt_InboundOrderRepository inboundOrderRepository)
			public MyBackgroundService(ILogger<MyBackgroundService> logger, ILocationInfoRepository locationRepository, IStockInfoRepository stockInfoRepository, IDt_AreaInfoRepository areaInfoRepository, IDt_TaskRepository taskRepository, IDt_StationManagerRepository stationManagerRepository, ISys_ConfigService configService,IDt_InboundOrderRepository inboundOrderRepository,IDt_AllocateOutboundOrderRepository allocateoutboundorderRepository,IDt_ProductionOutboundOrderRepository productionOutboundOrderRepository,IUnitOfWorkManage unitOfWorkManage)
			{
			_logger = logger;
			_locationRepository = locationRepository;
			@@ -43,11 +47,14 @@
			_stationManagerRepository = stationManagerRepository;
			_configService = configService;
			_inboundOrderRepository = inboundOrderRepository;
			_allocateoutboundorderRepository = allocateoutboundorderRepository;
			_productionoutboundorderRepository = productionOutboundOrderRepository;
			_unitOfWorkManage = unitOfWorkManage;
			}

			public Task StartAsync(CancellationToken cancellationToken)
			{
			_timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromMinutes(1));
			_timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromMinutes(5));
			return Task.CompletedTask;
			}

			@@ -55,22 +62,21 @@
			{
			try
			{
			#region å¥åºåæ®åæ¥
			List<WMS_éè´å¥æåå¥åºèªå¨æå°æ¸å_ST> ERPPrintChecklist =SqlSugarHelper.DBERP.Queryable<WMS_éè´å¥æåå¥åºèªå¨æå°æ¸å_ST>().Where(x => true).ToList();


			var printCheckList = _inboundOrderRepository.QueryData(x => true);
			List<Dt_InboundOrder> inboundOrderAdd = new List<Dt_InboundOrder>();
			List<Dt_InboundOrder> inboundOrderUpdate = new List<Dt_InboundOrder>();
			if (ERPPrintChecklist != null) return;
			foreach (var item in ERPPrintChecklist)
			{
			var x = printCheckList.Where(x => x.MaterialNo == item.æå· && x.OrderNo == item.åå· && x.WarehouseName == item.å¥åºä»åºåç§°).FirstOrDefault();
			var x = printCheckList.Where(x => x.MaterialNo == item.æå· && x.UpperOrderNo == item.åå· && x.WarehouseName == item.å¥åºä»åºåç§°).FirstOrDefault();
			if (x == null)
			{
			Dt_InboundOrder Print = new Dt_InboundOrder()
			{
			PrintCode = GetOrderPintCode(),
			OrderNo = item.åå·,
			OrderNo = GetOrderPintCode("OrderNoIn"),
			UpperOrderNo = item.åå·,
			DemandClassification = item.éæ±åç±»,
			OrderType = item.åæ®ç±»å,
			WarehouseName = item.å¥åºä»åºåç§°,
			@@ -91,10 +97,10 @@
			}
			else
			{
			if (x.PrintCode == null \|\| x.PrintCode == "")
			if (x.OrderNo == null \|\| x.OrderNo == "")
			{
			x.PrintCode = GetOrderPintCode();
			x.OrderNo = item.åå·;
			x.OrderNo = GetOrderPintCode("OrderNoIn");
			x.UpperOrderNo = item.åå·;
			x.DemandClassification = item.éæ±åç±»;
			x.OrderType = item.åæ®ç±»å;
			x.WarehouseName = item.å¥åºä»åºåç§°;
			@@ -121,17 +127,210 @@
			{
			_inboundOrderRepository.UpdateData(inboundOrderUpdate);
			}
			#endregion

			#region ERPçäº§é¢æååæ¥

			var productionOutOrder = _productionoutboundorderRepository.Db.Queryable<Dt_ProductionOutboundOrder>().Includes(x => x.Details).ToList();

			List<Dt_ProductionOutboundOrder> productionoutboundOrderAdd = new List<Dt_ProductionOutboundOrder>();
			List<WMS_ç¨åå·¥ç¨åè´§åä¸è§è¡¨_ST> EngineeringERP = SqlSugarHelper.DBERP.Queryable<WMS_ç¨åå·¥ç¨åè´§åä¸è§è¡¨_ST>().Where(x => true).ToList();
			List<WMS_ç¨åçäº§é¢æåä¸è§è¡¨_ST> productERP = SqlSugarHelper.DBERP.Queryable<WMS_ç¨åçäº§é¢æåä¸è§è¡¨_ST>().Where(x => true).ToList();
			foreach (var item in EngineeringERP)
			{
			var x = productionOutOrder.Where(x => x.UpperOrderNo == item.åå· && x.DemandClassification == item.éæ±åç§° && x.OrderPartNumber == item.è®¢åæå· && x.OrderSpec == item.è®¢åè§æ ¼).FirstOrDefault();
			if (x == null)
			{
			if(productionoutboundOrderAdd.Where(x => x.UpperOrderNo == item.åå· && x.DemandClassification == item.éæ±åç§° && x.OrderPartNumber == item.è®¢åæå· && x.OrderSpec == item.è®¢åè§æ ¼).FirstOrDefault()==null)
			{
			Dt_ProductionOutboundOrder outOrder = new Dt_ProductionOutboundOrder()
			{
			OrderNo = GetOrderPintCode("OrderNoOut"),
			UpperOrderNo = item.åå·,
			OrderName = item.è®¢ååå,
			DemandClassification = item.éæ±åç§°,
			OrderPartNumber = item.è®¢åæå·,
			OrderSpec = item.è®¢åè§æ ¼,
			OrderStatus = (int)OrderStateEmun.æªå¼å§,
			OrderType = (int)OrderTypeEmun.çäº§é¢æå,
			CreateType = (int)OrderCreateTypeEmun.ERPæ¨é,
			Details = new List<Dt_ProductionOutboundOrderDetail>()
			{
			new Dt_ProductionOutboundOrderDetail()
			{
			MaterielCode = item.åä»¶æå·,
			MaterielName = item.åä»¶åå,
			Specs = item.åä»¶è§æ ¼,
			Weight = item.åä»¶åé,
			OrderQuantity = item.åä»¶å®éç¨é,
			NotOutQuantity = item.åä»¶æªåæ°é,
			OverOutQuantity = item.åä»¶åæ¾æ°é,
			}
			}
			};
			productionoutboundOrderAdd.Add(outOrder);
			}
			else
			{
			var existingOrder = productionoutboundOrderAdd.Where(x => x.UpperOrderNo == item.åå·).FirstOrDefault();
			existingOrder.Details.Add(new Dt_ProductionOutboundOrderDetail()
			{
			MaterielCode = item.åä»¶æå·,
			MaterielName = item.åä»¶åå,
			Specs = item.åä»¶è§æ ¼,
			Weight = item.åä»¶åé,
			OrderQuantity = item.åä»¶å®éç¨é,
			NotOutQuantity = item.åä»¶æªåæ°é,
			OverOutQuantity = item.åä»¶åæ¾æ°é,
			});
			}
			}
			}
			foreach (var item in productERP)
			{
			var x = productionOutOrder.Where(x => x.UpperOrderNo == item.åå· && x.DemandClassification == item.éæ±åç§° && x.OrderPartNumber == item.è®¢åæå·).FirstOrDefault();
			if (x == null)
			{
			if (productionoutboundOrderAdd.Where(x => x.UpperOrderNo == item.åå· && x.DemandClassification == item.éæ±åç§° && x.OrderPartNumber == item.è®¢åæå·).FirstOrDefault() == null)
			{
			Dt_ProductionOutboundOrder outOrder = new Dt_ProductionOutboundOrder()
			{
			OrderNo = GetOrderPintCode("OrderNoOut"),
			UpperOrderNo = item.åå·,
			OrderName = item.è®¢ååå,
			DemandClassification = item.éæ±åç§°,
			OrderPartNumber = item.è®¢åæå·,
			//OrderSpec = item.è®¢åè§æ ¼,
			OrderStatus = (int)OrderStateEmun.æªå¼å§,
			OrderType = (int)OrderTypeEmun.çäº§é¢æå,
			CreateType = (int)OrderCreateTypeEmun.ERPæ¨é,
			Details = new List<Dt_ProductionOutboundOrderDetail>()
			{
			new Dt_ProductionOutboundOrderDetail()
			{
			MaterielCode = item.åä»¶æå·,
			MaterielName = item.åä»¶åå,
			Specs = item.åä»¶è§æ ¼,
			Weight = item.åä»¶åé,
			OrderQuantity = item.åä»¶å®éç¨é,
			NotOutQuantity = item.åä»¶æªåæ°é,
			OverOutQuantity = item.åä»¶åæ¾æ°é,
			}
			}
			};
			productionoutboundOrderAdd.Add(outOrder);
			}
			else
			{
			var existingOrder = productionoutboundOrderAdd.Where(x => x.UpperOrderNo == item.åå· && x.DemandClassification == item.éæ±åç§° && x.OrderPartNumber == item.è®¢åæå·).FirstOrDefault();
			existingOrder.Details.Add(new Dt_ProductionOutboundOrderDetail()
			{
			MaterielCode = item.åä»¶æå·,
			MaterielName = item.åä»¶åå,
			Specs = item.åä»¶è§æ ¼,
			Weight = item.åä»¶åé,
			OrderQuantity = item.åä»¶å®éç¨é,
			NotOutQuantity = item.åä»¶æªåæ°é,
			OverOutQuantity = item.åä»¶åæ¾æ°é,
			});
			}
			}

			}

			#endregion

			#region ERPè°æ¨åºåºååæ¥

			var allocateoutboundorder = _allocateoutboundorderRepository.Db.Queryable<Dt_AllocateOutboundOrder>().Includes(x => x.Details).ToList();

			List<Dt_AllocateOutboundOrder> allocateoutboundorderAdd = new List<Dt_AllocateOutboundOrder>();
			List<Dt_AllocateOutboundOrder> allocateoutboundorderUpdate = new List<Dt_AllocateOutboundOrder>();
			List<WMS_ç¨åçµæ§æè°æ¨ä¸è§è¡¨_ST> ERPallocateOrder = SqlSugarHelper.DBERP.Queryable<WMS_ç¨åçµæ§æè°æ¨ä¸è§è¡¨_ST>().Where(x => true).ToList();
			foreach (var item in ERPallocateOrder)
			{
			var x = allocateoutboundorder.Where(x => x.UpperOrderNo == item.åå· && x.DemandClassification == item.éæ±åç§° && x.OrderPartNumber == item.è®¢åæå· && x.OrderSpec == item.è®¢åè§æ ¼).FirstOrDefault();
			if (x == null)
			{
			if (allocateoutboundorderAdd.Where(x => x.UpperOrderNo == item.åå·).FirstOrDefault() == null)
			{
			Dt_AllocateOutboundOrder outOrder = new Dt_AllocateOutboundOrder()
			{
			OrderNo = GetOrderPintCode("OrderNoOut"),
			UpperOrderNo = item.åå·,
			OrderName=item.è®¢ååå,
			DemandClassification=item.éæ±åç§°,
			OrderPartNumber =item.è®¢åæå·,
			OrderSpec =item.è®¢åè§æ ¼,
			OrderStatus = (int)OrderStateEmun.æªå¼å§,
			OrderType = (int)OrderTypeEmun.è°æ¨åºåºå,
			CreateType = (int)OrderCreateTypeEmun.ERPæ¨é,
			Details = new List<Dt_AllocateOutboundOrderDetail>()
			{
			new Dt_AllocateOutboundOrderDetail()
			{
			MaterielCode = item.åä»¶æå·,
			MaterielName = item.åä»¶åå,
			Specs = item.åä»¶è§æ ¼,
			Weight = item.åä»¶åé,
			OrderQuantity = item.åä»¶å®éç¨é,
			NotOutQuantity = item.åä»¶æªåæ°é,
			OverOutQuantity = item.åä»¶åæ¾æ°é,
			}
			}
			};
			allocateoutboundorderAdd.Add(outOrder);
			}
			else
			{
			var existingOrder = allocateoutboundorderAdd.Where(x => x.UpperOrderNo == item.åå· && x.DemandClassification == item.éæ±åç§° && x.OrderPartNumber == item.è®¢åæå· && x.OrderSpec == item.è®¢åè§æ ¼).FirstOrDefault();
			existingOrder.Details.Add(new Dt_AllocateOutboundOrderDetail()
			{
			MaterielCode = item.åä»¶æå·,
			MaterielName = item.åä»¶åå,
			Specs = item.åä»¶è§æ ¼,
			Weight = item.åä»¶åé,
			OrderQuantity = item.åä»¶å®éç¨é,
			NotOutQuantity = item.åä»¶æªåæ°é,
			OverOutQuantity = item.åä»¶åæ¾æ°é,
			});
			}
			}
			}
			#endregion

			#region æ°æ®å¤ç
			_unitOfWorkManage.BeginTran();

			if (productionoutboundOrderAdd.Count > 0)
			{
			//foreach (var order in productionoutboundOrderAdd)
			//{
			// _productionoutboundorderRepository.AddDataNavAsync(order);
			//}
			SqlSugarHelper.DbWMS.InsertNav(productionoutboundOrderAdd).Include(x => x.Details).ExecuteCommandAsync();
			}
			if (allocateoutboundorderAdd.Count > 0)
			{
			SqlSugarHelper.DbWMS.InsertNav(allocateoutboundorderAdd).Include(x=>x.Details).ExecuteCommandAsync();
			}
			_unitOfWorkManage.CommitTran();


			#endregion

			}
			catch (Exception ex)
			{
			_unitOfWorkManage.RollbackTran();
			ConsoleHelper.WriteErrorLine($"éè¯¯ä¿¡æ¯ï¼" + ex.Message);
			}
			}

			public string GetOrderPintCode()
			public string GetOrderPintCode(string printCode)
			{
			string PrintCode = "";
			var PrintSetting = SqlSugarHelper.DbWMS.Queryable<Dt_PrintSetting>().Where(x => x.PrintCode == "OrderNo").ToList().FirstOrDefault();
			var PrintSetting = SqlSugarHelper.DbWMS.Queryable<Dt_PrintSetting>().Where(x => x.PrintCode == printCode).ToList().FirstOrDefault();

			if (PrintSetting.Spare1 == DateTime.Now.ToString("yyyyMMdd"))
			{
			@@ -142,7 +341,7 @@
			{
			PrintSetting.Spare1 = DateTime.Now.ToString("yyyyMMdd");
			PrintSetting.PrintNo = 2;
			PrintCode = PrintSetting.PrintCode + PrintSetting.Spare1 + 1.ToString().PadLeft(PrintSetting.Spare2, '0');
			PrintCode = PrintSetting.Spare1 + 1.ToString().PadLeft(PrintSetting.Spare2, '0');
			}
			SqlSugarHelper.DbWMS.Updateable(PrintSetting).ExecuteCommand();
			return PrintCode;