opms_backend/opms_admin/app/service/sys_post.go

package service

import (
	"context"
	"dashoo.cn/micro/app/dao"
	"dashoo.cn/micro/app/model"
	"github.com/gogf/gf/errors/gerror"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/util/gconv"
)

type postService struct {
	*contextService
	Dao *dao.SysPostDao
}

func NewPostService(ctx context.Context) (svc *postService, err error) {
	svc = new(postService)
	if svc.contextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = dao.NewSysPostDao(svc.Tenant)
	svc.Table = svc.Dao.Table
	return svc, nil
}

func (s *postService) GetList(req *model.SysPostSearchParams) (total int, list []*model.SysPost, err error) {
	db := s.Dao.M
	if req != nil {
		if req.PostCode != "" {
			db = db.WhereLike(s.Dao.Columns.PostCode, req.PostCode)
		}
		if req.PostName != "" {
			db = db.WhereLike(s.Dao.Columns.PostName, req.PostName)
		}
		if req.Status != "" {
			db = db.Where(s.Dao.Columns.Status, req.Status)
		}
	}

	total, err = db.Count()

	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取总行数失败")
	}

	err = db.Page(req.GetPage()).Order(s.Dao.Columns.Sort + " asc," + s.Dao.Columns.Id + " asc").Scan(&list)
	if err != nil {
		g.Log().Error(err)
		err = gerror.New("获取数据失败")
	}
	return
}

func (s *postService) GetEntity(id int64) (post *model.SysPost, err error) {
	err = s.Dao.WherePri(id).Scan(&post)
	return
}

func (s *postService) Create(params *model.SysPostReq) error {
	data := new(model.SysPost)
	if err := gconv.Struct(params, data); err != nil {
		return err
	}
	SetCreatedInfo(data, s.GetCxtUserId(), s.GetCxtUserName())
	_, err := s.Dao.Insert(data)
	return err
}

func (s *postService) UpdateById(params *model.UpdateSysPostReq) (err error) {
	data := new(model.SysPost)
	if err := gconv.Struct(params, data); err != nil {
		return err
	}
	SetUpdatedInfo(data, s.GetCxtUserId(), s.GetCxtUserName())
	_, err = s.Dao.FieldsEx(UpdateFieldEx...).WherePri(params.Id).Update(data)
	return err
}

func (s *postService) DeleteByIds(ids []int64) error {
	_, err := s.Dao.WhereIn(s.Dao.Columns.Id, ids).Delete()
	return err
}