电信物联网平台，java后台对接电信北向应用，命令下发到设备

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 /**
     * 登录认证获取token
     * Authentication锛実et token
     * */
    @SuppressWarnings("unchecked")
    public static Map<String, String> login(HttpsUtil httpsUtil) throws Exception {
        String appId = Constant.APPID;
        String secret = Constant.SECRET;
        String urlLogin = "https://server:port/iocm/app/sec/v1.1.0/login";
        Map<String, String> paramLogin = new HashMap<String, String>();
        paramLogin.put("appId", appId);
        paramLogin.put("secret", secret);
        StreamClosedHttpResponse responseLogin = httpsUtil.doPostFormUrlEncodedGetStatusLine(urlLogin, paramLogin);
        System.out.println("app auth success,return accessToken:");
        System.out.print(responseLogin.getStatusLine());
        System.out.println(responseLogin.getContent());
        Map<String, String> data = new HashMap<String, String>();
        return JsonUtil.jsonString2SimpleObj(responseLogin.getContent(), data.getClass());
    }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
/**
     * 2.5.1 订阅平台业务数据,设备数据变化
     * @param httpsUtil
     * @param accessToken
     * @throws Exception 
     */
    public static int deviceDataChanged(HttpsUtil httpsUtil,String accessToken,String callbackUrl,String notifyType) throws Exception{
    	String appId = Constant.APPID; // please replace the appId, when you use the demo.
        Map<String, Object> paramSubscribe = new HashMap<String, Object>();
	    paramSubscribe.put("appId", appId);
	    paramSubscribe.put("callbackUrl", callbackUrl);
	    paramSubscribe.put("notifyType", notifyType);
	    String jsonRequest = JsonUtil.jsonObj2Sting(paramSubscribe);
	    Map<String, String> header = new HashMap<String, String>();
	    header.put(Constant.HEADER_APP_KEY, appId);
	    header.put(Constant.HEADER_APP_AUTH, "Bearer" + " " + accessToken);
	    HttpResponse httpResponse = httpsUtil.doPostJson(Constant.paltform_data_changed_url, header, jsonRequest);
	    String bodySubscribe = httpsUtil.getHttpResponseBody(httpResponse);
	    System.out.println(httpResponse.getStatusLine());
	    System.out.println(bodySubscribe);
	    return httpResponse.getStatusLine().getStatusCode();
    }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 /**
     * 下发数据到设备
     * @create 2019年2月15日 下午4:33:57
     * @since 
     * @param httpsUtil
     * @param accessToken
     * @param deviceId
     * @param data
     * @throws Exception
     */
    public static void postCommand(HttpsUtil httpsUtil,String accessToken,String deviceId,String data)throws Exception{
        String urlPostAsynCmd = Constant.POST_ASYN_CMD;
        String appId = Constant.APPID;
        String callbackUrl = "http://xxxxx.com/service-api/dx/callbackUrl";
        String serviceId = "BodyFatScaleInfo";
        String method = "bodyfatscalecmd";
        
        ObjectNode paras = JsonUtil.convertObject2ObjectNode("{"cmd_data_info":""+data+""}");
      
        Map<String, Object> paramCommand = new HashMap<String, Object>();
        paramCommand.put("serviceId", serviceId);
        paramCommand.put("method", method);
        paramCommand.put("paras", paras);      
        
        Map<String, Object> paramPostAsynCmd = new HashMap<String, Object>();
        paramPostAsynCmd.put("deviceId", deviceId);
        paramPostAsynCmd.put("command", paramCommand);
        paramPostAsynCmd.put("callbackUrl", callbackUrl);
        paramPostAsynCmd.put("expireTime", 86400); //有效期一年(一天)
        String jsonRequest = JsonUtil.jsonObj2Sting(paramPostAsynCmd);
        Map<String, String> header = new HashMap<String, String>();
        header.put(Constant.HEADER_APP_KEY, appId);
        header.put(Constant.HEADER_APP_AUTH, "Bearer" + " " + accessToken);
        HttpResponse responsePostAsynCmd = httpsUtil.doPostJson(urlPostAsynCmd, header, jsonRequest);
        String responseBody = httpsUtil.getHttpResponseBody(responsePostAsynCmd);
        System.out.println("PostAsynCommand, response content:");
        System.out.print(responsePostAsynCmd.getStatusLine());
        System.out.println(responseBody);
    }