Diboot轻代码开发平台 v3.2.0.zip

/* * Copyright (c) 2015-2020, www.dibo.ltd ([email protected]). * <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 [email protected] * @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(entityClass); 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); } @Transactional(rollbackFor = Exception.class) @Override public boolean createEntity(T entity) { if(entity == null){ warning("createEntity", "参数entity为null"); return false; } return save(entity); } @Transactional(rollbackFor = Exception.class) @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 fieldKey * @param fieldVal */ protected void afterDelete(String fieldKey, Object fieldVal) { } @Override @Transactional(rollbackFor = Exception.class) public <RE, R> boolean createEntityAndRelatedEntities(T entity, List<RE> relatedEntities, ISetter<RE, R> relatedEntitySetter) { boolean success = createEntity(entity); if(!success){ log.warn("新建Entity失败: {}", entity.toString()); return false; } if(V.isEmpty(relatedEntities)){ return true; } Class relatedEntityClass = relatedEntities.get(0).getClass(); // 获取主键 Object pkValue = getPrimaryKeyValue(entity); String relatedEntitySetterFld = BeanUtils.convertToFieldName(relatedEntitySetter); // 填充关联关系 relatedEntities.forEach(relatedEntity-> BeanUtils.setProperty(relatedEntity, relatedEntitySetterFld, pkValue)); // 获取关联对象对应的Service BaseService relatedEntityService = ContextHolder.getBaseServiceByEntity(relatedEntityClass); if(relatedEntityService != null){ return relatedEntityService.createEntities(relatedEntities); } else{ // 查找mapper BaseMapper mapper = ContextHolder.getBaseMapperByEntity(relatedEntityClass); // 新增