明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2024-08-31 5489c2cc4d35970ca8fe4d30cf8ac374eef17ca4 
 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/UploadRealTimeMonitoringDataMessageListener.java


@@ -5,12 +5,16 @@


import com.ruoyi.integration.mongodb.service.UploadRealTimeMonitoringDataService;


import com.ruoyi.integration.rocket.model.UploadRealTimeMonitoringDataMessage;


import com.ruoyi.integration.rocket.util.EnhanceMessageHandler;


import com.ruoyi.order.api.feignClient.ChargingOrderClient;


import com.ruoyi.order.api.query.UploadRealTimeMonitoringDataQuery;


import lombok.extern.slf4j.Slf4j;


import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;


import org.apache.rocketmq.spring.core.RocketMQListener;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Component;




import javax.annotation.Resource;




@Slf4j


@Component


@@ -24,6 +28,15 @@




    @Autowired


    private UploadRealTimeMonitoringDataService uploadRealTimeMonitoringDataService;


    


    @Resource


    private ChargingOrderClient chargingOrderClient;


    


    


    


    


    


    


    @Override


    protected void handleMessage(UploadRealTimeMonitoringDataMessage message) throws Exception {


        // 此时这里才是最终的业务处理，代码只需要处理资源类关闭异常，其他的可以交给父类重试


@@ -33,6 +46,9 @@


        BeanUtils.copyProperties(message,uploadRealTimeMonitoringData);


        uploadRealTimeMonitoringDataService.create(uploadRealTimeMonitoringData);


        // 业务处理


        UploadRealTimeMonitoringDataQuery query = new UploadRealTimeMonitoringDataQuery();


        BeanUtils.copyProperties(uploadRealTimeMonitoringData, query);


        chargingOrderClient.chargeMonitoring(query);


    }




    @Override