package service

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

type GroupService struct {
	*contextService
	Dao *dao.SysGroupDao
}

func NewGroupService(ctx context.Context) (svc *GroupService, err error) {
	svc = new(GroupService)
	if svc.contextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = dao.NewSysGroupDao(svc.Tenant)
	return svc, nil
}

func (s *GroupService) GetList(req *model.SysGroupSearchParams) (total int, list []*model.SysGroup, err error) {
	db := s.Dao.M
	if req != nil {
		if req.GroupCode != "" {
			db = db.WhereLike(s.Dao.C.GroupCode, req.GroupCode)
		}
		if req.GroupName != "" {
			db = db.WhereLike(s.Dao.C.GroupName, req.GroupName)
		}
		if req.Status != "" {
			db = db.Where(s.Dao.C.Status, req.Status)
		}
	}

	total, err = db.Count()

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

	err = db.Page(req.GetPage()).OrderAsc(s.Dao.C.Sort).Scan(&list)
	if err != nil {
		g.Log().Error(err)
		err = myerrors.TipsError("获取数据失败")
	}
	return
}

func (s *GroupService) GetEntity(id int64) (group *model.SysGroup, err error) {
	err = s.Dao.WherePri(id).Scan(&group)
	return
}

func (s *GroupService) Create(params *model.SysGroupReq) error {
	data := new(model.SysGroup)
	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 *GroupService) UpdateById(params *model.UpdateSysGroupReq) (err error) {
	data := new(model.SysGroup)
	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 *GroupService) DeleteByIds(ids []int64) error {
	_, err := s.Dao.WhereIn(s.Dao.C.Id, ids).Delete()
	return err
}