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

修正单侧

Browse Source
This commit is contained in:
三丙
2024-10-08 21:54:30 +08:00
parent b7a0d592c2
commit a1db728be5
8 changed files with 24 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
jcpp-protocol-bootstrap/src/test/java/sanbing/jcpp/protocol/AbstractProtocolTestBase.java
View File

@@ -1,7 +1,8 @@
package sanbing.jcpp.protocol; /**
/**
* 抖音关注：程序员三丙
* 知识星球：https://t.zsxq.com/j9b21
*/
package sanbing.jcpp.protocol;
import org.junit.jupiter.api.MethodOrderer;
import org.junit.jupiter.api.TestMethodOrder;

12
jcpp-protocol-bootstrap/src/test/java/sanbing/jcpp/protocol/adapter/DownlinkControllerTest.java → jcpp-protocol-bootstrap/src/test/java/sanbing/jcpp/protocol/adapter/DownlinkControllerIT.java
View File

@@ -13,7 +13,7 @@ import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import jakarta.annotation.Resource;
import org.junit.After;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Value;
@@ -38,7 +38,7 @@ import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
import static sanbing.jcpp.protocol.listener.tcp.configs.BinaryHandlerConfiguration.LITTLE_ENDIAN_BYTE_ORDER;
class DownlinkControllerTest extends AbstractProtocolTestBase {
class DownlinkControllerIT extends AbstractProtocolTestBase {
final String PROTOCOL_NAME = "yunkuaichongV150";
@Value("${service.protocols.yunkuaichongV150.listener.tcp.handler.configuration}")
@@ -81,7 +81,7 @@ class DownlinkControllerTest extends AbstractProtocolTestBase {
@Override
protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
log.info("接收到字节码:{}", msg);
log.info("接收到下行报文:{}", msg);
}
});
}
@@ -92,8 +92,8 @@ class DownlinkControllerTest extends AbstractProtocolTestBase {
channel = f.channel();
}
@After
public void tearDown() {
@AfterEach
void tearDown() {
if (channel != null) {
channel.close();
}
@@ -101,7 +101,7 @@ class DownlinkControllerTest extends AbstractProtocolTestBase {
}
@Test
void remoteStartCharging() throws Exception {
void remoteStartChargingTest() throws Exception {
// 先发送一段登录
channel.writeAndFlush(Unpooled.wrappedBuffer(HexUtil.decodeHex("6822001900012023121200001001011047562e393572313300898604d11722d0348606024E87"))).sync();