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

[BUG][修改][C端我的活动下当活动结束时间小于当前时间属于过期应该改变活动状态进入已过期下]

release_toaliyun_real
gongbiao 7 лет назад
Родитель
Сommit
126e69cf18
3 измененных файлов: 17 добавлений и 9 удалений
  1. +7
    -9
      mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java
  2. +2
    -0
      mallinkService/src/main/java/com/iformall/mapper/WxActivityJoinMapper.java
  3. +8
    -0
      mallinkService/src/main/resources/mapper/WxActivityJoinMapper.xml

+ 7
- 9
mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java Просмотреть файл

@@ -18,6 +18,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
@@ -108,14 +109,8 @@ public class ActivitySchedule {
WxActivity activity = new WxActivity();
activity.setStatus(EnumActivityStatus.STATUS_TAKE_OFFF.getCode());
wxActivityMapper.activityCompletion(activity);
}

/**
* 5分钟一次
*/
@Scheduled(cron = "0 */5 * * * ?")
public void campaignCompletion() {
logger.info("宣传页下架任务");
List<WxActivity> activityList = new ArrayList();
//宣传页下线
WxCampaign campaign = new WxCampaign();
campaign.setStatus(EnumCampaignStatus.STATUS_THROW_IN.getCode());
campaign.setType(EnumCampaignType.PAGEPATH.getCode());
@@ -123,12 +118,15 @@ public class ActivitySchedule {
for (WxCampaign wxCampaign : campaignList) {
WxActivity wxActivity = wxActivityMapper.selectByPrimaryKey(wxCampaign.getProduceId());
if (wxActivity.getStatus().equals(EnumActivityStatus.STATUS_TAKE_OFFF.getCode())) {
activityList.add(wxActivity);
wxCampaign.setStatus(EnumCampaignStatus.STATUS_TAKE_OFFF.getCode());
wxCampaign.setUpdateTime(new Date());
wxCampaignMapper.updateByPrimaryKeySelective(wxCampaign);
}
}
}
//更新报名状态
wxActivityJoinMapper.updateStatus(activityList);

}

}

+ 2
- 0
mallinkService/src/main/java/com/iformall/mapper/WxActivityJoinMapper.java Просмотреть файл

@@ -18,4 +18,6 @@ public interface WxActivityJoinMapper extends CommonMapper<WxActivityJoin, Long>

void updateSendMsg(Map<String, Object> param);

void updateStatus(List<WxActivity> wxActivity);

}

+ 8
- 0
mallinkService/src/main/resources/mapper/WxActivityJoinMapper.xml Просмотреть файл

@@ -97,5 +97,13 @@
#{join.id}
</foreach>
</update>
<update id="updateStatus" parameterType="java.util.List">
update wx_activity_join set status = 3 where activity_id in
<foreach collection="activityList" index="index" item="activity" open="(" separator="," close=")">
#{activity.id}
</foreach>
</update>


</mapper>

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