C#微信小程序服务端获取用户解密信息实例代码

usingAIOWeb.Models;

usingNewtonsoft.Json;

usingNewtonsoft.Json.Linq;

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Data;

usingSystem.Data.SqlClient;

usingSystem.Linq;

usingSystem.Web;

namespaceAIOWeb

{

  ///

  /// wxapi 的摘要说明

  ///

  publicclasswxapi : IHttpHandler

  {

    publicvoidProcessRequest(HttpContext context)

    {

      context.Response.ContentType ="text/plain";

      stringcode ="";

      stringiv ="";

      stringencryptedData ="";

      try

      {

        code = HttpContext.Current.Request.QueryString["code"].ToString();

        iv = HttpContext.Current.Request.QueryString["iv"].ToString();

        encryptedData = HttpContext.Current.Request.QueryString["encryptedData"].ToString();

      }

      catch(Exception ex)

      {

        context.Response.Write(ex.ToString());

      }

      stringAppid ="wxdb2641f85b04f1b3";

      stringSecret ="8591d8cd7197b9197e17b3275329a1e7";

      stringgrant_type ="authorization_code";

      //向微信服务端 使用登录凭证 code 获取 session_key 和 openid 

      stringurl  ="https://api.weixin.qq.com/sns/jscode2session?appid="+ Appid  +"&secret="+ Secret +"&js_code="+ code +"&grant_type="+  grant_type;

      stringtype ="utf-8";

      AIOWeb.Models.GetUsersHelper GetUsersHelper =newAIOWeb.Models.GetUsersHelper();

      stringj = GetUsersHelper.GetUrltoHtml(url, type);//获取微信服务器返回字符串

      //将字符串转换为json格式

      JObject jo = (JObject)JsonConvert.DeserializeObject(j);

      result res =newresult();

      try

      {

        //微信服务器验证成功

        res.openid = jo["openid"].ToString();

        res.session_key = jo["session_key"].ToString();

      }

      catch(Exception)

      {

        //微信服务器验证失败

        res.errcode = jo["errcode"].ToString();

        res.errmsg = jo["errmsg"].ToString();

      }

      if(!string.IsNullOrEmpty(res.openid))

      {

        //用户数据解密

        GetUsersHelper.AesIV = iv;

        GetUsersHelper.AesKey = res.session_key;

        stringresult = GetUsersHelper.AESDecrypt(encryptedData);

        //存储用户数据

        JObject _usrInfo = (JObject)JsonConvert.DeserializeObject(result);

        userInfo userInfo =newuserInfo();

        userInfo.openId = _usrInfo["openId"].ToString();

        try//部分验证返回值中没有unionId

        {

          userInfo.unionId = _usrInfo["unionId"].ToString();

        }

        catch(Exception)

        {

          userInfo.unionId ="unionId";

        }

        userInfo.nickName = _usrInfo["nickName"].ToString();

        userInfo.gender = _usrInfo["gender"].ToString();

        userInfo.city = _usrInfo["city"].ToString();

        userInfo.province = _usrInfo["province"].ToString();

        userInfo.country = _usrInfo["country"].ToString();

        userInfo.avatarUrl = _usrInfo["avatarUrl"].ToString();

        objectwatermark = _usrInfo["watermark"].ToString();

        objectappid = _usrInfo["watermark"]["appid"].ToString();

        objecttimestamp = _usrInfo["watermark"]["timestamp"].ToString();

        #region

        //创建连接池对象（与数据库服务器进行连接）

        SqlConnection conn =newSqlConnection("server=127.0.0.1;database=Test;uid=sa;pwd=1");

        //打开连接池

        conn.Open();

        //创建命令对象

        stringQrystr ="SELECT * FROM WeChatUsers WHERE openId='"+ userInfo.openId +"'";

        SqlCommand cmdQry =newSqlCommand(Qrystr, conn);

        objectobj = cmdQry.ExecuteScalar();

        if((Object.Equals(obj,null)) || (Object.Equals(obj, System.DBNull.Value)))

        {

          stringstr  ="INSERT INTO WeChatUsers ([UnionId]  ,[OpenId],[NickName],[Gender],[City],[Province],[Country],[AvatarUrl],[Appid],1664178218,[Memo],[counts])VALUES('"+  userInfo.unionId +"','"+ userInfo.openId +"','"+ userInfo.nickName  +"','"+ userInfo.gender +"','"+ userInfo.city +"','"+ userInfo.province  +"','"+ userInfo.country +"','"+ userInfo.avatarUrl +"','"+  appid.ToString() +"','"+ timestamp.ToString() +"','来自微信小程序',Ƈ')";

          SqlCommand cmdUp =newSqlCommand(str, conn);

          // 执行操作

          try

          {

            introw = cmdUp.ExecuteNonQuery();

          }

          catch(Exception ex)

          {

            context.Response.Write(ex.ToString());

          }

        }

        else

        {

          //多次访问，记录访问次数counts  更新unionId是预防最初没有，后期关联后却仍未记录

          stringstr  ="UPDATE dbo.WeChatUsers SET counts = counts+1，UnionId = '"+  userInfo.unionId +"' WHERE OpenId='"+ userInfo.openId +"'";

          SqlCommand cmdUp =newSqlCommand(str, conn);

          introw = cmdUp.ExecuteNonQuery();

        }

        //关闭连接池

        conn.Close();

        #endregion

        //返回解密后的用户数据

        context.Response.Write(result);

      }

      else

      {

        context.Response.Write(j);

      }

    }

    publicboolIsReusable

    {

      get

      {

        returnfalse;

      }

    }

  }

}

usingSystem;

usingSystem.Collections.Generic;

usingSystem.IO;

usingSystem.Linq;

usingSystem.Security.Cryptography;

usingSystem.Text;

usingSystem.Threading.Tasks;

namespaceAIOWeb.Models

{

  publicclassGetUsersHelper

  {

    ///

    /// 获取链接返回数据

    ///

    ///链接

    ///请求类型

    ///

    publicstringGetUrltoHtml(stringUrl,stringtype)

    {

      try

      {

        System.Net.WebRequest wReq = System.Net.WebRequest.Create(Url);

        // Get the response instance.

        System.Net.WebResponse wResp = wReq.GetResponse();

        System.IO.Stream respStream = wResp.GetResponseStream();

        // Dim reader As StreamReader = New StreamReader(respStream)

        using(System.IO.StreamReader reader =newSystem.IO.StreamReader(respStream, Encoding.GetEncoding(type)))

        {

          returnreader.ReadToEnd();

        }

      }

      catch(System.Exception ex)

      {

        returnex.Message;

      }

    }

    #region 微信小程序用户数据解密

    publicstaticstringAesKey;

    publicstaticstringAesIV;

    ///

    /// AES解密

    ///

    ///输入的数据encryptedData

    ///key

    ///向量128

    ///解密后的字符串

    publicstringAESDecrypt(stringinputdata)

    {

      try

      {

        AesIV = AesIV.Replace(" ","+");

        AesKey = AesKey.Replace(" ","+");

        inputdata = inputdata.Replace(" ","+");

        byte[] encryptedData = Convert.FromBase64String(inputdata);

        RijndaelManaged rijndaelCipher =newRijndaelManaged();

        rijndaelCipher.Key = Convert.FromBase64String(AesKey);// Encoding.UTF8.GetBytes(AesKey);

        rijndaelCipher.IV = Convert.FromBase64String(AesIV);// Encoding.UTF8.GetBytes(AesIV);

        rijndaelCipher.Mode = CipherMode.CBC;

        rijndaelCipher.Padding = PaddingMode.PKCS7;

        ICryptoTransform transform = rijndaelCipher.CreateDecryptor();

        byte[] plainText = transform.TransformFinalBlock(encryptedData, 0, encryptedData.Length);

        stringresult = Encoding.UTF8.GetString(plainText);

        returnresult;

      }

      catch(Exception)

      {

        returnnull;

      }

    }

    #endregion

  }

}