|
@@ -2,21 +2,21 @@
|
|
|
|
|
|
namespace App\Console\Commands;
|
|
namespace App\Console\Commands;
|
|
|
|
|
|
-use App\Components\Helpers;
|
|
|
|
use App\Models\Config;
|
|
use App\Models\Config;
|
|
use App\Models\Coupon;
|
|
use App\Models\Coupon;
|
|
use App\Models\Invite;
|
|
use App\Models\Invite;
|
|
use App\Models\Order;
|
|
use App\Models\Order;
|
|
use App\Models\User;
|
|
use App\Models\User;
|
|
|
|
+use App\Models\UserSubscribe;
|
|
use App\Models\VerifyCode;
|
|
use App\Models\VerifyCode;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Database\Eloquent\Builder;
|
|
use Illuminate\Database\Eloquent\Builder;
|
|
use Log;
|
|
use Log;
|
|
|
|
|
|
-class AutoJob extends Command
|
|
|
|
|
|
+class TaskAuto extends Command
|
|
{
|
|
{
|
|
- protected $signature = 'autoJob';
|
|
|
|
- protected $description = '自动化任务';
|
|
|
|
|
|
+ protected $signature = 'task:auto';
|
|
|
|
+ protected $description = '自动任务';
|
|
|
|
|
|
/*
|
|
/*
|
|
* 警告:除非熟悉业务流程,否则不推荐更改以下执行顺序,随意变更以下顺序可能导致系统异常
|
|
* 警告:除非熟悉业务流程,否则不推荐更改以下执行顺序,随意变更以下顺序可能导致系统异常
|
|
@@ -25,38 +25,36 @@ class AutoJob extends Command
|
|
{
|
|
{
|
|
$jobTime = microtime(true);
|
|
$jobTime = microtime(true);
|
|
|
|
|
|
- Order::recentUnPay()->chunk(config('tasks.chunk'), function ($orders) {
|
|
|
|
- $orders->each->close();
|
|
|
|
- }); // 关闭超时未支付本地订单
|
|
|
|
-
|
|
|
|
- Order::whereStatus(1)->where('created_at', '<=', date('Y-m-d H:i:s', strtotime('-'.config('tasks.close.confirmation_orders').' hours')))->chunk(config('tasks.chunk'), function ($orders) {
|
|
|
|
- $orders->each->close();
|
|
|
|
- }); // 关闭未处理的人工支付订单
|
|
|
|
-
|
|
|
|
- $this->expireCode(); //过期验证码、优惠券、邀请码无效化
|
|
|
|
-
|
|
|
|
|
|
+ $this->orderTimer(); // 超时订单
|
|
|
|
+ $this->expireCode(); // 过期验证码、优惠券、邀请码无效化
|
|
if (sysConfig('is_subscribe_ban')) {
|
|
if (sysConfig('is_subscribe_ban')) {
|
|
- $this->blockSubscribe(); // 封禁访问异常的订阅链接
|
|
|
|
|
|
+ $this->blockSubscribes(); // 封禁访问异常的订阅
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+ $this->unblockSubscribes(); // 解禁订阅
|
|
$this->blockUsers(); // 封禁账号
|
|
$this->blockUsers(); // 封禁账号
|
|
$this->unblockUsers(); // 解封被封禁的账号
|
|
$this->unblockUsers(); // 解封被封禁的账号
|
|
|
|
|
|
- if (sysConfig('auto_release_port')) {
|
|
|
|
- $this->dispatchPort(); // 端口回收与再分配
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- if (sysConfig('maintenance_mode') && sysConfig('maintenance_time') && sysConfig('maintenance_time') <= date('c')) {// 检查维护模式
|
|
|
|
- Config::whereIn('name', ['maintenance_mode', 'maintenance_content', 'maintenance_time'])->update(['value' => null]);
|
|
|
|
|
|
+ if (sysConfig('maintenance_mode') && sysConfig('maintenance_time') && sysConfig('maintenance_time') <= date('c')) { // 检查维护模式
|
|
|
|
+ Config::whereIn('name', ['maintenance_mode', 'maintenance_time'])->update(['value' => null]);
|
|
}
|
|
}
|
|
|
|
|
|
$jobTime = round(microtime(true) - $jobTime, 4);
|
|
$jobTime = round(microtime(true) - $jobTime, 4);
|
|
-
|
|
|
|
- Log::info('---【'.$this->description.'】完成---,耗时'.$jobTime.'秒');
|
|
|
|
|
|
+ Log::info(__('----「:job」Completed, Used :time seconds ----', ['job' => $this->description, 'time' => $jobTime]));
|
|
}
|
|
}
|
|
|
|
|
|
- private function expireCode()// 注册验证码自动置无效 & 优惠券无效化
|
|
|
|
|
|
+ private function orderTimer()
|
|
{
|
|
{
|
|
|
|
+ Order::recentUnPay()->chunk(config('tasks.chunk'), function ($orders) {
|
|
|
|
+ $orders->each->close();
|
|
|
|
+ }); // 关闭超时未支付本地订单
|
|
|
|
+
|
|
|
|
+ Order::whereStatus(1)->where('created_at', '<=', date('Y-m-d H:i:s', strtotime('-'.config('tasks.close.confirmation_orders').' hours')))->chunk(config('tasks.chunk'), function ($orders) {
|
|
|
|
+ $orders->each->close();
|
|
|
|
+ }); // 关闭未处理的人工支付订单
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private function expireCode()
|
|
|
|
+ { // 注册验证码自动置无效 & 优惠券无效化
|
|
// 注册验证码自动置无效
|
|
// 注册验证码自动置无效
|
|
VerifyCode::recentUnused()->update(['status' => 2]);
|
|
VerifyCode::recentUnused()->update(['status' => 2]);
|
|
|
|
|
|
@@ -74,42 +72,46 @@ class AutoJob extends Command
|
|
->update(['status' => 2]);
|
|
->update(['status' => 2]);
|
|
}
|
|
}
|
|
|
|
|
|
- private function blockSubscribe()// 封禁访问异常的订阅链接
|
|
|
|
- {
|
|
|
|
- $subscribe_ban_times = sysConfig('subscribe_ban_times');
|
|
|
|
|
|
+ private function blockSubscribes()
|
|
|
|
+ { // 封禁访问异常的订阅链接
|
|
User::activeUser()
|
|
User::activeUser()
|
|
->with(['subscribe', 'subscribeLogs'])
|
|
->with(['subscribe', 'subscribeLogs'])
|
|
->whereHas('subscribe', function (Builder $query) {
|
|
->whereHas('subscribe', function (Builder $query) {
|
|
- $query->whereStatus(0); // 获取有订阅且未被封禁用户
|
|
|
|
|
|
+ $query->whereStatus(1); // 获取有订阅且未被封禁用户
|
|
})
|
|
})
|
|
- ->chunk(config('tasks.chunk'), function ($users) use ($subscribe_ban_times) {
|
|
|
|
|
|
+ ->whereHas('subscribeLogs', function (Builder $query) {
|
|
|
|
+ $query->where('request_time', '>=', date('Y-m-d H:i:s', strtotime('-1 day'))); // ->distinct()->count('request_ip');
|
|
|
|
+ }, '>=', sysConfig('subscribe_ban_times'))
|
|
|
|
+ ->chunk(config('tasks.chunk'), function ($users) {
|
|
|
|
+ $trafficBanTime = sysConfig('traffic_ban_time');
|
|
|
|
+ $ban_time = strtotime($trafficBanTime.' minutes');
|
|
|
|
+ $dirtyWorks = ['status' => 0, 'ban_time' => $ban_time, 'ban_desc' => 'Subscription link receive abnormal access and banned by the system'];
|
|
|
|
+ $banMsg = ['time' => $trafficBanTime, 'description' => __('[Auto Job] Blocked Subscription: Subscription with abnormal requests within 24 hours')];
|
|
foreach ($users as $user) {
|
|
foreach ($users as $user) {
|
|
- // 24小时内不同IP的请求次数
|
|
|
|
- $request_times = $user->subscribeLogs()
|
|
|
|
- ->where('request_time', '>=', date('Y-m-d H:i:s', strtotime('-1 days')))
|
|
|
|
- ->distinct()
|
|
|
|
- ->count('request_ip');
|
|
|
|
- if ($request_times >= $subscribe_ban_times) {
|
|
|
|
- $user->subscribe->update([
|
|
|
|
- 'status' => 0,
|
|
|
|
- 'ban_time' => strtotime(sysConfig('traffic_ban_time').' minutes'),
|
|
|
|
- 'ban_desc' => '存在异常,自动封禁',
|
|
|
|
- ]);
|
|
|
|
- $user->banedLogs()->create(['description' => '【完全封禁订阅】-订阅24小时内请求异常']); // 记录封禁日志
|
|
|
|
- }
|
|
|
|
|
|
+ $user->subscribe->update($dirtyWorks);
|
|
|
|
+ $user->banedLogs()->create($banMsg); // 记录封禁日志
|
|
}
|
|
}
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
|
|
- private function blockUsers()// 封禁账号
|
|
|
|
|
|
+ private function unblockSubscribes()
|
|
{
|
|
{
|
|
|
|
+ UserSubscribe::whereStatus(0)->where('ban_time', '<=', time())->chunk(config('tasks.chunk'), function ($subscribes) {
|
|
|
|
+ foreach ($subscribes as $subscribe) {
|
|
|
|
+ $subscribe->update(['status' => 1, 'ban_time' => null, 'ban_desc' => null]);
|
|
|
|
+ }
|
|
|
|
+ });
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private function blockUsers()
|
|
|
|
+ { // 封禁账号
|
|
// 禁用流量超限用户
|
|
// 禁用流量超限用户
|
|
User::activeUser()
|
|
User::activeUser()
|
|
->whereRaw('u + d >= transfer_enable')
|
|
->whereRaw('u + d >= transfer_enable')
|
|
->chunk(config('tasks.chunk'), function ($users) {
|
|
->chunk(config('tasks.chunk'), function ($users) {
|
|
foreach ($users as $user) {
|
|
foreach ($users as $user) {
|
|
$user->update(['enable' => 0]);
|
|
$user->update(['enable' => 0]);
|
|
- $user->banedLogs()->create(['description' => '【封禁代理】-流量已用完']); // 写入日志
|
|
|
|
|
|
+ $user->banedLogs()->create(['description' => __('[Auto Job] Blocked service: Run out of traffic')]); // 写入日志
|
|
}
|
|
}
|
|
});
|
|
});
|
|
|
|
|
|
@@ -119,34 +121,31 @@ class AutoJob extends Command
|
|
User::activeUser()
|
|
User::activeUser()
|
|
->whereBanTime(null)
|
|
->whereBanTime(null)
|
|
->chunk(config('tasks.chunk'), function ($users) use ($trafficBanTime) {
|
|
->chunk(config('tasks.chunk'), function ($users) use ($trafficBanTime) {
|
|
|
|
+ $ban_time = strtotime($trafficBanTime.' minutes');
|
|
foreach ($users as $user) {
|
|
foreach ($users as $user) {
|
|
// 多往前取5分钟,防止数据统计任务执行时间过长导致没有数据
|
|
// 多往前取5分钟,防止数据统计任务执行时间过长导致没有数据
|
|
if ($user->isTrafficWarning()) {
|
|
if ($user->isTrafficWarning()) {
|
|
- $user->update([
|
|
|
|
- 'enable' => 0,
|
|
|
|
- 'ban_time' => strtotime($trafficBanTime.' minutes'),
|
|
|
|
- ]);
|
|
|
|
- $user->banedLogs()->create(['time' => $trafficBanTime, 'description' => '【临时封禁代理】-1小时内流量异常']); // 写入日志
|
|
|
|
|
|
+ $user->update(['enable' => 0, 'ban_time' => $ban_time]);
|
|
|
|
+ $user->banedLogs()->create(['time' => $trafficBanTime, 'description' => __('[Auto Job] Blocked service: Abnormal traffic within 1 hour')]); // 写入日志
|
|
}
|
|
}
|
|
}
|
|
}
|
|
});
|
|
});
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- private function unblockUsers()// 解封被临时封禁的账号
|
|
|
|
- {
|
|
|
|
|
|
+ private function unblockUsers()
|
|
|
|
+ { // 解封账号
|
|
// 解封被临时封禁的账号
|
|
// 解封被临时封禁的账号
|
|
User::bannedUser()
|
|
User::bannedUser()
|
|
- ->whereNotNull('ban_time')
|
|
|
|
->where('ban_time', '<', time())
|
|
->where('ban_time', '<', time())
|
|
->chunk(config('tasks.chunk'), function ($users) {
|
|
->chunk(config('tasks.chunk'), function ($users) {
|
|
foreach ($users as $user) {
|
|
foreach ($users as $user) {
|
|
$user->update(['enable' => 1, 'ban_time' => null]);
|
|
$user->update(['enable' => 1, 'ban_time' => null]);
|
|
- $user->banedLogs()->create(['description' => '【自动解封】-临时封禁到期']); // 写入操作日志
|
|
|
|
|
|
+ $user->banedLogs()->create(['description' => '[自动任务]解封服务: 封禁到期']); // 写入操作日志
|
|
}
|
|
}
|
|
});
|
|
});
|
|
|
|
|
|
- // 可用流量大于已用流量也解封(比如:邀请返利自动加了流量)
|
|
|
|
|
|
+ // 可用流量大于已用流量也解封(比如:邀请返利加了流量)
|
|
User::bannedUser()
|
|
User::bannedUser()
|
|
->whereBanTime(null)
|
|
->whereBanTime(null)
|
|
->where('expired_at', '>=', date('Y-m-d'))
|
|
->where('expired_at', '>=', date('Y-m-d'))
|
|
@@ -154,28 +153,8 @@ class AutoJob extends Command
|
|
->chunk(config('tasks.chunk'), function ($users) {
|
|
->chunk(config('tasks.chunk'), function ($users) {
|
|
foreach ($users as $user) {
|
|
foreach ($users as $user) {
|
|
$user->update(['enable' => 1]);
|
|
$user->update(['enable' => 1]);
|
|
- $user->banedLogs()->create(['description' => '【自动解封】-有流量解封']); // 写入操作日志
|
|
|
|
|
|
+ $user->banedLogs()->create(['description' => '[自动任务]解封服务: 出现可用流量']); // 写入操作日志
|
|
}
|
|
}
|
|
});
|
|
});
|
|
}
|
|
}
|
|
-
|
|
|
|
- // 端口回收与分配
|
|
|
|
- private function dispatchPort()
|
|
|
|
- {
|
|
|
|
- // 自动分配端口
|
|
|
|
- User::activeUser()
|
|
|
|
- ->wherePort(0)
|
|
|
|
- ->chunk(config('tasks.chunk'), function ($users) {
|
|
|
|
- foreach ($users as $user) {
|
|
|
|
- $user->update(['port' => Helpers::getPort()]);
|
|
|
|
- }
|
|
|
|
- });
|
|
|
|
-
|
|
|
|
- // 被封禁 / 过期xx天 的账号自动释放端口
|
|
|
|
- User::where('port', '<>', 0)
|
|
|
|
- ->where(function ($query) {
|
|
|
|
- $query->whereStatus(-1)->orWhere('expired_at', '<=', date('Y-m-d', strtotime('-'.config('tasks.release_port').' days')));
|
|
|
|
- })
|
|
|
|
- ->update(['port' => 0]);
|
|
|
|
- }
|
|
|
|
}
|
|
}
|