<?php
/**
 * user
 */

/**
 * @var string $action
 * @var object $CACHE
 */

require_once 'globals.php';

$User_Model = new User_Model();

if($action == 'money_ajax'){
    $user_id = Input::postIntVar('user_id');
    $type = Input::postStrVar('type');
    $money = Input::postStrVar('money');

    if(empty($type)){
        output::error('请选择操作类型');
    }
    if(empty($money) || $money <= 0){
        output::error('请填写正确的金额');
    }

    $db = Database::getInstance();
    $db_prefix = DB_PREFIX;

    $user = $db->once_fetch_array("select * from {$db_prefix}user where uid={$user_id}");

    $blance_insert = [
        'user_id' => UID,
        'money' => $money,
        'update_before' => $user['money'],
        'create_time' => time()
    ];



    if($type == 'inc'){
        $blance_insert['plus'] = 'y';
        $blance_insert['description'] = '客服充值';
        $sql = "update " . DB_PREFIX . "user set money = money + {$money} where uid={$user_id}";
    }else{
        $blance_insert['plus'] = 'n';
        $blance_insert['description'] = '客服扣除';
        $sql = "update " . DB_PREFIX . "user set money = money - {$money} where uid={$user_id}";
    }
    $db->query($sql);
    $db->add('balance_log', $blance_insert);
    output::ok();
}
if ($action == 'money') {
    $uid = isset($_GET['uid']) ? (int)$_GET['uid'] : '';
    $data = $User_Model->getOneUser($uid);
    $money = $data['money'];
    include View::getAdmView('open_head');
    require_once View::getAdmView('user_money');
    include View::getAdmView('open_foot');
    View::output();
}

if (empty($action)) {

    $db_prefix = DB_PREFIX;
    $db = Database::getInstance();


    $br = '<a href="./">控制台</a><a><cite>用户管理</cite></a>';


    $member_list = [];
    $sql = "SELECT * FROM `{$db_prefix}member`";
    $member = $db->fetch_all($sql);
    foreach($member as $val){
        $member_list[] = [
            'name' => $val['name'],
            'id' => $val['id']
        ];
    }
    $member_list[] = [
        'name' => '普通用户',
        'id' => -1
    ];


    include View::getAdmView('header');
    require_once View::getAdmView('user');
    include View::getAdmView('footer');
    View::output();
}

if($action == 'index'){
    $db = Database::getInstance();
    $db_prefix = DB_PREFIX;
    $page = Input::getIntVar('page', 1);
    $limit = Input::getIntVar('limit', 10);
    $keyword = Input::getStrVar('keyword');
    $member_id = Input::getIntVar('member_id', null);
    $start = ($page - 1) * $limit;
    $where = "";
    $sort1 = Input::getStrVar('field', 'uid');
    $sort2 = Input::getStrVar('order', 'desc');
    $order_by = "order by {$sort1} {$sort2}";

    if($member_id !== null){
        $member_id = $member_id == -1 ? 0 : $member_id;
        $where .= " and u.level={$member_id}";
        $member_id = -1;
    }
    if(!empty($keyword)){
        $where .= " and (u.uid='{$keyword}' or u.tel like '%{$keyword}%' or u.nickname like '%{$keyword}%' or u.email like '%{$keyword}%')";
    }

    $sql = "SELECT u.*, m.name level_name FROM {$db_prefix}user u left join " . DB_PREFIX . "member m on u.level=m.id  where 1=1 $where {$order_by} limit $start, {$limit}";
    $res = $db->fetch_all($sql);
    $users = [];
    foreach($res as $row){
        $row['name'] = htmlspecialchars($row['nickname']);
        $row['login'] = htmlspecialchars($row['username']);
        $row['email'] = htmlspecialchars($row['email']);
        $row['description'] = htmlspecialchars($row['description']);
        $row['create_time'] = smartDate($row['create_time']);
        $row['update_time'] = smartDate($row['update_time']);
        $row['role'] = User::getRoleName($row['role'], (int)$row['uid']);
        $row['level_name'] = empty($row['level_name']) ? '普通用户' : $row['level_name'];
        $users[] = $row;
    }

    $sql = "SELECT count(u.uid) total FROM {$db_prefix}user u left join " . DB_PREFIX . "member m on u.level=m.id  where 1=1 $where";
    $res = $db->once_fetch_array($sql);
    $userCount = $res['total'];

    output::data($users, $res['total']);
}

if ($action == 'new') {
    $email = isset($_POST['email']) ? addslashes(trim($_POST['email'])) : '';
    $password = isset($_POST['password']) ? addslashes(trim($_POST['password'])) : '';
    $password2 = isset($_POST['password2']) ? addslashes(trim($_POST['password2'])) : '';
    $role = isset($_POST['role']) ? addslashes(trim($_POST['role'])) : self::ROLE_WRITER;

    LoginAuth::checkToken();

    if (User::isAdmin()) {
        $ischeck = 'n';
    }

    if ($email == '') {
        emDirect('./user.php?error_email=1');
    }
    if ($User_Model->isMailExist($email)) {
        emDirect("./user.php?error_exist_email=1");
    }
    if (strlen($password) < 6) {
        emDirect('./user.php?error_pwd_len=1');
    }
    if ($password != $password2) {
        emDirect('./user.php?error_pwd2=1');
    }

    $PHPASS = new PasswordHash(8, true);
    $password = $PHPASS->HashPassword($password);

    $User_Model->addUser('', $email, $password, $role);
    $CACHE->updateCache(array('sta', 'user'));
    emDirect('./user.php?active_add=1');
}

if ($action == 'edit') {

    $uid = isset($_GET['uid']) ? (int)$_GET['uid'] : '';

    $data = $User_Model->getOneUser($uid);

    $nickname = $data['nickname'];
    $role = $data['role'];
    $description = $data['description'];
//    $username = $data['username'];
    $email = $data['email'];
    $level = $data['level'];
    $tel = $data['tel'];

    $ex1 = $ex2 = $ex3 = '';
    if (user::isVisitor($role)) {
        $ex1 = 'selected="selected"';
    } elseif (User::isEditor($role)) {
        $ex2 = 'selected="selected"';
    } elseif (User::isAdmin($role)) {
        $ex3 = 'selected="selected"';
    }

    $memberModel = new Member_Model();
    $members = $memberModel->getMembersAll();


    include View::getAdmView('open_head');
    require_once View::getAdmView('user_edit');
    include View::getAdmView('open_foot');
    View::output();
}

if ($action == 'edit_ajax') {
//    $username = isset($_POST['username']) ? addslashes(trim($_POST['username'])) : '';
    $nickname = isset($_POST['nickname']) ? addslashes(trim($_POST['nickname'])) : '';
    $password = isset($_POST['password']) ? addslashes(trim($_POST['password'])) : '';
    $password2 = isset($_POST['password2']) ? addslashes(trim($_POST['password2'])) : '';
    $email = isset($_POST['email']) ? addslashes(trim($_POST['email'])) : '';
    $description = isset($_POST['description']) ? addslashes(trim($_POST['description'])) : '';
    $role = isset($_POST['role']) ? addslashes(trim($_POST['role'])) : User::ROLE_WRITER;
    $uid = isset($_POST['uid']) ? (int)$_POST['uid'] : '';
    $tel = Input::postStrVar('tel');

    LoginAuth::checkToken();

    //创始人账户不能被他人编辑
    if (!User::isFounder() && $uid === 1) {
        emDirect('./user.php?error_del_b=1');
    }
    if ($uid === 1) {
        $role = User::ROLE_ADMIN;
    }
    if (empty($nickname)) {
        output::error('请填写昵称');
    }

    if ($User_Model->isMailExist($email, $uid)) {
        output::error('该邮箱已被使用');
    }
    if ($User_Model->isTelExist($tel, $uid)) {
        output::error('该手机被使用');
    }
    /*if ($User_Model->isUserExist($username, $uid)) {
        output::error('该用户名已被使用');
    }*/
    if (strlen($password) > 0 && strlen($password) < 6) {
        output::error('密码不能小于6位数');
    }


    $userData = [
//        'username'    => $username,
        'nickname'    => $nickname,
        'email'       => $email,
        'tel'       => $tel,
        'description' => $description,
        'role'        => $role,
        'level'       => Input::postIntVar('level')
    ];

    if (!empty($password)) {
        $PHPASS = new PasswordHash(8, true);
        $password = $PHPASS->HashPassword($password);
        $userData['password'] = $password;
    }

    $User_Model->updateUser($userData, $uid);
    $CACHE->updateCache('user');
    output::ok();
}

if ($action == 'del') {
    LoginAuth::checkToken();
    $ids = Input::postStrVar('ids');
    $ids = explode(',', $ids);
    $ids_arr = [];
    foreach($ids as $key => $val){
        if($val != 1){
            $ids_arr[] = $val;
        }
    }
    if(empty($ids_arr)){
        output::ok();
    }
    $ids = implode(',', $ids_arr);

    $sql = "DELETE FROM " . DB_PREFIX . "user WHERE uid IN ({$ids})";

    $db = Database::getInstance();
    $db->query($sql);

    $CACHE->updateCache(array('sta', 'user'));
    output::ok();


}



if ($action == 'forbid') {
    LoginAuth::checkToken();
    $uid = Input::postStrVar('ids');
    if (UID == $uid) {
        output::ok();
    }
    //创始人账户不能被禁用
    if ($uid == 1) {
        output::ok();
    }
    $User_Model->forbidUser($uid);
    output::ok();
}

if ($action == 'unforbid') {
    LoginAuth::checkToken();
    $uid = Input::postStrVar('ids');
    $User_Model->unforbidUser($uid);
    output::ok();
}

