From 126e69cf18efaf85714e814c6fb8f04348c10786 Mon Sep 17 00:00:00 2001 From: gongbiao Date: Fri, 14 Jun 2019 16:55:25 +0800 Subject: [PATCH] =?UTF-8?q?[BUG][=E4=BF=AE=E6=94=B9][C=E7=AB=AF=E6=88=91?= =?UTF-8?q?=E7=9A=84=E6=B4=BB=E5=8A=A8=E4=B8=8B=E5=BD=93=E6=B4=BB=E5=8A=A8?= =?UTF-8?q?=E7=BB=93=E6=9D=9F=E6=97=B6=E9=97=B4=E5=B0=8F=E4=BA=8E=E5=BD=93?= =?UTF-8?q?=E5=89=8D=E6=97=B6=E9=97=B4=E5=B1=9E=E4=BA=8E=E8=BF=87=E6=9C=9F?= =?UTF-8?q?=E5=BA=94=E8=AF=A5=E6=94=B9=E5=8F=98=E6=B4=BB=E5=8A=A8=E7=8A=B6?= =?UTF-8?q?=E6=80=81=E8=BF=9B=E5=85=A5=E5=B7=B2=E8=BF=87=E6=9C=9F=E4=B8=8B?= =?UTF-8?q?]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/iformall/schedule/ActivitySchedule.java | 16 +++++++--------- .../iformall/mapper/WxActivityJoinMapper.java | 2 ++ .../resources/mapper/WxActivityJoinMapper.xml | 8 ++++++++ 3 files changed, 17 insertions(+), 9 deletions(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java index f25ba26ff..00ca15367 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/ActivitySchedule.java +++ b/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 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); + } } \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxActivityJoinMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxActivityJoinMapper.java index ae770500e..25628e3a9 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxActivityJoinMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxActivityJoinMapper.java @@ -18,4 +18,6 @@ public interface WxActivityJoinMapper extends CommonMapper void updateSendMsg(Map param); + void updateStatus(List wxActivity); + } diff --git a/mallinkService/src/main/resources/mapper/WxActivityJoinMapper.xml b/mallinkService/src/main/resources/mapper/WxActivityJoinMapper.xml index c52582920..10d984d6f 100644 --- a/mallinkService/src/main/resources/mapper/WxActivityJoinMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxActivityJoinMapper.xml @@ -97,5 +97,13 @@ #{join.id} + + + update wx_activity_join set status = 3 where activity_id in + + #{activity.id} + + +