gfwleak/k18-ntcs-web-ntc
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cgi接口 调整

Browse Source
This commit is contained in:
leijun
2018-11-29 14:29:36 +08:00
parent 4edab49209
commit c479a40536
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/com/nis/util/httpclient/HttpClientUtil.java
View File

@@ -400,6 +400,7 @@ public class HttpClientUtil {
//获取响应结果 //获取响应结果
Builder header = wt.request(MediaType.APPLICATION_JSON).header("Content-Type", MediaType.APPLICATION_JSON); Builder header = wt.request(MediaType.APPLICATION_JSON).header("Content-Type", MediaType.APPLICATION_JSON);
response= header.get(); response= header.get();
int status = response.getStatus();
result= response.readEntity(String.class); result= response.readEntity(String.class);
logger.info("获取消息成功，相应内容如下： " + result); logger.info("获取消息成功，相应内容如下： " + result);
} catch (Exception e) { } catch (Exception e) {

19
src/main/java/com/nis/web/service/configuration/UserManageService.java
View File

@@ -54,7 +54,7 @@ public class UserManageService extends BaseService{
entity.setIsValid(Constants.VALID_NO); entity.setIsValid(Constants.VALID_NO);
userManageDao.insert(entity); userManageDao.insert(entity);
//cgi接口添加 //cgi接口添加
/*String[] ipArray = entity.getServerIp().split(","); String[] ipArray = entity.getServerIp().split(",");
for(String ip :ipArray){ for(String ip :ipArray){
//循环调用接口增加 //循环调用接口增加
Map<String, Object> params = new HashMap<String, Object>(); Map<String, Object> params = new HashMap<String, Object>();
@@ -63,7 +63,7 @@ public class UserManageService extends BaseService{
params.put("user_pwd", entity.getUserPwd()); params.put("user_pwd", entity.getUserPwd());
Map<String,String> map=getUrl(params,Constants.NTC_IP_REUSE_USER_CREATE,request); Map<String,String> map=getUrl(params,Constants.NTC_IP_REUSE_USER_CREATE,request);
//返回处理 //返回处理
}*/ }
} catch (MaatConvertException e) { } catch (MaatConvertException e) {
e.printStackTrace(); e.printStackTrace();
logger.info("获取编译ID出错"); logger.info("获取编译ID出错");
@@ -78,7 +78,7 @@ public class UserManageService extends BaseService{
userManageDao.update(entity); userManageDao.update(entity);
//cgi接口删除旧数据 //cgi接口删除旧数据
String[] ipArray = olduser.getServerIp().split(","); String[] ipArray = olduser.getServerIp().split(",");
/*for(String ip :ipArray){ for(String ip :ipArray){
//循环调用接口删除 //循环调用接口删除
Map<String, Object> params = new HashMap<String, Object>(); Map<String, Object> params = new HashMap<String, Object>();
params.put("server_ip", ip); params.put("server_ip", ip);
@@ -86,14 +86,14 @@ public class UserManageService extends BaseService{
Map<String,String> map=getUrl(params,Constants.NTC_IP_REUSE_USER_DELETE,request); Map<String,String> map=getUrl(params,Constants.NTC_IP_REUSE_USER_DELETE,request);
//返回处理 //返回处理
}*/ }
if(StringUtil.isEmpty(entity.getUserName())){ if(StringUtil.isEmpty(entity.getUserName())){
entity.setUserName(olduser.getUserName()); entity.setUserName(olduser.getUserName());
} }
if(StringUtil.isEmpty(entity.getUserPwd())){ if(StringUtil.isEmpty(entity.getUserPwd())){
entity.setUserPwd(olduser.getUserPwd()); entity.setUserPwd(olduser.getUserPwd());
} }
/*String[] newIpArray = entity.getServerIp().split(","); String[] newIpArray = entity.getServerIp().split(",");
for(String newIp :newIpArray){ for(String newIp :newIpArray){
//循环调用接口添加 //循环调用接口添加
Map<String, Object> params = new HashMap<String, Object>(); Map<String, Object> params = new HashMap<String, Object>();
@@ -102,8 +102,7 @@ public class UserManageService extends BaseService{
params.put("user_pwd", entity.getUserPwd()); params.put("user_pwd", entity.getUserPwd());
Map<String,String> map=getUrl(params,Constants.NTC_IP_REUSE_USER_CREATE,request); Map<String,String> map=getUrl(params,Constants.NTC_IP_REUSE_USER_CREATE,request);
//返回处理 //返回处理
}
}*/
}catch (Exception e) { }catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
logger.info("获取编译ID出错"); logger.info("获取编译ID出错");
@@ -114,7 +113,7 @@ public class UserManageService extends BaseService{
public Map<String,String> getUrl(Map<String, Object> params,String urlType,HttpServletRequest request){ public Map<String,String> getUrl(Map<String, Object> params,String urlType,HttpServletRequest request){
Map<String,String> map=new HashMap<String,String>(); Map<String,String> map=new HashMap<String,String>();
try{ try{
String url =Constants.IP_REUSE_CALL_CGI_URL+ Constants.NTC_IP_REUSE_USER_GET ; String url =Constants.IP_REUSE_CALL_CGI_URL+ urlType ;
String recv = HttpClientUtil.getCGI(url, params, request); String recv = HttpClientUtil.getCGI(url, params, request);
logger.info("查询结果:" + recv); logger.info("查询结果:" + recv);
if (StringUtils.isNotBlank(recv)) { if (StringUtils.isNotBlank(recv)) {
@@ -172,7 +171,7 @@ public class UserManageService extends BaseService{
userManageDao.update(entity); userManageDao.update(entity);
} }
//cgi接口删除旧数据 //cgi接口删除旧数据
/*for (int i = 0; i < userList.size(); i++) { for (int i = 0; i < userList.size(); i++) {
String[] ipArray = userList.get(i).getServerIp().split(","); String[] ipArray = userList.get(i).getServerIp().split(",");
for(String ip :ipArray){ for(String ip :ipArray){
//循环调用接口删除 //循环调用接口删除
@@ -182,7 +181,7 @@ public class UserManageService extends BaseService{
Map<String,String> map=getUrl(params,Constants.NTC_IP_REUSE_USER_DELETE,request); Map<String,String> map=getUrl(params,Constants.NTC_IP_REUSE_USER_DELETE,request);
//返回处理 //返回处理
} }
}*/ }
} catch (Exception e) { } catch (Exception e) {
logger.error("查询失败", e); logger.error("查询失败", e);
} }