电商业务中台OMS全渠道订单管理系统

package org.skyer.goods.app.service.impl; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.json.JSONUtil; import com.alibaba.fastjson.JSON; import lombok.extern.slf4j.Slf4j; import org.apache.commons.compress.utils.Lists; import org.apache.commons.lang3.StringUtils; import org.skyer.core.cache.ProcessCacheValue; import org.skyer.core.domain.Page; import org.skyer.core.domain.PageInfo; import org.skyer.core.exception.CommonException; import org.skyer.core.oauth.CustomUserDetails; import org.skyer.core.oauth.DetailsHelper; import org.skyer.goods.api.dto.*; import org.skyer.goods.app.service.SkuEsService; import org.skyer.goods.app.service.SkuService; import org.skyer.goods.domain.dto.AuditDTO; import org.skyer.goods.domain.dto.SkuAuditDTO; import org.skyer.goods.domain.entity.*; import org.skyer.goods.domain.repository.*; import org.skyer.goods.domain.vo.*; import org.skyer.goods.infra.util.Md5Utils; import org.skyer.mybatis.domian.Condition; import org.skyer.mybatis.util.Sqls; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.support.TransactionSynchronizationAdapter; import org.springframework.transaction.support.TransactionSynchronizationManager; import org.springframework.util.ObjectUtils; import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; import java.util.stream.Stream; import static org.skyer.goods.domain.entity.Sku.*; /** * 商品规格表应用服务默认实现 * * @author chenzz 2021-07-06 10:35:43 */ @Slf4j @Service public class SkuServiceImpl implements SkuService { @Autowired private SkuRepository skuRepository; @Autowired private SkuAttributeValueRepository skuAttributeValueRepository; @Autowired private SkuDraftRepository skuDraftRepository; @Autowired private SkuAttributeValueDraftRepository skuAttributeValueDraftRepository; @Autowired private SkuAuditSettingRepository skuAuditSettingRepository; @Autowired private SpuRepository spuRepository; @Autowired private CategoryRepository categoryRepository; @Autowired private MaterialRepository materialRepository; @Autowired private BrandRepository brandRepository; @Autowired private SkuEsService skuEsService; @Autowired private SkuPackageRepository skuPackageRepository; @Override public Page<GoodsSkuPageVO> listPage(GoodsSkuPageDTO goodsSkuPageDTO) { if (CollUtil.isNotEmpty(goodsSkuPageDTO.getCategoryIdList())) { goodsSkuPageDTO.setCategoryIdList(categoryRepository.getLaterCategoryId(goodsSkuPageDTO.getCategoryIdList())); } Page<Sku> pageList = skuRepository.pageSku(goodsSkuPageDTO); List<Sku> skuList = pageList.getContent(); List<GoodsSkuPageVO> pageVOS = new ArrayList<>(); if (CollUtil.isNotEmpty(skuList)) { // 找出所有的商品数据 Set<Long> goodsIds = skuList.stream().map(Sku::getSpuId).collect(Collectors.toSet()); List<Spu> spuList = spuRepository.selectByCondition(Condition.builder(Spu.class) .andWhere(Sqls.custom() .andIn(org.skyer.goods.domain.entity.Spu.ID, goodsIds, true) .andEqualTo(org.skyer.goods.domain.entity.Spu.DELETE_FLAG, false)) .build()); // 找出所有素材 Set<Long> materialIds = spuList.stream().map(Spu::getMaterialId).collect(Collectors.toSet()); List<Material> materialList = materialRepository.selectByCondition(Condition.builder(Material.class) .andWhere(Sqls.custom() .andIn("id", materialIds, true) .andEqualTo(org.skyer.goods.domain.entity.Spu.DELETE_FLAG, false)) .build()); //组装返回数据 skuList.forEach(o -> { GoodsSkuPageVO skuPageVO = new GoodsSkuPageVO(); //复制id 价格等信息 BeanUtils.copyProperties(o, skuPageVO); //找到与sku匹配的spu Spu tempSpu = spuList.stream().filter(xx -> xx.getId().longValue() == o.getSpuId().longValue()).findFirst().orElse(null); if (ObjectUtil.isNotNull(tempSpu)) { //设置sku属性字段 skuPageVO.setMaterialId(tempSpu.getMaterialId()); skuPageVO.setSpuName(tempSpu.getName()); skuPageVO.setSpuCode(tempSpu.getSpuCode()); if (ObjectUtil.isNotNull(tempSpu.getRemark())) { skuPageVO.setGoodsRemark(tempSpu.getRemark()); } String categoryName = categoryRepository.getCategoryNameById(tempSpu.getCategoryId()); skuPageVO.setCategoryName(categoryName); //匹配素材 if (ObjectUtil.isNotNull(tempSpu.getMaterialId())) { skuPageVO.setMaterialId(tempSpu.getMaterialId()); Material tempMaterial = materialList.stream().filter(xx -> xx.getId().longValue() == skuPageVO.getMaterialId().longValue()).findFirst().orElse(null); if (ObjectUtil.isNotNull(tempMaterial)) { skuPageVO.setMaterialMainImages(Arrays.asList(Optional.ofNullable(tempMaterial.getMainImage()).orElse("").split(","))); skuPageVO.setMaterialName(tempMaterial.getMaterialName()); } } //查询属性值 是带入初始属性 否放入到额外属性 List<SkuAttributeValue> skuAttrValueRelationList = skuAttributeValueRepository.selectByCondition(Condition.builder(SkuAttributeValue.class) .andWhere(Sqls.custom().andEqualTo(SkuAttributeValue.FIELD_SKU_ID, o.getId(), true)) .build()); if (CollUtil.isNotEmpty(skuAttrValueRelationList)) { List<SkuAttributeValue> originalAttributeList = skuAttrValueRelationList.stream().filter(SkuAttributeValue::getIsSku).collect(Collectors.toList()); skuPageVO.setSkuAttributeList(originalAttributeList); List<SkuAttributeValue> attachedAttributeList = skuAttrValueRelationList.stream().filter(f -> !f.getIsSku()).collect(Collectors.toList()); skuPageVO.setOtherAttributeList(attachedAttributeList); } } pageVOS.add(skuPageVO); }); } return new Page<>(pageVOS, new PageInfo(pageList.getTotalPages(), pageList.getSize()), pageList.getTotalElements()); } @Override public GoodsSkuDetailVO getDetail(Long id, boolean isEdit) { Sku sku = skuRepository.selectByPrimaryKey(id); GoodsSkuDetailVO goodsSkuVO = new GoodsSkuDetailVO(); if (ObjectUtil.isNotEmpty(sku)) { BeanUtils.copyProperties(sku, goodsSkuVO); //如果是审核被驳回 需要去副本里寻找数据 if (isEdit && Sku.STATUS_TAKE_EFFECT_REJECTED.equals(sku.getStatus())) { SkuDraft skuDraft = skuDraftRepository.selectByPrimaryKey(sku.getId()); if (ObjectUtil.isNotEmpty(skuDraft)) { //把草稿里的属性覆盖给vo显示 BeanUtils.copyProperties(skuDraft, goodsSkuVO); } } Spu spu = spuRepository.selectByPrimaryKey(sku.getSpuId()); if (ObjectUtil.isNotNull(spu)) { //设置sku属性字段 goodsSkuVO.setMaterialId(spu.getMaterialId()); goodsSkuV