|
|
@@ -95,7 +95,7 @@ public class EnNotifyServiceImpl implements EnNotifyService {
|
|
|
@DS("db-admin")
|
|
|
public String handleNotificationStationStatus(JSONObject json) {
|
|
|
var data = enPlusService.signValidation(json);
|
|
|
- LOGGER.info("【EN+推送】收到充电桩设备状态变化推送:\n{} \n 解密数据:{}", json, data);
|
|
|
+ LOGGER.info("【EN+推送】收到充电桩设备状态变化推送:{},解密数据:{}", json, data);
|
|
|
// 更新数据库,存入redis,发送邮件通知
|
|
|
var connectorStatusInfo = JSONObject.parseObject(data).getJSONObject("ConnectorStatusInfo").toJavaObject(EnConnectorStatusInfo.class);
|
|
|
var connectorId = connectorStatusInfo.getConnectorId();
|
|
|
@@ -167,7 +167,7 @@ public class EnNotifyServiceImpl implements EnNotifyService {
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public String handleNotificationStartChargeResult(JSONObject json) {
|
|
|
var data = enPlusService.signValidation(json);
|
|
|
- LOGGER.info("【EN+推送】收到启动充电结果推送:\n{},解密数据:\n{}", json, data);
|
|
|
+ LOGGER.info("【EN+推送】收到启动充电结果推送:{},解密数据:{}", json, data);
|
|
|
var obj = JSONObject.parseObject(data);
|
|
|
var startChargeSeq = obj.getString("StartChargeSeq");
|
|
|
var startChargeSeqStat = obj.getIntValue("StartChargeSeqStat");
|
|
|
@@ -202,7 +202,7 @@ public class EnNotifyServiceImpl implements EnNotifyService {
|
|
|
public String handleNotificationEquipChargeStatus(JSONObject json) {
|
|
|
var dataStr = enPlusService.signValidation(json);
|
|
|
var data = JSONObject.parseObject(dataStr);
|
|
|
- LOGGER.info("【EN+推送】收到充电状态推送:\n{},解密数据:\n{}", json, data);
|
|
|
+ LOGGER.info("【EN+推送】收到充电状态推送:{},解密数据:{}", json, data);
|
|
|
var startChargeSeq = data.getString("StartChargeSeq");
|
|
|
var chargeOrder = chargeOrderService.getChargingOrderByStartChargeSeq(startChargeSeq);
|
|
|
// 更新订单信息
|
|
|
@@ -235,7 +235,7 @@ public class EnNotifyServiceImpl implements EnNotifyService {
|
|
|
public String handleNotificationStopChargeResult(JSONObject json) {
|
|
|
var dataStr = enPlusService.signValidation(json);
|
|
|
var data = JSONObject.parseObject(dataStr);
|
|
|
- LOGGER.info("【EN+推送】收到停止充电结果推送:\n{},解密数据:\n{}", json, data);
|
|
|
+ LOGGER.info("【EN+推送】收到停止充电结果推送:{},解密数据:{}", json, data);
|
|
|
var startChargeSeq = data.getString("StartChargeSeq");
|
|
|
var chargeOrder = chargeOrderService.getChargingOrderByStartChargeSeq(startChargeSeq);
|
|
|
if (data.containsKey("SuccStat") && data.getIntValue("SuccStat") == 0) {
|
|
|
@@ -262,7 +262,7 @@ public class EnNotifyServiceImpl implements EnNotifyService {
|
|
|
public String handleNotificationChargeOrderInfo(JSONObject json) {
|
|
|
var dataStr = enPlusService.signValidation(json);
|
|
|
var data = JSONObject.parseObject(dataStr);
|
|
|
- LOGGER.info("【EN+推送】收到充电订单信息推送:\n{},解密数据:\n{}", json, data);
|
|
|
+ LOGGER.info("【EN+推送】收到充电订单信息推送:{},解密数据:{}", json, data);
|
|
|
var startChargeSeq = data.getString("StartChargeSeq");
|
|
|
var chargeOrder = chargeOrderService.getChargingOrderByStartChargeSeq(startChargeSeq);
|
|
|
|