瀏覽代碼

账户维度-盯盘日、时数据清洗

zhaoxian 4 年之前
父節點
當前提交
de69e2fb60
共有 15 個文件被更改,包括 767 次插入191 次删除
  1. 29 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAccountReportLoadEtlJob.java
  2. 30 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyAccountReportLoadEtlJob.java
  3. 193 175
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/entity/EtlKuaishouReportAccountDaily.java
  4. 183 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/entity/EtlKuaishouReportAccountHourly.java
  5. 1 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/EtlKuaishouReportAccountDailyMapper.java
  6. 20 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/EtlKuaishouReportAccountHourlyMapper.java
  7. 3 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/KuaishouReportHourlyAccountMapper.java
  8. 75 1
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/xml/EtlKuaishouReportAccountDailyMapper.xml
  9. 82 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/xml/EtlKuaishouReportAccountHourlyMapper.xml
  10. 41 3
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/xml/KuaishouReportDailyAccountMapper.xml
  11. 46 6
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/xml/KuaishouReportHourlyAccountMapper.xml
  12. 3 1
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/IEtlKuaishouReportAccountDailyService.java
  13. 17 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/IEtlKuaishouReportAccountHourlyService.java
  14. 9 5
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/EtlKuaishouReportAccountDailyServiceImpl.java
  15. 35 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/EtlKuaishouReportAccountHourlyServiceImpl.java

+ 29 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAccountReportLoadEtlJob.java

@@ -0,0 +1,29 @@
+package cn.com.ctop.job.kuaishou.handler;
+
+import cn.com.ctop.kuaishou.modules.report.service.IEtlKuaishouReportAccountDailyService;
+import com.xxl.job.core.context.XxlJobHelper;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * 账户维度-盯盘每日数据
+ *
+ * @author syh
+ */
+@Component
+public class KuaishouDailyAccountReportLoadEtlJob {
+
+    @Autowired
+    private IEtlKuaishouReportAccountDailyService iEtlKuaishouReportAccountDailyService;
+
+    @XxlJob("kuaishouDailyAccountReportLoadEtl")
+    public void execute() throws Exception {
+        try {
+            iEtlKuaishouReportAccountDailyService.queryEveryDayDataForAccount();
+            XxlJobHelper.log("queryEveryDayDataForAccount success");
+        } catch (Exception e) {
+            XxlJobHelper.log(e.getMessage());
+        }
+    }
+}

+ 30 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyAccountReportLoadEtlJob.java

@@ -0,0 +1,30 @@
+package cn.com.ctop.job.kuaishou.handler;
+
+import cn.com.ctop.kuaishou.modules.report.service.IEtlKuaishouReportAccountDailyService;
+import cn.com.ctop.kuaishou.modules.report.service.IEtlKuaishouReportAccountHourlyService;
+import com.xxl.job.core.context.XxlJobHelper;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * 账户维度-盯盘每小时数据
+ *
+ * @author syh
+ */
+@Component
+public class KuaishouHourlyAccountReportLoadEtlJob {
+
+    @Autowired
+    private IEtlKuaishouReportAccountHourlyService hourlyService;
+
+    @XxlJob("kuaishouHourlyAccountReportLoadEtl")
+    public void execute() throws Exception {
+        try {
+            hourlyService.queryEveryhourlyDataForAccount();
+            XxlJobHelper.log("queryEveryhourlyDataForAccount success");
+        } catch (Exception e) {
+            XxlJobHelper.log(e.getMessage());
+        }
+    }
+}

+ 193 - 175
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/entity/EtlKuaishouReportAccountDaily.java

@@ -1,231 +1,249 @@
 package cn.com.ctop.kuaishou.modules.report.entity;
-
-import java.io.Serializable;
-import java.util.Date;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
-import com.baomidou.mybatisplus.annotation.TableField;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonProperty;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import org.springframework.format.annotation.DateTimeFormat;
 import org.jeecgframework.poi.excel.annotation.Excel;
+import org.springframework.format.annotation.DateTimeFormat;
 
 /**
- * 盯盘日数据
+ * 账户维度-每日盯盘数据
+ *
  * @author jeecg-boot
- * @date   2021-03-04
  * @version V1.0
+ * @date 2021-03-04
  */
 @Data
 @TableName("ctop_etl_kuaishou_report_account_daily")
 @EqualsAndHashCode(callSuper = false)
 @Accessors(chain = true)
-@ApiModel(value="ctop_etl_kuaishou_report_account_daily对象", description="盯盘数据")
+@ApiModel(value = "ctop_etl_kuaishou_report_account_daily对象", description = "账户维度-每日盯盘数据")
 public class EtlKuaishouReportAccountDaily {
-    
-	/**id*/
-	@TableId(type = IdType.INPUT)
-	@ApiModelProperty(value = "id")
-	private Long id;
-	/**日期*/
-	@Excel(name = "日期", width = 15)
+
+    /**
+     * id
+     */
+    @TableId(type = IdType.INPUT)
+    @ApiModelProperty(value = "id")
+    private java.lang.Long id;
+    /**
+     * 日期
+     */
+    @Excel(name = "日期", width = 15)
     @ApiModelProperty(value = "日期")
-	private String statDate;
-	/**账户ID*/
-	@Excel(name = "账户ID", width = 15)
+    private java.lang.String statDate;
+    /**
+     * 账户ID
+     */
+    @Excel(name = "账户ID", width = 15)
     @ApiModelProperty(value = "账户ID")
-	private Long accountId;
-	/**广告投放场景*/
-	@Excel(name = "广告投放场景", width = 15)
-    @ApiModelProperty(value = "广告投放场景")
-	private String adScene;
-	/**花费(元)*/
-	@Excel(name = "花费(元)", width = 15)
+    private java.lang.Long accountId;
+    /**
+     * 花费(元)
+     */
+    @Excel(name = "花费(元)", width = 15)
     @ApiModelProperty(value = "花费(元)")
-	private java.math.BigDecimal charge;
-	/**封面曝光数*/
-	@Excel(name = "封面曝光数", width = 15)
+    private java.math.BigDecimal charge;
+    /**
+     * 封面曝光数
+     */
+    @Excel(name = "封面曝光数", width = 15)
     @ApiModelProperty(value = "封面曝光数")
-	private Long photoShow;
-	/**封面点击数*/
-	@Excel(name = "封面点击数", width = 15)
+    private java.lang.Long photoShow;
+    /**
+     * 封面点击数
+     */
+    @Excel(name = "封面点击数", width = 15)
     @ApiModelProperty(value = "封面点击数")
-	private Long photoClick;
-	/**素材曝光数*/
-	@Excel(name = "素材曝光数", width = 15)
+    private java.lang.Long photoClick;
+    /**
+     * 素材曝光数
+     */
+    @Excel(name = "素材曝光数", width = 15)
     @ApiModelProperty(value = "素材曝光数")
-	private Long aclick;
-	/**行为数*/
-	@Excel(name = "行为数", width = 15)
+    private java.lang.Long aclick;
+    /**
+     * 行为数
+     */
+    @Excel(name = "行为数", width = 15)
     @ApiModelProperty(value = "行为数")
-	private Long bclick;
-	/**分享数*/
-	@Excel(name = "分享数", width = 15)
+    private java.lang.Long bclick;
+    /**
+     * 分享数
+     */
+    @Excel(name = "分享数", width = 15)
     @ApiModelProperty(value = "分享数")
-	private Long photoShare;
-	/**评论数*/
-	@Excel(name = "评论数", width = 15)
+    private java.lang.Long photoShare;
+    /**
+     * 评论数
+     */
+    @Excel(name = "评论数", width = 15)
     @ApiModelProperty(value = "评论数")
-	private Long photoComment;
-	/**点赞数*/
-	@Excel(name = "点赞数", width = 15)
+    private java.lang.Long photoComment;
+    /**
+     * 点赞数
+     */
+    @Excel(name = "点赞数", width = 15)
     @ApiModelProperty(value = "点赞数")
-	private Long photoLike;
-	/**平均点击单价(元)*/
-	@Excel(name = "平均点击单价(元)", width = 15)
-    @ApiModelProperty(value = "平均点击单价(元)")
-	private java.math.BigDecimal photoClickCost;
-	/**平均行为单价(元)*/
-	@Excel(name = "平均行为单价(元)", width = 15)
-    @ApiModelProperty(value = "平均行为单价(元)")
-	private java.math.BigDecimal actionCost;
-	/**新增关注数*/
-	@Excel(name = "新增关注数", width = 15)
+    private java.lang.Long photoLike;
+    /**
+     * 新增关注数
+     */
+    @Excel(name = "新增关注数", width = 15)
     @ApiModelProperty(value = "新增关注数")
-	private Long follow;
-	/**取消关注数*/
-	@Excel(name = "取消关注数", width = 15)
+    private java.lang.Long follow;
+    /**
+     * 取消关注数
+     */
+    @Excel(name = "取消关注数", width = 15)
     @ApiModelProperty(value = "取消关注数")
-	private Long cancelFollow;
-	/**举报数*/
-	@Excel(name = "举报数", width = 15)
+    private java.lang.Long cancelFollow;
+    /**
+     * 举报数
+     */
+    @Excel(name = "举报数", width = 15)
     @ApiModelProperty(value = "举报数")
-	private Long report;
-	/**拉黑数*/
-	@Excel(name = "拉黑数", width = 15)
+    private java.lang.Long report;
+    /**
+     * 拉黑数
+     */
+    @Excel(name = "拉黑数", width = 15)
     @ApiModelProperty(value = "拉黑数")
-	private Long block;
-	/**减少此类作品数*/
-	@Excel(name = "减少此类作品数", width = 15)
+    private java.lang.Long block;
+    /**
+     * 减少此类作品数
+     */
+    @Excel(name = "减少此类作品数", width = 15)
     @ApiModelProperty(value = "减少此类作品数")
-	private Long negative;
-	/**应用下载数据-安卓下载开始数*/
-	@Excel(name = "应用下载数据-安卓下载开始数", width = 15)
+    private java.lang.Long negative;
+    /**
+     * 应用下载数据-安卓下载开始数
+     */
+    @Excel(name = "应用下载数据-安卓下载开始数", width = 15)
     @ApiModelProperty(value = "应用下载数据-安卓下载开始数")
-	private Long downloadStarted;
-	/**应用下载数据-安卓下载完成数*/
-	@Excel(name = "应用下载数据-安卓下载完成数", width = 15)
+    private java.lang.Long downloadStarted;
+    /**
+     * 应用下载数据-安卓下载完成数
+     */
+    @Excel(name = "应用下载数据-安卓下载完成数", width = 15)
     @ApiModelProperty(value = "应用下载数据-安卓下载完成数")
-	private Long downloadCompleted;
-	/**应用下载数据-激活数*/
-	@Excel(name = "应用下载数据-激活数", width = 15)
+    private java.lang.Long downloadCompleted;
+    /**
+     * 应用下载数据-激活数
+     */
+    @Excel(name = "应用下载数据-激活数", width = 15)
     @ApiModelProperty(value = "应用下载数据-激活数")
-	private Long activation;
-	/**提交按钮点击数*/
-	@Excel(name = "提交按钮点击数", width = 15)
+    private java.lang.Long activation;
+    /**
+     * 提交按钮点击数
+     */
+    @Excel(name = "提交按钮点击数", width = 15)
     @ApiModelProperty(value = "提交按钮点击数")
-	private Long submit;
-	/**应用下载数据-首日付费次数*/
-	@Excel(name = "应用下载数据-首日付费次数", width = 15)
+    private java.lang.Long submit;
+    /**
+     * 应用下载数据-首日付费次数
+     */
+    @Excel(name = "应用下载数据-首日付费次数", width = 15)
     @ApiModelProperty(value = "应用下载数据-首日付费次数")
-	private Long eventPayFirstDay;
-	/**应用下载数据-首日付费金额*/
-	@Excel(name = "应用下载数据-首日付费金额", width = 15)
+    private java.lang.Long eventPayFirstDay;
+    /**
+     * 应用下载数据-首日付费金额
+     */
+    @Excel(name = "应用下载数据-首日付费金额", width = 15)
     @ApiModelProperty(value = "应用下载数据-首日付费金额")
-	private java.math.BigDecimal eventPayPurchaseAmountFirstDay;
-	/**应用下载数据-首日ROI*/
-	@Excel(name = "应用下载数据-首日ROI", width = 15)
-    @ApiModelProperty(value = "应用下载数据-首日ROI")
-	private Double eventPayFirstDayRoi;
-	/**应用下载数据-付费次数*/
-	@Excel(name = "应用下载数据-付费次数", width = 15)
+    private java.math.BigDecimal eventPayPurchaseAmountFirstDay;
+    /**
+     * 应用下载数据-付费次数
+     */
+    @Excel(name = "应用下载数据-付费次数", width = 15)
     @ApiModelProperty(value = "应用下载数据-付费次数")
-	private Long eventPay;
-	/**应用下载数据-付费金额*/
-	@Excel(name = "应用下载数据-付费金额", width = 15)
+    private java.lang.Long eventPay;
+    /**
+     * 应用下载数据-付费金额
+     */
+    @Excel(name = "应用下载数据-付费金额", width = 15)
     @ApiModelProperty(value = "应用下载数据-付费金额")
-	private java.math.BigDecimal eventPayPurchaseAmount;
-	/**应用下载数据-ROI*/
-	@Excel(name = "应用下载数据-ROI", width = 15)
-    @ApiModelProperty(value = "应用下载数据-ROI")
-	private Double eventPayRoi;
-	/**应用下载数据-注册数*/
-	@Excel(name = "应用下载数据-注册数", width = 15)
+    private java.math.BigDecimal eventPayPurchaseAmount;
+    /**
+     * 应用下载数据-注册数
+     */
+    @Excel(name = "应用下载数据-注册数", width = 15)
     @ApiModelProperty(value = "应用下载数据-注册数")
-	private Long eventRegister;
-	/**应用下载数据-注册成本*/
-	@Excel(name = "应用下载数据-注册成本", width = 15)
-    @ApiModelProperty(value = "应用下载数据-注册成本")
-	private java.math.BigDecimal eventRegisterCost;
-	/**应用下载数据-完件数*/
-	@Excel(name = "应用下载数据-完件数", width = 15)
+    private java.lang.Long eventRegister;
+    /**
+     * 应用下载数据-完件数
+     */
+    @Excel(name = "应用下载数据-完件数", width = 15)
     @ApiModelProperty(value = "应用下载数据-完件数")
-	private Long eventJinJianApp;
-	/**应用下载数据-完件成本*/
-	@Excel(name = "应用下载数据-完件成本", width = 15)
-    @ApiModelProperty(value = "应用下载数据-完件成本")
-	private java.math.BigDecimal eventJinJianAppCost;
-	/**应用下载数据-授信数*/
-	@Excel(name = "应用下载数据-授信数", width = 15)
+    private java.lang.Long eventJinJianApp;
+    /**
+     * 应用下载数据-授信数
+     */
+    @Excel(name = "应用下载数据-授信数", width = 15)
     @ApiModelProperty(value = "应用下载数据-授信数")
-	private Long eventCreditGrantApp;
-	/**应用下载数据-授信成本*/
-	@Excel(name = "应用下载数据-授信成本", width = 15)
-    @ApiModelProperty(value = "应用下载数据-授信成本")
-	private java.math.BigDecimal eventCreditGrantAppCost;
-	/**应用下载数据-付款成功数*/
-	@Excel(name = "应用下载数据-付款成功数", width = 15)
+    private java.lang.Long eventCreditGrantApp;
+    /**
+     * 应用下载数据-付款成功数
+     */
+    @Excel(name = "应用下载数据-付款成功数", width = 15)
     @ApiModelProperty(value = "应用下载数据-付款成功数")
-	private Long eventOrderPaid;
-	/**应用下载数据-付款成功金额*/
-	@Excel(name = "应用下载数据-付款成功金额", width = 15)
+    private java.lang.Long eventOrderPaid;
+    /**
+     * 应用下载数据-付款成功金额
+     */
+    @Excel(name = "应用下载数据-付款成功金额", width = 15)
     @ApiModelProperty(value = "应用下载数据-付款成功金额")
-	private java.math.BigDecimal eventOrderPaidPurchaseAmount;
-	/**落地页数据-落地页完件数*/
-	@Excel(name = "落地页数据-落地页完件数", width = 15)
+    private java.math.BigDecimal eventOrderPaidPurchaseAmount;
+    /**
+     * 落地页数据-落地页完件数
+     */
+    @Excel(name = "落地页数据-落地页完件数", width = 15)
     @ApiModelProperty(value = "落地页数据-落地页完件数")
-	private Long eventJinJianLandingPage;
-	/**落地页数据-落地页完件成本*/
-	@Excel(name = "落地页数据-落地页完件成本", width = 15)
-    @ApiModelProperty(value = "落地页数据-落地页完件成本")
-	private java.math.BigDecimal eventJinJianLandingPageCost;
-	/**落地页数据-落地页授信数*/
-	@Excel(name = "落地页数据-落地页授信数", width = 15)
+    private java.lang.Long eventJinJianLandingPage;
+    /**
+     * 落地页数据-落地页授信数
+     */
+    @Excel(name = "落地页数据-落地页授信数", width = 15)
     @ApiModelProperty(value = "落地页数据-落地页授信数")
-	private Long eventCreditGrantLandingPage;
-	/**落地页数据-落地页授信成本*/
-	@Excel(name = "落地页数据-落地页授信成本", width = 15)
-    @ApiModelProperty(value = "落地页数据-落地页授信成本")
-	private java.math.BigDecimal eventCreditGrantLandingPageCost;
-	/**应用下载数据-次留成本(仅支持分日查询)*/
-	@Excel(name = "应用下载数据-次留成本(仅支持分日查询)", width = 15)
-    @ApiModelProperty(value = "应用下载数据-次留成本(仅支持分日查询)")
-	private java.math.BigDecimal eventNextDayStayCost;
-	/**应用下载数据-单次付款成本*/
-	@Excel(name = "应用下载数据-单次付款成本", width = 15)
-    @ApiModelProperty(value = "应用下载数据-单次付款成本")
-	private java.math.BigDecimal eventOrderPaidCost;
-	/**应用下载数据-次留数(仅支持分日查询)*/
-	@Excel(name = "应用下载数据-次留数(仅支持分日查询)", width = 15)
+    private java.lang.Long eventCreditGrantLandingPage;
+    /**
+     * 应用下载数据-次留数(仅支持分日查询)
+     */
+    @Excel(name = "应用下载数据-次留数(仅支持分日查询)", width = 15)
     @ApiModelProperty(value = "应用下载数据-次留数(仅支持分日查询)")
-	private Long eventNextDayStay;
-	/**落地页数据-表单提交单价*/
-	@Excel(name = "落地页数据-表单提交单价", width = 15)
-    @ApiModelProperty(value = "落地页数据-表单提交单价")
-	private java.math.BigDecimal formCost;
-	/**落地页数据-表单提交数*/
-	@Excel(name = "落地页数据-表单提交数", width = 15)
+    private java.lang.Long eventNextDayStay;
+    /**
+     * 落地页数据-表单提交数
+     */
+    @Excel(name = "落地页数据-表单提交数", width = 15)
     @ApiModelProperty(value = "落地页数据-表单提交数")
-	private Long formCount;
-	/**3s播放数*/
-	@Excel(name = "3s播放数", width = 15)
+    private java.lang.Long formCount;
+    /**
+     * 3s播放数
+     */
+    @Excel(name = "3s播放数", width = 15)
     @ApiModelProperty(value = "3s播放数")
-	private Long play3s;
-	/**创建时间*/
-	@Excel(name = "创建时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
-	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
-    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
+    private long play3sCount;
+    /**
+     * 创建时间
+     */
+    @Excel(name = "创建时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
+    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     @ApiModelProperty(value = "创建时间")
-	private Date createTime;
-	/**修改时间*/
-	@Excel(name = "修改时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
-	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
-    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
+    private java.util.Date createTime;
+    /**
+     * 修改时间
+     */
+    @Excel(name = "修改时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
+    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     @ApiModelProperty(value = "修改时间")
-	private Date updateTime;
+    private java.util.Date updateTime;
 }

+ 183 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/entity/EtlKuaishouReportAccountHourly.java

@@ -0,0 +1,183 @@
+package cn.com.ctop.kuaishou.modules.report.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableField;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.format.annotation.DateTimeFormat;
+import org.jeecgframework.poi.excel.annotation.Excel;
+
+/**
+ * 账户维度-每小时盯盘数据
+ * @author jeecg-boot
+ * @date   2021-03-04
+ * @version V1.0
+ */
+@Data
+@TableName("ctop_etl_kuaishou_report_account_hourly")
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="ctop_etl_kuaishou_report_account_hourly对象", description="账户维度-每小时盯盘数据")
+public class EtlKuaishouReportAccountHourly {
+    
+	/**id*/
+	@TableId(type = IdType.INPUT)
+	@ApiModelProperty(value = "id")
+	private Long id;
+	/**日期*/
+	@Excel(name = "日期", width = 15)
+    @ApiModelProperty(value = "日期")
+	private String statDate;
+	/**时间*/
+	@Excel(name = "时间", width = 15)
+    @ApiModelProperty(value = "时间")
+	private Long statHour;
+	/**账户ID*/
+	@Excel(name = "账户ID", width = 15)
+    @ApiModelProperty(value = "账户ID")
+	private Long accountId;
+	/**花费(元)*/
+	@Excel(name = "花费(元)", width = 15)
+    @ApiModelProperty(value = "花费(元)")
+	private java.math.BigDecimal charge;
+	/**封面曝光数*/
+	@Excel(name = "封面曝光数", width = 15)
+    @ApiModelProperty(value = "封面曝光数")
+	private Long photoShow;
+	/**封面点击数*/
+	@Excel(name = "封面点击数", width = 15)
+    @ApiModelProperty(value = "封面点击数")
+	private Long photoClick;
+	/**素材曝光数*/
+	@Excel(name = "素材曝光数", width = 15)
+    @ApiModelProperty(value = "素材曝光数")
+	private Long aclick;
+	/**行为数*/
+	@Excel(name = "行为数", width = 15)
+    @ApiModelProperty(value = "行为数")
+	private Long bclick;
+	/**分享数*/
+	@Excel(name = "分享数", width = 15)
+    @ApiModelProperty(value = "分享数")
+	private Long photoShare;
+	/**评论数*/
+	@Excel(name = "评论数", width = 15)
+    @ApiModelProperty(value = "评论数")
+	private Long photoComment;
+	/**点赞数*/
+	@Excel(name = "点赞数", width = 15)
+    @ApiModelProperty(value = "点赞数")
+	private Long photoLike;
+	/**新增关注数*/
+	@Excel(name = "新增关注数", width = 15)
+    @ApiModelProperty(value = "新增关注数")
+	private Long follow;
+	/**取消关注数*/
+	@Excel(name = "取消关注数", width = 15)
+    @ApiModelProperty(value = "取消关注数")
+	private Long cancelFollow;
+	/**举报数*/
+	@Excel(name = "举报数", width = 15)
+    @ApiModelProperty(value = "举报数")
+	private Long report;
+	/**拉黑数*/
+	@Excel(name = "拉黑数", width = 15)
+    @ApiModelProperty(value = "拉黑数")
+	private Long block;
+	/**减少此类作品数*/
+	@Excel(name = "减少此类作品数", width = 15)
+    @ApiModelProperty(value = "减少此类作品数")
+	private Long negative;
+	/**应用下载数据-安卓下载开始数*/
+	@Excel(name = "应用下载数据-安卓下载开始数", width = 15)
+    @ApiModelProperty(value = "应用下载数据-安卓下载开始数")
+	private Long downloadStarted;
+	/**应用下载数据-安卓下载完成数*/
+	@Excel(name = "应用下载数据-安卓下载完成数", width = 15)
+    @ApiModelProperty(value = "应用下载数据-安卓下载完成数")
+	private Long downloadCompleted;
+	/**应用下载数据-激活数*/
+	@Excel(name = "应用下载数据-激活数", width = 15)
+    @ApiModelProperty(value = "应用下载数据-激活数")
+	private Long activation;
+	/**提交按钮点击数*/
+	@Excel(name = "提交按钮点击数", width = 15)
+    @ApiModelProperty(value = "提交按钮点击数")
+	private Long submit;
+	/**应用下载数据-首日付费次数*/
+	@Excel(name = "应用下载数据-首日付费次数", width = 15)
+    @ApiModelProperty(value = "应用下载数据-首日付费次数")
+	private Long eventPayFirstDay;
+	/**应用下载数据-首日付费金额*/
+	@Excel(name = "应用下载数据-首日付费金额", width = 15)
+    @ApiModelProperty(value = "应用下载数据-首日付费金额")
+	private java.math.BigDecimal eventPayPurchaseAmountFirstDay;
+	/**应用下载数据-付费次数*/
+	@Excel(name = "应用下载数据-付费次数", width = 15)
+    @ApiModelProperty(value = "应用下载数据-付费次数")
+	private Long eventPay;
+	/**应用下载数据-付费金额*/
+	@Excel(name = "应用下载数据-付费金额", width = 15)
+    @ApiModelProperty(value = "应用下载数据-付费金额")
+	private java.math.BigDecimal eventPayPurchaseAmount;
+	/**应用下载数据-注册数*/
+	@Excel(name = "应用下载数据-注册数", width = 15)
+    @ApiModelProperty(value = "应用下载数据-注册数")
+	private Long eventRegister;
+	/**应用下载数据-完件数*/
+	@Excel(name = "应用下载数据-完件数", width = 15)
+    @ApiModelProperty(value = "应用下载数据-完件数")
+	private Long eventJinJianApp;
+	/**应用下载数据-授信数*/
+	@Excel(name = "应用下载数据-授信数", width = 15)
+    @ApiModelProperty(value = "应用下载数据-授信数")
+	private Long eventCreditGrantApp;
+	/**应用下载数据-付款成功数*/
+	@Excel(name = "应用下载数据-付款成功数", width = 15)
+    @ApiModelProperty(value = "应用下载数据-付款成功数")
+	private Long eventOrderPaid;
+	/**应用下载数据-付款成功金额*/
+	@Excel(name = "应用下载数据-付款成功金额", width = 15)
+    @ApiModelProperty(value = "应用下载数据-付款成功金额")
+	private java.math.BigDecimal eventOrderPaidPurchaseAmount;
+	/**落地页数据-落地页完件数*/
+	@Excel(name = "落地页数据-落地页完件数", width = 15)
+    @ApiModelProperty(value = "落地页数据-落地页完件数")
+	private Long eventJinJianLandingPage;
+	/**落地页数据-落地页授信数*/
+	@Excel(name = "落地页数据-落地页授信数", width = 15)
+    @ApiModelProperty(value = "落地页数据-落地页授信数")
+	private Long eventCreditGrantLandingPage;
+	/**应用下载数据-次留数(仅支持分日查询)*/
+	@Excel(name = "应用下载数据-次留数(仅支持分日查询)", width = 15)
+    @ApiModelProperty(value = "应用下载数据-次留数(仅支持分日查询)")
+	private Long eventNextDayStay;
+	/**落地页数据-表单提交数*/
+	@Excel(name = "落地页数据-表单提交数", width = 15)
+    @ApiModelProperty(value = "落地页数据-表单提交数")
+	private Long formCount;
+	/**3s播放数*/
+	@Excel(name = "3s播放数", width = 15)
+    @ApiModelProperty(value = "3s播放数")
+	private long play3sCount;
+	/**创建时间*/
+	@Excel(name = "创建时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
+	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
+    @ApiModelProperty(value = "创建时间")
+	private Date createTime;
+	/**修改时间*/
+	@Excel(name = "修改时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
+	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
+    @ApiModelProperty(value = "修改时间")
+	private Date updateTime;
+}

+ 1 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/EtlKuaishouReportAccountDailyMapper.java

@@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  */
 public interface EtlKuaishouReportAccountDailyMapper extends BaseMapper<EtlKuaishouReportAccountDaily> {
 
+    void replaceBatch(@Param("list") List<EtlKuaishouReportAccountDaily> list);
 }

+ 20 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/EtlKuaishouReportAccountHourlyMapper.java

@@ -0,0 +1,20 @@
+package cn.com.ctop.kuaishou.modules.report.mapper;
+
+
+import java.util.List;
+
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouAppList;
+import cn.com.ctop.kuaishou.modules.report.entity.EtlKuaishouReportAccountHourly;
+import org.apache.ibatis.annotations.Param;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * 账户维度-每小时盯盘数据
+ * @author: jeecg-boot
+ * @date:   2021-03-04
+ * @cersion: V1.0
+ */
+public interface EtlKuaishouReportAccountHourlyMapper extends BaseMapper<EtlKuaishouReportAccountHourly> {
+
+    void replaceBatch(@Param("list") List<EtlKuaishouReportAccountHourly> list);
+}

+ 3 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/KuaishouReportHourlyAccountMapper.java

@@ -1,5 +1,6 @@
 package cn.com.ctop.kuaishou.modules.report.mapper;
 
+import cn.com.ctop.kuaishou.modules.report.entity.EtlKuaishouReportAccountHourly;
 import cn.com.ctop.kuaishou.modules.report.entity.KuaishouReportHourlyAccount;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Param;
@@ -13,4 +14,6 @@ public interface KuaishouReportHourlyAccountMapper extends BaseMapper<KuaishouRe
     BigDecimal getCost(@Param("accountId") Long accountId, @Param("statHour") Integer statHour, @Param("statDate") String statDate);
 
     void replaceBatch(@Param("addList") List<KuaishouReportHourlyAccount> addList);
+
+    List<EtlKuaishouReportAccountHourly> queryEveryhourlyDataForAccount();
 }

+ 75 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/xml/EtlKuaishouReportAccountDailyMapper.xml

@@ -1,5 +1,79 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="cn.com.ctop.kuaishou.modules.report.mapper.EtlKuaishouReportAccountDailyMapper">
-
+    <insert id="replaceBatch">
+        replace into ctop_etl_kuaishou_report_account_daily(
+        stat_date,
+        account_id,
+        charge,
+        photo_show,
+        photo_click,
+        aclick,
+        bclick,
+        photo_share,
+        photo_comment,
+        photo_like,
+        follow,
+        cancel_follow,
+        report,
+        block,
+        negative,
+        download_started,
+        download_completed,
+        activation,
+        submit,
+        event_pay_first_day,
+        event_pay_purchase_amount_first_day,
+        event_pay,
+        event_pay_purchase_amount,
+        event_register,
+        event_jin_jian_app,
+        event_credit_grant_app,
+        event_order_paid,
+        event_order_paid_purchase_amount,
+        event_jin_jian_landing_page,
+        event_credit_grant_landing_page,
+        event_next_day_stay,
+        form_count,
+        play_3s_count
+        )
+        values
+        <foreach collection="list" item="appInfo" separator=",">
+            (
+            #{appInfo.statDate},
+            #{appInfo.accountId},
+            #{appInfo.charge},
+            #{appInfo.photoShow},
+            #{appInfo.photoClick},
+            #{appInfo.aclick},
+            #{appInfo.bclick},
+            #{appInfo.photoShare},
+            #{appInfo.photoComment},
+            #{appInfo.photoLike},
+            #{appInfo.follow},
+            #{appInfo.cancelFollow},
+            #{appInfo.report},
+            #{appInfo.block},
+            #{appInfo.negative},
+            #{appInfo.downloadStarted},
+            #{appInfo.downloadCompleted},
+            #{appInfo.activation},
+            #{appInfo.submit},
+            #{appInfo.eventPayFirstDay},
+            #{appInfo.eventPayPurchaseAmountFirstDay},
+            #{appInfo.eventPay},
+            #{appInfo.eventPayPurchaseAmount},
+            #{appInfo.eventRegister},
+            #{appInfo.eventJinJianApp},
+            #{appInfo.eventCreditGrantApp},
+            #{appInfo.eventOrderPaid},
+            #{appInfo.eventOrderPaidPurchaseAmount},
+            #{appInfo.eventJinJianLandingPage},
+            #{appInfo.eventCreditGrantLandingPage},
+            #{appInfo.eventNextDayStay},
+            #{appInfo.formCount},
+            #{appInfo.play3sCount}
+            )
+        </foreach>
+    </insert>
 </mapper>

+ 82 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/xml/EtlKuaishouReportAccountHourlyMapper.xml

@@ -0,0 +1,82 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="cn.com.ctop.kuaishou.modules.report.mapper.EtlKuaishouReportAccountHourlyMapper">
+
+    <insert id="replaceBatch">
+        replace into ctop_etl_kuaishou_report_account_hourly(
+        stat_date,
+        stat_hour,
+        account_id,
+        charge,
+        photo_show,
+        photo_click,
+        aclick,
+        bclick,
+        photo_share,
+        photo_comment,
+        photo_like,
+        follow,
+        cancel_follow,
+        report,
+        block,
+        negative,
+        download_started,
+        download_completed,
+        activation,
+        submit,
+        event_pay_first_day,
+        event_pay_purchase_amount_first_day,
+        event_pay,
+        event_pay_purchase_amount,
+        event_register,
+        event_jin_jian_app,
+        event_credit_grant_app,
+        event_order_paid,
+        event_order_paid_purchase_amount,
+        event_jin_jian_landing_page,
+        event_credit_grant_landing_page,
+        event_next_day_stay,
+        form_count,
+        play_3s_count
+        )
+        values
+        <foreach collection="list" item="appInfo" separator=",">
+            (
+            #{appInfo.statDate},
+            #{appInfo.statHour},
+            #{appInfo.accountId},
+            #{appInfo.charge},
+            #{appInfo.photoShow},
+            #{appInfo.photoClick},
+            #{appInfo.aclick},
+            #{appInfo.bclick},
+            #{appInfo.photoShare},
+            #{appInfo.photoComment},
+            #{appInfo.photoLike},
+            #{appInfo.follow},
+            #{appInfo.cancelFollow},
+            #{appInfo.report},
+            #{appInfo.block},
+            #{appInfo.negative},
+            #{appInfo.downloadStarted},
+            #{appInfo.downloadCompleted},
+            #{appInfo.activation},
+            #{appInfo.submit},
+            #{appInfo.eventPayFirstDay},
+            #{appInfo.eventPayPurchaseAmountFirstDay},
+            #{appInfo.eventPay},
+            #{appInfo.eventPayPurchaseAmount},
+            #{appInfo.eventRegister},
+            #{appInfo.eventJinJianApp},
+            #{appInfo.eventCreditGrantApp},
+            #{appInfo.eventOrderPaid},
+            #{appInfo.eventOrderPaidPurchaseAmount},
+            #{appInfo.eventJinJianLandingPage},
+            #{appInfo.eventCreditGrantLandingPage},
+            #{appInfo.eventNextDayStay},
+            #{appInfo.formCount},
+            #{appInfo.play3sCount}
+            )
+        </foreach>
+    </insert>
+</mapper>

+ 41 - 3
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/xml/KuaishouReportDailyAccountMapper.xml

@@ -67,7 +67,8 @@
     </resultMap>
 
     <sql id="Base_Column_List">
-    id, account_id, charge, photo_show, aclick, bclick, photo_share, photo_comment, photo_like,
+        id
+        , account_id, charge, photo_show, aclick, bclick, photo_share, photo_comment, photo_like,
     follow, cancel_follow, report, block, negative, download_started, download_completed,
     activation, submit, stat_date, photo_click, photo_click_ratio, action_ratio, impression_1k_cost,
     photo_click_cost, action_cost, event_pay_first_day, event_pay_purchase_amount_first_day,
@@ -79,7 +80,7 @@
     event_credit_grant_landing_ratio, event_next_day_stay_cost, event_next_day_stay_ratio,
     form_action_ratio, event_order_paid_cost, event_next_day_stay, form_cost, form_count,
     play_3s_ratio, create_time, update_time
-  </sql>
+    </sql>
 
 
     <insert id="replaceBatch">
@@ -1328,8 +1329,44 @@
 
     </select>
 
-    <select id="queryEveryDayDataForAccount"  resultType="cn.com.ctop.kuaishou.modules.report.entity.EtlKuaishouReportAccountDaily">>
+    <select id="queryEveryDayDataForAccount"
+            resultType="cn.com.ctop.kuaishou.modules.report.entity.EtlKuaishouReportAccountDaily">
+    SELECT stat_date,
+           account_id,
+           SUM(charge) as 'charge',
+           SUM(photo_show) as 'photoShow',
+           SUM(photo_click) as 'photoClick',
+           SUM(aclick) as 'aclick',
+           SUM(bclick) as 'bclick',
+           SUM(photo_share) as 'photoShare',
+           SUM(photo_comment) as 'photoComment',
+           SUM(photo_like) as 'photoLike',
+           SUM(follow) as 'follow',
+           SUM(cancel_follow) as 'cancelFollow',
+           SUM(report) as 'report',
+           SUM(block) as 'block',
+           SUM(negative) as 'negative',
+           SUM(download_started) as 'downloadStarted',
+           SUM(download_completed) as 'downloadCompleted',
+           SUM(activation) as 'activation',
+           SUM(submit) as 'submit',
+           SUM(event_pay_first_day) as 'eventPayFirstDay',
+           SUM(event_pay_purchase_amount_first_day) as 'eventPayPurchaseAmountFirstDay',
+           SUM(event_pay) as 'eventPay',
+           SUM(event_pay_purchase_amount) as 'eventPayPurchaseAmount',
+           SUM(event_register) as 'eventRegister',
+           SUM(event_jin_jian_app) as 'eventJinJianApp',
+           SUM(event_credit_grant_app) as 'eventCreditGrantApp',
+           SUM(event_order_paid) as 'eventOrderPaid',
+           SUM(event_order_paid_purchase_amount) as 'eventOrderPaidPurchaseAmount',
+           SUM(event_jin_jian_landing_page) as 'eventJinJianLandingPage',
+           SUM(event_credit_grant_landing_page) as 'eventCreditGrantLandingPage',
+           SUM(event_next_day_stay) as 'eventNextDayStay',
+           SUM(form_count) as 'formCount',
+           ROUND(SUM(play_3s_ratio * photo_show)) as 'play3sCount'
+    FROM ctop_kuaishou_report_daily_account
+    WHERE stat_date = DATE_FORMAT(date_sub(now(), interval 1 day), '%Y-%m-%d')
+    GROUP BY account_id
     </select>
 
 </mapper>

+ 46 - 6
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/mapper/xml/KuaishouReportHourlyAccountMapper.xml

@@ -109,13 +109,53 @@
 
     <select id="getCost" resultType="java.math.BigDecimal">
         select charge
-        from
-        ctop_kuaishou_report_hourly_account
-        where
-        account_id = #{accountId}
-        and stat_date = #{statDate}
-        and stat_hour = #{statHour}
+        from ctop_kuaishou_report_hourly_account
+        where account_id = #{accountId}
+          and stat_date = #{statDate}
+          and stat_hour = #{statHour}
 
     </select>
 
+    <select id="queryEveryhourlyDataForAccount"
+            resultType="cn.com.ctop.kuaishou.modules.report.entity.EtlKuaishouReportAccountHourly">
+        SELECT stat_date,
+        account_id,
+        DATE_FORMAT(now(), '%H') as 'statHour',
+        SUM(charge) as 'charge',
+        SUM(photo_show) as 'photoShow',
+        SUM(photo_click) as 'photoClick',
+        SUM(aclick) as 'aclick',
+        SUM(bclick) as 'bclick',
+        SUM(share) as 'photoShare',
+        SUM(comment) as 'photoComment',
+        SUM(photo_like) as 'photoLike',
+        SUM(follow) as 'follow',
+        SUM(cancel_follow) as 'cancelFollow',
+        SUM(report) as 'report',
+        SUM(block) as 'block',
+        SUM(negative) as 'negative',
+        SUM(download_started) as 'downloadStarted',
+        SUM(download_completed) as 'downloadCompleted',
+        SUM(activation) as 'activation',
+        SUM(submit) as 'submit',
+        SUM(event_pay_first_day) as 'eventPayFirstDay',
+        SUM(event_pay_purchase_amount_first_day) as 'eventPayPurchaseAmountFirstDay',
+        SUM(event_pay) as 'eventPay',
+        SUM(event_pay_purchase_amount) as 'eventPayPurchaseAmount',
+        SUM(event_register) as 'eventRegister',
+        SUM(event_jin_jian_app) as 'eventJinJianApp',
+        SUM(event_credit_grant_app) as 'eventCreditGrantApp',
+        SUM(event_order_paid) as 'eventOrderPaid',
+        SUM(event_order_paid_purchase_amount) as 'eventOrderPaidPurchaseAmount',
+        SUM(event_jin_jian_landing_page) as 'eventJinJianLandingPage',
+        SUM(event_credit_grant_landing_page) as 'eventCreditGrantLandingPage',
+        SUM(event_next_day_stay) as 'eventNextDayStay',
+        SUM(form_count) as 'formCount',
+        ROUND(SUM(play_3s_ratio * photo_show)) as 'play3sCount'
+        FROM ctop_kuaishou_report_hourly_account
+        WHERE stat_date = DATE_FORMAT(now(), '%Y-%m-%d')
+        AND stat_hour  &lt;= DATE_FORMAT(now(), '%H')
+        GROUP BY account_id
+    </select>
+
 </mapper>

+ 3 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/IEtlKuaishouReportAccountDailyService.java

@@ -10,5 +10,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
  * @Version: V1.0
  */
 public interface IEtlKuaishouReportAccountDailyService extends IService<EtlKuaishouReportAccountDaily> {
-    void processData();
+
+    void queryEveryDayDataForAccount();
+
 }

+ 17 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/IEtlKuaishouReportAccountHourlyService.java

@@ -0,0 +1,17 @@
+package cn.com.ctop.kuaishou.modules.report.service;
+
+
+import cn.com.ctop.kuaishou.modules.report.entity.EtlKuaishouReportAccountHourly;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * @Description: 账户维度-每小时盯盘数据
+ * @Author: jeecg-boot
+ * @Date: 2021-03-04
+ * @Version: V1.0
+ */
+public interface IEtlKuaishouReportAccountHourlyService extends IService<EtlKuaishouReportAccountHourly> {
+
+    void queryEveryhourlyDataForAccount();
+
+}

+ 9 - 5
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/EtlKuaishouReportAccountDailyServiceImpl.java

@@ -4,18 +4,18 @@ import cn.com.ctop.kuaishou.modules.report.entity.EtlKuaishouReportAccountDaily;
 import cn.com.ctop.kuaishou.modules.report.mapper.EtlKuaishouReportAccountDailyMapper;
 import cn.com.ctop.kuaishou.modules.report.mapper.KuaishouReportDailyAccountMapper;
 import cn.com.ctop.kuaishou.modules.report.service.IEtlKuaishouReportAccountDailyService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-
 import java.util.List;
 
 /**
  * 盯盘日数据
+ *
  * @author jeecg-boot
- * @date   2021-03-04
  * @version V1.0
+ * @date 2021-03-04
  */
 @Service
 public class EtlKuaishouReportAccountDailyServiceImpl extends ServiceImpl<EtlKuaishouReportAccountDailyMapper, EtlKuaishouReportAccountDaily> implements IEtlKuaishouReportAccountDailyService {
@@ -23,8 +23,12 @@ public class EtlKuaishouReportAccountDailyServiceImpl extends ServiceImpl<EtlKua
     @Autowired
     private KuaishouReportDailyAccountMapper dailyAccountMapper;
 
+    @Autowired
+    private EtlKuaishouReportAccountDailyMapper etlDailyAccountMapper;
+
     @Override
-    public void processData() {
-      List<EtlKuaishouReportAccountDaily> list = dailyAccountMapper.queryEveryDayDataForAccount();
+    public void queryEveryDayDataForAccount() {
+        List<EtlKuaishouReportAccountDaily> list = dailyAccountMapper.queryEveryDayDataForAccount();
+        etlDailyAccountMapper.replaceBatch(list);
     }
 }

+ 35 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/EtlKuaishouReportAccountHourlyServiceImpl.java

@@ -0,0 +1,35 @@
+package cn.com.ctop.kuaishou.modules.report.service.impl;
+
+
+import cn.com.ctop.kuaishou.modules.report.entity.EtlKuaishouReportAccountHourly;
+import cn.com.ctop.kuaishou.modules.report.mapper.EtlKuaishouReportAccountHourlyMapper;
+import cn.com.ctop.kuaishou.modules.report.mapper.KuaishouReportHourlyAccountMapper;
+import cn.com.ctop.kuaishou.modules.report.service.IEtlKuaishouReportAccountHourlyService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 账户维度-每小时盯盘数据
+ *
+ * @author jeecg-boot
+ * @version V1.0
+ * @date 2021-03-04
+ */
+@Service
+public class EtlKuaishouReportAccountHourlyServiceImpl extends ServiceImpl<EtlKuaishouReportAccountHourlyMapper, EtlKuaishouReportAccountHourly> implements IEtlKuaishouReportAccountHourlyService {
+
+    @Autowired
+    private KuaishouReportHourlyAccountMapper hourlyAccountMapper;
+
+    @Autowired
+    private EtlKuaishouReportAccountHourlyMapper etlHourlyAccountMapper;
+
+    @Override
+    public void queryEveryhourlyDataForAccount() {
+        List<EtlKuaishouReportAccountHourly> list = hourlyAccountMapper.queryEveryhourlyDataForAccount();
+        etlHourlyAccountMapper.replaceBatch(list);
+    }
+}