diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java index bbf033367..d3e9267c9 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java @@ -2,10 +2,13 @@ package com.iformall.schedule; import com.iformall.domain.po.WxActivity; import com.iformall.domain.po.WxActivityJoin; +import com.iformall.domain.po.WxCampaign; import com.iformall.domain.po.msg.WxMsgRecord; import com.iformall.enums.*; import com.iformall.mapper.WxActivityJoinMapper; import com.iformall.mapper.WxActivityMapper; +import com.iformall.mapper.WxCampaignMapper; +import com.iformall.mapper.WxCouponChannelMapper; import com.iformall.mq.MqBaseProducer; import com.iformall.utils.DateUtils; import org.apache.commons.collections.map.HashedMap; @@ -16,6 +19,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; +import java.util.Date; import java.util.List; import java.util.Map; @@ -36,6 +40,12 @@ public class ActivitySchedule { @Autowired private MqBaseProducer mqBaseProducer; + @Autowired + private WxCampaignMapper wxCampaignMapper; + + @Autowired + private WxCouponChannelMapper wxCouponChannelMapper; + /** * 每天12点执行 */ @@ -103,4 +113,25 @@ public class ActivitySchedule { wxActivityMapper.activityCompletion(activity); } + /** + * 5分钟一次 + */ + @Scheduled(cron = "0 */5 * * * ?") + public void campaignCompletion() { + logger.info("宣传页下架任务"); + WxCampaign campaign = new WxCampaign(); + campaign.setStatus(EnumCampaignStatus.STATUS_THROW_IN.getCode()); + campaign.setType(EnumCampaignType.PAGEPATH.getCode()); + List campaignList = wxCampaignMapper.select(campaign); + for (WxCampaign wxCampaign : campaignList) { + WxActivity wxActivity = wxActivityMapper.selectByPrimaryKey(wxCampaign.getProduceId()); + if (wxActivity.getStatus().equals(EnumActivityStatus.STATUS_TAKE_OFFF.getCode())) { + wxCampaign.setStatus(EnumCampaignStatus.STATUS_TAKE_OFFF.getCode()); + wxCampaign.setUpdateTime(new Date()); + wxCampaignMapper.updateByPrimaryKeySelective(wxCampaign); + } + } + } + + } \ No newline at end of file