using System;
|
using Top.Api.Util;
|
using System.Threading;
|
using System.Collections.Generic;
|
using Top.Api.Security;
|
using System.Text;
|
|
namespace Top.Api.Report
|
{
|
|
public class ApiReporter
|
{
|
private static readonly ITopLogger Log = Top.Api.Log.Instance;
|
private static readonly object InitSecretLock = new object();
|
private static readonly int SleepTime = 1000 * 60 * 1;
|
private static readonly int FlushInterval = 1000 * 60 * 5;// 5分钟
|
private static readonly int MinFlushInterval = 1000 * 60 * 1;// 1分钟
|
private static readonly string AppSecretType = "2";
|
private static readonly string AppUserSecretType = "3";
|
private static readonly IDictionary<string, object> AppInitStatus = new Dictionary<string, object>();
|
private DefaultTopClient topClient;
|
private bool EnableApiReporter = false;
|
|
|
public void InitSecret(DefaultTopClient defaultTaobaoClient)
|
{
|
string appkey = defaultTaobaoClient.appKey;
|
this.topClient = defaultTaobaoClient;
|
if(!EnableApiReporter)
|
{
|
return;
|
}
|
lock (InitSecretLock)
|
{
|
if (AppInitStatus.ContainsKey(appkey))
|
{
|
return;
|
}
|
|
InitSecretThread();
|
AppInitStatus.Add(appkey, true);
|
}
|
}
|
|
public void SetEnableApiReporter(bool enable)
|
{
|
this.EnableApiReporter = enable;
|
}
|
|
private void InitSecretThread()
|
{
|
Thread uploadThread = new Thread(o =>
|
{
|
DoUploadBiz();
|
});
|
uploadThread.IsBackground = true;
|
uploadThread.Name = "flushSecretApiReporter-thread";
|
uploadThread.Start();
|
}
|
|
private void DoUploadBiz()
|
{
|
long uploadTime = TopUtils.GetCurrentTimeMillis() + FlushInterval;
|
while (true)
|
{
|
try
|
{
|
Thread.Sleep(SleepTime);
|
IDictionary<string, Counter> appUserCounterMap = SecurityCounter.GetUserCounter(topClient.appKey);
|
if (TopUtils.GetCurrentTimeMillis() >= uploadTime || (appUserCounterMap.Count * 4 > 65536))
|
{
|
StringBuilder counterBuilder = new StringBuilder();
|
IDictionary<string, Counter> cloneAppUserCounter = SecurityCounter.CloneUserCounter(topClient.appKey);
|
SecurityCounter.CleanUserCounter(topClient.appKey);
|
|
int count = 0;
|
foreach (KeyValuePair<string, Counter> currentPair in cloneAppUserCounter)
|
{
|
Counter counter = currentPair.Value;
|
if (counterBuilder.Length > 0)
|
{
|
counterBuilder.Append(";");
|
}
|
counterBuilder.Append(currentPair.Key);
|
GenerateCounter(counterBuilder, counter);
|
|
if ((++count) % 100 == 0)
|
{
|
DoUpload(counterBuilder.ToString(), AppUserSecretType);
|
counterBuilder = new StringBuilder();
|
}
|
}
|
if (counterBuilder.Length > 0)
|
{
|
DoUpload(counterBuilder.ToString(), AppUserSecretType);
|
counterBuilder = new StringBuilder();
|
}
|
|
Counter appCounter = SecurityCounter.GetAppCounter(topClient.appKey);
|
counterBuilder.Append(SecurityCore.GetAppUserSecretCache().Count);
|
GenerateCounter(counterBuilder, appCounter);
|
appCounter.Reset();
|
|
long uploadInterval = DoUpload(counterBuilder.ToString(), AppSecretType);
|
uploadTime = TopUtils.GetCurrentTimeMillis() + uploadInterval;
|
}
|
}
|
catch (Exception e)
|
{
|
Log.Error(string.Format("flushSecretApiReporter error: {0}", e.Message));
|
}
|
}
|
}
|
|
private IDictionary<string, Counter> CloneAppUserCounter(IDictionary<string, Counter> sourceDictionary)
|
{
|
IDictionary<string, Counter> targetDictionary = new Dictionary<string, Counter>();
|
foreach (KeyValuePair<string, Counter> currentPair in sourceDictionary)
|
{
|
targetDictionary.Add(currentPair.Key, currentPair.Value);
|
}
|
return targetDictionary;
|
}
|
|
private int DoUpload(string contentJson, string type)
|
{
|
int uploadInterval = FlushInterval;
|
TopSdkFeedbackUploadRequest request = new TopSdkFeedbackUploadRequest();
|
request.Type = type;
|
request.Content = contentJson;
|
|
TopSdkFeedbackUploadResponse response = topClient.Execute(request, null);
|
if (!response.IsError)
|
{
|
uploadInterval = response.UploadInterval;
|
if (uploadInterval < MinFlushInterval)
|
{
|
uploadInterval = FlushInterval;
|
}
|
}
|
return uploadInterval;
|
}
|
|
|
private void GenerateCounter(StringBuilder counterBuilder, Counter counter)
|
{
|
|
// encrypt
|
if (counterBuilder.Length > 0)
|
{
|
counterBuilder.Append(",");
|
}
|
if (SecurityCounter.GetAppCounter(topClient.appKey).GetEncryptPhoneNum() != 0)
|
{
|
counterBuilder.Append(counter.GetEncryptPhoneNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetEncryptNickNum() != 0)
|
{
|
counterBuilder.Append(counter.GetEncryptNickNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetEncryptReceiverNameNum() != 0)
|
{
|
counterBuilder.Append(counter.GetEncryptReceiverNameNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetEncryptSimpleNum() != 0)
|
{
|
counterBuilder.Append(counter.GetEncryptSimpleNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetEncryptSearchNum() != 0)
|
{
|
counterBuilder.Append(counter.GetEncryptSearchNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
|
// decrypt
|
counterBuilder.Append(",");
|
if (counter.GetDecryptPhoneNum() != 0)
|
{
|
counterBuilder.Append(counter.GetDecryptPhoneNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetDecryptNickNum() != 0)
|
{
|
counterBuilder.Append(counter.GetDecryptNickNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetDecryptReceiverNameNum() != 0)
|
{
|
counterBuilder.Append(counter.GetDecryptReceiverNameNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetDecryptSimpleNum() != 0)
|
{
|
counterBuilder.Append(counter.GetDecryptSimpleNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetDecryptSearchNum() != 0)
|
{
|
counterBuilder.Append(counter.GetDecryptSearchNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
|
// search
|
counterBuilder.Append(",");
|
if (counter.GetSearchPhoneNum() != 0)
|
{
|
counterBuilder.Append(counter.GetSearchPhoneNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetSearchNickNum() != 0)
|
{
|
counterBuilder.Append(counter.GetSearchNickNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetSearchReceiverNameNum() != 0)
|
{
|
counterBuilder.Append(counter.GetSearchReceiverNameNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetSearchSimpleNum() != 0)
|
{
|
counterBuilder.Append(counter.GetSearchSimpleNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
counterBuilder.Append(",");
|
if (counter.GetSearchSearchNum() != 0)
|
{
|
counterBuilder.Append(counter.GetSearchSearchNum());
|
}
|
else
|
{
|
counterBuilder.Append("0");
|
}
|
}
|
}
|
}
|
