fanqie-go/internal/handlers/book.go

package handlers

import (
	"fanqie/internal/fqapi"
	"fmt"
	"net/http"
)

// HandleSearch 搜索处理
func HandleSearch(w http.ResponseWriter, r *http.Request) {
	incrementStat("total", "search")
	w.Header().Set("Content-Type", "application/json; charset=utf-8")

	query := r.URL.Query().Get("query")
	if query == "" {
		query = r.URL.Query().Get("key")
	}
	if query == "" {
		respondError(w, "缺少 query 参数", true)
		return
	}

	offset, err := parseIntParam(r.URL.Query().Get("offset"), "offset")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}

	tabType, err := parseIntParam(r.URL.Query().Get("tab_type"), "tab_type")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}
	if tabType == 0 {
		tabType = 3
	}

	result, err := fqapi.HandleBookSearch(query, offset, tabType)
	if err != nil {
		respondError(w, "搜索失败: "+err.Error(), false)
		return
	}

	fmt.Fprint(w, result)
}

// HandleDetail 详情处理
func HandleDetail(w http.ResponseWriter, r *http.Request) {
	incrementStat("total", "detail")
	w.Header().Set("Content-Type", "application/json; charset=utf-8")

	params, err := validateParams(r, "book_id")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}

	result, err := fqapi.HandleGetDetail(params["book_id"])
	if err != nil {
		respondError(w, "获取详情失败: "+err.Error(), false)
		return
	}

	fmt.Fprint(w, result)
}

// HandleCatalog 目录处理
func HandleCatalog(w http.ResponseWriter, r *http.Request) {
	incrementStat("total", "catalog")
	w.Header().Set("Content-Type", "application/json; charset=utf-8")

	params, err := validateParams(r, "book_id")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}

	result, err := fqapi.HandleGetCatalog(params["book_id"])
	if err != nil {
		respondError(w, "获取目录失败: "+err.Error(), false)
		return
	}

	fmt.Fprint(w, result)
}

// HandleMultiDetail 批量详情处理
func HandleMultiDetail(w http.ResponseWriter, r *http.Request) {
	incrementStat("total", "detail")
	w.Header().Set("Content-Type", "application/json; charset=utf-8")

	params, err := validateParams(r, "book_id")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}

	result, err := fqapi.HandleGetMultiDetail(params["book_id"])
	if err != nil {
		respondError(w, "批量获取详情失败: "+err.Error(), false)
		return
	}

	fmt.Fprint(w, result)
}

// HandleRank 榜单处理（推荐/完结/热搜/黑马/爆更榜，免签名接口）
func HandleRank(w http.ResponseWriter, r *http.Request) {
	incrementStat("total", "category")
	w.Header().Set("Content-Type", "application/json; charset=utf-8")

	sideType, err := parseIntParam(r.URL.Query().Get("side_type"), "side_type")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}
	page, err := parseIntParam(r.URL.Query().Get("page"), "page")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}

	result, err := fqapi.HandleGetRank(sideType, page)
	if err != nil {
		respondError(w, "获取榜单失败: "+err.Error(), false)
		return
	}

	fmt.Fprint(w, result)
}

// HandleBookshelf 书架处理（需登录 sessionid）
func HandleBookshelf(w http.ResponseWriter, r *http.Request) {
	incrementStat("total", "category")
	w.Header().Set("Content-Type", "application/json; charset=utf-8")

	params, err := validateParams(r, "sessionid")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}

	result, err := fqapi.HandleBookshelf(params["sessionid"], r.URL.Query().Get("group"))
	if err != nil {
		respondError(w, "获取书架失败: "+err.Error(), false)
		return
	}

	fmt.Fprint(w, result)
}

// HandleReadHistory 阅读历史处理（需登录 sessionid）
func HandleReadHistory(w http.ResponseWriter, r *http.Request) {
	incrementStat("total", "category")
	w.Header().Set("Content-Type", "application/json; charset=utf-8")

	params, err := validateParams(r, "sessionid")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}

	offset, err := parseIntParam(r.URL.Query().Get("offset"), "offset")
	if err != nil {
		respondError(w, err.Error(), true)
		return
	}

	result, err := fqapi.HandleReadHistory(params["sessionid"], offset)
	if err != nil {
		respondError(w, "获取阅读历史失败: "+err.Error(), false)
		return
	}

	fmt.Fprint(w, result)
}