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.XpActivity;
import com.xiaopeng.operation.service.IXpActicityService;
import com.xiaopeng.operation.service.IXpActicityStrategyService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;

@Slf4j
@Component
public class ActivityTask {

    @Resource
    private IXpActicityStrategyService xpActicityStrategyService;

    @Resource
    private IXpActicityService xpActicityService;


    @Scheduled(cron = "0 0/1 * * * *")
    public void taskOrder() {
        xpActicityService.updateStatus();
        //循环发放的活动
        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;
        }
        for (XpActivity activity : activities) {
            List<XpActicityStrategy> list = xpActicityStrategyService.list(new QueryWrapper<XpActicityStrategy>()
                    .eq("distribution_rules", 1)
                    .eq("is_deleted", 0)
                    .eq("actitcity_id", activity.getId()));
            for (XpActicityStrategy xpActicityStrategy : list) {
                String distributionTime = xpActicityStrategy.getDistributionTime();
                String format = LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm"));
                if (distributionTime.equals(format)) {
                    xpActicityService.pushCoupon(activity, xpActicityStrategy);
                }
            }
        }
    }
}