[MODIFY] 일부 Specification 클래스에 @RequiredArgsConstructor 추가하여 생성자 중복 제거 및 코드 간소화, BatchScheduler 실행 간격 5분으로 변경

main
bjkim 7 months ago
parent 4accb71545
commit d95468e24d

@ -17,7 +17,7 @@ public class BatchScheduler {
private final JobLauncher jobLauncher; private final JobLauncher jobLauncher;
private final Job runSyncJob; // Spring Batch의 Job 타입 private final Job runSyncJob; // Spring Batch의 Job 타입
@Scheduled(fixedDelay = 30000) // 30초마다 실행 @Scheduled(fixedDelay = 300000) // 30초마다 실행
public void runJob() throws Exception { public void runJob() throws Exception {
JobParameters params = new JobParametersBuilder() JobParameters params = new JobParametersBuilder()
.addLong("timestamp", System.currentTimeMillis()) // 중복 실행 방지 .addLong("timestamp", System.currentTimeMillis()) // 중복 실행 방지

@ -112,7 +112,6 @@ public class EdgeSWUploadService {
default -> throw new IllegalArgumentException("Invalid sw_type: " + sw_type); default -> throw new IllegalArgumentException("Invalid sw_type: " + sw_type);
} }
jsonBody.put("sw_id", edgeSWVO.getSw_id()); jsonBody.put("sw_id", edgeSWVO.getSw_id());
jsonBody.put("sw_version", edgeSWVO.getSw_version()); jsonBody.put("sw_version", edgeSWVO.getSw_version());
jsonBody.put("sw_name", edgeSWVO.getSw_name()); jsonBody.put("sw_name", edgeSWVO.getSw_name());

@ -7,6 +7,7 @@ import jakarta.persistence.metamodel.Attribute;
import jakarta.persistence.metamodel.EntityType; import jakarta.persistence.metamodel.EntityType;
import jakarta.persistence.metamodel.Metamodel; import jakarta.persistence.metamodel.Metamodel;
import kr.re.etri.autoflow.entity.DataGroupEntity; import kr.re.etri.autoflow.entity.DataGroupEntity;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.data.jpa.domain.Specification; import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -17,16 +18,13 @@ import java.util.stream.Collectors;
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor
public class DataGroupSpecification { public class DataGroupSpecification {
private final EntityManager entityManager; private final EntityManager entityManager;
private Set<String> stringFields; private Set<String> stringFields;
public DataGroupSpecification(EntityManager entityManager) {
this.entityManager = entityManager;
}
// 스프링 빈 초기화 후 실행 // 스프링 빈 초기화 후 실행
@PostConstruct @PostConstruct
public void init() { public void init() {

@ -7,6 +7,7 @@ import jakarta.persistence.metamodel.Attribute;
import jakarta.persistence.metamodel.EntityType; import jakarta.persistence.metamodel.EntityType;
import jakarta.persistence.metamodel.Metamodel; import jakarta.persistence.metamodel.Metamodel;
import kr.re.etri.autoflow.entity.ExperimentsEntity; import kr.re.etri.autoflow.entity.ExperimentsEntity;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.data.jpa.domain.Specification; import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -16,14 +17,12 @@ import java.util.stream.Collectors;
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor
public class ExperimentsSpecification { public class ExperimentsSpecification {
private final EntityManager entityManager; private final EntityManager entityManager;
private Set<String> stringFields; private Set<String> stringFields;
public ExperimentsSpecification(EntityManager entityManager) {
this.entityManager = entityManager;
}
@PostConstruct @PostConstruct
public void init() { public void init() {

@ -80,6 +80,7 @@ import jakarta.persistence.metamodel.EntityType;
import jakarta.persistence.metamodel.Metamodel; import jakarta.persistence.metamodel.Metamodel;
import kr.re.etri.autoflow.entity.ProjectEntity; import kr.re.etri.autoflow.entity.ProjectEntity;
import kr.re.etri.autoflow.entity.KubeflowRunEntity; import kr.re.etri.autoflow.entity.KubeflowRunEntity;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.data.jpa.domain.Specification; import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -91,16 +92,14 @@ import java.util.stream.Collectors;
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor
public class KubeflowRunSpecification { public class KubeflowRunSpecification {
private final EntityManager entityManager; private final EntityManager entityManager;
private Set<String> stringFields; private Set<String> stringFields;
public KubeflowRunSpecification(EntityManager entityManager) {
this.entityManager = entityManager;
}
// 스프링 빈 초기화 후 실행 // 스프링 빈 초기화 후 실행
@PostConstruct @PostConstruct
public void init() { public void init() {

@ -7,6 +7,7 @@ import jakarta.persistence.metamodel.Attribute;
import jakarta.persistence.metamodel.EntityType; import jakarta.persistence.metamodel.EntityType;
import jakarta.persistence.metamodel.Metamodel; import jakarta.persistence.metamodel.Metamodel;
import kr.re.etri.autoflow.entity.MinioAttachmentEntity; import kr.re.etri.autoflow.entity.MinioAttachmentEntity;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.data.jpa.domain.Specification; import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -17,16 +18,14 @@ import java.util.stream.Collectors;
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor
public class MinioAttachmentSpecification { public class MinioAttachmentSpecification {
private final EntityManager entityManager; private final EntityManager entityManager;
private Set<String> stringFields; private Set<String> stringFields;
public MinioAttachmentSpecification(EntityManager entityManager) {
this.entityManager = entityManager;
}
@PostConstruct @PostConstruct
public void init() { public void init() {
Metamodel metamodel = entityManager.getMetamodel(); Metamodel metamodel = entityManager.getMetamodel();

@ -6,6 +6,7 @@ import jakarta.persistence.metamodel.Attribute;
import jakarta.persistence.metamodel.EntityType; import jakarta.persistence.metamodel.EntityType;
import jakarta.persistence.metamodel.Metamodel; import jakarta.persistence.metamodel.Metamodel;
import kr.re.etri.autoflow.entity.ProjectEntity; import kr.re.etri.autoflow.entity.ProjectEntity;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.data.jpa.domain.Specification; import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -17,16 +18,13 @@ import java.util.stream.Collectors;
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor
public class ProjectSpecification { public class ProjectSpecification {
private final EntityManager entityManager; private final EntityManager entityManager;
private Set<String> stringFields; private Set<String> stringFields;
public ProjectSpecification(EntityManager entityManager) {
this.entityManager = entityManager;
}
// 스프링 빈 초기화 후 실행 // 스프링 빈 초기화 후 실행
@PostConstruct @PostConstruct
public void init() { public void init() {

@ -7,6 +7,7 @@ import jakarta.persistence.metamodel.EntityType;
import jakarta.persistence.metamodel.Metamodel; import jakarta.persistence.metamodel.Metamodel;
import kr.re.etri.autoflow.entity.ProjectEntity; import kr.re.etri.autoflow.entity.ProjectEntity;
import kr.re.etri.autoflow.entity.WorkflowEntity; import kr.re.etri.autoflow.entity.WorkflowEntity;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.data.jpa.domain.Specification; import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -18,16 +19,13 @@ import java.util.stream.Collectors;
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor
public class WorkflowSpecification { public class WorkflowSpecification {
private final EntityManager entityManager; private final EntityManager entityManager;
private Set<String> stringFields; private Set<String> stringFields;
public WorkflowSpecification(EntityManager entityManager) {
this.entityManager = entityManager;
}
// 스프링 빈 초기화 후 실행 // 스프링 빈 초기화 후 실행
@PostConstruct @PostConstruct
public void init() { public void init() {

Loading…
Cancel
Save