package jnpf.limsService.impl;

import jnpf.limsEntity.LimsHaocaiAlertRow;
import jnpf.limsEntity.LimsMessageEvent;
import jnpf.limsEntity.LimsMessageRequest;
import jnpf.limsEntity.LimsMessageSendResult;
import jnpf.limsEntity.LimsRecipientRef;
import jnpf.limsMapper.LimsHaocaiAlertMapper;
import jnpf.limsService.LimsHaocaiAlertService;
import jnpf.limsService.LimsMessageService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.Arrays;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

@Slf4j
@Service
@RequiredArgsConstructor
public class LimsHaocaiAlertServiceImpl implements LimsHaocaiAlertService {
    private static final String QC_ADMIN_ROLE = "ROLE.005";

    private final LimsHaocaiAlertMapper alertMapper;
    private final LimsMessageService messageService;

    @Value("${lims.message.enabled:false}")
    private boolean messageEnabled;

    @Scheduled(cron = "${lims.haocai.alert.cron:0 0 1 * * ?}")
    public void cronTrigger() {
        if (!messageEnabled) {
            log.info("[haocai-alert] skipped because lims.message.enabled=false");
            return;
        }
        log.info("[haocai-alert] cron triggered");
        scanAndAlert(false);
    }

    @Override
    public Map<String, Integer> scanAndAlert(boolean dryRun) {
        List<LimsHaocaiAlertRow> rows = alertMapper.selectBelowThreshold();
        int sent = 0;
        for (LimsHaocaiAlertRow row : rows) {
            LimsMessageSendResult result = messageService.send(LimsMessageRequest.builder()
                    .event(LimsMessageEvent.CONSUMABLE_STOCK_LOW)
                    .tenantId(row.getTenantId())
                    .bizId(row.getId())
                    .remindStage("DAILY")
                    .occurrenceKey(LimsMessageEvent.CONSUMABLE_STOCK_LOW.getCode() + ":" + row.getId()
                            + ":" + LocalDate.now().format(DateTimeFormatter.BASIC_ISO_DATE))
                    .recipients(Arrays.asList(LimsRecipientRef.roleEnCode(QC_ADMIN_ROLE)))
                    .parameters(parameters(row))
                    .dryRun(dryRun)
                    .build());
            if (result.isAccepted() && result.getRecipientCount() > 0
                    && result.getSentCount() == result.getRecipientCount()
                    && result.getFailedCount() == 0) {
                sent++;
            }
        }
        Map<String, Integer> stats = new LinkedHashMap<>();
        stats.put("hit", rows.size());
        stats.put("sent", sent);
        stats.put("skipped", rows.size() - sent);
        log.info("[haocai-alert] done, dryRun={}, stats={}", dryRun, stats);
        return stats;
    }

    private Map<String, Object> parameters(LimsHaocaiAlertRow row) {
        Map<String, Object> parameters = new HashMap<>();
        parameters.put("bizId", row.getId());
        parameters.put("bizName", row.getMingcheng() == null ? "" : row.getMingcheng());
        parameters.put("currentStock", plain(row.getJieyuSum()));
        parameters.put("warningStock", row.getQuehuoYujing() == null ? "" : row.getQuehuoYujing());
        return parameters;
    }

    private String plain(BigDecimal value) {
        return value == null ? "0" : value.stripTrailingZeros().toPlainString();
    }
}