package com.ruoyi.envaccess.controller;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.ruoyi.common.handler.CustomTenantLineHandler;
import com.ruoyi.framework.aspectj.lang.annotation.Anonymous;
import com.ruoyi.framework.aspectj.lang.annotation.Log;
import com.ruoyi.framework.aspectj.lang.enums.BusinessType;
import com.ruoyi.framework.web.domain.AjaxResult;
import com.ruoyi.envaccess.pojo.EnvInspection;
import com.ruoyi.envaccess.service.IEnvInspectionService;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

/**
 * 环保门禁--智能巡检台账（含路径规划/AI视频分析/报告/无人机机器人，AI与无人机字段预留）
 */
@RestController
@RequestMapping("/environmentAccess/inspection")
public class EnvInspectionController {

    @Resource
    private IEnvInspectionService envInspectionService;

    @GetMapping("/page")
    public AjaxResult page(Page page, EnvInspection req) {
        return AjaxResult.success(envInspectionService.listPage(page, req));
    }

    @GetMapping("/{id}")
    public AjaxResult detail(@PathVariable Long id) {
        return AjaxResult.success(envInspectionService.getById(id));
    }

    @PostMapping("/add")
    @Log(title = "智能巡检-新增", businessType = BusinessType.INSERT)
    public AjaxResult add(@RequestBody EnvInspection inspection) {
        inspection.setId(null);
        if (inspection.getStatus() == null) {
            inspection.setStatus(0);
        }
        return envInspectionService.save(inspection) ? AjaxResult.success() : AjaxResult.error("新增失败");
    }

    @PostMapping("/update")
    @Log(title = "智能巡检-修改", businessType = BusinessType.UPDATE)
    public AjaxResult update(@RequestBody EnvInspection inspection) {
        return envInspectionService.updateById(inspection) ? AjaxResult.success() : AjaxResult.error("修改失败");
    }

    @DeleteMapping("/delete")
    @Log(title = "智能巡检-删除", businessType = BusinessType.DELETE)
    public AjaxResult delete(@RequestBody List<Long> ids) {
        return envInspectionService.removeByIds(ids) ? AjaxResult.success() : AjaxResult.error("删除失败");
    }

    /**
     * 自动生成巡检报告
     */
    @GetMapping("/report/{id}")
    @Log(title = "智能巡检-生成报告", businessType = BusinessType.OTHER)
    public AjaxResult generateReport(@PathVariable Long id) {
        return AjaxResult.success((Object) envInspectionService.generateReport(id));
    }

    @PostMapping("/export")
    public void export(HttpServletResponse response, EnvInspection req) {
        envInspectionService.export(response, req);
    }

    @Value("${envaccess.callback.secret:hbmjxt-callback-2026}")
    private String callbackSecret;

    private static final ObjectMapper CALLBACK_MAPPER = new ObjectMapper();

    /**
     * 无人机 / 机器人 / AI 摄像头 巡检数据回传（对外开放接口，供第三方设备调用）
     *
     * 请求示例（POST JSON）：
     * {
     *   "secret": "hbmjxt-callback-2026",
     *   "tenantId": 222,
     *   "inspectionId": 3,                    // 可选，不传则按 area 匹配最近一条未取消任务，再没有就新建
     *   "area": "东门区域",
     *   "deviceType": "UAV",                  // UAV 无人机 / ROBOT 机器人 / CAMERA 摄像头
     *   "deviceCode": "UAV-M350-001",
     *   "collectedAt": "2026-10-24 09:12:35",
     *   "aiSummary": "共识别 5 类目标，发现 1 处未佩戴安全帽",
     *   "aiObjects": [{"object":"人员未佩戴安全帽","conclusion":"未按要求佩戴","confidence":0.93,"frameTime":"2026-10-24 09:12:35"}],
     *   "longitude": 120.382145, "latitude": 31.298512, "altitude": 45.6, "battery": 78,
     *   "photos": ["/profile/upload/uav_east_01.jpg"],
     *   "track": [{"t":"09:12:10","lng":120.3821,"lat":31.2985}]
     * }
     */
    @Anonymous
    @PostMapping("/callback")
    public AjaxResult callback(@RequestBody Map<String, Object> payload) {
        if (payload == null || payload.isEmpty()) {
            return AjaxResult.error("回传数据不能为空");
        }
        if (!callbackSecret.equals(String.valueOf(payload.get("secret")))) {
            return AjaxResult.error("secret 校验失败，请在请求体中携带正确的 secret");
        }
        Long tenantId = toLong(payload.get("tenantId"));
        if (tenantId == null) {
            return AjaxResult.error("tenantId 不能为空");
        }
        String area = payload.get("area") == null ? "未指定区域" : String.valueOf(payload.get("area"));
        String deviceType = payload.get("deviceType") == null ? "UAV" : String.valueOf(payload.get("deviceType"));
        String deviceCode = payload.get("deviceCode") == null ? deviceType + "-UNKNOWN" : String.valueOf(payload.get("deviceCode"));

        Map<String, Object> ai = new LinkedHashMap<>();
        ai.put("summary", payload.get("aiSummary") == null ? "本次回传未附带 AI 识别结论" : payload.get("aiSummary"));
        ai.put("objects", payload.get("aiObjects") == null ? new ArrayList<>() : payload.get("aiObjects"));

        Map<String, Object> uav = new LinkedHashMap<>();
        uav.put("deviceType", deviceType);
        uav.put("deviceCode", deviceCode);
        uav.put("area", area);
        uav.put("collectedAt", payload.get("collectedAt") == null ? "" : payload.get("collectedAt"));
        uav.put("longitude", payload.get("longitude"));
        uav.put("latitude", payload.get("latitude"));
        uav.put("altitude", payload.get("altitude"));
        uav.put("battery", payload.get("battery"));
        uav.put("photos", payload.get("photos") == null ? new ArrayList<>() : payload.get("photos"));
        uav.put("track", payload.get("track") == null ? new ArrayList<>() : payload.get("track"));
        uav.put("receivedAt", new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));

        String aiJson;
        String uavJson;
        try {
            aiJson = CALLBACK_MAPPER.writeValueAsString(ai);
            uavJson = CALLBACK_MAPPER.writeValueAsString(uav);
        } catch (Exception e) {
            return AjaxResult.error("回传数据序列化失败：" + e.getMessage());
        }

        EnvInspection target = null;
        Long inspectionId = toLong(payload.get("inspectionId"));
        if (inspectionId != null) {
            target = envInspectionService.getById(inspectionId);
        }
        if (target == null) {
            com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<EnvInspection> w =
                    new com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<>();
            w.eq(EnvInspection::getArea, area).ne(EnvInspection::getStatus, 3)
                    .orderByDesc(EnvInspection::getId).last("limit 1");
            target = envInspectionService.getOne(w, false);
        }

        boolean created = false;
        if (target == null) {
            target = new EnvInspection();
            target.setInspectionName(area + " 智能巡检（设备回传）");
            target.setInspectionType(2);
            target.setArea(area);
            target.setStatus(2);
            target.setPlanStartTime(new Date());
            target.setPlanEndTime(new Date());
            target.setActualStartTime(new Date());
            target.setActualEndTime(new Date());
            target.setInspector(deviceCode);
            target.setRoutePlan("由 " + deviceType + " 自动规划并执行");
            target.setInspectionResult("设备自动巡检已完成，识别结果详见回传数据。");
            target.setTenantId(tenantId);
            created = true;
        }
        target.setAiAnalysis(aiJson);
        target.setUavData(uavJson);
        if (target.getStatus() != null && target.getStatus() == 0) {
            target.setStatus(2);
        }
        if (target.getTenantId() == null) {
            target.setTenantId(tenantId);
        }

        // 设备回调没有登录上下文，临时跳过租户插件，tenant_id 已在上面显式写入
        CustomTenantLineHandler.TEMP_IGNORE.set(Boolean.TRUE);
        try {
            if (created) {
                envInspectionService.save(target);
            } else {
                envInspectionService.updateById(target);
            }
        } catch (Exception e) {
            return AjaxResult.error("回传数据落库失败：" + e.getMessage());
        } finally {
            CustomTenantLineHandler.TEMP_IGNORE.remove();
        }

        Map<String, Object> result = new LinkedHashMap<>();
        result.put("inspectionId", target.getId());
        result.put("created", created);
        result.put("deviceCode", deviceCode);
        result.put("deviceType", deviceType);
        result.put("area", area);
        return AjaxResult.success("巡检数据回传成功", result);
    }

    private Long toLong(Object v) {
        if (v == null) {
            return null;
        }
        try {
            return Long.valueOf(String.valueOf(v).trim());
        } catch (NumberFormatException e) {
            return null;
        }
    }
}