Kaynağa Gözat

promotion project增加字段重试

hpk 1 yıl önce
ebeveyn
işleme
7f4c00908b

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

@@ -22,6 +22,7 @@
         ) t1
         LEFT JOIN tidb.deepthink.bytedance_advertiser_list t2 ON t1.advertiser_id = t2.advertiser_id
         LEFT JOIN tidb.deepthink.bytedance_auth_list t3 ON t2.admin_advertiser_id = t3.admin_advertiser_id
+        order by 1
     </select>
 
     <insert id="replaceProductReportDailies">

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

@@ -131,12 +131,12 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
                             log.info("---账户({})广告更新成功", advertiserId);
                     }*/
                 } else {
-                    //40100请求超频
-                    if (40100 == code && count <= 5) {
+                    //40100请求超频 (40100 == code || 40110 == code || 40130 == code) &&
+                    if (count <= 5) {
                         Thread.sleep(800);
                         getPromotionListVo(advertiserId, ids, date, page, count + 1, errorId, isLog);
                     } else {
-                        insertErrorLog(isLog, advertiserId, "-", "-", "promotion_list", null);
+                        insertErrorLog(isLog, advertiserId, "-", "-", "promotion_list", results);
                         log.error("获取广告列表失败(url:{}),入参:{}\n结果:{}", url, JSONObject.toJSONString(params), obj);
                     }
                     return;
@@ -227,12 +227,12 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
                             log.info("---账户({})项目信息更新成功", advertiserId);
                     }
                 } else {
-                    //40100请求超频
-                    if (40100 == code && count <= 5) {
+                    //40100请求超频 (40100 == code || 40110 == code || 40130 == code) &&
+                    if (count <= 5) {
                         Thread.sleep(800);
                         getProjectListVo(advertiserId, ids, type, date, page, count + 1, errorId, isLog);
                     } else {
-                        insertErrorLog(isLog, advertiserId, "-", "-", "project_list", null);
+                        insertErrorLog(isLog, advertiserId, "-", "-", "project_list", results);
                         log.error("获取项目列表失败(url:{}),入参:{}\n结果:{}", url, JSONObject.toJSONString(params), obj);
                     }
                     return;