JAVA:通过电信ctg.ag.sdk从电信物联平台AIOT获取设备上报数据的简单示例

一、问题场景

物联设备比如NB设备通过NB协议将数据传到电信平台后，我们的应用服务如何从电信平台获取可用的上报数据。以下通过电信开发者平台提供的SDK来简单演示下整个过程。

二、使用电信 SDK进行开发

电信AIOT物联平台提供了两种方式获取平台数据，一种是HTTP方式，一种事SDK方式。推荐使用SDK方式，因为HTTP方式调用时可能会遇到一些不通或不稳定的情况。

电信平台提供了多种SDK，本示例使用JAVA SDK开发。电信平台提供了在线API调试，在开发程序前，可以先通过在线API来验证一下请求和响应的演示过程。参见我另一篇文章介绍物联网：从电信物联开发平台AIoT获取物联设备上报数据示例

下列调用设备数据查询接口getDeviceStatusHisInPage为例。

1.下载电信sdk的jar包

点击下载地址，从电信开发者平台下载两个jar包为，ag-sdk-biz-53266.tar.gz-20240517.102115-SNAPSHOT.jar和ctg-ag-sdk-core-2.8.0-20230508.100604-1.jar。

2.引入jar依赖包

        <dependency>
            <groupId>com.ctg.ag.sdk.biz</groupId>
            <artifactId>sdkpackage</artifactId>
            <scope>system</scope>
            <version>1.0</version>
            <systemPath>${project.basedir}/lib/ag-sdk-biz-53266.tar.gz-20240517.102115-SNAPSHOT.jar</systemPath>
        </dependency>

        <dependency>
            <groupId>com.ctg.ag.sdk.core</groupId>
            <artifactId>sdkcore</artifactId>
            <scope>system</scope>
            <version>1.0</version>
            <systemPath>${project.basedir}/lib/ctg-ag-sdk-core-2.8.0-20230508.100604-1.jar</systemPath>
        </dependency>

程序实现方法源码如下：

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ctg.ag.sdk.biz.AepDeviceStatusClient;
import com.ctg.ag.sdk.biz.aep_device_status.GetDeviceStatusHisInPageRequest;
import com.ctg.ag.sdk.biz.aep_device_status.GetDeviceStatusHisInPageResponse;
   
 public ResultMsg ctGetDeviceStatusHisInPage(@RequestBody HashMap<String, Object> map) {
        String estr = "电信物联平台接口-用于测试物联上报数据 (ctGetDeviceStatusHisInPage)====:";
        ResultMsg rMsg = new ResultMsg(); //此类是返回对象类，你可以根据自己的需求来定义返回类型
        JSONObject jb;
        try {
            logger.info(estr + map.toString());
            String secret = "a2ze0b9su3";//密钥，到控制台->应用管理打开应用可以找到此值
            String appkey = "t9U2ykdRIO5";//appKey，到控制台->应用管理打开应用可以找到此值
            AepDeviceStatusClient client = AepDeviceStatusClient.newClient()
                    .appKey(appkey).appSecret(secret)
                    .build();
            //创建对应方法请求对象，不同的请求方法，对应不同的类名
            GetDeviceStatusHisInPageRequest request = new GetDeviceStatusHisInPageRequest();
            // 将入参转为json 字符串格式
            String bodyString=Comm.hashMapToJsonStr(map);
            request.setBody(bodyString.getBytes());	//具体格式见前面请求body说明
            //向电信平台发送请求
            GetDeviceStatusHisInPageResponse response= client.getDeviceStatusHisInPage(request);
            //返回响应信息
            if(response.getStatusCode()==200){
                //字符串转为json对象
                jb=Comm.strToJson(new String(response.getBody(),"UTF-8"));
                //将结果中的设备状态列表中转为数组
                JSONArray array=(JSONArray) jb.get("deviceStatusList");
                if(array==null){
                    rMsg.Clear();
                    rMsg.setResultMsg(jb.toString());
                    return rMsg;
                }
                String data,state;
                //遍历数组，逐条解码，将对应设备上报数据中的点表(字节)转换为可用数据.(下列为该示例设备的点表字符串按厂家给的位数规则进行分拆转换)
                for (int i = 0; i < array.size(); i++) {
                    jb=(JSONObject)array.get(i);
                    //base64位转为16进制
                    data=Comm.base64toHex(Comm.getString(jb.get("APPdata")));
                    jb.put("APPdata",data);
                    jb.put("imei",data.substring(4,20));
                    jb.put("sim",data.substring(50,70));
                    jb.put("curRead",Comm.hexToInt(data.substring(70,78))*0.01);//16进制转位10进制
                    jb.put("cdateTime",data.substring(78,90));
                    state=Comm.getStrAddPrefix(Comm.hexToBinary(data.substring(94,96)),"0",8);//16进制转2进制
                    jb.put("powerState",state.substring(2,4));//1x 电池正常 0x 电池欠电
                    jb.put("valveState",state.substring(4,6));//00 无阀 01 阀门关闭 10 阀门开启 11 阀门不到位
                }
                rMsg.setSuccess();
                rMsg.setList(Comm.toList(array));
            }
            logger.info(rMsg.toString());
            client.shutdown();
            return rMsg;
        } catch (Exception e) {
            map.clear();
            map.put("oper_module", estr);
            map.put("oper_content", estr + e.getMessage());
            logExceptServ.add(map);
            rMsg.setResultMsg(estr + e.getMessage());

            return rMsg;
        }
    }

以下是上述代码中使用到的方法，主要是在解析过程中使用到字节转换，你可以根据不同设备厂家提供的对应点表说明文档，依实际情况来按位数解析。本示例的设备是远传水表。

    /**
     * HashMap转json字符串
     */
    public static String hashMapToJsonStr(HashMap<String, Object> map) {
        JSONObject jObject = new JSONObject();
        for (Map.Entry<String, Object> item : map.entrySet()) {
            jObject.put(item.getKey(), item.getValue());
        }
        return jObject.toString();
    }    

    /**
     * 将Json字符串转换为Json
     * @param json
     * @return
     */
    public static JSONObject strToJson(String json) {
        // 将json字符串转换成jsonObject
        return JSONObject.parseObject(json);
    }

    // base64转16进制
    public static final String base64toHex(String str) {
        byte[] data= Base64.getDecoder().decode(str);
        final StringBuffer sb = new StringBuffer(data.length * 2);
        for (int i = 0; i < data.length; i++) {
            sb.append(DIGITS[(data[i] >>> 4) & 0x0F]);
            sb.append(DIGITS[data[i] & 0x0F]);
        }
        return sb.toString();
    }
    private static final char[] DIGITS
            = {'0', '1', '2', '3', '4', '5', '6', '7',
            '8', '9', 'A', 'B', 'C', 'D', 'E', 'F'};

    //十六进制转十进制
    public static int hexToInt(String hex) {
        return Integer.parseInt(hex,16);
    }

    /**
     * 字符串前补指定字符，指定总长度
     * @return java.lang.String
     * @Param [str 原字符串, c 前缀字符, allLen 总长度]
     * @Author quan
     * @Date 2020/12/29
     */
    public static String getStrAddPrefix(String str, String c, int allLen) {
        while (str.length() < allLen) {
            str = c + str;
        }
        return str;
    }

    //十六进制转二进制
    public static String hexToBinary(String hex) {
        int hexint = Integer.parseInt(hex, 16);
        String binary = Integer.toBinaryString(hexint);
        return binary;
    }

    /**
     * 将对象类(或json格式的字符串)解析成List对象
     * @param object json格式：[{point_ids: "49,", road_ids: "32", officer_ids: "8f08537b00d74fa2b99120f3a2a1fd9a"}]
     * @return List<Object></>
     *
     * @author qiang
     */
    public static List<Object> toList(Object object) {
        List<Object> list = new ArrayList<>();
        if(object == null || object.equals(""))
            return null;
        // 将json字符串转换成jsonObject
        JSONArray jsonArray = JSONArray.parseArray(object.toString());
        // 此时需要加个判断
        if (jsonArray.isEmpty()) {
            System.out.println("jsonArray 为空");
        } else {
            list.addAll(jsonArray);
        }
        return list;
    }

3.运行程序并调用接口后输出结果

补充说明

在引用电信SDK的两个依赖包后，本地开发环境运行正常，但若出现打包后在生产环境运行出错，提示电信jar中的某方法丢失，是因为该本地引用包没有打包到进去的原因。可以参见我这篇文章来解决：在IDEA引入本地jar包的方法并解决打包scope为system时发布无法打包进lib的方案。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/695259.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

阿里云 MQTT 服务器搭建与测试（上传和下发数据finish）

阿里云 MQTT 服务器搭建与测试（上传和下发数据finish）

一、 MQTT 概念 MQTT（Message Queuing Telemetry Transport，消息队列遥测传输协议），是一种基于发布/订阅（publish/subscribe）模式的"轻量级"通讯协议，该协议构建于 TCP/IP协议上，由 IBM 在 1999 年发布。MQTT 最大优点在于，可以以极少的代码和有限的带宽，…
阅读更多...
JVM对象分配和垃圾回收机制

JVM对象分配和垃圾回收机制

一、对象创建 1.1 符号引用 new 创建一个对象&#xff0c;需要在JVM创建对象。 符号引用&#xff1a;目标对象采用一个符号表示&#xff0c;类A加载的时候&#xff0c;如果成员变量类B还没有被加载进来&#xff0c;采用一个符号&#xff08;字面量&#xff09;来表示&#x…
阅读更多...
Vulnhub靶机之reven 1

Vulnhub靶机之reven 1

一、信息收集 nmap扫描网段&#xff0c;靶机地址为192.168.145.129。 nmap -sP 192.168.145.* 扫一下端口&#xff0c;开放了22、80、111、50967。 nmap -sT -T4 -p1-65535 192.168.145.129 再看一下目录情况&#xff0c;发现一个疑似后台登录的地址。 dirsearch -u http://…
阅读更多...
基于Python + Flask+ Mysq实现简易留言板

基于Python + Flask+ Mysq实现简易留言板

使用Python Flask Mysql实现简易留言板&#xff0c;包括网友编辑留言、修改留言&#xff0c;删除留言、分页显示四大功能。 写出留言板建设过程&#xff0c;包括开发使用工具、留言板模块设计、数据库设计、页面设计、关键技术。 留言板建设过程总结 一&#xff0e;开发使用…
阅读更多...
图像处理ASIC设计方法 笔记28 无效像元检测

图像处理ASIC设计方法 笔记28 无效像元检测

&#xff08;一&#xff09;无效像元检测 P149 基于场景的红外焦平面无效像元检测 空间噪声的两个来源1 各探测源相应的非均匀性产生 2 IRFPA组件制造过程中产生 先进的工艺水平可以做到成品期间不存在连续分布或中心分布的无效像元&#xff0c;无效像元率在0.5%以内。国内…
阅读更多...
LeetCode | 1.两数之和

LeetCode | 1.两数之和

这道题&#xff0c;很容易想到的是暴力解&#xff0c;直接一个双重循环&#xff0c;对于数组中的每一个数&#xff0c;都去遍历其他数字&#xff0c;看能不能找到数字等于target-nums[i]的数字&#xff0c;时间复杂度为 O ( n 2 ) O(n^2) O(n2) 但是通过其他题目&#xff0c;我…
阅读更多...
动态规划（多重背包+完全背包）

动态规划（多重背包+完全背包）

P2851 [USACO06DEC] 最少的硬币 G 题解&#xff1a;从题目上看到那个有n种不同的货币&#xff0c;对于买家来说每个货币有C[ i ]个&#xff0c;是有限个数的&#xff0c;但是对于卖家来说 每个货币都是无限的&#xff0c;题目中要我们求的是买到这个物品的最小交易的货币数&…
阅读更多...
transformer - 注意力机制

transformer - 注意力机制

Transformer 的注意力机制 Transformer 是一种用于自然语言处理任务的模型架构&#xff0c;依赖于注意力机制来实现高效的序列建模。注意力机制允许模型在处理一个位置的表示时&#xff0c;考虑输入序列中所有其他位置的信息&#xff0c;而不仅仅是前面的几个位置。这种机制能…
阅读更多...
3.大模型高效微调PEFT

3.大模型高效微调PEFT

大模型高效微调（PEFT）技术 预训练模型的背景 预训练与微调：传统的微调方法通常涉及对整个预训练模型的参数进行再训练，以适应特定任务。这虽然有效，但计算成本高，且需要大量的标记数据。模型结构：像BERT或GPT这样的模型通常包含数亿甚至数十亿个参数，构成一个深层次的…
阅读更多...
JWT 从入门到精通

JWT 从入门到精通

什么是 JWT JSON Web Token&#xff08;JWT&#xff09;是目前最流行的跨域身份验证解决方案 JSON Web Token Introduction - jwt.ioLearn about JSON Web Tokens, what are they, how they work, when and why you should use them.https://jwt.io/introduction 一、常见会…
阅读更多...
转型AI产品经理（6）：“ 序列位置效应”如何应用在Chatbot产品中

转型AI产品经理（6）：“ 序列位置效应”如何应用在Chatbot产品中

序列位置效应是心理学中的一个记忆现象&#xff0c;指的是人们对一系列信息的记忆效果受到信息在序列中位置的影响。具体来说&#xff0c;人们通常更容易记住列表的开头和结尾部分的项目&#xff0c;而对中间部分的项目记忆较差。这个效应可以进一步分为“首因效应”和“近因效…
阅读更多...
递归

递归

特点&#xff1a;有一个初始状态&#xff1b;后续的情况可由前面的状态推出。&#xff08;斐波拉契&#xff0c;求阶乘&#xff09; 一 .写出分段函数&#xff08;有初值&#xff0c;递推关系&#xff09;可以递归 用if-else连接
阅读更多...
Day47 代码随想录打卡|二叉树篇---最大二叉树

Day47 代码随想录打卡|二叉树篇---最大二叉树

题目&#xff08;leecode T654&#xff09;&#xff1a; 给定一个不重复的整数数组 nums 。 最大二叉树 可以用下面的算法从 nums 递归地构建: 创建一个根节点&#xff0c;其值为 nums 中的最大值。递归地在最大值 左边 的 子数组前缀上 构建左子树。递归地在最大值 右边 的 …
阅读更多...
java版多语言抢单系统 多语言海外AEON抢单可连单加额外单源码 抢单平台搭建开发 抢单开挂的软件

java版多语言抢单系统 多语言海外AEON抢单可连单加额外单源码 抢单平台搭建开发 抢单开挂的软件

此套是全新开发的java版多语言抢单系统。 后端java&#xff0c;用的若依框架&#xff0c;这套代码前后端是编译后的&#xff0c;测试可以正常使用&#xff0c;语言繁体&#xff0c;英文&#xff0c;日语 源码大小&#xff1a;155M 源码下载&#xff1a;https://download.csd…
阅读更多...
初识 java 2

初识 java 2

1. idea 的调试 1. 点击鼠标左键设置断点 2.运行到断点处 点击 或点击鼠标右键&#xff0c;再点击 使代码运行到断点处&#xff0c;得到 2. 输出到控制台 System.out.println(value);//输出指定的内容&#xff0c;并换行 value 要打印的内容System.out.print(value);…
阅读更多...
《精通ChatGPT：从入门到大师的Prompt指南》附录A：常用Prompt示例

《精通ChatGPT：从入门到大师的Prompt指南》附录A：常用Prompt示例

附录A&#xff1a;常用Prompt示例 在《精通ChatGPT&#xff1a;从入门到大师的Prompt指南》的附录A中&#xff0c;我们将展示一系列常用的Prompt示例&#xff0c;帮助读者更好地理解和应用Prompt技术。每个示例将包含Prompt的描述、使用场景、预期结果以及实际输出。希望这些示…
阅读更多...
Leetcode3040. 相同分数的最大操作数目 II

Leetcode3040. 相同分数的最大操作数目 II

Every day a Leetcode 题目来源&#xff1a;3040. 相同分数的最大操作数目 II 解法1&#xff1a;记忆化搜索 第一步可以做什么&#xff1f;做完后&#xff0c;剩下要解决的问题是什么&#xff1f; 删除前两个数&#xff0c;剩下 nums[2] 到 nums[n−1]&#xff0c;这是一个…
阅读更多...
Nvidia的成功与竞争：CEO黄仁勋的自信与挑战

Nvidia的成功与竞争：CEO黄仁勋的自信与挑战

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗&#xff1f;订阅我们的简报&#xff0c;深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同&#xff0c;从行业内部的深度分析和实用指南中受益。不要错过这个机会&#xff0c;成为AI领…
阅读更多...
【微信小程序】事件分类以及阻止事件冒泡

【微信小程序】事件分类以及阻止事件冒泡

在微信小程序中&#xff0c;事件分为冒泡事件和非冒泡事件两大类&#xff0c;它们的区别在于事件是否能从原始触发组件开始&#xff0c;向父级组件传播&#xff08;即“冒泡”&#xff09;。 冒泡事件&#xff1a;当一个组件上的事件被触发后&#xff0c;不仅当前组件会接收到这…
阅读更多...
Pytorch学习11_神经网络-卷积层

Pytorch学习11_神经网络-卷积层

1.创建神经网络实例 import torch import torchvision from torch import nn from torch.nn import Conv2d from torch.utils.data import DataLoaderdatasettorchvision.datasets.CIFAR10("../dataset_cov2d",trainFalse,transformtorchvision.transforms.ToTensor(…
阅读更多...
最新文章

Copyright @ 2022~2023