zoumaliveServer/admin/Lib/Action/BmPromoterUserAction.class.php

<?php
// +----------------------------------------------------------------------
// | Fanwe 方维直播系统
// +----------------------------------------------------------------------
// | Copyright (c) 2011 http://www.fanwe.com All rights reserved.
// +----------------------------------------------------------------------
// | Author: 云淡风轻(1956838968@qq.com)
// +----------------------------------------------------------------------

class BmPromoterUserAction extends CommonAction
{
    public function __construct()
    {
        parent::__construct();
        require_once APP_ROOT_PATH . "/admin/Lib/Action/UserCommonAction.class.php";
        require_once APP_ROOT_PATH . "/system/libs/user.php";
    }

    public function index()
    {
        //$common = new UserCommon();
        $data = $_REQUEST;
//		$data['is_authentication'] = array('in',array(0,1,3));
        $data['is_robot'] = 0;
        if (trim($data['nick_name']) != '') {
            $parameter .= "nick_name like " . urlencode('%' . trim($data['nick_name']) . '%') . "&";
            $sql_w .= "nick_name like '%" . trim($data['nick_name']) . "%' and ";
        }
        if (trim($data['mobile']) != '') {
            $parameter .= "mobile like " . urlencode('%' . trim($data['mobile']) . '%') . "&";
            $sql_w .= "mobile like '%" . trim($data['mobile']) . "%' and ";
        }
        $create_time_2 = empty($_REQUEST['create_time_2']) ? to_date(get_gmtime(),
            'Y-m-d') : strim($data['create_time_2']);
        $create_time_2 = to_timespan($create_time_2) + 24 * 3600;
        if (trim($data['create_time_1']) != '') {
            $parameter .= "create_time between '" . to_timespan($data['create_time_1']) . "' and '" . $create_time_2 . "'&";
            $sql_w .= " (create_time between '" . to_timespan($data['create_time_1']) . "' and '" . $create_time_2 . "' ) and ";
        }
        if (intval($data['id']) > 0) {
            $parameter .= "id=" . intval($data['id']) . "&";
            $sql_w .= "id=" . intval($data['id']) . " and ";
        }

        if ($data['is_effect'] != null) {
            $parameter .= "is_effect=" . intval($data['is_effect']) . "&";
            $sql_w .= "is_effect=" . intval($data['is_effect']) . " and ";
        } else {
            $parameter .= "is_effect=1&";
            $sql_w .= "is_effect=1 and ";
        }

        if ($_REQUEST['is_admin'] != '') {
            $parameter .= "is_admin=" . intval($data['is_admin']) . "&";
            $sql_w .= "is_admin=" . intval($data['is_admin']) . " and ";
        }

        if (!isset($_REQUEST['anchor_type'])) {
            $_REQUEST['anchor_type'] = -1;
        }
        $data['anchor_type']=intval($_REQUEST['anchor_type']);
        if($data['anchor_type'] ==0){
            //普通会员
            $parameter .= "anchor_type=" . $data['anchor_type'] . "&";
            $sql_w .= "is_authentication in (0,1,3) and ";
        }elseif($data['anchor_type'] ==1){
            //普通主播
            $parameter .= "anchor_type=" . $data['anchor_type'] . "&";
            $sql_w .= "is_authentication = 2 and bm_special=0";
        }elseif($data['anchor_type'] ==2){
            //签约主播
            $parameter .= "anchor_type=" . $data['anchor_type'] . "&";
            $sql_w .= "is_authentication = 2 and bm_special=1";
        }

        $bm_promoter_id = intval($data['bm_promoter_id']);
        if ($bm_promoter_id > 0) {
            $bm_pid=$GLOBALS['db']->getOne("select user_id from ".DB_PREFIX."bm_promoter where id=".$bm_promoter_id." ");
            $parameter .= "bm_pid=" . $bm_pid . "&";
            $sql_w .= "bm_pid=" . $bm_pid . " and ";
        } else {
            $sql_w .= "bm_pid >0 and ";
        }

        if (isset($data['is_robot'])) {
            $parameter .= "is_robot=" . intval($data['is_robot']) . "&";
            $sql_w .= "is_robot=" . intval($data['is_robot']) . " and ";
        } else {
            $parameter .= "is_robot=0&";
            $sql_w .= "is_robot=0 and ";
        }


        $m_config = load_auto_cache("m_config");//初始化手机端配置
        if (defined('OPEN_VIP') && OPEN_VIP == 1) {
            if ($_REQUEST['is_vip'] != '') {
                $parameter .= "is_vip=" . intval($data['is_vip']) . "&";
                $sql_w .= "is_vip=" . intval($data['is_vip']) . " and ";
            }
            $this->assign('open_vip', 1);
        }

        $model = D();

        $m_config = load_auto_cache("m_config");
        $ote = floatval($m_config['onlinetime_to_experience']);
        $sql_str = "SELECT *," .
            " ticket-refund_ticket as useable_ticket ,floor(score + online_time*" . $ote . ") as u_score" .
            " FROM " . DB_PREFIX . "user WHERE 1=1 ";
        $count_sql = "SELECT count(*) as tpcount" .
            " FROM " . DB_PREFIX . "user WHERE (1=1 ";

        if (intval($data['id']) == 0) {
            $sql_str .= " and " . $sql_w . " 1=1 ";
            $count_sql .= " and " . $sql_w . " 1=1) ";
        } else {
            $sql_str .= " and " . $sql_w . " 1=1 union SELECT *," .
                " ticket-refund_ticket as useable_ticket ,floor(score + online_time*" . $ote . ") as u_score" .
                " FROM " . DB_PREFIX . "user WHERE luck_num=" . $data['id'];
            $count_sql .= " and " . $sql_w . " 1=1 ) or (luck_num=" . $data['id'] . ")";
        }

        $distribution_log = 0;
        if (defined('OPEN_DISTRIBUTION') && OPEN_DISTRIBUTION == 1) {
            $distribution_log = 1;
        }
        $coins = 0;
        if (defined('OPEN_GAME_MODULE') && OPEN_GAME_MODULE == 1) {
            $coins = 1;
        }
        $goods = 0;
        if ((defined('SHOPPING_GOODS') && SHOPPING_GOODS == 1) || (defined('PAI_REAL_BTN') && PAI_REAL_BTN == 1)) {
            $goods = 1;
        }
        $voList = $this->_Sql_list($model, $sql_str, "&" . $parameter, 'id', 0, $count_sql);

        foreach ($voList as $k => $v) {
            $voList[$k]['head_image'] = get_spec_image($v['head_image']);
            $voList[$k]['distribution_log'] = $distribution_log;
            $voList[$k]['coins'] = $coins;
            $voList[$k]['goods'] = $goods;
            $voList[$k]['ticket'] = $v['ticket'] + $v['no_ticket'];
        }

        $this->assign('list', $voList);
        $this->display();

    }

    public function edit()
    {
        $data = $_REQUEST;
        $id = intval($data['id']);
        $condition['id'] = $id;
        $vo = M('User')->where($condition)->find();
        $vo['ban_time'] = $vo['ban_time'] > 0 ? to_date($vo['ban_time']) : '';
        $vo['create_time'] = $vo['create_time'] > 0 ? to_date($vo['create_time']) : '';
        $vo['nick_name'] = emoji_decode($vo['nick_name']);
        $vo['signature'] = emoji_decode($vo['signature']);
        $m_config = load_auto_cache("m_config");//初始化手机端配置
        if (defined('OPEN_VIP') && OPEN_VIP == 1) {
            $this->assign('open_vip', 1);
            $vip_expire_time = $vo['vip_expire_time'];
            $vo['vip_expire_time'] = '';
            if (intval($vo['is_vip']) == 1) {
                $vo['vip_expire_time'] = $vip_expire_time > 0 ? to_date($vip_expire_time) : '';
                if ($vip_expire_time > 0 && $vip_expire_time < NOW_TIME) {
                    $vo['is_vip'] = 0;
                    $vo['vip_expire_time'] = '';
                    $sql = "update " . DB_PREFIX . "user set is_vip = 0 where id = " . $id;
                    $GLOBALS['db']->query($sql);
                    user_deal_to_reids(array($id));
                }
            }
        }
        if (defined('OPEN_DISTRIBUTION') && OPEN_DISTRIBUTION == 1) {
            $this->assign('open_distribution', 1);
        }
        $user_level = $GLOBALS['db']->getOne("select user_level from " . DB_PREFIX . "user where id = " . $id);  //二级地址

        $vo['user_level'] = $user_level > 0 ? $user_level : 1;
        //过滤头像是本地连接的问题
        $vo['head_image'] = get_spec_image($vo['head_image'], 50, 50);

        //关联上级id
        $vo['bm_promoter_id'] = M("BmPromoter")->where("user_id=" . intval($vo['bm_pid']) . "")->getField("id");
        $this->assign('vo', $vo);
        $region_pid = 0;
        $region_lv2 = $GLOBALS['db']->getAll("select * from " . DB_PREFIX . "region_conf where region_level = 2 order by py asc");  //二级地址
        foreach ($region_lv2 as $k => $v) {
            if ($v['name'] == $vo['province']) {
                $region_lv2[$k]['selected'] = 1;
                $region_pid = $region_lv2[$k]['id'];
                break;
            }
        }
        $this->assign("region_lv2", $region_lv2);

        if ($region_pid > 0) {
            $region_lv3 = $GLOBALS['db']->getAll("select * from " . DB_PREFIX . "region_conf where pid = " . $region_pid . " order by py asc");  //三级地址
            foreach ($region_lv3 as $k => $v) {
                if ($v['name'] == $vo['city']) {
                    $region_lv3[$k]['selected'] = 1;
                    break;
                }
            }
            $this->assign("region_lv3", $region_lv3);
        }
        //会员等级信息
        $user_level = $GLOBALS['db']->getAll("select * from " . DB_PREFIX . "user_level where `level`>=" . $user_level . " order by level ASC");
        $this->assign("user_level", $user_level);

        //认证类型
        $authent_list = M("AuthentList")->findAll();
        $this->assign("authent_list", $authent_list);
        //分类
        $classifi_list = M("VideoClassified")->findAll();
        $this->assign("classified_id", $classifi_list);

        if (defined('OPEN_EDU_MODULE') && OPEN_EDU_MODULE == 1) {
            if ($vo['authentication_type'] == '教师') {
                $teacher = M('EduTeacher')->where(array('user_id' => $vo['id']))->find();
                $this->assign('teaching_certificate', get_spec_image($teacher['teaching_certificate']));
                $this->assign('education_certificate', get_spec_image($teacher['education_certificate']));
            } elseif ($vo['authentication_type'] == '机构') {
                $org = M('EduOrg')->where(array('user_id' => $vo['id']))->find();
                $this->assign('business_license', get_spec_image($org['business_license']));
            }
        }
        //是否显示身份证号码
        $show_identify_number = intval($m_config['is_show_identify_number']);
        $this->assign('show_identify_number', $show_identify_number);
        $this->display();
    }


    public function delete()
    {
        //彻底删除指定记录
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->delete($data);
    }


    public function update()
    {
        B('FilterString');
        $data = M('User')->create();
        //开始验证有效性
        $this->assign("jumpUrl", u(MODULE_NAME . "/edit", array("id" => $data['id'])));
        $old_user_info = M('User')->where("id=" . $data['id'])->find();

        //app和admin共用user.php的save_user方法，后台update是没有验证码的，所以save_user设置标示字段$update_status
        $user_info = $GLOBALS['db']->getRow("select * from " . DB_PREFIX . "user where id = " . intval($data['id']));
        /*if($user_info['user_level'] != $data['user_level']){
            //require_once APP_ROOT_PATH.'mapi/lib/redis/BaseRedisService.php';
            //require_once(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
            //$user_redis = new UserRedisService();
            $score = $GLOBALS['db']->getOne("select score from ".DB_PREFIX."user_level where `level` = ".$data['user_level']);
            //$online_time = $user_redis->getOne_db($data['id'],'online_time');
            //$online_time = intval($online_time)>0?intval($online_time):0;
            //$score = $score - floor($online_time/app_conf('ONLINETIME_TO_EXPERIENCE'));
            $user_info['score'] = $score;
        }*/
        if ($user_info['login_type'] == 2 && empty($data['mobile'])) {
            $this->error('手机注册用户，手机号不能为空');
        } else {
            $user_info['mobile'] = $data['mobile'];
        }
        $user_info['user_level'] = $data['user_level'];

        if ($data['v_explain'] == '') {
            $data['v_explain'] = $data['authentication_type'];
        }
        $data['v_icon'] = get_spec_image(M('AuthentList')->where("name='" . trim($data['authentication_type'] . "'"))->getField("icon"));
        $data['authent_list_id'] = get_spec_image(M('AuthentList')->where("name='" . trim($data['authentication_type'] . "'"))->getField("id"));

        $data['nick_name'] = emoji_encode($data['nick_name']);
        $data['signature'] = emoji_encode($data['signature']);


        //上级id
        $bm_promoter_id = intval($_REQUEST['bm_promoter_id']);
        if ($bm_promoter_id <= 0) {
            $this->error('请输入关联的上级ID');
        } else {
            $bm_promoter_info_new=M("BmPromoter")->where("id=".$bm_promoter_id."")->find();
            if(!$bm_promoter_info_new || $bm_promoter_info_new['is_effect'] !=1){
                $this->error('无效的关联的上级ID');
            }

            if($bm_promoter_info_new['pid'] ==0){
                $this->error('关联的上级ID不能是推广中心的id');
            }

            $new_bm_pid=$bm_promoter_info_new['user_id'];
        }
        $user_info = array_merge($user_info, $data);
        if (defined('GAME_DISTRIBUTION') && GAME_DISTRIBUTION == 1) {
            if ($user_info['id'] == $user_info['game_distribution_id']) {
                $this->error('推荐人不能为自己');
            }
            if ($user_info['game_distribution_id']) {
                $distribution = M('User')->where(['id' => $user_info['game_distribution_id']])->find();
                if (!$distribution) {
                    $this->error('推荐人ID不存在');
                }
            }
        }

        $res = save_user($user_info, 'UPDATE', $update_status = 0);

        if ($res['status'] == 0) {
            $error_field = $res['data'];
            if ($error_field['error'] == EMPTY_ERROR) {
                if ($error_field['field_name'] == 'user_name') {
                    $this->error(L("USER_NAME_EMPTY_TIP"));
                } elseif ($error_field['field_name'] == 'email') {
                    $this->error(L("USER_EMAIL_EMPTY_TIP"));
                } else {
                    $this->error(sprintf(L("USER_EMPTY_ERROR"), $error_field['field_show_name']));
                }
            } elseif ($error_field['error'] == FORMAT_ERROR) {
                if ($error_field['field_name'] == 'email') {
                    $this->error(L("USER_EMAIL_FORMAT_TIP"));
                }
                if ($error_field['field_name'] == 'mobile') {
                    $this->error(L("USER_MOBILE_FORMAT_TIP"));
                }
            } elseif ($error_field['error'] == EXIST_ERROR) {
                if ($error_field['field_name'] == 'user_name') {
                    $this->error(L("USER_NAME_EXIST_TIP"));
                }
                if ($error_field['field_name'] == 'email') {
                    $this->error(L("USER_EMAIL_EXIST_TIP"));
                }
                if ($error_field['field_name'] == 'mobile') {
                    $this->error(L("USER_MOBILE_EXIST_TIP"));
                }
            } else {
                $this->error($res['error']);
            }
        }

        //开始更新is_effect状态
        M("User")->where("id=" . intval($data['id']))->setField("is_effect", intval($data['is_effect']));
        $user_id = intval($data['id']);
        $log_info = '';
        if ($data['user_level'] != $old_user_info['user_level']) {
            $log_info .= " 等级从" . $old_user_info['user_level'] . "级变为" . $data['user_level'] . "级";
        }
        if ($data['is_authentication'] != $old_user_info['is_authentication']) {
            $log_info .= " 认证状态从" . $this->get_authentication($old_user_info['is_authentication']) . "变为" . $this->get_authentication($data['is_authentication']);
        }

        //更新关联上级id成功后，重新统计上级子级个数
        if($old_user_info['bm_pid']>0 && $new_bm_pid>0 && $old_user_info['bm_pid'] != $new_bm_pid){
            $re=$GLOBALS['db']->query("update " . DB_PREFIX . "user set bm_pid= ".$new_bm_pid." where id=".intval($old_user_info['id'])."");
            if($re){
                //新
                $GLOBALS['db']->query("update " . DB_PREFIX . "bm_promoter set child_count=(SELECT count(*) from " . DB_PREFIX . "user where bm_pid=" . intval($new_bm_pid) . " and is_effect=1 ) where user_id= " . intval($new_bm_pid) . "");
                //旧
                $GLOBALS['db']->query("update " . DB_PREFIX . "bm_promoter set child_count=(SELECT count(*) from " . DB_PREFIX . "user where bm_pid=" . intval($old_user_info['bm_pid']) . " and is_effect=1 ) where user_id= " . intval($old_user_info['bm_pid']) . "");
            }
        }

        save_log($user_id . L("UPDATE_SUCCESS") . $log_info, 1);
        $this->success(L("UPDATE_SUCCESS"));

    }
    public function get_authentication($is_authentication){
        switch($is_authentication){
            case 1:
                return "待审核";
                break;
            case 2:
                return "已认证";
                break;
            case 3:
                return "认证不通过";
                break;
            default:
                return "未认证";
        }
    }
    public function set_effect()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $n_is_effect = $common->set_effect($data);
        $this->ajaxReturn($n_is_effect, l("SET_EFFECT_" . $n_is_effect), 1);
    }

    public function set_ban()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $n_is_effect = $common->set_ban($data);
        $this->ajaxReturn($n_is_effect, l("SET_BAN_" . $n_is_effect), 1);
    }

    //禁热门
    public function set_hot_on()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $n_is_effect = $common->set_hot_on($data);
        $this->ajaxReturn($n_is_effect, l("SET_HOT_ON_" . $n_is_effect), 1);
    }

    //新增关注
    public function add_focus()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->add_focus($data);
    }

    //新增关注
    public function set_follow()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->set_follow($data);
    }

    //关注列表
    public function focus_list()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->focus_list($data);
    }

    //新增粉丝
    public function add_fans()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->add_fans($data);
    }

    //新增粉丝
    public function set_follower()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->set_follower($data);
    }

    //粉丝列表
    public function fans_list()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->fans_list($data);
    }

    //删除关注
    public function del_focus_list()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->del_focus_list($data);
    }

    //删除粉丝
    public function del_fans_list()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->del_fans_list($data);
    }

    //印票贡献榜
    public function contribution_list()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->contribution_list($data);
    }

    /**
     * 删除印票贡献榜
     */
    /*public function del_contribution_list()
    {
        $ajax = intval($_REQUEST['ajax']);
        $id = $_REQUEST ['id'];
        if (isset ( $id )) {
            $common = new UserCommon();
            $data = $_REQUEST;
            $status = $common->del_contribution_list($data);

            if ($status!==false) {
                $this->success (l("FOREVER_DELETE_SUCCESS"),$ajax);
            } else {
                $this->error (l("FOREVER_DELETE_FAILED"),$ajax);
            }
        } else {
            $this->error (l("INVALID_OPERATION"),$ajax);
        }
    }*/

    //消息推送
    public function push()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->push($data);
    }

    //删除推送消息
    public function del_push()
    {
        $ajax = intval($_REQUEST['ajax']);
        $id = $_REQUEST ['id'];
        if (isset ($id)) {
            $common = new UserCommon();
            $data = $_REQUEST;
            $status = $common->del_push($data);

            if ($status !== false) {
                $this->success(l("FOREVER_DELETE_SUCCESS"), $ajax);
            } else {
                $this->error(l("FOREVER_DELETE_FAILED"), $ajax);
            }
        } else {
            $this->error(l("INVALID_OPERATION"), $ajax);
        }
    }

    //账户管理
    public function account()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $status = $common->account($data);
    }

    //账户修改
    public function modify_account()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $status = $common->modify_account($data);
        if ($status) {
            $this->success(L("UPDATE_SUCCESS"));
        } else {
            $this->error("累计充值数据有误！");
        }

    }

    //账户日志
    public function account_detail()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->account_detail($data);
    }

    //兑换日志
    public function exchange_log()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->exchange_log($data);
    }

    //删除账户日志
    public function foreverdelete_account_detail()
    {

        //彻底删除指定记录
        $ajax = intval($_REQUEST['ajax']);
        $id = $_REQUEST ['id'];
        $data = $_REQUEST;
        if (isset ($id)) {
            $common = new UserCommon();
            $status = $common->foreverdelete_account_detail($data);
            if ($status !== false) {
                $this->success(l("FOREVER_DELETE_SUCCESS"), $ajax);
            } else {
                $this->error(l("FOREVER_DELETE_FAILED"), $ajax);
            }
        } else {
            $this->error(l("INVALID_OPERATION"), $ajax);
        }
    }

    //删除兑换日志
    public function foreverdelete_exchange_log()
    {

        //彻底删除指定记录
        $ajax = intval($_REQUEST['ajax']);
        $id = $_REQUEST ['id'];
        $data = $_REQUEST;
        if (isset ($id)) {
            $common = new UserCommon();
            $status = $common->foreverdelete_exchange_log($data);
            if ($status !== false) {
                $this->success(l("FOREVER_DELETE_SUCCESS"), $ajax);
            } else {
                $this->error(l("FOREVER_DELETE_FAILED"), $ajax);
            }
        } else {
            $this->error(l("INVALID_OPERATION"), $ajax);
        }
    }

    //检查用户
    public function check_user()
    {
        $common = new UserCommon();
        $user_id = $_REQUEST['id'];
        admin_ajax_return($common->check_user($user_id));
    }

    //礼物日志
    public function prop()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->prop($data);
    }

    //收礼物日志
    public function closed_prop()
    {
        $data = $_REQUEST;
        $now = get_gmtime();
        $user_id = intval($_REQUEST['id']);
        $user_info = M("User")->getById($user_id);
        $prop_list = M("prop")->where("is_effect <>0")->findAll();

        $where = "l.to_user_id=" . $user_id;
        $model = D("video_prop");
        //赠送时间

        $current_Year = date('Y');


        $current_YM = date('Ym');
        for ($i = 0; $i < 5; $i++) {
            $years[$i] = $current_Year - $i;
        }

        for ($i = 01; $i < 13; $i++) {
            $month[$i] = str_pad(0 + $i, 2, 0, STR_PAD_LEFT);
        }

        if (strim($data['years']) != -1 && strim($data['month'] != -1)) {
            $time = $data['years'] . '' . $data['month'];
        } else {
            $time = $current_YM;
        }
        if (strim($data['years']) != -1 && strim($data['month'] == -1)) {
            $this->error("请选择月份");
        }
        if (strim($data['years']) == -1 && strim($data['month'] != -1)) {
            $this->error("请选择年份");
        }

        //查询ID
        if (strim($data['from_user_id']) != '') {
            $parameter .= "l.from_user_id=" . intval($data['from_user_id']) . "&";
            $sql_w .= "l.from_user_id=" . intval($data['from_user_id']) . " and ";
        }
        //查询昵称
        if (trim($data['nick_name']) != '') {
            $parameter .= "u.nick_name like " . urlencode('%' . trim($data['nick_name']) . '%') . "&";
            $sql_w .= "u.nick_name like '%" . trim($data['nick_name']) . "%' and ";

        }
        if (!isset($_REQUEST['prop_id'])) {
            $_REQUEST['prop_id'] = -1;
        }
        //查询礼物
        if ($_REQUEST['prop_id'] != -1) {
            if (isset($data['prop_id'])) {
                $parameter .= "l.prop_id=" . intval($data['prop_id']) . "&";
                $sql_w .= "l.prop_id=" . intval($data['prop_id']) . " and ";
            }
        }

        //默认查询本月的记录,选择查询时间时,如果查询时间 不等于当前时间,则查询他表
        if ($data['years'] != '' && $data['month'] != '') {
            $sql_str = "SELECT l.id,l.create_ym,l.to_user_id, l.create_time,l.prop_id,l.prop_name,l.from_user_id,l.create_date,l.num,l.total_ticket,u.nick_name
                         FROM   " . DB_PREFIX . "video_prop_" . $time . " as l
                         LEFT JOIN " . DB_PREFIX . "user AS u  ON l.from_user_id = u.id" . " LEFT JOIN " . DB_PREFIX . "prop AS v ON l.prop_name = v.name" . "
                         WHERE $where " . "  and " . $sql_w . " 1=1  ";

            $count_sql = "SELECT count(l.id)  as tpcount
                         FROM   " . DB_PREFIX . "video_prop_" . $time . " as l
                         LEFT JOIN " . DB_PREFIX . "user AS u  ON l.from_user_id = u.id" . " LEFT JOIN " . DB_PREFIX . "prop AS v ON l.prop_name = v.name" . "
                         WHERE $where " . "  and " . $sql_w . " 1=1  ";

            $total_ticket_sql = "SELECT SUM(l.total_ticket)  as tpcount
                         FROM   " . DB_PREFIX . "video_prop_" . $time . " as l
                         LEFT JOIN " . DB_PREFIX . "user AS u  ON l.from_user_id = u.id" . " LEFT JOIN " . DB_PREFIX . "prop AS v ON l.prop_name = v.name" . "
                         WHERE $where " . "   and " . $sql_w . " 1=1  ";
        } else {

            $sql_str = "SELECT l.id,l.create_ym,l.to_user_id, l.create_time,l.prop_id,l.prop_name,l.from_user_id,l.create_date,l.num,l.total_ticket,u.nick_name
                         FROM   " . DB_PREFIX . "video_prop_" . date('Ym', NOW_TIME) . " as l
                         LEFT JOIN " . DB_PREFIX . "user AS u  ON l.from_user_id = u.id" . " LEFT JOIN " . DB_PREFIX . "prop AS v ON l.prop_name = v.name" . "
                         WHERE $where " . "   and " . $sql_w . " 1=1  ";

            $count_sql = "SELECT count(l.id)  as tpcount
                         FROM   " . DB_PREFIX . "video_prop_" . date('Ym', NOW_TIME) . " as l
                         LEFT JOIN " . DB_PREFIX . "user AS u  ON l.from_user_id = u.id" . " LEFT JOIN " . DB_PREFIX . "prop AS v ON l.prop_name = v.name" . "
                         WHERE $where " . "   and " . $sql_w . " 1=1  ";

            $total_ticket_sql = "SELECT SUM(l.total_ticket)  as tpcount
                         FROM   " . DB_PREFIX . "video_prop_" . date('Ym', NOW_TIME) . " as l
                         LEFT JOIN " . DB_PREFIX . "user AS u  ON l.from_user_id = u.id" . " LEFT JOIN " . DB_PREFIX . "prop AS v ON l.prop_name = v.name" . "
                         WHERE $where " . "   and " . $sql_w . " 1=1  ";
        }

        $count = $GLOBALS['db']->getOne($count_sql);
        $total_ticket = $GLOBALS['db']->getOne($total_ticket_sql);

        $volist = $this->_Sql_list($model, $sql_str, '&' . $parameter, 1, 0, $count_sql);
        foreach ($volist as $k => $v) {
            if ($volist[$k]['prop_id'] == 12) {
                $volist[$k]['total_ticket'] = '';
            }
            $volist[$k]['create_time'] = date('Y-m-d', $volist[$k]['create_time']);
        }

        $this->assign("user_info", $user_info);
        $this->assign("prop", $prop_list);
        $this->assign("years", $years);
        $this->assign("month", $month);
        $this->assign("list", $volist);
        $this->assign("count", intval($count));
        $this->assign('total_ticket', intval($total_ticket));
        $this->display();
    }

    //分享奖励
    public function distribution_log()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->distribution_log($data);
    }

    //分销子成员奖励
    public function distribution_user()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->distribution_user($data);
    }

    //删除礼物日志
    public function delete_prop()
    {

        //彻底删除指定记录
        $ajax = intval($_REQUEST['ajax']);
        $id = intval($_REQUEST ['id']);
        $data = $_REQUEST;
        if (isset ($id)) {
            $common = new UserCommon();
            $status = $common->del_prop($data);
            if ($status !== false) {
                $this->success(l("FOREVER_DELETE_SUCCESS"), $ajax);
            } else {
                $this->error(l("FOREVER_DELETE_FAILED"), $ajax);
            }
        } else {
            $this->error(l("INVALID_OPERATION"), $ajax);
        }
    }

    public function forbid_msg()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
        $common->forbid_msg($data);
    }

    //商品管理
    public function goods()
    {

        $user_id = intval($_REQUEST['user_id']);
        if (strim($_REQUEST['name']) != '') {
            $map['name'] = array('like', '%' . strim($_REQUEST['name']) . '%');
        }
        $map['is_effect'] = 1;
        $model = D('goods');
        if (!empty ($model)) {
            $this->_list($model, $map);
        }
        $list = $this->get('list');
        $user_list = $GLOBALS['db']->getAll("select goods_id from " . DB_PREFIX . "user_goods where is_effect=1 and user_id=" . $user_id);
        foreach ($list as $k => $v) {
            $imgs = array();
            $imgs_details = array();
            $imgs = json_decode($v['imgs'], 1);
            $imgs_details = json_decode($v['imgs_details'], 1);
            $list[$k]['imgs'] = $imgs[0];
            $list[$k]['imgs_details'] = $imgs_details[0];
            $list[$k]['has'] = '否';
            foreach ($user_list as $value1) {
                if ($v['id'] == $value1['goods_id']) {
                    $list[$k]['has'] = '是';
                    break;
                }
            }
        }
        $sort = array_column($list, 'has');
        array_multisort($sort, SORT_DESC, $list);

        $this->assign("list", $list);
        $this->display();

    }

    //上架商品
    public function shelves()
    {

        $ajax = intval($_REQUEST['ajax']);
        $goods_id = intval($_REQUEST ['id']);
        $user_id = intval($_REQUEST ['user_id']);

        if (isset($goods_id)) {
            $where['goods_id'] = $goods_id;
            $where['user_id'] = $user_id;
            $user_goods = M('user_goods')->where($where)->select();
            $goods_info = $GLOBALS['db']->getRow("select name,imgs,imgs_details,price,pai_diamonds,kd_cost,score,is_effect from " . DB_PREFIX . "goods where is_effect=1 and id=" . $goods_id);
            if ($user_goods) {
                $list = M('user_goods')->where($where)->save($goods_info);
            } else {
                $data = array_merge($where, $goods_info);
                $list = M('user_goods')->add($data);
            }

            if ($list !== false) {
                $result['info'] = "上架成功！";
                $result['status'] = 1;
            } else {
                $result['info'] = "上架失败！";
                $result['status'] = 0;
            }
            $this->ajax_return($result);
        } else {
            $this->error(l("INVALID_OPERATION"), $ajax);
        }

    }

    //下架商品
    public function sold()
    {

        $ajax = intval($_REQUEST['ajax']);
        $goods_id = intval($_REQUEST ['id']);
        $user_id = intval($_REQUEST ['user_id']);

        if (isset($goods_id)) {
            $condition['goods_id'] = $goods_id;
            $condition['user_id'] = $user_id;
            $user_goods = M('user_goods')->where($condition)->select();
            if ($user_goods) {
                $list = M('user_goods')->where($condition)->delete();
            }

            if ($list !== false) {
                $result['info'] = "下架成功！";
                $result['status'] = 1;
            } else {
                $result['info'] = "下架失败！";
                $result['status'] = 0;
            }
            $this->ajax_return($result);
        } else {
            $this->error(l("INVALID_OPERATION"), $ajax);
        }

    }

    public function clear_view_count()
    {
        $sql = "update  " . DB_PREFIX . "user set view_count = 0";
        $res = $GLOBALS['db']->query($sql);
        if ($res) {
            $result['info'] = "清除成功！";
            $result['status'] = 1;
        } else {
            $result['info'] = "清除失败！";
            $result['status'] = 0;
        }
        admin_ajax_return($result);
    }

    public function weibo_index()
    {
        $common = new UserCommon();
        $data = $_REQUEST;
//		$data['is_authentication'] = array('in',array(0,1,3));
        $data['is_robot'] = 0;
        $common->index($data);
    }

    public function set_sort()
    {
        $id = intval($_REQUEST['id']);
        $sort = intval($_REQUEST['sort']);
        $log_info = M("User")->where("id=" . $id)->getField("nick_name");
        if (!check_sort($sort)) {
            $this->error(l("SORT_FAILED"), 1);
        }
        M("User")->where("id=" . $id)->setField("weibo_recommend_weight", $sort);
        save_log($log_info . l("SORT_SUCCESS"), 1);

        $this->success(l("SORT_SUCCESS"), 1);
    }

    public function game_rate()
    {
        if ($_POST) {
            $user_id = intval($_REQUEST['user_id']);
            $rate = intval($_REQUEST['rate']);
            if (!$user_id) {
                $this->ajax_return(array(
                    'status' => 0,
                    'error' => '参数错误',
                ));
            }
            if ($rate > 100 || $rate < 0) {
                $this->ajax_return(array(
                    'status' => 0,
                    'error' => '参数错误',
                ));
            }
            $where = array('id' => $user_id);
            $user_model = M('user');
            $res = $user_model->setField('rate', $rate, $where);
            if ($res) {
                fanwe_require(APP_ROOT_PATH . 'mapi/lib/redis/BaseRedisService.php');
                fanwe_require(APP_ROOT_PATH . 'mapi/lib/redis/UserRedisService.php');
                $user_redis = new UserRedisService();
                $user_redis->update_db($user_id, ['rate' => $rate]);
                $this->ajax_return(array(
                    'status' => 1,
                    'error' => '更新成功',
                ));
            }
            $this->ajax_return(array(
                'status' => 0,
                'error' => '更新失败',
            ));
        } else {
            $user_id = intval($_REQUEST['user_id']);
            $user_model = M('user');
            $user_info = $user_model->field(array('id', 'rate'))->find($user_id);
            $user_info['rate'] = +$user_info['rate'];
            $this->assign("user_info", $user_info);
            $this->display();
        }
    }

    protected function ajax_return($data)
    {
        header("Content-Type:text/html; charset=utf-8");
        echo(json_encode($data));
        exit;
    }

    public function game_distribution()
    {

        if ($_POST) {
            $user_id = intval($_REQUEST['user_id']);
            $game_distribution1 = intval($_REQUEST['game_distribution1']);
            $game_distribution2 = intval($_REQUEST['game_distribution2']);
            if (!$user_id) {
                $this->ajax_return(array(
                    'status' => 0,
                    'error' => '参数错误',
                ));
            }
            $where = array('id' => $user_id);
            $user_model = M('user');
            $res = $user_model->where($where)->save([
                'game_distribution1' => $game_distribution1,
                'game_distribution2' => $game_distribution2
            ]);
            if ($res) {
                fanwe_require(APP_ROOT_PATH . 'mapi/lib/redis/BaseRedisService.php');
                fanwe_require(APP_ROOT_PATH . 'mapi/lib/redis/UserRedisService.php');
                $user_redis = new UserRedisService();
                $user_redis->update_db($user_id,
                    ['game_distribution1' => $game_distribution1, 'game_distribution2' => $game_distribution2]);
                $this->ajax_return(array(
                    'status' => 1,
                    'error' => '更新成功',
                ));
            }
            $this->ajax_return(array(
                'status' => 0,
                'error' => '更新失败',
            ));
        } else {
            $user_id = intval($_REQUEST['user_id']);
            $user_model = M('user');
            $user_info = $user_model->field(array('id', 'game_distribution1', 'game_distribution2'))->find($user_id);
            $user_info['game_distribution1'] = +$user_info['game_distribution1'];
            $user_info['game_distribution2'] = +$user_info['game_distribution2'];
            $this->assign("user_info", $user_info);
            $this->display();
        }
    }

    public function invitation_code()
    {
        $user_id = intval($_REQUEST['user_id']);
        $user_model = M('user');
        $user_info = $user_model->field(['invitation_code', 'create_time'])->find($user_id);
        if ($user_info['invitation_code']) {
            exit($user_info['invitation_code']);
        }
        $users = $user_model->field(['id', 'create_time'])->where(['invitation_code' => ''])->findAll();
        foreach ($users as $v) {
            $res = $user_model->save([
                'invitation_code' => substr(md5($v['id'] . ':' . $v['create_time']), -16),
                'id' => $v['id']
            ]);
        }
        exit(substr(md5($user_id . ':' . $user_info['create_time']), -16));
    }

    public function game_distribution_detail()
    {
        $user_id = intval($_REQUEST['user_id']);
        if ($_REQUEST['type']) {
            $model = M('game_distribution');
            $table = DB_PREFIX . 'user u,' . DB_PREFIX . 'game_distribution gd';
            $field = "u.id,u.nick_name,u.head_image,sum(gd.first_distreibution_money * (gd.first_distreibution_id = {$user_id}) + gd.second_distreibution_money * (gd.second_distreibution_id = {$user_id})) as `sum`,gd.is_ticket";
            $where = "(gd.first_distreibution_id = $user_id or gd.second_distreibution_id = $user_id) and u.id = gd.user_id";
            $group = 'u.id,gd.is_ticket';
            $list = $model->table($table)->field($field)->where($where)->group($group)->findAll();
            $this->assign("list", $list);
        } else {
            $map = [
                'user_id' => $user_id,
            ];
            $model = M('game_distribution');
            if (!empty($model)) {
                $this->_list($model, $map);
            }
        }
        $this->assign("user_id", $user_id);
        $this->display();
    }

    //禁游戏
    public function forbid_game()
    {
        $id = intval($_REQUEST['user_id']);

        $open_game = $GLOBALS['db']->getRow("select open_game from " . DB_PREFIX . "user where id =" . $id);
        $where = 'id=' . $id;
        require_once APP_ROOT_PATH . 'mapi/lib/redis/BaseRedisService.php';
        require_once APP_ROOT_PATH . 'mapi/lib/redis/UserRedisService.php';
        $user_redis = new UserRedisService();

        $data['open_game'] = 1;
        $info = '';
        if ($open_game['open_game'] == 1) {
            $data['open_game'] = 0;
            $info = '取消';
        }

        $list = $GLOBALS['db']->autoExecute(DB_PREFIX . "user", $data, 'UPDATE', $where);

        if ($list !== false) {
            $user_redis->update_db($id, $data);
            $this->success($info . '禁游戏成功', 1);

        } else {
            $this->error($info . '禁游戏成功', 1);
        }
    }

    //禁付费
    public function forbid_pay()
    {
        $id = intval($_REQUEST['user_id']);

        $open_game = $GLOBALS['db']->getRow("select open_pay from " . DB_PREFIX . "user where id =" . $id);
        $where = 'id=' . $id;
        require_once APP_ROOT_PATH . 'mapi/lib/redis/BaseRedisService.php';
        require_once APP_ROOT_PATH . 'mapi/lib/redis/UserRedisService.php';
        $user_redis = new UserRedisService();

        $data['open_pay'] = 1;
        $info = '';
        if ($open_game['open_pay'] == 1) {
            $data['open_pay'] = 0;
            $info = '取消';
        }

        $list = $GLOBALS['db']->autoExecute(DB_PREFIX . "user", $data, 'UPDATE', $where);

        if ($list !== false) {
            $user_redis->update_db($id, $data);
            $this->success($info . '禁付费成功', 1);

        } else {
            $this->error($info . '禁付费成功', 1);
        }
    }

    //禁竞拍
    public function forbid_auction()
    {
        $id = intval($_REQUEST['user_id']);

        $open_game = $GLOBALS['db']->getRow("select open_auction from " . DB_PREFIX . "user where id =" . $id);
        $where = 'id=' . $id;
        require_once APP_ROOT_PATH . 'mapi/lib/redis/BaseRedisService.php';
        require_once APP_ROOT_PATH . 'mapi/lib/redis/UserRedisService.php';
        $user_redis = new UserRedisService();

        $data['open_auction'] = 1;
        $info = '';
        if ($open_game['open_auction'] == 1) {
            $data['open_auction'] = 0;
            $info = '取消';
        }

        $list = $GLOBALS['db']->autoExecute(DB_PREFIX . "user", $data, 'UPDATE', $where);

        if ($list !== false) {
            $user_redis->update_db($id, $data);
            $this->success($info . '禁竞拍成功', 1);

        } else {
            $this->error($info . '禁竞拍成功', 1);
        }
    }
}

?>