Merge remote-tracking branch 'origin/master'

This commit is contained in:
张松 2025-02-20 10:02:44 +08:00
commit f389516732
14 changed files with 410 additions and 17 deletions

View File

@ -4,6 +4,7 @@ import com.czg.log.annotation.OperationLog;
import com.czg.product.dto.ProdSkuDTO; import com.czg.product.dto.ProdSkuDTO;
import com.czg.product.dto.ProductDTO; import com.czg.product.dto.ProductDTO;
import com.czg.product.param.ProductIsSaleParam; import com.czg.product.param.ProductIsSaleParam;
import com.czg.product.param.ProductIsSoldOutParam;
import com.czg.product.service.ProductService; import com.czg.product.service.ProductService;
import com.czg.resp.CzgResult; import com.czg.resp.CzgResult;
import com.czg.utils.AssertUtil; import com.czg.utils.AssertUtil;
@ -97,4 +98,15 @@ public class ProductController {
return CzgResult.success(); return CzgResult.success();
} }
/**
* 商品-标记售罄
*/
@PostMapping("/markIsSoldOut")
@OperationLog("商品-标记售罄")
//@SaAdminCheckPermission("product:markIsSoldOut")
public CzgResult<Void> markIsSoldOutProduct(@RequestBody @Validated({DefaultGroup.class}) ProductIsSoldOutParam param) {
productService.markProductIsSoldOut(param);
return CzgResult.success();
}
} }

View File

@ -2,13 +2,16 @@ package com.czg.controller.user;
import com.czg.log.annotation.OperationLog; import com.czg.log.annotation.OperationLog;
import com.czg.product.param.MiniHomeProductParam; import com.czg.product.param.MiniHomeProductParam;
import com.czg.product.param.ShopProductSkuParam;
import com.czg.product.service.UProductService; import com.czg.product.service.UProductService;
import com.czg.product.vo.MiniAppHomeProductVo; import com.czg.product.vo.*;
import com.czg.product.vo.ShopGroupProductVo;
import com.czg.product.vo.ShopProductVo;
import com.czg.resp.CzgResult; import com.czg.resp.CzgResult;
import com.czg.utils.AssertUtil;
import com.czg.validator.ValidatorUtil;
import com.czg.validator.group.DefaultGroup;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
@ -58,4 +61,28 @@ public class UProductController {
return CzgResult.success(list); return CzgResult.success(list);
} }
/**
* 小程序点餐-商品详情
*
* @param id 商品id
*/
@GetMapping("/miniApp/info/{id}")
@OperationLog("小程序点餐-商品详情")
public CzgResult<ShopProductInfoVo> getProductInfo(@PathVariable("id") Long id) {
AssertUtil.isNull(id, "商品id不能为空");
ShopProductInfoVo data = uProductService.getProductInfo(id);
return CzgResult.success(data);
}
/**
* 小程序点餐-商品SKU详情
*/
@GetMapping("/miniApp/sku/info")
@OperationLog("小程序点餐-商品SKU详情")
public CzgResult<ShopProductSkuInfoVo> getProductSkuInfo(ShopProductSkuParam param) {
ValidatorUtil.validateEntity(param, DefaultGroup.class);
ShopProductSkuInfoVo data = uProductService.getProductSkuInfo(param);
return CzgResult.success(data);
}
} }

View File

@ -90,7 +90,8 @@ public class OperationLogAspect {
} }
//登录用户信息 //登录用户信息
Long shopId = StpKit.USER.getShopId();
Long shopId = StpKit.USER.getShopId(0L);
Long createUserId = StpKit.USER.getLoginIdAsLong(); Long createUserId = StpKit.USER.getLoginIdAsLong();
//TODO SA-TOKEN 暂未整合当前登录人信息此处仅为临时账号 //TODO SA-TOKEN 暂未整合当前登录人信息此处仅为临时账号
String createUserName = "temp-account"; String createUserName = "temp-account";

View File

@ -0,0 +1,46 @@
package com.czg.product.param;
import com.czg.validator.group.DefaultGroup;
import jakarta.validation.constraints.Max;
import jakarta.validation.constraints.Min;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotNull;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
/**
* 商品标记售罄参数
*
* @author tankaikai
* @since 2025-02-18 17:46
*/
@Data
public class ProductIsSoldOutParam implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* 售罄类型 product-商品 sku-SKU
*/
@NotBlank(message = "售罄类型不能为空", groups = DefaultGroup.class)
private String type;
/**
* 商品id/sku id
*/
@NotNull(message = "商品id/sku-id不能为空", groups = DefaultGroup.class)
private Long id;
/**
* 是否售罄 1-0-
*/
@NotNull(message = "是否售罄不能为空", groups = DefaultGroup.class)
@Min(value = 0, message = "是否售罄必须是0或1", groups = DefaultGroup.class)
@Max(value = 1, message = "是否售罄必须是0或1", groups = DefaultGroup.class)
private Integer isSoldOut;
}

View File

@ -0,0 +1,31 @@
package com.czg.product.param;
import com.czg.validator.group.DefaultGroup;
import jakarta.validation.constraints.NotNull;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
/**
* 商品SKU查询参数
*
* @author tankaikai
* @since 2025-02-19 09:23
*/
@Data
public class ShopProductSkuParam implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* 商品id
*/
@NotNull(message = "商品id不能为空", groups = DefaultGroup.class)
private Long id;
/**
* 选中的规格名称单规格传null,多规格如选择微辣+常温则传递微辣,常温顺序不能变
*/
private String specInfo;
}

View File

@ -3,6 +3,7 @@ package com.czg.product.service;
import com.czg.product.dto.ProductDTO; import com.czg.product.dto.ProductDTO;
import com.czg.product.entity.Product; import com.czg.product.entity.Product;
import com.czg.product.param.ProductIsSaleParam; import com.czg.product.param.ProductIsSaleParam;
import com.czg.product.param.ProductIsSoldOutParam;
import com.mybatisflex.core.paginate.Page; import com.mybatisflex.core.paginate.Page;
import com.mybatisflex.core.service.IService; import com.mybatisflex.core.service.IService;
@ -28,4 +29,6 @@ public interface ProductService extends IService<Product> {
boolean deleteProduct(Long id); boolean deleteProduct(Long id);
boolean onOffProduct(ProductIsSaleParam param); boolean onOffProduct(ProductIsSaleParam param);
boolean markProductIsSoldOut(ProductIsSoldOutParam param);
} }

View File

@ -2,9 +2,8 @@ package com.czg.product.service;
import com.czg.product.entity.Product; import com.czg.product.entity.Product;
import com.czg.product.param.MiniHomeProductParam; import com.czg.product.param.MiniHomeProductParam;
import com.czg.product.vo.MiniAppHomeProductVo; import com.czg.product.param.ShopProductSkuParam;
import com.czg.product.vo.ShopGroupProductVo; import com.czg.product.vo.*;
import com.czg.product.vo.ShopProductVo;
import com.mybatisflex.core.service.IService; import com.mybatisflex.core.service.IService;
import java.util.List; import java.util.List;
@ -21,4 +20,8 @@ public interface UProductService extends IService<Product> {
List<ShopProductVo> queryHotsProductList(); List<ShopProductVo> queryHotsProductList();
List<ShopGroupProductVo> queryGroupProductList(); List<ShopGroupProductVo> queryGroupProductList();
ShopProductInfoVo getProductInfo(Long id);
ShopProductSkuInfoVo getProductSkuInfo(ShopProductSkuParam param);
} }

View File

@ -0,0 +1,115 @@
package com.czg.product.vo;
import cn.hutool.core.convert.Convert;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.annotation.JSONField;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
import java.math.BigDecimal;
import java.time.LocalTime;
/**
* 商品规格详情
*
* @author tankaikai
* @since 2025-02-19 09:23
*/
@Data
public class ShopProductInfoVo implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* 商品id
*/
private Long id;
/**
* 商品名称
*/
private String name;
/**
* 短标题--促销语
*/
private String shortTitle;
/**
* 封面图url
*/
private String coverImg;
/**
* 商品图集
*/
private Object images;
/**
* 单位名称
*/
private String unitName;
/**
* 原价
*/
private BigDecimal originPrice;
/**
* 销售价
*/
private BigDecimal salePrice;
/**
* 会员价
*/
private BigDecimal memberPrice;
/**
* 是否售罄 1- 0-
*/
private Integer isSoldStock;
/**
* 库存数量
*/
private Integer stockNumber;
/**
* 商品类型 single-单规格商品 sku-多规格商品 package-套餐商品 weight-称重商品 coupon-团购券
*/
private String type;
/**
* 套餐类型 0-固定套餐 1-可选套餐
*/
private String groupType;
/**
* 是否可售时间 1- 0-
*/
private Integer isSaleTime;
/**
* 起售数量
*/
private Integer suitNum;
/**
* 商品规格
*/
private Object selectSpecInfo;
/**
* 商品每周销售日 Monday,Tuesday,Wednesday,Thursday,Friday,Saturday,Sunday
*/
@JSONField(serialize = false)
private String days;
/**
* 可售卖起始时间
*/
@JSONField(serialize = false)
private LocalTime startTime;
/**
* 可售卖截止时间
*/
@JSONField(serialize = false)
private LocalTime endTime;
public Object getImages() {
return JSON.parseArray(Convert.toStr(images, "[]"));
}
/**
* {"口味":[{"甜度":["少甜","中甜","多甜"]},{"辣度":["微辣","重辣","变态辣"]},{"小料":["葱花","香菜","折耳根"]}]}
*/
public Object getSelectSpecInfo() {
return JSON.parseObject(Convert.toStr(selectSpecInfo, "{}"));
}
}

View File

@ -0,0 +1,77 @@
package com.czg.product.vo;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
import java.math.BigDecimal;
/**
* 商品SKU详情
*
* @author tankaikai
* @since 2025-02-19 09:23
*/
@Data
public class ShopProductSkuInfoVo implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* id
*/
private Long id;
/**
* 条形码
*/
private String barCode;
/**
* 商品Id
*/
private Long productId;
/**
* 原价
*/
private BigDecimal originPrice;
/**
* 成本价
*/
private BigDecimal costPrice;
/**
* 会员价
*/
private BigDecimal memberPrice;
/**
* 售价
*/
private BigDecimal salePrice;
/**
* 起售数量
*/
private Integer suitNum;
/**
* 规格详情
*/
private String specInfo;
/**
* 商品封面图
*/
private String coverImg;
/**
* 重量
*/
private BigDecimal weight;
/**
* 销量
*/
private BigDecimal realSalesNumber;
/**
* 是否售罄
*/
private Integer isPauseSale;
/**
* 商品库存
*/
private Integer stockNumber;
}

View File

@ -28,6 +28,10 @@ public class ShopProductVo implements Serializable {
* 商品名称 * 商品名称
*/ */
private String name; private String name;
/**
* sku id
*/
private Long skuId;
/** /**
* 原价 * 原价
*/ */

View File

@ -1,6 +1,7 @@
package com.czg.service.product.mapper; package com.czg.service.product.mapper;
import com.czg.product.entity.Product; import com.czg.product.entity.Product;
import com.czg.product.vo.ShopProductInfoVo;
import com.czg.product.vo.ShopProductVo; import com.czg.product.vo.ShopProductVo;
import com.mybatisflex.core.BaseMapper; import com.mybatisflex.core.BaseMapper;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
@ -20,4 +21,6 @@ public interface ProductMapper extends BaseMapper<Product> {
List<ShopProductVo> selectHotsProductList(@Param("shopId") Long shopId); List<ShopProductVo> selectHotsProductList(@Param("shopId") Long shopId);
List<ShopProductVo> selectGroupProductList(@Param("shopId") Long shopId); List<ShopProductVo> selectGroupProductList(@Param("shopId") Long shopId);
ShopProductInfoVo selectOneProductInfo(@Param("id") Long id, @Param("shopId") Long shopId);
} }

View File

@ -16,6 +16,7 @@ import com.czg.product.entity.Product;
import com.czg.product.enums.ProductIsSaleTypeEnum; import com.czg.product.enums.ProductIsSaleTypeEnum;
import com.czg.product.enums.ProductTypeEnum; import com.czg.product.enums.ProductTypeEnum;
import com.czg.product.param.ProductIsSaleParam; import com.czg.product.param.ProductIsSaleParam;
import com.czg.product.param.ProductIsSoldOutParam;
import com.czg.product.service.ProductService; import com.czg.product.service.ProductService;
import com.czg.sa.StpKit; import com.czg.sa.StpKit;
import com.czg.service.product.mapper.ProdSkuMapper; import com.czg.service.product.mapper.ProdSkuMapper;
@ -256,23 +257,38 @@ public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> impl
String type = param.getType(); String type = param.getType();
Long id = param.getId(); Long id = param.getId();
Integer isSale = param.getIsSale(); Integer isSale = param.getIsSale();
UpdateChain.of(ProdSku.class)
.set(ProdSku::getIsGrounding, isSale)
.eq(ProdSku::getId, id)
.update();
if (ProductIsSaleTypeEnum.PRODUCT.value().equals(type)) { if (ProductIsSaleTypeEnum.PRODUCT.value().equals(type)) {
UpdateChain.of(Product.class) UpdateChain.of(Product.class)
.set(Product::getIsSale, isSale) .set(Product::getIsSale, isSale)
.eq(Product::getId, id) .eq(Product::getId, id)
.eq(Product::getShopId, shopId) .eq(Product::getShopId, shopId)
.update(); .update();
UpdateChain.of(ProdSku.class)
.set(ProdSku::getIsGrounding, isSale)
.eq(ProdSku::getProductId, id)
.update();
} else if (ProductIsSaleTypeEnum.SKU.value().equals(type)) {
UpdateChain.of(ProdSku.class)
.set(ProdSku::getIsGrounding, isSale)
.eq(ProdSku::getId, id)
.update();
} }
return true; return true;
} }
@Override
@Transactional(rollbackFor = Exception.class)
public boolean markProductIsSoldOut(ProductIsSoldOutParam param) {
Long shopId = StpKit.USER.getLoginIdAsLong();
String type = param.getType();
Long id = param.getId();
Integer isSoldOut = param.getIsSoldOut();
UpdateChain.of(ProdSku.class)
.set(ProdSku::getIsPauseSale, isSoldOut)
.eq(ProdSku::getProductId, id)
.update();
if (ProductIsSaleTypeEnum.PRODUCT.value().equals(type)) {
UpdateChain.of(Product.class)
.set(Product::getIsSoldStock, isSoldOut)
.eq(Product::getId, id)
.eq(Product::getShopId, shopId)
.update();
}
return true;
}
} }

View File

@ -6,13 +6,16 @@ import cn.hutool.core.util.StrUtil;
import com.czg.enums.DeleteEnum; import com.czg.enums.DeleteEnum;
import com.czg.enums.StatusEnum; import com.czg.enums.StatusEnum;
import com.czg.enums.YesNoEnum; import com.czg.enums.YesNoEnum;
import com.czg.exception.CzgException;
import com.czg.product.dto.ProdSkuDTO; import com.czg.product.dto.ProdSkuDTO;
import com.czg.product.dto.ProductDTO; import com.czg.product.dto.ProductDTO;
import com.czg.product.entity.ProdGroup; import com.czg.product.entity.ProdGroup;
import com.czg.product.entity.ProdGroupRelation; import com.czg.product.entity.ProdGroupRelation;
import com.czg.product.entity.ProdSku; import com.czg.product.entity.ProdSku;
import com.czg.product.entity.Product; import com.czg.product.entity.Product;
import com.czg.product.enums.ProductTypeEnum;
import com.czg.product.param.MiniHomeProductParam; import com.czg.product.param.MiniHomeProductParam;
import com.czg.product.param.ShopProductSkuParam;
import com.czg.product.service.UProductService; import com.czg.product.service.UProductService;
import com.czg.product.vo.*; import com.czg.product.vo.*;
import com.czg.sa.StpKit; import com.czg.sa.StpKit;
@ -197,6 +200,43 @@ public class UProductServiceImpl extends ServiceImpl<ProductMapper, Product> imp
return groupList.stream().filter(group -> CollUtil.isNotEmpty(group.getProductList())).toList(); return groupList.stream().filter(group -> CollUtil.isNotEmpty(group.getProductList())).toList();
} }
@Override
public ShopProductInfoVo getProductInfo(Long id) {
Long shopId = StpKit.USER.getShopId(0L);
ShopProductInfoVo data = productMapper.selectOneProductInfo(id, shopId);
if (data == null) {
throw new CzgException("商品不可售");
}
return data;
}
@Override
public ShopProductSkuInfoVo getProductSkuInfo(ShopProductSkuParam param) {
Long shopId = StpKit.USER.getShopId(0L);
Product product = productMapper.selectOneById(param.getId());
if (product == null) {
throw new CzgException("商品信息不存在");
}
String specInfo = StrUtil.blankToDefault(param.getSpecInfo(), null);
ShopProductSkuInfoVo data = prodSkuMapper.selectOneByQueryAs(
query().eq(ProdSku::getProductId, param.getId())
.eq(ProdSku::getShopId, shopId)
.eq(ProdSku::getIsDel, DeleteEnum.NORMAL.value())
.eq(ProdSku::getIsGrounding, YesNoEnum.YES.value())
.eq(ProdSku::getSpecInfo, specInfo)
, ShopProductSkuInfoVo.class);
if (data == null) {
throw new CzgException("商品SKU不可售或不存在");
}
if (ProductTypeEnum.SINGLE.value().equals(product.getType())) {
data.setStockNumber(product.getStockNumber());
} else {
// TODO 临时数据后续对接库存系统
data.setStockNumber(1000);
}
return data;
}
/** /**
* 计算是否在可售时间内 * 计算是否在可售时间内
* *

View File

@ -5,10 +5,13 @@
<sql id="shopProductQuery"> <sql id="shopProductQuery">
select t1.id, select t1.id,
t1.name, t1.name,
t1.short_title,
t2.sku_id,
t2.origin_price, t2.origin_price,
t2.sale_price, t2.sale_price,
t2.member_price, t2.member_price,
t1.cover_img, t1.cover_img,
t1.images,
t3.name as unit_name, t3.name as unit_name,
t1.is_sold_stock, t1.is_sold_stock,
t1.stock_number, t1.stock_number,
@ -17,9 +20,11 @@
t1.days, t1.days,
t1.start_time, t1.start_time,
t1.end_time, t1.end_time,
ifnull(t2.suit_num, 1) as suit_num ifnull(t2.suit_num, 1) as suit_num,
t1.select_spec_info
from tb_product t1 from tb_product t1
left join (select x.product_id, left join (select x.product_id,
x.id as sku_id,
MIN(x.sale_price) as sale_price, MIN(x.sale_price) as sale_price,
x.origin_price, x.origin_price,
x.member_price, x.member_price,
@ -53,4 +58,14 @@
</where> </where>
order by t1.sort desc,t1.id desc order by t1.sort desc,t1.id desc
</select> </select>
<select id="selectOneProductInfo" resultType="com.czg.product.vo.ShopProductInfoVo">
<include refid="shopProductQuery"/>
<where>
and t1.is_del = 0
and t1.is_sale = 1
and t2.sale_price is not null
and t1.shop_id = #{shopId}
and t1.id = #{id}
</where>
</select>
</mapper> </mapper>