为开发人员打造的低代码开发平台 Mybatis-plus关联查询，关联无SQL，性能高10倍，前后端代码本地可视化生成，flo...

/* * Copyright (c) 2015-2020, www.dibo.ltd (service@dibo.ltd). * <p> * Licensed under the Apache License, Version 2.0 (the "License"); you may not * use this file except in compliance with the License. You may obtain a copy of * the License at * <p> * https://www.apache.org/licenses/LICENSE-2.0 * <p> * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the * License for the specific language governing permissions and limitations under * the License. */ package com.diboot.core.service.impl; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.LambdaUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.support.LambdaMeta; import com.baomidou.mybatisplus.core.toolkit.support.SFunction; import com.baomidou.mybatisplus.extension.conditions.query.ChainQuery; import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.baomidou.mybatisplus.extension.conditions.query.QueryChainWrapper; import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper; import com.baomidou.mybatisplus.extension.conditions.update.UpdateChainWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.toolkit.ChainWrappers; import com.diboot.core.binding.Binder; import com.diboot.core.binding.cache.BindingCacheManager; import com.diboot.core.binding.helper.ServiceAdaptor; import com.diboot.core.binding.helper.WrapperHelper; import com.diboot.core.binding.parser.EntityInfoCache; import com.diboot.core.binding.parser.ParserCache; import com.diboot.core.binding.parser.PropInfo; import com.diboot.core.binding.query.dynamic.DynamicJoinQueryWrapper; import com.diboot.core.config.BaseConfig; import com.diboot.core.config.Cons; import com.diboot.core.dto.SortParamDTO; import com.diboot.core.entity.BaseTreeEntity; import com.diboot.core.exception.BusinessException; import com.diboot.core.exception.InvalidUsageException; import com.diboot.core.mapper.BaseCrudMapper; import com.diboot.core.service.BaseService; import com.diboot.core.util.*; import com.diboot.core.vo.LabelValue; import com.diboot.core.vo.Pagination; import com.diboot.core.vo.Status; import org.apache.ibatis.reflection.property.PropertyNamer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeanWrapper; import org.springframework.lang.Nullable; import org.springframework.transaction.annotation.Transactional; import java.io.Serializable; import java.lang.invoke.SerializedLambda; import java.util.*; import java.util.concurrent.atomic.AtomicLong; import java.util.function.BiFunction; import java.util.function.Consumer; import java.util.function.Function; import java.util.stream.Collectors; /** * CRUD通用接口实现类 * @author mazc@dibo.ltd * @param <M> mapper类 * @param <T> entity类 * @version 2.0 * @date 2019/01/01 */ @SuppressWarnings({"unchecked", "rawtypes", "JavaDoc"}) public class BaseServiceImpl<M extends BaseCrudMapper<T>, T> extends ServiceImpl<M, T> implements BaseService<T> { private static final Logger log = LoggerFactory.getLogger(BaseServiceImpl.class); /** * 获取当前的Mapper对象 * @return */ @Override public M getMapper(){ return baseMapper; } @Override public QueryChainWrapper<T> query() { return ChainWrappers.queryChain(this.getBaseMapper()); } @Override public LambdaQueryChainWrapper<T> lambdaQuery() { return ChainWrappers.lambdaQueryChain(this.getBaseMapper()); } @Override public UpdateChainWrapper<T> update() { return ChainWrappers.updateChain(this.getBaseMapper()); } @Override public LambdaUpdateChainWrapper<T> lambdaUpdate() { return ChainWrappers.lambdaUpdateChain(this.getBaseMapper()); } @Override public T getEntity(Serializable id){ return super.getById(id); } @Override public <FT> FT getValueOfField(Serializable idVal, SFunction<T, FT> getterFn) { PropInfo propInfo = BindingCacheManager.getPropInfoByClass(getEntityClass()); String fetchCol = propInfo.getColumnByField(BeanUtils.convertSFunctionToFieldName(getterFn)); QueryWrapper<T> queryWrapper = new QueryWrapper<T>() .select(propInfo.getIdColumn(), fetchCol) .eq(propInfo.getIdColumn(), idVal); T entity = getSingleEntity(queryWrapper); if(entity == null){ return null; } return getterFn.apply(entity); } @Override public <FT> FT getValueOfField(SFunction<T, ?> queryFieldFn, Serializable queryFieldVal, SFunction<T, FT> getterFn) { return getValueOfField(Wrappers.<T>lambdaQuery().eq(queryFieldFn, queryFieldVal), getterFn); } @Override public <FT> FT getValueOfField(LambdaQueryWrapper<T> queryWrapper, SFunction<T, FT> getterFn) { T entity = getSingleEntity(queryWrapper.select(getterFn)); if(entity == null){ return null; } return getterFn.apply(entity); } @Override public <FT> List<FT> getValuesOfField(String fieldKey, Object fieldVal, SFunction<T, FT> getterFn) { QueryWrapper<T> queryWrapper = buildQueryWrapperByFieldValue(fieldKey, fieldVal); PropInfo propInfo = BindingCacheManager.getPropInfoByClass(getEntityClass()); String fetchCol = propInfo.getColumnByField(BeanUtils.convertSFunctionToFieldName(getterFn)); queryWrapper.select(fetchCol); return getValuesOfField(queryWrapper, getterFn); } /** * 基于给定的字段和值，构建 QueryWrapper * @param fieldKey * @param fieldVal * @return */ protected QueryWrapper<T> buildQueryWrapperByFieldValue(String fieldKey, Object fieldVal){ PropInfo propInfo = BindingCacheManager.getPropInfoByClass(getEntityClass()); String conditionCol = propInfo.getColumnByField(fieldKey); QueryWrapper<T> queryWrapper = new QueryWrapper<T>(); if((fieldVal instanceof Collection)){ queryWrapper.in(conditionCol, (Collection<?>) fieldVal); } else if(fieldVal.getClass().isArray()){ queryWrapper.in(conditionCol, (Object[]) fieldVal); } else { queryWrapper.eq(conditionCol, fieldVal); } return queryWrapper; } @Transactional(rollbackFor = Exception.class) @Override public boolean createEntity(T entity) { if(entity == null){ warning("createEntity", "参数entity为null"); return false; } return save(entity); } @Override public boolean save(T entity) { this.beforeCreate(entity); boolean success = super.save(entity); if(success) { this.afterCreate(entity); } return success; } /** * 用于创建之前的自动填充等场景调用 */ protected void beforeCreate(T entity) { if(entity instanceof BaseTreeEntity) { fillTreeNodeParentPath(entity); } } /** * 创建数据的后拦截 * @param entity */ protected void afterCreate(T entity) { } /** * 批量创建数据的前拦截 * @param entityList */ protected void beforeBatchCreate(Collection<T> entityList) { } /** * 批量创建数据的后拦截 * @param entityList */ protected void afterBatchCreate(Collection<T> entityList) { } /** * 更新数据的后拦截 * @param entity */ protected void afterUpdate(T entity) { } /** * 删除数据的前拦截，值可能为单值或集合 * @param fieldKey * @param fieldVal */ protected void beforeDelete(String fieldKey, Object fieldVal) { } /** * 删除数据的前拦截，值可能为单值或集合 * @param entityIds */ protected void beforeDelete(Object entityIds) { String