Program.cs 9.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274
  1. using System;
  2. using System.Threading;
  3. using System.Data;
  4. using StackExchange.Redis;
  5. using CSharpUtil;
  6. using System.Collections.Generic;
  7. using System.Linq;
  8. using Newtonsoft.Json;
  9. using Newtonsoft.Json.Linq;
  10. using System.Diagnostics;
  11. using DataTransfer.tongji;
  12. namespace DataTransfer
  13. {
  14. class Program
  15. {
  16. static void Main(string[] args)
  17. {
  18. Console.WriteLine("言灵数据传输开始........");
  19. Thread t1 = new Thread(transfer);
  20. t1.Start();
  21. //dataSav();
  22. }
  23. public static int mask = 0;
  24. public static int mask_lose = 0;
  25. public static int dataSavNum = 0;
  26. public static void dataSav()
  27. {
  28. Console.WriteLine("dataSav................");
  29. //DataToExcelText.TargetStatistics();
  30. }
  31. public static void transfer()
  32. {
  33. Console.WriteLine("transfer............");
  34. while (true)
  35. {
  36. try
  37. {
  38. int hour = DateTime.Now.Hour;
  39. if (hour == 2 && mask == 0)//正式的是晚上2点进行数据传输
  40. {
  41. Console.WriteLine("数据传输的时间到了开始执行程序.......");
  42. //进行数据传输
  43. mask = 1;
  44. dataTransfer();
  45. }
  46. if (hour != 2 && mask != 0)
  47. {
  48. mask = 0;
  49. }
  50. #region------流失玩家指标分析
  51. //【解释:次日、2日、3日、4日、5日、6日、7日的流失玩家的uid和该玩家的信息统计\\redis中保存一份,execl文件也存一份】
  52. if (hour == 3 && mask_lose == 0)//正式的是晚上2点进行数据传输
  53. {
  54. Console.WriteLine("统计信息程序开始执行............");
  55. //进行数据传输
  56. mask_lose = 1;
  57. UserStatistics.DataDeal();
  58. }
  59. if (hour != 3 && mask_lose != 0)
  60. {
  61. mask_lose = 0;
  62. }
  63. #endregion
  64. }
  65. catch (Exception ex)
  66. {
  67. Console.WriteLine(ex.Message); // 提示套接字监听异常
  68. break;
  69. }
  70. }
  71. }
  72. public static void dataTransfer()
  73. {
  74. Console.WriteLine("进入dataTransfer方法..............");
  75. TimeSpan ts = DateTime.Now.ToUniversalTime() - new DateTime(1970, 1, 1);
  76. float curday = MathF.Floor((long)ts.TotalSeconds / 24 / 60 / 60);
  77. float day = curday - 1;
  78. Console.WriteLine("当前天是:" + day);
  79. var mem = Redis.Ins.GetDatabase(0);
  80. //int zoneid = 1;//暂时先这样
  81. HashEntry[] zoneidList = mem.HashGetAll(MemKey_Statistics.Zonelist());
  82. foreach (var item in zoneidList)
  83. {
  84. string[] sList = item.ToString().Split(':');
  85. int zoneid = int.Parse(sList[0]);
  86. Taskprogressrecord_RedisToSql(zoneid);
  87. Userbaseparams_RedisToSql(zoneid);
  88. if (mem.KeyExists(MemKey_Statistics.GamerunLoginUser(zoneid, day)))
  89. {
  90. string[] list = mem.HashKeys(MemKey_Statistics.GamerunLoginUser(zoneid, day)).ToStringArray();
  91. foreach (string k in list)
  92. {
  93. Console.WriteLine("uid:" + k);
  94. redisToSql(k, zoneid);
  95. }
  96. }
  97. else
  98. {
  99. Console.WriteLine(day + "-没有玩家登录,以玩家为单位的数据不做传输");
  100. }
  101. }
  102. }
  103. /// <summary>
  104. /// redis数据传输到mysql中
  105. /// </summary>
  106. /// <param name="uid"></param>
  107. /// <param name="zoneid"></param>
  108. public static void redisToSql(string uid, int zoneid)
  109. {
  110. Console.WriteLine("以玩家为单位数据传输开始..........:");
  111. TaskcompleteTsrecord_RedisToSql(uid, zoneid);
  112. }
  113. const string Userbaseparams_TableName = "tab_userbaseparams";
  114. const string TaskcompleteTsrecord_TableName = "tab_taskcompleteTsrecord";
  115. const string Taskprogressrecord_TableName = "tab_taskprogressrecord";
  116. /// <summary>
  117. /// 界面内数值变化数据传输
  118. /// </summary>
  119. /// <param name="uid"></param>
  120. /// <param name="zoneid"></param>
  121. public static void Userbaseparams_RedisToSql(int zoneid)
  122. {
  123. Console.WriteLine("玩家基础数值变化方法开始.........");
  124. var mem = Redis.Ins.GetDatabase(0);
  125. string key = MemKey_Statistics.UserBaseParams(zoneid);
  126. if (mem.KeyExists(key))
  127. {
  128. long length = mem.ListLength(key);
  129. var ctxList = mem.ListRange(key, 0, length);
  130. int num = 0;
  131. foreach (var item in ctxList)
  132. {
  133. num += 1;
  134. JObject dic = JObject.Parse(item.ToString());
  135. int uid = int.Parse(dic["uid"].ToString());
  136. int cmd = int.Parse(dic["cmd"].ToString());
  137. int type = int.Parse(dic["type"].ToString());
  138. string curVal = dic["curVal"].ToString();
  139. string changeVal = dic["changeVal"].ToString();
  140. string endVal = dic["endVal"].ToString();
  141. string desc = dic["desc"].ToString();
  142. //Console.WriteLine("desc..........:"+ desc);
  143. string ts = dic["ts"].ToString();
  144. //continue;
  145. var sql = $" Insert Into {Userbaseparams_TableName} (`uid`, `zoneid`, `cmd`, `type`, `curVal`, `endVal`, `changeVal`, `desc`, `ts`) " +
  146. $"values('{uid}',{zoneid},{cmd},{type},'{curVal}','{endVal}','{changeVal}','{desc}','{ts}')";
  147. var n = MysqlUtil.Ins.ExecuteSqlNonQuery(sql);
  148. //Debug.Assert(n > 0, $"{sql} 执行失败!");
  149. if (num >= length)
  150. {
  151. Console.WriteLine("总共执行条数:" + num);
  152. mem.KeyDelete(key);
  153. break;
  154. }
  155. }
  156. }
  157. }
  158. /// <summary>
  159. /// 个人数据 包括以下两点:
  160. ///1.通过玩家ID查询指定玩家的任务进度,包括任务ID和任务STEP ID----【直接从玩家数据里取数据展示】
  161. ///2.可查询玩家每日任务进度变化---【单一记录玩家自己的任务信息就可以了,每次做任务时候要记录时间,展示的时候需要以天为单位展示任务进度】
  162. /// </summary>
  163. /// <param name="uid"></param>
  164. /// <param name="zoneid"></param>
  165. public static void TaskcompleteTsrecord_RedisToSql(string uid, int zoneid)
  166. {
  167. var mem = Redis.Ins.GetDatabase(0);
  168. string key = MemKey_Statistics.SelfTaskDataCollect(uid, zoneid);
  169. if (mem.KeyExists(key))
  170. {
  171. Console.WriteLine("玩家任务完成时间记录方法开始.........");
  172. long length = mem.ListLength(key);
  173. var ctxList = mem.ListRange(key, 0, length);
  174. int num = 0;
  175. foreach (var item in ctxList)
  176. {
  177. num += 1;
  178. string[] sList = item.ToString().Split('-');
  179. string taskId = sList[0];
  180. string time = sList[1];
  181. var sql = $" Insert Into {TaskcompleteTsrecord_TableName} (`uid`, `zoneid`, `taskId`, `time`) " +
  182. $"values('{uid}',{zoneid},'{taskId}','{time}')";
  183. var n = MysqlUtil.Ins.ExecuteSqlNonQuery(sql);
  184. //Debug.Assert(n > 0, $"{sql} 执行失败!");
  185. if (num >= length)
  186. {
  187. Console.WriteLine("总共执行条数:" + num);
  188. mem.KeyDelete(key);
  189. break;
  190. }
  191. }
  192. }
  193. }
  194. /// <summary>
  195. /// 所有玩家最新主线任务id记录
  196. /// </summary>
  197. /// <param name="uid"></param>
  198. /// <param name="zoneid"></param>
  199. public static void Taskprogressrecord_RedisToSql(int zoneid)
  200. {
  201. Console.WriteLine("玩家任务进度方式开始......");
  202. var mem = Redis.Ins.GetDatabase(0);
  203. string key = MemKey_Statistics.TaskDataCollect(zoneid);
  204. if (mem.KeyExists(key))
  205. {
  206. HashEntry[] ctxList = mem.HashGetAll(key);
  207. int length = ctxList.Length;
  208. int num = 0;
  209. foreach (var item in ctxList)
  210. {
  211. num += 1;
  212. string[] sList = item.ToString().Split(':');
  213. string uid = sList[0];
  214. string taskId = sList[1];
  215. var sql = $" Insert Into {Taskprogressrecord_TableName} (`uid`, `zoneid`, `taskId`) " +
  216. $"values('{uid}',{zoneid},'{taskId}')";
  217. var n = MysqlUtil.Ins.ExecuteSqlNonQuery(sql);
  218. //Debug.Assert(n > 0, $"{sql} 执行失败!");
  219. if (num >= length)
  220. {
  221. Console.WriteLine("总共执行条数:" + num);
  222. mem.KeyDelete(key);
  223. break;
  224. }
  225. }
  226. }
  227. else
  228. {
  229. Console.WriteLine("玩家任务进度redis-key不存在所以不在数据传输处理");
  230. }
  231. }
  232. }
  233. }