package cn.lihu.jh.module.ecg.controller.admin.callingscreen;

import cn.hutool.extra.servlet.ServletUtil;
import cn.lihu.jh.framework.common.pojo.CommonResult;
import cn.lihu.jh.framework.common.util.object.BeanUtils;
import cn.lihu.jh.module.ecg.dal.dataobject.checktype.CheckTypeDO;
import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO;
import cn.lihu.jh.module.ecg.dal.mysql.checktype.CheckTypeMapper;
import cn.lihu.jh.module.ecg.service.callingscreen.CallingScreenService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.annotation.security.PermitAll;
import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

import static cn.lihu.jh.framework.common.pojo.CommonResult.error;
import static cn.lihu.jh.framework.common.pojo.CommonResult.success;

@Tag(name = "叫号屏 ")
@RestController
@RequestMapping("/ecg/screen")
@Validated
@Slf4j
public class CallingScreenController {

    @Resource
    private CallingScreenService callingScreenService;

    /** 用于给屏幕数据补「排队号前缀」（check_type.seq_prefix） */
    @Resource
    private CheckTypeMapper checkTypeMapper;

    /** 【重叫】用于给屏幕数据补"最近一次叫号记录id"（call_patient） */
    @Resource
    private cn.lihu.jh.module.ecg.dal.mysql.call.CallMapper callMapper;

    @GetMapping("/display-col-info")
    @Operation(summary = "列上显示的检查类型名称")
    @PermitAll
    public CommonResult<Map<Integer, List<String>>> displayColInfo()
    {
        Map<Integer, List<String>> map = callingScreenService.getDisplayColInfo();
        return success( map );
    }

    @GetMapping("/big-screen-data")
    @Operation(summary = "大屏叫号数据")
    @PermitAll
    public CommonResult<Map<Integer, List<ScreenQueueRespVO>>> callingData()
    {
        Map<Integer, List<QueueDO>> map = callingScreenService.getBigScreenPatient();

        Map<Integer, List<ScreenQueueRespVO>> mapVO = new HashMap<>();
        // 屏幕要显示「前缀 + 排队号」，设备未登录拿不到检查项目字典，故由后端一并下发（每次请求读一次）
        Map<Integer, String> seqPrefixMap = getSeqPrefixMap();
        // 【重叫】一并下发"最近一次叫号记录id"，屏幕据此重新播报
        Map<String, Long> callIdMap = getLatestCallIdMap();
        map.keySet().forEach( displayCol -> {
            //log.info("dispayCol: " + displayCol);
            List<QueueDO> columnQueueDOList = map.get(displayCol);
            List<ScreenQueueRespVO> screenQueueRespVOList = BeanUtils.toBean(columnQueueDOList, ScreenQueueRespVO.class);
            fillSeqPrefix(screenQueueRespVOList, seqPrefixMap);
            fillCallId(screenQueueRespVOList, callIdMap);
            mapVO.put(displayCol, screenQueueRespVOList);
        });

        return success( mapVO );
    }

    @GetMapping("/room-screen-data")
    @Operation(summary = "诊间屏数据")
    @PermitAll
    public CommonResult<Map<Integer, List<ScreenQueueRespVO>>> callingDataRoom(HttpServletRequest request, @RequestParam(value = "roomId", required = false)Long roomId)
    {
        String reqIp = ServletUtil.getClientIP(request);

        List<QueueDO> queueDOList1 = callingScreenService.getRoomCheckRelatedPatient(reqIp, roomId);
        List<QueueDO> queueDOList2 = callingScreenService.getRoomInstallRelatedPatient(reqIp, roomId);

        Map<Integer, List<ScreenQueueRespVO>> mapVO = new HashMap<>();
        List<ScreenQueueRespVO> waitingVOList = BeanUtils.toBean(queueDOList1, ScreenQueueRespVO.class);
        List<ScreenQueueRespVO> installVOList = BeanUtils.toBean(queueDOList2, ScreenQueueRespVO.class);
        // 屏幕要显示「前缀 + 排队号」，设备未登录拿不到检查项目字典，故由后端一并下发（每次请求读一次）
        Map<Integer, String> seqPrefixMap = getSeqPrefixMap();
        Map<String, Long> callIdMap = getLatestCallIdMap();
        fillSeqPrefix(waitingVOList, seqPrefixMap);
        fillSeqPrefix(installVOList, seqPrefixMap);
        fillCallId(waitingVOList, callIdMap);
        fillCallId(installVOList, callIdMap);
        mapVO.put(1, waitingVOList);
        mapVO.put(2, installVOList);
        return success( mapVO );
    }

    /**
     * 给屏幕数据补上「排队号显示前缀」= {@code check_type.seq_prefix}。
     *
     * <p>【号统一（本需求）】排队号按检查项目各自编号，不同检查项目会出现相同数字，
     * 屏幕上必须带前缀才分得清（例：A5 / B5）。屏幕设备不登录、无法调用检查项目接口，
     * 因此在这里补齐。
     *
     * <p>每次请求查一次全表建映射（检查项目只有十几个，量级很小）：
     * 不做长期缓存，避免管理员改了前缀后屏幕一直显示旧值。
     * 查不到配置时留空串——宁可只显示数字，也不要让屏幕报错或空白。
     */
    private void fillSeqPrefix(List<ScreenQueueRespVO> voList, Map<Integer, String> seqPrefixMap) {
        if (voList == null || voList.isEmpty() || seqPrefixMap == null) {
            return;
        }
        voList.forEach(vo -> vo.setSeqPrefix(seqPrefixMap.getOrDefault(vo.getBookCheckType(), "")));
    }

    /* ==================== 重叫：下发"最近一次叫号记录id" ==================== */

    /**
     * 给屏幕数据补上 {@code callId}（该患者最近一次叫号记录的 id）。
     *
     * <p>为什么需要：屏幕播报靠"数据变化"触发 —— 大屏判断"某患者新出现在叫号列"、
     * 诊间屏判断"诊中第一人变化"。而医生点「重叫」时**患者还是那个人、诊室还是那个诊室**，
     * 队列数据一点没变，两块屏自然不会再播。重叫会新增一条叫号记录（call_patient），
     * 把它的 id 下发后，屏幕只要发现 callId 变了就重新播报。
     */
    private void fillCallId(List<ScreenQueueRespVO> voList, Map<String, Long> callIdMap) {
        if (voList == null || voList.isEmpty() || callIdMap == null || callIdMap.isEmpty()) {
            return;
        }
        voList.forEach(vo -> {
            if (null != vo.getPatId()) {
                vo.setCallId(callIdMap.get(vo.getPatId()));
            }
        });
    }

    /** 一次查询取到「患者编号 → 最近一次叫号记录 id」；失败时返回空映射（屏幕按老逻辑播报） */
    private Map<String, Long> getLatestCallIdMap() {
        try {
            Map<String, Long> map = new HashMap<>();
            for (Map<String, Object> row : callMapper.selectLatestCallIds()) {
                Object patId = row.get("patId");
                Object callId = row.get("callId");
                if (null != patId && callId instanceof Number) {
                    map.put(String.valueOf(patId), ((Number) callId).longValue());
                }
            }
            return map;
        } catch (Exception e) {
            log.error("[getLatestCallIdMap] 读取最近叫号记录失败，重叫将不会触发屏幕重播", e);
            return new HashMap<>();
        }
    }

    /** 读一次检查项目配置，得到「检查项目值 → 排队号前缀」映射；失败时返回空映射（屏幕只显示号） */
    private Map<Integer, String> getSeqPrefixMap() {        try {
            return checkTypeMapper.simpleCheckTypeList().stream()
                    .filter(checkType -> null != checkType.getValue())
                    .collect(Collectors.toMap(CheckTypeDO::getValue,
                            checkType -> null == checkType.getSeqPrefix() ? "" : checkType.getSeqPrefix(),
                            (a, b) -> a));
        } catch (Exception e) {
            log.error("[getSeqPrefixMap] 读取检查项目前缀失败，屏幕将只显示号", e);
            return new HashMap<>();
        }
    }

}