网络编程
位置:首页>> 网络编程>> 数据库>> C#获取微信小程序的云数据库中数据的示例代码

C#获取微信小程序的云数据库中数据的示例代码

作者:shanzm  发布时间:2024-01-18 07:30:59 

标签:C#,小程序,数据
目录
  • 0 背景说明

    • 0.1 获取AccessToken

    • 0.2 数据库查询

    • 0.3 文件下载

  • 2. 简单的封装

    • 3. 简单测试

      • 4. 参考文档

        0 背景说明

        试水小程序,实现访客登记,现有.NET程序需要获取该小程序的数据

        0.1 获取AccessToken

        调用绝大多数后台接口时都需使用 access_token

        参考小程序文档:auth.getAccessToken

        发送Get请求,获取AccessToken

        接口:

        • https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET

        参数:

        • appid:小程序ID

        • secret:注册时产生的密钥,可以重置

        • 两个参数信息可以在后台->开发管理->开发设置->开发者设置中查看

        返回值:

        格式如下:

          {"access_token":"ACCESS_TOKEN","expires_in":7200}    

        • access_token:获取到的凭证

        • expires_in:凭证的有效时间,单位:秒

        0.2 数据库查询

        参考小程序文档:databaseQuery

        发送Post请求,获取数据

        接口:

        • POST https://api.weixin.qq.com/tcb/databasequery?access_token=ACCESS_TOKEN

        参数:

        接口地址中加入AccessToken

        请求参数:

        • env:云环境ID

        • query:数据库操作语句

        格式如下:


        { "env":"小程序环境", "query": "db.collection(\"集合名称\").where({done:true}).limit(10).skip(1).get()" }

        query中应使用limit()限制单次拉取的数量,默认10条。

        0.3 文件下载

        参考小程序文档:获取文件下载链接

        发送post请求获取

        接口:

        • POST https://api.weixin.qq.com/tcb/batchdownloadfile?access_token=ACCESS_TOKEN

        参数:

        • 接口地址中加入AccessToken

        请求参数:

        • env:云环境ID

        • file_list:文件列表

        格式如下:


        { "env": "云环境ID", "file_list": [ { "fileid":"文件ID", "max_age":7200 } ] }

        2. 简单的封装

        简单的封装了发送请求的方法


        //需要添加的命名空间
        using Newtonsoft.Json;
        using System.IO;

        /// <summary>
        /// 发送http Get请求
        /// </summary>
        /// <param name="url"></param>
        /// <returns></returns>
        public static HttpWebResponse GetRequest(string url)
        {
           HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
           request.Method = "GET";
           request.ContentType = "application/x-www-form-urlencoded";//链接类型
           return request.GetResponse() as HttpWebResponse;
        }

        /// <summary>
        /// 发送http Post请求
        /// </summary>
        /// <returns></returns>
        public static HttpWebResponse PostRequest(string url, string messsage)
        {
           byte[] byteData = Encoding.UTF8.GetBytes(messsage);
           HttpWebRequest webRequest = (HttpWebRequest)WebRequest.Create(url);
           webRequest.Method = "POST";
           webRequest.ContentType = "application/json;charset=UTF-8";
           webRequest.ContentLength = byteData.Length;
           using (Stream stream = webRequest.GetRequestStream())
           {
               stream.Write(byteData, 0, byteData.Length);
           }
           HttpWebResponse response = (HttpWebResponse)webRequest.GetResponse();
           return response;
        }

        /// <summary>
        /// 从HttpWebResponse对象中提取响应的数据转换为字符串
        /// </summary>
        /// <param name="webresponse"></param>
        /// <returns></returns>
        public static string HttpWebResponseToString(HttpWebResponse webresponse)
        {
           using (Stream s = webresponse.GetResponseStream())
           {
               StreamReader reader = new StreamReader(s, Encoding.UTF8);
               return reader.ReadToEnd();
           }
        }

        /// <summary>
        /// Json字符串转为匿名对象
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="json"></param>
        /// <param name="anonymousTypeObject"></param>
        /// <returns></returns>
        public static T DesAnonymousType<T>(string json, T anonymousTypeObject)
        {
           return JsonConvert.DeserializeAnonymousType(json, anonymousTypeObject);
        }

        3. 简单测试

        发送请求获取数据


        /// <summary>
        /// 获取access_token
        /// </summary>
        /// <returns></returns>
        public static string GetAccessToken()
        {
           // 通过Get请求获取access_token
           HttpWebResponse httpWebResponse = GetRequest("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credentiaappid=小程序ID&secret=小程序密钥");
           string resultJson = HttpWebResponseToString(httpWebResponse);
           var resultObj = DesAnonymousType(resultJson, new { access_token = "", expires_in = "" });
           return resultObj.access_token;
        }

        /// <summary>
        ///  查询数据
        /// </summary>
        /// <param name="queryString">形如: $"{{\"env\":\"小程序环境id\", \"query\": \"db.collecti(\\\"数据集合名称\\\").where({{集合中字段:\\\"集合中字段值\\\"}}).limit(10).get()\"}}"</param>
        /// <returns></returns>
        public static string GetData(string queryString)
        {
           string accessToken = GetAccessToken();
           HttpWebResponse httpWebResponse = PostRequest("https://api.weixin.qq.com/tcb/databasequery?access_token=" + accessTokenqueryString);
           string data = HttpWebResponseToString(httpWebResponse);
           return data;
        }

        /// <summary>
        /// 通过FileId获取文件下载URL
        /// </summary>
        /// <param name="queryString">形如:$"{{\"env\": \"环境ID\",\"file_list\": [{{\"fileid\":文件ID\",\"max_age\":7200 }}]}}"</param>
        /// <returns></returns>
        public static string GetDownFileUrl(string queryString)
        {
           string accessToken = GetAccessToken();
           string url = $"https://api.weixin.qq.com/tcb/batchdownloadfile?access_token={accessToken}";
           HttpWebResponse httpWebResponse = PostRequest(url, queryString);
           string downFileUrl = HttpWebResponseToString(httpWebResponse);
           return downFileUrl;
        }

        4. 参考文档

        小程序官方文档:云开发->数据库查询记录

        小程序官方文档:接口调用凭证->getAccessToken

        来源:https://www.cnblogs.com/shanzhiming/p/15208107.html

        0
        投稿

        猜你喜欢

        手机版 网络编程 asp之家 www.aspxhome.com