package backend

import (
	"cron_admin/app/models/croncmdmodel"
	"cron_admin/app/models/crondbmodel"
	"cron_admin/app/models/cronreportchannelmodel"
	"time"
)

type CmdListRequest struct {
	Page        int      `json:"page" validate:"required" form:"page" example:"1"`
	Limit       int      `json:"limit" validate:"required" form:"limit" example:"10"`
	CmdName     string   `json:"cmd_name" form:"cmd_name" example:"155555555"`
	Status      int      `json:"status" form:"status" example:"1"`
	ExecuteType int      `json:"execute_type" form:"execute_type" example:"46516"`
	ReadDbId    int      `json:"read_db_id"`
	WriteDbId   int      `json:"write_db_id"`
	CmdIds      []string `json:"cmd_id"`
}

type CmdInfoRequest struct {
	CmdId int `json:"cmd_id" form:"cmd_id" validate:"required" example:"1"`
}

type CmdListResponse struct {
	CmdId           int                                       `json:"cmd_id"`
	CmdName         string                                    `json:"cmd_name"`
	UserIds         string                                    `json:"user_ids"`
	EntryId         int                                       `json:"entry_id"`
	ReadDbId        int                                       `json:"read_db_id"`
	WriteDbId       int                                       `json:"write_db_id"`
	ExecuteType     int                                       `json:"execute_type"`
	ExecuteRead     string                                    `json:"execute_read"`
	ExecuteWrite    string                                    `json:"execute_write"`
	Cron            string                                    `json:"cron"`
	MatchJson       string                                    `json:"match_json"`
	SendTimeType    int                                       `json:"send_time_type"`
	SendLimit       int                                       `json:"send_limit"`
	ReportChannelId int                                       `json:"report_channel_id"`
	CreateTime      string                                    `json:"create_time"`
	UpdateTime      string                                    `json:"update_time"`
	Status          int                                       `json:"status"`
	FailReason      string                                    `json:"fail_reason"`
	Users           string                                    `json:"users"`
	ReadDb          *crondbmodel.CronDb                       `json:"read_db"`
	WriteDb         *crondbmodel.CronDb                       `json:"write_db"`
	ReportChannel   *cronreportchannelmodel.CronReportChannel `json:"report_channel"`
}

type CmdAddRequest struct {
	CmdName         string `json:"cmd_name"`
	UserIds         string `json:"user_ids"`
	ReadDbId        int    `json:"read_db_id"`
	WriteDbId       int    `json:"write_db_id"`
	ExecuteType     int    `json:"execute_type"`
	ExecuteRead     string `json:"execute_read"`
	ExecuteWrite    string `json:"execute_write"`
	Cron            string `json:"cron"`
	MatchJson       string `json:"match_json"`
	SendTimeType    int    `json:"send_time_type"`
	SendLimit       int    `json:"send_limit"`
	ReportChannelId int    `json:"report_channel_id"`
}

type CmdEditRequest struct {
	CmdId           int    `json:"cmd_id" validate:"required" form:"cmd_id" example:""`
	CmdName         string `json:"cmd_name"`
	UserIds         string `json:"user_ids"`
	ReadDbId        int    `json:"read_db_id"`
	WriteDbId       int    `json:"write_db_id"`
	ExecuteType     int    `json:"execute_type"`
	ExecuteRead     string `json:"execute_read"`
	ExecuteWrite    string `json:"execute_write"`
	Cron            string `json:"cron"`
	MatchJson       string `json:"match_json"`
	SendTimeType    int    `json:"send_time_type"`
	SendLimit       int    `json:"send_limit"`
	ReportChannelId int    `json:"report_channel_id"`
}

type CmdDeleteRequest struct {
	CmdId int `json:"cmd_id" validate:"required" form:"cmd_id" example:""`
}

type CmdStartRequest struct {
	CmdId int `json:"cmd_id" validate:"required" form:"cmd_id" example:""`
}

type CmdTestWriteRequest struct {
	ReadDbId     int    `json:"read_db_id" validate:"required"`
	ExecuteRead  string `json:"execute_read" validate:"required"`
	WriteDbId    int    `json:"write_db_id" validate:"required"`
	ExecuteWrite string `json:"execute_write" validate:"required"`
	MatchJson    string `json:"match_json" validate:"required"`
}

type CmdTestReadRequest struct {
	ReadDbId    int    `json:"read_db_id" validate:"required" form:"read_db_id" example:""`
	ExecuteRead string `json:"execute_read" validate:"required" form:"execute_read" example:""`
}

type CmdStopRequest struct {
	CmdId int `json:"cmd_id" validate:"required" form:"cmd_id" example:""`
}

func (response *CmdListResponse) ResponseFromDb(l croncmdmodel.CronCmd) {
	response.CmdId = l.CmdId
	response.CmdName = l.CmdName
	response.UserIds = l.UserIds
	response.Status = l.Status
	response.ReadDbId = l.ReadDbId
	response.WriteDbId = l.WriteDbId
	response.ExecuteType = l.ExecuteType
	response.ExecuteRead = l.ExecuteRead
	response.ExecuteWrite = l.ExecuteWrite
	response.Cron = l.Cron
	response.MatchJson = l.MatchJson
	response.SendTimeType = l.SendTimeType
	response.SendLimit = l.SendLimit
	response.ReportChannelId = l.ReportChannelId
	response.CreateTime = l.CreateTime.Format(time.DateTime)
	response.UpdateTime = l.UpdateTime.Format(time.DateTime)
	response.FailReason = l.FailReason

	//cronusermodel.GetInstance().GetDb().Where("user_id IN (?)", strings.Join(strings.Split(l.UserIds, ","), ",")).Find(&response.Users)
	//crond.GetInstance().GetDb().Where("user_id = ?", strings.Join(strings.Split(l.UserIds, ","), ",")).Find(&response.Users)
	return

}