Browse Source

快手-计划,组-(昨天~当天)数据拉取

yangzian 3 years ago
parent
commit
24b840b3e9

+ 5 - 0
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/data/entity/KuaishouAdUnitList.java

@@ -257,6 +257,9 @@ public class KuaishouAdUnitList {
     @SerializedName("intention_target")
     @SerializedName("intention_target")
     private String entionTarget;
     private String entionTarget;
 
 
+    private String createTime;
+
+
 
 
 
 
     public static KuaishouAdUnitList getAdUnitListInfo(JSONObject unitDetail){
     public static KuaishouAdUnitList getAdUnitListInfo(JSONObject unitDetail){
@@ -413,6 +416,8 @@ public class KuaishouAdUnitList {
         adUnit.setProductImage(!unitDetail.containsKey("product_image") ? "" : unitDetail.getString("product_image"));
         adUnit.setProductImage(!unitDetail.containsKey("product_image") ? "" : unitDetail.getString("product_image"));
         //' 行为意向-系统优选
         //' 行为意向-系统优选
         adUnit.setEntionTarget(!unitDetail.containsKey("intention_target") ? "" : unitDetail.getString("intention_target"));
         adUnit.setEntionTarget(!unitDetail.containsKey("intention_target") ? "" : unitDetail.getString("intention_target"));
+        adUnit.setCreateTime(!unitDetail.containsKey("create_time") ? "" : unitDetail.getString("create_time"));
+
 
 
         return adUnit;
         return adUnit;
     }
     }

+ 4 - 2
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/data/mapper/xml/AdUnitReportMapper.xml

@@ -80,7 +80,8 @@
        `product_name`,
        `product_name`,
        `product_price`,
        `product_price`,
        `product_image`,
        `product_image`,
-       `ention_target`
+       `ention_target`,
+       `create_time`
        )
        )
        values
        values
        <foreach collection="addList" item="add" separator=",">
        <foreach collection="addList" item="add" separator=",">
@@ -160,7 +161,8 @@
            #{add.productName},
            #{add.productName},
            #{add.productPrice},
            #{add.productPrice},
            #{add.productImage},
            #{add.productImage},
-           #{add.entionTarget}
+           #{add.entionTarget},
+           #{add.createTime}
            )
            )
        </foreach>
        </foreach>
    </insert>
    </insert>

+ 4 - 0
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/data/service/impl/AdUnitReportServiceImpl.java

@@ -72,6 +72,8 @@ public class AdUnitReportServiceImpl implements IAdUnitReportService {
 
 
       Map<String, Object> param = new HashMap<>();
       Map<String, Object> param = new HashMap<>();
       param.put("advertiser_id", advertiserId);
       param.put("advertiser_id", advertiserId);
+      param.put("start_date", startDate);
+      param.put("end_date", endDate);
       param.put("page_size", page_size);
       param.put("page_size", page_size);
       param.put("page", page);
       param.put("page", page);
 
 
@@ -140,6 +142,8 @@ public class AdUnitReportServiceImpl implements IAdUnitReportService {
 
 
     JSONObject param = new JSONObject();
     JSONObject param = new JSONObject();
     param.put("advertiser_id", advertiserId);
     param.put("advertiser_id", advertiserId);
+    param.put("start_date", startDate);
+    param.put("end_date", endDate);
     param.put("page_size", 500);
     param.put("page_size", 500);
     param.put("page", page);
     param.put("page", page);
 
 

+ 6 - 4
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/AdUnitReportJob.java

@@ -54,13 +54,14 @@ public class AdUnitReportJob {
     }
     }
 
 
     // 前一天 时间
     // 前一天 时间
-    String date = DateUtils.getAnotherDay("yyyy-MM-dd", DateUtils.getNowDate("yyyy-MM-dd"), -1);
+    String startTime = DateUtils.getNowDate("yyyy-MM-dd");
+    String endTime = DateUtils.getAnotherDay("yyyy-MM-dd", DateUtils.getNowDate("yyyy-MM-dd"), -1);
     dailyExecutorService.submit(
     dailyExecutorService.submit(
         new Runnable() {
         new Runnable() {
           @Override
           @Override
           public void run() {
           public void run() {
             try {
             try {
-              adUnitReportService.getAdUnitReport(Long.valueOf(param),token, date, date, 1);
+              adUnitReportService.getAdUnitReport(Long.valueOf(param),token, startTime, endTime, 1);
             }catch (Exception e){
             }catch (Exception e){
               log.info(String.valueOf(e));;
               log.info(String.valueOf(e));;
             }
             }
@@ -91,13 +92,14 @@ public class AdUnitReportJob {
     }
     }
 
 
     // 前一天 时间
     // 前一天 时间
-    String date = DateUtils.getAnotherDay("yyyy-MM-dd", DateUtils.getNowDate("yyyy-MM-dd"), -1);
+    String startTime = DateUtils.getNowDate("yyyy-MM-dd");
+    String endTime = DateUtils.getAnotherDay("yyyy-MM-dd", DateUtils.getNowDate("yyyy-MM-dd"), -1);
     dailyExecutorService.submit(
     dailyExecutorService.submit(
             new Runnable() {
             new Runnable() {
               @Override
               @Override
               public void run() {
               public void run() {
                 try {
                 try {
-                  adUnitReportService.getAdPlanReport(Long.valueOf(param),token, date, date, 1);
+                  adUnitReportService.getAdPlanReport(Long.valueOf(param),token, startTime, endTime, 1);
                 }catch (Exception e){
                 }catch (Exception e){
                   log.info(String.valueOf(e));;
                   log.info(String.valueOf(e));;
                 }
                 }