From 0571bf579557ec97682a8940e29ed19699f6d95e Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期一, 30 六月 2025 10:16:32 +0800
Subject: [PATCH] 修改bug
---
ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/activity/ActivityServiceImpl.java | 836 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 833 insertions(+), 3 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 5a0aa94..b49f53d 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,10 +1,52 @@
package com.ruoyi.goods.service.impl.activity;
-import com.ruoyi.goods.domain.pojo.activity.Activity;
-import com.ruoyi.goods.mapper.activity.ActivityMapper;
-import com.ruoyi.goods.service.activity.ActivityService;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.common.core.constant.Constants;
+import com.ruoyi.common.core.domain.R;
+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.common.redis.service.RedisService;
+import com.ruoyi.goods.domain.dto.*;
+import com.ruoyi.system.api.domain.poji.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.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.poji.goods.Goods;
+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.*;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+import java.util.function.Function;
+import java.util.stream.Collectors;
/**
* <p>
@@ -17,4 +59,792 @@
@Service
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;
+
+ @Resource
+ private RemoteOrderService remoteOrderService;
+
+ @Resource
+ private RemoteGoodsService remoteGoodsService;
+
+ @Autowired
+ private RedissonClient redissonClient;
+
+ @Resource
+ private RemoteFileService remoteFileService;
+
+ /**
+ * @param mgtActivityEditDto
+ * @return void
+ * @description 平台编辑活动
+ * @author jqs
+ * @date 2023/6/14 15:12
+ */
+ @Override
+ public void editMgtActivity(MgtActivityEditDto mgtActivityEditDto) {
+ 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())) {
+ // 获取活动信息
+ activity = this.getById(mgtActivityEditDto.getActivityId());
+ if(activity.getDelFlag() == 1){
+ throw new ServiceException(AppErrorConstant.ACTIVITY_DEL);
+ }
+ if(activity.getActivityStatus() == 2){
+ throw new ServiceException(AppErrorConstant.ACTIVITY_END);
+ }
+ //校验可以修改的项
+ if(activity.getActivityStatus() == 1){
+ /**
+ * 1、活动时间：已经开始活动开始时间不可修改，结束时间不能小于当前时间
+ * 2、是否限购
+ * - 不限购：无法修改。
+ * - 限购：只能增加
+ * 3、适用地区
+ * - 全部地区：无法修改。
+ * - 指定地区：只能新增
+ * 4、适用店铺
+ * - 全部店铺：无法修改
+ * - 指定店铺：只能新增
+ * 5、秒杀库存：只能增加
+ * 6、活动名称、宣传海报、是否推荐、活动简介：可直接修改
+ * 7、秒杀价和定金不能修改
+ */
+ if(activity.getActivityStartTime().getTime() != mgtActivityEditDto.getActivityStartTime().getTime()){
+ throw new ServiceException("活动开始后无法修改开始时间");
+ }
+ if(System.currentTimeMillis() >= mgtActivityEditDto.getActivityEndTime().getTime()){
+ throw new ServiceException("活动结束时间必须大于当前时间");
+ }
+ if(activity.getPurchaseLimitationFlag() == 0 && activity.getPurchaseLimitationFlag().compareTo(mgtActivityEditDto.getPurchaseLimitationFlag()) != 0){
+ throw new ServiceException("不能修改限购配置");
+ }
+ if(activity.getPurchaseLimitationFlag() == 1 && mgtActivityEditDto.getLimitNumber().compareTo(activity.getLimitNumber()) < 0){
+ throw new ServiceException("限购数量不能小于原始数量");
+ }
+ if(activity.getAreaFlag() == 1 && activity.getAreaFlag().compareTo(mgtActivityEditDto.getAreaFlag()) != 0){
+ throw new ServiceException("不能修改适用地区配置");
+ }
+ if(activity.getAreaFlag() == 2){
+ List<String> list = Arrays.asList(activity.getDesignatedArea().split(","));
+ List<String> list1 = Arrays.asList(mgtActivityEditDto.getDesignatedArea().split(","));
+ for (String s : list) {
+ if(!list1.contains(s)){
+ throw new ServiceException("适用地区只能增加");
+ }
+ }
+ }
+ if(activity.getShopFlag() == 1 && activity.getShopFlag().compareTo(mgtActivityEditDto.getShopFlag()) != 0){
+ throw new ServiceException("不能修改适用店铺配置");
+ }
+ if(activity.getShopFlag() == 2){
+ List<String> list = Arrays.asList(activity.getApplicableShop().split(","));
+ List<String> list1 = Arrays.asList(mgtActivityEditDto.getApplicableShop().split(","));
+ for (String s : list) {
+ if(!list1.contains(s)){
+ throw new ServiceException("适用店铺只能增加");
+ }
+ }
+ }
+
+ List<MgtActivityGoodsEditDto> mgtActivityGoodsEditDtoList = mgtActivityEditDto.getMgtActivityGoodsEditDtoList();
+ List<String> collect = mgtActivityGoodsEditDtoList.stream().map(MgtActivityGoodsEditDto::getGoodsId).collect(Collectors.toList());
+ List<ActivityGoods> list = activityGoodsService.list(new QueryWrapper<ActivityGoods>()
+ .eq("del_flag", 0)
+ .eq("activity_id", activity.getActivityId())
+ );
+ for (ActivityGoods activityGoods : list) {
+ String goodsId = activityGoods.getGoodsId();
+ BigDecimal activitySubscription1 = activityGoods.getActivitySubscription();
+ BigDecimal activityPrice1 = activityGoods.getActivityPrice();
+ Integer activityNumber1 = activityGoods.getActivityNumber();
+ if(!collect.contains(goodsId)){
+ throw new ServiceException("只能新增商品数据");
+ }
+ for (MgtActivityGoodsEditDto mgtActivityGoodsEditDto : mgtActivityGoodsEditDtoList) {
+ String goodsId1 = mgtActivityGoodsEditDto.getGoodsId();
+ BigDecimal activityPrice = mgtActivityGoodsEditDto.getActivityPrice();
+ BigDecimal activitySubscription = mgtActivityGoodsEditDto.getActivitySubscription();
+ Integer activityNumber = mgtActivityGoodsEditDto.getActivityNumber();
+ if(null != activitySubscription && null != activitySubscription1 &&
+ goodsId.equals(goodsId1) && activitySubscription1.compareTo(activitySubscription) != 0){
+ throw new ServiceException("不能修改定金");
+ }
+ if(goodsId.equals(goodsId1) && activityPrice1.compareTo(activityPrice) != 0){
+ throw new ServiceException("不能修改秒杀价");
+ }
+ if(goodsId.equals(goodsId1) && activityNumber1.compareTo(activityNumber) > 0){
+ throw new ServiceException("只能增加商品库存");
+ }
+ }
+ }
+ }
+ } else {
+ // 如果活动ID为空，则表示新增活动信息
+ activity = new Activity();
+ // 生成活动ID
+ String activityId = IdUtils.simpleUUID();
+ activity.setActivityId(activityId);
+ activity.setDelFlag(0);
+ activity.setCreateUserId(mgtActivityEditDto.getUserId());
+ activity.setCreateTime(nowTime);
+ ActivityTotal activityTotal = new ActivityTotal();
+ activityTotal.setActivityId(activityId);
+ activityTotal.setOrderTotal(0);
+ activityTotal.setPersonTotal(0);
+ 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);
+ activity.setActivityStatus(0);
+ }
+ // 获取活动开始时间和结束时间
+ Date activityStartTime = mgtActivityEditDto.getActivityStartTime();
+ Date activityEndTime = mgtActivityEditDto.getActivityEndTime();
+ // 根据当前时间和活动时间判断活动状态
+ /*if (nowTime.compareTo(activityStartTime) < 0) {
+ activity.setActivityStatus(0);
+ } else {
+ activity.setActivityStatus(1);
+
+ }*/
+ // 设置活动信息
+ activity.setActivityName(mgtActivityEditDto.getActivityName());
+ activity.setActivityIntroduce(mgtActivityEditDto.getActivityIntroduce());
+ activity.setActivityStartTime(activityStartTime);
+ activity.setActivityEndTime(activityEndTime);
+ activity.setGroupBuyNumber(mgtActivityEditDto.getGroupBuyNumber());
+ activity.setPurchaseLimitationFlag(mgtActivityEditDto.getPurchaseLimitationFlag());
+ activity.setLimitNumber(mgtActivityEditDto.getLimitNumber());
+ activity.setPropagandaPoster(mgtActivityEditDto.getPropagandaPoster());
+ activity.setAreaFlag(mgtActivityEditDto.getAreaFlag());
+ activity.setDesignatedArea(mgtActivityEditDto.getDesignatedArea());
+ activity.setShopFlag(mgtActivityEditDto.getShopFlag());
+ activity.setApplicableShop(mgtActivityEditDto.getApplicableShop());
+ 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);
+ }
+ }
+ this.saveOrUpdate(activity);
+ // 获取活动商品信息
+ List<MgtActivityGoodsEditDto> mgtActivityGoodsEditDtoList = mgtActivityEditDto.getMgtActivityGoodsEditDtoList();
+
+ //存储需要更新缓存的库存数量
+ List<Map<String, Object>> goods = new ArrayList<>();
+ // 如果活动商品信息不为空，则保存活动商品信息
+ if (!mgtActivityGoodsEditDtoList.isEmpty()) {
+ List<ActivityGoods> activityGoodsList = mgtActivityGoodsEditDtoList.stream().map(
+ dto -> {
+ ActivityGoods activityGoods = activityGoodsService.getOne(new LambdaQueryWrapper<ActivityGoods>()
+ .eq(ActivityGoods::getActivityId, activity.getActivityId())
+ .eq(ActivityGoods::getGoodsId, dto.getGoodsId())
+ .eq(ActivityGoods::getDelFlag, 0)
+ );
+ int number = 0;
+ if(null != activityGoods){
+ //剩余数量
+ Integer surpNum = redisService.getCacheObject(SecurityConstant.ACTIVITY_GOODS + "-" + activity.getActivityId() + "-" + dto.getGoodsId());
+ surpNum = null == surpNum ? 0 : surpNum;
+ number = surpNum + (dto.getActivityNumber() - activityGoods.getActivityNumber());
+ activityGoods.setActivityId(activity.getActivityId());
+ activityGoods.setActivityPrice(dto.getActivityPrice());
+ activityGoods.setActivitySubscription(dto.getActivitySubscription());
+ activityGoods.setActivityNumber(dto.getActivityNumber());
+ activityGoods.setActivityStock(dto.getActivityNumber());
+ activityGoods.setActivityDeadline(activity.getActivityEndTime());
+ activityGoods.setPurchaseLimitationFlag(activity.getPurchaseLimitationFlag());
+ activityGoods.setLimitNumber(activity.getLimitNumber());
+ }else{
+ number = dto.getActivityNumber();
+ activityGoods = new ActivityGoods();
+ activityGoods.setDelFlag(0);
+ activityGoods.setGoodsId(dto.getGoodsId());
+ activityGoods.setActivityId(activity.getActivityId());
+ 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());
+ }
+ Map<String, Object> map = new HashMap<>();
+ map.put("goodsId", dto.getGoodsId());
+ map.put("number", number);
+ goods.add(map);
+ return activityGoods;
+ }
+ ).collect(Collectors.toList());
+ if (!activityGoodsList.isEmpty()) {
+ activityGoodsService.saveOrUpdateBatch(activityGoodsList);
+ }
+ }
+
+ //进行中的活动更新缓存中库存数量
+ if(activity.getActivityStatus() == 1){
+ for (Map<String, Object> good : goods) {
+ String goodsId = good.get("goodsId").toString();
+ Integer number = Integer.valueOf(good.get("number").toString());
+ redisService.setCacheObject(SecurityConstant.ACTIVITY_GOODS+"-"+activity.getActivityId()+"-"+goodsId,number);
+ }
+ }
+
+ //如果活动在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;
+ startTimeDifference = startTimeDifference < 0 ? 3L : startTimeDifference;
+ 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, 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/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);
+ //活动结束
+ endActivity(activityId);
+ }
+
+ /**
+ * @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(userJoinedString).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(MgtActivityListDto mgtActivityListDto){
+ List<MgtActivityListVo> activityListVoList = new ArrayList<>();
+ if(mgtActivityListDto.getActivityFrom()!=null&&mgtActivityListDto.getActivityFrom()!=2){
+ activityListVoList = activityMapper.listMgtActivity();
+ }
+ return activityListVoList;
+ }
+
+ /**
+ * @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
+ @Transactional(propagation = Propagation.REQUIRES_NEW)
+ 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;
+ }
+
+
+ /**
+ * @description 判断商户是否在活动范围
+ * @author jqs
+ * @date 2023/9/7 14:13
+ * @param merActivityShopDto
+ * @return Boolean
+ */
+ @Override
+ public Boolean judgeActivityShop(MerActivityShopDto merActivityShopDto){
+ Boolean judge = false;
+ Long shopId = merActivityShopDto.getShopId();
+ Activity activity = this.getById(merActivityShopDto.getActivityId());
+ //判断是否全部商户
+ if(activity.getAreaFlag()==1&&activity.getShopFlag()==1){
+ judge = true;
+ }else{
+ //判断是否在商户范围内
+ String applicableShop = activity.getApplicableShop();
+ applicableShop = ","+applicableShop+",";
+ judge = applicableShop.contains(","+shopId.toString()+",");
+ }
+ return judge;
+ }
+
+ /**
+ * 立即结束活动
+ * @param mgtBaseGetDto
+ */
+ @Override
+ public R endImmediately(MgtBaseGetDto mgtBaseGetDto) {
+ Activity activity = this.getById(mgtBaseGetDto.getId());
+ if(null == activity){
+ return R.fail("活动不存在");
+ }
+ //判断是否在活动中
+ Date now = new Date();
+ if (now.before(activity.getActivityStartTime())||now.after(activity.getActivityEndTime())){
+ return R.fail("未在活动时间范围内，不能执行立即结束操作");
+ }
+ activity.setActivityEndTime(now);
+ activity.setUpdateTime(now);
+ activity.setUpdateUserId(mgtBaseGetDto.getUserId());
+ this.updateById(activity);
+ return R.ok();
+ }
}
--
Gitblit v1.7.1