package com.battery.business.web.device;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
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.RequestHeader;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.ruoyi.common.annotation.Anonymous;
import com.ruoyi.common.exception.ServiceException;
import com.battery.business.service.DeviceAdapterErrorCodes;
import com.battery.business.service.DeviceIngestErrorCodes;
import com.battery.business.service.IDeviceIngestService;
import com.battery.business.service.IDeviceIngestService.IngestResult;

/**
 * 推式来源的接收端点（ADR-0065）：甲方机器上的只读取数程序把厂商原始行推到这里。
 *
 * <p>端点匿名放行但自己校验来源凭据（令牌随请求头来）：取数程序不带登录态，也不能带。
 * 拒绝一律用非 2xx 状态码——程序只在收到 2xx 后才推进自己的读取位置，
 * 所以"响应 200 但体内是错误码"是不能接受的：那会让程序把没落库的数据当成已送达。
 */
@Anonymous
@RestController
@RequestMapping("/device-ingest")
public class DeviceIngestController
{
    /** 来源凭据的请求头名；每个推式来源实例各有一个令牌。 */
    public static final String TOKEN_HEADER = "X-Device-Ingest-Token";

    private final IDeviceIngestService ingest;

    @Autowired
    public DeviceIngestController(IDeviceIngestService ingest)
    {
        this.ingest = ingest;
    }

    @PostMapping("/{adapterCode}")
    public ResponseEntity<?> receive(@PathVariable String adapterCode,
            @RequestHeader(value = TOKEN_HEADER, required = false) String token,
            @RequestBody(required = false) String body)
    {
        try
        {
            IngestResult result = ingest.ingest(adapterCode, token, body);
            return ResponseEntity.ok(result);
        }
        catch (ServiceException failure)
        {
            return ResponseEntity.status(httpStatus(failure.getCode()))
                    .body(new IngestFailure(failure.getCode(), failure.getMessage()));
        }
    }

    /** 业务错误码到 HTTP 状态的映射：只影响取数程序"是否推进水位"这一个判断。 */
    private static HttpStatus httpStatus(Integer code)
    {
        if (code == null) return HttpStatus.INTERNAL_SERVER_ERROR;
        return switch (code)
        {
            case DeviceAdapterErrorCodes.NOT_FOUND -> HttpStatus.NOT_FOUND;
            case DeviceIngestErrorCodes.TOKEN_INVALID -> HttpStatus.UNAUTHORIZED;
            case DeviceAdapterErrorCodes.UNSUPPORTED_TYPE, DeviceIngestErrorCodes.SOURCE_DISABLED -> HttpStatus.FORBIDDEN;
            case DeviceIngestErrorCodes.PAYLOAD_INVALID -> HttpStatus.BAD_REQUEST;
            default -> HttpStatus.INTERNAL_SERVER_ERROR;
        };
    }

    /** 拒绝应答：取数程序据此记录原因，并保持自己的读取位置不动。 */
    public record IngestFailure(Integer code, String message) { }
}