diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDeptMapper.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDeptMapper.java index ef960a54..44a34ff3 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDeptMapper.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDeptMapper.java @@ -33,47 +33,6 @@ import org.apache.ibatis.annotations.Mapper; @Mapper public interface SystemDeptMapper extends BaseMapper { - default List selectDeptByPidIsNull() { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - wrapper.isNull(SystemDeptTb::getPid); - return selectList(wrapper); - } - - default long countDeptByPid(Long pid) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - wrapper.eq(SystemDeptTb::getPid, pid); - return selectCount(wrapper); - } - - default List queryDeptByArgs(SystemQueryDeptArgs criteria) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - if (criteria != null) { - wrapper.in(CollUtil.isNotEmpty(criteria.getIds()), SystemDeptTb::getId, criteria.getIds()); - wrapper.like(StrUtil.isNotBlank(criteria.getName()), SystemDeptTb::getName, criteria.getName()); - wrapper.eq(criteria.getEnabled() != null, SystemDeptTb::getEnabled, criteria.getEnabled()); - wrapper.eq(criteria.getPid() != null, SystemDeptTb::getPid, criteria.getPid()); - wrapper.isNull(criteria.getPidIsNull() != null, SystemDeptTb::getPid); - if (CollUtil.isNotEmpty(criteria.getCreateTime()) && criteria.getCreateTime().size() >= 2) { - wrapper.between(SystemDeptTb::getCreateTime, criteria.getCreateTime().get(0), - criteria.getCreateTime().get(1)); - } - } - wrapper.orderByAsc(SystemDeptTb::getDeptSort); - return selectList(wrapper); - } - - default List selectEnabledDepts() { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - wrapper.eq(SystemDeptTb::getEnabled, 1); - return selectList(wrapper); - } - - default List selectDeptByPid(long pid) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - wrapper.eq(SystemDeptTb::getPid, pid); - return selectList(wrapper); - } - default void updateDeptSubCountById(long count, Long deptId) { LambdaUpdateWrapper wrapper = new LambdaUpdateWrapper<>(); wrapper.eq(SystemDeptTb::getId, deptId); diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDictDetailMapper.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDictDetailMapper.java index d744a1ed..98e35d5c 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDictDetailMapper.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDictDetailMapper.java @@ -15,13 +15,8 @@ */ package cn.odboy.system.dal.mysql; -import cn.hutool.core.collection.CollUtil; import cn.odboy.system.dal.dataobject.SystemDictDetailTb; -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import com.baomidou.mybatisplus.core.metadata.IPage; -import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import java.util.List; import org.apache.ibatis.annotations.Mapper; /** @@ -32,15 +27,4 @@ import org.apache.ibatis.annotations.Mapper; @Mapper public interface SystemDictDetailMapper extends BaseMapper { - default List selectByDictId(Long dictId) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - wrapper.eq(SystemDictDetailTb::getDictId, dictId); - return selectList(wrapper); - } - - default IPage selectDictDetailByArgs(List dictIds, Page page) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - wrapper.in(CollUtil.isNotEmpty(dictIds), SystemDictDetailTb::getDictId, dictIds); - return selectPage(page, wrapper); - } } diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDictMapper.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDictMapper.java index 113a0ac4..ee588fa5 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDictMapper.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemDictMapper.java @@ -15,13 +15,8 @@ */ package cn.odboy.system.dal.mysql; -import cn.hutool.core.util.StrUtil; import cn.odboy.system.dal.dataobject.SystemDictTb; -import cn.odboy.system.dal.model.SystemQueryDictArgs; -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import java.util.List; import org.apache.ibatis.annotations.Mapper; /** @@ -32,28 +27,4 @@ import org.apache.ibatis.annotations.Mapper; @Mapper public interface SystemDictMapper extends BaseMapper { - default void injectQueryParams(SystemQueryDictArgs args, LambdaQueryWrapper wrapper) { - if (args != null) { - wrapper.and(StrUtil.isNotBlank(args.getBlurry()), c -> c.like(SystemDictTb::getName, args.getBlurry()).or() - .like(SystemDictTb::getDescription, args.getBlurry())); - } - } - - default List selectDictByArgs(SystemQueryDictArgs args) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - injectQueryParams(args, wrapper); - return selectList(wrapper); - } - - default List selectDictByArgs(SystemQueryDictArgs args, Page page) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - injectQueryParams(args, wrapper); - return selectList(page, wrapper); - } - - default SystemDictTb getByName(String name) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - wrapper.eq(SystemDictTb::getName, name); - return selectOne(wrapper); - } } diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemJobMapper.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemJobMapper.java index af052bc7..0f20d2d1 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemJobMapper.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemJobMapper.java @@ -15,15 +15,8 @@ */ package cn.odboy.system.dal.mysql; -import cn.hutool.core.collection.CollUtil; -import cn.hutool.core.util.StrUtil; import cn.odboy.system.dal.dataobject.SystemJobTb; -import cn.odboy.system.dal.model.SystemQueryJobArgs; -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import com.baomidou.mybatisplus.core.metadata.IPage; -import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import java.util.List; import org.apache.ibatis.annotations.Mapper; /** @@ -34,33 +27,4 @@ import org.apache.ibatis.annotations.Mapper; @Mapper public interface SystemJobMapper extends BaseMapper { - default SystemJobTb getJobByName(String name) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - wrapper.eq(SystemJobTb::getName, name); - return selectOne(wrapper); - } - - default void injectQueryParams(SystemQueryJobArgs criteria, LambdaQueryWrapper wrapper) { - if (criteria != null) { - wrapper.like(StrUtil.isNotBlank(criteria.getName()), SystemJobTb::getName, criteria.getName()); - wrapper.eq(criteria.getEnabled() != null, SystemJobTb::getEnabled, criteria.getEnabled()); - if (CollUtil.isNotEmpty(criteria.getCreateTime()) && criteria.getCreateTime().size() >= 2) { - wrapper.between(SystemJobTb::getCreateTime, criteria.getCreateTime().get(0), - criteria.getCreateTime().get(1)); - } - } - wrapper.orderByDesc(SystemJobTb::getJobSort, SystemJobTb::getId); - } - - default IPage selectJobByArgs(SystemQueryJobArgs criteria, Page page) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - this.injectQueryParams(criteria, wrapper); - return selectPage(page, wrapper); - } - - default List selectJobByArgs(SystemQueryJobArgs criteria) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - this.injectQueryParams(criteria, wrapper); - return selectList(wrapper); - } } diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemLocalStorageMapper.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemLocalStorageMapper.java index 64ef3a5e..c6ccce07 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemLocalStorageMapper.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/dal/mysql/SystemLocalStorageMapper.java @@ -15,15 +15,8 @@ */ package cn.odboy.system.dal.mysql; -import cn.hutool.core.collection.CollUtil; -import cn.hutool.core.util.StrUtil; import cn.odboy.system.dal.dataobject.SystemLocalStorageTb; -import cn.odboy.system.dal.model.SystemQueryStorageArgs; -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import com.baomidou.mybatisplus.core.metadata.IPage; -import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import java.util.List; import org.apache.ibatis.annotations.Mapper; /** @@ -34,31 +27,4 @@ import org.apache.ibatis.annotations.Mapper; @Mapper public interface SystemLocalStorageMapper extends BaseMapper { - default void injectQueryParams(SystemQueryStorageArgs criteria, LambdaQueryWrapper wrapper) { - if (criteria != null) { - wrapper.and(StrUtil.isNotBlank(criteria.getBlurry()), - c -> c.like(SystemLocalStorageTb::getName, criteria.getBlurry()).or() - .like(SystemLocalStorageTb::getSuffix, criteria.getBlurry()).or() - .like(SystemLocalStorageTb::getType, criteria.getBlurry()).or() - .like(SystemLocalStorageTb::getCreateBy, criteria.getBlurry())); - if (CollUtil.isNotEmpty(criteria.getCreateTime()) && criteria.getCreateTime().size() >= 2) { - wrapper.between(SystemLocalStorageTb::getUpdateTime, criteria.getCreateTime().get(0), - criteria.getCreateTime().get(1)); - } - } - wrapper.orderByDesc(SystemLocalStorageTb::getId); - } - - default List selectLocalStorageByArgs(SystemQueryStorageArgs criteria) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - injectQueryParams(criteria, wrapper); - return selectList(wrapper); - } - - default IPage selectLocalStorageByArgs(SystemQueryStorageArgs criteria, - Page page) { - LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - injectQueryParams(criteria, wrapper); - return selectPage(page, wrapper); - } } diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDeptService.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDeptService.java index bc96bd9d..f188befd 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDeptService.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDeptService.java @@ -29,11 +29,11 @@ import cn.odboy.system.dal.model.SystemProductLineTreeVo; import cn.odboy.system.dal.model.SystemProductLineVo; import cn.odboy.system.dal.model.SystemQueryDeptArgs; import cn.odboy.system.dal.mysql.SystemDeptMapper; -import cn.odboy.system.dal.mysql.SystemRoleMapper; import cn.odboy.system.dal.mysql.SystemUserMapper; import cn.odboy.system.framework.permission.core.KitSecurityHelper; import cn.odboy.util.KitClassUtil; import cn.odboy.util.KitFileUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import java.io.IOException; import java.lang.reflect.Field; import java.util.ArrayList; @@ -133,11 +133,17 @@ public class SystemDeptService { @Transactional(rollbackFor = Exception.class) public void updateDeptSubCnt(Long deptId) { if (deptId != null) { - long count = systemDeptMapper.countDeptByPid(deptId); + long count = this.countDeptByPid(deptId); systemDeptMapper.updateDeptSubCountById(count, deptId); } } + public long countDeptByPid(Long pid) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(SystemDeptTb::getPid, pid); + return systemDeptMapper.selectCount(wrapper); + } + /** * 筛选出 list 中没有父部门(即 pid 不在其他部门 id 列表中的部门)的部门列表 */ @@ -154,6 +160,23 @@ public class SystemDeptService { return deptList; } + public List queryDeptByArgs(SystemQueryDeptArgs criteria) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + if (criteria != null) { + wrapper.in(CollUtil.isNotEmpty(criteria.getIds()), SystemDeptTb::getId, criteria.getIds()); + wrapper.like(StrUtil.isNotBlank(criteria.getName()), SystemDeptTb::getName, criteria.getName()); + wrapper.eq(criteria.getEnabled() != null, SystemDeptTb::getEnabled, criteria.getEnabled()); + wrapper.eq(criteria.getPid() != null, SystemDeptTb::getPid, criteria.getPid()); + wrapper.isNull(criteria.getPidIsNull() != null, SystemDeptTb::getPid); + if (CollUtil.isNotEmpty(criteria.getCreateTime()) && criteria.getCreateTime().size() >= 2) { + wrapper.between(SystemDeptTb::getCreateTime, criteria.getCreateTime().get(0), + criteria.getCreateTime().get(1)); + } + } + wrapper.orderByAsc(SystemDeptTb::getDeptSort); + return systemDeptMapper.selectList(wrapper); + } + /** * 查询所有数据 * @@ -188,7 +211,7 @@ public class SystemDeptService { } // 数据权限 criteria.setIds(KitSecurityHelper.getCurrentUserDataScope()); - List list = systemDeptMapper.queryDeptByArgs(criteria); + List list = this.queryDeptByArgs(criteria); // 如果为空, 就代表为自定义权限或者本级权限, 就需要去重, 不理解可以注释掉,看查询结果 if (StrUtil.isBlank(dataScopeType)) { return this.deduplication(list); @@ -213,7 +236,7 @@ public class SystemDeptService { * @return / */ public List queryDeptByPid(long pid) { - return systemDeptMapper.selectDeptByPid(pid); + return this.selectDeptByPid(pid); } /** @@ -226,7 +249,7 @@ public class SystemDeptService { public Set queryRelationDeptSet(List deptTbList, Set depts) { for (SystemDeptTb dept : deptTbList) { depts.add(dept); - List deptList = systemDeptMapper.selectDeptByPid(dept.getId()); + List deptList = this.selectDeptByPid(dept.getId()); if (CollUtil.isNotEmpty(deptList)) { queryRelationDeptSet(deptList, depts); } @@ -244,7 +267,7 @@ public class SystemDeptService { List list = new ArrayList<>(); for (SystemDeptTb systemDeptTb : deptList) { if (systemDeptTb != null && systemDeptTb.getEnabled()) { - List deptList1 = systemDeptMapper.selectDeptByPid(systemDeptTb.getId()); + List deptList1 = this.selectDeptByPid(systemDeptTb.getId()); if (CollUtil.isNotEmpty(deptList1)) { list.addAll(queryChildDeptIdListByDeptIds(deptList1)); } @@ -263,13 +286,19 @@ public class SystemDeptService { */ public List querySuperiorDeptListByPid(SystemDeptTb dept, List deptList) { if (dept.getPid() == null) { - deptList.addAll(systemDeptMapper.selectDeptByPidIsNull()); + deptList.addAll(this.selectDeptByPidIsNull()); return deptList; } - deptList.addAll(systemDeptMapper.selectDeptByPid(dept.getPid())); + deptList.addAll(this.selectDeptByPid(dept.getPid())); return querySuperiorDeptListByPid(this.getDeptById(dept.getPid()), deptList); } + public List selectDeptByPidIsNull() { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.isNull(SystemDeptTb::getPid); + return systemDeptMapper.selectList(wrapper); + } + /** * 构建树形数据 * @@ -325,6 +354,12 @@ public class SystemDeptService { } } + public List selectEnabledDepts() { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(SystemDeptTb::getEnabled, 1); + return systemDeptMapper.selectList(wrapper); + } + /** * 遍历所有部门和子部门 * @@ -345,7 +380,7 @@ public class SystemDeptService { } public List queryDeptSelectDataSource() { - List depts = systemDeptMapper.selectEnabledDepts(); + List depts = this.selectEnabledDepts(); return buildDeptSelectOptions(depts); } @@ -394,7 +429,7 @@ public class SystemDeptService { } public List queryDeptSelectProDataSource() { - List depts = systemDeptMapper.selectEnabledDepts(); + List depts = this.selectEnabledDepts(); // 获取所有部门并按父子关系组织 Map deptMap = depts.stream().collect(Collectors.toMap(SystemDeptTb::getId, Function.identity())); @@ -441,4 +476,11 @@ public class SystemDeptService { vo.setChildren(children); return vo; } + + public List selectDeptByPid(long pid) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(SystemDeptTb::getPid, pid); + return systemDeptMapper.selectList(wrapper); + } + } diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDictDetailService.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDictDetailService.java index 3059a492..72720474 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDictDetailService.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDictDetailService.java @@ -25,7 +25,6 @@ import cn.odboy.system.dal.model.SystemCreateDictDetailArgs; import cn.odboy.system.dal.model.SystemDictDetailVo; import cn.odboy.system.dal.model.SystemQueryDictDetailArgs; import cn.odboy.system.dal.mysql.SystemDictDetailMapper; -import cn.odboy.system.dal.mysql.SystemDictMapper; import cn.odboy.util.KitPageUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; @@ -45,7 +44,7 @@ public class SystemDictDetailService { @Autowired private SystemDictDetailMapper systemDictDetailMapper; @Autowired - private SystemDictMapper systemDictMapper; + private SystemDictService systemDictService; /** * 创建 @@ -90,6 +89,18 @@ public class SystemDictDetailService { } } + private List selectByDictId(Long dictId) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(SystemDictDetailTb::getDictId, dictId); + return systemDictDetailMapper.selectList(wrapper); + } + + private IPage selectDictDetailByArgs(List dictIds, Page page) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.in(CollUtil.isNotEmpty(dictIds), SystemDictDetailTb::getDictId, dictIds); + return systemDictDetailMapper.selectPage(page, wrapper); + } + /** * 分页查询 * @@ -104,14 +115,14 @@ public class SystemDictDetailService { List dictTbs = new ArrayList<>(); if (args == null) { - dictTbs.addAll(systemDictMapper.selectList(null)); + dictTbs.addAll(systemDictService.selectList(null)); dictIds = dictTbs.stream().map(SystemDictTb::getId).collect(Collectors.toList()); } else { String dictName = args.getDictName(); if (StrUtil.isBlank(dictName)) { return KitPageUtil.toPage(iPage); } - SystemDictTb dictTb = systemDictMapper.getByName(dictName); + SystemDictTb dictTb = systemDictService.getByName(dictName); if (dictTb == null) { return KitPageUtil.toPage(iPage); } else { @@ -121,7 +132,7 @@ public class SystemDictDetailService { } Map id2ItemMap = dictTbs.stream().collect(Collectors.toMap(SystemDictTb::getId, i -> i)); - iPage = systemDictDetailMapper.selectDictDetailByArgs(dictIds, page) + iPage = this.selectDictDetailByArgs(dictIds, page) .convert(i -> BeanUtil.copyProperties(i, SystemDictDetailVo.class)); for (SystemDictDetailVo record : iPage.getRecords()) { record.setDict(id2ItemMap.get(record.getDictId())); @@ -139,11 +150,11 @@ public class SystemDictDetailService { if (StrUtil.isBlank(name)) { return new ArrayList<>(); } - SystemDictTb systemDictTb = systemDictMapper.getByName(name); + SystemDictTb systemDictTb = systemDictService.getByName(name); if (systemDictTb == null) { return new ArrayList<>(); } - return systemDictDetailMapper.selectByDictId(systemDictTb.getId()).stream().map(m -> { + return this.selectByDictId(systemDictTb.getId()).stream().map(m -> { SystemDictDetailVo detailVo = BeanUtil.copyProperties(m, SystemDictDetailVo.class); detailVo.setDict(systemDictTb); return detailVo; diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDictService.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDictService.java index 5376c797..570b7a69 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDictService.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemDictService.java @@ -17,6 +17,7 @@ package cn.odboy.system.service; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollectionUtil; +import cn.hutool.core.util.StrUtil; import cn.odboy.base.KitPageResult; import cn.odboy.system.dal.dataobject.SystemDictDetailTb; import cn.odboy.system.dal.dataobject.SystemDictTb; @@ -26,6 +27,7 @@ import cn.odboy.system.dal.model.SystemQueryDictArgs; import cn.odboy.system.dal.mysql.SystemDictMapper; import cn.odboy.util.KitFileUtil; import cn.odboy.util.KitPageUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import java.io.IOException; import java.util.ArrayList; @@ -40,6 +42,7 @@ import org.springframework.transaction.annotation.Transactional; @Service public class SystemDictService { + @Autowired private SystemDictMapper systemDictMapper; @Autowired @@ -123,7 +126,7 @@ public class SystemDictService { * @return / */ public KitPageResult queryDictByArgs(SystemQueryDictArgs args, Page page) { - return KitPageUtil.toPage(systemDictMapper.selectDictByArgs(args, page)); + return KitPageUtil.toPage(this.selectDictByArgs(args, page)); } /** @@ -133,10 +136,39 @@ public class SystemDictService { * @return / */ public List queryDictByArgs(SystemQueryDictArgs args) { - return systemDictMapper.selectDictByArgs(args); + return this.selectDictByArgs(args); } public SystemDictTb getById(int id) { return systemDictMapper.selectById(id); } + + private void injectQueryParams(SystemQueryDictArgs args, LambdaQueryWrapper wrapper) { + if (args != null) { + wrapper.and(StrUtil.isNotBlank(args.getBlurry()), c -> c.like(SystemDictTb::getName, args.getBlurry()).or() + .like(SystemDictTb::getDescription, args.getBlurry())); + } + } + + private List selectDictByArgs(SystemQueryDictArgs args) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + injectQueryParams(args, wrapper); + return systemDictMapper.selectList(wrapper); + } + + private List selectDictByArgs(SystemQueryDictArgs args, Page page) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + injectQueryParams(args, wrapper); + return systemDictMapper.selectList(page, wrapper); + } + + public SystemDictTb getByName(String name) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(SystemDictTb::getName, name); + return systemDictMapper.selectOne(wrapper); + } + + public List selectList(LambdaQueryWrapper wrapper) { + return systemDictMapper.selectList(wrapper); + } } diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemJobService.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemJobService.java index 99010c26..dbcccb83 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemJobService.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemJobService.java @@ -16,6 +16,8 @@ package cn.odboy.system.service; import cn.hutool.core.bean.BeanUtil; +import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.util.StrUtil; import cn.odboy.base.KitPageResult; import cn.odboy.framework.exception.BadRequestException; import cn.odboy.system.dal.dataobject.SystemJobTb; @@ -25,6 +27,8 @@ import cn.odboy.system.dal.mysql.SystemJobMapper; import cn.odboy.system.dal.mysql.SystemUserMapper; import cn.odboy.util.KitFileUtil; import cn.odboy.util.KitPageUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import java.io.IOException; import java.util.ArrayList; @@ -52,7 +56,7 @@ public class SystemJobService { */ @Transactional(rollbackFor = Exception.class) public void saveJob(SystemCreateJobArgs args) { - SystemJobTb job = systemJobMapper.getJobByName(args.getName()); + SystemJobTb job = this.getJobByName(args.getName()); if (job != null) { throw new BadRequestException("职位名称已存在"); } @@ -67,7 +71,7 @@ public class SystemJobService { @Transactional(rollbackFor = Exception.class) public void modifyJobById(SystemJobTb args) { SystemJobTb job = systemJobMapper.selectById(args.getId()); - SystemJobTb old = systemJobMapper.getJobByName(args.getName()); + SystemJobTb old = this.getJobByName(args.getName()); if (old != null && !old.getId().equals(args.getId())) { throw new BadRequestException("职位名称已存在"); } @@ -112,7 +116,7 @@ public class SystemJobService { * @return */ public KitPageResult queryJobByArgs(SystemQueryJobArgs args, Page page) { - return KitPageUtil.toPage(systemJobMapper.selectJobByArgs(args, page)); + return KitPageUtil.toPage(this.selectJobByArgs(args, page)); } /** @@ -122,7 +126,7 @@ public class SystemJobService { * @return / */ public List queryJobByArgs(SystemQueryJobArgs args) { - return systemJobMapper.selectJobByArgs(args); + return this.selectJobByArgs(args); } /** @@ -135,4 +139,35 @@ public class SystemJobService { throw new BadRequestException("所选的岗位中存在用户关联, 请解除关联再试!"); } } + + + public SystemJobTb getJobByName(String name) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(SystemJobTb::getName, name); + return systemJobMapper.selectOne(wrapper); + } + + public void injectQueryParams(SystemQueryJobArgs criteria, LambdaQueryWrapper wrapper) { + if (criteria != null) { + wrapper.like(StrUtil.isNotBlank(criteria.getName()), SystemJobTb::getName, criteria.getName()); + wrapper.eq(criteria.getEnabled() != null, SystemJobTb::getEnabled, criteria.getEnabled()); + if (CollUtil.isNotEmpty(criteria.getCreateTime()) && criteria.getCreateTime().size() >= 2) { + wrapper.between(SystemJobTb::getCreateTime, criteria.getCreateTime().get(0), + criteria.getCreateTime().get(1)); + } + } + wrapper.orderByDesc(SystemJobTb::getJobSort, SystemJobTb::getId); + } + + public IPage selectJobByArgs(SystemQueryJobArgs criteria, Page page) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + this.injectQueryParams(criteria, wrapper); + return systemJobMapper.selectPage(page, wrapper); + } + + public List selectJobByArgs(SystemQueryJobArgs criteria) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + this.injectQueryParams(criteria, wrapper); + return systemJobMapper.selectList(wrapper); + } } diff --git a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemLocalStorageService.java b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemLocalStorageService.java index 41f378a8..39751cb9 100644 --- a/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemLocalStorageService.java +++ b/cutejava/cutejava-module-system/src/main/java/cn/odboy/system/service/SystemLocalStorageService.java @@ -15,6 +15,7 @@ */ package cn.odboy.system.service; +import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DateUtil; import cn.hutool.core.io.IORuntimeException; @@ -28,6 +29,8 @@ import cn.odboy.system.dal.model.SystemQueryStorageArgs; import cn.odboy.system.dal.mysql.SystemLocalStorageMapper; import cn.odboy.util.KitFileUtil; import cn.odboy.util.KitPageUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import java.io.File; import java.io.IOException; @@ -152,7 +155,7 @@ public class SystemLocalStorageService { */ public KitPageResult queryLocalStorage(SystemQueryStorageArgs criteria, Page page) { - return KitPageUtil.toPage(systemLocalStorageMapper.selectLocalStorageByArgs(criteria, page)); + return KitPageUtil.toPage(this.selectLocalStorageByArgs(criteria, page)); } /** @@ -162,6 +165,34 @@ public class SystemLocalStorageService { * @return / */ public List queryLocalStorage(SystemQueryStorageArgs criteria) { - return systemLocalStorageMapper.selectLocalStorageByArgs(criteria); + return this.selectLocalStorageByArgs(criteria); + } + + public void injectQueryParams(SystemQueryStorageArgs criteria, LambdaQueryWrapper wrapper) { + if (criteria != null) { + wrapper.and(StrUtil.isNotBlank(criteria.getBlurry()), + c -> c.like(SystemLocalStorageTb::getName, criteria.getBlurry()).or() + .like(SystemLocalStorageTb::getSuffix, criteria.getBlurry()).or() + .like(SystemLocalStorageTb::getType, criteria.getBlurry()).or() + .like(SystemLocalStorageTb::getCreateBy, criteria.getBlurry())); + if (CollUtil.isNotEmpty(criteria.getCreateTime()) && criteria.getCreateTime().size() >= 2) { + wrapper.between(SystemLocalStorageTb::getUpdateTime, criteria.getCreateTime().get(0), + criteria.getCreateTime().get(1)); + } + } + wrapper.orderByDesc(SystemLocalStorageTb::getId); + } + + public List selectLocalStorageByArgs(SystemQueryStorageArgs criteria) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + this.injectQueryParams(criteria, wrapper); + return systemLocalStorageMapper.selectList(wrapper); + } + + public IPage selectLocalStorageByArgs(SystemQueryStorageArgs criteria, + Page page) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + this.injectQueryParams(criteria, wrapper); + return systemLocalStorageMapper.selectPage(page, wrapper); } }