|
|
@@ -91,48 +91,7 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
|
|
|
dbConnect.runSqlUpdate(sqllist);
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 查询频道多场次概览统计数据
|
|
|
- */
|
|
|
- public void getSessionStats() {
|
|
|
- System.err.println("getSessionStats");
|
|
|
- DBConnect dbConnect = new DBConnect();
|
|
|
- String[] channelids = dbConnect.runSqlQuery("select channelid from tlive where livestatus in('live','waiting') and convert(varchar(10),lastlivedate,120)=convert(varchar(10),getDate(),120) ").toArray("channelid");
|
|
|
- for (String channelid : channelids) {
|
|
|
- Polyv polyv = new Polyv();
|
|
|
- ArrayList<String> sqllist = new ArrayList<>();
|
|
|
- JSONArray dataArray = polyv.getSessionStats(channelid);
|
|
|
- System.err.println(dataArray);
|
|
|
- if (dataArray == null) {
|
|
|
- return;
|
|
|
- }
|
|
|
- for (Object o : dataArray) {
|
|
|
- JSONObject contentsObject = (JSONObject) o;
|
|
|
- String channelId = contentsObject.getString("channelId");
|
|
|
- String sessionId = contentsObject.getString("sessionId");
|
|
|
- String name = contentsObject.getString("name");
|
|
|
- String startTime = contentsObject.getString("startTime");
|
|
|
- long duration = contentsObject.getLong("duration");
|
|
|
- long liveUV = contentsObject.getLong("liveUV");
|
|
|
- long livePV = contentsObject.getLong("livePV");
|
|
|
- long playbackPV = contentsObject.getLong("playbackPV");
|
|
|
- long playbackUV = contentsObject.getLong("playbackUV");
|
|
|
- SQLFactory sqlFactory = new SQLFactory(this, "场次直播概览统计数据插入");
|
|
|
|
|
|
- sqlFactory.addParameter("channelid", channelId);
|
|
|
- sqlFactory.addParameter("sessionid", sessionId);
|
|
|
- sqlFactory.addParameter("name", name);
|
|
|
- sqlFactory.addParameter("starttime", startTime);
|
|
|
- sqlFactory.addParameter("duration", duration);
|
|
|
- sqlFactory.addParameter("liveuv", liveUV);
|
|
|
- sqlFactory.addParameter("livepv", livePV);
|
|
|
- sqlFactory.addParameter("playbackpv", playbackPV);
|
|
|
- sqlFactory.addParameter("playbackuv", playbackUV);
|
|
|
- sqllist.add(sqlFactory.getSQL());
|
|
|
- }
|
|
|
- dbConnect.runSqlUpdate(sqllist);
|
|
|
- }
|
|
|
- }
|
|
|
|
|
|
|
|
|
/**
|
|
|
@@ -305,4 +264,47 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
|
|
|
dbConnect.runSqlUpdate(sqllist);
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询频道多场次概览统计数据
|
|
|
+ */
|
|
|
+ public void getSessionStats() {
|
|
|
+ System.err.println("getSessionStats");
|
|
|
+ DBConnect dbConnect = new DBConnect();
|
|
|
+ String[] channelids = dbConnect.runSqlQuery("select channelid from tlive where livestatus in('live','waiting') and convert(varchar(10),lastlivedate,120)=convert(varchar(10),getDate(),120) ").toArray("channelid");
|
|
|
+ for (String channelid : channelids) {
|
|
|
+ Polyv polyv = new Polyv();
|
|
|
+ ArrayList<String> sqllist = new ArrayList<>();
|
|
|
+ JSONArray dataArray = polyv.getSessionStats(channelid);
|
|
|
+ System.err.println(dataArray);
|
|
|
+ if (dataArray == null) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ for (Object o : dataArray) {
|
|
|
+ JSONObject contentsObject = (JSONObject) o;
|
|
|
+ String channelId = contentsObject.getString("channelId");
|
|
|
+ String sessionId = contentsObject.getString("sessionId");
|
|
|
+ String name = contentsObject.getString("name");
|
|
|
+ String startTime = contentsObject.getString("startTime");
|
|
|
+ long duration = contentsObject.getLong("duration");
|
|
|
+ long liveUV = contentsObject.getLong("liveUV");
|
|
|
+ long livePV = contentsObject.getLong("livePV");
|
|
|
+ long playbackPV = contentsObject.getLong("playbackPV");
|
|
|
+ long playbackUV = contentsObject.getLong("playbackUV");
|
|
|
+ SQLFactory sqlFactory = new SQLFactory(this, "场次直播概览统计数据插入");
|
|
|
+
|
|
|
+ sqlFactory.addParameter("channelid", channelId);
|
|
|
+ sqlFactory.addParameter("sessionid", sessionId);
|
|
|
+ sqlFactory.addParameter("name", name);
|
|
|
+ sqlFactory.addParameter("starttime", startTime);
|
|
|
+ sqlFactory.addParameter("duration", duration);
|
|
|
+ sqlFactory.addParameter("liveuv", liveUV);
|
|
|
+ sqlFactory.addParameter("livepv", livePV);
|
|
|
+ sqlFactory.addParameter("playbackpv", playbackPV);
|
|
|
+ sqlFactory.addParameter("playbackuv", playbackUV);
|
|
|
+ sqllist.add(sqlFactory.getSQL());
|
|
|
+ }
|
|
|
+ dbConnect.runSqlUpdate(sqllist);
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|