数据传输

CSserver/DataTransfer/Program.cs

@@ -31,7 +31,7 @@ namespace DataTransfer
                 try
                 {                               
                     int hour = DateTime.Now.Hour;            
-                    if (hour == 11 && mask == 0)//正式的是晚上2点进行数据传输
+                    if (hour == 17 && mask == 0)//正式的是晚上2点进行数据传输
                     {
                         Console.WriteLine("数据传输的时间到了开始执行程序.......");
                         //进行数据传输
@@ -39,7 +39,7 @@ namespace DataTransfer
                         dataTransfer();                      
                     }
 
-                    if (hour != 11 && mask != 0)
+                    if (hour != 17 && mask != 0)
                     {
                         mask = 0;
                     }
@@ -67,9 +67,10 @@ namespace DataTransfer
             {              
                 string[] list = mem.HashKeys(MemKey_Statistics.GamerunLoginUser(zoneid, day)).ToStringArray();                          
                 foreach (string k in list)
-                {                 
+                {
+                    Console.WriteLine("uid：" + k);
                     redisToSql(k,zoneid);
-                }          
+                }
             }
         }
        
@@ -121,7 +122,7 @@ namespace DataTransfer
                     //continue;
 
                     var sql = $" Insert Into {Userbaseparams_TableName} (`uid`, `zoneid`, `cmd`, `type`, `curVal`, `endVal`, `changeVal`, `desc`, `ts`) " +
-                $"values('{uid}',{zoneid},{cmd},{type},'{curVal}','{changeVal}','{endVal}','{desc}','{ts}')";
+                $"values('{uid}',{zoneid},{cmd},{type},'{curVal}','{endVal}','{changeVal}','{desc}','{ts}')";
 
                     var n = MysqlUtil.Ins.ExecuteSqlNonQuery(sql);
                     //Debug.Assert(n > 0, $"{sql} 执行失败!");
@@ -129,6 +130,7 @@ namespace DataTransfer
                     if (num >= length)
                     {
                         Console.WriteLine("总共执行条数：" + num);
+                        mem.KeyDelete(key);
                         break;
                     }
 
@@ -157,14 +159,10 @@ namespace DataTransfer
                 foreach (var item in ctxList)
                 {
                     num += 1;
-
-                    JObject dic = JObject.Parse(item.ToString());
-                    
-                    string taskId = dic["taskId"].ToString();               
-                    //Console.WriteLine("desc..........："+ desc);
-                    string time = dic["time"].ToString();
-
-                    //continue;
+            
+                    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}')";
@@ -175,6 +173,7 @@ namespace DataTransfer
                     if (num >= length)
                     {
                         Console.WriteLine("总共执行条数：" + num);
+                        mem.KeyDelete(key);
                         break;
                     }