update 对接内蒙古平台

jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/neimenggu/domain/SupStationInfo.java

@@ -3,7 +3,6 @@ package com.jsowell.thirdparty.platform.neimenggu.domain;
 import com.alibaba.fastjson2.annotation.JSONField;
 import com.jsowell.thirdparty.platform.common.StationInfo;
 import lombok.AllArgsConstructor;
-import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
@@ -13,7 +12,6 @@ import lombok.NoArgsConstructor;
 @Data
 @AllArgsConstructor
 @NoArgsConstructor
-@Builder
 public class SupStationInfo extends StationInfo {
     /**
      * 充换电站唯一编码

jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/neimenggu/service/NeiMengGuPlatformServiceImpl.java

@@ -1,27 +1,57 @@
 package com.jsowell.thirdparty.platform.neimenggu.service;
 
+import cn.hutool.core.util.PageUtil;
 import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
+import com.github.pagehelper.PageInfo;
 import com.google.common.collect.Maps;
+import com.jsowell.common.constant.Constants;
+import com.jsowell.common.core.domain.ykc.RealTimeMonitorData;
+import com.jsowell.common.enums.lianlian.PayChannelEnum;
+import com.jsowell.common.enums.thirdparty.BusinessInformationExchangeEnum;
+import com.jsowell.common.enums.thirdparty.ThirdPartyOperatorIdEnum;
 import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
-import com.jsowell.common.exception.BusinessException;
+import com.jsowell.common.enums.ykc.OrderPayModeEnum;
+import com.jsowell.common.enums.ykc.PileConnectorDataBaseStatusEnum;
+import com.jsowell.common.util.DateUtils;
 import com.jsowell.common.util.JWTUtils;
+import com.jsowell.common.util.PageUtils;
 import com.jsowell.common.util.StringUtils;
+import com.jsowell.pile.domain.OrderBasicInfo;
+import com.jsowell.pile.domain.OrderDetail;
 import com.jsowell.pile.domain.ThirdPartyPlatformConfig;
 import com.jsowell.pile.domain.ThirdPartyStationRelation;
+import com.jsowell.pile.dto.QueryEquipChargeStatusDTO;
 import com.jsowell.pile.dto.QueryOperatorInfoDTO;
 import com.jsowell.pile.dto.QueryStationInfoDTO;
-import com.jsowell.pile.service.ThirdPartyPlatformConfigService;
-import com.jsowell.pile.service.ThirdPartyStationRelationService;
+import com.jsowell.pile.service.*;
 import com.jsowell.pile.thirdparty.CommonParamsDTO;
+import com.jsowell.pile.thirdparty.EquipmentInfo;
+import com.jsowell.pile.vo.base.ConnectorInfoVO;
+import com.jsowell.pile.vo.base.ThirdPartyStationInfoVO;
+import com.jsowell.pile.vo.base.ThirdPartyStationRelationVO;
+import com.jsowell.pile.vo.uniapp.BillingPriceVO;
+import com.jsowell.pile.vo.web.PileStationVO;
+import com.jsowell.thirdparty.lianlian.domain.*;
 import com.jsowell.thirdparty.lianlian.vo.AccessTokenVO;
+import com.jsowell.thirdparty.lianlian.vo.QueryChargingStatusVO;
 import com.jsowell.thirdparty.platform.ThirdPartyPlatformService;
+import com.jsowell.thirdparty.platform.common.StationInfo;
 import com.jsowell.thirdparty.platform.util.Cryptos;
-import com.jsowell.thirdparty.platform.util.GBSignUtils;
+import com.jsowell.thirdparty.platform.util.Encodes;
+import com.jsowell.thirdparty.platform.util.HttpRequestUtil;
+import com.jsowell.thirdparty.platform.util.ThirdPartyPlatformUtils;
+import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.math.BigDecimal;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * 内蒙古监测平台逻辑
@@ -37,6 +67,21 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
     @Autowired
     private ThirdPartyStationRelationService thirdPartyStationRelationService;
 
+    @Autowired
+    private PileBasicInfoService pileBasicInfoService;
+
+    @Autowired
+    private PileStationInfoService pileStationInfoService;
+
+    @Autowired
+    private PileConnectorInfoService pileConnectorInfoService;
+
+    @Autowired
+    private OrderBasicInfoService orderBasicInfoService;
+
+    @Autowired
+    private PileBillingTemplateService pileBillingTemplateService;
+
     /**
      * query_token 获取token，提供给第三方平台使用
      *
@@ -45,54 +90,52 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
      */
     @Override
     public Map<String, String> queryToken(CommonParamsDTO dto) {
+        AccessTokenVO vo = new AccessTokenVO();
+        // 0:成功；1:失败
+        int succStat = 0;
+        // 0:无；1:无此对接平台；2:密钥错误； 3～99:自定义
+        int failReason = 0;
+
         String operatorId = dto.getPlatformID();
         // 通过operatorId 查出 operatorSecret
         ThirdPartyPlatformConfig platformConfig = thirdPartyPlatformConfigService.getInfoByOperatorId(operatorId);
         if (platformConfig == null) {
-            throw new BusinessException("1", "无此对接平台");
-        }
-
-        String operatorSecret = platformConfig.getOperatorSecret();
-        String dataSecret = platformConfig.getDataSecret();
-        String dataSecretIv = platformConfig.getDataSecretIv();
-        String signSecret = platformConfig.getSignSecret();
-
-        // 解密data 获取参数中的OperatorSecret
-        try {
+            // throw new BusinessException("1", "无此对接平台");
+            failReason = 1;
+            succStat = 1;
+        } else {
+            String operatorSecret = platformConfig.getOperatorSecret();
+            String dataSecret = platformConfig.getDataSecret();
+            String dataSecretIv = platformConfig.getDataSecretIv();
+            // 解密data 获取参数中的OperatorSecret
             String decrypt = Cryptos.decrypt(dto.getData(), dataSecret, dataSecretIv);
             String inputOperatorSecret = null;
             if (StringUtils.isNotBlank(decrypt)) {
                 inputOperatorSecret = JSON.parseObject(decrypt).getString("PlatformSecret");
             }
+            // 对比密钥
             if (!StringUtils.equals(operatorSecret, inputOperatorSecret)) {
-                throw new RuntimeException("密钥不一致");
+                // throw new RuntimeException("密钥不一致");
+                failReason = 1;
+                succStat = 1;
+            } else {
+                // 生成token
+                String token = JWTUtils.createToken(operatorId, operatorSecret, JWTUtils.ttlMillis);
+                vo.setAccessToken(token);
+                vo.setTokenAvailableTime((int) (JWTUtils.ttlMillis / 1000));
             }
-        } catch (RuntimeException e) {
-            throw new BusinessException("2", "密钥错误");
         }
-
-        // 生成token
-        String token = JWTUtils.createToken(operatorId, operatorSecret, JWTUtils.ttlMillis);
-
         // 组装返回参数
-        AccessTokenVO vo = new AccessTokenVO();
-        vo.setAccessToken(token);
-        // vo.setOperatorID(operatorId);
         vo.setPlatformId(operatorId);
-        vo.setTokenAvailableTime((int) (JWTUtils.ttlMillis / 1000));
-        vo.setFailReason(0);
-        vo.setSuccStat(0);
+        vo.setFailReason(failReason);
+        vo.setSuccStat(succStat);
 
-        Map<String, String> resultMap = Maps.newLinkedHashMap();
-        // 加密数据
-        String encryptData = Cryptos.aesEncrypt(JSON.toJSONString(vo), dataSecret, dataSecretIv);
-        resultMap.put("Data", encryptData);
-        // 生成sig
-        String resultSign = GBSignUtils.sign(resultMap, signSecret);
-        resultMap.put("Sig", resultSign);
+        Map<String, String> resultMap = ThirdPartyPlatformUtils.generateResultMap(vo, platformConfig);
         return resultMap;
     }
 
+
+
     /**
      * 查询运营商信息 query_operator_info
      * supervise_query_operator_info
@@ -119,7 +162,80 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
      */
     @Override
     public Map<String, String> queryStationsInfo(QueryStationInfoDTO dto) {
-        return ThirdPartyPlatformService.super.queryStationsInfo(dto);
+        int pageNo = dto.getPageNo() == null ? 1 : dto.getPageNo();
+        int pageSize = dto.getPageSize() == null ? 10 : dto.getPageSize();
+
+        PageUtils.startPage(pageNo, pageSize);
+        List<ThirdPartyStationInfoVO> stationInfos = pileStationInfoService.getStationInfosByThirdParty(dto);
+        if (CollectionUtils.isEmpty(stationInfos)) {
+            // 未查到数据
+            return null;
+        }
+        ThirdPartyPlatformConfig configInfo = thirdPartyPlatformConfigService.getInfoByOperatorId(dto.getOperatorId());
+        if (configInfo == null) {
+            return null;
+        }
+        PageInfo<ThirdPartyStationInfoVO> pageInfo = new PageInfo<>(stationInfos);
+        List<StationInfo> resultList = new ArrayList<>();
+        for (ThirdPartyStationInfoVO pileStationInfo : pageInfo.getList()) {
+            StationInfo stationInfo = new StationInfo();
+            String stationId = String.valueOf(pileStationInfo.getId());
+            stationInfo.setStationID(stationId);
+            // MerchantInfoVO merchantInfo = pileMerchantInfoService.getMerchantInfo(String.valueOf(pileStationInfo.getMerchantId()));
+            stationInfo.setOperatorID(Constants.OPERATORID_LIANLIAN); // 组织机构代码
+            stationInfo.setEquipmentOwnerID(String.valueOf(pileStationInfo.getMerchantId()));
+            stationInfo.setStationName(pileStationInfo.getStationName());
+            stationInfo.setIsAloneApply(Integer.valueOf(pileStationInfo.getAloneApply()));
+            stationInfo.setIsPublicParkingLot(Integer.valueOf(pileStationInfo.getPublicParking()));
+            stationInfo.setCountryCode(pileStationInfo.getCountryCode());
+            stationInfo.setAreaCode(pileStationInfo.getAreaCode());
+            stationInfo.setAddress(pileStationInfo.getAddress());
+            stationInfo.setServiceTel(pileStationInfo.getStationTel());
+            stationInfo.setStationType(Integer.valueOf(pileStationInfo.getStationType()));
+            stationInfo.setParkNums(Integer.valueOf(pileStationInfo.getParkNums()));
+            stationInfo.setStationLng(new BigDecimal(pileStationInfo.getStationLng()));
+            stationInfo.setStationLat(new BigDecimal(pileStationInfo.getStationLat()));
+            stationInfo.setConstruction(Integer.valueOf(pileStationInfo.getConstruction()));
+            stationInfo.setOpenAllDay(Integer.valueOf(pileStationInfo.getOpenAllDay()));
+            // stationInfo.setMinElectricityPrice(pileStationInfo); // 最低充电电费率
+            // stationInfo.setElectricityFee(); // 电费 xx元/度
+            // stationInfo.setServiceFee(); // 服务费 xx元/度
+            stationInfo.setParkFree(Integer.valueOf(pileStationInfo.getParkFree()));
+            stationInfo.setPayment(pileStationInfo.getPayment());
+            stationInfo.setSupportOrder(Integer.valueOf(pileStationInfo.getSupportOrder()));
+            // stationInfo.setParkFeeType(pileStationInfo); // 停车收费类型
+            stationInfo.setToiletFlag(Integer.valueOf(pileStationInfo.getToiletFlag()));
+            stationInfo.setStoreFlag(Integer.valueOf(pileStationInfo.getStoreFlag()));
+            stationInfo.setRestaurantFlag(Integer.valueOf(pileStationInfo.getRestaurantFlag()));
+            stationInfo.setLoungeFlag(Integer.valueOf(pileStationInfo.getLoungeFlag()));
+            stationInfo.setCanopyFlag(Integer.valueOf(pileStationInfo.getCanopyFlag()));
+            stationInfo.setPrinterFlag(Integer.valueOf(pileStationInfo.getPrinterFlag()));
+            stationInfo.setBarrierFlag(Integer.valueOf(pileStationInfo.getBarrierFlag()));
+            stationInfo.setParkingLockFlag(Integer.valueOf(pileStationInfo.getParkingLockFlag()));
+
+            List<EquipmentInfo> pileList = pileBasicInfoService.getPileListForLianLian(stationId);
+            if (CollectionUtils.isNotEmpty(pileList)) {
+                stationInfo.setEquipmentInfos(pileList); // 充电设备信息列表
+            }
+
+            resultList.add(stationInfo);
+        }
+        Map<String, Object> map = new LinkedHashMap<>();
+        map.put("PageNo", pageInfo.getPageNum());
+        map.put("PageCount", pageInfo.getPages());
+        map.put("ItemSize", resultList.size());
+        map.put("StationInfos", resultList);
+
+        // Map<String, String> resultMap = Maps.newLinkedHashMap();
+        // 加密数据
+        // String encryptData = Cryptos.aesEncrypt(JSON.toJSONString(map), configInfo.getDataSecret(), configInfo.getDataSecretIv());
+        // resultMap.put("Data", encryptData);
+        // 生成sig
+        // String resultSign = GBSignUtils.sign(resultMap, configInfo.getSignSecret());
+        // resultMap.put("Sig", resultSign);
+
+        Map<String, String> resultMap = ThirdPartyPlatformUtils.generateResultMap(map, configInfo);
+        return resultMap;
     }
 
     /**
@@ -130,7 +246,82 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
      */
     @Override
     public Map<String, String> queryStationStatus(QueryStationInfoDTO dto) {
-        return ThirdPartyPlatformService.super.queryStationStatus(dto);
+        List<String> stationIds = dto.getStationIds();
+        List<StationStatusInfo> StationStatusInfos = new ArrayList<>();
+        List<Object> connectorStatusInfos = new ArrayList<>();
+        ThirdPartyPlatformConfig configInfo = thirdPartyPlatformConfigService.getInfoByOperatorId(dto.getOperatorId());
+        if (configInfo == null) {
+            return null;
+        }
+        ConnectorStatusInfo connectorStatusInfo;
+        for (String stationId : stationIds) {
+            StationStatusInfo stationStatusInfo = new StationStatusInfo();
+            stationStatusInfo.setStationId(stationId);
+            // 根据站点id查询
+            List<ConnectorInfoVO> list = pileConnectorInfoService.getConnectorListForLianLian(Long.parseLong(stationId));
+            for (ConnectorInfoVO connectorInfoVO : list) {
+
+                String connectorStatus = connectorInfoVO.getConnectorStatus();
+                if (StringUtils.equals(connectorStatus, PileConnectorDataBaseStatusEnum.OCCUPIED_CHARGING.getValue())) {
+                    // 充电中
+                    ConnectorChargeStatusInfo info = new ConnectorChargeStatusInfo();
+                    OrderBasicInfo orderBasicInfo = orderBasicInfoService.queryChargingByPileConnectorCode(connectorInfoVO.getPileConnectorCode());
+                    if (orderBasicInfo == null) {
+                        continue;
+                    }
+                    List<RealTimeMonitorData> chargingRealTimeData = orderBasicInfoService.getChargingRealTimeData(orderBasicInfo.getTransactionCode());
+                    if (CollectionUtils.isNotEmpty(chargingRealTimeData)) {
+                        RealTimeMonitorData realTimeMonitorData = chargingRealTimeData.get(0);
+                        info.setStartChargeSeq(orderBasicInfo.getOrderCode());
+                        info.setConnectorID(orderBasicInfo.getPileConnectorCode());
+                        info.setConnectorStatus(Integer.valueOf(connectorInfoVO.getConnectorStatus()));
+                        info.setCurrentA(new BigDecimal(realTimeMonitorData.getOutputCurrent()));
+                        info.setVoltageA(new BigDecimal(realTimeMonitorData.getOutputVoltage()));
+                        info.setSoc(new BigDecimal(realTimeMonitorData.getSOC()));
+                        info.setStartTime(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, orderBasicInfo.getChargeStartTime()));
+                        info.setEndTime(DateUtils.getDateTime()); // 本次采样时间
+                        info.setTotalPower(new BigDecimal(realTimeMonitorData.getChargingDegree())); // 累计充电量
+                        // info.setElecMoney(); // 累计电费
+                        // info.setSeviceMoney(); // 累计服务费
+                        info.setTotalMoney(new BigDecimal(realTimeMonitorData.getChargingAmount()));
+                        connectorStatusInfos.add(info);
+                    }
+                } else {
+                    // 其他
+                    connectorStatusInfo = new ConnectorStatusInfo();
+                    connectorStatusInfo.setConnectorID(connectorInfoVO.getPileConnectorCode());
+                    connectorStatusInfo.setStatus(Integer.parseInt(connectorInfoVO.getConnectorStatus()));
+                    connectorStatusInfos.add(connectorStatusInfo);
+                }
+            }
+            stationStatusInfo.setConnectorStatusInfos(connectorStatusInfos);
+            StationStatusInfos.add(stationStatusInfo);
+        }
+        // 将 StationStatusInfos 分页
+        int pageNum = 1;
+        int pageSize = 10;
+        List<StationStatusInfo> collect = StationStatusInfos.stream()
+                .skip((pageNum - 1) * pageSize)
+                .limit(pageSize)
+                .collect(Collectors.toList());
+
+        int total = StationStatusInfos.size();
+        int pages = PageUtil.totalPage(total, pageSize);
+
+        Map<String, Object> map = new LinkedHashMap<>();
+        map.put("Total", total);
+        map.put("StationStatusInfos", collect);
+
+        // Map<String, String> resultMap = Maps.newLinkedHashMap();
+        // // 加密数据
+        // String encryptData = Cryptos.aesEncrypt(JSON.toJSONString(map), configInfo.getDataSecret(), configInfo.getDataSecretIv());
+        // resultMap.put("Data", encryptData);
+        // // 生成sig
+        // String resultSign = GBSignUtils.sign(resultMap, configInfo.getSignSecret());
+        // resultMap.put("Sig", resultSign);
+
+        Map<String, String> resultMap = ThirdPartyPlatformUtils.generateResultMap(map, configInfo);
+        return resultMap;
     }
 
     /**
@@ -143,7 +334,34 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
      */
     @Override
     public String notificationStationStatus(String pileConnectorCode, String status) {
-        return ThirdPartyPlatformService.super.notificationStationStatus(pileConnectorCode, status);
+        // 查出该桩所属哪个站点
+        String pileSn = StringUtils.substring(pileConnectorCode, 0, 14);
+        PileStationVO stationVO = pileStationInfoService.getStationInfoByPileSn(pileSn);
+        // 通过站点id查询相关配置信息
+        ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(stationVO.getId());
+        if (relationInfo == null) {
+            return null;
+        }
+        String operatorId = relationInfo.getOperatorId();
+        String operatorSecret = relationInfo.getOperatorSecret();
+        String signSecret = relationInfo.getSignSecret();
+        String dataSecret = relationInfo.getDataSecret();
+        String dataSecretIv = relationInfo.getDataSecretIv();
+        String urlAddress = relationInfo.getUrlAddress();
+
+        String url = urlAddress + BusinessInformationExchangeEnum.NOTIFICATION_STATION_STATUS.getValue();
+        ConnectorStatusInfo info = ConnectorStatusInfo.builder()
+                .connectorID(pileConnectorCode)
+                .status(Integer.parseInt(status))
+                .build();
+        // 调用联联平台接口
+        JSONObject json = new JSONObject();
+        json.put("ConnectorStatusInfo", info);
+        String jsonString = JSON.toJSONString(json);
+        // 获取令牌
+        String token = getToken(urlAddress, operatorId, operatorSecret, dataSecretIv, signSecret, dataSecret);
+        String result = HttpRequestUtil.sendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret);
+        return result;
     }
 
     /**
@@ -154,7 +372,120 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
      */
     @Override
     public String notificationChargeOrderInfo(String orderCode) {
-        return ThirdPartyPlatformService.super.notificationChargeOrderInfo(orderCode);
+        // 根据订单号查询出信息
+        OrderBasicInfo orderBasicInfo = orderBasicInfoService.getOrderInfoByOrderCode(orderCode);
+        OrderDetail orderDetail = orderBasicInfoService.getOrderDetailByOrderCode(orderCode);
+
+        // 通过站点id查询相关配置信息
+        ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(orderBasicInfo.getStationId());
+        if (relationInfo == null) {
+            return null;
+        }
+        String operatorId = relationInfo.getOperatorId();
+        String operatorSecret = relationInfo.getOperatorSecret();
+        String signSecret = relationInfo.getSignSecret();
+        String dataSecret = relationInfo.getDataSecret();
+        String dataSecretIv = relationInfo.getDataSecretIv();
+        String urlAddress = relationInfo.getUrlAddress();
+
+        String url = urlAddress + "notification_orderInfo";
+
+        // 拼装成联联平台所需格式对象
+        OrderInfo orderInfo = OrderInfo.builder()
+                .operatorID(operatorId)
+                .equipmentOwnerID(Constants.OPERATORID_LIANLIAN)
+                .stationID("LC" + orderBasicInfo.getStationId())
+                .equipmentID(orderBasicInfo.getPileSn())
+                .connectorID(orderBasicInfo.getPileConnectorCode())
+                .startChargeSeq(orderCode)
+                .userChargeType(Constants.one)
+                .money(new BigDecimal(String.valueOf(orderBasicInfo.getOrderAmount())).setScale(2, BigDecimal.ROUND_HALF_UP))
+                .electMoney(new BigDecimal(String.valueOf(orderDetail.getTotalElectricityAmount())).setScale(2, BigDecimal.ROUND_HALF_UP))
+                .serviceMoney(new BigDecimal(String.valueOf(orderDetail.getTotalServiceAmount())).setScale(2, BigDecimal.ROUND_HALF_UP))
+                .elect(new BigDecimal(String.valueOf(orderDetail.getTotalUsedElectricity())).setScale(2, BigDecimal.ROUND_HALF_UP))
+                .startTime(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, orderBasicInfo.getChargeStartTime()))
+                .endTime(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, orderBasicInfo.getChargeEndTime()))
+                .paymentAmount(orderBasicInfo.getPayAmount())
+                // .payChannel()
+                .stopReason(0)
+                // .chargeDetails()
+                .build();
+        if (StringUtils.equals("35", orderBasicInfo.getMerchantId())) {
+            orderInfo.setEquipmentOwnerID(Constants.OPERATORID_XI_XIAO);
+        }
+        // 支付方式
+        if (StringUtils.equals(orderBasicInfo.getPayMode(), OrderPayModeEnum.PAYMENT_OF_WECHATPAY.getValue())) {
+            // 微信支付
+            orderInfo.setPayChannel(Integer.valueOf(PayChannelEnum.WEXIN_PAY.getCode()));
+        } else if (StringUtils.equals(orderBasicInfo.getPayMode(), OrderPayModeEnum.PAYMENT_OF_ALIPAY.getValue())) {
+            // 支付宝支付
+            orderInfo.setPayChannel(Integer.valueOf(PayChannelEnum.ALI_PAY.getCode()));
+        } else {
+            // 其他
+            orderInfo.setPayChannel(Integer.valueOf(PayChannelEnum.OTHER.getCode()));
+        }
+        // 订单详情
+        ChargeDetail detail;
+
+        List<BillingPriceVO> billingList = pileBillingTemplateService.queryBillingPrice(orderBasicInfo.getStationId());
+        // 先将list按照 尖、峰、平、谷 时段排序
+        // List<BillingPriceVO> collect = billingList.stream().sorted(Comparator.comparing(BillingPriceVO::getTimeType)).collect(Collectors.toList());
+        // 再循环该list，拼装对应的充电价格、费率
+        List<ChargeDetail> chargeDetails = new ArrayList<>();
+        for (BillingPriceVO billingPriceVO : billingList) {
+            detail = new ChargeDetail();
+            if (StringUtils.equals(billingPriceVO.getTimeType(), "1")) {
+                // 尖时段
+                detail.setDetailStartTime(billingPriceVO.getStartTime());
+                detail.setDetailEndTime(billingPriceVO.getEndTime());
+                detail.setElecPrice(new BigDecimal(billingPriceVO.getElectricityPrice()).setScale(4, BigDecimal.ROUND_HALF_UP));
+                detail.setSevicePrice(new BigDecimal(billingPriceVO.getServicePrice()).setScale(4, BigDecimal.ROUND_HALF_UP));
+                detail.setDetailPower(orderDetail.getSharpUsedElectricity());
+                detail.setDetailElecMoney(orderDetail.getSharpElectricityPrice());
+                detail.setDetailSeviceMoney(orderDetail.getSharpServicePrice());
+            } else if (StringUtils.equals(billingPriceVO.getTimeType(), "2")) {
+                // 峰时段
+                detail.setDetailStartTime(billingPriceVO.getStartTime());
+                detail.setDetailEndTime(billingPriceVO.getEndTime());
+                detail.setElecPrice(new BigDecimal(billingPriceVO.getElectricityPrice()).setScale(4, BigDecimal.ROUND_HALF_UP));
+                detail.setSevicePrice(new BigDecimal(billingPriceVO.getServicePrice()).setScale(4, BigDecimal.ROUND_HALF_UP));
+                detail.setDetailPower(orderDetail.getPeakUsedElectricity());
+                detail.setDetailElecMoney(orderDetail.getPeakElectricityPrice());
+                detail.setDetailSeviceMoney(orderDetail.getPeakServicePrice());
+            } else if (StringUtils.equals(billingPriceVO.getTimeType(), "3")) {
+                // 平时段
+                detail.setDetailStartTime(billingPriceVO.getStartTime());
+                detail.setDetailEndTime(billingPriceVO.getEndTime());
+                detail.setElecPrice(new BigDecimal(billingPriceVO.getElectricityPrice()).setScale(4, BigDecimal.ROUND_HALF_UP));
+                detail.setSevicePrice(new BigDecimal(billingPriceVO.getServicePrice()).setScale(4, BigDecimal.ROUND_HALF_UP));
+                detail.setDetailPower(orderDetail.getFlatUsedElectricity());
+                detail.setDetailElecMoney(orderDetail.getFlatElectricityPrice());
+                detail.setDetailSeviceMoney(orderDetail.getFlatServicePrice());
+            } else if (StringUtils.equals(billingPriceVO.getTimeType(), "4")) {
+                // 谷时段
+                detail.setDetailStartTime(billingPriceVO.getStartTime());
+                detail.setDetailEndTime(billingPriceVO.getEndTime());
+                detail.setElecPrice(new BigDecimal(billingPriceVO.getElectricityPrice()).setScale(4, BigDecimal.ROUND_HALF_UP));
+                detail.setSevicePrice(new BigDecimal(billingPriceVO.getServicePrice()).setScale(4, BigDecimal.ROUND_HALF_UP));
+                detail.setDetailPower(orderDetail.getValleyUsedElectricity());
+                detail.setDetailElecMoney(orderDetail.getValleyElectricityPrice());
+                detail.setDetailSeviceMoney(orderDetail.getValleyServicePrice());
+            }
+            chargeDetails.add(detail);
+        }
+        orderInfo.setChargeDetails(chargeDetails);
+
+        // 获取令牌
+        String token = getToken(urlAddress, operatorId, operatorSecret, dataSecretIv, signSecret, dataSecret);
+        if (StringUtils.isBlank(token)) {
+            return null;
+        }
+        // 调用联联平台接口
+        JSONObject json = new JSONObject();
+        json.put("OrderInfo", orderInfo);
+        String jsonString = JSON.toJSONString(json);
+        String result = HttpRequestUtil.sendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret);
+        return result;
     }
 
     /**
@@ -166,7 +497,51 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
      */
     @Override
     public String notificationEquipChargeStatus(String orderCode) {
-        return ThirdPartyPlatformService.super.notificationEquipChargeStatus(orderCode);
+        // 根据订单号查询订单信息
+        OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByOrderCode(orderCode);
+        // 通过站点id查询相关配置信息
+        ThirdPartyStationRelation relation = new ThirdPartyStationRelation();
+        relation.setStationId(Long.parseLong(orderInfo.getStationId()));
+        ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(relation);
+        // ThirdPartySettingInfo settingInfo = thirdPartySettingInfoService.getInfoByStationId(Long.parseLong(orderInfo.getStationId()));
+        if (relationInfo == null) {
+            return null;
+        }
+        String operatorId = relationInfo.getOperatorId();
+        String operatorSecret = relationInfo.getOperatorSecret();
+        String signSecret = relationInfo.getSignSecret();
+        String dataSecret = relationInfo.getDataSecret();
+        String dataSecretIv = relationInfo.getDataSecretIv();
+        String urlAddress = relationInfo.getUrlAddress();
+        String thirdPartyType = relationInfo.getThirdPartyType();
+
+        // 调用 查询充电状态方法
+        QueryEquipChargeStatusDTO dto = new QueryEquipChargeStatusDTO();
+        dto.setStartChargeSeq(orderCode);
+        // 根据type获取operatorId
+        String operatorIdByType = ThirdPartyOperatorIdEnum.getOperatorIdByType(thirdPartyType);
+        dto.setOperatorID(operatorIdByType);
+        Map<String, String> map = queryEquipChargeStatus(dto);
+        if (map == null) {
+            return null;
+        }
+        String data = map.get("Data");
+        // 解密data (此处解密需用 thirdparty_platform_config 的密钥配置)
+        ThirdPartyPlatformConfig configInfo = thirdPartyPlatformConfigService.getInfoByOperatorId(operatorIdByType);
+        byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(data),
+                configInfo.getDataSecret().getBytes(), configInfo.getDataSecretIv().getBytes());
+        String dataStr = new String(plainText, StandardCharsets.UTF_8);
+        // 转成对应的对象
+        QueryChargingStatusVO vo = JSONObject.parseObject(dataStr, QueryChargingStatusVO.class);
+
+        String url = urlAddress + BusinessInformationExchangeEnum.NOTIFICATION_EQUIP_CHARGE_STATUS.getValue();
+        // 调用联联平台接口
+        String jsonString = JSON.toJSONString(vo);
+
+        // 获取令牌
+        String token = getToken(urlAddress, operatorId, operatorSecret, dataSecretIv, signSecret, dataSecret);
+        String result = HttpRequestUtil.sendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret);
+        return result;
     }
 
     /**

jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/util/ThirdPartyPlatformUtils.java

@@ -0,0 +1,41 @@
+package com.jsowell.thirdparty.platform.util;
+
+import com.alibaba.fastjson2.JSON;
+import com.google.common.collect.Maps;
+import com.jsowell.pile.domain.ThirdPartyPlatformConfig;
+
+import java.util.Map;
+
+public class ThirdPartyPlatformUtils {
+
+    /**
+     * 生成结果集
+     * @param obj 需要返回的数据
+     * @param config 密钥配置信息对象
+     * @return 结果集
+     */
+    public static Map<String, String> generateResultMap(Object obj, ThirdPartyPlatformConfig config) {
+        return generateResultMap(obj, config.getDataSecret(), config.getDataSecretIv(), config.getSignSecret());
+    }
+
+    /**
+     * 生成结果集
+     * @param obj 需要返回的数据
+     * @param dataSecret 消息密钥
+     * @param dataSecretIv 消息密钥初始化向量
+     * @param signSecret 签名密钥
+     * @return 结果集
+     */
+    public static Map<String, String> generateResultMap(Object obj, String dataSecret, String dataSecretIv, String signSecret) {
+        Map<String, String> resultMap = Maps.newHashMap();
+        // 加密数据
+        String encryptData = Cryptos.aesEncrypt(JSON.toJSONString(obj), dataSecret, dataSecretIv);
+        resultMap.put("Data", encryptData);
+        // 生成sig
+        String resultSign = GBSignUtils.sign(resultMap, signSecret);
+        resultMap.put("Sig", resultSign);
+        return resultMap;
+    }
+
+
+}