package com.xzx.gc.order.service;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.constant.OrderEnum;
import com.xzx.gc.entity.CityPartner;
import com.xzx.gc.entity.CoreUserRole;
import com.xzx.gc.entity.PartnerFence;
import com.xzx.gc.model.admin.PartnerAccountModel;
import com.xzx.gc.model.admin.XzxCityPartnerModel;
import com.xzx.gc.model.admin.XzxElectronicFenceModel;
import com.xzx.gc.order.mapper.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

@Service
@Transactional
public class PartnerFenceService {

    @Autowired
    CoreUserRoleMapper coreUserRoleMapper;

    @Autowired
    private SysMessageMapper sysMessageMapper;
    @Autowired
    private PartnerFenceMapper partnerFenceMapper;
    @Autowired
    private CityPartnerService cityPartnerService;

    @Autowired
    private PartnerAccountMapper partnerAccountMapper;

    @Autowired
    private AccountMapper accountMapper;
    
    
    public CityPartner queryPartnerIds(String fenceId){
        List<String> list = partnerFenceMapper.queryPartnerIds(fenceId);
        if(CollUtil.isNotEmpty(list)){
            CityPartner  partner = cityPartnerService.queryPartnerById(Long.parseLong(list.get(0)));
            return partner;
        }else{
            return null;
        }
    }

    /**
     * 根据围栏查找合伙人
     * @param fenceId
     * @return
     */
    public String findPartnerIdByFenceId(String fenceId){
        if(StrUtil.isNotBlank(fenceId)) {
            List<String> list = partnerFenceMapper.queryPartnerIds(fenceId);
            if (CollUtil.isNotEmpty(list)) {
                return list.get(0);
            }
        }
        return null;
    }



    public void updateByFenceId(PartnerFence pfInfo){
        partnerFenceMapper.updateByFenceId(pfInfo);
    }

    public void deleteByFenceId(String id){
        XzxElectronicFenceModel model = new XzxElectronicFenceModel();
        model.setId(Integer.parseInt(id));
        partnerFenceMapper.deleteByFenceId(model);
    }

    public Map<String,Object> queryElectronicFence(XzxCityPartnerModel model){
        List<String> partnerIdList= cityPartnerService.queryPartnerByCurrent();
        model.setPartnerIdList(partnerIdList);
        Map<String,Object> map = new HashMap<>();

        if(null!=model.getStartTime()&&!"".equals(model.getStartTime())){
            model.setStartTime(model.getStartTime()+" 00:00:00");
        }
        if(null!=model.getEndTime()&&!"".equals(model.getEndTime())){
            model.setEndTime(model.getEndTime()+" 23:59:59");
        }
        PageHelper.startPage(model.getPage(),model.getLimit());
        List<XzxCityPartnerModel>  list = partnerFenceMapper.queryElectronicFencePage(model);
        for (XzxCityPartnerModel model1:list) {
            String longLatiArr = model1.getLongLatiArr();
            String longi="";
            String lati="";

            if(null!=longLatiArr&&!"".equals(longLatiArr)){
                String[] objects = longLatiArr.split(";");
                List<Map<String,Object>> llarr = new ArrayList<>();
                for (String object : objects) {
                    Map<String, Object> ageMap = new HashMap<String, Object>();
                    String[] objStrs = object.split(",");
                    longi = objStrs[0];
                    lati = objStrs[1];
                    ageMap.put("longitude",longi);
                    ageMap.put("latitude",lati);
                    llarr.add(ageMap);
                    model1.setLongitude(longi);
                    model1.setLatitude(lati);
                    //break;
                }
                String jsonString = JSON.toJSONString(llarr);
                model1.setLongLatiArr(jsonString);
            }
        }
        PageInfo<XzxCityPartnerModel> pageInfo=new PageInfo<>(list);
        map.put("count",pageInfo.getTotal());
        map.put("code",0);
        map.put("data",pageInfo.getList());
        return map;
    }

    public boolean save(PartnerFence pfInfo) {
        return partnerFenceMapper.insertSelective(pfInfo)>0?true:false;
    }


    /**
     * 根据合伙人id查询围栏id集合
     * @param partnerId
     * @return
     */
    public List<String> findFences(String partnerId){
        PartnerFence partnerFence=new PartnerFence();
        partnerFence.setPartnerId(partnerId);
        List<PartnerFence> select = partnerFenceMapper.select(partnerFence);
        List<String> collect = select.stream().map(x -> x.getFenceId()).distinct().collect(Collectors.toList());
        return collect;
    }
}