按需使用量推送（新）-j9九游会登录

接口说明

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

sdk请参考。

如何获取ak/sk请参考。

uri

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

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

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

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

请求消息示例：

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 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.set;
        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 jsontomap =
            jsonutils.decode(jsonutils.encode(o), new typereference>() {
            });
        map 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>() {
                        }))
                        .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;
    }
}

1、接口调用上传时，如果话单数据异常，不会在接口层进行报错；后台定时任务会对上传的数据进行校验和处理，生成可以使用的话单数据。如果后台数据处理失败，需要商家重新进行上报。

异常数据可以在 “” 进行查看！

2、话单上报周期要求：

• 按小时计费

  需要至少每小时上报一次话单数据，且最好在消费时间下一个小时的0-15分钟内完成上报，譬如，用户消费时间在13:25，最好在14:00-14:15内上报，这样能及时给用户扣费，否则就会出现扣费延迟，如果无法实现实时上报，需要在2小时完成上报

• 按天计费

  推荐每小时将已经明确的用量话单上报到云商店，如果必须每天汇总上报一次，需要保证必须在次日的00:00-00:15内完成上报，最大不能超过01:00，否则用户的扣费会延迟到下一天

3、话单数据上报要求：

• 资源未关闭：
• 话单开始时间（begin_time）≥资源开始时间
• 话单开始时间（begin_time）≤ 话单结束时间（end_time）≤ 话单上报时间
• 资源关闭后：
• 话单结束时间（end_time）≤ 资源关闭时间

4、话单上报中的时间为utc 时间，与北京时间相差 8 小时；

5、同一个记录的时间，即begin_time 和end_time 时间都一致的情况下，如多次上报记录，会被识别为重复话单，只会处理第一条数据，一旦话单采集后形成正式账单将无法逆向错误话单（话单采集时间：按天计费为每天凌晨1点，按小时计费为每小时15分）。

重复话单将视为异常，异常数据可以在 “” 进行查看！

6、使用量推送接口使用按需接口返回的实例id，不能使用套餐包返回的实例id。

 
{ 
   "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"
            }
        ]
    }
}