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

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

class UserRefundAction extends CommonAction{

	/**
	 * 提现审核记录
     */
	public function index()
	{
		//列表过滤器，生成查询Map对象
		$map = $this->_search ();
		$map['_string'] = 'is_pay = 0 and withdrawals_type <> 2 ';
		//公会无抽成模式下显示ljz
		$m_config = load_auto_cache('m_config');
		if($m_config['society_pattern'] == 2){
		    $map['_string'] = 'is_pay = 0';
		}
		//追加默认参数
		if($this->get("default_map"))
		$map = array_merge($map,$this->get("default_map"));
        if(strim($_REQUEST['nick_name'])!=''){//name
            $user=M("User")->where("nick_name like '%".strim($_REQUEST['nick_name'])."%' ")->findAll();
            $user_arr_id = array();
            foreach($user as $k=>$v){
                $user_arr_id[$k] =intval($v['id']);
            }
            //$user_str_id = implode(',',$user_arr_id);
            $map['user_id'] = array('in',$user_arr_id);
        }
        if(intval($_REQUEST['user_id'])>0)
        {
            $map['user_id'] = intval($_REQUEST['user_id']);
        }
		if (method_exists ( $this, '_filter' )) {
			$this->_filter ( $map );
		}
		$name=$this->getActionName();
		$model = D ($name);
		if (! empty ( $model )) {
			$this->_list ( $model, $map );
		}
		$this->display ();
		return;
	}

	public function refund_allow(){
		$id=intval($_REQUEST['id']);
		$status=intval($_REQUEST['status']);
		$refund_data=M("UserRefund")->getById($id);
		$info=array();
		if($status){
			$info['do']='允许';
		}else{
			$info['do']='不允许';
		}
		$this->assign("info",$info);
		$this->assign("refund_data",$refund_data);
		$this->assign("status",$status);
		$this->display ();
	}
	public function refund_go_allow(){
		$id=intval($_REQUEST['id']);
		$status=intval($_REQUEST['status']);
		$refund_data = M("UserRefund")->getById($id);
		$user_id = $refund_data['user_id'];
		if($refund_data)
		{
//			if($refund_data['is_pay']==1)
//			{
//				$this->error("已经允许提现");
//			}

			$reply = strim($_REQUEST['reply']);
			$m_config =  load_auto_cache("m_config");//初始化手机端配置
			$ticket_name = $m_config['ticket_name']!=''?$m_config['ticket_name']:'印票';
			//管理员的SESSION
			$adm_session = es_session::get(md5(conf("AUTH_KEY")));
			$adm_id = intval($adm_session['adm_id']);
			if($status==1){
				//$refund_user = M("User")->where("id=".$refund_data['user_id']." and is_effect = 1")->find();
				/*fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/BaseRedisService.php');
				fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
	        	$user_redis = new UserRedisService();
	        	$refund_user = $user_redis->getRow_db($user_id,array('ticket','diamonds','refund_ticket'));*/
	        	
	        	//修改读取本地mysql 20170118
	        	$refund_user = $GLOBALS['db']->getRow("select ticket,diamonds,refund_ticket from ".DB_PREFIX."user where id=".$user_id);
	        	

				if(intval($refund_user['ticket'])-intval($refund_user['refund_ticket'])<intval($refund_data['ticket']))
				{
					$refund_data['pay_log'] = $m_config['ticket_name']."不足，不能提现";
					$refund_data['is_pay'] = 4;
					M("UserRefund")->save($refund_data);
					$info=$m_config['ticket_name']."不足，不能提现";
				}else{
					//冻结用户提现印票
					$sql = "update ".DB_PREFIX."user set refund_ticket=refund_ticket+".$refund_data['ticket']." where ticket >= refund_ticket + ".$refund_data['ticket']." and id=".$refund_data['user_id'];
					$GLOBALS['db']->query($sql);
					if($GLOBALS['db']->affected_rows()){
						user_deal_to_reids(array($user_id));
						$refund_data['is_pay'] = 1;
						$refund_data['pay_log']="已审核";
						$info="允许操作成功";
						 //写入用户日志
	                    $data = array();
	                    $data['ticket'] = intval($refund_data['ticket']);
	                    $data['log_admin_id'] = intval($adm_id);
	                    $param['type'] = 1;//类型 0表示充值 1表示提现 2赠送道具 3 兑换印票
	                    $log_msg ='冻结提现'.$data['ticket'].$m_config['ticket_name'].'成功';
	                    account_log_com($data,$refund_data['user_id'],$log_msg,$param);
                        save_log($user_id.$log_msg,1);
					}else{
						$refund_data['pay_log']="提现冻结失败";
					}
				}
			}else{
				$refund_data['is_pay'] = 2;
				$refund_data['pay_log']="--";
				$refund_data['partner_trade_no']="--";
				$info="拒绝提现操作成功";
				 //写入用户日志
                $data = array();
                $data['ticket'] = intval($refund_data['ticket']);
                $data['log_admin_id'] = intval($adm_id);
                $param['type'] = 1;//类型 0表示充值 1表示提现 2赠送道具 3 兑换印票
                $log_msg ='提现'.$data['ticket'].$m_config['ticket_name'].',被拒绝';
                account_log_com($data,$refund_data['user_id'],$log_msg,$param);
                save_log($user_id.$log_msg,0);
			}
			$refund_data['reply']=$reply;
			M("UserRefund")->save($refund_data);
			$GLOBALS['msg']->manage_msg('MSG_MONEY_CARRY_RESULT',$refund_data['user_id'],$refund_data);
			$this->success($info);

		}else{
			$this->error("没有提现数据");
		}

	}

	public function delete() {
		//彻底删除指定记录
		$ajax = intval($_REQUEST['ajax']);
		$id = $_REQUEST ['id'];
		if (isset ( $id )) {
				$condition = array ('id' => array ('in', explode ( ',', $id ) ) );
				$rel_data = M(MODULE_NAME)->where($condition)->findAll();
				$list = M(MODULE_NAME)->where ( $condition )->delete();

				foreach($rel_data as $data)
				{
					$info[] = "[id:".$data['id'].",ticket:".$data['ticket']."]";
				}
				if($info) $info = implode(",",$info);

				if ($list!==false) {
					save_log($info."成功删除",1);
					$this->success ("成功删除",$ajax);
				} else {
					save_log($info."删除出错",0);
					$this->error ("删除出错",$ajax);
				}
			} else {
				$this->error (l("INVALID_OPERATION"),$ajax);
		}
	}
	
	public function refund_check() {
        $user_id=intval($_REQUEST['user_id']);
        $sql = "select u.id, u.nick_name, b.`max_ticket` , u.ticket as 'actual_ticket', (u.ticket - b.`max_ticket`) as 'differ',  u.refund_ticket, u.ticket - u.refund_ticket as 'surplus_ticket' from (select to_user_id, sum(total_ticket) as 'max_ticket' from (select to_user_id,sum(total_ticket) as total_ticket from ".DB_PREFIX."video_prop group by to_user_id";

        $table = DB_PREFIX . 'live_pay_log';
        $sql .= $this->refund_check_tablename_exist($table);

        $table = DB_PREFIX . 'live_pay_log_history';
        $sql .= $this->refund_check_tablename_exist($table);

        //家族、分享
        $table = DB_PREFIX . 'user_log';
        $sql .= $this->refund_check_tablename_exist_user_log($table);

        //分销
        $table = DB_PREFIX . 'distribution_log';
        $sql .= $this->refund_check_tablename_exist_distribution_log($table);

        $i = 0;
        do{
            $lastday=date('Ym',strtotime(date('Ym',NOW_TIME)." -".$i." month"));
            $sql1 = $this->refund_check_tablename_exist1($lastday);
            if($sql1!=''){
                $sql .= $sql1;
            }
            $i++;
        }while($sql1!=''&&$i<12);

        $sql .= " ) as a where a.to_user_id group by to_user_id ) b LEFT JOIN ".DB_PREFIX."user u on u.id = b.to_user_id  where u.id=".$user_id." order by (u.ticket - b.`max_ticket`) desc";
        $list = $GLOBALS['db']->getAll($sql);
        foreach ($list as $k => $v) {
        	$list[$k]['nick_name'] = emoji_decode($list[$k]['nick_name']);
        }
        $this->assign("list",$list);
        $this->display ();
	}

    public function refund_check_tablename_exist_distribution_log($table){
        $res = $GLOBALS['db']->getRow("SHOW TABLES LIKE'$table'");
        $sql = '';
        if($res){
            $sql = " UNION ALL select to_user_id,sum(ticket) as total_ticket from ".$table." group by to_user_id";
        }
        return $sql;
    }

    public function refund_check_tablename_exist_user_log($table){
        //区分公会模式显示ljz
        $m_config = load_auto_cache('m_config');
        if($m_config['society_pattern'] == 1){
            $type = 8;
        }elseif($m_config['society_pattern'] == 2){
            $type = 10;
        }else{
            $type = 0;
        }
        $res = $GLOBALS['db']->getRow("SHOW TABLES LIKE'$table'");
        $sql = '';
        if($res){
            $sql = " UNION ALL select user_id as to_user_id,sum(ticket) as total_ticket from ".$table." where type=$type and (log_info like '%获取公会成员%' or log_info like '%产生公会收益%') group by to_user_id";
        }
        return $sql;
    }
	
	public function refund_check_tablename_exist($table) {
    	$res = $GLOBALS['db']->getRow("SHOW TABLES LIKE'$table'");
    	$sql = '';
    	if($res){
    		$sql = " UNION ALL select to_user_id, sum(total_ticket) from ".$table." group by to_user_id";
    	}    	
    	return $sql;
	}
	public function refund_check_tablename_exist1($dayname='') {
        if($dayname==''){
            $dayname = date('Ym',NOW_TIME);
        }
        $table = DB_PREFIX . 'video_prop_' . $dayname;
        if($table!=''){
            $res = $GLOBALS['db']->getRow("SHOW TABLES LIKE'$table'");
        }else{
            $res = 0 ;
        }
        $sql = '';
        if($res){
            $sql = " UNION ALL select to_user_id, sum(total_ticket) from ".$table." where is_red_envelope=0 group by to_user_id";
        }
        return $sql;
	}
}
?>