opms_backend/opms_admin/app/handler/base_product_auth.go

package handler

import (
	"context"
	"errors"
	"github.com/gogf/gf/util/gvalid"

	"dashoo.cn/common_definition/comm_def"
	"dashoo.cn/micro/app/model"
	"dashoo.cn/micro/app/service"
	"github.com/gogf/gf/frame/g"
)

type BaseProductAuthHandler struct{}

// GetList 获取列表
func (h *BaseProductAuthHandler) GetList(ctx context.Context, req *model.BaseProductAuthSearchReq, rsp *comm_def.CommonMsg) error {
	lineService, err := service.NewLineService(ctx)
	if err != nil {
		g.Log().Error(err)
		return errors.New("系统异常，请重新尝试")
	}
	list, err := lineService.GetList(req)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": list}
	return nil
}

// Save 保存数据
func (h *BaseProductAuthHandler) Save(ctx context.Context, req *model.SaveBaseProductAuthReq, rsp *comm_def.CommonMsg) (err error) {
	// 检查请求参数
	if v := gvalid.CheckStruct(ctx, req, nil); v != nil {
		return v
	}
	// 检查列表数据
	for _, line := range req.Lines {
		if v := gvalid.CheckStruct(ctx, line, nil); v != nil {
			return v
		}
	}
	lineService, err := service.NewLineService(ctx)
	if err != nil {
		return err
	}
	err = lineService.Save(req)
	return err
}

// GetProductLineUsers 获取列表
func (h *BaseProductAuthHandler) GetProductLineUsers(ctx context.Context, req *model.SysUserSearchReq, rsp *comm_def.CommonMsg) error {
	lineService, err := service.NewLineService(ctx)
	if err != nil {
		g.Log().Error(err)
		return errors.New("系统异常，请重新尝试")
	}
	total, list, err := lineService.GetProductLineUsers(req)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": list, "total": total}
	return nil
}