AutoAnalysisXml.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663
  1. using Microsoft.Win32;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.IO;
  6. using System.Threading;
  7. using System.Windows.Forms;
  8. using System.Xml;
  9. using System.Text;
  10. namespace FileWatcher
  11. {
  12. public partial class AutoAnalysisXml : Form
  13. {
  14. DataHelper dh;
  15. DataTable dt;
  16. DataTable DB;
  17. /// <summary>
  18. /// 用户编号
  19. /// </summary>
  20. string iusercode;
  21. /// <summary>
  22. /// 岗位资源
  23. /// </summary>
  24. string isource;
  25. Tip tipform;
  26. Thread InitDB;
  27. /// <summary>
  28. /// 线别
  29. /// </summary>
  30. string ilinecode;
  31. /// <summary>
  32. /// 不良代码组
  33. /// </summary>
  34. string ibadgroup;
  35. /// <summary>
  36. /// 当前工序
  37. /// </summary>
  38. string istepcode;
  39. StringBuilder sql = new StringBuilder();
  40. /// <summary>
  41. /// 缓存的文件
  42. /// </summary>
  43. public static string CachePath = Environment.GetEnvironmentVariable("windir").Substring(0, 1) + @":/UAS_MES/XmlAnalysor/Cache.xml";
  44. /// <summary>
  45. /// 缓存的文件夹
  46. /// </summary>
  47. public static string CachePathFolder = Environment.GetEnvironmentVariable("windir").Substring(0, 1) + @":/UAS_MES/XmlAnalysor/";
  48. /// <summary>
  49. /// 需要解析的文件名
  50. /// </summary>
  51. List<string> _FileName = new List<string>();
  52. string master="WKS";
  53. ftpOperater ftp = new ftpOperater();
  54. public AutoAnalysisXml()
  55. {
  56. tipform = new Tip();
  57. InitializeComponent();
  58. StartPosition = FormStartPosition.CenterScreen;
  59. }
  60. public AutoAnalysisXml(string iUserName, string iSource,string iMaster)
  61. {
  62. tipform = new Tip();
  63. InitializeComponent();
  64. iusercode = iUserName;
  65. isource = iSource.ToUpper();
  66. master = iMaster;
  67. StartPosition = FormStartPosition.CenterScreen;
  68. }
  69. private void Form1_Load(object sender, EventArgs e)
  70. {
  71. tipform.Show();
  72. CheckForIllegalCrossThreadCalls = false;
  73. FormBorderStyle = FormBorderStyle.FixedSingle;
  74. InitDB = new Thread(ConnectDB);
  75. //添加监控事件
  76. XmlWatcher.Created += new FileSystemEventHandler(XmlWatcher_Created);
  77. SetLoadingWindow stw = new SetLoadingWindow(InitDB, "正在启动程序");
  78. stw.StartPosition = FormStartPosition.CenterScreen;
  79. stw.ShowDialog();
  80. List<string> CacheInf = new List<string>();
  81. //获取缓存信息
  82. try
  83. {
  84. //FolderPath.Text = BaseUtil.GetCacheData("FolderPath").ToString();
  85. //BackUpFolderPath.Text = BaseUtil.GetCacheData("BackUpFolderPath").ToString();
  86. //Master.Text = BaseUtil.GetCacheData("Master").ToString();
  87. //AutoStart.Checked = (bool)BaseUtil.GetCacheData("AutoStart");
  88. }
  89. catch (Exception ex) { MessageBox.Show(ex.Message); }
  90. //获取岗位资源相关信息
  91. DataTable dt = (DataTable)dh.ExecuteSql("select sc_linecode,sc_stepcode,st_badgroupcode from source left join step on sc_stepcode=st_code where sc_code='" + isource + "'", "select");
  92. if (dt.Rows.Count > 0)
  93. {
  94. ilinecode = dt.Rows[0]["sc_linecode"].ToString();
  95. istepcode = dt.Rows[0]["sc_stepcode"].ToString();
  96. ibadgroup = dt.Rows[0]["st_badgroupcode"].ToString();
  97. }
  98. }
  99. private void ConnectDB()
  100. {
  101. DataHelper.DBConnectionString = "Connection Timeout=0;Pooling=false;Password=select!#%*(;User ID=" + master + ";Pooling=false;Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=81.71.42.91)(PORT=11678)))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=orcl)));";
  102. dh = new DataHelper();
  103. }
  104. private void StartWatch_Click(object sender, EventArgs e)
  105. {
  106. if (FolderPath.Text == "")
  107. {
  108. OperateResult.AppendText("请选择监控文件夹\n");
  109. return;
  110. }
  111. else
  112. {
  113. if (!Directory.Exists(FolderPath.Text))
  114. {
  115. OperateResult.AppendText("监控文件夹不存在\n");
  116. return;
  117. }
  118. }
  119. //for (int i = 0; i < DB.Rows.Count; i++)
  120. //{
  121. // if (Master.Text == DB.Rows[i]["ma_user"].ToString())
  122. // {
  123. // DataHelper.DBConnectionString = "Connection Timeout=0;Pooling=false;Password=select!#%*(;User ID=DGW;Pooling=false;Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=81.71.42.91)(PORT=11678)))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=orcl)));";
  124. // dh = new DataHelper();
  125. // LogicHandler.dh = new DataHelper();
  126. // }
  127. //}
  128. //存在工单必须是已下放状态
  129. if ((!dh.CheckExist("make", "ma_statuscode='STARTED' and ma_code='" + ma_code.Text + "'") || ma_code.Text == "") && Device.Text == "AOI设备")
  130. {
  131. OperateResult.AppendText("工单不存在或者未下放\n");
  132. return;
  133. }
  134. XmlWatcher.Path = FolderPath.Text;
  135. XmlWatcher.Filter = "*.txt";
  136. XmlWatcher.EnableRaisingEvents = true;
  137. //设置缓存数据
  138. //BaseUtil.SetCacheData("FolderPath", FolderPath.Text);
  139. //BaseUtil.SetCacheData("BackUpFolderPath", BackUpFolderPath.Text);
  140. //BaseUtil.SetCacheData("Master", Master.Text);
  141. //BaseUtil.SetCacheData("AutoStart", AutoStart.Checked);
  142. Timer.Interval = 1000 * 10;
  143. Timer.Start();
  144. //设置按钮不可点击
  145. StartWatch.Enabled = false;
  146. ChooseFolder.Enabled = false;
  147. Master.Enabled = false;
  148. ma_code.Enabled = false;
  149. StopWatch.Enabled = true;
  150. OperateResult.AppendText("开始执行监控\n");
  151. }
  152. public void CreateNode(XmlDocument xmlDoc, XmlNode parentNode, string name, string value)
  153. {
  154. XmlNode node = xmlDoc.CreateNode(XmlNodeType.Element, name, null);
  155. node.InnerText = value;
  156. parentNode.AppendChild(node);
  157. }
  158. private void XmlWatcher_Created(object sender, FileSystemEventArgs e)
  159. {
  160. //while (true)
  161. //{
  162. // try
  163. // {
  164. // using (Stream stream = File.Open(e.FullPath, FileMode.Open, FileAccess.Read, FileShare.Read))
  165. // {
  166. // if (stream != null)
  167. // break;
  168. // }
  169. // }
  170. // catch (Exception ex)
  171. // {
  172. // Console.WriteLine(ex.Message);
  173. // }
  174. //}
  175. //switch (e.Name.Substring(e.Name.LastIndexOf(".") + 1).ToUpper())
  176. //{
  177. // case "TXT":
  178. // TxtHandleProcess(e.FullPath);
  179. // break;
  180. // case "XML":
  181. // XmlHandleProcess(e.FullPath);
  182. // break;
  183. // default:
  184. // break;
  185. //}
  186. }
  187. string nextLine;
  188. private void TxtHandleProcess(string FileName)
  189. {
  190. List<string> badcode = new List<string>();
  191. List<string> badlocation = new List<string>();
  192. List<string> badprod = new List<string>();
  193. if (Device.Text == "AOI设备")
  194. {
  195. StreamReader sR = File.OpenText(FileName);
  196. DataTable filedt = new DataTable();
  197. //文件内的行,用一个DataTable存储
  198. int Rowindex = 0;
  199. while ((nextLine = sR.ReadLine()) != null)
  200. {
  201. //DataTable用第一行的数据作为列名
  202. string[] title = nextLine.Split(',');
  203. DataRow dr = filedt.NewRow();
  204. for (int i = 0; i < title.Length; i++)
  205. {
  206. if (Rowindex == 0)
  207. {
  208. filedt.Columns.Add(title[i]);
  209. }
  210. else
  211. {
  212. dr[filedt.Columns[i].ColumnName] = title[i];
  213. }
  214. }
  215. //除了第一行,然后添加到表格中
  216. if (Rowindex > 0)
  217. {
  218. filedt.Rows.Add(dr);
  219. }
  220. Rowindex = Rowindex + 1;
  221. }
  222. sR.Close();
  223. string SN = FileName.Substring(FileName.LastIndexOf(@"\") + 1).Replace("-", "/").ToUpper().Replace(".TXT", "");
  224. string Result = "OK";
  225. string makecode = "";
  226. string stepcode = "";
  227. string oErrMessage = "";
  228. string oMSID = "";
  229. isource = "SMT_01_AOI";
  230. iusercode = "SMT_01_AOI";
  231. DataTable dt = (DataTable)dh.ExecuteSql("select sc_linecode,sc_stepcode,st_badgroupcode from source left join step on sc_stepcode=st_code where sc_code='" + isource + "'", "select");
  232. if (dt.Rows.Count > 0)
  233. {
  234. ilinecode = dt.Rows[0]["sc_linecode"].ToString();
  235. istepcode = dt.Rows[0]["sc_stepcode"].ToString();
  236. ibadgroup = dt.Rows[0]["st_badgroupcode"].ToString();
  237. }
  238. if (LogicHandler.CheckStepSNAndMacode(ma_code.Text, isource, SN, iusercode, out makecode, out oMSID, out oErrMessage))
  239. {
  240. for (int i = 0; i < filedt.Rows.Count; i++)
  241. {
  242. if (filedt.Rows[i]["c_result"].ToString() != "OK" && filedt.Rows[i]["c_result"].ToString() != "FC")
  243. {
  244. Result = "NG";
  245. //只添加一条记录
  246. if (badcode.Count == 0 && filedt.Rows[i]["w_ng_name"].ToString() != "")
  247. {
  248. badcode.Add(filedt.Rows[i]["w_ng_name"].ToString());
  249. badlocation.Add(filedt.Rows[i]["c_subboard_number"].ToString());
  250. badprod.Add(filedt.Rows[i]["c_subboard_number"].ToString());
  251. }
  252. }
  253. }
  254. //获取序列号ID最大的工单
  255. dt = (DataTable)dh.ExecuteSql("select ms_makecode,ms_id,ms_stepcode from makeserial where ms_sncode='" + SN + "' order by ms_id desc", "select");
  256. if (dt.Rows.Count > 0)
  257. {
  258. ma_code.Text = dt.Rows[0]["ms_makecode"].ToString();
  259. makecode = dt.Rows[0]["ms_makecode"].ToString();
  260. stepcode = dt.Rows[0]["ms_stepcode"].ToString();
  261. if (stepcode == istepcode)
  262. {
  263. tipform.startthread("序列号 " + SN + "已执行过" + istepcode, "NG");
  264. OperateResult.AppendText("序列号 " + SN + "已执行过" + istepcode + "\n");
  265. }
  266. switch (Result)
  267. {
  268. case "OK":
  269. if (!LogicHandler.SetStepResult(makecode, isource, SN, "自动过站采集", Result, iusercode, out oErrMessage))
  270. {
  271. OperateResult.AppendText(oErrMessage + "\n");
  272. tipform.startthread(oErrMessage, Result);
  273. }
  274. tipform.startthread("序列号 " + SN + "通过检测", Result);
  275. OperateResult.AppendText("序列号 " + SN + "通过检测" + "\n");
  276. break;
  277. case "NG":
  278. RecordBadInfo(SN, makecode, FileName, "", badcode.ToArray(), badlocation.ToArray(), badprod.ToArray());
  279. //所有的序列号均采集为良品
  280. if (!LogicHandler.SetTestNGDetail(SN, makecode, iusercode, isource, Result, out oErrMessage))
  281. {
  282. OperateResult.AppendText(oErrMessage + "\n");
  283. tipform.startthread(oErrMessage, Result);
  284. }
  285. tipform.startthread("序列号 " + SN + "未通过检测", Result);
  286. OperateResult.AppendText("序列号 " + SN + "未通过检测" + "\n");
  287. break;
  288. default:
  289. break;
  290. }
  291. File.Delete(FileName);
  292. }
  293. }
  294. else
  295. {
  296. OperateResult.AppendText(oErrMessage + "\n");
  297. tipform.startthread(oErrMessage, Result);
  298. //File.Delete(FileName);
  299. }
  300. }
  301. else if (Device.Text == "测试设备")
  302. {
  303. try
  304. {
  305. string filename = FileName;
  306. if (filename.Substring(filename.LastIndexOf(".") + 1).ToUpper() == "TXT")
  307. {
  308. string folderpath = FileName.Substring(0, FileName.LastIndexOf(@"\"));
  309. string SN = FileName.Substring(FileName.LastIndexOf(@"\") + 1).Replace("-", "/").ToUpper().Replace(".TXT", "");
  310. if (SN.Length == 12)
  311. {
  312. string ms_sncode = dh.getFieldDataByCondition("steppassed", "sp_sncode", "substr(sp_sncode,0,12)='" + SN + "' order by sp_id desc").ToString();
  313. string ms_makecode = dh.getFieldDataByCondition("steppassed", "sp_makecode", "substr(sp_sncode,0,12)='" + SN + "' order by sp_id desc").ToString();
  314. string makecode = ma_code.Text;
  315. string ftppath = "/"+master+"/" + DateTime.Now.ToString("yyyy-MM-dd") + "/";
  316. ftp.UpLoadFile(folderpath, SN + ".txt", ftppath, "");
  317. int num = int.Parse(dh.ExecuteSql("insert into STEPTESTDETAIL (std_id,std_sn,std_makecode,std_indate,std_class)select STEPTESTDETAIL_seq.nextval,'"+ ms_sncode + "','"+ ms_makecode + "',sysdate,'http://81.71.42.91:8099/ftp" + ftppath + SN + ".txt" + "' from dual ", "insert").ToString());
  318. if (num > 0)
  319. {
  320. OperateResult.AppendText("序列号:" + ms_sncode + "上传成功\n");
  321. File.Delete(FileName);
  322. }
  323. else
  324. {
  325. OperateResult.AppendText("序列号: " + ms_sncode + "上传失败\n");
  326. //MessageBox.Show("序列号: " + ms_sncode + "前工段未扫描", "信息", MessageBoxButtons.OK, MessageBoxIcon.Information, MessageBoxDefaultButton.Button1, MessageBoxOptions.DefaultDesktopOnly);
  327. }
  328. }
  329. }
  330. }
  331. catch (Exception e)
  332. {
  333. OperateResult.AppendText("解析失败:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\n" + FileName + "\n" + e.Message + "\n");
  334. }
  335. }
  336. }
  337. /// <summary>
  338. /// 使用进程处理文件,避免界面假死
  339. /// </summary>
  340. private void XmlHandleProcess(string FileName)
  341. {
  342. string test_date = "";
  343. string test_result = "";
  344. string test_sn = "";
  345. string imageurl = "";
  346. string oMSID = "";
  347. string oErrMessage = "";
  348. XmlReader myReader = XmlReader.Create(FolderPath.Text + @"\" + FileName);
  349. OperateResult.AppendText("读取文件" + FileName + "\n");
  350. //获取采集的项目名称
  351. List<string> badcode = new List<string>();
  352. //获取采集项目的结果
  353. List<string> badlocation = new List<string>();
  354. while (myReader.Read())
  355. {
  356. if (myReader.NodeType == XmlNodeType.Element && myReader.Name == "test" && myReader.IsStartElement())
  357. {
  358. test_sn = myReader.GetAttribute("test_sn");
  359. test_result = myReader.GetAttribute("test_result");
  360. test_date = myReader.GetAttribute("test_date");
  361. imageurl = myReader.GetAttribute("imgurl");
  362. }
  363. //if (myReader.NodeType == XmlNodeType.Text)
  364. //{
  365. // if (code_or_location % 2 == 0)
  366. // {
  367. // badcode.Add(myReader.Value);
  368. // code_or_location++;
  369. // }
  370. // else
  371. // {
  372. // badlocation.Add(myReader.Value);
  373. // code_or_location++;
  374. // }
  375. //}
  376. if (myReader.NodeType == XmlNodeType.Element && myReader.Name == "err_reason" && myReader.IsStartElement())
  377. {
  378. badcode.Add(myReader.ReadInnerXml() + " ");
  379. }
  380. if (myReader.NodeType == XmlNodeType.Element && myReader.Name == "err_location" && myReader.IsStartElement())
  381. {
  382. badlocation.Add(myReader.ReadInnerXml() + " ");
  383. }
  384. }
  385. myReader.Close();
  386. //获取文件名的序列号,如SA123456.xml,如果开头为-表示无条码需要自动获取
  387. string sncode = FileName.Substring(0, 1) == "-" ? "" : FileName.Split('.')[0];
  388. string makecode = "";
  389. //获取序列号ID最大的工单号,所有序列号都测试为良品
  390. if (sncode == "")
  391. {
  392. //获取资源,线别,工序相等,并且状态在线的序列号进行分配
  393. sql.Clear();
  394. sql.Append("select ms_sncode,ms_makecode from makeserial left join source on sc_code=ms_sccode where ");
  395. sql.Append("sc_linecode='" + ilinecode + "' and ms_nextstepcode='" + istepcode + "' and ms_status=1 order by ms_id");
  396. dt = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
  397. if (dt.Rows.Count > 0)
  398. {
  399. makecode = dt.Rows[0]["ms_makecode"].ToString();
  400. sncode = dt.Rows[0]["ms_sncode"].ToString();
  401. }
  402. else
  403. {
  404. OperateResult.AppendText("当前线别在" + istepcode + "无可分配序列号");
  405. tipform.startthread("当前线别在" + istepcode + "无可分配序列号", "NG");
  406. return;
  407. }
  408. //-2-NG2017/10/2514:46:29.xml取第二位版号
  409. string combinecode = FileName.Substring(1, 1);
  410. if (LogicHandler.CheckStepSNAndMacode(ma_code.Text == "" ? makecode : ma_code.Text, isource, sncode, iusercode, out makecode, out oMSID, out oErrMessage))
  411. {
  412. //插入日志
  413. LogicHandler.AutoPassLog(sncode, isource, makecode, test_date, istepcode, ilinecode, FileName, test_result == "NG" ? "-1" : "0", "-1", 0, "", "");
  414. //如果是不良品记录日志,用于测试采集判负
  415. if (test_result == "NG")
  416. {
  417. RecordBadInfo(sncode, makecode, FileName, combinecode, badcode.ToArray(), badlocation.ToArray(), null);
  418. }
  419. if (!LogicHandler.SetStepResult(makecode, isource, sncode, "自动过站采集", "OK", iusercode, out oErrMessage))
  420. {
  421. OperateResult.AppendText(oErrMessage + "\n");
  422. tipform.startthread(oErrMessage, "NG");
  423. return;
  424. }
  425. tipform.startthread("序列号 " + sncode + "通过检测", test_result);
  426. }
  427. else
  428. {
  429. OperateResult.AppendText(oErrMessage + "\n");
  430. tipform.startthread(oErrMessage, "NG");
  431. return;
  432. }
  433. }
  434. else
  435. {
  436. string status = "";
  437. string errmessage = "";
  438. bool NoteAlready = false;
  439. LogicHandler.GetMakeInfo(sncode, out makecode, out status, out errmessage);
  440. if (ma_code.Text != makecode && makecode != "" && ma_code.Text != "" && status != "2")
  441. {
  442. string ChangeMakeCode = MessageBox.Show(this.ParentForm, "序列号" + sncode + "所属工单不同,是否切换?", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
  443. //如果选择不切换赋值当前界面工单
  444. if (ChangeMakeCode != "Yes")
  445. {
  446. makecode = ma_code.Text;
  447. }
  448. else
  449. {
  450. NoteAlready = true;
  451. }
  452. }
  453. if (LogicHandler.CheckStepSNAndMacode(ma_code.Text == "" ? makecode : ma_code.Text, isource, sncode, iusercode, out makecode, out oMSID, out oErrMessage))
  454. {
  455. if (!NoteAlready)
  456. {
  457. if (makecode != ma_code.Text && ma_code.Text != "")
  458. {
  459. string ChangeMakeCode = MessageBox.Show(this.ParentForm, "序列号所属工单不同,是否切换?", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
  460. //如果选择不切换赋值当前界面工单
  461. if (ChangeMakeCode == "Yes")
  462. {
  463. ma_code.Text = makecode;
  464. }
  465. else
  466. {
  467. OperateResult.AppendText(">>请重新采集序列号\n");
  468. tipform.startthread("请重新采集序列号", test_result);
  469. return;
  470. }
  471. }
  472. }
  473. //获取序列号ID最大的工单
  474. dt = (DataTable)dh.ExecuteSql("select ms_makecode,ms_id from makeserial where ms_sncode='" + sncode + "' order by ms_id desc", "select");
  475. if (dt.Rows.Count > 0)
  476. {
  477. ma_code.Text = dt.Rows[0]["ms_makecode"].ToString();
  478. makecode = dt.Rows[0]["ms_makecode"].ToString();
  479. switch (test_result)
  480. {
  481. case "OK":
  482. if (!LogicHandler.SetStepResult(makecode, isource, sncode, "自动过站采集", test_result, iusercode, out oErrMessage))
  483. {
  484. OperateResult.AppendText(oErrMessage + "\n");
  485. tipform.startthread(oErrMessage, test_result);
  486. return;
  487. }
  488. tipform.startthread("序列号 " + sncode + "通过检测", test_result);
  489. break;
  490. case "NG":
  491. RecordBadInfo(sncode, makecode, FileName, "", badcode.ToArray(), badlocation.ToArray(), null);
  492. //所有的序列号均采集为良品
  493. if (!LogicHandler.SetTestNGDetail(sncode, makecode, iusercode, isource, test_result, out oErrMessage))
  494. {
  495. OperateResult.AppendText(oErrMessage + "\n");
  496. tipform.startthread(oErrMessage, test_result);
  497. return;
  498. }
  499. tipform.startthread("序列号 " + sncode + "未通过检测", test_result);
  500. break;
  501. default:
  502. break;
  503. }
  504. LogicHandler.AutoPassLog(sncode, isource, makecode, test_date, istepcode, ilinecode, FileName, test_result == "NG" ? "1" : "0", "0", 0, "", "");
  505. }
  506. }
  507. else
  508. {
  509. OperateResult.AppendText(oErrMessage + "\n");
  510. tipform.startthread(oErrMessage, "NG");
  511. return;
  512. }
  513. }
  514. FileInfo file = new FileInfo(FolderPath.Text + @"\" + FileName);
  515. if (file.Exists)
  516. {
  517. try
  518. {
  519. }
  520. catch (Exception ex)
  521. {
  522. OperateResult.AppendText(FileName + ex.Message + "\n");
  523. }
  524. }
  525. }
  526. private void RecordBadInfo(string sncode, string makecode, string filename, string combine, string[] badcode, string[] badlocation, string[] soncode)
  527. {
  528. string[] ID = dh.GetSEQ("makebad_seq", badcode.Length);
  529. sql.Clear();
  530. sql.Append("update makebad set mb_status=-1 where mb_sncode='" + sncode + "' and mb_stepcode='" + istepcode + "' and mb_makecode='" + makecode + "' and mb_status=0");
  531. dh.ExecuteSql(sql.ToString(), "update");
  532. sql.Clear();
  533. sql.Append("insert into makebad(mb_id,mb_makecode,mb_mscode,mb_sncode,mb_inman,mb_indate,mb_stepcode");
  534. sql.Append(",mb_sourcecode,mb_badname,mb_bgcode,mb_badtable,mb_status,mb_badlocation,mb_soncode,mb_content) select :ID");
  535. sql.Append(",ma_code,ms_code,ms_sncode,'" + iusercode + "',sysdate,'" + istepcode + "','" + isource + "',");
  536. sql.Append(":bc_code,'WG','','0',:location,:soncode,'" + nextLine + "' from make left join makeSerial on ms_makecode=ma_code ");
  537. sql.Append("where ms_sncode='" + sncode + "' and ms_makecode='" + makecode + "'");
  538. dh.BatchInsert(sql.ToString(), new string[] { "ID", "bc_code", "location", "soncode" }, ID, badcode, badlocation, soncode);
  539. sql.Clear();
  540. sql.Append("update makebad set mb_badcode=(select DISTINCT bc_code from badcode where bc_name=mb_badcode),mb_badname=mb_badcode,mb_bgname=(select DISTINCT bg_name from badgroup where bg_code=mb_bgcode) ");
  541. sql.Append("where mb_id=:ID");
  542. dh.BatchInsert(sql.ToString(), new string[] { "ID" }, ID);
  543. //记录判断日志
  544. if (dh.getFieldDataByCondition("source", "sc_scantype", "sc_code='" + isource + "'").ToString() == "REJUCE")
  545. {
  546. LogicHandler.AutoPassJudge(sncode, makecode, isource, filename, ilinecode, combine);
  547. }
  548. }
  549. private void StopWatch_Click(object sender, EventArgs e)
  550. {
  551. XmlWatcher.EnableRaisingEvents = false;
  552. StartWatch.Enabled = true;
  553. ma_code.Enabled = true;
  554. Master.Enabled = true;
  555. ChooseFolder.Enabled = true;
  556. StopWatch.Enabled = false;
  557. OperateResult.AppendText("停止执行监控\n");
  558. }
  559. private void Clean_Click(object sender, EventArgs e)
  560. {
  561. OperateResult.Clear();
  562. }
  563. private void ChooseFolder_Click(object sender, EventArgs e)
  564. {
  565. FolderBrowserDialog folder = new FolderBrowserDialog();
  566. folder.Description = "选择监控文件夹";
  567. DialogResult result = folder.ShowDialog();
  568. if (result == DialogResult.OK)
  569. {
  570. FolderPath.Text = folder.SelectedPath;
  571. }
  572. }
  573. private void ChooseBackUpFolder_Click(object sender, EventArgs e)
  574. {
  575. FolderBrowserDialog folder = new FolderBrowserDialog();
  576. folder.Description = "选择备份文件夹";
  577. DialogResult result = folder.ShowDialog();
  578. if (result == DialogResult.OK)
  579. {
  580. }
  581. }
  582. private void Form1_FormClosing(object sender, FormClosingEventArgs e)
  583. {
  584. string ExitConfirm = MessageBox.Show(this, "确认退出?", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question).ToString();
  585. if (ExitConfirm != "Yes")
  586. {
  587. WindowState = FormWindowState.Minimized;
  588. e.Cancel = true;
  589. }
  590. }
  591. private void AutoStart_CheckedChanged(object sender, EventArgs e)
  592. {
  593. SetAutoRun();
  594. }
  595. private void SetAutoRun()
  596. {
  597. if (AutoStart.Checked) //设置开机自启动
  598. {
  599. string path = Application.ExecutablePath;
  600. RegistryKey rk = Registry.LocalMachine;
  601. RegistryKey rk2 = rk.CreateSubKey(@"Software\Microsoft\Windows\CurrentVersion\Run");
  602. rk2.SetValue("UAS自动过站解析器.exe", path);
  603. rk2.Close();
  604. rk.Close();
  605. }
  606. else //取消开机自启动
  607. {
  608. string path = Application.ExecutablePath;
  609. RegistryKey rk = Registry.LocalMachine;
  610. RegistryKey rk2 = rk.CreateSubKey(@"Software\Microsoft\Windows\CurrentVersion\Run");
  611. rk2.DeleteValue("UAS自动过站解析器.exe", false);
  612. rk2.Close();
  613. rk.Close();
  614. }
  615. }
  616. private void BatchAnalysus_Click(object sender, EventArgs e)
  617. {
  618. var AllXmls = Directory.GetFiles(FolderPath.Text, "*.txt");
  619. foreach (var Xml in AllXmls)
  620. {
  621. TxtHandleProcess(Xml);
  622. }
  623. }
  624. private void Timer_Tick(object sender, EventArgs e)
  625. {
  626. var AllXmls = Directory.GetFiles(FolderPath.Text, "*.txt");
  627. foreach (var Xml in AllXmls)
  628. {
  629. TxtHandleProcess(Xml);
  630. }
  631. }
  632. }
  633. }