修改bug

puzhibing

2026-04-28 2bfe1a712733a95553adbfcc01c4ea8b332ed5c1

修改bug

 xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/task/ActivityTask.java

New file
@@ -0,0 +1,70 @@
package com.xiaopeng.operation.utils.task;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.xiaopeng.api.model.operation.XpActicityStrategy;
import com.xiaopeng.api.model.operation.XpActicityUser;
import com.xiaopeng.api.model.operation.XpActivity;
import com.xiaopeng.operation.service.IXpActicityService;
import com.xiaopeng.operation.service.IXpActicityStrategyService;
import com.xiaopeng.operation.service.IXpActicityUserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.List;
import java.util.stream.Collectors;

@Slf4j
@Component
public class ActivityTask {

    @Resource
    private IXpActicityStrategyService xpActicityStrategyService;

    @Resource
    private IXpActicityService xpActicityService;

    @Resource
    private IXpActicityUserService xpActicityUserService;




    /**
     * 凌晨执行的定时任务
     */
    @Scheduled(cron = "0 0 0 * * *")
    public void taskOrder() {
        pusCoupon();
    }


    /**
     * 每日发放券的活动
     */
    public void pusCoupon(){
        List<XpActivity> activities = xpActicityService.list(new QueryWrapper<XpActivity>().eq("status", 2)
                .eq("is_deleted", 0).last(" and now() between start_time and end_time"));
        if(activities.isEmpty()){
            return;
        }
        List<Long> activityIds = activities.stream().map(XpActivity::getId).collect(Collectors.toList());
        //获取发放人
        List<XpActicityUser> xpActicityUsers = xpActicityUserService.list(new QueryWrapper<XpActicityUser>().eq("is_deleted", 0)
                .in("actitcity_id", activityIds));
        List<XpActicityStrategy> list = xpActicityStrategyService.list(new QueryWrapper<XpActicityStrategy>()
                .eq("distribution_rules", 1)
                .eq("is_deleted", 0)
                .in("actitcity_id", activityIds));
        for (XpActicityStrategy xpActicityStrategy : list) {
            //发放人
            List<XpActicityUser> collect = xpActicityUsers.stream().filter(s -> s.getActitcityStrategeId().equals(xpActicityStrategy.getId())).collect(Collectors.toList());




        }
    }
}