package com.smartor.service.impl;

import com.smartor.domain.PatSpecificArchiveGenerateLog;
import com.smartor.mapper.PatSpecificArchiveGenerateLogMapper;
import com.smartor.service.IPatSpecificArchiveGenerateLogService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;

import java.util.Date;

/**
 * 专科档案生成日志Service业务层处理。
 *
 * @author ruoyi
 * @date 2026-11-11
 */
@Service
public class PatSpecificArchiveGenerateLogServiceImpl implements IPatSpecificArchiveGenerateLogService {

    @Autowired
    private PatSpecificArchiveGenerateLogMapper logMapper;

    @Override
    public PatSpecificArchiveGenerateLog selectBySourceSubAndConfig(String sourceType, Long sourceSubId, Integer configId) {
        return logMapper.selectBySourceSubAndConfig(sourceType, sourceSubId,
                configId == null ? 0 : configId);
    }

    @Override
    public boolean existsProcessedBySourceSub(String sourceType, Long sourceSubId) {
        return logMapper.countProcessedBySourceSub(sourceType, sourceSubId) > 0;
    }

    @Override
    public int saveOrUpdate(PatSpecificArchiveGenerateLog log) {
        if (log == null) {
            return 0;
        }
        if (log.getSourceType() == null) {
            log.setSourceType("2");
        }
        if (log.getConfigId() == null) {
            log.setConfigId(0);
        }
        if (log.getRetryCount() == null) {
            log.setRetryCount(0);
        }
        Date now = new Date();
        log.setUpdateTime(now);
        PatSpecificArchiveGenerateLog old = logMapper.selectBySourceSubAndConfig(
                log.getSourceType(), log.getSourceSubId(), log.getConfigId());
        if (old == null) {
            log.setCreateTime(now);
            try {
                return logMapper.insertPatSpecificArchiveGenerateLog(log);
            } catch (DuplicateKeyException e) {
                // 并发下另一个线程已写入，转为更新，保证幂等
                old = logMapper.selectBySourceSubAndConfig(
                        log.getSourceType(), log.getSourceSubId(), log.getConfigId());
                if (old == null) {
                    throw e;
                }
                log.setId(old.getId());
                return logMapper.updatePatSpecificArchiveGenerateLog(log);
            }
        }
        log.setId(old.getId());
        if (log.getCreateTime() == null) {
            log.setCreateTime(old.getCreateTime());
        }
        return logMapper.updatePatSpecificArchiveGenerateLog(log);
    }
}