AnalyseLogic.php 48 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179
  1. <?php
  2. // 运营分析
  3. namespace app\v1\logic\dataReport;
  4. use plugin\saiadmin\basic\BaseLogic;
  5. use plugin\saiadmin\exception\ApiException;
  6. use support\think\Db;
  7. class AnalyseLogic extends BaseLogic
  8. {
  9. // 注册按日
  10. public function getRegDayDataList($params)
  11. {
  12. $params = $this->searchByAuth($params);
  13. $whereRaw = $this->getCommonWhereRaw($params);
  14. $field = "SUM(reg_total) AS reg_total, tdate, game_id";
  15. $yearRange = getYearRange($params['tdate'][0], $params['tdate'][1]);
  16. $baseData = $this->generateUnionList('base_total_day', $yearRange, $whereRaw, $field, 'game_id,tdate');
  17. $data = [];
  18. foreach ($baseData as $row) {
  19. $game_id = $row['game_id'];
  20. $data[$game_id][$row['tdate']] = $row['reg_total'];
  21. $data[$game_id]['total'] = !empty($data[$game_id]['total']) ? $data[$game_id]['total'] + $row['reg_total'] : $row['reg_total'];
  22. $data[$game_id]['game_id'] = $game_id;
  23. }
  24. $list = array_values($data);
  25. $totalRow = ['game_id' => '合计'];
  26. foreach ($list as $row) {
  27. $totalRow['total'] = !empty($totalRow['total']) ? ($totalRow['total'] + $row['total']) : $row['total'];
  28. foreach ($row as $key => $value) {
  29. if ($key == 'total' || $key == 'game_id') {
  30. continue;
  31. }
  32. $totalRow[$key] = !empty($totalRow[$key]) ? $totalRow[$key] + $value : $value;
  33. }
  34. }
  35. // 获取两个注册日期之间的日期列表
  36. $dateList = getDateRange($params['tdate'][0], $params['tdate'][1]);
  37. $columnsData = [
  38. [
  39. 'title' => '游戏ID',
  40. 'dataIndex' => 'game_id',
  41. 'width' => 120,
  42. ],
  43. [
  44. 'title' => '游戏',
  45. 'dataIndex' => 'game_name',
  46. 'width' => 120,
  47. ],
  48. [
  49. 'title' => '合计',
  50. 'dataIndex' => 'total',
  51. 'width' => 120,
  52. ]
  53. ];
  54. foreach ($dateList as $date) {
  55. $columnsData[] = [
  56. 'title' => $date,
  57. 'dataIndex' => $date,
  58. 'width' => 120,
  59. ];
  60. }
  61. $result['data'] = $list;
  62. $result['totalRow'] = $totalRow;
  63. $result['columns'] = $columnsData;
  64. return $result;
  65. }
  66. // 注册分时
  67. public function getRegHourDataList($params)
  68. {
  69. $params = $this->searchByAuth($params);
  70. $regDate = $params['tdate'];
  71. $params['tdate'] = [$params['tdate'], $params['tdate']];
  72. $field = "SUM(reg_total) AS reg_total, tdate,game_id,thour";
  73. // 将$regDate转化为年月格式,如202509
  74. $ym = date('Ym', strtotime($regDate));
  75. $tableName = 'base_total_hour_' . $ym;
  76. $whereRaw = $this->getCommonWhereRaw($params);
  77. $sql = "SELECT {$field} FROM {$tableName} where {$whereRaw} GROUP BY game_id,thour,tdate";
  78. $baseData = Db::connect('db_data_report')->query($sql);
  79. $data = [];
  80. foreach ($baseData as &$row) {
  81. $game_id = $row['game_id'];
  82. $thour = $row['thour'];
  83. $data[$game_id]['h' . $thour] = $row['reg_total'];
  84. $data[$game_id]['total'] = !empty($data[$game_id]['total']) ? $data[$game_id]['total'] + $row['reg_total'] : $row['reg_total'];
  85. $data[$game_id]['game_id'] = $game_id;
  86. }
  87. $list = array_values($data);
  88. $totalRow = ['game_id' => '合计'];
  89. foreach ($list as &$row) {
  90. $totalRow['total'] = !empty($totalRow['total']) ? $totalRow['total'] + $row['total'] : $row['total'];
  91. foreach ($row as $key => $value) {
  92. if ($key == 'total' || $key == 'game_id') {
  93. continue;
  94. }
  95. $totalRow[$key] = !empty($totalRow[$key]) ? $totalRow[$key] + $value : $value;
  96. }
  97. }
  98. $result['data'] = $list;
  99. $result['totalRow'] = $totalRow;
  100. return $result;
  101. }
  102. /*
  103. 数据总览(按月)
  104. */
  105. public function getRetentionDayDataList($where)
  106. {
  107. $params = $this->searchByAuth($where);
  108. // 构建whereSql
  109. $whereRaw = $this->getCommonWhereRaw($params);
  110. $data = [];
  111. $totalRow = ['game_id' => '合计'];
  112. $baseField = "SUM(reg_total) AS reg_total, tdate,game_id";
  113. $activeField = "SUM(active_total) AS active_total, reg_date, game_id, days";
  114. // 1. 查询每天的注册数,根据注册时间,游戏
  115. $yearRange = getYearRange($params['tdate'][0], $params['tdate'][1]);
  116. $baseData = $this->generateUnionList('base_total_day', $yearRange, $whereRaw, $baseField, 'game_id,tdate');
  117. $baseData = array_column($baseData, null, 'tdate');
  118. // 2. 查询每天的活跃数,根据注册时间,游戏,留存天数
  119. $activeWhereSql = str_replace("tdate", "reg_date", $whereRaw);
  120. if (!empty($params['days'])) {
  121. $activeWhereSql .= " AND days = {$params['days']}";
  122. }
  123. $activeData = $this->generateUnionList('game_active_day', $yearRange, $activeWhereSql, $activeField, 'game_id, reg_date');
  124. $activeData = array_column($activeData, null, 'reg_date');
  125. foreach ($baseData as $row) {
  126. $game_id = $row['game_id'];
  127. $tdate = $row['tdate'];
  128. $data[$game_id]['game_id'] = $game_id;
  129. $data[$game_id][$tdate]['reg_total'] = $row['reg_total'];
  130. $data[$game_id][$tdate]['active_total'] = !empty($activeData[$tdate]['active_total']) ? $activeData[$tdate]['active_total'] : 0;
  131. $data[$game_id][$tdate]['retention_total'] = getPercent($data[$game_id][$tdate]['active_total'], $data[$game_id][$tdate]['reg_total']);
  132. // 每日合计
  133. $data[$game_id]['total_reg_total'] = !empty($data[$game_id]['total_reg_total']) ? $data[$game_id]['total_reg_total'] + $data[$game_id][$tdate]['reg_total'] : $data[$game_id][$tdate]['reg_total'];
  134. $data[$game_id]['total_active_total'] = !empty($data[$game_id]['total_active_total']) ? $data[$game_id]['total_active_total'] + $data[$game_id][$tdate]['active_total'] : $data[$game_id][$tdate]['active_total'];
  135. // 底部合计
  136. $totalRow['total_reg_total'] = !empty($totalRow['total_reg_total']) ? $totalRow['total_reg_total'] + $data[$game_id][$tdate]['reg_total'] : $data[$game_id][$tdate]['reg_total'];
  137. $totalRow['total_active_total'] = !empty($totalRow['total_active_total']) ? $totalRow['total_active_total'] + $data[$game_id][$tdate]['active_total'] : $data[$game_id][$tdate]['active_total'];
  138. $totalRow[$tdate]['reg_total'] = !empty($totalRow[$tdate]['reg_total']) ? $totalRow[$tdate]['reg_total'] + $data[$game_id][$tdate]['reg_total'] : $data[$game_id][$tdate]['reg_total'];
  139. $totalRow[$tdate]['active_total'] = !empty($totalRow[$tdate]['active_total']) ? $totalRow[$tdate]['active_total'] + $data[$game_id][$tdate]['active_total'] : $data[$game_id][$tdate]['active_total'];
  140. }
  141. $data = array_values($data);
  142. foreach ($data as &$row) {
  143. foreach ($row as $key => $value) {
  144. if ($key == 'total_reg_total' || $key == 'game_id') {
  145. continue;
  146. }
  147. if ($key == 'total_active_total') {
  148. $row['total'] = getPercent($row['total_active_total'], $row['total_reg_total']);
  149. } else {
  150. $row[$key] = getPercent($value['active_total'], $value['reg_total']);
  151. }
  152. }
  153. }
  154. foreach ($totalRow as $totalKey => &$row) {
  155. if ($totalKey == 'game_id' || $totalKey == 'total_active_total' || $totalKey == 'total_reg_total') {
  156. continue;
  157. }
  158. $totalRow[$totalKey] = getPercent($row['active_total'], $row['reg_total']);
  159. }
  160. $totalRow['total'] = getPercent($totalRow['total_active_total'] ?? 0, $totalRow['total_reg_total'] ?? 0);
  161. // 获取两个注册日期之间的日期列表
  162. $dateList = getDateRange($where['tdate'][0], $where['tdate'][1]);
  163. $columnsData = [
  164. [
  165. 'title' => '游戏ID',
  166. 'dataIndex' => 'game_id',
  167. 'width' => 120,
  168. ],
  169. [
  170. 'title' => '游戏',
  171. 'dataIndex' => 'game_name',
  172. 'width' => 120,
  173. ],
  174. [
  175. 'title' => '合计',
  176. 'dataIndex' => 'total',
  177. 'width' => 120,
  178. ]
  179. ];
  180. foreach ($dateList as $date) {
  181. $columnsData[] = [
  182. 'title' => $date,
  183. 'dataIndex' => $date,
  184. 'width' => 120,
  185. ];
  186. }
  187. $result['data'] = $data;
  188. $result['totalRow'] = $totalRow;
  189. $result['columns'] = $columnsData;
  190. return $result;
  191. }
  192. // 数据总览
  193. public function getDataOverview($where)
  194. {
  195. $params = $this->searchByAuth($where);
  196. $whereRaw = $this->getCommonWhereRaw($params);
  197. // 基础汇总信息
  198. $field = "
  199. SUM(login_total) AS login_total,
  200. SUM(reg_total) AS reg_total,
  201. SUM(pay_total) AS pay_total,
  202. SUM(pay_num) AS pay_num,
  203. SUM(reg_login_total) AS reg_login_total,
  204. SUM(reg_pay_num) AS reg_pay_num,
  205. SUM(reg_pay_total) AS reg_pay_total,
  206. SUM(old_login_total) AS old_login_total,
  207. tdate";
  208. $yearRange = getYearRange($params['tdate'][0], $params['tdate'][1]);
  209. $baseData = $this->generateUnionList('base_total_day', $yearRange, $whereRaw, $field, 'tdate');
  210. if (empty($baseData)) {
  211. return [
  212. 'data' => [],
  213. 'totalRow' => []
  214. ];
  215. }
  216. $actWhereSql = str_replace("tdate", "reg_date", $whereRaw);
  217. $actWhereSql .= " AND days = 1";
  218. $actData = $this->generateUnionList('game_active_day', $yearRange, $actWhereSql, 'SUM(active_total) AS active_total, reg_date', 'reg_date');
  219. $actData = array_column($actData, null, 'reg_date');
  220. $totalRow = [
  221. 'tdate' => '合计'
  222. ];
  223. foreach ($baseData as &$row) {
  224. $totalRow['login_total'] = !empty($totalRow['login_total']) ? $totalRow['login_total'] + $row['login_total'] : $row['login_total']; // 总用户 - 登陆总数
  225. $totalRow['reg_login_total'] = !empty($totalRow['reg_login_total']) ? $totalRow['reg_login_total'] + $row['reg_login_total'] : $row['reg_login_total']; // 新用户 - 注册登陆总数
  226. $totalRow['pay_num'] = !empty($totalRow['pay_num']) ? $totalRow['pay_num'] + $row['pay_num'] : $row['pay_num']; // 总用户 - 付费人数
  227. $totalRow['pay_total'] = !empty($totalRow['pay_total']) ? $totalRow['pay_total'] + $row['pay_total'] : $row['pay_total']; // 总用户 - 付费金额
  228. $totalRow['old_login_total'] = !empty($totalRow['old_login_total']) ? $totalRow['old_login_total'] + $row['old_login_total'] : $row['old_login_total']; // 老用户 - 登陆总数
  229. $totalRow['reg_total'] = !empty($totalRow['reg_total']) ? $totalRow['reg_total'] + $row['reg_total'] : $row['reg_total']; // 新用户 - 注册总数
  230. $totalRow['reg_pay_num'] = !empty($totalRow['reg_pay_num']) ? $totalRow['reg_pay_num'] + $row['reg_pay_num'] : $row['reg_pay_num']; // 新用户 - 注册付费数
  231. $totalRow['reg_pay_total'] = !empty($totalRow['reg_pay_total']) ? $totalRow['reg_pay_total'] + $row['reg_pay_total'] : $row['reg_pay_total']; // 新用户 - 注册付费金额
  232. $totalRow['active'] = !empty($totalRow['active']) ? $totalRow['active'] + $actData[$row['tdate']]['active_total'] ?? 0 : $actData[$row['tdate']]['active_total'] ?? 0; // 次留数
  233. $row['active'] = !empty($actData[$row['tdate']]['active_total']) ? $actData[$row['tdate']]['active_total'] : 0; // 次留数
  234. $row['arpu'] = getRound($row['pay_total'], $row['pay_num']); // 总用户 - ARPU
  235. $row['pay_rate'] = getPercent($row['pay_num'], $row['login_total']); // 总用户 - 付费率
  236. $row['reg_pay_rate'] = getPercent($row['reg_pay_num'], $row['reg_total']); // 新用户 - 注册付费率
  237. $row['reg_arpu'] = getRound($row['reg_pay_total'], $row['reg_pay_num']); // 新用户 - 注册付费ARPU
  238. $row['act_rate'] = getPercent($row['active'], $row['reg_total']); // 新用户 - 次留率
  239. $row['old_pay_num'] = $row['pay_num'] - $row['reg_pay_num']; // 老用户 - 付费人数
  240. $row['old_pay_total'] = $row['pay_total'] - $row['reg_pay_total']; // 老用户 - 付费金额
  241. $row['old_pay_rate'] = getPercent($row['old_pay_num'], $row['old_login_total']); // 老用户 - 付费率
  242. $row['old_arpu'] = getRound($row['old_pay_total'], $row['old_pay_num']); // 老用户 - 付费ARPU
  243. }
  244. $totalRow['arpu'] = getRound($totalRow['pay_total'], $totalRow['pay_num']); // 总用户 - ARPU
  245. $totalRow['pay_rate'] = getPercent($totalRow['pay_num'], $totalRow['login_total']); // 总用户 - 付费率
  246. $totalRow['reg_pay_rate'] = getPercent($totalRow['reg_pay_num'], $totalRow['reg_total']); // 新用户 - 注册付费率
  247. $totalRow['reg_arpu'] = getRound($totalRow['reg_pay_total'], $totalRow['reg_pay_num']); // 新用户 - 注册付费ARPU
  248. $totalRow['old_pay_num'] = $totalRow['pay_num'] - $totalRow['reg_pay_num']; // 老用户 - 付费人数
  249. $totalRow['old_pay_total'] = $totalRow['pay_total'] - $totalRow['reg_pay_total']; // 老用户 - 付费金额
  250. $totalRow['old_pay_rate'] = getPercent($totalRow['old_pay_num'], $totalRow['old_login_total']); // 老用户 - 付费率
  251. $totalRow['old_arpu'] = getRound($totalRow['old_pay_total'], $totalRow['old_pay_num']); // 老用户 - 付费ARPU
  252. $totalRow['act_rate'] = getPercent($totalRow['active'], $totalRow['reg_total']); // 次留率
  253. return [
  254. 'data' => $baseData,
  255. 'totalRow' => $totalRow
  256. ];
  257. }
  258. // 数据总览(按月)
  259. public function getDataOverviewByMonth($where)
  260. {
  261. $params = $this->searchByAuth($where);
  262. // 根据渠道名称获取渠道ID
  263. if (!empty($params['agent_name'])) {
  264. $agentData = Db::connect('db_advert')->query("SELECT id,name FROM agent_list WHERE name = '{$params['agent_name']}'");
  265. $params['agent_id'] = $agentData[0]['id'] ?? 0;
  266. }
  267. $whereRaw = $this->getCommonWhereRaw($params);
  268. // 基础汇总信息
  269. $field = "
  270. SUM(login_total) AS login_total,
  271. SUM(reg_total) AS reg_total,
  272. SUM(pay_total) AS pay_total,
  273. SUM(pay_num) AS pay_num,
  274. SUM(reg_login_total) AS reg_login_total,
  275. SUM(reg_pay_num) AS reg_pay_num,
  276. SUM(reg_pay_total) AS reg_pay_total,
  277. SUM(old_login_total) AS old_login_total,
  278. date_format(`tdate`, '%Y-%m') AS mdate";
  279. $yearRange = getYearRange($params['tdate'][0], $params['tdate'][1]);
  280. $baseData = $this->generateUnionList('base_total_day', $yearRange, $whereRaw, $field, 'mdate');
  281. if (empty($baseData)) {
  282. return [
  283. 'data' => [],
  284. 'totalRow' => []
  285. ];
  286. }
  287. $actWhereSql = str_replace("tdate", "reg_date", $whereRaw);
  288. $actWhereSql .= " AND days = 1";
  289. $actData = $this->generateUnionList('game_active_day', $yearRange, $actWhereSql, 'SUM(active_total) AS active_total,date_format(reg_date, "%Y-%m") AS mdate', 'mdate');
  290. $actData = array_column($actData, null, 'mdate');
  291. $totalRow = [
  292. 'mdate' => '合计'
  293. ];
  294. foreach ($baseData as &$row) {
  295. $totalRow['login_total'] = !empty($totalRow['login_total']) ? $totalRow['login_total'] + $row['login_total'] : $row['login_total']; // 总用户 - 登陆总数
  296. $totalRow['reg_login_total'] = !empty($totalRow['reg_login_total']) ? $totalRow['reg_login_total'] + $row['reg_login_total'] : $row['reg_login_total']; // 新用户 - 注册登陆总数
  297. $totalRow['pay_num'] = !empty($totalRow['pay_num']) ? $totalRow['pay_num'] + $row['pay_num'] : $row['pay_num']; // 总用户 - 付费人数
  298. $totalRow['pay_total'] = !empty($totalRow['pay_total']) ? $totalRow['pay_total'] + $row['pay_total'] : $row['pay_total']; // 总用户 - 付费金额
  299. $totalRow['old_login_total'] = !empty($totalRow['old_login_total']) ? $totalRow['old_login_total'] + $row['old_login_total'] : $row['old_login_total']; // 老用户 - 登陆总数
  300. $totalRow['reg_total'] = !empty($totalRow['reg_total']) ? $totalRow['reg_total'] + $row['reg_total'] : $row['reg_total']; // 新用户 - 注册总数
  301. $totalRow['reg_pay_num'] = !empty($totalRow['reg_pay_num']) ? $totalRow['reg_pay_num'] + $row['reg_pay_num'] : $row['reg_pay_num']; // 新用户 - 注册付费数
  302. $totalRow['reg_pay_total'] = !empty($totalRow['reg_pay_total']) ? $totalRow['reg_pay_total'] + $row['reg_pay_total'] : $row['reg_pay_total']; // 新用户 - 注册付费金额
  303. $totalRow['active'] = !empty($totalRow['active']) ? $totalRow['active'] + $actData[$row['mdate']]['active_total'] ?? 0 : $actData[$row['mdate']]['active_total'] ?? 0; // 次留数
  304. $row['active'] = !empty($actData[$row['mdate']]['active_total']) ? $actData[$row['mdate']]['active_total'] : 0; // 次留数
  305. $row['arpu'] = getRound($row['pay_total'], $row['pay_num']); // 总用户 - ARPU
  306. $row['pay_rate'] = getPercent($row['pay_num'], $row['login_total']); // 总用户 - 付费率
  307. $row['reg_pay_rate'] = getPercent($row['reg_pay_num'], $row['reg_total']); // 新用户 - 注册付费率
  308. $row['reg_arpu'] = getRound($row['reg_pay_total'], $row['reg_pay_num']); // 新用户 - 注册付费ARPU
  309. $row['act_rate'] = getPercent($row['active'], $row['reg_total']); // 新用户 - 次留率
  310. $row['old_pay_num'] = $row['pay_num'] - $row['reg_pay_num']; // 老用户 - 付费人数
  311. $row['old_pay_total'] = $row['pay_total'] - $row['reg_pay_total']; // 老用户 - 付费金额
  312. $row['old_pay_rate'] = getPercent($row['old_pay_num'], $row['old_login_total']); // 老用户 - 付费率
  313. $row['old_arpu'] = getRound($row['old_pay_total'], $row['old_pay_num']); // 老用户 - 付费ARPU
  314. }
  315. $totalRow['arpu'] = getRound($totalRow['pay_total'], $totalRow['pay_num']); // 总用户 - ARPU
  316. $totalRow['pay_rate'] = getPercent($totalRow['pay_num'], $totalRow['login_total']); // 总用户 - 付费率
  317. $totalRow['reg_pay_rate'] = getPercent($totalRow['reg_pay_num'], $totalRow['reg_total']); // 新用户 - 注册付费率
  318. $totalRow['reg_arpu'] = getRound($totalRow['reg_pay_total'], $totalRow['reg_pay_num']); // 新用户 - 注册付费ARPU
  319. $totalRow['old_pay_num'] = $totalRow['pay_num'] - $totalRow['reg_pay_num']; // 老用户 - 付费人数
  320. $totalRow['old_pay_total'] = $totalRow['pay_total'] - $totalRow['reg_pay_total']; // 老用户 - 付费金额
  321. $totalRow['old_pay_rate'] = getPercent($totalRow['old_pay_num'], $totalRow['old_login_total']); // 老用户 - 付费率
  322. $totalRow['old_arpu'] = getRound($totalRow['old_pay_total'], $totalRow['old_pay_num']); // 老用户 - 付费ARPU
  323. $totalRow['act_rate'] = getPercent($totalRow['active'], $totalRow['reg_total']); // 次留率
  324. return [
  325. 'data' => $baseData,
  326. 'totalRow' => $totalRow
  327. ];
  328. }
  329. /**
  330. * 收入分析
  331. */
  332. public function getIncomeAnalysis($where)
  333. {
  334. $params = $this->searchByAuth($where);
  335. $tdate = $params['tdate'] ?? date('Y-m-d');
  336. $ldate = date('Y-m-d', strtotime($tdate . ' -1 days'));
  337. $wdate = date('Y-m-d', strtotime($tdate . ' -7 days'));
  338. unset($params['tdate']);
  339. $whereRaw = $this->getCommonWhereRaw($params);
  340. $whereRaw .= " AND tdate IN ('{$tdate}','{$ldate}','{$wdate}')";
  341. $field = "
  342. SUM(pay_total) AS pay_total,
  343. SUM(pay_num) AS pay_num,
  344. SUM(login_total) AS login_total,
  345. game_id,
  346. tdate";
  347. $year = (int)date('Y', strtotime($tdate));
  348. $tableName = 'base_total_day_' . $year;
  349. $baseData = Db::connect('db_data_report')->query("SELECT {$field} FROM {$tableName} WHERE {$whereRaw} GROUP BY game_id,tdate");
  350. if (empty($baseData)) {
  351. return [
  352. 'data' => [],
  353. 'totalRow' => []
  354. ];
  355. }
  356. // 计算今日,所有游戏总充值
  357. $totalRow = [
  358. 'game_id' => '合计',
  359. 'yestoday_pay_total' => 0,
  360. 'pay_total' => 0,
  361. 'week_pay_total' => 0,
  362. ];
  363. $allTotal = 0;
  364. $data = [];
  365. foreach ($baseData as &$row) {
  366. $gameId = $row['game_id'];
  367. // 查询日期数据
  368. if ($row['tdate'] == $tdate) {
  369. $data[$gameId]['game_id'] = $gameId;
  370. $data[$gameId]['login_total'] = $row['login_total']; // DAU
  371. $data[$gameId]['pay_total'] = $row['pay_total'] ?? 0; // 今日充值
  372. $data[$gameId]['pay_num'] = $row['pay_num'] ?? 0; // 今日付费人数
  373. $data[$gameId]['pay_arpu'] = getRound($row['pay_total'], $row['pay_num']); // 今日付费ARPU
  374. $allTotal += $row['pay_total'];
  375. $totalRow['pay_total'] = !empty($totalRow['pay_total']) ? $totalRow['pay_total'] + $row['pay_total'] : $row['pay_total']; // 今日充值
  376. $totalRow['pay_num'] = !empty($totalRow['pay_num']) ? $totalRow['pay_num'] + $row['pay_num'] : $row['pay_num']; // 今日付费人数
  377. $totalRow['login_total'] = !empty($totalRow['login_total']) ? $totalRow['login_total'] + $row['login_total'] : $row['login_total']; // 今日登陆人数
  378. }
  379. // 查询昨天数据
  380. $data[$gameId]['yestoday_pay_total'] = 0;
  381. if ($row['tdate'] == $ldate) {
  382. $data[$gameId]['yestoday_pay_total'] = $row['pay_total'] ?? 0; // 昨日充值
  383. $totalRow['yestoday_pay_total'] = !empty($totalRow['yestoday_pay_total']) ? $totalRow['yestoday_pay_total'] + $row['pay_total'] : $row['pay_total']; // 昨日充值
  384. }
  385. // 查询7天前数据
  386. $data[$gameId]['week_pay_total'] = 0;
  387. if ($row['tdate'] == $wdate) {
  388. $data[$gameId]['week_pay_total'] = $row['pay_total'] ?? 0; // 7天前充值
  389. $totalRow['week_pay_total'] = !empty($totalRow['week_pay_total']) ? $totalRow['week_pay_total'] + $row['pay_total'] : $row['pay_total']; // 7天前充值
  390. }
  391. }
  392. $totalRow['pay_arpu'] = getRound($totalRow['pay_total'], $totalRow['pay_num']); // 今日充值ARPU
  393. $totalRow['pay_ratio'] = getPercent($totalRow['pay_total'], $allTotal); // 今日充值占比
  394. $totalRow['pay_increase_yestoday'] = $totalRow['pay_total'] - $totalRow['yestoday_pay_total']; // 昨日增长
  395. $totalRow['pay_increase_week'] = $totalRow['pay_total'] - $totalRow['week_pay_total']; // 7天增长
  396. if($data)foreach ($data as &$row) {
  397. $row['pay_ratio'] = getPercent($row['pay_total'], $allTotal); // 今日充值占比
  398. $row['pay_increase_yestoday'] = $row['pay_total'] - $row['yestoday_pay_total']; // 昨日增长
  399. $row['pay_increase_week'] = $row['pay_total'] - $row['week_pay_total']; // 7天增长
  400. }
  401. return [
  402. 'data' => array_values($data),
  403. 'totalRow' => $totalRow
  404. ];
  405. }
  406. /**
  407. * 付费留存
  408. * 1. 登录日志表:sdk_login_log_, 查找符合注册时间的用户, 获取用户id
  409. *
  410. * inner join ON login.uid = order.uid,
  411. *
  412. * 2. 根据用户id,去订单表,筛选出,次留、2留的日期为充值日期, 从而获取充值人数
  413. * 3. 根据注册时间,获取总的pay_num
  414. */
  415. public function getPayRetention($where)
  416. {
  417. $params = $this->searchByAuth($where);
  418. // 判断不能超过90天查询
  419. $days = getDateNum($where['tdate'][0], $where['tdate'][1]);
  420. if ($days > 90) {
  421. throw new ApiException('时间查询范围请勿超过90天');
  422. }
  423. $whereParams = $params;
  424. unset($whereParams['tdate']);
  425. $whereRaw = $this->getCommonWhereRaw($whereParams);
  426. $whereRaw = str_replace('tdate', 'reg_date', $whereRaw);
  427. // 1. 根据注册时间,获取注册付费人数
  428. $payData = Db::connect('db_game_log')->query("
  429. SELECT
  430. SUBSTRING(reg_date,1,10) as dimension,
  431. COUNT(DISTINCT uid) as pay_num
  432. FROM sdk_order_success
  433. WHERE {$whereRaw} AND reg_date BETWEEN '{$params['tdate'][0]} 00:00:00' AND '{$params['tdate'][1]} 23:59:59'
  434. GROUP BY
  435. dimension
  436. ");
  437. $payDataMap = array_column($payData, null, 'dimension');
  438. // 2. 计算留存付费的人数
  439. $sqlArr = [];
  440. $medate = date("Y-m-d", strtotime("+ 60 day", strtotime($params['tdate'][1])));
  441. $monthRange = getMonthRange($params['tdate'][0], $medate);
  442. $newMonth = date("Ym");
  443. foreach ($monthRange as $month) {
  444. if($month>$newMonth){
  445. break;
  446. }
  447. $tableName = 'sdk_login_log_' . $month;
  448. $sqlArr[] = "
  449. SELECT
  450. CONCAT(FROM_UNIXTIME(reg_time, '%Y-%m-%d'), '|', TIMESTAMPDIFF(DAY, FROM_UNIXTIME(reg_time), FROM_UNIXTIME(login_time))) AS dimension,
  451. FROM_UNIXTIME(reg_time, '%Y-%m-%d') AS reg_date,
  452. TIMESTAMPDIFF(DAY, FROM_UNIXTIME(reg_time), FROM_UNIXTIME(login_time)) AS day_num,
  453. COUNT(DISTINCT a.user_name) AS remain_num
  454. FROM {$tableName} AS a
  455. INNER JOIN (
  456. SELECT
  457. DISTINCT user_name
  458. FROM sdk_order_success
  459. WHERE
  460. {$whereRaw} AND reg_date BETWEEN '{$params['tdate'][0]} 00:00:00' AND '{$params['tdate'][1]} 23:59:59'
  461. ) AS b ON a.user_name = b.user_name
  462. WHERE
  463. {$whereRaw} AND reg_time BETWEEN " . strtotime($params['tdate'][0] . " 00:00:00") . " AND " . strtotime($params['tdate'][1] . " 23:59:59") . "
  464. GROUP BY dimension
  465. ";
  466. }
  467. $sql = implode(" UNION ALL ", $sqlArr);
  468. // echo $sql . "\n";
  469. $remainData = Db::connect('db_game_log')->query($sql);
  470. $remainData = $remainData ? array_column($remainData, null, "dimension") : [];
  471. $regDateRange = getDateRange($params['tdate'][0], $params['tdate'][1]);
  472. $remainRange = [];
  473. for ($i = 2; $i <= 30; $i++) {
  474. $remainRange[] = $i;
  475. }
  476. $remainRange = array_merge($remainRange, [35, 40, 45, 50, 55, 60]);
  477. $data = [];
  478. foreach ($regDateRange as $regDate) {
  479. $row['reg_date'] = $regDate;
  480. $row['reg_pay_num'] = $payDataMap[$regDate]['pay_num'] ?? '';
  481. foreach ($remainRange as $remainNum) {
  482. $dimension = $regDate . "|" . ($remainNum - 1);
  483. $row['remain_' . $remainNum] = $remainData[$dimension]['remain_num'] ?? '';
  484. }
  485. $data[] = $row;
  486. }
  487. // 合计
  488. $totalRow = [
  489. 'reg_date' => '合计',
  490. ];
  491. // 计算合计
  492. if ($data) foreach ($data as $item) {
  493. $totalRow['reg_pay_num'] = $totalRow['reg_pay_num'] ?? 0;
  494. $totalRow['reg_pay_num'] = $totalRow['reg_pay_num'] ? $totalRow['reg_pay_num'] + $item['reg_pay_num'] : $item['reg_pay_num'];
  495. foreach ($remainRange as $remainNum) {
  496. $key = 'remain_' . $remainNum;
  497. $totalRow[$key] = $totalRow[$key] ?? 0;
  498. $totalRow[$key] = $totalRow[$key] ? $totalRow[$key] + $item[$key] : $item[$key];
  499. }
  500. }
  501. // 计算比率
  502. if ($params['show_type'] == 'rate') {
  503. if ($data) foreach ($remainRange as $remainNum) {
  504. $key = 'remain_' . $remainNum;
  505. $totalRow[$key] = $totalRow[$key] ? getPercent($totalRow[$key], $totalRow['reg_pay_num']) : '';
  506. foreach ($data as &$val) {
  507. $val[$key] = $val[$key] ? getPercent($val[$key], $val['reg_pay_num']) : '';
  508. }
  509. }
  510. }
  511. return [
  512. 'data' => $data,
  513. 'totalRow' => $totalRow
  514. ];
  515. }
  516. // 生成基础小时统计表的联合查询列表
  517. public function getChartData($where)
  518. {
  519. $params = $this->searchByAuth($where);
  520. $type = $params['compare_type'] ?? 'day';
  521. // 如果按照天对比
  522. if ($type === 'day') {
  523. $data1 = [];
  524. $data2 = [];
  525. $data1Res = [];
  526. $data2Res = [];
  527. $field = "
  528. SUM(reg_total) as reg,
  529. SUM(old_login_total) as login,
  530. SUM(pay_total) as pay,
  531. tdate
  532. ";
  533. // 获取对比日期1的数据, 注册、登录、充值
  534. $params['tdate'] = $params['compare_date1'];
  535. $whereRaw1 = $this->getCommonWhereRaw($params);
  536. $yearRange = getYearRange($params['compare_date1'][0], $params['compare_date1'][1]);
  537. $baseData1 = $this->generateUnionList('base_total_day', $yearRange, $whereRaw1, $field, 'tdate');
  538. foreach ($baseData1 as $item) {
  539. $data1Res[$item['tdate']]['reg'] = $item['reg'];
  540. $data1Res[$item['tdate']]['pay'] = $item['pay'];
  541. $data1Res[$item['tdate']]['login'] = $item['login'];
  542. }
  543. // 获取对比日期2的数据, 注册、登录、充值
  544. $params['tdate'] = $params['compare_date2'];
  545. $whereRaw2 = $this->getCommonWhereRaw($params);
  546. $yearRange = getYearRange($params['compare_date2'][0], $params['compare_date2'][1]);
  547. $baseData2 = $this->generateUnionList('base_total_day', $yearRange, $whereRaw2, $field, 'tdate');
  548. foreach ($baseData2 as $item) {
  549. $data2Res[$item['tdate']]['reg'] = $item['reg'];
  550. $data2Res[$item['tdate']]['pay'] = $item['pay'];
  551. $data2Res[$item['tdate']]['login'] = $item['login'];
  552. }
  553. // 获取消耗数据1
  554. $params['tdate'] = $params['compare_date1'];
  555. $costWhereSql1 = $this->getCommonWhereRaw($params);
  556. $costData1 = Db::connect('db_advert')->query("
  557. SELECT SUM(money) as money, tdate
  558. FROM media_cost
  559. WHERE {$costWhereSql1}
  560. GROUP BY tdate
  561. ");
  562. foreach ($costData1 as $item) {
  563. $data1Res[$item['tdate']]['cost'] = $item['money'];
  564. }
  565. // 获取消耗数据2
  566. $params['tdate'] = $params['compare_date2'];
  567. $costWhereSql2 = $this->getCommonWhereRaw($params);
  568. $costData2 = Db::connect('db_advert')->query("
  569. SELECT SUM(money) as money, tdate
  570. FROM media_cost
  571. WHERE {$costWhereSql2}
  572. GROUP BY tdate
  573. ");
  574. foreach ($costData2 as $item) {
  575. $data2Res[$item['tdate']]['cost'] = $item['money'];
  576. }
  577. // 获取两个日期之间的所有日期
  578. $day1Date = getDateRange($params['compare_date1'][0], $params['compare_date1'][1]);
  579. $day2Date = getDateRange($params['compare_date2'][0], $params['compare_date2'][1]);
  580. foreach ($day1Date as $k => $d) {
  581. $data1['days'][$k] = $d;
  582. $data1['pay'][$k] = !empty($data1Res[$d]['pay']) ? round((float)$data1Res[$d]['pay'], 2) : 0;
  583. $data1['cost'][$k] = !empty($data1Res[$d]['cost']) ? round((float)$data1Res[$d]['cost'], 2) : 0;
  584. $data1['reg'][$k] = !empty($data1Res[$d]['reg']) ? (int)$data1Res[$d]['reg'] : 0;
  585. $data1['login'][$k] = !empty($data1Res[$d]['login']) ? (int)$data1Res[$d]['login'] : 0;
  586. }
  587. foreach ($day2Date as $k => $d) {
  588. $data2['days'][$k] = $d;
  589. $data2['pay'][$k] = !empty($data2Res[$d]['pay']) ? round((float)$data2Res[$d]['pay'], 2) : 0;
  590. $data2['cost'][$k] = !empty($data2Res[$d]['cost']) ? round((float)$data2Res[$d]['cost'], 2) : 0;
  591. $data2['reg'][$k] = !empty($data2Res[$d]['reg']) ? (int)$data2Res[$d]['reg'] : 0;
  592. $data2['login'][$k] = !empty($data2Res[$d]['login']) ? (int)$data2Res[$d]['login'] : 0;
  593. }
  594. // 格式化x轴的时间
  595. $days1 = [];
  596. $days2 = [];
  597. if (count($data1['days']) > count($data2['days'])) {
  598. $forData = $data1['days'];
  599. } else {
  600. $forData = $data2['days'];
  601. }
  602. for ($i = 0; $i < count($forData); $i++) {
  603. $d1 = !empty($data1['days'][$i]) ? date("m-d", strtotime($data1['days'][$i])) : "";
  604. $d2 = !empty($data2['days'][$i]) ? date("m-d", strtotime($data2['days'][$i])) : "";
  605. $days1[] = $d1;
  606. $days2[] = $d2;
  607. }
  608. $data1['series'] = "日期1";
  609. $data2['series'] = "日期2";
  610. return [
  611. 'data1' => $data1,
  612. 'data2' => $data2,
  613. 'days1' => $days1,
  614. 'days2' => $days2
  615. ];
  616. }
  617. // 如果按小时对比
  618. if ($type === 'hour') {
  619. $data1 = [];
  620. $data2 = [];
  621. $data1Res = [];
  622. $data2Res = [];
  623. $field = "
  624. SUM(reg_total) as reg,
  625. SUM(old_login_total) as login,
  626. SUM(pay_total) as pay,
  627. SUM(cost) as cost,
  628. thour
  629. ";
  630. // 获取对比日期1的数据, 注册、登录、充值
  631. $params['tdate'] = $params['compare_date1_date'];
  632. $whereRaw1 = $this->getCommonWhereRaw($params);
  633. $monthRange = getMonthRange($params['compare_date1'][0], $params['compare_date1'][1]);
  634. $baseData1 = $this->generateUnionList('base_total_hour', $monthRange, $whereRaw1, $field, 'thour');
  635. foreach ($baseData1 as $item) {
  636. $data1Res[$item['thour']]['reg'] = $item['reg'];
  637. $data1Res[$item['thour']]['pay'] = $item['pay'];
  638. $data1Res[$item['thour']]['login'] = $item['login'];
  639. $data1Res[$item['thour']]['cost'] = $item['cost'];
  640. }
  641. // 获取对比日期2的数据, 注册、登录、充值
  642. $params['tdate'] = $params['compare_date2_date'];
  643. $whereRaw2 = $this->getCommonWhereRaw($params);
  644. $monthRange2 = getMonthRange($params['compare_date2'][0], $params['compare_date2'][1]);
  645. $baseData2 = $this->generateUnionList('base_total_hour', $monthRange2, $whereRaw2, $field, 'thour');
  646. foreach ($baseData2 as $item) {
  647. $data2Res[$item['thour']]['reg'] = $item['reg'];
  648. $data2Res[$item['thour']]['pay'] = $item['pay'];
  649. $data2Res[$item['thour']]['login'] = $item['login'];
  650. $data2Res[$item['thour']]['cost'] = $item['cost'];
  651. }
  652. $ndate = date("Y-m-d");
  653. $hour = date("H");
  654. for ($h = 0; $h < 24; $h++) {
  655. if ($params['compare_date1_date'] == $ndate && $h > $hour) {
  656. continue;
  657. }
  658. $data1['hour'][$h] = $h;
  659. $data1['pay'][$h] = !empty($data1Res[$h]) ? round((float)$data1Res[$h]['pay'] ?? 0, 2) : 0;
  660. $data1['cost'][$h] = !empty($data1Res[$h]) ? round((float)$data1Res[$h]['cost'] ?? 0, 2) : 0;
  661. $data1['reg'][$h] = !empty($data1Res[$h]) ? (int)$data1Res[$h]['reg'] ?? 0 : 0;
  662. $data1['login'][$h] = !empty($data1Res[$h]) ? (int)$data1Res[$h]['login'] ?? 0 : 0;
  663. }
  664. for ($h = 0; $h < 24; $h++) {
  665. if ($params['compare_date2_date'] == $ndate && $h > $hour) {
  666. continue;
  667. }
  668. $data2['hour'][$h] = $h;
  669. $data2['pay'][$h] = !empty($data2Res[$h]) ? round((float)$data2Res[$h]['pay'] ?? 0, 2) : 0;
  670. $data2['cost'][$h] = !empty($data2Res[$h]) ? round((float)$data2Res[$h]['cost'] ?? 0, 2) : 0;
  671. $data2['reg'][$h] = !empty($data2Res[$h]) ? (int)$data2Res[$h]['reg'] ?? 0 : 0;
  672. $data2['login'][$h] = !empty($data2Res[$h]) ? (int)$data2Res[$h]['login'] ?? 0 : 0;
  673. }
  674. $hour = [];
  675. for ($h = 0; $h < 24; $h++) {
  676. $hour[] = $h;
  677. }
  678. $data1['series'] = $params['compare_date1_date'];
  679. $data2['series'] = $params['compare_date2_date'];
  680. return [
  681. 'data1' => $data1,
  682. 'data2' => $data2,
  683. 'days1' => $hour,
  684. 'days2' => $hour
  685. ];
  686. }
  687. }
  688. // 支付成功率
  689. public function getPaySuccessRate($where)
  690. {
  691. $params = $this->searchByAuth($where);
  692. $whereRaw = $this->getCommonWhereRaw($params);
  693. $type = $params['type'] ?? 'day';
  694. if ($type == 'day') {
  695. return $this->getPaySuccessRateByDay($whereRaw);
  696. } elseif ($type == 'week') {
  697. return $this->getPaySuccessRateByWeek($whereRaw);
  698. }
  699. return [];
  700. }
  701. /**
  702. * 按天对比支付成功率(今天vs昨天,按小时分组)
  703. */
  704. private function getPaySuccessRateByDay($whereRaw)
  705. {
  706. $today = date('Y-m-d');
  707. $yesterday = date('Y-m-d', strtotime('-1 day'));
  708. $currentStartTime = strtotime($today . " 00:00:00");
  709. $currentEndTime = strtotime($today . " 23:59:59");
  710. $lastStartTime = strtotime($yesterday . " 00:00:00");
  711. $lastEndTime = strtotime($yesterday . " 23:59:59");
  712. // 获取当前周期和上一周期的数据
  713. $currentData = $this->getPayDataByTimeRange($whereRaw, $currentStartTime, $currentEndTime);
  714. $lastData = $this->getPayDataByTimeRange($whereRaw, $lastStartTime, $lastEndTime);
  715. // 初始化24小时数据
  716. $currentOrderMap = $this->initHourlyData();
  717. $currentPayMap = $this->initHourlyData();
  718. $lastOrderMap = $this->initHourlyData();
  719. $lastPayMap = $this->initHourlyData();
  720. // 填充数据(按小时)
  721. $this->fillDataByHour($currentData['orderData'], $currentOrderMap);
  722. $this->fillDataByHour($currentData['payData'], $currentPayMap);
  723. $this->fillDataByHour($lastData['orderData'], $lastOrderMap);
  724. $this->fillDataByHour($lastData['payData'], $lastPayMap);
  725. // 计算成功率
  726. $currentRateArr = $this->calculateSuccessRate($currentOrderMap, $currentPayMap);
  727. $lastRateArr = $this->calculateSuccessRate($lastOrderMap, $lastPayMap);
  728. // 生成X轴数据(小时)
  729. $xAxisData = $this->generateHourlyXAxisData();
  730. // 计算成功率变化
  731. $successRateChange = $this->calculateRateChange($currentRateArr, $lastRateArr);
  732. // 生成表格数据
  733. $tableData = $this->generateDayTableData(
  734. $currentOrderMap,
  735. $currentPayMap,
  736. $currentRateArr,
  737. $lastOrderMap,
  738. $lastPayMap,
  739. $lastRateArr,
  740. $successRateChange
  741. );
  742. $currentOrderNum = array_sum($currentOrderMap);
  743. $currentPaySuccessNum = array_sum($currentPayMap);
  744. $paySuccessRate = $currentOrderNum > 0 ? getRound($currentPaySuccessNum, $currentOrderNum) : 0;
  745. return [
  746. 'PaySuccessRateArr' => $currentRateArr,
  747. 'OldPaySuccessRateArr' => $lastRateArr,
  748. 'orderNum' => $currentOrderNum,
  749. 'successNum' => $currentPaySuccessNum,
  750. 'paySuccessRate' => $paySuccessRate,
  751. 'xAxisData' => $xAxisData,
  752. 'successRateChange' => $successRateChange,
  753. 'data' => $tableData
  754. ];
  755. }
  756. /**
  757. * 按周对比支付成功率(本周vs上周,按天分组)
  758. */
  759. private function getPaySuccessRateByWeek($whereRaw)
  760. {
  761. // 本周:今天往前7天(包含今天)
  762. $currentEndTime = strtotime(date('Y-m-d') . " 23:59:59");
  763. $currentStartTime = strtotime(date('Y-m-d', strtotime('-6 days')) . " 00:00:00");
  764. // 上周:今天往前14天到往前7天
  765. $lastEndTime = strtotime(date('Y-m-d', strtotime('-7 days')) . " 23:59:59");
  766. $lastStartTime = strtotime(date('Y-m-d', strtotime('-13 days')) . " 00:00:00");
  767. // 获取当前周期和上一周期的数据
  768. $currentData = $this->getPayDataByTimeRange($whereRaw, $currentStartTime, $currentEndTime);
  769. $lastData = $this->getPayDataByTimeRange($whereRaw, $lastStartTime, $lastEndTime);
  770. // 初始化7天数据
  771. $currentOrderMap = $this->initWeeklyData($currentStartTime);
  772. $currentPayMap = $this->initWeeklyData($currentStartTime);
  773. $lastOrderMap = $this->initWeeklyData($lastStartTime);
  774. $lastPayMap = $this->initWeeklyData($lastStartTime);
  775. // 填充数据(按天)
  776. $this->fillDataByDay($currentData['orderData'], $currentOrderMap);
  777. $this->fillDataByDay($currentData['payData'], $currentPayMap);
  778. $this->fillDataByDay($lastData['orderData'], $lastOrderMap);
  779. $this->fillDataByDay($lastData['payData'], $lastPayMap);
  780. // 计算成功率
  781. $currentRateArr = $this->calculateSuccessRate($currentOrderMap, $currentPayMap);
  782. $lastRateArr = $this->calculateSuccessRate($lastOrderMap, $lastPayMap);
  783. // 生成X轴数据(星期)
  784. $xAxisData = $this->generateWeeklyXAxisData($currentStartTime);
  785. // 计算成功率变化
  786. $successRateChange = $this->calculateRateChange($currentRateArr, $lastRateArr);
  787. // 生成表格数据
  788. $tableData = $this->generateWeekTableData(
  789. $currentOrderMap,
  790. $currentPayMap,
  791. $currentRateArr,
  792. $lastOrderMap,
  793. $lastPayMap,
  794. $lastRateArr,
  795. $successRateChange,
  796. $xAxisData
  797. );
  798. $currentOrderNum = array_sum($currentOrderMap);
  799. $currentPaySuccessNum = array_sum($currentPayMap);
  800. $paySuccessRate = $currentOrderNum > 0 ? getRound($currentPaySuccessNum, $currentOrderNum) : 0;
  801. return [
  802. 'PaySuccessRateArr' => $currentRateArr,
  803. 'OldPaySuccessRateArr' => $lastRateArr,
  804. 'orderNum' => $currentOrderNum,
  805. 'successNum' => $currentPaySuccessNum,
  806. 'paySuccessRate' => $paySuccessRate,
  807. 'xAxisData' => $xAxisData,
  808. 'successRateChange' => $successRateChange,
  809. 'data' => $tableData
  810. ];
  811. }
  812. /**
  813. * 获取指定时间范围内的订单和支付数据
  814. */
  815. private function getPayDataByTimeRange($whereRaw, $startTime, $endTime)
  816. {
  817. $timeWhereRaw = $whereRaw . " AND pay_time BETWEEN '{$startTime}' AND '{$endTime}'";
  818. // 总下单量
  819. $orderData = Db::connect('db_game_log')->query("
  820. SELECT Count(*) as order_num, pay_time
  821. FROM sdk_order_success
  822. WHERE {$timeWhereRaw}
  823. GROUP BY pay_time
  824. ");
  825. // 总支付量
  826. $payData = Db::connect('db_game_log')->query("
  827. SELECT Count(*) as pay_num, pay_time
  828. FROM sdk_order_success
  829. WHERE {$timeWhereRaw} AND sync_status = 1
  830. GROUP BY pay_time
  831. ");
  832. return [
  833. 'orderData' => $orderData,
  834. 'payData' => $payData
  835. ];
  836. }
  837. /**
  838. * 初始化24小时数据结构
  839. */
  840. private function initHourlyData()
  841. {
  842. $data = [];
  843. for ($hour = 0; $hour < 24; $hour++) {
  844. $hourKey = str_pad($hour, 2, '0', STR_PAD_LEFT);
  845. $data[$hourKey] = 0;
  846. }
  847. return $data;
  848. }
  849. /**
  850. * 初始化7天数据结构
  851. */
  852. private function initWeeklyData($startTime)
  853. {
  854. $data = [];
  855. for ($day = 0; $day < 7; $day++) {
  856. $dateKey = date('Y-m-d', strtotime("+{$day} days", $startTime));
  857. $data[$dateKey] = 0;
  858. }
  859. return $data;
  860. }
  861. /**
  862. * 按小时填充数据
  863. */
  864. private function fillDataByHour($sourceData, &$targetMap)
  865. {
  866. foreach ($sourceData as $item) {
  867. $hourKey = date('H', $item['pay_time']);
  868. $value = $item['order_num'] ?? $item['pay_num'] ?? 0;
  869. $targetMap[$hourKey] = $value;
  870. }
  871. }
  872. /**
  873. * 按天填充数据
  874. */
  875. private function fillDataByDay($sourceData, &$targetMap)
  876. {
  877. foreach ($sourceData as $item) {
  878. $dateKey = date('Y-m-d', $item['pay_time']);
  879. $value = $item['order_num'] ?? $item['pay_num'] ?? 0;
  880. if (isset($targetMap[$dateKey])) {
  881. $targetMap[$dateKey] += $value;
  882. }
  883. }
  884. }
  885. /**
  886. * 计算成功率数组
  887. */
  888. private function calculateSuccessRate($orderMap, $payMap)
  889. {
  890. $rateArr = [];
  891. foreach ($orderMap as $key => $orderNum) {
  892. $payNum = $payMap[$key] ?? 0;
  893. $rateArr[] = $orderNum > 0 ? getRound($payNum, $orderNum) : 0;
  894. }
  895. return $rateArr;
  896. }
  897. /**
  898. * 计算成功率变化
  899. */
  900. private function calculateRateChange($currentRateArr, $lastRateArr)
  901. {
  902. $change = [];
  903. $count = count($currentRateArr);
  904. for ($i = 0; $i < $count; $i++) {
  905. $change[] = $currentRateArr[$i] - $lastRateArr[$i];
  906. }
  907. return $change;
  908. }
  909. /**
  910. * 生成小时X轴数据
  911. */
  912. private function generateHourlyXAxisData()
  913. {
  914. $xAxisData = [];
  915. for ($hour = 0; $hour < 24; $hour++) {
  916. $xAxisData[] = str_pad($hour, 2, '0', STR_PAD_LEFT) . ":00-" .
  917. str_pad($hour + 1, 2, '0', STR_PAD_LEFT) . ":00";
  918. }
  919. return $xAxisData;
  920. }
  921. /**
  922. * 生成星期X轴数据(根据起始日期往后推7天)
  923. */
  924. private function generateWeeklyXAxisData($startTime)
  925. {
  926. $weekDays = ['周日', '周一', '周二', '周三', '周四', '周五', '周六'];
  927. $xAxisData = [];
  928. for ($day = 0; $day < 7; $day++) {
  929. $timestamp = strtotime("+{$day} days", $startTime);
  930. $weekIndex = date('w', $timestamp);
  931. $xAxisData[] = $weekDays[$weekIndex];
  932. }
  933. return $xAxisData;
  934. }
  935. /**
  936. * 生成按天的表格数据
  937. */
  938. private function generateDayTableData(
  939. $currentOrderMap,
  940. $currentPayMap,
  941. $currentRateArr,
  942. $lastOrderMap,
  943. $lastPayMap,
  944. $lastRateArr,
  945. $successRateChange
  946. ) {
  947. $tableData = [];
  948. $index = 0;
  949. foreach ($currentOrderMap as $hourKey => $orderNum) {
  950. $tableData[] = [
  951. 'time' => $hourKey . ":00-" . str_pad(intval($hourKey) + 1, 2, '0', STR_PAD_LEFT) . ":00",
  952. 'todayOrderNum' => $orderNum,
  953. 'todayPayNum' => $currentPayMap[$hourKey],
  954. 'todayPaySuccessRate' => $currentRateArr[$index],
  955. 'yesterdayOrderNum' => array_values($lastOrderMap)[$index],
  956. 'yesterdayPayNum' => array_values($lastPayMap)[$index],
  957. 'yesterdayPaySuccessRate' => $lastRateArr[$index],
  958. 'successRateChange' => $successRateChange[$index],
  959. ];
  960. $index++;
  961. }
  962. return $tableData;
  963. }
  964. /**
  965. * 生成按周的表格数据
  966. */
  967. private function generateWeekTableData(
  968. $currentOrderMap,
  969. $currentPayMap,
  970. $currentRateArr,
  971. $lastOrderMap,
  972. $lastPayMap,
  973. $lastRateArr,
  974. $successRateChange,
  975. $xAxisData
  976. ) {
  977. $tableData = [];
  978. $index = 0;
  979. foreach ($currentOrderMap as $dateKey => $orderNum) {
  980. $tableData[] = [
  981. 'time' => $xAxisData[$index],
  982. 'todayOrderNum' => $orderNum,
  983. 'todayPayNum' => $currentPayMap[$dateKey],
  984. 'todayPaySuccessRate' => $currentRateArr[$index],
  985. 'yesterdayOrderNum' => array_values($lastOrderMap)[$index],
  986. 'yesterdayPayNum' => array_values($lastPayMap)[$index],
  987. 'yesterdayPaySuccessRate' => $lastRateArr[$index],
  988. 'successRateChange' => $successRateChange[$index],
  989. ];
  990. $index++;
  991. }
  992. return $tableData;
  993. }
  994. }