package com.ruoyi.integration.rocket.listener;

import com.ruoyi.integration.api.model.QrCodeDeliveryReply;
import com.ruoyi.integration.mongodb.service.QrCodeDeliveryReplyService;
import com.ruoyi.integration.rocket.model.AcquisitionBillingModeMessage;
import com.ruoyi.integration.rocket.model.QrCodeDeliveryReplyMessage;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.MessageModel;
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;

/**
 * @author zhibing.pu
 * @Date 2025/4/28 14:57
 */
@Slf4j
@Component
@RocketMQMessageListener(
		messageModel = MessageModel.CLUSTERING,
		consumerGroup = "charge_qr_code_delivery_reply",
		topic = "charge_qr_code_delivery_reply",
		selectorExpression = "qr_code_delivery_reply"
)
public class QrCodeDeliveryReplyMessageListener implements RocketMQListener<QrCodeDeliveryReplyMessage> {
	
	@Autowired
	private QrCodeDeliveryReplyService qrCodeDeliveryReplyService;
	
	
	@Override
	public void onMessage(QrCodeDeliveryReplyMessage message) {
		log.info("二维码下发应答-业务消息处理:{}",message);
		QrCodeDeliveryReply qrCodeDeliveryReply = new QrCodeDeliveryReply();
		BeanUtils.copyProperties(message,qrCodeDeliveryReply);
		qrCodeDeliveryReplyService.create(qrCodeDeliveryReply);
	}
}