";
                echo $value['tron_address'].'-----'. base64_decode($value['tron_private_key']).'-----'.$usdt;
            }
        }
    }

    //止盈止损平仓
    public function contract_deal()
    {
        $redis = getRedis();
        echo "合约止盈止损---";
        $running = $redis->get('contract_deal');
        if($running) {
            echo' is running';
            $redis->set('contract_deal', false);
            exit;
        }
        $contract = Db::name('app_contract')
            ->where('status','1')
//            ->where('user_id','3736')
            ->select();
//        echo '
';var_dump($contract);exit;
        foreach ($contract as $key=>$value)
        {
            if($value['zy_price'] <= 0 && $value['zs_price']<=0) continue;
            $coin = Db::name('app_rate')
                ->where('symbol',$value['symbol'])
                ->find();
            //调整价格
            $tradejson = json_decode($coin['tradectrl_json'],true);
            $jd = $coin['jd'];
            $hour = date('H');
            $minute = date('i');
            $prices = $num = 0;
            if($tradejson) {
                foreach ($tradejson as $keys => $values) {
                    $time1 = explode('-', $keys);
                    $time2 = explode(':', $time1[0]);
                    $time3 = explode(':', $time1[1]);
                    $pricearr = explode('-', $values);
                    if ($hour >= $time2[0] && $hour <= $time3[0]) {
                        if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                        $prices = (float)$this->randomFloat($pricearr[0], $pricearr[1], $jd);
                        break;
                    }
                }
                if ($prices > 0) $coin['close'] = $prices;
            }

            $user = Db::name('user')->where('id',$value['user_id'])->find();
            //个人调整价格
            $tradejsons = json_decode($user['tradectrl_json'],true);
            if($tradejsons) {
                $pricess = 0;
                foreach ($tradejsons as $keys => $values) {
                    if($keys == $coin['symbol']) {
                        $jsonarr = explode('|',$values);
                        if(!isset($jsonarr[0]) || !isset($jsonarr[1])) continue;
                        $time1 = explode('-',$jsonarr[0]);
                        $time2 = explode(':', $time1[0]);
                        $time3 = explode(':', $time1[1]);
                        $pricearr = explode('-', $jsonarr[1]);
                        if(!isset($pricearr[0]) || !isset($pricearr[1])) continue;
                        if ($hour >= $time2[0] && $hour <= $time3[0]) {
                            if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                            $pricess = (float)$this->randomFloat($pricearr[0], $pricearr[1], $jd);
                            break;
                        }
                    }
                }
                if ($pricess > 0) $coin['close'] = $pricess;
            }
            $release = Db::name("app_curr_release")->where("symbol",$coin['symbol'])->find();
            if($release){
                $trademulte_json = json_decode($release['trademulte_json'],true);
                if($trademulte_json && !$prices){
                    foreach ($trademulte_json as $kk => $vv) {
                        $time1 = explode('-', $kk);
                        $time2 = explode(':', $time1[0]);
                        $time3 = explode(':', $time1[1]);
                        if ($hour >= $time2[0] && $hour <= $time3[0]) {
                            if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                            $datass = json_decode(http_curl('https://api.huobi.pro/market/history/kline?period=1min&size=1&symbol='.$release['symbol'],'get'),true);
                            if(!$datass || !isset($datass['data']) || empty($datass['data']))
                            {
                                $coin['close'] = $coin['close'];
                                break;
                            }
                            $coin['close'] = $datass['data'][0]['close'] * $vv;
                            break;
                        }
                    }
                }
            }

//            if(($coin['close'] > $value['zy_price'] && $coin['close']>$value['price'] && $value['zy_price'] > 0) ||
//                ($coin['close'] < $value['zs_price'] && $coin['close']<$value['price'] && $value['zs_price'] > 0)) {
//                var_dump($value['type'],$coin['close'],$value['zy_price'],$value['zs_price']);
            $flag = false;
            $newprices = 0;
            if($value['type'] == 'more' && $coin['close'] > $value['zy_price'] && $value['zy_price']>0){
                $flag = true;
                $newprices = $value['zy_price'];
            }else if($value['type'] == 'more' && $coin['close'] < $value['zs_price'] && $value['zs_price'] > 0){
                $flag = true;
                $newprices = $value['zs_price'];
            }
            if($value['type'] == 'free' && $coin['close'] < $value['zy_price'] && $value['zy_price']>0){
                $flag = true;
                $newprices = $value['zy_price'];
            }else if($value['type'] == 'free' && $coin['close'] > $value['zs_price'] && $value['zs_price']>0){
                $flag = true;
                $newprices = $value['zs_price'];
            }
            if(!$flag) continue;
            $coin['close'] = $newprices;

//                if($coin['close'] > $value['zy_price'] && $value['zy_price'] > 0)
//                {
//                    $coin['close'] = $value['zy_price'];
//                }else if($coin['close'] < $value['zs_price'] && $value['zs_price'] > 0)
//                {
//                    $coin['close'] = $value['zs_price'];
//                }

            $diffnum = $coin['close'] - $value['price'];
            if ($value['type'] == 'more') {
                //计算收益
//                $income = $diffnum / 100 * $value['num'] * $value['multiple'] * Config::get('site.shizhi');
                $income = $diffnum * $value['num'] * Config::get('site.shizhi');
            } else {
                if ($diffnum < 0) {
//                    $income = abs($diffnum) / 100 * $value['num'] * $value['multiple'] * Config::get('site.shizhi');
                    $income = abs($diffnum) * $value['num'] * Config::get('site.shizhi');
                } else {
//                    $income = 0 - $diffnum / 100 * $value['num'] * $value['multiple'] * Config::get('site.shizhi');
                    $income = 0 - $diffnum * $value['num'] * Config::get('site.shizhi');
                }
            }
            $benjin = $value['promise_fee'];
            $income = sprintf('%.6f', $income);
            $flags = false;
            //爆仓
            if($income<0 && abs($income) > $benjin)
            {
                $flags = true;
                $income = 0 - $benjin;
            }

            $currency = Db::name('app_currency_user')
                ->field('num,id')
                ->where('user_id',$value['user_id'])
                ->where('curr_id',1)->find();

            $detailed = [
                'user_id' => $value['user_id'],
                'curr_id' => 1,
                'price' => abs($income),
                'cart' => '2',
                'type' => '6',
                'serial_no' => time().Random::build('numeric',4),
                'order_result' => 'result',
                'description' => '合约交易平仓',
                'createtime' => time(),
                'notice' => '合约交易平仓',
                'before_num' => $currency['num'],
                'after_num' => $currency['num'] + $income,
            ];
            if($income >0 ){
                $detailed['cart'] = '1';
                $detailed['description'] = '合约交易平仓盈利';
            }else{
                $detailed['cart'] = '2';
                $detailed['description'] = '合约交易平仓亏损';
            }

            $detaileds[] = $detailed;
            if(!$flags) {
                $detaileds[] = [
                    'user_id' => $value['user_id'],
                    'curr_id' => 1,
                    'price' => $value['promise_fee'],
                    'cart' => '1',
                    'type' => '6',
                    'serial_no' => time() . Random::build('numeric', 4),
                    'order_result' => 'result',
                    'description' => '合约交易保证金',
                    'createtime' => time(),
                    'notice' => '合约交易保证金',
                    'before_num' => $detailed['after_num'],
                    'after_num' => $detailed['after_num'] + $value['promise_fee'],
                ];
                $lostnum =  sprintf("%.6f",($currency['num'] + $income + $value['promise_fee']));
            }
            Db::startTrans();
            try {
                if(!$flags) {
                    $ret = Db::name('app_currency_user')
                        ->where('id', $currency['id'])->update(['num' => $lostnum, 'updatetime' => time()]);
                    if (!$ret) {
                        Db::rollback();
                        continue;
                    }
                }
                $ret1 = Db::name('app_contract')->where('id',$value['id'])
                    ->update(['status'=>'2','pc_price'=>$coin['close'],'pctime'=>time(),'income'=>$income]);
                if(!$ret1)
                {
                    Db::rollback();
                    continue;
                }
                $ret2 = Db::name('app_detailed')->insertAll($detaileds);
                if(!$ret2)
                {
                    Db::rollback();
                    continue;
                }
                Db::commit();
                echo '合约-'.$value['id'].'止盈止损平仓----';
            } catch (Exception $e) {
                Db::rollback();
            }
        }
//        }
        $redis->set('contract_deal', false);
    }

    //爆仓处理
    public function baocang()
    {
        $redis = getRedis();
        echo "合约爆仓---";
        $running = $redis->get('baocang');
        if($running) {
            echo' is running';
            $redis->set('baocang', false);
            exit;
        }
        $contract = Db::name('app_contract')
//            ->where('user_id',3727)
            ->where('status','1')->select();
        foreach ($contract as $key=>$value)
        {
            $coin = Db::name('app_rate')
                ->where('symbol',$value['symbol'])
                ->find();
            //调整价格
            $tradejson = json_decode($coin['tradectrl_json'],true);
            $jd = $coin['jd'];
            $hour = date('H');
            $minute = date('i');
            $prices = $num = 0;
            if($tradejson) {
                foreach ($tradejson as $keys => $values) {
                    $time1 = explode('-', $keys);
                    $time2 = explode(':', $time1[0]);
                    $time3 = explode(':', $time1[1]);
                    $pricearr = explode('-', $values);
                    if ($hour >= $time2[0] && $hour <= $time3[0]) {
                        if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                        $prices = (float)$this->randomFloat($pricearr[0], $pricearr[1], $jd);
                        break;
                    }
                }
                if ($prices > 0) $coin['close'] = $prices;
            }

            $user = Db::name('user')->where('id',$value['user_id'])->find();
            //个人调整价格
            $tradejsons = json_decode($user['tradectrl_json'],true);
            if($tradejsons) {
                $pricess = 0;
                foreach ($tradejsons as $keys => $values) {
                    if($keys == $coin['symbol']) {
                        $jsonarr = explode('|',$values);
                        if(!isset($jsonarr[0]) || !isset($jsonarr[1])) continue;
                        $time1 = explode('-',$jsonarr[0]);
                        $time2 = explode(':', $time1[0]);
                        $time3 = explode(':', $time1[1]);
                        $pricearr = explode('-', $jsonarr[1]);
                        if(!isset($pricearr[0]) || !isset($pricearr[1])) continue;
                        if ($hour >= $time2[0] && $hour <= $time3[0]) {
                            if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                            $pricess = (float)$this->randomFloat($pricearr[0], $pricearr[1], $jd);
                            break;
                        }
                    }
                }
                if ($pricess > 0) $coin['close'] = $pricess;
            }
            
            $release = Db::name("app_curr_release")->where("symbol",$coin['symbol'])->find();
            if($release){
                $trademulte_json = json_decode($release['trademulte_json'],true);
                if($trademulte_json && !$prices){
                    foreach ($trademulte_json as $kk => $vv) {
                        $time1 = explode('-', $kk);
                        $time2 = explode(':', $time1[0]);
                        $time3 = explode(':', $time1[1]);
                        if ($hour >= $time2[0] && $hour <= $time3[0]) {
                            if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                            $datass = json_decode(http_curl('https://api.huobi.pro/market/history/kline?period=1min&size=1&symbol='.$release['symbol'],'get'),true);
                            if(!$datass || !isset($datass['data']) || empty($datass['data']))
                            {
                                $coin['close'] = $coin['close'];
                                break;
                            }
                            $coin['close'] = $datass['data'][0]['close'] * $vv;
                            break;
                        }
                    }
                }
            }

            $diffnum = $coin['close'] - $value['price'];
            if($value['type'] == 'more')
            {
                //计算收益
//                $income = $diffnum / 100 * $value['num'] * $value['multiple'] * Config::get('site.shizhi');
                $income = $diffnum * $value['num'] * Config::get('site.shizhi');
            }else{
                if($diffnum < 0) {
//                    $income = abs($diffnum) / 100 * $value['num'] * $value['multiple'] * Config::get('site.shizhi');
                    $income = abs($diffnum) * $value['num'] * Config::get('site.shizhi');
                }else{
//                    $income = 0 - $diffnum / 100 * $value['num'] * $value['multiple'] * Config::get('site.shizhi');
                    $income = 0 - $diffnum * $value['num'] * Config::get('site.shizhi');
                }
            }
            $benjin = $value['promise_fee'];
            $income = sprintf('%.6f',$income);
            $flags = false;
            //爆仓
            if($income<0 && abs($income) > $benjin)
            {
                $currency = Db::name('app_currency_user')
                    ->field('num,id')
                    ->where('user_id',$value['user_id'])
                    ->where('curr_id',1)->find();
                $flags = true;
                $income = 0 - $benjin;
                $detailed = [
                    'user_id' => $value['user_id'],
                    'curr_id' => 1,
                    'price' => abs($income),
                    'cart' => '2',
                    'type' => '6',
                    'serial_no' => time().Random::build('numeric',4),
                    'order_result' => 'result',
                    'description' => '合约交易平仓',
                    'createtime' => time(),
                    'notice' => '合约交易平仓',
                    'before_num' => $currency['num'],
                    'after_num' => $currency['num'],
                ];
                if($income >0 ){
                    $detailed['cart'] = '1';
                    $detailed['description'] = '合约交易平仓盈利';
                }else{
                    $detailed['cart'] = '2';
                    $detailed['description'] = '合约交易平仓亏损';
                }
                $ret1 = Db::name('app_contract')->where('id',$value['id'])
                    ->update(['status'=>'2','pc_price'=>$coin['close'],'pctime'=>time(),'income'=>$income]);
                $ret2 = Db::name('app_detailed')->insert($detailed);
                echo '合约-'.$value['id'].'-爆仓------';
            }
        }
        $redis->set('baocang', false);
//        echo "
";var_dump($contract);

    }

    //限价合约入场
    public function limit_comein()
    {
        echo "合约";
        $redis = getRedis();
        $running = $redis->get('contractdeal');
        if($running) {
            echo' is running';
            $redis->set('contractdeal', false);
            exit;
        }
        $contract = Db::name('app_contract')
            ->where('status','0')->order('id','asc')->select();
        foreach ($contract as $key=>$value)
        {
            $coin = Db::name('app_rate')
                ->where('id',$value['coin_id'])->find();
            //调整价格
            $tradejson = json_decode($coin['tradectrl_json'],true);
            $jd = $coin['jd'];
            $hour = date('H');
            $minute = date('i');
            $prices = $coin['close'];
            $num = 0;
            if($tradejson) {
                foreach ($tradejson as $keys => $values) {
                    $time1 = explode('-', $keys);
                    $time2 = explode(':', $time1[0]);
                    $time3 = explode(':', $time1[1]);
                    $pricearr = explode('-', $values);
                    if ($hour >= $time2[0] && $hour <= $time3[0]) {
                        if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                        $prices = (float)$this->randomFloat($pricearr[0], $pricearr[1], $jd);
                        break;
                    }
                }
                if ($prices > 0) $coin['close'] = $prices;
            }

            $user = Db::name('user')->where('id',$value['user_id'])->find();
            //个人调整价格
            $tradejsons = json_decode($user['tradectrl_json'],true);
            if($tradejsons) {
                $pricess = 0;
                foreach ($tradejsons as $keys => $values) {
                    if($keys == $coin['symbol']) {
                        $jsonarr = explode('|',$values);
                        if(!isset($jsonarr[0]) || !isset($jsonarr[1])) continue;
                        $time1 = explode('-',$jsonarr[0]);
                        $time2 = explode(':', $time1[0]);
                        $time3 = explode(':', $time1[1]);
                        $pricearr = explode('-', $jsonarr[1]);
                        if(!isset($pricearr[0]) || !isset($pricearr[1])) continue;
                        if ($hour >= $time2[0] && $hour <= $time3[0]) {
                            if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                            $pricess = (float)$this->randomFloat($pricearr[0], $pricearr[1], $jd);
                            break;
                        }
                    }
                }
                if ($pricess > 0) $coin['close'] = $pricess;
                $prices = $coin['close'];
            }

            if($prices <= 0) continue;

            $flag = false;
            if($value['type'] == 'more' && $coin['close'] <= $value['price']){
                $flag = true;
            }else if($value['type'] == 'free' && $coin['close'] >= $value['price'])
            {
                $flag = true;
            }
            if($flag)
            {
                $update = [
                    'status' => '1',
//                    'price' => $prices,
                    'updatetime' => time()
                ];
                $ret = Db::name('app_contract')->where('id',$value['id'])
                    ->update($update);
                echo "限价合约：".$value['id'].'入场';
                if($ret)
                break;
            }
        }
        $redis->set('contractdeal', false);

    }

    //币币撮合交易
    public function coin_deal()
    {
        echo 'coin trade ---';
        $order = Db::name('app_coin_trade')
            ->whereIn('status','0,1')
            ->where('cart','market')
            ->order('id','desc')->find();
        $rates = Db::name('app_rate')
                ->select();
        $rate_arr = array_column($rates,'close','id');
        if(empty($order))
        {
            $orders = Db::name('app_coin_trade a')
                ->field('a.*')
                ->join('app_rate b','a.coin_id=b.id','left')
                ->whereIn('a.status','0,1')
                ->where('a.type','buy')
                ->where('a.cart','limit')
                ->select();
            $order = [];
            foreach ($orders as $key => $value)
            {
                if(isset($rate_arr[$value['coin_id']]) && $value['price'] >= $rate_arr[$value['coin_id']]){
                    $order = $value;
                    break;
                }
            }

            if(empty($order))
            {
                $orders = Db::name('app_coin_trade a')
                ->field('a.*')
                ->join('app_rate b','a.coin_id=b.id','left')
                ->whereIn('a.status','0,1')
                ->where('a.type','sell')
                ->where('a.cart','limit')
                ->select();
                $order = [];
                foreach ($orders as $key => $value)
                {
                    if(isset($rate_arr[$value['coin_id']]) && $value['price'] <= $rate_arr[$value['coin_id']]){
                        $order = $value;
                        break;
                    }
                }
            }

        }
        // echo "
";
        // var_dump($order);exit;
        if(empty($order)){
            echo "暂无订单";exit;
        }
        $redis = getRedis();
        $running = $redis->get('cointrades');
        if($running) {
            echo' is running';
            $redis->set('cointrades', false);
            exit;
        }
        $redis->set('cointrades', time(), 60);
        $coin = Db::name('app_rate')
            ->where('id',$order['coin_id'])
            ->find();
        $currency = Db::name('app_currency')
            ->where('suffix',$coin['symbol'])->find();
        $prices = $coin['close'];

        $user = Db::name('user')->where('id',$order['user_id'])->find();
        if($order['cart'] == 'limit' && $order['type'] == 'buy' && $order['price'] < $prices)
        {
            echo $order['id'].'-'.'价格未达限价-'.$order['price'].'-当前价格-'.$prices;
            $redis->set('cointrades', false);
            exit;
        }
        $trade_order = [];
        $ordersn = 'C' . time() . Random::build('numeric', 4);
        
        //质押手续费折扣
        $count_zhiya = Db::name("app_zhiya_user")->where("user_id", $order['user_id'])->where("status",1)->sum("num");
        $zhiya_free_rebate = Config::get("site.zhiya_free_rebate");
        $zhekou = 1;
        foreach ($zhiya_free_rebate as $key => $value) {
            if($count_zhiya > $key){
                $zhekou = $value;
            }
        }
        //手续费
        $market_bb_free = Config::get("site.market_bb_free")*$zhekou/100;
        //现价买 市价买(高->低) 现价卖 市价卖(低->高)
        if($order['type'] == 'buy') {
            $tradenum = sprintf('%.6f', $order['amount'] / $prices);
            $amount = $order['amount'];
            $fee = sprintf('%.8f', $tradenum * $market_bb_free);
            $fee_type = 1;
            ////是否开启APT手续费支付
            if($user['apy_pay'] == 1){
                //开启apt手续费支付
                $apt_free = Config::get("site.apt_free");
                $apy_curr = Db::name("app_currency")->where("id",2)->find();
                $res_curr = Db::name("app_currency")->where("suffix",$coin['symbol'])->find();
                $apy_num = sprintf("%.8f",$fee*$res_curr['exchange']/$apy_curr['exchange']*$apt_free);
                $user_apy = Db::name('app_currency_user')->where('curr_id',2)->where('user_id',$order['user_id'])->find();
                if($user_apy['num'] >= $apy_num){
                    //达到APT手续费支付条件
                    $fee = $apy_num;
                    $fee_type = 2;
                    $detailed[] = [
                        'user_id' => $order['user_id'],
                        'curr_id' => $user_apy['curr_id'],
                        'price' => $apy_num,
                        'cart' => '2',
                        'type' => '7',
                        'serial_no' => 'C'.time().Random::build('numeric',4),
                        'order_result' => 'result',
                        'description' => '币币APT手续费',
                        'createtime' => time(),
                        'notice' => '币币APT手续费',
                        'before_num' => $user_apy['num'],
                        'after_num' => $user_apy['num'] - $apy_num,
                    ];
                }
            }
            $trade_order[] = [
                'user_id' => $order['user_id'],
                'coin_id' => $order['coin_id'],
                'trade_id' => $order['id'],
                'num' => $tradenum,
                'price' => $prices,
                'amount' => $order['amount'],
                'fee' => $fee,
                'createtime' => time(),
                'type' => 'buy',
                'order_sn' => $ordersn,
                'fee_type' => $fee_type,
            ];
        }else{
            $tradenum = $order['num'];
            $amount = sprintf('%.6f',$tradenum * $prices);
            $fee = sprintf('%.8f',$amount*$market_bb_free);
            $fee_type = 1;//
            ////是否开启APT手续费支付
            if($user['apy_pay'] == 1){
                //开启apt手续费支付
                $apt_free = Config::get("site.apt_free");
                $apy_curr = Db::name("app_currency")->where("id",2)->find();
                $res_curr = Db::name("app_currency")->where("suffix",$coin['symbol'])->find();
                $apy_num = sprintf("%.6f",$fee*$res_curr['exchange']/$apy_curr['exchange']*$apt_free);
                $user_apy = Db::name('app_currency_user')->where('curr_id',2)->where('user_id',$order['user_id'])->find();
                if($user_apy['num'] >= $apy_num){
                    //达到APT手续费支付条件
                    $fee = $apy_num;
                    $fee_type = 2;
                    $detailed[] = [
                        'user_id' => $order['user_id'],
                        'curr_id' => $user_apy['curr_id'],
                        'price' => $apy_num,
                        'cart' => '2',
                        'type' => '7',
                        'serial_no' => 'C'.time().Random::build('numeric',4),
                        'order_result' => 'result',
                        'description' => '币币APT手续费',
                        'createtime' => time(),
                        'notice' => '币币APT手续费',
                        'before_num' => $user_apy['num'],
                        'after_num' => $user_apy['num'] - $apy_num,
                    ];
                }
            }
            $trade_order[] = [
                'user_id' => $order['user_id'],
                'coin_id' => $order['coin_id'],
                'trade_id' => $order['id'],
                'num' => $tradenum,
                'price' => $prices,
                'amount' => $amount,
                'fee' => $fee,
                'createtime' => time(),
                'type' => 'sell',
                'order_sn' => $ordersn,
                'fee_type' => $fee_type,
            ];
        }

            Db::startTrans();
            try {
                Db::name('app_coin_trade_order')->insertAll($trade_order);
                
                $update1['status'] = '2';
                $update1['finishtime'] = time();
                if($order['cart'] == 'market'){
                    $update1['price'] = $prices;
                }
                $update1['num'] = $tradenum;
                $update1['amount'] = $amount;
                $update1['updatetime'] = time();

                Db::name('app_coin_trade')->where('id', $order['id'])->update($update1);
                if($order['type'] == 'buy') {
                    $currency1 = Db::name('app_currency_user')->where('user_id', $order['user_id'])->where('curr_id', $currency['id'])->find();
                    if($fee_type == 2){
                        //使用APT来支付手续费
                        $upnum = $currency1['num'] + $tradenum;
                        Db::name('app_currency_user')->where('id', $user_apy['id'])->update(['num' => $user_apy['num']-$apy_num]);
                        $last_price = $tradenum;
                    }else{
                        $upnum = $currency1['num'] + $tradenum - $trade_order[0]['fee'];
                        $last_price = $tradenum - $trade_order[0]['fee'];
                    }
                    Db::name('app_currency_user')->where('id', $currency1['id'])->update(['num' => $upnum, 'updatetime' => time()]);
                    
                    $detailed[] = [
                        'user_id' => $order['user_id'],
                        'curr_id' => $currency['id'],
                        'price' => $last_price,
                        'cart' => '1',
                        'type' => '7',
                        'serial_no' => 'C'.time().Random::build('numeric',4),
                        'order_result' => 'result',
                        'description' => '币币交易买入',
                        'createtime' => time(),
                        'notice' => '币币交易买入',
                        'before_num' => $currency1['num'],
                        'after_num' => $upnum,
                    ];
                    Db::name('app_detailed')->insertAll($detailed);
                }else{
                    $currency = Db::name('app_currency_user')->where('user_id', $order['user_id'])->where('curr_id', 1)->find();
                    if($fee_type == 2){
                        //使用APT来支付手续费
                        $upnum = $currency['num'] + $amount;
                        Db::name('app_currency_user')->where('id', $user_apy['id'])->update(['num' => $user_apy['num']-$apy_num]);
                        $last_price = $amount;
                    }else{
                        $upnum = $currency['num'] + $amount  - $trade_order[0]['fee'];
                        $last_price = $amount - $trade_order[0]['fee'];
                    }
                    Db::name('app_currency_user')->where('id', $currency['id'])->update(['num' => $upnum, 'updatetime' => time()]);
                    
                    $detailed[] = [
                        'user_id' => $order['user_id'],
                        'curr_id' => 1,
                        'price' => $last_price,
                        'cart' => '1',
                        'type' => '7',
                        'serial_no' => 'C'.time().Random::build('numeric',4),
                        'order_result' => 'result',
                        'description' => '币币交易买入',
                        'createtime' => time(),
                        'notice' => '币币交易买入',
                        'before_num' => $currency['num'],
                        'after_num' => $upnum,
                    ];
                    Db::name('app_detailed')->insertAll($detailed);
                }

                Db::commit();
                $redis->set('cointrades', false);
                echo '交易单：'.$order['id'].'已成交-';
            } catch (Exception $e) {
                Db::rollback();
            }
        $redis->set('cointrades', false);

    }
    
    //币币撮合交易-所有市价
    public function coin_deal_marketall()
    {
        echo 'coin trade ---';
        $order = Db::name('app_coin_trade')
                ->whereIn('status','0,1')
                ->where('cart','market')
                ->order('id','asc')
                ->select();
        if(empty($order))
        {
            echo "暂无订单";exit;

        }
        $redis = getRedis();
        $running = $redis->get('cointrades_marketall');
        if($running) {
            echo' is running';
            $redis->set('cointrades_marketall', false);
            exit;
        }
        $redis->set('cointrades_marketall', time(), 60);
        foreach ($order as $kkk => $vvvvv) {
            $coin = Db::name('app_rate')->where('id',$vvvvv['coin_id'])->find();
            $currency = Db::name('app_currency')
                ->where('suffix',$coin['symbol'])->find();
            $prices = $coin['close'];
            
            //价格调整
            if(strtolower($coin['name'])."usdt" == $coin['symbol']){
                $trademulte_json = json_decode($coin['trademulte_json'],true);
                $hour = date('H');
                $minute = date('i');
                if($trademulte_json){
                    foreach ($trademulte_json as $kk => $vv) {
                        $time1 = explode('-', $kk);
                        $time2 = explode(':', $time1[0]);
                        $time3 = explode(':', $time1[1]);
                        if ($hour >= $time2[0] && $hour <= $time3[0]) {
                            if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                            $prices = $prices * $vv;
                            break;
                        }
                    }
                }
            }

            $trade_order = [];
            $ordersn = 'C' . time() . Random::build('numeric', 4);

            //质押手续费折扣
            $zhekou = 1;
            //手续费
            $market_bb_free = Config::get("site.market_bb_free")*$zhekou/100;
            //现价买 市价买(高->低) 现价卖 市价卖(低->高)
            if($vvvvv['type'] == 'buy') {
                $tradenum = sprintf('%.6f', $vvvvv['amount'] / $prices);
                $amount = $vvvvv['amount'];
                $fee = sprintf('%.8f', $tradenum * $market_bb_free);
                $fee_type = 1;
                $trade_order[] = [
                    'user_id' => $vvvvv['user_id'],
                    'coin_id' => $vvvvv['coin_id'],
                    'trade_id' => $vvvvv['id'],
                    'num' => $tradenum,
                    'price' => $prices,
                    'amount' => $vvvvv['amount'],
                    'fee' => $fee,
                    'createtime' => time(),
                    'type' => 'buy',
                    'order_sn' => $ordersn,
                    'fee_type' => $fee_type,
                ];
            }else{
                $tradenum = $vvvvv['num'];
                $amount = sprintf('%.6f',$tradenum * $prices);
                $fee = sprintf('%.8f',$amount*$market_bb_free);
                $fee_type = 1;
                $trade_order[] = [
                    'user_id' => $vvvvv['user_id'],
                    'coin_id' => $vvvvv['coin_id'],
                    'trade_id' => $vvvvv['id'],
                    'num' => $tradenum,
                    'price' => $prices,
                    'amount' => $amount,
                    'fee' => $fee,
                    'createtime' => time(),
                    'type' => 'sell',
                    'order_sn' => $ordersn,
                    'fee_type' => $fee_type,
                ];
            }

            Db::startTrans();
            try {
                $detailed = [];
                Db::name('app_coin_trade_order')->insertAll($trade_order);

                $update1['status'] = '2';
                $update1['finishtime'] = time();
                if($vvvvv['cart'] == 'market'){
                    $update1['price'] = $prices;
                }
                $update1['num'] = $tradenum;
                $update1['amount'] = $amount;
                $update1['updatetime'] = time();

                Db::name('app_coin_trade')->where('id', $vvvvv['id'])->update($update1);
                if($vvvvv['type'] == 'buy') {
                    $currency1 = Db::name('app_currency_user')->where('user_id', $vvvvv['user_id'])->where('curr_id', $currency['id'])->find();
                    $upnum = $currency1['num'] + $tradenum - $trade_order[0]['fee'];
                    $last_price = $tradenum - $trade_order[0]['fee'];
                    Db::name('app_currency_user')->where('id', $currency1['id'])->update(['num' => $upnum, 'updatetime' => time()]);

                    $detailed[] = [
                        'user_id' => $vvvvv['user_id'],
                        'curr_id' => $currency['id'],
                        'price' => $last_price,
                        'cart' => '1',
                        'type' => '7',
                        'serial_no' => 'C'.time().Random::build('numeric',4),
                        'order_result' => 'result',
                        'description' => '币币交易买入',
                        'createtime' => time(),
                        'notice' => '币币交易买入',
                        'before_num' => $currency1['num'],
                        'after_num' => $upnum,
                    ];
                    Db::name('app_detailed')->insertAll($detailed);
                }else{
                    $currency = Db::name('app_currency_user')->where('user_id', $vvvvv['user_id'])->where('curr_id', 1)->find();
                    $upnum = $currency['num'] + $amount  - $trade_order[0]['fee'];
                    $last_price = $amount - $trade_order[0]['fee'];
                    Db::name('app_currency_user')->where('id', $currency['id'])->update(['num' => $upnum, 'updatetime' => time()]);

                    $detailed[] = [
                        'user_id' => $vvvvv['user_id'],
                        'curr_id' => 1,
                        'price' => $last_price,
                        'cart' => '1',
                        'type' => '7',
                        'serial_no' => 'C'.time().Random::build('numeric',4),
                        'order_result' => 'result',
                        'description' => '币币交易买入',
                        'createtime' => time(),
                        'notice' => '币币交易买入',
                        'before_num' => $currency['num'],
                        'after_num' => $upnum,
                    ];
                    Db::name('app_detailed')->insertAll($detailed);
                }
                Db::commit();
                $redis->set('cointrades_marketall', false);
                echo '交易单：'.$vvvvv['id'].'已成交-';
            } catch (Exception $e) {
                Db::rollback();
            }
        }
        
        $redis->set('cointrades_marketall', false);

    }
    
    //币币撮合交易 - 限价所有
    public function coin_deal_limitall()
    {
        echo 'coin trade ---';
        $order = Db::name('app_coin_trade')
                ->whereIn('status','0,1')
                ->where('cart','limit')
                ->order('id','desc')
                ->select();
        if(empty($order)){
            echo "暂无订单";exit;
        }
        $redis = getRedis();
        $running = $redis->get('cointrades_limitall');
        if($running) {
            echo' is running';
            $redis->set('cointrades_limitall', false);
            exit;
        }
        $redis->set('cointrades_limitall', time(), 60);
        foreach ($order as $kkk => $vvvvv) {
            $coin = Db::name('app_rate')->where('id',$vvvvv['coin_id'])->find();
            $currency = Db::name('app_currency')
                ->where('suffix',$coin['symbol'])->find();
            $prices = $coin['close'];
            
            //价格调整
            if(strtolower($coin['name'])."usdt" == $coin['symbol']){
                $trademulte_json = json_decode($coin['trademulte_json'],true);
                $hour = date('H');
                $minute = date('i');
                if($trademulte_json){
                    foreach ($trademulte_json as $kk => $vv) {
                        $time1 = explode('-', $kk);
                        $time2 = explode(':', $time1[0]);
                        $time3 = explode(':', $time1[1]);
                        if ($hour >= $time2[0] && $hour <= $time3[0]) {
                            if (($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                            $prices = $prices * $vv;
                            break;
                        }
                    }
                }
            }
            

            if($vvvvv['cart'] == 'limit' && $vvvvv['type'] == 'buy' && $vvvvv['price'] < $prices)
            {
                echo $vvvvv['id'].'-'.'价格未达限价-'.$vvvvv['price'].'-当前价格-'.$prices;
                $redis->set('cointrades_limitall', false);
                continue;
            }
            if($vvvvv['cart'] == 'limit' && $vvvvv['type'] == 'sell' && $vvvvv['price'] > $prices)
            {
                echo $vvvvv['id'].'-'.'价格未达限价-'.$vvvvv['price'].'-当前价格-'.$prices;
                $redis->set('cointrades_limitall', false);
                continue;
            }
            $trade_order = [];
            $ordersn = 'C' . time() . Random::build('numeric', 4);

            //质押手续费折扣
            $zhekou = 1;
            //手续费
            $market_bb_free = Config::get("site.market_bb_free")*$zhekou/100;
            //现价买 市价买(高->低) 现价卖 市价卖(低->高)
            if($vvvvv['type'] == 'buy') {
                $tradenum = sprintf('%.6f', $vvvvv['amount'] / $prices);
                $amount = $vvvvv['amount'];
                $fee = sprintf('%.8f', $tradenum * $market_bb_free);
                $fee_type = 1;
                
                $trade_order[] = [
                    'user_id' => $vvvvv['user_id'],
                    'coin_id' => $vvvvv['coin_id'],
                    'trade_id' => $vvvvv['id'],
                    'num' => $tradenum,
                    'price' => $prices,
                    'amount' => $vvvvv['amount'],
                    'fee' => $fee,
                    'createtime' => time(),
                    'type' => 'buy',
                    'order_sn' => $ordersn,
                    'fee_type' => $fee_type,
                ];
            }else{
                $tradenum = $vvvvv['num'];
                $amount = sprintf('%.6f',$tradenum * $prices);
                $fee = sprintf('%.8f',$amount*$market_bb_free);
                $fee_type = 1;//
                
                $trade_order[] = [
                    'user_id' => $vvvvv['user_id'],
                    'coin_id' => $vvvvv['coin_id'],
                    'trade_id' => $vvvvv['id'],
                    'num' => $tradenum,
                    'price' => $prices,
                    'amount' => $amount,
                    'fee' => $fee,
                    'createtime' => time(),
                    'type' => 'sell',
                    'order_sn' => $ordersn,
                    'fee_type' => $fee_type,
                ];
            }
            $detailed = [];
            Db::startTrans();
            try {
                Db::name('app_coin_trade_order')->insertAll($trade_order);
                
                $update1['status'] = '2';
                $update1['finishtime'] = time();
                if($vvvvv['cart'] == 'market'){
                    $update1['price'] = $prices;
                }
                $update1['num'] = $tradenum;
                $update1['amount'] = $amount;
                $update1['updatetime'] = time();

                Db::name('app_coin_trade')->where('id', $vvvvv['id'])->update($update1);
                if($vvvvv['type'] == 'buy') {
                    $currency1 = Db::name('app_currency_user')->where('user_id', $vvvvv['user_id'])->where('curr_id', $currency['id'])->find();
                    $upnum = $currency1['num'] + $tradenum - $trade_order[0]['fee'];
                    $last_price = $tradenum - $trade_order[0]['fee'];
                    Db::name('app_currency_user')->where('id', $currency1['id'])->update(['num' => $upnum, 'updatetime' => time()]);
                    
                    $detailed[] = [
                        'user_id' => $vvvvv['user_id'],
                        'curr_id' => $currency['id'],
                        'price' => $last_price,
                        'cart' => '1',
                        'type' => '7',
                        'serial_no' => 'C'.time().Random::build('numeric',4),
                        'order_result' => 'result',
                        'description' => '币币交易买入',
                        'createtime' => time(),
                        'notice' => '币币交易买入',
                        'before_num' => $currency1['num'],
                        'after_num' => $upnum,
                    ];
                    Db::name('app_detailed')->insertAll($detailed);
                }else{
                    $currency = Db::name('app_currency_user')->where('user_id', $vvvvv['user_id'])->where('curr_id', 1)->find();
                    $upnum = $currency['num'] + $amount  - $trade_order[0]['fee'];
                    $last_price = $amount - $trade_order[0]['fee'];
                    Db::name('app_currency_user')->where('id', $currency['id'])->update(['num' => $upnum, 'updatetime' => time()]);
                    
                    $detailed[] = [
                        'user_id' => $vvvvv['user_id'],
                        'curr_id' => 1,
                        'price' => $last_price,
                        'cart' => '1',
                        'type' => '7',
                        'serial_no' => 'C'.time().Random::build('numeric',4),
                        'order_result' => 'result',
                        'description' => '币币交易买入',
                        'createtime' => time(),
                        'notice' => '币币交易买入',
                        'before_num' => $currency['num'],
                        'after_num' => $upnum,
                    ];
                    Db::name('app_detailed')->insertAll($detailed);
                }

                Db::commit();
                $redis->set('cointrades_limitall', false);
                echo '交易单：'.$vvvvv['id'].'已成交-';
            } catch (Exception $e) {
                Db::rollback();
            }
        }
        
        $redis->set('cointrades_limitall', false);

    }

    //撮合成交单
    public function cuohe_ztc()
    {
        $coin = Db::name('app_rate')
            ->where('id',19)->find();
        $tradejson = json_decode($coin['tradectrl_json'],true);
        $hour = date('H');
        $minute = date('i');
        $price = $num = 0;
        foreach ($tradejson as $key=>$value){
            $time1 = explode('-',$key);
            $time2 = explode(':',$time1[0]);
            $time3 = explode(':',$time1[1]);
            $pricearr = explode('-',$value);
            if($hour >= $time2[0] && $hour <= $time3[0]){
                if(($hour == $time3[0] && $minute > $time3[1]) || ($hour == $time2[0] && $minute < $time2[1])) continue;
                $price = $this->randomFloat($pricearr[0],$pricearr[1],6);
                $num = $this->randomFloat(1,10,6);
            }
        }
        if($price == 0 || $num == 0)
        {
            echo 'price null';exit;
        }
        $data = [
            'symbol' => 'ztcusdt',
            'ts' => time(),
            'price' => $price,
            'amount' => $num,
            'source' =>0
        ];
        $ret = Db::name('ztc_1s')->insert($data);
        echo "update ztc";
    }

    //4位小数的随机数
    public function randomFloat($min = 0, $max = 10 , $localnum = 4)
    {
        if($localnum == 4) {
            if ($max - $min <= 0.0002) {
                return 0;
            }
            $rand = mt_rand() / mt_getrandmax() * ($max - $min-0.0001);
            $num = $min + $rand;
            $number = sprintf("%.4f", $num);
            if($number == $min){
                $number += 0.0001;
            }
        }else if($localnum == 5){
            if ($max - $min <= 0.00002) {
                return 0;
            }
            $rand = mt_rand() / mt_getrandmax() * ($max - $min-0.00001);
            $num = $min + $rand;
            $number = sprintf("%.5f", $num);
            if($number == $min){
                $number += 0.00001;
            }
        }else if($localnum == 6){
            if ($max - $min <= 0.000002) {
                return 0;
            }
            $rand = mt_rand() / mt_getrandmax() * ($max - $min-0.000001);
            $num = $min + $rand;
            $number = sprintf("%.6f", $num);
            if($number == $min){
                $number += 0.000001;
            }
        }else if($localnum == 2){
            if ($max - $min <= 0.02) {
                return 0;
            }
            $rand = mt_rand() / mt_getrandmax() * ($max - $min-0.01);
            $num = $min + $rand;
            $number = sprintf("%.2f", $num);
            if($number == $min){
                $number += 0.01;
            }
        }else if($localnum == 3){
            if ($max - $min <= 0.001) {
                return 0;
            }
            $rand = mt_rand() / mt_getrandmax() * ($max - $min-0.001);
            $num = $min + $rand;
            $number = sprintf("%.3f", $num);
            if($number == $min){
                $number += 0.001;
            }
        }

        return $number;

    }

    //更新ztcK线数据
    public function update_ztc_kline()
    {
        echo "start ".date('Y-m-d H:i:s');
        $alltrade  = Db::name('ztc_1s')
            ->order('id','desc')
            ->limit(100)
            ->select();
        $last_names = array_column($alltrade,'id');
        array_multisort($last_names,SORT_ASC,$alltrade);
        $nowtime = strtotime(date('H:i'));
        //更新分钟
        $mindata = Db::name('ztc_k_1min')
            ->order('ts','desc')->find();
        $start1min = $mindata['ts'];
        $end1min = $mindata['ts'] + 60;
        $mints = $mindata['ts'];
        $allmints[$mints] = $mindata;
        //更新5分钟
        $min5data = Db::name('ztc_k_5min')
            ->order('ts','desc')->find();
        $start5min = $min5data['ts'];
        $end5min = $min5data['ts'] + 300;
        $min5ts = $min5data['ts'];
        $allmin5ts[$min5ts] = $min5data;
        //更新15分钟
        $min15data = Db::name('ztc_k_15min')
            ->order('ts','desc')->find();
        $start15min = $min15data['ts'];
        $end15min = $min15data['ts'] + 900;
        $min15ts = $min15data['ts'];
        $allmin15ts[$min15ts] = $min15data;
        //更新30分钟
        $min30data = Db::name('ztc_k_30min')
            ->order('ts','desc')->find();
        $start30min = $min30data['ts'];
        $end30min = $min30data['ts'] + 1800;
        $min30ts = $min30data['ts'];
        $allmin30ts[$min30ts] = $min30data;

        //更新1小时
        $min1hdata = Db::name('ztc_k_1h')
            ->order('ts','desc')->find();
        $start1hmin = $min1hdata['ts'];
        $end1hmin = $min1hdata['ts'] + 3600;
        $min1hts = $min1hdata['ts'];
        $allmin1hts[$min1hts] = $min1hdata;

        //更新24小时
        $min24hdata = Db::name('ztc_k_24h')
            ->order('ts','desc')->find();
        $start24hmin = $min24hdata['ts'];
        $end24hmin = $min24hdata['ts'] + 86400;
        $min24hts = $min24hdata['ts'];
        $allmin24hts[$min24hts] = $min24hdata;

        //更新1周
        $min1wdata = Db::name('ztc_k_1week')
            ->order('ts','desc')->find();
        $start1wmin = $min1wdata['ts'];
        $end1wmin = $min1wdata['ts'] + 604800;
        $min1wts = $min1wdata['ts'];
        $allmin1wts[$min1wts] = $min1wdata;
//
//        //更新1月
        $min1mdata = Db::name('ztc_k_1month')
            ->order('ts','desc')->find();
        $start1mmin = $min1mdata['ts'];
        $end1mmin = $min1mdata['ts'] + 2592000;
        $min1mts = $min1mdata['ts'];
        $allmin1mts[$min1mts] = $min1mdata;

        //更新当前这分钟
        foreach($alltrade as $key=>$value)
        {
            //分钟
            if($value['ts'] >= $start1min && $value['ts'] < $end1min)
            {
                $update1min = $allmints[$mints];
                $close = $value['price'];
                $update1min['close'] = $close;
                if($close < $allmints[$mints]['low'])  $update1min['low'] = $close;
                if($close > $allmints[$mints]['high']) $update1min['high'] = $close;
                $update1min['amount'] = $allmints[$mints]['amount'] + $value['amount'];
                $update1min['vol'] = $allmints[$mints]['vol'] + $value['amount'];
                $update1min['count'] = $allmints[$mints]['count'] + 1;
                $allmints[$mints] = $update1min;
            }else if($value['ts'] >= $end1min)
            {
                for ($i = 0;$i<100;$i++)
                {
                    $newts = $mints + 60;
                    $start1min = $newts;
                    $end1min = $newts + 60;
                    $mints = $newts;
                    $allmints[$mints] = [
                        'symbol' => 'ztcusdt',
                        'ts' => $mints,
                        'amount' => $value['amount'],
                        'open' => $value['price'],
                        'close' => $value['price'],
                        'high' => $value['price'],
                        'low' => $value['price'],
                        'vol' => $value['amount'],
                        'count' => 0,
                    ];
                    if($value['ts'] < $end1min) break;
                }
            }

            //更新五分钟
            if($value['ts'] >= $start5min && $value['ts'] < $end5min)
            {
                $update1min = $allmin5ts[$min5ts];
                $close = $value['price'];
                $update1min['close'] = $close;
                if($close < $allmin5ts[$min5ts]['low'])  $update1min['low'] = $close;
                if($close > $allmin5ts[$min5ts]['high']) $update1min['high'] = $close;
                $update1min['amount'] = $allmin5ts[$min5ts]['amount'] + $value['amount'];
                $update1min['vol'] = $allmin5ts[$min5ts]['vol'] + $value['amount'];
                $update1min['count'] = $allmin5ts[$min5ts]['count'] + 1;
                $allmin5ts[$min5ts] = $update1min;
            }else if($value['ts'] >= $end5min)
            {
                for ($i = 0;$i<100;$i++)
                {
                    $newts = $min5ts + 300;
                    $start5min = $newts;
                    $end5min = $newts + 300;
                    $min5ts = $newts;
                    $allmin5ts[$min5ts] = [
                        'symbol' => 'ztcusdt',
                        'ts' => $min5ts,
                        'amount' => $value['amount'],
                        'open' => $value['price'],
                        'close' => $value['price'],
                        'high' => $value['price'],
                        'low' => $value['price'],
                        'vol' => $value['amount'],
                        'count' => 0,
                    ];
                    if($value['ts'] < $end5min) break;
                }
            }
            //更新1五分钟
            if($value['ts'] >= $start15min && $value['ts'] < $end15min)
            {
                $update1min = $allmin15ts[$min15ts];
                $close = $value['price'];
                $update1min['close'] = $close;
                if($close < $allmin15ts[$min15ts]['low'])  $update1min['low'] = $close;
                if($close > $allmin15ts[$min15ts]['high']) $update1min['high'] = $close;
                $update1min['amount'] = $allmin15ts[$min15ts]['amount'] + $value['amount'];
                $update1min['vol'] = $allmin15ts[$min15ts]['vol'] + $value['amount'];
                $update1min['count'] = $allmin15ts[$min15ts]['count'] + 1;
                $allmin15ts[$min15ts] = $update1min;
            }else if($value['ts'] >= $end15min)
            {
                for ($i = 0;$i<100;$i++)
                {
                    $newts = $min15ts + 300;
                    $start15min = $newts;
                    $end15min = $newts + 300;
                    $min15ts = $newts;
                    $allmin15ts[$min15ts] = [
                        'symbol' => 'ztcusdt',
                        'ts' => $min15ts,
                        'amount' => $value['amount'],
                        'open' => $value['price'],
                        'close' => $value['price'],
                        'high' => $value['price'],
                        'low' => $value['price'],
                        'vol' => $value['amount'],
                        'count' => 0,
                    ];
                    if($value['ts'] < $end15min) break;
                }
            }
            //更新30分钟
            if($value['ts'] >= $start30min && $value['ts'] < $end30min)
            {
                $update1min = $allmin30ts[$min30ts];
                $close = $value['price'];
                $update1min['close'] = $close;
                if($close < $allmin30ts[$min30ts]['low'])  $update1min['low'] = $close;
                if($close > $allmin30ts[$min30ts]['high']) $update1min['high'] = $close;
                $update1min['amount'] = $allmin30ts[$min30ts]['amount'] + $value['amount'];
                $update1min['vol'] = $allmin30ts[$min30ts]['vol'] + $value['amount'];
                $update1min['count'] = $allmin30ts[$min30ts]['count'] + 1;
                $allmin30ts[$min30ts] = $update1min;
            }else if($value['ts'] >= $end30min)
            {
                for ($i = 0;$i<100;$i++)
                {
                    $newts = $min30ts + 1800;
                    $start30min = $newts;
                    $end30min = $newts + 1800;
                    $min30ts = $newts;
                    $allmin30ts[$min30ts] = [
                        'symbol' => 'ztcusdt',
                        'ts' => $min30ts,
                        'amount' => $value['amount'],
                        'open' => $value['price'],
                        'close' => $value['price'],
                        'high' => $value['price'],
                        'low' => $value['price'],
                        'vol' => $value['amount'],
                        'count' => 0,
                    ];
                    if($value['ts'] < $end30min) break;
                }
            }

            //更新1小时
            if($value['ts'] >= $start1hmin && $value['ts'] < $end1hmin)
            {
                $update1min = $allmin1hts[$min1hts];
                $close = $value['price'];
                $update1min['close'] = $close;
                if($close < $allmin1hts[$min1hts]['low'])  $update1min['low'] = $close;
                if($close > $allmin1hts[$min1hts]['high']) $update1min['high'] = $close;
                $update1min['amount'] = $allmin1hts[$min1hts]['amount'] + $value['amount'];
                $update1min['vol'] = $allmin1hts[$min1hts]['vol'] + $value['amount'];
                $update1min['count'] = $allmin1hts[$min1hts]['count'] + 1;
                $allmin1hts[$min1hts] = $update1min;
            }else if($value['ts'] >= $end1hmin)
            {
                for ($i = 0;$i<100;$i++)
                {
                    $newts = $min1hts + 3600;
                    $start1hmin = $newts;
                    $end1hmin = $newts + 3600;
                    $min1hts = $newts;
                    $allmin1hts[$min1hts] = [
                        'symbol' => 'ztcusdt',
                        'ts' => $min1hts,
                        'amount' => $value['amount'],
                        'open' => $value['price'],
                        'close' => $value['price'],
                        'high' => $value['price'],
                        'low' => $value['price'],
                        'vol' => $value['amount'],
                        'count' => 0,
                    ];
                    if($value['ts'] < $end1hmin) break;
                }
            }

            //更新24小时
            if($value['ts'] >= $start24hmin && $value['ts'] < $end24hmin)
            {
                $update1min = $allmin24hts[$min24hts];
                $close = $value['price'];
                $update1min['close'] = $close;
                if($close < $allmin24hts[$min24hts]['low'])  $update1min['low'] = $close;
                if($close > $allmin24hts[$min24hts]['high']) $update1min['high'] = $close;
                $update1min['amount'] = $allmin24hts[$min24hts]['amount'] + $value['amount'];
                $update1min['vol'] = $allmin24hts[$min24hts]['vol'] + $value['amount'];
                $update1min['count'] = $allmin24hts[$min24hts]['count'] + 1;
                $allmin24hts[$min24hts] = $update1min;
            }else if($value['ts'] >= $end24hmin)
            {
                for ($i = 0;$i<100;$i++)
                {
                    $newts = $min24hts + 86400;
                    $start24hmin = $newts;
                    $end24hmin = $newts + 86400;
                    $min24hts = $newts;
                    $allmin24hts[$min24hts] = [
                        'symbol' => 'ztcusdt',
                        'ts' => $min24hts,
                        'amount' => $value['amount'],
                        'open' => $value['price'],
                        'close' => $value['price'],
                        'high' => $value['price'],
                        'low' => $value['price'],
                        'vol' => $value['amount'],
                        'count' => 0,
                    ];
                    if($value['ts'] < $end24hmin) break;
                }
            }

            //更新1周
            if($value['ts'] >= $start1wmin && $value['ts'] < $end1wmin)
            {
                $update1min = $allmin1wts[$min1wts];
                $close = $value['price'];
                $update1min['close'] = $close;
                if($close < $allmin1wts[$min1wts]['low'])  $update1min['low'] = $close;
                if($close > $allmin1wts[$min1wts]['high']) $update1min['high'] = $close;
                $update1min['amount'] = $allmin1wts[$min1wts]['amount'] + $value['amount'];
                $update1min['vol'] = $allmin1wts[$min1wts]['vol'] + $value['amount'];
                $update1min['count'] = $allmin1wts[$min1wts]['count'] + 1;
                $allmin1wts[$min1wts] = $update1min;
            }else if($value['ts'] >= $end1wmin)
            {
                for ($i = 0;$i<100;$i++)
                {
                    $newts = $min1wts + 604800;
                    $start1wmin = $newts;
                    $end1wmin = $newts + 604800;
                    $min1wts = $newts;
                    $allmin1wts[$min1wts] = [
                        'symbol' => 'ztcusdt',
                        'ts' => $min1wts,
                        'amount' => $value['amount'],
                        'open' => $value['price'],
                        'close' => $value['price'],
                        'high' => $value['price'],
                        'low' => $value['price'],
                        'vol' => $value['amount'],
                        'count' => 0,
                    ];
                    if($value['ts'] < $end1wmin) break;
                }
            }

            //更新1月
            if($value['ts'] >= $start1mmin && $value['ts'] < $end1mmin)
            {
                $update1min = $allmin1mts[$min1mts];
                $close = $value['price'];
                $update1min['close'] = $close;
                if($close < $allmin1mts[$min1mts]['low'])  $update1min['low'] = $close;
                if($close > $allmin1mts[$min1mts]['high']) $update1min['high'] = $close;
                $update1min['amount'] = $allmin1mts[$min1mts]['amount'] + $value['amount'];
                $update1min['vol'] = $allmin1mts[$min1mts]['vol'] + $value['amount'];
                $update1min['count'] = $allmin1mts[$min1mts]['count'] + 1;
                $allmin1mts[$min1mts] = $update1min;
            }else if($value['ts'] >= $end1mmin)
            {
                for ($i = 0;$i<100;$i++)
                {
                    $newts = $min1mts + 2592000;
                    $start1mmin = $newts;
                    $end1mmin = $newts + 2592000;
                    $min1mts = $newts;
                    $allmin1mts[$min1mts] = [
                        'symbol' => 'ztcusdt',
                        'ts' => $min1mts,
                        'amount' => $value['amount'],
                        'open' => $value['price'],
                        'close' => $value['price'],
                        'high' => $value['price'],
                        'low' => $value['price'],
                        'vol' => $value['amount'],
                        'count' => 0,
                    ];
                    if($value['ts'] < $end1mmin) break;
                }
            }

        }
        //1分钟
        foreach ($allmints as $key=>$value)
        {
            if($key == $mindata['ts'])  //更新
            {
                Db::name('ztc_k_1min')->where('id',$mindata['id'])
                    ->update($value);
            }else{
                Db::name('ztc_k_1min')
                    ->insert($value);
            }
        }
        //5分钟
        foreach ($allmin5ts as $key=>$value)
        {
            if($key == $min5data['ts'])  //更新
            {
                Db::name('ztc_k_5min')->where('id',$min5data['id'])
                    ->update($value);
            }else{
                Db::name('ztc_k_5min')
                    ->insert($value);
            }
        }
        //15分钟
        foreach ($allmin15ts as $key=>$value)
        {
            if($key == $min15data['ts'])  //更新
            {
                Db::name('ztc_k_15min')->where('id',$min15data['id'])
                    ->update($value);
            }else{
                Db::name('ztc_k_15min')
                    ->insert($value);
            }
        }
        //30分钟
        foreach ($allmin30ts as $key=>$value)
        {
            if($key == $min30data['ts'])  //更新
            {
                Db::name('ztc_k_30min')->where('id',$min30data['id'])
                    ->update($value);
            }else{
                Db::name('ztc_k_30min')
                    ->insert($value);
            }
        }
        //1小时
        foreach ($allmin1hts as $key=>$value)
        {
            if($key == $min1hdata['ts'])  //更新
            {
                Db::name('ztc_k_1h')->where('id',$min1hdata['id'])
                    ->update($value);
            }else{
                Db::name('ztc_k_1h')
                    ->insert($value);
            }
        }
        //1天
        foreach ($allmin24hts as $key=>$value)
        {
            if($key == $min24hdata['ts'])  //更新
            {
                Db::name('ztc_k_24h')->where('id',$min24hdata['id'])
                    ->update($value);
            }else{
                Db::name('ztc_k_24h')
                    ->insert($value);
            }
        }
        //1周
        foreach ($allmin1wts as $key=>$value)
        {
            if($key == $min1wdata['ts'])  //更新
            {
                Db::name('ztc_k_1week')->where('id',$min1wdata['id'])
                    ->update($value);
            }else{
                Db::name('ztc_k_1week')
                    ->insert($value);
            }
        }
        //1月
        foreach ($allmin1mts as $key=>$value)
        {
            if($key == $min1mdata['ts'])  //更新
            {
                Db::name('ztc_k_1month')->where('id',$min1mdata['id'])
                    ->update($value);
            }else{
                Db::name('ztc_k_1month')
                    ->insert($value);
            }
        }

        $updatearr = [
            'high' => $allmin24hts[$min24hdata['ts']]['high'],
            'low' => $allmin24hts[$min24hdata['ts']]['low'],
            'open' => $allmin24hts[$min24hdata['ts']]['open'],
            'close' => $allmin24hts[$min24hdata['ts']]['close'],
            'usdt' => $allmin24hts[$min24hdata['ts']]['close'],
            'updatetime' => time(),
        ];


        $updatearr['increase'] = sprintf("%.4f",
            ($updatearr['close']-$updatearr['open'])/$updatearr['close']);
        Db::name('app_rate')->where('id',19)->update($updatearr);



        echo "update complete ".date('Y-m-d H:i:s');
        echo "
";exit;
    }

    //更新火币ztc数据k线
    public function sync_ztc()
    {
        $request = [
            // 'code' => "shethdata2020.1",
            'period' => '1mon',
            'size' => 100,
            'symbol' => "firousdt",
            // 'command' => 'kline',
        ];
        $data = json_decode(http_curl('https://api.huobi.pro/market/history/kline?period='.
            $request['period'].'&size='.$request['size'].'&symbol='.$request['symbol'],'get',$request),true);
//         echo "
";var_dump($data);exit;
        $insertarr = [];
         foreach ($data['data'] as $key=>$value)
         {
            $insertarr[] = [
                'symbol' => 'ztcusdt',
                'ts' => $value['id'],
                'amount' => $value['amount'],
                'open' => $value['open'],
                'close' => $value['close'],
                'high' => $value['high'],
                'low' => $value['low'],
                'vol' => $value['vol'],
                'count' => $value['count'],
            ];
         }
//        $ret = Db::name('ztc_k_1month')->insertAll($insertarr);
    }
    
    /**
     * 更新团队等级
     */
    public function level_update()
    {
        $t = time();
        $user = Db::name("user a")->field("a.id,b.level,a.path,a.level_call,a.last_level_time")
                ->join("app_level b","a.level_id=b.id","left")
                ->where("level_call",0)
                ->order("id desc")
                ->limit(50)
                ->select();
        if(empty($user)){
            echo "empty";
            Db::name("user")->where("level_call",1)->update(['level_call'=>0]);
            exit;
        }
        //查询所有质押
        $all_zhiya = Db::name("app_zhiya_user")->where("status",1)->select();
        $id_arr = [];
        foreach ($user as $key => $value) {
            $id_arr[] = $value['id'];
            $user_update = array(
                "level_call" => 1,
            );
            //下一个等级 
            $next_level = Db::name("app_level")->where("level",">",$value['level'])->order("level asc")->find();
            
            //达标升级
            $team_user = Db::name("user")->field("id")->where("path","like",$value['path']."%")->where("id","neq",$value['id'])->select();
            $user_arr = [];
            foreach ($team_user as $ke => $val) {
                $user_arr[] = $val['id'];
            }
            $team_zhiya = 0;
            foreach ($all_zhiya as $ke => $val) {
                if(in_array($val['user_id'], $user_arr)){
                    $team_zhiya += $val['num'];
                }
            }

            if($team_zhiya >= $next_level['team_num']){
                $user_update['level_id'] = $next_level['id'];
                $user_update['last_level_time'] = time();
            }else{
                //1个月强制更新一次
                if($value['last_level_time'] < time()-(30*86400)){
                    $leves = Db::name("app_level")->where("team_num","<=",$team_zhiya)->order("level desc")->find();
                    $user_update['level_id'] = $leves['id'];
                    $user_update['last_level_time'] = time();
                }
            }
            Db::name("user")->where("id",$value['id'])->update($user_update);
        }
        echo "执行时长:".(time()-$t);
    }
    
    /**
     * 锁仓收益计算
     */
    public function zhiya_js()
    {
        $zhiya = Db::name("app_zhiya_user a")->field("a.*,b.yield")
                ->join("app_zhiya_set b","a.zhiya_id=b.id","left")
                ->where("a.status",1)
                ->order("a.last_time asc")
                ->limit(20)
                ->select();
        if(empty($zhiya)){
            echo "empty";exit;
        }
        foreach ($zhiya as $key => $value) {
            if($value['end_time'] < time()){
                $detail = [];
                //完结
                $update = array(
                    "status" => 0,
                );
                Db::startTrans();
                try {
                    Db::name("app_zhiya_user")->where("id",$value['id'])->update($update);
                    //收益发放
                    $user_curr = Db::name("app_currency_user")->where("user_id",$value['user_id'])->where("curr_id",2)->find();
                    $detail[] = array(
                        "user_id" => $user_curr['user_id'],
                        "curr_id" => $user_curr['curr_id'],
                        "price" => $value['num'],
                        "cart" => 1,
                        "type" => 9,
                        "description" => "锁仓释放",
                        "createtime" => time(),
                        "before_num" => $user_curr['num'],
                        "after_num" => $user_curr['num']+$value['num'],
                    );
                    $detail[] = array(
                        "user_id" => $user_curr['user_id'],
                        "curr_id" => $user_curr['curr_id'],
                        "price" => $value['profit_num'],
                        "cart" => 1,
                        "type" => 9,
                        "description" => "锁仓收益",
                        "createtime" => time(),
                        "before_num" => $user_curr['num']+$value['num'],
                        "after_num" => $user_curr['num']+$value['num']+$value['profit_num'],
                    );
                    Db::name("app_currency_user")->where("id",$user_curr['id'])->update(['num'=>$user_curr['num']+$value['num']+$value['profit_num']]);

                    //团队收益
                    $profit_num = $value['profit_num'];
                    $users = Db::name('user')->where('id',$user_curr['user_id'])->find();
                    $usersarr = array_filter(array_reverse( explode('|',$users['path'])));
                    $level = 0;
                    $zhiya_push_profit = Config::get("site.zhiya_push_profit");//直推
                    $level_arr = Db::name("app_level")->field("id,name,level,team_prize")->where("team_prize",">",0)->select();
                    $team_prize = 0;

                    foreach ($usersarr as $ks => $vals)
                    {
                        if(!is_numeric($vals) || empty($vals)) continue;
                        if($vals == 1) continue;
                        if($vals == $users['id']) continue;

                        $usera = Db::name('user')->where('id',$vals)->find();
                        $currencys = Db::name('app_currency_user')
                            ->where('user_id',$usera['id'])
                            ->where('curr_id','2')->find();
                        //先算直推
                        if($ks == 2){
                            $push_price = sprintf("%.6f",$profit_num*$zhiya_push_profit);
                            $detail[] = array(
                                'user_id' => $usera['id'],
                                'curr_id' => '2',
                                'price' => $push_price,
                                'cart' => '1',
                                'type' => '4',
                                'description' => '锁仓直推收益',
                                'createtime' => time(),
                                'before_num' => $currencys['num'],
                                'after_num' => $currencys['num']+$push_price,
                            );
                            Db::name("app_currency_user")->where("id",$currencys['id'])->update(['num'=>$currencys['num']+$push_price]);
                            continue;
                        }
                        if($usera['level_id'] == 1 || $usera['level_id']<=$level){
                            continue;
                        }
                        // 团队将
                        foreach ($level_arr as $kk => $vv) {
                            if($vv['id'] == $usera['level_id']){
                                $team_price = sprintf("%.6f",$profit_num*($vv['team_prize']-$team_prize)/100);
                                $detail[] = array(
                                    'user_id' => $usera['id'],
                                    'curr_id' => '2',
                                    'price' => $team_price,
                                    'cart' => '1',
                                    'type' => '10',
                                    'description' => '锁仓团队收益',
                                    'createtime' => time(),
                                    'before_num' => $currencys['num'],
                                    'after_num' => $currencys['num']+$team_price,
                                );
                                Db::name("app_currency_user")->where("id",$currencys['id'])->update(['num'=>$currencys['num']+$team_price]);
                                $level = $usera['level_id'];
                                $team_prize = $vv['team_prize'];
                            }
                        }
                    }
                    Db::name("app_detailed")->insertAll($detail);
                    echo 2;
                    Db::commit();
                } catch (Exception $e) {
                    Db::rollback();
                    continue;
                }
            }else{
                if($value['last_time'] > time()-86400){
                    continue;
                }
                $profit_num = sprintf("%.6f",$value['num']*$value['yield']/100);
                $update = array(
                    "profit_num" => $value['profit_num']+$profit_num,
                    "last_time" => $value['last_time']+86400,
                );
                Db::name("app_zhiya_user")->where("id",$value['id'])->update($update);
                $zhiya_detail = array(
                    "user_id" => $value['user_id'],
                    "zhiya_id" => $value['id'],
                    "num" => $profit_num,
                    "addtime" => time(),
                );
                Db::name("app_zhiya_detail")->insert($zhiya_detail);
                echo 1;
            }
        }
        
    }
    
    
    /**
     * C2C订单自动取消
     */
    public function clear_order()
    {
        $today = strtotime(date("Y-m-d", time()));
        $order = Db::name("app_market_user")->where("status",1)->order("add_time asc")->limit(5)->select();
        if(empty($order)){
            echo "empty";exit;
        }
        $jiedian_times = Config::get("site.market_time");
        $times = time() - $jiedian_times*60;
        foreach ($order as $key => $value) {
            if($value['add_time'] > $times){
                continue;
            }
            if($value['type'] == 1){
                $user_id = $value['user_id'];//买家id
                $sell_id = $value['relid'];
            }else{
                $user_id = $value['relid'];//买家id
                $sell_id = $value['user_id'];
            }
            
            //查询累计取消次数
            $cleal_num = Config::get("site.cleal_num");
            $user_cleal_num = Db::name("app_market_cancel_log")->where("user_id",$user_id)->where("createtime",">", $today)->count();
            if($user_cleal_num+1 >= $cleal_num){
                Db::name("app_market")->where("user_id",$user_id)->where("id",$value['order_id'])->update(["status"=>4]);
            }else{
                Db::name("app_market")->where("user_id",$user_id)->where("id",$value['order_id'])->update(["status"=>1]);
            }
            Db::name("app_market_user")->where("id",$value['id'])->update(['status'=>5,"cancel_time"=> time()]);
            $cleal_data = array(
                "user_id" => $user_id,
                "type" => 1,
                "description" => "未接单自动取消",
                "createtime" => time(),
            );
            Db::name("app_market_cancel_log")->insert($cleal_data);
            $market = Db::name("app_market")->where("id",$value['order_id'])->find();
            
            //退款
            if($value['type'] == 2){
                $user_curr = Db::name("app_currency_user")->where("user_id",$sell_id)->where("curr_id",$market['curr_id'])->find();
                $count_num = $value['num']+$value['free_num'];
                $detail_data = array(
                    "user_id" => $sell_id,
                    "curr_id" => $market['curr_id'],
                    "price" => $count_num,
                    "cart" => 1,
                    "type" => 2,
                    "description" => "取消订单",
                    "createtime" => time(),
                    "before_num" => $user_curr['num_fb'],
                    "after_num" => $user_curr['num_fb']+$count_num,
                );
                Db::name("app_detailed_fb")->insert($detail_data);
                Db::name("app_currency_user")->where("id",$user_curr['id'])->update(['num_fb' => $user_curr['num_fb']+$count_num]);
            }else{
                Db::name("app_market")->where("user_id",$sell_id)->where("id",$value['order_id'])->update(["status"=>1]);
            }
            echo 1;
        }
        echo "success";
    }
    
    /**
     * 天使投资释放
     */
    public function angel_sf()
    {
        $angel = Db::name("app_angel_user a")->field("a.*,b.interest,b.freed_day,b.freed_bl,b.curr_id")
                ->join("app_angel_set b","a.angel_id=b.id","left")
                ->where("a.lasttime","<=", time()-86400)
                ->order("a.lasttime asc")
                ->limit(20)
                ->select();
        if(empty($angel)){
            echo "empty";exit;
        }
        foreach ($angel as $key => $value) {
            if($value['lasttime'] > time()-86400){
                continue;
            }
            $profit_num = sprintf("%.6f",$value['real_num']*$value['interest']/100);
            if($value['lasttime'] == 0){
                $lasttime = time();
            }else{
                $lasttime = $value['lasttime']+86400;
            }
            $update = array(
                "days" => $value['days']+1,
                "count_lixi" => $value['count_lixi']+$profit_num,
                "wait_lixi" => $value['wait_lixi']+$profit_num,
                "lasttime" => $lasttime,
            );
            $detail_data = [];
            $angel_detail = [];
            Db::startTrans();
            try {
                if($update['days'] >= $value['freed_day']){
                    //达到释放周期
                    $user_curr = Db::name("app_currency_user")->where("user_id",$value['user_id'])->where("curr_id",$value['curr_id'])->find();
                    $detail_data[] = array(
                        "user_id" => $value['user_id'],
                        "curr_id" => $value['curr_id'],
                        "price" => $update['wait_lixi'],
                        "cart" => 1,
                        "type" => 11,
                        "description" => "日息释放",
                        "createtime" => time(),
                        "before_num" => $user_curr['num'],
                        "after_num" => $user_curr['num']+$update['wait_lixi'],
                    );
                    $bj_num = sprintf("%.6f",$value['real_num']*0.2);
                    $detail_data[] = array(
                        "user_id" => $value['user_id'],
                        "curr_id" => $value['curr_id'],
                        "price" => $bj_num,
                        "cart" => 1,
                        "type" => 11,
                        "description" => "本金释放",
                        "createtime" => time(),
                        "before_num" => $user_curr['num']+$update['wait_lixi'],
                        "after_num" => $user_curr['num']+$update['wait_lixi']+$bj_num,
                    );
                    Db::name("app_currency_user")->where("id",$user_curr['id'])->update(['num'=>$user_curr['num']+$update['wait_lixi']+$bj_num]);
                    Db::name("app_detailed")->insertAll($detail_data);
                    $update['days'] = 0;
                    $update['wait_lixi'] = 0;
                    $update['real_num'] = $value['real_num']-$bj_num;
                    $angel_detail[] = array(
                        "num" => $bj_num,
                        "type" => 2,
                        "addtime" => time(),
                        "pro_id" => $value['id'],
                    );
                    echo 2;
                }else{
                    echo 1;
                }
                //每日产生释放记录
                $angel_detail[] = array(
                    "num" => $profit_num,
                    "type" => 1,
                    "addtime" => time(),
                    "pro_id" => $value['id'],
                );
                Db::name("app_angel_detail")->insertAll($angel_detail);
                Db::name("app_angel_user")->where("id",$value['id'])->update($update);
                Db::commit();
            } catch (Exception $e) {
                Db::rollback();
                continue;
            }
        }
        echo "success";
        
    }
    

}