|
|
@@ -138,7 +138,7 @@ namespace FileWatcher
|
|
|
if (!string.IsNullOrEmpty(wccode) && !string.IsNullOrEmpty(orderdetno) && !string.IsNullOrEmpty(ordercode))
|
|
|
{
|
|
|
string day = today.ToString("yyyy-MM-dd");
|
|
|
- if (!dh.CheckExist("MakePlanDetail left join makeplan on mpd_mpid=mp_id ", "trunc(mp_begintime)=to_date('"+ day + "','yyyy-mm-dd') and mpd_orderdetno='" + orderdetno + "' and mpd_ordercode='" + ordercode + "' and mpd_wccode='" + wccode + "'"))
|
|
|
+ if (!dh.CheckExist("MakePlanDetail left join makeplan on mpd_mpid=mp_id ", "trunc(mp_begintime)=to_date('" + day + "','yyyy-mm-dd') and mpd_orderdetno='" + orderdetno + "' and mpd_ordercode='" + ordercode + "' and mpd_wccode='" + wccode + "'"))
|
|
|
{
|
|
|
string insertQuery = "INSERT INTO MakePlanDetail (mpd_mpid,mpd_detno,mpd_id,mpd_wccode, mpd_orderdetno, mpd_ordercode,mpd_outqty,mpd_remark) VALUES (" + id + "," + detno + ",MakePlanDetail_seq.nextval,:1, :2, :3,:4,:5)";
|
|
|
using (OracleCommand cmd = new OracleCommand(insertQuery, conn))
|
|
|
@@ -165,6 +165,273 @@ namespace FileWatcher
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
+ //上传日期1
|
|
|
+ if (DateTime1.Value != DateTime.Value)
|
|
|
+ {
|
|
|
+ today = DateTime1.Value;
|
|
|
+ todayDate = today.ToString("MMdd");
|
|
|
+ code = dh.GetSerialNumberByCaller("MakePlan");
|
|
|
+ id = "";
|
|
|
+ dt = (DataTable)dh.ExecuteSql("select mp_id from MakePlan where to_char(mp_begintime,'yyyymmdd')='" + today.ToString("yyyyMMdd") + "'", "select");
|
|
|
+ if (dt.Rows.Count == 0)
|
|
|
+ {
|
|
|
+ id = dh.GetSEQ("MakePlan_seq");
|
|
|
+ dh.ExecuteSql("insert into MakePlan(MP_ID, MP_CODE, MP_KIND, MP_INDATE, MP_STATUS, MP_STATUSCODE, MP_BEGINTIME)" +
|
|
|
+ "values(" + id + ",'" + code + "','日计划',sysdate,'在录入','ENTERING',to_date('" + today.ToString("yyyyMMdd") + "','yyyymmdd'))", "insert");
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ id = dt.Rows[0]["mp_id"].ToString();
|
|
|
+ dh.ExecuteSql("delete from MakePlandetail where mpd_mpid=" + id, "delete");
|
|
|
+ }
|
|
|
+
|
|
|
+ using (FileStream file = new FileStream(FilePath.Text, FileMode.Open, FileAccess.Read))
|
|
|
+ {
|
|
|
+ XSSFWorkbook workbook = new XSSFWorkbook(file);
|
|
|
+ int detno = 1;
|
|
|
+
|
|
|
+ for (int i = 0; i < workbook.NumberOfSheets; i++)
|
|
|
+ {
|
|
|
+ ISheet sheet = workbook.GetSheetAt(i);
|
|
|
+ string sheetName = sheet.SheetName;
|
|
|
+ if (sheetName.Contains(todayDate))
|
|
|
+ {
|
|
|
+ OperateResult.AppendText(sheetName);
|
|
|
+ OperateResult.AppendText($"Processing sheet: {sheetName}\n");
|
|
|
+ //Console.WriteLine($"Processing sheet: {sheetName}");
|
|
|
+
|
|
|
+ // 获取标题行（第4行）
|
|
|
+ IRow headerRow = sheet.GetRow(3); // 第4行索引为3
|
|
|
+ if (headerRow == null)
|
|
|
+ {
|
|
|
+ Console.WriteLine("Header row not found.");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取标题列的索引
|
|
|
+ int wccodeIndex = -1;
|
|
|
+ int orderdetnoIndex = -1;
|
|
|
+ int ordercodeIndex = -1;
|
|
|
+ int planqtyIndex = -1;
|
|
|
+ int remarkIndex = -1;
|
|
|
+
|
|
|
+ for (int colIndex = 0; colIndex < headerRow.LastCellNum; colIndex++)
|
|
|
+ {
|
|
|
+ ICell cell = headerRow.GetCell(colIndex);
|
|
|
+ if (cell != null)
|
|
|
+ {
|
|
|
+ string headerValue = cell.ToString().Trim().Replace("\r\n", "").Replace("\n", "").Replace("\r", "");
|
|
|
+ if (headerValue == "工作中心")
|
|
|
+ {
|
|
|
+ wccodeIndex = colIndex;
|
|
|
+ }
|
|
|
+ else if (headerValue == "订单序号")
|
|
|
+ {
|
|
|
+ orderdetnoIndex = colIndex;
|
|
|
+ }
|
|
|
+ else if (headerValue == "订单编号")
|
|
|
+ {
|
|
|
+ ordercodeIndex = colIndex;
|
|
|
+ }
|
|
|
+ else if (headerValue == "计划数量")
|
|
|
+ {
|
|
|
+ planqtyIndex = colIndex;
|
|
|
+ }
|
|
|
+ else if (headerValue.Contains("备注") && !headerValue.Contains("生产异常备注"))
|
|
|
+ {
|
|
|
+ remarkIndex = colIndex;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (wccodeIndex == -1 || orderdetnoIndex == -1 || ordercodeIndex == -1 || planqtyIndex == -1 || remarkIndex == -1)
|
|
|
+ {
|
|
|
+ Console.WriteLine("Required columns not found in the header.");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ using (OracleConnection conn = new OracleConnection(connectionString))
|
|
|
+ {
|
|
|
+ conn.Open();
|
|
|
+ for (int rowIndex = 4; rowIndex <= sheet.LastRowNum; rowIndex++) // 从第5行开始解析数据
|
|
|
+ {
|
|
|
+ IRow row = sheet.GetRow(rowIndex);
|
|
|
+ if (row != null)
|
|
|
+ {
|
|
|
+ string wccode = row.GetCell(wccodeIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).StringCellValue.ToString();
|
|
|
+ if (wccode == "")
|
|
|
+ {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ string orderdetno = row.GetCell(orderdetnoIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).ToString();
|
|
|
+ string ordercode = row.GetCell(ordercodeIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).ToString();
|
|
|
+ string planqty = row.GetCell(planqtyIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).NumericCellValue.ToString();
|
|
|
+ string remark = row.GetCell(remarkIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).ToString();
|
|
|
+ if (!string.IsNullOrEmpty(wccode) && !string.IsNullOrEmpty(orderdetno) && !string.IsNullOrEmpty(ordercode))
|
|
|
+ {
|
|
|
+ string day = today.ToString("yyyy-MM-dd");
|
|
|
+ if (!dh.CheckExist("MakePlanDetail left join makeplan on mpd_mpid=mp_id ", "trunc(mp_begintime)=to_date('" + day + "','yyyy-mm-dd') and mpd_orderdetno='" + orderdetno + "' and mpd_ordercode='" + ordercode + "' and mpd_wccode='" + wccode + "'"))
|
|
|
+ {
|
|
|
+ string insertQuery = "INSERT INTO MakePlanDetail (mpd_mpid,mpd_detno,mpd_id,mpd_wccode, mpd_orderdetno, mpd_ordercode,mpd_outqty,mpd_remark) VALUES (" + id + "," + detno + ",MakePlanDetail_seq.nextval,:1, :2, :3,:4,:5)";
|
|
|
+ using (OracleCommand cmd = new OracleCommand(insertQuery, conn))
|
|
|
+ {
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":1", wccode));
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":2", orderdetno));
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":3", ordercode));
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":4", planqty));
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":5", remark));
|
|
|
+ cmd.ExecuteNonQuery();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ OperateResult.AppendText(" 序号'" + orderdetno + "' 销售订单'" + ordercode + "' 工作中心'" + wccode + "' 重复");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ detno = detno + 1;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ dh.ExecuteSql("delete from MakePlanDetail where mpd_orderdetno is null", "delete");
|
|
|
+ OperateResult.AppendText("计划上传成功");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //上传日期2
|
|
|
+ if (DateTime2.Value != DateTime1.Value && DateTime2.Value != DateTime.Value)
|
|
|
+ {
|
|
|
+ today = DateTime2.Value;
|
|
|
+ todayDate = today.ToString("MMdd");
|
|
|
+ code = dh.GetSerialNumberByCaller("MakePlan");
|
|
|
+ id = "";
|
|
|
+ dt = (DataTable)dh.ExecuteSql("select mp_id from MakePlan where to_char(mp_begintime,'yyyymmdd')='" + today.ToString("yyyyMMdd") + "'", "select");
|
|
|
+ if (dt.Rows.Count == 0)
|
|
|
+ {
|
|
|
+ id = dh.GetSEQ("MakePlan_seq");
|
|
|
+ dh.ExecuteSql("insert into MakePlan(MP_ID, MP_CODE, MP_KIND, MP_INDATE, MP_STATUS, MP_STATUSCODE, MP_BEGINTIME)" +
|
|
|
+ "values(" + id + ",'" + code + "','日计划',sysdate,'在录入','ENTERING',to_date('" + today.ToString("yyyyMMdd") + "','yyyymmdd'))", "insert");
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ id = dt.Rows[0]["mp_id"].ToString();
|
|
|
+ dh.ExecuteSql("delete from MakePlandetail where mpd_mpid=" + id, "delete");
|
|
|
+ }
|
|
|
+
|
|
|
+ using (FileStream file = new FileStream(FilePath.Text, FileMode.Open, FileAccess.Read))
|
|
|
+ {
|
|
|
+ XSSFWorkbook workbook = new XSSFWorkbook(file);
|
|
|
+ int detno = 1;
|
|
|
+
|
|
|
+ for (int i = 0; i < workbook.NumberOfSheets; i++)
|
|
|
+ {
|
|
|
+ ISheet sheet = workbook.GetSheetAt(i);
|
|
|
+ string sheetName = sheet.SheetName;
|
|
|
+ if (sheetName.Contains(todayDate))
|
|
|
+ {
|
|
|
+ OperateResult.AppendText(sheetName);
|
|
|
+ OperateResult.AppendText($"Processing sheet: {sheetName}\n");
|
|
|
+ //Console.WriteLine($"Processing sheet: {sheetName}");
|
|
|
+
|
|
|
+ // 获取标题行（第4行）
|
|
|
+ IRow headerRow = sheet.GetRow(3); // 第4行索引为3
|
|
|
+ if (headerRow == null)
|
|
|
+ {
|
|
|
+ Console.WriteLine("Header row not found.");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取标题列的索引
|
|
|
+ int wccodeIndex = -1;
|
|
|
+ int orderdetnoIndex = -1;
|
|
|
+ int ordercodeIndex = -1;
|
|
|
+ int planqtyIndex = -1;
|
|
|
+ int remarkIndex = -1;
|
|
|
+
|
|
|
+ for (int colIndex = 0; colIndex < headerRow.LastCellNum; colIndex++)
|
|
|
+ {
|
|
|
+ ICell cell = headerRow.GetCell(colIndex);
|
|
|
+ if (cell != null)
|
|
|
+ {
|
|
|
+ string headerValue = cell.ToString().Trim().Replace("\r\n", "").Replace("\n", "").Replace("\r", "");
|
|
|
+ if (headerValue == "工作中心")
|
|
|
+ {
|
|
|
+ wccodeIndex = colIndex;
|
|
|
+ }
|
|
|
+ else if (headerValue == "订单序号")
|
|
|
+ {
|
|
|
+ orderdetnoIndex = colIndex;
|
|
|
+ }
|
|
|
+ else if (headerValue == "订单编号")
|
|
|
+ {
|
|
|
+ ordercodeIndex = colIndex;
|
|
|
+ }
|
|
|
+ else if (headerValue == "计划数量")
|
|
|
+ {
|
|
|
+ planqtyIndex = colIndex;
|
|
|
+ }
|
|
|
+ else if (headerValue.Contains("备注") && !headerValue.Contains("生产异常备注"))
|
|
|
+ {
|
|
|
+ remarkIndex = colIndex;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (wccodeIndex == -1 || orderdetnoIndex == -1 || ordercodeIndex == -1 || planqtyIndex == -1 || remarkIndex == -1)
|
|
|
+ {
|
|
|
+ Console.WriteLine("Required columns not found in the header.");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ using (OracleConnection conn = new OracleConnection(connectionString))
|
|
|
+ {
|
|
|
+ conn.Open();
|
|
|
+ for (int rowIndex = 4; rowIndex <= sheet.LastRowNum; rowIndex++) // 从第5行开始解析数据
|
|
|
+ {
|
|
|
+ IRow row = sheet.GetRow(rowIndex);
|
|
|
+ if (row != null)
|
|
|
+ {
|
|
|
+ string wccode = row.GetCell(wccodeIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).StringCellValue.ToString();
|
|
|
+ if (wccode == "")
|
|
|
+ {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ string orderdetno = row.GetCell(orderdetnoIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).ToString();
|
|
|
+ string ordercode = row.GetCell(ordercodeIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).ToString();
|
|
|
+ string planqty = row.GetCell(planqtyIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).NumericCellValue.ToString();
|
|
|
+ string remark = row.GetCell(remarkIndex, MissingCellPolicy.CREATE_NULL_AS_BLANK).ToString();
|
|
|
+ if (!string.IsNullOrEmpty(wccode) && !string.IsNullOrEmpty(orderdetno) && !string.IsNullOrEmpty(ordercode))
|
|
|
+ {
|
|
|
+ string day = today.ToString("yyyy-MM-dd");
|
|
|
+ if (!dh.CheckExist("MakePlanDetail left join makeplan on mpd_mpid=mp_id ", "trunc(mp_begintime)=to_date('" + day + "','yyyy-mm-dd') and mpd_orderdetno='" + orderdetno + "' and mpd_ordercode='" + ordercode + "' and mpd_wccode='" + wccode + "'"))
|
|
|
+ {
|
|
|
+ string insertQuery = "INSERT INTO MakePlanDetail (mpd_mpid,mpd_detno,mpd_id,mpd_wccode, mpd_orderdetno, mpd_ordercode,mpd_outqty,mpd_remark) VALUES (" + id + "," + detno + ",MakePlanDetail_seq.nextval,:1, :2, :3,:4,:5)";
|
|
|
+ using (OracleCommand cmd = new OracleCommand(insertQuery, conn))
|
|
|
+ {
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":1", wccode));
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":2", orderdetno));
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":3", ordercode));
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":4", planqty));
|
|
|
+ cmd.Parameters.Add(new OracleParameter(":5", remark));
|
|
|
+ cmd.ExecuteNonQuery();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ OperateResult.AppendText(" 序号'" + orderdetno + "' 销售订单'" + ordercode + "' 工作中心'" + wccode + "' 重复");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ detno = detno + 1;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ dh.ExecuteSql("delete from MakePlanDetail where mpd_orderdetno is null", "delete");
|
|
|
+ OperateResult.AppendText("计划上传成功");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
private void ChooseFile_Click(object sender, EventArgs e)
|
