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.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.Metadata;
using Kingdee.BOS.Core.Metadata.EntityElement;
using Kingdee.BOS.JSON;
using Kingdee.BOS.KDThread;
using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.ServiceHelper;
using Kingdee.BOS.ServiceHelper.FileServer;
using Kingdee.BOS.Util;
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.IO;
using System.Linq;
using System.Runtime.CompilerServices;
using System.Runtime.InteropServices;
using System.Text;
using System.Threading.Tasks;
using System.Web;
using System.Windows.Documents;
using ZD.Cloud.Logger;
using ZD.Cloud.WebApi;
using ZD.Share.Common;

namespace Demo.DynamicForm.PRD
{
    [Description("生产计划平台按钮功能")]
    [HotUpdate]
    public class Pro_WorkBillPlatform : AbstractDynamicFormPlugIn
    {
        string _OutServicePath = "";
        string PathName = "日计划导入模板.xlsx";
        List<PRD_Inventory> ListInventory;

        public override void BarItemClick(BarItemClickEventArgs e)
        {
            base.BarItemClick(e);
            try
            {
                if (e.BarItemKey.ToUpper() == "BTEXPORT")
                {
                    ExportExcel();
                    //this.View.ShowMessage("测试啦");


                    string path = PathUtils.GetServerPath(KeyConst.TEMPFILEPATH, PathName);

                    DynamicFormShowParameter dynamicForm = new DynamicFormShowParameter();
                    dynamicForm.FormId = "BOS_FileDownLoad";
                    dynamicForm.OpenStyle.ShowType = ShowType.Modal;
                    dynamicForm.CustomParams.Add("IsExportData", "true");
                    dynamicForm.CustomParams.Add("url", path);

                    this.View.ShowForm(dynamicForm);


                    //ShowDownload();

                }

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

                if (e.BarItemKey.ToUpper() == "TBLOCK")
                {
                    Lock();
                }

                if (e.BarItemKey.ToUpper() == "BTNSAVE")
                {
                    Save();
                }

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

            }
            catch (Exception ex)
            {
                this.View.ShowErrMessage(ex.Message.ToString());
            }
        }
        public override void EntryBarItemClick(BarItemClickEventArgs e)
        {
            base.EntryBarItemClick(e);

            if (e.BarItemKey.ToUpper() == "TBEDIT")
            {
                SearchList222();
            }
        }
        /// <summary>
        /// 行双击 跳出齐套分析明细列表
        /// </summary>
        /// <param name="e"></param>
        public override void EntityRowDoubleClick(Kingdee.BOS.Core.DynamicForm.PlugIn.Args.EntityRowClickEventArgs e)
        {
            var m = e.Row;
            var n = e.Key;
            base.EntityRowClick(e);
            DynamicFormShowParameter formPa = new DynamicFormShowParameter();
            formPa.FormId = "paez_CompleteAnalysisDetail";

            /* jsonModel.Add("FHMainICMOInterID", FMainInterID);//主生产订单主内码
             jsonModel.Add("FHMainICMOEntryID", FMainEntryID);//主生产订单子内码
             jsonModel.Add("FHICMOInterID", FDayPlanWorkID);//日计划订单主内码
            current["FMatrailId_Id"].ToString(), current["FHMainSourceInterID"].ToString(), current["FHMainSourceEntryID"].ToString(), current["FDayPlanWorkID"].ToString())

            */

            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>
        /// 导出数据到Excel
        /// </summary>
        public void ExportExcel()
        {
            string[] Title = new 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"};

            string sheetname = "日计划导入模板.xlsx";
            string file = "";
            file = @"D:\办公\K3Cloud\WebSite\TempfilePath\" + sheetname;

            //@"D:\办公\K3Cloud\WebSite\";
            //通过Directory类的CreateDirectory方法创建。
            string activeDir = AppDomain.CurrentDomain.BaseDirectory;
            string newPath = System.IO.Path.Combine(activeDir, "TempfilePath");
            System.IO.Directory.CreateDirectory(newPath);

            file = newPath + "\\" + sheetname;
            //Server.MapPath("/");
            DataTable dt = null;
            HSSFWorkbook xssfworkbook = new HSSFWorkbook();//建立Excel2003对象
            HSSFSheet sheet = (HSSFSheet)xssfworkbook.CreateSheet(sheetname);//新建一个名称为sheetname的工作簿



            //设置基本样式
            ICellStyle style = xssfworkbook.CreateCellStyle();
            style.WrapText = true;
            IFont font = xssfworkbook.CreateFont();
            font.FontHeightInPoints = 9;
            font.FontName = "Arial";
            style.SetFont(font);

            //设置统计样式
            ICellStyle style1 = xssfworkbook.CreateCellStyle();
            style1.WrapText = true;
            IFont font1 = xssfworkbook.CreateFont();
            font1.FontHeightInPoints = 9;
            font1.Boldweight = (short)NPOI.SS.UserModel.FontBoldWeight.Bold;
            font1.FontName = "Arial";
            style1.SetFont(font1);

            //设置大类样式
            ICellStyle style2 = xssfworkbook.CreateCellStyle();
            style2.WrapText = true;
            //style2.FillBackgroundColor = NPOI.HSSF.Util.HSSFColor.Gold.Index;
            //style2.FillPattern = FillPattern.SolidForeground;
            IFont font2 = xssfworkbook.CreateFont();
            font2.FontHeightInPoints = 9;
            font2.Boldweight = (short)NPOI.SS.UserModel.FontBoldWeight.Bold;
            font2.FontName = "Arial";
            style2.SetFont(font2);

            //设置列名
            HSSFRow row = (HSSFRow)sheet.CreateRow(0);
            for (int i = 0; i < Title.Length; i++)
            {
                ICell cell = (ICell)row.CreateCell(i);
                var rowName = Title[i];
                cell.SetCellValue(rowName);
                cell.CellStyle = style;
            }

            //单元格赋值
            //列宽自适应，只对英文和数字有效
            for (int i = 0; i <= Title.Length; i++)
            {
                sheet.AutoSizeColumn(i);
            }
            using (System.IO.Stream stream = System.IO.File.OpenWrite(file))
            {
                xssfworkbook.Write(stream);
                stream.Close();
                _OutServicePath = file;

            }

        }


        private string _fileId = string.Empty;
        /// <summary>
        /// 弹出下载提示窗，下载文件至客户端本地。
        /// </summary>
        public void ShowDownload()
        {

            _fileId = "2000avbbb";
            string url = FileServerHelper.GetAppSiteOuterNetUrl(this.Context, HttpContext.Current.Request);
            //fileId文件编码可由 T_BAS_ATTACHMENT 附件明细表查得，此处直接拿上面上传文件的编码来做示例。
            string fileurl = string.Format("{0}FileUpLoadServices/download.aspx?fileId={1}&token={2}",
                url, _fileId, this.Context.UserToken);

            JSONObject jObject = new JSONObject();
            jObject.Put("url", HttpUtility.UrlEncode(fileurl));
            jObject.Put("title", "文件下载");
            jObject.Put("desc", "请点击打开附件：");
            jObject.Put("urltitle", "这是文件名");
            this.View.AddAction(JSAction.openUrlWindow, new JSONArray { jObject });
        }

        /// <summary>
        /// 锁定
        /// </summary>
        public void Lock()
        {
            int day = Convert.ToInt32(this.Model.GetValue("FLockDays"));

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

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

            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())   " + sqlwhere;

            int result = DBUtils.Execute(Context, sql);
            if (result > 0)
            {
                SearchList222();
                this.View.ShowMessage("操作成功");
            }
            else
                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;

            foreach (DynamicObject current in entityDataObjoct)
            {
                for (int i = 0; i <= 60; i++)
                {
                    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);
                }

            }

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

        }

        /// <summary>
        /// 齐套分析
        /// </summary>
        /// 
        private void COMPLETE()
        {

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

            // 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(() =>
            {
                try
                {
                    // 需要捕获错误，以确保处理结束时，关闭进度滚动界面

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

                    // 引入完毕，关闭进度显示页面
                    var processView = this.View.GetView(processForm.PageId);
                    if (processView != null)
                    {
                        processView.Close();
                        this.View.SendDynamicFormAction(processView);
                    }
                }
            },
            (t) => { });
        }
        public void COMPLETEMAIN()
        {
            //获取当前即时库存
            DataSet ds = DBServiceHelper.ExecuteDataSet(Context, " /*dialect*/ select DISTINCT FBASEQTY,FMATERIALID from T_STK_Inventory");
            ListInventory = 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)
            {
                int m = 0;
                foreach (DynamicObject current in entityDataObjoct)
                {
                    //计划总数量
                    decimal SumPlan = 0;
                    for (int i = 0; i <= 60; i++)
                    {
                        SumPlan += Convert.ToDecimal(current["FT" + "" + i + ""]);
                    }

                    double Sum = 100;
                    Sum = Convert.ToDouble(SumGetComplete(current["FMatrailId_Id"].ToString(), current["FHMainSourceInterID"].ToString(), current["FHMainSourceEntryID"].ToString(), current["FDayPlanWorkID"].ToString(), SumPlan));
                    this.View.Model.SetValue("FCompleteSetCount", Sum, m);
                    this.View.UpdateView("FCompleteSetCount");
                    //保存齐套数 
                    DBServiceHelper.Execute(Context, "/*dialect*/ update Sc_WorkBillSortBillMain set FCompleteCount='" + Sum + "',FPlanCount='" + 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("请先加载数据！");
            }

        }

        /// <summary>
        /// 计算最大齐套数量
        /// </summary>
        /// <param name="FMATERIALID"> 物料Number</param>
        /// <param name="FMainInterID"> 生产订单主码</param>
        /// <param name="FMainEntryID"> 生产订单子码</param>
        /// <param name="FDayPlanWorkID"> 日计划工单FID</param>
        /// <param name="FDayPlanWorkID"> 计划总数量</param>
        /// <returns></returns>
        public string SumGetComplete(string FMATERIALID, string FMainInterID, string FMainEntryID, string FDayPlanWorkID, decimal SumPlan)
        {
            //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 = ListInventory.Where(c => c.FMATERIALID == t.FMATERIALID2).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 UnitDosage = item.FNeedQty / item.FQty;
                var ls = ListInventory.Where(c => c.FMATERIALID == item.FMATERIALID2).FirstOrDefault();
                if (ls != null)
                    ls.FBASEQTY -= SumGetComplete * (UnitDosage);
                // 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 物料

                jsonModel.Add("FHStockQty", Convert.ToDecimal(item.FBASEQTY));//及时库存数量
                jsonModel.Add("FHUseQty", Convert.ToDecimal(SumGetComplete * (UnitDosage)));//数量 
                jsonModel.Add("FHLeftQty", Convert.ToDecimal(item.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 工单编号  

                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("操作失败，联系管理员！");
                }
            }
            return SumGetComplete.ToString();
        }



        /// <summary>
        /// 查询
        /// </summary>
        public void SearchList222()
        {
            string sqlwhere = " where 1=1";

            if ((this.Model.GetValue("FProWorkShopId") as DynamicObject) != null)
            {
                string FProWorkShopId = (this.Model.GetValue("FProWorkShopId") as DynamicObject)["Id"].ToString();
                if (!string.IsNullOrEmpty(FProWorkShopId))
                    sqlwhere += $" and FProductWorkShopId='{FProWorkShopId}'";
            }
            //销售订单号
            string FSalOrder = Convert.ToString((this.Model.GetValue("FSalOrder")));
            if (string.IsNullOrEmpty(FSalOrder))
            {

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

            //物料
            if ((this.Model.GetValue("FMatralId") as DynamicObject) != null)
            {
                string FMatralId = (this.Model.GetValue("FMatralId") as DynamicObject)["Number"].ToString();
                if (!string.IsNullOrEmpty(FMatralId))
                    sqlwhere += $" and t3.FNumber='{FMatralId}'";
            }
            //编制日期
            string FPreparatDate = Convert.ToString((this.Model.GetValue("FPreparatDate")));
            if (!string.IsNullOrEmpty(FPreparatDate))
                sqlwhere += $" and FPreparatDate='{FPreparatDate}'";


            try
            {
                string sql = @"/*dialect*/select t1.* from  Sc_WorkBillSortBillMain t1
   left join T_BD_MATERIAL t3 on t1.FHMaterID=t3.FMATERIALID
" + sqlwhere;
                DataTable dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
                DateTime DateNow = DateTime.Now;//获取当前日期
                this.Model.DeleteEntryData("FEntity");
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    this.Model.CreateNewEntryRow("FEntity");
                    this.Model.SetValue("FSEQ", i + 1, 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("FBatch", dt.Rows[i]["FBatch"].ToString(), i);//批次号
                    this.Model.SetValue("FUnit", dt.Rows[i]["FHUnitID"].ToString(), i);//计量单位
                    this.Model.SetValue("FMatrailId", dt.Rows[i]["FHMaterID"].ToString(), i);//产品代码
                    this.Model.SetValue("FORGID", dt.Rows[i]["FHPRDORGID"].ToString(), i);//生产组织
                    this.Model.SetValue("FDeliverydate", dt.Rows[i]["FHOrderCommitDate"].ToString(), i);//交货日期
                    this.Model.SetValue("FOrderLevel", dt.Rows[i]["FHOrderLev"].ToString(), i);//订单等级
                    this.Model.SetValue("FSCOrderNo", dt.Rows[i]["FSCOrderNo"].ToString(), i);//生产订单号
                    this.Model.SetValue("FSalOrderNo", dt.Rows[i]["FHSEORDERBILLNO"].ToString(), i);//销售订单号
                    this.Model.SetValue("FBzDate", dt.Rows[i]["FPreparatDate"].ToString(), i);//编制日期
                    this.Model.SetValue("FProOrderCount", dt.Rows[i]["FHOrderNeedQty"].ToString(), i);//生产订单数量
                    this.Model.SetValue("FHMainSourceInterID", dt.Rows[i]["FPRDMOMAINID"].ToString(), i);//源单主内码FHMainSourceInterID
                    this.Model.SetValue("FHMainSourceEntryID", dt.Rows[i]["FPRDMOENTYID"].ToString(), i);//源单子内码FHMainSourceEntryID
                    this.Model.SetValue("FDayPlanWorkID", dt.Rows[i]["FID"].ToString(), i);//日计划工单FID

                    sql = @"/*dialect*/SELECT * FROM Sc_WorkBillSortBillSub WHERE DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0 and FID=" + dt.Rows[i]["FID"].ToString();
                    DataTable _dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
                    foreach (DataRow dr in _dt.Rows)
                    {
                        /*
                        this.Model.SetValue(dr["FColumn"].ToString(), dr["FHQTY"].ToString(), i);//日计划工单FID
                        if (dr["FHLockedSub"].ToString() == "1")
                            this.View.GetFieldEditor(dr["FColumn"].ToString(), i).Enabled = false; //单据体行锁定字段
                        */
                        DateTime start = Convert.ToDateTime(DateNow.ToShortDateString());
                        DateTime end = Convert.ToDateTime(Convert.ToDateTime(dr["FHMASTERDATE"]).ToShortDateString());
                        TimeSpan getDay = end.Subtract(start);
                        if (getDay.Days > 60)
                            continue;
                        this.Model.SetValue("FT" + getDay.Days.ToString(), dr["FHQTY"].ToString(), i);//日计划工单FID
                        if (dr["FHLockedSub"].ToString() == "1")
                            this.View.GetFieldEditor("FT" + getDay.Days.ToString(), i).Enabled = false; //单据体行锁定字段

                    }

                    this.View.InvokeFieldUpdateService("FMatrailId", i);//调用数量值更新

                }
                this.View.UpdateView();
                for (int j = 0; j < dt.Rows.Count; j++)
                {
                    sql = @"/*dialect*/SELECT * FROM Sc_WorkBillSortBillSub WHERE DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0 and FID=" + dt.Rows[j]["FID"].ToString();
                    DataTable _dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
                    foreach (DataRow dr in _dt.Rows)
                    {
                        DateTime start = Convert.ToDateTime(DateNow.ToShortDateString());
                        DateTime end = Convert.ToDateTime(Convert.ToDateTime(dr["FHMASTERDATE"]).ToShortDateString());
                        TimeSpan getDay = end.Subtract(start);
                        if (getDay.Days > 60)
                            continue;

                        if (dr["FHLockedSub"].ToString() == "1")
                            this.View.GetFieldEditor("FT" + getDay.Days.ToString(), j).Enabled = false; //单据体行锁定字段
                    }
                }

                for (int m = 0; m <= 60; m++)
                {
                    this.View.GetControl("FT" + "" + m + "").Text = DateNow.AddDays(m).ToShortDateString();
                }
            }
            catch (Exception ex)
            {
                this.View.ShowErrMessage(ex.Message.ToString());
            }


        }

        /// <summary>
        /// 提料计划
        /// </summary>

        public void Extraction2()
        {

            //获取单据体信息
            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)
            {
                this.View.ShowMessage("请先加载数据！");
            }
            else
            {
                foreach (DynamicObject current in entityDataObjoct)
                {

                    string FDayPlanWorkID = Convert.ToString(current["FDayPlanWorkID"]);//日工单ID
                    string FPRDMOMAINID = Convert.ToString(current["FHMainSourceInterID"]);//生产订单id
                    //是否有过齐套分析 找出齐套数量 日计划数量
                    string sql = string.Format(@"
/*dialect*/
 SELECT T1.FID,FHMATERID,FHMASTERDATE,FHQTY,FCOMPLETECOUNT,FPRDMOMAINID,T2.FENTRYID,T1.FBILLNO FROM  SC_WORKBILLSORTBILLMAIN T1 
JOIN SC_WORKBILLSORTBILLSUB T2 ON T1.FID=T2.FID
WHERE  DATEDIFF(D,GETDATE(),FHMASTERDATE) >=0
AND FPLANCOUNT>FCOMPLETECOUNT
AND T1.FID='{0}' AND FPRDMOMAINID='{1}'
", FDayPlanWorkID, FPRDMOMAINID);
                    DataSet ds = DBServiceHelper.ExecuteDataSet(Context, sql);
                    DataTable dt = ds.Tables[0];
                    if (dt.Rows.Count > 0)
                    {
                        string FMATERIALID = dt.Rows[0]["FHMaterID"].ToString();//物料编码
                        decimal FCompleteCount = Convert.ToDecimal(dt.Rows[0]["FCompleteCount"].ToString());//齐套数量

                        //按主物料查询子物料单位用料 最小采购 和 提前期
                        sql = string.Format(@"
/*dialect*/
SELECT  FNeedQty,t5.FFIXLEADTIME,t5.FMAXPOQTY,t5.FMINPOQTY,t2.FMATERIALID,t3.FNumber FROM T_PRD_PPBOM T1
LEFT JOIN(SELECT FID, MAX(FENTRYID) FENTRYID, SUM(convert(decimal(18, 2), FBASENUMERATOR / FBASEDENOMINATOR))FNeedQty, FMATERIALID from T_PRD_PPBOMENTRY where FMoId = '{0}'
group by FMATERIALID, FID) T2 on T1.FID = t2.FID
JOIN T_BD_MATERIAL T3 ON T2.FMATERIALID = t3.FMATERIALID
join t_BD_MaterialBase t4 on t3.FMATERIALID = t4.FMATERIALID
join t_BD_MaterialPlan t5 on t3.FMATERIALID = t5.FMATERIALID
WHERE T1.FMaterialID = '{1}'
AND FMoId = '{0}'
AND FERPCLSID=1  
", FPRDMOMAINID, FMATERIALID);
                        DataTable _dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
                        //根据bom去循环
                        foreach (DataRow drDetail in _dt.Rows)
                        {
                            string DetailFmaterialID = drDetail["FNumber"].ToString();//子物料
                            int FfixleadTime = Convert.ToInt32(drDetail["FFIXLEADTIME"].ToString());//提前天数
                            decimal FminPoqty = Convert.ToDecimal(drDetail["FMINPOQTY"].ToString());//最小采购量
                            decimal FNeedQty = Convert.ToDecimal(drDetail["FNeedQty"].ToString());//单位用料

                            //日计划数量(套数)
                            decimal FHQTY = 0;
                            foreach (DataRow dr in dt.Rows)
                            {
                                //日计划数量
                                decimal DayFHQTY = Convert.ToDecimal(dr["FHQTY"].ToString());
                                if (FCompleteCount >= DayFHQTY)
                                {
                                    FCompleteCount -= DayFHQTY;
                                    continue;
                                }
                                else if (FCompleteCount != 0)
                                {
                                    FHQTY = DayFHQTY - FCompleteCount;
                                    FCompleteCount = 0;
                                }
                                //提料计划日期
                                DateTime FHDate;
                                //套数*单位用料是否满足最小需求量
                                if (FHQTY * FNeedQty >= FminPoqty)
                                {
                                    FHDate = Convert.ToDateTime(dr["FHMASTERDATE"]);

                                    JObject model = new JObject();
                                    model.Add("FHDate", FHDate.AddDays(-FfixleadTime));
                                    model.Add("FHRemark", "生产订单号：" + "测试呢呢");

                                    JArray Fentity = new JArray();
                                    JObject FentityModel = new JObject();
                                    FentityModel.Add("FHMaterID", new JObject() { ["Fnumber"] = DetailFmaterialID });//物料
                                    FentityModel.Add("FHQty", FHQTY * FNeedQty);//数量
                                    FentityModel.Add("FHSourceInterID", dr["FID"].ToString());//日计划工单FID
                                    FentityModel.Add("FHSourceEntryID", dr["FENTRYID"].ToString());//日计划工单FENTRYID
                                    FentityModel.Add("FHSourceBillNo", dr["FBILLNO"].ToString());//日计划工单单号
                                    FentityModel.Add("FHSourceBillType", "");//日计划工单类型
                                    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();

                                    if (saveIsSuc == "TRUE")
                                    {
                                        //清空值
                                        FHQTY = 0;
                                        LogHelper.Info("单据日期:" + FHDate.AddDays(-FfixleadTime).ToString());
                                    }
                                    else
                                    {
                                        LogHelper.Error(saveIsSuc);

                                    }

                                }
                                else
                                {
                                    FHQTY += DayFHQTY;
                                    continue;
                                }

                            }

                        }

                    }
                }
            }

        }

        public void Extraction3()
        {

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

            //提料计划预处理 清理提料计划单数据 更新采购订单提料计划数量
            string sql = string.Format(@"
 /*dialect*/
 exec [提料计划预处理] '{0}'
 ", FDayPlanWorkID.Replace(",", "-"));

            DBServiceHelper.Execute(Context, sql);

            //采购订单数据
            sql = @"select t1.FID,t1.FBillNo,t2.FENTRYID,t1.FSUPPLIERID,t3.fnumber,t2.FMATERIALID,(t2.FQTY-t2.FPODemandPlanCount)FQTY 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
where t2.FQTY-t2.FPODemandPlanCount>0
";
            List<PurchaseInventory> PurchaseInventory = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList<PurchaseInventory>();

            sql = string.Format(@"
 /*dialect*/
 SELECT T1.FID,FHMATERID,FHMASTERDATE,FHQTY,FCOMPLETECOUNT,FPRDMOMAINID,T2.FENTRYID,T1.FBILLNO, FNeedQty,t5.FFIXLEADTIME,t5.FMAXPOQTY,t5.FMINPOQTY,t3.FMATERIALID,t6.FNumber,FHQTY*FNeedQty NeedQty  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 FPLANCOUNT>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);

            DataSet ds = DBServiceHelper.ExecuteDataSet(Context, sql);
            List<DayPlanPpbom> DayPlanPpbom = ds.ToModelList<DayPlanPpbom>();
            //物料集合 由物料去分组
            List<string> MaterialIDList = DayPlanPpbom.Select(x => x.FMATERIALID).Distinct().ToList();
            //提料计划数据集临时存储集合
            List<PODemandPlanTemp> PODemandPlanTemp = new List<PODemandPlanTemp>();
            //sql集合 更新采购订单占用的提料计划数量
            List<string> sqlList = new List<string>();
            foreach (string item in MaterialIDList)
            {
                List<DayPlanPpbom> _DayPlanPpbom = DayPlanPpbom.Where(x => x.FMATERIALID == item).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 && 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;
                    }
                    //剩下不足时按最小采购批次生成
                    else if (i == _DayPlanPpbom.Count && NeedQty > 0)
                    {
                        NeedQty = FMINPOQTY;
                        List<PurchaseInventory> _PurchaseInventory = PurchaseInventory.Where(x => x.FMATERIALID == item && 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;
                    }
                    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("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("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();

                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();
        }
    }
}