!27 添加直播流

Merge pull request !27 from Chao Xing/xingchao

application/api/controller/Live.php

@@ -3,6 +3,9 @@
 namespace app\api\controller;
 
 use app\common\controller\Api;
+use think\Db;
+use think\Exception;
+use think\Log;
 
 /**
  * 直播接口
@@ -26,7 +29,7 @@ class Live extends Api
     }
 
     /**
-     * 读取产品信息
+     * 读取直播流信息
      */
     public function index()
     {
@@ -44,14 +47,56 @@ class Live extends Api
 
 //        $pagesize = $this->request->request("per_page");
 
-//        print_r($this->request->request("status"));
-//        exit();
         if ($this->request->request("status")) {
             $where = array(
                 'status' => $this->request->request("status"),
             );
         }
 
+        if ($this->request->request("username")) {
+            $username = $this->request->request("username");
+//        $username = 'qq';
+            $sql = "select b.* 
+                from fa_user as a,fa_live as b 
+                where a.id=b.user_id  and a.username = '$username'";
+
+            $list = Db::query($sql);
+            if (!empty($list)) {
+                return true;
+            } else {
+                //创建直播流
+                $sql = "select id
+                        from fa_user 
+                        where username = '$username'";
+
+                $list = Db::query($sql);
+                $user_id = $list[0]['id'];
+
+                $code = time();
+                $base_url = "rtmp://47.104.165.49:1935/live/";
+                $push_url = $base_url . $code;
+                $pull_url = $push_url;
+                $sql = "INSERT INTO fa_live(push_url,pull_url,user_id,status) VALUES ('$push_url','$pull_url','$user_id','1')";
+
+//                echo $sql;
+//                exit();
+                $rs = Db::execute($sql);
+                if ($rs === false) {
+                    echo '添加直播流失败';
+                } else {
+                    echo '添加直播流成功';
+                }
+
+                $list = array(
+                    'base_url'=>$base_url,
+                    'code'=>$code,
+                );
+
+                $result = array( "rows" => $list);
+                return json($result);
+            }
+        }
+
 
         $total = $this->model
             ->where($where)
@@ -67,7 +112,6 @@ class Live extends Api
         $result = array("total" => $total, "rows" => $list);
 
         return json($result);
-//        return ($where);
 
 
         //  }

application/api/model/User.php

@@ -0,0 +1,86 @@
+<?php
+
+namespace app\api\model;
+
+use think\Model;
+
+class User extends Model
+{
+
+    // 表名
+    protected $name = 'user';
+    // 自动写入时间戳字段
+    protected $autoWriteTimestamp = 'int';
+    // 定义时间戳字段名
+    protected $createTime = 'createtime';
+    protected $updateTime = 'updatetime';
+    // 追加属性
+    protected $append = [
+        'prevtime_text',
+        'logintime_text',
+        'jointime_text'
+    ];
+
+    protected static function init()
+    {
+        self::beforeUpdate(function ($row) {
+            $changed = $row->getChangedData();
+            //如果有修改密码
+            if (isset($changed['password']))
+            {
+                $salt = \fast\Random::alnum();
+                $row->password = \app\common\library\Auth::instance()->getEncryptPassword($changed['password'], $salt);
+                $row->salt = $salt;
+            }
+        });
+    }
+
+    public function getGenderList()
+    {
+        return ['1' => __('Male'), '0' => __('Female')];
+    }
+
+    public function getStatusList()
+    {
+        return ['normal' => __('Normal'), 'hidden' => __('Hidden')];
+    }
+
+    public function getPrevtimeTextAttr($value, $data)
+    {
+        $value = $value ? $value : $data['prevtime'];
+        return is_numeric($value) ? date("Y-m-d H:i:s", $value) : $value;
+    }
+
+    public function getLogintimeTextAttr($value, $data)
+    {
+        $value = $value ? $value : $data['logintime'];
+        return is_numeric($value) ? date("Y-m-d H:i:s", $value) : $value;
+    }
+
+    public function getJointimeTextAttr($value, $data)
+    {
+        $value = $value ? $value : $data['jointime'];
+        return is_numeric($value) ? date("Y-m-d H:i:s", $value) : $value;
+    }
+
+    protected function setPrevtimeAttr($value)
+    {
+        return $value && !is_numeric($value) ? strtotime($value) : $value;
+    }
+
+    protected function setLogintimeAttr($value)
+    {
+        return $value && !is_numeric($value) ? strtotime($value) : $value;
+    }
+
+    protected function setJointimeAttr($value)
+    {
+        return $value && !is_numeric($value) ? strtotime($value) : $value;
+    }
+
+    public function group()
+    {
+        return $this->belongsTo('UserGroup', 'group_id', 'id', [], 'LEFT')->setEagerlyType(0);
+    }
+
+}

application/api/model/UserGroup.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace app\api\model;
+
+use think\Model;
+
+class UserGroup extends Model
+{
+
+    // 表名
+    protected $name = 'user_group';
+    // 自动写入时间戳字段
+    protected $autoWriteTimestamp = 'int';
+    // 定义时间戳字段名
+    protected $createTime = 'createtime';
+    protected $updateTime = 'updatetime';
+    // 追加属性
+    protected $append = [
+        'status_text'
+    ];
+
+    public function getStatusList()
+    {
+        return ['normal' => __('Normal'), 'hidden' => __('Hidden')];
+    }
+
+    public function getStatusTextAttr($value, $data)
+    {
+        $value = $value ? $value : $data['status'];
+        $list = $this->getStatusList();
+        return isset($list[$value]) ? $list[$value] : '';
+    }
+
+}

application/api/model/UserRule.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace app\api\model;
+
+use think\Model;
+
+class UserRule extends Model
+{
+
+    // 表名
+    protected $name = 'user_rule';
+    // 自动写入时间戳字段
+    protected $autoWriteTimestamp = 'int';
+    // 定义时间戳字段名
+    protected $createTime = 'createtime';
+    protected $updateTime = 'updatetime';
+    // 追加属性
+    protected $append = [
+        'status_text'
+    ];
+
+    protected static function init()
+    {
+        self::afterInsert(function ($row) {
+            $pk = $row->getPk();
+            $row->getQuery()->where($pk, $row[$pk])->update(['weigh' => $row[$pk]]);
+        });
+    }
+
+    public function getStatusList()
+    {
+        return ['normal' => __('Normal'), 'hidden' => __('Hidden')];
+    }
+
+    public function getStatusTextAttr($value, $data)
+    {
+        $value = $value ? $value : $data['status'];
+        $list = $this->getStatusList();
+        return isset($list[$value]) ? $list[$value] : '';
+    }
+
+    public static function getTreeList($selected = [])
+    {
+        $ruleList = collection(self::where('status', 'normal')->select())->toArray();
+        $nodeList = [];
+        foreach ($ruleList as $k => $v)
+        {
+            $state = array('selected' => $v['ismenu'] ? false : in_array($v['id'], $selected));
+            $nodeList[] = array('id' => $v['id'], 'parent' => $v['pid'] ? $v['pid'] : '#', 'text' => __($v['title']), 'type' => 'menu', 'state' => $state);
+        }
+        return $nodeList;
+    }
+
+}