<?php
namespace App\DAO;

use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use App\{Users, PrizePool, Setting};
use App\DAO\PrizePool\CandySender;
use App\Events\RealNameEvent;

class UserDAO
{
    /**
     * 检查是否符合升级工作室条件,若符合自动升级
     *
     * @param App\Users $user
     * @return boolean
     */
    public static function checkUpgradeAtelierCondition(&$user) : bool
    {
        $user->refresh();
        //检查自身是否已实名或已经是工作室
        if ($user->is_realname != 2 || $user->is_atelier == 1) {
            return false;
        }
        $upgrade_atelier_must_has_son = Setting::getValueByKey('upgrade_atelier_must_has_son'); //升级工作室直推实名人数要求
        $upgrade_atelier_must_team_son = Setting::getValueByKey('upgrade_atelier_must_team_son'); //升级工作室团队实名人数要求
        $upgrade_atelier_must_team_recharge = Setting::getValueByKey('upgrade_atelier_must_team_recharge'); //升级工作室团队充值金额
        //检查直推实名人数
        if ($user->zhitui_real_number < $upgrade_atelier_must_has_son) {
            return false;
        }
        //检查团队实名人数
        if ($user->real_teamnumber < $upgrade_atelier_must_team_son) {
            return false;
        }
        //检查团队充值金额
        if ($user->top_upnumber < $upgrade_atelier_must_team_recharge) {
            return false;
        }
        $user->is_atelier = 1;
        return $user->save();
    }

    /**
     * 检查用户的上级是否有通证变动
     * @param App\Users $user 用户查询的对象
     */
    public static function addCandyNumber($user)
    {
        $parents = self::getParentsPathDesc($user);
        foreach ($parents as $key => $user_id) {
            $current_user = Users::find($user_id);//检查该上级是否实名认证过
            if ($current_user->is_realname == 2) {
                //该上级实名认证过
                self::checkUserRealNameReward($current_user); //检查是否符合发奖条件，符合就发放奖励
                self::checkUpgradeAtelierCondition($current_user); //检查是否符合升级工作室条件
            } else {
                //该上级还没实名认证
                continue;
            }
        }
    }

    /**
     * 检测用户是否符合实名奖励
     *
     * @param App\Users $user
     * @return bool
     */
    public static function checkUserRealNameReward(&$user)
    {
        if (!$user) {
            return false;
        }
        //获取setting值
        $real_name_candy = Setting::getValueByKey('real_name_candy', '');
        $zhitui2_number = Setting::getValueByKey('zhitui2_number', '');
        $zhitui2_candy = Setting::getValueByKey('zhitui2_candy', '');
        $zhitui3_number = Setting::getValueByKey('zhitui3_number', '');
        $zhitui3_real_teamnumber = Setting::getValueByKey('zhitui3_real_teamnumber', '');
        $zhitui3_top_upnumber = Setting::getValueByKey('zhitui3_top_upnumber', '');
        $zhitui3_candy = Setting::getValueByKey('zhitui3_candy', '');
        $zhitui4_number = Setting::getValueByKey('zhitui4_number', '');
        $zhitui4_real_teamnumber = Setting::getValueByKey('zhitui4_real_teamnumber', '');
        $zhitui4_top_upnumber = Setting::getValueByKey('zhitui4_top_upnumber', '');
        $zhitui4_candy = Setting::getValueByKey('zhitui4_candy', '');
        $zhitui5_number = Setting::getValueByKey('zhitui5_number', '');
        $zhitui5_real_teamnumber = Setting::getValueByKey('zhitui5_real_teamnumber', '');
        $zhitui5_top_upnumber = Setting::getValueByKey('zhitui5_top_upnumber', '');
        $zhitui5_candy = Setting::getValueByKey('zhitui5_candy', '');
        $zhitui6_number = Setting::getValueByKey('zhitui6_number', '');
        $zhitui6_real_teamnumber = Setting::getValueByKey('zhitui6_real_teamnumber', '');
        $zhitui6_top_upnumber = Setting::getValueByKey('zhitui6_top_upnumber', '');
        $zhitui6_candy = Setting::getValueByKey('zhitui6_candy', '');

        $only = 1;
        $user->refresh();
        $push_status = $user->push_status;

        //实名认证过的有效直推人数
        $real_zhitui = Users::where("is_realname", 2)
            ->where("parent_id", $user->id)
            ->count();
        
        $user->zhitui_real_number = $real_zhitui ?: 0; //更新直推实名人数
        $user->real_teamnumber += 1;

        if ($push_status == 1) {
            if ($real_zhitui >= $zhitui2_number) {
                $user->candy_number += $zhitui2_candy;
                $user->push_status = 2;
                $log_candy_number = $zhitui2_candy;
                $only = 2;
            }
        } elseif ($push_status == 2) {
            if ($real_zhitui >= $zhitui3_number && $user->real_teamnumber >= $zhitui3_real_teamnumber && $user->top_upnumber >= $zhitui3_top_upnumber) {
                $user->candy_number += $zhitui3_candy;
                $user->push_status = 3;
                $log_candy_number = $zhitui3_candy;
                $only = 2;
            }
        } elseif ($push_status == 3) {
            if ($real_zhitui >= $zhitui4_number && $user->real_teamnumber >= $zhitui4_real_teamnumber && $user->top_upnumber >= $zhitui4_top_upnumber) {
                $user->candy_number += $zhitui4_candy;
                $user->push_status = 4;
                $log_candy_number = $zhitui4_candy;
                $only = 2;
            }
        } elseif ($push_status == 4) {
            if ($real_zhitui >= $zhitui5_number && $user->real_teamnumber >= $zhitui5_real_teamnumber && $user->top_upnumber >= $zhitui5_top_upnumber) {
                $user->candy_number += $zhitui5_candy;
                $user->push_status = 5;
                $log_candy_number = $zhitui5_candy;
                $only = 2;
            }
        } elseif ($push_status == 5) {
            if ($real_zhitui >= $zhitui6_number && $user->real_teamnumber >= $zhitui6_real_teamnumber && $user->top_upnumber >= $zhitui6_top_upnumber) {
                $user->candy_number += $zhitui6_candy;
                $user->push_status = 6;
                $log_candy_number = $zhitui6_candy;
                $only = 2;
            }
        }
        try {
            DB::beginTransaction();
            //当天新增实名认证团队人数
            $beginToday=mktime(0,0,0,date('m'),date('d'),date('Y'));
            if($user->new_isreal_time<$beginToday)
            {
                $user->today_real_teamnumber=1;
            }
            else
            {
                $user->today_real_teamnumber=$user->today_real_teamnumber+1;
            }
            $user->new_isreal_time=time();



            $result = $user->save();
            if (!$result) {
                throw new \Exception('用户' . $user->account_number . '更新信息失败');
            }
            //开始记录日志
            if ($only == 2) {
                $prize_pool = new PrizePool();
                $prize_pool->scene = PrizePool::CERTIFICATION;//const CERTIFICATION = 1; //实名认证奖励
                $prize_pool->reward_type = PrizePool::REWARD_CANDY;//const REWARD_CANDY = 0; //奖励通证
                $prize_pool->reward_qty = $log_candy_number;
                $prize_pool->from_user_id = $user->id;
                $prize_pool->to_user_id = $user->id;
                $prize_pool->status = 1;
                $prize_pool->memo = '下级直推' . $real_zhitui . '人，实名认证团队' . $user->real_teamnumber . '人，充值金额' . $user->top_upnumber . '美金，触发通证奖励' . $log_candy_number;
                $prize_pool->create_time = time();
                $prize_pool->receive_time = time();
                $result = $prize_pool->save();
                if (!$result) {
                    throw new \Exception('用户' . $user->account_number . '奖励记录失败');
                }
            }
            DB::commit();
            return true;
        } catch (\Exception $e) {
            DB::rollBack();
            return false;
        }
    }

    /**
     * 取用户的上级工作室
     *
     * @param App\Users $user
     * @return App\Users||null
     */
    public static function getParentsAtelier($user)
    {
        $parents = UserDAO::getParentsPathDesc($user);
        //将所有上级工作室查出来
        $parent_atelier = Users::where('is_atelier', 1)
            ->whereIn('id', $parents)
            ->get();
        if (count($parent_atelier) <= 0) {
            return $parent_atelier;
        }
        $parents_sort = array_flip($parents);
        //检测有没有达到封页
        $sorted = $parent_atelier->sortBy(function ($item, $key) use ($parents_sort) {
            $sort = $parents_sort[$item->id];
            return $sort;
        });
        $sorted = $sorted->values();
        return $sorted;
    }

    //递归查询用户下级所有人数
    public function GetTeamMember($members, $mid)
    {
        $Teams = array();//最终结果
        $mids = array($mid);//第一次执行时候的用户id
        do {
            $othermids = array();
            $state = false;
            foreach ($mids as $valueone) {
                foreach ($members as $key => $valuetwo) {
                    if ($valuetwo['parent_id'] == $valueone && $valuetwo['is_realname'] == 2) //实名认证通过的团队人数
                    {
                        $Teams[] = $valuetwo['id'];//找到我的下级立即添加到最终结果中
                        $othermids[] = $valuetwo['id'];//将我的下级id保存起来用来下轮循环他的下级
                        //                        array_splice($members,$key,1);//从所有会员中删除他
                        $state = true;
                    }
                }
            }
            $mids = $othermids;//foreach中找到的我的下级集合,用来下次循环
        } while ($state == true);
        $Teams = Users::whereIn("id", $Teams)->where("is_realname", "=", 2)->count();

        return $Teams;
    }

    /**
     * 更新用户团队充值业绩金额
     * @param integer $id 用户的id值，用于查询更新该用户上级的团队充值金额
     * @return $number 充值金额值
     * * @param integer $qty 要取的上级代数,不传或传null则取全部
     */
    public static function updateTopUpnumber($id, $number, $qty = null)
    {
        $user = Users::find($id);
        $parents = self::getParentsPathDesc($user, $qty);
        $result = Users::whereIn('id', $parents)->increment('top_upnumber', $number);
        //此处应再遍历检查一下$parents是否符合升级条件
        foreach ($parents as $key => $current_user_id) {
            $current_user = Users::find($current_user_id);
            if (!$current_user) {
                continue;
            }
            self::checkUserRealNameReward($current_user);
            self::checkUpgradeAtelierCondition($current_user);
        }
        return $result;
    }


    /**
     * 查询用户的指定代数的上级(根据parents_path信息)
     *
     * @param App\Users $user 用户模型实例
     * @param integer $qty 要取的上级代数,不传或传null则取全部
     * @return array 返回包含上级id的数组
     */
    public static function getParentsPathDesc($user, $qty = null)
    {
        $path = $user->parents_path;
        if ($path == null || empty($path)) {
            return [];
        }
        $parents = explode(',', $path);
        $parents = array_filter($parents);
        krsort($parents);
        $parents = array_slice($parents, 0, $qty);
        return $parents;
    }

    /**
     * 递归查询上级
     *
     * @param App\Users $user 用户模型实例
     * @return array
     */
    public static function getRealParents($user)
    {
        $found_parent_node = [];
        $parents = self::findParent($user, $found_parent_node);
        return $parents;
    }

    /**
     * 递归查询上级(字符串)
     *
     * @param App\Users $user 用户模型实例
     * @return string 返回逗号间隔的path
     */
    public static function getRealParentsPath($user)
    {
        $parents = self::getRealParents($user);
        if (count($parents) > 0) {
            return implode(',', $parents);
        }
        return '';
    }

    private static function findParent($user, &$found_parent_node)
    {
        $parent_id = $user->parent_id;

        if ($parent_id) {
            //检测节点关系是否有死循环
            if (in_array($parent_id, $found_parent_node)) {
                $context = [
                    'user_id' => $user->id,
                    'parent_id' => $parent_id,
                    'found_parent_node' => $found_parent_node,
                ];
                //记录错误日志
                Log::useDailyFiles(base_path('storage/logs/user/'), 7);
                Log::critical('id:' . $user->id . '的用户,上级关系存在死循环', $context);
                return [];
            }
            array_unshift($found_parent_node, $parent_id);
            $parent = Users::find($parent_id);
            $result = self::findParent($parent, $found_parent_node);
            unset($parent);
            array_push($result, $parent_id);
            return $result;
        } else {
            return [];
        }
    }

    /**
     * 检查用户是否符合对应级别的升级,若符合就升级(不降级)
     *
     * @param App\Users $user 要升级的用户模型实例
     * @param App\Users $from_user 触发者用户模型实例
     * @return void 无返回值
     */
    public static function upgradeCheck($user)
    {
        $before_level = $user->level_id;
        $new_level = 2;
        if ($user->is_disable == 1) {
            $new_level = 1;
        } else if ($user->total_integral >= 1000000) {
            $new_level = 5;
        } else if ($user->total_topup >= 10000) {
            $new_level = 4;
        } else if ($user->total_topup >= 300) {
            $new_level = 3;
        }

        //查询等级对应的id
        $level = Level::where('code', $new_level)->first();
        //不掉级处理
        if ($before_level < $new_level) {
            try {
                DB::transaction(function () use ($user, $level, $before_level, $new_level) {
                    $user_upgrade_log = new UserUpgradeLog();
                    $user_upgrade_log->user_id = $user->id;
                    $user_upgrade_log->from_user_id = $user->id;
                    $user_upgrade_log->before_level = $before_level;
                    $user_upgrade_log->after_level = $new_level;
                    $user_upgrade_log->memo = '用户等级变更:由[' . self::get_level_name($before_level) . ']升级到[' . self::get_level_name($new_level) . ']';
                    $user_upgrade_log->created_time = time();
                    $result = $user_upgrade_log->save();
                    if (!$result) {
                        throw new \Exception('记录用户升级日志失败');
                    }
                    $user->level_id = $level->id;
                    $result = $user->save();
                    if (!$result) {
                        throw new \Exception('变更用户等级失败');
                    }
                });
            } catch (\Exception $e) {
                echo '<pre>';
                echo '错误:' . $e->getMessage() . PHP_EOL . ',文件:' . $e->getFile() . PHP_EOL . '行号:' . $e->getLine();
                return;
            }
//            $parent = Users::find($user->parent_id);
//            if ($parent) {
//                self::upgradeCheck($parent, $user);
//            }
        }
    }


    public static function get_level_name($id = 2)
    {

        $name = '';
        switch ($id) {
            case 1:
                $name = '限制会员';
                break;
            case 2:
                $name = '临时会员';
                break;
            case 3:
                $name = '正式会员';
                break;
            case 4:
                $name = '五星会员';
                break;
            case 5:
                $name = 'VIP会员';
                break;
            default:
                $name = '临时会员';
        }

        return $name;
    }
}