package kr.wisestone.owl.service.impl;

import kr.wisestone.owl.domain.Issue;
import kr.wisestone.owl.domain.IssueRisk;
import kr.wisestone.owl.domain.Workspace;
import kr.wisestone.owl.repository.IssueRiskRepository;
import kr.wisestone.owl.service.IssueRiskService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashMap;
import java.util.Map;

@Service
public class IssueRiskServiceImpl extends AbstractServiceImpl<IssueRisk, Long, JpaRepository<IssueRisk, Long>> implements IssueRiskService {

    private static final Logger log = LoggerFactory.getLogger(IssueRiskServiceImpl.class);

    @Autowired
    private IssueRiskRepository issueRiskRepository;

    @Override
    protected JpaRepository<IssueRisk, Long> getRepository() {
        return this.issueRiskRepository;
    }

    //  이슈가 생성될 때 이슈 위험 관리도 같이 생성된다.
    @Override
    @Transactional
    public IssueRisk addIssueRisk(Issue issue, Workspace workspace) {
        IssueRisk issueRisk = new IssueRisk();
        issueRisk.setChangeIssueStatusCount(0L);
        issueRisk.setChangeAssigneeCount(0L);
        issueRisk.setIssue(issue);
        issueRisk.setWorkspace(workspace);
        issueRisk.setIssueStatusIds(issue.getIssueStatus().getId().toString());
        return this.issueRiskRepository.saveAndFlush(issueRisk);
    }

    //  이슈에서 담당자나 상태가 변경될 경우 이슈 위험 관리 정보를 업데이트한다.
    @Override
    @Transactional
    public void modifyIssueRisk(Issue issue, Boolean changeIssueStatus, Boolean changeAssignee, Long issueStatusId) {
        IssueRisk issueRisk = issue.getIssueRisk();

        //  상태 변경
        if (changeIssueStatus) {
            String issueStatusIds = issueRisk.getIssueStatusIds();
            issueStatusIds += "&" + issueStatusId;

            Map<String, Integer> issueStatusIdMaps = new HashMap<>();

            for (String key : issueStatusIds.split("&")) {
                if (!issueStatusIdMaps.containsKey(key)) {
                    issueStatusIdMaps.put(key, 1);
                }
                else {
                    issueStatusIdMaps.put(key, issueStatusIdMaps.get(key) + 1);
                }
            }

            Integer saveCount = 0;

            for (Integer value : issueStatusIdMaps.values()) {
                if (value > saveCount) {
                    saveCount = value;
                }
            }

            issueRisk.setChangeIssueStatusCount(saveCount.longValue());
            issueRisk.setIssueStatusIds(issueStatusIds);
        }

        //  담당자 변경
        if (changeAssignee) {
            issueRisk.setChangeAssigneeCount(issueRisk.getChangeAssigneeCount() + 1);
        }

        this.issueRiskRepository.saveAndFlush(issueRisk);
    }
}