kuake/extend/logicmodel/award/Recommend.php

<?php


namespace logicmodel\award;


use datamodel\AwardRecommend;
use datamodel\Conf;
use datamodel\Goods;
use datamodel\UsersBox;
use datamodel\UsersGoods;
use logicmodel\AccountLogic;

class Recommend extends Award
{
    private $award_id;
    public function __construct()
    {
        parent::__construct();
        $this->award_id  = 1;
    }

    /**
     *推荐奖励
     * @param $uid
     * @param $from_uid
     * @return bool
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function award($uid,$from_uid){
       $awardInfo =  $this->awardIsOpen($this->award_id);
        if($awardInfo === false) return false;
        $recommendData = new AwardRecommend();
        $recommends =  $recommendData->select();
        foreach ($recommends as $recommend){
            $register_award = $recommend['register_award'];
            if($register_award >0){
                (new AccountLogic())->addAccount($uid, 2, $register_award, '实名认证奖励', '认证奖励');
            }
            if($recommend['stock'] <= 0) {
                continue;
            }
            $count = $this->usersData->where(['is_auth'=>1,'pid'=>$uid,'is_del'=>0])->where('create_time','>=',Conf::getValue('award_goods_clear_time','0000-00-00'))->count();
            if($count != $recommend['total_direct']) {
                continue;
            }
            $type = $recommend['type'];
            if($type == 1){
                $recommend_award = $recommend['recommend_award'];//推荐奖励
                if($recommend_award > 0){
                    $recommendData->where(['id'=>1])->setDec('stock',1);
                    $this->record($uid,2,$recommend_award,$from_uid,$this->award_id,$awardInfo['name'],'推荐奖励',$awardInfo['field'],0,0,1);
                }
            }elseif ($type == 2){
                //生成一个藏品
                if($recommend['goods_id'] > 0){
                    $goods =  Goods::where(['id'=>$recommend['goods_id']])->find();
                    if($goods){
                        $recommendData->where(['id'=>1])->setDec('stock',1);
                        $usersGoods = ['uid'=>$uid,'goods_id'=>$goods['id'],'price'=>$goods['price'],'create_time'=>date('Y-m-d H:i:s')];
                        $result = (new UsersGoods())->insertGetId($usersGoods);
                        if($result){
                            UsersGoods::get($result)->addHash($goods->hash()->zero()->find());
                            $this->record($uid,2,0,$from_uid,$this->award_id,$awardInfo['name'],'推荐奖励',$awardInfo['field'],$recommend['goods_id'],0,2);
                        }
                    }

                }

            }elseif ($type == 3){
                if($recommend['box_id'] > 0){
                    $box =  Goods::where(['id'=>$recommend['box_id']])->find();
                    if($box){
                        $recommendData->where(['id'=>1])->setDec('stock',1);
                        $usersBox = ['uid'=>$uid,'box_id'=>$recommend['box_id'],'price'=>$box['price'],'create_time'=>date('Y-m-d H:i:s')];
                        $result =  (new UsersBox())->insertGetId($usersBox);
                        if($result){
                            $this->record($uid,2,0,$from_uid,$this->award_id,$awardInfo['name'],'推荐奖励',$awardInfo['field'],0,$recommend['box_id'],3);
                        }
                    }
                }
            }
        }
        return false;

    }
}