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


@@ -11,12 +11,15 @@


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


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


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


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


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


@@ -34,6 +37,12 @@


    private MessageUtil messageUtil;


    @Autowired


    private IotMessageProduce iotMessageProduce;


    


    @Resource


    private ChargingOrderClient chargingOrderClient;


    


    


    


    @Override


    protected void handleMessage(EndChargeMessage message) throws Exception {


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


@@ -43,6 +52,7 @@


        BeanUtils.copyProperties(message,endCharge);


        endChargeService.create(endCharge);


        // 业务处理


        chargingOrderClient.endCharge(endCharge.getTransaction_serial_number());


    }




    @Override