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

CRC

Browse Source
This commit is contained in:
ZZ 2021-09-09 15:07:05 +08:00
parent e2eb7b3003
commit 38f949df23
2 changed files with 15 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -8,7 +8,6 @@ import com.xhpc.common.api.dto.ChargingStationDto;
import com.xhpc.common.core.domain.R; import com.xhpc.common.core.domain.R;
import com.xhpc.common.core.utils.HttpUtils; import com.xhpc.common.core.utils.HttpUtils;
import com.xhpc.common.data.down.StartChargingData; import com.xhpc.common.data.down.StartChargingData;
import com.xhpc.common.data.redis.CacheRateModel;
import com.xhpc.pp.logic.RateModelRequestLogic; import com.xhpc.pp.logic.RateModelRequestLogic;
import com.xhpc.pp.server.ChargingPileServer; import com.xhpc.pp.server.ChargingPileServer;
import com.xhpc.pp.utils.security.CRCCalculator; import com.xhpc.pp.utils.security.CRCCalculator;
@ -105,15 +104,9 @@ public class ChargingController {
Long stationRateModelId = cacheStation.getRateModelId(); Long stationRateModelId = cacheStation.getRateModelId();
Long pileRateModelId = (Long) cachePile.get("rateModelId"); Long pileRateModelId = (Long) cachePile.get("rateModelId");
if (!stationRateModelId.equals(pileRateModelId)) { if (!stationRateModelId.equals(pileRateModelId)) {
CacheRateModel cacheRateModel = REDIS.getCacheObject("rateModel:".concat(stationRateModelId.toString())); String resultStr = RateModelRequestLogic.translate(pileNo, stationRateModelId, "0058");
String rateModel = RateModelRequestLogic.translate(cacheRateModel);
String skey = pkey.concat(".seqhex");
String rateModelMsg = "685E".concat(seqHex(skey)).concat("0058").concat(pileNo)
.concat(String.format("%04X", stationRateModelId))
.concat(rateModel);
rateModelMsg = rateModelMsg.concat(CRCCalculator.calcCrc(rateModelMsg.substring(4)));
String response = HttpUtils.post(fmt(svcSrv).concat("/native/pile/".concat(pileNo).concat("/rateModel")), String response = HttpUtils.post(fmt(svcSrv).concat("/native/pile/".concat(pileNo).concat("/rateModel")),
rateModelMsg); resultStr);
JSONObject responseJson = (JSONObject) JSON.parse(response); JSONObject responseJson = (JSONObject) JSON.parse(response);
assert responseJson != null; assert responseJson != null;
int code = responseJson.getInteger("code"); int code = responseJson.getInteger("code");

21
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RateModelRequestLogic.java
View File

@ -34,22 +34,27 @@ public class RateModelRequestLogic implements ServiceLogic {
Map<String, Object> cachePile = REDIS.getCacheMap("pile:".concat(pileNo)); Map<String, Object> cachePile = REDIS.getCacheMap("pile:".concat(pileNo));
Long stationId = (Long) cachePile.get("stationId"); Long stationId = (Long) cachePile.get("stationId");
ChargingStationDto cacheStation = REDIS.getCacheObject("station:".concat(stationId.toString())); ChargingStationDto cacheStation = REDIS.getCacheObject("station:".concat(stationId.toString()));
Long rateModelId = cacheStation.getRateModelId(); Long stationRateModelId = cacheStation.getRateModelId();
if (rateModelId == null) { if (stationRateModelId == null) {
ObjectMapper mapper = new ObjectMapper(); ObjectMapper mapper = new ObjectMapper();
ObjectNode json = mapper.createObjectNode(); ObjectNode json = mapper.createObjectNode();
json.put("error", "场站没有设置费率"); json.put("error", "场站没有设置费率");
return new ServiceResult((byte[]) null, ServiceResult.FAIL, json); return new ServiceResult((byte[]) null, ServiceResult.FAIL, json);
} }
CacheRateModel cacheRateModel = REDIS.getCacheObject("rateModel:".concat(rateModelId.toString())); String resultStr = translate(pileNo, stationRateModelId, "000A");
return new ServiceResult(HexUtils.toBytes(resultStr), ServiceResult.OK);
}
public static String translate(String pileNo, Long stationRateModelId, String svc) {
CacheRateModel cacheRateModel = REDIS.getCacheObject("rateModel:".concat(stationRateModelId.toString()));
String rateModel = translate(cacheRateModel); String rateModel = translate(cacheRateModel);
String skey = "pile:".concat(pileNo).concat(".seqhex"); String skey = "pile:".concat(pileNo).concat(".seqhex");
String seq = seqHex(skey); String resultStr = "685E".concat(seqHex(skey)).concat(svc).concat(pileNo)
String resultStr = "685E".concat(seq).concat("000A").concat(pileNo) .concat(String.format("%04X", stationRateModelId))
.concat(String.format("%04X", rateModelId))
.concat(rateModel); .concat(rateModel);
resultStr = resultStr.concat(CRCCalculator.calcCrc(resultStr.substring(4))); resultStr = resultStr.concat(CRCCalculator.calcCrc(resultStr));
return new ServiceResult(HexUtils.toBytes(resultStr), ServiceResult.OK); return resultStr;
} }
public static String translate(CacheRateModel cacheRateModel) { public static String translate(CacheRateModel cacheRateModel) {