package gravity

import (
	"github.com/oylshe1314/framework/util"
	"strings"
)

const apiUri = "https://backend.gravity-engine.com/event_center/api"
const apiEventCollect = "/v1/event/collect/"

// 产品名称：逃脱计划（微信）
const wechatAppId = 11930427
const wechatBundleId = "wx057a904618b19710"
const wechatAppKey = "jpXjkmya45lfi6fzGyVvIL2wrPhx7grxYnbsmDJ9ZqgtC0TR8AQvcSdNWieecBtF"
const wechatAccessToken = "aQND0ibWsKq8oOLXbedTlxzFcek4qxpc"
const wechatAesKey = "YcuW6Y+1PoBgz+PNqP3tNA=="

// 产品名称：逃脱计划(TapTap)
const tapTapAppId = 16041238
const tapTapBundleId = "com.qmhd.ttjh.game_1"
const tapTapAppKey = "DQWb2gVXrrowl7qa0PmcYbtcfnSpn6fNtAljdjhyHJLxwihR8pyegzdkZCBOeu5a"
const tapTapAccessToken = "Xj9wf1yyeEtDbnjdBg5pGr8snbqivIcm"
const tapTapAesKey = "OQBXXNxQP6YzDXYrVuJOBQ=="

type Properties map[string]any

func (properties Properties) Add(name string, value any) {
	if !strings.HasPrefix(name, "$") {
		name = "$" + name
	}
	properties[name] = value
}

func (properties Properties) get(name string) any {
	if !strings.HasPrefix(name, "$") {
		name = "$" + name
	}
	return properties[name]
}

type EventType string

const EventTypeTrack EventType = "track"
const EventTypeProfile EventType = "Profile"

type EventName string

const EventNameCharge EventName = "$PayEvent"

type Event struct {
	Type       EventType  `json:"type"`       //事件类型，可选值：track、profile，分别对应用户埋点事件、用户属性事件
	Event      EventName  `json:"event"`      //具体事件英文名称请参考引力后台-设置-元事件
	Time       int64      `json:"time"`       //事件发生毫秒级时间戳，只接收相对服务器时间在前 10 天至后 1 小时之内的数据，超过范围的数据将不会入库
	TimeFree   bool       `json:"time_free"`  //默认为false、当为true的时候会取消对time参数的校验（一般用于历史数据导入）
	Properties Properties `json:"properties"` //事件属性，具体需要参考 引力引擎后台--设置--元数据 中的内容
}

func NewEvent(tipe EventType, event EventName, properties Properties) *Event {
	return &Event{Type: tipe, Event: event, Time: util.NowMilli(), Properties: properties}
}

type Events []*Event

func (events Events) Add(tipe EventType, event EventName, time int64, properties Properties) Events {
	return append(events, &Event{
		Type:       tipe,
		Event:      event,
		Time:       time,
		Properties: properties,
	})
}

type MsgEventCollectReq struct {
	ClientId  string   `json:"client_id"`           //用户唯一 ID
	ClientIp  string   `json:"client_ip,omitempty"` //如果有值，则引力引擎会取该ip作为$ip字段（强制替换）
	ClientUa  string   `json:"client_ua,omitempty"` //如果有值，则引力引擎会取该ua作为$ua字段（强制替换）
	EventList []*Event `json:"event_list"`          //事件列表
}

type MsgEventCollectAck struct {
	Code int    `json:"code"` //如果收到返回参数，code: 0，则代表数据传输成功
	Msg  string `json:"msg"`  //信息
}

type Reporter func(clientId, clientIp string, event *Event) error