| | |
| | | package com.doumee.service.business.impl; |
| | | |
| | | import com.doumee.biz.system.SystemDictDataBiz; |
| | | import com.doumee.core.constants.ResponseStatus; |
| | | import com.doumee.core.exception.BusinessException; |
| | | import com.doumee.service.business.third.model.LoginUserInfo; |
| | |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.apache.shiro.SecurityUtils; |
| | | import org.checkerframework.checker.units.qual.C; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.CollectionUtils; |
| | | import org.springframework.validation.BindException; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | |
| | | public class CategoryServiceImpl implements CategoryService { |
| | | |
| | | @Autowired |
| | | private SystemDictDataBiz systemDictDataBiz; |
| | | @Autowired |
| | | private CategoryMapper categoryMapper; |
| | | |
| | | @Override |
| | | public Integer create(Category category) { |
| | | @Transactional(rollbackFor = {Exception.class, BindException.class}) |
| | | public Integer create(Category category){ |
| | | checkUnique(category); |
| | | LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(loginUserInfo ==null){ |
| | |
| | | insert.setRemark(category.getRemark()); |
| | | insert.setStatus(Constants.ZERO); |
| | | insert.setSortnum(category.getSortnum()); |
| | | insert.setBizType(category.getBizType()); |
| | | insert.setImgurl(category.getImgurl()); |
| | | insert.setType(category.getType()); |
| | | insert.setParentId(category.getParentId()); |
| | | categoryMapper.insert(insert); |
| | | if(insert.getBizType()!=null){ |
| | | //清空其他bizType,只保留当前新增记录唯一有效 |
| | | categoryMapper.update(null,new UpdateWrapper<Category>().lambda() |
| | | .set(Category::getBizType,null) |
| | | .eq(Category::getBizType,insert.getType()) |
| | | .ne(Category::getId,insert.getId()) |
| | | ); |
| | | } |
| | | return insert.getId(); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = {Exception.class, BindException.class}) |
| | | public void updateById(Category category) { |
| | | checkUnique(category); |
| | | categoryMapper.updateById(category); |
| | | if(category.getBizType()!=null){ |
| | | //清空其他该bizType属性,只保留当前记录唯一有效 |
| | | categoryMapper.update(null,new UpdateWrapper<Category>().lambda() |
| | | .set(Category::getBizType,null) |
| | | .eq(Category::getBizType,category.getBizType()) |
| | | .ne(Category::getId,category.getId()) |
| | | ); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | |
| | | IPage<Category> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); |
| | | QueryWrapper<Category> queryWrapper = new QueryWrapper<>(); |
| | | Utils.MP.blankToNull(pageWrap.getModel()); |
| | | String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + |
| | | systemDictDataBiz.queryByCode(Constants.FTP,Constants.BANNER_IMG).getCode(); |
| | | |
| | | queryWrapper.lambda().eq(Category::getIsdeleted,Constants.ZERO) |
| | | .eq(Objects.nonNull(pageWrap.getModel().getType()),Category::getType,pageWrap.getModel().getType()) |
| | | .isNull(Category::getParentId); |
| | | .like(StringUtils.isNotBlank(pageWrap.getModel().getName()),Category::getName,pageWrap.getModel().getName()) |
| | | .isNull(Category::getParentId) |
| | | .orderByDesc(Category::getSortnum); |
| | | PageData<Category> categoryPageData = PageData.from(categoryMapper.selectPage(page, queryWrapper)); |
| | | //查询所有二级数据 |
| | | List<Category> categoryList = categoryMapper.selectList( |
| | | new QueryWrapper<Category>().lambda() |
| | | .eq(Objects.nonNull(pageWrap.getModel().getType()),Category::getType,pageWrap.getModel().getType()) |
| | | .eq(Category::getIsdeleted,Constants.ZERO).isNotNull(Category::getParentId)); |
| | | .eq(Category::getIsdeleted,Constants.ZERO).isNotNull(Category::getParentId).orderByDesc(Category::getSortnum)); |
| | | |
| | | for (Category category:categoryPageData.getRecords()) { |
| | | category.setChildCategoryList( |
| | | categoryList.stream().filter(i->Constants.equalsInteger(i.getParentId(),category.getId())).collect(Collectors.toList()) |
| | | ); |
| | | if(StringUtils.isNotBlank(category.getImgurl())){ |
| | | category.setImgurlFull(prefixUrl + category.getImgurl()); |
| | | } |
| | | } |
| | | |
| | | return categoryPageData; |
| | |
| | | } |
| | | @Override |
| | | public List<Category> findChileList(Category model) { |
| | | if(Objects.isNull(model)){ |
| | | model = new Category(); |
| | | } |
| | | model.setIsdeleted(Constants.ZERO); |
| | | List<Category> list =findList(model); |
| | | List<Category> data = new ArrayList<>(); |
| | | if(list!=null){ |
| | |
| | | category.setGroupName( category.getParentName()+"/"+category.getName()); |
| | | data.add(category); |
| | | } |
| | | }else{ |
| | | data.add(category); |
| | | } |
| | | } |
| | | } |
| | |
| | | wrapper.lambda() |
| | | .eq(Category::getIsdeleted,Constants.ZERO) |
| | | .eq(Category::getType,category.getType()) |
| | | .eq(Category::getName,category.getName()); |
| | | .eq(Category::getName,category.getName()) |
| | | .ne(category.getId()!=null, Category::getId,category.getId()) |
| | | ; |
| | | |
| | | List<Category> categories = categoryMapper.selectList(wrapper); |
| | | |
| | | if (org.apache.commons.collections.CollectionUtils.isNotEmpty(categories)){ |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"分类信息已存在"); |
| | | } |