From 20e583035f94edaba23d88e43c37e02088f07bea Mon Sep 17 00:00:00 2001
From: 王 垚 <1402714037@qq.com>
Date: 星期二, 16 二月 2021 17:04:13 +0800
Subject: [PATCH] 生产计划平台 选单功能修改 将生产订单数量 自动填充到 日计划中 规则为 明细行的开工日期 即为 日计划日期 2h

---
 src/BLL/Demo.BillView/PRD/Pro_WorkBillPlatform.cs |  865 ++++++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 668 insertions(+), 197 deletions(-)

diff --git a/src/BLL/Demo.BillView/PRD/Pro_WorkBillPlatform.cs b/src/BLL/Demo.BillView/PRD/Pro_WorkBillPlatform.cs
index cfc5ebd..4cf0488 100644
--- a/src/BLL/Demo.BillView/PRD/Pro_WorkBillPlatform.cs
+++ b/src/BLL/Demo.BillView/PRD/Pro_WorkBillPlatform.cs
@@ -1,12 +1,16 @@
-锘縰sing Demo.Model.Model;
+锘縰sing Demo.BillView.PRD;
+using Demo.Model.Model;
 using Demo.Model.Model.PODemandPlan;
 using K3Cloud.Extend.Utils;
 using Kingdee.BOS.Core;
+using Kingdee.BOS.Core.Bill;
 using Kingdee.BOS.Core.Const;
 using Kingdee.BOS.Core.DynamicForm;
 using Kingdee.BOS.Core.DynamicForm.PlugIn;
 using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
 using Kingdee.BOS.Core.DynamicForm.PlugIn.ControlModel;
+using Kingdee.BOS.Core.List;
+using Kingdee.BOS.Core.Metadata;
 using Kingdee.BOS.Core.Metadata.EntityElement;
 using Kingdee.BOS.JSON;
 using Kingdee.BOS.KDThread;
@@ -25,6 +29,7 @@
 using System.Data;
 using System.Diagnostics;
 using System.Linq;
+using System.Threading;
 using System.Web;
 using ZD.Cloud.Logger;
 using ZD.Cloud.WebApi;
@@ -66,6 +71,7 @@
             base.BarItemClick(e);
             try
             {
+                LogHelper.Info("鐢熶骇璁″垝骞冲彴鎸夐挳");
                 if (e.BarItemKey.ToUpper() == "BTEXPORT")
                 {
                     ExportExcel();
@@ -130,6 +136,11 @@
                         this.View.ShowMessage("鎿嶄綔鎴愬姛锛�");
                     }
                 }
+                //閫夊崟
+                if (e.BarItemKey.ToUpper() == "TBSELECTMENU")
+                {
+                    SelectMenu();
+                }
                 //棰勭暀
                 if (e.BarItemKey.ToUpper() == "TBRESERVE")
                 {
@@ -175,7 +186,7 @@
                     sqlList.Add(sql);
                     string columnName = DBServiceHelper.ExecuteScalar<string>(Context, "/*dialect*/ select stuff((select ',' + name  from syscolumns Where id = object_Id('Sc_WorkBillMainXnqt') for xml path('')),1,1,'') as name ", "");
                     sql = $"insert into  Sc_WorkBillMainXnqt({columnName}) select {columnName} from  Sc_WorkBillSortBillMain";
-                    LogHelper.Info("娴嬭瘯1锛�"+sql);
+                    LogHelper.Info("娴嬭瘯1锛�" + sql);
                     sqlList.Add(sql);
                     columnName = DBServiceHelper.ExecuteScalar<string>(Context, "/*dialect*/ select stuff((select ',' + name  from syscolumns Where id = object_Id('Sc_WorkBillSubXnqt') for xml path('')),1,1,'') as name ", "");
                     sql = $"insert into  Sc_WorkBillSubXnqt({columnName}) select {columnName} from  Sc_WorkBillSortBillSub";
@@ -210,14 +221,30 @@
                 //鐢熶骇璁″垝骞冲彴鎷栨湡鏄庣粏璺宠浆
                 formPa.FormId = "paez_TardinessDetails";
                 formPa.CustomParams.Add("FID", Convert.ToString(this.View.Model.GetValue("FDayPlanWorkID", e.Row).ToString()));
+                this.View.ShowForm(formPa);
+            }
+            else if (e.ColKey == "FQTYLS")
+            {
+                //鐢熶骇璁″垝骞冲彴
+                string pageId = Guid.NewGuid().ToString();
+                BillShowParameter showParameter = new BillShowParameter();
+                showParameter.FormId = "Paez_Sc_WorkBillAutoSortBill";
+                showParameter.OpenStyle.ShowType = ShowType.MainNewTabPage;
+                showParameter.PageId = pageId;
+                showParameter.Status = OperationStatus.EDIT;
+                // 浼犲叆闇�瑕佷慨鏀圭殑鏃ヨ鍒掑伐鍗曞唴鐮侊紝 
+                showParameter.PKey = Convert.ToString(this.View.Model.GetValue("FDayPlanWorkID", e.Row).ToString());
+                this.View.ShowForm(showParameter);
+
             }
             else
             {
                 //榻愬鍒嗘瀽鏄庣粏鍒楄〃璺宠浆
                 formPa.FormId = "paez_CompleteAnalysisDetail";
                 formPa.CustomParams.Add("FHICMOInterID", Convert.ToString(this.View.Model.GetValue("FDayPlanWorkID", e.Row).ToString()));
+                this.View.ShowForm(formPa);
             }
-            this.View.ShowForm(formPa);
+
         }
         /// <summary>
         /// 鏌ョ湅铏氭嫙榻愬
@@ -357,16 +384,7 @@
             string sql = $"/*dialect*/update t1 set t1.FHLockedSub=1 from Sc_WorkBillSortBillSub t1  join Sc_WorkBillSortBillMain t2 on  t1.FID = t2.FID  where  FHMASTERDATE between  DATEADD(day,-1,getdate()) and DATEADD(day,{day - 1},getdate())";
             sqlList.Add(sql);
             int result = DBServiceHelper.ExecuteBatch(Context, sqlList);
-            //if (result > 0)
-            //{
-            //閿佸畾鍚庣敓鎴愭棩璁″垝鐢ㄦ枡娓呭崟 鍙� 鎻愭枡璁″垝
-            DayPlanPPBomBillBatch();
-            Extraction();
-            SearchList();
-            this.View.ShowMessage("鎿嶄綔鎴愬姛");
-            //}
-            //else
-            //    this.View.ShowMessage("鎿嶄綔澶辫触锛岃仈绯荤鐞嗗憳锛�");
+            DayPlanPPBomBill();
         }
         /// <summary>
         /// 瑙i攣
@@ -379,12 +397,13 @@
             //鍗曟嵁浣撲俊鎭浆鎹负鍒楄〃闆嗗悎
             DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
             List<string> sqlList = new List<string>();
-            string sql;
-            foreach (var item in entityDataObjoct)
-            {
-                sql = $"/*dialect*/update t1 set t1.FHLockedSub=0 from Sc_WorkBillSortBillSub t1  join Sc_WorkBillSortBillMain t2 on  t1.FID = t2.FID  where  FHMASTERDATE between  DATEADD(day,-1,getdate()) and DATEADD(day,{day - 1},getdate())   and t1.FID = { Convert.ToString(item["FDayPlanWorkID"])} ";
-                sqlList.Add(sql);
-            }
+            string sql = $"/*dialect*/update t1 set t1.FHLockedSub=0 from Sc_WorkBillSortBillSub t1  join Sc_WorkBillSortBillMain t2 on  t1.FID = t2.FID  where  FHMASTERDATE between  DATEADD(day,-1,getdate()) and DATEADD(day,{day - 1},getdate())";
+            DBServiceHelper.Execute(Context, sql);
+            //foreach (var item in entityDataObjoct)
+            //{
+            //    sql = $"/*dialect*/update t1 set t1.FHLockedSub=0 from Sc_WorkBillSortBillSub t1  join Sc_WorkBillSortBillMain t2 on  t1.FID = t2.FID  where  FHMASTERDATE between  DATEADD(day,-1,getdate()) and DATEADD(day,{day - 1},getdate())   and t1.FID = { Convert.ToString(item["FDayPlanWorkID"])} ";
+            //    sqlList.Add(sql);
+            //}
             SearchList();
             this.View.ShowMessage("鎿嶄綔鎴愬姛");
 
@@ -414,49 +433,175 @@
             }
             foreach (DynamicObject current in entityDataObjoct)
             {
-                JObject jsonRoot = new JObject();
-                jsonRoot.Add("Creator", "");
-                jsonRoot.Add("NeedUpDateFields", new JArray());
-                jsonRoot.Add("NeedReturnFields", new JArray());
-                jsonRoot.Add("IsDeleteEntry", "false");
-                jsonRoot.Add("SubSystemId", "");
-                jsonRoot.Add("IsVerifyBaseDataField", "");
-                JObject jsonModel = new JObject();
-                jsonModel.Add("FID", Convert.ToString(current["FDayPlanWorkID"]));
-                jsonModel.Add("FOrderQuantity", Convert.ToString(current["FOrderQuantity"]));
-                jsonModel.Add("FDayPlanQuantity", Convert.ToDecimal(current["FDayPlanQuantity"]) + Convert.ToDecimal(current["FQTYLS"]));
-                jsonModel.Add("FNoScheduled", Convert.ToString(current["FNoScheduled"]));
-                sql = $" /*dialect*/ select FEntryID, FHMASTERDATE from SC_WORKBILLSORTBILLSub  where FID={Convert.ToString(current["FDayPlanWorkID"])} ";
-                List<DayPlanModel> dayPlanModel = new List<DayPlanModel>();
-                dayPlanModel = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList<DayPlanModel>();
-                JArray Entry = new JArray();
-                for (int i = 0; i <= 60; i++)
+                if (Convert.ToInt32(current["FDayPlanWorkID"]) > 0)
                 {
-                    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)
+                    JObject jsonRoot = new JObject();
+                    jsonRoot.Add("Creator", "");
+                    jsonRoot.Add("NeedUpDateFields", new JArray());
+                    jsonRoot.Add("NeedReturnFields", new JArray());
+                    jsonRoot.Add("IsDeleteEntry", "false");
+                    jsonRoot.Add("SubSystemId", "");
+                    jsonRoot.Add("IsVerifyBaseDataField", "");
+                    JObject jsonModel = new JObject();
+                    jsonModel.Add("FID", Convert.ToString(current["FDayPlanWorkID"]));
+                    jsonModel.Add("FOrderQuantity", Convert.ToString(current["FOrderQuantity"]));
+                    jsonModel.Add("FDayPlanQuantity", Convert.ToDecimal(current["FDayPlanQuantity"]) + Convert.ToDecimal(current["FQTYLS"]));
+                    jsonModel.Add("FNoScheduled", Convert.ToString(current["FNoScheduled"]));
+                    sql = $" /*dialect*/ select FEntryID, FHMASTERDATE from SC_WORKBILLSORTBILLSub  where FID={Convert.ToString(current["FDayPlanWorkID"])} ";
+                    List<DayPlanModel> dayPlanModel = new List<DayPlanModel>();
+                    dayPlanModel = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList<DayPlanModel>();
+                    JArray Entry = new JArray();
+                    for (int i = 0; i <= 60; i++)
                     {
-                        jsonFPOOrderEntry.Add("FEntryID", _dayPlanModel.FirstOrDefault().FEntryID); ;//搴忓彿
+                        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);
                     }
-                    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("鏁版嵁鍌ㄥ瓨澶辫触锛佽鑱旂郴绠$悊鍛橈紒");
+                    }
                 }
-                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")
+                else
                 {
-                    LogHelper.Error("鐢熶骇璁″垝骞冲彴淇濆瓨澶辫触:" + jsonRoot.ToString());
-                    this.View.ShowMessage("鏁版嵁鍌ㄥ瓨澶辫触锛佽鑱旂郴绠$悊鍛橈紒");
+                    //鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鏄庣粏 +鐢熶骇璁㈠崟鏄庣粏琛屽彿
+                    sql = string.Format(@"
+/*dialect*/
+SELECT t4.FNAME as FMoFBillType,T1.FBILLNO,T2.*,t3.FNUMBER as FUnitNumber,tBom.FNUMBER as FBomNumber FROM T_PRD_MO T1
+ LEFT JOIN T_PRD_MOENTRY T2 ON T1.FID = T2.FID
+ LEFT JOIN T_ENG_BOM tBom on t2.FBOMID = tBom.FID
+ join T_BD_UNIT t3 on t2.FUNITID=t3.FUNITID 
+ join (  select A.FBILLTYPEID,B.FNAME  from T_BAS_BILLTYPE A 
+JOIN T_BAS_BILLTYPE_L B ON A.FBILLTYPEID =B.FBILLTYPEID
+where FBILLFORMID='PRD_MO'  AND FNAME<>'鐢熺敘瑷傚柈')t4 on t1.FBILLTYPE =t4.FBILLTYPEID
+ WHERE T1.FBILLNO = '{0}'  AND T2.FMATERIALID = '{1}' AND T2.FSEQ = '{2}'", Convert.ToString(current["FSCOrderNo"]), Convert.ToString(current["FMatrailId_Id"]), Convert.ToString(current["FSRCBILLENTRYSEQ"]));
+                    DataTable dt = new DataTable();
+                    dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
+                    if (dt.Rows.Count == 0)
+                        continue;
+                    string FID = "";//FID 婧愬崟涓诲唴鐮�
+                    string FENTRYID = "";//FENTRYID 婧愬崟瀛愬唴鐮�
+                    string FLOT = "";//FLOT  鎵规
+                    string FQTY = "";//FQTY 鐢熶骇璁㈠崟鏁伴噺
+                    string FBILLNO = "";//FBILLNO 鍘熷崟鍙� 
+                    string FHUnitID = "";//鍗曚綅
+                    string FPlanBeginDate = "";//寮�濮嬫棩鏈�
+                    string FPlanEndDate = "";//缁撴潫鏃ユ湡
+                    string FMoFBillType = "";//
+                    string FBomNumber = "";//Bom 鐗堟湰
+                    if (dt.Rows.Count > 0)
+                    {
+                        FID = dt.Rows[0]["FID"].ToString();
+                        FENTRYID = dt.Rows[0]["FENTRYID"].ToString();
+                        FLOT = dt.Rows[0]["FLOT"].ToString();
+                        FQTY = dt.Rows[0]["FQTY"].ToString();
+                        FBILLNO = dt.Rows[0]["FBILLNO"].ToString();
+                        FHUnitID = dt.Rows[0]["FUnitNumber"].ToString();
+                        FPlanBeginDate = dt.Rows[0]["FPlanStartDate"].ToString();
+                        FPlanEndDate = dt.Rows[0]["FPlanFinishDate"].ToString();
+                        FMoFBillType = dt.Rows[0]["FMoFBillType"].ToString();
+                        FBomNumber = dt.Rows[0]["FBomNumber"].ToString();
+                    }
+
+                    //閫夊崟鏁版嵁 鍋氭柊澧�
+                    JObject jsonRoot = new JObject();
+                    jsonRoot.Add("Creator", "");
+                    jsonRoot.Add("NeedUpDateFields", new JArray());
+                    jsonRoot.Add("NeedReturnFields", new JArray());
+                    jsonRoot.Add("IsDeleteEntry", "false");
+                    jsonRoot.Add("SubSystemId", "");
+                    jsonRoot.Add("IsVerifyBaseDataField", "");
+                    JObject jsonModel = new JObject();
+                    jsonModel.Add("FPreparatDate", date.ToString());//缂栧埗鏃ユ湡
+                    jsonModel.Add("FMoFBillType", FMoFBillType);//
+                    jsonModel.Add("FSRCBILLENTRYSEQ", Convert.ToString(current["FSRCBILLENTRYSEQ"]));//鐢熶骇璁㈠崟鏄庣粏琛屽彿
+                    jsonModel.Add("FSCOrderNo", Convert.ToString(current["FSCOrderNo"])); //鐢熶骇璁㈠崟鍙稦SCOrderNo
+                    jsonModel.Add("FHSeOrderBillNo", Convert.ToString(current["FSalOrderNo"]));//閿�鍞鍗曞彿
+                    jsonModel.Add("FHOrderLev", current["FOrderLevel"].ToString());//璁㈠崟绛夌骇
+                    jsonModel.Add("FHOrderQty", Convert.ToString(current["FSalOrderCount"]));//閿�鍞鍗曟暟閲�
+                    jsonModel.Add("FHOrderCommitDate", Convert.ToString(current["FDeliveryDate"]));//浜よ揣鏈烪OrderCommitDate
+                    jsonModel.Add("FHUnitID", new JObject() { ["Fnumber"] = FHUnitID });//鍗曚綅
+                    jsonModel.Add("FBOMID", new JObject() { ["Fnumber"] = FBomNumber });//BOM鐗堟湰
+                    jsonModel.Add("FHPlanBeginDate", FPlanBeginDate);//璁″垝寮�濮嬫棩鏈�
+                    jsonModel.Add("FHPlanEndDate", FPlanEndDate);//璁″垝瀹屽伐鏃ユ湡
+                    //jsonModel.Add("FBatch", current["FBatch"].ToString());//鎵规
+                    jsonModel.Add("FBatch", FLOT);//鎵规
+                    jsonModel.Add("FHOrderNeedQty", FQTY);// 璁㈠崟闇�姹傛暟閲�
+                    jsonModel.Add("FPrdBillNo", FBILLNO); ;//婧愬崟缂栧彿
+                    jsonModel.Add("FPRDMOMAINID", FID); ;//婧愬崟涓诲唴鐮�
+                    jsonModel.Add("FPRDMOENTYID", FENTRYID); ;//婧愬崟瀛愬唴鐮�
+                    jsonModel.Add("FMoFID", FID); ;//婧愬崟涓诲唴鐮�
+                    jsonModel.Add("FMoFentryId", FENTRYID); ;//婧愬崟瀛愬唴鐮�
+                    jsonModel.Add("FOrderQuantity", Convert.ToString(current["FOrderQuantity"])); ;//鐢熶骇璁㈠崟鏁伴噺
+                    jsonModel.Add("FDayPlanQuantity", Convert.ToString(current["FDayPlanQuantity"])); ;//鏃ヨ鍒掓暟閲�
+                    jsonModel.Add("FNoScheduled", Convert.ToString(current["FNoScheduled"])); ;//鏈帓鏁伴噺
+                    JObject jsonFHMaterID = new JObject();
+                    jsonFHMaterID.Add("FNumber", (current["FMatrailId"] as DynamicObject)["Number"].ToString());
+                    jsonModel.Add("FHMaterID", jsonFHMaterID);//FHMaterID 鐗╂枡
+                    if (Convert.ToString(current["FORGID_Id"]) != "0")
+                    {
+                        JObject jsonFHPRDORGID = new JObject();
+                        jsonFHPRDORGID.Add("FNumber", (current["FORGID"] as DynamicObject)["Number"].ToString());
+                        jsonModel.Add("FHPRDORGID", jsonFHPRDORGID);//FHMaterID 鐢熶骇缁勭粐
+
+                    }
+                    if (Convert.ToString(current["FResourcesId_Id"]) != "0")
+                    {
+                        JObject jsonFProductWorkShopId = new JObject();
+                        jsonFProductWorkShopId.Add("FNumber", (current["FResourcesId"] as DynamicObject)["Number"].ToString());
+                        jsonModel.Add("FHSourceID", jsonFProductWorkShopId);//FHSourceID  鐢熶骇杞﹂棿
+                    }
+                    if (Convert.ToString(current["FProductWorkShopId_Id"]) != "0")
+                    {
+                        JObject jsonFResourcesId = new JObject();
+                        jsonFResourcesId.Add("FNumber", (current["FProductWorkShopId"] as DynamicObject)["Number"].ToString());
+                        jsonModel.Add("FHWorkShopID", jsonFResourcesId);//FHWorkShopID  鐢熶骇璧勬簮
+                    }
+                    JArray Entry = new JArray();
+                    for (int i = 0; i <= 60; i++)
+                    {
+                        if (Convert.ToString(current["FT" + "" + i + ""]) == "" || Convert.ToString(current["FT" + "" + i + ""]) == "0")
+                            continue;
+                        JObject jsonFPOOrderEntry = new JObject();
+                        jsonFPOOrderEntry.Add("FHMasterDate", date.AddDays(i).ToShortDateString()); ;//涓绘棩鏈�
+                        jsonFPOOrderEntry.Add("FHQty ", Convert.ToString(current["FT" + "" + i + ""])); ;//鏃ヨ鍒掓暟閲�
+                        Entry.Add(jsonFPOOrderEntry);
+                    }
+                    jsonModel.Add("FEntity", Entry);
+                    jsonRoot.Add("Model", jsonModel);
+                    CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
+                    var result = cloudClient.Save("Paez_Sc_WorkBillAutoSortBill", jsonRoot.ToString());
+                    JObject saveObj = JObject.Parse(result);
+                    string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
+                    if (saveIsSuc != "TRUE")
+                    {
+                        LogHelper.Error("鐢熶骇璁″垝骞冲彴淇濆瓨澶辫触:" + jsonRoot.ToString());
+                        this.View.ShowMessage("鏁版嵁鍌ㄥ瓨澶辫触锛佽鑱旂郴绠$悊鍛橈紒");
+                    }
+                    if (saveIsSuc == "TRUE")
+                    {
+                        string FDayPlanBillNo = saveObj["Result"]["Number"].ToString();
+                        string FDayPlanID = saveObj["Result"]["Id"].ToString();
+                        this.Model.SetValue("FDayPlanBillNo", FDayPlanBillNo, Convert.ToInt32(current["SEQ"]) - 1);// 
+                        this.Model.SetValue("FDayPlanID", FDayPlanID, Convert.ToInt32(current["SEQ"]) - 1);// 
+                    }
                 }
             }
-
             this.View.ShowMessage("鎿嶄綔鎴愬姛");
             SearchList();
         }
@@ -487,11 +632,12 @@
             // using Kingdee.BOS.KDThread;
             MainWorker.QuequeTask(() =>
             {
+                var resuult = "";
                 try
                 {
                     // 闇�瑕佹崟鑾烽敊璇紝浠ョ‘淇濆鐞嗙粨鏉熸椂锛屽叧闂繘搴︽粴鍔ㄧ晫闈�
                     // 寮曞叆鍔熻兘瀹為檯澶勭悊鍑芥暟
-                    this.CompleteSetAnalysisBySQL();
+                    resuult = this.CompleteSetAnalysisByDataTable();
                 }
                 finally
                 {
@@ -503,6 +649,7 @@
                     {
                         processView.Close();
                         this.View.SendDynamicFormAction(processView);
+                        this.View.ShowMessage(resuult);
                     }
                 }
             },
@@ -1018,8 +1165,7 @@
             {
                 Stopwatch sw = new Stopwatch();
                 sw.Start();//寮�濮嬭鏃�
-                LogHelper.Info("榻愬鍒嗘瀽寮�濮嬪噯澶囨暟鎹細" + sw.Elapsed);
-                //娓呯┖榻愬涓存椂琛�
+                           //娓呯┖榻愬涓存椂琛�
                 DBServiceHelper.Execute(Context, "/*dialect*/  delete JIT_MOMaterReadysBill ");
                 //鏇存柊鐘舵��
                 DBServiceHelper.Execute(Context, "/*dialect*/  update Sc_WorkBillSortBillsub set FCOMPLETE='' ");
@@ -1090,9 +1236,9 @@
                 int i = 1;
                 //鍒涘缓瀛楀吀 鐢ㄤ簬鍌ㄥ瓨鐗╂枡 + 鍗犵敤鏁伴噺
                 Dictionary<string, decimal> occupyDic = new Dictionary<string, decimal>();
+                LogHelper.Info("榻愬鍒嗘瀽鍑嗗鏁版嵁瀹屾垚锛�" + sw.Elapsed);
                 foreach (var item in DatePlanList)
                 {
-
                     //绛涢�夊嚭褰撴棩璁″垝鏁版嵁
                     var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();
                     foreach (var _item in _BomList)
@@ -1108,7 +1254,6 @@
                             decimal _fLackCount = _item.PlanCount > sjkcList.FBASEQTY ? (_item.PlanCount - sjkcList.FBASEQTY) : 0;//缂烘枡鏁伴噺
                             foreach (var Inventory in _ListInventory)
                             {
-
                                 if (need == 0)
                                     break;
                                 decimal fCompleteCount = need >= Inventory.FBASEQTY ? Inventory.FBASEQTY : need;//榻愬鏁伴噺
@@ -1208,7 +1353,7 @@
 delete   z_JIT_MOMaterReadysBill
 ", item.FHMainICMOInterIDr, item.FHMainICMOEntryID, item.FHICMOInterID, item.FHICMOEntryID, item.FHMaterID, item.FHStockOrgID, item.FHStockQty, item.FHLeftQty, item.FHPRDORGID, item.FUnitDosage, item.FSumPlanCount, item.FPRDBillNo, item.FOwnerId == null ? "0" : item.FOwnerId, item.FPlanDate.ToString("yyyy-MM-dd"), item.FComPlete, item.FLackCount, item.FOccupyCount, item.FCompleteCount1, item.FErpClsID);
                     sqlList.Add(sql);
-                    this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(98) / completeAnalysisTempModel.Count) * jdtmmm);
+                    this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(80) / completeAnalysisTempModel.Count) * jdtmmm);
                     jdtmmm++;
                 }
                 DBServiceHelper.ExecuteBatch(Context, sqlList);
@@ -1225,6 +1370,269 @@
             catch (Exception ex)
             {
                 LogHelper.Error("榻愬鍒嗘瀽璺冲嚭锛�" + ex.Message.ToString());
+
+            }
+        }
+        public string CompleteSetAnalysisByDataTable()
+        {
+            LogHelper.Info("榻愬鍒嗘瀽sql妯″紡寮�濮嬪噯澶囨暟鎹細");
+            string sql = "";
+            try
+            {
+                Stopwatch sw = new Stopwatch();
+                sw.Start();//寮�濮嬭鏃�
+                int maxFid = DBServiceHelper.ExecuteScalar<int>(Context, "select max(FID)FID FROM  JIT_MOMaterReadysBill", 0);
+                //娓呯┖榻愬涓存椂琛�
+                DBServiceHelper.Execute(Context, "/*dialect*/  delete JIT_MOMaterReadysBill ");
+                //鏇存柊鐘舵��
+                DBServiceHelper.Execute(Context, "/*dialect*/  update Sc_WorkBillSortBillsub set FCOMPLETE='' ");
+                //鑾峰彇褰撳墠鍗虫椂搴撳瓨 鎸夌収鐗╂枡+搴撳瓨缁勭粐+璐т富+搴撳瓨鏁伴噺  
+                DataSet ds = DBServiceHelper.ExecuteDataSet(Context, @" 
+/*dialect*/ 
+  select  isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0) FBASEQTY,T1.FStockOrgId,T1.FMATERIALID,a.FOWNERID,c.FNUMBER from 
+(
+select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
+join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
+join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
+LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
+group by FMATERIALID,FID) T2 on T1.FID = t2.FID
+group by a.FHPRDORGID,T2.FMATERIALID
+) T1 
+LEFT JOIN T_STK_Inventory a on T1.FStockOrgId = a.FStockOrgId and T1.FMATERIALID =a.FMATERIALID 
+LEFT JOIN JIT_MOMaterReadysBill B ON T1.FStockOrgId = b.FHSTOCKORGID and T1.FMATERIALID =b.FHMATERID and a.FOwnerId = b.FOwnerId 
+LEFT join T_ORG_Organizations c on a.FOWNERID = c.FORGID
+join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
+where d.FAvailableComplete<>0
+--where T1.FMATERIALID in (105773)
+");
+                ListInventory = ds.ToModelList<PRD_Inventory>();
+                //鎬诲簱瀛� 鐗╂枡+搴撳瓨缁勭粐+搴撳瓨鏁伴噺
+                ds = DBServiceHelper.ExecuteDataSet(Context, @" 
+/*dialect*/ 
+ select  sum(isnull(a.FBASEQTY,0)-ISNULL(b.FHUseQty,0))FBASEQTY,T1.FStockOrgId,T1.FMATERIALID from 
+(
+select a.FHPRDORGID FStockOrgId,T2.FMATERIALID from SC_WORKBILLSORTBILLMAIN a
+join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
+join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
+LEFT JOIN(select FID,FMATERIALID from T_PRD_PPBOMENTRY
+group by FMATERIALID,FID) T2 on T1.FID = t2.FID
+group by a.FHPRDORGID,T2.FMATERIALID
+) T1 
+LEFT JOIN T_STK_Inventory a on T1.FStockOrgId = a.FStockOrgId and T1.FMATERIALID =a.FMATERIALID 
+LEFT JOIN JIT_MOMaterReadysBill B ON T1.FStockOrgId = b.FHSTOCKORGID and T1.FMATERIALID =b.FHMATERID
+join t_BD_Stock d on a.FSTOCKID =d.FSTOCKID
+where d.FAvailableComplete<>0
+--where T1.FMATERIALID in (105773)
+group by T1.FStockOrgId,T1.FMATERIALID
+");
+                ListInventoryByStockOrgId = ds.ToModelList<PRD_Inventory>();
+                //闇�瑕侀綈濂楀垎鏋愮殑鏁版嵁
+                sql = @"
+ /*dialect*/
+select a.FPRDMOMAINID,a.FPRDMOENTYID,a.FID,b.FEntryID,a.FHPRDORGID FStockOrgId,t5.FNUMBER as OrgFnumber,a.FHOrderLev,b.FHQTY,b.FHMASTERDATE,T1.FBillNo,T1.FMOBillNO,T1.FMOEntrySeq,T1.FMoId,T1.FMaterialID,T1.FQty,
+T2.FMATERIALID FMATERIALID2, T4.FNumber,T2.FNeedQty,FNeedQty/FQty dwyl,(FHQTY-ISNULL(FProductNum,0))*(FNeedQty/FQty) PlanCount,TBase.FErpClsID  from SC_WORKBILLSORTBILLMAIN a
+join SC_WORKBILLSORTBILLSub b on a.FID = b.FID
+join T_PRD_PPBOM T1 on a.FPRDMOMAINID = t1.FMoId and a.FPRDMOENTYID = t1.FMOENTRYID
+LEFT JOIN(select FID, MAX(FENTRYID) FENTRYID, SUM(FNeedQty) FNeedQty, FMATERIALID from T_PRD_PPBOMENTRY
+group by FMATERIALID, FID ) T2 on T1.FID = t2.FID
+ --LEFT JOIN T_STK_Inventory T3 on t2.FMATERIALID = t3.FMATERIALID
+JOIN T_BD_MATERIAL T4 on T2.FMATERIALID = T4.FMATERIALID
+JOIN t_BD_MaterialBase TBase on T2.FMATERIALID = TBase.FMATERIALID
+JOIN T_ORG_Organizations t5 on a.FHPRDORGID = t5.FORGID
+--鏉′欢涓轰粖澶╁線鍚庣殑鏃ヨ鍒� + 浠婂ぉ涔嬪墠鏈叧闂殑鏃ヨ鍒�
+where (FHEntryCloseDate is null and DATEDIFF(D,GETDATE(),FHMASTERDATE)<0)or DATEDIFF(D,GETDATE(),FHMASTERDATE)>=0
+and b.FHQTY>0
+ORDER BY b.FHMASTERDATE,a.FHOrderLev 
+";
+                ds = DBServiceHelper.ExecuteDataSet(Context, sql);
+                List<PRD_PPBOM> BomList = ds.ToModelList<PRD_PPBOM>();
+                //鏃ヨ鍒�+鐢熶骇璁㈠崟瀛愯〃缂栫爜ID
+                var DatePlanList = BomList.GroupBy(p => new { p.FHMASTERDATE, p.FPRDMOENTYID }).Select(x => new PRD_PPBOM { FHMASTERDATE = x.Key.FHMASTERDATE, FPRDMOENTYID = x.Key.FPRDMOENTYID }).ToList();
+                //CompleteAnalysisTempModel 鐢ㄤ簬瀛樺偍涓存椂闇�瑕佹彃鍏ユ暟鎹�
+                List<CompleteAnalysisTempModel> completeAnalysisTempModel = new List<CompleteAnalysisTempModel>();
+                int i = 1;
+                //鍒涘缓瀛楀吀 鐢ㄤ簬鍌ㄥ瓨鐗╂枡 + 鍗犵敤鏁伴噺
+                Dictionary<string, decimal> occupyDic = new Dictionary<string, decimal>();
+                LogHelper.Info("榻愬鍒嗘瀽鍑嗗鏁版嵁瀹屾垚锛�" + sw.Elapsed);
+                foreach (var item in DatePlanList)
+                {
+                    //绛涢�夊嚭褰撴棩璁″垝鏁版嵁
+                    var _BomList = BomList.Where(x => x.FHMASTERDATE == item.FHMASTERDATE && x.FPRDMOENTYID == item.FPRDMOENTYID).ToList();
+                    foreach (var _item in _BomList)
+                    {
+                        //璇ユ棩璁″垝鐗╂枡闇�瑕佹暟 
+                        decimal need = _item.PlanCount;
+                        var sjkcList = ListInventoryByStockOrgId.Where(x => x.FMATERIALID == _item.FMATERIALID2 && x.FStockOrgId == _item.FStockOrgId).FirstOrDefault();
+                        //鐪熸闇�瑕佸彇璁$畻鐨勬暟閲忥紙鎷嗗垎璐т富锛�
+                        //璐т富鍖归厤
+                        List<PRD_Inventory> _ListInventory = ListInventory.Where(c => c.FMATERIALID == _item.FMATERIALID2 && c.FStockOrgId == _item.FStockOrgId && c.FBASEQTY > 0).ToList();
+                        if (_ListInventory.Count > 0)
+                        {
+                            decimal _fLackCount = _item.PlanCount > sjkcList.FBASEQTY ? (_item.PlanCount - sjkcList.FBASEQTY) : 0;//缂烘枡鏁伴噺
+                            foreach (var Inventory in _ListInventory)
+                            {
+                                if (need == 0)
+                                    break;
+                                decimal fCompleteCount = need >= Inventory.FBASEQTY ? Inventory.FBASEQTY : need;//榻愬鏁伴噺
+                                decimal occupyMaterial = 0;
+                                if (!occupyDic.ContainsKey(_item.FMATERIALID2))
+                                {
+                                    occupyDic.Add(_item.FMATERIALID2, fCompleteCount);
+                                }
+                                else
+                                {
+                                    occupyMaterial = occupyDic[_item.FMATERIALID2];
+                                    occupyDic[_item.FMATERIALID2] = occupyMaterial + fCompleteCount;
+                                }
+                                completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
+                                {
+                                    FHMainICMOInterIDr = _item.FPRDMOMAINID,
+                                    FHMainICMOEntryID = _item.FPRDMOENTYID,
+                                    FHICMOInterID = _item.FID.ToString(),
+                                    FHICMOEntryID = _item.FEntryID.ToString(),
+                                    FHMaterID = _item.FMATERIALID2,
+                                    FHStockOrgID = _item.FStockOrgId,
+                                    FHPRDORGID = _item.FStockOrgId,
+                                    FErpClsID = _item.FErpClsID,
+                                    FPRDBillNo = _item.FMOBillNO,
+                                    FOwnerTypeId = "BD_OwnerOrg",
+                                    FOwnerId = Inventory.FOwnerId,
+                                    FUnitDosage = _item.dwyl.ToString(),//鍗曚綅鐢ㄩ噺
+                                    FSumPlanCount = _item.PlanCount.ToString(),//璁″垝鎬绘暟閲�
+                                    FCompleteCount1 = fCompleteCount, //榻愬鏁伴噺
+                                    FLackCount = _fLackCount,//缂烘枡鏁伴噺
+                                    FHStockQty = sjkcList.FBASEQTY,//鍗虫椂搴撳瓨
+                                    FHLeftQty = Inventory.FBASEQTY,//鍙敤鏁伴噺
+                                    FOccupyCount = occupyMaterial,//鍗犵敤鏁伴噺
+                                    /* 2021 1.26 鏇存敼涓簄eed
+                                    FComPlete = sjkcList.FBASEQTY >= _item.PlanCount ? "榻愬" : "鏈綈濂�",
+                                    */
+                                    FComPlete = sjkcList.FBASEQTY >= need ? "榻愬" : "鏈綈濂�",
+                                    FPlanDate = item.FHMASTERDATE // 鏃ヨ鍒掓棩鏈�
+                                });
+                                //鎵e噺鎬诲簱瀛樻暟閲�
+                                sjkcList.FBASEQTY = sjkcList.FBASEQTY >= fCompleteCount ? sjkcList.FBASEQTY - fCompleteCount : 0;
+                                //鍓╀綑鏃ヨ鍒掗渶姹傛暟閲�
+                                need = need >= Inventory.FBASEQTY ? need - Inventory.FBASEQTY : 0;
+                                //鎵e噺娑堣�楀簱瀛�
+                                Inventory.FBASEQTY = Inventory.FBASEQTY - fCompleteCount;
+                            }
+                        }
+                        else
+                        {
+                            decimal occupyMaterial = 0;
+                            if (occupyDic.ContainsKey(_item.FMATERIALID2))
+                            {
+                                occupyMaterial = occupyDic[_item.FMATERIALID2];
+                            }
+                            completeAnalysisTempModel.Add(new Demo.Model.Model.CompleteAnalysisTempModel
+                            {
+                                FHMainICMOInterIDr = _item.FPRDMOMAINID,
+                                FHMainICMOEntryID = _item.FPRDMOENTYID,
+                                FHICMOInterID = _item.FID.ToString(),
+                                FHICMOEntryID = _item.FEntryID.ToString(),
+                                FHMaterID = _item.FMATERIALID2,
+                                FErpClsID = _item.FErpClsID,
+                                FHStockOrgID = _item.FStockOrgId,
+                                FHPRDORGID = _item.FStockOrgId,
+                                FPRDBillNo = _item.FMOBillNO,
+                                FOwnerTypeId = "BD_OwnerOrg",
+                                FUnitDosage = _item.dwyl.ToString(),//鍗曚綅鐢ㄩ噺
+                                FSumPlanCount = _item.PlanCount.ToString(),//璁″垝鎬绘暟閲�
+                                FCompleteCount1 = 0, //榻愬鏁伴噺
+                                FLackCount = _item.PlanCount,//缂烘枡鏁伴噺
+                                FHStockQty = 0,//鍗虫椂搴撳瓨
+                                FHLeftQty = 0,//鍙敤鏁伴噺
+                                FOccupyCount = occupyMaterial,//鍗犵敤鏁伴噺
+                                FComPlete = "鏈綈濂�",
+                                FPlanDate = item.FHMASTERDATE // 鏃ヨ鍒掓棩鏈�
+                            });
+                        }
+                    }
+                    //Thread.Sleep(100);
+                    // this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(40) / DatePlanList.Count) * i);
+                    i++;
+
+                }
+                LogHelper.Info($"榻愬鍒嗘瀽锛屾暟鎹噯澶囧畬鎴愶紝淇濆瓨鍒癕odel瀹炰綋锛屾�昏鏁帮細{completeAnalysisTempModel.Count}锛岃�楁椂锛�" + sw.Elapsed);
+                List<string> sqlList = new List<string>();
+                DataTable insertDT = new DataTable();
+                insertDT.TableName = "JIT_MOMaterReadysBill";
+                insertDT.Columns.Add("FID", typeof(long));
+                //insertDT.Columns.Add("FBILLNO", typeof(string));
+                insertDT.Columns.Add("FDOCUMENTSTATUS", typeof(string));
+                insertDT.Columns.Add("FHMAINICMOINTERIDR", typeof(long));
+                insertDT.Columns.Add("FHMAINICMOENTRYID", typeof(long));
+                insertDT.Columns.Add("FHICMOINTERID", typeof(long));
+                insertDT.Columns.Add("FHICMOENTRYID", typeof(long));
+                insertDT.Columns.Add("FHMATERID", typeof(long));
+                insertDT.Columns.Add("FHSTOCKORGID", typeof(long));
+                insertDT.Columns.Add("FHSTOCKQTY", typeof(decimal));
+                insertDT.Columns.Add("FHLEFTQTY", typeof(decimal));
+                insertDT.Columns.Add("FHPRDORGID", typeof(long));
+                insertDT.Columns.Add("FUNITDOSAGE", typeof(decimal));
+                insertDT.Columns.Add("FSUMPLANCOUNT", typeof(decimal));
+                insertDT.Columns.Add("FPRDBILLNO", typeof(string));
+                insertDT.Columns.Add("FOWNERID", typeof(long));
+                insertDT.Columns.Add("FOWNERTYPEID", typeof(string));
+                //insertDT.Columns.Add("FIDENTIFICAT", typeof(long));
+                insertDT.Columns.Add("FPLANDATE", typeof(DateTime));
+                insertDT.Columns.Add("FCOMPLETE", typeof(string));
+                insertDT.Columns.Add("FLACKCOUNT", typeof(decimal));
+                insertDT.Columns.Add("FOCCUPYCOUNT", typeof(decimal));
+                insertDT.Columns.Add("FCOMPLETECOUNT1", typeof(decimal));
+                insertDT.Columns.Add("FERPCLSID", typeof(string));
+                int jdtmmm = 1;
+                foreach (var item in completeAnalysisTempModel)
+                {
+                    DataRow dr = insertDT.NewRow();
+                    dr["FID"] = maxFid + jdtmmm;
+                    //dr["FBILLNO"] = "";
+                    dr["FDOCUMENTSTATUS"] = "A";
+                    dr["FHMAINICMOINTERIDR"] = item.FHMainICMOInterIDr;
+                    dr["FHMAINICMOENTRYID"] = item.FHMainICMOEntryID;
+                    dr["FHICMOINTERID"] = item.FHICMOInterID;
+                    dr["FHICMOENTRYID"] = item.FHICMOEntryID;
+                    dr["FHMATERID"] = item.FHMaterID;
+                    dr["FHSTOCKORGID"] = item.FHStockOrgID;
+                    dr["FHSTOCKQTY"] = item.FHStockQty;
+                    dr["FHLEFTQTY"] = item.FHLeftQty;
+                    dr["FHPRDORGID"] = item.FHPRDORGID;
+                    dr["FUNITDOSAGE"] = item.FUnitDosage;
+                    dr["FSUMPLANCOUNT"] = item.FSumPlanCount;
+                    dr["FPRDBILLNO"] = item.FPRDBillNo;
+                    dr["FOWNERID"] = item.FOwnerId == null ? "0" : item.FOwnerId;
+                    dr["FOWNERTYPEID"] = "BD_OwnerOrg";
+                    //dr["FIDENTIFICAT"] = "";
+                    dr["FPLANDATE"] = item.FPlanDate.ToString("yyyy-MM-dd");
+                    dr["FCOMPLETE"] = item.FComPlete;
+                    dr["FLACKCOUNT"] = item.FLackCount;
+                    dr["FOCCUPYCOUNT"] = item.FOccupyCount;
+                    dr["FCOMPLETECOUNT1"] = item.FCompleteCount1;
+                    dr["FERPCLSID"] = item.FErpClsID;
+                    insertDT.Rows.Add(dr);
+                    this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(80) / completeAnalysisTempModel.Count) * jdtmmm);
+                    jdtmmm++;
+                }
+                insertDT.EndLoadData(); // 鐏屽叆鏁版嵁缁撴潫
+                                        // 鎵归噺鎻掑叆鍒版暟鎹簱
+                DBServiceHelper.BulkInserts(this.Context, string.Empty, string.Empty, insertDT);
+                //DBServiceHelper.ExecuteBatch(Context, sqlList);
+                //鎵ц瀹屾垚鍚� 鏇存柊鏃ヨ鍒掑伐鍗曠姸鎬�
+                DBServiceHelper.Execute(Context, @"
+/*dialect*/update Sc_WorkBillSortBillSub set FComplete = '鏈綈濂�' where FEntryID IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBill where isnull(FCOMPLETE,'鏈綈濂�') ='鏈綈濂�')
+");
+                DBServiceHelper.Execute(Context, @"
+/*dialect*/update Sc_WorkBillSortBillSub set FComplete = '榻愬' where FEntryID NOT IN (select distinct FHICMOEntryID from JIT_MOMaterReadysBill where isnull(FCOMPLETE,'鏈綈濂�') ='鏈綈濂�')
+");
+                sw.Stop();//缁撴潫璁℃椂
+                LogHelper.Info("榻愬鍒嗘瀽杩愯鎬绘椂闀匡細" + sw.Elapsed);
+                return "鎿嶄綔鎴愬姛";
+            }
+            catch (Exception ex)
+            {
+                LogHelper.Error("榻愬鍒嗘瀽璺冲嚭锛�" + ex.Message.ToString());
+                return "鎿嶄綔澶辫触锛�" + ex.Message.ToString();
 
             }
         }
@@ -1695,145 +2103,111 @@
         }
 
         /// <summary>
-        /// 鏃ヨ鍒掔敤鏂欐竻鍗曠敓鎴�
+        /// 鏃ヨ鍒掔敤鏂欐竻鍗曡繘搴︽潯
         /// </summary>
-        public void DayPlanPPBomBill()
+        private void DayPlanPPBomBill()
         {
-            Stopwatch sw = new Stopwatch();
-            sw.Start();//寮�濮嬭鏃�
-            LogHelper.Info("鎵归噺锛岀敓鎴愭棩璁″垝鐢ㄦ枡娓呭崟鍑嗗鏁版嵁");
-            //閿佸畾鐨勬棩璁″垝涓嶇敓鎴�
-            try
+            // 鏄剧ず涓�涓繘搴︽樉绀虹晫闈細鏄剧ず涓�涓笉鍋滄粴鍔ㄧ殑妯℃嫙杩涘害
+            // bUseTruePro鍙傛暟锛氭槸鍚︽樉绀虹湡瀹炵殑杩涘害銆�
+            // bUseTruePro = false 锛�
+            // 鏄剧ず涓�涓笉鍋滄粴鍔ㄧ殑妯℃嫙杩涘害锛屼笌瀹為檯澶勭悊杩涘害娌℃湁鍏宠仈銆�
+            // 姝ゆ柟妗堜紭鐐癸細瀹為檯澶勭悊浠g爜鏃犻渶璁$畻杩涘害
+            // 姝ゆ柟妗堢己鐐癸細杩涘害涓嶅噯纭紝涓旇繘搴﹂〉闈笉浼氳嚜鍔ㄥ叧闂��
+            // bUseTruePro = true: 杩涘害鐣岄潰鏄剧ず鐪熷疄杩涘害
+            // 姝ゆ柟妗堜紭鐐癸細杩涘害鐪熷疄
+            // 姝ゆ柟妗堢己鐐癸細闇�瑕佸湪澶勭悊浠g爜涓紝涓嶆柇鐨勬洿鏂扮湡瀹炶繘搴︼紝鏇存柊璇彞
+            // this.View.Session["ProcessRateValue"] = 100;
+            // 鐗瑰埆璇存槑锛屽綋杩涘害鏇存柊鍒�100鏃讹紝杩涘害鐣岄潰浼氳嚜鍔ㄥ叧闂�
+            // 鏈渚嬮�夌敤姝ゆ柟妗�
+            var processForm = this.View.ShowProcessForm(
+                new Action<FormResult>(t => { }),
+                true,
+                "姝e湪鐢熸垚锛岃绋嶅��...");
+
+            // 寮�鍚竴涓紓姝ョ嚎绋嬶紝澶勭悊寮曞叆鍔熻兘
+            // using Kingdee.BOS.KDThread;
+            MainWorker.QuequeTask(() =>
             {
-                string sql = string.Format(@"
-/*dialect*/
-select t1.FID,t1.FEntryID,t3.FMATERIALID,T5.FNUMBER,t1.FHMASTERDATE,t1.FHQTY,t4.FMATERIALID FMATERIALID2,T6.FNUMBER FNUMBER2,T7.FNUMBER FUNITNUMBER,FNumerator,FDenominator,convert(decimal(18,2),(FNumerator/FDenominator) *t1.FHQTY) FHQtyMust,T4.FUnitID,t8.FNUMBER FUNITNUMBER2,T3.FID FPPBOM,T4.FENTRYID,isnull(T9.FBillNo,'')FBillNo,t10.FNUMBER FORGNUMBER,t11.FNUMBER FHSOURCENUMBER,FSCRAPRATE,FFIXSCRAPQTY,T9.FID AS DayPlanFID
-FROM Sc_WorkBillSortBillSub t1
-JOIN Sc_WorkBillSortBillMAIN t2 on t1.FID = t2.FID
-JOIN T_PRD_PPBOM T3 on T2.FPRDMOMAINID=t3.FMOID AND T2.FPRDMOENTYID=T3.FMOENTRYID
-JOIN T_PRD_PPBOMENTRY T4 ON T3.FID=T4.FID
-JOIN T_BD_MATERIAL T5 ON T3.FMATERIALID=T5.FMATERIALID
-JOIN T_BD_MATERIAL T6 ON T4.FMATERIALID=T6.FMATERIALID
-LEFT JOIN T_BD_UNIT T7 ON T3.FUNITID = T7.FUNITID
-LEFT JOIN T_BD_UNIT T8 ON T4.FUNITID = T8.FUNITID
- LEFT JOIN Sc_DayPlanPPBomBillMain T9 ON T1.FEntryID=T9.FDayPlanFID
- LEFT join T_ORG_Organizations t10 on t2.FHPRDORGID = t10.FORGID
- LEFT join T_ENG_WORKCENTER t11 on t2.FHSOURCEID = t11.FID
- WHERE t1.FHQTY>0
-"
-);
-                LogHelper.Info("鎵归噺锛岀敓鎴愭棩璁″垝鐢ㄦ枡娓呭崟鍑嗗鏁版嵁sql:" + sql);
-                DataSet ds = DBServiceHelper.ExecuteDataSet(Context, sql);
-                DataTable dt = ds.Tables[0];
-                List<DayPlanMaterial> DayPlanMaterial = new List<DayPlanMaterial>();
-                if (dt.Rows.Count > 0)
+                var result = "鎿嶄綔鎴愬姛";
+                try
                 {
-                    foreach (DataRow dr in dt.Rows)
+                    // 闇�瑕佹崟鑾烽敊璇紝浠ョ‘淇濆鐞嗙粨鏉熸椂锛屽叧闂繘搴︽粴鍔ㄧ晫闈�
+                    // 寮曞叆鍔熻兘瀹為檯澶勭悊鍑芥暟
+                    result = this.DayPlanPPBomBillBatch();
+                }
+                finally
+                {
+                    // 纭繚鏍囪杩涘害宸茬粡鍒拌揪100%
+                    this.View.Session["ProcessRateValue"] = 100;
+                    // 寮曞叆瀹屾瘯锛屽叧闂繘搴︽樉绀洪〉闈�
+                    var processView = this.View.GetView(processForm.PageId);
+                    if (processView != null)
                     {
-                        DayPlanMaterial.Add(new Demo.Model.Model.DayPlanMaterial
-                        {
-                            FID = dr["DayPlanFID"].ToString(),
-                            FEntryID = dr["FEntryID"].ToString(),
-                            FHDate = DateTime.Now.ToString(),
-                            FOrgId = dr["FORGNUMBER"].ToString(),
-                            FHMaterID = dr["FNUMBER"].ToString(),
-                            FHWorkDate = dr["FHMASTERDATE"].ToString(),
-                            FHQty = dr["FHQTY"].ToString(),
-                            FHUnitID = dr["FUNITNUMBER"].ToString(),
-                            FDayPlanFID = dr["FEntryID"].ToString(),
-                            FHMaterSubID = dr["FNUMBER2"].ToString(),
-                            FHUnitSubID = dr["FUNITNUMBER2"].ToString(),
-                            FHQtyMust = dr["FHQtyMust"].ToString(),
-                            FHQtySub = dr["FHQtyMust"].ToString(),
-                            FHPPBomInterID = dr["FPPBOM"].ToString(),
-                            FHPPBomEntryID = dr["FENTRYID"].ToString(),
-                            FHSourceID = dr["FHSOURCENUMBER"].ToString(),
-                            FNumerator = dr["FNumerator"].ToString(),
-                            FDenominator = dr["FDenominator"].ToString(),
-                            FFIXSCRAPQTY = dr["FFIXSCRAPQTY"].ToString(),
-                            FHQtyScrap = dr["FSCRAPRATE"].ToString(),
-                        });
-                    }
-                    LogHelper.Info($"鎵归噺锛屾棩璁″垝鐢ㄦ枡娓呭崟锛屾暟鎹噯澶囧畬鎴愶紝淇濆瓨鍒癕odel瀹炰綋锛屾�昏鏁帮細{DayPlanMaterial.Count}锛岃�楁椂锛�" + sw.Elapsed);
-                    var fidList = DayPlanMaterial.Select(x => x.FEntryID).Distinct().ToList();
-                    foreach (var item in fidList)
-                    {
-                        var _DayPlanMaterial = DayPlanMaterial.Where(x => x.FEntryID == item).ToList();
-                        JObject model = new JObject();
-                        model.Add("FHDate", DateTime.Now);
-                        model.Add("FOrgId", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FOrgId });//鍙戞枡缁勭粐
-                        model.Add("FHMaterID", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FHMaterID });//鐗╂枡
-                        model.Add("FHWorkDate", _DayPlanMaterial[0].FHWorkDate);//鏃ュ伐鍗曟棩鏈� FHWorkDate
-                        model.Add("FHQty", _DayPlanMaterial[0].FHQty);//涓讳骇鍝佹暟閲忥細FHQty 
-                        model.Add("FHUnitID", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FHUnitID });//鍗曚綅锛欶HUnitID 
-                        model.Add("FDayPlanFID", _DayPlanMaterial[0].FDayPlanFID);//鏃ヨ鍒掑伐鍗曞唴鐮� 
-                        JArray Entry = new JArray();
-                        foreach (var _item in _DayPlanMaterial)
-                        {
-                            JObject ModelEnty = new JObject();
-                            ModelEnty.Add("FHMaterSubID", new JObject() { ["Fnumber"] = _item.FHMaterSubID });//瀛愮墿鏂橣HMaterSubID
-                            ModelEnty.Add("FHUnitSubID", new JObject() { ["Fnumber"] = _item.FHUnitSubID });//鍗曚綅FHUnitSubID
-                            ModelEnty.Add("FHQtyMust", _item.FHQtyMust);//搴斿彂鏁伴噺FHQtyMust
-                            ModelEnty.Add("FHQtySub", _item.FHQtySub);//鏁伴噺FHQtySub
-                            ModelEnty.Add("FHPPBomInterID", _item.FHPPBomInterID);//鐢ㄦ枡娓呭崟涓诲唴鐮丗HPPBomInterID
-                            ModelEnty.Add("FHPPBomEntryID", _item.FHPPBomEntryID);//鐢ㄦ枡娓呭崟瀛愬唴鐮丗HPPBomEntryID
-                            ModelEnty.Add("FHSourceID", new JObject() { ["Fnumber"] = _item.FHSourceID });//鐢熶骇璧勬簮FHSourceID
-                            ModelEnty.Add("FNumerator", _item.FNumerator);//鍒嗘瘝
-                            ModelEnty.Add("FDenominator", _item.FDenominator);//鍒嗗瓙
-                            ModelEnty.Add("FDwyl", Convert.ToDecimal(_item.FNumerator) / Convert.ToDecimal(_item.FDenominator));//鍗曚綅鐢ㄦ枡
-                            ModelEnty.Add("FFIXSCRAPQTY", _item.FFIXSCRAPQTY);//鍥哄畾鎹熻��
-                            ModelEnty.Add("FHQtyScrap", _item.FHQtyScrap);//鍙樺姩鎹熻�楃巼%
-                            Entry.Add(ModelEnty);
-                        }
-                        model.Add("FEntity", Entry);
-                        //if (!string.IsNullOrEmpty(_DayPlanMaterial[0].FID))
-                        //    model.Add("FID", _DayPlanMaterial[0].FID);
-                        JObject jsonRoot = new JObject()
-                        {
-                            ["Creator"] = "",
-                            ["NeedUpDateFields"] = new JArray(),
-                            ["NeedReturnFields"] = new JArray(),
-                            ["IsDeleteEntry"] = "true",
-                            ["SubSystemId"] = "",
-                            ["IsVerifyBaseDataField"] = "false",
-                            ["Model"] = model
-                        };
-
-                        CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
-                        var result = cloudClient.Save("Paez_Sc_DayPlanPPBomBill", jsonRoot.ToString());
-                        JObject saveObj = JObject.Parse(result);
-                        string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
-                        if (saveIsSuc != "TRUE")
-                        {
-                            LogHelper.Error(jsonRoot.ToString());
-
-                        }
+                        processView.Close();
+                        this.View.SendDynamicFormAction(processView);
+                        this.View.ShowMessage(result);
                     }
                 }
-                sw.Stop();//缁撴潫璁℃椂
-                LogHelper.Info("鎵归噺锛岀敓鎴愭棩璁″垝鐢ㄦ枡娓呭崟杩愯鎬绘椂闀匡細" + sw.Elapsed);
-            }
-            catch (Exception ex)
-            {
-                LogHelper.Error("鎵归噺锛岀敓鎴愭棩璁″垝鐢ㄦ枡娓呭崟+" + ex.Message.ToString());
-            }
+            },
+            (t) => { });
+
+            //this.View.ShowMessage("鎿嶄綔鎴愬姛");
         }
-        public void DayPlanPPBomBillBatch()
+
+        /// <summary>
+        /// 鏃ヨ鍒掔敤鏂欐竻鍗曠敓鎴�
+        /// </summary>  
+        public string DayPlanPPBomBillBatch()
         {
+            //LogService.WriteAsync(entrys);
+            //鏌ユ壘鍒扮殑鍚屾壒椤规
+            int day = Convert.ToInt32(this.Model.GetValue("FLockDays"));
+            Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
+            //鍗曟嵁浣撲俊鎭浆鎹负鍒楄〃闆嗗悎
+            DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
+            DynamicObjectCollection filterResult = entityDataObjoct.Clone();
+            filterResult.Clear();
+            entityDataObjoct.Where(x => Convert.ToBoolean(x["FFOCUS"])).ToList().ForEach(x => filterResult.Add(x));
+            string sqlWhere = " 1=1 ";
+            string FDayPlanWorkID = "";
+            string zxSql = "";
+            List<string> zxSqlList = new List<string>();
+            if (filterResult.Count() > 0)
+            {
+                foreach (var filter in filterResult)
+                {
+                    FDayPlanWorkID += filter["FDayPlanWorkID"].ToString() + ",";
+                    zxSqlList.Add(string.Format(@"/*dialect*/  
+ INSERT INTO Z_SC_TLPLANZXJH (COLUMN1) VALUES ('{0}') 
+ SELECT * FROM Z_SC_TLPLANZXJH
+ INSERT INTO SC_TLPLANZXJH(FID, FDAYPLANID, FCREATEDATE) SELECT *, GETDATE() FROM Z_SC_TLPLANZXJH
+ DELETE FROM Z_SC_TLPLANZXJH
+ SELECT * FROM SC_TLPLANZXJH", filter["FDayPlanWorkID"]));
+                }
+                FDayPlanWorkID = FDayPlanWorkID.TrimEnd(',');
+                sqlWhere += $"AND t2.FID IN ({FDayPlanWorkID})";
+            }
+            DBServiceHelper.ExecuteBatch(Context, zxSqlList);
             Stopwatch sw = new Stopwatch();
             sw.Start();//寮�濮嬭鏃�
+
             LogHelper.Info("鐢熸垚鏃ヨ鍒掔敤鏂欐竻鍗曞噯澶囨暟鎹�");
             //閿佸畾鐨勬棩璁″垝涓嶇敓鎴�
             try
             {
-                string sql = string.Format(@"
-/*dialect*/
- select t1.FID,t1.FSEQ FDayPlanFSEQ,t1.FEntryID,T2.FBILLNO AS FDayPlanFBILLNO,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
+                string sql = string.Format(@"/*dialect*/
+select t1.FID,t1.FSEQ FDayPlanFSEQ,t1.FEntryID,T2.FBILLNO AS FDayPlanFBILLNO,t3.FMATERIALID,t3.FMOEntrySeq as FMoSeq,T5.FNUMBER,t1.FHMASTERDATE,t1.FHQTY,t4.FMATERIALID FMATERIALID2,T6.FNUMBER FNUMBER2,T7.FNUMBER FUNITNUMBER,FNumerator,FDenominator,convert(decimal(18,2),(t4.FMustQty/T3.FQTY) *t1.FHQTY) FHQtyMust,T4.FUnitID,t8.FNUMBER FUNITNUMBER2,T3.FID FPPBOM,T4.FENTRYID FPPBOMENTRYID,isnull(T9.FBillNo,'')FBillNo,t10.FNUMBER FORGNUMBER,t11.FNUMBER FHSOURCENUMBER,FSCRAPRATE,FFIXSCRAPQTY,T9.FID AS DayPlanFID,t2.FSCORDERNO,
+t3.FMOENTRYID,t3.FBILLNO FPPBOMBILLNO,T4.FSEQ,tc.FOWNERTYPEID,tc.FOWNERID,tc.FEntrustPickOrgId,torg.FNUMBER as FORGNUMBER,t3.FMOID,FIssueType,FMaterialType,td.FNUMBER as FWORKSHOPID,t4.FReplaceGroup,isnull(ttt.FrowCount,0)FIsTDL,t4.FUseRate
 FROM Sc_WorkBillSortBillSub t1
 JOIN Sc_WorkBillSortBillMAIN t2 on t1.FID = t2.FID
 JOIN T_PRD_PPBOM T3 on T2.FPRDMOMAINID=t3.FMOID AND T2.FPRDMOENTYID=T3.FMOENTRYID
 JOIN T_PRD_PPBOMENTRY T4 ON T3.FID=T4.FID
+left join
+(
+	select FREPLACEGROUP,COUNT(*) FrowCount,FID  from T_PRD_PPBOMENTRY
+	GROUP BY FREPLACEGROUP,FID
+	having count(*) >1
+) ttt on t4.FID = ttt.FID and  t4.FREPLACEGROUP =ttt.FREPLACEGROUP 
 JOIN T_PRD_PPBOMENTRY_C Tc ON T4.FENTRYID=Tc.FENTRYID
 join T_ORG_Organizations torg ON tc.FOWNERID = torg.FORGID 
 JOIN T_BD_MATERIAL T5 ON T3.FMATERIALID=T5.FMATERIALID
@@ -1843,9 +2217,27 @@
  LEFT JOIN Sc_DayPlanPPBomBillMain T9 ON T1.FEntryID=T9.FDayPlanFID
  LEFT join T_ORG_Organizations t10 on t2.FHPRDORGID = t10.FORGID
  LEFT join T_ENG_WORKCENTER t11 on t2.FHSOURCEID = t11.FID
- WHERE t1.FHQTY>0
-"
-);
+ left join T_BD_DEPARTMENT td on t3.FWORKSHOPID=td.FDEPTID
+ WHERE
+t1.FHMASTERDATE between  DATEADD(day,-1,getdate()) and DATEADD(day,{{1} - 1},getdate())
+and t1.FEntryID not in 
+(
+select distinct FDAYPLANFID from Sc_DayPlanPPBomBillMain where FID IN 
+(
+--棰嗘枡鍗�
+select distinct FDAYPLANFID from T_PRD_PICKMTRLDATA
+union all
+--鏃ヨ鍒掔敤鏂欐竻鍗曞彉鏇村崟
+select distinct FDAYPLANID from Sc_DayPlanPPBomBillSubBG
+)
+)
+AND {0}
+-- and T4.FMustQty>0
+-- (
+-- select  FDayPlanFID FROM Sc_DayPlanPPBomBillMain WHERE FID IN ( select distinct FID from  Sc_DayPlanPPBomBillSub WHERE FTranslateQty >0 or FPickedQty >0)
+-- )
+",
+sqlWhere, day);
                 LogHelper.Info("鐢熸垚鏃ヨ鍒掔敤鏂欐竻鍗曞噯澶囨暟鎹畇ql:" + sql);
                 DataSet ds = DBServiceHelper.ExecuteDataSet(Context, sql);
                 DataTable dt = ds.Tables[0];
@@ -1887,16 +2279,22 @@
                             FIssueType = dr["FIssueType"].ToString(),
                             FMaterialType = dr["FMaterialType"].ToString(),
                             FDayPlanFSEQ = dr["FDayPlanFSEQ"].ToString(),
-                            FDayPlanFBILLNO = dr["FDayPlanFBILLNO"].ToString()
+                            FDayPlanFBILLNO = dr["FDayPlanFBILLNO"].ToString(),
+                            FWORKSHOPID = dr["FWORKSHOPID"].ToString(),
+                            FReplaceGroup = dr["FReplaceGroup"].ToString(),
+                            FUseRate = dr["FUseRate"].ToString(),
+                            FIsTDL = dr["FIsTDL"].ToString(),
+                            FMoSeq = dr["FMoSeq"].ToString(),
                         });
                     }
                     LogHelper.Info($"鏃ヨ鍒掔敤鏂欐竻鍗曪紝鏁版嵁鍑嗗瀹屾垚锛屼繚瀛樺埌Model瀹炰綋锛屾�昏鏁帮細{DayPlanMaterial.Count}锛岃�楁椂锛�" + sw.Elapsed);
                     var fidList = DayPlanMaterial.Select(x => x.FEntryID).Distinct().ToList();
                     int i = 1;
+                    int jdtmmm = 1;
                     JArray Fentity = new JArray();
                     foreach (var item in fidList)
                     {
-                        var _DayPlanMaterial = DayPlanMaterial.Where(x => x.FEntryID == item).ToList();
+                        var _DayPlanMaterial = DayPlanMaterial.Where(x => x.FEntryID == item).OrderBy(x => Convert.ToInt32(x.FReplaceGroup)).ToList();
                         JObject model = new JObject();
 
                         if (!string.IsNullOrEmpty(_DayPlanMaterial[0].FID))
@@ -1929,6 +2327,7 @@
                             ModelEnty.Add("FHQtyScrap", _item.FHQtyScrap);//鍙樺姩鎹熻�楃巼%
                             ModelEnty.Add("FMOBILLNO", _item.FMOBILLNO);//  
                             ModelEnty.Add("FMOENTRYIDINT", _item.FMOENTRYID);//  
+                            ModelEnty.Add("FMoSeq", _item.FMoSeq);//  
                             ModelEnty.Add("FPPBOMBILLNO", _item.FPPBOMBILLNO);//  
                             ModelEnty.Add("FPPBOMFSEQINT", _item.FPPBOMFSEQ);//  
                             ModelEnty.Add("FOwnerTypeId", _item.FOwnerTypeId);//  
@@ -1937,10 +2336,12 @@
                             ModelEnty.Add("FMOID", _item.FMOID);//  
                             ModelEnty.Add("FISSUETYPE", _item.FIssueType);//  
                             ModelEnty.Add("FMaterialType", _item.FMaterialType);//  
-                                                                                // ModelEnty.Add("FSEQ", FSEQ);//  
+                            ModelEnty.Add("FWORKSHOPID", new JObject() { ["Fnumber"] = _item.FWORKSHOPID });// 
+                            ModelEnty.Add("FReplaceGroup", _item.FReplaceGroup);// 
+                            ModelEnty.Add("FUseRate", _item.FUseRate);// 
+                            ModelEnty.Add("FIsTDL", Convert.ToInt32(_item.FIsTDL) > 0 ? 1 : 0);// 
                             Entry.Add(ModelEnty);
                             FSEQ++;
-
                         }
                         model.Add("FEntity", Entry);
 
@@ -1956,28 +2357,52 @@
                                 ["IsDeleteEntry"] = "true",
                                 ["SubSystemId"] = "",
                                 ["IsVerifyBaseDataField"] = "false",
+                                ["IsAutoSubmitAndAudit"] = true,//鑷姩璋冪敤鎻愪氦鍜屽鏍稿姛鑳�
                                 ["Model"] = Fentity
                             };
                             CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
                             var result = cloudClient.BatchSave("Paez_Sc_DayPlanPPBomBill", jsonRoot.ToString());
                             JObject saveObj = JObject.Parse(result);
                             string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
+                            if (saveIsSuc == "TRUE")
+                            {
+                                var Success = saveObj["Result"]["ResponseStatus"]["SuccessEntitys"].ToString().TrimStart('{').TrimEnd('}');
+                                var allList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Dictionary<string, string>>>(Success);
+                                List<string> ls = new List<string>();
+                                foreach (var it in allList)
+                                {
+                                    it.TryGetValue("Id", out string value);
+                                    ls.Add(value);
+                                }
+                                var resultAA = String.Join(",", ls.ToArray());
+                                string resSql = string.Format(@"/*dialect*/ update Sc_WorkBillSortBillSub set Sc_WorkBillSortBillSub.FDAYPLANPPBOMBILLNO = Sc_DayPlanPPBomBillMain.FBILLNO from Sc_WorkBillSortBillSub   join Sc_DayPlanPPBomBillMain   on Sc_WorkBillSortBillSub.FEntryID = Sc_DayPlanPPBomBillMain.FDayPlanFID where Sc_DayPlanPPBomBillMain.FID in ({0})", resultAA);
+                                DBServiceHelper.Execute(Context, resSql);
+                            }
                             if (saveIsSuc != "TRUE")
                             {
-                                LogHelper.Error("鏃ヨ鍒掔敤鏂欐竻鍗曞垪琛ㄧ敓鎴愬け璐�:" + jsonRoot.ToString());
-                                this.View.ShowMessage(saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString());
+                                //LogHelper.Error("鏃ヨ鍒掔敤鏂欐竻鍗曞垪琛ㄧ敓鎴愬け璐�:" + jsonRoot.ToString());
+                                LogHelper.Error(saveObj.ToString());
+                                return "鎿嶄綔澶辫触锛�" + saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString();
+                                //this.View.ShowMessage(saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString());
                             }
                             Fentity = new JArray();
                         }
                         i++;
+
+                        this.View.Session["ProcessRateValue"] = Convert.ToInt32((Convert.ToDecimal(80) / fidList.Count) * jdtmmm);
+                        //Thread.Sleep(6000);
+                        jdtmmm++;
                     }
                 }
                 sw.Stop();//缁撴潫璁℃椂
                 LogHelper.Info("鐢熸垚鏃ヨ鍒掔敤鏂欐竻鍗曡繍琛屾�绘椂闀匡細" + sw.Elapsed);
+                return "鎿嶄綔鎴愬姛";
             }
             catch (Exception ex)
             {
                 LogHelper.Error("鏃ヨ鍒掔敤鏂欐竻鍗�+" + ex.Message.ToString());
+                return "鎿嶄綔澶辫触锛�" + ex.Message.ToString();
+                //this.View.ShowErrMessage(ex.Message.ToString());
             }
         }
 
@@ -2022,7 +2447,8 @@
                 LogHelper.Info("[鎻愭枡璁″垝鍑嗗闃舵]鍙敤閲囪喘璁㈠崟鏁版嵁sql锛�" + sql);
                 sql = string.Format(@"
  /*dialect*/
- SELECT T1.FID,FHMATERID,FHMASTERDATE,FHQTY,FCOMPLETECOUNT,FPRDMOMAINID,T2.FENTRYID,T1.FBILLNO, FNeedQty,(FLeadtime+FLeadTtime2)FFIXLEADTIME,t5.FMAXPOQTY,FJITBatch FMINPOQTY,FJITMATERIALGROUP,FJITMaterielDemand,FJITSafeStock,t3.FMATERIALID,t6.FNumber,FHQTY*FNeedQty NeedQty,FHPRDORGID FStockOrgId FROM  SC_WORKBILLSORTBILLMAIN T1 
+ SELECT T1.FID,FHMATERID,FHMASTERDATE,FHQTY,FCOMPLETECOUNT,FPRDMOMAINID,T2.FENTRYID,T1.FBILLNO, FNeedQty,(FLeadtime+FLeadTtime2)FFIXLEADTIME,t5.FMAXPOQTY,FJITBatch FMINPOQTY,FJITMATERIALGROUP,FJITMaterielDemand,FJITSafeStock,t3.FMATERIALID,t6.FNumber,FHQTY*FNeedQty NeedQty,FHPRDORGID FStockOrgId
+FROM  SC_WORKBILLSORTBILLMAIN T1 
 JOIN SC_WORKBILLSORTBILLSUB T2 ON T1.FID=T2.FID
 LEFT JOIN(SELECT T1.FID,max(t2.FMATERIALID)FMATERIALIDMAIN, max(t2.FMoId)FMoId,MAX(FENTRYID) FENTRYID, SUM(convert(decimal(18, 2), FBASENUMERATOR / FBASEDENOMINATOR))FNeedQty, T1.FMATERIALID from T_PRD_PPBOMENTRY  T1
 JOIN T_PRD_PPBOM   T2 on t1.FID = t2.FID
@@ -2094,7 +2520,7 @@
                         _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);
+                            //LogHelper.Info("[鎻愭枡璁″垝寮�濮媇褰撳墠鐗╂枡鏄庣粏鏃犻噰璐俊鎭細" + item.FMATERIALID + " 搴撳瓨缁勭粐锛�" + item.FStockOrgId);
                             break;
                         }
 
@@ -2118,7 +2544,7 @@
                         //{
                         foreach (var Purchase in _PurchaseInventory)
                         {
-                            LogHelper.Info("閲囪喘璁㈠崟鍙锋祴璇曪細" + Purchase.FBillNo);
+                            //LogHelper.Info("閲囪喘璁㈠崟鍙锋祴璇曪細" + Purchase.FBillNo);
                             //LogHelper.Info("鐗╂枡锛�" + Purchase.FMATERIALID + ",閲囪喘璁㈠崟鏁伴噺锛�" + Purchase.FQTY);
                             if (Purchase.FQTY >= NeedQty)
                             {
@@ -2169,8 +2595,8 @@
                                 {
                                     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 == 0)
+                                                                         //    LogHelper.Info("璁㈠崟鏁伴噺涓�0");
                                     if (Qty > _NeedQty)
                                         Qty = _NeedQty; //璁㈠崟鏁伴噺>閲囪喘璁㈠崟鏁伴噺 鍙栭噰璐鍗�
 
@@ -2367,7 +2793,7 @@
                         FentityModel.Add("FHPOOrderEntryID", _item.PurchseFentryID); //閲囪喘璁㈠崟瀛愬唴鐮侊細FHPOOrderEntryID
                         FentityModel.Add("FHPOOrderBillNo", _item.PurchseFBillNo); //閲囪喘璁㈠崟鍙凤細FHPOOrderBillNo
                         FentityModel.Add("FERPCLSID", _item.FErpClsID); //鍙戞枡鏂瑰紡
-                        //FentityModel.Add("FSEQ", FSEQ); //鍙戞枡鏂瑰紡
+                                                                        //FentityModel.Add("FSEQ", FSEQ); //鍙戞枡鏂瑰紡
                         FentityModel.Add("FUnitID", new JObject() { ["Fnumber"] = "Pcs" }); //鍙戞枡鏂瑰紡
 
                         Fentity.Add(FentityModel);
@@ -2541,7 +2967,7 @@
                         lockStockArgs.FID = Convert.ToInt32(current["FHMainSourceInterID"]); //鐢熶骇璁㈠崟琛孖D
                         lockStockArgs.BaseQty = decimal.Parse(dr["FBASEQTY"].ToString());//鍩烘湰鍗曚綅鏁伴噺
                         lockStockArgs.BaseUnitID = int.Parse(dr["FBASEUNITID"].ToString());//鍩烘湰鍗曚綅
-                        //lockStockArgs.Lot = Convert.ToString(current["FBatch"]); ;//鎵规 FBatch
+                                                                                           //lockStockArgs.Lot = Convert.ToString(current["FBatch"]); ;//鎵规 FBatch
                         lockStockArgs.MaterialID = long.Parse(dr["FMATERIALID2"].ToString());
                         lockStockArgs.OwnerID = long.Parse(dr["FOwnerID"].ToString());
                         lockStockArgs.OwnerTypeID = dr["FOwnerTypeID"].ToString();
@@ -2617,6 +3043,51 @@
                 this.View.ShowErrMessage(ex.Message.ToString());
             }
         }
+
+        public void SelectMenu()
+        {
+            //鑾峰彇鍗曟嵁浣撲俊鎭�
+            Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
+            //鍗曟嵁浣撲俊鎭浆鎹负鍒楄〃闆嗗悎
+            DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
+            int Fseq = entityDataObjoct.Count();
+
+            string pageId = Guid.NewGuid().ToString();
+            ListShowParameter showParameter = new ListShowParameter();
+            showParameter.FormId = "PRD_MO";
+            showParameter.PageId = pageId;
+            showParameter.UseOrgId = this.Context.CurrentOrganizationInfo.ID;
+            showParameter.IsLookUp = true;
+            this.View.ShowForm(showParameter);
+
+            this.View.ShowForm(showParameter, delegate (FormResult result)
+            {
+                object returnData = result.ReturnData;
+                if (returnData is ListSelectedRowCollection)
+                {
+                    ListSelectedRowCollection listSelectedRowCollection = returnData as ListSelectedRowCollection;
+                    if (listSelectedRowCollection != null)
+                    {
+                        foreach (var listSelectedRow in listSelectedRowCollection)
+                        {
+                            string sql = $"select DATEDIFF(d,FPlanStartDate,getdate())days from T_PRD_MOENTRY where FENTRYID = {listSelectedRow.DataRow["t1_FENTRYID"].ToString()}";
+                            int day = DBServiceHelper.ExecuteScalar<int>(Context, sql, 0);
+                            this.Model.CreateNewEntryRow("FEntity");
+                            this.View.Model.SetItemValueByNumber("FORGID", "100", Fseq);
+                            this.View.Model.SetValue("FSCOrderNo", listSelectedRow.DataRow["FBillNo"].ToString(), Fseq);
+                            this.View.Model.SetValue("FSRCBILLENTRYSEQ", listSelectedRow.DataRow["t1_FSeq"].ToString(), Fseq);
+                            this.View.Model.SetValue("FMatrailId", listSelectedRow.DataRow["FMaterialId_Id"].ToString(), Fseq);//2129900005
+                            this.View.Model.SetValue("FFUnit", listSelectedRow.DataRow["FUnitId_Id"].ToString(), Fseq);
+                            this.View.Model.SetValue("FOrderQuantity", listSelectedRow.DataRow["FQty"].ToString(), Fseq);
+                            this.View.Model.SetValue("FProductWorkShopId", listSelectedRow.DataRow["FWorkShopID_Id"].ToString(), Fseq);
+                            this.View.Model.SetValue("FOrderLevel", "3", Fseq);
+                            this.View.Model.SetValue("FT" + day.ToString(), listSelectedRow.DataRow["FQty"].ToString(), Fseq);
+                            Fseq++;
+                        }
+                    }
+                }
+            });
+        }
     }
 }
 

--
Gitblit v1.9.1