|
@@ -653,12 +653,12 @@ class PostRepository
|
|
|
//内容被设为推荐时，发送推送消息
|
|
//内容被设为推荐时，发送推送消息
|
|
|
if($post->is_suggest==1){
|
|
if($post->is_suggest==1){
|
|
|
$title = $post['title'] ? $post['title'] : subtext($post['content'], 18);
|
|
$title = $post['title'] ? $post['title'] : subtext($post['content'], 18);
|
|
|
- $rabbitmq = new RabbitMqUtil();
|
|
|
|
|
$push['uid'] = $post->uid;
|
|
$push['uid'] = $post->uid;
|
|
|
$push['title'] = '【由你内容】推荐通知';
|
|
$push['title'] = '【由你内容】推荐通知';
|
|
|
$push['text'] = '你的内容《'.$title.'》被小编推荐全平台优先展示喽，获得推荐位后你的内容会被更多人看到。记得多来和大家互动赚取更多U米~';
|
|
$push['text'] = '你的内容《'.$title.'》被小编推荐全平台优先展示喽，获得推荐位后你的内容会被更多人看到。记得多来和大家互动赚取更多U米~';
|
|
|
- $rabbitmq->push('send_push_msg_queue',$push);
|
|
|
|
|
|
|
+ Redis::LPUSH('send_push_msg_queue',json_encode($push));
|
|
|
|
|
|
|
|
|
|
+ $rabbitmq = new RabbitMqUtil();
|
|
|
$rabbitmq->push('add_message_one', [
|
|
$rabbitmq->push('add_message_one', [
|
|
|
'uid' => $post->uid,
|
|
'uid' => $post->uid,
|
|
|
'message_rule_id' => 0,
|
|
'message_rule_id' => 0,
|
xielin