autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-05-14 06:50:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

update 电单车

Browse Source
This commit is contained in:
Guoqs
2024-09-14 14:55:19 +08:00
parent 95a49969b4
commit d2e6a09ab7
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/EBikeSendCommandServiceImpl.java
View File

@@ -76,7 +76,8 @@ public class EBikeSendCommandServiceImpl implements EBikeSendCommandService {
data.setFullChargePower(0); data.setFullChargePower(0);
data.setMaxFullChargePowerCheckTime(0); data.setMaxFullChargePowerCheckTime(0);
message.setData(data); message.setData(data);
this.send(message); byte[] send = this.send(message);
log.info("电单车发送启动充电指令response:{}", BytesUtil.binary(send, 16));
} }
/** /**
@@ -131,10 +132,10 @@ public class EBikeSendCommandServiceImpl implements EBikeSendCommandService {
* 公共方法, 发送指令 * 公共方法, 发送指令
* @param msg * @param msg
*/ */
private void send(AbsEBikeMessage msg) throws Exception { private byte[] send(AbsEBikeMessage msg) throws Exception {
this.send(msg, 3, TimeUnit.SECONDS); return this.send(msg, 3, TimeUnit.SECONDS);
} }
private void send(AbsEBikeMessage msg, long timeout, TimeUnit unit) throws Exception { private byte[] send(AbsEBikeMessage msg, long timeout, TimeUnit unit) throws Exception {
String pileSn = msg.getPhysicalId() + ""; String pileSn = msg.getPhysicalId() + "";
byte[] messageBytes = msg.getMessageBytes(); byte[] messageBytes = msg.getMessageBytes();
// PileChannelEntity.output(); // PileChannelEntity.output();
@@ -181,6 +182,7 @@ public class EBikeSendCommandServiceImpl implements EBikeSendCommandService {
} }
// 移除容器 // 移除容器
RpcUtil.getSyncPromiseMap().remove(msgId); RpcUtil.getSyncPromiseMap().remove(msgId);
return rpcResponse;
} }
} }