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.FundManagementApiDao;
import com.ibeetl.admin.console.dao.PayConsoleDao;
import com.ibeetl.admin.console.dao.XzxCityPartnerDao;
import com.ibeetl.admin.console.dao.XzxSysAddressLevelInfoDao;
import com.ibeetl.admin.console.model.*;
import com.ibeetl.admin.console.util.DateUtil;
import com.ibeetl.admin.console.util.DoubleUtil;
import com.ibeetl.admin.console.util.HttpClientUtils;
import com.ibeetl.admin.core.entity.CoreUser;
import com.ibeetl.admin.core.entity.XzxAccountInfo;
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.service.CorePlatformService;
import com.ibeetl.admin.core.util.PlatformException;
import com.ibeetl.admin.core.web.JsonResult;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.poi.sl.usermodel.Placeholder;
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 org.springframework.web.bind.annotation.RequestBody;

import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;


/**
 * XzxCityPartner Service
 */

@Service
@Transactional
public class XzxCityPartnerService extends CoreBaseService<XzxCityPartner> {

    @Autowired
    private XzxCityPartnerDao xzxCityPartnerDao;
    @Autowired
    private FundManagementApiDao fundManagementApiDao;
    @Autowired
    PayConsoleDao payConsoleDao;
    @Autowired
    private XzxSysAddressLevelInfoDao xzxSysAddressLevelInfoDao;
    @Autowired
    private XzxUserShareInfoService shareInfoService;
    @Autowired
    CuserConsoleService cuserConsoleService;
    @Autowired
    XzxCityPartnerService cityPartnerService;
    @Autowired
    PayConsoleService payLogService;
    @Autowired
    CorePlatformService platformService;
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    final org.apache.commons.codec.binary.Base64 base64 = new Base64();

    public PageQuery<XzxCityPartner> queryByCondition(PageQuery query) {
        PageQuery ret = xzxCityPartnerDao.queryByCondition(query);
        queryListAfter(ret.getList());
        return ret;
    }

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

    public XzxCityPartner queryEntityByUserIds(String userId) {
        return xzxCityPartnerDao.queryEntityByUserIds(userId);
    }

    public void batchDelXzxCityPartner(List<Long> ids) {
        try {
            xzxCityPartnerDao.batchDelXzxCityPartnerByIds(ids);
        } catch (Exception e) {
            throw new PlatformException("批量删除XzxCityPartner失败", e);
        }
    }

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

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

    public AreaModel queryAreaLongiLati(AreaModel model) {
        return xzxCityPartnerDao.queryAreaLongiLati(model);
    }

    public List<String> queryAreaLongiLatiList(String city) {
        return xzxCityPartnerDao.queryAreaLongiLatiList(city);
    }

    public void deletePartnerAccount(XzxCityPartner partner) {
        PartnerAccountModel model = new PartnerAccountModel();
        model.setDelFlag(1);
        model.setUserId(partner.getUserId());
        xzxCityPartnerDao.deletePartnerAccount(model);
        xzxCityPartnerDao.deleteAccountByUserId(model);
    }

    public String deleteServiceByKey(XzxCityPartner partner) {
        String key = partner.getPartnerKey();
        String url = "https://tsapi.amap.com/v1/track/service/delete";
        List<String> sidList = xzxCityPartnerDao.querySidListByPartnerId(partner.getId() + "");
        /*List<String> sidList= new ArrayList<>();
        sidList.add("117858");
        sidList.add("117878");*/
        for (String sid : sidList) {
            Map<String, String> map = new HashMap<>();
            map.put("key", key);
            map.put("sid", sid);
            String result1 = HttpClientUtils.doPost(url, map);
            System.out.println("删除服务返回：" + result1);
        }
        int num = xzxCityPartnerDao.deleteGaodeService(partner.getId() + "");
        return num + "";
    }

    public String createServiceByKey(XzxCityPartner partner) {
        String name1 = "回收员轨迹_" + partner.getId();
        String name2 = "推广员轨迹_" + partner.getId();
        String url = "https://tsapi.amap.com/v1/track/service/add";

        String key = partner.getPartnerKey();
        Map<String, String> map1 = new HashMap<>();
        Map<String, String> map2 = new HashMap<>();
        String result1 = "";
        String result2 = "";
        if (null != key && !"".equals(key)) {
            map1.put("key", key);
            map1.put("name", name1);
            map2.put("key", key);
            map2.put("name", name2);
            result1 = HttpClientUtils.doPost(url, map1);
            result2 = HttpClientUtils.doPost(url, map2);
        } else {
            return null;
        }

        Map maps1 = (Map) JSON.parse(result1);
        Map maps2 = (Map) JSON.parse(result2);
        if (null != maps1.get("data")) {
            String str1 = maps1.get("data").toString();
            String str2 = maps2.get("data").toString();
            Map mapsHsy = (Map) JSON.parse(str1);
            Map mapsTgy = (Map) JSON.parse(str2);
            String sid1 = mapsHsy.get("sid").toString();
            String sid2 = mapsTgy.get("sid").toString();
            String r1 = createGaodeAddress(key, sid1, "string");
            String r2 = createGaodeAddress(key, sid2, "string");
            PartnerTraceModel model1 = new PartnerTraceModel();
            model1.setDelFlag(0);
            model1.setCreateTime(sdf.format(new Date()));
            model1.setPartnerId(partner.getId() + "");
            model1.setPartnerKey(key);
            model1.setPartnerServiceId(sid1);
            model1.setPartnerServiceType("1");
            int num1 = insertGaodeSid(model1);
            if (num1 > 0) {
                model1.setPartnerServiceId(sid2);
                model1.setPartnerServiceType("2");
                int num2 = insertGaodeSid(model1);
                return num2 + "";
            } else {
                return null;
            }
        }
        return null;

    }

    private String createGaodeAddress(String key, String sid, String type) {
        String url = "https://tsapi.amap.com/v1/track/point/column/add";
        Map<String, String> map1 = new HashMap<>();
        map1.put("key", key);
        map1.put("sid", sid);
        map1.put("column", "address");
        map1.put("type", type);
        String result = HttpClientUtils.doPost(url, map1);
        System.out.println("=============高德返回" + result);
        return result;
    }

    private int insertGaodeSid(PartnerTraceModel model) {
        return xzxCityPartnerDao.insertGaodeSid(model);
    }

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

    public String queryAreaProvinceList(String city) {
        return xzxCityPartnerDao.queryAreaProvinceList(city);
    }

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

    public String queryGaodeByTownId(String townId) {
        return xzxCityPartnerDao.queryGaodeByTownId(townId);
    }

    public XzxCityPartner queryCityPartnerByCityId(String city) {
        String partnerId = xzxCityPartnerDao.queryPartnerByCity(city);
        if (null != partnerId && !"".equals(partnerId)) {
            return xzxCityPartnerDao.queryPartnerById(Long.parseLong(partnerId));

        } else {
            return null;
        }
    }

    public String queryAccountByPartnerId(String userId) {
        return xzxCityPartnerDao.queryAccountByPartnerId(userId);
    }

    public Map<String, Object> queryPartnerAccount(String userId) {
        String accountInfoMoney = xzxCityPartnerDao.queryAccountByPartnerId(userId);
        if (null != accountInfoMoney && !"".equals(accountInfoMoney)) {
            accountInfoMoney = DoubleUtil.roundTwo(accountInfoMoney);
        } else {
            accountInfoMoney = "0.00";
        }
        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 xzxCityPartnerDao.queryPartnerAdmin(id);
    }

    public List<XzxCityPartner> queryAllCityPartnerList(String partnerId) {
        return xzxCityPartnerDao.queryAllCityPartnerList(partnerId);
    }

    public List<XzxCityPartner> queryPartnerName(List<String> partnerIds) {
        return xzxCityPartnerDao.queryPartnerName(partnerIds);
    }

    public List<XzxCityPartner> queryPackageByPartner(List<String> partnerIds) {
        return xzxCityPartnerDao.queryPackageByPartner(partnerIds);
    }

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

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

    public List<String> queryAllUserIds() {
        return xzxCityPartnerDao.queryAllUserIds();
    }

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

    public int queryAccountByUserIdsCount(AccountMoneyModel model) {

        return xzxCityPartnerDao.queryAccountByUserIdsCount(model);
    }
    public void updateAccountLimitByPid(PartnerAccountModel pa){
         xzxCityPartnerDao.updateAccountLimitByPid(pa);
    }
    public List<String> queryUserIdsByPid(String partnerId){
        return xzxCityPartnerDao.queryUserIdsByPid(partnerId);
    }
    public int updateAccountLimit(AccountMoneyModel model) {
        AccountMoneyModel oldModel = xzxCityPartnerDao.queryAccountByAccountId(model);
        String message ="";
        String packageUserId="";
        UserModel userModel = cuserConsoleService.queryUserOtherById(oldModel.getUserId());
        BigDecimal newOl = new BigDecimal("0");
        if (null != userModel) {
            if (null != userModel.getPartnerId()) {
                if (userModel.getUserType().equals("7")) {
                    PartnerAccountModel pa = xzxCityPartnerDao.queryAccountIdByUserId(userModel.getUserId());

                    if (null != pa.getFixedLimit()) {
                        if (null != pa.getOverdraftLimit()) {
                        } else {
                            pa.setOverdraftLimit("0");
                        }
                        BigDecimal pao = new BigDecimal(pa.getOverdraftLimit());
                        newOl = new BigDecimal(model.getFixedLimit()).subtract(new BigDecimal(pa.getFixedLimit()));
                        BigDecimal overFlag = pao.add(newOl);
                        if (overFlag.compareTo(BigDecimal.ZERO) == -1) {
                            return -1;
                        }
                        pao=overFlag;
                        pa.setOverdraftLimit(pao.toString());
                    } else {
                        pa.setOverdraftLimit(model.getFixedLimit());
                    }
                    pa.setFixedLimit(model.getFixedLimit());
                    //调整打包站额度
                    cityPartnerService.updatePackageAccount(pa);

                    String partnerId = userModel.getPartnerId();
                    XzxCityPartner partner = cityPartnerService.queryById(Long.parseLong(partnerId));
                    Snowflake snowflake = IdUtil.getSnowflake(0, 3);
                    String payOrderId = "ZF" + snowflake.nextIdStr();
                    pa.setType("7");
                    insertPackageAccountLog(pa,payOrderId,DoubleUtil.roundTwo(newOl.toString()));
                    if (partner.getPartnerType().equals("2")) {
                        partner = cityPartnerService.queryById(partner.getPackingStation());
                    }
                    String type = "8";
                    //调整额度时需要扣除合伙人额度
                    UserAccountModel partnerAccount = queryPartnerAccountByUserId(partner.getUserId());
                    PartnerAccountModel partnerAccountModel = getPartnerAccountByUserId(partner.getUserId());


                    if (newOl.compareTo(BigDecimal.ZERO) == -1) {
                        type = "14";
                    }
                    insertPartnerAccountLog(partnerAccount, type, newOl, payOrderId, "7");
                    BigDecimal newPartnerMoney = new BigDecimal(partnerAccount.getMoney()).subtract(newOl);
                    if (newPartnerMoney.compareTo(BigDecimal.ZERO) == -1) {
                        return -1;
                    }
                    partnerAccount.setMoney(newPartnerMoney.doubleValue());
                    partnerAccountModel.setHbb(DoubleUtil.roundTwo(newPartnerMoney.toString()));
                    partnerAccountModel.setMoney(DoubleUtil.roundTwo(newPartnerMoney.toString()));
                    cityPartnerService.updateAccountPartner(partnerAccount);
                    cityPartnerService.updatePartnerAccount(partnerAccountModel);
                    //将打包员的额度置为0
                    //List<String> userIds = cityPartnerService.queryUserIdsByPid(pa.getPartnerId());
                    //pa.setUserIds(userIds);
                    //cityPartnerService.updateAccountLimitByPid(pa);
                    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 (overFlag.compareTo(BigDecimal.ZERO) == -1) {
                        return -1;
                    }
                    oldModel.setOverdraftLimit(DoubleUtil.roundTwo(oldol.add(newOl).toString()));
                    oldModel.setFixedLimit(DoubleUtil.roundTwo(ollimit.add(newOl).toString()));

                    String type = "8";
                    //调整额度时需要扣除合伙人额度
                    String partnerId = userModel.getPartnerId();
                    XzxCityPartner partner = cityPartnerService.queryById(partnerId);
                    UserAccountModel partnerAccount = queryPartnerAccountByUserId(partner.getUserId());
                    PartnerAccountModel partnerAccountModel = getPartnerAccountByUserId(partner.getUserId());

                    Snowflake snowflake = IdUtil.getSnowflake(0, 3);
                    String payOrderId = "ZF" + snowflake.nextIdStr();
                    if (newOl.compareTo(BigDecimal.ZERO) == -1) {
                        type = "14";
                    }
                    insertPartnerAccountLog(partnerAccount, type, newOl, payOrderId, "7");

                    BigDecimal newPartnerMoney = new BigDecimal(partnerAccount.getMoney()).subtract(newOl);
                    if (newPartnerMoney.compareTo(BigDecimal.ZERO) == -1) {
                        return -1;
                    }
                    partnerAccount.setMoney(newPartnerMoney.doubleValue());
                    partnerAccountModel.setMoney(DoubleUtil.roundTwo(newPartnerMoney.toString()));
                    partnerAccountModel.setHbb(DoubleUtil.roundTwo(newPartnerMoney.toString()));
                    cityPartnerService.updateAccountPartner(partnerAccount);
                    cityPartnerService.updatePartnerAccount(partnerAccountModel);
                    xzxCityPartnerDao.updateAccountLimit(oldModel);
                }

            }
        } else {
            return 0;
        }
        if(null!=message&&!"".equals(message)){
            payConsoleDao.insertMessage(message, packageUserId, "", "1", "额度调整", sdf.format(new Date()));

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

        }

        return 1;
    }

    public List<AccountMoneyModel> queryAccountByUserIds(AccountMoneyModel model) {
        int p = model.getPage();
        p = (p - 1) * model.getLimit();
        model.setPage(p);
        List<AccountMoneyModel> list = xzxCityPartnerDao.queryAccountByUserIds(model);
        for (AccountMoneyModel mm : list) {
            UserModel userModel = cuserConsoleService.queryUserOtherInfoById(mm.getUserId());
            mm.setMoney(DoubleUtil.roundTwo(mm.getMoney()));
            if (null != userModel) {
                if (userModel.getUserType().equals("7")) {
                    //查询打包站额度
                    String partnerId = userModel.getPartnerId();
                    XzxCityPartner partner = xzxCityPartnerDao.queryPartnerById(Long.parseLong(partnerId));
                    PartnerAccountModel partnerAccountModel = xzxCityPartnerDao.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 {
                    mm.setMobilePhone(userModel.getMobilePhone());
                    mm.setUserName(userModel.getName());
                    mm.setRegistTime(userModel.getRegistTime());
                    mm.setRoleType(userModel.getUserType());
                }

            } else {
                userModel = cuserConsoleService.queryUserById(mm.getUserId());
                mm.setMobilePhone(userModel.getMobilePhone());
                if (null != userModel.getNickName() && !"".equals(userModel.getNickName())) {
                    try {
                        mm.setUserName(new String(base64.decode(userModel.getNickName()), "UTF-8"));
                    } catch (UnsupportedEncodingException e) {
                        e.printStackTrace();
                    }
                } else {
                    mm.setUserName("--");
                }
                mm.setRegistTime(userModel.getRegistTime());
                mm.setRoleType("1");
            }

        }

        return list;
    }

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

    public int queryPartnerGaode(List<AreaModel> areaList){
        List<String> list = new ArrayList<>();
        for (AreaModel area:areaList) {
            list.add(area.getTownName());
        }
        return xzxCityPartnerDao.queryPartnerGaode(list);
    }
    public List<String> queryPartnerByCurrent() {
        //查询合伙人列表
        List<String> partnerIds = new ArrayList<>();
        CoreUser user = platformService.getCurrentUser();

        if (user.getId() == 1) {
            //如果是超管 显示全部投诉订单信息
            partnerIds = null;
        } else {
            //如果是运营管理员 显示
            if (user.getOrgId() == 10) {
                partnerIds = null;
            } else {
                //合伙人显示 该合伙人和名下合伙人的所有订单。
                partnerIds.add(user.getId() + "");
                //多级合伙人带拓展
                //List<String> childPartnerIds = xzxOrderComplaintDao.queryChildPids(user.getId()+"");
            }

        }
        return partnerIds;
    }

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


    public Map<String, Object> queryCityPartnerForOtherUser() {
        List<String> partnerIds = queryPartnerByCurrent();
        List<UserModel> list1 = xzxCityPartnerDao.queryCityPartnerForOtherUser(partnerIds, "2");
        List<UserModel> list2 = xzxCityPartnerDao.queryCityPartnerForOtherUser(partnerIds, "6");
        Map<String, Object> map = new HashMap<>();
        map.put("code", 0);
        map.put("hsyData", list1);
        map.put("tgyData", list2);
        return map;
    }

    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<>();
        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");
        }
        if (null != model.getPartnerType()) {
            if (model.getPartnerType().equals("2")) {
                model.setPartnerIdList(null);
            }
        } else {
            model.setPartnerType("1");
        }

        List<XzxCityPartnerModel> list = xzxCityPartnerDao.queryCityPartner(model);
        for (XzxCityPartnerModel obj : list) {
            List<List<String>> townList = new ArrayList<>();

            List<AreaModel> areaList = xzxCityPartnerDao.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 = xzxCityPartnerDao.queryGaodeByParentner(obj.getId());
            obj.setAreaList(areaList);
            //当前只支持多选
            if (cityIdList.size() > 0) {
                cityName = xzxCityPartnerDao.queryCityNameById(cityIdList.get(0));
            }
            //if(obj.getPartnerType().equals("2")){
            //打包站前端需要返回list地址
            PartnerGaodeModel gaodeModel = new PartnerGaodeModel();
            gaodeModel = xzxCityPartnerDao.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 = xzxCityPartnerDao.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 = xzxCityPartnerDao.queryCitysByPartnerId(obj.getId());
            String cityName1 = "";
            for (String cityId : citys) {
                String named = xzxCityPartnerDao.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 = cuserConsoleService.queryUserOtherById(userId);
                cityName = cuserConsoleService.queryAreaName("2", userModel.getCityId());
                obj.setCityId(userModel.getCityId());
                obj.setCityName(cityName);
            }

            if (null != obj.getPackingStation() && !"".equals(obj.getPackingStation())) {
                XzxCityPartner partner = xzxCityPartnerDao.queryPartnerById(Long.parseLong(obj.getPackingStation()));
                obj.setPackingStationName(partner.getPartnerName());
            }
        }
        int num = xzxCityPartnerDao.queryCityPartnerCount(model);
        map.put("code", 0);
        map.put("data", list);
        map.put("count", num);
        return map;
    }

    public Map<String, Object> queryDetailsPresentation(PartnerPayMsgModel model) {
        List<String> partnerIds = queryPartnerByCurrent();
        model.setPartnerIds(partnerIds);
        Map<String, Object> map = new HashMap<>();
        int p = model.getPage();
        p = (p - 1) * model.getLimit();
        model.setPage(p);
        model.setUserId(model.getUserId());

        List<PartnerPayMsgModel> list = xzxCityPartnerDao.queryDetailsPresentation(model);
        for (PartnerPayMsgModel model1 : list
        ) {
            model1.setMoney(DoubleUtil.roundTwo(model1.getMoney()));
        }
        int count = 0;
        if (null != list && list.size() > 0) {
            count = xzxCityPartnerDao.queryDetailsPresentationCount(model);
        }
        map.put("code", 0);
        map.put("data", list);
        map.put("count", count);
        return map;
    }

    public String addPayInfoImg(PayInfoModel model) {
        Snowflake snowflake1 = IdUtil.getSnowflake(0, 3);
        String payOrderId = "ZF" + snowflake1.nextIdStr();
        RemittanceModel remittanceModel = new RemittanceModel();
        remittanceModel.setBankName("长沙银行股份有限公司鑫泰支行");
        remittanceModel.setCompany("湖南小棕熊环保科技有限公司");
        remittanceModel.setCompanyAccount("800271283808014");
        remittanceModel.setCreateTime(sdf.format(new Date()));
        remittanceModel.setRechargeName(model.getRechargeName());
        remittanceModel.setRechargePhone(model.getRechargePhone());
        remittanceModel.setPayOrderId(payOrderId);
        CoreUser user = platformService.getCurrentUser();
        XzxCityPartner partner = xzxCityPartnerDao.queryPartnerById(user.getId());
        if (null == partner) {
            if (null != model.getPartnerId() && !"".equals(model.getPartnerId())) {
                partner = xzxCityPartnerDao.queryPartnerById(Long.parseLong(model.getPartnerId()));
            }
        }else{
            if(null!=model.getPartnerId()&&!"".equals(model.getPartnerId())){
                partner = xzxCityPartnerDao.queryPartnerById(Long.parseLong(model.getPartnerId()));

            }
        }
        remittanceModel.setCreateUserId(partner.getUserId() + "");
        xzxCityPartnerDao.insertRemittance(remittanceModel);


        model.setPayOrderId(payOrderId);
        model.setCreateUserId(partner.getUserId() + "");

        int num = xzxCityPartnerDao.addPayInfo(model);
        PartnerAccountLogModel log = new PartnerAccountLogModel();
        log.setFlowNo(payOrderId);
        log.setCreateTime(sdf.format(new Date()));
        log.setApproverStatus("1");
        log.setMoney(model.getMoney());
        log.setHbb(model.getMoney());
        log.setDelFlag(0);
        log.setAccountId(partner.getAccountNo());
        log.setUserName(partner.getPartnerName());
        log.setType("1");
        log.setUserPhone(partner.getMobilePhone());
        if (partner.getPartnerType().equals("1")) {
            log.setRoleName("城市合伙人");
        } else {
            log.setRoleName("打包站");
        }

        xzxCityPartnerDao.addPartnerAccountLog(log);
        return num + "";
    }

    public int addPayInfo1(PayInfoModel model) {
        return xzxCityPartnerDao.addPayInfo1(model);
    }

    public int addPayInfo(PayInfoModel model) {
        CoreUser user = platformService.getCurrentUser();
        model.setAccountId("");
        model.setStatus("1");
        model.setPayType("1");
        model.setCreateUserId(user.getId() + "");
        model.setCreateTime(sdf.format(new Date()));
        return xzxCityPartnerDao.addPayInfo(model);
    }

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

    public void updateAccountPartner(UserAccountModel accountModel) {
        xzxCityPartnerDao.updateAccountPartner(accountModel);
        //return  null
    }

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

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

    public void insertPackageAccountLog(PartnerAccountModel partnerAccountModel, String payOrderId, String money) {
        XzxCityPartner partner = xzxCityPartnerDao.queryEntityByUserIds(partnerAccountModel.getUserId());
        PartnerAccountLogModel partnerLog = new PartnerAccountLogModel();
        partnerLog.setFlowNo(payOrderId);
        partnerLog.setCreateTime(sdf.format(new Date()));
        partnerLog.setApproverStatus("1");
        if(null!=partnerAccountModel.getType()&&!"".equals(partnerAccountModel.getType())){
            if(partnerAccountModel.getType().equals("7")){
                partnerLog.setMoney(DoubleUtil.roundTwo(money));
                partnerLog.setHbb(DoubleUtil.roundTwo(partnerAccountModel.getFixedLimit()));
                BigDecimal oldLimit = new BigDecimal(partnerAccountModel.getFixedLimit());
                oldLimit =oldLimit.subtract(new BigDecimal(money));
                partnerLog.setAccountMoney(DoubleUtil.roundTwo(oldLimit.toString()));
            }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("打包站");
        xzxCityPartnerDao.addPartnerAccountLog(partnerLog);
    }
    public void insertAccountLogByPartner(UserAccountModel accountModel, String type, BigDecimal money, String payOrderId) {
        //写入日志
        AccountLogModel log = new AccountLogModel();
        log.setAccountId(accountModel.getAccountId());
        log.setChannelType(type);
        log.setCreateTime(sdf.format(new Date()));
        log.setCreateUserId(accountModel.getUserId());
        log.setNewFixedLimit(DoubleUtil.roundTwo("0"));
        log.setNewLimit(DoubleUtil.roundTwo("0"));
        log.setNewMoney(DoubleUtil.roundTwo(new BigDecimal(accountModel.getMoney()).add(money).toString()));
        log.setOldFixedLimit(DoubleUtil.roundTwo("0"));
        log.setOldLimit(DoubleUtil.roundTwo("0"));
        log.setOldMoney(DoubleUtil.roundTwo(accountModel.getMoney() + ""));
        log.setOrderId(payOrderId);
        payLogService.insertAccountLog(log);
    }
    public void insertPartnerLogByPartner(PartnerAccountModel accountModel, String type, String money, String payOrderId,XzxCityPartner partner,String newMoney) {
        //写入日志
        PartnerAccountLogModel partnerLog = new PartnerAccountLogModel();
        partnerLog.setAccountId(accountModel.getAccount());
        partnerLog.setType(type);
        partnerLog.setCreateTime(sdf.format(new Date()));
        partnerLog.setRoleName("城市合伙人");
        partnerLog.setMoney(money);
        partnerLog.setUserName(partner.getPartnerName());
        partnerLog.setUserPhone(partner.getMobilePhone());
        partnerLog.setAccountMoney(accountModel.getMoney());
        partnerLog.setHbb(newMoney);
        partnerLog.setFlowNo(payOrderId);
        partnerLog.setApproverStatus("1");
        partnerLog.setDelFlag(0);
        xzxCityPartnerDao.addPartnerAccountLog(partnerLog);
    }
    public void insertPartnerAccountLog(UserAccountModel accountModel, String type, BigDecimal money, String payOrderId, String packageType) {
        //写入日志
        AccountLogModel log = new AccountLogModel();
        log.setAccountId(accountModel.getAccountId());
        log.setChannelType(type);
        log.setCreateTime(sdf.format(new Date()));
        log.setCreateUserId(accountModel.getUserId());
        BigDecimal oldFixedLimit = new BigDecimal(String.valueOf(accountModel.getFixedLimit()));
        BigDecimal oldLimit = new BigDecimal(String.valueOf(accountModel.getOverdraftLimit()));
        BigDecimal oldMoney = new BigDecimal(accountModel.getMoney());
        log.setNewFixedLimit(accountModel.getFixedLimit());
        log.setNewLimit(accountModel.getLimit() + "");
        if(null!=accountModel.getAddType()&&!"".equals(accountModel.getAddType())){
            log.setNewMoney(DoubleUtil.roundTwo(new BigDecimal(accountModel.getMoney()).add(money).toString()));

        }else{
            log.setNewMoney(DoubleUtil.roundTwo(new BigDecimal(accountModel.getMoney()).subtract(money).toString()));

        }
        log.setOldFixedLimit(accountModel.getFixedLimit());
        log.setOldLimit(accountModel.getLimit() + "");
        log.setOldMoney(DoubleUtil.roundTwo(accountModel.getMoney() + ""));
        log.setOrderId(payOrderId);
        payLogService.insertAccountLog(log);
        XzxCityPartner partner = xzxCityPartnerDao.queryEntityByUserIds(accountModel.getUserId());
        PartnerAccountLogModel partnerLog = new PartnerAccountLogModel();
        partnerLog.setFlowNo(payOrderId);
        partnerLog.setCreateTime(sdf.format(new Date()));
        partnerLog.setApproverStatus("1");
        partnerLog.setMoney(DoubleUtil.roundTwo(money.toString()));
        partnerLog.setHbb(log.getNewMoney());
        partnerLog.setDelFlag(0);
        partnerLog.setAccountId(accountModel.getAccountId());
        partnerLog.setAccountMoney(DoubleUtil.roundTwo(accountModel.getMoney() + ""));
        partnerLog.setUserName(partner.getPartnerName());
        if (null != packageType) {
            partnerLog.setType(packageType);

        } else {
            partnerLog.setType("1");

        }
        partnerLog.setUserPhone(partner.getMobilePhone());
        partnerLog.setRoleName("城市合伙人");
        xzxCityPartnerDao.addPartnerAccountLog(partnerLog);
    }

    public String queryAccountByAdminId() {
        return xzxCityPartnerDao.queryAccountByAdminId();
    }

    public int updatePlatformHbb(String hbb) {
        return fundManagementApiDao.updatePlatformHbb(hbb);
    }
    public int updatePlatformMoney(String money) {
        return fundManagementApiDao.updatePlatformMoney(money);
    }
    public void insertPlatFormLog(PlatformAccountLogModel model) {
        fundManagementApiDao.insertPlatFormLog(model);
    }

    public String updatePayInfoPass(PayInfoModel model) {
        String payOrderId = model.getPayOrderId();
        PayInfoModel payInfo = xzxCityPartnerDao.queryPayInfoById(payOrderId);
        String fee = "0";
        if (null != payInfo.getFee() && !"".equals(payInfo.getFee())) {
            fee = payInfo.getFee();
        }
        int num = xzxCityPartnerDao.updatePayInfoPass(model);
        PartnerAccountLogModel log = new PartnerAccountLogModel();
        //审核通过，需要修改用户可用余额
        //1:查询合作人账号
        PartnerAccountModel pAccount = fundManagementApiDao.getPartnerAccountByUserId(model.getCreateUserId());
        String acc = xzxCityPartnerDao.queryAccountByAdminId();
        String[] accArr = acc.split(",");
        String adminMoney = accArr[1];
        String adminhbb = accArr[2];

        if (null != pAccount) {
            BigDecimal oldMoney = new BigDecimal("0");
            if(null!=pAccount.getHbb()){
                oldMoney = new BigDecimal(pAccount.getHbb());
            }else{
                pAccount.setHbb("0");
            }
            BigDecimal oldhbb = new BigDecimal(pAccount.getHbb());
            BigDecimal newhbb = oldhbb.add(new BigDecimal(payInfo.getMoney()));
            //平台
            BigDecimal oldAdminMoney = new BigDecimal(adminMoney);
            BigDecimal oldAdminhbb = new BigDecimal(adminhbb);
            CoreUser user = platformService.getCurrentUser();
            BigDecimal b3 = new BigDecimal(pAccount.getHbb());
            //平台账户处理充值
            BigDecimal newAdminMoney = oldAdminMoney.add(new BigDecimal(payInfo.getMoney()));
            BigDecimal newAdminhbb = oldAdminhbb.subtract(new BigDecimal(payInfo.getMoney()));
            log.setApprover(user.getName());
            log.setUpdateTime(sdf.format(new Date()));
            log.setApproverTime(sdf.format(new Date()));
            log.setHbb(b3.add(new BigDecimal(payInfo.getMoney())).toString());
            log.setFlowNo(payOrderId);
            log.setApproverStatus("2");
            if (pAccount.getType().equals("0")) {
                //合伙人充值
                //用户
                BigDecimal newMoney = oldMoney.subtract(new BigDecimal(payInfo.getMoney()));

                if (model.getStatus().equals("3")) {
                    BigDecimal b1 = new BigDecimal(pAccount.getHbb());
                    BigDecimal b2 = new BigDecimal(model.getMoney());
                    fundManagementApiDao.updateParterAccount(DoubleUtil.roundTwo(b3.add(b2).toString()), pAccount.getAccount());
                    fundManagementApiDao.updatePlatformMoney(DoubleUtil.roundTwo(newAdminMoney.toString()));
                    fundManagementApiDao.updatePlatformHbb(DoubleUtil.roundTwo(newAdminhbb.toString()));
                    //写流水日志


                    XzxCityPartner partner = queryById(pAccount.getPartnerId());
                    PartnerAccountModel pAccount1 = fundManagementApiDao.getPartnerAccountByUserId(partner.getUserId());
                    UserAccountModel account1 = fundManagementApiDao.getAccountByUserId(partner.getUserId());
                    String userM = "0";
                    if (null != pAccount1.getHbb() & !"".equals(pAccount1.getHbb())) {
                        userM = DoubleUtil.roundTwo(pAccount1.getHbb());
                    }
                    String packUserId = partner.getUserId();
                    System.out.println("打包员金额为：：" + userM + "打包员的UserId 为" + packUserId);
                    PlatformAccountLogModel platformAccountLogModel = new PlatformAccountLogModel();
                    platformAccountLogModel.setCreateTime(sdf.format(new Date()));
                    platformAccountLogModel.setCreateUserId(pAccount.getPartnerId());
                    platformAccountLogModel.setMoney(DoubleUtil.roundTwo(payInfo.getMoney()));
                    platformAccountLogModel.setHbb("-" + DoubleUtil.roundTwo(payInfo.getMoney()));
                    platformAccountLogModel.setOldHbb(DoubleUtil.roundTwo(oldAdminhbb.toString()));
                    platformAccountLogModel.setOldMoney(DoubleUtil.roundTwo(oldAdminMoney.toString()));
                    platformAccountLogModel.setNewHbb(DoubleUtil.roundTwo(newAdminhbb.toString()));
                    platformAccountLogModel.setNewMoney(DoubleUtil.roundTwo(newAdminMoney.toString()));
                    platformAccountLogModel.setCreateUserName(partner.getPartnerName());
                    platformAccountLogModel.setCreateUserType("2");
                    platformAccountLogModel.setCreateUserMobile(partner.getMobilePhone());
                    platformAccountLogModel.setFlowNo(payOrderId);
                    fundManagementApiDao.insertPlatFormLog(platformAccountLogModel);
                    fundManagementApiDao.updateParterAccountLog(log);
                    //同步合伙人普通账号
                    insertAccountLogByPartner(account1,"1",b2,payOrderId);

                    fundManagementApiDao.updateParterAccount1(DoubleUtil.roundTwo(b3.add(b2).toString()), pAccount.getAccount());
                } else {
                    log.setApproverStatus("3");
                }
            } else {
                //打包站充值 查询打包站的账号
                if (model.getStatus().equals("3")) {
                    XzxCityPartner packagePartner = xzxCityPartnerDao.queryPartnerById(Long.parseLong(pAccount.getPartnerId()));
                    XzxCityPartner partner = xzxCityPartnerDao.queryPartnerById(Long.parseLong(packagePartner.getPackingStation()));
                    fundManagementApiDao.updatePlatformMoney(DoubleUtil.roundTwo(newAdminMoney.toString()));
                    fundManagementApiDao.updatePlatformHbb(DoubleUtil.roundTwo(newAdminhbb.toString()));
                    if(pAccount.getOverdraftLimit().equals(pAccount.getFixedLimit())){
                        PartnerAccountModel newPackage = new PartnerAccountModel();
                        newPackage.setUserId(packagePartner.getUserId());
                        newPackage.setHbb(DoubleUtil.roundTwo(newhbb.toString()));
                        updatePartnerAccount(newPackage);
                        insertPackageAccountLog(pAccount, payOrderId, payInfo.getMoney());
                    }else{
                        BigDecimal ov = new BigDecimal(pAccount.getOverdraftLimit());
                        BigDecimal fl = new BigDecimal(pAccount.getFixedLimit());
                        BigDecimal pfMoney = new BigDecimal(payInfo.getMoney());
                        BigDecimal sfo =  fl.subtract(ov);
                        BigDecimal fla = sfo.subtract(pfMoney);
                        BigDecimal fla1 = pfMoney.subtract(sfo);
                        if(fla.compareTo(BigDecimal.ZERO)==-1){
                            pAccount.setOverdraftLimit(pAccount.getFixedLimit());
                            pAccount.setHbb(fla1.add(new BigDecimal(pAccount.getHbb())).toString());
                            updatePartnerAccount(pAccount);
                            insertPackageAccountLog(pAccount, payOrderId, payInfo.getMoney());
                        }else{
                            //pAccount.setHbb(pAccount.getHbb());
                            pAccount.setOverdraftLimit(DoubleUtil.roundTwo(ov.add(pfMoney).toString()));
                            updatePartnerAccount(pAccount);
                            insertPackageAccountLog(pAccount, payOrderId, payInfo.getMoney());
                        }

                    }

                    PlatformAccountLogModel platformAccountLogModel = new PlatformAccountLogModel();
                    platformAccountLogModel.setCreateTime(sdf.format(new Date()));
                    platformAccountLogModel.setCreateUserId(pAccount.getPartnerId());
                    platformAccountLogModel.setMoney(DoubleUtil.roundTwo(payInfo.getMoney()));
                    platformAccountLogModel.setHbb("-" + DoubleUtil.roundTwo(payInfo.getMoney()));
                    platformAccountLogModel.setOldHbb(DoubleUtil.roundTwo(oldAdminhbb.toString()));
                    platformAccountLogModel.setOldMoney(DoubleUtil.roundTwo(oldAdminMoney.toString()));
                    platformAccountLogModel.setNewHbb(DoubleUtil.roundTwo(newAdminhbb.toString()));
                    platformAccountLogModel.setNewMoney(DoubleUtil.roundTwo(newAdminMoney.toString()));
                    platformAccountLogModel.setCreateUserName(partner.getPartnerName());
                    platformAccountLogModel.setCreateUserType("2");
                    platformAccountLogModel.setCreateUserMobile(partner.getMobilePhone());
                    platformAccountLogModel.setFlowNo(payOrderId);
                    fundManagementApiDao.insertPlatFormLog(platformAccountLogModel);
                    fundManagementApiDao.updateParterAccountLog(log);
                } else {
                    log.setApproverStatus("3");
                }
            }
        }

        return num + "";
    }

    public List<XzxElectronicFenceModel> queryPartnerFenceList(XzxCityPartnerModel model) {
        CoreUser user = platformService.getCurrentUser();
        model.setId(user.getId() + "");
        List<XzxElectronicFenceModel> list = xzxCityPartnerDao.queryPartnerFenceList(model);
        return list;
    }

    public List<XzxElectronicFenceModel> queryPartnerFenceListByUser(XzxCityPartnerModel model) {
        CoreUser user = platformService.getCurrentUser();
        List<String> partnerIds = queryPartnerByCurrent();
        if (user.getId() == 1) {
            model.setId(null);
        } else {
            model.setId(user.getId() + "");
        }

        if (null != partnerIds && partnerIds.size() > 0) {
            model.setPartnerIds(partnerIds.get(0));
        }
        List<XzxElectronicFenceModel> list = xzxCityPartnerDao.queryPartnerFenceListByUser(model);
        return list;
    }

    public List<XzxCityPartner> queryPartnerByMobile(XzxCityPartnerModel model) {
        return xzxCityPartnerDao.queryPartnerByMobile(model);

    }

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


    public String querySidByPid(String partnerId, String serviceType) {
        return xzxCityPartnerDao.querySidByPid(partnerId, serviceType);
    }

    public List<String> queryTownIdsByPartnerId(String partnerId) {
        return xzxCityPartnerDao.queryTownIdsByPartnerId(partnerId);
    }

    public List<String> queryTownIdsByPartnerIdList(List<String> partnerIds) {
        return xzxCityPartnerDao.queryTownIdsByPartnerIdList(partnerIds);
    }

    public List<Map<String, Object>> queryGaodeByUserId(XzxCityPartnerModel model) {
        List<Map<String, Object>> list1 = new ArrayList<>();
        CoreUser user = platformService.getCurrentUser();
        List<String> partnerIds = queryPartnerByCurrent();
        XzxCityPartner partner = xzxCityPartnerDao.queryPartnerById(user.getId());
        String key = "";
        if (null != model.getOrderId() && !"".equals(model.getOrderId())) {
            partner = xzxCityPartnerDao.queryPartnerKeyByOrder(model.getOrderId());
            key = partner.getPartnerKey();
            model.setUserType("2");
        } else {
            model.setUserType("6");
        }
        if (null != partner) {
            key = partner.getPartnerKey();
        } else {
            UserModel userModel = cuserConsoleService.queryUserOtherById(model.getUserId());
            String partnerId = userModel.getPartnerId();
            partner = cityPartnerService.queryById(partnerId);
            if (null != partner) {
                key = partner.getPartnerKey();
            } else {
                return null;
            }

        }

        UserModel userModel = xzxCityPartnerDao.queryUserModelbyPartnerId(partnerIds, model.getUserType(), model.getUserId(), model.getOrderId());
        if (null != model.getDayTime() && !"".equals(model.getDayTime())) {
            if (null != model.getDateTime() && !"".equals(model.getDateTime())) {
                String[] ss = model.getDateTime().split("-");
                model.setStartTime(model.getDayTime() + " " + ss[0] + ":00");
                model.setEndTime(model.getDayTime() + " " + ss[1] + ":59");
            }
        }
        Map<String, Object> objMap = new HashMap<>();
        String terminalId = userModel.getTerminalId();
        Map map1 = new HashMap();
        String url = "";
        String type = null;
        if (userModel.getUserType().equals("2")) {
            type = "1";
            map1.put("tid", terminalId);
        } else if (userModel.getUserType().equals("6")) {
            type = "2";
        }
        String sid = xzxCityPartnerDao.querySidByPartnerId(partner.getId() + "", type);
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        map1.put("key", key);
        map1.put("sid", sid);

        String result1 = "";
        url = "https://tsapi.amap.com/v1/track/terminal/trsearch";
        if (userModel.getUserType().equals("2")) {
            if (null != model.getOrderId()) {
                String trid = xzxCityPartnerDao.queryOrderById(model.getOrderId(), userModel.getUserId(), model.getStartTime(), model.getEndTime());
                map1.put("trid", trid);
                result1 = HttpClientUtils.doGet(url, map1);
                Map maps1 = (Map) JSON.parse(result1);
                if (null != maps1.get("data")) {
                    String str1 = maps1.get("data").toString();
                    Map mapsHsy = (Map) JSON.parse(str1);
                    if (null != mapsHsy.get("tracks")) {
                        String tracks = mapsHsy.get("tracks").toString();
                        List<GuijiByGaodeTridModel> dataArr = JSON.parseArray(tracks, GuijiByGaodeTridModel.class);

                        GuijiByGaodeTridModel mm = dataArr.get(0);
                        objMap.put("distance", mm.getDistance());
                        objMap.put("totalTime", mm.getTime() / (1000 * 60));
                        objMap.put("counts", mm.getCounts());
                        List<PointsModel> pointsList = mm.getPoints();
                        if (null != pointsList && pointsList.size() > 0) {
                            List<Map<String, Object>> propData = new ArrayList<>();
                            String address = "";
                            long t = 0;
                            long tt1 = 0;
                            for (PointsModel pp : pointsList) {
                                Map<String, Object> propMap = new HashMap<>();
                                Map maps4 = pp.getProps();
                                if (!"".equals(address)) {
                                    if (address.equals(maps4.get("address").toString())) {
                                        if (tt1 == 0) {
                                            tt1 = pp.getLocatetime() - t;
                                        } else {
                                            tt1 = tt1 + (pp.getLocatetime() - t);
                                        }
                                        continue;
                                    } else {
                                        propMap.put("stopTime", tt1 / (1000 * 60));
                                    }
                                }

                                address = maps4.get("address").toString();
                                propMap.put("address", address);
                                t = pp.getLocatetime();
                                Date date = new Date(t);
                                SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                                String tt = sdf1.format(date);
                                propMap.put("time", tt);
                                propData.add(propMap);
                            }
                            objMap.put("counts", propData.size());
                            objMap.put("propData", propData);
                        }
                    }
                }
            } else {

                List<String> trids = xzxCityPartnerDao.queryOrderByIds(userModel.getUserId(), model.getStartTime(), model.getEndTime());
                for (int i = 0; i < trids.size(); i++) {
                    map1.put("trid", trids.get(i));
                    String r1 = HttpClientUtils.doGet(url, map1);
                    if (i == 0) {
                        result1 = i + ":" + r1;
                    } else {
                        result1 = result1 + "    " + i + ":" + r1;
                    }
                }

            }
        } else if (userModel.getUserType().equals("6")) {
            try {

                Date date1 = simpleDateFormat.parse(model.getStartTime());
                Date date2 = simpleDateFormat.parse(model.getEndTime());
                long ts1 = date1.getTime();
                long ts2 = date2.getTime();
                map1.put("starttime", ts1 + "");
                map1.put("endtime", ts2 + "");
                map1.put("tid", terminalId);
                result1 = HttpClientUtils.doGet(url, map1);
                Map maps1 = (Map) JSON.parse(result1);
                if (null != maps1.get("data")) {
                    String str1 = maps1.get("data").toString();
                    Map mapsHsy = (Map) JSON.parse(str1);
                    if (null != mapsHsy.get("tracks")) {
                        String tracks = mapsHsy.get("tracks").toString();
                        List<GuijiByGaodeTridModel> dataArr = JSON.parseArray(tracks, GuijiByGaodeTridModel.class);
                        GuijiByGaodeTridModel mm = dataArr.get(0);
                        objMap.put("distance", mm.getDistance());
                        objMap.put("totalTime", mm.getTime() / (1000 * 60));
                        objMap.put("counts", mm.getCounts());
                        List<PointsModel> pointsList = mm.getPoints();
                        if (null != pointsList && pointsList.size() > 0) {
                            List<Map<String, Object>> propData = new ArrayList<>();
                            String address = "";
                            long t = 0;
                            long tt1 = 0;
                            for (PointsModel pp : pointsList) {
                                Map<String, Object> propMap = new HashMap<>();
                                Map maps4 = pp.getProps();
                                if (!"".equals(address)) {
                                    if (address.equals(maps4.get("address").toString())) {
                                        if (tt1 == 0) {
                                            tt1 = pp.getLocatetime() - t;
                                        } else {
                                            tt1 = tt1 + (pp.getLocatetime() - t);
                                        }
                                        continue;
                                    } else {
                                        propMap.put("stopTime", tt1 / (1000 * 60));
                                    }
                                }

                                address = maps4.get("address").toString();
                                propMap.put("address", address);
                                t = pp.getLocatetime();
                                Date date = new Date(t);
                                SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                                String tt = sdf1.format(date);
                                propMap.put("time", tt);
                                propData.add(propMap);
                            }
                            objMap.put("counts", propData.size());
                            objMap.put("propData", propData);
                        }

                    }
                }
            } catch (ParseException e) {
                e.printStackTrace();
            }
        }
        objMap.put("userModel", userModel);
        list1.add(objMap);


        return list1;
    }

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

        Map<String, Object> result = new HashMap<>();
        int page = model.getPage();
        int limit = model.getLimit();
        int p = page;
        p = (p - 1) * limit;
        model.setPage(p);
        String totalMoney = "0";
        CoreUser user = platformService.getCurrentUser();
        XzxCityPartner partner = xzxCityPartnerDao.queryPartnerById(user.getId());
        if (null != model.getAccountId() && !"".equals(model.getAccountId())) {
            AccountMoneyModel am = new AccountMoneyModel();
            am.setAccountId(model.getAccountId());
            AccountMoneyModel account = xzxCityPartnerDao.queryAccountByAccountId(am);
            totalMoney = account.getMoney();
        }
        //String accountNo = partner.getAccountNo();
        List<String> partnerIds = queryPartnerByCurrent();
        // model.setAccountId(accountNo);
        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);
        }

        List<AccountLogModel> list = xzxCityPartnerDao.queryAccountLogByAccount(model);
        for (AccountLogModel r : list) {
            if (r.getUserType().equals("1")) {
                //转昵称
                String nickName = r.getUserName();
                if (nickName != null && !"".equals(nickName)) {
                    try {
                        nickName = new String(base64.decode(nickName), "UTF-8");
                    } catch (UnsupportedEncodingException e) {
                        e.printStackTrace();
                    }
                }
                r.setUserName(nickName);
            }
            r.setRoleName("城市合伙人");
        }
        result.put("data", list);
        result.put("count", xzxCityPartnerDao.queryAccountLogByAccountCount(model));
        result.put("code", 0);
        result.put("totalMoney", DoubleUtil.roundTwo(totalMoney));
        return result;
    }

    public List<Map<String, String>> queryOrderByHsy(XzxCityPartnerModel model) {
        if (null != model.getDayTime() && !"".equals(model.getDayTime())) {
            if (null != model.getDateTime() && !"".equals(model.getDateTime())) {
                String[] ss = model.getDateTime().split("-");
                model.setStartTime(model.getDayTime() + " " + ss[0] + ":00");
                model.setEndTime(model.getDayTime() + " " + ss[1] + ":59");
            } else {
                model.setStartTime(model.getDayTime() + " 00:00:00");
                model.setEndTime(model.getDayTime() + " 23:59:59");
            }
        } else {
            String t = sdf.format(new Date());
            String[] tl = t.split(" ");

            model.setStartTime(tl[0] + " 00:00:00");
            model.setEndTime(tl[0] + " 23:59:59");
        }
        List<Map<String, String>> list = xzxCityPartnerDao.queryOrderByHsy(model);
        return list;
    }

    public PartnerAccountModel queryAccountIdByUserId(String userId) {
        return xzxCityPartnerDao.queryAccountIdByUserId(userId);
    }

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

        Map<String, Object> result = new HashMap<>();
        int page = model.getPage();
        int limit = model.getLimit();
        int p = page;
        p = (p - 1) * limit;
        model.setPage(p);
        CoreUser user = platformService.getCurrentUser();
        XzxCityPartner partner = xzxCityPartnerDao.queryPartnerById(user.getId());
        PartnerAccountModel userAccount = new PartnerAccountModel();
        if (null != partner) {
            userAccount = xzxCityPartnerDao.queryAccountIdByUserId(partner.getUserId());
        } else {
            String acc = xzxCityPartnerDao.queryAccountByAdminId();
            String[] accArr = acc.split(",");
            userAccount.setMoney(accArr[1]);
            userAccount.setHbb(accArr[2]);
        }
        int count = 0;
        if (null != userAccount) {
            List<PartnerAccountLogModel> list = new ArrayList<>();
            if (null != userAccount.getAccount() && !"".equals(userAccount.getAccount())) {
                model.setAccountId(userAccount.getAccount());
                list = xzxCityPartnerDao.queryPartnerAccountLog(model);
                count = xzxCityPartnerDao.queryPartnerAccountLogCount(model);
            } else {
                list = xzxCityPartnerDao.queryAdminAccountLog(model);
                count = xzxCityPartnerDao.queryAdminAccountLogCount(model);
                for (PartnerAccountLogModel log : list) {
                    log.setApproverStatus("2");
                    log.setApproverTime(log.getCreateTime());
                    String userName = log.getUserName();
                    if (!StringUtils.isEmpty(userName)) {
                        try {
                            userName = new String(base64.decode(log.getUserName()), "UTF-8");
                        } catch (UnsupportedEncodingException e) {
                            e.printStackTrace();
                        }
                    }
                    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("普通用户");
                    }

                }
            }

            result.put("data", list);
            result.put("hbbAccount", userAccount.getHbb());
            result.put("moneryAccount", userAccount.getMoney());
            result.put("code", 0);
            result.put("count", count);
        } 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(XzxCityPartner partner) {
        List<Map<String, String>> list = xzxCityPartnerDao.queryPartnerCityById(partner);
        return list;
    }

    public List<Map<String, Object>> queryAreaObj(XzxCityPartner partner) {
        List<Map<String, Object>> list = xzxCityPartnerDao.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 = xzxCityPartnerDao.queryGaodeByCid(partnerId, pid);
            for (Map<String, Object> cmap : clist) {
                List<Map<String, String>> tlist = xzxCityPartnerDao.queryGaodeByTid(partnerId, cmap.get("code").toString());
                cmap.put("children", tlist);
            }
            map.put("children", clist);
        }
        return list;
    }

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

    }
}