zoumaliveServer/mapi/lib/models/userModel.class.php

<?php
/**
 *
 */
class userModel extends NewModel
{
    public function getOneById($id, $field = '')
    {
        return $this->field($field)->selectOne(array('id' => intval($id)));
    }
    public function coin($user_id, $coin = false, $coin_field = false)
    {
        if ($coin_field == false) {
            $open_game = defined('OPEN_GAME_MODULE') && (OPEN_GAME_MODULE == 1);
            $diamond = defined('OPEN_DIAMOND_GAME_MODULE') && (OPEN_DIAMOND_GAME_MODULE == 1);
            $coin_field = ($open_game && !$diamond) ? 'coin' : 'diamonds';
        }
        $user_id = intval($user_id);
        if (!$user_id) {
            return false;
        }
        fanwe_require(APP_ROOT_PATH . 'mapi/lib/redis/UserRedisService.php');
        $user_redis = new UserRedisService();
        if ($coin === false) {
            return intval($user_redis->getOne_db($user_id, $coin_field));
        } else {
            $coin  = intval($coin);
            $where = array('id' => $user_id);
            if ($coin < 0) {
                $where[$coin_field] = array('>=', -$coin);
            }
            $res = $this->update(array($coin_field => array($coin_field . ' + ' . $coin)), $where);
            if ($res) {
                $user_redis->inc_field($user_id, $coin_field, $coin);
            }
            return $res;
        }
    }
    public function multiAddCoin($game_log_id, $result, $times)
    {
        $coin_field = 'coin';
        if (defined('OPEN_DIAMOND_GAME_MODULE') && OPEN_DIAMOND_GAME_MODULE == 1) {
            $coin_field = 'diamonds';
        }
        $table      = DB_PREFIX . 'user_game_log';
        $table_user = DB_PREFIX . 'user';
        self::$sql  =
            "UPDATE $table_user AS a
                INNER JOIN (
                    SELECT
                        SUM(`money`) AS `win`,
                        `user_id`
                    FROM
                        $table
                    WHERE
                        `game_log_id` = $game_log_id
                    AND `bet` = $result
                    GROUP BY
                        `user_id`
                ) AS b ON a.id = b.user_id
                SET a.{$coin_field} = a.{$coin_field} + b.win * $times";
        return Connect::exec(self::$sql);
    }
    public function returnCoin($game_log_id)
    {
        $coin_field = 'coin';
        if (defined('OPEN_DIAMOND_GAME_MODULE') && OPEN_DIAMOND_GAME_MODULE == 1) {
            $coin_field = 'diamonds';
        }
        $table      = DB_PREFIX . 'user_game_log';
        $table_user = DB_PREFIX . 'user';
        self::$sql  =
            "UPDATE $table_user a
            INNER JOIN (
                SELECT
                    SUM(`money`) AS `win`,
                    `user_id`
                FROM
                    $table
                WHERE
                    `game_log_id` = $game_log_id
                GROUP BY
                    `user_id`
            ) AS b ON a.id = b.user_id
            SET a.{$coin_field} = a.{$coin_field} + b.win";
        return Connect::exec(self::$sql);
    }
    /**
     * 获取邀请码
     * @param  [type] $user_id [description]
     * @return [type]          [description]
     */
    public function getInvitationCode($user_id)
    {
        $user_id = intval($user_id);
        $user    = $this->field('create_time,invitation_code')->selectOne(['id' => $user_id]);
        if (!$user) {
            return false;
        }
        if ($user['invitation_code']) {
            return $user['invitation_code'];
        }
        $users = $this->field('create_time,id')->select(['invitation_code' => '']);
        foreach ($users as $v) {
            $this->update(['invitation_code' => substr(md5($v['id'] . ':' . $v['create_time']), -16)], ['id' => $v['id']]);
        }
        return substr(md5($user_id . ':' . $user['create_time']), -16);
    }
    public function getInvitationId($user_id)
    {
        $user_id = intval($user_id);
        $user    = $this->field('bm_pid')->selectOne(['id' => $user_id]);
        if ($user['bm_pid']) {
            return intval($user['bm_pid']);
        }
        return false;
    }
    /**
     * 通过邀请码设置邀请人
     * @param [type] $user_id   [description]
     * @param [type] $qrcode_sn [description]
     */
    public function getInvitationBycode($qrcode_sn)
    {
        $user = $this->table('bm_qrcode')->field('id bm_qrcode_id,user_id bm_pid,promoter_id bm_promoter_id')->selectOne(['qrcode_sn' => $qrcode_sn, 'is_effect' => 1]);
        if (!$user) {
            return false;
        }
        return $user;
    }
    public function getChild($pid, $field = false)
    {
        if (!$pid) {
            return [];
        }
        if (is_array($pid)) {
            $where = ['game_distribution_id' => ['in', $pid]];
        } else {
            $where = ['game_distribution_id' => intval($pid)];
        }
        if ($field === false) {
            $child = $this->field('id')->select($where);
            $array = [];
            foreach ($child as $value) {
                $array[] = intval($value['id']);
            }
            return $array;
        } else {
            return $this->field($field)->select($where);
        }
    }
}