Merge branch 'feature/airdrop' into develop

api/controllers/AirDropController.php

@@ -3,6 +3,8 @@
 namespace api\controllers;
 
 use api\base\BaseController;
+use common\models\psources\AirDrop;
+use common\models\psources\AirDropApplyRecord;
 use common\models\psources\CoinAirDropTrade;
 use common\service\chain33\Chain33Service;
 use Yii;
@@ -10,16 +12,139 @@ use Yii;
 
 class AirDropController extends BaseController
 {
+    public function actionApply()
+    {
+        if (Yii::$app->request->isPost) {
+            $data = Yii::$app->request->post();
+            $model = new AirDrop();
+            $model->setScenario(AirDrop::SCENARIOS_CREATE);
+            if ($model->load($data, '') && $model->save()) {
+                goto doEnd;
+            }
+            $this->code = -1;
+            $this->msg = $model->errors;
+            if (empty($this->msg)) {
+                $this->msg = 'Validation failed.';
+            }
+            goto doEnd;
+        }
+
+        if (Yii::$app->request->isGet) {
+            $page = \Yii::$app->request->get('page', 1);
+            $size = \Yii::$app->request->get('size', 10);
+
+            $data = Yii::$app->request->get();
+            $identifier = $data['identifier'] ?? '';
+            $miner_address = $data['miner_address'] ?? '';
+            if (false == $identifier || false == $miner_address) {
+                $this->code = -1;
+                $this->msg = 'Validation failed.';
+                goto doEnd;
+            }
+            $model = AirDrop::find()->select('id')->where(['identifier' => $identifier, 'miner_address' => $miner_address])->one();
+            $total = 0;
+            $items = [];
+            if (empty($model) || empty($model->record)) {
+                goto doEnd;
+            }
+
+            $query = AirDropApplyRecord::find()
+                ->select('id, reach, bonus_token, draw_status, create_time')
+                ->where(['apply_id' => $model['id']]);
+
+            $items = $query->offset(($page - 1) * $size)->orderBy('id desc')->limit($size)->all();
+            $countQuery = clone $query;
+            $total = (int)$countQuery->count();
+
+            $this->data = [
+                'items' => $items,
+                'total' => $total
+            ];
+        }
+
+        if (Yii::$app->request->isPut) {
+            $data = Yii::$app->request->post();
+            $id = $data['id'] ?? '';
+            $identifier = $data['identifier'] ?? '';
+            $miner_address = $data['miner_address'] ?? '';
+            if (false == $id || false == $identifier || false == $miner_address) {
+                $this->code = -1;
+                $this->msg = 'Validation failed.';
+                goto doEnd;
+            }
+            $model = AirDrop::find()->select('id')->where(['identifier' => $identifier, 'miner_address' => $miner_address])->one();
+
+            if (empty($model) || empty($model->record)) {
+                $this->code = -1;
+                $this->msg = '暂无符合条件的空投申请记录';
+                goto doEnd;
+            }
+
+            $record = AirDropApplyRecord::find()->where(['id' => $id, 'reach' => AirDropApplyRecord::REACH_YES, 'draw_status' => AirDropApplyRecord::STATUS_UNDRAW])->one();
+            if (empty($record)) {
+                $this->code = -1;
+                $this->msg = '暂无符合条件的领取记录';
+                goto doEnd;
+            }
+
+            $record->draw_status = AirDropApplyRecord::STATUS_DRAWING;
+            if (false == $record->save()) {
+                $this->code = -1;
+                $this->msg = $record->errors;
+                goto doEnd;
+            }
+        }
+
+        doEnd :
+        return ['code' => $this->code, 'msg' => $this->msg, 'data' => $this->data];
+    }
+
+    public function actionDraw()
+    {
+        if (Yii::$app->request->isPost) {
+            $data = Yii::$app->request->post();
+            $identifier = $data['identifier'] ?? '';
+            $miner_address = $data['miner_address'] ?? '';
+            if (false == $identifier || false == $miner_address) {
+                $this->code = -1;
+                $this->msg = 'Validation failed.';
+                goto doEnd;
+            }
+            $model = AirDrop::find()->select('id')->where(['identifier' => $identifier, 'miner_address' => $miner_address])->one();
+
+            if (empty($model) || empty($model->record)) {
+                $this->code = -1;
+                $this->msg = '暂无符合条件的空投申请记录';
+                goto doEnd;
+            }
+
+            $record = AirDropApplyRecord::find()->where(['apply_id' => $model['id'], 'reach' => AirDropApplyRecord::REACH_YES, 'draw_status' => AirDropApplyRecord::STATUS_UNDRAW])->all();
+            if (empty($record)) {
+                $this->code = -1;
+                $this->msg = '暂无符合条件的领取记录';
+                goto doEnd;
+            }
+            foreach ($record as $val) {
+                $val->draw_status = AirDropApplyRecord::STATUS_DRAWING;
+                $val->save();
+            }
+        }
+
+        doEnd :
+        return ['code' => $this->code, 'msg' => $this->msg, 'data' => $this->data];
+    }
+
+
     public function actionGameTrade()
     {
         $coins_address = Yii::$app->request->post('coins_address', '');
 
-        if(empty($coins_address)){
+        if (empty($coins_address)) {
             return ['code' => -1, 'msg' => '参数不能为空'];
         }
 
         $coinTokenTransfer = CoinAirDropTrade::find()->where(['coins_address' => $coins_address, 'type' => CoinAirDropTrade::TYPE_GAME])->one();
-        if($coinTokenTransfer){
+        if ($coinTokenTransfer) {
             return ['code' => -1, 'data' => null, 'msg' => 'record already exists'];
         }
 
@@ -29,8 +154,8 @@ class AirDropController extends BaseController
         $note = '';
 
         $service = new Chain33Service();
-        $createRawTransaction  = $service->createRawTransaction($coins_address, $amount, $fee, $note, $execer);
-        if(0 != $createRawTransaction['code']){
+        $createRawTransaction = $service->createRawTransaction($coins_address, $amount, $fee, $note, $execer);
+        if (0 != $createRawTransaction['code']) {
             $msg = $createRawTransaction['msg'];
             $code = -1;
             goto doEnd;
@@ -41,7 +166,7 @@ class AirDropController extends BaseController
         $expire = '1m';
 
         $signRawTx = $service->signRawTx($privkey, $txHex, $expire);
-        if(0 != $signRawTx['code']){
+        if (0 != $signRawTx['code']) {
             $msg = $signRawTx['msg'];
             $code = -1;
             goto doEnd;
@@ -49,7 +174,7 @@ class AirDropController extends BaseController
         $sign_str = $signRawTx['result'];
         $result = $service->sendTransaction($sign_str);
 
-        if(0 != $result['code']){
+        if (0 != $result['code']) {
             $msg = $result['msg'];
             $code = -1;
             goto doEnd;
@@ -72,16 +197,16 @@ class AirDropController extends BaseController
 
     public function actionGameTradeUpdate()
     {
-        $coinAirDropTrade = CoinAirDropTrade::find()->where(['attach' => 2 ,'msg' => '0'])->limit(30)->all();
-        foreach ($coinAirDropTrade as $val){
+        $coinAirDropTrade = CoinAirDropTrade::find()->where(['attach' => 2, 'msg' => '0'])->limit(30)->all();
+        foreach ($coinAirDropTrade as $val) {
             $fee = 100000;
             $amount = 1 * 1e8;
             $execer = 'coins';
             $note = '';
 
             $service = new Chain33Service();
-            $createRawTransaction  = $service->createRawTransaction($val->coins_address, $amount, $fee, $note, $execer);
-            if(0 != $createRawTransaction['code']){
+            $createRawTransaction = $service->createRawTransaction($val->coins_address, $amount, $fee, $note, $execer);
+            if (0 != $createRawTransaction['code']) {
                 continue;
             }
 
@@ -90,13 +215,13 @@ class AirDropController extends BaseController
             $expire = '1m';
 
             $signRawTx = $service->signRawTx($privkey, $txHex, $expire);
-            if(0 != $signRawTx['code']){
+            if (0 != $signRawTx['code']) {
                 continue;
             }
             $sign_str = $signRawTx['result'];
             $result = $service->sendTransaction($sign_str);
 
-            if(0 != $result['code']){
+            if (0 != $result['code']) {
                 continue;
             }
             $currentModel = CoinAirDropTrade::findOne($val->id);
@@ -112,17 +237,17 @@ class AirDropController extends BaseController
     {
         $coinAirDropTrade = CoinAirDropTrade::find()->where(['balance' => 0])->limit(60)->all();
         $address = [];
-        foreach ($coinAirDropTrade as $val){
+        foreach ($coinAirDropTrade as $val) {
             $address[] = $val->coins_address;
         }
         $service = new Chain33Service();
         $execer = 'coins';
-        $result  = $service->getBalance($address, $execer);
-        if(0 == $result['code']){
+        $result = $service->getBalance($address, $execer);
+        if (0 == $result['code']) {
             $result_balance = $result['result'];
-            foreach ($result_balance as $val){
+            foreach ($result_balance as $val) {
                 $coinAirDropTrade = CoinAirDropTrade::find()->where(['coins_address' => $val['addr']])->one();
-                if(empty($coinAirDropTrade)) continue;
+                if (empty($coinAirDropTrade)) continue;
                 $coinAirDropTrade->balance = $val['balance'];
                 $coinAirDropTrade->save();
             }

common/business/ExchangeBusiness.php

@@ -26,21 +26,21 @@ class ExchangeBusiness
      * @var array
      */
     private static $exchanges = [
-        0 => 'Bty',
-        1 => 'HuoBi',
-        2 => 'Hadax',
-        3 => 'Bitfinex',
-        4 => 'Bittrex',
-        5 => 'Zb',
-        6 => 'Token7',
-        7 => 'Zg',
-        8 => 'Go',
-        9 => 'Zhaobi',
-        10 => 'Ex',
-        11 => 'Zt',
-        12 => 'Tsc',
-        13 => 'Binance',
-        14 => 'Bilaxy',
+//        0 => 'Bty',
+//        1 => 'HuoBi',
+//        2 => 'Hadax',
+//        3 => 'Bitfinex',
+//        4 => 'Bittrex',
+//        5 => 'Zb',
+//        6 => 'Token7',
+//        7 => 'Zg',
+//        8 => 'Go',
+//        9 => 'Zhaobi',
+//        10 => 'Ex',
+//        11 => 'Zt',
+//        12 => 'Tsc',
+//        13 => 'Binance',
+//        14 => 'Bilaxy',
         15 => 'Bitnasdaq',
         16 => 'Dag',
         17 => 'Coinka',

common/models/psources/AirDrop.php

+<?php
+
+namespace common\models\psources;
+
+use Yii;
+use yii\db\Expression;
+
+class AirDrop extends CommonActiveRecord
+{
+    //定义场景
+    const SCENARIOS_CREATE = 'create';
+    const SCENARIOS_UPDATE = 'update';
+
+    public static function getDb()
+    {
+        return Yii::$app->get('p_sources');
+    }
+
+    public static function tableName()
+    {
+        return '{{%wallet_airdrop_apply}}';
+    }
+
+    public function rules()
+    {
+        return [
+            [['identifier', 'wallet_address', 'miner_address'], 'required'],
+            [['reach_times'], 'integer'],
+            [['identifier'], 'string', 'length' => [5, 50]],
+            [['wallet_address', 'miner_address'], 'string', 'length' => [10, 50]],
+        ];
+    }
+
+    public function scenarios()
+    {
+        $scenarios = [
+            self:: SCENARIOS_CREATE => ['identifier', 'miner_address'],
+            self:: SCENARIOS_UPDATE => ['wallet_address'],
+        ];
+        return array_merge(parent:: scenarios(), $scenarios);
+    }
+
+    public function attributeLabels()
+    {
+        return [
+            'identifier' => '树莓派编号',
+            'wallet_address' => '矿主地址',
+            'miner_address' => '矿工地址',
+            'reach_times' => '达标次数',
+            'create_time' => '开始时间',
+            'finish_time' => '结束时间'
+        ];
+    }
+
+    public function getRecord()
+    {
+        return $this->hasMany(AirDropApplyRecord::className(), ['apply_id' => 'id'])->all();
+    }
+}
\ No newline at end of file

common/models/psources/AirDropApplyRecord.php

+<?php
+
+namespace common\models\psources;
+
+use Yii;
+use yii\db\Expression;
+
+class AirDropApplyRecord extends CommonActiveRecord
+{
+    const REACH_NO = 0;    //未达标
+    const REACH_YES = 1;    //已达标
+
+    const STATUS_UNDRAW = 0;    //未领取
+    const STATUS_DRAWING = 1;    // 领取中
+    const STATUS_DRAW_SUEEESS = 2;    //领取成功
+    const STATUS_DRAW_FAIL = 3;    // 领取失败
+
+    //定义场景
+    const SCENARIOS_CREATE = 'create';
+    const SCENARIOS_UPDATE = 'update';
+
+    public static function getDb()
+    {
+        return Yii::$app->get('p_sources');
+    }
+
+    public static function tableName()
+    {
+        return '{{%wallet_airdrop_apply_record}}';
+    }
+
+    public function rules()
+    {
+        return [
+
+        ];
+    }
+
+    public function scenarios()
+    {
+        $scenarios = [
+
+        ];
+        return array_merge(parent:: scenarios(), $scenarios);
+    }
+
+    public function attributeLabels()
+    {
+        return [
+            'apply_id' => '申请ID',
+            'reach' => '达标情况',
+            'bonus_token' => '奖励单位',
+            'draw_status' => '领取情况',
+            'create_time' => '创建时间',
+            'finish_time' => '更新时间'
+        ];
+    }
+}
\ No newline at end of file

console/controllers/AirDropController.php

@@ -2,6 +2,7 @@
 
 namespace console\controllers;
 
+use common\models\psources\AirDrop;
 use Yii;
 use yii\console\Controller;
 use common\service\chain33\Chain33Service;
@@ -9,6 +10,31 @@ use common\models\psources\CoinAirDropTransfer;
 
 class AirDropController extends Controller
 {
+    public function actionMinerSourceList()
+    {
+        $model = AirDrop::find()->where(['wallet_address' => ''])->asArray()->all();
+        if (empty($model)) {
+            return 0;
+        }
+        $service = new Chain33Service();
+        foreach ($model as $key => $val) {
+            $playload = [
+                'data' => $val['miner_address']
+            ];
+            $result = $service->chainQuery('ticket', 'MinerSourceList', $playload);
+            if (0 != $result['code']) {
+                continue;
+            }
+            $wallet_address = isset($result['result']['datas'][0]) ? $result['result']['datas'][0] : '';
+            if (empty($wallet_address)) {
+                continue;
+            }
+            $current_model = AirDrop::findOne($val['id']);
+            $current_model->wallet_address = $wallet_address;
+            $current_model->save();
+        }
+    }
+
     /**
      * 获取游戏状态
      *