import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import net.sf.json.JSONArray;

import org.apache.commons.lang.exception.ExceptionUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;

public class APIHttpClient {

 //接口地址
 private String apiURL = "";
 private Log logger = LogFactory.getLog(this.getClass());
 private static final String pattern = "yyyy-MM-dd HH:mm:ss:SSS";
        private HttpClient httpClient = null;
 private HttpPost method = null;
 private long startTime = 0L;
 private long endTime = 0L;
 private int status = 0;
 /**
  * 接口地址
  * @param url
  */
 public APIHttpClient(String url){

  if(url != null)
  {
   this.apiURL = url;
  }
  if(apiURL != null)
  {
                    httpClient = new DefaultHttpClient();
                    method = new HttpPost(apiURL);

  }
 }

 /**
  * 調(diào)用 API
  * @param parameters
  * @return
  */
 public String post(String parameters)
 {
  String body = null;
                logger.info("parameters:" + parameters);

               
  if(method != null & parameters != null  && !"".equals(parameters.trim()))
  {
                    JSONArray jsonObject = JSONArray.fromObject(parameters);
                    logger.info("json:" + jsonObject.toString());
                    try{

                        List<NameValuePair> params=new ArrayList<NameValuePair>(); 
                        //建立一個NameValuePair數(shù)組，用于存儲欲傳送的參數(shù) 
                        params.add(new BasicNameValuePair("data",parameters)); 
                        //添加參數(shù) 
                        method.setEntity(new UrlEncodedFormEntity(params,HTTP.UTF_8)); 

                        startTime = System.currentTimeMillis();

                        //設(shè)置編碼 
                        HttpResponse response=httpClient.execute(method); 
                        endTime = System.currentTimeMillis();
                        int statusCode = response.getStatusLine().getStatusCode();
                        logger.info("statusCode:" + statusCode);
                         logger.info("調(diào)用API 花費(fèi)時間(單位：毫秒)：" + (endTime - startTime));
                        if(statusCode != HttpStatus.SC_OK){
                            logger.error("Method failed:"+response.getStatusLine());
                            status = 1;
                        }

                            //Read the response body
                             body=EntityUtils.toString(response.getEntity());

   }catch(IOException e){
    //發(fā)生網(wǎng)絡(luò)異常
    logger.error("exception occurred!\n"+ExceptionUtils.getFullStackTrace(e));
    //網(wǎng)絡(luò)錯誤
    status = 3;
   }
                    finally{
                        logger.info("調(diào)用接口狀態(tài)：" + status);
                    }

   
  }
  return body;
 }

 /**
  * 0.成功 1.執(zhí)行方法失敗 2.協(xié)議錯誤 3.網(wǎng)絡(luò)錯誤
  * @return the status
  */
 public int getStatus() {
  return status;
 }

 /**
  * @param status the status to set
  */
 public void setStatus(int status) {
  this.status = status;
 }
 /**
  * @return the startTime
  */
 public long getStartTime() {
  return startTime;
 }
 /**
  * @return the endTime
  */
 public long getEndTime() {
  return endTime;
 }
}