手机话费充值-java示例

[java]代码库

package com.jefferson.utils.interfaceDemo.huafei;
 
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
 
import net.sf.json.JSONObject;
 
import org.apache.http.HttpEntity;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
 
import com.jefferson.utils.encrypt.Md5Util;
 
public class ShoujiHuaFei {
// HttpClient请求的相关设置，可以不用配置，用默认的参数，这里设置连接和超时时长(毫秒)
public static RequestConfig config = RequestConfig.custom()
.setConnectTimeout(30000).setSocketTimeout(30000).build();
public static final String key ="********";//申请的接口Appkey
public static final String openId="*******";//在个人中心查询
public static final String telCheckUrl = "http://op.juhe.cn/ofpay/mobile/telcheck?cardnum=*&phoneno=!&key="+key;
public static final String telQueryUrl="http://op.juhe.cn/ofpay/mobile/telquery?cardnum=*&phoneno=!&key="+key;
public static final String onlineUrl="http://op.juhe.cn/ofpay/mobile/onlineorder?key="+key+"&phoneno=!&cardnum=*&orderid=@&sign=$";
public static final String yueUrl="http://op.juhe.cn/ofpay/mobile/yue?key="+key+"&"+"timestamp=%&sign=$";
public static final String orderstaUrl="http://op.juhe.cn/ofpay/mobile/ordersta?key="+key+"&orderid=!";
public static final String orderListUrl="http://op.juhe.cn/ofpay/mobile/orderlist?key="+key;
//---------------------------------------------------------------------------------------------------------------------------------------------
/**
* 1.检测手机号码是否能充值接口
* @param phone 手机号码
* @param cardnum 充值金额,目前可选：5、10、20、30、50、100、300
* @return 返回错码，0为允许充
值的手机号码及金额，其他为不可以或其他错误
* @throws Exception
*/
public static int telCheck(String phone,int cardnum) throws Exception{
int error_code=0;
String result = get(telCheckUrl.replace("*", cardnum+"").replace("!", phone),0);
error_code =JSONObject.fromObject(result).getInt("error_code");
 return error_code;
  }
/**
* 2.根据手机号和面值查询商品信息
* @param phone 手机号码
* @param cardnum 充值金额,目前可选：5、10、20、30、50、100、300
* @return String类型结果
* @throws Exception
*/
public static String telQuery(String phone,int cardnum) throws Exception{
String result = get(telQueryUrl.replace("*", cardnum+"").replace("!", phone),0);
return result;
}
/**
* 3.依据用户提供的请求为指定手机直接充值
* @param phone 手机号码
* @param cardnum 充值金额,目前可选：5、10、20、30、50、100、300
* @param orderid 商家订单号，8-32位字母数字组合，自定义
* @return 返回String结果 
* @throws Exception
*/
public static String onlineOrder(String phone,int cardnum,String orderid) throws Exception{
String result = null;
//Md5Util工具类
String sign = Md5Util.MD5(openId+key+phone+cardnum+orderid);
result = get(onlineUrl.replace("*", cardnum+"").replace("!", phone).replace("@", orderid).replace("$", sign),0);
return result;
}
/**
* 4.查询账户余额
* @return
* @throws Exception 
*/
public static String yuE() throws Exception{
String timestamp = System.currentTimeMillis()/1000+"";
String sign = Md5Util.MD5(openId+key+timestamp);
String result =get(yueUrl.replace("%", timestamp).replace("$", sign),0);
return result;
}
/**
* 5.订单状态查询 
* @param orderid 商家订单号
* @return 订单结果
* @throws Exception
*/
public static String orderSta(String orderid) throws Exception{
return get(orderstaUrl.replace("1", orderid), 0);
}
/**
* 6.历史订单列表
* @return
* @throws Exception
*/
public static String orderList() throws Exception{
return get(orderListUrl,0);
}
/**工具类方法
* get 网络请求
* @param url 接收请求的网址
* @param tts 重试
* @return String类型 返回网络请求数据 
* @throws Exception 网络异常
*/
  public static String get(String url,int tts) throws Exception{
 if(tts>3){//重试3次
 return null;
 }
 CloseableHttpClient httpClient = HttpClients.createDefault();
 CloseableHttpResponse response = null;
 String result = null;
try {
HttpGet httpGet = new HttpGet(url);
httpGet.setConfig(config);
response = httpClient.execute(httpGet);
HttpEntity resEntity = response.getEntity();
if (resEntity != null) {
result = ConvertStreamToString(resEntity.getContent(), "UTF-8");
}
EntityUtils.consume(resEntity);
return result;
}catch(IOException e){
return get(url, tts++);
}finally {
response.close();
httpClient.close();
}
// 得到的是JSON类型的数据需要第三方解析JSON的jar包来解析
  }
  /**工具类方法
   * 此方法是把传进的字节流转化为相应的字符串并返回，此方法一般在网络请求中用到
   * @param is 输入流
   * @param charset 字符格式
   * @return String 类型
   * @throws Exception
   */
public static String ConvertStreamToString(InputStream is, String charset)
throws Exception {
StringBuilder sb = new StringBuilder();
try (InputStreamReader inputStreamReader = new InputStreamReader(is,
charset)) {
try (BufferedReader reader = new BufferedReader(inputStreamReader)) {
String line = null;
while ((line = reader.readLine()) != null) {
sb.append(line).append("\r\n");
}
}
}
return sb.toString();
}
}