新增采集调度器代码生成

segment2.0
linrf 2 years ago
parent c4b29f96dc
commit ff2f44389f

@ -27,7 +27,7 @@ public class CodeGenerator {
AutoGenerator defaultConfig = BaseCodeGenerator.getDefaultConfig();
defaultConfig.getGlobalConfig().setSwagger2(true);
defaultConfig.getStrategy().setEntityLombokModel(true);
defaultConfig.getStrategy().setInclude("task_system_params");//需要生成的表,可指定多个,留空为全部生成
defaultConfig.getStrategy().setInclude("sch_collect_error_log","sch_collect_record","sch_collect_record_retry_log","sch_collector","sch_collector_config","sch_collector_version","sch_collector_version_file","sch_collector_version_log","sch_operation_log","sch_system_params","sch_terminator","sch_virtual_log");//需要生成的表,可指定多个,留空为全部生成
BaseCodeGenerator.generate(defaultConfig);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchCollectErrorLogApi;
import com.docus.server.dto.scheduling.management.SchCollectErrorLogDTO;
import com.docus.server.service.ISchCollectErrorLogService;
import com.docus.server.vo.scheduling.management.SchCollectErrorLogVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchCollectErrorLogController implements SchCollectErrorLogApi {
@Resource
private ISchCollectErrorLogService iSchCollectErrorLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectErrorLogVO findById(String id) {
return iSchCollectErrorLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectErrorLogVO> search(SearchRequest searchRequest) {
return iSchCollectErrorLogService.search(searchRequest);
}
/**
*
*
* @param schCollectErrorLogDTO
* @return
*/
@Override
public boolean add(SchCollectErrorLogDTO schCollectErrorLogDTO) {
return iSchCollectErrorLogService.add(schCollectErrorLogDTO);
}
/**
*
*
* @param schCollectErrorLogDTO
* @return
*/
@Override
public boolean edit(SchCollectErrorLogDTO schCollectErrorLogDTO) {
return iSchCollectErrorLogService.edit(schCollectErrorLogDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchCollectErrorLogService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchCollectRecordApi;
import com.docus.server.dto.scheduling.management.SchCollectRecordDTO;
import com.docus.server.service.ISchCollectRecordService;
import com.docus.server.vo.scheduling.management.SchCollectRecordVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchCollectRecordController implements SchCollectRecordApi {
@Resource
private ISchCollectRecordService iSchCollectRecordService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectRecordVO findById(String id) {
return iSchCollectRecordService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectRecordVO> search(SearchRequest searchRequest) {
return iSchCollectRecordService.search(searchRequest);
}
/**
*
*
* @param schCollectRecordDTO
* @return
*/
@Override
public boolean add(SchCollectRecordDTO schCollectRecordDTO) {
return iSchCollectRecordService.add(schCollectRecordDTO);
}
/**
*
*
* @param schCollectRecordDTO
* @return
*/
@Override
public boolean edit(SchCollectRecordDTO schCollectRecordDTO) {
return iSchCollectRecordService.edit(schCollectRecordDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchCollectRecordService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchCollectRecordRetryLogApi;
import com.docus.server.dto.scheduling.management.SchCollectRecordRetryLogDTO;
import com.docus.server.service.ISchCollectRecordRetryLogService;
import com.docus.server.vo.scheduling.management.SchCollectRecordRetryLogVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchCollectRecordRetryLogController implements SchCollectRecordRetryLogApi {
@Resource
private ISchCollectRecordRetryLogService iSchCollectRecordRetryLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectRecordRetryLogVO findById(String id) {
return iSchCollectRecordRetryLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectRecordRetryLogVO> search(SearchRequest searchRequest) {
return iSchCollectRecordRetryLogService.search(searchRequest);
}
/**
*
*
* @param schCollectRecordRetryLogDTO
* @return
*/
@Override
public boolean add(SchCollectRecordRetryLogDTO schCollectRecordRetryLogDTO) {
return iSchCollectRecordRetryLogService.add(schCollectRecordRetryLogDTO);
}
/**
*
*
* @param schCollectRecordRetryLogDTO
* @return
*/
@Override
public boolean edit(SchCollectRecordRetryLogDTO schCollectRecordRetryLogDTO) {
return iSchCollectRecordRetryLogService.edit(schCollectRecordRetryLogDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchCollectRecordRetryLogService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchCollectorConfigApi;
import com.docus.server.dto.scheduling.management.SchCollectorConfigDTO;
import com.docus.server.service.ISchCollectorConfigService;
import com.docus.server.vo.scheduling.management.SchCollectorConfigVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchCollectorConfigController implements SchCollectorConfigApi {
@Resource
private ISchCollectorConfigService iSchCollectorConfigService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectorConfigVO findById(String id) {
return iSchCollectorConfigService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectorConfigVO> search(SearchRequest searchRequest) {
return iSchCollectorConfigService.search(searchRequest);
}
/**
*
*
* @param schCollectorConfigDTO
* @return
*/
@Override
public boolean add(SchCollectorConfigDTO schCollectorConfigDTO) {
return iSchCollectorConfigService.add(schCollectorConfigDTO);
}
/**
*
*
* @param schCollectorConfigDTO
* @return
*/
@Override
public boolean edit(SchCollectorConfigDTO schCollectorConfigDTO) {
return iSchCollectorConfigService.edit(schCollectorConfigDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchCollectorConfigService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchCollectorApi;
import com.docus.server.dto.scheduling.management.SchCollectorDTO;
import com.docus.server.service.ISchCollectorService;
import com.docus.server.vo.scheduling.management.SchCollectorVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchCollectorController implements SchCollectorApi {
@Resource
private ISchCollectorService iSchCollectorService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectorVO findById(String id) {
return iSchCollectorService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectorVO> search(SearchRequest searchRequest) {
return iSchCollectorService.search(searchRequest);
}
/**
*
*
* @param schCollectorDTO
* @return
*/
@Override
public boolean add(SchCollectorDTO schCollectorDTO) {
return iSchCollectorService.add(schCollectorDTO);
}
/**
*
*
* @param schCollectorDTO
* @return
*/
@Override
public boolean edit(SchCollectorDTO schCollectorDTO) {
return iSchCollectorService.edit(schCollectorDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchCollectorService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchCollectorVersionApi;
import com.docus.server.dto.scheduling.management.SchCollectorVersionDTO;
import com.docus.server.service.ISchCollectorVersionService;
import com.docus.server.vo.scheduling.management.SchCollectorVersionVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchCollectorVersionController implements SchCollectorVersionApi {
@Resource
private ISchCollectorVersionService iSchCollectorVersionService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectorVersionVO findById(String id) {
return iSchCollectorVersionService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectorVersionVO> search(SearchRequest searchRequest) {
return iSchCollectorVersionService.search(searchRequest);
}
/**
*
*
* @param schCollectorVersionDTO
* @return
*/
@Override
public boolean add(SchCollectorVersionDTO schCollectorVersionDTO) {
return iSchCollectorVersionService.add(schCollectorVersionDTO);
}
/**
*
*
* @param schCollectorVersionDTO
* @return
*/
@Override
public boolean edit(SchCollectorVersionDTO schCollectorVersionDTO) {
return iSchCollectorVersionService.edit(schCollectorVersionDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchCollectorVersionService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchCollectorVersionFileApi;
import com.docus.server.dto.scheduling.management.SchCollectorVersionFileDTO;
import com.docus.server.service.ISchCollectorVersionFileService;
import com.docus.server.vo.scheduling.management.SchCollectorVersionFileVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchCollectorVersionFileController implements SchCollectorVersionFileApi {
@Resource
private ISchCollectorVersionFileService iSchCollectorVersionFileService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectorVersionFileVO findById(String id) {
return iSchCollectorVersionFileService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectorVersionFileVO> search(SearchRequest searchRequest) {
return iSchCollectorVersionFileService.search(searchRequest);
}
/**
*
*
* @param schCollectorVersionFileDTO
* @return
*/
@Override
public boolean add(SchCollectorVersionFileDTO schCollectorVersionFileDTO) {
return iSchCollectorVersionFileService.add(schCollectorVersionFileDTO);
}
/**
*
*
* @param schCollectorVersionFileDTO
* @return
*/
@Override
public boolean edit(SchCollectorVersionFileDTO schCollectorVersionFileDTO) {
return iSchCollectorVersionFileService.edit(schCollectorVersionFileDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchCollectorVersionFileService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchCollectorVersionLogApi;
import com.docus.server.dto.scheduling.management.SchCollectorVersionLogDTO;
import com.docus.server.service.ISchCollectorVersionLogService;
import com.docus.server.vo.scheduling.management.SchCollectorVersionLogVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchCollectorVersionLogController implements SchCollectorVersionLogApi {
@Resource
private ISchCollectorVersionLogService iSchCollectorVersionLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectorVersionLogVO findById(String id) {
return iSchCollectorVersionLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectorVersionLogVO> search(SearchRequest searchRequest) {
return iSchCollectorVersionLogService.search(searchRequest);
}
/**
*
*
* @param schCollectorVersionLogDTO
* @return
*/
@Override
public boolean add(SchCollectorVersionLogDTO schCollectorVersionLogDTO) {
return iSchCollectorVersionLogService.add(schCollectorVersionLogDTO);
}
/**
*
*
* @param schCollectorVersionLogDTO
* @return
*/
@Override
public boolean edit(SchCollectorVersionLogDTO schCollectorVersionLogDTO) {
return iSchCollectorVersionLogService.edit(schCollectorVersionLogDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchCollectorVersionLogService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchOperationLogApi;
import com.docus.server.dto.scheduling.management.SchOperationLogDTO;
import com.docus.server.service.ISchOperationLogService;
import com.docus.server.vo.scheduling.management.SchOperationLogVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchOperationLogController implements SchOperationLogApi {
@Resource
private ISchOperationLogService iSchOperationLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchOperationLogVO findById(String id) {
return iSchOperationLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchOperationLogVO> search(SearchRequest searchRequest) {
return iSchOperationLogService.search(searchRequest);
}
/**
*
*
* @param schOperationLogDTO
* @return
*/
@Override
public boolean add(SchOperationLogDTO schOperationLogDTO) {
return iSchOperationLogService.add(schOperationLogDTO);
}
/**
*
*
* @param schOperationLogDTO
* @return
*/
@Override
public boolean edit(SchOperationLogDTO schOperationLogDTO) {
return iSchOperationLogService.edit(schOperationLogDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchOperationLogService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchSystemParamsApi;
import com.docus.server.dto.scheduling.management.SchSystemParamsDTO;
import com.docus.server.service.ISchSystemParamsService;
import com.docus.server.vo.scheduling.management.SchSystemParamsVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchSystemParamsController implements SchSystemParamsApi {
@Resource
private ISchSystemParamsService iSchSystemParamsService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchSystemParamsVO findById(String id) {
return iSchSystemParamsService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchSystemParamsVO> search(SearchRequest searchRequest) {
return iSchSystemParamsService.search(searchRequest);
}
/**
*
*
* @param schSystemParamsDTO
* @return
*/
@Override
public boolean add(SchSystemParamsDTO schSystemParamsDTO) {
return iSchSystemParamsService.add(schSystemParamsDTO);
}
/**
*
*
* @param schSystemParamsDTO
* @return
*/
@Override
public boolean edit(SchSystemParamsDTO schSystemParamsDTO) {
return iSchSystemParamsService.edit(schSystemParamsDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchSystemParamsService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchTerminatorApi;
import com.docus.server.dto.scheduling.management.SchTerminatorDTO;
import com.docus.server.service.ISchTerminatorService;
import com.docus.server.vo.scheduling.management.SchTerminatorVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchTerminatorController implements SchTerminatorApi {
@Resource
private ISchTerminatorService iSchTerminatorService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchTerminatorVO findById(String id) {
return iSchTerminatorService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchTerminatorVO> search(SearchRequest searchRequest) {
return iSchTerminatorService.search(searchRequest);
}
/**
*
*
* @param schTerminatorDTO
* @return
*/
@Override
public boolean add(SchTerminatorDTO schTerminatorDTO) {
return iSchTerminatorService.add(schTerminatorDTO);
}
/**
*
*
* @param schTerminatorDTO
* @return
*/
@Override
public boolean edit(SchTerminatorDTO schTerminatorDTO) {
return iSchTerminatorService.edit(schTerminatorDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchTerminatorService.delete(ids);
}
}

@ -0,0 +1,79 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.SchVirtualLogApi;
import com.docus.server.dto.scheduling.management.SchVirtualLogDTO;
import com.docus.server.service.ISchVirtualLogService;
import com.docus.server.vo.scheduling.management.SchVirtualLogVO;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* 使
*
* @author AutoGenerator
* @since 2023-07-14
*/
@RestController
public class SchVirtualLogController implements SchVirtualLogApi {
@Resource
private ISchVirtualLogService iSchVirtualLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public SchVirtualLogVO findById(String id) {
return iSchVirtualLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchVirtualLogVO> search(SearchRequest searchRequest) {
return iSchVirtualLogService.search(searchRequest);
}
/**
*
*
* @param schVirtualLogDTO
* @return
*/
@Override
public boolean add(SchVirtualLogDTO schVirtualLogDTO) {
return iSchVirtualLogService.add(schVirtualLogDTO);
}
/**
*
*
* @param schVirtualLogDTO
* @return
*/
@Override
public boolean edit(SchVirtualLogDTO schVirtualLogDTO) {
return iSchVirtualLogService.edit(schVirtualLogDTO);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iSchVirtualLogService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskCollectorApi;
import com.docus.server.entity.scheduling.management.TaskCollector;
import com.docus.server.service.ITaskCollectorService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskCollectorController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskCollectorController implements TaskCollectorApi {
@Resource
private ITaskCollectorService iTaskCollectorService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskCollector findById(String id) {
return iTaskCollectorService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskCollector> search(SearchRequest searchRequest) {
return iTaskCollectorService.search(searchRequest);
}
/**
*
*
* @param taskCollector
* @return
*/
@Override
public boolean add(TaskCollector taskCollector) {
return iTaskCollectorService.add(taskCollector);
}
/**
*
*
* @param taskCollector
* @return
*/
@Override
public boolean edit(TaskCollector taskCollector) {
return iTaskCollectorService.edit(taskCollector);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskCollectorService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskCollectorVersionApi;
import com.docus.server.entity.scheduling.management.TaskCollectorVersion;
import com.docus.server.service.ITaskCollectorVersionService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskCollectorVersionController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskCollectorVersionController implements TaskCollectorVersionApi {
@Resource
private ITaskCollectorVersionService iTaskCollectorVersionService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskCollectorVersion findById(String id) {
return iTaskCollectorVersionService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskCollectorVersion> search(SearchRequest searchRequest) {
return iTaskCollectorVersionService.search(searchRequest);
}
/**
*
*
* @param taskCollectorVersion
* @return
*/
@Override
public boolean add(TaskCollectorVersion taskCollectorVersion) {
return iTaskCollectorVersionService.add(taskCollectorVersion);
}
/**
*
*
* @param taskCollectorVersion
* @return
*/
@Override
public boolean edit(TaskCollectorVersion taskCollectorVersion) {
return iTaskCollectorVersionService.edit(taskCollectorVersion);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskCollectorVersionService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskCollectorVersionFileApi;
import com.docus.server.entity.scheduling.management.TaskCollectorVersionFile;
import com.docus.server.service.ITaskCollectorVersionFileService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskCollectorVersionFileController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskCollectorVersionFileController implements TaskCollectorVersionFileApi {
@Resource
private ITaskCollectorVersionFileService iTaskCollectorVersionFileService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskCollectorVersionFile findById(String id) {
return iTaskCollectorVersionFileService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskCollectorVersionFile> search(SearchRequest searchRequest) {
return iTaskCollectorVersionFileService.search(searchRequest);
}
/**
*
*
* @param taskCollectorVersionFile
* @return
*/
@Override
public boolean add(TaskCollectorVersionFile taskCollectorVersionFile) {
return iTaskCollectorVersionFileService.add(taskCollectorVersionFile);
}
/**
*
*
* @param taskCollectorVersionFile
* @return
*/
@Override
public boolean edit(TaskCollectorVersionFile taskCollectorVersionFile) {
return iTaskCollectorVersionFileService.edit(taskCollectorVersionFile);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskCollectorVersionFileService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskCollectorVersionLogApi;
import com.docus.server.entity.scheduling.management.TaskCollectorVersionLog;
import com.docus.server.service.ITaskCollectorVersionLogService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskCollectorVersionLogController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskCollectorVersionLogController implements TaskCollectorVersionLogApi {
@Resource
private ITaskCollectorVersionLogService iTaskCollectorVersionLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskCollectorVersionLog findById(String id) {
return iTaskCollectorVersionLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskCollectorVersionLog> search(SearchRequest searchRequest) {
return iTaskCollectorVersionLogService.search(searchRequest);
}
/**
*
*
* @param taskCollectorVersionLog
* @return
*/
@Override
public boolean add(TaskCollectorVersionLog taskCollectorVersionLog) {
return iTaskCollectorVersionLogService.add(taskCollectorVersionLog);
}
/**
*
*
* @param taskCollectorVersionLog
* @return
*/
@Override
public boolean edit(TaskCollectorVersionLog taskCollectorVersionLog) {
return iTaskCollectorVersionLogService.edit(taskCollectorVersionLog);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskCollectorVersionLogService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskOperationLogApi;
import com.docus.server.entity.scheduling.management.TaskOperationLog;
import com.docus.server.service.ITaskOperationLogService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskOperationLogController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskOperationLogController implements TaskOperationLogApi {
@Resource
private ITaskOperationLogService iTaskOperationLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskOperationLog findById(String id) {
return iTaskOperationLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskOperationLog> search(SearchRequest searchRequest) {
return iTaskOperationLogService.search(searchRequest);
}
/**
*
*
* @param taskOperationLog
* @return
*/
@Override
public boolean add(TaskOperationLog taskOperationLog) {
return iTaskOperationLogService.add(taskOperationLog);
}
/**
*
*
* @param taskOperationLog
* @return
*/
@Override
public boolean edit(TaskOperationLog taskOperationLog) {
return iTaskOperationLogService.edit(taskOperationLog);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskOperationLogService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskSystemParamsApi;
import com.docus.server.entity.scheduling.management.TaskSystemParams;
import com.docus.server.service.ITaskSystemParamsService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskSystemParamsController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskSystemParamsController implements TaskSystemParamsApi {
@Resource
private ITaskSystemParamsService iTaskSystemParamsService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskSystemParams findById(String id) {
return iTaskSystemParamsService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskSystemParams> search(SearchRequest searchRequest) {
return iTaskSystemParamsService.search(searchRequest);
}
/**
*
*
* @param taskSystemParams
* @return
*/
@Override
public boolean add(TaskSystemParams taskSystemParams) {
return iTaskSystemParamsService.add(taskSystemParams);
}
/**
*
*
* @param taskSystemParams
* @return
*/
@Override
public boolean edit(TaskSystemParams taskSystemParams) {
return iTaskSystemParamsService.edit(taskSystemParams);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskSystemParamsService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskTerminatorCollectApi;
import com.docus.server.entity.scheduling.management.TaskTerminatorCollect;
import com.docus.server.service.ITaskTerminatorCollectService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskTerminatorCollectController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskTerminatorCollectController implements TaskTerminatorCollectApi {
@Resource
private ITaskTerminatorCollectService iTaskTerminatorCollectService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskTerminatorCollect findById(String id) {
return iTaskTerminatorCollectService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskTerminatorCollect> search(SearchRequest searchRequest) {
return iTaskTerminatorCollectService.search(searchRequest);
}
/**
*
*
* @param taskTerminatorCollect
* @return
*/
@Override
public boolean add(TaskTerminatorCollect taskTerminatorCollect) {
return iTaskTerminatorCollectService.add(taskTerminatorCollect);
}
/**
*
*
* @param taskTerminatorCollect
* @return
*/
@Override
public boolean edit(TaskTerminatorCollect taskTerminatorCollect) {
return iTaskTerminatorCollectService.edit(taskTerminatorCollect);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskTerminatorCollectService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskTerminatorCollectRetryLogApi;
import com.docus.server.entity.scheduling.management.TaskTerminatorCollectRetryLog;
import com.docus.server.service.ITaskTerminatorCollectRetryLogService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskTerminatorCollectRetryLogController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskTerminatorCollectRetryLogController implements TaskTerminatorCollectRetryLogApi {
@Resource
private ITaskTerminatorCollectRetryLogService iTaskTerminatorCollectRetryLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskTerminatorCollectRetryLog findById(String id) {
return iTaskTerminatorCollectRetryLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskTerminatorCollectRetryLog> search(SearchRequest searchRequest) {
return iTaskTerminatorCollectRetryLogService.search(searchRequest);
}
/**
*
*
* @param taskTerminatorCollectRetryLog
* @return
*/
@Override
public boolean add(TaskTerminatorCollectRetryLog taskTerminatorCollectRetryLog) {
return iTaskTerminatorCollectRetryLogService.add(taskTerminatorCollectRetryLog);
}
/**
*
*
* @param taskTerminatorCollectRetryLog
* @return
*/
@Override
public boolean edit(TaskTerminatorCollectRetryLog taskTerminatorCollectRetryLog) {
return iTaskTerminatorCollectRetryLogService.edit(taskTerminatorCollectRetryLog);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskTerminatorCollectRetryLogService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskTerminatorApi;
import com.docus.server.entity.scheduling.management.TaskTerminator;
import com.docus.server.service.ITaskTerminatorService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskTerminatorController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskTerminatorController implements TaskTerminatorApi {
@Resource
private ITaskTerminatorService iTaskTerminatorService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskTerminator findById(String id) {
return iTaskTerminatorService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskTerminator> search(SearchRequest searchRequest) {
return iTaskTerminatorService.search(searchRequest);
}
/**
*
*
* @param taskTerminator
* @return
*/
@Override
public boolean add(TaskTerminator taskTerminator) {
return iTaskTerminatorService.add(taskTerminator);
}
/**
*
*
* @param taskTerminator
* @return
*/
@Override
public boolean edit(TaskTerminator taskTerminator) {
return iTaskTerminatorService.edit(taskTerminator);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskTerminatorService.delete(ids);
}
}

@ -1,81 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskTerminatorErrorLogApi;
import com.docus.server.entity.scheduling.management.TaskTerminatorErrorLog;
import com.docus.server.service.ITaskTerminatorErrorLogService;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* TaskTerminatorErrorLogController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskTerminatorErrorLogController implements TaskTerminatorErrorLogApi {
@Resource
private ITaskTerminatorErrorLogService iTaskTerminatorErrorLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskTerminatorErrorLog findById(String id) {
return iTaskTerminatorErrorLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskTerminatorErrorLog> search(SearchRequest searchRequest) {
return iTaskTerminatorErrorLogService.search(searchRequest);
}
/**
*
*
* @param taskTerminatorErrorLog
* @return
*/
@Override
public boolean add(TaskTerminatorErrorLog taskTerminatorErrorLog, MultipartFile screenUrl) {
return iTaskTerminatorErrorLogService.add(taskTerminatorErrorLog);
}
/**
*
*
* @param taskTerminatorErrorLog
* @return
*/
@Override
public boolean edit(TaskTerminatorErrorLog taskTerminatorErrorLog) {
return iTaskTerminatorErrorLogService.edit(taskTerminatorErrorLog);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskTerminatorErrorLogService.delete(ids);
}
}

@ -1,80 +0,0 @@
package com.docus.server.controller;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.api.scheduling.management.TaskTerminatorVirtualLogApi;
import com.docus.server.entity.scheduling.management.TaskTerminatorVirtualLog;
import com.docus.server.service.ITaskTerminatorVirtualLogService;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
* 使 TaskTerminatorVirtualLogController
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@RestController
public class TaskTerminatorVirtualLogController implements TaskTerminatorVirtualLogApi {
@Resource
private ITaskTerminatorVirtualLogService iTaskTerminatorVirtualLogService;
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskTerminatorVirtualLog findById(String id) {
return iTaskTerminatorVirtualLogService.findById(id);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskTerminatorVirtualLog> search(SearchRequest searchRequest) {
return iTaskTerminatorVirtualLogService.search(searchRequest);
}
/**
*
*
* @param taskTerminatorVirtualLog
* @return
*/
@Override
public boolean add(TaskTerminatorVirtualLog taskTerminatorVirtualLog) {
return iTaskTerminatorVirtualLogService.add(taskTerminatorVirtualLog);
}
/**
*
*
* @param taskTerminatorVirtualLog
* @return
*/
@Override
public boolean edit(TaskTerminatorVirtualLog taskTerminatorVirtualLog) {
return iTaskTerminatorVirtualLogService.edit(taskTerminatorVirtualLog);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return iTaskTerminatorVirtualLogService.delete(ids);
}
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchCollectErrorLogDTO;
import com.docus.server.entity.scheduling.management.SchCollectErrorLog;
import com.docus.server.vo.scheduling.management.SchCollectErrorLogVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectErrorLogConvert {
SchCollectErrorLogConvert INSTANCE = Mappers.getMapper(SchCollectErrorLogConvert.class);
@Mappings({})
SchCollectErrorLog convertDO(SchCollectErrorLogDTO schCollectErrorLogDTO);
@Mappings({})
List<SchCollectErrorLog> convertDO(List<SchCollectErrorLogDTO> schCollectErrorLogDTOList);
@Mappings({})
SchCollectErrorLogVO convertVO(SchCollectErrorLog schCollectErrorLog);
@Mappings({})
List<SchCollectErrorLogVO> convertVO(List<SchCollectErrorLog> schCollectErrorLogList);
@Mappings({})
PageResult<SchCollectErrorLogVO> convertVO(PageResult<SchCollectErrorLog> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchCollectRecordDTO;
import com.docus.server.entity.scheduling.management.SchCollectRecord;
import com.docus.server.vo.scheduling.management.SchCollectRecordVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectRecordConvert {
SchCollectRecordConvert INSTANCE = Mappers.getMapper(SchCollectRecordConvert.class);
@Mappings({})
SchCollectRecord convertDO(SchCollectRecordDTO schCollectRecordDTO);
@Mappings({})
List<SchCollectRecord> convertDO(List<SchCollectRecordDTO> schCollectRecordDTOList);
@Mappings({})
SchCollectRecordVO convertVO(SchCollectRecord schCollectRecord);
@Mappings({})
List<SchCollectRecordVO> convertVO(List<SchCollectRecord> schCollectRecordList);
@Mappings({})
PageResult<SchCollectRecordVO> convertVO(PageResult<SchCollectRecord> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchCollectRecordRetryLogDTO;
import com.docus.server.entity.scheduling.management.SchCollectRecordRetryLog;
import com.docus.server.vo.scheduling.management.SchCollectRecordRetryLogVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectRecordRetryLogConvert {
SchCollectRecordRetryLogConvert INSTANCE = Mappers.getMapper(SchCollectRecordRetryLogConvert.class);
@Mappings({})
SchCollectRecordRetryLog convertDO(SchCollectRecordRetryLogDTO schCollectRecordRetryLogDTO);
@Mappings({})
List<SchCollectRecordRetryLog> convertDO(List<SchCollectRecordRetryLogDTO> schCollectRecordRetryLogDTOList);
@Mappings({})
SchCollectRecordRetryLogVO convertVO(SchCollectRecordRetryLog schCollectRecordRetryLog);
@Mappings({})
List<SchCollectRecordRetryLogVO> convertVO(List<SchCollectRecordRetryLog> schCollectRecordRetryLogList);
@Mappings({})
PageResult<SchCollectRecordRetryLogVO> convertVO(PageResult<SchCollectRecordRetryLog> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchCollectorConfigDTO;
import com.docus.server.entity.scheduling.management.SchCollectorConfig;
import com.docus.server.vo.scheduling.management.SchCollectorConfigVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorConfigConvert {
SchCollectorConfigConvert INSTANCE = Mappers.getMapper(SchCollectorConfigConvert.class);
@Mappings({})
SchCollectorConfig convertDO(SchCollectorConfigDTO schCollectorConfigDTO);
@Mappings({})
List<SchCollectorConfig> convertDO(List<SchCollectorConfigDTO> schCollectorConfigDTOList);
@Mappings({})
SchCollectorConfigVO convertVO(SchCollectorConfig schCollectorConfig);
@Mappings({})
List<SchCollectorConfigVO> convertVO(List<SchCollectorConfig> schCollectorConfigList);
@Mappings({})
PageResult<SchCollectorConfigVO> convertVO(PageResult<SchCollectorConfig> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchCollectorDTO;
import com.docus.server.entity.scheduling.management.SchCollector;
import com.docus.server.vo.scheduling.management.SchCollectorVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorConvert {
SchCollectorConvert INSTANCE = Mappers.getMapper(SchCollectorConvert.class);
@Mappings({})
SchCollector convertDO(SchCollectorDTO schCollectorDTO);
@Mappings({})
List<SchCollector> convertDO(List<SchCollectorDTO> schCollectorDTOList);
@Mappings({})
SchCollectorVO convertVO(SchCollector schCollector);
@Mappings({})
List<SchCollectorVO> convertVO(List<SchCollector> schCollectorList);
@Mappings({})
PageResult<SchCollectorVO> convertVO(PageResult<SchCollector> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchCollectorVersionDTO;
import com.docus.server.entity.scheduling.management.SchCollectorVersion;
import com.docus.server.vo.scheduling.management.SchCollectorVersionVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorVersionConvert {
SchCollectorVersionConvert INSTANCE = Mappers.getMapper(SchCollectorVersionConvert.class);
@Mappings({})
SchCollectorVersion convertDO(SchCollectorVersionDTO schCollectorVersionDTO);
@Mappings({})
List<SchCollectorVersion> convertDO(List<SchCollectorVersionDTO> schCollectorVersionDTOList);
@Mappings({})
SchCollectorVersionVO convertVO(SchCollectorVersion schCollectorVersion);
@Mappings({})
List<SchCollectorVersionVO> convertVO(List<SchCollectorVersion> schCollectorVersionList);
@Mappings({})
PageResult<SchCollectorVersionVO> convertVO(PageResult<SchCollectorVersion> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchCollectorVersionFileDTO;
import com.docus.server.entity.scheduling.management.SchCollectorVersionFile;
import com.docus.server.vo.scheduling.management.SchCollectorVersionFileVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorVersionFileConvert {
SchCollectorVersionFileConvert INSTANCE = Mappers.getMapper(SchCollectorVersionFileConvert.class);
@Mappings({})
SchCollectorVersionFile convertDO(SchCollectorVersionFileDTO schCollectorVersionFileDTO);
@Mappings({})
List<SchCollectorVersionFile> convertDO(List<SchCollectorVersionFileDTO> schCollectorVersionFileDTOList);
@Mappings({})
SchCollectorVersionFileVO convertVO(SchCollectorVersionFile schCollectorVersionFile);
@Mappings({})
List<SchCollectorVersionFileVO> convertVO(List<SchCollectorVersionFile> schCollectorVersionFileList);
@Mappings({})
PageResult<SchCollectorVersionFileVO> convertVO(PageResult<SchCollectorVersionFile> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchCollectorVersionLogDTO;
import com.docus.server.entity.scheduling.management.SchCollectorVersionLog;
import com.docus.server.vo.scheduling.management.SchCollectorVersionLogVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorVersionLogConvert {
SchCollectorVersionLogConvert INSTANCE = Mappers.getMapper(SchCollectorVersionLogConvert.class);
@Mappings({})
SchCollectorVersionLog convertDO(SchCollectorVersionLogDTO schCollectorVersionLogDTO);
@Mappings({})
List<SchCollectorVersionLog> convertDO(List<SchCollectorVersionLogDTO> schCollectorVersionLogDTOList);
@Mappings({})
SchCollectorVersionLogVO convertVO(SchCollectorVersionLog schCollectorVersionLog);
@Mappings({})
List<SchCollectorVersionLogVO> convertVO(List<SchCollectorVersionLog> schCollectorVersionLogList);
@Mappings({})
PageResult<SchCollectorVersionLogVO> convertVO(PageResult<SchCollectorVersionLog> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchOperationLogDTO;
import com.docus.server.entity.scheduling.management.SchOperationLog;
import com.docus.server.vo.scheduling.management.SchOperationLogVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchOperationLogConvert {
SchOperationLogConvert INSTANCE = Mappers.getMapper(SchOperationLogConvert.class);
@Mappings({})
SchOperationLog convertDO(SchOperationLogDTO schOperationLogDTO);
@Mappings({})
List<SchOperationLog> convertDO(List<SchOperationLogDTO> schOperationLogDTOList);
@Mappings({})
SchOperationLogVO convertVO(SchOperationLog schOperationLog);
@Mappings({})
List<SchOperationLogVO> convertVO(List<SchOperationLog> schOperationLogList);
@Mappings({})
PageResult<SchOperationLogVO> convertVO(PageResult<SchOperationLog> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchSystemParamsDTO;
import com.docus.server.entity.scheduling.management.SchSystemParams;
import com.docus.server.vo.scheduling.management.SchSystemParamsVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchSystemParamsConvert {
SchSystemParamsConvert INSTANCE = Mappers.getMapper(SchSystemParamsConvert.class);
@Mappings({})
SchSystemParams convertDO(SchSystemParamsDTO schSystemParamsDTO);
@Mappings({})
List<SchSystemParams> convertDO(List<SchSystemParamsDTO> schSystemParamsDTOList);
@Mappings({})
SchSystemParamsVO convertVO(SchSystemParams schSystemParams);
@Mappings({})
List<SchSystemParamsVO> convertVO(List<SchSystemParams> schSystemParamsList);
@Mappings({})
PageResult<SchSystemParamsVO> convertVO(PageResult<SchSystemParams> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchTerminatorDTO;
import com.docus.server.entity.scheduling.management.SchTerminator;
import com.docus.server.vo.scheduling.management.SchTerminatorVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
*
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchTerminatorConvert {
SchTerminatorConvert INSTANCE = Mappers.getMapper(SchTerminatorConvert.class);
@Mappings({})
SchTerminator convertDO(SchTerminatorDTO schTerminatorDTO);
@Mappings({})
List<SchTerminator> convertDO(List<SchTerminatorDTO> schTerminatorDTOList);
@Mappings({})
SchTerminatorVO convertVO(SchTerminator schTerminator);
@Mappings({})
List<SchTerminatorVO> convertVO(List<SchTerminator> schTerminatorList);
@Mappings({})
PageResult<SchTerminatorVO> convertVO(PageResult<SchTerminator> pageResult);
}

@ -0,0 +1,39 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.dto.scheduling.management.SchVirtualLogDTO;
import com.docus.server.entity.scheduling.management.SchVirtualLog;
import com.docus.server.vo.scheduling.management.SchVirtualLogVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
/**
* 使
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchVirtualLogConvert {
SchVirtualLogConvert INSTANCE = Mappers.getMapper(SchVirtualLogConvert.class);
@Mappings({})
SchVirtualLog convertDO(SchVirtualLogDTO schVirtualLogDTO);
@Mappings({})
List<SchVirtualLog> convertDO(List<SchVirtualLogDTO> schVirtualLogDTOList);
@Mappings({})
SchVirtualLogVO convertVO(SchVirtualLog schVirtualLog);
@Mappings({})
List<SchVirtualLogVO> convertVO(List<SchVirtualLog> schVirtualLogList);
@Mappings({})
PageResult<SchVirtualLogVO> convertVO(PageResult<SchVirtualLog> pageResult);
}

@ -1,40 +0,0 @@
package com.docus.server.convert;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.TaskMessage;
import com.docus.server.enums.CollectTypeEnum;
import com.docus.server.enums.StateEnum;
import com.docus.server.vo.TaskMessageVO;
import org.mapstruct.Mapper;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
@Mapper
public interface TaskMessageConvert {
TaskMessageConvert INSTANCE = Mappers.getMapper(TaskMessageConvert.class);
@Mappings({})
TaskMessageVO convert(TaskMessage taskMessage);
@Mappings({})
List<TaskMessageVO> convert(List<TaskMessage> taskMessages);
@Mappings({})
PageResult<TaskMessageVO> convert(PageResult<TaskMessage> pageResult);
default TaskMessage convert(String json, String xml, CollectTypeEnum collectType, String retryKey, Long id) {
TaskMessage taskOriginalMessage = new TaskMessage();
taskOriginalMessage.setId(id);
taskOriginalMessage.setName(collectType.getDesc());
taskOriginalMessage.setMemo(collectType.getDisplay());
taskOriginalMessage.setCollectType(collectType);
taskOriginalMessage.setRetryKey(retryKey);
taskOriginalMessage.setJsonStr(json);
taskOriginalMessage.setSource(xml);
taskOriginalMessage.setState(StateEnum.OK);
return taskOriginalMessage;
}
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectErrorLog;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchCollectErrorLogDao extends IBaseDao<SchCollectErrorLog> {
/**
*
*
* @param id id
* @return
*/
SchCollectErrorLog findById(String id);
/**
*
*
* @param schCollectErrorLog
* @return
*/
boolean add(SchCollectErrorLog schCollectErrorLog);
/**
*
*
* @param schCollectErrorLog
* @return
*/
boolean edit(SchCollectErrorLog schCollectErrorLog);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchCollectErrorLog> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectRecord;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchCollectRecordDao extends IBaseDao<SchCollectRecord> {
/**
*
*
* @param id id
* @return
*/
SchCollectRecord findById(String id);
/**
*
*
* @param schCollectRecord
* @return
*/
boolean add(SchCollectRecord schCollectRecord);
/**
*
*
* @param schCollectRecord
* @return
*/
boolean edit(SchCollectRecord schCollectRecord);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchCollectRecord> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectRecordRetryLog;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchCollectRecordRetryLogDao extends IBaseDao<SchCollectRecordRetryLog> {
/**
*
*
* @param id id
* @return
*/
SchCollectRecordRetryLog findById(String id);
/**
*
*
* @param schCollectRecordRetryLog
* @return
*/
boolean add(SchCollectRecordRetryLog schCollectRecordRetryLog);
/**
*
*
* @param schCollectRecordRetryLog
* @return
*/
boolean edit(SchCollectRecordRetryLog schCollectRecordRetryLog);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchCollectRecordRetryLog> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectorConfig;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchCollectorConfigDao extends IBaseDao<SchCollectorConfig> {
/**
*
*
* @param id id
* @return
*/
SchCollectorConfig findById(String id);
/**
*
*
* @param schCollectorConfig
* @return
*/
boolean add(SchCollectorConfig schCollectorConfig);
/**
*
*
* @param schCollectorConfig
* @return
*/
boolean edit(SchCollectorConfig schCollectorConfig);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchCollectorConfig> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollector;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchCollectorDao extends IBaseDao<SchCollector> {
/**
*
*
* @param id id
* @return
*/
SchCollector findById(String id);
/**
*
*
* @param schCollector
* @return
*/
boolean add(SchCollector schCollector);
/**
*
*
* @param schCollector
* @return
*/
boolean edit(SchCollector schCollector);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchCollector> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectorVersion;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchCollectorVersionDao extends IBaseDao<SchCollectorVersion> {
/**
*
*
* @param id id
* @return
*/
SchCollectorVersion findById(String id);
/**
*
*
* @param schCollectorVersion
* @return
*/
boolean add(SchCollectorVersion schCollectorVersion);
/**
*
*
* @param schCollectorVersion
* @return
*/
boolean edit(SchCollectorVersion schCollectorVersion);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchCollectorVersion> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectorVersionFile;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchCollectorVersionFileDao extends IBaseDao<SchCollectorVersionFile> {
/**
*
*
* @param id id
* @return
*/
SchCollectorVersionFile findById(String id);
/**
*
*
* @param schCollectorVersionFile
* @return
*/
boolean add(SchCollectorVersionFile schCollectorVersionFile);
/**
*
*
* @param schCollectorVersionFile
* @return
*/
boolean edit(SchCollectorVersionFile schCollectorVersionFile);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchCollectorVersionFile> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectorVersionLog;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchCollectorVersionLogDao extends IBaseDao<SchCollectorVersionLog> {
/**
*
*
* @param id id
* @return
*/
SchCollectorVersionLog findById(String id);
/**
*
*
* @param schCollectorVersionLog
* @return
*/
boolean add(SchCollectorVersionLog schCollectorVersionLog);
/**
*
*
* @param schCollectorVersionLog
* @return
*/
boolean edit(SchCollectorVersionLog schCollectorVersionLog);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchCollectorVersionLog> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchOperationLog;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchOperationLogDao extends IBaseDao<SchOperationLog> {
/**
*
*
* @param id id
* @return
*/
SchOperationLog findById(String id);
/**
*
*
* @param schOperationLog
* @return
*/
boolean add(SchOperationLog schOperationLog);
/**
*
*
* @param schOperationLog
* @return
*/
boolean edit(SchOperationLog schOperationLog);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchOperationLog> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchSystemParams;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchSystemParamsDao extends IBaseDao<SchSystemParams> {
/**
*
*
* @param id id
* @return
*/
SchSystemParams findById(String id);
/**
*
*
* @param schSystemParams
* @return
*/
boolean add(SchSystemParams schSystemParams);
/**
*
*
* @param schSystemParams
* @return
*/
boolean edit(SchSystemParams schSystemParams);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchSystemParams> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchTerminator;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchTerminatorDao extends IBaseDao<SchTerminator> {
/**
*
*
* @param id id
* @return
*/
SchTerminator findById(String id);
/**
*
*
* @param schTerminator
* @return
*/
boolean add(SchTerminator schTerminator);
/**
*
*
* @param schTerminator
* @return
*/
boolean edit(SchTerminator schTerminator);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchTerminator> search(SearchRequest searchRequest);
}

@ -0,0 +1,57 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchVirtualLog;
import java.util.List;
/**
* 使 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
public interface ISchVirtualLogDao extends IBaseDao<SchVirtualLog> {
/**
*
*
* @param id id
* @return
*/
SchVirtualLog findById(String id);
/**
*
*
* @param schVirtualLog
* @return
*/
boolean add(SchVirtualLog schVirtualLog);
/**
*
*
* @param schVirtualLog
* @return
*/
boolean edit(SchVirtualLog schVirtualLog);
/**
*
*
* @param ids ids
* @return
*/
int delete(List<String> ids);
/**
*
*
* @param searchRequest
* @return
*/
PageResult<SchVirtualLog> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskCollector;
import java.util.List;
/**
* <p>
* ITaskCollectorDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskCollectorDao extends IBaseDao<TaskCollector> {
TaskCollector findById(String id);
boolean add(TaskCollector taskCollector);
boolean edit(TaskCollector taskCollector);
int delete(List<String> ids);
PageResult<TaskCollector> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskCollectorVersion;
import java.util.List;
/**
* <p>
* ITaskCollectorVersionDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskCollectorVersionDao extends IBaseDao<TaskCollectorVersion> {
TaskCollectorVersion findById(String id);
boolean add(TaskCollectorVersion taskCollectorVersion);
boolean edit(TaskCollectorVersion taskCollectorVersion);
int delete(List<String> ids);
PageResult<TaskCollectorVersion> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskCollectorVersionFile;
import java.util.List;
/**
* <p>
* ITaskCollectorVersionFileDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskCollectorVersionFileDao extends IBaseDao<TaskCollectorVersionFile> {
TaskCollectorVersionFile findById(String id);
boolean add(TaskCollectorVersionFile taskCollectorVersionFile);
boolean edit(TaskCollectorVersionFile taskCollectorVersionFile);
int delete(List<String> ids);
PageResult<TaskCollectorVersionFile> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskCollectorVersionLog;
import java.util.List;
/**
* <p>
* ITaskCollectorVersionLogDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskCollectorVersionLogDao extends IBaseDao<TaskCollectorVersionLog> {
TaskCollectorVersionLog findById(String id);
boolean add(TaskCollectorVersionLog taskCollectorVersionLog);
boolean edit(TaskCollectorVersionLog taskCollectorVersionLog);
int delete(List<String> ids);
PageResult<TaskCollectorVersionLog> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskOperationLog;
import java.util.List;
/**
* <p>
* ITaskOperationLogDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskOperationLogDao extends IBaseDao<TaskOperationLog> {
TaskOperationLog findById(String id);
boolean add(TaskOperationLog taskOperationLog);
boolean edit(TaskOperationLog taskOperationLog);
int delete(List<String> ids);
PageResult<TaskOperationLog> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskSystemParams;
import java.util.List;
/**
* <p>
* ITaskSystemParamsDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskSystemParamsDao extends IBaseDao<TaskSystemParams> {
TaskSystemParams findById(String id);
boolean add(TaskSystemParams taskSystemParams);
boolean edit(TaskSystemParams taskSystemParams);
int delete(List<String> ids);
PageResult<TaskSystemParams> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminatorCollect;
import java.util.List;
/**
* <p>
* ITaskTerminatorCollectDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskTerminatorCollectDao extends IBaseDao<TaskTerminatorCollect> {
TaskTerminatorCollect findById(String id);
boolean add(TaskTerminatorCollect taskTerminatorCollect);
boolean edit(TaskTerminatorCollect taskTerminatorCollect);
int delete(List<String> ids);
PageResult<TaskTerminatorCollect> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminatorCollectRetryLog;
import java.util.List;
/**
* <p>
* ITaskTerminatorCollectRetryLogDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskTerminatorCollectRetryLogDao extends IBaseDao<TaskTerminatorCollectRetryLog> {
TaskTerminatorCollectRetryLog findById(String id);
boolean add(TaskTerminatorCollectRetryLog taskTerminatorCollectRetryLog);
boolean edit(TaskTerminatorCollectRetryLog taskTerminatorCollectRetryLog);
int delete(List<String> ids);
PageResult<TaskTerminatorCollectRetryLog> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminator;
import java.util.List;
/**
* <p>
* ITaskTerminatorDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskTerminatorDao extends IBaseDao<TaskTerminator> {
TaskTerminator findById(String id);
boolean add(TaskTerminator taskTerminator);
boolean edit(TaskTerminator taskTerminator);
int delete(List<String> ids);
PageResult<TaskTerminator> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminatorErrorLog;
import java.util.List;
/**
* <p>
* ITaskTerminatorErrorLogDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskTerminatorErrorLogDao extends IBaseDao<TaskTerminatorErrorLog> {
TaskTerminatorErrorLog findById(String id);
boolean add(TaskTerminatorErrorLog taskTerminatorErrorLog);
boolean edit(TaskTerminatorErrorLog taskTerminatorErrorLog);
int delete(List<String> ids);
PageResult<TaskTerminatorErrorLog> search(SearchRequest searchRequest);
}

@ -1,30 +0,0 @@
package com.docus.server.infrastructure.dao;
import com.docus.infrastructure.core.db.dao.IBaseDao;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminatorVirtualLog;
import java.util.List;
/**
* <p>
* 使 ITaskTerminatorVirtualLogDao 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
public interface ITaskTerminatorVirtualLogDao extends IBaseDao<TaskTerminatorVirtualLog> {
TaskTerminatorVirtualLog findById(String id);
boolean add(TaskTerminatorVirtualLog taskTerminatorVirtualLog);
boolean edit(TaskTerminatorVirtualLog taskTerminatorVirtualLog);
int delete(List<String> ids);
PageResult<TaskTerminatorVirtualLog> search(SearchRequest searchRequest);
}

@ -5,9 +5,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskOperationLog;
import com.docus.server.infrastructure.dao.ITaskOperationLogDao;
import com.docus.server.infrastructure.mapper.TaskOperationLogMapper;
import com.docus.server.entity.scheduling.management.SchCollectErrorLog;
import com.docus.server.infrastructure.dao.ISchCollectErrorLogDao;
import com.docus.server.infrastructure.mapper.SchCollectErrorLogMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
@ -15,15 +15,13 @@ import java.util.Date;
import java.util.List;
/**
* <p>
* TaskOperationLogDaoImpl 访
* </p>
* 访
*
* @author AutoGenerator
* @since 2023-07-12
* @since 2023-07-14
*/
@Repository
public class TaskOperationLogDaoImpl extends BaseDaoImpl<TaskOperationLogMapper, TaskOperationLog> implements ITaskOperationLogDao {
public class SchCollectErrorLogDaoImpl extends BaseDaoImpl<SchCollectErrorLogMapper, SchCollectErrorLog> implements ISchCollectErrorLogDao {
/**
*
@ -32,30 +30,30 @@ public class TaskOperationLogDaoImpl extends BaseDaoImpl<TaskOperationLogMapper,
* @return
*/
@Override
public TaskOperationLog findById(String id) {
public SchCollectErrorLog findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskOperationLog
* @param schCollectErrorLog
* @return
*/
@Override
public boolean add(TaskOperationLog taskOperationLog) {
return super.save(taskOperationLog);
public boolean add(SchCollectErrorLog schCollectErrorLog) {
return super.save(schCollectErrorLog);
}
/**
*
*
* @param taskOperationLog
* @param schCollectErrorLog
* @return
*/
@Override
public boolean edit(TaskOperationLog taskOperationLog) {
return super.updateById(taskOperationLog);
public boolean edit(SchCollectErrorLog schCollectErrorLog) {
return super.updateById(schCollectErrorLog);
}
/**
@ -76,30 +74,30 @@ public class TaskOperationLogDaoImpl extends BaseDaoImpl<TaskOperationLogMapper,
* @return
*/
@Override
public PageResult<TaskOperationLog> search(SearchRequest searchRequest) {
public PageResult<SchCollectErrorLog> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskOperationLog> query = Wrappers.lambdaQuery();
LambdaQueryWrapper<SchCollectErrorLog> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskOperationLog::getCreateTime, searchRequest.getBeginTime());
query.ge(SchCollectErrorLog::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskOperationLog::getCreateTime, endTime);
query.le(SchCollectErrorLog::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskOperationLog::getxxx, searchRequest. getKeyword());
//query. like(SchCollectErrorLog::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskOperationLog::getxx1, searchRequest. getKeyword())
// оr(). like(TaskOperationLog::getXX2, searchRequest. getKeyword()))
//query. and(sub -> sub.like(SchCollectErrorLog::getxx1, searchRequest. getKeyword())
// оr(). like(SchCollectErrorLog::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskOperationLog::getCreateTime);
List<TaskOperationLog> list = super.find(query);
query.orderByDesc(SchCollectErrorLog::getCreateTime);
List<SchCollectErrorLog> list = super.find(query);
return new PageResult<>(list);
}

@ -5,9 +5,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskSystemParams;
import com.docus.server.infrastructure.dao.ITaskSystemParamsDao;
import com.docus.server.infrastructure.mapper.TaskSystemParamsMapper;
import com.docus.server.entity.scheduling.management.SchCollectRecord;
import com.docus.server.infrastructure.dao.ISchCollectRecordDao;
import com.docus.server.infrastructure.mapper.SchCollectRecordMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
@ -15,15 +15,13 @@ import java.util.Date;
import java.util.List;
/**
* <p>
* TaskSystemParamsDaoImpl 访
* </p>
* 访
*
* @author AutoGenerator
* @since 2023-07-12
* @since 2023-07-14
*/
@Repository
public class TaskSystemParamsDaoImpl extends BaseDaoImpl<TaskSystemParamsMapper, TaskSystemParams> implements ITaskSystemParamsDao {
public class SchCollectRecordDaoImpl extends BaseDaoImpl<SchCollectRecordMapper, SchCollectRecord> implements ISchCollectRecordDao {
/**
*
@ -32,30 +30,30 @@ public class TaskSystemParamsDaoImpl extends BaseDaoImpl<TaskSystemParamsMapper,
* @return
*/
@Override
public TaskSystemParams findById(String id) {
public SchCollectRecord findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskSystemParams
* @param schCollectRecord
* @return
*/
@Override
public boolean add(TaskSystemParams taskSystemParams) {
return super.save(taskSystemParams);
public boolean add(SchCollectRecord schCollectRecord) {
return super.save(schCollectRecord);
}
/**
*
*
* @param taskSystemParams
* @param schCollectRecord
* @return
*/
@Override
public boolean edit(TaskSystemParams taskSystemParams) {
return super.updateById(taskSystemParams);
public boolean edit(SchCollectRecord schCollectRecord) {
return super.updateById(schCollectRecord);
}
/**
@ -76,30 +74,30 @@ public class TaskSystemParamsDaoImpl extends BaseDaoImpl<TaskSystemParamsMapper,
* @return
*/
@Override
public PageResult<TaskSystemParams> search(SearchRequest searchRequest) {
public PageResult<SchCollectRecord> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskSystemParams> query = Wrappers.lambdaQuery();
LambdaQueryWrapper<SchCollectRecord> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskSystemParams::getCreateTime, searchRequest.getBeginTime());
query.ge(SchCollectRecord::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskSystemParams::getCreateTime, endTime);
query.le(SchCollectRecord::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskSystemParams::getxxx, searchRequest. getKeyword());
//query. like(SchCollectRecord::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskSystemParams::getxx1, searchRequest. getKeyword())
// оr(). like(TaskSystemParams::getXX2, searchRequest. getKeyword()))
//query. and(sub -> sub.like(SchCollectRecord::getxx1, searchRequest. getKeyword())
// оr(). like(SchCollectRecord::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskSystemParams::getCreateTime);
List<TaskSystemParams> list = super.find(query);
query.orderByDesc(SchCollectRecord::getCreateTime);
List<SchCollectRecord> list = super.find(query);
return new PageResult<>(list);
}

@ -5,9 +5,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminatorVirtualLog;
import com.docus.server.infrastructure.dao.ITaskTerminatorVirtualLogDao;
import com.docus.server.infrastructure.mapper.TaskTerminatorVirtualLogMapper;
import com.docus.server.entity.scheduling.management.SchCollectRecordRetryLog;
import com.docus.server.infrastructure.dao.ISchCollectRecordRetryLogDao;
import com.docus.server.infrastructure.mapper.SchCollectRecordRetryLogMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
@ -15,15 +15,13 @@ import java.util.Date;
import java.util.List;
/**
* <p>
* 使 TaskTerminatorVirtualLogDaoImpl 访
* </p>
* 访
*
* @author AutoGenerator
* @since 2023-07-12
* @since 2023-07-14
*/
@Repository
public class TaskTerminatorVirtualLogDaoImpl extends BaseDaoImpl<TaskTerminatorVirtualLogMapper, TaskTerminatorVirtualLog> implements ITaskTerminatorVirtualLogDao {
public class SchCollectRecordRetryLogDaoImpl extends BaseDaoImpl<SchCollectRecordRetryLogMapper, SchCollectRecordRetryLog> implements ISchCollectRecordRetryLogDao {
/**
*
@ -32,30 +30,30 @@ public class TaskTerminatorVirtualLogDaoImpl extends BaseDaoImpl<TaskTerminatorV
* @return
*/
@Override
public TaskTerminatorVirtualLog findById(String id) {
public SchCollectRecordRetryLog findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskTerminatorVirtualLog
* @param schCollectRecordRetryLog
* @return
*/
@Override
public boolean add(TaskTerminatorVirtualLog taskTerminatorVirtualLog) {
return super.save(taskTerminatorVirtualLog);
public boolean add(SchCollectRecordRetryLog schCollectRecordRetryLog) {
return super.save(schCollectRecordRetryLog);
}
/**
*
*
* @param taskTerminatorVirtualLog
* @param schCollectRecordRetryLog
* @return
*/
@Override
public boolean edit(TaskTerminatorVirtualLog taskTerminatorVirtualLog) {
return super.updateById(taskTerminatorVirtualLog);
public boolean edit(SchCollectRecordRetryLog schCollectRecordRetryLog) {
return super.updateById(schCollectRecordRetryLog);
}
/**
@ -76,30 +74,30 @@ public class TaskTerminatorVirtualLogDaoImpl extends BaseDaoImpl<TaskTerminatorV
* @return
*/
@Override
public PageResult<TaskTerminatorVirtualLog> search(SearchRequest searchRequest) {
public PageResult<SchCollectRecordRetryLog> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskTerminatorVirtualLog> query = Wrappers.lambdaQuery();
LambdaQueryWrapper<SchCollectRecordRetryLog> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskTerminatorVirtualLog::getCreateTime, searchRequest.getBeginTime());
query.ge(SchCollectRecordRetryLog::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskTerminatorVirtualLog::getCreateTime, endTime);
query.le(SchCollectRecordRetryLog::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskTerminatorVirtualLog::getxxx, searchRequest. getKeyword());
//query. like(SchCollectRecordRetryLog::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskTerminatorVirtualLog::getxx1, searchRequest. getKeyword())
// оr(). like(TaskTerminatorVirtualLog::getXX2, searchRequest. getKeyword()))
//query. and(sub -> sub.like(SchCollectRecordRetryLog::getxx1, searchRequest. getKeyword())
// оr(). like(SchCollectRecordRetryLog::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskTerminatorVirtualLog::getCreateTime);
List<TaskTerminatorVirtualLog> list = super.find(query);
query.orderByDesc(SchCollectRecordRetryLog::getCreateTime);
List<SchCollectRecordRetryLog> list = super.find(query);
return new PageResult<>(list);
}

@ -0,0 +1,104 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectorConfig;
import com.docus.server.infrastructure.dao.ISchCollectorConfigDao;
import com.docus.server.infrastructure.mapper.SchCollectorConfigMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Repository
public class SchCollectorConfigDaoImpl extends BaseDaoImpl<SchCollectorConfigMapper, SchCollectorConfig> implements ISchCollectorConfigDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectorConfig findById(String id) {
return super.findById(id);
}
/**
*
*
* @param schCollectorConfig
* @return
*/
@Override
public boolean add(SchCollectorConfig schCollectorConfig) {
return super.save(schCollectorConfig);
}
/**
*
*
* @param schCollectorConfig
* @return
*/
@Override
public boolean edit(SchCollectorConfig schCollectorConfig) {
return super.updateById(schCollectorConfig);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectorConfig> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<SchCollectorConfig> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(SchCollectorConfig::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(SchCollectorConfig::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(SchCollectorConfig::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(SchCollectorConfig::getxx1, searchRequest. getKeyword())
// оr(). like(SchCollectorConfig::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(SchCollectorConfig::getCreateTime);
List<SchCollectorConfig> list = super.find(query);
return new PageResult<>(list);
}
}

@ -5,9 +5,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminator;
import com.docus.server.infrastructure.dao.ITaskTerminatorDao;
import com.docus.server.infrastructure.mapper.TaskTerminatorMapper;
import com.docus.server.entity.scheduling.management.SchCollector;
import com.docus.server.infrastructure.dao.ISchCollectorDao;
import com.docus.server.infrastructure.mapper.SchCollectorMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
@ -15,15 +15,13 @@ import java.util.Date;
import java.util.List;
/**
* <p>
* TaskTerminatorDaoImpl 访
* </p>
* 访
*
* @author AutoGenerator
* @since 2023-07-12
* @since 2023-07-14
*/
@Repository
public class TaskTerminatorDaoImpl extends BaseDaoImpl<TaskTerminatorMapper, TaskTerminator> implements ITaskTerminatorDao {
public class SchCollectorDaoImpl extends BaseDaoImpl<SchCollectorMapper, SchCollector> implements ISchCollectorDao {
/**
*
@ -32,30 +30,30 @@ public class TaskTerminatorDaoImpl extends BaseDaoImpl<TaskTerminatorMapper, Tas
* @return
*/
@Override
public TaskTerminator findById(String id) {
public SchCollector findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskTerminator
* @param schCollector
* @return
*/
@Override
public boolean add(TaskTerminator taskTerminator) {
return super.save(taskTerminator);
public boolean add(SchCollector schCollector) {
return super.save(schCollector);
}
/**
*
*
* @param taskTerminator
* @param schCollector
* @return
*/
@Override
public boolean edit(TaskTerminator taskTerminator) {
return super.updateById(taskTerminator);
public boolean edit(SchCollector schCollector) {
return super.updateById(schCollector);
}
/**
@ -76,30 +74,30 @@ public class TaskTerminatorDaoImpl extends BaseDaoImpl<TaskTerminatorMapper, Tas
* @return
*/
@Override
public PageResult<TaskTerminator> search(SearchRequest searchRequest) {
public PageResult<SchCollector> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskTerminator> query = Wrappers.lambdaQuery();
LambdaQueryWrapper<SchCollector> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskTerminator::getCreateTime, searchRequest.getBeginTime());
query.ge(SchCollector::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskTerminator::getCreateTime, endTime);
query.le(SchCollector::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskTerminator::getxxx, searchRequest. getKeyword());
//query. like(SchCollector::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskTerminator::getxx1, searchRequest. getKeyword())
// оr(). like(TaskTerminator::getXX2, searchRequest. getKeyword()))
//query. and(sub -> sub.like(SchCollector::getxx1, searchRequest. getKeyword())
// оr(). like(SchCollector::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskTerminator::getCreateTime);
List<TaskTerminator> list = super.find(query);
query.orderByDesc(SchCollector::getCreateTime);
List<SchCollector> list = super.find(query);
return new PageResult<>(list);
}

@ -0,0 +1,104 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectorVersion;
import com.docus.server.infrastructure.dao.ISchCollectorVersionDao;
import com.docus.server.infrastructure.mapper.SchCollectorVersionMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Repository
public class SchCollectorVersionDaoImpl extends BaseDaoImpl<SchCollectorVersionMapper, SchCollectorVersion> implements ISchCollectorVersionDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public SchCollectorVersion findById(String id) {
return super.findById(id);
}
/**
*
*
* @param schCollectorVersion
* @return
*/
@Override
public boolean add(SchCollectorVersion schCollectorVersion) {
return super.save(schCollectorVersion);
}
/**
*
*
* @param schCollectorVersion
* @return
*/
@Override
public boolean edit(SchCollectorVersion schCollectorVersion) {
return super.updateById(schCollectorVersion);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectorVersion> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<SchCollectorVersion> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(SchCollectorVersion::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(SchCollectorVersion::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(SchCollectorVersion::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(SchCollectorVersion::getxx1, searchRequest. getKeyword())
// оr(). like(SchCollectorVersion::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(SchCollectorVersion::getCreateTime);
List<SchCollectorVersion> list = super.find(query);
return new PageResult<>(list);
}
}

@ -5,9 +5,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskCollectorVersionLog;
import com.docus.server.infrastructure.dao.ITaskCollectorVersionLogDao;
import com.docus.server.infrastructure.mapper.TaskCollectorVersionLogMapper;
import com.docus.server.entity.scheduling.management.SchCollectorVersionFile;
import com.docus.server.infrastructure.dao.ISchCollectorVersionFileDao;
import com.docus.server.infrastructure.mapper.SchCollectorVersionFileMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
@ -15,15 +15,13 @@ import java.util.Date;
import java.util.List;
/**
* <p>
* TaskCollectorVersionLogDaoImpl 访
* </p>
* 访
*
* @author AutoGenerator
* @since 2023-07-12
* @since 2023-07-14
*/
@Repository
public class TaskCollectorVersionLogDaoImpl extends BaseDaoImpl<TaskCollectorVersionLogMapper, TaskCollectorVersionLog> implements ITaskCollectorVersionLogDao {
public class SchCollectorVersionFileDaoImpl extends BaseDaoImpl<SchCollectorVersionFileMapper, SchCollectorVersionFile> implements ISchCollectorVersionFileDao {
/**
*
@ -32,30 +30,30 @@ public class TaskCollectorVersionLogDaoImpl extends BaseDaoImpl<TaskCollectorVer
* @return
*/
@Override
public TaskCollectorVersionLog findById(String id) {
public SchCollectorVersionFile findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskCollectorVersionLog
* @param schCollectorVersionFile
* @return
*/
@Override
public boolean add(TaskCollectorVersionLog taskCollectorVersionLog) {
return super.save(taskCollectorVersionLog);
public boolean add(SchCollectorVersionFile schCollectorVersionFile) {
return super.save(schCollectorVersionFile);
}
/**
*
*
* @param taskCollectorVersionLog
* @param schCollectorVersionFile
* @return
*/
@Override
public boolean edit(TaskCollectorVersionLog taskCollectorVersionLog) {
return super.updateById(taskCollectorVersionLog);
public boolean edit(SchCollectorVersionFile schCollectorVersionFile) {
return super.updateById(schCollectorVersionFile);
}
/**
@ -76,30 +74,30 @@ public class TaskCollectorVersionLogDaoImpl extends BaseDaoImpl<TaskCollectorVer
* @return
*/
@Override
public PageResult<TaskCollectorVersionLog> search(SearchRequest searchRequest) {
public PageResult<SchCollectorVersionFile> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskCollectorVersionLog> query = Wrappers.lambdaQuery();
LambdaQueryWrapper<SchCollectorVersionFile> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskCollectorVersionLog::getCreateTime, searchRequest.getBeginTime());
query.ge(SchCollectorVersionFile::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskCollectorVersionLog::getCreateTime, endTime);
query.le(SchCollectorVersionFile::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskCollectorVersionLog::getxxx, searchRequest. getKeyword());
//query. like(SchCollectorVersionFile::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskCollectorVersionLog::getxx1, searchRequest. getKeyword())
// оr(). like(TaskCollectorVersionLog::getXX2, searchRequest. getKeyword()))
//query. and(sub -> sub.like(SchCollectorVersionFile::getxx1, searchRequest. getKeyword())
// оr(). like(SchCollectorVersionFile::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskCollectorVersionLog::getCreateTime);
List<TaskCollectorVersionLog> list = super.find(query);
query.orderByDesc(SchCollectorVersionFile::getCreateTime);
List<SchCollectorVersionFile> list = super.find(query);
return new PageResult<>(list);
}

@ -0,0 +1,98 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchCollectorVersionLog;
import com.docus.server.infrastructure.mapper.SchCollectorVersionLogMapper;
import com.docus.server.infrastructure.dao.ISchCollectorVersionLogDao;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
*
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Repository
public class SchCollectorVersionLogDaoImpl extends BaseDaoImpl<SchCollectorVersionLogMapper, SchCollectorVersionLog> implements ISchCollectorVersionLogDao {
/**
*
* @param id Id
* @return
*/
@Override
public SchCollectorVersionLog findById(String id) {
return super.findById(id);
}
/**
*
* @param schCollectorVersionLog
* @return
*/
@Override
public boolean add(SchCollectorVersionLog schCollectorVersionLog) {
return super.save(schCollectorVersionLog);
}
/**
*
* @param schCollectorVersionLog
* @return
*/
@Override
public boolean edit(SchCollectorVersionLog schCollectorVersionLog) {
return super.updateById(schCollectorVersionLog);
}
/**
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchCollectorVersionLog> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<SchCollectorVersionLog> query = Wrappers.lambdaQuery() ;
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(SchCollectorVersionLog::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest. getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(SchCollectorVersionLog::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(SchCollectorVersionLog::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(SchCollectorVersionLog::getxx1, searchRequest. getKeyword())
// оr(). like(SchCollectorVersionLog::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(SchCollectorVersionLog::getCreateTime);
List<SchCollectorVersionLog> list = super.find(query);
return new PageResult<>(list);
}
}

@ -0,0 +1,104 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchOperationLog;
import com.docus.server.infrastructure.dao.ISchOperationLogDao;
import com.docus.server.infrastructure.mapper.SchOperationLogMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Repository
public class SchOperationLogDaoImpl extends BaseDaoImpl<SchOperationLogMapper, SchOperationLog> implements ISchOperationLogDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public SchOperationLog findById(String id) {
return super.findById(id);
}
/**
*
*
* @param schOperationLog
* @return
*/
@Override
public boolean add(SchOperationLog schOperationLog) {
return super.save(schOperationLog);
}
/**
*
*
* @param schOperationLog
* @return
*/
@Override
public boolean edit(SchOperationLog schOperationLog) {
return super.updateById(schOperationLog);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchOperationLog> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<SchOperationLog> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(SchOperationLog::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(SchOperationLog::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(SchOperationLog::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(SchOperationLog::getxx1, searchRequest. getKeyword())
// оr(). like(SchOperationLog::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(SchOperationLog::getCreateTime);
List<SchOperationLog> list = super.find(query);
return new PageResult<>(list);
}
}

@ -0,0 +1,104 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchSystemParams;
import com.docus.server.infrastructure.dao.ISchSystemParamsDao;
import com.docus.server.infrastructure.mapper.SchSystemParamsMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Repository
public class SchSystemParamsDaoImpl extends BaseDaoImpl<SchSystemParamsMapper, SchSystemParams> implements ISchSystemParamsDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public SchSystemParams findById(String id) {
return super.findById(id);
}
/**
*
*
* @param schSystemParams
* @return
*/
@Override
public boolean add(SchSystemParams schSystemParams) {
return super.save(schSystemParams);
}
/**
*
*
* @param schSystemParams
* @return
*/
@Override
public boolean edit(SchSystemParams schSystemParams) {
return super.updateById(schSystemParams);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchSystemParams> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<SchSystemParams> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(SchSystemParams::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(SchSystemParams::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(SchSystemParams::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(SchSystemParams::getxx1, searchRequest. getKeyword())
// оr(). like(SchSystemParams::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(SchSystemParams::getCreateTime);
List<SchSystemParams> list = super.find(query);
return new PageResult<>(list);
}
}

@ -5,9 +5,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskCollector;
import com.docus.server.infrastructure.dao.ITaskCollectorDao;
import com.docus.server.infrastructure.mapper.TaskCollectorMapper;
import com.docus.server.entity.scheduling.management.SchTerminator;
import com.docus.server.infrastructure.dao.ISchTerminatorDao;
import com.docus.server.infrastructure.mapper.SchTerminatorMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
@ -15,15 +15,13 @@ import java.util.Date;
import java.util.List;
/**
* <p>
* TaskCollectorDaoImpl 访
* </p>
* 访
*
* @author AutoGenerator
* @since 2023-07-12
* @since 2023-07-14
*/
@Repository
public class TaskCollectorDaoImpl extends BaseDaoImpl<TaskCollectorMapper, TaskCollector> implements ITaskCollectorDao {
public class SchTerminatorDaoImpl extends BaseDaoImpl<SchTerminatorMapper, SchTerminator> implements ISchTerminatorDao {
/**
*
@ -32,30 +30,30 @@ public class TaskCollectorDaoImpl extends BaseDaoImpl<TaskCollectorMapper, TaskC
* @return
*/
@Override
public TaskCollector findById(String id) {
public SchTerminator findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskCollector
* @param schTerminator
* @return
*/
@Override
public boolean add(TaskCollector taskCollector) {
return super.save(taskCollector);
public boolean add(SchTerminator schTerminator) {
return super.save(schTerminator);
}
/**
*
*
* @param taskCollector
* @param schTerminator
* @return
*/
@Override
public boolean edit(TaskCollector taskCollector) {
return super.updateById(taskCollector);
public boolean edit(SchTerminator schTerminator) {
return super.updateById(schTerminator);
}
/**
@ -76,30 +74,30 @@ public class TaskCollectorDaoImpl extends BaseDaoImpl<TaskCollectorMapper, TaskC
* @return
*/
@Override
public PageResult<TaskCollector> search(SearchRequest searchRequest) {
public PageResult<SchTerminator> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskCollector> query = Wrappers.lambdaQuery();
LambdaQueryWrapper<SchTerminator> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskCollector::getCreateTime, searchRequest.getBeginTime());
query.ge(SchTerminator::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskCollector::getCreateTime, endTime);
query.le(SchTerminator::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskCollector::getxxx, searchRequest. getKeyword());
//query. like(SchTerminator::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskCollector::getxx1, searchRequest. getKeyword())
// оr(). like(TaskCollector::getXX2, searchRequest. getKeyword()))
//query. and(sub -> sub.like(SchTerminator::getxx1, searchRequest. getKeyword())
// оr(). like(SchTerminator::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskCollector::getCreateTime);
List<TaskCollector> list = super.find(query);
query.orderByDesc(SchTerminator::getCreateTime);
List<SchTerminator> list = super.find(query);
return new PageResult<>(list);
}

@ -0,0 +1,104 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.SchVirtualLog;
import com.docus.server.infrastructure.dao.ISchVirtualLogDao;
import com.docus.server.infrastructure.mapper.SchVirtualLogMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* 使 访
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Repository
public class SchVirtualLogDaoImpl extends BaseDaoImpl<SchVirtualLogMapper, SchVirtualLog> implements ISchVirtualLogDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public SchVirtualLog findById(String id) {
return super.findById(id);
}
/**
*
*
* @param schVirtualLog
* @return
*/
@Override
public boolean add(SchVirtualLog schVirtualLog) {
return super.save(schVirtualLog);
}
/**
*
*
* @param schVirtualLog
* @return
*/
@Override
public boolean edit(SchVirtualLog schVirtualLog) {
return super.updateById(schVirtualLog);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<SchVirtualLog> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<SchVirtualLog> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(SchVirtualLog::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(SchVirtualLog::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(SchVirtualLog::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(SchVirtualLog::getxx1, searchRequest. getKeyword())
// оr(). like(SchVirtualLog::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(SchVirtualLog::getCreateTime);
List<SchVirtualLog> list = super.find(query);
return new PageResult<>(list);
}
}

@ -1,106 +0,0 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskCollectorVersion;
import com.docus.server.infrastructure.dao.ITaskCollectorVersionDao;
import com.docus.server.infrastructure.mapper.TaskCollectorVersionMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* <p>
* TaskCollectorVersionDaoImpl 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Repository
public class TaskCollectorVersionDaoImpl extends BaseDaoImpl<TaskCollectorVersionMapper, TaskCollectorVersion> implements ITaskCollectorVersionDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskCollectorVersion findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskCollectorVersion
* @return
*/
@Override
public boolean add(TaskCollectorVersion taskCollectorVersion) {
return super.save(taskCollectorVersion);
}
/**
*
*
* @param taskCollectorVersion
* @return
*/
@Override
public boolean edit(TaskCollectorVersion taskCollectorVersion) {
return super.updateById(taskCollectorVersion);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskCollectorVersion> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskCollectorVersion> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskCollectorVersion::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskCollectorVersion::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskCollectorVersion::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskCollectorVersion::getxx1, searchRequest. getKeyword())
// оr(). like(TaskCollectorVersion::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskCollectorVersion::getCreateTime);
List<TaskCollectorVersion> list = super.find(query);
return new PageResult<>(list);
}
}

@ -1,106 +0,0 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskCollectorVersionFile;
import com.docus.server.infrastructure.dao.ITaskCollectorVersionFileDao;
import com.docus.server.infrastructure.mapper.TaskCollectorVersionFileMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* <p>
* TaskCollectorVersionFileDaoImpl 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Repository
public class TaskCollectorVersionFileDaoImpl extends BaseDaoImpl<TaskCollectorVersionFileMapper, TaskCollectorVersionFile> implements ITaskCollectorVersionFileDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskCollectorVersionFile findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskCollectorVersionFile
* @return
*/
@Override
public boolean add(TaskCollectorVersionFile taskCollectorVersionFile) {
return super.save(taskCollectorVersionFile);
}
/**
*
*
* @param taskCollectorVersionFile
* @return
*/
@Override
public boolean edit(TaskCollectorVersionFile taskCollectorVersionFile) {
return super.updateById(taskCollectorVersionFile);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskCollectorVersionFile> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskCollectorVersionFile> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskCollectorVersionFile::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskCollectorVersionFile::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskCollectorVersionFile::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskCollectorVersionFile::getxx1, searchRequest. getKeyword())
// оr(). like(TaskCollectorVersionFile::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskCollectorVersionFile::getCreateTime);
List<TaskCollectorVersionFile> list = super.find(query);
return new PageResult<>(list);
}
}

@ -1,106 +0,0 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminatorCollect;
import com.docus.server.infrastructure.dao.ITaskTerminatorCollectDao;
import com.docus.server.infrastructure.mapper.TaskTerminatorCollectMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* <p>
* TaskTerminatorCollectDaoImpl 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Repository
public class TaskTerminatorCollectDaoImpl extends BaseDaoImpl<TaskTerminatorCollectMapper, TaskTerminatorCollect> implements ITaskTerminatorCollectDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskTerminatorCollect findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskTerminatorCollect
* @return
*/
@Override
public boolean add(TaskTerminatorCollect taskTerminatorCollect) {
return super.save(taskTerminatorCollect);
}
/**
*
*
* @param taskTerminatorCollect
* @return
*/
@Override
public boolean edit(TaskTerminatorCollect taskTerminatorCollect) {
return super.updateById(taskTerminatorCollect);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskTerminatorCollect> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskTerminatorCollect> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskTerminatorCollect::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskTerminatorCollect::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskTerminatorCollect::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskTerminatorCollect::getxx1, searchRequest. getKeyword())
// оr(). like(TaskTerminatorCollect::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskTerminatorCollect::getCreateTime);
List<TaskTerminatorCollect> list = super.find(query);
return new PageResult<>(list);
}
}

@ -1,106 +0,0 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminatorCollectRetryLog;
import com.docus.server.infrastructure.dao.ITaskTerminatorCollectRetryLogDao;
import com.docus.server.infrastructure.mapper.TaskTerminatorCollectRetryLogMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* <p>
* TaskTerminatorCollectRetryLogDaoImpl 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Repository
public class TaskTerminatorCollectRetryLogDaoImpl extends BaseDaoImpl<TaskTerminatorCollectRetryLogMapper, TaskTerminatorCollectRetryLog> implements ITaskTerminatorCollectRetryLogDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskTerminatorCollectRetryLog findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskTerminatorCollectRetryLog
* @return
*/
@Override
public boolean add(TaskTerminatorCollectRetryLog taskTerminatorCollectRetryLog) {
return super.save(taskTerminatorCollectRetryLog);
}
/**
*
*
* @param taskTerminatorCollectRetryLog
* @return
*/
@Override
public boolean edit(TaskTerminatorCollectRetryLog taskTerminatorCollectRetryLog) {
return super.updateById(taskTerminatorCollectRetryLog);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskTerminatorCollectRetryLog> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskTerminatorCollectRetryLog> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskTerminatorCollectRetryLog::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskTerminatorCollectRetryLog::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskTerminatorCollectRetryLog::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskTerminatorCollectRetryLog::getxx1, searchRequest. getKeyword())
// оr(). like(TaskTerminatorCollectRetryLog::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskTerminatorCollectRetryLog::getCreateTime);
List<TaskTerminatorCollectRetryLog> list = super.find(query);
return new PageResult<>(list);
}
}

@ -1,106 +0,0 @@
package com.docus.server.infrastructure.dao.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.docus.infrastructure.core.db.dao.impl.BaseDaoImpl;
import com.docus.infrastructure.web.request.SearchRequest;
import com.docus.infrastructure.web.response.PageResult;
import com.docus.server.entity.scheduling.management.TaskTerminatorErrorLog;
import com.docus.server.infrastructure.dao.ITaskTerminatorErrorLogDao;
import com.docus.server.infrastructure.mapper.TaskTerminatorErrorLogMapper;
import com.github.pagehelper.PageHelper;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
/**
* <p>
* TaskTerminatorErrorLogDaoImpl 访
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Repository
public class TaskTerminatorErrorLogDaoImpl extends BaseDaoImpl<TaskTerminatorErrorLogMapper, TaskTerminatorErrorLog> implements ITaskTerminatorErrorLogDao {
/**
*
*
* @param id Id
* @return
*/
@Override
public TaskTerminatorErrorLog findById(String id) {
return super.findById(id);
}
/**
*
*
* @param taskTerminatorErrorLog
* @return
*/
@Override
public boolean add(TaskTerminatorErrorLog taskTerminatorErrorLog) {
return super.save(taskTerminatorErrorLog);
}
/**
*
*
* @param taskTerminatorErrorLog
* @return
*/
@Override
public boolean edit(TaskTerminatorErrorLog taskTerminatorErrorLog) {
return super.updateById(taskTerminatorErrorLog);
}
/**
*
*
* @param ids ids
* @return
*/
@Override
public int delete(List<String> ids) {
return super.deleteByIds(ids);
}
/**
*
*
* @param searchRequest
* @return
*/
@Override
public PageResult<TaskTerminatorErrorLog> search(SearchRequest searchRequest) {
//分页
PageHelper.startPage(searchRequest.getPageNum(), searchRequest.getPageSize());
LambdaQueryWrapper<TaskTerminatorErrorLog> query = Wrappers.lambdaQuery();
//时间范围默认按createTime
if (searchRequest.getBeginTime() != null) {
query.ge(TaskTerminatorErrorLog::getCreateTime, searchRequest.getBeginTime());
}
if (searchRequest.getEndTime() != null) {
Date endTime = searchRequest.getEndTime();
query.le(TaskTerminatorErrorLog::getCreateTime, endTime);
}
//关键字比较多个列or
//if (!StringUtils.isEmpty(searchRequest.getKeyword())) {
//单个列用like
//query. like(TaskTerminatorErrorLog::getxxx, searchRequest. getKeyword());
//多个列用like
//query. and(sub -> sub.like(TaskTerminatorErrorLog::getxx1, searchRequest. getKeyword())
// оr(). like(TaskTerminatorErrorLog::getXX2, searchRequest. getKeyword()))
//);
//}
//默认createTime倒序排序
query.orderByDesc(TaskTerminatorErrorLog::getCreateTime);
List<TaskTerminatorErrorLog> list = super.find(query);
return new PageResult<>(list);
}
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchCollectErrorLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectErrorLogMapper extends BaseMapper<SchCollectErrorLog> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchCollectRecord;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectRecordMapper extends BaseMapper<SchCollectRecord> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchCollectRecordRetryLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectRecordRetryLogMapper extends BaseMapper<SchCollectRecordRetryLog> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchCollectorConfig;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorConfigMapper extends BaseMapper<SchCollectorConfig> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchCollector;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorMapper extends BaseMapper<SchCollector> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchCollectorVersionFile;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorVersionFileMapper extends BaseMapper<SchCollectorVersionFile> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchCollectorVersionLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorVersionLogMapper extends BaseMapper<SchCollectorVersionLog> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchCollectorVersion;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchCollectorVersionMapper extends BaseMapper<SchCollectorVersion> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchOperationLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchOperationLogMapper extends BaseMapper<SchOperationLog> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchSystemParams;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchSystemParamsMapper extends BaseMapper<SchSystemParams> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchTerminator;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchTerminatorMapper extends BaseMapper<SchTerminator> {
}

@ -0,0 +1,17 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.SchVirtualLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
*
* 使 Mapper
*
* @author AutoGenerator
* @since 2023-07-14
*/
@Mapper
public interface SchVirtualLogMapper extends BaseMapper<SchVirtualLog> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskCollector;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskCollectorMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskCollectorMapper extends BaseMapper<TaskCollector> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskCollectorVersionFile;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskCollectorVersionFileMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskCollectorVersionFileMapper extends BaseMapper<TaskCollectorVersionFile> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskCollectorVersionLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskCollectorVersionLogMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskCollectorVersionLogMapper extends BaseMapper<TaskCollectorVersionLog> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskCollectorVersion;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskCollectorVersionMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskCollectorVersionMapper extends BaseMapper<TaskCollectorVersion> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskOperationLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskOperationLogMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskOperationLogMapper extends BaseMapper<TaskOperationLog> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskSystemParams;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskSystemParamsMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskSystemParamsMapper extends BaseMapper<TaskSystemParams> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskTerminatorCollect;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskTerminatorCollectMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskTerminatorCollectMapper extends BaseMapper<TaskTerminatorCollect> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskTerminatorCollectRetryLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskTerminatorCollectRetryLogMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskTerminatorCollectRetryLogMapper extends BaseMapper<TaskTerminatorCollectRetryLog> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskTerminatorErrorLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskTerminatorErrorLogMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskTerminatorErrorLogMapper extends BaseMapper<TaskTerminatorErrorLog> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskTerminator;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* TaskTerminatorMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskTerminatorMapper extends BaseMapper<TaskTerminator> {
}

@ -1,18 +0,0 @@
package com.docus.server.infrastructure.mapper;
import com.docus.server.entity.scheduling.management.TaskTerminatorVirtualLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* <p>
* 使 TaskTerminatorVirtualLogMapper
* </p>
*
* @author AutoGenerator
* @since 2023-07-12
*/
@Mapper
public interface TaskTerminatorVirtualLogMapper extends BaseMapper<TaskTerminatorVirtualLog> {
}

Some files were not shown because too many files have changed in this diff Show More

Loading…
Cancel
Save