package cn.iocoder.yudao.module.research.service.guideline;

import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.research.controller.admin.guideline.vo.ResearchGuidelinePageReqVO;
import cn.iocoder.yudao.module.research.controller.admin.guideline.vo.ResearchGuidelineSaveReqVO;
import cn.iocoder.yudao.module.research.dal.dataobject.guideline.ResearchGuidelineDO;
import cn.iocoder.yudao.module.research.dal.mysql.application.ResearchApplicationMapper;
import cn.iocoder.yudao.module.research.dal.mysql.guideline.ResearchGuidelineMapper;
import cn.iocoder.yudao.module.research.dal.redis.ResearchNoRedisDAO;
import cn.iocoder.yudao.module.research.enums.ResearchGuidelineStatusEnum;
import cn.iocoder.yudao.module.system.api.storage.StorageAttachmentApi;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.Collection;
import java.util.List;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
import static cn.iocoder.yudao.module.research.enums.ErrorCodeConstants.*;

@Service
@Validated
@Slf4j
public class ResearchGuidelineServiceImpl implements ResearchGuidelineService {

    public static final String GUIDELINE_RECORD_TYPE = "research_guideline";

    private static final DateTimeFormatter DATE_TIME_FORMATTER =
            DateTimeFormatter.ofPattern(FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);

    @Resource
    private ResearchGuidelineMapper guidelineMapper;

    @Resource
    private ResearchApplicationMapper applicationMapper;

    @Resource
    private ResearchNoRedisDAO noRedisDAO;

    @Resource
    private StorageAttachmentApi storageAttachmentApi;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Long createGuideline(ResearchGuidelineSaveReqVO createReqVO) {
        validateApplyTime(createReqVO);

        String no = noRedisDAO.generate(ResearchNoRedisDAO.GUIDELINE_NO_PREFIX);
        if (guidelineMapper.selectByNo(no) != null) {
            throw exception(GUIDELINE_NO_EXISTS);
        }

        ResearchGuidelineDO guideline = BeanUtils.toBean(createReqVO, ResearchGuidelineDO.class, in -> in
                .setNo(no)
                .setPublishStatus(ResearchGuidelineStatusEnum.DRAFT.getStatus()));
        guidelineMapper.insert(guideline);

        storageAttachmentApi.bindAttachments("file", GUIDELINE_RECORD_TYPE,
                guideline.getId(), createReqVO.getBlobIds());
        return guideline.getId();
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateGuideline(ResearchGuidelineSaveReqVO updateReqVO) {
        ResearchGuidelineDO guideline = validateGuidelineExists(updateReqVO.getId());
        if (!ResearchGuidelineStatusEnum.DRAFT.getStatus().equals(guideline.getPublishStatus())) {
            throw exception(GUIDELINE_UPDATE_FAIL_NOT_DRAFT, guideline.getNo());
        }
        validateApplyTime(updateReqVO);

        ResearchGuidelineDO updateObj = BeanUtils.toBean(updateReqVO, ResearchGuidelineDO.class);
        guidelineMapper.updateById(updateObj);

        storageAttachmentApi.updateAttachments("file", GUIDELINE_RECORD_TYPE,
                updateReqVO.getId(), updateReqVO.getBlobIds());
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void deleteGuideline(Long id) {
        ResearchGuidelineDO guideline = validateGuidelineExists(id);
        if (!ResearchGuidelineStatusEnum.DRAFT.getStatus().equals(guideline.getPublishStatus())) {
            throw exception(GUIDELINE_DELETE_FAIL_NOT_DRAFT, guideline.getNo());
        }
        // 已产生申报单时禁止删除，避免申报单悬挂在已删除指南上
        Long applicationCount = applicationMapper.selectCountByGuidelineId(id);
        if (applicationCount != null && applicationCount > 0) {
            throw exception(GUIDELINE_HAS_APPLICATION, guideline.getNo(), applicationCount);
        }

        guidelineMapper.deleteById(id);
        storageAttachmentApi.deleteAttachmentsByRecord(GUIDELINE_RECORD_TYPE, id);
    }

    @Override
    public ResearchGuidelineDO getGuideline(Long id) {
        return guidelineMapper.selectById(id);
    }

    @Override
    public PageResult<ResearchGuidelineDO> getGuidelinePage(ResearchGuidelinePageReqVO pageReqVO) {
        return guidelineMapper.selectPage(pageReqVO);
    }

    @Override
    public List<ResearchGuidelineDO> getPublishedGuidelineList() {
        return guidelineMapper.selectPublishedList();
    }

    @Override
    public List<ResearchGuidelineDO> getGuidelineList(Collection<Long> ids) {
        return guidelineMapper.selectListByIds(ids);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void publishGuideline(Long id) {
        ResearchGuidelineDO guideline = validateGuidelineExists(id);
        if (!ResearchGuidelineStatusEnum.DRAFT.getStatus().equals(guideline.getPublishStatus())) {
            throw exception(GUIDELINE_PUBLISH_FAIL_STATUS);
        }
        guidelineMapper.updateById(new ResearchGuidelineDO()
                .setId(id)
                .setPublishStatus(ResearchGuidelineStatusEnum.PUBLISHED.getStatus())
                .setPublishTime(LocalDateTime.now()));
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void closeGuideline(Long id) {
        ResearchGuidelineDO guideline = validateGuidelineExists(id);
        if (!ResearchGuidelineStatusEnum.PUBLISHED.getStatus().equals(guideline.getPublishStatus())) {
            throw exception(GUIDELINE_CLOSE_FAIL_STATUS);
        }
        guidelineMapper.updateById(new ResearchGuidelineDO()
                .setId(id)
                .setPublishStatus(ResearchGuidelineStatusEnum.CLOSED.getStatus()));
    }

    @Override
    public ResearchGuidelineDO validateGuidelineSubmittable(Long guidelineId) {
        ResearchGuidelineDO guideline = guidelineMapper.selectById(guidelineId);
        if (guideline == null) {
            throw exception(GUIDELINE_NOT_EXISTS);
        }
        // 逐维度校验，提示里给出「指南名 + 实际状态/时间 + 下一步动作」
        if (!ResearchGuidelineStatusEnum.PUBLISHED.getStatus().equals(guideline.getPublishStatus())) {
            throw exception(APPLICATION_SUBMIT_FAIL_GUIDELINE_STATUS,
                    guideline.getTitle(), ResearchGuidelineStatusEnum.nameOf(guideline.getPublishStatus()));
        }
        LocalDateTime now = LocalDateTime.now();
        boolean beforeStart = guideline.getApplyStartTime() != null && now.isBefore(guideline.getApplyStartTime());
        boolean afterEnd = guideline.getApplyEndTime() != null && now.isAfter(guideline.getApplyEndTime());
        if (beforeStart || afterEnd) {
            throw exception(APPLICATION_SUBMIT_FAIL_NOT_IN_PERIOD,
                    format(now), guideline.getTitle(),
                    format(guideline.getApplyStartTime()), format(guideline.getApplyEndTime()));
        }
        return guideline;
    }

    // =================== 内部方法 ===================

    private ResearchGuidelineDO validateGuidelineExists(Long id) {
        ResearchGuidelineDO guideline = guidelineMapper.selectById(id);
        if (guideline == null) {
            throw exception(GUIDELINE_NOT_EXISTS);
        }
        return guideline;
    }

    private void validateApplyTime(ResearchGuidelineSaveReqVO reqVO) {
        if (reqVO.getApplyStartTime() != null && reqVO.getApplyEndTime() != null
                && reqVO.getApplyEndTime().isBefore(reqVO.getApplyStartTime())) {
            throw exception(GUIDELINE_APPLY_TIME_INVALID,
                    format(reqVO.getApplyEndTime()), format(reqVO.getApplyStartTime()));
        }
    }

    private static String format(LocalDateTime time) {
        return time == null ? "未设置" : time.format(DATE_TIME_FORMATTER);
    }

}