123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489 |
- <?php
- namespace huomp\logic\data;
- use huo\controller\agent\AgentCache;
- use huo\controller\game\GameCache;
- use huo\logic\data\StatisticsLogic;
- use huo\model\common\CommonModel;
- use huo\model\data\DayAgentModel;
- use huo\model\data\DayGameAgentModel;
- use huo\model\data\DayGameModel;
- use huo\model\data\DayModel;
- use huo\model\game\GameModel;
- use huo\model\log\DayMemLogModel;
- use huo\model\user\UserModel;
- use huolib\constant\AgentConst;
- use huolib\constant\CommonConst;
- use huolib\tool\StrUtils;
- use huomp\model\agent\AgentGameDateCostModel;
- class DayDataLogic extends CommonModel {
- private $base_field
- = [
- 'date' => 'date',
- 'active_cnt' => 'active_cnt',
- 'today_cnt' => 'today_cnt',
- 'ip_cnt' => 'ip_cnt',
- 'user_cnt' => 'user_cnt',
- 'reg_device_cnt' => 'reg_device_cnt',
- 'reg_cnt' => 'reg_cnt',
- 'pay_user_cnt' => 'pay_user_cnt',
- 'order_cnt' => 'order_cnt',
- 'reg_pay_cnt' => 'reg_pay_cnt',
- 'sum_money' => 'sum_money',
- 'reg_sum_money' => 'reg_sum_money',
- 'click_cnt' => 'click_cnt',
- 'stay_time' => 'stay_time',
- ];
- private $sum_field
- = [
- 'sum(active_cnt)' => 'active_cnt',
- 'sum(today_cnt)' => 'today_cnt',
- 'sum(ip_cnt)' => 'ip_cnt',
- 'sum(order_cnt)' => 'order_cnt',
- 'sum(user_cnt)' => 'user_cnt',
- 'sum(reg_device_cnt)' => 'reg_device_cnt',
- 'sum(reg_cnt)' => 'reg_cnt',
- 'sum(pay_user_cnt)' => 'pay_user_cnt',
- 'sum(reg_order_cnt)' => 'reg_order_cnt',
- 'sum(reg_pay_cnt)' => 'reg_pay_cnt',
- 'sum(sum_money)' => 'sum_money',
- 'sum(reg_sum_money)' => 'reg_sum_money',
- 'sum(click_cnt)' => 'click_cnt',
- 'sum(stay_time)' => 'stay_time',
- ];
- private $output_base_field
- = [
- 'date' => 'date',
- 'reg_cnt' => 'reg_cnt',
- 'reg_pay_cnt' => 'reg_pay_cnt',
- 'reg_sum_money' => 'reg_sum_money',
- 'pay_amount_day2' => 'pay_amount_day2',
- 'pay_amount_day3' => 'pay_amount_day3',
- 'pay_amount_day4' => 'pay_amount_day4',
- 'pay_amount_day5' => 'pay_amount_day5',
- 'pay_amount_day6' => 'pay_amount_day6',
- 'pay_amount_day7' => 'pay_amount_day7',
- 'pay_amount_day8' => 'pay_amount_day8',
- 'pay_amount_day9' => 'pay_amount_day9',
- 'pay_amount_day10' => 'pay_amount_day10',
- 'pay_amount_day11' => 'pay_amount_day11',
- 'pay_amount_day12' => 'pay_amount_day12',
- 'pay_amount_day13' => 'pay_amount_day13',
- 'pay_amount_day14' => 'pay_amount_day14',
- 'pay_amount_day15' => 'pay_amount_day15',
- 'pay_amount_day16' => 'pay_amount_day16',
- 'pay_amount_day17' => 'pay_amount_day17',
- 'pay_amount_day18' => 'pay_amount_day18',
- 'pay_amount_day19' => 'pay_amount_day19',
- 'pay_amount_day20' => 'pay_amount_day20',
- 'pay_amount_day21' => 'pay_amount_day21',
- 'pay_amount_day22' => 'pay_amount_day22',
- 'pay_amount_day23' => 'pay_amount_day23',
- 'pay_amount_day24' => 'pay_amount_day24',
- 'pay_amount_day25' => 'pay_amount_day25',
- 'pay_amount_day26' => 'pay_amount_day26',
- 'pay_amount_day27' => 'pay_amount_day27',
- 'pay_amount_day28' => 'pay_amount_day28',
- 'pay_amount_day29' => 'pay_amount_day29',
- 'pay_amount_day30' => 'pay_amount_day30',
- ];
- private $output_sum_field
- = [
- 'sum(reg_cnt)' => 'reg_cnt',
- 'sum(reg_pay_cnt)' => 'reg_pay_cnt',
- 'sum(reg_sum_money)' => 'reg_sum_money',
- 'sum(pay_amount_day2)' => 'pay_amount_day2',
- 'sum(pay_amount_day3)' => 'pay_amount_day3',
- 'sum(pay_amount_day4)' => 'pay_amount_day4',
- 'sum(pay_amount_day5)' => 'pay_amount_day5',
- 'sum(pay_amount_day6)' => 'pay_amount_day6',
- 'sum(pay_amount_day7)' => 'pay_amount_day7',
- 'sum(pay_amount_day8)' => 'pay_amount_day8',
- 'sum(pay_amount_day9)' => 'pay_amount_day9',
- 'sum(pay_amount_day10)' => 'pay_amount_day10',
- 'sum(pay_amount_day11)' => 'pay_amount_day11',
- 'sum(pay_amount_day12)' => 'pay_amount_day12',
- 'sum(pay_amount_day13)' => 'pay_amount_day13',
- 'sum(pay_amount_day14)' => 'pay_amount_day14',
- 'sum(pay_amount_day15)' => 'pay_amount_day15',
- 'sum(pay_amount_day16)' => 'pay_amount_day16',
- 'sum(pay_amount_day17)' => 'pay_amount_day17',
- 'sum(pay_amount_day18)' => 'pay_amount_day18',
- 'sum(pay_amount_day19)' => 'pay_amount_day19',
- 'sum(pay_amount_day20)' => 'pay_amount_day20',
- 'sum(pay_amount_day21)' => 'pay_amount_day21',
- 'sum(pay_amount_day22)' => 'pay_amount_day22',
- 'sum(pay_amount_day23)' => 'pay_amount_day23',
- 'sum(pay_amount_day24)' => 'pay_amount_day24',
- 'sum(pay_amount_day25)' => 'pay_amount_day25',
- 'sum(pay_amount_day26)' => 'pay_amount_day26',
- 'sum(pay_amount_day27)' => 'pay_amount_day27',
- 'sum(pay_amount_day28)' => 'pay_amount_day28',
- 'sum(pay_amount_day29)' => 'pay_amount_day29',
- 'sum(pay_amount_day30)' => 'pay_amount_day30',
- ];
-
- protected function getWhere($param = []) {
- $_map = [];
- if (!empty($param['start_time']) && !empty($param['end_time'])) {
- $_map['date'] = ['between', [$param['start_time'], $param['end_time']]];
- } elseif (!empty($param['start_time'])) {
- $_map['date'] = ['egt', $param['start_time']];
- } elseif (!empty($param['end_time'])) {
- $_map['date'] = ['elt', $param['end_time']];
- }
- $_agent_model = new UserModel();
- if (!empty($param['cp_id'])) {
- $_ids = $_agent_model->getIdsByCpId(
- $param['cp_id'], ['in', [AgentConst::AGENT_ROLE_MP_AGENT, AgentConst::AGENT_ROLE_MP_AD]]
- );
- if (empty($_ids)) {
- $_ids = [-1];
- }
- $_map['agent_id'] = ['in', $_ids];
- }
- if (!empty($param['agent_level_1_id'])) {
- $_agent_map = [
- 'role_id' => ['in', [AgentConst::AGENT_ROLE_MP_AGENT, AgentConst::AGENT_ROLE_MP_AD]]
- ];
- $_ids = $_agent_model->getIdsByParentId($param['agent_level_1_id'], $_agent_map);
- $_ids[] = $param['agent_level_1_id'];
- $_map['agent_id'] = ['in', $_ids];
- }
- if (!empty($param['agent_level_2_id'])) {
- $_map['agent_id'] = $param['agent_level_2_id'];
- }
- if (!empty($param['agent_id'])) {
- $_map['agent_id'] = $param['agent_id'];
- }
- if (!empty($param['sub_agent_id'])) {
- $_map['agent_id'] = $param['sub_agent_id'];
- }
- if (!empty($param['game_id'])) {
- $_map['app_id'] = $param['game_id'];
- }
- $_game_model = new GameModel();
- if (!empty($param['app_id'])) {
- $_ids = $_game_model->getGameIds($param['app_id']);
- $_map['app_id'] = ['in', $_ids];
- }
-
- $_class = '\\huosdk\\auth\\controller\\Auth';
- if (class_exists($_class)) {
- $_map = (new $_class())->getAgentIdBySearch(
- get_val($_map, 'agent_id', 0), $_map, cmf_get_current_admin_id()
- );
- $_map = (new $_class())->getAppIdBySearch(get_val($_map, 'app_id', 0), $_map, cmf_get_current_admin_id());
- }
-
- return $_map;
- }
-
- public function getDataModel($where) {
- if (!empty($where['agent_id']) && !empty($where['app_id'])) {
- return new DayGameAgentModel();
- } elseif (!empty($where['agent_id'])) {
- return new DayAgentModel();
- } elseif (!empty($where['app_id'])) {
- return new DayGameModel();
- } else {
- return new DayModel();
- }
- }
-
- public function getField($where, $is_summary = 0) {
- if (CommonConst::STATUS_YES == $is_summary) {
- $_field = $this->sum_field;
- $_field['date'] = 'date';
- } else {
- $_field = $this->base_field;
- }
- if (!empty($where['agent_id']) && !empty($where['app_id'])) {
- $_field['agent_id'] = 'agent_id';
- $_field['app_id'] = 'app_id';
- } elseif (!empty($where['agent_id'])) {
- $_field['agent_id'] = 'agent_id';
- } elseif (!empty($where['app_id'])) {
- $_field['app_id'] = 'app_id';
- }
- return $_field;
- }
-
- public function getSumField($where) {
- $_field = $this->sum_field;
- if (!empty($where['agent_id']) && !empty($where['app_id'])) {
- $_field['agent_id'] = 'agent_id';
- $_field['app_id'] = 'app_id';
- } elseif (!empty($where['agent_id'])) {
- $_field['agent_id'] = 'agent_id';
- } elseif (!empty($where['app_id'])) {
- $_field['app_id'] = 'app_id';
- }
- return $_field;
- }
-
- public function getTodayData($where) {
- $_map = $this->getWhere($where);
- if (isset($_map['agent_id']) && -1 == $_map['agent_id']) {
- $_map['agent_id'] = 0;
- }
- $_date = date('Y-m-d');
- $_today_data = (new StatisticsLogic())->getTodayData($_map);
- $_data = [$_today_data];
- if (empty($_data)) {
- return [];
- }
- $_agdc_model = new AgentGameDateCostModel();
- $_game_cache = new GameCache();
- $_agent_cache = new AgentCache();
- foreach ($_data as $_k => $_v) {
- $_agdc_map = [
- 'date' => $_date
- ];
- if (!empty($_map['app_id'])) {
- $_agdc_map['app_id'] = $_map['app_id'];
- }
- if (CommonConst::STATUS_NO == $where['is_summary'] && !empty($_v['agent_id'])) {
- $_agdc_map['agent_id'] = $_v['agent_id'];
- } elseif (!empty($_map['agent_id'])) {
- $_agdc_map['agent_id'] = $_map['agent_id'];
- }
- if (empty($_v['app_id'])) {
- $_data[$_k]['game_name'] = '';
- } else {
- $_game_data = $_game_cache->getInfoByAppId($_v['app_id']);
- $_data[$_k]['game_name'] = get_val($_game_data, 'name', '');
- }
- if (empty($_v['agent_id'])) {
- $_data[$_k]['agent_name'] = '';
- } else {
- $_agent_data = $_agent_cache->getInfoByAgentId($_v['agent_id']);
- $_data[$_k]['agent_name'] = get_val($_agent_data, 'user_login', '');
- }
- $_data[$_k]['agent_name'] = $_agdc_model->getCostByWhere($_agdc_map);
- $_data[$_k]['cost'] = $_agdc_model->getCostByWhere($_agdc_map);
- $_data[$_k]['price'] = StrUtils::getArpu($_data[$_k]['cost'], $_data[$_k]['reg_cnt']);
- $_data[$_k]['reg_pay_rate'] = StrUtils::getRate($_data[$_k]['reg_pay_cnt'], $_data[$_k]['reg_cnt']);
- $_data[$_k]['user_pay_rate'] = StrUtils::getRate($_data[$_k]['pay_user_cnt'], $_data[$_k]['user_cnt']);
- $_data[$_k]['reg_arpu'] = StrUtils::getArpu($_data[$_k]['reg_sum_money'], $_data[$_k]['reg_cnt']);
- $_data[$_k]['arpu'] = StrUtils::getArpu($_data[$_k]['sum_money'], $_data[$_k]['user_cnt']);
- $_data[$_k]['arppu'] = StrUtils::getArpu($_data[$_k]['sum_money'], $_data[$_k]['pay_user_cnt']);
- $_data[$_k]['first_day_ltv'] = StrUtils::getArpu($_data[$_k]['reg_sum_money'], $_data[$_k]['reg_cnt']);
- }
- return $_data;
- }
-
- public function getList($where, $page = '1,10', $order = '-date') {
- $_map = $this->getWhere($where);
- if (!empty(request()->default_agent_ids)) {
- $_map['agent_id'] = ['in', request()->default_agent_ids];
- $where['is_summary'] = CommonConst::STATUS_YES;
- }
- $_model = $this->getDataModel($_map);
- if (isset($_map['agent_id']) && -1 == $_map['agent_id']) {
- $_map['agent_id'] = 0;
- }
- $_agdc_model = new AgentGameDateCostModel();
- $_model->where($_map);
- if (CommonConst::STATUS_YES == $where['is_summary']) {
- $_model->group('date');
- }
- $_count = $_model->count();
- $_sum_field = $this->sum_field;
- $_sum_data = $_model
- ->field($_sum_field)
- ->where($_map)
- ->find();
- if (is_object($_sum_data)) {
- $_sum_data = $_sum_data->toArray();
- }
- $_sum = $_sum_data;
- if ($where['end_time'] >= date('Y-m-d')) {
-
- $_today_data = $this->getTodayData($where);
- foreach ($_sum as $_sum_key => $_sum_value) {
- if (isset($_today_data[0][$_sum_key])) {
- $_sum[$_sum_key] += $_today_data[0][$_sum_key];
- }
- }
- }
- $_sum['cost'] = $_agdc_model->getCostByWhere($_map);
- $_sum['price'] = StrUtils::getArpu($_sum['cost'], $_sum_data['reg_cnt']);
- $_sum['act_pay_rate'] = StrUtils::getRate($_sum_data['reg_pay_cnt'], $_sum_data['today_cnt']);
- $_sum['reg_pay_rate'] = StrUtils::getRate($_sum_data['reg_pay_cnt'], $_sum_data['reg_cnt']);
- $_sum['user_pay_rate'] = StrUtils::getRate($_sum_data['pay_user_cnt'], $_sum_data['user_cnt']);
- $_sum['reg_arpu'] = StrUtils::getArpu($_sum_data['reg_sum_money'], $_sum_data['reg_cnt']);
- $_sum['arpu'] = StrUtils::getArpu($_sum_data['sum_money'], $_sum_data['user_cnt']);
- $_sum['arppu'] = StrUtils::getArpu($_sum_data['sum_money'], $_sum_data['pay_user_cnt']);
- $_sum['acr'] = StrUtils::getRate($_sum_data['reg_cnt'], $_sum_data['today_cnt']);
- $_sum['first_day_ltv'] = StrUtils::getArpu($_sum_data['reg_sum_money'], $_sum_data['reg_cnt']);
- $_sum['average_stay_time'] = StrUtils::getArpu($_sum_data['stay_time'], $_sum_data['click_cnt']);
- if (empty($_count)) {
- return [
- 'count' => 0,
- 'sum' => $_sum,
- 'list' => []
- ];
- }
- $_order = $_model->orderFilter($order);
- $_field = $this->getField($_map, $where['is_summary']);
- $_model->where($_map)->field($_field)->order($_order);
- if (CommonConst::STATUS_YES == $where['is_summary']) {
- $_model->group('date');
- }
- $_datas = $_model->page($page)->select();
- if (is_object($_datas)) {
- $_datas = $_datas->toArray();
- }
- if (empty($_datas)) {
- return [
- 'count' => $_count,
- 'sum' => $_sum,
- 'list' => []
- ];
- }
- $_game_cache = GameCache::ins();
- $_agent_cache = AgentCache::ins();
- foreach ($_datas as $_k => $_v) {
- $_agdc_map = [
- 'date' => $_v['date']
- ];
- if (!empty($_v['app_id'])) {
- $_agdc_map['app_id'] = $_v['app_id'];
- }
- if (CommonConst::STATUS_NO == $where['is_summary'] && !empty($_v['agent_id'])) {
- $_agdc_map['agent_id'] = $_v['agent_id'];
- } elseif (!empty($_map['agent_id'])) {
- $_agdc_map['agent_id'] = $_map['agent_id'];
- }
- if (empty($_v['app_id'])) {
- $_data[$_k]['game_name'] = '';
- } else {
- $_game_data = $_game_cache->getInfoByAppId($_v['app_id']);
- $_data[$_k]['game_name'] = get_val($_game_data, 'name', '');
- }
- if (empty($_v['agent_id'])) {
- $_data[$_k]['agent_name'] = '';
- } else {
- $_agent_data = $_agent_cache->getInfoByAgentId($_v['agent_id']);
- $_data[$_k]['agent_name'] = get_val($_agent_data, 'user_login', '');
- }
- $_datas[$_k]['cost'] = $_agdc_model->getCostByWhere($_agdc_map);
- $_datas[$_k]['price'] = StrUtils::getArpu($_datas[$_k]['cost'], $_v['reg_cnt']);
- $_datas[$_k]['agent_name'] = !empty($_v['agent']) ? $_v['agent']['user_login'] : '';
- $_datas[$_k]['agent_name'] = !empty($_v['agent']) ? $_v['agent']['user_login'] : '';
- $_datas[$_k]['reg_pay_rate'] = StrUtils::getRate($_v['reg_pay_cnt'], $_v['reg_cnt']);
- $_datas[$_k]['user_pay_rate'] = StrUtils::getRate($_v['pay_user_cnt'], $_v['user_cnt']);
- $_datas[$_k]['act_pay_rate'] = StrUtils::getRate($_v['reg_pay_cnt'], $_v['today_cnt']);
- $_datas[$_k]['reg_arpu'] = StrUtils::getArpu($_v['reg_sum_money'], $_v['reg_cnt']);
- $_datas[$_k]['arppu'] = StrUtils::getArpu($_v['sum_money'], $_v['pay_user_cnt']);
- $_datas[$_k]['arpu'] = StrUtils::getArpu($_v['sum_money'], $_v['user_cnt']);
- $_datas[$_k]['acr'] = StrUtils::getRate($_v['reg_cnt'], $_v['today_cnt']);
- $_datas[$_k]['first_day_ltv'] = StrUtils::getArpu($_v['reg_sum_money'], $_v['reg_cnt']);
- $_datas[$_k]['average_stay_time'] = StrUtils::getArpu($_v['stay_time'], $_v['click_cnt']);
- }
- return [
- 'count' => $_count,
- 'sum' => $_sum,
- 'list' => $_datas
- ];
- }
- }
|