From 2e5a31b54bc716a9dcaf28df6870b372f9af795c Mon Sep 17 00:00:00 2001
From: 王 垚 <1402714037@qq.com>
Date: 星期二, 23 二月 2021 09:23:30 +0800
Subject: [PATCH] 问题更改上传

---
 src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs |  205 ++++++++++++++++++++++++++++----------------------
 1 files changed, 114 insertions(+), 91 deletions(-)

diff --git a/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs b/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs
index 562a6ed..c41185e 100644
--- a/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs
+++ b/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs
@@ -27,11 +27,8 @@
     [HotUpdate]
     public class Pro_ScDayImport : AbstractDynamicFormPlugIn
     {
-
-
-
+        CloudClient cloudClient = new CloudClient("http://localhost/K3Cloud/");
         private string fileFullPath = string.Empty;
-
         //public override void BarItemClick(Kingdee.BOS.Core.DynamicForm.PlugIn.Args.BarItemClickEventArgs e)
         //{
         //    base.BarItemClick(e);
@@ -53,13 +50,12 @@
         //    }
 
         //}
-
-
         public override void AfterBarItemClick(AfterBarItemClickEventArgs e)
         {
             base.AfterBarItemClick(e);
             if (e.BarItemKey.ToUpper().Equals("TBIMPORT"))
             {
+                LogService.WriteAsync("瀵煎叆鍔熻兘锛�");
                 ImportData();
             }
 
@@ -72,7 +68,8 @@
                 //// 涓嬭浇鍦板潃
                 //string downloadUrl = "FileUpLoadServices/download.aspx";
                 //updateControl.SetCustomPropertyValue("ExDownLoadUrl", downloadUrl);
-
+                LogHelper.Info("222222");
+                LogService.WriteAsync("涓婁紶鍔熻兘锛�");
                 ImportDataSC(fileFullPath);
             }
         }
@@ -98,6 +95,10 @@
             }
             base.CustomEvents(e);
         }
+        /// <summary>
+        /// 鏂囦欢涓婁紶鐣岄潰鏁版嵁鏄剧ず
+        /// </summary>
+        /// <param name="fileFullPath"></param>
         private void ImportDataSC(string fileFullPath)
         {
             using (ExcelOperation helper = new ExcelOperation(this.View))
@@ -106,17 +107,40 @@
                 {
                     DataSet ds = helper.ReadFromFile(fileFullPath, 1);
                     DataTable dt = ds.Tables[0];
-
+                    LogService.WriteAsync("瀵煎叆鍔熻兘锛歞t琛屾暟锛�" + dt.Rows.Count);
                     DateTime date = Convert.ToDateTime(this.Model.GetValue("F_Paez_Date"));
                     if (dt.Rows.Count > 0)
                     {
-                        //Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
-                        //DynamicObjectCollection rows = this.Model.GetEntityDataObject(entity);
-                        this.Model.DeleteEntryData("FEntity");
-
+                        //楠岃瘉瀵煎叆妯℃澘
+                        string ErrorResult = "";
+                        string error = "";
                         for (int i = 0; i < dt.Rows.Count; i++)
                         {
+                            error = "";
+                            if (dt.Rows[i][1].ToString() == "")
+                                error += "鐢熶骇璁㈠崟鍙蜂笉鑳戒负绌�;";
+                            if (dt.Rows[i][2].ToString() == "")
+                                error += "鐢熶骇缁勭粐涓嶈兘涓虹┖;";
+                            if (dt.Rows[i][3].ToString() == "")
+                                error += "鐢熶骇杞﹂棿涓嶈兘涓虹┖;";
+                            if (dt.Rows[i][5].ToString() == "")
+                                error += "浜у搧浠g爜涓嶈兘涓虹┖;";
+                            if (dt.Rows[i][13].ToString() == "")
+                                error += "浜よ揣鏃ユ湡涓嶈兘涓虹┖;";
+                            if (dt.Rows[i][14].ToString() == "")
+                                error += "璁㈠崟绛夌骇涓嶈兘涓虹┖;";
 
+                            if (error.Length > 0)
+                                ErrorResult += $"Excel妯℃澘瀛樺湪閿欒锛岃鏁皗i + 1}:{error}\r\n";
+                        }
+                        if (ErrorResult.Length > 0)
+                        {
+                            this.View.ShowErrMessage(ErrorResult);
+                            return;
+                        }
+                        this.Model.DeleteEntryData("FEntity");
+                        for (int i = 0; i < dt.Rows.Count; i++)
+                        {
                             //鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鏄庣粏
                             string sql = string.Format(@"/*dialect*/ SELECT T1.FBILLNO,T2.* FROM T_PRD_MO T1
 LEFT JOIN T_PRD_MOENTRY T2 ON T1.FID = T2.FID
@@ -124,19 +148,27 @@
 WHERE T1.FBILLNO = '{0}'  AND T3.FNUMBER = '{1}'", dt.Rows[i][1].ToString(), dt.Rows[i][5].ToString());
                             DataTable _dt = new DataTable();
                             _dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
-
-
                             string FLOT = "";//FLOT  鎵规
                             string FQTY = "";//FQTY 鐢熶骇璁㈠崟鏁伴噺
                             string FBILLNO = "";//FBILLNO 鍘熷崟鍙� 
-
                             if (_dt.Rows.Count > 0)
                             {
                                 FLOT = _dt.Rows[0]["FLOT"].ToString();
                                 FQTY = _dt.Rows[0]["FQTY"].ToString();
                                 FBILLNO = _dt.Rows[0]["FBILLNO"].ToString();
                             }
-
+                            //鐗╂枡缂栫爜 + 鐢熶骇璁㈠崟鍙� + 鐢熶骇璧勬簮 鍘诲垽鏂槸鍚﹀鍏ヨ繃 甯﹀嚭鏃ヨ鍒掑伐鍗旾D鍙婄紪鍙�
+                            string fDayPlanID = "";
+                            string fDayPlanBillNo = "";
+                            sql = string.Format(@"select a.FID,FBILLNO,FSCOrderNo,FHMaterID,FHSourceID from Sc_WorkBillSortBillMain a JOIN T_BD_MATERIAL b ON a.FHMaterID = b.FMATERIALID 
+left join T_ENG_WORKCENTER c on a.FHSourceID=c.fid 
+ where FSCOrderNo ='{0}' and b.FNUMBER ='{1}' and (isnull(c.FNUMBER,'') ='{2}' or (select count(*) from T_ENG_WORKCENTER where isnull(c.FNUMBER,'') ='{2}')=0)", dt.Rows[i][1].ToString(), dt.Rows[i][5].ToString(), dt.Rows[i][4].ToString());
+                            DataTable dayPlanDt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
+                            if (dayPlanDt.Rows.Count > 0)
+                            {
+                                fDayPlanID = dayPlanDt.Rows[0]["FID"].ToString();
+                                fDayPlanBillNo = dayPlanDt.Rows[0]["FBILLNO"].ToString();
+                            }
                             //DynamicObject row = new DynamicObject(entity.DynamicObjectType);
                             this.Model.CreateNewEntryRow("FEntity");
                             this.Model.SetValue("FSEQ", i + 1, i);
@@ -147,27 +179,23 @@
                             this.Model.SetItemValueByNumber("FResourcesId", dt.Rows[i][4].ToString(), i);
                             //  this.Model.SetValue("FMatrailId", dt.Rows[i][5].ToString(), i);
                             this.Model.SetItemValueByNumber("FMatrailId", dt.Rows[i][5].ToString(), i);
-                            this.Model.SetValue("FMatrailName", dt.Rows[i][6].ToString(), i);
-                            this.Model.SetValue("FModel", dt.Rows[i][7].ToString(), i);
-                            this.Model.SetValue("FUnit", dt.Rows[i][8].ToString(), i);
                             this.Model.SetValue("FBatch", dt.Rows[i][9].ToString(), i);
                             this.Model.SetValue("FSalOrderCount", dt.Rows[i][10].ToString(), i);
                             this.Model.SetValue("FCompleteSetCount", dt.Rows[i][12].ToString(), i);
                             this.Model.SetValue("FDeliveryDate", ToDateTimeValue(dt.Rows[i][13].ToString()), i);
-                            this.Model.SetValue("FOrderLevel", dt.Rows[i][14].ToString(), i);
+                            this.Model.SetValue("FOrderLevel", OrderType(dt.Rows[i][14].ToString()), i);
                             this.Model.SetValue("FOrderQuantity", FQTY, i);
+                            this.Model.SetValue("FDayPlanID", fDayPlanID, i);//鏃ヨ鍒掑伐鍗旾D
+                            this.Model.SetValue("FDayPlanBillNo", fDayPlanBillNo, i);//鏃ュ伐鍗曠紪鍙�
                             for (int j = 0; j <= 60; j++)
                             {
                                 this.Model.SetValue("FT" + "" + j + "", dt.Rows[i][15 + j].ToString(), i);
                             }
-
                             //璋冪敤鏁伴噺鍊兼洿鏂�
                             this.View.InvokeFieldUpdateService("FT0", i);
                         }
                     }
-
                     this.View.UpdateView();
-
                     for (int j = 0; j <= 60; j++)
                     {
                         this.View.GetControl("FT" + "" + j + "").Text = date.AddDays(j).ToShortDateString();
@@ -179,7 +207,30 @@
 
 
         }
+        /// <summary>
+        /// 璁㈠崟鐘舵�佺瓑绾�
+        /// </summary>
+        /// <param name="Type"></param>
+        /// <returns></returns>
+        public string OrderType(string Type)
+        {
+            switch (Type)
+            {
 
+                case "鐗规��":
+                    return "1";
+                    break;
+                case "绱ф��":
+                    return "2";
+                    break;
+                case "鏅��":
+                    return "3";
+                    break;
+                default:
+                    return " ";
+                    break;
+            }
+        }
         /// <summary>  
         /// 鏃堕棿鎴砊imestamp杞崲鎴愭棩鏈�  
         /// </summary>  
@@ -193,7 +244,6 @@
             DateTime targetDt = dtStart.Add(toNow);
             return targetDt;
         }
-
         /// <summary>
         /// 瀵煎叆鍔熻兘
         /// </summary>
@@ -202,14 +252,26 @@
             try
             {
                 LogService.WriteAsync("娴嬭瘯");
-
                 string sql;
                 DateTime date = Convert.ToDateTime(this.Model.GetValue("F_Paez_Date"));
                 //鑾峰彇鍗曟嵁浣撲俊鎭�
                 Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
                 //鍗曟嵁浣撲俊鎭浆鎹负鍒楄〃闆嗗悎
                 DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
-
+                List<string> sqlList = new List<string>();
+                foreach (DynamicObject current in entityDataObjoct)
+                {
+                    if (Convert.ToString(current["FDayPlanID"]) == "0")
+                        continue;
+                    for (int i = 0; i <= 60; i++)
+                    {
+                        JObject jsonFPOOrderEntry = new JObject();
+                        //閲嶅瀵煎叆鐨勬洿鏂版帀璁″垝鏁伴噺浠ュ強鏇存柊榻愬鐘舵�佷负绌�
+                        sql = string.Format($"update SC_WORKBILLSORTBILLSub set FHQTY ='{Convert.ToString(current["FT" + "" + i + ""])}',FCOMPLETE='' where FID ={Convert.ToString(current["FDayPlanID"])} and FHMASTERDATE ={date.AddDays(i).ToShortDateString()} and FHLOCKEDSUB = 0");
+                        sqlList.Add(sql);
+                    }
+                }
+                int res = DBServiceHelper.ExecuteBatch(Context, sqlList);
                 string _result = "";
                 foreach (DynamicObject current in entityDataObjoct)
                 {
@@ -228,24 +290,20 @@
                     this.View.ShowErrMessage(_result);
                     return;
                 }
-
                 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)
                 {
-                    if (string.IsNullOrEmpty(Convert.ToString(current["FSalOrderNo"])) || string.IsNullOrEmpty(Convert.ToString(current["FSCOrderNo"])))
+                    if (string.IsNullOrEmpty(Convert.ToString(current["FSCOrderNo"])))
                         continue;
-
                     //鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鏄庣粏
                     sql = string.Format(@"/*dialect*/SELECT T1.FBILLNO,T2.* FROM T_PRD_MO T1
                                 LEFT JOIN T_PRD_MOENTRY T2 ON T1.FID = T2.FID
@@ -254,13 +312,11 @@
                     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 鍘熷崟鍙� 
-
                     if (dt.Rows.Count > 0)
                     {
                         FID = dt.Rows[0]["FID"].ToString();
@@ -269,22 +325,19 @@
                         FQTY = dt.Rows[0]["FQTY"].ToString();
                         FBILLNO = dt.Rows[0]["FBILLNO"].ToString();
                     }
-
-
                     JObject jsonRoot = new JObject();
                     jsonRoot.Add("Creator", "");
                     jsonRoot.Add("NeedUpDateFields", new JArray());
                     jsonRoot.Add("NeedReturnFields", new JArray());
-                    jsonRoot.Add("IsDeleteEntry", "true");
+                    jsonRoot.Add("IsDeleteEntry", "false");
                     jsonRoot.Add("SubSystemId", "");
                     jsonRoot.Add("IsVerifyBaseDataField", "");
-
                     JObject jsonModel = new JObject();
                     jsonModel.Add("FPreparatDate", date.ToString());//缂栧埗鏃ユ湡
                     jsonModel.Add("FSCOrderNo", current["FSCOrderNo"].ToString()); //鐢熶骇璁㈠崟鍙稦SCOrderNo
-                    jsonModel.Add("FHSeOrderBillNo", current["FSalOrderNo"].ToString());//閿�鍞鍗曞彿
+                    jsonModel.Add("FHSeOrderBillNo", Convert.ToString(current["FSalOrderNo"]));//閿�鍞鍗曞彿
                     jsonModel.Add("FHOrderLev", current["FOrderLevel"].ToString());//璁㈠崟绛夌骇
-                    jsonModel.Add("FSalOrderCount", current["FOrderLevel"].ToString());//閿�鍞鍗曟暟閲�
+                    jsonModel.Add("FHOrderQty", Convert.ToString(current["FSalOrderCount"]));//閿�鍞鍗曟暟閲�
                     jsonModel.Add("FHOrderCommitDate", current["FDeliveryDate"].ToString());//浜よ揣鏈烪OrderCommitDate
                                                                                             //jsonModel.Add("FBatch", current["FBatch"].ToString());//鎵规
                     jsonModel.Add("FBatch", FLOT);//鎵规
@@ -292,18 +345,12 @@
                     jsonModel.Add("FPrdBillNo", FBILLNO); ;//婧愬崟缂栧彿
                     jsonModel.Add("FPRDMOMAINID", FID); ;//婧愬崟涓诲唴鐮�
                     jsonModel.Add("FPRDMOENTYID", FENTRYID); ;//婧愬崟瀛愬唴鐮�
-
                     jsonModel.Add("FOrderQuantity", current["FOrderQuantity"].ToString()); ;//鐢熶骇璁㈠崟鏁伴噺
                     jsonModel.Add("FDayPlanQuantity", current["FDayPlanQuantity"].ToString()); ;//鏃ヨ鍒掓暟閲�
                     jsonModel.Add("FNoScheduled", current["FNoScheduled"].ToString()); ;//鏈帓鏁伴噺
-
-
-
-
                     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();
@@ -317,7 +364,6 @@
                         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();
@@ -325,28 +371,23 @@
                         jsonModel.Add("FHWorkShopID", jsonFResourcesId);//FHWorkShopID  鐢熶骇璧勬簮
                     }
                     JArray Entry = new JArray();
-                    for (int i = 0; i <= 60; i++)
-                    {
-                        JObject jsonFPOOrderEntry = new JObject();
-
-                        jsonFPOOrderEntry.Add("FHMasterDate", date.AddDays(i).ToShortDateString()); ;//涓绘棩鏈�
-                        jsonFPOOrderEntry.Add("FHQty ", Convert.ToString(current["FT" + "" + i + ""])); ;//鏃ヨ鍒掓暟閲�
-                        jsonFPOOrderEntry.Add("FColumn", "FT" + "" + i + ""); ;//瀵瑰簲鐨勫垪澶�
-                                                                               //jsonFPOOrderEntry.Add("FHMainSourceBillType ", "鐢熶骇璁㈠崟"); ;//婧愬崟绫诲瀷
-                                                                               //jsonFPOOrderEntry.Add("FHMainSourceBillNo", FBILLNO); ;//婧愬崟缂栧彿
-                                                                               //jsonFPOOrderEntry.Add("FHMainSourceInterID", FID); ;//婧愬崟涓诲唴鐮�
-                                                                               //jsonFPOOrderEntry.Add("FHMainSourceEntryID", FENTRYID); ;//婧愬崟瀛愬唴鐮�
-
-                        Entry.Add(jsonFPOOrderEntry);
-                    }
-
-                    jsonModel.Add("FEntity", Entry);
-                    //鏃ヨ鍒掑伐鍗曚笉涓虹┖鏃秛pdate
                     if (Convert.ToString(current["FDayPlanID"]) != "0")
                     {
+                        sql = $"select max(FHMASTERDATE)FHMASTERDATE from SC_WORKBILLSORTBILLSub where FID={Convert.ToString(current["FDayPlanID"])} ";
+                        DateTime EndDate = DBServiceHelper.ExecuteScalar<DateTime>(Context, sql, DateTime.Now);
+                        for (int i = 0; i <= 60; i++)
+                        {
+                            if (EndDate >= date.AddDays(i))
+                                continue;
+                            JObject jsonFPOOrderEntry = new JObject();
+                            jsonFPOOrderEntry.Add("FHMasterDate", date.AddDays(i).ToShortDateString()); ;//涓绘棩鏈�
+                            jsonFPOOrderEntry.Add("FHQty ", Convert.ToString(current["FT" + "" + i + ""])); ;//鏃ヨ鍒掓暟閲�
+                            jsonFPOOrderEntry.Add("FColumn", "FT" + "" + i + ""); ;//瀵瑰簲鐨勫垪澶�
+                            Entry.Add(jsonFPOOrderEntry);
+                        }
+                        jsonModel.Add("FEntity", Entry);
                         jsonModel.Add("FID", Convert.ToString(current["FDayPlanID"])); ;//婧愬崟缂栧彿
                         jsonRoot.Add("Model", jsonModel);
-                        CloudClient cloudClient = new CloudClient("http://erp-windows002/K3Cloud/");
                         var result = cloudClient.Save("Paez_Sc_WorkBillAutoSortBill", jsonRoot.ToString());
                         JObject saveObj = JObject.Parse(result);
                         string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
@@ -355,29 +396,27 @@
                         {
                             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("瀵煎叆鎴愬姛");
-
-
                         }
                         else
                         {
-                            //LogService.WriteAsync(saveIsSuc);
                             LogService.WriteAsync(jsonRoot);
                             LogHelper.Error(jsonRoot.ToString());
-
                             this.View.ShowErrMessage(jsonRoot.ToString());
-
-
                         }
                     }
                     else
                     {
+                        for (int i = 0; i <= 60; i++)
+                        {
+                            JObject jsonFPOOrderEntry = new JObject();
+                            jsonFPOOrderEntry.Add("FHMasterDate", date.AddDays(i).ToShortDateString()); ;//涓绘棩鏈�
+                            jsonFPOOrderEntry.Add("FHQty ", Convert.ToString(current["FT" + "" + i + ""])); ;//鏃ヨ鍒掓暟閲�
+                            jsonFPOOrderEntry.Add("FColumn", "FT" + "" + i + ""); ;//瀵瑰簲鐨勫垪澶�
+                            Entry.Add(jsonFPOOrderEntry);
+                        }
+                        jsonModel.Add("FEntity", Entry);
                         jsonRoot.Add("Model", jsonModel);
-                        CloudClient cloudClient = new CloudClient("http://erp-windows002/K3Cloud/");
                         var result = cloudClient.Save("Paez_Sc_WorkBillAutoSortBill", jsonRoot.ToString());
                         JObject saveObj = JObject.Parse(result);
                         string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
@@ -386,41 +425,26 @@
                         {
                             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("瀵煎叆鎴愬姛");
-
                         }
                         else
                         {
-                            // LogService.WriteAsync(saveIsSuc);
                             LogService.WriteAsync(jsonRoot);
                             LogHelper.Error(jsonRoot.ToString());
-
                             this.View.ShowErrMessage(jsonRoot.ToString());
-
-
                         }
                     }
-
                     this.View.UpdateView();
-
-
                 }
             }
             catch (Exception ex)
             {
-
                 this.View.ShowErrMessage(ex.ToString());
             }
 
         }
-
-
-
         /// <summary>
         /// 鏁板瓧杞崲鏃堕棿鏍煎紡
         /// </summary>
@@ -468,7 +492,6 @@
             }
             return string.Empty;
         }
-
     }
 
 }

--
Gitblit v1.9.1