甬城泊车平台添加查询充电站限制条件 现只可查到选择推送该平台的站点信息

jsowell-pile/src/main/resources/mapper/pile/PileStationInfoMapper.xml

@@ -472,6 +472,12 @@
         <if test="dto.address != null and dto.address != ''">
             and t1.address like concat('%', #{dto.address}, '%')
         </if>
+        <if test="dto.stationIds != null and dto.stationIds.size() != 0">
+            and t1.id in
+            <foreach collection="dto.stationIds" item="stationId" open="(" separator="," close=")">
+                #{stationId,jdbcType=VARCHAR}
+            </foreach>
+        </if>
     </select>
 
     <select id="queryByStationDeptIds" resultType="java.lang.String">

jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/yongchengboche/service/impl/YCBCServiceImpl.java

@@ -5,9 +5,12 @@ import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson2.JSON;
 import com.jsowell.common.constant.CacheConstants;
 import com.jsowell.common.core.redis.RedisCache;
+import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
 import com.jsowell.common.util.DateUtils;
 import com.jsowell.common.util.StringUtils;
+import com.jsowell.pile.domain.ThirdPartyStationRelation;
 import com.jsowell.pile.dto.*;
+import com.jsowell.pile.service.IThirdPartyStationRelationService;
 import com.jsowell.thirdparty.lianlian.dto.CommonParamsDTO;
 import com.jsowell.thirdparty.lianlian.service.LianLianService;
 import com.jsowell.thirdparty.lianlian.util.Cryptos;
@@ -17,17 +20,16 @@ import com.jsowell.thirdparty.lianlian.vo.LianLianResultVO;
 import com.jsowell.thirdparty.yongchengboche.dto.YCBCGetTokenDTO;
 import com.jsowell.thirdparty.yongchengboche.service.YCBCService;
 import com.jsowell.thirdparty.zhongdianlian.service.ZDLService;
+import org.apache.commons.collections4.CollectionUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.io.UnsupportedEncodingException;
-import java.util.Date;
+import java.util.*;
-import java.util.HashMap;
-import java.util.LinkedHashMap;
-import java.util.Map;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
 
 /**
  * 甬城泊车 Service
@@ -44,6 +46,9 @@ public class YCBCServiceImpl implements YCBCService {
     @Autowired
     private LianLianService lianLianService;
 
+    @Autowired
+    private IThirdPartyStationRelationService relationService;
+
     @Autowired
     private RedisCache redisCache;
 
@@ -147,6 +152,16 @@ public class YCBCServiceImpl implements YCBCService {
      */
     @Override
     public Map<String, String> queryStationsInfo(QueryStationInfoDTO dto) {
+        // 查询出要查询的充电站id并set进 dto 的stationIds
+        ThirdPartyStationRelation relation = new ThirdPartyStationRelation();
+        relation.setThirdPartyType(ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getCode());
+        List<ThirdPartyStationRelation> ycbcList = relationService.selectThirdPartyStationRelationList(relation);
+        if (CollectionUtils.isNotEmpty(ycbcList)) {
+            List<String> stationList = ycbcList.stream()
+                    .map(x -> String.valueOf(x.getStationId()))
+                    .collect(Collectors.toList());
+            dto.setStationIds(stationList);
+        }
         return zdlService.queryStationsInfo(dto);
     }