package com.matrix.system.shopXcx.mqTask;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.matrix.system.hive.dao.OnlinebookingDao;
|
import com.matrix.system.hive.dao.SysShopInfoDao;
|
import com.matrix.system.shopXcx.dao.ShopProductDao;
|
import com.matrix.system.shopXcx.dao.ShopWxtemplateMsgDao;
|
import com.matrix.system.shopXcx.mqTask.templateMsg.AppointmentSuccess;
|
import com.matrix.system.shopXcx.shopEnum.TemplateMsgType;
|
import com.rabbitmq.client.DeliverCallback;
|
import com.rabbitmq.client.Delivery;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.io.IOException;
|
|
/**
|
* 发送预约成功提醒消息
|
*/
|
public class TemplateMsgTask implements DeliverCallback {
|
|
@Autowired
|
OnlinebookingDao onlinebookingDao;
|
@Autowired
|
SysShopInfoDao shopInfoDao;
|
@Autowired
|
ShopProductDao productDao;
|
|
@Autowired
|
ShopWxtemplateMsgDao wxtemplateMsgDao;
|
|
@Autowired
|
AppointmentSuccess appointmentSuccess;
|
|
|
@Override
|
public void handle(String consumerTag, Delivery message) throws IOException {
|
|
String msg = new String(message.getBody(), "UTF-8");
|
JSONObject object = JSONObject.parseObject(msg);
|
Integer templateMsgType = (Integer) object.get("templateMsgType");
|
String content = object.get("content") + "";
|
|
if (TemplateMsgType.APPOINTMENT_SUCCESS.getCode().equals(templateMsgType)) {
|
appointmentSuccess.sendTemplateMsg(content);
|
}
|
|
|
}
|
}
|
