<?php

namespace app\agent\model;

use app\agent\model\page\Page as PageModel;
use app\common\model\shop\Agent as AgentModel;
use app\common\model\agent\User as AgentUser;
use app\agent\model\user\Grade as GradeModel;
use app\common\model\agent\BalanceLog as BalanceLogModel;
use app\common\model\agent\LoginLog as LoginLogModel;
use app\common\model\agent\Client as ClientModel;

use Workerman\Events\Select;
use xin\helper\Func;

class Agent extends AgentModel
{
    /**
     * 获取小程序列表
     */
    public function getList($limit, $is_recycle = false)
    {
		$agent_id=self::$agent_id;
		$data = $this->alias('agent')->field(['agent.*,user.user_name'])->where('is_recycle', '=', (int)$is_recycle)
		    ->join('dlagent_user user', 'user.agent_id = agent.agent_id','left')
			->where('agent.parent_id', '=', $agent_id)
		    ->where('user.is_super', '=', 1)
		    ->where('agent.is_delete', '=', 0)
			->order(['create_time' => 'asc'])
		    ->paginate($limit);
		  $data->each(function($item,$key){
			  $item['lastlogin_time']=$this->getlastLogin($item['agent_id']);
			  $item['client_num']=$this->getClinetTotal($item['agent_id']);
		 });
		return $data;
    }

    /**
     * 新增记录
     */
    public function add($data)
    {
        if ($data['password'] !== $data['password_confirm']) {
            $this->error = '确认密码不正确';
            return false;
        }
		if (AgentUser::checkExist($data['user_name'])) {
		    $this->error = '代理商用户名已存在';
		    return false;
		}
        $this->startTrans();
        try {
            // 添加小程序记录
			$data['parent_id']=self::$agent_id;
            $this->save($data);
		   // 新增商家用户信息
		   $AgentUser = new AgentUser;
		   if (!$AgentUser->dladd($this['agent_id'], $data)) {
			   $this->error = $AgentUser>error;
			   return false;
		   }
		   // // 新增应用diy配置
		   // (new PageModel)->insertDefault($this['agent_id']);
		   // // 默认等级
		   // (new GradeModel)->insertDefault($this['agent_id']);
            $this->commit();
            return true;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }

    /**
     * 修改记录
     */
    public function edit($data)
    {
        $this->startTrans();
        try {
            $save_data = [
                'agent_name' => $data['agent_name'],
				'agent_phone' => $data['agent_phone'],
				'email' => $data['email'],
				'duetime'=>$data['duetime']
            ];
            $this->save($save_data);
            
			$user_data = [
			    'user_name' => $data['user_name']
			];
			if (!empty($data['password'])) {
			    $user_data['password'] = salt_hash($data['password']);
			}
			$agent_user = (new AgentUser())->where('agent_id', '=', $this['agent_id'])->where('is_super', '=', 1)->find();
			if($agent_user['user_name'] != $data['user_name']){
			    if (AgentUser::checkExist($data['user_name'])) {
			        $this->error = '代理商用户名已存在';
			        return false;
			    }
			}
			 
			$agent_user->save($user_data);
			
            $this->commit();
            return true;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }
    /**
     * 移入移出回收站
     */
    public function recycle($is_recycle = true)
    {
        return $this->save(['is_recycle' => (int)$is_recycle]);
    }

    /**
     * 软删除
     */
    public function setDelete()
    {
        return $this->save(['is_delete' => 1]);
    }
	
	/**
	 * 用户充值
	 */
	public function recharge($storeUserName, $source, $data)
	{
	    if ($source == 0) {
	        return $this->rechargeToBalance($storeUserName, $data['balance']);
	    } elseif ($source == 1) {
	        return $this->rechargeToPoints($storeUserName, $data['points']);
	    }
	    return false;
	}
	
	/**
	 * 用户充值：余额
	 */
	private function rechargeToBalance($storeUserName, $data)
	{
	    if (!isset($data['money']) || $data['money'] === '' || $data['money'] < 0) {
	        $this->error = '请输入正确的金额';
	        return false;
	    }
	    // 判断充值方式，计算最终金额
	    $money = 0;
	    if ($data['mode'] === 'inc') {
	        $diffMoney = $this['balance'] + $data['money'];
	        $money = $data['money'];
	    } elseif ($data['mode'] === 'dec') {
	        $diffMoney = $this['balance'] - $data['money'] <= 0 ? 0 : $this['balance'] - $data['money'];
	        $money = -$data['money'];
	    } else {
	        $diffMoney = $data['money'];
	        $money = $diffMoney - $this['balance'];
	    }
	    // 更新记录
	    $this->transaction(function () use ($storeUserName, $data, $diffMoney, $money) {
	        // 更新账户余额
	        $this->where('agent_id', '=', $this['agent_id'])->update(['balance' => $diffMoney]);
	        // 新增余额变动记录
	        BalanceLogModel::add(30, [
	            'agent_id' => $this['agent_id'],
	            'money' => $money,
	            'remark' => $data['remark'],
	        ], [$storeUserName]);
	    });
	    return true;
	}
	//
	/**
	 * 获取最后登录时间
	 */
	public function getlastLogin($agent_id)
	{
	    $model = new LoginLogModel;
	    
	    $model = $model->where('agent_id', '=', $agent_id)->order(['create_time' => 'desc'])->find();
	   
	    return $model['create_time'];
	}
	//获取客户总数
	public function getClinetTotal($agent_id){
		$ClientModel = new ClientModel;
		$list = $ClientModel->where('agent_id','=',$agent_id)->where('is_delete', '=', 0)->select();
		//dd($agent_id);
		return count($list);
	}
	
	//获取余额
	public function getBalanceTotal($agent_id){
		$balance = $this->where('agent_id','=',$agent_id)->where('is_delete', '=', 0)->find();
		//dd($agent_id);
		return $balance['balance'];
	}
  //获取下级代理商总数
	public function getAgentTotal($agent_id){
		$list = $this->where('parent_id','=',$agent_id)->where('is_delete', '=', 0)->select();
		return count($list);
	}
	//获取余额变动
	public function getBalanceByDay($agent_id){
		$list = [];
		$balancelog = new BalanceLogModel;
		$today = strtotime(date('Y-m-d'));
		$list['tday'] = $balancelog
				->where('agent_id','=',$agent_id)->where('create_time','>=',$today)
				->sum('money');
		$list['ytd'] = $balancelog
				->where('agent_id','=',$agent_id)->where('create_time','<',$today)
				->where('create_time','>=',$today - 86400)
				->sum('money');
		$list['tday'] = number_format($list['tday']);
		$list['ytd'] = number_format($list['ytd']);
		return $list;
	}
}