<?php

namespace api\controllers;

use common\service\chain33\Chain33Service;
use Yii;
use yii\data\Pagination;
use api\base\BaseController;
use common\models\psources\CoinPlatform;
use common\models\psources\CoinIssueCoin;
use common\models\psources\CoinIssueChainRecord;

class IssueCoinController extends BaseController
{
    public function actionIsManager()
    {
        $node = [
            'scheme' => 'https',
            'host' => 'jiedian1.bityuan.com',
            'port' => 8801,
        ];

//        $node = [
//            'scheme' => 'http',
//            'host' => '47.97.193.201',
//            'port' => 8901,
//        ];
        $chain_service = new Chain33Service($node);
        $result = $chain_service->query();
        echo json_encode($result);exit;
    }

    /**
     * 发行申请
     * @return array
     */
    public function actionApply()
    {
        $data = null;
        $header = Yii::$app->request->headers;
        $platform_id = $header['FZM-PLATFORM-ID'] ?? null;

        if (empty($platform_id)) {
            $msg = '缺少必要的参数';
            $code = -1;
            goto doEnd;
        }

        $coin_platform = CoinPlatform::findOne($platform_id);
        if (false == $coin_platform) {
            $msg = '参数错误';
            $code = -1;
            goto doEnd;
        }

        $model = new CoinIssueCoin();
        $model->setScenario(CoinIssueCoin::SCENARIOS_CREATE);

        if (!Yii::$app->request->isPost) {
            $msg = '错误的请求方式';
            $code = -1;
            goto doEnd;
        }
        $result = Yii::$app->request->post();
        $chain_id = isset($result['chain_id']) ? $result['chain_id'] : 0;
        if (false == $chain_id) {
            $msg = '不存在的链';
            $code = -1;
            goto doEnd;
        }

        $result = [
            'name' => isset($result['name']) ? $result['name'] : '',
            'symbol' => isset($result['symbol']) ? strtoupper($result['symbol']) : '',
            'total' => isset($result['total']) ? $result['total'] : '',
            'owner' => isset($result['owner']) ? $result['owner'] : '',
            'introduction' => isset($result['introduction']) ? $result['introduction'] : '',
            'category' => isset($result['category']) ? $result['category'] : 0,
            'platform_id' => $platform_id,
            'chain_id' => $chain_id,
            'charge_unit_id' => isset($result['charge_unit_id']) ? $result['charge_unit_id'] : '',
            'charge' => $coin_platform->issue_charge,
        ];
        $model->load($result, '');
        if (!$model->save()) {
            $msg = $model->errors;
            $code = -1;
            goto doEnd;
        }
        $msg = 'ok';
        $code = 0;
        $data = $model->getPrimaryKey();

        doEnd :
        return ['code' => $code, 'msg' => $msg, 'data' => $data];
    }

    /**
     * 申请列表
     * @param integer page
     * @param integer size
     * @return array
     */
    public function actionApplyList()
    {
        $data = null;
        $header = Yii::$app->request->headers;
        $platform_id = $header['FZM-PLATFORM-ID'] ?? null;
        $address = Yii::$app->request->get('address', '');

        if (empty($platform_id) || empty($address)) {
            $msg = '缺少必要的参数';
            $code = -1;
            goto doEnd;
        }

        $page = \Yii::$app->request->get('page', 1);
        $size = \Yii::$app->request->get('size', 5);

        $query = CoinIssueCoin::find()
            ->select('id, name, symbol, total, create_time, status, chain_id')
            ->where(['owner' => $address])
            ->orderBy('create_time desc');

        $countQuery = clone $query;
        $models = $query->offset(($page - 1) * $size)->limit($size)->all();
        $pages = new Pagination(['totalCount' => $countQuery->count(), 'pageSize' => $size]);
        foreach ($models as &$val) {
            $val->chain_id = $val->chain->platform;
            $val->total = (int)$val->total * 1e8;
        }
        $data = [
            'list' => $models,
            'page' => [
                'pageCount' => $pages->pageCount,
                'pageSize' => $size,
                'currentPage' => $page,
            ]
        ];
        $msg = 'ok';
        $code = 0;

        doEnd :
        return ['code' => $code, 'msg' => $msg, 'data' => $data];
    }

    /**
     * 申请详情
     * @param integer id
     * @return array
     */
    public function actionApplyDetail()
    {
        $id = Yii::$app->request->get('id', '');
        $data = null;
        if (empty($id)) {
            $msg = '缺少必要的参数';
            $code = -1;
            goto doEnd;
        }

        $data = CoinIssueCoin::find()->where(['id' => $id])->one();
        $data->total = (int)$data->total * 1e8;
        $data->chain_name = $data->chain->platform;
        $data->charge = isset($data->platform->issue_charge) ? (int)$data->platform->issue_charge : 0;
        $data->charge_unit = isset($data->gas->coin_name) ? $data->gas->coin_name : '';
        $code = 0;
        $msg = 'success';

        doEnd :
        return ['code' => $code, 'msg' => $msg, 'data' => $data];
    }

    /**
     * 申请撤消/确认
     * @param integer id
     * @param string pre_create_tx
     * @param string pre_send_transaction
     * @return array
     */

    public function actionSendTransfer()
    {
        $data = null;
        $header = Yii::$app->request->headers;
        $platform_id = $header['FZM-PLATFORM-ID'] ?? null;

        if (empty($platform_id)) {
            $msg = '缺少必要的参数';
            $code = -1;
            goto doEnd;
        }

        $params = Yii::$app->request->post();
        $id = isset($params['id']) ? (int)$params['id'] : 0;
        $pre_create_tx = isset($params['pre_create_tx']) ? $params['pre_create_tx'] : '';
        $pre_send_transaction = isset($params['pre_send_transaction']) ? $params['pre_send_transaction'] : '';
        if (false == $id || false == $pre_create_tx || false == $pre_send_transaction) {
            $msg = '缺少必要的参数';
            $code = -1;
            goto doEnd;
        }

        $model = CoinIssueChainRecord::find()->where(['issue_coin_id' => $id])->one();
        if (true == $model) {
            $msg = '交易记录已存在';
            $code = -1;
            goto doEnd;
        }

        $params = [
            'pre_create_tx' => $pre_create_tx,
            'pre_send_transaction' => $pre_send_transaction,
            'pre_query_transaction' => 'success',
            'finish_tx' => 'standby',
            'finish_send_transaction' => 'standby',
            'finish_query_transaction' => 'standby',
            'issue_coin_id' => $id,
        ];
        $transfer_model = new CoinIssueChainRecord();
        $transfer_model->setScenario(CoinIssueChainRecord::SCENARIOS_PRE_CREATE);
        $transfer_model->load($params, '');
        if (!$transfer_model->save()) {
            $msg = current($transfer_model->firstErrors);
            $code = -1;
            goto doEnd;
        }

        $code = 0;
        $msg = 'success';

        doEnd :
        return ['code' => $code, 'msg' => $msg];
    }

    /**
     * 申请撤消/确认
     * @param integer id
     * @param integer status
     * @return array
     */
    public function actionVerify()
    {
        $data = null;
        $header = Yii::$app->request->headers;
        $platform_id = $header['FZM-PLATFORM-ID'] ?? null;

        if (empty($platform_id)) {
            $msg = '缺少必要的参数';
            $code = -1;
            goto doEnd;
        }

        $params = Yii::$app->request->post();
        $id = isset($params['id']) ? (int)$params['id'] : 0;
        $status = isset($params['status']) ? (int)$params['status'] : 0;
        if (false == $id || false == $status) {
            $msg = '缺少必要的参数';
            $code = -1;
            goto doEnd;
        }

        $model = CoinIssueCoin::findOne($id);
        if (false == $model) {
            $msg = '不存在的记录';
            $code = -1;
            goto doEnd;
        }

        $record_model = CoinIssueChainRecord::find()->where(['issue_coin_id' => $id])->one();
        if (false == $record_model) {
            $msg = '交易记录不存在';
            $code = -1;
            goto doEnd;
        }

        if ($model->status > CoinIssueCoin::UN_AUDIT) {
            $msg = '不允许取消的发行';
            $code = -1;
            goto doEnd;
        }

        $data = [
            'status' => $status,
        ];
        $model->setScenario(CoinIssueCoin::SCENARIOS_CANCEL);
        $model->load($data, '');
        if (!$model->save()) {
            $msg = current($model->firstErrors);
            $code = -1;
            goto doEnd;
        }

        if ($status == CoinIssueCoin::ALLOWED_ISSUE) {
            $record_model->pre_query_transaction = 'success';
            $record_model->update();
        }

        $code = 0;
        $msg = 'success';

        doEnd :
        return ['code' => $code, 'msg' => $msg];
    }

    /**
     * 手续费划转
     * @return
     */
    public function actionPayCharge()
    {
        $issue_coin_model = CoinIssueCoin::find()
            ->select('id')->where(['charge_pay' => CoinIssueCoin::ALLOW_PAY])->asArray()->all();
        if (false == $issue_coin_model) {
            echo date('Y-m-d H:i:s') . '暂无手续费划转任务' . PHP_EOL;
            return 0;
        }

        $issue_transfer = CoinIssueTransfer::find()
            ->where(['unissue' => 1])
            ->andWhere(['in', 'issue_coin_id', ArrayHelper::getColumn($issue_coin_model, 'id')])
            ->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()
    {
        $unissue = -1;
        $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 {
                if (isset($result['result']['receipt']['logs'])) {
                    foreach ($result['result']['receipt']['logs'] as $log) {
                        if (isset($log['tyName']) && 'LogErr' == $log['tyName']) {
                            $msg = $log['tyName'];
                            break;
                        }
                    }
                } else {
                    $msg = $result['msg'];
                }
                $query_result = $result['code'];
                goto doEnd;
            }
            doEnd :

            if ('success' == $msg) {
                $unissue = 0;
                $coin_issue_coin = CoinIssueCoin::find()->where(['id' => $val['issue_coin_id']])->one();
                $coin_issue_coin->charge_pay = CoinIssueCoin::SUCCESS_PAY;
                $coin_issue_coin->save();
            }

            $currentModel = CoinIssueTransfer::findOne($val['id']);
            $currentModel->query_result = $query_result;
            if ($unissue > -1) {
                $currentModel->unissue = $unissue;
            }
            $currentModel->msg = $msg;
            $currentModel->save();
        }
    }
}