C# 物联网交互，开发API接口实例代码

程序员文章站 2022-03-27 21:32:54

C# 物联网开发API接口系列（四）#久爱物联网#MQTT#【提纲】1）获取设备列表（某用户的）2）单独检查设备是否存在合法3）各种接口效果展示【正文】 ///

/// 获取设备列表 ///

/// 令牌 /// priva...

C# 物联网开发API接口系列（四）

#久爱物联网#MQTT#

【提纲】

1）获取设备列表（某用户的）

2）单独检查设备是否存在合法

3）各种接口效果展示

【正文】

 /// <summary>
    /// 获取设备列表
    /// </summary>
    /// <param name="_token">令牌</param>
    /// <returns></returns>
    private string getDevList(string _token)
    {
        string result = "";
        int listnum = 0;

        StringBuilder sb = new StringBuilder();
        try
        {
            if (SqlHelper.isConnected)
            {
                SqlConnection SqlConn = new SqlConnection(SqlHelper.ConnString);
                if (SqlConn.State != ConnectionState.Connecting)
                {
                    SqlConn.Open();// 打开数据库连接
                }
                //注意：参数是token查询用的是 uid 之前有一方法已经调用了 uid = getUidbyToken(token);
                SqlCommand sqlCmd = new SqlCommand("SELECT * FROM box_List WHERE bForUid=" + uid, SqlConn);
                SqlDataReader rd = sqlCmd.ExecuteReader();//返回的是记录集

                if (rd.HasRows)
                {
                    while (rd.Read())
                    {
                        listnum++;
                        sb.AppendFormat("｛" + string.Format("\"regpacket\":\"{0}\",\"boxname\":\"{1}\",\"actived\":{2}", rd["bRegpacket"].ToString(), rd["bName"].ToString(),Convert.ToInt16(rd["bStatus"])) + "｝");//可继续扩展其他属性
                        sb.AppendFormat(",");//最后一条需要处理此符号
                    }
                    sb.Remove(sb.ToString().LastIndexOf(','), 1);//处理最后一位符号（如何处理最后一个逗号）
                }                
                rd.Close();//统一释放资源
                rd = null;
                sqlCmd = null;
                SqlConn.Close();//关闭数据库连接   
                SqlConn = null;//否则不更新原内容 
            }
            //当data为数组时加[] 非数组及json格式写法
            if(listnum>0)
                result = string.Format("\"data\":[{0}],\"code\":{1},\"time\":\"{2}\"", sb.ToString().Replace("｛", "{").Replace("｝", "}"), 200, svrNowTime());
            else
                result = string.Format("\"data\":\"{0}\",\"code\":{1},\"time\":\"{2}\"", "请检查参数的合法性:" + _token, 0, svrNowTime());
            
        }
        catch (Exception ex)
        {
            result = string.Format("\"data\":\"[ERROR]:{0}\",\"code\":{1},\"time\":\"{2}\"", ex.Message.ToString(), -1, DateTime.Now);
        }

        return "{"+result+"}";//组合成标准的json格式的头尾
    }

    /// <summary>
    /// 验证智能模块的合法性
    /// </summary>
    /// <param name="reg">注册包</param>
    /// <returns></returns>
    private string checkDevValidity(string reg)
    {
        string _retu = "";
        try
        {
            SqlConnection SqlConn = new SqlConnection(SqlHelper.ConnString);
            if (SqlConn.State != ConnectionState.Connecting)
            {
                SqlConn.Open();// 打开数据库连接
            }
            //bStatus 1启用0禁用-1列黑
            SqlCommand sqlCmd = new SqlCommand("SELECT * FROM  box_List WHERE bStatus=1 AND bForUid=" + uid + " AND bRegpacket='" + reg + "'", SqlConn);
            SqlDataReader rd = sqlCmd.ExecuteReader();

            if (rd.HasRows)
            {
                rd.Read();
                _retu = string.Format("\"data\":\"[OK]{0}\",\"code\":{1},\"time\":\"{2}\"", rd["bRegpacket"], 200, DateTime.Now);
            }
            else
            {
                _retu = string.Format("\"data\":\"[SORRY]{0}\",\"code\":{1},\"time\":\"{2}\"", "验证失败，请检查参数是否正确!", 0, DateTime.Now);
            }
        }
        catch (Exception ex)
        {
            _retu = string.Format("\"data\":\"[ERROR]:{0}\",\"code\":{1},\"time\":\"{2}\"", ex.Message.ToString(), -1, DateTime.Now);
        }
        return "{" + _retu + "}"; //重新组合标准json格式头尾{}
        
    } 



    //通过token获取uid
    private int getUidbyToken(string tok)
    {
        int _uid;
        try
        {
            SqlConnection SqlConn = new SqlConnection(SqlHelper.ConnString);
            if (SqlConn.State != ConnectionState.Connecting)
            {
                SqlConn.Open();// 打开数据库连接
            }
            SqlCommand sqlCmd = new SqlCommand("SELECT top 1 uid,fuid,uToken,uTel,uName FROM user_List WHERE uToken='" + tok + "' AND uStatus=1", SqlConn);//uRole=8
            SqlDataReader rd = sqlCmd.ExecuteReader();//返回的是记录集   AND uStatus=1
            if (rd.HasRows)
            {
                if (rd.Read())
                {
                    uid = Convert.ToInt16(rd["uid"]);//***主要查询这个
                    fuid = Convert.ToInt16(rd["fuid"]);
                    utoken = rd["uToken"].ToString();
                    utel = rd["uTel"].ToString();
                    uname = rd["uName"].ToString();
                    //
                    ujson = "{\"uid\":" + uid + ",\"fuid\":" + fuid + ",\"utoken\":\"" + utoken + "\",\"uname\":\"" + uname + "\",\"utel\":\"" + utel + "\"}";
                }
                _uid = uid;//返回这个
            }
            else
            {
                _uid = -1;//没找到
            }
        }
        catch (Exception ex)
        {
            _uid = 0;//错误异常时0
        }
        return _uid;
    }

C# 物联网交互，开发API接口实例代码