package com.ruoyi.energymeter.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.energymeter.dto.EnergyMeterDeviceQuery;
import com.ruoyi.energymeter.dto.MeterBindRequest;
import com.ruoyi.energymeter.dto.MeterCollectRequest;
import com.ruoyi.energymeter.dto.MeterManualBindRequest;
import com.ruoyi.energymeter.dto.MeterReadingRequest;
import com.ruoyi.energymeter.dto.MeterUpdateRequest;
import com.ruoyi.energymeter.dto.MeterVerifyRequest;
import com.ruoyi.energymeter.pojo.EnergyMeterDevice;
import com.ruoyi.energymeter.pojo.EnergyMeterMeasurement;
import com.ruoyi.energymeter.service.EnergyMeterDeviceService;
import com.ruoyi.energymeter.service.EnergyMeterDemoService;
import com.ruoyi.energymeter.service.EnergyMeterStatService;
import com.ruoyi.energymeter.service.EnergyMeterSyncService;
import com.ruoyi.energymeter.service.ElectricMeterDashboardService;
import com.ruoyi.energymeter.util.EnergyMeterSupport;
import com.ruoyi.framework.aspectj.lang.annotation.Log;
import com.ruoyi.framework.aspectj.lang.enums.BusinessType;
import com.ruoyi.framework.web.controller.BaseController;
import com.ruoyi.framework.web.domain.AjaxResult;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.RequiredArgsConstructor;
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.PutMapping;
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.DeleteMapping;
import org.springframework.web.bind.annotation.RestController;

import java.time.LocalDate;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

/**
 * 水电表接入与查表接口。
 *
 * <p>前端只调用本系统后端，第三方授权码不会下发到浏览器。</p>
 */
@RestController
@Tag(name = "水电表监测")
@RequestMapping("/energyMeter")
@RequiredArgsConstructor
public class EnergyMeterController extends BaseController {

    private final EnergyMeterDeviceService deviceService;
    private final EnergyMeterSyncService syncService;
    private final EnergyMeterStatService statService;
    private final EnergyMeterDemoService demoService;
    private final ElectricMeterDashboardService electricDashboardService;

    @GetMapping("/devices")
    @Operation(summary = "设备列表-分页查询")
    @Log(title = "水电表监测-设备列表", businessType = BusinessType.OTHER)
    public AjaxResult devices(Page<EnergyMeterDevice> page, EnergyMeterDeviceQuery query) {
        IPage<EnergyMeterDevice> result = deviceService.pageDevices(page, query);
        return AjaxResult.success(result);
    }

    @GetMapping("/devices/options")
    @Operation(summary = "设备下拉选项")
    public AjaxResult deviceOptions(@RequestParam(required = false) String meterType) {
        return AjaxResult.success(deviceService.listDeviceOptions(meterType));
    }

    @PostMapping("/devices/verify")
    @Operation(summary = "验证并读取第三方档案")
    @Log(title = "水电表监测-档案验证", businessType = BusinessType.OTHER)
    public AjaxResult verify(@RequestBody MeterVerifyRequest request) {
        return AjaxResult.success(deviceService.verifyArchive(request.getMeterType(), request.getMeterAddress()));
    }

    @PostMapping("/devices")
    @Operation(summary = "新增本地绑定")
    @Log(title = "水电表监测-新增绑定", businessType = BusinessType.INSERT)
    public AjaxResult add(@RequestBody MeterBindRequest request) {
        return AjaxResult.success(deviceService.bind(request));
    }

    @PutMapping("/devices/{id}")
    @Operation(summary = "修改设备本地字段/启停用")
    @Log(title = "表具台账-修改设备", businessType = BusinessType.UPDATE)
    public AjaxResult update(@PathVariable Long id, @RequestBody MeterUpdateRequest request) {
        return AjaxResult.success(deviceService.updateLocal(id, request));
    }

    @PostMapping("/devices/manual")
    @Operation(summary = "新增手工抄表设备（水表/电表/气表）")
    @Log(title = "表具台账-新增手工抄表设备", businessType = BusinessType.INSERT)
    public AjaxResult addManual(@RequestBody MeterManualBindRequest request) {
        return AjaxResult.success(deviceService.addManual(request));
    }

    @DeleteMapping("/devices/{id}")
    @Operation(summary = "删除设备（初始化设备与第三方接入设备不允许删除）")
    @Log(title = "表具台账-删除设备", businessType = BusinessType.DELETE)
    public AjaxResult remove(@PathVariable Long id) {
        deviceService.removeDevice(id);
        return AjaxResult.success();
    }

    @GetMapping("/devices/{id}/readings")
    @Operation(summary = "手工抄表记录分页")
    public AjaxResult readings(@PathVariable Long id,
                               @RequestParam(defaultValue = "1") long current,
                               @RequestParam(defaultValue = "20") long size) {
        return AjaxResult.success(deviceService.pageReadings(id, current, size));
    }

    @PostMapping("/devices/{id}/readings")
    @Operation(summary = "录入手工抄表表码")
    @Log(title = "表具台账-手工录表", businessType = BusinessType.INSERT)
    public AjaxResult addReading(@PathVariable Long id, @RequestBody MeterReadingRequest request) {
        return AjaxResult.success(deviceService.addReading(id, request));
    }

    @DeleteMapping("/devices/{id}/readings/{readingId}")
    @Operation(summary = "删除手工抄表记录")
    @Log(title = "表具台账-删除抄表记录", businessType = BusinessType.DELETE)
    public AjaxResult removeReading(@PathVariable Long id, @PathVariable Long readingId) {
        deviceService.removeReading(id, readingId);
        return AjaxResult.success();
    }

    @PostMapping("/devices/{id}/collect")
    @Operation(summary = "单台设备手动查表")
    @Log(title = "水电表监测-手动查表", businessType = BusinessType.OTHER)
    public AjaxResult collect(@PathVariable Long id,
                              @RequestBody(required = false) MeterCollectRequest request) {
        LocalDate start = request == null ? null : request.getStartDate();
        LocalDate end = request == null ? null : request.getEndDate();
        Boolean includeReadings = request == null ? null : request.getIncludeReadings();
        Long runId = syncService.triggerManual(List.of(id), start, end, includeReadings);
        return AjaxResult.success(runResult(runId));
    }

    @PostMapping("/devices/collect")
    @Operation(summary = "批量手动查表")
    @Log(title = "水电表监测-批量查表", businessType = BusinessType.OTHER)
    public AjaxResult collectBatch(@RequestBody MeterCollectRequest request) {
        List<Long> meterIds = new ArrayList<>();
        if (request.getMeterIds() != null) {
            meterIds.addAll(request.getMeterIds());
        }
        if (request.getMeterId() != null && !meterIds.contains(request.getMeterId())) {
            meterIds.add(request.getMeterId());
        }
        Long runId = syncService.triggerManual(meterIds, request.getStartDate(), request.getEndDate(),
                request.getIncludeReadings());
        return AjaxResult.success(runResult(runId));
    }

    @GetMapping("/devices/{id}/measurements")
    @Operation(summary = "设备读数/用量明细")
    public AjaxResult measurements(@PathVariable Long id,
                                   @RequestParam(required = false) String metricCode,
                                   @RequestParam(required = false) String granularity,
                                   @RequestParam(required = false) String start,
                                   @RequestParam(required = false) String end,
                                   @RequestParam(defaultValue = "1") long current,
                                   @RequestParam(defaultValue = "20") long size) {
        IPage<EnergyMeterMeasurement> page = statService.pageMeasurements(id, metricCode, granularity,
                parseDate(start), parseDate(end), current, size);
        return AjaxResult.success(page);
    }

    @GetMapping("/overview")
    @Operation(summary = "用能概览")
    public AjaxResult overview(@RequestParam(defaultValue = "WATER") String meterType,
                               @RequestParam(required = false) Long meterId,
                               @RequestParam(required = false) String month,
                               @RequestParam(required = false) Integer year) {
        return AjaxResult.success(statService.overview(meterType, meterId, month, year));
    }

    @GetMapping("/electric/dashboard")
    @Operation(summary = "电表实时看板：今日15分钟曲线与电能质量")
    public AjaxResult electricDashboard(@RequestParam(required = false) Long meterId,
                                        @RequestParam(defaultValue = "0") Integer weekOffset) {
        return AjaxResult.success(electricDashboardService.dashboard(meterId, weekOffset));
    }

    @PostMapping("/sync/trigger")
    @Operation(summary = "手动触发一次每日同步（排障用）")
    @Log(title = "水电表监测-触发同步", businessType = BusinessType.OTHER)
    public AjaxResult triggerDailySync() {
        return AjaxResult.success(runResult(syncService.triggerScheduledSync()));
    }

    @PostMapping("/sync/recover")
    @Operation(summary = "手动触发一次重试/超时恢复（排障用）")
    @Log(title = "水电表监测-触发恢复", businessType = BusinessType.OTHER)
    public AjaxResult recoverSync() {
        Map<String, Object> data = new LinkedHashMap<>();
        data.put("handled", syncService.recoverDueTasks());
        return AjaxResult.success(data);
    }

    @GetMapping("/providerStatus")
    @Operation(summary = "第三方接入模式")
    public AjaxResult providerStatus() {
        Map<String, Object> data = new LinkedHashMap<>();
        data.put("mockMode", deviceService.mockMode());
        return AjaxResult.success(data);
    }

    @PostMapping("/sync/gasSimulate")
    @Operation(summary = "生成气表演示数据（按天，默认今天；同一天重复执行不会重复写入）")
    @Log(title = "表具台账-气表演示数据", businessType = BusinessType.OTHER)
    public AjaxResult gasSimulate(@RequestParam(required = false) String date) {
        LocalDate day = StringUtils.isBlank(date) ? EnergyMeterSupport.today() : parseDate(date);
        Map<String, Object> data = new LinkedHashMap<>();
        data.put("date", day.toString());
        data.put("generated", demoService.generateGasDemo(day));
        return AjaxResult.success(data);
    }

    private Map<String, Object> runResult(Long runId) {
        Map<String, Object> data = new LinkedHashMap<>();
        data.put("runId", runId);
        return data;
    }

    private LocalDate parseDate(String value) {
        if (StringUtils.isBlank(value)) {
            return null;
        }
        try {
            return LocalDate.parse(value.trim());
        } catch (Exception e) {
            throw new ServiceException("日期格式应为 yyyy-MM-dd");
        }
    }
}