package com.changhong.epc.zuul.filter.version;

import com.changhong.epc.constter.base.Context;
import com.changhong.epc.rely.api.epc.tenant.NormApi;
import com.changhong.epc.rely.api.tool.FilterTool;
import com.iemsoft.framework.cloud.core.tools.JSONTool;
import com.iemsoft.framework.cloud.core.tools.ObjectUtil;
import com.iemsoft.framework.cloud.core.tools.SpringUtil;
import com.iemsoft.framework.cloud.zuul.tool.RequestContextTool;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.http.HttpServletRequestWrapper;
import com.netflix.zuul.http.ServletInputStreamWrapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.math.NumberUtils;
import org.springframework.util.StreamUtils;

import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;
import java.util.*;
import java.util.stream.Collectors;

@Slf4j
public class NormVersion implements Version{

    @Override
    public String getUpdateUrl() {
        return "epc/epc-tenant/tenant/normType/insert";
    }

    @Override
    public String getUpdateKey() {
        return getUpdateKey(RequestContextTool.getCurrentContext().getRequest());
    }

    protected String getUpdateKey(HttpServletRequest request) {
        FilterTool.FILTER_TYPE.get(FilterTool.FilterType.PRIVATE).filter(request);
        Integer cId = getCid(request);
        String key = String.format("version_norm_%s_%s_%s"
                , Context.getTenantId()
                , Context.getCompanyId()
                , cId);
        return key;
    }

    private Integer getCid(HttpServletRequest request) {
        RequestContext context = RequestContextTool.getCurrentContext();

        try (InputStream in = context.getRequest().getInputStream()) {
            String body = StreamUtils.copyToString(in, Charset.forName("UTF-8"));

            final byte[] reqBodyBytes = body.getBytes();
            context.setRequest(new HttpServletRequestWrapper(context.getRequest()) {
                @Override
                public ServletInputStream getInputStream(){
                    return new ServletInputStreamWrapper(reqBodyBytes);
                }

                @Override
                public int getContentLength() {
                    return reqBodyBytes.length;
                }

                @Override
                public long getContentLengthLong() {
                    return reqBodyBytes.length;
                }
            });
            Map<String, Object> bodyObj = JSONTool.toObj(body, Map.class);
            if(ObjectUtil.empty(bodyObj) || ObjectUtil.empty(bodyObj.get("suppStanderExtend"))){
                return null;
            }
            List<Map<String, Object>> suppStanderExtend = (List<Map<String, Object>>)bodyObj.get("suppStanderExtend");
            return NumberUtils.createInteger(Objects.toString(suppStanderExtend.get(0).get("ctId"), "0"));
        } catch (IOException e) {
            return null;
        }
    }

    @Override
    public String getCacheKey(HttpServletRequest request, String key) {
        String cacheKey = String.format("version_norm_%s_%s_%s"
                , Context.getTenantId()
                , Context.getCompanyId()
                , key);
        return cacheKey;
    }


    @Override
    public Set<String> getKeys() {
        return SpringUtil.getBean(NormApi.class).getAllNormCostType()
                .stream()
                .map(costType -> Objects.toString(costType.getId(), "")).collect(Collectors.toSet());
    }

}