Merge branch 'dev' of http://192.168.2.2:8099/jsowell/jsowell-charger-web into dev

jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/ThirdPartyPlatformService.java

@@ -38,9 +38,9 @@ public interface ThirdPartyPlatformService {
         throw new UnsupportedOperationException("This method is not yet implemented");
     }
 
-    default Map<String, String> queryToken(String operatorId, String operatorSecret) {
-        throw new UnsupportedOperationException("This method is not yet implemented");
-    }
+    // default Map<String, String> queryToken(String operatorId, String operatorSecret) {
+    //     throw new UnsupportedOperationException("This method is not yet implemented");
+    // }
 
     // =================================================================================== //
     // ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓  由我方平台实现此接口，对方平台调用的查询接口 ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓ ↓ //
@@ -234,15 +234,6 @@ public interface ThirdPartyPlatformService {
         throw new UnsupportedOperationException("This method is not yet implemented");
     }
 
-    /**
-     * 订单信息推送 notification_orderInfo
-     *
-     * @throws UnsupportedOperationException 未实现异常
-     */
-    default String notificationOrderInfo(String orderCode) {
-        throw new UnsupportedOperationException("This method is not yet implemented");
-    }
-
     /**
      * 站点费率变化推送 notification_stationFee
      *
@@ -253,11 +244,7 @@ public interface ThirdPartyPlatformService {
     }
 
     /**
-     * 充电订单推送 notification_charge_order_info
-     * TODO 海南一张网文档中的接口，检查一下是否和订单信息推送notification_orderInfo一致
-     * TODO 甬城泊车平台文档中的接口，检查一下是否和订单信息推送notification_orderInfo一致
-     * TODO 华为平台文档中的接口，检查一下是否和订单信息推送notification_orderInfo一致
-     * TODO 内蒙古平台文档中的接口，检查一下是否和订单信息推送notification_orderInfo一致
+     * 充电订单推送 notification_charge_order_info/notification_orderInfo
      *
      * @param orderCode 订单编号
      * @throws UnsupportedOperationException 未实现异常

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

@@ -0,0 +1,357 @@
+package com.jsowell.thirdparty.platform.common;
+
+
+import com.alibaba.fastjson2.annotation.JSONField;
+import com.jsowell.pile.thirdparty.EquipmentInfo;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 充电站信息
+ * 第三方平台使用
+ */
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+public class StationInfo {
+    /**
+     * 充电站ID  Y
+     * 对接平台自定义的唯一编码
+     */
+    @JSONField(name = "StationID")
+    private String stationID;
+
+    /**
+     * 对接平台ID  Y
+     * 组织机构代码
+     */
+    @JSONField(name = "OperatorID")
+    private String operatorID;
+
+    /**
+     * 设备所属运营商ID  Y
+     * 设备所属运营商组织机构代码
+     */
+    @JSONField(name = "EquipmentOwnerID")
+    private String equipmentOwnerID;
+
+    /**
+     * 充电站名称  Y
+     * 充电站名称的描述
+     */
+    @JSONField(name = "StationName")
+    private String stationName;
+
+    /**
+     * 是否独立报桩 (0-否;1-是) Y
+     * 如果是独立报桩需要填写户号以及容量
+     */
+    @JSONField(name = "IsAloneApply")
+    private Integer isAloneApply;
+
+    /**
+     * 户号  N
+     * 国网电费账单户号
+     */
+    @JSONField(name = "AccountNumber")
+    private String accountNumber;
+
+    /**
+     * 容量(单位KW)  N
+     * 独立电表申请的功率
+     */
+    @JSONField(name = "Capacity")
+    private BigDecimal capacity;
+
+    /**
+     * 是否是公共停车场库 (0-否;1-是)  Y
+     * 如果是公共停车场库需要填写场库编号
+     */
+    @JSONField(name = "IsPublicParkingLot")
+    private Integer isPublicParkingLot;
+
+    /**
+     * 停车场库编号  N
+     * 公共停车场库编号
+     */
+    @JSONField(name = "ParkingLotNumber")
+    private String parkingLotNumber;
+
+    /**
+     * 充电站国家代码  Y
+     * 比如CN
+     */
+    @JSONField(name = "CountryCode")
+    private String countryCode;
+
+    /**
+     * 充电站省市辖区编码  Y
+     * 填写内容为参照 GB/T2260-2015
+     */
+    @JSONField(name = "AreaCode")
+    private String areaCode;
+
+    /**
+     * 详细地址  Y
+     */
+    @JSONField(name = "Address")
+    private String address;
+
+    /**
+     * 站点电话  N
+     * 能够联系场站工作人员进行协助的联系电话
+     */
+    // private String StationTel;
+
+    /**
+     * 服务电话  Y
+     * 平台服务电话，例如400 的电话
+     */
+    @JSONField(name = "ServiceTel")
+    private String serviceTel;
+
+    /**
+     * 站点类型  Y
+     * 1-公共
+     * 50-个人
+     * 100-公交（专用）
+     * 101-环卫（专用）
+     * 102-物流（专用）
+     * 103-出租车（专用）
+     * 104-分时租赁（专用）
+     * 105-小区共享（专用）
+     * 106-单位（专用）
+     * 255-其他
+     */
+    @JSONField(name = "StationType")
+    private Integer stationType;
+
+    /**
+     * 站点状态  Y
+     * 0：未知
+     * 1：建设中
+     * 5：关闭下线
+     * 6：维护中
+     * 50：正常使用
+     */
+    @JSONField(name = "StationStatus")
+    private Integer stationStatus;
+
+    /**
+     * 车位数量  Y
+     * 可停放进行充电的车位总数(默认：0-未知)
+     */
+    @JSONField(name = "ParkNums")
+    private Integer parkNums;
+
+    /**
+     * 经度  Y
+     * GCJ-02坐标系
+     */
+    @JSONField(name = "StationLng")
+    private BigDecimal stationLng;
+
+    /**
+     * 纬度  Y
+     * GCJ-02坐标系
+     */
+    @JSONField(name = "StationLat")
+    private BigDecimal stationLat;
+
+    /**
+     * 站点引导  N
+     * 描述性文字，用于引导车主找到充电车位
+     */
+    private String SiteGuide;
+
+    /**
+     * 建设场所  Y
+     * 1：居民区
+     * 2：公共机构
+     * 3：企事业单位
+     * 4：写字楼
+     * 5：工业园区
+     * 6：交通枢纽
+     * 7：大型文体设施
+     * 8：城市绿地
+     * 9：大型建筑配建停车场
+     * 10：路边停车位
+     * 11：城际高速服务区
+     * 12：风景区
+     * 13：公交场站
+     * 14：加油加气站
+     * 15：出租车
+     * 255：其他
+     */
+    @JSONField(name = "Construction")
+    private Integer construction;
+
+    /**
+     * 站点照片  N
+     * 充电设备照片、充电车位照片、停车场入口照片
+     */
+    private List<String> Pictures;
+
+    /**
+     * 使用车型描述  N
+     * 描述该站点接受的车大小以及类型，如大巴、物流车、私家乘用车、出租车等
+     */
+    private String MatchCars;
+
+    /**
+     * 车位楼层及数量描述  N
+     * 车位楼层以及数量信息
+     */
+    private String ParkInfo;
+
+    /**
+     * 停车场产权方  N
+     * 停车场产权人
+     */
+    // private String ParkOwner;
+
+    /**
+     * 停车场管理方  N
+     * 停车场管理人（如：XX 物业）
+     */
+    // private String ParkManager;
+
+    /**
+     * 全天开放  Y
+     * 是否全天开放(0-否；1-是),如果为0，则营业时间必填
+     */
+    @JSONField(name = "OpenAllDay")
+    private Integer openAllDay;
+
+    /**
+     * 营业时间  N
+     * 营业时间描述,推荐格式：周一至周日00:00-24:00
+     */
+    // private String BusinessHours;
+
+    /**
+     * 最低单价  Y
+     * 最低充电电费率
+     */
+    @JSONField(name = "MinElectricityPrice")
+    private BigDecimal minElectricityPrice;
+
+    /**
+     * 充电电费率  Y
+     * 充电费描述,推荐格式：XX 元/度
+     */
+    @JSONField(name = "ElectricityFee")
+    private String electricityFee;
+
+    /**
+     * 服务费率  Y
+     * 服务费率描述,推荐格式：XX 元/度
+     */
+    @JSONField(name = "ServiceFee")
+    private String serviceFee;
+
+    /**
+     * 免费停车  Y
+     * 是否停车免费(0-否；1-是)
+     */
+    @JSONField(name = "ParkFree")
+    private Integer parkFree;
+
+    /**
+     * 停车费  N
+     * 停车费率描述
+     */
+    // private String ParkFee;
+
+    /**
+     * 支付方式  Y
+     * 支付方式:刷卡、线上、现金  其中电子钱包类卡为刷卡，身份鉴权卡、微信/ 支付宝、APP为线上
+     */
+    @JSONField(name = "Payment")
+    private String payment;
+
+    /**
+     * 是否支持预约  Y
+     * 充电设备是否需要提前预约后才能使用。(0-不支持预约;1-支持预约)  不填默认为0
+     */
+    @JSONField(name = "SupportOrder")
+    private Integer supportOrder;
+
+    /**
+     * 备注  N
+     * 其他备注信息
+     */
+    // private String Remark;
+
+    /**
+     * 充电设备信息列表  Y
+     * 该充电站所有充电设备信息对象集合
+     */
+    @JSONField(name = "EquipmentInfos")
+    private List<EquipmentInfo> equipmentInfos;
+
+    /**
+     * 停车收费类型  Y
+     * 0:停车收费;
+     * 1:停车免费;
+     * 2:限时免费;
+     * 3:充电限免
+     */
+    @JSONField(name = "ParkFeeType")
+    private Integer parkFeeType;
+
+    /**
+     * 是否靠近卫生间(0-否；1-是)  Y
+     */
+    @JSONField(name = "ToiletFlag")
+    private Integer toiletFlag;
+
+    /**
+     * 是否靠近便利店(0-否；1-是)  Y
+     */
+    @JSONField(name = "StoreFlag")
+    private Integer storeFlag;
+
+    /**
+     * 是否靠近餐厅(0-否；1-是)  Y
+     */
+    @JSONField(name = "RestaurantFlag")
+    private Integer restaurantFlag;
+
+    /**
+     * 是否靠近休息室(0-否；1-是)  Y
+     */
+    @JSONField(name = "LoungeFlag")
+    private Integer loungeFlag;
+
+    /**
+     * 是否有雨棚(0-否；1-是)  Y
+     */
+    @JSONField(name = "CanopyFlag")
+    private Integer canopyFlag;
+
+    /**
+     * 是否有小票机(0-否；1-是)  Y
+     */
+    @JSONField(name = "PrinterFlag")
+    private Integer printerFlag;
+
+    /**
+     * 是否有道闸(0-否；1-是)  Y
+     */
+    @JSONField(name = "BarrierFlag")
+    private Integer barrierFlag;
+
+    /**
+     * 是否有地锁(0-否；1-是)  Y
+     */
+    @JSONField(name = "ParkingLockFlag")
+    private Integer parkingLockFlag;
+
+}

jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/hainan/service/HaiNanPlatformServiceImpl.java

@@ -70,7 +70,7 @@ import java.util.stream.Collectors;
 public class HaiNanPlatformServiceImpl implements ThirdPartyPlatformService {
     Logger logger = LoggerFactory.getLogger(HaiNanPlatformServiceImpl.class);
     // 平台类型
-    private final String platformType = ThirdPlatformTypeEnum.HAI_NAN_1.getTypeCode();
+    private final String platformType = ThirdPlatformTypeEnum.HAI_NAN_1_PLATFORM.getTypeCode();
 
     @Autowired
     private PileMerchantInfoService pileMerchantInfoService;

jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/lianlian/service/LianLianPlatformServiceImpl.java

@@ -36,6 +36,7 @@ import com.jsowell.thirdparty.lianlian.domain.*;
 import com.jsowell.thirdparty.lianlian.vo.AccessTokenVO;
 import com.jsowell.thirdparty.lianlian.vo.EquipmentAuthVO;
 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.Encodes;
 import com.jsowell.thirdparty.platform.util.GBSignUtils;
@@ -682,7 +683,7 @@ public class LianLianPlatformServiceImpl implements ThirdPartyPlatformService {
      * @throws UnsupportedOperationException 未实现异常
      */
     @Override
-    public String notificationOrderInfo(String orderCode) {
+    public String notificationChargeOrderInfo(String orderCode) {
 
         // 根据订单号查询出信息
         OrderBasicInfo orderBasicInfo = orderBasicInfoService.getOrderInfoByOrderCode(orderCode);

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

@@ -0,0 +1,32 @@
+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;
+
+/**
+ * 内蒙古平台站点信息
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class SupStationInfo extends StationInfo {
+    /**
+     * 充换电站唯一编码
+     * 行政区划代码，区县地区码（6位）+运营商ID（9位）+充换电站ID
+     */
+    @JSONField(name = "StationUniqueNumber")
+    private String stationUniqueNumber;
+
+    /**
+     * 充换电站所在县以下行政区划代码
+     * 填写内容为12位行政区划代码，1-6位为县及以上行政区划代码，7-12位为县以下区划代码；
+     * 参考地址：http://www.stats.gov.cn/sj/tjbz/tjyqhdmhcxhfdm/2022/
+     */
+    @JSONField(name = "AreaCodeCountryside")
+    private String areaCodeCountryside;
+}

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

@@ -1,15 +1,193 @@
 package com.jsowell.thirdparty.platform.neimenggu.service;
 
+import com.alibaba.fastjson2.JSON;
+import com.google.common.collect.Maps;
 import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
+import com.jsowell.common.exception.BusinessException;
+import com.jsowell.common.util.JWTUtils;
+import com.jsowell.common.util.StringUtils;
+import com.jsowell.pile.domain.ThirdPartyPlatformConfig;
+import com.jsowell.pile.domain.ThirdPartyStationRelation;
+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.thirdparty.CommonParamsDTO;
+import com.jsowell.thirdparty.lianlian.vo.AccessTokenVO;
 import com.jsowell.thirdparty.platform.ThirdPartyPlatformService;
+import com.jsowell.thirdparty.platform.util.Cryptos;
+import com.jsowell.thirdparty.platform.util.GBSignUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+import java.util.Map;
+
 /**
  * 内蒙古监测平台逻辑
  */
 @Service
 public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
     // 平台类型
-    private final String platformType = ThirdPlatformTypeEnum.NEI_MENG_GU_PLATFORM.getTypeCode();
+    private final String thirdPlatformType = ThirdPlatformTypeEnum.NEI_MENG_GU_PLATFORM.getTypeCode();
 
+    @Autowired
+    private ThirdPartyPlatformConfigService thirdPartyPlatformConfigService;
+
+    @Autowired
+    private ThirdPartyStationRelationService thirdPartyStationRelationService;
+
+    /**
+     * query_token 获取token，提供给第三方平台使用
+     *
+     * @param dto
+     * @return
+     */
+    @Override
+    public Map<String, String> queryToken(CommonParamsDTO dto) {
+        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 {
+            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("密钥不一致");
+            }
+        } 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);
+
+        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);
+        return resultMap;
+    }
+
+    /**
+     * 查询运营商信息 query_operator_info
+     * supervise_query_operator_info
+     *
+     * @param dto 查询运营商信息DTO
+     * @throws UnsupportedOperationException 未实现异常
+     */
+    @Override
+    public Map<String, String> queryOperatorInfo(QueryOperatorInfoDTO dto) {
+        Map<String, String> resultMap = Maps.newHashMap();
+        // TODO 查询接入内蒙古平台的站点信息
+        List<ThirdPartyStationRelation> thirdPartyStationRelations =
+                thirdPartyStationRelationService.selectThirdPartyStationRelationList(thirdPlatformType);
+
+        return resultMap;
+    }
+
+    /**
+     * 查询充电站信息 query_stations_info
+     * 此接口用于查询对接平台的充电站的信息
+     *
+     * @param dto 查询站点信息dto
+     * @throws UnsupportedOperationException 未实现异常
+     */
+    @Override
+    public Map<String, String> queryStationsInfo(QueryStationInfoDTO dto) {
+        return ThirdPartyPlatformService.super.queryStationsInfo(dto);
+    }
+
+    /**
+     * 设备接口状态查询 query_station_status
+     *
+     * @param dto 查询站点信息dto
+     * @throws UnsupportedOperationException 未实现异常
+     */
+    @Override
+    public Map<String, String> queryStationStatus(QueryStationInfoDTO dto) {
+        return ThirdPartyPlatformService.super.queryStationStatus(dto);
+    }
+
+    /**
+     * 设备状态变化推送  notification_stationStatus
+     * 推送充电设备接口状态信息 supervise_notification_station_status
+     *
+     * @param pileConnectorCode 充电枪口编号
+     * @param status            枪口状态
+     * @throws UnsupportedOperationException 未实现异常
+     */
+    @Override
+    public String notificationStationStatus(String pileConnectorCode, String status) {
+        return ThirdPartyPlatformService.super.notificationStationStatus(pileConnectorCode, status);
+    }
+
+    /**
+     * 充电订单推送 notification_charge_order_info
+     *
+     * @param orderCode 订单编号
+     * @throws UnsupportedOperationException 未实现异常
+     */
+    @Override
+    public String notificationChargeOrderInfo(String orderCode) {
+        return ThirdPartyPlatformService.super.notificationChargeOrderInfo(orderCode);
+    }
+
+    /**
+     * 推送充电状态 notification_equip_charge_status
+     * 推送充电状态信息 supervise_notification_equip_charge_status
+     *
+     * @param orderCode 订单编号
+     * @throws UnsupportedOperationException 未实现异常
+     */
+    @Override
+    public String notificationEquipChargeStatus(String orderCode) {
+        return ThirdPartyPlatformService.super.notificationEquipChargeStatus(orderCode);
+    }
+
+    /**
+     * 推送充换电站用能统计信息 supervise_notification_operation_stats_info
+     *
+     * @param stationId
+     * @throws UnsupportedOperationException 未实现异常
+     */
+    @Override
+    public String notificationOperationStatsInfo(String stationId) {
+        return ThirdPartyPlatformService.super.notificationOperationStatsInfo(stationId);
+    }
+
+    /**
+     * 推送充电站历史充电订单信息 supervise_notification_charge_order_info_history
+     *
+     * @param stationId
+     * @throws UnsupportedOperationException 未实现异常
+     */
+    @Override
+    public String notificationChargeOrderInfoHistory(String stationId) {
+        return ThirdPartyPlatformService.super.notificationChargeOrderInfoHistory(stationId);
+    }
 }