接口修改

suerprisePlus

2024-09-14 0cf13d9df73e8e9befa36236756ef02dd5f60e94

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

@@ -1,7 +1,9 @@
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;

@@ -10,9 +12,11 @@


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

@@ -57,6 +61,9 @@
        }

        return  null;

    }







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

        try{

            String axiosUrl = xzConfig.geographicalUrl+aurl;

@@ -65,9 +72,9 @@
                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)

            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)

@@ -82,4 +89,38 @@
        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;









    }

}