zoumaliveServer/mapi_copy/lib/models/game_distributionModel.class.php

<?php
/**
 *
 */
class game_distributionModel extends Model
{
    public function getParent($user_id)
    {
        $parent = null;
        $model  = Model::build('user');
        $user   = $model->field('game_distribution_id')->selectOne(['id' => $user_id]);
        if ($user['game_distribution_id']) {
            $parent               = $model->field('id', 'nick_name', 'head_image')->selectOne(['id' => $user['game_distribution_id']]);
            if ($parent) {
                $parent['head_image'] = get_spec_image($parent['head_image']);
            }
        }
        return $parent;
    }
    public function getDistributionList($user_id, $page, $page_size = 20)
    {
        $page    = $page > 0 ? $page : 1;
        $user_id = intval($user_id);
        $field   = [
            'u.id',
            'u.nick_name',
            'u.head_image',
            'gd.is_ticket',
            ["sum(gd.first_distreibution_money * (gd.first_distreibution_id = {$user_id}) + gd.second_distreibution_money * (gd.second_distreibution_id = {$user_id})) as `sum`"],
        ];
        $table = ['user u', 'game_distribution gd'];
        $where = [
            [
                'gd.first_distreibution_id'  => ['=', $user_id],
                'gd.second_distreibution_id' => ['=', $user_id, 'or'],
            ],
            'u.id' => ['gd.user_id'],
        ];
        $list  = $this->table($table)->field($field)->group('u.id,gd.is_ticket')->limit(($page - 1) * $page_size, $page_size)->select($where);
        $count = $this->table($table)->group('u.id')->count($where);
        foreach ($list as $key => $value) {
            $list[$key]['head_image'] = get_spec_image($value['head_image']);
            unset($list[$key]['is_ticket']);
            $list[$key]['sum'] = $value['sum'] . ($value['is_ticket'] ? '印票' : '游戏币');
        }

        $data = [
            'parent' => $this->getParent($user_id),
            'list'   => $list,
            'page'   => [
                'page'     => $page,
                'has_next' => intval($count > ($page * $page_size)),
            ],
        ];
        if (!$data['parent']) {
            unset($data['parent']);
        }
        return $data;
    }
    public function addLog($user_id, $room_id, $game_log_id, $money, $dec, $is_ticket = false)
    {

        $first_distreibution_id     = 0;
        $first_distreibution_money  = 0;
        $second_distreibution_id    = 0;
        $second_distreibution_money = 0;

        $m_config = load_auto_cache("m_config");

        $model = Model::build('user');
        $user  = $model->field('game_distribution_id')->selectOne(['id' => $user_id]);
        if ($user['game_distribution_id']) {
            $first_distreibution_id    = intval($user['game_distribution_id']);
            $first_distreibution       = $model->field('game_distribution_id,game_distribution1')->selectOne(['id' => $first_distreibution_id]);
            $first_distreibution_money = intval($money / 100 * ($first_distreibution['game_distribution1'] ? $first_distreibution['game_distribution1'] : $m_config['game_distribution1']));
            if ($first_distreibution['game_distribution_id']) {
                $second_distreibution_id    = intval($first_distreibution['game_distribution_id']);
                $second_distreibution       = $model->field('game_distribution_id,game_distribution2')->selectOne(['id' => $second_distreibution_id]);
                $second_distreibution_money = intval($money / 100 * ($second_distreibution['game_distribution2'] ? $second_distreibution['game_distribution2'] : $m_config['game_distribution2']));
            }
        }
        $distreibution_money = $money - $first_distreibution_money - $second_distreibution_money;

        $create_time = NOW_TIME;
        $is_ticket   = intval(defined('OPEN_DIAMOND_GAME_MODULE') && OPEN_DIAMOND_GAME_MODULE == 1 || $is_ticket);
        $res         = $this->insert(compact('room_id', 'game_log_id', 'money', 'user_id', 'distreibution_money', 'first_distreibution_id', 'first_distreibution_money', 'second_distreibution_id', 'second_distreibution_money', 'dec', 'create_time', 'is_ticket'));
        if (!$res) {
            return false;
        }
        if ($first_distreibution_money + $second_distreibution_money) {
            $coin = -$first_distreibution_money - $second_distreibution_money;
            if ($is_ticket) {
                fanwe_require(APP_ROOT_PATH . 'mapi/lib/redis/BaseRedisService.php');
                fanwe_require(APP_ROOT_PATH . 'mapi/lib/redis/UserRedisService.php');
                $user_redis = new UserRedisService();
                $log_model  = Model::build('user_log');
                $res        = $model->update(['ticket' => ['ticket + ' . $coin]], ['id' => $user_id]);
                if ($res) {
                    $user_redis->inc_field($user_id, 'ticket', $coin);
                    $log_data = [
                        'log_info'     => $dec . '抽成(上交)',
                        'log_time'     => NOW_TIME,
                        'log_admin_id' => 0,
                        'money'        => 0,
                        'user_id'      => $user_id,
                        'type'         => 7,
                        'prop_id'      => 0,
                        'score'        => 0,
                        'point'        => 0,
                        'podcast_id'   => $user_id,
                        'diamonds'     => 0,
                        'ticket'       => $coin,
                        'video_id'     => $room_id,
                    ];
                    $log_model->insert($log_data);
                }
                if ($first_distreibution_money) {
                    $res = $model->update(['ticket' => ['ticket + ' . $first_distreibution_money]], ['id' => $first_distreibution_id]);
                    if ($res) {
                        $user_redis->inc_field($first_distreibution_id, 'ticket', $first_distreibution_money);
                        $log_data = [
                            'log_info'     => $dec . '一级抽成(抽取)',
                            'log_time'     => NOW_TIME,
                            'log_admin_id' => 0,
                            'money'        => 0,
                            'user_id'      => $first_distreibution_id,
                            'type'         => 7,
                            'prop_id'      => 0,
                            'score'        => 0,
                            'point'        => 0,
                            'podcast_id'   => $user_id,
                            'diamonds'     => 0,
                            'ticket'       => $first_distreibution_money,
                            'video_id'     => $room_id,
                        ];
                        $log_model->insert($log_data);
                    }
                }
                if ($second_distreibution_money) {
                    $res = $model->update(['ticket' => ['ticket + ' . $second_distreibution_money]], ['id' => $second_distreibution_id]);
                    if ($res) {
                        $user_redis->inc_field($second_distreibution_id, 'ticket', $second_distreibution_money);
                        $log_data = [
                            'log_info'     => $dec . '二级抽成(抽取)',
                            'log_time'     => NOW_TIME,
                            'log_admin_id' => 0,
                            'money'        => 0,
                            'user_id'      => $second_distreibution_id,
                            'type'         => 7,
                            'prop_id'      => 0,
                            'score'        => 0,
                            'point'        => 0,
                            'podcast_id'   => $user_id,
                            'diamonds'     => 0,
                            'ticket'       => $second_distreibution_money,
                            'video_id'     => $room_id,
                        ];
                        $log_model->insert($log_data);
                    }
                }
            } else {
                $coin_log_model   = Model::build('coin_log');
                $user_model       = Model::build('user');
                $res              = $user_model->coin($user_id, $coin);
                $account_diamonds = $user_model->coin($user_id);
                if ($res) {
                    $coin_log_model->addLog($user_id, $game_log_id, $coin, $account_diamonds, $dec . '抽成(上交)');
                }
                if ($first_distreibution_money) {
                    $res              = $user_model->coin($first_distreibution_id, $first_distreibution_money);
                    $account_diamonds = $user_model->coin($first_distreibution_id);
                    if ($res) {
                        $coin_log_model->addLog($first_distreibution_id, $game_log_id, $first_distreibution_money, $account_diamonds, $dec . '一级抽成(抽取)');
                    }
                }
                if ($second_distreibution_money) {
                    $res              = $user_model->coin($second_distreibution_id, $second_distreibution_money);
                    $account_diamonds = $user_model->coin($second_distreibution_id);
                    if ($res) {
                        $coin_log_model->addLog($second_distreibution_id, $game_log_id, $second_distreibution_money, $account_diamonds, $dec . '二级抽成(抽取)');
                    }
                }
            }
        }
        return $distreibution_money;
    }
}