package plat

import (
	"context"
	"strings"

	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/util/gconv"

	"dashoo.cn/micro/app/dao/plat"
	model "dashoo.cn/micro/app/model/plat"
	"dashoo.cn/micro/app/service"
)

type scheduleService struct {
	*service.ContextService

	Dao *plat.PlatScheduleDao
}

func NewScheduleService(ctx context.Context) (svc *scheduleService, err error) {
	svc = new(scheduleService)
	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = plat.NewPlatScheduleDao(svc.Tenant)
	return svc, nil
}

//GetList 日程列表
func (s *scheduleService) GetList(req *model.ScheduleSearchReq) (total int, scheduleList []*model.GetScheduleRes, err error) {
	Model := s.Dao.M
	Model = Model.Where("user_id = ", s.GetCxtUserId())
	if req.SchDate != nil {
		schDate := gconv.String(req.SchDate)
		begin := strings.Split(schDate, " ")[0] + " 00:00:00"
		end := strings.Split(schDate, " ")[0] + " 23:59:59"
		Model = Model.Where("sch_date >= ? AND sch_date <= ? ", begin, end)
	}
	total, err = Model.Count()
	if err != nil {

		g.Log().Error(err)
		//err = myerrors.DbError("获取总行数失败。")
		return
	}
	err = Model.Page(req.GetPage()).Order("id desc").Scan(&scheduleList)
	if err != nil {
		g.Log().Error(err)
		return
	}
	return
}

//Create 创建日程信息
func (s *scheduleService) Create(req *model.AddScheduleSeq) (insertId int64, err error) {
	schedule := new(model.PlatSchedule)
	if err = gconv.Struct(req, schedule); err != nil {
		return
	}
	service.SetCreatedInfo(schedule, s.GetCxtUserId(), s.GetCxtUserName())
	schedule.UserId = s.GetCxtUserId()
	schedule.UserName = s.GetCxtUserName()
	insertId, err = s.Dao.InsertAndGetId(schedule)
	if err != nil {
		g.Log().Error(err)
		return 0, err
	}
	return

}