直播场次列表查询错误修复

src/dsb/com/cnd3b/restcontroller/customer/live/SQL/直播场次列表查询.sql

@@ -1,6 +1,6 @@
 SELECT t1.sessionid,
        t1.description,
-       DATEADD(S, t1.starttime / 1000, '1970-01-01 08:00:00') as starttime,
+       DATEADD(S, convert(float,t1.starttime) / 1000, '1970-01-01 08:00:00') as starttime,
        t1.liveuv,
        t1.livepv,
        t1.duration

src/dsb/com/cnd3b/service/GetPolyvAnalysisBigData.java

@@ -35,13 +35,11 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
      * 获取频道直播概览统计数据表
      */
     public void getLiveData() {
-        System.err.println("getLiveData");
         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");
         Polyv polyv = new Polyv();
         ArrayList<String> sqllist = new ArrayList<>();
         JSONArray dataArray = polyv.getChannelSummary(channelids, getDate_Str());
-        System.err.println(dataArray);
         if (dataArray == null) {
             return;
         }
@@ -98,7 +96,6 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
      * 获取频道直播观看详情数据
      */
     public void getLiveviewLog() {
-        System.err.println("getLiveviewLog");
         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");
         Polyv polyv = new Polyv();
@@ -109,7 +106,6 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
             int pageNumber = 1;
             do {
                 JSONObject object = polyv.getPageViewlog(channelid, getDate_Str(), "200", String.valueOf(pageNumber++));
-                System.err.println(object);
                 if (object == null) {
                     continue out;
                 }
@@ -183,7 +179,6 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
      * 获取频道直播观众聊天记录
      */
     public void getLiveMessageList() {
-        System.err.println("getLiveMessageList");
         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");
         Polyv polyv = new Polyv();
@@ -201,7 +196,6 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
             int pageNumber = 1;
             do {
                 JSONObject object = polyv.getPageMessageList(channelid, startdate, getDate_Str(), "200", String.valueOf(pageNumber++));
-                System.err.println(object);
                 if (object == null) {
                     continue out;
                 }
@@ -269,14 +263,12 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
      * 查询频道多场次概览统计数据
      */
     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;
             }