File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
package kr.itn.itnhub.seed;
import kr.itn.itnhub.org.Organization;
import kr.itn.itnhub.org.OrganizationMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.support.TransactionTemplate;
import java.io.InputStream;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
@Service
public class SeedService {
private final SeedParser parser;
private final OrganizationMapper mapper;
private final TransactionTemplate transactionTemplate;
public SeedService(SeedParser parser, OrganizationMapper mapper,
PlatformTransactionManager transactionManager) {
this.parser = parser;
this.mapper = mapper;
this.transactionTemplate = new TransactionTemplate(transactionManager);
}
/**
* 엑셀 파싱은 DB와 무관하므로 트랜잭션 밖에서 수행한다. 커넥션을 잡아두는 구간은
* 기존 행 조회 + upsert 루프뿐이며, {@link TransactionTemplate}으로 그 구간만 감싼다.
* (같은 빈의 @Transactional 메서드를 self-invocation으로 호출하면 프록시를 우회해
* 트랜잭션이 아예 적용되지 않으므로 이 방식을 쓴다.)
*/
public SeedReport seed(InputStream xlsx) {
List<SeedRow> rows = parser.parse(xlsx);
return transactionTemplate.execute(status -> seedRows(rows));
}
private SeedReport seedRows(List<SeedRow> rows) {
// DB에 이미 있는 키와, 이번 업로드에서 먼저 처리된 키를 모두 "이미 존재함"으로 취급한다.
// 그래야 한 시트에 같은 기관이 두 번 들어와도 두 번째는 created가 아니라 updated로 집계된다.
Set<String> seen = new HashSet<>();
for (Organization existing : mapper.findAll()) {
seen.add(key(existing.getOrgNo(), existing.getOrgName()));
}
int created = 0;
int updated = 0;
for (SeedRow row : rows) {
if (seen.add(key(row.orgNo(), row.orgName()))) {
created++;
} else {
updated++;
}
mapper.upsertBySeed(toOrganization(row));
}
return new SeedReport(created, updated, rows.size());
}
private String key(String orgNo, String orgName) {
return orgNo + " " + orgName;
}
private Organization toOrganization(SeedRow row) {
Organization org = new Organization();
org.setOrgNo(row.orgNo());
org.setOrgName(row.orgName());
org.setChannelSlug(row.channelSlug());
org.setDeptName(row.deptName());
org.setManagerName(row.managerName());
org.setManagerTitle(row.managerTitle());
org.setManagerPhone(row.managerPhone());
org.setManagerEmail(row.managerEmail());
return org;
}
}