diff --git a/src/main/java/com/baiyee/adcallback/repository/TbPlatformDeliveryEntityRepository.java b/src/main/java/com/baiyee/adcallback/repository/TbPlatformDeliveryEntityRepository.java index 467fa9a..0bab603 100644 --- a/src/main/java/com/baiyee/adcallback/repository/TbPlatformDeliveryEntityRepository.java +++ b/src/main/java/com/baiyee/adcallback/repository/TbPlatformDeliveryEntityRepository.java @@ -3,6 +3,7 @@ package com.baiyee.adcallback.repository; import com.baiyee.adcallback.api.dto.RepeatFormDTO; import com.baiyee.adcallback.repository.entity.TbPlatformDeliveryEntity; import org.springframework.data.jpa.repository.JpaRepository; +import org.springframework.data.jpa.repository.Modifying; import org.springframework.data.jpa.repository.Query; import java.util.List; @@ -26,4 +27,23 @@ public interface TbPlatformDeliveryEntityRepository extends JpaRepository findByTag(Long userId, String tagStr, int num); + + + /** + * 删除剩余天数为0 的数据 + * + * @param dayNum 剩余天数 + */ + @Modifying + @Query(value = "delete from TbPlatformDeliveryEntity where dayNum =?1") + void deleteAllByDayNum(Integer dayNum); + + + /** + * 将所有未到时间的数据 剩余天数减一 + */ + @Modifying + @Query(value = "update TbPlatformDeliveryEntity set dayNum = dayNum -1") + void updateAllByDayNum(); + } diff --git a/src/main/java/com/baiyee/adcallback/service/AdPlatformDeliveryService.java b/src/main/java/com/baiyee/adcallback/service/AdPlatformDeliveryService.java index 9ee4d4c..9439d78 100644 --- a/src/main/java/com/baiyee/adcallback/service/AdPlatformDeliveryService.java +++ b/src/main/java/com/baiyee/adcallback/service/AdPlatformDeliveryService.java @@ -27,4 +27,15 @@ public interface AdPlatformDeliveryService { * @return */ Boolean saveAll(List deliveryStatisticEntityList); + + /** + * 删除数据 + * @param num + */ + void deleteAllByDayNum(Integer num); + + /** + * 修改数据 + */ + void updateAllByDayNum(); } diff --git a/src/main/java/com/baiyee/adcallback/service/impl/AdPlatformDeliveryServiceImpl.java b/src/main/java/com/baiyee/adcallback/service/impl/AdPlatformDeliveryServiceImpl.java index ad3d971..a9ac15d 100644 --- a/src/main/java/com/baiyee/adcallback/service/impl/AdPlatformDeliveryServiceImpl.java +++ b/src/main/java/com/baiyee/adcallback/service/impl/AdPlatformDeliveryServiceImpl.java @@ -31,4 +31,14 @@ public class AdPlatformDeliveryServiceImpl implements AdPlatformDeliveryService return tbPlatformDeliveryEntityRepository.saveAll (deliveryStatisticEntityList).size() == deliveryStatisticEntityList.size(); } + + @Override + public void deleteAllByDayNum(Integer num) { + tbPlatformDeliveryEntityRepository.deleteAllByDayNum(num); + } + + @Override + public void updateAllByDayNum() { + tbPlatformDeliveryEntityRepository.updateAllByDayNum(); + } } diff --git a/src/main/java/com/baiyee/adcallback/task/PlatFormRecordTask.java b/src/main/java/com/baiyee/adcallback/task/PlatFormRecordTask.java index f4040f1..d499c1f 100644 --- a/src/main/java/com/baiyee/adcallback/task/PlatFormRecordTask.java +++ b/src/main/java/com/baiyee/adcallback/task/PlatFormRecordTask.java @@ -134,4 +134,23 @@ public class PlatFormRecordTask { } } } + + + /** + * 修改数据 + */ + @Scheduled(cron = "0 30 23 * * ? ") + @Transactional(rollbackFor = Exception.class) + public void autoDeal() { + log.info("++++++++++++++++++++++change plate form sync start time {} ++++++++++++++++", DateUtil.now()); + + //删除剩余天数为0的数据 + adPlatformDeliveryService.deleteAllByDayNum(0); + + //所有的数据剩余天数-1 + adPlatformDeliveryService.updateAllByDayNum(); + + log.info("++++++++++++++++++++++change plate form Sync end time {} ++++++++++++++++", DateUtil.now()); + } + }