Skip to content

O
OTWebSocketHub
Commit 2fc4bbf5 authored by Maodashu's avatar Maodashu
Browse files
Options

修复持久化逻辑bug

parent 1e289a96
Pipeline #204 canceled with stages
      Hide whitespace changes
      Inline Side-by-side
      Showing with 12 additions and 12 deletions
      OTWebSocket.API/Services/OrderTracer.cs
      View file @ 2fc4bbf5
      ...@@ -237,7 +237,7 @@ namespace OTWebSocket.API.Services ...@@ -237,7 +237,7 @@ namespace OTWebSocket.API.Services
      await _redisService.ReleaseOrder(order.OrderId); await _redisService.ReleaseOrder(order.OrderId);
      if (needPersist) if (needPersist)
      { {
      await _mongoDBService.UpdateOTOrderAsync(cacheOrder); await _apiService.UpdateMongoOrder(cacheOrder);
      _logger.Debug($"[订单同步] 执行缓存数据持久化完毕 {JObject.FromObject(cacheOrder)}"); _logger.Debug($"[订单同步] 执行缓存数据持久化完毕 {JObject.FromObject(cacheOrder)}");
      } }
      if (needReport) if (needReport)
      ...@@ -268,7 +268,7 @@ namespace OTWebSocket.API.Services ...@@ -268,7 +268,7 @@ namespace OTWebSocket.API.Services
      await _redisService.RemoveLiveOrder(cacheOrder.OrderId);//删除缓冲 await _redisService.RemoveLiveOrder(cacheOrder.OrderId);//删除缓冲
      await _redisService.ReleaseOrder(order.OrderId);//释放锁 await _redisService.ReleaseOrder(order.OrderId);//释放锁
      await _mongoDBService.DeleteOrderRecordAsync(cacheOrder.OrderId);//删除MongoDB待查订单列表 await _mongoDBService.DeleteOrderRecordAsync(cacheOrder.OrderId);//删除MongoDB待查订单列表
      await _mongoDBService.UpdateOTOrderAsync(cacheOrder);//持久化更新 await _apiService.UpdateMongoOrder(cacheOrder);
      count++; count++;
      } }
      } }
      ......
      OTWebSocket.API/Services/WebSocketService.cs
      View file @ 2fc4bbf5
      ...@@ -181,16 +181,16 @@ namespace OTWebSocket.API.Services ...@@ -181,16 +181,16 @@ namespace OTWebSocket.API.Services
      _redisService.SetLiveOrder(liveOrder); _redisService.SetLiveOrder(liveOrder);
      _redisService.ReleaseOrder(orderId); _redisService.ReleaseOrder(orderId);
      if (liveOrder.IsFinished()) //if (liveOrder.IsFinished())
      { //{
      _logger.Debug($"持久化更新redis缓存{JObject.FromObject(liveOrder)}"); // _logger.Debug($"持久化更新redis缓存{JObject.FromObject(liveOrder)}");
      liveOrder = _redisService.LockGetOrder(orderId).Result; // liveOrder = _redisService.LockGetOrder(orderId).Result;
      liveOrder.Comment = "持久化"; // liveOrder.Comment = "持久化";
      _redisService.SetLiveOrder(liveOrder); // _redisService.SetLiveOrder(liveOrder);
      _redisService.ReleaseOrder(orderId); // _redisService.ReleaseOrder(orderId);
      _redisService.RemoveLiveOrder(liveOrder.OrderId); // _redisService.RemoveLiveOrder(liveOrder.OrderId);
      _apiService.UpdateMongoOrder(liveOrder); // _apiService.UpdateMongoOrder(liveOrder);
      } //}
      } }
      catch (Exception e) catch (Exception e)
      { {
      ......
      Markdown is supported
      0% or
      You are about to add 0 people to the discussion. Proceed with caution.
      Finish editing this message first!
      Please register or to comment