package com.landtool.lanbase.modules.res.service.impl;
|
|
import java.io.IOException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import org.apache.http.HttpEntity;
|
import org.apache.http.NameValuePair;
|
import org.apache.http.client.entity.UrlEncodedFormEntity;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.message.BasicNameValuePair;
|
import org.apache.http.util.EntityUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.landtool.lanbase.config.SysTemPropertyConfig;
|
import com.landtool.lanbase.modules.res.dao.Res_StorageConfigMapper;
|
import com.landtool.lanbase.modules.res.entity.Res_ExtDataSource;
|
import com.landtool.lanbase.modules.res.entity.Res_StorageConfig;
|
import com.landtool.lanbase.modules.res.service.ResStorageConfigService;
|
|
@Service("ResStorageConfigService")
|
public class ResStorageConfigServiceImpl implements ResStorageConfigService{
|
|
@Autowired
|
private Res_StorageConfigMapper dao;
|
@Autowired
|
private SysTemPropertyConfig sysConfig;
|
|
@Override
|
public Res_StorageConfig findStorageConfigByResourceid(int resourceid) {
|
// TODO Auto-generated method stub
|
return dao.findStorageConfigByResourceid(resourceid);
|
}
|
|
@Override
|
public int insertStorageConfig(Res_StorageConfig res_storageConfig) {
|
// TODO Auto-generated method stub
|
return dao.insertStorageConfig(res_storageConfig);
|
}
|
|
@Override
|
public int updateStorageConfig(Res_StorageConfig res_storageConfig) {
|
// TODO Auto-generated method stub
|
return dao.updateStorageConfig(res_storageConfig);
|
}
|
|
@Override
|
public int deleteByResourceid(int resourceid) {
|
// TODO Auto-generated method stub
|
return dao.deleteByResourceid(resourceid);
|
}
|
|
@Override
|
public String invoke(Res_StorageConfig res_storageConfig,Res_ExtDataSource res_ExtDataSource,String ncFilePath) {
|
CloseableHttpClient closeHttpClient = HttpClients.createDefault();
|
CloseableHttpResponse response =null;
|
String body ="";
|
//发送post请求
|
HttpPost httpPost = new HttpPost(sysConfig.getNcStorageUrl());
|
|
//设置参数
|
List<NameValuePair> params = new ArrayList<NameValuePair>();
|
// params.add(new BasicNameValuePair("nc_file","http://192.168.0.130:8080/webapp/data/nc/hailang.nc"));
|
params.add(new BasicNameValuePair("nc_file",ncFilePath));
|
// params.add(new BasicNameValuePair("debug_count", "1"));
|
|
if(res_storageConfig.getUvparams()!=null && !res_storageConfig.getUvparams().equals("")){
|
JSONObject jsonObject = JSONObject.parseObject(res_storageConfig.getUvparams());
|
String uvariables = jsonObject.get("uvariables").toString();
|
String vvariables = jsonObject.get("vvariables").toString();
|
String layer = jsonObject.get("layer").toString();
|
|
if(uvariables!=null && !uvariables.equals("") && vvariables!=null && !vvariables.equals("")){
|
params.add(new BasicNameValuePair("nc_u_var",uvariables));
|
params.add(new BasicNameValuePair("nc_v_var",vvariables));
|
}
|
if(res_ExtDataSource.getFeature()!=null && !res_ExtDataSource.getFeature().equals("")){
|
params.add(new BasicNameValuePair("to_db_layername",res_ExtDataSource.getFeature()+"/"+layer));
|
}else{
|
params.add(new BasicNameValuePair("to_db_layername",layer));
|
}
|
params.add(new BasicNameValuePair("nc_data_var",""));
|
params.add(new BasicNameValuePair("nc_row_dimensions",""));
|
}
|
|
if(res_storageConfig.getVariableparams()!=null && !res_storageConfig.getVariableparams().equals("")){
|
JSONObject jsonObject = JSONObject.parseObject(res_storageConfig.getVariableparams());
|
String nc_data_var = jsonObject.get("nc_data_var").toString();
|
String rowDimensions = jsonObject.get("rowDimensions").toString();
|
String layer = jsonObject.get("layer").toString();
|
|
if(nc_data_var!=null && !nc_data_var.equals("") && rowDimensions!=null && !rowDimensions.equals("")){
|
params.add(new BasicNameValuePair("nc_data_var",nc_data_var));
|
params.add(new BasicNameValuePair("nc_row_dimensions",rowDimensions));
|
}
|
params.add(new BasicNameValuePair("nc_u_var",""));
|
params.add(new BasicNameValuePair("nc_v_var",""));
|
if(res_ExtDataSource.getFeature()!=null && !res_ExtDataSource.getFeature().equals("")){
|
params.add(new BasicNameValuePair("to_db_layername",res_ExtDataSource.getFeature()+"/"+layer));
|
}else{
|
params.add(new BasicNameValuePair("to_db_layername",layer));
|
}
|
}
|
|
params.add(new BasicNameValuePair("nc_x_var",res_storageConfig.getLonName()));
|
params.add(new BasicNameValuePair("nc_y_var",res_storageConfig.getLatName()));
|
params.add(new BasicNameValuePair("nc_time_var",res_storageConfig.getTimeName()));
|
if(res_ExtDataSource.getDatabasetype().equalsIgnoreCase("Oracle")){
|
params.add(new BasicNameValuePair("to_db_platform",res_ExtDataSource.getDatabasetype()));
|
// params.add(new BasicNameValuePair("to_db_platform","192.168.0.215/PDBGDHYXJ"));
|
params.add(new BasicNameValuePair("to_db_instance", res_ExtDataSource.getServeraddress()+"/"+res_ExtDataSource.getDatabasename()));
|
}
|
if(res_ExtDataSource.getDatabasetype().equalsIgnoreCase("SQLServer")){
|
params.add(new BasicNameValuePair("to_db_platform","SQL_SERVER"));
|
params.add(new BasicNameValuePair("to_db_instance", res_ExtDataSource.getServeraddress()));
|
params.add(new BasicNameValuePair("to_db_database", res_ExtDataSource.getDatabasename()));
|
}
|
params.add(new BasicNameValuePair("to_db_username",res_ExtDataSource.getUsername()));
|
params.add(new BasicNameValuePair("to_db_password",res_ExtDataSource.getPassword()));
|
|
params.add(new BasicNameValuePair("returnZ","false"));
|
params.add(new BasicNameValuePair("returnM","false"));
|
params.add(new BasicNameValuePair("returnTrueCurves","false"));
|
params.add(new BasicNameValuePair("f","json"));
|
System.out.println(params.toString());
|
try {
|
httpPost.setEntity(new UrlEncodedFormEntity(params, "UTF-8"));
|
response = closeHttpClient.execute(httpPost);
|
HttpEntity entity = response.getEntity();
|
int statusCode = response.getStatusLine().getStatusCode();
|
if(statusCode==200){ //请求成功
|
if(entity!=null){
|
body=EntityUtils.toString(entity);
|
}
|
}
|
EntityUtils.consume(entity);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}finally{
|
try {
|
httpPost=null;
|
response.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return body;
|
}
|
|
}
|
