Jelajahi Sumber

代理商 数据

zhaoxian 1 tahun lalu
induk
melakukan
5950703cd3

+ 8 - 8
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/controller/BytedanceController.java

@@ -178,19 +178,19 @@ public class BytedanceController {
     public void getReports() {
         List<JSONObject> tokens = tokenService.getAgentTokens();
         //获取两个时间的每一天
-        List<String> perDay = DateUtils.getPerDay("2023-12-01", "2023-12-26");
+        List<String> perDay = DateUtils.getPerDay("2024-06-24", "2024-06-24");
         for (String date : perDay) {
             for (JSONObject obj : tokens) {
                 OauthToken oauthToken = new OauthToken();
                 oauthToken.setAccessToken(obj.getString("access_token"));
-                oauthToken.setAccountId(obj.getLong("agent_id"));
-                dailyExecutorService.submit(
-                        new Runnable() {
-                            @Override
-                            public void run() {
+                oauthToken.setAccountId(73970348172L);
+//                dailyExecutorService.submit(
+//                        new Runnable() {
+//                            @Override
+//                            public void run() {
                                 advertiserDataService.getAgentReport(oauthToken, date, date);
-                            }
-                        });
+//                            }
+//                        });
             }
         }
     }

+ 2 - 0
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/mapper/xml/OauthTokenMapper.xml

@@ -32,6 +32,8 @@
     <select id="getAgentTokens" resultType="com.alibaba.fastjson.JSONObject">
         SELECT access_token
         from `jeecg-boot`.ctop_oauth_token
+        WHERE media_id =1
+          AND update_time > DATE_FORMAT(now(),'%Y%m%d')
     </select>
 
 </mapper>

+ 9 - 6
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/ByteDanceAdvertiserDataServiceImpl.java

@@ -513,7 +513,7 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
 
         List<Object> advertiserAccountList = redisUtil.getList("POSITION_ADVERTISER" + conditions.getStartDate(), null);
 
-        log.info("开始获取广告主账户报表,账户id:{}--时间---{},page:{}", token.getAccountId(), conditions.getStartDate(), page);
+        log.info("(分版位)开始获取广告主账户报表,账户id:{}--时间---{},page:{}", token.getAccountId(), conditions.getStartDate(), page);
         conditions.setPage(page);
         SerializeConfig config = new SerializeConfig();
         config.propertyNamingStrategy = PropertyNamingStrategy.SnakeCase;
@@ -521,14 +521,14 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
         JSONObject getObject = getPositionAdvertiserStat(token, jsonObject);
 //        System.out.println("返回结果:" + getObject);
         if (null == getObject) {
-            XxlJobHelper.log("头条广告主数据获取异常");
-            log.error("头条广告主数据获取信息为空==》accountId:{}", token.getAccountId());
+            XxlJobHelper.log("头条广告主数据获取异常(分版位)");
+            log.error("头条广告主数据获取信息为空(分版位)==》accountId:{}", token.getAccountId());
             return;
         }
         Integer code = getObject.getInteger("code");
         String message = getObject.getString("message");
         if (null == code || code != 0) {
-            log.error("头条广告主数据获取异常:{}---code--{}", message, code);
+            log.error("头条广告主数据获取异常(分版位):{}---code--{}", message, code);
 
             //请求过于频繁
             if (40100 == code) {
@@ -592,7 +592,7 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
                 bytedanceAdvertiserReportDailyMapper.insertPosition(dailyList);
             }
         } catch (Exception e) {
-            log.info("获取广告主数据错误:{}", e.toString());
+            log.info("获取广告主数据错误(分版位):{}", e.toString());
         }
         page++;
         int totalPage =
@@ -688,6 +688,9 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
                 e.printStackTrace();
                 log.info("获取代理商数据错误:{}", e.toString());
             }
+        }else{
+            log.error("获取代理商获取失败,结果:{}",getObject.getString("message"));
+            return;
         }
         page++;
         int totalPage =
@@ -730,7 +733,7 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
 //            data_topics_list.add("QUERY_DATA");//搜索词数据、
 //            data_topics_list.add("BIDWORD_DATA");//关键词数据
 //            data_topics_list.add("MATERIAL_DATA");//素材数据、
-            data_topics_list.add("PRODUCT_DATA");//产品数据、
+//            data_topics_list.add("PRODUCT_DATA");//产品数据、
 //            data_topics_list.add("ONE_KEY_BOOST_DATA");//一键起量(巨量广告升级版)
             String data_topics = mapper.writeValueAsString(data_topics_list);
             param.put("data_topics", data_topics);