|
@@ -28,17 +28,11 @@ class notifyConsumer implements ConsumerInterface
|
|
|
try {
|
|
try {
|
|
|
// 反序列化消息体
|
|
// 反序列化消息体
|
|
|
$data = unserialize($msg->body);
|
|
$data = unserialize($msg->body);
|
|
|
-
|
|
|
|
|
- print_r($data);
|
|
|
|
|
- print_r('done！！！！！！！');
|
|
|
|
|
-
|
|
|
|
|
if (!is_array($data)) {
|
|
if (!is_array($data)) {
|
|
|
Yii::error("Invalid notify message format: {$msg->body}", 'rabbitmq.notify');
|
|
Yii::error("Invalid notify message format: {$msg->body}", 'rabbitmq.notify');
|
|
|
return ConsumerInterface::MSG_REJECT;
|
|
return ConsumerInterface::MSG_REJECT;
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
Yii::info("Processing notify message: " . json_encode($data), 'rabbitmq.notify');
|
|
Yii::info("Processing notify message: " . json_encode($data), 'rabbitmq.notify');
|
|
|
-
|
|
|
|
|
// 根据通知类型分发处理
|
|
// 根据通知类型分发处理
|
|
|
$type = $data['type'] ?? null;
|
|
$type = $data['type'] ?? null;
|
|
|
switch ($type) {
|
|
switch ($type) {
|
