Merge branch 'master' into feature/airdrop

api/controllers/ArticleController.php

@@ -10,7 +10,7 @@ namespace api\controllers;
 
 use Yii;
 use api\base\BaseController;
-use common\models\pwallet\Article;
+use common\models\pwallet\News;
 
 class ArticleController extends BaseController
 {
@@ -50,7 +50,7 @@ class ArticleController extends BaseController
         if (isset($post['update_at'])) {
             $condition[] = ['>=', 'update_at', $post['update_at']];
         }
-        $data = Article::getList($page, $limit, $condition);
+        $data = News::getList($page, $limit, $condition);
 
         return $data;
     }

api/controllers/CoinDogController.php

@@ -3,7 +3,7 @@
 namespace api\controllers;
 
 use backend\models\coin\ArticleForm;
-use common\models\pwallet\Article;
+use common\models\pwallet\News;
 use common\service\bishijie\BishijieService;
 use linslin\yii2\curl\Curl;
 use Yii;
@@ -127,7 +127,7 @@ class CoinDogController extends BaseController
     public function actionArticleBanner()
     {
         $type = Yii::$app->request->get('type', 1);
-        $data = Article::find()
+        $data = News::find()
             ->select('id, image_url ,title, url')
             ->where(['type' => $type])
             ->orderBy('update_at desc')

api/controllers/TickerController.php

@@ -28,7 +28,7 @@ class TickerController extends BaseController
         $data_value = Yii::$app->request->get('data_value', '');
         $sort_value = Yii::$app->request->get('sort_value', '');
 
-        $exchange_arr = ['huobi', 'binance', 'zhaobi', 'bitnasdaq'];
+        $exchange_arr = ['huobi', 'binance', 'zhaobi', 'bitnasdaq', 'jingwang'];
 
         if (!in_array($exchange, $exchange_arr)) {
             $msg = '不存在的交易平台';
@@ -43,6 +43,9 @@ class TickerController extends BaseController
                 'sort_value' => $sort_value
             ];
         }
+        if ('jingwang' == $exchange) {
+            $exchange = 'jinwang';
+        }
         $builder = ExchangeBuilderFactory::create($exchange);
         $result = $builder->getTickerFromCache($page, $condition);
         $code = $result['code'];

backend/controllers/SourceController.php

@@ -11,7 +11,7 @@ namespace backend\controllers;
 use backend\models\coin\ArticleForm;
 use backend\models\coin\NoticeForm;
 use Yii;
-use common\models\pwallet\Article;
+use common\models\pwallet\News;
 use common\models\pwallet\Notice;
 use common\models\pwallet\Feedback;
 use yii\db\Exception;
@@ -37,7 +37,7 @@ class SourceController extends BaseController
             if ($status != 'all') {
                 $condition[] = ['status' => $status];
             }
-            $results                    = Article::getList($page, $limit, $condition);
+            $results                    = News::getList($page, $limit, $condition);
             Yii::$app->response->format = 'json';
             Yii::$app->response->data   = $results;
             Yii::$app->response->send();
@@ -56,7 +56,7 @@ class SourceController extends BaseController
         if (Yii::$app->request->isPost) {
             $request = Yii::$app->request;
             if ($model->load($request->post()) && $model->validate()) {
-                $article = new Article();
+                $article = new News();
                 $res     = $article->addOne($request->post());
                 if ($res === true) {
                     $this->success('添加成功', '/admin/source/article');
@@ -85,7 +85,7 @@ class SourceController extends BaseController
         $model->scenario = 'edit';
         $id              = Yii::$app->request->get('id', null);
         if ($id) {
-            $article = Article::findOne(['id' => $id]);
+            $article = News::findOne(['id' => $id]);
             if ($article) {
                 if (Yii::$app->request->isPost) {
                     if ($model->load(Yii::$app->request->post()) && $model->validate()) {
@@ -118,7 +118,7 @@ class SourceController extends BaseController
     {
         $id = Yii::$app->request->get('id', null);
         if ($id) {
-            $article = Article::findOne(['id' => $id]);
+            $article = News::findOne(['id' => $id]);
             if ($article) {
                 try {
                     $article->delete();

common/behaviors/LoginStatusAuthInterceptor.php

@@ -20,25 +20,24 @@ class LoginStatusAuthInterceptor extends ActionFilter
     {
         $request_class = get_class($action->controller);
         $request_action = $action->id;
-        if('login' == $request_action || 'user-sync' == $request_action){
+        if ('login' == $request_action || 'user-sync' == $request_action) {
             return true;
         }
         $token_string = Yii::$app->request->headers->get('Token');
-        if(false == $token_string){
+        if (false == $token_string) {
             $msg = 'platform auth error';
             $code = '40001';
             goto doEnd;
         }
-        $model = new Admin();
-        $user = $model->loginByAccessToken($token_string,'');
-        if(false == $user){
-            $msg = 'user auth error';
-            $code = '40002';
+        $user = Admin::verfication($token_string, '');
+        if (-1 == $user['code']) {
+            $code = '40001';
+            $msg = $user['data'];
             goto doEnd;
         }
-        $group = $user->group;
-        $user_id = $user->uid;
-        $platform_id = $user->platform_id;
+        $group = $user["data"]->group;
+        $user_id = $user["data"]->uid;
+        $platform_id = $user["data"]->platform_id;
         Yii::$app->request->setGroup($group);
         Yii::$app->request->setUserId($user_id);
         Yii::$app->request->setPlatformId($platform_id);

common/behaviors/OperationLogInterceptor.php

+<?php
+
+namespace common\behaviors;
+
+use Yii;
+use linslin\yii2\curl\Curl;
+use yii\base\ActionFilter;
+use wallet\base\ResponseMsg;
+
+class OperationLogInterceptor extends ActionFilter
+{
+    public function beforeAction($action)
+    {
+        if (!parent::beforeAction($action)) {
+            return false;
+        }
+
+        $method = strtolower(Yii::$app->request->method);
+        $handerClass = strtolower(Yii::$app->controller->id);
+        $handlerAction = strtolower(Yii::$app->controller->action->id);
+
+        if ('login' == $handlerAction) {
+            return true;
+        }
+//        if (!isset(Yii::$app->params['handleTableAndDesc']['handleTableAndDesc'][$handerClass][$handlerAction][$method])) {
+//            return false;
+//        }
+        if ('asset' == $handerClass) {
+            $uri = Yii::$app->request->post('uri', '');
+            $params = [
+                'ip' => Yii::$app->request->userIP,
+                'operation' => '操作',
+                'business' => isset(Yii::$app->params['handleTableAndDesc']['handleTableAndDesc'][$handerClass][$handlerAction][$uri]) ? Yii::$app->params['handleTableAndDesc']['handleTableAndDesc'][$handerClass][$handlerAction][$uri] : $uri,
+                'table' => 'asset'
+            ];
+        } else {
+            switch ($method) {
+                case "get":
+                    $operation = '查询';
+                    break;
+                case 'post':
+                    $operation = '增加';
+                    break;
+                case 'put':
+                    $operation = '更新';
+                    break;
+                case 'delete':
+                    $operation = '删除';
+                    break;
+                default:
+                    $operation = '未知';
+            }
+
+            $params = [
+                'ip' => Yii::$app->request->userIP,
+                'operation' => $operation,
+                'business' => Yii::$app->params['handleTableAndDesc']['handleTableAndDesc'][$handerClass][$handlerAction][$method] ?? $handerClass . '-' . $handlerAction,
+                'table' => Yii::$app->params['handleTableAndDesc']['handleTableAndDesc'][$handerClass][$handlerAction]['table'] ?? '未知'
+            ];
+        }
+
+        $token_string = Yii::$app->request->headers->get('Token');
+
+        $curl = new Curl();
+        $response = $curl->setRequestBody(json_encode($params))
+            ->setHeaders([
+                'Content-Type' => 'application/json',
+                'Token' => $token_string
+            ])
+            ->post(Yii::$app->params['go_biqianbao'] . '/api/log');
+        $response = json_decode($response, true);
+        if (!is_array($response) || 0 != $response['code']) {
+            $msg = '同步日志错误';
+            $code = -1;
+            goto doEnd;
+        }
+
+        return true;
+
+        doEnd :
+        // 返回错误
+        $response_message = new ResponseMsg();
+        $content = $response_message->jsonError($msg, $code);
+        $content = $response_message->withHeaders($response_message->getHeaders())->withContent($content);
+        Yii::$app->response->data = $content;
+        Yii::$app->response->send();
+        return false;
+
+    }
+}
\ No newline at end of file

common/behaviors/UserAuthInterceptor.php

@@ -23,20 +23,20 @@ class UserAuthInterceptor extends ActionFilter
 
         $request_class = get_class($action->controller);
         $request_action = $action->id;
-        if('login' == $request_action || 'user-sync' == $request_action){
+        if ('login' == $request_action || 'user-sync' == $request_action) {
             return true;
         }
         $token_string = Yii::$app->request->headers->get('Token');
-        $model = new Admin();
-        $user = $model->loginByAccessToken($token_string, '');
-        if (empty($user)) {
+        $user = Admin::verfication($token_string, '');
+        if (-1 == $user['code']) {
             $code = '40001';
-            $msg = 'user auth error';
+            $msg = $user['msg'];
             goto doEnd;
         }
-        $group = $user->group;
-        $user_id = $user->uid;
-        $platform_id = $user->platform_id;
+
+        $group = $user["data"]->group;
+        $user_id = $user["data"]->uid;
+        $platform_id = $user["data"]->platform_id;
         Yii::$app->request->setGroup($group);
         Yii::$app->request->setUserId($user_id);
         Yii::$app->request->setPlatformId($platform_id);

common/business/ExchangeBusiness.php

@@ -44,8 +44,9 @@ class ExchangeBusiness
         15 => 'Bitnasdaq',
         16 => 'Dag',
         17 => 'Coinka',
-        18 => 'Boc',
-
+        18 => 'Isummit',
+        19 => 'Boc',
+        20 => 'Jinwang'
 
         //1 => 'Hadax', //不需要
         //2 => 'Bitfinex', //不需要
@@ -84,6 +85,17 @@ class ExchangeBusiness
             $quotation['last'] = (float)sprintf("%0.4f", $quotation['rmb'] / $rate);
             goto doEnd;
         }
+
+        if (strtoupper($tag) == 'DUSDT') {
+            $quotation = [
+                'low' => 6.99,
+                'high' => 6.99,
+                'last' => 6.99,
+                'rmb' => 6.99,
+            ];
+            goto doEnd;
+        }
+
         if (strtoupper($tag) == 'YPLUS') {
             $quotation = [
                 'low' => 10,
@@ -124,6 +136,16 @@ class ExchangeBusiness
             goto doEnd;
         }
 
+        if (strtoupper($tag) == 'POKE') {
+            $quotation = [
+                'low' => 0.1587,
+                'high' => 0.1587,
+                'last' => 0.1587,
+                'rmb' => 0.1587,
+            ];
+            goto doEnd;
+        }
+
         if (strtoupper($tag) == 'GST' || strtoupper($tag) == 'JNTK' || strtoupper($tag) == 'SPT' || strtoupper($tag) == 'STO' || strtoupper($tag) == 'GM' || strtoupper($tag) == 'BSTC' || strtoupper($tag) == 'RYH' || strtoupper($tag) == 'CNDT' || strtoupper($tag) == 'WL' || strtoupper($tag) == 'ETS' || strtoupper($tag) == 'LIMS' || strtoupper($tag) == 'AT' || strtoupper($tag) == 'BTJ') {
             $quotation = [
                 'low' => 0,
@@ -139,6 +161,12 @@ class ExchangeBusiness
         }
         $f = false;
         $quotation = [];
+        if (in_array(strtoupper($tag), ['SUM', 'USDW', 'FUT'])) {
+            $exchange = ExchangeFactory::createExchange("Isummit");
+            $quotation = $exchange->getTicker($tag, 'USDT');
+            goto doEnd;
+        }
+
         if (in_array(strtoupper($tag), ['PAX'])) {
             $exchange = ExchangeFactory::createExchange("HuoBi");
             $quotation = $exchange->getTicker($tag, 'husd');
@@ -337,9 +365,13 @@ class ExchangeBusiness
         $exchange = ExchangeFactory::createExchange("Go");
         $rate = $exchange->getTicker("CNY", "USD");
         $cny_usd_rate = 1 / $rate['last'];
-        if (in_array(strtoupper($tag), ['FOLI', 'CIC', 'KPC8', 'BVA', 'DAG', 'BNC', 'GHP', 'DRA', 'ETC', 'PAX', 'STH', 'XJH', 'SFT', 'TSC'])) {
+        if (in_array(strtoupper($tag), ['FOLI', 'CIC', 'KPC8', 'BVA', 'DAG', 'BNC', 'GHP', 'DRA', 'ETC', 'PAX', 'STH', 'XJH', 'SFT', 'TSC', 'SUM', 'USDW', 'FUT'])) {
             $quotation['usd'] = (float)sprintf("%0.4f", $quotation['last']);
             $quotation['rmb'] = (float)sprintf("%0.4f", $quotation['last'] / $cny_usd_rate);
+            $quotation['low'] = (float)sprintf("%0.4f", $quotation['low']);
+            $quotation['high'] = (float)sprintf("%0.4f", $quotation['high']);
+            $quotation['last'] = (float)sprintf("%0.4f", $quotation['last']);
+            $quotation['open'] = isset($quotation['open']) ? (float)sprintf("%0.4f", $quotation['open']) : $quotation['last'];
         } else if (in_array(strtoupper($tag), ['SUSD'])) {
             $quotation['usd'] = (float)sprintf("%0.4f", 1);
         } else {

common/models/Admin.php

@@ -2,6 +2,7 @@
 
 namespace common\models;
 
+use Firebase\JWT\JWT;
 use Yii;
 use yii\base\NotSupportedException;
 use yii\web\IdentityInterface;
@@ -25,25 +26,25 @@ use yii\web\IdentityInterface;
 class Admin extends \common\modelsgii\Admin implements IdentityInterface
 {
     const STATUS_DELETED = 0;
-    const STATUS_ACTIVE  = 1;
+    const STATUS_ACTIVE = 1;
 
-	/**
+    /**
      * 根据UID获取账号信息
      */
     public static function findIdentity($uid)
     {
-		return static::find()->where(['uid' => $uid, 'status' => self::STATUS_ACTIVE])->one();
+        return static::find()->where(['uid' => $uid, 'status' => self::STATUS_ACTIVE])->one();
     }
 
     /**
      * 根据用户名获取账号信息
      *
      * @param string $username
-	 * @return array|null|\yii\db\ActiveRecord
-	 */
+     * @return array|null|\yii\db\ActiveRecord
+     */
     public static function findByUsername($username)
     {
-		return static::findOne(['username' => $username, 'status' => self::STATUS_ACTIVE]);
+        return static::findOne(['username' => $username, 'status' => self::STATUS_ACTIVE]);
     }
 
     /**
@@ -76,7 +77,7 @@ class Admin extends \common\modelsgii\Admin implements IdentityInterface
             return false;
         }
 
-        $timestamp = (int) substr($token, strrpos($token, '_') + 1);
+        $timestamp = (int)substr($token, strrpos($token, '_') + 1);
         $expire = Yii::$app->params['user.passwordResetTokenExpire'];
         return $timestamp + $expire >= time();
     }
@@ -89,13 +90,13 @@ class Admin extends \common\modelsgii\Admin implements IdentityInterface
         return $this->getPrimaryKey();
     }
 
-	/**
-	 * @inheritdoc
-	 */
-	public function getAuthKey()
-	{
-		return $this->salt;
-	}
+    /**
+     * @inheritdoc
+     */
+    public function getAuthKey()
+    {
+        return $this->salt;
+    }
 
     /**
      * @inheritdoc
@@ -168,8 +169,31 @@ class Admin extends \common\modelsgii\Admin implements IdentityInterface
         return $user;
     }
 
-    public function loginByAccessToken($accessToken, $type) {
-        return static::findIdentityByAccessToken($accessToken, $type);
+    public function loginByAccessToken($accessToken, $type)
+    {
+        print_r(static::findIdentityByAccessToken($accessToken, $type));
+        exit;
+    }
+
+    public static function verfication($accessToken)
+    {
+        $key = 'bwallet'; //key要和签发的时候一样
+        try {
+            JWT::$leeway = 60;//当前时间减去60，把时间留点余地
+            $decoded = JWT::decode($accessToken, $key, ['HS256']); //HS256方式，这里要和签发的时候对应
+            $arr = (array)$decoded;
+            $resp = [
+                'code' => 0,
+                'data' => $arr['user']
+            ];
+        } catch (\Exception $e) {  //其他错误
+            $resp = [
+                'code' => -1,
+                'data' => $e->getMessage()
+            ];
+        }
+
+        return $resp;
     }
 
     /**

common/models/LoginForm.php

 <?php
+
 namespace common\models;
 
 use Yii;
@@ -34,11 +35,12 @@ class LoginForm extends Model
         ];
     }
 
-    public function scenarios() {
+    public function scenarios()
+    {
         $scenarios = [
             self:: SCENARIOS_LOGIN => ['username', 'password'],
         ];
-        return array_merge( parent:: scenarios(), $scenarios);
+        return array_merge(parent:: scenarios(), $scenarios);
     }
 
     /**
@@ -67,13 +69,10 @@ class LoginForm extends Model
     {
         if ($this->validate()) {
             if ($this->getUser()) {
-                $access_token = $this->_user->generateAccessToken();
-                $this->_user->access_token = $access_token ;
-                $this->_user->save();
-                return $access_token;
+                return $this->_user;
             }
         }
-        
+
         return false;
     }
 

common/models/pwallet/Article.php

@@ -87,7 +87,7 @@ class Article extends BaseActiveRecord
             unset($params['id']);
         } else {
             $article = $this;
-            $params  = array_merge($params, ['create_at' => date('Y-m-d H:i:s')]);
+            $params = array_merge($params, ['create_at' => date('Y-m-d H:i:s')]);
         }
         $params = array_merge($params, ['update_at' => date('Y-m-d H:i:s', time())]);
         if (!isset($params['status'])) {

common/models/pwallet/News.php

+<?php
+/**
+ * Created by PhpStorm.
+ * User: rlgyzhcn
+ * Date: 18-6-4
+ * Time: 上午9:53
+ */
+
+namespace common\models\pwallet;
+
+use common\base\Exception;
+use common\core\BaseActiveRecord;
+use Yii;
+
+class News extends BaseActiveRecord
+{
+    public static function getDb()
+    {
+        return Yii::$app->get('db_pwallet');
+    }
+
+    public static function tableName()
+    {
+        return '{{%news}}';
+    }
+
+    /**
+     * 获取文章列表
+     * @param int $page
+     * @param int $limit
+     * @param array $condition
+     * @return array
+     */
+    public static function getList($page = 1, $limit = 10, $condition = [])
+    {
+        $query = self::find();
+        foreach ($condition as $item) {
+            $query = $query->andWhere($item);
+        }
+        $count = $query->count();
+        if ($count) {
+            $data = $query->offset(($page - 1) * $limit)->limit($limit)->asArray()->all();
+            return ['code' => 0, 'count' => $count, 'data' => $data];
+        }
+        return ['code' => 1, 'msg' => '数据为空'];
+    }
+
+    /**
+     * 添加文章
+     * @param $params
+     * @return bool|array
+     */
+    public function addOne($params)
+    {
+        return $this->realWrite($params);
+    }
+
+    /**
+     * 更新文章
+     * @param $params
+     * @return bool|array
+     */
+    public function updateOne($params)
+    {
+        return $this->realWrite($params);
+    }
+
+    /**
+     * 实际操作数据方法
+     */
+    private function realWrite($params)
+    {
+        if (!is_array($params)) {
+            $params = [$params];
+        }
+        $params = array_filter($params, function ($value, $key) {
+            if (ctype_digit($key) || empty($value)) {
+                return false;
+            }
+            return true;
+        }, ARRAY_FILTER_USE_BOTH);
+        if (isset($params['id'])) {
+            $article = self::findOne($params['id']);
+            if ($article === null) {
+                return ['code' => 1, 'msg' => '文章不存在'];
+            }
+            unset($params['id']);
+        } else {
+            $article = $this;
+            $params  = array_merge($params, ['create_at' => date('Y-m-d H:i:s')]);
+        }
+        $params = array_merge($params, ['update_at' => date('Y-m-d H:i:s', time())]);
+        if (!isset($params['status'])) {
+            $params['status'] = 0;
+        }
+        $article->setAttributes($params, false);
+        try {
+            return (bool)$article->save();
+        } catch (Exception $exception) {
+            return ['code' => $exception->getCode(), 'msg' => $exception->getMessage()];
+        }
+    }
+}
\ No newline at end of file

common/service/exchange/Isummit.php

+<?php
+/**
+ * Created by PhpStorm.
+ * User: rlgyzhcn
+ * Date: 18-6-26
+ * Time: 下午7:21
+ */
+
+namespace common\service\exchange;
+
+use Yii;
+use linslin\yii2\curl\Curl;
+
+class Isummit extends Exchange implements ExchangeInterface
+{
+    protected $supported_symbol = 'supported_symbol_isummit';
+    protected $quotation_prefix = 'quotation_isummit_';
+    protected $base_url = 'http://www.isummit.top';
+
+    public function formatSymbol($tag = 'BTC', $aim = 'USDT')
+    {
+        return strtolower(trim($tag) . trim($aim));
+    }
+
+    public function setSupportedSymbol()
+    {
+
+    }
+
+    public function setQuotation()
+    {
+        $curl = new Curl();
+        $api = $this->base_url . '/api/coins/market';
+        $res = $curl->get($api, false);
+        if (isset($res['code']) && 200 == $res['code'] && isset($res['data'])) {
+            foreach ($res['data'] as $item) {
+                if (in_array(strtoupper($item['coin']), ['SUM', 'USDW', 'FUT'])) {
+                    $low = isset($item['price']) ? $item['price'] : 0;
+                    $high = isset($item['price']) ? $item['price'] : 0;
+                    $last = isset($item['price']) ? $item['price'] : 0;
+                    $open = isset($item['price']) ? $item['price'] : 0;
+                    $cache_key = $this->quotation_prefix . strtolower($item['coin'] . 'USDT');
+                    $this->redis->hmset($cache_key, 'low', $low, 'high', $high, 'last', $last, 'open', $open);
+                }
+            }
+        }
+    }
+
+}

common/service/exchange/Jinwang.php

+<?php
+/**
+ * Created by PhpStorm.
+ * User: rlgyzhcn
+ * Date: 18-8-7
+ * Time: 上午11:30
+ */
+
+namespace common\service\exchange;
+
+use linslin\yii2\curl\Curl;
+
+class Jinwang extends Exchange implements ExchangeInterface
+{
+    protected $supported_symbol = 'supported_symbol_jinwang';
+    protected $quotation_prefix = 'quotation_jinwang_';
+    protected $base_url = 'http://www.jinwangin.com/exapi/api/klinevtwo/message';
+
+    public function symbolExists($tag = 'TG', $aim = "USDT")
+    {
+        $supported = $this->redis->smembers($this->supported_symbol);
+        if (is_array($supported) && in_array($this->formatSymbol($tag, $aim), $supported)) {
+            return true;
+        }
+        return false;
+    }
+
+    /**
+     * 转化交易对为请求变量
+     *
+     * @param string $tag
+     * @param string $aim
+     * @return mixed
+     */
+    public function formatSymbol($tag = 'TG', $aim = 'USDT')
+    {
+        return strtoupper($tag . $aim);
+    }
+
+    /**
+     * 保存支持的交易对到redis数据库，使用crontab定时更新
+     *
+     * @return mixed|void
+     */
+    public function setSupportedSymbol()
+    {
+
+    }
+
+    /**
+     * 更新交易对行情保存到redis，使用crontab定时更新
+     *
+     * @return mixed|void
+     */
+    public function setQuotation()
+    {
+        $curl = new Curl();
+        $resp = $curl->get($this->base_url, false);
+        if (is_array($resp)) {
+            if (isset($resp['marketDetail'])) {
+                foreach ($resp['marketDetail'] as $symbol => $item) {
+                    $key = $this->quotation_prefix . strtolower($symbol);
+                    $this->redis->hmset($key, 'low', $item[0]["payload"]['priceLow'], 'high', $item[0]["payload"]['priceHigh'], 'last', $item[0]["payload"]['priceLast'], 'open', $item[0]["payload"]['priceOpen'], 'vol', $item[0]["payload"]['totalAmount']);
+                    if (!$this->redis->sismember($this->supported_symbol, strtoupper($symbol))) {
+                        $this->redis->sadd($this->supported_symbol, strtoupper($symbol));
+                    }
+                }
+            }
+        }
+    }
+
+}
\ No newline at end of file

common/service/exchange/factory/JinwangBuilder.php

+<?php
+/**
+ * Created by PhpStorm.
+ * User: jiaming
+ * Date: 2019/8/15
+ * Time: 10:10
+ */
+
+namespace common\service\exchange\factory;
+
+use common\components\Tools;
+use linslin\yii2\curl\Curl;
+
+class JinwangBuilder extends FactoryService
+{
+    protected $base_url = 'http://www.jinwangin.com';
+    protected $supported_symbol = 'supported_symbol_jinwang';
+    protected $supported_symbol_list = 'supported_symbol_jinwang_list';
+    protected $supported_symbol_close_asc = 'supported_symbol_close_asc_jinwang';
+    protected $supported_symbol_close_desc = 'supported_symbol_close_desc_jinwang';
+    protected $supported_symbol_change_asc = 'supported_symbol_change_asc_jinwang';
+    protected $supported_symbol_change_desc = 'supported_symbol_change_desc_jinwang';
+    protected $quotation_prefix = 'quotation_jinwang_';
+
+    public function getTickerFromCache($page = 1, $condition = [])
+    {
+        $size = 0;
+        for ($i = 0; $i < $page; $i++) {
+            $size += 50;
+            $this->end = $size;
+        }
+        $this->start = $this->end - 50;
+        $this->end = $this->end - 1;
+        $keys = $this->redis->smembers($this->supported_symbol);
+        if (false == $this->redis->exists($this->supported_symbol_list)) {
+            foreach ($keys as $val) {
+                if (in_array(strtoupper($val), ['LTC_USDT', 'BTC_USDT', 'EOS_USDT', 'TG_USDT', 'TPC_USDT', 'ETH_USDT'])) {
+                    $this->redis->lpush($this->supported_symbol_list, strtoupper($val));
+                }
+            }
+        }
+        if (false != $condition) {
+            if ('price' == $condition['data_value']) {
+                if ('price_asc' == $condition['sort_value']) {
+                    $keys = $this->redis_ticker->lrange($this->supported_symbol_close_asc, $this->start, $this->end);
+                }
+                if ('price_desc' == $condition['sort_value']) {
+                    $keys = $this->redis_ticker->lrange($this->supported_symbol_close_desc, $this->start, $this->end);
+                }
+            }
+            if ('change' == $condition['data_value']) {
+                if ('change_asc' == $condition['sort_value']) {
+                    $keys = $this->redis_ticker->lrange($this->supported_symbol_change_asc, $this->start, $this->end);
+                }
+                if ('change_desc' == $condition['sort_value']) {
+                    $keys = $this->redis_ticker->lrange($this->supported_symbol_change_desc, $this->start, $this->end);
+                }
+            }
+        } else {
+            $keys = $this->redis->lrange($this->supported_symbol_list, $this->start, $this->end);
+        }
+
+        $ticker = [];
+        foreach ($keys as $val) {
+            foreach ($this->basic_coin as $k => $coin) {
+                $explode_arr = explode(strtoupper($coin), strtoupper($val));
+                if (2 == count($explode_arr) && empty($explode_arr[1])) {
+                    if (false != $condition) {
+                        list($low, $high, $close, $open, $vol) = $this->redis_ticker->hmget($this->quotation_prefix . strtoupper($val), 'low', 'high', 'last', 'open', 'vol');
+                    } else {
+                        list($low, $high, $close, $open, $vol) = $this->redis->hmget($this->quotation_prefix . strtolower($val), 'low', 'high', 'last', 'open', 'vol');
+                    }
+                    $temp = [];
+                    $temp['currency'] = strtoupper(str_replace('_', '', $explode_arr[0]));
+                    $temp['symbol'] = $temp['currency'] . '/' . $coin;
+                    $temp['base_currency'] = strtoupper($coin);
+                    $temp['close'] = rtrim(sprintf('%.8f', floatval($close)), '0');
+                    $temp['close_usd'] = rtrim(sprintf('%.6f', floatval($close * $this->basic_price[$coin]['usd'])), '0');
+                    $temp['close_rmb'] = (float)sprintf("%0.4f", $close * $this->basic_price[$coin]['rmb']);
+                    $temp['change'] = (false == $open) ? 0 : (float)sprintf("%0.2f", ($close - $open) / $open * 100);
+                    $temp['high_usd'] = (float)sprintf("%0.4f", $high * $this->basic_price[$coin]['usd']);
+                    $temp['low_usd'] = (float)sprintf("%0.4f", $low * $this->basic_price[$coin]['usd']);
+                    $temp['high_rmb'] = (float)sprintf("%0.4f", $high * $this->basic_price[$coin]['rmb']);
+                    $temp['low_rmb'] = (float)sprintf("%0.4f", $low * $this->basic_price[$coin]['rmb']);
+                    $temp['vol'] = (float)sprintf("%0.4f", $vol);
+                    $temp['optional'] = false;
+                    $temp['platform_zh'] = '金网国际';
+                    $temp['platform_us'] = 'Diamond coin';
+                    array_push($ticker, $temp);
+                }
+            }
+        }
+        $this->code = 0;
+        $data = [
+            'ticker' => $ticker,
+            'page' => [
+                'pageSize' => 50,
+                'currentPage' => (int)$page,
+            ]
+        ];
+        return ['code' => $this->code, 'data' => $data];
+    }
+
+    public function TickerSort()
+    {
+        $len = $this->redis->llen($this->supported_symbol_list);
+        $ticker = [];
+        for ($i = 0; $i < $len; $i++) {
+            $symbol = $this->redis->lindex($this->supported_symbol_list, $i);
+            list($close, $open, $low, $high, $vol) = $this->redis->hmget($this->quotation_prefix . strtolower($symbol), 'last', 'open', 'low', 'high', 'vol');
+            if ('0.00000000' == $close) continue;
+            $temp = [];
+            $temp['symbol'] = strtoupper($symbol);
+            $temp['close'] = $close;
+            foreach ($this->basic_coin as $k => $coin) {
+                $explode_arr = explode(strtoupper($coin), strtoupper($symbol));
+                if (2 == count($explode_arr) && empty($explode_arr[1])) {
+                    $temp['close_rmb'] = (float)sprintf("%0.4f", $close * $this->basic_price[$coin]['rmb']);
+                }
+            }
+            $temp['low'] = $low;
+            $temp['high'] = $high;
+            $temp['open'] = $open;
+            $temp['vol'] = $vol;
+            $temp['change'] = (0 == $open) ? 0 : (float)sprintf("%0.2f", ($close - $open) / $open * 100);
+            array_push($ticker, $temp);
+            $key = $this->quotation_prefix . strtoupper($symbol);
+            $this->redis_ticker->hmset($key, 'low', $low, 'high', $high, 'last', $close, 'open', $open, 'vol', $vol);
+        }
+
+        $ticker_sort_close = Tools::arraySort($ticker, 'close_rmb');
+        $this->redis_ticker->del($this->supported_symbol_close_asc);
+        $this->redis_ticker->del($this->supported_symbol_close_desc);
+        foreach ($ticker_sort_close as $val) {
+            $this->redis_ticker->lpush($this->supported_symbol_close_asc, strtoupper($val['symbol']));
+            $this->redis_ticker->rpush($this->supported_symbol_close_desc, strtoupper($val['symbol']));
+        }
+
+        $ticker_change_close = Tools::arraySort($ticker, 'change');
+        $this->redis_ticker->del($this->supported_symbol_change_asc);
+        $this->redis_ticker->del($this->supported_symbol_change_desc);
+        foreach ($ticker_change_close as $val) {
+            $this->redis_ticker->lpush($this->supported_symbol_change_asc, strtoupper($val['symbol']));
+            $this->redis_ticker->rpush($this->supported_symbol_change_desc, strtoupper($val['symbol']));
+        }
+    }
+
+    public function getHotTicker($symbol = [])
+    {
+        if (empty($symbol)) {
+            return ['code' => $this->code, 'ticker' => []];
+        }
+
+        $ticker = [];
+        foreach ($symbol as $val) {
+            list($low, $high, $close, $open, $vol) = $this->redis->hmget($this->quotation_prefix . strtolower($val), 'low', 'high', 'last', 'open', 'vol');
+            $explode_arr = explode('usdt', $val);
+            $temp = [];
+            $temp['symbol'] = strtoupper($explode_arr[0]) . '/USDT';
+            $temp['currency'] = strtoupper($explode_arr[0]);
+            $temp['base_currency'] = 'USDT';
+            $temp['close'] = (float)sprintf("%0.6f", $close);
+            $temp['close_usd'] = (float)sprintf("%0.6f", $close * $this->basic_price['USDT']['usd']);
+            $temp['close_rmb'] = (float)sprintf("%0.4f", $close * $this->basic_price['USDT']['rmb']);
+            $temp['change'] = (0 == $open) ? 0 : (float)sprintf("%0.2f", ($close - $open) / $open * 100);
+            $temp['high_usd'] = (float)sprintf("%0.4f", $high * $this->basic_price['USDT']['usd']);
+            $temp['low_usd'] = (float)sprintf("%0.4f", $low * $this->basic_price['USDT']['usd']);
+            $temp['high_rmb'] = (float)sprintf("%0.4f", $high * $this->basic_price['USDT']['rmb']);
+            $temp['low_rmb'] = (float)sprintf("%0.4f", $low * $this->basic_price['USDT']['rmb']);
+            $temp['vol'] = (float)sprintf("%0.4f", $vol);
+            array_push($ticker, $temp);
+        }
+        if (count($ticker) > 0) {
+            $this->code = 0;
+        }
+        return ['code' => $this->code, 'ticker' => $ticker];
+    }
+}

common/service/trusteeship/TrusteeShipService.php

@@ -158,4 +158,9 @@ class TrusteeShipService
 
         return $this->send("POST", $uri, $params);
     }
+
+    public function handleAsset($uri, $method, $params)
+    {
+        return $this->send($method, $uri, $params);
+    }
 }

composer.json

@@ -26,7 +26,8 @@
     "yiisoft/yii2-elasticsearch": "~2.0.0",
     "workerman/workerman": "^3.5",
     "aliyuncs/oss-sdk-php": "^2.3",
-    "elasticsearch/elasticsearch": "^7.4"
+    "elasticsearch/elasticsearch": "^7.4",
+    "firebase/php-jwt": "^5.2"
   },
   "require-dev": {
     "yiisoft/yii2-debug": "~2.0.0",

composer.lock

@@ -4,7 +4,7 @@
         "Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies",
         "This file is @generated automatically"
     ],
-    "content-hash": "c74650379de435f8618ee861ec785d20",
+    "content-hash": "e1686d1bba6dc1878258a26d6da1d392",
     "packages": [
         {
             "name": "aliyuncs/oss-sdk-php",
@@ -463,6 +463,56 @@
             "time": "2018-02-23T01:58:20+00:00"
         },
         {
+            "name": "firebase/php-jwt",
+            "version": "v5.2.0",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/firebase/php-jwt.git",
+                "reference": "feb0e820b8436873675fd3aca04f3728eb2185cb"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/firebase/php-jwt/zipball/feb0e820b8436873675fd3aca04f3728eb2185cb",
+                "reference": "feb0e820b8436873675fd3aca04f3728eb2185cb",
+                "shasum": ""
+            },
+            "require": {
+                "php": ">=5.3.0"
+            },
+            "require-dev": {
+                "phpunit/phpunit": ">=4.8 <=9"
+            },
+            "type": "library",
+            "autoload": {
+                "psr-4": {
+                    "Firebase\\JWT\\": "src"
+                }
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "BSD-3-Clause"
+            ],
+            "authors": [
+                {
+                    "name": "Neuman Vong",
+                    "email": "neuman+pear@twilio.com",
+                    "role": "Developer"
+                },
+                {
+                    "name": "Anant Narayanan",
+                    "email": "anant@php.net",
+                    "role": "Developer"
+                }
+            ],
+            "description": "A simple library to encode and decode JSON Web Tokens (JWT) in PHP. Should conform to the current spec.",
+            "homepage": "https://github.com/firebase/php-jwt",
+            "keywords": [
+                "jwt",
+                "php"
+            ],
+            "time": "2020-03-25T18:49:23+00:00"
+        },
+        {
             "name": "guzzlehttp/ringphp",
             "version": "1.1.1",
             "source": {
@@ -511,6 +561,7 @@
                 }
             ],
             "description": "Provides a simple API and specification that abstracts away the details of HTTP into a single PHP function.",
+            "abandoned": true,
             "time": "2018-07-31T13:22:33+00:00"
         },
         {
@@ -561,6 +612,7 @@
                 "Guzzle",
                 "stream"
             ],
+            "abandoned": true,
             "time": "2014-10-12T19:18:40+00:00"
         },
         {
@@ -5329,5 +5381,6 @@
     "platform": {
         "php": ">=5.4.0"
     },
-    "platform-dev": []
+    "platform-dev": [],
+    "plugin-api-version": "1.1.0"
 }

console/controllers/ArticleController.php

+<?php
+
+namespace console\controllers;
+
+use Yii;
+use yii\console\Controller;
+use common\components\Tools;
+use common\models\pwallet\Article;
+use common\service\bishijie\BishijieService;
+
+class ArticleController extends Controller
+{
+    public function actionIndex()
+    {
+        $page = 1;
+        $size = 20;
+
+        $bishijie = Yii::$app->params['bishijie'];
+        $appid = $bishijie['Appid'];
+        $appSecret = $bishijie['AppSecret'];
+        $bishijie_service = new BishijieService($appid, $appSecret);
+        $resp = $bishijie_service->getArticleList($page, $size);
+
+        if (!isset($resp['list'])) {
+            return 0;
+        }
+        $create_time = Article::find()->where(['platform_id' => -1])->max('create_time');
+
+        $list = $resp['list'];
+        if ($create_time >= $list[0]['issue_time']) {
+            return 0;
+        }
+
+        $list = Tools::arraySort($list, 'issue_time', SORT_ASC);
+
+        $article = new Article();
+        foreach ($list as &$item) {
+            go(function () use ($item, $article, $create_time) {
+                \Co::sleep(0.5);
+                if ($item['issue_time'] > $create_time) {
+                    $article->setIsNewRecord(true);
+                    $article->title = $item['title'];
+                    $article->source = $item['source'];
+                    $article->content = $item['id'];
+                    $article->logo_pic = $item['promulgator']['logo_pic'];
+                    $article->img_url = $item['img_url'];
+                    $article->platform_id = -1;
+                    $article->create_time = $item['issue_time'];
+                    $article->save() && $article->id = 0;;
+                }
+            });
+        }
+        return 0;
+    }
+}

console/controllers/NewsController.php

+<?php
+
+namespace console\controllers;
+
+use Yii;
+use yii\console\Controller;
+use linslin\yii2\curl\Curl;
+use common\components\Tools;
+use common\models\pwallet\News;
+
+class NewsController extends Controller
+{
+    public function actionIndex()
+    {
+        $coindog = Yii::$app->params['coindog'];
+
+        $accessKey = $coindog['accessKey'];
+        $secretKey = $coindog['secretKey'];
+        $httpParams = array(
+            'access_key' => $accessKey,
+            'date' => time()
+        );
+
+        $signParams = array_merge($httpParams, array('secret_key' => $secretKey));
+
+        ksort($signParams);
+        $signString = http_build_query($signParams);
+
+        $httpParams = [
+            'sign' => strtolower(md5($signString)),
+        ];
+
+        $url = $coindog['live'] . '?' . http_build_query($httpParams);
+        $curl = new Curl();
+        $resp = $curl->get($url, false);
+        if (!isset($resp['list'])) {
+            return 0;
+        }
+        $create_time = News::find()->where(['platform_id' => -1])->max('create_time');
+
+        $list = $resp['list'][0]['lives'];
+        if ($create_time >= $list[0]['created_at']) {
+            return 0;
+        }
+
+        $list = Tools::arraySort($list, 'created_at', SORT_ASC);
+
+        $article = new News();
+        foreach ($list as &$item) {
+            go(function () use ($item, $article, $create_time) {
+                \Co::sleep(0.5);
+                if ($item['created_at'] > $create_time) {
+                    preg_match_all("/\【(.+?)\】/", $item['content'], $match);
+                    $title = $match[1][0];
+                    $content = str_replace('【' . $title . '】', '', $item['content']);
+
+                    $article->setIsNewRecord(true);
+                    $article->title = $title;
+                    $article->content = $content;
+                    $article->platform_id = -1;
+                    $article->create_time = $item['created_at'];
+                    $article->save() && $article->id = 0;;
+                }
+            });
+        }
+        return 0;
+    }
+}

console/controllers/TickerController.php

@@ -14,7 +14,7 @@ class TickerController extends Controller
 {
     public function actionSort()
     {
-        $class = ['Binance', 'Huobi', 'Zhaobi', 'Bitnasdaq'];
+        $class = ['Binance', 'Huobi', 'Zhaobi', 'Bitnasdaq', 'Jinwang'];
         foreach ($class as $val) {
             go(function () use ($val) {
                 \Co::sleep(0.5);

vendor/composer/autoload_psr4.php

@@ -74,6 +74,7 @@ return array(
     'GuzzleHttp\\Stream\\' => array($vendorDir . '/guzzlehttp/streams/src'),
     'GuzzleHttp\\Ring\\' => array($vendorDir . '/guzzlehttp/ringphp/src'),
     'GuzzleHttp\\Psr7\\' => array($vendorDir . '/guzzlehttp/psr7/src'),
+    'Firebase\\JWT\\' => array($vendorDir . '/firebase/php-jwt/src'),
     'Faker\\' => array($vendorDir . '/fzaninotto/faker/src/Faker'),
     'Elasticsearch\\' => array($vendorDir . '/elasticsearch/elasticsearch/src/Elasticsearch'),
     'Egulias\\EmailValidator\\' => array($vendorDir . '/egulias/email-validator/EmailValidator'),

vendor/composer/autoload_real.php

@@ -13,6 +13,9 @@ class ComposerAutoloaderInit33057934f3e7eaaa1ce2d53797277936
         }
     }
 
+    /**
+     * @return \Composer\Autoload\ClassLoader
+     */
     public static function getLoader()
     {
         if (null !== self::$loader) {

vendor/composer/autoload_static.php

@@ -128,6 +128,7 @@ class ComposerStaticInit33057934f3e7eaaa1ce2d53797277936
         ),
         'F' => 
         array (
+            'Firebase\\JWT\\' => 13,
             'Faker\\' => 6,
         ),
         'E' => 
@@ -423,6 +424,10 @@ class ComposerStaticInit33057934f3e7eaaa1ce2d53797277936
         array (
             0 => __DIR__ . '/..' . '/guzzlehttp/psr7/src',
         ),
+        'Firebase\\JWT\\' => 
+        array (
+            0 => __DIR__ . '/..' . '/firebase/php-jwt/src',
+        ),
         'Faker\\' => 
         array (
             0 => __DIR__ . '/..' . '/fzaninotto/faker/src/Faker',

vendor/composer/installed.json

@@ -380,7 +380,8 @@
             "acceptance testing",
             "functional testing",
             "unit testing"
-        ]
+        ],
+        "abandoned": true
     },
     {
         "name": "codeception/phpunit-wrapper",
@@ -826,6 +827,58 @@
         ]
     },
     {
+        "name": "firebase/php-jwt",
+        "version": "v5.2.0",
+        "version_normalized": "5.2.0.0",
+        "source": {
+            "type": "git",
+            "url": "https://github.com/firebase/php-jwt.git",
+            "reference": "feb0e820b8436873675fd3aca04f3728eb2185cb"
+        },
+        "dist": {
+            "type": "zip",
+            "url": "https://api.github.com/repos/firebase/php-jwt/zipball/feb0e820b8436873675fd3aca04f3728eb2185cb",
+            "reference": "feb0e820b8436873675fd3aca04f3728eb2185cb",
+            "shasum": ""
+        },
+        "require": {
+            "php": ">=5.3.0"
+        },
+        "require-dev": {
+            "phpunit/phpunit": ">=4.8 <=9"
+        },
+        "time": "2020-03-25T18:49:23+00:00",
+        "type": "library",
+        "installation-source": "dist",
+        "autoload": {
+            "psr-4": {
+                "Firebase\\JWT\\": "src"
+            }
+        },
+        "notification-url": "https://packagist.org/downloads/",
+        "license": [
+            "BSD-3-Clause"
+        ],
+        "authors": [
+            {
+                "name": "Neuman Vong",
+                "email": "neuman+pear@twilio.com",
+                "role": "Developer"
+            },
+            {
+                "name": "Anant Narayanan",
+                "email": "anant@php.net",
+                "role": "Developer"
+            }
+        ],
+        "description": "A simple library to encode and decode JSON Web Tokens (JWT) in PHP. Should conform to the current spec.",
+        "homepage": "https://github.com/firebase/php-jwt",
+        "keywords": [
+            "jwt",
+            "php"
+        ]
+    },
+    {
         "name": "fzaninotto/faker",
         "version": "v1.8.0",
         "version_normalized": "1.8.0.0",
@@ -995,7 +1048,8 @@
                 "homepage": "https://github.com/mtdowling"
             }
         ],
-        "description": "Provides a simple API and specification that abstracts away the details of HTTP into a single PHP function."
+        "description": "Provides a simple API and specification that abstracts away the details of HTTP into a single PHP function.",
+        "abandoned": true
     },
     {
         "name": "guzzlehttp/streams",
@@ -1047,7 +1101,8 @@
         "keywords": [
             "Guzzle",
             "stream"
-        ]
+        ],
+        "abandoned": true
     },
     {
         "name": "kartik-v/bootstrap-fileinput",

vendor/firebase/php-jwt/LICENSE

+Copyright (c) 2011, Neuman Vong
+
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+    * Redistributions of source code must retain the above copyright
+      notice, this list of conditions and the following disclaimer.
+
+    * Redistributions in binary form must reproduce the above
+      copyright notice, this list of conditions and the following
+      disclaimer in the documentation and/or other materials provided
+      with the distribution.
+
+    * Neither the name of Neuman Vong nor the names of other
+      contributors may be used to endorse or promote products derived
+      from this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

vendor/firebase/php-jwt/README.md

+[![Build Status](https://travis-ci.org/firebase/php-jwt.png?branch=master)](https://travis-ci.org/firebase/php-jwt)
+[![Latest Stable Version](https://poser.pugx.org/firebase/php-jwt/v/stable)](https://packagist.org/packages/firebase/php-jwt)
+[![Total Downloads](https://poser.pugx.org/firebase/php-jwt/downloads)](https://packagist.org/packages/firebase/php-jwt)
+[![License](https://poser.pugx.org/firebase/php-jwt/license)](https://packagist.org/packages/firebase/php-jwt)
+
+PHP-JWT
+=======
+A simple library to encode and decode JSON Web Tokens (JWT) in PHP, conforming to [RFC 7519](https://tools.ietf.org/html/rfc7519).
+
+Installation
+------------
+
+Use composer to manage your dependencies and download PHP-JWT:
+
+```bash
+composer require firebase/php-jwt
+```
+
+Example
+-------
+```php
+<?php
+use \Firebase\JWT\JWT;
+
+$key = "example_key";
+$payload = array(
+    "iss" => "http://example.org",
+    "aud" => "http://example.com",
+    "iat" => 1356999524,
+    "nbf" => 1357000000
+);
+
+/**
+ * IMPORTANT:
+ * You must specify supported algorithms for your application. See
+ * https://tools.ietf.org/html/draft-ietf-jose-json-web-algorithms-40
+ * for a list of spec-compliant algorithms.
+ */
+$jwt = JWT::encode($payload, $key);
+$decoded = JWT::decode($jwt, $key, array('HS256'));
+
+print_r($decoded);
+
+/*
+ NOTE: This will now be an object instead of an associative array. To get
+ an associative array, you will need to cast it as such:
+*/
+
+$decoded_array = (array) $decoded;
+
+/**
+ * You can add a leeway to account for when there is a clock skew times between
+ * the signing and verifying servers. It is recommended that this leeway should
+ * not be bigger than a few minutes.
+ *
+ * Source: http://self-issued.info/docs/draft-ietf-oauth-json-web-token.html#nbfDef
+ */
+JWT::$leeway = 60; // $leeway in seconds
+$decoded = JWT::decode($jwt, $key, array('HS256'));
+
+?>
+```
+Example with RS256 (openssl)
+----------------------------
+```php
+<?php
+use \Firebase\JWT\JWT;
+
+$privateKey = <<<EOD
+-----BEGIN RSA PRIVATE KEY-----
+MIICXAIBAAKBgQC8kGa1pSjbSYZVebtTRBLxBz5H4i2p/llLCrEeQhta5kaQu/Rn
+vuER4W8oDH3+3iuIYW4VQAzyqFpwuzjkDI+17t5t0tyazyZ8JXw+KgXTxldMPEL9
+5+qVhgXvwtihXC1c5oGbRlEDvDF6Sa53rcFVsYJ4ehde/zUxo6UvS7UrBQIDAQAB
+AoGAb/MXV46XxCFRxNuB8LyAtmLDgi/xRnTAlMHjSACddwkyKem8//8eZtw9fzxz
+bWZ/1/doQOuHBGYZU8aDzzj59FZ78dyzNFoF91hbvZKkg+6wGyd/LrGVEB+Xre0J
+Nil0GReM2AHDNZUYRv+HYJPIOrB0CRczLQsgFJ8K6aAD6F0CQQDzbpjYdx10qgK1
+cP59UHiHjPZYC0loEsk7s+hUmT3QHerAQJMZWC11Qrn2N+ybwwNblDKv+s5qgMQ5
+5tNoQ9IfAkEAxkyffU6ythpg/H0Ixe1I2rd0GbF05biIzO/i77Det3n4YsJVlDck
+ZkcvY3SK2iRIL4c9yY6hlIhs+K9wXTtGWwJBAO9Dskl48mO7woPR9uD22jDpNSwe
+k90OMepTjzSvlhjbfuPN1IdhqvSJTDychRwn1kIJ7LQZgQ8fVz9OCFZ/6qMCQGOb
+qaGwHmUK6xzpUbbacnYrIM6nLSkXgOAwv7XXCojvY614ILTK3iXiLBOxPu5Eu13k
+eUz9sHyD6vkgZzjtxXECQAkp4Xerf5TGfQXGXhxIX52yH+N2LtujCdkQZjXAsGdm
+B2zNzvrlgRmgBrklMTrMYgm1NPcW+bRLGcwgW2PTvNM=
+-----END RSA PRIVATE KEY-----
+EOD;
+
+$publicKey = <<<EOD
+-----BEGIN PUBLIC KEY-----
+MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQC8kGa1pSjbSYZVebtTRBLxBz5H
+4i2p/llLCrEeQhta5kaQu/RnvuER4W8oDH3+3iuIYW4VQAzyqFpwuzjkDI+17t5t
+0tyazyZ8JXw+KgXTxldMPEL95+qVhgXvwtihXC1c5oGbRlEDvDF6Sa53rcFVsYJ4
+ehde/zUxo6UvS7UrBQIDAQAB
+-----END PUBLIC KEY-----
+EOD;
+
+$payload = array(
+    "iss" => "example.org",
+    "aud" => "example.com",
+    "iat" => 1356999524,
+    "nbf" => 1357000000
+);
+
+$jwt = JWT::encode($payload, $privateKey, 'RS256');
+echo "Encode:\n" . print_r($jwt, true) . "\n";
+
+$decoded = JWT::decode($jwt, $publicKey, array('RS256'));
+
+/*
+ NOTE: This will now be an object instead of an associative array. To get
+ an associative array, you will need to cast it as such:
+*/
+
+$decoded_array = (array) $decoded;
+echo "Decode:\n" . print_r($decoded_array, true) . "\n";
+?>
+```
+
+Changelog
+---------
+
+#### 5.0.0 / 2017-06-26
+- Support RS384 and RS512.
+  See [#117](https://github.com/firebase/php-jwt/pull/117). Thanks [@joostfaassen](https://github.com/joostfaassen)!
+- Add an example for RS256 openssl.
+  See [#125](https://github.com/firebase/php-jwt/pull/125). Thanks [@akeeman](https://github.com/akeeman)!
+- Detect invalid Base64 encoding in signature.
+  See [#162](https://github.com/firebase/php-jwt/pull/162). Thanks [@psignoret](https://github.com/psignoret)!
+- Update `JWT::verify` to handle OpenSSL errors.
+  See [#159](https://github.com/firebase/php-jwt/pull/159). Thanks [@bshaffer](https://github.com/bshaffer)!
+- Add `array` type hinting to `decode` method
+  See [#101](https://github.com/firebase/php-jwt/pull/101). Thanks [@hywak](https://github.com/hywak)!
+- Add all JSON error types.
+  See [#110](https://github.com/firebase/php-jwt/pull/110). Thanks [@gbalduzzi](https://github.com/gbalduzzi)!
+- Bugfix 'kid' not in given key list.
+  See [#129](https://github.com/firebase/php-jwt/pull/129). Thanks [@stampycode](https://github.com/stampycode)!
+- Miscellaneous cleanup, documentation and test fixes.
+  See [#107](https://github.com/firebase/php-jwt/pull/107), [#115](https://github.com/firebase/php-jwt/pull/115),
+  [#160](https://github.com/firebase/php-jwt/pull/160), [#161](https://github.com/firebase/php-jwt/pull/161), and
+  [#165](https://github.com/firebase/php-jwt/pull/165). Thanks [@akeeman](https://github.com/akeeman),
+  [@chinedufn](https://github.com/chinedufn), and [@bshaffer](https://github.com/bshaffer)!
+
+#### 4.0.0 / 2016-07-17
+- Add support for late static binding. See [#88](https://github.com/firebase/php-jwt/pull/88) for details. Thanks to [@chappy84](https://github.com/chappy84)!
+- Use static `$timestamp` instead of `time()` to improve unit testing. See [#93](https://github.com/firebase/php-jwt/pull/93) for details. Thanks to [@josephmcdermott](https://github.com/josephmcdermott)!
+- Fixes to exceptions classes. See [#81](https://github.com/firebase/php-jwt/pull/81) for details. Thanks to [@Maks3w](https://github.com/Maks3w)!
+- Fixes to PHPDoc. See [#76](https://github.com/firebase/php-jwt/pull/76) for details. Thanks to [@akeeman](https://github.com/akeeman)!
+
+#### 3.0.0 / 2015-07-22
+- Minimum PHP version updated from `5.2.0` to `5.3.0`.
+- Add `\Firebase\JWT` namespace. See
+[#59](https://github.com/firebase/php-jwt/pull/59) for details. Thanks to
+[@Dashron](https://github.com/Dashron)!
+- Require a non-empty key to decode and verify a JWT. See
+[#60](https://github.com/firebase/php-jwt/pull/60) for details. Thanks to
+[@sjones608](https://github.com/sjones608)!
+- Cleaner documentation blocks in the code. See
+[#62](https://github.com/firebase/php-jwt/pull/62) for details. Thanks to
+[@johanderuijter](https://github.com/johanderuijter)!
+
+#### 2.2.0 / 2015-06-22
+- Add support for adding custom, optional JWT headers to `JWT::encode()`. See
+[#53](https://github.com/firebase/php-jwt/pull/53/files) for details. Thanks to
+[@mcocaro](https://github.com/mcocaro)!
+
+#### 2.1.0 / 2015-05-20
+- Add support for adding a leeway to `JWT:decode()` that accounts for clock skew
+between signing and verifying entities. Thanks to [@lcabral](https://github.com/lcabral)!
+- Add support for passing an object implementing the `ArrayAccess` interface for
+`$keys` argument in `JWT::decode()`. Thanks to [@aztech-dev](https://github.com/aztech-dev)!
+
+#### 2.0.0 / 2015-04-01
+- **Note**: It is strongly recommended that you update to > v2.0.0 to address
+  known security vulnerabilities in prior versions when both symmetric and
+  asymmetric keys are used together.
+- Update signature for `JWT::decode(...)` to require an array of supported
+  algorithms to use when verifying token signatures.
+
+
+Tests
+-----
+Run the tests using phpunit:
+
+```bash
+$ pear install PHPUnit
+$ phpunit --configuration phpunit.xml.dist
+PHPUnit 3.7.10 by Sebastian Bergmann.
+.....
+Time: 0 seconds, Memory: 2.50Mb
+OK (5 tests, 5 assertions)
+```
+
+New Lines in private keys
+-----
+
+If your private key contains `\n` characters, be sure to wrap it in double quotes `""`
+and not single quotes `''` in order to properly interpret the escaped characters.
+
+License
+-------
+[3-Clause BSD](http://opensource.org/licenses/BSD-3-Clause).

vendor/firebase/php-jwt/composer.json

+{
+    "name": "firebase/php-jwt",
+    "description": "A simple library to encode and decode JSON Web Tokens (JWT) in PHP. Should conform to the current spec.",
+    "homepage": "https://github.com/firebase/php-jwt",
+    "keywords": [
+        "php",
+        "jwt"
+    ],
+    "authors": [
+        {
+            "name": "Neuman Vong",
+            "email": "neuman+pear@twilio.com",
+            "role": "Developer"
+        },
+        {
+            "name": "Anant Narayanan",
+            "email": "anant@php.net",
+            "role": "Developer"
+        }
+    ],
+    "license": "BSD-3-Clause",
+    "require": {
+        "php": ">=5.3.0"
+    },
+    "autoload": {
+        "psr-4": {
+            "Firebase\\JWT\\": "src"
+        }
+    },
+    "require-dev": {
+        "phpunit/phpunit": ">=4.8 <=9"
+    }
+}

vendor/firebase/php-jwt/src/BeforeValidException.php

+<?php
+namespace Firebase\JWT;
+
+class BeforeValidException extends \UnexpectedValueException
+{
+}

vendor/firebase/php-jwt/src/ExpiredException.php

+<?php
+namespace Firebase\JWT;
+
+class ExpiredException extends \UnexpectedValueException
+{
+}

vendor/firebase/php-jwt/src/JWK.php

+<?php
+
+namespace Firebase\JWT;
+
+use DomainException;
+use UnexpectedValueException;
+
+/**
+ * JSON Web Key implementation, based on this spec:
+ * https://tools.ietf.org/html/draft-ietf-jose-json-web-key-41
+ *
+ * PHP version 5
+ *
+ * @category Authentication
+ * @package  Authentication_JWT
+ * @author   Bui Sy Nguyen <nguyenbs@gmail.com>
+ * @license  http://opensource.org/licenses/BSD-3-Clause 3-clause BSD
+ * @link     https://github.com/firebase/php-jwt
+ */
+class JWK
+{
+    /**
+     * Parse a set of JWK keys
+     *
+     * @param array $jwks The JSON Web Key Set as an associative array
+     *
+     * @return array An associative array that represents the set of keys
+     *
+     * @throws InvalidArgumentException     Provided JWK Set is empty
+     * @throws UnexpectedValueException     Provided JWK Set was invalid
+     * @throws DomainException              OpenSSL failure
+     *
+     * @uses parseKey
+     */
+    public static function parseKeySet(array $jwks)
+    {
+        $keys = array();
+
+        if (!isset($jwks['keys'])) {
+            throw new UnexpectedValueException('"keys" member must exist in the JWK Set');
+        }
+        if (empty($jwks['keys'])) {
+            throw new InvalidArgumentException('JWK Set did not contain any keys');
+        }
+
+        foreach ($jwks['keys'] as $k => $v) {
+            $kid = isset($v['kid']) ? $v['kid'] : $k;
+            if ($key = self::parseKey($v)) {
+                $keys[$kid] = $key;
+            }
+        }
+
+        if (0 === \count($keys)) {
+            throw new UnexpectedValueException('No supported algorithms found in JWK Set');
+        }
+
+        return $keys;
+    }
+
+    /**
+     * Parse a JWK key
+     *
+     * @param array $jwk An individual JWK
+     *
+     * @return resource|array An associative array that represents the key
+     *
+     * @throws InvalidArgumentException     Provided JWK is empty
+     * @throws UnexpectedValueException     Provided JWK was invalid
+     * @throws DomainException              OpenSSL failure
+     *
+     * @uses createPemFromModulusAndExponent
+     */
+    private static function parseKey(array $jwk)
+    {
+        if (empty($jwk)) {
+            throw new InvalidArgumentException('JWK must not be empty');
+        }
+        if (!isset($jwk['kty'])) {
+            throw new UnexpectedValueException('JWK must contain a "kty" parameter');
+        }
+
+        switch ($jwk['kty']) {
+            case 'RSA':
+                if (\array_key_exists('d', $jwk)) {
+                    throw new UnexpectedValueException('RSA private keys are not supported');
+                }
+                if (!isset($jwk['n']) || !isset($jwk['e'])) {
+                    throw new UnexpectedValueException('RSA keys must contain values for both "n" and "e"');
+                }
+
+                $pem = self::createPemFromModulusAndExponent($jwk['n'], $jwk['e']);
+                $publicKey = \openssl_pkey_get_public($pem);
+                if (false === $publicKey) {
+                    throw new DomainException(
+                        'OpenSSL error: ' . \openssl_error_string()
+                    );
+                }
+                return $publicKey;
+            default:
+                // Currently only RSA is supported
+                break;
+        }
+    }
+
+    /**
+     * Create a public key represented in PEM format from RSA modulus and exponent information
+     *
+     * @param string $n The RSA modulus encoded in Base64
+     * @param string $e The RSA exponent encoded in Base64
+     *
+     * @return string The RSA public key represented in PEM format
+     *
+     * @uses encodeLength
+     */
+    private static function createPemFromModulusAndExponent($n, $e)
+    {
+        $modulus = JWT::urlsafeB64Decode($n);
+        $publicExponent = JWT::urlsafeB64Decode($e);
+
+        $components = array(
+            'modulus' => \pack('Ca*a*', 2, self::encodeLength(\strlen($modulus)), $modulus),
+            'publicExponent' => \pack('Ca*a*', 2, self::encodeLength(\strlen($publicExponent)), $publicExponent)
+        );
+
+        $rsaPublicKey = \pack(
+            'Ca*a*a*',
+            48,
+            self::encodeLength(\strlen($components['modulus']) + \strlen($components['publicExponent'])),
+            $components['modulus'],
+            $components['publicExponent']
+        );
+
+        // sequence(oid(1.2.840.113549.1.1.1), null)) = rsaEncryption.
+        $rsaOID = \pack('H*', '300d06092a864886f70d0101010500'); // hex version of MA0GCSqGSIb3DQEBAQUA
+        $rsaPublicKey = \chr(0) . $rsaPublicKey;
+        $rsaPublicKey = \chr(3) . self::encodeLength(\strlen($rsaPublicKey)) . $rsaPublicKey;
+
+        $rsaPublicKey = \pack(
+            'Ca*a*',
+            48,
+            self::encodeLength(\strlen($rsaOID . $rsaPublicKey)),
+            $rsaOID . $rsaPublicKey
+        );
+
+        $rsaPublicKey = "-----BEGIN PUBLIC KEY-----\r\n" .
+            \chunk_split(\base64_encode($rsaPublicKey), 64) .
+            '-----END PUBLIC KEY-----';
+
+        return $rsaPublicKey;
+    }
+
+    /**
+     * DER-encode the length
+     *
+     * DER supports lengths up to (2**8)**127, however, we'll only support lengths up to (2**8)**4.  See
+     * {@link http://itu.int/ITU-T/studygroups/com17/languages/X.690-0207.pdf#p=13 X.690 paragraph 8.1.3} for more information.
+     *
+     * @param int $length
+     * @return string
+     */
+    private static function encodeLength($length)
+    {
+        if ($length <= 0x7F) {
+            return \chr($length);
+        }
+
+        $temp = \ltrim(\pack('N', $length), \chr(0));
+
+        return \pack('Ca*', 0x80 | \strlen($temp), $temp);
+    }
+}

vendor/firebase/php-jwt/src/SignatureInvalidException.php

+<?php
+namespace Firebase\JWT;
+
+class SignatureInvalidException extends \UnexpectedValueException
+{
+}

wallet/controllers/AssetController.php

+<?php
+
+namespace wallet\controllers;
+
+use Yii;
+use yii\helpers\ArrayHelper;
+use wallet\base\BaseController;
+use common\models\psources\CoinPlatform;
+use common\models\psources\CoinCurrency;
+use common\models\psources\CoinSupportedCurrency;
+use common\service\trusteeship\TrusteeShipService;
+
+class AssetController extends BaseController
+{
+    public function actionIndex()
+    {
+        $current_platform_id = Yii::$app->request->getPlatformId();
+        if (1 === $current_platform_id) {
+            $platform_id = Yii::$app->request->get('platform_id', 1);
+            $platform_id = empty($platform_id) ? 1 : $platform_id;
+        } else {
+            $platform_id = Yii::$app->request->getPlatformId();
+        }
+        if (!isset(Yii::$app->params['trusteeship']['node_' . $platform_id])) {
+            return ['code' => -1, 'data' => [], 'msg' => '此钱包节点尚未开通'];
+        }
+        $node_params = Yii::$app->params['trusteeship']['node_' . $platform_id];
+
+        $uri = Yii::$app->request->post('uri', '');
+        $method = Yii::$app->request->post('method', 'GET');
+        $params = Yii::$app->request->post('params', '');
+
+        $time = time();
+        $appKey = isset($node_params['appKey']) ? $node_params['appKey'] : null;
+        $appSecret = isset($node_params['appSecret']) ? $node_params['appSecret'] : null;
+        $signature = self::getSign($params, $appKey, $appSecret, $time);
+
+        $headers = [
+            'FZM-Wallet-Signature' => $signature,
+            'FZM-Wallet-Timestamp' => $time,
+            'FZM-Wallet-AppKey' => $appKey,
+            'FZM-Wallet-AppIp' => Yii::$app->request->userIP
+        ];
+
+        $service = new TrusteeShipService($node_params, $headers);
+        $result = $service->handleAsset($uri, $method, $params);
+        if (200 !== $result['code']) {
+            return ['code' => $result['code'], 'data' => [], 'msg' => $result['msg']];
+        }
+        return ['code' => 1, 'data' => $result['msg'], 'msg' => 'success'];
+    }
+}
\ No newline at end of file

wallet/controllers/UserController.php

@@ -3,6 +3,7 @@
 namespace wallet\controllers;
 
 
+use Firebase\JWT\JWT;
 use Yii;
 use common\models\Admin;
 use common\models\LoginForm;
@@ -24,13 +25,32 @@ class UserController extends BaseController
         $model = new LoginForm();
         $model->setScenario(LoginForm::SCENARIOS_LOGIN);
         $model->load(Yii::$app->request->post(), '');
-        if (!$model->login()) {
+
+        $key = 'bwallet'; //key
+        $time = time(); //当前时间
+        if (!$user = $model->login()) {
             $msg = implode(", ", \yii\helpers\ArrayHelper::getColumn($model->errors, 0, false)); // Model's Errors string
             $data = null;
             $code = -1;
             goto doEnd;
         }
-        $data = ['access_token' => $model->login()];
+        $token = [
+            'iss' => 'https://www.bitfeel.cn', //签发者 可选
+            'aud' => 'https://www.bitfeel.cn', //接收该JWT的一方，可选
+            'iat' => time(), //签发时间
+            'nbf' => $time, //(Not Before)：某个时间点后才能访问，比如设置time+30，表示当前时间30秒后才能使用
+            'exp' => $time + 7200, //过期时间,这里设置2个小时
+            'user' => [ //自定义信息，不要定义敏感信息
+                'uid' => $user->uid,
+                'username' => $user->username,
+                'platform_id' => $user->platform_id,
+                'group' => $user->group
+            ]
+        ];
+
+        $access_token = JWT::encode($token, $key);
+
+        $data = ['access_token' => $access_token];
 
         doEnd :
         return ['code' => $code, 'msg' => $msg, 'data' => $data];
@@ -41,13 +61,13 @@ class UserController extends BaseController
         $msg = 'ok';
         $code = 0;
         $token_string = Yii::$app->request->headers->get('Token');
-        $user = Admin::findIdentityByAccessToken($token_string);
+        $user = Admin::verfication($token_string);
         $data = [
-            'username' => $user->username,
-            'uid' => isset($user->bind_uid) ? $user->bind_uid : $user->uid,
-            'type' => isset($user->bind_uid) ? 2 : 1,
-            'platform_id' => $user->platform_id,
-            'group' => $user->group
+            'username' => $user["data"]->username,
+            'uid' => isset($user["data"]->bind_uid) ? $user["data"]->bind_uid : $user["data"]->uid,
+            'type' => isset($user["data"]->bind_uid) ? 2 : 1,
+            'platform_id' => $user["data"]->platform_id,
+            'group' => $user["data"]->group
         ];
 
         return ['code' => $code, 'msg' => $msg, 'data' => $data];
@@ -127,23 +147,24 @@ class UserController extends BaseController
     public function actionUserList()
     {
         $current_platform_id = Yii::$app->request->getPlatformId();
-        if(1 === $current_platform_id) {
+        if (1 === $current_platform_id) {
             $platform_id = Yii::$app->request->get('platform_id', 1);
             $platform_id = empty($platform_id) ? 1 : $platform_id;
         } else {
             $platform_id = Yii::$app->request->getPlatformId();
         }
-        if(!isset(Yii::$app->params['trusteeship']['node_'. $platform_id])){
+        if (!isset(Yii::$app->params['trusteeship']['node_' . $platform_id])) {
             return ['code' => -1, 'data' => [], 'msg' => '此钱包节点尚未开通'];
         }
 
-        $node_params = Yii::$app->params['trusteeship']['node_'. $platform_id];
+        $node_params = Yii::$app->params['trusteeship']['node_' . $platform_id];
 
         $page = Yii::$app->request->get('page', 1);
         $size = Yii::$app->request->get('size', 15);
         $real_type = Yii::$app->request->get('real_type', '');
         $search_type = Yii::$app->request->get('search_type', 'user');
         $search = Yii::$app->request->get('search', '');
+        $excel = Yii::$app->request->get('excel', '');
         $start_time = Yii::$app->request->get('start_time', '');
         $end_time = Yii::$app->request->get('end_time', '');
         $params = [
@@ -152,6 +173,7 @@ class UserController extends BaseController
             'real_type' => $real_type,
             'search_type' => $search_type,
             'search' => $search,
+            'excel' => $excel,
             'start_time' => $start_time,
             'end_time' => $end_time
         ];
@@ -177,22 +199,22 @@ class UserController extends BaseController
     }
 
     /**
-     * 	人工实名全部列表
+     *    人工实名全部列表
      */
     public function actionManualList()
     {
         $current_platform_id = Yii::$app->request->getPlatformId();
-        if(1 === $current_platform_id) {
+        if (1 === $current_platform_id) {
             $platform_id = Yii::$app->request->get('platform_id', 1);
             $platform_id = empty($platform_id) ? 1 : $platform_id;
         } else {
             $platform_id = Yii::$app->request->getPlatformId();
         }
-        if(!isset(Yii::$app->params['trusteeship']['node_'. $platform_id])){
+        if (!isset(Yii::$app->params['trusteeship']['node_' . $platform_id])) {
             return ['code' => -1, 'data' => [], 'msg' => '此钱包节点尚未开通'];
         }
 
-        $node_params = Yii::$app->params['trusteeship']['node_'. $platform_id];
+        $node_params = Yii::$app->params['trusteeship']['node_' . $platform_id];
 
         $page = Yii::$app->request->get('page', 1);
         $size = Yii::$app->request->get('size', 15);
@@ -232,22 +254,22 @@ class UserController extends BaseController
     public function actionVerify()
     {
         $current_platform_id = Yii::$app->request->getPlatformId();
-        if(1 === $current_platform_id) {
+        if (1 === $current_platform_id) {
             $platform_id = Yii::$app->request->get('platform_id', 1);
             $platform_id = empty($platform_id) ? 1 : $platform_id;
         } else {
             $platform_id = Yii::$app->request->getPlatformId();
         }
-        if(!isset(Yii::$app->params['trusteeship']['node_'. $platform_id])){
+        if (!isset(Yii::$app->params['trusteeship']['node_' . $platform_id])) {
             return ['code' => -1, 'data' => [], 'msg' => '此钱包节点尚未开通'];
         }
 
-        $node_params = Yii::$app->params['trusteeship']['node_'. $platform_id];
+        $node_params = Yii::$app->params['trusteeship']['node_' . $platform_id];
 
         $post = Yii::$app->request->post();
         $uid = isset($post['uid']) ? $post['uid'] : null;
         $action = isset($post['action']) ? $post['action'] : null;
-        if(false == $uid || false == $action){
+        if (false == $uid || false == $action) {
             return ['code' => -1, 'data' => [], 'msg' => '参数错误'];
         }