live接口

张宗朋
1 parent 9af6d59d
Showing 5 changed files with 183 additions and 24 deletions
.classpath
.settings/org.eclipse.wst.common.project.facet.core.xml
src/main/java/com/cnlive/mz/live/action/LiveAction.java
src/main/java/com/cnlive/socket/SocketServer.java
target/m2e-wtp/web-resources/META-INF/maven/com.cnlive.mz.live.web/cnlive_live_web/pom.properties
@@ -26,7 +26,7 @@
 	</classpathentry>
 	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7">
 		<attributes>
-			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="owner.project.facets" value="java"/>
 		</attributes>
 	</classpathentry>
 	<classpathentry kind="output" path="target/classes"/>
@@ -3,5 +3,5 @@
   <installed facet="jst.web" version="3.0"/>
   <installed facet="wst.jsdt.web" version="1.0"/>
   <installed facet="jst.jaxrs" version="1.1"/>
-  <installed facet="java" version="1.6"/>
+  <installed facet="java" version="1.7"/>
 </faceted-project>
@@ -9,11 +9,15 @@
 package com.cnlive.mz.live.action;
+import java.io.IOException;
 import java.io.UnsupportedEncodingException;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
 import org.apache.commons.httpclient.NameValuePair;
 import org.apache.commons.lang.StringUtils;
 import org.apache.log4j.Logger;
@@ -34,6 +38,7 @@ import org.smart4j.framework.util.CastUtil;
 import com.cnlive.mz.commons.Constants;
 import com.cnlive.mz.commons.net.HttpReq;
 import com.cnlive.mz.live.common.LiveUtils;
+import com.cnlive.mz.live.entity.TChannel;
 import com.cnlive.mz.live.entity.TLive;
 import com.cnlive.mz.live.entity.TRoom;
 import com.cnlive.mz.live.rest.BaseUtil;
@@ -306,6 +311,8 @@ public class LiveAction {
 					rb.setErrorCode("0");
 					rb.setErrorMessage("创建活动成功");
 					log.info("创建活动成功");
+					//通知cms直播
+					boolean success = tLiveService.startLive(tLive);
 					return rb;
 				} else {
 					Map<String, Object> map = new HashMap<String, Object>();
@@ -391,10 +398,11 @@ public class LiveAction {
 				String delsignature = BaseUtil.signature(del, streamName);
 				String expire = BaseUtil.getTimestamp();
 				System.out.println(expire + "---expire---");
-				// 断流。
+				// 直播断流。
 				addBlackList(signature, accesskey, expire, streamName);
+				//通知cms停止直播
+				tLiveService.releaseChatRoom(tLive);
 			} catch (UnsupportedEncodingException e1) {
-				// TODO Auto-generated catch block
 				e1.printStackTrace();
 			}
 			// 直播通知
@@ -494,7 +502,156 @@ public class LiveAction {
 			return rb;
 		}
 	}
-
+	
+	/**
+	 * 1.8 获取APP直播URL接口.md
+	 * 
+	 * @param params
+	 * @return
+	 */
+	@Request.Get("/live/epg/play/app")
+	public ResultBean appURL(Params params) throws IOException {
+		HttpServletResponse response = DataContext.getResponse();
+		ResultBean rb = new ResultBean();
+		String appId = params.getString("appId");
+		String activityid = params.getString("activityId");
+		Map<String, Object> map = new HashMap<String, Object>();
+		if (StringUtils.isEmpty(appId) || StringUtils.isEmpty(activityid)) {
+			map.put("location", "");
+			rb.setData(map);
+			rb.setErrorCode("500");
+			rb.setErrorMessage("启动app活动失败");
+			return rb;
+		} else {
+			TLive tLive = tLiveService.selectByParams(appId, activityid);
+			TChannel tchannel = tLiveService.selectChannel(tLive.getRelation_id());
+			if(tchannel!=null){
+				// 请求到app.......
+				redirect(response, "http://ips.cnlive.com/IPS/liveplayByAPP.action?appId="+appId+"&channelID="+tLive.getRelation_id());
+				map.put("location", "");
+				rb.setData(map);
+				rb.setErrorCode("0");
+				rb.setErrorMessage("302重定向到app");
+				return rb;
+			}else{
+				map.put("location", tLive.getLive_url());
+				rb.setData(map);
+				rb.setErrorCode("0");
+				rb.setErrorMessage("启动app活动成功");
+				return rb;
+			}
+		}
+		
+	}
+	
+	/**
+	 * 1.9 获取H5直播URL接口.md
+	 * 
+	 * @param params
+	 * @return
+	 */
+	@Request.Get("/live/epg/play/h5")
+	public ResultBean h5URL(Params params) {
+		HttpServletResponse response = DataContext.getResponse();
+		ResultBean rb = new ResultBean();
+		String appId = params.getString("appId");
+		String activityid = params.getString("activityId");
+		Map<String, Object> map = new HashMap<String, Object>();
+		if (StringUtils.isEmpty(appId) || StringUtils.isEmpty(activityid)) {
+			map.put("location", "");
+			rb.setData(map);
+			rb.setErrorCode("500");
+			rb.setErrorMessage("启动h5活动失败");
+			return rb;
+		} else {
+			TLive tLive = tLiveService.selectByParams(appId, activityid);
+			TChannel tchannel = tLiveService.selectChannel(tLive.getRelation_id());
+			if(tchannel!=null){
+				// 重定向到h5.......
+				redirect(response, "http://ips.cnlive.com/IPS/liveplayByH5?appId="+appId+"&channelID="+tLive.getRelation_id());
+				map.put("location", "");
+				rb.setData(map);
+				rb.setErrorCode("0");
+				rb.setErrorMessage("302重定向到h5");
+				return rb;
+			}else{
+				map.put("location", tLive.getLive_url());
+				rb.setData(map);
+				rb.setErrorCode("0");
+				rb.setErrorMessage("启动h5活动成功");
+				return rb;
+			}
+		}
+		
+	}
+	
+	/**
+	 * 2.0 获取SWF直播URL接口.md
+	 * 
+	 * @param params
+	 * @return
+	 */
+	@Request.Get("/live/epg/play/swf")
+	public ResultBean swfURL(Params params) {
+		HttpServletResponse response = DataContext.getResponse();
+		ResultBean rb = new ResultBean();
+		String appId = params.getString("appId");
+		String activityid = params.getString("activityId");
+		Map<String, Object> map = new HashMap<String, Object>();
+		if (StringUtils.isEmpty(appId) || StringUtils.isEmpty(activityid)) {
+			map.put("location", "");
+			rb.setData(map);
+			rb.setErrorCode("500");
+			rb.setErrorMessage("启动swf活动失败");
+			return rb;
+		} else {
+			TLive tLive = tLiveService.selectByParams(appId, activityid);
+			TChannel tchannel = tLiveService.selectChannel(tLive.getRelation_id());
+			rb.setData(map);
+			rb.setErrorCode("0");
+			if(tchannel!=null){
+				// 302重定向到swf.......
+				redirect(response, "http://ips.cnlive.com/IPS/liveplayBySWF.action?appId="+appId+"&channelID="+tLive.getRelation_id());
+				map.put("location", "");
+				rb.setErrorMessage("302重定向到swf");
+				return rb;
+			}else{
+				
+				map.put("location", tLive.getLive_url());
+				rb.setErrorMessage("启动swf活动成功");
+				return rb;
+			}
+		}
+		
+	}
+	/**
+	 * 2.1 获取推流直播播放地址.md
+	 * 
+	 * @param params
+	 * @return
+	 */
+	@Request.Get("/live/epg/play")
+	public ResultBean startLiveActivity(Params params) {
+		ResultBean rb = new ResultBean();
+		String appId = params.getString("appId");
+		String activityid = params.getString("activityId");
+		if (StringUtils.isEmpty(appId) || StringUtils.isEmpty(activityid)) {
+			Map<String, Object> map = new HashMap<String, Object>();
+			map.put("location", "");
+			rb.setData(map);
+			rb.setErrorCode("500");
+			rb.setErrorMessage("启动活动失败");
+			return rb;
+		} else {
+			TLive tLive = tLiveService.selectByParams(appId, activityid);
+				Map<String, Object> map = new HashMap<String, Object>();
+				map.put("location", tLive.getLive_url());
+				rb.setData(map);
+				rb.setErrorCode("0");
+				rb.setErrorMessage("启动活动成功");
+				return rb;
+			}
+		}
 	@Request.Post("/live/epg/error500")
 	public ResultBean error(Params params) {
 		ResultBean rb = new ResultBean();
@@ -505,23 +662,25 @@ public class LiveAction {
 		rb.setErrorMessage("失败");
 		return rb;
 	}
+	
+	public static void redirect(HttpServletResponse response, String redirectUrl) {
+        try {
+        	response.setContentType("application/mpegurl");
+    		response.setStatus(302);
+    		response.setHeader("Location", redirectUrl);
+    		response.setHeader("Connection", "close");
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+	@Request.Get("/live/epg/302")
+	public void red302() {
+		HttpServletResponse response =DataContext.getResponse();
+		redirect(response, "http://ips.cnlive.com/IPS/liveplayBySWF.action?activityId=12345");
+	}
 	public static void main(String[] args) {
-		/*
-		 * Map<String, Object> mapFiles = new HashMap<String, Object>();
-		 * mapFiles.put("app_id", null); mapFiles.put("start_time", "");
-		 * mapFiles.put("end_time",""); // TODO 活动id mapFiles.put("category",
-		 * ""); boolean flag = DataSet.insert(TLive.class, mapFiles);
-		 * System.out.println(flag);
-		 */
-		// String appId = params.getString("appId");
-		// String activityid = params.getString("activityid");
-		// String activityname = params.getString("activityname");
-		// int activitystatus = params.getInt("activitystatus");
-		// int isHorizontalScreen = params.getInt("isHorizontalScreen");
-		// String channelID = params.getString("channelID");
-		// NameValuePair nv1 = new NameValuePair("appId", "123");
-		// NameValuePair nv2 = new NameValuePair("activityid", "234");
-		NameValuePair[] nvp = new NameValuePair[6];
+	
+		/*NameValuePair[] nvp = new NameValuePair[6];
 		NameValuePair nv1 = new NameValuePair();
 		nv1.setName("appId");
 		nv1.setValue("123");
@@ -550,6 +709,6 @@ public class LiveAction {
 		System.out.println(ss);
 		String aa = HttpReq
 				.getRequestWidthResult("http://bc.cnlive.com/live/epg/startActivity?appId=123&activityId=234");
-		System.out.println(aa);
+		System.out.println(aa);*/
 	}
 }
 \ No newline at end of file
@@ -130,7 +130,7 @@ public class SocketServer {
                                 oos.flush();  
                             }  */
                     } catch (Exception e) {  
-                    	 System.out.println(System.currentTimeMillis()-lastReceiveTime);
+                    	System.out.println(System.currentTimeMillis()-lastReceiveTime);
                         e.printStackTrace();  
                         overThis();  
                     }   
 #Generated by Maven Integration for Eclipse
-#Fri Aug 12 09:21:48 CST 2016
+#Fri Aug 19 09:15:52 CST 2016
 version=0.0.1-SNAPSHOT
 groupId=com.cnlive.mz.live.web
 m2e.projectName=cnlive_live_web