autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-07-02 21:18:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

update qcyun停车优化

Browse Source
This commit is contained in:
jsowell
2026-06-24 14:39:02 +08:00
parent a92af3ea35
commit 0ec61089fc
9 changed files with 260 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/common/CommonService.java vendored
View File

@@ -822,7 +822,9 @@ public class CommonService {
QcyunParkCouponDTO dto = QcyunParkCouponDTO.builder()
.plateNumber(orderBasicInfo.getPlateNumber())
.stationId(orderBasicInfo.getStationId())
.stationName("深圳停车场")
.grantSerial(orderBasicInfo.getOrderCode())
.discountType(chargeParkingDiscount.getDiscountType())
.discountValue(chargeParkingDiscount.getDiscountValue())
.build();
discountFlag = qcyunsService.issuanceOfParkingTickets(dto);
}

10
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/parking/common/bean/QcyunParkCouponDTO.java vendored
View File

@@ -33,4 +33,14 @@ public class QcyunParkCouponDTO {
// 停车流水, 标识具体某次停车事件, 需保证该停车场下唯一
private String parkingSerial;
/**
* 优惠类型(1-减时间单位分钟; 2-减金额单位元)
*/
private Integer discountType;
/**
* 优惠值
*/
private String discountValue;
}

3
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/parking/service/QcyunsService.java vendored
View File

@@ -9,8 +9,7 @@ public interface QcyunsService {
/**
* 发放停车券
* dto中只需要传入车牌号, 其他参数取配置文件中的参数
* 现在只有一家车场, parkId在配置文件中, 以后多家车场改为数据库配置
* dto中需要传入车牌号、站点id和优惠配置，停车场鉴权参数根据站点绑定配置查询
* @return true: 发放成功, false: 失败
*/
boolean issuanceOfParkingTickets(QcyunParkCouponDTO dto);

159
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/parking/service/impl/QcyunsServiceImpl.java vendored
View File

@@ -6,18 +6,24 @@ import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.google.common.collect.Maps;
import com.jsowell.common.core.domain.parking.ParkingCommonParam;
import com.jsowell.common.enums.parkplatform.ParkingPlatformEnum;
import com.jsowell.common.util.ParkingUtil;
import com.jsowell.common.util.StringUtils;
import com.jsowell.common.util.id.UUID;
import com.jsowell.pile.domain.ThirdpartyParkingConfig;
import com.jsowell.pile.service.ThirdPartyParkingConfigService;
import com.jsowell.thirdparty.parking.common.ServiceApiCmd;
import com.jsowell.thirdparty.parking.common.bean.QcyunParkCouponDTO;
import com.jsowell.thirdparty.parking.common.bean.TempCarInfo;
import com.jsowell.thirdparty.parking.common.response.DataResponse;
import com.jsowell.thirdparty.parking.service.QcyunsService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.Map;
/**
@@ -27,28 +33,36 @@ import java.util.Map;
@Service
public class QcyunsServiceImpl implements QcyunsService {
@Value("${parking.qcyuns.url}")
private String URL;
private static final String QCYUN_DISCOUNT_TYPE_AMOUNT = "1";
@Value("${parking.qcyuns.secretKey}")
private String secretKey;
private static final String QCYUN_DISCOUNT_TYPE_TIME = "2";
@Value("${parking.qcyuns.parkId}")
private String parkId;
private static final Integer DISCOUNT_TYPE_TIME = 1;
@Value("${parking.qcyuns.orgId}")
private String orgId;
private static final Integer DISCOUNT_TYPE_AMOUNT = 2;
@Value("${parking.qcyuns.url:}")
private String defaultUrl;
@Autowired
private ThirdPartyParkingConfigService thirdPartyParkingConfigService;
/**
* 发放停车券
* dto中只需要传入车牌号, 其他参数取配置文件中的参数
* 现在只有一家车场, parkId在配置文件中, 以后多家车场改为数据库配置
* 根据站点绑定的停车场配置动态获取parkId/orgId/secretKey
*/
@Override
public boolean issuanceOfParkingTickets(QcyunParkCouponDTO dto) {
dto.setParkId(parkId);
ThirdpartyParkingConfig parkingConfig = resolveParkingConfig(dto);
if (parkingConfig == null) {
return false;
}
dto.setParkId(parkingConfig.getParkId());
if (StringUtils.isBlank(dto.getGrantSerial())) {
dto.setGrantSerial(UUID.randomUUID().toString());
}
// 1. 查询车辆信息
String carInfo = getCarInfo(dto);
String carInfo = getCarInfo(dto, parkingConfig);
if (StringUtils.isBlank(carInfo)) {
return false;
}
@@ -60,18 +74,48 @@ public class QcyunsServiceImpl implements QcyunsService {
}
dto.setParkingSerial(String.valueOf(tempCarInfo.getRecordId()));
// 2. 创建停车券
boolean discountCoupon = createDiscountCoupon(dto);
boolean discountCoupon = createDiscountCoupon(dto, parkingConfig);
// 3. 查询优惠抵扣金额
// queryCarInfoDiscountDestory(dto);
return discountCoupon;
}
private ThirdpartyParkingConfig resolveParkingConfig(QcyunParkCouponDTO dto) {
if (dto == null || StringUtils.isBlank(dto.getStationId())) {
log.warn("qcyun发券失败, stationId为空, dto:{}", JSON.toJSONString(dto));
return null;
}
ThirdpartyParkingConfig parkingConfig = thirdPartyParkingConfigService.selectByStationId(dto.getStationId());
if (parkingConfig == null) {
log.warn("qcyun发券失败, 站点未绑定停车场配置, stationId:{}", dto.getStationId());
return null;
}
if (!StringUtils.equals(ParkingPlatformEnum.SHEN_ZHEN_PLATFORM.getCode(), parkingConfig.getPlatformType())) {
log.warn("qcyun发券失败, 站点绑定的停车平台类型不是qcyun, stationId:{}, parkingConfigId:{}, platformType:{}",
dto.getStationId(), parkingConfig.getId(), parkingConfig.getPlatformType());
return null;
}
if (StringUtils.isBlank(parkingConfig.getParkId())
|| StringUtils.isBlank(parkingConfig.getOrgId())
|| StringUtils.isBlank(parkingConfig.getSecretKey())) {
log.warn("qcyun发券失败, 停车场配置缺少parkId/orgId/secretKey, stationId:{}, parkingConfigId:{}",
dto.getStationId(), parkingConfig.getId());
return null;
}
if (StringUtils.isBlank(getRequestUrl(parkingConfig))) {
log.warn("qcyun发券失败, 停车场配置缺少接口地址, stationId:{}, parkingConfigId:{}",
dto.getStationId(), parkingConfig.getId());
return null;
}
return parkingConfig;
}
/**
* 获取车辆信息接口
* 根据车牌号获取车辆信息（临时车，月租车，储值车）
*/
private String getCarInfo(QcyunParkCouponDTO dto) {
String parkId = dto.getParkId(); // 使用dto中传入的parkId(写在配置文件中), 也许以后有多家车场改为数据库配置
private String getCarInfo(QcyunParkCouponDTO dto, ThirdpartyParkingConfig parkingConfig) {
String parkId = dto.getParkId();
// 业务参数
Map<String, String> data = Maps.newHashMap();
data.put("parkId", parkId);
@@ -81,13 +125,16 @@ public class QcyunsServiceImpl implements QcyunsService {
param.setService(ServiceApiCmd.CarInfo);
param.setVersion("01");
param.setMsgId(UUID.randomUUID().toString());
// param.setOrgId(dto.getOrgId());
param.setOrgId(orgId);
param.setOrgId(parkingConfig.getOrgId());
param.setData(data);
// 生成sign
ParkingUtil.generateAndSetSign(param, secretKey);
ParkingUtil.generateAndSetSign(param, parkingConfig.getSecretKey());
// 发送请求
String result = HttpUtil.post(URL, JSON.toJSONString(param));
String result = HttpUtil.post(getRequestUrl(parkingConfig), JSON.toJSONString(param));
if (StringUtils.isBlank(result)) {
log.warn("获取车辆信息接口返回为空, param:{}", JSON.toJSONString(param));
return null;
}
DataResponse dataResponse = JSONUtil.toBean(result, DataResponse.class);
log.info("获取车辆信息接口成功, param:{}, response:{}", JSON.toJSONString(param), JSON.toJSONString(dataResponse));
if (dataResponse.getRetCode() == 0) {
@@ -99,28 +146,39 @@ public class QcyunsServiceImpl implements QcyunsService {
/**
* 商家减免
*/
private boolean createDiscountCoupon(QcyunParkCouponDTO dto) {
private boolean createDiscountCoupon(QcyunParkCouponDTO dto, ThirdpartyParkingConfig parkingConfig) {
String qcyunDiscountType = getQcyunDiscountType(dto);
String qcyunDiscountValue = getQcyunDiscountValue(dto);
if (StringUtils.isBlank(qcyunDiscountType) || StringUtils.isBlank(qcyunDiscountValue)) {
log.warn("qcyun创建优惠券失败, 优惠配置错误, stationId:{}, discountType:{}, discountValue:{}",
dto.getStationId(), dto.getDiscountType(), dto.getDiscountValue());
return false;
}
// 业务参数
Map<String, String> data = Maps.newHashMap();
data.put("parkingSerial", dto.getParkingSerial());
data.put("grantSerial", dto.getGrantSerial()); // 对接方唯一id
data.put("plate", dto.getPlateNumber()); // 车牌号
data.put("storeName", dto.getStationName()); // 商家名称
data.put("type", "1"); // 优惠类型: 1.金额, 2.时长, 3.全免
data.put("value", String.valueOf(10 * 100)); // 当type=1时单位为分;当type=2时单位为分钟
data.put("storeName", StringUtils.defaultIfBlank(dto.getStationName(),
StringUtils.defaultIfBlank(parkingConfig.getParkingName(), "充电停车优惠"))); // 商家名称
data.put("type", qcyunDiscountType); // 优惠类型: 1.金额, 2.时长, 3.全免
data.put("value", qcyunDiscountValue); // 当type=1时单位为分;当type=2时单位为分钟
data.put("parkId", dto.getParkId()); // 车场id
// 组装请求体
ParkingCommonParam param = new ParkingCommonParam();
param.setService(ServiceApiCmd.DiscountCreate);
param.setVersion("01");
param.setMsgId(UUID.randomUUID().toString());
// param.setOrgId(dto.getOrgId());
param.setOrgId(orgId);
param.setOrgId(parkingConfig.getOrgId());
param.setData(data);
// 生成sign
ParkingUtil.generateAndSetSign(param, secretKey);
ParkingUtil.generateAndSetSign(param, parkingConfig.getSecretKey());
// 发送请求
String result = HttpUtil.post(URL, JSON.toJSONString(param));
String result = HttpUtil.post(getRequestUrl(parkingConfig), JSON.toJSONString(param));
if (StringUtils.isBlank(result)) {
log.warn("创建优惠券返回为空, param:{}", JSON.toJSONString(param));
return false;
}
DataResponse dataResponse = JSONUtil.toBean(result, DataResponse.class);
log.info("创建优惠券成功, param:{}, response:{}", JSON.toJSONString(param), JSON.toJSONString(dataResponse));
@@ -130,30 +188,65 @@ public class QcyunsServiceImpl implements QcyunsService {
return false;
}
private String getQcyunDiscountType(QcyunParkCouponDTO dto) {
if (DISCOUNT_TYPE_AMOUNT.equals(dto.getDiscountType())) {
return QCYUN_DISCOUNT_TYPE_AMOUNT;
}
if (DISCOUNT_TYPE_TIME.equals(dto.getDiscountType())) {
return QCYUN_DISCOUNT_TYPE_TIME;
}
return null;
}
private String getQcyunDiscountValue(QcyunParkCouponDTO dto) {
if (StringUtils.isBlank(dto.getDiscountValue())) {
return null;
}
try {
BigDecimal discountValue = new BigDecimal(dto.getDiscountValue());
if (discountValue.compareTo(BigDecimal.ZERO) <= 0) {
return null;
}
if (DISCOUNT_TYPE_AMOUNT.equals(dto.getDiscountType())) {
return discountValue.multiply(new BigDecimal("100")).setScale(0, RoundingMode.HALF_UP).toPlainString();
}
if (DISCOUNT_TYPE_TIME.equals(dto.getDiscountType())) {
return discountValue.setScale(0, RoundingMode.HALF_UP).toPlainString();
}
} catch (NumberFormatException e) {
log.warn("qcyun优惠值转换失败, discountValue:{}", dto.getDiscountValue(), e);
}
return null;
}
private String getRequestUrl(ThirdpartyParkingConfig parkingConfig) {
return StringUtils.defaultIfBlank(parkingConfig.getApiUrl(), defaultUrl);
}
/**
* 查询优惠抵扣金额
*/
private void queryCarInfoDiscountDestory(QcyunParkCouponDTO dto) {
private void queryCarInfoDiscountDestory(QcyunParkCouponDTO dto, ThirdpartyParkingConfig parkingConfig) {
// 业务参数
Map<String, String> data = Maps.newHashMap();
data.put("parkingSerial", dto.getParkingSerial());
data.put("grantSerial", dto.getGrantSerial()); // 对接方唯一id
data.put("plate", dto.getPlateNumber()); // 车牌号
data.put("storeName", dto.getStationName()); // 商家名称
data.put("type", "1"); // 优惠类型: 1.金额, 2.时长, 3.全免
data.put("value", String.valueOf(10 * 100)); // 当type=1时单位为分;当type=2时单位为分钟
data.put("type", getQcyunDiscountType(dto)); // 优惠类型: 1.金额, 2.时长, 3.全免
data.put("value", getQcyunDiscountValue(dto)); // 当type=1时单位为分;当type=2时单位为分钟
data.put("parkId", dto.getParkId()); //
// 组装请求体
ParkingCommonParam param = new ParkingCommonParam();
param.setService(ServiceApiCmd.CarInfoDiscountDestory);
param.setVersion("01");
param.setMsgId(UUID.randomUUID().toString());
param.setOrgId(orgId);
param.setOrgId(parkingConfig.getOrgId());
param.setData(data);
// 生成sign
ParkingUtil.generateAndSetSign(param, secretKey);
ParkingUtil.generateAndSetSign(param, parkingConfig.getSecretKey());
// 发送请求
String result = HttpUtil.post(URL, JSON.toJSONString(param));
String result = HttpUtil.post(getRequestUrl(parkingConfig), JSON.toJSONString(param));
DataResponse dataResponse = JSONUtil.toBean(result, DataResponse.class);
log.info("查询优惠抵扣金额, param:{}, response:{}", JSON.toJSONString(param), JSON.toJSONString(dataResponse));
}