管理端推送邮件或短信

app/admin/controller/Admin.php

@@ -124,4 +124,11 @@ class Admin extends AdminBaseController
         $returnData = (new AdminService())->giveVip($this->request->param());
         return json($returnData);
     }
+
+    // 一键推送消息，邮件或短信
+    public function sendEmailOrSms()
+    {
+        $returnData = (new AdminService())->sendEmailOrSms($this->request->param());
+        return json($returnData);
+    }
 }

app/admin/route/app.php

@@ -14,7 +14,7 @@ $header = [
 //Route::get('/test', 'Test/index');
 Route::post('/test', 'Test/index');
 Route::post('/test_upload', 'Upload/uploadVideo');
-Route::post('test_api', 'Admin/giveVip');
+Route::post('test_api', 'Admin/sendEmailOrSms');
 Route::group('/', function () {
     // 上传图片
     Route::post('/upload', 'Upload/upload');
@@ -208,6 +208,7 @@ Route::group('/', function () {
 
     // 送会员
     Route::post('admin/give_vip', 'Admin/giveVip')->middleware('admin_log');   //赠送用户vip
+    Route::post('admin/send_email_or_sms', 'Admin/sendEmailOrSms');  // 给用户发邮件或者短信
 
     // 配置管理
     // 合约插针行情

app/admin/service/AdminService.php

@@ -23,6 +23,7 @@ use app\utility\UnqId;
 use think\facade\Config;
 use think\facade\Db;
 use think\facade\Log;
+use think\facade\Queue;
 use function Sodium\compare;
 use think\facade\Request;
 
@@ -637,4 +638,35 @@ class AdminService extends AdminBaseService
         }
     }
 
+    public function sendEmailOrSms($param)
+    {
+        try {
+            if (empty($param['user_id'])) {
+                return $this->toData('400', '参数错误');
+            }
+            if (!in_array($param['type'], [1,2])) {
+                return $this->toData('400', '参数错误');
+            }
+
+            // 发送邮件
+            if ($param['type'] == 1) {
+
+            }
+
+            // 发送短信
+            if ($param['type'] == 2) {
+                // 推送短信
+                $to = '18582301860';
+                $content = '测试短信推送';
+                $accessKey = 'LTAI5tMYUS9asodB6n2qSL9Y';
+                $secret = 'TIMy9s5m7mHSPZN4uRahok4GRdWH1p';
+                (new \app\utility\SendSms())->send($to, $content, $accessKey, $secret);
+            }
+
+            return $this->toData('0', 'success');
+        } catch (\Exception $e) {
+            return $this->toData('500', 'The system is busy.', [$e->getMessage(), $e->getTrace()]);
+        }
+    }
+
 }