diff --git a/backend/src/main/java/com/stdproject/config/CustomUserDetailsService.java b/backend/src/main/java/com/stdproject/config/CustomUserDetailsService.java index 5b798f7..71255ba 100644 --- a/backend/src/main/java/com/stdproject/config/CustomUserDetailsService.java +++ b/backend/src/main/java/com/stdproject/config/CustomUserDetailsService.java @@ -1,11 +1,14 @@ package com.stdproject.config; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.stdproject.entity.User; +import com.stdproject.service.IMenuService; +import com.stdproject.service.IRoleService; +import com.stdproject.service.IUserService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.security.core.GrantedAuthority; import org.springframework.security.core.authority.SimpleGrantedAuthority; -import org.springframework.security.core.userdetails.User; import org.springframework.security.core.userdetails.UserDetails; import org.springframework.security.core.userdetails.UserDetailsService; import org.springframework.security.core.userdetails.UsernameNotFoundException; @@ -29,25 +32,19 @@ import java.util.stream.Collectors; public class CustomUserDetailsService implements UserDetailsService { @Autowired - private IAppUserService appUserService; + private IUserService appUserService; @Autowired - private IAppRoleService appRoleService; + private IRoleService appRoleService; + @Autowired - private IAppRoleUserService appRoleUserService; - - @Autowired - private IAppRoleMenuService appRoleMenuService; - - @Autowired - private IAppMenuService appMenuService; + private IMenuService appMenuService; @Override public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException { log.debug("加载用户信息: {}", username); - - AppUser appUser = appUserService.findByUsername(username); + User appUser = appUserService.findByUsername(username); if (appUser == null) { log.warn("用户不存在: {}", username); throw new UsernameNotFoundException("用户不存在: " + username); @@ -62,7 +59,7 @@ public class CustomUserDetailsService implements UserDetailsService { // 构建用户权限 Collection authorities = buildUserAuthorities(appUser); - return User.builder() + return org.springframework.security.core.userdetails.User.builder() .username(appUser.getUsername()) .password(appUser.getPassword()) .authorities(authorities) @@ -79,7 +76,7 @@ public class CustomUserDetailsService implements UserDetailsService { * @param appUser 用户信息 * @return 权限集合 */ - private Collection buildUserAuthorities(AppUser appUser) { + private Collection buildUserAuthorities(User appUser) { Set authorities = new HashSet<>(); try { @@ -91,65 +88,65 @@ public class CustomUserDetailsService implements UserDetailsService { } // 查询用户的角色 - QueryWrapper roleUserQuery = new QueryWrapper<>(); - roleUserQuery.eq("userid", appUser.getId()); - List roleUsers = appRoleUserService.list(roleUserQuery); - - if (!roleUsers.isEmpty()) { - // 获取角色ID列表 - List roleIds = roleUsers.stream() - .map(AppRoleUser::getRoleid) - .collect(Collectors.toList()); - - // 查询角色信息并添加角色权限 - List roles = appRoleService.listByIds(roleIds); - for (AppRole role : roles) { - if ("1".equals(role.getIsvaild())) { - // 添加角色权限，格式：ROLE_角色编码 - if (StringUtils.hasText(role.getRolecode())) { - authorities.add(new SimpleGrantedAuthority("ROLE_" + role.getRolecode().toUpperCase())); - } - } - } - - // 查询角色关联的菜单权限 - QueryWrapper roleMenuQuery = new QueryWrapper<>(); - roleMenuQuery.in("roleid", roleIds); - List roleMenus = appRoleMenuService.list(roleMenuQuery); - - if (!roleMenus.isEmpty()) { - // 获取菜单ID列表 - List menuIds = roleMenus.stream() - .map(AppRoleMenu::getMenuid) - .distinct() - .collect(Collectors.toList()); - - // 查询菜单信息并添加菜单权限 - List menus = appMenuService.listByIds(menuIds); - for (AppMenu menu : menus) { - if ("1".equals(menu.getIsdisplay()) && StringUtils.hasText(menu.getCode())) { - // 添加菜单权限，格式：菜单编码 - authorities.add(new SimpleGrantedAuthority(menu.getCode())); - - // 根据菜单类型添加操作权限 - String menuCode = menu.getCode(); - if (StringUtils.hasText(menuCode)) { - // 为每个菜单添加基本操作权限 - authorities.add(new SimpleGrantedAuthority(menuCode + ":list")); - authorities.add(new SimpleGrantedAuthority(menuCode + ":detail")); - - // 管理员拥有所有操作权限 - if ("0".equals(appUser.getUsertype())) { - authorities.add(new SimpleGrantedAuthority(menuCode + ":add")); - authorities.add(new SimpleGrantedAuthority(menuCode + ":edit")); - authorities.add(new SimpleGrantedAuthority(menuCode + ":delete")); - authorities.add(new SimpleGrantedAuthority(menuCode + ":permission")); - } - } - } - } - } - } +// QueryWrapper roleUserQuery = new QueryWrapper<>(); +// roleUserQuery.eq("userid", appUser.getId()); +// List roleUsers = appRoleUserService.list(roleUserQuery); +// +// if (!roleUsers.isEmpty()) { +// // 获取角色ID列表 +// List roleIds = roleUsers.stream() +// .map(AppRoleUser::getRoleid) +// .collect(Collectors.toList()); +// +// // 查询角色信息并添加角色权限 +// List roles = appRoleService.listByIds(roleIds); +// for (AppRole role : roles) { +// if ("1".equals(role.getIsvaild())) { +// // 添加角色权限，格式：ROLE_角色编码 +// if (StringUtils.hasText(role.getRolecode())) { +// authorities.add(new SimpleGrantedAuthority("ROLE_" + role.getRolecode().toUpperCase())); +// } +// } +// } +// +// // 查询角色关联的菜单权限 +// QueryWrapper roleMenuQuery = new QueryWrapper<>(); +// roleMenuQuery.in("roleid", roleIds); +// List roleMenus = appRoleMenuService.list(roleMenuQuery); +// +// if (!roleMenus.isEmpty()) { +// // 获取菜单ID列表 +// List menuIds = roleMenus.stream() +// .map(AppRoleMenu::getMenuid) +// .distinct() +// .collect(Collectors.toList()); +// +// // 查询菜单信息并添加菜单权限 +// List menus = appMenuService.listByIds(menuIds); +// for (AppMenu menu : menus) { +// if ("1".equals(menu.getIsdisplay()) && StringUtils.hasText(menu.getCode())) { +// // 添加菜单权限，格式：菜单编码 +// authorities.add(new SimpleGrantedAuthority(menu.getCode())); +// +// // 根据菜单类型添加操作权限 +// String menuCode = menu.getCode(); +// if (StringUtils.hasText(menuCode)) { +// // 为每个菜单添加基本操作权限 +// authorities.add(new SimpleGrantedAuthority(menuCode + ":list")); +// authorities.add(new SimpleGrantedAuthority(menuCode + ":detail")); +// +// // 管理员拥有所有操作权限 +// if ("0".equals(appUser.getUsertype())) { +// authorities.add(new SimpleGrantedAuthority(menuCode + ":add")); +// authorities.add(new SimpleGrantedAuthority(menuCode + ":edit")); +// authorities.add(new SimpleGrantedAuthority(menuCode + ":delete")); +// authorities.add(new SimpleGrantedAuthority(menuCode + ":permission")); +// } +// } +// } +// } +// } +// } log.debug("用户 {} 的权限列表: {}", appUser.getUsername(), authorities.stream().map(GrantedAuthority::getAuthority).collect(Collectors.toList())); @@ -174,7 +171,7 @@ public class CustomUserDetailsService implements UserDetailsService { * @param appUser 用户信息 * @return 是否被锁定 */ - private boolean isAccountLocked(AppUser appUser) { + private boolean isAccountLocked(User appUser) { // 检查登录失败锁定时间 if (appUser.getFailedlocktime() != null) { // 如果锁定时间还未过期，则账户被锁定 @@ -189,7 +186,7 @@ public class CustomUserDetailsService implements UserDetailsService { * @param appUser 用户信息 * @return 是否过期 */ - private boolean isCredentialsExpired(AppUser appUser) { + private boolean isCredentialsExpired(User appUser) { // 检查密码是否过期 if (appUser.getPwdresettime() != null && appUser.getPwdvalidperiod() != null) { java.time.LocalDateTime expireTime = appUser.getPwdresettime().plusDays(appUser.getPwdvalidperiod()); diff --git a/backend/src/main/java/com/stdproject/service/IUserService.java b/backend/src/main/java/com/stdproject/service/IUserService.java index c3d5f19..216073d 100644 --- a/backend/src/main/java/com/stdproject/service/IUserService.java +++ b/backend/src/main/java/com/stdproject/service/IUserService.java @@ -88,4 +88,12 @@ public interface IUserService extends IService { * 返回值说明: 是否新增成功 ***********************************/ boolean addUserRole(String roleid, String userid); + + /*********************************** + * 用途说明：根据用于名称查询用户 + * 参数说明 + * username 角色名称 + * 返回值说明: 是否新增成功 + ***********************************/ + User findByUsername(String username); } diff --git a/backend/src/main/java/com/stdproject/service/impl/DynamicDataServiceImpl.java b/backend/src/main/java/com/stdproject/service/impl/DynamicDataServiceImpl.java new file mode 100644 index 0000000..3258ba5 --- /dev/null +++ b/backend/src/main/java/com/stdproject/service/impl/DynamicDataServiceImpl.java @@ -0,0 +1,450 @@ +package com.stdproject.service.impl; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.stdproject.common.BusinessException; +import com.stdproject.entity.CoreDatasource; +import com.stdproject.mapper.CoreDatasourceMapper; +import com.stdproject.service.IDynamicDataService; +import io.gisbi.exception.DEException; +import io.gisbi.extensions.datasource.dto.DatasourceRequest; +import io.gisbi.extensions.datasource.dto.DatasourceSchemaDTO; +import io.gisbi.extensions.datasource.dto.TableField; +import io.gisbi.extensions.datasource.factory.ProviderFactory; +import io.gisbi.extensions.datasource.provider.Provider; +import io.gisbi.utils.BeanUtils; +import io.gisbi.utils.IDUtils; +import io.gisbi.utils.JsonUtil; +import jakarta.annotation.Resource; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; +import com.stdproject.utils.EncryptUtils; +import java.util.ArrayList; +import java.util.LinkedHashMap; +import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; + +@Slf4j +@Service +public class DynamicDataServiceImpl implements IDynamicDataService { + @Resource + private CoreDatasourceMapper coreDatasourceMapper; + @Override + public boolean addTableData(Long datasourceId, String tableData) throws Exception { + // 根据数据源 id 查询数据源信息，调用通用数据源执行器 + CoreDatasource coreDatasource = coreDatasourceMapper.selectById(datasourceId); + if (coreDatasource == null) { + BusinessException.throwException("数据源不存在"); + } + coreDatasource.setConfiguration(String.valueOf(EncryptUtils.aesDecrypt(coreDatasource.getConfiguration()))); + // 解析 tableData JSON 字符串 "{ \"tableName\": \"user\", \"data\": [ { \"fieldName\": \"id\", \"fieldType\": \"varchar\", \"IsPrimaryKey\": true, \"fieldValue\": \"0001\" }, { \"fieldName\": \"name\", \"fieldType\": \"varchar\", \"fieldValue\": \"张三\" } ] }"; + Map dataMap = JsonUtil.parseObject(tableData, Map.class); + String tableName = (String) dataMap.get("tableName"); + List> fieldList = (List>) dataMap.get("data"); + + if (fieldList == null || fieldList.isEmpty()) { + BusinessException.throwException("没有可插入的数据字段"); + } + + // 构建插入语句 + StringBuilder columns = new StringBuilder(); + StringBuilder values = new StringBuilder(); + + for (int i = 0; i < fieldList.size(); i++) { + Map field = fieldList.get(i); + String fieldName = (String) field.get("fieldName"); + Object fieldValue = field.get("fieldValue"); + boolean isPrimaryKey = field.get("IsPrimaryKey") != null && (boolean) field.get("IsPrimaryKey"); + if (isPrimaryKey) { + if (fieldValue == null) {fieldValue= IDUtils.snowID();} + } + if (i > 0) { + columns.append(", "); + values.append(", "); + } + columns.append(fieldName); + if (fieldValue instanceof String) { + values.append("'").append(fieldValue).append("'"); + } else { + values.append(fieldValue); + } + } + + String sql = String.format("INSERT INTO %s (%s) VALUES (%s)", tableName, columns.toString(), values.toString()); + + // 调用执行器，向数据表中插入 tableData 数据 + DatasourceSchemaDTO datasourceSchemaDTO = new DatasourceSchemaDTO(); + BeanUtils.copyBean(datasourceSchemaDTO, coreDatasource); + + Provider provider = ProviderFactory.getProvider(coreDatasource.getType()); + DatasourceRequest datasourceRequest = new DatasourceRequest(); + datasourceRequest.setQuery(sql); + datasourceRequest.setDsList(Map.of(datasourceSchemaDTO.getId(), datasourceSchemaDTO)); + + log.debug("执行插入数据的SQL: {}", sql); + + // 执行插入操作 + int result= provider.executeUpdate(datasourceRequest); + if (result==1) { + return true; + // process result set + } else { + return false; + } + } + @Override + public Map getTableDataByPk(Long datasourceId, String condtion) throws Exception { + // 获取数据源信息 + CoreDatasource coreDatasource = coreDatasourceMapper.selectById(datasourceId); + if (coreDatasource == null) { + BusinessException.throwException("数据源不存在"); + } + coreDatasource.setConfiguration(String.valueOf(EncryptUtils.aesDecrypt(coreDatasource.getConfiguration()))); + // 解析 JSON 数据 + //condtion={ \"tableName\": \"user\", key:[{ \"fieldName\": \"id\",\"fieldValue\": \"0001\"] + Map dataMap = JsonUtil.parseObject(condtion, Map.class); + String tableName = (String) dataMap.get("tableName"); + // 参数校验 + if (StringUtils.isBlank(tableName)) { + BusinessException.throwException("表名不能为空"); + } + List> keyFields = (List>) dataMap.get("key"); + if (CollectionUtils.isEmpty(keyFields)) { + BusinessException.throwException("主键字段或值不能为空"); + } + + String whereClause = buildWhereCondition(keyFields); + String sql = String.format("SELECT * FROM %s WHERE %s", tableName, whereClause); + // 执行查询操作 + DatasourceSchemaDTO datasourceSchemaDTO = new DatasourceSchemaDTO(); + BeanUtils.copyBean(datasourceSchemaDTO, coreDatasource); + + Provider provider = ProviderFactory.getProvider(coreDatasource.getType()); + DatasourceRequest datasourceRequest = new DatasourceRequest(); + datasourceRequest.setQuery(sql); + datasourceRequest.setDsList(Map.of(datasourceSchemaDTO.getId(), datasourceSchemaDTO)); + + log.debug("执行查询数据的SQL: {}", sql); + + // 获取查询结果 + Map data = provider.fetchResultField(datasourceRequest); + + // 处理查询结果 + List dataList = (List) data.get("data"); + List fields = (List) data.get("fields"); + + if (CollectionUtils.isEmpty(dataList) || dataList.size() == 0) { + return null; + } + + // 将结果转换为 Map 格式 + String[] row = dataList.get(0); + Map resultMap = new LinkedHashMap<>(); + for (int i = 0; i < fields.size(); i++) { + TableField field = fields.get(i); + String fieldName = field.getOriginName(); + resultMap.put(fieldName, row[i]); + } + return resultMap; + } + /** + * 构建 WHERE 条件字符串，用于多字段主键查询/更新/删除操作 + * + * @param keyFields 主键字段列表，格式如：{ "fieldName": "id", "fieldValue": "0001" } + * @return SQL WHERE 子句字符串 + */ + private String buildWhereCondition(List> keyFields) { + StringBuilder whereClause = new StringBuilder(); + + for (int i = 0; i < keyFields.size(); i++) { + Map keyField = keyFields.get(i); + String fieldName = (String) keyField.get("fieldName"); + Object fieldValue = keyField.get("fieldValue"); + + if (i > 0) { + whereClause.append(" AND "); + } + + if (fieldValue == null) { + whereClause.append(fieldName).append(" IS NULL"); + } else if (fieldValue instanceof String) { + whereClause.append(String.format("%s = '%s'", fieldName, fieldValue)); + } else { + whereClause.append(String.format("%s = %s", fieldName, fieldValue)); + } + } + + return whereClause.toString(); + } + @Override + public boolean updateTableData(Long datasourceId, String tableData) throws Exception { + // 获取数据源信息 + CoreDatasource coreDatasource = coreDatasourceMapper.selectById(datasourceId); + if (coreDatasource == null) { + BusinessException.throwException("数据源不存在"); + } + coreDatasource.setConfiguration(String.valueOf(EncryptUtils.aesDecrypt(coreDatasource.getConfiguration()))); + //String tableDataJson = "{ \"tableName\": \"user\", key:[{ \"fieldName\": \"id\",\"fieldValue\": \"0001\"], \"data\": [ { \"fieldName\": \"name\", \"fieldType\": \"varchar\", \"fieldValue\": \"李四\" } ] }"; + // 解析 JSON 数据 + Map dataMap = JsonUtil.parseObject(tableData, Map.class); + String tableName = (String) dataMap.get("tableName"); + if (StringUtils.isBlank(tableName)) { + BusinessException.throwException("表名不能为空"); + } + List> keyFields = (List>) dataMap.get("key"); + if (CollectionUtils.isEmpty(keyFields)) { + BusinessException.throwException("主键字段或值不能为空"); + } + List> fieldList = (List>) dataMap.get("data"); + if (fieldList == null || fieldList.isEmpty()) { + BusinessException.throwException("没有可更新的数据字段"); + } + // 构建 UPDATE 语句 + StringBuilder setClause = new StringBuilder(); + for (int i = 0; i < fieldList.size(); i++) { + Map field = fieldList.get(i); + String fieldName = (String) field.get("fieldName"); + Object fieldValue = field.get("fieldValue"); + + if (i > 0) { + setClause.append(", "); + } + if (fieldValue instanceof String) { + setClause.append(String.format("%s = '%s'", fieldName, fieldValue)); + } else { + setClause.append(String.format("%s = %s", fieldName, fieldValue)); + } + } + + String whereClause = buildWhereCondition(keyFields); + String sql = String.format("UPDATE %s SET %s WHERE %s", tableName, setClause, whereClause); + // 调用执行器执行 SQL + DatasourceSchemaDTO datasourceSchemaDTO = new DatasourceSchemaDTO(); + BeanUtils.copyBean(datasourceSchemaDTO, coreDatasource); + + Provider provider = ProviderFactory.getProvider(coreDatasource.getType()); + DatasourceRequest datasourceRequest = new DatasourceRequest(); + datasourceRequest.setQuery(sql); + datasourceRequest.setDsList(Map.of(datasourceSchemaDTO.getId(), datasourceSchemaDTO)); + + log.debug("执行更新数据的SQL: {}", sql); + + // 执行更新操作 + int result= provider.executeUpdate(datasourceRequest); + if (result==1) { + return true; + // process result set + } else { + return false; + } + } + @Override + public boolean deleteTableData(Long datasourceId, String condtion) throws Exception { + // 获取数据源信息 + CoreDatasource coreDatasource = coreDatasourceMapper.selectById(datasourceId); + if (coreDatasource == null) { + BusinessException.throwException("数据源不存在"); } + coreDatasource.setConfiguration(String.valueOf(EncryptUtils.aesDecrypt(coreDatasource.getConfiguration()))); + // 解析 JSON 数据 + //String tableDataJson = "{ \"tableName\": \"user\", key:[{ \"fieldName\": \"id\",\"fieldValue\": \"0001\"] }"; + Map dataMap = JsonUtil.parseObject(condtion, Map.class); + String tableName = (String) dataMap.get("tableName"); + if (StringUtils.isBlank(tableName)) { + BusinessException.throwException("表名不能为空"); + } + List> keyFields = (List>) dataMap.get("key"); + if (CollectionUtils.isEmpty(keyFields)) { + BusinessException.throwException("主键字段或值不能为空"); + } + String whereClause = buildWhereCondition(keyFields); + String sql = String.format("DELETE FROM %s WHERE %s", tableName, whereClause); + // 调用执行器执行 SQL + DatasourceSchemaDTO datasourceSchemaDTO = new DatasourceSchemaDTO(); + BeanUtils.copyBean(datasourceSchemaDTO, coreDatasource); + + Provider provider = ProviderFactory.getProvider(coreDatasource.getType()); + DatasourceRequest datasourceRequest = new DatasourceRequest(); + datasourceRequest.setQuery(sql); + datasourceRequest.setDsList(Map.of(datasourceSchemaDTO.getId(), datasourceSchemaDTO)); + + log.debug("执行删除数据的SQL: {}", sql); + + // 执行删除操作 + int result= provider.executeUpdate(datasourceRequest); + if (result==1) { + return true; + // process result set + } else { + return false; + } + } + @Override + public Page> queryTableDataPaged(Long datasourceId, String condition) throws Exception { + // 获取数据源信息 + CoreDatasource coreDatasource = coreDatasourceMapper.selectById(datasourceId); + if (coreDatasource == null) { + BusinessException.throwException("数据源不存在"); + } + coreDatasource.setConfiguration(String.valueOf(EncryptUtils.aesDecrypt(coreDatasource.getConfiguration()))); + // 解析 condition JSON 数据 + Map dataMap = JsonUtil.parseObject(condition, Map.class); + String tableName = (String) dataMap.get("tableName"); + List> conditionList = (List>) dataMap.get("conditions"); + + Integer pageNum = (Integer) dataMap.getOrDefault("pageNum", 1); + Integer pageSize = (Integer) dataMap.getOrDefault("pageSize", 10); + + if (StringUtils.isBlank(tableName)) { + BusinessException.throwException("表名不能为空"); + } + + // 构建 WHERE 条件子句 + StringBuilder whereClause = new StringBuilder(); + if (conditionList != null && !conditionList.isEmpty()) { + whereClause.append(" WHERE "); + for (int i = 0; i < conditionList.size(); i++) { + Map cond = conditionList.get(i); + String field = (String) cond.get("field"); + String operator = ((String) cond.get("operator")).toLowerCase(); + Object value = cond.get("value"); + + if (i > 0) { + whereClause.append(" AND "); + } + switch (operator) { + case "like": + whereClause.append(String.format("%s LIKE '%%%s%%'", field, value)); + break; + case "mlike": + String fields[]=field.split(","); + for(int j=0;j0){ + whereClause.append(" OR "); + } + whereClause.append(String.format("%s LIKE '%%%s%%'", fields[j], value)); + if(j==fields.length-1){ + whereClause.append(")"); + } + } + break; + case "=": + appendValue(whereClause, field, value, "="); + break; + case "<": + appendValue(whereClause, field, value, "<"); + break; + case ">": + appendValue(whereClause, field, value, ">"); + break; + case "<=": + appendValue(whereClause, field, value, "<="); + break; + case ">=": + appendValue(whereClause, field, value, ">="); + break; + case "between": + String datevales[]=String.valueOf(value).split(","); + appendValue(whereClause, field, datevales[0]+" 00:00:00", ">="); + whereClause.append(" AND "); + appendValue(whereClause, field, datevales[1]+" 23:59:59", "<="); + break; + case "<>": + appendValue(whereClause, field, value, "<>"); + break; + case "in": + if (!(value instanceof List)) { + DEException.throwException("IN 操作符要求值为列表类型"); + } + List values = (List) value; + String inValues = values.stream() + .map(v -> v instanceof String ? "'" + v + "'" : v.toString()) + .collect(Collectors.joining(", ")); + whereClause.append(String.format("%s IN (%s)", field, inValues)); + break; + default: + DEException.throwException("不支持的操作符: " + operator); + } + } + } + + // 构建基础 SQL + String baseSql = String.format("SELECT * FROM %s%s", tableName, whereClause); + String dbType = coreDatasource.getType().toLowerCase(); + String pagedSql = buildPagedSQL(baseSql, dbType, pageNum, pageSize); + String countSql = String.format("SELECT COUNT(*) FROM %s%s", tableName, whereClause); + + DatasourceSchemaDTO schemaDTO = new DatasourceSchemaDTO(); + BeanUtils.copyBean(schemaDTO, coreDatasource); + Provider provider = ProviderFactory.getProvider(coreDatasource.getType()); + DatasourceRequest request = new DatasourceRequest(); + request.setDsList(Map.of(schemaDTO.getId(), schemaDTO)); + + // 查询分页数据 + request.setQuery(pagedSql); + Map result = provider.fetchResultField(request); + List dataList = (List) result.get("data"); + List fields = (List) result.get("fields"); + + // 查询总记录数 + request.setQuery(countSql); + Map countResult = provider.fetchResultField(request); + long total = Long.parseLong(((List) countResult.get("data")).get(0)[0]); + + // 将数据封装为 Map 形式 + List> records = new ArrayList<>(); + if (!CollectionUtils.isEmpty(dataList)) { + for (String[] row : dataList) { + Map rowMap = new LinkedHashMap<>(); + for (int i = 0; i < fields.size() && i < row.length; i++) { + String fieldName = fields.get(i).getOriginName(); + String fieldValue = row[i]; + rowMap.put(fieldName, fieldValue); + } + records.add(rowMap); + } + } + + // 返回分页结果 + Page> page = new Page<>(); + page.setCurrent(pageNum); + page.setSize(pageSize); + page.setTotal(total); + page.setRecords(records); + + return page; + } + + + private void appendValue(StringBuilder sb, String field, Object value, String op) { + if (value instanceof String) { + sb.append(String.format("%s %s '%s'", field, op, value)); + } else { + sb.append(String.format("%s %s %s", field, op, value)); + } + } + + private String buildPagedSQL(String baseSql, String dbType, int pageNum, int pageSize) { + int offset = (pageNum - 1) * pageSize; + + switch (dbType) { + case "mysql": + case "mariadb": + return String.format("%s LIMIT %d OFFSET %d", baseSql, pageSize, offset); + case "postgresql": + return String.format("%s LIMIT %d OFFSET %d", baseSql, pageSize, offset); + case "oracle": + int start = offset + 1; + int end = offset + pageSize; + return String.format("SELECT * FROM (SELECT ROWNUM rn, t.* FROM (%s) t WHERE ROWNUM <= %d) WHERE rn >= %d", baseSql, end, start); + case "sqlserver": + return String.format("%s OFFSET %d ROWS FETCH NEXT %d ROWS ONLY", baseSql, offset, pageSize); + default: + // 默认使用 MySQL 方式 + return String.format("%s LIMIT %d OFFSET %d", baseSql, pageSize, offset); + } + } +} diff --git a/backend/src/main/java/com/stdproject/service/impl/UserServiceImpl.java b/backend/src/main/java/com/stdproject/service/impl/UserServiceImpl.java index 21e6516..ebd6a86 100644 --- a/backend/src/main/java/com/stdproject/service/impl/UserServiceImpl.java +++ b/backend/src/main/java/com/stdproject/service/impl/UserServiceImpl.java @@ -330,6 +330,18 @@ public class UserServiceImpl extends ServiceImpl implements IU return isOk; } + @Override +public User findByUsername(String username) { + if (username == null || username.trim().isEmpty()) { + return null; + } + return this.baseMapper.selectOne( + new LambdaQueryWrapper() + .eq(User::getUsername, username) + ); +} + + /*********************************** * 用途说明:比较登录名称是否有重复