//package com.ruoyi.integration.rocket.produce;
|
//
|
//import com.alibaba.fastjson.JSONObject;
|
//import com.ruoyi.chargingPile.api.feignClient.AccountingStrategyDetailClient;
|
//import com.ruoyi.chargingPile.api.feignClient.ChargingGunClient;
|
//import com.ruoyi.chargingPile.api.feignClient.ChargingPileClient;
|
//import com.ruoyi.chargingPile.api.model.TAccountingStrategyDetail;
|
//import com.ruoyi.chargingPile.api.model.TChargingGun;
|
//import com.ruoyi.chargingPile.api.vo.UpdateChargingPileStatusVo;
|
//import com.ruoyi.integration.api.model.*;
|
//import com.ruoyi.integration.drainage.TCECPushUtil;
|
//import com.ruoyi.integration.iotda.constant.SendTagConstant;
|
//import com.ruoyi.integration.mongodb.service.*;
|
//import com.ruoyi.integration.rocket.model.*;
|
//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.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.stereotype.Component;
|
//import org.springframework.util.StringUtils;
|
//
|
//import javax.annotation.Resource;
|
//import java.math.RoundingMode;
|
//import java.util.Objects;
|
//import java.util.Set;
|
//import java.util.concurrent.LinkedBlockingQueue;
|
//import java.util.concurrent.ThreadPoolExecutor;
|
//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;
|
// @Autowired
|
// private TCECPushUtil tcecPushUtil;
|
//
|
// @Resource
|
// private ChargingPileClient chargingPileClient;
|
// @Resource
|
// private ChargingGunClient chargingGunClient;
|
//
|
// @Resource
|
// private RedisTemplate redisTemplate;
|
// @Autowired
|
// private EnhanceProduce enhanceProduce;
|
//
|
//
|
//
|
//
|
//
|
// public void handleMessage(com.ruoyi.integration.rocket.model.ChargingMessage message){
|
// log.info("rocket收到的消息内容:{}",message);
|
// String serviceId = message.getServiceId();
|
// if(!StringUtils.hasLength(serviceId)){
|
// return;
|
// }
|
// log.info("rocket收到的消息内容:{} {}", serviceId,message);
|
// 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);
|
// // 监管平台推送充电设备状态
|
// SendResult sendResult;
|
// String gunCode = pingMessage.getCharging_pile_code() + pingMessage.getCharging_gun_code();
|
// ChargingMessage chargingMessage = new ChargingMessage();
|
// chargingMessage.setServiceId(SendTagConstant.GUN_STATUS);
|
// GunStatusMessage gunStatusMessage = new GunStatusMessage();
|
// gunStatusMessage.setFullNumber(gunCode);
|
// chargingMessage.setGunStatusMessage(gunStatusMessage);
|
// sendResult = enhanceProduce.gunStatusMessage(chargingMessage);
|
//
|
// 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());
|
// // 订单id
|
// String transactionSerialNumber = endCharge.getTransaction_serial_number();
|
// ChargingOrderMessage chargingOrderMessage = new ChargingOrderMessage();
|
// chargingOrderMessage.setOrderNumber(transactionSerialNumber);
|
// // 推送充电订单信息
|
// ChargingMessage chargingMessage1 = new ChargingMessage();
|
// chargingMessage1.setServiceId(SendTagConstant.ORDER_INFO);
|
// chargingMessage1.setOrderMessage(chargingOrderMessage);
|
// enhanceProduce.orderInfoMessage(chargingMessage1);
|
// // 推送充电订单状态
|
// ChargingMessage chargingMessage2 = new ChargingMessage();
|
// chargingMessage2.setServiceId(SendTagConstant.ORDER_STATUS);
|
// chargingMessage2.setOrderMessage(chargingOrderMessage);
|
// enhanceProduce.orderStatusMessage(chargingMessage2);
|
//// ThreadPoolExecutor threadPoolExecutor1 = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
|
//// threadPoolExecutor1.execute(new Runnable() {
|
//// @Override
|
//// public void run() {
|
//// try {
|
//// TChargingOrder chargingOrder = chargingOrderClient.getOrderByCode(endCharge.getTransaction_serial_number()).getData();
|
//// tcecPushUtil.pushSuperviseNotificationChargeOrderInfo(chargingOrder);
|
//// tcecPushUtil.pushSuperviseNotificationEquipChargeStatus(chargingOrder);
|
//// }catch (Exception e){
|
//// e.printStackTrace();
|
//// System.out.println("充电结束推送监管平台失败："+e.getMessage());
|
//// }
|
//// }
|
//// });
|
// 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:
|
// try {
|
// UploadRealTimeMonitoringDataMessage uploadRealTimeMonitoringDataMessage = message.getUploadRealTimeMonitoringDataMessage();
|
// 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());
|
//// uploadRealTimeMonitoringData.setStartTime(chargingOrder.getStartTime());
|
//// uploadRealTimeMonitoringData.setEndTime(chargingOrder.getEndTime());
|
// int i = uploadRealTimeMonitoringDataService.create(uploadRealTimeMonitoringData);
|
// if(i == 0){
|
// log.error("数据存储mongo失败");
|
// }
|
//
|
// // 业务处理
|
// UploadRealTimeMonitoringDataQuery query = new UploadRealTimeMonitoringDataQuery();
|
// BeanUtils.copyProperties(uploadRealTimeMonitoringData, query);
|
// chargingOrderClient.chargeMonitoring(query);
|
// // 订单id
|
// ChargingOrderMessage chargingOrderMessage3 = new ChargingOrderMessage();
|
// chargingOrderMessage3.setOrderNumber(chargingOrder.getCode());
|
// // 推送充电订单信息
|
// ChargingMessage chargingMessage4 = new ChargingMessage();
|
// chargingMessage4.setServiceId(SendTagConstant.ORDER_STATUS);
|
// chargingMessage4.setOrderMessage(chargingOrderMessage3);
|
// enhanceProduce.orderInfoMessage(chargingMessage4);
|
//// ThreadPoolExecutor threadPoolExecutor2 = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
|
//// threadPoolExecutor2.execute(new Runnable() {
|
//// @Override
|
//// public void run() {
|
//// chargingOrder.setEndSoc(uploadRealTimeMonitoringDataMessage.getSoc()+"");
|
////
|
//// tcecPushUtil.pushSuperviseNotificationEquipChargeStatus(chargingOrder);
|
//// }
|
//// });
|
// } 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);
|
//
|
// ThreadPoolExecutor threadPoolExecutor3 = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
|
// threadPoolExecutor3.execute(new Runnable() {
|
// @Override
|
// public void run() {
|
// // 业务处理
|
// 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);
|
// // 持久化消息
|
// 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);
|
// // 持久化消息
|
// 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(message));
|
// // 持久化消息
|
// TransactionRecord transactionRecord = new TransactionRecord();
|
// BeanUtils.copyProperties(transactionRecordMessage,transactionRecord);
|
// 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);
|
// int code = chargingOrderClient.endChargeBillingCharge(vo).getCode();
|
// if(200 != code){
|
// //失败后添加到队列中继续处理数据
|
// redisTemplate.opsForSet().add(SendTagConstant.TRANSACTION_RECORD, transactionRecordMessage.getTransaction_serial_number());
|
// }
|
//
|
//
|
// // 添加实时上传记录结束记录
|
// // 查询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;
|
// default:
|
// PlatformRemoteUpdateReplyMessage platformRemoteUpdateReplyMessage = message.getPlatformRemoteUpdateReplyMessage();
|
// log.info("远程更新应答-业务消息处理:{}",platformRemoteUpdateReplyMessage);
|
// PlatformRemoteUpdateReply platformRemoteUpdateReply = new PlatformRemoteUpdateReply();
|
// BeanUtils.copyProperties(platformRemoteUpdateReplyMessage,platformRemoteUpdateReply);
|
// platformRemoteUpdateReplyService.create(platformRemoteUpdateReply);
|
// break;
|
// }
|
// }
|
//
|
//
|
//}
|
