| | |
|---|
| | | acquisitionBillingModeService.create(acquisitionBillingMode); |
|---|
| | | break; |
|---|
| | | case SendTagConstant.UPLOAD_REAL_TIME_MONITORING_DATA: |
|---|
| | | //限制数据处理频率，30秒一次 |
|---|
| | | //限制数据处理频率，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 < 30000){ |
|---|
| | | if(m < 60000){ |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | Object o1 = redisTemplate.opsForValue().get("bms_demand_and_charger_exportation:" + transaction_serial_number1); |
|---|
| | | if(null != o1){ |
|---|
| | | Long m = System.currentTimeMillis() - (Long) o1; |
|---|
| | | if(m < 30000){ |
|---|
| | | if(m < 60000){ |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | Object o2 = redisTemplate.opsForValue().get("bms_information:" + transaction_serial_number2); |
|---|
| | | if(null != o2){ |
|---|
| | | Long m = System.currentTimeMillis() - (Long) o2; |
|---|
| | | if(m < 30000){ |
|---|
| | | if(m < 60000){ |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
