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;
    }
}