修改消息推送

app/Amqp/Consumer/SendStationMessageConsumer.php

@@ -138,6 +138,11 @@ class SendStationMessageConsumer extends ConsumerMessage
             }
         }
 
+        // 消息标题
+        if (!isset($push_data['notice_title']) && !isset($push_data['notice_brief_type'])){
+            return false;
+        }
+
         return true;
     }
 

app/Amqp/Consumer/SendSubMessageConsumer.php

@@ -85,6 +85,8 @@ class SendSubMessageConsumer extends ConsumerMessage
                 return Result::DROP;
             }
 
+            Log::getInstance()->info("订阅消息推送数据记录：" . json_encode($send_data,JSON_UNESCAPED_UNICODE));
+
             // 获取open_id
             $UserService = new UserService();
             $open_id = $UserService->getOpenIdWithUserId($user['user_id'],$user['user_type']);