yumeng 11 mesiacov pred
rodič
commit
4809c096a6

+ 36 - 7
job-adq/src/main/java/cn/com/ctop/job/adq/controller/AdqController.java

@@ -47,17 +47,46 @@ public class AdqController {
     @Autowired
     private IAppBanWarnService appBanWarnService;
 
+
+
+    @GetMapping("/getReport")
+    public JSONObject getReport() {
+        List<JSONObject> dataJson = adqReportService.getAccountListByDate(20250425, 20250630);
+        if (!Check.isNull(dataJson)) {
+            for (int i = 0; i < dataJson.size(); i++) {
+                JSONObject jsonObject = dataJson.get(i);
+
+                Long advertiserId = jsonObject.getLong("advertiserId");
+                String accessToken = jsonObject.getString("accessToken");
+                dailyExecutorService.submit(new Runnable() {
+                    @Override
+                    public void run() {
+                        adqReportService.getAdqCreativeDaily(advertiserId, accessToken, "2025-04-25", "2025-06-30", 1, 1);
+                        accountReportService.getAdqAccountDaily(advertiserId, accessToken, "2025-04-25", "2025-06-30", 1, 1);
+                    }
+                });
+
+
+            }
+
+        }
+
+        return null;
+
+    }
+
+
     @GetMapping("/testCreativeHour")
     public JSONObject testRefreshToken(Long advertiserId, String accessToken, String date) {
 
-            long currentTimeMillis = System.currentTimeMillis();
-            // 转换为秒级时间戳
-            long currentTimeSeconds = currentTimeMillis / 1000;
-            // 计算10分钟之前的时间戳(秒级)
-            long tenMinutesAgoSeconds = currentTimeSeconds - 600; // 10分钟前的时间戳(秒级)
+        long currentTimeMillis = System.currentTimeMillis();
+        // 转换为秒级时间戳
+        long currentTimeSeconds = currentTimeMillis / 1000;
+        // 计算10分钟之前的时间戳(秒级)
+        long tenMinutesAgoSeconds = currentTimeSeconds - 600; // 10分钟前的时间戳(秒级)
         System.err.println(tenMinutesAgoSeconds);
-            appBanWarnService.appBanWarnJob(tenMinutesAgoSeconds);
-            return null;
+        appBanWarnService.appBanWarnJob(tenMinutesAgoSeconds);
+        return null;
 
     }
 

+ 2 - 0
job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/AdqErrorLogMapper.java

@@ -10,4 +10,6 @@ public interface AdqErrorLogMapper {
     void replaceErrorInfo(AdqErrorLog errorInfo);
     void deleteInfoByErrorId(@Param("errorId") Long errorId);
     List<JSONObject> getErrorLogs();
+
+    List<JSONObject> getAccountListByDate(@Param("startDate") Integer startDate, @Param("endDate") Integer endDate);
 }

+ 11 - 0
job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/xml/AdqErrorLogMapper.xml

@@ -34,5 +34,16 @@
                  LEFT JOIN deepthink.adq_advertiser_list t2 ON t1.advertiser_id = t2.advertiser_id
                  LEFT JOIN deepthink.adq_auth_list t3 ON t2.admin_advertiser_id = t3.admin_advertiser_id
     </select>
+    <select id="getAccountListByDate" resultType="com.alibaba.fastjson.JSONObject">
+        select t1.advertiser_id as 'advertiserId', t3.access_token as 'accessToken'
+        from media_api.adq_advertiser_report_daily t1
+                 left join deepthink.adq_advertiser_list t2
+                           on t1.advertiser_id = t2.advertiser_id
+                 left join deepthink.adq_auth_list t3
+                           on t2.admin_advertiser_id = t3.admin_advertiser_id
+        where t1.stat_time_day >= 20250425
+          and t1.cost > 0
+        group by t1.advertiser_id
+    </select>
 
 </mapper>

+ 2 - 0
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/IAdqCreativeReportService.java

@@ -12,4 +12,6 @@ public interface IAdqCreativeReportService {
     void getAdqCreativeDaily(Long advertiserId, String accessToken, String date, String date1, Integer page,Integer isLog);
 
     List<JSONObject> getErrorLogs();
+
+    List<JSONObject> getAccountListByDate(Integer startDate, Integer endDate);
 }

+ 2 - 2
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqAccountReportServiceImpl.java

@@ -100,7 +100,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
             if (hourList.size() >= 1000) {
                 getAdqAccountHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
             } else {
-                log.error("请求账户时报完成,account_id:{},日期:{}", advertiserId, startDate);
+                log.info("请求账户时报完成,account_id:{},日期:{}", advertiserId, startDate);
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -175,7 +175,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
             if (dailyList.size() >= 1000) {
                 getAdqAccountHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
             } else {
-                log.error("请求账户日报完成,account_id:{},日期:{}", advertiserId, startDate);
+                log.info("请求账户日报完成,account_id:{},开始日期:{},开始日期:{}", advertiserId, startDate, endDate);
             }
         } catch (Exception e) {
             e.printStackTrace();

+ 8 - 6
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqCreativeCreativeReportServiceImpl.java

@@ -17,10 +17,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.time.Instant;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 @Service
 @Slf4j
@@ -58,7 +55,7 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
             paramsMap.put("fields", fieldsList);
             List<AdqCreativeReportHour> hourList = new ArrayList<>();
             String s = HttpUtils.httpGet("https://api.e.qq.com/v3.0/hourly_reports/get", paramsMap, null);
-          //  System.err.println(s);
+            //  System.err.println(s);
             JSONObject jsonObject = JSONObject.parseObject(s);
             if (!Check.isNull(jsonObject)) {
                 Integer code = jsonObject.getInteger("code");
@@ -187,7 +184,7 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
             if (dailies.size() >= 1000) {
                 getAdqCreativeDaily(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
             } else {
-                log.error("请求创意日报完成,account_id:{},日期:{}", advertiserId, startDate);
+                log.info("请求创意日报完成,account_id:{},开始日期:{},结束日期:{}", advertiserId, startDate, endDate);
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -198,4 +195,9 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
     public List<JSONObject> getErrorLogs() {
         return adqErrorLogMapper.getErrorLogs();
     }
+
+    @Override
+    public List<JSONObject> getAccountListByDate(Integer startDate, Integer endDate) {
+        return adqErrorLogMapper.getAccountListByDate(startDate, endDate);
+    }
 }

+ 30 - 0
job-adq/src/main/java/cn/com/ctop/job/adq/handler/AdqRetryReportJob.java

@@ -9,6 +9,7 @@ import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.GetMapping;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -187,4 +188,33 @@ public class AdqRetryReportJob {
     }
 
 
+
+
+    /*@XxlJob("getLtv3Data")
+    public JSONObject getReport() {
+        List<JSONObject> dataJson = adqReportService.getAccountListByDate(20250425, 20250630);
+        if (!Check.isNull(dataJson)) {
+            for (int i = 0; i < dataJson.size(); i++) {
+                JSONObject jsonObject = dataJson.get(i);
+
+                Long advertiserId = jsonObject.getLong("advertiserId");
+                String accessToken = jsonObject.getString("accessToken");
+               //  dailyExecutorService.submit(new Runnable() {
+                    @Override
+                    public void run() {
+                        adqReportService.getAdqCreativeDaily(advertiserId, accessToken, "2025-04-25", "2025-06-30", 1, 1);
+                        accountReportService.getAdqAccountDaily(advertiserId, accessToken, "2025-04-25", "2025-06-30", 1, 1);
+                    }
+                });
+
+
+            }
+
+        }
+
+        return null;
+
+    }*/
+
+
 }