增加参数。csv是否包含表头

myhandle/queryHandlerBytes.go → myhandle/query_handler_bytes.go

 import (
 	"encoding/json"
 	"net/http"
-
-	"git.x2erp.com/qdy/go-base/types"
-	"git.x2erp.com/qdy/go-db/factory/database"
 )
 
 // 最简单的 queryHandler，只处理 []byte 返回
-func QueryHandlerBytes(
+func QueryHandlerBytes[T any, F any](
 	w http.ResponseWriter,
 	r *http.Request,
-	dbFactory *database.DBFactory,
-	handlerFunc func(*database.DBFactory, types.QueryRequest) []byte,
+	factory F,
+	handlerFunc func(F, T) []byte,
 ) {
 	// 解析请求参数
-	var req types.QueryRequest
+	var req T
 	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
 		// 返回 CSV 格式的错误信息
 		errorCSV := "error,Invalid request body\n"
 	}
 
 	// 调用业务逻辑函数
-	csvData := handlerFunc(dbFactory, req)
+	csvData := handlerFunc(factory, req)
 
 	// 直接返回 CSV 数据（包含错误信息时也会被正确处理）
 	w.Header().Set("Content-Type", "text/csv")

myhandle/queryHandlerJson.go → myhandle/query_handler_json.go

 	"time"
 
 	"git.x2erp.com/qdy/go-base/types"
-	"git.x2erp.com/qdy/go-db/factory/database"
 )
 
 // queryHandler - 最简单的版本
-func QueryHandlerJson(
+func QueryHandlerJson[T any, F any](
 	w http.ResponseWriter,
 	r *http.Request,
-	dbFactory *database.DBFactory,
-	handlerFunc func(*database.DBFactory, types.QueryRequest) *types.QueryResult,
+	factory F,
+	handlerFunc func(F, T) *types.QueryResult,
 ) {
 	// 解析请求参数
-	var req types.QueryRequest
+	var req T
 	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
 		// 如果解析失败，也返回 QueryResult 格式
 		w.Header().Set("Content-Type", "application/json")
 	}
 
 	// 执行业务逻辑
-	result := handlerFunc(dbFactory, req)
+	result := handlerFunc(factory, req)
 
 	// 设置头，写入结果
 	w.Header().Set("Content-Type", "application/json")