/** # __----~~~~~~~~~~~------___ # . . ~~//====...... __--~ ~~ # -. \_|// |||\\ ~~~~~~::::... /~ # ___-==_ _-~o~ \/ ||| \\ _/~~- # __---~~~.==~||\=_ -_--~/_-~|- |\\ \\ _/~ # _-~~ .=~ | \\-_ '-~7 /- / || \ / # .~ .~ | \\ -_ / /- / || \ / # / ____ / | \\ ~-_/ /|- _/ .|| \ / # |~~ ~~|--~~~~--_ \ ~==-/ | \~--===~~ .\ # ' ~-| /| |-~\~~ __--~~ # |-~~-_/ | | ~\_ _-~ /\ # / \ \__ \/~ \__ # _--~ _/ | .-~~____--~-/ ~~==. # ((->/~ '.|||' -_| ~~-/ , . _|| # -_ ~\ ~~---l__i__i__i--~~_/ # _-~-__ ~) \--______________--~~ # //.-~~~-~_--~- |-------~~~~~~~~ # //.-~~~--\ # 神兽保佑 # 永无BUG! */ package com.nanjing.water.repository.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.nanjing.water.common.PagerResult; import com.nanjing.water.common.enums.EYesOrNo; import com.nanjing.water.common.util.*; import com.nanjing.water.entity.dto.*; import com.nanjing.water.entity.enums.*; import com.nanjing.water.entity.search.SearchSysRegion; import com.nanjing.water.repository.BasicMapperImpl; import com.nanjing.water.repository.mapper.SysRegionMapper; import com.nanjing.water.repository.po.SysRegionPO; import org.springframework.stereotype.Repository; import java.util.List; /** * 系统行政地区 * @author lin.liu */ @Repository public class SysRegionMapperImpl extends BasicMapperImpl { SysRegionMapperImpl(SysRegionMapper mapper) { super(mapper); } @Override public PagerResult search(SearchBasicDTO request) { // 还原查询条件真实类型 SearchSysRegion search = (SearchSysRegion)request; // 查询条件 LambdaQueryWrapper queryWrapper = this.query(); // 非逻辑删除 queryWrapper.eq(SysRegionPO::getIsDelete, EYesOrNo.NO.getValue()); // 状态 //queryWrapper.eq(NumericUtil.tryParseInt(search.getStatus()).compareTo(0) > 0, SysRegionPO::getStatus, search.getStatus()); // 状态列表 //queryWrapper.in(ListUtil.isNotNullOrEmpty(search.getListStatus()), SysRegionPO::getStatus, search.getListStatus()); // 数据创建时间-起始 queryWrapper.ge(NumericUtil.tryParseLong(search.getCreateTimeStart()).compareTo(0L) > 0, SysRegionPO::getCreateTime, search.getCreateTimeStart()); // 数据创建时间-截止 queryWrapper.le(NumericUtil.tryParseLong(search.getCreateTimeEnd()).compareTo(0L) > 0, SysRegionPO::getCreateTime, search.getCreateTimeEnd()); // 关键字 //if (StringUtil.isNotNullOrEmpty(search.getKeywords())) { // queryWrapper.and(q -> // q.like(SysRegionPO::getName, search.getKeywords()) // .or().like(SysRegionPO::getPhone, search.getKeywords()) // ); //} // 排序处理 if (ListUtil.isNotNullOrEmpty(search.getOrderBy())) { for (OrderByDTO item : search.getOrderBy()) { EOrderBy orderBy = EOrderBy.getByValue(item.getOrderBy()); // 顺序排序 if (item.getIsAsc()) { switch (orderBy) { // 主键 case ID: queryWrapper.orderByAsc(SysRegionPO::getId); break; // 数据创建时间 case CREATE_TIME: queryWrapper.orderByAsc(SysRegionPO::getCreateTime); break; // 最后更新时间 case UPDATE_TIME: queryWrapper.orderByAsc(SysRegionPO::getUpdateTime); break; } } else { // 倒叙排序 switch (orderBy) { // 主键 case ID: queryWrapper.orderByDesc(SysRegionPO::getId); break; // 数据创建时间 case CREATE_TIME: queryWrapper.orderByDesc(SysRegionPO::getCreateTime); break; // 最后更新时间 case UPDATE_TIME: queryWrapper.orderByDesc(SysRegionPO::getUpdateTime); break; } } } } else { queryWrapper.orderByDesc(SysRegionPO::getId); } Page pageResult = super.selectPage(new Page<>(search.getPage(), search.getLimit()), queryWrapper); return new PagerResult<>(pageResult.getSize(), pageResult.getCurrent(), pageResult.getTotal(), pageResult.getRecords()); } public Boolean add(SysRegionPO item) { int rowCount = super.insert(item); return rowCount == 1; } public List getList4Parent(String code) { LambdaQueryWrapper queryWrapper = this.query(); queryWrapper.eq(SysRegionPO::getParentCode,code); return DB.selectList(queryWrapper); } public SysRegionPO get4Code(String code) { LambdaQueryWrapper queryWrapper = this.query(); queryWrapper.eq(SysRegionPO::getCode,code); return DB.selectOne(queryWrapper); } public List getList4LevelChild(Integer level) { LambdaQueryWrapper queryWrapper = this.query(); queryWrapper.gt(SysRegionPO::getLevel,level); return DB.selectList(queryWrapper); } public List getList4Level(Integer level) { LambdaQueryWrapper queryWrapper = this.query(); queryWrapper.eq(SysRegionPO::getLevel,level); return DB.selectList(queryWrapper); } public Boolean addNotIncrement(SysRegionPO item) { int rowCount = super.insert(item); return rowCount == 1; } public SysRegionPO getById(Long id) { return super.get(id); } public List getListById(List listId) { return super.getList(listId); } public List list4Code(List listCode) { LambdaQueryWrapper queryWrapper = this.query(); queryWrapper.in(SysRegionPO::getCode, listCode); return DB.selectList(queryWrapper); } }