package jnpf.wrapper;

import cn.dev33.satoken.context.SaHolder;
import cn.hutool.core.net.url.UrlQuery;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import jnpf.constant.GlobalConst;
import jnpf.handler.IRestHandler;
import jnpf.util.StringUtil;
import lombok.Getter;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.MediaType;
import org.springframework.util.StreamUtils;
import org.springframework.util.StringUtils;

import jakarta.servlet.ReadListener;
import jakarta.servlet.ServletInputStream;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletRequestWrapper;
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.util.*;
import java.util.stream.Collectors;

/**
 * Request封装
 * 处理类型：
 * application/json
 * application/x-www-form-urlencoded
 */
@Slf4j
public class MyRequestWrapper extends HttpServletRequestWrapper {

    protected Map<String, String[]> paramHashValues;
    @Getter
    @Setter
    protected String requestBody = null;
    protected HttpServletRequest req;

    private final List<IRestHandler> handlers;

    private final String[] EMPTY_ARRAY = new String[0];

    /**
     * 是否需要处理Header, Body, Form
     */
    private boolean supportHeader, supportBody, supportParameter;

    public MyRequestWrapper(HttpServletRequest request, List<IRestHandler> handlers) throws IOException {
        super(request);
        this.req = request;
        this.handlers = handlers == null ? Collections.emptyList() : handlers;
        if(!handlers.isEmpty()){
            try {
                if (isJsonBodyRequest()) {
                    if(this.handlers.stream().anyMatch(IRestHandler::supportBodyJson)) {
                        processBody();
                    }
                } else if (isParameterRequest()) {
                    if(this.handlers.stream().anyMatch(IRestHandler::supportParameter)) {
                        processParameter();
                    }
                    if(this.handlers.stream().anyMatch(IRestHandler::supportBodyJson)) {
                        processFormBody();
                    }
                }
            } catch (Exception e){
                log.error("请求解析失败：{}", SaHolder.getRequest().getRequestPath());
                throw e;
            }
        }
    }

    public void wrapperRequestData() throws IOException {
        try {
            if (isJsonBodyRequest()) {
                processBody();
            } else if (isParameterRequest()) {
                processParameter();
                processFormBody();
            }
        } catch (Exception e){
            log.error("请求解析失败：{}", SaHolder.getRequest().getRequestPath());
            throw e;
        }
    }

    private void processBody() throws IOException {
        List<IRestHandler> bodyHandlers = this.handlers.stream().filter(IRestHandler::supportBodyJson).collect(Collectors.toList());
        this.requestBody = convertInputStreamToString(req.getInputStream());
        if (StringUtil.isNotEmpty(this.requestBody)) {
            JSON jsonData = (JSON) JSON.parse(this.requestBody);
            for (IRestHandler bodyHandler : bodyHandlers) {
                jsonData = bodyHandler.initBodyJson(jsonData);
            }
            requestBody = jsonData.toJSONString();
            supportBody = true;
        }
    }

    private void processParameter(){
        List<IRestHandler> parameterHandlers = this.handlers.stream().filter(IRestHandler::supportParameter).collect(Collectors.toList());
        paramHashValues = new HashMap<>();
        paramHashValues.putAll(req.getParameterMap());
                    /*
                    //解除锁定直接添加
                    if(paramHashValues instanceof ParameterMap){
                        ((ParameterMap<String, String[]>) paramHashValues).setLocked(false);
                    }
                    */
        parameterHandlers.forEach(h -> paramHashValues = h.initParameter(paramHashValues));
        supportParameter = true;
    }
    private void processFormBody() throws IOException {
        List<IRestHandler> bodyHandlers = this.handlers.stream().filter(IRestHandler::supportBodyJson).collect(Collectors.toList());
        this.requestBody = convertInputStreamToString(req.getInputStream());
        if(StringUtil.isNotEmpty(this.requestBody)){
            Map<CharSequence, CharSequence> uriToListToMap = new UrlQuery().parse(this.requestBody, GlobalConst.DEFAULT_CHARSET).getQueryMap();
            requestBody = JSONObject.toJSONString(uriToListToMap);
        }
        if (StringUtil.isNotEmpty(this.requestBody)) {
            JSON jsonData = (JSON) JSON.parse(this.requestBody);
            for (IRestHandler bodyHandler : bodyHandlers) {
                jsonData = bodyHandler.initBodyJson(jsonData);
            }
            Map<String, Object> formJson = (JSONObject) jsonData;
            UrlQuery urlQuery = new UrlQuery();
            for (Map.Entry<String, Object> entry : formJson.entrySet()) {
                urlQuery.add(entry.getKey(), entry.getValue());
            }
            requestBody = urlQuery.build(GlobalConst.DEFAULT_CHARSET);
            supportBody = true;
        }
    }

    @Override
    public BufferedReader getReader() throws IOException {
        if(supportBody){
            return new BufferedReader(new StringReader(requestBody));
        }else{
            return super.getReader();
        }
    }

    @Override
    public ServletInputStream getInputStream() throws IOException {
        if(supportBody){
            return new ServletInputStream() {
                private InputStream in = new ByteArrayInputStream(
                        requestBody.getBytes(req.getCharacterEncoding()));
                @Override
                public int read() throws IOException {
                    return in.read();
                }
                @Override
                public boolean isFinished() {
                    return false;
                }
                @Override
                public boolean isReady() {
                    return false;
                }
                @Override
                public void setReadListener(ReadListener readListener) {

                }
            };
        }else {
            return super.getInputStream();
        }
    }

    @Override
    public Map<String, String[]> getParameterMap() {
        if(supportParameter){
            return this.paramHashValues;
        }else {
            return super.getParameterMap();
        }
    }

    @Override
    public String getParameter(String name) {
        if(supportParameter){
            String[] parameter = this.paramHashValues.getOrDefault(name, EMPTY_ARRAY);
            return parameter.length == 0 ? null: parameter[0];
        }else {
            return super.getParameter(name);
        }
    }

    @Override
    public String[] getParameterValues(String name) {
        if(supportParameter){
            return this.paramHashValues.get(name);
        }else {
            return super.getParameterValues(name);
        }
    }

    @Override
    public Enumeration<String> getParameterNames() {
        if(supportParameter){
            return Collections.enumeration(this.paramHashValues.keySet());
        }else {
            return super.getParameterNames();
        }
    }

    public void addAllParameters(Map<String, Object> otherParams) {// 增加多个参数
        for (Map.Entry<String, Object> entry : otherParams.entrySet()) {
            addParameter(entry.getKey(), entry.getValue());
        }
    }


    public void addParameter(String name, Object value) {// 增加参数
        if (value != null && paramHashValues != null) {
            if (value instanceof String[]) {
                paramHashValues.put(name, (String[]) value);
            } else if (value instanceof String) {
                paramHashValues.put(name, new String[]{(String) value});
            } else {
                paramHashValues.put(name, new String[]{String.valueOf(value)});
            }
        }
    }

    protected boolean isParameterRequest(){
        String contentType = this.req.getContentType();
        if(StringUtil.isNotEmpty(contentType)) {
            if (StringUtils.substringMatch(contentType, 0, MediaType.APPLICATION_FORM_URLENCODED_VALUE)) {
                return true;
            }
        }
        return false;
    }

    protected boolean isJsonBodyRequest(){
        String contentType = this.req.getContentType();
        if(StringUtil.isNotEmpty(contentType)) {
            if (StringUtils.substringMatch(contentType, 0, MediaType.APPLICATION_JSON_VALUE)) {
                return true;
            }
        }
        return false;
    }

    protected String convertInputStreamToString(InputStream inputStream) throws IOException {
        return StreamUtils.copyToString(inputStream, GlobalConst.DEFAULT_CHARSET);
    }
}