明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2024-11-01 ea4e6cf0a63fa8470846fd5188da9e912faf661e 
 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/produce/ChargingMessageListener.java


@@ -149,7 +149,7 @@


                BeanUtils.copyProperties(pingMessage,ping);


                pingService.create(ping);


    


                chargingPileClient.updateChargingPileStatus(pingMessage.getCharging_pile_code(), pingMessage.getCharging_gun_status());


                chargingPileClient.updateChargingPileStatus(pingMessage.getCharging_pile_code(), pingMessage.getCharging_gun_code(), pingMessage.getCharging_gun_status());


                break;


            case SendTagConstant.END_CHARGE:


                EndChargeMessage endChargeMessage = message.getEndChargeMessage();


@@ -201,7 +201,7 @@


                    uploadRealTimeMonitoringData.setElectrovalence_all(accountingStrategyDetail.getElectrovalence());


                    uploadRealTimeMonitoringData.setService_charge(accountingStrategyDetail.getServiceCharge());


                    if (Objects.nonNull(data)) {


                        data.setLast_time(new Date());


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


@@ -337,10 +337,12 @@


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


                // 查询mogondb上一条数据


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


                UploadRealTimeMonitoringData uploadRealTimeMonitoringData = new UploadRealTimeMonitoringData();


                BeanUtils.copyProperties(data,uploadRealTimeMonitoringData);


                uploadRealTimeMonitoringData.setStatus(5);


                uploadRealTimeMonitoringDataService.create(uploadRealTimeMonitoringData);


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