| package com.doumee.service.business.impl; | 
|   | 
| import com.doumee.core.constants.ResponseStatus; | 
| import com.doumee.core.exception.BusinessException; | 
| import com.doumee.core.model.LoginUserInfo; | 
| import com.doumee.core.model.PageData; | 
| import com.doumee.core.model.PageWrap; | 
| import com.doumee.core.utils.Constants; | 
| import com.doumee.core.utils.Utils; | 
| import com.doumee.dao.business.CategoryMapper; | 
| import com.doumee.dao.business.model.Category; | 
| import com.doumee.service.business.CategoryService; | 
| import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; | 
| import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; | 
| import com.baomidou.mybatisplus.core.metadata.IPage; | 
| import com.baomidou.mybatisplus.extension.plugins.pagination.Page; | 
| import org.apache.shiro.SecurityUtils; | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.stereotype.Service; | 
| import org.springframework.util.CollectionUtils; | 
|   | 
| import java.util.Date; | 
| import java.util.List; | 
|   | 
| /** | 
|  * 分类信息表Service实现 | 
|  * @author 江蹄蹄 | 
|  * @date 2023/11/30 15:33 | 
|  */ | 
| @Service | 
| public class CategoryServiceImpl implements CategoryService { | 
|   | 
|     @Autowired | 
|     private CategoryMapper categoryMapper; | 
|   | 
|     @Override | 
|     public Integer create(Category category) { | 
|         checkUnique(category); | 
|         LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); | 
|         if(loginUserInfo ==null){ | 
|             loginUserInfo = category.getLoginUserInfo(); | 
|         } | 
|         Category insert = new Category(); | 
|         insert.setCreator(loginUserInfo.getId()); | 
|         insert.setCreateDate(new Date()); | 
|         insert.setEditor(loginUserInfo.getId()); | 
|         insert.setEditDate(new Date()); | 
|         insert.setIsdeleted(Constants.ZERO); | 
|         insert.setName(category.getName()); | 
|         insert.setRemark(category.getRemark()); | 
|         insert.setStatus(Constants.ZERO); | 
|         insert.setSortnum(category.getSortnum()); | 
|         insert.setImgurl(category.getImgurl()); | 
|         insert.setType(Constants.ZERO); | 
|         insert.setParentId(category.getParentId()); | 
|         categoryMapper.insert(insert); | 
|         return insert.getId(); | 
|     } | 
|   | 
|     @Override | 
|     public void deleteById(Integer id) { | 
|         categoryMapper.deleteById(id); | 
|     } | 
|   | 
|     @Override | 
|     public void delete(Category category) { | 
|         UpdateWrapper<Category> deleteWrapper = new UpdateWrapper<>(category); | 
|         categoryMapper.delete(deleteWrapper); | 
|     } | 
|   | 
|     @Override | 
|     public void deleteByIdInBatch(List<Integer> ids) { | 
|         if (CollectionUtils.isEmpty(ids)) { | 
|             return; | 
|         } | 
|         categoryMapper.deleteBatchIds(ids); | 
|     } | 
|   | 
|     @Override | 
|     public void updateById(Category category) { | 
|         checkUnique(category); | 
|         categoryMapper.updateById(category); | 
|     } | 
|   | 
|     @Override | 
|     public void updateByIdInBatch(List<Category> categorys) { | 
|         if (CollectionUtils.isEmpty(categorys)) { | 
|             return; | 
|         } | 
|         for (Category category: categorys) { | 
|             this.updateById(category); | 
|         } | 
|     } | 
|   | 
|     @Override | 
|     public Category findById(Integer id) { | 
|         return categoryMapper.selectById(id); | 
|     } | 
|   | 
|     @Override | 
|     public Category findOne(Category category) { | 
|         QueryWrapper<Category> wrapper = new QueryWrapper<>(category); | 
|         return categoryMapper.selectOne(wrapper); | 
|     } | 
|   | 
|     @Override | 
|     public List<Category> findList(Category category) { | 
|         QueryWrapper<Category> wrapper = new QueryWrapper<>(category); | 
|         return categoryMapper.selectList(wrapper); | 
|     } | 
|   | 
|     @Override | 
|     public PageData<Category> findPage(PageWrap<Category> pageWrap) { | 
|         IPage<Category> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); | 
|         QueryWrapper<Category> queryWrapper = new QueryWrapper<>(); | 
|         Utils.MP.blankToNull(pageWrap.getModel()); | 
|         if (pageWrap.getModel().getId() != null) { | 
|             queryWrapper.lambda().eq(Category::getId, pageWrap.getModel().getId()); | 
|         } | 
|         if (pageWrap.getModel().getCreator() != null) { | 
|             queryWrapper.lambda().eq(Category::getCreator, pageWrap.getModel().getCreator()); | 
|         } | 
|         if (pageWrap.getModel().getCreateDate() != null) { | 
|             queryWrapper.lambda().ge(Category::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); | 
|             queryWrapper.lambda().le(Category::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); | 
|         } | 
|         if (pageWrap.getModel().getEditor() != null) { | 
|             queryWrapper.lambda().eq(Category::getEditor, pageWrap.getModel().getEditor()); | 
|         } | 
|         if (pageWrap.getModel().getEditDate() != null) { | 
|             queryWrapper.lambda().ge(Category::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); | 
|             queryWrapper.lambda().le(Category::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); | 
|         } | 
|         if (pageWrap.getModel().getIsdeleted() != null) { | 
|             queryWrapper.lambda().eq(Category::getIsdeleted, pageWrap.getModel().getIsdeleted()); | 
|         } | 
|         if (pageWrap.getModel().getName() != null) { | 
|             queryWrapper.lambda().eq(Category::getName, pageWrap.getModel().getName()); | 
|         } | 
|         if (pageWrap.getModel().getRemark() != null) { | 
|             queryWrapper.lambda().eq(Category::getRemark, pageWrap.getModel().getRemark()); | 
|         } | 
|         if (pageWrap.getModel().getStatus() != null) { | 
|             queryWrapper.lambda().eq(Category::getStatus, pageWrap.getModel().getStatus()); | 
|         } | 
|         if (pageWrap.getModel().getSortnum() != null) { | 
|             queryWrapper.lambda().eq(Category::getSortnum, pageWrap.getModel().getSortnum()); | 
|         } | 
|         if (pageWrap.getModel().getImgurl() != null) { | 
|             queryWrapper.lambda().eq(Category::getImgurl, pageWrap.getModel().getImgurl()); | 
|         } | 
|         if (pageWrap.getModel().getType() != null) { | 
|             queryWrapper.lambda().eq(Category::getType, pageWrap.getModel().getType()); | 
|         } | 
|         if (pageWrap.getModel().getParentId() != null) { | 
|             queryWrapper.lambda().eq(Category::getParentId, pageWrap.getModel().getParentId()); | 
|         } | 
|         for(PageWrap.SortData sortData: pageWrap.getSorts()) { | 
|             if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { | 
|                 queryWrapper.orderByDesc(sortData.getProperty()); | 
|             } else { | 
|                 queryWrapper.orderByAsc(sortData.getProperty()); | 
|             } | 
|         } | 
|         return PageData.from(categoryMapper.selectPage(page, queryWrapper)); | 
|     } | 
|   | 
|     @Override | 
|     public long count(Category category) { | 
|         QueryWrapper<Category> wrapper = new QueryWrapper<>(category); | 
|         return categoryMapper.selectCount(wrapper); | 
|     } | 
|   | 
|     private void checkUnique(Category category){ | 
|         QueryWrapper<Category> wrapper = new QueryWrapper<>(); | 
|         wrapper.lambda() | 
|                 .eq(Category::getIsdeleted,Constants.ZERO) | 
|                 .eq(Category::getType,category.getType()) | 
|                 .eq(Category::getName,category.getName()); | 
|   | 
|         List<Category> categories = categoryMapper.selectList(wrapper); | 
|   | 
|         if (org.apache.commons.collections.CollectionUtils.isNotEmpty(categories)){ | 
|             throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"分类信息已存在"); | 
|         } | 
|     } | 
| } |