mirror of
https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git
synced 2026-06-29 11:38:04 +08:00
bugfix 新电途平台查询站点信息接口只能查询到推送该平台的站点信息
This commit is contained in:
@@ -1,18 +1,24 @@
|
|||||||
package com.jsowell.thirdparty.xindiantu.service.impl;
|
package com.jsowell.thirdparty.xindiantu.service.impl;
|
||||||
|
|
||||||
|
import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
|
||||||
|
import com.jsowell.pile.domain.ThirdPartyStationRelation;
|
||||||
import com.jsowell.pile.dto.QueryEquipChargeStatusDTO;
|
import com.jsowell.pile.dto.QueryEquipChargeStatusDTO;
|
||||||
import com.jsowell.pile.dto.QueryEquipmentDTO;
|
import com.jsowell.pile.dto.QueryEquipmentDTO;
|
||||||
import com.jsowell.pile.dto.QueryStartChargeDTO;
|
import com.jsowell.pile.dto.QueryStartChargeDTO;
|
||||||
import com.jsowell.pile.dto.QueryStationInfoDTO;
|
import com.jsowell.pile.dto.QueryStationInfoDTO;
|
||||||
|
import com.jsowell.pile.service.ThirdPartyStationRelationService;
|
||||||
import com.jsowell.thirdparty.lianlian.dto.CommonParamsDTO;
|
import com.jsowell.thirdparty.lianlian.dto.CommonParamsDTO;
|
||||||
import com.jsowell.thirdparty.xindiantu.service.XDTService;
|
import com.jsowell.thirdparty.xindiantu.service.XDTService;
|
||||||
import com.jsowell.thirdparty.zhongdianlian.dto.ZDLGetTokenDTO;
|
import com.jsowell.thirdparty.zhongdianlian.dto.ZDLGetTokenDTO;
|
||||||
import com.jsowell.thirdparty.zhongdianlian.service.ZDLService;
|
import com.jsowell.thirdparty.zhongdianlian.service.ZDLService;
|
||||||
|
import org.apache.commons.collections4.CollectionUtils;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
import java.io.UnsupportedEncodingException;
|
import java.io.UnsupportedEncodingException;
|
||||||
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 新电途Service
|
* 新电途Service
|
||||||
@@ -25,6 +31,9 @@ public class XDTServiceImpl implements XDTService {
|
|||||||
@Autowired
|
@Autowired
|
||||||
private ZDLService zdlService;
|
private ZDLService zdlService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private ThirdPartyStationRelationService relationService;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取令牌
|
* 获取令牌
|
||||||
* @param dto
|
* @param dto
|
||||||
@@ -57,6 +66,16 @@ public class XDTServiceImpl implements XDTService {
|
|||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
public Map<String, String> queryStationsInfo(QueryStationInfoDTO dto) {
|
public Map<String, String> queryStationsInfo(QueryStationInfoDTO dto) {
|
||||||
|
// 查询出要查询的充电站id并set进 dto 的stationIds
|
||||||
|
ThirdPartyStationRelation relation = new ThirdPartyStationRelation();
|
||||||
|
relation.setThirdPartyType(ThirdPlatformTypeEnum.XIN_DIAN_TU.getCode());
|
||||||
|
List<ThirdPartyStationRelation> xdtList = relationService.selectThirdPartyStationRelationList(relation);
|
||||||
|
if (CollectionUtils.isNotEmpty(xdtList)) {
|
||||||
|
List<String> stationList = xdtList.stream()
|
||||||
|
.map(x -> String.valueOf(x.getStationId()))
|
||||||
|
.collect(Collectors.toList());
|
||||||
|
dto.setStationIds(stationList);
|
||||||
|
}
|
||||||
return zdlService.queryStationsInfo(dto);
|
return zdlService.queryStationsInfo(dto);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user