|
|
|
package com.yoho.ufo.service.impl;
|
|
|
|
|
|
|
|
import com.yoho.core.common.utils.DateUtil;
|
|
|
|
import com.yoho.ufo.dal.SaleCategoryMapper;
|
|
|
|
import com.yoho.ufo.exception.CommonException;
|
|
|
|
import com.yoho.ufo.model.salecategory.SaleCategory;
|
|
|
|
import com.yoho.ufo.service.ISaleCategoryService;
|
|
|
|
import com.yoho.ufo.util.OrikaUtils;
|
|
|
|
import com.yohobuy.ufo.model.response.salecategory.SaleCategoryResponseBo;
|
|
|
|
import com.yohobuy.ufo.model.response.salecategory.SaleCategoryTreeViewResponseBo;
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
import org.apache.commons.collections.CollectionUtils;
|
|
...
|
...
|
@@ -14,6 +17,7 @@ import org.springframework.stereotype.Service; |
|
|
|
import java.util.ArrayList;
|
|
|
|
import java.util.Iterator;
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
@Slf4j
|
|
|
|
@Service
|
|
...
|
...
|
@@ -30,22 +34,101 @@ public class SaleCategoryServiceImpl implements ISaleCategoryService { |
|
|
|
private static final Integer PRODUCT_SORT_LEVEL_1 = 1;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 二级层级
|
|
|
|
*/
|
|
|
|
private static final Integer PRODUCT_SORT_LEVEL_2 = 2;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 二级层级
|
|
|
|
*/
|
|
|
|
private static final Integer PRODUCT_SORT_LEVEL_3 = 3;
|
|
|
|
@Autowired
|
|
|
|
private SaleCategoryMapper saleCategoryMapper;
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public void updateStatus(SaleCategoryResponseBo saleCategoryResponseBo){
|
|
|
|
log.info("updateStatus param = {}", saleCategoryResponseBo);
|
|
|
|
|
|
|
|
SaleCategory db_saleCategory = saleCategoryMapper.selectById(saleCategoryResponseBo.getId());
|
|
|
|
if(db_saleCategory==null){
|
|
|
|
throw new CommonException(201, "找不到销售类目!");
|
|
|
|
}
|
|
|
|
Integer newStatus = saleCategoryResponseBo.getStatus();
|
|
|
|
if(db_saleCategory.getStatus().equals(newStatus)){
|
|
|
|
return ;
|
|
|
|
}
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
private SaleCategoryMapper saleCategoryMapper;
|
|
|
|
//关闭就直接关闭，开启需要检查上一级是否开启，如果上一级没开启就提示，需要先开启上一级
|
|
|
|
if(newStatus==0){
|
|
|
|
//检查上一级
|
|
|
|
if(db_saleCategory.getLevel()>PRODUCT_SORT_LEVEL_1){
|
|
|
|
SaleCategory parent_saleCategory = saleCategoryMapper.selectById(saleCategoryResponseBo.getParentId());
|
|
|
|
if(parent_saleCategory!=null&&!parent_saleCategory.getStatus().equals(0)){
|
|
|
|
throw new CommonException(201, "请先开启上级类目!");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}else{
|
|
|
|
newStatus = 1;
|
|
|
|
}
|
|
|
|
saleCategoryMapper.updateStatusById(saleCategoryResponseBo.getId(),newStatus,DateUtil.currentTimeSeconds());
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public void saveOrUpdateSaleCategory(SaleCategoryResponseBo saleCategoryResponseBo){
|
|
|
|
log.info("saveOrUpdateSaleCategory param = {}", saleCategoryResponseBo);
|
|
|
|
SaleCategory saleCategory = OrikaUtils.map(saleCategoryResponseBo, SaleCategory.class);
|
|
|
|
if (saleCategory.getId() == null || saleCategory.getId() == 0) {
|
|
|
|
// 新增
|
|
|
|
if (saleCategory.getParentId() == null || saleCategory.getParentId() == 0) {
|
|
|
|
// 一级层级
|
|
|
|
saleCategory.setLevel(PRODUCT_SORT_LEVEL_1);
|
|
|
|
saleCategory.setParentId(TOP_PARENT_ID);
|
|
|
|
} else {
|
|
|
|
//查看上一级的level
|
|
|
|
SaleCategory saleCategoryParent = saleCategoryMapper.selectById(saleCategory.getParentId());
|
|
|
|
if(saleCategoryParent==null){
|
|
|
|
throw new CommonException(201, "父类销售类目找不到!");
|
|
|
|
}
|
|
|
|
saleCategory.setLevel(saleCategoryParent.getLevel()+1);
|
|
|
|
}
|
|
|
|
saleCategory.setStatus(0);
|
|
|
|
saleCategory.setCreateTime(DateUtil.currentTimeSeconds());
|
|
|
|
saleCategory.setUpdateTime(saleCategory.getCreateTime());
|
|
|
|
|
|
|
|
List<SaleCategory> sameNameList = saleCategoryMapper.selectByNameAndParentId(saleCategory.getCategoryName(),saleCategory.getParentId());
|
|
|
|
if(CollectionUtils.isNotEmpty(sameNameList)){
|
|
|
|
throw new CommonException(201, "销售类目名称已被占用!");
|
|
|
|
}
|
|
|
|
|
|
|
|
saleCategoryMapper.insert(saleCategory);
|
|
|
|
} else {
|
|
|
|
// 更新
|
|
|
|
SaleCategory db_saleCategory = saleCategoryMapper.selectById(saleCategory.getId());
|
|
|
|
if(db_saleCategory==null){
|
|
|
|
throw new CommonException(201, "找不到销售类目!");
|
|
|
|
}
|
|
|
|
db_saleCategory.setCategoryName(saleCategoryResponseBo.getCategoryName());
|
|
|
|
db_saleCategory.setOrderBy(saleCategoryResponseBo.getOrderBy());
|
|
|
|
db_saleCategory.setUpdateTime(DateUtil.currentTimeSeconds());
|
|
|
|
|
|
|
|
List<SaleCategory> sameNameList = saleCategoryMapper.selectByNameAndParentId(saleCategory.getCategoryName(),saleCategory.getParentId());
|
|
|
|
if(CollectionUtils.isNotEmpty(sameNameList)){
|
|
|
|
//过滤掉自己
|
|
|
|
sameNameList = sameNameList.stream().filter(a -> !a.getId().equals(saleCategory.getId())) .collect(Collectors.toList());
|
|
|
|
if(CollectionUtils.isNotEmpty(sameNameList)){
|
|
|
|
throw new CommonException(201, "销售类目名称已被占用!");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
saleCategoryMapper.updateSaleCategoryById(db_saleCategory);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public SaleCategoryResponseBo getSaleCategoryById(Integer id){
|
|
|
|
log.info("enter getSaleCategoryById param = {}",id);
|
|
|
|
SaleCategory saleCategory = saleCategoryMapper.selectById(id);
|
|
|
|
if(saleCategory!=null){
|
|
|
|
return OrikaUtils.map(saleCategory, SaleCategoryResponseBo.class);
|
|
|
|
}
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public List<SaleCategoryTreeViewResponseBo> getSaleCategoryList() {
|
|
|
|
log.info("enter getSaleCategoryList param = {}");
|
|
|
|
List<SaleCategory> productSorts = saleCategoryMapper.selectAll();
|
...
|
...
|
|
