~wy/MES.git - Gitblit

			@@ -31,6 +31,7 @@
			using System.Runtime.CompilerServices;
			using System.Runtime.InteropServices;
			using System.Text;
			using System.Threading;
			using System.Threading.Tasks;
			using System.Web;
			using System.Windows.Documents;
			@@ -76,7 +77,7 @@

			if (e.BarItemKey.ToUpper() == "TBSEARCH")
			{
			SearchList222();
			SearchList();
			}

			if (e.BarItemKey.ToUpper() == "TBLOCK")
			@@ -95,14 +96,14 @@

			if (e.BarItemKey.ToUpper() == "TBCOMPLETE")
			{
			CompleteSetAnalysis();
			//CompleteSetAnalysis();
			//COMPLETEMAIN();
			// COMPLETE();
			COMPLETE();
			}
			//提料计划
			if (e.BarItemKey.ToUpper() == "TBEXTRACTION")
			{
			Extraction3();
			Extraction();
			}

			}
			@@ -254,35 +255,16 @@
			public void Lock()
			{
			int day = Convert.ToInt32(this.Model.GetValue("FLockDays"));

			string sqlwhere = " and 1=1";
			string FSalOrder = Convert.ToString((this.Model.GetValue("FSalOrder")));
			if (string.IsNullOrEmpty(FSalOrder))
			{

			}
			else
			sqlwhere += $" and FHSeOrderBillNo='{FSalOrder}'";

			//获取单据体信息
			Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
			//单据体信息转换为列表集合
			DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
			List<string> sqlList = new List<string>();
			string sql;
			foreach (var item in entityDataObjoct)
			{
			sql = $"/dialect/update t1 set t1.FHLockedSub=1 from Sc_WorkBillSortBillSub t1 join Sc_WorkBillSortBillMain t2 on t1.FID = t2.FID where FHMASTERDATE between DATEADD(day,-1,getdate()) and DATEADD(day,{day - 1},getdate()) and t1.FID = { Convert.ToString(item["FDayPlanWorkID"])} ";

			//sql = $"/dialect/update Sc_WorkBillSortBillSub set FHLockedSub=1 where FEntryID in (select TOP({day}) FEntryID from Sc_WorkBillSortBillSub where FHLOCKEDSUB = 0 AND FID = { Convert.ToString(item["FDayPlanWorkID"])} AND DATEDIFF(DAY, GETDATE(), FHMASTERDATE) >= 0 ORDER BY FEntryID) ";
			sqlList.Add(sql);

			}

			string sql = $"/dialect/update t1 set t1.FHLockedSub=1 from Sc_WorkBillSortBillSub t1 join Sc_WorkBillSortBillMain t2 on t1.FID = t2.FID where FHMASTERDATE between DATEADD(day,-1,getdate()) and DATEADD(day,{day - 1},getdate())";
			sqlList.Add(sql);
			int result = DBServiceHelper.ExecuteBatch(Context, sqlList);
			if (result > 0)
			{
			SearchList222();
			//锁定后生成日计划用料清单及提料计划
			DayPlanPPBomBill();
			Extraction();
			SearchList();
			this.View.ShowMessage("操作成功");
			}
			else
			@@ -294,16 +276,6 @@
			public void RelieveLock()
			{
			int day = Convert.ToInt32(this.Model.GetValue("FLockDays"));

			string sqlwhere = " and 1=1";
			string FSalOrder = Convert.ToString((this.Model.GetValue("FSalOrder")));
			if (string.IsNullOrEmpty(FSalOrder))
			{

			}
			else
			sqlwhere += $" and FHSeOrderBillNo='{FSalOrder}'";

			//获取单据体信息
			Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
			//单据体信息转换为列表集合
			@@ -313,16 +285,12 @@
			foreach (var item in entityDataObjoct)
			{
			sql = $"/dialect/update t1 set t1.FHLockedSub=0 from Sc_WorkBillSortBillSub t1 join Sc_WorkBillSortBillMain t2 on t1.FID = t2.FID where FHMASTERDATE between DATEADD(day,-1,getdate()) and DATEADD(day,{day - 1},getdate()) and t1.FID = { Convert.ToString(item["FDayPlanWorkID"])} ";

			//sql = $"/dialect/update Sc_WorkBillSortBillSub set FHLockedSub=1 where FEntryID in (select TOP({day}) FEntryID from Sc_WorkBillSortBillSub where FHLOCKEDSUB = 0 AND FID = { Convert.ToString(item["FDayPlanWorkID"])} AND DATEDIFF(DAY, GETDATE(), FHMASTERDATE) >= 0 ORDER BY FEntryID) ";
			sqlList.Add(sql);

			}

			int result = DBServiceHelper.ExecuteBatch(Context, sqlList);
			if (result > 0)
			{
			SearchList222();
			SearchList();
			this.View.ShowMessage("操作成功");
			}
			else
			@@ -380,7 +348,7 @@
			if (result > 0)
			{
			this.View.ShowMessage("操作成功");
			SearchList222();
			SearchList();
			}
			else
			this.View.ShowMessage("操作失败，联系管理员！");
			@@ -392,16 +360,12 @@
			///
			private void COMPLETE()
			{

			// 显示一个进度显示界面：显示一个不停滚动的模拟进度

			// bUseTruePro参数：是否显示真实的进度。
			// bUseTruePro = false ：
			// 显示一个不停滚动的模拟进度，与实际处理进度没有关联。
			// 此方案优点：实际处理代码无需计算进度
			// 此方案缺点：进度不准确，且进度页面不会自动关闭。


			// bUseTruePro = true: 进度界面显示真实进度
			// 此方案优点：进度真实
			// 此方案缺点：需要在处理代码中，不断的更新真实进度，更新语句
			@@ -420,15 +384,13 @@
			try
			{
			// 需要捕获错误，以确保处理结束时，关闭进度滚动界面

			// 引入功能实际处理函数
			this.COMPLETEMAIN();
			this.CompleteSetAnalysis();
			}
			finally
			{
			// 确保标记进度已经到达100%
			this.View.Session["ProcessRateValue"] = 100;

			// 引入完毕，关闭进度显示页面
			var processView = this.View.GetView(processForm.PageId);
			if (processView != null)
			@@ -749,12 +711,15 @@
			/// </summary>
			public void CompleteSetAnalysis()
			{

			try
			{
			Stopwatch sw = new Stopwatch();
			sw.Start();//开始计时
			//清空齐套临时表
			DBServiceHelper.Execute(Context, "/dialect/ delete JIT_MOMaterReadysBill ");
			//更新状态
			DBServiceHelper.Execute(Context, "/dialect/ update Sc_WorkBillSortBillsub set FCOMPLETE='' ");
			//获取当前即时库存按照物料+库存组织+货主+库存数量
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			@@ -770,7 +735,7 @@
			LEFT JOIN T_STK_Inventory a on T1.FStockOrgId = a.FStockOrgId and T1.FMATERIALID =a.FMATERIALID
			LEFT JOIN JIT_MOMaterReadysBill B ON T1.FStockOrgId = b.FHSTOCKORGID and T1.FMATERIALID =b.FHMATERID and a.FOwnerId = b.FOwnerId
			LEFT join T_ORG_Organizations c on a.FOWNERID = c.FORGID
			where T1.FMATERIALID in (105773)
			--where T1.FMATERIALID in (105773)
			");
			ListInventory = ds.ToModelList<PRD_Inventory>();
			//总库存物料+库存组织+库存数量
			@@ -787,7 +752,7 @@
			) T1
			LEFT JOIN T_STK_Inventory a on T1.FStockOrgId = a.FStockOrgId and T1.FMATERIALID =a.FMATERIALID
			LEFT JOIN JIT_MOMaterReadysBill B ON T1.FStockOrgId = b.FHSTOCKORGID and T1.FMATERIALID =b.FHMATERID
			where T1.FMATERIALID in (105773)
			--where T1.FMATERIALID in (105773)
			group by T1.FStockOrgId,T1.FMATERIALID
			");
			ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();
			@@ -804,8 +769,8 @@
			JOIN T_BD_MATERIAL T4 on T2.FMATERIALID = T4.FMATERIALID
			JOIN T_ORG_Organizations t5 on a.FHPRDORGID = t5.FORGID
			--where FPRDMOMAINID = 100010
			where t4.FMATERIALID in (105773
			)
			--where t4.FMATERIALID in (105773
			--)
			ORDER BY b.FHMASTERDATE,a.FHOrderLev ";
			ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			List<PRD_PPBOM> BomList = ds.ToModelList<PRD_PPBOM>();
			@@ -813,8 +778,11 @@
			var DatePlanList = BomList.GroupBy(p => new { p.FHMASTERDATE, p.FPRDMOENTYID }).Select(x => new PRD_PPBOM { FHMASTERDATE = x.Key.FHMASTERDATE, FPRDMOENTYID = x.Key.FPRDMOENTYID }).ToList();
			//CompleteAnalysisTempModel 用于存储临时需要插入数据
			List<CompleteAnalysisTempModel> completeAnalysisTempModel = new List<CompleteAnalysisTempModel>();
			int i = 1;
			foreach (var item in DatePlanList)
			{
			this.View.Session["ProcessRateValue"] = Convert.ToInt32(this.View.Session["ProcessRateValue"]) + Convert.ToInt32((decimal)(1.0 / DatePlanList.Count));

			//筛选出当日计划数据
			var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();
			foreach (var _item in _BomList)
			@@ -889,9 +857,15 @@
			});
			}
			}
			Thread.Sleep(100);
			this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(40) / DatePlanList.Count) * i);
			i++;

			}
			i = 1;
			foreach (var item in completeAnalysisTempModel)
			{
			// this.View.Session["ProcessRateValue"] = Convert.ToInt32(this.View.Session["ProcessRateValue"]) + Convert.ToInt32(1 / completeAnalysisTempModel.Count * 90);
			JObject jsonRoot = new JObject();
			jsonRoot.Add("Creator", "");
			jsonRoot.Add("NeedUpDateFields", new JArray());
			@@ -929,6 +903,8 @@
			{
			LogHelper.Error(jsonRoot.ToString());
			}
			this.View.Session["ProcessRateValue"] = 40 + Convert.ToInt32((Convert.ToDecimal(60) / completeAnalysisTempModel.Count) * i);
			i++;
			}
			//执行完成后更新日计划工单状态
			DBServiceHelper.Execute(Context, @"
			@@ -948,10 +924,9 @@
			/// <summary>
			/// 查询
			/// </summary>
			public void SearchList222()
			public void SearchList()
			{
			string sqlwhere = " where 1=1";

			if ((this.Model.GetValue("FProWorkShopId") as DynamicObject) != null)
			{
			string FProWorkShopId = (this.Model.GetValue("FProWorkShopId") as DynamicObject)["Id"].ToString();
			@@ -960,23 +935,12 @@
			}
			//销售订单号
			string FSalOrder = Convert.ToString((this.Model.GetValue("FSalOrder")));
			if (string.IsNullOrEmpty(FSalOrder))
			{

			}
			else
			if (!string.IsNullOrEmpty(FSalOrder))
			sqlwhere += $" and FHSeOrderBillNo='{FSalOrder}'";


			//生产订单号
			string FScOrderMainNo = Convert.ToString((this.Model.GetValue("FScOrderMainNo")));
			if (string.IsNullOrEmpty(FScOrderMainNo))
			{

			}
			else
			if (!string.IsNullOrEmpty(FScOrderMainNo))
			sqlwhere += $" and FSCORDERNO='{FScOrderMainNo}'";

			//物料
			if ((this.Model.GetValue("FMatralId") as DynamicObject) != null)
			{
			@@ -988,8 +952,6 @@
			string FPreparatDate = Convert.ToString((this.Model.GetValue("FPreparatDate")));
			if (!string.IsNullOrEmpty(FPreparatDate))
			sqlwhere += $" and FPreparatDate='{FPreparatDate}'";


			try
			{
			string sql = @"/dialect/select t1.* from Sc_WorkBillSortBillMain t1
			@@ -1019,19 +981,14 @@
			this.Model.SetValue("FHMainSourceInterID", dt.Rows[i]["FPRDMOMAINID"].ToString(), i);//源单主内码FHMainSourceInterID
			this.Model.SetValue("FHMainSourceEntryID", dt.Rows[i]["FPRDMOENTYID"].ToString(), i);//源单子内码FHMainSourceEntryID
			this.Model.SetValue("FDayPlanWorkID", dt.Rows[i]["FID"].ToString(), i);//日计划工单FID

			this.Model.SetValue("FResourcesId", dt.Rows[i]["FHSourceID"].ToString(), i);//生产资源
			this.Model.SetValue("FProductWorkShopId", dt.Rows[i]["FHWorkShopID"].ToString(), i);//生产车间

			this.Model.SetValue("FCompleteSetCount", dt.Rows[i]["FCompleteCount"].ToString(), i);//齐套数量
			this.Model.SetValue("FOrderQuantity", dt.Rows[i]["FOrderQuantity"].ToString(), i);//生产订单数量
			this.Model.SetValue("FDayPlanQuantity", dt.Rows[i]["FDayPlanQuantity"].ToString(), i);//日计划数量
			this.Model.SetValue("FNoScheduled", dt.Rows[i]["FNoScheduled"].ToString(), i);//未排数量


			sql = @"/dialect/SELECT * FROM Sc_WorkBillSortBillSub WHERE DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0 and FID=" + dt.Rows[i]["FID"].ToString();
			DataTable _dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];

			foreach (DataRow dr in _dt.Rows)
			{
			/*
			@@ -1077,7 +1034,6 @@
			}
			}
			}

			for (int m = 0; m <= 60; m++)
			{
			this.View.GetControl("FT" + "" + m + "").Text = DateNow.AddDays(m).ToShortDateString();
			@@ -1087,9 +1043,6 @@
			{
			this.View.ShowErrMessage(ex.Message.ToString());
			}



			}
			/// <summary>
			/// 编辑
			@@ -1214,35 +1167,23 @@
			/// </summary>
			public void Extraction3()
			{
			string sql = string.Format(@"/dialect/ select t1.FID from Sc_WorkBillSortBillMain t1");
			DataTable fidDt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
			string FDayPlanWorkID = "";
			foreach (DataRow dr in fidDt.Rows)
			{
			FDayPlanWorkID += Convert.ToString(dr["FID"]) + ",";
			}

			//获取单据体信息
			Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
			//单据体信息转换为列表集合
			DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
			EntryGrid grid = this.View.GetControl<EntryGrid>("FEntity");
			string FDayPlanWorkID = "";//日工单ID
			if (entityDataObjoct.Count == 0)
			{
			this.View.ShowMessage("请先加载数据！");
			return;
			}
			else
			{
			foreach (DynamicObject current in entityDataObjoct)
			{
			FDayPlanWorkID += Convert.ToString(current["FDayPlanWorkID"]) + ",";
			}
			}
			FDayPlanWorkID = FDayPlanWorkID.Substring(0, FDayPlanWorkID.Length - 1);

			//提料计划预处理清理提料计划单数据更新采购订单提料计划数量
			string sql = string.Format(@"
			/dialect/
			sql = string.Format(@"

			exec [提料计划预处理] '{0}'
			", FDayPlanWorkID.Replace(",", "-"));

			DBServiceHelper.Execute(Context, sql);

			//采购订单数据
			sql = @"
			/dialect/
			@@ -1256,7 +1197,6 @@
			";
			List<PurchaseInventory> PurchaseInventory = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList<PurchaseInventory>();
			LogHelper.Info("采购订单数据" + sql);


			sql = string.Format(@"
			/dialect/
			@@ -1311,9 +1251,6 @@
			{
			DayPlanPpbom.RemoveAll(p => p.FENTRYID == item.FENTRYID && p.FMATERIALID == item.FMATERIALID);
			}



			sql = @"select T1.FID,FDayPlanQuantity,FCOMPLETECOUNT,t2.FHQTY, FHPRDORGID FStockOrgId from SC_WORKBILLSORTBILLMAIN T1
			JOIN SC_WORKBILLSORTBILLSUB T2 ON T1.FID=T2.FID WHERE DATEDIFF(D,GETDATE(),FHMASTERDATE) >=0 AND FDayPlanQuantity>FCOMPLETECOUNT AND T1.FID in (" + FDayPlanWorkID + ")";
			DataSet Complete = DBServiceHelper.ExecuteDataSet(Context, sql);
			@@ -1705,6 +1642,516 @@
			this.View.ShowMessage("操作成功");
			// var PODemandPlanList22 = PODemandPlanTemp.GroupBy(p => new {p.FSUPPLIERID, p.FHMASTERDATE }).ToList();
			}
			/// <summary>
			/// 日计划用料清单生成
			/// </summary>
			public void DayPlanPPBomBill()
			{
			try
			{
			string sql = string.Format(@"
			/dialect/
			select t1.FID,t1.FEntryID,t3.FMATERIALID,T5.FNUMBER,t1.FHMASTERDATE,t1.FHQTY,t4.FMATERIALID FMATERIALID2,T6.FNUMBER FNUMBER2,T7.FNUMBER FUNITNUMBER,FNumerator,FDenominator,convert(decimal(18,2),(FNumerator/FDenominator) *t1.FHQTY) FHQtyMust,T4.FUnitID,t8.FNUMBER FUNITNUMBER2,T3.FID FPPBOM,T4.FENTRYID,isnull(T9.FBillNo,'')FBillNo,t10.FNUMBER FORGNUMBER,t11.FNUMBER FHSOURCENUMBER,FSCRAPRATE,FFIXSCRAPQTY,T9.FID AS DayPlanFID
			FROM Sc_WorkBillSortBillSub t1
			JOIN Sc_WorkBillSortBillMAIN t2 on t1.FID = t2.FID
			JOIN T_PRD_PPBOM T3 on T2.FPRDMOMAINID=t3.FMOID AND T2.FPRDMOENTYID=T3.FMOENTRYID
			JOIN T_PRD_PPBOMENTRY T4 ON T3.FID=T4.FID
			JOIN T_BD_MATERIAL T5 ON T3.FMATERIALID=T5.FMATERIALID
			JOIN T_BD_MATERIAL T6 ON T4.FMATERIALID=T6.FMATERIALID
			LEFT JOIN T_BD_UNIT T7 ON T3.FUNITID = T7.FUNITID
			LEFT JOIN T_BD_UNIT T8 ON T4.FUNITID = T8.FUNITID
			LEFT JOIN Sc_DayPlanPPBomBillMain T9 ON T1.FEntryID=T9.FDayPlanFID
			LEFT join T_ORG_Organizations t10 on t2.FHPRDORGID = t10.FORGID
			LEFT join T_ENG_WORKCENTER t11 on t2.FHSOURCEID = t11.FID
			"
			);
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			DataTable dt = ds.Tables[0];
			List<DayPlanMaterial> DayPlanMaterial = new List<DayPlanMaterial>();
			if (dt.Rows.Count > 0)
			{
			foreach (DataRow dr in dt.Rows)
			{
			DayPlanMaterial.Add(new Demo.Model.Model.DayPlanMaterial
			{
			FID = dr["DayPlanFID"].ToString(),
			FEntryID = dr["FEntryID"].ToString(),
			FHDate = DateTime.Now.ToString(),
			FOrgId = dr["FORGNUMBER"].ToString(),
			FHMaterID = dr["FNUMBER"].ToString(),
			FHWorkDate = dr["FHMASTERDATE"].ToString(),
			FHQty = dr["FHQTY"].ToString(),
			FHUnitID = dr["FUNITNUMBER"].ToString(),
			FDayPlanFID = dr["FEntryID"].ToString(),
			FHMaterSubID = dr["FNUMBER2"].ToString(),
			FHUnitSubID = dr["FUNITNUMBER2"].ToString(),
			FHQtyMust = dr["FHQtyMust"].ToString(),
			FHQtySub = dr["FHQtyMust"].ToString(),
			FHPPBomInterID = dr["FPPBOM"].ToString(),
			FHPPBomEntryID = dr["FENTRYID"].ToString(),
			FHSourceID = dr["FHSOURCENUMBER"].ToString(),
			FNumerator = dr["FNumerator"].ToString(),
			FDenominator = dr["FDenominator"].ToString(),
			FFIXSCRAPQTY = dr["FFIXSCRAPQTY"].ToString(),
			FHQtyScrap = dr["FSCRAPRATE"].ToString(),
			});
			}
			var fidList = DayPlanMaterial.Select(x => x.FEntryID).Distinct().ToList();
			foreach (var item in fidList)
			{
			var _DayPlanMaterial = DayPlanMaterial.Where(x => x.FEntryID == item).ToList();
			JObject model = new JObject();
			model.Add("FHDate", DateTime.Now);
			model.Add("FOrgId", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FOrgId });//发料组织
			model.Add("FHMaterID", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FHMaterID });//物料
			model.Add("FHWorkDate", _DayPlanMaterial[0].FHWorkDate);//日工单日期 FHWorkDate
			model.Add("FHQty", _DayPlanMaterial[0].FHQty);//主产品数量：FHQty
			model.Add("FHUnitID", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FHUnitID });//单位：FHUnitID
			model.Add("FDayPlanFID", _DayPlanMaterial[0].FDayPlanFID);//日计划工单内码
			JArray Entry = new JArray();
			foreach (var _item in _DayPlanMaterial)
			{
			JObject ModelEnty = new JObject();
			ModelEnty.Add("FHMaterSubID", new JObject() { ["Fnumber"] = _item.FHMaterSubID });//子物料FHMaterSubID
			ModelEnty.Add("FHUnitSubID", new JObject() { ["Fnumber"] = _item.FHUnitSubID });//单位FHUnitSubID
			ModelEnty.Add("FHQtyMust", _item.FHQtyMust);//应发数量FHQtyMust
			ModelEnty.Add("FHQtySub", _item.FHQtySub);//数量FHQtySub
			ModelEnty.Add("FHPPBomInterID", _item.FHPPBomInterID);//用料清单主内码FHPPBomInterID
			ModelEnty.Add("FHPPBomEntryID", _item.FHPPBomEntryID);//用料清单子内码FHPPBomEntryID
			ModelEnty.Add("FHSourceID", new JObject() { ["Fnumber"] = _item.FHSourceID });//生产资源FHSourceID
			ModelEnty.Add("FNumerator", _item.FNumerator);//分母
			ModelEnty.Add("FDenominator", _item.FDenominator);//分子
			ModelEnty.Add("FFIXSCRAPQTY", _item.FFIXSCRAPQTY);//固定损耗
			ModelEnty.Add("FHQtyScrap", _item.FHQtyScrap);//变动损耗率%
			Entry.Add(ModelEnty);
			}
			model.Add("FEntity", Entry);
			if (!string.IsNullOrEmpty(_DayPlanMaterial[0].FID))
			model.Add("FID", _DayPlanMaterial[0].FID);
			JObject jsonRoot = new JObject()
			{
			["Creator"] = "",
			["NeedUpDateFields"] = new JArray(),
			["NeedReturnFields"] = new JArray(),
			["IsDeleteEntry"] = "true",
			["SubSystemId"] = "",
			["IsVerifyBaseDataField"] = "false",
			["Model"] = model
			};

			CloudClient cloudClient = new CloudClient("http://localhost/K3Cloud/");
			var result = cloudClient.Save("Paez_Sc_DayPlanPPBomBill", jsonRoot.ToString());
			JObject saveObj = JObject.Parse(result);
			string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
			if (saveIsSuc != "TRUE")
			LogHelper.Error(saveIsSuc);
			}
			}
			}
			catch (Exception ex)
			{
			LogHelper.Error(ex.Message.ToString());
			}
			}
			/// <summary>
			/// 提料计划
			/// </summary>
			public void Extraction()
			{
			string sql = string.Format(@"/dialect/ select t1.FID from Sc_WorkBillSortBillMain t1");
			DataTable fidDt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
			string FDayPlanWorkID = "";
			foreach (DataRow dr in fidDt.Rows)
			{
			FDayPlanWorkID += Convert.ToString(dr["FID"]) + ",";
			}

			FDayPlanWorkID = FDayPlanWorkID.Substring(0, FDayPlanWorkID.Length - 1);

			//提料计划预处理清理提料计划单数据更新采购订单提料计划数量
			sql = string.Format(@"

			exec [提料计划预处理] '{0}'
			", FDayPlanWorkID.Replace(",", "-"));

			DBServiceHelper.Execute(Context, sql);
			//采购订单数据
			sql = @"
			/dialect/
			select t1.FID,t1.FBillNo,t2.FENTRYID,t1.FSUPPLIERID,t3.fnumber,t2.FMATERIALID,(t2.FQTY-t2.FPODemandPlanCount)FQTY,FPurchaseOrgId FStockOrgId,t5.FNUMBER FORGNumber,FSTOCKINQTY,FReceiveQty,FCloseStatus,FMRPCLOSESTATUS from t_PUR_POOrder t1
			join t_PUR_POOrderEntry t2 on t1.FID = t2.FID
			join t_BD_Supplier t3 on t1.FSUPPLIERID = t3.FSUPPLIERID
			join T_PUR_POORDERENTRY_R t4 on t2.FENTRYID = t4.FENTRYID
			join T_ORG_Organizations t5 on t1.FPurchaseOrgId = t5.FORGID
			where t2.FQTY-t2.FPODemandPlanCount>0
			and FCloseStatus in('A') and FMRPCLOSESTATUS in('A')
			";
			List<PurchaseInventory> PurchaseInventory = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList<PurchaseInventory>();
			LogHelper.Info("采购订单数据" + sql);

			sql = string.Format(@"
			/dialect/
			select T1.*,t5.FFIXLEADTIME,t5.FMAXPOQTY,t5.FMINPOQTY,t6.FNumber from (
			select FHICMOINTERID FID,FHICMOENTRYID FEntryID,FPlanDate FHMASTERDATE,FLackCount NeedQty,FHMATERID FMATERIALID,FHStockOrgID FStockOrgId,FPRDBILLNO FBillNo from JIT_MOMaterReadysBill
			)T1
			join t_BD_MaterialBase t4 on T1.FMATERIALID = t4.FMATERIALID
			join t_BD_MaterialPlan t5 on T1.FMATERIALID = t5.FMATERIALID
			JOIN T_BD_MATERIAL T6 ON T1.FMATERIALID = T6.FMATERIALID
			WHERE T1.NeedQty >0 AND FERPCLSID=1
			AND T1.FENTRYID not in (select distinct FHSOURCEENTRYID from CG_PODEMANDPLANBILLSUB where FHSOURCEINTERID IN ({0}))
			AND T1.FID in ({0})
			order by FHMASTERDATE
			", FDayPlanWorkID);
			LogHelper.Info("提料数据" + sql);
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			List<DayPlanPpbom> DayPlanPpbom = ds.ToModelList<DayPlanPpbom>();

			var MaterialIDList = DayPlanPpbom.GroupBy(p => new { p.FMATERIALID, p.FStockOrgId }).Select(x => new PODemandPlanTemp { FMATERIALID = x.Key.FMATERIALID, FStockOrgId = x.Key.FStockOrgId }).ToList();
			var _MaterialIDList = MaterialIDList.Where(p => p.FMATERIALID == "105773").ToList();

			LogHelper.Info("物料行数" + MaterialIDList.Count);

			//提料计划数据集临时存储集合
			List<PODemandPlanTemp> PODemandPlanTemp = new List<PODemandPlanTemp>();
			//sql集合更新采购订单占用的提料计划数量
			List<string> sqlList = new List<string>();
			//MaterialIDList = new List<string> { "105773" };
			foreach (var item in MaterialIDList)
			{
			LogHelper.Info(item.FMATERIALID.ToString());
			List<DayPlanPpbom> _DayPlanPpbom = DayPlanPpbom.Where(x => x.FMATERIALID == item.FMATERIALID && x.FStockOrgId == item.FStockOrgId).ToList();

			decimal FMINPOQTY = _DayPlanPpbom.FirstOrDefault().FMINPOQTY;//最小起订量
			double FFIXLEADTIME = _DayPlanPpbom.FirstOrDefault().FFIXLEADTIME;//提前期
			decimal NeedQty = 0;
			DateTime DATE = _DayPlanPpbom.FirstOrDefault().FHMASTERDATE;
			int i = 1;
			//记录在最小采购量需求下的日计划明细FentyrID
			List<int> FEntryIdList = new List<int>();
			foreach (var _item in _DayPlanPpbom)
			{

			if (NeedQty == 0)
			DATE = Convert.ToDateTime(_item.FHMASTERDATE).AddDays(-FFIXLEADTIME);

			FEntryIdList.Add(_item.FENTRYID);

			NeedQty += _item.NeedQty;
			if (NeedQty >= FMINPOQTY)
			{
			List<PurchaseInventory> _PurchaseInventory = PurchaseInventory.Where(x => x.FMATERIALID == item.FMATERIALID && x.FStockOrgId == item.FStockOrgId && x.FQTY > 0).ToList();
			if (_PurchaseInventory.Count == 0)
			{
			NeedQty = 0;
			break;
			}

			foreach (var Purchase in _PurchaseInventory)
			{
			LogHelper.Info("Purchase");
			LogHelper.Info("物料：" + Purchase.FMATERIALID + ",数量：" + Purchase.FQTY);

			if (Purchase.FQTY >= NeedQty)
			{
			List<int> mmm = new List<int>();
			foreach (int id in FEntryIdList)
			{
			mmm.Add(id);
			var DayPlanPpbomls = DayPlanPpbom.Where(c => c.FENTRYID == id && c.FMATERIALID == _item.FMATERIALID).FirstOrDefault();
			PODemandPlanTemp.Add(new Demo.Model.Model.PODemandPlan.PODemandPlanTemp
			{
			FID = DayPlanPpbomls.FID,
			FHMASTERDATE = DATE,
			FQty = DayPlanPpbomls.NeedQty,
			FBILLNO = DayPlanPpbomls.FBILLNO,
			FENTRYID = DayPlanPpbomls.FENTRYID,
			FMATERIALID = DayPlanPpbomls.FMATERIALID,
			FNumber = DayPlanPpbomls.FNumber,
			OLDDATE = DayPlanPpbomls.FHMASTERDATE,
			FFIXLEADTIME = FFIXLEADTIME,

			PurchseFID = Purchase.FID,
			PurchseFentryID = Purchase.FENTRYID,
			FSUPPLIERID = Purchase.FSUPPLIERID,
			PurchseFNUMBER = Purchase.FNUMBER,
			PurchseFBillNo = Purchase.FBillNo,
			PurchseFqty = Purchase.FQTY,
			FStockOrgId = Purchase.FStockOrgId, //采购组织
			FORGNumber = Purchase.FORGNumber

			});
			//扣除日计划明细已被分配的数量
			DayPlanPpbomls.NeedQty = 0;
			}
			FEntryIdList.Clear();
			//更新采购订单
			sqlList.Add($"/dialect/ update t_PUR_POOrderEntry set FPODemandPlanCount =isnull(FPODemandPlanCount,0)+ '{NeedQty}' where FENTRYID = {Purchase.FENTRYID}");
			//扣除当前行对应采购订单数量
			var ls = PurchaseInventory.Where(c => c.FENTRYID == Purchase.FENTRYID).FirstOrDefault();
			ls.FQTY -= NeedQty;
			break;
			}
			else
			{
			NeedQty = NeedQty - Purchase.FQTY;
			decimal _NeedQty = Purchase.FQTY;//采购订单数量
			List<int> mmm = new List<int>();
			foreach (int id in FEntryIdList)
			{

			var DayPlanPpbomls = DayPlanPpbom.Where(c => c.FENTRYID == id && c.FMATERIALID == _item.FMATERIALID).FirstOrDefault();
			decimal Qty = DayPlanPpbomls.NeedQty;
			if (Qty > _NeedQty)
			Qty = _NeedQty;
			_NeedQty = _NeedQty - DayPlanPpbomls.NeedQty;
			PODemandPlanTemp.Add(new Demo.Model.Model.PODemandPlan.PODemandPlanTemp
			{
			FID = DayPlanPpbomls.FID,
			FHMASTERDATE = DATE,
			FQty = Qty,
			FBILLNO = DayPlanPpbomls.FBILLNO,
			FENTRYID = DayPlanPpbomls.FENTRYID,
			FMATERIALID = DayPlanPpbomls.FMATERIALID,
			FNumber = DayPlanPpbomls.FNumber,
			OLDDATE = DayPlanPpbomls.FHMASTERDATE,
			FFIXLEADTIME = FFIXLEADTIME,


			PurchseFID = Purchase.FID,
			PurchseFentryID = Purchase.FENTRYID,
			FSUPPLIERID = Purchase.FSUPPLIERID,
			PurchseFNUMBER = Purchase.FNUMBER,
			PurchseFBillNo = Purchase.FBillNo,
			PurchseFqty = Purchase.FQTY,
			FStockOrgId = Purchase.FStockOrgId, //采购组织
			FORGNumber = Purchase.FORGNumber


			});
			DayPlanPpbomls.NeedQty -= Qty;

			//更新采购订单
			sqlList.Add($"/dialect/ update t_PUR_POOrderEntry set FPODemandPlanCount = isnull(FPODemandPlanCount,0)+ '{Qty}' where FENTRYID = {Purchase.FENTRYID}");

			//更新Model
			var ls = PurchaseInventory.Where(c => c.FENTRYID == Purchase.FENTRYID).FirstOrDefault();
			ls.FQTY -= Qty;

			if (_NeedQty < 0)
			{
			foreach (var mm in mmm)
			{
			FEntryIdList.Remove(mm);
			}
			break;
			}

			mmm.Add(id);
			}
			foreach (var mm in mmm)
			{
			FEntryIdList.Remove(mm);
			}

			}
			}
			NeedQty = 0;
			}

			#region 剩下不足时按最小采购批次生成
			//剩下不足时按最小采购批次生成
			//else if (i == _DayPlanPpbom.Count && NeedQty > 0)
			//{
			// NeedQty = FMINPOQTY;
			// List<PurchaseInventory> _PurchaseInventory = PurchaseInventory.Where(x => x.FMATERIALID == item.FMATERIALID && x.FStockOrgId == item.FStockOrgId && x.FQTY > 0).ToList();
			// if (_PurchaseInventory.Count == 0)
			// {
			// NeedQty = 0;
			// break;
			// }

			// foreach (var Purchase in _PurchaseInventory)
			// {
			// if (Purchase.FQTY >= NeedQty)
			// {

			// List<int> mmm = new List<int>();
			// foreach (int id in FEntryIdList)
			// {
			// mmm.Add(id);
			// var DayPlanPpbomls = DayPlanPpbom.Where(c => c.FENTRYID == id && c.FMATERIALID == _item.FMATERIALID).FirstOrDefault();
			// PODemandPlanTemp.Add(new Demo.Model.Model.PODemandPlan.PODemandPlanTemp
			// {
			// FID = DayPlanPpbomls.FID,
			// FHMASTERDATE = DATE,
			// FQty = DayPlanPpbomls.NeedQty,
			// FBILLNO = DayPlanPpbomls.FBILLNO,
			// FENTRYID = DayPlanPpbomls.FENTRYID,
			// FMATERIALID = DayPlanPpbomls.FMATERIALID,
			// FNumber = DayPlanPpbomls.FNumber,
			// OLDDATE = DayPlanPpbomls.FHMASTERDATE,
			// FFIXLEADTIME = FFIXLEADTIME,

			// PurchseFID = Purchase.FID,
			// PurchseFentryID = Purchase.FENTRYID,
			// FSUPPLIERID = Purchase.FSUPPLIERID,
			// PurchseFNUMBER = Purchase.FNUMBER,
			// PurchseFBillNo = Purchase.FBillNo,
			// PurchseFqty = Purchase.FQTY

			// });
			// //扣除日计划明细已被分配的数量
			// DayPlanPpbomls.NeedQty = 0;
			// }
			// FEntryIdList.Clear();
			// //更新采购订单
			// sqlList.Add($"/dialect/ update t_PUR_POOrderEntry set FPODemandPlanCount =isnull(FPODemandPlanCount,0)+ '{NeedQty}' where FENTRYID = {Purchase.FENTRYID}");
			// //扣除当前行对应采购订单数量
			// var ls = PurchaseInventory.Where(c => c.FENTRYID == Purchase.FENTRYID).FirstOrDefault();
			// ls.FQTY -= NeedQty;
			// break;
			// }
			// else
			// {
			// NeedQty = NeedQty - Purchase.FQTY;
			// decimal _NeedQty = Purchase.FQTY;//采购订单数量
			// List<int> mmm = new List<int>();
			// foreach (int id in FEntryIdList)
			// {

			// var DayPlanPpbomls = DayPlanPpbom.Where(c => c.FENTRYID == id && c.FMATERIALID == _item.FMATERIALID).FirstOrDefault();
			// decimal Qty = DayPlanPpbomls.NeedQty;
			// if (Qty > _NeedQty)
			// Qty = _NeedQty;
			// _NeedQty = _NeedQty - DayPlanPpbomls.NeedQty;
			// PODemandPlanTemp.Add(new Demo.Model.Model.PODemandPlan.PODemandPlanTemp
			// {
			// FID = DayPlanPpbomls.FID,
			// FHMASTERDATE = DATE,
			// FQty = Qty,
			// FBILLNO = DayPlanPpbomls.FBILLNO,
			// FENTRYID = DayPlanPpbomls.FENTRYID,
			// FMATERIALID = DayPlanPpbomls.FMATERIALID,
			// FNumber = DayPlanPpbomls.FNumber,
			// OLDDATE = DayPlanPpbomls.FHMASTERDATE,
			// FFIXLEADTIME = FFIXLEADTIME,


			// PurchseFID = Purchase.FID,
			// PurchseFentryID = Purchase.FENTRYID,
			// FSUPPLIERID = Purchase.FSUPPLIERID,
			// PurchseFNUMBER = Purchase.FNUMBER,
			// PurchseFBillNo = Purchase.FBillNo,
			// PurchseFqty = Purchase.FQTY


			// });
			// DayPlanPpbomls.NeedQty -= Qty;
			// //更新采购订单
			// sqlList.Add($"/dialect/ update t_PUR_POOrderEntry set FPODemandPlanCount = isnull(FPODemandPlanCount,0)+ '{Qty}' where FENTRYID = {Purchase.FENTRYID}");

			// //更新Model
			// var ls = PurchaseInventory.Where(c => c.FENTRYID == Purchase.FENTRYID).FirstOrDefault();
			// ls.FQTY -= Qty;

			// if (_NeedQty < 0)
			// {
			// foreach (var mm in mmm)
			// {
			// FEntryIdList.Remove(mm);
			// }
			// break;
			// }

			// mmm.Add(id);
			// }
			// foreach (var mm in mmm)
			// {
			// FEntryIdList.Remove(mm);
			// }

			// }
			// }
			// NeedQty = 0;
			//}
			#endregion
			i++;
			}
			}

			var PODemandPlanList222 = PODemandPlanTemp.GroupBy(p => new PODemandPlanTemp { PurchseFNUMBER = p.PurchseFNUMBER, FHMASTERDATE = p.FHMASTERDATE }).Select(x => new PODemandPlanTemp { PurchseFNUMBER = x.Key.PurchseFNUMBER, FHMASTERDATE = x.Key.FHMASTERDATE }).ToList();

			var PODemandPlanList = PODemandPlanTemp.GroupBy(p => new { p.PurchseFNUMBER, p.FHMASTERDATE }).Select(x => new PODemandPlanTemp { PurchseFNUMBER = x.Key.PurchseFNUMBER, FHMASTERDATE = x.Key.FHMASTERDATE }).ToList();


			foreach (var item in PODemandPlanList)
			{
			DateTime date = item.FHMASTERDATE;
			string PurchseFNUMBER = item.PurchseFNUMBER;

			JObject model = new JObject();
			model.Add("FHDate", date);
			model.Add("FHRemark", "生产订单号：" + "测试呢呢");
			model.Add("FSupplierID", new JObject() { ["Fnumber"] = PurchseFNUMBER });
			JArray Fentity = new JArray();

			List<PODemandPlanTemp> _PODemandPlanList = PODemandPlanTemp.Where(x => x.FHMASTERDATE == date && x.PurchseFNUMBER == PurchseFNUMBER).ToList();
			foreach (var _item in _PODemandPlanList)
			{
			JObject FentityModel = new JObject();

			FentityModel.Add("FHPURCHASEORGID", new JObject() { ["Fnumber"] = _item.FORGNumber });//采购组织

			FentityModel.Add("FHMaterID", new JObject() { ["Fnumber"] = _item.FNumber });//物料
			FentityModel.Add("FHQty", _item.FQty);//数量
			FentityModel.Add("FHSourceInterID", _item.FID);//日计划工单FID
			FentityModel.Add("FHSourceEntryID", _item.FENTRYID);//日计划工单FENTRYID
			FentityModel.Add("FHSourceBillNo", _item.FBILLNO);//日计划工单单号
			FentityModel.Add("FHSourceBillType", "");//日计划工单类型
			FentityModel.Add("FDayPlanDate", _item.OLDDATE);//日计划工单类型
			FentityModel.Add("FHRelationQty", _item.PurchseFqty);//关联数量
			FentityModel.Add("FFIXLEADTIME", _item.FFIXLEADTIME);//提前期


			FentityModel.Add("FPURCHASEORGID", new JObject() { ["Fnumber"] = _item.FORGNumber });//采购组织
			FentityModel.Add("FHPOOrderInterID", _item.PurchseFID);// 采购订单内码：FHPOOrderInterID
			FentityModel.Add("FHPOOrderEntryID", _item.PurchseFentryID); //采购订单子内码：FHPOOrderEntryID
			FentityModel.Add("FHPOOrderBillNo", _item.PurchseFBillNo); //采购订单号：FHPOOrderBillNo
			Fentity.Add(FentityModel);
			}
			model.Add("FEntity", Fentity);
			JObject jsonRoot = new JObject()
			{
			["Creator"] = "",
			["NeedUpDateFields"] = new JArray(),
			["NeedReturnFields"] = new JArray(),
			["IsDeleteEntry"] = "false",
			["SubSystemId"] = "",
			["IsVerifyBaseDataField"] = "false",
			["Model"] = model
			};

			CloudClient cloudClient = new CloudClient("http://localhost/K3Cloud/");
			var result = cloudClient.Save("paez_PODemandPlan", jsonRoot.ToString());
			JObject saveObj = JObject.Parse(result);
			string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();

			LogHelper.Info("最后");
			LogHelper.Info(jsonRoot.ToString());
			if (saveIsSuc == "TRUE")
			{
			}
			else
			{
			LogHelper.Error(saveIsSuc);

			}

			}
			DBServiceHelper.ExecuteBatch(Context, sqlList);
			this.View.ShowMessage("操作成功");
			// var PODemandPlanList22 = PODemandPlanTemp.GroupBy(p => new {p.FSUPPLIERID, p.FHMASTERDATE }).ToList();
			}
			}
			}