Parcourir la source

代理人app开发

xuqiang il y a 1 an
Parent
commit
fc67b1e341

+ 1 - 1
src/main/java/com/ydtech/modules/partner/dao/PartnerLiftingRecordMapper.java

@@ -25,7 +25,7 @@ public interface PartnerLiftingRecordMapper extends BaseMapper<PartnerLiftingRec
     Page<PartnerLiftingRecord> queryPage(Page page,@Param("ew") QueryWrapper<PartnerLiftingRecord> queryWrapper);
 
     @Select("SELECT * FROM partner_lifting_record WHERE type = 1 AND audit_status = 0 AND DATE(DATE_ADD(create_time, INTERVAL #{expireDays} DAY)) =  CURDATE() ")
-    List<PartnerLiftingRecord> queryExpireDays(String expireDays);
+    List<PartnerLiftingRecord> queryExpireDays(Integer expireDays);
 
     @Update("update partner_lifting_record set audit_status = #{status} where id = #{id}")
     void updateAuditStatusById(String id, int status);

+ 1 - 1
src/main/java/com/ydtech/modules/partner/service/Impl/PartnerLiftingRecordServiceImpl.java

@@ -221,7 +221,7 @@ public class PartnerLiftingRecordServiceImpl extends ServiceImpl<PartnerLiftingR
     }
 
     @Override
-    public List<PartnerLiftingRecord> queryExpireDays(String expireDays) {
+    public List<PartnerLiftingRecord> queryExpireDays(Integer expireDays) {
         List<PartnerLiftingRecord> list = baseMapper.queryExpireDays(expireDays);
         return list;
     }

+ 1 - 1
src/main/java/com/ydtech/modules/partner/service/PartnerLiftingRecordService.java

@@ -26,7 +26,7 @@ public interface PartnerLiftingRecordService {
 
     HttpResult confirmUnlocking(PartnerRecordApper recordApper);
 
-    List<PartnerLiftingRecord> queryExpireDays(String expireDays);
+    List<PartnerLiftingRecord> queryExpireDays(Integer expireDays);
 
     void updateAuditStatusById(PartnerLiftingRecord record);
 

+ 2 - 2
src/main/java/com/ydtech/modules/partner/utils/TimedTaskUtils.java

@@ -50,7 +50,7 @@ public class TimedTaskUtils {
     private PartnerExpiredCommissionMapper expiredCommissionMapper;
 
     @Value("${newPartner.expireDays}")
-    private String expireDays;
+    private Integer expireDays;
 
     /**
      * TODO  每天晚上  记录佣金过期记录
@@ -59,7 +59,7 @@ public class TimedTaskUtils {
     @Scheduled(cron = "0 0 0 * * *")
     public void updateOrderDateNoon() {
         log.info("记录佣金过期定时任务开始执行:{}", expireDays);
-        List<PartnerLiftingRecord> list = liftingRecordService.queryExpireDays(expireDays);
+        List<PartnerLiftingRecord> list = liftingRecordService.queryExpireDays(expireDays + 1);
         for (PartnerLiftingRecord record : list) {
             //清空 当前用户抽成账户表
             PartnerPartnerAccount account = accountMapper.selectOne(new LambdaQueryWrapper<>(PartnerPartnerAccount.class)