using Kingdee.BOS.Core.DynamicForm.PlugIn; using Kingdee.BOS.Core.DynamicForm.PlugIn.Args; using Kingdee.BOS.Core.Metadata.EntityElement; using Kingdee.BOS.JSON; 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 ZD.Cloud.Logger; using Demo.Model.Model; 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 { private string fileFullPath = string.Empty; //public override void OnLoad(EventArgs e) //{ // base.OnLoad(e); // throw new Exception("1"); //} public override void BarItemClick(BarItemClickEventArgs e) { LogHelper.Info("导入功能点击按钮:"); if (e.BarItemKey.ToUpper().Equals("TBIMPORT")) { LogHelper.Info("导入功能点击按钮:"); ImportData(); WriteImportLog(); //this.View.ShowErrMessage("测试导入功能点击按钮"); } if (e.BarItemKey.ToUpper().Equals("TBWJSC")) { LogHelper.Info("文件上传功能点击按钮:"); ImportDataSC(fileFullPath); } } public override void CustomEvents(CustomEventsArgs e) { //触发事件是上传文件有变化 if (e.EventName.ToUpper() == "FILECHANGED") { JSONObject jSONObject = KDObjectConverter.DeserializeObject(e.EventArgs); if (jSONObject != null) { JSONArray jSONArray = new JSONArray(jSONObject["NewValue"].ToString()); if (jSONArray.Count > 0) { //获取上传的文件名 string text = (jSONArray[0] as Dictionary)["ServerFileName"].ToString(); //文件上传到服务端的临时目录 string directory = "FileUpLoadServices\\UploadFiles"; //文件的完整路径 fileFullPath = PathUtils.GetPhysicalPath(directory, text); } } } base.CustomEvents(e); } /// /// 文件上传界面数据显示 /// /// private void ImportDataSC(string fileFullPath) { using (ExcelOperation helper = new ExcelOperation(this.View)) { if (!string.IsNullOrEmpty(fileFullPath)) { NpoiHelper np = new NpoiHelper(); DataSet ds = np.ReadExcel(fileFullPath, 1); DataTable dt = ds.Tables[0]; RemoveEmpty(dt);//去除空行 dt.Rows.RemoveAt(0);//去除标题行 //DataSet ds = helper.ReadFromFile(fileFullPath, 1); //DataTable dt = ds.Tables[0]; LogHelper.Info("导入功能:dt行数:" + dt.Rows.Count); DateTime date = Convert.ToDateTime(this.Model.GetValue("F_Paez_Date")); if (dt.Rows.Count > 0) { //验证导入模板 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 += "产品代码不能为空;"; 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++) { //根据生产订单号和物料查询是否存在明细(2.28+生产订单明细行号验证) 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(); } //物料编码 + 生产订单号 + 生产资源 + 生产订单行号 去判断是否导入过 带出日计划工单ID及编号 和 关闭数量(6.18更) string fDayPlanID = ""; string fDayPlanBillNo = ""; string fCloseCount = ""; string fQtyLS = ""; sql = string.Format(@"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 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(); } 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); this.Model.SetItemValueByNumber("FProductWorkShopId", dt.Rows[i][3].ToString(), i); 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("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", 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);//日计划工单ID 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); } //调用数量值更新 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(); } } } } /// /// 订单状态等级 /// /// /// public string OrderType(string Type) { switch (Type) { case "特急": return "1"; break; case "紧急": return "2"; break; case "普通": return "3"; break; default: return " "; break; } } /// /// 时间戳Timestamp转换成日期 /// /// /// private DateTime GetDateTime(int timeStamp) { DateTime dtStart = TimeZone.CurrentTimeZone.ToLocalTime(new DateTime(1970, 1, 1)); long lTime = ((long)timeStamp * 10000000); TimeSpan toNow = new TimeSpan(lTime); DateTime targetDt = dtStart.Add(toNow); return targetDt; } /// /// 导入功能 /// private void ImportData() { 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); LogHelper.Info("导入功能列表行数:" + entityDataObjoct.Count); List sqlList = new List(); 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) { //根据生产订单号和物料查询是否存在明细 +生产订单明细行号 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"])); 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"] + "不存在"; } if (_result != "") { this.View.ShowErrMessage(_result); return; } //校验生产用料清单是否审核 foreach (DynamicObject current in entityDataObjoct) { //根据生产订单号和物料查询是否存在明细 +生产订单明细行号 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 != "") { this.View.ShowErrMessage(_result); return; } foreach (DynamicObject current in entityDataObjoct) { if (string.IsNullOrEmpty(Convert.ToString(current["FSCOrderNo"]))) continue; //根据生产订单号和物料查询是否存在明细 +生产订单明细行号 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"])); //生产订单号FSCOrderNo 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"]));//交货期HOrderCommitDate 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(); if (Convert.ToString(current["FDayPlanID"]) != "0") { sql = $" /*dialect*/ select FEntryID, FHMASTERDATE from SC_WORKBILLSORTBILLSub where FID={Convert.ToString(current["FDayPlanID"])} "; List dayPlanModel = new List(); dayPlanModel = DBServiceHelper.ExecuteDataSet(Context, sql).ToModelList(); 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 + ""); ;//对应的列头 List _dayPlanModel = dayPlanModel.Where(x => x.FHMASTERDATE == date.AddDays(i)).ToList(); if (_dayPlanModel.Count > 0) { jsonFPOOrderEntry.Add("FEntryID", _dayPlanModel.FirstOrDefault().FEntryID); ;//序号 } Entry.Add(jsonFPOOrderEntry); } jsonModel.Add("FEntity", Entry); 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(); if (saveIsSuc == "TRUE") { string FDayPlanBillNo = saveObj["Result"]["Number"].ToString(); string FDayPlanID = saveObj["Result"]["Id"].ToString(); this.View.ShowMessage("导入成功"); } else { LogHelper.Error(jsonRoot.ToString()); this.View.ShowErrMessage(jsonRoot.ToString()); } } else { 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", jsonRoot.ToString()); JObject saveObj = JObject.Parse(result); string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper(); 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("导入成功"); } else { this.View.ShowMessage(saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString()); this.View.ShowErrMessage(jsonRoot.ToString()); } } this.View.UpdateView(); } } catch (Exception ex) { LogHelper.Error(ex.ToString()); this.View.ShowErrMessage(ex.ToString()); } } /// /// 数字转换时间格式 /// /// 数字,如:42095.7069444444/0.650694444444444 /// 日期/时间格式 private string ToDateTimeValue(string strNumber) { if (!string.IsNullOrWhiteSpace(strNumber)) { Decimal tempValue; //先检查 是不是数字; if (Decimal.TryParse(strNumber, out tempValue)) { //天数,取整 int day = Convert.ToInt32(Math.Truncate(tempValue)); //这里也不知道为什么. 如果是小于32,则减1,否则减2 //日期从1900-01-01开始累加 // day = day < 32 ? day - 1 : day - 2; DateTime dt = new DateTime(1900, 1, 1).AddDays(day < 32 ? (day - 1) : (day - 2)); //小时:减掉天数,这个数字转换小时:(* 24) Decimal hourTemp = (tempValue - day) * 24;//获取小时数 //取整.小时数 int hour = Convert.ToInt32(Math.Truncate(hourTemp)); //分钟:减掉小时,( * 60) //这里舍入,否则取值会有1分钟误差. Decimal minuteTemp = Math.Round((hourTemp - hour) * 60, 2);//获取分钟数 int minute = Convert.ToInt32(Math.Truncate(minuteTemp)); //秒:减掉分钟,( * 60) //这里舍入,否则取值会有1秒误差. Decimal secondTemp = Math.Round((minuteTemp - minute) * 60, 2);//获取秒数 int second = Convert.ToInt32(Math.Truncate(secondTemp)); //时间格式:00:00:00 string resultTimes = string.Format("{0}:{1}:{2}", (hour < 10 ? ("0" + hour) : hour.ToString()), (minute < 10 ? ("0" + minute) : minute.ToString()), (second < 10 ? ("0" + second) : second.ToString())); if (day > 0) return string.Format("{0} {1}", dt.ToString("yyyy-MM-dd"), resultTimes); else return resultTimes; } } 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"])); //生产订单号FSCOrderNo 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"]));//交货期HOrderCommitDate 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()); } } /// /// dt去空行 /// /// public void RemoveEmpty(DataTable dt) { List removelist = new List(); 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]); } } } }