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

update 联联平台推送接口设置缓存

Browse Source
This commit is contained in:
Lemon
2025-04-03 09:38:40 +08:00
parent fffe2a47bc
commit 1fd45e6794
2 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
jsowell-common/src/main/java/com/jsowell/common/constant/CacheConstants.java
View File

@@ -320,6 +320,11 @@ public class CacheConstants {
*/ */
public static final String HUA_WEI_ORDER_INFO_BY_ORDER_CODE = "HUA_WEI_ORDER_INFO_BY_ORDER_CODE:"; public static final String HUA_WEI_ORDER_INFO_BY_ORDER_CODE = "HUA_WEI_ORDER_INFO_BY_ORDER_CODE:";
/**
* 联联平台推送枪口充电状态缓存key
*/
public static final String LIANLIAN_NOTIFICATION_CONNECTOR_CHARGE_STATUS = "LIANLIAN_NOTIFICATION_CONNECTOR_CHARGE_STATUS_";
/** /**
* 桩硬件故障 根据枪口号查询故障原因 * 桩硬件故障 根据枪口号查询故障原因
*/ */

8
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/LianLianPlatformServiceImpl.java vendored
View File

@@ -677,6 +677,12 @@ public class LianLianPlatformServiceImpl implements ThirdPartyPlatformService {
*/ */
@Override @Override
public String notificationConnectorChargeStatus(String orderCode) { public String notificationConnectorChargeStatus(String orderCode) {
// 设置2分钟缓存，2分钟只推送一次
String redisKey = CacheConstants.LIANLIAN_NOTIFICATION_CONNECTOR_CHARGE_STATUS + orderCode;
Object cacheObject = redisCache.getCacheObject(redisKey);
if (cacheObject != null) {
return "Success";
}
// 通过订单号查询信息 // 通过订单号查询信息
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByOrderCode(orderCode); OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByOrderCode(orderCode);
// 根据枪口号查询充电实时状态 // 根据枪口号查询充电实时状态
@@ -720,6 +726,8 @@ public class LianLianPlatformServiceImpl implements ThirdPartyPlatformService {
String jsonString = JSON.toJSONString(json); String jsonString = JSON.toJSONString(json);
// 发送请求 // 发送请求
String result = HttpRequestUtil.sendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret); String result = HttpRequestUtil.sendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret);
// 将信息存入缓存，时间设置2分钟
redisCache.setCacheObject(redisKey, result, 2, TimeUnit.MINUTES);
return result; return result;
} }