package com.ibeetl.admin.console.service;


import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.ibeetl.admin.console.dao.XzxElectronicFenceDao;
import com.ibeetl.admin.console.dao.XzxPartnerFenceDao;
import com.ibeetl.admin.console.model.AreaModel;
import com.ibeetl.admin.console.model.XzxElectronicFenceModel;
import com.ibeetl.admin.console.model.XzxPartnerFenceModel;
import com.ibeetl.admin.console.util.HttpClientUtils;
import com.ibeetl.admin.core.entity.XzxCityPartner;
import com.ibeetl.admin.core.entity.XzxElectronicFence;
import com.ibeetl.admin.core.service.CoreBaseService;
import com.ibeetl.admin.core.util.PlatformException;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.util.EntityUtils;
import org.beetl.sql.core.engine.PageQuery;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


/**
 * XzxElectronicFence Service
 */

@Service
@Transactional
public class XzxElectronicFenceService extends CoreBaseService<XzxElectronicFence>{

    @Autowired private XzxElectronicFenceDao xzxElectronicFenceDao;
    @Autowired private XzxPartnerFenceDao partnerFenceDao;
    @Autowired
    XzxCityPartnerService service;
    public PageQuery<XzxElectronicFence>queryByCondition(PageQuery query){
        PageQuery ret =  xzxElectronicFenceDao.queryByCondition(query);
        queryListAfter(ret.getList());
        return ret;
    }

    public List<String> queryTownListByArea(String townCode,String eleId){
        return xzxElectronicFenceDao.queryTownListByArea(townCode,eleId);
    }
    public boolean queryPartnerAreaIds(String partnerId,String townId){
        boolean flag = false;
        int num = xzxElectronicFenceDao.queryPartnerAreaIds(partnerId,townId);
        if(num>0){
            flag = true;
        }
        return flag;
    }

    public String queryAreaTownId(String keyword){
        return xzxElectronicFenceDao.queryAreaTownId(keyword);
    }
    public List<XzxElectronicFenceModel> queryFenceList(XzxElectronicFenceModel model){
        List<String> partnerIdList = service.queryPartnerByCurrent();
        model.setPartnerIdList(partnerIdList);
        List<XzxElectronicFenceModel> list =  xzxElectronicFenceDao.queryFenceList(model);
        for (XzxElectronicFenceModel model1:list) {
            String keyword = model1.getKeyword();
            if(null!=keyword&&!"".equals(keyword)) {
                AreaModel m = new AreaModel();
                m.setName(keyword.trim());
                AreaModel map = service.queryAreaLongiLati(m);
                if(map!=null){
                    model1.setLongitude(map.getLongitude());
                    model1.setLatitude(map.getLatitude());
                }

            }else{
                String longLatiArr = model1.getLongLatiArr();
                String longi="";
                String lati="";
                List<Map<String,Object>> longlaL = new ArrayList<>();
                if(null!=longLatiArr&&!"".equals(longLatiArr)){
                    String[] liststr = longLatiArr.split(";");
                    //List<Object>  = JSON.parseArray(longLatiArr);
                    for (String str : liststr) {
                        //Map<String, Object> ret = (Map<String, Object>) object;//取出list里面的值转为map
                        Map<String, Object> ageMap = new HashMap<String, Object>();
                        //String[] objStrs = object.split(",");
                        String[] stt = str.split(",");
                        longi = stt[0];
                        lati = stt[1];
                        ageMap.put("longitude",longi);
                        ageMap.put("latitude",lati);
                        longlaL.add(ageMap);
                        model1.setLongitude(longi);
                        model1.setLatitude(lati);
                        //break;
                    }
                    String jsonString = JSON.toJSONString(longlaL);
                    model1.setLongLatiArr(jsonString);
                }
            }

        }
        return list;
    }
    public XzxElectronicFence queryElectronic(XzxElectronicFenceModel info){
        return xzxElectronicFenceDao.queryElectronic(info);
    }
    public void batchDelXzxElectronicFence(List<Long> ids){
        try {
            xzxElectronicFenceDao.batchDelXzxElectronicFenceByIds(ids);
        } catch (Exception e) {
            throw new PlatformException("批量删除XzxElectronicFence失败", e);
        }
    }

    public String queryLongiLatiForTownName(String key,String location,String longiLatiStr){
        Map<String,String> map = new HashMap<>();
        String district="";
        if(null!=longiLatiStr){
            map.put("location",longiLatiStr);
            map.put("batch","true");
        }else{
            map.put("location",location);
        }
        if(null!=key&&!"".equals(key)){
            map.put("key",key);
        }else{
            map.put("key","a64d28b2e036f4688b05916ef321b17d");
        }

        String url ="https://restapi.amap.com/v3/geocode/regeo";
        String result = HttpClientUtils.doGet(url,map);
        Map maps = (Map) JSON.parse(result);
        String infocode = maps.get("infocode").toString();
        if(infocode.equals("10000")){
            System.out.println(maps);
            String regeocode="";
            if(null!=maps.get("regeocodes")){
                List<Object> regeocodes = (List)maps.get("regeocodes");
                //regeocode=checkAddressIp(regeocodes);
                 district = checkAddressIp(regeocodes);
            }else{
                regeocode = maps.get("regeocode").toString();
                Map maps1 = (Map) JSON.parse(regeocode);
                String addressComponent = maps1.get("addressComponent").toString();
                Map maps2 = (Map) JSON.parse(addressComponent);
                district = maps2.get("district").toString();
            }
        }
        return district;
    }

    private String checkAddressIp(List<Object> regeocodes){
        StringBuffer location=new StringBuffer();
        String address="";
        for (int i=0; i<regeocodes.size();i++) {
            Map maps1 = (Map) JSON.parse(regeocodes.get(i).toString());
             if(null!=address&&!"".equals(address)){
                 String component = maps1.get("addressComponent").toString();
                 Map mapsx = (Map) JSON.parse(component);
                 String addressNew= mapsx.get("district").toString();
                 if(address.equals(addressNew)){
                     continue;
                 }else{
                     location.append(",").append(i+1).append("_").append(address);
                 }
             }else{
                 String addressComponent = maps1.get("addressComponent").toString();
                 Map maps2 = (Map) JSON.parse(addressComponent);
                 address= maps2.get("district").toString();
                 location.append(i+1).append("_").append(address);
             }

        }
        return location.toString();
    }
    public String deleteGDFence(XzxElectronicFence info,String url,XzxCityPartner partner){
        String uri = url+"?key="+partner.getPartnerKey()+"&gid="+info.getGid()+"&method=delete";
        String result = HttpClientUtils.doPost(uri,new HashMap<>());
        return result;
    }
    public String updateGDFence(XzxElectronicFence info, XzxPartnerFenceModel pfInfo,String longiLatiStr,String gid){
        XzxCityPartner partner = service.queryById(pfInfo.getPartnerId());
        String key = partner.getPartnerKey();

         String uri = "https://restapi.amap.com/v4/geofence/meta?key="+key+"&gid="+gid+"&method=patch";
        System.out.println("uri===="+uri);
         HttpPost httpPost = new HttpPost(uri);
        Map<String,String> map = new HashMap<>();;
        map.put("name",info.getFenceName());
        if(null!=longiLatiStr&&!"".equals(longiLatiStr)){
            map.put("points",longiLatiStr);
        }else{
            map.put("center",info.getLongitude()+","+info.getLatitude());
            map.put("radius",String.valueOf(info.getRadius()));
        }
        //map.put("enable","true");
        map.put("valid_time","2054-12-30");
        map.put("repeat","Mon,Tues,Wed,Thur,Fri,Sat,Sun");
        //map.put("time","00:00,11:59;13:00,20:59");
        map.put("desc",info.getFenceName());
        map.put("alert_condition","enter");
        String  param= JSON.toJSONString(map);
        System.out.println(param);
        //String result = HttpClientUtils.doPost(uri,map);
        String result = HttpClientUtils.doPost(uri,param, ContentType.APPLICATION_JSON);
        //String result = HttpClientUtils.doPost(uri,map);
        return result;
    }
    public List<String>  queryODByArea(String townCode){
        return xzxElectronicFenceDao.queryODByArea(townCode);
    }
    public String createGDFence(XzxElectronicFence info, XzxPartnerFenceModel pfInfo,String url,String longiLatiStr){


        XzxCityPartner partner = service.queryById(pfInfo.getPartnerId());
        String key = partner.getPartnerKey();
        url =url+key;
        HttpPost httpPost = new HttpPost(url);
        Map<String,String> map = new HashMap<>();;
        map.put("name",info.getFenceName());
        if(null!=longiLatiStr&&!"".equals(longiLatiStr)){
            map.put("points",longiLatiStr);
        }else{
            map.put("center",info.getLongitude()+","+info.getLatitude());
            map.put("radius",String.valueOf(info.getRadius()));
        }


        map.put("enable","true");
        map.put("valid_time","2054-12-30");
        map.put("repeat","Mon,Tues,Wed,Thur,Fri,Sat,Sun");
        //map.put("time","00:00,11:59;13:00,20:59");
        map.put("desc",info.getFenceName());
        map.put("alert_condition","enter;leave");
        System.out.println(map);
        String  param= JSON.toJSONString(map);
        String result = HttpClientUtils.doPost(url,param, ContentType.APPLICATION_JSON);

        return result;
    }

}