新增消息推送，修改订阅消息推送队列

app/Amqp/Consumer/SendSubMessageConsumer.php

@@ -98,18 +98,6 @@ class SendSubMessageConsumer extends ConsumerMessage
                 return Result::ACK;
             }
 
-            // 获取消息模版
-            $sub_template = $this->getSubTemplate($user['user_type'],$data['sub_data']['template_title']);
-            if (empty($sub_template)){
-                Log::getInstance()->error("订阅消息推送执行失败：未获取到需要发送的消息模版数据");
-                $this->saveErrorPushLog($user['user_type'],$data['sub_data'],"未获取到需要发送的消息模版数据");
-
-                // 执行发送短信步骤
-                $this->addSendSmsMessageQueue($data['sms_data']);
-
-                return Result::ACK;
-            }
-
             // 处理发送环境
 //            $miniprogram_state = "developer";
             $miniprogram_state = "trial";
@@ -118,16 +106,14 @@ class SendSubMessageConsumer extends ConsumerMessage
             }
 
             $options = [
-                "template_id" => $sub_template['wx_template_id'],
-                "page" => $sub_template['page'] ?: $data['sub_data']['params']['page'] ?: "",
+                "template_id" => $data['sub_data']['wx_template_id'],
+                "page" => $data['sub_data']['params']['page'] ?: "",
                 "touser" => $open_id,
                 "data" => $send_data,
                 "miniprogram_state" => $miniprogram_state,
                 "lang" => "zh_CN",
             ];
 
-            dump($options);
-
             // 发起推送
             $Wechat = new Wechat($user['user_type']);
             $result = $Wechat->sendSubscribeMessage($options);