pushdeer/api/app/Http/Controllers/PushDeerMessageController.php
2022-06-27 00:33:35 +08:00

158 lines
5.1 KiB
PHP
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

<?php
namespace App\Http\Controllers;
use Illuminate\Http\Request;
use Illuminate\Support\Str;
use App\Models\PushDeerUser;
use App\Models\PushDeerKey;
use App\Models\PushDeerDevice;
use App\Models\PushDeerMessage as Message;
use App\Models\PushDeerMessage;
class PushDeerMessageController extends Controller
{
public function list(Request $request)
{
$validated = $request->validate(
[
'limit' => 'integer|nullable',
'since_id' => 'integer|nullable',
]
);
$limit = !isset($validated['limit']) ? 10 : intval($validated['limit']);
if ($limit > 100) {
$limit = 100;
}
if (isset($validated['since_id']) && intval($validated['since_id']) > 0) {
$pd_sql = Message::where('uid', $_SESSION['uid'])->where('id', '>', intval($validated['since_id']));
} else {
$pd_sql = Message::where('uid', $_SESSION['uid']);
}
$pd_messages = $pd_sql->orderBy('id', 'DESC')->offset(0)->limit($limit)->get(['id', 'uid', 'text', 'desp', 'type','pushkey_name','created_at']);
return http_result(['messages' => $pd_messages]);
}
//
public function push(Request $request)
{
$validated = $request->validate(
[
'pushkey' => 'string|required',
'text' => 'string|required',
'desp' => 'string|nullable',
'type' => 'string|nullable',
]
);
if (!isset($validated['desp'])) {
$validated['desp'] = '';
}
if (!isset($validated['type'])) {
$validated['type'] = 'markdown';
}
$result = [];
$keys = explode(",", $validated['pushkey']);
// 去掉重复的key
$keys = array_unique($keys);
// 限制key的数量
$keys = array_slice($keys, 0, intval(env('MAX_PUSH_KEY_PER_TIME')));
foreach ($keys as $thekey) {
$key = PushDeerKey::where('key', $thekey)->get()->first();
$user = PushDeerUser::where('id', $key->uid)->get()->first();
if ($user->level < 1) {
return send_error('此账号已被停用', ErrorCode('ARGS'));
}
if ($key) {
$readkey = Str::random(32);
$the_message = [];
$the_message['uid'] = $key->uid;
$the_message['text'] = $validated['text'];
$the_message['desp'] = $validated['desp'];
$the_message['type'] = $validated['type'];
$the_message['readkey'] = $readkey;
$the_message['pushkey_name'] = $key->name;
$pd_message = Message::create($the_message);
// 因为通知是悬浮显示所以将URL改为文字提示
// 如果需要访问原始内容,使用 $the_message['text']
if (strtolower($validated['type'])=='image') {
$validated['text'] = '[图片]';
}
$sent = false;
// 如果配置MQTT服务
// if (strtolower(env('MQTT_ON')) == 'true') {
if (env('MQTT_ON') > 0) {
// 给 mqtt/send 转发消息
$result[] = make_post('http://mqtt/send', [
'key' => env('MQTT_API_KEY'),
'content' => $the_message['text'],
'payload' => json_encode($the_message),
'type' => $validated['type'] == 'image' ? 'bg_url' : 'text',
'topic' => $thekey,
], 3);
}
if ($devices = PushDeerDevice::where('uid', $key->uid)->get()) {
foreach ($devices as $device) {
if ($device) {
$func_name = $device['type'].'_send';
if (function_exists($func_name)) {
$result[] = $func_name($device->is_clip, $device->device_id, $validated['text'], '', env('APP_DEBUG'));
}
}
}
} else {
if (!$sent) {
return send_error('没有可用的设备,请先注册', ErrorCode('ARGS'));
}
}
}
}
return http_result(['result'=>$result]);
}
public function remove(Request $request)
{
$validated = $request->validate(
[
'id' => 'integer|required',
]
);
if ($pd_message = PushDeerMessage::where('id', $validated['id'])->get(['id', 'uid', 'text', 'desp', 'type','created_at'])->first()) {
if ($pd_message->uid == $_SESSION['uid']) {
$pd_message->delete();
return http_result(['message'=>'done']);
}
}
return send_error('消息不存在或已删除', ErrorCode('ARGS'));
}
public function clean(Request $request)
{
PushDeerMessage::where('uid', $_SESSION['uid'])->delete();
return http_result(['message'=>'done']);
}
}