Uploader.cs 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. using DbHelper;
  2. using Log;
  3. using System;
  4. using WCS.Entity;
  5. using WCS.WebApi.WMS;
  6. namespace WCS.Service
  7. {
  8. public class Uploader
  9. {
  10. public static void Upload(Db db)
  11. {
  12. try
  13. {
  14. var tasks = db.Default.Queryable<WCS_TASK>().Where(v => v.WMSTASK > 0)
  15. .Where(v => v.STATUS != v.UPLOADED).ToArray();
  16. foreach (var task in tasks)
  17. {
  18. try
  19. {
  20. WMS.UpdateTask(task.ADDRNEXT, task.WMSTASK, (int)task.STATUS, task.HEIGHT);
  21. var st = task.UPLOADED;
  22. task.UPLOADED = task.STATUS;
  23. InfoLog.INFO_SYTASKSTATUS($"[{task.ID}]---old:[{st}]-new:[{task.UPLOADED}]---{task.HEIGHT}");
  24. }
  25. catch (Exception ex)
  26. {
  27. Console.WriteLine($"上传任务状态失败:WCS任务号{task.ID},{ex.Message}");
  28. }
  29. }
  30. db.Default.Updateable(tasks).ExecuteCommand();
  31. }
  32. catch
  33. {
  34. // ignored
  35. }
  36. }
  37. }
  38. }