From c2f02a271b5cdc46aa338407b8efb16ccd6305c1 Mon Sep 17 00:00:00 2001 From: wyf Date: Wed, 28 May 2025 10:02:20 +0000 Subject: [PATCH] SVN r643 SVN-Revision: r643 --- 插件库/Lskj.PubBomImport/FrmMain.cs | 83 ++-- 插件库/Lskj.PubBomImport/FrmProgress.cs | 582 ++++++++++++++++++++++-- 2 files changed, 609 insertions(+), 56 deletions(-) diff --git a/插件库/Lskj.PubBomImport/FrmMain.cs b/插件库/Lskj.PubBomImport/FrmMain.cs index c3e2a89..88ef028 100644 --- a/插件库/Lskj.PubBomImport/FrmMain.cs +++ b/插件库/Lskj.PubBomImport/FrmMain.cs @@ -80,7 +80,7 @@ namespace Lskj.PubBomImport InitGridColumns(); InitMulitControl(); InitDataSource(); - if (showTypeValue == 0 || showTypeValue == 3 || showTypeValue == 33 || showTypeValue == 4 || showTypeValue == 44 || showTypeValue == 5 || showTypeValue == 55 || (showTypeValue > 0 && showType)) + if (showTypeValue == 0 || showTypeValue == 2 || showTypeValue == 3 || showTypeValue == 33 || showTypeValue == 4 || showTypeValue == 44 || showTypeValue == 5 || showTypeValue == 55 || (showTypeValue > 0 && showType)) { OnBtnImportClick(null, null); } @@ -286,33 +286,60 @@ namespace Lskj.PubBomImport // this.Close(); // } //} - //else if (Model.ShowType.Equals("2")) - //{ - // OpenFileDialog dialog = new OpenFileDialog(); - // dialog.InitialDirectory = Properties.Settings.Default.LastSelectFolder; - // dialog.Title = "选择导入文件"; - // dialog.Filter = "Excel文件(*.xlsx)|*.xlsx|Excel文件(*.xls)|*.xls"; - // DialogResult dialogResult = dialog.ShowDialog(); - // if (dialogResult == DialogResult.OK) - // { - // Properties.Settings.Default.LastSelectFolder = Path.GetDirectoryName(dialog.FileName); - // string dirPath = dialog.FileName; - // FrmProgress frmProgress = new FrmProgress(); - // frmProgress.frmMain = this; - // frmProgress.ImportTimer.Tick += (ts, te) => - // { - // frmProgress.ImportTimer.Enabled = false; - // frmProgress.StartImportInMxFile(dirPath); - // }; - // frmProgress.ImportTimer.Enabled = true; - // frmProgress.ShowDialog(); - // frmProgress.Dispose(); - // } - // else - // { - // this.Close(); - // } - //} + else if (Model.ShowType.Equals("2"))//一级BOM上传 + { + BomImpRtnModel bomImpRtnModel = new BomImpRtnModel() + { + ShowType = Model.ShowType, + AfterBomFieldName = Model.AfterBomFieldName, + CanSave = true + }; + FormDialogModel dialogModel = new FormDialogModel() + { + DialogDllName = "Lskj.PubBomImport.dll", + PubDialogType = DialogType.PubAddRecord, + ReturnTag = bomImpRtnModel + }; + this.Tag = dialogModel; + DataTable sourceTable = StaticControl.RightMenuGridView.GridControl.DataSourceTable(); + if (sourceTable.Columns.Contains("BomFieldNameDir")) + { + List selectRows = new List(); + foreach (DataRow sourceRow in sourceTable.Rows) + { + if (sourceRow.RowState == DataRowState.Deleted) + { + continue; + } + string fileName = sourceRow[Model.AfterBomFieldName] + ""; + string dirPath = sourceRow["BomFieldNameDir"] + ""; + selectRows.Add(sourceRow); + } + if (selectRows.Count > 0) + { + FrmProgress frmProgress = new FrmProgress(); + frmProgress.frmMain = this; + frmProgress.Model = Model; + frmProgress.ImportTimer.Tick += (ts, te) => + { + frmProgress.ImportTimer.Enabled = false; + frmProgress.StartImportInFirstFiles(selectRows); + }; + frmProgress.ImportTimer.Enabled = true; + DialogResult dialogResult = frmProgress.ShowDialog(); + bomImpRtnModel.CanSave = dialogResult == DialogResult.OK; + frmProgress.Dispose(); + } + else + { + this.Close(); + } + } + else + { + this.Close(); + } + } else if (Model.ShowType.Equals("3"))//新增多个QD文件或图纸文件 { BomImpRtnModel bomImpRtnModel = new BomImpRtnModel() diff --git a/插件库/Lskj.PubBomImport/FrmProgress.cs b/插件库/Lskj.PubBomImport/FrmProgress.cs index a1eea76..6fc9dd4 100644 --- a/插件库/Lskj.PubBomImport/FrmProgress.cs +++ b/插件库/Lskj.PubBomImport/FrmProgress.cs @@ -55,7 +55,6 @@ namespace Lskj.PubBomImport { int execOrder = 1; FrmBillInfo frmBillInfo = new FrmBillInfo(); - StringBuilder stringBuilder = new StringBuilder(); foreach (DataRow selectRow in selectRows) { string fileName = selectRow[Model.AfterBomFieldName] + ""; @@ -84,8 +83,11 @@ namespace Lskj.PubBomImport } if (sourceCode.StartsWith("QD")) { - stringBuilder.AppendLine($"if not exists (select productid from p_ProductTab where productid = '{sourceCode}')"); - stringBuilder.AppendLine($"begin insert into p_ProductTab (productid,appellation,spec,model,bak,SpeciesNo) values ('{sourceCode.Replace("'", "''")}','{sourceName.Replace("'", "''")}','{sourceCode.Replace("'", "''")}','{sourceCode.Replace("QD-", "").Replace("'", "''")}','','0199') end;"); + int createCode = ProductSaveUnique(sourceCode.Replace("'", "''"), sourceName.Replace("'", "''"), "", "1000202_1", out string pid, out string msg); + if ((createCode + "").Equals("-1")) + { + throw new Exception($"虚拟物料创建失败\r\n{msg}"); + } } } else @@ -99,10 +101,6 @@ namespace Lskj.PubBomImport throw new Exception($"{fileName}的文件不存在"); } } - if (!string.IsNullOrEmpty(stringBuilder.ToString())) - { - SqlHelper.ExecuteNonQuery(stringBuilder.ToString()); - } frmBillInfo.OnControlSourceBind += (s, args) => { Task task = new Task(() => @@ -126,7 +124,7 @@ namespace Lskj.PubBomImport GetFileCodeInfo(fileNameWithoutExtension, out string sourceCode, out string sourceName, out string sourceBB, out int sourceBC); if (sourceCode.StartsWith("QD")) { - DataRow productRow = BaseImpl.GetDataRowResult($"select top 1 billdocument_id from bom_BillTab where productid='{sourceCode}'"); + DataRow productRow = BaseImpl.GetDataRowResult($"select top 1 billdocument_id from bom_BillTab where productid = (select top 1 productid from p_ProductTab where spec = '{sourceCode}')"); if (productRow == null)//如果不存在bom建立单 { string childGuid = Guid.NewGuid() + ""; @@ -150,7 +148,7 @@ namespace Lskj.PubBomImport throw new Exception($"{sourceCode}明细数据为空"); } SetProcessBar(40, allCount); - string childBillMasterSql = $"select (select top 1 billdocument_id from bom_BillTab where productid='{sourceCode}') as billdocument_id,'0' affirmer,'0' rtagid,'{sourceCode}' as productid,'{sourceCode}' as bak,'{sourceBB}' as bombb,'{sourceBC}' as bombc"; + string childBillMasterSql = $"select (select top 1 billdocument_id from bom_BillTab where productid = (select top 1 productid from p_ProductTab where spec = '{sourceCode}')) as billdocument_id,'0' affirmer,'0' rtagid,(select top 1 productid from p_ProductTab where spec = '{sourceCode}') as productid,'{sourceCode}' as bak,'{sourceBB}' as bombb,'{sourceBC}' as bombc"; // 处理单据表头数据 DataRow childMasterRow = BillImpl.GetDataRowResult(childBillMasterSql); SetProcessBar(60, allCount); @@ -351,15 +349,13 @@ namespace Lskj.PubBomImport { throw new Exception($"变更版本{sourceBB}已存在，请进行版次变更"); } - StringBuilder stringBuilder = new StringBuilder(); if (sourceCode.StartsWith("QD")) { - stringBuilder.AppendLine($"if not exists (select productid from p_ProductTab where productid = '{sourceCode}')"); - stringBuilder.AppendLine($"begin insert into p_ProductTab (productid,appellation,spec,model,bak,SpeciesNo) values ('{sourceCode.Replace("'", "''")}','{sourceName.Replace("'", "''")}','{sourceCode.Replace("'", "''")}','{sourceCode.Replace("QD-", "").Replace("'", "''")}','','0199') end;"); - } - if (!string.IsNullOrEmpty(stringBuilder.ToString())) - { - SqlHelper.ExecuteNonQuery(stringBuilder.ToString()); + int createCode = ProductSaveUnique(sourceCode.Replace("'", "''"), sourceName.Replace("'", "''"), "", "1000202_1", out string pid, out string msg); + if ((createCode + "").Equals("-1")) + { + throw new Exception($"虚拟物料创建失败\r\n{msg}"); + } } //StringBuilder insertbulider = new StringBuilder(); @@ -398,7 +394,7 @@ namespace Lskj.PubBomImport detailRow["bombc"] = sourceBC; } SetProcessBar(20, allCount); - string billMasterSql = $"select (select top 1 billdocument_id from bom_BillTab where productid='{sourceCode}') as billdocument_id,'0' affirmer,'0' rtagid,'{sourceCode}' as productid,'{sourceCode}' as bak,'{sourceBB}' as bombb,'{sourceBC}' as bombc"; + string billMasterSql = $"select (select top 1 billdocument_id from bom_BillTab where productid = (select top 1 productid from p_ProductTab where spec = '{sourceCode}')) as billdocument_id,'0' affirmer,'0' rtagid,(select top 1 productid from p_ProductTab where spec = '{sourceCode}') as productid,'{sourceCode}' as bak,'{sourceBB}' as bombb,'{sourceBC}' as bombc"; // 处理单据表头数据 DataRow masterRow = BillImpl.GetDataRowResult(billMasterSql); SetProcessBar(40, allCount); @@ -490,7 +486,7 @@ namespace Lskj.PubBomImport detailRow["bombc"] = sourceBC; } SetProcessBar(20, allCount); - string billMasterSql = $"select (select top 1 billdocument_id from bom_BillTab where productid='{productCode}') as billdocument_id,'0' affirmer,'0' rtagid,'{productCode}' as productid"; + string billMasterSql = $"select (select top 1 billdocument_id from bom_BillTab where productid = '{productCode}') as billdocument_id,'0' affirmer,'0' rtagid,'{productCode}' as productid"; // 处理单据表头数据 DataRow masterRow = BillImpl.GetDataRowResult(billMasterSql); if (masterRow == null) @@ -607,8 +603,11 @@ namespace Lskj.PubBomImport string childCode = (dataRow["图号"] + "").Trim(); if (childCode.StartsWith("QD")) { - stringBuilder.AppendLine($"if not exists (select productid from p_ProductTab where productid = '{childCode}')"); - stringBuilder.AppendLine($"begin insert into p_ProductTab (productid,appellation,spec,model,bak,SpeciesNo) values ('{childCode.Replace("'", "''")}','{(dataRow["名称"] + "").Replace("'", "''")}','{childCode.Replace("'", "''")}','{childCode.Replace("QD-", "").Replace("'", "''")}','{(dataRow["备注"] + "").Replace("'", "''")}','0199') end;"); + int createCode = ProductSaveUnique(childCode.Replace("'", "''"), (dataRow["名称"] + "").Replace("'", "''"), (dataRow["备注"] + "").Replace("'", "''"), "1000202_1", out string pid, out string msg); + if ((createCode + "").Equals("-1")) + { + throw new Exception($"虚拟物料创建失败\r\n{msg}"); + } } } if (!string.IsNullOrEmpty(stringBuilder.ToString())) @@ -642,7 +641,7 @@ namespace Lskj.PubBomImport if (childCode.StartsWith("QD")) { DataRow childRow = childTable.NewRow(); - childRow["ProductId"] = childCode; + childRow["ProductId"] = BaseImpl.GetResult($"(select top 1 productid from p_ProductTab where spec = '{childCode}')"); childRow["appellation"] = parentRow["名称"] + ""; childRow["bak"] = childCode; childRow["bombb"] = childsourceBB; @@ -651,6 +650,10 @@ namespace Lskj.PubBomImport childRow["amount"] = parentRow["套数"] + ""; childTable.Rows.Add(childRow); } + else if (childCode.StartsWith("ZZQD")) + { + throw new Exception($"MX{sourceCode}未获取到ZZQD附件"); + } } if (childInfo != null) { @@ -691,7 +694,7 @@ namespace Lskj.PubBomImport else if (childCode.StartsWith("QD")) { DataRow childRow = childTable.NewRow(); - childRow["ProductId"] = childCode; + childRow["ProductId"] = BaseImpl.GetResult($"(select top 1 productid from p_ProductTab where spec = '{childCode}')"); childRow["appellation"] = parentRow["名称"] + ""; childRow["bak"] = childsourceCode; childRow["bombb"] = childsourceBB; @@ -939,8 +942,11 @@ namespace Lskj.PubBomImport string code = (dataRow["图号"] + "").Trim(); if (code.StartsWith("QD")) { - stringBuilder.AppendLine($"if not exists (select productid from p_ProductTab where productid = '{code}')"); - stringBuilder.AppendLine($"begin insert into p_ProductTab (productid,appellation,spec,model,bak,SpeciesNo) values ('{code.Replace("'", "''")}','{(dataRow["名称"] + "").Replace("'", "''")}','{code.Replace("'", "''")}','{code.Replace("QD-", "").Replace("'", "''")}','{(dataRow["备注"] + "").Replace("'", "''")}','0199') end;"); + int createCode = ProductSaveUnique(code.Replace("'", "''"), (dataRow["名称"] + "").Replace("'", "''"), (dataRow["备注"] + "").Replace("'", "''"), "1000202_1", out string pid, out string msg); + if ((createCode + "").Equals("-1")) + { + throw new Exception($"虚拟物料创建失败\r\n{msg}"); + } } } if (!string.IsNullOrEmpty(stringBuilder.ToString())) @@ -1082,7 +1088,7 @@ namespace Lskj.PubBomImport else if (code.StartsWith("QD")) { DataRow childRow = childTable.NewRow(); - childRow["ProductId"] = code; + childRow["ProductId"] = BaseImpl.GetResult($"(select top 1 productid from p_ProductTab where spec = '{code}')"); childRow["appellation"] = parentRow["名称"] + ""; childRow["bak"] = childsourceCode; childRow["bombb"] = childsourceBB; @@ -1198,7 +1204,7 @@ namespace Lskj.PubBomImport if (childInfo != null) { GetFileCodeInfo(Path.GetFileNameWithoutExtension(childInfo.Name).Trim(), out string qdsourceCode, out string qdname, out string qdsourceBB, out int qdsourceBC); - DataRow productRow = BaseImpl.GetDataRowResult($"select top 1 billdocument_id from bom_BillTab where productid='{code}'"); + DataRow productRow = BaseImpl.GetDataRowResult($"select top 1 billdocument_id from bom_BillTab where productid = (select top 1 productid from p_ProductTab where spec = '{code}')"); if (productRow == null) { string childGuid = childInfoRow != null && !string.IsNullOrEmpty(childInfoRow["qms_laddf_Exec"] + "") ? childInfoRow["qms_laddf_Exec"] + "" : Guid.NewGuid() + ""; @@ -1225,7 +1231,7 @@ namespace Lskj.PubBomImport throw new Exception($"{code}明细数据为空"); } SetProcessBar(40, allCount); - string childBillMasterSql = $"select (select top 1 billdocument_id from bom_BillTab where productid='{code}') as billdocument_id,'0' affirmer,'0' rtagid,'{code}' as productid,'{qdsourceCode}' as bak,'{qdsourceBB}' as bombb,'{qdsourceBC}' as bombc"; + string childBillMasterSql = $"select (select top 1 billdocument_id from bom_BillTab where productid = (select top 1 productid from p_ProductTab where spec = '{code}')) as billdocument_id,'0' affirmer,'0' rtagid,(select top 1 productid from p_ProductTab where spec = '{code}') as productid,'{qdsourceCode}' as bak,'{qdsourceBB}' as bombb,'{qdsourceBC}' as bombc"; // 处理单据表头数据 DataRow childMasterRow = BillImpl.GetDataRowResult(childBillMasterSql); SetProcessBar(60, allCount); @@ -1420,6 +1426,447 @@ namespace Lskj.PubBomImport } } /// + /// 一级bom结构上传 + /// + /// + public void StartImportInFirstFiles(List selectRows) + { + try + { + if (Directory.Exists("BomImportTemp")) + { + Directory.Delete("BomImportTemp", true); + } + Directory.CreateDirectory("BomImportTemp"); + int execOrder = 1; + var mxRows = selectRows.Where(n => (n[Model.AfterBomFieldName] + "").StartsWith("MX")); + if (mxRows.Count() > 1) + { + throw new Exception($"不允许出现多个MX文件"); + } + DataRow mxRow = mxRows.FirstOrDefault(); + if (mxRow != null) + { + string mxFileName = mxRow[Model.AfterBomFieldName] + ""; + string mxDirPath = mxRow["BomFieldNameDir"] + ""; + string productId = mxRow["BomMxMainProduct"] + ""; + string addState = mxRow["BomMxAddState"] + ""; + if (string.IsNullOrEmpty(productId)) + { + throw new Exception($"保存失败\r\n请重新进行BOM上传后保存"); + } + if (addState.Equals("新增")) + { + DataRow billRow = BaseImpl.GetDataRowResult($"select qms_maddf_billdocument_id from qms_BillFileAddMaintab where qms_maddf_productid = '{productId}' and isnull(qms_maddf_addMode,'0') = '2'"); + if (billRow != null) + { + throw new Exception($"物料编码{productId}的BOM新增单已存在审批流\r\n请进行审批"); + } + //DataRow billbomRow = BaseImpl.GetDataRowResult($"select top 1 billdocument_id from bom_BillTab where productid='{productId}'"); + //if (billRow != null) + //{ + // throw new Exception($"物料编码{productId}的BOM建立单已存在\r\n请进行修改操作"); + //} + } + else + { + //DataRow billbomRow = BaseImpl.GetDataRowResult($"select top 1 billdocument_id from bom_BillTab where productid='{productId}' and stepover = '1'"); + //if (billbomRow != null) + //{ + // throw new Exception($"物料编码{productId}的BOM建立单已终审\r\n禁止修改操作"); + //} + } + GetFileCodeInfo(mxFileName.Trim(), out string mxsourceCode, out string mxname, out string mxsourceBB, out int mxsourceBC); + DataTable mxfiletable = BaseImpl.GetDataTableResult($"select sname,fileId,webpath from p_fm_filetab where parentid in (select dirid from P_fm_DirectoryTab where pid = '{productId}' and dllcoid = '1000202') and speciesno = '010106' and sname like '{mxsourceCode}%'"); + + FileInfo mxInfo = null; + if (!string.IsNullOrEmpty(mxDirPath)) + { + mxInfo = new FileInfo(mxDirPath); + } + if (mxInfo != null || mxfiletable.Rows.Count > 0) + { + if (mxfiletable.Rows.Count > 1) + { + throw new Exception($"{mxsourceCode}存在多个版次，请进行MX修改"); + } + if (mxfiletable.Rows.Count > 0) + { + using (WebClient webClient = new WebClient()) + { + try + { + string webpath = mxfiletable.Rows[0]["webpath"] + ""; + string sName = mxfiletable.Rows[0]["sName"] + ""; + webpath = webpath.StartsWith("/") ? webpath : $"/{webpath}"; + string url = $"{SystemInfo.Instance.OAUrl}/{webpath}"; + string tempFileName = $"BomImportTemp/{sName}"; + if (!File.Exists(tempFileName)) + { + webClient.DownloadFile(url, tempFileName); + } + mxInfo = new FileInfo(tempFileName); + } + catch (Exception) + { + throw new Exception($"Bom明细附件{mxsourceCode}获取失败\r\nBom导入失败"); + } + } + } + if (mxInfo != null) + { + int mxMaxBc = 0; + string mxMaxBcFileId = "-1"; + foreach (DataRow mxfileRow in mxfiletable.Rows) + { + string fileName = mxfileRow["sname"] + ""; + string fileId = mxfileRow["fileId"] + ""; + GetFileCodeInfo(fileName, out string fileCode, out string name, out string fileBB, out int fileBC); + if (fileBC >= mxMaxBc) + { + mxMaxBc = fileBC; + mxMaxBcFileId = fileId; + } + } + if (mxsourceBC > mxMaxBc && mxfiletable.Rows.Count > 0) + { + throw new Exception($"{mxsourceCode}的版次为{mxsourceBC}，大于最大版次{mxMaxBc}\r\n请进行变更"); + } + mxsourceBC = mxsourceBC >= mxMaxBc ? mxsourceBC : mxMaxBc; + FrmBillInfo frmBillInfo = new FrmBillInfo(); + DataTable parentTable = ExcelToDatatable(mxInfo.FullName, Model, "", 5); + parentTable = parentTable.Rows.Cast().Where(n => int.TryParse(n["序号"] + "", out _) && !string.IsNullOrEmpty(n["图号"] + "") && !string.IsNullOrEmpty(n["名称"] + "")).ToList().CopyToDataTable(); + StringBuilder stringBuilder = new StringBuilder(); + foreach (DataRow dataRow in parentTable.Rows) + { + string code = (dataRow["图号"] + "").Trim(); + if (code.StartsWith("QD")) + { + int createCode = ProductSaveUnique(code.Replace("'", "''"), (dataRow["名称"] + "").Replace("'", "''"), (dataRow["备注"] + "").Replace("'", "''"), "1000202_1", out string pid, out string msg); + if ((createCode + "").Equals("-1")) + { + throw new Exception($"虚拟物料创建失败\r\n{msg}"); + } + } + } + if (!string.IsNullOrEmpty(stringBuilder.ToString())) + { + SqlHelper.ExecuteNonQuery(stringBuilder.ToString()); + } + frmBillInfo.OnControlSourceBind += (s, args) => + { + Task task = new Task(() => + { + try + { + int.TryParse(Model.FirstRowIndex, out int index); + frmMain.FirstRowIndex = index; + bool isUpload = false; + string msg = ""; + Dictionary maxBcFileDic = new Dictionary(); + Dictionary fileTableDic = new Dictionary(); + #region 新增或修改MX + frmBillInfo.OnBillAdd(); + SetProcessBar(0, 0); + SetProcessMsg($"正在导入：{Path.GetFileName(mxInfo.FullName)}"); + DataTable childTable = frmBillInfo.GcMainView.GridControl.DataSourceTable().Clone(); + StringBuilder insertbulider = new StringBuilder(); + insertbulider.AppendLine($"delete FileAttachmentMapping where MaterialCode = '{productId}';"); + //insertbulider.AppendLine($"insert into FileAttachmentMapping (MaterialCode,MxFileName,RelatedAttachmentName,OperatorUser,ChangeStatus) values ('{productId}','{mxsourceCode }','{mxsourceCode}','{ERPInfo.Instance.UserName}','新增');"); + var mxCodeRows = parentTable.AsEnumerable(); + foreach (DataRow parentRow in parentTable.Rows) + { + int.TryParse(parentRow["套数"] + "", out int tamount); + string code = (parentRow["图号"] + "").Trim(); + int codeCount = mxCodeRows.Where(n => (n["图号"] + "").Trim().StartsWith(code)).Count(); + if (codeCount > 1)//只允许存在一个 + { + throw new Exception($"MX中的{code}重复,请修改"); + } + insertbulider.AppendLine($"insert into FileAttachmentMapping (MaterialCode,MxFileName,RelatedAttachmentName,OperatorUser,ChangeStatus) values ('{productId}','{mxsourceCode }','{code}','{ERPInfo.Instance.UserName}','新增');"); + DataTable filetable = BaseImpl.GetDataTableResult($"select sname,fileId,webpath from p_fm_filetab where parentid in (select dirid from P_fm_DirectoryTab where pid = '{code}' and dllcoid = '1000202') and speciesno = '010106' and sname like '{code}%'"); + fileTableDic[code] = filetable; + int childMaxBc = -1; + foreach (DataRow fileRow in filetable.Rows) + { + string fileName = fileRow["sname"] + ""; + string fileId = fileRow["fileId"] + ""; + GetFileCodeInfo(fileName, out string fileCode, out string name, out string fileBB, out int fileBC); + if (fileBC >= childMaxBc) + { + childMaxBc = fileBC; + maxBcFileDic[code] = fileRow; + } + } + //判断code是否已经上传，如果已经上传则不再上传， + //如果附件不存在文件夹中，则直接使用最新的 + //如果附件不存在则提示 + FileInfo childInfo = null; + DataRow childInfoRow = selectRows.Where(n => (n[Model.AfterBomFieldName] + "").StartsWith(code)).FirstOrDefault(); + if (childInfoRow != null) + { + string childFileName = childInfoRow[Model.AfterBomFieldName] + ""; + string childDirPath = childInfoRow["BomFieldNameDir"] + ""; + if (!string.IsNullOrEmpty(childDirPath)) + { + childInfo = new FileInfo(childDirPath); + } + } + if ((childInfo == null || filetable.Rows.Count > 0) && maxBcFileDic.ContainsKey(code) && maxBcFileDic[code] != null) + { + using (WebClient webClient = new WebClient()) + { + try + { + string webpath = maxBcFileDic[code]["webpath"] + ""; + string sName = maxBcFileDic[code]["sName"] + ""; + webpath = webpath.StartsWith("/") ? webpath : $"/{webpath}"; + string url = $"{SystemInfo.Instance.OAUrl}/{webpath}"; + string tempFileName = $"BomImportTemp/{sName}"; + if (!File.Exists(tempFileName)) + { + webClient.DownloadFile(url, tempFileName); + } + childInfo = new FileInfo(tempFileName); + } + catch (Exception) + { + throw new Exception($"Bom明细附件{code}获取失败\r\nBom导入失败"); + } + } + } + if (childInfo != null) + { + GetFileCodeInfo(Path.GetFileNameWithoutExtension(childInfo.Name).Trim(), out string childsourceCode, out string childname, out string childsourceBB, out int childsourceBC); + //如果文件夹中有附件，则比较版次，如果大于最大版次，则提示 + if (childsourceBC > childMaxBc && filetable.Rows.Count > 0) + { + throw new Exception($"{childsourceCode}的版次为{childsourceBC}，大于最大版次{childMaxBc}\r\n请进行变更"); + } + childsourceBC = childsourceBC >= childMaxBc ? childsourceBC : childMaxBc; + if (code.StartsWith("ZZQD")) + { + DataTable qdTable = ExcelToDatatable(childInfo.FullName, Model, "", index); + DataView filterDataView = new DataView(qdTable); + try + { + if (!string.IsNullOrEmpty(Model.ReadTableCond)) + { + filterDataView.RowFilter = Model.ReadTableCond; + } + } + catch (Exception) + { + } + qdTable = filterDataView.ToTable(); + var qdCodeRows = qdTable.AsEnumerable(); + foreach (DataRow qdItem in qdTable.Rows) + { + string qdCode = (qdItem["物料编码"] + "").Trim(); + int qdCount = qdCodeRows.Where(n => (n["物料编码"] + "").Trim().StartsWith(qdCode)).Count(); + if (qdCount > 1)//只允许存在一个 + { + throw new Exception($"{childsourceCode}中的{qdCode}重复,请修改"); + } + } + if (code.StartsWith("ZZQD")) + { + foreach (DataRow zzqdItem in qdTable.Rows) + { + DataRow childRow = childTable.NewRow(); + childRow["ProductId"] = (zzqdItem["物料编码"] + "").Trim(); + childRow["appellation"] = zzqdItem["名称"] + ""; + childRow["bak"] = childsourceCode; + childRow["bombb"] = childsourceBB; + childRow["bombc"] = childsourceBC; + childRow["tamount"] = parentRow["套数"] + ""; + int.TryParse(zzqdItem["数量"] + "", out int amount); + childRow["amount"] = amount * tamount; + childTable.Rows.Add(childRow); + } + } + } + } + else + { + if (filetable.Rows.Count == 0) + { + throw new Exception($"{code}的附件不存在，请检查文件"); + } + } + } + SetProcessBar(20, 0); + if (childTable.Rows.Count == 0) + { + throw new Exception($"MX明细数据不能空"); + } + SetProcessBar(40, 0); + string billMasterSql = $"select (select top 1 billdocument_id from bom_BillTab where productid='{productId}') as billdocument_id,'0' affirmer,'0' rtagid,'{productId}' as productid,'{mxsourceCode}' as bak,'{mxsourceBB}' as bombb,'{mxsourceBC}' as bombc"; + // 处理单据表头数据 + DataRow masterRow = BillImpl.GetDataRowResult(billMasterSql); + SetProcessBar(60, 0); + frmBillInfo.AddOrUpdateBill(masterRow, childTable); + string guid = Guid.NewGuid() + ""; + frmBillInfo.BillSaveSql(guid); + BaseImpl.ExecSqlValue($"update p_bomImportExecTab set afterSql = '{insertbulider.ToString().Replace("'", "''")}' where guid = '{guid}'"); + BaseImpl.ExecSqlValue($"update p_bomImportExecTab set userid = '1' where guid = '{guid}'"); + SetProcessBar(80, 0); + //上传文件 + string uploadMxFileId = mxMaxBcFileId; + if (mxfiletable.Rows.Count == 0) + { + isUpload = UploadFileToAudit(mxInfo.FullName, productId, "010106", out msg, out uploadMxFileId); + if (!isUpload) + { + throw new Exception($"{mxInfo.Name}附件上传失败\r\n{msg}"); + } + } + StaticControl.RightMenuGridView.GridControl.Invoke(new Action(() => + { + if (mxRow.Table.Columns.Contains("qms_laddf_FileId")) + { + int.TryParse(uploadMxFileId, out int qms_laddf_FileId); + mxRow["qms_laddf_FileId"] = qms_laddf_FileId; + } + if (mxRow.Table.Columns.Contains("qms_laddf_Exec")) + { + mxRow["qms_laddf_Exec"] = guid; + } + if (mxRow.Table.Columns.Contains("qms_laddf_ExecOrder")) + { + mxRow["qms_laddf_ExecOrder"] = execOrder; + } + })); + execOrder += 1; + #endregion + SetProcessBar(100, (1 / (parentTable.Rows.Count + 1)) * 100); + SetProcessLabelAllMsg($"总进度：{1}/{parentTable.Rows.Count + 1}"); + foreach (DataRow dataRow in parentTable.Rows) + { + int childIndex = parentTable.Rows.IndexOf(dataRow); + int nowCount = 1 + childIndex; + int allCount = (int)((decimal)(1 + childIndex) / (parentTable.Rows.Count + 1) * 100); + int finishCount = (int)((decimal)(1 + nowCount) / (parentTable.Rows.Count + 1) * 100); + int.TryParse(dataRow["套数"] + "", out int tamount); + string code = (dataRow["图号"] + "").Trim(); + DataTable filetable = fileTableDic.ContainsKey(code) ? fileTableDic[code] : null; + + FileInfo childInfo = null; + DataRow childInfoRow = selectRows.Where(n => (n[Model.AfterBomFieldName] + "").StartsWith(code)).FirstOrDefault(); + if (childInfoRow != null) + { + string childFileName = childInfoRow[Model.AfterBomFieldName] + ""; + string childDirPath = childInfoRow["BomFieldNameDir"] + ""; + if (!string.IsNullOrEmpty(childDirPath)) + { + childInfo = new FileInfo(childDirPath); + } + } + if ((childInfo == null || filetable.Rows.Count > 0) && maxBcFileDic.ContainsKey(code) && maxBcFileDic[code] != null) + { + using (WebClient webClient = new WebClient()) + { + try + { + string webpath = maxBcFileDic[code]["webpath"] + ""; + string sName = maxBcFileDic[code]["sName"] + ""; + webpath = webpath.StartsWith("/") ? webpath : $"/{webpath}"; + string url = $"{SystemInfo.Instance.OAUrl}/{webpath}"; + string tempFileName = $"BomImportTemp/{sName}"; + if (!File.Exists(tempFileName)) + { + webClient.DownloadFile(url, tempFileName); + } + childInfo = new FileInfo(tempFileName); + } + catch (Exception) + { + throw new Exception($"Bom明细附件{code}获取失败\r\nBom导入失败"); + } + } + } + if (childInfo == null) + { + throw new Exception($"目录中不包含文件{code}"); + } + if (childInfo != null) + { + SetProcessBar(0, allCount); + string uploadFileId = maxBcFileDic.ContainsKey(code) ? maxBcFileDic[code]["fileId"] + "" : "-1"; + if (filetable.Rows.Count == 0) + { + GetFileCodeInfo(Path.GetFileNameWithoutExtension(childInfo.Name).Trim(), out string qdsourceCode, out string qdname, out string qdsourceBB, out int qdsourceBC); + if (filetable.Rows.Count == 0) + { + isUpload = UploadFileToAudit(childInfo.FullName, qdsourceCode, "010106", out msg, out uploadFileId); + if (!isUpload) + { + throw new Exception($"{code}附件上传失败\r\n{msg}"); + } + } + } + StaticControl.RightMenuGridView.GridControl.Invoke(new Action(() => + { + if (childInfoRow.Table.Columns.Contains("qms_laddf_FileId")) + { + int.TryParse(uploadFileId, out int qms_laddf_FileId); + childInfoRow["qms_laddf_FileId"] = qms_laddf_FileId; + } + })); + SetProcessBar(100, finishCount); + SetProcessLabelAllMsg($"总进度：{nowCount + 1}/{parentTable.Rows.Count + 1}"); + } + else + { + throw new Exception($"目录中不包含文件{code}"); + } + } + this.Invoke(new Action(() => + { + this.DialogResult = DialogResult.OK; + Close(); + ImportTimer?.Dispose(); + })); + } + catch (Exception ex) + { + MessageUtil.Show(ex.Message); + this.Invoke(new Action(() => + { + this.DialogResult = DialogResult.Cancel; + Close(); + ImportTimer?.Dispose(); + })); + } + }); + task.Start(); + }; + frmBillInfo.OnLoad(Model); + frmMain.ParentView = frmBillInfo.GcMainView; + } + else + { + throw new Exception("未找到MX文件"); + } + } + else + { + throw new Exception("未包含MX文件"); + } + } + } + catch (Exception ex) + { + MessageUtil.Show(ex.Message); + this.Invoke(new Action(() => + { + this.DialogResult = DialogResult.Cancel; + Close(); + ImportTimer?.Dispose(); + })); + } + } + /// /// 修改终审同步 /// /// @@ -1562,7 +2009,7 @@ namespace Lskj.PubBomImport { throw new Exception($"物料编码不能为空"); } - string billdocumentId = BaseImpl.GetResult($"select qms_maddf_billdocument_id from qms_BillFileAddMaintab where qms_maddf_productid = '{parentProductId}' and isnull(qms_maddf_addMode,'0') = '0'") + ""; + string billdocumentId = BaseImpl.GetResult($"select qms_maddf_billdocument_id from qms_BillFileAddMaintab where qms_maddf_productid = '{parentProductId}' and (isnull(qms_maddf_addMode,'0') = '0' or isnull(qms_maddf_addMode,'0') = '2')") + ""; if (string.IsNullOrEmpty(billdocumentId)) { throw new Exception($"未查询到物料编码{parentProductId}的Bom单据号"); @@ -1769,6 +2216,85 @@ namespace Lskj.PubBomImport })); } } + public int ProductSaveUnique(string spec, string appellation, string bak, string billSeq, out string productId, out string tipMsg) + { + productId = string.Empty; + tipMsg = string.Empty; + try + { + /*---------------------------------------------------- + * 1) 组装存储过程参数 + *--------------------------------------------------*/ + // ProductId OUTPUT + SqlParameter pProductId = new SqlParameter("@ProductId", SqlDbType.VarChar, 100) + { + Direction = ParameterDirection.Output + }; + + // 存储过程 RETURN 值 + SqlParameter pReturn = new SqlParameter("@return", SqlDbType.Int) + { + Direction = ParameterDirection.ReturnValue + }; + + // 中文字段可根据服务器排序规则切换参数类型 + bool useNVar = ERPInfo.Instance.ChangeParameterType; + + SqlParameter[] param = + { + new SqlParameter("@Spec", SqlDbType.VarChar, 50), + useNVar + ? new SqlParameter("@Appellation", SqlDbType.NVarChar, 200) + : new SqlParameter("@Appellation", SqlDbType.VarChar, 200), + useNVar + ? new SqlParameter("@Bak", SqlDbType.NVarChar, 200) + : new SqlParameter("@Bak", SqlDbType.VarChar, 200), + new SqlParameter("@BillSeq", SqlDbType.VarChar, 40), + pProductId, + pReturn + }; + + param[0].Value = spec; + param[1].Value = appellation ?? string.Empty; + param[2].Value = bak ?? string.Empty; + param[3].Value = string.IsNullOrWhiteSpace(billSeq) ? (object)DBNull.Value : billSeq; + + SqlHelper.ExecuteNonQuery( + CommandType.StoredProcedure, + "sp_InsertProductUnique", + param); + + /*---------------------------------------------------- + * 3) 处理返回值与提示信息 + *--------------------------------------------------*/ + productId = pProductId.Value == DBNull.Value ? string.Empty + : pProductId.Value.ToString(); + int retCode = (pReturn.Value == DBNull.Value) ? -1 + : Convert.ToInt32(pReturn.Value); + + // 根据返回值给出业务提示 + switch (retCode) + { + case 0: + tipMsg = "保存成功！"; + break; + case 1: + tipMsg = "规格已存在，直接返回现有编码。"; + break; + default: + tipMsg = "发生异常，请查看日志！"; + break; + } + + return retCode; + } + catch (Exception ex) + { + tipMsg = ex.Message; + throw; // 继续向外抛，让调用层捕获日志 + } + } + /// /// 显示当前文件 ///