package com.yelang.project.thridinterface;
import com.burukeyou.uniapi.http.annotation.HttpApi;
import com.burukeyou.uniapi.http.annotation.param.QueryPar;
import com.burukeyou.uniapi.http.annotation.request.GetHttpInterface;
import com.burukeyou.uniapi.http.core.response.HttpResponse;
@HttpApi
public interface BaiduGeoSearchWithSnService {
	/**
	 * - 百度行政區(qū)劃區(qū)域檢索接口
	 * @param query         檢索關(guān)鍵字。行政區(qū)劃區(qū)域檢索不支持多關(guān)鍵字檢索。如果需要按POI分類進(jìn)行檢索，請將分類通過query參數(shù)進(jìn)行設(shè)置，如query=美食
	 * @param region        檢索行政區(qū)劃區(qū)域（增加區(qū)域內(nèi)數(shù)據(jù)召回權(quán)重，如需嚴(yán)格限制召回?cái)?shù)據(jù)在區(qū)域內(nèi)，請搭配使用city_limit參數(shù)），可輸入行政區(qū)劃名或?qū)?yīng)
	 * @param output        輸出格式為json或者xml
	 * @param scope         檢索結(jié)果詳細(xì)程度。取值為1 或空，則返回基本信息；取值為2，返回檢索POI詳細(xì)信息
	 * @param ret_coordtype 返回的坐標(biāo)類型，可選參數(shù)，添加后POI返回國測局經(jīng)緯度坐標(biāo)
	 * @param pageSize      單次召回POI數(shù)量，默認(rèn)為10條記錄，最大返回20條
	 * @param pageNum       分頁頁碼，默認(rèn)為0,0代表第一頁
	 * @param ak            開發(fā)者的訪問密鑰，必填項(xiàng)
	 * @param sn            開發(fā)者的權(quán)限簽名
	 * @return
	 */
	@GetHttpInterface(url="https://api.map.baidu.com/place/v2/search")
	public HttpResponse<String> getSearch(@QueryPar("query") String query, @QueryPar("region") String region,
			@QueryPar("output") String output, @QueryPar("scope") String scope,
			@QueryPar("ret_coordtype") String ret_coordtype, @QueryPar("page_size") int pageSize,
			@QueryPar("page_num") int pageNum, @QueryPar("ak") String ak, @QueryPar("sn") String sn);
}

package com.yelang.project.unihttp;
import java.io.UnsupportedEncodingException;
import java.util.LinkedHashMap;
import java.util.Map;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import com.burukeyou.uniapi.http.core.response.HttpResponse;
import com.yelang.project.thridinterface.BaiduGeoSearchSnProcessorService;
import com.yelang.project.thridinterface.BaiduGeoSearchWithSnService;
import com.yelang.project.thridinterface.signature.BaiduSignature;
/**
 * - 百度檢索2.0接口帶SN訪問服務(wù)示例
 * @author 夜郎king
 *
 */
@SpringBootTest
@RunWith(SpringRunner.class)
public class BaiduGeoSearchWithSnServiceCase {
	/**
	 * - 應(yīng)用申請的AK值
	 */
	private static final String AK_VALUE = "yourak";
	/**
	 * - 應(yīng)用申請的SK值
	 */
	private static final String SK_VALUE = "yoursk";
	@Autowired
	private BaiduGeoSearchWithSnService bdGeoSearchWithSnService;
	@Test
	public void searchBySn() throws UnsupportedEncodingException {
		/**
		 * -計(jì)算sn跟參數(shù)對出現(xiàn)順序有關(guān)，get請求請使用LinkedHashMap保存<key,value>，該方法根據(jù)key的插入順序排序；
		 * -post請使用TreeMap保存<key,value>，該方法會(huì)自動(dòng)將key按照字母a-z順序排序。
		 * -所以get請求可自定義參數(shù)順序（sn參數(shù)必須在最后）發(fā)送請求，但是post請求必須按照字母a-z順序填充body（sn參數(shù)必須在最后）。
		 * -以get請求為例：https://api.map.baidu.com/geocoder/v2/?address=百度大廈&output=json&ak=yourak，paramsMap中先放入address，
		 * -再放output，然后放ak，放入順序必須跟get請求中對應(yīng)參數(shù)的出現(xiàn)順序保持一致。
		 */
		Map<String, String> paramsMap = new LinkedHashMap<String, String>();
		String api_prefix = "/place/v2/search?";
		//按接口定義順序來創(chuàng)建參數(shù)
		String query = "湘菜";
		String region = "158";// 158表示長沙市
		String output = "json";
		String scope = "2";
		String ret_coordtype = "WGS84";
		int pageSize = 20;
		int pageNum = 0;
		paramsMap.put("query", query);
		paramsMap.put("region", region);
		paramsMap.put("output", output);
		paramsMap.put("scope", scope);
		paramsMap.put("ret_coordtype", ret_coordtype);
		paramsMap.put("page_size", String.valueOf(pageSize));
		paramsMap.put("page_num", String.valueOf(pageNum));
		paramsMap.put("ak", AK_VALUE);
		// 調(diào)用簽名工具生成SN
		BaiduSignature signature = new BaiduSignature(AK_VALUE, SK_VALUE,paramsMap,api_prefix);
		String sn = signature.getSnByMap();
		System.out.println("sn==>" + sn);
		HttpResponse<String> result = bdGeoSearchWithSnService.getSearch(query, region, output, scope,
				ret_coordtype, pageSize, pageNum ,AK_VALUE,sn);
		System.out.println("第一頁的數(shù)據(jù)如下：");
		System.out.println(result);
		System.out.println(result.getBodyResult());
		System.out.println("--------------------------------------------------------------");
	}
}

HttpUrl(
url=https://api.map.baidu.com/place/v2/search?, 
path=, 
anchor=null, 
queryParam={output=json, query=湘菜, scope=2, page_num=0, ak=yourak, s
n=d1abf338a49bd82fca6992f5d2b9f686, 
region=158, ret_coordtype=WGS84, 
page_size=20}, 
pathParam={}
)

@GetHttpInterface(url="https://api.map.baidu.com/place/v2/search")
public HttpResponse<String> getSearch(@QueryPar("query") String query, @QueryPar("region") String region,
			@QueryPar("output") String output, @QueryPar("scope") String scope,
			@QueryPar("ret_coordtype") String ret_coordtype, @QueryPar("page_size") int pageSize,
			@QueryPar("page_num") int pageNum, @QueryPar("ak") String ak, @QueryPar("sn") String sn);

@Test
public void searchBySn() throws UnsupportedEncodingException {
	Map<String, String> paramsMap = new LinkedHashMap<String, String>();
	String api_prefix = "/place/v2/search?";
	/*
	 * - 按請求順序來加密
	*/
	String output = "json";
	String query = "湘菜";
	String scope = "2";
	int pageNum = 0;
	String region = "158";// 158表示長沙市
	String ret_coordtype = "WGS84";
	int pageSize = 20;
	paramsMap.put("output", output);
	paramsMap.put("query", query);
	paramsMap.put("scope", scope);
	paramsMap.put("page_num", String.valueOf(pageNum));
	paramsMap.put("ak", AK_VALUE);
	paramsMap.put("region", region);
	paramsMap.put("ret_coordtype", ret_coordtype);
	paramsMap.put("page_size", String.valueOf(pageSize));
	// 調(diào)用簽名工具生成SN
	BaiduSignature signature = new BaiduSignature(AK_VALUE, SK_VALUE,paramsMap,api_prefix);
	String sn = signature.getSnByMap();
	System.out.println("sn==>" + sn);
	HttpResponse<String> result = bdGeoSearchWithSnService.getSearch(query, region, output, scope,
				ret_coordtype, pageSize, pageNum ,AK_VALUE,sn);
	System.out.println("第一頁的數(shù)據(jù)如下：");
	System.out.println(result);
	System.out.println(result.getBodyResult());
	System.out.println("--------------------------------------------------------------");
}

/**
* 
* @param snMapParams
* @param queryParam
* @return
*/
protected Map<String, Object> reorderingQueryParamMap(String snMapParams,Map<String, Object> queryParam) {
	Map<String, Object> paramsMap = null;
	if(StringUtils.isNotEmpty(snMapParams)) {
		paramsMap = new LinkedHashMap<String, Object>();
		//將ak和sn分別放到paramsMap中
		paramsMap.put("region", queryParam.get("region"));
        //其它參數(shù)
		//將ak和sn分別放到paramsMap中
		paramsMap.put("ak", queryParam.get("ak"));
		paramsMap.put("sn", queryParam.get("sn"));
	}else {
		paramsMap = queryParam;
	}
	return paramsMap;
}

/** * -實(shí)現(xiàn)-postBeforeHttpMetadata： 發(fā)送Http請求之前會(huì)回調(diào)該方法，可對Http請求體的內(nèi)容進(jìn)行二次處理
*
* @param uniHttpRequest              原來的請求體
* @param methodInvocation          被代理的方法
* @return                          新的請求體
*/
@Override
public UniHttpRequest postBeforeHttpRequest(UniHttpRequest uniHttpRequest,
			HttpApiMethodInvocation<BaiduHttpApi> methodInvocation) {
		/**
         * -在查詢參數(shù)中添加提供的appId字段
         */
        // 獲取BaiduHttpApi注解
		BaiduHttpApi apiAnnotation = methodInvocation.getProxyApiAnnotation();
        // 獲取所有查詢參數(shù)
        Map<String, Object> queryParam = uniHttpRequest.getHttpUrl().getQueryParam();
        System.out.println("未處理之前的請求參數(shù)：" + queryParam);
        Map<String, Object> paramsMap = this.reorderingQueryParamMap(snMapParams, queryParam);
       System.out.println("處理之后的請求參數(shù)：" + paramsMap);
        // 第二種方式，直接修改請求參數(shù)
        String queryString =  this.reorderingQueryParam(snMapParams,queryParam);
        uniHttpRequest.getHttpUrl().setQueryParam(null);
        String url = uniHttpRequest.getHttpUrl().getUrl() + uniHttpRequest.getHttpUrl().getPath() + "?" + queryString;
        uniHttpRequest.getHttpUrl().setUrl(url);
        uniHttpRequest.getHttpUrl().setPath("");
    }
    return uniHttpRequest;
}

@GetHttpInterface(path = "/place/v2/search?")
public HttpResponse<String> getSearch(@QueryPar("query") String query, @QueryPar("region") String region,
			@QueryPar("output") String output, @QueryPar("scope") String scope,
			@QueryPar("ret_coordtype") String ret_coordtype, @QueryPar("page_size") String pageSize,
			@QueryPar("page_num") String pageNum, @QueryPar("ak") String ak, @QueryPar("sn") String sn);

url=https://api.map.baidu.com/place/v2/search??query=%E6%B9%98%E8%8F%9C&region=158&output=json&scope=2&ret_coordtype=WGS84&page_size=20&page_num=0&ak=yourak&sn=d1abf338a49bd82fca6992f5d2b9f686

package com.yelang.project.thridinterface.apiprocessor;
import java.lang.annotation.ElementType;
import java.lang.annotation.Inherited;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.core.annotation.AliasFor;
import com.burukeyou.uniapi.http.annotation.HttpApi;
@Inherited
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@HttpApi(processor = BaiduHttpApiProcessor.class)
public @interface BaiduHttpApi {
	/**
     * -渠道方域名地址
     */
    @AliasFor(annotation = HttpApi.class)
    String url() default "${unihttp.channel.baidu.url}";
    /**
     * -snMapParams 模式下的請求參數(shù)順序，用于按順序加密,在統(tǒng)一處理器中獲取后處理
     */
    String snMapParams() default "";
    /**
     * - 是否使用sn簽名模式
     * @return
     */
    boolean snMode() default false;
}

/**
* 
* @param snMapParams
* @param queryParam
* @return
*/
protected Map<String, Object> reorderingQueryParamMap(String snMapParams,Map<String, Object> queryParam) {
	Map<String, Object> paramsMap = null;
	if(StringUtils.isNotEmpty(snMapParams)) {
		paramsMap = new LinkedHashMap<String, Object>();
		//從注解中讀取配置的參數(shù)
		String [] snMap = snMapParams.split(",");
		//按照參數(shù)重新組合參數(shù)，生成按順序的請求字符串
		for(String paramKey : snMap) {
			paramsMap.put(paramKey, queryParam.get(paramKey));
		}
		//將ak和sn分別放到paramsMap中
		paramsMap.put("ak", queryParam.get("ak"));
		paramsMap.put("sn", queryParam.get("sn"));
	}else {
		paramsMap = queryParam;
	}
	return paramsMap;
}

@BaiduHttpApi(snMode = true, snMapParams = "query,region,output,scope,ret_coordtype,page_size,page_num")
public interface BaiduGeoSearchSnProcessorService {
}

/** * -實(shí)現(xiàn)-postBeforeHttpMetadata： 發(fā)送Http請求之前會(huì)回調(diào)該方法，可對Http請求體的內(nèi)容進(jìn)行二次處理
 *
 * @param uniHttpRequest              原來的請求體
 * @param methodInvocation          被代理的方法
 * @return                          新的請求體
 */
@Override
public UniHttpRequest postBeforeHttpRequest(UniHttpRequest uniHttpRequest,
			HttpApiMethodInvocation<BaiduHttpApi> methodInvocation) {
    // 獲取BaiduHttpApi注解
	BaiduHttpApi apiAnnotation = methodInvocation.getProxyApiAnnotation();
    String snMapParams = apiAnnotation.snMapParams();
    boolean snMode = apiAnnotation.snMode();
    //如果開啟sn簽名，則將請求參數(shù)進(jìn)行充排序后進(jìn)行簽名，反之不用處理
    if(snMode) {
        System.out.println("開啟SN簽名處理");
        // 獲取所有查詢參數(shù)
        Map<String, Object> queryParam = uniHttpRequest.getHttpUrl().getQueryParam();
        Map<String, Object> paramsMap = this.reorderingQueryParamMap(snMapParams, queryParam);
        System.out.println("處理之后的請求參數(shù)：" + paramsMap);
        //第一種請求參數(shù)重排序
        uniHttpRequest.getHttpUrl().setQueryParam(paramsMap);
    }
    return uniHttpRequest;
}