kxs-main/AppStart/Helper/SetDepositService.cs

using System;
using System.Collections.Generic;
using Library;
using LitJson;
using System.Linq;
using System.Data;
using System.Threading;
using MySystem.PxcModels;
using System.Security.Cryptography;
using System.Text;

namespace MySystem
{
    public class SetDepositService
    {
        public readonly static SetDepositService Instance = new SetDepositService();
        private SetDepositService()
        { }

        public void Start()
        {
            Thread th = new Thread(dosomething);
            th.IsBackground = true;
            th.Start();
        }

        public void dosomething()
        {
            while (true)
            {
                string data = RedisDbconn.Instance.RPop<string>("SetDepositQueue");
                if (!string.IsNullOrEmpty(data))
                {
                    try
                    {
                        WebCMSEntities db = new WebCMSEntities();
                        JsonData jsonObj = JsonMapper.ToObject(data);
                        string PosIds = jsonObj["PosId"].ToString();
                        int Kind = int.Parse(function.CheckInt(jsonObj["Kind"].ToString()));
                        string OpMan = jsonObj["OpMan"].ToString();
                        if(!string.IsNullOrEmpty(PosIds) && Kind > 0)
                        {
                            List<int> ids = new List<int>();
                            string[] PosIdList = PosIds.Split(',');
                            foreach(string sub in PosIdList)
                            {
                                ids.Add(int.Parse(sub));
                            }
                            List<KqProducts> brands = db.KqProducts.ToList();
                            List<PosMachinesTwo> poslist = db.PosMachinesTwo.Where(m => ids.Contains(m.Id)).ToList();
                            List<int> mids = poslist.Select(m => m.BindMerchantId).ToList();
                            List<PosMerchantInfo> merchantlist = db.PosMerchantInfo.Where(m => mids.Contains(m.Id)).ToList();
                            Dictionary<int, List<PosMachinesTwo>> userPosList = new Dictionary<int, List<PosMachinesTwo>>();
                            foreach(PosMachinesTwo pos in poslist)
                            {
                                PosMerchantInfo merchant = merchantlist.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                                if(merchant != null)
                                {
                                    decimal Fee = Kind == 1 ? 0.63M : 0.6M;
                                    if(pos.BrandId == 1 || pos.BrandId == 3) //金控
                                    {
                                        string content = SetDeposit(merchant.KqMerNo, pos.PosSn, Fee);
                                        JsonData obj = JsonMapper.ToObject(content);
                                        if (obj["code"].ToString() == "0000")
                                        {
                                            content = Decrypt(obj["data"].ToString());
                                            JsonData contentObj = JsonMapper.ToObject(content);
                                            if (contentObj["respCode"].ToString() == "00")
                                            { 
                                                if(Kind == 1)
                                                {
                                                    pos.UpFeeFlag = 1;
                                                    pos.UpFeeMan = OpMan;
                                                    pos.UpFeeDate = DateTime.Now;
                                                }
                                                else if(Kind == 2)
                                                {
                                                    pos.DownFeeFlag = 1;
                                                    pos.DownFeeMan = OpMan;
                                                    pos.DownFeeDate = DateTime.Now;
                                                }
                                                db.SaveChanges();
                                                pos.QueryCount = Kind;
                                                if(userPosList.ContainsKey(pos.BuyUserId))
                                                {
                                                    userPosList[pos.BuyUserId].Add(pos);
                                                }
                                                else
                                                {
                                                    List<PosMachinesTwo> subPos = new List<PosMachinesTwo>();
                                                    subPos.Add(pos);
                                                    userPosList.Add(pos.BuyUserId, subPos);
                                                }
                                            }
                                            else
                                            {
                                                string msg = contentObj["respMsg"].ToString();
                                                pos.SeoDescription = msg;
                                                db.SaveChanges();
                                            }
                                        }
                                        else
                                        {
                                            string msg = obj["message"].ToString();
                                            pos.SeoDescription = msg;
                                            db.SaveChanges();
                                        }
                                    }
                                    else if(pos.BrandId == 6) //立刷
                                    {
                                        string content = SetLiSFee(pos.PosSn, Fee);
                                        JsonData obj = JsonMapper.ToObject(content);
                                        if (obj["ret_code"].ToString() == "00")
                                        { 
                                            if(Kind == 1)
                                            {
                                                pos.UpFeeFlag = 1;
                                                pos.UpFeeMan = OpMan;
                                                pos.UpFeeDate = DateTime.Now;
                                            }
                                            else if(Kind == 2)
                                            {
                                                pos.DownFeeFlag = 1;
                                                pos.DownFeeMan = OpMan;
                                                pos.DownFeeDate = DateTime.Now;
                                            }
                                            db.SaveChanges();
                                            pos.QueryCount = Kind;
                                            if(userPosList.ContainsKey(pos.BuyUserId))
                                            {
                                                userPosList[pos.BuyUserId].Add(pos);
                                            }
                                            else
                                            {
                                                List<PosMachinesTwo> subPos = new List<PosMachinesTwo>();
                                                subPos.Add(pos);
                                                userPosList.Add(pos.BuyUserId, subPos);
                                            }
                                        }
                                        else
                                        {
                                            string msg = obj["ret_msg"].ToString();
                                            pos.SeoDescription = msg;
                                            db.SaveChanges();
                                        }
                                    }
                                }
                            }
                            foreach(int UserId in userPosList.Keys)
                            {
                                string snhtml = "", snhtml2 = "";
                                foreach (var items in userPosList[UserId])
                                {
                                    var mer = merchantlist.FirstOrDefault(m => m.Id == items.BindMerchantId) ?? new PosMerchantInfo();
                                    var brand = brands.FirstOrDefault(m => m.Id == items.BrandId) ?? new KqProducts();
                                    if(items.QueryCount == 1)
                                    {
                                        snhtml += "<div style='margin-bottom: .48rem;'><div class='f12'>商户姓名：" + mer.MerRealName + "</div>";
                                        snhtml += "<div class='f12'>机具品牌：" + brand.Name + "</div>";
                                        snhtml += "<div class='f12'>SN：" + items.PosSn + "</div>";
                                        string DownFeeDate = items.DownFeeDate == null ? "" : items.DownFeeDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
                                    }
                                    else if(items.QueryCount == 2)
                                    {
                                        snhtml2 += "<div style='margin-bottom: .48rem;'><div class='f12'>商户姓名：" + mer.MerRealName + "</div>";
                                        snhtml2 += "<div class='f12'>机具品牌：" + brand.Name + "</div>";
                                        snhtml2 += "<div class='f12'>SN：" + items.PosSn + "</div>";
                                        string DownFeeDate = items.DownFeeDate == null ? "" : items.DownFeeDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
                                        snhtml2 += "<div class='f12'>当前费率：0.6%</div>";
                                        snhtml2 += "<div class='f12'>费率调整时间：" + DownFeeDate + "</div>";
                                    }
                                }
                                if(!string.IsNullOrEmpty(snhtml))
                                {
                                    snhtml = "<div style='margin-bottom: .48rem;'>" + snhtml + "</div>";
                                    RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                                    {
                                        UserId = Convert.ToInt32(UserId), //创客
                                        Title = "商户费率变更通知", //标题
                                        Content = "<div class='f12' style='margin-bottom: .72rem'>您的部分机具已绑定超过180天，刷卡费率已自动变更为0.63%，如需调整费率，请前往我的商户-商户详情中调整费率</div>" + snhtml, //内容
                                        Summary = "您的部分机具已绑定超过180天，刷卡费率已自动变更为0.63%，如需调整费率，请前往我的商户-商户详情中调整费率",
                                        CreateDate = DateTime.Now,
                                    }));
                                }
                                else if(!string.IsNullOrEmpty(snhtml2))
                                {
                                    snhtml2 = "<div style='margin-bottom: .48rem;'>" + snhtml2 + "</div>";
                                    RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                                    {
                                        UserId = Convert.ToInt32(UserId), //创客
                                        Title = "商户费率变更通知", //标题
                                        Content = "<div class='f12' style='margin-bottom: .72rem'>您的商户刷卡交易费率已变更成功！</div>" + snhtml2, //内容
                                        Summary = "您的商户刷卡交易费率已变更成功！",
                                        CreateDate = DateTime.Now,
                                    }));
                                }
                            }
                        }
                        db.Dispose();
                    }
                    catch (Exception ex)
                    {                        
                        function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "设置费率队列异常");
                    }
                }
                else
                {
                    Thread.Sleep(60000);
                }
            }
        }

        #region 金控
        // 开发环境
        // string mfe88PublicKey = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCy8cg6/tXbSj2i1tyi7VztwJw7uNmqc3bS6sVIZkDYhTmcXhpV17jq4j2zz/tURwX8b3MdK1A1HTR1XRd7hl0w2UF9iFk6UezByJ5tdNDoffMCGJtVSThq+MCV+WQI26tJ/ub6bm7GPrzTR79fntN+nTniRM4trjONN2WzEhHEcwIDAQAB";
        // string mfe88PrivateKey = "MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALLxyDr+1dtKPaLW3KLtXO3AnDu42apzdtLqxUhmQNiFOZxeGlXXuOriPbPP+1RHBfxvcx0rUDUdNHVdF3uGXTDZQX2IWTpR7MHInm100Oh98wIYm1VJOGr4wJX5ZAjbq0n+5vpubsY+vNNHv1+e036dOeJEzi2uM403ZbMSEcRzAgMBAAECgYAeRbb4/AmTypB4zt6OlZdGBXKoy9HO+y+b6OmtINdRieBAKs9LvG3lFpcXp1S+YjGKDhSsV5p/EczBGhmR5R44j52886h6OoU0HskifeEJs152gMXLEFya/1QWnf1Ev+ugzuto+CxuHlGHE0T43uFkuATZp4sfXX/03um99FIKmQJBAOrYJX+VmKdNbmwNKMXkFBAw6FM4wrtr6vT3ne0pBWgbUDIH8cs83wq/SQHuvy/Cafqr8qWC9fFX2m+hllzxzA0CQQDDEIDNXdRxEmRVQ90lnn6ppnERvLhTY3RyuyOj3aqM1lxWEU2vvylimCpccTEqgY/PqMwfqChSf2v3S2CFjzJ/AkAPw2ho8vKnMDRcPlnhRpjuKUo+4812ZR0FSmWoWJuLTGIKqavaN4DFKOfOoGbm3sbcU5Ra9bpqc7ouygrcvEI1AkB8uqbBqsfW7X2+j8Bu96Picw1F3Di5CZVCb6tgcrNFjyRH3JSiVkfuRYKAzdg0Z9g/Xp33eB0gc13kKQy1GlWdAkB6Emn94YesoHda26HWbrgBy18KSfcLH57EuXquX/pOma1TXjaXw1E7kkFz1EPde9WzuSWUmGN2AdJT0ruTOb4C";
        // string clientPublicKey = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCb861uuey1252WdS8KPeBB+vm5AIBEKclsfBzVLY1cZXiiEbInCmsqT6fSO+A6wjWyJixGCzZICmUxhdBzuo3Du2YTbuo+fRlV6DW1mbguBV8/l2+LJvht0jl87J8N4skFUzvAeYKpWDX6dC6cLzjm5nyI1OrCQq0lsWPEMDCNAwIDAQAB";
        // string clientPrivateKey = "MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBAJvzrW657LXbnZZ1Lwo94EH6+bkAgEQpyWx8HNUtjVxleKIRsicKaypPp9I74DrCNbImLEYLNkgKZTGF0HO6jcO7ZhNu6j59GVXoNbWZuC4FXz+Xb4sm+G3SOXzsnw3iyQVTO8B5gqlYNfp0LpwvOObmfIjU6sJCrSWxY8QwMI0DAgMBAAECgYAjE0dqo/6NWHu1H14ZG5mYvW31Ihu3OP7Im5GQkNI+ecQMD5bWGQ3JUmkYa8ce8BdLnjJO/q6SvWPNI5+ip87CYPH1SMXKUiSLzaCrw4xMySW9PSnudTzJwhrmlmyjYTAg70tHf2YQC4YkNvtkR+PJ2yf6JEKGFVgP5p2KyeKXgQJBANjGryxyu95QC3jIaggcYmGD36sVO/ns8Uyu8PkAHYOscuXRcV0L8LghIzPolcehj9bTbDLjiuNgeuyjNs2YBvMCQQC4K4uIXt0kVDLYzlJfhN1CsV90vQitcKdD8wTO0JRKfMCQ6UDSumU7lq+z4TxTlRYxmZjpgIqH+N0WohmEiwWxAkBEfuMzBD3gjSJS0+DNF0ruzSCLinYdDoVgWZbC1wp8ZK0ZeQh9AhzZ0X6yFDffkGlG1B9IJSXpmr68rwXOCM+JAkBkrKEUxc6bGk/FRluvDWEqIO2uUdtZfBhjQ4ggSdKWOUXGsUsXJn9KKKAZc4lXo0rDiFQXaIXRuE+bHLdYReqxAkAj0Kol0LkJgdl2PoBAeyQHTpt9nxaeNX56W7CN/srBA1O2wr+aoQiJaKsu9I0EeW3zaMJlLi3VyjU4wnF+yAsB";
        // string reqUrl = "https://test-push.mfe88.com/push-service/api/MODIFYPERPOSFEE";

        // 生产环境
        string merchantNo = "4487378308096";
        string clientId = "1243966544896";
        string mfe88PublicKey = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQC2HxPVZ5ZIxIWfr24qB45PAz9WfjN9CiF1x9Lz3P/tVvIXFdBaUw+9zxCAPRDGQxJId7anjEjCOuAIKpFOiTPhVqHTHd3075FFsW5fL7lFCOFJELTj+mVamAIbKalAuRzIX0m0VQUXd+madB+yRQSBjkOIboAMYQ9amf99SqI9KwIDAQAB";
        string clientPublicKey = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCrSrNKkBt/X8Fkd7viGpTMk+GdJgE+SvoA4PSjccpZoLWnwxXsC8K/7pfm9uGxPjte9e4RznXE5nuhSrcfls4lDWhTrGd/lj3Id8OCM+yEG+xilJs1lvXJjHDhL6/wa+TE5NSzWoKgXnyeHF3TSHMbUefLLtoKqL3j4h4lPqrjiQIDAQAB";
        string clientPrivateKey = "MIICdwIBADANBgkqhkiG9w0BAQEFAASCAmEwggJdAgEAAoGBAKtKs0qQG39fwWR3u+IalMyT4Z0mAT5K+gDg9KNxylmgtafDFewLwr/ul+b24bE+O1717hHOdcTme6FKtx+WziUNaFOsZ3+WPch3w4Iz7IQb7GKUmzWW9cmMcOEvr/Br5MTk1LNagqBefJ4cXdNIcxtR58su2gqovePiHiU+quOJAgMBAAECgYBQIIyIR6slRWTRG5V/KlIK9O5oNbwFKMuUF6c4weUXUi9Hv+GEXugGIpVaTIi9AdCCFmb8W2kJ54tTowDQvRnGxVpr7repYwJv2jHh5ug3oreBghfbfbaOaRMXisp2x1CLi+8Q5BNjpe9KdurRtg7jt8bqgWels5aV2PbjPHHwBQJBANjqYXbapz6xUPdI0kyEQhdxHt7jOmysTY3vT+/UcgU2sf37hWh8JlTtVlFZns3JBocc9rMtBEAh0Cy5faMQXKMCQQDKJ9eYWQvb1GyB5IdDlkOuByyuwFfosZ0Qp+QNtnz1VAHHgQRM7RGNv3nYDJNEJ+qIhIzZppG5yDbAN7PYyTXjAkEAq8a4VkIDbZ9HyfxOJbAbEqtPUhzJ+KNea0cXm4o2nTBaNhLH7B1c0aZ908BQBRDr7XWfW/cLRapBTBm8h7R+VwJBAJAKrZMPN+TuSlaPaFYfNqBE2nC1+q2CCQE6L8QZmJYRwqbN5iuN7CkNGxt3cmNo8bNOhzH6fvFamLCDwDEixbMCQEgaxfAxpJdMoR6LrklSkigHiKfA6SaRWxxShFtBfjk5XcakmLkU/U5lgD/Blu7h4x6bRf4VPTYWdbxtiOK11rY=";
        string reqUrl = "https://push.mfe88.com/push-service/api/MODIFYPERPOSFEE";


        public string SetDeposit(string merNo, string sn, decimal fee = 0.6M)
        {
            List<SetDepositList> rateDOs = new List<SetDepositList>();
            rateDOs.Add(new SetDepositList()
            {
                productSubType = "2020032007vz7Ux6",
                updateValue = fee,
                updateType = 0
            });
            Dictionary<string, string> headers = new Dictionary<string, string>();
            headers.Add("X-Client-ID", clientId);
            headers.Add("X-Security", "RSA");
            Dictionary<string, object> obj = new Dictionary<string, object>();
            obj.Add("merNo", merNo);
            obj.Add("sn", sn);
            obj.Add("batchUpdateType", 2);
            obj.Add("rateDOs", rateDOs);
            string content = Newtonsoft.Json.JsonConvert.SerializeObject(obj);
            content = Encrypt(content);
            string signstr = Sign(content);
            headers.Add("X-Sign", signstr);
            string req = "{\"param\":\"" + content + "\"}";
            string result = function.PostWebRequest(reqUrl, req, headers, "application/json");
            return result;
        }

        public string Decrypt(string data)
        {
            var toDecryptArray = Convert.FromBase64String(data);
            var rsa = RSA.Create();
            rsa.ImportPkcs8PrivateKey(Convert.FromBase64String(clientPrivateKey), out _);
            string result = "";
            List<byte> cache = new List<byte>();
            for (int i = 0; i < toDecryptArray.Length; i++)
            {
                cache.Add(toDecryptArray[i]);
                if ((i + 1) % 128 == 0 || i + 1 == toDecryptArray.Length)
                {
                    var ContentArray = rsa.Decrypt(cache.ToArray(), RSAEncryptionPadding.Pkcs1);
                    result += System.Text.Encoding.UTF8.GetString(ContentArray);
                    cache.Clear();
                }
            }
            return result;
        }
        public string Encrypt(string data)
        {
            return new RSAHelper(RSAType.RSA, System.Text.Encoding.UTF8, "", mfe88PublicKey).Encrypt(data);
        }
        public string Sign(string data)
        {
            var toEncryptArray = System.Text.Encoding.UTF8.GetBytes(data);
            var rsa = RSA.Create();
            rsa.ImportPkcs8PrivateKey(Convert.FromBase64String(clientPrivateKey), out _);
            string result = "";
            var buffer = rsa.SignData(toEncryptArray, HashAlgorithmName.SHA256, RSASignaturePadding.Pkcs1);
            result = Convert.ToBase64String(buffer);
            return result;
        }
        #endregion
    
        #region 立刷

        string LiSAgentId = "50814834";
        string LiSPrivateKey = "MIIJQwIBADANBgkqhkiG9w0BAQEFAASCCS0wggkpAgEAAoICAQDTdeLXqQmfVJM/ATVnq+TdhgpKKPp3hXcuY2s9qrN1Uws7I7jqnq/gfoBHBWBu/PnQp/z65okBoz4PEpWzJYZDF4csgh3E45He46ialNzUlOPWv6yLzgQPHuneq2pXOb7dbN4kZx+g3nEbBjH+/P9xp+lU3HCwjNxIFSr3EyBAQf2HgvNqh70u9T13fGVx3Jtd2xbIKYhvGNPH9ZCGiZNiCy+m+F+TKywgKK/xify1KQgR6otVUOVIGYvPYlXAgLJM2/V54166KX1UUFMsKRj4Kt2j4GqoHzDfRk9ibYJ/8iSDGX4+WH5+8mq/raqA77VcAD+bMrt3Bm59XmaWtjZwDY1zh5sP5jEaxu4lde2xZD80kQ6p1ZydpqnjmWm6NKXSz8j85gRkTQqNALKNANnJb6f1Yy30WirnrhMkqU2dqBzzXxtk3k/2zv9BENjYs1igrRYpwX3QRx87aTOrIk/PO6cxMaWl249LPigah0OqVyIg5yOvtnUCdU12OqaVELIw5GnZ7rTRn3tAsJ+u1om+3XktbN3GUEpw5RWAT3UAsAU7Vxt9xPCss+JXF+ogXYgo9QpEjanXOfLo5KPv2CkBuzy87d85OId71gXpYcbp0zbKz5eXKZanVP9pwn43jqiPkqtam8N1TLCCmZ4t2cd+gpW2CX/+W7bmc25HJtRPuwIDAQABAoICAE7B9GfwTGYsYN8xewuOySH8n255jrffXMFJRBLmtgo3kNJI/sFbsxPA6dQJ253a2MxvFNj57gNPInkIqfrcOgJZC/52w9GmFJlYX16bnRgMEEPWhdRYOcjL8bz+SRANsNnVh3M1eWE4GBZBm3NmFVnmeRAjPlFzVUP/pk35sKReL6g+DJ0by0lnC6qqCTp8ON2fEQAh/++o5o/uFRMWwG7ezbO5hBdTGA8uOEGU7CspChlqKtTu2UaeRSVLcbbN+BqKPgZUud5KP6Scei3TbLpZdM1pczAE1fYCwORe9yDiNdkiMJPV798mOL4FV6DIJtsKOKZ8Ibg2DAbjlwABA4rQsgBUAA4Nj+skqLE7gGnJViHzKw87zve+v3CV9NEldHV7g2a78yKye489vlmmxcLj+Ln5O/Y3OQnDwsO8mVua5Ddyp26N88oB1wW62VLUn68ePclDd3Bdub/ayiBqFOqA0cTlqI5Dvz0rqrK9dkq4Ij295EK3OfYHCjuoHN+mJP0K0+o+5ItPXu7KWRz/Bf+KPneAAgvTRaDMww+HpfbcM6sxfiZqVE0yGux39i6wjEOCcIbfO8O7wgCEk4GE/98Z6/+lp1NEaQLHcu24FlUeCgThTVaJsmcY9aHB+jFn11yBiJ6+N+RYONWto0xLDyt71qM5KXEEngYambCK8D0JAoIBAQD5tYwpTNfcessxPcYAXkdJWNAP3/8kwz97rFi9gZYsxhZJ/JCU8TUCYlpJDf91mCe0i7uayGb3FbtzoWEwHxKL4DdlL47ZaaGA2dIVNMkxksXDehEE6/bVRAcFH1fT9mZr7uB2uX1YjesFRKEEd3UXpfKSPwtm3QUQz7P7WxzL0CWpfC11vAK2biCG72inE3MelCw/z1Y7M7oo2fyflObMPKkqyuy5NGtZ5t9xpMvLaZrOzJkYbwPaIqxIvISg9rxilZhjMhIFHOW8xM0lVHMEkk2NrwwsMihxFmDaUohZf0GiyYzNEEVBmVEhAZSOV5d1JlWYQStyvDas195/IHjNAoIBAQDYyakyJbbEhgcLSrmXKtJY584y6SYFE1mOZKKkON2EfDpAlwFmJYV26dWiPb77mUsf1HUU/aIT6sfZsrh6axvs0rqqp5ltIr6AzXnJce590EMJnASWLTAdhYXK6e5Y1W8AhylP4LzZk/dy4LOaF09pMi3ugogFFJAWV8j/cv2niUsCXg/I6cQz/Co6cwVhBzOnAMIjdvZbJ2ONJ1Jy/4yS17DBFRyHxMbGVPckXEVodjZ73TAfUQIM83Z8YILxyym2d2f7lvuCyT+ZjmpEJQztdxPO8qT9MaROs4c/qVjJZndoTZ3z4i2eke9Bf3Qcd6Bfy6jPq/r73hl0w0kBo4qnAoIBAQCC8fgZJEnCPcZWAR3WzZm2VdNtr7n9TkH5GazDW7QjsJC5pa8v27k/kdHko2mGAg84N1pe1Z5hDc1p2oO7l1/DaAXEkwbm7eSaTB9FrZOf4mbAlj9chFzBA1ZnEkOdTIXzLaYZvDWF/Y30CkQhsn79srEcjeDtxRNF+JVaRzI3kuRdF1hDeB84CVIXUG5hxupEa9E0eQawLvT9PSqjiJLrIRhY72bpzBpLX61my9NuzOc4cMQLsxOjDTGpRuqJ+jlZvTbXNceLVNcIgW9OlxVlnU778IKCnp7khqatdkA4JmqF8gla86BNwRdxJoH/juFGtp6GJA6jsR0+0EjGA4I1AoIBAGl2ITNeGX2dXgvmPEcH8/CARFWMCozpjuWwm1acu1baQFRvoaSZmEXzF5SnySMIvf0sFBE0GgbqbnK/ePNE6/7XvSuMAR2Qi3CJhTe0jzrxd8tS9QBB12hlLmM6TlM08Z0mI7jSMcz/KJ/gJD9QG7enS6T+J0GhcT8NUaDDxhYcujram384CdToVXq9vd4n7L7PpaIvG0XY8ZsXiAqduzssZrZnmMuLtM+DQf+US8e3ymWTgveZJxA52GhFYy5RkWdMy28fUheb467GE3g3NgTHqwFAFXd/ENmgiKk1rxW7HVfGepLMczjy8ZvBbzDyGTjBEMyGc8DXmTauUfPUJX0CggEBAKEWyNHhEBcEfW6ppPYsaKTlIquA2Chr15KsZcSFOMIcsF/6D7TDZg2NPDYFmlALF/cdqDjRIAP/v5IMRiu3UtHyfDbRyEHx0prvucFMY0HyX9VOJnticwTb39awHi/uFJLs7txERw89eJFcLaxRRRRSpPq3PCalGFpC2i8HXsPnv3gyt+bfE92h6E2YTyP41NYmcuuXkyWM83s11YSC9ZgeilbJuvdajePHrtIAxy8cny+yTBcbnJnWw1yHtzWCA5FAw5OWSaeotbWaFEAHaOW1VG9e1I54pgmVTc5n+WixsgH1fpiz04ojlWRWRyP7hqS+GbAyGgg00KyErRrPcwc=";

        string LiSReqUrl = "https://openapi.jlpay.com/access/charge/"; //请求url

        public string LiSSign(string data)
        {
            var rsa = RSA.Create();
            var key = Convert.FromBase64String(LiSPrivateKey);
            var content = Encoding.UTF8.GetBytes(data);
            rsa.ImportPkcs8PrivateKey(key, out _);
            var result = rsa.SignData(content, HashAlgorithmName.SHA256, RSASignaturePadding.Pkcs1);
            return Convert.ToBase64String(result);
        }

        // 设置费率
        public string SetLiSFee(string sn, decimal serviceFee = 0.6M)
        {
            Dictionary<string, object> dic = new Dictionary<string, object>();
            dic.Add("agentId", LiSAgentId);
            dic.Add("deviceSn", sn);
            List<Dictionary<string, object>> feeList = new List<Dictionary<string, object>>();
            Dictionary<string, object> item = new Dictionary<string, object>();
            item.Add("feeCalcType", "M5");
            item.Add("fixed", "0");
            item.Add("rate", serviceFee);
            feeList.Add(item);
            dic.Add("feeList", feeList);
            dic.Add("signMethod", "02");
            string content = LiSAgentId + sn + "M50" + serviceFee + "02";
            string signstr = LiSSign(content);
            dic.Add("signData", signstr);
            string req = Newtonsoft.Json.JsonConvert.SerializeObject(dic);
            string result = PostWebRequest(LiSReqUrl + "FEE003", req, new Dictionary<string, string>());
            return result;
        }

        public string QueryLiSDeposit(string merchNo, string sn)
        {
            Dictionary<string, object> dic = new Dictionary<string, object>();
            dic.Add("agentId", LiSAgentId);
            dic.Add("deviceSn", sn);
            dic.Add("merchNo", merchNo);
            dic.Add("signMethod", "02");
            string content = LiSAgentId + sn + merchNo + "02";
            string signstr = LiSSign(content);
            dic.Add("signData", signstr);
            string req = Newtonsoft.Json.JsonConvert.SerializeObject(dic);
            string result = PostWebRequest(LiSReqUrl + "FEE001", req, new Dictionary<string, string>());
            return result;
        }

        private string PostWebRequest(string postUrl, string paramData, Dictionary<string, string> headers)
        {
            string ret = string.Empty;
            try
            {
                function.WriteLog(DateTime.Now.ToString(), "请求开店宝API日志");
                function.WriteLog(postUrl, "请求开店宝API日志");
                function.WriteLog(paramData, "请求开店宝API日志");
                byte[] postData = System.Text.Encoding.UTF8.GetBytes(paramData);
                // 设置提交的相关参数 
                System.Net.HttpWebRequest request = System.Net.WebRequest.Create(postUrl) as System.Net.HttpWebRequest;
                System.Text.Encoding myEncoding = System.Text.Encoding.UTF8;
                request.Method = "POST";
                request.KeepAlive = false;
                request.AllowAutoRedirect = true;
                request.ContentType = "application/json";
                foreach (string key in headers.Keys)
                {
                    request.Headers.Add(key, headers[key]);
                }
                request.UserAgent = "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; .NET CLR 2.0.50727; .NET CLR  3.0.04506.648; .NET CLR 3.5.21022; .NET CLR 3.0.4506.2152; .NET CLR 3.5.30729)";

                request.ContentLength = postData.Length;

                // 提交请求数据 
                System.IO.Stream outputStream = request.GetRequestStream();
                outputStream.Write(postData, 0, postData.Length);
                outputStream.Close();
                System.Net.HttpWebResponse response;
                System.IO.Stream responseStream;
                System.IO.StreamReader reader;
                string srcString;
                response = request.GetResponse() as System.Net.HttpWebResponse;
                responseStream = response.GetResponseStream();
                reader = new System.IO.StreamReader(responseStream, System.Text.Encoding.UTF8);
                srcString = reader.ReadToEnd();
                ret = srcString;   //返回值赋值
                reader.Close();
                function.WriteLog(srcString, "请求开店宝API日志");
            }
            catch (Exception ex)
            {
                ret = "fail";
                function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "请求开店宝API异常");
            }
            return ret;
        }

        #endregion
    
    }
}