Commit 6b2d4890 authored by zhengfunan's avatar zhengfunan

json解析

parent df2f2307
......@@ -74,6 +74,12 @@
<version>2.9.6</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.10.1</version>
</dependency>
</dependencies>
<build>
......
package com.tongda.tdpimssdk.api;
public class Pim {
// private String
}
package com.tongda.tdpimssdk.api;
import com.alibaba.fastjson.JSONObject;
import com.tongda.tdpimssdk.auth.SaAuth;
import com.tongda.tdpimssdk.entities.common.CatalogRoot;
import com.tongda.tdpimssdk.http.PimHttpUtil;
import java.util.List;
public class PimsApi {
public List<CatalogRoot> pimsTemplate(){
String url="http://"+ SaAuth.serverId +":"+SaAuth.serverPort+"/pims/template?dbName="+SaAuth.dbName;
String response=PimHttpUtil.sendGet(url);
String s=resultUtil(response);
JSONObject.parseArray(s,CatalogRoot.class);
return JSONObject.parseArray(s,CatalogRoot.class);
}
public static String resultUtil(String re){
System.out.println(re);
JSONObject jsonObject=JSONObject.parseObject(re);
if (jsonObject.get("code").toString().equals("200")){
return jsonObject.get("data").toString();
}else {
throw new RuntimeException("调用接口异常:"+re);
}
}
}
package com.tongda.tdpimssdk.auth;
import com.alibaba.fastjson.JSONObject;
import com.tongda.tdpimssdk.http.PimHttpUtil;
import lombok.Data;
import java.util.HashMap;
@Data
public class Login {
private String user;
private String password;
private String satoken;
public static void main(String[] args) {
String url="http://121.199.160.117:9000/sso/doLogin";
// String url="http://121.199.160.117:9000/sso/auth?redirect=#";
String satoken=PimHttpUtil.loginGet(url,"zhengfunan","q1w2e3r4");
System.out.println("aaaaaaaaaaaaaaaaaaa;"+satoken);
String testurl="http://150.158.75.213:8080/pims/metadata/details?dbName=TXPIMDB&id=storage_warehouse";
PimHttpUtil.sendGet(testurl,new HashMap<>(),satoken);
}
}
package com.tongda.tdpimssdk.auth;
import com.tongda.tdpimssdk.api.PimsApi;
import com.tongda.tdpimssdk.entities.common.CatalogRoot;
import com.tongda.tdpimssdk.http.PimHttpUtil;
import lombok.Data;
import java.util.List;
@Data
public class SaAuth {
public static String user;
public static String password;
public static String id;
public static int port;
public static String satoken;
public static String serverId;
public static int serverPort;
public static String dbName;
public SaAuth(String user, String password, String id, int port) {
this.user = user;
this.password = password;
this.id = id;
this.port = port;
}
public static String loginAndSatoken(){
String url="http://"+id+":"+port+"/sso/doLogin";
satoken=PimHttpUtil.loginGet(url,user,password);
return satoken;
}
public static void main(String[] args) {
SaAuth.serverId="150.158.75.213";
SaAuth.serverPort=8080;
SaAuth.dbName="TXPIMDB";
SaAuth saAuth=new SaAuth("zhengfunan","q1w2e3r4","121.199.160.117",9000);
String satoken=SaAuth.loginAndSatoken();
PimsApi pimsApi =new PimsApi();
List<CatalogRoot> list= pimsApi.pimsTemplate();
System.out.println(list);
// s= pimsApi.pimsTemplate();
// System.out.println(s);
}
}
......@@ -38,44 +38,39 @@ import javax.xml.bind.annotation.XmlType;
*
*
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "", propOrder = {
"candidateValue"
})
@Data
@XmlRootElement(name = "MetadataEntryTemplate")
public class MetadataEntryTemplate extends AbstractDBEntity {
@XmlElement(name = "CandidateValue")
protected List<CandidateValue> candidateValue;
@NotNull(message = "缺少元数据编码字段")
@NotEmpty(message = "元数据编码不能为空")
@XmlAttribute(name = "key", required = true)
protected String key;
@XmlAttribute(name = "mode", required = true)
protected String mode;
@XmlAttribute(name = "modeLabel")
protected String modeLabel;
@XmlAttribute(name = "dataType", required = true)
protected String dataType;
@XmlAttribute(name = "dataTypeLabel")
protected String dataTypeLabel;
@XmlAttribute(name = "uom")
protected String uom;
@XmlAttribute(name = "uomLabel")
protected String uomLabel;
@XmlAttribute(name = "value", required = true)
protected String value;
@XmlAttribute(name = "valueMin")
protected String valueMin;
@XmlAttribute(name = "valueMax")
protected String valueMax;
@XmlAttribute(name = "regPattern")
protected String regPattern;
@XmlAttribute(name = "regPatternLabel")
protected String regPatternLabel;
@XmlAttribute(name = "desc")
protected String desc;
}
......@@ -11,6 +11,7 @@ import javax.xml.bind.annotation.XmlSchemaType;
import javax.xml.bind.annotation.XmlType;
import javax.xml.bind.annotation.XmlValue;
import javax.xml.datatype.XMLGregorianCalendar;
import java.util.GregorianCalendar;
/**
......
package com.tongda.tdpimssdk.http;
import com.tongda.tdpimssdk.auth.SaAuth;
import org.apache.http.Header;
import org.apache.http.HeaderElement;
import org.apache.http.HttpEntity;
......@@ -76,7 +77,7 @@ public class PimHttpUtil {
}
}
public static String sendGet(String url , HashMap hashMap,String satoken){
public static String sendGet(String url){
try {
//创建httpClient实例
CloseableHttpClient client = HttpClients.createDefault();
......@@ -90,12 +91,12 @@ public class PimHttpUtil {
//创建httpGet远程连接实例,这里传入目标的网络地址
HttpGet httpGet = new HttpGet(uriBuilder.build());
httpGet.setHeader("Satoken",satoken);
httpGet.setHeader("Satoken", SaAuth.satoken);
// 设置请求头信息,鉴权(没有可忽略)
// httpGet.setHeader("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");
// 设置配置请求参数(没有可忽略)
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(10000)// 连接主机服务超时时间
.setConnectionRequestTimeout(10000)// 请求超时时间
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(60000)// 连接主机服务超时时间
.setConnectionRequestTimeout(60000)// 请求超时时间
.setSocketTimeout(60000)// 数据读取超时时间
.build();
// 为httpGet实例设置配置
......@@ -113,7 +114,7 @@ public class PimHttpUtil {
response.close();
client.close();
return "";
return str;
} catch (URISyntaxException e) {
throw new RuntimeException(e);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment