MES.git - Gitblit

			@@ -1,14 +1,15 @@
			using Demo.Model.Model;
			using Demo.BillView.PRD;
			using Demo.Model.Model;
			using Demo.Model.Model.PODemandPlan;
			using K3Cloud.Extend.Utils;
			using Kingdee.BOS.App.Data;
			using Kingdee.BOS.Core;
			using Kingdee.BOS.Core.Bill.PlugIn;
			using Kingdee.BOS.Core.Bill;
			using Kingdee.BOS.Core.Const;
			using Kingdee.BOS.Core.DynamicForm;
			using Kingdee.BOS.Core.DynamicForm.PlugIn;
			using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
			using Kingdee.BOS.Core.DynamicForm.PlugIn.ControlModel;
			using Kingdee.BOS.Core.List;
			using Kingdee.BOS.Core.Metadata;
			using Kingdee.BOS.Core.Metadata.EntityElement;
			using Kingdee.BOS.JSON;
			@@ -21,22 +22,15 @@
			using Kingdee.K3.SCM.ServiceHelper;
			using Newtonsoft.Json.Linq;
			using NPOI.HSSF.UserModel;
			using NPOI.SS.Formula.Functions;
			using NPOI.SS.UserModel;
			using System;
			using System.Collections.Generic;
			using System.ComponentModel;
			using System.Data;
			using System.Diagnostics;
			using System.IO;
			using System.Linq;
			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;
			using ZD.Cloud.Logger;
			using ZD.Cloud.WebApi;
			using ZD.Share.Common;
			@@ -51,11 +45,33 @@
			string PathName = "日计划导入模板.xlsx";
			List<PRD_Inventory> ListInventory;//库存明细
			List<PRD_Inventory> ListInventoryByStockOrgId;//物料总库存

			private bool isSearched = false;
			public override void DataChanged(DataChangedEventArgs e)
			{
			if (!isSearched) return;
			base.DataChanged(e);
			var columns = new List<string>() { "", "" };
			for (int i = 0; i < 100; i++)
			{
			columns.Add("FT" + i.ToString());
			}
			var model = this.View.Model;
			if (columns.Contains(e.Field.Key))
			{
			var sum = columns.Select(x => Convert.ToDouble(model.GetValue(x, e.Row))).Sum();//日计划总和
			var scOrderCount = Convert.ToDouble(model.GetValue("FOrderQuantity", e.Row));//生产订单数量
			var FQTYLS = Convert.ToDouble(model.GetValue("FQTYLS", e.Row));//历史
			this.View.Model.SetValue("FNoScheduled", scOrderCount - sum - FQTYLS, e.Row);
			this.View.Model.SetValue("FDayPlanQuantity", sum, e.Row);
			}
			}
			public override void BarItemClick(BarItemClickEventArgs e)
			{
			base.BarItemClick(e);
			try
			{
			LogHelper.Info("生产计划平台按钮");
			if (e.BarItemKey.ToUpper() == "BTEXPORT")
			{
			ExportExcel();
			@@ -69,7 +85,9 @@
			}
			if (e.BarItemKey.ToUpper() == "TBSEARCH")
			{
			isSearched = false;
			SearchList();
			isSearched = true;
			}
			if (e.BarItemKey.ToUpper() == "TBLOCK")
			{
			@@ -80,35 +98,53 @@
			{
			RelieveLock();
			}
			//保存
			if (e.BarItemKey.ToUpper() == "BTNSAVE")
			{
			Save();
			}

			//齐套分析
			if (e.BarItemKey.ToUpper() == "TBCOMPLETE")
			{
			//CompleteSetAnalysis();
			//COMPLETEMAIN();
			COMPLETE();
			}
			//齐套分析
			if (e.BarItemKey.ToUpper() == "TBCOMPLETEBOM")
			{
			COMPLETEBOM();
			}
			//tbXnqt虚拟齐套
			if (e.BarItemKey.ToUpper() == "TBXNQT")
			{
			Xnqt();
			}
			//tb_CKXNQT 查看虚拟齐套
			if (e.BarItemKey.ToUpper() == "TB_CKXNQT")
			{
			XnqtLook();
			}
			//提料计划
			if (e.BarItemKey.ToUpper() == "TBEXTRACTION")
			{
			try
			{
			COMPLETE();
			DayPlanPPBomBill();
			CompleteSetAnalysisBySQL();
			DayPlanPPBomBillBatch();
			Extraction();
			}
			catch (Exception ex)
			{
			this.View.ShowErrMessage(ex.Message.ToString());
			}
			finally {
			finally
			{
			this.View.ShowMessage("操作成功！");

			}

			}
			//选单
			if (e.BarItemKey.ToUpper() == "TBSELECTMENU")
			{
			SelectMenu();
			}
			//预留
			if (e.BarItemKey.ToUpper() == "TBRESERVE")
			@@ -118,9 +154,9 @@
			//释放
			if (e.BarItemKey.ToUpper() == "TBRELEASE")
			{

			Release();
			}

			}
			catch (Exception ex)
			{
			@@ -132,7 +168,47 @@
			base.EntryBarItemClick(e);
			if (e.BarItemKey.ToUpper() == "TBEDIT")
			{
			isSearched = false;
			SearchListEdit();
			isSearched = true;
			}
			}
			/// <summary>
			/// button按钮点击事件
			/// </summary>
			/// <param name="e"></param>
			public override void ButtonClick(ButtonClickEventArgs e)
			{
			base.ButtonClick(e);
			if (e.Key.ToUpper() == "FTBXNQT")
			{
			try
			{
			List<string> sqlList = new List<string>();
			string sql = $"truncate table Sc_WorkBillMainXnqt";
			sqlList.Add(sql);
			sql = $"truncate table Sc_WorkBillSubXnqt";
			sqlList.Add(sql);
			string columnName = DBServiceHelper.ExecuteScalar<string>(Context, "/dialect/ select stuff((select ',' + name from syscolumns Where id = object_Id('Sc_WorkBillMainXnqt') for xml path('')),1,1,'') as name ", "");
			sql = $"insert into Sc_WorkBillMainXnqt({columnName}) select {columnName} from Sc_WorkBillSortBillMain";
			LogHelper.Info("测试1：" + sql);
			sqlList.Add(sql);
			columnName = DBServiceHelper.ExecuteScalar<string>(Context, "/dialect/ select stuff((select ',' + name from syscolumns Where id = object_Id('Sc_WorkBillSubXnqt') for xml path('')),1,1,'') as name ", "");
			sql = $"insert into Sc_WorkBillSubXnqt({columnName}) select {columnName} from Sc_WorkBillSortBillSub";
			LogHelper.Info("测试1：" + sql);

			sqlList.Add(sql);
			sql = $"update Sc_WorkBillSubXnqt set FComplete=''";
			sqlList.Add(sql);

			DBServiceHelper.ExecuteBatch(Context, sqlList);
			}
			catch (Exception ex)
			{
			this.View.ShowErrMessage(ex.Message);
			return;
			}
			this.View.ShowMessage("操作成功");
			}
			}
			/// <summary>
			@@ -141,25 +217,59 @@
			/// <param name="e"></param>
			public override void EntityRowDoubleClick(Kingdee.BOS.Core.DynamicForm.PlugIn.Args.EntityRowClickEventArgs e)
			{
			LogHelper.Info("[行双击事件]");

			base.EntityRowClick(e);

			DynamicFormShowParameter formPa = new DynamicFormShowParameter();

			if (e.ColKey == "FDELAYLNUM")
			{
			//生产计划平台拖期明细跳转
			formPa.FormId = "paez_TardinessDetails";
			formPa.CustomParams.Add("FID", Convert.ToString(this.View.Model.GetValue("FDayPlanWorkID", e.Row).ToString()));
			this.View.ShowForm(formPa);
			}
			else if (e.ColKey == "FQTYLS")
			{
			//生产计划平台
			string pageId = Guid.NewGuid().ToString();
			BillShowParameter showParameter = new BillShowParameter();
			showParameter.FormId = "Paez_Sc_WorkBillAutoSortBill";
			showParameter.OpenStyle.ShowType = ShowType.MainNewTabPage;
			showParameter.PageId = pageId;
			showParameter.Status = OperationStatus.EDIT;
			// 传入需要修改的日计划工单内码，
			showParameter.PKey = Convert.ToString(this.View.Model.GetValue("FDayPlanWorkID", e.Row).ToString());
			this.View.ShowForm(showParameter);

			}
			else
			{
			var type = this.View.Model.GetValue("FQTTYPE");
			if(type =="标准Bom")
			formPa.CustomParams.Add("tempName", "JIT_MOMaterReadysBomBill");
			//齐套分析明细列表跳转
			formPa.FormId = "paez_CompleteAnalysisDetail";
			formPa.CustomParams.Add("FHMainICMOInterID", Convert.ToString(this.View.Model.GetValue("FHMainSourceInterID", e.Row).ToString()));
			formPa.CustomParams.Add("FHMainICMOEntryID", Convert.ToString(this.View.Model.GetValue("FHMainSourceEntryID", e.Row).ToString()));
			formPa.CustomParams.Add("FHICMOInterID", Convert.ToString(this.View.Model.GetValue("FDayPlanWorkID", e.Row).ToString()));
			formPa.CustomParams.Add("FMatrailId_Id", Convert.ToString((this.View.Model.GetValue("FMatrailId", e.Row) as DynamicObject)["Id"].ToString()));
			this.View.ShowForm(formPa);
			}

			}
			/// <summary>
			/// 查看虚拟齐套
			/// </summary>
			public void XnqtLook()
			{
			var _key = this.View.Model.GetEntryCurrentRowIndex("FEntity");
			if (_key < 0)
			{
			this.View.ShowErrMessage("请选择需要查看的单据行！");
			return;
			}
			DynamicFormShowParameter formPa = new DynamicFormShowParameter();
			//齐套分析明细列表跳转
			formPa.FormId = "paez_CompleteAnalysisDetail";
			formPa.CustomParams.Add("FHICMOInterID", Convert.ToString(this.View.Model.GetValue("FDayPlanWorkID", _key).ToString()));
			formPa.CustomParams.Add("tempName", "JIT_MOMaterReadysBillXn");
			this.View.ShowForm(formPa);
			}
			/// <summary>
			@@ -167,13 +277,20 @@
			/// </summary>
			public void ExportExcel()
			{
			string[] Title = new string[] {"销售订单号", "生产订单号", "生产组织", "生产车间", "生产资源", "产品代码", "产品名称", "规格型号", "计量单位",
			"批次号","销售订单数量","生产订单数量","总齐套数量","交货日期","订单等级","T0","T1","T2","T3","T4","T5","T6","T7",
			List<string> Title = new List<string> {"销售订单号", "生产订单号","生产订单明细行号", "生产车间", "生产资源", "产品代码", "产品名称", "规格型号", "计量单位",
			"批次号","销售订单数量","生产订单数量","总齐套数量","交货日期","订单等级"};
			/*
			,"T0","T1","T2","T3","T4","T5","T6","T7",
			"T8","T9","T10","T11","T12","T13","T14","T15","T16","T17",
			"T18","T19","T20","T21","T22","T23","T24","T25","T26","T27","T28","T29",
			"T30","T31","T32","T33","T34","T35","T36","T37","T38","T39","T40","T41","T42",
			"T43","T44","T45","T46","T47","T48","T49","T50","T51","T52","T53","T54","T55","T56","T57","T58","T59","T60"};

			"T43","T44","T45","T46","T47","T48","T49","T50","T51","T52","T53","T54","T55","T56","T57","T58","T59","T60"
			*/
			DateTime date = DateTime.Now;
			for (int i = 0; i < 61; i++)
			{
			Title.Add(date.AddDays(i).ToString("yyyy-MM-dd"));
			}
			string sheetname = "日计划导入模板.xlsx";
			string file = "";
			file = @"D:\办公\K3Cloud\WebSite\TempfilePath\" + sheetname;
			@@ -222,7 +339,7 @@

			//设置列名
			HSSFRow row = (HSSFRow)sheet.CreateRow(0);
			for (int i = 0; i < Title.Length; i++)
			for (int i = 0; i < Title.Count; i++)
			{
			ICell cell = (ICell)row.CreateCell(i);
			var rowName = Title[i];
			@@ -232,7 +349,7 @@

			//单元格赋值
			//列宽自适应，只对英文和数字有效
			for (int i = 0; i <= Title.Length; i++)
			for (int i = 0; i <= Title.Count; i++)
			{
			sheet.AutoSizeColumn(i);
			}
			@@ -275,16 +392,7 @@
			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)
			{
			//锁定后生成日计划用料清单及提料计划
			DayPlanPPBomBill();
			Extraction();
			SearchList();
			this.View.ShowMessage("操作成功");
			}
			else
			this.View.ShowMessage("操作失败，联系管理员！");
			DayPlanPPBomBill();
			}
			/// <summary>
			/// 解锁
			@@ -297,78 +405,213 @@
			//单据体信息转换为列表集合
			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=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"])} ";
			sqlList.Add(sql);
			}
			int result = DBServiceHelper.ExecuteBatch(Context, sqlList);
			if (result > 0)
			{
			SearchList();
			this.View.ShowMessage("操作成功");
			}
			else
			this.View.ShowMessage("操作失败，联系管理员！");
			string 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())";
			DBServiceHelper.Execute(Context, sql);
			//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"])} ";
			// sqlList.Add(sql);
			//}
			SearchList();
			this.View.ShowMessage("操作成功");

			}
			/// <summary>
			/// 保存功能
			/// </summary>
			public void Save()
			{

			List<string> sqlList = new List<string>();
			string sql;
			//获取单据体信息
			Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
			//单据体信息转换为列表集合
			DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
			DateTime date = DateTime.Now;

			DateTime date = Convert.ToDateTime(DateTime.Now.ToString("d"));
			string _result = "";

			foreach (DynamicObject current in entityDataObjoct)
			{
			if (Convert.ToInt32(current["FNoScheduled"]) < 0)
			_result += "序号：" + Convert.ToString(current["SEQ"]) + ",日计划总数量超出生产订单数量";

			}
			if (_result != "")
			{
			this.View.ShowErrMessage(_result);
			return;
			}

			foreach (DynamicObject current in entityDataObjoct)
			{
			sql = $"/dialect/ update Sc_WorkBillSortBillMain set FOrderQuantity={current["FOrderQuantity"]},FDayPlanQuantity={current["FDayPlanQuantity"]},FNoScheduled={current["FNoScheduled"]} where FID = {current["FDayPlanWorkID"]}";
			sqlList.Add(sql);
			DateTime FBzDate = Convert.ToDateTime(Convert.ToDateTime(current["FBzDate"]));
			DateTime end = Convert.ToDateTime(Convert.ToDateTime(current["FBzDate"]).AddDays(60).ToShortDateString());//最大日期
			for (int i = 0; i <= 60; i++)
			if (Convert.ToInt32(current["FDayPlanWorkID"]) > 0)
			{
			DateTime start = Convert.ToDateTime(date.AddDays(i).ToShortDateString());
			TimeSpan getDay = end.Subtract(start);
			//编制日期+61天>date.AddDays(i).ToShortDateString() continue
			if (getDay.Days < 0)
			break;
			sql = $"/dialect/update t1 set FHQTY='{Convert.ToString(current["FT" + "" + i + ""])}' from Sc_WorkBillSortBillSub t1 join " +
			$" Sc_WorkBillSortBillMain t2 on t1.FID = t2.FID where FHMASTERDATE='{date.AddDays(i).ToShortDateString()}' and t2.FID='{Convert.ToString(current["FDayPlanWorkID"])}'";
			sqlList.Add(sql);
			JObject jsonRoot = new JObject();
			jsonRoot.Add("Creator", "");
			jsonRoot.Add("NeedUpDateFields", new JArray());
			jsonRoot.Add("NeedReturnFields", new JArray());
			jsonRoot.Add("IsDeleteEntry", "false");
			jsonRoot.Add("SubSystemId", "");
			jsonRoot.Add("IsVerifyBaseDataField", "");
			JObject jsonModel = new JObject();
			jsonModel.Add("FID", Convert.ToString(current["FDayPlanWorkID"]));
			jsonModel.Add("FOrderQuantity", Convert.ToString(current["FOrderQuantity"]));
			jsonModel.Add("FDayPlanQuantity", Convert.ToDecimal(current["FDayPlanQuantity"]) + Convert.ToDecimal(current["FQTYLS"]));
			jsonModel.Add("FNoScheduled", Convert.ToString(current["FNoScheduled"]));
			sql = $" /dialect/ select FEntryID, FHMASTERDATE from SC_WORKBILLSORTBILLSub where FID={Convert.ToString(current["FDayPlanWorkID"])} ";
			List<DayPlanModel> dayPlanModel = new List<DayPlanModel>();
			dayPlanModel = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList<DayPlanModel>();
			JArray Entry = new JArray();
			for (int i = 0; i <= 60; i++)
			{
			if (Convert.ToString(current["FT" + "" + i + ""]) == "" \|\| Convert.ToString(current["FT" + "" + i + ""]) == "0")
			continue;
			JObject jsonFPOOrderEntry = new JObject();
			jsonFPOOrderEntry.Add("FHMasterDate", date.AddDays(i).ToShortDateString()); ;//主日期
			jsonFPOOrderEntry.Add("FHQty ", Convert.ToString(current["FT" + "" + i + ""])); ;//日计划数量
			List<DayPlanModel> _dayPlanModel = dayPlanModel.Where(x => x.FHMASTERDATE == date.AddDays(i)).ToList();
			if (_dayPlanModel.Count > 0)
			{
			jsonFPOOrderEntry.Add("FEntryID", _dayPlanModel.FirstOrDefault().FEntryID); ;//序号
			}
			Entry.Add(jsonFPOOrderEntry);
			}
			jsonModel.Add("FEntity", Entry);
			jsonRoot.Add("Model", jsonModel);
			CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
			var result = cloudClient.Save("Paez_Sc_WorkBillAutoSortBill", jsonRoot.ToString());
			JObject saveObj = JObject.Parse(result);
			string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
			if (saveIsSuc != "TRUE")
			{
			LogHelper.Error("生产计划平台保存失败:" + jsonRoot.ToString());
			this.View.ShowMessage("数据储存失败！请联系管理员！");
			}
			}
			else
			{
			//根据生产订单号和物料查询是否存在明细 +生产订单明细行号
			sql = string.Format(@"
			/dialect/
			SELECT t4.FNAME as FMoFBillType,T1.FBILLNO,T2.*,t3.FNUMBER as FUnitNumber,tBom.FNUMBER as FBomNumber FROM T_PRD_MO T1
			LEFT JOIN T_PRD_MOENTRY T2 ON T1.FID = T2.FID
			LEFT JOIN T_ENG_BOM tBom on t2.FBOMID = tBom.FID
			join T_BD_UNIT t3 on t2.FUNITID=t3.FUNITID
			join ( select A.FBILLTYPEID,B.FNAME from T_BAS_BILLTYPE A
			JOIN T_BAS_BILLTYPE_L B ON A.FBILLTYPEID =B.FBILLTYPEID
			where FBILLFORMID='PRD_MO' AND FNAME<>'生產訂單')t4 on t1.FBILLTYPE =t4.FBILLTYPEID
			WHERE T1.FBILLNO = '{0}' AND T2.FMATERIALID = '{1}' AND T2.FSEQ = '{2}'", Convert.ToString(current["FSCOrderNo"]), Convert.ToString(current["FMatrailId_Id"]), Convert.ToString(current["FSRCBILLENTRYSEQ"]));
			DataTable dt = new DataTable();
			dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
			if (dt.Rows.Count == 0)
			continue;
			string FID = "";//FID 源单主内码
			string FENTRYID = "";//FENTRYID 源单子内码
			string FLOT = "";//FLOT 批次
			string FQTY = "";//FQTY 生产订单数量
			string FBILLNO = "";//FBILLNO 原单号
			string FHUnitID = "";//单位
			string FPlanBeginDate = "";//开始日期
			string FPlanEndDate = "";//结束日期
			string FMoFBillType = "";//
			string FBomNumber = "";//Bom 版本
			if (dt.Rows.Count > 0)
			{
			FID = dt.Rows[0]["FID"].ToString();
			FENTRYID = dt.Rows[0]["FENTRYID"].ToString();
			FLOT = dt.Rows[0]["FLOT"].ToString();
			FQTY = dt.Rows[0]["FQTY"].ToString();
			FBILLNO = dt.Rows[0]["FBILLNO"].ToString();
			FHUnitID = dt.Rows[0]["FUnitNumber"].ToString();
			FPlanBeginDate = dt.Rows[0]["FPlanStartDate"].ToString();
			FPlanEndDate = dt.Rows[0]["FPlanFinishDate"].ToString();
			FMoFBillType = dt.Rows[0]["FMoFBillType"].ToString();
			FBomNumber = dt.Rows[0]["FBomNumber"].ToString();
			}

			//选单数据做新增
			JObject jsonRoot = new JObject();
			jsonRoot.Add("Creator", "");
			jsonRoot.Add("NeedUpDateFields", new JArray());
			jsonRoot.Add("NeedReturnFields", new JArray());
			jsonRoot.Add("IsDeleteEntry", "false");
			jsonRoot.Add("SubSystemId", "");
			jsonRoot.Add("IsVerifyBaseDataField", "");
			JObject jsonModel = new JObject();
			jsonModel.Add("FPreparatDate", date.ToString());//编制日期
			jsonModel.Add("FMoFBillType", FMoFBillType);//
			jsonModel.Add("FSRCBILLENTRYSEQ", Convert.ToString(current["FSRCBILLENTRYSEQ"]));//生产订单明细行号
			jsonModel.Add("FSCOrderNo", Convert.ToString(current["FSCOrderNo"])); //生产订单号FSCOrderNo
			jsonModel.Add("FHSeOrderBillNo", Convert.ToString(current["FSalOrderNo"]));//销售订单号
			jsonModel.Add("FHOrderLev", current["FOrderLevel"].ToString());//订单等级
			jsonModel.Add("FHOrderQty", Convert.ToString(current["FSalOrderCount"]));//销售订单数量
			jsonModel.Add("FHOrderCommitDate", Convert.ToString(current["FDeliveryDate"]));//交货期HOrderCommitDate
			jsonModel.Add("FHUnitID", new JObject() { ["Fnumber"] = FHUnitID });//单位
			jsonModel.Add("FBOMID", new JObject() { ["Fnumber"] = FBomNumber });//BOM版本
			jsonModel.Add("FHPlanBeginDate", FPlanBeginDate);//计划开始日期
			jsonModel.Add("FHPlanEndDate", FPlanEndDate);//计划完工日期
			//jsonModel.Add("FBatch", current["FBatch"].ToString());//批次
			jsonModel.Add("FBatch", FLOT);//批次
			jsonModel.Add("FHOrderNeedQty", FQTY);// 订单需求数量
			jsonModel.Add("FPrdBillNo", FBILLNO); ;//源单编号
			jsonModel.Add("FPRDMOMAINID", FID); ;//源单主内码
			jsonModel.Add("FPRDMOENTYID", FENTRYID); ;//源单子内码
			jsonModel.Add("FMoFID", FID); ;//源单主内码
			jsonModel.Add("FMoFentryId", FENTRYID); ;//源单子内码
			jsonModel.Add("FOrderQuantity", Convert.ToString(current["FOrderQuantity"])); ;//生产订单数量
			jsonModel.Add("FDayPlanQuantity", Convert.ToString(current["FDayPlanQuantity"])); ;//日计划数量
			jsonModel.Add("FNoScheduled", Convert.ToString(current["FNoScheduled"])); ;//未排数量
			JObject jsonFHMaterID = new JObject();
			jsonFHMaterID.Add("FNumber", (current["FMatrailId"] as DynamicObject)["Number"].ToString());
			jsonModel.Add("FHMaterID", jsonFHMaterID);//FHMaterID 物料
			if (Convert.ToString(current["FORGID_Id"]) != "0")
			{
			JObject jsonFHPRDORGID = new JObject();
			jsonFHPRDORGID.Add("FNumber", (current["FORGID"] as DynamicObject)["Number"].ToString());
			jsonModel.Add("FHPRDORGID", jsonFHPRDORGID);//FHMaterID 生产组织

			}
			if (Convert.ToString(current["FResourcesId_Id"]) != "0")
			{
			JObject jsonFProductWorkShopId = new JObject();
			jsonFProductWorkShopId.Add("FNumber", (current["FResourcesId"] as DynamicObject)["Number"].ToString());
			jsonModel.Add("FHSourceID", jsonFProductWorkShopId);//FHSourceID 生产车间
			}
			if (Convert.ToString(current["FProductWorkShopId_Id"]) != "0")
			{
			JObject jsonFResourcesId = new JObject();
			jsonFResourcesId.Add("FNumber", (current["FProductWorkShopId"] as DynamicObject)["Number"].ToString());
			jsonModel.Add("FHWorkShopID", jsonFResourcesId);//FHWorkShopID 生产资源
			}
			JArray Entry = new JArray();
			for (int i = 0; i <= 60; i++)
			{
			if (Convert.ToString(current["FT" + "" + i + ""]) == "" \|\| Convert.ToString(current["FT" + "" + i + ""]) == "0")
			continue;
			JObject jsonFPOOrderEntry = new JObject();
			jsonFPOOrderEntry.Add("FHMasterDate", date.AddDays(i).ToShortDateString()); ;//主日期
			jsonFPOOrderEntry.Add("FHQty ", Convert.ToString(current["FT" + "" + i + ""])); ;//日计划数量
			Entry.Add(jsonFPOOrderEntry);
			}
			jsonModel.Add("FEntity", Entry);
			jsonRoot.Add("Model", jsonModel);
			CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
			var result = cloudClient.Save("Paez_Sc_WorkBillAutoSortBill", jsonRoot.ToString());
			JObject saveObj = JObject.Parse(result);
			string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
			if (saveIsSuc != "TRUE")
			{
			LogHelper.Error("生产计划平台保存失败:" + jsonRoot.ToString());
			this.View.ShowMessage("数据储存失败！请联系管理员！");
			}
			if (saveIsSuc == "TRUE")
			{
			string FDayPlanBillNo = saveObj["Result"]["Number"].ToString();
			string FDayPlanID = saveObj["Result"]["Id"].ToString();
			this.Model.SetValue("FDayPlanBillNo", FDayPlanBillNo, Convert.ToInt32(current["SEQ"]) - 1);//
			this.Model.SetValue("FDayPlanID", FDayPlanID, Convert.ToInt32(current["SEQ"]) - 1);//
			}
			}
			}

			int result = DBServiceHelper.ExecuteBatch(Context, sqlList);
			if (result > 0)
			{
			this.View.ShowMessage("操作成功");
			SearchList();
			}
			else
			this.View.ShowMessage("操作失败，联系管理员！");

			this.View.ShowMessage("操作成功");
			SearchList();
			}
			/// <summary>
			/// 齐套分析
			@@ -397,11 +640,12 @@
			// using Kingdee.BOS.KDThread;
			MainWorker.QuequeTask(() =>
			{
			var resuult = "";
			try
			{
			// 需要捕获错误，以确保处理结束时，关闭进度滚动界面
			// 引入功能实际处理函数
			this.CompleteSetAnalysis();
			resuult = this.CompleteSetAnalysisByDataTable();
			}
			finally
			{
			@@ -413,315 +657,59 @@
			{
			processView.Close();
			this.View.SendDynamicFormAction(processView);
			this.View.ShowMessage(resuult);
			}
			}
			},
			(t) => { });
			}
			public void COMPLETEMAIN()
			private void COMPLETEBOM()
			{
			//获取当前即时库存按照物料+货主+库存展现
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, @" /dialect/ select DISTINCT (a.FBASEQTY- ISNULL(FHUseQty,0)) as FBASEQTY,a.FMATERIALID,a.FStockOrgId,a.FOwnerId from T_STK_Inventory a
			left join
			(
			select FHMaterID,FHUseQty,FHStockOrgID,FOwnerId from JIT_MOMaterReadysBill
			where FIdentificat = 2
			) b on a.FMATERIALID=b.FHMaterID and a.FStockOrgId=b.FHStockOrgID and a.FOwnerId = b.FOwnerId
			order by FBASEQTY");
			ListInventory = ds.ToModelList<PRD_Inventory>();
			// 显示一个进度显示界面：显示一个不停滚动的模拟进度
			// bUseTruePro参数：是否显示真实的进度。
			// bUseTruePro = false ：
			// 显示一个不停滚动的模拟进度，与实际处理进度没有关联。
			// 此方案优点：实际处理代码无需计算进度
			// 此方案缺点：进度不准确，且进度页面不会自动关闭。
			// bUseTruePro = true: 进度界面显示真实进度
			// 此方案优点：进度真实
			// 此方案缺点：需要在处理代码中，不断的更新真实进度，更新语句
			// this.View.Session["ProcessRateValue"] = 100;
			// 特别说明，当进度更新到100时，进度界面会自动关闭
			// 本案例选用此方案
			var processForm = this.View.ShowProcessForm(
			new Action<FormResult>(t => { }),
			true,
			"正在生成，请稍候...");

			ds = DBServiceHelper.ExecuteDataSet(Context, @" /dialect/ select sum(FBASEQTY)FBASEQTY,FMATERIALID,FStockOrgId from
			(
			select DISTINCT (a.FBASEQTY- ISNULL(FHUseQty,0)) as FBASEQTY,a.FMATERIALID,a.FStockOrgId,a.FOwnerId from T_STK_Inventory a
			left join
			(
			select FHMaterID,FHUseQty,FHStockOrgID,FOwnerId from JIT_MOMaterReadysBill
			where FIdentificat = 2
			) b on a.FMATERIALID=b.FHMaterID and a.FStockOrgId=b.FHStockOrgID and a.FOwnerId = b.FOwnerId

			) TT
			group by FMATERIALID, FStockOrgId ");
			ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();

			//获取单据体信息
			Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
			//单据体信息转换为列表集合
			DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
			EntryGrid grid = this.View.GetControl<EntryGrid>("FEntity");

			if (entityDataObjoct.Count > 0)
			// 开启一个异步线程，处理引入功能
			// using Kingdee.BOS.KDThread;
			MainWorker.QuequeTask(() =>
			{
			int m = 0;

			//删除齐套数量
			foreach (DynamicObject current in entityDataObjoct)
			var resuult = "";
			try
			{
			//FDayPlanWorkID日计划工单ID去删除现有的齐套分析数据
			DBServiceHelper.Execute(Context, "/dialect/delete JIT_MOMaterReadysBill where FHICMOInterID = '" + current["FDayPlanWorkID"].ToString() + "'");
			// 需要捕获错误，以确保处理结束时，关闭进度滚动界面
			// 引入功能实际处理函数
			resuult = this.CompleteSetAnalysisByDataTableBom();
			}

			foreach (DynamicObject current in entityDataObjoct)
			finally
			{
			//计划总数量
			decimal SumPlan = 0;
			for (int i = 0; i <= 60; i++)
			// 确保标记进度已经到达100%
			this.View.Session["ProcessRateValue"] = 100;
			// 引入完毕，关闭进度显示页面
			var processView = this.View.GetView(processForm.PageId);
			if (processView != null)
			{
			SumPlan += Convert.ToDecimal(current["FT" + "" + i + ""]);
			processView.Close();
			this.View.SendDynamicFormAction(processView);
			this.View.ShowMessage(resuult);
			}

			double Sum = 100;
			Sum = Convert.ToDouble(SumGetComplete(current["FMatrailId_Id"].ToString(), current["FHMainSourceInterID"].ToString(), current["FHMainSourceEntryID"].ToString(), current["FDayPlanWorkID"].ToString(), SumPlan, current["FORGID_Id"].ToString()));
			this.View.Model.SetValue("FCompleteSetCount", Sum, m);
			this.View.UpdateView("FCompleteSetCount");
			//保存齐套数
			DBServiceHelper.Execute(Context, "/dialect/ update Sc_WorkBillSortBillMain set FCompleteCount='" + Sum + "',FDayPlanQuantity='" + SumPlan + "' where FID=" + current["FDayPlanWorkID"].ToString());
			for (int i = 0; i <= 60; i++)
			{
			this.View.GetFieldEditor("FT" + i.ToString(), m).Enabled = false; //单据体行锁定字段
			Sum = Sum - Convert.ToDouble(current["FT" + "" + i + ""]);
			if (Sum >= 0)
			{

			grid.SetForecolor("FT" + "" + i + "", "#00FF00", m);
			}
			else
			{
			grid.SetForecolor("FT" + "" + i + "", "#FF0000", m);
			}

			}
			m++;
			//grid = this.View.GetControl[EntryGrid]("FSaleOrderEntry")#需要设置的单据体标识Key
			//grid.SetRowBackcolor("#FFFF00", 0)#设置整行背景颜色
			//grid.SetForecolor("FMaterialName", "#FF0000", 0)#需要设置字段标识Key[/code]
			// grid.SetBackcolor("FT" + "" + i + "", "#FF0000", m);

			//this.View.Session["ProcessRateValue"] = Convert.ToInt32(this.View.Session["ProcessRateValue"]) + Convert.ToInt32(1 / entityDataObjoct.Count * 90);

			}

			}
			else
			{
			this.View.ShowMessage("请先加载数据！");
			}

			},
			(t) => { });
			}
			/// <summary>
			/// 计算最大齐套数量
			/// </summary>
			/// <param name="FMATERIALID"> 物料Number</param>
			/// <param name="FMainInterID"> 生产订单主码</param>
			/// <param name="FMainEntryID"> 生产订单子码</param>
			/// <param name="FDayPlanWorkID"> 日计划工单FID</param>
			/// <param name="SumPlan"> 计划总数量</param>
			/// <param name="FStockOrgId"> 库存组织</param>
			/// <returns></returns>
			public string SumGetComplete(string FMATERIALID, string FMainInterID, string FMainEntryID, string FDayPlanWorkID, decimal SumPlan, string FStockOrgId)
			{
			//FDayPlanWorkID日计划工单ID去删除现有的齐套分析数据
			DBServiceHelper.Execute(Context, "/dialect/delete JIT_MOMaterReadysBill where FHICMOInterID = '" + FDayPlanWorkID + "'");

			#region 数据库直接算出所以需要数据字段
			/*
			--生产用料清单列表
			SELECT T1.FID,T1.FBillNo,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,
			T2.FMATERIALID FMATERIALID2,T4.FNumber,T2.FNeedQty,t3.FBASEQTY,convert(decimal(18,3),FNeedQty/t1.FQty)UnitDosage,
			floor(t3.FBASEQTY/convert(decimal(18,3),FNeedQty/t1.FQty)) SumGetComplete
			FROM T_PRD_PPBOM T1
			LEFT JOIN (select FID,MAX(FENTRYID)FENTRYID,SUM(FNeedQty)FNeedQty,FMATERIALID from T_PRD_PPBOMENTRY where FMoId='100007'
			group by FMATERIALID,FID ) T2 on T1.FID=t2.FID
			LEFT JOIN T_STK_Inventory T3 on t2.FMATERIALID = t3.FMATERIALID
			LEFT JOIN T_BD_MATERIAL T4 on T2.FMATERIALID=T4.FMATERIALID
			where t1.FMoId='100007' and T1.FMaterialID='105771'
			*/
			#endregion

			string sql = string.Format(@"
			/dialect/
			--生产用料清单列表
			SELECT T1.FID,T1.FBillNo,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,
			T2.FMATERIALID FMATERIALID2,T4.FNumber,T2.FNeedQty
			--,isnull(t3.FBASEQTY,0)FBASEQTY
			FROM T_PRD_PPBOM T1
			LEFT JOIN (select FID,MAX(FENTRYID)FENTRYID,SUM(FNeedQty)FNeedQty,FMATERIALID from T_PRD_PPBOMENTRY where FMoId='{0}'
			group by FMATERIALID,FID ) T2 on T1.FID=t2.FID
			--LEFT JOIN T_STK_Inventory T3 on t2.FMATERIALID = t3.FMATERIALID
			LEFT JOIN T_BD_MATERIAL T4 on T2.FMATERIALID=T4.FMATERIALID
			where t1.FMoId='{0}' and T1.FMaterialID='{1}'
			", FMainInterID, FMATERIALID);
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			var PpbomList = ds.ToModelList<PRD_PPBOM>();
			//当前最大齐套数下层需求数量/父级需求数量=单位用料
			//var SumGetComplete = Math.Floor(PpbomList.Min(t => t.FBASEQTY / (t.FNeedQty / t.FQty)));

			//最大齐套数
			decimal SumGetComplete;
			List<decimal> list = new List<decimal>();
			foreach (var t in PpbomList)
			{
			var ls = ListInventoryByStockOrgId.Where(c => c.FMATERIALID == t.FMATERIALID2 && c.FStockOrgId == FStockOrgId).FirstOrDefault();
			if (ls == null)
			{
			list.Add(0);
			continue;
			}

			SumGetComplete = Math.Floor(ls.FBASEQTY / (t.FNeedQty / t.FQty));
			list.Add(SumGetComplete);
			}
			//没有物料的库存信息
			SumGetComplete = list.Min();

			if (SumGetComplete > SumPlan)//系统可生产最大齐套数大于计划需求量时，取计划
			SumGetComplete = SumPlan;
			foreach (var item in PpbomList)
			{
			decimal jskc = 0;
			var ls = ListInventoryByStockOrgId.Where(c => c.FMATERIALID == item.FMATERIALID2 && c.FStockOrgId == FStockOrgId).FirstOrDefault();
			if (ls != null)
			jskc = ls.FBASEQTY;
			/*
			及时库存数量 = 系统现有库存
			可用数量 = 及时库存数量
			数量字段 = 齐套量 * 单位用料
			*/
			decimal UnitDosage = item.FNeedQty / item.FQty;//单位用量
			decimal xhsl = SumGetComplete * (UnitDosage);///消耗数量

			JObject _jsonRoot = new JObject();
			_jsonRoot.Add("Creator", "");
			_jsonRoot.Add("NeedUpDateFields", new JArray());
			_jsonRoot.Add("NeedReturnFields", new JArray());
			_jsonRoot.Add("IsDeleteEntry", "true");
			_jsonRoot.Add("SubSystemId", "");
			_jsonRoot.Add("IsVerifyBaseDataField", "");
			JObject _jsonModel = new JObject();
			_jsonModel.Add("FHMainICMOInterIDr", FMainInterID);//主生产订单主内码
			_jsonModel.Add("FHMainICMOEntryID", FMainEntryID);//主生产订单主内码
			_jsonModel.Add("FHICMOInterID", FDayPlanWorkID);//日计划订单主内码

			JObject _HMaterID = new JObject();
			_HMaterID.Add("FNumber", item.FNumber);
			_jsonModel.Add("FHMaterID", _HMaterID);//FHMaterID 物料

			_jsonModel.Add("FHStockQty", Convert.ToDecimal(jskc));//及时库存数量
			_jsonModel.Add("FHUseQty", Convert.ToDecimal(xhsl));//数量
			_jsonModel.Add("FHLeftQty", Convert.ToDecimal(jskc));//可用数量
			_jsonModel.Add("FUnitDosage", Convert.ToDecimal(UnitDosage));//单位用量 .

			_jsonModel.Add("FSumPlanCount", Convert.ToDecimal(SumPlan));//FSumPlanCount 计划总数量
			_jsonModel.Add("FCompleteCount", Convert.ToDecimal(SumGetComplete));//FCompleteCount 齐套数量
			_jsonModel.Add("FPRDBILLNO", item.FMOBillNO);//FPRDBILLNO 工单编号
			_jsonModel.Add("FIdentificat", "1");//标识

			_jsonRoot.Add("Model", _jsonModel);

			CloudClient _cloudClient = new CloudClient("http://localhost/K3Cloud/");
			var _result = _cloudClient.Save("paez_CompleteAnalysisTemp", _jsonRoot.ToString());
			JObject _saveObj = JObject.Parse(_result);
			string _saveIsSuc = _saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();

			if (_saveIsSuc != "TRUE")
			{
			this.View.ShowMessage("操作失败，联系管理员！");
			}

			//扣除总库存的数量

			if (ls != null)
			ls.FBASEQTY -= xhsl;



			List<PRD_Inventory> _ListInventory = ListInventory.Where(c => c.FMATERIALID == item.FMATERIALID2 && c.FStockOrgId == FStockOrgId && c.FBASEQTY > 0).ToList();
			foreach (var Inventory in _ListInventory)
			{
			//扣除库存数量
			// Inventory.FBASEQTY;
			if (xhsl <= 0)
			break;

			// var _ls = ListInventory.Where(c => c.FMATERIALID == item.FMATERIALID2).DefaultIfEmpty();
			JObject jsonRoot = new JObject();
			jsonRoot.Add("Creator", "");
			jsonRoot.Add("NeedUpDateFields", new JArray());
			jsonRoot.Add("NeedReturnFields", new JArray());
			jsonRoot.Add("IsDeleteEntry", "true");
			jsonRoot.Add("SubSystemId", "");
			jsonRoot.Add("IsVerifyBaseDataField", "");
			JObject jsonModel = new JObject();
			jsonModel.Add("FHMainICMOInterIDr", FMainInterID);//主生产订单主内码
			jsonModel.Add("FHMainICMOEntryID", FMainEntryID);//主生产订单主内码
			jsonModel.Add("FHICMOInterID", FDayPlanWorkID);//日计划订单主内码

			JObject HMaterID = new JObject();
			HMaterID.Add("FNumber", item.FNumber);
			jsonModel.Add("FHMaterID", HMaterID);//FHMaterID 物料


			DataTable dt = DBServiceHelper.ExecuteDataSet(Context, @"
			select FNUMBER
			from T_ORG_Organizations where FORGID='" + FStockOrgId + "'").Tables[0];
			JObject FHStockOrgID = new JObject();
			FHStockOrgID.Add("FNumber", dt.Rows[0]["FNUMBER"].ToString());
			jsonModel.Add("FHStockOrgID", FHStockOrgID);//FHStockOrgID 库存组织

			jsonModel.Add("FOwnerTypeId", "BD_OwnerOrg");//FHStockOrgID 货主类型

			dt = DBServiceHelper.ExecuteDataSet(Context, @"
			select FNUMBER
			from T_ORG_Organizations where FORGID='" + Inventory.FOwnerId + "'").Tables[0];

			JObject FOwnerId = new JObject();
			FOwnerId.Add("FNumber", dt.Rows[0]["FNUMBER"].ToString());
			jsonModel.Add("FOwnerId", FOwnerId);//FOwnerId 货主

			jsonModel.Add("FHStockQty", Convert.ToDecimal(Inventory.FBASEQTY));//及时库存数量
			jsonModel.Add("FHUseQty", Convert.ToDecimal(xhsl > Inventory.FBASEQTY ? Inventory.FBASEQTY : xhsl));//数量
			jsonModel.Add("FHLeftQty", Convert.ToDecimal(Inventory.FBASEQTY));//可用数量
			jsonModel.Add("FUnitDosage", Convert.ToDecimal(UnitDosage));//单位用量 .

			jsonModel.Add("FSumPlanCount", Convert.ToDecimal(SumPlan));//FSumPlanCount 计划总数量
			jsonModel.Add("FCompleteCount", Convert.ToDecimal(SumGetComplete));//FCompleteCount 齐套数量
			jsonModel.Add("FPRDBILLNO", item.FMOBillNO);//FPRDBILLNO 工单编号
			jsonModel.Add("FIdentificat", "2");//标识


			jsonRoot.Add("Model", jsonModel);

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

			if (saveIsSuc != "TRUE")
			{
			this.View.ShowMessage("操作失败，联系管理员！");
			}


			if (xhsl >= Inventory.FBASEQTY)
			{
			xhsl = xhsl - Inventory.FBASEQTY;
			Inventory.FBASEQTY = 0;

			}
			else
			{
			Inventory.FBASEQTY -= xhsl;
			xhsl = 0;
			}





			}

			}
			return SumGetComplete.ToString();
			}
			/// <summary>
			/// 齐套分析
			/// </summary>
			@@ -731,6 +719,7 @@
			{
			Stopwatch sw = new Stopwatch();
			sw.Start();//开始计时
			LogHelper.Info("齐套分析开始准备数据：" + sw.Elapsed);
			//清空齐套临时表
			DBServiceHelper.Execute(Context, "/dialect/ delete JIT_MOMaterReadysBill ");
			//更新状态
			@@ -750,6 +739,8 @@
			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
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			");
			ListInventory = ds.ToModelList<PRD_Inventory>();
			@@ -767,24 +758,28 @@
			) 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
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			group by T1.FStockOrgId,T1.FMATERIALID
			");
			ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();
			//需要齐套分析的数据
			string sql = @"
			/dialect/
			/dialect/
			select a.FPRDMOMAINID,a.FPRDMOENTYID,a.FID,b.FEntryID,a.FHPRDORGID FStockOrgId,t5.FNUMBER as OrgFnumber,a.FHOrderLev,b.FHQTY,b.FHMASTERDATE,T1.FBillNo,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,
			T2.FMATERIALID FMATERIALID2, T4.FNumber,T2.FNeedQty,FNeedQty/FQty dwyl,(FHQTY-ISNULL(FProductNum,0))*(FNeedQty/FQty) PlanCount from SC_WORKBILLSORTBILLMAIN a
			T2.FMATERIALID FMATERIALID2, T4.FNumber,T2.FNeedQty,FNeedQty/FQty dwyl,(FHQTY-ISNULL(FProductNum,0))*(FNeedQty/FQty) PlanCount,TBase.FErpClsID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID, MAX(FENTRYID) FENTRYID, SUM(FNeedQty) FNeedQty, FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID, FID ) T2 on T1.FID = t2.FID
			--LEFT JOIN T_STK_Inventory T3 on t2.FMATERIALID = t3.FMATERIALID
			JOIN T_BD_MATERIAL T4 on T2.FMATERIALID = T4.FMATERIALID
			JOIN t_BD_MaterialBase TBase on T2.FMATERIALID = TBase.FMATERIALID
			JOIN T_ORG_Organizations t5 on a.FHPRDORGID = t5.FORGID
			--条件为今天往后的日计划 + 今天之前未关闭的日计划
			where (FHEntryCloseDate is null and DATEDIFF(D,GETDATE(),FHMASTERDATE)<0)or DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0
			and b.FHQTY>0
			ORDER BY b.FHMASTERDATE,a.FHOrderLev
			";
			ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			@@ -843,11 +838,261 @@
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount = fCompleteCount, //齐套数量
			FCompleteCount1 = fCompleteCount, //齐套数量
			FLackCount = _fLackCount,//缺料数量
			FHStockQty = sjkcList.FBASEQTY,//即时库存
			FHLeftQty = Inventory.FBASEQTY,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			FErpClsID = _item.FErpClsID,
			/* 2021 1.26 更改为need
			FComPlete = sjkcList.FBASEQTY >= _item.PlanCount ? "齐套" : "未齐套",
			*/
			FComPlete = sjkcList.FBASEQTY >= need ? "齐套" : "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			}); ;
			//扣减总库存数量
			sjkcList.FBASEQTY = sjkcList.FBASEQTY >= fCompleteCount ? sjkcList.FBASEQTY - fCompleteCount : 0;
			//剩余日计划需求数量
			need = need >= Inventory.FBASEQTY ? need - Inventory.FBASEQTY : 0;
			//扣减消耗库存
			Inventory.FBASEQTY = Inventory.FBASEQTY - fCompleteCount;
			}
			}
			else
			{
			decimal occupyMaterial = 0;
			if (occupyDic.ContainsKey(_item.FMATERIALID2))
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FNumber,
			FHStockOrgID = _item.OrgFnumber,
			FHPRDORGID = _item.OrgFnumber,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount = 0, //齐套数量
			FCompleteCount1 = 0, //齐套数量
			FLackCount = _item.PlanCount,//缺料数量
			FHStockQty = 0,//即时库存
			FHLeftQty = 0,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			FComPlete = "未齐套",
			FPlanDate = item.FHMASTERDATE, // 日计划日期
			FErpClsID = _item.FErpClsID

			});
			}
			}
			//Thread.Sleep(100);
			// this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(40) / DatePlanList.Count) * i);
			i++;

			}
			LogHelper.Info($"齐套分析，数据准备完成，保存到Model实体，总行数：{completeAnalysisTempModel.Count}，耗时：" + sw.Elapsed);
			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());
			jsonRoot.Add("NeedReturnFields", new JArray());
			jsonRoot.Add("IsDeleteEntry", "true");
			jsonRoot.Add("SubSystemId", "");
			jsonRoot.Add("IsVerifyBaseDataField", "");
			JObject jsonModel = new JObject();
			jsonModel.Add("FHMainICMOInterIDr", item.FHMainICMOInterIDr);
			jsonModel.Add("FHMainICMOEntryID", item.FHMainICMOEntryID);
			jsonModel.Add("FHICMOInterID", item.FHICMOInterID);
			jsonModel.Add("FHICMOEntryID", item.FHICMOEntryID);
			jsonModel.Add("FHMaterID", new JObject() { ["FNUMBER"] = item.FHMaterID });
			jsonModel.Add("FHUseQty", item.FHUseQty);
			jsonModel.Add("FHStockOrgID", new JObject() { ["FNUMBER"] = item.FHStockOrgID });
			jsonModel.Add("FHStockQty", item.FHStockQty);
			jsonModel.Add("FHLeftQty", item.FHLeftQty);
			jsonModel.Add("FHPRDORGID", new JObject() { ["FNUMBER"] = item.FHStockOrgID });
			jsonModel.Add("FUnitDosage", item.FUnitDosage);
			jsonModel.Add("FSumPlanCount", item.FSumPlanCount);
			jsonModel.Add("FCompleteCount", item.FCompleteCount);
			jsonModel.Add("FCompleteCount1", item.FCompleteCount1);
			jsonModel.Add("FPRDBillNo", item.FPRDBillNo);
			jsonModel.Add("FOwnerTypeId", item.FOwnerTypeId);
			jsonModel.Add("FComPlete", item.FComPlete);
			jsonModel.Add("FLackCount", item.FLackCount);
			jsonModel.Add("FOccupyCount", item.FOccupyCount);
			jsonModel.Add("FPlanDate", item.FPlanDate);
			jsonModel.Add("FErpClsID", item.FErpClsID);
			if (item.FOwnerId != null)
			jsonModel.Add("FOwnerId", new JObject() { ["FNUMBER"] = item.FOwnerId });
			jsonRoot.Add("Model", jsonModel);
			CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
			var result = cloudClient.Save("paez_CompleteAnalysisTemp", jsonRoot.ToString());
			JObject saveObj = JObject.Parse(result);
			string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
			if (saveIsSuc != "TRUE")
			{
			LogHelper.Error(jsonRoot.ToString());
			}
			this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(100) / completeAnalysisTempModel.Count) * i);
			i++;
			}
			//执行完成后更新日计划工单状态
			DBServiceHelper.Execute(Context, @"
			/dialect/update Sc_WorkBillSortBillSub set FComplete = '未齐套' where FEntryID IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBill where isnull(FCOMPLETE,'未齐套') ='未齐套')
			");
			DBServiceHelper.Execute(Context, @"
			/dialect/update Sc_WorkBillSortBillSub set FComplete = '齐套' where FEntryID NOT IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBill where isnull(FCOMPLETE,'未齐套') ='未齐套')
			");
			sw.Stop();//结束计时
			LogHelper.Info("齐套分析运行总时长：" + sw.Elapsed);
			}
			catch (Exception ex)
			{
			LogHelper.Error("齐套分析跳出：" + ex.Message.ToString());
			}
			}
			public void CompleteSetAnalysisBatch()
			{
			LogHelper.Info("齐套分析批量开始准备数据：");
			try
			{
			Stopwatch sw = new Stopwatch();
			sw.Start();//开始计时
			LogHelper.Info("齐套分析开始准备数据：" + sw.Elapsed);
			//清空齐套临时表
			DBServiceHelper.Execute(Context, "/dialect/ delete JIT_MOMaterReadysBill ");
			//更新状态
			DBServiceHelper.Execute(Context, "/dialect/ update Sc_WorkBillSortBillsub set FCOMPLETE='' ");
			//获取当前即时库存按照物料+库存组织+货主+库存数量
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			select isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0) FBASEQTY,T1.FStockOrgId,T1.FMATERIALID,a.FOWNERID,c.FNUMBER from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) 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 and a.FOwnerId = b.FOwnerId
			LEFT join T_ORG_Organizations c on a.FOWNERID = c.FORGID
			--join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			--where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			");
			ListInventory = ds.ToModelList<PRD_Inventory>();
			//总库存物料+库存组织+库存数量
			ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			select sum(isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0))FBASEQTY,T1.FStockOrgId,T1.FMATERIALID from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) 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)
			--join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			--where d.FAvailableComplete<>0
			group by T1.FStockOrgId,T1.FMATERIALID
			");
			ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();
			//需要齐套分析的数据
			string sql = @"
			/dialect/
			select a.FPRDMOMAINID,a.FPRDMOENTYID,a.FID,b.FEntryID,a.FHPRDORGID FStockOrgId,t5.FNUMBER as OrgFnumber,a.FHOrderLev,b.FHQTY,b.FHMASTERDATE,T1.FBillNo,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,
			T2.FMATERIALID FMATERIALID2, T4.FNumber,T2.FNeedQty,FNeedQty/FQty dwyl,(FHQTY-ISNULL(FProductNum,0))*(FNeedQty/FQty) PlanCount,TBase.FErpClsID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID, MAX(FENTRYID) FENTRYID, SUM(FNeedQty) FNeedQty, FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID, FID ) T2 on T1.FID = t2.FID
			--LEFT JOIN T_STK_Inventory T3 on t2.FMATERIALID = t3.FMATERIALID
			JOIN T_BD_MATERIAL T4 on T2.FMATERIALID = T4.FMATERIALID
			JOIN t_BD_MaterialBase TBase on T2.FMATERIALID = TBase.FMATERIALID
			JOIN T_ORG_Organizations t5 on a.FHPRDORGID = t5.FORGID
			--条件为今天往后的日计划 + 今天之前未关闭的日计划
			where (FHEntryCloseDate is null and DATEDIFF(D,GETDATE(),FHMASTERDATE)<0)or DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0
			and b.FHQTY>0
			ORDER BY b.FHMASTERDATE,a.FHOrderLev
			";
			ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			List<PRD_PPBOM> BomList = ds.ToModelList<PRD_PPBOM>();
			//日计划+生产订单子表编码ID
			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;
			//创建字典用于储存物料 + 占用数量
			Dictionary<string, decimal> occupyDic = new Dictionary<string, decimal>();
			foreach (var item in DatePlanList)
			{
			//筛选出当日计划数据
			var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();
			foreach (var _item in _BomList)
			{
			//该日计划物料需要数
			decimal need = _item.PlanCount;
			var sjkcList = ListInventoryByStockOrgId.Where(x => x.FMATERIALID == _item.FMATERIALID2 && x.FStockOrgId == _item.FStockOrgId).FirstOrDefault();
			//真正需要取计算的数量（拆分货主）
			//货主匹配
			List<PRD_Inventory> _ListInventory = ListInventory.Where(c => c.FMATERIALID == _item.FMATERIALID2 && c.FStockOrgId == _item.FStockOrgId && c.FBASEQTY > 0).ToList();
			if (_ListInventory.Count > 0)
			{
			decimal _fLackCount = _item.PlanCount > sjkcList.FBASEQTY ? (_item.PlanCount - sjkcList.FBASEQTY) : 0;//缺料数量
			foreach (var Inventory in _ListInventory)
			{

			if (need == 0)
			break;
			decimal fCompleteCount = need >= Inventory.FBASEQTY ? Inventory.FBASEQTY : need;//齐套数量
			decimal occupyMaterial = 0;
			if (!occupyDic.ContainsKey(_item.FMATERIALID2))
			{
			occupyDic.Add(_item.FMATERIALID2, fCompleteCount);
			}
			else
			{
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			occupyDic[_item.FMATERIALID2] = occupyMaterial + fCompleteCount;
			}
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FNumber,
			FHStockOrgID = _item.OrgFnumber,
			FHPRDORGID = _item.OrgFnumber,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FOwnerId = Inventory.Fnumber,
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount = fCompleteCount, //齐套数量
			FCompleteCount1 = fCompleteCount, //齐套数量
			FLackCount = _fLackCount,//缺料数量
			FHStockQty = sjkcList.FBASEQTY,//即时库存
			FHLeftQty = Inventory.FBASEQTY,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			FErpClsID = _item.FErpClsID,
			/* 2021 1.26 更改为need
			FComPlete = sjkcList.FBASEQTY >= _item.PlanCount ? "齐套" : "未齐套",
			*/
			FComPlete = sjkcList.FBASEQTY >= need ? "齐套" : "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			});
			//扣减总库存数量
			@@ -876,7 +1121,9 @@
			FOwnerTypeId = "BD_OwnerOrg",
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FErpClsID = _item.FErpClsID,
			FCompleteCount = 0, //齐套数量
			FCompleteCount1 = 0, //齐套数量
			FLackCount = _item.PlanCount,//缺料数量
			FHStockQty = 0,//即时库存
			FHLeftQty = 0,//可用数量
			@@ -887,53 +1134,67 @@
			}
			}
			//Thread.Sleep(100);
			this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(40) / DatePlanList.Count) * i);
			// this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(40) / DatePlanList.Count) * i);
			i++;

			}
			LogHelper.Info($"齐套分析，数据准备完成，保存到Model实体，总行数：{completeAnalysisTempModel.Count}，耗时：" + sw.Elapsed);
			i = 1;


			JArray Fentity = new JArray();
			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());
			jsonRoot.Add("NeedReturnFields", new JArray());
			jsonRoot.Add("IsDeleteEntry", "true");
			jsonRoot.Add("SubSystemId", "");
			jsonRoot.Add("IsVerifyBaseDataField", "");
			JObject jsonModel = new JObject();
			jsonModel.Add("FHMainICMOInterIDr", item.FHMainICMOInterIDr);
			jsonModel.Add("FHMainICMOEntryID", item.FHMainICMOEntryID);
			jsonModel.Add("FHICMOInterID", item.FHICMOInterID);
			jsonModel.Add("FHICMOEntryID", item.FHICMOEntryID);
			jsonModel.Add("FHMaterID", new JObject() { ["FNUMBER"] = item.FHMaterID });
			jsonModel.Add("FHUseQty", item.FHUseQty);
			jsonModel.Add("FHStockOrgID", new JObject() { ["FNUMBER"] = item.FHStockOrgID });
			jsonModel.Add("FHStockQty", item.FHStockQty);
			jsonModel.Add("FHLeftQty", item.FHLeftQty);
			jsonModel.Add("FHPRDORGID", new JObject() { ["FNUMBER"] = item.FHStockOrgID });
			jsonModel.Add("FUnitDosage", item.FUnitDosage);
			jsonModel.Add("FSumPlanCount", item.FSumPlanCount);
			jsonModel.Add("FCompleteCount", item.FCompleteCount);
			jsonModel.Add("FPRDBillNo", item.FPRDBillNo);
			jsonModel.Add("FOwnerTypeId", item.FOwnerTypeId);
			jsonModel.Add("FComPlete", item.FComPlete);
			jsonModel.Add("FLackCount", item.FLackCount);
			jsonModel.Add("FOccupyCount", item.FOccupyCount);
			jsonModel.Add("FPlanDate", item.FPlanDate);
			JObject FBatchModel = new JObject();
			FBatchModel.Add("FHMainICMOInterIDr", item.FHMainICMOInterIDr);
			FBatchModel.Add("FHMainICMOEntryID", item.FHMainICMOEntryID);
			FBatchModel.Add("FHICMOInterID", item.FHICMOInterID);
			FBatchModel.Add("FHICMOEntryID", item.FHICMOEntryID);
			FBatchModel.Add("FHMaterID", new JObject() { ["FNUMBER"] = item.FHMaterID });
			FBatchModel.Add("FHUseQty", item.FHUseQty);
			FBatchModel.Add("FHStockOrgID", new JObject() { ["FNUMBER"] = item.FHStockOrgID });
			FBatchModel.Add("FHStockQty", item.FHStockQty);
			FBatchModel.Add("FHLeftQty", item.FHLeftQty);
			FBatchModel.Add("FHPRDORGID", new JObject() { ["FNUMBER"] = item.FHStockOrgID });
			FBatchModel.Add("FUnitDosage", item.FUnitDosage);
			FBatchModel.Add("FSumPlanCount", item.FSumPlanCount);
			FBatchModel.Add("FCompleteCount", item.FCompleteCount);
			FBatchModel.Add("FCompleteCount1", item.FCompleteCount1);
			FBatchModel.Add("FPRDBillNo", item.FPRDBillNo);
			FBatchModel.Add("FOwnerTypeId", item.FOwnerTypeId);
			FBatchModel.Add("FComPlete", item.FComPlete);
			FBatchModel.Add("FLackCount", item.FLackCount);
			FBatchModel.Add("FOccupyCount", item.FOccupyCount);
			FBatchModel.Add("FPlanDate", item.FPlanDate);
			FBatchModel.Add("FErpClsID", item.FErpClsID);
			if (item.FOwnerId != null)
			jsonModel.Add("FOwnerId", new JObject() { ["FNUMBER"] = item.FOwnerId });
			jsonRoot.Add("Model", jsonModel);
			CloudClient cloudClient = new CloudClient("http://localhost/K3Cloud/");
			var result = cloudClient.Save("paez_CompleteAnalysisTemp", jsonRoot.ToString());
			JObject saveObj = JObject.Parse(result);
			string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
			if (saveIsSuc != "TRUE")
			FBatchModel.Add("FOwnerId", new JObject() { ["FNUMBER"] = item.FOwnerId });
			Fentity.Add(FBatchModel);
			if ((i >= 20 \|\| i == completeAnalysisTempModel.Count) && (i % 20 == 0 \|\| i == completeAnalysisTempModel.Count))
			{
			LogHelper.Error(jsonRoot.ToString());
			LogHelper.Info("齐套分析批量执行，记录循环的当前条数" + i);
			JObject jsonRoot = new JObject()
			{
			["Creator"] = "",
			["NeedUpDateFields"] = new JArray(),
			["NeedReturnFields"] = new JArray(),
			["IsDeleteEntry"] = "false",
			["SubSystemId"] = "",
			["IsVerifyBaseDataField"] = "false",
			["Model"] = Fentity
			};
			CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
			var result = cloudClient.BatchSave("paez_CompleteAnalysisTemp", jsonRoot.ToString());
			JObject saveObj = JObject.Parse(result);
			string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
			if (saveIsSuc != "TRUE")
			{
			LogHelper.Error(jsonRoot.ToString());
			}
			Fentity = new JArray();
			}
			this.View.Session["ProcessRateValue"] = 40 + Convert.ToInt32((Convert.ToDecimal(60) / completeAnalysisTempModel.Count) * i);

			this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(100) / completeAnalysisTempModel.Count) * i);
			i++;
			}
			//执行完成后更新日计划工单状态
			@@ -944,13 +1205,987 @@
			/dialect/update Sc_WorkBillSortBillSub set FComplete = '齐套' where FEntryID NOT IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBill where isnull(FCOMPLETE,'未齐套') ='未齐套')
			");
			sw.Stop();//结束计时
			LogHelper.Info("运行总时长：" + sw.Elapsed);
			LogHelper.Info("齐套分析运行总时长：" + sw.Elapsed);
			}
			catch (Exception ex)
			{
			LogHelper.Error(ex.Message.ToString());
			LogHelper.Error("齐套分析跳出：" + ex.Message.ToString());
			}
			}
			public void CompleteSetAnalysisBySQL()
			{
			LogHelper.Info("齐套分析sql模式开始准备数据：");
			string sql = "";
			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/
			select isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0) FBASEQTY,T1.FStockOrgId,T1.FMATERIALID,a.FOWNERID,c.FNUMBER from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) 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 and a.FOwnerId = b.FOwnerId
			LEFT join T_ORG_Organizations c on a.FOWNERID = c.FORGID
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			");
			ListInventory = ds.ToModelList<PRD_Inventory>();
			//总库存物料+库存组织+库存数量
			ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			select sum(isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0))FBASEQTY,T1.FStockOrgId,T1.FMATERIALID from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) 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
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			group by T1.FStockOrgId,T1.FMATERIALID
			");
			ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();
			//需要齐套分析的数据
			sql = @"
			/dialect/
			select a.FPRDMOMAINID,a.FPRDMOENTYID,a.FID,b.FEntryID,a.FHPRDORGID FStockOrgId,t5.FNUMBER as OrgFnumber,a.FHOrderLev,b.FHQTY,b.FHMASTERDATE,T1.FBillNo,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,
			T2.FMATERIALID FMATERIALID2, T4.FNumber,T2.FNeedQty,FNeedQty/FQty dwyl,(FHQTY-ISNULL(FProductNum,0))*(FNeedQty/FQty) PlanCount,TBase.FErpClsID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID, MAX(FENTRYID) FENTRYID, SUM(FNeedQty) FNeedQty, FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID, FID ) T2 on T1.FID = t2.FID
			--LEFT JOIN T_STK_Inventory T3 on t2.FMATERIALID = t3.FMATERIALID
			JOIN T_BD_MATERIAL T4 on T2.FMATERIALID = T4.FMATERIALID
			JOIN t_BD_MaterialBase TBase on T2.FMATERIALID = TBase.FMATERIALID
			JOIN T_ORG_Organizations t5 on a.FHPRDORGID = t5.FORGID
			--条件为今天往后的日计划 + 今天之前未关闭的日计划
			where (FHEntryCloseDate is null and DATEDIFF(D,GETDATE(),FHMASTERDATE)<0)or DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0
			and b.FHQTY>0
			ORDER BY b.FHMASTERDATE,a.FHOrderLev
			";
			ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			List<PRD_PPBOM> BomList = ds.ToModelList<PRD_PPBOM>();
			//日计划+生产订单子表编码ID
			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;
			//创建字典用于储存物料 + 占用数量
			Dictionary<string, decimal> occupyDic = new Dictionary<string, decimal>();
			LogHelper.Info("齐套分析准备数据完成：" + sw.Elapsed);
			foreach (var item in DatePlanList)
			{
			//筛选出当日计划数据
			var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();
			foreach (var _item in _BomList)
			{
			//该日计划物料需要数
			decimal need = _item.PlanCount;
			var sjkcList = ListInventoryByStockOrgId.Where(x => x.FMATERIALID == _item.FMATERIALID2 && x.FStockOrgId == _item.FStockOrgId).FirstOrDefault();
			//真正需要取计算的数量（拆分货主）
			//货主匹配
			List<PRD_Inventory> _ListInventory = ListInventory.Where(c => c.FMATERIALID == _item.FMATERIALID2 && c.FStockOrgId == _item.FStockOrgId && c.FBASEQTY > 0).ToList();
			if (_ListInventory.Count > 0)
			{
			decimal _fLackCount = _item.PlanCount > sjkcList.FBASEQTY ? (_item.PlanCount - sjkcList.FBASEQTY) : 0;//缺料数量
			foreach (var Inventory in _ListInventory)
			{
			if (need == 0)
			break;
			decimal fCompleteCount = need >= Inventory.FBASEQTY ? Inventory.FBASEQTY : need;//齐套数量
			decimal occupyMaterial = 0;
			if (!occupyDic.ContainsKey(_item.FMATERIALID2))
			{
			occupyDic.Add(_item.FMATERIALID2, fCompleteCount);
			}
			else
			{
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			occupyDic[_item.FMATERIALID2] = occupyMaterial + fCompleteCount;
			}
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FMATERIALID2,
			FHStockOrgID = _item.FStockOrgId,
			FHPRDORGID = _item.FStockOrgId,
			FErpClsID = _item.FErpClsID,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FOwnerId = Inventory.FOwnerId,
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount1 = fCompleteCount, //齐套数量
			FLackCount = _fLackCount,//缺料数量
			FHStockQty = sjkcList.FBASEQTY,//即时库存
			FHLeftQty = Inventory.FBASEQTY,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			/* 2021 1.26 更改为need
			FComPlete = sjkcList.FBASEQTY >= _item.PlanCount ? "齐套" : "未齐套",
			*/
			FComPlete = sjkcList.FBASEQTY >= need ? "齐套" : "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			});
			//扣减总库存数量
			sjkcList.FBASEQTY = sjkcList.FBASEQTY >= fCompleteCount ? sjkcList.FBASEQTY - fCompleteCount : 0;
			//剩余日计划需求数量
			need = need >= Inventory.FBASEQTY ? need - Inventory.FBASEQTY : 0;
			//扣减消耗库存
			Inventory.FBASEQTY = Inventory.FBASEQTY - fCompleteCount;
			}
			}
			else
			{
			decimal occupyMaterial = 0;
			if (occupyDic.ContainsKey(_item.FMATERIALID2))
			{
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			}
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FMATERIALID2,
			FErpClsID = _item.FErpClsID,
			FHStockOrgID = _item.FStockOrgId,
			FHPRDORGID = _item.FStockOrgId,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount1 = 0, //齐套数量
			FLackCount = _item.PlanCount,//缺料数量
			FHStockQty = 0,//即时库存
			FHLeftQty = 0,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			FComPlete = "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			});
			}
			}
			//Thread.Sleep(100);
			// this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(40) / DatePlanList.Count) * i);
			i++;

			}
			LogHelper.Info($"齐套分析，数据准备完成，保存到Model实体，总行数：{completeAnalysisTempModel.Count}，耗时：" + sw.Elapsed);
			List<string> sqlList = new List<string>();
			int jdtmmm = 1;
			foreach (var item in completeAnalysisTempModel)
			{
			sql = string.Format(@"
			/dialect/
			delete z_JIT_MOMaterReadysBill
			insert into z_JIT_MOMaterReadysBill (column1)
			values('')
			insert into JIT_MOMaterReadysBill
			(FID, FBILLNO, FDOCUMENTSTATUS, FHMAINICMOINTERIDR, FHMAINICMOENTRYID, FHICMOINTERID, FHICMOENTRYID, FHMATERID, FHSTOCKORGID, FHSTOCKQTY, FHLEFTQTY, FHPRDORGID, FUNITDOSAGE, FSUMPLANCOUNT, FPRDBILLNO, FOWNERID, FOWNERTYPEID, FIDENTIFICAT, FPLANDATE, FCOMPLETE, FLACKCOUNT, FOCCUPYCOUNT, FCOMPLETECOUNT1,FErpClsID)
			select id, '', 'A', '{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}', '{8}', '{9}', '{10}', '{11}', '{12}', 'BD_OwnerOrg', '','{13}','{14}','{15}','{16}','{17}',{18} from z_JIT_MOMaterReadysBill
			delete z_JIT_MOMaterReadysBill
			", item.FHMainICMOInterIDr, item.FHMainICMOEntryID, item.FHICMOInterID, item.FHICMOEntryID, item.FHMaterID, item.FHStockOrgID, item.FHStockQty, item.FHLeftQty, item.FHPRDORGID, item.FUnitDosage, item.FSumPlanCount, item.FPRDBillNo, item.FOwnerId == null ? "0" : item.FOwnerId, item.FPlanDate.ToString("yyyy-MM-dd"), item.FComPlete, item.FLackCount, item.FOccupyCount, item.FCompleteCount1, item.FErpClsID);
			sqlList.Add(sql);
			this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(80) / completeAnalysisTempModel.Count) * jdtmmm);
			jdtmmm++;
			}
			DBServiceHelper.ExecuteBatch(Context, sqlList);
			//执行完成后更新日计划工单状态
			DBServiceHelper.Execute(Context, @"
			/dialect/update Sc_WorkBillSortBillSub set FComplete = '未齐套' where FEntryID IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBill where isnull(FCOMPLETE,'未齐套') ='未齐套')
			");
			DBServiceHelper.Execute(Context, @"
			/dialect/update Sc_WorkBillSortBillSub set FComplete = '齐套' where FEntryID NOT IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBill where isnull(FCOMPLETE,'未齐套') ='未齐套')
			");
			sw.Stop();//结束计时
			LogHelper.Info("齐套分析运行总时长：" + sw.Elapsed);
			}
			catch (Exception ex)
			{
			LogHelper.Error("齐套分析跳出：" + ex.Message.ToString());

			}
			}
			//生产用料清单齐套分析
			public string CompleteSetAnalysisByDataTable()
			{
			LogHelper.Info("齐套分析sql模式开始准备数据：");
			string sql = "";
			try
			{
			Stopwatch sw = new Stopwatch();
			sw.Start();//开始计时
			int maxFid = DBServiceHelper.ExecuteScalar<int>(Context, "select max(FID)FID FROM JIT_MOMaterReadysBill", 0);
			//清空齐套临时表
			DBServiceHelper.Execute(Context, "/dialect/ delete JIT_MOMaterReadysBill ");
			//更新状态
			DBServiceHelper.Execute(Context, "/dialect/ update Sc_WorkBillSortBillsub set FCOMPLETE='' ");
			//获取当前即时库存按照物料+库存组织+货主+库存数量
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			select isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0) FBASEQTY,T1.FStockOrgId,T1.FMATERIALID,a.FOWNERID,c.FNUMBER from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) 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 and a.FOwnerId = b.FOwnerId
			LEFT join T_ORG_Organizations c on a.FOWNERID = c.FORGID
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			");
			ListInventory = ds.ToModelList<PRD_Inventory>();
			//总库存物料+库存组织+库存数量
			ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			select sum(isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0))FBASEQTY,T1.FStockOrgId,T1.FMATERIALID from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) 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
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			group by T1.FStockOrgId,T1.FMATERIALID
			");
			ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();
			//需要齐套分析的数据
			sql = @"
			/dialect/
			select a.FPRDMOMAINID,a.FPRDMOENTYID,a.FID,b.FEntryID,a.FHPRDORGID FStockOrgId,t5.FNUMBER as OrgFnumber,a.FHOrderLev,b.FHQTY,b.FHMASTERDATE,T1.FBillNo,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,
			T2.FMATERIALID FMATERIALID2, T4.FNumber,T2.FNeedQty,FNeedQty/FQty dwyl,(FHQTY-ISNULL(FProductNum,0))*(FNeedQty/FQty) PlanCount,TBase.FErpClsID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID, MAX(FENTRYID) FENTRYID, SUM(FNeedQty) FNeedQty, FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID, FID ) T2 on T1.FID = t2.FID
			--LEFT JOIN T_STK_Inventory T3 on t2.FMATERIALID = t3.FMATERIALID
			JOIN T_BD_MATERIAL T4 on T2.FMATERIALID = T4.FMATERIALID
			JOIN t_BD_MaterialBase TBase on T2.FMATERIALID = TBase.FMATERIALID
			JOIN T_ORG_Organizations t5 on a.FHPRDORGID = t5.FORGID
			--条件为今天往后的日计划 + 今天之前未关闭的日计划
			where (FHEntryCloseDate is null and DATEDIFF(D,GETDATE(),FHMASTERDATE)<0)or DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0
			and b.FHQTY>0
			ORDER BY b.FHMASTERDATE,a.FHOrderLev
			";
			ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			List<PRD_PPBOM> BomList = ds.ToModelList<PRD_PPBOM>();
			//日计划+生产订单子表编码ID
			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;
			//创建字典用于储存物料 + 占用数量
			Dictionary<string, decimal> occupyDic = new Dictionary<string, decimal>();
			LogHelper.Info("齐套分析准备数据完成：" + sw.Elapsed);
			foreach (var item in DatePlanList)
			{
			//筛选出当日计划数据
			var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();
			foreach (var _item in _BomList)
			{
			//该日计划物料需要数
			decimal need = _item.PlanCount;
			var sjkcList = ListInventoryByStockOrgId.Where(x => x.FMATERIALID == _item.FMATERIALID2 && x.FStockOrgId == _item.FStockOrgId).FirstOrDefault();
			//真正需要取计算的数量（拆分货主）
			//货主匹配
			List<PRD_Inventory> _ListInventory = ListInventory.Where(c => c.FMATERIALID == _item.FMATERIALID2 && c.FStockOrgId == _item.FStockOrgId && c.FBASEQTY > 0).ToList();
			if (_ListInventory.Count > 0)
			{
			decimal _fLackCount = _item.PlanCount > sjkcList.FBASEQTY ? (_item.PlanCount - sjkcList.FBASEQTY) : 0;//缺料数量
			foreach (var Inventory in _ListInventory)
			{
			if (need == 0)
			break;
			decimal fCompleteCount = need >= Inventory.FBASEQTY ? Inventory.FBASEQTY : need;//齐套数量
			decimal occupyMaterial = 0;
			if (!occupyDic.ContainsKey(_item.FMATERIALID2))
			{
			occupyDic.Add(_item.FMATERIALID2, fCompleteCount);
			}
			else
			{
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			occupyDic[_item.FMATERIALID2] = occupyMaterial + fCompleteCount;
			}
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FMATERIALID2,
			FHStockOrgID = _item.FStockOrgId,
			FHPRDORGID = _item.FStockOrgId,
			FErpClsID = _item.FErpClsID,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FOwnerId = Inventory.FOwnerId,
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount1 = fCompleteCount, //齐套数量
			FLackCount = _fLackCount,//缺料数量
			FHStockQty = sjkcList.FBASEQTY,//即时库存
			FHLeftQty = Inventory.FBASEQTY,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			/* 2021 1.26 更改为need
			FComPlete = sjkcList.FBASEQTY >= _item.PlanCount ? "齐套" : "未齐套",
			*/
			FComPlete = sjkcList.FBASEQTY >= need ? "齐套" : "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			});
			//扣减总库存数量
			sjkcList.FBASEQTY = sjkcList.FBASEQTY >= fCompleteCount ? sjkcList.FBASEQTY - fCompleteCount : 0;
			//剩余日计划需求数量
			need = need >= Inventory.FBASEQTY ? need - Inventory.FBASEQTY : 0;
			//扣减消耗库存
			Inventory.FBASEQTY = Inventory.FBASEQTY - fCompleteCount;
			}
			}
			else
			{
			decimal occupyMaterial = 0;
			if (occupyDic.ContainsKey(_item.FMATERIALID2))
			{
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			}
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FMATERIALID2,
			FErpClsID = _item.FErpClsID,
			FHStockOrgID = _item.FStockOrgId,
			FHPRDORGID = _item.FStockOrgId,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount1 = 0, //齐套数量
			FLackCount = _item.PlanCount,//缺料数量
			FHStockQty = 0,//即时库存
			FHLeftQty = 0,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			FComPlete = "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			});
			}
			}
			//Thread.Sleep(100);
			// this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(40) / DatePlanList.Count) * i);
			i++;

			}
			LogHelper.Info($"齐套分析，数据准备完成，保存到Model实体，总行数：{completeAnalysisTempModel.Count}，耗时：" + sw.Elapsed);
			List<string> sqlList = new List<string>();
			DataTable insertDT = new DataTable();
			insertDT.TableName = "JIT_MOMaterReadysBill";
			insertDT.Columns.Add("FID", typeof(long));
			//insertDT.Columns.Add("FBILLNO", typeof(string));
			insertDT.Columns.Add("FDOCUMENTSTATUS", typeof(string));
			insertDT.Columns.Add("FHMAINICMOINTERIDR", typeof(long));
			insertDT.Columns.Add("FHMAINICMOENTRYID", typeof(long));
			insertDT.Columns.Add("FHICMOINTERID", typeof(long));
			insertDT.Columns.Add("FHICMOENTRYID", typeof(long));
			insertDT.Columns.Add("FHMATERID", typeof(long));
			insertDT.Columns.Add("FHSTOCKORGID", typeof(long));
			insertDT.Columns.Add("FHSTOCKQTY", typeof(decimal));
			insertDT.Columns.Add("FHLEFTQTY", typeof(decimal));
			insertDT.Columns.Add("FHPRDORGID", typeof(long));
			insertDT.Columns.Add("FUNITDOSAGE", typeof(decimal));
			insertDT.Columns.Add("FSUMPLANCOUNT", typeof(decimal));
			insertDT.Columns.Add("FPRDBILLNO", typeof(string));
			insertDT.Columns.Add("FOWNERID", typeof(long));
			insertDT.Columns.Add("FOWNERTYPEID", typeof(string));
			//insertDT.Columns.Add("FIDENTIFICAT", typeof(long));
			insertDT.Columns.Add("FPLANDATE", typeof(DateTime));
			insertDT.Columns.Add("FCOMPLETE", typeof(string));
			insertDT.Columns.Add("FLACKCOUNT", typeof(decimal));
			insertDT.Columns.Add("FOCCUPYCOUNT", typeof(decimal));
			insertDT.Columns.Add("FCOMPLETECOUNT1", typeof(decimal));
			insertDT.Columns.Add("FERPCLSID", typeof(string));
			int jdtmmm = 1;
			foreach (var item in completeAnalysisTempModel)
			{
			DataRow dr = insertDT.NewRow();
			dr["FID"] = maxFid + jdtmmm;
			//dr["FBILLNO"] = "";
			dr["FDOCUMENTSTATUS"] = "A";
			dr["FHMAINICMOINTERIDR"] = item.FHMainICMOInterIDr;
			dr["FHMAINICMOENTRYID"] = item.FHMainICMOEntryID;
			dr["FHICMOINTERID"] = item.FHICMOInterID;
			dr["FHICMOENTRYID"] = item.FHICMOEntryID;
			dr["FHMATERID"] = item.FHMaterID;
			dr["FHSTOCKORGID"] = item.FHStockOrgID;
			dr["FHSTOCKQTY"] = item.FHStockQty;
			dr["FHLEFTQTY"] = item.FHLeftQty;
			dr["FHPRDORGID"] = item.FHPRDORGID;
			dr["FUNITDOSAGE"] = item.FUnitDosage;
			dr["FSUMPLANCOUNT"] = item.FSumPlanCount;
			dr["FPRDBILLNO"] = item.FPRDBillNo;
			dr["FOWNERID"] = item.FOwnerId == null ? "0" : item.FOwnerId;
			dr["FOWNERTYPEID"] = "BD_OwnerOrg";
			//dr["FIDENTIFICAT"] = "";
			dr["FPLANDATE"] = item.FPlanDate.ToString("yyyy-MM-dd");
			dr["FCOMPLETE"] = item.FComPlete;
			dr["FLACKCOUNT"] = item.FLackCount;
			dr["FOCCUPYCOUNT"] = item.FOccupyCount;
			dr["FCOMPLETECOUNT1"] = item.FCompleteCount1;
			dr["FERPCLSID"] = item.FErpClsID;
			insertDT.Rows.Add(dr);
			//Thread.Sleep(6000);
			this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(80) / completeAnalysisTempModel.Count) * jdtmmm);
			jdtmmm++;
			}
			insertDT.EndLoadData(); // 灌入数据结束
			// 批量插入到数据库
			DBServiceHelper.BulkInserts(this.Context, string.Empty, string.Empty, insertDT);
			//DBServiceHelper.ExecuteBatch(Context, sqlList);
			//执行完成后更新日计划工单状态
			DBServiceHelper.Execute(Context, @"
			/dialect/update Sc_WorkBillSortBillSub set FComplete = '未齐套' where FEntryID IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBill where isnull(FCOMPLETE,'未齐套') ='未齐套')
			");
			DBServiceHelper.Execute(Context, @"
			/dialect/update Sc_WorkBillSortBillSub set FComplete = '齐套' where FEntryID NOT IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBill where isnull(FCOMPLETE,'未齐套') ='未齐套')
			");
			sw.Stop();//结束计时
			LogHelper.Info("齐套分析运行总时长：" + sw.Elapsed);
			return "操作成功";
			}
			catch (Exception ex)
			{
			LogHelper.Error("齐套分析跳出：" + ex.Message.ToString());
			return "操作失败，" + ex.Message.ToString();

			}
			}
			//物料用料清单齐套分析
			public string CompleteSetAnalysisByDataTableBom()
			{
			LogHelper.Info("齐套分析(bom)sql模式开始准备数据：");
			string sql = "";
			try
			{
			Stopwatch sw = new Stopwatch();
			sw.Start();//开始计时
			int maxFid = DBServiceHelper.ExecuteScalar<int>(Context, "select max(FID)FID FROM JIT_MOMaterReadysBomBill", 0);
			//清空齐套临时表
			DBServiceHelper.Execute(Context, "/dialect/ delete JIT_MOMaterReadysBomBill ");
			//更新状态
			DBServiceHelper.Execute(Context, "/dialect/ update Sc_WorkBillSortBillsub set FCOMPLETEBOM='' ");
			//获取当前即时库存按照物料+库存组织+货主+库存数量
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			select isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0) FBASEQTY,T1.FStockOrgId,T1.FMATERIALID,a.FOWNERID,c.FNUMBER from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) T1
			LEFT JOIN T_STK_Inventory a on T1.FStockOrgId = a.FStockOrgId and T1.FMATERIALID =a.FMATERIALID
			LEFT JOIN JIT_MOMaterReadysBomBill 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
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			");
			ListInventory = ds.ToModelList<PRD_Inventory>();
			//总库存物料+库存组织+库存数量
			ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			select sum(isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0))FBASEQTY,T1.FStockOrgId,T1.FMATERIALID from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) T1
			LEFT JOIN T_STK_Inventory a on T1.FStockOrgId = a.FStockOrgId and T1.FMATERIALID =a.FMATERIALID
			LEFT JOIN JIT_MOMaterReadysBomBill B ON T1.FStockOrgId = b.FHSTOCKORGID and T1.FMATERIALID =b.FHMATERID
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			group by T1.FStockOrgId,T1.FMATERIALID
			");
			ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();
			//需要齐套分析(bom)的数据
			sql = @"
			/dialect/
			select a.FPRDMOMAINID,a.FPRDMOENTYID,a.FID,b.FEntryID,a.FHPRDORGID FStockOrgId,t5.FNUMBER as OrgFnumber,a.FHOrderLev,b.FHQTY,b.FHMASTERDATE, a.FSCORDERNO as FMOBillNO,
			T2.FMATERIALID FMATERIALID2, T4.FNumber,t2.FNUMERATOR/t2.FDENOMINATOR dwyl,(FHQTY-ISNULL(FProductNum,0))*(t2.FNUMERATOR/t2.FDENOMINATOR ) PlanCount,TBase.FErpClsID
			from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			--join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN T_ENG_BOMCHILD T2 on a.FBOMID = t2.FID
			--LEFT JOIN T_STK_Inventory T3 on t2.FMATERIALID = t3.FMATERIALID
			JOIN T_BD_MATERIAL T4 on T2.FMATERIALID = T4.FMATERIALID
			JOIN t_BD_MaterialBase TBase on T2.FMATERIALID = TBase.FMATERIALID
			JOIN T_ORG_Organizations t5 on a.FHPRDORGID = t5.FORGID
			--条件为今天往后的日计划 + 今天之前未关闭的日计划
			where (FHEntryCloseDate is null and DATEDIFF(D,GETDATE(),FHMASTERDATE)<0)or DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0
			and b.FHQTY>0
			ORDER BY b.FHMASTERDATE,a.FHOrderLev
			";
			ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			List<PRD_PPBOM> BomList = ds.ToModelList<PRD_PPBOM>();
			//日计划+生产订单子表编码ID
			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;
			//创建字典用于储存物料 + 占用数量
			Dictionary<string, decimal> occupyDic = new Dictionary<string, decimal>();
			LogHelper.Info("齐套分析(bom)准备数据完成：" + sw.Elapsed);
			foreach (var item in DatePlanList)
			{
			//筛选出当日计划数据
			var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();
			foreach (var _item in _BomList)
			{
			//该日计划物料需要数
			decimal need = _item.PlanCount;
			var sjkcList = ListInventoryByStockOrgId.Where(x => x.FMATERIALID == _item.FMATERIALID2 && x.FStockOrgId == _item.FStockOrgId).FirstOrDefault();
			//真正需要取计算的数量（拆分货主）
			//货主匹配
			List<PRD_Inventory> _ListInventory = ListInventory.Where(c => c.FMATERIALID == _item.FMATERIALID2 && c.FStockOrgId == _item.FStockOrgId && c.FBASEQTY > 0).ToList();
			if (_ListInventory.Count > 0)
			{
			decimal _fLackCount = _item.PlanCount > sjkcList.FBASEQTY ? (_item.PlanCount - sjkcList.FBASEQTY) : 0;//缺料数量
			foreach (var Inventory in _ListInventory)
			{
			if (need == 0)
			break;
			decimal fCompleteCount = need >= Inventory.FBASEQTY ? Inventory.FBASEQTY : need;//齐套数量
			decimal occupyMaterial = 0;
			if (!occupyDic.ContainsKey(_item.FMATERIALID2))
			{
			occupyDic.Add(_item.FMATERIALID2, fCompleteCount);
			}
			else
			{
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			occupyDic[_item.FMATERIALID2] = occupyMaterial + fCompleteCount;
			}
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FMATERIALID2,
			FHStockOrgID = _item.FStockOrgId,
			FHPRDORGID = _item.FStockOrgId,
			FErpClsID = _item.FErpClsID,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FOwnerId = Inventory.FOwnerId,
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount1 = fCompleteCount, //齐套数量
			FLackCount = _fLackCount,//缺料数量
			FHStockQty = sjkcList.FBASEQTY,//即时库存
			FHLeftQty = Inventory.FBASEQTY,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			/* 2021 1.26 更改为need
			FComPlete = sjkcList.FBASEQTY >= _item.PlanCount ? "齐套" : "未齐套",
			*/
			FComPlete = sjkcList.FBASEQTY >= need ? "齐套" : "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			});
			//扣减总库存数量
			sjkcList.FBASEQTY = sjkcList.FBASEQTY >= fCompleteCount ? sjkcList.FBASEQTY - fCompleteCount : 0;
			//剩余日计划需求数量
			need = need >= Inventory.FBASEQTY ? need - Inventory.FBASEQTY : 0;
			//扣减消耗库存
			Inventory.FBASEQTY = Inventory.FBASEQTY - fCompleteCount;
			}
			}
			else
			{
			decimal occupyMaterial = 0;
			if (occupyDic.ContainsKey(_item.FMATERIALID2))
			{
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			}
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FMATERIALID2,
			FErpClsID = _item.FErpClsID,
			FHStockOrgID = _item.FStockOrgId,
			FHPRDORGID = _item.FStockOrgId,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount1 = 0, //齐套数量
			FLackCount = _item.PlanCount,//缺料数量
			FHStockQty = 0,//即时库存
			FHLeftQty = 0,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			FComPlete = "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			});
			}
			}
			//Thread.Sleep(100);
			// this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(40) / DatePlanList.Count) * i);
			i++;

			}
			LogHelper.Info($"齐套分析(bom)，数据准备完成，保存到Model实体，总行数：{completeAnalysisTempModel.Count}，耗时：" + sw.Elapsed);
			List<string> sqlList = new List<string>();
			DataTable insertDT = new DataTable();
			insertDT.TableName = "JIT_MOMaterReadysBomBill";
			insertDT.Columns.Add("FID", typeof(long));
			//insertDT.Columns.Add("FBILLNO", typeof(string));
			insertDT.Columns.Add("FDOCUMENTSTATUS", typeof(string));
			insertDT.Columns.Add("FHMAINICMOINTERIDR", typeof(long));
			insertDT.Columns.Add("FHMAINICMOENTRYID", typeof(long));
			insertDT.Columns.Add("FHICMOINTERID", typeof(long));
			insertDT.Columns.Add("FHICMOENTRYID", typeof(long));
			insertDT.Columns.Add("FHMATERID", typeof(long));
			insertDT.Columns.Add("FHSTOCKORGID", typeof(long));
			insertDT.Columns.Add("FHSTOCKQTY", typeof(decimal));
			insertDT.Columns.Add("FHLEFTQTY", typeof(decimal));
			insertDT.Columns.Add("FHPRDORGID", typeof(long));
			insertDT.Columns.Add("FUNITDOSAGE", typeof(decimal));
			insertDT.Columns.Add("FSUMPLANCOUNT", typeof(decimal));
			insertDT.Columns.Add("FPRDBILLNO", typeof(string));
			insertDT.Columns.Add("FOWNERID", typeof(long));
			insertDT.Columns.Add("FOWNERTYPEID", typeof(string));
			//insertDT.Columns.Add("FIDENTIFICAT", typeof(long));
			insertDT.Columns.Add("FPLANDATE", typeof(DateTime));
			insertDT.Columns.Add("FCOMPLETE", typeof(string));
			insertDT.Columns.Add("FLACKCOUNT", typeof(decimal));
			insertDT.Columns.Add("FOCCUPYCOUNT", typeof(decimal));
			insertDT.Columns.Add("FCOMPLETECOUNT1", typeof(decimal));
			insertDT.Columns.Add("FERPCLSID", typeof(string));
			int jdtmmm = 1;
			foreach (var item in completeAnalysisTempModel)
			{
			DataRow dr = insertDT.NewRow();
			dr["FID"] = maxFid + jdtmmm;
			//dr["FBILLNO"] = "";
			dr["FDOCUMENTSTATUS"] = "A";
			dr["FHMAINICMOINTERIDR"] = item.FHMainICMOInterIDr;
			dr["FHMAINICMOENTRYID"] = item.FHMainICMOEntryID;
			dr["FHICMOINTERID"] = item.FHICMOInterID;
			dr["FHICMOENTRYID"] = item.FHICMOEntryID;
			dr["FHMATERID"] = item.FHMaterID;
			dr["FHSTOCKORGID"] = item.FHStockOrgID;
			dr["FHSTOCKQTY"] = item.FHStockQty;
			dr["FHLEFTQTY"] = item.FHLeftQty;
			dr["FHPRDORGID"] = item.FHPRDORGID;
			dr["FUNITDOSAGE"] = item.FUnitDosage;
			dr["FSUMPLANCOUNT"] = item.FSumPlanCount;
			dr["FPRDBILLNO"] = item.FPRDBillNo;
			dr["FOWNERID"] = item.FOwnerId == null ? "0" : item.FOwnerId;
			dr["FOWNERTYPEID"] = "BD_OwnerOrg";
			//dr["FIDENTIFICAT"] = "";
			dr["FPLANDATE"] = item.FPlanDate.ToString("yyyy-MM-dd");
			dr["FCOMPLETE"] = item.FComPlete;
			dr["FLACKCOUNT"] = item.FLackCount;
			dr["FOCCUPYCOUNT"] = item.FOccupyCount;
			dr["FCOMPLETECOUNT1"] = item.FCompleteCount1;
			dr["FERPCLSID"] = item.FErpClsID;
			insertDT.Rows.Add(dr);
			//Thread.Sleep(6000);
			this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(80) / completeAnalysisTempModel.Count) * jdtmmm);
			jdtmmm++;
			}
			insertDT.EndLoadData(); // 灌入数据结束
			// 批量插入到数据库
			DBServiceHelper.BulkInserts(this.Context, string.Empty, string.Empty, insertDT);
			//DBServiceHelper.ExecuteBatch(Context, sqlList);
			//执行完成后更新日计划工单状态
			DBServiceHelper.Execute(Context, @"
			/dialect/update Sc_WorkBillSortBillSub set FCompletebom = '未齐套' where FEntryID IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBomBill where isnull(FCOMPLETE,'未齐套') ='未齐套')
			");
			DBServiceHelper.Execute(Context, @"
			/dialect/update Sc_WorkBillSortBillSub set FCompletebom = '齐套' where FEntryID NOT IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBomBill where isnull(FCOMPLETE,'未齐套') ='未齐套')
			");
			sw.Stop();//结束计时
			LogHelper.Info("齐套分析(bom)运行总时长：" + sw.Elapsed);
			return "操作成功";
			}
			catch (Exception ex)
			{
			LogHelper.Error("齐套分析(bom)跳出：" + ex.Message.ToString());
			return "操作失败，" + ex.Message.ToString();

			}
			}


			/// <summary>
			/// 虚拟齐套
			/// </summary>
			public void Xnqt()
			{
			LogHelper.Info("虚拟齐套分析sql模式开始准备数据：");
			string sql = "";
			try
			{
			Stopwatch sw = new Stopwatch();
			sw.Start();//开始计时
			LogHelper.Info("虚拟齐套分析开始准备数据：" + sw.Elapsed);
			//清空齐套临时表
			DBServiceHelper.Execute(Context, "/dialect/ delete JIT_MOMaterReadysBillXn ");
			////更新状态
			//DBServiceHelper.Execute(Context, "/dialect/ update Sc_WorkBillSortBillsub set FCOMPLETE='' ");
			//获取当前即时库存按照物料+库存组织+货主+库存数量
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			select isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0) FBASEQTY,T1.FStockOrgId,T1.FMATERIALID,a.FOWNERID,c.FNUMBER from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) T1
			LEFT JOIN T_STK_Inventory a on T1.FStockOrgId = a.FStockOrgId and T1.FMATERIALID =a.FMATERIALID
			LEFT JOIN JIT_MOMaterReadysBillXn 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
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			");
			ListInventory = ds.ToModelList<PRD_Inventory>();
			//总库存物料+库存组织+库存数量
			ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			select sum(isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0))FBASEQTY,T1.FStockOrgId,T1.FMATERIALID from
			(
			select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID,FID) T2 on T1.FID = t2.FID
			group by a.FHPRDORGID,T2.FMATERIALID
			) T1
			LEFT JOIN T_STK_Inventory a on T1.FStockOrgId = a.FStockOrgId and T1.FMATERIALID =a.FMATERIALID
			LEFT JOIN JIT_MOMaterReadysBillXn B ON T1.FStockOrgId = b.FHSTOCKORGID and T1.FMATERIALID =b.FHMATERID
			join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
			where d.FAvailableComplete<>0
			--where T1.FMATERIALID in (105773)
			group by T1.FStockOrgId,T1.FMATERIALID
			");
			ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();
			//需要虚拟齐套分析的数据
			sql = @"
			/dialect/
			select a.FPRDMOMAINID,a.FPRDMOENTYID,a.FID,b.FEntryID,a.FHPRDORGID FStockOrgId,t5.FNUMBER as OrgFnumber,a.FHOrderLev,b.FHQTY,b.FHMASTERDATE,T1.FBillNo,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,
			T2.FMATERIALID FMATERIALID2, T4.FNumber,T2.FNeedQty,FNeedQty/FQty dwyl,(FHQTY-ISNULL(FProductNum,0))*(FNeedQty/FQty) PlanCount,TBase.FErpClsID from SC_WORKBILLSORTBILLMAIN a
			join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
			join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
			LEFT JOIN(select FID, MAX(FENTRYID) FENTRYID, SUM(FNeedQty) FNeedQty, FMATERIALID from T_PRD_PPBOMENTRY
			group by FMATERIALID, FID ) T2 on T1.FID = t2.FID
			--LEFT JOIN T_STK_Inventory T3 on t2.FMATERIALID = t3.FMATERIALID
			JOIN T_BD_MATERIAL T4 on T2.FMATERIALID = T4.FMATERIALID
			JOIN t_BD_MaterialBase TBase on T2.FMATERIALID = TBase.FMATERIALID
			JOIN T_ORG_Organizations t5 on a.FHPRDORGID = t5.FORGID
			--条件为今天往后的日计划 + 今天之前未关闭的日计划
			where (FHEntryCloseDate is null and DATEDIFF(D,GETDATE(),FHMASTERDATE)<0)or DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0
			and b.FHQTY>0
			ORDER BY b.FHMASTERDATE,a.FHOrderLev
			";
			ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			List<PRD_PPBOM> BomList = ds.ToModelList<PRD_PPBOM>();
			//日计划+生产订单子表编码ID
			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;
			//创建字典用于储存物料 + 占用数量
			Dictionary<string, decimal> occupyDic = new Dictionary<string, decimal>();
			foreach (var item in DatePlanList)
			{

			//筛选出当日计划数据
			var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();
			foreach (var _item in _BomList)
			{
			//该日计划物料需要数
			decimal need = _item.PlanCount;
			var sjkcList = ListInventoryByStockOrgId.Where(x => x.FMATERIALID == _item.FMATERIALID2 && x.FStockOrgId == _item.FStockOrgId).FirstOrDefault();
			//真正需要取计算的数量（拆分货主）
			//货主匹配
			List<PRD_Inventory> _ListInventory = ListInventory.Where(c => c.FMATERIALID == _item.FMATERIALID2 && c.FStockOrgId == _item.FStockOrgId && c.FBASEQTY > 0).ToList();
			if (_ListInventory.Count > 0)
			{
			decimal _fLackCount = _item.PlanCount > sjkcList.FBASEQTY ? (_item.PlanCount - sjkcList.FBASEQTY) : 0;//缺料数量
			foreach (var Inventory in _ListInventory)
			{

			if (need == 0)
			break;
			decimal fCompleteCount = need >= Inventory.FBASEQTY ? Inventory.FBASEQTY : need;//齐套数量
			decimal occupyMaterial = 0;
			if (!occupyDic.ContainsKey(_item.FMATERIALID2))
			{
			occupyDic.Add(_item.FMATERIALID2, fCompleteCount);
			}
			else
			{
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			occupyDic[_item.FMATERIALID2] = occupyMaterial + fCompleteCount;
			}
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FMATERIALID2,
			FHStockOrgID = _item.FStockOrgId,
			FHPRDORGID = _item.FStockOrgId,
			FErpClsID = _item.FErpClsID,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FOwnerId = Inventory.FOwnerId,
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount1 = fCompleteCount, //齐套数量
			FLackCount = _fLackCount,//缺料数量
			FHStockQty = sjkcList.FBASEQTY,//即时库存
			FHLeftQty = Inventory.FBASEQTY,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			/* 2021 1.26 更改为need
			FComPlete = sjkcList.FBASEQTY >= _item.PlanCount ? "齐套" : "未齐套",
			*/
			FComPlete = sjkcList.FBASEQTY >= need ? "齐套" : "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			});
			//扣减总库存数量
			sjkcList.FBASEQTY = sjkcList.FBASEQTY >= fCompleteCount ? sjkcList.FBASEQTY - fCompleteCount : 0;
			//剩余日计划需求数量
			need = need >= Inventory.FBASEQTY ? need - Inventory.FBASEQTY : 0;
			//扣减消耗库存
			Inventory.FBASEQTY = Inventory.FBASEQTY - fCompleteCount;
			}
			}
			else
			{
			decimal occupyMaterial = 0;
			if (occupyDic.ContainsKey(_item.FMATERIALID2))
			{
			occupyMaterial = occupyDic[_item.FMATERIALID2];
			}
			completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
			{
			FHMainICMOInterIDr = _item.FPRDMOMAINID,
			FHMainICMOEntryID = _item.FPRDMOENTYID,
			FHICMOInterID = _item.FID.ToString(),
			FHICMOEntryID = _item.FEntryID.ToString(),
			FHMaterID = _item.FMATERIALID2,
			FErpClsID = _item.FErpClsID,
			FHStockOrgID = _item.FStockOrgId,
			FHPRDORGID = _item.FStockOrgId,
			FPRDBillNo = _item.FMOBillNO,
			FOwnerTypeId = "BD_OwnerOrg",
			FUnitDosage = _item.dwyl.ToString(),//单位用量
			FSumPlanCount = _item.PlanCount.ToString(),//计划总数量
			FCompleteCount1 = 0, //齐套数量
			FLackCount = _item.PlanCount,//缺料数量
			FHStockQty = 0,//即时库存
			FHLeftQty = 0,//可用数量
			FOccupyCount = occupyMaterial,//占用数量
			FComPlete = "未齐套",
			FPlanDate = item.FHMASTERDATE // 日计划日期
			});
			}
			}
			//Thread.Sleep(100);
			// this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(40) / DatePlanList.Count) * i);
			i++;

			}
			LogHelper.Info($"虚拟齐套分析，数据准备完成，保存到Model实体，总行数：{completeAnalysisTempModel.Count}，耗时：" + sw.Elapsed);
			List<string> sqlList = new List<string>();
			int jdtmmm = 1;
			foreach (var item in completeAnalysisTempModel)
			{
			sql = string.Format(@"
			/dialect/
			delete z_JIT_MOMaterReadysBillXn
			insert into z_JIT_MOMaterReadysBillXn (column1)
			values('')
			insert into JIT_MOMaterReadysBillXn
			(FID, FBILLNO, FDOCUMENTSTATUS, FHMAINICMOINTERIDR, FHMAINICMOENTRYID, FHICMOINTERID, FHICMOENTRYID, FHMATERID, FHSTOCKORGID, FHSTOCKQTY, FHLEFTQTY, FHPRDORGID, FUNITDOSAGE, FSUMPLANCOUNT, FPRDBILLNO, FOWNERID, FOWNERTYPEID, FIDENTIFICAT, FPLANDATE, FCOMPLETE, FLACKCOUNT, FOCCUPYCOUNT, FCOMPLETECOUNT1,FErpClsID)
			select id, '', 'A', '{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}', '{8}', '{9}', '{10}', '{11}', '{12}', 'BD_OwnerOrg', '','{13}','{14}','{15}','{16}','{17}',{18} from z_JIT_MOMaterReadysBillXn
			delete z_JIT_MOMaterReadysBillXn
			", item.FHMainICMOInterIDr, item.FHMainICMOEntryID, item.FHICMOInterID, item.FHICMOEntryID, item.FHMaterID, item.FHStockOrgID, item.FHStockQty, item.FHLeftQty, item.FHPRDORGID, item.FUnitDosage, item.FSumPlanCount, item.FPRDBillNo, item.FOwnerId == null ? "0" : item.FOwnerId, item.FPlanDate.ToString("yyyy-MM-dd"), item.FComPlete, item.FLackCount, item.FOccupyCount, item.FCompleteCount1, item.FErpClsID);
			sqlList.Add(sql);
			//this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(98) / completeAnalysisTempModel.Count) * jdtmmm);
			jdtmmm++;
			}
			DBServiceHelper.ExecuteBatch(Context, sqlList);
			// //执行完成后更新日计划工单状态
			// DBServiceHelper.Execute(Context, @"
			///dialect/update Sc_WorkBillSortBillSub set FComplete = '未齐套' where FEntryID IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBillXn where isnull(FCOMPLETE,'未齐套') ='未齐套')
			//");
			// DBServiceHelper.Execute(Context, @"
			///dialect/update Sc_WorkBillSortBillSub set FComplete = '齐套' where FEntryID NOT IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBillXn where isnull(FCOMPLETE,'未齐套') ='未齐套')
			//");
			sw.Stop();//结束计时
			LogHelper.Info("虚拟齐套分析运行总时长：" + sw.Elapsed);
			}
			catch (Exception ex)
			{
			this.View.ShowErrMessage("异常：" + ex.Message.ToString());
			LogHelper.Error("虚拟齐套分析跳出：" + ex.Message.ToString());
			}
			finally
			{
			this.View.ShowMessage("执行完成！");
			}
			}

			/// <summary>
			/// 查询
			/// </summary>
			@@ -966,11 +2201,11 @@
			//销售订单号
			string FSalOrder = Convert.ToString((this.Model.GetValue("FSalOrder")));
			if (!string.IsNullOrEmpty(FSalOrder))
			sqlwhere += $" and FHSeOrderBillNo='{FSalOrder}'";
			sqlwhere += $" and FHSeOrderBillNo like '%{FSalOrder}%'";
			//生产订单号
			string FScOrderMainNo = Convert.ToString((this.Model.GetValue("FScOrderMainNo")));
			if (!string.IsNullOrEmpty(FScOrderMainNo))
			sqlwhere += $" and FSCORDERNO='{FScOrderMainNo}'";
			sqlwhere += $" and FSCORDERNO like '%{FScOrderMainNo}%'";
			//物料
			if ((this.Model.GetValue("FMatralId") as DynamicObject) != null)
			{
			@@ -984,7 +2219,8 @@
			sqlwhere += $" and FPreparatDate='{FPreparatDate}'";
			try
			{
			string sql = @"/dialect/ select t1.*,isnull((select SUM(isnull(FNotProductNum,0)) from SC_WORKBILLSORTBILLSub t2 where t2.FID = t1.FID and DATEDIFF(D,FHMASTERDATE,GETDATE())>0),0)FNotProductNum from Sc_WorkBillSortBillMain t1
			string sql = @"/dialect/ select t1.*,isnull((select SUM(isnull(FNotProductNum,0)) from SC_WORKBILLSORTBILLSub t2 where t2.FID = t1.FID and DATEDIFF(D,FHMASTERDATE,GETDATE())>0),0)FNotProductNum ,isnull((select SUM(isnull(FHQTY,0)) from SC_WORKBILLSORTBILLSub t2 where t2.FID = t1.FID and DATEDIFF(D,FHMASTERDATE,GETDATE())>0),0)FQTYLS
			from Sc_WorkBillSortBillMain t1
			left join T_BD_MATERIAL t3 on t1.FHMaterID=t3.FMATERIALID
			" + sqlwhere;
			DataTable dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
			@@ -995,9 +2231,11 @@
			{
			this.Model.CreateNewEntryRow("FEntity");
			this.Model.SetValue("FSEQ", i + 1, i);//序号
			this.Model.SetValue("FMOFBILLTYPE", Convert.ToString(dt.Rows[i]["FMOFBILLTYPE"]), i);//生产订单单据类型
			this.Model.SetValue("FCompleteSetCount", "", i);//总齐套数量
			this.Model.SetValue("FProOrderCount", dt.Rows[i]["FHOrderNeedQty"].ToString(), i);//生产订单数量
			this.Model.SetValue("FSalOrderCount", dt.Rows[i]["FHSeOrderBillNo"].ToString(), i);//销售订单数量
			this.Model.SetValue("FSRCBILLENTRYSEQ", dt.Rows[i]["FSRCBILLENTRYSEQ"].ToString(), i);//
			this.Model.SetValue("FSalOrderCount", dt.Rows[i]["FHOrderQty"].ToString(), i);//销售订单数量
			this.Model.SetValue("FBatch", dt.Rows[i]["FBatch"].ToString(), i);//批次号
			this.Model.SetValue("FUnit", dt.Rows[i]["FHUnitID"].ToString(), i);//计量单位
			this.Model.SetValue("FORGID", dt.Rows[i]["FHPRDORGID"].ToString(), i);//生产组织
			@@ -1015,7 +2253,8 @@
			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("FDayPlanQuantity", Convert.ToDecimal(dt.Rows[i]["FDAYPLANQUANTITY"]) - Convert.ToDecimal(dt.Rows[i]["FQTYLS"]), i);//日计划数量
			this.Model.SetValue("FQTYLS", dt.Rows[i]["FQTYLS"].ToString(), i);//历史遗留
			this.Model.SetValue("FNoScheduled", dt.Rows[i]["FNoScheduled"].ToString(), i);//未排数量
			this.Model.SetValue("FDelaylnUM", dt.Rows[i]["FNotProductNum"].ToString(), i);//拖期数量
			sql = @"/dialect/SELECT * FROM Sc_WorkBillSortBillSub WHERE DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0 and FID=" + dt.Rows[i]["FID"].ToString();
			@@ -1031,7 +2270,7 @@
			if (dr["FHLockedSub"].ToString() == "1")
			this.View.GetFieldEditor("FT" + getDay.Days.ToString(), i).Enabled = false; //单据体行锁定字段
			}
			this.View.InvokeFieldUpdateService("FMatrailId", i);//调用数量值更新
			this.View.InvokeFieldUpdateService("FMatrailId", i);//GetControl
			}
			this.View.UpdateView();
			for (int j = 0; j < dt.Rows.Count; j++)
			@@ -1085,20 +2324,12 @@
			}
			//销售订单号
			string FSalOrder = Convert.ToString((this.Model.GetValue("FSalOrder")));
			if (string.IsNullOrEmpty(FSalOrder))
			{

			}
			else
			sqlwhere += $" and FHSeOrderBillNo='{FSalOrder}'";
			if (!string.IsNullOrEmpty(FSalOrder))
			sqlwhere += $" and FHSeOrderBillNo like '%{FSalOrder}%'";
			//生产订单号
			string FScOrderMainNo = Convert.ToString((this.Model.GetValue("FScOrderMainNo")));
			if (string.IsNullOrEmpty(FScOrderMainNo))
			{

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

			//物料
			if ((this.Model.GetValue("FMatralId") as DynamicObject) != null)
			@@ -1113,7 +2344,8 @@
			sqlwhere += $" and FPreparatDate='{FPreparatDate}'";
			try
			{
			string sql = @"/dialect/ select t1.*,isnull((select SUM(isnull(FNotProductNum,0)) from SC_WORKBILLSORTBILLSub t2 where t2.FID = t1.FID and DATEDIFF(D,FHMASTERDATE,GETDATE())>0),0)FNotProductNum from Sc_WorkBillSortBillMain t1
			string sql = @"/dialect/ select t1.*,isnull((select SUM(isnull(FNotProductNum,0)) from SC_WORKBILLSORTBILLSub t2 where t2.FID = t1.FID and DATEDIFF(D,FHMASTERDATE,GETDATE())>0),0)FNotProductNum ,isnull((select SUM(isnull(FHQTY,0)) from SC_WORKBILLSORTBILLSub t2 where t2.FID = t1.FID and DATEDIFF(D,FHMASTERDATE,GETDATE())>0),0)FQTYLS
			from Sc_WorkBillSortBillMain t1
			left join T_BD_MATERIAL t3 on t1.FHMaterID=t3.FMATERIALID
			" + sqlwhere;
			DataTable dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
			@@ -1124,9 +2356,11 @@
			{
			this.Model.CreateNewEntryRow("FEntity");
			this.Model.SetValue("FSEQ", i + 1, i);//序号
			this.Model.SetValue("FMOFBILLTYPE", Convert.ToString(dt.Rows[i]["FMOFBILLTYPE"]), i);//生产订单单据类型
			this.Model.SetValue("FCompleteSetCount", "", i);//总齐套数量
			this.Model.SetValue("FProOrderCount", dt.Rows[i]["FHOrderNeedQty"].ToString(), i);//生产订单数量
			this.Model.SetValue("FSalOrderCount", dt.Rows[i]["FHSeOrderBillNo"].ToString(), i);//销售订单数量
			this.Model.SetValue("FSRCBILLENTRYSEQ", dt.Rows[i]["FSRCBILLENTRYSEQ"].ToString(), i);//
			this.Model.SetValue("FSalOrderCount", dt.Rows[i]["FHOrderQty"].ToString(), i);//销售订单数量
			this.Model.SetValue("FBatch", dt.Rows[i]["FBatch"].ToString(), i);//批次号
			this.Model.SetValue("FUnit", dt.Rows[i]["FHUnitID"].ToString(), i);//计量单位
			this.Model.SetValue("FORGID", dt.Rows[i]["FHPRDORGID"].ToString(), i);//生产组织
			@@ -1144,7 +2378,8 @@
			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("FDayPlanQuantity", Convert.ToDecimal(dt.Rows[i]["FOrderQuantity"]) - Convert.ToDecimal(dt.Rows[i]["FQTYLS"]), i);//日计划数量
			this.Model.SetValue("FQTYLS", dt.Rows[i]["FQTYLS"].ToString(), i);//历史遗留
			this.Model.SetValue("FNoScheduled", dt.Rows[i]["FNoScheduled"].ToString(), i);//未排数量
			this.Model.SetValue("FDelaylnUM", dt.Rows[i]["FNotProductNum"].ToString(), i);//拖期数量
			sql = @"/dialect/SELECT * FROM Sc_WorkBillSortBillSub WHERE DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0 and FID=" + dt.Rows[i]["FID"].ToString();
			@@ -1189,501 +2424,115 @@
			}

			}

			/// <summary>
			/// 提料计划
			/// 日计划用料清单进度条
			/// </summary>
			public void Extraction3()
			private void DayPlanPPBomBill()
			{
			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)
			// 显示一个进度显示界面：显示一个不停滚动的模拟进度
			// bUseTruePro参数：是否显示真实的进度。
			// bUseTruePro = false ：
			// 显示一个不停滚动的模拟进度，与实际处理进度没有关联。
			// 此方案优点：实际处理代码无需计算进度
			// 此方案缺点：进度不准确，且进度页面不会自动关闭。
			// bUseTruePro = true: 进度界面显示真实进度
			// 此方案优点：进度真实
			// 此方案缺点：需要在处理代码中，不断的更新真实进度，更新语句
			// this.View.Session["ProcessRateValue"] = 100;
			// 特别说明，当进度更新到100时，进度界面会自动关闭
			// 本案例选用此方案
			var processForm = this.View.ShowProcessForm(
			new Action<FormResult>(t => { }),
			true,
			"正在生成，请稍候...");

			// 开启一个异步线程，处理引入功能
			// using Kingdee.BOS.KDThread;
			MainWorker.QuequeTask(() =>
			{
			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.FID,FHMATERID,FHMASTERDATE,FHQTY,FCOMPLETECOUNT,FPRDMOMAINID,T2.FENTRYID,T1.FBILLNO, FNeedQty,(FLeadtime+FLeadTtime2)FFIXLEADTIME,t5.FMAXPOQTY,FJITBatch FMINPOQTY,FJITMATERIALGROUP,FJITMaterielDemand,FJITSafeStock,t3.FMATERIALID,t6.FNumber,FHQTY*FNeedQty NeedQty,FHPRDORGID FStockOrgId FROM SC_WORKBILLSORTBILLMAIN T1
			JOIN SC_WORKBILLSORTBILLSUB T2 ON T1.FID=T2.FID
			LEFT JOIN(SELECT T1.FID,max(t2.FMATERIALID)FMATERIALIDMAIN, max(t2.FMoId)FMoId,MAX(FENTRYID) FENTRYID, SUM(convert(decimal(18, 2), FBASENUMERATOR / FBASEDENOMINATOR))FNeedQty, T1.FMATERIALID from T_PRD_PPBOMENTRY T1
			JOIN T_PRD_PPBOM T2 on t1.FID = t2.FID
			group by T1.FMATERIALID, T1.FID) T3 on T1.FPRDMOMAINID = t3.FMoId and T1.FHMATERID = t3.FMATERIALIDMAIN
			JOIN T_BD_MATERIAL T6 ON T3.FMATERIALID = T6.FMATERIALID
			join t_BD_MaterialBase t4 on t3.FMATERIALID = t4.FMATERIALID
			join t_BD_MaterialPlan t5 on t3.FMATERIALID = t5.FMATERIALID
			WHERE DATEDIFF(D,GETDATE(),FHMASTERDATE) >=0
			AND FDayPlanQuantity>FCOMPLETECOUNT
			AND FERPCLSID=1
			AND T2.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>();

			//所有物料的库存
			ds = DBServiceHelper.ExecuteDataSet(Context, @" /dialect/ select sum(FBASEQTY)FBASEQTY,FMATERIALID,FStockOrgId from T_STK_Inventory group by FMATERIALID, FStockOrgId ");
			ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();
			List<PODemandPlanTemp> deleteList = new List<PODemandPlanTemp>();
			foreach (var item in DayPlanPpbom)
			{
			string FmaterialID = item.FMATERIALID;
			string FStockOrgId = item.FStockOrgId.ToString();
			decimal NeedQty = item.NeedQty;
			var kcList = ListInventoryByStockOrgId.Where(c => c.FMATERIALID == FmaterialID && c.FStockOrgId == FStockOrgId && c.FBASEQTY > 0).FirstOrDefault();
			if (kcList != null)
			var result = "操作成功";
			try
			{
			if (kcList.FBASEQTY >= NeedQty)
			// 需要捕获错误，以确保处理结束时，关闭进度滚动界面
			// 引入功能实际处理函数
			result = this.DayPlanPPBomBillBatch();
			}
			finally
			{
			// 确保标记进度已经到达100%
			this.View.Session["ProcessRateValue"] = 100;
			// 引入完毕，关闭进度显示页面
			var processView = this.View.GetView(processForm.PageId);
			if (processView != null)
			{
			deleteList.Add(new PODemandPlanTemp
			{
			FENTRYID = item.FENTRYID,
			FMATERIALID = item.FMATERIALID
			});
			kcList.FBASEQTY = kcList.FBASEQTY - NeedQty;
			}
			else
			{
			item.NeedQty -= kcList.FBASEQTY;
			kcList.FBASEQTY = 0;
			processView.Close();
			this.View.SendDynamicFormAction(processView);
			this.View.ShowMessage(result);
			}
			}
			}
			foreach (var item in deleteList)
			{
			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);
			List<DayPlanPpbom> CompleteList = ds.ToModelList<DayPlanPpbom>();
			#region
			/*
			//FID集合
			var FIDList = CompleteList.Select(x => x.FID).Distinct().ToList();
			foreach (var item in FIDList)
			{
			var _CompleteList = CompleteList.Where(p => p.FID == item).ToList();
			decimal FComplete = _CompleteList.FirstOrDefault().FCOMPLETECOUNT;
			if (FComplete == 0)
			continue;
			foreach (var _item in _CompleteList)
			{
			FComplete = FComplete - _item.FHQTY;
			if (FComplete >= 0)
			{
			DayPlanPpbom.RemoveAll(p => p.FENTRYID == _item.FENTRYID);
			},
			(t) => { });

			}
			else
			{
			DayPlanPpbom.FindAll(p => p.FENTRYID == _item.FENTRYID).ForEach(x =>
			{
			x.NeedQty = -(x.FNeedQty * FComplete);
			});
			break;
			}


			}

			}
			*/
			#endregion
			//获取当前即时库存
			DataSet JSKCds = DBServiceHelper.ExecuteDataSet(Context, " /dialect/ select DISTINCT FBASEQTY,FMATERIALID,FStockOrgId,FOwnerId from T_STK_Inventory");
			var InventoryList = ds.ToModelList<PRD_Inventory>();


			//物料集合由物料去分组
			// List<string> MaterialIDList = DayPlanPpbom.Select(x => x.FMATERIALID).Distinct().ToList();

			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();
			//this.View.ShowMessage("操作成功");
			}

			/// <summary>
			/// 日计划用料清单生成
			/// </summary>
			public void DayPlanPPBomBill()
			/// </summary>
			public string DayPlanPPBomBillBatch()
			{
			//LogService.WriteAsync(entrys);
			//查找到的同批项次
			int day = Convert.ToInt32(this.Model.GetValue("FLockDays"));
			Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
			//单据体信息转换为列表集合
			DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
			DynamicObjectCollection filterResult = entityDataObjoct.Clone();
			filterResult.Clear();
			entityDataObjoct.Where(x => Convert.ToBoolean(x["FFOCUS"])).ToList().ForEach(x => filterResult.Add(x));
			string sqlWhere = " 1=1 ";
			string FDayPlanWorkID = "";
			string zxSql = "";
			List<string> zxSqlList = new List<string>();
			if (filterResult.Count() > 0)
			{
			foreach (var filter in filterResult)
			{
			FDayPlanWorkID += filter["FDayPlanWorkID"].ToString() + ",";
			zxSqlList.Add(string.Format(@"/dialect/
			INSERT INTO Z_SC_TLPLANZXJH (COLUMN1) VALUES ('{0}')
			SELECT * FROM Z_SC_TLPLANZXJH
			INSERT INTO SC_TLPLANZXJH(FID, FDAYPLANID, FCREATEDATE) SELECT *, GETDATE() FROM Z_SC_TLPLANZXJH
			DELETE FROM Z_SC_TLPLANZXJH
			SELECT * FROM SC_TLPLANZXJH", filter["FDayPlanWorkID"]));
			}
			FDayPlanWorkID = FDayPlanWorkID.TrimEnd(',');
			sqlWhere += $"AND t2.FID IN ({FDayPlanWorkID})";
			}
			DBServiceHelper.ExecuteBatch(Context, zxSqlList);
			Stopwatch sw = new Stopwatch();
			sw.Start();//开始计时

			LogHelper.Info("生成日计划用料清单准备数据");
			//锁定的日计划不生成
			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
			string sql = string.Format(@"/dialect/
			select t1.FID,t1.FSEQ FDayPlanFSEQ,t1.FEntryID,T2.FBILLNO AS FDayPlanFBILLNO,t3.FMATERIALID,t3.FMOEntrySeq as FMoSeq,T5.FNUMBER,t1.FHMASTERDATE,t1.FHQTY,t4.FMATERIALID FMATERIALID2,T6.FNUMBER FNUMBER2,T7.FNUMBER FUNITNUMBER,FNumerator,FDenominator,convert(decimal(18,2),(t4.FMustQty/T3.FQTY) *t1.FHQTY) FHQtyMust,T4.FUnitID,t8.FNUMBER FUNITNUMBER2,T3.FID FPPBOM,T4.FENTRYID FPPBOMENTRYID,isnull(T9.FBillNo,'')FBillNo,t10.FNUMBER FORGNUMBER,t11.FNUMBER FHSOURCENUMBER,FSCRAPRATE,FFIXSCRAPQTY,T9.FID AS DayPlanFID,t2.FSCORDERNO,
			t3.FMOENTRYID,t3.FBILLNO FPPBOMBILLNO,T4.FSEQ,tc.FOWNERTYPEID,tc.FOWNERID,tc.FEntrustPickOrgId,torg.FNUMBER as FORGNUMBER,t3.FMOID,FIssueType,FMaterialType,td.FNUMBER as FWORKSHOPID,t4.FReplaceGroup,isnull(ttt.FrowCount,0)FIsTDL,t4.FUseRate
			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
			left join
			(
			select FREPLACEGROUP,COUNT(*) FrowCount,FID from T_PRD_PPBOMENTRY
			GROUP BY FREPLACEGROUP,FID
			having count(*) >1
			) ttt on t4.FID = ttt.FID and t4.FREPLACEGROUP =ttt.FREPLACEGROUP
			JOIN T_PRD_PPBOMENTRY_C Tc ON T4.FENTRYID=Tc.FENTRYID
			join T_ORG_Organizations torg ON tc.FOWNERID = torg.FORGID
			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
			@@ -1691,8 +2540,28 @@
			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
			"
			);
			left join T_BD_DEPARTMENT td on t3.FWORKSHOPID=td.FDEPTID
			WHERE
			t1.FHMASTERDATE between DATEADD(day,-1,getdate()) and DATEADD(day,{{1} - 1},getdate())
			and t1.FEntryID not in
			(
			select distinct FDAYPLANFID from Sc_DayPlanPPBomBillMain where FID IN
			(
			--领料单
			select distinct FDAYPLANFID from T_PRD_PICKMTRLDATA
			union all
			--日计划用料清单变更单
			select distinct FDAYPLANID from Sc_DayPlanPPBomBillSubBG
			)
			)
			AND {0}
			-- and T4.FMustQty>0
			-- (
			-- select FDayPlanFID FROM Sc_DayPlanPPBomBillMain WHERE FID IN ( select distinct FID from Sc_DayPlanPPBomBillSub WHERE FTranslateQty >0 or FPickedQty >0)
			-- )
			",
			sqlWhere, day);
			LogHelper.Info("生成日计划用料清单准备数据sql:" + sql);
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, sql);
			DataTable dt = ds.Tables[0];
			List<DayPlanMaterial> DayPlanMaterial = new List<DayPlanMaterial>();
			@@ -1716,19 +2585,43 @@
			FHQtyMust = dr["FHQtyMust"].ToString(),
			FHQtySub = dr["FHQtyMust"].ToString(),
			FHPPBomInterID = dr["FPPBOM"].ToString(),
			FHPPBomEntryID = dr["FENTRYID"].ToString(),
			FHPPBomEntryID = dr["FPPBOMENTRYID"].ToString(),
			FHSourceID = dr["FHSOURCENUMBER"].ToString(),
			FNumerator = dr["FNumerator"].ToString(),
			FDenominator = dr["FDenominator"].ToString(),
			FFIXSCRAPQTY = dr["FFIXSCRAPQTY"].ToString(),
			FHQtyScrap = dr["FSCRAPRATE"].ToString(),
			FMOBILLNO = dr["FSCORDERNO"].ToString(),
			FMOENTRYID = dr["FMOENTRYID"].ToString(),
			FPPBOMBILLNO = dr["FPPBOMBILLNO"].ToString(),
			FPPBOMFSEQ = dr["FSEQ"].ToString(),
			FOwnerTypeId = dr["FOWNERTYPEID"].ToString(),
			FOwnerID = dr["FORGNUMBER"].ToString(),
			FEntrustPickOrgId = dr["FORGNUMBER"].ToString(),
			FMOID = dr["FMOID"].ToString(),
			FIssueType = dr["FIssueType"].ToString(),
			FMaterialType = dr["FMaterialType"].ToString(),
			FDayPlanFSEQ = dr["FDayPlanFSEQ"].ToString(),
			FDayPlanFBILLNO = dr["FDayPlanFBILLNO"].ToString(),
			FWORKSHOPID = dr["FWORKSHOPID"].ToString(),
			FReplaceGroup = dr["FReplaceGroup"].ToString(),
			FUseRate = dr["FUseRate"].ToString(),
			FIsTDL = dr["FIsTDL"].ToString(),
			FMoSeq = dr["FMoSeq"].ToString(),
			});
			}
			LogHelper.Info($"日计划用料清单，数据准备完成，保存到Model实体，总行数：{DayPlanMaterial.Count}，耗时：" + sw.Elapsed);
			var fidList = DayPlanMaterial.Select(x => x.FEntryID).Distinct().ToList();
			int i = 1;
			int jdtmmm = 1;
			JArray Fentity = new JArray();
			foreach (var item in fidList)
			{
			var _DayPlanMaterial = DayPlanMaterial.Where(x => x.FEntryID == item).ToList();
			var _DayPlanMaterial = DayPlanMaterial.Where(x => x.FEntryID == item).OrderBy(x => Convert.ToInt32(x.FReplaceGroup)).ToList();
			JObject model = new JObject();

			if (!string.IsNullOrEmpty(_DayPlanMaterial[0].FID))
			model.Add("FID", _DayPlanMaterial[0].FID);
			model.Add("FHDate", DateTime.Now);
			model.Add("FOrgId", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FOrgId });//发料组织
			model.Add("FHMaterID", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FHMaterID });//物料
			@@ -1736,7 +2629,10 @@
			model.Add("FHQty", _DayPlanMaterial[0].FHQty);//主产品数量：FHQty
			model.Add("FHUnitID", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FHUnitID });//单位：FHUnitID
			model.Add("FDayPlanFID", _DayPlanMaterial[0].FDayPlanFID);//日计划工单内码
			model.Add("FDayPlanFSEQ", _DayPlanMaterial[0].FDayPlanFSEQ);//日计划工单明细行号
			model.Add("FDayPlanFBillNo", _DayPlanMaterial[0].FDayPlanFBILLNO);//日计划工单单据编号
			JArray Entry = new JArray();
			int FSEQ = 1;
			foreach (var _item in _DayPlanMaterial)
			{
			JObject ModelEnty = new JObject();
			@@ -1749,77 +2645,133 @@
			ModelEnty.Add("FHSourceID", new JObject() { ["Fnumber"] = _item.FHSourceID });//生产资源FHSourceID
			ModelEnty.Add("FNumerator", _item.FNumerator);//分母
			ModelEnty.Add("FDenominator", _item.FDenominator);//分子
			ModelEnty.Add("FDwyl", Convert.ToDecimal(_item.FNumerator) / Convert.ToDecimal(_item.FDenominator));//单位用料
			ModelEnty.Add("FFIXSCRAPQTY", _item.FFIXSCRAPQTY);//固定损耗
			ModelEnty.Add("FHQtyScrap", _item.FHQtyScrap);//变动损耗率%
			ModelEnty.Add("FMOBILLNO", _item.FMOBILLNO);//
			ModelEnty.Add("FMOENTRYIDINT", _item.FMOENTRYID);//
			ModelEnty.Add("FMoSeq", _item.FMoSeq);//
			ModelEnty.Add("FPPBOMBILLNO", _item.FPPBOMBILLNO);//
			ModelEnty.Add("FPPBOMFSEQINT", _item.FPPBOMFSEQ);//
			ModelEnty.Add("FOwnerTypeId", _item.FOwnerTypeId);//
			ModelEnty.Add("FOwnerID", new JObject() { ["Fnumber"] = _item.FOwnerID });//
			ModelEnty.Add("FEntrustPickOrgId", new JObject() { ["Fnumber"] = _item.FEntrustPickOrgId });//
			ModelEnty.Add("FMOID", _item.FMOID);//
			ModelEnty.Add("FISSUETYPE", _item.FIssueType);//
			ModelEnty.Add("FMaterialType", _item.FMaterialType);//
			ModelEnty.Add("FWORKSHOPID", new JObject() { ["Fnumber"] = _item.FWORKSHOPID });//
			ModelEnty.Add("FReplaceGroup", _item.FReplaceGroup);//
			ModelEnty.Add("FUseRate", _item.FUseRate);//
			ModelEnty.Add("FIsTDL", Convert.ToInt32(_item.FIsTDL) > 0 ? 1 : 0);//
			Entry.Add(ModelEnty);
			FSEQ++;
			}
			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);
			Fentity.Add(model);
			if ((i >= 20 \|\| i == fidList.Count) && (i % 20 == 0 \|\| i == fidList.Count))
			{
			LogHelper.Info("日计划用料清单批量执行，记录循环的当前条数" + i);
			JObject jsonRoot = new JObject()
			{
			["Creator"] = "",
			["NeedUpDateFields"] = new JArray(),
			["NeedReturnFields"] = new JArray(),
			["IsDeleteEntry"] = "true",
			["SubSystemId"] = "",
			["IsVerifyBaseDataField"] = "false",
			["IsAutoSubmitAndAudit"] = true,//自动调用提交和审核功能
			["Model"] = Fentity
			};
			CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
			var result = cloudClient.BatchSave("Paez_Sc_DayPlanPPBomBill", jsonRoot.ToString());
			JObject saveObj = JObject.Parse(result);
			string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
			if (saveIsSuc == "TRUE")
			{
			var Success = saveObj["Result"]["ResponseStatus"]["SuccessEntitys"].ToString().TrimStart('{').TrimEnd('}');
			var allList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Dictionary<string, string>>>(Success);
			List<string> ls = new List<string>();
			foreach (var it in allList)
			{
			it.TryGetValue("Id", out string value);
			ls.Add(value);
			}
			var resultAA = String.Join(",", ls.ToArray());
			string resSql = string.Format(@"/dialect/ update Sc_WorkBillSortBillSub set Sc_WorkBillSortBillSub.FDAYPLANPPBOMBILLNO = Sc_DayPlanPPBomBillMain.FBILLNO from Sc_WorkBillSortBillSub join Sc_DayPlanPPBomBillMain on Sc_WorkBillSortBillSub.FEntryID = Sc_DayPlanPPBomBillMain.FDayPlanFID where Sc_DayPlanPPBomBillMain.FID in ({0})", resultAA);
			DBServiceHelper.Execute(Context, resSql);
			}
			if (saveIsSuc != "TRUE")
			{
			//LogHelper.Error("日计划用料清单列表生成失败:" + jsonRoot.ToString());
			LogHelper.Error(saveObj.ToString());
			return "操作失败，" + saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString();
			//this.View.ShowMessage(saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString());
			}
			Fentity = new JArray();
			}
			i++;

			this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(80) / fidList.Count) * jdtmmm);
			//Thread.Sleep(6000);
			jdtmmm++;
			}
			}
			sw.Stop();//结束计时
			LogHelper.Info("生成日计划用料清单运行总时长：" + sw.Elapsed);
			return "操作成功";
			}
			catch (Exception ex)
			{
			LogHelper.Error(ex.Message.ToString());
			LogHelper.Error("日计划用料清单+" + ex.Message.ToString());
			return "操作失败，" + ex.Message.ToString();
			//this.View.ShowErrMessage(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)
			LogHelper.Info("[提料计划准备阶段]：测试测试测试测试测试测试测试测试");
			try
			{
			FDayPlanWorkID += Convert.ToString(dr["FID"]) + ",";
			}

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

			//提料计划预处理清理提料计划单数据更新采购订单提料计划数量
			sql = string.Format(@"
			Stopwatch sw = new Stopwatch();
			sw.Start();//开始计时
			string sql = string.Format(@"/dialect/ select distinct FHICMOINTERID FID from JIT_MOMaterReadysBill ");
			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(@"
			/dialect/
			exec [提料计划预处理] '{0}'
			", FDayPlanWorkID.Replace(",", "-"));

			DBServiceHelper.Execute(Context, sql);
			//采购订单数据
			sql = @"
			DBServiceHelper.Execute(Context, sql);
			LogHelper.Info("[提料计划准备阶段]提料计划预处理sql：" + 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
			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')
			and t1.FBillTypeID in('83d822ca3e374b4ab01e5dd46a0062bd','6d01d059713d42a28bb976c90a121142')
			";
			List<PurchaseInventory> PurchaseInventory = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList<PurchaseInventory>();
			LogHelper.Info("采购订单数据" + sql);

			sql = string.Format(@"
			List<PurchaseInventory> PurchaseInventory = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList<PurchaseInventory>();
			LogHelper.Info("[提料计划准备阶段]可用采购订单数据sql：" + sql);
			sql = string.Format(@"
			/dialect/
			SELECT T1.FID,FHMATERID,FHMASTERDATE,FHQTY,FCOMPLETECOUNT,FPRDMOMAINID,T2.FENTRYID,T1.FBILLNO, FNeedQty,(FLeadtime+FLeadTtime2)FFIXLEADTIME,t5.FMAXPOQTY,FJITBatch FMINPOQTY,FJITMATERIALGROUP,FJITMaterielDemand,FJITSafeStock,t3.FMATERIALID,t6.FNumber,FHQTY*FNeedQty NeedQty,FHPRDORGID FStockOrgId FROM SC_WORKBILLSORTBILLMAIN T1
			SELECT T1.FID,FHMATERID,FHMASTERDATE,FHQTY,FCOMPLETECOUNT,FPRDMOMAINID,T2.FENTRYID,T1.FBILLNO, FNeedQty,(FLeadtime+FLeadTtime2)FFIXLEADTIME,t5.FMAXPOQTY,FJITBatch FMINPOQTY,FJITMATERIALGROUP,FJITMaterielDemand,FJITSafeStock,t3.FMATERIALID,t6.FNumber,FHQTY*FNeedQty NeedQty,FHPRDORGID FStockOrgId
			FROM SC_WORKBILLSORTBILLMAIN T1
			JOIN SC_WORKBILLSORTBILLSUB T2 ON T1.FID=T2.FID
			LEFT JOIN(SELECT T1.FID,max(t2.FMATERIALID)FMATERIALIDMAIN, max(t2.FMoId)FMoId,MAX(FENTRYID) FENTRYID, SUM(convert(decimal(18, 2), FBASENUMERATOR / FBASEDENOMINATOR))FNeedQty, T1.FMATERIALID from T_PRD_PPBOMENTRY T1
			JOIN T_PRD_PPBOM T2 on t1.FID = t2.FID
			@@ -1828,67 +2780,99 @@
			join t_BD_MaterialBase t4 on t3.FMATERIALID = t4.FMATERIALID
			join t_BD_MaterialPlan t5 on t3.FMATERIALID = t5.FMATERIALID
			WHERE DATEDIFF(D,GETDATE(),FHMASTERDATE) >=0
			AND FDayPlanQuantity>FCOMPLETECOUNT
			AND FComplete ='未齐套'
			AND FERPCLSID=1
			AND T2.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;//提前期
			string FJITmaterialGroup = _DayPlanPpbom.FirstOrDefault().FJITmaterialGroup;//jit物料分类
			string FJITMaterielDemand = _DayPlanPpbom.FirstOrDefault().FJITMaterielDemand; //JIT物料需求供货周期
			string FJITSafeStock = _DayPlanPpbom.FirstOrDefault().FJITSafeStock; //JIT安全库存
			decimal NeedQty = 0;
			DateTime DATE = _DayPlanPpbom.FirstOrDefault().FHMASTERDATE;
			int i = 1;
			//记录在最小采购量需求下的日计划明细FentyrID
			List<int> FEntryIdList = new List<int>();
			foreach (var _item in _DayPlanPpbom)
			sql = string.Format(@"
			/dialect/
			SELECT T1.FID,FHMASTERDATE,t1.FEntryID,T1.FBILLNO, FNeedQty,(FLeadtime+FLeadTtime2)FFIXLEADTIME,t5.FMAXPOQTY,FJITBatch FMINPOQTY,FJITMATERIALGROUP,FJITMaterielDemand,FJITSafeStock,t1.FMATERIALID,t6.FNumber,NeedQty, FStockOrgId ,FErpClsID
			FROM (
			select FHICMOINTERID FID,FHICMOENTRYID FEntryID,FPlanDate FHMASTERDATE,FLackCount NeedQty,FHMATERID FMATERIALID,FHStockOrgID FStockOrgId,FPRDBILLNO FBillNo,FSumPlanCount FNeedQty from JIT_MOMaterReadysBill a
			right join (select max(FID)FID from JIT_MOMaterReadysBill GROUP BY FHICMOENTRYID,FHMATERID) b on a.FID = b.FID
			)T1
			JOIN T_BD_MATERIAL T6 ON T1.FMATERIALID = T6.FMATERIALID
			join t_BD_MaterialBase t4 on T1.FMATERIALID = t4.FMATERIALID
			join t_BD_MaterialPlan t5 on T1.FMATERIALID = t5.FMATERIALID
			WHERE DATEDIFF(D,GETDATE(),FHMASTERDATE) >=0
			AND FERPCLSID in ('1','3')
			AND T1.NeedQty>0
			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：" + 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 == "163165").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)
			{
			if (NeedQty == 0)
			DATE = Convert.ToDateTime(_item.FHMASTERDATE).AddDays(-FFIXLEADTIME);
			FEntryIdList.Add(_item.FENTRYID);
			NeedQty += _item.NeedQty;
			if ((FJITmaterialGroup == "总量控制规格类" \|\| FJITmaterialGroup == "订单专用个性类") && FEntryIdList.Count < Convert.ToInt32(FJITMaterielDemand)) //订单专用个性类
			continue;
			if (NeedQty >= FMINPOQTY)
			//当前物料没有采购订单时直接跳出
			List<PurchaseInventory> _PurchaseInventory = PurchaseInventory.Where(x => x.FMATERIALID == item.FMATERIALID && x.FStockOrgId == item.FStockOrgId && x.FQTY > 0).OrderBy(x => x.FENTRYID).ToList();
			if (_PurchaseInventory.Count == 0)
			{
			List<PurchaseInventory> _PurchaseInventory = PurchaseInventory.Where(x => x.FMATERIALID == item.FMATERIALID && x.FStockOrgId == item.FStockOrgId && x.FQTY > 0).ToList();
			LogHelper.Info("[提料计划开始]当前物料无采购信息：" + item.FMATERIALID + " 库存组织：" + item.FStockOrgId);
			continue;
			}
			//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;//提前期
			string FJITmaterialGroup = _DayPlanPpbom.FirstOrDefault().FJITmaterialGroup;//jit物料分类
			string FJITMaterielDemand = _DayPlanPpbom.FirstOrDefault().FJITMaterielDemand; //JIT物料需求供货周期
			string FJITSafeStock = _DayPlanPpbom.FirstOrDefault().FJITSafeStock; //JIT安全库存
			decimal NeedQty = 0;
			DateTime DATE = _DayPlanPpbom.FirstOrDefault().FHMASTERDATE;//第一个订货起始日期
			int i = 0;
			//记录在最小采购量需求下的日计划明细FentyrID
			List<int> FEntryIdList = new List<int>();
			foreach (var _item in _DayPlanPpbom)
			{
			i++;
			_PurchaseInventory = PurchaseInventory.Where(x => x.FMATERIALID == item.FMATERIALID && x.FStockOrgId == item.FStockOrgId && x.FQTY > 0).OrderBy(x => x.FENTRYID).ToList();
			if (_PurchaseInventory.Count == 0)
			{
			NeedQty = 0;
			//LogHelper.Info("[提料计划开始]当前物料明细无采购信息：" + item.FMATERIALID + " 库存组织：" + item.FStockOrgId);
			break;
			}

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

			//LogHelper.Info("记录明细id：" + _item.FENTRYID + "");
			//LogHelper.Info("总需求量：" + NeedQty + "");
			//LogHelper.Info("最小起订量：" + FMINPOQTY + "");
			if (NeedQty <= FMINPOQTY)
			{
			LogHelper.Info("[提料计划]当前物料明细无采购信息：" + item.FMATERIALID + ",数量：" + NeedQty + "，最小起订量：" + FMINPOQTY + "");
			}

			if ((FJITmaterialGroup == "总量控制规格类" \|\| FJITmaterialGroup == "订单专用个性类") && FEntryIdList.Count < Convert.ToInt32(FJITMaterielDemand) && i < _DayPlanPpbom.Count) //订单专用个性类
			continue;

			//if (NeedQty >= FMINPOQTY)
			//{
			foreach (var Purchase in _PurchaseInventory)
			{
			LogHelper.Info("Purchase");
			LogHelper.Info("物料：" + Purchase.FMATERIALID + ",数量：" + Purchase.FQTY);
			//LogHelper.Info("采购订单号测试：" + Purchase.FBillNo);
			//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
			{
			@@ -1901,6 +2885,7 @@
			FNumber = DayPlanPpbomls.FNumber,
			OLDDATE = DayPlanPpbomls.FHMASTERDATE,
			FFIXLEADTIME = FFIXLEADTIME,
			FErpClsID = DayPlanPpbomls.FErpClsID,

			PurchseFID = Purchase.FID,
			PurchseFentryID = Purchase.FENTRYID,
			@@ -1924,16 +2909,24 @@
			}
			else
			{
			//更新总需求数量
			NeedQty = NeedQty - Purchase.FQTY;
			decimal _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;
			decimal Qty = DayPlanPpbomls.NeedQty;//订单数量
			//if (Qty == 0)
			// LogHelper.Info("订单数量为0");
			if (Qty > _NeedQty)
			Qty = _NeedQty;
			_NeedQty = _NeedQty - DayPlanPpbomls.NeedQty;
			Qty = _NeedQty; //订单数量>采购订单数量取采购订单

			//if (_NeedQty == 0)
			// LogHelper.Info("订单数量为0");

			_NeedQty = _NeedQty - Qty;
			PODemandPlanTemp.Add(new Demo.Model.Model.PODemandPlan.PODemandPlanTemp
			{
			FID = DayPlanPpbomls.FID,
			@@ -1945,6 +2938,7 @@
			FNumber = DayPlanPpbomls.FNumber,
			OLDDATE = DayPlanPpbomls.FHMASTERDATE,
			FFIXLEADTIME = FFIXLEADTIME,
			FErpClsID = DayPlanPpbomls.FErpClsID,

			PurchseFID = Purchase.FID,
			PurchseFentryID = Purchase.FENTRYID,
			@@ -1955,13 +2949,14 @@
			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)
			if (_NeedQty <= 0)
			{
			foreach (var mm in mmm)
			{
			@@ -1971,202 +2966,197 @@
			}
			mmm.Add(id);
			}
			foreach (var mm in mmm)
			{
			FEntryIdList.Remove(mm);
			}
			//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

			}

			#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();
			LogHelper.Info($"提料计划，数据准备完成，保存到Model实体，总行数：{PODemandPlanTemp.Count}，耗时：" + sw.Elapsed);
			int tlmmm = 1;
			JArray FinalyResult = new JArray();
			foreach (var item in PODemandPlanList)
			{
			DateTime date = item.FHMASTERDATE;
			string PurchseFNUMBER = item.PurchseFNUMBER;
			JObject model = new JObject();
			model.Add("FHDate", date);
			model.Add("FSettleCurrId", new JObject() { ["Fnumber"] = "PRE001" });
			model.Add("FSupplierID", new JObject() { ["Fnumber"] = PurchseFNUMBER });

			JArray Fentity = new JArray();
			List<PODemandPlanTemp> _PODemandPlanList = PODemandPlanTemp.Where(x => x.FHMASTERDATE == date && x.PurchseFNUMBER == PurchseFNUMBER).ToList();
			int FSEQ = 1;
			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
			FentityModel.Add("FERPCLSID", _item.FErpClsID); //发料方式
			//FentityModel.Add("FSEQ", FSEQ); //发料方式
			FentityModel.Add("FUnitID", new JObject() { ["Fnumber"] = "Pcs" }); //发料方式

			Fentity.Add(FentityModel);
			FSEQ++;
			}
			model.Add("FEntity", Fentity);
			FinalyResult.Add(model);
			if ((tlmmm >= 20 \|\| tlmmm == PODemandPlanList.Count) && (tlmmm % 20 == 0 \|\| tlmmm == PODemandPlanList.Count))
			{
			LogHelper.Info("提料计划新增批量执行，记录循环的当前条数" + tlmmm);
			JObject jsonRoot = new JObject()
			{
			["Creator"] = "",
			["NeedUpDateFields"] = new JArray(),
			["NeedReturnFields"] = new JArray(),
			["IsDeleteEntry"] = "false",
			["SubSystemId"] = "",
			["IsVerifyBaseDataField"] = "false",
			["Model"] = FinalyResult
			};
			CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
			var result = cloudClient.BatchSave("paez_PODemandPlan", jsonRoot.ToString());
			JObject saveObj = JObject.Parse(result);
			string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
			if (saveIsSuc != "TRUE")
			{
			LogHelper.Error(jsonRoot.ToString());
			}
			FinalyResult = new JArray();
			}
			tlmmm++;
			}
			sw.Stop();//结束计时
			LogHelper.Info("提料计划执行完成，运行总时长：" + sw.Elapsed);
			DBServiceHelper.ExecuteBatch(Context, sqlList);
			}

			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)
			catch (Exception ex)
			{
			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);

			}
			LogHelper.Info("提料计划跳出：" + ex.Message.ToString());
			}
			DBServiceHelper.ExecuteBatch(Context, sqlList);
			// var PODemandPlanList22 = PODemandPlanTemp.GroupBy(p => new {p.FSUPPLIERID, p.FHMASTERDATE }).ToList();
			}
			/// <summary>
			@@ -2186,7 +3176,14 @@
			Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
			//单据体信息转换为列表集合
			DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
			EntryGrid grid = this.View.GetControl<EntryGrid>("FEntity");
			DynamicObjectCollection filterResult = entityDataObjoct.Clone();
			filterResult.Clear();
			entityDataObjoct.Where(x => Convert.ToBoolean(x["FFOCUS"])).ToList().ForEach(x => filterResult.Add(x));
			if (filterResult.Count == 0)
			{
			this.View.ShowMessage("请选择需要预留的单据！");
			return;
			}
			//总库存物料+库存组织+库存数量
			DataSet ds = DBServiceHelper.ExecuteDataSet(Context, @"
			/dialect/
			@@ -2265,7 +3262,7 @@
			}
			sql = string.Format(@"/dialect/
			--生产用料清单列表
			SELECT T1.FID,T1.FBillNo,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,FPRDORGID FStockOrgId,
			SELECT T1.FID,T1.FBillNo,T2.FENTRYID,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,FPRDORGID FStockOrgId,
			T2.FMATERIALID FMATERIALID2,T4.FNumber,T2.FNeedQty,convert(decimal(18,2),FNeedQty/T1.FQty ) as dwyl,
			t5.FBASEUNITID,t6.FSTOREUNITID,t7.FID FSTKID,t7.FOwnerID,t7.FOwnerTypeID,t7.FSTOCKID,t7.FBASEQTY
			--,isnull(t3.FBASEQTY,0)FBASEQTY
			@@ -2285,15 +3282,15 @@
			foreach (DataRow dr in skDt.Rows)
			{
			LockStockArgs lockStockArgs = new LockStockArgs();
			lockStockArgs.ObjectId = "SAL_SaleOrder";
			lockStockArgs.BillId = Convert.ToString(current["FHMainSourceInterID"]); //生产订单ID
			lockStockArgs.BillNo = Convert.ToString(current["FSCOrderNo"]);//生产订单号
			lockStockArgs.FID = Convert.ToInt32(current["FHMainSourceInterID"]); //生产订单ID
			lockStockArgs.ObjectId = "PRD_PPBOM"; //字段 FDEMANDFORMID = 'PRD_PPBOM'
			lockStockArgs.BillId = dr["FID"].ToString(); //生产用料清单主表ID
			lockStockArgs.BillDetailID = dr["FENTRYID"].ToString();//生产用料清单明细表ID
			lockStockArgs.BillNo = dr["FBillNo"].ToString();//生产用料清单单据号
			lockStockArgs.FEntryID = Convert.ToInt32(current["FHMainSourceEntryID"]); ;
			lockStockArgs.FID = Convert.ToInt32(current["FHMainSourceInterID"]); //生产订单行ID
			lockStockArgs.BaseQty = decimal.Parse(dr["FBASEQTY"].ToString());//基本单位数量
			lockStockArgs.BaseUnitID = int.Parse(dr["FBASEUNITID"].ToString());//基本单位
			lockStockArgs.BillDetailID = Convert.ToString(current["FHMainSourceEntryID"]);
			lockStockArgs.FEntryID = Convert.ToInt32(current["FHMainSourceEntryID"]); ;
			//lockStockArgs.Lot = Convert.ToString(current["FBatch"]); ;//批次 FBatch
			//lockStockArgs.Lot = Convert.ToString(current["FBatch"]); ;//批次 FBatch
			lockStockArgs.MaterialID = long.Parse(dr["FMATERIALID2"].ToString());
			lockStockArgs.OwnerID = long.Parse(dr["FOwnerID"].ToString());
			lockStockArgs.OwnerTypeID = dr["FOwnerTypeID"].ToString();
			@@ -2307,6 +3304,20 @@
			list.Add(lockStockArgs);
			}
			var sa = StockServiceHelper.SaveLockInfo(Context, list, "Inv", false);
			sql = @"/dialect/
			update a set
			FPARENTFORMID ='PRD_MO',
			FPARENTINTERID =b.FMOID,
			FPARENTENTRYID =b.FMOENTRYID,
			FPARENTBILLNO = b.FMOBILLNO,
			FSRCFORMID = 'PRD_MO',
			FSRCINTERID = b.FMOID,
			FSRCENTRYID = b.FMOENTRYID,
			FSRCBILLNO = b.FMOBILLNO
			from T_PLN_RESERVELINK a
			join T_PRD_PPBOM b on a.FDEMANDINTERID = b.FID
			where a.FPARENTINTERID = '' and a.FPARENTENTRYID =''";
			DBServiceHelper.Execute(Context, sql);
			this.View.ShowMessage("操作成功！");
			}
			}
			@@ -2329,13 +3340,23 @@
			DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
			DynamicObjectCollection filterResult = entityDataObjoct.Clone();
			filterResult.Clear();
			entityDataObjoct.Where(x => Convert.ToBoolean(x["FFOCUS"])).ToList().ForEach(x=> filterResult.Add(x));
			foreach (DynamicObject current in entityDataObjoct)
			entityDataObjoct.Where(x => Convert.ToBoolean(x["FFOCUS"])).ToList().ForEach(x => filterResult.Add(x));
			if (filterResult.Count == 0)
			{
			this.View.ShowMessage("请选择需要预留的单据！");
			return;
			}
			foreach (DynamicObject current in filterResult)
			{
			if (Convert.ToString(current["FFOCUS"]) == "False")
			continue;
			string sql = string.Format(@"/dialect/ update Sc_WorkBillSortBillSub set FReservedCount = 0 where FID='{0}'", current["FDayPlanWorkID"].ToString());
			DBServiceHelper.Execute(Context, sql);

			//删除锁库表(不用更新库存库存表没有更)
			sql = string.Format(@"/dialect/
			delete T_PLN_RESERVELINKENTRY where FID IN (SELECT FID FROM T_PLN_RESERVELINK WHERE FPARENTINTERID='{0}' AND FPARENTENTRYID='{1}')
			delete T_PLN_RESERVELINK WHERE FPARENTINTERID='{0}' AND FPARENTENTRYID='{1}'", Convert.ToString(current["FHMainSourceInterID"]), Convert.ToString(current["FHMainSourceEntryID"]));
			}
			this.View.ShowMessage("操作成功！");
			}
			@@ -2345,6 +3366,51 @@
			this.View.ShowErrMessage(ex.Message.ToString());
			}
			}

			public void SelectMenu()
			{
			//获取单据体信息
			Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
			//单据体信息转换为列表集合
			DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
			int Fseq = entityDataObjoct.Count();

			string pageId = Guid.NewGuid().ToString();
			ListShowParameter showParameter = new ListShowParameter();
			showParameter.FormId = "PRD_MO";
			showParameter.PageId = pageId;
			showParameter.UseOrgId = this.Context.CurrentOrganizationInfo.ID;
			showParameter.IsLookUp = true;
			this.View.ShowForm(showParameter);

			this.View.ShowForm(showParameter, delegate (FormResult result)
			{
			object returnData = result.ReturnData;
			if (returnData is ListSelectedRowCollection)
			{
			ListSelectedRowCollection listSelectedRowCollection = returnData as ListSelectedRowCollection;
			if (listSelectedRowCollection != null)
			{
			foreach (var listSelectedRow in listSelectedRowCollection)
			{
			string sql = $"select DATEDIFF(d,FPlanStartDate,getdate())days from T_PRD_MOENTRY where FENTRYID = {listSelectedRow.DataRow["t1_FENTRYID"].ToString()}";
			int day = DBServiceHelper.ExecuteScalar<int>(Context, sql, 0);
			this.Model.CreateNewEntryRow("FEntity");
			this.View.Model.SetItemValueByNumber("FORGID", "100", Fseq);
			this.View.Model.SetValue("FSCOrderNo", listSelectedRow.DataRow["FBillNo"].ToString(), Fseq);
			this.View.Model.SetValue("FSRCBILLENTRYSEQ", listSelectedRow.DataRow["t1_FSeq"].ToString(), Fseq);
			this.View.Model.SetValue("FMatrailId", listSelectedRow.DataRow["FMaterialId_Id"].ToString(), Fseq);//2129900005
			this.View.Model.SetValue("FFUnit", listSelectedRow.DataRow["FUnitId_Id"].ToString(), Fseq);
			this.View.Model.SetValue("FOrderQuantity", listSelectedRow.DataRow["FQty"].ToString(), Fseq);
			this.View.Model.SetValue("FProductWorkShopId", listSelectedRow.DataRow["FWorkShopID_Id"].ToString(), Fseq);
			this.View.Model.SetValue("FOrderLevel", "3", Fseq);
			this.View.Model.SetValue("FT" + day.ToString(), listSelectedRow.DataRow["FQty"].ToString(), Fseq);
			Fseq++;
			}
			}
			}
			});
			}
			}
			}