From 26526de10d49c3422a6d6c2d55fe5a2997786ad9 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期一, 21 七月 2025 13:58:37 +0800
Subject: [PATCH] Merge branch 'dev' of http://120.76.84.145:10101/gitblit/r/java/mx_charging_pile into dev
---
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java | 365 ++++++++++++++++++++++++++++-----------------------
1 files changed, 202 insertions(+), 163 deletions(-)
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java
index 14214bf..3e4077b 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java
@@ -12,24 +12,20 @@
import com.ruoyi.integration.api.model.*;
import com.ruoyi.integration.iotda.constant.SendTagConstant;
import com.ruoyi.integration.iotda.enums.ServiceIdMenu;
+import com.ruoyi.integration.iotda.model.*;
import com.ruoyi.integration.iotda.utils.produce.IotMessageProduce;
import com.ruoyi.integration.iotda.utils.tools.CP56Time2aConverter;
import com.ruoyi.integration.iotda.utils.tools.MessageUtil;
import com.ruoyi.integration.iotda.utils.tools.StrategyUtil;
-import com.ruoyi.integration.rocket.model.*;
-import com.ruoyi.integration.rocket.produce.EnhanceProduce;
+import com.ruoyi.integration.iotda.utils.tools.ChargingMessageUtil;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.client.producer.SendResult;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.FileWriter;
import java.io.IOException;
import java.math.BigDecimal;
import java.util.*;
@@ -44,8 +40,6 @@
public class IotMessageListener {
@Autowired
- private EnhanceProduce enhanceProduce;
- @Autowired
private MessageUtil messageUtil;
@Autowired
private IotMessageProduce iotMessageProduce;
@@ -57,6 +51,9 @@
@Resource
private ChargingPileClient chargingPileClient;
+
+ @Resource
+ private ChargingMessageUtil chargingMessageUtil;
@@ -70,29 +67,36 @@
@PostMapping(value = "/message")
public AjaxResult<String> message(@RequestBody JSONObject jsonObject) throws IOException {
log.info("接收到消息中转：{}",jsonObject);
- JSONObject content = jsonObject.getJSONObject("notify_data").getJSONObject("body").getJSONObject("content");
+ JSONObject body = jsonObject.getJSONObject("notify_data").getJSONObject("body");
+ JSONObject content = null;
+ try {
+ content = body.getJSONObject("content");
+ }catch (Exception e){
+ String content1 = body.getString("content");
+ String substring = content1.substring(content1.length() - 1);
+ if(!"}".equals(substring)){
+ content1 = content1.substring(0, content1.length() - 1) + "}";
+ }
+ log.info("content1:"+content1);
+ content = JSON.parseObject(content1);
+ }
JSONObject header = jsonObject.getJSONObject("notify_data").getJSONObject("header");
String deviceId = header.getString("device_id"); // 设备id
String nodeId = header.getString("node_id"); // 设备编号
String productId = header.getString("product_id"); // 产品id
String service_id = content.getString("service_id");
log.info("服务id:{}",service_id);
- // 写入文件
-// FileWriter writer = new FileWriter("D:/sample.txt",true);
-// writer.write("接收到消息中转："+jsonObject+"\n");
-// writer.write("服务id:"+service_id+"\n");
-// writer.close();
- SendResult sendResult;
ChargingMessage chargingMessage = new ChargingMessage();
chargingMessage.setServiceId(service_id);
// 设备消息下发
String result;
switch (service_id){
case SendTagConstant.ONLINE:
+ long ONLINE = System.currentTimeMillis();
+
OnlineMessage onlineMessage = JSON.parseObject(content.toJSONString(),OnlineMessage.class);
- sendResult = enhanceProduce.onlineMessage(onlineMessage);
-// chargingMessage.setOnlineMessage(onlineMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
+ chargingMessage.setOnlineMessage(onlineMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
// 响应硬件
// 业务处理 登录认证应答
OnlineReply onlineReply = new OnlineReply();
@@ -105,16 +109,16 @@
timingSettingReplyOnline.setCharging_pile_code(onlineMessage.getCharging_pile_code());
timingSettingReplyOnline.setCurrent_time(CP56Time2aConverter.convertToCP56Time2a(new Date()));
iotMessageProduce.sendMessage(timingSettingReplyOnline.getCharging_pile_code(), ServiceIdMenu.TIMING_SETTING_REPLY.getKey(),messageUtil.timingSettingReply(timingSettingReplyOnline));
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
+
+ log.warn("ONLINE消息处理：{} 毫秒", System.currentTimeMillis() - ONLINE);
break;
case SendTagConstant.PING:
+ long PING = System.currentTimeMillis();
+
PingMessage pingMessage = JSON.parseObject(content.toJSONString(),PingMessage.class);
//存储缓存中，5分钟有效
redisTemplate.opsForValue().set("ping:" + pingMessage.getCharging_pile_code() + pingMessage.getCharging_gun_code(), pingMessage, 5, TimeUnit.MINUTES);
- sendResult = null;
-// sendResult = enhanceProduce.pingMessage(pingMessage);
-// chargingMessage.setPingMessage(pingMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
+
// 响应硬件
Pong pong = new Pong();
pong.setCharging_pile_code(pingMessage.getCharging_pile_code());
@@ -122,44 +126,47 @@
pong.setCharging_gun_status(0);
iotMessageProduce.sendMessage(pong.getCharging_pile_code(), ServiceIdMenu.PONG.getKey(), messageUtil.pong(pong));
+
+ Long time = (Long) redisTemplate.opsForHash().get("charging_gun_online", (pingMessage.getCharging_pile_code() + pingMessage.getCharging_gun_code()));
+ //小于1分钟才处理数据，防止频繁查询数据
+ if(null != time && (System.currentTimeMillis() - time) < 60000){
+ log.warn("PING消息处理：{} 毫秒", System.currentTimeMillis() - PING);
+ break;
+ }
+
+ //检查修改设备状态
UpdateChargingPileStatusVo vo1 = new UpdateChargingPileStatusVo();
vo1.setGun_code(pingMessage.getCharging_gun_code());
vo1.setPile_code(pingMessage.getCharging_pile_code());
vo1.setStatus(pingMessage.getCharging_gun_status());
chargingPileClient.updateChargingPileStatus(vo1);
- // 监管平台推送充电设备状态
- String gunCode = pingMessage.getCharging_pile_code() + pingMessage.getCharging_gun_code();
- ChargingMessage chargingMessage1 = new ChargingMessage();
- chargingMessage1.setServiceId(SendTagConstant.GUN_STATUS);
- GunStatusMessage gunStatusMessage = new GunStatusMessage();
- gunStatusMessage.setFullNumber(gunCode);
- chargingMessage1.setGunStatusMessage(gunStatusMessage);
- sendResult = enhanceProduce.gunStatusMessage(chargingMessage1);
-
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
+ log.warn("PING消息处理：{} 毫秒", System.currentTimeMillis() - PING);
break;
case SendTagConstant.END_CHARGE:
+ long END_CHARGE = System.currentTimeMillis();
+
EndChargeMessage endChargeMessage = JSON.parseObject(content.toJSONString(),EndChargeMessage.class);
- sendResult = enhanceProduce.endChargeMessage(endChargeMessage);
-// chargingMessage.setEndChargeMessage(endChargeMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setEndChargeMessage(endChargeMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("END_CHARGE消息处理：{} 毫秒", System.currentTimeMillis() - END_CHARGE);
break;
case SendTagConstant.ERROR_MESSAGE:
+ long ERROR_MESSAGE = System.currentTimeMillis();
+
ErrorMessageMessage errorMessageMessage = JSON.parseObject(content.toJSONString(),ErrorMessageMessage.class);
- sendResult = enhanceProduce.errorMessageMessage(errorMessageMessage);
-// chargingMessage.setErrorMessageMessage(errorMessageMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setErrorMessageMessage(errorMessageMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("ERROR_MESSAGE消息处理：{} 毫秒", System.currentTimeMillis() - ERROR_MESSAGE);
break;
case SendTagConstant.BILLING_MODE_VERIFY:
+ long BILLING_MODE_VERIFY = System.currentTimeMillis();
+
BillingModeVerifyMessage billingModeVerifyMessage = JSON.parseObject(content.toJSONString(),BillingModeVerifyMessage.class);
- sendResult = enhanceProduce.billingModeVerifyMessage(billingModeVerifyMessage);
-// chargingMessage.setBillingModeVerifyMessage(billingModeVerifyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
+ chargingMessage.setBillingModeVerifyMessage(billingModeVerifyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
// 响应硬件
BillingModeVerifyReply billingModeVerifyReply = new BillingModeVerifyReply();
if(billingModeVerifyMessage.getBilling_model_code().equals("0")){
@@ -183,13 +190,15 @@
}
}
iotMessageProduce.sendMessage(billingModeVerifyReply.getCharging_pile_code(), ServiceIdMenu.BILLING_MODE_VERIFY_REPLY.getKey(),messageUtil.billingModeVerifyReply(billingModeVerifyReply));
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
+
+ log.warn("ERROR_MESSAGE消息处理：{} 毫秒", System.currentTimeMillis() - BILLING_MODE_VERIFY);
break;
case SendTagConstant.ACQUISITION_BILLING_MODE:
+ long ACQUISITION_BILLING_MODE = System.currentTimeMillis();
+
AcquisitionBillingModeMessage acquisitionBillingModeMessage = JSON.parseObject(content.toJSONString(),AcquisitionBillingModeMessage.class);
- sendResult = enhanceProduce.acquisitionBillingModeMessage(acquisitionBillingModeMessage);
-// chargingMessage.setAcquisitionBillingModeMessage(acquisitionBillingModeMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
+ chargingMessage.setAcquisitionBillingModeMessage(acquisitionBillingModeMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
// 响应硬件 计费模型请求应答 1=尖阶段，2=峰阶段，3=平阶段，4=谷阶段
List<TAccountingStrategyDetail> accountingStrategyDetails = accountingStrategyDetailClient.getDetailListByCode(acquisitionBillingModeMessage.getCharging_pile_code()).getData();
Map<Integer, TAccountingStrategyDetail> strategyPrice = StrategyUtil.getStrategyPrice(accountingStrategyDetails);
@@ -203,68 +212,79 @@
acquisitionBillingModeReply.setCharging_pile_code(acquisitionBillingModeMessage.getCharging_pile_code());
acquisitionBillingModeReply.setLoss_ratio(BigDecimal.ZERO);
iotMessageProduce.sendMessage(acquisitionBillingModeReply.getCharging_pile_code(), ServiceIdMenu.ACQUISITION_BILLING_MODE_REPLY.getKey(),messageUtil.acquisitionBillingModeReply(acquisitionBillingModeReply));
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
+
+ log.warn("ACQUISITION_BILLING_MODE消息处理：{} 毫秒", System.currentTimeMillis() - ACQUISITION_BILLING_MODE);
break;
case SendTagConstant.UPLOAD_REAL_TIME_MONITORING_DATA:
+ long UPLOAD_REAL_TIME_MONITORING_DATA = System.currentTimeMillis();
+
log.info("充电实时数据上传");
UploadRealTimeMonitoringDataMessage uploadRealTimeMonitoringDataMessage = JSON.parseObject(content.toJSONString(),UploadRealTimeMonitoringDataMessage.class);
- sendResult = enhanceProduce.uploadRealTimeMonitoringDataMessage(uploadRealTimeMonitoringDataMessage);
-// chargingMessage.setUploadRealTimeMonitoringDataMessage(uploadRealTimeMonitoringDataMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setUploadRealTimeMonitoringDataMessage(uploadRealTimeMonitoringDataMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("UPLOAD_REAL_TIME_MONITORING_DATA消息处理：{} 毫秒", System.currentTimeMillis() - UPLOAD_REAL_TIME_MONITORING_DATA);
break;
case SendTagConstant.CHARGING_HANDSHAKE:
+ long CHARGING_HANDSHAKE = System.currentTimeMillis();
+
ChargingHandshakeMessage chargingHandshakeMessage = JSON.parseObject(content.toJSONString(),ChargingHandshakeMessage.class);
- sendResult = enhanceProduce.chargingHandshakeMessage(chargingHandshakeMessage);
-// chargingMessage.setChargingHandshakeMessage(chargingHandshakeMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setChargingHandshakeMessage(chargingHandshakeMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("CHARGING_HANDSHAKE消息处理：{} 毫秒", System.currentTimeMillis() - CHARGING_HANDSHAKE);
break;
case SendTagConstant.PARAMETER_SETTING:
+ long PARAMETER_SETTING = System.currentTimeMillis();
+
ParameterSettingMessage parameterSettingMessage = JSON.parseObject(content.toJSONString(),ParameterSettingMessage.class);
- sendResult = enhanceProduce.parameterSettingMessage(parameterSettingMessage);
-// chargingMessage.setParameterSettingMessage(parameterSettingMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
+ chargingMessage.setParameterSettingMessage(parameterSettingMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("PARAMETER_SETTING消息处理：{} 毫秒", System.currentTimeMillis() - PARAMETER_SETTING);
break;
case SendTagConstant.BMS_ABORT:
+ long BMS_ABORT = System.currentTimeMillis();
+
BmsAbortMessage bmsAbortMessage = JSON.parseObject(content.toJSONString(),BmsAbortMessage.class);
- sendResult = enhanceProduce.bmsAbortMessage(bmsAbortMessage);
-// chargingMessage.setBmsAbortMessage(bmsAbortMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setBmsAbortMessage(bmsAbortMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("BMS_ABORT消息处理：{} 毫秒", System.currentTimeMillis() - BMS_ABORT);
break;
case SendTagConstant.MOTOR_ABORT:
+ long MOTOR_ABORT = System.currentTimeMillis();
+
MotorAbortMessage motorAbortMessage = JSON.parseObject(content.toJSONString(),MotorAbortMessage.class);
- sendResult = enhanceProduce.motorAbortMessage(motorAbortMessage);
-// chargingMessage.setMotorAbortMessage(motorAbortMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
+ chargingMessage.setMotorAbortMessage(motorAbortMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("MOTOR_ABORT消息处理：{} 毫秒", System.currentTimeMillis() - MOTOR_ABORT);
break;
case SendTagConstant.BMS_DEMAND_AND_CHARGER_EXPORTATION:
+ long BMS_DEMAND_AND_CHARGER_EXPORTATION = System.currentTimeMillis();
+
BmsDemandAndChargerExportationMessage bmsDemandAndChargerExportationMessage = JSON.parseObject(content.toJSONString(),BmsDemandAndChargerExportationMessage.class);
- sendResult = enhanceProduce.bmsDemandAndChargerExportationMessage(bmsDemandAndChargerExportationMessage);
-// chargingMessage.setBmsDemandAndChargerExportationMessage(bmsDemandAndChargerExportationMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setBmsDemandAndChargerExportationMessage(bmsDemandAndChargerExportationMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("BMS_DEMAND_AND_CHARGER_EXPORTATION消息处理：{} 毫秒", System.currentTimeMillis() - BMS_DEMAND_AND_CHARGER_EXPORTATION);
break;
case SendTagConstant.BMS_INFORMATION:
+ long BMS_INFORMATION = System.currentTimeMillis();
+
BmsInformationMessage bmsInformationMessage = JSON.parseObject(content.toJSONString(),BmsInformationMessage.class);
- sendResult = enhanceProduce.bmsInformationMessage(bmsInformationMessage);
-// chargingMessage.setBmsInformationMessage(bmsInformationMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setBmsInformationMessage(bmsInformationMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("BMS_INFORMATION消息处理：{} 毫秒", System.currentTimeMillis() - BMS_INFORMATION);
break;
case SendTagConstant.CHARGING_PILE_STARTS_CHARGING:
+ long CHARGING_PILE_STARTS_CHARGING = System.currentTimeMillis();
+
ChargingPileStartsChargingMessage chargingPileStartsChargingMessage = JSON.parseObject(content.toJSONString(),ChargingPileStartsChargingMessage.class);
- sendResult = enhanceProduce.chargingPileStartsChargingMessage(chargingPileStartsChargingMessage);
-// chargingMessage.setChargingPileStartsChargingMessage(chargingPileStartsChargingMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
+ chargingMessage.setChargingPileStartsChargingMessage(chargingPileStartsChargingMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
// 响应硬件
PlatformConfirmationCharging platformConfirmationCharging = new PlatformConfirmationCharging();
platformConfirmationCharging.setCharging_pile_code(chargingPileStartsChargingMessage.getCharging_pile_code());
@@ -274,139 +294,156 @@
platformConfirmationCharging.setAuthentication(1);
// TODO 若是失败，给出失败原因
iotMessageProduce.sendMessage(platformConfirmationCharging.getCharging_pile_code(), ServiceIdMenu.PLATFORM_CONFIRMATION_CHARGING.getKey(),messageUtil.platformConfirmationCharging(platformConfirmationCharging));
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
+
+ log.warn("CHARGING_PILE_STARTS_CHARGING消息处理：{} 毫秒", System.currentTimeMillis() - CHARGING_PILE_STARTS_CHARGING);
break;
case SendTagConstant.PLATFORM_START_CHARGING_REPLY:
+ long PLATFORM_START_CHARGING_REPLY = System.currentTimeMillis();
+
PlatformStartChargingReplyMessage platformStartChargingReplyMessage = JSON.parseObject(content.toJSONString(),PlatformStartChargingReplyMessage.class);
- sendResult = enhanceProduce.platformStartChargingReplyMessage(platformStartChargingReplyMessage);
-// chargingMessage.setPlatformStartChargingReplyMessage(platformStartChargingReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setPlatformStartChargingReplyMessage(platformStartChargingReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("PLATFORM_START_CHARGING_REPLY消息处理：{} 毫秒", System.currentTimeMillis() - PLATFORM_START_CHARGING_REPLY);
break;
case SendTagConstant.PLATFORM_STOP_CHARGING_REPLY:
+ long PLATFORM_STOP_CHARGING_REPLY = System.currentTimeMillis();
+
PlatformStopChargingReplyMessage platformStopChargingReplyMessage = JSON.parseObject(content.toJSONString(),PlatformStopChargingReplyMessage.class);
- sendResult = enhanceProduce.platformStopChargingReplyMessage(platformStopChargingReplyMessage);
-// chargingMessage.setPlatformStopChargingReplyMessage(platformStopChargingReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setPlatformStopChargingReplyMessage(platformStopChargingReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("PLATFORM_STOP_CHARGING_REPLY消息处理：{} 毫秒", System.currentTimeMillis() - PLATFORM_STOP_CHARGING_REPLY);
break;
case SendTagConstant.TRANSACTION_RECORD:
+ long TRANSACTION_RECORD = System.currentTimeMillis();
+
TransactionRecordMessage transactionRecordMessage = JSON.parseObject(content.toJSONString(),TransactionRecordMessage.class);
transactionRecordMessage.setResult(content.toJSONString());
- sendResult = enhanceProduce.transactionRecordMessage(transactionRecordMessage);
-// chargingMessage.setTransactionRecordMessage(transactionRecordMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
+ chargingMessage.setTransactionRecordMessage(transactionRecordMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
// 响应硬件
ConfirmTransactionRecord confirmTransactionRecord = new ConfirmTransactionRecord();
confirmTransactionRecord.setTransaction_serial_number(transactionRecordMessage.getTransaction_serial_number());
confirmTransactionRecord.setConfirm_result(0);
iotMessageProduce.sendMessage(transactionRecordMessage.getCharging_pile_code(), ServiceIdMenu.CONFIRM_TRANSACTION_RECORD.getKey(),messageUtil.confirmTransactionRecord(confirmTransactionRecord));
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
+
+ log.warn("TRANSACTION_RECORD消息处理：{} 毫秒", System.currentTimeMillis() - TRANSACTION_RECORD);
break;
case SendTagConstant.UPDATE_BALANCE_REPLY:
+ long UPDATE_BALANCE_REPLY = System.currentTimeMillis();
+
UpdateBalanceReplyMessage updateBalanceReplyMessage = JSON.parseObject(content.toJSONString(),UpdateBalanceReplyMessage.class);
- sendResult = enhanceProduce.updateBalanceReplyMessage(updateBalanceReplyMessage);
-// chargingMessage.setUpdateBalanceReplyMessage(updateBalanceReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setUpdateBalanceReplyMessage(updateBalanceReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("UPDATE_BALANCE_REPLY消息处理：{} 毫秒", System.currentTimeMillis() - UPDATE_BALANCE_REPLY);
break;
case SendTagConstant.SYNCHRONIZE_OFFLINE_CARD_REPLY:
+ long SYNCHRONIZE_OFFLINE_CARD_REPLY = System.currentTimeMillis();
+
SynchronizeOfflineCardReplyMessage synchronizeOfflineCardReplyMessage = JSON.parseObject(content.toJSONString(),SynchronizeOfflineCardReplyMessage.class);
- sendResult = enhanceProduce.synchronizeOfflineCardReplyMessage(synchronizeOfflineCardReplyMessage);
-// chargingMessage.setSynchronizeOfflineCardReplyMessage(synchronizeOfflineCardReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setSynchronizeOfflineCardReplyMessage(synchronizeOfflineCardReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("SYNCHRONIZE_OFFLINE_CARD_REPLY消息处理：{} 毫秒", System.currentTimeMillis() - SYNCHRONIZE_OFFLINE_CARD_REPLY);
break;
case SendTagConstant.CLEAR_OFFLINE_CARD_REPLY:
+ long CLEAR_OFFLINE_CARD_REPLY = System.currentTimeMillis();
+
ClearOfflineCardReplyMessage clearOfflineCardReplyMessage = JSON.parseObject(content.toJSONString(),ClearOfflineCardReplyMessage.class);
- sendResult = enhanceProduce.clearOfflineCardReplyMessage(clearOfflineCardReplyMessage);
-// chargingMessage.setClearOfflineCardReplyMessage(clearOfflineCardReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setClearOfflineCardReplyMessage(clearOfflineCardReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("CLEAR_OFFLINE_CARD_REPLY消息处理：{} 毫秒", System.currentTimeMillis() - CLEAR_OFFLINE_CARD_REPLY);
break;
case SendTagConstant.WORKING_PARAMETER_SETTING_REPLY:
+ long WORKING_PARAMETER_SETTING_REPLY = System.currentTimeMillis();
+
WorkingParameterSettingReplyMessage workingParameterSettingReplyMessage = JSON.parseObject(content.toJSONString(),WorkingParameterSettingReplyMessage.class);
- sendResult = enhanceProduce.workingParameterSettingReplyMessage(workingParameterSettingReplyMessage);
-// chargingMessage.setWorkingParameterSettingReplyMessage(workingParameterSettingReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setWorkingParameterSettingReplyMessage(workingParameterSettingReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("WORKING_PARAMETER_SETTING_REPLY消息处理：{} 毫秒", System.currentTimeMillis() - WORKING_PARAMETER_SETTING_REPLY);
break;
case SendTagConstant.TIMING_SETTING:
+ long TIMING_SETTING = System.currentTimeMillis();
+
TimingSettingMessage timingSettingMessage = JSON.parseObject(content.toJSONString(),TimingSettingMessage.class);
- sendResult = enhanceProduce.timingSettingMessage(timingSettingMessage);
-// chargingMessage.setTimingSettingMessage(timingSettingMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
+ chargingMessage.setTimingSettingMessage(timingSettingMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
// 响应硬件 对时设置应答
TimingSettingReply timingSettingReply = new TimingSettingReply();
timingSettingReply.setCharging_pile_code(timingSettingMessage.getCharging_pile_code());
timingSettingReply.setCurrent_time(CP56Time2aConverter.convertToCP56Time2a(new Date()));
iotMessageProduce.sendMessage(timingSettingReply.getCharging_pile_code(), ServiceIdMenu.TIMING_SETTING_REPLY.getKey(),messageUtil.timingSettingReply(timingSettingReply));
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
+
+ log.warn("TIMING_SETTING消息处理：{} 毫秒", System.currentTimeMillis() - TIMING_SETTING);
break;
case SendTagConstant.SETUP_BILLING_MODEL_REPLY:
+ long SETUP_BILLING_MODEL_REPLY = System.currentTimeMillis();
+
SetupBillingModelReplyMessage setupBillingModelReplyMessage = JSON.parseObject(content.toJSONString(),SetupBillingModelReplyMessage.class);
- sendResult = enhanceProduce.setupBillingModelReplyMessage(setupBillingModelReplyMessage);
-// chargingMessage.setSetupBillingModelReplyMessage(setupBillingModelReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setSetupBillingModelReplyMessage(setupBillingModelReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("SETUP_BILLING_MODEL_REPLY消息处理：{} 毫秒", System.currentTimeMillis() - SETUP_BILLING_MODEL_REPLY);
break;
case SendTagConstant.GROUND_LOCK_REAL_TIME_DATA:
+ long GROUND_LOCK_REAL_TIME_DATA = System.currentTimeMillis();
+
GroundLockRealTimeDataMessage groundLockRealTimeDataMessage = JSON.parseObject(content.toJSONString(),GroundLockRealTimeDataMessage.class);
- sendResult = enhanceProduce.groundLockRealTimeDataMessage(groundLockRealTimeDataMessage);
-// chargingMessage.setGroundLockRealTimeDataMessage(groundLockRealTimeDataMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setGroundLockRealTimeDataMessage(groundLockRealTimeDataMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("GROUND_LOCK_REAL_TIME_DATA消息处理：{} 毫秒", System.currentTimeMillis() - GROUND_LOCK_REAL_TIME_DATA);
break;
case SendTagConstant.CHARGING_PILE_RETURNS_GROUND_LOCK_DATA:
+ long CHARGING_PILE_RETURNS_GROUND_LOCK_DATA = System.currentTimeMillis();
+
ChargingPileReturnsGroundLockDataMessage chargingPileReturnsGroundLockDataMessage = JSON.parseObject(content.toJSONString(),ChargingPileReturnsGroundLockDataMessage.class);
- sendResult = enhanceProduce.chargingPileReturnsGroundLockDataMessage(chargingPileReturnsGroundLockDataMessage);
-// chargingMessage.setChargingPileReturnsGroundLockDataMessage(chargingPileReturnsGroundLockDataMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setChargingPileReturnsGroundLockDataMessage(chargingPileReturnsGroundLockDataMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("CHARGING_PILE_RETURNS_GROUND_LOCK_DATA消息处理：{} 毫秒", System.currentTimeMillis() - CHARGING_PILE_RETURNS_GROUND_LOCK_DATA);
break;
case SendTagConstant.PLATFORM_RESTART_REPLY:
+ long PLATFORM_RESTART_REPLY = System.currentTimeMillis();
+
PlatformRestartReplyMessage platformRestartReplyMessage = JSON.parseObject(content.toJSONString(),PlatformRestartReplyMessage.class);
- sendResult = enhanceProduce.platformRestartReplyMessage(platformRestartReplyMessage);
-// chargingMessage.setPlatformRestartReplyMessage(platformRestartReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setPlatformRestartReplyMessage(platformRestartReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("PLATFORM_RESTART_REPLY消息处理：{} 毫秒", System.currentTimeMillis() - PLATFORM_RESTART_REPLY);
break;
case SendTagConstant.QR_CODE_DELIVERY_REPLY:
+ long QR_CODE_DELIVERY_REPLY = System.currentTimeMillis();
+
QrCodeDeliveryReplyMessage qrCodeDeliveryReplyMessage = JSON.parseObject(content.toJSONString(),QrCodeDeliveryReplyMessage.class);
- sendResult = enhanceProduce.qrCodeDeliveryReplyMessage(qrCodeDeliveryReplyMessage);
-// chargingMessage.setQrCodeDeliveryReplyMessage(qrCodeDeliveryReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setQrCodeDeliveryReplyMessage(qrCodeDeliveryReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("QR_CODE_DELIVERY_REPLY消息处理：{} 毫秒", System.currentTimeMillis() - QR_CODE_DELIVERY_REPLY);
break;
case SendTagConstant.SECURITY_DETECTION:
+ long SECURITY_DETECTION = System.currentTimeMillis();
+
SecurityDetectionMessage securityDetectionMessage = JSON.parseObject(content.toJSONString(),SecurityDetectionMessage.class);
- sendResult = enhanceProduce.securityDetectionMessage(securityDetectionMessage);
-// chargingMessage.setSecurityDetectionMessage(securityDetectionMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setSecurityDetectionMessage(securityDetectionMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("SECURITY_DETECTION消息处理：{} 毫秒", System.currentTimeMillis() - SECURITY_DETECTION);
break;
default:
+ long other = System.currentTimeMillis();
+
PlatformRemoteUpdateReplyMessage platformRemoteUpdateReplyMessage = JSON.parseObject(content.toJSONString(),PlatformRemoteUpdateReplyMessage.class);
- sendResult = enhanceProduce.platformRemoteUpdateReplyMessage(platformRemoteUpdateReplyMessage);
-// chargingMessage.setPlatformRemoteUpdateReplyMessage(platformRemoteUpdateReplyMessage);
-// chargingMessageUtil.handleMessage(chargingMessage);
-// sendResult = enhanceProduce.chargingMessage(chargingMessage);
- // 响应硬件
+ chargingMessage.setPlatformRemoteUpdateReplyMessage(platformRemoteUpdateReplyMessage);
+ chargingMessageUtil.handleMessage(chargingMessage);
+
+ log.warn("other消息处理：{} 毫秒", System.currentTimeMillis() - other);
break;
}
- log.info("rocketmq消息下发结果:{}",sendResult);
return AjaxResult.success();
}
@@ -553,5 +590,7 @@
iotMessageProduce.sendMessage(deviceId, ServiceIdMenu.ACQUISITION_BILLING_MODE_REPLY.getKey(),messageUtil.acquisitionBillingModeReply(acquisitionBillingModeReply));
return R.ok();
}
-
+
+
+
}
\ No newline at end of file
--
Gitblit v1.7.1