admin/qingcheng-houduan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first commit

Browse Source
This commit is contained in:
chen-xin-zhi
2025-04-01 11:48:31 +08:00
commit fcebd8474e
49 changed files with 2804 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

96
src/main/java/com/greenorange/promotion/service/common/CommonService.java Normal file
View File

@ -0,0 +1,96 @@
package com.greenorange.promotion.service.common;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.IService;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
public interface CommonService {
/**
* 从源集合中提取指定属性并作为查询条件查询目标集合
* @param sourceList 源集合（List<T>），包含需要提取属性的元素
* @param service 执行查询的 Service
* @param getField 提取源集合中每个元素的属性值的函数
* @param targetField 目标集合中查询字段的字段名
* @param <T> 源集合元素类型
* @param <R> 目标集合中元素类型
* @return 查询结果集合
*/
<T, R> List<R> findByFieldInTargetField(List<T> sourceList, IService<R> service, Function<T, Object> getField, String targetField);
/**
* 根据指定字段名和值，使用给定的服务对象构建查询条件。
* @param <T> 实体类类型
* @param fieldName 查询字段的名称
* @param fieldValue 查询字段的值
* @param service 用于执行查询的服务层对象
*
* @return 返回构建的 QueryWrapper 对象，用于进一步查询或修改
*/
<T> QueryWrapper<T> buildQueryWrapperByField(String fieldName, Object fieldValue, IService<T> service);
/**
* 根据指定字段名和值，使用给定的服务对象查询对应的实体类列表。
* @param <T> 实体类类型
* @param fieldName 查询字段的名称
* @param fieldValue 查询字段的值
* @param service 用于执行查询的服务层对象
* @return 返回符合条件的实体类列表（`List<T>`）。如果没有符合条件的记录，返回空列表。
*/
<T> List<T> findByFieldEqTargetField(String fieldName, Object fieldValue, IService<T> service);
/**
* 根据多个字段和对应的值进行查询。
* 该方法可以动态构建查询条件并执行查询。
*
* @param fieldConditions 查询条件的字段和值，使用Map存储
* @param service 执行查询操作的服务对象（通常是MyBatis-Plus的 IService）
* @return 返回查询结果的列表
*/
<T> List<T> findByFieldEqTargetFields(Map<String, Object> fieldConditions, IService<T> service);
/**
* 将一个类型的 List 转换为另一个类型的 List。
* @param sourceList 源列表，类型为 T
* @param targetClass 目标类型的 Class 对象
* @param <T> 源类型
* @param <R> 目标类型
* @return 转换后的目标类型列表
*/
<T, R> List<R> convertList(List<T> sourceList, Class<R> targetClass);
/**
* 复制属性并返回新的目标对象
*
* @param source 源对象
* @param targetClass 目标对象的类型
* @param <S> 源对象类型
* @param <T> 目标对象类型
* @return 目标对象
*/
<S, T> T copyProperties(S source, Class<T> targetClass);
}

179
src/main/java/com/greenorange/promotion/service/common/impl/CommonServiceImpl.java Normal file
View File

@ -0,0 +1,179 @@
package com.greenorange.promotion.service.common.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.IService;
import com.greenorange.promotion.service.common.CommonService;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;
@Service
public class CommonServiceImpl implements CommonService {
/**
* 从源集合中提取指定属性并作为查询条件查询目标集合
* @param sourceList 源集合（List<T>），包含需要提取属性的元素
* @param service 执行查询的 Service
* @param getField 提取源集合中每个元素的属性值的函数
* @param targetField 目标集合中查询字段的字段名
* @param <T> 源集合元素类型
* @param <R> 目标集合中元素类型
* @return 查询结果集合
*/
public <T, R> List<R> findByFieldInTargetField(List<T> sourceList, IService<R> service, Function<T, Object> getField, String targetField) {
// 提取源集合中每个元素的字段值
List<Object> fieldValues = sourceList.stream()
.map(getField) // 提取每个元素的字段值
.collect(Collectors.toList());
// 如果 fieldValues 为空，直接返回空集合
if (fieldValues.isEmpty()) {
return List.of(); // 返回空集合
}
// 创建查询条件
QueryWrapper<R> queryWrapper = new QueryWrapper<>();
queryWrapper.in(targetField, fieldValues); // 根据字段值进行查询
// 执行查询并返回结果
return service.list(queryWrapper);
}
/**
* 根据指定字段名和值，使用给定的服务对象构建查询条件。
* @param <T> 实体类类型
* @param fieldName 查询字段的名称
* @param fieldValue 查询字段的值
* @param service 用于执行查询的服务层对象
*
* @return 返回构建的 QueryWrapper 对象，用于进一步查询或修改
*/
@Override
public <T> QueryWrapper<T> buildQueryWrapperByField(String fieldName, Object fieldValue, IService<T> service) {
// 创建 QueryWrapper，动态构建查询条件
QueryWrapper<T> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(fieldName, fieldValue); // 设置等值查询条件
// 返回 QueryWrapper，供外部使用
return queryWrapper;
}
/**
* 根据指定字段名和值，使用给定的服务对象查询对应的实体类列表。
* @param <T> 实体类类型
* @param fieldName 查询字段的名称
* @param fieldValue 查询字段的值
* @param service 用于执行查询的服务层对象
*
* @return 返回符合条件的实体类列表（`List<T>`）。如果没有符合条件的记录，返回空列表。
*/
@Override
public <T> List<T> findByFieldEqTargetField(String fieldName, Object fieldValue, IService<T> service) {
// 创建 QueryWrapper，动态构建查询条件
QueryWrapper<T> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(fieldName, fieldValue); // 设置等值查询条件
// 执行查询
return service.list(queryWrapper);
}
/**
* 根据多个字段和对应的值进行查询。
* 该方法根据输入的查询条件，动态构建查询，并执行数据库查询。
* @param fieldConditions 查询条件的字段和值，使用Map存储
* @param service 执行查询操作的服务对象（通常是MyBatis-Plus的 IService）
* @return 返回查询结果的列表
*/
@Override
public <T> List<T> findByFieldEqTargetFields(Map<String, Object> fieldConditions, IService<T> service) {
// 创建 QueryWrapper，动态构建查询条件
QueryWrapper<T> queryWrapper = new QueryWrapper<>();
// 遍历传入的条件Map，逐个设置查询条件
for (Map.Entry<String, Object> entry : fieldConditions.entrySet()) {
// 设置等值查询条件
queryWrapper.eq(entry.getKey(), entry.getValue());
}
// 执行查询，并返回结果
return service.list(queryWrapper);
}
/**
* 将源列表 List<T> 转换为目标类型的列表 List<R>
* @param sourceList 源列表，包含 T 类型的对象
* @param targetClass 目标类型的 Class 对象
* @param <T> 源类型
* @param <R> 目标类型
* @return 转换后的目标类型的 List
*/
@Override
public <T, R> List<R> convertList(List<T> sourceList, Class<R> targetClass) {
// 使用 Stream 流式操作来遍历源列表，并将每个元素转换为目标类型
return sourceList.stream()
.map(source -> {
try {
// 通过反射创建目标类型的实例
R target = targetClass.getDeclaredConstructor().newInstance();
// 使用 BeanUtils.copyProperties 复制属性
BeanUtils.copyProperties(source, target);
return target;
} catch (Exception e) {
// 捕获异常并抛出运行时异常
throw new RuntimeException("Error copying properties", e);
}
})
.collect(Collectors.toList()); // 将转换后的对象收集到目标类型的列表中
}
/**
* 复制属性并返回新的目标对象
*
* @param source 源对象
* @param targetClass 目标对象的类型
* @param <S> 源对象类型
* @param <T> 目标对象类型
* @return 目标对象
*/
public <S, T> T copyProperties(S source, Class<T> targetClass) {
try {
if (source == null || targetClass == null) {
return null;
}
// 创建目标对象
T target = targetClass.getDeclaredConstructor().newInstance();
// 复制属性
BeanUtils.copyProperties(source, target);
return target;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
}

68
src/main/java/com/greenorange/promotion/service/user/UserService.java Normal file
View File

@ -0,0 +1,68 @@
package com.greenorange.promotion.service.user;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.greenorange.promotion.model.dto.CommonBatchRequest;
import com.greenorange.promotion.model.dto.CommonRequest;
import com.greenorange.promotion.model.dto.user.UserAddRequest;
import com.greenorange.promotion.model.dto.user.UserQueryRequest;
import com.greenorange.promotion.model.dto.user.UserUpdateRequest;
import com.greenorange.promotion.model.entity.User;
import com.baomidou.mybatisplus.extension.service.IService;
import com.greenorange.promotion.model.vo.user.UserVO;
import java.util.List;
/**
* @author 35880
* @description 针对表【user(用户表)】的数据库操作Service
* @createDate 2025-03-30 23:03:14
*/
public interface UserService extends IService<User> {
/**
* 获取查询条件
*/
QueryWrapper<User> getQueryWrapper(UserQueryRequest userQueryRequest);
/**
* 分页查询用户
*/
Page<UserVO> listUserByPage(UserQueryRequest userQueryRequest);
/**
* 根据id查询用户
*/
UserVO queryUserById(CommonRequest commonRequest);
/**
* 添加用户
*/
Long addUser(UserAddRequest userAddRequest);
/**
* 更新用户
*/
boolean updateUser(UserUpdateRequest userUpdateRequest);
/**
* 删除用户
*/
boolean deleteUser(CommonRequest commonRequest);
/**
* 批量删除用户
*/
boolean delBatchUser(CommonBatchRequest commonBatchRequest);
}

156
src/main/java/com/greenorange/promotion/service/user/impl/UserServiceImpl.java Normal file
View File

@ -0,0 +1,156 @@
package com.greenorange.promotion.service.user.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.greenorange.promotion.common.ErrorCode;
import com.greenorange.promotion.common.ResultUtils;
import com.greenorange.promotion.constant.CommonConstant;
import com.greenorange.promotion.exception.BusinessException;
import com.greenorange.promotion.exception.ThrowUtils;
import com.greenorange.promotion.model.dto.CommonBatchRequest;
import com.greenorange.promotion.model.dto.CommonRequest;
import com.greenorange.promotion.model.dto.user.UserAddRequest;
import com.greenorange.promotion.model.dto.user.UserQueryRequest;
import com.greenorange.promotion.model.dto.user.UserUpdateRequest;
import com.greenorange.promotion.model.entity.User;
import com.greenorange.promotion.model.vo.user.UserVO;
import com.greenorange.promotion.service.common.CommonService;
import com.greenorange.promotion.service.user.UserService;
import com.greenorange.promotion.mapper.UserMapper;
import com.greenorange.promotion.utils.SqlUtils;
import jakarta.annotation.Resource;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* @author 35880
* @description 针对表【user(用户表)】的数据库操作Service实现
* @createDate 2025-03-30 23:03:14
*/
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService{
@Resource
private CommonService commonService;
/**
* 获取查询条件
*/
@Override
public QueryWrapper<User> getQueryWrapper(UserQueryRequest userQueryRequest) {
Long id = userQueryRequest.getId();
String userName = userQueryRequest.getUserName();
String userRole = userQueryRequest.getUserRole();
String sortField = userQueryRequest.getSortField();
String sortOrder = userQueryRequest.getSortOrder();
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(id != null, "id", id);
queryWrapper.like(StringUtils.isNotBlank(userName), "userName", userName);
queryWrapper.eq(StringUtils.isNotBlank(userRole), "userRole", userRole);
queryWrapper.orderBy(SqlUtils.validSortField(sortField), sortOrder.equals(CommonConstant.SORT_ORDER_ASC),
sortField);
return queryWrapper;
}
/**
* 分页查询用户
*/
@Override
public Page<UserVO> listUserByPage(UserQueryRequest userQueryRequest) {
if (userQueryRequest == null) throw new BusinessException(ErrorCode.PARAMS_ERROR);
long current = userQueryRequest.getCurrent();
long pageSize = userQueryRequest.getPageSize();
QueryWrapper<User> queryWrapper = this.getQueryWrapper(userQueryRequest);
Page<User> page = this.page(new Page<>(current, pageSize), queryWrapper);
List<User> userList = page.getRecords();
List<UserVO> userVOList = commonService.convertList(userList, UserVO.class);
Page<UserVO> voPage = new Page<>();
voPage.setRecords(userVOList);
voPage.setPages(page.getPages());
voPage.setCurrent(page.getCurrent());
voPage.setTotal(page.getTotal());
voPage.setSize(page.getSize());
return voPage;
}
/**
* 根据id查询用户
*/
@Override
public UserVO queryUserById(CommonRequest commonRequest) {
if (commonRequest == null || commonRequest.getId() <= 0) {
throw new BusinessException(ErrorCode.PARAMS_ERROR);
}
User user = this.getById(commonRequest.getId());
ThrowUtils.throwIf(user == null, ErrorCode.OPERATION_ERROR, "用户不存在");
return commonService.copyProperties(user, UserVO.class);
}
/**
* 添加用户
*/
@Override
public Long addUser(UserAddRequest userAddRequest) {
if (userAddRequest == null) {
throw new BusinessException(ErrorCode.PARAMS_ERROR);
}
User user = commonService.copyProperties(userAddRequest, User.class);
boolean result = this.save(user);
ThrowUtils.throwIf(!result, ErrorCode.OPERATION_ERROR, "用户添加失败");
return user.getId();
}
/**
* 更新用户
*/
@Override
public boolean updateUser(UserUpdateRequest userUpdateRequest) {
if (userUpdateRequest == null || userUpdateRequest.getId() <= 0) {
throw new BusinessException(ErrorCode.PARAMS_ERROR);
}
User user = commonService.copyProperties(userUpdateRequest, User.class);
boolean result = this.updateById(user);
ThrowUtils.throwIf(!result, ErrorCode.OPERATION_ERROR, "用户更新失败");
return true;
}
/**
* 删除用户
*/
@Override
public boolean deleteUser(CommonRequest commonRequest) {
if (commonRequest == null || commonRequest.getId() <= 0) {
throw new BusinessException(ErrorCode.PARAMS_ERROR);
}
Long id = commonRequest.getId();
boolean result = this.removeById(id);
ThrowUtils.throwIf(!result, ErrorCode.OPERATION_ERROR, "用户删除失败");
return true;
}
/**
* 批量删除用户
*/
@Override
public boolean delBatchUser(CommonBatchRequest commonBatchRequest) {
if (commonBatchRequest == null || CollectionUtils.isEmpty(commonBatchRequest.getIds())) {
throw new BusinessException(ErrorCode.PARAMS_ERROR);
}
List<Long> ids = commonBatchRequest.getIds();
boolean result = this.removeByIds(ids);
ThrowUtils.throwIf(!result, ErrorCode.OPERATION_ERROR, "用户批量删除失败");
return true;
}
}