<?php

namespace app\api\logic;
use app\common\logic\Basic as BasicLogic;
use app\common\model\User as ModelUser;
use app\common\model\user\Third as ModelThird;
use app\common\model\UserLevel as ModelUserLevel;
use app\common\model\user\Levellog as ModelLevellog;
use think\Db;
use fast\Http;
use app\api\logic\commission\Tb as LogicTb;
use app\api\logic\commission\Jd as LogicJd;
use app\api\logic\commission\Pdd as LogicPdd;
use app\api\logic\commission\Wph as LogicWph;
use app\api\logic\commission\Jtk as LogicJtk;
use app\api\logic\commission\Dy as LogicDy;
use app\api\logic\SettlementRecord as LogicSettlementRecord;
use app\common\model\user\Settlement as ModelSettlementRecord;


class User extends BasicLogic
{

    protected $model;

    protected function initialize()
    {
        $this->model = new ModelUser();
    }


    /**
     * 获取数据库用户信息
     *
     * @return void
     */
    public function getUser($user_id)
    {
        if(empty($user_id)) return [];
        return $this->model->where(['id'=>$user_id])->find();
    }

      /**
     * 获取用户绑定信息
     *
     * @param [type] $openid
     * @return void
     */
    public function getWxBind($user_id,$type)
    {
        $ModelThird = new ModelThird();
        $find = $ModelThird->where(['user_id'=>$user_id,'platform'=>$type])->find();
        return empty($find) ? 0 : 1;
    }

    /**
     * 绑定微信
     *
     * @param [type] $user_id
     * @param [type] $avatar
     * @param [type] $gender
     * @param [type] $nickName
     * @param [type] $openId
     * @return void
     */
    public function bindWechat($user_id,$avatar,$gender,$nickName,$openId){
        $ModelThird = new ModelThird();
        $find = $ModelThird->where(['platform'=>'wechat','user_id'=>$user_id])->find();
        if(!empty($find)) fault('当前微信已被绑定');
        Db::startTrans();
        $save_data = [
            'user_id' => $user_id,
            'platform' => 'wechat',
            'openname' => $nickName,
            'openid' => $openId,
            'create_time' =>time()
        ];
        $res = $ModelThird->insert($save_data);
        if(!$res){
            Db::rollback();
            fault('绑定失败');
        }
        $user = $this->model->where(['id' => $user_id])->find();
        $user_data = [];
        if(empty($user['avatar'])) $user['avatar'] = $avatar;
        if(!empty($user_data)){
            $user['updatetime'] = time();
            $res2 = $this->model->where(['id'=>$user_id])->update($user_data);
            if(!$res2){
                Db::rollback();
                fault('绑定失败');
            }
        }
        Db::commit();
        return true;
    }


    /**
     * 解绑微信
     *
     * @return void
     */
    public function unboundWechat($user_id)
    {
        $ModelThird = new ModelThird();
        $find = $ModelThird->where(['user_id'=>$user_id])->find();
        if(empty($find)) fault('当前账户暂未绑定微信');
        $res = $ModelThird->where(['user_id'=>$user_id])->delete();
        if(!$res) fault('解绑失败，请稍后再试');
        return true;
    }


    /**
     * 获取用户ID
     *
     * @param [type] $openid
     * @return void
     */
    public function getUserByOpenId($openid)
    {
        $ModelThird = new ModelThird();
        $find = $ModelThird->where(['openid'=>$openid])->find();
        return empty($find) ? [] : $find['user_id'];
    }
    

    /**
     * 根据用户openI和access_token获取用户信息
     *
     * @param [type] $openid
     * @param [type] $access_token
     * @return void
     */
    public function getWxUserByOpenId($openid,$access_token)
    {
        $get_user_info_url =  'https://api.weixin.qq.com/sns/userinfo?access_token='.$access_token.'&openid='.$openid.'&lang=zh_CN'; 
        $Http = new Http();
        $result = $Http->get($get_user_info_url);
        if(empty($result)) fault('微信授权失败');
        return json_decode($result,true);
    }


    /**
     * 用户等级申请
     *
     * @return void
     */
    public function levelApply($user_id)
    {
        $user = $this->getUser($user_id);
        if(empty($user)) fault('用户信息获取失败');
        if($user['level'] == 3) fault('您已经是最高等级');
        //获取下一级升级条件
        $ModelUserLevel = new ModelUserLevel();
        $next_level = $user['level']+1;
        $levelInfo = $ModelUserLevel->where(['level'=>$next_level,'status'=>1])->find();
        if(empty($levelInfo)) fault('等级信息获取失败');
        if($next_level == 1){
            if(empty($user['invitation_code'])) fault('暂未满足升级条件');
        }else if($next_level > 1){
            $user_zscj_num = $this->model->where(['invitation_id'=>$user_id,'level'=>1])->count(); //直属初级人数
            $user_jjcj_num = $this->model->where(['f_invitation_id'=>$user_id,'level'=>1])->count(); //间接初级人数
            $user_zszj_num = $this->model->where(['invitation_id'=>$user_id,'level'=>2])->count(); //直属中级人数
            $user_jjzj_num = $this->model->where(['f_invitation_id'=>$user_id,'level'=>2])->count(); //间接中级人数
            $user_monthly_commission = self::getUserCommission($user_id,'month'); //获取上月天佣金
            $user_total_commission = self::getUserCommission($user_id,'total'); //获取累计佣金
            if($next_level == 2){
                if($user_zscj_num < $levelInfo['direct_primary_count'] || $user_jjcj_num < $levelInfo['indirect_primary_count'] || $user_monthly_commission < $levelInfo['own_monthly_commission']) fault('暂未满足升级条件');
            }else if($next_level == 3){
                if($user_zszj_num < $levelInfo['direct_intermediate_count'] || $user_jjzj_num < $levelInfo['indirect_intermediate_count'] || $user_monthly_commission < $levelInfo['own_monthly_commission'] || $user_total_commission < $levelInfo['accumulated_commission']) fault('暂未满足升级条件');
            }else{
                fault('不符合升级规则');
            }
        }
        //满足升级条件，更新用户等级
        $ModelLevellog = new ModelLevellog();
        Db::startTrans();
        try{
            $user_data = [
                'level' => $next_level,
                'updatetime' => time()
            ];
            $this->model->where(['id'=>$user['id']])->update($user_data);
            $level_log = [
                'user_id' => $user['id'],
                'old_level' => $user['level'],
                'new_level' => $next_level,
                'type' => 'self',
                'create_time' => time()
            ];
            $ModelLevellog->insert($level_log);
            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            fault('升级错误，请联系管理员');
        }
        return true;
    }

    /**
     * 获取用户对应时间段的佣金金额
     *
     * @return void
     */
    public static function getUserCommission($user_id,$time_type="month")
    {
        if(!in_array($time_type,['month','total']));
        $ModelSettlementRecord = new ModelSettlementRecord();
        $obj = $ModelSettlementRecord->where(['user_id'=>$user_id]);
        if($time_type =="month"){ //获取上月
            $obj->whereTime('create_time','last month');
        }
        $total = $obj->sum("change_money");
        return empty($total) ? 0 : $total;
    }


    public function getProfit($user_id,$type,$is_user=false)
    {
        $time_type = "";
        switch($type){
            case 0:
                $time_type = 'today';
                break;
            case 1:
                $time_type = 'yesterday';
                break;
            case 2:
                $time_type = 'month';
                break; 
            case 3:
                $time_type = 'last month';
                break;      
        }
        if(empty($time_type)) return false;
        $LogicTb = new LogicTb();
        $LogicJd = new LogicJd();
        $LogicPdd = new LogicPdd();
        $LogicWph = new LogicWph();
        $LogicJtk = new LogicJtk();
        $LogicDy = new LogicDy();
        $LogicSettlementRecord = new LogicSettlementRecord();
        //自购
        $tb = $LogicTb->getEstimateCommission($user_id,$time_type,1);
        $jd = $LogicJd->getEstimateCommission($user_id,$time_type,1);
        $pdd = $LogicPdd->getEstimateCommission($user_id,$time_type,1);
        $wph = $LogicWph->getEstimateCommission($user_id,$time_type,1);
        $jtk = $LogicJtk->getEstimateCommission($user_id,$time_type,1);
        $dy = $LogicDy->getEstimateCommission($user_id,$time_type,1);
        if(!$is_user){
            //团队
            $tb_team = $LogicTb->getEstimateCommission($user_id,$time_type,0);
            $jd_team = $LogicJd->getEstimateCommission($user_id,$time_type,0);
            $pdd_team = $LogicPdd->getEstimateCommission($user_id,$time_type,0);
            $wph_team = $LogicWph->getEstimateCommission($user_id,$time_type,0);
            $jtk_team = $LogicJtk->getEstimateCommission($user_id,$time_type,0);
            $dy_team = $LogicDy->getEstimateCommission($user_id,$time_type,0);
        }
        $data = [
            'sumMoney' => $LogicSettlementRecord->totalMoney($user_id),
            'my'=>[
                'order_num' => $tb['order_num']+$jd['order_num']+$pdd['order_num']+$wph['order_num']+$dy['order_num']+$jtk['order_num'],
                'money' => $tb['money']+$jd['money']+$pdd['money']+$wph['money']+$dy['money']+$jtk['money'],
                'sales_volume' => $tb['sales_volume']+$jd['sales_volume']+$pdd['sales_volume']+$wph['sales_volume']+$dy['sales_volume']+$jtk['sales_volume'],
            ],
            'myData' => [$tb,$jd,$pdd,$wph,$dy,$jtk]
        ];
        if(!$is_user){
            $data['team'] = [
                'order_num' => $tb_team['order_num']+$jd_team['order_num']+$pdd_team['order_num']+$wph_team['order_num']+$dy_team['order_num']+$jtk_team['order_num'],
                'money' => $tb_team['money']+$jd_team['money']+$pdd_team['money']+$wph_team['money']+$dy_team['money']+$jtk_team['money'],
                'sales_volume' => $tb_team['sales_volume']+$jd_team['sales_volume']+$pdd_team['sales_volume']+$wph_team['sales_volume']+$dy_team['sales_volume']+$jtk_team['sales_volume'],
            ];
            $data['teamData'] = [$tb_team,$jd_team,$pdd_team,$wph_team,$dy_team,$jtk_team];
            $data['team']['money'] = floor($data['team']['money']*100)/100;
            $data['team']['sales_volume'] = floor($data['team']['sales_volume']*100)/100;
            $data['team']['money'] = round($data['team']['money'],2);
        }
        $data['my']['money'] = round($data['my']['money'],2);
        $data['my']['sales_volume'] = floor($data['my']['sales_volume']*100)/100;
        return $data;

    }

}