明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
puzhibing
2024-09-18 4b486f955cd3d36fa09e372c484b7a66711d7ec7 
 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java


@@ -63,7 +63,7 @@


        String result;


        switch (service_id){


            case SendTagConstant.ONLINE:


                OnlineMessage onlineMessage = JSON.parseObject(jsonObject.toJSONString(),OnlineMessage.class);


                OnlineMessage onlineMessage = JSON.parseObject(content.toJSONString(),OnlineMessage.class);


                sendResult = enhanceProduce.onlineMessage(onlineMessage);


                // 响应硬件


                // 业务处理 登录认证应答


@@ -74,7 +74,7 @@


                log.info("充电桩登录认证-返回结果：{}",result);


                break;


            case SendTagConstant.PING:


                PingMessage pingMessage = JSON.parseObject(jsonObject.toJSONString(),PingMessage.class);


                PingMessage pingMessage = JSON.parseObject(content.toJSONString(),PingMessage.class);


                sendResult = enhanceProduce.pingMessage(pingMessage);


                // 响应硬件


                Pong pong = new Pong();


@@ -85,12 +85,12 @@


                log.info("充电桩心跳包-返回结果：{}",result);


                break;


            case SendTagConstant.END_CHARGE:


                EndChargeMessage endChargeMessage = JSON.parseObject(jsonObject.toJSONString(),EndChargeMessage.class);


                EndChargeMessage endChargeMessage = JSON.parseObject(content.toJSONString(),EndChargeMessage.class);


                sendResult = enhanceProduce.endChargeMessage(endChargeMessage);


                // 响应硬件


                break;


            case SendTagConstant.BILLING_MODE_VERIFY:


                BillingModeVerifyMessage billingModeVerifyMessage = JSON.parseObject(jsonObject.toJSONString(),BillingModeVerifyMessage.class);


                BillingModeVerifyMessage billingModeVerifyMessage = JSON.parseObject(content.toJSONString(),BillingModeVerifyMessage.class);


                sendResult = enhanceProduce.billingModeVerifyMessage(billingModeVerifyMessage);


                // 响应硬件


                BillingModeVerifyReply billingModeVerifyReply = new BillingModeVerifyReply();


@@ -117,7 +117,7 @@


                iotMessageProduce.sendMessage(deviceId, ServiceIdMenu.BILLING_MODE_VERIFY_REPLY.getKey(),messageUtil.billingModeVerifyReply(billingModeVerifyReply));


                break;


            case SendTagConstant.ACQUISITION_BILLING_MODE:


                AcquisitionBillingModeMessage acquisitionBillingModeMessage = JSON.parseObject(jsonObject.toJSONString(),AcquisitionBillingModeMessage.class);


                AcquisitionBillingModeMessage acquisitionBillingModeMessage = JSON.parseObject(content.toJSONString(),AcquisitionBillingModeMessage.class);


                sendResult = enhanceProduce.acquisitionBillingModeMessage(acquisitionBillingModeMessage);


                // 响应硬件   计费模型请求应答  1=尖阶段，2=峰阶段，3=平阶段，4=谷阶段


                List<TAccountingStrategyDetail> accountingStrategyDetails = accountingStrategyDetailClient.getDetailListByCode(acquisitionBillingModeMessage.getCharging_pile_code()).getData();


@@ -130,55 +130,55 @@


                iotMessageProduce.sendMessage(deviceId, ServiceIdMenu.ACQUISITION_BILLING_MODE_REPLY.getKey(),messageUtil.acquisitionBillingModeReply(acquisitionBillingModeReply));


                break;


            case SendTagConstant.UPLOAD_REAL_TIME_MONITORING_DATA:


                UploadRealTimeMonitoringDataMessage uploadRealTimeMonitoringDataMessage = JSON.parseObject(jsonObject.toJSONString(),UploadRealTimeMonitoringDataMessage.class);


                UploadRealTimeMonitoringDataMessage uploadRealTimeMonitoringDataMessage = JSON.parseObject(content.toJSONString(),UploadRealTimeMonitoringDataMessage.class);


                sendResult = enhanceProduce.uploadRealTimeMonitoringDataMessage(uploadRealTimeMonitoringDataMessage);


                // 响应硬件


                break;


            case SendTagConstant.CHARGING_HANDSHAKE:


                ChargingHandshakeMessage chargingHandshakeMessage = JSON.parseObject(jsonObject.toJSONString(),ChargingHandshakeMessage.class);


                ChargingHandshakeMessage chargingHandshakeMessage = JSON.parseObject(content.toJSONString(),ChargingHandshakeMessage.class);


                sendResult = enhanceProduce.chargingHandshakeMessage(chargingHandshakeMessage);


                // 响应硬件


                break;


            case SendTagConstant.PARAMETER_SETTING:


                ParameterSettingMessage parameterSettingMessage = JSON.parseObject(jsonObject.toJSONString(),ParameterSettingMessage.class);


                ParameterSettingMessage parameterSettingMessage = JSON.parseObject(content.toJSONString(),ParameterSettingMessage.class);


                sendResult = enhanceProduce.parameterSettingMessage(parameterSettingMessage);


                break;


            case SendTagConstant.BMS_ABORT:


                BmsAbortMessage bmsAbortMessage = JSON.parseObject(jsonObject.toJSONString(),BmsAbortMessage.class);


                BmsAbortMessage bmsAbortMessage = JSON.parseObject(content.toJSONString(),BmsAbortMessage.class);


                sendResult = enhanceProduce.bmsAbortMessage(bmsAbortMessage);


                // 响应硬件


                break;


            case SendTagConstant.MOTOR_ABORT:


                MotorAbortMessage motorAbortMessage = JSON.parseObject(jsonObject.toJSONString(),MotorAbortMessage.class);


                MotorAbortMessage motorAbortMessage = JSON.parseObject(content.toJSONString(),MotorAbortMessage.class);


                sendResult = enhanceProduce.motorAbortMessage(motorAbortMessage);


                break;


            case SendTagConstant.BMS_DEMAND_AND_CHARGER_EXPORTATION:


                BmsDemandAndChargerExportationMessage bmsDemandAndChargerExportationMessage = JSON.parseObject(jsonObject.toJSONString(),BmsDemandAndChargerExportationMessage.class);


                BmsDemandAndChargerExportationMessage bmsDemandAndChargerExportationMessage = JSON.parseObject(content.toJSONString(),BmsDemandAndChargerExportationMessage.class);


                sendResult = enhanceProduce.bmsDemandAndChargerExportationMessage(bmsDemandAndChargerExportationMessage);


                // 响应硬件


                break;


            case SendTagConstant.BMS_INFORMATION:


                BmsInformationMessage bmsInformationMessage = JSON.parseObject(jsonObject.toJSONString(),BmsInformationMessage.class);


                BmsInformationMessage bmsInformationMessage = JSON.parseObject(content.toJSONString(),BmsInformationMessage.class);


                sendResult = enhanceProduce.bmsInformationMessage(bmsInformationMessage);


                // 响应硬件


                break;


            case SendTagConstant.CHARGING_PILE_STARTS_CHARGING:


                ChargingPileStartsChargingMessage chargingPileStartsChargingMessage = JSON.parseObject(jsonObject.toJSONString(),ChargingPileStartsChargingMessage.class);


                ChargingPileStartsChargingMessage chargingPileStartsChargingMessage = JSON.parseObject(content.toJSONString(),ChargingPileStartsChargingMessage.class);


                sendResult = enhanceProduce.chargingPileStartsChargingMessage(chargingPileStartsChargingMessage);


                // 响应硬件


                break;


            case SendTagConstant.PLATFORM_START_CHARGING_REPLY:


                PlatformStartChargingReplyMessage platformStartChargingReplyMessage = JSON.parseObject(jsonObject.toJSONString(),PlatformStartChargingReplyMessage.class);


                PlatformStartChargingReplyMessage platformStartChargingReplyMessage = JSON.parseObject(content.toJSONString(),PlatformStartChargingReplyMessage.class);


                sendResult = enhanceProduce.platformStartChargingReplyMessage(platformStartChargingReplyMessage);


                // 响应硬件


                break;


            case SendTagConstant.PLATFORM_STOP_CHARGING_REPLY:


                PlatformStopChargingReplyMessage platformStopChargingReplyMessage = JSON.parseObject(jsonObject.toJSONString(),PlatformStopChargingReplyMessage.class);


                PlatformStopChargingReplyMessage platformStopChargingReplyMessage = JSON.parseObject(content.toJSONString(),PlatformStopChargingReplyMessage.class);


                sendResult = enhanceProduce.platformStopChargingReplyMessage(platformStopChargingReplyMessage);


                // 响应硬件


                break;


            case SendTagConstant.TRANSACTION_RECORD:


                TransactionRecordMessage transactionRecordMessage = JSON.parseObject(jsonObject.toJSONString(),TransactionRecordMessage.class);


                TransactionRecordMessage transactionRecordMessage = JSON.parseObject(content.toJSONString(),TransactionRecordMessage.class);


                sendResult = enhanceProduce.transactionRecordMessage(transactionRecordMessage);


                // 响应硬件


                ConfirmTransactionRecord confirmTransactionRecord = new ConfirmTransactionRecord();


@@ -187,27 +187,27 @@


                iotMessageProduce.sendMessage(deviceId, ServiceIdMenu.CONFIRM_TRANSACTION_RECORD.getKey(),messageUtil.confirmTransactionRecord(confirmTransactionRecord));


                break;


            case SendTagConstant.UPDATE_BALANCE_REPLY:


                UpdateBalanceReplyMessage updateBalanceReplyMessage = JSON.parseObject(jsonObject.toJSONString(),UpdateBalanceReplyMessage.class);


                UpdateBalanceReplyMessage updateBalanceReplyMessage = JSON.parseObject(content.toJSONString(),UpdateBalanceReplyMessage.class);


                sendResult = enhanceProduce.updateBalanceReplyMessage(updateBalanceReplyMessage);


                // 响应硬件


                break;


            case SendTagConstant.SYNCHRONIZE_OFFLINE_CARD_REPLY:


                SynchronizeOfflineCardReplyMessage synchronizeOfflineCardReplyMessage = JSON.parseObject(jsonObject.toJSONString(),SynchronizeOfflineCardReplyMessage.class);


                SynchronizeOfflineCardReplyMessage synchronizeOfflineCardReplyMessage = JSON.parseObject(content.toJSONString(),SynchronizeOfflineCardReplyMessage.class);


                sendResult = enhanceProduce.synchronizeOfflineCardReplyMessage(synchronizeOfflineCardReplyMessage);


                // 响应硬件


                break;


            case SendTagConstant.CLEAR_OFFLINE_CARD_REPLY:


                ClearOfflineCardReplyMessage clearOfflineCardReplyMessage = JSON.parseObject(jsonObject.toJSONString(),ClearOfflineCardReplyMessage.class);


                ClearOfflineCardReplyMessage clearOfflineCardReplyMessage = JSON.parseObject(content.toJSONString(),ClearOfflineCardReplyMessage.class);


                sendResult = enhanceProduce.clearOfflineCardReplyMessage(clearOfflineCardReplyMessage);


                // 响应硬件


                break;


            case SendTagConstant.WORKING_PARAMETER_SETTING_REPLY:


                WorkingParameterSettingReplyMessage workingParameterSettingReplyMessage = JSON.parseObject(jsonObject.toJSONString(),WorkingParameterSettingReplyMessage.class);


                WorkingParameterSettingReplyMessage workingParameterSettingReplyMessage = JSON.parseObject(content.toJSONString(),WorkingParameterSettingReplyMessage.class);


                sendResult = enhanceProduce.workingParameterSettingReplyMessage(workingParameterSettingReplyMessage);


                // 响应硬件


                break;


            case SendTagConstant.TIMING_SETTING:


                TimingSettingMessage timingSettingMessage = JSON.parseObject(jsonObject.toJSONString(),TimingSettingMessage.class);


                TimingSettingMessage timingSettingMessage = JSON.parseObject(content.toJSONString(),TimingSettingMessage.class);


                sendResult = enhanceProduce.timingSettingMessage(timingSettingMessage);


                // 响应硬件 对时设置应答


                TimingSettingReply timingSettingReply = new TimingSettingReply();


@@ -216,27 +216,27 @@


                iotMessageProduce.sendMessage(deviceId, ServiceIdMenu.TIMING_SETTING_REPLY.getKey(),messageUtil.timingSettingReply(timingSettingReply));


                break;


            case SendTagConstant.SETUP_BILLING_MODEL_REPLY:


                SetupBillingModelReplyMessage setupBillingModelReplyMessage = JSON.parseObject(jsonObject.toJSONString(),SetupBillingModelReplyMessage.class);


                SetupBillingModelReplyMessage setupBillingModelReplyMessage = JSON.parseObject(content.toJSONString(),SetupBillingModelReplyMessage.class);


                sendResult = enhanceProduce.setupBillingModelReplyMessage(setupBillingModelReplyMessage);


                // 响应硬件


                break;


            case SendTagConstant.GROUND_LOCK_REAL_TIME_DATA:


                GroundLockRealTimeDataMessage groundLockRealTimeDataMessage = JSON.parseObject(jsonObject.toJSONString(),GroundLockRealTimeDataMessage.class);


                GroundLockRealTimeDataMessage groundLockRealTimeDataMessage = JSON.parseObject(content.toJSONString(),GroundLockRealTimeDataMessage.class);


                sendResult = enhanceProduce.groundLockRealTimeDataMessage(groundLockRealTimeDataMessage);


                // 响应硬件


                break;


            case SendTagConstant.CHARGING_PILE_RETURNS_GROUND_LOCK_DATA:


                ChargingPileReturnsGroundLockDataMessage chargingPileReturnsGroundLockDataMessage = JSON.parseObject(jsonObject.toJSONString(),ChargingPileReturnsGroundLockDataMessage.class);


                ChargingPileReturnsGroundLockDataMessage chargingPileReturnsGroundLockDataMessage = JSON.parseObject(content.toJSONString(),ChargingPileReturnsGroundLockDataMessage.class);


                sendResult = enhanceProduce.chargingPileReturnsGroundLockDataMessage(chargingPileReturnsGroundLockDataMessage);


                // 响应硬件


                break;


            case SendTagConstant.PLATFORM_RESTART_REPLY:


                PlatformRestartReplyMessage platformRestartReplyMessage = JSON.parseObject(jsonObject.toJSONString(),PlatformRestartReplyMessage.class);


                PlatformRestartReplyMessage platformRestartReplyMessage = JSON.parseObject(content.toJSONString(),PlatformRestartReplyMessage.class);


                sendResult = enhanceProduce.platformRestartReplyMessage(platformRestartReplyMessage);


                // 响应硬件


                break;


            default:


                PlatformRemoteUpdateReplyMessage platformRemoteUpdateReplyMessage = JSON.parseObject(jsonObject.toJSONString(),PlatformRemoteUpdateReplyMessage.class);


                PlatformRemoteUpdateReplyMessage platformRemoteUpdateReplyMessage = JSON.parseObject(content.toJSONString(),PlatformRemoteUpdateReplyMessage.class);


                sendResult = enhanceProduce.platformRemoteUpdateReplyMessage(platformRemoteUpdateReplyMessage);


                // 响应硬件


                break;