接口优化

suerprisePlus

2024-09-27 53ae0215de46b9bb68d9aa5d5a3e83dde7cb3986

 src/main/java/com/yb/util/EntityHttpUtil.java

@@ -1,69 +1,130 @@
package com.yb.util;



import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.yb.config.XzConfig;

import io.swagger.v3.core.util.Json;

import okhttp3.*;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;



import org.springframework.stereotype.Component;



import org.springframework.web.bind.annotation.RestController;



import java.io.File;

import java.io.IOException;



import java.util.HashMap;

import java.util.Map;

import java.util.concurrent.TimeUnit;



@Component

@RestController

public class EntityHttpUtil {

    @Autowired

    private XzConfig xzConfig;



    @Value("${spring.geographical.token}")

    String token ;



    @Value("${spring.geographical.url}")

    String url ;



    public  String getMessage(String aurl){

        try{

            String axiosUrl =  url+aurl;

    public String getMessage(String aurl) {

        try {

            String axiosUrl = xzConfig.geographicalUrl + aurl;

            OkHttpClient client = new OkHttpClient.Builder().connectTimeout(5, TimeUnit.SECONDS)

                    .readTimeout(5, TimeUnit.SECONDS)

                    .writeTimeout(5, TimeUnit.SECONDS)

                    .build();

            Request request = new Request.Builder()

                    .addHeader("Token",token)

                    .addHeader("Token", xzConfig.token)

                    .url(axiosUrl)

                    .build();

            Response response = client.newCall(request).execute();

            return response.body().string();

        }catch (IOException e){

        } catch (IOException e) {

            System.out.println(e.getMessage());

            return null;

        }

        return  null;



    }

    public String getPostMessage(String aurl, HashMap<String,String> parms){

        try{

            String axiosUrl = url+aurl;

            FormBody.Builder builder= new FormBody.Builder();

            for(String key:parms.keySet()){

                builder.add(key,parms.get(key));

            }

            RequestBody requestBody =  builder.build();

            OkHttpClient client = new OkHttpClient.Builder().connectTimeout(5, TimeUnit.SECONDS)

                    .readTimeout(5, TimeUnit.SECONDS)

                    .writeTimeout(5, TimeUnit.SECONDS)



    public String getAgentMessage(String aurl) {

        try {



            OkHttpClient client = new OkHttpClient.Builder().connectTimeout(0, TimeUnit.SECONDS)

                    .readTimeout(0, TimeUnit.SECONDS)

                    .writeTimeout(0, TimeUnit.SECONDS)

                    .build();

            Request request = new Request.Builder()

                    .addHeader("Token",token)

                    .url(aurl)

                    .build();

            Response response = client.newCall(request).execute();

            return response.body().string();

        } catch (IOException e) {

            System.out.println(e.getMessage());

            return null;

        }



    }







    public String getPostMessage(String aurl, HashMap<String, String> parms) {

        try {

            String axiosUrl = xzConfig.geographicalUrl + aurl;

            FormBody.Builder builder = new FormBody.Builder();

            for (String key : parms.keySet()) {

                builder.add(key, parms.get(key));

            }

            RequestBody requestBody = builder.build();

            OkHttpClient client = new OkHttpClient.Builder().connectTimeout(0, TimeUnit.SECONDS)

                    .readTimeout(0, TimeUnit.SECONDS)

                    .writeTimeout(0, TimeUnit.SECONDS)

                    .build();

            Request request = new Request.Builder()

                    .addHeader("Token", xzConfig.token)

                    .url(axiosUrl)

                    .post(requestBody)

                    .build();

            Response response = client.newCall(request).execute();

            return response.body().string();

        }catch (IOException e){

        } catch (IOException e) {

            System.out.println(e.getMessage());

            return  null;

        }

        return  null;

//        return null;

    }



    public String postAgentMessage(String aurl, Map<String, String> parms) {

        try {

            String axiosUrl = xzConfig.agentUrl + aurl;

            MediaType JSON = MediaType.parse("application/json; charset=utf-8");

//            JSONObject jsonObject= JSONObject.parseObject(parms.toString());

            HashMap<String,Object> itemMap = new HashMap<>();

            for (String key : parms.keySet()) {

                if(key=="history_msg"){

                    itemMap.put(key,JSONObject.parseObject( parms.get(key)));

                }else{

                    itemMap.put(key, parms.get(key));

                }

                System.out.println("rec application/json:" + key);

            }

            RequestBody requestBody = RequestBody.create(JSON,JSONObject.toJSON(itemMap).toString());

            OkHttpClient client = new OkHttpClient.Builder().connectTimeout(0, TimeUnit.SECONDS)

                    .readTimeout(0, TimeUnit.SECONDS)

                    .writeTimeout(0, TimeUnit.SECONDS)

                    .build();

            Request request = new Request.Builder()

                    .url(axiosUrl)

                    .post(requestBody)

                    .build();

            Response response = client.newCall(request).execute();

            return response.body().string();

        } catch (IOException e) {

            System.out.println(e.getMessage());

            return  null;

        }

//        return null;









    }

}