opms_backend/opms_admin/app/handler/dict.go

package handler

import (
	"context"
	"dashoo.cn/common_definition/comm_def"
	"dashoo.cn/micro/app/model"
	"dashoo.cn/micro/app/service"
	"dashoo.cn/opms_libary/myerrors"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/os/glog"
	"github.com/gogf/gf/util/gvalid"
)

type Dict struct{}

// GetDictTypeList 分页查询字典分类列表信息
func (c *Dict) GetDictTypeList(ctx context.Context, req *model.ListSysDictTypeReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	// 设置默认的页数
	if req.PageSize == 0 {
		req.PageSize = DefaultPageNum
	}
	dictService, err := service.NewDictTypeService(ctx)
	if flag, err, _, _ := myerrors.CheckError(err); flag {
		return err
	}

	total, list, err := dictService.GetList(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		g.Log().Error(err)
		return err
	}
	rsp.Data = g.Map{"list": list, "total": total}
	return nil
}

// GetDictTypeEntity 根据id获取字典分类详情信息
func (c *Dict) GetDictTypeEntity(ctx context.Context, req *comm_def.IdReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if req.Id == 0 {
		return NoParamsErr
	}
	dictService, err := service.NewDictTypeService(ctx)
	if flag, err, _, _ := myerrors.CheckError(err); flag {
		return err
	}

	data, err := dictService.GetDictById(req.Id)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		g.Log().Error(err)
		return err
	}
	rsp.Data = data
	return nil
}

// CreateDictType 添加字典分类
func (c *Dict) CreateDictType(ctx context.Context, req *model.SysDictTypeAddReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}
	dictService, err := service.NewDictTypeService(ctx)
	if flag, err, _, _ := myerrors.CheckError(err); flag {
		return err
	}

	err = dictService.Create(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	return err
}

// UpdateDictType 更新字典分类信息
func (c *Dict) UpdateDictType(ctx context.Context, req *model.SysDictTypeEditReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}
	dictService, err := service.NewDictTypeService(ctx)
	if flag, err, _, _ := myerrors.CheckError(err); flag {
		return err
	}

	err = dictService.UpdateById(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	return err
}

// DeleteDictTypeByIds 删除字典分类 支持批量删除
func (c *Dict) DeleteDictTypeByIds(ctx context.Context, req *comm_def.IdsReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if len(req.Ids) == 0 {
		return NoParamsErr
	}
	dictService, err := service.NewDictTypeService(ctx)
	if err != nil {
		return err
	}

	err = dictService.Delete(req.Ids)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	return err
}

// 字典明细数据相关

// GetDictDataList 分页查询字典明细列表信息
func (c *Dict) GetDictDataList(ctx context.Context, req *model.SelectDictPageReq, rsp *comm_def.CommonMsg) error {
	dictService, err := service.NewDictDataService(ctx)
	if err != nil {
		return err
	}
	if req.PageSize == 0 {
		req.PageSize = DefaultPageNum
	}
	total, list, err := dictService.GetDictDataList(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		glog.Error(err)
		return err
	}
	rsp.Data = g.Map{"list": list, "total": total}
	return nil
}

// GetDictDataEntity 根据id获取字典明细详情信息
func (c *Dict) GetDictDataEntity(ctx context.Context, req *comm_def.IdReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if req.Id == 0 {
		return NoParamsErr
	}
	dictService, err := service.NewDictDataService(ctx)
	if err != nil {
		return err
	}

	data, err := dictService.GetDictDataById(req.Id)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		glog.Error(err)
		return err
	}
	rsp.Data = data
	return nil
}

// GetDictDataByType 根据字典类型获取字典项明细
func (c *Dict) GetDictDataByType(ctx context.Context, req *model.GetDictReq, rsp *comm_def.CommonMsg) error {
	dictService, err := service.NewDictDataService(ctx)
	if err != nil {
		return err
	}

	list, err := dictService.GetDictWithDataByType(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		glog.Error(err)
		return err
	}
	rsp.Data = list
	return nil
}

// CreateDictData 添加字典明细
func (c *Dict) CreateDictData(ctx context.Context, req *model.DictDataAddReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}

	dictService, err := service.NewDictDataService(ctx)
	if err != nil {
		return err
	}

	_, err = dictService.Create(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		glog.Error(err)
		return err

	}
	return nil
}

// UpdateDictData 更新字典明细信息
func (c *Dict) UpdateDictData(ctx context.Context, req *model.EditDictDataReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}

	dictService, err := service.NewDictDataService(ctx)
	if err != nil {
		return err
	}

	err = dictService.UpdateByDict(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		glog.Error(err)
		return err
	}
	return nil
}

// DeleteDictDataByIds 删除字典明细 支持批量删除
func (c *Dict) DeleteDictDataByIds(ctx context.Context, req *comm_def.IdsReq, rsp *comm_def.CommonMsg) error {
	// 参数验证
	if len(req.Ids) == 0 {
		return NoParamsErr
	}
	dictService, err := service.NewDictDataService(ctx)
	if err != nil {
		return err
	}

	err = dictService.DeleteDictDataByIds(req.Ids)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		glog.Error(err)
		return err
	}
	return nil
}