package com.dy.pipIrrWechat.remote;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.dy.common.webUtil.BaseResponse;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import okhttp3.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.io.IOException;

/**
 * 远程视频服务调用类
 * 用于调用pipIrr-web-remote模块的video接口
 * 
 * @author zuoxiao
 * @date 2025-01-21
 * @description 微信模块调用远程控制模块的视频服务类
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class RemoteService {

    @Value("${remote.service.base-url:http://localhost:8081/remote}")
    private String remoteServiceBaseUrl;

    private final OkHttpClient httpClient;

    /**
     * 调用远程视频监控接口 - 获取摄像机数据
     * 
     * @param queryParams 查询参数字符串
     * @return 远程调用结果
     */
    public BaseResponse<Object> getVideoSome(String queryParams) {
        return callRemoteApi("/video/some?" + (queryParams != null ? queryParams : ""), null, "GET");
    }

    /**
     * 通用远程API调用方法
     * 
     * @param endpoint 接口端点
     * @param requestBody 请求体（GET请求时为null）
     * @param method HTTP方法
     * @return 调用结果
     */
    private BaseResponse<Object> callRemoteApi(String endpoint, String requestBody, String method) {
        String url = remoteServiceBaseUrl + endpoint;
        Request request;

        try {
            Request.Builder requestBuilder = new Request.Builder()
                    .url(url)
                    .addHeader("Content-Type", "application/json")
                    .addHeader("Accept", "application/json");

            if ("POST".equalsIgnoreCase(method) && requestBody != null) {
                RequestBody body = RequestBody.create(requestBody, MediaType.get("application/json; charset=utf-8"));
                request = requestBuilder.post(body).build();
            } else {
                request = requestBuilder.get().build();
            }

            log.info("调用远程接口: {} {}", method, url);
            log.debug("请求体: {}", requestBody);

            try (Response response = httpClient.newCall(request).execute()) {
                if (!response.isSuccessful()) {
                    log.error("远程调用失败: HTTP {}", response.code());
                    return BaseResponse.<Object>builder()
                            .success(false)
                            .msg("远程服务调用失败: HTTP " + response.code())
                            .build();
                }

                String responseBody = response.body() != null ? response.body().string() : "";
                log.debug("远程接口响应: {}", responseBody);

                // 解析远程服务返回的BaseResponse
                JSONObject jsonResponse = JSON.parseObject(responseBody);
                return BaseResponse.<Object>builder()
                        .success(jsonResponse.getBooleanValue("success"))
                        .msg(jsonResponse.getString("msg"))
                        .content(jsonResponse.get("content"))
                        .build();

            }
        } catch (IOException e) {
            log.error("调用远程接口异常: {}", e.getMessage(), e);
            return BaseResponse.<Object>builder()
                    .success(false)
                    .msg("远程服务调用异常: " + e.getMessage())
                    .build();
        }
    }
}