消息推送和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; }
        }

  
    }
}