首門程序員理財課 Python量化交易系統實戰

download：首門程序員理財課 Python量化交易系統實戰

 

import java.io.BufferedReader;

import java.io.DataOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.UnsupportedEncodingException;

import java.net.HttpURLConnection;

import java.net.URL;

import java.net.URLEncoder;

import java.util.HashMap;

import java.util.Map;

  

import net.sf.json.JSONObject;

  

/**

*短信API服務調用示例代碼 － 聚合數據

*在線接口文檔：http://www.juhe.cn/docs/54

**/

  

public class JuheDemo {

     public static final String DEF_CHATSET = "UTF-8" ;

     public static final int DEF_CONN_TIMEOUT = 30000 ;

     public static final int DEF_READ_TIMEOUT = 30000 ;

     public static String userAgent =  "Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/29.0.1547.66 Safari/537.36" ;

  

     //配置您申請的KEY

     public static final String APPKEY = "*************************" ;

  

     //1.屏蔽詞檢查測

     public static void getRequest1(){

         String result = null ;

         String url = "http://v.juhe.cn/sms/black" ;//請求接口地址

         Map params = new HashMap(); //請求參數

             params.put( "word" , "" ); //須要檢測的短信內容，須要UTF8 URLENCODE

             params.put( "key" ,APPKEY); //應用APPKEY(應用詳細頁查詢)

  

         try {

             result =net(url, params, "GET" );

             JSONObject object = JSONObject.fromObject(result);

             if (object.getInt( "error_code" )== 0 ){

                 System.out.println(object.get( "result" ));

             } else {

                 System.out.println(object.get( "error_code" )+ ":" +object.get( "reason" ));

             }

         } catch (Exception e) {

             e.printStackTrace();

         }

     }

  

     //2.發送短信

     public static void getRequest2(){

         String result = null ;

         String url = "http://v.juhe.cn/sms/send" ;//請求接口地址

         Map params = new HashMap(); //請求參數

             params.put( "mobile" , "" ); //接收短信的手機號碼

             params.put( "tpl_id" , "" ); //短信模板ID，請參考我的中心短信模板設置

             params.put( "tpl_value" , "" ); //變量名和變量值對。若是你的變量名或者變量值中帶有#&=中的任意一個特殊符號，請先分別進行urlencode編碼後再傳遞，<a href="http://www.juhe.cn/news/index/id/50" target="_blank">詳細說明></a>

             params.put( "key" ,APPKEY); //應用APPKEY(應用詳細頁查詢)

             params.put( "dtype" , "" ); //返回數據的格式,xml或json，默認json

  

         try {

             result =net(url, params, "GET" );

             JSONObject object = JSONObject.fromObject(result);

             if (object.getInt( "error_code" )== 0 ){

                 System.out.println(object.get( "result" ));

             } else {

                 System.out.println(object.get( "error_code" )+ ":" +object.get( "reason" ));

             }

         } catch (Exception e) {

             e.printStackTrace();

         }

     }

  

  

  

     public static void main(String[] args) {

  

     }

  

     /**

      *

      * @param strUrl 請求地址

      * @param params 請求參數

      * @param method 請求方法

      * @return  網絡請求字符串

      * @throws Exception

      */

     public static String net(String strUrl, Map params,String method) throws Exception {

         HttpURLConnection conn = null ;

         BufferedReader reader = null ;

         String rs = null ;

         try {

             StringBuffer sb = new StringBuffer();

             if (method== null || method.equals( "GET" )){

                 strUrl = strUrl+ "?" +urlencode(params);

             }

             URL url = new URL(strUrl);

             conn = (HttpURLConnection) url.openConnection();

             if (method== null || method.equals( "GET" )){

                 conn.setRequestMethod( "GET" );

             } else {

                 conn.setRequestMethod( "POST" );

                 conn.setDoOutput( true );

             }

             conn.setRequestProperty( "User-agent" , userAgent);

             conn.setUseCaches( false );

             conn.setConnectTimeout(DEF_CONN_TIMEOUT);

             conn.setReadTimeout(DEF_READ_TIMEOUT);

             conn.setInstanceFollowRedirects( false );

             conn.connect();

             if (params!= null && method.equals( "POST" )) {