Handle.php 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110
  1. <?php
  2. namespace Live\Lib;
  3. use Dever;
  4. class Handle
  5. {
  6. public function method($config)
  7. {
  8. if ($config['type'] == 1) {
  9. $method = new Qiniu($config);
  10. }
  11. return $method;
  12. }
  13. # 启动
  14. public function start($id)
  15. {
  16. $info = Dever::db('live/stream')->one($id);
  17. $config = Dever::db('live/info')->one($info['live_id']);
  18. $method = $this->method($config);
  19. $stream = $method->start($info['key']);
  20. }
  21. # 禁播
  22. public function stop($id)
  23. {
  24. $info = Dever::db('live/stream')->one($id);
  25. $config = Dever::db('live/info')->one($info['live_id']);
  26. $method = $this->method($config);
  27. $stream = $method->stop($info['key']);
  28. }
  29. # 保存
  30. public function save($id)
  31. {
  32. $info = Dever::db('live/stream')->one($id);
  33. $config = Dever::db('live/info')->one($info['live_id']);
  34. $method = $this->method($config);
  35. return $method->save($info['key']);
  36. }
  37. # 初始化流
  38. public function init($id, $name = '')
  39. {
  40. $info = Dever::db('live/stream')->one($id);
  41. if ($info['url_rtmp']) {
  42. return;
  43. }
  44. if ($name) {
  45. $info['key'] = $name;
  46. }
  47. return $this->get($info);
  48. }
  49. # 获取流信息 定时跑
  50. public function get($info)
  51. {
  52. if (!is_array($info)) {
  53. $info = Dever::db('live/stream')->one($info);
  54. }
  55. $config = Dever::db('live/info')->one($info['live_id']);
  56. $method = $this->method($config);
  57. $rtmp = $method->getRtmp($info['key'], $info['times'] * 3600);
  58. $url = $method->getPlay($info['key']);
  59. $stream = $method->getInfo($info['key']);
  60. $live = array();
  61. $hitory = array();
  62. try {
  63. $live = $method->getLiveStatus($info['key']);
  64. $hitory = $method->history($info['key']);
  65. } catch (\Exception $e) {
  66. $live = array();
  67. $hitory = array();
  68. }
  69. $data['where_id'] = $info['id'];
  70. $data['live'] = $rtmp;
  71. $data['url_rtmp'] = $url['rtmp'];
  72. $data['url_hls'] = $url['hls'];
  73. $data['url_hdl'] = $url['hdl'];
  74. $data['url_pic'] = $url['pic'];
  75. $live = Dever::json_decode($info['info']);
  76. $live['info'] = $stream;
  77. $live['live'] = $live;
  78. $live['hitory'] = $history;
  79. if ($live) {
  80. $data['status'] = 2;
  81. } else {
  82. $data['status'] = 1;
  83. }
  84. $data['info'] = Dever::json_encode($live);
  85. Dever::db('live/stream')->update($data);
  86. return $data;
  87. }
  88. }