package com.iotechn.unimall.app.api.product;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.dobbinsoft.fw.core.exception.ServiceException;
|
import com.dobbinsoft.fw.support.component.CacheComponent;
|
import com.dobbinsoft.fw.support.model.Page;
|
import com.iotechn.unimall.biz.service.footprint.FootprintBizService;
|
import com.iotechn.unimall.biz.service.freight.FreightTemplateBizService;
|
import com.iotechn.unimall.biz.service.groupshop.GroupShopBizService;
|
import com.iotechn.unimall.biz.service.product.ProductBizService;
|
import com.iotechn.unimall.data.constant.CacheConst;
|
import com.iotechn.unimall.data.domain.SkuDO;
|
import com.iotechn.unimall.data.domain.SpuAttributeDO;
|
import com.iotechn.unimall.data.domain.SpuDO;
|
import com.iotechn.unimall.data.domain.SpuSpecificationDO;
|
import com.iotechn.unimall.data.dto.product.GroupShopDTO;
|
import com.iotechn.unimall.data.dto.product.SpuDTO;
|
import com.iotechn.unimall.data.enums.BizType;
|
import com.iotechn.unimall.data.enums.SpuActivityType;
|
import com.iotechn.unimall.data.mapper.*;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.TransactionStatus;
|
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
|
import org.springframework.transaction.support.TransactionTemplate;
|
|
import java.util.List;
|
|
|
/**
|
* Created by rize on 2019/7/2.
|
*/
|
@Service
|
public class ProductServiceImpl implements ProductService {
|
|
@Autowired
|
private ProductBizService productBizService;
|
|
@Autowired
|
private CacheComponent cacheComponent;
|
|
@Autowired
|
private SpuMapper spuMapper;
|
|
@Autowired
|
private ImgMapper imgMapper;
|
|
@Autowired
|
private SkuMapper skuMapper;
|
|
@Autowired
|
private SpuAttributeMapper spuAttributeMapper;
|
|
@Autowired
|
private SpuSpecificationMapper spuSpecificationMapper;
|
|
@Autowired
|
private FootprintBizService footprintBizService;
|
|
@Autowired
|
private GroupShopBizService groupShopBizService;
|
|
@Autowired
|
private FreightTemplateBizService freightTemplateBizService;
|
|
@Autowired
|
private TransactionTemplate transactionTemplate;
|
|
@Override
|
public Page<SpuDO> getProductPage(Integer pageNo, Integer pageSize, Long categoryId, String orderBy, Boolean isAsc, String title) throws ServiceException {
|
if (categoryId != null && categoryId <= 0) {
|
categoryId = null;
|
}
|
return productBizService.getProductPage(pageNo, pageSize, categoryId, orderBy, isAsc, title);
|
}
|
|
@Override
|
public SpuDTO getProduct(Long spuId, Long userId) throws ServiceException {
|
// 1. 获取基本信息
|
SpuDTO spuDTO = productBizService.getProductByIdFromCache(spuId);
|
// 2.
|
// 2.1. 封装其他信息，此类属性只能在管理员编辑界面统一编辑改变，不能由用户行为改变
|
SpuDTO detailSpuInfo = cacheComponent.getHashObj(CacheConst.PRT_SPU_DETAIL_HASH_BUCKET, "P" + spuId, SpuDTO.class);
|
if (detailSpuInfo == null) {
|
// 从DB中封装属性
|
detailSpuInfo = new SpuDTO();
|
// 1. SkuDOList
|
List<SkuDO> skuDOList = skuMapper.selectList(new QueryWrapper<SkuDO>().eq("spu_id", spuDTO.getId()));
|
detailSpuInfo.setSkuList(skuDOList);
|
// 2. 图片列表
|
List<String> imgs = imgMapper.getImgs(BizType.GOODS.getCode(), spuId);
|
detailSpuInfo.setImgList(imgs);
|
// 3. 设置detail
|
SpuDO spuLoadDetail = spuMapper.selectOne(new QueryWrapper<SpuDO>().select("detail").eq("id", spuId));
|
detailSpuInfo.setDetail(spuLoadDetail.getDetail());
|
// 4. 设置商品属性
|
List<SpuAttributeDO> attributeList = spuAttributeMapper.selectList(new QueryWrapper<SpuAttributeDO>().eq("spu_id", spuId));
|
detailSpuInfo.setAttributeList(attributeList);
|
// 5. 设置商品规格
|
List<SpuSpecificationDO> specificationList = spuSpecificationMapper.selectList(new QueryWrapper<SpuSpecificationDO>().eq("spu_id", spuId));
|
detailSpuInfo.setSpecificationList(specificationList);
|
cacheComponent.putHashObj(CacheConst.PRT_SPU_DETAIL_HASH_BUCKET, "P" + spuId, detailSpuInfo);
|
}
|
// 2.2. 记住忽略以上 N 个属性
|
BeanUtils.copyProperties(spuDTO, detailSpuInfo, "skuList", "imgList", "detail", "attributeList", "specificationList");
|
spuDTO = detailSpuInfo;
|
// 3. 封装各个Sku的库存
|
spuDTO.getSkuList().forEach(item -> {
|
String stockStr = cacheComponent.getHashRaw(CacheConst.PRT_SKU_STOCK_BUCKET, "K" + item.getId());
|
if (stockStr == null) {
|
// 几乎不可能。这次判断是悲观考虑
|
transactionTemplate.execute(new TransactionCallbackWithoutResult() {
|
@Override
|
protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
|
// 在事务中，获取最新的值
|
Integer stockForUpdate = skuMapper.getStockForUpdate(item.getId());
|
cacheComponent.putHashRaw(CacheConst.PRT_SKU_STOCK_BUCKET, "K" + item.getId(), stockForUpdate + "");
|
item.setStock(stockForUpdate);
|
}
|
});
|
} else {
|
Integer stock = Integer.parseInt(stockStr);
|
item.setStock(stock);
|
}
|
});
|
// 4. 运费模板 MicroFix 运费模板存在RPC。建议移动到detailSpuInfo中，但是编辑运费模板的时候需要删除detailSpuInfo的缓存
|
spuDTO.setFreightTemplate(freightTemplateBizService.getFreightTemplateById(spuDTO.getFreightTemplateId()));
|
if (userId != null) {
|
// 添加用户足迹 & 封装用户是否LIKE此商品
|
footprintBizService.newFootprint(spuId, userId);
|
spuDTO.setFavorite(cacheComponent.getHashRaw(CacheConst.PRT_USER_FAVORITE_HASH_BUCKET + spuId, "U" + userId) != null);
|
}
|
// 5. 封装活动信息
|
if (spuDTO.getActivityType() != null && spuDTO.getActivityType() != SpuActivityType.NONE.getCode()
|
&& spuDTO.getGmtActivityEnd() != null && spuDTO.getGmtActivityEnd().getTime() > System.currentTimeMillis()) {
|
// 若存在正在进行的活动，封装活动实例。这里活动的缓存应该由各个活动BizService内部决定是否使用缓存？如何设计缓存？
|
if (spuDTO.getActivityType() == SpuActivityType.GROUP_SHOP.getCode()) {
|
GroupShopDTO groupShopDTO = groupShopBizService.getGroupShopById(spuDTO.getActivityId());
|
spuDTO.setActivity(groupShopDTO);
|
}
|
}
|
return spuDTO;
|
}
|
}
|
