package com.webmanage.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
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.webmanage.common.BusinessException;
|
import com.webmanage.emun.PriceTypeEnum;
|
import com.webmanage.entity.ProductPricing;
|
import com.webmanage.mapper.ProductPricingMapper;
|
import com.webmanage.service.ProductPricingService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.StringUtils;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
/**
|
* 产品定价服务实现类
|
*
|
* @author webmanage
|
* @date 2024-08-07
|
*/
|
@Slf4j
|
@Service
|
public class ProductPricingServiceImpl extends ServiceImpl<ProductPricingMapper, ProductPricing> implements ProductPricingService {
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public boolean addProductPricing(ProductPricing productPricing) {
|
try {
|
// 设置创建时间
|
productPricing.setCreatedAt(LocalDateTime.now());
|
productPricing.setUpdatedAt(LocalDateTime.now());
|
|
// 验证必填字段
|
if (!StringUtils.hasText(productPricing.getSuiteName())) {
|
throw new BusinessException("产品套件名称不能为空");
|
}
|
if (!StringUtils.hasText(productPricing.getSalesForm())) {
|
throw new BusinessException("销售形式不能为空");
|
}
|
if (!StringUtils.hasText(productPricing.getCustomerType())) {
|
throw new BusinessException("客户对象不能为空");
|
}
|
if (!StringUtils.hasText(productPricing.getPriceType())) {
|
throw new BusinessException("价格设置不能为空");
|
}
|
if (productPricing.getPriceType().indexOf(PriceTypeEnum.POINTS.getName()) > -1
|
&& productPricing.getPointsPrice() == null ||
|
productPricing.getPriceType().indexOf(PriceTypeEnum.POINTS.getName()) > -1
|
&&productPricing.getPointsPrice().doubleValue() < 0) {
|
throw new BusinessException("积分价格值不能为空且不能为负数");
|
}
|
if (productPricing.getPriceType().indexOf(PriceTypeEnum.CURRENCY.getName()) > -1
|
&& productPricing.getCurrencyPrice()== null ||
|
productPricing.getPriceType().indexOf(PriceTypeEnum.CURRENCY.getName()) > -1
|
&& productPricing.getCurrencyPrice().doubleValue() < 0){
|
throw new BusinessException("货币价格值不能为空且不能为负数");
|
}
|
if (productPricing.getProductId() == null) {
|
throw new BusinessException("产品ID不能为空");
|
}
|
|
// 设置默认值
|
if (productPricing.getIsActive() == null) {
|
productPricing.setIsActive(true);
|
}
|
|
boolean result = save(productPricing);
|
if (result) {
|
log.info("新增产品定价成功: {}", productPricing.getSuiteName());
|
}
|
return result;
|
} catch (Exception e) {
|
log.error("新增产品定价失败: ", e);
|
throw new BusinessException("新增产品定价失败: " + e.getMessage());
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public boolean updateProductPricing(ProductPricing productPricing) {
|
try {
|
// 检查定价是否存在
|
ProductPricing existingPricing = getById(productPricing.getId());
|
if (existingPricing == null) {
|
throw new BusinessException("产品定价不存在");
|
}
|
|
// 设置更新时间
|
productPricing.setUpdatedAt(LocalDateTime.now());
|
|
// 验证必填字段
|
if (!StringUtils.hasText(productPricing.getSuiteName())) {
|
throw new BusinessException("产品套件名称不能为空");
|
}
|
if (!StringUtils.hasText(productPricing.getSalesForm())) {
|
throw new BusinessException("销售形式不能为空");
|
}
|
if (!StringUtils.hasText(productPricing.getCustomerType())) {
|
throw new BusinessException("客户对象不能为空");
|
}
|
if (!StringUtils.hasText(productPricing.getPriceType())) {
|
throw new BusinessException("价格设置不能为空");
|
}
|
if (productPricing.getPriceType().indexOf(PriceTypeEnum.POINTS.getName()) > -1
|
&& productPricing.getPointsPrice() == null ||
|
productPricing.getPriceType().indexOf(PriceTypeEnum.POINTS.getName()) > -1
|
&&productPricing.getPointsPrice().doubleValue() < 0) {
|
throw new BusinessException("积分价格值不能为空且不能为负数");
|
}
|
if (productPricing.getPriceType().indexOf(PriceTypeEnum.CURRENCY.getName()) > -1
|
&& productPricing.getCurrencyPrice()== null ||
|
productPricing.getPriceType().indexOf(PriceTypeEnum.CURRENCY.getName()) > -1
|
&& productPricing.getCurrencyPrice().doubleValue() < 0) {
|
throw new BusinessException("货币价格值不能为空且不能为负数");
|
}
|
|
boolean result = updateById(productPricing);
|
if (result) {
|
log.info("更新产品定价成功: {}", productPricing.getSuiteName());
|
}
|
return result;
|
} catch (Exception e) {
|
log.error("更新产品定价失败: ", e);
|
throw new BusinessException("更新产品定价失败: " + e.getMessage());
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public boolean deleteProductPricing(Long id) {
|
try {
|
// 检查定价是否存在
|
ProductPricing existingPricing = getById(id);
|
if (existingPricing == null) {
|
throw new BusinessException("产品定价不存在");
|
}
|
|
boolean result = removeById(id);
|
if (result) {
|
log.info("删除产品定价成功: {}", existingPricing.getSuiteName());
|
}
|
return result;
|
} catch (Exception e) {
|
log.error("删除产品定价失败: ", e);
|
throw new BusinessException("删除产品定价失败: " + e.getMessage());
|
}
|
}
|
|
@Override
|
public IPage<ProductPricing> getProductPricingPage(Page<ProductPricing> page, Long productId) {
|
try {
|
return baseMapper.selectProductPricingPage(page, productId);
|
} catch (Exception e) {
|
log.error("分页查询产品定价失败: ", e);
|
throw new BusinessException("分页查询产品定价失败: " + e.getMessage());
|
}
|
}
|
|
@Override
|
public List<ProductPricing> getPricingByProductId(Long productId) {
|
try {
|
if (productId == null) {
|
throw new BusinessException("产品ID不能为空");
|
}
|
return baseMapper.selectByProductId(productId);
|
} catch (Exception e) {
|
log.error("根据产品ID查询定价失败: ", e);
|
throw new BusinessException("根据产品ID查询定价失败: " + e.getMessage());
|
}
|
}
|
|
@Override
|
public List<ProductPricing> getPricingByCondition(String suiteName, String salesForm,
|
String customerType, String priceType, Boolean isActive) {
|
try {
|
QueryWrapper<ProductPricing> queryWrapper = new QueryWrapper<>();
|
|
if (StringUtils.hasText(suiteName)) {
|
queryWrapper.like("suite_name", suiteName);
|
}
|
if (StringUtils.hasText(salesForm)) {
|
queryWrapper.eq("sales_form", salesForm);
|
}
|
if (StringUtils.hasText(customerType)) {
|
queryWrapper.eq("customer_type", customerType);
|
}
|
if (StringUtils.hasText(priceType)) {
|
queryWrapper.eq("price_type", priceType);
|
}
|
if (isActive != null) {
|
queryWrapper.eq("is_active", isActive);
|
}
|
|
queryWrapper.orderByDesc("created_at");
|
|
return list(queryWrapper);
|
} catch (Exception e) {
|
log.error("根据条件查询产品定价失败: ", e);
|
throw new BusinessException("根据条件查询产品定价失败: " + e.getMessage());
|
}
|
}
|
}
|
