优化持久化业务逻辑

OTWebSocket.API/Services/ApiService.cs

@@ -159,7 +159,7 @@ namespace OTWebSocket.API.Services
                 HttpResponseMessage resp = await _httpClient.SendAsync(req);
                 string content = await resp.Content.ReadAsStringAsync();
                 _logger.Debug($"[更新MongoDB订单信息] API返回:{content}");
-                return true;
+                return resp.IsSuccessStatusCode;
             }
             catch (Exception e)
             {

OTWebSocket.API/Services/OrderTracer.cs

@@ -237,8 +237,11 @@ namespace OTWebSocket.API.Services
                                         await _redisService.ReleaseOrder(order.OrderId);
                                         if (needPersist)
                                         {
-                                            await _apiService.UpdateMongoOrder(cacheOrder);
-                                            _logger.Debug($"[订单同步] 执行缓存数据持久化完毕 {JObject.FromObject(cacheOrder)}");
+                                            if (await _apiService.UpdateMongoOrder(cacheOrder))
+                                                _logger.Debug($"[订单同步] 执行缓存数据持久化完毕 {JObject.FromObject(cacheOrder)}");
+                                            else
+                                                _logger.LogWarning($"[订单同步] 执行缓存数据持久化失败 {JObject.FromObject(cacheOrder)}");
+
                                         }
                                         if (needReport)
                                         {
@@ -265,10 +268,13 @@ namespace OTWebSocket.API.Services
                                     _logger.Debug($"[订单同步] 执行清除备删订单 {JObject.FromObject(cacheOrder)}");
                                     cacheOrder.Comment = "执行订单缓存删除";
                                     await _redisService.SetLiveOrder(cacheOrder, true);//记录最后一次更新的数据,这样可以更新订单更新日志信息
-                                    await _redisService.RemoveLiveOrder(cacheOrder.OrderId);//删除缓冲
-                                    await _redisService.ReleaseOrder(order.OrderId);//释放锁
                                     await _mongoDBService.DeleteOrderRecordAsync(cacheOrder.OrderId);//删除MongoDB待查订单列表
-                                    await _apiService.UpdateMongoOrder(cacheOrder);
+                                    if (await _apiService.UpdateMongoOrder(cacheOrder))
+                                    {
+                                        await _redisService.RemoveLiveOrder(cacheOrder.OrderId);//删除缓冲
+                                    }
+                                    await _redisService.ReleaseOrder(order.OrderId);//释放锁
+
                                     count++;
                                 }
                             }