live

张宗朋
1 parent 78a6fadf
Showing 3 changed files with 193 additions and 139 deletions
.settings/org.eclipse.wst.common.component
src/main/java/com/cnlive/mz/live/action/LiveAction.java
src/main/java/com/cnlive/mz/live/action/VideoAction.java
@@ -9,10 +9,16 @@
         <dependent-module archiveName="cnlive_live_model-0.0.1-SNAPSHOT.jar" deploy-path="/WEB-INF/lib" handle="module:/resource/cnlive_live_model/cnlive_live_model">
             <dependency-type>uses</dependency-type>
         </dependent-module>
-        <dependent-module archiveName="cnlive_ks3-1.0-SNAPSHOT.jar" deploy-path="/WEB-INF/lib" handle="module:/resource/cnlive_ks3/cnlive_ks3">
+        <dependent-module archiveName="smart-framework-4.0.1.jar" deploy-path="/WEB-INF/lib" handle="module:/resource/smart-framework/smart-framework">
             <dependency-type>uses</dependency-type>
         </dependent-module>
-        <dependent-module archiveName="smart-framework-4.0.1.jar" deploy-path="/WEB-INF/lib" handle="module:/resource/smart-framework/smart-framework">
+        <dependent-module archiveName="smart-plugin-dbcp-1.0.jar" deploy-path="/WEB-INF/lib" handle="module:/resource/smart-plugin-dbcp/smart-plugin-dbcp">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="smart-plugin-rest-1.0.jar" deploy-path="/WEB-INF/lib" handle="module:/resource/smart-plugin-rest/smart-plugin-rest">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="smart-plugin-i18n-1.0.jar" deploy-path="/WEB-INF/lib" handle="module:/resource/smart-plugin-i18n/smart-plugin-i18n">
             <dependency-type>uses</dependency-type>
         </dependent-module>
         <dependent-module archiveName="cnlive_mam_commons-0.0.1-SNAPSHOT.jar" deploy-path="/WEB-INF/lib" handle="module:/resource/cnlive_mam_commons/cnlive_mam_commons">
@@ -203,13 +203,14 @@ public class LiveAction {
 				boolean flag = tLiveService.addAcitvity(params);
 				if (flag) {
 					Map<String, Object> map = new HashMap<String, Object>();
-					map.put("location", com.cnlive.mz.live.common.Constants.KS_HOST_UP_RTMP+channelID+"?vdoid=" + activityId);
+					map.put("location",
+							com.cnlive.mz.live.common.Constants.KS_HOST_UP_RTMP + channelID + "?vdoid=" + activityId);
 					rb.setData(map);
 					rb.setErrorCode("0");
 					rb.setErrorMessage("创建活动成功");
 					log.info("创建活动成功");
-					//通知cms直播
-					boolean success = tLiveService.startLive(tLive);
+					// 通知cms直播
+					// boolean success = tLiveService.startLive(tLive);
 					return rb;
 				} else {
 					Map<String, Object> map = new HashMap<String, Object>();
@@ -242,23 +243,25 @@ public class LiveAction {
 	@Request.Get("/live/epg/startActivity")
 	public ResultBean startActivity(Params params) {
 		ResultBean rb = new ResultBean();
+		log.info(params);
 		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("启动活动失败");
+			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;
+			if (tLive == null) {
+				log.info("tLive为空......");
+				rb.setErrorCode("500");
+				rb.setErrorMessage("启动活动失败,活动对象为空");
+				return rb;
+			} else {
+				rb.setErrorCode("0");
+				rb.setErrorMessage("启动活动成功");
+				return rb;
+			}
 		}
 	}
@@ -270,38 +273,42 @@ public class LiveAction {
 	 */
 	@Request.Get("/live/epg/stopActivity")
 	public ResultBean stopActivity(Params params) {
+		log.info(params);
 		ResultBean rb = new ResultBean();
 		String appId = params.getString("appId");
 		String activityid = params.getString("activityId");
 		TLive tLive = tLiveService.selectByParams(appId, activityid);
+		Map<String, Object> map = new HashMap<String, Object>();
 		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 {
-			
-			String live_url = tLive.getLive_url();
-			int index = live_url.lastIndexOf("/");
-			String streamName = live_url.substring(index + 1);
-			System.out.println("streamName===" + streamName);
+			if (tLive == null) {
+				map.put("location", "");
+				rb.setData(map);
+				rb.setErrorCode("500");
+				rb.setErrorMessage("停止直播失败,活动对象为空");
+				return rb;
+			} else {
+				String live_url = tLive.getLive_url();
+				int index = live_url.lastIndexOf("/");
+				String streamName = live_url.substring(index + 1);
+				System.out.println("streamName===" + streamName);
 				// 直播断流。
-			    tCheckService.close(streamName, tLive.getId(), tLive.getUuid());
-				//通知cms停止直播
-				tLiveService.releaseChatRoom(tLive);
+				tCheckService.close(streamName, tLive.getId(), tLive.getUuid());
 			}
 			// 直播通知
 			// tLiveService.notify(video_uuid, -1);
-			Map<String, Object> map = new HashMap<String, Object>();
 			map.put("location", tLive.getLive_url());
 			rb.setData(map);
 			rb.setErrorCode("0");
 			rb.setErrorMessage("停止直播成功");
 			return rb;
 		}
-
+	}
 	/**
 	 * 1.6 获取直播活动列表接口.md
@@ -320,14 +327,21 @@ public class LiveAction {
 			map.put("location", "");
 			rb.setData(map);
 			rb.setErrorCode("500");
-			rb.setErrorMessage("获取活动列表失败,字段不正确");
+			rb.setErrorMessage("获取活动列表失败,参数不正确");
 			return rb;
 		} else {
 			Pager<TLive> tLive = tLiveService.getActivityPager(pageNo, pageSize, appId);
-			rb.setData(tLive);
-			rb.setErrorCode("0");
-			rb.setErrorMessage("获取活动列表成功");
-			return rb;
+			if (tLive == null) {
+				rb.setData("");
+				rb.setErrorCode("500");
+				rb.setErrorMessage("获取活动列表失败,活动对象为空");
+				return rb;
+			} else {
+				rb.setData(tLive);
+				rb.setErrorCode("0");
+				rb.setErrorMessage("获取活动列表成功");
+				return rb;
+			}
 		}
 	}
@@ -342,21 +356,28 @@ public class LiveAction {
 		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<String, Object> map = new HashMap<String, Object>();
 			map.put("location", "");
 			rb.setData(map);
 			rb.setErrorCode("500");
-			rb.setErrorMessage("获取直播回放失败");
+			rb.setErrorMessage("获取直播回放失败,参数不正确");
 			return rb;
 		} else {
 			TLive tLive = tLiveService.selectByParams(appId, activityid);
-			Map<String, Object> map = new HashMap<String, Object>();
-			map.put("location", tLive.getPlayback_url());
-			rb.setData(map);
-			rb.setErrorCode("0");
-			rb.setErrorMessage("获取直播回放成功");
-			return rb;
+			if (tLive == null) {
+				map.put("location", "");
+				rb.setData(map);
+				rb.setErrorCode("500");
+				rb.setErrorMessage("获取直播回放失败,活动对象为空");
+				return rb;
+			} else {
+				map.put("location", tLive.getPlayback_url());
+				rb.setData(map);
+				rb.setErrorCode("0");
+				rb.setErrorMessage("获取直播回放成功");
+				return rb;
+			}
 		}
 	}
@@ -367,27 +388,35 @@ public class LiveAction {
 	 */
 	@Request.Get("/live/epg/liveplayByAPP")
 	public ResultBean liveplayByAPP(Params params) {
+		log.info(params);
 		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<String, Object> map = new HashMap<String, Object>();
 			map.put("location", "");
 			rb.setData(map);
 			rb.setErrorCode("500");
-			rb.setErrorMessage("获取直播回放失败");
+			rb.setErrorMessage("获取直播回放失败,参数不正确");
 			return rb;
 		} else {
 			TLive tLive = tLiveService.selectByParams(appId, activityid);
-			Map<String, Object> map = new HashMap<String, Object>();
-			map.put("location", tLive.getPlayback_url());
-			rb.setData(map);
-			rb.setErrorCode("0");
-			rb.setErrorMessage("获取直播回放成功");
-			return rb;
+			if (tLive == null) {
+				map.put("location", "");
+				rb.setData(map);
+				rb.setErrorCode("500");
+				rb.setErrorMessage("获取直播回放失败,活动对象为空");
+				return rb;
+			} else {
+				map.put("location", tLive.getPlayback_url());
+				rb.setData(map);
+				rb.setErrorCode("0");
+				rb.setErrorMessage("获取直播回放成功");
+				return rb;
+			}
 		}
 	}
-	
+
 	/**
 	 * 1.8 获取APP直播URL接口.md
 	 * 
@@ -409,26 +438,35 @@ public class LiveAction {
 			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());
+			if (tLive == null) {
 				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活动成功");
+				rb.setErrorCode("500");
+				rb.setErrorMessage("启动app活动失败,活动对象为空");
 				return rb;
+			} else {
+				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
 	 * 
@@ -450,26 +488,35 @@ public class LiveAction {
 			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());
+			if (tLive == null) {
 				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活动成功");
+				rb.setErrorCode("500");
+				rb.setErrorMessage("启动h5活动失败,活动对象为空");
 				return rb;
+			} else {
+				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
 	 * 
@@ -491,24 +538,34 @@ public class LiveAction {
 			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());
+			if (tLive == null) {
 				map.put("location", "");
-				rb.setErrorMessage("302重定向到swf");
-				return rb;
-			}else{
-				
-				map.put("location", tLive.getLive_url());
-				rb.setErrorMessage("启动swf活动成功");
+				rb.setData(map);
+				rb.setErrorCode("500");
+				rb.setErrorMessage("启动swf活动失败,活动对象为空");
 				return rb;
+			} else {
+				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
 	 * 
@@ -529,14 +586,15 @@ public class LiveAction {
 			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;
-			}
+			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();
@@ -547,57 +605,47 @@ 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);
-        }
-    }
+		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();
+		HttpServletResponse response = DataContext.getResponse();
 		redirect(response, "http://ips.cnlive.com/IPS/liveplayBySWF.action?activityId=12345");
 	}
 	public static void main(String[] args) {
-	
-		/*NameValuePair[] nvp = new NameValuePair[6];
-		NameValuePair nv1 = new NameValuePair();
-		nv1.setName("appId");
-		nv1.setValue("123");
-		nvp[0] = nv1;
-		NameValuePair nv2 = new NameValuePair();
-		nv2.setName("activityId");
-		nv2.setValue("234e");
-		nvp[1] = nv2;
-		NameValuePair nv3 = new NameValuePair();
-		nv3.setName("activityName");
-		nv3.setValue("ee");
-		nvp[2] = nv3;
-		NameValuePair nv4 = new NameValuePair();
-		nv4.setName("activityStatus");
-		nv4.setValue("11");
-		nvp[3] = nv4;
-		NameValuePair nv5 = new NameValuePair();
-		nv5.setName("isHorizontalScreen");
-		nv5.setValue("321");
-		nvp[4] = nv5;
-		NameValuePair nv6 = new NameValuePair();
-		nv6.setName("channelId");
-		nv6.setValue("ww");
-		nvp[5] = nv6;
-		String ss = HttpReq.postRequestWidthResult("http://bc.cnlive.com/live/epg/createActivity", nvp);
-		System.out.println(ss);
-<<<<<<< HEAD
+
+		/*
+		 * NameValuePair[] nvp = new NameValuePair[6]; NameValuePair nv1 = new
+		 * NameValuePair(); nv1.setName("appId"); nv1.setValue("123"); nvp[0] =
+		 * nv1; NameValuePair nv2 = new NameValuePair();
+		 * nv2.setName("activityId"); nv2.setValue("234e"); nvp[1] = nv2;
+		 * NameValuePair nv3 = new NameValuePair(); nv3.setName("activityName");
+		 * nv3.setValue("ee"); nvp[2] = nv3; NameValuePair nv4 = new
+		 * NameValuePair(); nv4.setName("activityStatus"); nv4.setValue("11");
+		 * nvp[3] = nv4; NameValuePair nv5 = new NameValuePair();
+		 * nv5.setName("isHorizontalScreen"); nv5.setValue("321"); nvp[4] = nv5;
+		 * NameValuePair nv6 = new NameValuePair(); nv6.setName("channelId");
+		 * nv6.setValue("ww"); nvp[5] = nv6; String ss =
+		 * HttpReq.postRequestWidthResult(
+		 * "http://bc.cnlive.com/live/epg/createActivity", nvp);
+		 * System.out.println(ss); <<<<<<< HEAD String aa = HttpReq
+		 * .getRequestWidthResult(
+		 * "http://bc.cnlive.com/live/epg/startActivity?appId=123&activityId=234"
+		 * ); System.out.println(aa);
+		 */
 		String aa = HttpReq
 				.getRequestWidthResult("http://bc.cnlive.com/live/epg/startActivity?appId=123&activityId=234");
-		System.out.println(aa);*/
-		String aa = HttpReq.getRequestWidthResult("http://bc.cnlive.com/live/epg/startActivity?appId=123&activityId=234");
 		System.out.println(aa);
 	}
 }
 \ No newline at end of file
@@ -115,7 +115,7 @@ public class VideoAction {
 			} else {
 				tLive.setDirect(Integer.parseInt(direct));
 			}
-			tLive.setLive_url(Constants.KS_HOST_RTMP + tLive.getT_user_id() + "_" + uuid);
+			tLive.setLive_url(Constants.KS_HOST_RTMP + tLive.getT_user_id() );
 			success = tLiveService.startLive(tLive);
 		}
 		data.put("video_uuid", uuid);