按需使用量推送（新）

接口说明

用户在云商店开通按需资源并产生使用量后，商家需通过此接口返回用户的实际使用量话单，云商店获取话单后根据使用量计费并对用户扣费。

URI

POST https://mkt.myhuaweicloud.com/api/mkp-openapi-public/global/v1/isv/usage-data

“mkt.myhuaweicloud.com”域名不可用时请使用“mkt.myhuaweicloud.cn”进行重试。

① 按需计量商品购买和使用流程

② 用完即停套餐包商品购买和使用流程

请求消息

请求参数说明请参见下表：

请求方法：POST

请求消息示例：

public class PushDemoForPublic_2_0 {

    static final String ALGO = "HmacSHA256";

    static String FORMAT = "ts=%s&nonce=%s&body=%s";

    static String ISV_ACCESS_KEY = "xxx";
        //商家秘钥-已绑定基础接口的秘钥值
    public static void main(String[] args) throws IOException {
        List<UsagePushData2> pushDataList = new ArrayList<>();
        UsagePushData2 usagePushData = new UsagePushData2();
        //实例id
        usagePushData.setInstance_id("instanceid");
        //时间格式化pattern
        DateTimeFormatter formatter = DateTimeFormat.forPattern("yyyyMMdd'T'HHmmss'Z'");
        DateTime now = DateTime.now();
        //时间自定义：开始时间
        usagePushData.setBegin_time(now.withTimeAtStartOfDay().toString(formatter));
        //时间自定义：结束时间
        usagePushData.setEnd_time(now.plusDays(1).withTimeAtStartOfDay().toString(formatter));
        //时间自定义：统计时间
        usagePushData.setRecord_time(usagePushData.getEnd_time());
        //统计用量
        usagePushData.setUsage_value("1.1");
        // 话单唯一标识
        usagePushData.setMetering_sn(UUID.randomUUID().toString());
        pushDataList.add(usagePushData);
        JSONObject requestParam = new JSONObject();
        requestParam.put("usage_records", JSONArray.parseArray(JSON.toJSONString(pushDataList)));
        String url = "https://mkt.myhuaweicloud.com/api/mkp-openapi-public/global/v1/isv/usage-data";
        Request request = new Request();
        request.setKey("xxx");
        request.setSecret("xxx");
        // 我的凭证-申请访问秘钥
        request.setMethod("POST");
        request.setUrl(url);
        request.addHeader("Host", "mkt.myhuaweicloud.com");
        // 时间戳
        String ts = System.currentTimeMillis() + "";
        // nonce 只被使用一次的任意或非重复的随机数值。
        String nonce = "number used once";
        // 生成签名
        String signature = genSignature(requestParam, nonce, ts);
        request.addHeader("ts", ts);
        request.addHeader("nonce", nonce);
        request.addHeader("signature", signature);
        request.addHeader("Content-Type", "application/json");
        request.setBody(requestParam.toJSONString());
        CloseableHttpClient client = null;
        try{
            HttpRequestBase signedRequest = Client.sign(request, Constant.SIGNATURE_ALGORITHM_SDK_HMAC_SHA256);
            client = (CloseableHttpClient) SSLCipherSuiteUtil.createHttpClient(Constant.INTERNATIONAL_PROTOCOL);
            HttpResponse response = client.execute(signedRequest);
            HttpEntity resEntity = response.getEntity();
            if (resEntity != null)
            {
                String str = EntityUtils.toString(resEntity, "UTF-8");
                System.out.println(str);
            }
        }catch (Exception e){
            System.out.println("report usage data failed");
        }finally {
            if(client!=null){
                client.close();
            }
        }
    }

    private static String toSnakeString(Object o) {
        Map<String, Object> jsonToMap =
            JsonUtils.decode(JsonUtils.encode(o), new TypeReference<Map<String, Object>>() {
            });
        Map<String, Object> toSortedMap = jsonToMap.entrySet()
            .stream()
            .collect(Collectors.toMap(e -> e.getKey(), entry -> {
                if (entry.getValue() instanceof List) {
                    return ((List<?>) entry.getValue()).stream()
                        .map(e -> JsonUtils.decode(JsonUtils.encode(e), new TypeReference<TreeMap<String, Object>>() {
                        }))
                        .collect(Collectors.toList());
                }
                return entry.getValue();
            }, (u, v) -> v));
        return JsonUtils.encode(new TreeMap<>(toSortedMap));
    }

    /**
     * 生成签名接口
     *
     * @param requestParam 请求提
     * @param nonce 随机值
     * @param timestamp 时间戳
     * @return 签名
     */
    private static String genSignature(JSONObject requestParam, String nonce, String timestamp) {
        try {
            String originSignData = String.format(FORMAT, timestamp, nonce,
                    toSnakeString(requestParam));
            Mac mac;
            mac = Mac.getInstance(ALGO);
            mac.init(new SecretKeySpec(ISV_ACCESS_KEY.getBytes(StandardCharsets.UTF_8), ALGO));
            byte[] signatureBytes = mac.doFinal(originSignData.getBytes(StandardCharsets.UTF_8));
            return Base64.getEncoder().encodeToString(signatureBytes);
        } catch (NoSuchAlgorithmException | InvalidKeyException e) {
            log.error("check signature failed for hmac hash", e);
        }
        return null;
    }

}

响应消息

响应参数说明请参见下表：

错误码：

当您调用API时，如果遇到“APIGW”开头的错误码，请参见API网关错误码进行处理。

响应消息示例：

  
{  
   "error_code":"MKT.0000",  
   "error_msg":"Success"  
} 
  
{ 
    "error_code": "94060999", 
    "error_msg": "Failed", 
    "data": { 
        "abnormal_usage_data": [ 
            { 
                "error_code": "005", 
                "error_msg": "METERING_SN_DUPLICATE", 
                "metering_sn": "6c75c177b5fe4b8cbb6fc2aa33facfcb" 
            } 
        ] 
    } 
}