抖小IAA数据回补

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceReportRetryJob.java

@@ -162,6 +162,23 @@ public class BytedanceReportRetryJob {
             log.info("常读重试列表为空");
         }
 
+        List<JSONObject> maEcpmRetryJob = miniAppService.getMaEcpmRetryJob();
+        if (!Check.isNull(maEcpmRetryJob)) {
+            for (int i = 0; i < maEcpmRetryJob.size(); i++) {
+                JSONObject jsonObject = maEcpmRetryJob.get(i);
+                Long id = jsonObject.getLong("id");
+                String startDate = jsonObject.getString("startDate");
+                String endDate = jsonObject.getString("endDate");
+                String dataDimension = jsonObject.getString("dataDimension");
+                Integer isSend = jsonObject.getInteger("isSend");
+                if (dataDimension != null && dataDimension.startsWith("ma_ecpm:")) {
+                    String appId = dataDimension.split(":")[1];
+                    miniAppService.getMaEcpm(startDate, endDate, appId, 1, id, isSend);
+                }
+            }
+        } else {
+            log.info("抖小IAA重试列表为空");
+        }
 
     }