diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityCashMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityCashMapper.java index 1bf81c24..13d45e5c 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityCashMapper.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityCashMapper.java @@ -37,6 +37,7 @@ public interface XhpcActivityCashMapper { List> selectUserListByParams(@Param("params")Map params); - List selectCheckedPassAndAutoReceive(); + + int updateStatusByExpireNow(); } \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityDiscountMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityDiscountMapper.java index 112675da..eaf5e10b 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityDiscountMapper.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityDiscountMapper.java @@ -13,6 +13,8 @@ public interface XhpcActivityDiscountMapper { List selectByTemplateIdAndStatus(@Param("templateId") Integer templateId, @Param("status")Integer status); + int updateByTemplateIdAndUncheck(@Param("templateId") Integer templateId); + List selectByTemplateIdAndDelflag(@Param("templateId") Integer templateId, @Param("delflag")Integer status); List> selectNameMapList(@Param("params")Map params); @@ -40,4 +42,6 @@ public interface XhpcActivityDiscountMapper { List> selectBUserListByUserIds(@Param("userIds") String userIds); List> selectUserListByParams(@Param("params")Map params); + + int updateStatusByExpireNow(); } \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityInternetMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityInternetMapper.java index 4268fcbb..a9a6da83 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityInternetMapper.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityInternetMapper.java @@ -29,4 +29,5 @@ public interface XhpcActivityInternetMapper { List selectByDateBetween(@Param("startTime")String startTime, @Param("endTime")String endTime); + int updateStatusByExpireNow(); } \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityTemplateServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityTemplateServiceImpl.java index 7c322411..0a3f5a85 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityTemplateServiceImpl.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityTemplateServiceImpl.java @@ -63,6 +63,7 @@ public class XhpcActivityTemplateServiceImpl implements XhpcActivityTemplateServ if(domainList.size() > 0){ throw new CustomException("存在生效的折扣活动,请先失效使用该模版的折扣活动"); } + discountMapper.updateByTemplateIdAndUncheck(domain.getActivityTemplateId()); } return templateMapper.updateStatusByPrimaryKey(domain) > 0; diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AutoCashTask.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AutoActivityTask.java similarity index 94% rename from xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AutoCashTask.java rename to xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AutoActivityTask.java index 60341e69..50807e49 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AutoCashTask.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AutoActivityTask.java @@ -2,9 +2,7 @@ package com.xhpc.activity.task; import com.xhpc.activity.domain.*; import com.xhpc.activity.enums.ActivityTypeEnum; -import com.xhpc.activity.mapper.XhpcActivityCashMapper; -import com.xhpc.activity.mapper.XhpcActivityRecordMapper; -import com.xhpc.activity.mapper.XhpcUserMapper; +import com.xhpc.activity.mapper.*; import com.xhpc.common.core.utils.StringUtils; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; @@ -18,10 +16,14 @@ import java.util.List; @Component @Transactional -public class AutoCashTask { +public class AutoActivityTask { @Resource XhpcActivityCashMapper cashMapper; + @Resource + XhpcActivityDiscountMapper discountMapper; + @Resource + XhpcActivityInternetMapper internetMapper; @Resource XhpcUserMapper userMapper; @@ -130,6 +132,14 @@ public class AutoCashTask { } + @Scheduled(cron = "0 0 1 * * ?") + private void updateActivityStatus(){ + cashMapper.updateStatusByExpireNow(); + discountMapper.updateStatusByExpireNow(); + internetMapper.updateStatusByExpireNow(); + } + + private XhpcActivityRecordDomain addRecord(XhpcActivityCashDomain cashDomain, Integer source, String userId) { XhpcActivityRecordDomain recordDomain = new XhpcActivityRecordDomain(); recordDomain.setActivityType(ActivityTypeEnum.CASH.getCode()); diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityCashMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityCashMapper.xml index 77606808..e6c67227 100644 --- a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityCashMapper.xml +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityCashMapper.xml @@ -132,7 +132,7 @@ - SELECT 'C端用户' as 'userType', phone as 'usreAccount' from xhpc_app_user where del_flag=0 and status=0 @@ -197,7 +197,11 @@ from xhpc_activity_cash where del_flag=0 and status=3 and auto_receive=1 and auto_status=0 - + + + update xhpc_activity_cash set status=4 where status=3 and del_flag=0 and end_time now() + + \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityDiscountMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityDiscountMapper.xml index cd3e0a2d..33ea97d2 100644 --- a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityDiscountMapper.xml +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityDiscountMapper.xml @@ -133,11 +133,18 @@ update xhpc_activity_discount set status=#{status} - where status = 3 + where status = 3 and del_flag=0 and template_id = #{templateId} + + update xhpc_activity_discount + set status=4 + where template_id = #{templateId} and del_flag=0 and find_in_set(status, '0,1') + + + @@ -213,4 +219,10 @@ from xhpc_activity_discount ad where ad.del_flag=#{delflag} and ad.template_id=#{templateId} + + + + update xhpc_activity_discount set status=4 where status=3 and del_flag=0 and end_time now() + + \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityInternetMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityInternetMapper.xml index b07d7bb0..8cdb9a59 100644 --- a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityInternetMapper.xml +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityInternetMapper.xml @@ -140,4 +140,9 @@ where activity_id = #{activityId,jdbcType=INTEGER} + + + update xhpc_activity_internet set status=4 where status=3 and del_flag=0 and end_time now() + + \ No newline at end of file