123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176 |
- <?php
- namespace App\Services;
- use App\Jobs\ServerLogJob;
- use App\Jobs\StatServerJob;
- use App\Jobs\StatUserJob;
- use App\Jobs\TrafficFetchJob;
- use App\Models\InviteCode;
- use App\Models\Order;
- use App\Models\ServerV2ray;
- use App\Models\Ticket;
- use App\Models\User;
- use Illuminate\Support\Facades\DB;
- class UserService
- {
- private function calcResetDayByMonthFirstDay()
- {
- $today = date('d');
- $lastDay = date('d', strtotime('last day of +0 months'));
- return $lastDay - $today;
- }
- private function calcResetDayByExpireDay(int $expiredAt)
- {
- $day = date('d', $expiredAt);
- $today = date('d');
- $lastDay = date('d', strtotime('last day of +0 months'));
- if ((int)$day >= (int)$today && (int)$day >= (int)$lastDay) {
- return $lastDay - $today;
- }
- if ((int)$day >= (int)$today) {
- return $day - $today;
- } else {
- return $lastDay - $today + $day;
- }
- }
- private function calcResetDayByYearFirstDay()
- {
- $nextYear = strtotime(date("Y-01-01", strtotime('+1 year')));
- return (int)(($nextYear - time()) / 86400);
- }
- private function calcResetDayByYearExpiredAt(int $expiredAt)
- {
- $md = date('m-d', $expiredAt);
- $nowYear = strtotime(date("Y-{$md}"));
- $nextYear = strtotime('+1 year', $nowYear);
- return (int)(($nextYear - time()) / 86400);
- }
- public function getResetDay(User $user)
- {
- if ($user->expired_at <= time() || $user->expired_at === NULL) return null;
- // if reset method is not reset
- if (!isset($user->plan->reset_traffic_method)) return null;
- if ($user->plan->reset_traffic_method === 2) return null;
- switch (true) {
- case ($user->plan->reset_traffic_method === NULL): {
- $resetTrafficMethod = config('v2board.reset_traffic_method', 0);
- switch ((int)$resetTrafficMethod) {
- // month first day
- case 0:
- return $this->calcResetDayByMonthFirstDay();
- // expire day
- case 1:
- return $this->calcResetDayByExpireDay($user->expired_at);
- // no action
- case 2:
- return null;
- // year first day
- case 3:
- return $this->calcResetDayByYearFirstDay();
- // year expire day
- case 4:
- return $this->calcResetDayByYearExpiredAt($user->expired_at);
- }
- break;
- }
- case ($user->plan->reset_traffic_method === 0): {
- return $this->calcResetDayByMonthFirstDay();
- }
- case ($user->plan->reset_traffic_method === 1): {
- return $this->calcResetDayByExpireDay($user->expired_at);
- }
- case ($user->plan->reset_traffic_method === 2): {
- return null;
- }
- case ($user->plan->reset_traffic_method === 3): {
- return $this->calcResetDayByYearFirstDay();
- }
- case ($user->plan->reset_traffic_method === 4): {
- return $this->calcResetDayByYearExpiredAt($user->expired_at);
- }
- }
- return null;
- }
- public function isAvailable(User $user)
- {
- if (!$user->banned && $user->transfer_enable && ($user->expired_at > time() || $user->expired_at === NULL)) {
- return true;
- }
- return false;
- }
- public function getAvailableUsers()
- {
- return User::whereRaw('u + d < transfer_enable')
- ->where(function ($query) {
- $query->where('expired_at', '>=', time())
- ->orWhere('expired_at', NULL);
- })
- ->where('banned', 0)
- ->get();
- }
- public function getUnAvailbaleUsers()
- {
- return User::where(function ($query) {
- $query->where('expired_at', '<', time())
- ->orWhere('expired_at', 0);
- })
- ->where(function ($query) {
- $query->where('plan_id', NULL)
- ->orWhere('transfer_enable', 0);
- })
- ->get();
- }
- public function getUsersByIds($ids)
- {
- return User::whereIn('id', $ids)->get();
- }
- public function getAllUsers()
- {
- return User::all();
- }
- public function addBalance(int $userId, int $balance):bool
- {
- $user = User::lockForUpdate()->find($userId);
- if (!$user) {
- return false;
- }
- $user->balance = $user->balance + $balance;
- if ($user->balance < 0) {
- return false;
- }
- if (!$user->save()) {
- return false;
- }
- return true;
- }
- public function isNotCompleteOrderByUserId(int $userId):bool
- {
- $order = Order::whereIn('status', [0, 1])
- ->where('user_id', $userId)
- ->first();
- if (!$order) {
- return false;
- }
- return true;
- }
- public function trafficFetch(int $u, int $d, int $userId, array $server, string $protocol)
- {
- TrafficFetchJob::dispatch($u, $d, $userId, $server, $protocol);
- StatServerJob::dispatch($u, $d, $server, $protocol, 'd');
- StatUserJob::dispatch($u, $d, $userId, $server, $protocol, 'd');
- }
- }
|