GoodsCode_DM.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578
  1. 
  2. using System;
  3. using System.Collections.Generic;
  4. using System.ComponentModel;
  5. using System.Data;
  6. using Curtain.DataAccess;
  7. using Curtain.Extension.ExObjectConvert;
  8. using Curtain.Extension.ExSystemData;
  9. using Curtain.Framework.Json;
  10. using Curtain.Helpers;
  11. using Curtain.Log;
  12. using Curtain.Net.Sockets.PLC;
  13. using Curtain.Net.Sockets.PLC.Model;
  14. using Curtain.Net.Sockets.PLC.Model.Siemens;
  15. using PLC_S.Proxy;
  16. namespace PLC_S.ServerModel
  17. {
  18. /// <summary>
  19. /// 返回产品型号等信息(打磨 条码+型号)
  20. /// </summary>
  21. public class GoodsCode_DM : SocketServer<SimpleSocketServerModel>, IShowFormLog, IWindowsServer
  22. {
  23. public Dictionary<string, PLC_S_GC_DM> PLC_FLAGS = new Dictionary<string, PLC_S_GC_DM>();
  24. public const string M_NAME = "GC_DM";
  25. private MES_S _mes_s = null;
  26. private readonly Logger logger = Logger.CreateLogger(M_NAME);
  27. private readonly LogInfo logger_t = new LogInfo();
  28. private readonly LogInfo logger_e = new LogInfo();
  29. private bool _S_STOP = false;
  30. public int Interval
  31. {
  32. get;
  33. set;
  34. }
  35. public string EPTS_CODE
  36. {
  37. get;
  38. set;
  39. }
  40. public GoodsCode_DM()
  41. {
  42. logger.FileExistDays = 30;
  43. logger.FilePrefix = "";
  44. logger.FileSuffix = M_NAME;
  45. logger.LevelOneFile = true;
  46. logger.FileNameWithoutDate = true;
  47. logger_t.SubFolderFormat = "<name>";
  48. logger_t.FileExistDays = 30;
  49. logger_t.LevelOneFile = true;
  50. logger_e.FileExistDays = 10;
  51. this.Model.FormatType = CommandFormatType.StartStopChar;
  52. this.ServerStarting += ServerSocket_ServerStarting;
  53. this.ServerStarted += ServerSocket_ServerStarted;
  54. this.ServerStoping += ServerSocket_ServerStoping;
  55. this.ServerStoped += ServerSocket_ServerStoped;
  56. this.ServerMessage += ServerSocket_ServerMessage;
  57. this.Received += ServerSocket_Received;
  58. _mes_s = MES_S.Get();
  59. }
  60. #region Server
  61. public IFormLogShow FormLogShow
  62. {
  63. get;
  64. set;
  65. }
  66. private void ServerSocket_ServerStarting(object sender, CancelEventArgs e)
  67. {
  68. try
  69. {
  70. _S_STOP = false;
  71. logger.OutputTrace($"{M_NAME}_ServerStarting");
  72. }
  73. catch { }
  74. }
  75. private void ServerSocket_ServerStarted(object sender, EventArgs e)
  76. {
  77. try
  78. {
  79. _S_STOP = false;
  80. logger.OutputTrace($"{M_NAME}_ServerStarted");
  81. }
  82. catch { }
  83. }
  84. private void ServerSocket_ServerStoping(object sender, CancelEventArgs e)
  85. {
  86. try
  87. {
  88. _S_STOP = false;
  89. logger.OutputTrace($"{M_NAME}_ServerStoping");
  90. }
  91. catch { }
  92. }
  93. private void ServerSocket_ServerStoped(object sender, EventArgs e)
  94. {
  95. try
  96. {
  97. _S_STOP = false;
  98. logger.OutputTrace($"{M_NAME}_ServerStoped");
  99. }
  100. catch { }
  101. }
  102. private void ServerSocket_ServerMessage(object sender, ServerMessageEventArgs e)
  103. {
  104. try
  105. {
  106. _S_STOP = false;
  107. string message = e.ToString();
  108. string cip = e?.Client?.IP;
  109. if (e.Type == ServerMessageType.Debug)
  110. {
  111. Logger.Debug(message, $"{M_NAME}-T[{cip}]", logger_t);
  112. }
  113. if (e.Type == ServerMessageType.Error)
  114. {
  115. Logger.Error(e.Exception, message, $"{M_NAME}-E[{cip}]", logger_e);
  116. }
  117. if (e.Type == ServerMessageType.Trace)
  118. {
  119. Logger.Trace(message, $"{M_NAME}-T[{cip}]", logger_t);
  120. }
  121. if (e.Type == ServerMessageType.Warning)
  122. {
  123. Logger.Warn(message, $"{M_NAME}-E[{cip}]", logger_e);
  124. }
  125. FormLogShow?.ShowLog("ServerMessage=" + message);
  126. }
  127. catch { }
  128. }
  129. #endregion
  130. /// <summary>
  131. /// 返回产品型号
  132. /// </summary>
  133. /// <param name="sender"></param>
  134. /// <param name="e"></param>
  135. private void ServerSocket_Received(object sender, ReceiveSession e)
  136. {
  137. PLC_S_GC_DM plc_s = null;
  138. string cIP = e?.Client?.IP;
  139. string logKeyT = $"{M_NAME}-T[{cIP}]";
  140. string logKeyE = $"{M_NAME}-E[{cIP}]";
  141. _S_STOP = false;
  142. SocketClient<SiemensS7_1200Model> plc = null;
  143. Logger LoggerT = null;
  144. try
  145. {
  146. LoggerT = Logger.CreateLogger(logKeyT, logger_t);
  147. lock (LoggerT)
  148. {
  149. LoggerT.BeginTracking();
  150. string outputMessage = e.ToString();
  151. Logger.Trace(outputMessage, logKeyT, logger_t);
  152. FormLogShow?.ShowLog(outputMessage);
  153. if (string.IsNullOrWhiteSpace(e.Content))
  154. {
  155. outputMessage = "接收数据为空";
  156. Logger.Warn(outputMessage, logKeyT, logger_t);
  157. Logger.Warn(outputMessage, logKeyE, logger_e);
  158. FormLogShow?.ShowLog(outputMessage);
  159. return;
  160. }
  161. outputMessage = e.Content;
  162. Logger.Trace(outputMessage, logKeyT, logger_t);
  163. FormLogShow?.ShowLog(outputMessage);
  164. string[] c = e.Content.Split('#');
  165. string flag = null;
  166. if (c.Length > 0)
  167. {
  168. flag = c[0];
  169. }
  170. string barcode = null;
  171. if (c.Length > 1)
  172. {
  173. barcode = c[1];
  174. }
  175. if (string.IsNullOrWhiteSpace(flag))
  176. {
  177. outputMessage = $"[{e.Content}]接收设备代码为空";
  178. Logger.Warn(outputMessage, logKeyT, logger_t);
  179. Logger.Warn(outputMessage, logKeyE, logger_e);
  180. FormLogShow?.ShowLog(outputMessage);
  181. return;
  182. }
  183. plc_s = GetPLC_S_GC(flag, e, logKeyE);
  184. if (plc_s == null)
  185. {
  186. outputMessage = $"[{e.Content}]设备代码[{flag}]未找到ini配置或有错误";
  187. Logger.Error(null, outputMessage, logKeyT, logger_t);
  188. Logger.Error(null, outputMessage, logKeyE, logger_e);
  189. FormLogShow?.ShowLog(outputMessage);
  190. return;
  191. }
  192. outputMessage = $"[{e.Content}]PLC_Connect={JsonHelper.FromObject(plc_s)}";
  193. Logger.Trace(outputMessage, logKeyT, logger_t);
  194. FormLogShow?.ShowLog(outputMessage);
  195. plc = new SocketClient<SiemensS7_1200Model>();
  196. plc.Connect(plc_s.IP, plc_s.Port);
  197. //outputMessage = $"[{e.Content}]PLC_Connect=[{plc_s.IP}:{plc_s.Port}]";
  198. //Logger.Trace(outputMessage, logKeyT, logger_t);
  199. //FormLogShow?.ShowLog(outputMessage);
  200. if (string.IsNullOrWhiteSpace(barcode) ||
  201. barcode == "0" ||
  202. barcode.Length != 11 ||
  203. barcode.StartsWith("0"))
  204. {
  205. outputMessage = $"[{e.Content}]接收条码格式错误";
  206. Logger.Warn(outputMessage, logKeyT, logger_t);
  207. Logger.Warn(outputMessage, logKeyE, logger_e);
  208. FormLogShow?.ShowLog(outputMessage);
  209. SendError(plc_s, e, logKeyT, logKeyE, plc, false);
  210. return;
  211. }
  212. DataRow codeRow = GetGoodsCode(barcode, e, logKeyE);
  213. if (codeRow == null)
  214. {
  215. outputMessage = $"[{e.Content}]此条码[{barcode}]不存在";
  216. Logger.Warn(outputMessage, logKeyT, logger_t);
  217. Logger.Warn(outputMessage, logKeyE, logger_e);
  218. FormLogShow?.ShowLog(outputMessage);
  219. SendError(plc_s, e, logKeyT, logKeyE, plc);
  220. return;
  221. }
  222. string code = codeRow["goodscode"].ToString();
  223. string intcode = codeRow["seatcovercode"].ToString();
  224. string groutinglinecode = codeRow["groutinglinecode"].ToString();
  225. outputMessage = $"[{e.Content}]产品型号={code}[{intcode}]";
  226. Logger.Trace(outputMessage, logKeyT, logger_t);
  227. FormLogShow?.ShowLog(outputMessage);
  228. if (string.IsNullOrWhiteSpace(intcode))
  229. {
  230. outputMessage = $"[{e.Content}]此条码[{barcode}]未设置型号代码";
  231. Logger.Error(null, outputMessage, logKeyT, logger_t);
  232. Logger.Error(null, outputMessage, logKeyE, logger_e);
  233. FormLogShow?.ShowLog(outputMessage);
  234. SendError(plc_s, e, logKeyT, logKeyE, plc);
  235. return;
  236. }
  237. // 写入PLC 条码
  238. outputMessage = $"[{e.Content}]SET_BarCode=[{barcode}]{plc_s.Add_BarCode + plc_s.Add_BarCodeNum}";
  239. Logger.Trace(outputMessage, logKeyT, logger_t);
  240. FormLogShow?.ShowLog(outputMessage);
  241. PLCResult p_r = plc.Write<string>(plc_s.Add_BarCode, plc_s.Add_BarCodeNum, barcode);
  242. outputMessage = $"[{e.Content}]END_BarCode=[{p_r}]{plc_s.Add_BarCode + plc_s.Add_BarCodeNum}";
  243. Logger.Trace(outputMessage, logKeyT, logger_t);
  244. FormLogShow?.ShowLog(outputMessage);
  245. // 写入PLC 型号
  246. outputMessage = $"[{e.Content}]SET_GoodsCode=[{intcode}]{plc_s.Add_Code + plc_s.Add_CodeNum}";
  247. Logger.Trace(outputMessage, logKeyT, logger_t);
  248. FormLogShow?.ShowLog(outputMessage);
  249. p_r = plc.Write<short>(plc_s.Add_Code, plc_s.Add_CodeNum, (short)(intcode.ToInt32()));
  250. outputMessage = $"[{e.Content}]END_GoodsCode=[{p_r}]{plc_s.Add_Code + plc_s.Add_CodeNum}";
  251. Logger.Trace(outputMessage, logKeyT, logger_t);
  252. FormLogShow?.ShowLog(outputMessage);
  253. // 写入成型线号 6331-6332 20250313 qq
  254. outputMessage = $"[{e.Content}]SET_GROUTINGLINE=[{groutinglinecode}]{plc_s.Add_GroutingLineCode + plc_s.Add_GroutingLineCodeNum}";
  255. Logger.Trace(outputMessage, logKeyT, logger_t);
  256. FormLogShow?.ShowLog(outputMessage);
  257. //p_r = plc.Write<short>(plc_s.Add_GroutingLineCode, "300.26", (short)(groutinglinecode.Length));
  258. p_r = plc.Write<string>(plc_s.Add_GroutingLineCode, plc_s.Add_GroutingLineCodeNum, groutinglinecode);
  259. outputMessage = $"[{e.Content}]END_GROUTINGLINE=[{p_r}]{plc_s.Add_GroutingLineCode + plc_s.Add_GroutingLineCodeNum}";
  260. Logger.Trace(outputMessage, logKeyT, logger_t);
  261. FormLogShow?.ShowLog(outputMessage);
  262. if (flag == "6331" || flag == "31")
  263. {
  264. // 智能线 直接计件
  265. string roomcode = "0#";
  266. // 打磨工号
  267. string usercode = "";
  268. using (IDataAccess dataAccess = PLC_S_DataAccess.GetDataAccess())
  269. {
  270. string sqlString1 = @"
  271. SELECT t.flowprocedureid
  272. FROM tp_pm_inproduction t
  273. WHERE t.barcode = @barcode@
  274. ";
  275. CDAParameter[] ps1 = new CDAParameter[]
  276. {
  277. new CDAParameter("barcode", barcode),
  278. };
  279. string p_id = dataAccess.ExecuteScalar(sqlString1, ps1) + "";
  280. if (p_id != "93")
  281. {
  282. string sqlString = @"
  283. SELECT t.usercode
  284. FROM tp_mst_workstation t
  285. WHERE t.workstationtypeid = 3310
  286. AND t.workstationid = @workstationid@
  287. ";
  288. CDAParameter[] ps = new CDAParameter[]
  289. {
  290. new CDAParameter("workstationid", 31),
  291. };
  292. DataTable dataTable = dataAccess.ExecuteDatatable(sqlString, ps);
  293. if (dataTable.HasData())
  294. {
  295. usercode = dataTable.Rows[0]["usercode"].ToString();
  296. }
  297. outputMessage = $"[{e.Content}]DB_UserCode=[{usercode}]";
  298. //logger_t.OutputTrace(outputMessage);
  299. Logger.Trace(outputMessage, logKeyT, logger_t);
  300. FormLogShow?.ShowLog(outputMessage);
  301. string sql = @"
  302. update tp_pm_groutingdailydetail set
  303. POLISHROOM = :POLISHROOM
  304. WHERE barcode = :barcode";
  305. CDAParameter[] pss = new CDAParameter[]
  306. {
  307. new CDAParameter("POLISHROOM", roomcode),
  308. new CDAParameter("barcode", barcode),
  309. };
  310. dataAccess.ExecuteNonQuery(sql, pss);
  311. outputMessage = $"[{e.Content}]DB_ROOM=[{roomcode}]";
  312. //logger_t.OutputTrace(outputMessage);
  313. Logger.Trace(outputMessage, logKeyT, logger_t);
  314. FormLogShow?.ShowLog(outputMessage);
  315. string result = SmartDeviceProxy.Instance.Invoke<string>(
  316. p => p.AddWorkPieceByStatus3("dongke",
  317. usercode, null, 93, barcode, roomcode));
  318. outputMessage = $"[{e.Content}]MES_Result=[{result}]";
  319. //logger_t.OutputTrace(outputMessage);
  320. Logger.Trace(outputMessage, logKeyT, logger_t);
  321. FormLogShow?.ShowLog(outputMessage);
  322. // 返回状态(成功、失败)
  323. if (result != "OK")
  324. {
  325. if (result == "EE")
  326. {
  327. outputMessage = $"[{e.Content}]result=[{result}]MES服务端异常(详情参见MES端日志)";
  328. }
  329. else if (result == "EU-01")
  330. {
  331. outputMessage = $"[{e.Content}]result=[{result}]无效的帐套或工号(详情参见MES端日志)";
  332. }
  333. else
  334. {
  335. outputMessage = $"[{e.Content}]result=[{result}]其他错误(详情参见MES端日志)";
  336. }
  337. //logger_e_out.OutputError(null, outputMessage);
  338. //logger_t.OutputError(null, outputMessage);
  339. //logger_e.OutputError(null, outputMessage);
  340. Logger.Error(null, outputMessage, logKeyT, logger_t);
  341. Logger.Error(null, outputMessage, logKeyE, logger_e);
  342. FormLogShow?.ShowLog(outputMessage);
  343. //2.状态(int)【1:MES写入完成,2:PLC读取完成,0:PLC复位】
  344. outputMessage = $"[{e.Content}]SET_F_Code=[0]{plc_s.Add_F_Code + plc_s.Add_F_CodeNum}";
  345. Logger.Trace(outputMessage, logKeyT, logger_t);
  346. FormLogShow?.ShowLog(outputMessage);
  347. p_r = plc?.Write<short>(plc_s.Add_F_Code, plc_s.Add_F_CodeNum, (short)0);
  348. outputMessage = $"[{e.Content}]END_F_Code=[{p_r}]{plc_s.Add_F_Code + plc_s.Add_F_CodeNum}";
  349. Logger.Trace(outputMessage, logKeyT, logger_t);
  350. FormLogShow?.ShowLog(outputMessage);
  351. //3.通信异常标识(int)【0:正常,1:后台处理异常,报警】
  352. outputMessage = $"[{e.Content}]SET_ErrorNum=[1]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
  353. Logger.Trace(outputMessage, logKeyT, logger_t);
  354. FormLogShow?.ShowLog(outputMessage);
  355. p_r = plc?.Write<short>(plc_s.Add_Error, plc_s.Add_ErrorNum, (short)1);
  356. outputMessage = $"[{e.Content}]END_ErrorNum=[{p_r}]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
  357. Logger.Trace(outputMessage, logKeyT, logger_t);
  358. FormLogShow?.ShowLog(outputMessage);
  359. return;
  360. }
  361. }
  362. }
  363. }
  364. //2.状态(int)【1:MES写入完成,2:PLC读取完成,0:PLC复位】
  365. outputMessage = $"[{e.Content}]SET_F_Code=[1]{plc_s.Add_F_Code + plc_s.Add_F_CodeNum}";
  366. Logger.Trace(outputMessage, logKeyT, logger_t);
  367. FormLogShow?.ShowLog(outputMessage);
  368. p_r = plc?.Write<short>(plc_s.Add_F_Code, plc_s.Add_F_CodeNum, (short)1);
  369. outputMessage = $"[{e.Content}]END_F_Code=[{p_r}]{plc_s.Add_F_Code + plc_s.Add_F_CodeNum}";
  370. Logger.Trace(outputMessage, logKeyT, logger_t);
  371. FormLogShow?.ShowLog(outputMessage);
  372. //3.通信异常标识(int)【0:正常,1:后台处理异常,报警】
  373. outputMessage = $"[{e.Content}]SET_ErrorNum=[0]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
  374. Logger.Trace(outputMessage, logKeyT, logger_t);
  375. FormLogShow?.ShowLog(outputMessage);
  376. p_r = plc?.Write<short>(plc_s.Add_Error, plc_s.Add_ErrorNum, (short)0);
  377. outputMessage = $"[{e.Content}]END_ErrorNum=[{p_r}]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
  378. Logger.Trace(outputMessage, logKeyT, logger_t);
  379. FormLogShow?.ShowLog(outputMessage);
  380. }
  381. }
  382. catch (Exception ex)
  383. {
  384. FormLogShow?.ShowLog($"[{e.Content}]ERROR={ex.Message}");
  385. if (plc_s != null)
  386. {
  387. Logger.Error(ex, $"[{e.Content}]ERROR", logKeyT, logger_t);
  388. Logger.Error(ex, $"[{e.Content}]ERROR", logKeyE, logger_e);
  389. SendError(plc_s, e, logKeyT, logKeyE, plc);
  390. }
  391. else
  392. {
  393. Logger.Error(ex, $"[{e.Content}]ERROR-NOFLAG", logKeyT, logger_t);
  394. Logger.Error(ex, $"[{e.Content}]ERROR-NOFLAG", logKeyE, logger_e);
  395. }
  396. }
  397. finally
  398. {
  399. LoggerT?.EndTracking();
  400. plc?.Disconnect();
  401. plc?.Close();
  402. //e.ReturnMessage("0000");
  403. }
  404. }
  405. private void SendError(PLC_S_GC_DM plc_s, ReceiveSession e, string loggerNameT,
  406. string loggerNameE, SocketClient<SiemensS7_1200Model> plc, bool isClear = true)
  407. {
  408. try
  409. {
  410. //using (SocketClient<SiemensS7_1200Model> plc = new SocketClient<SiemensS7_1200Model>())
  411. {
  412. string outputMessage;
  413. if (isClear)
  414. {
  415. //// 写入PLC 条码
  416. //outputMessage = $"[{e.Content}]SET_BarCode=[0]{plc_s.Add_BarCode + plc_s.Add_BarCodeNum}";
  417. //Logger.Trace(outputMessage, loggerNameT, logger_t);
  418. //FormLogShow?.ShowLog(outputMessage);
  419. //plc.Write<string>(plc_s.Add_BarCode, plc_s.Add_BarCodeNum, "00000000000");
  420. //outputMessage = $"[{e.Content}]END_BarCode=[0]{plc_s.Add_BarCode + plc_s.Add_BarCodeNum}";
  421. //Logger.Trace(outputMessage, loggerNameT, logger_t);
  422. //FormLogShow?.ShowLog(outputMessage);
  423. // 写入PLC 型号
  424. outputMessage = $"[{e.Content}]SET_GoodsCode=[0]{plc_s.Add_Code + plc_s.Add_CodeNum}";
  425. Logger.Trace(outputMessage, loggerNameT, logger_t);
  426. FormLogShow?.ShowLog(outputMessage);
  427. PLCResult p_r1 = plc.Write<short>(plc_s.Add_Code, plc_s.Add_CodeNum, (short)0);
  428. outputMessage = $"[{e.Content}]END_GoodsCode=[{p_r1}]{plc_s.Add_Code + plc_s.Add_CodeNum}";
  429. Logger.Trace(outputMessage, loggerNameT, logger_t);
  430. FormLogShow?.ShowLog(outputMessage);
  431. ////2.状态(int)【1:MES写入完成,2:PLC读取完成,0:PLC复位】
  432. //outputMessage = $"[{e.Content}]SET_F_Code=[0]{plc_s.Add_F_Code + plc_s.Add_F_CodeNum}";
  433. //Logger.Trace(outputMessage, loggerNameT, logger_t);
  434. //FormLogShow?.ShowLog(outputMessage);
  435. //plc?.Write<short>(plc_s.Add_F_Code, plc_s.Add_F_CodeNum, (short)0);
  436. //outputMessage = $"[{e.Content}]END_F_Code=[0]{plc_s.Add_F_Code + plc_s.Add_F_CodeNum}";
  437. //Logger.Trace(outputMessage, loggerNameT, logger_t);
  438. //FormLogShow?.ShowLog(outputMessage);
  439. }
  440. outputMessage = $"[{e.Content}]SET_ErrorNum=[1]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
  441. Logger.Trace(outputMessage, loggerNameT, logger_t);
  442. FormLogShow?.ShowLog(outputMessage);
  443. PLCResult p_r = plc?.Write<short>(plc_s.Add_Error, plc_s.Add_ErrorNum, (short)1);
  444. outputMessage = $"[{e.Content}]END_ErrorNum=[{p_r}]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
  445. Logger.Trace(outputMessage, loggerNameT, logger_t);
  446. FormLogShow?.ShowLog(outputMessage);
  447. }
  448. }
  449. catch (Exception ex)
  450. {
  451. Logger.Error(ex, $"[{e.Content}]ERROR-SendError", loggerNameT, logger_t);
  452. Logger.Error(ex, $"[{e.Content}]ERROR-SendError", loggerNameE, logger_e);
  453. FormLogShow?.ShowLog($"[{e.Content}]ERROR-SendError={ex.Message}");
  454. }
  455. }
  456. private DataRow GetGoodsCode(string barcode, ReceiveSession e, string loggerName)
  457. {
  458. IDataAccess dataAccess = null;
  459. try
  460. {
  461. dataAccess = PLC_S_DataAccess.GetDataAccess(e);
  462. string sqlString = "select g.goodscode, g.seatcovercode , gdd.groutinglinecode\n" +
  463. " from tp_pm_groutingdailydetail gdd\n" +
  464. " inner join tp_mst_goods g\n" +
  465. " on g.goodsid = gdd.goodsid\n" +
  466. " where gdd.barcode = :barcode";
  467. DataTable dataTable = dataAccess.ExecuteDatatable(sqlString, new CDAParameter(":barcode", barcode));
  468. if (dataTable.HasData())
  469. {
  470. return dataTable.Rows[0];
  471. }
  472. return null;
  473. }
  474. catch (Exception ex)
  475. {
  476. Logger.Error(ex, $"[{e.Content}]ERROR-GetGoodsCode", loggerName, logger_e);
  477. FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetGoodsCode={ex.Message}");
  478. return null;
  479. }
  480. finally
  481. {
  482. dataAccess?.Close();
  483. }
  484. }
  485. private PLC_S_GC_DM GetPLC_S_GC(string flag, ReceiveSession e, string loggerName)
  486. {
  487. try
  488. {
  489. flag = M_NAME + flag;
  490. if (PLC_FLAGS.ContainsKey(flag))
  491. {
  492. return PLC_FLAGS[flag];
  493. }
  494. else
  495. {
  496. PLC_S_GC_DM plc_s = new PLC_S_GC_DM();
  497. INIHelper ini = INIHelper.Create($@"PLC_S_INI\PLC_S_{M_NAME}.ini");
  498. plc_s.IP = ini.Read(flag, "IP");
  499. plc_s.Port = ini.Read(flag, "Port").ToInt32();
  500. plc_s.Add_BarCode = ini.Read(flag, "Add_BarCode");
  501. plc_s.Add_BarCodeNum = ini.Read(flag, "Add_BarCodeNum");
  502. plc_s.Add_Code = ini.Read(flag, "Add_Code");
  503. plc_s.Add_CodeNum = ini.Read(flag, "Add_CodeNum");
  504. plc_s.Add_GroutingLineCode = ini.Read(flag, "Add_GroutingLineCode");
  505. plc_s.Add_GroutingLineCodeNum = ini.Read(flag, "Add_GroutingLineCodeNum");
  506. plc_s.Add_F_Code = ini.Read(flag, "Add_F_Code");
  507. plc_s.Add_F_CodeNum = ini.Read(flag, "Add_F_CodeNum");
  508. plc_s.Add_Error = ini.Read(flag, "Add_Error");
  509. plc_s.Add_ErrorNum = ini.Read(flag, "Add_ErrorNum");
  510. PLC_FLAGS.Add(flag, plc_s);
  511. return plc_s;
  512. }
  513. }
  514. catch (Exception ex)
  515. {
  516. Logger.Error(ex, $"[{e.Content}]ERROR-GetPLC_S_GC", loggerName, logger_e);
  517. FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetPLC_S_GC={ex.Message}");
  518. return null;
  519. }
  520. }
  521. }
  522. }