package xinge

import (
	"bytes"
	"encoding/json"
	"errors"
	"net/http"
)

// CommonRspEnv 信鸽推送接口通用基础返回值的environment字段
type CommonRspEnv string

const (
	// EnvProd 生产环境
	EnvProd CommonRspEnv = "product"
	// EnvDev 测试环境
	EnvDev CommonRspEnv = "dev"
)

// XingeURL 信鸽API地址
var XingeURL = "https://openapi.xg.qq.com/v3/push/app"

// PushURL 修改信鸽的请求URL
func PushURL(url string) {
	XingeURL = url
}

//PushMsgOption Option函数的原型
type PushMsgOption func(*PushMsg) error

// CommonRsp 信鸽推送接口的通用基础返回值
type CommonRsp struct {
	// TODO: doc this
	Seq int64 `json:"seq"`
	// 推送id
	PushID string `json:"push_id"`
	// 错误码
	RetCode int `json:"ret_code"`
	// 用户指定推送环境，仅支持iOS
	Environment CommonRspEnv `json:"environment"`
	// 结果描述
	ErrMsg string `json:"err_msg,omitempty"`
	// 请求正确且有额外数据时，则结果在这个字段中
	Result map[string]string `json:"result,omitempty"`
}

// AudienceType 推送目标
type AudienceType string

const (
	// AudienceTypeAll 全量推送
	AudienceTypeAll AudienceType = "all"
	// AudienceTypeTag 标签推送
	AudienceTypeTag AudienceType = "tag"
	// AudienceTypeToken  单设备推送
	AudienceTypeToken AudienceType = "token"
	// AudienceTypeTokenList  设备列表推送
	AudienceTypeTokenList AudienceType = "token_list"
	// AudienceTypeAccount 单账号推送
	AudienceTypeAccount AudienceType = "account"
	// AudienceTypeAccountList 账号列表推送
	AudienceTypeAccountList AudienceType = "account_list"
)

// Platform push API platform参数
type Platform string

const (
	//PlatformAndroid Android推送平台标识
	PlatformAndroid Platform = "android"
	// PlatformiOS 苹果推送平台标识
	PlatformiOS Platform = "ios"
)

// MessageType push API message_type参数
type MessageType string

const (
	// MessageTypeOfNotify 消息类型为通知栏消息
	MessageTypeOfNotify MessageType = "notify"
	// MessageTypeOfMsg 消息类型为透传消息(android)/静默消息(iOS)
	MessageTypeOfMsg MessageType = "message"
)

// PushMsg 推送的消息体
type PushMsg struct {
	//AudienceType 受众类型，见AudienceType类型
	AudienceType `json:"audience_type"`
	//Platform 推送平台，见Platform类型
	Platform `json:"platform"`
	//Message 消息内容
	Message `json:"message"`
	//MessageType 消息类型，见MessageType类型
	MessageType `json:"message_type"`

	//TagList 当AudienceType == AdTag时必填
	TagList *TagList `json:"tag_list,omitempty"`
	/*TokenList 当AudienceType == AdToken 或 AdTokenList 时必填的参数，
	 当AdToken时即使传了多个token，也只有第一个会被推送
	 当AdTokenList时，最多支持1000个token，同时push_id第一次请求时必须填0
	 系统会返回一个push_id = 123(例)，后续推送如果push_id填写123(例)
	则会使用跟123相同的文案推送*/
	TokenList []string `json:"token_list,omitempty"`
	//AccountList 当AudienceType == AudienceTypeAccount 或 AdAccountList 时必填的参数，
	// 当AdAccount时即使传了多个token，也只有第一个会被推送
	// 当AdAccountList时，最多支持1000个token，同时push_id第一次请求时必须填0
	// 系统会返回一个push_id = 123(例)，后续推送如果push_id填写123(例)
	//AccountList 则会使用跟123相同的文案推送
	AccountList []string `json:"account_list,omitempty"`

	//ExpireTime 	消息离线存储时间（单位为秒）
	// 最长存储时间3天，若设置为0，则默认值（3天）
	// 建议取值区间[600, 86400x3]
	//ExpireTime 第三方通道离线保存消息不同厂商标准不同
	ExpireTime int `json:"expire_time,omitempty"`

	//SendTime 	指定推送时间
	// 格式为yyyy-MM-DD HH:MM:SS
	// 若小于服务器当前时间，则会立即推送
	//SendTime 仅全量推送和标签推送支持此字段
	SendTime string `json:"send_time,omitempty"`

	//MultiPkg 	多包名推送
	//MultiPkg 当app存在多个不同渠道包（例如应用宝、豌豆荚等），推送时如果是希望手机上安装任何一个渠道的app都能收到消息那么该值需要设置为true
	MultiPkg bool `json:"multi_pkg,omitempty"`

	//LoopTimes 	循环任务重复次数
	// 仅支持全推、标签推
	//LoopTimes 建议取值[1, 15]
	LoopTimes int `json:"loop_times,omitempty"`

	//Environment 	用户指定推送环境，仅限iOS平台推送使用
	// product： 推送生产环境
	//Environment dev： 推送开发环境
	Environment CommonRspEnv `json:"environment,omitempty"`

	//StatTag 	统计标签，用于聚合统计
	// 使用场景(示例)：
	// 现在有一个活动id：active_picture_123,需要给10000个设备通过单推接口（或者列表推送等推送形式）下发消息，同时设置该字段为active_picture_123
	//StatTag 推送完成之后可以使用v3统计查询接口，根据该标签active_picture_123 查询这10000个设备的实发、抵达、展示、点击数据
	StatTag string `json:"stat_tag,omitempty"`

	//Seq 	接口调用时，在应答包中信鸽会回射该字段，可用于异步请求
	//Seq 使用场景：异步服务中可以通过该字段找到server端返回的对应应答包
	Seq int64 `json:"seq,omitempty"`

	//AccountType 单账号推送时可选
	// 	 账号类型，参考后面账号说明。
	//AccountType  必须与账号绑定时设定的账号类型一致
	AccountType int `json:"account_type,omitempty"`

	//PushID
	// 账号列表推送、设备列表推送时必需
	// 账号列表推送和设备列表推送时，第一次推送该值填0，系统会创建对应的推送任务，
	// 并且返回对应的pushid：123，后续推送push_id 填123(同一个文案）
	// 表示使用与123 id 对应的文案进行推送。(注：文案的有效时间由前面的expire_time 字段决定）
	PushID string `json:"push_id,omitempty"`
	//nextIndex 如果推送的account,token大于1000,需要轮询推送,此标志用来作为遍历的游标
	nextIndex int
}

//IPushMsg PushMsg实现的接口
type IPushMsg interface {
	RenderOptions(opts ...PushMsgOption) error
	clone(options ...PushMsgOption) IPushMsg
	nextRequest() IPushMsg
	toHttpRequest(author IAuth) (request *http.Request, err error)
	equalsPlatform(platform Platform) bool
}

//RenderOptions 使用Option来动态修改PushMsg的内容
func (rst *PushMsg) RenderOptions(opts ...PushMsgOption) error {
	for _, opt := range opts {
		err := opt(rst)
		return err
	}
	return nil
}
func (rst *PushMsg) clone(options ...PushMsgOption) IPushMsg {
	request := PushMsg{
		AudienceType: rst.AudienceType,
		Platform:     rst.Platform,
		Message:      rst.Message,
		MessageType:  rst.MessageType,
		TagList:      rst.TagList,
		TokenList:    rst.TokenList,
		AccountList:  rst.AccountList,
		ExpireTime:   rst.ExpireTime,
		SendTime:     rst.SendTime,
		MultiPkg:     rst.MultiPkg,
		LoopTimes:    rst.LoopTimes,
		Environment:  rst.Environment,
		StatTag:      rst.StatTag,
		Seq:          rst.Seq,
		AccountType:  rst.AccountType,
		PushID:       rst.PushID}
	err := request.RenderOptions(options...)
	if err != nil {
		return nil
	}
	return &request
}
func (rst *PushMsg) nextRequest() IPushMsg {
	var request IPushMsg
	if rst.AudienceType == AudienceTypeAccountList {
		request = rst.clone(sliceAccountList)
	} else if rst.AudienceType == AudienceTypeTokenList {
		request = rst.clone(sliceTokenList)
	} else if rst.nextIndex == 0 {
		rst.nextIndex = -1
		request = rst
	} else {
		request = nil
	}
	return request
}

//equalsPlatform 比较Platform是否一致
func (rst *PushMsg) equalsPlatform(platform Platform) bool {
	return rst.Platform == platform
}

func (rst PushMsg) toHttpRequest(author IAuth) (request *http.Request, err error) {

	bodyBytes, err := json.Marshal(rst)
	if err != nil {
		return nil, err
	}
	request, err = http.NewRequest("POST", XingeURL, bytes.NewReader(bodyBytes))
	if err != nil {
		return nil, err
	}
	author.authRequest(request)
	return
}
func sliceAccountList(rst *PushMsg) error {
	lens := len(rst.AccountList)
	if lens > rst.nextIndex { //大于1000需要二次提交,如果此处长度大于nextIndex,则说明还有(account或者token没有推送)
		end := rst.nextIndex + 1000
		if end > lens {
			end = lens - rst.nextIndex
		}
		rst.AccountList = rst.AccountList[rst.nextIndex:end]
		return nil
	}
	return errors.New("index out of range!")
}
func sliceTokenList(rst *PushMsg) error {
	lens := len(rst.TokenList)
	if lens > rst.nextIndex { //大于1000需要二次提交,如果此处长度大于nextIndex,则说明还有(account或者token没有推送)
		end := rst.nextIndex + 1000
		if end > lens {
			end = lens - rst.nextIndex
		}
		rst.TokenList = rst.TokenList[rst.nextIndex:end]
		rst.nextIndex = end
		return nil
	}
	return errors.New("index out of range!")
}

// TagOperation 标签推送参数的逻辑操作符
type TagOperation string

const (
	// TagOperationAnd 推送tag1且tag2
	TagOperationAnd TagOperation = "AND"
	// TagOperationOr 推送tag1或tag2
	TagOperationOr TagOperation = "OR"
)

// TagList 标签推送参数
type TagList struct {
	//Tags 标签
	Tags []string `json:"tags"`
	//TagOperation 标签逻辑操作符
	TagOperation `json:"op"`
}

// Message 消息体
type Message struct {
	Title      string   `json:"title,omitempty"`
	Content    string   `json:"content,omitempty"`
	AcceptTime []string `json:"accept_time,omitempty"`
	//Android推送的参数
	Android *AndroidParams `json:"android,omitempty"`
	//IOS推送的参数
	IOS *IOSParams `json:"ios,omitempty"`
}

// AndroidParams 安卓push参数
type AndroidParams struct {
	NID           int                    `json:"n_id,omitempty"`
	BuilderID     int                    `json:"builder_id,omitempty"`
	Ring          int                    `json:"ring,omitempty"`
	RingRaw       string                 `json:"ring_raw,omitempty"`
	Vibrate       int                    `json:"vibrate,omitempty"`
	Lights        int                    `json:"lights,omitempty"`
	Cleanable     int                    `json:"clearable,omitempty"`
	IconType      int                    `json:"icon_type,omitempty"`
	IconRes       string                 `json:"icon_res,omitempty"`
	StyleID       int                    `json:"style_id,omitempty"`
	SmallIcon     int                    `json:"small_icon,omitempty"`
	Action        map[string]interface{} `json:"action,omitempty"`
	CustomContent map[string]string      `json:"custom_content,omitempty"`
}

// IOSParams iOS push参数
type IOSParams struct {
	Aps    *Aps              `json:"aps,omitempty"`
	Custom map[string]string `json:"custom,omitempty"`
}

// Aps 通知栏iOS消息的aps字段，详情请参照苹果文档 https://developer.apple.com/library/archive/documentation/NetworkingInternet/Conceptual/RemoteNotificationsPG/PayloadKeyReference.html#//apple_ref/doc/uid/TP40008194-CH17-SW1
type Aps struct {
	Alert            `json:"alert,omitempty"`
	Badge            int    `json:"badge,omitempty"`
	Category         string `json:"category,omitempty"`
	ContentAvailable int    `json:"content-available,omitempty"`
	Sound            string `json:"sound,omitempty"`
	ThreadId         string `json:"thread_id,omitempty"`
}

//Alert 自定义Alert的数据类型
type Alert map[string]interface{}

/*
Alert包含以下几个子属性：
title			String
body			String
title-loc-key	String or null
title-loc-args	Array of strings or null
action-loc-key	String or null
loc-key			String
loc-args		Array of strings
launch-image	String

其中，title,body应该是必须的。详细请参考：
https://developer.apple.com/library/archive/documentation/NetworkingInternet/Conceptual/RemoteNotificationsPG/PayloadKeyReference.html#//apple_ref/doc/uid/TP40008194-CH17-SW1
*/

//Set 设置Key-Value
func (alert Alert) Set(key string, value interface{}) {
	alert[key] = value
}

//SetTitle 设置标题
func (alert Alert) SetTitle(title string) {
	alert.Set("title", title)
}

//SetBody 设置提示详情
func (alert Alert) SetBody(content string) {
	alert.Set("body", content)
}

//SetTitleLocKey 设置相关属性
func (alert Alert) SetTitleLocKey(data string) {
	alert.Set("title-loc-key", data)
}

//SetTitleLocArgs  设置相关属性
func (alert Alert) SetTitleLocArgs(data []string) {
	alert.Set("title-loc-args", data)
}

//SetActionLocKey  设置相关属性
func (alert Alert) SetActionLocKey(data string) {
	alert.Set("action-loc-key", data)
}

//SetLocKey  设置相关属性
func (alert Alert) SetLocKey(data string) {
	alert.Set("loc-key", data)
}

//SetLocArgs  设置相关属性
func (alert Alert) SetLocArgs(data []string) {
	alert.Set("loc-args", data)
}

//SetLaunchImage  设置相关属性
func (alert Alert) SetLaunchImage(data string) {
	alert.Set("launch-image", data)
}

//DefaultAndroidParams 默认的Android推送参数
func DefaultAndroidParams() *AndroidParams {
	return &AndroidParams{NID: 0, BuilderID: 0, Ring: 1, Vibrate: 1, Lights: 0}
}

//DefaultIOSParams 默认的iOS推送参数
func DefaultIOSParams(title string, content string) *IOSParams {
	return &IOSParams{Aps: &Aps{Alert: DefaultApsAlert(title, content)}}
}

//DefaultApsAlert 创建默认的Alert
func DefaultApsAlert(title string, body string) Alert {
	alert := Alert{"title": title, "body": body}
	return alert
}

//DefaultAps 创建默认的Aps
func DefaultAps(title string, content string) *Aps {
	return &Aps{Alert: DefaultApsAlert(title, content)}
}