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-10-20 14:10:50 +08:00
parent 97e4d7c506
commit 4155b52a7f
1 changed files with 23 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RateModelValidateLogic.java
View File

@ -13,6 +13,7 @@ import org.springframework.stereotype.Component;
import java.util.Map; import java.util.Map;
import static cn.hutool.core.util.NumberUtil.isInteger;
import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS; import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS;
import static com.xhpc.common.data.redis.StaticBeanUtil.seqHex; import static com.xhpc.common.data.redis.StaticBeanUtil.seqHex;
@ -29,18 +30,33 @@ public class RateModelValidateLogic implements ServiceLogic {
String pileNo = (String) req.get("pileNo"); String pileNo = (String) req.get("pileNo");
String rateModelIdStr = (String) req.get("rateModelId"); String rateModelIdStr = (String) req.get("rateModelId");
Map<String, Object> cachePile = REDIS.getCacheMap("pile:".concat(pileNo)); Map<String, Object> cachePile = REDIS.getCacheMap("pile:".concat(pileNo));
Integer gunNum = (Integer) cachePile.get("gunNum");
boolean charging = false;
for (int gunN = 1; gunN <= gunNum; gunN++) {
String gunId = String.format("%02d", gunN);
String gunkey = "gun:".concat(pileNo.concat(gunId));
Map<String, Object> cacheGun = REDIS.getCacheMap(gunkey);
Object status = cacheGun.get("status");
if (isInteger(status.toString())) {
charging = true;
}
}
String resultCode = ServiceResult.OK; String resultCode = ServiceResult.OK;
String hexCode = ServiceResult.HEX_00; String hexCode = ServiceResult.HEX_00;
ChargingStationDto cacheStation = REDIS.getCacheObject("station:".concat(cachePile.get("stationId").toString())); Long rateModelId = Long.valueOf(Integer.parseInt(rateModelIdStr, 16));
Long csRateModelId = cacheStation.getRateModelId(); Long csRateModelId = rateModelId;
int rateModelId = Integer.parseInt(rateModelIdStr, 16); if (!charging) {
if (csRateModelId.intValue() != rateModelId) { ChargingStationDto cacheStation = REDIS.getCacheObject("station:".concat(cachePile.get("stationId").toString()));
hexCode = ServiceResult.HEX_01; csRateModelId = cacheStation.getRateModelId();
resultCode = ServiceResult.FAIL; if (csRateModelId.intValue() != rateModelId) {
hexCode = ServiceResult.HEX_01;
resultCode = ServiceResult.FAIL;
}
} }
String skey = "pile:".concat(pileNo).concat(".seqhex"); String skey = "pile:".concat(pileNo).concat(".seqhex");
String seq = seqHex(skey); String seq = seqHex(skey);
String resultStr = "680E".concat(seq).concat("0006").concat(pileNo).concat(String.format("%04X", csRateModelId)).concat(hexCode); String resultStr =
"680E".concat(seq).concat("0006").concat(pileNo).concat(String.format("%04X", csRateModelId)).concat(hexCode);
resultStr = resultStr.concat(CRCCalculator.calcCrc(resultStr)); resultStr = resultStr.concat(CRCCalculator.calcCrc(resultStr));
return new ServiceResult(HexUtils.toBytes(resultStr), resultCode); return new ServiceResult(HexUtils.toBytes(resultStr), resultCode);
} }