<?php

require_once('mt/Parameter.php');
require_once('mt/Item.php');
require_once('mt/Drop.php');
require_once('mt/Hero.php');

require_once('models/Bag.php');
require_once('models/Hero.php');
require_once('models/Gun.php');
require_once('models/Nft.php');
require_once('models/Chip.php');
require_once('models/Transaction.php');
require_once('models/BuyRecord.php');
require_once('models/Chip.php');
require_once('models/TransactionPrefee.php');

require_once('services/AwardService.php');
require_once('services/PropertyChgService.php');

require_once('services/NameService.php');

use phpcommon\SqlHelper;
use models\Bag;
use models\Hero;
use models\Gun;
use models\Nft;
use models\Transaction;
use models\BuyRecord;
use models\Chip;
use models\TransactionPrefee;

class BlockChainController extends BaseAuthedController {

    const TEST_ITEM_ID = 666;
    public function _handlePre()
    {
        parent::_handlePre();
        if (getReqVal('a', '') != 'getTransactionList' &&
            myself()->_getChannel() != BC_CHANNEL) {
            die(json_encode(array(
                'errcode' => 501,
                'errmsg' => 'you are not a wallet user'
            )));
            return;
        }
        error_log(json_encode($_REQUEST));
    }

    public function getTransactionList()
    {
        $trans = array();
        foreach (Transaction::all() as $tran) {
            if (myself()->_getNowTime() - $tran['createtime'] < 24*3600){
                array_push(
                    $trans,
                    array(
                        'trans_id' => $tran['trans_id'],
                        'item_id' => $tran['item_id'],
                        'action' => Transaction::getActionDesc($tran),
                        'status' => Transaction::getStatusDesc($tran),
                        'time' => $tran['createtime'],
                    )
                );
            }
        }
        $this->_rspData(array(
            'transactions' => $trans
        ));
    }

    public function reportResult()
    {
        $transId = getReqVal('trans_id', '');
        $result = getReqVal('result', '');
        error_log($result);
        Transaction::reportResult($transId, $result);
        myself()->_rspOk();
    }

    public function getJumpInfo()
    {
        $transId = getReqVal('trans_id', '');
        if (!$transId){
            myself()->_rspErr(101, 'trans_id paramater error');
            return;
        }
        $tranDb= Transaction::find($transId);
        if (!$tranDb){
            myself()->_rspErr(101, 'trans_id paramater error');
            return;
        }
        $data = Transaction::getJumpInfo($tranDb);
        myself()->_rspData($data);
    }

    public function getTransactionInfo()
    {
        $transId = getReqVal('trans_id', '');
        if (!$transId){
            myself()->_rspErr(101, 'trans_id paramater error');
            return;
        }
        $tranDb= Transaction::find($transId);
        myself()->_rspData(array(
            'data' => array(
                'trans_id' => $tranDb['trans_id'],
                'item_id' => $tranDb['item_id'],
                'action' => Transaction::getActionDesc($tranDb),
                'status' => Transaction::getStatusDesc($tranDb),
                'time' => $tranDb['createtime'],
            )
        ));
    }

    private function internalBcCall($params, $transParams, $cb = null) {
        $propertyChgService = new services\PropertyChgService();
        $propertyChgService->addUserChg();
        $url = self::getWeb3ServiceUrl();
        $response = '';
        if (!phpcommon\HttpClient::get
            ($url,
             $params,
             $response)) {
            myself()->_rspErr(500,  'server internal error');
            die();
            return;
        }
        error_log($response);
        $rspObj = json_decode($response, true);
        if ($rspObj['errcode'] == 0) {
            $transId = $rspObj['trans_id'];
            Transaction::add(
                $transId,
                $transParams['action'],
                $transParams['tokenId'],
                $transParams['tokenType'],
                $transParams['itemUniId'],
                $transParams['itemId'],
                $transParams['result']
            );
            if ($cb) {
                $cb($transId);
            }
            myself()->_rspData(array(
                'trans_id' => $transId,
                'params' => $rspObj['params'],
                'property_chg' => $propertyChgService->toDto(),
            ));
        } else {
            myself()->_rspErr(500,  'server internal error');
            die();
            return;
        }
    }

    private static function getWeb3ServiceUrl()
    {
        if (SERVER_ENV == _TEST) {
            return 'http://127.0.0.1:7672/webapp/index.php';
        }
        $web3ServiceCluster = require_once('../config/web3service.cluster.php');
        return $web3ServiceCluster[rand() % count($web3ServiceCluster)];
    }

}