From 96b93ccecedabe77676c57f8c41842a1dda21180 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期一, 20 三月 2023 15:33:08 +0800
Subject: [PATCH] optimize charge port
---
service-common/src/main/java/com/java110/common/charge/ChargeCoreImpl.java | 31 ++++++++++++++++++++++++++-----
1 files changed, 26 insertions(+), 5 deletions(-)
diff --git a/service-common/src/main/java/com/java110/common/charge/ChargeCoreImpl.java b/service-common/src/main/java/com/java110/common/charge/ChargeCoreImpl.java
index d75e09b..88b95da 100644
--- a/service-common/src/main/java/com/java110/common/charge/ChargeCoreImpl.java
+++ b/service-common/src/main/java/com/java110/common/charge/ChargeCoreImpl.java
@@ -294,11 +294,32 @@
}
@Override
- public ResponseEntity<String> heartbeat(NotifyChargeOrderDto notifyChargeOrderDto) {
- return new ResponseEntity<>("{\n" +
- "\"code\" : 200,\n" +
- "\"msg\" : \"success\"\n" +
- "}", HttpStatus.OK);
+ public ResultVo workHeartbeat(NotifyChargeOrderDto notifyChargeOrderDto) {
+
+ ChargeMachineDto chargeMachineDto = new ChargeMachineDto();
+ chargeMachineDto.setMachineCode(notifyChargeOrderDto.getMachineCode());
+ List<ChargeMachineDto> chargeMachineDtos = chargeMachineV1InnerServiceSMOImpl.queryChargeMachines(chargeMachineDto);
+
+ if (chargeMachineDtos == null || chargeMachineDtos.size() < 1) {
+ return new ResultVo(ResultVo.CODE_OK, "鎴愬姛");
+ }
+
+
+ ChargeMachineFactoryDto chargeMachineFactoryDto = new ChargeMachineFactoryDto();
+ chargeMachineFactoryDto.setFactoryId(chargeMachineDtos.get(0).getImplBean());
+ List<ChargeMachineFactoryDto> chargeMachineFactoryDtos = chargeMachineFactoryV1InnerServiceSMOImpl.queryChargeMachineFactorys(chargeMachineFactoryDto);
+
+ Assert.listOnlyOne(chargeMachineFactoryDtos, "鍏呯數妗╁巶瀹朵笉瀛樺湪");
+
+ IChargeFactoryAdapt chargeFactoryAdapt = ApplicationContextFactory.getBean(chargeMachineFactoryDtos.get(0).getBeanImpl(), IChargeFactoryAdapt.class);
+ if (chargeFactoryAdapt == null) {
+ throw new CmdException("鍘傚鎺ュ彛鏈疄鐜�");
+ }
+
+ chargeFactoryAdapt.workHeartbeat(chargeMachineDtos.get(0),notifyChargeOrderDto.getBodyParam());
+
+ return new ResultVo(ResultVo.CODE_OK, "鎴愬姛");
+
}
@Override
--
Gitblit v1.8.0