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

更新VIN码启动充电

Browse Source
This commit is contained in:
panshuling321 2022-09-20 11:28:03 +08:00
parent 4f6dccda05
commit c58dceea4b
1 changed files with 59 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

71
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/PileStartChargingDataLogic.java
View File

@ -3,6 +3,7 @@ package com.xhpc.pp.logic;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.xhpc.common.api.CardService; import com.xhpc.common.api.CardService;
import com.xhpc.common.api.PileOrderService; import com.xhpc.common.api.PileOrderService;
import com.xhpc.common.core.constant.Constants;
import com.xhpc.common.core.domain.R; import com.xhpc.common.core.domain.R;
import com.xhpc.common.data.up.PileStartChargingData; import com.xhpc.common.data.up.PileStartChargingData;
import com.xhpc.common.domain.IccardInfo; import com.xhpc.common.domain.IccardInfo;
@ -90,7 +91,8 @@ public class PileStartChargingDataLogic implements ServiceLogic {
rateModelId = ((Long) REDIS.getCacheMapValue("pile:".concat(connectorId.substring(0, 14)), rateModelId = ((Long) REDIS.getCacheMapValue("pile:".concat(connectorId.substring(0, 14)),
"rateModelId")).intValue(); "rateModelId")).intValue();
R r = cardService.cardStartup(cardNo, connectorId, rateModelId.toString()); R r = cardService.cardStartup(cardNo, connectorId, rateModelId.toString());
if (r.getCode() == 200) { int code = r.getCode();
if (code == 200) {
result = ServiceResult.HEX_01; result = ServiceResult.HEX_01;
Map data = (Map) r.getData(); Map data = (Map) r.getData();
orderNo = (String) data.get("serialNumber"); orderNo = (String) data.get("serialNumber");
@ -116,12 +118,15 @@ public class PileStartChargingDataLogic implements ServiceLogic {
REDIS.setCacheMapValue("gun:".concat(connectorId), "ac.on", false); REDIS.setCacheMapValue("gun:".concat(connectorId), "ac.on", false);
resultStr = "00"; resultStr = "00";
} else { } else {
String internalError = r.getMsg(); resultStr = "1C";
if (internalError.startsWith("0") || internalError.startsWith("1")) { if(code < 600){
resultStr = internalError; String errorMsg = r.getMsg();
if ( errorMsg != null && (errorMsg.startsWith("0") || errorMsg.startsWith("1")) ) {
resultStr = errorMsg;
}
log.error("pile start charging internalError: {}", resultStr);
} else { } else {
resultStr = "1C"; resultStr = getFailReasonByCode(code);
log.error("pile start charging internalError: {}", internalError);
} }
} }
cardNo = StringUtils.leftPad(iccardInfo.getCardno(), 16, "0"); cardNo = StringUtils.leftPad(iccardInfo.getCardno(), 16, "0");
@ -137,7 +142,8 @@ public class PileStartChargingDataLogic implements ServiceLogic {
String vinCode = asciiToString(pileStartChargingData.getVin()); String vinCode = asciiToString(pileStartChargingData.getVin());
R r = pileOrderService.pileVin(connectorId, vinCode); R r = pileOrderService.pileVin(connectorId, vinCode);
if (r.getCode() == 200) { int code = r.getCode();
if (code == 200) {
if(r.getData() == null){ if(r.getData() == null){
return new ServiceResult(ServiceResult.FAIL); return new ServiceResult(ServiceResult.FAIL);
} }
@ -171,12 +177,15 @@ public class PileStartChargingDataLogic implements ServiceLogic {
REDIS.setCacheMapValue("gun:".concat(connectorId), "ac.on", false); REDIS.setCacheMapValue("gun:".concat(connectorId), "ac.on", false);
resultStr = "00"; resultStr = "00";
} else { } else {
String internalError = r.getMsg(); resultStr = Constants.INTERNAL_ERROR;
if (internalError.startsWith("0") || internalError.startsWith("1")) { if(code < 600){
resultStr = internalError; String errorMsg = r.getMsg();
if ( errorMsg != null && (errorMsg.startsWith("0") || errorMsg.startsWith("1")) ) {
resultStr = errorMsg;
}
log.error("pile start charging internalError: {}", errorMsg);
} else { } else {
resultStr = "1C"; resultStr = getFailReasonByCode(code);
log.error("pile start charging internalError: {}", internalError);
} }
} }
} }
@ -184,6 +193,19 @@ public class PileStartChargingDataLogic implements ServiceLogic {
String hex = String hex =
"682A".concat(seqHex(skey)).concat("0032").concat(orderNo).concat(connectorId).concat(cardNo).concat(balance).concat(result).concat(resultStr); "682A".concat(seqHex(skey)).concat("0032").concat(orderNo).concat(connectorId).concat(cardNo).concat(balance).concat(result).concat(resultStr);
hex = hex.concat(CRCCalculator.calcCrc(hex)); hex = hex.concat(CRCCalculator.calcCrc(hex));
Integer startFlag = result.equals(ServiceResult.HEX_01) ? 2: 4;
String pushOrderKey = "pushOrder:".concat(orderNo);
Map<String, Object> pushOrder = REDIS.getCacheMap(pushOrderKey);
if (pushOrder != null) {
REDIS.setCacheMapValue(pushOrderKey, "startChargeSeqStat", startFlag);
} else {
Map map = new HashMap<>();
map.put("startChargeSeqStat", startFlag);
REDIS.setCacheMap(pushOrderKey, map);
}
String remark = "充电桩发起充电"; String remark = "充电桩发起充电";
XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage(); XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
deviceMessage.setType(StationDeviceEnum.PILE.getCode()); deviceMessage.setType(StationDeviceEnum.PILE.getCode());
@ -195,6 +217,31 @@ public class PileStartChargingDataLogic implements ServiceLogic {
return new ServiceResult(HexUtils.toBytes(hex), result); return new ServiceResult(HexUtils.toBytes(hex), result);
} }
private static String getFailReasonByCode(int code){
String failReason = "";
switch (code){
case 1888: failReason = Constants.EMPTY_VIN; break;
case 1880: failReason = Constants.INVALID_VIN;break;
case 1881: failReason = Constants.UNEXIST_VIN;break;
case 1104: failReason = Constants.UNUSE_TERMINAL;break;
case 1103: failReason = Constants.EXCEPTION_ORDER;break;
case 1100: failReason = Constants.INSUFFICIENT_ACCOUNT; break;
case 1101: failReason = Constants.REFUND_ORDER; break;
case 1102: failReason = Constants.CHARGE_ORDER; break;
case 1105: failReason = Constants.UNREGISTERED_TERMINAL; break;
case 1106:
case 1008: failReason = Constants.UNKNOWN_GUN; break;
case 1107: failReason = Constants.OFFLINE_TERMINAL; break;
case 1109: failReason = Constants.INSERT_THE_GUN; break;
case 1111: failReason = Constants.FAULT_TERMINAL; break;
case 1112: failReason = Constants.CHARGE_TERMINAL; break;
default: failReason = Constants.INTERNAL_ERROR; break;
}
return failReason;
}
public static String asciiToString(String text) { public static String asciiToString(String text) {
StringBuilder builder = new StringBuilder(); StringBuilder builder = new StringBuilder();