| | |
|---|
| | | package com.stylefeng.guns.modular.system.util; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.aliyuncs.CommonRequest; |
|---|
| | | import com.aliyuncs.CommonResponse; |
|---|
| | | import com.aliyuncs.DefaultAcsClient; |
|---|
| | | import com.aliyuncs.IAcsClient; |
|---|
| | | import com.aliyuncs.exceptions.ClientException; |
|---|
| | | import com.aliyuncs.exceptions.ServerException; |
|---|
| | | import com.aliyuncs.http.MethodType; |
|---|
| | | import com.aliyuncs.profile.DefaultProfile; |
|---|
| | | import com.stylefeng.guns.core.util.MD5Util; |
|---|
| | | import org.apache.commons.codec.binary.Base64; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 中国移动工具类 |
|---|
| | | */ |
|---|
| | | @Component |
|---|
| | | public class ChinaMobileUtil { |
|---|
| | | |
|---|
| | | private static String APIKey = "LTAI4G1BpRaihVRZp1RS8Stn"; |
|---|
| | | |
|---|
| | | private static String SecretKey = "PDR7uUEGNf0wIPPVCPCVdySgTwCr90"; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private HttpClientUtil httpClientUtil; |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 绑定小号 |
|---|
| | | * @param phoneA |
|---|
| | | * @param phoneB |
|---|
| | | * @param areaCode |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | public static Map<String, String> midAxbBindSend(String phoneA, String phoneB, Integer areaCode) throws Exception{ |
|---|
| | | Map<String, String> map1 = new HashMap<>(); |
|---|
| | | map1.put("code", "-1"); |
|---|
| | | map1.put("msg", ""); |
|---|
| | | map1.put("telX", ""); |
|---|
| | | map1.put("bindId", ""); |
|---|
| | | return map1; |
|---|
| | | //暂时屏蔽-后期放开 |
|---|
| | | /*DefaultProfile profile = DefaultProfile.getProfile( |
|---|
| | | "cn-hangzhou", // 地域ID |
|---|
| | | APIKey, // 您的AccessKey ID |
|---|
| | | SecretKey ); // 您的AccessKey Secret |
|---|
| | | IAcsClient client = new DefaultAcsClient(profile); |
|---|
| | | |
|---|
| | | CommonRequest request = new CommonRequest(); |
|---|
| | | request.setMethod(MethodType.POST); |
|---|
| | | request.setDomain("dyplsapi.aliyuncs.com"); |
|---|
| | | request.setVersion("2017-05-25"); |
|---|
| | | request.setAction("BindAxb"); |
|---|
| | | // 绑定关系的过期时间。必须晚于当前时间1分钟以上。 |
|---|
| | | request.putQueryParameter("Expiration", DateUtil.format(new Date(new Date().getTime()+7 * 24 * 60 * 60*1000L),"yyyy-MM-dd HH:mm:ss")); |
|---|
| | | // 号码池Key |
|---|
| | | request.putQueryParameter("PoolKey", "FC100000119206151"); |
|---|
| | | // AXB中的B号码 |
|---|
| | | request.putQueryParameter("PhoneNoB", phoneB); |
|---|
| | | // AXB中的A号码 |
|---|
| | | request.putQueryParameter("PhoneNoA", phoneA); |
|---|
| | | // 指定城市进行X号码的选号。 |
|---|
| | | request.putQueryParameter("ExpectCity", "北京"); |
|---|
| | | // 是否需要针对该绑定关系产生的所有通话录制通话录音。 |
|---|
| | | request.putQueryParameter("IsRecordingEnabled", "false"); |
|---|
| | | Map<String, String> map1 = new HashMap<>(); |
|---|
| | | try { |
|---|
| | | CommonResponse response = client.getCommonResponse(request); |
|---|
| | | // 处理请求结果 |
|---|
| | | System.out.println(response.getData()); |
|---|
| | | JSONObject jsonObject = JSONObject.parseObject(response.getData()); |
|---|
| | | if(jsonObject.getString("Code").equals("OK")){ |
|---|
| | | map1.put("code", "200"); |
|---|
| | | map1.put("msg", jsonObject.getString("Message")); |
|---|
| | | map1.put("telX", jsonObject.getJSONObject("SecretBindDTO").getString("SecretNo")); |
|---|
| | | map1.put("bindId", jsonObject.getJSONObject("SecretBindDTO").getString("SubsId")); |
|---|
| | | }else{ |
|---|
| | | map1.put("code", jsonObject.getString("Code")); |
|---|
| | | map1.put("msg", jsonObject.getString("Message")); |
|---|
| | | } |
|---|
| | | } catch (ServerException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | map1.put("code", "-1"); |
|---|
| | | map1.put("msg", e.getErrMsg()); |
|---|
| | | } catch (ClientException e) { |
|---|
| | | System.out.println("ErrCode:" + e.getErrCode()); |
|---|
| | | System.out.println("ErrMsg:" + e.getErrMsg()); |
|---|
| | | System.out.println("RequestId:" + e.getRequestId()); |
|---|
| | | map1.put("code", "-1"); |
|---|
| | | map1.put("msg", e.getErrMsg()); |
|---|
| | | } |
|---|
| | | return map1;*/ |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 解绑小号关系 |
|---|
| | | * @param bindId 绑定关系id |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | public static Map<String, String> midAxbUnBindSend(String bindId,String secretNo) throws Exception{ |
|---|
| | | DefaultProfile profile = DefaultProfile.getProfile( |
|---|
| | | "cn-hangzhou", // 地域ID |
|---|
| | | APIKey, // 您的AccessKey ID |
|---|
| | | SecretKey ); // 您的AccessKey Secret |
|---|
| | | IAcsClient client = new DefaultAcsClient(profile); |
|---|
| | | |
|---|
| | | CommonRequest request = new CommonRequest(); |
|---|
| | | request.setMethod(MethodType.POST); |
|---|
| | | request.setDomain("dyplsapi.aliyuncs.com"); |
|---|
| | | request.setVersion("2017-05-25"); |
|---|
| | | request.setAction("UnbindSubscription"); |
|---|
| | | // 绑定关系的过期时间。必须晚于当前时间1分钟以上。 |
|---|
| | | // 号码池Key |
|---|
| | | request.putQueryParameter("PoolKey", "FC100000119206151"); |
|---|
| | | // 隐私号码。调用BindAXG等号码绑定接口时指定或自动分配的X号码。 |
|---|
| | | request.putQueryParameter("SecretNo", secretNo); |
|---|
| | | // 绑定关系ID。 |
|---|
| | | //package com.stylefeng.guns.modular.system.util; |
|---|
| | | // |
|---|
| | | //可以在控制台的号码管理 > 号码详情中查看绑定关系ID，或者在调用BindAxb等号码绑定API时查看返回参数中的SubsId。 |
|---|
| | | request.putQueryParameter("SubsId", bindId); |
|---|
| | | Map<String, String> map1 = new HashMap<>(); |
|---|
| | | try { |
|---|
| | | CommonResponse response = client.getCommonResponse(request); |
|---|
| | | // 处理请求结果 |
|---|
| | | System.out.println(response.getData()); |
|---|
| | | JSONObject jsonObject = JSONObject.parseObject(response.getData()); |
|---|
| | | if(jsonObject.getString("Code").equals("OK")){ |
|---|
| | | map1.put("code", "200"); |
|---|
| | | map1.put("msg", jsonObject.getString("Message")); |
|---|
| | | }else{ |
|---|
| | | map1.put("code", jsonObject.getString("Code")); |
|---|
| | | map1.put("msg", jsonObject.getString("Message")); |
|---|
| | | } |
|---|
| | | } catch (ServerException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | map1.put("code", "-1"); |
|---|
| | | map1.put("msg", e.getErrMsg()); |
|---|
| | | } catch (ClientException e) { |
|---|
| | | System.out.println("ErrCode:" + e.getErrCode()); |
|---|
| | | System.out.println("ErrMsg:" + e.getErrMsg()); |
|---|
| | | System.out.println("RequestId:" + e.getRequestId()); |
|---|
| | | map1.put("code", "-1"); |
|---|
| | | map1.put("msg", e.getErrMsg()); |
|---|
| | | } |
|---|
| | | return map1; |
|---|
| | | } |
|---|
| | | |
|---|
| | | public static void main(String[] args) throws IOException { |
|---|
| | | try{ |
|---|
| | | // System.out.println(midAxbBindSend("18380476116","13688394165",null)); |
|---|
| | | System.out.println(midAxbUnBindSend("1000031640138366","17150145472")); |
|---|
| | | }catch (Exception e){ |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | public Map<String, String> HeaderUtils(String APIKey, String SecretKey) throws Exception{ |
|---|
| | | Map<String, String> header = new HashMap<>(); |
|---|
| | | long time = System.currentTimeMillis(); |
|---|
| | | String signStr = MD5Util.encrypt(APIKey + SecretKey + time); |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | jsonObject.put("apiKey", APIKey); |
|---|
| | | jsonObject.put("time", time); |
|---|
| | | jsonObject.put("sign", signStr); |
|---|
| | | Base64 base64 = new Base64(); |
|---|
| | | String s = base64.encodeToString(jsonObject.toJSONString().getBytes("UTF-8")); |
|---|
| | | header.put("header", s); |
|---|
| | | |
|---|
| | | jsonObject = new JSONObject(); |
|---|
| | | jsonObject.put("platformId", ""); |
|---|
| | | jsonObject.put("secret", ""); |
|---|
| | | s = base64.encodeToString(jsonObject.toJSONString().getBytes("UTF-8")); |
|---|
| | | header.put("accessCode", s); |
|---|
| | | return header; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //import com.alibaba.fastjson.JSONObject; |
|---|
| | | //import com.aliyuncs.CommonRequest; |
|---|
| | | //import com.aliyuncs.CommonResponse; |
|---|
| | | //import com.aliyuncs.DefaultAcsClient; |
|---|
| | | //import com.aliyuncs.IAcsClient; |
|---|
| | | //import com.aliyuncs.exceptions.ClientException; |
|---|
| | | //import com.aliyuncs.exceptions.ServerException; |
|---|
| | | //import com.aliyuncs.http.MethodType; |
|---|
| | | //import com.aliyuncs.profile.DefaultProfile; |
|---|
| | | //import com.stylefeng.guns.core.util.MD5Util; |
|---|
| | | //import org.apache.commons.codec.binary.Base64; |
|---|
| | | //import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | //import org.springframework.stereotype.Component; |
|---|
| | | // |
|---|
| | | //import java.io.IOException; |
|---|
| | | //import java.util.HashMap; |
|---|
| | | //import java.util.Map; |
|---|
| | | // |
|---|
| | | ///** |
|---|
| | | // * 中国移动工具类 |
|---|
| | | // */ |
|---|
| | | //@Component |
|---|
| | | //public class ChinaMobileUtil { |
|---|
| | | // |
|---|
| | | // private static String APIKey = "LTAI4G1BpRaihVRZp1RS8Stn"; |
|---|
| | | // |
|---|
| | | // private static String SecretKey = "PDR7uUEGNf0wIPPVCPCVdySgTwCr90"; |
|---|
| | | // |
|---|
| | | // @Autowired |
|---|
| | | // private HttpClientUtil httpClientUtil; |
|---|
| | | // |
|---|
| | | // |
|---|
| | | // /** |
|---|
| | | // * 绑定小号 |
|---|
| | | // * @param phoneA |
|---|
| | | // * @param phoneB |
|---|
| | | // * @param areaCode |
|---|
| | | // * @return |
|---|
| | | // * @throws Exception |
|---|
| | | // */ |
|---|
| | | // public static Map<String, String> midAxbBindSend(String phoneA, String phoneB, Integer areaCode) throws Exception{ |
|---|
| | | // Map<String, String> map1 = new HashMap<>(); |
|---|
| | | // map1.put("code", "-1"); |
|---|
| | | // map1.put("msg", ""); |
|---|
| | | // map1.put("telX", ""); |
|---|
| | | // map1.put("bindId", ""); |
|---|
| | | // return map1; |
|---|
| | | // //暂时屏蔽-后期放开 |
|---|
| | | // /*DefaultProfile profile = DefaultProfile.getProfile( |
|---|
| | | // "cn-hangzhou", // 地域ID |
|---|
| | | // APIKey, // 您的AccessKey ID |
|---|
| | | // SecretKey ); // 您的AccessKey Secret |
|---|
| | | // IAcsClient client = new DefaultAcsClient(profile); |
|---|
| | | // |
|---|
| | | // CommonRequest request = new CommonRequest(); |
|---|
| | | // request.setMethod(MethodType.POST); |
|---|
| | | // request.setDomain("dyplsapi.aliyuncs.com"); |
|---|
| | | // request.setVersion("2017-05-25"); |
|---|
| | | // request.setAction("BindAxb"); |
|---|
| | | // // 绑定关系的过期时间。必须晚于当前时间1分钟以上。 |
|---|
| | | // request.putQueryParameter("Expiration", DateUtil.format(new Date(new Date().getTime()+7 * 24 * 60 * 60*1000L),"yyyy-MM-dd HH:mm:ss")); |
|---|
| | | // // 号码池Key |
|---|
| | | // request.putQueryParameter("PoolKey", "FC100000119206151"); |
|---|
| | | // // AXB中的B号码 |
|---|
| | | // request.putQueryParameter("PhoneNoB", phoneB); |
|---|
| | | // // AXB中的A号码 |
|---|
| | | // request.putQueryParameter("PhoneNoA", phoneA); |
|---|
| | | // // 指定城市进行X号码的选号。 |
|---|
| | | // request.putQueryParameter("ExpectCity", "北京"); |
|---|
| | | // // 是否需要针对该绑定关系产生的所有通话录制通话录音。 |
|---|
| | | // request.putQueryParameter("IsRecordingEnabled", "false"); |
|---|
| | | // Map<String, String> map1 = new HashMap<>(); |
|---|
| | | // try { |
|---|
| | | // CommonResponse response = client.getCommonResponse(request); |
|---|
| | | // // 处理请求结果 |
|---|
| | | // System.out.println(response.getData()); |
|---|
| | | // JSONObject jsonObject = JSONObject.parseObject(response.getData()); |
|---|
| | | // if(jsonObject.getString("Code").equals("OK")){ |
|---|
| | | // map1.put("code", "200"); |
|---|
| | | // map1.put("msg", jsonObject.getString("Message")); |
|---|
| | | // map1.put("telX", jsonObject.getJSONObject("SecretBindDTO").getString("SecretNo")); |
|---|
| | | // map1.put("bindId", jsonObject.getJSONObject("SecretBindDTO").getString("SubsId")); |
|---|
| | | // }else{ |
|---|
| | | // map1.put("code", jsonObject.getString("Code")); |
|---|
| | | // map1.put("msg", jsonObject.getString("Message")); |
|---|
| | | // } |
|---|
| | | // } catch (ServerException e) { |
|---|
| | | // e.printStackTrace(); |
|---|
| | | // map1.put("code", "-1"); |
|---|
| | | // map1.put("msg", e.getErrMsg()); |
|---|
| | | // } catch (ClientException e) { |
|---|
| | | // System.out.println("ErrCode:" + e.getErrCode()); |
|---|
| | | // System.out.println("ErrMsg:" + e.getErrMsg()); |
|---|
| | | // System.out.println("RequestId:" + e.getRequestId()); |
|---|
| | | // map1.put("code", "-1"); |
|---|
| | | // map1.put("msg", e.getErrMsg()); |
|---|
| | | // } |
|---|
| | | // return map1;*/ |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // |
|---|
| | | // /** |
|---|
| | | // * 解绑小号关系 |
|---|
| | | // * @param bindId 绑定关系id |
|---|
| | | // * @return |
|---|
| | | // * @throws Exception |
|---|
| | | // */ |
|---|
| | | // public static Map<String, String> midAxbUnBindSend(String bindId,String secretNo) throws Exception{ |
|---|
| | | // DefaultProfile profile = DefaultProfile.getProfile( |
|---|
| | | // "cn-hangzhou", // 地域ID |
|---|
| | | // APIKey, // 您的AccessKey ID |
|---|
| | | // SecretKey ); // 您的AccessKey Secret |
|---|
| | | // IAcsClient client = new DefaultAcsClient(profile); |
|---|
| | | // |
|---|
| | | // CommonRequest request = new CommonRequest(); |
|---|
| | | // request.setMethod(MethodType.POST); |
|---|
| | | // request.setDomain("dyplsapi.aliyuncs.com"); |
|---|
| | | // request.setVersion("2017-05-25"); |
|---|
| | | // request.setAction("UnbindSubscription"); |
|---|
| | | // // 绑定关系的过期时间。必须晚于当前时间1分钟以上。 |
|---|
| | | // // 号码池Key |
|---|
| | | // request.putQueryParameter("PoolKey", "FC100000119206151"); |
|---|
| | | // // 隐私号码。调用BindAXG等号码绑定接口时指定或自动分配的X号码。 |
|---|
| | | // request.putQueryParameter("SecretNo", secretNo); |
|---|
| | | // // 绑定关系ID。 |
|---|
| | | // // |
|---|
| | | // //可以在控制台的号码管理 > 号码详情中查看绑定关系ID，或者在调用BindAxb等号码绑定API时查看返回参数中的SubsId。 |
|---|
| | | // request.putQueryParameter("SubsId", bindId); |
|---|
| | | // Map<String, String> map1 = new HashMap<>(); |
|---|
| | | // try { |
|---|
| | | // CommonResponse response = client.getCommonResponse(request); |
|---|
| | | // // 处理请求结果 |
|---|
| | | // System.out.println(response.getData()); |
|---|
| | | // JSONObject jsonObject = JSONObject.parseObject(response.getData()); |
|---|
| | | // if(jsonObject.getString("Code").equals("OK")){ |
|---|
| | | // map1.put("code", "200"); |
|---|
| | | // map1.put("msg", jsonObject.getString("Message")); |
|---|
| | | // }else{ |
|---|
| | | // map1.put("code", jsonObject.getString("Code")); |
|---|
| | | // map1.put("msg", jsonObject.getString("Message")); |
|---|
| | | // } |
|---|
| | | // } catch (ServerException e) { |
|---|
| | | // e.printStackTrace(); |
|---|
| | | // map1.put("code", "-1"); |
|---|
| | | // map1.put("msg", e.getErrMsg()); |
|---|
| | | // } catch (ClientException e) { |
|---|
| | | // System.out.println("ErrCode:" + e.getErrCode()); |
|---|
| | | // System.out.println("ErrMsg:" + e.getErrMsg()); |
|---|
| | | // System.out.println("RequestId:" + e.getRequestId()); |
|---|
| | | // map1.put("code", "-1"); |
|---|
| | | // map1.put("msg", e.getErrMsg()); |
|---|
| | | // } |
|---|
| | | // return map1; |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // public static void main(String[] args) throws IOException { |
|---|
| | | // try{ |
|---|
| | | // // System.out.println(midAxbBindSend("18380476116","13688394165",null)); |
|---|
| | | // System.out.println(midAxbUnBindSend("1000031640138366","17150145472")); |
|---|
| | | // }catch (Exception e){ |
|---|
| | | // |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // |
|---|
| | | // public Map<String, String> HeaderUtils(String APIKey, String SecretKey) throws Exception{ |
|---|
| | | // Map<String, String> header = new HashMap<>(); |
|---|
| | | // long time = System.currentTimeMillis(); |
|---|
| | | // String signStr = MD5Util.encrypt(APIKey + SecretKey + time); |
|---|
| | | // JSONObject jsonObject = new JSONObject(); |
|---|
| | | // jsonObject.put("apiKey", APIKey); |
|---|
| | | // jsonObject.put("time", time); |
|---|
| | | // jsonObject.put("sign", signStr); |
|---|
| | | // Base64 base64 = new Base64(); |
|---|
| | | // String s = base64.encodeToString(jsonObject.toJSONString().getBytes("UTF-8")); |
|---|
| | | // header.put("header", s); |
|---|
| | | // |
|---|
| | | // jsonObject = new JSONObject(); |
|---|
| | | // jsonObject.put("platformId", ""); |
|---|
| | | // jsonObject.put("secret", ""); |
|---|
| | | // s = base64.encodeToString(jsonObject.toJSONString().getBytes("UTF-8")); |
|---|
| | | // header.put("accessCode", s); |
|---|
| | | // return header; |
|---|
| | | // } |
|---|
| | | //} |
|---|
