基於華為物聯網IOT的應用開發 ---界面管理開發

在前面隨筆《基於華為物聯網IOT的應用開發 --- 基於.net 的SDK封裝》介紹過IOT中應用側SDK的封裝，主要就是基於華為IOT的應用側封裝，以便在應用系統中進行調用。應用側SDK的封裝是一切應用開發的基礎，不過華為並沒有提供對應.net的SDK封裝，不過SDK都是基於Web  API 的JSON數據進行交互，因此花了一點時間進行了華為.net 的SDK進行了全面封裝，本篇隨筆介紹如何基於封裝好的IOT 應用側的SDK進行界面管理的開發，實現對IOT業務數據的管理等。

1、應用側SDK封裝回顧

應用側的開發接口一般雲平台都會提供不同平台的SDK，如阿里雲開源提供Java SDK/C# SDK等；而華為則提供了Java、PHP等SDK，沒有包含.net 的SDK。華為物聯網雲的應用側API接口包括：

 

基於對應應用側API接口的定義，我們使用C#進行了對應接口的封裝。

  包含了一個測試接口項目、一個SDK封裝接口項目，以及一個訂閱的消息推送接口的解析和處理，例如新增設備、設備信息變化、設備綁定激活等。

對於事件的通知，我們一般是在應用端被動的進行相應的處理，因此需要對它們的消息進行轉換和處理。

類似在管理后台訂閱這些事件，然后這些事件觸發后會推送給應用服務器。

  

2、接口的測試使用

根據IOT的應用側API的定義，我們編寫一個快速測試SDK工作情況的Winform程序來測試，如獲取授權信息，以及查詢產品、注冊設備、修改設備、獲取設備狀態和詳細等等接口的正常與否，然后再在Web應用中進行整合，這樣可以減少返工調試的問題。

按照業務接口的歸類測試，我們編寫如下程序用來測試對應SDK接口。

 在使用SDK接口前，我們需要知道，華為IOT的API接口，基本上全部需要證書的對接的，這個和我們開發微信API有所差異。例如，我們的Winform測試程序，讓它帶有一個Cert目錄下的證書文件，這個證書文件可以在API的Demo里面找到，或者在華為IOT平台上下載。

 我們最終用到的是cert/outgoing.CertwithKey.pkcs12這個證書文件。

 我們創建一個HTTPRequest對象獲取數據的時候，需要指定這個證書，如下所示。

helper.ContentType = "application/json";
helper.ClientCertificates = new X509CertificateCollection() { new X509Certificate2(Constants.CertFilePath, Constants.CertPassword) };

其他部分就是對API接口封裝的調用測試了。

如首先是授權的測試，用來獲取AccessToken的，這個是調用其他接口的前提。

private void btnLogin_Click(object sender, EventArgs e)
{
    var result = basicApi.Authentication();
    Console.WriteLine(result != null ? "accessToken:" + result.ToJson() : "獲取結果出錯");

    if (result != null)
    {
        var refreshResult = basicApi.RefreshToken(result.refreshToken);

        Console.WriteLine(refreshResult != null ? "accessToken:" + refreshResult.ToJson() : "獲取結果出錯");
        this.accessToken = refreshResult.accessToken;//記錄待用
    }
}

華為IOT接口很多沒有全部整合在一起，有的在https://support.huaweicloud.com/api-IoT/iot_06_0003.html ,而有的則在https://support.huaweicloud.com/api-iothub/iot_06_0008.html, 就拿授權來說，還有另外一個版本的接口可以獲取，兩個接口獲得的token都可以通用。

var url = Constants.AppBaseUrl + "/iocm/app/sec/v1.1.0/login";

var url = Constants.AppBaseUrl + "/api/v3.0/auth/tokens";

這兩個地址都可以獲取AccessToken，如設備創建，也是有多個接口，版本不同。

我們針對各個接口的封裝，對相關接口進行測試，如基於產品、產品下面的列表等信息，可以在一個接口測試代碼里面進行測試，如下所示。

        /// <summary>
        /// 產品相關接口測試
        /// </summary>
        private void btnProduct_Click(object sender, EventArgs e)
        {
            if (string.IsNullOrEmpty(accessToken))
            {
                MessageUtil.ShowTips("請先鑒權獲取AccessToken");
                return;
            }
            try
            {
                var productApi = new ProductApi();
                var deviceApi = new DataCollectionApi();

                //查詢產品列表
                var queryJson = new QueryProductJson { ownerAppId = Constants.AppId };
                var result = productApi.QueryProduct(accessToken, queryJson);
                Console.WriteLine(result != null ? result.ToJson() : "no result");

                if (result != null && result.products != null)
                {
                    //遍歷產品，根據產品ID獲取產品信息
                    foreach (var p in result.products)
                    {
                        var detailResult = productApi.QueryProduct(accessToken, p.productId, Constants.AppId);
                        Console.WriteLine(detailResult != null ? detailResult.ToJson() : "no result");
                    }

                    //遍歷產品下面的設備信息
                    foreach (var p in result.products)
                    {
                        var deviceJson = new QueryDeviceJson { ownerAppId = Constants.AppId, productId = p.productId };
                        var deviceResult = deviceApi.BatchQueryDevice2(accessToken, deviceJson);
                        Console.WriteLine(deviceResult != null ? deviceResult.ToJson() : "no result");
                    }
                }
            }
            catch (Exception ex)
            {
                MessageUtil.ShowError(ex.Message);
            }
        }

對於設備，產品、設備組，都屬於設備的入口之一，因此設備組也是管理接口設備的一個類別，我們可以根據SDK對設備組接口進行測試，如下代碼所示。

        /// <summary>
        /// 設備分組測試
        /// </summary>
        private void btnDeviceGroup_Click(object sender, EventArgs e)
        {
            if (string.IsNullOrEmpty(accessToken))
            {
                MessageUtil.ShowTips("請先鑒權獲取AccessToken");
                return;
            }

            try
            {
                //根據自己數據修改
                var deviceId = "64bf5869-b271-4007-8db8-fab185e19c10";
                var groupName = "testGroup";
                var groupApi = new DeviceGroupApi();
                var groupJson = new CreateDeviceGroupJson()
                {
                    appId = Constants.AppId,
                    name = groupName,
                    description = "測試設備分組",
                    deviceIds = { deviceId }
                };

                //創建設備組
                var result = groupApi.CreateDeviceGroup(accessToken, groupJson);
                Console.WriteLine(result != null ? result.ToJson() : "no result");

                //查詢設備組
                var queryJson = new QueryDeviceGroupJson()
                {
                    accessAppId = Constants.AppId,
                    name = groupName
                };
                var queryResult = groupApi.QueryDeviceGroup(accessToken, queryJson);
                Console.WriteLine(queryResult != null ? queryResult.ToJson() : "no result");

                //查詢設備組成員
                if (queryResult != null && queryResult.list != null)
                {
                    foreach (var group in queryResult.list)
                    {
                        //設備明細
                        var groupResult = groupApi.GetDeviceGroup(accessToken, group.id, Constants.AppId);
                        Console.WriteLine(groupResult != null ? groupResult.ToJson() : "no result");

                        //設備組成員
                        var queryMemberJson = new QueryDeviceGroupMemberJson()
                        {
                            appId = Constants.AppId,
                            devGroupId = group.id
                        };
                        var queryMemberResult = groupApi.QueryDeviceGroupMember(accessToken, queryMemberJson);
                        Console.WriteLine(queryMemberResult != null ? queryMemberResult.ToJson() : "no result");
                    }
                }
            }
            catch (Exception ex)
            {
                MessageUtil.ShowError(ex.Message);
            }
        }

 

3、IOT業務界面管理開發

當我們把大多數接口都跑一遍，並解決相關問題后，我們就可以根據這些接口進行Web應用的開發了。

為了方便，我們把IOT相關的業務，定義在一個控制器里面，方便管理，以后如果有需要，可以拆分進行管理。

 例如，對於數據提供，主要就是分頁JSON數據的處理，方便界面控件通過Ajax進行獲取數據顯示。

例如，對於產品列表，我們構建了一個控制器方法，如下所示。

        /// <summary>
        /// 根據條件查詢產品列表,並返回對象集合(用於分頁數據顯示)
        /// </summary>
        /// <returns>指定對象的集合</returns>
        public virtual ActionResult FindProductWithPager()
        {
            var pagerInfo = GetPagerInfo();
            var sort = GetSortOrder();
            var accessToken = GetAccessToken();

            var queryJson = new QueryProductJson(pagerInfo) { ownerAppId = Constants.AppId };
            var result = productApi.QueryProduct(accessToken, queryJson);

            var list = result != null ? result.products : null;
            var totalCount = result != null ? result.totalCount : 0;

            //Json格式的要求{total:22,rows:{}}
            var jsonResult = new { total = totalCount, rows = list };
            return ToJsonContent(jsonResult);
        }

其他，如設備組、設備列表等類似的處理，都是先通過接口獲取數據，然后組裝為對應的JSON格式提供給視圖即可。

 有時候，除了列表展示外，我們可能還需要對視圖中創建、刪除、獲取單個明細的接口進行處理，如下所示是設備分組的管理接口。

 其他的業務對象也是類似的封裝，有了這些接口，我們就可以處理分頁、獲取詳細、編輯、刪除等接口的處理了。

在Web應用中定義幾個業務菜單，用來管理產品信息、設備組和設備信息。

  產品管理界面如下所示。

如果我們要查看產品明細，調用對應接口進行展示即可。

包含設備列表，我們根據產品ID獲取對應設備列表返回到界面進行展示即可，如下所示效果。

 設備分組如下所示。

 而設備列表展示可以通過產品和設備組進行限定查詢，我們如下管理這個設備列表的展示的。

 同樣，設備詳細信息，通過對應ID調用SDK接口獲取數據，並返回到視圖即可展示出來了。設備的相關信息，如下歷史數據、歷史命令等，我們也可以通過對應接口進行數據獲取返回，在界面的Tab控件進行展示即可。

 如設備歷史命令，可以獲取到相關歷史命令信息。

 以上就是對IOT應用側API接口的封裝和應用界面的管理開發，不過使用過程中，對於IOT的接口還是不夠完善，希望華為在這方便能夠繼續完善和提供良好的開發人員支持，我們也繼續關注，以便在后續項目中整合物聯網的硬件設備進行使用。