notification

type Attachment struct {
	Name        string `json:"name"`         // 附件名称
	Content     []byte `json:"content"`      // 附件内容
	ContentType string `json:"content_type"` // 内容类型
	Size        int64  `json:"size"`         // 大小
}

type BaseChannelConfig struct {
	Enabled       bool          `json:"enabled" yaml:"enabled"`               // 是否启用
	MaxRetries    int           `json:"max_retries" yaml:"max_retries"`       // 最大重试次数
	RetryInterval time.Duration `json:"retry_interval" yaml:"retry_interval"` // 重试间隔
	Timeout       time.Duration `json:"timeout" yaml:"timeout"`               // 超时时间
}

type BatchSendNotificationPayload struct {
	Requests  []*SendRequest         `json:"requests"`
	Metadata  map[string]interface{} `json:"metadata,omitempty"`
	CreatedAt time.Time              `json:"created_at"`
}

type ChannelConfig interface {
	GetChannelName() string
	Validate() error
}

type EmailChannel struct {
	// contains filtered or unexported fields
}

type EmailConfig interface {
	IsEnabled() bool
	GetMaxRetries() int
	GetRetryInterval() time.Duration
	GetTimeout() time.Duration
	GetChannelName() string
	Validate() error
	GetSMTPHost() string
	GetSMTPPort() int
	GetUsername() string
	GetPassword() string
	GetFromName() string
	GetUseTLS() bool
}

type FeishuChannel struct {
	// contains filtered or unexported fields
}

type FeishuConfig interface {
	IsEnabled() bool
	GetMaxRetries() int
	GetRetryInterval() time.Duration
	GetTimeout() time.Duration
	GetChannelName() string
	Validate() error
	GetAppID() string
	GetAppSecret() string
	GetWebhookURL() string
	GetPrivateMessageAPI() string
	GetTenantAccessTokenAPI() string
}

type Manager struct {
	// contains filtered or unexported fields
}

type NotificationChannel interface {
	// GetName 获取渠道名称
	GetName() string

	// Send 发送通知
	Send(ctx context.Context, request *SendRequest) (*SendResponse, error)

	// Validate 验证配置
	Validate() error

	// IsEnabled 是否启用
	IsEnabled() bool

	// GetMaxRetries 获取最大重试次数
	GetMaxRetries() int

	// GetRetryInterval 获取重试间隔
	GetRetryInterval() time.Duration
}

type NotificationConfig interface {
	GetEmail() EmailConfig
	GetFeishu() FeishuConfig
}

type Processor struct {
	// contains filtered or unexported fields
}

type RetryFailedNotificationPayload struct {
	Request           *SendRequest           `json:"request"`
	OriginalMessageID string                 `json:"original_message_id"`
	RetryCount        int                    `json:"retry_count"`
	LastError         string                 `json:"last_error"`
	Metadata          map[string]interface{} `json:"metadata,omitempty"`
	CreatedAt         time.Time              `json:"created_at"`
}

type ScheduledNotificationPayload struct {
	Request      *SendRequest           `json:"request"`
	ScheduledAt  time.Time              `json:"scheduled_at"`
	ScheduleType string                 `json:"schedule_type"` // once, daily, weekly, monthly
	Metadata     map[string]interface{} `json:"metadata,omitempty"`
	CreatedAt    time.Time              `json:"created_at"`
}

type SendNotificationPayload struct {
	Request   *SendRequest           `json:"request"`
	Metadata  map[string]interface{} `json:"metadata,omitempty"`
	CreatedAt time.Time              `json:"created_at"`
}

type SendRequest struct {
	// 基础信息
	MessageID string `json:"message_id"` // 消息ID
	Subject   string `json:"subject"`    // 主题
	Content   string `json:"content"`    // 内容
	Priority  int8   `json:"priority"`   // 优先级 1-高 2-中 3-低

	// 接收人信息
	RecipientType string `json:"recipient_type"` // 接收人类型
	RecipientID   string `json:"recipient_id"`   // 接收人ID
	RecipientAddr string `json:"recipient_addr"` // 接收人地址(邮箱/手机号等)
	RecipientName string `json:"recipient_name"` // 接收人名称

	// 工单相关
	InstanceID *int   `json:"instance_id,omitempty"` // 工单实例ID
	EventType  string `json:"event_type"`            // 事件类型

	// 扩展数据
	Metadata    map[string]interface{} `json:"metadata,omitempty"`    // 元数据
	Templates   map[string]string      `json:"templates,omitempty"`   // 模板变量
	Attachments []Attachment           `json:"attachments,omitempty"` // 附件
}

type SendResponse struct {
	Success      bool                   `json:"success"`                 // 是否成功
	MessageID    string                 `json:"message_id"`              // 消息ID
	ExternalID   string                 `json:"external_id"`             // 外部系统消息ID
	Status       string                 `json:"status"`                  // 状态
	ErrorMessage string                 `json:"error_message"`           // 错误信息
	Cost         *float64               `json:"cost,omitempty"`          // 发送成本
	SendTime     time.Time              `json:"send_time"`               // 发送时间
	ResponseData map[string]interface{} `json:"response_data,omitempty"` // 响应数据
}