错误修复

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

@@ -94,7 +94,12 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
     }
 
 
-
+    public static void main(String[] args) {
+        GetPolyvAnalysisBigData getPolyvAnalysisBigData = new GetPolyvAnalysisBigData();
+        Polyv polyv = new Polyv();
+        JSONObject object = polyv.getPageViewlog("2771246", getPolyvAnalysisBigData.getDate_Str(), "200", "1");
+        System.err.println(object);
+    }
 
     /**
      * 获取频道直播观看详情数据
@@ -103,15 +108,16 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
         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();
-        out:
+
         for (String channelid : channelids) {
             ArrayList<String> sqllist = new ArrayList<>();
-            boolean islastpage;
+            boolean islastpage = false;
             int pageNumber = 1;
+
             do {
                 JSONObject object = polyv.getPageViewlog(channelid, getDate_Str(), "200", String.valueOf(pageNumber++));
                 if (object == null) {
-                    continue out;
+                    break;
                 }
                 islastpage = object.getBoolean("lastPage");
                 JSONArray contentsarray = object.getJSONArray("contents");
@@ -186,7 +192,6 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
         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();
-        out:
         for (String channelid : channelids) {
             String startdate = getDate_Str();
             Rows maxtimerows = dbConnect.runSqlQuery("select isnull(max(time),0) as ftime from tlive_usermessages where channelid='" + channelid + "' having isnull(max(time),0)>0");
@@ -201,7 +206,7 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
             do {
                 JSONObject object = polyv.getPageMessageList(channelid, startdate, getDate_Str(), "200", String.valueOf(pageNumber++));
                 if (object == null) {
-                    continue out;
+                    break;
                 }
                 JSONArray contentsarray = object.getJSONArray("contents");
                 islastpage = contentsarray.size() == 0;
@@ -274,7 +279,7 @@ public class GetPolyvAnalysisBigData extends BaseClass implements Runnable {
             ArrayList<String> sqllist = new ArrayList<>();
             JSONArray dataArray = polyv.getSessionStats(channelid);
             if (dataArray == null) {
-                return;
+                continue;
             }
             for (Object o : dataArray) {
                 JSONObject contentsObject = (JSONObject) o;