消息推送和Http請求

 

 

 

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using Genersoft.Platform.Workflow.Spi.Event;
using log;
using System.Net;
using System.Xml;
using System.IO;
using Newtonsoft.Json;
using Genersoft.Platform.Core.DataAccess;

 

namespace TestApplication
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs e)
        {
            //根據GS實例號從數據庫中獲取數據定義爲db
            IGSPDatabase db = Database.GetDatabase(this.textBox1.Text.ToString().Trim());
            string sql = "select '3004' registerCode,srccol01 thirdUserId,'' thirdLoginName, name thirdName,tarcol thirdCode,'' thirdMobile,'' thirdEmail,'' param0,'' param1 from DepVmvaluelist join gspuser on srccol01=code where VMID = 'f608e31a-077d-4f24-b129-e66cded8aaaf' and srccol01!='dongzhe' and srccol01!='wpc' and srccol01!='wpc1'";
          
            try
            {
                //根據sql取出數據庫中的數據，將DataSet轉化爲datetable
                DataTable dt = db.ExecuteDataSet(sql).Tables[0];
                //datetable轉json，Json.NET序列化爲Json格式的數據
                string json = JsonConvert.SerializeObject(dt);
                //將json格式寫好{"userlist":    json        }
                json = "{\"userlist\": " + json + "}";
                //this.textBox3.Text = json;
                SendMessages(json);
            }
            catch (Exception ex)
            {
                this.textBox4.Text += ex.Message;
                return;
            }
     
        }

        #region 消息推送
        private void SendMessages(string json)
        {
            string serverIP = this.textBox2.Text.ToString().Trim();
            string tokenUrl = "http://" + serverIP + "/seeyon/rest/token";
            string token = HttpPost(tokenUrl, "", "{\"userName\":\"rest-mobil\",\"password\":\"qwe123\"}");
            //Json.NET序列化Json數據
            Token jobj = JsonConvert.DeserializeObject<Token>(token);
            string messageUrl = "http://" + serverIP + "/seeyon/rest/thirdpartyUserMapper/binding";
            string message = HttpPost(messageUrl, jobj.id, json);
            textBox3.Text = message;
        }
        #endregion

        #region HTTP請求
        private string HttpPost(string url, string token, string json)
        {
            //解析xml，且爲string型
            XmlDocument xml = new XmlDocument();
            xml.LoadXml("<burlap:call xmlns:burlap=\"http://www.w3.org/2001/XMLSchema-instance\"><method>rmtLogon</method></burlap:call>");
            //初始化新的webRequst
            //1． 建立httpWebRequest對象
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
            //2． 初始化HttpWebRequest對象
            // 將請求字符串轉換爲字節流。
            request.UserAgent = "Mozilla/5.0 (Windows NT 6.2; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/32.0.1700.76 Safari/537.36";           
            request.Method = "POST";
            CookieContainer CookieArray = new CookieContainer();
            request.CookieContainer = CookieArray;
            request.Credentials = CredentialCache.DefaultCredentials;
            request.Timeout = 20000;
            request.ContentType = "application/json;charset=UTF-8";
            request.Accept = "application/json";
            request.ServicePoint.Expect100Continue = true;
            request.KeepAlive = true;
            //轉換輸入參數的編碼類型，獲取bytep[]數組
            byte[] postBytes = Encoding.UTF8.GetBytes(json);
            request.ContentLength = postBytes.Length;

            if (token != "")
                request.Headers.Add("token", token);

            //3． 附加要POST給服務器的數據到HttpWebRequest對象
            //(附加POST數據的過程比較特殊，它並無提供一個屬性給用戶存取，須要寫入HttpWebRequest對象提供的一個stream裏面。)
            //建立一個Stream,賦值是寫入HttpWebRequest對象提供的一個stream裏面
            Stream requestStream = request.GetRequestStream();
            requestStream.Write(postBytes, 0, postBytes.Length);
            requestStream.Close();
            try
            {
                //4． 讀取服務器的返回信息
                HttpWebResponse httpResponse = (HttpWebResponse)request.GetResponse();//得到服務端響應               
                using (Stream responsestream = httpResponse.GetResponseStream())
                {
                    using (StreamReader sr = new StreamReader(responsestream, System.Text.Encoding.Default))
                    {
                        return sr.ReadToEnd();
                    }
                }
            }
            catch (Exception ex)
            {
                textBox4.Text += ex.Message;
                return ex.Message;
            }
        }
        #endregion

        partial class Token
        {
            public string bindingUser { get; set; }
            public string id { get; set; }
        }

  
    }
}