feat(1.5.0): 增加jobLog及retryLog接口;及自动配置类

This commit is contained in:
srzou 2025-04-14 23:25:34 +08:00
parent 8a90a67717
commit 3fa9eaceb9
6 changed files with 43 additions and 22 deletions

View File

@ -0,0 +1,5 @@
package com.aizuda.snailjob.template.datasource.access;
public interface JobLogAccess<T> extends LogAccess<T>{
}

View File

@ -0,0 +1,5 @@
package com.aizuda.snailjob.template.datasource.access;
public interface RetryLogAccess<T> extends LogAccess<T>{
}

View File

@ -1,14 +0,0 @@
package com.aizuda.snailjob.template.datasource.access.log;
import com.aizuda.snailjob.template.datasource.access.LogAccess;
/**
* <p>
*
* </p>
*
* @author opensnail
* @date 2025-03-30
*/
public abstract class AbstractLogAccess<T> implements LogAccess<T> {
}

View File

@ -1,6 +1,6 @@
package com.aizuda.snailjob.template.datasource.access.log; package com.aizuda.snailjob.template.datasource.access.log;
import com.aizuda.snailjob.template.datasource.access.LogAccess; import com.aizuda.snailjob.template.datasource.access.JobLogAccess;
import com.aizuda.snailjob.template.datasource.enums.DbTypeEnum; import com.aizuda.snailjob.template.datasource.enums.DbTypeEnum;
import com.aizuda.snailjob.template.datasource.enums.OperationTypeEnum; import com.aizuda.snailjob.template.datasource.enums.OperationTypeEnum;
import com.aizuda.snailjob.template.datasource.persistence.dataobject.common.*; import com.aizuda.snailjob.template.datasource.persistence.dataobject.common.*;
@ -13,8 +13,6 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.PageDTO; import com.baomidou.mybatisplus.extension.plugins.pagination.PageDTO;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.stereotype.Component;
import java.io.Serializable; import java.io.Serializable;
import java.util.*; import java.util.*;
@ -29,11 +27,9 @@ import static com.aizuda.snailjob.template.datasource.utils.DbUtils.getDbType;
* @author opensnail * @author opensnail
* @date 2025-03-30 * @date 2025-03-30
*/ */
@Component
@Slf4j @Slf4j
//@ConditionalOnMissingBean(LogAccess.class)
@RequiredArgsConstructor @RequiredArgsConstructor
public class JobLogMessageAccess extends AbstractLogAccess<JobLogMessageDO> { public class JobLogMessageAccess implements JobLogAccess<JobLogMessageDO> {
private final JobLogMessageMapper jobLogMessageMapper; private final JobLogMessageMapper jobLogMessageMapper;
private final JobTaskBatchMapper jobTaskBatchMapper; private final JobTaskBatchMapper jobTaskBatchMapper;

View File

@ -1,5 +1,6 @@
package com.aizuda.snailjob.template.datasource.access.log; package com.aizuda.snailjob.template.datasource.access.log;
import com.aizuda.snailjob.template.datasource.access.RetryLogAccess;
import com.aizuda.snailjob.template.datasource.enums.DbTypeEnum; import com.aizuda.snailjob.template.datasource.enums.DbTypeEnum;
import com.aizuda.snailjob.template.datasource.enums.OperationTypeEnum; import com.aizuda.snailjob.template.datasource.enums.OperationTypeEnum;
import com.aizuda.snailjob.template.datasource.persistence.dataobject.common.*; import com.aizuda.snailjob.template.datasource.persistence.dataobject.common.*;
@ -20,8 +21,7 @@ import static com.aizuda.snailjob.template.datasource.utils.DbUtils.getDbType;
* @author opensnail * @author opensnail
* @date 2025-03-29 * @date 2025-03-29
*/ */
@Component public class RetryTaskLogMessageAccess implements RetryLogAccess<RetryTaskLogMessageDO> {
public class RetryTaskLogMessageAccess extends AbstractLogAccess<RetryTaskLogMessageDO> {
@Override @Override

View File

@ -0,0 +1,29 @@
package com.aizuda.snailjob.template.datasource.access.log.config;
import com.aizuda.snailjob.template.datasource.access.JobLogAccess;
import com.aizuda.snailjob.template.datasource.access.RetryLogAccess;
import com.aizuda.snailjob.template.datasource.access.log.JobLogMessageAccess;
import com.aizuda.snailjob.template.datasource.access.log.RetryTaskLogMessageAccess;
import com.aizuda.snailjob.template.datasource.persistence.dataobject.log.JobLogMessageDO;
import com.aizuda.snailjob.template.datasource.persistence.dataobject.log.RetryTaskLogMessageDO;
import com.aizuda.snailjob.template.datasource.persistence.mapper.JobLogMessageMapper;
import com.aizuda.snailjob.template.datasource.persistence.mapper.JobTaskBatchMapper;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class LogConfig {
@ConditionalOnMissingBean
@Bean
public JobLogAccess<JobLogMessageDO> defaultJobLogAccess(JobLogMessageMapper jobLogMessageMapper, JobTaskBatchMapper jobTaskBatchMapper) {
return new JobLogMessageAccess(jobLogMessageMapper, jobTaskBatchMapper);
}
@ConditionalOnMissingBean
@Bean
public RetryLogAccess<RetryTaskLogMessageDO> defaultRetryLogAccess() {
return new RetryTaskLogMessageAccess();
}
}