DailyJob.php 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130
  1. <?php
  2. namespace App\Console\Commands;
  3. use App\Components\Helpers;
  4. use App\Models\Order;
  5. use App\Models\Ticket;
  6. use App\Models\User;
  7. use App\Notifications\TicketClosed;
  8. use App\Services\OrderService;
  9. use Illuminate\Console\Command;
  10. use Log;
  11. class DailyJob extends Command
  12. {
  13. protected $signature = 'dailyJob';
  14. protected $description = '每日任务';
  15. public function handle(): void
  16. {
  17. $jobStartTime = microtime(true);
  18. // 过期用户处理
  19. $this->expireUser();
  20. // 关闭超过72小时未处理的工单
  21. $this->closeTickets();
  22. // 重置用户流量
  23. if (sysConfig('reset_traffic')) {
  24. $this->resetUserTraffic();
  25. }
  26. $jobEndTime = microtime(true);
  27. $jobUsedTime = round(($jobEndTime - $jobStartTime), 4);
  28. Log::info('---【'.$this->description.'】完成---,耗时'.$jobUsedTime.'秒');
  29. }
  30. private function expireUser(): void
  31. {
  32. // 过期用户处理
  33. $userList = User::activeUser()->where('expired_at', '<', date('Y-m-d H:i:s'))->get();
  34. $isBanStatus = sysConfig('is_ban_status');
  35. foreach ($userList as $user) {
  36. if ($isBanStatus) {
  37. $user->update([
  38. 'u' => 0,
  39. 'd' => 0,
  40. 'transfer_enable' => 0,
  41. 'enable' => 0,
  42. 'level' => 0,
  43. 'reset_time' => null,
  44. 'ban_time' => null,
  45. 'status' => -1,
  46. ]);
  47. Helpers::addUserBanLog($user->id, 0, '【禁止登录,清空账户】-账号已过期');
  48. // 废除其名下邀请码
  49. $user->invites()->whereStatus(0)->update(['status' => 2]);
  50. // 写入用户流量变动记录
  51. Helpers::addUserTrafficModifyLog($user->id, null, $user->transfer_enable, 0, '[定时任务]账号已过期(禁止登录,清空账户)');
  52. } else {
  53. $user->update([
  54. 'u' => 0,
  55. 'd' => 0,
  56. 'transfer_enable' => 0,
  57. 'enable' => 0,
  58. 'level' => 0,
  59. 'reset_time' => null,
  60. 'ban_time' => null,
  61. ]);
  62. Helpers::addUserBanLog($user->id, 0, '【封禁代理,清空账户】-账号已过期');
  63. // 写入用户流量变动记录
  64. Helpers::addUserTrafficModifyLog($user->id, null, $user->transfer_enable, 0, '[定时任务]账号已过期(封禁代理,清空账户)');
  65. }
  66. }
  67. }
  68. // 关闭超过72小时未处理的工单
  69. private function closeTickets(): void
  70. {
  71. foreach (Ticket::where('updated_at', '<=', date('Y-m-d', strtotime('-3 days')))->whereStatus(1)->get() as $ticket) {
  72. if ($ticket->close()) {
  73. $ticket->user->notify(new TicketClosed($ticket->id, $ticket->title, route('replyTicket', ['id' => $ticket->id]), __('You have not responded this ticket in :num hours, System has auto closed your ticket.', ['num' => '72'])));
  74. }
  75. }
  76. }
  77. // 重置用户流量
  78. private function resetUserTraffic(): void
  79. {
  80. $userList = User::where('status', '<>', -1)
  81. ->where('expired_at', '>', date('Y-m-d H:i:s'))
  82. ->where('reset_time', '<=', date('Y-m-d H:i:s'))
  83. ->get();
  84. foreach ($userList as $user) {
  85. // 跳过 没有重置日期的账号
  86. if (! $user->reset_time) {
  87. continue;
  88. }
  89. // 取出用户正在使用的套餐
  90. $order = Order::userActivePlan($user->id)->first();
  91. // 无订单用户跳过
  92. if (! $order) {
  93. continue;
  94. }
  95. // 过期生效中的加油包
  96. Order::userActivePackage($user->id)->update(['is_expire' => 1]);
  97. $oldData = $user->transfer_enable;
  98. // 重置流量与重置日期
  99. $ret = $user->update((new OrderService($order))->resetTimeAndData($user->expired_at));
  100. if ($ret) {
  101. // 可用流量变动日志
  102. Helpers::addUserTrafficModifyLog($order->user_id, $order->id, $oldData, $user->transfer_enable, '【流量重置】重置可用流量');
  103. Log::info('用户[ID:'.$user->id.' 昵称: '.$user->username.' 邮箱: '.$user->email.'] 流量重置为 '.flowAutoShow($user->transfer_enable).'. 重置日期为 '.($user->reset_time ?: '【无】'));
  104. } else {
  105. Log::warning('用户[ID:'.$user->id.' 昵称: '.$user->username.' 邮箱: '.$user->email.'] 流量重置失败');
  106. }
  107. }
  108. }
  109. }