This commit is contained in:
Rinjae
2025-08-20 15:47:00 +09:00
commit 2cd9c29d4d
293 changed files with 9834 additions and 0 deletions
@@ -0,0 +1,19 @@
package com.eactive.eai.adapter.loader;
import java.util.List;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.adapter.AdapterGroup;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class AdapterGroupLoader extends AbstractDataLoader<AdapterGroup, String, AdapterGroupLoaderRepository> {
public List<AdapterGroup> selectAllGroups() {
return repository.selectAllGroups();
}
}
@@ -0,0 +1,21 @@
package com.eactive.eai.adapter.loader;
import java.util.List;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.querydsl.QuerydslPredicateExecutor;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.adapter.AdapterGroup;
import com.eactive.eai.data.jpa.BaseRepository;
interface AdapterGroupLoaderRepository extends BaseRepository<AdapterGroup, String>,
QuerydslPredicateExecutor<AdapterGroup>, DataLoaderRepository<AdapterGroup> {
@Query("from AdapterGroup where adptruseyn = '1' order by adptriodstcd desc")
List<AdapterGroup> selectAllGroups();
List<AdapterGroup> findByAdptrcd(String adptrcd, Sort by);
}
@@ -0,0 +1,24 @@
package com.eactive.eai.adapter.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.adapter.Adapter;
import com.eactive.eai.data.entity.onl.adapter.AdapterId;
import com.eactive.eai.data.entity.onl.adapter.QAdapter;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class AdapterLoader extends AbstractDataLoader<Adapter, AdapterId, AdapterLoaderRepository> {
public Iterable<Adapter> selectAdaptersByGroup(String defaultServer, String adapterGroupName,
String localServerName) {
QAdapter qAdapter = QAdapter.adapter;
return repository
.findAll(qAdapter.id.adptrbzwkgroupname
.eq(adapterGroupName)
.and(qAdapter.eaisevrinstncname.in(defaultServer, localServerName)));
}
}
@@ -0,0 +1,13 @@
package com.eactive.eai.adapter.loader;
import org.springframework.data.querydsl.QuerydslPredicateExecutor;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.adapter.Adapter;
import com.eactive.eai.data.entity.onl.adapter.AdapterId;
import com.eactive.eai.data.jpa.BaseRepository;
interface AdapterLoaderRepository
extends BaseRepository<Adapter, AdapterId>, QuerydslPredicateExecutor<Adapter>, DataLoaderRepository<Adapter> {
}
@@ -0,0 +1,14 @@
package com.eactive.eai.adapter.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.adapter.AdapterPropGroup;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class AdapterPropGroupLoader
extends AbstractDataLoader<AdapterPropGroup, String, AdapterPropGroupLoaderRepository> {
}
@@ -0,0 +1,10 @@
package com.eactive.eai.adapter.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.adapter.AdapterPropGroup;
import com.eactive.eai.data.jpa.BaseRepository;
interface AdapterPropGroupLoaderRepository
extends DataLoaderRepository<AdapterPropGroup>, BaseRepository<AdapterPropGroup, String> {
}
@@ -0,0 +1,14 @@
package com.eactive.eai.adapter.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.adapter.AdapterProp;
import com.eactive.eai.data.entity.onl.adapter.AdapterPropId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class AdapterPropLoader extends AbstractDataLoader<AdapterProp, AdapterPropId, AdapterPropLoaderRepository> {
}
@@ -0,0 +1,11 @@
package com.eactive.eai.adapter.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.adapter.AdapterProp;
import com.eactive.eai.data.entity.onl.adapter.AdapterPropId;
import com.eactive.eai.data.jpa.BaseRepository;
interface AdapterPropLoaderRepository
extends DataLoaderRepository<AdapterProp>, BaseRepository<AdapterProp, AdapterPropId> {
}
@@ -0,0 +1,13 @@
package com.eactive.eai.adapter.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.adapter.AdapterType;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class AdapterTypeLoader extends AbstractDataLoader<AdapterType, String, AdapterTypeLoaderRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.adapter.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.adapter.AdapterType;
import com.eactive.eai.data.jpa.BaseRepository;
interface AdapterTypeLoaderRepository extends DataLoaderRepository<AdapterType>, BaseRepository<AdapterType, String> {
}
@@ -0,0 +1,11 @@
package com.eactive.eai.apim.apigroup.loader;
import com.eactive.eai.data.entity.onl.apim.apigroup.ApiGroupApi;
import com.eactive.eai.data.jpa.AbstractDataLoader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Service
@Transactional
public class ApiGroupApiLoader extends AbstractDataLoader<ApiGroupApi, String, ApiGroupApiLoaderRepository> {
}
@@ -0,0 +1,10 @@
package com.eactive.eai.apim.apigroup.loader;
import com.eactive.eai.data.entity.onl.apim.apigroup.ApiGroupApi;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.jpa.BaseRepository;
import org.springframework.data.querydsl.QuerydslPredicateExecutor;
public interface ApiGroupApiLoaderRepository extends BaseRepository<ApiGroupApi, String>,
QuerydslPredicateExecutor<ApiGroupApi>, DataLoaderRepository<ApiGroupApi> {
}
@@ -0,0 +1,16 @@
package com.eactive.eai.apim.apigroup.loader;
import com.eactive.eai.data.entity.onl.apim.apigroup.ApiGroup;
import com.eactive.eai.data.jpa.AbstractDataLoader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
@Service
@Transactional
public class ApiGroupLoader extends AbstractDataLoader<ApiGroup, String, ApiGroupLoaderRepository> {
public List<ApiGroup> selectAllGroups() {
return repository.findAll();
}
}
@@ -0,0 +1,13 @@
package com.eactive.eai.apim.apigroup.loader;
import com.eactive.eai.data.entity.onl.apim.apigroup.ApiGroup;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.jpa.BaseRepository;
import org.springframework.data.querydsl.QuerydslPredicateExecutor;
import java.util.List;
public interface ApiGroupLoaderRepository extends BaseRepository<ApiGroup, String>,
QuerydslPredicateExecutor<ApiGroup>, DataLoaderRepository<ApiGroup> {
}
@@ -0,0 +1,20 @@
package com.eactive.eai.authserver.dao;
import java.util.stream.Stream;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.authserver.ClientEntity;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class ClientLoader extends AbstractDataLoader<ClientEntity, String, ClientLoaderRepository> {
@Override
public Stream<ClientEntity> loadAll() {
return repository.loadAll();
}
}
@@ -0,0 +1,9 @@
package com.eactive.eai.authserver.dao;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.authserver.ClientEntity;
import com.eactive.eai.data.jpa.BaseRepository;
interface ClientLoaderRepository extends DataLoaderRepository<ClientEntity>, BaseRepository<ClientEntity, String> {
}
@@ -0,0 +1,26 @@
package com.eactive.eai.authserver.dao;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.authserver.ScopeEntity;
import com.eactive.eai.data.entity.onl.authserver.ScopeEntityId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class ScopeLoader extends AbstractDataLoader<ScopeEntity, ScopeEntityId, ScopeLoaderRepository> {
public ScopeEntity findByIdBzwksvckeyname(String apiId) {
return repository.findByIdBzwksvckeyname(apiId);
}
public ScopeEntity findByIdScopeid(String scopeId) {
return repository.findByIdScopeid(scopeId);
}
public ScopeEntity findByIdBzwksvckeynameAndIdScopeid(String apiId, String scopeId) {
return repository.findByIdBzwksvckeynameAndIdScopeid(apiId, scopeId);
}
}
@@ -0,0 +1,15 @@
package com.eactive.eai.authserver.dao;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.authserver.ScopeEntity;
import com.eactive.eai.data.entity.onl.authserver.ScopeEntityId;
import com.eactive.eai.data.jpa.BaseRepository;
interface ScopeLoaderRepository extends DataLoaderRepository<ScopeEntity>, BaseRepository<ScopeEntity, ScopeEntityId> {
ScopeEntity findByIdBzwksvckeyname(String apiId);
ScopeEntity findByIdScopeid(String scopeId);
ScopeEntity findByIdBzwksvckeynameAndIdScopeid(String apiId, String scopeId);
}
@@ -0,0 +1,57 @@
package com.eactive.eai.authserver.dao;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Optional;
import java.util.stream.Stream;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import com.eactive.eai.data.entity.onl.authserver.TokenIssuanceLog;
@Component
public class TokenIssuanceLogLoader {
@Autowired
private TokenIssuanceLogLoaderRepository tokenIssuanceLogLoaderRepository;
public Stream<TokenIssuanceLog> loadAll() {
return tokenIssuanceLogLoaderRepository.findAll().stream();
}
public Optional<TokenIssuanceLog> findById(String id) {
return tokenIssuanceLogLoaderRepository.findById(id);
}
public List<TokenIssuanceLog> findByClientId(String clientId) {
return tokenIssuanceLogLoaderRepository.findByClientId(clientId);
}
public List<TokenIssuanceLog> findByAppName(String appName) {
return tokenIssuanceLogLoaderRepository.findByAppName(appName);
}
public List<TokenIssuanceLog> findByIssuanceDateTimeBetween(LocalDateTime start, LocalDateTime end) {
return tokenIssuanceLogLoaderRepository.findByIssuanceDateTimeBetween(start, end);
}
public List<TokenIssuanceLog> findBySuccessYn(String successYn) {
return tokenIssuanceLogLoaderRepository.findBySuccessYn(successYn);
}
public TokenIssuanceLog save(TokenIssuanceLog tokenIssuanceLog) {
return tokenIssuanceLogLoaderRepository.save(tokenIssuanceLog);
}
public int findRecentLogsForRestrictionCount(
String clientId, LocalDateTime startDateTime) {
List<TokenIssuanceLog> tokenIssuanceLogs = tokenIssuanceLogLoaderRepository.findRecentLogsForRestrictionCount(
clientId, startDateTime);
if(tokenIssuanceLogs == null){
return 0;
} else {
return tokenIssuanceLogs.size();
}
}
}
@@ -0,0 +1,31 @@
package com.eactive.eai.authserver.dao;
import java.time.LocalDateTime;
import java.util.List;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import com.eactive.eai.data.entity.onl.authserver.TokenIssuanceLog;
@Repository
public interface TokenIssuanceLogLoaderRepository extends JpaRepository<TokenIssuanceLog, String> {
List<TokenIssuanceLog> findByClientId(String clientId);
List<TokenIssuanceLog> findByAppName(String appName);
List<TokenIssuanceLog> findByIssuanceDateTimeBetween(LocalDateTime start, LocalDateTime end);
List<TokenIssuanceLog> findBySuccessYn(String successYn);
@Query("SELECT t FROM TokenIssuanceLog t WHERE t.clientId = :clientId " +
"AND t.issuanceDateTime >= :startDateTime " +
"AND (t.restrictionExemptYn = 'N' OR t.restrictionExemptYn IS NULL)")
List<TokenIssuanceLog> findRecentLogsForRestrictionCount(
@Param("clientId") String clientId,
@Param("startDateTime") LocalDateTime startDateTime
);
}
@@ -0,0 +1,13 @@
package com.eactive.eai.authserver.dao;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.authserver.UserEntity;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class UserLoader extends AbstractDataLoader<UserEntity, String, UserLoaderRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.authserver.dao;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.authserver.UserEntity;
import com.eactive.eai.data.jpa.BaseRepository;
interface UserLoaderRepository extends DataLoaderRepository<UserEntity>, BaseRepository<UserEntity, String> {
}
@@ -0,0 +1,17 @@
package com.eactive.eai.common.authoutbound.loader;
import com.eactive.eai.data.entity.onl.authoutbound.OutboundOAuthCredential;
import com.eactive.eai.data.jpa.AbstractDataLoader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
@Service
@Transactional
public class OutboundOAuthCredentialLoader extends AbstractDataLoader<OutboundOAuthCredential, String, OutboundOAuthCredentialLoaderRepository> {
public List<OutboundOAuthCredential> findAllByUseYn(String useYn){
return this.repository.findAllByUseYn(useYn);
}
}
@@ -0,0 +1,12 @@
package com.eactive.eai.common.authoutbound.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.authoutbound.OutboundOAuthCredential;
import com.eactive.eai.data.jpa.BaseRepository;
import java.util.List;
public interface OutboundOAuthCredentialLoaderRepository extends DataLoaderRepository<OutboundOAuthCredential>, BaseRepository<OutboundOAuthCredential, String> {
List<OutboundOAuthCredential>findAllByUseYn(String useYn);
}
@@ -0,0 +1,43 @@
package com.eactive.eai.common.b2badaptermapping.loader;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Order;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.b2badaptermapping.B2BAdapterMap;
import com.eactive.eai.data.entity.onl.b2badaptermapping.B2BAdapterMapId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class B2BAdapterMapLoader extends AbstractDataLoader<B2BAdapterMap, B2BAdapterMapId, B2BAdapterMapLoaderRepository> {
@Transactional(readOnly = true)
public List<B2BAdapterMap> findByIdEaisevrinstncnameOrderByDefault(String eaiSevrInstncName) {
List<Order> orders = new ArrayList<>();
orders.add(Order.asc("id.eaisvcname"));
orders.add(Order.asc("id.extnlinstiidnfiname"));
orders.add(Order.asc("id.dmnddtalsbzwkdsticname"));
Sort sort = Sort.by(orders);
return repository.findByIdEaisevrinstncname(eaiSevrInstncName, sort);
}
@Transactional(readOnly = true)
public Collection<B2BAdapterMap> findByIdEaisevrinstncnameAndIdEaisvcname(String eaiInstCd, String eaiSvcCd) {
List<Order> orders = new ArrayList<>();
orders.add(Order.asc("id.eaisvcname"));
orders.add(Order.asc("id.dmnddtalsbzwkdsticname"));
Sort sort = Sort.by(orders);
return repository.findByIdEaisevrinstncnameAndIdEaisvcname(eaiInstCd, eaiSvcCd, sort);
}
}
@@ -0,0 +1,20 @@
package com.eactive.eai.common.b2badaptermapping.loader;
import java.util.Collection;
import java.util.List;
import org.springframework.data.domain.Sort;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.b2badaptermapping.B2BAdapterMap;
import com.eactive.eai.data.entity.onl.b2badaptermapping.B2BAdapterMapId;
import com.eactive.eai.data.jpa.BaseRepository;
interface B2BAdapterMapLoaderRepository
extends DataLoaderRepository<B2BAdapterMap>, BaseRepository<B2BAdapterMap, B2BAdapterMapId> {
List<B2BAdapterMap> findByIdEaisevrinstncname(String eaiSevrInstncName, Sort sort);
Collection<B2BAdapterMap> findByIdEaisevrinstncnameAndIdEaisvcname(String eaiInstCd, String eaiSvcCd, Sort sort);
}
@@ -0,0 +1,37 @@
package com.eactive.eai.common.b2bextractor.loader;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Order;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.b2bextractor.B2BExtract;
import com.eactive.eai.data.entity.onl.b2bextractor.B2BExtractId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class B2BExtractLoader extends AbstractDataLoader<B2BExtract, B2BExtractId, B2BExtractLoaderRepository> {
public List<B2BExtract> findAllOrderByEaisvcname() {
try (Stream<B2BExtract> b2bStream = repository.loadAll(sortByEaisvcname())) {
return b2bStream.collect(Collectors.toList());
}
}
private Sort sortByEaisvcname() {
List<Order> orders = new ArrayList<>();
orders.add(Order.asc("id.eaisvcname"));
return Sort.by(orders);
}
public B2BExtract findByIdEaisvcname(String eaisvcname) {
return repository.findByIdEaisvcname(eaisvcname);
}
}
@@ -0,0 +1,12 @@
package com.eactive.eai.common.b2bextractor.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.b2bextractor.B2BExtract;
import com.eactive.eai.data.entity.onl.b2bextractor.B2BExtractId;
import com.eactive.eai.data.jpa.BaseRepository;
interface B2BExtractLoaderRepository
extends DataLoaderRepository<B2BExtract>, BaseRepository<B2BExtract, B2BExtractId> {
B2BExtract findByIdEaisvcname(String eaisvcname);
}
@@ -0,0 +1,36 @@
package com.eactive.eai.common.b2bservice.loader;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Order;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.b2bservice.B2BService;
import com.eactive.eai.data.entity.onl.b2bservice.B2BServiceId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class B2BServiceLoader extends AbstractDataLoader<B2BService, B2BServiceId, B2BServiceLoaderRepository> {
@Transactional(readOnly = true)
public List<B2BService> findByUseynOrderByDefault(String useyn) {
return repository.findByUseyn(useyn, sortByDefault());
}
@Transactional(readOnly = true)
public Collection<B2BService> findByIdExtnlinstiidnfinameOrderByDefault(String extnlinstiidnfiname) {
return repository.findByIdExtnlinstiidnfiname(extnlinstiidnfiname, sortByDefault());
}
private Sort sortByDefault() {
List<Order> orders = new ArrayList<>();
orders.add(Order.asc("id.extnlinstiidnfiname"));
orders.add(Order.asc("id.svcprcssno"));
return Sort.by(orders);
}
}
@@ -0,0 +1,20 @@
package com.eactive.eai.common.b2bservice.loader;
import java.util.Collection;
import java.util.List;
import org.springframework.data.domain.Sort;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.b2bservice.B2BService;
import com.eactive.eai.data.entity.onl.b2bservice.B2BServiceId;
import com.eactive.eai.data.jpa.BaseRepository;
public interface B2BServiceLoaderRepository
extends DataLoaderRepository<B2BService>, BaseRepository<B2BService, B2BServiceId> {
List<B2BService> findByUseyn(String useyn, Sort sortByDefault);
Collection<B2BService> findByIdExtnlinstiidnfiname(String extnlinstiidnfiname, Sort sortByDefault);
}
@@ -0,0 +1,41 @@
package com.eactive.eai.common.bizkey.loader;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Order;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.bizkey.BizKey;
import com.eactive.eai.data.entity.onl.bizkey.BizKeyId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class BizKeyLoader extends AbstractDataLoader<BizKey, BizKeyId, BizKeyLoaderRepository> {
@Transactional(readOnly = true)
public List<BizKey> findAllOrderByDefault() {
try (Stream<BizKey> stream = repository.loadAll(sortByDefault())) {
return stream.collect(Collectors.toList());
}
}
@Transactional(readOnly = true)
public Collection<BizKey> findByIdEaisvcnameAndIdEtractdstcd(String eaiSvcCd, String exrClsNm) {
return repository.findByIdEaisvcnameAndIdEtractdstcd(eaiSvcCd, exrClsNm, sortByDefault());
}
protected Sort sortByDefault() {
List<Order> orders = new ArrayList<>();
orders.add(Order.asc("id.eaisvcname"));
orders.add(Order.asc("id.etractdstcd"));
orders.add(Order.asc("id.fldprcssno"));
return Sort.by(orders);
}
}
@@ -0,0 +1,16 @@
package com.eactive.eai.common.bizkey.loader;
import java.util.Collection;
import org.springframework.data.domain.Sort;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.bizkey.BizKey;
import com.eactive.eai.data.entity.onl.bizkey.BizKeyId;
import com.eactive.eai.data.jpa.BaseRepository;
interface BizKeyLoaderRepository extends DataLoaderRepository<BizKey>, BaseRepository<BizKey, BizKeyId> {
Collection<BizKey> findByIdEaisvcnameAndIdEtractdstcd(String eaiSvcCd, String exrClsNm, Sort sortByDefault);
}
@@ -0,0 +1,35 @@
package com.eactive.eai.common.c2rservice.loader;
import java.util.ArrayList;
import java.util.List;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Order;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.c2rservice.C2RService;
import com.eactive.eai.data.entity.onl.c2rservice.C2RServiceId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class C2RServiceLoader extends AbstractDataLoader<C2RService, C2RServiceId, C2RServiceLoaderRepository> {
@Transactional(readOnly = true)
public List<C2RService> findByUseynOrderByDefault(String string) {
return repository.findByUseyn("1", sortByDefault());
}
public C2RService findByIdExtnlinstiidnfinameOrderByDefault(String c2rExtnlInstiCd) {
return repository.findByIdExtnlinstiidnfiname(c2rExtnlInstiCd, sortByDefault());
}
private Sort sortByDefault() {
List<Order> orders = new ArrayList<>();
orders.add(Order.asc("id.extnlinstiidnfiname"));
orders.add(Order.asc("id.svcprcssno"));
return Sort.by(orders);
}
}
@@ -0,0 +1,18 @@
package com.eactive.eai.common.c2rservice.loader;
import java.util.List;
import org.springframework.data.domain.Sort;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.c2rservice.C2RService;
import com.eactive.eai.data.entity.onl.c2rservice.C2RServiceId;
import com.eactive.eai.data.jpa.BaseRepository;
interface C2RServiceLoaderRepository extends DataLoaderRepository<C2RService>, BaseRepository<C2RService, C2RServiceId> {
List<C2RService> findByUseyn(String string, Sort sortByDefault);
C2RService findByIdExtnlinstiidnfiname(String c2rExtnlInstiCd, Sort sortByDefault);
}
@@ -0,0 +1,15 @@
package com.eactive.eai.common.duplication.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.duplication.DuplicationGuidData;
import com.eactive.eai.data.entity.onl.duplication.DuplicationGuidDataId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class DuplicationGuidDataLogger
extends AbstractDataLogger<DuplicationGuidData, DuplicationGuidDataId, DuplicationGuidDataLoggerRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.duplication.loader;
import com.eactive.eai.data.entity.onl.duplication.DuplicationGuidData;
import com.eactive.eai.data.entity.onl.duplication.DuplicationGuidDataId;
import com.eactive.eai.data.jpa.BaseRepository;
interface DuplicationGuidDataLoggerRepository extends BaseRepository<DuplicationGuidData, DuplicationGuidDataId> {
}
@@ -0,0 +1,15 @@
package com.eactive.eai.common.duplication.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.duplication.DuplicationGuidLog;
import com.eactive.eai.data.entity.onl.duplication.DuplicationGuidLogId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class DuplicationGuidLogLogger
extends AbstractDataLogger<DuplicationGuidLog, DuplicationGuidLogId, DuplicationGuidLogLoggerRepository> {
}
@@ -0,0 +1,8 @@
package com.eactive.eai.common.duplication.loader;
import com.eactive.eai.data.entity.onl.duplication.DuplicationGuidLog;
import com.eactive.eai.data.entity.onl.duplication.DuplicationGuidLogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface DuplicationGuidLogLoggerRepository extends BaseRepository<DuplicationGuidLog, DuplicationGuidLogId> {
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.errorcode.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.errorcode.ErrorCode;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class ErrorCodeLoader extends AbstractDataLoader<ErrorCode, String, ErrorCodeLoaderRepository> {
}
@@ -0,0 +1,12 @@
package com.eactive.eai.common.errorcode.loader;
import org.springframework.data.querydsl.QuerydslPredicateExecutor;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.errorcode.ErrorCode;
import com.eactive.eai.data.jpa.BaseRepository;
interface ErrorCodeLoaderRepository extends DataLoaderRepository<ErrorCode>, BaseRepository<ErrorCode, String>,
QuerydslPredicateExecutor<ErrorCode> {
}
@@ -0,0 +1,30 @@
package com.eactive.eai.common.inflow.loader;
import org.apache.commons.lang3.StringUtils;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.inflow.InflowControl;
import com.eactive.eai.data.entity.onl.inflow.InflowControlId;
import com.eactive.eai.data.entity.onl.inflow.QInflowControl;
import com.eactive.eai.data.jpa.AbstractDataLoader;
import com.querydsl.core.types.dsl.BooleanExpression;
@Service
@Transactional
public class InflowControlLoader extends AbstractDataLoader<InflowControl, InflowControlId, InflowControlLoaderRepository> {
public Iterable<InflowControl> findByConditions(String type, String name) {
QInflowControl q = QInflowControl.inflowControl;
BooleanExpression expression = q.id.type.eq(type);
if (StringUtils.isNotBlank(name)) {
expression = expression.and(q.id.name.eq(name));
}
Sort sort = Sort.by("id.name").and(Sort.by("useyn"));
return repository.findAll(expression, sort);
// return repository.findAll(expression, Sort.by("id.name", "useyn"));
}
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.inflow.loader;
import org.springframework.data.querydsl.QuerydslPredicateExecutor;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.inflow.InflowControl;
import com.eactive.eai.data.entity.onl.inflow.InflowControlId;
import com.eactive.eai.data.jpa.BaseRepository;
interface InflowControlLoaderRepository extends DataLoaderRepository<InflowControl>,
BaseRepository<InflowControl, InflowControlId>, QuerydslPredicateExecutor<InflowControl> {
}
@@ -0,0 +1,15 @@
package com.eactive.eai.common.inflow.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.inflow.InflowControlLog;
import com.eactive.eai.data.entity.onl.inflow.InflowControlLogId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class InflowControlLogLogger
extends AbstractDataLogger<InflowControlLog, InflowControlLogId, InflowControlLogLoggerRepository> {
}
@@ -0,0 +1,11 @@
package com.eactive.eai.common.inflow.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.inflow.InflowControlLog;
import com.eactive.eai.data.entity.onl.inflow.InflowControlLogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface InflowControlLogLoggerRepository
extends DataLoaderRepository<InflowControlLog>, BaseRepository<InflowControlLog, InflowControlLogId> {
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.lifecycle.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.lifecycle.LifeCycle;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class LifeCycleLoader extends AbstractDataLoader<LifeCycle, String, LifeCycleLoaderRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.lifecycle.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.lifecycle.LifeCycle;
import com.eactive.eai.data.jpa.BaseRepository;
interface LifeCycleLoaderRepository extends DataLoaderRepository<LifeCycle>, BaseRepository<LifeCycle, String> {
}
@@ -0,0 +1,29 @@
package com.eactive.eai.common.logger;
import java.util.Optional;
import javax.transaction.Transactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.eactive.eai.data.entity.onl.logger.EAIErrorLog;
import com.eactive.eai.data.entity.onl.logger.EAIErrorLogId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class EAIErrorLogLogger extends AbstractDataLogger<EAIErrorLog, EAIErrorLogId, EAIErrorLogLoggerRepository> {
private EAIErrorLogLoggerRepository eaiErrorLogRepository;
@Autowired
public EAIErrorLogLogger(EAIErrorLogLoggerRepository eaiErrorLogRepository) {
this.eaiErrorLogRepository = eaiErrorLogRepository;
}
public <S extends EAIErrorLog> Optional<EAIErrorLog> findById(Class<S> clazz, EAIErrorLogId eaiLogId) {
return eaiErrorLogRepository.findById(clazz, eaiLogId);
}
}
@@ -0,0 +1,11 @@
package com.eactive.eai.common.logger;
import com.eactive.eai.data.RollingTableRepository;
import com.eactive.eai.data.entity.onl.logger.EAIErrorLog;
import com.eactive.eai.data.entity.onl.logger.EAIErrorLogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface EAIErrorLogLoggerRepository
extends BaseRepository<EAIErrorLog, EAIErrorLogId>, RollingTableRepository<EAIErrorLog, EAIErrorLogId> {
}
@@ -0,0 +1,31 @@
package com.eactive.eai.common.logger;
import java.util.Optional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.logger.EAILog;
import com.eactive.eai.data.entity.onl.logger.EAILogId;
@Service
@Transactional
public class EAILogLogger {
private EAILogLoggerRepository eaiLogRepository;
@Autowired
public EAILogLogger(EAILogLoggerRepository eaiLogRepository) {
this.eaiLogRepository = eaiLogRepository;
}
public <S extends EAILog> Optional<EAILog> findById(Class<S> clazz, EAILogId eaiLogId) {
return eaiLogRepository.findById(clazz, eaiLogId);
}
public void save(EAILog eaiLog) {
eaiLogRepository.save(eaiLog);
}
}
@@ -0,0 +1,10 @@
package com.eactive.eai.common.logger;
import com.eactive.eai.data.RollingTableRepository;
import com.eactive.eai.data.entity.onl.logger.EAILog;
import com.eactive.eai.data.entity.onl.logger.EAILogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface EAILogLoggerRepository extends BaseRepository<EAILog, EAILogId>, RollingTableRepository<EAILog, EAILogId> {
}
@@ -0,0 +1,16 @@
package com.eactive.eai.common.logger;
import javax.transaction.Transactional;
import org.springframework.stereotype.Service;
import com.eactive.eai.data.entity.onl.logger.HttpAdapterExtraLog;
import com.eactive.eai.data.entity.onl.logger.HttpAdapterExtraLogId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class HttpAdapterExtraLogLogger
extends AbstractDataLogger<HttpAdapterExtraLog, HttpAdapterExtraLogId, HttpAdapterExtraLogLoggerRepository> {
}
@@ -0,0 +1,8 @@
package com.eactive.eai.common.logger;
import com.eactive.eai.data.entity.onl.logger.HttpAdapterExtraLog;
import com.eactive.eai.data.entity.onl.logger.HttpAdapterExtraLogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface HttpAdapterExtraLogLoggerRepository extends BaseRepository<HttpAdapterExtraLog, HttpAdapterExtraLogId> {
}
@@ -0,0 +1,23 @@
package com.eactive.eai.common.logger;
import java.io.Serializable;
import java.util.Optional;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import com.eactive.eai.data.RollingTable;
import com.eactive.eai.data.RollingTableRepository;
class RollingTableRepositoryImpl<T extends RollingTable, I extends Serializable>
implements RollingTableRepository<T, I> {
@PersistenceContext
private EntityManager em;
@Override
public <S extends T> Optional<T> findById(Class<S> clazz, I id) {
return Optional.ofNullable(em.find(clazz, id));
}
}
@@ -0,0 +1,16 @@
package com.eactive.eai.common.logger;
import javax.transaction.Transactional;
import org.springframework.stereotype.Service;
import com.eactive.eai.data.entity.onl.logger.StatAdapterLog;
import com.eactive.eai.data.entity.onl.logger.StatAdapterLogId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class StatAdapterLogLogger
extends AbstractDataLogger<StatAdapterLog, StatAdapterLogId, StatAdapterLogLoggerRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.logger;
import com.eactive.eai.data.entity.onl.logger.StatAdapterLog;
import com.eactive.eai.data.entity.onl.logger.StatAdapterLogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface StatAdapterLogLoggerRepository extends BaseRepository<StatAdapterLog, StatAdapterLogId> {
}
@@ -0,0 +1,16 @@
package com.eactive.eai.common.logger;
import javax.transaction.Transactional;
import org.springframework.stereotype.Service;
import com.eactive.eai.data.entity.onl.logger.StatLog;
import com.eactive.eai.data.entity.onl.logger.StatLogId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class StatLogLogger
extends AbstractDataLogger<StatLog, StatLogId, StatLogLoggerRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.logger;
import com.eactive.eai.data.entity.onl.logger.StatLog;
import com.eactive.eai.data.entity.onl.logger.StatLogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface StatLogLoggerRepository extends BaseRepository<StatLog, StatLogId> {
}
@@ -0,0 +1,15 @@
package com.eactive.eai.common.logger;
import javax.transaction.Transactional;
import org.springframework.stereotype.Service;
import com.eactive.eai.data.entity.onl.logger.StatTranLog;
import com.eactive.eai.data.entity.onl.logger.StatTranLogId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class StatTranLogLogger extends AbstractDataLogger<StatTranLog, StatTranLogId, StatTranLogLoggerRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.logger;
import com.eactive.eai.data.entity.onl.logger.StatTranLog;
import com.eactive.eai.data.entity.onl.logger.StatTranLogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface StatTranLogLoggerRepository extends BaseRepository<StatTranLog, StatTranLogId> {
}
@@ -0,0 +1,24 @@
package com.eactive.eai.common.logger;
import java.util.Optional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.logger.SubMessageLog;
import com.eactive.eai.data.entity.onl.logger.SubMessageLogId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class SubMessageLogLogger extends AbstractDataLogger<SubMessageLog, SubMessageLogId, SubMessageLogLoggerRepository> {
@Autowired
private SubMessageLogLoggerRepository subMessageLogLoggerRepository;
public <S extends SubMessageLog> Optional<SubMessageLog> findById(Class<S> clazz, SubMessageLogId subMessageLogId) {
return subMessageLogLoggerRepository.findById(clazz, subMessageLogId);
}
}
@@ -0,0 +1,11 @@
package com.eactive.eai.common.logger;
import com.eactive.eai.data.RollingTableRepository;
import com.eactive.eai.data.entity.onl.logger.SubMessageLog;
import com.eactive.eai.data.entity.onl.logger.SubMessageLogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface SubMessageLogLoggerRepository
extends BaseRepository<SubMessageLog, SubMessageLogId>, RollingTableRepository<SubMessageLog, SubMessageLogId> {
}
@@ -0,0 +1,15 @@
package com.eactive.eai.common.message.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.message.CondPerRtgInfoEntity;
import com.eactive.eai.data.entity.onl.message.CondPerRtgInfoEntityId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class CondPerRtgInfoLoader
extends AbstractDataLoader<CondPerRtgInfoEntity, CondPerRtgInfoEntityId, CondPerRtgInfoLoaderRepository> {
}
@@ -0,0 +1,11 @@
package com.eactive.eai.common.message.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.message.CondPerRtgInfoEntity;
import com.eactive.eai.data.entity.onl.message.CondPerRtgInfoEntityId;
import com.eactive.eai.data.jpa.BaseRepository;
interface CondPerRtgInfoLoaderRepository extends DataLoaderRepository<CondPerRtgInfoEntity>,
BaseRepository<CondPerRtgInfoEntity, CondPerRtgInfoEntityId> {
}
@@ -0,0 +1,19 @@
package com.eactive.eai.common.message.loader;
import java.util.List;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.message.EAIMessageEntity;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class EAIMessageLoader extends AbstractDataLoader<EAIMessageEntity, String, EAIMessageLoaderRepository> {
public List<EAIMessageEntity> findByUseynOrderByEaisvcname(String useyn) {
return repository.findByUseynOrderByEaisvcname(useyn);
}
}
@@ -0,0 +1,14 @@
package com.eactive.eai.common.message.loader;
import java.util.List;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.message.EAIMessageEntity;
import com.eactive.eai.data.jpa.BaseRepository;
interface EAIMessageLoaderRepository
extends DataLoaderRepository<EAIMessageEntity>, BaseRepository<EAIMessageEntity, String> {
List<EAIMessageEntity> findByUseynOrderByEaisvcname(String string);
}
@@ -0,0 +1,15 @@
package com.eactive.eai.common.message.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.message.EAIReferenceMessage;
import com.eactive.eai.data.entity.onl.message.EAIReferenceMessageId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class EAIReferenceMessageLoader
extends AbstractDataLoader<EAIReferenceMessage, EAIReferenceMessageId, EAIReferenceMessageLoaderRepository> {
}
@@ -0,0 +1,10 @@
package com.eactive.eai.common.message.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.message.EAIReferenceMessage;
import com.eactive.eai.data.entity.onl.message.EAIReferenceMessageId;
import com.eactive.eai.data.jpa.BaseRepository;
interface EAIReferenceMessageLoaderRepository
extends DataLoaderRepository<EAIReferenceMessage>, BaseRepository<EAIReferenceMessage, EAIReferenceMessageId> {
}
@@ -0,0 +1,15 @@
package com.eactive.eai.common.message.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.message.ServiceMessageEntity;
import com.eactive.eai.data.entity.onl.message.ServiceMessageEntityId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class ServiceMessageLoader
extends AbstractDataLoader<ServiceMessageEntity, ServiceMessageEntityId, ServiceMessageLoaderRepository> {
}
@@ -0,0 +1,11 @@
package com.eactive.eai.common.message.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.message.ServiceMessageEntity;
import com.eactive.eai.data.entity.onl.message.ServiceMessageEntityId;
import com.eactive.eai.data.jpa.BaseRepository;
interface ServiceMessageLoaderRepository extends DataLoaderRepository<ServiceMessageEntity>,
BaseRepository<ServiceMessageEntity, ServiceMessageEntityId> {
}
@@ -0,0 +1,38 @@
package com.eactive.eai.common.messagekey.loader;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.messagekey.MessageKey;
import com.eactive.eai.data.entity.onl.messagekey.MessageKeyId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class MessageKeyLoader extends AbstractDataLoader<MessageKey, MessageKeyId, MessageKeyLoaderRepository> {
@Transactional(readOnly = true)
public List<MessageKey> loadAllByOrderByDefault() {
try (Stream<MessageKey> stream = repository.loadAll(sortByDefault())) {
return stream.collect(Collectors.toList());
}
}
private Sort sortByDefault() {
return Sort.by(
Sort.Order.asc("id.adptrbzwkgroupname"),
Sort.Order.asc("id.msgdstcd"),
Sort.Order.asc("id.iodstcd"),
Sort.Order.asc("id.groupinorno"),
Sort.Order.asc("id.fldprcssno")
);
}
public List<MessageKey> selectMessageKeyByNameAndIoDstCode(String adptrbzwkgroupname,String iodstcd) {
return repository.selectMessageKeyByNameAndIoDstCode(adptrbzwkgroupname, iodstcd);
}
}
@@ -0,0 +1,18 @@
package com.eactive.eai.common.messagekey.loader;
import java.util.List;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.messagekey.MessageKey;
import com.eactive.eai.data.entity.onl.messagekey.MessageKeyId;
import com.eactive.eai.data.jpa.BaseRepository;
interface MessageKeyLoaderRepository
extends DataLoaderRepository<MessageKey>, BaseRepository<MessageKey, MessageKeyId> {
@Query("from MessageKey u where u.id.adptrbzwkgroupname = :pAdptrbzwkgroupname and u.id.iodstcd = :pIodstcd")
List<MessageKey> selectMessageKeyByNameAndIoDstCode(@Param("pAdptrbzwkgroupname") String adptrbzwkgroupname,
@Param("pIodstcd") String iodstcd);
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.property.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.property.PropGroup;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class PropGroupLoader extends AbstractDataLoader<PropGroup, String, PropGroupLoaderRepository> {
}
@@ -0,0 +1,20 @@
package com.eactive.eai.common.property.loader;
import java.util.List;
import org.springframework.data.jpa.repository.EntityGraph;
import org.springframework.data.jpa.repository.EntityGraph.EntityGraphType;
import org.springframework.data.querydsl.QuerydslPredicateExecutor;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.property.PropGroup;
import com.eactive.eai.data.jpa.BaseRepository;
interface PropGroupLoaderRepository extends DataLoaderRepository<PropGroup>, BaseRepository<PropGroup, String>,
QuerydslPredicateExecutor<PropGroup> {
@EntityGraph(type = EntityGraphType.FETCH, attributePaths = "props")
@Override
List<PropGroup> findAll();
}
@@ -0,0 +1,14 @@
package com.eactive.eai.common.property.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.property.Prop;
import com.eactive.eai.data.entity.onl.property.PropId;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class PropLoader extends AbstractDataLoader<Prop, PropId, PropLoaderRepository> {
}
@@ -0,0 +1,10 @@
package com.eactive.eai.common.property.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.property.Prop;
import com.eactive.eai.data.entity.onl.property.PropId;
import com.eactive.eai.data.jpa.BaseRepository;
interface PropLoaderRepository extends DataLoaderRepository<Prop>, BaseRepository<Prop, PropId> {
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.pushinfo.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.pushinfo.PushInfoDetail;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class PushInfoDetailLoader extends AbstractDataLoader<PushInfoDetail, String, PushInfoDetailLoaderRepository> {
}
@@ -0,0 +1,10 @@
package com.eactive.eai.common.pushinfo.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.pushinfo.PushInfoDetail;
import com.eactive.eai.data.jpa.BaseRepository;
interface PushInfoDetailLoaderRepository
extends DataLoaderRepository<PushInfoDetail>, BaseRepository<PushInfoDetail, String> {
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.pushinfo.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.pushinfo.PushInfo;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class PushInfoLoader extends AbstractDataLoader<PushInfo, String, PushInfoLoaderRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.pushinfo.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.pushinfo.PushInfo;
import com.eactive.eai.data.jpa.BaseRepository;
interface PushInfoLoaderRepository extends DataLoaderRepository<PushInfo>, BaseRepository<PushInfo, String> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.restrict.logger;
import com.eactive.eai.data.entity.onl.restrict.RestrictInfoHistory;
import com.eactive.eai.data.entity.onl.restrict.RestrictInfoHistoryId;
import com.eactive.eai.data.jpa.BaseRepository;
interface RestrictInfoHistoryRepository extends BaseRepository<RestrictInfoHistory, RestrictInfoHistoryId> {
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.restrict.logger;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.restrict.RestrictInfo;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class RestrictInfoLoader extends AbstractDataLoader<RestrictInfo, String, RestrictInfoLoaderRepository> {
}
@@ -0,0 +1,10 @@
package com.eactive.eai.common.restrict.logger;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.restrict.RestrictInfo;
import com.eactive.eai.data.jpa.BaseRepository;
interface RestrictInfoLoaderRepository
extends DataLoaderRepository<RestrictInfo>, BaseRepository<RestrictInfo, String> {
}
@@ -0,0 +1,15 @@
package com.eactive.eai.common.restrict.logger;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.restrict.RestrictInfoLog;
import com.eactive.eai.data.entity.onl.restrict.RestrictInfoLogId;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class RestrictInfoLogLogger
extends AbstractDataLogger<RestrictInfoLog, RestrictInfoLogId, RestrictInfoLogLoggerRepository> {
}
@@ -0,0 +1,11 @@
package com.eactive.eai.common.restrict.logger;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.restrict.RestrictInfoLog;
import com.eactive.eai.data.entity.onl.restrict.RestrictInfoLogId;
import com.eactive.eai.data.jpa.BaseRepository;
interface RestrictInfoLogLoggerRepository
extends DataLoaderRepository<RestrictInfoLog>, BaseRepository<RestrictInfoLog, RestrictInfoLogId> {
}
@@ -0,0 +1,34 @@
package com.eactive.eai.common.routing.loader;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Order;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.routing.Routing;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class RoutingLoader extends AbstractDataLoader<Routing, String, RoutingLoaderRepository> {
@Transactional(readOnly = true)
public List<Routing> findAllByOrderByDefault() {
try (Stream<Routing> routingStream = repository.loadAll(sortByDefault())) {
return routingStream.collect(Collectors.toList());
}
}
private Sort sortByDefault() {
List<Order> orders = new ArrayList<>();
orders.add(Order.asc("routname"));
orders.add(Order.desc("layerdstcd"));
return Sort.by(orders);
}
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.routing.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.routing.Routing;
import com.eactive.eai.data.jpa.BaseRepository;
interface RoutingLoaderRepository extends BaseRepository<Routing, String>, DataLoaderRepository<Routing> {
}
@@ -0,0 +1,7 @@
package com.eactive.eai.common.server.loader;
interface DatabaseHealthCheckRepository {
public boolean checkConnection();
}
@@ -0,0 +1,28 @@
package com.eactive.eai.common.server.loader;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Root;
import com.eactive.eai.data.entity.onl.server.EAIServer;
class DatabaseHealthCheckRepositoryImpl implements DatabaseHealthCheckRepository {
@PersistenceContext
private EntityManager em;
@Override
public boolean checkConnection() {
CriteriaBuilder builder = em.getCriteriaBuilder();
CriteriaQuery<Long> countQuery = builder.createQuery(Long.class);
Root<EAIServer> root = countQuery.from(EAIServer.class);
countQuery.select(builder.count(root));
Long count = em.createQuery(countQuery).getSingleResult();
return count > 0;
}
}
@@ -0,0 +1,23 @@
package com.eactive.eai.common.server.loader;
import java.util.stream.Stream;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.server.EAIServer;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class EAIServerLoader extends AbstractDataLoader<EAIServer, String, EAIServerLoaderRepository> {
public Stream<EAIServer> loadAll() {
return repository.loadAll();
}
public boolean checkConnection() {
return repository.checkConnection();
}
}
@@ -0,0 +1,10 @@
package com.eactive.eai.common.server.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.server.EAIServer;
import com.eactive.eai.data.jpa.BaseRepository;
interface EAIServerLoaderRepository
extends BaseRepository<EAIServer, String>, DatabaseHealthCheckRepository, DataLoaderRepository<EAIServer> {
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.sessioninfo.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.sessioninfo.SessionHistory;
import com.eactive.eai.data.jpa.AbstractDataLogger;
@Service
@Transactional
public class SessionHistoryLogger extends AbstractDataLogger<SessionHistory, String, SessionHistoryLoggerRepository> {
}
@@ -0,0 +1,8 @@
package com.eactive.eai.common.sessioninfo.loader;
import com.eactive.eai.data.entity.onl.sessioninfo.SessionHistory;
import com.eactive.eai.data.jpa.BaseRepository;
interface SessionHistoryLoggerRepository extends BaseRepository<SessionHistory, String> {
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.sessioninfo.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.sessioninfo.SessionInfo;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class SessionInfoLoader extends AbstractDataLoader<SessionInfo, String, SessionInfoLoaderRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.sessioninfo.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.sessioninfo.SessionInfo;
import com.eactive.eai.data.jpa.BaseRepository;
interface SessionInfoLoaderRepository extends DataLoaderRepository<SessionInfo>, BaseRepository<SessionInfo, String> {
}
@@ -0,0 +1,13 @@
package com.eactive.eai.common.sessioninfo.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.sessioninfo.TerminalInfo;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class TerminalInfoLoader extends AbstractDataLoader<TerminalInfo, String, TerminalInfoLoaderRepository> {
}
@@ -0,0 +1,10 @@
package com.eactive.eai.common.sessioninfo.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.sessioninfo.TerminalInfo;
import com.eactive.eai.data.jpa.BaseRepository;
interface TerminalInfoLoaderRepository
extends DataLoaderRepository<TerminalInfo>, BaseRepository<TerminalInfo, String> {
}
@@ -0,0 +1,14 @@
package com.eactive.eai.common.stdmessage.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.stdmessage.StandardMessageInfo;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class StandardMessageInfoLoader
extends AbstractDataLoader<StandardMessageInfo, String, StandardMessageInfoLoaderRepository> {
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.stdmessage.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.stdmessage.StandardMessageInfo;
import com.eactive.eai.data.jpa.BaseRepository;
interface StandardMessageInfoLoaderRepository
extends DataLoaderRepository<StandardMessageInfo>, BaseRepository<StandardMessageInfo, String> {
}
@@ -0,0 +1,18 @@
package com.eactive.eai.common.stdmessage.loader;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.eactive.eai.data.entity.onl.stdmessage.StandardMessageLayoutDeploy;
import com.eactive.eai.data.jpa.AbstractDataLoader;
@Service
@Transactional
public class StandardMessageLayoutDeployLoader
extends AbstractDataLoader<StandardMessageLayoutDeploy, String, StandardMessageLayoutDeployLoaderRepository> {
public StandardMessageLayoutDeploy findFirst() {
return repository.loadAll().findFirst().orElse(null);
}
}
@@ -0,0 +1,9 @@
package com.eactive.eai.common.stdmessage.loader;
import com.eactive.eai.data.DataLoaderRepository;
import com.eactive.eai.data.entity.onl.stdmessage.StandardMessageLayoutDeploy;
import com.eactive.eai.data.jpa.BaseRepository;
public interface StandardMessageLayoutDeployLoaderRepository
extends DataLoaderRepository<StandardMessageLayoutDeploy>, BaseRepository<StandardMessageLayoutDeploy, String> {
}

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