TaskSubscribe.php 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. <?php
  2. namespace crmeb\subscribes;
  3. use app\admin\model\system\SystemAttachment;
  4. use app\models\store\StoreBargainUser;
  5. use app\models\store\StoreOrder;
  6. use app\models\store\StorePink;
  7. use app\models\user\UserToken;
  8. use think\facade\Db;
  9. use think\facade\Log;
  10. /**
  11. * 定时任务类
  12. * Class TaskSubscribe
  13. * @package crmeb\subscribes
  14. */
  15. class TaskSubscribe
  16. {
  17. public function handle()
  18. {
  19. }
  20. /**
  21. * 2秒钟执行的方法
  22. */
  23. public function onTask_2()
  24. {
  25. }
  26. /**
  27. * 6秒钟执行的方法
  28. */
  29. public function onTask_6()
  30. {
  31. }
  32. /**
  33. * 10秒钟执行的方法
  34. */
  35. public function onTask_10()
  36. {
  37. }
  38. /**
  39. * 30秒钟执行的方法
  40. */
  41. public function onTask_30()
  42. {
  43. try {
  44. Db::startTrans();
  45. StoreBargainUser::startBargainUserStatus();//批量修改砍价状态为 砍价失败
  46. Db::commit();
  47. } catch (\Exception $e) {
  48. Log::error('startBargainUserStatus:' . $e->getMessage());
  49. Db::rollback();
  50. }
  51. try {
  52. Db::startTrans();
  53. StoreOrder::orderUnpaidCancel();//订单未支付默认取消
  54. Db::commit();
  55. } catch (\Exception $e) {
  56. Log::error('orderUnpaidCancel:' . $e->getMessage());
  57. Db::rollback();
  58. }
  59. try {
  60. Db::startTrans();
  61. StoreOrder::startTakeOrder();//7天自动收货
  62. Db::commit();
  63. } catch (\Exception $e) {
  64. Log::error('startTakeOrder:' . $e->getMessage());
  65. Db::rollback();
  66. }
  67. try {
  68. Db::startTrans();
  69. StorePink::statusPink();//拼团到期修改状态
  70. Db::commit();
  71. } catch (\Exception $e) {
  72. Log::error('statusPink:' . $e->getMessage());
  73. Db::rollback();
  74. }
  75. }
  76. /**
  77. * 60秒钟执行的方法
  78. */
  79. public function onTask_60()
  80. {
  81. }
  82. /**
  83. * 180秒钟执行的方法
  84. */
  85. public function onTask_180()
  86. {
  87. }
  88. /**
  89. * 300秒钟执行的方法
  90. */
  91. public function onTask_300()
  92. {
  93. UserToken::delToken();//删除一天前的过期token
  94. SystemAttachment::emptyYesterdayAttachment();//清除昨日海报
  95. StoreOrder::sendTen();//10分钟未付款发送通知
  96. }
  97. }