RWACha-API/application/api/controller/Airdrop.php

<?php

namespace app\api\controller;

use app\common\model\UserAirdrop;
use think\Exception;
use app\api\logic\WelfareLoginc;
use app\common\model\UserModel;
use app\common\controller\Api;
use app\common\model\UserWelfare;
use think\Db;
use app\common\model\LedgerWalletModel;
use app\common\model\ProductOrder;
//空投
class Airdrop extends Api
{

    protected array $noNeedLogin = [''];
    protected string $lan = '';

    public function _initialize()
    {
        parent::_initialize();
        $this->lan = $this->request->getLan();
    }

    //获取领取福利信息
    public function getNewbieWeal(UserWelfare $userWelfare, ProductOrder $productOrder)
    {
        $info    = $productOrder::getUserWelfare($this->auth->id, $productOrder::Newbie);
        $endTime = isset($info->create_time)? bcadd($info->create_time, 86400): 0;

        $rows    = $userWelfare::getIsWelfare();
        $this->success('', ['is_super'=>$this->auth->is_super, 'end_time'=>$endTime, 'chabao'=>$rows->frozen]);
    }


    //新人福利
    public function setNewbieWeal(UserWelfare $userWelfare, ProductOrder $productOrder, UserModel $userModel)
    {
        $row = $userWelfare::getIsWelfare();
        if(empty($row->is_newbie)) $this->error(__('暂未开启'));
      
        $info = $productOrder::getUserWelfare($this->auth->id, $productOrder::Newbie);
        if(!empty($info)) $this->error(__('您已领取'));
        Db::startTrans();
        try {
            //添加Rwa茶记录
            $result = WelfareLoginc::setUserWelfareLos($this->auth->id, $row->new_product_id, $row->new_num, time(), $this->lan, $productOrder::Newbie);

            //添加茶数量
            if($result['price'] > config('min_rwa_price')) $userModel::updateForRwaNum($this->auth->id, $this->auth->parent_id, $row->new_num, '+');
            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        $this->success('', $result);
    }



    //超级福利
    public function setSuperWeal(UserWelfare $userWelfare, UserModel $userModel, ProductOrder $productOrder)
    {
        $row = $userWelfare::getIsWelfare();
        if(empty($row->is_super)) $this->error(__('暂未开启'));
        if(!empty($this->auth->is_super)) $this->error(__('您已领取'));

        //判断距离领取新人福利是否超过一天
        $info = $productOrder::getUserWelfare($this->auth->id, $productOrder::Newbie);
        if((time()-$info->create_time) >= 86400) $this->error(__('您已过期'));
        Db::startTrans();
        try {
            //把9.9茶宝转入冻结账号
            if($row->frozen > 0) (new LedgerWalletModel)->sendUserSubFrozen($this->auth->id, $row->frozen, LedgerWalletModel::Super, '-');

            //添加Rwa茶记录
            $result = WelfareLoginc::setUserWelfareLos($this->auth->id, $row->super_product_id, $row->super_num, time(), $this->lan, $productOrder::Super);

            //添加超级福利标识/上级
            $userModel::updateUserSuper($this->auth->id, $this->auth->parent_id);

            //添加茶数量
            if($result['price'] > config('min_rwa_price')) $userModel::updateForRwaNum($this->auth->id, $this->auth->parent_id, $row->super_num, '+');

            //插入待空投记录
            $rs = UserAirdrop::insert([
                'user_id'       =>  $this->auth->id,
                'type_id'       =>  UserAirdrop::typeSuperWeal,
                'product_id'    =>  $row->super_product_id,
                'num'           =>  $row->super_num,
                'address'       =>  $this->auth->address,
                'remark'        =>  '超级福利空投',
                'create_time'   =>time(),
                'status'        =>UserAirdrop::NORMAL,//为0 待发放层级奖励
            ]);

            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        $this->success('', $result);
    }


}