增加删除代码

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<TbPlat
     @Query(value = "select new com.baiyee.adcallback.api.dto.RepeatFormDTO(imei, tag, userId)from TbPlatformDeliveryEntity where  userId = ?1 and tag = ?2 and dayNum > ?3 ")
     List<RepeatFormDTO> 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();
+
 }

src/main/java/com/baiyee/adcallback/service/AdPlatformDeliveryService.java

@@ -27,4 +27,15 @@ public interface AdPlatformDeliveryService {
      * @return
      */
     Boolean saveAll(List<TbPlatformDeliveryEntity> deliveryStatisticEntityList);
+
+    /**
+     * 删除数据
+     * @param num
+     */
+    void deleteAllByDayNum(Integer num);
+
+    /**
+     * 修改数据
+     */
+    void updateAllByDayNum();
 }

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();
+    }
 }

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());
+    }
+
 }