package com.matrix.system.shopXcx.quartz;

import com.matrix.core.tools.LogUtil;
import com.matrix.system.hive.plugin.util.CollectionUtils;
import com.matrix.system.shopXcx.bean.ShopActivities;
import com.matrix.system.shopXcx.bean.ShopActivitiesGroupInfo;
import com.matrix.system.shopXcx.bean.ShopActivitiesGroupJoin;
import com.matrix.system.shopXcx.dao.ShopActivitiesDao;
import com.matrix.system.shopXcx.dao.ShopActivitiesGroupJoinDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.Scheduled;

import java.util.List;

/**
 * 开团时间超时任务处理
 *
 * @author wzy
 */
@Configuration
public class ShopActivityGroupJoinTimeOutQuartz {

    @Autowired
    private ShopActivitiesGroupJoinDao shopActivitiesGroupJoinDao ;

    @Autowired
    private ShopActivitiesDao shopActivitiesDao ;




    @Scheduled(cron = "0 */1 * * * ?")
    public boolean executeExt() {
            LogUtil.info("#开团时间超时任务处理#");
            List<ShopActivitiesGroupJoin> groupJoins = shopActivitiesGroupJoinDao.selectGroupJoinWithEnd();
            ShopActivityTimeOutQuartz timeOutQuartz = new ShopActivityTimeOutQuartz();
            if (CollectionUtils.isNotEmpty(groupJoins)) {
                for (ShopActivitiesGroupJoin groupJoin : groupJoins) {
                    ShopActivities shopActivities = shopActivitiesDao.selectShopActivitiesById(groupJoin.getActId());
                    // 需判断虚拟成团
                    if (shopActivities.getGroupInfo().getGiVirtualGroup() == ShopActivitiesGroupInfo.GROUP_VIRTUAL_Y) {
                        timeOutQuartz.doVirtualGroup(groupJoin);
                    } else {
                        timeOutQuartz.doUnVirtualGroup(groupJoin);
                    }
                }
        }
        return true;
    }
}