Vladimir Bryzgalov
77 lines
2.6 KiB
PHP
77 lines
2.6 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
|
|
namespace Cf7stg;
|
|
|
|
final class Activator
|
|
{
|
|
public const DB_VERSION = '1';
|
|
public const DB_VERSION_OPTION = 'cf7stg_db_version';
|
|
|
|
public static function activate(): void
|
|
{
|
|
self::guard_requirements();
|
|
self::install_table();
|
|
self::schedule_events();
|
|
}
|
|
|
|
public static function deactivate(): void
|
|
{
|
|
wp_clear_scheduled_hook('cf7stg_dispatch');
|
|
wp_clear_scheduled_hook('cf7stg_cleanup');
|
|
}
|
|
|
|
private static function guard_requirements(): void
|
|
{
|
|
if (version_compare(PHP_VERSION, '7.4', '<')) {
|
|
deactivate_plugins(plugin_basename(CF7STG_PLUGIN_FILE));
|
|
wp_die('Плагин CF7 Spam → Telegram требует PHP 7.4 или выше. Текущая: ' . PHP_VERSION);
|
|
}
|
|
global $wp_version;
|
|
if (version_compare($wp_version, '6.0', '<')) {
|
|
deactivate_plugins(plugin_basename(CF7STG_PLUGIN_FILE));
|
|
wp_die('Плагин CF7 Spam → Telegram требует WordPress 6.0 или выше.');
|
|
}
|
|
}
|
|
|
|
private static function install_table(): void
|
|
{
|
|
global $wpdb;
|
|
$table = $wpdb->prefix . 'cf7stg_queue';
|
|
$charset_collate = $wpdb->get_charset_collate();
|
|
|
|
$sql = "CREATE TABLE {$table} (
|
|
id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
|
|
flamingo_post_id BIGINT UNSIGNED NULL,
|
|
form_id BIGINT UNSIGNED NULL,
|
|
source_key VARCHAR(40) NOT NULL DEFAULT 'cf7',
|
|
payload_json LONGTEXT NOT NULL,
|
|
label VARCHAR(10) NOT NULL DEFAULT 'unclear',
|
|
is_retro TINYINT(1) NOT NULL DEFAULT 0,
|
|
status VARCHAR(20) NOT NULL DEFAULT 'pending',
|
|
attempts SMALLINT UNSIGNED NOT NULL DEFAULT 0,
|
|
last_error TEXT NULL,
|
|
next_try_at DATETIME NULL,
|
|
created_at DATETIME NOT NULL,
|
|
sent_at DATETIME NULL,
|
|
PRIMARY KEY (id),
|
|
KEY idx_status_next (status, next_try_at),
|
|
UNIQUE KEY uq_flamingo (flamingo_post_id, is_retro)
|
|
) {$charset_collate};";
|
|
|
|
require_once ABSPATH . 'wp-admin/includes/upgrade.php';
|
|
dbDelta($sql);
|
|
update_option(self::DB_VERSION_OPTION, self::DB_VERSION);
|
|
}
|
|
|
|
private static function schedule_events(): void
|
|
{
|
|
if (!wp_next_scheduled('cf7stg_dispatch')) {
|
|
wp_schedule_event(time() + 60, 'cf7stg_every_minute', 'cf7stg_dispatch');
|
|
}
|
|
if (!wp_next_scheduled('cf7stg_cleanup')) {
|
|
wp_schedule_event(time() + 3600, 'daily', 'cf7stg_cleanup');
|
|
}
|
|
}
|
|
}
|