package com.xzx.gc.user.service;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.Result;
import com.xzx.gc.common.constant.*;
import com.xzx.gc.common.dto.gdmap.FindTraceDto;
import com.xzx.gc.common.dto.gdmap.TrackDto;
import com.xzx.gc.common.dto.gdmap.UploadTraceLocationDto;
import com.xzx.gc.common.exception.RestException;
import com.xzx.gc.common.utils.*;
import com.xzx.gc.common.utils.ali.SmsUtil;
import com.xzx.gc.common.utils.gdmap.GdTraceUtil;
import com.xzx.gc.entity.*;
import com.xzx.gc.model.JsonResult;
import com.xzx.gc.model.admin.*;
import com.xzx.gc.user.mapper.*;
import com.xzx.gc.util.BeanUtils;
import com.xzx.gc.util.DoubleUtil;
import com.xzx.gc.util.SessionUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

@Service
@Transactional
@Slf4j
public class CityPartnerService {

    @Autowired
    private RemittanceUserMapper remittanceUserMapper;

    @Autowired
    private CityPartnerMapper cityPartnerMapper;

    @Autowired
    private PartnerTraceMapper partnerTraceMapper;

    @Autowired
    private OtherUserService otherUserService;

    @Autowired
    private AddressLevelMapper addressLevelInfoMapper;

    @Autowired
    private BannerMapper bannerMapper;

    @Autowired
    private ConfigService configService;

    @Autowired
    private SessionUtil platformService;

    @Autowired
    private SysMessageMapper sysMessageMapper;
    @Autowired
    private AccountLogMapper accountLogMapper;
    @Autowired
    private OtherUserMapper otherUserMapper;
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private PayInfoMapper payInfoMapper;
    @Autowired
    private SysEnvironmentalInfoMapper sysEnvironmentalInfoMapper;

    @Autowired
    private PartnerTraceService partnerTraceService;

    @Autowired
    private SysEnvironmentalInfoService sysEnvironmentalInfoService;

    @Autowired
    private PartnerFenceService partnerFenceService;

    @Autowired
    private PartnerFenceMapper partnerFenceMapper;

    @Autowired
    private FenceMapper fenceMapper;

    @Autowired
    private IdUtils idUtils;

    @Autowired
    private PartnerAccountMapper partnerAccountMapper;

    @Autowired
    private RedisUtil redisUtil;

    @Autowired
    private AccountService accountService;

    @Autowired
    private AccountMapper accountMapper;

    @Autowired
    private UserMapper userMapper;

    @Autowired
    private AddressService addressService;

    @Autowired
    private PartnerGaodeMapper partnerGaodeMapper;

    @Autowired
    private LongiLatiMapper longiLatiMapper;

    @Autowired
    private PartnerGaodeService partnerGaodeService;


    @Autowired
    private CoreUserMapper coreUserMapper;

    @Autowired
    private PlatformAccountInfoMapper platformAccountInfoMapper;

    @Autowired
    private PlatformAccountLogMapper platformAccountLogMapper;

    @Autowired
    private PartnerAccountLogMapper partnerAccountLogMapper;

    @Autowired
    private CoreUserRoleMapper coreUserRoleMapper;

    @Autowired
    private SessionUtil sessionUtil;

    @Autowired
    private PartnerAccountService partnerAccountService;

    /**
     * 根据合伙人查找打包站列表
     * @param partnerId
     * @return
     */
    public List<CityPartner> findPackageIdByPartnerId(String partnerId){
        CityPartner cityPartner=new CityPartner();
        cityPartner.setPartnerType(OrderEnum.打包站.getValue());
        cityPartner.setDelFlag(Constants.DEL_NOT_FLAG);
        cityPartner.setPackingStation(partnerId);
        return cityPartnerMapper.select(cityPartner);
    }



    public CityPartner findById(Integer id){
        return cityPartnerMapper.selectByPrimaryKey(id);
    }

    /**
     * 根据类型查找  分合伙人和打包站
     * @param type
     * @return
     */
    public List<CityPartner> findByType(String type){
        CityPartner cityPartner=new CityPartner();
        cityPartner.setDelFlag(Constants.DEL_NOT_FLAG);
        cityPartner.setPartnerType(type);
        return cityPartnerMapper.select(cityPartner);
    }


    public int queryElectronicFenceByPartner(String partnerId) {
        return fenceMapper.queryElectronicFenceByPartner(partnerId);
    }



    public void insertGaodeInfo(List<PartnerGaodeModel> gaodeModels) {
        partnerGaodeMapper.insertGaodeInfo(gaodeModels);
    }

    public void deletePartnerTownCode(String partnerId) {
        partnerGaodeMapper.deletePartnerTownCode(partnerId);
    }


    public void deletePartnerAccount(CityPartner  partner) {
        PartnerAccountModel model = new PartnerAccountModel();
        model.setDelFlag(1);
        model.setUserId(partner.getUserId());
        partnerAccountMapper.deletePartnerAccount(model);
        accountService.deleteByUserId(model.getUserId());
    }

    public String deleteServiceByKey(CityPartner  partner) {
        //先删除服务
        Result<JSONArray> service = GdTraceUtil.findService(partner.getPartnerKey());
        if(service.getCode()==0){
            JSONArray data = service.getData();
            for (Object result : data) {
                JSONObject jsonObject1= (JSONObject) result;
                String sid = jsonObject1.getStr("sid");
                String name = jsonObject1.getStr("name");
                //删除以合伙人id开始命名的服务
                if(name.startsWith(partner.getPartnerKey())) {
                    GdTraceUtil.deleteService(partner.getPartnerKey(), sid);
                }
            }
        }

        int num = partnerTraceMapper.deleteGaodeService(partner.getId() + "");
        return num + "";
    }

    public void createServiceByKey(CityPartner  partner) {
        String service1=partnerTraceService.createService(partner, OrderEnum.回收员全天轨迹);
        String service2=partnerTraceService.createService(partner,OrderEnum.回收员订单轨迹);
        String service3=partnerTraceService.createService(partner,OrderEnum.推广员全天轨迹);

        //创建轨迹服务的自定义字段
        if(StrUtil.isNotBlank(service1)){
            GdTraceUtil.createTraceProp(partner.getPartnerKey(),service1,"address","string");
        }
        if(StrUtil.isNotBlank(service2)){
            GdTraceUtil.createTraceProp(partner.getPartnerKey(),service2,"address","string");
        }
        if(StrUtil.isNotBlank(service3)){
            GdTraceUtil.createTraceProp(partner.getPartnerKey(),service3,"address","string");
        }

    }


    public String queryAreaCityList(String city) {
        return addressLevelInfoMapper.queryAreaCityList(city);
    }


    public String queryAreaTownList(String city) {
        return addressLevelInfoMapper.queryAreaTownList(city);
    }

    public String queryGaodeByTownId(String townId) {
        PartnerGaode byTownId = partnerGaodeService.findByTownId(townId);
        if(byTownId!=null){
            return byTownId.getPartnerId();
        }
        return "";
    }


    public String queryAccountByPartnerId(String userId) {
        PartnerAccountModel partnerAccountByUserId = partnerAccountMapper.getPartnerAccountByUserId(userId);
        if(partnerAccountByUserId!=null){
            String hbb = partnerAccountByUserId.getHbb();
            if(StrUtil.isNotBlank(hbb)){
                return hbb;
            }
        }
        return "0";
    }

    public Map<String, Object> queryPartnerAccount(String userId) {
        String accountInfoMoney = queryAccountByPartnerId(userId);
        accountInfoMoney = DoubleUtil.roundTwo(accountInfoMoney);
        Map<String, Object> map = new HashMap<>();
        map.put("money", accountInfoMoney);
        map.put("code", 0);
        map.put("userId", userId);
        return map;
    }

    public CoreUser queryPartnerAdmin(Long id) {
        return coreUserMapper.selectByPrimaryKey(id);
    }

    public List<CityPartner>   queryAllCityPartnerList(String partnerId) {
        return cityPartnerMapper.queryAllCityPartnerList(partnerId);
    }

    public List<CityPartner>   queryPartnerName(List<String> partnerIds) {
        return cityPartnerMapper.queryPartnerName(partnerIds);
    }

    public List<CityPartner>   queryPackageByPartner(List<String> partnerIds) {
        return cityPartnerMapper.queryPackageByPartner(partnerIds);
    }

    public List<String> queryPackageIdList(String partnerId) {
        return cityPartnerMapper.queryPackageIdList(partnerId);
    }

    public List<UserModel> queryOtherUserByPid(String pid, AccountMoneyModel model, List<String> packageStationList) {
        return otherUserMapper.queryOtherUserByPid(pid, model.getUserName(), model.getRoleType(), packageStationList);
    }


    public List<UserModel> queryUserNormal(AccountMoneyModel model) {
        return userMapper.queryAllUserByPid(model.getUserName(), model.getRoleType(),model.getPartnerId());
    }

    public int updateAccountLimit(AccountMoneyModel model) {
        AccountInfo oldModel = accountService.findById(model.getAccountId());
        String message ="";
        String packageUserId="";
        OtherUserInfo userModel =otherUserService.findById(oldModel.getUserId());
        BigDecimal newOl = new BigDecimal("0");
        if (null != userModel) {
            if (null != userModel.getPartnerId()) {
                //打包站
                if (userModel.getUserType().equals("7")) {
                    PartnerAccountModel pa = partnerAccountMapper.queryAccountIdByUserId(userModel.getUserId());
                    CityPartner packP = queryById(Long.parseLong(pa.getPartnerId()));

                    PartnerAccount byPartnerId = partnerAccountService.findByPartnerId(packP.getPackingStation());
                    String  cityPartnerMoney = byPartnerId.getHbb();

                    if (pa.getFixedLimit()!=null) {
                        newOl = new BigDecimal(model.getFixedLimit()).subtract(Convert.toBigDecimal(pa.getOverdraftLimit(),BigDecimal.ZERO));
                        BigDecimal overFlag = Convert.toBigDecimal(cityPartnerMoney,BigDecimal.ZERO).subtract(newOl);
                        if (overFlag.compareTo(BigDecimal.ZERO) == -1) {
                            return -1;
                        }
                        if(DoubleUtil.roundTwo(pa.getFixedLimit()).equals(DoubleUtil.roundTwo(model.getFixedLimit()))){
                            return -2;
                        }
                        pa.setOverdraftLimit(model.getFixedLimit());
                    } else {
                        if(model.getFixedLimit().equals("0")){
                            return -2;

                        }
                        pa.setOverdraftLimit(model.getFixedLimit());
                    }
                    pa.setFixedLimit(model.getFixedLimit());
                    String partnerId = userModel.getPartnerId();
                    CityPartner partner = queryById(Long.parseLong(partnerId));
                    Snowflake snowflake = IdUtil.getSnowflake(0, 3);
                    String payOrderId = "ZF" + snowflake.nextIdStr();
                    pa.setType("7");

                    if (partner.getPartnerType().equals("2")) {
                        partner = queryById(partner.getPackingStation());
                    }
                    //调整额度时需要扣除合伙人额度
                    //UserAccountModel partnerAccount = queryPartnerAccountByUserId(partner.getUserId());
                    PartnerAccountModel partnerAccountModel = getPartnerAccountByUserId(partner.getUserId());



                    //insertPartnerAccountLog(partnerAccount, type, newOl, payOrderId, "7");
                    BigDecimal newPartnerMoney = new BigDecimal(partnerAccountModel.getHbb()).subtract(newOl);
                    if (newPartnerMoney.compareTo(BigDecimal.ZERO) == -1) {
                        return -1;
                    }
                    insertPackageAccountLog(pa,payOrderId,DoubleUtil.roundTwo(newOl.toString()),null,null);

                    //调整打包站额度
                    updatePackageAccount(pa);
                    //insertPacAccountLog(partnerAccountModel, type, newOl, payOrderId, "7");
                    //String type, String money, String payOrderId,CityPartner  partner,String newMoney
                    BigDecimal pol = newOl.multiply(new BigDecimal("-1"));
                    insertPartnerLogByPartner(partnerAccountModel,"7",pol.toString(),payOrderId,partner,newPartnerMoney.toString());

                    //partnerAccount.setMoney(newPartnerMoney.doubleValue());
                    partnerAccountModel.setHbb(DoubleUtil.roundTwo(newPartnerMoney.toString()));
                    partnerAccountModel.setMoney(DoubleUtil.roundTwo(newPartnerMoney.toString()));
                    //updateAccountPartner(partnerAccount);
                    updatePartnerAccount(partnerAccountModel);

                    message="您已经由管理员调整额度，固定额度为：" + pa.getFixedLimit() + "元，可用额度为：" + pa.getOverdraftLimit() + ",请注意变化.";
                    packageUserId = partner.getUserId();
                } else {
                    BigDecimal oldol = new BigDecimal(oldModel.getOverdraftLimit());
                    BigDecimal ollimit = new BigDecimal(oldModel.getFixedLimit());
                    newOl = new BigDecimal(model.getFixedLimit()).subtract(ollimit);
                    BigDecimal overFlag = oldol.add(newOl);
                    if(new BigDecimal(model.getFixedLimit()).compareTo(BigDecimal.ZERO)==0){
                        overFlag = oldol.multiply(new BigDecimal("-1"));
                    }
                    boolean flag1 = false;
                    if (overFlag.compareTo(BigDecimal.ZERO) == -1) {
                        if(new BigDecimal(model.getFixedLimit()).compareTo(BigDecimal.ZERO)==0){
                            flag1 = true;
                        }else{
                            return -1;

                        }
                    }
                    if(DoubleUtil.roundTwo(oldModel.getFixedLimit()).equals(DoubleUtil.roundTwo(model.getFixedLimit()))){
                        return -2;
                    }
                    if(!flag1){
                        oldModel.setOverdraftLimit(DoubleUtil.roundTwo(oldol.add(newOl).toString()));
                        oldModel.setFixedLimit(DoubleUtil.roundTwo(ollimit.add(newOl).toString()));
                    }else{
                        oldModel.setOverdraftLimit(DoubleUtil.roundTwo("0"));
                        oldModel.setFixedLimit(DoubleUtil.roundTwo("0"));
                    }
                    String type = "8";
                    //调整额度时需要扣除合伙人额度
                    String partnerId = userModel.getPartnerId();
                    CityPartner  partner = queryById(partnerId);
                    PartnerAccountModel partnerAccountModel = getPartnerAccountByUserId(partner.getUserId());

                    Snowflake snowflake = IdUtil.getSnowflake(0, 3);
                    String payOrderId = "ZF" + snowflake.nextIdStr();
                    if (newOl.compareTo(BigDecimal.ZERO) == -1) {
                        type = "14";
                    }
                    BigDecimal newPartnerMoney;
                    if(!flag1){
                        newPartnerMoney = new BigDecimal(partnerAccountModel.getHbb()).subtract(newOl);
                    }else{
                        newPartnerMoney = new BigDecimal(partnerAccountModel.getHbb()).add(oldol);
                    }
                    if (newPartnerMoney.compareTo(BigDecimal.ZERO) == -1) {
                        return -1;
                    }
                    if(!flag1){
                    }else{
                        newOl = overFlag;

                    }
                    partnerAccountModel.setAddType("");
                    insertPartnerAccountLog(partnerAccountModel, type, newOl, payOrderId, "7");

                    partnerAccountModel.setMoney(DoubleUtil.roundTwo(newPartnerMoney.toString()));
                    partnerAccountModel.setHbb(DoubleUtil.roundTwo(newPartnerMoney.toString()));
                    updatePartnerAccount(partnerAccountModel);
                    accountMapper.updateAccountLimit(oldModel);
                }

            }
        } else {
            return 0;
        }
        if(null!=message&&!"".equals(message)){
            sysMessageMapper.insertMessage(message, packageUserId, "", "1", "额度调整", DateUtil.now());

        }else{
            //发送系统消息
            message = "您已经由管理员调整额度，固定额度为：" + oldModel.getFixedLimit() + "元，可用额度为：" + oldModel.getOverdraftLimit() + ",请注意变化.";
            sysMessageMapper.insertMessage(message, oldModel.getUserId(), "", "1", "额度调整", DateUtil.now());

        }

        return 1;
    }

    public void insertPartnerLogByPartner(PartnerAccountModel accountModel, String type, String money, String payOrderId,CityPartner  partner,String newMoney) {
        //写入日志
        PartnerAccountLogModel partnerLog = new PartnerAccountLogModel();
        partnerLog.setAccountId(accountModel.getAccount());
        partnerLog.setType(type);
        partnerLog.setCreateTime(DateUtil.now());
        partnerLog.setRoleName("城市合伙人");
        partnerLog.setUserName(partner.getPartnerName());
        partnerLog.setUserPhone(partner.getMobilePhone());
        if(type.equals("13")){
            BigDecimal subMoney = new BigDecimal(money).multiply(new BigDecimal("-1")) ;
            partnerLog.setMoney(DoubleUtil.roundTwo(subMoney.toString()));

        }else{
            partnerLog.setMoney(money);

        }
        partnerLog.setAccountMoney(accountModel.getHbb());
        partnerLog.setHbb(newMoney);
        partnerLog.setFlowNo(payOrderId);
        partnerLog.setApproverStatus("1");
        partnerLog.setDelFlag(0);
        partnerAccountMapper.addPartnerAccountLog(partnerLog);
    }

    public PageInfo<AccountMoneyModel> queryAccountByUserIds(AccountMoneyModel model) {
        PageHelper.startPage(model.getPage(),model.getLimit());
        List<AccountMoneyModel> list = accountMapper.queryAccountByUserIds(model);
        PageInfo<AccountMoneyModel> pageInfo=new PageInfo<>(list);

        for (AccountMoneyModel mm : list) {
            mm.setMoney(DoubleUtil.roundTwo(mm.getMoney()));
            OtherUserInfo userModel = otherUserService.findById(mm.getUserId());

            if (null != userModel) {
                if (userModel.getUserType().equals("7")) {
                    //查询打包站额
                    String partnerId = userModel.getPartnerId();
                    CityPartner  partner = queryById(Long.parseLong(partnerId));
                    if(null!=partner){
                        PartnerAccountModel partnerAccountModel = partnerAccountMapper.queryAccountIdByUserId(partner.getUserId());
                        mm.setFixedLimit(partnerAccountModel.getFixedLimit());
                        mm.setOverdraftLimit(partnerAccountModel.getOverdraftLimit());
                        mm.setMobilePhone(userModel.getMobilePhone());
                        mm.setUserName(userModel.getName());
                        mm.setRegistTime(userModel.getRegistTime());
                        mm.setRoleType(userModel.getUserType());
                    }else{

                    }

                } else {
                    if(userModel.getUserType().equals("5")){
                        String pHbb = queryAccountByPartnerId(mm.getUserId());
                        if(null!=pHbb&&!"".equals(pHbb)){
                            mm.setMoney(DoubleUtil.roundTwo(pHbb));
                        }
                    }
                    mm.setMobilePhone(userModel.getMobilePhone());
                    mm.setUserName(userModel.getName());
                    mm.setRegistTime(userModel.getRegistTime());
                    mm.setRoleType(userModel.getUserType());
                }

            } else {
                UserModel userInfo = userMapper.queryUserById(mm.getUserId());
                userModel=new OtherUserInfo();
                BeanUtil.copyProperties(userInfo,userModel);
                if(userModel!=null) {
                    mm.setMobilePhone(userModel.getMobilePhone());
                    if (null != userModel.getNickName() && !"".equals(userModel.getNickName())) {
                        mm.setUserName(com.xzx.gc.common.utils.StringUtils.decode(userModel.getNickName()));
                    } else {
                        mm.setUserName("--");
                    }
                    mm.setRegistTime(userModel.getRegistTime());
                    mm.setRoleType("1");
                }
            }

        }

        return pageInfo;
    }

    public int updateAccountType(AccountMoneyModel model) {
        return accountMapper.updateAccountType(model);
    }

    public int queryPartnerGaode(List<AreaModel> areaList){
        List<String> list = new ArrayList<>();
        for (AreaModel area:areaList) {
            list.add(area.getTownName());
        }
        return partnerGaodeMapper.queryPartnerGaode(list);
    }
    public void sendPasswordByPartner(CityPartner cityPartner){
        Map<String,Object> map= MapUtil.newHashMap();
        map.put("password",cityPartner.getPassword());
        map.put("account",cityPartner.getAccountNo());
        String content = StrUtil.format("敬爱的合伙人：（{account}）,您的合伙人账户已经开通，后台登录密码是{password}，请登录后台及时更新。谢谢", map);
        SmsUtil.sendPoint(cityPartner.getMobilePhone(), content);

    }
    public List<String> queryPartnerByCurrent() {
        //查询合伙人列表
        List<String> partnerIds = new ArrayList<>();
        CoreUser user = platformService.getCurrentUser();
        //CoreUser user = cityPartnerMapper.queryCoreUser();
        if (user.getId() == 1) {
            //如果是超管 显示全部投诉订单信息
            partnerIds = null;
        } else {
            //如果是运营管理员 显示
            if (user.getOrgId() == 10) {
                partnerIds = null;
            } else {
                //合伙人显示 该合伙人和名下合伙人的所有订单。
                CityPartner partner = cityPartnerMapper.selectByPrimaryKey(user.getId());
                if(null!=partner){
                    partnerIds.add(user.getId() + "");

                }else{
                    partnerIds = null;
                }
                //多级合伙人带拓展
                //List<String> childPartnerIds = xzxOrderComplaintDao.queryChildPids(user.getId()+"");
            }

        }
        return partnerIds;
    }

    public String queryCityPartnerByPhone(String mobilePhone) {
        return cityPartnerMapper.queryCityPartnerByPhone(mobilePhone);
    }



    public Map<String, Object> queryCityPartner(XzxCityPartnerModel model) {
        List<String> partnerIds = queryPartnerByCurrent();
        model.setPartnerIdList(partnerIds);
        if (null != partnerIds && partnerIds.size() > 0) {
            model.setPackingStation(partnerIds.get(0));
        }
        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");
        }
        if (null != model.getPartnerType()) {
            if (model.getPartnerType().equals("2")) {
                model.setPartnerIdList(null);
            }
        } else {
            model.setPartnerType("1");
        }

        PageHelper.startPage(model.getPage(),model.getLimit());
        if(model.getPartnerType().equals("1")){
            model.setPackingStation(null);
        }
        List<XzxCityPartnerModel> list = cityPartnerMapper.queryCityPartner(model);
        for (XzxCityPartnerModel obj : list) {
            List<List<String>> townList = new ArrayList<>();

            List<AreaModel> areaList = partnerGaodeMapper.queryAreaByParentner(obj.getId());
            for (AreaModel am : areaList) {
                List<String> townList1 = new ArrayList<>();
                townList1.add(am.getProvinceName());
                townList1.add(am.getCityName());
                townList1.add(am.getTownName());
                townList.add(townList1);
            }
            obj.setTownList(townList);
            String cityName = "";
            List<String> cityIdList = partnerGaodeMapper.queryGaodeByParentner(obj.getId());
            obj.setAreaList(areaList);
            //当前只支持多选
            if (cityIdList.size() > 0) {
                cityName = addressLevelInfoMapper.queryCityNameById(cityIdList.get(0));
            }
            if(obj.getPartnerType().equals("2")){
                //打包站前端需要返回list地址
                PartnerGaodeModel gaodeModel = new PartnerGaodeModel();
                gaodeModel = partnerGaodeMapper.queryGaodeAreaByPackageId(obj.getId());
                if (null != gaodeModel) {
                    String[] packageAddress = gaodeModel.getAddressArea().split(",");
                    obj.setPackageAddress(packageAddress);
                }

            }
            obj.setCityName(cityName);
            obj.setCzMoney(DoubleUtil.roundTwo(obj.getCzMoney()));
            obj.setTxMoney(DoubleUtil.roundTwo(obj.getTxMoney()));
            List<XzxElectronicFenceModel> fenceNameList = fenceMapper.queryFenceNameList(obj);
            StringBuffer sb = new StringBuffer();
            StringBuffer sbId = new StringBuffer();
            if (null != fenceNameList && fenceNameList.size() > 0) {
                for (XzxElectronicFenceModel stn : fenceNameList) {
                    sb.append(stn.getFenceName()).append(",");
                    sbId.append(stn.getId()).append(",");
                }
                String sbStr = sb.toString();
                String sbIds = sbId.toString();
                if (!"".equals(sbStr)) {
                    sbStr = sbStr.substring(0, sbStr.length() - 1);
                    obj.setFenceName(sbStr);
                }
                if (!"".equals(sbIds)) {
                    sbIds = sbIds.substring(0, sbIds.length() - 1);
                    obj.setFenceIds(sbIds);
                }
            }
            List<String> citys = partnerGaodeMapper.queryCitysByPartnerId(obj.getId());
            String cityName1 = "";
            for (String cityId : citys) {
                String named = addressLevelInfoMapper.queryCityNameById(cityId);
                if (null != cityName1 && !"".equals(cityName1)) {
                    cityName1 = cityName1 + "," + named;
                } else {
                    cityName1 = named;
                }
            }

            if (cityName1 != null && !"".equals(cityName1)) {
                obj.setCityName(cityName1);
            } else {

                String userId = obj.getUserId();
                UserModel userModel = otherUserMapper.queryUserOtherById(userId);

                cityName = addressLevelInfoMapper.queryCityByCityId(userModel.getCityId());
                obj.setCityId(userModel.getCityId());
                obj.setCityName(cityName);
            }

            if (null != obj.getPackingStation() && !"".equals(obj.getPackingStation())) {
                CityPartner  partner = queryById(Long.parseLong(obj.getPackingStation()));
                obj.setPackingStationName(partner.getPartnerName());
            }
        }
        PageInfo<XzxCityPartnerModel> pageInfo=new PageInfo<>(list);
        map.put("code", 0);
        map.put("data", list);
        map.put("count", pageInfo.getTotal());
        return map;
    }




    public PartnerAccountModel getPartnerAccountByUserId(String userId) {
        return partnerAccountMapper.getPartnerAccountByUserId(userId);
    }


    public void updatePartnerAccount(PartnerAccountModel partnerAccountModel) {
        partnerAccountMapper.updatePartnerAccount(partnerAccountModel);
    }

    public void updatePackageAccount(PartnerAccountModel partnerAccountModel) {
        partnerAccountMapper.updatePackageAccount(partnerAccountModel);
    }

    public void insertPackageAccountLog(PartnerAccountModel partnerAccountModel, String payOrderId, String money,BigDecimal hbbFp,BigDecimal edFp) {
        CityPartner  partner = cityPartnerMapper.queryEntityByUserIds(partnerAccountModel.getUserId());
        PartnerAccountLogModel partnerLog = new PartnerAccountLogModel();
        partnerLog.setFlowNo(payOrderId);
        partnerLog.setCreateTime(DateUtil.now());
        partnerLog.setApproverStatus("1");
        if(null!=partnerAccountModel.getType()&&!"".equals(partnerAccountModel.getType())){
            if(partnerAccountModel.getType().equals("7")){
                AccountMoneyModel model = new AccountMoneyModel();
                model.setAccountId(partnerAccountModel.getAccount());
                AccountMoneyModel oldModel = partnerAccountMapper.queryPartnerByAccountId(model);
                BigDecimal oldLimit = new BigDecimal(oldModel.getFixedLimit());
                BigDecimal oldOverLimit = new BigDecimal(oldModel.getOverdraftLimit());

                partnerLog.setManageLimit(DoubleUtil.roundTwo(money));
                partnerLog.setManageLimitFix(DoubleUtil.roundTwo(money));
                partnerLog.setOldLimitFix(DoubleUtil.roundTwo(oldLimit.toString()));
                partnerLog.setNewLimitFix(DoubleUtil.roundTwo(partnerAccountModel.getFixedLimit()));
                partnerLog.setOldLimit(DoubleUtil.roundTwo(oldOverLimit.toString()));
                partnerLog.setNewLimit(DoubleUtil.roundTwo(partnerAccountModel.getOverdraftLimit()));
                partnerLog.setMoney(DoubleUtil.roundTwo("0"));
                partnerLog.setHbb(DoubleUtil.roundTwo(partnerAccountModel.getHbb()));
                partnerLog.setAccountMoney(DoubleUtil.roundTwo(partnerAccountModel.getHbb()));
            }else{
                //充值处理
                if(null!=hbbFp){
                    //环保币分配
                    partnerLog.setMoney(DoubleUtil.roundTwo(hbbFp.toString()));
                    partnerLog.setHbb(DoubleUtil.roundTwo(hbbFp.add(new BigDecimal(partnerAccountModel.getHbb())).toString()));
                    partnerLog.setAccountMoney(DoubleUtil.roundTwo(partnerAccountModel.getHbb() + ""));//额度分配
                    //额度分配
                    partnerLog.setOldLimit(partnerAccountModel.getOverdraftLimit());
                    partnerLog.setManageLimit(DoubleUtil.roundTwo(edFp.toString()));
                    partnerLog.setNewLimit(DoubleUtil.roundTwo(edFp.add(new BigDecimal(partnerAccountModel.getOverdraftLimit())).toString()));

                    partnerLog.setOldLimitFix(partnerAccountModel.getFixedLimit());
                    partnerLog.setManageLimitFix("0");
                    partnerLog.setNewLimitFix(partnerAccountModel.getFixedLimit());
                }else{
                    partnerLog.setMoney(DoubleUtil.roundTwo(money));
                    partnerLog.setHbb(DoubleUtil.roundTwo(new BigDecimal(money).add(new BigDecimal(partnerAccountModel.getHbb())).toString()));
                    partnerLog.setAccountMoney(DoubleUtil.roundTwo(partnerAccountModel.getHbb() + ""));
                }
            }

        }else{
            partnerLog.setMoney(DoubleUtil.roundTwo(money));
            partnerLog.setHbb(DoubleUtil.roundTwo(new BigDecimal(money).add(new BigDecimal(partnerAccountModel.getHbb())).toString()));
            partnerLog.setAccountMoney(DoubleUtil.roundTwo(partnerAccountModel.getHbb() + ""));
        }
        partnerLog.setDelFlag(0);
        partnerLog.setAccountId(partnerAccountModel.getAccount());
        partnerLog.setUserName(partner.getPartnerName());
        if(null!=partnerAccountModel.getType()&&!"".equals(partnerAccountModel.getType())){
            partnerLog.setType(partnerAccountModel.getType());
        }else{
            partnerLog.setType("1");
        }

        partnerLog.setUserPhone(partner.getMobilePhone());
        partnerLog.setRoleName("打包站");
        partnerAccountMapper.addPartnerAccountLog(partnerLog);
    }


    public void insertPartnerAccountLog(PartnerAccountModel accountModel, String type, BigDecimal money, String payOrderId, String packageType) {
        //写入日志
        AccountLogModel log = new AccountLogModel();
        boolean flag = true;
        if(null!=accountModel.getAddType()&&!"".equals(accountModel.getAddType())){
            log.setNewMoney(DoubleUtil.roundTwo(new BigDecimal(accountModel.getHbb()).add(money).toString()));

        }else{
            flag = false;
            log.setNewMoney(DoubleUtil.roundTwo(new BigDecimal(accountModel.getHbb()).subtract(money).toString()));

        }
        CityPartner partner = cityPartnerMapper.queryEntityByUserIds(accountModel.getUserId());
        PartnerAccountLogModel partnerLog = new PartnerAccountLogModel();
        partnerLog.setFlowNo(payOrderId);
        partnerLog.setCreateTime(DateUtil.now());
        partnerLog.setApproverStatus("1");
        if(type.equals("14")){
            if(!flag){
                partnerLog.setMoney(DoubleUtil.roundTwo(money.multiply(new BigDecimal("-1")).toString()));

            }else{
                partnerLog.setMoney(DoubleUtil.roundTwo(money.toString()));

            }

        }else{
            if(!flag){
                partnerLog.setMoney(DoubleUtil.roundTwo(money.multiply(new BigDecimal("-1")).toString()));

            }else{
                partnerLog.setMoney(DoubleUtil.roundTwo(money.toString()));

            }
        }
        partnerLog.setHbb(log.getNewMoney());
        partnerLog.setDelFlag(0);
        partnerLog.setAccountId(accountModel.getAccount());
        partnerLog.setAccountMoney(DoubleUtil.roundTwo(accountModel.getHbb() + ""));
        partnerLog.setUserName(partner.getPartnerName());
        if (null != packageType) {
            partnerLog.setType(packageType);

        } else {
            if(type.equals("9")){
                partnerLog.setType("12");
            }else if(type.equals("8")){
                partnerLog.setType("7");
            }else{
                partnerLog.setType("1");
            }
        }
        partnerLog.setUserPhone(partner.getMobilePhone());
        partnerLog.setRoleName("城市合伙人");
        partnerAccountMapper.addPartnerAccountLog(partnerLog);

    }




    public List<CityPartner>   queryPartnerByMobile(XzxCityPartnerModel model) {
        return cityPartnerMapper.queryPartnerByMobile(model);

    }

    public UserAccountModel queryPartnerAccountByUserId(String userId) {
        return accountMapper.getAccountByUserId(userId);
    }




    public CityPartner queryById(String partnerId) {

        return   cityPartnerMapper.selectByPrimaryKey(partnerId);
    }

    public Map<String, Object> queryUserAccountLog(AccountLogModel model) {

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

        String totalMoney = "0";
        CoreUser user = platformService.getCurrentUser();
        if (null != model.getAccountId() && !"".equals(model.getAccountId())) {
            AccountMoneyModel am = new AccountMoneyModel();
            am.setAccountId(model.getAccountId());
            AccountMoneyModel account = accountMapper.queryAccountByAccountId(am);
            totalMoney = account.getMoney();
        }
        List<String> partnerIds = queryPartnerByCurrent();
        model.setPartnerIds(partnerIds);
        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<String> list1 = new ArrayList<>();
        if (null != model.getSzType()&&!"".equals(model.getSzType())) {

            if (model.getSzType().equals("1")) {
                switch (model.getRoleType()) {
                    case 5:
                        list1.add("1");
                        list1.add("14");
                        break;
                    case 2:
                        list1.add("1");
                        list1.add("4");
                        list1.add("11");
                        list1.add("12");
                        break;
                    case 6:
                        list1.add("1");
                        list1.add("10");
                        break;
                    case 1:
                        list1.add("1");
                        list1.add("3");
                        list1.add("5");
                        list1.add("6");
                        list1.add("7");
                        list1.add("13");
                        break;
                    case 7:
                        list1.add("1");
                        break;
                    default:
                        break;
                }
            } else if (model.getSzType().equals("2")) {
                switch (model.getRoleType()) {
                    case 5:
                        list1.add("2");
                        list1.add("5");
                        list1.add("6");
                        list1.add("7");
                        list1.add("8");
                        list1.add("15");
                        break;
                    case 2:
                        list1.add("2");
                        list1.add("3");
                        list1.add("13");
                        list1.add("15");
                        break;
                    case 6:
                        list1.add("2");
                        list1.add("15");
                        break;
                    case 4:
                        list1.add("4");
                        list1.add("15");
                        break;
                    case 1:
                        list1.add("2");
                        list1.add("15");
                        break;
                    case 7:
                        list1.add("4");
                        list1.add("15");
                        break;
                    default:
                        break;
                }
            } else {
                list1.add("1");
                list1.add("2");
                list1.add("3");
                //操作渠道1：充值 2：提现 3：回收 4入库 5红包 6分享返利 7重量达标返利
                list1.add("4");
                list1.add("5");
                list1.add("6");
                list1.add("7");
                list1.add("10");
                list1.add("11");
                list1.add("12");
                list1.add("13");
                list1.add("8");
                list1.add("14");
                list1.add("15");
            }
            model.setTypeList(list1);
        }

        String mType = model.getChannelType();
        List<AccountLogModel> list = new ArrayList<>();
        if(model.getRoleType()==5||model.getRoleType()==7) {
            PageHelper.startPage(model.getPage(), model.getLimit());
            list = partnerAccountLogMapper.queryPartnerLog(model);
            for (AccountLogModel almodel : list) {
                almodel.setTypeText(changeTypeText(almodel.getChannelType(), almodel.getRoleType()+""));
                if (null != almodel.getOldLimit() && !"".equals(almodel.getOldLimit())) {
                    almodel.setOldLimit(DoubleUtil.roundTwo(almodel.getOldLimit()));
                } else {
                    almodel.setOldLimit("0");
                }
                if (null != almodel.getNewLimit() && !"".equals(almodel.getNewLimit())) {
                    almodel.setNewLimit(DoubleUtil.roundTwo(almodel.getNewLimit()));

                } else {
                    almodel.setNewLimit("0");
                }

                if(null!=almodel.getNewMoney()&&!"".equals(almodel.getNewMoney())){
                    almodel.setNewMoney(DoubleUtil.roundTwo(almodel.getNewMoney()));
                }else{
                    almodel.setNewMoney(DoubleUtil.roundTwo("0"));
                }

                if(null!=almodel.getOldMoney()&&!"".equals(almodel.getOldMoney())){
                    almodel.setOldMoney(DoubleUtil.roundTwo(almodel.getOldMoney()));
                }else{
                    almodel.setOldMoney(DoubleUtil.roundTwo("0"));
                }

                if (almodel.getUserType().equals("1")) {
                    //转昵称
                    String nickName = almodel.getUserName();
                    if (nickName != null && !"".equals(nickName)) {
                        nickName= com.xzx.gc.common.utils.StringUtils.decode(nickName);
                    }
                    almodel.setUserName(nickName);
                }
                if(model.getRoleType()==7) {
                    almodel.setRoleName("打包员");
                }
            }
//        }else if(model.getRoleType()==7){
//            PartnerAccountModel packageAccount = partnerAccountMapper.queryAccountIdByAccountId(model.getAccountId());
//            List<String> packageIds = new ArrayList<>();
//            packageIds.add(packageAccount.getPartnerId());
//            model.setPartnerIds(packageIds);
//            if(null!=partnerIds&&partnerIds.size()>0){
//                List<String> townIds = partnerGaodeMapper.queryTownIdsByPartnerId(partnerIds.get(0));
//                model.setTownIds(townIds);
//            }
//            if(model.getChannelType().equals("-1")){
//                if(mType.equals("")){
//                    model.setChannelType(null);
//                }
//            }
//            PageHelper.startPage(model.getPage(),model.getLimit());
//            //TODO szType=1 收入 2支出  channelType 费用类型
//            list = accountLogMapper.queryAccountLogByAccount(model);
//            for (AccountLogModel r : list) {
//                if(null!=r.getChannelType()&&!"".equals(r.getChannelType())){
//                    r.setTypeText(changeTypeText(r.getChannelType(),"0"));
//
//                }else{
//                    r.setTypeText("充值");
//                }
//
//                if(null!=r.getNewMoney()&&!"".equals(r.getNewMoney())){
//                    r.setNewMoney(DoubleUtil.roundTwo(r.getNewMoney()));
//                }else{
//                    r.setNewMoney(DoubleUtil.roundTwo("0"));
//                }
//                if(null!=r.getNewLimit()&&!"".equals(r.getNewLimit())){
//                    r.setNewLimit(DoubleUtil.roundTwo(r.getNewLimit()));
//                }else{
//                    r.setNewLimit(DoubleUtil.roundTwo("0"));
//                }
//                if(null!=r.getOldMoney()&&!"".equals(r.getOldMoney())){
//                    r.setOldMoney(DoubleUtil.roundTwo(r.getOldMoney()));
//                }else{
//                    r.setOldMoney(DoubleUtil.roundTwo("0"));
//                }
//                if (r.getUserType().equals("1")) {
//                    //转昵称
//                    String nickName = r.getUserName();
//                    if (nickName != null && !"".equals(nickName)) {
//                        nickName= com.xzx.gc.common.utils.StringUtils.decode(nickName);
//                    }
//                    r.setUserName(nickName);
//                }
//                r.setRoleName("打包员");
//            }
        }else{
            if(null!=partnerIds&&partnerIds.size()>0){
                List<String> townIds = partnerGaodeMapper.queryTownIdsByPartnerId(partnerIds.get(0));
                model.setTownIds(townIds);
            }
            if(model.getChannelType().equals("-1")){
                if(mType.equals("")){
                    model.setChannelType(null);
                }
            }
            PageHelper.startPage(model.getPage(),model.getLimit());
            list = accountLogMapper.queryAccountLogByAccount(model);
            for (AccountLogModel r : list) {
                r.setTypeText(changeTypeText(r.getChannelType(),"0"));

                if(null!=r.getOldLimit()&&!"".equals(r.getOldLimit())){
                    r.setOldLimit(DoubleUtil.roundTwo(r.getOldLimit()));
                }else{
                    r.setOldLimit("0");
                }
                if(null!=r.getNewLimit()&&!"".equals(r.getNewLimit())){
                    r.setNewLimit(DoubleUtil.roundTwo(r.getNewLimit()));

                }else{
                    r.setNewLimit("0");
                }
                if (r.getUserType().equals("1")) {
                    //转昵称
                    String nickName = r.getUserName();
                    if (nickName != null && !"".equals(nickName)) {
                        nickName= com.xzx.gc.common.utils.StringUtils.decode(nickName);
                    }
                    r.setUserName(nickName);
                }
                r.setRoleName("城市合伙人");
            }
        }
        result.put("data", list);

        PageInfo<AccountLogModel> pageInfo=new PageInfo<>(list);
        result.put("count", pageInfo.getTotal());
        result.put("code", 0);
        result.put("totalMoney", DoubleUtil.roundTwo(totalMoney));
        return result;
    }



    public Map<String, Object> queryPartnerAccountLog(PartnerAccountLogModel model) {

        Map<String, Object> result = new HashMap<>();
        CoreUser user = platformService.getCurrentUser();
        CityPartner  partner = queryById(user.getId());
        PartnerAccountModel userAccount = new PartnerAccountModel();
        if (null != partner) {
            userAccount = partnerAccountMapper.queryAccountIdByUserId(partner.getUserId());
        } else {
            String acc = platformAccountInfoMapper.queryAccountByAdminId();
            String[] accArr = acc.split(",");
            userAccount.setMoney(accArr[1]);
            userAccount.setHbb(accArr[2]);
        }
        if (null != userAccount) {
            List<PartnerAccountLogModel> list = new ArrayList<>();
            PageHelper.startPage(model.getPage(),model.getLimit());
            if (null != userAccount.getAccount() && !"".equals(userAccount.getAccount())) {
                model.setAccountId(userAccount.getAccount());
                list = partnerAccountLogMapper.queryPartnerAccountLog(model);
            } else {
                list = partnerAccountLogMapper.queryAdminAccountLog(model);
                for (PartnerAccountLogModel log : list) {
                    String type = log.getType();
                    if(type.equals(CommonEnum.平台充值.getValue())){
                        log.setTypeText("充值");
                    }else if(type.equals(CommonEnum.平台提现.getValue())){
                        log.setTypeText("提现");
                    }else if(type.equals(CommonEnum.平台总部流水提佣.getValue())){
                        log.setTypeText("总部流水提佣");
                    }else if(type.equals(CommonEnum.平台集货.getValue())){
                        log.setTypeText("集货");
                    }
                    log.setApproverStatus("2");
                    log.setApproverTime(log.getCreateTime());
                    String userName = log.getUserName();
                    if (!StringUtils.isEmpty(userName)) {
                        userName =  com.xzx.gc.common.utils.StringUtils.decode(log.getUserName());
                    }
                    if (!StringUtils.isEmpty(userName)) {
                        log.setUserName(userName);
                    }
                    if (null != log.getRoleName()) {
                        if (log.getRoleName().equals("1")) {
                            log.setRoleName("普通用户");
                        } else if (log.getRoleName().equals("2")) {
                            log.setRoleName("平台用户");
                        }
                    } else {
                        log.setRoleName("普通用户");
                    }

                }
            }

            PageInfo<PartnerAccountLogModel> pageInfo=new PageInfo<>(list);
            result.put("data", list);
            result.put("hbbAccount", userAccount.getHbb());
            result.put("moneryAccount", userAccount.getMoney());
            result.put("code", 0);
            result.put("count", pageInfo.getTotal());
        } else {
            result.put("data", new ArrayList<>());
            result.put("hbbAccount", "0");
            result.put("moneryAccount", "0");
            result.put("code", 0);
            result.put("count", 0);
        }

        return result;
    }

    public List<Map<String, String>> queryPartnerCityById(CityPartner  partner) {
        List<Map<String, String>> list = partnerGaodeMapper.queryPartnerCityById(partner);
        for (Map<String,String> map:list) {
            map.put("cityid",map.get("cityId"));
            map.put("cityname",map.get("cityName"));
        }
        return list;
    }

    public List<Map<String, Object>> queryAreaObj(CityPartner  partner) {
        List<Map<String, Object>> list = partnerGaodeMapper.queryPidBypartnerId(partner);
        String partnerId = "";
        if (null != partner) {
            partnerId = partner.getId() + "";
        }
        for (Map<String, Object> map : list) {
            String pid = map.get("code").toString();
            List<Map<String, Object>> clist = partnerGaodeMapper.queryGaodeByCid(partnerId, pid);
            for (Map<String, Object> cmap : clist) {
                List<Map<String, String>> tlist = partnerGaodeMapper.queryGaodeByTid(partnerId, cmap.get("code").toString());
                cmap.put("children", tlist);
            }
            map.put("children", clist);
        }
        return list;
    }

    public int deleteUserByPartnerId(String id, String accountId) {
        accountMapper.deleteAccount(accountId);
        return otherUserMapper.deleteUserByPartnerId(id);

    }

    public boolean update(CityPartner partner) {
        return cityPartnerMapper.updateByPrimaryKeySelective(partner)>0?true:false;
    }

    public boolean save(CityPartner info) {
        return cityPartnerMapper.insertUseGeneratedKeys(info)>0?true:false;
    }

    public CityPartner queryById(Long id) {
        return cityPartnerMapper.selectByPrimaryKey(id);
    }




    public List<Map<String, Object>> queryAllType(RoleTypeModel model) {
        List<Map<String,Object>> list;
        if(model.getRoleType().equals("5")){
            list = partnerAccountLogMapper.queryAllPartnerType();
        }else{
            list = partnerAccountLogMapper.queryAllAccountType();
        }
        list = changeTypeNameByType(list,model.getRoleType());
        return list;
    }

    public List<Map<String,Object>> changeTypeNameByType(List<Map<String, Object>> typeList,String roleType){
        for (Map<String, Object> map:typeList) {
            if(null!=map){
                String key = map.get("type").toString();
                Integer type = Integer.parseInt(key);
                if(roleType.equals("5")){
                    //1充值 2提现 3重量返利 4提佣 5分享 6阶梯返利 7额度调整 8红包 9推广返利 10人员变动 11结算提成 12额度恢复 13订单投诉
                    switch (type) {
                        case 1: map.put(key,"充值");map.put("value","充值"); break;
                        case 2:map.put(key,"提现");map.put("value","提现"); break;
                        case 3:map.put(key,"重量返利");map.put("value","重量返利"); break;
                        case 4:map.put(key,"提佣");map.put("value","提佣"); break;
                        case 5:map.put(key,"分享"); map.put("value","分享");break;
                        case 6:map.put(key,"阶梯返利");map.put("value","阶梯返利"); break;
                        case 7:map.put(key,"额度调整"); map.put("value","额度调整");break;
                        case 8:map.put(key,"红包");map.put("value","红包"); break;
                        case 9:map.put(key,"推广返利");map.put("value","推广返利");  break;
                        case 10:map.put(key,"人员变动");map.put("value","人员变动"); break;
                        case 11:map.put(key,"结算提成");map.put("value","结算提成"); break;
                        case 12:map.put(key,"额度恢复"); map.put("value","额度恢复");break;
                        case 13:map.put(key,"订单投诉");map.put("value","订单投诉"); break;
                        default:
                            return null;
                    }
                }else{
                    switch (type) {
                        //数字
                        //1：充值 2：提现 3：回收 4入库 5红包 6分享返利 7重量达标返利 8额度申请 9\
                        // 额度恢复 10 推广返利 11垫付合伙人 12提成 13重量返利支出 14：额度降低 15总部流水提佣 16订单投诉
                        case 1: map.put(key,"充值"); map.put("value","充值");break;
                        case 2:map.put(key,"提现"); map.put("value","提现");break;
                        case 3:map.put(key,"回收");map.put("value","回收"); break;
                        case 4:map.put(key,"入库"); map.put("value","入库");break;
                        case 5:map.put(key,"红包"); map.put("value","红包");break;
                        case 6:map.put(key,"分享返利");map.put("value","分享返利"); break;
                        case 7:map.put(key,"重量达标返利"); map.put("value","重量达标返利"); break;
                        case 8:map.put(key,"额度申请"); map.put("value","额度申请");break;
                        case 9:map.put(key,"额度恢复");map.put("value","额度恢复"); break;
                        case 10:map.put(key,"推广返利"); map.put("value","推广返利");break;
                        case 11:map.put(key,"垫付合伙人"); map.put("value","垫付合伙人"); break;
                        case 12:map.put(key,"提成"); map.put("value","提成");break;
                        case 13:map.put(key,"重量返利支出"); map.put("value","重量返利支出"); break;
                        case 14:map.put(key,"额度降低");map.put("value","额度降低"); break;
                        case 15:map.put(key,"总部流水提佣"); map.put("value","总部流水提佣");break;
                        case 16:map.put(key,"订单投诉");map.put("value","订单投诉"); break;
                        default:
                            return null;
                    }
                }

            }
        }

        return typeList;
    }
    public String changeTypeText(String key,String roleType){
        Integer type = Convert.toInt(key,1);
        String typeText = "";
        if(roleType.equals("1")){
            //合伙人账户类型
            //1充值 2提现 3重量返利 4提佣 5分享 6阶梯返利 7额度调整 8红包 9推广返利 10人员变动 11结算提成 12额度恢复 13订单投诉
            switch (type) {
                case 1: typeText = "充值"; break;
                case 2:typeText="提现"; break;
                case 3:typeText="重量返利"; break;
                case 4:typeText="提佣";break;
                case 5:typeText="分享";break;
                case 6:typeText="阶梯返利";break;
                case 7:typeText="额度调整";break;
                case 8:typeText="红包";break;
                case 9:typeText="推广返利";break;
                case 10:typeText="人员变动";break;
                case 11:typeText="结算提成";break;
                case 12:typeText="额度恢复";break;
                case 13:typeText="订单投诉";break;
                default:
                    return null;
            }
        }else{
            switch (type) {
                //用户账户类型
                //1：充值 2：提现 3：回收 4入库 5红包 6分享返利 7重量达标返利 8额度申请 9\
                // 额度恢复 10 推广返利 11垫付合伙人 12提成 13重量返利支出 14：额度降低 15总部流水提佣 16订单投诉
                case 1: typeText="充值";break;
                case 2:typeText="提现";break;
                case 3:typeText="回收";break;
                case 4:typeText="入库";break;
                case 5:typeText="红包";break;
                case 6:typeText="分享返利";break;
                case 7:typeText="重量达标返利";break;
                case 8:typeText="额度申请";break;
                case 9:typeText="额度恢复";break;
                case 10:typeText="推广返利";break;
                case 11:typeText="垫付合伙人";break;
                case 12:typeText="提成";break;
                case 13:typeText="重量返利支出";break;
                case 14:typeText="额度降低";break;
                case 15:typeText="总部流水提佣";break;
                case 16:typeText="订单投诉";break;
                default:
                    return null;
            }
        }


        return typeText;
    }


    /**
     * 删除合伙人
     * @param model
     * @return
     */
    public JsonResult<String> deletePartner(XzxCityPartnerModel model){
        int count = queryElectronicFenceByPartner(model.getId());
        if(count>0){
            return JsonResult.failMessage("删除合伙人前，请先删除该合伙人的电子围栏！");
        }else{
            CityPartner partner = queryById(model.getId());
            partner.setDelFlag(1);
            if(partner.getPartnerType().equals(OrderEnum.打包站.getValue())){
                List<String> partnerIds = queryPartnerByCurrent();
                if(null!=partnerIds&&partnerIds.size()>0){
                    return JsonResult.failMessage("合伙人不能删除打包站！");
                }
                delCuserById(partner.getUserId(), partner.getMobilePhone(), "7");
            }else{
                deleteServiceByKey(partner);
                deleteUserByPartnerId(model.getId(),partner.getAccountNo());
            }
            deletePartnerAccount(partner);
            deletePartnerTownCode(partner.getId()+"");
            sysEnvironmentalInfoService.deleteGoods(partner.getId()+"");

            update(partner);

            return JsonResult.success(model.getId());
        }
    }

    private void delCuserById(String id, String phone, String userType) {

        UserAccountModel account = queryPartnerAccountByUserId(id);
        if (null == account.getOverdraftLimit() && "".equals(account.getOverdraftLimit())) {
            account.setOverdraftLimit("0");
        }
        BigDecimal overLimit = new BigDecimal(account.getOverdraftLimit());
        //要把可用余额加入到合伙人
        UserModel userModel1 = otherUserMapper.queryUserOtherByIdC(id);
        if (null != userModel1) {
            if (overLimit.compareTo(BigDecimal.ZERO) == 1) {


                if (null != userModel1.getPartnerId()) {
                    //调整额度时需要扣除合伙人额度
                    String partnerId = userModel1.getPartnerId();
                    CityPartner partner = queryById(partnerId);
                    //UserAccountModel partnerAccount = queryPartnerAccountByUserId(partner.getUserId());
                    PartnerAccountModel partnerAccountModel = getPartnerAccountByUserId(partner.getUserId());
                    Snowflake snowflake = IdUtil.getSnowflake(0, 3);
                    String payOrderId = "ZF" + snowflake.nextIdStr();
                    partnerAccountModel.setAddType("1");
                    insertPartnerAccountLog(partnerAccountModel, "8", overLimit, payOrderId, "7");
                    BigDecimal newPartnerMoney = new BigDecimal(partnerAccountModel.getHbb()).add(overLimit);
                    partnerAccountModel.setHbb(DoubleUtil.roundTwo(newPartnerMoney.toString()));
                    updatePartnerAccount(partnerAccountModel);
                }
            }
        }
        // 删除user_info
        otherUserService.deleteById(id);
        // 删除account
        accountService.deleteByUserId(id);
        if (userType.equals("普通用户")) {
            // 删除地址
            addressService.deleteByUserId(id);
        }
        // 删除redis token
        UserModel userModel = userMapper.queryUserByUsertype(phone, "1", "0", null, null);
        // redisService.removeToken(userModel.getUserId());
        redisUtil.remove("xzx:user:token:" + id);
        if (null != userModel) {
            redisUtil.remove("xzx:user:token:" + userModel.getUserId());
        }

        List<Map<String, Object>> userIdList = otherUserMapper.queryCuserByPhoneRedisDelList(phone);
        for (Map<String, Object> map : userIdList) {
            String userId = map.get("userId").toString();
            redisUtil.remove("xzx:user:token:" + userId);
        }
        redisUtil.remove(phone);
    }

    /**
     * 添加合伙人
     * @param model
     * @return
     */
    public JsonResult<String> addPartner(XzxCityPartnerModel model){
        //判断是否有分配key
        List<String> partnerIds1 = queryPartnerByCurrent();
        if(null!=partnerIds1&&partnerIds1.size()>0){
            if(model.getPartnerType().equals("1")){
                return JsonResult.failMessage("不允许新建下级合伙人！");

            }
        }
        //不能添加重复区域的合伙人
        if(model.getPartnerType().equals("1")){
            int num = queryPartnerGaode(model.getAreaList());
            if(num>0){
                return JsonResult.failMessage("该区域已经存在合伙人！");

            }
        }
        List<AreaModel> areaModelList = model.getAreaList();
        String mobile = model.getMobilePhone();
        String res = checkSamePartnerName(model,areaModelList,mobile);
        if(null!=res){
            return JsonResult.failMessage(res);
        }
        model.setDelFlag(0);
        model.setCreateTime(DateUtil.now());
        CityPartner info = BeanUtils.copy(model, CityPartner.class);

        info.setDelFlag(0);
        String userId = idUtils.generate("USER",3);
        info.setUserId(userId);
        if(model.getPartnerType().equals(OrderEnum.合伙人.getValue())){
            String password = RandomUtil.randomString(6);
            info.setPassword(password);
            //发送密码短信
            sendPasswordByPartner(info);
            if(null==info.getOrgId()){
                info.setOrgId(Constants.ORG_ID_PARTNER);
            }
            info.setState(Constants.IS_START);
        }else{
            if(null==info.getOrgId()){
                info.setOrgId(Constants.ORG_ID_PACKAGE);
            }
            info.setState(Constants.IS_START);
            //判断是否合伙人登陆
            List<String> partnerIds = queryPartnerByCurrent();
            if(null!=partnerIds&&partnerIds.size()>0){
                info.setPackingStation(partnerIds.get(0));
            }else{
                //根据区域查询合伙人Id
                String townName = model.getTownName();
                String townIdPackage = queryAreaTownList(townName);
                String packingStation = queryGaodeByTownId(townIdPackage);
                info.setPackingStation(packingStation);
            }
        }
        if(null!=info.getPassword()&&!"".equals(info.getPassword())){
            String salt1 = RandomUtil.randomString(16);
            String newPassword =SecurityUtil.encrypt(salt1,info.getPassword());
            info.setPassword(newPassword);
            info.setSalt(salt1);
        }

        info.setPartnerKey(model.getPartnerKeys());
        if(save(info)){
            //创建服务
            if(model.getPartnerType().equals(OrderEnum.合伙人.getValue())){
                createServiceByKey(info);
                String partnerId = queryCityPartnerByPhone(mobile);
                List<String> townIds = insertGaodeTown(areaModelList,partnerId,model.getPartnerKeys());
                info.setId(Integer.parseInt(partnerId));
                insertUserOther(info,userId);
                addAccountInfo(info.getMobilePhone(),userId,model.getAccountNo(),Long.parseLong(info.getId()+""),model.getRoleId());
                initGoodsByPartner(partnerId,townIds);
            }else{
                areaModelList = new ArrayList<>();
                String cityPackage = model.getCityName();
                String cityIdPackage = queryAreaCityList(cityPackage);
                AreaModel areaModel = new AreaModel();
                areaModel.setCityId(Long.parseLong(cityIdPackage));
                areaModel.setCityName(cityPackage);
                areaModel.setProvinceName(model.getProvinceName());
                areaModel.setTownName(model.getTownName());
                areaModelList.add(areaModel);
                insertGaodeTown(areaModelList,info.getId()+"",info.getId()+"");
                insertUserOtherPackage(info,userId,cityIdPackage);
                addAccountByPackage(info.getMobilePhone(),userId,model.getAccountNo(),Long.parseLong(info.getId()+""));
            }
            return JsonResult.success(info.getId()+"");
        }else{
            return JsonResult.failMessage("添加合伙人失败！");
        }
    }

    public void addAccountByPackage(String mobilePhone,String userId,String accountNo,Long id){
        // 添加账号表
        String value = "0";
        accountMapper.addCuserAccountRole(accountNo, mobilePhone, userId,value);
        PartnerAccountModel model = new PartnerAccountModel();
        model.setUserId(userId);
        model.setAccount(accountNo);
        model.setUpdateTime(cn.hutool.core.date.DateUtil.now());
        model.setPartnerId(id+"");
        model.setOverdraftLimit("0");
        model.setFixedLimit("0");
        model.setType(OrderEnum.账户打包站.getValue());
        partnerAccountMapper.addPartnerAccount(model);
        //写入消息列表中
        String message = "新建打包站成功,您的账号为："+accountNo+"，初始密码为：888888";
        sysMessageMapper.insertMessage(message,userId,"","1","新建打包站",DateUtil.now());

    }

    public void addAccountInfo(String mobilePhone,String userId,String accountNo,Long id,Long roleId){
        // 添加账号表
        String value = "0";
        accountMapper.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(cn.hutool.core.date.DateUtil.now());
            model.setPartnerId(id+"");
            model.setType(OrderEnum.账户合伙人.getValue());
            partnerAccountMapper.addPartnerAccount(model);
        }
        coreUserRole.setOrgId(Long.parseLong("9"));
        //String uId = userId.substring(userId.length()-6,userId.length());
        //coreUserRole.setUserId(Long.parseLong(uId));
        coreUserRole.setUserId(id);
        coreUserRoleMapper.insert(coreUserRole);

        //写入消息列表中
        String message = "新建合伙人成功,您的账号为："+accountNo+"，初始密码为：888888";
        sysMessageMapper.insertMessage(message,userId,"","1","新建合伙人",DateUtil.now());


    }


    /**
     * 修改合伙人
     * @param model
     * @return
     */
    public JsonResult<String> updatePartner(XzxCityPartnerModel model){
        //判断是否有分配key
        String key = model.getPartnerKeys();
        if(model.getPartnerType().equals("1")){
            if(null==key&&"".equals(model.getPartnerKeys())){
                return JsonResult.failMessage(" 修改失败，合伙人key不能为空！");
            }
        }

        List<AreaModel> areaModelList = model.getAreaList();
        if(model.getPartnerType().equals("1")) {
            if(null==areaModelList&&areaModelList.size()==0){
                return JsonResult.failMessage(" 添加失败，合伙人地区不能为空！");
            }
        }

        model.setDelFlag(0);
        model.setCreateTime(DateUtil.now());
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        CityPartner info = objectMapper.convertValue(model, CityPartner.class);
        info.setPartnerKey(key);
        if(model.getPartnerType().equals("1")){
            CityPartner partner=queryById(info.getId()+"");
            if (null == info.getOrgId()) {
                info.setOrgId(partner.getOrgId());
            }
            info.setState("S1");
        }else{
            if(null==info.getOrgId()){
                info.setOrgId(16);
            }
            info.setState("S1");
        }
        if(update(info)){
            //删除合伙人原有区域
            deletePartnerTownCode(info.getId()+"");

            List<AreaModel> oldAreaModel = model.getOldAreaList();
            //需要新增的区域
            List<String> newArea = new ArrayList<>();
            //需要减少的区域
            List<String> oldAreaList = new ArrayList<>();
            List<String> subArea = new ArrayList<>();
            List<String> addArea = new ArrayList<>();
            for (AreaModel oldArea:oldAreaModel) {
                oldAreaList.add(oldArea.getTownName());
            }
            for (AreaModel addAreaModel:areaModelList) {
                addArea.add(addAreaModel.getTownName());
            }
            //是否有新区域

            for (String townName:addArea) {
                boolean flag=false;
                String townIdPackage = "";
                if (oldAreaList.contains(townName)) {
                    flag =  true;
                }
                townIdPackage = queryAreaTownList(townName);
                if(!flag){
                    newArea.add(townIdPackage);
                }
            }
            //减少的区域
            for (String oldTown:oldAreaList) {
                boolean flag=false;
                String townIdPackage = "";
                if (addArea.contains(oldTown)) {
                    flag =  true;
                }
                townIdPackage = queryAreaTownList(oldTown);
                if(!flag){
                    subArea.add(townIdPackage);
                }
            }
            if(null!=newArea&&newArea.size()>0){
                initGoodsByPartner(info.getId()+"",newArea);
            }
            if(null!=subArea&&subArea.size()>0){
                sysEnvironmentalInfoMapper.deleteGoods(info.getId()+"",subArea);
                bannerMapper.delBannerApiByTown(info.getId()+"",subArea);
            }

            insertGaodeTown(areaModelList,info.getId()+"",model.getPartnerKeys());


            return JsonResult.success("修改成功！");
        }else{
            return JsonResult.failMessage("修改合伙人失败！");
        }
    }


    private String checkSamePartnerName(XzxCityPartnerModel model, List<AreaModel> areaModelList, String mobile){
        String key = model.getPartnerKeys();
        if(model.getPartnerType().equals("1")){
            if(null==key&&"".equals(model.getPartnerKeys())){
                return " 添加失败，合伙人key不能为空！";
            }
        }
        if(model.getPartnerType().equals("1")) {
            if(null==areaModelList&&areaModelList.size()==0){
                return " 添加失败，合伙人地区不能为空！";
            }
        }
        //判断是否有该合伙人手机号
        if(null!=mobile&&!"".equals(mobile)){
            List<CityPartner> list = queryPartnerByMobile(model);
            if(null!=list&&list.size()>0){
                return " 添加失败，手机号码、合伙人或打包站名称不能重复！";
            }
        }
        return null;
    }

    private List<String> insertGaodeTown(List<AreaModel> areaModelList,String partnerId,String key){
        List<PartnerGaodeModel>  townCodeList = new ArrayList<>();
        List<String> townIds = new ArrayList<>();
        for (AreaModel area:areaModelList) {
            String city = area.getCityName();
            String cityId = queryAreaCityList(city);
            String cityPackage = area.getCityName();
            String cityIdPackage = queryAreaCityList(cityPackage);
            String provinceName = area.getProvinceName();
            String townName = area.getTownName();
            String townIdPackage = queryAreaTownList(townName);
            townIds.add(townIdPackage);
            PartnerGaodeModel gaodeModel = new PartnerGaodeModel();
            gaodeModel.setCityId(cityIdPackage);
            if(null!=townName&&!"".equals(townName)){
                gaodeModel.setAddressArea(provinceName+","+cityPackage+","+townName);
            }else{
                gaodeModel.setAddressArea(provinceName+","+cityPackage);

            }
            gaodeModel.setTownId(townIdPackage);
            gaodeModel.setCityId(cityId);
            gaodeModel.setCreateTime(DateUtil.now());
            gaodeModel.setPartnerId(partnerId);
            gaodeModel.setPartnerKey(key);
            gaodeModel.setDelFlag("0");
            townCodeList.add(gaodeModel);
        }
        insertGaodeInfo(townCodeList);
        return townIds;
    }

    private void insertUserOther(CityPartner info,String userId){
        UserModel otherInfo = new UserModel();
        otherInfo.setName(info.getPartnerName());
        otherInfo.setDelFlag("0");
        otherInfo.setMobilePhone(info.getMobilePhone());
        otherInfo.setLoginAccount(userId);
        otherInfo.setRoleIds("3");
        otherInfo.setUserType("5");
        otherInfo.setUserId(userId);
        String salt = RandomUtil.randomString(16);
        otherInfo.setSalt(salt);
        String pass = SecurityUtil.encrypt(salt,info.getPassword());
        otherInfo.setPassword(pass);
        otherInfo.setRegistTime(DateUtil.now());
        otherInfo.setIsProhibit("0");
        otherInfo.setPartnerId(info.getId()+"");
        otherUserMapper.insertUserOtherInfo(otherInfo);
    }

    private void insertUserOtherPackage(CityPartner info,String userId,String cityId){
        UserModel otherInfo = new UserModel();
        otherInfo.setName(info.getPartnerName());
        otherInfo.setDelFlag("0");
        otherInfo.setMobilePhone(info.getMobilePhone());
        otherInfo.setLoginAccount(userId);
        otherInfo.setRoleIds("6");
        otherInfo.setUserType("7");
        otherInfo.setCityId(cityId);
        otherInfo.setUserId(userId);
        String salt =  RandomUtil.randomString(16);
        otherInfo.setSalt(salt);
        String pass = SecurityUtil.encrypt(salt,"888888");
        otherInfo.setPassword(pass);
        otherInfo.setRegistTime(DateUtil.now());
        otherInfo.setIsProhibit("0");
        otherInfo.setPartnerId(info.getId()+"");

        otherInfo.setAvatar(Constants.DEFAULT_AVATAR);
        otherUserMapper.insertUserOtherInfo(otherInfo);

    }

    //初始化合伙人的物品价格
    private void initGoodsByPartner(String partnerId,List<String> cityIds){
        List<SysEnvironmentalInfo> list = sysEnvironmentalInfoService.findByCityId(Constants.TIANXIN_CODE);

        List<SysEnvironmentalInfo> fatherList=new ArrayList<>();
        List<SysEnvironmentalInfo> childList=new ArrayList<>();


        for (String cityId:cityIds) {

            //排除自营区的分类
            if(!Constants.TIANXIN_CODE.equals(cityId)) {

                //先加父类 再加子类
                for (SysEnvironmentalInfo item : list) {
                    SysEnvironmentalInfo dto=new SysEnvironmentalInfo();
                    BeanUtil.copyProperties(item,dto);
                    Long parentId=item.getParentId();
                    //父类
                    if(parentId==null){
                        dto.setCityId(Convert.toInt(cityId));
                        dto.setPartnerId(partnerId);
                        dto.setCreateTime(DateUtil.now());
                        fatherList.add(dto);
                    }
                }

                if(CollUtil.isNotEmpty(fatherList)){
                    sysEnvironmentalInfoService.insertBatch(fatherList);
                    //再加子类
                    for (SysEnvironmentalInfo item : list) {
                        Long parentId=item.getParentId();
                        //父类
                        if(parentId!=null){
                            SysEnvironmentalInfo dto=new SysEnvironmentalInfo();
                            BeanUtil.copyProperties(item,dto);
                            dto.setCityId(Convert.toInt(cityId));
                            dto.setPartnerId(partnerId);
                            dto.setCreateTime(DateUtil.now());
                            String fatherItemType = list.stream().filter(x -> x.getId().equals(parentId)).collect(Collectors.toList()).get(0).getItemType();
                            Long fatherId = fatherList.stream().filter(x -> x.getItemType().equals(fatherItemType)).collect(Collectors.toList()).get(0).getId();
                            dto.setParentId(fatherId);
                            childList.add(dto);
                        }
                    }

                    if(CollUtil.isNotEmpty(childList)) {
                        sysEnvironmentalInfoService.insertBatch(childList);
                    }
                }


            }
        }
    }

    public JsonResult updatePartnerProhibit(XzxCityPartnerModel model){
        CityPartner info=queryById(model.getId());
        String msg = checkPackageProhibit(model);
        if(null!=msg){
            return JsonResult.failMessage(msg);
        }
        if(model.getProhibit()==0){
            info.setProhibit(false);
        }else{
            info.setProhibit(true);
        }

        info.setUpdateTime(DateUtil.now());
        update(info);
        otherUserMapper.updateOtherUserById1(info.getId()+"");
        return JsonResult.success("修改成功");
    }

    private String checkPackageProhibit(XzxCityPartnerModel model){
        //判断是否合伙人身份
        CoreUser user = sessionUtil.getCurrentUser();
        CityPartner partner = queryById(user.getId());
        if(null!=partner){
            //查询打包站账户余额是否为0
            String hbb = queryAccountByPartnerId(partner.getUserId());
            BigDecimal m = new BigDecimal(hbb);
            if(m.compareTo(BigDecimal.ZERO)==1){
                return "打包站账户余额不为零，无法关闭打包站！";
            }
        }
        return null;
    }

}