<dependency>
  <groupId>io.github.burukeyou</groupId>
  <artifactId>uniapi-http</artifactId>
  <version>0.0.4</version>
</dependency>

@HttpApi(url = "http://localhost:8080")
interface UserHttpApi {
    
   @GetHttpInterface("/getUser")
   BaseRsp<String> getUser(@QueryPar("name") String param,@HeaderPar("userId") Integer id);
    
   @PostHttpInterface("/addUser")
   BaseRsp<Add4DTO> addUser(@BodyJsonPar Add4DTO req);
   
}

GET http://localhost:8080/getUser?name=param
Header:
    userId: id

POST:  http://localhost:8080/addUser 
Header: 
    Content-Type:   application/json
Body:
    {"id":1,"name":"jay"}

@UniAPIScan("com.xxx.demo.api")
@SpringBootApplication
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class,args);
    }
}

@Service
class UserAppService {
    
    @Autowired
    private UserHttpApi userHttpApi;
    
    public void doSomething(){
        userHttpApi.getUser("jay",3);
    }
}

@PostHttpInterface(
    // 請求路徑
    path = "/getUser",
    // 請求頭
    headers = {"clientType:sys-app","userId:99"},
    // url查詢參數(shù) 
    params = {"name=周杰倫","age=1"},
    // url查詢參數(shù)拼接字符串
    paramStr = "a=1&b=2&c=3&d=哈哈&e=%E7%89%9B%E9%80%BC",
    // cookie 字符串
    cookie = "name=1;sessionId=999"
)
BaseRsp<String> getUser();

@PostHttpInterface
BaseRsp<String> getUser(@QueryPar("id")  String id,  //  普通值   
                        @QueryPar("ids") List<Integer> idsList, //  普通值集合
                        @QueryPar User user,  // 對象
                        @QueryPar Map<String,Object> map); // Map

@PostHttpInterface("/getUser/{userId}/detail")
BaseRsp<String> getUser(@PathPar("userId")  String id);  //  普通值

@PostHttpInterface
BaseRsp<String> getUser(@HeaderPar("id")  String id,  //  普通值   
                        @HeaderPar User user,  // 對象
                        @HeaderPar Map<String,Object> map); // Map

@PostHttpInterface
BaseRsp<String> getUser(@CookiePar("id")  String cookiePar,  //   普通值 （指定name）當(dāng)成單個(gè)cookie鍵值對處理
                        @CookiePar String cookieString,  //  普通值 （不指定name），當(dāng)成完整的cookie字符串處理
                        @CookiePar com.burukeyou.uniapi.http.support.Cookie cookieObj,  // 單個(gè)Cookie對象 
                        @CookiePar List<com.burukeyou.uniapi.http.support.Cookie> cookieList // Cookie對象列表
                        @CookiePar Map<String,Object> map); // Map

@PostHttpInterface
BaseRsp<String> getUser(@BodyJsonPar  String id,                //  普通值
                        @BodyJsonPar  String[] id               //  普通值集合
                        @BodyJsonPar List<User> userList,       // 對象集合
                        @BodyJsonPar User user,                  // 對象
                        @BodyJsonPar Map<String,Object> map);    // Map

@PostHttpInterface
BaseRsp<String> getUser(@BodyFormPar("name") String value,         //  普通值
                        @BodyFormPar User user,                   // 對象
                        @BodyFormPar Map<String,Object> map);    // Map

@PostHttpInterface
BaseRsp<String> getUser(@BodyMultiPartPar("name") String value,         //  單個(gè)表單文本值
                        @BodyMultiPartPar User user,                   // 對象
                        @BodyMultiPartPar Map<String,Object> map,      // Map
                        @BodyMultiPartPar("userImg") File file);     // 單個(gè)表單文件值

@PostHttpInterface
BaseRsp<String> getUser(@BodyBinaryPar InputStream value,         
                        @BodyBinaryPar File user,                   
                        @BodyBinaryPar InputStreamSource map);

@PostHttpInterface
BaseRsp<String> getUser(@ComposePar UserReq req);

class UserReq {

    @QueryPar
    private Long id;

    @HeaderPar
    private String name;

    @BodyJsonPar
    private Add4DTO req;

    @CookiePar
    private String cook;
}

@PostHttpInterface("/user-web/get")
HttpResponse<Add4DTO> get();

postBeforeHttpMetadata  (請求發(fā)送前)在發(fā)送請求之前，對Http請求體后置處理
           |
           V
postSendingHttpRequest  (請求發(fā)送時(shí))在Http請求發(fā)送時(shí)處理
           |
           V
postAfterHttpResponseBodyString  (請求響應(yīng)后)對響應(yīng)body文本字符串進(jìn)行后置處理
           |
           V
postAfterHttpResponseBodyResult  (請求響應(yīng)后)對響應(yīng)body反序列化后的結(jié)果進(jìn)行后置處理
           |
           V
postAfterMethodReturnValue  (請求響應(yīng)后)對代理的方法的返回值進(jìn)行后置處理，類似aop的后置處理

@Configuration
public class CusotmConfiguration {

    @Bean
    public OkHttpClient myOHttpClient(){
        return new OkHttpClient.Builder()
                .readTimeout(50, TimeUnit.SECONDS)
                .writeTimeout(50, TimeUnit.SECONDS)
                .connectTimeout(10, TimeUnit.SECONDS)
                .connectionPool(new ConnectionPool(20,10, TimeUnit.MINUTES))
                .build();
    }
}

channel:
  mtuan:
    # 請求域名
    url: http://127.0.0.1:8999
    # 分配的渠道appId
    appId: UUU-asd-01
    # 分配的公鑰
    publicKey: fajdkf9492304jklfahqq

@Inherited
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@HttpApi(processor = MTuanHttpApiProcessor.class)
public @interface MTuanHttpApi {

    /**
     * 渠道方域名地址
     */
    @AliasFor(annotation = HttpApi.class)
    String url() default "${channel.mtuan.url}";

    /**
     * 渠道方分配的appId
     */
    String appId() default "${channel.mtuan.appId}";
}
@Slf4j
@Component
public class MTuanHttpApiProcessor implements HttpApiProcessor<MTuanHttpApi> {
    
}

@MTuanHttpApi
public interface WeatherApi {
    
    /**
     * 根據(jù)城市名獲取天氣情況
     */
    @GetHttpInterface("/getCityByName")
    BaseRsp<WeatherDTO> getCityWeather(@QueryPar("city") String cityName);

    /**
     *  根據(jù)appId和公鑰獲取令牌
     */
    @PostHttpInterface("/getToken")
    HttpResponse<BaseRsp<TokenDTO>> getToken(@HeaderPar("appId") String appId, @HeaderPar("publicKey")String publicKey);

}

@Slf4j
@Component
public class MTuanHttpApiProcessor implements HttpApiProcessor<MTuanHttpApi> {

    /**
     *  渠道方分配的公鑰
     */
    @Value("${channel.mtuan.publicKey}")
    private String publicKey;

    @Value("${channel.mtuan.appId}")
    private String appId;

    @Autowired
    private Environment environment;
    
    @Autowired
    private WeatherApi weatherApi;

    /** 實(shí)現(xiàn)-postBeforeHttpMetadata： 發(fā)送Http請求之前會(huì)回調(diào)該方法，可對Http請求體的內(nèi)容進(jìn)行二次處理
     *
     * @param httpMetadata              原來的請求體
     * @param methodInvocation          被代理的方法
     * @return                          新的請求體
     */
    @Override
    public HttpMetadata postBeforeHttpMetadata(HttpMetadata httpMetadata, HttpApiMethodInvocation<MTuanHttpApi> methodInvocation) {
        /**
         * 在查詢參數(shù)中添加提供的appId字段
         */
        // 獲取MTuanHttpApi注解
        MTuanHttpApi apiAnnotation = methodInvocation.getProxyApiAnnotation();

        // 獲取MTuanHttpApi注解的appId，由于該appId是環(huán)境變量所以我們從environment中解析取出來
        String appIdVar = apiAnnotation.appId();
        appIdVar = environment.resolvePlaceholders(appIdVar);

        // 添加到查詢參數(shù)中
        httpMetadata.putQueryParam("appId",appIdVar);

        /**
         *  生成簽名sign字段
         */
        // 獲取所有查詢參數(shù)
        Map<String, Object> queryParam = httpMetadata.getHttpUrl().getQueryParam();

        // 獲取請求體參數(shù)
        HttpBody body = httpMetadata.getBody();

        // 生成簽名
        String signKey = createSignKey(queryParam,body);

        // 將簽名添加到請求頭中
        httpMetadata.putHeader("sign",signKey);

        return httpMetadata;
    }

    private String createSignKey(Map<String, Object> queryParam, HttpBody body) {
        // todo 偽代碼
        // 1、將查詢參數(shù)拼接成字符串
        String queryParamString = queryParam.entrySet()
                .stream().map(e -> e.getKey() + "="+e.getValue())
                .collect(Collectors.joining(";"));

        // 2、將請求體參數(shù)拼接成字符串
        String bodyString = "";
        if (body instanceof HttpBodyJSON){
            // application/json  類型的請求體
            bodyString = body.toStringBody();
        }else if (body instanceof HttpBodyFormData){
            // application/x-www-form-urlencoded 類型的請求體
            bodyString = body.toStringBody();
        }else if (body instanceof HttpBodyMultipart){
            // multipart/form-data 類型的請求體
            bodyString =  body.toStringBody();
        }

        // 使用公鑰publicKey 加密拼接起來
        String sign = publicKey + queryParamString + bodyString;
        try {
            MessageDigest md = MessageDigest.getInstance("SHA-256");
            byte[] digest = md.digest(sign.getBytes());
            return new String(digest);
        } catch (NoSuchAlgorithmException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     *  實(shí)現(xiàn)-postBeforeHttpMetadata： 發(fā)送Http請求時(shí)，可定義發(fā)送請求的行為 或者打印請求和響應(yīng)日志。
     */
    @Override
    public HttpResponse<?> postSendHttpRequest(HttpSender httpSender, HttpMetadata httpMetadata) {
        //  忽略 weatherApi.getToken的方法回調(diào)，否則該方法也會(huì)回調(diào)此方法會(huì)遞歸死循環(huán)。 或者該接口指定自定義的HttpApiProcessor重寫postSendingHttpRequest
        Method getTokenMethod = ReflectionUtils.findMethod(WeatherServiceApi.class, "getToken",String.class,String.class);
        if (getTokenMethod == null || getTokenMethod.equals(methodInvocation.getMethod())){
            return httpSender.sendHttpRequest(httpMetadata);
        }
        
        // 1、動(dòng)態(tài)獲取token和sessionId
        HttpResponse<String> httpResponse = weatherApi.getToken(appId, publicKey);

        // 從響應(yīng)體獲取令牌token
        String token = httpResponse.getBodyResult();
        // 從響應(yīng)頭中獲取sessionId
        String sessionId = httpResponse.getHeader("sessionId");

        // 把這兩個(gè)值放到此次的請求cookie中
        httpMetadata.addCookie(new Cookie("token",token));
        httpMetadata.addCookie(new Cookie("sessionId",sessionId));
        
        log.info("開始發(fā)送Http請求 請求接口:{} 請求體:{}",httpMetadata.getHttpUrl().toUrl(),httpMetadata.toHttpProtocol());

        // 使用框架內(nèi)置工具實(shí)現(xiàn)發(fā)送請求
        HttpResponse<?> rsp =  httpSender.sendHttpRequest(httpMetadata);

        log.info("開始發(fā)送Http請求 響應(yīng)結(jié)果:{}",rsp.toHttpProtocol());
        
        return rsp;
    }

    /**
     *  實(shí)現(xiàn)-postAfterHttpResponseBodyResult： 反序列化后Http響應(yīng)體的內(nèi)容后回調(diào)，可對該結(jié)果進(jìn)行二次處理返回
     * @param bodyResult                     Http響應(yīng)體反序列化后的結(jié)果
     * @param rsp                            原始Http響應(yīng)對象
     * @param method                         被代理的方法
     * @param httpMetadata                   Http請求體
     */
    @Override
    public Object postAfterHttpResponseBodyResult(Object bodyResult, HttpResponse<?> rsp, Method method, HttpMetadata httpMetadata) {
        if (bodyResult instanceof BaseRsp){
            BaseRsp baseRsp = (BaseRsp) bodyResult;
            // 設(shè)置
            baseRsp.setCode(999);
        }
        
        return bodyResult;
    }
}