<?php

namespace console\controllers;

use common\models\psources\Coin;
use common\models\psources\CoinIssueCoin;
use common\models\psources\CoinIssueTransfer;
use common\service\chain33\Chain33Service;
use Yii;
use yii\console\Controller;

class IssueCoinController extends Controller
{
    /**
     * 手续费划转
     * @return
     */
    public function actionPayCharge()
    {
        $issue_transfer = CoinIssueTransfer::find()->where(['send_result' => '0', 'msg' => '0'])->asArray()->all();
        if (false == $issue_transfer) {
            echo date('Y-m-d H:i:s') . '暂无手续费划转任务' . PHP_EOL;
            return 0;
        }
        $node = Yii::$app->params['chain_nodes']['STO'];
        $service = new Chain33Service($node);
        foreach ($issue_transfer as $val) {
            $result = $service->sendTransaction($val['txhex']);
            if (0 == $result['code']) {
                $send_result = $result['result'];
                $currentModel = CoinIssueTransfer::findOne($val['id']);
                $currentModel->send_result = $send_result;
                $currentModel->msg = 0;
                $currentModel->save();
            } else {
                $currentModel = CoinIssueTransfer::findOne($val['id']);
                $currentModel->msg = $result['msg'];
                $currentModel->save();
            }
        }
        echo date('Y-m-d H:i:s') . '手续费划转任务完成' . PHP_EOL;
        return 0;
    }

    /**
     * 手续费划转状态确认
     * @return
     */
    public function actionPayChargeStatus()
    {
        $model = CoinIssueTransfer::find()->where(['<>', 'send_result', '0'])->andWhere(['msg' => '0'])->asArray()->all();
        if (empty($model)) {
            echo date('Y-m-d H:i:s') . '暂无需要确认的手续费划转状态' . PHP_EOL;
            return 0;
        }

        $node = \Yii::$app->params['chain_parallel']['primary'];
        $service = new Chain33Service($node);
        foreach ($model as $val) {
            $send_result = $val['send_result'];
            $result = $service->QueryTransaction($send_result);
            if (isset($result['result']['actionName']) && 'unknown' == $result['result']['actionName']) {
                $query_result = 'success';
                $msg = 'success';
                goto doEnd;
            } else if (isset($result['result']['receipt']['ty']) && 2 == $result['result']['receipt']['ty']) {
                $query_result = 'success';
                $msg = 'success';
                goto doEnd;
            } else {
                $msg = $result['msg'];
                $query_result = $result['code'];
                goto doEnd;
            }
            doEnd :

            $currentModel = CoinIssueTransfer::findOne($val['id']);
            $currentModel->query_result = $query_result;
            $currentModel->msg = $msg;
            $currentModel->save();
        }

    }

    /**
     * 自动发币
     * @param $type 0 未开启人工 1 已开启人工
     * @return
     */
    public function actionAutoIssue($type)
    {
        if (0 == $type) {
            $status = CoinIssueCoin::UN_AUDIT;
            $manual_review = Yii::$app->redis->get('issue_chain_manual_review');
            if ('close' == $manual_review) {
                return 0;
            }
        }

        if (1 == $type) {
            $status = CoinIssueCoin::ALLOW_ISSUE;
        }

        $issue_transfers = CoinIssueTransfer::find()
            ->where(['<>', 'send_result', '0'])
            ->andWhere(['msg' => 'success'])
            ->andWhere(['unissue' => 1])
            ->asArray()
            ->all();
        if (false == $issue_transfers) {
            echo date('Y-m-d H:i:s') . '暂无发行任务' . PHP_EOL;
            return 0;
        }

        $node = Yii::$app->params['chain_nodes']['STO'];
        $chain_service = new Chain33Service($node);
        foreach ($issue_transfers as $issue_transfer) {
            $issue_coin_model = CoinIssueCoin::find()
                ->select('id, name, platform_id, chain_id, symbol, introduction, total, category, owner')
                ->where(['id' => $issue_transfer['issue_coin_id'], 'status' => $status])
                ->one();

            if (false == $issue_coin_model) continue;
            $params = [
                'name' => $issue_coin_model->name,
                'symbol' => $issue_coin_model->symbol,
                'introduction' => $issue_coin_model->introduction,
                'total' => (int)$issue_coin_model->total,
                'price' => isset($issue_coin_model->platform->issue_charge) ? (int)$issue_coin_model->platform->issue_charge : 0,
                'category' => (int)$issue_coin_model->category,
                'owner' => $issue_coin_model->owner
            ];

            $result = $chain_service->createRawTokenPreCreateTx($params);
            if (null == $result['error'] && false == $result['code']) {
                $status = CoinIssueCoin::SUCCESS_ISSUE;
                $params['platform'] = $issue_coin_model->chain->platform;
                $this->syncTransfer($issue_transfer['id']);
                $this->syncCoin($params);
            } else {
                $status = CoinIssueCoin::FAIL_ISSUE;
            }
            if ($status > CoinIssueCoin::REFUSE_ISSUE) {
                CoinIssueCoin::updateAll([
                    'msg' => $result['result'],
                    'status' => $status
                ], [
                    'id' => $issue_coin_model->id,
                ]);
            }
        }
        echo date('Y-m-d H:i:s') . '发行成功' . PHP_EOL;
        return 0;
    }

    public function syncCoin($params = [])
    {
        $model_coin = Coin::find()->where(['name' => $params['name'], 'platform' => $params['platform']])->one();
        if (false == $model_coin) {
            $model = new Coin();
            $model->name = $params['name'];
            $model->sid = $params['symbol'];
            $model->platform = $params['platform'];
            $model->chain = 'BTY';
            $model->treaty = 1;
            $model->save();
        }
    }

    public function syncTransfer($id)
    {
        $issue_transfer = CoinIssueTransfer::find()->where(['id' => $id])->one();
        $issue_transfer->unissue = 0;
        $issue_transfer->save();
    }
}