DayDataLogic.php 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489
  1. <?php
  2. /**
  3. * DayDataLogic.php UTF-8
  4. * 数据 #13831
  5. *
  6. * @date : 2020/12/16 10:08
  7. *
  8. * @license 这不是一个自由软件,未经授权不许任何使用和传播。
  9. * @author : chenbingling <cbl@huosdk.com>
  10. * @version : HUOSDK-MP
  11. */
  12. namespace huomp\logic\data;
  13. use huo\controller\agent\AgentCache;
  14. use huo\controller\game\GameCache;
  15. use huo\logic\data\StatisticsLogic;
  16. use huo\model\common\CommonModel;
  17. use huo\model\data\DayAgentModel;
  18. use huo\model\data\DayGameAgentModel;
  19. use huo\model\data\DayGameModel;
  20. use huo\model\data\DayModel;
  21. use huo\model\game\GameModel;
  22. use huo\model\log\DayMemLogModel;
  23. use huo\model\user\UserModel;
  24. use huolib\constant\AgentConst;
  25. use huolib\constant\CommonConst;
  26. use huolib\tool\StrUtils;
  27. use huomp\model\agent\AgentGameDateCostModel;
  28. class DayDataLogic extends CommonModel {
  29. private $base_field
  30. = [
  31. 'date' => 'date', /* 日期 */
  32. 'active_cnt' => 'active_cnt', /* 访问人数 */
  33. 'today_cnt' => 'today_cnt', /* 访问人数 */
  34. 'ip_cnt' => 'ip_cnt', /* 独立IP数 */
  35. 'user_cnt' => 'user_cnt', /* 活跃玩家数量 */
  36. 'reg_device_cnt' => 'reg_device_cnt', /* 新增设备 */
  37. 'reg_cnt' => 'reg_cnt', /* 注册玩家数 */
  38. 'pay_user_cnt' => 'pay_user_cnt',/* 付费玩家数 */
  39. 'order_cnt' => 'order_cnt', /* 成功订单数 */
  40. 'reg_pay_cnt' => 'reg_pay_cnt', /* 新增即付费人数 */
  41. 'sum_money' => 'sum_money', /* 充值金额 */
  42. 'reg_sum_money' => 'reg_sum_money', /* 新增即付总额 */
  43. 'click_cnt' => 'click_cnt', /* 新增即付总额 */
  44. 'stay_time' => 'stay_time', /* 新增即付总额 */
  45. ];
  46. private $sum_field
  47. = [
  48. 'sum(active_cnt)' => 'active_cnt',
  49. 'sum(today_cnt)' => 'today_cnt',
  50. 'sum(ip_cnt)' => 'ip_cnt',
  51. 'sum(order_cnt)' => 'order_cnt',
  52. 'sum(user_cnt)' => 'user_cnt',
  53. 'sum(reg_device_cnt)' => 'reg_device_cnt',
  54. 'sum(reg_cnt)' => 'reg_cnt',
  55. 'sum(pay_user_cnt)' => 'pay_user_cnt',
  56. 'sum(reg_order_cnt)' => 'reg_order_cnt',
  57. 'sum(reg_pay_cnt)' => 'reg_pay_cnt',
  58. 'sum(sum_money)' => 'sum_money',
  59. 'sum(reg_sum_money)' => 'reg_sum_money',
  60. 'sum(click_cnt)' => 'click_cnt',
  61. 'sum(stay_time)' => 'stay_time',
  62. ];
  63. private $output_base_field
  64. = [
  65. 'date' => 'date', /* 日期 */
  66. 'reg_cnt' => 'reg_cnt', /* 注册玩家数 */
  67. 'reg_pay_cnt' => 'reg_pay_cnt', /* 新增即付费人数 */
  68. 'reg_sum_money' => 'reg_sum_money', /* 新增即付总额 */
  69. 'pay_amount_day2' => 'pay_amount_day2', /* 二日留存付费金额 */
  70. 'pay_amount_day3' => 'pay_amount_day3', /* 三日留存付费金额 */
  71. 'pay_amount_day4' => 'pay_amount_day4', /* 四日留存付费金额 */
  72. 'pay_amount_day5' => 'pay_amount_day5', /* 五日留存付费金额 */
  73. 'pay_amount_day6' => 'pay_amount_day6', /* 六日留存付费金额 */
  74. 'pay_amount_day7' => 'pay_amount_day7', /* 七日留存付费金额 */
  75. 'pay_amount_day8' => 'pay_amount_day8', /* 八日留存付费金额 */
  76. 'pay_amount_day9' => 'pay_amount_day9', /* 九日留存付费金额 */
  77. 'pay_amount_day10' => 'pay_amount_day10', /* 十日留存付费金额 */
  78. 'pay_amount_day11' => 'pay_amount_day11', /* 十一日留存付费金额 */
  79. 'pay_amount_day12' => 'pay_amount_day12', /* 十二日留存付费金额 */
  80. 'pay_amount_day13' => 'pay_amount_day13', /* 十三日留存付费金额 */
  81. 'pay_amount_day14' => 'pay_amount_day14', /* 十四日留存付费金额 */
  82. 'pay_amount_day15' => 'pay_amount_day15', /* 十五日留存付费金额 */
  83. 'pay_amount_day16' => 'pay_amount_day16', /* 十六日留存付费金额 */
  84. 'pay_amount_day17' => 'pay_amount_day17', /* 十七日留存付费金额 */
  85. 'pay_amount_day18' => 'pay_amount_day18', /* 十八日留存付费金额 */
  86. 'pay_amount_day19' => 'pay_amount_day19', /* 十九日留存付费金额 */
  87. 'pay_amount_day20' => 'pay_amount_day20', /* 二十日留存付费金额 */
  88. 'pay_amount_day21' => 'pay_amount_day21', /* 二一日留存付费金额 */
  89. 'pay_amount_day22' => 'pay_amount_day22', /* 二二日留存付费金额 */
  90. 'pay_amount_day23' => 'pay_amount_day23', /* 二三日留存付费金额 */
  91. 'pay_amount_day24' => 'pay_amount_day24', /* 二四日留存付费金额 */
  92. 'pay_amount_day25' => 'pay_amount_day25', /* 二五日留存付费金额 */
  93. 'pay_amount_day26' => 'pay_amount_day26', /* 二六日留存付费金额 */
  94. 'pay_amount_day27' => 'pay_amount_day27', /* 二七日留存付费金额 */
  95. 'pay_amount_day28' => 'pay_amount_day28', /* 二八日留存付费金额 */
  96. 'pay_amount_day29' => 'pay_amount_day29', /* 二九日留存付费金额 */
  97. 'pay_amount_day30' => 'pay_amount_day30', /* 三十日留存付费金额 */
  98. ];
  99. private $output_sum_field
  100. = [
  101. 'sum(reg_cnt)' => 'reg_cnt',
  102. 'sum(reg_pay_cnt)' => 'reg_pay_cnt',
  103. 'sum(reg_sum_money)' => 'reg_sum_money',
  104. 'sum(pay_amount_day2)' => 'pay_amount_day2',
  105. 'sum(pay_amount_day3)' => 'pay_amount_day3',
  106. 'sum(pay_amount_day4)' => 'pay_amount_day4',
  107. 'sum(pay_amount_day5)' => 'pay_amount_day5',
  108. 'sum(pay_amount_day6)' => 'pay_amount_day6',
  109. 'sum(pay_amount_day7)' => 'pay_amount_day7',
  110. 'sum(pay_amount_day8)' => 'pay_amount_day8', /* 八日留存付费金额 */
  111. 'sum(pay_amount_day9)' => 'pay_amount_day9', /* 九日留存付费金额 */
  112. 'sum(pay_amount_day10)' => 'pay_amount_day10', /* 十日留存付费金额 */
  113. 'sum(pay_amount_day11)' => 'pay_amount_day11', /* 十一日留存付费金额 */
  114. 'sum(pay_amount_day12)' => 'pay_amount_day12', /* 十二日留存付费金额 */
  115. 'sum(pay_amount_day13)' => 'pay_amount_day13', /* 十三日留存付费金额 */
  116. 'sum(pay_amount_day14)' => 'pay_amount_day14', /* 十四日留存付费金额 */
  117. 'sum(pay_amount_day15)' => 'pay_amount_day15',
  118. 'sum(pay_amount_day16)' => 'pay_amount_day16', /* 十六日留存付费金额 */
  119. 'sum(pay_amount_day17)' => 'pay_amount_day17', /* 十七日留存付费金额 */
  120. 'sum(pay_amount_day18)' => 'pay_amount_day18', /* 十八日留存付费金额 */
  121. 'sum(pay_amount_day19)' => 'pay_amount_day19', /* 十九日留存付费金额 */
  122. 'sum(pay_amount_day20)' => 'pay_amount_day20', /* 二十日留存付费金额 */
  123. 'sum(pay_amount_day21)' => 'pay_amount_day21', /* 二一日留存付费金额 */
  124. 'sum(pay_amount_day22)' => 'pay_amount_day22', /* 二二日留存付费金额 */
  125. 'sum(pay_amount_day23)' => 'pay_amount_day23', /* 二三日留存付费金额 */
  126. 'sum(pay_amount_day24)' => 'pay_amount_day24', /* 二四日留存付费金额 */
  127. 'sum(pay_amount_day25)' => 'pay_amount_day25', /* 二五日留存付费金额 */
  128. 'sum(pay_amount_day26)' => 'pay_amount_day26', /* 二六日留存付费金额 */
  129. 'sum(pay_amount_day27)' => 'pay_amount_day27', /* 二七日留存付费金额 */
  130. 'sum(pay_amount_day28)' => 'pay_amount_day28', /* 二八日留存付费金额 */
  131. 'sum(pay_amount_day29)' => 'pay_amount_day29', /* 二九日留存付费金额 */
  132. 'sum(pay_amount_day30)' => 'pay_amount_day30',
  133. ];
  134. /**
  135. * @param array $param
  136. *
  137. * @return array
  138. */
  139. protected function getWhere($param = []) {
  140. $_map = [];
  141. if (!empty($param['start_time']) && !empty($param['end_time'])) {
  142. $_map['date'] = ['between', [$param['start_time'], $param['end_time']]];
  143. } elseif (!empty($param['start_time'])) {
  144. $_map['date'] = ['egt', $param['start_time']];
  145. } elseif (!empty($param['end_time'])) {
  146. $_map['date'] = ['elt', $param['end_time']];
  147. }
  148. $_agent_model = new UserModel();
  149. if (!empty($param['cp_id'])) {
  150. $_ids = $_agent_model->getIdsByCpId(
  151. $param['cp_id'], ['in', [AgentConst::AGENT_ROLE_MP_AGENT, AgentConst::AGENT_ROLE_MP_AD]]
  152. );
  153. if (empty($_ids)) {
  154. $_ids = [-1];
  155. }
  156. $_map['agent_id'] = ['in', $_ids];
  157. }
  158. if (!empty($param['agent_level_1_id'])) {
  159. $_agent_map = [
  160. 'role_id' => ['in', [AgentConst::AGENT_ROLE_MP_AGENT, AgentConst::AGENT_ROLE_MP_AD]]
  161. ];
  162. $_ids = $_agent_model->getIdsByParentId($param['agent_level_1_id'], $_agent_map);
  163. $_ids[] = $param['agent_level_1_id'];
  164. $_map['agent_id'] = ['in', $_ids];
  165. }
  166. if (!empty($param['agent_level_2_id'])) {
  167. $_map['agent_id'] = $param['agent_level_2_id'];
  168. }
  169. if (!empty($param['agent_id'])) {
  170. $_map['agent_id'] = $param['agent_id'];
  171. }
  172. if (!empty($param['sub_agent_id'])) {
  173. $_map['agent_id'] = $param['sub_agent_id'];
  174. }
  175. if (!empty($param['game_id'])) {
  176. $_map['app_id'] = $param['game_id'];
  177. }
  178. $_game_model = new GameModel();
  179. if (!empty($param['app_id'])) {
  180. $_ids = $_game_model->getGameIds($param['app_id']); // 查询父子孙级
  181. $_map['app_id'] = ['in', $_ids];
  182. }
  183. /* Modified by wuyonghong BEGIN 2020/10/7 ISSUES:13308 小游戏后台cp功能开发 */
  184. $_class = '\\huosdk\\auth\\controller\\Auth';
  185. if (class_exists($_class)) {
  186. $_map = (new $_class())->getAgentIdBySearch(
  187. get_val($_map, 'agent_id', 0), $_map, cmf_get_current_admin_id()
  188. );
  189. $_map = (new $_class())->getAppIdBySearch(get_val($_map, 'app_id', 0), $_map, cmf_get_current_admin_id());
  190. }
  191. /* END 2020/10/7 ISSUES:13308 */
  192. return $_map;
  193. }
  194. /**
  195. * @param array $where
  196. *
  197. * @return DayAgentModel|DayGameAgentModel|DayGameModel|DayModel|null|\think\Model
  198. */
  199. public function getDataModel($where) {
  200. if (!empty($where['agent_id']) && !empty($where['app_id'])) {
  201. return new DayGameAgentModel();
  202. } elseif (!empty($where['agent_id'])) {
  203. return new DayAgentModel();
  204. } elseif (!empty($where['app_id'])) {
  205. return new DayGameModel();
  206. } else {
  207. return new DayModel();
  208. }
  209. }
  210. /**
  211. * 获取字段
  212. *
  213. * @param $where
  214. *
  215. * @return array
  216. */
  217. public function getField($where, $is_summary = 0) {
  218. if (CommonConst::STATUS_YES == $is_summary) {
  219. $_field = $this->sum_field;
  220. $_field['date'] = 'date';
  221. } else {
  222. $_field = $this->base_field;
  223. }
  224. if (!empty($where['agent_id']) && !empty($where['app_id'])) {
  225. $_field['agent_id'] = 'agent_id';
  226. $_field['app_id'] = 'app_id';
  227. } elseif (!empty($where['agent_id'])) {
  228. $_field['agent_id'] = 'agent_id';
  229. } elseif (!empty($where['app_id'])) {
  230. $_field['app_id'] = 'app_id';
  231. }
  232. return $_field;
  233. }
  234. /**
  235. * 获取字段
  236. *
  237. * @param $where
  238. *
  239. * @return array
  240. */
  241. public function getSumField($where) {
  242. $_field = $this->sum_field;
  243. if (!empty($where['agent_id']) && !empty($where['app_id'])) {
  244. $_field['agent_id'] = 'agent_id';
  245. $_field['app_id'] = 'app_id';
  246. } elseif (!empty($where['agent_id'])) {
  247. $_field['agent_id'] = 'agent_id';
  248. } elseif (!empty($where['app_id'])) {
  249. $_field['app_id'] = 'app_id';
  250. }
  251. return $_field;
  252. }
  253. /**
  254. * 获取今日数据
  255. *
  256. * @param $where
  257. *
  258. * @return array|bool|false
  259. */
  260. public function getTodayData($where) {
  261. $_map = $this->getWhere($where);
  262. if (isset($_map['agent_id']) && -1 == $_map['agent_id']) {
  263. $_map['agent_id'] = 0;
  264. }
  265. $_date = date('Y-m-d');
  266. // $_map['date'] = $_date;
  267. // $_group = 'date';
  268. // if (!empty($_map['agent_id']) && !empty($_map['app_id'])) {
  269. // $_group .= ',app_id';
  270. // if (CommonConst::STATUS_NO == $where['is_summary']) {
  271. // $_group .= ',agent_id';
  272. // }
  273. // } elseif (!empty($_map['agent_id']) && CommonConst::STATUS_NO == $where['is_summary']) {
  274. // $_group .= ',agent_id';
  275. // } elseif (!empty($where['app_id'])) {
  276. // $_group .= ',app_id';
  277. // }
  278. // $_field = [
  279. // 'date' => 'date',
  280. // 'app_id' => 'app_id',
  281. // 'agent_id' => 'agent_id',
  282. // 'COUNT(DISTINCT `mem_id`)' => 'active_cnt',
  283. // // 'SUM(`login_cnt`)' => 'click_cnt',
  284. // 'SUM(`login_cnt`)' => 'click_cnt',
  285. // // 'SUM(`stay_time`)' => 'stay_time',
  286. // 'COUNT(DISTINCT `mem_id` )' => 'user_cnt',
  287. // 'COUNT(DISTINCT `last_login_ip` )' => 'ip_cnt',
  288. // 'COUNT(DISTINCT(CASE WHEN `reg_days`= 0 THEN `mem_id` END))' => 'reg_cnt',
  289. // 'COUNT(DISTINCT(CASE WHEN `reg_days`= 0 THEN `device_id` END))' => 'reg_device_cnt',
  290. // 'COUNT(DISTINCT(CASE WHEN `reg_days`= 0 THEN `last_login_ip` END))' => 'reg_ip_cnt',
  291. // 'COUNT(DISTINCT(CASE WHEN `sum_money`>0 THEN `mem_id` END))' => 'pay_user_cnt',
  292. // // 'COUNT(DISTINCT(CASE WHEN `first_pay_time`>0 THEN `mem_id` END))' => 'first_pay_user_cnt',
  293. // // 'SUM(`order_suc_cnt`)' => 'order_cnt',
  294. // 'COUNT(DISTINCT(CASE WHEN `reg_days`=0 AND `sum_money`>0 THEN `mem_id` END))' => 'reg_pay_cnt',
  295. // 'SUM(`sum_money`)' => 'sum_money',
  296. // 'SUM(`order_cnt`)' => 'order_cnt',
  297. // // 'SUM(`sum_real_money`)' => 'sum_real_money',
  298. // 'SUM(CASE WHEN `reg_days`= 0 THEN `sum_money` END)' => 'reg_sum_money',
  299. // 'SUM(CASE WHEN `reg_days`= 0 THEN `sum_real_money` END)' => 'reg_real_sum_money',
  300. // ];
  301. // $_data = (new DayMemLogModel())->computeTable($_date)->field($_field)->where($_map)->group($_group)->select();
  302. // if (is_object($_data)) {
  303. // $_data = $_data->toArray();
  304. // }
  305. $_today_data = (new StatisticsLogic())->getTodayData($_map);
  306. $_data = [$_today_data];
  307. if (empty($_data)) {
  308. return [];
  309. }
  310. $_agdc_model = new AgentGameDateCostModel();
  311. $_game_cache = new GameCache();
  312. $_agent_cache = new AgentCache();
  313. foreach ($_data as $_k => $_v) {
  314. $_agdc_map = [
  315. 'date' => $_date
  316. ];
  317. if (!empty($_map['app_id'])) {
  318. $_agdc_map['app_id'] = $_map['app_id'];
  319. }
  320. if (CommonConst::STATUS_NO == $where['is_summary'] && !empty($_v['agent_id'])) {
  321. $_agdc_map['agent_id'] = $_v['agent_id'];
  322. } elseif (!empty($_map['agent_id'])) {
  323. $_agdc_map['agent_id'] = $_map['agent_id'];
  324. }
  325. if (empty($_v['app_id'])) {
  326. $_data[$_k]['game_name'] = '';
  327. } else {
  328. $_game_data = $_game_cache->getInfoByAppId($_v['app_id']);
  329. $_data[$_k]['game_name'] = get_val($_game_data, 'name', '');
  330. }
  331. if (empty($_v['agent_id'])) {
  332. $_data[$_k]['agent_name'] = '';
  333. } else {
  334. $_agent_data = $_agent_cache->getInfoByAgentId($_v['agent_id']);
  335. $_data[$_k]['agent_name'] = get_val($_agent_data, 'user_login', '');
  336. }
  337. $_data[$_k]['agent_name'] = $_agdc_model->getCostByWhere($_agdc_map);
  338. $_data[$_k]['cost'] = $_agdc_model->getCostByWhere($_agdc_map);
  339. $_data[$_k]['price'] = StrUtils::getArpu($_data[$_k]['cost'], $_data[$_k]['reg_cnt']);
  340. $_data[$_k]['reg_pay_rate'] = StrUtils::getRate($_data[$_k]['reg_pay_cnt'], $_data[$_k]['reg_cnt']);
  341. $_data[$_k]['user_pay_rate'] = StrUtils::getRate($_data[$_k]['pay_user_cnt'], $_data[$_k]['user_cnt']);
  342. $_data[$_k]['reg_arpu'] = StrUtils::getArpu($_data[$_k]['reg_sum_money'], $_data[$_k]['reg_cnt']);
  343. $_data[$_k]['arpu'] = StrUtils::getArpu($_data[$_k]['sum_money'], $_data[$_k]['user_cnt']);
  344. $_data[$_k]['arppu'] = StrUtils::getArpu($_data[$_k]['sum_money'], $_data[$_k]['pay_user_cnt']);
  345. $_data[$_k]['first_day_ltv'] = StrUtils::getArpu($_data[$_k]['reg_sum_money'], $_data[$_k]['reg_cnt']);
  346. // $_data[$_k]['average_stay_time'] = StrUtils::getArpu($_data[$_k]['stay_time'], $_data[$_k]['click_cnt']);
  347. }
  348. return $_data;
  349. }
  350. /**
  351. * 获取列表
  352. *
  353. * @param array $where
  354. * @param string $page
  355. * @param string $order
  356. *
  357. * @return array
  358. */
  359. public function getList($where, $page = '1,10', $order = '-date') {
  360. $_map = $this->getWhere($where);
  361. if (!empty(request()->default_agent_ids)) {
  362. $_map['agent_id'] = ['in', request()->default_agent_ids];
  363. $where['is_summary'] = CommonConst::STATUS_YES;
  364. }
  365. $_model = $this->getDataModel($_map);
  366. if (isset($_map['agent_id']) && -1 == $_map['agent_id']) {
  367. $_map['agent_id'] = 0;
  368. }
  369. $_agdc_model = new AgentGameDateCostModel();
  370. $_model->where($_map);
  371. if (CommonConst::STATUS_YES == $where['is_summary']) {
  372. $_model->group('date');
  373. }
  374. $_count = $_model->count();
  375. $_sum_field = $this->sum_field;
  376. $_sum_data = $_model
  377. ->field($_sum_field)
  378. ->where($_map)
  379. ->find();
  380. if (is_object($_sum_data)) {
  381. $_sum_data = $_sum_data->toArray();
  382. }
  383. $_sum = $_sum_data;
  384. if ($where['end_time'] >= date('Y-m-d')) {
  385. // 累加今日数据
  386. $_today_data = $this->getTodayData($where);
  387. foreach ($_sum as $_sum_key => $_sum_value) {
  388. if (isset($_today_data[0][$_sum_key])) {
  389. $_sum[$_sum_key] += $_today_data[0][$_sum_key];
  390. }
  391. }
  392. }
  393. $_sum['cost'] = $_agdc_model->getCostByWhere($_map);
  394. $_sum['price'] = StrUtils::getArpu($_sum['cost'], $_sum_data['reg_cnt']);
  395. $_sum['act_pay_rate'] = StrUtils::getRate($_sum_data['reg_pay_cnt'], $_sum_data['today_cnt']);
  396. $_sum['reg_pay_rate'] = StrUtils::getRate($_sum_data['reg_pay_cnt'], $_sum_data['reg_cnt']);
  397. $_sum['user_pay_rate'] = StrUtils::getRate($_sum_data['pay_user_cnt'], $_sum_data['user_cnt']);
  398. $_sum['reg_arpu'] = StrUtils::getArpu($_sum_data['reg_sum_money'], $_sum_data['reg_cnt']);
  399. $_sum['arpu'] = StrUtils::getArpu($_sum_data['sum_money'], $_sum_data['user_cnt']);
  400. $_sum['arppu'] = StrUtils::getArpu($_sum_data['sum_money'], $_sum_data['pay_user_cnt']);
  401. $_sum['acr'] = StrUtils::getRate($_sum_data['reg_cnt'], $_sum_data['today_cnt']);
  402. $_sum['first_day_ltv'] = StrUtils::getArpu($_sum_data['reg_sum_money'], $_sum_data['reg_cnt']);
  403. $_sum['average_stay_time'] = StrUtils::getArpu($_sum_data['stay_time'], $_sum_data['click_cnt']);
  404. if (empty($_count)) {
  405. return [
  406. 'count' => 0,
  407. 'sum' => $_sum,
  408. 'list' => []
  409. ];
  410. }
  411. $_order = $_model->orderFilter($order);
  412. $_field = $this->getField($_map, $where['is_summary']);
  413. $_model->where($_map)->field($_field)->order($_order);
  414. if (CommonConst::STATUS_YES == $where['is_summary']) {
  415. $_model->group('date');
  416. }
  417. $_datas = $_model->page($page)->select();
  418. if (is_object($_datas)) {
  419. $_datas = $_datas->toArray();
  420. }
  421. if (empty($_datas)) {
  422. return [
  423. 'count' => $_count,
  424. 'sum' => $_sum,
  425. 'list' => []
  426. ];
  427. }
  428. $_game_cache = GameCache::ins();
  429. $_agent_cache = AgentCache::ins();
  430. foreach ($_datas as $_k => $_v) {
  431. $_agdc_map = [
  432. 'date' => $_v['date']
  433. ];
  434. if (!empty($_v['app_id'])) {
  435. $_agdc_map['app_id'] = $_v['app_id'];
  436. }
  437. if (CommonConst::STATUS_NO == $where['is_summary'] && !empty($_v['agent_id'])) {
  438. $_agdc_map['agent_id'] = $_v['agent_id'];
  439. } elseif (!empty($_map['agent_id'])) {
  440. $_agdc_map['agent_id'] = $_map['agent_id'];
  441. }
  442. if (empty($_v['app_id'])) {
  443. $_data[$_k]['game_name'] = '';
  444. } else {
  445. $_game_data = $_game_cache->getInfoByAppId($_v['app_id']);
  446. $_data[$_k]['game_name'] = get_val($_game_data, 'name', '');
  447. }
  448. if (empty($_v['agent_id'])) {
  449. $_data[$_k]['agent_name'] = '';
  450. } else {
  451. $_agent_data = $_agent_cache->getInfoByAgentId($_v['agent_id']);
  452. $_data[$_k]['agent_name'] = get_val($_agent_data, 'user_login', '');
  453. }
  454. $_datas[$_k]['cost'] = $_agdc_model->getCostByWhere($_agdc_map);
  455. $_datas[$_k]['price'] = StrUtils::getArpu($_datas[$_k]['cost'], $_v['reg_cnt']);
  456. $_datas[$_k]['agent_name'] = !empty($_v['agent']) ? $_v['agent']['user_login'] : '';
  457. $_datas[$_k]['agent_name'] = !empty($_v['agent']) ? $_v['agent']['user_login'] : '';
  458. $_datas[$_k]['reg_pay_rate'] = StrUtils::getRate($_v['reg_pay_cnt'], $_v['reg_cnt']);
  459. $_datas[$_k]['user_pay_rate'] = StrUtils::getRate($_v['pay_user_cnt'], $_v['user_cnt']);
  460. $_datas[$_k]['act_pay_rate'] = StrUtils::getRate($_v['reg_pay_cnt'], $_v['today_cnt']);
  461. $_datas[$_k]['reg_arpu'] = StrUtils::getArpu($_v['reg_sum_money'], $_v['reg_cnt']);
  462. $_datas[$_k]['arppu'] = StrUtils::getArpu($_v['sum_money'], $_v['pay_user_cnt']);
  463. $_datas[$_k]['arpu'] = StrUtils::getArpu($_v['sum_money'], $_v['user_cnt']);
  464. $_datas[$_k]['acr'] = StrUtils::getRate($_v['reg_cnt'], $_v['today_cnt']);
  465. $_datas[$_k]['first_day_ltv'] = StrUtils::getArpu($_v['reg_sum_money'], $_v['reg_cnt']);
  466. $_datas[$_k]['average_stay_time'] = StrUtils::getArpu($_v['stay_time'], $_v['click_cnt']);
  467. }
  468. return [
  469. 'count' => $_count,
  470. 'sum' => $_sum,
  471. 'list' => $_datas
  472. ];
  473. }
  474. }