job/app/Task/GetEnergyPlatformBalance.php

<?php
namespace App\Task;

use App\Model\Energy\EnergyPlatform;
use App\Library\Log;
use App\Service\RsaServices;
use App\Model\Telegram\TelegramBotUser;

class GetEnergyPlatformBalance
{
    public function execute()
    { 
        try {
            $data = EnergyPlatform::from('energy_platform as a')
                    ->leftJoin('telegram_bot as b','a.tg_notice_bot_rid','b.rid')
                    ->where('a.status',0)
                    ->select('a.*','b.bot_token')
                    ->get();
            
            if($data->count() > 0){
                $rsa_services = new RsaServices();
                
                foreach ($data as $k => $v) {
                    //neee.cc平台
                    if($v['platform_name'] == 1){
                        $header = [
                            "Content-Type:application/json"
                        ];
                        
                        $param = [
                            "uid" => $v['platform_uid'],
                            "time" => time()
                        ];
                        
                		ksort($param);
                		reset($param);
                		
                		$signstr = $rsa_services->privateDecrypt($v['platform_apikey']);
                	
                		foreach($param as $k1 => $v1){
                			if($k1 != "sign" && $k1 != "sign_type" && $v1!=''){
                				$signstr .= $k1.$v1;
                			}
                		}
                		
                		$sign = md5($signstr);
                		$param['sign'] = $sign;
                        $balance_url = 'https://api.tronqq.com/openapi/v1/user/balance';
                        $res = Get_Pay($balance_url,json_encode($param),$header);
                        
                        if(empty($res)){
                            $this->log('energyplatformbalance',$v['rid'].'平台请求失败');
                        }else{
                            $res = json_decode($res,true);
                            if($res['status'] == 200){
                                if(empty($res['data'])){
                                    $this->log('energyplatformbalance',$v['rid'].'平台请求失败2:'.json_encode($res));
                                }else{
                                    $balance = $res['data']['balance'];
                                    $balance = $balance <= 0 ?0:$balance;
                                    
                                    $updatedata1['platform_balance'] = $balance;
                                    //间隔10分钟通知一次
                                    if($balance <= $v['alert_platform_balance'] && $v['alert_platform_balance'] > 0 && strtotime($v['last_alert_time']) + 600 <= strtotime(nowDate())){
                                        $updatedata1['last_alert_time'] = nowDate();
                                        
                                        //余额通知管理员
                                        if($v['tg_notice_obj'] && !empty($v['tg_notice_obj'])){
                                            $replytext = "能量平台(neee.cc)，余额不足，请立即前往平台充值！\n"
                                                        ."能量平台ID：".$v['rid']."\n"
                                                        ."平台用户UID：".$v['platform_uid']."\n"
                                                        ."当前余额：".$balance."\n"
                                                        ."告警金额：".$v['alert_platform_balance']."\n\n"
                                                        ."不处理会一直告警通知！间隔10分钟告警一次";
                                                        
                                            $sendlist = explode(',',$v['tg_notice_obj']);
                            
                                            foreach ($sendlist as $x => $y) {
                                                $sendmessageurl = 'https://api.telegram.org/bot'.$v['bot_token'].'/sendMessage?chat_id='.$y.'&text='.urlencode($replytext).'&parse_mode=HTML';
                                                
                                                Get_Pay($sendmessageurl);
                                            }
                                        }
                                    }
                                    
                                    EnergyPlatform::where('rid',$v['rid'])->update($updatedata1);
                                }
                            }else{
                                $this->log('energyplatformbalance',$v['rid'].'平台请求失败3:'.json_encode($res));
                            }
                        }
                    }
                    
                    //RentEnergysBot平台
                    elseif($v['platform_name'] == 2){
                        $signstr = $rsa_services->privateDecrypt($v['platform_apikey']);
                        $balance_url = 'https://api.wallet.buzz?api=getBalance&apikey='.$signstr;
                        $res = Get_Pay($balance_url);
                        
                        if(!isset($res) || $res === ""){
                            $this->log('energyplatformbalance',$v['rid'].'平台请求失败1:');
                        }else{
                            $balance = $res <= 0 ?0:$res;
                                    
                            $updatedata2['platform_balance'] = $balance;
                            
                            if($balance <= $v['alert_platform_balance'] && $v['alert_platform_balance'] > 0 && strtotime($v['last_alert_time']) + 600 <= strtotime(nowDate())){
                                $updatedata2['last_alert_time'] = nowDate();
                                
                                //余额通知管理员
                                if($v['tg_notice_obj'] && !empty($v['tg_notice_obj'])){
                                    $replytext = "能量平台(RentEnergysBot)，余额不足，请立即前往平台充值！\n"
                                                ."能量平台ID：".$v['rid']."\n"
                                                ."平台用户UID：".$v['platform_uid']."\n"
                                                ."当前余额：".$balance."\n"
                                                ."告警金额：".$v['alert_platform_balance']."\n\n"
                                                ."不处理会一直告警通知！间隔10分钟告警一次";
                                                
                                    $sendlist = explode(',',$v['tg_notice_obj']);
                    
                                    foreach ($sendlist as $x => $y) {
                                        $sendmessageurl = 'https://api.telegram.org/bot'.$v['bot_token'].'/sendMessage?chat_id='.$y.'&text='.urlencode($replytext).'&parse_mode=HTML';
                                        
                                        Get_Pay($sendmessageurl);
                                    }
                                }
                            }
                            
                            EnergyPlatform::where('rid',$v['rid'])->update($updatedata2);
                        }
                    }
                    
                    //自己质押代理
                    elseif($v['platform_name'] == 3 && mb_strlen($v['platform_uid']) == 34){
                        $tronurl = 'https://api.trongrid.io/wallet/getaccountresource';
                
                        $api_key = config('apikey.gridapikey');
                        $apikeyrand = $api_key[array_rand($api_key)];
                        
                        $heders = [
                            "TRON-PRO-API-KEY:".$apikeyrand
                        ];
                        
                        $body = [
                          "address" => $v['platform_uid'],
                          "visible" => true
                        ];
                        
                        $tronres = Get_Pay($tronurl,json_encode($body),$heders);

                        if(empty($tronres)){
                            $this->log('energyplatformbalance',$v['rid'].'平台请求失败1:');
                        }else{
                            $tronres = json_decode($tronres,true);

                            if(isset($tronres['EnergyLimit'])){
                                $balance = $tronres['EnergyLimit'] - ($tronres['EnergyUsed'] ?? 0);
                                $updatedata3['platform_balance'] = $balance;
                                
                                if($balance <= $v['alert_platform_balance'] && $v['alert_platform_balance'] > 0 && strtotime($v['last_alert_time']) + 600 <= strtotime(nowDate())){
                                    $updatedata3['last_alert_time'] = nowDate();
                                    
                                    //余额通知管理员
                                    if($v['tg_notice_obj'] && !empty($v['tg_notice_obj'])){
                                        $replytext = "能量平台(自己质押代理)，能量不足，请立即质押！\n"
                                                    ."能量平台ID：".$v['rid']."\n"
                                                    ."质押钱包地址：".$v['platform_uid']."\n"
                                                    ."当前能量剩余：".$balance."\n"
                                                    ."告警能量值：".$v['alert_platform_balance']."\n\n"
                                                    ."不处理会一直告警通知！间隔10分钟告警一次";
                                                    
                                        $sendlist = explode(',',$v['tg_notice_obj']);
                        
                                        foreach ($sendlist as $x => $y) {
                                            $sendmessageurl = 'https://api.telegram.org/bot'.$v['bot_token'].'/sendMessage?chat_id='.$y.'&text='.urlencode($replytext).'&parse_mode=HTML';
                                            
                                            Get_Pay($sendmessageurl);
                                        }
                                    }
                                }
                                
                                EnergyPlatform::where('rid',$v['rid'])->update($updatedata3);
                            }
                        }
                    }
                    
                    //trongas.io平台
                    elseif($v['platform_name'] == 4){
                        $param = [
                            "username" => $v['platform_uid']
                        ];
                        $balance_url = 'https://trongas.io/api/userInfo';
                        $res = Get_Pay($balance_url,$param);
                        
                        if(empty($res)){
                            $this->log('energyplatformbalance',$v['rid'].'平台请求失败');
                        }else{
                            $res = json_decode($res,true);
                            if($res['code'] == 10000){
                                if(empty($res['data'])){
                                    $this->log('energyplatformbalance',$v['rid'].'平台请求失败2:'.json_encode($res));
                                }else{
                                    $balance = $res['data']['balance'];
                                    $balance = $balance <= 0 ?0:$balance;
                                    
                                    $updatedata4['platform_balance'] = $balance;
                                    //间隔10分钟通知一次
                                    if($balance <= $v['alert_platform_balance'] && $v['alert_platform_balance'] > 0 && strtotime($v['last_alert_time']) + 600 <= strtotime(nowDate())){
                                        $updatedata4['last_alert_time'] = nowDate();
                                        
                                        //余额通知管理员
                                        if($v['tg_notice_obj'] && !empty($v['tg_notice_obj'])){
                                            $replytext = "能量平台(trongas.io)，余额不足，请立即前往平台充值！\n"
                                                        ."能量平台ID：".$v['rid']."\n"
                                                        ."平台用户UID：".$v['platform_uid']."\n"
                                                        ."当前余额：".$balance."\n"
                                                        ."告警金额：".$v['alert_platform_balance']."\n\n"
                                                        ."不处理会一直告警通知！间隔10分钟告警一次";
                                                        
                                            $sendlist = explode(',',$v['tg_notice_obj']);
                            
                                            foreach ($sendlist as $x => $y) {
                                                $sendmessageurl = 'https://api.telegram.org/bot'.$v['bot_token'].'/sendMessage?chat_id='.$y.'&text='.urlencode($replytext).'&parse_mode=HTML';
                                                
                                                Get_Pay($sendmessageurl);
                                            }
                                        }
                                    }
                                    
                                    EnergyPlatform::where('rid',$v['rid'])->update($updatedata4);
                                }
                            }else{
                                $this->log('energyplatformbalance',$v['rid'].'平台请求失败3:'.json_encode($res));
                            }
                        }
                    }
                    
                    //机器人开发者代理
                    elseif($v['platform_name'] == 5){
                        $balance_url = env('THIRD_URL');
                        if(!empty($balance_url)){
                            $balance_url = $balance_url.'/api/thirdpart/balance?tg_uid='.$v['platform_uid'];
                            $res = Get_Pay($balance_url);
                            
                            if(empty($res)){
                                $this->log('energyplatformbalance',$v['rid'].'平台请求失败');
                            }else{
                                $res = json_decode($res,true);
                                if($res['code'] == 200){
                                    if(empty($res['data'])){
                                        $this->log('energyplatformbalance',$v['rid'].'平台请求失败2:'.json_encode($res));
                                    }else{
                                        $balance = $res['data']['trx_balance'];
                                        $balance = $balance <= 0 ?0:$balance;
                                        
                                        $updatedata5['platform_balance'] = $balance;
                                        //间隔10分钟通知一次
                                        if($balance <= $v['alert_platform_balance'] && $v['alert_platform_balance'] > 0 && strtotime($v['last_alert_time']) + 600 <= strtotime(nowDate())){
                                            $updatedata5['last_alert_time'] = nowDate();
                                            
                                            //余额通知管理员
                                            if($v['tg_notice_obj'] && !empty($v['tg_notice_obj'])){
                                                $replytext = "能量平台(机器人开发者代理)，余额不足，请立即联系客服充值！\n"
                                                            ."能量平台ID：".$v['rid']."\n"
                                                            ."平台用户UID：".$v['platform_uid']."\n"
                                                            ."当前余额：".$balance."\n"
                                                            ."告警金额：".$v['alert_platform_balance']."\n\n"
                                                            ."不处理会一直告警通知！间隔10分钟告警一次";
                                                            
                                                $sendlist = explode(',',$v['tg_notice_obj']);
                                
                                                foreach ($sendlist as $x => $y) {
                                                    $sendmessageurl = 'https://api.telegram.org/bot'.$v['bot_token'].'/sendMessage?chat_id='.$y.'&text='.urlencode($replytext).'&parse_mode=HTML';
                                                    
                                                    Get_Pay($sendmessageurl);
                                                }
                                            }
                                        }
                                        
                                        EnergyPlatform::where('rid',$v['rid'])->update($updatedata5);
                                    }
                                }else{
                                    $this->log('energyplatformbalance',$v['rid'].'平台请求失败3:'.json_encode($res));
                                }
                            }
                        }
                    }

                    // MeFree.NET 平台
                    elseif($v['platform_name'] == 6){

                        // API 配置信息
                        $base_url = "https://api.mefree.net";        // Mefree API 基础地址
                        $api_key = $v['platform_uid'];              // 替换为实际的 API Key
                        $secret_key = $v['platform_apikey'];        // 替换为实际的 Secret Key

                        // 获取账户信息
                        $request_path = "/api/available"; // API 请求路径
                        $response = send_request("GET", $request_path, $base_url, $api_key, $secret_key);

                        // 处理返回结果
                        if ($response['code'] == 0) {

                            $balance = $response['data'] <= 0 ?0:$response['data'];

                            $updatedata2['platform_balance'] = $balance;

                            if($balance <= $v['alert_platform_balance'] && $v['alert_platform_balance'] > 0 && strtotime($v['last_alert_time']) + 600 <= strtotime(nowDate())){
                                $updatedata2['last_alert_time'] = nowDate();

                                //余额通知管理员
                                if($v['tg_notice_obj'] && !empty($v['tg_notice_obj'])){
                                    $replytext = "能量平台(MeFree.NET)，余额不足，请立即前往平台充值！\n"
                                        ."能量平台ID：".$v['rid']."\n"
                                        ."平台用户UID：".$v['platform_uid']."\n"
                                        ."当前余额：".$balance."\n"
                                        ."告警金额：".$v['alert_platform_balance']."\n\n"
                                        ."不处理会一直告警通知！间隔10分钟告警一次";

                                    $sendlist = explode(',',$v['tg_notice_obj']);

                                    foreach ($sendlist as $x => $y) {
                                        $sendmessageurl = 'https://api.telegram.org/bot'.$v['bot_token'].'/sendMessage?chat_id='.$y.'&text='.urlencode($replytext).'&parse_mode=HTML';

                                        Get_Pay($sendmessageurl);
                                    }
                                }
                            }

                            EnergyPlatform::where('rid',$v['rid'])->update($updatedata2);
                        }
                    }
                }
            }
            
        }catch (\Exception $e){
            $this->log('energyplatformbalance','----------任务执行报错，请联系管理员。报错原因：----------'.$e->getMessage());
        }
    }

    /**
     * 记入日志
     * @param $log_title [日志路径]
     * @param $message [内容，不支持数组]
     * @param $remarks [备注]
    */
    protected function log($log_title,$message,$remarks='info'){
        Log::get($remarks,$log_title)->info($message);
    }

}