package jnpf.limsController;

import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jnpf.exception.DataException;
import jnpf.limsEntity.LimsHuanjingCaiyangdianVo;
import jnpf.limsEntity.LimsHuanjingJianceActionParam;
import jnpf.limsEntity.LimsHuanjingJianceKanbanItemVo;
import jnpf.limsEntity.LimsHuanjingJianceKanbanRowVo;
import jnpf.limsEntity.LimsHuanjingJianceQushiDataVo;
import jnpf.limsEntity.LimsHuanjingJianceQushiParam;
import jnpf.limsEntity.LimsHuanjingJianceQuyangParam;
import jnpf.limsEntity.LimsHuanjingJianceJiluEntity;
import jnpf.limsEntity.LimsSignEntity;
import jnpf.limsEntity.LimsSignUsageTarget;
import jnpf.limsEntity.SignOpType;
import jnpf.limsService.LimsHuanjingJianceService;
import jnpf.limsService.LimsSignService;
import jnpf.util.R;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.time.LocalDate;
import java.time.LocalTime;
import java.time.ZoneId;
import java.time.format.DateTimeParseException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.List;

@Slf4j
@Tag(name = "lims环境监测接口", description = "环境监测采样点 / 计划操作")
@RestController
@RequestMapping("/lims/biz/huanjing/jiance")
public class LimsHuanjingJianceController {

    @Autowired
    private LimsHuanjingJianceService limsHuanjingJianceService;
    @Autowired
    private LimsSignService limsSignService;

    /**
     * 查询采样点。
     *
     * <p>前端传入的 {@code jiance_quyu_id} 为 lims_huanjing_quyu.f_id；
     * lims_huanjing_caiyangdian 实际用 jiance_quyu 字段保存该区域主键。
     */
    @Operation(summary = "查询采样点")
    @GetMapping("/caiyangdian/list")
    public R<List<LimsHuanjingCaiyangdianVo>> listCaiyangdian(
            @RequestParam("jiance_quyu_id") String jianceQuyuId,
            @RequestParam(value = "jiejing_jibie", required = false) String jiejingJibie) {
        if (!StringUtils.hasText(jianceQuyuId)) {
            return R.error("检测区域ID不能为空");
        }

        String jibie = StringUtils.hasText(jiejingJibie) ? jiejingJibie.trim() : null;
        return R.success(limsHuanjingJianceService.listCaiyangdian(jianceQuyuId.trim(), jibie));
    }

    /**
     * 环境监测计划看板行。
     */
    @Operation(summary = "环境监测计划看板行")
    @GetMapping("/kanban/rows")
    public R<List<LimsHuanjingJianceKanbanRowVo>> listKanbanRows(
            @RequestParam(value = "jiance_quyu", required = false) String jianceQuyu,
            @RequestParam(value = "weizhi_bianhao", required = false) String weizhiBianhao,
            @RequestParam(value = "jiejing_jibie", required = false) String jiejingJibie) {
        return R.success(limsHuanjingJianceService.listKanbanRows(
                trimToNull(jianceQuyu),
                trimToNull(weizhiBianhao),
                trimToNull(jiejingJibie)));
    }

    /**
     * 环境监测计划看板日历项。
     */
    @Operation(summary = "环境监测计划看板日历项")
    @GetMapping("/kanban/items")
    public R<List<LimsHuanjingJianceKanbanItemVo>> listKanbanItems(
            @RequestParam("start_date") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
            @RequestParam("end_date") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate,
            @RequestParam(value = "jiance_quyu", required = false) String jianceQuyu,
            @RequestParam(value = "weizhi_bianhao", required = false) String weizhiBianhao,
            @RequestParam(value = "jiejing_jibie", required = false) String jiejingJibie) {
        if (startDate == null || endDate == null) {
            return R.error("日期范围不能为空");
        }
        if (startDate.isAfter(endDate)) {
            return R.error("开始日期不能大于结束日期");
        }

        ZoneId zoneId = ZoneId.systemDefault();
        Date start = Date.from(startDate.atStartOfDay(zoneId).toInstant());
        Date end = Date.from(endDate.atTime(LocalTime.MAX).atZone(zoneId).toInstant());
        return R.success(limsHuanjingJianceService.listKanbanItems(
                start,
                end,
                trimToNull(jianceQuyu),
                trimToNull(weizhiBianhao),
                trimToNull(jiejingJibie)));
    }

    /**
     * 删除环境监测计划看板记录子项。
     */
    @Operation(summary = "删除环境监测计划看板记录子项")
    @DeleteMapping("/kanban/zixiang/{id}")
    public R<String> deleteKanbanZixiang(@PathVariable("id") String id) {
        if (!StringUtils.hasText(id)) {
            return R.error("记录子项ID不能为空");
        }
        try {
            int affected = limsHuanjingJianceService.deleteKanbanZixiang(id.trim());
            if (affected <= 0) {
                return R.error("环境监测记录子项不存在");
            }
            return R.success("删除成功");
        } catch (DataException e) {
            return R.error(e.getMessage());
        }
    }

    /**
     * 环境监测趋势分析数据。
     */
    @Operation(summary = "环境监测趋势分析数据")
    @PostMapping("/qushi/data")
    public R<LimsHuanjingJianceQushiDataVo> getQushiData(@RequestBody LimsHuanjingJianceQushiParam param) {
        if (param == null) {
            return R.error("请求参数不能为空");
        }
        if (!StringUtils.hasText(param.getStartDate()) || !StringUtils.hasText(param.getEndDate())) {
            return R.error("日期范围不能为空");
        }
        if (!StringUtils.hasText(param.getJianceQuyu())) {
            return R.error("区域不能为空");
        }
        if (!StringUtils.hasText(param.getJiejingJibie())) {
            return R.error("洁净级别不能为空");
        }
        if (!StringUtils.hasText(param.getWeizhiBianhao())) {
            return R.error("房间编号不能为空");
        }
        if (!StringUtils.hasText(param.getJiancePinci())) {
            return R.error("监测频次不能为空");
        }
        if (param.getJianceXiangmu() == null || param.getJianceXiangmu().isEmpty()) {
            return R.error("监测项目不能为空");
        }
        if (!StringUtils.hasText(param.getJianceZhuangtai())) {
            return R.error("监测状态不能为空");
        }

        LocalDate startDate;
        LocalDate endDate;
        try {
            startDate = LocalDate.parse(param.getStartDate().trim());
            endDate = LocalDate.parse(param.getEndDate().trim());
        } catch (DateTimeParseException e) {
            return R.error("日期格式不正确");
        }
        if (startDate.isAfter(endDate)) {
            return R.error("开始日期不能大于结束日期");
        }

        List<String> jianceXiangmu = new ArrayList<>();
        for (String item : param.getJianceXiangmu()) {
            if (StringUtils.hasText(item)) {
                jianceXiangmu.add(item.trim());
            }
        }
        if (jianceXiangmu.isEmpty()) {
            return R.error("监测项目不能为空");
        }

        ZoneId zoneId = ZoneId.systemDefault();
        Date start = Date.from(startDate.atStartOfDay(zoneId).toInstant());
        Date end = Date.from(endDate.atTime(LocalTime.MAX).atZone(zoneId).toInstant());
        return R.success(limsHuanjingJianceService.listQushiData(
                start,
                end,
                param.getJianceQuyu().trim(),
                param.getJiejingJibie().trim(),
                param.getWeizhiBianhao().trim(),
                param.getJiancePinci().trim(),
                jianceXiangmu,
                param.getJianceZhuangtai().trim()));
    }

    /**
     * 环境监测计划操作。
     */
    @Operation(summary = "环境监测计划操作")
    @PostMapping("/jihua/action")
    public R<String> jianceJihuaAction(@RequestBody LimsHuanjingJianceActionParam param) {
        if (param == null) {
            return R.error("请求参数不能为空");
        }

        String action = param.getAction();
        String flowId = param.getFlowId();
        String taskId = param.getTaskId();

        if (!StringUtils.hasText(action)) {
            return R.error("缺少 action");
        }
        action = action.trim();
        if (!StringUtils.hasText(flowId)) {
            return R.error("流程id(flow_id)不能为空");
        }
        if (!StringUtils.hasText(taskId)) {
            return R.error("流程任务id(task_id)不能为空");
        }

        switch (action) {
            case "accept":
                int affected = limsHuanjingJianceService.acceptJianceJihua(flowId.trim(), taskId.trim());
                if (affected <= 0) {
                    return R.error("环境监测计划数据不存在");
                }
                return R.success("启用成功");
            case "terminate":
                int terminated = limsHuanjingJianceService.terminateJianceJihua(flowId.trim(), taskId.trim());
                if (terminated <= 0) {
                    return R.error("环境监测计划数据不存在");
                }
                return R.success("终止成功");
            default:
                return R.error("不支持的操作: " + action);
        }
    }

    /**
     * 环境监测报告操作。
     */
    @Operation(summary = "环境监测报告操作")
    @PostMapping("/baogao/action")
    public R<String> baogaoAction(@RequestBody LimsHuanjingJianceActionParam param) {
        if (param == null) {
            return R.error("请求参数不能为空");
        }

        String action = param.getAction();
        String flowId = param.getFlowId();
        String taskId = param.getTaskId();

        if (!StringUtils.hasText(action)) {
            return R.error("缺少 action");
        }
        action = action.trim();
        if (!StringUtils.hasText(flowId)) {
            return R.error("流程id(flow_id)不能为空");
        }
        if (!StringUtils.hasText(taskId)) {
            return R.error("流程任务id(task_id)不能为空");
        }
        if (!"submit".equals(action) && !"accept".equals(action) && !"reject".equals(action)) {
            return R.error("不支持的操作: " + action);
        }

        int affected = limsHuanjingJianceService.baogaoAction(flowId.trim(), taskId.trim(), action);
        if (affected <= 0) {
            return R.error("环境监测报告数据不存在");
        }
        return R.success("操作成功");
    }

    /**
     * 环境监测记录取样。
     */
    @Transactional(rollbackFor = Exception.class)
    @Operation(summary = "环境监测记录取样")
    @PostMapping("/jilu/quyang")
    public R<String> quyangJilu(@RequestBody LimsHuanjingJianceQuyangParam param) {
        if (param == null) {
            return R.error("请求参数不能为空");
        }
        if (!StringUtils.hasText(param.getJiluId())) {
            return R.error("环境监测记录ID不能为空");
        }
        if (!StringUtils.hasText(param.getBizSign())) {
            return R.error("请添加电子签名");
        }

        String jiluId = param.getJiluId().trim();
        String bizSign = param.getBizSign().trim();
        LimsHuanjingJianceJiluEntity jilu = limsHuanjingJianceService.findJiluById(jiluId);
        if (jilu == null) {
            return R.error("环境监测记录数据不存在");
        }
        LimsSignEntity sign;
        try {
            sign = limsSignService.requireValidSign(
                    bizSign, SignOpType.HUANJING_QUYANG, jiluId);
        } catch (DataException e) {
            return R.error(e.getMessage());
        }
        int affected = limsHuanjingJianceService.quyangJilu(jiluId, bizSign);
        if (affected <= 0) {
            return R.error("环境监测记录数据不存在");
        }
        recordHuanjingSignUsage(sign, SignOpType.HUANJING_QUYANG, jilu);
        return R.success("取样成功");
    }

    /**
     * 环境监测记录终止取样。
     */
    @Transactional(rollbackFor = Exception.class)
    @Operation(summary = "环境监测记录终止取样")
    @PostMapping("/jilu/quyang/terminate")
    public R<String> terminateQuyangJilu(@RequestBody LimsHuanjingJianceQuyangParam param) {
        if (param == null) {
            return R.error("请求参数不能为空");
        }
        if (!StringUtils.hasText(param.getJiluId())) {
            return R.error("环境监测记录ID不能为空");
        }
        if (!StringUtils.hasText(param.getBizSign())) {
            return R.error("请添加电子签名");
        }

        String jiluId = param.getJiluId().trim();
        String bizSign = param.getBizSign().trim();
        LimsHuanjingJianceJiluEntity jilu = limsHuanjingJianceService.findJiluById(jiluId);
        if (jilu == null) {
            return R.error("环境监测记录数据不存在");
        }
        LimsSignEntity sign;
        try {
            sign = limsSignService.requireValidSign(
                    bizSign, SignOpType.HUANJING_QUYANG_TERMINATE, jiluId);
        } catch (DataException e) {
            return R.error(e.getMessage());
        }
        int affected = limsHuanjingJianceService.terminateQuyangJilu(jiluId, bizSign);
        if (affected <= 0) {
            return R.error("环境监测记录数据不存在");
        }
        recordHuanjingSignUsage(sign, SignOpType.HUANJING_QUYANG_TERMINATE, jilu);
        return R.success("终止取样成功");
    }

    private String trimToNull(String value) {
        return StringUtils.hasText(value) ? value.trim() : null;
    }

    private void recordHuanjingSignUsage(LimsSignEntity sign,
                                         SignOpType opType,
                                         LimsHuanjingJianceJiluEntity jilu) {
        String bizCode = StringUtils.hasText(jilu.getJihuaMingcheng())
                ? jilu.getJihuaMingcheng().trim()
                : (StringUtils.hasText(jilu.getJihuaId()) ? jilu.getJihuaId().trim() : jilu.getId());
        LimsSignUsageTarget target = LimsSignUsageTarget.builder()
                .targetTable("lims_huanjing_jiance_jilu")
                .targetId(jilu.getId())
                .bizType("HUANJING_JIANCE")
                .bizModule("LIMS-环境监测")
                .bizCode(bizCode)
                .build();
        limsSignService.recordSignUsage(sign, opType,
                Collections.singletonList(jilu.getId()), Collections.singletonList(target));
    }
}