From 90d4fd8cf1db71cf51cfc2694290a9a4bc53344e Mon Sep 17 00:00:00 2001 From: 疯狂的狮子li <15040126243@163.com> Date: 星期六, 24 七月 2021 21:19:05 +0800 Subject: [PATCH] update [重大改动] 重写VO转换 支持深拷贝 将VO类抽象到 ServicePlus 泛型处理 --- ruoyi-common/src/main/java/com/ruoyi/common/core/mybatisplus/core/ServicePlusImpl.java | 126 +++++++++++++++++++++++++++++++++++++++++ 1 files changed, 125 insertions(+), 1 deletions(-) diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/core/mybatisplus/core/ServicePlusImpl.java b/ruoyi-common/src/main/java/com/ruoyi/common/core/mybatisplus/core/ServicePlusImpl.java index fb0998b..0325431 100644 --- a/ruoyi-common/src/main/java/com/ruoyi/common/core/mybatisplus/core/ServicePlusImpl.java +++ b/ruoyi-common/src/main/java/com/ruoyi/common/core/mybatisplus/core/ServicePlusImpl.java @@ -1,12 +1,21 @@ package com.ruoyi.common.core.mybatisplus.core; +import cn.hutool.core.bean.copier.BeanCopier; +import cn.hutool.core.bean.copier.CopyOptions; +import cn.hutool.core.util.ReflectUtil; +import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.toolkit.ClassUtils; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.common.core.page.PagePlus; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.core.ResolvableType; +import java.io.Serializable; import java.util.Collection; +import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; /** * IServicePlus 瀹炵幇绫� @@ -15,7 +24,7 @@ */ @Slf4j @SuppressWarnings("unchecked") -public class ServicePlusImpl<M extends BaseMapperPlus<T>, T> extends ServiceImpl<M, T> implements IServicePlus<T> { +public class ServicePlusImpl<M extends BaseMapperPlus<T>, T, K> extends ServiceImpl<M, T> implements IServicePlus<T, K> { @Autowired protected M baseMapper; @@ -35,6 +44,12 @@ protected Class<T> mapperClass = currentMapperClass(); + protected Class<K> voClass = currentVoClass(); + + public Class<K> getVoClass() { + return voClass; + } + @Override protected Class<T> currentMapperClass() { return (Class<T>) this.getResolvableType().as(ServicePlusImpl.class).getGeneric(0).getType(); @@ -43,6 +58,10 @@ @Override protected Class<T> currentModelClass() { return (Class<T>) this.getResolvableType().as(ServicePlusImpl.class).getGeneric(1).getType(); + } + + protected Class<K> currentVoClass() { + return (Class<K>) this.getResolvableType().as(ServicePlusImpl.class).getGeneric(2).getType(); } @Override @@ -76,6 +95,21 @@ return super.updateBatchById(entityList, batchSize); } + @Override + public boolean saveBatch(Collection<T> entityList) { + return saveBatch(entityList, DEFAULT_BATCH_SIZE); + } + + @Override + public boolean saveOrUpdateBatch(Collection<T> entityList) { + return saveOrUpdateBatch(entityList, DEFAULT_BATCH_SIZE); + } + + @Override + public boolean updateBatchById(Collection<T> entityList) { + return updateBatchById(entityList, DEFAULT_BATCH_SIZE); + } + /** * 鍗晄ql鎵归噺鎻掑叆( 鍏ㄩ噺濉厖 鏃犺鏁版嵁搴撻粯璁ゅ�� ) * 閫傜敤浜庢棤鑴戞彃鍏� @@ -85,4 +119,94 @@ return baseMapper.insertAll(entityList) == entityList.size(); } + /** + * 鏍规嵁 ID 鏌ヨ + * + * @param id 涓婚敭ID + */ + @Override + public K getVoById(Serializable id, CopyOptions copyOptions) { + T t = getBaseMapper().selectById(id); + return oneVoCopy(t, copyOptions); + } + + /** + * 鏌ヨ锛堟牴鎹甀D 鎵归噺鏌ヨ锛� + * + * @param idList 涓婚敭ID鍒楄〃 + */ + @Override + public List<K> listVoByIds(Collection<? extends Serializable> idList, CopyOptions copyOptions) { + List<T> list = getBaseMapper().selectBatchIds(idList); + if (list == null) { + return null; + } + return listVoCopy(list, copyOptions); + } + + /** + * 鏌ヨ锛堟牴鎹� columnMap 鏉′欢锛� + * + * @param columnMap 琛ㄥ瓧娈� map 瀵硅薄 + */ + @Override + public List<K> listVoByMap(Map<String, Object> columnMap, CopyOptions copyOptions) { + List<T> list = getBaseMapper().selectByMap(columnMap); + if (list == null) { + return null; + } + return listVoCopy(list, copyOptions); + } + + /** + * 鏍规嵁 Wrapper锛屾煡璇竴鏉¤褰� <br/> + * <p>缁撴灉闆嗭紝濡傛灉鏄涓細鎶涘嚭寮傚父锛岄殢鏈哄彇涓�鏉″姞涓婇檺鍒舵潯浠� wrapper.last("LIMIT 1")</p> + * + * @param queryWrapper 瀹炰綋瀵硅薄灏佽鎿嶄綔绫� {@link com.baomidou.mybatisplus.core.conditions.query.QueryWrapper} + */ + @Override + public K getVoOne(Wrapper<T> queryWrapper, CopyOptions copyOptions) { + T t = getOne(queryWrapper, true); + return oneVoCopy(t, copyOptions); + } + + /** + * 鏌ヨ鍒楄〃 + * + * @param queryWrapper 瀹炰綋瀵硅薄灏佽鎿嶄綔绫� {@link com.baomidou.mybatisplus.core.conditions.query.QueryWrapper} + */ + @Override + public List<K> listVo(Wrapper<T> queryWrapper, CopyOptions copyOptions) { + List<T> list = getBaseMapper().selectList(queryWrapper); + if (list == null) { + return null; + } + return listVoCopy(list, copyOptions); + } + + /** + * 缈婚〉鏌ヨ + * + * @param page 缈婚〉瀵硅薄 + * @param queryWrapper 瀹炰綋瀵硅薄灏佽鎿嶄綔绫� + */ + @Override + public PagePlus<T, K> pageVo(PagePlus<T, K> page, Wrapper<T> queryWrapper, CopyOptions copyOptions) { + PagePlus<T, K> result = getBaseMapper().selectPage(page, queryWrapper); + List<K> volist = listVoCopy(result.getRecords(), copyOptions); + result.setRecordsVo(volist); + return result; + } + + private K oneVoCopy(T t, CopyOptions copyOptions) { + K k = ReflectUtil.newInstanceIfPossible(voClass); + return BeanCopier.create(t, k, copyOptions).copy(); + } + + private List<K> listVoCopy(List<T> list, CopyOptions copyOptions) { + return list.stream() + .map(any -> BeanCopier.create(any, ReflectUtil.newInstanceIfPossible(voClass), copyOptions).copy()) + .collect(Collectors.toList()); + } + } -- Gitblit v1.9.3