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

新增 推送中电联对应的接口信息

Browse Source
This commit is contained in:
Lemon
2023-09-14 13:44:20 +08:00
parent 9dd3835ad5
commit b0423041d1
1 changed files with 24 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
jsowell-netty/src/main/java/com/jsowell/netty/handler/UploadRealTimeMonitorHandler.java
View File

@@ -19,6 +19,7 @@ import com.jsowell.pile.domain.ThirdPartyStationRelation;
import com.jsowell.pile.service.*; import com.jsowell.pile.service.*;
import com.jsowell.pile.vo.base.ThirdPartyStationRelationVO; import com.jsowell.pile.vo.base.ThirdPartyStationRelationVO;
import com.jsowell.thirdparty.lianlian.service.LianLianService; import com.jsowell.thirdparty.lianlian.service.LianLianService;
import com.jsowell.thirdparty.zhongdianlian.service.ZDLService;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@@ -65,6 +66,9 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler {
@Autowired @Autowired
private RedisCache redisCache; private RedisCache redisCache;
@Autowired
private ZDLService zdlService;
@Override @Override
public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, Channel channel) { public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, Channel channel) {
log.info("[===获取桩上传的实时监测数据===] param:{}, channel:{}", JSONObject.toJSONString(ykcDataProtocol), channel.toString()); log.info("[===获取桩上传的实时监测数据===] param:{}, channel:{}", JSONObject.toJSONString(ykcDataProtocol), channel.toString());
@@ -292,7 +296,7 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler {
} }
try { try {
// 推送联联平台 // 推送第三方平台
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode); OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
if (orderInfo == null) { if (orderInfo == null) {
return null; return null;
@@ -302,17 +306,18 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler {
if (StringUtils.equals(connectorStatus, pileStatus)) { if (StringUtils.equals(connectorStatus, pileStatus)) {
return null; return null;
} }
// 状态不一样，传给联联 // 状态不一样，传给第三方平台
// 查询该站点是否推送联联平台 // 查询该站点是否推送第三方平台
ThirdPartyStationRelation relation = new ThirdPartyStationRelation(); ThirdPartyStationRelation relation = new ThirdPartyStationRelation();
if (StringUtils.isBlank(orderInfo.getStationId())) { if (StringUtils.isBlank(orderInfo.getStationId())) {
return null; return null;
} }
relation.setStationId(Long.parseLong(orderInfo.getStationId())); relation.setStationId(Long.parseLong(orderInfo.getStationId()));
ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(relation); ThirdPartyStationRelationVO relationInfo = thirdPartyStationRelationService.selectRelationInfo(relation);
// ThirdPartySettingInfo thirdPartySettingInfo = thirdPartySettingInfoService.getInfoByStationId(pileBasicInfo.getStationId());
if (Objects.nonNull(relationInfo)) { if (Objects.nonNull(relationInfo)) {
String pileConnectorCode = pileSn + connectorCode; String pileConnectorCode = pileSn + connectorCode;
if (StringUtils.equals("1", relationInfo.getThirdPartyType())) {
// 联联
log.info("推送联联平台实时数据 params: orderBasicInfo:{}", JSON.toJSONString(orderInfo)); log.info("推送联联平台实时数据 params: orderBasicInfo:{}", JSON.toJSONString(orderInfo));
// 设备状态变化推送 notification_stationStatus // 设备状态变化推送 notification_stationStatus
lianLianService.pushConnectorStatus(pileConnectorCode, connectorStatus); lianLianService.pushConnectorStatus(pileConnectorCode, connectorStatus);
@@ -322,9 +327,15 @@ public class UploadRealTimeMonitorHandler extends AbstractHandler {
} }
// 推送充电状态 // 推送充电状态
lianLianService.pushChargeStatus(orderInfo.getOrderCode()); lianLianService.pushChargeStatus(orderInfo.getOrderCode());
}else if (StringUtils.equals("2", relationInfo.getThirdPartyType())) {
// 中电联
log.info("推送中电联平台实时数据 params: orderBasicInfo:{}", JSON.toJSONString(orderInfo));
zdlService.notificationStationStatus(pileConnectorCode, connectorStatus);
}
} }
} catch (Exception e) { } catch (Exception e) {
log.error("推送联联平台 实时数据 异常", e); log.error("推送第三方平台 实时数据 异常", e);
} }
return null; return null;