cf-platform/Application/Base/Service/GameRebateService.class.php

<?php
namespace Base\Service;

use Base\Tool\GameResource\JmxyClient;
use Base\Tool\GameResource\YjlyClient;
use Base\Tool\GameResource\ZzylClient;
use Think\Model;

class GameRebateService
{

    public $sendStatusList = [
        0 => '待发放',
        1 => '发放成功',
        2 => '发放异常',
    ];

    public $reviewStatusList = [
        0 => '待审核',
        1 => '审核通过',
        2 => '审核拒绝',
    ];

    public $typeDisplayNames = [
        'A' => '单笔充值福利',
        'B' => '月卡福利发放',
        'C' => '创角累充福利',
        'D' => '首充福利发放',
        'E' => '单日累充福利发放',
        'F' => '周卡福利发放',
        'G' => '首次进游福利',
        'H' => '签到福利发放',
        'I' => '充值返利发放',
        'J' => '定制道具申请',
        'K' => '新服七日礼包',
        'L' => '等级福利发放',
    ];

    public $typeNames = [
        'A' => 'single',
        'B' => 'daily',
        'C' => 'accumulative',
        'D' => 'firstPay',
        'E' => 'dayAccumulative',
        'F' => 'weekly',
        'G' => 'newRole',
        'H' => 'dailySign',
        'I' => 'singleTimes',
        'J' => 'propsApplication',
        'K' => 'openSevenDay',
        'L' => 'roleLevel',
    ];

    public $rebateBaseGameIds = [11, 17, 21];

    public function isGiftItemSend($order, $item)
    {
        // 每日发放奖励暂时通过send_status来判断是否第一次发放
        if ($order['send_status'] == 1 && isset($item['once']) && $item['once']) {
            return false;   
        }
        return true;
    }

    public function sendByOrder($order, $handleDate = null)
    {
        $gift = null;
        if ($order['gift_key']) {
            $gift = M('rebate_gifts', 'tab_')
                ->where(['base_game_id' => $order['base_game_id'], 'type' => $order['type'], 'gift_key' => $order['gift_key'], 'group' => $order['gift_group']])->find();
        }
        $order['type_name'] = $this->typeDisplayNames[$order['type']] ?: '返利福利';
        $hasError = false;
        $sendResult = '';
        if ($gift && $gift['game_currency'] > 0) {
            $result = $this->sendGold($order, $gift['game_currency']);
            if (!$result['status']) {
                $hasError = true;
            }
            $sendResult .= ($result['message'] ?? '') . ';';
        }
        $index = 1;
        $giftItems = $gift ? json_decode($gift['gifts'], true) : [];
        foreach ($giftItems as $giftItem) {
            $giftItem['index'] = $index;
            $index ++;
            if (!$this->isGiftItemSend($order, $giftItem)) {
                continue;
            }
            $result = $this->sendGift($order, $giftItem);
            if (!$result['status']) {
                $hasError = true;
            }
            $sendResult .= ($result['message'] ?? '') . ';';
        }

        if ($order['props'] && $order['props'] != 'null') {
            $result = $this->sendProps($order);
            if (!$result['status']) {
                $hasError = true;
            }
            $sendResult .= ($result['message'] ?? '') . ';';
        }

        $data = [
            'send_status' => $hasError ? 2 : 1,
            'send_time' => time(),
            'send_result' => $sendResult,
        ];
        if ($handleDate) {
            $data['current_award_date'] = $handleDate;
        }

        M('rebate_orders', 'tab_')->where(['id' => $order['id']])->save($data);
    }

    private function getClient($baseGameId)
    {
        $client = null;
        switch ($baseGameId) {
            case 11:
                $client = new ZzylClient();
                break;
            case 17:
                $client = new JmxyClient();
                break;
            case 21:
                $client = new YjlyClient();
                break;
            default:
                throw new \Exception('客户端未实现');
                break;
        }
        return $client;
    }

    public function sendGold($order, $gold)
    {
        $client = $this->getClient($order['base_game_id']);
        return $client->sendGold($gold, $order);
    }

    public function sendGift($order, $giftItem)
    {
        $client = $this->getClient($order['base_game_id']);
        return $client->sendEmail($giftItem, $order);
    }

    public function sendProps($order)
    {
        $client = $this->getClient($order['base_game_id']);
        return $client->sendProps($order);
    }

    private function checkPropNumOfOrders($orders, $numMap)
    {
        $settings = M('rebate_times_setting', 'tab_')->where(['type' => 'I'])->select();
        $settings = index_by_column('base_game_id', $settings);

        foreach ($orders as $order) {
            $setting = $settings[$order['base_game_id']] ?? null;
            $maxTimes = $setting ? $setting['max_times'] : 0;
            if ($numMap[$order['id']] > $maxTimes) {
                throw new \Exception('返利倍数超过设定的最大值');
            }
        }
    }

    public function review(array $ids, $status, $handler)
    {
        if (!in_array($status, [1, 2])) {
            throw new \Exception('状态异常');
        }
        if (count($ids) == 0) {
            throw new \Exception('请选择要操作的记录');
        }

        $isSingleUpdate = is_array($ids[0]);

        $numMap = [];
        $idList = [];
        if ($isSingleUpdate) {
            foreach ($ids as $item) {
                $idList[] = $item[0];
                $numMap[$item[0]] = $item[1];
            }
        } else {
            $idList = $ids;
        }

        $orders = M('rebate_orders', 'tab_')->where(['review_status' => 0, 'id' => ['in', $idList]])->select();
        $orders = index_by_column('id', $orders);
        if (count($orders) != count($idList)) {
            throw new \Exception('含有不存在的记录或者已审核的记录');
        }

        $this->checkPropNumOfOrders($orders, $numMap);

        $commonData = [
            'review_type' => $handler['type'],
            'review_status' => $status,
            'review_time' => time(),
            'reviewer_id' => $handler['id'],
            'reviewer_username' => $handler['username'],
        ];
        if ($isSingleUpdate) {
            foreach ($ids as $item) {
                $order = $orders[$item[0]];
                $props = json_decode($order['props'], true);
                foreach ($props as $key => $prop) {
                    $prop['num'] = $item[1];
                    $props[$key] = $prop;
                }
                $giftContent = $this->getGiftContentByProps($props);
                M('rebate_orders', 'tab_')
                    ->where(['review_status' => 0, 'id' => $item[0]])
                    ->save(array_merge($commonData, [
                        'times' => $item[1],
                        'gift_content' => $giftContent,
                        'props' => json_encode($props)
                    ]));
            }
        } else {
            M('rebate_orders', 'tab_')->where(['review_status' => 0, 'id' => ['in', $idList]])->save($commonData);
        }
    }

    public function sendOnce($type)
    {
        $orders = M('rebate_orders', 'tab_')->where(['type' => $type, 'review_status' => 1, 'send_status' => 0])->select();
        foreach ($orders as $order) {
            $this->sendByOrder($order);
        }
    }

    public function sendDaily($type, $date)
    {
        $map = [
            'type' => $type,
            'review_status' => 1,
            'award_started_at' => ['elt', $date],
            'award_ended_at' => ['egt', $date],
            '_string' => '(current_award_date is null or current_award_date < "' . $date . '")'
        ];
        $orders = M('rebate_orders', 'tab_')->where($map)->select();
        foreach ($orders as $order) {
            $this->sendByOrder($order, $date);
        }
    }

    public function listQuery($params, $awardType, $promote = null)
    {
        $isExport = $params['is_export'] ?? 0;
        $page = $params['page'] ?? 0;
        $limit = $params['limit'] ?? 0;
        $baseGameId = $params['base_game_id'] ?? 0;
        $serverId = $params['server_id'] ?? '';
        $roleName = $params['role_name'] ?? '';
        $userAccount = $params['user_account'] ?? '';
        $reviewStatus = $params['review_status'] ?? -1;
        $sendStatus = $params['send_status'] ?? -1;
        $reviewerId = $params['reviewer_id'] ?? 0;
        $reviewType = $params['review_type'] ?? -1;

        $where = [
            '_string' => '1=1',
        ];
        $where['type'] = $awardType;
        if ($baseGameId != 0) {
            $where['base_game_id'] = $baseGameId;
        }
        if ($userAccount != '') {
            $where['user_account'] = ['like', $userAccount . '%'];
        }
        if ($roleName != '') {
            $where['role_name'] = ['like', $roleName . '%'];
        }
        if ($serverId != '') {
            $where['server_id'] = $serverId;
        }
        if ($reviewStatus != -1) {
            $where['review_status'] = $reviewStatus;
        }
        if ($sendStatus != -1) {
            $where['send_status'] = $sendStatus;
        }
        if ($reviewerId != 0) {
            $where['reviewer_id'] = $reviewerId;
        }
        if ($reviewType != -1) {
            $where['review_type'] = $reviewType;
        }

        if (I('send_time_start', '') != '') {
            $where['_string'] .= ' and send_time>=' . strtotime(I('send_time_start') . ' 00:00:00');
        }
        if (I('send_time_end', '') != '') {
            $where['_string'] .= ' and send_time<=' . strtotime(I('send_time_end') . ' 23:59:59');
        }

        if (I('create_time_start', '') != '') {
            $where['_string'] .= ' and create_time>=' . strtotime(I('create_time_start') . ' 00:00:00');
        }
        if (I('create_time_end', '') != '') {
            $where['_string'] .= ' and create_time<=' . strtotime(I('create_time_end') . ' 23:59:59');
        }

        if ($promote) {
            $promoteService = new PromoteService();
            $subSql = M('user', 'tab_')->field(['id'])->where(['_string' => 'promote_id in(' . $promoteService->subInSql($promote) . ')'])->select(false);
            $where['_string'] .= ' and user_id in(' . $subSql . ')';
        }

        $query = M('rebate_orders', 'tab_')->where($where);

        $count = 0;
        $records = [];
        if ($isExport == 1 || $limit == 'all') {
            $records = $query->order('create_time desc')->select();
            $count = count($records);
        } else {
            $countQuery = clone $query;
            $records = $query->order('create_time desc')->page($page, $limit)->select();
            $count = $countQuery->count();
        }
        return [$records, $count];
    }

    public function listRange(array $records, $isExport = false)
    {
        $users = [];
        if (count($records) > 0) {
            $userIds = array_column($records, 'user_id');
            $users = M('user', 'tab_')->field(['id', 'promote_account'])->where(['id' => ['in', $userIds]])->select();
            $users = index_by_column('id', $users);

            $settings = M('rebate_times_setting', 'tab_')->where(['type' => 'I'])->select();
            $settings = index_by_column('base_game_id', $settings);
        }

        $newLine = $isExport == 1 ? "\n" : '<br/>';
        foreach ($records as $key => $record) {
            $user = $users[$record['user_id']];
            $setting = $settings[$record['base_game_id']] ?? null;
            $records[$key]['max_times'] = $setting ? $setting['max_times'] : 0;
            $records[$key]['promote_account'] = $user['promote_account'];
            $records[$key]['review_status_text'] = $this->reviewStatusList[$record['review_status']];
            $records[$key]['review_time'] = $record['review_time'] > 0 ? date('Y-m-d H:i:s', $record['review_time']) : '--';
            $records[$key]['send_status_text'] = $this->sendStatusList[$record['send_status']];
            $records[$key]['send_time'] = $record['send_time'] > 0 ? date('Y-m-d H:i:s', $record['send_time']) : '--';
            $records[$key]['create_time'] = $record['create_time'] > 0 ? date('Y-m-d H:i:s', $record['create_time']) : '--';
            $records[$key]['award_date_range'] = is_null($record['award_started_at']) || is_null($record['award_ended_at']) 
                ? '' : $record['award_started_at'] . ' ~ ' . $record['award_ended_at'];
            $records[$key]['gift_content'] = implode($newLine, explode('|', $record['gift_content']));
        }
        return $records;
    }

    public function getExportHeadings($awardType)
    {
        $fields = [
            'base_game_name' => '游戏名称',
            'server_name' => '区服',
            'user_account' => '账号',
            'role_id' => '角色ID',
            'role_name' => '角色名称',
            'promote_account' => '所属推广员',
        ];
            
        if ($awardType == 'A') {
            $fields['pay_amount'] = '充值金额';
        } elseif ($awardType == 'B') {
            $fields['pay_amount'] = '当日累计充值金额';
            $fields['award_date_range'] = '可领取福利日期';
        } elseif ($awardType == 'C') {
            $fields['amount'] = '达到档位金额';
        } elseif ($awardType == 'D') {
            $fields['pay_amount'] = '首充金额';
        } elseif($awardType == 'E') {
            $fields['pay_amount'] = '当日累计充值金额';
            $fields['award_date'] = '达成日期';
        } elseif($awardType == 'F') {
            $fields['award_date_range'] = '可领取福利日期';
        } elseif($awardType == 'H') {
            $fields['award_date'] = '签到日期';
        } elseif ($awardType == 'I') {
            $fields['pay_amount'] = '充值金额';
            $fields['times'] = '返利倍数';
        } elseif($awardType == 'J') {
            $fields['award_date'] = '达成日期';
            $fields['pay_amount'] = '当日累充总额';
            $fields['times'] = '返利倍数';
            $fields['amount'] = '申请总价值';
        } elseif ($awardType == 'K') {
            $fields['pay_amount'] = '充值金额';
        } elseif ($awardType == 'L') {
            $fields['pay_amount'] = '当前等级';
            $fields['mount'] = '奖励等级';
        }

        if ($awardType == 'J') {
            $fields['gift_content'] = '申请道具';
        } elseif($awardType == 'I') {

        } else {
            $fields['gift_content'] = '奖励内容';
        }

        $fields = array_merge($fields, [
            'create_time' => '订单生成时间',
            'review_status_text' => '审核状态',
            'review_time' => '审核时间',
            'send_status_text' => '发放状态',
            'send_time' => '发放时间',
            'reviewer_username' => '审核人',
        ]);
        return $fields;
    }

    public function addSimulateSpend($params, $handler)
    {
        $baseGameId = $params['base_game_id'] ?? 0;
        $roleId = $params['role_id'] ?? '';
        $amount = $params['amount'] ?? 0;
        $remark = $params['remark'] ?? '';
        if ($baseGameId == 0) {
            throw new \Exception('请选择游戏');
        }
        if ($roleId == 0) {
            throw new \Exception('请输入角色ID');
        }
        if ($amount <= 0) {
            throw new \Exception('金额必须大于0');
        }
        $baseGame = M('base_game', 'tab_')->where(['id' => $baseGameId])->find();
        if ($baseGame == null) {
            throw new \Exception('游戏不存在');
        }
        $gameIds = [$baseGame['android_game_id'], $baseGame['ios_game_id']];

        $role = M('user_play_info', 'tab_')->where(['role_id' => $roleId, 'game_id' => ['in', $gameIds]])->find();
        if ($role == null) {
            throw new \Exception('角色不存在');
        }

        $data = [
            'user_id' => $role['user_id'],
            'user_account' => $role['user_account'],
            'base_game_id' => $baseGame['id'],
            'base_game_name' => $baseGame['name'],
            'role_id' => $role['role_id'],
            'role_name' => $role['role_name'],
            'server_id' => $role['server_id'],
            'server_name' => $role['server_name'],
            'order_no' => 'SS_' . date('YmdHis') . getRandomPassword(4),
            'create_time' => time(),
            'amount' => $amount,
            'remark' => $remark,
            'creator_id' => $handler['id'],
            'creator_username' => $handler['username'],
        ];

        M('simulate_spend', 'tab_')->add($data);
    }

    public function reviewSimulateSpend(array $ids, $status, $handler)
    {
        if (!in_array($status, [1, 2])) {
            throw new \Exception('状态异常');
        }
        if (count($ids) == 0) {
            throw new \Exception('请选择要操作的记录');
        }
        $orders = M('simulate_spend', 'tab_')->field(['id'])->where(['review_status' => 0, 'id' => ['in', $ids]])->select();
        if (count($orders) != count($ids)) {
            throw new \Exception('含有不存在的记录或者已审核的记录');
        }
        
        M('simulate_spend', 'tab_')->where(['status' => 0, 'id' => ['in', $ids]])->save([
            'status' => $status,
            'review_time' => time(),
            'reviewer_id' => $handler['id'],
            'reviewer_username' => $handler['username'],
        ]);
    }

    public function deleteProp($id)
    {
        M('rebate_props', 'tab_')->where(['id' => $id])->delete();
    }

    public function batchDeleteProp($ids, $baseGameId)
    {
        M('rebate_props', 'tab_')->where(['id' => ['in', $ids], 'base_game_id' => $baseGameId])->delete();
    }

    public function saveProp($params)
    {
        $id = $params['id'] ?? 0;

        $this->checkPropItem($params);

        $prop = null;
        if ($id > 0) {
            $prop = M('rebate_props', 'tab_')->where(['id' => $id])->find();
            if (!$prop) {
                throw new \Exception('道具不存在');
            }
        }

        $data = [
            'ref_id' => $params['ref_id'],
            'name' => $params['name'],
            'value' => $params['value'],
            'update_time' => time()
        ];

        if ($id > 0) {
            M('rebate_props', 'tab_')->where(['id' => $id])->save($data);
        } else {
            $data['base_game_id'] = $params['base_game_id'] ?? 0;
            $data['create_time'] = time();
            M('rebate_props', 'tab_')->add($data);
        }
    }

    private function checkPropItem($prop)
    {
        $value = $prop['value'] ?? 0;
        if (!isset($prop['value'])) {
            throw new \Exception('缺少参数道具价值');
        }
        if (!isset($prop['name'])) {
            throw new \Exception('缺少参数道具名称');
        }
        if (!isset($prop['ref_id'])) {
            throw new \Exception('缺少参数道具ID');
        }
        if (!is_numeric($value) || $value < 0) {
            throw new \Exception('道具价值必须为大于0的整数');
        }
    }

    public function saveProps($baseGameId, $props)
    {
        if (count($props) == 0) {
            throw new \Exception('道具项为0');
        }

        foreach ($props as $prop) {
            $this->checkPropItem($prop);
        }
        
        $refIds = array_column($props, 'ref_id');
        $existItems = M('rebate_props', 'tab_')->field(['ref_id'])->where(['base_game_id' => $baseGameId, 'ref_id' => ['in', $refIds]])->select();
        $existItems = index_by_column('ref_id', $existItems);

        $model = new Model();
        $model->startTrans();

        try {
            $updateRecords = [];
            $newRecords = [];
            foreach ($props as $prop) {
                $record = [
                    'base_game_id' => $baseGameId,
                    'ref_id' => $prop['ref_id'],
                    'name' => $prop['name'],
                    'value' => $prop['value'],
                    'update_time' => time()
                ];
                if (isset($existItems[$prop['ref_id']])) {
                    $updateRecords[] = $record;
                } else {
                    $record['create_time'] = time();
                    $newRecords[] = $record;
                }
            }
            M('rebate_props', 'tab_')->addAll($newRecords);
            foreach ($updateRecords as $record) {
                M('rebate_props', 'tab_')->where(['base_game_id' => $baseGameId, 'ref_id' => $record['ref_id']])->save($record);
            }
            $model->commit();
        } catch (\Exception $e) {
            $model->rollback();
            throw new \Exception('保存失败');
        }
    }

    public function saveSetting($params)
    {
        $baseGameId = $params['base_game_id'] ?? 0;
        $defaultTimes = $params['default_times'] ?? 0;
        $maxTimes = $params['max_times'] ?? 0;
        $type = $params['type'] ?? 'J';
        
        if ($baseGameId == 0) {
            throw new \Exception('请选择游戏');
        }

        if (!is_numeric($defaultTimes)) {
            throw new \Exception('默认倍数格式错误');
        }

        if (!is_numeric($maxTimes)) {
            throw new \Exception('倍数上限格式错误');
        }

        $defaultTimes = intval($defaultTimes);
        $maxTimes = intval($maxTimes);

        if ($defaultTimes < 0) {
            throw new \Exception('默认倍数需大于0');
        }

        if ($maxTimes < 0) {
            throw new \Exception('倍数上限需大于0');
        }

        if ($defaultTimes > $maxTimes) {
            throw new \Exception('默认倍数不能大于倍数上限');
        }

        $setting = M('rebate_times_setting', 'tab_')->where(['base_game_id' => $baseGameId, 'type' => $type])->find();

        // $baseGame = M('base_game', 'tab_')->where(['id' => $baseGameId])->find();

        $data = [
            'base_game_id' => $params['base_game_id'],
            'type' => $type,
            'default_times' => $defaultTimes,
            'max_times' => $maxTimes,
            'update_time' => time()
        ];

        if ($setting) {
            M('rebate_times_setting', 'tab_')->where(['id' => $setting['id']])->save($data);
        } else {
            $data['create_time'] = time();
            M('rebate_times_setting', 'tab_')->add($data);
        }
    }

    public function deleteSetting($id)
    {
        $setting = M('rebate_times_setting', 'tab_')->where(['id' => $id])->find();
        if (!$setting) {
            throw new \Exception('记录不存在');
        }
        if ($setting['type'] == 'J') {
            $count = M('rebate_props', 'tab_')->where(['base_game_id' => $setting['base_game_id']])->count();
            if ($count > 0) {
                throw new \Exception('该游戏道具列表含有道具，无法删除！');
            }
        }
        M('rebate_times_setting', 'tab_')->where(['id' => $id])->delete();
    }

    private function getRoleDailyPayAmount($role, $date)
    {
        $spendMap = [
            'pay_status' => 1,
            'game_play_id' => $role['role_id'],
            'user_id' => $role['user_id'],
            'game_id' => ['in', $role['game_ids']],
            'pay_time' => ['between', [strtotime($date . ' 00:00:00'), strtotime($date . ' 23:59:59')]]
        ];
        $payAmount = M('spend', 'tab_')->where($spendMap)->sum('pay_amount');

        $simulateMap = [
            'status' => 1,
            'role_id' => $role['role_id'],
            'user_id' => $role['user_id'],
            'base_game_id' => $role['base_game_id'],
            'review_time' => ['between', [strtotime($date . ' 00:00:00'), strtotime($date . ' 23:59:59')]]
        ];
        $simulateAmount = M('simulate_spend', 'tab_')->where($simulateMap)->sum('amount');

        return floatval($payAmount) + floatval($simulateAmount);
    }

    private function getRoleDailyAppliedAmount($role, $date)
    {
        $map = [
            'review_status' => ['in', [0, 1]],
            'role_id' => $role['role_id'],
            'user_id' => $role['user_id'],
            'base_game_id' => $role['base_game_id'],
            'date' => $date,
            'type' => 'J',
        ];
        $amount = M('rebate_orders', 'tab_')->where($map)->sum('amount');
        return floatval($amount);
    }

    public function propsApply($params, $handler = null)
    {
        $baseGameId = $params['base_game_id'] ?? 0;
        $roleId = $params['role_id'] ?? '';
        $propItems = $params['props'] ?? [];
        $date = $params['date'] ?? '';

        if ($baseGameId == 0) {
            throw new \Exception('请选择游戏');
        }

        if ($date == '') {
            throw new \Exception('请选择日期');
        }
        if (count($propItems) == 0) {
            throw new \Exception('至少选择一项道具');
        }

        $baseGame = M('base_game', 'tab_')->where(['id' => $baseGameId])->find();
        if (!$baseGame) {
            throw new \Exception('游戏不存在');
        }

        $roleFields = ['user_id', 'user_account', 'game_id', 'role_id', 'role_name', 'server_id', 'server_name'];
        $role = M('user_play_info', 'tab_')->field($roleFields)->where(['base_game_id' => $baseGameId, 'role_id' => $roleId])->find();
        if (!$role) {
            throw new \Exception('角色不存在');
        }

        $setting = M('rebate_times_setting', 'tab_')->where(['base_game_id' => $baseGameId, 'type' => 'J'])->find();
        if (!$setting) {
            throw new \Exception('未设定定制道具返利倍数');
        }

        $props = M('rebate_props', 'tab_')->where(['id' => ['in', array_column($propItems, 'id')], 'base_game_id' => $baseGameId])->select();
        $props = index_by_column('id', $props);
        
        $applyAmount = 0;
        $applyProps = [];
        foreach ($propItems as $item) {
            if (isset($props[$item['id']])) {
                $prop = $props[$item['id']];
                $applyAmount += ($prop['value'] * $item['num']);
                $applyProps[] = [
                    'ref_id' => $prop['ref_id'],
                    'value' => $prop['value'],
                    'num' =>  $item['num'],
                    'name' => $prop['name']
                ];
            } else {
                throw new \Exception('道具不存在');
            }
        }
        $gameIds = [$baseGame['android_game_id'], $baseGame['ios_game_id']];
        $role['game_ids'] = $gameIds;
        $role['base_game_id'] = $baseGameId;

        $dailyPayAmount = $this->getRoleDailyPayAmount($role, $date);
        $appliedAmount = $this->getRoleDailyAppliedAmount($role, $date);

        if ($dailyPayAmount * $setting['max_times'] - $applyAmount - $appliedAmount < 0) {
            throw new \Exception('额度不足');
        }

        $record = [
            'base_game_id' => $baseGame['id'],
            'base_game_name' => $baseGame['name'],
            'user_id' => $role['user_id'],
            'user_account' => $role['user_account'],
            'server_id' => $role['server_id'],
            'server_name' => $role['server_name'],
            'role_name' => $role['role_name'],
            'role_id' => $role['role_id'],
            'type' => 'J',
            'award_date' => $date,
            'amount' => $applyAmount,
            'pay_amount' => $dailyPayAmount,
            'gift_key' => 'J-0',
            'gift_content' => $this->getGiftContentByProps($applyProps),
            'props' => json_encode($applyProps, JSON_UNESCAPED_UNICODE),
            'times' => $setting['max_times'],
            'create_time' => time(),
        ];

        if ($handler) {
            $record['creator_id'] = $handler['id'];
            $record['creator_username'] = $handler['username'];
            $record['creator_type'] = $handler['type'];
        }

        // 是否自动审核
        if (false) {
            $record['review_type'] = 2;
            $record['reviewer_id'] = 0;
            $record['reviewer_username'] = '系统';
            $record['review_status'] = 1;
            $record['review_time'] = time();
        }

        M('rebate_orders', 'tab_')->add($record);
    }

    private function getGiftContentByProps($props)
    {
        $items = [];
        foreach ($props as $prop) {
            $items[] = $prop['name'] . '*' . $prop['num'];
        }
        return implode('|', $items);
    }

    public function getRebateBaseGames()
    {
        return M('base_game', 'tab_')->where(['id' => ['in', $this->rebateBaseGameIds]])->select();
    }

    public function getRoleInfo($params, $permPromote = null)
    {
        $baseGameId = $params['base_game_id'] ?? 0;
        $roleId = $params['role_id'] ?? '';
        $date = $params['date'] ?? '';

        $baseGame = M('base_game', 'tab_')->where(['id' => $baseGameId])->find();
        if (!$baseGame) {
            throw new \Exception('游戏不存在');
        }
        $gameIds = [$baseGame['android_game_id'] , $baseGame['ios_game_id']];

        $roleStr = '1=1';
        if ($permPromote != null) {
            $promoteService = new PromoteService();
            $roleStr .= ' and promote_id in ('  . $promoteService->subInSql($permPromote) . ')';
        }
        
        $role = M('user_play_info', 'tab_')->where(['game_id' => ['in', $gameIds], 'role_id' => $roleId, '_string' => $roleStr])->order('play_time', 'desc')->limit(1)->find();
        if (!$role) {
            throw new \Exception('角色不存在');
        }
        $spendMap = ['game_id' => ['in', $gameIds], 'game_player_id' => $roleId, 'pay_status' => 1, 'user_id' => $role['user_id']];
        $simulateMap = ['base_game_id' => $baseGameId, 'role_id' => $roleId, 'status' => 1, 'user_id' => $role['user_id']];
        if ($date) {
            $spendMap['pay_time'] = ['between', [strtotime($date . ' 00:00:00'), strtotime($date . ' 23:59:59')]];
            $simulateMap['review_time'] = ['between', [strtotime($date . ' 00:00:00'), strtotime($date . ' 23:59:59')]];
        }
        $payAmount = M('spend', 'tab_')->where($spendMap)->sum('pay_amount');
        $payAmount = floatval($payAmount);

        $simulateAmount = M('simulate_spend', 'tab_')->where($simulateMap)->sum('amount');
        $simulateAmount = floatval($simulateAmount);

        $data = [
            'server_name' => $role['server_name'],
            'role_name' => $role['role_name'],
            'pay_amount' => $payAmount,
            'simulate_amount' => $simulateAmount
        ];

        if ($date) {
            $setting = M('rebate_times_setting', 'tab_')->where(['base_game_id' => $baseGameId, 'type' => 'J'])->find();
            if (!$setting) {
                throw new \Exception('返利倍数未设置');
            }
            $totalQuota = intval(($payAmount + $simulateAmount) * $setting['max_times']);
            $appliedQuota = M('rebate_orders', 'tab_')
                ->where(['base_game_id' => $baseGameId, 'type' => 'J', 'role_id' => $roleId, 'award_date' => $date, 'review_status' => ['in', [0, 1]]])
                ->sum('amount');
            $appliedQuota = intval($appliedQuota);
            $remainQuota = $totalQuota - $appliedQuota;
            $data =  array_merge($data, 
                [
                    'applied_quota' => $appliedQuota,
                    'remain_quota' => $remainQuota,
                    'total_quota' => $totalQuota,
                    'max_times' => $setting['max_times'],
                ]
            );
        }
        return $data;
    }
}