<?php
namespace wstmart\admin\model;
use think\Db;
use think\Loader;
/**
 * ============================================================================
 * 会员业务处理
 */
class Users extends Base{
    /**
     * 个体认证审核列表
     * @param int $isPersonal  是否是个体认证
     * @return array
     * @throws \think\exception\DbException
     */
    public function getReview($isPersonal=1){

        if(1 == $isPersonal){
            $m = Db::name('auth_personal a');
        }else{
            $m = Db::name('auth_company a');
        }
        $where=[];
        $loginName = input('post.loginName');
        if($loginName) $where['u.loginName|u.userPhone'] = $loginName;
        $rs = $m->join('__USERS__ u','a.userId=u.userId')
                ->where($where)
                ->field('u.loginName,u.userPhone,a.*')
                ->order('status ASC,createTime ASC')
                ->paginate(input('limit/d'))
                ->toArray();
        return $rs;
    }
    /**个体认证操作
     * @param int $isPersonal 是否是个体认证
     * @return array
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function authAction($isPersonal=1){
        $data = input('post.');
        $id = $data['id'];
        if(1 == $data['status']){
            unset($data['reasonsForRefusal']);
        }
        $field = '*';
        $user_data = [];
        if(1 == $isPersonal){
            $field = 'userId,householdName trueName,userPhone';
            $user_data['authType'] = 1;
            $m = Db::name('auth_personal a');
        }else{
            $user_data['authType'] = 2;
            $field = 'userId,trueName,userPhone';
            $m = Db::name('auth_company a');
        }
        $where['id'] = $id;
        $authInfo = $m->where($where)->field($field)->find();
        if(!$authInfo){
        	return WSTReturn('认证不存在');
        }else{
            if(1 == $data['status']) {
            	$user_data['userPhone'] = $authInfo['userPhone'];
                $user_data['trueName'] = $authInfo['trueName'];
                $user_data['userName'] = $authInfo['trueName'];
            }else{
                $user_data['authType'] = 0;
            }
            Db::name('users')->where(['userId' => $authInfo['userId']])->update($user_data);
        }
        $data['updateTime'] = time();
        $rs = $m->where($where)->update($data);
        if(false !== $rs){

            return WSTReturn('操作成功',1);
        }
        return WSTReturn('操作失败，请重试',-1);
    }
    /**
     * 获取申请列表
     */
    public function getUserUpdateList(){
        $where=[];
        $loginName = input('post.loginName');
        if($loginName) $where['u.loginName|u.userPhone'] = $loginName;
        $rs = Db::name('user_update d')
                    ->join('__USERS__ u','d.userId=u.userId')
                    ->join('__SHOPS__ s','d.shopId=s.shopId')
                    ->where($where)
                    ->field('u.loginName,u.userPhone,u.trueName,s.userName,s.phone,s.shopName,s.provinceId,s.cityId,s.countyId,s.townId,s.villageId,d.userId,d.shopId,d.id,d.applyLevel,d.confirmImg,d.shopImg,d.status,d.reasonsForRefusal,d.createTime,d.updateTime')
                    ->order('status ASC,createTime ASC')
                    ->paginate(input('limit/d'))
                    ->toArray();
        $m = Model('common/Position');
        foreach ($rs['Rows'] as &$v) {
        	$m->initData(1);
        	$v['province'] = $m->getAreaName($v['provinceId']);

        	$m->initData(2);
        	$v['city'] = $m->getAreaName($v['cityId']);

        	$m->initData(3);
        	$v['county'] = $m->getAreaName($v['countyId']);

        	$m->initData(4);
        	$v['town'] = $m->getAreaName($v['townId']);

        	$m->initData(5);
        	$v['village'] = $m->getAreaName($v['villageId']);
        }
        return $rs;
    }
    /**
     * 申请操作
     */
    public function setUserUpdate(){

        $data   = input('post.');
        $id     = $data['id'];
        $applyInfo = Db::name('user_update')->where(['id'=>$id])->field('userId,shopId,applyLevel')->find();
        if(!$applyInfo){
            return WSTReturn('此数据不存在');
        }
        $applyLevel = $applyInfo['applyLevel'];
        if(!in_array($applyLevel,[2,3,4])) return WSTReturn('请正确输入等级！');
        if(1 == $data['status']){
            unset($data['reasonsForRefusal']);
            //店铺位置信息
		    $shopInfo = Model('common/shops')->getFieldsById($applyInfo['shopId'],'provinceId,cityId,countyId,townId,villageId');	
		    $shopInfo = $shopInfo->toArray();	    
			//检查是否已有代理
			$applyArea='';
			switch ($applyLevel) {
				case 2:
					$applyArea = 'countyId';
					break;
				case 3:
					$applyArea = 'townId';
					break;
				case 4:
					$applyArea = 'villageId';
					break;
			}
			if(Db::name('user_update')->where(['status'=>1,'applyLevel'=>$applyLevel,$applyArea=>$shopInfo[$applyArea]])->value('id')){
				 return WSTReturn('当前区域代理已存在');
			}
			$data = array_merge($data,$shopInfo);
        }        
        Db::startTrans();
        try{
            $data['updateTime'] = time();
			if(1 == $data['status']){
				//升级会员等级，没啥用了，留着吧
				$userInfo = getUserInfo(['userId'=>$applyInfo['userId']],'userLevel');
				if($applyLevel > $userInfo['userLevel']){
					Db::name('users')->where(['userId'=>$applyInfo['userId']])->update(['userLevel'=>$applyLevel]);
				}
			}            
            if(false !== Db::name('user_update')->where(['id'=>$id])->update($data)){
               	Db::commit();
            	return WSTReturn('操作成功',1);
            }
            
        }catch (\Exception $e) {
            Db::rollback();errLog($e);
        }
        return WSTReturn('操作失败',-1);

    }
	/**
	 * 分页
	 */
	public function pageQuery(){
		/******************** 查询 ************************/
		$where = [];
		$where['u.dataFlag'] = 1;
		$lName = input('loginName1');
		$phone = input('loginPhone');
		$email = input('loginEmail');
		$uType = input('userType');
		$uStatus = input('userStatus1');
		$sort = input('sort');
		if(!empty($lName))
			$where['loginName|s.shopName'] = ['like',"%$lName%"];
		if(!empty($phone))
			$where['userPhone'] = ['like',"%$phone%"];
		if(!empty($email))
			$where['userEmail'] = ['like',"%$email%"];
		if(is_numeric($uType))
			$where['userType'] = ['=',"$uType"];
		if(is_numeric($uStatus))
			$where['userStatus'] = ['=',"$uStatus"];
		$order = 'u.userId desc';
		if($sort){
			//$sort =  str_replace('.',' ',$sort);
			//$order = $sort;
		}
		/********************* 取数据 *************************/
		$rs = $this->alias('u')->join('__SHOPS__ s','u.userId=s.userId and s.dataFlag=1','left')->join('__USER_TREES__ t','u.userId=t.uid','left')->where($where)
					->field(['u.userId','u.regConfirmImg','loginName','u.userName','userType','userPhone','userEmail','userECT','userScore','u.createTime','u.productNum','u.couponsNum','u.wangNum','userStatus','lastTime','s.shopId','userMoney','u.lockMoney','t.pid'])
					->order($order)
					->group('u.userId')
					->paginate(input('limit/d'))
					->toArray();
		$m = Model('Table');
	    foreach ($rs['Rows'] as &$v) {	 
	    	if($v['pid']){
	    		$m->setTable('users');		
	    		$v['pName'] = $m->getField(['userId'=>$v['pid']],'loginName');
	    	}else{
	    		$v['pName'] = '';
	    	}
			$m->setTable('user_vouchers_summary');
	    	$sInfo = $m->getInfo(['userId'=>$v['userId']],'expectedProductNum,expectedCouponsNum');
	    	$v['expectedProductNum'] = (float)$sInfo['expectedProductNum'];
	    	$v['expectedCouponsNum'] = (float)$sInfo['expectedCouponsNum'];
	    	$r = WSTUserRank($v['userScore']);
	    	$v['rank'] = $r['rankName'];
	    }
		return $rs;
	}
	public function getById($id){
		return $this->get(['userId'=>$id]);
	}
	/**
	 * 新增
	 */
	public function add(){
		$data = input('post.');
		$data['createTime'] = date('Y-m-d H:i:s');
		$data["loginSecret"] = rand(1000,9999);
    	$data['loginPwd'] = md5($data['loginPwd'].$data['loginSecret']);
    	WSTUnset($data,'userId,userType,userScore,userTotalScore,lastIP,lastTime,userMoney,lockMoney,dataFlag,rechargeMoney');
    	Db::startTrans();
		try{
			$result = $this->validate('Users.add')->allowField(true)->save($data);
			$id = $this->userId;
	        if(false !== $result){
	        	hook("adminAfterAddUser",["userId"=>$id]);
	        	WSTUseImages(1, $id, $data['userPhoto']);
	        	Db::commit();
	        	return WSTReturn("新增成功", 1);
	        }
		}catch (\Exception $e) {
            Db::rollback();errLog($e);
            return WSTReturn('新增失败',-1);
        }	
	}
    /**
	 * 编辑
	 */
	public function edit(){
		$Id = (int)input('post.userId');
		$data = input('post.');
		$u = $this->where('userId',$Id)->field('loginSecret')->find();
		if(empty($u))return WSTReturn('无效的用户');
		//判断是否需要修改密码
		if(empty($data['loginPwd'])){
			unset($data['loginPwd']);
		}else{
			//修改联盟登录密码
			$password = $data['loginPwd'];
    		$data['loginPwd'] = md5($data['loginPwd'].$u['loginSecret']);
		}
		Db::startTrans();
		try{
			if(isset($data['userPhoto'])){
			    WSTUseImages(1, $Id, $data['userPhoto'], 'users', 'userPhoto');
			}
			
			WSTUnset($data,'loginName,createTime,userId,userType,userScore,userTotalScore,lastIP,lastTime,userMoney,lockMoney,dataFlag,rechargeMoney');
		    $result = $this->allowField(true)->save($data,['userId'=>$Id]);
	        if(false !== $result){
	        	// 同步修改联盟密码
	        	// if(!empty($password)){
	        	// 	Db::table('rd_users')->where(['shop_id'=>$Id])->setField('password',md5($password));
	        	// }
	        	hook("adminAfterEditUser",["userId"=>$Id]);
	        	Db::commit();
	        	return WSTReturn("编辑成功", 1);
	        }
		}catch (\Exception $e) {
            Db::rollback();errLog($e);
            return WSTReturn('编辑失败',-1);
        }
	}
	/**
     * 查看会员定返数据
     */
	public function viewUserDayData(){

	}
	/**
	 * 充值
	 */
	public function recharge(){
		$userId = (int)input('post.userId');
		$loginName = input('post.loginName');
		$rechargeCurrency = input('post.rechargeCurrency');//充值币种，1为ECT
		$rechargeType = (int)input('post.rechargeType');//1充值0扣除
		$rechargeNum = (float)input('post.rechargeNum');
		if($rechargeNum <=0){
			return WSTReturn('请正确输入充值数量！');
		}
		$rechargeNames = ['0'=>'扣除','1'=>'充值'];
		if(!$rechargeCurrency) return WSTReturn('请正确输入币种！');
		if(!$userId) $userId = $this->where('loginName',$loginName)->value('userId');
		if(!$userId) return WSTReturn('未找到此会员');
		Db::startTrans();
		try{
			switch ($rechargeCurrency) {
				case 1://预获产品券
					Model('common/UserVouchers')->insertVouchersNotice($userId,0,$rechargeNum,0,'系统'.$rechargeNames[$rechargeType],$rechargeType);
					break;
				case 2://预获优惠券
					Model('common/UserVouchers')->insertVouchersNotice($userId,0,0,$rechargeNum,'系统'.$rechargeNames[$rechargeType],$rechargeType);
					break;
				case 3://产品券
				case 4://优惠券
				case 5://旺旺券
					$rechargeCurrency-=2;
					Model('common/LogMoneys')->addMoneyLog(0,$userId,0,2,'系统'.$rechargeNames[$rechargeType],$rechargeType,$rechargeNum,'system',$rechargeCurrency);
					break;
				default:				
					break;
			}
			Db::commit();
	        return WSTReturn("操作成功", 1);
		}catch (\Exception $e) {
            Db::rollback();errLog($e);
            return WSTReturn('操作失败',-1);
        }	
		// if($userId){
		// 	$u = $this->where('userId',$userId)->field('userId,loginSecret,userECT')->find();
		// }else{
		// 	$u = $this->where('loginName',$loginName)->field('userId,loginSecret,userECT')->find();
		// }

		// if(empty($u))return WSTReturn('无效的用户');
		// $userId = $u['userId'];
		// if($rechargeType == 2){//扣除
		// 	if($rechargeCurrency == 1){
		// 		if($u['userECT'] < $rechargeNum ){
		// 			return WSTReturn('余额不足以扣除！当前余额：'.$u['userECT']);	
		// 		}
		// 	}
		// }
		// Db::startTrans();
		// try{
		// 	if($rechargeCurrency == 1){//ECT
		// 		if($rechargeType == 1){//充值
		// 			ectLog($userId,$rechargeNum,10,'',['userECT'=>['exp','userECT+'.$rechargeNum]],1);					
		// 		}else{
		// 			ectLog($userId,$rechargeNum,10,'',['userECT'=>['exp','userECT-'.$rechargeNum]],2);
		// 		}
		// 	}
	 //        Db::commit();
	 //        return WSTReturn("操作成功", 1);
		// }catch (\Exception $e) {
  //           Db::rollback();errLog($e);
  //           return WSTReturn('操作失败',-1);
  //       }
	}
	/**
	 * 删除
	 */
    public function del(){
	    $id = (int)input('post.id');
	    if($id==1){
	    	return WSTReturn('无法删除自营店铺账号',-1);
	    }
	    Db::startTrans();
	    try{
		    $data = [];
			$data['dataFlag'] = -1;
		    $result = $this->update($data,['userId'=>$id]);
	        if(false !== $result){
	        	//删除店铺信息
	        	model('shops')->delByUserId($id);
	        	hook("adminAfterDelUser",["userId"=>$id]);
	        	WSTUnuseImage('users','userPhoto',$id);
	        	Db::commit();
	        	return WSTReturn("删除成功", 1);
	        }
	    }catch (\Exception $e) {
            Db::rollback();errLog($e);
            return WSTReturn('删除失败',-1);
        }
	}
	/**
	* 是否启用
	*/
	public function changeUserStatus($id, $status){
		Db::startTrans();
        try{

        	$this->update(['userStatus'=>(int)$status],['userId'=>(int)$id]);
        	if(0 == $status){
        		$lockTime =(int)input('post.lockTime');
        		$lockReason =input('post.lockReason');
        		Db::name('user_lock')->insert(['userId'=>$id,'lockTime'=>$lockTime,'lockReason'=>$lockReason,'createTime'=>time()]);
        		$this->update(['userStatus'=>(int)$status],['userId'=>(int)$id]);
        	}
			
	    	Db::commit();
			return WSTReturn("操作成功",1); 
        }catch (\Exception $e) {
        	//dump($e);
            Db::rollback();errLog($e);
        }
		return WSTReturn("操作失败，请刷新后再重试"); 
	}
	/**
	* 根据用户名查找用户
	*/
	public function getByName($name){
		return $this->field(['userId','loginName'])->where(['loginName'=>['like',"%$name%"]])->select();
	}
	/**
	* 获取所有用户id
	*/
	public function getAllUserId()
	{
		return $this->where('dataFlag',1)->column('userId');
	}
	/**
	* 重置支付密码
	*/
	public function resetPayPwd(){
		$Id = (int)input('post.userId');
		$loginSecret = $this->where('userId',$Id)->value('loginSecret');
		// 重置支付密码为6个6
		$payPwd = md5('666666'.$loginSecret);
		$result = $this->where('userId',$Id)->setField('payPwd',$payPwd);
		if(false !== $result){
        	return WSTReturn("重置成功", 1);
        }else{
        	return WSTReturn($this->getError(),-1);
        }
	}

	/**
	 * 根据用户账号查找用户信息
	 */
	public function getUserByKey(){
		$key = input('key');
		$user = $this->where(['loginName|userPhone|userEmail'=>['=',$key],'dataFlag'=>1])->find();
        if(empty($user))return WSTReturn('找不到用户',-1);
        $shop = model('shops')->where(['userId'=>$user->userId,'dataFlag'=>1])->find();
        if(!empty($shop))return WSTReturn('该用户已存在关联的店铺信息',-1);
        return WSTReturn('',1,['loginName'=>$user->loginName,'userId'=>$user->userId]);
	}
	/**
	 * 导出订单 --林莉
	 */
	public function toExport(){
		$name="会员管理表";
		$where = [];
		$where['u.dataFlag'] = 1;
		$lName = input('loginName1');
		$phone = input('loginPhone');
		$email = input('loginEmail');
		$uType = input('userType');
		$uStatus = input('userStatus1');
		$sort = input('sort');
		if(!empty($lName))
			$where['loginName|s.shopName'] = ['like',"%$lName%"];
		if(!empty($phone))
			$where['userPhone'] = ['like',"%$phone%"];
		if(!empty($email))
			$where['userEmail'] = ['like',"%$email%"];
		if(is_numeric($uType))
			$where['userType'] = ['=',"$uType"];
		if(is_numeric($uStatus))
			$where['userStatus'] = ['=',"$uStatus"];
		$order = 'u.userId desc';
		/********************* 取数据 *************************/
		$page = db('users')->alias('u')->join('__SHOPS__ s','u.userId=s.userId and s.dataFlag=1','left')->where($where)
				->field(['u.userId','loginName','userName','userType','userPhone','userEmail','userECT','userScore','u.createTime','userStatus','lastTime','s.shopId','userMoney','u.lockMoney'])
				->order($order)
				->select();
		foreach ($page as $key => $v) {
			$r = WSTUserRank($v['userScore']);
			$page[$key]['rank'] = $r['rankName'];
		}
		Loader::import('phpexcel.PHPExcel.IOFactory');
		$objPHPExcel = new \PHPExcel();
		// 设置excel文档的属性
		$objPHPExcel->getProperties()->setCreator("heyuanhui")//创建人
		->setLastModifiedBy("heyuanhui")//最后修改人
		->setTitle($name)//标题
		->setSubject($name)//题目
		->setDescription($name)//描述
		->setKeywords("会员")//关键字
		->setCategory("Test result file");//种类

		// 开始操作excel表
		$objPHPExcel->setActiveSheetIndex(0);
		// 设置工作薄名称
		$objPHPExcel->getActiveSheet()->setTitle(iconv('gbk', 'utf-8', 'Sheet'));
		// 设置默认字体和大小
		$objPHPExcel->getDefaultStyle()->getFont()->setName(iconv('gbk', 'utf-8', ''));
		$objPHPExcel->getDefaultStyle()->getFont()->setSize(11);
		$styleArray = array(
				'font' => array(
						'bold' => true,
						'color'=>array(
								'argb' => 'ffffffff',
						)
				),
				'borders' => array (
						'outline' => array (
								'style' => \PHPExcel_Style_Border::BORDER_THIN,  //设置border样式
								'color' => array ('argb' => 'FF000000'),     //设置border颜色
						)
				)
		);
		//设置宽
		$objPHPExcel->getActiveSheet()->getColumnDimension('A')->setWidth(20);
		$objPHPExcel->getActiveSheet()->getColumnDimension('B')->setWidth(20);
		$objPHPExcel->getActiveSheet()->getColumnDimension('C')->setWidth(20);
		$objPHPExcel->getActiveSheet()->getColumnDimension('D')->setWidth(20);
		$objPHPExcel->getActiveSheet()->getColumnDimension('E')->setWidth(15);
		$objPHPExcel->getActiveSheet()->getColumnDimension('F')->setWidth(15);
		$objPHPExcel->getActiveSheet()->getColumnDimension('G')->setWidth(20);
		$objPHPExcel->getActiveSheet()->getColumnDimension('H')->setWidth(20);
		$objPHPExcel->getActiveSheet()->getColumnDimension('I')->setWidth(15);
		$objPHPExcel->getActiveSheet()->getColumnDimension('J')->setWidth(25);
		$objPHPExcel->getActiveSheet()->getColumnDimension('K')->setWidth(8);
		$objPHPExcel->getActiveSheet()->getColumnDimension('L')->setWidth(8);
		$objPHPExcel->getActiveSheet()->getColumnDimension('M')->setWidth(8);
		$objPHPExcel->getActiveSheet()->getColumnDimension('N')->setWidth(12);
		$objPHPExcel->getActiveSheet()->getColumnDimension('O')->setWidth(8);
		$objPHPExcel->getActiveSheet()->getColumnDimension('P')->setWidth(25);
		$objPHPExcel->getActiveSheet()->getColumnDimension('Q')->setWidth(25);
		$objPHPExcel->getActiveSheet()->getColumnDimension('R')->setWidth(25);
		$objPHPExcel->getActiveSheet()->getColumnDimension('S')->setWidth(35);
		$objPHPExcel->getActiveSheet()->getColumnDimension('T')->setWidth(25);
		$objPHPExcel->getActiveSheet()->getStyle('A1:T1')->getFill()->setFillType(\PHPExcel_Style_Fill::FILL_SOLID);
		$objPHPExcel->getActiveSheet()->getStyle('A1:T1')->getFill()->getStartColor()->setARGB('333399');

		$objPHPExcel->getActiveSheet()
				->setCellValue('A1', '账号')
				->setCellValue('B1', '用户名')
				->setCellValue('C1', '手机号码')
				->setCellValue('D1', '电子邮箱')
				->setCellValue('E1', '可用金额')
				->setCellValue('F1', '冻结金额')
				->setCellValue('G1', '积分')
				->setCellValue('H1', 'ECT')
				->setCellValue('I1', '等级')
				->setCellValue('J1', '注册时间')
				->setCellValue('K1', '状态');
		$objPHPExcel->getActiveSheet()->getStyle('A1:R1')->applyFromArray($styleArray);

		for ($row = 0; $row < count($page); $row++){
			$i = $row+2;
			$objPHPExcel->getActiveSheet()
					->setCellValue('A'.$i, $page[$row]['loginName'])
					->setCellValue('B'.$i, $page[$row]['userName'])
					->setCellValue('C'.$i, $page[$row]['userPhone'])
					->setCellValue('D'.$i, $page[$row]['userEmail'])
					->setCellValue('E'.$i, $page[$row]['userMoney'])
					->setCellValue('F'.$i, $page[$row]['lockMoney'])
					->setCellValue('G'.$i, $page[$row]['userScore'])
					->setCellValue('H'.$i, $page[$row]['userECT'])
					->setCellValue('I'.$i, $page[$row]['rank'])
					->setCellValue('J'.$i, $page[$row]['createTime'])
					->setCellValue('K'.$i, $page[$row]['userStatus']);
		}

		//输出EXCEL格式
		$objWriter = \PHPExcel_IOFactory::createWriter($objPHPExcel, 'Excel5');
		// 从浏览器直接输出$filename
		header('Content-Type:application/csv;charset=UTF-8');
		header("Pragma: public");
		header("Expires: 0");
		header("Cache-Control:must-revalidate, post-check=0, pre-check=0");
		header("Content-Type:application/force-download");
		header("Content-Type:application/vnd.ms-excel;");
		header("Content-Type:application/octet-stream");
		header("Content-Type:application/download");
		header('Content-Disposition: attachment;filename="'.$name.'.xls"');
		header("Content-Transfer-Encoding:binary");
		$objWriter->save('php://output');
	}
}