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){
|
String serviceId = message.getServiceId();
|
if(!StringUtils.hasLength(serviceId)){
|
return;
|
}
|
switch (serviceId){
|
case SendTagConstant.ONLINE:
|
OnlineMessage onlineMessage = message.getOnlineMessage();
|
// 持久化消息
|
Online online = new Online();
|
BeanUtils.copyProperties(onlineMessage,online);
|
onlineService.create(online);
|
break;
|
case SendTagConstant.PING:
|
PingMessage pingMessage = message.getPingMessage();
|
// 持久化消息
|
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();
|
// 持久化消息
|
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();
|
// 持久化消息
|
// ErrorMessageMessage errorMessageMessage = new ErrorMessageMessage();
|
// BeanUtils.copyProperties(errorMessageMessage1,errorMessageMessage);
|
// errorMessageMessageService.create(errorMessageMessage);
|
break;
|
case SendTagConstant.BILLING_MODE_VERIFY:
|
BillingModeVerifyMessage billingModeVerifyMessage = message.getBillingModeVerifyMessage();
|
// 持久化消息
|
// BillingModeVerify billingModeVerify = new BillingModeVerify();
|
// BeanUtils.copyProperties(billingModeVerifyMessage,billingModeVerify);
|
// billingModeVerifyService.create(billingModeVerify);
|
break;
|
case SendTagConstant.ACQUISITION_BILLING_MODE:
|
AcquisitionBillingModeMessage acquisitionBillingModeMessage = message.getAcquisitionBillingModeMessage();
|
// 持久化消息
|
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 {
|
// 持久化消息
|
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 {
|
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();
|
// 持久化消息
|
ChargingHandshake chargingHandshake = new ChargingHandshake();
|
BeanUtils.copyProperties(chargingHandshakeMessage,chargingHandshake);
|
chargingHandshakeService.create(chargingHandshake);
|
break;
|
case SendTagConstant.PARAMETER_SETTING:
|
ParameterSettingMessage parameterSettingMessage = message.getParameterSettingMessage();
|
// 持久化消息
|
// ParameterSetting parameterSetting = new ParameterSetting();
|
// BeanUtils.copyProperties(parameterSettingMessage,parameterSetting);
|
// parameterSettingService.create(parameterSetting);
|
break;
|
case SendTagConstant.BMS_ABORT:
|
BmsAbortMessage bmsAbortMessage = message.getBmsAbortMessage();
|
// 持久化消息
|
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();
|
// 持久化消息
|
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();
|
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();
|
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();
|
// 持久化消息
|
ChargingPileStartsCharging chargingPileStartsCharging = new ChargingPileStartsCharging();
|
BeanUtils.copyProperties(chargingPileStartsChargingMessage,chargingPileStartsCharging);
|
chargingPileStartsChargingService.create(chargingPileStartsCharging);
|
break;
|
case SendTagConstant.PLATFORM_START_CHARGING_REPLY:
|
PlatformStartChargingReplyMessage platformStartChargingReplyMessage = message.getPlatformStartChargingReplyMessage();
|
// 持久化消息
|
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();
|
// 持久化消息
|
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();
|
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();
|
// 持久化消息
|
UpdateBalanceReply updateBalanceReply = new UpdateBalanceReply();
|
BeanUtils.copyProperties(updateBalanceReplyMessage,updateBalanceReply);
|
updateBalanceReplyService.create(updateBalanceReply);
|
break;
|
case SendTagConstant.SYNCHRONIZE_OFFLINE_CARD_REPLY:
|
SynchronizeOfflineCardReplyMessage synchronizeOfflineCardReplyMessage = message.getSynchronizeOfflineCardReplyMessage();
|
// 持久化消息
|
SynchronizeOfflineCardReply synchronizeOfflineCardReply = new SynchronizeOfflineCardReply();
|
BeanUtils.copyProperties(synchronizeOfflineCardReplyMessage,synchronizeOfflineCardReply);
|
synchronizeOfflineCardReplyService.create(synchronizeOfflineCardReply);
|
break;
|
case SendTagConstant.CLEAR_OFFLINE_CARD_REPLY:
|
ClearOfflineCardReplyMessage clearOfflineCardReplyMessage = message.getClearOfflineCardReplyMessage();
|
// 持久化消息
|
ClearOfflineCardReply clearOfflineCardReply = new ClearOfflineCardReply();
|
BeanUtils.copyProperties(clearOfflineCardReplyMessage,clearOfflineCardReply);
|
clearOfflineCardReplyService.create(clearOfflineCardReply);
|
break;
|
case SendTagConstant.WORKING_PARAMETER_SETTING_REPLY:
|
WorkingParameterSettingReplyMessage workingParameterSettingReplyMessage = message.getWorkingParameterSettingReplyMessage();
|
// 持久化消息
|
WorkingParameterSettingReply workingParameterSettingReply = new WorkingParameterSettingReply();
|
BeanUtils.copyProperties(workingParameterSettingReplyMessage,workingParameterSettingReply);
|
workingParameterSettingReplyService.create(workingParameterSettingReply);
|
break;
|
case SendTagConstant.TIMING_SETTING:
|
TimingSettingMessage timingSettingMessage = message.getTimingSettingMessage();
|
// 持久化消息
|
// TimingSetting timingSetting = new TimingSetting();
|
// BeanUtils.copyProperties(timingSettingMessage,timingSetting);
|
// timingSettingService.create(timingSetting);
|
break;
|
case SendTagConstant.SETUP_BILLING_MODEL_REPLY:
|
SetupBillingModelReplyMessage setupBillingModelReplyMessage = message.getSetupBillingModelReplyMessage();
|
// 持久化消息
|
SetupBillingModelReply setupBillingModelReply = new SetupBillingModelReply();
|
BeanUtils.copyProperties(setupBillingModelReplyMessage,setupBillingModelReply);
|
setupBillingModelReplyService.create(setupBillingModelReply);
|
break;
|
case SendTagConstant.GROUND_LOCK_REAL_TIME_DATA:
|
GroundLockRealTimeDataMessage groundLockRealTimeDataMessage = message.getGroundLockRealTimeDataMessage();
|
// 持久化消息
|
GroundLockRealTimeData groundLockRealTimeData = new GroundLockRealTimeData();
|
BeanUtils.copyProperties(groundLockRealTimeDataMessage,groundLockRealTimeData);
|
groundLockRealTimeDataService.create(groundLockRealTimeData);
|
break;
|
case SendTagConstant.CHARGING_PILE_RETURNS_GROUND_LOCK_DATA:
|
ChargingPileReturnsGroundLockDataMessage chargingPileReturnsGroundLockDataMessage = message.getChargingPileReturnsGroundLockDataMessage();
|
// 持久化消息
|
ChargingPileReturnsGroundLockData chargingPileReturnsGroundLockData = new ChargingPileReturnsGroundLockData();
|
BeanUtils.copyProperties(chargingPileReturnsGroundLockDataMessage,chargingPileReturnsGroundLockData);
|
chargingPileReturnsGroundLockDataService.create(chargingPileReturnsGroundLockData);
|
break;
|
case SendTagConstant.PLATFORM_RESTART_REPLY:
|
PlatformRestartReplyMessage platformRestartReplyMessage = message.getPlatformRestartReplyMessage();
|
// 持久化消息
|
PlatformRestartReply platformRestartReply = new PlatformRestartReply();
|
BeanUtils.copyProperties(platformRestartReplyMessage,platformRestartReply);
|
platformRestartReplyService.create(platformRestartReply);
|
break;
|
case SendTagConstant.QR_CODE_DELIVERY_REPLY:
|
QrCodeDeliveryReplyMessage qrCodeDeliveryReplyMessage = message.getQrCodeDeliveryReplyMessage();
|
QrCodeDeliveryReply qrCodeDeliveryReply = new QrCodeDeliveryReply();
|
BeanUtils.copyProperties(qrCodeDeliveryReplyMessage,qrCodeDeliveryReply);
|
qrCodeDeliveryReplyService.create(qrCodeDeliveryReply);
|
break;
|
case SendTagConstant.SECURITY_DETECTION:
|
SecurityDetectionMessage securityDetectionMessage = message.getSecurityDetectionMessage();
|
SecurityDetection securityDetection = new SecurityDetection();
|
BeanUtils.copyProperties(securityDetectionMessage,securityDetection);
|
securityDetectionService.create(securityDetection);
|
|
SecurityDetectionVO securityDetection1 = new SecurityDetectionVO();
|
BeanUtils.copyProperties(securityDetection, securityDetection1);
|
chargingOrderClient.securityDetection(securityDetection1);
|
break;
|
}
|
}
|
|
|
}
|
