yuyang/XH-Power-Cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

丢弃空闲的实时数据

Browse Source
This commit is contained in:
ZZ 2021-09-30 11:05:29 +08:00
parent ca414bf210
commit cfce6e7dba
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/controller/ChargingController.java
View File

@ -230,12 +230,16 @@ public class ChargingController {
return R.fail("端口不在空闲或正常状态,稍后再试");
}
if (CacheDataUtils.hori(gunkey)) return R.fail("请检查枪号是否正确,稍后再试");
String orderkey = "order:".concat(startChargingData.getOrderNo());
// String oldOrderKey = (String) cacheGun.get("orderkey");
// if (oldOrderKey!=null && !oldOrderKey.equals(orderkey)) {
// return R.fail("端口正在充电");
// } //todo delete oldOrderKey val?
String skey = gunkey.concat(".seqhex");
String seq = seqHex(skey);
byte[] msg = translateStart(startChargingData, seq);
handler.sendClientBinary(msg);
Integer balance = startChargingData.getBalance();
String orderkey = "order:".concat(startChargingData.getOrderNo());
Map<String, Object> cacheOrder = REDIS.getCacheMap(orderkey);
String pkey = "pile:".concat(pileNo);
Map<String, Object> cachePile = REDIS.getCacheMap(pkey);

2
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RealtimeDataLogic.java
View File

@ -99,7 +99,7 @@ public class RealtimeDataLogic implements ServiceLogic {
REDIS.setCacheMap(stationTermStatusKey, cacheTerminalStatusMap);
Map<String, Object> cacheOrder = REDIS.getCacheMap(orderkey);
List<CacheRealtimeData> realtimeDataList = (List<CacheRealtimeData>) cacheOrder.get("realtimeDataList");
if (!orderNo.equals("00000000000000000000000000000000")) {
if (!orderNo.equals("00000000000000000000000000000000") && statusInt != 2) {
if (realtimeDataList == null) {
realtimeDataList = new ArrayList<>();
}