autumn/JChargePointProtocol
1
0
Fork 0
mirror of https://gitee.com/san-bing/JChargePointProtocol synced 2026-05-03 17:39:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改BMS中止信息命名规范

Browse Source 
BMS通信报文国标：http://c.gb688.cn/bzgk/gb/showGb?type=online&hcno=6ECF725CD2BCCA2819082279F6B2E243
This commit is contained in:
三丙
2025-08-05 15:43:57 +08:00
parent ccd5d3d943
commit b225cadde9
5 changed files with 12 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -97,6 +97,6 @@ public interface PileProtocolService {
/**
* 充电阶段BMS中止
*/
void bmsAbortDuringCharging(UplinkQueueMessage uplinkQueueMessage, Callback callback);
void onBmsAbort(UplinkQueueMessage uplinkQueueMessage, Callback callback);
}

4
jcpp-app/src/main/java/sanbing/jcpp/app/service/impl/DefaultPileProtocolService.java
View File

@@ -6,8 +6,6 @@
*/
package sanbing.jcpp.app.service.impl;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
@@ -322,7 +320,7 @@ public class DefaultPileProtocolService implements PileProtocolService {
log.info("充电桩与 BMS 充电错误上报 {}", uplinkQueueMessage);
}
public void bmsAbortDuringCharging(UplinkQueueMessage uplinkQueueMessage, Callback callback) {
public void onBmsAbort(UplinkQueueMessage uplinkQueueMessage, Callback callback) {
log.info("接收到充电阶段BMS中止报文 {}", uplinkQueueMessage);
// TODO 处理相关业务逻辑
callback.onSuccess();

4
jcpp-app/src/main/java/sanbing/jcpp/app/service/queue/consumer/ProtocolUplinkConsumerService.java
View File

@@ -204,9 +204,9 @@ public class ProtocolUplinkConsumerService extends AbstractConsumerService imple
pileProtocolService.onBmsCharingInfo(uplinkQueueMsg, callback);
} else if (uplinkQueueMsg.hasBmsAbortDuringChargingRequest()) {
} else if (uplinkQueueMsg.hasBmsAbortProto()) {
pileProtocolService.bmsAbortDuringCharging(uplinkQueueMsg, callback);
pileProtocolService.onBmsAbort(uplinkQueueMsg, callback);
} else {

4
jcpp-infrastructure-proto/src/main/proto/protocol.proto
View File

@@ -69,7 +69,7 @@ message UplinkQueueMessage {
BmsChargingErrorProto bmsChargingErrorProto = 31;
BmsParamConfigReport bmsParamConfigReport = 33;
BmsChargingInfoProto bmsChargingInfoProto = 34;
BmsAbortDuringChargingRequest bmsAbortDuringChargingRequest = 35;
BmsAbortProto bmsAbortProto = 35;
}
message DownlinkRequestMessage {
@@ -327,7 +327,7 @@ message BmsChargingInfoProto {
optional string additionalInfo = 4;
}
message BmsAbortDuringChargingRequest {
message BmsAbortProto {
string pileCode = 4;
string gunCode = 5;
string tradeNo = 6;

13
jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/v150/cmd/YunKuaiChongV150BmsAbortDuringChargingULCmd.java → jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/v150/cmd/YunKuaiChongV150BmsAbortULCmd.java
View File

@@ -10,10 +10,11 @@ import com.fasterxml.jackson.databind.node.ObjectNode;
import com.google.common.base.Joiner;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import sanbing.jcpp.infrastructure.util.codec.BCDUtil;
import sanbing.jcpp.infrastructure.util.jackson.JacksonUtil;
import sanbing.jcpp.proto.gen.ProtocolProto.BmsAbortDuringChargingRequest;
import sanbing.jcpp.proto.gen.ProtocolProto.BmsAbortProto;
import sanbing.jcpp.proto.gen.ProtocolProto.UplinkQueueMessage;
import sanbing.jcpp.protocol.ProtocolContext;
import sanbing.jcpp.protocol.listener.tcp.TcpSession;
@@ -29,7 +30,7 @@ import java.util.List;
*/
@Slf4j
@YunKuaiChongCmd(0x1D)
public class YunKuaiChongV150BmsAbortDuringChargingULCmd extends YunKuaiChongUplinkCmdExe {
public class YunKuaiChongV150BmsAbortULCmd extends YunKuaiChongUplinkCmdExe {
@Override
public void execute(TcpSession tcpSession, YunKuaiChongUplinkMessage yunKuaiChongUplinkMessage, ProtocolContext ctx) {
@@ -66,7 +67,7 @@ public class YunKuaiChongV150BmsAbortDuringChargingULCmd extends YunKuaiChongUpl
byte errorReasonByte = byteBuf.readByte();
additionalInfo.put("BMS中止充电错误原因", parseErrorReasons(errorReasonByte));
BmsAbortDuringChargingRequest request = BmsAbortDuringChargingRequest.newBuilder()
BmsAbortProto proto = BmsAbortProto.newBuilder()
.setPileCode(pileCode)
.setGunCode(gunCode)
.setTradeNo(tradeNo)
@@ -75,7 +76,7 @@ public class YunKuaiChongV150BmsAbortDuringChargingULCmd extends YunKuaiChongUpl
// 转发到后端
UplinkQueueMessage uplinkQueueMessage = uplinkMessageBuilder(pileCode, tcpSession, yunKuaiChongUplinkMessage)
.setBmsAbortDuringChargingRequest(request)
.setBmsAbortProto(proto)
.build();
tcpSession.getForwarder().sendMessage(uplinkQueueMessage);
@@ -181,6 +182,7 @@ public class YunKuaiChongV150BmsAbortDuringChargingULCmd extends YunKuaiChongUpl
/**
* BMS中止充电错误原因枚举
*/
@Getter
public enum ErrorReasonsEnum {
CURRENT_OVERFLOW("电流过大"),
VOLTAGE_ABNORMAL("电压异常");
@@ -191,9 +193,6 @@ public class YunKuaiChongV150BmsAbortDuringChargingULCmd extends YunKuaiChongUpl
this.description = description;
}
public String getDescription() {
return description;
}
}
/**