package com.landtool.lanbase.modules.terra;

import com.alibaba.excel.context.AnalysisContext;
import com.alibaba.excel.event.AnalysisEventListener;
import com.alibaba.fastjson.JSONObject;
import com.landtool.lanbase.common.utils.HttpUtils;
import com.landtool.lanbase.common.utils.JpinyinUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.CookieStore;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLContexts;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.core.io.ClassPathResource;
import org.springframework.web.util.CookieGenerator;

import java.io.FileInputStream;
import java.io.IOException;
import java.security.KeyManagementException;
import java.security.KeyStore;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.CertificateException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.function.BiConsumer;
import java.util.function.Consumer;

public class GisServiceListener extends AnalysisEventListener<GisService> {

    private String proxyHost = "http://192.168.20.106:8066";


    public CookieStore store;
    public SSLConnectionSocketFactory sslsf;
    public String tgc;
    private String regurl = "http://192.168.20.106:8082/res/ziYuanInsert";

    private String casurl = "https://192.168.20.106:8088/cas/login";

    private String muluUrl = "http://192.168.20.106:8082/res/selectMuLu?id=0";

    private String updateUrl = "http://192.168.20.106:8082/res/resExtBaseMap/insertSelectiveAndUpdate";

    private String themeMapUrl = "http://192.168.20.106:8082/res/ResExtThemeMap/insertSelectiveAndUpdate";


    private String cookieurl = "http://192.168.20.106:8082/manage/ok";

    private String st = "";
    //不包含子图层的注册服务list
    public List<GisService> list = new ArrayList<>();
    //包含子图层的注册服务list
    public List<GisService> finallist = new ArrayList<>();

    public Map<String, Object> resourceclass = new HashMap<>();

    public GisServiceListener(String t, String jsession) throws ClientProtocolException, IOException, KeyStoreException, NoSuchAlgorithmException, CertificateException, KeyManagementException {
        tgc = t;
        resourceclass.put("接口服务", "JKFW");
        resourceclass.put("数据文件", "SJWJ");
        resourceclass.put("业务集成", "YWJC");
        resourceclass.put("基础底图", "KJ_JCDT");
        resourceclass.put("专题地图", "KJ_ZTDT");
        resourceclass.put("空间分析", "KJ_KJFX");
        resourceclass.put("业务图层", "KJ_YWTC");
        resourceclass.put("三维模型", "KJ_SWMX");
        resourceclass.put("三维地形", "KJ_SWDX");
        resourceclass.put("三维影像", "KJ_SWYX");
        DefaultHttpClient cl = new DefaultHttpClient();

        HttpGet httpget = new HttpGet(cookieurl + "?tgc=" + tgc + "&jsession=" + jsession);

        HttpResponse httprep = cl.execute(httpget);
        this.store = cl.getCookieStore();
        KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());
        FileInputStream ins = new FileInputStream(new ClassPathResource("cas.keystore").getFile());
        trustStore.load(ins, "123456".toCharArray());
        javax.net.ssl.SSLContext sslContext = SSLContexts.custom().loadTrustMaterial(trustStore).build();
        sslsf = new SSLConnectionSocketFactory(sslContext, SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);

    }


    private Logger log = LoggerFactory.getLogger(GisServiceListener.class);

    @Override
    public void invoke(GisService data, AnalysisContext context) {
        list.add(data);
        log.info(data.toString());
    }

    @Override
    public void doAfterAllAnalysed(AnalysisContext context) {
        // TODO 调用接口保存数据
        log.info("调用接口保存数据");
        registerService(list);
    }

    /**
     * 注册服务,保存返回资源id
     */
    public void registerService(List<GisService> list) {
        list.forEach(new Consumer<GisService>() {

            @Override
            public void accept(GisService t) {
                List<Map> layers = new ArrayList<>();
                if (t.getRemark().indexOf("arcgis") != -1 && !"基础底图".equals(t.getResourceclass())) {
                    layers = getSubLayerInfo(t.getRemark());
                }

                /* 循环构造子图层并
                 * 调用注册接口
                 */
                if (layers == null || layers.isEmpty()) {
                    if (regService(t)) {
                        if ("基础底图".equals(t.getResourceclass())) {
                            registerMapUrlService(t);
                        } else {
                            registerthemeMap(t);
                        }
                    } else {
                        log.error("注册服务错误");
                    }
                } else {
                    layers.forEach(new Consumer<Map>() {

                        @Override
                        public void accept(Map map) {
                            GisService cloneObj = new GisService();
                            BeanUtils.copyProperties(t, cloneObj);
                            cloneObj.setTitle(map.get("name").toString());
                            cloneObj.setRemark(t.getRemark() + "/" + map.get("id"));
                            finallist.add(cloneObj);
                            if (regService(cloneObj)) {
                                if ("基础底图".equals(t.getResourceclass())) {
                                    registerMapUrlService(cloneObj);
                                } else {
                                    registerthemeMap(cloneObj);
                                }

                            } else {
                                log.error("注册服务错误");
                            }
                        }
                    });


                }


            }

        });

    }


    /**
     * 代理地址,注册入扩展资源
     */
    public boolean registerMapUrlService(GisService t) {
        //生成代理服务地址，构造扩展对象
        layersProxy(t);
        List<Map> list = new ArrayList<>();
        Map<String, Object> map = new HashMap<>();
        map.put("typeandurl", "DYNAMIC");
        map.put("serverurl", t.getProxyUrl());

        if (t.getRemark().indexOf("esri/wmts") > -1) {
            map.put("publishsoft", "天地图");
        } else {
            map.put("publishsoft", "Arcgis");
        }
        map.put("basemaptype", "影像");
        map.put("extMapUrlStr", "DYNAMIC," + t.getProxyUrl() + "," + t.getProxyid() + "," + t.getRemark() + "|");
        map.put("xianshibiliStart", "");
        map.put("xianshibiliEnd", "");
        map.put("resourceid", Integer.valueOf(t.getResourceid()));

        JSONObject json = null;
        try {
            String res = HttpUtils.post(updateUrl, map);
            json = JSONObject.parseObject(res);

        } catch (Exception e) {
            log.error("注册基础底图扩展服务失败");
            e.printStackTrace();
        }
        return json.getInteger("result") == 1 ? true : false;
        //调用更新接口，写入扩展资源表


    }


    public boolean registerthemeMap(GisService t) {
        //生成代理服务地址，构造扩展对象
        layersProxy(t);
        List<Map> list = new ArrayList<>();
        Map<String, Object> map = new HashMap<>();
        map.put("typeandurl", "DYNAMIC");
        map.put("serverurl", t.getProxyUrl());
        map.put("publishsoft", "Arcgis");

        map.put("legendurl", "");
        map.put("extMapUrlStr", "DYNAMIC," + t.getProxyUrl() + "," + t.getProxyid() + "," + t.getRemark() + "|");
        map.put("resourceid", Integer.valueOf(t.getResourceid()));
        map.put("type", "ArcMap");
        map.put("oldserverurl", t.getRemark());
        map.put("serverurl", t.getProxyUrl());
        map.put("espproxy", 1);
        String result = "";
        try {
            result = HttpUtils.post(themeMapUrl, map);


        } catch (Exception e) {
            log.error("注册专题地图扩展服务失败");
            e.printStackTrace();
        }
        return Integer.valueOf(result) == 1 ? true : false;
        //调用更新接口，写入扩展资源表


    }


    public List<Map> getSubLayerInfo(String gisUrl) {
        List<Map> list = new ArrayList<>();
        List<Map> finallist = new ArrayList<>();
        try {
            String res = HttpUtils.get(gisUrl + "/layers?f=json");
            JSONObject json = JSONObject.parseObject(res);
            list = (List<Map>) json.get("layers");
            list.forEach(new Consumer<Map>() {
                @Override
                public void accept(Map t) {
                    if ("Feature Layer".equals(t.get("type"))) {
                        finallist.add(t);
                    }

                }
            });
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return finallist;

    }

    public Map getMulu(int id, String catlogtitle) {


        List<Map> list = new ArrayList<>();
        Map<String, Object> params = new HashMap<>();
        params.put("id", id);

        try {
            CookieGenerator cg = new CookieGenerator();


            CloseableHttpClient httpclient = HttpClientBuilder.create().setDefaultCookieStore(store).setSSLSocketFactory(sslsf).build();

            HttpGet httpget = new HttpGet(muluUrl);

            CloseableHttpResponse httprep = httpclient.execute(httpget);
            HttpEntity entity = httprep.getEntity();
            System.out.println("----------------------------------------------------");
            System.out.println(httprep.getStatusLine());
            String res = "";
            if (entity != null) {

                res = EntityUtils.toString(entity);
                System.out.println(res);
            }

            //	String  res=HttpUtils.get(muluUrl);


            list = JSONObject.parseArray(res, Map.class);
        } catch (Exception e) {

            e.printStackTrace();
        }
        for (Map t : list) {
            if (catlogtitle.equals(t.get("name"))) {
                return t;
            }
        }
        return null;


    }

    //http://www.nmsmp.com:8082/res/selectMuLu
    public boolean regService(GisService t) {
        List<Map> list = new ArrayList<>();
        Map<String, Object> map = new HashMap<>();
        map.put("title", t.getTitle());
        map.put("abbreviation", JpinyinUtils.changeToGetShortPinYin((String) t.getTitle()));
        map.put("resourceclass", resourceclass.get(t.getResourceclass()));
        Map<String, Object> catalog = getMulu(0, t.getCatalog());
        map.put("catlogid", catalog.get("id"));
        map.put("catlogcode", catalog.get("code"));
        map.put("catlogtitle", catalog.get("name"));
        map.put("imgurl", "");
        map.put("datasources", "个人发布");
        //map.put("productiontime", null);
        map.put("pubunitid", 4);
        map.put("sharprotocol", "单位内公开");
        //map.put("administrativeid", null);
        //map.put("administrativename", null);
        //map.put("updatetimes", null);
        map.put("createuserid", 1939);
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        map.put("pubdate", sdf.format(new Date()));
        //map.put("txtTags",  null);
        map.put("keywords", t.getKeywords());
        //map.put("securitylev", null);
        map.put("remark", t.getRemark());
        map.put("description", t.getDescription());
        map.put("ticket", st);
        JSONObject json = null;
        try {

            CloseableHttpClient httpclient = HttpClientBuilder.create().setDefaultCookieStore(store).setSSLSocketFactory(sslsf).build();

            HttpPost post = new HttpPost(regurl);
            List<NameValuePair> parameters = new ArrayList<NameValuePair>();
            map.forEach(new BiConsumer<String, Object>() {

                @Override
                public void accept(String t, Object u) {
                    parameters.add(new BasicNameValuePair(t, String.valueOf(u)));

                }
            });
            UrlEncodedFormEntity entit = new UrlEncodedFormEntity(parameters, "utf-8");
            post.setEntity(entit);
            CloseableHttpResponse httprep = httpclient.execute(post);
            HttpEntity entity = httprep.getEntity();
            System.out.println("----------------------------------------------------");
            System.out.println(httprep.getStatusLine());
            String res = "";
            if (entity != null) {

                res = EntityUtils.toString(entity);
                System.out.println(res);
            }

            //	String  res=HttpUtils.get(muluUrl);


            json = JSONObject.parseObject(res);
            t.setResourceid(json.getString("ziyuanId"));
        } catch (Exception e) {

            e.printStackTrace();
        }
        return json.getInteger("result") == 1 ? true : false;

    }


    public void layersProxy(GisService t) {
        Map<String, Object> map = new HashMap<>();
        map.put("zyid", Integer.valueOf(t.getResourceid()));
        map.put("serverUrl", t.getRemark());
        map.put("contextPath", "");
        map.put("urlid", null);
        map.put("isPublic", 1);
        map.put("suffix", 0);
        map.put("fromsys", "HYJGPT");
        map.put("servername", t.getTitle());

        JSONObject json = getProxyUrl(map);
        t.setProxyUrl(json.getString("proxyurl"));
        t.setProxyid(json.getInteger("id"));

    }

    public JSONObject getProxyUrl(Map<String, Object> map) {
        JSONObject json = new JSONObject();
        try {
            String res = com.landtool.lanbase.common.utils.HttpUtils.get(proxyHost + "/serverRegister/addArcGisServer", map);
            json = JSONObject.parseObject(res);

        } catch (Exception e) {

            e.printStackTrace();
        }
        return json;

    }
}