明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2024-09-03 85c4410b0948799a93f19f345b4ed18c253c89f3 
 ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/listener/PingMessageListener.java


@@ -2,6 +2,10 @@




import com.ruoyi.integration.api.model.Online;


import com.ruoyi.integration.api.model.Ping;


import com.ruoyi.integration.api.model.Pong;


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.mongodb.service.OnlineService;


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


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


@@ -25,7 +29,10 @@




    @Autowired


    private PingService pingService;




    @Autowired


    private MessageUtil messageUtil;


    @Autowired


    private IotMessageProduce iotMessageProduce;


    @Override


    protected void handleMessage(PingMessage message) throws Exception {


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


@@ -35,6 +42,12 @@


        BeanUtils.copyProperties(message,ping);


        pingService.create(ping);


        // 业务处理


        Pong pong = new Pong();


        pong.setCharging_pile_code(message.getCharging_pile_code());


        pong.setCharging_gun_code(message.getCharging_gun_code());


        pong.setCharging_gun_status(0);


        String result = iotMessageProduce.sendMessage(pong.getCharging_pile_code(), ServiceIdMenu.PONG.getKey(), messageUtil.pong(pong));


        log.info("充电桩心跳包-返回结果：{}",result);


    }




    @Override