aggregates) {
+ this.aggregates = aggregates;
+ }
+
+ public DataSourceResult() {
+ }
+
+ public boolean equals(final Object o) {
+ if (o == this) {
+ return true;
+ } else if (!(o instanceof DataSourceResult)) {
+ return false;
+ } else {
+ DataSourceResult other = (DataSourceResult)o;
+ if (!other.canEqual(this)) {
+ return false;
+ } else if (this.getTotal() != other.getTotal()) {
+ return false;
+ } else {
+ Object this$data = this.getData();
+ Object other$data = other.getData();
+ if (this$data == null) {
+ if (other$data != null) {
+ return false;
+ }
+ } else if (!this$data.equals(other$data)) {
+ return false;
+ }
+
+ Object this$aggregates = this.getAggregates();
+ Object other$aggregates = other.getAggregates();
+ if (this$aggregates == null) {
+ if (other$aggregates != null) {
+ return false;
+ }
+ } else if (!this$aggregates.equals(other$aggregates)) {
+ return false;
+ }
+
+ return true;
+ }
+ }
+ }
+
+ protected boolean canEqual(final Object other) {
+ return other instanceof DataSourceResult;
+ }
+
+ public int hashCode() {
+ int PRIME = 59;
+ int result = 1;
+ long $total = this.getTotal();
+ result = result * 59 + (int)($total >>> 32 ^ $total);
+ Object $data = this.getData();
+ result = result * 59 + ($data == null ? 43 : $data.hashCode());
+ Object $aggregates = this.getAggregates();
+ result = result * 59 + ($aggregates == null ? 43 : $aggregates.hashCode());
+ return result;
+ }
+
+ public String toString() {
+ return "DataSourceResult(total=" + this.getTotal() + ", data=" + this.getData() + ", aggregates=" + this.getAggregates() + ")";
+ }
+}
diff --git a/backend/src/main/java/com/yfd/platform/common/DynamicSQLMapper.java b/backend/src/main/java/com/yfd/platform/common/DynamicSQLMapper.java
new file mode 100644
index 0000000..adefb25
--- /dev/null
+++ b/backend/src/main/java/com/yfd/platform/common/DynamicSQLMapper.java
@@ -0,0 +1,262 @@
+package com.yfd.platform.common;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 通用动态 SQL Mapper。
+ *
+ * 说明：
+ *
+ * 1. 该接口通过注解 SQL 直接执行动态查询，适用于“表名/联表 SQL/查询列”需要运行期决定的场景；
+ * 2. 带 {@code QueryWrapper} 的方法统一使用 {@code ew.customSqlSegment} 追加条件；
+ * 3. 传入的 {@code sql}/{@code select}/{@code tableName} 属于动态片段，请在上层确保来源可信，避免注入风险。
+ */
+@Mapper
+public interface DynamicSQLMapper {
+
+ /**
+ * 分页执行完整 SQL（SQL 内可使用 map 参数）。
+ */
+ @Select({""})
+ List> pageAllList(Page page,
+ @Param("sql") String sql,
+ @Param("map") Map map);
+
+ /**
+ * 分页执行完整 SQL（泛型结果，依赖 MyBatis 映射规则）。
+ */
+ @Select({""})
+ List pageAllListWithResultType(Page page,
+ @Param("sql") String sql,
+ @Param("map") Map map,
+ @Param("resultType") Class resultType);
+
+ /**
+ * 不分页执行完整 SQL。
+ */
+ @Select({""})
+ List> getAllList(@Param("sql") String sql,
+ @Param("map") Map map);
+
+ /**
+ * 不分页执行完整 SQL（泛型结果，依赖 MyBatis 映射规则）。
+ */
+ @Select({""})
+ List getAllListWithResultType(@Param("sql") String sql,
+ @Param("map") Map map,
+ @Param("resultType") Class resultType);
+
+ /**
+ * 统计条数（含动态条件）。
+ */
+ @Select({
+ ""
+ })
+ Integer count(@Param("sql") String sql,
+ @Param("ew") QueryWrapper queryWrapper);
+
+ /**
+ * 统计条数（无动态条件）。
+ */
+ @Select({""})
+ Integer countNoWrapper(@Param("sql") String sql);
+
+ /**
+ * 分页查询（含动态条件）。
+ */
+ @Select({
+ ""
+ })
+ List> pageList(Page page,
+ @Param("select") String select,
+ @Param("sql") String sql,
+ @Param("ew") QueryWrapper queryWrapper);
+
+ /**
+ * 分页查询（含动态条件，泛型结果）。
+ */
+ @Select({
+ ""
+ })
+ List pageListWithResultType(Page page,
+ @Param("select") String select,
+ @Param("sql") String sql,
+ @Param("ew") QueryWrapper queryWrapper,
+ @Param("resultType") Class resultType);
+
+ /**
+ * 分页查询（条件可选；方法名保持兼容）。
+ */
+ @Select({
+ ""
+ })
+ List> pageNoFilterList(Page page,
+ @Param("select") String select,
+ @Param("sql") String sql,
+ @Param("ew") QueryWrapper queryWrapper);
+
+ /**
+ * 分页查询（无动态条件）。
+ */
+ @Select({""})
+ List> pageListNoWrapper(Page page,
+ @Param("select") String select,
+ @Param("sql") String sql);
+
+ /**
+ * 非分页查询（含动态条件）。
+ */
+ @Select({
+ ""
+ })
+ List> getList(@Param("select") String select,
+ @Param("sql") String sql,
+ @Param("ew") QueryWrapper queryWrapper);
+
+ /**
+ * 非分页查询（含动态条件，历史命名保留；返回 Map 结构）。
+ */
+ @Select({
+ ""
+ })
+ List> getListWithResultType(@Param("select") String select,
+ @Param("sql") String sql,
+ @Param("ew") QueryWrapper queryWrapper);
+
+ /**
+ * 单表条件查询（直接传 where 条件片段）。
+ */
+ @Select({""})
+ List> getSingleTableList(@Param("select") String select,
+ @Param("table") String table,
+ @Param("condition") String condition);
+
+ /**
+ * 非分页查询（条件可选；方法名保持兼容）。
+ */
+ @Select({
+ ""
+ })
+ List> getNoFilterList(@Param("select") String select,
+ @Param("sql") String sql,
+ @Param("ew") QueryWrapper queryWrapper);
+
+ /**
+ * 非分页查询（无动态条件）。
+ */
+ @Select({""})
+ List> getListNoWrapper(@Param("select") String select,
+ @Param("sql") String sql);
+
+ /**
+ * 汇总查询（含动态条件），返回单行汇总结果。
+ */
+ @Select({
+ ""
+ })
+ Map totalSummary(@Param("select") String select,
+ @Param("sql") String sql,
+ @Param("ew") QueryWrapper queryWrapper);
+
+ /**
+ * 汇总查询（无动态条件）。
+ */
+ @Select({""})
+ Map totalSummaryNoWrapper(@Param("select") String select,
+ @Param("sql") String sql);
+
+ /**
+ * 单表汇总查询（含动态条件）。
+ */
+ @Select({
+ ""
+ })
+ Map totalSummarySingleTable(@Param("select") String select,
+ @Param("tableName") String tableName,
+ @Param("ew") QueryWrapper queryWrapper);
+
+ /**
+ * 单表汇总查询（无动态条件）。
+ */
+ @Select({""})
+ Map totalSummaryNoWrapperSingleTable(@Param("select") String select,
+ @Param("tableName") String tableName);
+
+ /**
+ * 获取表中最大排序值。
+ */
+ @Select({""})
+ Integer getOrderIndexMax(@Param("tableName") String tableName);
+
+ /**
+ * 按条件获取表中最大排序值。
+ */
+ @Select({
+ ""
+ })
+ Integer getOrderIndexMaxByParentId(@Param("tableName") String tableName,
+ @Param("ew") QueryWrapper queryWrapper);
+
+ /**
+ * 获取分组字段列表。
+ */
+ @Select({""})
+ List