package com.highdatas.mdm.util;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.highdatas.mdm.entity.SysField;
|
import com.highdatas.mdm.pojo.CodeMsg;
|
import com.highdatas.mdm.pojo.Result;
|
import com.highdatas.mdm.service.ISysFieldService;
|
import org.jcodings.util.Hash;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
import org.springframework.http.*;
|
import org.springframework.http.client.SimpleClientHttpRequestFactory;
|
import org.springframework.http.converter.StringHttpMessageConverter;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.LinkedMultiValueMap;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.nio.charset.StandardCharsets;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
|
@ConfigurationProperties(prefix = "rule")
|
@Component
|
public class RuleClient {
|
|
@Value("${rule.url}")
|
String url;
|
@Autowired
|
ISysFieldService fieldService;
|
String prefix ;
|
|
private RuleClient() {
|
|
// this.prefix = "/quality/";
|
this.prefix = "/api/datacvg/quality/";
|
}
|
public HashMap<String,Boolean> execuImmeForCollect(String tableName,String userId) {
|
//TODO
|
String url = this.url + prefix + "execuImmeForCollect";
|
HashMap<String, String> params = new HashMap<>();
|
params.put("tableName",tableName);
|
params.put("createUserId",tableName);
|
String s = HttpRestClient(url, HttpMethod.POST, params, null, null);
|
JSONObject result = (JSONObject) JSON.parse(s);
|
String sucess = result.getString(Constant.Success);
|
JSONObject dataObject = result.getJSONObject(Constant.Data);
|
JSONArray jsonArray = dataObject.getJSONArray(Constant.ResultList);
|
HashMap<String, Boolean> resultMap = new HashMap<>();
|
|
for (Object o : jsonArray) {
|
JSONObject oneResult = (JSONObject) o;
|
String fieldName = oneResult.getString(Constant.fieldName);
|
Boolean checked;
|
Integer sucPercent = oneResult.getInteger(Constant.sucPercent);
|
if (sucPercent != null && sucPercent == 100) {
|
checked = true;
|
}else {
|
checked = false;
|
}
|
if (resultMap.containsKey(fieldName) && !checked) {
|
Boolean preChecked = resultMap.get(fieldName);
|
if (preChecked) {
|
resultMap.put(fieldName, checked);
|
}
|
}else {
|
resultMap.put(fieldName, checked);
|
}
|
}
|
return resultMap;
|
}
|
|
public boolean getExecHistoryByTableName(String tableName, Integer pageNo, Integer pageSize) {
|
//TODO
|
String url = this.url + prefix + "getExecHistoryByTableName";
|
HashMap<String, String> params = new HashMap<>();
|
params.put("tableName",tableName);
|
params.put("pageNum",pageNo.toString());
|
params.put("pageSize",pageSize.toString());
|
String s = HttpRestClient(url, HttpMethod.POST, params, null, null);
|
JSONObject result = (JSONObject) JSON.parse(s);
|
String sucess = result.getString(Constant.Success);
|
if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
|
return false;
|
}else {
|
return true;
|
}
|
}
|
|
public Result getRuleByTable(String tableName, String isTemp, String maintainId) {
|
String url = this.url + prefix + "getRuleByTable";
|
HashMap<String, String> params = new HashMap<>();
|
params.put("tableName",tableName);
|
params.put("isTemp",isTemp);
|
|
String s = HttpRestClient(url, HttpMethod.POST, params,null, MediaType.APPLICATION_JSON);
|
JSONObject result = (JSONObject) JSON.parse(s);
|
boolean sucess = result.getBoolean(Constant.Success);
|
if (!sucess) {
|
return Result.error(CodeMsg.Client_fail);
|
}
|
JSONArray jsonArray = result.getJSONArray(Constant.Data);
|
List<SysField> fields = fieldService.getFieldByTable(tableName);
|
HashMap<String, String> fieldMap = new HashMap<>();
|
for (SysField field : fields) {
|
String alias = field.getAlias();
|
String code = field.getField();
|
fieldMap.put(code,alias);
|
}
|
for (Object o : jsonArray) {
|
JSONObject one = (JSONObject) o;
|
String field = one.getString(Constant.fieldName);
|
String alias = fieldMap.get(field);
|
if (!StringUtils.isEmpty(alias)){
|
one.fluentPut(Constant.fieldName, alias);
|
}
|
}
|
return Result.success(jsonArray);
|
}
|
|
|
public String HttpRestClient(String url, HttpMethod method, HashMap<String, String> formParams, String getParams, MediaType mediaType) {
|
if (!StringUtils.isEmpty(getParams)) {
|
url = url + Constant.QUESTION + getParams;
|
}
|
SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
|
requestFactory.setConnectTimeout(15*1000);
|
requestFactory.setReadTimeout(15*1000);
|
RestTemplate client = new RestTemplate(requestFactory);
|
client.getMessageConverters().set(1,new StringHttpMessageConverter(StandardCharsets.UTF_8));
|
HttpHeaders headers = new HttpHeaders();
|
if (mediaType == null){
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
}else {
|
headers.setContentType(mediaType);
|
}
|
|
HttpEntity<HashMap<String, String>> requestEntity = new HttpEntity<HashMap<String, String>>(formParams, headers);
|
// 执行HTTP请求
|
ResponseEntity<String> response = client.exchange(url, method, requestEntity, String.class);
|
|
return response.getBody();
|
}
|
}
|
