package com.panzhihua.service_community.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.panzhihua.common.model.dtos.community.convenient.ConvenientProductDTO;
|
import com.panzhihua.common.model.dtos.community.convenient.ConvenientProductSpecificationDTO;
|
import com.panzhihua.common.model.dtos.community.convenient.DeleteConvenientProductDTO;
|
import com.panzhihua.common.model.dtos.community.convenient.OnShelfOrOffShelfProductDTO;
|
import com.panzhihua.common.model.dtos.community.convenient.PageConvenientProductDTO;
|
import com.panzhihua.common.model.dtos.community.convenient.PageMerchantProductDTO;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.model.vos.community.convenient.ConvenientProductSpecificationVO;
|
import com.panzhihua.common.model.vos.community.convenient.ConvenientProductVO;
|
import com.panzhihua.service_community.dao.ConvenientProductCategoryDAO;
|
import com.panzhihua.service_community.dao.ConvenientProductDAO;
|
import com.panzhihua.service_community.dao.ConvenientProductSpecificationDAO;
|
import com.panzhihua.service_community.model.dos.ConvenientProductCategoryDO;
|
import com.panzhihua.service_community.model.dos.ConvenientProductDO;
|
import com.panzhihua.service_community.model.dos.ConvenientProductSpecificationDO;
|
import com.panzhihua.service_community.service.ConvenientProductService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
import static java.util.Objects.isNull;
|
import static java.util.Objects.nonNull;
|
|
/**
|
* @title: ConvenientProductServiceImpl
|
* @projectName: 成都呐喊信息技术有限公司-智慧社区项目
|
* @description: 便民服务商家后台产品服务实现类
|
* @author: hans
|
* @date: 2021/09/21 21:33
|
*/
|
@Service
|
public class ConvenientProductServiceImpl extends ServiceImpl<ConvenientProductDAO, ConvenientProductDO> implements ConvenientProductService {
|
|
@Resource
|
private ConvenientProductCategoryDAO convenientProductCategoryDAO;
|
@Resource
|
private ConvenientProductSpecificationDAO convenientProductSpecificationDAO;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R addProduct(ConvenientProductDTO convenientProductDTO) {
|
ConvenientProductCategoryDO convenientProductCategoryDO = convenientProductCategoryDAO.selectById(convenientProductDTO.getCategoryId());
|
if (isNull(convenientProductCategoryDO)) {
|
return R.fail("产品分类不存在");
|
}
|
ConvenientProductDO convenientProductDO = new ConvenientProductDO();
|
BeanUtils.copyProperties(convenientProductDTO, convenientProductDO);
|
Date nowDate = new Date();
|
convenientProductDO.setCreatedAt(nowDate);
|
this.baseMapper.insert(convenientProductDO);
|
Long productId = convenientProductDO.getId();
|
if (nonNull(productId)) {
|
//规格
|
List<ConvenientProductSpecificationDTO> productSpecificationDTOList = convenientProductDTO.getProductSpecificationDTOList();
|
List<ConvenientProductSpecificationDO> productSpecificationDOList = productSpecificationDTOList.stream().map(specificationDTO -> {
|
ConvenientProductSpecificationDO convenientProductSpecificationDO = new ConvenientProductSpecificationDO();
|
BeanUtils.copyProperties(specificationDTO, convenientProductSpecificationDO);
|
convenientProductSpecificationDO.setProductId(productId);
|
convenientProductSpecificationDO.setCreatedAt(nowDate);
|
convenientProductSpecificationDO.setCreatedBy(convenientProductDTO.getCreatedBy());
|
return convenientProductSpecificationDO;
|
}).collect(Collectors.toList());
|
convenientProductSpecificationDAO.batchInsert(productSpecificationDOList);
|
}
|
return R.ok();
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R putProduct(ConvenientProductDTO convenientProductDTO) {
|
Long productId = convenientProductDTO.getId();
|
Long updatedBy = convenientProductDTO.getUpdatedBy();
|
ConvenientProductDO convenientProductDO = this.baseMapper.selectById(productId);
|
if (isNull(convenientProductDO)) {
|
return R.fail("产品不存在");
|
}
|
BeanUtils.copyProperties(convenientProductDTO, convenientProductDO);
|
convenientProductDO.setUpdatedBy(updatedBy);
|
this.baseMapper.updateById(convenientProductDO);
|
List<ConvenientProductSpecificationDTO> productSpecificationDTOList = convenientProductDTO.getProductSpecificationDTOList();
|
List<Long> notNeedDelIds = productSpecificationDTOList.stream().filter(specificationDTO -> nonNull(specificationDTO.getId()))
|
.map(ConvenientProductSpecificationDTO::getId).collect(Collectors.toList());
|
//删除已失去关联的规格
|
convenientProductSpecificationDAO.deleteLoseRelationSpecifications(notNeedDelIds);
|
Date nowDate = new Date();
|
productSpecificationDTOList.forEach(specificationDTO -> {
|
Long specificationId = specificationDTO.getId();
|
if (isNull(specificationId)) {
|
//新增
|
ConvenientProductSpecificationDO convenientProductSpecificationDO = new ConvenientProductSpecificationDO();
|
BeanUtils.copyProperties(specificationDTO, convenientProductSpecificationDO);
|
convenientProductSpecificationDO.setProductId(productId);
|
convenientProductSpecificationDO.setCreatedAt(nowDate);
|
convenientProductSpecificationDO.setCreatedBy(updatedBy);
|
convenientProductSpecificationDAO.insert(convenientProductSpecificationDO);
|
} else {
|
//更新
|
ConvenientProductSpecificationDO convenientProductSpecificationDO = convenientProductSpecificationDAO.selectById(specificationId);
|
BeanUtils.copyProperties(specificationDTO, convenientProductSpecificationDO);
|
convenientProductSpecificationDO.setUpdatedBy(updatedBy);
|
convenientProductSpecificationDAO.updateById(convenientProductSpecificationDO);
|
}
|
});
|
return R.ok();
|
}
|
|
@Override
|
public R getProduct(Long productId) {
|
if (isNull(productId)) {
|
return R.fail("产品ID不能为空");
|
}
|
ConvenientProductDO convenientProductDO = this.baseMapper.selectById(productId);
|
if (isNull(convenientProductDO)) {
|
return R.fail("产品不存在");
|
}
|
ConvenientProductVO convenientProductVO = new ConvenientProductVO();
|
BeanUtils.copyProperties(convenientProductDO, convenientProductVO);
|
//查找产品规格
|
List<ConvenientProductSpecificationDO> convenientProductSpecificationDOList = convenientProductSpecificationDAO.selectList(new LambdaQueryWrapper<ConvenientProductSpecificationDO>()
|
.eq(ConvenientProductSpecificationDO::getProductId, productId).eq(ConvenientProductSpecificationDO::getIsDel, false));
|
List<ConvenientProductSpecificationVO> convenientProductSpecificationVOList = new ArrayList<>();
|
if (!convenientProductSpecificationDOList.isEmpty()) {
|
convenientProductSpecificationDOList.forEach(specificationDO -> {
|
ConvenientProductSpecificationVO convenientProductSpecificationVO = new ConvenientProductSpecificationVO();
|
BeanUtils.copyProperties(specificationDO, convenientProductSpecificationVO);
|
convenientProductSpecificationVOList.add(convenientProductSpecificationVO);
|
});
|
}
|
convenientProductVO.setProductSpecificationVOList(convenientProductSpecificationVOList);
|
return R.ok(convenientProductVO);
|
}
|
|
@Override
|
public R pageProduct(PageConvenientProductDTO pageConvenientProductDTO) {
|
Page page = new Page<>();
|
page.setSize(pageConvenientProductDTO.getPageSize());
|
page.setCurrent(pageConvenientProductDTO.getPageNum());
|
IPage<ConvenientProductVO> productVOIPage = this.baseMapper.pageProduct(page, pageConvenientProductDTO);
|
List<ConvenientProductVO> convenientProductVOList = productVOIPage.getRecords();
|
//图片填充
|
if (!convenientProductVOList.isEmpty()) {
|
convenientProductVOList.forEach(product -> {
|
ConvenientProductSpecificationDO specificationDO = convenientProductSpecificationDAO.selectList(new LambdaQueryWrapper<ConvenientProductSpecificationDO>()
|
.eq(ConvenientProductSpecificationDO::getProductId, product.getId())).get(0);
|
product.setImage(specificationDO.getImage());
|
});
|
}
|
return R.ok(productVOIPage);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R deleteProduct(DeleteConvenientProductDTO deleteConvenientProductDTO) {
|
List<Long> needDelIds = deleteConvenientProductDTO.getIds();
|
//删除产品
|
int result = this.baseMapper.batchDeleteByIds(needDelIds);
|
if (result > 0) {
|
//删除规格
|
convenientProductSpecificationDAO.batchDeleteByProductIds(needDelIds);
|
}
|
return R.ok();
|
}
|
|
@Override
|
public R onShelfOrOffShelfProduct(OnShelfOrOffShelfProductDTO onShelfOrOffShelfProductDTO) {
|
Integer type = onShelfOrOffShelfProductDTO.getType();
|
Long updatedBy = onShelfOrOffShelfProductDTO.getUpdatedBy();
|
List<Long> needDelIds = onShelfOrOffShelfProductDTO.getIds();
|
if (type.intValue() == 1) {
|
//上架
|
this.baseMapper.batchOnShelfOrOffShelfByIds(needDelIds, updatedBy, true);
|
} else if (type.intValue() == 2) {
|
//下架
|
this.baseMapper.batchOnShelfOrOffShelfByIds(needDelIds, updatedBy, false);
|
} else {
|
return R.fail("处理类型错误");
|
}
|
return R.ok();
|
}
|
|
/**
|
* 小程序获取商家产品
|
* @param pageMerchantProductDTO
|
* @return
|
*/
|
@Override
|
public R getMerchantProduct(PageMerchantProductDTO pageMerchantProductDTO) {
|
Page page = new Page<>();
|
page.setSize(pageMerchantProductDTO.getPageSize());
|
page.setCurrent(pageMerchantProductDTO.getPageNum());
|
IPage<ConvenientProductVO> productVOIPage = this.baseMapper.getMerchantProduct(page, pageMerchantProductDTO);
|
return null;
|
}
|
}
|
