package com.ruoyi.goods.service.impl.activity;
|
|
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.util.*;
|
import java.util.concurrent.TimeUnit;
|
import java.util.function.Function;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 活动 服务实现类
|
* </p>
|
*
|
* @author jqs
|
* @since 2023-05-25
|
*/
|
@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(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;
|
}
|
}
|
