java/LiquorAuction.git

			@@ -2,31 +2,42 @@

			import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.fasterxml.jackson.core.JsonProcessingException;
			import com.fasterxml.jackson.databind.ObjectMapper;
			import com.ruoyi.common.core.constant.CacheConstants;
			import com.ruoyi.common.core.constant.SecurityConstants;
			import com.ruoyi.common.core.enums.ListingStatusEnum;
			import com.ruoyi.common.core.enums.StartStatusEnum;
			import com.ruoyi.common.core.exception.ServiceException;
			import com.ruoyi.common.core.utils.StringUtils;
			import com.ruoyi.common.core.utils.page.BeanUtils;
			import com.ruoyi.common.core.utils.page.PageDTO;
			import com.ruoyi.common.redis.service.RedisService;
			import com.ruoyi.goods.controller.management.DTO.GoodsSeckillDTO;
			import com.ruoyi.goods.controller.management.DTO.GoodsSeckillQuery;
			import com.ruoyi.goods.controller.management.DTO.GoodsSeckillUpd;
			import com.ruoyi.goods.controller.management.VO.GoodsSeckillVO;
			import com.ruoyi.goods.domain.GoodsSeckill;
			import com.ruoyi.goods.domain.GoodsSku;
			import com.ruoyi.goods.controller.management.dto.GoodsSeckillDTO;
			import com.ruoyi.goods.controller.management.dto.GoodsSeckillQuery;
			import com.ruoyi.goods.controller.management.dto.GoodsSeckillUpd;
			import com.ruoyi.goods.controller.management.vo.GoodsSeckillVO;
			import com.ruoyi.goods.mapper.GoodsSeckillMapper;
			import com.ruoyi.goods.service.IGoodsSeckillService;
			import com.ruoyi.goods.service.IGoodsSkuService;
			import com.ruoyi.goods.service.async.AsyncMethodService;
			import com.ruoyi.system.api.constants.DelayTaskEnum;
			import com.ruoyi.system.api.constants.NotificationTypeConstant;
			import com.ruoyi.system.api.domain.GoodsSeckill;
			import com.ruoyi.system.api.domain.GoodsSku;
			import com.ruoyi.system.api.domain.dto.ListStatusDTO;
			import com.ruoyi.system.api.feignClient.OrderClient;
			import com.ruoyi.system.api.feignClient.SysUserClient;
			import java.time.LocalDateTime;
			import java.util.List;
			import java.util.Map;
			import java.util.Optional;
			import java.util.concurrent.ConcurrentHashMap;
			import lombok.RequiredArgsConstructor;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;
			import util.WebSocketUsers;

			/**
			* <p>
			@@ -44,8 +55,10 @@
			private final IGoodsSkuService goodsSkuService;
			private final OrderClient orderClient;
			private final RedisService redisService;
			private final SysUserClient sysUserClient;
			private final AsyncMethodService asyncMethodService;

			// 创建一个静态共享的ObjectMapper实例以重用
			private static final ObjectMapper objectMapper = new ObjectMapper();
			@Override
			@Transactional(rollbackFor = Exception.class)
			public void addGoodsSeckill(GoodsSeckillDTO dto) {
			@@ -99,7 +112,10 @@
			//查询秒杀商品
			GoodsSeckill goodsSeckill = this.getById(upd.getId());
			if (StringUtils.isNull(goodsSeckill)) {
			throw new RuntimeException("秒杀商品不存在");
			throw new ServiceException("秒杀商品不存在");
			}
			if (goodsSeckill.getStartStatus().equals(StartStatusEnum.STARTED)) {
			throw new ServiceException("秒杀商品已开始秒杀，不能修改");
			}
			GoodsSeckill goodsSeckillUpd = BeanUtils.copyBean(upd, GoodsSeckill.class);
			this.updateById(goodsSeckillUpd);
			@@ -113,10 +129,21 @@
			*/
			@Override
			public void updStatus(ListStatusDTO dto) {
			GoodsSeckill goodsSeckill = this.getById(dto.getId());
			if (StringUtils.isNull(goodsSeckill)) {
			throw new ServiceException("秒杀商品不存在");
			}
			this.lambdaUpdate()
			.eq(GoodsSeckill::getId, dto.getId())
			.set(GoodsSeckill::getListingStatus, dto.getListingStatus())
			.update();
			if (dto.getListingStatus().equals(ListingStatusEnum.REMOVED_FROM_THE_SHELF)) {
			//移除该秒杀商品的延时任务
			redisService.deleteObject(
			DelayTaskEnum.SECKILL_START_TASK.getCode() + "-" + goodsSeckill.getId());
			redisService.deleteObject(
			DelayTaskEnum.SECKILL_END_TASK.getCode() + "-" + goodsSeckill.getId());
			}
			}

			/**
			@@ -129,12 +156,13 @@
			public GoodsSeckillVO getDetail(Long id) {
			GoodsSeckill goodsSeckill = this.getById(id);
			if (StringUtils.isNull(goodsSeckill)) {
			throw new RuntimeException("秒杀商品不存在");
			throw new ServiceException("秒杀商品不存在");
			}
			GoodsSeckillVO vo = BeanUtils.copyBean(goodsSeckill, GoodsSeckillVO.class);
			GoodsSku goods = goodsSkuService.getById(goodsSeckill.getGoodsSkuId());
			Optional.of(goods).ifPresent(goodsSku -> vo.setGoodsSkuName(goodsSku.getSkuName()));
			Integer num = orderClient.getSeckillMembers(goodsSeckill.getGoodsSkuId()).getData();
			Integer num = orderClient.getSeckillMembers(goodsSeckill.getGoodsSkuId(),
			SecurityConstants.INNER).getData();
			vo.setNumberOfPurchasedMembers(num);
			return vo;
			}
			@@ -145,7 +173,7 @@
			* @param seckillId 秒杀id
			*/
			@Override
			public void startSeckill(Long seckillId) {
			public void startSeckill(Long seckillId) throws JsonProcessingException {
			log.info(">>>>>>>>>>>>>>>>>>>>{}秒杀开始<<<<<<<<<<<<<<<<<<<<", seckillId);
			GoodsSeckill goodsSeckill = this.getById(seckillId);
			//秒杀商品不能为空且状态为未开始
			@@ -159,7 +187,14 @@
			CacheConstants.SECKILL_GOODS + goodsSeckill.getId(),
			goodsSeckill.getSeckillStock());
			}
			//TODO websocket 推送秒杀开始消息
			//推送秒杀开始消息
			Map<String, Object> map = new ConcurrentHashMap<>();
			map.put("notification_type", NotificationTypeConstant.SECKILL);
			map.put("notification_time", LocalDateTime.now());
			map.put("message_type", "start");
			String msg = objectMapper.writeValueAsString(map);
			WebSocketUsers.sendMessageToUsersByText(msg);
			log.info("===================>发送websocket通知，消息体{}", msg);
			}

			/**
			@@ -168,7 +203,7 @@
			* @param seckillId 秒杀id
			*/
			@Override
			public void endSeckill(Long seckillId) {
			public void endSeckill(Long seckillId) throws JsonProcessingException {
			log.info(">>>>>>>>>>>>>>>>>>>>{}秒杀结束<<<<<<<<<<<<<<<<<<<<", seckillId);
			GoodsSeckill goodsSeckill = this.getById(seckillId);
			if (StringUtils.isNotNull(goodsSeckill)
			@@ -179,6 +214,12 @@
			// 将秒杀商品从缓存中移除
			redisService.deleteObject(CacheConstants.SECKILL_GOODS + goodsSeckill.getId());
			}
			//TODO websocket 推送秒杀结束消息
			Map<String, Object> map = new ConcurrentHashMap<>();
			map.put("notification_type", NotificationTypeConstant.SECKILL);
			map.put("notification_time", LocalDateTime.now());
			map.put("message_type", "end");
			String msg = objectMapper.writeValueAsString(map);
			WebSocketUsers.sendMessageToUsersByText(msg);
			log.info("===================>发送websocket通知，消息体{}", msg);
			}
			}