From 527469d17b75d42349bf17234ef3e34cc36e8920 Mon Sep 17 00:00:00 2001 From: 王 垚 <1402714037@qq.com> Date: 星期一, 13 九月 2021 17:30:55 +0800 Subject: [PATCH] nothing --- src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs | 326 ++++++++++++++++++++++++++++++++++++++++++------------ 1 files changed, 252 insertions(+), 74 deletions(-) diff --git a/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs b/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs index e234176..b0dd09c 100644 --- a/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs +++ b/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs @@ -5,72 +5,47 @@ using Kingdee.BOS.Orm.DataEntity; using Kingdee.BOS.ServiceHelper.Excel; using Kingdee.BOS.Util; +using Kingdee.BOS.ServiceHelper; + using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using Newtonsoft.Json.Linq; -using Kingdee.BOS.WebApi.Client; -using ZD.Cloud.WebApi; -using Kingdee.BOS.Core; -using Kingdee.BOS.Core.DynamicForm; -using Kingdee.BOS.KDThread; -using Kingdee.BOS.ServiceHelper; -using Demo.TimedTaskPlugIn.PRD; using ZD.Cloud.Logger; using Demo.Model.Model; -using ZD.Share.Common; using System.Linq; +using ZD.Share.Common; +using ZD.Cloud.WebApi; +using Demo.Utility; namespace Demo.BillView.PRD { - [Description("鐢熶骇鏃ヨ鍒掑鍏�")] [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) + + //public override void OnLoad(EventArgs e) //{ - // base.BarItemClick(e); - // if (e.BarItemKey.ToUpper().Equals("TBIMPORT")) - // { - // } - - // if (e.BarItemKey.ToUpper().Equals("TBWJSC")) - // { - // //Control updateControl = this.View.GetControl("fileFullPath"); - // //// 涓婁紶鍦板潃 - // //string uploadUrl = "FileUpLoadServices/FileService.svc/upload2attachment/"; - // //updateControl.SetCustomPropertyValue("ExtandUrl", uploadUrl); - // //// 涓嬭浇鍦板潃 - // //string downloadUrl = "FileUpLoadServices/download.aspx"; - // //updateControl.SetCustomPropertyValue("ExDownLoadUrl", downloadUrl); - - // ImportData(fileFullPath); - // } - + // base.OnLoad(e); + // throw new Exception("1"); //} - public override void AfterBarItemClick(AfterBarItemClickEventArgs e) + public override void BarItemClick(BarItemClickEventArgs e) { - base.AfterBarItemClick(e); + LogHelper.Info("瀵煎叆鍔熻兘鐐瑰嚮鎸夐挳锛�"); if (e.BarItemKey.ToUpper().Equals("TBIMPORT")) { - LogService.WriteAsync("瀵煎叆鍔熻兘锛�"); + LogHelper.Info("瀵煎叆鍔熻兘鐐瑰嚮鎸夐挳锛�"); ImportData(); + //WriteImportLog(); + //this.View.ShowErrMessage("娴嬭瘯瀵煎叆鍔熻兘鐐瑰嚮鎸夐挳"); } if (e.BarItemKey.ToUpper().Equals("TBWJSC")) { - //Control updateControl = this.View.GetControl("fileFullPath"); - //// 涓婁紶鍦板潃 - //string uploadUrl = "FileUpLoadServices/FileService.svc/upload2attachment/"; - //updateControl.SetCustomPropertyValue("ExtandUrl", uploadUrl); - //// 涓嬭浇鍦板潃 - //string downloadUrl = "FileUpLoadServices/download.aspx"; - //updateControl.SetCustomPropertyValue("ExDownLoadUrl", downloadUrl); - LogService.WriteAsync("涓婁紶鍔熻兘锛�"); + LogHelper.Info("鏂囦欢涓婁紶鍔熻兘鐐瑰嚮鎸夐挳锛�"); ImportDataSC(fileFullPath); } } @@ -106,9 +81,14 @@ { if (!string.IsNullOrEmpty(fileFullPath)) { - DataSet ds = helper.ReadFromFile(fileFullPath, 1); + NpoiHelper np = new NpoiHelper(); + DataSet ds = np.ReadExcel(fileFullPath, 1); DataTable dt = ds.Tables[0]; - LogService.WriteAsync("瀵煎叆鍔熻兘锛歞t琛屾暟锛�" + dt.Rows.Count); + RemoveEmpty(dt);//鍘婚櫎绌鸿 + dt.Rows.RemoveAt(0);//鍘婚櫎鏍囬琛� + //DataSet ds = helper.ReadFromFile(fileFullPath, 1); + //DataTable dt = ds.Tables[0]; + LogHelper.Info("瀵煎叆鍔熻兘锛歞t琛屾暟锛�" + dt.Rows.Count); DateTime date = Convert.ToDateTime(this.Model.GetValue("F_Paez_Date")); if (dt.Rows.Count > 0) { @@ -143,36 +123,52 @@ for (int i = 0; i < dt.Rows.Count; i++) { //鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鏄庣粏(2.28+鐢熶骇璁㈠崟鏄庣粏琛屽彿楠岃瘉) - string sql = string.Format(@"/*dialect*/ SELECT T1.FBILLNO,T2.* FROM T_PRD_MO T1 + string sql = string.Format(@"/*dialect*/ +SELECT t4.FNAME as FMoFBillType,T1.FBILLNO,T2.* FROM T_PRD_MO T1 LEFT JOIN T_PRD_MOENTRY T2 ON T1.FID = T2.FID JOIN T_BD_MATERIAL T3 ON T2.FMATERIALID = T3.FMATERIALID +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 T3.FNUMBER = '{1}' and FSEQ='{2}' ", dt.Rows[i][1].ToString(), dt.Rows[i][5].ToString(), dt.Rows[i][2].ToString()); DataTable _dt = new DataTable(); _dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0]; string FLOT = "";//FLOT 鎵规 string FQTY = "";//FQTY 鐢熶骇璁㈠崟鏁伴噺 string FBILLNO = "";//FBILLNO 鍘熷崟鍙� + string FMoFBillType = ""; if (_dt.Rows.Count > 0) { FLOT = _dt.Rows[0]["FLOT"].ToString(); FQTY = _dt.Rows[0]["FQTY"].ToString(); FBILLNO = _dt.Rows[0]["FBILLNO"].ToString(); + FMoFBillType = _dt.Rows[0]["FMoFBillType"].ToString(); } - //鐗╂枡缂栫爜 + 鐢熶骇璁㈠崟鍙� + 鐢熶骇璧勬簮 + 鐢熶骇璁㈠崟琛屽彿 鍘诲垽鏂槸鍚﹀鍏ヨ繃 甯﹀嚭鏃ヨ鍒掑伐鍗旾D鍙婄紪鍙� + //鐗╂枡缂栫爜 + 鐢熶骇璁㈠崟鍙� + 鐢熶骇璧勬簮 + 鐢熶骇璁㈠崟琛屽彿 鍘诲垽鏂槸鍚﹀鍏ヨ繃 甯﹀嚭鏃ヨ鍒掑伐鍗旾D鍙婄紪鍙� 鍜� 鍏抽棴鏁伴噺锛�6.18鏇达級 + //9.2 鍏抽棴鐨勬棩璁″垝闇�瑕佹帓闄� 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 a.FSRCBILLENTRYSEQ ='{3}' 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(), dt.Rows[i][2].ToString()); + string fCloseCount = ""; + string fQtyLS = ""; + sql = string.Format(@"/*dialect*/ +SELECT A.FID,FBILLNO,FSCORDERNO,FHMATERID,FHSOURCEID,A.FCLOSECOUNT,ISNULL((SELECT SUM(ISNULL(FHQTY,0)) FROM SC_WORKBILLSORTBILLSUB T2 WHERE T2.FID = A.FID AND DATEDIFF(D,FHMASTERDATE,GETDATE())>0),0)FQTYLS +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 A.FDOCUMENTSTATUS NOT IN ('E') AND +FSCORDERNO ='{0}' AND B.FNUMBER ='{1}' AND A.FSRCBILLENTRYSEQ ='{3}' 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(), dt.Rows[i][2].ToString()); + //LogHelper.Error(sql); 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(); + fCloseCount = dayPlanDt.Rows[0]["FCloseCount"].ToString(); + fQtyLS = dayPlanDt.Rows[0]["FQTYLS"].ToString(); } - //DynamicObject row = new DynamicObject(entity.DynamicObjectType); this.Model.CreateNewEntryRow("FEntity"); this.Model.SetValue("FSEQ", i + 1, i); + this.Model.SetValue("FMoFBillType", FMoFBillType, i); this.Model.SetValue("FSalOrderNo", dt.Rows[i][0].ToString(), i); this.Model.SetValue("FSCOrderNo", dt.Rows[i][1].ToString(), i); this.Model.SetItemValueByNumber("FORGID", "100", i); @@ -183,12 +179,15 @@ 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("FDeliveryDate", dt.Rows[i][13].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);//鏃ュ伐鍗曠紪鍙� this.Model.SetValue("FSRCBILLENTRYSEQ", dt.Rows[i][2].ToString(), i);//鐢熶骇璁㈠崟鏄庣粏琛屽彿 + this.Model.SetValue("FCloseCount", fCloseCount, i);//鍏抽棴鏁伴噺 + this.Model.SetValue("FQTYLS", fQtyLS, i);//鍘嗗彶閬楃暀 + for (int j = 0; j <= 60; j++) { this.Model.SetValue("FT" + "" + j + "", dt.Rows[i][15 + j].ToString(), i); @@ -251,13 +250,14 @@ { try { - LogService.WriteAsync("娴嬭瘯"); + CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/"); 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); + LogHelper.Info("瀵煎叆鍔熻兘鍒楄〃琛屾暟锛�" + entityDataObjoct.Count); List<string> sqlList = new List<string>(); foreach (DynamicObject current in entityDataObjoct) { @@ -273,9 +273,10 @@ } int res = DBServiceHelper.ExecuteBatch(Context, sqlList); string _result = ""; + //楠岃瘉鏄惁鏈夌敓浜ц鍗曟槑缁嗚 foreach (DynamicObject current in entityDataObjoct) { - //鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鏄庣粏 +鐢熶骇璁㈠崟鏄庣粏琛屽彿 + //鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鐢熶骇璁㈠崟鏄庣粏鏄庣粏 +鐢熶骇璁㈠崟鏄庣粏琛屽彿 sql = string.Format(@"/*dialect*/SELECT T1.FBILLNO,T2.* FROM T_PRD_MO T1 LEFT JOIN T_PRD_MOENTRY T2 ON T1.FID = T2.FID 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"])); @@ -289,9 +290,27 @@ this.View.ShowErrMessage(_result); return; } + //鏍¢獙鐢熶骇鐢ㄦ枡娓呭崟鏄惁瀹℃牳 foreach (DynamicObject current in entityDataObjoct) { - if (Convert.ToInt32(current["FNoScheduled"]) < 0) + //鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鏄庣粏 +鐢熶骇璁㈠崟鏄庣粏琛屽彿 + sql = string.Format(@"/*dialect*/SELECT FBILLNO FROM T_PRD_PPBOM T1 +WHERE T1.FMOBILLNO = '{0}' AND T1.FMATERIALID = '{1}' AND T1.FMOENTRYSEQ = '{2}' and FDOCUMENTSTATUS <>'C' +", 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) + _result += "搴忓彿锛�" + Convert.ToString(current["SEQ"]) + ",鐢熶骇璁㈠崟鍙凤細" + Convert.ToString(current["FSCOrderNo"]) + ",鐢熶骇璁㈠崟鏄庣粏琛屽彿锛�" + Convert.ToString(current["FSRCBILLENTRYSEQ"]) + "鐗╂枡" + (current["FMatrailId"] as DynamicObject)["Number"] + "瀵瑰簲鐨勭敓浜х敤鏂欐竻鍗曪細" + dt.Rows[0][0] + "鏈鏍�"; + } + if (_result != "") + { + this.View.ShowErrMessage(_result); + return; + } + foreach (DynamicObject current in entityDataObjoct) + { + //鏈帓鏁伴噺= 鎬绘暟 - 鏃ヨ鍒� 瓒呭嚭鏃ヨ鍒掍负璐� - 鍘嗗彶鏁伴噺 + 鍏抽棴鏁伴噺 < 0 琛ㄧず瓒呭嚭浜嗘�昏鍒掓暟閲� + if (Convert.ToInt32(current["FNoScheduled"]) - Convert.ToInt32(current["FQTYLS"]) + Convert.ToInt32(current["FCloseCount"]) < 0) _result += "搴忓彿锛�" + Convert.ToString(current["SEQ"]) + ",鏃ヨ鍒掓�绘暟閲忚秴鍑虹敓浜ц鍗曟暟閲�"; } if (_result != "") @@ -303,12 +322,16 @@ { if (string.IsNullOrEmpty(Convert.ToString(current["FSCOrderNo"]))) continue; - //鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鏄庣粏 +鐢熶骇璁㈠崟鏄庣粏琛屽彿 + //鏌ヨ鐢熶骇璁㈠崟鏁版嵁 sql = string.Format(@" /*dialect*/ -SELECT T1.FBILLNO,T2.*,t3.FNUMBER as FUnitNumber FROM T_PRD_MO T1 +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]; @@ -320,6 +343,10 @@ 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(); @@ -328,6 +355,10 @@ 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", ""); @@ -337,7 +368,8 @@ jsonRoot.Add("SubSystemId", ""); jsonRoot.Add("IsVerifyBaseDataField", ""); JObject jsonModel = new JObject(); - jsonModel.Add("FPreparatDate", date.ToString());//缂栧埗鏃ユ湡 + jsonModel.Add("FPreparatDate", FPlanBeginDate);//缂栧埗鏃ユ湡(鏀逛负璁″垝寮�濮嬫棩鏈�) + 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"]));//閿�鍞鍗曞彿 @@ -345,13 +377,17 @@ 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"])); ;//鏈帓鏁伴噺 @@ -380,36 +416,30 @@ JArray Entry = new JArray(); if (Convert.ToString(current["FDayPlanID"]) != "0") { - sql = $" /*dialect*/ select FEntryID,FHMASTERDATE from SC_WORKBILLSORTBILLSub where FID={Convert.ToString(current["FDayPlanID"])} "; + sql = $" /*dialect*/ select FEntryID, FHMASTERDATE from SC_WORKBILLSORTBILLSub where FID={Convert.ToString(current["FDayPlanID"])} "; List<DayPlanModel> dayPlanModel = new List<DayPlanModel>(); dayPlanModel = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList<DayPlanModel>(); - int fseq = 1; 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 + ""])); ;//鏃ヨ鍒掓暟閲� jsonFPOOrderEntry.Add("FColumn", "FT" + "" + i + ""); ;//瀵瑰簲鐨勫垪澶� - //jsonFPOOrderEntry.Add("FSEQ", fseq); ;//搴忓彿 - List<DayPlanModel> _dayPlanModel = dayPlanModel.Where(x => x.FHMASTERDATE == date.AddDays(i).ToShortDateString()).ToList(); + 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); - fseq++; } jsonModel.Add("FEntity", Entry); - jsonModel.Add("FID", Convert.ToString(current["FDayPlanID"])); ;//婧愬崟缂栧彿 + jsonModel.Add("FID", Convert.ToString(current["FDayPlanID"])); jsonRoot.Add("Model", jsonModel); var result = cloudClient.Save("Paez_Sc_WorkBillAutoSortBill", jsonRoot.ToString()); JObject saveObj = JObject.Parse(result); string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper(); - LogHelper.Info(jsonRoot.ToString()); if (saveIsSuc == "TRUE") { string FDayPlanBillNo = saveObj["Result"]["Number"].ToString(); @@ -418,13 +448,12 @@ } else { - LogHelper.Error(jsonRoot.ToString()); - this.View.ShowErrMessage(jsonRoot.ToString()); + LogHelper.Error("鐢熶骇鏃ヨ鍒掑鍏� 鏂板寮傚父锛�" + saveObj.ToString()); + this.View.ShowMessage(saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString()); } } else { - int fseq = 1; for (int i = 0; i <= 60; i++) { if (Convert.ToString(current["FT" + "" + i + ""]) == "" || Convert.ToString(current["FT" + "" + i + ""]) == "0") @@ -433,16 +462,13 @@ jsonFPOOrderEntry.Add("FHMasterDate", date.AddDays(i).ToShortDateString()); ;//涓绘棩鏈� jsonFPOOrderEntry.Add("FHQty ", Convert.ToString(current["FT" + "" + i + ""])); ;//鏃ヨ鍒掓暟閲� jsonFPOOrderEntry.Add("FColumn", "FT" + "" + i + ""); ;//瀵瑰簲鐨勫垪澶� - //jsonFPOOrderEntry.Add("FSEQ", fseq); ;//搴忓彿 Entry.Add(jsonFPOOrderEntry); - fseq++; } jsonModel.Add("FEntity", Entry); jsonRoot.Add("Model", jsonModel); var result = cloudClient.Save("Paez_Sc_WorkBillAutoSortBill", jsonRoot.ToString()); JObject saveObj = JObject.Parse(result); string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper(); - LogService.WriteAsync(jsonRoot); if (saveIsSuc == "TRUE") { string FDayPlanBillNo = saveObj["Result"]["Number"].ToString(); @@ -453,8 +479,8 @@ } else { - LogHelper.Error(jsonRoot.ToString()); - this.View.ShowErrMessage(jsonRoot.ToString()); + LogHelper.Error("鐢熶骇鏃ヨ鍒掑鍏� 鏂板寮傚父锛�" + saveObj.ToString()); + this.View.ShowMessage(saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString()); } } this.View.UpdateView(); @@ -514,6 +540,158 @@ } return string.Empty; } - } + public void WriteImportLog() + { + try + { + CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/"); + 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); + foreach (DynamicObject current in entityDataObjoct) + { + if (string.IsNullOrEmpty(Convert.ToString(current["FSCOrderNo"]))) + continue; + //鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鏄庣粏 +鐢熶骇璁㈠崟鏄庣粏琛屽彿 + sql = string.Format(@" +/*dialect*/ +SELECT T1.FBILLNO,T2.*,t3.FNUMBER as FUnitNumber FROM T_PRD_MO T1 + LEFT JOIN T_PRD_MOENTRY T2 ON T1.FID = T2.FID + join T_BD_UNIT t3 on t2.FUNITID=t3.FUNITID + 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 = "";//缁撴潫鏃ユ湡 + 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(); + } + 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("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("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 + ""])); ;//鏃ヨ鍒掓暟閲� + jsonFPOOrderEntry.Add("FColumn", "FT" + "" + i + ""); ;//瀵瑰簲鐨勫垪澶� + Entry.Add(jsonFPOOrderEntry); + } + jsonModel.Add("FEntity", Entry); + jsonRoot.Add("Model", jsonModel); + var result = cloudClient.Save("paez_Sc_WorkBillAutoSortBill_Log", jsonRoot.ToString()); + JObject saveObj = JObject.Parse(result); + string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper(); + if (saveIsSuc != "TRUE") + { + LogHelper.Error("鐢熶骇鏃ヨ鍒掑鍏ヨ褰曟棩蹇楋紝鏂板寮傚父json锛�" + jsonRoot.ToString()); + } + + } + } + catch (Exception ex) + { + LogHelper.Error("鐢熶骇鏃ヨ鍒掑鍏ヨ褰曟棩蹇楄烦鍑�:" + ex.Message.ToString()); + } + } + + /// <summary> + /// dt鍘荤┖琛� + /// </summary> + /// <param name="dt"></param> + public void RemoveEmpty(DataTable dt) + { + List<DataRow> removelist = new List<DataRow>(); + for (int i = 0; i < dt.Rows.Count; i++) + { + bool IsNull = true; + for (int j = 0; j < dt.Columns.Count; j++) + { + if (!string.IsNullOrEmpty(dt.Rows[i][j].ToString().Trim())) + { + IsNull = false; + } + } + if (IsNull) + { + removelist.Add(dt.Rows[i]); + } + } + for (int i = 0; i < removelist.Count; i++) + { + dt.Rows.Remove(removelist[i]); + } + } + } } -- Gitblit v1.9.1