feat(hjgl): 支持组件焊口导入和优先匹配
组件与焊口关系需要参与材料匹配、任务生成和出库明细计算。 新增组件焊口导入入口，并允许在材料匹配时手动指定优先组件， 确保按组件范围生成任务单和领料数据。
This commit is contained in:
@@ -0,0 +1,336 @@
|
||||
using BLL;
|
||||
using MiniExcelLibs;
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Data;
|
||||
using System.IO;
|
||||
using System.Linq;
|
||||
|
||||
namespace FineUIPro.Web.HJGL.PreDesign
|
||||
{
|
||||
public partial class PrePipelineComponentJointIn : PageBase
|
||||
{
|
||||
private string initPath = Const.ExcelUrl;
|
||||
|
||||
public static List<ComponentJointImportItem> ComponentJointList = new List<ComponentJointImportItem>();
|
||||
|
||||
public static string errorInfos = string.Empty;
|
||||
|
||||
protected void Page_Load(object sender, EventArgs e)
|
||||
{
|
||||
if (!IsPostBack)
|
||||
{
|
||||
this.hdFileName.Text = string.Empty;
|
||||
if (ComponentJointList != null)
|
||||
{
|
||||
ComponentJointList.Clear();
|
||||
}
|
||||
errorInfos = string.Empty;
|
||||
}
|
||||
}
|
||||
|
||||
protected void btnAudit_Click(object sender, EventArgs e)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (this.fuAttachUrl.HasFile == false)
|
||||
{
|
||||
ShowNotify("请您选择Excel文件！", MessageBoxIcon.Warning);
|
||||
return;
|
||||
}
|
||||
string isXls = Path.GetExtension(this.fuAttachUrl.FileName).ToString().Trim().ToLower();
|
||||
if (isXls != ".xlsx")
|
||||
{
|
||||
ShowNotify("只可以选择Excel文件！", MessageBoxIcon.Warning);
|
||||
return;
|
||||
}
|
||||
ComponentJointList.Clear();
|
||||
errorInfos = string.Empty;
|
||||
|
||||
string rootPath = Server.MapPath("~/");
|
||||
string initFullPath = rootPath + initPath;
|
||||
if (!Directory.Exists(initFullPath))
|
||||
{
|
||||
Directory.CreateDirectory(initFullPath);
|
||||
}
|
||||
|
||||
this.hdFileName.Text = BLL.Funs.GetNewFileName() + isXls;
|
||||
string filePath = initFullPath + this.hdFileName.Text;
|
||||
this.fuAttachUrl.PostedFile.SaveAs(filePath);
|
||||
ImportXlsToData(filePath);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Alert alert = new Alert
|
||||
{
|
||||
Message = "'" + ex.Message + "'",
|
||||
Target = Target.Self
|
||||
};
|
||||
alert.Show();
|
||||
}
|
||||
}
|
||||
|
||||
private void ImportXlsToData(string fileName)
|
||||
{
|
||||
var rows = MiniExcel.QueryAsDataTable(fileName, useHeaderRow: true);
|
||||
Model.ResponeData responeData = AddDatasetToSQL(rows, 3);
|
||||
if (responeData.code == 1)
|
||||
{
|
||||
ShowNotify("审核完成,请点击导入！", MessageBoxIcon.Success);
|
||||
}
|
||||
else
|
||||
{
|
||||
Alert alert = new Alert
|
||||
{
|
||||
Message = responeData.message,
|
||||
Target = Target.Self
|
||||
};
|
||||
alert.Show();
|
||||
}
|
||||
}
|
||||
|
||||
private Model.ResponeData AddDatasetToSQL(DataTable pds, int cols)
|
||||
{
|
||||
Model.ResponeData responeData = new Model.ResponeData();
|
||||
List<string> result = new List<string>();
|
||||
if (pds == null)
|
||||
{
|
||||
responeData.code = 0;
|
||||
responeData.message = "导入数据为空！";
|
||||
return responeData;
|
||||
}
|
||||
|
||||
int ic = pds.Columns.Count;
|
||||
int ir = pds.Rows.Count;
|
||||
if (ic < cols || !pds.Columns.Contains("管线号") || !pds.Columns.Contains("预制组件") || !pds.Columns.Contains("焊口号"))
|
||||
{
|
||||
responeData.code = 0;
|
||||
responeData.message = "导入Excel格式错误！模板列必须包含：管线号、预制组件、焊口号";
|
||||
return responeData;
|
||||
}
|
||||
if (ir == 0)
|
||||
{
|
||||
responeData.code = 0;
|
||||
responeData.message = "导入数据为空！";
|
||||
return responeData;
|
||||
}
|
||||
|
||||
var getPipeline = from x in Funs.DB.HJGL_Pipeline where x.ProjectId == this.CurrUser.LoginProjectId select x;
|
||||
List<ComponentJointImportItem> importItems = new List<ComponentJointImportItem>();
|
||||
|
||||
for (int i = 0; i < ir; i++)
|
||||
{
|
||||
string pipelineCode = GetCellValue(pds.Rows[i], "管线号");
|
||||
string pipelineComponentCode = GetCellValue(pds.Rows[i], "预制组件");
|
||||
string weldJointCode = GetCellValue(pds.Rows[i], "焊口号");
|
||||
|
||||
if (string.IsNullOrEmpty(pipelineCode) && string.IsNullOrEmpty(pipelineComponentCode) && string.IsNullOrEmpty(weldJointCode))
|
||||
{
|
||||
continue;
|
||||
}
|
||||
|
||||
if (string.IsNullOrEmpty(pipelineCode))
|
||||
{
|
||||
result.Add("第" + (i + 2).ToString() + "行,管线号,此项为必填项！");
|
||||
continue;
|
||||
}
|
||||
if (string.IsNullOrEmpty(pipelineComponentCode))
|
||||
{
|
||||
result.Add("第" + (i + 2).ToString() + "行,预制组件,此项为必填项！");
|
||||
continue;
|
||||
}
|
||||
if (string.IsNullOrEmpty(weldJointCode))
|
||||
{
|
||||
result.Add("第" + (i + 2).ToString() + "行,焊口号,此项为必填项！");
|
||||
continue;
|
||||
}
|
||||
|
||||
var pipeline = getPipeline.FirstOrDefault(x => x.PipelineCode == pipelineCode);
|
||||
if (pipeline == null)
|
||||
{
|
||||
result.Add("第" + (i + 2).ToString() + "行,不存在此管线号-" + pipelineCode);
|
||||
continue;
|
||||
}
|
||||
|
||||
var pipelineComponent = HJGL_PipelineComponentService.GetPipelineComponentByCodeandpipelineId(pipelineComponentCode, pipeline.PipelineId);
|
||||
if (pipelineComponent == null)
|
||||
{
|
||||
result.Add("第" + (i + 2).ToString() + "行,不存在此预制组件-" + pipelineComponentCode);
|
||||
continue;
|
||||
}
|
||||
|
||||
var weldJoint = WeldJointService.GetWeldJointsByWeldJointCode(pipeline.PipelineId, weldJointCode);
|
||||
if (weldJoint == null)
|
||||
{
|
||||
result.Add("第" + (i + 2).ToString() + "行,不存在此焊口号-" + weldJointCode);
|
||||
continue;
|
||||
}
|
||||
|
||||
importItems.Add(new ComponentJointImportItem
|
||||
{
|
||||
PipelineId = pipeline.PipelineId,
|
||||
PipelineCode = pipeline.PipelineCode,
|
||||
PipelineComponentId = pipelineComponent.PipelineComponentId,
|
||||
PipelineComponentCode = pipelineComponent.PipelineComponentCode,
|
||||
WeldJointId = weldJoint.WeldJointId,
|
||||
WeldJointCode = weldJoint.WeldJointCode
|
||||
});
|
||||
}
|
||||
|
||||
var conflictWeldJoints = importItems
|
||||
.GroupBy(x => x.WeldJointId)
|
||||
.Where(x => x.Select(y => y.PipelineComponentId).Distinct().Count() > 1)
|
||||
.Select(x => x.First().PipelineCode + "-" + x.First().WeldJointCode)
|
||||
.ToList();
|
||||
if (conflictWeldJoints.Count > 0)
|
||||
{
|
||||
result.Add("同一焊口不能导入到多个组件：" + string.Join("、", conflictWeldJoints));
|
||||
}
|
||||
|
||||
if (result.Count > 0)
|
||||
{
|
||||
ComponentJointList.Clear();
|
||||
errorInfos = string.Join("|", result.Distinct());
|
||||
responeData.code = 0;
|
||||
responeData.message = errorInfos;
|
||||
return responeData;
|
||||
}
|
||||
|
||||
ComponentJointList = importItems
|
||||
.GroupBy(x => new { x.PipelineComponentId, x.WeldJointId })
|
||||
.Select(x => x.First())
|
||||
.ToList();
|
||||
errorInfos = string.Empty;
|
||||
responeData.code = ComponentJointList.Count > 0 ? 1 : 0;
|
||||
responeData.message = ComponentJointList.Count > 0 ? string.Empty : "导入数据为空！";
|
||||
return responeData;
|
||||
}
|
||||
|
||||
protected void btnImport_Click(object sender, EventArgs e)
|
||||
{
|
||||
if (string.IsNullOrEmpty(errorInfos))
|
||||
{
|
||||
if (!string.IsNullOrEmpty(this.hdFileName.Text))
|
||||
{
|
||||
if (ComponentJointList.Count > 0)
|
||||
{
|
||||
this.Grid1.Hidden = false;
|
||||
this.Grid1.DataIDField = "WeldJointId";
|
||||
this.Grid1.DataSource = ComponentJointList;
|
||||
this.Grid1.DataBind();
|
||||
Grid1.RecordCount = ComponentJointList.Count;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
ShowNotify("请先审核要导入的文件！", MessageBoxIcon.Warning);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
ShowNotify("请先将错误数据修正，再重新导入提交！", MessageBoxIcon.Warning);
|
||||
}
|
||||
}
|
||||
|
||||
protected void btnSave_Click(object sender, EventArgs e)
|
||||
{
|
||||
if (!string.IsNullOrEmpty(errorInfos))
|
||||
{
|
||||
ShowNotify("请先将错误数据修正，再重新导入提交！", MessageBoxIcon.Warning);
|
||||
return;
|
||||
}
|
||||
|
||||
if (ComponentJointList.Count > 0)
|
||||
{
|
||||
foreach (var item in ComponentJointList)
|
||||
{
|
||||
var componentJoint = BLL.HJGL_PipelineComponentjointService.GetHJGL_Pipeline_ComponentJointByWeldJointId(item.WeldJointId);
|
||||
if (componentJoint != null)
|
||||
{
|
||||
componentJoint.PipelineComponentCode = item.PipelineComponentCode;
|
||||
componentJoint.PipelineComponentId = item.PipelineComponentId;
|
||||
componentJoint.WeldJointCode = item.WeldJointCode;
|
||||
componentJoint.WeldJointId = item.WeldJointId;
|
||||
HJGL_PipelineComponentjointService.UpdateHJGL_Pipeline_ComponentJoint(componentJoint);
|
||||
}
|
||||
else
|
||||
{
|
||||
Model.HJGL_Pipeline_ComponentJoint newComponentJoint = new Model.HJGL_Pipeline_ComponentJoint();
|
||||
newComponentJoint.Id = SQLHelper.GetNewID();
|
||||
newComponentJoint.PipelineComponentCode = item.PipelineComponentCode;
|
||||
newComponentJoint.PipelineComponentId = item.PipelineComponentId;
|
||||
newComponentJoint.WeldJointCode = item.WeldJointCode;
|
||||
newComponentJoint.WeldJointId = item.WeldJointId;
|
||||
newComponentJoint.State = 0;
|
||||
HJGL_PipelineComponentjointService.AddHJGL_Pipeline_ComponentJoint(newComponentJoint);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
string rootPath = Server.MapPath("~/");
|
||||
string filePath = rootPath + initPath + this.hdFileName.Text;
|
||||
if (filePath != string.Empty && System.IO.File.Exists(filePath))
|
||||
{
|
||||
System.IO.File.Delete(filePath);
|
||||
}
|
||||
ShowNotify("导入成功！", MessageBoxIcon.Success);
|
||||
PageContext.RegisterStartupScript(ActiveWindow.GetHidePostBackReference());
|
||||
}
|
||||
|
||||
protected void btnDownLoad_Click(object sender, EventArgs e)
|
||||
{
|
||||
string rootPath = Server.MapPath("~/");
|
||||
string tempDirectory = rootPath + @"File\Excel\Temp\";
|
||||
if (!Directory.Exists(tempDirectory))
|
||||
{
|
||||
Directory.CreateDirectory(tempDirectory);
|
||||
}
|
||||
string tempPath = tempDirectory + "组件焊口信息导入模板" + string.Format("{0:yyyyMMddHHmmss}", DateTime.Now) + ".xlsx";
|
||||
DataTable template = new DataTable();
|
||||
template.Columns.Add("管线号");
|
||||
template.Columns.Add("预制组件");
|
||||
template.Columns.Add("焊口号");
|
||||
MiniExcel.SaveAs(tempPath, template);
|
||||
|
||||
FileInfo info = new FileInfo(tempPath);
|
||||
long fileSize = info.Length;
|
||||
Response.ClearContent();
|
||||
Response.AddHeader("Content-Disposition", "attachment;filename=" + System.Web.HttpUtility.UrlEncode("组件焊口信息导入模板.xlsx", System.Text.Encoding.UTF8));
|
||||
Response.ContentType = "excel/plain";
|
||||
Response.ContentEncoding = System.Text.Encoding.UTF8;
|
||||
Response.AddHeader("Content-Length", fileSize.ToString().Trim());
|
||||
Response.TransmitFile(tempPath, 0, fileSize);
|
||||
Response.Flush();
|
||||
Response.Close();
|
||||
File.Delete(tempPath);
|
||||
}
|
||||
|
||||
protected void ddlPageSize_SelectedIndexChanged(object sender, EventArgs e)
|
||||
{
|
||||
Grid1.PageSize = Convert.ToInt32(ddlPageSize.SelectedValue);
|
||||
this.Grid1.DataSource = ComponentJointList;
|
||||
this.Grid1.DataBind();
|
||||
Grid1.RecordCount = ComponentJointList.Count;
|
||||
}
|
||||
|
||||
private string GetCellValue(DataRow row, string columnName)
|
||||
{
|
||||
return Convert.ToString(row[columnName]).Replace("\n", "").Replace(" ", "").Replace("\t", "").Replace("\r", "").Trim();
|
||||
}
|
||||
|
||||
public class ComponentJointImportItem
|
||||
{
|
||||
public string PipelineId { get; set; }
|
||||
|
||||
public string PipelineCode { get; set; }
|
||||
|
||||
public string PipelineComponentId { get; set; }
|
||||
|
||||
public string PipelineComponentCode { get; set; }
|
||||
|
||||
public string WeldJointId { get; set; }
|
||||
|
||||
public string WeldJointCode { get; set; }
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user