|
@@ -9,12 +9,13 @@ class Manage
|
|
|
public function getStream_api()
|
|
|
{
|
|
|
$handle = new Handle();
|
|
|
- $info = Dever::db('live/info')->state();
|
|
|
+ $info = Dever::db('live/active')->state();
|
|
|
foreach ($info as $k => $v) {
|
|
|
- $data = $handle->method($v)->gets();
|
|
|
+ $live = Dever::db('live/info')->one($v['live_id']);
|
|
|
+ $data = $handle->method($live)->gets();
|
|
|
if (isset($data['keys']) && $data['keys']) {
|
|
|
foreach ($data['keys'] as $k1 => $v1) {
|
|
|
- $this->insertStream($v1);
|
|
|
+ $this->insertStream($v1, $live['id'], $v['id']);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -22,13 +23,15 @@ class Manage
|
|
|
return 'yes';
|
|
|
}
|
|
|
|
|
|
- private function insertStream($name)
|
|
|
+ private function insertStream($name, $live_id, $active_id)
|
|
|
{
|
|
|
$data['key'] = $name;
|
|
|
$info = Dever::db('live/stream')->one($data);
|
|
|
|
|
|
if (!$info) {
|
|
|
$data['name'] = $name;
|
|
|
+ $data['active_id'] = $active_id;
|
|
|
+ $data['live_id'] = $live_id;
|
|
|
$id = Dever::db('live/stream')->insert($data);
|
|
|
} else {
|
|
|
$id = $info['id'];
|