| | |
|---|
| | | package com.ruoyi.integration.rocket.listener; |
|---|
| | | |
|---|
| | | import com.ruoyi.chargingPile.api.feignClient.AccountingStrategyDetailClient; |
|---|
| | | import com.ruoyi.chargingPile.api.model.TAccountingStrategyDetail; |
|---|
| | | import com.ruoyi.integration.api.model.AcquisitionBillingMode; |
|---|
| | | import com.ruoyi.integration.api.model.AcquisitionBillingModeReply; |
|---|
| | | import com.ruoyi.integration.api.model.Online; |
|---|
| | | import com.ruoyi.integration.iotda.enums.ServiceIdMenu; |
|---|
| | | import com.ruoyi.integration.iotda.utils.produce.IotMessageProduce; |
|---|
| | | import com.ruoyi.integration.iotda.utils.tools.MessageUtil; |
|---|
| | | import com.ruoyi.integration.iotda.utils.tools.StrategyUtil; |
|---|
| | | import com.ruoyi.integration.mongodb.service.AcquisitionBillingModeService; |
|---|
| | | import com.ruoyi.integration.rocket.model.AcquisitionBillingModeMessage; |
|---|
| | | import com.ruoyi.integration.rocket.util.EnhanceMessageHandler; |
|---|
| | |
|---|
| | | import org.springframework.beans.BeanUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.Objects; |
|---|
| | | |
|---|
| | | @Slf4j |
|---|
| | | @Component |
|---|
| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private AcquisitionBillingModeService acquisitionBillingModeService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private AccountingStrategyDetailClient accountingStrategyDetailClient; |
|---|
| | | @Autowired |
|---|
| | | private IotMessageProduce iotMessageProduce; |
|---|
| | | @Autowired |
|---|
| | | private MessageUtil messageUtil; |
|---|
| | | @Override |
|---|
| | | protected void handleMessage(AcquisitionBillingModeMessage message) throws Exception { |
|---|
| | | // 此时这里才是最终的业务处理，代码只需要处理资源类关闭异常，其他的可以交给父类重试 |
|---|
| | |
|---|
| | | AcquisitionBillingMode acquisitionBillingMode = new AcquisitionBillingMode(); |
|---|
| | | BeanUtils.copyProperties(message,acquisitionBillingMode); |
|---|
| | | acquisitionBillingModeService.create(acquisitionBillingMode); |
|---|
| | | // 业务处理 |
|---|
| | | // 业务处理 计费模型请求应答 1=尖阶段，2=峰阶段，3=平阶段，4=谷阶段 |
|---|
| | | List<TAccountingStrategyDetail> accountingStrategyDetails = accountingStrategyDetailClient.getDetailListByCode(message.getCharging_pile_code()).getData(); |
|---|
| | | Map<Integer, TAccountingStrategyDetail> strategyPrice = StrategyUtil.getStrategyPrice(accountingStrategyDetails); |
|---|
| | | // 价格设置 |
|---|
| | | AcquisitionBillingModeReply acquisitionBillingModeReply = new AcquisitionBillingModeReply(); |
|---|
| | | StrategyUtil.setStrategyPrice(strategyPrice,acquisitionBillingModeReply); |
|---|
| | | // 时段设置 |
|---|
| | | StrategyUtil.setTime(accountingStrategyDetails,acquisitionBillingModeReply); |
|---|
| | | iotMessageProduce.sendMessage(acquisitionBillingModeReply.getCharging_pile_code(), ServiceIdMenu.ACQUISITION_BILLING_MODE_REPLY.getKey(),messageUtil.acquisitionBillingModeReply(acquisitionBillingModeReply)); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
