账单

api/controllers/BillController.php

+<?php
+/**
+ * Created by PhpStorm.
+ * User: rlgyzhcn
+ * Date: 18-7-30
+ * Time: 下午3:09
+ */
+
+namespace api\controllers;
+
+use common\models\pwallet\Bill;
+use Yii;
+use api\base\BaseController;
+use api\job\BillJob;
+
+class BillController extends BaseController
+{
+    /**
+     * 插入交易记录
+     */
+    public function actionInsert()
+    {
+        $post  = Yii::$app->request->post();
+        $model = new Bill();
+        if ($model->load($post) && $model->validate()) {
+            $model->status = 0;
+            if ($model->save(false)) {
+                //加入队列
+                Yii::$app->queue->push(new BillJob(['id' => $model->id, 'txid' => $model->txid, 'chain' => $model->chain, 'from' => $model->from]));
+                return ['code' => 0, 'message' => 'succeed'];
+            }
+        } else {
+            return ['code' => -1, 'message' => '数据验证失败'];
+        }
+    }
+}
\ No newline at end of file

api/job/BillJob.php

+<?php
+/**
+ * Created by PhpStorm.
+ * User: rlgyzhcn
+ * Date: 18-7-30
+ * Time: 下午3:12
+ */
+
+namespace api\job;
+
+use yii\base\BaseObject;
+use yii\queue\JobInterface;
+use yii\queue\Queue;
+
+/**
+ * Class BillJob
+ *
+ * 处理账单队列数据
+ * @package api\job
+ */
+class BillJob extends BaseObject implements JobInterface
+{
+    public $id;
+    public $chain;
+    public $txid;
+    public $from;
+
+    /**
+     * @param Queue $queue which pushed and is handling the job
+     * @return integer
+     */
+    public function execute($queue)
+    {
+        //todo 查询交易状态, 更改状态
+
+        return 0;
+    }
+
+}
\ No newline at end of file

common/config/main-local.php

@@ -42,6 +42,18 @@ return [
             'port'     => 6379,
             'database' => 1,
         ],
+        'redis-queue' => [
+            'class'    => 'yii\redis\Connection',
+            'hostname' => 'localhost',
+            'password' => 'jlm123456',
+            'port'     => 6379,
+            'database' => 2,
+        ],
+        'queue'       => [
+            'class'   => \yii\queue\redis\Queue::class,
+            'redis'   => 'redis-queue', // Redis connection component or its config
+            'channel' => 'queue', // Queue channel key
+        ],
         'uploader'    => [
             'class'    => 'common\components\uploader\Uploader',
             'baseuri'  => 'http://127.0.0.1:8082/admin/upload',

common/config/main.php

@@ -80,6 +80,17 @@ return [
             'port'     => 6379,
             'database' => 1,
         ],
+        'redis-queue'  => [
+            'class'    => 'yii\redis\Connection',
+            'hostname' => 'localhost',
+            'port'     => 6379,
+            'database' => 2,
+        ],
+        'queue'        => [
+            'class'   => \yii\queue\redis\Queue::class,
+            'redis'   => 'redis-queue', // Redis connection component or its config
+            'channel' => 'queue', // Queue channel key
+        ],
         'i18n'         => [
             'translations' => [
                 '*' => [

common/models/pwallet/Bill.php

+<?php
+/**
+ * Created by PhpStorm.
+ * User: rlgyzhcn
+ * Date: 18-8-1
+ * Time: 下午5:13
+ */
+
+namespace common\models\pwallet;
+
+use Yii;
+use common\core\BaseActiveRecord;
+
+
+class Bill extends BaseActiveRecord
+{
+    /**
+     * @return null|object|\yii\db\Connection
+     * @throws \yii\base\InvalidConfigException
+     */
+    public static function getDb()
+    {
+        return Yii::$app->get('db_pwallet');
+    }
+
+    public function formName()
+    {
+        return '';
+    }
+
+    public function attributeLabels()
+    {
+        return [
+            'id'        => 'ID',
+            'txid'      => 'HashId',
+            'chain'     => '主链',
+            'coinname'  => '币种',
+            'from'      => '转出地址',
+            'to'        => '转入地址',
+            'value'     => '金额',
+            'fee'       => '矿工费',
+            'status'    => '状态',
+            'type'      => '交易类型',
+            'height'    => '区块高度',
+            'note'      => '备注',
+            'blocktime' => '更新时间'
+        ];
+    }
+
+    public function rules()
+    {
+        return [
+            [['txid', 'chain', 'coinname', 'from', 'to', 'value', 'fee', 'type'], 'required', 'message' => '{attribute} 不能为空'],
+            [['txid', 'from', 'to', 'note'], 'string', 'max' => 255],
+            [['chain', 'coinname'], 'string', 'max' => 32],
+            [['value', 'fee'], 'double'],
+            [['status', 'type'], 'number', 'max' => 2],
+        ];
+    }
+}
\ No newline at end of file

composer.json

@@ -19,7 +19,8 @@
     "kartik-v/yii2-field-range": "*",
     "kartik-v/yii2-date-range": "*",
     "kartik-v/yii2-widget-fileinput": "*",
-    "yiisoft/yii2-redis": "~2.0.0"
+    "yiisoft/yii2-redis": "~2.0.0",
+    "yiisoft/yii2-queue": "~2.0"
   },
   "require-dev": {
     "yiisoft/yii2-debug": "~2.0.0",

console/config/main.php

@@ -9,7 +9,10 @@ $params = array_merge(
 return [
     'id'                  => 'app-console',
     'basePath'            => dirname(__DIR__),
-    'bootstrap'           => ['log'],
+    'bootstrap'           => [
+        'log',
+        'queue'
+    ],
     'controllerNamespace' => 'console\controllers',
     'aliases'             => [
         '@bower' => '@vendor/bower-asset',