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

Merge branch 'dev-zza' into dev

Browse Source
This commit is contained in:
Lemon
2025-02-26 08:46:26 +08:00
parent c725f35778 9dbc12e129
commit 66add2fa3d
33 changed files with 2280 additions and 2423 deletions
Download Patch File Download Diff File Expand all files Collapse all files

596
jsowell-admin/src/main/java/com/jsowell/api/thirdparty/HuaWeiController.java vendored
View File

@@ -1,31 +1,31 @@
package com.jsowell.api.thirdparty;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
//
// import com.alibaba.fastjson2.JSON;
// import com.alibaba.fastjson2.JSONObject;
import com.jsowell.common.annotation.Anonymous;
import com.jsowell.common.core.controller.BaseController;
// import com.jsowell.common.core.controller.BaseController;
import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
import com.jsowell.common.util.JWTUtils;
import com.jsowell.pile.dto.QueryEquipChargeStatusDTO;
import com.jsowell.pile.dto.QueryEquipmentDTO;
import com.jsowell.pile.dto.QueryStartChargeDTO;
import com.jsowell.pile.dto.QueryStationInfoDTO;
import com.jsowell.thirdparty.huawei.HuaWeiService;
import com.jsowell.thirdparty.lianlian.common.CommonResult;
import com.jsowell.pile.thirdparty.CommonParamsDTO;
import com.jsowell.thirdparty.platform.util.Cryptos;
import com.jsowell.thirdparty.platform.util.Encodes;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
// import com.jsowell.common.util.JWTUtils;
// import com.jsowell.pile.dto.QueryEquipChargeStatusDTO;
// import com.jsowell.pile.dto.QueryEquipmentDTO;
// import com.jsowell.pile.dto.QueryStartChargeDTO;
// import com.jsowell.pile.dto.QueryStationInfoDTO;
// import com.jsowell.thirdparty.huawei.HuaWeiService;
// import com.jsowell.thirdparty.lianlian.common.CommonResult;
// import com.jsowell.pile.thirdparty.CommonParamsDTO;
// import com.jsowell.thirdparty.platform.util.Cryptos;
// import com.jsowell.thirdparty.platform.util.Encodes;
// import org.springframework.beans.factory.annotation.Autowired;
// import org.springframework.web.bind.annotation.PostMapping;
// import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
import java.io.UnsupportedEncodingException;
import java.nio.charset.StandardCharsets;
import java.util.Map;
//
// import javax.servlet.http.HttpServletRequest;
// import java.io.UnsupportedEncodingException;
// import java.nio.charset.StandardCharsets;
// import java.util.Map;
//
/**
* 华为 Controller
*
@@ -37,279 +37,279 @@ import java.util.Map;
@RequestMapping("/huawei")
@Deprecated
public class HuaWeiController extends ThirdPartyBaseController {
private final String platformName = "华为平台";
private final String platformType = ThirdPlatformTypeEnum.HUA_WEI.getTypeCode();
@Autowired
private HuaWeiService huaWeiService;
/**
* 获取token接口
* http://localhost:8080/huawei/v1/query_token
*/
@PostMapping("/v1/query_token")
public CommonResult<?> queryToken(@RequestBody CommonParamsDTO dto) {
logger.info("华为平台请求令牌 params:{}", JSON.toJSONString(dto));
try {
Map<String, String> map = huaWeiService.generateToken(dto);
logger.info("华为平台请求令牌 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求令牌成功！", map.get("Data"), map.get("Sig"));
} catch (UnsupportedEncodingException e) {
logger.error("获取token接口 异常");
return CommonResult.failed("获取token发生异常");
}
}
/**
* 查询充电站信息
* @param dto
*/
@RequestMapping("/v1/query_stations_info")
public CommonResult<?> query_stations_info(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("华为平台查询充电站信息 params:{}", JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
// 校验失败
return CommonResult.failed("令牌校验错误");
}
// 校验签名
Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
if (resultMap == null) {
// 签名错误
return CommonResult.failed("签名校验错误");
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStationInfoDTO queryStationInfoDTO = JSONObject.parseObject(dataStr, QueryStationInfoDTO.class);
queryStationInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaWeiService.queryStationsInfo(queryStationInfoDTO);
return CommonResult.success(0, "查询充电站信息成功！", map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("华为平台查询充电站信息 error", e);
}
return CommonResult.failed("查询充电站信息异常");
}
/**
* 华为平台查询统计信息
* http://localhost:8080/huawei/v1/query_stations_stats
* @param dto
* @return
*/
@PostMapping("/v1/query_station_status")
public CommonResult<?> queryStationStatus(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("华为平台查询统计信息 params:{}", JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
// 校验失败
return CommonResult.failed("令牌校验错误");
}
// 校验签名
Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
if (resultMap == null) {
// 签名错误
return CommonResult.failed("签名校验错误");
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStationInfoDTO queryStationInfoDTO = JSONObject.parseObject(dataStr, QueryStationInfoDTO.class);
queryStationInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaWeiService.queryStationStatus(queryStationInfoDTO);
logger.info("华为平台查询统计信息 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "查询统计信息成功！", map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("华为平台查询统计信息 error:", e);
e.printStackTrace();
}
return CommonResult.failed("查询统计信息发生异常");
}
/**
* 请求设备认证
* @param request
* @param dto
* @return
*/
@PostMapping("/v1/query_equip_auth")
public CommonResult<?> query_equip_auth(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("华为平台请求设备认证 param:{}", JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
// 校验失败
return CommonResult.failed("令牌校验错误");
}
// 校验签名
Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
if (resultMap == null) {
// 签名错误
return CommonResult.failed("签名校验错误");
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryEquipmentDTO queryEquipmentDTO = JSONObject.parseObject(dataStr, QueryEquipmentDTO.class);
queryEquipmentDTO.setOperatorID(dto.getOperatorID());
Map<String, String> map = huaWeiService.queryEquipAuth(queryEquipmentDTO);
logger.info("华为平台请求设备认证 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求设备认证成功！", map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("华为平台请求设备认证 error:", e);
e.printStackTrace();
}
return CommonResult.failed("请求设备认证发生异常");
}
/**
* 华为平台请求计费策略
* http://localhost:8080/huawei/v1/query_equip_business_policy
* @param dto
* @return
*/
@PostMapping("/v1/request_equip_business_policy")
public CommonResult<?> requestEquipBusinessPolicy(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("华为平台请求计费策略 params:{}", JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
// 校验失败
return CommonResult.failed("令牌校验错误");
}
// 校验签名
Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
if (resultMap == null) {
// 签名错误
return CommonResult.failed("签名校验错误");
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
queryStartChargeDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaWeiService.requestEquipBusinessPolicy(queryStartChargeDTO);
logger.info("华为平台请求计费策略 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求计费策略成功！", map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("华为平台请求计费策略 error:", e);
e.printStackTrace();
}
return CommonResult.failed("请求计费策略发生异常");
}
/**
* 查询充电状态
* http://localhost:8080/huawei/query_equip_charge_status/{startChargeSeq}
* @param dto
* @return
*/
@PostMapping("/v1/query_equip_charge_status")
public CommonResult<?> query_equip_charge_status(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("华为平台查询充电状态 params :{}", JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
// 校验失败
return CommonResult.failed("令牌校验错误");
}
// 校验签名
Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
if (resultMap == null) {
// 签名错误
return CommonResult.failed("签名校验错误");
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryEquipChargeStatusDTO queryEquipChargeStatusDTO = JSONObject.parseObject(dataStr, QueryEquipChargeStatusDTO.class);
queryEquipChargeStatusDTO.setOperatorID(dto.getOperatorID());
Map<String, String> map = huaWeiService.queryEquipChargeStatus(queryEquipChargeStatusDTO);
logger.info("华为平台查询充电状态 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "查询充电状态成功！", map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("华为平台查询充电状态 error", e);
}
return CommonResult.failed("华为平台查询充电状态发生异常");
}
/**
* 请求停止充电
* @param request
* @param dto
* @return
*/
@PostMapping("/v1/query_stop_charge")
public CommonResult<?> query_stop_charge(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("华为平台请求停止充电 params :{}", JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
// 校验失败
return CommonResult.failed("令牌校验错误");
}
// 校验签名
Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
if (resultMap == null) {
// 签名错误
return CommonResult.failed("签名校验错误");
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
queryStartChargeDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaWeiService.queryStopCharge(queryStartChargeDTO);
logger.info("华为平台请求停止充电 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求停止充电成功！", map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("华为平台请求停止充电 error", e);
}
return CommonResult.failed("华为平台请求停止充电发生异常");
}
//
// private final String platformName = "华为平台";
//
// private final String platformType = ThirdPlatformTypeEnum.HUA_WEI.getTypeCode();
//
// @Autowired
// private HuaWeiService huaWeiService;
//
// /**
// * 获取token接口
// * http://localhost:8080/huawei/v1/query_token
// */
// @PostMapping("/v1/query_token")
// public CommonResult<?> queryToken(@RequestBody CommonParamsDTO dto) {
// logger.info("华为平台请求令牌 params:{}", JSON.toJSONString(dto));
// try {
// Map<String, String> map = huaWeiService.generateToken(dto);
// logger.info("华为平台请求令牌 result:{}", JSON.toJSONString(map));
// return CommonResult.success(0, "请求令牌成功！", map.get("Data"), map.get("Sig"));
// } catch (UnsupportedEncodingException e) {
// logger.error("获取token接口 异常");
// return CommonResult.failed("获取token发生异常");
// }
// }
//
//
// /**
// * 查询充电站信息
// * @param dto
// */
// @RequestMapping("/v1/query_stations_info")
// public CommonResult<?> query_stations_info(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("华为平台查询充电站信息 params:{}", JSON.toJSONString(dto));
// try {
// // 校验令牌
// String token = request.getHeader("Authorization");
// if (!JWTUtils.checkThirdPartyToken(token)) {
// // 校验失败
// return CommonResult.failed("令牌校验错误");
// }
// // 校验签名
// Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
// if (resultMap == null) {
// // 签名错误
// return CommonResult.failed("签名校验错误");
// }
// String operatorSecret = resultMap.get("OperatorSecret");
// String dataString = resultMap.get("Data");
// String dataSecret = resultMap.get("DataSecret");
// String dataSecretIV = resultMap.get("DataSecretIV");
// // 解密data
// byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
// String dataStr = new String(plainText, StandardCharsets.UTF_8);
// // 转换成相应对象
// QueryStationInfoDTO queryStationInfoDTO = JSONObject.parseObject(dataStr, QueryStationInfoDTO.class);
// queryStationInfoDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaWeiService.queryStationsInfo(queryStationInfoDTO);
// return CommonResult.success(0, "查询充电站信息成功！", map.get("Data"), map.get("Sig"));
// } catch (Exception e) {
// logger.error("华为平台查询充电站信息 error", e);
// }
// return CommonResult.failed("查询充电站信息异常");
// }
//
// /**
// * 华为平台查询统计信息
// * http://localhost:8080/huawei/v1/query_stations_stats
// * @param dto
// * @return
// */
// @PostMapping("/v1/query_station_status")
// public CommonResult<?> queryStationStatus(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("华为平台查询统计信息 params:{}", JSON.toJSONString(dto));
// try {
// // 校验令牌
// String token = request.getHeader("Authorization");
// if (!JWTUtils.checkThirdPartyToken(token)) {
// // 校验失败
// return CommonResult.failed("令牌校验错误");
// }
// // 校验签名
// Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
// if (resultMap == null) {
// // 签名错误
// return CommonResult.failed("签名校验错误");
// }
// String operatorSecret = resultMap.get("OperatorSecret");
// String dataString = resultMap.get("Data");
// String dataSecret = resultMap.get("DataSecret");
// String dataSecretIV = resultMap.get("DataSecretIV");
//
// // 解密data
// byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
// String dataStr = new String(plainText, StandardCharsets.UTF_8);
// // 转换成相应对象
// QueryStationInfoDTO queryStationInfoDTO = JSONObject.parseObject(dataStr, QueryStationInfoDTO.class);
// queryStationInfoDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaWeiService.queryStationStatus(queryStationInfoDTO);
// logger.info("华为平台查询统计信息 result:{}", JSON.toJSONString(map));
// return CommonResult.success(0, "查询统计信息成功！", map.get("Data"), map.get("Sig"));
// } catch (Exception e) {
// logger.info("华为平台查询统计信息 error:", e);
// e.printStackTrace();
// }
// return CommonResult.failed("查询统计信息发生异常");
// }
//
//
// /**
// * 请求设备认证
// * @param request
// * @param dto
// * @return
// */
// @PostMapping("/v1/query_equip_auth")
// public CommonResult<?> query_equip_auth(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("华为平台请求设备认证 param:{}", JSON.toJSONString(dto));
// try {
// // 校验令牌
// String token = request.getHeader("Authorization");
// if (!JWTUtils.checkThirdPartyToken(token)) {
// // 校验失败
// return CommonResult.failed("令牌校验错误");
// }
// // 校验签名
// Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
// if (resultMap == null) {
// // 签名错误
// return CommonResult.failed("签名校验错误");
// }
// String operatorSecret = resultMap.get("OperatorSecret");
// String dataString = resultMap.get("Data");
// String dataSecret = resultMap.get("DataSecret");
// String dataSecretIV = resultMap.get("DataSecretIV");
// // 解密data
// byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
// String dataStr = new String(plainText, StandardCharsets.UTF_8);
// // 转换成相应对象
// QueryEquipmentDTO queryEquipmentDTO = JSONObject.parseObject(dataStr, QueryEquipmentDTO.class);
// queryEquipmentDTO.setOperatorID(dto.getOperatorID());
// Map<String, String> map = huaWeiService.queryEquipAuth(queryEquipmentDTO);
// logger.info("华为平台请求设备认证 result:{}", JSON.toJSONString(map));
// return CommonResult.success(0, "请求设备认证成功！", map.get("Data"), map.get("Sig"));
// } catch (Exception e) {
// logger.info("华为平台请求设备认证 error:", e);
// e.printStackTrace();
// }
// return CommonResult.failed("请求设备认证发生异常");
// }
//
// /**
// * 华为平台请求计费策略
// * http://localhost:8080/huawei/v1/query_equip_business_policy
// * @param dto
// * @return
// */
// @PostMapping("/v1/request_equip_business_policy")
// public CommonResult<?> requestEquipBusinessPolicy(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("华为平台请求计费策略 params:{}", JSON.toJSONString(dto));
// try {
// // 校验令牌
// String token = request.getHeader("Authorization");
// if (!JWTUtils.checkThirdPartyToken(token)) {
// // 校验失败
// return CommonResult.failed("令牌校验错误");
// }
// // 校验签名
// Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
// if (resultMap == null) {
// // 签名错误
// return CommonResult.failed("签名校验错误");
// }
// String operatorSecret = resultMap.get("OperatorSecret");
// String dataString = resultMap.get("Data");
// String dataSecret = resultMap.get("DataSecret");
// String dataSecretIV = resultMap.get("DataSecretIV");
//
// // 解密data
// byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
// String dataStr = new String(plainText, StandardCharsets.UTF_8);
// // 转换成相应对象
// QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
// queryStartChargeDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaWeiService.requestEquipBusinessPolicy(queryStartChargeDTO);
// logger.info("华为平台请求计费策略 result:{}", JSON.toJSONString(map));
//
// return CommonResult.success(0, "请求计费策略成功！", map.get("Data"), map.get("Sig"));
// } catch (Exception e) {
// logger.info("华为平台请求计费策略 error:", e);
// e.printStackTrace();
// }
// return CommonResult.failed("请求计费策略发生异常");
// }
//
// /**
// * 查询充电状态
// * http://localhost:8080/huawei/query_equip_charge_status/{startChargeSeq}
// * @param dto
// * @return
// */
// @PostMapping("/v1/query_equip_charge_status")
// public CommonResult<?> query_equip_charge_status(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("华为平台查询充电状态 params :{}", JSON.toJSONString(dto));
// try {
// // 校验令牌
// String token = request.getHeader("Authorization");
// if (!JWTUtils.checkThirdPartyToken(token)) {
// // 校验失败
// return CommonResult.failed("令牌校验错误");
// }
// // 校验签名
// Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
// if (resultMap == null) {
// // 签名错误
// return CommonResult.failed("签名校验错误");
// }
// String operatorSecret = resultMap.get("OperatorSecret");
// String dataString = resultMap.get("Data");
// String dataSecret = resultMap.get("DataSecret");
// String dataSecretIV = resultMap.get("DataSecretIV");
// // 解密data
// byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
// String dataStr = new String(plainText, StandardCharsets.UTF_8);
// // 转换成相应对象
// QueryEquipChargeStatusDTO queryEquipChargeStatusDTO = JSONObject.parseObject(dataStr, QueryEquipChargeStatusDTO.class);
// queryEquipChargeStatusDTO.setOperatorID(dto.getOperatorID());
// Map<String, String> map = huaWeiService.queryEquipChargeStatus(queryEquipChargeStatusDTO);
// logger.info("华为平台查询充电状态 result:{}", JSON.toJSONString(map));
// return CommonResult.success(0, "查询充电状态成功！", map.get("Data"), map.get("Sig"));
// } catch (Exception e) {
// logger.error("华为平台查询充电状态 error", e);
// }
// return CommonResult.failed("华为平台查询充电状态发生异常");
// }
//
// /**
// * 请求停止充电
// * @param request
// * @param dto
// * @return
// */
// @PostMapping("/v1/query_stop_charge")
// public CommonResult<?> query_stop_charge(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("华为平台请求停止充电 params :{}", JSON.toJSONString(dto));
// try {
// // 校验令牌
// String token = request.getHeader("Authorization");
// if (!JWTUtils.checkThirdPartyToken(token)) {
// // 校验失败
// return CommonResult.failed("令牌校验错误");
// }
// // 校验签名
// Map<String, String> resultMap = huaWeiService.checkoutSign(dto);
// if (resultMap == null) {
// // 签名错误
// return CommonResult.failed("签名校验错误");
// }
// String operatorSecret = resultMap.get("OperatorSecret");
// String dataString = resultMap.get("Data");
// String dataSecret = resultMap.get("DataSecret");
// String dataSecretIV = resultMap.get("DataSecretIV");
// // 解密data
// byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
// String dataStr = new String(plainText, StandardCharsets.UTF_8);
// // 转换成相应对象
// QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
// queryStartChargeDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaWeiService.queryStopCharge(queryStartChargeDTO);
// logger.info("华为平台请求停止充电 result:{}", JSON.toJSONString(map));
// return CommonResult.success(0, "请求停止充电成功！", map.get("Data"), map.get("Sig"));
// } catch (Exception e) {
// logger.error("华为平台请求停止充电 error", e);
// }
// return CommonResult.failed("华为平台请求停止充电发生异常");
// }
}

768
jsowell-admin/src/main/java/com/jsowell/api/thirdparty/HuaWeiControllerV2.java vendored
View File

@@ -1,33 +1,33 @@
package com.jsowell.api.thirdparty;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
//
// import com.alibaba.fastjson2.JSON;
// import com.alibaba.fastjson2.JSONObject;
import com.jsowell.common.annotation.Anonymous;
import com.jsowell.common.core.controller.BaseController;
import com.jsowell.common.response.RestApiResponse;
import com.jsowell.common.util.JWTUtils;
import com.jsowell.pile.dto.ThirdPartyCommonStartChargeDTO;
import com.jsowell.pile.dto.huawei.*;
import com.jsowell.pile.vo.huawei.QueryChargeStatusVO;
import com.jsowell.pile.vo.huawei.QueryEquipAuthVO;
import com.jsowell.pile.vo.huawei.QueryStartChargeVO;
import com.jsowell.thirdparty.common.CommonService;
import com.jsowell.thirdparty.huawei.HuaweiServiceV2;
import com.jsowell.thirdparty.lianlian.common.CommonResult;
import com.jsowell.thirdparty.lianlian.domain.ConnectorStatusInfo;
import com.jsowell.pile.thirdparty.CommonParamsDTO;
import com.jsowell.thirdparty.platform.util.Cryptos;
import com.jsowell.thirdparty.platform.util.Encodes;
import org.springframework.beans.factory.annotation.Autowired;
// import com.jsowell.common.response.RestApiResponse;
// import com.jsowell.common.util.JWTUtils;
// import com.jsowell.pile.dto.ThirdPartyCommonStartChargeDTO;
// import com.jsowell.pile.dto.huawei.*;
// import com.jsowell.pile.vo.huawei.QueryChargeStatusVO;
// import com.jsowell.pile.vo.huawei.QueryEquipAuthVO;
// import com.jsowell.pile.vo.huawei.QueryStartChargeVO;
// import com.jsowell.thirdparty.common.CommonService;
// import com.jsowell.thirdparty.huawei.HuaweiServiceV2;
// import com.jsowell.thirdparty.lianlian.common.CommonResult;
// import com.jsowell.thirdparty.lianlian.domain.ConnectorStatusInfo;
// import com.jsowell.pile.thirdparty.CommonParamsDTO;
// import com.jsowell.thirdparty.platform.util.Cryptos;
// import com.jsowell.thirdparty.platform.util.Encodes;
// import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import java.io.UnsupportedEncodingException;
import java.nio.charset.StandardCharsets;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
//
// import javax.servlet.http.HttpServletRequest;
// import java.io.UnsupportedEncodingException;
// import java.nio.charset.StandardCharsets;
// import java.util.LinkedHashMap;
// import java.util.List;
// import java.util.Map;
//
/**
* 华为 Controller V2
*
@@ -39,362 +39,362 @@ import java.util.Map;
@RequestMapping("/huawei")
@Deprecated
public class HuaWeiControllerV2 extends BaseController {
@Autowired
private HuaweiServiceV2 huaweiServiceV2;
@Autowired
private CommonService commonService;
/**
* 获取token接口
* http://localhost:8080/huawei/v1/query_token
*/
@PostMapping("/v2/query_token")
public CommonResult<?> queryToken(@RequestBody CommonParamsDTO dto) {
logger.info("华为平台请求令牌 params:{}", JSON.toJSONString(dto));
try {
Map<String, String> map = huaweiServiceV2.generateToken(dto);
logger.info("华为平台请求令牌 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求令牌成功！", map.get("Data"), map.get("Sig"));
} catch (UnsupportedEncodingException e) {
logger.error("获取token接口 异常");
return CommonResult.failed("获取token发生异常");
}
}
/**
* 华为设备接口状态变化推送
* @param dto
* @return
*/
@PostMapping("/v2/notification_stationStatus")
public CommonResult<?> receiveNotificationStationStatus(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("华为设备接口状态变化推送 params:{}", JSON.toJSONString(dto));
String dataStr = checkAuth(request, dto);
// 转换成相应对象
ConnectorStatusInfo connectorStatusInfo = JSONObject.parseObject(dataStr, ConnectorStatusInfo.class);
connectorStatusInfo.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaweiServiceV2.receiveNotificationStationStatus(connectorStatusInfo);
logger.info("华为设备接口状态变化推送 result:{}", map);
return CommonResult.success(0, "设备接口状态变化推送成功！", map.get("Data"), map.get("Sig"));
}
/**
* 请求设备计费信息
* @param request
* @param dto
* @return
*/
@PostMapping("/v2/request_equip_business_policy")
public CommonResult<?> requestEquipBusinessPolicy(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("华为请求设备计费信息 params:{}", JSON.toJSONString(dto));
String dataStr = checkAuth(request, dto);
// 转换成相应对象
RequestEquipBusinessPolicyDTO requestEquipBusinessPolicyDTO = JSONObject.parseObject(dataStr, RequestEquipBusinessPolicyDTO.class);
requestEquipBusinessPolicyDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaweiServiceV2.requestEquipBusinessPolicy(requestEquipBusinessPolicyDTO);
logger.info("华为请求设备计费信息 result:{}", map);
return CommonResult.success(0, "请求设备计费信息成功！", map.get("Data"), map.get("Sig"));
}
/**
* 接收启动充电结果
* @param request
* @param dto
* @return
*/
@PostMapping("/v2/notification_start_charge_result")
public CommonResult<?> receiveStartChargeResult(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("接收华为启动充电结果 params:{}", JSON.toJSONString(dto));
String dataStr = checkAuth(request, dto);
// 转换成相应对象
ReceiveStartChargeResultDTO receiveStartChargeResultDTO = JSONObject.parseObject(dataStr, ReceiveStartChargeResultDTO.class);
// receiveStartChargeResultDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaweiServiceV2.receiveStartChargeResult(receiveStartChargeResultDTO);
logger.info("接收华为启动充电结果 result:{}", map);
return CommonResult.success(0, "推送启动充电结果成功！", map.get("Data"), map.get("Sig"));
}
/**
* 接收设备充电状态
* @param request
* @param dto
* @return
*/
@PostMapping("/v2/notification_equip_charge_status")
public CommonResult<?> receiveEquipChargeStatus(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("接收华为设备充电状态 params:{}", JSON.toJSONString(dto));
String dataStr = checkAuth(request, dto);
// 转换成相应对象
ReceiveEquipChargeStatusDTO receiveEquipChargeStatusDTO = JSONObject.parseObject(dataStr, ReceiveEquipChargeStatusDTO.class);
// receiveEquipChargeStatusDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaweiServiceV2.receiveEquipChargeStatus(receiveEquipChargeStatusDTO);
logger.info("接收华为设备充电状态 result:{}", map);
return CommonResult.success(0, "接收设备充电状态成功！", map.get("Data"), map.get("Sig"));
}
/**
* 接收华为所推送的停止充电结果
* @param request
* @param dto
* @return
*/
@PostMapping("/v2/notification_stop_charge_result")
public CommonResult<?> receiveStopChargeResult(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("接收华为停止充电结果 params:{}", JSON.toJSONString(dto));
String dataStr = checkAuth(request, dto);
// 转换成相应对象
ReceiveStopChargeResultVO receiveStopChargeResultVO = JSONObject.parseObject(dataStr, ReceiveStopChargeResultVO.class);
// receiveStopChargeResultVO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaweiServiceV2.receiveStopChargeResult(receiveStopChargeResultVO);
logger.info("接收华为停止充电结果 result:{}", map);
return CommonResult.success(0, "接收停止充电结果成功！", map.get("Data"), map.get("Sig"));
}
/**
* 接收订单信息
* @param request
* @param dto
* @return
*/
@PostMapping("/v2/notification_charge_order_info")
public CommonResult<?> receiveOrderInfo(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("接收华为订单信息 params:{}", JSON.toJSONString(dto));
String dataStr = checkAuth(request, dto);
// 转换成相应对象
ReceiveOrderInfoDTO receiveOrderInfoDTO = JSONObject.parseObject(dataStr, ReceiveOrderInfoDTO.class);
// receiveOrderInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaweiServiceV2.receiveOrderInfo(receiveOrderInfoDTO);
logger.info("接收华为订单信息 result:{}", map);
return CommonResult.success(0, "接收订单信息成功！", map.get("Data"), map.get("Sig"));
}
/**
* vin启动充电
* @param request
* @param dto
* @return
*/
@PostMapping("/v2/insert_start_charge")
public CommonResult<?> vinStartCharge(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("华为vin启动充电 params:{}", JSON.toJSONString(dto));
String dataStr = checkAuth(request, dto);
// 转换成相应对象
VinStartChargeDTO vinStartChargeDTO = JSONObject.parseObject(dataStr, VinStartChargeDTO.class);
// receiveOrderInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> resultMap = null;
try {
resultMap = huaweiServiceV2.vinStartCharge(vinStartChargeDTO);
} catch (Exception e) {
logger.error("华为vin启动充电 error", e);
}
logger.info("华为vin启动充电 resultMap:{}", resultMap);
if (resultMap != null) {
return CommonResult.success(0, "vin启动充电结果", resultMap.get("Data"), resultMap.get("Sig"));
}else {
return CommonResult.failed("vin启动充电 error");
}
}
/**
* 下发计费策略响应
* @param request
* @param dto
* @return
*/
@PostMapping("/v2/notification_deliver_equip_business_policy_result")
public CommonResult<?> receiveDeliverEquipBusinessPolicyResult(HttpServletRequest request, @RequestBody CommonParamsDTO dto){
logger.info("华为下发计费策略响应 params:{}", JSON.toJSONString(dto));
String dataStr = checkAuth(request, dto);
// 转换成相应对象
DeliverBusinessPolicyResponseDTO deliverPolicyResponseDTO = JSONObject.parseObject(dataStr, DeliverBusinessPolicyResponseDTO.class);
// receiveOrderInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = huaweiServiceV2.receiveDeliverEquipBusinessPolicyResult(deliverPolicyResponseDTO);
logger.info("华为下发计费策略响应 result:{}", map);
return CommonResult.success(0, "接收下发计费策略响应信息成功！", map.get("Data"), map.get("Sig"));
}
// ======================== 以上为 华为 --> 万车充 ========================
// ======================== 下面为 万车充 --> 华为 ========================
/**
* 平台充电设备编码同步
* @param stationId
* @return
*/
@GetMapping("/v2/notification_operation_system_info/{stationId}")
public RestApiResponse<?> notificationOperationSystemInfo(@PathVariable("stationId") String stationId) {
// logger.info("华为平台充电设备编码同步 stationId:{}", stationId);
RestApiResponse<?> response = null;
String result = null;
try {
result = huaweiServiceV2.notificationOperationSystemInfo(stationId);
response = new RestApiResponse<>(result);
} catch (Exception e) {
logger.error("华为平台充电设备编码同步 error", e);
}
logger.info("华为平台充电设备编码同步 stationId:{}, result:{}", stationId, result);
return response;
}
/**
* 设备接口状态查询
* @param stationIds
* @return
*/
@PostMapping("/v2/query_station_status")
public RestApiResponse<?> queryStationStatus(@RequestBody List<String> stationIds) {
// logger.info("查询华为设备接口状态 stationIds:{}", stationIds);
RestApiResponse<?> response = null;
Map<String, String> map = new LinkedHashMap<>();
try {
map = huaweiServiceV2.queryStationStatus(stationIds);
response = new RestApiResponse<>(map);
} catch (Exception e) {
logger.error("查询华为设备接口状态 error", e);
}
logger.info("查询华为设备接口状态 stationIds:{}, result:{}", stationIds, map);
return response;
}
/**
* 请求设备认证
* @param connectorId
* @return
*/
@PostMapping("/v2/query_equip_auth")
public RestApiResponse<?> queryEquipAuth(@RequestBody String connectorId) {
// logger.info("请求华为设备认证 connectorId:{}", connectorId);
RestApiResponse<?> response = null;
QueryEquipAuthVO vo = null;
try {
vo = huaweiServiceV2.queryEquipAuth(connectorId);
response = new RestApiResponse<>(vo);
} catch (Exception e) {
logger.error("请求华为设备认证 error", e);
}
logger.info("请求华为设备认证 connectorId:{}, result:{}", connectorId, JSON.toJSONString(vo));
return response;
}
/**
* 请求启动充电
* @param dto
* @return
*/
@PostMapping("/v2/query_start_charge")
public RestApiResponse<?> queryStartCharge(@RequestBody HWQueryStartChargeDTO dto) {
// logger.info("请求华为启动充电 param:{}", JSON.toJSONString(dto));
RestApiResponse<?> response = null;
QueryStartChargeVO vo = null;
try {
vo = huaweiServiceV2.queryStartCharge(dto);
response = new RestApiResponse<>(vo);
} catch (Exception e) {
logger.error("请求华为启动充电 error", e);
}
logger.info("请求华为启动充电 param:{}, result:{}", JSON.toJSONString(dto), JSON.toJSONString(vo));
return response;
}
/**
* 查询充电状态
* @param startChargeSeq
* @return
*/
@PostMapping("/v2/query_equip_charge_status")
public RestApiResponse<?> queryChargeStatus(@RequestBody String startChargeSeq) {
// logger.info("查询华为充电状态 startChargeSeq:{}", startChargeSeq);
RestApiResponse<?> response = null;
QueryChargeStatusVO vo = null;
try {
vo = huaweiServiceV2.queryChargeStatus(startChargeSeq);
response = new RestApiResponse<>(vo);
} catch (Exception e) {
logger.error("查询华为充电状态 error", e);
}
logger.info("查询华为充电状态 startChargeSeq:{}, result:{}", startChargeSeq, JSON.toJSONString(vo));
return response;
}
/**
* 请求停止充电
* @param startChargeSeq
* @return
*/
@PostMapping("/v2/query_stop_charge")
public RestApiResponse<?> queryStopCharge(@RequestBody String startChargeSeq) {
// logger.info("请求华为停止充电 startChargeSeq:{}", startChargeSeq);
RestApiResponse<?> response = null;
QueryStartChargeVO vo = null;
try {
vo = huaweiServiceV2.queryStopCharge(startChargeSeq);
response = new RestApiResponse<>(vo);
}catch (Exception e) {
logger.error("请求华为停止充电 error", e);
}
logger.info("请求华为停止充电 startChargeSeq:{}, result:{}", startChargeSeq, JSON.toJSONString(vo));
return response;
}
@PostMapping("/commonStartCharge")
public RestApiResponse<?> commonStartCharge(@RequestBody ThirdPartyCommonStartChargeDTO dto) {
RestApiResponse<?> response = null;
try {
String result = commonService.commonQueryStartCharge(dto);
response = new RestApiResponse<>(result);
} catch (Exception e) {
logger.error("统一启动充电接口 error", e);
}
logger.info("统一启动充电接口 params:{}, result:{}", JSON.toJSONString(dto), response);
return response;
}
/**
* 校验令牌
* @param request
* @param dto
* @return
*/
private String checkAuth(HttpServletRequest request, CommonParamsDTO dto) {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
// 校验失败
logger.error("令牌校验错误");
return null;
}
// 校验签名
Map<String, String> resultMap = huaweiServiceV2.checkoutSign(dto);
if (resultMap == null) {
// 签名错误
logger.error("令牌校验错误");
return null;
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
return dataStr;
}
//
// @Autowired
// private HuaweiServiceV2 huaweiServiceV2;
//
// @Autowired
// private CommonService commonService;
//
// /**
// * 获取token接口
// * http://localhost:8080/huawei/v1/query_token
// */
// // @PostMapping("/v2/query_token")
// // public CommonResult<?> queryToken(@RequestBody CommonParamsDTO dto) {
// // logger.info("华为平台请求令牌 params:{}", JSON.toJSONString(dto));
// // try {
// // Map<String, String> map = huaweiServiceV2.generateToken(dto);
// // logger.info("华为平台请求令牌 result:{}", JSON.toJSONString(map));
// // return CommonResult.success(0, "请求令牌成功！", map.get("Data"), map.get("Sig"));
// // } catch (UnsupportedEncodingException e) {
// // logger.error("获取token接口 异常");
// // return CommonResult.failed("获取token发生异常");
// // }
// // }
//
// /**
// * 华为设备接口状态变化推送
// * @param dto
// * @return
// */
// @PostMapping("/v2/notification_stationStatus")
// public CommonResult<?> receiveNotificationStationStatus(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("华为设备接口状态变化推送 params:{}", JSON.toJSONString(dto));
// String dataStr = checkAuth(request, dto);
// // 转换成相应对象
// ConnectorStatusInfo connectorStatusInfo = JSONObject.parseObject(dataStr, ConnectorStatusInfo.class);
// connectorStatusInfo.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaweiServiceV2.receiveNotificationStationStatus(connectorStatusInfo);
// logger.info("华为设备接口状态变化推送 result:{}", map);
// return CommonResult.success(0, "设备接口状态变化推送成功！", map.get("Data"), map.get("Sig"));
// }
//
//
// /**
// * 请求设备计费信息
// * @param request
// * @param dto
// * @return
// */
// @PostMapping("/v2/request_equip_business_policy")
// public CommonResult<?> requestEquipBusinessPolicy(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("华为请求设备计费信息 params:{}", JSON.toJSONString(dto));
// String dataStr = checkAuth(request, dto);
// // 转换成相应对象
// RequestEquipBusinessPolicyDTO requestEquipBusinessPolicyDTO = JSONObject.parseObject(dataStr, RequestEquipBusinessPolicyDTO.class);
// requestEquipBusinessPolicyDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaweiServiceV2.requestEquipBusinessPolicy(requestEquipBusinessPolicyDTO);
// logger.info("华为请求设备计费信息 result:{}", map);
// return CommonResult.success(0, "请求设备计费信息成功！", map.get("Data"), map.get("Sig"));
// }
//
//
// /**
// * 接收启动充电结果
// * @param request
// * @param dto
// * @return
// */
// @PostMapping("/v2/notification_start_charge_result")
// public CommonResult<?> receiveStartChargeResult(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("接收华为启动充电结果 params:{}", JSON.toJSONString(dto));
// String dataStr = checkAuth(request, dto);
// // 转换成相应对象
// ReceiveStartChargeResultDTO receiveStartChargeResultDTO = JSONObject.parseObject(dataStr, ReceiveStartChargeResultDTO.class);
// // receiveStartChargeResultDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaweiServiceV2.receiveStartChargeResult(receiveStartChargeResultDTO);
// logger.info("接收华为启动充电结果 result:{}", map);
// return CommonResult.success(0, "推送启动充电结果成功！", map.get("Data"), map.get("Sig"));
// }
//
//
// /**
// * 接收设备充电状态
// * @param request
// * @param dto
// * @return
// */
// @PostMapping("/v2/notification_equip_charge_status")
// public CommonResult<?> receiveEquipChargeStatus(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("接收华为设备充电状态 params:{}", JSON.toJSONString(dto));
// String dataStr = checkAuth(request, dto);
// // 转换成相应对象
// ReceiveEquipChargeStatusDTO receiveEquipChargeStatusDTO = JSONObject.parseObject(dataStr, ReceiveEquipChargeStatusDTO.class);
// // receiveEquipChargeStatusDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaweiServiceV2.receiveEquipChargeStatus(receiveEquipChargeStatusDTO);
// logger.info("接收华为设备充电状态 result:{}", map);
// return CommonResult.success(0, "接收设备充电状态成功！", map.get("Data"), map.get("Sig"));
// }
//
//
// /**
// * 接收华为所推送的停止充电结果
// * @param request
// * @param dto
// * @return
// */
// @PostMapping("/v2/notification_stop_charge_result")
// public CommonResult<?> receiveStopChargeResult(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("接收华为停止充电结果 params:{}", JSON.toJSONString(dto));
// String dataStr = checkAuth(request, dto);
// // 转换成相应对象
// ReceiveStopChargeResultVO receiveStopChargeResultVO = JSONObject.parseObject(dataStr, ReceiveStopChargeResultVO.class);
// // receiveStopChargeResultVO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaweiServiceV2.receiveStopChargeResult(receiveStopChargeResultVO);
// logger.info("接收华为停止充电结果 result:{}", map);
// return CommonResult.success(0, "接收停止充电结果成功！", map.get("Data"), map.get("Sig"));
// }
//
// /**
// * 接收订单信息
// * @param request
// * @param dto
// * @return
// */
// @PostMapping("/v2/notification_charge_order_info")
// public CommonResult<?> receiveOrderInfo(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("接收华为订单信息 params:{}", JSON.toJSONString(dto));
// String dataStr = checkAuth(request, dto);
// // 转换成相应对象
// ReceiveOrderInfoDTO receiveOrderInfoDTO = JSONObject.parseObject(dataStr, ReceiveOrderInfoDTO.class);
// // receiveOrderInfoDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaweiServiceV2.receiveOrderInfo(receiveOrderInfoDTO);
// logger.info("接收华为订单信息 result:{}", map);
// return CommonResult.success(0, "接收订单信息成功！", map.get("Data"), map.get("Sig"));
// }
//
// /**
// * vin启动充电
// * @param request
// * @param dto
// * @return
// */
// @PostMapping("/v2/insert_start_charge")
// public CommonResult<?> vinStartCharge(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
// logger.info("华为vin启动充电 params:{}", JSON.toJSONString(dto));
// String dataStr = checkAuth(request, dto);
// // 转换成相应对象
// VinStartChargeDTO vinStartChargeDTO = JSONObject.parseObject(dataStr, VinStartChargeDTO.class);
// // receiveOrderInfoDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> resultMap = null;
// try {
// resultMap = huaweiServiceV2.vinStartCharge(vinStartChargeDTO);
// } catch (Exception e) {
// logger.error("华为vin启动充电 error", e);
// }
// logger.info("华为vin启动充电 resultMap:{}", resultMap);
// if (resultMap != null) {
// return CommonResult.success(0, "vin启动充电结果", resultMap.get("Data"), resultMap.get("Sig"));
// }else {
// return CommonResult.failed("vin启动充电 error");
// }
// }
//
// /**
// * 下发计费策略响应
// * @param request
// * @param dto
// * @return
// */
// @PostMapping("/v2/notification_deliver_equip_business_policy_result")
// public CommonResult<?> receiveDeliverEquipBusinessPolicyResult(HttpServletRequest request, @RequestBody CommonParamsDTO dto){
// logger.info("华为下发计费策略响应 params:{}", JSON.toJSONString(dto));
// String dataStr = checkAuth(request, dto);
// // 转换成相应对象
// DeliverBusinessPolicyResponseDTO deliverPolicyResponseDTO = JSONObject.parseObject(dataStr, DeliverBusinessPolicyResponseDTO.class);
// // receiveOrderInfoDTO.setOperatorId(dto.getOperatorID());
// Map<String, String> map = huaweiServiceV2.receiveDeliverEquipBusinessPolicyResult(deliverPolicyResponseDTO);
// logger.info("华为下发计费策略响应 result:{}", map);
// return CommonResult.success(0, "接收下发计费策略响应信息成功！", map.get("Data"), map.get("Sig"));
// }
//
//
// // ======================== 以上为 华为 --> 万车充 ========================
// // ======================== 下面为 万车充 --> 华为 ========================
//
//
// /**
// * 平台充电设备编码同步
// * @param stationId
// * @return
// */
// @GetMapping("/v2/notification_operation_system_info/{stationId}")
// public RestApiResponse<?> notificationOperationSystemInfo(@PathVariable("stationId") String stationId) {
// // logger.info("华为平台充电设备编码同步 stationId:{}", stationId);
// RestApiResponse<?> response = null;
// String result = null;
// try {
// result = huaweiServiceV2.notificationOperationSystemInfo(stationId);
// response = new RestApiResponse<>(result);
// } catch (Exception e) {
// logger.error("华为平台充电设备编码同步 error", e);
// }
// logger.info("华为平台充电设备编码同步 stationId:{}, result:{}", stationId, result);
// return response;
// }
//
// /**
// * 设备接口状态查询
// * @param stationIds
// * @return
// */
// @PostMapping("/v2/query_station_status")
// public RestApiResponse<?> queryStationStatus(@RequestBody List<String> stationIds) {
// // logger.info("查询华为设备接口状态 stationIds:{}", stationIds);
// RestApiResponse<?> response = null;
// Map<String, String> map = new LinkedHashMap<>();
// try {
// map = huaweiServiceV2.queryStationStatus(stationIds);
// response = new RestApiResponse<>(map);
// } catch (Exception e) {
// logger.error("查询华为设备接口状态 error", e);
// }
// logger.info("查询华为设备接口状态 stationIds:{}, result:{}", stationIds, map);
// return response;
// }
//
// /**
// * 请求设备认证
// * @param connectorId
// * @return
// */
// @PostMapping("/v2/query_equip_auth")
// public RestApiResponse<?> queryEquipAuth(@RequestBody String connectorId) {
// // logger.info("请求华为设备认证 connectorId:{}", connectorId);
// RestApiResponse<?> response = null;
// QueryEquipAuthVO vo = null;
// try {
// vo = huaweiServiceV2.queryEquipAuth(connectorId);
// response = new RestApiResponse<>(vo);
// } catch (Exception e) {
// logger.error("请求华为设备认证 error", e);
// }
// logger.info("请求华为设备认证 connectorId:{}, result:{}", connectorId, JSON.toJSONString(vo));
// return response;
// }
//
// /**
// * 请求启动充电
// * @param dto
// * @return
// */
// @PostMapping("/v2/query_start_charge")
// public RestApiResponse<?> queryStartCharge(@RequestBody HWQueryStartChargeDTO dto) {
// // logger.info("请求华为启动充电 param:{}", JSON.toJSONString(dto));
// RestApiResponse<?> response = null;
// QueryStartChargeVO vo = null;
// try {
// vo = huaweiServiceV2.queryStartCharge(dto);
// response = new RestApiResponse<>(vo);
// } catch (Exception e) {
// logger.error("请求华为启动充电 error", e);
// }
// logger.info("请求华为启动充电 param:{}, result:{}", JSON.toJSONString(dto), JSON.toJSONString(vo));
// return response;
// }
//
//
// /**
// * 查询充电状态
// * @param startChargeSeq
// * @return
// */
// @PostMapping("/v2/query_equip_charge_status")
// public RestApiResponse<?> queryChargeStatus(@RequestBody String startChargeSeq) {
// // logger.info("查询华为充电状态 startChargeSeq:{}", startChargeSeq);
// RestApiResponse<?> response = null;
// QueryChargeStatusVO vo = null;
// try {
// vo = huaweiServiceV2.queryChargeStatus(startChargeSeq);
// response = new RestApiResponse<>(vo);
// } catch (Exception e) {
// logger.error("查询华为充电状态 error", e);
// }
// logger.info("查询华为充电状态 startChargeSeq:{}, result:{}", startChargeSeq, JSON.toJSONString(vo));
// return response;
// }
//
//
// /**
// * 请求停止充电
// * @param startChargeSeq
// * @return
// */
// @PostMapping("/v2/query_stop_charge")
// public RestApiResponse<?> queryStopCharge(@RequestBody String startChargeSeq) {
// // logger.info("请求华为停止充电 startChargeSeq:{}", startChargeSeq);
// RestApiResponse<?> response = null;
// QueryStartChargeVO vo = null;
// try {
// vo = huaweiServiceV2.queryStopCharge(startChargeSeq);
// response = new RestApiResponse<>(vo);
// }catch (Exception e) {
// logger.error("请求华为停止充电 error", e);
// }
// logger.info("请求华为停止充电 startChargeSeq:{}, result:{}", startChargeSeq, JSON.toJSONString(vo));
// return response;
// }
//
//
//
// @PostMapping("/commonStartCharge")
// public RestApiResponse<?> commonStartCharge(@RequestBody ThirdPartyCommonStartChargeDTO dto) {
// RestApiResponse<?> response = null;
// try {
// String result = commonService.commonQueryStartCharge(dto);
// response = new RestApiResponse<>(result);
// } catch (Exception e) {
// logger.error("统一启动充电接口 error", e);
// }
// logger.info("统一启动充电接口 params:{}, result:{}", JSON.toJSONString(dto), response);
// return response;
// }
//
//
//
//
//
// /**
// * 校验令牌
// * @param request
// * @param dto
// * @return
// */
// private String checkAuth(HttpServletRequest request, CommonParamsDTO dto) {
// // 校验令牌
// String token = request.getHeader("Authorization");
// if (!JWTUtils.checkThirdPartyToken(token)) {
// // 校验失败
// logger.error("令牌校验错误");
// return null;
// }
// // 校验签名
// Map<String, String> resultMap = huaweiServiceV2.checkoutSign(dto);
// if (resultMap == null) {
// // 签名错误
// logger.error("令牌校验错误");
// return null;
// }
// String operatorSecret = resultMap.get("OperatorSecret");
// String dataString = resultMap.get("Data");
// String dataSecret = resultMap.get("DataSecret");
// String dataSecretIV = resultMap.get("DataSecretIV");
// // 解密data
// byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
// String dataStr = new String(plainText, StandardCharsets.UTF_8);
// return dataStr;
// }
//
//
}

182
jsowell-admin/src/main/java/com/jsowell/api/thirdparty/NXJTController.java vendored
View File

@@ -4,16 +4,21 @@ import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.jsowell.common.annotation.Anonymous;
import com.jsowell.common.core.controller.BaseController;
import com.jsowell.common.enums.thirdparty.ThirdPartyReturnCodeEnum;
import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
import com.jsowell.common.util.JWTUtils;
import com.jsowell.pile.dto.QueryStationInfoDTO;
import com.jsowell.pile.dto.ningxiajiaotou.NXJTQueryOrdersInfoDTO;
import com.jsowell.pile.dto.ningxiajiaotou.NXJTQueryStationInfoDTO;
import com.jsowell.thirdparty.lianlian.common.CommonResult;
import com.jsowell.pile.thirdparty.CommonParamsDTO;
import com.jsowell.thirdparty.lianlian.service.LianLianService;
import com.jsowell.thirdparty.platform.service.ThirdPartyPlatformService;
import com.jsowell.thirdparty.platform.util.Cryptos;
import com.jsowell.thirdparty.platform.util.Encodes;
import com.jsowell.thirdparty.ningxiajiaotou.service.NXJTService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -33,13 +38,15 @@ import java.util.Map;
@Anonymous
@RestController
@RequestMapping("/nxjt")
public class NXJTController extends BaseController {
public class NXJTController extends ThirdPartyBaseController {
private final String platformName = "宁夏交投平台";
private final String platformType = ThirdPlatformTypeEnum.NING_XIA_JIAO_TOU.getTypeCode();
@Autowired
private NXJTService nxjtService;
@Autowired
private LianLianService lianLianService;
@Qualifier("ningXiaJiaoTouPlatformServiceImpl")
private ThirdPartyPlatformService platformLogic;
/**
* 获取token接口
@@ -47,13 +54,12 @@ public class NXJTController extends BaseController {
*/
@PostMapping("/v1/query_token")
public CommonResult<?> queryToken(@RequestBody CommonParamsDTO dto) {
logger.info("宁夏交投平台请求令牌 params:{}", JSON.toJSONString(dto));
try {
Map<String, String> map = nxjtService.generateToken(dto);
logger.info("宁夏交投平台请求令牌 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求令牌成功！", map.get("Data"), map.get("Sig"));
} catch (UnsupportedEncodingException e) {
logger.error("获取token接口 异常");
Map<String, String> map = platformLogic.queryToken(dto);
logger.info("{}-请求令牌, params:{}, result:{}", platformName, JSON.toJSONString(dto), JSON.toJSONString(map));
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("{}-获取token接口, 异常, params:{}", platformName, JSON.toJSONString(dto), e);
return CommonResult.failed("获取token发生异常");
}
}
@@ -66,36 +72,30 @@ public class NXJTController extends BaseController {
*/
@PostMapping("/v1/query_stations_info")
public CommonResult<?> queryStationsInfo(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("宁夏交投平台查询充电站信息 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询充电站信息 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
NXJTQueryStationInfoDTO nxjtQueryStationInfoDTO = JSONObject.parseObject(dataStr, NXJTQueryStationInfoDTO.class);
nxjtQueryStationInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = nxjtService.queryStationsInfo(nxjtQueryStationInfoDTO);
// return CommonResult.success(map);
return CommonResult.success(0, "查询充电站信息成功！", map.get("Data"), map.get("Sig"));
// 解析入参
NXJTQueryStationInfoDTO nxjtQueryStationInfoDTO = parseParamsDTO(dto, NXJTQueryStationInfoDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.NXJTQueryStationsInfo(nxjtQueryStationInfoDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("宁夏交投平台查询充电站信息 error:", e);
e.printStackTrace();
logger.info("{}-查询充电站信息 error:", platformName, e);
}
return CommonResult.failed("查询充电站信息发生异常");
}
@@ -109,38 +109,32 @@ public class NXJTController extends BaseController {
*/
@PostMapping("/v1/query_free_pile_number")
public CommonResult<?> queryFreePileNumber(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("宁夏交投平台查询充电站中空闲桩数量 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询充电站中空闲桩数量 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
NXJTQueryStationInfoDTO nxjtQueryStationInfoDTO = JSONObject.parseObject(dataStr, NXJTQueryStationInfoDTO.class);
nxjtQueryStationInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = nxjtService.queryFreePileNumber(nxjtQueryStationInfoDTO);
// return CommonResult.success(map);
return CommonResult.success(0, "查询充电站中空闲桩数量信息成功！", map.get("Data"), map.get("Sig"));
// 解析入参
NXJTQueryStationInfoDTO nxjtQueryStationInfoDTO = parseParamsDTO(dto, NXJTQueryStationInfoDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryFreePileNumber(nxjtQueryStationInfoDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("宁夏交投平台查询充电站中空闲桩数量 error:", e);
e.printStackTrace();
logger.info("{}-查询充电站中空闲桩数量 error:", platformName, e);
}
return CommonResult.failed("查询充电站中空闲桩数量信息发生异常");
return CommonResult.failed("查询充电站中空闲桩数量发生异常");
}
/**
@@ -151,36 +145,30 @@ public class NXJTController extends BaseController {
*/
@PostMapping("/v1/query_orders_info_by_Plate_number")
public CommonResult<?> queryOrdersInfoByPlateNumber(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("宁夏交投平台查询某车牌号消费记录 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询某车牌号消费记录 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
NXJTQueryOrdersInfoDTO nxjtQueryOrdersInfoDTO = JSONObject.parseObject(dataStr, NXJTQueryOrdersInfoDTO.class);
nxjtQueryOrdersInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = nxjtService.queryOrdersInfoByPlateNumber(nxjtQueryOrdersInfoDTO);
// return CommonResult.success(map);
return CommonResult.success(0, "查询充电站中空闲桩数量信息成功！", map.get("Data"), map.get("Sig"));
// 解析入参
NXJTQueryOrdersInfoDTO nxjtQueryOrdersInfoDTO = parseParamsDTO(dto, NXJTQueryOrdersInfoDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryOrdersInfoByPlateNumber(nxjtQueryOrdersInfoDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("宁夏交投平台查询某车牌号消费记录 error:", e);
e.printStackTrace();
logger.info("{}-查询某车牌号消费记录 error:", platformName, e);
}
return CommonResult.failed("查询某车牌号消费记录发生异常");
}
@@ -194,36 +182,30 @@ public class NXJTController extends BaseController {
*/
@PostMapping("/v1/query_orders_info")
public CommonResult<?> queryOrdersInfo(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("宁夏交投平台查询某段时间内消费记录 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询某段时间内消费记录 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
NXJTQueryOrdersInfoDTO nxjtQueryOrdersInfoDTO = JSONObject.parseObject(dataStr, NXJTQueryOrdersInfoDTO.class);
nxjtQueryOrdersInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = nxjtService.queryOrdersInfo(nxjtQueryOrdersInfoDTO);
// return CommonResult.success(map);
return CommonResult.success(0, "查询充电站中空闲桩数量信息成功！", map.get("Data"), map.get("Sig"));
// 解析入参
NXJTQueryOrdersInfoDTO nxjtQueryOrdersInfoDTO = parseParamsDTO(dto, NXJTQueryOrdersInfoDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryOrdersInfo(nxjtQueryOrdersInfoDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("宁夏交投平台查询某段时间内消费记录 error:", e);
e.printStackTrace();
logger.info("{}-查询某段时间内消费记录 error:", platformName, e);
}
return CommonResult.failed("查询某段时间内消费记录发生异常");
}

197
jsowell-admin/src/main/java/com/jsowell/api/thirdparty/QingHaiController.java vendored
View File

@@ -3,6 +3,7 @@ package com.jsowell.api.thirdparty;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.jsowell.common.annotation.Anonymous;
import com.jsowell.common.enums.thirdparty.ThirdPartyReturnCodeEnum;
import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
import com.jsowell.common.exception.BusinessException;
import com.jsowell.common.response.RestApiResponse;
@@ -11,6 +12,7 @@ import com.jsowell.pile.domain.ThirdPartyPlatformConfig;
import com.jsowell.pile.dto.PushRealTimeInfoDTO;
import com.jsowell.pile.dto.QueryStartChargeDTO;
import com.jsowell.pile.dto.QueryStationInfoDTO;
import com.jsowell.pile.dto.ningxiajiaotou.NXJTQueryStationInfoDTO;
import com.jsowell.pile.service.ThirdPartyPlatformConfigService;
import com.jsowell.pile.thirdparty.CommonParamsDTO;
import com.jsowell.thirdparty.lianlian.common.CommonResult;
@@ -37,30 +39,27 @@ import java.util.Map;
@RequestMapping("/qinghai/evcs")
public class QingHaiController extends ThirdPartyBaseController {
@Autowired
@Qualifier("qingHaiPlatformServiceImpl")
private ThirdPartyPlatformService qingHaiPlatformServiceImpl;
private final String platformName = "青海省平台";
private final String platformType = ThirdPlatformTypeEnum.QING_HAI_PLATFORM.getTypeCode();
@Autowired
private ThirdPartyPlatformConfigService thirdPartyPlatformConfigService;
@Qualifier("qingHaiPlatformServiceImpl")
private ThirdPartyPlatformService platformLogic;
/**
* 获取token接口
* http://localhost:8080/qinghai/evcs/v1/query_token
*/
@PostMapping("/v1/query_token")
public CommonResult<?> queryToken(@RequestBody CommonParamsDTO dto) {
logger.info("青海平台请求令牌 params:{}", JSON.toJSONString(dto));
try {
// Map<String, String> map = lianLianService.generateToken(dto);
Map<String, String> map = qingHaiPlatformServiceImpl.queryToken(dto);
logger.info("青海平台请求令牌 result:{}", JSON.toJSONString(map));
Map<String, String> map = platformLogic.queryToken(dto);
logger.info("{}-请求令牌, params:{}, result:{}", platformName, JSON.toJSONString(dto), JSON.toJSONString(map));
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
}catch (BusinessException e) {
logger.error("青海平台请求令牌 error:{}, {}", e.getCode(), e.getMessage());
return CommonResult.failed("获取token发生异常");
} catch (Exception e) {
logger.error("青海平台请求令牌接口 异常");
logger.error("{}-获取token接口, 异常, params:{}", platformName, JSON.toJSONString(dto), e);
return CommonResult.failed("获取token发生异常");
}
}
@@ -71,41 +70,31 @@ public class QingHaiController extends ThirdPartyBaseController {
*/
@RequestMapping("/v1/query_stations_info")
public CommonResult<?> query_stations_info(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("青海平台查询充电站信息 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询充电站信息 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
// 查询配置信息
ThirdPartyPlatformConfig platformConfig = thirdPartyPlatformConfigService.getInfoByOperatorId(dto.getOperatorID());
String operatorSecret = platformConfig.getOperatorSecret();
String dataString = dto.getData();
String dataSecret = platformConfig.getDataSecret();
String dataSecretIV = platformConfig.getDataSecretIv();
// 校验签名
boolean verifyResult = qingHaiPlatformServiceImpl.verifySignature(dto, platformConfig.getSignSecret());
if (!verifyResult) {
// 验签失败
return CommonResult.failed("签名错误");
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStationInfoDTO queryStationInfoDTO = JSONObject.parseObject(dataStr, QueryStationInfoDTO.class);
queryStationInfoDTO.setOperatorId(dto.getOperatorID());
queryStationInfoDTO.setThirdPlatformType(ThirdPlatformTypeEnum.QING_HAI_PLATFORM.getTypeCode());
Map<String, String> map = qingHaiPlatformServiceImpl.queryStationsInfo(queryStationInfoDTO);
// 解析入参
QueryStationInfoDTO queryStationInfoDTO = parseParamsDTO(dto, QueryStationInfoDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryStationsInfo(queryStationInfoDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("青海平台查询充电站信息 error", e);
logger.info("{}-查询充电站信息 error:", platformName, e);
}
return CommonResult.failed("查询充电站信息异常");
return CommonResult.failed("查询充电站信息发生异常");
}
/**
@@ -114,39 +103,31 @@ public class QingHaiController extends ThirdPartyBaseController {
*/
@RequestMapping("/v1/query_equip_business_policy")
public CommonResult<?> query_equip_business_policy(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("青海平台查询业务策略信息 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询业务策略信息 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
// 查询配置信息
ThirdPartyPlatformConfig platformConfig = thirdPartyPlatformConfigService.getInfoByOperatorId(dto.getOperatorID());
String operatorSecret = platformConfig.getOperatorSecret();
String dataString = dto.getData();
String dataSecret = platformConfig.getDataSecret();
String dataSecretIV = platformConfig.getDataSecretIv();
// 校验签名
boolean verifyResult = qingHaiPlatformServiceImpl.verifySignature(dto, platformConfig.getSignSecret());
if (!verifyResult) {
// 验签失败
return CommonResult.failed("签名错误");
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
queryStartChargeDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = qingHaiPlatformServiceImpl.queryEquipBusinessPolicy(queryStartChargeDTO);
// 解析入参
QueryStartChargeDTO queryStartChargeDTO = parseParamsDTO(dto, QueryStartChargeDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryEquipBusinessPolicy(queryStartChargeDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("青海平台查询业务策略信息 error", e);
logger.info("{}-查询业务策略信息 error:", platformName, e);
}
return CommonResult.failed("查询业务策略信息异常");
return CommonResult.failed("查询业务策略信息发生异常");
}
/**
@@ -154,71 +135,71 @@ public class QingHaiController extends ThirdPartyBaseController {
* @param stationIds
* @return
*/
@PostMapping("/pushStationPower")
public RestApiResponse<?> pushStationPower(@RequestBody List<String> stationIds) {
RestApiResponse<?> response = null;
try {
String result = qingHaiPlatformServiceImpl.notificationPowerInfo(stationIds);
response = new RestApiResponse<>(result);
}catch (Exception e) {
logger.error("青海平台推送站点功率 error", e);
}
logger.info("青海平台推送站点功率 result:{}", response);
return response;
}
// @PostMapping("/pushStationPower")
// public RestApiResponse<?> pushStationPower(@RequestBody List<String> stationIds) {
// RestApiResponse<?> response = null;
// try {
// String result = qingHaiPlatformServiceImpl.notificationPowerInfo(stationIds);
// response = new RestApiResponse<>(result);
// }catch (Exception e) {
// logger.error("青海平台推送站点功率 error", e);
// }
// logger.info("青海平台推送站点功率 result:{}", response);
// return response;
// }
/**
* 推送设备状态变化
* @param dto
* @return
*/
@PostMapping("/pushRealTimeInfo")
public RestApiResponse<?> pushStationPower(@RequestBody PushRealTimeInfoDTO dto) {
RestApiResponse<?> response = null;
try {
String result = qingHaiPlatformServiceImpl.notificationStationStatus(dto);
response = new RestApiResponse<>(result);
}catch (Exception e) {
logger.error("青海平台推送设备状态变化 error", e);
}
logger.info("青海平台推送设备状态变化 result:{}", response);
return response;
}
// @PostMapping("/pushRealTimeInfo")
// public RestApiResponse<?> pushStationPower(@RequestBody PushRealTimeInfoDTO dto) {
// RestApiResponse<?> response = null;
// try {
// String result = qingHaiPlatformServiceImpl.notificationStationStatus(dto);
// response = new RestApiResponse<>(result);
// }catch (Exception e) {
// logger.error("青海平台推送设备状态变化 error", e);
// }
// logger.info("青海平台推送设备状态变化 result:{}", response);
// return response;
// }
/**
* 推送充电状态
* @param orderCode
* @return
*/
@GetMapping("/notificationEquipChargeStatus/{orderCode}")
public RestApiResponse<?> notificationEquipChargeStatus(@PathVariable("orderCode") String orderCode) {
RestApiResponse<?> response = null;
try {
String result = qingHaiPlatformServiceImpl.notificationEquipChargeStatus(orderCode);
response = new RestApiResponse<>(result);
}catch (Exception e) {
logger.error("青海平台推送充电状态 error", e);
}
logger.info("青海平台推送充电状态 result:{}", response);
return response;
}
// @GetMapping("/notificationEquipChargeStatus/{orderCode}")
// public RestApiResponse<?> notificationEquipChargeStatus(@PathVariable("orderCode") String orderCode) {
// RestApiResponse<?> response = null;
// try {
// String result = qingHaiPlatformServiceImpl.notificationEquipChargeStatus(orderCode);
// response = new RestApiResponse<>(result);
// }catch (Exception e) {
// logger.error("青海平台推送充电状态 error", e);
// }
// logger.info("青海平台推送充电状态 result:{}", response);
// return response;
// }
/**
* 推送订单
* @param orderCode
* @return
*/
@GetMapping("/pushOrderInfo/{orderCode}")
public RestApiResponse<?> pushOrderInfo(@PathVariable("orderCode") String orderCode) {
RestApiResponse<?> response = null;
try {
String result = qingHaiPlatformServiceImpl.notificationChargeOrderInfo(orderCode);
response = new RestApiResponse<>(result);
}catch (Exception e) {
logger.error("青海平台推送订单信息 error", e);
}
logger.info("青海平台推送订单信息 result:{}", response);
return response;
}
// @GetMapping("/pushOrderInfo/{orderCode}")
// public RestApiResponse<?> pushOrderInfo(@PathVariable("orderCode") String orderCode) {
// RestApiResponse<?> response = null;
// try {
// String result = qingHaiPlatformServiceImpl.notificationChargeOrderInfo(orderCode);
// response = new RestApiResponse<>(result);
// }catch (Exception e) {
// logger.error("青海平台推送订单信息 error", e);
// }
// logger.info("青海平台推送订单信息 result:{}", response);
// return response;
// }
}

526
jsowell-admin/src/main/java/com/jsowell/api/thirdparty/XDTController.java vendored
View File

@@ -4,6 +4,7 @@ import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.jsowell.common.annotation.Anonymous;
import com.jsowell.common.core.controller.BaseController;
import com.jsowell.common.enums.thirdparty.ThirdPartyReturnCodeEnum;
import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
import com.jsowell.common.enums.ykc.ReturnCodeEnum;
import com.jsowell.common.exception.BusinessException;
@@ -13,10 +14,12 @@ import com.jsowell.common.util.StringUtils;
import com.jsowell.pile.dto.*;
import com.jsowell.thirdparty.lianlian.common.CommonResult;
import com.jsowell.pile.thirdparty.CommonParamsDTO;
import com.jsowell.thirdparty.platform.service.ThirdPartyPlatformService;
import com.jsowell.thirdparty.platform.util.Cryptos;
import com.jsowell.thirdparty.platform.util.Encodes;
import com.jsowell.thirdparty.xindiantu.service.XDTService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
@@ -33,10 +36,18 @@ import java.util.Map;
@Anonymous
@RestController
@RequestMapping("/xindiantu")
public class XDTController extends BaseController {
public class XDTController extends ThirdPartyBaseController {
private final String platformName = "新电途平台";
private final String platformType = ThirdPlatformTypeEnum.XIN_DIAN_TU.getTypeCode();
@Autowired
private XDTService xdtService;
@Qualifier("xinDiantuPlatfromServiceImpl")
private ThirdPartyPlatformService platformLogic;
// @Autowired
// private XDTService xdtService;
/**
* 获取token接口
@@ -44,13 +55,12 @@ public class XDTController extends BaseController {
*/
@PostMapping("/v1/query_token")
public CommonResult<?> queryToken(@RequestBody CommonParamsDTO dto) {
logger.info("新电途平台请求令牌 params:{}", JSON.toJSONString(dto));
try {
Map<String, String> map = xdtService.generateToken(dto);
logger.info("新电途平台请求令牌 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求令牌成功！", map.get("Data"), map.get("Sig"));
} catch (UnsupportedEncodingException e) {
logger.error("获取token接口 异常");
Map<String, String> map = platformLogic.queryToken(dto);
logger.info("{}-请求令牌, params:{}, result:{}", platformName, JSON.toJSONString(dto), JSON.toJSONString(map));
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("{}-获取token接口, 异常, params:{}", platformName, JSON.toJSONString(dto), e);
return CommonResult.failed("获取token发生异常");
}
}
@@ -61,26 +71,26 @@ public class XDTController extends BaseController {
* @param dto
* @return
*/
@PostMapping("/pushStationInfo")
public RestApiResponse<?> pushStationInfo(@RequestBody PushStationInfoDTO dto) {
logger.info("推送新电途平台充电站信息 params:{}", JSON.toJSONString(dto));
RestApiResponse<?> response = null;
try {
if (StringUtils.isBlank(String.valueOf(dto.getStationId()))) {
throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
}
xdtService.pushStationInfo(dto);
response = new RestApiResponse<>();
}catch (BusinessException e) {
logger.error("推送新电途平台充电站信息 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("推送新电途平台充电站信息 error", e);
response = new RestApiResponse<>(e);
}
logger.info("推送新电途平台充电站信息 result:{}", response);
return response;
}
// @PostMapping("/pushStationInfo")
// public RestApiResponse<?> pushStationInfo(@RequestBody PushStationInfoDTO dto) {
// logger.info("推送新电途平台充电站信息 params:{}", JSON.toJSONString(dto));
// RestApiResponse<?> response = null;
// try {
// if (StringUtils.isBlank(String.valueOf(dto.getStationId()))) {
// throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
// }
// xdtService.pushStationInfo(dto);
// response = new RestApiResponse<>();
// }catch (BusinessException e) {
// logger.error("推送新电途平台充电站信息 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("推送新电途平台充电站信息 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("推送新电途平台充电站信息 result:{}", response);
// return response;
// }
/**
* 查询充电站信息
@@ -88,36 +98,32 @@ public class XDTController extends BaseController {
*/
@RequestMapping("/v1/query_stations_info")
public CommonResult<?> query_stations_info(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("新电途平台查询充电站信息 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询充电站信息 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = xdtService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStationInfoDTO queryStationInfoDTO = JSONObject.parseObject(dataStr, QueryStationInfoDTO.class);
queryStationInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = xdtService.queryStationsInfo(queryStationInfoDTO);
return CommonResult.success(0, "查询充电站信息成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryStationInfoDTO queryStationInfoDTO = parseParamsDTO(dto, QueryStationInfoDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryStationsInfo(queryStationInfoDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("新电途平台查询充电站信息 error", e);
logger.info("{}-查询充电站信息 error:", platformName, e);
}
return CommonResult.failed("查询充电站信息异常");
return CommonResult.failed("查询充电站信息发生异常");
}
/**
@@ -128,39 +134,32 @@ public class XDTController extends BaseController {
*/
@PostMapping("/v1/query_station_status")
public CommonResult<?> queryStationStatus(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("新电途平台查询统计信息 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询充电站状态信息 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
// 校验签名
Map<String, String> resultMap = xdtService.checkoutSign(dto);
if (resultMap == null) {
// 签名错误
return CommonResult.failed("签名校验错误");
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
dto.setPlatformType(platformType);
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStationInfoDTO queryStationInfoDTO = JSONObject.parseObject(dataStr, QueryStationInfoDTO.class);
queryStationInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = xdtService.queryStationStatus(queryStationInfoDTO);
logger.info("新电途平台查询统计信息 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "查询统计信息成功！", map.get("Data"), map.get("Sig"));
// 校验签名
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
// 解析入参
QueryStationInfoDTO queryStationInfoDTO = parseParamsDTO(dto, QueryStationInfoDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryStationStatus(queryStationInfoDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("新电途平台查询统计信息 error:", e);
e.printStackTrace();
logger.error("{}-查询充电站状态信息 error:", platformName, e);
}
return CommonResult.failed("查询统计信息发生异常");
return CommonResult.failed("查询充电站状态信息发生异常");
}
/**
@@ -171,40 +170,32 @@ public class XDTController extends BaseController {
*/
@PostMapping("/v1/query_equip_business_policy")
public CommonResult<?> queryEquipBusinessPolicy(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("新电途平台查询业务策略信息 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询业务策略信息结果 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = xdtService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
queryStartChargeDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = xdtService.queryEquipBusinessPolicy(queryStartChargeDTO);
logger.info("新电途平台查询业务策略信息 result:{}", JSON.toJSONString(map));
// 解析入参
QueryStartChargeDTO queryStartChargeDTO = parseParamsDTO(dto, QueryStartChargeDTO.class);
return CommonResult.success(0, "查询业务策略信息成功！", map.get("Data"), map.get("Sig"));
// 执行逻辑
Map<String, String> map = platformLogic.queryEquipBusinessPolicy(queryStartChargeDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("新电途平台查询业务策略信息 error:", e);
e.printStackTrace();
logger.error("{}-查询业务策略信息结果 error:", platformName, e);
}
return CommonResult.failed("查询业务策略信息发生异常");
return CommonResult.failed("查询业务策略信息结果发生异常");
}
/**
@@ -215,36 +206,30 @@ public class XDTController extends BaseController {
*/
@PostMapping("/v1/query_equip_auth")
public CommonResult<?> query_equip_auth(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("新电途平台请求设备认证 param:{}", JSON.toJSONString(dto));
logger.info("{}-请求设备认证 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = xdtService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryEquipmentDTO queryEquipmentDTO = JSONObject.parseObject(dataStr, QueryEquipmentDTO.class);
queryEquipmentDTO.setOperatorID(dto.getOperatorID());
Map<String, String> map = xdtService.queryEquipAuth(queryEquipmentDTO);
logger.info("新电途平台请求设备认证 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求设备认证成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryEquipmentDTO queryEquipmentDTO = parseParamsDTO(dto, QueryEquipmentDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryEquipAuth(queryEquipmentDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("新电途平台请求设备认证 error:", e);
e.printStackTrace();
logger.error("{}-请求设备认证 error:", platformName, e);
}
return CommonResult.failed("请求设备认证发生异常");
}
@@ -257,35 +242,30 @@ public class XDTController extends BaseController {
*/
@PostMapping("/v1/query_start_charge")
public CommonResult<?> query_start_charge(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("新电途平台请求启动充电 params :{}", JSON.toJSONString(dto));
logger.info("{}-请求启动充电 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = xdtService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
queryStartChargeDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = xdtService.queryStartCharge(queryStartChargeDTO);
logger.info("新电途平台请求启动充电 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求启动充电成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryStartChargeDTO queryStartChargeDTO = parseParamsDTO(dto, QueryStartChargeDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryStartCharge(queryStartChargeDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("新电途平台请求启动充电 error", e);
logger.error("{}-请求启动充电 error:", platformName, e);
}
return CommonResult.failed("请求启动充电发生异常");
}
@@ -298,37 +278,32 @@ public class XDTController extends BaseController {
*/
@PostMapping("/v1/query_equip_charge_status")
public CommonResult<?> query_equip_charge_status(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("新电途平台查询充电状态 params :{}", JSON.toJSONString(dto));
logger.info("{}-查询充电状态 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = xdtService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryEquipChargeStatusDTO queryEquipChargeStatusDTO = JSONObject.parseObject(dataStr, QueryEquipChargeStatusDTO.class);
queryEquipChargeStatusDTO.setOperatorID(dto.getOperatorID());
Map<String, String> map = xdtService.queryEquipChargeStatus(queryEquipChargeStatusDTO);
logger.info("新电途平台查询充电状态 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "查询充电状态成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryEquipChargeStatusDTO queryEquipChargeStatusDTO = parseParamsDTO(dto, QueryEquipChargeStatusDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryEquipChargeStatus(queryEquipChargeStatusDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("新电途平台查询充电状态 error", e);
logger.error("{}-查询充电状态 error:", platformName, e);
}
return CommonResult.failed("新电途平台查询充电状态发生异常");
return CommonResult.failed("查询充电状态发生异常");
}
/**
@@ -339,37 +314,32 @@ public class XDTController extends BaseController {
*/
@PostMapping("/v1/query_stop_charge")
public CommonResult<?> query_stop_charge(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("新电途平台请求停止充电 params :{}", JSON.toJSONString(dto));
logger.info("{}-请求停止充电 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = xdtService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
queryStartChargeDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = xdtService.queryStopCharge(queryStartChargeDTO);
logger.info("新电途平台请求停止充电 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求停止充电成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryStartChargeDTO queryStartChargeDTO = parseParamsDTO(dto, QueryStartChargeDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryStopCharge(queryStartChargeDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("新电途平台请求停止充电 error", e);
logger.error("{}-请求停止充电 error:", platformName, e);
}
return CommonResult.failed("新电途平台请求停止充电发生异常");
return CommonResult.failed("请求停止充电发生异常");
}
/**
@@ -378,23 +348,23 @@ public class XDTController extends BaseController {
* @param orderCode
* @return
*/
@GetMapping("/pushStopChargeResult/{orderCode}")
public RestApiResponse<?> pushStopChargeResult(@PathVariable("orderCode") String orderCode) {
logger.info("新电途平台推送停止充电结果 params:{}", orderCode);
RestApiResponse<?> response = null;
try {
String result = xdtService.notificationStopChargeResult(orderCode);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("新电途平台推送停止充电结果 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("新电途平台推送停止充电结果 error", e);
response = new RestApiResponse<>(e);
}
logger.info("新电途平台推送停止充电结果 result:{}", response);
return response;
}
// @GetMapping("/pushStopChargeResult/{orderCode}")
// public RestApiResponse<?> pushStopChargeResult(@PathVariable("orderCode") String orderCode) {
// logger.info("新电途平台推送停止充电结果 params:{}", orderCode);
// RestApiResponse<?> response = null;
// try {
// String result = xdtService.notificationStopChargeResult(orderCode);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("新电途平台推送停止充电结果 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("新电途平台推送停止充电结果 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("新电途平台推送停止充电结果 result:{}", response);
// return response;
// }
/**
* 新电途推送充电订单信息
@@ -402,23 +372,23 @@ public class XDTController extends BaseController {
* @param orderCode
* @return
*/
@GetMapping("/pushChargeOrderInfo/{orderCode}")
public RestApiResponse<?> pushChargeOrderInfo(@PathVariable("orderCode") String orderCode) {
logger.info("新电途平台推送充电订单信息 params:{}", orderCode);
RestApiResponse<?> response = null;
try {
String result = xdtService.pushChargeOrderInfo(orderCode);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("新电途平台推送充电订单信息 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("新电途平台推送充电订单信息 error", e);
response = new RestApiResponse<>(e);
}
logger.info("新电途平台推送充电订单信息 result:{}", response);
return response;
}
// @GetMapping("/pushChargeOrderInfo/{orderCode}")
// public RestApiResponse<?> pushChargeOrderInfo(@PathVariable("orderCode") String orderCode) {
// logger.info("新电途平台推送充电订单信息 params:{}", orderCode);
// RestApiResponse<?> response = null;
// try {
// String result = xdtService.pushChargeOrderInfo(orderCode);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("新电途平台推送充电订单信息 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("新电途平台推送充电订单信息 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("新电途平台推送充电订单信息 result:{}", response);
// return response;
// }
/**
* 新电途推送充电状态
@@ -426,23 +396,23 @@ public class XDTController extends BaseController {
* @param orderCode
* @return
*/
@GetMapping("/pushChargeStatus/{orderCode}")
public RestApiResponse<?> pushChargeStatus(@PathVariable("orderCode") String orderCode) {
logger.info("新电途平台推送充电状态 params:{}", orderCode);
RestApiResponse<?> response = null;
try {
String result = xdtService.notificationEquipChargeStatus(orderCode);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("新电途平台推送充电状态 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("新电途平台推送充电状态 error", e);
response = new RestApiResponse<>(e);
}
logger.info("新电途平台推送充电状态 result:{}", response);
return response;
}
// @GetMapping("/pushChargeStatus/{orderCode}")
// public RestApiResponse<?> pushChargeStatus(@PathVariable("orderCode") String orderCode) {
// logger.info("新电途平台推送充电状态 params:{}", orderCode);
// RestApiResponse<?> response = null;
// try {
// String result = xdtService.notificationEquipChargeStatus(orderCode);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("新电途平台推送充电状态 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("新电途平台推送充电状态 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("新电途平台推送充电状态 result:{}", response);
// return response;
// }
/**
* 新电途推送启动充电结果
@@ -450,23 +420,23 @@ public class XDTController extends BaseController {
* @param orderCode
* @return
*/
@GetMapping("/pushStartChargeResult/{orderCode}")
public RestApiResponse<?> pushStartChargeResult(@PathVariable("orderCode") String orderCode) {
logger.info("新电途平台推送启动充电结果 params:{}", orderCode);
RestApiResponse<?> response = null;
try {
String result = xdtService.notificationStartChargeResult(orderCode);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("新电途平台推送启动充电结果 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("新电途平台推送启动充电结果 error", e);
response = new RestApiResponse<>(e);
}
logger.info("新电途平台推送启动充电结果 result:{}", response);
return response;
}
// @GetMapping("/pushStartChargeResult/{orderCode}")
// public RestApiResponse<?> pushStartChargeResult(@PathVariable("orderCode") String orderCode) {
// logger.info("新电途平台推送启动充电结果 params:{}", orderCode);
// RestApiResponse<?> response = null;
// try {
// String result = xdtService.notificationStartChargeResult(orderCode);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("新电途平台推送启动充电结果 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("新电途平台推送启动充电结果 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("新电途平台推送启动充电结果 result:{}", response);
// return response;
// }
/**
* 新电途平台设备状态变化推送
@@ -474,30 +444,30 @@ public class XDTController extends BaseController {
* @param dto
* @return
*/
@PostMapping("/pushStationStatus")
public RestApiResponse<?> pushStationStatus(@RequestBody PushInfoParamDTO dto) {
logger.info("新电途平台设备状态变化推送 params:{}", JSON.toJSONString(dto));
RestApiResponse<?> response = null;
try {
if (StringUtils.isBlank(String.valueOf(dto.getPileConnectorCode())) ||
StringUtils.isBlank(String.valueOf(dto.getStatus()))) {
throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
}
PushRealTimeInfoDTO pushRealTimeInfoDTO = new PushRealTimeInfoDTO();
pushRealTimeInfoDTO.setStatus(dto.getStatus());
pushRealTimeInfoDTO.setPileConnectorCode(dto.getPileConnectorCode());
pushRealTimeInfoDTO.setThirdPartyType(ThirdPlatformTypeEnum.XIN_DIAN_TU.getTypeCode());
String result = xdtService.notificationStationStatus(pushRealTimeInfoDTO);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("新电途平台设备状态变化推送 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("新电途平台设备状态变化推送 error", e);
response = new RestApiResponse<>(e);
}
logger.info("新电途平台设备状态变化推送 result:{}", response);
return response;
}
// @PostMapping("/pushStationStatus")
// public RestApiResponse<?> pushStationStatus(@RequestBody PushInfoParamDTO dto) {
// logger.info("新电途平台设备状态变化推送 params:{}", JSON.toJSONString(dto));
// RestApiResponse<?> response = null;
// try {
// if (StringUtils.isBlank(String.valueOf(dto.getPileConnectorCode())) ||
// StringUtils.isBlank(String.valueOf(dto.getStatus()))) {
// throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
// }
// PushRealTimeInfoDTO pushRealTimeInfoDTO = new PushRealTimeInfoDTO();
// pushRealTimeInfoDTO.setStatus(dto.getStatus());
// pushRealTimeInfoDTO.setPileConnectorCode(dto.getPileConnectorCode());
// pushRealTimeInfoDTO.setThirdPartyType(ThirdPlatformTypeEnum.XIN_DIAN_TU.getTypeCode());
// String result = xdtService.notificationStationStatus(pushRealTimeInfoDTO);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("新电途平台设备状态变化推送 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("新电途平台设备状态变化推送 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("新电途平台设备状态变化推送 result:{}", response);
// return response;
// }
}

469
jsowell-admin/src/main/java/com/jsowell/api/thirdparty/YCBCController.java vendored
View File

@@ -4,6 +4,7 @@ import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.jsowell.common.annotation.Anonymous;
import com.jsowell.common.core.controller.BaseController;
import com.jsowell.common.enums.thirdparty.ThirdPartyReturnCodeEnum;
import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
import com.jsowell.common.enums.ykc.ReturnCodeEnum;
import com.jsowell.common.exception.BusinessException;
@@ -14,11 +15,13 @@ import com.jsowell.pile.dto.*;
import com.jsowell.thirdparty.lianlian.common.CommonResult;
import com.jsowell.pile.thirdparty.CommonParamsDTO;
import com.jsowell.thirdparty.lianlian.service.LianLianService;
import com.jsowell.thirdparty.platform.service.ThirdPartyPlatformService;
import com.jsowell.thirdparty.platform.util.Cryptos;
import com.jsowell.thirdparty.platform.util.Encodes;
import com.jsowell.thirdparty.yongchengboche.dto.YCBCGetTokenDTO;
import com.jsowell.thirdparty.yongchengboche.service.YCBCService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
@@ -35,7 +38,15 @@ import java.util.Map;
@Anonymous
@RestController
@RequestMapping("/ycbc")
public class YCBCController extends BaseController {
public class YCBCController extends ThirdPartyBaseController {
private final String platformName = "甬城泊车平台";
private final String platformType = ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getTypeCode();
@Autowired
@Qualifier("yongChengbochePlatfromServiceImpl")
private ThirdPartyPlatformService platformLogic;
@Autowired
private YCBCService ycbcService;
@@ -49,13 +60,13 @@ public class YCBCController extends BaseController {
*/
@PostMapping("/v1/query_token")
public CommonResult<?> queryToken(@RequestBody CommonParamsDTO dto) {
logger.info("甬城泊车平台请求令牌 params:{}", JSON.toJSONString(dto));
// logger.info("{}-请求令牌 params:{}", platformName, JSON.toJSONString(dto));
try {
Map<String, String> map = ycbcService.generateToken(dto);
logger.info("甬城泊车平台请求令牌 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求令牌成功！", map.get("Data"), map.get("Sig"));
} catch (UnsupportedEncodingException e) {
logger.error("甬城泊车平台 请求令牌接口 异常");
Map<String, String> map = platformLogic.queryToken(dto);
logger.info("{}-请求令牌, params:{}, result:{}", platformName, JSON.toJSONString(dto), JSON.toJSONString(map));
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("{}-获取token接口, 异常, params:{}", platformName, JSON.toJSONString(dto), e);
return CommonResult.failed("获取token发生异常");
}
}
@@ -64,19 +75,19 @@ public class YCBCController extends BaseController {
* 获取token接口
* http://localhost:8080/ycbc/v1/query_token
*/
@PostMapping("/v1/ycbcQuery_token")
public String ycbcQueryToken(@RequestBody YCBCGetTokenDTO dto) {
logger.info("请求甬城泊车平台令牌 params:{}", JSON.toJSONString(dto));
String token = "";
try {
token = ycbcService.YCBCGetToken(dto);
logger.info("请求甬城泊车平台令牌 result:{}", token);
} catch (Exception e) {
logger.error("请求甬城泊车平台令牌接口 异常");
return "";
}
return token;
}
// @PostMapping("/v1/ycbcQuery_token")
// public String ycbcQueryToken(@RequestBody YCBCGetTokenDTO dto) {
// logger.info("请求甬城泊车平台令牌 params:{}", JSON.toJSONString(dto));
// String token = "";
// try {
// token = ycbcService.YCBCGetToken(dto);
// logger.info("请求甬城泊车平台令牌 result:{}", token);
// } catch (Exception e) {
// logger.error("请求甬城泊车平台令牌接口 异常");
// return "";
// }
// return token;
// }
/**
@@ -87,37 +98,29 @@ public class YCBCController extends BaseController {
*/
@PostMapping("/v1/query_stations_info")
public CommonResult<?> query_stations_info(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("甬城泊车平台查询充电站信息 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询充电站信息 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
// 签名错误
return CommonResult.failed("签名校验错误");
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStationInfoDTO queryStationInfoDTO = JSONObject.parseObject(dataStr, QueryStationInfoDTO.class);
queryStationInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = ycbcService.queryStationsInfo(queryStationInfoDTO);
logger.info("甬城泊车平台查询充电站信息 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "查询充电站信息成功！", map.get("Data"), map.get("Sig"));
// 校验签名
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
// 解析入参
QueryStationInfoDTO queryStationInfoDTO = parseParamsDTO(dto, QueryStationInfoDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryStationsInfo(queryStationInfoDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("甬城泊车平台查询充电站信息 error:", e);
e.printStackTrace();
logger.info("{}-查询充电站信息 error:", platformName, e);
}
return CommonResult.failed("查询充电站信息发生异常");
}
@@ -131,36 +134,29 @@ public class YCBCController extends BaseController {
*/
@PostMapping("/v1/query_station_status")
public CommonResult<?> query_station_status(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("甬城泊车平台查询充电站状态信息 params:{}", JSON.toJSONString(dto));
logger.info("{}-查询充电站状态信息 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStationInfoDTO queryStationInfoDTO = JSONObject.parseObject(dataStr, QueryStationInfoDTO.class);
queryStationInfoDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = ycbcService.queryStationStatus(queryStationInfoDTO);
logger.info("甬城泊车平台查询充电站状态信息 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "查询充电站状态信息成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryStationInfoDTO queryStationInfoDTO = parseParamsDTO(dto, QueryStationInfoDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryStationStatus(queryStationInfoDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("甬城泊车平台查询充电站状态信息 error:", e);
e.printStackTrace();
logger.error("{}-查询充电站状态信息 error:", platformName, e);
}
return CommonResult.failed("查询充电站状态信息发生异常");
}
@@ -172,31 +168,31 @@ public class YCBCController extends BaseController {
* @param dto
* @return
*/
@PostMapping("/pushStationStatus")
public RestApiResponse<?> pushStationStatus(@RequestBody PushInfoParamDTO dto) {
logger.info("甬城泊车平台设备状态变化推送 params:{}", JSON.toJSONString(dto));
RestApiResponse<?> response = null;
try {
if (StringUtils.isBlank(String.valueOf(dto.getPileConnectorCode())) ||
StringUtils.isBlank(String.valueOf(dto.getStatus()))) {
throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
}
PushRealTimeInfoDTO pushRealTimeInfoDTO = new PushRealTimeInfoDTO();
pushRealTimeInfoDTO.setStatus(dto.getStatus());
pushRealTimeInfoDTO.setPileConnectorCode(dto.getPileConnectorCode());
pushRealTimeInfoDTO.setThirdPartyType(ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getTypeCode());
String result = ycbcService.notificationStationStatus(pushRealTimeInfoDTO);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("甬城泊车平台设备状态变化推送 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("甬城泊车平台设备状态变化推送 error", e);
response = new RestApiResponse<>(e);
}
logger.info("甬城泊车平台设备状态变化推送 result:{}", response);
return response;
}
// @PostMapping("/pushStationStatus")
// public RestApiResponse<?> pushStationStatus(@RequestBody PushInfoParamDTO dto) {
// logger.info("甬城泊车平台设备状态变化推送 params:{}", JSON.toJSONString(dto));
// RestApiResponse<?> response = null;
// try {
// if (StringUtils.isBlank(String.valueOf(dto.getPileConnectorCode())) ||
// StringUtils.isBlank(String.valueOf(dto.getStatus()))) {
// throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
// }
// PushRealTimeInfoDTO pushRealTimeInfoDTO = new PushRealTimeInfoDTO();
// pushRealTimeInfoDTO.setStatus(dto.getStatus());
// pushRealTimeInfoDTO.setPileConnectorCode(dto.getPileConnectorCode());
// pushRealTimeInfoDTO.setThirdPartyType(ThirdPlatformTypeEnum.YONG_CHENG_BO_CHE.getTypeCode());
// String result = ycbcService.notificationStationStatus(pushRealTimeInfoDTO);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("甬城泊车平台设备状态变化推送 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("甬城泊车平台设备状态变化推送 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("甬城泊车平台设备状态变化推送 result:{}", response);
// return response;
// }
/**
* 甬城泊车推送启动充电结果
@@ -204,23 +200,23 @@ public class YCBCController extends BaseController {
* @param orderCode
* @return
*/
@GetMapping("/pushStartChargeResult/{orderCode}")
public RestApiResponse<?> pushStartChargeResult(@PathVariable("orderCode") String orderCode) {
logger.info("甬城泊车平台推送启动充电结果 params:{}", orderCode);
RestApiResponse<?> response = null;
try {
String result = ycbcService.pushStartChargeResult(orderCode);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("甬城泊车平台推送启动充电结果 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("甬城泊车平台推送启动充电结果 error", e);
response = new RestApiResponse<>(e);
}
logger.info("甬城泊车平台推送启动充电结果 result:{}", response);
return response;
}
// @GetMapping("/pushStartChargeResult/{orderCode}")
// public RestApiResponse<?> pushStartChargeResult(@PathVariable("orderCode") String orderCode) {
// logger.info("甬城泊车平台推送启动充电结果 params:{}", orderCode);
// RestApiResponse<?> response = null;
// try {
// String result = ycbcService.pushStartChargeResult(orderCode);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("甬城泊车平台推送启动充电结果 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("甬城泊车平台推送启动充电结果 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("甬城泊车平台推送启动充电结果 result:{}", response);
// return response;
// }
/**
* 请求设备认证
@@ -230,36 +226,30 @@ public class YCBCController extends BaseController {
*/
@PostMapping("/v1/query_equip_auth")
public CommonResult<?> query_equip_auth(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("甬城泊车平台请求设备认证 param:{}", JSON.toJSONString(dto));
logger.info("{}-请求设备认证 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryEquipmentDTO queryEquipmentDTO = JSONObject.parseObject(dataStr, QueryEquipmentDTO.class);
queryEquipmentDTO.setOperatorID(dto.getOperatorID());
Map<String, String> map = ycbcService.queryEquipAuth(queryEquipmentDTO);
logger.info("甬城泊车平台请求设备认证 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求设备认证成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryEquipmentDTO queryEquipmentDTO = parseParamsDTO(dto, QueryEquipmentDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryEquipAuth(queryEquipmentDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.info("甬城泊车平台请求设备认证 error:", e);
e.printStackTrace();
logger.error("{}-请求设备认证 error:", platformName, e);
}
return CommonResult.failed("请求设备认证发生异常");
}
@@ -272,35 +262,30 @@ public class YCBCController extends BaseController {
*/
@PostMapping("/v1/query_start_charge")
public CommonResult<?> query_start_charge(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("甬城泊车平台请求启动充电 params :{}", JSON.toJSONString(dto));
logger.info("{}-请求启动充电 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
queryStartChargeDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = ycbcService.queryStartCharge(queryStartChargeDTO);
logger.info("甬城泊车平台请求启动充电 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求启动充电成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryStartChargeDTO queryStartChargeDTO = parseParamsDTO(dto, QueryStartChargeDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryStartCharge(queryStartChargeDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("甬城泊车平台请求启动充电 error", e);
logger.error("{}-请求启动充电 error:", platformName, e);
}
return CommonResult.failed("请求启动充电发生异常");
}
@@ -313,37 +298,32 @@ public class YCBCController extends BaseController {
*/
@PostMapping("/v1/query_equip_charge_status")
public CommonResult<?> query_equip_charge_status(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("甬城泊车平台查询充电状态 params :{}", JSON.toJSONString(dto));
logger.info("{}-查询充电状态 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryEquipChargeStatusDTO queryEquipChargeStatusDTO = JSONObject.parseObject(dataStr, QueryEquipChargeStatusDTO.class);
queryEquipChargeStatusDTO.setOperatorID(dto.getOperatorID());
Map<String, String> map = ycbcService.queryEquipChargeStatus(queryEquipChargeStatusDTO);
logger.info("甬城泊车平台查询充电状态 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "查询充电状态成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryEquipChargeStatusDTO queryEquipChargeStatusDTO = parseParamsDTO(dto, QueryEquipChargeStatusDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryEquipChargeStatus(queryEquipChargeStatusDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("甬城泊车平台查询充电状态 error", e);
logger.error("{}-查询充电状态 error:", platformName, e);
}
return CommonResult.failed("甬城泊车平台查询充电状态发生异常");
return CommonResult.failed("查询充电状态发生异常");
}
/**
@@ -352,23 +332,23 @@ public class YCBCController extends BaseController {
* @param orderCode
* @return
*/
@GetMapping("/pushChargeStatus/{orderCode}")
public RestApiResponse<?> pushChargeStatus(@PathVariable("orderCode") String orderCode) {
logger.info("甬城泊车平台推送充电状态 params:{}", orderCode);
RestApiResponse<?> response = null;
try {
String result = ycbcService.pushChargeStatus(orderCode);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("甬城泊车平台推送充电状态 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("甬城泊车平台推送充电状态 error", e);
response = new RestApiResponse<>(e);
}
logger.info("甬城泊车平台推送充电状态 result:{}", response);
return response;
}
// @GetMapping("/pushChargeStatus/{orderCode}")
// public RestApiResponse<?> pushChargeStatus(@PathVariable("orderCode") String orderCode) {
// logger.info("甬城泊车平台推送充电状态 params:{}", orderCode);
// RestApiResponse<?> response = null;
// try {
// String result = ycbcService.pushChargeStatus(orderCode);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("甬城泊车平台推送充电状态 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("甬城泊车平台推送充电状态 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("甬城泊车平台推送充电状态 result:{}", response);
// return response;
// }
/**
* 请求停止充电
@@ -378,37 +358,32 @@ public class YCBCController extends BaseController {
*/
@PostMapping("/v1/query_stop_charge")
public CommonResult<?> query_stop_charge(HttpServletRequest request, @RequestBody CommonParamsDTO dto) {
logger.info("甬城泊车平台请求停止充电 params :{}", JSON.toJSONString(dto));
logger.info("{}-请求停止充电 params:{}", platformName, JSON.toJSONString(dto));
try {
// 校验令牌
String token = request.getHeader("Authorization");
if (!JWTUtils.checkThirdPartyToken(token)) {
if (!verifyToken(request.getHeader("Authorization"))) {
// 校验失败
return CommonResult.failed("令牌校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.TOKEN_ERROR);
}
dto.setPlatformType(platformType);
// 校验签名
Map<String, String> resultMap = lianLianService.checkoutSign(dto);
if (resultMap == null) {
if (!verifySignature(dto)) {
// 签名错误
return CommonResult.failed("签名校验错误");
return CommonResult.failed(ThirdPartyReturnCodeEnum.SIGN_ERROR);
}
String operatorSecret = resultMap.get("OperatorSecret");
String dataString = resultMap.get("Data");
String dataSecret = resultMap.get("DataSecret");
String dataSecretIV = resultMap.get("DataSecretIV");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(dataString), dataSecret.getBytes(), dataSecretIV.getBytes());
String dataStr = new String(plainText, StandardCharsets.UTF_8);
// 转换成相应对象
QueryStartChargeDTO queryStartChargeDTO = JSONObject.parseObject(dataStr, QueryStartChargeDTO.class);
queryStartChargeDTO.setOperatorId(dto.getOperatorID());
Map<String, String> map = ycbcService.queryStopCharge(queryStartChargeDTO);
logger.info("甬城泊车平台请求停止充电 result:{}", JSON.toJSONString(map));
return CommonResult.success(0, "请求停止充电成功！", map.get("Data"), map.get("Sig"));
// 解析入参
QueryStartChargeDTO queryStartChargeDTO = parseParamsDTO(dto, QueryStartChargeDTO.class);
// 执行逻辑
Map<String, String> map = platformLogic.queryStopCharge(queryStartChargeDTO);
return CommonResult.success(Integer.parseInt(map.get("Ret")), map.get("Msg"), map.get("Data"), map.get("Sig"));
} catch (Exception e) {
logger.error("甬城泊车平台请求停止充电 error", e);
logger.error("{}-请求停止充电 error:", platformName, e);
}
return CommonResult.failed("甬城泊车平台请求停止充电发生异常");
return CommonResult.failed("请求停止充电发生异常");
}
/**
@@ -417,23 +392,23 @@ public class YCBCController extends BaseController {
* @param orderCode
* @return
*/
@GetMapping("/pushStopChargeResult/{orderCode}")
public RestApiResponse<?> pushStopChargeResult(@PathVariable("orderCode") String orderCode) {
logger.info("甬城泊车平台推送停止充电结果 params:{}", orderCode);
RestApiResponse<?> response = null;
try {
String result = ycbcService.pushStopChargeResult(orderCode);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("甬城泊车平台推送停止充电结果 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("甬城泊车平台推送停止充电结果 error", e);
response = new RestApiResponse<>(e);
}
logger.info("甬城泊车平台推送停止充电结果 result:{}", response);
return response;
}
// @GetMapping("/pushStopChargeResult/{orderCode}")
// public RestApiResponse<?> pushStopChargeResult(@PathVariable("orderCode") String orderCode) {
// logger.info("甬城泊车平台推送停止充电结果 params:{}", orderCode);
// RestApiResponse<?> response = null;
// try {
// String result = ycbcService.pushStopChargeResult(orderCode);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("甬城泊车平台推送停止充电结果 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("甬城泊车平台推送停止充电结果 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("甬城泊车平台推送停止充电结果 result:{}", response);
// return response;
// }
/**
* 甬城泊车推送充电订单信息
@@ -441,23 +416,23 @@ public class YCBCController extends BaseController {
* @param orderCode
* @return
*/
@GetMapping("/pushChargeOrderInfo/{orderCode}")
public RestApiResponse<?> pushChargeOrderInfo(@PathVariable("orderCode") String orderCode) {
logger.info("甬城泊车平台推送充电订单信息 params:{}", orderCode);
RestApiResponse<?> response = null;
try {
String result = ycbcService.pushChargeOrderInfo(orderCode);
response = new RestApiResponse<>(result);
}catch (BusinessException e) {
logger.error("甬城泊车平台推送充电订单信息 error",e);
response = new RestApiResponse<>(e.getCode(), e.getMessage());
}catch (Exception e) {
logger.error("甬城泊车平台推送充电订单信息 error", e);
response = new RestApiResponse<>(e);
}
logger.info("甬城泊车平台推送充电订单信息 result:{}", response);
return response;
}
// @GetMapping("/pushChargeOrderInfo/{orderCode}")
// public RestApiResponse<?> pushChargeOrderInfo(@PathVariable("orderCode") String orderCode) {
// logger.info("甬城泊车平台推送充电订单信息 params:{}", orderCode);
// RestApiResponse<?> response = null;
// try {
// String result = ycbcService.pushChargeOrderInfo(orderCode);
// response = new RestApiResponse<>(result);
// }catch (BusinessException e) {
// logger.error("甬城泊车平台推送充电订单信息 error",e);
// response = new RestApiResponse<>(e.getCode(), e.getMessage());
// }catch (Exception e) {
// logger.error("甬城泊车平台推送充电订单信息 error", e);
// response = new RestApiResponse<>(e);
// }
// logger.info("甬城泊车平台推送充电订单信息 result:{}", response);
// return response;
// }
}

2
jsowell-admin/src/test/java/SpringBootTestController.java
View File

@@ -3104,7 +3104,7 @@ public class SpringBootTestController {
CommonParamsDTO dto = JSONObject.parseObject(tokenRequest, CommonParamsDTO.class);
lianLianService.generateToken(dto);
// lianLianService.generateToken(dto);
}
@Test