<?php
namespace App\Service\Fms;
use App\Model\Telegram\FmsWalletTradeList;
use App\Library\Log;
use Hyperf\DbConnection\Db;
use App\Service\Bus\TronServices;
class FmsWalletTradeTrxServices
{
private $list_success_count = 0; //交易列表拉取成功数
private $list_error_count = 0; //交易列表拉取失败数
private $limit = 50; //每次获取多少条
/**
* 获取能量钱包数据
* @param $in_list [钱包数据]
* @param $start_timestamp [开始时间 13位时间戳]
* @param $end_timestamp [结束时间 13位时间戳]
* @param $page [页数]
*/
public function getList($in_list,$start_timestamp,$end_timestamp,$page=0){
$limit = $this->limit;
$start = $page * $limit;
$url = 'https://apilist.tronscanapi.com/api/new/transfer?sort=-timestamp&count=true&limit='.$limit.'&start='.$start.'&address='.$in_list['recharge_wallet_addr'].'&toAddress='.$in_list['recharge_wallet_addr'].'&tokens=_&start_timestamp='.$start_timestamp.'&end_timestamp='.$end_timestamp;
$api_key = config('apikey.tronapikey');
$apikeyrand = $api_key[array_rand($api_key)];
$heders = [
"TRON-PRO-API-KEY:".$apikeyrand
];
$data = Get_Pay($url,null,$heders);
if(!empty($data) && $data){
$data = json_decode($data,true);
if(!empty($data['total']) && isset($data['data']) && count($data['data']) > 0){
$data = $this->handleWalletData($data,$in_list,$start_timestamp,$end_timestamp,$page,$limit);
}
}
return ['success_count'=>$this->list_success_count,'error_count'=>$this->list_error_count];
}
/**
* 处理收款数据
* @param $data [收款数据]
* @param $in_list [钱包数据]
* @param $start_timestamp [开始时间 13位时间戳]
* @param $end_timestamp [结束时间 13位时间戳]
* @param $page [页数]
* @param $limit [每页获取数据]
*/
public function handleWalletData($data,$in_list,$start_timestamp,$end_timestamp,$page,$limit){
if(isset($data['data'])){
$list = $data['data'];
$total = $data['total']; //总数
if($list){
// 校验hash是否存在
$hash_list = array_column($list,'transactionHash');
$transaction_hash_list = FmsWalletTradeList::whereIn('tx_hash',$hash_list)->pluck('tx_hash')->toArray();
$success_hash_list = []; //成功hash值数组
$error_hash_list = []; //失败hash值数组
$time = nowDate();
foreach ($list as $k => $v) {
if(!in_array($v['transactionHash'],$transaction_hash_list) && $v['contractRet'] == 'SUCCESS' && calculationExcept($v['amount'],6) >= 1 && $v['tokenInfo']['tokenId'] == '_' && $v['tokenInfo']['tokenAbbr'] == 'trx'){
Db::beginTransaction();
try {
$res = $this->AddWalletData($v,$time,$in_list);
if($res['code'] == 200){
$success_hash_list[] = $v['transactionHash'];
}else{
$error_hash_list[] = $v['transactionHash'].'--------'.'不是收款记录或金额为0，交易失败';
}
Db::commit();
}catch (\Exception $e){
Db::rollBack();
$error_hash_list[] = $v['transactionHash'].'--------'.$e->getMessage();
}
}else{
$error_hash_list[] = $v['transactionHash'].'--------'.'已存在';
}
}
$success_hash_list_count = count($success_hash_list);
$error_hash_list_count = count($error_hash_list);
$this->list_success_count = $this->list_success_count + $success_hash_list_count;
$this->list_error_count = $this->list_error_count + $error_hash_list_count;
// 总数大于当前获取数时和当前获取数据总数等于设置条数，再次去获取
$get_total = ($page+1) * $limit;
if($total > $get_total && count($list) == $limit){
$this->getList($in_list,$start_timestamp,$end_timestamp,$page+1);
}
}
}
}
/**
* 整合添加收款数据
* @param $data [收款数据]
* @param $time [当前时间]
* @param $in_list [钱包数据]
*/
public function AddWalletData($data,$time,$in_list){
$txid_list = [];
$txid_list['tx_hash'] = $data['transactionHash']; //交易hash
$txid_list['transferfrom_address'] = $data['transferFromAddress']; //来源钱包地址
$txid_list['timestamp'] = $data['timestamp']; //时间戳
$txid_list['transferto_address'] = $in_list['recharge_wallet_addr']; //收款钱包地址
$txid_list['coin_name'] = 'trx';
$txid_list['amount'] = calculationExcept($data['amount'],6); //交易数额
$txid_list['get_time'] = $time; //拉取时间
$txid_list['process_status'] = 1; //待兑换
$txid_list['process_comments'] = '待处理'; //处理备注
$txid_list['process_time'] = $time; //处理时间
FmsWalletTradeList::insert($txid_list); //添加收款钱包交易列表
return ['code' => 200];
}
/**
* 获取能量钱包数据-通过trongrid获取
* @param $in_list [钱包数据]
* @param $start_timestamp [开始时间 13位时间戳]
* @param $nexturl [下一页]
*/
public function getListByGrid($in_list,$start_timestamp,$nexturl='0'){
$limit = $this->limit;
if($nexturl != '0'){
$url = $nexturl;
}else{
$url = 'https://api.trongrid.io/v1/accounts/'.$in_list['recharge_wallet_addr'].'/transactions?only_to=true&only_confirm=true&limit='.$limit.'&min_timestamp='.$start_timestamp.'&search_internal=false';
}
$api_key = config('apikey.gridapikey');
$apikeyrand = $api_key[array_rand($api_key)];
$heders = [
'TRON-PRO-API-KEY:'.$apikeyrand
];
$data = Get_Pay($url,null,$heders);
if(!empty($data) && $data){
//波场接口API
$TronApiConfig = [
'url' => 'https://api.trongrid.io',
'api_key' => $apikeyrand,
];
$tron = new TronServices($TronApiConfig,'1111111','222222');
$data = json_decode($data,true);
$data = $this->handleWalletDataByGrid($data,$in_list,$tron);
}
}
/**
* 处理收款数据-通过trongrid获取
* @param $data [收款数据]
* @param $in_list [钱包数据]
*/
public function handleWalletDataByGrid($data,$in_list,$tron){
if(isset($data['data'])){
$list = $data['data'];
if($list){
// 校验hash是否存在
$hash_list = array_column($list,'txID');
$transaction_hash_list = FmsWalletTradeList::whereIn('tx_hash',$hash_list)->pluck('tx_hash')->toArray();
$success_hash_list = []; //成功hash值数组
$error_hash_list = []; //失败hash值数组
$time = nowDate();
foreach ($list as $k => $v) {
if(!in_array($v['txID'],$transaction_hash_list) && $v['raw_data']['contract'][0]['type'] == 'TransferContract'){
Db::beginTransaction();
try {
$res = $this->AddWalletDataByGrid($v,$time,$in_list,$tron);
if($res['code'] == 200){
$success_hash_list[] = $v['txID'];
}else{
$error_hash_list[] = $v['txID'].'--------'.'不是收款记录或金额为0，交易失败';
}
Db::commit();
}catch (\Exception $e){
Db::rollBack();
$error_hash_list[] = $v['txID'].'--------'.$e->getMessage();
}
}else{
$error_hash_list[] = $v['txID'].'--------'.'已存在';
}
}
// 如果有下一页，再次去获取
if(isset($data['meta']['links']['next'])){
$this->getList($in_list,0,$data['meta']['links']['next']);
}
}
}
}
/**
* 整合添加收款数据-通过trongrid获取
* @param $data [收款数据]
* @param $time [当前时间]
* @param $in_list [钱包数据]
*/
public function AddWalletDataByGrid($data,$time,$in_list,$tron){
$amount = calculationExcept($data['raw_data']['contract'][0]['parameter']['value']['amount'],6);
if($amount >= 0.1){
$fromaddress = $tron->addressFromHex($data['raw_data']['contract'][0]['parameter']['value']['owner_address']);
$txid_list = [];
$txid_list['tx_hash'] = $data['txID']; //交易hash
$txid_list['transferfrom_address'] = $fromaddress; //来源钱包地址
$txid_list['timestamp'] = $data['raw_data']['timestamp']; //时间戳
$txid_list['transferto_address'] = $in_list['recharge_wallet_addr']; //收款钱包地址
$txid_list['coin_name'] = 'trx';
$txid_list['amount'] = $amount; //交易数额
$txid_list['get_time'] = $time; //拉取时间
$txid_list['process_status'] = 1; //待兑换
$txid_list['process_comments'] = '待处理'; //处理备注
$txid_list['process_time'] = $time; //处理时间
FmsWalletTradeList::insert($txid_list); //添加收款钱包交易列表
}
return ['code' => 200];
}
/**
* 记入日志
* @param $log_title [日志路径]
* @param $message [内容，不支持数组]
* @param $remarks [备注]
*/
protected function log($log_title,$message,$remarks='info'){
Log::get($remarks,$log_title)->info($message);
}
}