Просмотр исходного кода

[活动][修改][宣传页下架任务]

release_toaliyun_real
gongbiao 7 лет назад
Родитель
Сommit
e6e47f4660
1 измененных файлов: 31 добавлений и 0 удалений
  1. +31
    -0
      mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java

+ 31
- 0
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<WxCampaign> 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);
}
}
}


}

Загрузка…
Отмена
Сохранить