czk
/
one_mall
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

秒杀 #3

Merged
czk merged 1 commits from czk into main 2024-04-24 14:41:49 +08:00
Conversation 0 Commits 1 Files Changed 20
20 changed files with 707 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
mall_common/src/main/java/com/mall/common/domain/request/SpikesRequest.java 100644
View File

@ -0,0 +1,74 @@
package com.mall.common.domain.request;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.boot.autoconfigure.batch.BatchDataSource;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
/**
*Spikes接参
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class SpikesRequest {
/**
* 商品主图
*/
private String spikesImg;
/**
* 轮播图
*/
private String spikesManyImg;
/**
* 商品标题
*/
private String spikesTitle;
/**
* 秒杀活动简介
*/
private String spikesThings;
/**
* 单位
*/
private String spikesUnit;
/**
* 当天参与活动次数
*/
private Integer spikesNum;
/**
* 创建时间
*/
private Date createTime;
/**
* 结束时间
*/
private Date endTime;
/**
* 状态(0已开启1为开启)
*/
private Integer spikesState;
/**
* spuId
*/
private Long spuId;
/**
* 秒杀商品信息
*/
private List<Sku> skuList;
@Data
public static class Sku{
private Long skuId; //商品id
private BigDecimal activityPrice; //秒杀价格
private Integer inventoryRestrict; //限制数量
}
}

92
mall_common/src/main/java/com/mall/common/domain/vo/ActivitySkuVo.java 100644
View File

@ -0,0 +1,92 @@
package com.mall.common.domain.vo;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
import java.util.Date;
/**
*活动商品信息Vo
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class ActivitySkuVo {
/**
* id
*/
private Long id;
/**
* spuId
*/
private Long spuId;
/**
* sku名称
*/
private String name;
/**
* 所属分类id
*/
private Long categoryId;
/**
* 品牌id
*/
private Long brandId;
/**
* 默认图片
*/
private String defaultImage;
/**
* 标题
*/
private String title;
/**
* 副标题
*/
private String subtitle;
/**
* 价格
*/
private BigDecimal price;
/**
* 活动价格
*/
private BigDecimal activityPrice;
/**
* 重量（克）
*/
private Integer weight;
/**
* 库存
*/
private Integer inventory;
/**
* 库存限制量
*/
private Integer inventoryRestrict;
/**
* 秒杀id（0未开启秒杀）
*/
private Integer spikesId;
/**
* 砍价id（0未开启砍价）
*/
private Integer bargainId;
/**
* 拼团id（0未开启拼团）
*/
private Integer groupId;
/**
* 秒杀开始时间
*/
private Date startTime;
/**
* 秒杀结束时间
*/
private Date endTime;
}

8
mall_modules/mall_server/pom.xml
View File

@ -52,10 +52,10 @@
<version>1.2</version>
</dependency>
<!-- seata事务-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
<!-- <dependency>-->
<!-- <groupId>com.alibaba.cloud</groupId>-->
<!-- <artifactId>spring-cloud-starter-alibaba-seata</artifactId>-->
<!-- </dependency>-->
<!-- canal-->
<dependency>
<groupId>top.javatool</groupId>

13
mall_modules/mall_server/src/main/java/com/mall/server/ServerApplication.java 100644
View File

@ -0,0 +1,13 @@
package com.mall.server;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
*server启动类
*/
@SpringBootApplication
public class ServerApplication {
public static void main(String[] args) {
SpringApplication.run(ServerApplication.class,args);
}
}

39
mall_modules/mall_server/src/main/java/com/mall/server/aop/LogAnnotationAspect.java 100644
View File

@ -0,0 +1,39 @@
package com.mall.server.aop;
import com.mall.common.utils.JwtUtils;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.Map;
/**
*aop
*/
@Aspect
@Component
@Slf4j
public class LogAnnotationAspect {
@Pointcut("execution(* com.mall.server.service.impl.*.*(..))")
private void allMethod(){}
//应用周围通知
@Around("allMethod()")
public void doAround(ProceedingJoinPoint call) throws Throwable{
long start = new Date().getTime();
String methodName = call.getSignature().getName(); // 获取方法名
Object[] args = call.getArgs(); // 获取方法的参数
call.proceed();
long end = new Date().getTime();
log.info("耗时："+(end-start)/1000+"秒");
log.info(methodName+"()方法执行");
for (Object arg : args) {
log.info("参数："+String.valueOf(arg));
}
}
}

30
mall_modules/mall_server/src/main/java/com/mall/server/controller/SpikesController.java 100644
View File

@ -0,0 +1,30 @@
package com.mall.server.controller;
import com.mall.common.domain.request.SpikesRequest;
import com.mall.common.result.Result;
import com.mall.server.service.SpikesService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
*秒杀controller
*/
@RestController
@RequestMapping("spikes")
public class SpikesController {
@Autowired
private SpikesService spikesService;
/**
* 添加秒杀场次
* @param spikesRequest
* @return
*/
@PostMapping("add")
public Result add(@RequestBody SpikesRequest spikesRequest){
return spikesService.add(spikesRequest);
}
}

84
mall_modules/mall_server/src/main/java/com/mall/server/domain/SkuEntity.java 100644
View File

@ -0,0 +1,84 @@
package com.mall.server.domain;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
/**
*商品Sku
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@TableName("pms_sku")
public class SkuEntity {
/**
* id
*/
private Long id;
/**
* spuId
*/
private Long spuId;
/**
* sku名称
*/
private String name;
/**
* 所属分类id
*/
private Long categoryId;
/**
* 品牌id
*/
private Long brandId;
/**
* 默认图片
*/
private String defaultImage;
/**
* 标题
*/
private String title;
/**
* 副标题
*/
private String subtitle;
/**
* 价格
*/
private BigDecimal price;
/**
* 活动价格
*/
private BigDecimal activityPrice;
/**
* 重量（克）
*/
private Integer weight;
/**
* 库存
*/
private Integer inventory;
/**
* 库存限制量
*/
private Integer inventoryRestrict;
/**
* 秒杀id（0未开启秒杀）
*/
private Integer spikesId;
/**
* 砍价id（0未开启砍价）
*/
private Integer bargainId;
/**
* 拼团id（0未开启拼团）
*/
private Integer groupId;
}

67
mall_modules/mall_server/src/main/java/com/mall/server/domain/SpikesEntity.java 100644
View File

@ -0,0 +1,67 @@
package com.mall.server.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
*秒杀表
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@TableName("pms_spikes")
public class SpikesEntity {
/**
* 秒杀id
*/
@TableId(type = IdType.AUTO)
private Long spikesId;
/**
* 商品主图
*/
private String spikesImg;
/**
* 轮播图
*/
private String spikesManyImg;
/**
* 商品标题
*/
private String spikesTitle;
/**
* 秒杀活动简介
*/
private String spikesThings;
/**
* 单位
*/
private String spikesUnit;
/**
* 当天参与活动次数
*/
private Integer spikesNum;
/**
* 创建时间
*/
private Date createTime;
/**
* 结束时间
*/
private Date endTime;
/**
* 状态(0已开启1为开启)
*/
private Integer spikesState;
/**
* 0未删除1已删除
*/
private Integer isDelete;
}

52
mall_modules/mall_server/src/main/java/com/mall/server/domain/SpuEntity.java 100644
View File

@ -0,0 +1,52 @@
package com.mall.server.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
*商品Spu
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@TableName("pms_spu")
public class SpuEntity {
/**
* id
*/
@TableId(type = IdType.AUTO)
private Long id;
/**
* 商品名称
*/
private String name;
/**
*所属分类id
*/
private Long categoryId;
/**
*品牌id
*/
private Long brandId;
/**
*上架状态[0 - 下架，1 - 上架]
*/
private Integer publishStatus;
/**
*创建时间
*/
private Date createTime;
/**
*更新时间
*/
private Date updateTime;
}

38
mall_modules/mall_server/src/main/java/com/mall/server/enumerate/ActivityEnum.java 100644
View File

@ -0,0 +1,38 @@
package com.mall.server.enumerate;
import lombok.Data;
/**
*
*/
public enum ActivityEnum {
SPIKES(0,"秒杀未开启"),
BARGAIN(0,"砍价未开启"),
GROUP(0,"拼团未开启");
private Integer code;
private String msg;
ActivityEnum(Integer code, String msg) {
this.code = code;
this.msg = msg;
}
public Integer getCode() {
return code;
}
public void setCode(Integer code) {
this.code = code;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
}

12
mall_modules/mall_server/src/main/java/com/mall/server/mapper/SkuMapper.java 100644
View File

@ -0,0 +1,12 @@
package com.mall.server.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.mall.server.domain.SkuEntity;
import org.apache.ibatis.annotations.Mapper;
/**
*商品SkuMapperr
*/
@Mapper
public interface SkuMapper extends BaseMapper<SkuEntity> {
}

12
mall_modules/mall_server/src/main/java/com/mall/server/mapper/SpikesMapper.java 100644
View File

@ -0,0 +1,12 @@
package com.mall.server.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.mall.server.domain.SpikesEntity;
import org.apache.ibatis.annotations.Mapper;
/**
* 秒杀表mapper
*/
@Mapper
public interface SpikesMapper extends BaseMapper<SpikesEntity> {
}

12
mall_modules/mall_server/src/main/java/com/mall/server/mapper/SpuMapper.java 100644
View File

@ -0,0 +1,12 @@
package com.mall.server.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.mall.server.domain.SpuEntity;
import org.apache.ibatis.annotations.Mapper;
/**
*商品spuMapper
*/
@Mapper
public interface SpuMapper extends BaseMapper<SpuEntity> {
}

10
mall_modules/mall_server/src/main/java/com/mall/server/service/SkuService.java 100644
View File

@ -0,0 +1,10 @@
package com.mall.server.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.mall.server.domain.SkuEntity;
/**
*商品SkuService
*/
public interface SkuService extends IService<SkuEntity> {
}

14
mall_modules/mall_server/src/main/java/com/mall/server/service/SpikesService.java 100644
View File

@ -0,0 +1,14 @@
package com.mall.server.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.mall.common.domain.request.SpikesRequest;
import com.mall.common.result.Result;
import com.mall.server.domain.SpikesEntity;
/**
*秒杀service
*/
public interface SpikesService extends IService<SpikesEntity> {
Result add(SpikesRequest spikesRequest);
}

10
mall_modules/mall_server/src/main/java/com/mall/server/service/SpuService.java 100644
View File

@ -0,0 +1,10 @@
package com.mall.server.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.mall.server.domain.SpuEntity;
/**
*商品spuService
*/
public interface SpuService extends IService<SpuEntity> {
}

14
mall_modules/mall_server/src/main/java/com/mall/server/service/impl/SkuServiceImpl.java 100644
View File

@ -0,0 +1,14 @@
package com.mall.server.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.mall.server.domain.SkuEntity;
import com.mall.server.mapper.SkuMapper;
import com.mall.server.service.SkuService;
import org.springframework.stereotype.Service;
/**
*商品SkuServiceImpl
*/
@Service
public class SkuServiceImpl extends ServiceImpl<SkuMapper, SkuEntity>
implements SkuService {
}

107
mall_modules/mall_server/src/main/java/com/mall/server/service/impl/SpikesServiceImpl.java 100644
View File

@ -0,0 +1,107 @@
package com.mall.server.service.impl;
import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.mall.common.domain.request.SpikesRequest;
import com.mall.common.domain.vo.ActivitySkuVo;
import com.mall.common.redis.RedisCache;
import com.mall.common.result.Result;
import com.mall.server.domain.SkuEntity;
import com.mall.server.domain.SpikesEntity;
import com.mall.server.enumerate.ActivityEnum;
import com.mall.server.mapper.SpikesMapper;
import com.mall.server.service.SkuService;
import com.mall.server.service.SpikesService;
import com.mall.server.service.SpuService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.BoundZSetOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
/**
*秒杀serviceImpl
*/
@Service
public class SpikesServiceImpl extends ServiceImpl<SpikesMapper, SpikesEntity>
implements SpikesService {
@Autowired
private SpikesMapper spikesMapper;
@Autowired
private SpuService spuService;
@Autowired
private SkuService skuService;
@Autowired
private RedisCache redisCache;
@Autowired
private RedisTemplate redisTemplate;
@Transactional
@Override
public Result add(SpikesRequest spikesRequest) {
//秒杀表信息
int spikesId = spikesMapper.insert(
SpikesEntity.builder()
.spikesImg(spikesRequest.getSpikesImg())
.spikesManyImg(spikesRequest.getSpikesManyImg())
.spikesTitle(spikesRequest.getSpikesTitle())
.spikesThings(spikesRequest.getSpikesThings())
.spikesUnit(spikesRequest.getSpikesUnit())
.spikesNum(spikesRequest.getSpikesNum())
.createTime(spikesRequest.getCreateTime())
.endTime(spikesRequest.getEndTime())
.spikesState(spikesRequest.getSpikesState())
.build()
);
//修改sku商品信息
skuService.updateBatchById(
spikesRequest.getSkuList().stream().map(c->
SkuEntity.builder()
.id(c.getSkuId())
.inventoryRestrict(c.getInventoryRestrict())
.activityPrice(c.getActivityPrice())
.spikesId(spikesId).build()
).collect(Collectors.toList())
);
//遍历修改后的sku商品信息作转换
List<ActivitySkuVo> activitySkuVoList = skuService.list(
new LambdaQueryWrapper<SkuEntity>()
.eq(SkuEntity::getSpikesId, spikesId)
).stream().map(c ->
ActivitySkuVo.builder()
.id(c.getId())
.spuId(c.getSpuId())
.name(c.getName())
.categoryId(c.getCategoryId())
.brandId(c.getBrandId())
.defaultImage(c.getDefaultImage())
.title(c.getTitle())
.subtitle(c.getSubtitle())
.price(c.getPrice())
.activityPrice(c.getActivityPrice())
.weight(c.getWeight())
.inventory(c.getInventory())
.inventoryRestrict(c.getInventoryRestrict())
.spikesId(c.getSpikesId())
.bargainId(c.getBargainId())
.groupId(c.getGroupId())
.startTime(spikesRequest.getCreateTime())
.endTime(spikesRequest.getEndTime()).build()).collect(Collectors.toList());
activitySkuVoList.forEach(c->{
//redis秒杀信息存在时间
long expire = c.getEndTime().getTime() - System.currentTimeMillis()/1000/1000;
redisCache.setCacheObject("spikes_"+c.getId(),c,expire, TimeUnit.MINUTES);
});
return Result.success(true,"添加秒杀成功");
}
}

16
mall_modules/mall_server/src/main/java/com/mall/server/service/impl/SpuServiceImpl.java 100644
View File

@ -0,0 +1,16 @@
package com.mall.server.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.mall.server.domain.SpuEntity;
import com.mall.server.mapper.SpuMapper;
import com.mall.server.service.SpuService;
import org.springframework.stereotype.Service;
/**
*商品spuServiceImpl
*/
@Service
public class SpuServiceImpl extends ServiceImpl<SpuMapper, SpuEntity>
implements SpuService {
}

7
mall_modules/mall_server/src/main/resources/META-INF/spring.factories 100644
View File

@ -0,0 +1,7 @@
# Auto Configure
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.mall.common.config.MybatisPlusConfig,\
com.mall.common.config.RedisConfig,\
com.mall.common.redis.RedisCache,\
com.mall.common.config.ThreadPoolConfig,\
com.mall.common.handler.GlobalExceptionHandler