package feed

import (
	"context"
	"errors"
	"strconv"

	"git.huangwc.com/pig/pig-farm-controller/internal/app/controller"
	"git.huangwc.com/pig/pig-farm-controller/internal/app/dto"
	"git.huangwc.com/pig/pig-farm-controller/internal/app/service"
	"git.huangwc.com/pig/pig-farm-controller/internal/infra/logs"

	"github.com/labstack/echo/v4"
)

// PigTypeController 定义了猪类型相关的控制器
type PigTypeController struct {
	ctx         context.Context
	typeService service.PigTypeService
}

// NewPigTypeController 创建一个新的 PigTypeController 实例
func NewPigTypeController(ctx context.Context, feedManagementService service.PigTypeService) *PigTypeController {
	return &PigTypeController{
		ctx:         ctx,
		typeService: feedManagementService,
	}
}

// CreatePigType godoc
// @Summary      创建猪类型
// @Description  创建一个新的猪类型。
// @Tags         饲料管理-猪
// @Security     BearerAuth
// @Accept       json
// @Produce      json
// @Param        pigType body dto.CreatePigTypeRequest true "猪类型信息"
// @Success      200 {object} controller.Response{data=dto.PigTypeResponse} "业务码为201代表创建成功"
// @Router       /api/v1/feed/pig-types [post]
func (c *PigTypeController) CreatePigType(ctx echo.Context) error {
	reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "CreatePigType")
	var req dto.CreatePigTypeRequest
	const actionType = "创建猪类型"
	if err := ctx.Bind(&req); err != nil {
		logger.Errorf("%s: 参数绑定失败: %v", actionType, err)
		return controller.SendErrorWithAudit(ctx, controller.CodeBadRequest, "无效的请求体: "+err.Error(), actionType, "请求体绑定失败", req)
	}

	resp, err := c.typeService.CreatePigType(reqCtx, &req)
	if err != nil {
		logger.Errorf("%s: 服务层创建猪类型失败: %v", actionType, err)
		if errors.Is(err, service.ErrPigBreedNotFound) {
			return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "关联猪品种不存在", req)
		}
		if errors.Is(err, service.ErrPigAgeStageNotFound) {
			return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "关联猪年龄阶段不存在", req)
		}
		return controller.SendErrorWithAudit(ctx, controller.CodeInternalError, "创建猪类型失败: "+err.Error(), actionType, "服务层创建猪类型失败", req)
	}

	logger.Infof("%s: 猪类型创建成功, ID: %d", actionType, resp.ID)
	return controller.SendSuccessWithAudit(ctx, controller.CodeCreated, "猪类型创建成功", resp, actionType, "猪类型创建成功", resp)
}

// UpdatePigType godoc
// @Summary      更新猪类型
// @Description  根据ID更新猪类型信息。
// @Tags         饲料管理-猪
// @Security     BearerAuth
// @Accept       json
// @Produce      json
// @Param        id path int true "猪类型ID"
// @Param        pigType body dto.UpdatePigTypeRequest true "更新后的猪类型信息"
// @Success      200 {object} controller.Response{data=dto.PigTypeResponse} "业务码为200代表更新成功"
// @Router       /api/v1/feed/pig-types/{id} [put]
func (c *PigTypeController) UpdatePigType(ctx echo.Context) error {
	reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "UpdatePigType")
	const actionType = "更新猪类型"
	idStr := ctx.Param("id")
	id, err := strconv.ParseUint(idStr, 10, 64)
	if err != nil {
		logger.Errorf("%s: 猪类型ID格式错误: %v, ID: %s", actionType, err, idStr)
		return controller.SendErrorWithAudit(ctx, controller.CodeBadRequest, "无效的猪类型ID格式", actionType, "猪类型ID格式错误", idStr)
	}

	var req dto.UpdatePigTypeRequest
	if err := ctx.Bind(&req); err != nil {
		logger.Errorf("%s: 参数绑定失败: %v", actionType, err)
		return controller.SendErrorWithAudit(ctx, controller.CodeBadRequest, "无效的请求体: "+err.Error(), actionType, "请求体绑定失败", req)
	}

	resp, err := c.typeService.UpdatePigType(reqCtx, uint32(id), &req)
	if err != nil {
		logger.Errorf("%s: 服务层更新猪类型失败: %v, ID: %d", actionType, err, id)
		if errors.Is(err, service.ErrPigTypeNotFound) {
			return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "猪类型不存在", id)
		}
		if errors.Is(err, service.ErrPigBreedNotFound) {
			return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "关联猪品种不存在", req)
		}
		if errors.Is(err, service.ErrPigAgeStageNotFound) {
			return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "关联猪年龄阶段不存在", req)
		}
		return controller.SendErrorWithAudit(ctx, controller.CodeInternalError, "更新猪类型失败: "+err.Error(), actionType, "服务层更新猪类型失败", req)
	}

	logger.Infof("%s: 猪类型更新成功, ID: %d", actionType, resp.ID)
	return controller.SendSuccessWithAudit(ctx, controller.CodeSuccess, "猪类型更新成功", resp, actionType, "猪类型更新成功", resp)
}

// DeletePigType godoc
// @Summary      删除猪类型
// @Description  根据ID删除猪类型。
// @Tags         饲料管理-猪
// @Security     BearerAuth
// @Produce      json
// @Param        id path int true "猪类型ID"
// @Success      200 {object} controller.Response "业务码为200代表删除成功"
// @Router       /api/v1/feed/pig-types/{id} [delete]
func (c *PigTypeController) DeletePigType(ctx echo.Context) error {
	reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "DeletePigType")
	const actionType = "删除猪类型"
	idStr := ctx.Param("id")
	id, err := strconv.ParseUint(idStr, 10, 64)
	if err != nil {
		logger.Errorf("%s: 猪类型ID格式错误: %v, ID: %s", actionType, err, idStr)
		return controller.SendErrorWithAudit(ctx, controller.CodeBadRequest, "无效的猪类型ID格式", actionType, "猪类型ID格式错误", idStr)
	}

	err = c.typeService.DeletePigType(reqCtx, uint32(id))
	if err != nil {
		logger.Errorf("%s: 服务层删除猪类型失败: %v, ID: %d", actionType, err, id)
		if errors.Is(err, service.ErrPigTypeNotFound) {
			return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "猪类型不存在", id)
		}
		return controller.SendErrorWithAudit(ctx, controller.CodeInternalError, "删除猪类型失败: "+err.Error(), actionType, "服务层删除猪类型失败", id)
	}

	logger.Infof("%s: 猪类型删除成功, ID: %d", actionType, id)
	return controller.SendSuccessWithAudit(ctx, controller.CodeSuccess, "猪类型删除成功", nil, actionType, "猪类型删除成功", id)
}

// GetPigType godoc
// @Summary      获取猪类型详情
// @Description  根据ID获取单个猪类型的详细信息。
// @Tags         饲料管理-猪
// @Security     BearerAuth
// @Produce      json
// @Param        id path int true "猪类型ID"
// @Success      200 {object} controller.Response{data=dto.PigTypeResponse} "业务码为200代表成功获取"
// @Router       /api/v1/feed/pig-types/{id} [get]
func (c *PigTypeController) GetPigType(ctx echo.Context) error {
	reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "GetPigType")
	const actionType = "获取猪类型详情"
	idStr := ctx.Param("id")
	id, err := strconv.ParseUint(idStr, 10, 64)
	if err != nil {
		logger.Errorf("%s: 猪类型ID格式错误: %v, ID: %s", actionType, err, idStr)
		return controller.SendErrorWithAudit(ctx, controller.CodeBadRequest, "无效的猪类型ID格式", actionType, "猪类型ID格式错误", idStr)
	}

	resp, err := c.typeService.GetPigType(reqCtx, uint32(id))
	if err != nil {
		logger.Errorf("%s: 服务层获取猪类型详情失败: %v, ID: %d", actionType, err, id)
		if errors.Is(err, service.ErrPigTypeNotFound) {
			return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "猪类型不存在", id)
		}
		return controller.SendErrorWithAudit(ctx, controller.CodeInternalError, "获取猪类型详情失败: "+err.Error(), actionType, "服务层获取猪类型详情失败", id)
	}

	logger.Infof("%s: 获取猪类型详情成功, ID: %d", actionType, id)
	return controller.SendSuccessWithAudit(ctx, controller.CodeSuccess, "获取猪类型详情成功", resp, actionType, "获取猪类型详情成功", resp)
}

// ListPigTypes godoc
// @Summary      获取猪类型列表
// @Description  获取所有猪类型的列表，支持分页和过滤。
// @Tags         饲料管理-猪
// @Security     BearerAuth
// @Produce      json
// @Param        query query dto.ListPigTypeRequest false "查询参数"
// @Success      200 {object} controller.Response{data=dto.ListPigTypeResponse} "业务码为200代表成功获取列表"
// @Router       /api/v1/feed/pig-types [get]
func (c *PigTypeController) ListPigTypes(ctx echo.Context) error {
	reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "ListPigTypes")
	const actionType = "获取猪类型列表"
	var req dto.ListPigTypeRequest
	if err := ctx.Bind(&req); err != nil {
		logger.Errorf("%s: 查询参数绑定失败: %v", actionType, err)
		return controller.SendErrorWithAudit(ctx, controller.CodeBadRequest, "无效的查询参数: "+err.Error(), actionType, "查询参数绑定失败", req)
	}

	resp, err := c.typeService.ListPigTypes(reqCtx, &req)
	if err != nil {
		logger.Errorf("%s: 服务层获取猪类型列表失败: %v", actionType, err)
		return controller.SendErrorWithAudit(ctx, controller.CodeInternalError, "获取猪类型列表失败: "+err.Error(), actionType, "服务层获取猪类型列表失败", nil)
	}

	logger.Infof("%s: 获取猪类型列表成功, 数量: %d", actionType, len(resp.List))
	return controller.SendSuccessWithAudit(ctx, controller.CodeSuccess, "获取猪类型列表成功", resp, actionType, "获取猪类型列表成功", resp)
}

// UpdatePigTypeNutrientRequirements godoc
// @Summary      全量更新猪类型的营养需求
// @Description  根据猪类型ID，替换其所有的营养需求信息。这是一个覆盖操作。
// @Tags         饲料管理-猪
// @Security     BearerAuth
// @Accept       json
// @Produce      json
// @Param        id path int true "猪类型ID"
// @Param        nutrientRequirements body dto.UpdatePigTypeNutrientRequirementsRequest true "新的营养需求列表"
// @Success      200 {object} controller.Response{data=dto.PigTypeResponse} "业务码为200代表更新成功"
// @Router       /api/v1/feed/pig-types/{id}/nutrient-requirements [put]
func (c *PigTypeController) UpdatePigTypeNutrientRequirements(ctx echo.Context) error {
	reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "UpdatePigTypeNutrientRequirements")
	const actionType = "更新猪类型营养需求"

	idStr := ctx.Param("id")
	id, err := strconv.ParseUint(idStr, 10, 64)
	if err != nil {
		logger.Errorf("%s: 猪类型ID格式错误: %v, ID: %s", actionType, err, idStr)
		return controller.SendErrorWithAudit(ctx, controller.CodeBadRequest, "无效的猪类型ID格式", actionType, "猪类型ID格式错误", idStr)
	}

	var req dto.UpdatePigTypeNutrientRequirementsRequest
	if err := ctx.Bind(&req); err != nil {
		logger.Errorf("%s: 参数绑定失败: %v", actionType, err)
		return controller.SendErrorWithAudit(ctx, controller.CodeBadRequest, "无效的请求体: "+err.Error(), actionType, "请求体绑定失败", req)
	}

	resp, err := c.typeService.UpdatePigTypeNutrientRequirements(reqCtx, uint32(id), &req)
	if err != nil {
		logger.Errorf("%s: 服务层更新猪类型营养需求失败: %v, ID: %d", actionType, err, id)
		if errors.Is(err, service.ErrPigTypeNotFound) {
			return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "猪类型不存在", id)
		}
		// 这里可以根据未来可能从服务层返回的其他特定错误进行处理
		return controller.SendErrorWithAudit(ctx, controller.CodeInternalError, "更新猪类型营养需求失败: "+err.Error(), actionType, "服务层更新失败", req)
	}

	logger.Infof("%s: 猪类型营养需求更新成功, ID: %d", actionType, resp.ID)
	return controller.SendSuccessWithAudit(ctx, controller.CodeSuccess, "猪类型营养需求更新成功", resp, actionType, "猪类型营养需求更新成功", resp)
}
