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 2022-04-06 16:48:58 +08:00
parent 6fadbb070d
commit ff2f2eee4a
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -73,7 +73,7 @@ public class OrderDataLogic implements ServiceLogic {
final R r = pileOrderService.pileEndOrder(orderNo); final R r = pileOrderService.pileEndOrder(orderNo);
if (orderNo.equals("00000000000000000000000000000000") || (r != null && r.getMsg() != null && r.getMsg().contains( if (orderNo.equals("00000000000000000000000000000000") || (r != null && r.getMsg() != null && r.getMsg().contains(
"无效订单"))) { "无效订单"))) {
log.error(">>INVALID order [{}] detected. MUST check the system.<<", orderNo); log.error(">>INVALID order [{}] detected. MUST check the system or [{}].<<", orderNo, gunkey);
} }
String resultStr = "6815".concat(req.get("seqhex").toString()).concat("0040").concat(orderNo); String resultStr = "6815".concat(req.get("seqhex").toString()).concat("0040").concat(orderNo);
if (r != null && r.getCode() == 200) { if (r != null && r.getCode() == 200) {

9
xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RemoteStartReplyDataLogic.java
View File

@ -43,7 +43,6 @@ public class RemoteStartReplyDataLogic implements ServiceLogic {
@Override @Override
public ServiceResult service(ServiceParameter sp) throws Exception { public ServiceResult service(ServiceParameter sp) throws Exception {
Map<String, Object> req = sp.getParameters(); Map<String, Object> req = sp.getParameters();
ObjectMapper objectMapper = new ObjectMapper(); ObjectMapper objectMapper = new ObjectMapper();
RemoteStartReplyData remoteStartReplyData = objectMapper.convertValue(req, RemoteStartReplyData.class); RemoteStartReplyData remoteStartReplyData = objectMapper.convertValue(req, RemoteStartReplyData.class);
@ -69,12 +68,20 @@ public class RemoteStartReplyDataLogic implements ServiceLogic {
pileOrderService.pileStartup(orderNo, 1, "启动充电成功"); pileOrderService.pileStartup(orderNo, 1, "启动充电成功");
if (pushOrder != null) { if (pushOrder != null) {
REDIS.setCacheMapValue(pushOrderKey, "startChargeSeqStat", 2); REDIS.setCacheMapValue(pushOrderKey, "startChargeSeqStat", 2);
} else {
Map map = new HashMap<>();
map.put("startChargeSeqStat", Integer.valueOf(2));
REDIS.setCacheMap(pushOrderKey, map);
} }
} else { } else {
final String remark = frs.get(remoteStartReplyData.getFailReason()); final String remark = frs.get(remoteStartReplyData.getFailReason());
pileOrderService.pileStartup(orderNo, 2, remark == null ? "未知错误" : remark); pileOrderService.pileStartup(orderNo, 2, remark == null ? "未知错误" : remark);
if (pushOrder != null) { if (pushOrder != null) {
REDIS.setCacheMapValue(pushOrderKey, "startChargeSeqStat", 4); REDIS.setCacheMapValue(pushOrderKey, "startChargeSeqStat", 4);
} else {
Map map = new HashMap<>();
map.put("startChargeSeqStat", Integer.valueOf(4));
REDIS.setCacheMap(pushOrderKey, map);
} }
} }
return new ServiceResult(false); return new ServiceResult(false);