formatting code

pull/776/head
airoger 3 years ago
parent 450351ec18
commit a430e48661

@ -26,5 +26,4 @@ public class ConfigModifyTypeConstants {
public static final int WEB_THREAD_POOL = 3;
public static final int ADAPTER_THREAD_POOL = 4;
}

@ -27,7 +27,7 @@ import javax.validation.constraints.Pattern;
public class ConfigModifySaveReqDTO {
/**
* thread pool config change type
* Thread pool config change type.
*/
private Integer type;

@ -28,7 +28,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
public interface ConfigModificationQueryService {
/**
* query config modification application page
* query config modification application page.
*
* @param reqDTO
* @return
*/
@ -36,6 +37,7 @@ public interface ConfigModificationQueryService {
/**
* query config modification detail by application id
*
* @param id
* @return
*/

@ -21,30 +21,34 @@ import cn.hippo4j.config.model.biz.threadpool.ConfigModifySaveReqDTO;
import cn.hippo4j.config.model.biz.threadpool.ConfigModifyVerifyReqDTO;
/**
* config modification verify service
* Config modification verify service.
*/
public interface ConfigModificationVerifyService {
/**
* get type
* Get type
*
* @return
*/
Integer type();
/**
* save config change application
* Save config change application.
*
* @param reqDTO
*/
void saveConfigModifyApplication(ConfigModifySaveReqDTO reqDTO);
/**
* reject config modification
* Reject config modification.
*
* @param reqDTO
*/
void rejectModification(ConfigModifyVerifyReqDTO reqDTO);
/**
* accept config modification
* Accept config modification.
*
* @param reqDTO
*/
void acceptModification(ConfigModifyVerifyReqDTO reqDTO);

@ -50,7 +50,6 @@ public abstract class AbstractConfigModificationVerifyService implements ConfigM
HisConfigVerifyInfo hisConfigVerifyInfo = BeanUtil.convert(reqDTO, HisConfigVerifyInfo.class);
hisConfigVerifyInfo.setContent(JSONUtil.toJSONString(reqDTO));
hisConfigVerifyInfo.setVerifyStatus(VerifyEnum.TO_VERIFY.getVerifyStatus());
hisConfigVerifyMapper.insert(hisConfigVerifyInfo);
}
@ -61,22 +60,17 @@ public abstract class AbstractConfigModificationVerifyService implements ConfigM
.set(HisConfigVerifyInfo::getVerifyStatus, VerifyEnum.VERIFY_REJECT.getVerifyStatus())
.set(HisConfigVerifyInfo::getGmtVerify, new Date())
.set(HisConfigVerifyInfo::getVerifyUser, UserContext.getUserName());
hisConfigVerifyMapper.update(null, updateWrapper);
}
public void acceptModification(ConfigModifyVerifyReqDTO reqDTO) {
updateThreadPoolParameter(reqDTO);
LambdaUpdateWrapper<HisConfigVerifyInfo> updateWrapper = new LambdaUpdateWrapper<HisConfigVerifyInfo>()
.eq(HisConfigVerifyInfo::getId, reqDTO.getId())
.set(HisConfigVerifyInfo::getVerifyStatus, VerifyEnum.VERIFY_ACCEPT.getVerifyStatus())
.set(HisConfigVerifyInfo::getGmtVerify, new Date())
.set(HisConfigVerifyInfo::getVerifyUser, UserContext.getUserName());
hisConfigVerifyMapper.update(null, updateWrapper);
Date gmtVerify = hisConfigVerifyMapper.selectById(reqDTO.getId()).getGmtVerify();
LambdaUpdateWrapper<HisConfigVerifyInfo> invalidUpdateWrapper = new LambdaUpdateWrapper<HisConfigVerifyInfo>()
.eq(HisConfigVerifyInfo::getType, reqDTO.getType())
@ -87,11 +81,11 @@ public abstract class AbstractConfigModificationVerifyService implements ConfigM
.lt(HisConfigVerifyInfo::getGmtVerify, gmtVerify)
.set(HisConfigVerifyInfo::getVerifyStatus, VerifyEnum.VERIFY_INVALID.getVerifyStatus());
hisConfigVerifyMapper.update(null, invalidUpdateWrapper);
}
/**
* get client address
*
* @param reqDTO
* @return
*/
@ -103,7 +97,7 @@ public abstract class AbstractConfigModificationVerifyService implements ConfigM
() -> leases.forEach(lease -> clientAddressList.add(lease.getHolder().getCallBackUrl())),
() -> clientAddressList.add(
leases.stream()
.filter(lease -> lease.getHolder().getIdentify().equals(reqDTO.getIdentify())).findAny().orElseThrow(() -> new RuntimeException("线程池实例不存在")).getHolder()
.filter(lease -> lease.getHolder().getIdentify().equals(reqDTO.getIdentify())).findAny().orElseThrow(() -> new RuntimeException("线程池实例不存在")).getHolder()
.getCallBackUrl()));
return clientAddressList;
}
@ -113,5 +107,4 @@ public abstract class AbstractConfigModificationVerifyService implements ConfigM
* @param reqDTO
*/
protected abstract void updateThreadPoolParameter(ConfigModifyVerifyReqDTO reqDTO);
}

@ -27,7 +27,7 @@ import java.util.HashMap;
import java.util.Map;
/**
* config change verify service choose
* Config change verify service choose
*/
@Component
public class ConfigModificationVerifyServiceChoose implements CommandLineRunner {

Loading…
Cancel
Save