This commit is contained in:
YAS\29473
2025-06-30 14:11:06 +08:00
parent 3867d03000
commit 14bf284e82

View File

@@ -164,49 +164,55 @@ public class NotificationService {
// 如果dto中的platformType不为空并且不等于secretInfoVO.getPlatformType()continue
continue;
}
// 根据平台类型获取Service
ThirdPartyPlatformService platformService =null;
try {
// 根据平台类型获取Service
ThirdPartyPlatformService platformService = ThirdPartyPlatformFactory.getInvokeStrategy(secretInfoVO.getPlatformType());
String type = secretInfoVO.getPlatformType();
//充电订单信息推送
//判断实现此接口没有
// 25 , 20 ,17 ,18,7,24,3,1,10,13,26,16,23,6, 21,15,2
if(type.equals("25") || type.equals("17") ||type.equals("20") || type.equals("7") ||
type.equals("24") || type.equals("3") || type.equals("1")
|| type.equals("10") || type.equals("13") || type.equals("26") || type.equals("16")
|| type.equals("23") || type.equals("6") || type.equals("21") || type.equals("15") || type.equals("2")){
platformService = ThirdPartyPlatformFactory.getInvokeStrategy(secretInfoVO.getPlatformType());
}catch (Exception e){
logger.error("获取平台服务失败", e);
}
//充电订单信息推送
try {
if(platformService != null){
platformService.notificationChargeOrderInfo(orderCode, secretInfoVO);
}
//订单信息推送
//12,7,1,10,13,11,6
if(type.equals("12") || type.equals("7") || type.equals("1") || type.equals("10") ||
type.equals("13") || type.equals("11") || type.equals("6")){
platformService.notificationChargeOrderInfo(orderCode);
}
//停止充电结果推送
//25 , 7,1,23,6,4,2
if(type.equals("25") || type.equals("7") || type.equals("1") ||
type.equals("23") || type.equals("6") || type.equals("4") || type.equals("2")){
platformService.notificationStopChargeResult(orderCode);
}
//推送充换电站用能统计信息
//18,10,13,26
if(type.equals("18") || type.equals("10") || type.equals("13") || type.equals("26")){
platformService.notificationOperationStatsInfo(stationId);
}
//推送充电账单信息
//25
if(type.equals("25")){
platformService.notificationPayOrderInfo(orderCode);
}
} catch (Exception e) {
logger.error("充电订单信息推送error", e);
}
//订单信息推送
try {
if (platformService != null) {
platformService.notificationChargeOrderInfo(orderCode);
}
}catch (Exception e){
logger.error("订单信息推送error", e);
}
//停止充电结果推送
try {
if (platformService != null) {
platformService.notificationStopChargeResult(orderCode);
}
}catch (Exception e){
logger.error("停止充电结果推送error", e);
}
//推送充换电站用能统计信息
try {
if (platformService != null) {
platformService.notificationOperationStatsInfo(stationId);
}
}catch (Exception e){
logger.error("推送充换电站用能统计信息error", e);
}
//推送充电账单信息
try {
if (platformService != null) {
platformService.notificationPayOrderInfo(orderCode);
}
}catch (Exception e){
logger.error("推送充电账单信息error", e);
}
}
}