Make_ParseLog.cs 64 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441
  1. using BarTender;
  2. using DevExpress.Utils.OAuth.Provider;
  3. using DevExpress.Xpo.Logger;
  4. using DevExpress.XtraEditors.Controls;
  5. using DevExpress.XtraExport;
  6. using DevExpress.XtraPrinting;
  7. using NPOI.SS.Formula.Functions;
  8. using System;
  9. using System.Collections.Generic;
  10. using System.ComponentModel;
  11. using System.Data;
  12. using System.Drawing;
  13. using System.IO;
  14. using System.Linq;
  15. using System.Net;
  16. using System.Security;
  17. using System.Security.AccessControl;
  18. using System.Security.Principal;
  19. using System.Text;
  20. using System.Threading.Tasks;
  21. using System.Web.Services.Description;
  22. using System.Web.UI.WebControls;
  23. using System.Windows.Forms;
  24. using System.Xml;
  25. using UAS_MES_NEW.CustomControl.ButtonUtil;
  26. using UAS_MES_NEW.CustomControl.TextBoxWithIcon;
  27. using UAS_MES_NEW.DataOperate;
  28. using UAS_MES_NEW.Entity;
  29. using UAS_MES_NEW.PublicMethod;
  30. using static DevExpress.Xpo.DB.DataStoreLongrunnersWatch;
  31. using static System.Windows.Forms.VisualStyles.VisualStyleElement.Tab;
  32. namespace UAS_MES_NEW.Make
  33. {
  34. public partial class Make_ParseLog : Form
  35. {
  36. public Make_ParseLog()
  37. {
  38. InitializeComponent();
  39. }
  40. FileSystemWatcher watcher;
  41. LogStringBuilder sql = new LogStringBuilder();
  42. DataTable Dbfind;
  43. DataTable dt;
  44. DataHelper dh;
  45. string currFileType = "",equiType = "";
  46. string SN, omakeCode, oMsid, oErrorMessage = "";
  47. List<string> fileList = new List<string>();
  48. Timer formsTimer;
  49. string outXmlFilePath;
  50. private void Make_ParseLog_Load(object sender, EventArgs e)
  51. {
  52. dh = SystemInf.dh;
  53. fileList.Add("D:\\MES"); // 劲拓SPI
  54. fileList.Add("D:\\EYSPI\\DataExport\\Res"); // 思泰克SPI
  55. fileList.Add("E:\\MES_TEXT_PATH"); // AOI
  56. fileList.Add("C:\\GKGPrintTemp"); // GKG印刷机
  57. fileList.Add(""); // 贴片机
  58. fileList.Add("D:\\JANETSSC\\SMT\\MachineMonitoring"); // JUKI贴片机
  59. formsTimer = new Timer();
  60. formsTimer.Interval = 10000;
  61. formsTimer.Tick += timer1_Tick;
  62. //outXmlFilePath = "C:\\Users\\MI\\Desktop\\贴片机\\outLogs";
  63. outXmlFilePath = "D:\\JANETSSR";
  64. watcher = new FileSystemWatcher();
  65. watcher.NotifyFilter = NotifyFilters.FileName | NotifyFilters.LastWrite;
  66. watcher.Created += OnFileCreated;
  67. /*watcher.Changed += OnFileChanged;
  68. watcher.Deleted += OnFileChanged;
  69. watcher.Renamed += OnFileChanged;*/
  70. //设置锁定工单
  71. LockMakeCode.GetMakeCodeCtl(ma_code);
  72. ma_code.SetLockCheckBox(LockMakeCode);
  73. //工单号放大镜配置
  74. ma_code.TableName = "make left join product on ma_prodcode=pr_code";
  75. ma_code.SelectField = "ma_code # 工单号,pr_code # 产品编号,pr_detail # 产品名称";
  76. ma_code.FormName = Name;
  77. ma_code.SetValueField = new string[] { "ma_code", "pr_code", "pr_detail" };
  78. ma_code.Condition = "ma_statuscode='STARTED'";
  79. ma_code.DbChange += Ma_code_DbChange;
  80. }
  81. private void Ma_code_DbChange(object sender, EventArgs e)
  82. {
  83. Dbfind = ma_code.ReturnData;
  84. BaseUtil.SetFormValue(this.Controls, Dbfind);
  85. //获取工单的其他信息
  86. sql.Clear();
  87. sql.Append("select ma_code,nvl(mcd_okqty,0) mcd_okqty,ma_prodcode as pr_code ,pr_detail,");
  88. sql.Append("pr_spec,ma_qty - nvl(mcd_inqty, 0) mcd_remainqty from make left join makecraftdetail on ");
  89. sql.Append("mcd_maid=ma_id left join product on pr_code=ma_prodcode where ma_code='" + ma_code.Text + "' and mcd_stepcode='" + User.CurrentStepCode + "'");
  90. dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
  91. if (dt.Rows.Count > 0)
  92. {
  93. BaseUtil.SetFormValue(this.Controls, dt);
  94. }
  95. }
  96. private void Device_SelectedIndexChanged(object sender, EventArgs e)
  97. {
  98. if (Device.SelectedIndex == -1) return;
  99. switch (Device.SelectedIndex)
  100. {
  101. case 0:
  102. currFileType = "txt";
  103. equiType = "SPI";
  104. break;
  105. case 1:
  106. currFileType = "csv";
  107. equiType = "SPI";
  108. break;
  109. case 2:
  110. currFileType = "txt";
  111. equiType = "AOI";
  112. break;
  113. case 3:
  114. currFileType = "csv";
  115. equiType = "印刷机";
  116. break;
  117. case 4:
  118. currFileType = "xml";
  119. equiType = "贴片机";
  120. break;
  121. case 5:
  122. currFileType = "xml";
  123. equiType = "贴片机";
  124. break;
  125. }
  126. if (Device.SelectedIndex == 4 || Device.SelectedIndex == 2 || Device.SelectedIndex == 5)
  127. {
  128. txtPath.Text = fileList[Device.SelectedIndex];
  129. ma_code.Text = "";
  130. ma_code.Enabled = false;
  131. txtPath.Focus();
  132. txtPath.SelectAll();
  133. return;
  134. }
  135. if (string.IsNullOrEmpty(ma_code.Text))
  136. {
  137. Device.SelectedIndex = -1;
  138. txtPath.Text = "";
  139. MessageBox.Show(this.ParentForm, "请选择工单", "提示");
  140. return;
  141. }
  142. txtPath.Text = fileList[Device.SelectedIndex];
  143. txtPath.Focus();
  144. txtPath.SelectAll();
  145. ma_code.Enabled = true;
  146. txtPath.Enabled = false;
  147. }
  148. private void Choose_Click(object sender, EventArgs e)
  149. {
  150. FolderBrowserDialog dialog = new FolderBrowserDialog();
  151. switch (Device.SelectedIndex)
  152. {
  153. case 0:
  154. dialog.Description = "请选择读取劲拓SPI设备文件夹";
  155. currFileType = "txt";
  156. equiType = "SPI";
  157. break;
  158. case 1:
  159. dialog.Description = "请选择读取思泰克SPI设备文件夹";
  160. currFileType = "csv";
  161. equiType = "SPI";
  162. break;
  163. case 2:
  164. dialog.Description = "请选择读取AOI设备文本文件";
  165. currFileType = "txt";
  166. equiType = "AOI";
  167. break;
  168. case 3:
  169. dialog.Description = "请选择读取印刷机设备的文本文件夹";
  170. currFileType = "csv";
  171. equiType = "印刷机";
  172. break;
  173. case 4:
  174. dialog.Description = "请选择读取贴片机的文本文件夹";
  175. currFileType = "xml";
  176. equiType = "贴片机";
  177. break;
  178. case 5:
  179. dialog.Description = "请选择读取JUKI贴片机的文本文件夹";
  180. currFileType = "xml";
  181. equiType = "贴片机";
  182. break;
  183. }
  184. if (dialog.ShowDialog() == DialogResult.OK)
  185. {
  186. txtPath.Text = dialog.SelectedPath;
  187. txtPath.Enabled = false;
  188. Device.Enabled = false;
  189. watcher.EnableRaisingEvents = false;
  190. }
  191. }
  192. private void claerBtn_Click(object sender, EventArgs e)
  193. {
  194. lstFiles.Items.Clear();
  195. }
  196. private void allParse_Click(object sender, EventArgs e)
  197. {
  198. if (Device.SelectedIndex == 0 || Device.SelectedIndex == 1 || Device.SelectedIndex == 3)
  199. {
  200. if (string.IsNullOrEmpty(ma_code.Text))
  201. {
  202. MessageBox.Show(this.ParentForm, "请选择工单", "提示");
  203. return;
  204. }
  205. }
  206. if (Device.SelectedIndex == -1)
  207. {
  208. Device.Focus();
  209. Device.SelectAll();
  210. MessageBox.Show(this.ParentForm, "请选择设备", "提示");
  211. return;
  212. }
  213. if (String.IsNullOrEmpty(txtPath.Text))
  214. {
  215. txtPath.Focus();
  216. txtPath.SelectAll();
  217. return;
  218. }
  219. string[] txtFiles = Directory.GetFiles(txtPath.Text, $"*.{currFileType}");
  220. if (txtFiles.Length == 0)
  221. {
  222. LogMessage($"当前{txtPath.Text},没有{equiType}设备{currFileType.ToUpper()}文件");
  223. return;
  224. }
  225. RefreshFileList();
  226. }
  227. private void onWatch_Click(object sender, EventArgs e)
  228. {
  229. if (Device.SelectedIndex == 0 || Device.SelectedIndex == 1 || Device.SelectedIndex == 3)
  230. {
  231. if (string.IsNullOrEmpty(ma_code.Text))
  232. {
  233. MessageBox.Show(this.ParentForm, "请选择工单", "提示");
  234. return;
  235. }
  236. }
  237. if (Device.SelectedIndex == -1)
  238. {
  239. Device.Focus();
  240. Device.SelectAll();
  241. MessageBox.Show(this.ParentForm, "请选择设备", "提示");
  242. return;
  243. }
  244. if (String.IsNullOrEmpty(txtPath.Text))
  245. {
  246. txtPath.Focus();
  247. txtPath.SelectAll();
  248. return;
  249. }
  250. try
  251. {
  252. #region
  253. /* 识别文件类型
  254. var txtFiles = Directory.GetFiles(txtPath.Text, "*.txt");
  255. var csvFiles = Directory.GetFiles(txtPath.Text, "*.csv");
  256. currFileType = txtFiles.Length > csvFiles.Length ? "txt" : "csv";
  257. watcher.Filter = $"*.{currFileType}";*/
  258. #endregion
  259. watcher.Path = txtPath.Text;
  260. watcher.Filter = $"*.{currFileType}";
  261. if (onWatch.Text == "开启解析")
  262. {
  263. watcher.EnableRaisingEvents = true;
  264. onWatch.Text = "关闭解析";
  265. if (Device.SelectedIndex == 5) // JUKI贴片机
  266. {
  267. formsTimer.Start();
  268. }
  269. }
  270. else
  271. {
  272. watcher.EnableRaisingEvents = false;
  273. //watcher.Dispose();
  274. onWatch.Text = "开启解析";
  275. formsTimer.Stop();
  276. }
  277. }
  278. catch (Exception ex)
  279. {
  280. MessageBox.Show(this.ParentForm, ex.Message, "警告");
  281. }
  282. }
  283. private void timer1_Tick(object sender, EventArgs e)
  284. {
  285. try
  286. {
  287. sql.Clear();
  288. sql.Append($@"SELECT dd_date,dd_name,dd_status,dd_id FROM devicedata WHERE dd_status = 0");
  289. dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
  290. if (dt.Rows.Count > 0)
  291. {
  292. string currentDate = DateTime.Now.ToString("yyyyMMddHHmmss");
  293. XmlWriterSettings settings = new XmlWriterSettings
  294. {
  295. Indent = true,
  296. Encoding = System.Text.Encoding.UTF8
  297. };
  298. foreach (DataRow dr in dt.Rows)
  299. {
  300. var hasFileAry = Directory.GetFiles(outXmlFilePath, $"*.{currFileType}");
  301. string xmlName;
  302. if (hasFileAry.Length > 0)
  303. {
  304. var lastFile = Directory.GetFiles(outXmlFilePath).Select(f => new FileInfo(f))
  305. .Where(f => f.CreationTime.Date == DateTime.Today)
  306. .OrderByDescending(f => f.CreationTime).FirstOrDefault().Name;
  307. string seqNumStr = lastFile.Substring(lastFile.Length - 7, 3);
  308. string fileSeqNum = (int.Parse(seqNumStr) + 1).ToString().PadLeft(seqNumStr.Length, '0'); ;
  309. xmlName = $"1.08_{currentDate}_{currentDate}{fileSeqNum}.xml";
  310. }
  311. else
  312. {
  313. xmlName = $"1.08_{currentDate}_{currentDate}001.xml";
  314. }
  315. string fullPath = Path.Combine(outXmlFilePath, xmlName);
  316. using (XmlWriter writer = XmlWriter.Create(fullPath, settings))
  317. {
  318. writer.WriteStartDocument();
  319. writer.WriteStartElement("RequestTotalProductionInfo");
  320. writer.WriteAttributeString("MachineName", dr["dd_name"].ToString());
  321. writer.WriteEndElement();
  322. writer.WriteEndDocument();
  323. }
  324. if (File.Exists(fullPath))
  325. {
  326. File.ReadAllText(fullPath);
  327. }
  328. sql.Clear();
  329. sql.Append($"UPDATE devicedata SET dd_status = -1 WHERE dd_name = '{dr["dd_name"].ToString()}'");
  330. dh.ExecuteSql(sql.GetString(), "update");
  331. }
  332. }
  333. }
  334. catch (Exception ex)
  335. {
  336. MessageBox.Show(this.ParentForm, ex.Message, "警告");
  337. }
  338. }
  339. private void OnFileCreated(object sender, FileSystemEventArgs e)
  340. {
  341. RefreshFileList();
  342. }
  343. private void OnFileChanged(object sender, FileSystemEventArgs e)
  344. {
  345. if (e.ChangeType == WatcherChangeTypes.Changed)
  346. {
  347. RefreshFileList();
  348. }
  349. }
  350. private void RefreshFileList()
  351. {
  352. if (lstFiles.InvokeRequired)
  353. {
  354. lstFiles.Invoke(new Action(RefreshFileList));
  355. lstFiles.BeginInvoke(new Action(RefreshFileList));
  356. return;
  357. }
  358. try
  359. {
  360. if (!Directory.Exists(txtPath.Text))
  361. {
  362. LogMessage($"目录不存在: {txtPath.Text}");
  363. return;
  364. }
  365. string[] txtFiles = Directory.GetFiles(txtPath.Text, $"*.{currFileType}");
  366. if (txtFiles.Length == 0)
  367. {
  368. return;
  369. }
  370. else
  371. {
  372. foreach (string file in txtFiles)
  373. {
  374. if (!File.Exists(file))
  375. {
  376. LogMessage($"文件不存在: {file}");
  377. }
  378. if (Device.SelectedIndex == 0) // 劲拓SPI
  379. {
  380. ParseLogInsert(file);
  381. }
  382. else if (Device.SelectedIndex == 1) // 思泰克SPI
  383. {
  384. string fileName = Path.GetFileName(file);
  385. string[] lines = File.ReadAllLines(file, Encoding.GetEncoding("GB2312"));
  386. //string modelName = lines[1].Split(',')[0];
  387. //string lineNumber = lines[1].Split(',')[1];
  388. //string boardStatus = lines[2].Split(',')[1];
  389. SN = lines[4].Split(',')[16];
  390. if (string.IsNullOrEmpty(SN))
  391. {
  392. LogMessage($"文件: {file},无SN信息");
  393. continue;
  394. }
  395. LogMessage($"文件: {file},开始上传");
  396. if (UploadFileToFtp(file))
  397. {
  398. dh.ExecuteSql($@"insert into STEPTESTDETAIL (std_id,std_sn,std_makecode,std_indate,std_class,std_testresult)
  399. select STEPTESTDETAIL_seq.nextval,'{SN}','{ma_code.Text}',sysdate,'思泰克SPI',
  400. 'http://112.48.67.154:8088/ftp/mes/TestData/{DateTime.Now.ToString("yyyyMMdd")}/{Path.GetFileName(file)}.xml' from dual", "insert");
  401. string xmlContent = File.ReadAllText(file);
  402. if (ConsoleLog(xmlContent, file))
  403. {
  404. File.Delete(file);
  405. }
  406. }
  407. /*if (LogicHandler.CheckStepSNAndMacode(ma_code.Text, User.UserSourceCode, SN, User.UserCode, out omakeCode, out oMsid, out oErrorMessage))
  408. {
  409. if (LogicHandler.SetStepResult(omakeCode, User.UserSourceCode, SN, "日志解析", "OK", User.UserCode, out oErrorMessage))
  410. {
  411. }
  412. else
  413. {
  414. LogMessage(">>" + oErrorMessage + "\n");
  415. }
  416. }
  417. else
  418. {
  419. LogMessage(">>" + oErrorMessage + "\n");
  420. }*/
  421. #region // 20250630 M 调整对接方式
  422. /*List<SpiData> csvData;
  423. //csvData = ParseCsvFile(file);
  424. csvData = ParseCsvFile<SpiData>(file, MapToSpiData);
  425. List<string> Barcode = new List<string>();
  426. List<string> Date = new List<string>();
  427. List<string> AreaPercent = new List<string>();
  428. List<string> Height = new List<string>();
  429. List<string> VolumePercent = new List<string>();
  430. List<string> XOffset = new List<string>();
  431. List<string> YOffset = new List<string>();
  432. List<string> PadSizeX = new List<string>();
  433. List<string> PadSizeY = new List<string>();
  434. List<string> Area = new List<string>();
  435. List<string> HeightPercent = new List<string>();
  436. List<string> Volume = new List<string>();
  437. List<string> Result = new List<string>();
  438. foreach (var item in csvData)
  439. {
  440. Barcode.Add(item.Barcode);
  441. Date.Add(item.Date);
  442. Result.Add(item.Result);
  443. AreaPercent.Add(item.AreaPercent);
  444. Height.Add(item.Height);
  445. VolumePercent.Add(item.VolumePercent);
  446. XOffset.Add(item.XOffset);
  447. YOffset.Add(item.YOffset);
  448. PadSizeX.Add(item.PadSizeX);
  449. PadSizeY.Add(item.PadSizeY);
  450. Area.Add(item.Area);
  451. HeightPercent.Add(item.HeightPercent);
  452. Volume.Add(item.Volume);
  453. }
  454. if (csvData.Count == 0)
  455. {
  456. LogMessage($"文件: {file},读取记录 {csvData.Count} 条");
  457. return;
  458. }
  459. sql.Clear();
  460. sql.Append($@"INSERT INTO steptestdetail (std_id,std_sn,std_makecode,
  461. std_testresult,std_class,std_actualvalue,
  462. std_rescode,STD_SUBCLASS1,STD_VALUE1,
  463. STD_VALUE2,STD_VALUE3,STD_VALUE4,
  464. STD_VALUE5,STD_VALUE6,STD_VALUE7,
  465. STD_VALUE8,STD_VALUE9,STD_VALUE10)
  466. (select steptestdetail_seq.nextval,:Barcode,'{ma_code.Text}',
  467. :Result,'{equiType}','notfound',
  468. '{User.UserSourceCode}','{equiType}',:AreaPercent,
  469. :Height,:VolumePercent,:XOffset,
  470. :YOffset,:PadSizeX,:PadSizeY,
  471. :Area,:HeightPercent,:Volume from dual)");
  472. dh.BatchInsert(sql.GetString(),
  473. new string[] { "Barcode", "Result", "AreaPercent",
  474. "Height" ,"VolumePercent","XOffset",
  475. "YOffset","PadSizeX","PadSizeY",
  476. "Area","HeightPercent","Volume"},
  477. Barcode.ToArray(), Result.ToArray(), AreaPercent.ToArray(),
  478. Height.ToArray(), VolumePercent.ToArray(), XOffset.ToArray(),
  479. YOffset.ToArray(), PadSizeX.ToArray(), PadSizeY.ToArray(),
  480. Area.ToArray(), HeightPercent.ToArray(), Volume.ToArray());
  481. LogMessage($"文件: {file},共{csvData.Count}条记录,已解析");
  482. string xmlContent = File.ReadAllText(file);
  483. if (ConsoleLog(xmlContent, file))
  484. {
  485. File.Delete(file);
  486. }*/
  487. #endregion
  488. }
  489. else if (Device.SelectedIndex == 2) // AOI
  490. {
  491. ParseLogInsert(file);
  492. }
  493. else if (Device.SelectedIndex == 3) // 印刷机 ?
  494. {
  495. List<PrintData> priMacData;
  496. priMacData = ParseCsvFile<PrintData>(file, MapToPriMacData);
  497. List<string> BarCode = new List<string>();
  498. List<string> TimeStamp = new List<string>();
  499. List<string> FileName = new List<string>();
  500. List<string> ProgramRunning = new List<string>();
  501. List<string> CycleTime = new List<string>();
  502. List<string> DSPIResult_2 = new List<string>();
  503. List<string> PrintSpeed = new List<string>();
  504. List<string> FrontSQGPress = new List<string>();
  505. List<string> RearSQGPress = new List<string>();
  506. List<string> PrintMode = new List<string>();
  507. List<string> SnapOffDistance = new List<string>();
  508. List<string> SnapOffSpeed = new List<string>();
  509. List<string> SnapOffDelay = new List<string>();
  510. List<string> SQGUpSpeed = new List<string>();
  511. List<string> SQGDownSpeed = new List<string>();
  512. List<string> SQGUpFirst = new List<string>();
  513. List<string> SQGHeightAtSnapOff = new List<string>();
  514. List<string> CleaningAfterLastBoard = new List<string>();
  515. List<string> CleaningFrequency = new List<string>();
  516. List<string> CleaningSpeed = new List<string>();
  517. List<string> CleaningType = new List<string>();
  518. List<string> AddSPMode = new List<string>();
  519. List<string> PrintDirection = new List<string>();
  520. List<string> PCBSize = new List<string>();
  521. List<string> TableUpX = new List<string>();
  522. List<string> TableUpY1 = new List<string>();
  523. List<string> TableUpY2 = new List<string>();
  524. foreach (var item in priMacData)
  525. {
  526. BarCode.Add(item.BarCode);
  527. TimeStamp.Add(item.TimeStamp);
  528. FileName.Add(item.FileName);
  529. ProgramRunning.Add(item.ProgramRunning);
  530. CycleTime.Add(item.CycleTime);
  531. DSPIResult_2.Add(item._2DSPIResult);
  532. PrintSpeed.Add(item.PrintSpeed);
  533. FrontSQGPress.Add(item.FrontSQGPress);
  534. RearSQGPress.Add(item.RearSQGPress);
  535. PrintMode.Add(item.PrintMode);
  536. SnapOffDistance.Add(item.SnapOffDistance);
  537. SnapOffSpeed.Add(item.SnapOffSpeed);
  538. SnapOffDelay.Add(item.SnapOffDelay);
  539. SQGUpSpeed.Add(item.SQGUpSpeed);
  540. SQGDownSpeed.Add(item.SQGDownSpeed);
  541. SQGUpFirst.Add(item.SQGUpFirst);
  542. SQGHeightAtSnapOff.Add(item.SQGHeightAtSnapOff);
  543. CleaningAfterLastBoard.Add(item.CleaningAfterLastBoard);
  544. CleaningFrequency.Add(item.CleaningFrequency);
  545. CleaningSpeed.Add(item.CleaningSpeed);
  546. CleaningType.Add(item.CleaningType);
  547. AddSPMode.Add(item.AddSPMode);
  548. PrintDirection.Add(item.PrintDirection);
  549. PCBSize.Add(item.PCBSize);
  550. TableUpX.Add(item.TableUpX);
  551. TableUpY1.Add(item.TableUpY1);
  552. TableUpY2.Add(item.TableUpY2);
  553. }
  554. if (priMacData.Count == 0)
  555. {
  556. LogMessage($"文件: {file},读取记录 {priMacData.Count} 条");
  557. continue;
  558. }
  559. sql.Clear();
  560. sql.Append($@"INSERT INTO steptestdetail (std_id,std_sn,std_makecode,STD_TESTTIME,STD_CLASS,STD_SUBCLASS1,
  561. STD_SUBCLASS2,STD_SUBCLASS3,STD_VALUE1,STD_VALUE2,STD_VALUE3,STD_VALUE4,
  562. STD_VALUE5,STD_VALUE6,STD_VALUE7,STD_VALUE8,STD_VALUE9,
  563. STD_VALUE10,STD_VALUE11,std_value12,std_value13,std_value14,
  564. std_value15,std_value16,
  565. STD_TESTRESULT,std_value18,std_value19,std_value20,std_value21,
  566. std_rescode)
  567. (select steptestdetail_seq.nextval,:BarCode,'{ma_code.Text}',to_date(:TimeStamp,'yyyy-mm-dd hh24:mi:ss'),'印刷机',:ProgramRunning,
  568. :CycleTime,:DSPIResult2,:PrintSpeed,:FrontSQGPress,:RearSQGPress,:PrintMode,
  569. :SnapOffDistance,:SnapOffSpeed,:SnapOffDelay,:SQGUpSpeed,:SQGDownSpeed,
  570. :SQGUpFirst,:SQGHeightAtSnapOff,:CleaningAfterLastBoard,:CleaningFrequency,:CleaningSpeed,
  571. :CleaningType,:AddSPMode,
  572. :PrintDirection,:PCBSize,:TableUpX,:TableUpY1,:TableUpY2,
  573. '{User.UserSourceCode}' from dual)");
  574. dh.BatchInsert(sql.GetString(),
  575. new string[] { "BarCode", "TimeStamp","ProgramRunning",
  576. "CycleTime","DSPIResult_2","PrintSpeed","FrontSQGPress","RearSQGPress","PrintMode",
  577. "SnapOffDistance","SnapOffSpeed","SnapOffDelay","SQGUpSpeed","SQGDownSpeed",
  578. "SQGUpFirst","SQGHeightAtSnapOff","CleaningAfterLastBoard","CleaningFrequency","CleaningSpeed",
  579. "CleaningType","AddSPMode",
  580. "PrintDirection","PCBSize","TableUpX","TableUpY1","TableUpY2"},
  581. BarCode.ToArray(), TimeStamp.ToArray(), ProgramRunning.ToArray(),
  582. CycleTime.ToArray(), DSPIResult_2.ToArray(), PrintSpeed.ToArray(), FrontSQGPress.ToArray(), RearSQGPress.ToArray(), PrintMode.ToArray(),
  583. SnapOffDistance.ToArray(), SnapOffSpeed.ToArray(), SnapOffDelay.ToArray(), SQGUpSpeed.ToArray(), SQGDownSpeed.ToArray(),
  584. SQGUpFirst.ToArray(), SQGHeightAtSnapOff.ToArray(), CleaningAfterLastBoard.ToArray(), CleaningFrequency.ToArray(), CleaningSpeed.ToArray(),
  585. CleaningType.ToArray(), AddSPMode.ToArray(),
  586. PrintDirection.ToArray(), PCBSize.ToArray(), TableUpX.ToArray(), TableUpY1.ToArray(), TableUpY2.ToArray());
  587. LogMessage($"文件: {file},共{priMacData.Count}条记录,已解析");
  588. string xmlContent = File.ReadAllText(file);
  589. if (ConsoleLog(xmlContent, file))
  590. {
  591. File.Delete(file);
  592. }
  593. }
  594. else if (Device.SelectedIndex == 4 || Device.SelectedIndex == 5) // 贴片机
  595. {
  596. if (Device.SelectedIndex == 5 && !file.Contains("TotalProduction"))
  597. {
  598. continue;
  599. }
  600. string xmlContent = File.ReadAllText(file);
  601. var xmlList = ParseXml(xmlContent);
  602. if (xmlList.Count == 0)
  603. {
  604. LogMessage($"文件: {file},读取记录 {xmlList.Count} 条");
  605. continue;
  606. }
  607. List<string> param = new List<string>() { };
  608. string PS_CODE = "";
  609. LogicHandler.GetSerialNumByCaller("Make!ParseLog", out PS_CODE);
  610. List<string> MachineName = new List<string>();
  611. List<string> Part = new List<string>();
  612. List<string> Station = new List<string>();
  613. List<string> ReelNo = new List<string>();
  614. List<string> letNo = new List<string>();
  615. string Part_ = "";
  616. int letNoNum = 0;
  617. foreach (var item in xmlList)
  618. {
  619. MachineName.Add(item.MachineName);
  620. Part_ = item.Part.Split('.')[0];
  621. Station.Add(item.Station);
  622. ReelNo.Add(item.ReelNo);
  623. letNo.Add((++letNoNum).ToString());
  624. }
  625. string ps_id = "";
  626. string lineId = dh.getFieldDataByCondition("smtlocationinto", "SLI_LANE", "SLI_MCNO='" + MachineName[0] + "'").ToString();
  627. if (!dh.CheckExist("productsmt", "ps_prodcode='" + Part_ + "'"))
  628. {
  629. ps_id = dh.GetSEQ("productsmt_seq");
  630. dh.ExecuteSql("insert into productsmt(ps_id,ps_prodcode,ps_status,ps_statuscode,PS_LINECODE,PS_CODE)" +
  631. "values('" + ps_id + "','" + Part_ + "','在录入','ENTERING','" + lineId + "','" + PS_CODE + "')", "insert");
  632. }
  633. else
  634. {
  635. ps_id = dh.getFieldDataByCondition("productsmt", "ps_id", "ps_prodcode='" + Part_ + "'").ToString();
  636. }
  637. if (dh.getRowCount("productsmtlocation", "PSL_PSID=" + ps_id) > 0)
  638. {
  639. dh.ExecuteSql("delete from productsmtlocation where PSL_PSID" + ps_id, "delete");
  640. }
  641. sql.Clear();
  642. sql.Append("insert into productsmtlocation(PSL_ID, PSL_PSID, PSL_DETNO, PSL_PRODCODE, PSL_REPCODE, PSL_LOCATION, PSL_BASEQTY, PSL_TABLE)" +
  643. "select productsmtlocation_seq.nextval," + ps_id + ",:letArr, :ReelNo,:ReelNo,:Station,BD_BASEQTY,'A' from bom@ERP " +
  644. "left join bomdetail@ERP on bo_id=bd_bomid where bo_mothercode='" + Part_ + "' and BD_SONCODE=:ReelNo");
  645. dh.BatchInsert(sql.GetString(), new string[] { "letArr", "ReelNo", "ReelNo", "Station", "ReelNo" },
  646. letNo.ToArray(), ReelNo.ToArray(), ReelNo.ToArray(), Station.ToArray(), ReelNo.ToArray());
  647. LogMessage($"文件: {file},已解析生成站位表");
  648. if (ConsoleLog(xmlContent, file))
  649. {
  650. File.Delete(file);
  651. }
  652. }
  653. }
  654. }
  655. }
  656. catch (Exception ex)
  657. {
  658. LogMessage($"Error: 解析文件列表失败: {ex.Message}");
  659. }
  660. }
  661. public bool UploadFileToFtp(string localFilePath)
  662. {
  663. string ftpServer = "ftp://10.8.0.208:21/mes/TestData/";
  664. string username = "vsftpd";
  665. string password = "vsftpd3cd79018fl";
  666. string currentDate = DateTime.Now.ToString("yyyyMMdd");
  667. string ftpFullPath = $"{ftpServer.TrimEnd('/')}/{currentDate}";
  668. string outResult = CreateFtpDirectoryIfNotExists(ftpFullPath, username, password);
  669. if (outResult.Substring(0, 2) == "NG")
  670. {
  671. LogMessage(outResult);
  672. return false;
  673. }
  674. string remoteFileName = Path.GetFileName(localFilePath);
  675. string uri = $"{ftpFullPath}/{remoteFileName}";
  676. try
  677. {
  678. var request = (FtpWebRequest)WebRequest.Create(uri);
  679. request.Method = WebRequestMethods.Ftp.UploadFile;
  680. request.Credentials = new NetworkCredential(username, password);
  681. request.UsePassive = true;
  682. request.UseBinary = true;
  683. request.KeepAlive = false;
  684. using (var fileStream = File.OpenRead(localFilePath))
  685. using (var requestStream = request.GetRequestStream())
  686. {
  687. byte[] buffer = new byte[4096];
  688. int bytesRead;
  689. while ((bytesRead = fileStream.Read(buffer, 0, buffer.Length)) > 0)
  690. {
  691. requestStream.Write(buffer, 0, bytesRead);
  692. }
  693. }
  694. using (var response = (FtpWebResponse)request.GetResponse())
  695. {
  696. LogMessage($"文件: {localFilePath}上传成功,状态{response.StatusDescription}");
  697. return true;
  698. }
  699. }
  700. catch (WebException ex)
  701. {
  702. if (ex.Response is FtpWebResponse response)
  703. {
  704. LogMessage($"FTP 错误码: {(int)response.StatusCode} - {response.StatusDescription}");
  705. }
  706. else
  707. {
  708. LogMessage("Web异常: " + ex.Message);
  709. }
  710. return false;
  711. }
  712. catch (Exception ex)
  713. {
  714. LogMessage($"上传失败: " + ex.Message);
  715. return false;
  716. }
  717. }
  718. private string CreateFtpDirectoryIfNotExists(string ftpDirectoryPath, string username, string password)
  719. {
  720. try
  721. {
  722. FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpDirectoryPath);
  723. request.Method = WebRequestMethods.Ftp.MakeDirectory;
  724. request.Credentials = new NetworkCredential(username, password);
  725. request.UsePassive = true;
  726. request.UseBinary = true;
  727. request.KeepAlive = false;
  728. using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
  729. {
  730. return "OK,目录创建成功: " + response.StatusDescription;
  731. }
  732. }
  733. catch (WebException ex)
  734. {
  735. if (ex.Response is FtpWebResponse response && response.StatusCode == FtpStatusCode.ActionNotTakenFileUnavailable)
  736. {
  737. return "OK,目录已存在: " + response.StatusDescription;
  738. }
  739. else
  740. {
  741. return "NG,创建目录时发生错误: " + ex.Message;
  742. }
  743. }
  744. }
  745. private void ParseLogInsert(string PathName)
  746. {
  747. try
  748. {
  749. StreamReader SR = File.OpenText(PathName);
  750. string restOfStream = SR.ReadToEnd();
  751. SR.Close();
  752. SR.Dispose();
  753. List<Log> logArr = new List<Log>() { };
  754. string[] lines = restOfStream.Split(new string[] { "\r\n" }, StringSplitOptions.None);
  755. int fileNum = string.IsNullOrEmpty(lines[lines.Length - 1]) ? lines.Length - 1 : lines.Length;
  756. foreach (var item in lines)
  757. {
  758. if (string.IsNullOrEmpty(item)) continue;
  759. string[] currItem = item.Split(',');
  760. string res = "",wo = "";
  761. if(equiType == "SPI")
  762. {
  763. res = currItem[1];
  764. wo = ma_code.Text;
  765. }
  766. else if (equiType == "AOI")
  767. {
  768. res = currItem[3];
  769. sql.Clear();
  770. sql.Append($"SELECT a.li_code,b.dl_macode FROM line_ipaoi a, deviceline b WHERE a.ipaddress = '{currItem[2]}' AND a.li_code = b.dl_linecode");
  771. dt = (DataTable)dh.ExecuteSql(sql.GetString(), "select");
  772. if (dt.Rows.Count > 0)
  773. {
  774. wo = dt.Rows[0]["dd_name"].ToString();
  775. }
  776. else
  777. {
  778. LogMessage($"IP:{currItem[2]},无对应线体工单");
  779. return;
  780. }
  781. }
  782. Log itemLog = new Log()
  783. {
  784. SN = currItem[0],
  785. work_order = wo,
  786. Result = res,
  787. Details = equiType == "SPI" ? currItem[1] : currItem[3]
  788. };
  789. logArr.Add(itemLog);
  790. }
  791. LogMessage($"文件: {PathName},共{fileNum}条记录,已解析");
  792. InsertDb(logArr, PathName);
  793. File.WriteAllText(PathName, string.Empty);
  794. if (ConsoleLog(restOfStream, PathName))
  795. {
  796. File.Delete(PathName);
  797. }
  798. }
  799. catch (Exception ex)
  800. {
  801. LogMessage($"Error: 文件 {PathName}, {ex.Message}");
  802. }
  803. }
  804. private void InsertDb(List<Log> logs, string PathName)
  805. {
  806. try
  807. {
  808. StringBuilder sql = new StringBuilder();
  809. List<string> param = new List<string>() { };
  810. foreach (var item in logs)
  811. {
  812. if (LogicHandler.CheckStepSNAndMacode(ma_code.Text, User.UserSourceCode, item.SN, User.UserCode, out omakeCode, out oMsid, out oErrorMessage))
  813. {
  814. if (LogicHandler.SetStepResult(omakeCode, User.UserSourceCode, item.SN, "日志解析", "OK", User.UserCode, out oErrorMessage))
  815. {
  816. if (oErrorMessage.Contains("AFTERSUCCESS")) LogMessage(">>" + oErrorMessage + "\n");
  817. sql.Clear();
  818. sql.Append("select ma_code,nvl(mcd_okqty,0) mcd_okqty,ma_prodcode,pr_detail,");
  819. sql.Append("ma_qty - nvl(mcd_okqty, 0) remain_qty from make left join makecraftdetail on ");
  820. sql.Append("mcd_maid=ma_id left join product on pr_code=ma_prodcode where ma_code='" + omakeCode + "' and mcd_stepcode='" + User.CurrentStepCode + "'");
  821. dt = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
  822. BaseUtil.SetFormValue(Controls, dt);
  823. //记录日志
  824. LogicHandler.DoCommandLog(Tag.ToString(), User.UserCode, ma_code.Text, User.UserLineCode, User.UserSourceCode, "日志解析", "日志解析成功", item.SN, "");
  825. LogMessage("<<解析成功\n");
  826. }
  827. else
  828. {
  829. LogMessage(">>" + oErrorMessage + "\n");
  830. }
  831. }
  832. else
  833. {
  834. LogMessage(">>" + oErrorMessage + "\n");
  835. }
  836. param.Add(item.SN);
  837. param.Add(item.work_order);
  838. if (item.Result == "PASS")
  839. {
  840. param.Add(item.Result);
  841. }
  842. else
  843. {
  844. param.Add(item.Result);
  845. }
  846. param.Add(equiType);
  847. param.Add(item.Details);
  848. param.Add(User.UserCode);
  849. param.Add(User.UserSourceCode);
  850. param.Add(User.UserLineCode);
  851. string res = "";
  852. param.Add(res);
  853. string[] paramList = param.ToArray();
  854. dh.CallProcedure("cs_insert_testrejects", ref paramList);
  855. param.Clear();
  856. }
  857. }
  858. catch (Exception ex)
  859. {
  860. MessageBox.Show(this.ParentForm, ex.Message, "警告");
  861. }
  862. }
  863. private bool ConsoleLog(string Content, string PathName)
  864. {
  865. try
  866. {
  867. string sourceDir = Path.GetDirectoryName(PathName);
  868. string newFolderName = "Logs";
  869. string newFolderPath = Path.Combine(sourceDir, newFolderName);
  870. if (!Directory.Exists(newFolderPath))
  871. {
  872. Directory.CreateDirectory(newFolderPath);
  873. }
  874. string newFileName = "Log_" + Path.GetFileName(PathName);
  875. string newFilePath = Path.Combine(newFolderPath, newFileName);
  876. File.AppendAllText(newFilePath, Content + Environment.NewLine);
  877. return true;
  878. }
  879. catch (Exception ex)
  880. {
  881. MessageBox.Show(this.ParentForm, ex.Message, "警告");
  882. return false;
  883. }
  884. }
  885. private void LogMessage(string message)
  886. {
  887. if (lstFiles.InvokeRequired)
  888. {
  889. lstFiles.Invoke(new Action<string>(LogMessage), message);
  890. return;
  891. }
  892. lstFiles.Items.Add($"[{DateTime.Now:yyyy-MM-dd HH:mm:ss}] {message}");
  893. lstFiles.TopIndex = lstFiles.Items.Count - 1;
  894. }
  895. public List<MachineList> ParseXml(string xmlContent)
  896. {
  897. List<MachineList> result = new List<MachineList>();
  898. try
  899. {
  900. XmlDocument xmlDoc = new XmlDocument();
  901. xmlDoc.LoadXml(xmlContent);
  902. XmlNode machineNode = xmlDoc.SelectSingleNode("//TotalProductionInfo");
  903. string machineName = machineNode?.Attributes["MachineName"]?.Value ?? "Unknown";
  904. string part = machineNode?.Attributes["ProductionProgramName"]?.Value ?? "Unknown";
  905. XmlNodeList feederNodes = xmlDoc.SelectNodes("//FeederProductionManageInfo");
  906. foreach (XmlNode feederNode in feederNodes)
  907. {
  908. MachineList machineList = new MachineList();
  909. string feederBankPosition = feederNode.Attributes["FeederBankPosition"]?.Value ?? "Unknown";
  910. string holeNo = feederNode.Attributes["HoleNo"]?.Value ?? "Unknown";
  911. string componentName = feederNode.Attributes["ComponentName"]?.Value ?? "Unknown";
  912. machineList.MachineName = machineName;
  913. machineList.Part = part;
  914. machineList.ReelNo = componentName;
  915. machineList.Station = $"{machineName}-{feederBankPosition[0]}-{holeNo}";
  916. result.Add(machineList);
  917. }
  918. }
  919. catch (Exception ex)
  920. {
  921. LogMessage($"Error parsing XML: {ex.Message}");
  922. }
  923. return result;
  924. }
  925. public List<SpiData> ParseCsvFile(string filePath)
  926. {
  927. var SpiDataList = new List<SpiData>();
  928. try
  929. {
  930. string fileName = Path.GetFileName(filePath);
  931. Encoding fileEncoding = DetectFileEncoding(filePath);
  932. string[] lines = File.ReadAllLines(filePath, fileEncoding);
  933. if (lines.Length < 3) return SpiDataList;
  934. string modelName = lines[1].Split(',')[0];
  935. string lineNumber = lines[1].Split(',')[1];
  936. string boardStatus = lines[2].Split(',')[1];
  937. string[] headers = lines[3].Split(',');
  938. for (int i = 4; i < lines.Length; i++)
  939. {
  940. string[] values = lines[i].Split(',');
  941. var SpiData = new SpiData
  942. {
  943. FileName = fileName,
  944. ModelName = modelName,
  945. LineNumber = lineNumber,
  946. BoardStatus = boardStatus,
  947. PadID = GetValue(values, 0, headers, "PadID"),
  948. ComponentID = GetValue(values, 1, headers, "ComponentID"),
  949. Type = GetValue(values, 2, headers, "Type"),
  950. AreaPercent = GetValue(values, 3, headers, "Area(%)"),
  951. Height = GetValue(values, 4, headers, "Height"),
  952. VolumePercent = GetValue(values, 5, headers, "Volume(%)"),
  953. XOffset = GetValue(values, 6, headers, "XOffset"),
  954. YOffset = GetValue(values, 7, headers, "YOffset"),
  955. PadSizeX = GetValue(values, 8, headers, "PadSize(X)"),
  956. PadSizeY = GetValue(values, 9, headers, "PadSize(Y)"),
  957. Area = GetValue(values, 10, headers, "Area"),
  958. HeightPercent = GetValue(values, 11, headers, "Height(%)"),
  959. Volume = GetValue(values, 12, headers, "Volume"),
  960. Result = GetValue(values, 13, headers, "Result"),
  961. Errcode = GetValue(values, 14, headers, "Errcode"),
  962. PinNum = GetValue(values, 15, headers, "PinNum"),
  963. Barcode = GetValue(values, 16, headers, "Barcode"),
  964. Date = GetValue(values, 17, headers, "Date"),
  965. Time = GetValue(values, 18, headers, "Time"),
  966. ArrayID = GetValue(values, 19, headers, "ArrayID")
  967. };
  968. SpiDataList.Add(SpiData);
  969. }
  970. }
  971. catch (Exception ex)
  972. {
  973. LogMessage($"解析csv文件报错,{ex.Message}");
  974. }
  975. return SpiDataList;
  976. }
  977. public List<T> ParseCsvFile<T>(string filePath, Func<string, string[], string[], string, int, T> mapper) where T : class
  978. {
  979. var dataList = new List<T>();
  980. if (!File.Exists(filePath))
  981. {
  982. LogMessage($"文件不存在: {filePath}");
  983. return dataList;
  984. }
  985. try
  986. {
  987. string fileName = Path.GetFileName(filePath);
  988. /*Encoding fileEncoding = DetectFileEncoding(filePath);*/
  989. string[] lines = File.ReadAllLines(filePath, Encoding.GetEncoding("GB2312"));
  990. for (int i = 1; i < lines.Length; i++)
  991. {
  992. if (string.IsNullOrWhiteSpace(lines[i])) continue;
  993. if (equiType == "SPI")
  994. {
  995. if (lines.Length < 4) return dataList;
  996. string modelName = lines[1].Split(',')[0];
  997. string lineNumber = lines[1].Split(',')[1];
  998. string boardStatus = lines[2].Split(',')[1];
  999. if(i > 3)
  1000. {
  1001. string[] headers = lines[3].Split(',');
  1002. string[] values = lines[i].Split(',');
  1003. var item = mapper(fileName, headers, values, $"{modelName},{lineNumber},{boardStatus}", i);
  1004. if (item != null)
  1005. {
  1006. dataList.Add(item);
  1007. }
  1008. }
  1009. } else if (equiType == "印刷机")
  1010. {
  1011. string[] headers = lines[0].Split(',');
  1012. string[] values = lines[i].Split(',');
  1013. var item = mapper(fileName, headers, values, "", i);
  1014. if (item != null)
  1015. {
  1016. dataList.Add(item);
  1017. }
  1018. }
  1019. }
  1020. }
  1021. catch (Exception ex)
  1022. {
  1023. LogMessage($"解析csv文件报错: {ex.Message}");
  1024. }
  1025. return dataList;
  1026. }
  1027. private SpiData MapToSpiData(string fileName, string[] headers, string[] values,string others,int num)
  1028. {
  1029. return new SpiData
  1030. {
  1031. FileName = fileName,
  1032. ModelName = others.Split(',')[0],
  1033. LineNumber = others.Split(',')[1],
  1034. BoardStatus = others.Split(',')[2],
  1035. PadID = GetValue(values, 0, headers, "PadID"),
  1036. ComponentID = GetValue(values, 1, headers, "ComponentID"),
  1037. Type = GetValue(values, 2, headers, "Type"),
  1038. AreaPercent = GetValue(values, 3, headers, "Area(%)"),
  1039. Height = GetValue(values, 4, headers, "Height"),
  1040. VolumePercent = GetValue(values, 5, headers, "Volume(%)"),
  1041. XOffset = GetValue(values, 6, headers, "XOffset"),
  1042. YOffset = GetValue(values, 7, headers, "YOffset"),
  1043. PadSizeX = GetValue(values, 8, headers, "PadSize(X)"),
  1044. PadSizeY = GetValue(values, 9, headers, "PadSize(Y)"),
  1045. Area = GetValue(values, 10, headers, "Area"),
  1046. HeightPercent = GetValue(values, 11, headers, "Height(%)"),
  1047. Volume = GetValue(values, 12, headers, "Volume"),
  1048. Result = GetValue(values, 13, headers, "Result"),
  1049. Errcode = GetValue(values, 14, headers, "Errcode"),
  1050. PinNum = GetValue(values, 15, headers, "PinNum"),
  1051. Barcode = GetValue(values, 16, headers, "Barcode"),
  1052. Date = GetValue(values, 17, headers, "Date"),
  1053. Time = GetValue(values, 18, headers, "Time"),
  1054. ArrayID = GetValue(values, 19, headers, "ArrayID")
  1055. };
  1056. }
  1057. private PrintData MapToPriMacData(string fileName, string[] headers, string[] values, string others, int num)
  1058. {
  1059. return new PrintData
  1060. {
  1061. BarCode = GetValue(values, 0, headers, "BarCode"),
  1062. TimeStamp = GetValue(values, 1, headers, "TimeStamp"),
  1063. FileName = GetValue(values, 2, headers, "FileName"),
  1064. ProgramRunning = GetValue(values, 3, headers, "ProgramRunning"),
  1065. CycleTime = GetValue(values, 7, headers, "CycleTime"),
  1066. _2DSPIResult = GetValue(values, 8, headers, "_2DSPIResult"),
  1067. PrintSpeed = GetValue(values, 9, headers, "PrintSpeed"),
  1068. FrontSQGPress = GetValue(values, 10, headers, "FrontSQGPress"),
  1069. RearSQGPress = GetValue(values, 11, headers, "RearSQGPress"),
  1070. PrintMode = GetValue(values, 12, headers, "PrintMode"),
  1071. SnapOffDistance = GetValue(values, 14, headers, "SnapOffDistance"),
  1072. SnapOffSpeed = GetValue(values, 15, headers, "SnapOffSpeed"),
  1073. SnapOffDelay = GetValue(values, 16, headers, "SnapOffDelay"),
  1074. SQGUpSpeed = GetValue(values, 17, headers, "SQGUpSpeed"),
  1075. SQGDownSpeed = GetValue(values, 18, headers, "SQGDownSpeed"),
  1076. SQGUpFirst = GetValue(values, 19, headers, "SQGUpFirst"),
  1077. SQGHeightAtSnapOff = GetValue(values, 20, headers, "SQGHeightAtSnapOff"),
  1078. CleaningAfterLastBoard = GetValue(values, 21, headers, "CleaningAfterLastBoard"),
  1079. CleaningFrequency = GetValue(values, 22, headers, "CleaningFrequency"),
  1080. CleaningSpeed = GetValue(values, 23, headers, "CleaningSpeed"),
  1081. CleaningType = GetValue(values, 25, headers, "CleaningType"),
  1082. AddSPMode = GetValue(values, 26, headers, "AddSPMode"),
  1083. PrintDirection = GetValue(values, 29, headers, "PrintDirection"),
  1084. PCBSize = GetValue(values, 30, headers, "PCBSize"),
  1085. TableUpX = GetValue(values, 31, headers, "TableUpX"),
  1086. TableUpY1 = GetValue(values, 32, headers, "TableUpY1"),
  1087. TableUpY2 = GetValue(values, 33, headers, "TableUpY2"),
  1088. };
  1089. }
  1090. private static Encoding DetectFileEncoding(string filePath)
  1091. {
  1092. byte[] bom = new byte[4];
  1093. using (var file = new FileStream(filePath, FileMode.Open, FileAccess.Read))
  1094. {
  1095. file.Read(bom, 0, 4);
  1096. }
  1097. if (bom[0] == 0xef && bom[1] == 0xbb && bom[2] == 0xbf) return Encoding.UTF8;
  1098. if (bom[0] == 0xff && bom[1] == 0xfe) return Encoding.Unicode;
  1099. if (bom[0] == 0xfe && bom[1] == 0xff) return Encoding.BigEndianUnicode;
  1100. if (bom[0] == 0 && bom[1] == 0 && bom[2] == 0xfe && bom[3] == 0xff) return Encoding.UTF32;
  1101. try
  1102. {
  1103. string content = File.ReadAllText(filePath, Encoding.UTF8);
  1104. return Encoding.UTF8;
  1105. }
  1106. catch
  1107. {
  1108. return Encoding.GetEncoding("GB2312");
  1109. }
  1110. }
  1111. private string GetValue(string[] values, int index, string[] headers, string expectedHeader)
  1112. {
  1113. if (index >= values.Length || index >= headers.Length || headers[index] != expectedHeader) return string.Empty;
  1114. return values[index];
  1115. }
  1116. private class Log
  1117. {
  1118. public string work_order { get; set; }
  1119. public string SN { set; get; }
  1120. public string Result { set; get; }
  1121. /*public List<NgData> Details { set; get; }*/
  1122. public string Details { set; get; }
  1123. }
  1124. public class MachineList
  1125. {
  1126. public string MachineName { set; get; }
  1127. public string Part { set; get; }
  1128. public string Station { set; get; }
  1129. public string ReelNo { set; get; }
  1130. }
  1131. public class SpiData
  1132. {
  1133. public string FileName { get; set; }
  1134. public string ModelName { get; set; }
  1135. public string LineNumber { get; set; }
  1136. public string BoardStatus { get; set; }
  1137. public string PadID { get; set; }
  1138. public string ComponentID { get; set; }
  1139. public string Type { get; set; }
  1140. public string AreaPercent { get; set; }
  1141. public string Height { get; set; }
  1142. public string VolumePercent { get; set; }
  1143. public string XOffset { get; set; }
  1144. public string YOffset { get; set; }
  1145. public string PadSizeX { get; set; }
  1146. public string PadSizeY { get; set; }
  1147. public string Area { get; set; }
  1148. public string HeightPercent { get; set; }
  1149. public string Volume { get; set; }
  1150. public string Result { get; set; }
  1151. public string Errcode { get; set; }
  1152. public string PinNum { get; set; }
  1153. public string Barcode { get; set; }
  1154. public string Date { get; set; }
  1155. public string Time { get; set; }
  1156. public string ArrayID { get; set; }
  1157. }
  1158. public class PrintData
  1159. {
  1160. public string BarCode { get; set; }
  1161. public string TimeStamp { get; set; }
  1162. public string FileName { get; set; }
  1163. public string ProgramRunning { get; set; }
  1164. public string CycleTime { get; set; }
  1165. public string _2DSPIResult { get; set; }
  1166. public string PrintSpeed { get; set; }
  1167. public string FrontSQGPress { get; set; }
  1168. public string RearSQGPress { get; set; }
  1169. public string PrintMode { get; set; }
  1170. public string SnapOffDistance { get; set; }
  1171. public string SnapOffSpeed { get; set; }
  1172. public string SnapOffDelay { get; set; }
  1173. public string SQGUpSpeed { get; set; }
  1174. public string SQGDownSpeed { get; set; }
  1175. public string SQGUpFirst { get; set; }
  1176. public string SQGHeightAtSnapOff { get; set; }
  1177. public string CleaningAfterLastBoard { get; set; }
  1178. public string CleaningFrequency { get; set; }
  1179. public string CleaningSpeed { get; set; }
  1180. public string CleaningType { get; set; }
  1181. public string AddSPMode { get; set; }
  1182. public string PrintDirection { get; set; }
  1183. public string PCBSize { get; set; }
  1184. public string TableUpX { get; set; }
  1185. public string TableUpY1 { get; set; }
  1186. public string TableUpY2 { get; set; }
  1187. }
  1188. private PrinterData ReadWithXmlReader(string filePath)
  1189. {
  1190. PrinterData data = new PrinterData();
  1191. using (XmlReader reader = XmlReader.Create(filePath))
  1192. {
  1193. while (reader.Read())
  1194. {
  1195. if (reader.NodeType == XmlNodeType.Element)
  1196. {
  1197. switch (reader.Name)
  1198. {
  1199. case "SN":
  1200. data.SN = reader.ReadElementContentAsString();
  1201. break;
  1202. case "Barcode":
  1203. data.Barcode = reader.ReadElementContentAsString();
  1204. break;
  1205. case "Direction":
  1206. data.Direction = reader.ReadElementContentAsString();
  1207. break;
  1208. case "PrintTime":
  1209. data.PrintTime = reader.ReadElementContentAsString();
  1210. break;
  1211. case "PANEL":
  1212. ReadPanelData(reader, data.Panel);
  1213. break;
  1214. case "PROCESS":
  1215. ReadProcessData(reader, data.Process);
  1216. break;
  1217. }
  1218. }
  1219. }
  1220. }
  1221. return data;
  1222. }
  1223. private void ReadPanelData(XmlReader reader, Panel panel)
  1224. {
  1225. while (reader.Read())
  1226. {
  1227. if (reader.NodeType == XmlNodeType.Element)
  1228. {
  1229. switch (reader.Name)
  1230. {
  1231. case "PanelID":
  1232. panel.PanelID = reader.ReadElementContentAsString();
  1233. break;
  1234. case "PanelName":
  1235. panel.PanelName = reader.ReadElementContentAsString();
  1236. break;
  1237. case "PanelFirm":
  1238. panel.PanelFirm = reader.ReadElementContentAsString();
  1239. break;
  1240. case "PanelLength":
  1241. panel.PanelLength = reader.ReadElementContentAsDouble();
  1242. break;
  1243. case "PanelWide":
  1244. panel.PanelWide = reader.ReadElementContentAsDouble();
  1245. break;
  1246. case "PanelThickness":
  1247. panel.PanelThickness = reader.ReadElementContentAsDouble();
  1248. break;
  1249. }
  1250. }
  1251. else if (reader.NodeType == XmlNodeType.EndElement && reader.Name == "PANEL")
  1252. {
  1253. break;
  1254. }
  1255. }
  1256. }
  1257. private void ReadProcessData(XmlReader reader, Process process)
  1258. {
  1259. while (reader.Read())
  1260. {
  1261. if (reader.NodeType == XmlNodeType.Element)
  1262. {
  1263. switch (reader.Name)
  1264. {
  1265. case "ProcessName":
  1266. process.ProcessName = reader.ReadElementContentAsString();
  1267. break;
  1268. case "LineNumber":
  1269. process.LineNumber = reader.ReadElementContentAsString();
  1270. break;
  1271. case "StencilNum":
  1272. process.StencilNum = reader.ReadElementContentAsString();
  1273. break;
  1274. }
  1275. }
  1276. else if (reader.NodeType == XmlNodeType.EndElement && reader.Name == "PROCESS")
  1277. {
  1278. break;
  1279. }
  1280. }
  1281. }
  1282. private class PrinterData
  1283. {
  1284. public string SN { get; set; }
  1285. public string Barcode { get; set; }
  1286. public string Direction { get; set; }
  1287. public string PrintTime { get; set; }
  1288. public Panel Panel { get; set; } = new Panel();
  1289. public Process Process { get; set; } = new Process();
  1290. }
  1291. private class Panel
  1292. {
  1293. public string PanelID { get; set; }
  1294. public string PanelName { get; set; }
  1295. public string PanelFirm { get; set; }
  1296. public double PanelLength { get; set; }
  1297. public double PanelWide { get; set; }
  1298. public double PanelThickness { get; set; }
  1299. }
  1300. private class Process
  1301. {
  1302. public string ProcessName { get; set; }
  1303. public string LineNumber { get; set; }
  1304. public string StencilNum { get; set; }
  1305. }
  1306. }
  1307. }