package com.gs.xiaomi.service;


import com.gs.xiaomi.dto.BizDocumentResult;
import com.gs.xiaomi.dto.ZfmWsApiRequest;
import com.gs.xiaomi.util.SoapXmlBuilder;
import okhttp3.*;
import org.springframework.stereotype.Service;

import javax.xml.bind.JAXBContext;
import javax.xml.bind.Unmarshaller;
import java.io.StringReader;

@Service
public class SoapApiService {

    private static final OkHttpClient client = new OkHttpClient.Builder().build();

    public BizDocumentResult callAndParse(String url, ZfmWsApiRequest request) throws Exception {
        String soapXml = SoapXmlBuilder.build(request);
        Response response = sendRequest(url, soapXml);

        if (response.isSuccessful() && response.body() != null) {
            String bodyStr = response.body().string();

            String innerXml = extractCdata(bodyStr);
            if (innerXml == null) throw new RuntimeException("No CDATA <document> found in response");

            String decodedXml = decodeXmlEntities(innerXml);

            JAXBContext context = JAXBContext.newInstance(BizDocumentResult.class);
            Unmarshaller unmarshaller = context.createUnmarshaller();
            return (BizDocumentResult) unmarshaller.unmarshal(new StringReader(decodedXml));
        } else {
            throw new RuntimeException("SOAP request failed: " + response.code() + " - " + response.message());
        }
    }

    private Response sendRequest(String url, String soapXml) throws Exception {
        MediaType mediaType = MediaType.parse("application/xml");
        RequestBody body = RequestBody.create(mediaType, soapXml);

        Request request = new Request.Builder()
                .url(url)
                .method("POST", body)
//                .addHeader("User-Agent", "Apifox/1.0.0 (https://apifox.com)")
                .addHeader("Content-Type", "application/xml")
                .addHeader("Authorization", "Basic UkZDWkpYSUFPQlU6cHBCOVIhSGU=")
                .addHeader("Accept", "*/*")
                .addHeader("Host", "mipoq.p.mi.com")
                .addHeader("Connection", "keep-alive")
//                .addHeader("Cookie", "saplb_*=(J2EE4281420)4281450; MYSAPSSO2=AjExMDAgABJwb3J0YWw6UkZDWkpYSUFPQlWIAAdkZWZhdWx0AQALUkZDWkpYSUFPQlUCAAMwMDADAANQT1EEAAwyMDI1MDQwOTAwMTcFAAQAAAAICgALUkZDWkpYSUFPQlX%2FAQUwggEBBgkqhkiG9w0BBwKggfMwgfACAQExCzAJBgUrDgMCGgUAMAsGCSqGSIb3DQEHATGB0DCBzQIBATAiMB0xDDAKBgNVBAMTA1BPUTENMAsGA1UECxMESjJFRQIBADAJBgUrDgMCGgUAoF0wGAYJKoZIhvcNAQkDMQsGCSqGSIb3DQEHATAcBgkqhkiG9w0BCQUxDxcNMjUwNDA5MDAxNzU2WjAjBgkqhkiG9w0BCQQxFgQUvvJ1HSnOLckboGYaMR9Wiaem6z4wCQYHKoZIzjgEAwQvMC0CFQDKLPrpUC19VM2gcslWaHAnh7dfxQIUNs2dTxwGcKdNU%2FdAQPs4f08yaw4%3D; JSESSIONID=_6bPldDq9mFJPXEd11bc-GvrWMAVlgFqVEEA_SAPF-GrpRbcuqxMK_gShBYGdmdp; JSESSIONMARKID=QPmRVwktCDxMazp0fUbEMC40LWvmuqOMUbIGpUQQA")
                .build();

        return client.newCall(request).execute();
    }

    private String extractCdata(String xml) {
        int cdataStart = xml.indexOf("<![CDATA[");
        int cdataEnd = xml.indexOf("]]>", cdataStart);
        if (cdataStart == -1 || cdataEnd == -1) return null;
        return xml.substring(cdataStart + 9, cdataEnd).trim();
    }

    private String decodeXmlEntities(String xml) {
        return xml.replace("&#60;", "<")
                .replace("&#62;", ">")
                .replace("&lt;", "<")
                .replace("&gt;", ">")
                .replace("&amp;", "&");
    }
}