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


@@ -5,6 +5,7 @@


import com.ruoyi.chargingPile.api.dto.CheckChargingStrategyDTO;


import com.ruoyi.chargingPile.api.feignClient.AccountingStrategyDetailClient;


import com.ruoyi.chargingPile.api.model.TAccountingStrategyDetail;


import com.ruoyi.common.core.domain.R;


import com.ruoyi.common.core.web.domain.AjaxResult;


import com.ruoyi.integration.api.model.*;


import com.ruoyi.integration.iotda.constant.SendTagConstant;


@@ -17,15 +18,18 @@


import com.ruoyi.integration.rocket.produce.EnhanceProduce;


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.web.bind.annotation.PostMapping;


import org.springframework.web.bind.annotation.RequestBody;


import org.springframework.web.bind.annotation.RestController;




import java.io.IOException;


import java.math.BigDecimal;


import java.util.Date;


import java.util.List;


import java.util.Map;


import java.util.Objects;




/**


 * iotda消息监听


@@ -63,7 +67,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 +78,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 +89,17 @@


                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.ERROR_MESSAGE:


                ErrorMessageMessage errorMessageMessage = JSON.parseObject(content.toJSONString(),ErrorMessageMessage.class);


                sendResult = enhanceProduce.errorMessageMessage(errorMessageMessage);


                // 响应硬件


                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();


@@ -102,7 +111,7 @@


                }else {


                    // 查询桩使用的模版


                    CheckChargingStrategyDTO dto = new CheckChargingStrategyDTO();


                    dto.setCode(billingModeVerifyMessage.getBilling_model_code());


                    dto.setCode(billingModeVerifyMessage.getCharging_pile_code());


                    dto.setStrategyDetailId(Integer.valueOf(billingModeVerifyMessage.getBilling_model_code()));


                    Boolean check = accountingStrategyDetailClient.checkChargingStrategy(dto).getData();


                    // 校验计费模版是否准确


@@ -117,7 +126,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();


@@ -127,58 +136,70 @@


                StrategyUtil.setStrategyPrice(strategyPrice,acquisitionBillingModeReply);


                // 时段设置


                StrategyUtil.setTime(accountingStrategyDetails,acquisitionBillingModeReply);


                TAccountingStrategyDetail accountingStrategyDetail = accountingStrategyDetailClient.getDetailByCode(acquisitionBillingModeMessage.getCharging_pile_code()).getData();


                acquisitionBillingModeReply.setBilling_model_code(accountingStrategyDetail.getId().toString());


                acquisitionBillingModeReply.setCharging_pile_code(acquisitionBillingModeMessage.getCharging_pile_code());


                acquisitionBillingModeReply.setLoss_ratio(BigDecimal.ZERO);


                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);


                // 响应硬件


                PlatformConfirmationCharging platformConfirmationCharging = new PlatformConfirmationCharging();


                platformConfirmationCharging.setCharging_pile_code(chargingPileStartsChargingMessage.getCharging_pile_code());


                platformConfirmationCharging.setCharging_gun_code(chargingPileStartsChargingMessage.getCharging_gun_code());


                platformConfirmationCharging.setCard_number(chargingPileStartsChargingMessage.getAccount());


                platformConfirmationCharging.setAccount_balance(BigDecimal.ZERO);


                platformConfirmationCharging.setAuthentication(1);


                // TODO 若是失败，给出失败原因


                iotMessageProduce.sendMessage(deviceId, ServiceIdMenu.PLATFORM_CONFIRMATION_CHARGING.getKey(),messageUtil.platformConfirmationCharging(platformConfirmationCharging));


                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 +208,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 +237,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;


@@ -245,4 +266,63 @@


        return AjaxResult.success();


    }




    @PostMapping(value = "/message/sendMessage")


    public R sendMessage() {


        // 运营平台远程控制启机


//        PlatformStartCharging platformStartCharging = new PlatformStartCharging();


//        platformStartCharging.setTransaction_serial_number("4200002375202409185150427245");


//        platformStartCharging.setCharging_pile_code("3401231001200202");


//        platformStartCharging.setCharging_gun_code("1");


//        platformStartCharging.setCard_number("1833063878153543681");


//        platformStartCharging.setAccount_balance(new BigDecimal(50));


//        String message = iotMessageProduce.sendMessage(platformStartCharging.getCharging_pile_code(), ServiceIdMenu.PLATFORM_START_CHARGING.getKey(), messageUtil.platformStartCharging(platformStartCharging));


        // 运营平台远程停机


//        PlatformStopCharging platformStopCharging = new PlatformStopCharging();


//        platformStopCharging.setCharging_pile_code("3401231001200202");


//        platformStopCharging.setCharging_gun_code("1");


//        String message = iotMessageProduce.sendMessage(platformStopCharging.getCharging_pile_code(), ServiceIdMenu.PLATFORM_STOP_CHARGING.getKey(),messageUtil.platformStopCharging(platformStopCharging));


        // 修改余额


//        UpdateBalance updateBalance = new UpdateBalance();


//        updateBalance.setCharging_pile_code("3401231001200202");


//        updateBalance.setCharging_gun_code("1");


//        updateBalance.setPhysical_card_number("1833063878153543681");


//        updateBalance.setAccount_balance(new BigDecimal(20));


//        String message = iotMessageProduce.sendMessage(updateBalance.getCharging_pile_code(), ServiceIdMenu.UPDATE_BALANCE.getKey(),messageUtil.updateBalance(updateBalance));


        // 充电桩工作参数设置


//        WorkingParameterSetting workingParameterSetting = new WorkingParameterSetting();


//        workingParameterSetting.setCharging_pile_code("3401231001200202");


//        workingParameterSetting.setAllow_work(0);


//        workingParameterSetting.setMaximum_output_power(220);


//        String message = iotMessageProduce.sendMessage(workingParameterSetting.getCharging_pile_code(), ServiceIdMenu.WORKING_PARAMETER_SETTING.getKey(),messageUtil.workingParameterSetting(workingParameterSetting));


        // 对时设置


//        TimingSetting timingSetting = new TimingSetting();


//        timingSetting.setCharging_pile_code("3401231001200202");


//        System.err.println(CP56Time2aConverter.convertToCP56Time2a(new Date()));


//        timingSetting.setCurrent_time(CP56Time2aConverter.convertToCP56Time2a(new Date()));


//        String message = iotMessageProduce.sendMessage(timingSetting.getCharging_pile_code(), ServiceIdMenu.TIMING_SETTING.getKey(),messageUtil.timingSetting(timingSetting));


        // TODO 罗  计费模型设置


//        SetupBillingModel setupBillingModel = new SetupBillingModel();


//        // 计费模型


//        List<TAccountingStrategyDetail> accountingStrategyDetails = accountingStrategyDetailClient.getDetailListByCode("3401231001200202").getData();


//        Map<Integer, TAccountingStrategyDetail> strategyPrice = StrategyUtil.getStrategyPrice(accountingStrategyDetails);


//        // 价格设置


//        AcquisitionBillingModeReply acquisitionBillingModeReply = new AcquisitionBillingModeReply();


//        StrategyUtil.setStrategyPrice(strategyPrice,acquisitionBillingModeReply);


//        // 时段设置


//        StrategyUtil.setTime(accountingStrategyDetails,acquisitionBillingModeReply);


//        TAccountingStrategyDetail accountingStrategyDetail = accountingStrategyDetailClient.getDetailByCode("3401231001200202").getData();


//        acquisitionBillingModeReply.setBilling_model_code(accountingStrategyDetail.getId().toString());


//        acquisitionBillingModeReply.setCharging_pile_code("3401231001200202");


//        acquisitionBillingModeReply.setLoss_ratio(BigDecimal.ZERO);


//        BeanUtils.copyProperties(acquisitionBillingModeReply,setupBillingModel);


//        System.err.println(setupBillingModel);


//        String message = iotMessageProduce.sendMessage(setupBillingModel.getCharging_pile_code(), ServiceIdMenu.SETUP_BILLING_MODEL.getKey(),messageUtil.setupBillingModel(setupBillingModel));


        // 远程重启


        PlatformRestart platformRestart = new PlatformRestart();


        platformRestart.setCharging_pile_code("3401231001200202");


        platformRestart.setOperate(2);


        String message = iotMessageProduce.sendMessage(platformRestart.getCharging_pile_code(), ServiceIdMenu.PLATFORM_RESTART.getKey(),messageUtil.platformRestart(platformRestart));


        return R.ok(message);


    }




}