Преглед на файлове

修改定时任务删除数据

syh преди 5 години
родител
ревизия
ec1678148f

+ 3 - 1
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/job/KuaishouDailyReportLoadJob.java

@@ -25,6 +25,8 @@ public class KuaishouDailyReportLoadJob implements Job {
     private IKuaishouInterfaceService kuaishouInterfaceService;
     @Override
     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+//        Date deleteDate = DateUtils.addDay(new Date(), -2);
+//        kuaishouInterfaceService.deleteHourlyReport(deleteDate);
         Date getDate = DateUtils.addDay(new Date(), -1);
         //1:查询当日数据
         List<CtopOauthToken> tokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_KUAISHOU);
@@ -44,7 +46,7 @@ public class KuaishouDailyReportLoadJob implements Job {
             kuaishouInterfaceService.getAdvertiserGroupReportDaily(token, getDate, getDate);
             //4: 获取广告创意信息数据
             kuaishouInterfaceService.getAdvertiserCreativeReportDaily(token, getDate, getDate);
-
+//            kuaishouInterfaceService.loadAdvertiserCreativeReportDailyStatistic(token, getDate);
         });
     }
 }

+ 2 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IKuaishouInterfaceService.java

@@ -260,4 +260,6 @@ public interface IKuaishouInterfaceService {
     void loadData() throws InterruptedException;
 
     void updateCreativeReportHourlyStatistic(CtopOauthToken token, Date getDate);
+
+    void deleteHourlyReport(Date deleteDate);
 }

+ 5 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouInterfaceServiceImpl.java

@@ -1265,6 +1265,11 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
         hourlyCreativeStatisticService.updateCreativeReportHourlyStatistic(token, getDate);
     }
 
+    @Override
+    public void deleteHourlyReport(Date deleteDate) {
+        hourlyCreativeStatisticService.deleteHourlyReport(deleteDate);
+    }
+
     private void getGroupListByPage(CtopOauthToken token, int page) {
         String url = PropertiesUtils.getConfig("kuaishou_api_url") + KuaishouInterfaceConstant.GROUP_LIST;
         JSONObject param = new JSONObject();

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

@@ -13,4 +13,6 @@ import org.apache.ibatis.annotations.Param;
  */
 public interface KuaishouReportHourlyCreativeStatisticMapper extends BaseMapper<KuaishouReportHourlyCreativeStatistic> {
     void updateCreativeReportHourlyStatistic(@Param(value = "accountId") Long accountId, @Param(value = "date") String dateString);
+
+    void deleteHourlyReport(@Param(value = "date") String dateString);
 }

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

@@ -150,4 +150,8 @@ FROM
 				AND ckr.account_id = ckvg.account_id
 			) t
     </insert>
+
+	<delete id="deleteHourlyReport">
+		delete from ctop_kuaishou_report_hourly_creative where stat_date &lt;= #{date}
+	</delete>
 </mapper>

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

@@ -16,4 +16,6 @@ import java.util.Date;
 public interface IKuaishouReportHourlyCreativeStatisticService extends IService<KuaishouReportHourlyCreativeStatistic> {
 
     void updateCreativeReportHourlyStatistic(CtopOauthToken token, Date getDate);
+
+    void deleteHourlyReport(Date deleteDate);
 }

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

@@ -29,4 +29,11 @@ public class KuaishouReportHourlyCreativeStatisticServiceImpl extends ServiceImp
         String dateString = format.format(getDate);
         statisticMapper.updateCreativeReportHourlyStatistic(token.getAccountId(), dateString);
     }
+
+    @Override
+    public void deleteHourlyReport(Date deleteDate) {
+        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+        String dateString = format.format(deleteDate);
+        statisticMapper.deleteHourlyReport(dateString);
+    }
 }