Special_Reset.cs 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454
  1. using DevExpress.XtraPrinting.Export.Pdf;
  2. using HslCommunication.Profinet.Knx;
  3. using NPOI.HSSF.UserModel;
  4. using NPOI.SS.UserModel;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.ComponentModel;
  8. using System.Data;
  9. using System.Diagnostics;
  10. using System.Drawing;
  11. using System.IO;
  12. using System.Linq;
  13. using System.Text;
  14. using System.Windows.Forms;
  15. using UAS_MES_NEW.DataOperate;
  16. using UAS_MES_NEW.Entity;
  17. using UAS_MES_NEW.PublicMethod;
  18. namespace UAS_MES_NEW.Special
  19. {
  20. public partial class Special_Reset : Form
  21. {
  22. DataHelper dh;
  23. LogStringBuilder sql = new LogStringBuilder();
  24. AutoSizeFormClass asc = new AutoSizeFormClass();
  25. DataTable Dbfind;
  26. DataTable dt;
  27. List<String> sb = new List<string>();
  28. public Special_Reset()
  29. {
  30. InitializeComponent();
  31. }
  32. private void Special_BoxSplit_Load(object sender, EventArgs e)
  33. {
  34. dh = SystemInf.dh;
  35. asc.controllInitializeSize(this);
  36. cd_stepcode.FormName = Name;
  37. cd_stepcode.TableName = "craftdetail left join step on st_code=cd_stepcode left join craft on cd_crid=cr_id";
  38. cd_stepcode.SetValueField = new string[] { "cd_stepcode", "cd_stepno" };
  39. cd_stepcode.SelectField = "cd_stepname # 工序名称 ,cd_stepcode # 工序编号,cd_stepno # 执行顺序";
  40. cd_stepcode.Condition = "ST_STATUSCODE='AUDITED' and cr_code='" + cr_code.Text + "' and cr_prodcode='" + ms_prodcode.Text + "' order by cd_stepno";
  41. cd_stepcode.DBTitle = "回流工序";
  42. cd_stepcode.DbChange += Cd_stepcode_DbChange;
  43. }
  44. private void Cd_stepcode_DbChange(object sender, EventArgs e)
  45. {
  46. Dbfind = cd_stepcode.ReturnData;
  47. BaseUtil.SetFormValue(this.Controls, Dbfind);
  48. }
  49. private bool ReSN(string sncode, string stepcode)
  50. {
  51. DataTable dt = (DataTable)dh.ExecuteSql("select ms_paststep,ms_makecode from makeserial where ms_sncode ='" + sncode + "' order by ms_id desc", "select");
  52. if (!dt.Rows[0]["ms_paststep"].ToString().Contains(cd_stepcode.Text))
  53. {
  54. OperatResult.AppendText(">>序列号" + sncode + "不允许回流到未执行工序\n", Color.Red);
  55. return false;
  56. }
  57. string makecode = dt.Rows[0]["ms_makecode"].ToString();
  58. string stname = dh.getFieldDataByCondition("step", "st_name", "st_code = '" + stepcode + "'").ToString();
  59. dh.ExecuteSql("update makeserial set ms_status=1,ms_outboxcode='',ms_printcount = 0, ms_nextstepcode= '" + stepcode + "' where ms_sncode='" + sncode + "' and ms_makecode='" + makecode + "'", "update");
  60. dh.ExecuteSql("delete makebad where mb_sncode = '" + sncode + "' and mb_makecode='" + makecode + "' and mb_status = 0", "delete");
  61. dh.ExecuteSql("delete labelprintlog where lpl_value = '" + sncode + "' ", "delete");
  62. sql.Clear();
  63. sql.Append("update craftmaterial set cm_status=-1,cm_lastdeco=-1,cm_dropman='" + User.UserCode + "',");
  64. sql.Append("cm_dropdate =sysdate,CM_REMARK = '重置站点拆解',cm_dropstep='" + User.CurrentStepCode + "',");
  65. sql.Append("cm_dropsccode='" + User.UserSourceCode + "' where cm_sncode = '" + sncode + "' and cm_makecode='" + makecode + "' and cm_stepcode in (select cd_stepcode from craftdetail left join step on st_code=cd_stepcode left join craft on cd_crid=cr_id where ST_STATUSCODE='AUDITED' and cr_code='" + cr_code.Text + "' and cr_prodcode='" + ms_prodcode.Text + "' and cd_detno >=" + cd_stepno.Text + " )");
  66. dh.ExecuteSql(sql.GetString(), "update");
  67. LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, ms_makecode.Text, User.UserLineCode, User.UserSourceCode, "站点重置", "站点重置至" + stname, sncode, "");
  68. return true;
  69. }
  70. private void Split_Click(object sender, EventArgs e)
  71. {
  72. if (sb.Count == 0 || cd_stepcode.Text == "")
  73. {
  74. OperatResult.AppendText(">>采集数与回流工位不能为空\n", Color.Red);
  75. return;
  76. }
  77. string Delete = MessageBox.Show(this.ParentForm, "是否确认重置站点?", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
  78. if (Delete == "Yes")
  79. {
  80. if (serBtn.Checked)
  81. {
  82. for (int i = 0; i < sb.Count; i++)
  83. {
  84. if (ReSN(sb[i].ToString(), cd_stepcode.Text))
  85. OperatResult.AppendText("SN:" + sb[i].ToString() + "回流至" + cd_stepcode.Text + "完成\n", Color.Green);
  86. }
  87. WeighRecord.Clear();
  88. sb.Clear();
  89. }
  90. else if (bigboxBtn.Checked)
  91. {
  92. string stname = dh.getFieldDataByCondition("step", "st_name", "st_code = '" + cd_stepcode.Text + "'").ToString();
  93. for (int i = 0; i < sb.Count; i++)
  94. {
  95. if (dh.CheckExist("package", "pa_outboxcode='" + sb[i].ToString() + "' and pa_status=1"))
  96. {
  97. DataTable dt2 = (DataTable)dh.ExecuteSql("select ms_sncode from makeserial left Join package on pa_outboxcode=ms_outboxcode where ms_outboxcode = '" + sb[i].ToString() + "' and pa_status=1", "select");
  98. for (int k = 0; k < dt2.Rows.Count; k++)
  99. {
  100. ReSN(dt2.Rows[k]["ms_sncode"].ToString(), cd_stepcode.Text);
  101. }
  102. dh.ExecuteSql("delete from labelprintlog where lpl_value='" + sb[i].ToString() + "'", "delete");
  103. dh.ExecuteSql("insert into PACKAGEBACKUP(PA_ID, PA_PRODCODE, PA_OUTBOXCODE, PA_PACKDATE, PA_LEVEL, PA_PACKAGEQTY, PA_TOTALQTY, PA_MAKECODE, PA_STATUS, PA_INDATE, PA_SALECODE, PA_PRINTCOUNT, PA_CUSTCODE, PA_TYPE, PA_WEIGHT, PA_CURRENTQTY, PA_PACKTYPE, PA_CHECKNO, PA_DOWNSTATUS, PA_STANDARDQTY, PA_SCCODE, PA_YMD, PA_MOTHERCODE, PA_CURRENTSTEP, PA_NEXTSTEP, PA_OUTNO, PA_IOSTATUS, PA_REMARK, PA_WHCODE, PA_B2BID, PA_INNO)" +
  104. " select PA_ID, PA_PRODCODE, PA_OUTBOXCODE, PA_PACKDATE, PA_LEVEL, PA_PACKAGEQTY, PA_TOTALQTY, PA_MAKECODE, PA_STATUS, PA_INDATE, PA_SALECODE, PA_PRINTCOUNT, PA_CUSTCODE, PA_TYPE, PA_WEIGHT, PA_CURRENTQTY, PA_PACKTYPE, PA_CHECKNO, PA_DOWNSTATUS, PA_STANDARDQTY, PA_SCCODE, PA_YMD, PA_MOTHERCODE, PA_CURRENTSTEP, PA_NEXTSTEP, PA_OUTNO, PA_IOSTATUS, PA_REMARK, PA_WHCODE, PA_B2BID, PA_INNO from package where pa_outboxcode='" + sb[i].ToString() + "'", "insert");
  105. dh.ExecuteSql("insert into PACKAGEBACKUPDETAIL select * from packagedetail where pd_outboxcode='" + sb[i].ToString() + "'", "insert");
  106. dh.ExecuteSql("delete from package where pa_outboxcode = '" + sb[i].ToString() + "'", "delete");
  107. //删除箱的明细
  108. dh.ExecuteSql("delete from packagedetail where pd_outboxcode='" + sb[i].ToString() + "'", "delete");
  109. LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, ms_makecode.Text, User.UserLineCode, User.UserSourceCode, "站点重置", "站点重置至" + stname, sb[i].ToString(), "");
  110. OperatResult.AppendText("卡通箱:" + sb[i].ToString() + "回流至" + cd_stepcode.Text + "完成\n", Color.Green);
  111. }
  112. else
  113. {
  114. OperatResult.AppendText("卡通箱:" + sb[i].ToString() + "未封箱,不允许回流\n", Color.Green);
  115. }
  116. }
  117. WeighRecord.Clear();
  118. sb.Clear();
  119. }
  120. sql.Clear();
  121. sql.Append("MERGE INTO makecraftdetail USING (select mcd_macode,mcd_detno,mcd_stepcode,mcd_stepname,nvl(count(distinct A.ms_sncode),0) n,nvl(count(distinct B.ms_sncode),0) bn,(select nvl(count(distinct sp_sncode),0) from STEPPASSED where SP_MAKECODE = mcd_macode AND SP_STEPCODE = mcd_stepcode) inqty from MAKECRAFTdetail");
  122. sql.Append(" left join makeserial A on mcd_macode = A.ms_makecode and mcd_stepcode = A.ms_nextstepcode AND A.MS_STATUS = 1 LEFT JOIN MAKESERIAL B ON mcd_macode = B.ms_makecode AND MCD_STEPCODE = B.MS_STEPCODE AND B.MS_STATUS = 3 where mcd_macode = '" + ms_makecode.Text + "' group by mcd_macode,mcd_detno, mcd_stepcode, mcd_stepname order by mcd_detno asc) A");
  123. sql.Append(" ON (makecraftdetail.MCD_MACODE = A.MCD_MACODE and makecraftdetail.mcd_stepcode = A.mcd_stepcode) ");
  124. sql.Append(" WHEN MATCHED THEN UPDATE SET makecraftdetail.mcd_inqty = A.inqty,makecraftdetail.mcd_outqty = A.inqty,makecraftdetail.mcd_okqty = A.inqty ");
  125. dh.ExecuteSql(sql.GetString(), "update");
  126. }
  127. }
  128. private void bigboxBtn_Click(object sender, EventArgs e)
  129. {
  130. if (((RadioButton)sender).Checked == true)
  131. {
  132. if (WeighRecord.Items.Count > 0)
  133. {
  134. string logout_confirm = MessageBox.Show(this.ParentForm, "是否更换采集项(已录入信息会清空)?", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
  135. if (logout_confirm == "Yes")
  136. {
  137. WeighRecord.Items.Clear();
  138. sb.Clear();
  139. ms_makecode.Text = "";
  140. ms_prodcode.Text = "";
  141. cr_code.Text = "";
  142. cd_stepcode.Text = "";
  143. }
  144. else
  145. {
  146. serBtn.Checked = bigboxBtn.Checked;
  147. bigboxBtn.Checked = !serBtn.Checked;
  148. }
  149. }
  150. if (((RadioButton)sender).Name == "serBtn")
  151. {
  152. input.Focus();
  153. OperatResult.AppendText("请输入序列号进行采集\n", Color.Black, input);
  154. }
  155. else if (((RadioButton)sender).Name == "bigboxBtn")
  156. {
  157. input.Focus();
  158. OperatResult.AppendText("请输入箱号进行采集\n", Color.Black, input);
  159. }
  160. }
  161. }
  162. private void cr_code_TextChanged(object sender, EventArgs e)
  163. {
  164. cd_stepcode.Condition = "ST_STATUSCODE='AUDITED' and cr_code='" + cr_code.Text + "' and cr_prodcode='" + ms_prodcode.Text + "' order by cd_stepno";
  165. }
  166. private void input_KeyDown(object sender, KeyEventArgs e)
  167. {
  168. if (e.KeyCode == Keys.Enter)
  169. {
  170. if (serBtn.Checked)
  171. {
  172. dt = (DataTable)dh.ExecuteSql("select ms_sncode from makeserial where ms_imei1='" + input.Text + "' order by ms_id desc", "select");
  173. if (dt.Rows.Count > 0)
  174. {
  175. input.Text = dt.Rows[0]["ms_sncode"].ToString();
  176. }
  177. else
  178. {
  179. dt = (DataTable)dh.ExecuteSql("select ms_sncode from makeserial where ms_imei2='" + input.Text + "' order by ms_id desc", "select");
  180. if (dt.Rows.Count > 0)
  181. {
  182. input.Text = dt.Rows[0]["ms_sncode"].ToString();
  183. }
  184. else
  185. {
  186. dt = (DataTable)dh.ExecuteSql("select mil_sncode from makeimeilist where mil_imei1='" + input.Text + "' order by mil_id desc", "select");
  187. if (dt.Rows.Count > 0)
  188. {
  189. input.Text = dt.Rows[0]["mil_sncode"].ToString();
  190. }
  191. else
  192. {
  193. dt = (DataTable)dh.ExecuteSql("select mil_sncode from makeimeilist where mil_imei2='" + input.Text + "' order by mil_id desc", "select");
  194. if (dt.Rows.Count > 0)
  195. {
  196. input.Text = dt.Rows[0]["mil_sncode"].ToString();
  197. }
  198. }
  199. }
  200. }
  201. dt = (DataTable)dh.ExecuteSql("select ms_makecode,ms_prodcode,ms_sncode,ms_craftcode cr_code,ms_status,ms_outboxcode from makeserial where ms_sncode = '" + input.Text + "' or ms_imei1='" + input.Text + "' or ms_imei2='" + input.Text + "' order by ms_id desc", "select");
  202. if (dt.Rows.Count > 0)
  203. {
  204. input.Text = dt.Rows[0]["ms_sncode"].ToString();
  205. if (ms_makecode.Text != "" && dt.Rows[0]["ms_makecode"].ToString() != ms_makecode.Text)
  206. {
  207. OperatResult.AppendText("SN:" + input.Text + "所属工单" + dt.Rows[0]["ms_makecode"].ToString() + "与当前工单" + ms_makecode.Text + "不一致\n", Color.Red, input);
  208. return;
  209. }
  210. if (dt.Rows[0]["ms_status"].ToString() == "3")
  211. {
  212. OperatResult.AppendText("SN:" + input.Text + "为不良品,不允许采集\n", Color.Red, input);
  213. return;
  214. }
  215. if (dt.Rows[0]["ms_outboxcode"].ToString() != "")
  216. {
  217. OperatResult.AppendText("SN:" + input.Text + "已装箱" + dt.Rows[0]["ms_outboxcode"].ToString() + ",不允许采集\n", Color.Red, input);
  218. return;
  219. }
  220. BaseUtil.SetFormValue(this.Controls, dt);
  221. if (sb.Contains(dt.Rows[0]["ms_sncode"].ToString()))
  222. {
  223. OperatResult.AppendText("SN:" + input.Text + "已采集\n", Color.Red, input);
  224. return;
  225. }
  226. WeighRecord.Items.Add(dt.Rows[0]["ms_sncode"].ToString());
  227. sb.Add(dt.Rows[0]["ms_sncode"].ToString());
  228. OperatResult.AppendText("SN:" + input.Text + "采集\n", Color.Green, input);
  229. cd_stepcode.Condition = "ST_STATUSCODE='AUDITED' and cr_code='" + cr_code.Text + "' and cr_prodcode='" + ms_prodcode.Text + "' order by cd_stepno";
  230. }
  231. else
  232. {
  233. OperatResult.AppendText("SN:" + input.Text + "不存在\n", Color.Red, input);
  234. return;
  235. }
  236. }
  237. else if (bigboxBtn.Checked)
  238. {
  239. dt = (DataTable)dh.ExecuteSql("select pa_makecode ms_makecode,pa_prodcode ms_prodcode,pa_outboxcode,pa_mothercode,ma_craftcode,nvl(pa_iostatus,0)pa_iostatus,ma_craftcode cr_code from package left join make on pa_makecode = ma_code where pa_outboxcode = '" + input.Text + "' and pa_type = '1'", "select");
  240. if (dt.Rows.Count > 0)
  241. {
  242. if (ms_makecode.Text != "" && dt.Rows[0]["ms_makecode"].ToString() != ms_makecode.Text)
  243. {
  244. OperatResult.AppendText("SN:" + input.Text + "所属工单" + dt.Rows[0]["ms_makecode"].ToString() + "与当前工单" + ms_makecode.Text + "不一致\n", Color.Red, input);
  245. return;
  246. }
  247. if (dt.Rows[0]["pa_iostatus"].ToString() != "0")
  248. {
  249. OperatResult.AppendText("卡通箱:" + input.Text + "处于状态入库状态,不允许采集\n", Color.Red, input);
  250. return;
  251. }
  252. if (dt.Rows[0]["pa_mothercode"].ToString() != "")
  253. {
  254. OperatResult.AppendText("卡通箱:" + input.Text + "已装栈板" + dt.Rows[0]["pa_mothercode"].ToString() + ",不允许采集\n", Color.Red, input);
  255. return;
  256. }
  257. BaseUtil.SetFormValue(this.Controls, dt);
  258. if (sb.Contains(dt.Rows[0]["pa_outboxcode"].ToString()))
  259. {
  260. OperatResult.AppendText("卡通箱:" + input.Text + "已采集\n", Color.Red, input);
  261. return;
  262. }
  263. WeighRecord.Items.Add(dt.Rows[0]["pa_outboxcode"].ToString());
  264. sb.Add(dt.Rows[0]["pa_outboxcode"].ToString());
  265. OperatResult.AppendText("卡通箱:" + input.Text + "采集\n", Color.Green, input);
  266. cd_stepcode.Condition = "ST_STATUSCODE='AUDITED' and cr_code='" + cr_code.Text + "' and cr_prodcode='" + ms_prodcode.Text + "' order by cd_stepno";
  267. }
  268. else
  269. {
  270. OperatResult.AppendText("卡通箱:" + input.Text + "不存在\n", Color.Red, input);
  271. return;
  272. }
  273. }
  274. }
  275. }
  276. private void 数据清空_Click(object sender, EventArgs e)
  277. {
  278. BaseUtil.CleanControls(this.Controls);
  279. WeighRecord.Items.Clear();
  280. sb.Clear();
  281. }
  282. private void Special_Reset_SizeChanged(object sender, EventArgs e)
  283. {
  284. asc.controlAutoSize(this);
  285. }
  286. private void Export_Click(object sender, EventArgs e)
  287. {
  288. ExportFileDialog.Description = "选择导出的路径";
  289. DialogResult result = ExportFileDialog.ShowDialog();
  290. if (result == DialogResult.OK)
  291. {
  292. ExcelHandler eh = new ExcelHandler();
  293. sql.Clear();
  294. sql.Append("select ''箱号,'' SN from dual ");
  295. dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
  296. eh.ExportExcel(dt, ExportFileDialog.SelectedPath + "\\导出模板.xls");
  297. //string close = MessageBox.Show(this.ParentForm, "导出成功,是否打开文件", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
  298. }
  299. }
  300. private void ImportExcel_Click(object sender, EventArgs e)
  301. {
  302. ImportExcel1.Filter = "(*.xls)|*.xls";
  303. DialogResult result;
  304. result = ImportExcel1.ShowDialog();
  305. if (result == DialogResult.OK)
  306. {
  307. DataTable dt = ExcelToDataTable(ImportExcel1.FileName, true);
  308. for (int i = 0; i < dt.Rows.Count; i++)
  309. {
  310. if (bigboxBtn.Checked)
  311. {
  312. input.Text = dt.Rows[i]["箱号"].ToString();
  313. input_KeyDown(sender, new KeyEventArgs(Keys.Enter));
  314. }
  315. if (serBtn.Checked)
  316. {
  317. input.Text = dt.Rows[i]["SN"].ToString();
  318. input_KeyDown(sender, new KeyEventArgs(Keys.Enter));
  319. }
  320. }
  321. }
  322. }
  323. public static DataTable ExcelToDataTable(string filePath, bool isColumnName)
  324. {
  325. DataTable dataTable = null;
  326. FileStream fs = null;
  327. DataColumn column = null;
  328. DataRow dataRow = null;
  329. IWorkbook workbook = null;
  330. ISheet sheet = null;
  331. IRow row = null;
  332. ICell cell = null;
  333. int startRow = 0;
  334. try
  335. {
  336. using (fs = File.OpenRead(filePath))
  337. {
  338. // 2007版本
  339. workbook = new HSSFWorkbook(fs);
  340. if (workbook != null)
  341. {
  342. sheet = workbook.GetSheetAt(0);//读取第一个sheet,当然也可以循环读取每个sheet
  343. dataTable = new DataTable();
  344. if (sheet != null)
  345. {
  346. int rowCount = sheet.LastRowNum;//总行数
  347. if (rowCount > 0)
  348. {
  349. IRow firstRow = sheet.GetRow(0);//第一行
  350. int cellCount = firstRow.LastCellNum;//列数
  351. //构建datatable的列
  352. if (isColumnName)
  353. {
  354. startRow = 1;//如果第一行是列名,则从第二行开始读取
  355. for (int i = firstRow.FirstCellNum; i < cellCount; ++i)
  356. {
  357. cell = firstRow.GetCell(i);
  358. if (cell != null)
  359. {
  360. if (cell.StringCellValue != null)
  361. {
  362. column = new DataColumn(cell.StringCellValue);
  363. dataTable.Columns.Add(column);
  364. }
  365. }
  366. }
  367. }
  368. else
  369. {
  370. for (int i = firstRow.FirstCellNum; i < cellCount; ++i)
  371. {
  372. column = new DataColumn("column" + (i + 1));
  373. dataTable.Columns.Add(column);
  374. }
  375. }
  376. //填充行
  377. for (int i = startRow; i <= rowCount; ++i)
  378. {
  379. row = sheet.GetRow(i);
  380. if (row == null) continue;
  381. dataRow = dataTable.NewRow();
  382. for (int j = row.FirstCellNum; j < cellCount; ++j)
  383. {
  384. cell = row.GetCell(j);
  385. if (cell == null)
  386. {
  387. dataRow[j] = "";
  388. }
  389. else
  390. {
  391. //CellType(Unknown = -1,Numeric = 0,String = 1,Formula = 2,Blank = 3,Boolean = 4,Error = 5,)
  392. switch (cell.CellType)
  393. {
  394. case CellType.BLANK:
  395. dataRow[j] = "";
  396. break;
  397. case CellType.NUMERIC:
  398. short format = cell.CellStyle.DataFormat;
  399. //对时间格式(2015.12.5、2015/12/5、2015-12-5等)的处理
  400. if (format == 14 || format == 31 || format == 57 || format == 58)
  401. dataRow[j] = cell.DateCellValue;
  402. else
  403. dataRow[j] = cell.NumericCellValue;
  404. break;
  405. case CellType.STRING:
  406. dataRow[j] = cell.StringCellValue;
  407. break;
  408. case CellType.FORMULA:
  409. dataRow[j] = cell.StringCellValue;
  410. break;
  411. }
  412. }
  413. }
  414. dataTable.Rows.Add(dataRow);
  415. }
  416. }
  417. }
  418. }
  419. }
  420. return dataTable;
  421. }
  422. catch (Exception ex)
  423. {
  424. Console.WriteLine(ex.Message);
  425. if (fs != null)
  426. {
  427. fs.Close();
  428. }
  429. return null;
  430. }
  431. }
  432. }
  433. }