autumn/JChargePointProtocol
1
0
Fork 0
mirror of https://gitee.com/san-bing/JChargePointProtocol synced 2026-05-07 11:29:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

!4 修复bug:如果是单体部署，并且 （缓存是caffine或设备所在副本的ip与当前服务一致） ，才走进程内调用

Browse Source 
* fix:
* fix:
This commit is contained in:
sun
2024-12-05 09:44:19 +00:00
committed by 三丙
parent 5817cba8c6
commit 32d91b3992
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
jcpp-app/src/main/java/sanbing/jcpp/app/service/DownlinkCallService.java
View File

@@ -58,7 +58,7 @@ public abstract class DownlinkCallService {
} }
if (serviceInfoProvider.isMonolith() && if (serviceInfoProvider.isMonolith() &&
("caffeine".equalsIgnoreCase(cacheType)) || serviceInfoProvider.getServiceId().equalsIgnoreCase(pileSession.getNodeId())) { ("caffeine".equalsIgnoreCase(cacheType) || serviceInfoProvider.getServiceId().equalsIgnoreCase(pileSession.getNodeId()))) {
downlinkController.onDownlink(downlinkMessageBuilder.build()) downlinkController.onDownlink(downlinkMessageBuilder.build())
.setResultHandler(result -> log.debug("下行消息发送完成")); .setResultHandler(result -> log.debug("下行消息发送完成"));