using System; using System.Threading; using System.Data; using StackExchange.Redis; using CSharpUtil; using System.Collections.Generic; using System.Linq; using Newtonsoft.Json; using Newtonsoft.Json.Linq; using System.Diagnostics; using DataTransfer.tongji; namespace DataTransfer { class Program { static void Main(string[] args) { Console.WriteLine("言灵数据传输开始........"); Thread t1 = new Thread(transfer); t1.Start(); } public static int mask = 0; public static int mask_lose = 0; public static int dataSavNum = 0; public static void dataSav() { Console.WriteLine("dataSav................"); DataToExcelText.TargetStatistics(); } public static void transfer() { Console.WriteLine("transfer............"); while (true) { try { int hour = DateTime.Now.Hour; if (hour == 2 && mask == 0)//正式的是晚上2点进行数据传输 { Console.WriteLine("数据传输的时间到了开始执行程序......."); //进行数据传输 mask = 1; dataTransfer(); } if (hour != 2 && mask != 0) { mask = 0; } #region------流失玩家指标分析 if (hour == 17 && mask_lose == 0)//正式的是晚上2点进行数据传输 { Console.WriteLine("统计信息程序开始执行............"); //进行数据传输 mask_lose = 1; UserStatistics.DataDeal(); } if (hour != 17 && mask_lose != 0) { mask_lose = 0; } #endregion } catch (Exception ex) { Console.WriteLine(ex.Message); // 提示套接字监听异常 break; } } } public static void dataTransfer() { Console.WriteLine("进入dataTransfer方法.............."); TimeSpan ts = DateTime.Now.ToUniversalTime() - new DateTime(1970, 1, 1); float day = MathF.Floor((long)ts.TotalSeconds / 24 / 60 / 60); Console.WriteLine("当前天是:" + day); var mem = Redis.Ins.GetDatabase(0); //int zoneid = 1;//暂时先这样 HashEntry[] zoneidList = mem.HashGetAll(MemKey_Statistics.Zonelist()); foreach (var item in zoneidList) { string[] sList = item.ToString().Split(':'); int zoneid = int.Parse(sList[0]); Taskprogressrecord_RedisToSql(zoneid); if (mem.KeyExists(MemKey_Statistics.GamerunLoginUser(zoneid, day))) { string[] list = mem.HashKeys(MemKey_Statistics.GamerunLoginUser(zoneid, day)).ToStringArray(); foreach (string k in list) { Console.WriteLine("uid:" + k); redisToSql(k, zoneid); } } else { Console.WriteLine(day+"-没有玩家登录,以玩家为单位的数据不做传输"); } } } /// /// redis数据传输到mysql中 /// /// /// public static void redisToSql(string uid,int zoneid) { Console.WriteLine("以玩家为单位数据传输开始..........:" ); Userbaseparams_RedisToSql(uid,zoneid); TaskcompleteTsrecord_RedisToSql(uid,zoneid); } const string Userbaseparams_TableName = "tab_userbaseparams"; const string TaskcompleteTsrecord_TableName = "tab_taskcompleteTsrecord"; const string Taskprogressrecord_TableName = "tab_taskprogressrecord"; /// /// 界面内数值变化数据传输 /// /// /// public static void Userbaseparams_RedisToSql(string uid, int zoneid) { Console.WriteLine("玩家基础数值变化方法开始........."); var mem = Redis.Ins.GetDatabase(0); string key = MemKey_Statistics.UserBaseParams(uid, zoneid); if (mem.KeyExists(key)) { long length = mem.ListLength(key); var ctxList = mem.ListRange(key, 0, length); int num = 0; foreach (var item in ctxList) { num += 1; JObject dic = JObject.Parse(item.ToString()); int cmd = int.Parse(dic["cmd"].ToString()); int type = int.Parse(dic["type"].ToString()); string curVal = dic["curVal"].ToString(); string changeVal = dic["changeVal"].ToString(); string endVal = dic["endVal"].ToString(); string desc = dic["desc"].ToString(); //Console.WriteLine("desc..........:"+ desc); string ts = dic["ts"].ToString(); //continue; var sql = $" Insert Into {Userbaseparams_TableName} (`uid`, `zoneid`, `cmd`, `type`, `curVal`, `endVal`, `changeVal`, `desc`, `ts`) " + $"values('{uid}',{zoneid},{cmd},{type},'{curVal}','{endVal}','{changeVal}','{desc}','{ts}')"; var n = MysqlUtil.Ins.ExecuteSqlNonQuery(sql); //Debug.Assert(n > 0, $"{sql} 执行失败!"); if (num >= length) { Console.WriteLine("总共执行条数:" + num); mem.KeyDelete(key); break; } } } } /// /// 个人数据 包括以下两点: ///1.通过玩家ID查询指定玩家的任务进度,包括任务ID和任务STEP ID----【直接从玩家数据里取数据展示】 ///2.可查询玩家每日任务进度变化---【单一记录玩家自己的任务信息就可以了,每次做任务时候要记录时间,展示的时候需要以天为单位展示任务进度】 /// /// /// public static void TaskcompleteTsrecord_RedisToSql(string uid, int zoneid) { var mem = Redis.Ins.GetDatabase(0); string key = MemKey_Statistics.SelfTaskDataCollect(uid, zoneid); if (mem.KeyExists(key)) { Console.WriteLine("玩家任务完成时间记录方法开始........."); long length = mem.ListLength(key); var ctxList = mem.ListRange(key, 0, length); int num = 0; foreach (var item in ctxList) { num += 1; string[] sList = item.ToString().Split('-'); string taskId = sList[0]; string time = sList[1]; var sql = $" Insert Into {TaskcompleteTsrecord_TableName} (`uid`, `zoneid`, `taskId`, `time`) " + $"values('{uid}',{zoneid},'{taskId}','{time}')"; var n = MysqlUtil.Ins.ExecuteSqlNonQuery(sql); //Debug.Assert(n > 0, $"{sql} 执行失败!"); if (num >= length) { Console.WriteLine("总共执行条数:" + num); mem.KeyDelete(key); break; } } } } /// /// 所有玩家最新任务id记录 /// /// /// public static void Taskprogressrecord_RedisToSql(int zoneid) { Console.WriteLine("玩家任务进度方式开始......"); var mem = Redis.Ins.GetDatabase(0); string key = MemKey_Statistics.TaskDataCollect(zoneid); if (mem.KeyExists(key)) { HashEntry[] ctxList = mem.HashGetAll(key); int length = ctxList.Length; int num = 0; foreach (var item in ctxList) { num += 1; string[] sList = item.ToString().Split(':'); string uid = sList[0]; string taskId = sList[1]; var sql = $" Insert Into {Taskprogressrecord_TableName} (`uid`, `zoneid`, `taskId`) " + $"values('{uid}',{zoneid},'{taskId}')"; var n = MysqlUtil.Ins.ExecuteSqlNonQuery(sql); //Debug.Assert(n > 0, $"{sql} 执行失败!"); if (num >= length) { Console.WriteLine("总共执行条数:" + num); mem.KeyDelete(key); break; } } } else { Console.WriteLine("玩家任务进度redis-key不存在所以不在数据传输处理"); } } } }