JobDataRecorder.cs 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data;
  4. using Aitex.Core.RT.DBCore;
  5. using Aitex.Core.RT.Log;
  6. using Aitex.Sorter.Common;
  7. namespace MECF.Framework.Common.DBCore
  8. {
  9. public class JobDataRecorder
  10. {
  11. public static void StartCJ(string guid, string carrierGuid, string name, string portIn, string portOut, int totalWafer)
  12. {
  13. string sql = string.Format(
  14. "INSERT INTO \"cj_data\"(\"guid\", \"start_time\", \"carrier_data_guid\", \"name\",\"input_port\",\"output_port\",\"total_wafer_count\")VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}');",
  15. guid,
  16. DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
  17. carrierGuid,
  18. name,
  19. portIn,
  20. portOut,
  21. totalWafer);
  22. DB.Insert(sql);
  23. }
  24. public static void EndCJ(string guid, int abortWafer, int unprocessedWafer)
  25. {
  26. string sql = string.Format("UPDATE \"cj_data\" SET \"end_time\"='{0}', \"abort_wafer_count\"='{1}', \"unprocessed_wafer_count\"='{2}' WHERE \"guid\"='{3}';",
  27. DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
  28. abortWafer,
  29. unprocessedWafer,
  30. guid);
  31. DB.Insert(sql);
  32. }
  33. public static void StartPJ(string guid, string carrierGuid, string cjGuid, string lotGuid, string name, string portIn, string portOut, int totalWafer, string sequence)
  34. {
  35. string sql = string.Format(
  36. "INSERT INTO \"pj_data\"(\"guid\", \"start_time\", \"carrier_data_guid\", \"cj_data_guid\",\"lot_data_guid\",\"name\",\"input_port\",\"output_port\",\"total_wafer_count\",\"sequence_name\")VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}', '{8}', '{9}');",
  37. guid,
  38. DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
  39. carrierGuid,
  40. cjGuid,
  41. lotGuid,
  42. name,
  43. portIn,
  44. portOut,
  45. totalWafer,
  46. sequence);
  47. DB.Insert(sql);
  48. }
  49. public static void EndPJ(string guid, int abortWafer, int unprocessedWafer)
  50. {
  51. string sql = string.Format("UPDATE \"pj_data\" SET \"end_time\"='{0}', \"abort_wafer_count\"='{2}', \"unprocessed_wafer_count\"='{3}' WHERE \"guid\"='{1}';",
  52. DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
  53. guid, abortWafer, unprocessedWafer);
  54. DB.Insert(sql);
  55. }
  56. public static void CreatePJ(string guid, string batchId, string jobName, string recipeName, string layoutName, string layoutData, string form)
  57. {
  58. string sql = string.Format(
  59. "INSERT INTO \"pj_data\"(\"guid\", \"batch_id\", \"job_name\", \"recipe_name\", \"layout_name\", \"layout_data\", \"form\")VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}');",
  60. guid,
  61. batchId,
  62. jobName,
  63. recipeName,
  64. layoutName,
  65. layoutData,
  66. form);
  67. DB.Insert(sql);
  68. }
  69. public static void StartPJ(string guid)
  70. {
  71. string sql = string.Format("UPDATE \"pj_data\" SET \"start_time\"='{0}' WHERE \"guid\"='{1}';",
  72. DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
  73. guid);
  74. DB.Insert(sql);
  75. }
  76. public static void UpdatePJ(string guid,string layoutData, string waferData, int totalWafer)
  77. {
  78. string sql = string.Format("UPDATE \"pj_data\" SET \"layout_data\"='{0}', \"wafer_data\"='{1}', \"total_wafer_count\"='{2}' WHERE \"guid\"='{3}';",
  79. layoutData,
  80. waferData,
  81. totalWafer,
  82. guid);
  83. DB.Insert(sql);
  84. }
  85. public static void EndPJ(string guid, string form)
  86. {
  87. string sql = string.Format("UPDATE \"pj_data\" SET \"form\"='{0}', \"end_time\"='{1}' WHERE \"guid\"='{2}';",
  88. form,
  89. DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss.fff"),
  90. guid);
  91. DB.Insert(sql);
  92. }
  93. }
  94. }