diff --git a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/controller/MachineEnvController.java b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/controller/MachineEnvController.java index 48a1ec8e..cebe922b 100644 --- a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/controller/MachineEnvController.java +++ b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/controller/MachineEnvController.java @@ -57,7 +57,7 @@ public class MachineEnvController { return success(true); } - @GetMapping("/listByMachineId") + @GetMapping("/getByMachineId") @Operation(summary = "获取机器的环境变量") public CommonResult getByMachineId( @RequestParam Long machineId) { diff --git a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/controller/MachineProxyController.java b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/controller/MachineProxyController.java index fdb991fc..847dd9f3 100644 --- a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/controller/MachineProxyController.java +++ b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/controller/MachineProxyController.java @@ -34,7 +34,7 @@ public class MachineProxyController { } @GetMapping("/list") - @Operation(summary ="获取代理") + @Operation(summary ="获取代理列表") public CommonResult list(MachineProxyDTO machineProxyDTO) { return success(machineProxyService.list(machineProxyDTO)); } @@ -46,13 +46,6 @@ public class MachineProxyController { return success(true); } - @PostMapping("/receiptHeartbeat") - @Operation(summary ="接收代理心跳") - public CommonResult heartbeat(@RequestBody MachineProxyDTO machineProxyDTO) { - machineProxyService.heartbeat(machineProxyDTO); - return success(true); - } - @GetMapping("/statistics/status") @Operation(summary ="获取所有代理的状态统计") public CommonResult getStatusStatistics() { @@ -68,7 +61,7 @@ public class MachineProxyController { @DeleteMapping("/batch") @Operation(summary ="批量删除代理") - public CommonResult deleteBatch(@RequestBody List ids) { + public CommonResult deleteBatch(@RequestParam List ids) { machineProxyService.delete(ids); return success(true); } diff --git a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/dto/MachineEnvDTO.java b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/dto/MachineEnvDTO.java index 212fd38a..f0da272b 100644 --- a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/dto/MachineEnvDTO.java +++ b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/dto/MachineEnvDTO.java @@ -19,7 +19,7 @@ public class MachineEnvDTO extends PageDto implements Serializable { private Long id; private String envKey; private String envValue; - private Boolean sensitive; + private Integer sensitive;//(1敏感,0不敏感) private String description; private Long machineId; private Date createDate; @@ -32,7 +32,7 @@ public class MachineEnvDTO extends PageDto implements Serializable { * 获取脱敏后的环境变量值 */ public String getMaskedValue() { - if (!sensitive || envValue == null) { + if (sensitive==1 || envValue == null) { return envValue; } int length = envValue.length(); diff --git a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/entity/MachineEnv.java b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/entity/MachineEnv.java index e43d77c6..612dad3e 100644 --- a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/entity/MachineEnv.java +++ b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/entity/MachineEnv.java @@ -37,7 +37,8 @@ public class MachineEnv extends BaseEntity implements Serializable { /** * 是否敏感 */ - private Boolean sensitive; + @TableField("`sensitive`") + private Integer sensitive;//(1敏感,0不敏感) /** * 描述信息 @@ -45,9 +46,4 @@ public class MachineEnv extends BaseEntity implements Serializable { private String description; - /** - * 逻辑删除标志 - */ - @TableLogic - private Boolean deleted; } diff --git a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/entity/MachineProxy.java b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/entity/MachineProxy.java index 14f1eb7b..97585314 100644 --- a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/entity/MachineProxy.java +++ b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/entity/MachineProxy.java @@ -61,9 +61,5 @@ public class MachineProxy extends BaseEntity implements Serializable { private String description; - /** - * 逻辑删除标志 - */ - @TableLogic - private Boolean deleted; + } diff --git a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/service/MachineProxyService.java b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/service/MachineProxyService.java index 63b3c5e1..532a790d 100644 --- a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/service/MachineProxyService.java +++ b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/service/MachineProxyService.java @@ -21,10 +21,6 @@ public interface MachineProxyService extends IService { */ boolean updateStatus(MachineProxyDTO machineProxyDTO); - /** - * 接收代理心跳 - */ - boolean heartbeat(MachineProxyDTO machineProxyDTO); /** @@ -37,7 +33,7 @@ public interface MachineProxyService extends IService { /** * 更新代理配置 */ - boolean updateConfig(MachineProxyDTO machineProxyDTO); + void updateConfig(MachineProxyDTO machineProxyDTO); diff --git a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/service/impl/MachineEnvServiceImpl.java b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/service/impl/MachineEnvServiceImpl.java index d08fab41..d2e3805c 100644 --- a/modules/module-ci-machine/src/main/java/cd/casic/module/machine/service/impl/MachineEnvServiceImpl.java +++ b/modules/module-ci-machine/src/main/java/cd/casic/module/machine/service/impl/MachineEnvServiceImpl.java @@ -41,7 +41,7 @@ public class MachineEnvServiceImpl extends ServiceImpl onlineProxies = list(new LambdaQueryWrapper() .in(MachineProxy::getId, ids) - .eq(MachineProxy::getStatus, MachineProxyStatus.ONLINE.getCode())); + .eq(MachineProxy::getStatusCode, MachineProxyStatus.ONLINE.getCode())); if (!CollectionUtils.isEmpty(onlineProxies)) { List onlineIds = onlineProxies.stream()