package com.ruoyi.sales.task;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ruoyi.project.system.domain.SysNotice;
import com.ruoyi.project.system.service.ISysNoticeService;
import com.ruoyi.projectManagement.vo.InfoVo;
import com.ruoyi.projectManagement.pojo.ProjectConfig;
import com.ruoyi.projectManagement.service.InfoService;
import com.ruoyi.projectManagement.service.ProjectConfigService;
import com.ruoyi.sales.pojo.SalesLedger;
import com.ruoyi.sales.service.ISalesLedgerService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDate;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 销售台账-合同原件约定回传日期预警任务
 */
@Slf4j
@Component
@RequiredArgsConstructor
public class ContractReturnReminderTask {

    private final ProjectConfigService projectConfigService;
    private final ISalesLedgerService salesLedgerService;
    private final InfoService infoService;
    private final ISysNoticeService sysNoticeService;

    // 每天上午 8 点执行
    @Scheduled(cron = "0 0 8 * * ?")
    public void processReminders() {
        log.info("开始执行：合同原件回传预警扫描");
        ProjectConfig config = projectConfigService.getGlobalConfig();
        Integer reminderDays = config.getContractReturnReminderDays();
        if (reminderDays == null) {
            reminderDays = 3;
        }

        LocalDate targetDate = LocalDate.now().plusDays(reminderDays);

        // 查询符合条件的销售台账
        List<SalesLedger> ledgers = salesLedgerService.list(Wrappers.<SalesLedger>lambdaQuery()
                .eq(SalesLedger::getContractOriginalReturnDate, targetDate));

        if (ledgers == null || ledgers.isEmpty()) {
            log.info("今日无需要预警的合同回传记录");
            return;
        }

        log.info("发现 {} 条预警记录", ledgers.size());

        for (SalesLedger ledger : ledgers) {
            if (ledger.getProjectId() == null) {
                continue;
            }
            InfoVo projectInfo = infoService.getInfoById(ledger.getProjectId());
            if (projectInfo != null && projectInfo.getInfo() != null && projectInfo.getInfo().getManagerId() != null) {
                sendNotice(ledger, projectInfo);
            }
        }
        log.info("合同原件回传预警扫描结束");
    }

    private void sendNotice(SalesLedger ledger, InfoVo projectInfo) {
        SysNotice notice = new SysNotice();
        notice.setNoticeTitle("合同原件回传预警");
        notice.setNoticeType("1"); // 1为通知
        String content = String.format("项目【%s】关联的销售台账（%s）的合同原件约定回传日期（%s）即将到期，请及时处理！",
                projectInfo.getInfo().getTitle(),
                ledger.getSalesContractNo(),
                ledger.getContractOriginalReturnDate().toString());
        notice.setNoticeContent(content);
        notice.setStatus("0"); // 正常
        notice.setConsigneeId(projectInfo.getInfo().getManagerId());
        // 可以设置 senderId 为系统管理员 (例如 1L)
        notice.setSenderId(1L);

        try {
            sysNoticeService.save(notice);
        } catch (Exception e) {
            log.error("发送预警通知失败: salesLedgerId={}, error={}", ledger.getId(), e.getMessage());
        }
    }
}