明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
liujie
10 天以前 26526de10d49c3422a6d6c2d55fe5a2997786ad9 
 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/tools/ChargingMessageUtil.java


New file


@@ -0,0 +1,463 @@


package com.ruoyi.integration.iotda.utils.tools;




import com.alibaba.fastjson.JSONObject;


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


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


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


import com.ruoyi.chargingPile.api.vo.UpdateChargingPileStatusVo;


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


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


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


import com.ruoyi.integration.mongodb.service.*;


import com.ruoyi.order.api.feignClient.ChargingOrderClient;


import com.ruoyi.order.api.model.TChargingOrder;


import com.ruoyi.order.api.query.UploadRealTimeMonitoringDataQuery;


import com.ruoyi.order.api.vo.PlatformStartChargingReplyMessageVO;


import com.ruoyi.order.api.vo.PlatformStopChargingReplyVO;


import com.ruoyi.order.api.vo.SecurityDetectionVO;


import com.ruoyi.order.api.vo.TransactionRecordMessageVO;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Component;


import org.springframework.util.StringUtils;




import javax.annotation.Resource;


import java.math.RoundingMode;


import java.util.Objects;


import java.util.concurrent.TimeUnit;






@Slf4j


@Component


public class ChargingMessageUtil {




    @Autowired


    private AcquisitionBillingModeService acquisitionBillingModeService;


    @Autowired


    private BillingModeVerifyService billingModeVerifyService;


    @Autowired


    private BmsAbortService bmsAbortService;


    @Resource


    private ChargingOrderClient chargingOrderClient;


    @Autowired


    private BmsDemandAndChargerExportationService bmsDemandAndChargerExportationService;


    @Autowired


    private OnlineService onlineService;


    @Autowired


    private PingService pingService;


    @Autowired


    private EndChargeService endChargeService;


    @Autowired


    private ErrorMessageMessageService errorMessageMessageService;


    @Autowired


    private UploadRealTimeMonitoringDataService uploadRealTimeMonitoringDataService;


    @Resource


    private AccountingStrategyDetailClient accountingStrategyDetailClient;


    @Autowired


    private ChargingHandshakeService chargingHandshakeService;


    @Autowired


    private ParameterSettingService parameterSettingService;


    @Autowired


    private MotorAbortService motorAbortService;


    @Autowired


    private BmsInformationService bmsInformationService;


    @Autowired


    private ChargingPileStartsChargingService chargingPileStartsChargingService;


    @Autowired


    private PlatformStartChargingReplyService platformStartChargingReplyService;


    @Autowired


    private PlatformStopChargingReplyService platformStopChargingReplyService;


    @Autowired


    private TransactionRecordService transactionRecordService;


    @Autowired


    private UpdateBalanceReplyService updateBalanceReplyService;


    @Autowired


    private SynchronizeOfflineCardReplyService synchronizeOfflineCardReplyService;


    @Autowired


    private ClearOfflineCardReplyService clearOfflineCardReplyService;


    @Autowired


    private WorkingParameterSettingReplyService workingParameterSettingReplyService;


    @Autowired


    private TimingSettingService timingSettingService;


    @Autowired


    private SetupBillingModelReplyService setupBillingModelReplyService;


    @Autowired


    private GroundLockRealTimeDataService groundLockRealTimeDataService;


    @Autowired


    private ChargingPileReturnsGroundLockDataService chargingPileReturnsGroundLockDataService;


    @Autowired


    private PlatformRestartReplyService platformRestartReplyService;


    @Autowired


    private PlatformRemoteUpdateReplyService platformRemoteUpdateReplyService;


    @Autowired


    private QrCodeDeliveryReplyService qrCodeDeliveryReplyService;


    @Autowired


    private SecurityDetectionService securityDetectionService;




    @Resource


    private ChargingPileClient chargingPileClient;




    @Resource


    private RedisTemplate redisTemplate;












    public void handleMessage(ChargingMessage message){


        log.info("收到的消息内容:{}",message);


        String serviceId = message.getServiceId();


        if(!StringUtils.hasLength(serviceId)){


            return;


        }


        switch (serviceId){


            case SendTagConstant.ONLINE:


                OnlineMessage onlineMessage = message.getOnlineMessage();


                log.info("充电桩登录认证业务消息处理:{}",onlineMessage);


                // 持久化消息


                Online online = new Online();


                BeanUtils.copyProperties(onlineMessage,online);


                onlineService.create(online);


                break;


            case SendTagConstant.PING:


                PingMessage pingMessage = message.getPingMessage();


                log.info("充电桩心跳包-业务消息处理:{}",pingMessage);


                // 持久化消息


                Ping ping = new Ping();


                BeanUtils.copyProperties(pingMessage,ping);


                pingService.save(ping);


                //存储缓存中，5分钟有效


                redisTemplate.opsForValue().set("ping:" + ping.getCharging_pile_code() + ping.getCharging_gun_code(), ping, 5, TimeUnit.MINUTES);




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


                break;


            case SendTagConstant.END_CHARGE:


                EndChargeMessage endChargeMessage = message.getEndChargeMessage();


                log.info("充电结束-业务消息处理:{}",endChargeMessage);


                // 持久化消息


                EndCharge endCharge = new EndCharge();


                BeanUtils.copyProperties(endChargeMessage,endCharge);


                endChargeService.create(endCharge);


                // 业务处理


                chargingOrderClient.endCharge(endCharge.getTransaction_serial_number());


                break;


            case SendTagConstant.ERROR_MESSAGE:


                ErrorMessageMessage errorMessageMessage1 = message.getErrorMessageMessage();


                log.info("错误报文-业务消息处理:{}",errorMessageMessage1);


                // 持久化消息


//                ErrorMessageMessage errorMessageMessage = new ErrorMessageMessage();


//                BeanUtils.copyProperties(errorMessageMessage1,errorMessageMessage);


//                errorMessageMessageService.create(errorMessageMessage);


                break;


            case SendTagConstant.BILLING_MODE_VERIFY:


                BillingModeVerifyMessage billingModeVerifyMessage = message.getBillingModeVerifyMessage();


                log.info("计费模型验证请求-业务消息处理:{}",billingModeVerifyMessage);


                // 持久化消息


//                BillingModeVerify billingModeVerify = new BillingModeVerify();


//                BeanUtils.copyProperties(billingModeVerifyMessage,billingModeVerify);


//                billingModeVerifyService.create(billingModeVerify);


                break;


            case SendTagConstant.ACQUISITION_BILLING_MODE:


                AcquisitionBillingModeMessage acquisitionBillingModeMessage = message.getAcquisitionBillingModeMessage();


                log.info("充电桩计费模型请求-业务消息处理:{}",acquisitionBillingModeMessage);


                // 持久化消息


                AcquisitionBillingMode acquisitionBillingMode = new AcquisitionBillingMode();


                BeanUtils.copyProperties(acquisitionBillingModeMessage,acquisitionBillingMode);


                acquisitionBillingModeService.create(acquisitionBillingMode);


                break;


            case SendTagConstant.UPLOAD_REAL_TIME_MONITORING_DATA:


                //限制数据处理频率，60秒一次


                UploadRealTimeMonitoringDataMessage uploadRealTimeMonitoringDataMessage = message.getUploadRealTimeMonitoringDataMessage();


                String transaction_serial_number = uploadRealTimeMonitoringDataMessage.getTransaction_serial_number();


                Object o = redisTemplate.opsForValue().get("upload_real_time_monitoring_data:" + transaction_serial_number);


                if(null != o){


                    Long m = System.currentTimeMillis() - (Long) o;


                    if(m < 60000){


                        break;


                    }


                }


                redisTemplate.opsForValue().set("upload_real_time_monitoring_data:" + transaction_serial_number, System.currentTimeMillis(), 1, TimeUnit.MINUTES);


                try {


                    log.info("上传实时监测数据-业务消息处理:{}",uploadRealTimeMonitoringDataMessage);


                    // 持久化消息


                    UploadRealTimeMonitoringData uploadRealTimeMonitoringData = new UploadRealTimeMonitoringData();


                    BeanUtils.copyProperties(uploadRealTimeMonitoringDataMessage,uploadRealTimeMonitoringData);


                    // 查询mogondb上一条数据


                    UploadRealTimeMonitoringData data = uploadRealTimeMonitoringDataService.getLastDataById(uploadRealTimeMonitoringDataMessage.getTransaction_serial_number());


                    // 查询订单


                    TChargingOrder chargingOrder = chargingOrderClient.getOrderByCode(uploadRealTimeMonitoringDataMessage.getTransaction_serial_number()).getData();


                    // 查询当前时间段的计费策略


                    TAccountingStrategyDetail accountingStrategyDetail = accountingStrategyDetailClient.getDetailBySiteId(chargingOrder.getSiteId()).getData();


                    uploadRealTimeMonitoringData.setElectrovalence_all(accountingStrategyDetail.getElectrovalence());


                    uploadRealTimeMonitoringData.setService_charge(accountingStrategyDetail.getServiceCharge());


                    if (Objects.nonNull(data)) {


                        uploadRealTimeMonitoringDataService.updateById(data.getId());


                        uploadRealTimeMonitoringData.setPeriod_electric_price(uploadRealTimeMonitoringDataMessage.getPaid_amount().subtract(data.getPaid_amount()));


                        uploadRealTimeMonitoringData.setPeriod_charging_degree(uploadRealTimeMonitoringDataMessage.getCharging_degree().subtract(data.getCharging_degree()));


                        uploadRealTimeMonitoringData.setPeriod_service_price(uploadRealTimeMonitoringDataMessage.getCharging_degree().multiply(accountingStrategyDetail.getServiceCharge()).setScale(4, RoundingMode.HALF_UP));


                    }else {


                        log.info("首次上传实时监测数据");


                        uploadRealTimeMonitoringData.setPeriod_electric_price(uploadRealTimeMonitoringDataMessage.getPaid_amount());


                        uploadRealTimeMonitoringData.setPeriod_charging_degree(uploadRealTimeMonitoringDataMessage.getCharging_degree());


                        uploadRealTimeMonitoringData.setPeriod_service_price(uploadRealTimeMonitoringDataMessage.getCharging_degree().multiply(accountingStrategyDetail.getServiceCharge()).setScale(4, RoundingMode.HALF_UP));


                    }


                    uploadRealTimeMonitoringData.setOrderType(chargingOrder.getOrderType());


                    uploadRealTimeMonitoringData.setSiteId(chargingOrder.getSiteId());


                    uploadRealTimeMonitoringData.setStatus(chargingOrder.getStatus());


                    int i = uploadRealTimeMonitoringDataService.create(uploadRealTimeMonitoringData);


                    if(i == 0){


                        log.error("数据存储mongo失败");


                    }


        


                    // 业务处理


                    UploadRealTimeMonitoringDataQuery query = new UploadRealTimeMonitoringDataQuery();


                    BeanUtils.copyProperties(uploadRealTimeMonitoringData, query);


                    chargingOrderClient.chargeMonitoring(query);


                } catch (Exception e) {


                    e.printStackTrace();


                }


                break;


            case SendTagConstant.CHARGING_HANDSHAKE:


                ChargingHandshakeMessage chargingHandshakeMessage = message.getChargingHandshakeMessage();


                log.info("充电握手-业务消息处理:{}",chargingHandshakeMessage);


                // 持久化消息


                ChargingHandshake chargingHandshake = new ChargingHandshake();


                BeanUtils.copyProperties(chargingHandshakeMessage,chargingHandshake);


                chargingHandshakeService.create(chargingHandshake);


                break;


            case SendTagConstant.PARAMETER_SETTING:


                ParameterSettingMessage parameterSettingMessage = message.getParameterSettingMessage();


                log.info("参数配置-业务消息处理:{}",parameterSettingMessage);


                // 持久化消息


//                ParameterSetting parameterSetting = new ParameterSetting();


//                BeanUtils.copyProperties(parameterSettingMessage,parameterSetting);


//                parameterSettingService.create(parameterSetting);


                break;


            case SendTagConstant.BMS_ABORT:


                BmsAbortMessage bmsAbortMessage = message.getBmsAbortMessage();


                log.info("充电阶段BMS中止-业务消息处理:{}",bmsAbortMessage);


                // 持久化消息


                BmsAbort bmsAbort = new BmsAbort();


                BeanUtils.copyProperties(bmsAbortMessage,bmsAbort);


                bmsAbortService.create(bmsAbort);


                // 业务处理


                chargingOrderClient.excelEndCharge(bmsAbort.getTransaction_serial_number());


                break;


            case SendTagConstant.MOTOR_ABORT:


                MotorAbortMessage motorAbortMessage = message.getMotorAbortMessage();


                log.info("充电阶段充电机中止-业务消息处理:{}",motorAbortMessage);


                // 持久化消息


                MotorAbort motorAbort = new MotorAbort();


                BeanUtils.copyProperties(motorAbortMessage,motorAbort);


                motorAbortService.create(motorAbort);


                // 业务处理


                chargingOrderClient.excelEndCharge(motorAbort.getTransaction_serial_number());


                break;


            case SendTagConstant.BMS_DEMAND_AND_CHARGER_EXPORTATION:


                BmsDemandAndChargerExportationMessage bmsDemandAndChargerExportationMessage = message.getBmsDemandAndChargerExportationMessage();


                log.info("充电过程BMS需求、充电机输出-业务消息处理:{}",bmsDemandAndChargerExportationMessage);


                String transaction_serial_number1 = bmsDemandAndChargerExportationMessage.getTransaction_serial_number();


                Object o1 = redisTemplate.opsForValue().get("bms_demand_and_charger_exportation:" + transaction_serial_number1);


                if(null != o1){


                    Long m = System.currentTimeMillis() - (Long) o1;


                    if(m < 60000){


                        break;


                    }


                }


                redisTemplate.opsForValue().set("bms_demand_and_charger_exportation:" + transaction_serial_number1, System.currentTimeMillis(), 1, TimeUnit.MINUTES);


                


                // 持久化消息


                BmsDemandAndChargerExportation bmsDemandAndChargerExportation = new BmsDemandAndChargerExportation();


                BeanUtils.copyProperties(bmsDemandAndChargerExportationMessage,bmsDemandAndChargerExportation);


                bmsDemandAndChargerExportationService.create(bmsDemandAndChargerExportation);


    


                // 业务处理


                TChargingOrder chargingOrderBms = chargingOrderClient.getOrderByCode(bmsDemandAndChargerExportationMessage.getTransaction_serial_number()).getData();


                if(Objects.nonNull(chargingOrderBms)){


                    chargingOrderBms.setNeedElec(bmsDemandAndChargerExportationMessage.getBms_current_requirements());


                    chargingOrderClient.updateChargingOrder(chargingOrderBms);


                }


                break;


            case SendTagConstant.BMS_INFORMATION:


                BmsInformationMessage bmsInformationMessage = message.getBmsInformationMessage();


                log.info("充电过程BMS信息-业务消息处理:{}",bmsInformationMessage);


                String transaction_serial_number2 = bmsInformationMessage.getTransaction_serial_number();


                Object o2 = redisTemplate.opsForValue().get("bms_information:" + transaction_serial_number2);


                if(null != o2){


                    Long m = System.currentTimeMillis() - (Long) o2;


                    if(m < 60000){


                        break;


                    }


                }


                redisTemplate.opsForValue().set("bms_information:" + transaction_serial_number2, System.currentTimeMillis(), 1, TimeUnit.MINUTES);


                


                // 持久化消息


                BmsInformation bmsInformation = new BmsInformation();


                BeanUtils.copyProperties(bmsInformationMessage,bmsInformation);


                bmsInformationService.create(bmsInformation);


                break;


            case SendTagConstant.CHARGING_PILE_STARTS_CHARGING:


                ChargingPileStartsChargingMessage chargingPileStartsChargingMessage = message.getChargingPileStartsChargingMessage();


                log.info("充电桩主动申请启动充电-业务消息处理:{}",chargingPileStartsChargingMessage);


                // 持久化消息


                ChargingPileStartsCharging chargingPileStartsCharging = new ChargingPileStartsCharging();


                BeanUtils.copyProperties(chargingPileStartsChargingMessage,chargingPileStartsCharging);


                chargingPileStartsChargingService.create(chargingPileStartsCharging);


                break;


            case SendTagConstant.PLATFORM_START_CHARGING_REPLY:


                PlatformStartChargingReplyMessage platformStartChargingReplyMessage = message.getPlatformStartChargingReplyMessage();


                log.info("远程启机命令回复-业务消息处理:{}",platformStartChargingReplyMessage);


                // 持久化消息


                PlatformStartChargingReply platformStartChargingReply = new PlatformStartChargingReply();


                BeanUtils.copyProperties(platformStartChargingReplyMessage,platformStartChargingReply);


                platformStartChargingReplyService.create(platformStartChargingReply);


    


                // 业务处理


                PlatformStartChargingReplyMessageVO message1 = new PlatformStartChargingReplyMessageVO();


                BeanUtils.copyProperties(platformStartChargingReplyMessage, message1);


                chargingOrderClient.startChargeSuccessfully(message1);


                break;


            case SendTagConstant.PLATFORM_STOP_CHARGING_REPLY:


                PlatformStopChargingReplyMessage platformStopChargingReplyMessage = message.getPlatformStopChargingReplyMessage();


                log.info("远程停机命令回复-业务消息处理:{}",platformStopChargingReplyMessage);


                // 持久化消息


                PlatformStopChargingReply platformStopChargingReply = new PlatformStopChargingReply();


                BeanUtils.copyProperties(platformStopChargingReplyMessage,platformStopChargingReply);


                platformStopChargingReplyService.create(platformStopChargingReply);


    


                PlatformStopChargingReplyVO platformStopChargingReply1 = new PlatformStopChargingReplyVO();


                BeanUtils.copyProperties(platformStopChargingReply, platformStopChargingReply1);


                chargingOrderClient.terminateSuccessfulResponse(platformStopChargingReply1);


                break;


            case SendTagConstant.TRANSACTION_RECORD:


                TransactionRecordMessage transactionRecordMessage = message.getTransactionRecordMessage();


                log.info("交易记录-业务消息处理:{}",transactionRecordMessage);


                transactionRecordMessage.setResult(JSONObject.toJSONString(transactionRecordMessage));


                // 持久化消息


                TransactionRecord transactionRecord = new TransactionRecord();


                BeanUtils.copyProperties(transactionRecordMessage,transactionRecord);


                transactionRecord.setResult(transactionRecordMessage.getResult());


                transactionRecordService.create(transactionRecord);


    


                // 业务处理


                TChargingOrder chargingOrderRecord = chargingOrderClient.getOrderByCode(transactionRecordMessage.getTransaction_serial_number()).getData();


                if(Objects.nonNull(chargingOrderRecord)){


                    chargingOrderRecord.setTotalElectricity(transactionRecordMessage.getTotal_electricity());


                    chargingOrderClient.updateChargingOrder(chargingOrderRecord);


                }


                //计算费用


                TransactionRecordMessageVO vo = new TransactionRecordMessageVO();


                BeanUtils.copyProperties(transactionRecordMessage,vo);


                chargingOrderClient.endChargeBillingCharge(vo);


    


                // 添加实时上传结束记录


                // 查询mogondb上一条数据


                UploadRealTimeMonitoringData data = uploadRealTimeMonitoringDataService.getLastDataById(transactionRecordMessage.getTransaction_serial_number());


                if(Objects.nonNull(data) && data.getStatus() != 5){


                    UploadRealTimeMonitoringData uploadRealTimeMonitoringData = new UploadRealTimeMonitoringData();


                    BeanUtils.copyProperties(data,uploadRealTimeMonitoringData);


                    uploadRealTimeMonitoringData.setStatus(5);


                    uploadRealTimeMonitoringDataService.create(uploadRealTimeMonitoringData);


                }


                break;


            case SendTagConstant.UPDATE_BALANCE_REPLY:


                UpdateBalanceReplyMessage updateBalanceReplyMessage = message.getUpdateBalanceReplyMessage();


                log.info("余额更新应答-业务消息处理:{}",updateBalanceReplyMessage);


                // 持久化消息


                UpdateBalanceReply updateBalanceReply = new UpdateBalanceReply();


                BeanUtils.copyProperties(updateBalanceReplyMessage,updateBalanceReply);


                updateBalanceReplyService.create(updateBalanceReply);


                break;


            case SendTagConstant.SYNCHRONIZE_OFFLINE_CARD_REPLY:


                SynchronizeOfflineCardReplyMessage synchronizeOfflineCardReplyMessage = message.getSynchronizeOfflineCardReplyMessage();


                log.info("卡数据同步应答-业务消息处理:{}",synchronizeOfflineCardReplyMessage);


                // 持久化消息


                SynchronizeOfflineCardReply synchronizeOfflineCardReply = new SynchronizeOfflineCardReply();


                BeanUtils.copyProperties(synchronizeOfflineCardReplyMessage,synchronizeOfflineCardReply);


                synchronizeOfflineCardReplyService.create(synchronizeOfflineCardReply);


                break;


            case SendTagConstant.CLEAR_OFFLINE_CARD_REPLY:


                ClearOfflineCardReplyMessage clearOfflineCardReplyMessage = message.getClearOfflineCardReplyMessage();


                log.info("离线卡数据清除应答-业务消息处理:{}",clearOfflineCardReplyMessage);


                // 持久化消息


                ClearOfflineCardReply clearOfflineCardReply = new ClearOfflineCardReply();


                BeanUtils.copyProperties(clearOfflineCardReplyMessage,clearOfflineCardReply);


                clearOfflineCardReplyService.create(clearOfflineCardReply);


                break;


            case SendTagConstant.WORKING_PARAMETER_SETTING_REPLY:


                WorkingParameterSettingReplyMessage workingParameterSettingReplyMessage = message.getWorkingParameterSettingReplyMessage();


                log.info("充电桩工作参数设置应答-业务消息处理:{}",workingParameterSettingReplyMessage);


                // 持久化消息


                WorkingParameterSettingReply workingParameterSettingReply = new WorkingParameterSettingReply();


                BeanUtils.copyProperties(workingParameterSettingReplyMessage,workingParameterSettingReply);


                workingParameterSettingReplyService.create(workingParameterSettingReply);


                break;


            case SendTagConstant.TIMING_SETTING:


                TimingSettingMessage timingSettingMessage = message.getTimingSettingMessage();


                log.info("对时设置-业务消息处理:{}",timingSettingMessage);


                // 持久化消息


//                TimingSetting timingSetting = new TimingSetting();


//                BeanUtils.copyProperties(timingSettingMessage,timingSetting);


//                timingSettingService.create(timingSetting);


                break;


            case SendTagConstant.SETUP_BILLING_MODEL_REPLY:


                SetupBillingModelReplyMessage setupBillingModelReplyMessage = message.getSetupBillingModelReplyMessage();


                log.info("计费模型应答-业务消息处理:{}",setupBillingModelReplyMessage);


                // 持久化消息


                SetupBillingModelReply setupBillingModelReply = new SetupBillingModelReply();


                BeanUtils.copyProperties(setupBillingModelReplyMessage,setupBillingModelReply);


                setupBillingModelReplyService.create(setupBillingModelReply);


                break;


            case SendTagConstant.GROUND_LOCK_REAL_TIME_DATA:


                GroundLockRealTimeDataMessage groundLockRealTimeDataMessage = message.getGroundLockRealTimeDataMessage();


                log.info("地锁数据上送（充电桩上送）-业务消息处理:{}",groundLockRealTimeDataMessage);


                // 持久化消息


                GroundLockRealTimeData groundLockRealTimeData = new GroundLockRealTimeData();


                BeanUtils.copyProperties(groundLockRealTimeDataMessage,groundLockRealTimeData);


                groundLockRealTimeDataService.create(groundLockRealTimeData);


                break;


            case SendTagConstant.CHARGING_PILE_RETURNS_GROUND_LOCK_DATA:


                ChargingPileReturnsGroundLockDataMessage chargingPileReturnsGroundLockDataMessage = message.getChargingPileReturnsGroundLockDataMessage();


                log.info("充电桩返回数据（上行）-业务消息处理:{}",chargingPileReturnsGroundLockDataMessage);


                // 持久化消息


                ChargingPileReturnsGroundLockData chargingPileReturnsGroundLockData = new ChargingPileReturnsGroundLockData();


                BeanUtils.copyProperties(chargingPileReturnsGroundLockDataMessage,chargingPileReturnsGroundLockData);


                chargingPileReturnsGroundLockDataService.create(chargingPileReturnsGroundLockData);


                break;


            case SendTagConstant.PLATFORM_RESTART_REPLY:


                PlatformRestartReplyMessage platformRestartReplyMessage = message.getPlatformRestartReplyMessage();


                log.info("远程重启应答-业务消息处理:{}",platformRestartReplyMessage);


                // 持久化消息


                PlatformRestartReply platformRestartReply = new PlatformRestartReply();


                BeanUtils.copyProperties(platformRestartReplyMessage,platformRestartReply);


                platformRestartReplyService.create(platformRestartReply);


                break;


            case SendTagConstant.QR_CODE_DELIVERY_REPLY:


                QrCodeDeliveryReplyMessage qrCodeDeliveryReplyMessage = message.getQrCodeDeliveryReplyMessage();


                log.info("二维码下发应答-业务消息处理:{}",qrCodeDeliveryReplyMessage);


                QrCodeDeliveryReply qrCodeDeliveryReply = new QrCodeDeliveryReply();


                BeanUtils.copyProperties(qrCodeDeliveryReplyMessage,qrCodeDeliveryReply);


                qrCodeDeliveryReplyService.create(qrCodeDeliveryReply);


                break;


            case SendTagConstant.SECURITY_DETECTION:


                SecurityDetectionMessage securityDetectionMessage = message.getSecurityDetectionMessage();


                log.info("安全监测-业务消息处理:{}",securityDetectionMessage);


                SecurityDetection securityDetection = new SecurityDetection();


                BeanUtils.copyProperties(securityDetectionMessage,securityDetection);


                securityDetectionService.create(securityDetection);


    


                SecurityDetectionVO securityDetection1 = new SecurityDetectionVO();


                BeanUtils.copyProperties(securityDetection, securityDetection1);


                chargingOrderClient.securityDetection(securityDetection1);


                break;


        }


    }






}