k18-ntcs-web-ntc/src/main/java/com/nis/util/ConfigServiceUtil.java

package com.nis.util;

import java.io.File;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import javax.ws.rs.client.Invocation.Builder;
import javax.ws.rs.client.Entity;
import javax.ws.rs.client.WebTarget;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

import net.sf.json.JSONObject;

import org.glassfish.jersey.media.multipart.FormDataMultiPart;
import org.glassfish.jersey.media.multipart.file.FileDataBodyPart;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.nis.exceptions.MaatConvertException;
import com.nis.util.httpclient.ClientUtil;

public class ConfigServiceUtil {
	/**
	 * 从后台服务获取compileid,groupid,regionid
	 * @param type 1是compileid,2是groupid,3是regionid
	 * @return
	 */
	public static List<Integer> getId(int type,int num) throws Exception {
		String result = null;
		String url = "";
		List<Integer> list = new ArrayList();
		if (type == 1) {
			url = Constants.SERVICE_URL+Constants.CONFIG_ID_SOURCES+"?sourceName=CONFIG_COMPILE&num="+num;
		} else if (type == 2) {
			url = Constants.SERVICE_URL+Constants.CONFIG_ID_SOURCES+"?sourceName=CONFIG_GROUP&num="+num;
		} else if (type == 3) {
			url = Constants.SERVICE_URL+Constants.CONFIG_ID_SOURCES+"?sourceName=CONFIG_REGION&num="+num;
		}
		//创建连接
		WebTarget wt = ClientUtil.getWebTarger(url);
		//获取响应结果
		Builder header = wt.request(MediaType.APPLICATION_JSON).header("Content-Type", MediaType.APPLICATION_JSON);
		Response response= header.get(); 
		if( response.getStatus() == 200){
			result= response.readEntity(String.class);
			Gson gson=new GsonBuilder().disableHtmlEscaping()
					.excludeFieldsWithoutExposeAnnotation()
					.create();
			Map<String, Object> resMap = gson.fromJson(result,Map.class);
			if(!StringUtil.isEmpty(resMap)){
				Map<String, Object> dataMap = (Map<String, Object>)resMap.get("data");
				if(!StringUtil.isEmpty(dataMap)){
					list = (List<Integer>)dataMap.get("pzIdList");
					
				}else{
					throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
				}
			}else{
				throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
			}
		}else{
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
		}
		return list;
	}
	/**
	 * MAAT配置提交
	 * @param params
	 * @return
	 * @throws Exception 
	 */
	public static String postMaatCfg(String params) throws Exception{
		String result = null;
		String url = Constants.SERVICE_URL+Constants.MAAT_CFG;
		//创建连接
		WebTarget wt = ClientUtil.getWebTarger(url);
		//获取响应结果
		Builder header = wt.request(MediaType.APPLICATION_JSON).header("Content-Type", MediaType.APPLICATION_JSON);
		Response response= header.post(Entity.entity(params, MediaType.APPLICATION_JSON)); 
		if( response.getStatus() == 200){
			result= response.readEntity(String.class);
		}else{
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
		}
		return result;
		
	}
	/**
	 * 回调配置提交
	 * @param params
	 * @return
	 * @throws Exception 
	 */
	public static String postCallbackCfg(String params) throws Exception{
		String result = null;
		String url = Constants.SERVICE_URL+Constants.CALLBACK_CFG;
		//创建连接
		WebTarget wt = ClientUtil.getWebTarger(url);
		//获取响应结果
		Builder header = wt.request(MediaType.APPLICATION_JSON).header("Content-Type", MediaType.APPLICATION_JSON);
		Response response= header.post(Entity.entity(params, MediaType.APPLICATION_JSON));
		if( response.getStatus() == 200){
			result= response.readEntity(String.class);
		}else{
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
		}
		return result;
		
	}
	/**
	 * 文件配置提交
	 * @param params
	 * @return
	 * @throws Exception 
	 */
	public static String postFileCfg(String params,File file,JSONObject fileDesc) throws Exception{
		String result = null;
		String url = Constants.SERVICE_URL+Constants.FILE_UPLOAD_CFG;
		//创建连接
		WebTarget wt = ClientUtil.getWebTarger(url);
		FormDataMultiPart formDataMultiPart=new FormDataMultiPart();
		FileDataBodyPart bodyPart=new FileDataBodyPart("file",file);
		formDataMultiPart.bodyPart(bodyPart);
		Builder header = wt.request(MediaType.APPLICATION_JSON).header("File-Desc",fileDesc);
		Response response= header.post(Entity.entity(formDataMultiPart, formDataMultiPart.getMediaType())); 
		if( response.getStatus() == 200){
			result= response.readEntity(String.class);
		}else{
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
		}
		return result;
		
	}
	/**
	 * 配置删除
	 * @param params
	 * @param type,1表示maat配置取消，2表示回调配置取消
	 * @return
	 */
	public static String delete(String params,Integer type){
		String result = null;
		String url = Constants.SERVICE_URL;
		if(type==1){
			url = url+Constants.MAAT_CFG;
		}else if(type==2){
			url = url+Constants.CALLBACK_CFG;
		}
		//创建连接
		WebTarget wt = ClientUtil.getWebTarger(url);
		//获取响应结果
		Builder header = wt.request(MediaType.APPLICATION_JSON).header("Content-Type", MediaType.APPLICATION_JSON);
		Response response= header.delete(); 
		if( response.getStatus() == 200){
			result= response.readEntity(String.class);
		}else{
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
		}
		return result;
		
	}
	/**
	 * 配置状态修改
	 * @param params
	 * @param type,1表示maat配置取消，2表示回调配置取消
	 * @return
	 */
	public static String put(String params,Integer type){
		String result = null;
		String url = Constants.SERVICE_URL;
		if(type==1){
			url = url+Constants.MAAT_CFG;
		}else if(type==2){
			url = url+Constants.CALLBACK_CFG;
		}
		//创建连接
		WebTarget wt = ClientUtil.getWebTarger(url);
		//获取响应结果
		Builder header = wt.request(MediaType.APPLICATION_JSON).header("Content-Type", MediaType.APPLICATION_JSON);
		Response response= header.put(Entity.entity(params, MediaType.APPLICATION_JSON));
		if( response.getStatus() == 200){
			result= response.readEntity(String.class);
		}else{
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
		}
		return result;
	}
	/**
	 * 信息获取
	 * @param params
	 * @return
	 * @throws Exception 
	 */
	public static String getFileDigest(String params,File file,Map<String, Object> fileDesc) throws Exception{
		String result = null;	
		String url = Constants.SERVICE_URL+Constants.FILE_DIGEST_CFG;
		//创建连接
		WebTarget wt = ClientUtil.getWebTarger(url);
		FormDataMultiPart formDataMultiPart=new FormDataMultiPart();
		FileDataBodyPart bodyPart=new FileDataBodyPart("file",file);
		formDataMultiPart.bodyPart(bodyPart);
		Builder header = wt.request(MediaType.APPLICATION_JSON).header("File-Desc",ClientUtil.formatFileDesc(fileDesc) );
		Response response= header.post(Entity.entity(formDataMultiPart, formDataMultiPart.getMediaType())); 
		if( response.getStatus() == 200){
			result= response.readEntity(String.class);
		}else{
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
		}
		return result;
	}
	public static void main(String[] args) {
		try {
			//创建连接
			WebTarget wt = ClientUtil.getWebTarger("http://10.0.6.30:8080/maatRest/service/cfg/v1/getCompileId?sourceName=CONFIG_COMPILE&num=1");
			//获取响应结果
			Builder header = wt.request(MediaType.APPLICATION_JSON).header("Content-Type", MediaType.APPLICATION_JSON);
			Response response= header.get(); 
			if( response.getStatus() == 200){
				String result= response.readEntity(String.class);
			}else{
				throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+response.readEntity(String.class));
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}