mirror of
https://github.com/ProxyPanel/ProxyPanel.git
synced 2026-04-11 23:19:05 +00:00
66c3c53038
1. models 关系规范化； 2. 本地-在线 订单处理改写； 3. 优化用户界面节点的查表操作； 4. 半修复 VNet SSR版需要面板主动提交用户信息变动的问题；（节点等级，用户分组，Node信息修改 主动通知节点尚未添加）； 5. 简化并提取出了 返利佣金相关处理逻辑；
122 lines
3.7 KiB
PHP
122 lines
3.7 KiB
PHP
<?php
|
||
|
||
namespace App\Console\Commands;
|
||
|
||
use App\Components\Helpers;
|
||
use App\Components\NetworkDetection;
|
||
use App\Components\PushNotification;
|
||
use App\Mail\nodeCrashWarning;
|
||
use App\Models\Node;
|
||
use Cache;
|
||
use Illuminate\Console\Command;
|
||
use Log;
|
||
use Mail;
|
||
|
||
class NodeBlockedDetection extends Command {
|
||
protected $signature = 'nodeBlockedDetection';
|
||
protected $description = '节点阻断检测';
|
||
|
||
public function handle(): void {
|
||
$jobStartTime = microtime(true);
|
||
if(sysConfig('nodes_detection')){
|
||
if(!Cache::has('LastCheckTime')){
|
||
$this->checkNodes();
|
||
}elseif(Cache::get('LastCheckTime') <= time()){
|
||
$this->checkNodes();
|
||
}else{
|
||
Log::info('下次节点阻断检测时间：'.date('Y-m-d H:i:s', Cache::get('LastCheckTime')));
|
||
}
|
||
}
|
||
|
||
$jobEndTime = microtime(true);
|
||
$jobUsedTime = round(($jobEndTime - $jobStartTime), 4);
|
||
|
||
Log::info("---【{$this->description}】完成---，耗时 {$jobUsedTime} 秒");
|
||
}
|
||
|
||
// 监测节点状态
|
||
private function checkNodes(): void {
|
||
$nodeList = Node::whereIsRelay(0)->whereStatus(1)->where('detection_type', '>', 0)->get();
|
||
$sendText = false;
|
||
$message = "| 线路 | 协议 | 状态 |\r\n| ------ | ------ | ------ |\r\n";
|
||
$additionalMessage = '';
|
||
foreach($nodeList as $node){
|
||
$info = false;
|
||
if($node->detection_type == 0){
|
||
continue;
|
||
}
|
||
// 使用DDNS的node先通过gethostbyname获取ipv4地址
|
||
if($node->is_ddns){
|
||
$ip = gethostbyname($node->server);
|
||
if(strcmp($ip, $node->server) != 0){
|
||
$node->ip = $ip;
|
||
}else{
|
||
Log::warning("【节点阻断检测】检测".$node->server."时，IP获取失败".$ip." | ".$node->server);
|
||
$this->notifyMaster("{$node->name}动态IP获取失败", "节点 {$node->name} ： IP获取失败 ");
|
||
}
|
||
}
|
||
if($node->detection_type != 1){
|
||
$icmpCheck = NetworkDetection::networkCheck($node->ip, true);
|
||
if($icmpCheck != false && $icmpCheck !== "通讯正常"){
|
||
$message .= "| ".$node->name." | ICMP | ".$icmpCheck." |\r\n";
|
||
$sendText = true;
|
||
$info = true;
|
||
}
|
||
}
|
||
if($node->detection_type != 2){
|
||
$tcpCheck = NetworkDetection::networkCheck($node->ip, false, $node->single? $node->port : null);
|
||
if($tcpCheck != false && $tcpCheck !== "通讯正常"){
|
||
$message .= "| ".$node->name." | TCP | ".$tcpCheck." |\r\n";
|
||
$sendText = true;
|
||
$info = true;
|
||
}
|
||
}
|
||
|
||
// 节点检测次数
|
||
if($info && sysConfig('detection_check_times')){
|
||
// 已通知次数
|
||
$cacheKey = 'detection_check_times'.$node->id;
|
||
if(Cache::has($cacheKey)){
|
||
$times = Cache::get($cacheKey);
|
||
}else{
|
||
// 键将保留12小时，多10分钟防意外
|
||
Cache::put($cacheKey, 1, 43800);
|
||
$times = 1;
|
||
}
|
||
|
||
if($times < sysConfig('detection_check_times')){
|
||
Cache::increment($cacheKey);
|
||
}else{
|
||
Cache::forget($cacheKey);
|
||
Node::find($node->id)->update(['status' => 0]);
|
||
$additionalMessage .= "\r\n节点【{$node->name}】自动进入维护状态\r\n";
|
||
}
|
||
}
|
||
}
|
||
|
||
//只有在出现阻断线路时，才会发出警报
|
||
if($sendText){
|
||
$this->notifyMaster("节点阻断警告", "阻断日志: \r\n\r\n".$message.$additionalMessage);
|
||
Log::info("阻断日志: \r\n".$message.$additionalMessage);
|
||
}
|
||
|
||
// 随机生成下次检测时间
|
||
Cache::put('LastCheckTime', time() + random_int(3000, Hour), 3700);
|
||
}
|
||
|
||
/**
|
||
* 通知管理员
|
||
*
|
||
* @param string $title 消息标题
|
||
* @param string $content 消息内容
|
||
*
|
||
*/
|
||
private function notifyMaster($title, $content): void {
|
||
$result = PushNotification::send($title, $content);
|
||
if(!$result && sysConfig('webmaster_email')){
|
||
$logId = Helpers::addNotificationLog($title, $content, 1, sysConfig('webmaster_email'));
|
||
Mail::to(sysConfig('webmaster_email'))->send(new nodeCrashWarning($logId));
|
||
}
|
||
}
|
||
}
|