package com.ibeetl.admin.console.service;


import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.ibeetl.admin.console.dao.*;
import com.ibeetl.admin.console.model.PartnerAccountModel;
import com.ibeetl.admin.console.model.XzxCityPartnerModel;
import com.ibeetl.admin.console.model.XzxElectronicFenceModel;
import com.ibeetl.admin.console.model.XzxPartnerFenceModel;
import com.ibeetl.admin.core.dao.CoreUserRoleDao;
import com.ibeetl.admin.core.entity.CoreUserRole;
import com.ibeetl.admin.core.entity.XzxCityPartner;
import com.ibeetl.admin.core.entity.XzxPartnerFence;
import com.ibeetl.admin.core.entity.XzxUserOtherInfo;
import com.ibeetl.admin.core.service.CoreBaseService;
import com.ibeetl.admin.core.util.PlatformException;
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.text.SimpleDateFormat;
import java.util.*;


/**
 * XzxPartnerFence Service
 */

@Service
@Transactional
public class XzxPartnerFenceService extends CoreBaseService<XzxPartnerFence>{

    @Autowired
    private XzxPartnerFenceDao xzxPartnerFenceDao;
    @Autowired
    private XzxCityPartnerDao xzxCityPartnerDao;
    @Autowired
    private XzxCityPartnerService cityPartnerService;
    @Autowired
    SettingConsoleDao settingConsoleDao;
    @Autowired
    PayConsoleDao payDao;
    @Autowired
    CuserConsoleDao dao;
    @Autowired
    CoreUserRoleDao roleDao;
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    public PageQuery<XzxPartnerFence>queryByCondition(PageQuery query){
        PageQuery ret =  xzxPartnerFenceDao.queryByCondition(query);
        queryListAfter(ret.getList());
        return ret;
    }

    public void updateByFenceId(XzxPartnerFence pfInfo){
        xzxPartnerFenceDao.updateByFenceId(pfInfo);
    }
    public void batchDelXzxPartnerFence(List<Long> ids){
        try {
            xzxPartnerFenceDao.batchDelXzxPartnerFenceByIds(ids);
        } catch (Exception e) {
            throw new PlatformException("批量删除XzxPartnerFence失败", e);
        }
    }

    public void saveAllPfInfo(List<XzxPartnerFenceModel> list){
        xzxPartnerFenceDao.saveAllPfInfo(list);
    }
    public void deleteByPartnerId(String partnerId){
        xzxPartnerFenceDao.deleteByPartnerId(partnerId);
    }
    public XzxCityPartner queryPartnerIds(String fenceId){
        List<String> list = xzxPartnerFenceDao.queryPartnerIds(fenceId);
        if(list.size()>0){
            XzxCityPartner partner = xzxCityPartnerDao.queryPartnerById(Long.parseLong(list.get(0).toString()));
            return partner;
        }else{
            return null;
        }
    }
    public void deleteByFenceId(String id){
        XzxElectronicFenceModel model = new XzxElectronicFenceModel();
        model.setId(Integer.parseInt(id));
        xzxPartnerFenceDao.deleteByFenceId(model);
    }
    public void addAccountInfo(String mobilePhone,String userId,String accountNo,Long id,Long roleId,Long orgId){
        // 添加账号表
        Map<String,Object> setMap = new HashMap<>();
        String value = "0";
        dao.addCuserAccountRole(accountNo, mobilePhone, userId,value);

        CoreUserRole coreUserRole = new CoreUserRole();
        coreUserRole.setCreateTime(new Date());
        if(null!=roleId){
            coreUserRole.setRoleId(roleId);
        }else{
            coreUserRole.setRoleId(Long.parseLong("180"));
            PartnerAccountModel model = new PartnerAccountModel();
            model.setUserId(userId);
            model.setAccount(accountNo);
            model.setUpdateTime(sdf.format(new Date()));
            model.setPartnerId(id+"");
            dao.addPartnerAccount(model);
        }
            coreUserRole.setOrgId(Long.parseLong("9"));
        //String uId = userId.substring(userId.length()-6,userId.length());
        //coreUserRole.setUserId(Long.parseLong(uId));
        coreUserRole.setUserId(id);
        roleDao.insert(coreUserRole);

        //写入消息列表中
        String message = "新建合伙人成功,您的账号为："+accountNo+"，初始密码为：888888";
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        payDao.insertMessage(message,userId,"","1","新建合伙人",sdf.format(new Date()));


    }
    public void deleteByElectronicId(XzxElectronicFenceModel model){
        xzxPartnerFenceDao.deleteByFenceId(model);
    }

    public void addAccountByPackage(String mobilePhone,String userId,String accountNo,Long id,Long roleId){
        // 添加账号表
        Map<String,Object> setMap = new HashMap<>();
        String value = "0";
        dao.addCuserAccountRole(accountNo, mobilePhone, userId,value);
        PartnerAccountModel model = new PartnerAccountModel();
        model.setUserId(userId);
        model.setAccount(accountNo);
        model.setUpdateTime(sdf.format(new Date()));
        model.setPartnerId(id+"");
        model.setOverdraftLimit("0");
        model.setFixedLimit("0");
        model.setType("1");
        dao.addPartnerAccount(model);

        //写入消息列表中
        String message = "新建打包站成功,您的账号为："+accountNo+"，初始密码为：888888";
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        payDao.insertMessage(message,userId,"","1","新建打包站",sdf.format(new Date()));

    }
    public Map<String,Object> queryElectronicFence(XzxCityPartnerModel model){
        List<String> partnerIdList=cityPartnerService.queryPartnerByCurrent();
        model.setPartnerIdList(partnerIdList);
        Map<String,Object> map = new HashMap<>();
        int p = model.getPage();
        p = (p - 1) * model.getLimit();
        model.setPage(p);

        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");
        }
        List<XzxCityPartnerModel>  list = xzxPartnerFenceDao.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(",");
                    //Map<String, Object> ret = (Map<String, Object>) object;//取出list里面的值转为map
                    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);
            }
        }
        int  count = xzxPartnerFenceDao.queryElectronicFencePageCount(model);

        map.put("count",count);
        map.put("code",0);
        map.put("data",list);
        return map;
    }
}