diff --git a/src/main/java/neatlogic/module/deploy/api/appconfig/env/SearchDeployAppModuleEnvAutoConfigInstanceApi.java b/src/main/java/neatlogic/module/deploy/api/appconfig/env/SearchDeployAppModuleEnvAutoConfigInstanceApi.java index 47cd794420b7edaee17f59f9f149c4e02cf68ef4..d8a085644d3c7a63673956c31b1b9a7b4a3429e8 100644 --- a/src/main/java/neatlogic/module/deploy/api/appconfig/env/SearchDeployAppModuleEnvAutoConfigInstanceApi.java +++ b/src/main/java/neatlogic/module/deploy/api/appconfig/env/SearchDeployAppModuleEnvAutoConfigInstanceApi.java @@ -58,6 +58,7 @@ public class SearchDeployAppModuleEnvAutoConfigInstanceApi extends PrivateApiCom @Param(name = "appModuleId", type = ApiParamType.LONG, isRequired = true, desc = "模块 id"), @Param(name = "envId", type = ApiParamType.LONG, isRequired = true, desc = "环境 id"), @Param(name = "isAutoConfig", type = ApiParamType.INTEGER, desc = "是否有AutoConfig"), + @Param(name = "defaultValue", type = ApiParamType.JSONARRAY, desc = "默认值"), @Param(name = "currentPage", type = ApiParamType.INTEGER, desc = "当前页"), @Param(name = "pageSize", type = ApiParamType.INTEGER, desc = "每页数据条目"), @Param(name = "needPage", type = ApiParamType.BOOLEAN, desc = "是否需要分页,默认true") diff --git a/src/main/java/neatlogic/module/deploy/api/schedule/ListDeployScheduleApi.java b/src/main/java/neatlogic/module/deploy/api/schedule/ListDeployScheduleApi.java index eaeb732e55605923336ec5364b605526e321e183..fada341f842535ef8b7826d464c5d0624fdb2397 100644 --- a/src/main/java/neatlogic/module/deploy/api/schedule/ListDeployScheduleApi.java +++ b/src/main/java/neatlogic/module/deploy/api/schedule/ListDeployScheduleApi.java @@ -104,23 +104,23 @@ public class ListDeployScheduleApi extends PrivateApiComponentBase { int rowNum = deployScheduleMapper.getScheduleCount(searchVo); if (rowNum > 0) { searchVo.setRowNum(rowNum); - if (searchVo.getCurrentPage() <= searchVo.getPageCount()) { - IAppSystemMapper appSystemMapper = CrossoverServiceFactory.getApi(IAppSystemMapper.class); - tbodyList = deployScheduleMapper.getScheduleList(searchVo); - List idList = tbodyList.stream().map(DeployScheduleVo::getId).collect(Collectors.toList()); + IAppSystemMapper appSystemMapper = CrossoverServiceFactory.getApi(IAppSystemMapper.class); + List idList = deployScheduleMapper.getScheduleIdList(searchVo); + if (CollectionUtils.isNotEmpty(idList)) { + tbodyList = deployScheduleMapper.getScheduleListByIdList(idList); List scheduleAuditCountList = deployScheduleMapper.getScheduleAuditCountListByIdList(idList); - Map scheduleMap = scheduleAuditCountList.stream().collect(Collectors.toMap(e -> e.getId(), e -> e)); + Map scheduleMap = scheduleAuditCountList.stream().collect(Collectors.toMap(DeployScheduleVo::getId, e -> e)); Map appSystemMap = new HashMap<>(); List appSystemIdList = tbodyList.stream().map(DeployScheduleVo::getAppSystemId).collect(Collectors.toList()); if (CollectionUtils.isNotEmpty(appSystemIdList)) { List appSystemList = appSystemMapper.getAppSystemListByIdList(appSystemIdList); - appSystemMap = appSystemList.stream().collect(Collectors.toMap(e -> e.getId(), e -> e)); + appSystemMap = appSystemList.stream().collect(Collectors.toMap(AppSystemVo::getId, e -> e)); } Map appModuleMap = new HashMap<>(); List appModuleIdList = tbodyList.stream().map(DeployScheduleVo::getAppModuleId).collect(Collectors.toList()); if (CollectionUtils.isNotEmpty(appModuleIdList)) { List appModuleList = appSystemMapper.getAppModuleListByIdList(appModuleIdList); - appModuleMap = appModuleList.stream().collect(Collectors.toMap(e -> e.getId(), e -> e)); + appModuleMap = appModuleList.stream().collect(Collectors.toMap(AppModuleVo::getId, e -> e)); } List pipelineIdList = tbodyList.stream().map(DeployScheduleVo::getPipelineId).collect(Collectors.toList()); if (CollectionUtils.isNotEmpty(pipelineIdList)) { diff --git a/src/main/java/neatlogic/module/deploy/dao/mapper/DeployAppConfigMapper.xml b/src/main/java/neatlogic/module/deploy/dao/mapper/DeployAppConfigMapper.xml index 38d4f728e0e03ca86d8c904975016a20f7dd98b3..ee01bf36d8016eb061290986a38b218b9df62a03 100644 --- a/src/main/java/neatlogic/module/deploy/dao/mapper/DeployAppConfigMapper.xml +++ b/src/main/java/neatlogic/module/deploy/dao/mapper/DeployAppConfigMapper.xml @@ -940,7 +940,10 @@ along with this program. If not, see .--> #{item} - + + AND + + and b.`config` is not NULL @@ -963,32 +966,29 @@ along with this program. If not, see .--> - - AND - (daca.app_system_id is null - OR - (daca.action_type = 'operation' - AND daca.action IN - ('all' - , - - #{item} - - - ) - AND daca.auth_uuid IN - ( - 'alluser' - - , - - #{item} - - - ) - ) - ) + (daca.app_system_id is null + OR + (daca.action_type = 'operation' + AND daca.action IN + ('all' + , + + #{item} + + ) + AND daca.auth_uuid IN + ( + 'alluser' + + , + + #{item} + + + ) + ) + ) SELECT - COUNT(1) + COUNT(DISTINCT a.`id`) FROM `deploy_schedule` a LEFT JOIN `deploy_app_config_authority` daca ON daca.`app_system_id` = a.`app_system_id` @@ -100,31 +100,15 @@ along with this program. If not, see .--> - SELECT - a.`id`, - a.`uuid`, - a.`name`, - a.`begin_time` AS beginTime, - a.`end_time` AS endTime, - a.`cron`, - a.`is_active` AS isActive, - a.`config` AS configStr, - a.`type`, - a.`fcd`, - a.`fcu`, - a.`lcd`, - a.`lcu`, - a.`app_system_id` AS appSystemId, - a.`app_module_id` AS appModuleId, - a.`pipeline_id` AS pipelineId, - a.`pipeline_type` AS pipelineType + DISTINCT a.`id` FROM `deploy_schedule` a LEFT JOIN `deploy_app_config_authority` daca ON daca.`app_system_id` = a.`app_system_id` - ORDER BY a.`lcd` + ORDER BY a.`id` LIMIT #{startNum}, #{pageSize} diff --git a/src/main/java/neatlogic/module/deploy/dao/mapper/DeployVersionMapper.xml b/src/main/java/neatlogic/module/deploy/dao/mapper/DeployVersionMapper.xml index d191a631a08e229abfd1fc9dfe1852648a34bb96..81cd4a4cb0585de6c874bfd55e06d0f5216d3f80 100644 --- a/src/main/java/neatlogic/module/deploy/dao/mapper/DeployVersionMapper.xml +++ b/src/main/java/neatlogic/module/deploy/dao/mapper/DeployVersionMapper.xml @@ -150,7 +150,10 @@ along with this program. If not, see .--> dv.`fcd` <= FROM_UNIXTIME(#{startTimeRange[1]}) ) - + + AND + + diff --git a/src/main/java/neatlogic/module/deploy/schedule/plugin/DeployJobScheduleJob.java b/src/main/java/neatlogic/module/deploy/schedule/plugin/DeployJobScheduleJob.java index 7723a04342e6ec2198b346f8e14c4828159d1085..d21d7a6c1c8a860aa500563a619dd6b4848d4913 100644 --- a/src/main/java/neatlogic/module/deploy/schedule/plugin/DeployJobScheduleJob.java +++ b/src/main/java/neatlogic/module/deploy/schedule/plugin/DeployJobScheduleJob.java @@ -33,6 +33,7 @@ import neatlogic.module.deploy.dao.mapper.DeployPipelineMapper; import neatlogic.module.deploy.dao.mapper.DeployScheduleMapper; import neatlogic.module.deploy.service.DeployBatchJobService; import neatlogic.module.deploy.service.DeployJobService; +import org.apache.commons.collections4.CollectionUtils; import org.quartz.DisallowConcurrentExecution; import org.quartz.JobExecutionContext; import org.springframework.stereotype.Component; @@ -98,12 +99,15 @@ public class DeployJobScheduleJob extends JobBase { int pageCount = searchVo.getPageCount(); for (int currentPage = 1; currentPage <= pageCount; currentPage++) { searchVo.setCurrentPage(currentPage); - List list = deployScheduleMapper.getScheduleList(searchVo); - for (DeployScheduleVo scheduleVo : list) { - JobObject.Builder jobObjectBuilder = new JobObject - .Builder(scheduleVo.getUuid(), this.getGroupName(), this.getClassName(), TenantContext.get().getTenantUuid()); - JobObject jobObject = jobObjectBuilder.build(); - this.reloadJob(jobObject); + List idList = deployScheduleMapper.getScheduleIdList(searchVo); + if (CollectionUtils.isNotEmpty(idList)) { + List list = deployScheduleMapper.getScheduleListByIdList(idList); + for (DeployScheduleVo scheduleVo : list) { + JobObject.Builder jobObjectBuilder = new JobObject + .Builder(scheduleVo.getUuid(), this.getGroupName(), this.getClassName(), TenantContext.get().getTenantUuid()); + JobObject jobObject = jobObjectBuilder.build(); + this.reloadJob(jobObject); + } } } }