package opsdev

import (
	"context"

	"dashoo.cn/common_definition/comm_def"
	"dashoo.cn/opms_libary/myerrors"
	opsdevmodel "dashoo.cn/opms_parent/app/model/opsdev"
	services "dashoo.cn/opms_parent/app/service/opsdev"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/util/gvalid"
)

// PlatMeetingHandler 会议管理接口处理类
type PlatMeetingHandler struct{}

// GetList 分页查询会议列表
func (h *PlatMeetingHandler) GetList(ctx context.Context, req *opsdevmodel.PlatMeetingSearchReq, rsp *comm_def.CommonMsg) error {
	s, err := services.NewPlatMeetingService(ctx)
	if err != nil {
		return err
	}
	total, list, err := s.GetList(req)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": list, "total": total}
	return nil
}

// Create 新增会议
func (h *PlatMeetingHandler) Create(ctx context.Context, req *opsdevmodel.PlatMeetingAddReq, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return myerrors.ValidError(err.Error())
	}
	s, err := services.NewPlatMeetingService(ctx)
	if err != nil {
		return err
	}
	if err := s.Create(req); err != nil {
		return err
	}
	rsp.Data = g.Map{"message": "新增成功"}
	return nil
}

// UpdateById 更新会议
func (h *PlatMeetingHandler) UpdateById(ctx context.Context, req *opsdevmodel.PlatMeetingUpdateReq, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return myerrors.ValidError(err.Error())
	}
	s, err := services.NewPlatMeetingService(ctx)
	if err != nil {
		return err
	}
	if err := s.UpdateById(req); err != nil {
		return err
	}
	rsp.Data = g.Map{"message": "更新成功"}
	return nil
}

// DeleteByIds 删除会议
func (h *PlatMeetingHandler) DeleteByIds(ctx context.Context, req *opsdevmodel.PlatMeetingDeleteReq, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return myerrors.ValidError(err.Error())
	}
	s, err := services.NewPlatMeetingService(ctx)
	if err != nil {
		return err
	}
	if err := s.DeleteByIds(req.Ids); err != nil {
		return err
	}
	rsp.Data = g.Map{"message": "删除成功"}
	return nil
}

// GetById 根据ID获取会议详情
func (h *PlatMeetingHandler) GetById(ctx context.Context, req *opsdevmodel.IdReq, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return myerrors.ValidError(err.Error())
	}
	s, err := services.NewPlatMeetingService(ctx)
	if err != nil {
		return err
	}
	data, err := s.GetById(req.Id)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"data": data}
	return nil
}

// AddAttendees 追加参会人员
func (h *PlatMeetingHandler) AddAttendees(ctx context.Context, req *opsdevmodel.PlatMeetingAddAttendeeReq, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return myerrors.ValidError(err.Error())
	}
	s, err := services.NewPlatMeetingService(ctx)
	if err != nil {
		return err
	}
	if err := s.AddAttendees(req); err != nil {
		return err
	}
	rsp.Data = g.Map{"message": "追加成功"}
	return nil
}

// Complete 结束会议（计算时长并生成工时）
func (h *PlatMeetingHandler) Complete(ctx context.Context, req *opsdevmodel.PlatMeetingCompleteReq, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return myerrors.ValidError(err.Error())
	}
	s, err := services.NewPlatMeetingService(ctx)
	if err != nil {
		return err
	}
	if err := s.Complete(req); err != nil {
		return err
	}
	rsp.Data = g.Map{"message": "会议已结束，工时已生成"}
	return nil
}

// GetWorkHourList 获取会议工时记录
func (h *PlatMeetingHandler) GetWorkHourList(ctx context.Context, req *opsdevmodel.IdReq, rsp *comm_def.CommonMsg) error {
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return myerrors.ValidError(err.Error())
	}
	s, err := services.NewPlatMeetingService(ctx)
	if err != nil {
		return err
	}
	list, err := s.GetWorkHourList(req.Id)
	if err != nil {
		return err
	}
	rsp.Data = g.Map{"list": list}
	return nil
}