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" ) // Controller 定义了饲料管理相关的控制器 type Controller struct { ctx context.Context feedManagementService service.FeedManagementService } // NewController 创建一个新的 Controller 实例 func NewController(ctx context.Context, feedManagementService service.FeedManagementService) *Controller { return &Controller{ ctx: ctx, feedManagementService: feedManagementService, } } // --- 营养种类 (Nutrient) 接口方法实现 --- // CreateNutrient godoc // @Summary 创建营养种类 // @Description 创建一个新的营养种类。 // @Tags 饲料管理 // @Security BearerAuth // @Accept json // @Produce json // @Param nutrient body dto.CreateNutrientRequest true "营养种类信息" // @Success 200 {object} controller.Response{data=dto.NutrientResponse} "业务码为201代表创建成功" // @Router /api/v1/feed/nutrients [post] func (c *Controller) CreateNutrient(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "CreateNutrient") var req dto.CreateNutrientRequest 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.feedManagementService.CreateNutrient(reqCtx, &req) if err != nil { logger.Errorf("%s: 服务层创建营养种类失败: %v", actionType, err) if errors.Is(err, service.ErrNutrientNameConflict) { return controller.SendErrorWithAudit(ctx, controller.CodeConflict, 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) } // UpdateNutrient godoc // @Summary 更新营养种类 // @Description 根据ID更新营养种类信息。 // @Tags 饲料管理 // @Security BearerAuth // @Accept json // @Produce json // @Param id path int true "营养种类ID" // @Param nutrient body dto.UpdateNutrientRequest true "更新后的营养种类信息" // @Success 200 {object} controller.Response{data=dto.NutrientResponse} "业务码为200代表更新成功" // @Router /api/v1/feed/nutrients/{id} [put] func (c *Controller) UpdateNutrient(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "UpdateNutrient") 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.UpdateNutrientRequest 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.feedManagementService.UpdateNutrient(reqCtx, uint32(id), &req) if err != nil { logger.Errorf("%s: 服务层更新营养种类失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrNutrientNotFound) { return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "营养种类不存在", id) } if errors.Is(err, service.ErrNutrientNameConflict) { return controller.SendErrorWithAudit(ctx, controller.CodeConflict, 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) } // DeleteNutrient 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/nutrients/{id} [delete] func (c *Controller) DeleteNutrient(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "DeleteNutrient") 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.feedManagementService.DeleteNutrient(reqCtx, uint32(id)) if err != nil { logger.Errorf("%s: 服务层删除营养种类失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrNutrientNotFound) { 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) } // GetNutrient godoc // @Summary 获取营养种类详情 // @Description 根据ID获取单个营养种类的详细信息。 // @Tags 饲料管理 // @Security BearerAuth // @Produce json // @Param id path int true "营养种类ID" // @Success 200 {object} controller.Response{data=dto.NutrientResponse} "业务码为200代表成功获取" // @Router /api/v1/feed/nutrients/{id} [get] func (c *Controller) GetNutrient(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "GetNutrient") 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.feedManagementService.GetNutrient(reqCtx, uint32(id)) if err != nil { logger.Errorf("%s: 服务层获取营养种类详情失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrNutrientNotFound) { 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) } // ListNutrients godoc // @Summary 获取营养种类列表 // @Description 获取所有营养种类的列表,支持分页和过滤。 // @Tags 饲料管理 // @Security BearerAuth // @Produce json // @Param query query dto.ListNutrientRequest false "查询参数" // @Success 200 {object} controller.Response{data=dto.ListNutrientResponse} "业务码为200代表成功获取列表" // @Router /api/v1/feed/nutrients [get] func (c *Controller) ListNutrients(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "ListNutrients") const actionType = "获取营养种类列表" var req dto.ListNutrientRequest 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.feedManagementService.ListNutrients(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) } // --- 原料 (RawMaterial) 接口方法实现 --- // CreateRawMaterial godoc // @Summary 创建原料 // @Description 创建一个新的原料。 // @Tags 饲料管理 // @Security BearerAuth // @Accept json // @Produce json // @Param rawMaterial body dto.CreateRawMaterialRequest true "原料信息" // @Success 200 {object} controller.Response{data=dto.RawMaterialResponse} "业务码为201代表创建成功" // @Router /api/v1/feed/raw-materials [post] func (c *Controller) CreateRawMaterial(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "CreateRawMaterial") var req dto.CreateRawMaterialRequest 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.feedManagementService.CreateRawMaterial(reqCtx, &req) if err != nil { logger.Errorf("%s: 服务层创建原料失败: %v", actionType, err) if errors.Is(err, service.ErrRawMaterialNameConflict) { return controller.SendErrorWithAudit(ctx, controller.CodeConflict, 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) } // UpdateRawMaterial godoc // @Summary 更新原料 // @Description 根据ID更新原料信息。 // @Tags 饲料管理 // @Security BearerAuth // @Accept json // @Produce json // @Param id path int true "原料ID" // @Param rawMaterial body dto.UpdateRawMaterialRequest true "更新后的原料信息" // @Success 200 {object} controller.Response{data=dto.RawMaterialResponse} "业务码为200代表更新成功" // @Router /api/v1/feed/raw-materials/{id} [put] func (c *Controller) UpdateRawMaterial(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "UpdateRawMaterial") 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.UpdateRawMaterialRequest 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.feedManagementService.UpdateRawMaterial(reqCtx, uint32(id), &req) if err != nil { logger.Errorf("%s: 服务层更新原料失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrRawMaterialNotFound) { return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "原料不存在", id) } if errors.Is(err, service.ErrRawMaterialNameConflict) { return controller.SendErrorWithAudit(ctx, controller.CodeConflict, 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) } // DeleteRawMaterial 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/raw-materials/{id} [delete] func (c *Controller) DeleteRawMaterial(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "DeleteRawMaterial") 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.feedManagementService.DeleteRawMaterial(reqCtx, uint32(id)) if err != nil { logger.Errorf("%s: 服务层删除原料失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrRawMaterialNotFound) { 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) } // GetRawMaterial godoc // @Summary 获取原料详情 // @Description 根据ID获取单个原料的详细信息。 // @Tags 饲料管理 // @Security BearerAuth // @Produce json // @Param id path int true "原料ID" // @Success 200 {object} controller.Response{data=dto.RawMaterialResponse} "业务码为200代表成功获取" // @Router /api/v1/feed/raw-materials/{id} [get] func (c *Controller) GetRawMaterial(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "GetRawMaterial") 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.feedManagementService.GetRawMaterial(reqCtx, uint32(id)) if err != nil { logger.Errorf("%s: 服务层获取原料详情失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrRawMaterialNotFound) { 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) } // ListRawMaterials godoc // @Summary 获取原料列表 // @Description 获取所有原料的列表,支持分页和过滤。 // @Tags 饲料管理 // @Security BearerAuth // @Produce json // @Param query query dto.ListRawMaterialRequest false "查询参数" // @Success 200 {object} controller.Response{data=dto.ListRawMaterialResponse} "业务码为200代表成功获取列表" // @Router /api/v1/feed/raw-materials [get] func (c *Controller) ListRawMaterials(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "ListRawMaterials") const actionType = "获取原料列表" var req dto.ListRawMaterialRequest 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.feedManagementService.ListRawMaterials(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) } // UpdateRawMaterialNutrients godoc // @Summary 全量更新原料的营养成分 // @Description 根据原料ID,替换其所有的营养成分信息。这是一个覆盖操作。 // @Tags 饲料管理 // @Security BearerAuth // @Accept json // @Produce json // @Param id path int true "原料ID" // @Param nutrients body dto.UpdateRawMaterialNutrientsRequest true "新的营养成分列表" // @Success 200 {object} controller.Response{data=dto.RawMaterialResponse} "业务码为200代表更新成功" // @Router /api/v1/feed/raw-materials/{id}/nutrients [put] func (c *Controller) UpdateRawMaterialNutrients(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "UpdateRawMaterialNutrients") 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.UpdateRawMaterialNutrientsRequest 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.feedManagementService.UpdateRawMaterialNutrients(reqCtx, uint32(id), &req) if err != nil { logger.Errorf("%s: 服务层更新原料营养成分失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrRawMaterialNotFound) { 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) } // --- 猪品种 (PigBreed) 接口方法实现 --- // CreatePigBreed godoc // @Summary 创建猪品种 // @Description 创建一个新的猪品种。 // @Tags 饲料管理 // @Security BearerAuth // @Accept json // @Produce json // @Param pigBreed body dto.CreatePigBreedRequest true "猪品种信息" // @Success 200 {object} controller.Response{data=dto.PigBreedResponse} "业务码为201代表创建成功" // @Router /api/v1/feed/pig-breeds [post] func (c *Controller) CreatePigBreed(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "CreatePigBreed") var req dto.CreatePigBreedRequest 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.feedManagementService.CreatePigBreed(reqCtx, &req) if err != nil { logger.Errorf("%s: 服务层创建猪品种失败: %v", actionType, err) // 猪品种没有名称冲突的领域错误,这里直接返回内部错误 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) } // UpdatePigBreed godoc // @Summary 更新猪品种 // @Description 根据ID更新猪品种信息。 // @Tags 饲料管理 // @Security BearerAuth // @Accept json // @Produce json // @Param id path int true "猪品种ID" // @Param pigBreed body dto.UpdatePigBreedRequest true "更新后的猪品种信息" // @Success 200 {object} controller.Response{data=dto.PigBreedResponse} "业务码为200代表更新成功" // @Router /api/v1/feed/pig-breeds/{id} [put] func (c *Controller) UpdatePigBreed(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "UpdatePigBreed") 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.UpdatePigBreedRequest 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.feedManagementService.UpdatePigBreed(reqCtx, uint32(id), &req) if err != nil { logger.Errorf("%s: 服务层更新猪品种失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrPigBreedNotFound) { 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) } // DeletePigBreed 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-breeds/{id} [delete] func (c *Controller) DeletePigBreed(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "DeletePigBreed") 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.feedManagementService.DeletePigBreed(reqCtx, uint32(id)) if err != nil { logger.Errorf("%s: 服务层删除猪品种失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrPigBreedNotFound) { return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "猪品种不存在", id) } if errors.Is(err, service.ErrPigBreedInUse) { return controller.SendErrorWithAudit(ctx, controller.CodeConflict, 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) } // GetPigBreed godoc // @Summary 获取猪品种详情 // @Description 根据ID获取单个猪品种的详细信息。 // @Tags 饲料管理 // @Security BearerAuth // @Produce json // @Param id path int true "猪品种ID" // @Success 200 {object} controller.Response{data=dto.PigBreedResponse} "业务码为200代表成功获取" // @Router /api/v1/feed/pig-breeds/{id} [get] func (c *Controller) GetPigBreed(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "GetPigBreed") 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.feedManagementService.GetPigBreed(reqCtx, uint32(id)) if err != nil { logger.Errorf("%s: 服务层获取猪品种详情失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrPigBreedNotFound) { 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) } // ListPigBreeds godoc // @Summary 获取猪品种列表 // @Description 获取所有猪品种的列表,支持分页和过滤。 // @Tags 饲料管理 // @Security BearerAuth // @Produce json // @Param query query dto.ListPigBreedRequest false "查询参数" // @Success 200 {object} controller.Response{data=dto.ListPigBreedResponse} "业务码为200代表成功获取列表" // @Router /api/v1/feed/pig-breeds [get] func (c *Controller) ListPigBreeds(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "ListPigBreeds") const actionType = "获取猪品种列表" var req dto.ListPigBreedRequest 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.feedManagementService.ListPigBreeds(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) } // --- 猪年龄阶段 (PigAgeStage) 接口方法实现 --- // CreatePigAgeStage godoc // @Summary 创建猪年龄阶段 // @Description 创建一个新的猪年龄阶段。 // @Tags 饲料管理 // @Security BearerAuth // @Accept json // @Produce json // @Param pigAgeStage body dto.CreatePigAgeStageRequest true "猪年龄阶段信息" // @Success 200 {object} controller.Response{data=dto.PigAgeStageResponse} "业务码为201代表创建成功" // @Router /api/v1/feed/pig-age-stages [post] func (c *Controller) CreatePigAgeStage(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "CreatePigAgeStage") var req dto.CreatePigAgeStageRequest 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.feedManagementService.CreatePigAgeStage(reqCtx, &req) if err != nil { logger.Errorf("%s: 服务层创建猪年龄阶段失败: %v", actionType, err) // 猪年龄阶段没有名称冲突的领域错误,这里直接返回内部错误 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) } // UpdatePigAgeStage godoc // @Summary 更新猪年龄阶段 // @Description 根据ID更新猪年龄阶段信息。 // @Tags 饲料管理 // @Security BearerAuth // @Accept json // @Produce json // @Param id path int true "猪年龄阶段ID" // @Param pigAgeStage body dto.UpdatePigAgeStageRequest true "更新后的猪年龄阶段信息" // @Success 200 {object} controller.Response{data=dto.PigAgeStageResponse} "业务码为200代表更新成功" // @Router /api/v1/feed/pig-age-stages/{id} [put] func (c *Controller) UpdatePigAgeStage(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "UpdatePigAgeStage") 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.UpdatePigAgeStageRequest 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.feedManagementService.UpdatePigAgeStage(reqCtx, uint32(id), &req) if err != nil { logger.Errorf("%s: 服务层更新猪年龄阶段失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrPigAgeStageNotFound) { 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) } // DeletePigAgeStage 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-age-stages/{id} [delete] func (c *Controller) DeletePigAgeStage(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "DeletePigAgeStage") 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.feedManagementService.DeletePigAgeStage(reqCtx, uint32(id)) if err != nil { logger.Errorf("%s: 服务层删除猪年龄阶段失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrPigAgeStageNotFound) { return controller.SendErrorWithAudit(ctx, controller.CodeNotFound, err.Error(), actionType, "猪年龄阶段不存在", id) } if errors.Is(err, service.ErrPigAgeStageInUse) { return controller.SendErrorWithAudit(ctx, controller.CodeConflict, 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) } // GetPigAgeStage godoc // @Summary 获取猪年龄阶段详情 // @Description 根据ID获取单个猪年龄阶段的详细信息。 // @Tags 饲料管理 // @Security BearerAuth // @Produce json // @Param id path int true "猪年龄阶段ID" // @Success 200 {object} controller.Response{data=dto.PigAgeStageResponse} "业务码为200代表成功获取" // @Router /api/v1/feed/pig-age-stages/{id} [get] func (c *Controller) GetPigAgeStage(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "GetPigAgeStage") 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.feedManagementService.GetPigAgeStage(reqCtx, uint32(id)) if err != nil { logger.Errorf("%s: 服务层获取猪年龄阶段详情失败: %v, ID: %d", actionType, err, id) if errors.Is(err, service.ErrPigAgeStageNotFound) { 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) } // ListPigAgeStages godoc // @Summary 获取猪年龄阶段列表 // @Description 获取所有猪年龄阶段的列表,支持分页和过滤。 // @Tags 饲料管理 // @Security BearerAuth // @Produce json // @Param query query dto.ListPigAgeStageRequest false "查询参数" // @Success 200 {object} controller.Response{data=dto.ListPigAgeStageResponse} "业务码为200代表成功获取列表" // @Router /api/v1/feed/pig-age-stages [get] func (c *Controller) ListPigAgeStages(ctx echo.Context) error { reqCtx, logger := logs.Trace(ctx.Request().Context(), c.ctx, "ListPigAgeStages") const actionType = "获取猪年龄阶段列表" var req dto.ListPigAgeStageRequest 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.feedManagementService.ListPigAgeStages(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) } // --- 猪类型 (PigType) 接口方法实现 --- // 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 *Controller) 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.feedManagementService.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 *Controller) 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.feedManagementService.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 *Controller) 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.feedManagementService.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 *Controller) 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.feedManagementService.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 *Controller) 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.feedManagementService.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) }