274 lines
12 KiB
Markdown
274 lines
12 KiB
Markdown
#灵感/代码缓存
|
||
|
||
## SessionMgr
|
||
|
||
``` cs
|
||
using System;
|
||
using System.Collections;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using DefaultNamespace;
|
||
using HTFramework.Utility;
|
||
using UnityEngine;
|
||
using Newtonsoft.Json;
|
||
using UnityEngine.Networking;
|
||
using Random = System.Random;
|
||
|
||
namespace CGBU_SDK
|
||
{
|
||
[Serializable]
|
||
public class SessionEventData
|
||
{
|
||
public string event_name;
|
||
public long event_timestamp;
|
||
public string public_properties;
|
||
public Dictionary<string, object> event_properties;
|
||
}
|
||
/// <summary>
|
||
/// 会话时间管理类
|
||
/// </summary>
|
||
public class SessionMgr : MonoSingleton<SessionMgr>
|
||
{
|
||
// private const string appId = "3f99e16c541a";
|
||
// private const string reportUrl = "https://global-receiver-ias.icongamesg.com/report/?appid=" + appId; private const string StartSession = "start_session";
|
||
private const string EndSession = "end_session";
|
||
private const string sessionCachePrefsKey = "sessionCachePrefsKey";
|
||
|
||
private const string ReSendUrl = "&batch=1";
|
||
private string _sessionId;
|
||
private string _publicString;
|
||
private long _startEventTimestamp;
|
||
private long _endEventTimestamp;
|
||
private Dictionary<string, object> _eventDic;
|
||
private Dictionary<string, object> _userDataDic;
|
||
|
||
private string _uid = String.Empty;
|
||
|
||
private List<SessionEventData> sessionEventDataList; //临时缓存数据
|
||
private int ListCount = 10; //临时缓存数据大小
|
||
|
||
#region 生命周期
|
||
private void Awake()
|
||
{ _uid = SystemInfo.deviceUniqueIdentifier;
|
||
sessionEventDataList = new List<SessionEventData>(ListCount); //和晨辉沟通，设置最大数量为10
|
||
}
|
||
|
||
private void OnDestroy()
|
||
{ StopNetworkRequest();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 切后台 暂停游戏
|
||
/// </summary>
|
||
/// <param name="pauseStatus"></param> private void OnApplicationPause(bool pauseStatus)
|
||
{ if (pauseStatus)
|
||
{ SendEndSessionEvent();
|
||
}
|
||
else
|
||
{
|
||
CacheEvent(0);
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 退出游戏
|
||
/// </summary>
|
||
private void OnApplicationQuit()
|
||
{ AddToList(CreateEndEvent());
|
||
// SendEndSessionEvent();
|
||
}
|
||
|
||
private SessionEventData CreateEndEvent()
|
||
{ _endEventTimestamp = (DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
|
||
SessionEventData _sessionEndEventData = new SessionEventData
|
||
{
|
||
event_name = EndSession,
|
||
event_timestamp = _endEventTimestamp,
|
||
public_properties = _publicString,
|
||
event_properties = _eventDic
|
||
};
|
||
|
||
_sessionEndEventData.event_name = EndSession;
|
||
_sessionEndEventData.event_timestamp = _endEventTimestamp;
|
||
_sessionEndEventData.event_properties["session_dur"] = _endEventTimestamp - _startEventTimestamp;
|
||
_sessionEndEventData.event_properties["user_properties"] = _userDataDic;
|
||
return _sessionEndEventData;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 会话收发&业务逻辑
|
||
|
||
/// <summary>
|
||
/// 发送结束会话事件
|
||
/// </summary>
|
||
private void SendEndSessionEvent()
|
||
{ SessionEventData endData = CreateEndEvent();
|
||
ReportEvent(JsonConvert.SerializeObject(endData),false,0,endData);
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 初始化 发送开始会话事件
|
||
/// </summary>
|
||
/// <param name="wake"></param> /// <param name="publicString"></param> /// <param name="uid"></param> /// <param name="eventDataDic"></param> /// <param name="userDataDic"></param> public void OnInit(bool wake,string publicString,string uid = null,Dictionary<string,object> eventDataDic = null,Dictionary<string,object> userDataDic = null)
|
||
{ if (!wake)
|
||
{ Destroy(gameObject);
|
||
return; }
|
||
SessionCache.Instance.OnInit();
|
||
_uid = uid != null ? uid : _uid;
|
||
_publicString = publicString;
|
||
_startEventTimestamp = (DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
|
||
_sessionId = _uid + _startEventTimestamp + GenerateRandomString(10);
|
||
_userDataDic = new Dictionary<string, object>();
|
||
_eventDic = new Dictionary<string, object>
|
||
{
|
||
["session_id"] = _sessionId,
|
||
["session_dur"] = 0,
|
||
["user_properties"] = _userDataDic
|
||
};
|
||
SessionEventData _sessionStartEventData = new SessionEventData
|
||
{
|
||
event_name = StartSession,
|
||
event_timestamp = _startEventTimestamp,
|
||
public_properties = _publicString,
|
||
event_properties = _eventDic
|
||
};
|
||
ChangeEventDataDic(eventDataDic);
|
||
ChangeUserDataDic(userDataDic);
|
||
|
||
if (PlayerPrefs.HasKey(sessionCachePrefsKey))
|
||
{ sessionEventDataList =
|
||
JsonConvert.DeserializeObject<List<SessionEventData>>(PlayerPrefs.GetString(sessionCachePrefsKey,
|
||
""));
|
||
}
|
||
ReportEvent(JsonConvert.SerializeObject(_sessionStartEventData), false, 0, _sessionStartEventData);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 修改事件数据
|
||
/// </summary>
|
||
/// <param name="eventDataDic"></param> public void ChangeEventDataDic(Dictionary<string, object> eventDataDic)
|
||
{ if (eventDataDic != null)
|
||
{ Dictionary<string, object> mergedDict = _eventDic.Union(eventDataDic.Where(kvp => !_eventDic.ContainsKey(kvp.Key)))
|
||
.ToDictionary(pair => pair.Key, pair => pair.Value);
|
||
_eventDic = mergedDict;
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 修改用户数据
|
||
/// </summary>
|
||
/// <param name="userDataDic"></param> public void ChangeUserDataDic(Dictionary<string,object> userDataDic)
|
||
{ _userDataDic = userDataDic == null ? _userDataDic : userDataDic;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 生成随机数字字符串
|
||
/// </summary>
|
||
/// <param name="length"></param> /// <returns></returns> private string GenerateRandomString(int length)
|
||
{ const string chars = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
|
||
var random = new Random();
|
||
var stringChars = new char[length];
|
||
for (int i = 0; i < stringChars.Length; i++)
|
||
{ stringChars[i] = chars[random.Next(chars.Length)];
|
||
}
|
||
|
||
var randomString = new string(stringChars);
|
||
return randomString;
|
||
}
|
||
|
||
private void ReportEvent(string eventDataStr,bool isReSend = false,int reSendCount = 0,SessionEventData eventData = null)
|
||
{ if (eventData != null)
|
||
{ AddToList(eventData);
|
||
}
|
||
StartNetworkRequest(Instance.SendSessionEvent(eventDataStr,isReSend,reSendCount,eventData));
|
||
}
|
||
private IEnumerator SendSessionEvent(string eventDataStr,bool isReSend = false,int reSendCount = 0,SessionEventData eventData = null)
|
||
{ string AnalyseAppId = isReSend == false ? "8d482dec8f6d" : "8d482dec8f6d" + ReSendUrl;
|
||
Debug.Log("SendData:"+eventDataStr);
|
||
// 发送POST请求
|
||
// using (UnityWebRequest www = new UnityWebRequest("https://7b6zvje56lpbtmjuzwulj36qoi0hikbc.lambda-url.us-east-1.on.aws?appid=" + AnalyseAppId, "POST"))
|
||
using (UnityWebRequest www = new UnityWebRequest("https://7b6zvje56lpbtmjuzwulj36qoi0hikbc.lambda-url.us-east-1.on.aws?appid=" + AnalyseAppId, "POST"))
|
||
{ byte[] bodyRaw = System.Text.Encoding.UTF8.GetBytes(eventDataStr);
|
||
www.uploadHandler = new UploadHandlerRaw(bodyRaw);
|
||
www.downloadHandler = new DownloadHandlerBuffer();
|
||
www.SetRequestHeader("Content-Type", "application/json");
|
||
yield return www.SendWebRequest();
|
||
|
||
|
||
// 检查是否有错误发生
|
||
if (www.result != UnityWebRequest.Result.Success)
|
||
{ Debug.Log("Error: " + www.error);
|
||
// CacheEvent(jsonData,isReSend,reSendCount);
|
||
}
|
||
else
|
||
{
|
||
Debug.Log("SuccessData:"+eventDataStr);
|
||
// 获取服务器响应的文本内容
|
||
string responseText = www.downloadHandler.text;
|
||
// 输出服务器响应内容
|
||
Debug.Log("Server Response: " + responseText);
|
||
|
||
if (isReSend)
|
||
{ sessionEventDataList.Clear();
|
||
PlayerPrefs.DeleteKey(sessionCachePrefsKey);
|
||
PlayerPrefs.Save();
|
||
}
|
||
else //如果不是重发，说明第一次就发送成功了
|
||
{
|
||
if (eventData != null && sessionEventDataList.Contains(eventData))
|
||
{ Debug.Log("SuccessData_1:"+eventDataStr);
|
||
sessionEventDataList.Remove(eventData);
|
||
}
|
||
} }
|
||
if (www.isNetworkError || www.isHttpError)
|
||
{ Debug.LogError("Error: " + www.error);
|
||
Debug.Log("ErrorData_2:"+eventDataStr);
|
||
}
|
||
CacheEvent(reSendCount);
|
||
}
|
||
} private void CacheEvent(int reSendCount = 0)
|
||
{ if (reSendCount >= 1)
|
||
{ return;
|
||
}
|
||
if (sessionEventDataList.Count >0)
|
||
{ string ListStr = JsonConvert.SerializeObject(sessionEventDataList);
|
||
reSendCount += 1;
|
||
ReportEvent(ListStr,true,reSendCount);
|
||
}
|
||
}
|
||
private void AddToList(SessionEventData sessionEventData)
|
||
{ if (sessionEventDataList.Count >= ListCount)
|
||
{ sessionEventDataList.RemoveAt(0);
|
||
}
|
||
sessionEventDataList.Add(sessionEventData);
|
||
PlayerPrefs.SetString(sessionCachePrefsKey,JsonConvert.SerializeObject(sessionEventDataList));
|
||
PlayerPrefs.Save();
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 协程处理
|
||
|
||
private Coroutine networkCoroutine;
|
||
|
||
private void StartNetworkRequest(IEnumerator coroutine)
|
||
{ if (networkCoroutine == null) //检查是否已有协程在运行
|
||
{
|
||
networkCoroutine = StartCoroutine(coroutine);
|
||
}
|
||
else
|
||
{
|
||
StopCoroutine(networkCoroutine);
|
||
networkCoroutine = StartCoroutine(coroutine);
|
||
}
|
||
} private void StopNetworkRequest()
|
||
{ if (networkCoroutine != null)
|
||
{ StopCoroutine(networkCoroutine);
|
||
networkCoroutine = null;
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
}
|
||
}
|
||
``` |