更新时间：2024-09-24 GMT+08:00
Java
注：使用前请务必先仔细阅读使用注意事项。
|
样例 |
|
|---|---|
|
环境要求 |
JDK 1.6及以上版本。 |
|
引用库 |
httpclient、httpcore、httpmime、commons-codec、commons-logging、jackson-databind、jackson-annotations、jackson-core、fastjson、log4j |
将下列代码样例复制到新建java文件中即可运行。
- 本文档所述Demo在提供服务的过程中，可能会涉及个人数据的使用，建议您遵从国家的相关法律采取足够的措施，以确保用户的个人数据受到充分的保护。
- 本文档所述Demo仅用于功能演示，不允许客户直接进行商业使用。
- 本文档信息仅供参考，不构成任何要约或承诺。
“语音回呼场景API”代码样例
package com.huawei.demo;
import java.util.HashMap;
import java.util.Map;
import javax.net.ssl.HttpsURLConnection;
import com.huawei.utils.Constant;
import com.huawei.utils.HttpsUtil;
import com.huawei.utils.JsonUtil;
import com.huawei.utils.StreamClosedHttpResponse;
import com.huawei.utils.StringUtil;
public class VoiceCallMain {
// 接口通用返回值
private static String status = "";
private static String resultcode = "";
private static String resultdesc = "";
// 语音回呼接口返回值
private static String sessionId = "";
// 语音回呼业务类实体
public static VoiceCall voiceCallAPI = new VoiceCall();
// 获取录音文件下载地址实体
public static GetRecordLink recordLinkAPI = new GetRecordLink();
// 调用接口成功标识
private static final String success = "200";
public static void main(String args[]) throws Exception {
// TODO 程序前端要求发起语音回呼,调用doVoiceCall方法.
// 以下代码仅供调试使用,实际开发时请删除
VoiceCallMain.doVoiceCall("+8653159511234", "+8613800000001", "+8653159511234", "+8613800000002");
if (status.indexOf(success) != -1) {
System.out.println(status);
System.out.println(resultcode + " " + resultdesc);
System.out.println("The session id is: " + sessionId);
}
// TODO 需要接收状态和话单时,请参考"呼叫状态和话单通知API"接口实现状态通知和话单的接收和解析.
// HostingVoiceEventDemoImpl
// TODO 需要下载录音文件时,请参照"获取录音文件下载地址API"接口获取录音文件下载地址.
String aksk = StringUtil.buildAKSKHeader(Constant.CLICK2CALL_APPID, Constant.CLICK2CALL_SECRET);
String code = recordLinkAPI.getRecordLinkAPI("1200_366_0_20161228102743.wav", "ostor.huawei.com", aksk);
if (code.indexOf("301") != -1) {
System.out.println("The record file download link is: " + recordLinkAPI.getLocation());
} else {
System.out.println("code: " + code);
System.out.println("Failed: " + recordLinkAPI.getResponsebody().toString());
}
}
/*
* 前端需要发起语音回呼时,调用此方法 该示例只仅体现必选参数,可选参数根据接口文档和实际情况配置.
*/
public static void doVoiceCall(String displayNbr, String callerNbr, String displayCalleeNbr, String calleeNbr)
throws Exception {
Boolean retry = false;
// 调用语音回呼接口,直至成功
do {
status = voiceCallAPI.voiceCallAPI(displayNbr, callerNbr, displayCalleeNbr, calleeNbr);
if (status.indexOf(success) != -1) {
retry = false;
// 调用成功,记录返回的信息.
resultcode = voiceCallAPI.getResponsePara("resultcode");
resultdesc = voiceCallAPI.getResponsePara("resultdesc");
sessionId = voiceCallAPI.getResponsePara("sessionId");
} else {
retry = true;
// 调用失败,获取错误码和错误描述.
resultcode = voiceCallAPI.getResponsePara("resultcode");
resultdesc = voiceCallAPI.getResponsePara("resultdesc");
// 处理错误
VoiceCallMain.processError();
}
} while (retry);
}
// 当API的返回值不是200时,处理错误.
private static void processError() throws InterruptedException {
// TODO 根据错误码和错误码描述处理问题
// 以下代码仅供调试使用,实际开发时请删除
System.out.println(status);
System.out.println(resultcode + " " + resultdesc);
System.exit(-1);
}
}
class VoiceCall {
// 语音回呼API的URL
private String urlVoiceCall;
// 接口响应的消息体
private Map<String, String> Responsebody;
// Https实体
private HttpsUtil httpsUtil;
public VoiceCall() {
// 商用地址
urlVoiceCall = Constant.VOICE_CALL_COMERCIAL;
Responsebody = new HashMap<>();
}
@SuppressWarnings("unchecked")
/*
* 该示例只仅体现必选参数,可选参数根据接口文档和实际情况配置. 该示例不体现参数校验,请根据各参数的格式要求自行实现校验功能.
*/
public String voiceCallAPI(String displayNbr, String callerNbr, String displayCalleeNbr, String calleeNbr)
throws Exception {
httpsUtil = new HttpsUtil();
// 忽略证书信任问题
httpsUtil.trustAllHttpsCertificates();
HttpsURLConnection.setDefaultHostnameVerifier(httpsUtil.hv);
// 请求Headers
Map<String, String> headerMap = new HashMap<>();
headerMap.put(Constant.HEADER_APP_AUTH, Constant.AUTH_HEADER_VALUE);
headerMap.put(Constant.HEADER_APP_AKSK,
StringUtil.buildAKSKHeader(Constant.CLICK2CALL_APPID, Constant.CLICK2CALL_SECRET));
// 构造消息体
Map<String, String> bodys = new HashMap<String, String>();
bodys.put("displayNbr", displayNbr);//主叫用户手机终端的来电显示号码。
bodys.put("callerNbr", callerNbr);//发起呼叫时所使用的主叫号码。
bodys.put("displayCalleeNbr", displayCalleeNbr);//被叫用户终端的来电显示号码。
bodys.put("calleeNbr", calleeNbr);//发起呼叫时所拨打的被叫号码。
String jsonRequest = JsonUtil.jsonObj2Sting(bodys);
/*
* Content-Type为application/json且请求方法为post时, 使用doPostJsonGetStatusLine方法构造http
* request并获取响应.
*/
StreamClosedHttpResponse responseVoiceCall = httpsUtil.doPostJsonGetStatusLine(urlVoiceCall, headerMap,
jsonRequest);
// 响应的消息体写入Responsebody.
Responsebody = JsonUtil.jsonString2SimpleObj(responseVoiceCall.getContent(), Responsebody.getClass());
// 返回响应的status.
return responseVoiceCall.getStatusLine().toString();
}
// 获取整个响应消息体
public Map<String, String> getResponsebody() {
return this.Responsebody;
}
// 获取响应消息体中的单个参数
public String getResponsePara(String ParaName) {
return this.Responsebody.get(ParaName);
}
}
“获取录音文件下载地址API”代码样例
package com.huawei.demo;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.net.ssl.HttpsURLConnection;
import org.apache.http.NameValuePair;
import org.apache.http.message.BasicNameValuePair;
import com.huawei.utils.Constant;
import com.huawei.utils.HttpsUtil;
import com.huawei.utils.JsonUtil;
import com.huawei.utils.StreamClosedHttpResponse;
public class GetRecordLink {
// 获取录音文件下载地址API的URL
private String urlRecordFile;
// Https实体
private HttpsUtil httpsUtil;
// 接口响应的消息体
private Map<String, String> Responsebody;
// 录音文件下载地址
private String Location;
public GetRecordLink() {
// 商用地址
urlRecordFile = Constant.VOICE_FILE_DOWNLOAD;
Responsebody = new HashMap<>();
}
@SuppressWarnings("unchecked")
public String getRecordLinkAPI(String fileName, String recordDomain, String aksk) throws Exception {
httpsUtil = new HttpsUtil();
// 忽略证书信任问题
httpsUtil.trustAllHttpsCertificates();
HttpsURLConnection.setDefaultHostnameVerifier(httpsUtil.hv);
// 构造URL
List<NameValuePair> keyValues = new ArrayList<NameValuePair>();
keyValues.add(new BasicNameValuePair("fileName", fileName));
keyValues.add(new BasicNameValuePair("recordDomain", recordDomain));
// 请求Headers
Map<String, String> headerMap = new HashMap<>();
headerMap.put(Constant.HEADER_APP_AUTH, Constant.AUTH_HEADER_VALUE);
headerMap.put(Constant.HEADER_APP_AKSK, aksk);
/*
* Content-Type为application/json且请求方法为get时, 使用doGetWithParasGetStatusLine方法构造http
* request并获取响应.
*/
StreamClosedHttpResponse respRecordLink = httpsUtil.doGetWithParasGetStatusLine(urlRecordFile, keyValues,
headerMap);
// 响应的消息体写入Responsebody.
Responsebody = JsonUtil.jsonString2SimpleObj(respRecordLink.getContent(), Responsebody.getClass());
// 从响应头域中获取location.
String code = respRecordLink.getStatusLine().toString();
if (code.indexOf("301") != -1) {
Location = respRecordLink.getFirstHeader("Location").getValue();
} else {
Location = "";
}
// 返回响应的status.
return code;
}
// 获取整个响应消息体
public Map<String, String> getResponsebody() {
return this.Responsebody;
}
// 获取响应消息体中的单个参数
public String getResponsePara(String ParaName) {
return this.Responsebody.get(ParaName);
}
// 获取location
public String getLocation() {
return this.Location;
}
}
“呼叫状态通知API”与“话单通知API”代码样例
package com.huawei.demo;
import org.apache.log4j.Logger;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
/**
* 呼叫事件通知/话单通知
* 客户平台收到RTC业务平台的呼叫事件通知/话单通知的接口通知
*/
public class HostingVoiceEventDemoImpl {
private static Logger logger = Logger.getLogger(HostingVoiceEventDemoImpl.class);
/**
* 呼叫事件 for 语音回呼/语音通知/语音验证码
*
* @param jsonBody
* @breif 详细内容以接口文档为准
*/
public static void onCallEvent(String jsonBody) {
// 封装JOSN请求
JSONObject json = JSON.parseObject(jsonBody);
String eventType = json.getString("eventType"); // 通知事件类型
if ("fee".equalsIgnoreCase(eventType)) {
logger.info("EventType error: " + eventType);
return;
}
if (!(json.containsKey("statusInfo"))) {
logger.info("param error: no statusInfo.");
return;
}
JSONObject statusInfo = json.getJSONObject("statusInfo"); // 呼叫状态事件信息
logger.info("eventType: " + eventType); // 打印通知事件类型
//callout：呼出事件
if ("callout".equalsIgnoreCase(eventType)) {
/**
* Example: 此处以解析sessionId为例,请按需解析所需参数并自行实现相关处理
*
* 'timestamp': 该呼叫事件发生时RTC业务平台的UNIX时间戳
* 'userData': 用户附属信息
* 'sessionId': 通话链路的标识ID
* 'caller': 主叫号码
* 'called': 被叫号码
*/
if (statusInfo.containsKey("sessionId")) {
logger.info("sessionId: " + statusInfo.getString("sessionId"));
}
return;
}
//alerting：振铃事件
if ("alerting".equalsIgnoreCase(eventType)) {
/**
* Example: 此处以解析sessionId为例,请按需解析所需参数并自行实现相关处理
*
* 'timestamp': 该呼叫事件发生时RTC业务平台的UNIX时间戳
* 'userData': 用户附属信息
* 'sessionId': 通话链路的标识ID
* 'caller': 主叫号码
* 'called': 被叫号码
*/
if (statusInfo.containsKey("sessionId")) {
logger.info("sessionId: " + statusInfo.getString("sessionId"));
}
return;
}
//answer：应答事件
if ("answer".equalsIgnoreCase(eventType)) {
/**
* Example: 此处以解析sessionId为例,请按需解析所需参数并自行实现相关处理
*
* 'timestamp': 该呼叫事件发生时RTC业务平台的UNIX时间戳
* 'userData': 用户附属信息
* 'sessionId': 通话链路的标识ID
* 'caller': 主叫号码
* 'called': 被叫号码
*/
if (statusInfo.containsKey("sessionId")) {
logger.info("sessionId: " + statusInfo.getString("sessionId"));
}
return;
}
//collectInfo：放音收号结果事件,仅应用于语音通知场景
if ("collectInfo".equalsIgnoreCase(eventType)) {
/**
* Example: 此处以解析digitInfo为例,请按需解析所需参数并自行实现相关处理
*
* 'timestamp': 该呼叫事件发生时RTC业务平台的UNIX时间戳
* 'sessionId': 通话链路的标识ID
* 'digitInfo': 放音收号场景中,RTC业务平台对开发者进行放音收号操作的结果描述
*/
if (statusInfo.containsKey("digitInfo")) {
logger.info("digitInfo: " + statusInfo.getString("digitInfo"));
}
return;
}
//disconnect：挂机事件
if ("disconnect".equalsIgnoreCase(eventType)) {
/**
* Example: 此处以解析sessionId为例,请按需解析所需参数并自行实现相关处理
*
* 'timestamp': 该呼叫事件发生时RTC业务平台的UNIX时间戳
* 'userData': 用户附属信息
* 'sessionId': 通话链路的标识ID
* 'caller': 主叫号码
* 'called': 被叫号码
* 'partyType': 挂机的用户类型,仅在语音回呼场景携带
* 'stateCode': 通话挂机的原因值
* 'stateDesc': 通话挂机的原因值的描述
*/
if (statusInfo.containsKey("sessionId")) {
logger.info("sessionId: " + statusInfo.getString("sessionId"));
}
return;
}
}
/**
* 话单通知 for 语音回呼/语音通知/语音验证码
*
* @param jsonBody
* @breif 详细内容以接口文档为准
*/
public static void onFeeEvent(String jsonBody) {
// 封装JSON请求
JSONObject json = JSON.parseObject(jsonBody);
String eventType = json.getString("eventType"); // 通知事件类型
if (!("fee".equalsIgnoreCase(eventType))) {
logger.info("EventType error: " + eventType);
return;
}
if (!(json.containsKey("feeLst"))) {
logger.info("param error: no feeLst.");
return;
}
JSONArray feeLst = json.getJSONArray("feeLst"); // 呼叫话单事件信息
/**
* Example: 此处以解析sessionId为例,请按需解析所需参数并自行实现相关处理
*
* 'direction': 通话的呼叫方向,以RTC业务平台为基准
* 'spId': 客户的云服务账号
* 'appKey': 应用的app_key
* 'icid': 呼叫记录的唯一标识
* 'bindNum': 发起此次呼叫的CallEnabler业务号码
* 'sessionId': 通话链路的唯一标识
* 'callerNum': 主叫号码
* 'calleeNum': 被叫号码
* 'fwdDisplayNum': 转接呼叫时的显示号码(仅语音回呼场景携带)
* 'fwdDstNum': 转接呼叫时的转接号码(仅语音回呼场景携带)
* 'fwdStartTime': 转接呼叫操作的开始时间(仅语音回呼场景携带)
* 'fwdAlertingTime': 转接呼叫操作后的振铃时间(仅语音回呼场景携带)
* 'fwdAnswerTime': 转接呼叫操作后的应答时间(仅语音回呼场景携带)
* 'callEndTime': 呼叫结束时间
* 'fwdUnaswRsn': 转接呼叫操作失败的Q850原因值
* 'failTime': 呼入,呼出的失败时间
* 'ulFailReason': 通话失败的拆线点
* 'sipStatusCode': 呼入,呼出的失败SIP状态码
* 'callOutStartTime': Initcall的呼出开始时间
* 'callOutAlertingTime': Initcall的呼出振铃时间
* 'callOutAnswerTime': Initcall的呼出应答时间
* 'callOutUnaswRsn': Initcall的呼出失败的Q850原因值
* 'dynIVRStartTime': 自定义动态IVR开始时间(仅语音通知场景携带)
* 'dynIVRPath': 自定义动态IVR按键路径(仅语音通知场景携带)
* 'recordFlag': 录音标识
* 'recordStartTime': 录音开始时间(仅语音回呼场景携带)
* 'recordObjectName': 录音文件名(仅语音回呼场景携带)
* 'recordBucketName': 录音文件所在的目录名(仅语音回呼场景携带)
* 'recordDomain': 存放录音文件的域名(仅语音回呼场景携带)
* 'recordFileDownloadUrl': 录音文件下载地址(仅语音回呼场景携带)
* 'ttsPlayTimes': 应用TTS功能时,使用TTS的总次数
* 'ttsTransDuration': 应用TTS功能时,TTS Server进行TTS转换的总时长(单位为秒)
* 'serviceType': 携带呼叫的业务类型信息
* 'hostName': 话单生成的服务器设备对应的主机名
* 'userData': 用户附属信息
*/
//短时间内有多个通话结束时RTC业务平台会将话单合并推送,每条消息最多携带50个话单
if (feeLst.size() > 1) {
for (Object loop : feeLst) {
if (((JSONObject)loop).containsKey("sessionId")) {
logger.info("sessionId: " + ((JSONObject)loop).getString("sessionId"));
}
}
} else if (feeLst.size() == 1) {
if (feeLst.getJSONObject(0).containsKey("sessionId")) {
logger.info("sessionId: " + feeLst.getJSONObject(0).getString("sessionId"));
}
} else {
logger.info("feeLst error: no element.");
}
}
}
父主题： 语音回呼代码样例
