tp3_activity/Application/Home/Logic/Activityv2/RecylingLogic.class.php

<?php
/**
 * 佩奇拼图活动(由萌鸡快跑活动改写)
 * @author   xusong
 * @version  0.0.1
 * @datetime 2019.07.25
 */
namespace Home\Logic\Activityv2;

class RecylingLogic extends BaseLogic
{   

    private $act_id;
    private $uid;
    private $userinfo;
    private $activityinfo;
    private $vip_level;


    /**
     * [_initialize 前置操作-继承公共前置方法]
     * @author   Devil
     * @blog     http://gong.gg/
     * @version  0.0.1
     * @datetime 2016-12-03T12:39:08+0800
     */
    public function _initialize() {
        // 调用父类前置方法
        parent::_initialize();
        $this->uid = trim(I('uid'));
        
        if(!$this->userinfo = M('iptv_users')->where(['uid'=>$this->uid])->find()){
            $this->responseError('uid 参数非法');
        }
        
        $this->act_id = (int)I('act_id');
        if(!$this->activityinfo = M('Activity_v2')->where(['id'=>$this->act_id])->find()){
            $this->responseError('act_id 参数非法');
        }
        //检查vip鉴权方式
        $this->vip_level = I('is_vip') >= 1 ? 1 : 0;
    }

    /**
     * 获取活动状态
     * @return [type] [description]
     */
    public function getActStatus()
    {   
        //开始时间结束时间未作限制
        if($this->activityinfo['is_enable'] == 1){
            $this->responseSuccess(1, "请求成功!");
        }else{
            $this->responseSuccess(-1, "请求成功!");
        }
    }
    
    /**
     * 提交用户资料
     * @return [type] [description]
     */
    public function setUserInfo()
    {       
        $phone  = trim(I('phone'));
        if (empty($phone)) {
            $this->responseError('参数错误!');
        }
        //检测手机号码是否正确
        if (!preg_match('/^1[345789]\d{9}$/ims', $phone)) {
            $this->responseError('手机号填写有误!');
        }
        //更新用户活动手机号码
        $where = array(
            'uid'=>$this->uid,
            'act_id'=>$this->act_id,
        );
        if ($id = M('activity_user_v2')->where($where)->getField('id')){
            $update['user_phone']= $phone;
            $update['updated_at']= date('Y-m-d H:i:s');
            if(M('activity_user_v2')->where(['id'=>$id])->save($update)===false){
                Writelog(M()->getLastSql(),'sql','prize');
                $this->responseError("更新失败!");
            }
        }else{
            $insert_data = array(
                'uid'=>$this->uid,
                'act_id'=>$this->act_id,
                'user_phone'=>$phone,
                'created_at'=>date('Y-m-d H:i:s'),
                'updated_at'=>date('Y-m-d H:i:s')
            );
            if(!M('activity_user_v2')->add($insert_data)){
                Writelog(M()->getLastSql(),'sql','prize');
                $this->responseError("登记失败!");                
            }
        }
        $this->responseSuccess(0, "登记成功!");
    }
    
    /**
     * 提交用户资料
     * @return [type] [description]
     */
    public function setUserInfoByphone()
    {
        $phone  = trim(I('phone'));
        $address  = trim(I('address'));
        $receiver  = trim(I('receiver'));
        if (!($phone && $address && $receiver)) {
            $this->responseError('参数错误!');
        }
        //检测手机号码是否正确
        if (!preg_match('/^1[345789]\d{9}$/ims', $phone)) {
            $this->responseError('手机号填写有误!');
        }
        //更新用户活动手机号码
        $where = array(
            'uid'=>$this->uid,
            'act_id'=>$this->act_id,
        );
        if ($id = M('activity_user_v2')->where($where)->getField('id')){
            $update['user_phone']= $phone;
            $update['address'] = $address;
            $update['receiver'] = $receiver;
            $update['updated_at'] = date('Y-m-d H:i:s');            
            if(M('activity_user_v2')->where(['id'=>$id])->save($update)===false){
                Writelog(M()->getLastSql(),'sql','prize');
                $this->responseError("更新失败!");
            }
        }else{
            $insert_data = array(
                'uid'=>$this->uid,
                'act_id'=>$this->act_id,
                'user_phone'=>$phone,
                'address'=>$address,
                'receiver'=>$receiver,
                'created_at'=>date('Y-m-d H:i:s'),
                'updated_at'=>date('Y-m-d H:i:s'),
            );
            if(!M('activity_user_v2')->add($insert_data)){
                Writelog(M()->getLastSql(),'sql','prize');
                $this->responseError("登记失败!");                
            }
        }
        $this->responseSuccess(0, "登记成功!");
    }
    
    //获取网页二维码
    public function getQrcode()
    {
        $this->responseSuccess($this->createQrcode());
    }

    /**
     * 活动规则说明
     * @return [type] [description]
     */
    public function getActivityInfo()
    {        
//        //获取活动规则信息
        $data['act'] = $this->activityinfo;
        $data['act']['info'] = explode('######', $this->activityinfo['introduce']);
        $data['act']['info'][0] = mb_substr(htmlspecialchars_decode($data['act']['info'][0]), 0, -3) ;
        $data['act']['info'][1] = mb_substr(htmlspecialchars_decode($data['act']['info'][1]), 4);
        //获取当前活动的手机号码
        $user_phone          = M('activity_user_v2')->where(['act_id'=>$this->act_id,'uid'=>$this->uid])->getField('user_phone');
        if ($user_phone) {
            $data['user']['user_phone'] = $user_phone;
        }
        //获取奖品信息
        $prizes_tmp = json_decode($this->activityinfo['prize_list'],TRUE);
        foreach ($prizes_tmp as $key => $v) {
            $prizes[$v['prize_id']] = $v; 
            if($v['prize_status'] == 0 || $v['prize_status'] == -1){
                continue;
            }
            $prize_list[] = ['id'=>$v['prize_id'],'prize_name'=>$v['prize_name'],'prize_img'=>$v['prize_img']];
        }
        // var_dump($prizes);die;
        $data['prizes'] = $prize_list;
        //获取中奖信息
        $data['rank'] = $this->prizelog('localhost');
        unset($data['act']['prize_list']);
        unset($data['act']['prize_rule']);
        //获取当前用户中奖信息
        $map['act_id']       = $this->act_id;
        $map['uid'] = $this->uid;
        $map['rule_id']     = array("neq", 0); 
        //$data['my_prizes']   = M('prize_log_v2')->field('prize_id,prize_name')->where($map)->select();
        $my_prizes = M('prize_log_v2')->field('created_at,prize_id')->where($map)->select() ? : array();
        if($my_prizes){
            foreach ($my_prizes as $k=>$value) {
                $my_prizes[$k]['prize_name'] = $prizes[$value['prize_id']]['prize_name'];
                $data['my_prizes'][] = ['prize_id'=>$value['prize_id'],'prize_name'=>$prizes[$value['prize_id']]['prize_name']];
            }            
        }     
        //获取用户剩余中奖次数
        $data['remain_chance'] = $this->_getUserChance();
        $this->responseSuccess($data);
    }

    //建立游戏角色
    public function createRole()
    {
        if(!(I('role'))){
            $this->responseError('请选择角色!', -1);
        }

        if(!in_array(I('role'), ['yellow_pig','red_pig','blue_pig'])){
            $this->responseError('role参数不合法', -1);
        }

        //查看是否存在角色,存在及更新
        if(M('activity_chick_run')->where(['uid'=>$this->uid])->find()){
            $this->responseError('账号已存在!', -1);
        }

        $insertData = array(
            'uid'=>$this->uid,
            'role'=>I('role'),
            'created_at'=>date('Y-m-d H:i:s'),
            'updated_at'=>date('Y-m-d H:i:s'),
            'date'=>date('Ymd')
        );
        if(M('activity_chick_run')->add($insertData)){
            $this->responseSuccess(['success'=>'success'], '创建角色成功！');
        }else{
            $this->responseError('网络异常!', -1);
        }
    }

    //建立游戏角色
    private function _getRole()
    {
        //查看是否存在角色,存在及更新
        $role_info = M('activity_chick_run')->where(['uid'=>$this->uid])->find();
        return $role_info ? $role_info : FALSE;
    }

    //获取角色信息
    public function getRoleInfo()
    {
        $info = $this->_getRole();
        if($info){
            $this->responseSuccess($info);
        }else{
            $this->responseError('游戏角色未建立!', -1);
        }
    }

    /**
     * 获取虚拟道具卡
     * @param  [type] $uid [description]
     * @return [type]      [description]
     */
    public function getVitualCard()
    {
        if($daoju_name = trim(I('daoju_name'))){
            if(!in_array($daoju_name, ['reborn_card'])){
                $this->responseError('daoju_name 参数非法');                
            }
        } else {
            $this->responseError('daoju_name 参数非法');             
        }
        $remain = $this->_getVitualCard($daoju_name);
        $this->responseSuccess($remain,'剩余道具数量');
    }  
    
    /**
     * 获取虚拟卡
     * @param  [type] $uid [description]
     * @return [type]      [description]
     */
    private function _getVitualCard($daoju_name)
    {
        $map['uid']             = $this->uid;
        $map['act_id']          = $this->act_id;
        $map['date']            = date('Ymd');
        $map['name']            = $daoju_name;
        $daoju = M('activity_daoju')->field('operate,count(*) as total')->where($map)->group('operate')->select();
        $daoju = array_column($daoju, 'total', 'operate');
        $count = $daoju['add'] - $daoju['reduce'];
        if($daoju_name == 'reborn_card'){
            if($this->vip_level == 2){
                $remain_chance = 2 + $count;
            }elseif($this->vip_level ==1){
                $remain_chance = 1 + $count;
            }else{
                $remain_chance = 0 + $count; 
            }            
        }
        return $remain_chance > 0 ? $remain_chance : 0;
    }
    /**
     * 获取用户当日抽奖次数
     * @param  [type] $uid [description]
     * @return [type]      [description]
     */
    public function _getUserChance()
    {
        $map['uid']             = $this->uid;
        $map['act_id']          = $this->act_id;
        $map['date']            = date('Ymd');
        $chance = M('prize_log_v2')->where($map)->count();
        
        if($this->activityinfo['is_test'] ==1){
            if(I('is_test') ==1){
                return $remain_chance = 1000 - $chance;
            }
        }
        
        if($this->vip_level >=1){
            $remain_chance = ($this->vip_level * $this->activityinfo['vip_chance']  + $this->activityinfo['novip_chance'] - $chance);
        }else{
            $remain_chance = $this->activityinfo['novip_chance'] - $chance;
        }
        return $remain_chance > 0 ? $remain_chance : 0;
       
    }
        
    /**
     * 使用虚拟道具
     * @param  [type] $uid [description]
     * @return [type]      [description]
     */
    public function useVitualCard()
    {
        $remain_reborn_card = $this->_getVitualCard('reborn_card');
        if($remain_reborn_card >= 1){
            $insert = array(
                'uid'       => $this->uid,
                'act_id'    => $this->act_id,
                'date'      => date('Ymd'),
                'operate'   => 'reduce',
                'name'      => 'reborn_card'
            );
            if(M('activity_daoju')->add($insert)){
                $this->responseSuccess();
            }else{
                $this->responseError('网络异常!', -1);
            }
        }else{
            $this->responseError('您没有复活卡拉!', -3);
        }
    }
    /**
     * 获取用户剩余抽奖次数
     * @return [type] [description]
     */
    public function getPrizeNum()
    {
        $remain_chance = $this->_getUserChance();
        $this->responseSuccess($remain_chance);
    }

    /**
     * 所有中奖记录查询
     */
    public function prizelog($model = ''){
        $error[] = ['error' => 'error'];
        $where['pl.act_id'] = $this->act_id;
        $where['pl.prize_status'] = 1;
        $data = M('prize_log_v2')->alias('pl')
            ->join(array('left join '.C("DB_PREFIX").'activity_user_v2 as iu on iu.uid = pl.uid and iu.act_id = '.$this->act_id))
            ->where($where)
            ->order('pl.id desc')
            ->field('pl.prize_id,pl.created_at,pl.uid,iu.user_phone')
            ->select();
        $prizes = json_decode($this->activityinfo['prize_list'],TRUE);
        foreach ($prizes as $value) {
            $prize_list[$value['prize_id']] = $value;
        }
        if($data){
            foreach ($data as $key=>$value) {
                $data[$key]['prize_name'] = $prize_list[$value['prize_id']]['prize_name'];
                $data[$key]['prize_img'] = __MY_URL__.$prize_list[$value['prize_id']]['prize_img'];
            }
        }
        //增加虚拟中奖信息
        $default_data = $this->getPrizeDefault();    
        
        if($data || $default_data){
            if($data){
                foreach ($data as $k=>$v){
                    if($v['user_phone']){
                        $data[$k]['user_phone'] = substr_replace($v['user_phone'],'****',3,4);
                    }else {
                        $data[$k]['user_phone'] = substr_replace($v['uid'],'****',6);
                    }
                    unset($data[$k]['uid']);
                }                
            }
            if($data && $default_data){
                $data = array_merge($default_data,$data);
            }else{
                $data = $data ? : $default_data;
            }
            array_multisort(array_column($data,'created_at'),SORT_DESC,$data);  
            if($model == 'localhost'){
                return $data;
            }
            $this->responseSuccess($data, '查询成功！');
        }else{
            if($model == 'localhost'){
                return array();
            }
            $this->responseError('没有抽奖记录!', -3, $error);
        }
    }

    /**
     * 我的中奖记录查询
     */
    public function userPrizelog(){
        $error[] = ['error' => 'error'];
        //获取用户
        if($user_phone = M('activity_user_v2')->where(['uid'=>$this->uid,'act_id'=>$this->act_id])->getField('user_phone')){
            $phone_staus = 1;//填过
        }else{
            $phone_staus = 2;//填过
        }
        $where = array();
        $where['pl.prize_status'] = 1;
        $where['pl.uid'] = $this->uid;
        $where['pl.act_id'] = $this->act_id;
        $data = M('prize_log_v2')->alias('pl')
        ->where($where)
        ->order('pl.id desc')
        ->field('pl.prize_id,pl.created_at')
        ->select();
//        echo M()->getLastSql();die;
        $prizes = json_decode($this->activityinfo['prize_list'],TRUE);
        foreach ($prizes as $value) {
            $prize_list[$value['prize_id']] = $value;
        }

        $flag = $data ? 1 : 0;
        if($flag){
            if($data){
                foreach ($data as $k => $v){
                    $data[$k]['prize_name'] = $prize_list[$v['prize_id']]['prize_name'];
                    $data[$k]['prize_object'] = 'real';
                    $data[$k]['show_image']  = $prize_list[$v['prize_id']]['prize_img'] ? __MY_URL__.$prize_list[$v['prize_id']]['prize_img']:null;
                    unset($data[$k]['prize_id']);
                }                
            }

            $return_data = array(
                'my_prizes'=>$data,
                'user_phone'=>['phone_status'=>$phone_staus,'user_phone'=>$user_phone ? :''],
                'prize_status'=>$data ? 'real' : 'vitual'
            ); 
            $this->responseSuccess($return_data, '查询成功！');
        }else{
            $this->responseError('没有抽奖记录!', -3, $error);
        }
    }

    /**
     * 抽奖
     */
    public function prize(){
        $error[] = ['error' => 'error'];

        $chance = $this->_getUserChance();
        if(!$chance){
            $this->responseError('您今天的抽奖次数用完了!', -1, $error);
        }
       
        //开始抽奖
        $prize_data = $this->_get_prize();
        unset($prize_data['yes']['rule_id']);
        $this->responseSuccess($prize_data, '抽奖成功！');
    }

    private function _get_prize() {
        $result = $this->getPrizeSetDeatil();
//        var_dump($result);die;
        $this->_writePrizeLog($result);
        $res = array();
        $res['yes']['prize_name'] = $result['prize_name']; //中奖项
        $res['yes']['prize_status'] = $result['prize_object'] ? : 'none';
        $res['yes']['prize_img'] = $result['prize_img'] ? __MY_URL__.$result['prize_img'] : '';
        $res['yes']['rule_id'] = $result['rule_id'];
        return $res;
    }
    
    /**
     * @param desc 写入抽奖日志
     * @param type $result
     */
    private function _writePrizeLog(&$result) {
        $log_data['uid'] = $this->uid;
        $log_data['prize_id'] = $result['prize_id'];
        $log_data['is_vip'] = $this->vip_level;
        $log_data['act_id'] = $this->act_id;
        $log_data['created_at'] = date('Y-m-d H:i:s');
        $log_data['date'] = date('Ymd');
        $log_data['rule_id'] = $result['rule_id'];
        $log_data['prize_status'] = $result['prize_status'];
        if(!M('prize_log_v2')->add($log_data)){
            Writelog(M()->getLastSql(),'sql','activity');
            $this->responseError('系统繁忙抽奖失败', -1);
        }        
    }
    
    /**
     * 返回中奖的信息
     */
    private function getPrizeSetDeatil()
    {
        $prize_list = json_decode($this->activityinfo['prize_list'],TRUE);//获取奖项设置
        if($prize_list){
            foreach ($prize_list as $row) {
                $limit_sales[$row['prize_id']] = $row;
                if($row['prize_level']== 0){
                    $impossible_prize = ['prize_id'=>$row['prize_id'],'prize_name'=>$row['prize_name'],'rule_id'=>0,'prize_img'=>'','prize_status'=>0];
                }
            }
        }
        //获取所有规则
        $rules = json_decode($this->activityinfo['prize_rule'],TRUE);
        if(!$rules){
            return $impossible_prize;
        }
        
        if(I('run')!='complate'){
            return $impossible_prize;
        }

        //如果中了一次实物奖就不允许中第二次
        $map = array(
            'act_id'=> $this->act_id,
            'uid'=> $this->uid,
            'prize_status'=>1,
        );
        if(M('Prize_log_v2')->where($map)->find()){
            return $impossible_prize;
        }

        $swithc_no = ''; 
        foreach ($rules as $value) {
            if($value['rule_status'] == 0){
                $swithc_no = $swithc_no. 0; 
                continue;
            }
            //1.检查是否符合身份
            if(FALSE === $this->_checkRuleRole($value['rule_role'])){
                $swithc_no = $swithc_no. 1;
                continue;
            }
            //2.检查中奖日期设置
            if(FALSE === $this->_checkRuleDate($value['rule_date'])){
                $swithc_no = $swithc_no. 2;
                continue;
            }
            //3.检查时段设置
            if(FALSE === $this->_checkRuleHour($value['rule_hour'])){
                $swithc_no = $swithc_no. 3;
                continue;
            }
            //4.概率摇奖
            if(FALSE === $this->_getRandNum($value['rule_probability'])){
                $swithc_no = $swithc_no. 4;
                continue;
            }
            //5.查询是否超出当前规则下的出奖数
            if(FALSE === $this->_checkCurrentRuleSale($value)){
                $swithc_no = $swithc_no. 5;
                continue;
            }
            //6.查询是否超出奖品总数
            if(FALSE === $this->_checkGolabRule($value,$limit_sales)){
                $swithc_no = $swithc_no. 6;
                continue;
            }
//            //7.如果是限免视频对次数进行限制
//            if('限免视频'==$limit_sales[$value['rule_prize_id']]['prize_name']){
//                if( 6<= M('prize_program')->where(['uid'=>$this->uid,'act_id'=>$this->act_id,'style'=>'source'])->count()){
//                    $swithc_no = $swithc_no. 7;
//                    continue;
//                }
//            }
//            //8.如果中了一次实物奖就不允许中第二次
//            if('real'== $limit_sales[$value['rule_prize_id']]['prize_object']){
//                if(M('Prize_log_v2')->where(['act_id'=>$this->act_id,'uid'=>$this->uid,'prize_status'=>1])->find()){
//                    $swithc_no = $swithc_no. 8;
//                    continue;
//                }
//            }
            Writelog('uid: '.$this->uid.'跳出关卡: '.$swithc_no,'switch','activityv2');
            $prize = $limit_sales[$value['rule_prize_id']];
            $prize['rule_id'] = $value['rule_id'];
            $prize['prize_status'] = 1;
            return $prize;
        }
        Writelog('uid: '.$this->uid.'跳出关卡: '.$swithc_no,'switch','activityv2');
        return $impossible_prize;
    }
    
    /**
     * 获取转盘信息
     */
    public function prizeData(){
        $error[] = ['error' => 'error'];
        $data = array();
        $data['userp']['prize_num'] = $this->_getUserChance();
        $data['userp']['user_phone'] = $this->userinfo['user_phone'] ? :$this->userinfo['uid'];
        //转盘信息
        $turn_data = json_decode($this->activityinfo['prize_list'],TRUE);
        if($turn_data){
            foreach ($turn_data as $k => $v){
                if($v['prize_status'] == 0){
                    unset($turn_data[$k]);
                    continue;
                }
                if($v['prize_img']){
                    $turn_data[$k]['prize_img'] = __MY_URL__.$v['prize_img'];
                }
                unset($turn_data[$k]['prize_num']);
                unset($turn_data[$k]['prize_level']);
                unset($turn_data[$k]['prize_status']);
            }
            $data['prize_data'] = $turn_data;
        }else{
            $this->responseError('获取失败!', -1, $error);
        }
        $this->responseSuccess($data, '查询成功！');
    }
    
    private function getPrizeDefault()
    {   
        $map['pd.act_id'] = $this->act_id;
        $prizes = json_decode($this->activityinfo['prize_list'],true);
        foreach ($prizes as $key=>$v){
            $prize_list[$v['prize_id']] = $v;
        }
//        var_dump($prize_list);die;
        $data = M('prize_default_v2')->where(['act_id'=>$this->act_id])->select();
        if($data){
            foreach ($data as $value) {
                $return_data[] = array(
                    'created_at'=>$value['prize_date'],
                    'prize_name'=>$prize_list[$value['prize_id']]['prize_name'],
                    'prize_img'=>$prize_list[$value['prize_id']]['prize_img'] ? __MY_URL__.$prize_list[$value['prize_id']]['prize_img']:'',
                    'user_phone'=>substr_replace($value['phone'],'****',3,4),
                );
            }            
        }
        return $return_data;
    }
    
    /**
     * @desc 检查中奖规则关于身份设置
     */
    private function _checkRuleRole($rule_role)
    { 
        $role = $this->vip_level ? '会员' : '普通用户';
        if(FALSE !== strpos($rule_role, '不限')){
            return TRUE;
        }
        if($rule_role != '虚拟用户'){
            if(in_array($role, explode(',', $rule_role))){
                return TRUE;
            }
        }
        return FALSE;
    }
    /**
     * @desc 检查中奖规则关于日期
     */
    private function _checkRuleDate($rule_date)
    { 
        if(FALSE !== strpos($rule_date,'每日')){
            return TRUE;
        }
        //时间段
        if(strpos($rule_date,'至')){
            $date = explode('至', $rule_date);
            if((time()>=strtotime($date[0])) && time()< strtotime($date[1])){
                return TRUE;
            }else{
                return FALSE;
            }
        }else{
            if(date('Y-m-d') == $rule_date){
                return TRUE;
            }else{
                return FALSE;
            }
        }
    }
    
    /**
     * @desc 检查中奖规则关于时间段
     */
    private function _checkRuleHour($rule_hour)
    { 
        $hour = explode('至', $rule_hour);
        if((date('H:i')>= trim($hour[0])) && (date('H:i')< trim($hour[1]))){
            return TRUE;
        }else{
            return FALSE;
        }
    }
    /**
     * @desc 概率摇奖 
     * @param type $rule_probability
     * @return boolean
     */
    private function _getRandNum($rule_probability)
    {
        if($rule_probability == 0){
            return FALSE;
        }
        $tmp = explode('/', $rule_probability);
        $rand_array = range(1, $tmp[1]);
        shuffle($rand_array);
        $get_randnum = array_slice($rand_array, 0, $tmp[0]);
        Writelog('uid: '.$this->uid.'抽签: '.json_encode($get_randnum),'switch','activityv2');
        if(in_array($tmp[0], $get_randnum)){
            return TRUE;
        }else{
            return FALSE;
        }        
    }
    /**
     * @desc 查询符合当前规则
     */
    private function _checkCurrentRuleSale(&$rule)
    {
        //查询当前规则下的中奖数,如果为-1则无限制
        if($rule['rule_num'] == -1){
            return TRUE;
        }
        if((FALSE!==strpos($rule['rule_date'],'至')) && ($rule['rule_cycle']=='total')){
            $rule_date = explode('至', $rule['rule_date']);
            $where['rule_id'] = $rule['rule_id'];
            $where['act_id'] = $this->act_id;
            $where['date'] = ['between',[date('Ymd', strtotime($rule_date[0])),date('Ymd', strtotime($rule_date[1]))]];
            $countNum = M('Prize_log_v2')->where($where)->count();
            Writelog('当前1：'.$countNum.'规则：'.$rule['rule_num'],'info','activityv2');
            return $countNum >= $rule['rule_num'] ? FALSE : TRUE;    
        }else{
            $where['date'] = date('Ymd');
            $where['rule_id'] = $rule['rule_id'];
            $where['act_id'] = $this->act_id;
            $countNum = M('Prize_log_v2')->where($where)->count();
            Writelog('当前2：'.$countNum.'规则：'.$rule['rule_num'],'info','activityv2');
//            echo M()->getLastSql();die;
            return $countNum >= $rule['rule_num'] ? FALSE : TRUE;            
        }        
    }
    
    /**
     * @desc 不能超过奖品总数
     */
    private function _checkGolabRule(&$rule,&$limit_sales)
    {   
        if($limit_sales[$rule['rule_prize_id']]['prize_num'] == -1){
            return TRUE;
        }
        $countNum = M('Prize_log_v2')->where(['prize_id'=>$rule['rule_prize_id'],'act_id'=>$this->act_id])->count();
//        echo M()->getLastSql();die;
        Writelog('当前3：'.$countNum.'总量：'.$limit_sales[$rule['rule_prize_id']]['prize_num'],'info','activityv2');
        return $countNum >= $limit_sales[$rule['rule_prize_id']]['prize_num'] ? FALSE : TRUE;         
    }
}