直播数据获取娇艳

src/dsb/com/cnd3b/restcontroller/customer/live/live.java

@@ -102,9 +102,9 @@ public class live extends Controller {
         if (rows.isEmpty()) {
             PaoSetRemote paoSetRemote = getP2ServerSystemPaoSet("tliveapply", "siteid = '" + siteid + "' AND fissecret = 1 AND fstatus = '申请'");
             if (paoSetRemote.isEmpty()) {
-                return getErrReturnObject().setErrCode("3").setErrMsg("无直播间信息").toString();
+                return getErrReturnObject().setErrCode(3).setErrMsg("无直播间信息").toString();
             } else {
-                return getErrReturnObject().setErrCode("2").setErrMsg("直播申请中").toString();
+                return getErrReturnObject().setErrCode(2).setErrMsg("直播申请中").toString();
             }
         } else {
             return getSucReturnObject().setData(rows).toString();
@@ -158,7 +158,6 @@ public class live extends Controller {
      * @return
      */
     public String applySYLive() throws P2Exception {
-
         PaoSetRemote paoSetRemote = getP2ServerSystemPaoSet("tliveapply", "siteid = '" + siteid + "' AND fissecret = 1 AND fstatus = '申请'");
         if (paoSetRemote.isEmpty()) {
             PaoRemote paoRemote = paoSetRemote.addAtEnd();
@@ -171,7 +170,6 @@ public class live extends Controller {
             paoRemote.setValue("FNOTES", "私域直播申请", 11L);
             paoRemote.setValue("SITEID", siteid);
             paoRemote.setValue("TAGENTSID", tagentsid);
-            saveDataLog(paoRemote);
             paoSetRemote.save();
             return getSucReturnObject().setData("私域直播申请成功").toString();
         } else {

src/dsb/com/cnd3b/restcontroller/enterprise/live/live.java

@@ -282,7 +282,6 @@ public class live extends Controller {
         if (paoSetRemote.isEmpty()) {
             return getErrReturnObject().setErrMsg("未找到对应申请").toString();
         } else {
-
             String sql = "SELECT*FROM tlive WHERE categoryname='私域直播' AND tagentsid=" + tagentsid;
             Rows rows = dbConnect.runSqlQuery(sql);
             if (rows.totalRows > 0) {
@@ -300,10 +299,7 @@ public class live extends Controller {
                 content.put("categoryid", getCategoryId("私域直播"));
                 return createLive();
             }
-
-
         }
-
     }
 
 

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

@@ -34,11 +34,13 @@ 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;
         }
@@ -92,12 +94,14 @@ 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;
             }
@@ -134,6 +138,7 @@ 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();
@@ -144,6 +149,7 @@ 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;
                 }
@@ -217,6 +223,7 @@ 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();
@@ -234,6 +241,7 @@ 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;
                 }