* @version : HUOSDK-MP */ 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', /* 独立IP数 */ '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', ]; /** * @param array $param * * @return array */ 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]; } /* Modified by wuyonghong BEGIN 2020/10/7 ISSUES:13308 小游戏后台cp功能开发 */ $_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()); } /* END 2020/10/7 ISSUES:13308 */ return $_map; } /** * @param array $where * * @return DayAgentModel|DayGameAgentModel|DayGameModel|DayModel|null|\think\Model */ 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(); } } /** * 获取字段 * * @param $where * * @return array */ 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; } /** * 获取字段 * * @param $where * * @return array */ 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; } /** * 获取今日数据 * * @param $where * * @return array|bool|false */ 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'); // $_map['date'] = $_date; // $_group = 'date'; // if (!empty($_map['agent_id']) && !empty($_map['app_id'])) { // $_group .= ',app_id'; // if (CommonConst::STATUS_NO == $where['is_summary']) { // $_group .= ',agent_id'; // } // } elseif (!empty($_map['agent_id']) && CommonConst::STATUS_NO == $where['is_summary']) { // $_group .= ',agent_id'; // } elseif (!empty($where['app_id'])) { // $_group .= ',app_id'; // } // $_field = [ // 'date' => 'date', // 'app_id' => 'app_id', // 'agent_id' => 'agent_id', // 'COUNT(DISTINCT `mem_id`)' => 'active_cnt', // // 'SUM(`login_cnt`)' => 'click_cnt', // 'SUM(`login_cnt`)' => 'click_cnt', // // 'SUM(`stay_time`)' => 'stay_time', // 'COUNT(DISTINCT `mem_id` )' => 'user_cnt', // 'COUNT(DISTINCT `last_login_ip` )' => 'ip_cnt', // 'COUNT(DISTINCT(CASE WHEN `reg_days`= 0 THEN `mem_id` END))' => 'reg_cnt', // 'COUNT(DISTINCT(CASE WHEN `reg_days`= 0 THEN `device_id` END))' => 'reg_device_cnt', // 'COUNT(DISTINCT(CASE WHEN `reg_days`= 0 THEN `last_login_ip` END))' => 'reg_ip_cnt', // 'COUNT(DISTINCT(CASE WHEN `sum_money`>0 THEN `mem_id` END))' => 'pay_user_cnt', // // 'COUNT(DISTINCT(CASE WHEN `first_pay_time`>0 THEN `mem_id` END))' => 'first_pay_user_cnt', // // 'SUM(`order_suc_cnt`)' => 'order_cnt', // 'COUNT(DISTINCT(CASE WHEN `reg_days`=0 AND `sum_money`>0 THEN `mem_id` END))' => 'reg_pay_cnt', // 'SUM(`sum_money`)' => 'sum_money', // 'SUM(`order_cnt`)' => 'order_cnt', // // 'SUM(`sum_real_money`)' => 'sum_real_money', // 'SUM(CASE WHEN `reg_days`= 0 THEN `sum_money` END)' => 'reg_sum_money', // 'SUM(CASE WHEN `reg_days`= 0 THEN `sum_real_money` END)' => 'reg_real_sum_money', // ]; // $_data = (new DayMemLogModel())->computeTable($_date)->field($_field)->where($_map)->group($_group)->select(); // if (is_object($_data)) { // $_data = $_data->toArray(); // } $_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']); // $_data[$_k]['average_stay_time'] = StrUtils::getArpu($_data[$_k]['stay_time'], $_data[$_k]['click_cnt']); } return $_data; } /** * 获取列表 * * @param array $where * @param string $page * @param string $order * * @return array */ 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 ]; } }