liebao-cloud/lb-app/src/main/java/com/ydd/app/service/impl/ApiDeliveryServiceImpl.java

package com.ydd.app.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydd.api.DeliveryService;
import com.ydd.app.QueryAmountEntityUtils;
import com.ydd.app.service.ApiDeliveryService;
import com.ydd.common.enums.DeliveryTypeEnums;
import com.ydd.common.utils.StringUtils;
import com.ydd.ecloud.core.utils.JsonMapper;
import com.ydd.module.domain.*;
import com.ydd.module.dto.DeliveryDto;
import com.ydd.module.dto.DeliveryInfo;
import com.ydd.module.dto.MemberConfigDto;
import com.ydd.module.enums.BindStatusEnum;
import com.ydd.module.enums.IsDeleteEnum;
import com.ydd.module.enums.StatusEnum;
import com.ydd.module.expection.CustomAppException;
import com.ydd.module.service.*;
import com.ydd.system.service.ISysConfigService;
import com.ydd.third.common.dto.*;
import com.ydd.third.common.huolalaresponse.TokenResponse;
import com.ydd.third.common.vo.ResObject;
import com.ydd.third.common.vo.callback.ShansongTokenVo;
import com.ydd.third.common.vo.huolalavo.HCityInfo;
import com.ydd.third.common.vo.huolalavo.HPoiSearch;
import com.ydd.third.common.vo.huolalavo.Haddress;
import com.ydd.third.common.vo.shop.AmountResultVo;
import com.ydd.third.common.vo.shop.QueryAmount;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.List;

/**
 * Project：lb-server
 * Class：ApiDeliveryServiceImpl
 * Description：TODO
 * Time：2021/3/3 10:03
 *
 * @author zoe
 */
@Slf4j
@Service
@RequiredArgsConstructor(onConstructor_ = @Autowired)
public class ApiDeliveryServiceImpl implements ApiDeliveryService {

    private final ISysConfigService iSysConfigService;

    private final IDspDeliveryService iDspDeliveryService;

    private final IMemberConfigService iMemberConfigService;

    private final IShopDeliveryService iShopDeliveryService;

    private final IMemberService iMemberService;



    private final IMerchantService iMerchantService;



    private final DeliveryService client;



    private final IShopService iShopService;

    private final IHuoLaLaCityService iHuoLaLaCityService;

    @Override
    public List<DeliveryDto> list(Long loginId) {
        Member member = iMemberService.getById(loginId);
        List<DeliveryDto> list = iShopDeliveryService.findList(member.getMerchantId());
        // 查询余额
        for (DeliveryDto l : list){
            DeliveryInfo delivery = new DeliveryInfo();
            delivery.setThirdShopId(l.getThirdShopId());
            delivery.setShopId(l.getThirdShopId());
            delivery.setAuthToken(l.getAuthToken());
            delivery.setPhone(l.getAccount());
            delivery.setType(l.getType());
            // 达达或者达达优质的门店编号
            if (DeliveryTypeEnums.DADA.getType().equals(l.getType()) || DeliveryTypeEnums.DADA_YZ.getType().equals(l.getType())){
                ShopDelivery delivery1 = iShopDeliveryService.getDadaShopNo(member.getMerchantId(),l.getDeliveryId());
                if (delivery1 != null){
                    if (DeliveryTypeEnums.DADA.getType().equals(l.getType())){
                        l.setShopNo(delivery1.getDadaShopNo());
                    }
                    if (DeliveryTypeEnums.DADA_YZ.getType().equals(l.getType())){
                        l.setShopNo(delivery1.getDadaYzShopNo());
                    }
                }
            }
            DspDelivery dspDelivery = iDspDeliveryService.findOne(l.getType());
            QueryAmount queryAmount = QueryAmountEntityUtils.queryAmount(delivery, member.getMerchantId(),1);
            ResObject<AmountResultVo> amountRes = client.queryAmount(queryAmount);
            if (amountRes.getCode() == 0) {
                // 更新余额
                AmountResultVo vo = amountRes.getData();
                ShopDelivery shopDelivery = iShopDeliveryService.getOne(new QueryWrapper<ShopDelivery>().eq("merchant_id", member.getMerchantId()).eq("delivery_id", dspDelivery.getId())
                        .eq("deleted", IsDeleteEnum.NORMAL.status).isNull("shop_id").eq("bind_status",1));
                if (shopDelivery != null){
                    shopDelivery.setBalance(vo.getBalanceAmount());
                    iShopDeliveryService.updateById(shopDelivery);
                }
            }
        }
        List<DeliveryDto> deliveryList = iDspDeliveryService.floorList();
        List<DeliveryDto> dadaList = iShopDeliveryService.findBindList(member.getMerchantId());
        for (DeliveryDto dada : dadaList){
            DspDelivery dspDelivery = iDspDeliveryService.getById(dada.getDeliveryId());
            if (!dspDelivery.getType().equals(DeliveryTypeEnums.DADA.getType())
                    && !dspDelivery.getType().equals(DeliveryTypeEnums.DADA_YZ.getType())
                    && !dspDelivery.getType().equals(DeliveryTypeEnums.SHUN_FENG.getType())){
                continue;
            }
            list.add(dada);
        }
        deliveryList.removeAll(list);
        for (DeliveryDto dto : deliveryList){
            if (dto.getType().equals(DeliveryTypeEnums.MEI_TUAN.getType()) ||
                    dto.getType().equals(DeliveryTypeEnums.FENG_NIAO.getType()) ||
                    dto.getType().equals(DeliveryTypeEnums.FENG_NIAO_KA.getType()) ||
                    dto.getType().equals(DeliveryTypeEnums.HUO_LA_LA.getType())){
                continue;
            }
            dto.setBindStatus(BindStatusEnum.UNBIND.getStatus());
            list.add(dto);
        }
        return list;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void release(Long loginId, Integer id,String sfId) {
        ShopDelivery shopDelivery = iShopDeliveryService.getById(id);
        DspDelivery delivery =iDspDeliveryService.getById(shopDelivery.getDeliveryId());
        if (delivery.getType().equals(DeliveryTypeEnums.AIPT.getType())){
            AiptUnBindDto dto = unBind(id,loginId);
        }else {
            if (delivery.getType().equals(DeliveryTypeEnums.SHUN_FENG.getType()) ||
                    delivery.getType().equals(DeliveryTypeEnums.DADA.getType())||
                    delivery.getType().equals(DeliveryTypeEnums.DADA_YZ.getType()) ||
                    delivery.getType().equals(DeliveryTypeEnums.MEI_TUAN_ZB.getType())||
                    delivery.getType().equals(DeliveryTypeEnums.MEI_TUAN_SG_ZB.getType())){
                iShopDeliveryService.removeById(id);
            }
            if(DeliveryTypeEnums.SHAN_SONG.getType().equals(delivery.getType())){
                //解除绑定
                ResObject res = client.cancelToken(shopDelivery.getAuthToken());
                if (res.getCode() == 0){
                    iShopDeliveryService.removeById(id);
                }
                log.info("===闪送解除绑定结果===》"+ JsonMapper.nonEmptyMapper().toJson(res));
            }

            if (DeliveryTypeEnums.KUAI_FU.getType().equals(delivery.getType())){
                log.info("===快服解除绑定===》");
                iShopDeliveryService.removeById(id);
            }

        }
    }

    /**
     * 爱跑腿-解除绑定
     * @param id 商家绑定平台ID
     * @param loginId
     */
    @Override
    public AiptUnBindDto unBind(Integer id,Long loginId) {
        ShopDelivery shopDelivery = iShopDeliveryService.getById(id);
        if (shopDelivery != null){
            //解除绑定
            AiptUnBindDto bindDto = client.unBind(shopDelivery.getAccount());
            if (bindDto.getCode().equals(1) && bindDto.getState().equals("Success")){
                iShopDeliveryService.removeById(id);
            }
            log.info("===解除绑定结果===》"+ JsonMapper.nonEmptyMapper().toJson(bindDto));
            return bindDto;
        }else {
            AiptUnBindDto bindDto = new AiptUnBindDto();
            bindDto.setState("Fail");
            bindDto.setInfo("该运力不存在");
            return bindDto;
        }
    }

    @Override
    public String explain() {
        return iSysConfigService.selectConfigByKey("BINDING_PROCESS");
    }

    @Override
    public List<DeliveryDto> floorList(Long loginId) {
        return iDspDeliveryService.floorList();
    }

    @Override
    public MemberConfigDto findDetail(Long loginId) {
        return iMemberConfigService.findDetail(loginId);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void saveConfig(Long loginId, MemberConfigDto config) {
        MemberConfig memberConfig = iMemberConfigService.getOne(new QueryWrapper<MemberConfig>().eq("member_id",loginId));
        if (memberConfig == null){
            memberConfig = new MemberConfig();
            memberConfig.setMemberId(loginId);
        }
        memberConfig.setAddPriceTime(config.getAddPriceTime());
        memberConfig.setGuaranteeDeliveryIds(config.getGuaranteeDeliveryIds());
        memberConfig.setGuaranteeOrderTime(config.getGuaranteeOrderTime());
        memberConfig.setOpenGuarantee(config.getOpenGuarantee());
        memberConfig.setOpenTipSwitch(config.getOpenTipSwitch());
        memberConfig.setTipAmount(config.getTipAmount());
        memberConfig.setTipRemark(config.getTipRemark());
        iMemberConfigService.saveOrUpdate(memberConfig);
    }

    @Override
    public void status(Long loginId, Integer id, Integer preferredDelivery) {
        ShopDelivery delivery = iShopDeliveryService.getById(id);
        if (delivery == null){
            throw new CustomAppException("绑定运力不存在！");
        }
        if (preferredDelivery.equals(StatusEnum.SHOW.status)){
            iShopDeliveryService.updateStatus(delivery.getMerchantId());
        }
        delivery.setPreferredDelivery(preferredDelivery);
        iShopDeliveryService.updateById(delivery);

    }

    /**
     * 绑定运力平台
     * @param loginId
     * @param deliveryId
     * @param sfId
     * @param dadaName
     * @return
     */
    @Override
    public String bind(Long loginId, Long deliveryId,String sfId,String dadaName) {
        Member member = iMemberService.getById(loginId);
        ShopDelivery shopDelivery = iShopDeliveryService.getOne(new QueryWrapper<ShopDelivery>().eq("merchant_id",member.getMerchantId()).eq("delivery_id",deliveryId).isNull("shop_id"));
        if (member.getMerchantId() == null){
            throw new CustomAppException("请先申请成为商家！");
        }
        Merchant merchant = iMerchantService.getById(member.getMerchantId());
        if (merchant == null){
            throw new CustomAppException("商家信息异常，请联系管理员！");
        }
        DspDelivery delivery = iDspDeliveryService.getById(deliveryId);
        if (shopDelivery != null && shopDelivery.getBindStatus().equals(BindStatusEnum.BIND)){
            throw new CustomAppException("已绑定成功！");
        }
//        if (shopDelivery != null && delivery.getType().equals(DeliveryTypeEnums.SHUN_FENG.getType()) && shopDelivery.getBindStatus().equals(BindStatusEnum.BIND)){
//            throw new CustomAppException("已绑定成功！");
//        }
//        if (shopDelivery != null && delivery.getType().equals(DeliveryTypeEnums.DADA.getType()) && shopDelivery.getBindStatus().equals(BindStatusEnum.BIND)){
//            throw new CustomAppException("已绑定成功！");
//        }
//        if (shopDelivery != null && delivery.getType().equals(DeliveryTypeEnums.DADA_YZ.getType()) && shopDelivery.getBindStatus().equals(BindStatusEnum.BIND)){
//            throw new CustomAppException("已绑定成功！");
//        }
//        if (shopDelivery != null && delivery.getType().equals(DeliveryTypeEnums.KUAI_FU.getType()) && shopDelivery.getBindStatus().equals(BindStatusEnum.BIND)){
//            throw new CustomAppException("已绑定成功！");
//        }
        String url = null;
        if (delivery.getType().equals(DeliveryTypeEnums.SHAN_SONG.getType())){
            url = client.shansongAuthUrl(merchant.getCode());
        }
        if (delivery.getType().equals(DeliveryTypeEnums.FENG_NIAO.getType())){
            url = client.fengniaoAuthUrl();
        }
        if (delivery.getType().equals(DeliveryTypeEnums.AIPT.getType())){
            url = client.aptAuthUrl(merchant.getCode());
        }
        if (delivery.getType().equals(DeliveryTypeEnums.HUO_LA_LA.getType())){
            url = client.hllAuthUrl();
        }
        if (delivery.getType().equals(DeliveryTypeEnums.KUAI_FU.getType())){
            url = client.kfAuthUrl(merchant.getCode());
        }
        if (delivery.getType().equals(DeliveryTypeEnums.MEI_TUAN_ZB.getType())){
            shopDelivery = new ShopDelivery();
            shopDelivery.setAccount("sssss");
            shopDelivery.setMerchantId(merchant.getId());
            shopDelivery.setDeliveryId(delivery.getId());
            shopDelivery.setBindStatus(BindStatusEnum.BIND.status);
            iShopDeliveryService.save(shopDelivery);
        }
        if (delivery.getType().equals(DeliveryTypeEnums.MEI_TUAN_SG_ZB.getType())){
            shopDelivery = new ShopDelivery();
            shopDelivery.setAccount("sssss");
            shopDelivery.setMerchantId(merchant.getId());
            shopDelivery.setDeliveryId(delivery.getId());
            shopDelivery.setBindStatus(BindStatusEnum.BIND.status);
            iShopDeliveryService.save(shopDelivery);
        }
        if (StringUtils.isBlank(sfId) && (delivery.getType().equals(DeliveryTypeEnums.DADA.getType()) || delivery.getType().equals(DeliveryTypeEnums.DADA_YZ.getType()))){
            Integer type = 0;
            if (delivery.getType().equals(DeliveryTypeEnums.DADA_YZ.getType())){
                type = 1;
            }
            JSONObject jsonObject = client.partyTicket(type);
            if (jsonObject.getString("status").equals("success")){
                url = client.getPartyOauth(jsonObject.getString("result"),type,merchant.getCode());
            }else {
                throw new CustomAppException(jsonObject.getString("msg"));
            }
        }
        if (delivery.getType().equals(DeliveryTypeEnums.SHUN_FENG.getType()) || delivery.getType().equals(DeliveryTypeEnums.DADA.getType()) || delivery.getType().equals(DeliveryTypeEnums.DADA_YZ.getType())){
            if (StringUtils.isNotBlank(sfId)){
                if (shopDelivery == null){
                    shopDelivery = new ShopDelivery();
                    shopDelivery.setAccount("sssss");
                    if (StringUtils.isNotBlank(dadaName)){
                        shopDelivery.setAccount(dadaName);
                    }
                    shopDelivery.setBalance(new BigDecimal("0"));
                    shopDelivery.setThirdShopId(sfId);
                    shopDelivery.setMerchantId(merchant.getId());
                    shopDelivery.setDeliveryId(delivery.getId());
                    shopDelivery.setBindStatus(BindStatusEnum.CHECK.status);
                    iShopDeliveryService.save(shopDelivery);
                }else {
                    // 更新
                    shopDelivery.setThirdShopId(sfId);
                    shopDelivery.setBindStatus(BindStatusEnum.CHECK.status);
                    shopDelivery.setAccount("sssss");
                    if (StringUtils.isNotBlank(dadaName)){
                        shopDelivery.setAccount(dadaName);
                    }
                    iShopDeliveryService.updateById(shopDelivery);
                }
            }
        }
        return url;
    }

    /**
     * 填写达达/达达优质门店编号
     * @param loginId
     * @param deliveryId 运力
     * @param shopNo 达达/优质门店编号
     */
    @Override
    public void updateDadaShopNo(Long loginId, Long deliveryId, String shopNo) {
        Member member = iMemberService.getById(loginId);
        ShopDelivery shopDelivery = iShopDeliveryService.getOne(new QueryWrapper<ShopDelivery>().eq("merchant_id",member.getMerchantId()).eq("delivery_id",deliveryId).isNull("shop_id"));
        DspDelivery dspDelivery = iDspDeliveryService.getById(deliveryId);
        getBalance(shopDelivery,dspDelivery,member.getMerchantId(),deliveryId,shopNo);
    }

    /**
     * 查询达达余额，并且更新达达门店编号
     * @param shopDelivery
     * @param dspDelivery
     * @param merchantId
     * @param deliveryId
     * @param shopNo
     */
    public void getBalance(ShopDelivery shopDelivery,DspDelivery dspDelivery,Long merchantId,Long deliveryId,String shopNo){
        QueryAmount queryAmount = new QueryAmount();
        queryAmount.setIsDirectDelivery(0);
        queryAmount.setLbClient(DeliveryTypeEnums.DADA.getName());
        if (DeliveryTypeEnums.DADA_YZ.getType().equals(dspDelivery.getType())){
            queryAmount.setIsDirectDelivery(1);
            queryAmount.setLbClient(DeliveryTypeEnums.DADA_YZ.getName());
        }
        shopDelivery.setBindStatus(BindStatusEnum.BIND.status);
        // 查询余额
        queryAmount.setMerchantId(shopDelivery.getThirdShopId());
        ResObject<AmountResultVo> res = client.queryAmount(queryAmount);
        if(res.getCode().intValue()==0){
            BigDecimal balanceAmount = res.getData().getBalanceAmount();
            shopDelivery.setBalance(balanceAmount);
        }
        iShopDeliveryService.updateById(shopDelivery);
        iShopDeliveryService.updateDaDaShopNo(dspDelivery.getType(),merchantId,deliveryId,shopNo);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void bindCallBack(ShansongTokenVo tokenVo) {
        DspDelivery delivery = iDspDeliveryService.findOne(DeliveryTypeEnums.SHAN_SONG.getType());
        Merchant merchant = iMerchantService.getOne(new QueryWrapper<Merchant>().eq("code",tokenVo.getShopId()));
        if(merchant!=null){
            ShopDelivery shopDelivery = new ShopDelivery();
            //绑定闪送目前只能拿到授权token
            //TODO
            shopDelivery.setAccount("sssss");
            //   shopDelivery.setBalance(new BigDecimal("12.03"));
            shopDelivery.setThirdShopId(tokenVo.getShopId());
            shopDelivery.setMerchantId(merchant.getId());
            shopDelivery.setBindStatus(BindStatusEnum.BIND.status);
            shopDelivery.setDeliveryId(delivery.getId());
            shopDelivery.setAuthToken(tokenVo.getAccessToken());
            //获取余额
            try {
                QueryAmount queryAmount = new QueryAmount();
                queryAmount.setAccessToken(tokenVo.getAccessToken());
                queryAmount.setIsShansongSH(true);
                queryAmount.setLbClient(DeliveryTypeEnums.SHAN_SONG.getName());
                ResObject<AmountResultVo> res = client.queryAmount(queryAmount);
                if (res.getCode() == 0){
                    AmountResultVo vo = res.getData();
                    shopDelivery.setBalance(vo.getBalanceAmount());
                }
            } catch (Exception e) {
                e.printStackTrace();
            }

            shopDelivery.setRefreshToken(tokenVo.getRefreshToken());
            shopDelivery.setExpiresIn(tokenVo.getExpireIn());
            iShopDeliveryService.save(shopDelivery);
        }
    }

    /**
     * 爱跑腿绑定回调
     * @param aiptAuthDto
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void bindAipt(AiptAuthDto aiptAuthDto) {
        DspDelivery delivery = iDspDeliveryService.findOne(DeliveryTypeEnums.AIPT.getType());
        Merchant merchant = iMerchantService.getOne(new QueryWrapper<Merchant>().eq("code",aiptAuthDto.getUnique_id()));
        System.out.println("爱跑腿绑定回调商户---"+merchant.getId());
        if(merchant!=null){
            ShopDelivery shopDelivery = iShopDeliveryService.getByMerchantIdAndDeliveryId(merchant.getId(),delivery.getId());
            if (shopDelivery == null){
                shopDelivery = new ShopDelivery();
                shopDelivery.setAccount(aiptAuthDto.getPhone());
                shopDelivery.setThirdShopId(aiptAuthDto.getUnique_id());
                shopDelivery.setMerchantId(merchant.getId());
                if ("bind".equals(aiptAuthDto.getState())){
                    shopDelivery.setBindStatus(BindStatusEnum.BIND.status);
                }else {
                    shopDelivery.setBindStatus(BindStatusEnum.UNBIND.status);
                }
                shopDelivery.setDeliveryId(delivery.getId());
                //获取余额
                try {
                    QueryAmount queryAmount = new QueryAmount();
                    queryAmount.setPhone(aiptAuthDto.getPhone());
                    queryAmount.setLbClient(DeliveryTypeEnums.AIPT.getName());
                    ResObject<AmountResultVo> res = client.queryAmount(queryAmount);
                    if (res.getCode() == 0){
                        AmountResultVo vo = res.getData();
                        shopDelivery.setBalance(vo.getBalanceAmount());
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
                iShopDeliveryService.save(shopDelivery);
            }
        }
    }

    /**
     * 绑定快服回调
     * @param kfAuthDto
     */
    @Override
    public void bindKf(KfAuthDto kfAuthDto) {
        DspDelivery delivery = iDspDeliveryService.findOne(DeliveryTypeEnums.KUAI_FU.getType());
        Merchant merchant = iMerchantService.getOne(new QueryWrapper<Merchant>().eq("code",kfAuthDto.getMerchantCode()));
        if(merchant==null){
            log.info("快服绑定商家为空");
            return;
        }
        ShopDelivery shopDelivery = iShopDeliveryService.getByThirdShopIdAndMerchantId(merchant.getId(),kfAuthDto.getOpenid());
        if (shopDelivery == null){
            shopDelivery = new ShopDelivery();
            shopDelivery.setThirdShopId(kfAuthDto.getOpenid());
            shopDelivery.setMerchantId(merchant.getId());
            shopDelivery.setBindStatus(BindStatusEnum.BIND.status);
            shopDelivery.setDeliveryId(delivery.getId());
            shopDelivery.setAuthToken(kfAuthDto.getAccess_token());
            // 表示该商家是首次绑定,不是yes则是下过订单后的账户
            shopDelivery.setAccount("yes");
            iShopDeliveryService.save(shopDelivery);
        }
    }

    /**
     * 达达授权绑定
     * @param sourceId 三方门店ID
     * @param merchantCode 商家code
     * @param type
     * @param shopNo 门店编号，App账户会返回
     */
    @Override
    public void bindDaDa(String sourceId, String merchantCode, Integer type,String shopNo) {
        DspDelivery delivery = iDspDeliveryService.findOne(type);
        Merchant merchant = iMerchantService.getOne(new QueryWrapper<Merchant>().eq("code",merchantCode));
        if(merchant==null){
            log.info("达达绑定商家为空");
            return;
        }
        ShopDelivery shopDelivery = iShopDeliveryService.getOne(new QueryWrapper<ShopDelivery>().eq("merchant_id",merchant.getId()).
                eq("delivery_id",delivery.getId()).eq("deleted",0).isNull("shop_id"));
        if (shopDelivery == null){
            shopDelivery = new ShopDelivery();
        }
        shopDelivery.setThirdShopId(sourceId);
        shopDelivery.setMerchantId(merchant.getId());
        shopDelivery.setBindStatus(BindStatusEnum.WAIT_INFO.status);
        shopDelivery.setDeliveryId(delivery.getId());
        shopDelivery.setAccount("sssss");
        iShopDeliveryService.saveOrUpdate(shopDelivery);
        if (StringUtils.isNotBlank(shopNo)){
            shopDelivery.setBindStatus(BindStatusEnum.BIND.status);
            // 更新门店编号，同时查询余额
            getBalance( shopDelivery, delivery,merchant.getId(), delivery.getId(), shopNo);
        }

    }

    @Override
    public boolean bindUserApply(String mobile, String ip) {
        ResObject<BindUserApplyResponse> resObject =  client.bindUserApply(mobile,ip);
        if(resObject.getCode()!=0){
            return  false;
        }
        return  true;
    }

    @Override
    public String bindUserSubmit(Long memberId,String mobile, String validateCode, String cityName) {
        log.info("绑定用户请求：memberId:{}",memberId);
        ResObject<BindUserSubmitResponse> resObject = client.bindUserSubmit(mobile,validateCode,cityName);
        if(resObject.getCode()==0){
            BindUserSubmitResponse response = resObject.getData();
            Member member = iMemberService.getById(memberId);
            DspDelivery delivery = iDspDeliveryService.findOne(DeliveryTypeEnums.UUPT.getType());
            Merchant merchant = iMerchantService.getById(member.getMerchantId());
            ShopDelivery shopDelivery = new ShopDelivery();
            shopDelivery.setAccount(mobile);
            ResObject<GetBalanceDetailResponse> res = client.getBalance(response.getOpenid());
            if(res.getCode().intValue()==0){
                String accountMoney = res.getData().getAccountMoney();
                shopDelivery.setBalance(new BigDecimal(accountMoney));
            }
            shopDelivery.setThirdShopId(response.getOpenid());
            shopDelivery.setMerchantId(merchant.getId());
            shopDelivery.setBindStatus(BindStatusEnum.BIND.status);
            shopDelivery.setDeliveryId(delivery.getId());
            iShopDeliveryService.save(shopDelivery);
            return  "ok";
        }
        return  resObject.getMsg();
    }

    @Override
    public String cancelBind(Long memberId,String mobile) {
        Member member = iMemberService.getById(memberId);
        DspDelivery delivery = iDspDeliveryService.findOne(DeliveryTypeEnums.UUPT.getType());
        ShopDelivery shopDelivery = iShopDeliveryService.getOne(new QueryWrapper<ShopDelivery>().eq("merchant_id",member.getMerchantId()).
                eq("delivery_id",delivery.getId()).isNull("shop_id"));
        log.info("uupt 解除绑定开始:"+JSONObject.toJSONString(shopDelivery));
        if(shopDelivery!=null&&shopDelivery.getAccount().equals(mobile)&&StringUtils.isNotBlank(shopDelivery.getThirdShopId())){
            String openId = shopDelivery.getThirdShopId();
            ResObject<CancelBindResponse> resObject =  client.cancelBind(openId);
            if(resObject.getCode()==0){
                CancelBindResponse response = resObject.getData();
                log.info("uupt 解除绑定返回:"+JSONObject.toJSONString(response));
//                ShopDelivery shopDelivery1 = new ShopDelivery();
//                shopDelivery1.setBindStatus(BindStatusEnum.UNBIND.status);
//                iShopDeliveryService.update(shopDelivery1,new UpdateWrapper<ShopDelivery>().eq("third_shop_id",openId));
                  iShopDeliveryService.removeById(shopDelivery.getId());
                return  "ok";
            }
            return  resObject.getMsg();
        }else{
            return  "用户不存在" ;
        }

    }

    @Override
    public void bindHuoLaLa(TokenResponse tokenResponse) {
        DspDelivery delivery = iDspDeliveryService.findOne(DeliveryTypeEnums.HUO_LA_LA.getType());
        Merchant merchant = iMerchantService.findByMobile(tokenResponse.getAuthMobile());
        if (merchant==null){
            log.info("货拉拉商户绑定未找到,手机号为"+tokenResponse.getAuthMobile());
        }
        ShopDelivery shopDelivery = iShopDeliveryService.getByMerchantIdAndDeliveryId(merchant.getId(),delivery.getId());
        if (shopDelivery==null){
            shopDelivery=new ShopDelivery();
            shopDelivery.setMerchantId(merchant.getId());
            shopDelivery.setRefreshToken(tokenResponse.getRefreshToken());
            shopDelivery.setAuthToken(tokenResponse.getAccessToken());
            shopDelivery.setExpiresIn(tokenResponse.getExpires().getTime());
            shopDelivery.setDeliveryId(delivery.getId());
            shopDelivery.setBindStatus(BindStatusEnum.BIND.getStatus());
            iShopDeliveryService.save(shopDelivery);
        }
    }

    @Override
    public String findCity(String cityName) {
        HuoLaLaCity city = iHuoLaLaCityService.findCity(cityName);
        if (city!=null){
            return city.getCityId()+"";
        }else{
            return "";
        }
    }

    @Override
    public HCityInfo getCityInfo(String cityId) {
        HCityInfo cityInfo = iHuoLaLaCityService.getCityInfo(cityId);
        return cityInfo;
    }

    @Override
    public  List<Haddress>  poiSearch(HPoiSearch hPoiSearch) {
      List<Haddress> list = client.poiSearch(hPoiSearch);
        return list;
    }
}