From c97706c3cc213b7db3d381e8a0435ff0ef9a04d6 Mon Sep 17 00:00:00 2001 From: jiangqs <jiangqs> Date: 星期一, 04 九月 2023 18:53:40 +0800 Subject: [PATCH] seata 同步 支付调整 --- ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/activity/ActivityServiceImpl.java | 551 ++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 541 insertions(+), 10 deletions(-) diff --git a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/activity/ActivityServiceImpl.java b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/activity/ActivityServiceImpl.java index 712f5f8..0901f6d 100644 --- a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/activity/ActivityServiceImpl.java +++ b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/activity/ActivityServiceImpl.java @@ -1,25 +1,47 @@ package com.ruoyi.goods.service.impl.activity; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.common.core.exception.ServiceException; +import com.ruoyi.common.core.utils.DateUtils; import com.ruoyi.common.core.utils.StringUtils; +import com.ruoyi.common.core.utils.bean.BeanUtils; import com.ruoyi.common.core.utils.uuid.IdUtils; -import com.ruoyi.goods.domain.dto.MgtActivityEditDto; -import com.ruoyi.goods.domain.dto.MgtActivityGoodsEditDto; +import com.ruoyi.common.redis.service.RedisService; +import com.ruoyi.goods.domain.dto.*; import com.ruoyi.goods.domain.pojo.activity.Activity; import com.ruoyi.goods.domain.pojo.activity.ActivityTotal; +import com.ruoyi.goods.domain.vo.*; import com.ruoyi.goods.mapper.activity.ActivityMapper; import com.ruoyi.goods.service.activity.ActivityGoodsService; +import com.ruoyi.goods.service.activity.ActivityRecordService; import com.ruoyi.goods.service.activity.ActivityService; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.goods.service.activity.ActivityTotalService; import com.ruoyi.system.api.constant.AppErrorConstant; +import com.ruoyi.system.api.constant.DelayTaskEnum; +import com.ruoyi.system.api.constant.SecurityConstant; +import com.ruoyi.system.api.domain.dto.*; import com.ruoyi.system.api.domain.poji.activity.ActivityGoods; +import com.ruoyi.system.api.domain.poji.config.DelayTask; +import com.ruoyi.system.api.domain.vo.ActivityGoodsGetVo; +import com.ruoyi.system.api.domain.vo.MgtSimpleMemberVo; +import com.ruoyi.system.api.domain.vo.MgtSimpleShopVo; +import com.ruoyi.system.api.domain.vo.MgtUserIdByKeywordVo; +import com.ruoyi.system.api.service.RemoteConfigService; +import com.ruoyi.system.api.service.RemoteFileService; +import com.ruoyi.system.api.service.RemoteMemberService; +import com.ruoyi.system.api.service.RemoteShopService; +import org.redisson.api.RLock; +import org.redisson.api.RedissonClient; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.math.BigDecimal; -import java.util.Date; -import java.util.List; +import java.util.*; +import java.util.concurrent.TimeUnit; +import java.util.function.Function; import java.util.stream.Collectors; /** @@ -34,10 +56,35 @@ public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> implements ActivityService { @Resource + private ActivityMapper activityMapper; + + @Resource private ActivityGoodsService activityGoodsService; @Resource private ActivityTotalService activityTotalService; + + @Resource + private ActivityRecordService activityRecordService; + + @Resource + private RemoteShopService remoteShopService; + + @Resource + private RemoteMemberService remoteMemberService; + + @Resource + private RemoteConfigService remoteConfigService; + + @Resource + private RedisService redisService; + + + @Autowired + private RedissonClient redissonClient; + + @Resource + private RemoteFileService remoteFileService; /** * @param mgtActivityEditDto @@ -51,6 +98,9 @@ Activity activity; // 获取当前时间 Date nowTime = new Date(); + if(mgtActivityEditDto.getActivityStartTime().compareTo(mgtActivityEditDto.getActivityEndTime())>0){ + throw new ServiceException(AppErrorConstant.ACTIVITY_SE_ERROR); + } // 如果活动ID不为空,则表示修改活动信息 if (StringUtils.isNotBlank(mgtActivityEditDto.getActivityId())) { // 获取活动信息 @@ -77,20 +127,26 @@ activityTotal.setRefundTotal(0); activityTotal.setOrderMoneyTotal(BigDecimal.ZERO); activityTotalService.save(activityTotal); + CodeGetDto codeGetDto = new CodeGetDto(); + String url = "https://wxapp.hhhrt.cn/mini/activity?id="+activityId; + codeGetDto.setUrl(url); + codeGetDto.setFileName("activity-"+activityId); + String codeUrl = remoteFileService.getAppOrderTotal(codeGetDto).getData(); + activity.setActivityCode(codeUrl); } // 获取活动开始时间和结束时间 Date activityStartTime = mgtActivityEditDto.getActivityStartTime(); Date activityEndTime = mgtActivityEditDto.getActivityEndTime(); // 根据当前时间和活动时间判断活动状态 - if (nowTime.compareTo(activityStartTime) < 0) { + /*if (nowTime.compareTo(activityStartTime) < 0) { activity.setActivityStatus(0); - } else if (nowTime.compareTo(activityStartTime) >= 0 && nowTime.compareTo(activityEndTime) <= 0) { + } else { activity.setActivityStatus(1); - } else if (nowTime.compareTo(activityEndTime) > 0) { - activity.setActivityStatus(2); - } + + }*/ // 设置活动信息 activity.setActivityName(mgtActivityEditDto.getActivityName()); + activity.setActivityIntroduce(mgtActivityEditDto.getActivityIntroduce()); activity.setActivityStartTime(activityStartTime); activity.setActivityEndTime(activityEndTime); activity.setGroupBuyNumber(mgtActivityEditDto.getGroupBuyNumber()); @@ -104,6 +160,19 @@ activity.setUpdateUserId(mgtActivityEditDto.getUserId()); activity.setUpdateTime(nowTime); activity.setRecommendFlag(mgtActivityEditDto.getRecommendFlag()); + if(activity.getAreaFlag()==2&&activity.getShopFlag()==1&&StringUtils.isNotBlank(activity.getDesignatedArea())){ + activity.setApplicableShop(""); + String designatedArea = activity.getDesignatedArea(); + List<String> cityCodes = Arrays.asList(designatedArea.split(",")); + List<Long> shopIdList = remoteShopService.listShopIdByCityCode(cityCodes).getData(); + if(shopIdList!=null&&!shopIdList.isEmpty()){ + String result = shopIdList.stream() + .map(String::valueOf) + .collect(Collectors.joining(",")); + activity.setApplicableShop(result); + } + } + activity.setActivityStatus(0); this.saveOrUpdate(activity); // 获取活动商品信息 List<MgtActivityGoodsEditDto> mgtActivityGoodsEditDtoList = mgtActivityEditDto.getMgtActivityGoodsEditDtoList(); @@ -118,8 +187,12 @@ activityGoods.setActivityPrice(dto.getActivityPrice()); activityGoods.setActivitySubscription(dto.getActivitySubscription()); activityGoods.setActivityNumber(dto.getActivityNumber()); + activityGoods.setActivityStock(dto.getActivityNumber()); + activityGoods.setSalesNumber(0); activityGoods.setActivityDeadline(activity.getActivityEndTime()); activityGoods.setSellOutFlag(0); + activityGoods.setPurchaseLimitationFlag(activity.getPurchaseLimitationFlag()); + activityGoods.setLimitNumber(activity.getLimitNumber()); return activityGoods; } ).collect(Collectors.toList()); @@ -127,5 +200,463 @@ activityGoodsService.saveBatch(activityGoodsList); } } + //如果活动在1小时内生成自动开始任务的延时任务 + Date checkTime = DateUtils.addMinutes(new Date(),61); + if(checkTime.compareTo(activityStartTime)>0){ + String activityId = activity.getActivityId(); + long currentTimeMillis = System.currentTimeMillis(); + long startTimeDifference = activityStartTime.getTime() - currentTimeMillis; + long endTimeDifference = activityEndTime.getTime() - currentTimeMillis; + //判断任务是否已经开始,已经开始则3秒后立即开始 + if(nowTime.compareTo(activityStartTime) > 0){ + // 查询延时任务 + DelayTask startDelayTask = remoteConfigService.getDelayTask(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId).getData(); + // 如果延时任务为空,创建延时任务控制活动定时开始和结束 + if (startDelayTask == null) { + redisService.setCacheObject(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId, activityStartTime, 3L, TimeUnit.SECONDS); + startDelayTask = new DelayTask(); + startDelayTask.setDelFlag(0); + startDelayTask.setCreateTime(new Date()); + startDelayTask.setEndTime(DateUtils.addSeconds(new Date(),3)); + startDelayTask.setRedisKey(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId); + remoteConfigService.addDelayTask(startDelayTask); + }else{ + if(startDelayTask.getEndTime().compareTo(activityStartTime)!=0){ + remoteConfigService.deleteDelayTask(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId); + redisService.deleteObject(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId); + redisService.setCacheObject(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId, activityStartTime, 3L, TimeUnit.SECONDS); + startDelayTask = new DelayTask(); + startDelayTask.setDelFlag(0); + startDelayTask.setCreateTime(new Date()); + startDelayTask.setEndTime(DateUtils.addSeconds(new Date(),3)); + startDelayTask.setRedisKey(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId); + remoteConfigService.addDelayTask(startDelayTask); + } + } + }else{ + // 查询延时任务 + DelayTask startDelayTask = remoteConfigService.getDelayTask(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId).getData(); + // 如果延时任务为空,创建延时任务控制活动定时开始和结束 + if (startDelayTask == null) { + redisService.setCacheObject(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId, activityStartTime, startTimeDifference, TimeUnit.MILLISECONDS); + startDelayTask = new DelayTask(); + startDelayTask.setDelFlag(0); + startDelayTask.setCreateTime(new Date()); + startDelayTask.setEndTime(activityStartTime); + startDelayTask.setRedisKey(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId); + remoteConfigService.addDelayTask(startDelayTask); + }else{ + if(startDelayTask.getEndTime().compareTo(activityStartTime)!=0){ + remoteConfigService.deleteDelayTask(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId); + redisService.deleteObject(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId); + redisService.setCacheObject(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId, activityStartTime, startTimeDifference, TimeUnit.MILLISECONDS); + startDelayTask = new DelayTask(); + startDelayTask.setDelFlag(0); + startDelayTask.setCreateTime(new Date()); + startDelayTask.setEndTime(activityStartTime); + startDelayTask.setRedisKey(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId); + remoteConfigService.addDelayTask(startDelayTask); + } + } + } + // 查询延时任务 + DelayTask endDelayTask = remoteConfigService.getDelayTask(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId).getData(); + // 如果延时任务为空,创建延时任务控制活动定时开始和结束 + if (endDelayTask == null) { + redisService.setCacheObject(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId, activityEndTime, endTimeDifference, TimeUnit.MILLISECONDS); + endDelayTask = new DelayTask(); + endDelayTask.setDelFlag(0); + endDelayTask.setCreateTime(new Date()); + endDelayTask.setEndTime(activityEndTime); + endDelayTask.setRedisKey(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId); + remoteConfigService.addDelayTask(endDelayTask); + }else{ + if(endDelayTask.getEndTime().compareTo(activityEndTime)!=0){ + remoteConfigService.deleteDelayTask(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId); + redisService.deleteObject(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId); + redisService.setCacheObject(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId, activityEndTime, startTimeDifference, TimeUnit.MILLISECONDS); + endDelayTask = new DelayTask(); + endDelayTask.setDelFlag(0); + endDelayTask.setCreateTime(new Date()); + endDelayTask.setEndTime(activityStartTime); + endDelayTask.setRedisKey(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId); + remoteConfigService.addDelayTask(endDelayTask); + } + } + } } + + /** + * @description 分页获取活动列表 + * @author jqs + * @date 2023/6/14 16:39 + * @param mgtActivityPageDto + * @return List<MgtActivityPageVo> + */ + @Override + public List<MgtActivityPageVo> pageMgtActivity(Page page, MgtActivityPageDto mgtActivityPageDto){ + List<MgtActivityPageVo> mgtActivityPageVoList = activityMapper.pageMgtActivity(page, mgtActivityPageDto); + return mgtActivityPageVoList; + } + + /** + * @description 获取活动编辑信息 + * @author jqs + * @date 2023/6/14 17:30 + * @param activityId + * @return MgtActivityGetVo + */ + @Override + public MgtActivityGetVo getMgtActivity(String activityId){ + MgtActivityGetVo mgtActivityGetVo = new MgtActivityGetVo(); + Activity activity = this.getById(activityId); + BeanUtils.copyProperties(activity, mgtActivityGetVo); + //活动关联商户 + if(activity.getShopFlag()==2&&StringUtils.isNotBlank(activity.getApplicableShop())){ + String applicableShop = activity.getApplicableShop(); + MgtBaseBathDto mgtBaseBathDto = new MgtBaseBathDto(); + mgtBaseBathDto.setIds(applicableShop); + List<MgtSimpleShopVo> mgtSimpleShopVoList= remoteShopService.listShopSimpleVoByIds(mgtBaseBathDto).getData(); + mgtActivityGetVo.setMgtSimpleShopVosList(mgtSimpleShopVoList); + } + //活动关联商品 + List<MgtActivityGoodsListVo> mgtActivityGoodsVoList = activityGoodsService.listVoByActivityId(activityId); + mgtActivityGetVo.setMgtActivityGoodsVoList(mgtActivityGoodsVoList); + return mgtActivityGetVo; + } + + /** + * @description 平台删除活动 + * @author jqs + * @date 2023/6/14 18:12 + * @param activityId + * @return void + */ + @Override + public void deleteMgtActivity(String activityId){ + Activity activity = this.getById(activityId); + if (activity.getActivityStatus() != 0) { + throw new ServiceException(AppErrorConstant.ACTIVITY_ING_DELETE); + } + activity.setDelFlag(1); + activity.setActivityStatus(-1); + this.saveOrUpdate(activity); + } + + /** + * @description 分页获取活动参与记录列表 + * @param mgtActivityRecordPageDto + * @return MgtActivityRecordPageVo + * @author jqs34 + * @date 2023/6/24 16:58 + */ + @Override + public List<MgtActivityRecordPageVo> pageMgtActivityRecord(Page page, MgtActivityRecordPageDto mgtActivityRecordPageDto){ + if(StringUtils.isNotBlank(mgtActivityRecordPageDto.getKeyword())){ + MgtUserIdByKeywordDto mgtUserIdByKeywordDto = new MgtUserIdByKeywordDto(); + mgtUserIdByKeywordDto.setKeyword(mgtActivityRecordPageDto.getKeyword()); + MgtUserIdByKeywordVo mgtUserIdByKeywordVo = remoteMemberService.getUserIdByKeyword(mgtUserIdByKeywordDto).getData(); + if(StringUtils.isNotBlank(mgtUserIdByKeywordVo.getUserIds())){ + mgtActivityRecordPageDto.setUserIds(mgtUserIdByKeywordVo.getUserIds()); + } + } + List<MgtActivityRecordPageVo> activityRecordPageVoList = activityMapper.pageMgtActivityRecord(page, mgtActivityRecordPageDto); + if(!activityRecordPageVoList.isEmpty()){ + // 定义变量 + HashSet<Long> userIdSet = new HashSet<>(); + // 遍历列表,用户 ID + for (MgtActivityRecordPageVo mgtActivityRecordPageVo : activityRecordPageVoList) { + userIdSet.add(mgtActivityRecordPageVo.getUserId()); + } + // 将店铺 ID 和用户 ID 转换为逗号分隔的字符串 + String userJoinedString = String.join(",", userIdSet.stream().map(Object::toString).collect(Collectors.toList())); + // 从远程服务获取店铺和用户信息 + MgtBaseBathDto mgtBaseBathDto = new MgtBaseBathDto(); + mgtBaseBathDto = new MgtBaseBathDto(); + mgtBaseBathDto.setIds(userJoinedString); + List<MgtSimpleMemberVo> simpleMemberVoList = remoteMemberService.listSimpleVoByIds(mgtBaseBathDto).getData(); + Map<Long, MgtSimpleMemberVo> userMap = simpleMemberVoList.stream() + .collect(Collectors.toMap(MgtSimpleMemberVo::getUserId, Function.identity())); + for (MgtActivityRecordPageVo mgtActivityRecordPageVo : activityRecordPageVoList) { + mgtActivityRecordPageVo.setNickName(userMap.get(mgtActivityRecordPageVo.getUserId()).getNickName()+"/"+(userMap.get(mgtActivityRecordPageVo.getUserId()).getRealName())); + mgtActivityRecordPageVo.setMobile(userMap.get(mgtActivityRecordPageVo.getUserId()).getUserMobile()); + } + } + return activityRecordPageVoList; + } + + /** + * @description 分页获取平台活动列表 + * @author jqs + * @date 2023/6/30 17:33 + * @param page + * @param merPageDto + * @return List<MerActivityPageVo> + */ + @Override + public List<MerActivityPageVo> pagePlatformMerActivity(Page page, MerPageDto merPageDto){ + List<MerActivityPageVo> activityPageVoList = activityMapper.pagePlatformMerActivity(page, merPageDto); + return activityPageVoList; + } + + /** + * @description 获取活动列表 + * @author jqs + * @date 2023/7/4 15:31 + * @param + * @return List<MgtActivityListVo> + */ + @Override + public List<MgtActivityListVo> listMgtActivity(){ + return activityMapper.listMgtActivity(); + } + + /** + * @description 获取商户推荐活动 + * @author jqs + * @date 2023/7/4 18:14 + * @param shopId + * @return Activity + */ + @Override + public Activity getRecommendActivity(Long shopId){ + return activityMapper.getRecommendActivity(shopId); + } + + /** + * @description 获取商户参与活动id + * @author jqs + * @date 2023/7/4 19:55 + * @param shopId + * @return List<Long> + */ + @Override + public List<String> listActivityIdByShopId(Long shopId){ + return activityMapper.listActivityIdByShopId(shopId); + } + + /** + * @description 分页获取活动列表 + * @author jqs + * @date 2023/7/5 18:45 + * @param page + * @param shopId + * @return List<AppActivityPageVo> + */ + @Override + public List<AppActivityPageVo> pageAppActivity(Page page, Long shopId){ + return activityMapper.pageAppActivity(page, shopId); + } + + /** + * @description 获取用户活动商品信息 + * @author jqs + * @date 2023/7/6 16:18 + * @param activityGoodsGetDto + * @return ActivityGoodsGetVo + */ + @Override + public ActivityGoodsGetVo getUserActivityGoods(ActivityGoodsGetDto activityGoodsGetDto){ + ActivityGoodsGetVo activityGoodsGetVo = new ActivityGoodsGetVo(); + String activityId = activityGoodsGetDto.getActivityId(); + String goodsId = activityGoodsGetDto.getGoodsId(); + Activity activity = this.getById(activityId); + //获取活动商品 + ActivityGoods activityGoods = activityGoodsService.getByGoodsId(activityId,goodsId); + activityGoodsGetVo.setActivityName(activity.getActivityName()); + activityGoodsGetVo.setActivityPrice(activityGoods.getActivityPrice()); + activityGoodsGetVo.setActivitySubscription(activityGoods.getActivitySubscription()); + activityGoodsGetVo.setActivityStatus(activity.getActivityStatus()); + //剩余库存 + Integer availableBuyNum = activityGoods.getActivityStock(); + //限购判断 + if(activityGoods.getPurchaseLimitationFlag()==1){ + Integer buyNum = activityRecordService.getUserActivityGoodsNum(goodsId,activityId,activityGoodsGetDto.getUserId()); + Integer limitBuyNum = activityGoods.getLimitNumber() - buyNum; + if(limitBuyNum<availableBuyNum){ + availableBuyNum = limitBuyNum; + } + } + activityGoodsGetVo.setPurchaseLimitationFlag(activity.getPurchaseLimitationFlag()); + activityGoodsGetVo.setAvailableBuyNum(availableBuyNum); + return activityGoodsGetVo; + } + + /** + * @description 活动定时开始 + * @author jqs + * @date 2023/7/12 19:44 + * @param + * @return void + */ + @Override + public void timingStartActivity(){ + // 创建LambdaQueryWrapper对象 + LambdaQueryWrapper<Activity> queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(Activity::getDelFlag, 0); + queryWrapper.eq(Activity::getActivityStatus, 0); + // 计算时间差 + Date checkTime = DateUtils.addMinutes(new Date(), 61); + queryWrapper.lt(Activity::getActivityStartTime, checkTime); + // 查询符合条件的活动列表 + List<Activity> activityList = activityMapper.selectList(queryWrapper); + // 如果活动列表不为空 + if (activityList != null && !activityList.isEmpty()) { + // 遍历活动列表 + for (Activity activity : activityList) { + String activityId = activity.getActivityId(); + Date activityStartTime = activity.getActivityStartTime(); + Date activityEndTime = activity.getActivityEndTime(); + long currentTimeMillis = System.currentTimeMillis(); + long startTimeDifference = activityStartTime.getTime() - currentTimeMillis; + long endTimeDifference = activityEndTime.getTime() - currentTimeMillis; + // 查询延时任务 + DelayTask startDelayTask = remoteConfigService.getDelayTask(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId).getData(); + // 如果延时任务为空,创建延时任务控制活动定时开始和结束 + if (startDelayTask == null) { + redisService.setCacheObject(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId, activityStartTime, startTimeDifference, TimeUnit.MILLISECONDS); + startDelayTask = new DelayTask(); + startDelayTask.setDelFlag(0); + startDelayTask.setCreateTime(new Date()); + startDelayTask.setEndTime(activityStartTime); + startDelayTask.setRedisKey(DelayTaskEnum.ACTIVITY_START_TASK.getCode() + "-" + activityId); + remoteConfigService.addDelayTask(startDelayTask); + } + // 查询延时任务 + DelayTask endDelayTask = remoteConfigService.getDelayTask(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId).getData(); + // 如果延时任务为空,创建延时任务控制活动定时开始和结束 + if (endDelayTask == null) { + redisService.setCacheObject(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId, activityEndTime, endTimeDifference, TimeUnit.MILLISECONDS); + endDelayTask = new DelayTask(); + endDelayTask.setDelFlag(0); + endDelayTask.setCreateTime(new Date()); + endDelayTask.setEndTime(activityEndTime); + endDelayTask.setRedisKey(DelayTaskEnum.ACTIVITY_END_TASK.getCode() + "-" + activityId); + remoteConfigService.addDelayTask(endDelayTask); + } + } + } + } + + /** + * @description 开始活动 + * @author jqs + * @date 2023/7/12 20:31 + * @param activityId + * @return void + */ + @Override + public void startActivity(String activityId){ + log.debug(activityId+"活动开始"); + Activity activity = this.getById(activityId); + if(activity!=null&&activity.getActivityStatus()==0){ + activity.setActivityStatus(1); + List<ActivityGoods> activityGoodsList = activityGoodsService.listByActivityId(activityId); + if(activityGoodsList!=null&&!activityGoodsList.isEmpty()){ + for(ActivityGoods activityGoods : activityGoodsList){ + redisService.setCacheObject(SecurityConstant.ACTIVITY_GOODS+"-"+activityId+"-"+activityGoods.getGoodsId(),activityGoods.getActivityStock()); + } + } + this.saveOrUpdate(activity); + } + } + + /** + * @description 结束活动 + * @author jqs + * @date 2023/7/12 20:31 + * @param activityId + * @return void + */ + @Override + public void endActivity(String activityId){ + Activity activity = this.getById(activityId); + if(activity!=null&&activity.getActivityStatus()==1){ + activity.setActivityStatus(2); + List<ActivityGoods> activityGoodsList = activityGoodsService.listByActivityId(activityId); + if(activityGoodsList!=null&&!activityGoodsList.isEmpty()){ + for(ActivityGoods activityGoods : activityGoodsList){ + redisService.deleteObject(SecurityConstant.ACTIVITY_GOODS+"-"+activityId+"-"+activityGoods.getGoodsId()); + } + } + this.saveOrUpdate(activity); + } + } + + /** + * @description 活动商品库存变化 + * @author jqs + * @date 2023/7/13 13:53 + * @param + * @return void + */ + @Override + public void changeActivityTotal(ActivityTotalChangeDto activityTotalChangeDto){ + log.debug("活动统计变化---"+activityTotalChangeDto.toString()); + RLock lock = redissonClient.getLock("activity_clock_"+activityTotalChangeDto.getActivityId()); + try { + lock.lock(30, TimeUnit.SECONDS); + //判断活动商品是否售罄,是则停止活动 + /*Integer noSellOut = activityMapper.checkSellOut(activityTotalChangeDto.getActivityId()); + if(noSellOut==0){ + endActivity(activityTotalChangeDto.getActivityId()); + }*/ + //更新活动统计 + ActivityTotal activityTotal = activityTotalService.getById(activityTotalChangeDto.getActivityId()); + if(activityTotalChangeDto.getChangeType()==1){ + activityTotal.setOrderTotal(activityTotal.getOrderTotal()+activityTotalChangeDto.getChangeNum()); + activityTotal.setPersonTotal(activityTotal.getPersonTotal()+activityTotalChangeDto.getPersonNum()); + activityTotal.setOrderMoneyTotal(activityTotal.getOrderMoneyTotal().add(activityTotalChangeDto.getMoney())); + }else{ + activityTotal.setOrderTotal(activityTotal.getOrderTotal()-activityTotalChangeDto.getChangeNum()); + activityTotal.setPersonTotal(activityTotal.getPersonTotal()-activityTotalChangeDto.getPersonNum()); + activityTotal.setRefundTotal(activityTotal.getRefundTotal()+activityTotalChangeDto.getRefundNum()); + activityTotal.setOrderMoneyTotal(activityTotal.getOrderMoneyTotal().subtract(activityTotalChangeDto.getMoney())); + } + activityTotalService.saveOrUpdate(activityTotal); + } finally { + lock.unlock(); + } + } + + /** + * @description 活动商品库存变化 + * @author jqs + * @date 2023/7/13 13:53 + * @param + * @return void + */ + @Override + public void changeActivityStock(AGStockChangeDto agStockChangeDto){ + RLock lock = redissonClient.getLock("stock_clock_"+agStockChangeDto.getActivityId()+"_"+agStockChangeDto.getGoodsId()); + try { + lock.lock(30, TimeUnit.SECONDS); + if(agStockChangeDto.getChangeType()==1){ + //减少销量增加库存 + activityMapper.addActivityGoodsStock(agStockChangeDto); + }else{ + //增加销量减少库存 + activityMapper.subActivityGoodsStock(agStockChangeDto); + } + } finally { + lock.unlock(); + } + } + + /** + * @description 获取活动列表 + * @author jqs + * @date 2023/7/17 14:46 + * @param staffActivityListDto + * @return List<MgtActivityListVo> + */ + @Override + public List<MgtActivityListVo> listStaffActivity(StaffActivityListDto staffActivityListDto){ + List<MgtActivityListVo> activityListVoList = new ArrayList<>(); + if(staffActivityListDto.getActivityFrom()!=null&&staffActivityListDto.getActivityFrom()==1){ + activityListVoList = activityMapper.listStaffActivity(staffActivityListDto); + } + return activityListVoList; + } + } -- Gitblit v1.7.1