| | |
|---|
| | | import com.ruoyi.integration.mongodb.service.BmsAbortService; |
|---|
| | | import com.ruoyi.integration.rocket.model.BmsAbortMessage; |
|---|
| | | 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 |
|---|
| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private BmsAbortService bmsAbortService; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private ChargingOrderClient chargingOrderClient; |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | protected void handleMessage(BmsAbortMessage message) throws Exception { |
|---|
| | | // 此时这里才是最终的业务处理，代码只需要处理资源类关闭异常，其他的可以交给父类重试 |
|---|
| | |
|---|
| | | BeanUtils.copyProperties(message,bmsAbort); |
|---|
| | | bmsAbortService.create(bmsAbort); |
|---|
| | | // 业务处理 |
|---|
| | | chargingOrderClient.excelEndCharge(bmsAbort.getTransaction_serial_number()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
