MES研发
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
王 垚
2021-04-13 58de9116152c3a0f8aa436a2c82b520ad940b367 
 src/BLL/Demo.BillView/PRD/Pro_WorkBillPlatform.cs


@@ -1,15 +1,12 @@


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;


@@ -21,22 +18,14 @@


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;


@@ -87,6 +76,7 @@


                if (e.BarItemKey.ToUpper() == "TBCOMPLETE")


                {


                    COMPLETE();




                }


                //提料计划


                if (e.BarItemKey.ToUpper() == "TBEXTRACTION")


@@ -136,10 +126,10 @@


        /// <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")


            {


                //生产计划平台拖期明细跳转


@@ -154,6 +144,7 @@


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


        }


@@ -162,13 +153,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;


@@ -217,7 +215,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];


@@ -227,7 +225,7 @@




            //单元格赋值


            //列宽自适应，只对英文和数字有效


            for (int i = 0; i <= Title.Length; i++)


            for (int i = 0; i <= Title.Count; i++)


            {


                sheet.AutoSizeColumn(i);


            }


@@ -270,16 +268,16 @@


            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)


            {


                //锁定后生成日计划用料清单 及 提料计划


                DayPlanPPBomBillBatch();


                Extraction();


                SearchList();


                this.View.ShowMessage("操作成功");


            }


            else


                this.View.ShowMessage("操作失败，联系管理员！");


            //if (result > 0)


            //{


            //锁定后生成日计划用料清单 及 提料计划


            DayPlanPPBomBillBatch();


            Extraction();


            SearchList();


            this.View.ShowMessage("操作成功");


            //}


            //else


            //    this.View.ShowMessage("操作失败，联系管理员！");


        }


        /// <summary>


        /// 解锁


@@ -298,72 +296,80 @@


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


            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());//最大日期


                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.ToString(current["FDayPlanQuantity"]));


                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++)


                {


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


                    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("数据储存失败！请联系管理员！");


                }


            }




            int result = DBServiceHelper.ExecuteBatch(Context, sqlList);


            if (result > 0)


            {


                this.View.ShowMessage("操作成功");


                SearchList();


            }


            else


                this.View.ShowMessage("操作失败，联系管理员！");




            this.View.ShowMessage("操作成功");


            SearchList();


        }


        /// <summary>


        /// 齐套分析


@@ -470,18 +476,20 @@


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


@@ -545,12 +553,13 @@


                                    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;


                                //剩余日计划需求数量


@@ -584,7 +593,9 @@


                                FHLeftQty = 0,//可用数量


                                FOccupyCount = occupyMaterial,//占用数量


                                FComPlete = "未齐套",


                                FPlanDate = item.FHMASTERDATE // 日计划日期


                                FPlanDate = item.FHMASTERDATE, // 日计划日期


                                FErpClsID = _item.FErpClsID




                            });


                        }


                    }


@@ -627,10 +638,11 @@


                    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/");


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


@@ -710,18 +722,20 @@


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


@@ -735,7 +749,6 @@


                Dictionary<string, decimal> occupyDic = new Dictionary<string, decimal>();


                foreach (var item in DatePlanList)


                {


                    this.View.Session["ProcessRateValue"] = Convert.ToInt32(this.View.Session["ProcessRateValue"]) + Convert.ToInt32((decimal)(1.0 / DatePlanList.Count));


                    //筛选出当日计划数据


                    var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();


                    foreach (var _item in _BomList)


@@ -785,6 +798,7 @@


                                    FHStockQty = sjkcList.FBASEQTY,//即时库存


                                    FHLeftQty = Inventory.FBASEQTY,//可用数量


                                    FOccupyCount = occupyMaterial,//占用数量


                                    FErpClsID = _item.FErpClsID,


                                    /* 2021 1.26 更改为need


                                    FComPlete = sjkcList.FBASEQTY >= _item.PlanCount ? "齐套" : "未齐套",


                                    */


@@ -817,6 +831,7 @@


                                FOwnerTypeId = "BD_OwnerOrg",


                                FUnitDosage = _item.dwyl.ToString(),//单位用量


                                FSumPlanCount = _item.PlanCount.ToString(),//计划总数量


                                FErpClsID = _item.FErpClsID,


                                FCompleteCount = 0, //齐套数量


                                FCompleteCount1 = 0, //齐套数量


                                FLackCount = _item.PlanCount,//缺料数量


@@ -861,6 +876,7 @@


                    FBatchModel.Add("FLackCount", item.FLackCount);


                    FBatchModel.Add("FOccupyCount", item.FOccupyCount);


                    FBatchModel.Add("FPlanDate", item.FPlanDate);


                    FBatchModel.Add("FErpClsID", item.FErpClsID);


                    if (item.FOwnerId != null)


                        FBatchModel.Add("FOwnerId", new JObject() { ["FNUMBER"] = item.FOwnerId });


                    Fentity.Add(FBatchModel);


@@ -877,7 +893,7 @@


                            ["IsVerifyBaseDataField"] = "false",


                            ["Model"] = Fentity


                        };


                        CloudClient cloudClient = new CloudClient("http://localhost/K3Cloud/");


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


@@ -934,8 +950,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


join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID


where d.FAvailableComplete<>0


--where T1.FMATERIALID in (105773)


");


                ListInventory = ds.ToModelList<PRD_Inventory>();


@@ -953,23 +969,24 @@


) 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


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*/


 /*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


@@ -987,7 +1004,7 @@


                Dictionary<string, decimal> occupyDic = new Dictionary<string, decimal>();


                foreach (var item in DatePlanList)


                {


                    this.View.Session["ProcessRateValue"] = Convert.ToInt32(this.View.Session["ProcessRateValue"]) + Convert.ToInt32((decimal)(1.0 / DatePlanList.Count));




                    //筛选出当日计划数据


                    var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();


                    foreach (var _item in _BomList)


@@ -1026,6 +1043,7 @@


                                    FHMaterID = _item.FMATERIALID2,


                                    FHStockOrgID = _item.FStockOrgId,


                                    FHPRDORGID = _item.FStockOrgId,


                                    FErpClsID = _item.FErpClsID,


                                    FPRDBillNo = _item.FMOBillNO,


                                    FOwnerTypeId = "BD_OwnerOrg",


                                    FOwnerId = Inventory.FOwnerId,


@@ -1064,6 +1082,7 @@


                                FHICMOInterID = _item.FID.ToString(),


                                FHICMOEntryID = _item.FEntryID.ToString(),


                                FHMaterID = _item.FMATERIALID2,


                                FErpClsID = _item.FErpClsID,


                                FHStockOrgID = _item.FStockOrgId,


                                FHPRDORGID = _item.FStockOrgId,


                                FPRDBillNo = _item.FMOBillNO,


@@ -1096,10 +1115,10 @@


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)


select id, '', 'A', '{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}', '{8}', '{9}', '{10}', '{11}', '{12}', 'BD_OwnerOrg', '','{13}','{14}','{15}','{16}','{17}' from z_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.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++;


@@ -1136,11 +1155,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)


            {


@@ -1167,7 +1186,8 @@


                    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("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);//生产组织


@@ -1201,7 +1221,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++)


@@ -1255,20 +1275,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)


@@ -1296,7 +1308,8 @@


                    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("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);//生产组织


@@ -1465,7 +1478,7 @@


                            ["Model"] = model


                        };




                        CloudClient cloudClient = new CloudClient("http://localhost/K3Cloud/");


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


@@ -1494,11 +1507,14 @@


            {


                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


 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 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


FROM Sc_WorkBillSortBillSub t1


JOIN Sc_WorkBillSortBillMAIN t2 on t1.FID = t2.FID


JOIN T_PRD_PPBOM T3 on T2.FPRDMOMAINID=t3.FMOID AND T2.FPRDMOENTYID=T3.FMOENTRYID


JOIN T_PRD_PPBOMENTRY T4 ON T3.FID=T4.FID


JOIN T_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


@@ -1533,12 +1549,22 @@


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


                        });


                    }


                    LogHelper.Info($"日计划用料清单，数据准备完成，保存到Model实体，总行数：{DayPlanMaterial.Count}，耗时：" + sw.Elapsed);


@@ -1549,6 +1575,9 @@


                    {


                        var _DayPlanMaterial = DayPlanMaterial.Where(x => x.FEntryID == item).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 });//物料


@@ -1557,6 +1586,7 @@


                        model.Add("FHUnitID", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FHUnitID });//单位：FHUnitID 


                        model.Add("FDayPlanFID", _DayPlanMaterial[0].FDayPlanFID);//日计划工单内码 


                        JArray Entry = new JArray();


                        int FSEQ = 1;


                        foreach (var _item in _DayPlanMaterial)


                        {


                            JObject ModelEnty = new JObject();


@@ -1572,11 +1602,23 @@


                            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("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("FSEQ", FSEQ);//  


                            Entry.Add(ModelEnty);


                            FSEQ++;




                        }


                        model.Add("FEntity", Entry);


                        //if (!string.IsNullOrEmpty(_DayPlanMaterial[0].FID))


                        //    model.Add("FID", _DayPlanMaterial[0].FID);




                        Fentity.Add(model);


                        if ((i >= 20 || i == fidList.Count) && (i % 20 == 0 || i == fidList.Count))


                        {


@@ -1586,18 +1628,18 @@


                                ["Creator"] = "",


                                ["NeedUpDateFields"] = new JArray(),


                                ["NeedReturnFields"] = new JArray(),


                                ["IsDeleteEntry"] = "false",


                                ["IsDeleteEntry"] = "true",


                                ["SubSystemId"] = "",


                                ["IsVerifyBaseDataField"] = "false",


                                ["Model"] = Fentity


                            };


                            CloudClient cloudClient = new CloudClient("http://localhost/K3Cloud/");


                            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")


                            {


                                LogHelper.Error(jsonRoot.ToString());


                                LogHelper.Error(saveObj.ToString());


                            }


                            Fentity = new JArray();


                        }


@@ -1618,11 +1660,12 @@


        /// </summary>


        public void Extraction()


        {


            LogHelper.Info("[提料计划准备阶段]：测试测试测试测试测试测试测试测试");


            try


            {


                Stopwatch sw = new Stopwatch();


                sw.Start();//开始计时


                string sql = string.Format(@"/*dialect*/ select t1.FID from Sc_WorkBillSortBillMain t1");


                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)


@@ -1636,16 +1679,18 @@


 exec [提料计划预处理] '{0}'


 ", FDayPlanWorkID.Replace(",", "-"));


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


@@ -1668,15 +1713,16 @@


", FDayPlanWorkID);


                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 


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 


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=1 


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


@@ -1687,7 +1733,7 @@


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


                var _MaterialIDList = MaterialIDList.Where(p => p.FMATERIALID == "163165").ToList();


                LogHelper.Info("[提料计划准备阶段]总物料行数" + MaterialIDList.Count);


                //提料计划数据集临时存储集合


                List<PODemandPlanTemp> PODemandPlanTemp = new List<PODemandPlanTemp>();


@@ -1697,14 +1743,14 @@


                foreach (var item in MaterialIDList)


                {


                    //当前物料没有采购订单时 直接跳出


                    List<PurchaseInventory> _PurchaseInventory = PurchaseInventory.Where(x => x.FMATERIALID == item.FMATERIALID && x.FStockOrgId == item.FStockOrgId && x.FQTY > 0).ToList();


                    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)


                    {


                        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;//提前期


@@ -1713,127 +1759,146 @@


                    string FJITSafeStock = _DayPlanPpbom.FirstOrDefault().FJITSafeStock; //JIT安全库存


                    decimal NeedQty = 0;


                    DateTime DATE = _DayPlanPpbom.FirstOrDefault().FHMASTERDATE;//第一个订货起始日期


                    int i = 1;


                    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)


                        {


                            LogHelper.Info("[提料计划开始]当前物料明细无采购信息：" + item.FMATERIALID + " 库存组织：" + item.FStockOrgId);


                            break;


                        }




                        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)




                        //LogHelper.Info("记录明细id：" + _item.FENTRYID + "");


                        //LogHelper.Info("总需求量：" + NeedQty + "");


                        //LogHelper.Info("最小起订量：" + FMINPOQTY + "");


                        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)


                            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.FBillNo);


                            //LogHelper.Info("物料：" + Purchase.FMATERIALID + ",采购订单数量：" + Purchase.FQTY);


                            if (Purchase.FQTY >= NeedQty)


                            {


                                NeedQty = 0;


                                foreach (int id in FEntryIdList)


                                {


                                    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,


                                        FErpClsID = DayPlanPpbomls.FErpClsID,




                                        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;


                            }


                            */


                            foreach (var Purchase in _PurchaseInventory)


                            else


                            {


                                //LogHelper.Info("Purchase");


                                //LogHelper.Info("物料：" + Purchase.FMATERIALID + ",数量：" + Purchase.FQTY);


                                if (Purchase.FQTY >= NeedQty)


                                //更新总需求数量


                                NeedQty = NeedQty - Purchase.FQTY;


                                //采购订单数量


                                decimal _NeedQty = Purchase.FQTY;


                                List<int> mmm = new List<int>();


                                foreach (int id in FEntryIdList)


                                {


                                    foreach (int id in FEntryIdList)


                                    {


                                        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,


                                    var DayPlanPpbomls = DayPlanPpbom.Where(c => c.FENTRYID == id && c.FMATERIALID == _item.FMATERIALID).FirstOrDefault();


                                    decimal Qty = DayPlanPpbomls.NeedQty;//订单数量


                                    //if (Qty == 0)


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


                                    if (Qty > _NeedQty)


                                        Qty = _NeedQty; //订单数量>采购订单数量 取采购订单




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


                                    //if (_NeedQty == 0)


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




                                    _NeedQty = _NeedQty - Qty;


                                    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,


                                        FErpClsID = DayPlanPpbomls.FErpClsID,




                                        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)+  '{NeedQty}' where FENTRYID = {Purchase.FENTRYID}");


                                    //扣除当前行对应采购订单数量


                                    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 -= NeedQty;


                                    break;


                                }


                                else


                                {


                                    //更新总需求数量


                                    NeedQty = NeedQty - Purchase.FQTY;


                                    decimal _NeedQty = Purchase.FQTY;//采购订单数量


                                    List<int> mmm = new List<int>();


                                    foreach (int id in FEntryIdList)


                                    ls.FQTY -= Qty;


                                    if (_NeedQty <= 0)


                                    {


                                        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


                                        foreach (var mm in mmm)


                                        {


                                            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;


                                            FEntryIdList.Remove(mm);


                                        }


                                        mmm.Add(id);


                                        break;


                                    }


                                    foreach (var mm in mmm)


                                    {


                                        FEntryIdList.Remove(mm);


                                    }


                                    mmm.Add(id);


                                }


                                //foreach (var mm in mmm)


                                //{


                                //    FEntryIdList.Remove(mm);


                                //}


                            }


                            NeedQty = 0;


                        }


                        NeedQty = 0;


                        //}


                        #region 剩下不足时按最小采购批次生成


                        //剩下不足时按最小采购批次生成


                        //else if (i == _DayPlanPpbom.Count && NeedQty > 0)


@@ -1938,12 +2003,12 @@


                        //    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实体，总行数：{PODemandPlanList.Count}，耗时：" + sw.Elapsed);


                LogHelper.Info($"提料计划，数据准备完成，保存到Model实体，总行数：{PODemandPlanTemp.Count}，耗时：" + sw.Elapsed);


                int tlmmm = 1;


                JArray FinalyResult = new JArray();


                foreach (var item in PODemandPlanList)


@@ -1952,10 +2017,12 @@


                    string PurchseFNUMBER = item.PurchseFNUMBER;


                    JObject model = new JObject();


                    model.Add("FHDate", date);


                    model.Add("FHRemark", "生产订单号：" + "测试呢呢");


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


@@ -1973,13 +2040,18 @@


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


                        LogHelper.Info("提料计划新增批量执行，记录循环的当前条数" + tlmmm);


                        JObject jsonRoot = new JObject()


                        {


                            ["Creator"] = "",


@@ -1990,7 +2062,7 @@


                            ["IsVerifyBaseDataField"] = "false",


                            ["Model"] = FinalyResult


                        };


                        CloudClient cloudClient = new CloudClient("http://localhost/K3Cloud/");


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