optmize ConfigVerifyController

pull/776/head
yewei 3 years ago
parent 6dba104d16
commit ccd3999d00

@ -80,7 +80,7 @@ public class ConfigController {
modifySaveReqDTO.setModifyUser(UserContext.getUserName()); modifySaveReqDTO.setModifyUser(UserContext.getUserName());
modifySaveReqDTO.setModifyAll(StringUtil.isNotBlank(identify) ? EnableEnum.NO.getIntCode() : EnableEnum.YES.getIntCode()); modifySaveReqDTO.setModifyAll(StringUtil.isNotBlank(identify) ? EnableEnum.NO.getIntCode() : EnableEnum.YES.getIntCode());
modifySaveReqDTO.setInstanceId(identify); modifySaveReqDTO.setInstanceId(identify);
modifySaveReqDTO.setType(ConfigModifyTypeConstants.WEB_THREAD_POOL); modifySaveReqDTO.setType(ConfigModifyTypeConstants.THREAD_POOL_INSTANCE);
configModifyVerifyServiceChoose.choose(modifySaveReqDTO.getType()).saveConfigModifyApplication(modifySaveReqDTO); configModifyVerifyServiceChoose.choose(modifySaveReqDTO.getType()).saveConfigModifyApplication(modifySaveReqDTO);
} }
return Results.success(true); return Results.success(true);

@ -37,6 +37,11 @@ public class ConfigModifyVerifyReqDTO {
*/ */
private Integer type; private Integer type;
/**
* instance id
*/
private String instanceId;
/** /**
* weather accept config modification * weather accept config modification
*/ */

@ -34,11 +34,6 @@ public class WebThreadPoolReqDTO {
*/ */
private String itemId; private String itemId;
/**
* thread pool instance id
*/
private String instanceId;
/** /**
* Core pool size * Core pool size
*/ */

@ -18,14 +18,22 @@
package cn.hippo4j.config.service.biz.impl; package cn.hippo4j.config.service.biz.impl;
import cn.hippo4j.common.constant.ConfigModifyTypeConstants; import cn.hippo4j.common.constant.ConfigModifyTypeConstants;
import cn.hippo4j.config.model.ConfigAllInfo;
import cn.hippo4j.config.model.biz.threadpool.ConfigModifyVerifyReqDTO; import cn.hippo4j.config.model.biz.threadpool.ConfigModifyVerifyReqDTO;
import cn.hippo4j.config.service.biz.ConfigService;
import cn.hippo4j.config.toolkit.BeanUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Slf4j @Slf4j
@Service @Service
public class ThreadPoolInstanceConfigModifyVerifyServiceImpl extends AbstractConfigModifyVerifyService { public class ThreadPoolInstanceConfigModifyVerifyServiceImpl extends AbstractConfigModifyVerifyService {
@Resource
private ConfigService configService;
@Override @Override
public Integer type() { public Integer type() {
return ConfigModifyTypeConstants.THREAD_POOL_INSTANCE; return ConfigModifyTypeConstants.THREAD_POOL_INSTANCE;
@ -33,7 +41,8 @@ public class ThreadPoolInstanceConfigModifyVerifyServiceImpl extends AbstractCon
@Override @Override
protected void updateThreadPoolParameter(ConfigModifyVerifyReqDTO reqDTO) { protected void updateThreadPoolParameter(ConfigModifyVerifyReqDTO reqDTO) {
ConfigAllInfo config = BeanUtil.convert(reqDTO.getThreadPoolParameterInfo(), ConfigAllInfo.class);
configService.insertOrUpdate(reqDTO.getInstanceId(), true, config);
} }
} }

@ -41,7 +41,7 @@ public class WebThreadPoolConfigModifyVerifyServiceImpl extends AbstractConfigMo
protected void updateThreadPoolParameter(ConfigModifyVerifyReqDTO reqDTO) { protected void updateThreadPoolParameter(ConfigModifyVerifyReqDTO reqDTO) {
WebThreadPoolReqDTO webThreadPoolReqDTO = reqDTO.getWebThreadPoolReqDTO(); WebThreadPoolReqDTO webThreadPoolReqDTO = reqDTO.getWebThreadPoolReqDTO();
for (String each : webThreadPoolReqDTO.getClientAddressList()) { for (String each : webThreadPoolReqDTO.getClientAddressList()) {
String urlString = StrBuilder.create("http://", each, "/adapter/thread-pool/update").toString(); String urlString = StrBuilder.create("http://", each, "/web/update/pool").toString();
HttpUtil.post(urlString, JSONUtil.toJSONString(webThreadPoolReqDTO), HTTP_EXECUTE_TIMEOUT); HttpUtil.post(urlString, JSONUtil.toJSONString(webThreadPoolReqDTO), HTTP_EXECUTE_TIMEOUT);
} }
} }

Loading…
Cancel
Save