Browse Source

统一处理code

zhouj1203@hotmail.com 4 years ago
parent
commit
57d4a7e270
1 changed files with 12 additions and 1 deletions
  1. 12 1
      TEAMModelOS.SDK/DI/AzureCosmos/AzureCosmosExtensions.cs

+ 12 - 1
TEAMModelOS.SDK/DI/AzureCosmos/AzureCosmosExtensions.cs

@@ -449,7 +449,18 @@ namespace TEAMModelOS.SDK.DI
             StringBuilder sql;
             StringBuilder sql;
             sql = SQLHelper.GetSQLSelect(propertys);
             sql = SQLHelper.GetSQLSelect(propertys);
             string pk = typeof(T).Name;
             string pk = typeof(T).Name;
-            AzureCosmosQuery cosmosDbQuery = SQLHelper.GetSQL(jsonElement, sql, pk);
+            Dictionary<string, object> dict = new Dictionary<string, object>();
+            var emobj = jsonElement.EnumerateObject();
+            while (emobj.MoveNext())
+            {
+                dict[emobj.Current.Name] = emobj.Current.Value;
+            }
+            //处理code
+            if (dict.TryGetValue("code", out object _))
+            {
+                dict.Remove("code");
+            }
+            AzureCosmosQuery cosmosDbQuery = SQLHelper.GetSQL(dict, sql, pk);
             QueryRequestOptions queryRequestOptions = GetDefaultQueryRequestOptions(itemsPerPage: GetEffectivePageSize(-1, null));
             QueryRequestOptions queryRequestOptions = GetDefaultQueryRequestOptions(itemsPerPage: GetEffectivePageSize(-1, null));
             return await ResultsFromQueryAndOptions<T>(azureCosmosFactory, cosmosDbQuery, queryRequestOptions);
             return await ResultsFromQueryAndOptions<T>(azureCosmosFactory, cosmosDbQuery, queryRequestOptions);
         }
         }