对接浙江平台

jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/common/StationInfo.java

@@ -118,13 +118,6 @@ public class StationInfo extends BaseStationInfo {
     @JSONField(name = "StationStatus")
     private Integer stationStatus;
 
-    /**
-     * 车位数量  Y
-     * 可停放进行充电的车位总数(默认：0-未知)
-     */
-    @JSONField(name = "ParkNums")
-    private Integer parkNums = 0;
-
     /**
      * 经度  Y
      * GCJ-02坐标系
@@ -234,13 +227,6 @@ public class StationInfo extends BaseStationInfo {
     @JSONField(name = "Payment")
     private String payment;
 
-    /**
-     * 是否支持预约  N
-     * 充电设备是否需要提前预约后才能使用。(0-不支持预约;1-支持预约)  不填默认为0
-     */
-    @JSONField(name = "SupportOrder")
-    private Integer supportOrder = 0;
-
     /**
      * 备注  N
      * 其他备注信息

jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/ZheJiangPlatformServiceImpl.java

@@ -1,20 +1,24 @@
 package com.jsowell.thirdparty.platform.service.impl;
 
 import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.jsowell.common.constant.Constants;
+import com.jsowell.common.enums.lianlian.StationPaymentEnum;
 import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
 import com.jsowell.common.enums.ykc.ReturnCodeEnum;
 import com.jsowell.common.exception.BusinessException;
 import com.jsowell.common.util.JWTUtils;
 import com.jsowell.common.util.PageUtils;
 import com.jsowell.common.util.StringUtils;
+import com.jsowell.pile.domain.PileStationInfo;
 import com.jsowell.pile.dto.QueryOperatorInfoDTO;
 import com.jsowell.pile.dto.QueryStationInfoDTO;
 import com.jsowell.pile.service.PileBasicInfoService;
+import com.jsowell.pile.service.PileMerchantInfoService;
 import com.jsowell.pile.service.PileStationInfoService;
 import com.jsowell.pile.service.ThirdPartyStationRelationService;
 import com.jsowell.pile.thirdparty.CommonParamsDTO;
@@ -24,11 +28,13 @@ import com.jsowell.pile.vo.ThirdPartySecretInfoVO;
 import com.jsowell.pile.vo.base.MerchantInfoVO;
 import com.jsowell.pile.vo.base.ThirdPartyStationInfoVO;
 import com.jsowell.thirdparty.lianlian.vo.AccessTokenVO;
+import com.jsowell.thirdparty.platform.common.StationInfo;
 import com.jsowell.thirdparty.platform.domain.SupOperatorInfo;
 import com.jsowell.thirdparty.platform.domain.SupStationInfo;
 import com.jsowell.thirdparty.platform.factory.ThirdPartyPlatformFactory;
 import com.jsowell.thirdparty.platform.service.ThirdPartyPlatformService;
 import com.jsowell.thirdparty.platform.util.Cryptos;
+import com.jsowell.thirdparty.platform.util.HttpRequestUtil;
 import com.jsowell.thirdparty.platform.util.ThirdPartyPlatformUtils;
 import com.jsowell.thirdparty.service.ThirdpartySecretInfoService;
 import org.apache.commons.collections4.CollectionUtils;
@@ -36,6 +42,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.util.ArrayList;
 import java.util.LinkedHashMap;
 import java.util.List;
@@ -62,6 +69,9 @@ public class ZheJiangPlatformServiceImpl implements ThirdPartyPlatformService {
     @Autowired
     private PileBasicInfoService pileBasicInfoService;
 
+    @Autowired
+    private PileMerchantInfoService pileMerchantInfoService;
+
 
     // 平台类型
     private final String thirdPlatformType = ThirdPlatformTypeEnum.ZHE_JIANG_PLATFORM.getTypeCode();
@@ -245,6 +255,112 @@ public class ZheJiangPlatformServiceImpl implements ThirdPartyPlatformService {
      * 推送充电站信息
      * supervise_notification_station_info
      */
+    @Override
+    public String notificationStationInfo(String stationId) {
+        // 通过id查询站点相关信息
+        PileStationInfo pileStationInfo = pileStationInfoService.selectPileStationInfoById(Long.parseLong(stationId));
+
+        // 查询第三方平台配置信息
+        ThirdPartySecretInfoVO thirdPartySecretInfoVO = thirdpartySecretInfoService.queryByThirdPlatformType(thirdPlatformType);
+        if (thirdPartySecretInfoVO == null) {
+            throw new BusinessException("", "无此平台配置信息");
+        }
+        String operatorId = thirdPartySecretInfoVO.getOurOperatorId();
+        String operatorSecret = thirdPartySecretInfoVO.getTheirOperatorSecret();
+        String signSecret = thirdPartySecretInfoVO.getTheirSigSecret();
+        String dataSecret = thirdPartySecretInfoVO.getTheirDataSecret();
+        String dataSecretIv = thirdPartySecretInfoVO.getTheirDataSecretIv();
+        String urlAddress = thirdPartySecretInfoVO.getTheirUrlPrefix();
+
+        // 组装联联平台所需要的数据格式
+        StationInfo info = StationInfo.builder()
+                .stationID(stationId)
+                .operatorID(operatorId)
+                .stationName(pileStationInfo.getStationName())
+                .isAloneApply(Integer.valueOf(pileStationInfo.getAloneApply()))
+                .isPublicParkingLot(Integer.valueOf(pileStationInfo.getPublicParking()))
+                .countryCode(pileStationInfo.getCountryCode())
+                .address(pileStationInfo.getAddress())
+                .serviceTel(pileStationInfo.getStationTel())
+                .stationType(Integer.valueOf(pileStationInfo.getStationType()))
+                .stationStatus(Integer.valueOf(pileStationInfo.getStationStatus()))
+                .parkNums(Integer.valueOf(pileStationInfo.getParkNums()))
+                .stationLng(new BigDecimal(pileStationInfo.getStationLng()))
+                .stationLat(new BigDecimal(pileStationInfo.getStationLat()))
+                .construction(Integer.valueOf(pileStationInfo.getConstruction()))
+                .openAllDay(Integer.valueOf(pileStationInfo.getOpenAllDay()))
+                .minElectricityPrice(new BigDecimal(Constants.ZERO))
+                .electricityFee(Constants.ZERO)
+                .serviceFee(Constants.ZERO)
+                .parkFree(Integer.valueOf(pileStationInfo.getParkFree()))
+                .supportOrder(Integer.valueOf(pileStationInfo.getSupportOrder()))
+                .parkFeeType(0)
+                .toiletFlag(Integer.valueOf(pileStationInfo.getToiletFlag()))
+                .storeFlag(Integer.valueOf(pileStationInfo.getStoreFlag()))
+                .restaurantFlag(Integer.valueOf(pileStationInfo.getRestaurantFlag()))
+                .loungeFlag(Integer.valueOf(pileStationInfo.getLoungeFlag()))
+                .canopyFlag(Integer.valueOf(pileStationInfo.getCanopyFlag()))
+                .printerFlag(Integer.valueOf(pileStationInfo.getPrinterFlag()))
+                .barrierFlag(Integer.valueOf(pileStationInfo.getBarrierFlag()))
+                .parkingLockFlag(Integer.valueOf(pileStationInfo.getParkingLockFlag()))
+                // .parkNums()
+                // .supportOrder()
+                .build();
+        String areaCode = pileStationInfo.getAreaCode();  // 330000,330200,330213
+        // 根据逗号分组
+        String[] split = StringUtils.split(areaCode, ",");
+        // 只取最后一部分  330213
+        String subAreaCode = split[split.length - 1];
+        info.setAreaCode(subAreaCode);
+        // 截取运营商组织机构代码(去除最后一位后的最后九位)
+        String organizationCode = "";
+        if (StringUtils.equals(ThirdPlatformTypeEnum.LIAN_LIAN_PLATFORM.getTypeCode(), thirdPlatformType)) {
+            // 联联平台先使用自己运营商的组织机构代码
+            organizationCode = Constants.OPERATORID_LIANLIAN;
+            info.setEquipmentOwnerID(organizationCode);
+        } else {
+            MerchantInfoVO merchantInfo = pileMerchantInfoService.getMerchantInfoVO(String.valueOf(pileStationInfo.getMerchantId()));
+            organizationCode = merchantInfo.getOrganizationCode();
+            if (StringUtils.isNotBlank(organizationCode) && organizationCode.length() == 18) {
+                String equipmentOwnerId = StringUtils.substring(organizationCode, organizationCode.length() - 10, organizationCode.length() - 1);
+                info.setEquipmentOwnerID(equipmentOwnerId);
+            }
+        }
+
+        String payment = StationPaymentEnum.getPaymentByCode(pileStationInfo.getPayment());
+        info.setPayment(payment);
+        if (StringUtils.isNotBlank(pileStationInfo.getParkingNumber())) {
+            info.setIsPublicParkingLot(1);
+            info.setParkingLotNumber(pileStationInfo.getParkingNumber());
+        }
+        // 户号
+        if (StringUtils.isNotBlank(pileStationInfo.getAccountNumber())) {
+            info.setAccountNumber(pileStationInfo.getAccountNumber());
+        }
+
+        // 容量
+        if (StringUtils.isNotBlank(String.valueOf(pileStationInfo.getCapacity()))) {
+            info.setCapacity(pileStationInfo.getCapacity().setScale(4, RoundingMode.HALF_UP));
+        }
+        List<EquipmentInfo> pileList = pileBasicInfoService.getPileListForLianLian(stationId);
+        if (CollectionUtils.isNotEmpty(pileList)) {
+            info.setEquipmentInfos(pileList); // 充电设备信息列表
+        }
+
+        // 调用联联平台接口
+        String url = urlAddress + "supervise_notification_station_info";
+
+        String jsonStr = JSON.toJSONString(info);
+        JSONObject data = new JSONObject();
+        data.put("StationInfo", jsonStr);
+
+        String jsonString = JSON.toJSONString(data);
+
+        // 获取令牌
+        String token = getToken(urlAddress, operatorId, operatorSecret, dataSecretIv, signSecret, dataSecret);
+        String result = HttpRequestUtil.sendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret);
+        return result;
+    }
 
     /**
      * 推送充电设备接口状态信息