lkddi/nexusphp
1
0
Fork 0
mirror of https://github.com/lkddi/nexusphp.git synced 2026-06-15 16:22:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

send staff message to telegram

Browse Source
This commit is contained in:
xiaomlove
2026-06-12 17:47:08 +07:00
parent e4cdb26c2f
commit fab32bf63d
7 changed files with 66 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Enums/ModelEventEnum.php
+6
View File
@@ -14,6 +14,7 @@ use App\Events\HitAndRunUpdated;
use App\Events\MessageCreated;
use App\Events\NewsCreated;
use App\Events\SnatchedUpdated;
use App\Events\StaffMessageCreated;
use App\Events\TorrentCreated;
use App\Events\TorrentDeleted;
use App\Events\TorrentUpdated;
@@ -28,6 +29,7 @@ use App\Models\HitAndRun;
use App\Models\Message;
use App\Models\News;
use App\Models\Snatch;
use App\Models\StaffMessage;
use App\Models\Torrent;
use App\Models\User;
@@ -59,6 +61,8 @@ final class ModelEventEnum {
const SNATCHED_UPDATED = 'snatched_updated';
const MESSAGE_CREATED = 'message_created';
const STAFF_MESSAGE_CREATED = 'staff_message_created';
public static array $eventMaps = [
self::TORRENT_CREATED => ['event' => TorrentCreated::class, 'model' => Torrent::class],
self::TORRENT_UPDATED => ['event' => TorrentUpdated::class, 'model' => Torrent::class],
@@ -87,5 +91,7 @@ final class ModelEventEnum {
self::AGENT_DENY_CREATED => ['event' => AgentDenyCreated::class, 'model' => AgentDeny::class],
self::AGENT_DENY_UPDATED => ['event' => AgentDenyUpdated::class, 'model' => AgentDeny::class],
self::AGENT_DENY_DELETED => ['event' => AgentDenyDeleted::class, 'model' => AgentDeny::class],
self::STAFF_MESSAGE_CREATED => ['event' => StaffMessageCreated::class, 'model' => StaffMessage::class],
];
}
app/Events/StaffMessageCreated.php
+39
View File
@@ -0,0 +1,39 @@
<?php
namespace App\Events;
use Illuminate\Broadcasting\Channel;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;
class StaffMessageCreated
{
use Dispatchable, InteractsWithSockets, SerializesModels;
public ?Model $model = null;
/**
* Create a new event instance.
*
* @return void
*/
public function __construct(Model $model)
{
$this->model = $model;
}
/**
* Get the channels the event should broadcast on.
*
* @return \Illuminate\Broadcasting\Channel|array
*/
public function broadcastOn()
{
return new PrivateChannel('channel-name');
}
}
app/Models/StaffMessage.php
+13 -2
View File
@@ -2,8 +2,7 @@
namespace App\Models;
use App\Repositories\ToolRepository;
use Google\Service\Testing\ToolResultsExecution;
use App\Enums\ModelEventEnum;
class StaffMessage extends NexusModel
{
@@ -27,4 +26,16 @@ class StaffMessage extends NexusModel
return $this->belongsTo(User::class, 'answeredby');
}
public static function add(int $sender, string $subject, string $msg)
{
$record = self::query()->create([
'sender' => $sender,
'subject' => $subject,
'msg' => $msg,
'added' => now(),
]);
fire_event(ModelEventEnum::STAFF_MESSAGE_CREATED, $record);
return $record;
}
}
include/constants.php
+2 -2
View File
@@ -1,6 +1,6 @@
<?php
defined('VERSION_NUMBER') || define('VERSION_NUMBER', '1.10.2');
defined('RELEASE_DATE') || define('RELEASE_DATE', '2026-04-11');
defined('VERSION_NUMBER') || define('VERSION_NUMBER', '1.10.3');
defined('RELEASE_DATE') || define('RELEASE_DATE', '2026-06-12');
defined('IN_TRACKER') || define('IN_TRACKER', false);
defined('PROJECTNAME') || define("PROJECTNAME","NexusPHP");
defined('NEXUSPHPURL') || define("NEXUSPHPURL","https://nexusphp.org");
public/linksmanage.php
+2 -4
View File
@@ -65,13 +65,11 @@ elseif (strlen($reason) < 20)
stderr($lang_linksmanage['std_error'], $lang_linksmanage['std_reason_too_short']);
else{
$message = "[b]Sitename[/b]: ".$sitename."\n[b]URL[/b]: ".$url."\n[b]Title[/b]: ".$title."\n[b]Administrator: [/b]".$admin."\n[b]EMail[/b]: ".$email."\n[b]Reason[/b]: \n".$reason."\n";
$message = sqlesc($message);
$subject = $sitename." applys for links";
$subject = sqlesc($subject);
$added = "'" . date("Y-m-d H:i:s") . "'";
$userid = $CURUSER['id'];
sql_query("INSERT INTO staffmessages (sender, added, msg, subject) VALUES($userid, $added, $message, $subject)") or sqlerr(__FILE__, __LINE__);
stderr($lang_linksmanage['std_success'], $lang_linksmanage['std_success_note']);
\App\Models\StaffMessage::add($userid, $subject, $message);
stderr($lang_linksmanage['std_success'], $lang_linksmanage['std_success_note']);
}
}
else permissiondenied();
public/takecontact.php
+1 -3
View File
@@ -18,8 +18,6 @@ if (!$subject)
$added = "'" . date("Y-m-d H:i:s") . "'";
$userid = $CURUSER['id'];
$message = sqlesc($msg);
$subject = sqlesc($subject);
// Anti Flood Code
// This code ensures that a member can only send one PM per minute.
@@ -30,7 +28,7 @@ if (get_user_class() < UC_MODERATOR) {
stderr($lang_takecontact['std_error'],$lang_takecontact['std_message_flooding'].$secs.$lang_takecontact['std_second'].($secs == 1 ? '' : $lang_takecontact['std_s']).$lang_takecontact['std_before_sending_pm']);
}
}
sql_query("INSERT INTO staffmessages (sender, added, msg, subject) VALUES($userid, $added, $message, $subject)") or sqlerr(__FILE__, __LINE__);
\App\Models\StaffMessage::add($userid, $subject, $msg);
// Update Last PM sent...
sql_query("UPDATE users SET last_staffmsg = NOW() WHERE id = ".sqlesc($CURUSER['id'])) or sqlerr(__FILE__, __LINE__);
$Cache->delete_value('staff_message_count');
public/takemessage.php
+3 -3
View File
@@ -60,7 +60,7 @@ if ($_SERVER["REQUEST_METHOD"] != "POST")
$save = ($save == 'yes') ? "yes" : "no";
// End of Change
$res = sql_query("SELECT id,username,parked,email,acceptpms, notifs, UNIX_TIMESTAMP(last_access) as la FROM users WHERE id=".sqlesc($receiver)) or sqlerr(__FILE__, __LINE__);
$res = sql_query("SELECT id,username,parked,email,acceptpms, notifs, ".\Nexus\Database\NexusDB::unixTimestampField("last_access")." as la FROM users WHERE id=".$receiver) or sqlerr(__FILE__, __LINE__);
$user = mysql_fetch_assoc($res);
if (!$user)
stderr($lang_takemessage['std_error'], $lang_takemessage['std_user_not_exist']);
@@ -88,7 +88,7 @@ if ($_SERVER["REQUEST_METHOD"] != "POST")
$subject = trim($_POST['subject']);
\App\Models\Message::add([
$messageRecord = \App\Models\Message::add([
'sender' => $CURUSER["id"],
'receiver' => $receiver,
'msg' => $msg,
@@ -100,7 +100,7 @@ if ($_SERVER["REQUEST_METHOD"] != "POST")
$Cache->delete_value('user_'.$CURUSER["id"].'_outbox_count');
$msgid=mysql_insert_id();
$msgid=$messageRecord->id;
$date=date("Y-m-d H:i:s");
// Update Last PM sent...
sql_query("UPDATE users SET last_pm = NOW() WHERE id = ".sqlesc($CURUSER['id'])) or sqlerr(__FILE__, __LINE__);