增加了onpublish和endpublish的api，监听服务端开播和关播的回调，修改数据库内容，同时修改了dockerfile，安装n…

…ode环境
qingyanjiu · Sep 29, 2016 · 8635866 · 8635866
1 parent dfd5216
commit 8635866
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 7 deletions.
diff --git a/business/LiveBusiness.js b/business/LiveBusiness.js
@@ -22,7 +22,7 @@ module.exports = {
                 callback(err, {});
             }
             if (result) {
-                ret = {"result": param.streamcode};
+                result = {"result": param.streamcode};
                 callback(err, result);
             }
         });
@@ -41,7 +41,7 @@ module.exports = {
                 callback(err, {});
             }
             if (result) {
-                ret = {"result": param.streamcode};
+                result = {"result": param.streamcode};
                 callback(err, result);
             }
         });

diff --git a/routes/Live.js b/routes/Live.js
@@ -9,7 +9,7 @@ var constants = require('../services/constants');
 
 
 //开播
-router.post('/onpublish', function (req, res, next) {
+router.get('/onpublish', function (req, res, next) {
     var streamCode = req.query.name;
     var param = {};
     param.streamCode = streamCode;
@@ -22,17 +22,18 @@ router.post('/onpublish', function (req, res, next) {
         }
         if (data) {
             if (data.result === "success")
-                res.json({result: 'success'});
+                res.writeHead(200, { "Content-Type": "text/html;charset=utf-8" });
+            res.end();
         }
     });
 });
 
 //停播
-router.post('/endpublish', function (req, res, next) {
+router.get('/endpublish', function (req, res, next) {
     var streamCode = req.query.name;
     var param = {};
     param.streamCode = streamCode;
-    liveBusiness.onpublish(param, (err, data)=> {
+    liveBusiness.endpublish(param, (err, data)=> {
         if (err) {
             console.error("LiveRouter--post--end--error");
             console.error(err);
@@ -41,7 +42,8 @@ router.post('/endpublish', function (req, res, next) {
         }
         if (data) {
             if (data.result === "success")
-                res.json({result: 'success'});
+                res.writeHead(200, { "Content-Type": "text/html;charset=utf-8" });
+            res.end();
         }
     });
 });