youxiw2000 / trash · Files

package com.trash.common.utils;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.trash.common.config.trashConfig;
import com.trash.common.core.redis.RedisCache;
import com.trash.common.utils.SecurityUtils;

import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;

public class RemoteServerUtils {
	
//	public static String remote = "http://183.66.242.6:14601/";
	
//	public static String remote = "http://175.6.47.84:8008/"; 
	
	
	public static String remote;
	
	public static OkHttpClient okHttpClient;
	
	public static String TruckListRequestPath = "/api/gpsservice/cs/basevehicle/ledger/list";
	
	public static String UpdateTruckRequestPath = "/api/gpsservice/cs/basevehicle/credit/status";
	
	public static String TruckStatusListRequestPath = "/api/gpsservice/cs/basevehicle/statusquery";
													
	
	
	public static String TruckInfo = "/api/gpsservice/cs/basevehicle/";
	public static String EarthSitesInfo = "/api/siteservice/cs/earthsites/";
	
	public static String EarthSitesList = "//api/siteservice/cs/earthsites/ledger/list";
	
	public static String ConstructionInfo = "/api/siteservice/cs/constructionsites/";
	
	//license/ 留一下...
	public static String constructionLicenseById = "/api/siteservice/cs/constructionsites/";

	public static String ConstructionList = "/api/siteservice/cs/constructionsites/search";
	
	public static String UpdateConstruction= "/api/siteservice/cs/constructionsites/status";

	public static String UpdateSupervision= "/api/gpsservice/cs/supervision/status/update";

	
	public static String CompanyListRequestPath = "/api/gpsservice/cs/companies/ledger/list";
	
	public static String UpdateCompanyRequestPath = "/api/gpsservice/cs/companies/credit/status";

	public static String UpdateEarthSiteRequestPath = "/api/siteservice/cs/earthsites/status";

	public static String UpdateConractRequestPath = "/api/siteservice/cs/sitecontract/audit/status";
	
	public static String DriverListPath = "/api/gpsservice/v1/drivers/search";
	
	public static String CompanyUpdateAudit = "/api/gpsservice/cs/companies/audit/status";

	public static String TruckUpdateAudit = "/api/gpsservice/cs/basevehicle/audit/status";
	
	public static String DriverUpdateAudit = "/api/gpsservice/v1/drivers/audit/status";
	
	public static String BasevehicleInfo = "/api/gpsservice/cs/basevehicle/";
	
	public static String ContractList = "/api/siteservice/cs/sitecontract/ledger/list";
	
	public static String Unitetransport = "/api/siteservice/cs/unitetransport/bysite/";
	
	
	public static String GETAUTH = "/api/gpsservice/cs/authority";
	
	
	public static JSONArray getUnitetransport(String id){
		JSONArray list  = null;
		try {
			list = (JSONArray)get(Unitetransport+id,null);
		} catch (Exception e) {
			// TODO: handle exception
		}
		
		return list;
	}
	
	
	public static JSONArray getContractList(Map map){
		JSONArray list=null;
		Object object = post(ContractList,map);
		
		if(object != null){
			 JSONObject jsonObject = JSON.parseObject(object.toString());
			 list = jsonObject.getJSONArray("list");
		}
		
		return list;
	}
	
	public static JSONArray getContractList(Map map,String token){
		
		JSONArray list=null;
		Object object = post(ContractList,map,token);
		
		if(object != null){
			 JSONObject jsonObject = JSON.parseObject(object.toString());
			 list = jsonObject.getJSONArray("list");
		}
		
		return list;
	}
	
	
	public static JSONArray getEarthSitesList(Map map){
		JSONArray list=null;
		Object object = post(EarthSitesList,map);
		
		if(object != null){
			 JSONObject jsonObject = JSON.parseObject(object.toString());
			 list = jsonObject.getJSONArray("list");
		}
		
		return list;
	}

	public static JSONArray getEarthSitesList(Map map,String token){
		JSONArray list=null;
		Object object = post(EarthSitesList,map,token);

		if(object != null){
			JSONObject jsonObject = JSON.parseObject(object.toString());
			list = jsonObject.getJSONArray("list");
		}

		return list;
	}

	public static JSONArray getConstructionList(Map map){
		JSONArray list=null;
		Object object = post(ConstructionList,map);

		if(object != null){
			JSONObject jsonObject = JSON.parseObject(object.toString());
			list = jsonObject.getJSONArray("list");
		}

		return list;
	}

	public static JSONArray getConstructionList(Map map,String token){
		JSONArray list=null;
		Object object = post(ConstructionList,map,token);

		if(object != null){
			JSONObject jsonObject = JSON.parseObject(object.toString());
			list = jsonObject.getJSONArray("list");
		}

		return list;
	}

	public static JSONArray getTruckOnline(Map map){
		JSONArray turckList=null;
		Object object = post(TruckStatusListRequestPath,map);
		
		if(object != null){
			 JSONObject jsonObject = JSON.parseObject(object.toString());
        	 turckList = jsonObject.getJSONArray("list");
		}
		
		return turckList;
	}
	
	public static Object updateConstationCreditAndStatus(List<Map> map){
		JSONArray turckList=null;
		Object object = post(UpdateConstruction,map);
		
		return object;
	}

	public static Object UpdateSupervisionStatus(List<Map> map){
		Object object = post(UpdateSupervision,map);

		return object;
	}
	
	
	public static Object updateCompanyAudit(List<Map> map,String token){
		Object object = post(CompanyUpdateAudit,map,token);
		return object;
	}
	public static Object updateTruckAudit(List<Map> map,String token){
		Object object = post(TruckUpdateAudit,map,token);
		return object;
	}
	
	public static Object updateDriverAudit(List<Map> map,String token){
		Object object = post(DriverUpdateAudit,map,token);
		return object;
	}
	
	public static Object updateCompanyAudit(List<Map> map){
		Object object = post(CompanyUpdateAudit,map);
		return object;
	}
	
	public static Object updateTruckAudit(List<Map> map){
		Object object = post(TruckUpdateAudit,map);
		return object;
	}
	
	public static Object updateDriverAudit(List<Map> map){
		Object object = post(DriverUpdateAudit,map);
		return object;
	}
	
	public static Object updateEarthSitesCreditAndStatus(List<Map> map){
		JSONArray turckList=null;
		Object object = post(UpdateEarthSiteRequestPath,map);
		
		return object;
	}
	
	public static Object updateConractStatus(List<Map> map){
		JSONArray turckList=null;
		Object object = post(UpdateConractRequestPath,map);
		
		return object;
	}
	
	


	public static JSONObject getEarthSitesInfo(String id) {
		JSONObject json=null;
		Object object = get(EarthSitesInfo + id,null);
		
		if(object != null){
			json = JSON.parseObject(object.toString());
			return json;
		}
		
		return json;
	}


	
	public static JSONObject getTruckInfo(String id){
		JSONObject turckList=null;
		Object object = get(TruckInfo + id,null);
		
		if(object != null){
			turckList = JSON.parseObject(object.toString());
			return turckList;
		}
		
		return turckList;
	}
	
	public static JSONObject getConstructionLicenseById(String id) {
		JSONObject turckList=null;
		Object object = get(constructionLicenseById + id,null);
		
		if(object != null){
			turckList = JSON.parseObject(object.toString());
			return turckList;
		}
		
		return turckList;
		
	}
	public static JSONObject getConstructionLicenseById(String id,String token) {
		JSONObject turckList=null;
		Object object = get(constructionLicenseById + id,null,token);

		if(object != null){
			turckList = JSON.parseObject(object.toString());
			return turckList;
		}

		return turckList;

	}

	
	public static JSONObject getConstructionInfo(String id) {
		JSONObject turckList=null;
		Object object = get(ConstructionInfo + id,null);
		
		if(object != null){
			turckList = JSON.parseObject(object.toString());
			return turckList;
		}
		
		return turckList;
		
	}

	
	public static JSONArray getCompanyList(Map params){
		JSONArray turckList=null;
		Object object = post(CompanyListRequestPath,params);
		
		if(object != null){
			 JSONObject jsonObject = JSON.parseObject(object.toString());
        	 turckList = jsonObject.getJSONArray("list");
		}
		
		return turckList;
	}
	
	public static Object updateCompanyList(List<Map> updateList) {
		JSONArray turckList=null;
		Object object = post(UpdateCompanyRequestPath,updateList);
		
		
		return object;
	}
	
	
	public static JSONArray getAreas(){
		JSONArray array=null;
		Object object = get("/api/gpsservice/cs/area",null);
		
		if(object != null){
			 array = JSON.parseArray(object.toString());
		}
		
		return array;
	}
	
	public static JSONArray getDict(Map params){
		JSONArray array=null;
		Object object = get("/api/gpsservice/cs/dataDict",params);
		
		if(object != null){
			 array = JSON.parseArray(object.toString());
		}
		
		return array;
	}

	public static JSONArray getTruckList(Map params){
		JSONArray turckList=null;
		Object object = post(TruckListRequestPath,params);
		
		if(object != null){
			 JSONObject jsonObject = JSON.parseObject(object.toString());
        	 turckList = jsonObject.getJSONArray("list");
		}
		
		return turckList;
	}
	


	public static Object updateTruckList(List<Map> updateList) {
		JSONArray turckList=null;
		Object object = post(UpdateTruckRequestPath,updateList);
		
		
		return object;
	}
	
	
	
	public static JSONArray getTruckOnline(Map map,String token){
		JSONArray turckList=null;
		Object object = post(TruckStatusListRequestPath,map,token);
		
		if(object != null){
			 JSONObject jsonObject = JSON.parseObject(object.toString());
        	 turckList = jsonObject.getJSONArray("list");
		}
		
		return turckList;
	}
	
	public static Object updateConstationCreditAndStatus(List<Map> map,String token){
		JSONArray turckList=null;
		Object object = post(UpdateConstruction,map,token);
		
		return object;
	}
	
	public static Object updateEarthSitesCreditAndStatus(List<Map> map,String token){
		JSONArray turckList=null;
		Object object = post(UpdateEarthSiteRequestPath,map,token);
		
		return object;
	}
	
	public static Object updateConractStatus(List<Map> map,String token){
		JSONArray turckList=null;
		Object object = post(UpdateConractRequestPath,map,token);
		
		return object;
	}
	
	


	public static JSONObject getEarthSitesInfo(String id,String token) {
		JSONObject json=null;
		Object object = get(EarthSitesInfo + id,null,token);
		
		if(object != null){
			json = JSON.parseObject(object.toString());
			return json;
		}
		
		return json;
	}


	
	public static JSONObject getTruckInfo(String id,String token){
		JSONObject turckList=null;
		Object object = get(TruckInfo + id,null,token);
		
		if(object != null){
			turckList = JSON.parseObject(object.toString());
			return turckList;
		}
		
		return turckList;
	}
	
	
	public static JSONObject getConstructionInfo(String id,String token) {
		JSONObject turckList=null;
		Object object = get(ConstructionInfo + id,null,token);
		
		if(object != null){
			turckList = JSON.parseObject(object.toString());
			return turckList;
		}
		
		return turckList;
		
	}

	
	public static JSONArray getCompanyList(Map params,String token){
		JSONArray turckList=null;
		Object object = post(CompanyListRequestPath,params,token);
		
		if(object != null){
			 JSONObject jsonObject = JSON.parseObject(object.toString());
        	 turckList = jsonObject.getJSONArray("list");
		}
		
		return turckList;
	}
	
	public static Object updateCompanyList(List<Map> updateList,String token) {
		JSONArray turckList=null;
		Object object = post(UpdateCompanyRequestPath,updateList,token);
		
		
		return object;
	}
	
	
	public static JSONArray getAreas(String token){
		JSONArray array=null;
		Object object = get("/api/gpsservice/cs/area",null,token);
		
		if(object != null){
			 array = JSON.parseArray(object.toString());
		}
		
		return array;
	}
	
	public static JSONArray getDict(Map params,String token){
		JSONArray array=null;
		Object object = get("/api/gpsservice/cs/dataDict",params,token);
		
		if(object != null){
			 array = JSON.parseArray(object.toString());
		}
		
		return array;
	}
	
	
	public static JSONArray getTruckList(Map params,String token){
		JSONArray turckList=null;
		Object object = post(TruckListRequestPath,params,token);
		
		if(object != null){
			 JSONObject jsonObject = JSON.parseObject(object.toString());
        	 turckList = jsonObject.getJSONArray("list");
		}
		
		return turckList;
	}
	


	public static Object updateTruckList(List<Map> updateList,String token) {
		JSONArray turckList=null;
		Object object = post(UpdateTruckRequestPath,updateList,token);
		
		
		return object;
	}
	
	public static Object post(String url,Object obj){
		if(okHttpClient == null){
			okHttpClient = new OkHttpClient.Builder()
	                .connectTimeout(20, TimeUnit.SECONDS)
	                .writeTimeout(20, TimeUnit.SECONDS)
	                .readTimeout(30, TimeUnit.SECONDS)
	                .build();
		}
		
		String token = SecurityUtils.getLoginUser().getToken();
		
		if(token.contains("durable:")){
	    	token = token.replace("durable:", "Bearer durable:auth:token:");
		}else{
	    	token = "Bearer auth:token:"+ token;
		}
    				
    	String param = JSON.toJSON(obj).toString();
    	
    	RequestBody body = RequestBody.create(MediaType.parse("application/json"), param );

        Request request = new Request.Builder().url(remote+url).addHeader("Authorization",token ).post(body).build();

        try {
            okhttp3.Response response = okHttpClient.newCall(request).execute();
            String result = response.body().string();
            
            if(result != null){
            	JSONObject json = JSON.parseObject(result);
            	if(json.getInteger("code") == 200){
            		return json.get("result");
            	}
            	
            }else{
            	return null;
            }
            
        }catch (Exception e) {
        	e.printStackTrace();
        	return null;
		}
        
        return null;
	}

	public static Object get(String url,Map<String,String> obj){
		if(okHttpClient == null){
			okHttpClient = new OkHttpClient.Builder()
	                .connectTimeout(20, TimeUnit.SECONDS)
	                .writeTimeout(20, TimeUnit.SECONDS)
	                .readTimeout(30, TimeUnit.SECONDS)
	                .build();
		}
		
		String token = SecurityUtils.getLoginUser().getToken();

		
		if(token.contains("durable:")){
	    	token = token.replace("durable:", "Bearer durable:auth:token:");
		}else{
	    	token = "Bearer auth:token:"+ token;
		}
		
    	String params = "";
    	
    	
    	if(obj != null){
        	
    		params += "?";
        	
        	for(String key:obj.keySet()){
        		params += key + "=" + obj.get(key) + "&";
        	}
        	
        	params = params.substring(0,params.length()-1);
    	}
    	
    	
    	url += params;

        Request request = new Request.Builder().url(remote+url).addHeader("Authorization",token ).get().build();

        try {
            okhttp3.Response response = okHttpClient.newCall(request).execute();
            String result = response.body().string();
            
            if(result != null){
            	JSONObject json = JSON.parseObject(result);
            	if("success".equals(json.getString("message"))){
            		return json.get("result");
            	}
            }else{
            	return null;
            }
            
        }catch (Exception e) {
        	e.printStackTrace();
        	return null;
		}
        
        return null;
	}
	public static Object post(String url,Object obj,String token){
		if(okHttpClient == null){
			okHttpClient = new OkHttpClient.Builder()
	                .connectTimeout(20, TimeUnit.SECONDS)
	                .writeTimeout(20, TimeUnit.SECONDS)
	                .readTimeout(30, TimeUnit.SECONDS)
	                .build();
		}

    	token = "Bearer "+ token;
    				
    	String param = JSON.toJSON(obj).toString();
    	
    	RequestBody body = RequestBody.create(MediaType.parse("application/json"), param );

        Request request = new Request.Builder().url(remote+url).addHeader("Authorization",token ).post(body).build();

        try {
            okhttp3.Response response = okHttpClient.newCall(request).execute();
            String result = response.body().string();
            
            if(result != null){
            	JSONObject json = JSON.parseObject(result);
            	if(json.getInteger("code") == 200){
            		return json.get("result");
            	}
            	
            }else{
            	return null;
            }
            
        }catch (Exception e) {
        	e.printStackTrace();
        	return null;
		}
        
        return null;
	}

	public static Object get(String url,Map<String,String> obj,String token){
		if(okHttpClient == null){
			okHttpClient = new OkHttpClient.Builder()
	                .connectTimeout(20, TimeUnit.SECONDS)
	                .writeTimeout(20, TimeUnit.SECONDS)
	                .readTimeout(30, TimeUnit.SECONDS)
	                .build();
		}
		
    	token = "Bearer "+ token;
    	String params = "";
    	
    	
    	if(obj != null){
        	
    		params += "?";
        	
        	for(String key:obj.keySet()){
        		params += key + "=" + obj.get(key) + "&";
        	}
        	
        	params = params.substring(0,params.length()-1);
    	}
    	
    	
    	url += params;

        Request request = new Request.Builder().url(remote+url).addHeader("Authorization",token ).get().build();

        try {
            okhttp3.Response response = okHttpClient.newCall(request).execute();
            String result = response.body().string();
            
            if(result != null){
            	JSONObject json = JSON.parseObject(result);
            	if("success".equals(json.getString("message"))){
            		return json.get("result");
            	}
            }else{
            	return null;
            }
            
        }catch (Exception e) {
        	e.printStackTrace();
        	return null;
		}

		return null;
	}
	public static JSONObject getBasevehicleInfo(String id,String token) {
		JSONObject turckList=null;
		Object object = get(BasevehicleInfo + id,null,token);

		if(object != null){
			turckList = JSON.parseObject(object.toString());
			return turckList;
		}

		return turckList;

	}

	public static JSONArray getDriverList(String token) {
	
		if(okHttpClient == null){
			okHttpClient = new OkHttpClient.Builder()
	                .connectTimeout(20, TimeUnit.SECONDS)
	                .writeTimeout(20, TimeUnit.SECONDS)
	                .readTimeout(30, TimeUnit.SECONDS)
	                .build();
		}

    	token = "Bearer "+ token;
    				
    	String param = JSON.toJSON(new HashMap<>()).toString();
    	
    	RequestBody body = RequestBody.create(MediaType.parse("application/json"), param );

        Request request = new Request.Builder().url(remote+DriverListPath).addHeader("Authorization",token ).post(body).build();

        try {
            okhttp3.Response response = okHttpClient.newCall(request).execute();
            String result = response.body().string();
            
            if(result != null){
            	JSONObject json = JSON.parseObject(result);
            	return json.getJSONArray("list");
            	
            }else{
            	return null;
            }
            
        }catch (Exception e) {
        	e.printStackTrace();
        	return null;
		}
	}

	public static Object getAuth(String token) {
		
		return get(GETAUTH, null,token.replace("Bearer ", ""));
	}


}