kuake/extend/logicmodel/award/Recommend.php

<?php


namespace logicmodel\award;


use datamodel\AwardRecommend;
use datamodel\AwardRecord;
use datamodel\Conf;
use datamodel\Goods;
use datamodel\GoodsHash;
use datamodel\Users;
use datamodel\UsersBox;
use datamodel\UsersGoods;
use logicmodel\AccountLogic;
use logicmodel\ChainLogic;
use think\Log;

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->where('total_direct','>',0)->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('id','>',Conf::getValue('award_goods_clear_time','206139'))
                ->count();
            if($count < $recommend['total_direct']) {
                continue;
            }
            $type = $recommend['type'];
            if($type == 1){
                $recommend_award = $recommend['recommend_award'];//推荐奖励
                if($recommend_award > 0){
                    $hasSend=AwardRecord::where('uid',$uid)->where('from_uid',$from_uid)->value('id');
                    if($hasSend){
                        continue;
                    }
                    $recommendData->where(['id'=>$recommend['id']])->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){
                    $hasSend=AwardRecord::where('uid',$uid)->where('goods_id',$recommend['goods_id'])->value('id');
                    if($hasSend){
                        continue;
                    }
                    $goods =  Goods::where(['id'=>$recommend['goods_id']])->find();
                    if($goods){
                        $recommendData->where(['id'=>$recommend['id']])->setDec('stock',1);
                        #todo:HASH
                        $hash=GoodsHash::zero()->queryGoods($goods['id'])->lock(true)->find();
                        $usersGoods = [
                            'uid'=>$uid,
                            'goods_id'=>$goods['id'],
                            'price'=>$goods['price'],
                            'create_time'=>date('Y-m-d H:i:s'),
                            'token_id'=>$hash['token_id']??null,
                        ];
                        $hash && $hash->setOrder(-2);
                        ChainLogic::instance()->buy($hash,Users::get($uid));
                        $result = (new UsersGoods())->insertGetId($usersGoods);
                        if($result){
                            $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){
                    $hasSend=AwardRecord::where('uid',$uid)->where('box_id',$recommend['box_id'])->value('id');
                    if($hasSend){
                        continue;
                    }
                    $box =  Goods::where(['id'=>$recommend['box_id']])->find();
                    if($box){
                        $recommendData->where(['id'=>$recommend['id']])->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;

    }
}