|
|
|
@ -167,7 +167,7 @@ public class IdcServiceImpl implements IdcService {
|
|
|
|
|
}
|
|
|
|
|
logger.info("fetch from ip:" + host);
|
|
|
|
|
if (!StringUtils.isEmpty(host)) {
|
|
|
|
|
String result = post(host + "/spssync/common/list", null);
|
|
|
|
|
String result = IDCUtils.post(host + "/spssync/common/list", null);
|
|
|
|
|
|
|
|
|
|
if (IDCUtils.isJson(result)) {
|
|
|
|
|
JSONObject json = JSON.parseObject(result);
|
|
|
|
@ -306,7 +306,7 @@ public class IdcServiceImpl implements IdcService {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (success) {
|
|
|
|
|
String ret = post(host + "/spssync/common/success", params);
|
|
|
|
|
String ret = IDCUtils.post(host + "/spssync/common/success", params);
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -318,29 +318,7 @@ public class IdcServiceImpl implements IdcService {
|
|
|
|
|
return result;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private String post(String url, Map<String, Object> params) {
|
|
|
|
|
OkHttpClient client = new OkHttpClient().newBuilder()
|
|
|
|
|
.build();
|
|
|
|
|
MediaType mediaType = MediaType.parse("application/json");
|
|
|
|
|
RequestBody body = RequestBody.create(mediaType, "");
|
|
|
|
|
if (params != null)
|
|
|
|
|
body = RequestBody.create(mediaType, JSON.toJSONString(params));
|
|
|
|
|
Request request = new Request.Builder()
|
|
|
|
|
.url(url)
|
|
|
|
|
.method("POST", body)
|
|
|
|
|
.addHeader("Content-Type", "application/json")
|
|
|
|
|
.build();
|
|
|
|
|
String result = "";
|
|
|
|
|
try {
|
|
|
|
|
Response response = client.newCall(request).execute();
|
|
|
|
|
result = response.body().string();
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
// TODO Auto-generated catch block
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
return result;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public BaseResponse downlaodSuccess(HttpServletRequest request, Map<String, Object> params) {
|
|
|
|
|
String sql = "update basic_export_status set receiveStatus='1',endTime=now() where id='" + params.get("taskId") + "'";
|
|
|
|
|