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"
)

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)
	return svc, nil
}

func (s *postService) GetList(req *model.SysPostSearchParams) (total, page int, list []*model.SysPost, err error) {
	db := dao.SysPost.M
	if req != nil {
		if req.PostCode != "" {
			db.Where("post_code like ?", "%"+req.PostCode+"%")
		}

		if req.PostName != "" {
			db.Where("post_name like ?", "%"+req.PostName+"%")
		}

		if req.Status != "" {
			db.Where("status", req.Status)
		}
	}

	total, err = db.Count()

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

	err = db.Page(req.GetPage()).Order("post_sort asc,post_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 = dao.SysPost.WherePri(id).Scan(&post)
	return
}

func (s *postService) Create(params *model.SysPostAddParams) error {
	_, err := dao.SysPost.Insert(params)
	return err
}

func (s *postService) UpdateById(params *model.SysPostEditParams) (err error) {
	_, err = dao.SysPost.FieldsEx(dao.SysPost.Columns.Id, dao.SysPost.Columns.CreatedBy).
		WherePri(params.PostId).Update(params)
	return err
}

func (s *postService) DeleteByIds(ids []int) error {
	_, err := dao.SysPost.Where(dao.SysPost.Columns.Id+" in(?)", ids).Delete()
	return err
}