ChannelAnalysisLogic.php 65 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288
  1. <?php
  2. namespace app\v1\logic\dataReport;
  3. use app\v1\logic\tool\ToolLogic;
  4. use plugin\saiadmin\basic\BaseLogic;
  5. use support\think\Db;
  6. class ChannelAnalysisLogic extends BaseLogic
  7. {
  8. // 分时数据
  9. public function getHourDataList($where)
  10. {
  11. $params = $this->searchByAuth($where);
  12. // hour=>小时, reg_total=>注册数,cost=>消耗,pay_num=>付费总用户数,
  13. // pay_total=>付费总金额,reg_pay_num=>小时注册当天付费数,reg_pay_total=>小时注册当天付费金额
  14. // reg_pay_num_rg=>注册累计付费数,reg_pay_total_rg=>注册累计付费金额
  15. $field = "
  16. agent_id, thour as hour,
  17. SUM(reg_total) as reg_total,
  18. SUM(cost) as cost,
  19. SUM(pay_num) as pay_num,
  20. SUM(pay_total) as pay_total,
  21. SUM(reg_pay_num) as reg_pay_num,
  22. SUM(reg_pay_total) as reg_pay_total,
  23. SUM(reg_pay_num_rg) as reg_pay_num_rg,
  24. SUM(reg_pay_total_rg) as reg_pay_total_rg";
  25. $group = 'agent_id,thour';
  26. $whereSql = $this->generateWhereSql($params);
  27. // 根据日期,连表查询
  28. $tableNames = ToolLogic::getMonthlyTableNames('base_total_hour_', $where['reg_date'][0], $where['reg_date'][1]);
  29. $sqlParts = [];
  30. foreach ($tableNames as $tableName) {
  31. $sqlParts[] = "SELECT * FROM {$tableName} WHERE 1=1 {$whereSql}";
  32. }
  33. $unionSql = implode(" UNION ALL ", $sqlParts);
  34. // 外层包裹分页、排序
  35. $finalSql = " SELECT {$field} FROM ( {$unionSql} ) AS all_hour GROUP BY {$group} ";
  36. // 按小时数据
  37. $hourData = Db::connect('db_data_report')->query($finalSql);
  38. $total = [
  39. 'agent_id' => '合计'
  40. ];
  41. // 计算小时消耗数据的 注册成本、付费率、
  42. $hourResult = [];
  43. foreach ($hourData as $hourRow) {
  44. $agentId = $hourRow['agent_id'];
  45. $hourKey = 'h' . intval($hourRow['hour']);
  46. if (!isset($hourResult[$agentId])) {
  47. $hourResult[$agentId] = [
  48. 'agent_id' => $agentId
  49. ];
  50. }
  51. unset($hourRow['agent_id'], $hourRow['hour']);
  52. // 注册成本
  53. $hourRow['reg_cost'] = ToolLogic::getRound($hourRow['cost'], $hourRow['reg_total']);
  54. // 付费率
  55. $hourRow['pay_rate'] = ToolLogic::getPercent($hourRow['reg_pay_num'], $hourRow['reg_total']);
  56. // 回本率
  57. $hourRow['roi'] = ToolLogic::getPercent($hourRow['reg_pay_total'], $hourRow['cost']);
  58. // 统计数据,每小时的数据
  59. $total[$hourKey]['reg_total'] = !empty($total[$hourKey]['reg_total']) ? ($total[$hourKey]['reg_total'] + $hourRow['reg_total']) : $hourRow['reg_total'];
  60. $total[$hourKey]['cost'] = !empty($total[$hourKey]['cost']) ? round($total[$hourKey]['cost'] + $hourRow['cost'], 2) : $hourRow['cost'];
  61. $total[$hourKey]['reg_pay_total'] = !empty($total[$hourKey]['reg_pay_total']) ? ($total[$hourKey]['reg_pay_total'] + $hourRow['reg_pay_total']) : $hourRow['reg_pay_total'];
  62. $total[$hourKey]['reg_pay_num'] = !empty($total[$hourKey]['reg_pay_num']) ? ($total[$hourKey]['reg_pay_num'] + $hourRow['reg_pay_num']) : $hourRow['reg_pay_num'];
  63. $total['total_raw']['reg_total'] = !empty($total['total_raw']['reg_total']) ? ($total['total_raw']['reg_total'] + $hourRow['reg_total']) : $hourRow['reg_total'];
  64. $total['total_raw']['cost'] = !empty($total['total_raw']['cost']) ? round($total['total_raw']['cost'] + $hourRow['cost'], 2) : $hourRow['cost'];
  65. $total['total_raw']['reg_pay_total'] = !empty($total['total_raw']['reg_pay_total']) ? ($total['total_raw']['reg_pay_total'] + $hourRow['reg_pay_total']) : $hourRow['reg_pay_total'];
  66. $total['total_raw']['reg_pay_num'] = !empty($total['total_raw']['reg_pay_num']) ? ($total['total_raw']['reg_pay_num'] + $hourRow['reg_pay_num']) : $hourRow['reg_pay_num'];
  67. $hourResult[$agentId][$hourKey] = $hourRow;
  68. }
  69. // 计算统计的注册成本、付费绿、回本率
  70. foreach ($total as $key => &$v) {
  71. if (!is_array($v)) continue; // 跳过 agent_id => 合计 等非数组元素
  72. $v['reg_cost'] = ToolLogic::getRound($v['cost'], $v['reg_total']);
  73. $v['pay_rate'] = ToolLogic::getPercent($v['reg_pay_num'], $v['reg_total']);
  74. $v['roi'] = ToolLogic::getPercent($v['reg_pay_total'], $v['cost']);
  75. }
  76. // 计算行汇总
  77. foreach ($hourResult as &$item) {
  78. $item['total_raw']['cost'] = round(array_sum(array_column($item, 'cost')), 2);
  79. $item['total_raw']['reg_total'] = round(array_sum(array_column($item, 'reg_total')), 2);
  80. $item['total_raw']['reg_pay_num'] = round(array_sum(array_column($item, 'reg_pay_num')), 2);
  81. $item['total_raw']['reg'] = round(array_sum(array_column($item, 'reg')), 2);
  82. $item['total_raw']['pay_num'] = round(array_sum(array_column($item, 'pay_num')), 2);
  83. $item['total_raw']['pay'] = round(array_sum(array_column($item, 'pay')), 2);
  84. $item['total_raw']['reg_cost'] = ToolLogic::getRound($item['total_raw']['cost'], $item['total_raw']['reg'], 1);
  85. $item['total_raw']['pay_rate'] = ToolLogic::getPercent($item['total_raw']['pay_num'], $item['total_raw']['reg']);
  86. $item['total_raw']['roi'] = ToolLogic::getPercent($item['total_raw']['pay'], $item['total_raw']['cost']);
  87. }
  88. $data = array_values($hourResult);
  89. array_unshift($data, $total);
  90. return $data;
  91. }
  92. // 留存按日
  93. public function getActiveDataList($where): array
  94. {
  95. $params = $this->searchByAuth($where);
  96. $whereSql = $this->generateWhereSql($params);
  97. // 1. 注册数据:$regData = 按照日期,获取每日的 注册数【reg_total】分组,base_total_day_2025
  98. $baseTotalDayTableNames = ToolLogic::getYearlyTableNames('base_total_day_', $params['reg_date'][0], $params['reg_date'][1]);
  99. $baseTotalDaySqlParts = [];
  100. foreach ($baseTotalDayTableNames as $tableName) {
  101. $baseTotalDaySqlParts[] = "SELECT * FROM {$tableName} WHERE 1=1 {$whereSql}";
  102. }
  103. $unionBaseTotalDaySql = implode(" UNION ALL ", $baseTotalDaySqlParts);
  104. // 按照每日,获取=>注册数据
  105. $regData = Db::connect('db_data_report')->query("SELECT tdate, SUM('reg_total') reg_total FROM ( {$unionBaseTotalDaySql} ) AS all_base_total_day GROUP BY tdate order by tdate ");
  106. // 2. 活跃数据:$actData = 按照日期,获取每日的 活跃数 SUM(【active_total】) 活跃天数 【days】, 分组 【reg_date,days】,game_active_day_2025
  107. $gameActiveDayTableNames = ToolLogic::getYearlyTableNames('game_active_day_', $params['reg_date'][0], $params['reg_date'][1]);
  108. $gameActiveDaySqlParts = [];
  109. foreach ($gameActiveDayTableNames as $tableName) {
  110. if (!preg_match('/^game_active_day_\\d{4}$/', $tableName)) {
  111. continue;
  112. }
  113. $gameActiveDaySqlParts[] = "SELECT * FROM {$tableName} WHERE 1=1 {$whereSql}";
  114. }
  115. $unionGameActiveDaySql = implode(" UNION ALL ", $gameActiveDaySqlParts);
  116. $actDataSql = "select reg_date as tdate, days, sum(active_total) as active from ({$unionGameActiveDaySql}) as all_game_active_day group by reg_date,days";
  117. // 替换日期字段, 因为game_active_day_表的日期字段是[reg_date]
  118. $actDataSql = str_replace("AND tdate", "AND reg_date", $actDataSql);
  119. // 日期、活跃天数、活跃数,按日期和活跃天数分组
  120. $actData = Db::connect('db_data_report')->query($actDataSql);
  121. $tdate = date('Y-m-d');
  122. $list = $totalData = [];
  123. // 遍历每日的注册数
  124. foreach ($regData as $r) {
  125. // 如果当日没有注册的话,则跳过
  126. if (!$r['reg_total']) {
  127. continue;
  128. }
  129. // 注册日期
  130. $reg_date = $r['tdate'];
  131. $list[$reg_date]['tdate'] = $reg_date;
  132. // 注册数
  133. $list[$reg_date]['reg'] = $r['reg_total'];
  134. // 从注册日期 ($reg_date) 到当前日期的天数
  135. $days = (strtotime($tdate) - strtotime($reg_date)) / 86400;
  136. for ($i = 1; $i <= $days; $i++) {
  137. $dayKey = 'd' . $i;
  138. // d1...dn的reg = 记录按日的注册数
  139. $totalData[$dayKey]['reg'] += $r['reg_total'];
  140. }
  141. $totalData['reg'] += $r['reg_total'];
  142. }
  143. // 遍历每日的活跃数
  144. foreach ($actData as $r) {
  145. // 注册日期
  146. $reg_date = $r['tdate'];
  147. // 如果日期,没有注册数/活跃数, 则跳过
  148. if (!$list[$reg_date]['reg'] || !$r['active']) {
  149. continue;
  150. }
  151. // 如果活跃天数超过30天,并且活跃数不在[45,60,90,119,120]数组里面, 则跳过
  152. if ($r['days'] > 30 && !in_array($r['days'], [45, 60, 90, 119, 120])) {
  153. continue;
  154. }
  155. // 活跃天数的key
  156. $dayKey = 'd' . $r['days'];
  157. // N日留存率 = 第N天活跃数 ÷ 注册日注册数 × 100%。
  158. $list[$reg_date][$dayKey] = ToolLogic::getPercent($r['active'], $list[$reg_date]['reg']);
  159. // d1...dn的reg = 记录按日的活跃数
  160. $totalData[$dayKey]['active'] += $r['active'];
  161. }
  162. $total = [];
  163. foreach ($totalData as $key => $val) {
  164. if ($key == 'reg') {
  165. $total['reg'] = $val;
  166. } else {
  167. $total[$key] = ToolLogic::getPercent($val['active'], $val['reg']);
  168. }
  169. }
  170. return [
  171. 'data' => array_values($list),
  172. 'totalRow' => $total,
  173. ];
  174. }
  175. /**
  176. * @param $where
  177. * @return mixed
  178. * @description 渠道总览
  179. * 支出-> media_cost表的消耗数据
  180. * 激活(install)、注册设备(reg_dev)、注册数(reg_total)、创角数(role_create_user) -> base_total_day_2025表的数据
  181. * 注册成本-> 支出/注册数
  182. * 创角率 -> 创角数/注册数
  183. * 次留数 -> reg_date, days:1, active_total, game_active_day_2025
  184. * 次留率 -> 次留数 / reg_login_total
  185. * 次留成本 -> 支出 / 第二天的 ld_login_total
  186. * 当天付费金额 -> reg_pay_total
  187. * 总付费人数 -> pay_num
  188. * 总付费金额 -> pay_total
  189. * 付费率 -> 总付费人数 / 注册数
  190. * 当天回本率 -> 当天付费 / 支出
  191. * 累计回本率 -> 总付费 / 支出
  192. * 实际回本率 -> game_reg_pay_day_2025表的 addup_pay_amount / 支出
  193. * 7天实际回本率 -> game_reg_pay_day_2025表的 sum(addup_pay_amount) 根据注册时间 +6day, 遍历相加 / 支出
  194. * 付费成本 -> 总付费人数 / 支出
  195. * ARPU -> 付费总金额/ 付费总用户
  196. * 注册ARPU -> 注册付费金额/注册数
  197. * 老用户数 -> sum(old_login_total)
  198. * 负责人 -> 渠道负责人, 根据
  199. */
  200. public function getAgentDataList($where)
  201. {
  202. $params = $this->searchByAuth($where);
  203. // 忽略 0 投入
  204. $igz = !empty($params['filter']) && is_array($params['filter']) && in_array('igz', $params['filter']);
  205. $group = !empty($params['group']) ? $params['group'] : '';
  206. // 如果分组按照 游戏组ID||游戏组
  207. if ($group == 1) {
  208. $type = 'game_id';
  209. } else if ($group == 2) {
  210. $type = 'auth_id';
  211. } else if ($group == 3) {
  212. $type = 'media_id';
  213. } else {
  214. $type = 'agent_id';
  215. }
  216. $whereSql = $this->generateWhereSql($params);
  217. // 1.查询消耗数据, 安game_id/agent_id分组
  218. // 忽略后台录入的消耗
  219. $costWhereSql = $whereSql;
  220. if (!empty($params['filter']) && is_array($params['filter']) && in_array('fak', $params['filter'])) {
  221. $costWhereSql .= " AND add_type = 0";
  222. }
  223. $costSql = "SELECT {$type}, SUM(money) as cost from media_cost WHERE 1=1 {$costWhereSql} GROUP BY {$type}";
  224. $costData = Db::connect('db_advert')->query($costSql);
  225. $costDataColumn = array_column($costData, 'cost', $type);
  226. // 2.查询按日统计数据
  227. $totalDayField = "
  228. {$type},
  229. sum(install) as install,
  230. sum(reg_pay_total) as reg_pay_total_da,
  231. sum(reg_dev) as reg_dev,
  232. sum(reg_total) as reg_total,
  233. sum(login_total) as login_total,
  234. sum(old_login_total) as old_login_total,
  235. sum(role_create_user) as role_total,
  236. sum(pay_num) as pay_num_total,
  237. auth_id,
  238. media_id
  239. ";
  240. // 2. 获取基础报表数据,兼容跨年
  241. $baseData = $this->generateYearUnionList('base_total_day_', $params['reg_date'], $whereSql, $totalDayField, $type);
  242. // 3. 获取活跃数
  243. $activeWhereSql = $whereSql . ' AND days = 1';
  244. $activeWhereSql = str_replace('AND tdate', 'AND reg_date', $activeWhereSql);
  245. $activeField = "
  246. sum(active_total) as active,
  247. game_id,
  248. agent_id";
  249. $activeData = $this->generateYearUnionList('game_active_day_', $params['reg_date'], $activeWhereSql, $activeField, $type);
  250. $activeData = array_column($activeData, 'active', $type);
  251. // 4. 注册充值统计
  252. $regPayWhereSql = $whereSql;
  253. $regPayField = "
  254. sum(addup_pay_num) as reg_pay_num,
  255. sum(addup_pay_total) as reg_pay_total,
  256. sum(addup_pay_amount) as reg_pay_amount,
  257. {$type}";
  258. $regPayWhereSql = str_replace('AND tdate', 'AND reg_date', $regPayWhereSql);
  259. $regPayData = $this->generateYearUnionList('game_reg_pay_day_', $params['reg_date'], $regPayWhereSql, $regPayField, $type);
  260. $regPayData = array_column($regPayData, null, $type);
  261. // 5. 7天回本
  262. $hb7dayData = $this->computedHb7days($params, $type);
  263. $hb7dayData = array_column($hb7dayData ?? [], 'reg_pay_amount_7', $type);
  264. $hb7dayDataSum = 0;
  265. foreach ($hb7dayData as $daySum) {
  266. $hb7dayDataSum += $daySum;
  267. }
  268. if (empty($baseData)) {
  269. return [];
  270. }
  271. // 6. 所有游戏信息
  272. $gameData = Db::connect('db_center')->table('pf_game')->select()->toArray();
  273. // 7. 所有用户信息
  274. $authData = Db::connect('db_system')->table('sa_system_user')->select()->toArray();
  275. // 8. 媒体列表信息
  276. $mediaData = Db::connect('db_advert')->table('media_list')->select()->toArray();
  277. // 9. 渠道列表信息
  278. $agentData = Db::connect('db_advert')->table('agent_list')->select()->toArray();
  279. $gameData = array_column($gameData, null, 'id');
  280. $authData = array_column($authData, null, 'id');
  281. $mediaData = array_column($mediaData, null, 'id');
  282. // 拼接数据
  283. foreach ($baseData as $key => &$row) {
  284. $typeId = $row[$type]; // type, 的取值, 这里根据分组, game_id | agent_id
  285. $cost = $costDataColumn[$typeId] ?? 0;
  286. $row['cost'] = $cost;
  287. // 忽略0投入的
  288. if ($igz && $row['cost'] === 0) {
  289. unset($baseData[$key]);
  290. }
  291. // 注册成本
  292. $row['reg_cost'] = ToolLogic::getRound($cost, $row['reg_total'] ?? 0);
  293. // 创角率
  294. $row['role_per'] = ToolLogic::getRound($row['role_total'], $row['reg_total'] ?? 0);
  295. // 次留数
  296. $row['active'] = $activeData[$typeId]['active'] ?? 0;
  297. // 次留率
  298. $row['a_per'] = ToolLogic::getPercent($activeData[$typeId]['active'] ?? 0, $row['reg_total'], 1);
  299. // 次留成本
  300. $row['a_cost'] = ToolLogic::getRound($cost, $row['active'], 1);
  301. // 总付费金额
  302. $row['reg_pay_total'] = $regPayData[$typeId]['reg_pay_total'] ?? 0;
  303. // 总付费人数
  304. $row['reg_pay_num'] = $regPayData[$typeId]['reg_pay_num'] ?? 0;
  305. //付费成本
  306. $row['p_cost'] = ToolLogic::getRound($row['cost'], $row['reg_pay_num']);
  307. // 付费率
  308. $row['p_per'] = ToolLogic::getPercent($row['reg_pay_num'] ?? 0, $row['reg_total'], 1);
  309. // 当天回本率
  310. $row['da_per'] = ToolLogic::getPercent($row['reg_pay_total_da'] ?? 0, $row['cost'], 1);
  311. // 累计回本率
  312. $row['re_per'] = (float)trim(ToolLogic::getPercent($row['reg_pay_total'], $row['cost']), "%");
  313. $row['reg_pay_amount'] = $hb7dayData[$typeId]['reg_pay_amount'] ?? 0;
  314. // 实际回本率
  315. $row['re_amount_per'] = ToolLogic::getPercent($row['reg_pay_amount'], $row['cost'], 1);
  316. //ARPU
  317. $row['arpu'] = ToolLogic::getRound($row['reg_pay_total'], $row['reg_pay_num']);
  318. //注册ARPU
  319. $row['r_arpu'] = ToolLogic::getRound($row['reg_pay_total'], $row['reg_total']);
  320. // 7天回本率
  321. $row['re_amount_per_7'] = ToolLogic::getPercent($hb7dayData[$typeId] ?? 0, $row['cost'], 1);
  322. // 按分组信息展示,id和name
  323. switch ($params['group'] ?? '') {
  324. case 1:
  325. $row['akey'] = $row['game_id'];
  326. $row['name'] = $gameData[$row['game_id']]['name'] ?? "";
  327. $row['auth_name'] = '-';
  328. break;
  329. case 2:
  330. $row['akey'] = $row['auth_id'];
  331. $row['name'] = '-';
  332. $row['auth_name'] = $authData[$row['auth_id']]['username'] ?? "";
  333. case 3:
  334. $row['akey'] = $row['media_id'];
  335. $row['name'] = $mediaData[$row['media_id']]['name'] ?? "";
  336. $row['auth_name'] = $authData[$row['auth_id']]['username'] ?? "";
  337. default:
  338. $row['akey'] = $row['agent_id'];
  339. $row['name'] = $agentData[$row['agent_id']]['name'] ?? "";
  340. $row['auth_name'] = '-';
  341. break;
  342. }
  343. }
  344. // 底部合计
  345. $total = [
  346. 'akey' => '合计'
  347. ];
  348. foreach ($baseData as $val) {
  349. $total['cost'] = !empty($total['cost']) ? ($total['cost'] + $val['cost']) : $val['cost'];
  350. $total['install'] = !empty($total['install']) ? ($total['install'] + $val['install']) : $val['install']; // 激活
  351. $total['reg_dev'] = !empty($total['reg_dev']) ? ($total['reg_dev'] + $val['reg_dev']) : $val['reg_dev']; // 注册设备
  352. $total['reg_total'] = !empty($total['reg_total']) ? ($total['reg_total'] + $val['reg_total']) : $val['reg_total']; // 注册数
  353. $total['role_total'] = !empty($total['role_total']) ? ($total['role_total'] + $val['role_total']) : $val['role_total']; // 创角数
  354. $total['active'] = !empty($total['active']) ? ($total['active'] + $val['active']) : $val['active'];// 次留数
  355. $total['reg_pay_total_da'] = !empty($total['reg_pay_total_da']) ? ($total['reg_pay_total_da'] + $val['reg_pay_total_da']) : $val['reg_pay_total_da']; // 当天付费
  356. $total['reg_pay_num'] = !empty($total['reg_pay_num']) ? ($total['reg_pay_num'] + $val['reg_pay_num']) : $val['reg_pay_num']; // 总付费人数
  357. $total['reg_pay_total'] = !empty($total['reg_pay_total']) ? ($total['reg_pay_total'] + $val['reg_pay_total']) : $val['reg_pay_total']; // 总付费金额
  358. $total['old_login_total'] = !empty($total['old_login_total']) ? ($total['old_login_total'] + $val['old_login_total']) : $val['old_login_total']; // 老用户
  359. $total['reg_pay_amount'] = !empty($total['reg_pay_amount']) ? ($total['reg_pay_amount'] + $val['reg_pay_amount']) : $val['reg_pay_amount']; //注册总充值
  360. }
  361. // 注册成本
  362. $total['reg_cost'] = ToolLogic::getRound($total['cost']??0, $total['reg_total'] ?? 0);
  363. // 汇总创角率
  364. $total['role_per'] = ToolLogic::getRound($total['role_total']??0, $total['reg_total'] ?? 0);
  365. // 次留率
  366. $total['a_per'] = ToolLogic::getPercent($total['active']??0, $total['reg_total']??0, 1);
  367. // 次留成本
  368. $total['a_cost'] = ToolLogic::getRound($total['cost']??0, $total['active']??0, 1);
  369. // 付费率
  370. $total['p_per'] = ToolLogic::getPercent($total['reg_pay_num']??0, $total['reg_total']??0, 1);
  371. // 当天回本率
  372. $total['da_per'] = ToolLogic::getPercent($total['reg_pay_total_da']??0, $total['cost']??0, 1);
  373. // 累计回本率
  374. $total['re_per'] = (float)trim(ToolLogic::getPercent($total['reg_pay_total']??0, $total['cost']??0), "%");
  375. // 实际回本率
  376. $total['re_amount_per'] = ToolLogic::getPercent($total['reg_pay_amount']??0, $total['cost']??0, 1);
  377. //ARPU
  378. $total['arpu'] = ToolLogic::getRound($total['reg_pay_total']??0, $total['reg_pay_num']??0);
  379. //注册ARPU
  380. $total['r_arpu'] = ToolLogic::getRound($total['reg_pay_total']??0, $total['reg_total']??0);
  381. // 7天回本率
  382. $total['re_amount_per_7'] = ToolLogic::getPercent($hb7dayDataSum??0, $total['cost']??0, 1);
  383. //付费成本
  384. $total['p_cost'] = ToolLogic::getRound($total['reg_pay_num']??0, $total['cost']??0, 1);
  385. $totalData = $this->agentTotal($where);
  386. // 汇总数据
  387. return [
  388. 'data' => array_merge($baseData),
  389. 'totalRow' => $total,
  390. ];
  391. }
  392. public function generateYearUnionList($namePrefix, $regDate, $whereSql = '', $field = '*', $group = null)
  393. {
  394. $tableNames = ToolLogic::getYearlyTableNames($namePrefix, $regDate[0], $regDate[1]);
  395. $sqlParts = [];
  396. foreach ($tableNames as $tableName) {
  397. $sqlParts[] = "SELECT * FROM {$tableName} WHERE 1=1 {$whereSql}";
  398. }
  399. $unionSql = implode(" UNION ALL ", $sqlParts);
  400. $finalSql = "
  401. SELECT {$field} FROM ( {$unionSql} ) AS all_total_day
  402. ";
  403. if (!empty($group)) {
  404. $finalSql .= " GROUP BY {$group}";
  405. }
  406. $baseData = Db::connect('db_data_report')->query($finalSql);
  407. return $baseData;
  408. }
  409. /**
  410. * @param $where
  411. * @param $group
  412. * @description 计算7天回本率
  413. * 1. 7天的注册总充值计算出来,可以通过
  414. */
  415. public function computedHb7days($where, $type)
  416. {
  417. $payDataAll = [];
  418. $dateRange = ToolLogic::getDatesBetween($where['reg_date'][0], $where['reg_date'][1]);
  419. foreach ($dateRange as $regDate) {
  420. $field = "
  421. sum(addup_pay_amount) as reg_pay_amount_7,
  422. $type"; // 注册总充值
  423. $eDate = date("Y-m-d", strtotime($regDate . " +6 days"));
  424. // 如果7天后的时间,超过今天,则今天是最后一天
  425. if ($eDate > date("Y-m-d")) {
  426. $eDate = date("Y-m-d");
  427. }
  428. $wherePay = $where;
  429. unset($wherePay['reg_date']);
  430. $whereSql = $this->generateWhereSql($wherePay);
  431. $whereSql = "{$whereSql} AND reg_date = '{$regDate}' AND pay_date = '{$eDate}'";
  432. $payData = $this->generateYearUnionList('game_reg_pay_day_',
  433. [
  434. $regDate,
  435. $regDate
  436. ]
  437. , $whereSql, $field, $type);
  438. $payDataAll = array_merge($payDataAll, $payData);
  439. }
  440. return $payDataAll;
  441. }
  442. /**
  443. * 大盘数据(没有权限)
  444. * 注册成本:消耗金额/注册数
  445. * roi:注册付费金额 reg_pay_total /消耗 cost
  446. * 付费成本:总付费人数/消耗
  447. * 付费率:总付费人数/注册数
  448. */
  449. public function agentTotal($where)
  450. {
  451. $whereSql = $this->generateWhereSql($where);
  452. // 1. 消耗表. 获取消耗金额
  453. $costData = Db::connect('db_advert')->query("SELECT SUM(money) as cost FROM media_cost WHERE 1=1 $whereSql");
  454. $cost = $costData[0]['cost'] ?? 0;
  455. // 2. base_total_day_ 获取注册数(reg_total)、注册付费金额(reg_pay_total)、
  456. $baseTotalField = " SUM(reg_total) AS reg_total, SUM(reg_pay_total) AS reg_pay_total";
  457. $baseTotalDayData = $this->generateYearUnionList('base_total_day_', $where['reg_date'], $whereSql, $baseTotalField);
  458. $regTotal = $baseTotalDayData[0]['reg_total'] ?? 0;
  459. $regPayTotal = $baseTotalDayData[0]['reg_pay_total'] ?? 0;
  460. // 3. 注册付费表. 获取总付费人数(reg_pay_num)
  461. $regPayField = "sum(addup_pay_num) as reg_pay_num";
  462. $regPayWhereSql = str_replace('AND tdate', 'AND reg_date', $whereSql);
  463. $regPayData = $this->generateYearUnionList('game_reg_pay_day_', $where['reg_date'], $regPayWhereSql, $regPayField);
  464. $regPayNum = $regPayData[0]['reg_pay_num'] ?? 0;
  465. // roi
  466. $roi = ToolLogic::getPercent($regPayTotal, $cost, 1);
  467. // 付费成本
  468. $pCost = ToolLogic::getRound($cost, $regPayNum);
  469. // reg_cost 注册成本
  470. $regCost = ToolLogic::getRound($cost, $regTotal);
  471. // 付费率
  472. $pPer = ToolLogic::getPercent($regPayNum, $regTotal, 1);
  473. // 返回数据
  474. return [
  475. 'reg_cost' => $regCost,
  476. 'roi' => $roi,
  477. 'p_cost' => $pCost,
  478. 'p_per' => $pPer,
  479. ];
  480. }
  481. /**
  482. * 广告位总览 ,根据site_id分组
  483. * 支出-> media_cost表的消耗数据
  484. */
  485. public function getAdSiteDataList($where): array
  486. {
  487. $params = $this->searchByAuth($where);
  488. // 忽略 0 投入
  489. $igz = !empty($params['filter']) && is_array($params['filter']) && in_array('igz', $params['filter']);
  490. // 根据渠道名称获取渠道ID
  491. if (!empty($params['site_name'])) {
  492. $agentData = Db::connect('db_advert')->query("SELECT id,name FROM agent_list WHERE 1=1 AND name = '{$params['agent_name']}'");
  493. $params['agent_id'] = $agentData[0]['id'] ?? 0;
  494. }
  495. // 根据广告名称获取广告ID
  496. if (!empty($params['site_name'])) {
  497. $mediaData = Db::connect('db_advert')->query("SELECT id,name FROM agent_site WHERE 1=1 AND name = '{$params['site_name']}'");
  498. $params['media_id'] = $mediaData[0]['id'] ?? 0;
  499. }
  500. if (empty($params['agent_id'])) {
  501. $params['agent_id'] = 0;
  502. }
  503. $groupBy = 'site_id,media_id';
  504. $whereSql = $this->generateWhereSql($params);
  505. // 支出数据
  506. $costWhereSql = $whereSql;
  507. $costData = Db::connect('db_advert')->query("SELECT SUM(money), site_id as cost FROM media_cost WHERE 1=1 $costWhereSql GROUP BY $groupBy");
  508. $costData = array_column($costData, 'cost', 'site_id');
  509. // base统计数据(展示IP(ad_show_ip)、激活(install)、注册设备(reg_dev)、注册数(reg_total)、创角数(role_total)、老用户(old_login_total)、注册付费人数(reg_pay_num)、当天注册付费金额(reg_pay_total_da)、付费总金额(pay_total)、付费总人数(pay_num))
  510. $baseTotalField = "
  511. SUM(ad_show_ip) AS ad_show_ip,
  512. SUM(install) AS install,
  513. SUM(reg_dev) AS reg_dev,
  514. SUM(reg_total) AS reg_total,
  515. SUM(role_create_user) AS role_total,
  516. SUM(old_login_total) AS old_login_total,
  517. SUM(reg_pay_total) AS reg_pay_total_da,
  518. site_id,
  519. media_id,
  520. agent_id,
  521. auth_id";
  522. $baseWhereSql = $whereSql;
  523. $baseTotalDayData = $this->generateYearUnionList('base_total_day_', $params['reg_date'], $baseWhereSql, $baseTotalField, $groupBy);
  524. // active 活跃数,次留人数
  525. $activeWhereSql = $whereSql . ' AND days = 1';
  526. $activeWhereSql = str_replace('AND tdate', 'AND reg_date', $activeWhereSql);
  527. $activeField = " sum(active_total) as active, site_id";
  528. $activeData = $this->generateYearUnionList('game_active_day_', $params['reg_date'], $activeWhereSql, $activeField, $groupBy);
  529. $activeData = array_column($activeData, 'active', 'site_id');
  530. // 注册充值统计(累计充值reg_pay_total, 注册总充值(扣除分成)reg_pay_amount、注册累计付费人数(reg_pay_num))
  531. $regPayWhereSql = $whereSql;
  532. $regPayField = "
  533. sum(addup_pay_num) as reg_pay_num,
  534. sum(addup_pay_total) as reg_pay_total,
  535. sum(addup_pay_amount) as reg_pay_amount,
  536. site_id";
  537. $regPayWhereSql = str_replace('AND tdate', 'AND reg_date', $regPayWhereSql);
  538. $regPayData = $this->generateYearUnionList('game_reg_pay_day_', $params['reg_date'], $regPayWhereSql, $regPayField, $groupBy);
  539. $regPayData = array_column($regPayData, null, 'site_id');
  540. // 拼装数据
  541. foreach ($baseTotalDayData as $key => &$row) {
  542. $row['active'] = $activeData[$row['site_id']] ?? 0; // 次留数
  543. $row['cost'] = $costData[$row['site_id']] ?? 0; // 支出
  544. // 忽略0投入的
  545. if ($igz && $row['cost'] === 0) {
  546. unset($baseTotalDayData[$key]);
  547. }
  548. $row['reg_cost'] = ToolLogic::getRound($row['cost'], $row['reg_total'] ?? 0); // 注册成本
  549. $row['role_per'] = ToolLogic::getRound($row['role_total'], $row['reg_total'] ?? 0); // 创角率
  550. $row['a_cost'] = ToolLogic::getRound($row['cost'], $row['active'], 1); // 次留成本
  551. $row['a_per'] = ToolLogic::getPercent($row['active'], $row['reg_total'], 1); // 次留率
  552. $row['reg_pay_total'] = $regPayData[$row['site_id']]['reg_pay_total'] ?? 0; // 总付费金额
  553. $row['reg_pay_num'] = $regPayData[$row['site_id']]['reg_pay_num'] ?? 0; // 总付费人数
  554. $row['reg_pay_amount'] = $regPayData[$row['site_id']]['reg_pay_amount'] ?? 0; // 注册总充值
  555. $row['p_cost'] = ToolLogic::getRound($row['cost'], $row['reg_pay_num']); // 付费成本
  556. $row['p_per'] = ToolLogic::getPercent($row['reg_pay_num'] ?? 0, $row['reg_total'], 1); // 付费率
  557. $row['da_per'] = ToolLogic::getPercent($row['reg_pay_total_da'] ?? 0, $row['cost'], 1); // 当天回本率
  558. $row['re_per'] = (float)trim(ToolLogic::getPercent($row['reg_pay_total'], $row['cost']), "%"); // 累计回本率
  559. $row['re_amount_per'] = ToolLogic::getPercent($row['reg_pay_amount'], $row['cost'], 1); // 实际回本率
  560. $row['arpu'] = ToolLogic::getRound($row['reg_pay_total'], $row['reg_pay_num']); // ARPU
  561. $row['r_arpu'] = ToolLogic::getRound($row['reg_pay_total'], $row['reg_total']); // 注册ARPU
  562. }
  563. // 合计
  564. $total = [
  565. 'site_id' => '合计',
  566. 'media_id' => '-',
  567. 'agent_id' => '-',
  568. 'auth_id' => '-',
  569. 'agent_name' => '-',
  570. 'site_name' => '-',
  571. 'auth_name' => '-',
  572. ];
  573. foreach ($baseTotalDayData as $val) {
  574. $total['cost'] = !empty($total['cost']) ? round($total['cost'] + $val['cost'], 2) : $val['cost']; // 支出
  575. $total['install'] = !empty($total['install']) ? ($total['install'] + $val['install']) : $val['install']; // 激活
  576. $total['reg_dev'] = !empty($total['reg_dev']) ? ($total['reg_dev'] + $val['reg_dev']) : $val['reg_dev']; // 注册设备
  577. $total['reg_total'] = !empty($total['reg_total']) ? ($total['reg_total'] + $val['reg_total']) : $val['reg_total']; // 注册数
  578. $total['role_total'] = !empty($total['role_total']) ? ($total['role_total'] + $val['role_total']) : $val['role_total']; // 创角数
  579. $total['old_login_total'] = !empty($total['old_login_total']) ? ($total['old_login_total'] + $val['old_login_total']) : $val['old_login_total']; // 老用户
  580. $total['reg_pay_total'] = !empty($total['reg_pay_total']) ? ($total['reg_pay_total'] + $val['reg_pay_total']) : $val['reg_pay_total']; // 总付费金额
  581. $total['reg_pay_num'] = !empty($total['reg_pay_num']) ? ($total['reg_pay_num'] + $val['reg_pay_num']) : $val['reg_pay_num']; // 总付费人数
  582. $total['active'] = !empty($total['active']) ? ($total['active'] + $val['active']) : $val['active']; // 次留数
  583. $total['reg_pay_amount'] = !empty($total['reg_pay_amount']) ? ($total['reg_pay_amount'] + $val['reg_pay_amount']) : $val['reg_pay_amount']; // 注册总充值
  584. $total['reg_pay_total_da'] = !empty($total['reg_pay_total_da']) ? ($total['reg_pay_total_da'] + $val['reg_pay_total_da']) : $val['reg_pay_total_da']; // 当天注册付费金额
  585. }
  586. $total['reg_cost'] = ToolLogic::getRound($total['cost'] ?? 0, $total['reg_total'] ?? 0); // 注册成本
  587. $total['role_per'] = ToolLogic::getRound($total['role_total'] ?? 0, $total['reg_total'] ?? 0); // 创角率
  588. $total['a_per'] = ToolLogic::getPercent($total['active'] ?? 0, $total['reg_total'] ?? 0, 1); // 次留率
  589. $total['a_cost'] = ToolLogic::getRound($total['cost'] ?? 0, $total['active'] ?? 0, 1); // 次留成本
  590. $total['p_cost'] = ToolLogic::getRound($total['reg_pay_num'] ?? 0, $total['cost'] ?? 0, 1); // 付费成本
  591. $total['p_per'] = ToolLogic::getPercent($total['reg_pay_num'] ?? 0, $total['reg_total'] ?? 0, 1); // 付费率
  592. $total['da_per'] = ToolLogic::getPercent($total['reg_pay_total_da'] ?? 0, $total['cost'] ?? 0, 1); // 当天回本率
  593. $total['re_per'] = (float)trim(ToolLogic::getPercent($total['reg_pay_total'] ?? 0, $total['cost'] ?? 0), "%"); // 累计回本率
  594. $total['re_amount_per'] = ToolLogic::getPercent($total['reg_pay_amount'] ?? 0, $total['cost'] ?? 0, 1); // 实际回本率
  595. $total['arpu'] = ToolLogic::getRound($total['reg_pay_total'] ?? 0, $total['reg_pay_num'] ?? 0); // ARPU
  596. $total['r_arpu'] = ToolLogic::getRound($total['reg_pay_total'] ?? 0, $total['reg_total'] ?? 0); // 注册ARPU
  597. return ['data' => $baseTotalDayData, 'total' => $total];
  598. }
  599. /**
  600. * 渠道按日分析
  601. */
  602. public function getAgentDayDataList($where)
  603. {
  604. $params = $this->searchByAuth($where);
  605. // 根据渠道名称获取渠道ID
  606. if (!empty($params['site_name'])) {
  607. $agentData = Db::connect('db_advert')->query("SELECT id,name FROM agent_list WHERE 1=1 AND name = '{$params['agent_name']}'");
  608. $params['agent_id'] = $agentData[0]['id'] ?? 0;
  609. }
  610. // 根据广告名称获取广告ID
  611. if (!empty($params['site_name'])) {
  612. $mediaData = Db::connect('db_advert')->query("SELECT id,name FROM agent_site WHERE 1=1 AND name = '{$params['site_name']}'");
  613. $params['media_id'] = $mediaData[0]['id'] ?? 0;
  614. }
  615. if (empty($params['agent_id'])) {
  616. $params['agent_id'] = 0;
  617. }
  618. $whereSql = $this->generateWhereSql($params);
  619. // 1. 消耗表. 获取消耗金额
  620. $costData = Db::connect('db_advert')->query("SELECT SUM(money) as cost FROM media_cost WHERE 1=1 $whereSql Group By tdate");
  621. $costData = array_column($costData, 'cost', 'tdate');
  622. // 2. base统计数据(展示IP(ad_show_ip)、激活(install)、注册设备(reg_dev)、注册数(reg_total)、创角数(role_total)、老用户(old_login_total)、注册付费人数(reg_pay_num)、当天注册付费金额(reg_pay_total_da)、付费总金额(pay_total)、付费总人数(pay_num))
  623. $baseTotalField = "
  624. SUM(ad_show_ip) AS ad_show_ip,
  625. SUM(install) AS install,
  626. SUM(reg_dev) AS reg_dev,
  627. SUM(reg_total) AS reg_total,
  628. SUM(role_create_user) AS role_total,
  629. SUM(old_login_total) AS old_login_total,
  630. SUM(reg_pay_total) AS reg_pay_total_da,
  631. SUM(pay_amount) AS pay_amount,
  632. SUM(pay_total) AS pay_total,
  633. tdate";
  634. $baseWhereSql = $whereSql;
  635. $baseTotalDayData = $this->generateYearUnionList('base_total_day_', $params['reg_date'], $baseWhereSql, $baseTotalField, 'tdate');
  636. $baseTotalDayData = array_column($baseTotalDayData, null, 'tdate');
  637. // 3. active 活跃数,次留人数
  638. $activeWhereSql = $whereSql . ' AND days = 1';
  639. $activeWhereSql = str_replace('AND tdate', 'AND reg_date', $activeWhereSql);
  640. $activeField = "
  641. sum(active_total) as active,
  642. reg_date astdate";
  643. $activeData = $this->generateYearUnionList('game_active_day_', $params['reg_date'], $activeWhereSql, $activeField, 'reg_date');
  644. $activeData = array_column($activeData, 'active', 'tdate');
  645. // 4. 注册充值统计(累计充值reg_pay_total, 注册总充值(扣除分成)reg_pay_amount、注册累计付费人数(reg_pay_num))
  646. $regPayWhereSql = $whereSql;
  647. $regPayField = "
  648. sum(addup_pay_num) as reg_pay_num,
  649. sum(addup_pay_total) as reg_pay_total,
  650. sum(addup_pay_amount) as reg_pay_amount,
  651. reg_date as tdate";
  652. $regPayWhereSql = str_replace('AND tdate', 'AND reg_date', $regPayWhereSql);
  653. $regPayData = $this->generateYearUnionList('game_reg_pay_day_', $params['reg_date'], $regPayWhereSql, $regPayField, 'reg_date');
  654. $regPayData = array_column($regPayData, null, 'tdate');
  655. // 5. 拼装数据
  656. // 拼装数据
  657. foreach ($baseTotalDayData as $key => &$row)
  658. {
  659. $row['active'] = $activeData[$row['tdate']] ?? 0; // 次留数
  660. $row['cost'] = $costData[$row['tdate']] ?? 0; // 支出
  661. $row['reg_cost'] = ToolLogic::getRound($row['cost'], $row['reg_total'] ?? 0); // 注册成本
  662. $row['role_per'] = ToolLogic::getRound($row['role_total'], $row['reg_total'] ?? 0); // 创角率
  663. $row['a_cost'] = ToolLogic::getRound($row['cost'], $row['active'], 1); // 次留成本
  664. $row['a_per'] = ToolLogic::getPercent($row['active'], $row['reg_total'], 1); // 次留率
  665. $row['reg_pay_total'] = $regPayData[$row['tdate']]['reg_pay_total'] ?? 0; // 总付费金额
  666. $row['reg_pay_num'] = $regPayData[$row['tdate']]['reg_pay_num'] ?? 0; // 总付费人数
  667. $row['reg_pay_amount'] = $regPayData[$row['tdate']]['reg_pay_amount'] ?? 0; // 注册总充值
  668. $row['p_cost'] = ToolLogic::getRound($row['cost'], $row['reg_pay_num']); // 付费成本
  669. $row['p_per'] = ToolLogic::getPercent($row['reg_pay_num'] ?? 0, $row['reg_total'], 1); // 付费率
  670. $row['da_per'] = ToolLogic::getPercent($row['reg_pay_total_da'] ?? 0, $row['cost'], 1); // 当天回本率
  671. $row['re_per'] = (float)trim(ToolLogic::getPercent($row['reg_pay_total'], $row['cost']), "%"); // 累计回本率
  672. $row['re_amount_per'] = ToolLogic::getPercent($row['reg_pay_amount'], $row['cost'], 1); // 实际回本率
  673. $row['arpu'] = ToolLogic::getRound($row['reg_pay_total'], $row['reg_pay_num']); // ARPU
  674. $row['r_arpu'] = ToolLogic::getRound($row['reg_pay_total'], $row['reg_total']); // 注册ARPU
  675. $row['pay_cost'] = ToolLogic::getPercent($row['pay_amount'] ?? 0, $row['cost'] ?? 0); // 收支比
  676. }
  677. // 6. 合计
  678. $total = [
  679. 'tdate' => '合计'
  680. ];
  681. foreach ($baseTotalDayData as $vv) {
  682. $total['cost'] = !empty($total['cost']) ? ($total['cost'] + $vv['cost']) : $vv['cost']; // 支出
  683. $total['ad_show_ip'] = !empty($total['ad_show_ip']) ? ($total['ad_show_ip'] + $vv['ad_show_ip']) : $vv['ad_show_ip']; // 展示IP
  684. $total['install'] = !empty($total['install']) ? ($total['install'] + $vv['install']) : $vv['install']; // 激活
  685. $total['reg_dev'] = !empty($total['reg_dev']) ? ($total['reg_dev'] + $vv['reg_dev']) : $vv['reg_dev']; // 注册设备
  686. $total['reg_total'] = !empty($total['reg_total']) ? ($total['reg_total'] + $vv['reg_total']) : $vv['reg_total']; // 注册数
  687. $total['role_total'] = !empty($total['role_total']) ? ($total['role_total'] + $vv['role_total']) : $vv['role_total']; // 创角数
  688. $total['active'] = !empty($total['active']) ? ($total['active'] + $vv['active']) : $vv['active']; // 次留数
  689. // 付费人数
  690. $total['reg_pay_num'] = !empty($total['reg_pay_num']) ? ($total['reg_pay_num'] + $vv['reg_pay_num']) : $vv['reg_pay_num']; // 总付费人数
  691. $total['reg_pay_total'] = !empty($total['reg_pay_total']) ? ($total['reg_pay_total'] + $vv['reg_pay_total']) : $vv['reg_pay_total']; // 总付费金额
  692. $total['reg_pay_amount'] = !empty($total['reg_pay_amount']) ? ($total['reg_pay_amount'] + $vv['reg_pay_amount']) : $vv['reg_pay_amount']; // 注册总充值
  693. $total['pay_total'] = !empty($total['pay_total']) ? ($total['pay_total'] + $vv['pay_total']) : $vv['pay_total']; // 当天收入
  694. $total['pay_amount'] = !empty($total['pay_amount']) ? ($total['pay_amount'] + $vv['pay_amount']) : $vv['pay_amount']; // 实际收入
  695. $total['old_login_total'] = !empty($total['old_login_total']) ? ($total['old_login_total'] + $vv['old_login_total']) : $vv['old_login_total']; // 老用户
  696. $total['reg_pay_total_da'] = !empty($total['reg_pay_total_da']) ? ($total['reg_pay_total_da'] + $vv['reg_pay_total_da']) : $vv['reg_pay_total_da']; // 当天注册付费金额
  697. }
  698. $total['reg_cost'] = ToolLogic::getRound($total['cost'] ?? 0, $total['reg_total'] ?? 0); // 注册成本
  699. $total['role_per'] = ToolLogic::getRound($total['role_total'] ?? 0, $total['reg_total'] ?? 0); // 创角率
  700. $total['a_per'] = ToolLogic::getPercent($total['active'] ?? 0, $total['reg_total'] ?? 0, 1); // 次留率
  701. $total['a_cost'] = ToolLogic::getRound($total['cost'] ?? 0, $total['active'] ?? 0, 1); // 次留成本
  702. $total['p_cost'] = ToolLogic::getRound($total['reg_pay_num'] ?? 0, $total['cost'] ?? 0, 1); // 付费成本
  703. $total['p_per'] = ToolLogic::getPercent($total['reg_pay_num'] ?? 0, $total['reg_total'] ?? 0, 1); // 付费率
  704. $total['da_per'] = ToolLogic::getPercent($total['reg_pay_total_da'] ?? 0, $total['cost'] ?? 0, 1); // 当天回本率
  705. $total['re_per'] = (float)trim(ToolLogic::getPercent($total['reg_pay_total'] ?? 0, $total['cost'] ?? 0), "%"); // 累计回本率
  706. $total['re_amount_per'] = ToolLogic::getPercent($total['reg_pay_amount'] ?? 0, $total['cost'] ?? 0, 1); // 实际回本率
  707. $total['arpu'] = ToolLogic::getRound($total['reg_pay_total'] ?? 0, $total['reg_pay_num'] ?? 0); // ARPU
  708. $total['r_arpu'] = ToolLogic::getRound($total['reg_pay_total'] ?? 0, $total['reg_total'] ?? 0); // 注册ARPU
  709. $total['pay_cost'] = ToolLogic::getPercent($total['pay_amount'] ?? 0, $total['cost'] ?? 0); //收支比
  710. return ['data' => array_values($baseTotalDayData), 'totalRow' => $total];
  711. }
  712. /**
  713. * ltv
  714. */
  715. public function getLtvDataList($where)
  716. {
  717. $params = $this->searchByAuth($where);
  718. // 展示类型
  719. $dataType = $params['data_type'] ?? 'recovery';
  720. $nowDate = date("Y-m-d");
  721. $whereSql = $this->generateWhereSql($params);
  722. // 1. 获取消耗金额
  723. $costData = Db::connect('db_advert')->query("SELECT SUM(money) as cost, tdate FROM media_cost WHERE 1=1 $whereSql group by tdate");
  724. $costData = array_column($costData, 'cost', 'tdate');
  725. // 2. 获取注册数
  726. $baseData = $this->generateYearUnionList('base_total_day_', $params['reg_date'], $whereSql, "SUM(reg_total) as reg_total, tdate", 'tdate');
  727. $baseData = array_column($baseData, null, 'tdate');
  728. // 3. 获取注册付费金额
  729. $field = "
  730. reg_date,
  731. pay_date,
  732. SUM(pay_num) as pay_num,
  733. SUM(pay_total) as pay_total,
  734. SUM(addup_pay_num) AS addup_pay_num,
  735. SUM(addup_pay_total) AS addup_pay_total,
  736. SUM(addup_pay_amount) AS addup_pay_amount
  737. ";
  738. $regPayWhereSql = str_replace('AND tdate', 'AND reg_date', $whereSql);
  739. $regPayData = $this->generateYearUnionList('game_reg_pay_day_', $params['reg_date'], $regPayWhereSql, $field, 'reg_date,pay_date');
  740. // 如果注册付费数据为空,则返回空数据给前端
  741. if (empty($regPayData)) {
  742. return ['data' => [], 'totalRow' => []];
  743. }
  744. // 前端合计数据
  745. $totalRow = [
  746. 'tdate' => '合计'
  747. ];
  748. // 前端data数据
  749. $totalLtv = $data = [];
  750. // 合计 消耗金额,注册数,注册成本
  751. foreach ($baseData as $key => $val) {
  752. $totalRow['cost'] = !empty($totalRow['cost']) ? ($totalRow['cost'] + $costData[$key] ?? 0) : $costData[$key] ?? 0;
  753. $totalRow['d0']['cost'] = !empty($totalRow['cost']) ? ($totalRow['cost'] + $costData[$key] ?? 0) : $costData[$key] ?? 0;
  754. $totalRow['reg_total'] = !empty($totalRow['reg_total']) ? ($totalRow['reg_total'] + $val['reg_total'] ?? 0) : $val['reg_total'] ?? 0;
  755. $totalRow['d0']['reg_total'] = !empty($totalRow['reg_total']) ? ($totalRow['reg_total'] + $val['reg_total'] ?? 0) : $val['reg_total'] ?? 0;
  756. $totalRow['reg_cost'] = ToolLogic::getRound($totalRow['cost'] ?? 0, $totalRow['reg_total'] ?? 0);
  757. $days = (strtotime($nowDate) - strtotime($key)) / 86400 + 1;
  758. for ($i = 1; $i <= $days; $i++) {
  759. $daykey = 'd' . $i;
  760. $totalRow[$daykey]['reg_total'] = !empty($totalRow[$daykey]['reg_total']) ? ($totalRow[$daykey]['reg_total'] + $val['reg_total'] ?? 0) : $val['reg_total'] ?? 0;
  761. $totalRow[$daykey]['cost'] = !empty($totalRow[$daykey]['cost']) ? ($totalRow[$daykey]['cost'] + $costData[$key] ?? 0) : $costData[$key] ?? 0;
  762. }
  763. }
  764. // 按照天计算LTV
  765. foreach ($regPayData as $row) {
  766. $regDate = $row['reg_date'];
  767. $data[$regDate]['tdate'] = $regDate;
  768. // 注册数
  769. $data[$regDate]['reg_total'] = $baseData[$regDate]['reg_total'] ?? 0;
  770. // 注册成本
  771. $data[$regDate]['reg_cost'] = ToolLogic::getRound($costData[$regDate] ?? 0, $data[$regDate]['reg_total'] ?? 0);
  772. // 消耗金额
  773. $data[$regDate]['cost'] = $costData[$regDate] ?? 0;
  774. // 计算日期相差天数
  775. $daykey = (strtotime($row['pay_date']) - strtotime($regDate)) / 86400 + 1;
  776. $daykey = 'd' . $daykey;
  777. switch ($dataType) {
  778. case 'recovery':
  779. $data[$regDate][$daykey] = ToolLogic::getPercent($row['addup_pay_total'], $costData[$regDate] ?? 0, 1);
  780. if ($nowDate === $row['pay_date']) {
  781. $data[$regDate]['d0'] = ToolLogic::getPercent($row['addup_pay_total'], $costData[$regDate] ?? 0, 1);
  782. }
  783. break;
  784. /* 扣除分成/cost , 计算 */
  785. case 'remount':
  786. // 按天回本率
  787. $data[$regDate][$daykey] = ToolLogic::getPercent($row['addup_pay_amount'], $costData[$regDate] ?? 0, 1);
  788. // 累计回本率
  789. if ($nowDate === $row['pay_date']) {
  790. $data[$regDate]['d0'] = ToolLogic::getPercent($row['addup_pay_amount'], $costData[$regDate] ?? 0, 1);
  791. }
  792. break;
  793. /* 累计计费付费金额 / 注册数 */
  794. case 'ltv':
  795. // 按天LTV
  796. $data[$regDate][$daykey] = ToolLogic::getRound($row['addup_pay_total'], $baseData[$regDate]['reg_total'] ?? 0, 1);
  797. // 累计LTV
  798. if ($nowDate === $row['pay_date']) {
  799. $data[$regDate]['d0'] = ToolLogic::getRound($row['addup_pay_total'], $baseData[$regDate]['reg_total'] ?? 0, 1);
  800. }
  801. break;
  802. /* 后面的LTV数据, 按天LTV / 第一天LTV , 目的是为了计算LTV增长率*/
  803. case 'ltvbs':
  804. $totalLtv[$daykey] = ToolLogic::getRound($row['addup_pay_total'], $baseData[$regDate]['reg_total'] ?? 0, 1);
  805. $fz = $totalLtv['d1'] ?? 0 != 0 ? $totalLtv['d1'] : 1;
  806. $data[$regDate][$daykey] = round($totalLtv[$daykey] / $fz, 2);
  807. break;
  808. /* 付费人数*/
  809. case 'pay_num':
  810. $data[$regDate][$daykey] = $row['pay_num'];
  811. if ($nowDate === $row['pay_date']) {
  812. $data[$regDate]['d0'] = $row['addup_pay_num'];
  813. }
  814. break;
  815. /* 付费总额 */
  816. case 'pay_total':
  817. $data[$regDate][$daykey] = $row['pay_total'];
  818. if ($nowDate === $row['pay_date']) {
  819. $data[$regDate]['d0'] = $row['addup_pay_total'];
  820. }
  821. break;
  822. /* 付费率 */
  823. case 'pay_rate':
  824. $data[$regDate][$daykey] = ToolLogic::getPercent($row['pay_num'], $baseData[$regDate]['reg_total']);
  825. if ($nowDate === $row['pay_date']) {
  826. $data[$regDate]['d0'] = ToolLogic::getPercent($row['addup_pay_num'], $baseData[$regDate]['reg_total']);
  827. }
  828. break;
  829. /* 付费ARPU */
  830. case 'arpu':
  831. $data[$regDate][$daykey] = ToolLogic::getRound($row['pay_total'], $row['pay_num']);
  832. if ($nowDate === $row['pay_date']) {
  833. $data[$regDate]['d0'] = ToolLogic::getRound($row['addup_pay_total'], $row['addup_pay_num']);
  834. }
  835. break;
  836. default:
  837. break;
  838. }
  839. $totalRow[$daykey]['addup_pay_total'] = $totalRow[$daykey]['addup_pay_total'] ?? 0;
  840. $totalRow[$daykey]['addup_pay_amount'] = $totalRow[$daykey]['addup_pay_amount'] ?? 0;
  841. $totalRow[$daykey]['pay_num'] = $totalRow[$daykey]['pay_num'] ?? 0;
  842. $totalRow[$daykey]['pay_total'] = $totalRow[$daykey]['pay_total'] ?? 0;
  843. $totalRow[$daykey]['addup_pay_total'] = !empty($totalRow[$daykey]['addup_pay_total']) ? $totalRow[$daykey]['addup_pay_total'] + $row['addup_pay_total'] : $row['addup_pay_total'];
  844. $totalRow[$daykey]['addup_pay_amount'] = !empty($totalRow[$daykey]['addup_pay_amount']) ? $totalRow[$daykey]['addup_pay_amount'] + $row['addup_pay_amount'] : $row['addup_pay_amount'];
  845. $totalRow[$daykey]['pay_num'] = !empty($totalRow[$daykey]['pay_num']) ? $totalRow[$daykey]['pay_num'] + $row['pay_num'] : $row['pay_num'];
  846. $totalRow[$daykey]['pay_total'] = !empty($totalRow[$daykey]['pay_total']) ? $totalRow[$daykey]['pay_total'] + $row['pay_total'] : $row['pay_total'];
  847. if ($row['pay_date'] == $regDate) {
  848. $pay_total = !empty($pay_total) ? $pay_total + $row['addup_pay_total'] : $row['addup_pay_total'];
  849. $pay_amount = !empty($pay_amount) ? $pay_amount + $row['addup_pay_amount'] : $row['addup_pay_amount'];
  850. $pay_num = !empty($pay_num) ? $pay_num + $row['pay_num'] : $row['pay_num'];
  851. }
  852. }
  853. foreach ($totalRow as $key => $vv) {
  854. if ($key[0] === 'd') {
  855. switch ($dataType) {
  856. case 'recovery':
  857. $totalRow[$key] = ToolLogic::getPercent($totalRow[$key]['addup_pay_total'] ?? 0, $totalRow[$key]['cost'] ?? 0, 1);
  858. break;
  859. case 'remount':
  860. $totalRow[$key] = ToolLogic::getPercent($totalRow[$key]['addup_pay_amount'] ?? 0, $totalRow[$key]['cost'] ?? 0, 1);
  861. break;
  862. case 'ltv':
  863. $totalRow[$key] = ToolLogic::getRound($totalRow[$key]['addup_pay_total'] ?? 0, $totalRow[$key]['reg_total'] ?? 0);
  864. break;
  865. case 'ltvbs':
  866. $totalLtv[$key] = ToolLogic::getRound($totalRow[$key]['addup_pay_total'] ?? 0, $totalRow[$key]['reg_total'] ?? 0);
  867. $fz = $totalLtv['d1'] ?? 0 != 0 ? $totalLtv['d1'] : 1;
  868. $totalRow[$key] = round($totalLtv[$key] / $fz, 2);
  869. break;
  870. case 'pay_num':
  871. $totalRow[$key] = $totalRow[$key]['pay_num'] ?? 0;
  872. break;
  873. case 'pay_total':
  874. $totalRow[$key] = $totalRow[$key]['pay_total'] ?? 0;
  875. break;
  876. case 'pay_rate':
  877. $totalRow[$key] = ToolLogic::getPercent($totalRow[$key]['pay_num'] ?? 0, $totalRow[$key]['reg_total'] ?? 0);
  878. break;
  879. case 'arpu':
  880. $totalRow[$key] = ToolLogic::getRound($totalRow[$key]['pay_total'] ?? 0, $totalRow[$key]['pay_num'] ?? 0);
  881. break;
  882. }
  883. }
  884. }
  885. if ($data && $totalRow) {
  886. switch ($dataType) {
  887. case 'recovery':
  888. $totalRow['d0'] = ToolLogic::getPercent($pay_total, $totalRow['cost'], 1);
  889. break;
  890. case 'remount':
  891. $totalRow['d0'] = ToolLogic::getPercent($pay_amount, $totalRow['cost'], 1);
  892. break;
  893. case 'ltv':
  894. $totalRow['d0'] = ToolLogic::getRound($pay_total, $totalRow['reg_total']);
  895. break;
  896. case 'ltvbs':
  897. $totalLtv['d0'] = ToolLogic::getRound($pay_total, $totalRow['reg_total']);
  898. $fz = $totalLtv['d1'] ?? 0 != 0 ? $totalLtv['d1'] : 1;
  899. $totalRow['d0'] = round($totalLtv['d0'] / $fz, 2);
  900. break;
  901. case 'pay_num':
  902. $totalRow['d0'] = $pay_num;
  903. break;
  904. case 'pay_total':
  905. $totalRow['d0'] = $pay_total;
  906. break;
  907. case 'pay_rate':
  908. $totalRow['d0'] = ToolLogic::getPercent($pay_num, $totalRow['reg_total']);
  909. break;
  910. case 'arpu':
  911. $totalRow['d0'] = ToolLogic::getRound($pay_total, $pay_num);
  912. break;
  913. default:
  914. break;
  915. }
  916. $totalRow['reg_cost'] = ToolLogic::getRound($totalRow['cost'], $totalRow['reg_total']);
  917. $list = ToolLogic::arrSort($data, 'tdate', 'asc');
  918. }
  919. return [
  920. 'data' => array_values($list),
  921. 'totalRow' => $totalRow
  922. ];
  923. }
  924. /**
  925. * ltv按月
  926. */
  927. public function getLtvmDataList($where): array
  928. {
  929. $params = $this->searchByAuth($where);
  930. // 展示类型
  931. $dataType = $params['data_type'] ?? 'recovery';
  932. $nowDate = date("Y-m");
  933. $whereSql = $this->generateWhereSql($params);
  934. // 2. 获取注册数
  935. $totalBaseWhereSql = str_replace('AND tdate', 'AND tmonth', $whereSql);
  936. $baseData = Db::connect('db_data_report')->query("SELECT tmonth,SUM(cost) as cost,SUM(reg_total) as reg_total FROM game_total_month WHERE 1=1 $totalBaseWhereSql GROUP BY tmonth");
  937. $baseData = array_column($baseData, null, 'tmonth');
  938. // 3. 获取注册付费金额
  939. $field = "
  940. reg_month,
  941. pay_month,
  942. SUM(pay_num) as pay_num,
  943. SUM(pay_total) as pay_total,
  944. SUM(addup_pay_num) AS addup_pay_num,
  945. SUM(addup_pay_total) AS addup_pay_total,
  946. SUM(addup_pay_amount) AS addup_pay_amount
  947. ";
  948. $regPayWhereSql = str_replace('AND tdate', 'AND reg_month', $whereSql);
  949. $regPayData = Db::connect('db_data_report')->query("SELECT $field FROM game_reg_pay_month WHERE 1=1 $regPayWhereSql GROUP BY reg_month,pay_month");
  950. // 如果注册付费数据为空,则返回空数据给前端
  951. if (empty($regPayData)) {
  952. return ['data' => [], 'totalRow' => []];
  953. }
  954. // 前端合计数据
  955. $totalRow = [
  956. 'tmonth' => '合计'
  957. ];
  958. // 前端data数据
  959. $data = [];
  960. $pay_total = 0;
  961. $pay_amount = 0;
  962. $pay_num = 0;
  963. // 合计 消耗金额,注册数,注册成本
  964. foreach ($baseData as $key => $val) {
  965. $totalRow['cost'] = !empty($totalRow['cost']) ? round($totalRow['cost'] + $val['cost'] ?? 0, 2) : $val['cost'] ?? 0;
  966. $totalRow['reg_total'] = !empty($totalRow['reg_total']) ? ($totalRow['reg_total'] + $val['reg_total'] ?? 0) : $val['reg_total'] ?? 0;
  967. $totalRow['reg_cost'] = ToolLogic::getRound($totalRow['cost'] ?? 0, $totalRow['reg_total'] ?? 0);
  968. $days = ToolLogic::getMonthNum($key, $nowDate);
  969. for ($i = 1; $i <= $days; $i++) {
  970. $daykey = 'm' . ($i + 1);
  971. $totalRow[$daykey]['reg_total'] = !empty($totalRow[$daykey]['reg_total']) ? ($totalRow[$daykey]['reg_total'] + $val['reg_total'] ?? 0) : $val['reg_total'] ?? 0;
  972. $totalRow[$daykey]['cost'] = !empty($totalRow[$daykey]['cost']) ? ($totalRow[$daykey]['cost'] + $val['cost'] ?? 0) : $val['cost'] ?? 0;
  973. }
  974. }
  975. // 按照天计算LTV
  976. foreach ($regPayData as $row) {
  977. $regDate = $row['reg_month'];
  978. $data[$regDate]['tmonth'] = $regDate;
  979. // 注册数
  980. $data[$regDate]['reg_total'] = $baseData[$regDate]['reg_total'] ?? 0;
  981. // 注册成本
  982. $data[$regDate]['reg_cost'] = ToolLogic::getRound($baseData[$regDate]['cost'] ?? 0, $data[$regDate]['reg_total'] ?? 0);
  983. // 消耗金额
  984. $data[$regDate]['cost'] = $baseData[$regDate]['cost'] ?? 0;
  985. // 计算日期相差天数
  986. $daykey = 'm' . (ToolLogic::getMonthNum($regDate, $row['pay_month']) + 1);
  987. switch ($dataType) {
  988. case 'recovery':
  989. $data[$regDate][$daykey] = ToolLogic::getPercent($row['addup_pay_total'], $baseData[$regDate]['cost'] ?? 0, 1);
  990. if ($nowDate === $row['pay_month']) {
  991. $data[$regDate]['m0'] = ToolLogic::getPercent($row['addup_pay_total'], $baseData[$regDate]['cost'] ?? 0, 1);
  992. }
  993. break;
  994. /* 扣除分成/cost , 计算 */
  995. case 'remount':
  996. // 按天回本率
  997. $data[$regDate][$daykey] = ToolLogic::getPercent($row['addup_pay_amount'], $baseData[$regDate]['cost'] ?? 0, 1);
  998. // 累计回本率
  999. if ($nowDate === $row['pay_month']) {
  1000. $data[$regDate]['m0'] = ToolLogic::getPercent($row['addup_pay_amount'], $baseData[$regDate]['cost'] ?? 0, 1);
  1001. }
  1002. break;
  1003. /* 累计计费付费金额 / 注册数 */
  1004. case 'ltv':
  1005. // 按天LTV
  1006. $data[$regDate][$daykey] = ToolLogic::getRound($row['addup_pay_total'], $baseData[$regDate]['reg_total'] ?? 0, 1);
  1007. // 累计LTV
  1008. if ($nowDate === $row['pay_month']) {
  1009. $data[$regDate]['m0'] = ToolLogic::getRound($row['addup_pay_total'], $baseData[$regDate]['reg_total'] ?? 0, 1);
  1010. }
  1011. break;
  1012. /* 付费人数*/
  1013. case 'pay_num':
  1014. $data[$regDate][$daykey] = $row['pay_num'];
  1015. if ($nowDate === $row['pay_month']) {
  1016. $data[$regDate]['m0'] = $row['addup_pay_num'];
  1017. }
  1018. break;
  1019. /* 付费总额 */
  1020. case 'pay_total':
  1021. $data[$regDate][$daykey] = $row['pay_total'];
  1022. if ($nowDate === $row['pay_month']) {
  1023. $data[$regDate]['m0'] = $row['addup_pay_total'];
  1024. }
  1025. break;
  1026. /* 付费率 */
  1027. case 'pay_rate':
  1028. $data[$regDate][$daykey] = ToolLogic::getPercent($row['pay_num'], $baseData[$regDate]['reg_total']);
  1029. if ($nowDate === $row['pay_month']) {
  1030. $data[$regDate]['m0'] = ToolLogic::getPercent($row['addup_pay_num'], $baseData[$regDate]['reg_total']);
  1031. }
  1032. break;
  1033. /* 付费ARPU */
  1034. case 'arpu':
  1035. $data[$regDate][$daykey] = ToolLogic::getRound($row['pay_total'], $row['pay_num']);
  1036. if ($nowDate === $row['pay_month']) {
  1037. $data[$regDate]['m0'] = ToolLogic::getRound($row['addup_pay_total'], $row['addup_pay_num']);
  1038. }
  1039. break;
  1040. default:
  1041. break;
  1042. }
  1043. $totalRow[$daykey]['addup_pay_total'] = $totalRow[$daykey]['addup_pay_total'] ?? 0;
  1044. $totalRow[$daykey]['addup_pay_amount'] = $totalRow[$daykey]['addup_pay_amount'] ?? 0;
  1045. $totalRow[$daykey]['pay_num'] = $totalRow[$daykey]['pay_num'] ?? 0;
  1046. $totalRow[$daykey]['pay_total'] = $totalRow[$daykey]['pay_total'] ?? 0;
  1047. $totalRow[$daykey]['addup_pay_total'] = !empty($totalRow[$daykey]['addup_pay_total']) ? $totalRow[$daykey]['addup_pay_total'] + $row['addup_pay_total'] : $row['addup_pay_total'];
  1048. $totalRow[$daykey]['addup_pay_amount'] = !empty($totalRow[$daykey]['addup_pay_amount']) ? $totalRow[$daykey]['addup_pay_amount'] + $row['addup_pay_amount'] : $row['addup_pay_amount'];
  1049. $totalRow[$daykey]['pay_num'] = !empty($totalRow[$daykey]['pay_num']) ? $totalRow[$daykey]['pay_num'] + $row['pay_num'] : $row['pay_num'];
  1050. $totalRow[$daykey]['pay_total'] = !empty($totalRow[$daykey]['pay_total']) ? $totalRow[$daykey]['pay_total'] + $row['pay_total'] : $row['pay_total'];
  1051. if ($row['pay_month'] == $regDate) {
  1052. $pay_total = !empty($pay_total) ? $pay_total + $row['addup_pay_total'] : $row['addup_pay_total'];
  1053. $pay_amount = !empty($pay_amount) ? $pay_amount + $row['addup_pay_amount'] : $row['addup_pay_amount'];
  1054. $pay_num = !empty($pay_num) ? $pay_num + $row['pay_num'] : $row['pay_num'];
  1055. }
  1056. }
  1057. foreach ($totalRow as $key => $vv) {
  1058. if ($key[0] === 'm') {
  1059. switch ($dataType) {
  1060. case 'recovery':
  1061. $totalRow[$key] = ToolLogic::getPercent($totalRow[$key]['addup_pay_total'] ?? 0, $totalRow[$key]['cost'] ?? 0, 1);
  1062. break;
  1063. case 'remount':
  1064. $totalRow[$key] = ToolLogic::getPercent($totalRow[$key]['addup_pay_amount'] ?? 0, $totalRow[$key]['cost'] ?? 0, 1);
  1065. break;
  1066. case 'ltv':
  1067. $totalRow[$key] = ToolLogic::getRound($totalRow[$key]['addup_pay_total'] ?? 0, $totalRow[$key]['reg_total'] ?? 0);
  1068. break;
  1069. case 'pay_num':
  1070. $totalRow[$key] = $totalRow[$key]['pay_num'] ?? 0;
  1071. break;
  1072. case 'pay_total':
  1073. $totalRow[$key] = $totalRow[$key]['pay_total'] ?? 0;
  1074. break;
  1075. case 'pay_rate':
  1076. $totalRow[$key] = ToolLogic::getPercent($totalRow[$key]['pay_num'] ?? 0, $totalRow[$key]['reg_total'] ?? 0);
  1077. break;
  1078. case 'arpu':
  1079. $totalRow[$key] = ToolLogic::getRound($totalRow[$key]['pay_total'] ?? 0, $totalRow[$key]['pay_num'] ?? 0);
  1080. break;
  1081. }
  1082. }
  1083. }
  1084. if ($data && $totalRow) {
  1085. switch ($dataType) {
  1086. case 'recovery':
  1087. $totalRow['m0'] = ToolLogic::getPercent($pay_total, $totalRow['cost'], 1);
  1088. break;
  1089. case 'remount':
  1090. $totalRow['m0'] = ToolLogic::getPercent($pay_amount, $totalRow['cost'], 1);
  1091. break;
  1092. case 'ltv':
  1093. $totalRow['m0'] = ToolLogic::getRound($pay_total, $totalRow['reg_total']);
  1094. break;
  1095. case 'pay_num':
  1096. $totalRow['m0'] = $pay_num;
  1097. break;
  1098. case 'pay_total':
  1099. $totalRow['m0'] = $pay_total;
  1100. break;
  1101. case 'pay_rate':
  1102. $totalRow['m0'] = ToolLogic::getPercent($pay_num, $totalRow['reg_total']);
  1103. break;
  1104. case 'arpu':
  1105. $totalRow['m0'] = ToolLogic::getRound($pay_total, $pay_num);
  1106. break;
  1107. default:
  1108. break;
  1109. }
  1110. $totalRow['reg_cost'] = ToolLogic::getRound($totalRow['cost'], $totalRow['reg_total']);
  1111. $list = ToolLogic::arrSort($data, 'tmonth', 'asc');
  1112. }
  1113. return [
  1114. 'data' => array_values($list),
  1115. 'totalRow' => $totalRow
  1116. ];
  1117. }
  1118. }