Cron.php 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485
  1. <?php
  2. namespace Log\Lib;
  3. use Dever;
  4. class Cron extends Core
  5. {
  6. public function get()
  7. {
  8. # 获取所有项目
  9. $config = $this->config();
  10. $day = array();
  11. $day[0] = date('Y-m-d-H');
  12. $day[1] = date('Y-m-d-H', strtotime("-1 hour"));
  13. if (isset($config['project'])) {
  14. foreach ($config['project'] as $k => $v) {
  15. foreach ($day as $i => $j) {
  16. $data = $this->getDataByProject($j, $v['id'], $v['key']);
  17. $this->write($data);
  18. }
  19. }
  20. }
  21. return 'ok';
  22. }
  23. private function write($data)
  24. {
  25. //$data[0]写入到data表中,data[1]写入到es中
  26. $source = $data[0];
  27. $time = explode('-', $source['time']);
  28. $update['project_id'] = $source['project_id'];
  29. $update['time'] = Dever::maketime($time[0] . '-' . $time[1] . '-' . $time[2] . ' ' . $time[3] . ':00:00');
  30. $info = Dever::db('log/data')->one($update);
  31. $update['pv'] = $source['pv'];
  32. $update['uv'] = $source['uv'];
  33. if (!$info) {
  34. $update['year'] = $time[0];
  35. $update['month'] = $time[1];
  36. $update['day'] = $time[2];
  37. $update['hour'] = $time[3];
  38. Dever::db('log/data')->insert($update);
  39. } else {
  40. $update['where_id'] = $info['id'];
  41. Dever::db('log/data')->update($update);
  42. }
  43. }
  44. private function getDataByProject($day, $id, $key)
  45. {
  46. $data = Dever::getLog($day, $key . '/');
  47. $source = array();
  48. $source['project_id'] = $id;
  49. $source['time'] = $day;
  50. $source['pv'] = 0;
  51. $source['uv'] = 0;
  52. if ($data) {
  53. $result = array();
  54. $pv = $uv = 0;
  55. $user = array();
  56. foreach ($data as $k => $v) {
  57. if ($v) {
  58. $temp = explode('dever&', $v);
  59. $info = explode(' ', $temp[0]);
  60. $result[$k]['time'] = $info[0];
  61. $result[$k]['project'] = $info[1];
  62. $result[$k]['app'] = $info[2];
  63. parse_str($temp[1], $result[$k]['param']);
  64. $pv++;
  65. if (isset($result[$k]['param']['uid']) && $result[$k]['param']['uid'] > 0) {
  66. $user[$result[$k]['param']['uid']] = 1;
  67. } else {
  68. $user[$result[$k]['param']['ip']] = 1;
  69. }
  70. }
  71. }
  72. $source['pv'] = $pv;
  73. $source['uv'] = count($user);
  74. }
  75. return array($source, $result);
  76. }
  77. public function get_api(){}
  78. }