ChannelAnalysisLogic.php 67 KB

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