live

张宗朋
1 parent 1e188536
Showing 4 changed files with 77 additions and 40 deletions
src/main/java/com/cnlive/mz/live/action/LiveAction.java
src/main/java/com/cnlive/mz/live/rest/BaseUtil.java
src/main/webapp/static/assets/cnlive/js/check.js
src/main/webapp/static/assets/cnlive/js/live.js
@@ -30,6 +30,7 @@ import com.cnlive.mz.live.common.LiveUtils;
 import com.cnlive.mz.live.entity.TLive;
 import com.cnlive.mz.live.entity.TRoom;
 import com.cnlive.mz.live.rest.BaseUtil;
+import com.cnlive.mz.live.service.TCheckService;
 import com.cnlive.mz.live.service.TLiveService;
 import com.cnlive.mz.live.service.TRoomService;
  
@@ -47,7 +48,8 @@ public class LiveAction {
 	private TLiveService tLiveService;
 	@Inject
 	private TRoomService tRoomService;
-
+	@Inject
+	private TCheckService tCheckService;
 	@Request.Get("/live/preload")
 	public View preload() {
 		int user_id = CastUtil.castInt(DataContext.getRequest().getSession().getAttribute(LiveUtils.SESSION_KEY_ID));
@@ -114,11 +116,33 @@ public class LiveAction {
 	}
  
 	// 切断
-	@Request.Get("/check/cut/{id}")
-	public Result cut(int id) {
-		return new Result(true);
+	@Request.Post("/check/cut/{id}")
+	public Result cut(int id,Params params) throws UnsupportedEncodingException {
+		String live_url = params.getString("live_url");
+		if(live_url.isEmpty()){
+			return null;
+		}else{
+		int index = live_url.lastIndexOf("live");
+		String streamName = live_url.substring(index+6);
+		System.out.println("streamName==="+streamName);
+		String accesskey = BaseUtil.getAccessKey();
+		accesskey = java.net.URLEncoder.encode(accesskey,"utf-8");
+		String signature = BaseUtil.signature(streamName);
+		String del = "del";
+		String delsignature = BaseUtil.signature(del,streamName);
+		String expire = BaseUtil.getTimestamp();
+		System.out.println(expire+"---expire---");
+		//断流。
+		try {
+			addBlackList(signature,accesskey,expire,streamName);
+			delBlackList(delsignature,accesskey,expire,streamName);
+		} catch (UnsupportedEncodingException e) {
+			e.printStackTrace();
+		}
+		boolean flag = tCheckService.closeLive(id);
+		return new Result(flag);
+	}
 	}
-
 	// 通过审核
 	@Request.Get("/check/pass/{id}")
 	public Result pass(int id) {
@@ -156,19 +180,12 @@ public class LiveAction {
 	 * @return
 	 * @throws UnsupportedEncodingException
 	 */
-	public String addBlackList(String signature, String accesskey, String expire, String streamName)
-			throws UnsupportedEncodingException {
-		String url = "http://cnlive.dashboard.ks-cdn.com/blacklist?signature=" + signature + "&accesskey=" + accesskey
-				+ "&expire=" + expire + "&method=add&app=live&name=" + streamName;
+	public String addBlackList(String signature, String accesskey, String expire,String streamName) throws UnsupportedEncodingException {
+		String url = "http://cnlive.dashboard.ks-cdn.com/blacklist?signature="+signature+"&accesskey="+accesskey+"&expire="+expire+"&app=live&method=add&name=" + streamName; 
 		System.out.println(url);
 		String jsonArrStr = HttpReq.getRequestWidthResult(url);
 		int status = HttpReq.getRequest(url);
-		System.out.println("............" + status);
-		System.out.println("............" + jsonArrStr);
-		/*
-		 * Map map = JsonUtil.getMapFromJsonObjStr(jsonArrStr); String
-		 * chatRoomid = (String) map.get("Content-Length");
-		 */
+		System.out.println(status+"......and......"+jsonArrStr);
 		return jsonArrStr;
 	}
  
@@ -182,16 +199,12 @@ public class LiveAction {
 	 * @return
 	 * @throws UnsupportedEncodingException
 	 */
-	public Object delBlackList(String signature, String accesskey, String expire, String streamName)
-			throws UnsupportedEncodingException {
-		String url = "http://cnlive.uplive.ks-cdn.com/blacklist?signature=" + signature + "&accesskey=" + accesskey
-				+ "&expire=" + expire + "&method=del&app=live&name=" + streamName;
+	public Object delBlackList(String signature, String accesskey, String expire,String streamName) throws UnsupportedEncodingException {
+		String url = "http://cnlive.dashboard.ks-cdn.com/blacklist?signature="+signature+"&accesskey="+accesskey+"&expire="+expire+"&app=live&method=del&name=" + streamName;
+		System.out.println("..url.."+url);
 		String jsonArrStr = HttpReq.getRequestWidthResult(url);
-		System.out.println();
-		/*
-		 * Map map = JsonUtil.getMapFromJsonObjStr(jsonArrStr); String
-		 * chatRoomid = (String) map.get("Content-Length");
-		 */
+		System.out.println("..jsonArrStr.."+jsonArrStr);
 		return jsonArrStr;
+
 	}
 }
 \ No newline at end of file
@@ -114,7 +114,6 @@ public class BaseUtil {
 	public static String signature(String streamName) throws UnsupportedEncodingException {
  
 		String method = "GET";
-
 		String expire = BaseUtil.getTimestamp();
 		String app = "live";
 		String methodadd = "add";
@@ -131,17 +130,6 @@ public class BaseUtil {
 		String signature = HMACSha1(stringToSign, SECRET_KEY);
 		System.out.println( "---signature---"+signature );
 		signature = java.net.URLEncoder.encode(signature, "utf-8");
-
-		String Expire = String.valueOf(BaseUtil.getTimestamp()).substring(0, 10);
-		  System.out.println(Expire+"---expire----");
-		String Resource = "app=live&method=add&nonce=cnlive&public=0&vdoid=12345&stream="+streamName;
-	    Resource = java.net.URLEncoder.encode(Resource,"utf-8"); 
-		String stringToSign = method + "\n" + Expire + "\n" + Resource;
-		// 2.计算 HMAC-SHA1
-		String signature = HMACSha1(stringToSign, AK_SECRET);
-		System.out.println(signature+"------");
-		signature =java.net.URLEncoder.encode(signature,"utf-8");
-
 		return signature;
 	}
 	public static String signature(String methodNname,String streamName) throws UnsupportedEncodingException {
@@ -165,8 +153,6 @@ public class BaseUtil {
 		signature = java.net.URLEncoder.encode(signature, "utf-8");
 		return signature;
 	}
-	 
-	public static String getUUid() {
  
 	public static String UUid() {
  
@@ -25,6 +25,24 @@ function to_pass(id) {
 		}
 	});
 }
+//断流处理
+//function play_close(id,live_url){
+//	$.ajax({
+//		url : '../../check/cut/' + id,
+//		type : 'post',
+//		datatype : "json",
+//		async : true,
+//		data:{"live_url":live_url},
+//		error : function() {
+//			alert('关闭时发生错误!');
+//		},
+//		success : function(data) {
+//			location.href = '../../check/list/1';
+//			alert("关闭成功");
+//		}
+//	});
+//}
+//change
  
  
  
 \ No newline at end of file
@@ -435,5 +435,25 @@ function  do_publishreview(id){
 		}
 	});
 }
-
-
+//断流处理
+function play_close(id,live_url){
+	alert(111);
+	$.ajax({
+		url : '../../check/cut/' + id,
+		type : 'post',
+		datatype : "json",
+		async : true,
+		data:{"live_url":live_url},
+		error : function() {
+			alert('关闭时发生错误!');
+		},
+		success : function(data) {
+			location.href = '../../check/list/1';
+			alert("关闭成功");
+		}
+	});
+}
+/*function changePlay(id){
+	alert(111);
+	alert(id);
+}*/