Program.cs 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127
  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. namespace DataTransfer
  12. {
  13. class Program
  14. {
  15. static void Main(string[] args)
  16. {
  17. Console.WriteLine("言灵数据传输开始........");
  18. Thread t1 = new Thread(transfer);
  19. t1.Start();
  20. }
  21. public static int mask = 0;
  22. public static void transfer()
  23. {
  24. Console.WriteLine("transfer............");
  25. while (true)
  26. {
  27. try
  28. {
  29. int hour = DateTime.Now.Hour;
  30. if (hour == 11 && mask == 0)//正式的是晚上2点进行数据传输
  31. {
  32. Console.WriteLine("数据传输的时间到了开始执行程序.......");
  33. //进行数据传输
  34. mask = 1;
  35. dataTransfer();
  36. }
  37. if (hour != 11 && mask != 0)
  38. {
  39. mask = 0;
  40. }
  41. }
  42. catch (Exception ex)
  43. {
  44. Console.WriteLine(ex.Message); // 提示套接字监听异常
  45. break;
  46. }
  47. }
  48. }
  49. public static void dataTransfer()
  50. {
  51. Console.WriteLine("进入dataTransfer方法..............");
  52. TimeSpan ts = DateTime.Now.ToUniversalTime() - new DateTime(1970,1,1);
  53. float day = MathF.Floor((long)ts.TotalSeconds / 24 / 60 / 60);
  54. Console.WriteLine("当前天是:"+ day);
  55. var mem = Redis.Ins.GetDatabase(0);
  56. int zoneid = 1;//暂时先这样
  57. if (mem.KeyExists(MemKey_Statistics.GamerunLoginUser(zoneid,day)))
  58. {
  59. string[] list = mem.HashKeys(MemKey_Statistics.GamerunLoginUser(zoneid, day)).ToStringArray();
  60. foreach (string k in list)
  61. {
  62. redisToSql(k,zoneid);
  63. }
  64. }
  65. }
  66. const string Userbaseparams_TableName = "tab_userbaseparams";
  67. /// <summary>
  68. /// redis数据传输到mysql中
  69. /// </summary>
  70. /// <param name="uid"></param>
  71. /// <param name="zoneid"></param>
  72. public static void redisToSql(string uid,int zoneid)
  73. {
  74. Console.WriteLine("数据传输开始..........:" );
  75. var mem = Redis.Ins.GetDatabase(0);
  76. string key = MemKey_Statistics.UserBaseParams(uid,zoneid);
  77. if (mem.KeyExists(key))
  78. {
  79. long length = mem.ListLength(key);
  80. var ctxList = mem.ListRange(key, 0, length);
  81. int num = 0;
  82. foreach (var item in ctxList)
  83. {
  84. num += 1;
  85. JObject dic = JObject.Parse(item.ToString());
  86. int cmd = int.Parse(dic["cmd"].ToString());
  87. int type = int.Parse(dic["type"].ToString());
  88. string curVal = dic["curVal"].ToString();
  89. string changeVal = dic["changeVal"].ToString();
  90. string endVal = dic["endVal"].ToString();
  91. string desc = dic["desc"].ToString();
  92. //Console.WriteLine("desc..........:"+ desc);
  93. string ts = dic["ts"].ToString();
  94. //continue;
  95. var sql = $" Insert Into {Userbaseparams_TableName} (`uid`, `zoneid`, `cmd`, `type`, `curVal`, `endVal`, `changeVal`, `desc`, `ts`) " +
  96. $"values('{uid}',{zoneid},{cmd},{type},'{curVal}','{changeVal}','{endVal}','{desc}','{ts}')";
  97. var n = MysqlUtil.Ins.ExecuteSqlNonQuery(sql);
  98. //Debug.Assert(n > 0, $"{sql} 执行失败!");
  99. if (num>=length)
  100. {
  101. Console.WriteLine("总共执行条数:" + num);
  102. break;
  103. }
  104. }
  105. }
  106. }
  107. }
  108. }