采用Json方式集成调用批量查询数据【分享】

批量查询用户表数据
最主要的是构造CreateQuery的Model模板，设置需要返回的字段数据。
先上Cloud中 用户表，按字段【用户名】批量查找查询结果，查询结果最终也是返回Json数据，显示如下： 

示例代码：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

namespace ConsoleApplication.Json
{
    class Program
    {
        static void Main(string[] args)
        {
            if (Login())
            {
                string sJsonCreate = "{\"Model\":{\"FormId\":\"SEC_User\",\"HeadEntity\":{\"EntityKey\":\"SEC_User\",\"Fields\":[{\"FieldKey\":\"FName\"}]}}}";
                var QueryId = CreateQuery(sJsonCreate);

                string sJsonExecute = "{\"QueryId\":\"" + QueryId + "\",\"FilterString\":\"\",\"Recorders\":{\"From\":0,\"To\":1000},\"OrderString\":\"\"}";
                ExecuteQuery(sJsonExecute);

                string sJsonDispose = "{\"QueryId\":\"" + QueryId + "\"}";
                DisposeQuery(sJsonDispose);
            }
        }

        /// <summary>
        /// 登陆
        /// </summary>
        static bool Login()
        {
            HttpClient httpClient = new HttpClient();
            httpClient.Url = "http://localhost/K3CloudServiceInterface/json/syncreply/Auth";
            httpClient.Content = "{\"provider\":\"credentials\",\"UserName\":\"Administrator\",\"Password\":\"888888\",\"PasswordIsEncrypted\":false,\"RememberMe\":false}";

            var result = httpClient.SysncRequest();

            var bResult = JObject.Parse(result)["Result"]["ResponseStatus"]["IsSuccess"].Value<bool>();
            return bResult;
        }

        static string CreateQuery(string content)
        {
            HttpClient httpClient = new HttpClient();
            httpClient.Url = string.Concat("http://localhost/K3CloudServiceInterface/json/syncreply/CreateQuery");
            httpClient.Content = content;

            var result = httpClient.SysncRequest();

            var bResult = JObject.Parse(result)["Result"]["QueryId"].Value<string>();
            return bResult;
        }

        static void ExecuteQuery(string content)
        {
            HttpClient httpClient = new HttpClient();
            httpClient.Url = string.Concat("http://localhost/K3CloudServiceInterface/json/syncreply/ExecuteQuery");
            httpClient.Content = content;

            var result = httpClient.SysncRequest();
        }

        static void DisposeQuery(string content)
        {
            HttpClient httpClient = new HttpClient();
            httpClient.Url = string.Concat("http://localhost/K3CloudServiceInterface/json/syncreply/DisposeQuery");
            httpClient.Content = content;

            var result = httpClient.SysncRequest();
        }

    }
}


封装Http请求代码：


using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;


namespace ConsoleApplication.Json
{
    /// <summary>
    /// HTTP访问
    /// </summary>
    public class HttpClient
    {
        /// <summary>
        /// URL
        /// </summary>
        public string Url { get; set; }
        /// <summary>
        /// Content
        /// </summary>
        public string Content { get; set; }
        /// <summary>
        /// Cookie
        /// </summary>
        static CookieContainer Cookie = new CookieContainer();


        /// <summary>
        /// HTTP访问
        /// </summary>
        public string SysncRequest()
        {
            HttpWebRequest httpWebRequest = WebRequest.Create(Url) as HttpWebRequest;
            httpWebRequest.Method = "POST";
            httpWebRequest.CookieContainer = Cookie;
            httpWebRequest.ContentType = "Json";


            using (Stream requestStream = httpWebRequest.GetRequestStream())
            {
                byte[] postData = UnicodeEncoding.UTF8.GetBytes(Content);


                requestStream.Write(postData, 0, postData.Length);
                requestStream.Flush();
            }
            using (var repStream = httpWebRequest.GetResponse().GetResponseStream())
            {
                using (var reader = new StreamReader(repStream))
                {
                    string responseText = reader.ReadToEnd();
                    JObject jo = JsonConvert.DeserializeObject(responseText) as JObject;
                    return jo.ToString();
                }
            }
        }


    }


}