game-sdk/simplewind/huomp/logic/agent/AgentExtLogic.php

<?php
/**
 * AgentExtLogic.php  UTF-8
 * 渠道扩展
 *
 * @date    : 2018/8/17 10:33
 *
 * @license 这不是一个自由软件，未经授权不许任何使用和传播。
 * @author  : chenbingling <cbl@huosdk.com>
 * @version : HUOSDK 8.0
 */

namespace huomp\logic\agent;

use huo\controller\common\CommonFunc;
use huo\model\user\AgentExtModel;
use huolib\constant\CacheConst;
use huolib\constant\CommonConst;
use huolib\constant\MemConst;
use huolib\tool\StrUtils;
use huomp\model\common\CommonModel;
use huomp\model\fill\MemFakerModel;
use think\Cache;
use think\db\exception\DataNotFoundException;
use think\db\exception\ModelNotFoundException;
use think\exception\DbException;

class AgentExtLogic extends CommonModel {
    protected function getWhere($param = []) {
        $_map = [];
        if (!empty($param['agent_id'])) {
            $_map['agent_id'] = $param['agent_id'];
        }
        if (!empty($param['role_id'])) {
            $_map['mpagent.role_id'] = $param['role_id'];
        }

        return $_map;
    }

    /***
     * 后台获取渠道数据排行
     *
     * @param        $field //排序字段
     * @param array  $where
     * @param string $page
     *
     * @return array
     */
    public function getRank($field, $where = [], $page = '1,10') {
        $_map = $this->getWhere($where);
        $_rdata = ['count' => 0, 'list' => []];
        if (empty($field)) {
            return $_rdata;
        }
        $_field = [
            'id'            => 'id',
            'user_login'    => 'user_login',
            'user_nicename' => 'user_nicename',
            'mem_id'        => 'mem_id',
            'share_total'   => 'share_total',
            'reg_cnt'       => 'reg_cnt',
        ];
        $_order = $field.' desc';
        $_ae_model = new AgentExtModel();
        $_count = $_ae_model->with('mpagent')->where($_map)->count('agent_id');
        if (empty($_count)) {
            return $_rdata;
        }
        try {
            $_a_data = $_ae_model->with('mpagent')
                                 ->with('mem')
                                 ->where($_map)
                                 ->field($_field)
                                 ->order($_order)
                                 ->page($page)
                                 ->select();
            if (is_object($_a_data)) {
                $_a_data = $_a_data->toArray();
            }
            if (empty($_a_data)) {
                return $_rdata;
            }
            $_list = [];
            foreach ($_a_data as $_k => $_v) {
                $_data = [];
                foreach ($_field as $k => $v) {
                    $_data[$v] = $_v[$k];
                }
                $_data['mem'] = empty($_v['mem']) ? '' : $_v['mem']['username'];
                $_data['mem_nickname'] = empty($_v['mem']) ? '' : $_v['mem']['nickname'];
                $_list[] = $_data;
            }
            $_rdata = ['count' => $_count, 'list' => $_list];
        } catch (DataNotFoundException $e) {
        } catch (ModelNotFoundException $e) {
        } catch (DbException $e) {
        }

        return $_rdata;
    }

    /**
     * 收益排行列表
     *
     * @param        $agent_id
     * @param array  $where
     * @param string $page
     *
     * @return array
     */
    public function getRankList($agent_id, $where = [], $page = '1,10') {
        $_map = $this->getWhere($where);
        $_map['mpagent.user_status'] = MemConst::STATUS_NORMAL;
        $_data = $this->getList($agent_id, $_map, $page);

        return $_data;
    }

    /**
     * @param        $agent_id
     * @param        $where
     * @param string $page
     *
     * @return array|mixed
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function getList($agent_id, $where, $page = '1,10') {
        $_data = $this->getRankData($agent_id, $where);
        if (empty($_data['list'])) {
            return $_data;
        }
        $_page_data = explode(',', $page);
        $_start = ($_page_data[0] - 1) * $_page_data[1];
        $_data['list'] = array_slice($_data['list'], $_start, $_page_data[1]);

        return $_data;
    }

    /**
     * @param $agent_id
     * @param $where
     *
     * @return mixed
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function getRankData($agent_id, $where) {
        $_cache_key = CacheConst::CACHE_MONEY_RANK_PREFIX.md5(json_encode(array($where)));
        $_rdata = json_decode(Cache::get($_cache_key), true);
        if (!empty($_rdata)) {
            return $_rdata;
        }
        $_map = $where;
        /* 获取真实数据 */
        $_model = new AgentExtModel();
        $_order = 'share_total desc';
        $_data_list = $_model
            ->with('mpagent')
            ->where($_map)
            ->order($_order)
            ->limit(CommonConst::CONST_MAX_SHOW_CNT)
            ->select();
        if (is_object($_data_list)) {
            $_data_list = $_data_list->toArray();
        }
        $_merge_data = [];
        $_gold_rmb_rate = CommonFunc::getGoldRmbRate();
        foreach ($_data_list as $_item) {
            $_merge_data[] = [
                'avatar'               => !empty($_item['mpagent']) ? $_item['mpagent']['avatar'] : '',
                'nickname'             => !empty($_item['mpagent']) ? $_item['mpagent']['user_nicename'] : '',
                'mem_id'               => !empty($_item['mpagent']) ? $_item['mpagent']['mem_id'] : 0,
                'agent_id'             => $_item['agent_id'],
                'reg_cnt'              => StrUtils::formatNumber($_item['reg_cnt']),
                'share_total'          => StrUtils::formatNumber($_item['share_total']),
                'share_total_integral' => intval($_gold_rmb_rate * $_item['share_total']),
            ];
        }
        /* 获取虚拟数据 */
        $_order = 'sub_amount desc';
        $_faker_data_list = (new MemFakerModel())->where(['is_delete' => CommonConst::CONST_NOT_DELETE])
                                                 ->order($_order)
                                                 ->limit(CommonConst::CONST_MAX_SHOW_CNT)
                                                 ->select();
        if (is_object($_faker_data_list)) {
            $_faker_data_list = $_faker_data_list->toArray();
        }
        foreach ($_faker_data_list as $_item) {
            $_merge_data[] = [
                'avatar'               => empty($_item['avatar']) ? '' : cmf_get_image_preview_url($_item['avatar']),
                'nickname'             => empty($_item['nickname']) ? '' : $_item['nickname'],
                'mem_id'               => empty($_item['id']) ? 0 : 'fk_'.$_item['id'],
                'agent_id'             => empty($_item['id']) ? 0 : 'fk_'.$_item['id'],
                'reg_cnt'              => StrUtils::formatNumber($_item['sub_mem_cnt']),
                'share_total'          => StrUtils::formatNumber($_item['sub_amount']),
                'share_total_integral' => intval($_gold_rmb_rate * $_item['sub_amount']),
            ];
        }
        if (empty($_merge_data)) {
            return [
                'count'   => 0,
                'ranking' => 0,
                'list'    => []
            ];
        }
        //重新排序并截取
        array_multisort(array_column($_merge_data, 'share_total'), SORT_DESC, $_merge_data);
        $_merge_data = array_slice($_merge_data, 0, CommonConst::CONST_MAX_SHOW_CNT);
        $_ranking = '99+';
        foreach ($_merge_data as $_k => $_v) {
            if ($agent_id == $_v['agent_id']) {
                $_ranking = $_k + 1;
            }
        }
        $_rdata = [
            'count'   => CommonConst::CONST_MAX_SHOW_CNT,
            'ranking' => $_ranking,
            'list'    => $_merge_data
        ];
        Cache::set($_cache_key, json_encode($_rdata), CommonConst::CONST_MINUTE_SECONDS);

        return $_rdata;
    }
}