TaskSubscribe.php 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173
  1. <?php
  2. namespace crmeb\subscribes;
  3. use app\admin\model\system\SystemAttachment;
  4. use app\models\manage\UserBorrowMoney;
  5. use app\models\manage\UserManageMoney;
  6. use app\models\mining\UserMiningMachine;
  7. use app\models\point_plan\UserPointPlan;
  8. use app\models\store\StoreBargainUser;
  9. use app\models\store\StoreOrder;
  10. use app\models\store\StorePink;
  11. use app\models\trade\CashTradeOrder;
  12. use app\models\user\UserToken;
  13. use app\models\vote\VoteSub;
  14. use think\facade\Db;
  15. /**
  16. * 定时任务类
  17. * Class TaskSubscribe
  18. * @package crmeb\subscribes
  19. */
  20. class TaskSubscribe
  21. {
  22. public function handle()
  23. {
  24. }
  25. /**
  26. * 2秒钟执行的方法
  27. */
  28. public function onTask_2()
  29. {
  30. }
  31. /**
  32. * 6秒钟执行的方法
  33. */
  34. public function onTask_6()
  35. {
  36. }
  37. /**
  38. * 10秒钟执行的方法
  39. */
  40. public function onTask_10()
  41. {
  42. try {
  43. Db::startTrans();
  44. VoteSub::checkAllStop();//拼团到期修改状态
  45. Db::commit();
  46. } catch (\Exception $e) {
  47. Db::rollback();
  48. }
  49. try {
  50. Db::startTrans();
  51. VoteSub::robotOrder();
  52. Db::commit();
  53. } catch (\Exception $e) {
  54. Db::rollback();
  55. }
  56. }
  57. /**
  58. * 30秒钟执行的方法
  59. */
  60. public function onTask_30()
  61. {
  62. try {
  63. Db::startTrans();
  64. StoreBargainUser::startBargainUserStatus();//批量修改砍价状态为 砍价失败
  65. Db::commit();
  66. } catch (\Exception $e) {
  67. Db::rollback();
  68. }
  69. try {
  70. Db::startTrans();
  71. StoreOrder::orderUnpaidCancel();//订单未支付默认取消
  72. Db::commit();
  73. } catch (\Exception $e) {
  74. Db::rollback();
  75. }
  76. try {
  77. Db::startTrans();
  78. StoreOrder::startTakeOrder();//7天自动收货
  79. Db::commit();
  80. } catch (\Exception $e) {
  81. Db::rollback();
  82. }
  83. try {
  84. Db::startTrans();
  85. StorePink::statusPink();//拼团到期修改状态
  86. Db::commit();
  87. } catch (\Exception $e) {
  88. Db::rollback();
  89. }
  90. try {
  91. Db::startTrans();
  92. UserPointPlan::day_release();//每日释放
  93. Db::commit();
  94. } catch (\Exception $e) {
  95. Db::rollback();
  96. }
  97. try {
  98. Db::startTrans();
  99. UserPointPlan::checkFail();//每日释放
  100. Db::commit();
  101. } catch (\Exception $e) {
  102. Db::rollback();
  103. }
  104. try {
  105. Db::startTrans();
  106. CashTradeOrder::getBack();//挂出结束退回
  107. Db::commit();
  108. } catch (\Exception $e) {
  109. Db::rollback();
  110. }
  111. try {
  112. Db::startTrans();
  113. CashTradeOrder::orderClose();//挂出结束退回
  114. Db::commit();
  115. } catch (\Exception $e) {
  116. Db::rollback();
  117. }
  118. try {
  119. Db::startTrans();
  120. UserMiningMachine::dayMining();//每日挖矿
  121. Db::commit();
  122. } catch (\Exception $e) {
  123. Db::rollback();
  124. }
  125. try {
  126. Db::startTrans();
  127. UserManageMoney::daySend();
  128. Db::commit();
  129. } catch (\Exception $e) {
  130. Db::rollback();
  131. }
  132. try {
  133. Db::startTrans();
  134. UserBorrowMoney::daySend();
  135. Db::commit();
  136. } catch (\Exception $e) {
  137. Db::rollback();
  138. }
  139. }
  140. /**
  141. * 60秒钟执行的方法
  142. */
  143. public function onTask_60()
  144. {
  145. }
  146. /**
  147. * 180秒钟执行的方法
  148. */
  149. public function onTask_180()
  150. {
  151. }
  152. /**
  153. * 300秒钟执行的方法
  154. */
  155. public function onTask_300()
  156. {
  157. UserToken::delToken();//删除一天前的过期token
  158. SystemAttachment::emptyYesterdayAttachment();//清除昨日海报
  159. StoreOrder::sendTen();//10分钟未付款发送通知
  160. }
  161. }