| 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; | 
|     } | 
| } |