WCS_TaskExtensions.cs 1.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. using DBHelper;
  2. using System;
  3. using WCS.Entity;
  4. using WCS.Entity.Protocol;
  5. using WCS.Service.Log;
  6. namespace WCS.Service.Extensions
  7. {
  8. public static class WCS_TaskExtensions
  9. {
  10. /// <summary>
  11. /// 任务发生状态变更时,为任务新增状态变更记录
  12. /// </summary>
  13. /// <param name="task">对应任务</param>
  14. /// <param name="db">db链接, 没有从新构造一个db的原因是为了保证状态记录的增加与任务状态的变更是同步的</param>
  15. /// <param name="msg">需要记录的消息</param>
  16. public static void CreateStatusLog(this WCS_TASK task, DB db, string msg, Type cl)
  17. {
  18. try
  19. {
  20. WCS_StatusLog statusLog = new WCS_StatusLog()
  21. {
  22. WCS_TASKID = task.ID,
  23. NewStatus = task.STATUS,
  24. UPDATETIME = DateTime.Now,
  25. upStatus = task.UPLOADED,
  26. Node = cl.FullName,
  27. UPDATEUSER = "WCS",
  28. msg = msg,
  29. };
  30. db.Default.Add(statusLog);
  31. }
  32. catch (Exception e)
  33. {
  34. Console.WriteLine(e.Message);
  35. }
  36. }
  37. public static void infolog(this string code, string msg)
  38. {
  39. if (code == "G1190")
  40. {
  41. InfoLog.INFO_ERRORCHECK(msg);
  42. //InfoLog.INFO_ERRORCHECK($"{res.WMSTaskGroupKey}第一次分配:WMS返回{JsonConvert.SerializeObject(tunnels)}。");
  43. //InfoLog.INFO_ERRORCHECK($"{res.WMSTaskGroupKey}第一次分配:WCS选择{tunnelInfo.Tunnel.CODE}。");
  44. }
  45. }
  46. }
  47. }