<?php

namespace api\controllers;

use Yii;
use yii\data\Pagination;
use api\base\BaseController;
use common\models\psources\CoinCTocTransfer;

class OrderController extends BaseController
{
    public function actionIndex()
    {
        $code = -1;
        $request = Yii::$app->request;
        if (!$request->isPost) {
            $msg = '请求错误!';
            goto doEnd;
        }
        $post = $request->post();
        if (2 != count($post['txs'])) {
            $msg = '交易笔数错误!';
            goto doEnd;
        }

        $data['is_sell'] = (false == $post['isSell']) ? 0 : 1;
        $data['type'] = $post['type'];
        $data['address'] = $post['address'];
        $data['token_name'] = $post['token_name'];
        $data['market_name'] = $post['market_name'];
        $data['price'] = $post['price'];
        $data['amount'] = $post['amount'];
        $data['transfer_number'] = date('YmdHis') . self::getrandnums();

        $redis = Yii::$app->redis;
        if ($redis->exists('C2C_' . $post['address'] . '_' . $data['is_sell'])) {
            $msg = '尚存在一笔未完成的交易!';
            goto doEnd;
        }
        $redis->set('C2C_' . $post['address'] . '_' . $data['is_sell'], time());

        foreach ($post['txs'] as $key => $val) {
            $model = new CoinCTocTransfer();
            $data['txhex'] = $val['tx'];
            $data['transfer_url'] = $val['url'];
            $data['step'] = $val['step'];
            $model->load($data, '');
            $model->save();
        }

        $code = 0;
        $msg = 'success';
        doEnd :
        return ['code' => $code, 'msg' => $msg];
    }

    public function actionFixOrder()
    {
        $code = -1;
        $request = Yii::$app->request;
        if (!$request->isPost) {
            $msg = '请求错误!';
            goto doEnd;
        }
        $post = $request->post();

        $data['is_sell'] = (false == $post['isSell']) ? 0 : 1;
        $data['type'] = $post['type'];
        $data['address'] = $post['address'];

        foreach ($post['txs'] as $key => $val) {
            $model = CoinCTocTransfer::find()->where(['is_sell' => $data['is_sell']])
                ->andWhere(['type' => $data['type']])
                ->andWhere(['address' => $data['address']])
                ->andWhere(['step' => $val['step']])
                ->andWhere(['<>', 'msg', 'success'])
                ->one();

            $model->txhex = $val['tx'];
            $model->transfer_url = $val['url'];
            $model->send_result = 0;
            $model->query_result = 0;
            $model->msg = 0;
            $model->save();
            continue;
        }
        $redis = Yii::$app->redis;
        $redis->set('C2C_' . $post['address'] . '_' . $data['is_sell'], time());
        $code = 0;
        $msg = 'success';
        doEnd :
        return ['code' => $code, 'msg' => $msg];
    }

    public function actionOrderList()
    {
        $address = Yii::$app->request->get('address', '');
        $is_sell = Yii::$app->request->get('isSell', -1);
        $type = Yii::$app->request->get('type', '');
        $page = Yii::$app->request->get('page', 1);

        if(empty($address)){
            $msg = '请求参数错误';
            $code = -1;
            $data = null;
            goto doEnd;
        }

        $query = CoinCTocTransfer::find()
            ->where('address= :address',[':address' => $address])
            ->orderBy('create_time desc')
            ->groupBy('address, is_sell');

        if ($is_sell > -1) {
            $query->andWhere('is_sell= :is_sell',[':is_sell' => $is_sell]);
        }
        if (false != $type) {
            $query->andWhere('type= :type',[':type' => $type]);
        }
        $data = $query->offset(($page - 1) * 20)->limit(20)->asArray()->all();
        $countQuery = clone $query;
        $pages = new Pagination(['totalCount' => $countQuery->count(), 'pageSize' => 20]);
        $data = [
            'list' => $data,
            'page' => [
                'pageCount' => $pages->pageCount,
                'pageSize'  => 20,
                'currentPage' => $page,
            ]
        ];
        $code = 1;
        $msg = 'success';
        doEnd :

        return ['code' => $code, 'msg' => $msg, 'data' => $data];
    }

    public static function getrandnums()
    {
        $arr = array();
        while (count($arr) < 6) {
            $arr[] = rand(0, 9);
            $arr = array_unique($arr);
        }
        return implode("", $arr);
    }
}