接口广播完成

app/Jobs/BoadcastDetectionJob.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Models\BlockItems;
+use App\Servers\ContractServer;
+use Illuminate\Bus\Queueable;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+
+class BoadcastDetectionJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+    private $blockItem;
+
+    /**
+     * Create a new job instance.
+     *
+     * @return void
+     */
+    public function __construct(BlockItems $blockItem)
+    {
+        $this->blockItem=$blockItem;
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+        ContractServer::creatServer()->broadcastDetection($this->blockItem);
+    }
+}

app/Observers/BlockItemObserver.php

@@ -0,0 +1,104 @@
+<?php
+
+namespace App\Observers;
+
+
+
+
+use App\Models\BlockItems;
+use App\Servers\JobServer;
+
+class BlockItemObserver
+{
+    /**
+     * 获取到模型实例后触发
+     */
+    public function retrieved()
+    {
+
+    }
+
+    /**
+     * 插入到数据库前触发
+     */
+    public function creating()
+    {
+
+    }
+
+    /**
+     * 插入到数据库后触发
+     * @param BlockItems $blockItem
+     */
+    public function created(BlockItems $blockItem)
+    {
+        //加入队列
+        JobServer::creatServer()->broadcastDetectionJob($blockItem);
+    }
+
+    /**
+     * 更新到数据库前触发
+     */
+    public function updating()
+    {
+
+    }
+
+    /**
+     * 更新到数据库后触发
+     */
+    public function updated()
+    {
+
+    }
+
+    /**
+     * 保存到数据库前触发（插入/更新之前，无论插入还是更新都会触发）
+     */
+    public function saving()
+    {
+
+    }
+
+    /**
+     * 保存到数据库后触发（插入/更新之后，无论插入还是更新都会触发）
+     */
+    public function saved()
+    {
+
+    }
+
+    /**
+     * 从数据库删除记录前触发
+     */
+    public function deleting()
+    {
+
+    }
+
+    /**
+     * 从数据库删除记录后触发
+     */
+    public function deleted()
+    {
+
+    }
+
+    /**
+     * 恢复软删除记录前触发
+     */
+    public function restoring()
+    {
+
+    }
+
+    /**
+     * 恢复软删除记录后触发
+     */
+    public function restored()
+    {
+
+    }
+
+
+}

app/Providers/AppServiceProvider.php

@@ -2,6 +2,8 @@
 
 namespace App\Providers;
 
+use App\Models\BlockItems;
+use App\Observers\BlockItemObserver;
 use App\Observers\CouponGrantRangeObserver;
 use App\Observers\CouponRangeObserver;
 use App\Observers\GoodsSpecObserver;
@@ -32,5 +34,6 @@ class AppServiceProvider extends ServiceProvider
             $url->forceScheme('https');
         }
         //商品规格库存更新触发事件
+        BlockItems::observe(BlockItemObserver::class);
     }
 }

app/Servers/BroadcastServer.php

@@ -4,13 +4,13 @@
 namespace App\Servers;
 
 use App\Models\Broadcast;
-use App\Models\CoinTypes;
+use App\Models\CoinType;
 use App\Models\Config;
 use App\Models\MemberCoins;
 use App\Models\Withdraw;
-use App\Servers\Eth\Utils;
+use App\Servers\Icon\TronRPC;
+use App\Servers\Icon\Utils;
 use Illuminate\Support\Facades\Log;
-use Web3p\EthereumTx\Transaction;
 
 
 /**
@@ -30,61 +30,22 @@ class BroadcastServer
     ];
 
 
-
-    /**
-     * @param $eth_address ## 用户钱包地址
-     * @return bool|mixed|string|null
-     *
-     * 查询用户NYTR余额
-     */
-    public static function getUsdtNum($eth_address)
-    {
-        $eth = EthereumRPCServer::getInstance();
-        $tx = [];
-        $tx['from'] = $eth_address;                                 //用户地址
-//        $tx['to'] = config('muc.hy_address', '');   //系统钱包地址
-        $tx['to'] =Config::where('key','hy_address')->value('value');   //系统钱包地址
-        $tx['data'] = Utils::decodeSolMethod('balanceOf(address)', [$eth_address]);
-        $balance = $eth->call($tx);
-        $balance = Utils::hex2dec($balance);
-        $balance = Utils::int2fund($balance,6); // 18位小数
-        $balance = Utils::fund2int($balance, 2);
-        $balance = round($balance / 100, 2);
-        return $balance;
-    }
-
-
     /**
-     * 获取ETH余额
-     * @param $eth_address ##用户钱包地址
-     * @return bool|mixed|string
-     */
-    public static function getEthNum($eth_address)
-    {
-        $eth = EthereumRPCServer::getInstance();
-        $eth_num = $eth->getBalance($eth_address);
-        $eth_num = Utils::hex2dec($eth_num);
-        $eth_num = Utils::int2fund($eth_num, 18);
-        return $eth_num;
-    }
-
-    /**
-     * 获取BTC数量
-     * @param $btc_address
-     * @return string
+     * 创建广播信息
+     * @param $coin_id
+     * @param $money
+     * @param $from
+     * @param $from_key
+     * @param $to
+     * @param $member_id
+     * @param int $order_id
+     * @param int $status_type
+     * @param int $status
+     * @return mixed
      */
-    public static function getBtcNum($btc_address)
-    {
-        $btc = BtcereumRPCServer::getInstance();
-        $btc_num = $btc->bitcoinBalanceOfAddress($btc_address);
-        return $btc_num;
-    }
-
-
-    public static function addBroadcast($coin_id, $money, $from, $from_key, $to, $member_id, $order_id = 0, $status_type = 0, $from_id = 0, $status = 1)
+    public static function addBroadcast($coin_id, $money, $from, $from_key, $to, $member_id, $order_id = 0, $status_type = 0, $status = 1)
     {
         //保留数量
-        $retain_num = CoinTypes::where('id', $coin_id)->value('retain_num');
         $transaction = [
             'depend' => 0,
             'from' => $from,
@@ -100,460 +61,82 @@ class BroadcastServer
             'sign' => '',
             'hash' => $status == 5 ? '系统内部转账,直接成功,无需链上广播' : '',
             'from_key' => $from_key,
-            'money' =>$coin_id!=4? round($money - $retain_num,6):$money,
+            'money' =>round($money,6),
             'status' => $status,
             'type' => $status_type,
             'm_id' => $member_id,
             'order_id' => $order_id,
-//            'from_id' => $from_id,
-            'retain_num' => $retain_num,
             'send_money' => $money,
         ];
-        if ($coin_id == 1) {
-//            $btc = BtcereumRPCServer::getInstance();
-//            $feeAddressUXTO = $btc->listunspent(0, 999999, [$from]);
-//            if (empty($feeAddressUXTO)) {
-//                $transaction['error'] = "手续费地址uxto为空";
-//                $transaction['status'] = 4;
-//            } else {
-//                $inputs = [];
-//                foreach ($feeAddressUXTO as $item) {
-//                    $inputs[] = [
-//                        'txid' => $item['txid'],
-//                        'vout' => $item['vout'],
-//                    ];
-//                }
-//                $output = [$to => $transaction['money']];
-//                $rawtx = $btc->createrawtransaction($inputs, $output);
-//                if ($rawtx === false) {
-//                    $transaction['error'] = "创建裸交易失败";
-//                    $transaction['status'] = 4;
-//                } else {
-//                    $transaction['data'] = $rawtx;
-//                }
-//            }
-        } else {
-            $eth = EthereumRPCServer::getInstance();
-            $transaction['chain_id'] = $eth->chainId;
-            $depend = 0;
-            if ($coin_id == 4) {
-                $hy_address=Config::where('key','hy_address')->value('value');
-                $tx = static::build(
-                    $from,
-                    $hy_address,//系统钱包地址
-                    '0x0',
-                    Utils::decodeSolMethod(
-                        'transfer(address,uint256)',
-                        [$to, Utils::fund2int($money, 6)]
-//                        [$to, Utils::fund2int($money, 18)]
-                    )
-                );
-                $transaction['from'] = $tx['from'];
-                $transaction['to'] = $tx['to'];
-                $transaction['data'] = $tx['data'];
-                $my_eth = static::getEthNum($tx['from']);
-                if ($my_eth * 1 < 0.002) {
-                    $depend = static::withholdServiceCharge($tx, $member_id);
-                }
-            }else{
-                $transaction['value'] =Utils::dec2hex(Utils::fund2int($transaction['money'] * 1)); // 转账金额
-                $transaction['data'] =  '0x0';
-            }
-            $transaction['depend'] = $depend;
-//            $nonce = $eth->getTransactionCount($transaction['from']);
-//            $transaction['nonce'] = $nonce;//交易顺序十六进制。由eth_getTransactionCount获取
-//            $gas_price = $eth->getGasPrice();
-//            $transaction['gas_price'] = Utils::dec2hex(Utils::toWei("1gwei") + Utils::hex2dec($gas_price));//燃料十六进制。由eth_estimateGas获取
-//            $gas_limit = static::getGasLimit($transaction);
-//            $transaction['gas_limit'] = $gas_limit;
-            //写入数据库代码  $transaction
-        }
+
         $transaction = Broadcast::create($transaction);
-//        //写入 返回成功
         return $transaction->{'id'};
     }
 
 
     /**
-     * 导入广播
-     * @param $from
-     * @param $to
-     * @param $nonce
-     * @param $value
-     * @param $data
-     * @param $chain_id
-     * @param $gas_price
-     * @param $gas_limit
-     * @param $sign
-     * @param $hash
-     * @param $money
-     * @param $order_id
-     * @param $coin_id
-     * @param $status
-     * @return mixed
-     */
-    public static function addSysBroadcast($from, $to, $nonce, $value, $data, $chain_id, $gas_price, $gas_limit, $sign, $hash, $money, $order_id, $coin_id, $status)
-    {
-        $withdraws = Withdraw::where('id', $order_id)->first();
-        if (empty($withdraws)) {
-            Log::info('导入提现信息不存在，提现ID:' . $order_id);
-            return false;
-        }
-        if($withdraws->{'status'}!=1)return false;
-        $transaction_id = Broadcast::where('order_id', $order_id)->where('type', '2')->value('id');
-        //保留数量
-        $transaction = [
-            'depend' => 0,
-            'from' => $from,
-            'to' => $to,
-            'nonce' => $nonce,
-            'coin_id' => $coin_id,
-            'value' => $value,
-            'data' => $data,
-            'chain_id' => $chain_id,
-            'gas_price' => $gas_price,
-            'gas_limit' => $gas_limit,
-            'sign' => $sign,
-            'hash' => $hash,
-            'from_key' => '',
-            'money' => $money,
-            'status' => 3,
-            'type' => $status,
-            'm_id' => $withdraws->{'m_id'},
-            'order_id' => $order_id,
-            'created_at' => date('Y-m-d H:i:s'),
-            'updated_at' => date('Y-m-d H:i:s'),
-
-        ];
-        if (empty($transaction_id)) {
-            $transaction_id = Broadcast::insertGetId($transaction);
-        } else {
-            Broadcast::where('id', $transaction_id)->update($transaction);
-        }
-        Withdraw::where('id', $order_id)->update(['updated_at' => date('Y-m-d H:i:s'),'hash'=>$hash, 'status' => '2']);
-//        //写入 返回成功
-        return $transaction_id;
-    }
-
-    /**
-     * 广播签名
-     * @return bool
+     * 广播查询
      */
-    public static function signBroadcast()
+    public static function getBroadcast()
     {
-        $btc = BtcereumRPCServer::getInstance();
-        $list = Broadcast::where('status', '1')->select(['id', 'depend', 'chain_id', 'm_id', 'from', 'to', 'nonce', 'value', 'data', 'gas_price', 'gas_limit', 'sign', 'money', 'from_key', 'coin_id'])->groupBy('m_id')->limit(10)->get()->toArray();
-//        $service_money='4000000000000000';
-
-        // 手续费交易 转账0.0015个
-//        $serviceFee = Utils::dec2hex($service_money); // 手续费
-       
-        if (empty($list)) return false;
-        $sys_wei=Config::where('key','service_charge')->value('value');
-        $sys_wei=empty($sys_wei)?'15':$sys_wei;
-        $eth = EthereumRPCServer::getInstance();
+        $list = Broadcast::where('status', '2')->select(['id', 'm_id', 'from', 'to', 'send_money', 'value', 'coin_id', 'type', 'sign', 'money', 'from_key', 'coin_id', 'hash', 'send_money', 'order_id'])->limit(100)->get();
+        $ret_type=false;
+        if (empty($list)) return $ret_type;
         foreach ($list as $value) {
-            $update_info = [];
-            $from_key = PassServer::getSecretKey($value['from_key'], $value['m_id']);
-            $send_num = Broadcast::whereIn('status', ['2'])->where('from', $value['from'])->count();
-            if ($send_num > 0) continue;
-            if ($value['depend']) {
-                $num = Broadcast::where('id', $value['depend'])->where('status', 5)->where('updated_at','<',date('Y-m-d H:i:s',time()-15))->count();
-                if ($num <= 0) continue;
-            }
-            if ($value['coin_id'] == 1) {
-                $feeAddressUXTO = $btc->listunspent(0, 999999, [$value['from']]);
-                if (empty($feeAddressUXTO)) {
-                    $update_info['error'] = "手续费地址uxto为空";
-                    $update_info['status'] = 4;
-                } else {
-                    $inputs = [];
-                    foreach ($feeAddressUXTO as $item) {
-                        $inputs[] = [
-                            'txid' => $item['txid'],
-                            'vout' => $item['vout'],
-                        ];
-                    }
-                    $output = [$value['to'] => $value['money']*1];
-                    $rawtx = $btc->createrawtransaction($inputs, $output);
-                    if ($rawtx === false) {
-                        $update_info['error'] = "创建裸交易失败";
-                        $update_info['status'] = 4;
-                    } else {
-                        $value['data'] = $rawtx;
-                        $privKeys[] = $from_key;
-                        $sign = $btc->signrawtransactionwithkey($value['data'], $privKeys,null);
-                        if ($sign === false) {
-                            $update_info['error'] = '签名失败';
-                            $update_info['status'] = 5;
-                        } else {
-                            $update_info['sign'] = $sign['hex'];
-                            $update_info['status'] = 2;
-                        }
-                    }
-                }
-            } else {
-				
-                if($value['coin_id']==4){
-                    $my_eth = static::getEthNum($value['from']);
-					//dd( $my_eth);
-                    if ($my_eth * 1 < 0.005) {
-                        $depend = static::withholdServiceCharge($value, $value['m_id']);
-                        Broadcast::where('id', $value['id'])->update(['depend' => $depend]);
-                        continue;
-                    }
-
-                }else{
-//                    $value['value'] =Utils::dec2hex(Utils::fund2int($value['money'] * 1)); // 转账金额
-                }
-                if(empty($value['nonce']) || true){
-                    $nonce = $eth->getTransactionCount($value['from']);
-                    //交易顺序十六进制。由eth_getTransactionCount获取
-
-                    $nonce_count = Broadcast::where('nonce', $nonce)->where('from',$value['from'])->where('id','<>', $value['id'])->count();
-                    if ($nonce_count >= 1) {
-                        continue;
-//                    $nonce=Utils::dec2hex(Utils::hex2dec($nonce) + 1);
-                    }
-                    $value['nonce'] = $nonce;
-                }
-
-                $gas_price = $eth->getGasPrice();
-				
-                $value['gas_price'] =  Utils::dec2hex(Utils::toWei($sys_wei."gwei") + Utils::hex2dec($gas_price));//燃料十六进制。由eth_estimateGas获取
-//                $value['gas_price'] = $gas_price;//燃料十六进制。由eth_estimateGas获取
-                $gas_limit = static::getGasLimit($value);
-                $value['gas_limit'] = $gas_limit;
-                $sign = static::sign($value, $from_key);          //交易签名
-				 
-                if ($sign === false) {
-                    $update_info['error'] = '签名失败';
-                    $update_info['status'] = 4;
-                } else {
-                    $update_info['sign'] = $sign;
-                    $update_info['status'] = 2;
-                    $update_info['nonce'] = $value['nonce'];
-                    $update_info['gas_limit'] = $value['gas_limit'];
-                    $update_info['gas_price'] = $value['gas_price'];
-                }
+            $ret = TronRPC::CreationTron()->getTransaction($value->{'hash'});
+            if (!empty($ret['ret'][0]['contractRet']) && $ret['ret'][0]['contractRet'] == 'SUCCESS') {
+                $update_info['status'] = 4;
+                $update_info['end_time'] = time();
+            } elseif (!empty($ret['ret'][0]['contractRet']) && $ret['ret'][0]['contractRet'] == 'REVERT') {
+                $update_info['status'] = 3;
             }
-            Broadcast::where('id', $value['id'])->update($update_info);
-            sleep(5);
+            if(!empty($update_info))Broadcast::where('id',$value->{'id'})->update($update_info);
         }
-        return true;
+        return $ret_type;
     }
 
-    /**
-     * 广播交易
-     * @return bool
-     */
-    public static function sendBroadcast()
-    {
-        $btc = BtcereumRPCServer::getInstance();
-        $eth = EthereumRPCServer::getInstance();
-        $list = Broadcast::where('status', '2')->select(['id', 'm_id', 'from', 'to', 'nonce', 'value', 'data', 'gas_price', 'gas_limit', 'sign', 'money', 'from_key', 'coin_id'])->limit(10)->get()->toArray();
-        if (empty($list)) return false;
-        foreach ($list as $value) {
-            $update_info = [];
-            if ($value['coin_id'] == 1) {
-                $txid = $btc->sendrawtransaction($value['sign']);
-                if ($txid == false) {
-                    $update_info['error'] = '广播失败';
-                    $update_info['status'] = 4;
-                } else {
-                    $update_info['hash'] = $txid;
-                    $update_info['status'] = 3;
-                }
-            } else {
-                $hash = $eth->sendRawTransaction($value['sign'], $error);//广播交易
-                if ($hash == false) {
-                    $update_info['error'] = json_encode($error);
-                    $update_info['status'] = 4;
-                } else {
-                    $update_info['hash'] = $hash;
-                    $update_info['status'] = 3;
-                }
-            }
-            Broadcast::where('id', $value['id'])->update($update_info);
-        }
-        return true;
-    }
 
     /**
-     * 广播查询
+     * 交易广播
      */
-    public static function getBroadcast(){
-        $btc = BtcereumRPCServer::getInstance();
-        $eth = EthereumRPCServer::getInstance();
-        $list = Broadcast::where('status', '3')->select(['id', 'm_id', 'from', 'to', 'send_money', 'value', 'coin_id', 'type', 'sign', 'money', 'from_key', 'coin_id','hash','send_money','order_id'])->limit(10)->get()->toArray();
-        if (empty($list)) return false;
-        foreach ($list as $value) {
-            $update_info = [];
-            if ($value['coin_id'] == 1) {
-                $deal_info=$btc->getrawtransaction ($value['hash'],true);
-                if(empty($deal_info['confirmations']) || $deal_info['confirmations'] <=3){
-                    continue;
-                }else{
-                    $update_info['success'] = json_encode($deal_info);
-                    $update_info['status'] = 5;
-                }
-            } else {
-                $receipt = $eth->getTransactionReceipt($value['hash']);//交易查询
-                if (empty($receipt)) {
-                    //交易正在广播中，下次继续查询
-                    continue;
-                } else {
-                    //交易已完成 返回数据格式数据 ,将数据json保存
-                    if ($receipt['status'] != '0x1') {
-                        $update_info['error'] = json_encode($receipt);
-                        $update_info['status'] = 4;
-                    }else{
-                        $update_info['success'] = json_encode($receipt);
-                        $update_info['status'] = 5;
-                    }
-
-                }
+    function sendBroadcast(){
+        $list = Broadcast::where('status', '1')->where([['end_time','=',0,'or'],['end_time','<=',time()-60,'or']])->select(['id', 'm_id', 'from', 'to', 'nonce', 'value', 'data', 'gas_price', 'gas_limit', 'sign', 'money', 'from_key', 'coin_id', 'depend','type','contract_address','order_id'])->limit(100)->get();
+        foreach ($list as $transaction){
+            //验证trx余额
+            $trx_num = TronRPC::CreationTron()->getBalance($transaction['from']);
+            if ($trx_num < 5) {
+                //trx不足，创建手续费订单
+                CommonServer::creatServer()->addErrorRecord('系统账户手续不足',$transaction);
+                continue;
             }
-            if(!empty($update_info)){
-                Broadcast::where('id', $value['id'])->update($update_info);
-                if($update_info['status']==5){
-                    //广播成功，增加会员余额
-                    if($value['type']<=3){
-                        $member_coin= MemberCoins::where('m_id',$value['m_id'])->where('coin_id',$value['coin_id'])->select(['id','coin_name','coin_id','num','m_id'])->first();
-                        MemberCoins::where('id',$member_coin->{'id'})->update(['num'=>$member_coin->{'num'}+$value['send_money']]);
-                        MoneyDetailServer::write($member_coin['coin_id'], MoneyDetailServer::$status['coin_recharge'], $value['send_money'], MoneyDetailServer::$add_reduce['add'], $member_coin->{'m_id'}, $member_coin->{'mobile'}, '充币' .$value['send_money'] .''. $member_coin->{'coin_name'}, '', $value['id'], $member_coin->{'num'}, 'Recharge ' . $member_coin->{'money'} . $member_coin->{'coin_name'});
-                    }elseif($value['type']<=6){
-                        $withdraws = Withdraw::where('id', $value['order_id'])->where('m_id', $value['m_id'])->first();
-                        if (!empty($withdraws)) {
-                            Withdraw::where('id', $value['order_id'])->update([ 'status' => '3']);
-                            $member_coin = MemberCoins::where('m_id', $value['m_id'])->where('coin_id', $value['coin_id'])->select(['id', 'coin_name', 'coin_id', 'num', 'm_id','lock_num'])->first();
-                            $lock_num = $member_coin->{'lock_num'} - $withdraws->{'money'};
-                            if ($lock_num < 0) $lock_num = 0;
-                            MemberCoins::where('id', $member_coin->{'id'})->update(['lock_num' => $lock_num]);
-                        }
+            $send_data =TronRPC::CreationTron()->createContract($transaction['to'], $transaction['contract_address'], $transaction['money'] * 1, $transaction['from']);
+            if(empty($send_data)){
+                CommonServer::creatServer()->addErrorRecord('交易信息生成失败',$transaction);
+                continue;
+            }else{
+                $sign_data = TronRPC::CreationTron()->signTransaction($send_data, PassServer::creatServer()->getSecretKey('sadsadas','1'));
+                if (empty($sign_data['signature'][0])) {
+                    CommonServer::creatServer()->addErrorRecord('签名失败',$sign_data);
+                    $transaction['status'] = 3;
+                } else {
+                    $transaction['sign'] = $sign_data['signature'][0];
+                    $hash_data = TronRPC::CreationTron()->sendRawTransaction($sign_data);
+                    if (empty($hash_data['result'])) {
+                        CommonServer::creatServer()->addErrorRecord('广播失败',$hash_data);
+                        $transaction['status'] = 3;
+                    } else {
+                        $transaction['hash'] = $hash_data['txid'];
+                        $transaction['status'] = 2;
                     }
                 }
+                $transaction->save();
             }
         }
-        return true;
-    }
-
-    /**
-     * 系统手续费转账
-     * @param $tx
-     * @param $member_id
-     * @return mixed
-     */
-    public static function withholdServiceCharge($tx, $member_id)
-    {
-        $eth = EthereumRPCServer::getInstance();
-        $gasPrice = $eth->getGasPrice(); // 手续费
-        $cb_address = Config::where('key', 'cb_address')->value('value');
-        $address_key = Config::where('key', 'address_key')->value('value');
-        $sys_wei=Config::where('key','service_charge')->value('value');
-        $service_money=Config::where('key','service_money')->value('value');
-        $sys_wei=empty($sys_wei)?'15':$sys_wei;
-        $service_money=empty($service_money)?'3000000000000000':$service_money;
-        $tx = [
-            'from' => $cb_address,
-            'to' => $tx['from'],
-            'value' => '0x0',
-            'data' => $tx['data'],
-        ];
-        $gasLimit = $eth->estimateGas($tx);
-        // 手续费交易 转账0.0015个
-        $serviceFee = Utils::dec2hex($service_money); // 手续费
-        // 广播手续费
-        $transaction = [
-            'depend' => 0,
-            'from' => $cb_address,
-            'to' => $tx['to'],
-            'nonce' => '',
-            'value' => $serviceFee,//转账0.004个
-            'data' => '0x0',
-            'money' => round($service_money/1000000000000000000,6),
-            'gas_limit' => $gasLimit,
-            'chain_id' => $eth->chainId,
-            'gas_price' => '',
-            'to_address' => $tx['to'],
-            'coin_id' => 2,
-            'sign' => '',
-            'hash' => '',
-            'from_key' => $address_key,//系统支付秘钥
-            'status' => 1,//系统支付秘钥
-            'type' => 7,//系统支付秘钥
-            'm_id' => 0,
-            'send_money' => round($service_money/1000000000000000000,6),
-        ];
-        $nonce = $eth->getTransactionCount($transaction['from']);
-        $transaction['nonce'] = $nonce;//交易顺序十六进制。由eth_getTransactionCount获取
-        $transaction['gas_price'] = Utils::dec2hex(Utils::toWei($sys_wei."gwei") + Utils::hex2dec($gasPrice));//燃料十六进制。由eth_estimateGas获取
-        $transaction['gas_limit'] = $gasLimit;
-        //写入数据库代码  $transaction
-        $nytr = Broadcast::create($transaction);
-        return $nytr->{'id'};
     }
 
 
-    /**
-     * 转账内容拼接
-     * @param $from
-     * @param $to
-     * @param $value
-     * @param $data
-     * @return array
-     * @throws
-     */
-    protected static function build($from, $to, $value, $data)
-    {
-        $tx = [];
-        $tx['from'] = $from;
-        $tx['to'] = $to;
-        $tx['value'] = $value;
-        $tx['data'] = $data;
 
-        return $tx;
-    }
 
-    /**
-     * @param  $transaction
-     * @return string
-     */
-    public static function getGasLimit($transaction)
-    {
-        $tx = [
-            'from' => $transaction['from'],
-            'to' => $transaction['to'],
-            'nonce' => $transaction['nonce'],
-            'value' => $transaction['value'],
-            'data' => $transaction['data'],
-            'chainId' => 1,
-            'gasPrice' => $transaction['gas_price'],
-        ];
-        $eth = EthereumRPCServer::getInstance();
-        $gasLimit = $eth->estimateGas($tx);
-        if (!$gasLimit) {
-            $gasLimit = 10 * 10000; // 预估失败, 最高10万
-        }
-        return $gasLimit;
-    }
 
-    protected static function sign($transaction, $key)
-    {
-        $tx = [
-            'from' => $transaction['from'],
-            'to' => $transaction['to'],
-            'nonce' => $transaction['nonce'],
-            'value' => $transaction['value'],
-            'data' => $transaction['data'],
-            'chainId' => $transaction['chain_id'],
-            'gasPrice' => $transaction['gas_price'],
-            'gasLimit' => $transaction['gas_limit'],
-        ];
-        // 数据签名
 
-        $tr = new Transaction($tx);
-        $tr->sign($key);
-        return Utils::fixHex($tr->serialize()->toString('hex'));
-    }
 }

app/Servers/CommonServer.php

@@ -386,5 +386,19 @@ class CommonServer
         }
     }
 
+    /**
+     * 记录错误信息
+     * @param $msg
+     * @param array $data
+     * @param int $mId
+     */
+    function addErrorRecord($msg,$data=[],$mId=0){
+        ErrorRecord::create([
+            'm_id' => $mId,
+            'msg' => $msg,
+            'data' => json_encode($data)
+        ]);
+    }
+
 
 }

app/Servers/ContractServer.php

@@ -0,0 +1,68 @@
+<?php
+
+
+namespace App\Servers;
+
+
+
+
+use App\Jobs\BusinessFileJob;
+use App\Jobs\MsgFileJob;
+use App\Models\BlockItems;
+use App\Models\Contract;
+use App\Models\ErrorRecord;
+
+/**
+ * Redis数据缓存类
+ */
+class ContractServer
+{
+
+
+    static private $server = '';
+
+
+    private function __construct()
+    {
+
+    }
+
+    /**
+     * 创建对象
+     * @return ContractServer
+     */
+    static function creatServer()
+    {
+        if (empty(self::$server)) {
+            self::$server = new  ContractServer();
+        }
+        return self::$server;
+    }
+
+
+    function broadcastDetection(BlockItems $blockItem){
+        //检测报单信息
+        $contract=Contract::where('hash',$blockItem->{'hash'})->first();
+        if($contract){
+            if($contract->{'status'}!=1){
+                ErrorRecord::create([
+                    'm_id' => 0,
+                    'msg' => '合约状态从异常',
+                    'data' => json_encode($contract)
+                ]);
+            }else{
+                //检测交易信息
+
+                if($contract->{'type'}==1){
+                    //初始合约
+
+                }else{
+                    //复投合约
+                }
+            }
+        }
+    }
+
+
+
+}

app/Servers/Icon/TronRPC.php

@@ -124,6 +124,20 @@ class TronRPC
         return $new_str;
     }
 
+    /**
+     * 获取交易详情
+     * @param $txID
+     * @return array|\string[][][]
+     */
+    function getTransaction($txID){
+        try {
+            $data = $this->getTron()->getTransaction($txID);
+        }catch (\Exception $e){
+            $data=['ret'=>[['contractRet'=>'']]];
+        }
+        return $data;
+    }
+
 
     /**
      * 获取TRX数量

app/Servers/JobServer.php

@@ -0,0 +1,54 @@
+<?php
+
+
+namespace App\Servers;
+
+
+
+
+use App\Jobs\BoadcastDetectionJob;
+use App\Jobs\BusinessFileJob;
+use App\Jobs\MsgFileJob;
+use App\Models\BlockItems;
+
+/**
+ * Redis数据缓存类
+ */
+class JobServer
+{
+
+
+    static private $server = '';
+
+
+    private function __construct()
+    {
+
+    }
+
+    /**
+     * 创建对象
+     * @return JobServer
+     */
+    static function creatServer()
+    {
+        if (empty(self::$server)) {
+            self::$server = new  JobServer();
+        }
+        return self::$server;
+    }
+
+    /**
+     * 任务图片处理
+     * @param $blockItem
+     * @return void
+     */
+    function broadcastDetectionJob(BlockItems $blockItem){
+        BoadcastDetectionJob::dispatch($blockItem)->delay(3)->onConnection('redis')->onQueue('broadcastDetection');
+    }
+
+
+
+
+
+}

app/Servers/PassServer.php

@@ -155,7 +155,7 @@ class PassServer
 
 
 
-    public static function setSecretKey($private_key, $key_num = 0)
+    public  function setSecretKey($private_key, $key_num = 0)
     {
         $key_num = $key_num % 20;
         if ($key_num == 0) $key_num = 15;
@@ -166,7 +166,12 @@ class PassServer
         return $new_private;
     }
 
-    public static function getSecretKey($private_key, $key_num = 0)
+    /**
+     * @param $private_key
+     * @param int $key_num
+     * @return string
+     */
+    public  function getSecretKey($private_key, $key_num = 0)
     {
         $key_num = $key_num % 20;
         if ($key_num == 0) $key_num = 15;

任务.txt

@@ -0,0 +1,13 @@
+//队列 （编号监测）
+nohup php artisan queue:work redis --queue=broadcastDetection  --sleep=3 --tries=3 --timeout=120 &
+
+
+
+
+
+
+
+
+
+
+