马蜂窝API调用

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

namespace SFAPITest.Services
{
    public class MafengwoHelper
    {
        //  马蜂窝API调用：
        //1. 加密请求数据(data)
        //2. 拼接请求基本字段内容
        //3. 生成签名
        //4. 发送HTTP请求
        //5. 得到HTTP响应
        //6. 解密数据
        //7. 解析JSON结果
        public static string clientId = "";
        public static string clientSecret = "";
        public static string key = "";

        /// <summary>
        /// 马蜂窝api请求封装
        /// </summary>
        /// <param name="actionName">API接口的动作名称</param>
        /// <param name="requesParams">业务接口请求数据</param>
        /// <returns></returns>
        private static string MFWApiRequest(string actionName, object requesParams)
        {
            //商家ID
            int partnerId = int.Parse(clientId);
            //API接口的动作名称
            string action = actionName;
            //请求发起的时间戳
            string timestamp = Convert.ToInt32((DateTime.Now - new DateTime(1970, 1, 1, 0, 0, 0)).TotalSeconds).ToString();
            //随机串
            string nonce = GetRandomStr();
            //业务请求数据
            object obj = requesParams;
            string reqData = Newtonsoft.Json.JsonConvert.SerializeObject(obj);
            //加密请求数据data
            string data = encrypt(reqData, key);

            //根据基础参数生成的数据签名
            //对 partnerId、action、timestamp、key、nonce 和 data 字段进行合并
            string paramsValueStr = partnerId + action + timestamp + key + nonce + data;
            string sign = SignRequest(paramsValueStr);
            //OAuth token
            string access_token = GetAccessToekn(clientId, clientSecret, "client_credentials");
            //加密后的字符串有可能会包含“+”或者“=”字符，Java 或 C# 在某些处理字符串的步骤上会做特殊的处理【对 data 加密后的数据进行 urlencode】
            //data 字段只有在请求的最后一步之前再做 urlencode，请不要在生成签名之前做，这样会导致加密的数据无法被反解成正常的数据
            data = HttpUtility.UrlEncode(data);
            //http请求
            var str = string.Format("partnerId={0}&action={1}&timestamp={2}&nonce={3}&data={4}&sign={5}&access_token={6}", partnerId, action, timestamp, nonce, data, sign, access_token);
            var responseData = Post("https://openapi.mafengwo.cn/deals/rest", str);
            var response = decrypt(responseData, key);
            return DecodeString(response);
        }

        /// <summary>
        /// 生成签名
        /// 在数据已经加密完成之后，需要对 partnerId、action、timestamp、key、nonce 和 data 字段进行合并，并对汇总后的字符串进行 MD5 加密。
        /// 加密后的结果为本次请求的签名。
        ///  md5 加密后的英文字符均应为小写字符，否则验证会不通过
        ///  MD5(partnerId ＋ action ＋ timestamp ＋ key + nonce + data)
        /// </summary>
        /// <returns></returns>
        private static string SignRequest(string str)
        {
            MD5CryptoServiceProvider md5Hasher = new MD5CryptoServiceProvider();
            byte[] hashedDataBytes;
            hashedDataBytes = md5Hasher.ComputeHash(Encoding.GetEncoding("gb2312").GetBytes(str));
            //hashedDataBytes = md5Hasher.ComputeHash(Encoding.GetEncoding("utf-8").GetBytes(str));
            StringBuilder tmp = new StringBuilder();
            foreach (byte i in hashedDataBytes)
            {
                tmp.Append(i.ToString("x2"));
            }
            return tmp.ToString().ToLower();
        }

        /// <summary>
        /// 获取授权令牌   (默认有效期为120分钟（7200秒）)
        /// </summary>
        /// <param name="client_id">商户ID</param>
        /// <param name="client_secret">商户Secret</param>
        /// <param name="grant_type">固定值client_credentials</param>
        /// <returns>token</returns>
        private static string GetAccessToekn(string client_id, string client_secret, string grant_type = "client_credentials")
        {
            string url = "https://openapi.mafengwo.cn/oauth2/token?client_id={0}&client_secret={1}&grant_type={2}";
            string reqUrl = string.Format(url, client_id, client_secret, grant_type);
            var resStr = Get(reqUrl);  //"{\"access_token\":\"aab19fa3942ed9456945fc23b88a6baa\",\"token_type\":\"GET\",\"expires_in\":7200,\"scope\":null}"
            var str = "";
            JObject resultObj = JObject.Parse(resStr);
            if (!string.IsNullOrEmpty(resultObj["expires_in"].ToString()) && int.Parse(resultObj["expires_in"].ToString()) > 0)
            {
                str = resultObj["access_token"].ToString();
            }
            return str;
        }

        /// <summary>
        /// 生成随机串
        /// 随机串的生成规则为：
        /// 1. 长度为16为字符串
        /// 2. 字符串仅能包括 大小写英文字符、数字
        /// </summary>
        /// <param name="maxLength">随机串长度</param>
        /// <returns>生成的随机串</returns>
        private static string GetRandomStr(int maxLength = 16)
        {
            string str = "";
            string strPool = "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789abcdefghijklmnopqrstuvwxyz";
            Random rand = new Random();
            for (var i = 0; i < maxLength; i++)
            {
                str += strPool[rand.Next(0, 61)];
            }
            return str;
        }

        public static string Post(string url, string postData)
        {
            //请求
            WebRequest request = (HttpWebRequest)WebRequest.Create(url);
            request.Method = "POST";
            request.ContentType = "application/x-www-form-urlencoded;charset=utf-8";
            //request.ContentType = "multipart/form-data;charset=utf-8";
            request.ContentLength = Encoding.UTF8.GetByteCount(postData);
            byte[] postByte = Encoding.UTF8.GetBytes(postData);
            Stream reqStream = request.GetRequestStream();
            reqStream.Write(postByte, 0, postByte.Length);
            reqStream.Close();

            //响应
            HttpWebResponse response = (HttpWebResponse)request.GetResponse();
            Stream myResponseStream = response.GetResponseStream();
            StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.GetEncoding("utf-8"));
            string retString = myStreamReader.ReadToEnd();
            myStreamReader.Close();
            myResponseStream.Close();
            return retString;
        }

        public static string Get(string url)
        {
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
            request.Method = "GET";
            request.ContentType = "text/html;charset=UTF-8";
            HttpWebResponse response = (HttpWebResponse)request.GetResponse();
            Stream myResponseStream = response.GetResponseStream();
            StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.UTF8);
            string retString = myStreamReader.ReadToEnd();
            myStreamReader.Close();
            myResponseStream.Close();
            return retString;
        }

        /// <summary>
        /// unicode转中文
        /// </summary>
        /// <param name="unicode"></param>
        /// <returns></returns>
        public static string DecodeString(string unicode)
        {
            if (string.IsNullOrEmpty(unicode))
            {
                return string.Empty;
            }
            return System.Text.RegularExpressions.Regex.Unescape(unicode);
        }

        #region 加密解密
        static int BLOCK_SIZE = 32;
        /**
         * 获得对明文进行补位填充的字节.
         *
         * @param count 需要进行填充补位操作的明文字节个数
         * @return 补齐用的字节数组
         */
        public static byte[] fillByte(int count)
        {
            // 计算需要填充的位数
            int amountToPad = BLOCK_SIZE - (count % BLOCK_SIZE);
            if (amountToPad == 0)
            {
                amountToPad = BLOCK_SIZE;
            }
            // 获得补位所用的字符
            char padChr = chr(amountToPad);
            String tmp = string.Empty;
            for (int index = 0; index < amountToPad; index++)
            {
                tmp += padChr;
            }
            return Encoding.UTF8.GetBytes(tmp);
        }


        /**
         * 删除解密后明文的补位字符
         *
         * @param decrypted 解密后的明文
         * @return 删除补位字符后的明文
         */
        public static byte[] removeByte(byte[] decrypted)
        {
            int pad = (int)decrypted[decrypted.Length - 1];
            if (pad < 1 || pad > 32)
            {
                pad = 0;
            }
            byte[] res = new byte[decrypted.Length - pad];
            Array.Copy(decrypted, 0, res, 0, decrypted.Length - pad);
            return res;
        }

        /**
         * 将数字转化成ASCII码对应的字符，用于对明文进行补码
         *
         * @param a 需要转化的数字
         * @return 转化得到的字符
         */
        static char chr(int a)
        {
            byte target = (byte)(a & 0xFF);
            return (char)target;
        }

        /// <summary>
        /// 解密
        /// </summary>
        /// <param name="text"></param>
        /// <param name="sKey"></param>
        /// <returns></returns>
        public static string decrypt(string text, string sKey)
        {
            byte[] Key = Encoding.UTF8.GetBytes(sKey);
            byte[] Iv = new byte[16];
            Array.Copy(Key, Iv, 16);
            byte[] Text = Encoding.UTF8.GetBytes(text);
            return AES_decrypt(text, Iv, Key);
        }

        private static string AES_decrypt(String Input, byte[] Iv, byte[] Key)
        {
            RijndaelManaged aes = new RijndaelManaged();
            aes.KeySize = 256;
            aes.BlockSize = 128;
            aes.Mode = CipherMode.CBC;
            aes.Padding = PaddingMode.None;
            //aes.Padding = PaddingMode.PKCS7;
            aes.Key = Key;
            aes.IV = Iv;
            var decrypt = aes.CreateDecryptor(aes.Key, aes.IV);
            byte[] xBuff = null;
            using (var ms = new MemoryStream())
            {
                using (var cs = new CryptoStream(ms, decrypt, CryptoStreamMode.Write))
                {
                    byte[] xXml = Convert.FromBase64String(Input);
                    byte[] msg = new byte[xXml.Length + 32 - xXml.Length % 32];
                    Array.Copy(xXml, msg, xXml.Length);
                    cs.Write(xXml, 0, xXml.Length);
                }
                xBuff = removeByte(ms.ToArray());
            }
            return System.Text.Encoding.Default.GetString(xBuff);
        }


        /// <summary>
        /// 加密
        /// </summary>
        /// <param name="Input"></param>
        /// <param name="Iv"></param>
        /// <param name="Key"></param>
        /// <returns></returns>
        public static string encrypt(string text, string sKey)
        {
            byte[] Key = Encoding.UTF8.GetBytes(sKey);
            byte[] Iv = new byte[16];
            Array.Copy(Key, Iv, 16);
            byte[] Text = Encoding.UTF8.GetBytes(text);
            return AES_encrypt(Text, Iv, Key);
        }

        private static String AES_encrypt(byte[] Input, byte[] Iv, byte[] Key)
        {
            var aes = new System.Security.Cryptography.RijndaelManaged();
            //秘钥的大小，以位为单位
            aes.KeySize = 256;
            //支持的块大小
            aes.BlockSize = 128;
            //填充模式
            //aes.Padding = PaddingMode.PKCS7;
            aes.Padding = System.Security.Cryptography.PaddingMode.None;
            aes.Mode = System.Security.Cryptography.CipherMode.CBC;
            aes.Key = Key;
            aes.IV = Iv;
            var encrypt = aes.CreateEncryptor(aes.Key, aes.IV);
            byte[] xBuff = null;

            #region 自己进行PKCS7补位，用系统自己带的不行
            byte[] msg = new byte[Input.Length + 32 - Input.Length % 32];
            Array.Copy(Input, msg, Input.Length);
            byte[] pad = fillByte(Input.Length);
            Array.Copy(pad, 0, msg, Input.Length, pad.Length);
            #endregion

            #region 注释的也是一种方法，效果一样
            //ICryptoTransform transform = aes.CreateEncryptor();
            //byte[] xBuff = transform.TransformFinalBlock(msg, 0, msg.Length);
            #endregion

            using (var ms = new MemoryStream())
            {
                using (var cs = new System.Security.Cryptography.CryptoStream(ms, encrypt, System.Security.Cryptography.CryptoStreamMode.Write))
                {
                    cs.Write(msg, 0, msg.Length);
                }
                xBuff = ms.ToArray();
            }

            String Output = Convert.ToBase64String(xBuff);
            return Output;
        }

        #endregion

        #region 接口调用
        /// <summary>
        /// 获取马蜂窝订单详情
        /// </summary>
        /// <param name="orderId"></param>
        /// <returns></returns>
        public static MFWResponse<MFWOrderDetail> GetMFWOrderDetail(string orderId)
        {
            //API接口的动作名称
            string action = "sales.order.detail.get";
            //业务请求数据
            object obj = new
            {
                order_id = orderId
            };
            var response = MFWApiRequest(action, obj);
            var result = Newtonsoft.Json.JsonConvert.DeserializeObject<MFWResponse<MFWOrderDetail>>(response);
            return result;
        }


        /// <summary>
        /// 获取订单备注
        /// </summary>
        /// <param name="orderId"></param>
        /// <returns></returns>
        public static List<MFWOrderMemo> GetMFWOrderMemo(string orderId)
        {
            string action = "sales.order.memo.get";
            object obj = new
            {
                order_id = orderId
            };
            var response = MFWApiRequest(action, obj);
            var result = Newtonsoft.Json.JsonConvert.DeserializeObject<MFWResponse<List<MFWOrderMemo>>>(response);
            return result.data;
        }

        public static string GetMFWOrderMemoStr(string orderId)
        {
            var memoList = GetMFWOrderMemo(orderId);
            var memo = string.Join("|", memoList.Select(x => x.content));
            return memo;
        }

        /// <summary>
        /// 获取出行人信息
        /// </summary>
        /// <returns></returns>
        public static MFWTravelInfo GetTraveler(string orderId)
        {
            string action = "sales.order.traveler.get";
            object obj = new
            {
                order_id = orderId
            };
            var response = MFWApiRequest(action, obj);
            var result = Newtonsoft.Json.JsonConvert.DeserializeObject<MFWResponse<MFWTravelInfo>>(response);
            return result.data;
        }

        /// <summary>
        /// 获取补款单列表
        /// </summary>
        /// <param name="orderId"></param>
        /// <returns></returns>
        public static MFWReplenishResponse GetReplenishList(string orderId)
        {
            string action = "sales.replenish.list.get";
            object obj = new
            {
                order_id = orderId
            };
            var response = MFWApiRequest(action, obj);
            var result = Newtonsoft.Json.JsonConvert.DeserializeObject<MFWReplenishResponse>(response);
            return result;
        }


        #endregion
    }

    public class MFWResponse<T>
    {
        public int errno { get; set; }
        public string message { get; set; }
        public T data { get; set; }
    }

    #region 订单详情实体
    /// <summary>
    /// 订单详情
    /// </summary>
    public class MFWOrderDetail
    {
        //旅行商城业务订单号
        public string orderId { get; set; }
        public Status status { get; set; }
        //旅行出行时间
        public string goDate { get; set; }
        //旅行结束日期
        public string endDate { get; set; }
        //订单支付时间
        public string paytime { get; set; }
        //订单创建时间
        public string ctime { get; set; }
        //预订人信息
        public BookingPeople bookingPeople { get; set; }
        //马蜂窝产品id，产品唯一标识
        public string salesId { get; set; }
        //产品名称
        public string salesName { get; set; }
        //商家设置的产品外部编码
        public string otaSalesName { get; set; }
        //订单关联产品品类
        public int salesType { get; set; }
        //目的地
        public string mdd { get; set; }
        //订单关联产品出发地
        public string from { get; set; }
        //马蜂窝SKU ID，SKU唯一标识
        public string skuId { get; set; }
        //商家设置的SKU外部编码
        public string otaSkuId { get; set; }
        //SKU名称
        public string skuName { get; set; }
        //订单原始金额
        public decimal totalPrice { get; set; }
        //用户实际支付金额
        public decimal paymentFee { get; set; }
        //订单购买项详细信息
        public List<Items> items { get; set; }
        //订单优惠信息
        public PromotionDetail promotionDetail { get; set; }
        //库存信息
        public List<Skus> skus { get; set; }
    }

    /// <summary>
    /// 库存信息
    /// </summary>
    public class Skus
    {
        //库存名称
        public string stockName { get; set; }
        //商家设置的SKU外部编码
        public string otaSkuId { get; set; }
        //库存ID
        public int skuId { get; set; }
    }

    /// <summary>
    /// 订单优惠信息
    /// </summary>
    public class PromotionDetail
    {
        //马蜂窝补贴金额
        public decimal reduce_mfw { get; set; }
        //商家补贴金额
        public decimal reduce_ota { get; set; }
    }

    /// <summary>
    /// 订单购买项详情信息
    /// </summary>
    public class Items
    {
        //剩余可退金额
        public decimal remain_payment_fee { get; set; }
        //剩余可退数量
        public int remain_num { get; set; }
        //库存ID
        public int skuId { get; set; }
        //费用项
        public int price_type { get; set; }
        //本项总金额
        public decimal total_price { get; set; }
        //本项应支付金额
        public decimal payment_fee { get; set; }
        //购买项描述
        public string name { get; set; }
        //本项单价金额
        public decimal price { get; set; }
        //本项购买个数
        public int num { get; set; }
        //购买项ID
        public int id { get; set; }
    }

    /// <summary>
    /// 预订人信息
    /// </summary>
    public class BookingPeople
    {
        //预定人马蜂窝UID
        public int uid { get; set; }
        public string name { get; set; }
        public string email { get; set; }
        public string phone { get; set; }
        public string phone_area { get; set; }
        public string wechat { get; set; }
        public string remark { get; set; }
    }

    /// <summary>
    /// 状态信息
    /// </summary>
    public class Status
    {
        //订单状态
        public int orderStatus { get; set; }
        //全退标识
        public int allRefundFlag { get; set; }
        //退款状态
        public int refundStatus { get; set; }
    }

    /// <summary>
    /// 订单备注实体
    /// </summary>
    public class MFWOrderMemo
    {
        public int id { get; set; }
        public string order_id { get; set; }
        public int admin_uid { get; set; }
        public string content { get; set; }
        public DateTime dateTime { get; set; }
    }

    #region 出行人信息实体
    public class MFWTravelInfo
    {
        public string order_id { get; set; }
        public MFWTravelPeople travel_people { get; set; }
    }

    public class MFWTravelPeople
    {
        public MFWTraveler[] traveler { get; set; }
        public MFWTrip trip { get; set; }
        public MFWTsAddress ts_address { get; set; }
        public MFWAddress address { get; set; }
    }

    /// <summary>
    /// 出行人信息
    /// </summary>
    public class MFWTraveler
    {
        public string name { get; set; }
        public string id_type { get; set; }
        public string birthday { get; set; }
        public string gender { get; set; }
        public string nationality { get; set; }
        public string height { get; set; }
        public string weight { get; set; }
        public string shoe_size { get; set; }
        public string left_eye_sight { get; set; }
        public string right_eye_sight { get; set; }
        public string date_of_expiry { get; set; }
        public string cellphone { get; set; }
        public string family_name { get; set; }
        public string mainland_phone { get; set; }
        public string traveler_id { get; set; }
        public string laissez_passer_tw { get; set; }
        public string laissez_passer { get; set; }
        public string passport { get; set; }
        public string id_card { get; set; }
        public string first_name { get; set; }
    }

    public class MFWTrip
    {
        public string pick_up_time { get; set; }
        public string pick_up_place { get; set; }
        public string send_to { get; set; }
        public string pick_up_place_en { get; set; }
        public string send_to_en { get; set; }
        public string hotel_name_pick_up { get; set; }
        public string hotel_address_pick_up { get; set; }
        public string hotel_name_en_pick_up { get; set; }
        public string hotel_address_en_pick_up { get; set; }
        public string hotel_name_send_to { get; set; }
        public string hotel_address_send_to { get; set; }
        public string hotel_name_en_send_to { get; set; }
        public string hotel_address_en_send_to { get; set; }
        public string hotel_name_over_night { get; set; }
        public string flight_no_arrival { get; set; }
        public string flight_time_arrival { get; set; }
        public string flight_no_departure { get; set; }
        public string flight_time_departure { get; set; }
        public string luggage { get; set; }
        public string hotel_name_en { get; set; }
        public string hotel_address_en { get; set; }
        public string hotel_phone { get; set; }
        public string hotel_telephone { get; set; }
        public string using_time { get; set; }
        public string using_place { get; set; }
        public string flight_number { get; set; }
        public string flight_time { get; set; }
        public string place { get; set; }
        public string return_hotel { get; set; }
        public string hotel_adress { get; set; }
        public string return_hotel_phone { get; set; }
        public string pick_and_send_hotel_phone { get; set; }
        public string schedule { get; set; }
        public string back_hotel { get; set; }
        public string back_adress { get; set; }
        public string back_phone { get; set; }
        public string hotel_name { get; set; }
        public string hotel_address { get; set; }
        public string hotel_phone_number { get; set; }
        public string check_in_date { get; set; }
        public string check_out_date { get; set; }
        public string return_flight_number { get; set; }
        public string return_flight_time { get; set; }
        public string arrival_date { get; set; }
        public string departure_date { get; set; }
        public string departure_hotel_name { get; set; }
        public string departure_hotel_adress { get; set; }
        public string departure_hotel_number { get; set; }
        public string back_date { get; set; }
        public string over_night_hotel_address { get; set; }
        public string get_device_adress { get; set; }
        public string departure_hotel_name_cn { get; set; }
        public string time { get; set; }
        public string number { get; set; }
        public string phone { get; set; }
        public string wechat { get; set; }
        public string estimated_travel_date { get; set; }
        public string train_number { get; set; }
        public string train_station { get; set; }
        public string departure_time { get; set; }
        public string departure_frequency { get; set; }
        public string departure_hotel_area { get; set; }
        public string meal_time { get; set; }
        //出行人数
        public string tourists_number { get; set; }
    }

    public class MFWTsAddress
    {
        public string pick_up_address { get; set; }
        public string return_address { get; set; }
    }

    public class MFWAddress
    {
        public string adress { get; set; }
        public string receiver_name { get; set; }
        public string receiver_phone { get; set; }
    }
    #endregion

    #region 补款单
    public class MFWReplenishResponse
    {
        public int total { get; set; }
        public MFWReplenish[] list { get; set; }
    }

    public class MFWReplenish
    {
        public string order_id { get; set; }
        //补款单号
        public string replenish_id { get; set; }
        //补款单状态
        public int status { get; set; }
        //补款单创建时间
        public string ctime { get; set; }
        //创建补款单原因
        public int reason { get; set; }
        // 补款单具体金额
        public decimal fee { get; set; }
        // 补款单备注
        public string remark { get; set; }
    }

    /// <summary>
    /// 补款单状态
    /// </summary>
    public enum ReplenishStatus
    {
        待支付 = 0,
        已支付 = 1,
        申请退款中 = 2,
        部分退款成功 = 3,
        全部退款成功 = 4,
        已关闭 = 5
    }
    #endregion

    #endregion

}