| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private PingService pingService; |
|---|
| | | @Autowired |
|---|
| | | private MessageUtil messageUtil; |
|---|
| | | @Autowired |
|---|
| | | private IotMessageProduce iotMessageProduce; |
|---|
| | | @Override |
|---|
| | | protected void handleMessage(PingMessage message) throws Exception { |
|---|
| | | // 此时这里才是最终的业务处理，代码只需要处理资源类关闭异常，其他的可以交给父类重试 |
|---|
| | |
|---|
| | | 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 |
|---|
