2024-01-18 17:03:08 +08:00
|
|
|
package com.jsowell.thirdparty.common;
|
|
|
|
|
|
2024-01-25 11:37:38 +08:00
|
|
|
import com.alibaba.fastjson2.JSONObject;
|
|
|
|
|
import com.jsowell.common.constant.CacheConstants;
|
|
|
|
|
import com.jsowell.common.constant.Constants;
|
|
|
|
|
import com.jsowell.common.core.domain.ykc.RealTimeMonitorData;
|
|
|
|
|
import com.jsowell.common.core.redis.RedisCache;
|
|
|
|
|
import com.jsowell.common.enums.parkplatform.ParkingEnum;
|
2024-01-25 16:00:35 +08:00
|
|
|
import com.jsowell.common.enums.thirdparty.BusinessInformationExchangeEnum;
|
2024-01-19 11:43:20 +08:00
|
|
|
import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
|
2024-01-25 11:37:38 +08:00
|
|
|
import com.jsowell.common.enums.ykc.ReturnCodeEnum;
|
|
|
|
|
import com.jsowell.common.enums.ykc.StartModeEnum;
|
|
|
|
|
import com.jsowell.common.exception.BusinessException;
|
|
|
|
|
import com.jsowell.common.util.DateUtils;
|
2024-01-19 11:43:20 +08:00
|
|
|
import com.jsowell.common.util.StringUtils;
|
2024-01-25 11:37:38 +08:00
|
|
|
import com.jsowell.pile.domain.OrderBasicInfo;
|
|
|
|
|
import com.jsowell.pile.domain.PileBasicInfo;
|
2024-01-18 17:03:08 +08:00
|
|
|
import com.jsowell.pile.domain.ThirdPartyStationRelation;
|
2024-01-25 11:37:38 +08:00
|
|
|
import com.jsowell.pile.domain.ThirdpartyParkingConfig;
|
2024-01-18 17:03:08 +08:00
|
|
|
import com.jsowell.pile.dto.PushStationInfoDTO;
|
2024-01-25 11:37:38 +08:00
|
|
|
import com.jsowell.pile.dto.lutongyunting.BindCouponDTO;
|
|
|
|
|
import com.jsowell.pile.dto.ruanjie.UseCouponDTO;
|
|
|
|
|
import com.jsowell.pile.service.*;
|
2024-01-18 17:03:08 +08:00
|
|
|
import com.jsowell.pile.vo.base.ThirdPartyStationRelationVO;
|
2024-01-25 11:37:38 +08:00
|
|
|
import com.jsowell.pile.vo.web.PileStationVO;
|
2024-01-25 14:37:13 +08:00
|
|
|
import com.jsowell.thirdparty.platform.hainan.service.HaiNanPlatformLogic;
|
2024-01-19 11:43:20 +08:00
|
|
|
import com.jsowell.thirdparty.huawei.HuaWeiService;
|
|
|
|
|
import com.jsowell.thirdparty.lianlian.service.LianLianService;
|
2024-01-25 11:37:38 +08:00
|
|
|
import com.jsowell.thirdparty.lianlian.util.HttpRequestUtil;
|
|
|
|
|
import com.jsowell.thirdparty.lutongyunting.service.LTYTService;
|
2024-01-19 11:43:20 +08:00
|
|
|
import com.jsowell.thirdparty.nanrui.service.NRService;
|
2024-01-25 11:37:38 +08:00
|
|
|
import com.jsowell.thirdparty.ruanjie.service.RJService;
|
2024-01-19 11:43:20 +08:00
|
|
|
import com.jsowell.thirdparty.xindiantu.service.XDTService;
|
2024-01-25 11:37:38 +08:00
|
|
|
import com.jsowell.thirdparty.yongchengboche.dto.YCBCGetTokenDTO;
|
2024-01-19 11:43:20 +08:00
|
|
|
import com.jsowell.thirdparty.yongchengboche.service.YCBCService;
|
|
|
|
|
import com.jsowell.thirdparty.zhongdianlian.service.ZDLService;
|
2024-01-25 11:37:38 +08:00
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.apache.commons.collections4.CollectionUtils;
|
2024-01-18 17:03:08 +08:00
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
2024-01-25 11:37:38 +08:00
|
|
|
import java.io.UnsupportedEncodingException;
|
2024-01-19 11:43:20 +08:00
|
|
|
import java.text.ParseException;
|
|
|
|
|
import java.util.List;
|
2024-01-25 11:37:38 +08:00
|
|
|
import java.util.concurrent.TimeUnit;
|
2024-01-19 11:43:20 +08:00
|
|
|
|
2024-01-18 17:03:08 +08:00
|
|
|
/**
|
|
|
|
|
* TODO
|
|
|
|
|
*
|
|
|
|
|
* @author Lemon
|
|
|
|
|
* @Date 2024/1/18 15:11:32
|
|
|
|
|
*/
|
|
|
|
|
@Service
|
2024-01-25 11:37:38 +08:00
|
|
|
@Slf4j
|
2024-01-18 17:03:08 +08:00
|
|
|
public class CommonService {
|
|
|
|
|
|
2024-01-25 11:37:38 +08:00
|
|
|
@Autowired
|
|
|
|
|
private PileBasicInfoService pileBasicInfoService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private PileStationInfoService pileStationInfoService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private OrderBasicInfoService orderBasicInfoService;
|
|
|
|
|
|
2024-01-18 17:03:08 +08:00
|
|
|
@Autowired
|
|
|
|
|
private ThirdPartyStationRelationService thirdPartyStationRelationService;
|
|
|
|
|
|
2024-01-25 11:37:38 +08:00
|
|
|
@Autowired
|
|
|
|
|
private ThirdPartyParkingConfigService thirdPartyParkingConfigService;
|
|
|
|
|
|
2024-01-19 11:43:20 +08:00
|
|
|
@Autowired
|
|
|
|
|
private LianLianService lianLianService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private ZDLService zdlService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private NRService nrService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private YCBCService ycbcService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private XDTService xdtService;
|
|
|
|
|
|
2024-01-25 11:37:38 +08:00
|
|
|
@Autowired
|
|
|
|
|
private LTYTService ltytService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private RJService rjService;
|
|
|
|
|
|
2024-01-19 11:43:20 +08:00
|
|
|
@Autowired
|
|
|
|
|
private HuaWeiService huaWeiService;
|
|
|
|
|
|
2024-01-25 11:37:38 +08:00
|
|
|
@Autowired
|
2024-01-25 14:32:24 +08:00
|
|
|
private HaiNanPlatformLogic haiNanChargeService;
|
2024-01-25 11:37:38 +08:00
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private RedisCache redisCache;
|
|
|
|
|
|
2024-01-18 17:03:08 +08:00
|
|
|
/**
|
|
|
|
|
* 将站点--第三方平台类型对应关系存入关系表
|
|
|
|
|
* @param dto
|
|
|
|
|
*/
|
|
|
|
|
public void insertInfo2DataBase(PushStationInfoDTO dto) {
|
|
|
|
|
ThirdPartyStationRelation relation = new ThirdPartyStationRelation();
|
|
|
|
|
relation.setStationId(dto.getStationId());
|
|
|
|
|
relation.setThirdPartyType(dto.getThirdPartyType());
|
|
|
|
|
ThirdPartyStationRelationVO vo = thirdPartyStationRelationService.selectRelationInfo(relation);
|
|
|
|
|
if (vo != null) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
// 新增数据库
|
|
|
|
|
thirdPartyStationRelationService.insertThirdPartyStationRelation(relation);
|
|
|
|
|
}
|
2024-01-19 11:43:20 +08:00
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 统一方法推送站点信息
|
|
|
|
|
* @param dto
|
|
|
|
|
* @return
|
|
|
|
|
* @throws ParseException
|
|
|
|
|
*/
|
|
|
|
|
public String commonPushStation(PushStationInfoDTO dto) throws ParseException {
|
|
|
|
|
List<String> types = dto.getThirdPartyTypes();
|
|
|
|
|
|
|
|
|
|
String result = "";
|
|
|
|
|
StringBuilder finalResult = new StringBuilder();
|
|
|
|
|
for (String type : types) {
|
|
|
|
|
dto.setThirdPartyType(type);
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.LIAN_LIAN_PLATFORM.getCode(), dto.getThirdPartyType())) {
|
|
|
|
|
// 推送联联
|
|
|
|
|
// result = lianLianService.pushStationInfo(dto);
|
|
|
|
|
result = lianLianService.pushStationInfoV2(dto);
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.ZHONG_DIAN_LIAN_PLATFORM.getCode(), dto.getThirdPartyType())) {
|
|
|
|
|
// 中电联
|
|
|
|
|
// result = zdlService.pushStationInfo(dto);
|
|
|
|
|
result = zdlService.pushStationInfoV2(dto);
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.JIANG_SU_PLATFORM.getCode(), dto.getThirdPartyType())) {
|
|
|
|
|
// 江苏省平台
|
|
|
|
|
// result = nrService.pushStationInfo(dto);
|
|
|
|
|
result = nrService.pushStationInfoV2(dto);
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getCode(), dto.getThirdPartyType())) {
|
|
|
|
|
// 甬城泊车平台
|
|
|
|
|
// result = ycbcService.pushStationInfo(dto);
|
|
|
|
|
result = ycbcService.pushStationInfoV2(dto);
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.XIN_DIAN_TU.getCode(), dto.getThirdPartyType())) {
|
|
|
|
|
// 新电途平台
|
|
|
|
|
result = xdtService.pushStationInfoV2(dto);
|
|
|
|
|
}
|
|
|
|
|
// if(StringUtils.equals(ThirdPlatformTypeEnum.HUA_WEI.getCode(), dto.getThirdPartyType())) {
|
|
|
|
|
// // 华为
|
|
|
|
|
// result = huaWeiService.notificationOperationSystemInfo(dto);
|
|
|
|
|
// }
|
2024-01-29 16:03:36 +08:00
|
|
|
if(StringUtils.equals(ThirdPlatformTypeEnum.HAI_NAN.getCode(), dto.getThirdPartyType())) {
|
|
|
|
|
// 华为
|
2024-01-29 16:04:13 +08:00
|
|
|
result = haiNanChargeService.pushStationInfoV2(dto);
|
2024-01-29 16:03:36 +08:00
|
|
|
}
|
2024-01-19 11:43:20 +08:00
|
|
|
finalResult.append(result).append("\n");
|
|
|
|
|
}
|
|
|
|
|
return finalResult.toString();
|
|
|
|
|
}
|
2024-01-25 11:37:38 +08:00
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 统一推送第三方平台实时数据
|
|
|
|
|
* @param pileSn 桩编号
|
|
|
|
|
* @param connectorCode 枪口号
|
|
|
|
|
* @param connectorStatus 枪口状态
|
|
|
|
|
* @param realTimeMonitorData 实时数据
|
|
|
|
|
* @param transactionCode 交易流水号
|
|
|
|
|
*/
|
|
|
|
|
public void pushRealTimeInfo(String pileSn, String connectorCode, String connectorStatus,
|
|
|
|
|
RealTimeMonitorData realTimeMonitorData, String transactionCode) throws UnsupportedEncodingException {
|
|
|
|
|
// 推送第三方平台，先通过桩编号查出站点信息 pushToThirdPartyPlatforms
|
|
|
|
|
PileBasicInfo pileBasicInfo = pileBasicInfoService.selectPileBasicInfoBySN(pileSn);
|
|
|
|
|
|
|
|
|
|
// Map<String, String> pileStatusMap = pileConnectorInfoService.getPileStatus(Lists.newArrayList(pileSn));
|
|
|
|
|
// String pileStatus = pileStatusMap.get(pileSn);
|
|
|
|
|
// if (StringUtils.equals(connectorStatus, pileStatus)) {
|
|
|
|
|
// return null;
|
|
|
|
|
// }
|
|
|
|
|
// 状态不一样，传给第三方平台
|
|
|
|
|
|
|
|
|
|
// ThirdPartyStationRelation relation = new ThirdPartyStationRelation();
|
|
|
|
|
// if (StringUtils.isBlank(String.valueOf(pileBasicInfo.getStationId()))) {
|
|
|
|
|
// return;
|
|
|
|
|
// }
|
|
|
|
|
// relation.setStationId(pileBasicInfo.getStationId());
|
|
|
|
|
// 查询该站点是否推送第三方平台
|
|
|
|
|
List<ThirdPartyStationRelationVO> list = thirdPartyStationRelationService.getRelationInfoList(String.valueOf(pileBasicInfo.getStationId()));
|
|
|
|
|
// ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(relation);
|
|
|
|
|
if (CollectionUtils.isEmpty(list)) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
String pileConnectorCode = pileSn + connectorCode;
|
|
|
|
|
// 将枪口状态转换成对接平台的状态
|
|
|
|
|
String changedStatus = changeConnectorStatus(connectorStatus, realTimeMonitorData.getPutGunType());
|
|
|
|
|
for (ThirdPartyStationRelationVO vo : list) {
|
|
|
|
|
String thirdPartyType = vo.getThirdPartyType();
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.LIAN_LIAN_PLATFORM.getCode(), thirdPartyType)) {
|
|
|
|
|
// 联联
|
|
|
|
|
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
|
|
|
|
|
if (orderInfo == null) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
// log.info("推送联联平台实时数据 params: orderBasicInfo:{}", JSON.toJSONString(orderInfo));
|
|
|
|
|
// 设备状态变化推送 notification_stationStatus
|
|
|
|
|
lianLianService.pushConnectorStatus(pileConnectorCode, changedStatus);
|
|
|
|
|
if (StringUtils.equals(connectorStatus, "03")) {
|
|
|
|
|
// 充电中
|
|
|
|
|
lianLianService.pushPileChargeStatusChange(orderInfo.getOrderCode());
|
|
|
|
|
}
|
|
|
|
|
// 推送充电状态
|
|
|
|
|
lianLianService.pushChargeStatus(orderInfo.getOrderCode());
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.ZHONG_DIAN_LIAN_PLATFORM.getCode(), thirdPartyType)) {
|
|
|
|
|
// 中电联
|
|
|
|
|
// log.info("推送中电联平台实时数据 pileConnectorCode:{}, connectorStatus:{}", pileConnectorCode, connectorStatus);
|
|
|
|
|
zdlService.notificationStationStatus(pileConnectorCode, changedStatus);
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.JIANG_SU_PLATFORM.getCode(), thirdPartyType)) {
|
|
|
|
|
// 先判断缓存中是否有数据
|
|
|
|
|
String redisKey = CacheConstants.JIANGSU_PUSH_PILE_STATUS + pileConnectorCode;
|
|
|
|
|
Object cacheObject = redisCache.getCacheObject(redisKey);
|
|
|
|
|
|
|
|
|
|
// 江苏省平台(充电状态至少一分钟推送一次)
|
|
|
|
|
if (StringUtils.equals(connectorStatus, "03")) {
|
|
|
|
|
// 充电状态
|
|
|
|
|
// 如果缓存有数据，证明上次推送未超过一分钟，不予推送，若缓存中无数据，说明需要推送
|
|
|
|
|
if (cacheObject == null) {
|
|
|
|
|
// log.info("推送江苏省平台 充电状态 params:{}", realTimeMonitorData);
|
|
|
|
|
String result = nrService.pushPileStatus(realTimeMonitorData);
|
|
|
|
|
redisCache.setCacheObject(redisKey, realTimeMonitorData, 1, TimeUnit.MINUTES);
|
|
|
|
|
// log.info("推送江苏省平台 充电状态 result:{}", result);
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
// 如果不是充电状态，直接推送就可以
|
|
|
|
|
// log.info("推送江苏省平台 非充电状态 params:{}", realTimeMonitorData);
|
|
|
|
|
String result = nrService.pushPileStatus(realTimeMonitorData);
|
|
|
|
|
// log.info("推送江苏省平台 非充电状态 result:{}", result);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// log.info("推送江苏省平台实时数据 result:{}", result);
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.XIN_DIAN_TU.getCode(), thirdPartyType)) {
|
|
|
|
|
// 新电途平台
|
|
|
|
|
log.info("新电途平台设备状态变化推送 pileConnectorCode:{}, changedStatus:{}", pileConnectorCode, changedStatus);
|
|
|
|
|
String result1 = xdtService.notificationStationStatus(pileConnectorCode, changedStatus);
|
|
|
|
|
log.info("新电途平台设备状态变化推送 result:{}", result1);
|
|
|
|
|
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
|
|
|
|
|
if (orderInfo == null) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
log.info("推送新电途平台 充电状态 params:{}", orderInfo.getOrderCode());
|
|
|
|
|
String result = xdtService.notificationEquipChargeStatus(orderInfo.getOrderCode());
|
|
|
|
|
log.info("推送新电途平台 充电状态 result:{}", result);
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.HUA_WEI.getCode(), thirdPartyType)) {
|
|
|
|
|
// 华为平台
|
|
|
|
|
huaWeiService.notificationStationStatus(pileConnectorCode, changedStatus);
|
|
|
|
|
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
|
|
|
|
|
if (orderInfo == null) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
huaWeiService.notificationEquipChargeStatus(orderInfo.getOrderCode());
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.HAI_NAN.getCode(), thirdPartyType)) {
|
|
|
|
|
// 海南平台
|
|
|
|
|
haiNanChargeService.notificationStationStatus(pileConnectorCode, changedStatus);
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getCode(), thirdPartyType)) {
|
|
|
|
|
// 甬城泊车
|
|
|
|
|
// log.info("推送甬城泊车平台设备状态变化推送 pileConnectorCode:{}, changedStatus:{}", pileConnectorCode, changedStatus);
|
|
|
|
|
// 设备状态变化推送 notification_stationStatus
|
|
|
|
|
String result1 = ycbcService.notificationStationStatus(pileConnectorCode, changedStatus);
|
|
|
|
|
// log.info("推送甬城泊车平台设备状态变化推送 result:{}", result1);
|
|
|
|
|
// 推送充电状态
|
|
|
|
|
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
|
|
|
|
|
if (orderInfo == null) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(orderInfo.getStartMode(), StartModeEnum.THIRD_PARTY_PLATFORM.getValue())) {
|
|
|
|
|
// log.info("推送甬城泊车充电订单状态 param:{}", orderInfo);
|
|
|
|
|
String result2 = ycbcService.pushChargeStatus(orderInfo.getOrderCode());
|
|
|
|
|
// log.info("推送甬城泊车充电订单状态 result:{}", result2);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 统一方法推送订单信息
|
|
|
|
|
* @param orderBasicInfo 订单信息
|
|
|
|
|
*/
|
|
|
|
|
public void commonPushOrderInfo(OrderBasicInfo orderBasicInfo) {
|
|
|
|
|
// 查询该站点是否推送第三方平台
|
|
|
|
|
// ThirdPartyStationRelation relation = new ThirdPartyStationRelation();
|
|
|
|
|
// relation.setStationId(Long.parseLong(orderBasicInfo.getStationId()));
|
|
|
|
|
List<ThirdPartyStationRelationVO> relationInfoList = thirdPartyStationRelationService.getRelationInfoList(orderBasicInfo.getStationId());
|
|
|
|
|
// ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(relation);
|
|
|
|
|
if (CollectionUtils.isEmpty(relationInfoList)) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
for (ThirdPartyStationRelationVO relationVO : relationInfoList) {
|
|
|
|
|
String thirdPartyType = relationVO.getThirdPartyType();
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.LIAN_LIAN_PLATFORM.getCode(), thirdPartyType)) {
|
|
|
|
|
// 联联平台
|
|
|
|
|
// 推送停止充电结果
|
|
|
|
|
lianLianService.pushStopChargeResult(orderBasicInfo.getOrderCode());
|
|
|
|
|
// 推送订单信息
|
|
|
|
|
lianLianService.pushOrderInfo(orderBasicInfo.getOrderCode());
|
|
|
|
|
// 推送充电订单信息
|
|
|
|
|
lianLianService.pushChargeOrderInfo(orderBasicInfo.getOrderCode());
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.ZHONG_DIAN_LIAN_PLATFORM.getCode(), thirdPartyType)) {
|
|
|
|
|
// 中电联
|
|
|
|
|
zdlService.pushChargeOrderInfo(orderBasicInfo.getOrderCode());
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.JIANG_SU_PLATFORM.getCode(), thirdPartyType)) {
|
|
|
|
|
// 江苏平台
|
|
|
|
|
// 推送订单信息
|
|
|
|
|
nrService.pushOrderInfo(orderBasicInfo.getOrderCode());
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.XIN_DIAN_TU.getCode(), thirdPartyType)) {
|
|
|
|
|
// 新电途平台
|
|
|
|
|
// 推送停止充电结果
|
|
|
|
|
xdtService.notificationStopChargeResult(orderBasicInfo.getOrderCode());
|
|
|
|
|
// 推送订单信息
|
|
|
|
|
xdtService.pushChargeOrderInfo(orderBasicInfo.getOrderCode());
|
|
|
|
|
}
|
|
|
|
|
// if (StringUtils.equals(ThirdPlatformTypeEnum.HUA_WEI.getCode(), thirdPartyType)) {
|
|
|
|
|
// // 华为
|
|
|
|
|
// // 推送停止充电结果
|
|
|
|
|
// result = huaWeiService.notificationStopChargeResult(orderBasicInfo.getOrderCode());
|
|
|
|
|
// // 推送订单信息
|
|
|
|
|
// result = huaWeiService.pushChargeOrderInfo(orderBasicInfo.getOrderCode());
|
|
|
|
|
// }
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.HAI_NAN.getCode(), thirdPartyType)) {
|
|
|
|
|
// 海南平台
|
|
|
|
|
haiNanChargeService.pushChargeOrderInfo(orderBasicInfo.getOrderCode());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getCode(), thirdPartyType)) {
|
|
|
|
|
if (StringUtils.equals(orderBasicInfo.getStartMode(), StartModeEnum.THIRD_PARTY_PLATFORM.getValue())) {
|
|
|
|
|
// 甬城泊车
|
|
|
|
|
// 推送停止充电结果
|
|
|
|
|
ycbcService.pushStopChargeResult(orderBasicInfo.getOrderCode());
|
|
|
|
|
// 推送订单信息
|
|
|
|
|
// log.info("甬城泊车平台 推送充电订单信息 param:{}", orderBasicInfo.getOrderCode());
|
|
|
|
|
ycbcService.pushChargeOrderInfo(orderBasicInfo.getOrderCode());
|
|
|
|
|
// log.info("甬城泊车平台 推送充电订单信息 result:{}", result);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 统一推送启动充电结果
|
|
|
|
|
* @param orderBasicInfo
|
|
|
|
|
* @return
|
|
|
|
|
*/
|
|
|
|
|
public String commonPushStartChargeResult(OrderBasicInfo orderBasicInfo) {
|
|
|
|
|
// 通过站点id查询相关配置信息
|
|
|
|
|
ThirdPartyStationRelation relation = new ThirdPartyStationRelation();
|
|
|
|
|
relation.setStationId(Long.parseLong(orderBasicInfo.getStationId()));
|
|
|
|
|
ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(relation);
|
|
|
|
|
// ThirdPartySettingInfo settingInfo = thirdPartySettingInfoService.getInfoByStationId(Long.parseLong(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 thirdPartyType = relationInfo.getThirdPartyType();
|
|
|
|
|
|
|
|
|
|
// 推送启动充电结果(调用接口 notification_start_charge_result)
|
2024-01-25 16:00:35 +08:00
|
|
|
String url = urlAddress + BusinessInformationExchangeEnum.NOTIFICATION_START_CHARGE_RESULT.getValue();
|
2024-01-25 11:37:38 +08:00
|
|
|
|
|
|
|
|
// String orderStatus = orderInfo.getOrderStatus();
|
|
|
|
|
// // 订单状态统一
|
|
|
|
|
// if (StringUtils.equals(OrderStatusEnum.IN_THE_CHARGING.getValue(), orderStatus)) {
|
|
|
|
|
// // 充电中
|
|
|
|
|
// orderStatus = "2";
|
|
|
|
|
// } else if (StringUtils.equals(OrderStatusEnum.NOT_START.getValue(), orderStatus)) {
|
|
|
|
|
// // 未启动
|
|
|
|
|
// orderStatus = "1";
|
|
|
|
|
// } else {
|
|
|
|
|
// // 其他状态都为 未知
|
|
|
|
|
// orderStatus = "5";
|
|
|
|
|
// }
|
|
|
|
|
// 拼装参数
|
|
|
|
|
JSONObject json = new JSONObject();
|
|
|
|
|
json.put("StartChargeSeq", orderBasicInfo.getOrderCode());
|
|
|
|
|
json.put("ConnectorID", orderBasicInfo.getPileConnectorCode());
|
|
|
|
|
json.put("StartChargeSeqStat", 2); // 一定要给 2-充电中
|
|
|
|
|
json.put("StartTime", DateUtils.getDateTime());
|
|
|
|
|
|
|
|
|
|
String jsonString = JSONObject.toJSONString(json);
|
|
|
|
|
|
|
|
|
|
String token = "";
|
|
|
|
|
String result = "";
|
|
|
|
|
if (StringUtils.equals(ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getCode(), thirdPartyType)) {
|
|
|
|
|
YCBCGetTokenDTO dto = new YCBCGetTokenDTO();
|
|
|
|
|
dto.setOperatorId(operatorId);
|
|
|
|
|
dto.setDataSecret(dataSecret);
|
|
|
|
|
dto.setSignSecret(signSecret);
|
|
|
|
|
dto.setUrlAddress(urlAddress);
|
|
|
|
|
dto.setDataSecretIv(dataSecretIv);
|
|
|
|
|
dto.setOperatorSecret(operatorSecret);
|
|
|
|
|
|
|
|
|
|
token = ycbcService.YCBCGetToken(dto);
|
|
|
|
|
result = HttpRequestUtil.YCBCSendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret);
|
|
|
|
|
}else {
|
|
|
|
|
token = lianLianService.getToken(urlAddress, operatorId, operatorSecret, dataSecretIv, signSecret, dataSecret);
|
|
|
|
|
result = HttpRequestUtil.sendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret);
|
|
|
|
|
}
|
|
|
|
|
return result;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 绑定优惠券
|
|
|
|
|
*
|
|
|
|
|
* @param orderBasicInfo
|
|
|
|
|
* @return
|
|
|
|
|
* @throws UnsupportedEncodingException
|
|
|
|
|
*/
|
|
|
|
|
public String bindCoupon(OrderBasicInfo orderBasicInfo) throws UnsupportedEncodingException {
|
|
|
|
|
if (orderBasicInfo == null) {
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
// 如果该站点的停车场优惠券信息配置不为空，则需绑定一张优惠券
|
|
|
|
|
String stationId = orderBasicInfo.getStationId();
|
|
|
|
|
PileStationVO stationInfo = pileStationInfoService.getStationInfo(stationId);
|
|
|
|
|
if (StringUtils.isBlank(stationInfo.getParkingId())) {
|
|
|
|
|
return orderBasicInfo.getOrderCode() + " 该订单无需绑定优惠券";
|
|
|
|
|
}
|
|
|
|
|
if (StringUtils.equals(ParkingEnum.LU_TONG_YUN_TING_PLATFORM.getCode(), stationInfo.getParkingId())) {
|
|
|
|
|
// 路通云停
|
|
|
|
|
// 查询密钥等配置
|
|
|
|
|
ThirdpartyParkingConfig parkingInfo = thirdPartyParkingConfigService.selectByPrimaryKey(Integer.parseInt(stationInfo.getParkingId()));
|
|
|
|
|
if (parkingInfo == null) {
|
|
|
|
|
throw new BusinessException(ReturnCodeEnum.CODE_QUERY_PARKING_INFO_IS_NULL);
|
|
|
|
|
}
|
|
|
|
|
BindCouponDTO dto = BindCouponDTO.builder()
|
|
|
|
|
.appId(parkingInfo.getAppId())
|
|
|
|
|
.merchantId(parkingInfo.getParkingMerchantId())
|
|
|
|
|
.couponId(parkingInfo.getCouponId())
|
|
|
|
|
.secretKey(parkingInfo.getSecretKey())
|
|
|
|
|
.plateNumber(orderBasicInfo.getPlateNumber())
|
|
|
|
|
.plateColor(5) // 5-绿牌车
|
|
|
|
|
.build();
|
|
|
|
|
// 绑定优惠券
|
|
|
|
|
return ltytService.bindCoupon(dto);
|
|
|
|
|
} else if (StringUtils.equals(ParkingEnum.RUAN_JIE_PLATFORM.getCode(), stationInfo.getParkingId())) {
|
|
|
|
|
// 软杰
|
|
|
|
|
UseCouponDTO dto = UseCouponDTO.builder()
|
|
|
|
|
.fCouponCode(orderBasicInfo.getOrderCode()) // 优惠券编号(使用订单编号)
|
|
|
|
|
.fCouponType("2") // 优惠类型 2-时长
|
|
|
|
|
.fCouponValue("120") // 优惠券面额 单位：分钟
|
|
|
|
|
.fPlateCode(orderBasicInfo.getPlateNumber()) // 车牌号
|
|
|
|
|
.build();
|
|
|
|
|
return rjService.useCoupon(dto);
|
|
|
|
|
}
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 转换枪口状态
|
|
|
|
|
* @param connectorStatus 有电充平台枪口状态
|
|
|
|
|
* @param putGunType 是否插枪
|
|
|
|
|
* @return 第三方平台枪口状态
|
|
|
|
|
*/
|
|
|
|
|
private String changeConnectorStatus(String connectorStatus, String putGunType) {
|
|
|
|
|
if (StringUtils.equals(connectorStatus, "02")) {
|
|
|
|
|
// 空闲
|
|
|
|
|
return Constants.ONE;
|
|
|
|
|
} else if (StringUtils.equals(connectorStatus, "02") && StringUtils.equals(putGunType, "01")) {
|
|
|
|
|
// 占用（未充电）
|
|
|
|
|
return Constants.TWO;
|
|
|
|
|
} else if (StringUtils.equals(connectorStatus, "01")) {
|
|
|
|
|
// 故障
|
|
|
|
|
return "255";
|
|
|
|
|
}else {
|
|
|
|
|
// 0-离网和 3-充电中不需要转换，直接返回
|
|
|
|
|
return connectorStatus;
|
|
|
|
|
}
|
|
|
|
|
}
|
2024-01-18 17:03:08 +08:00
|
|
|
}
|
