Vladimir Bryzgalov
67 lines
2.3 KiB
PHP
67 lines
2.3 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
|
|
namespace Cf7stg;
|
|
|
|
final class RetroImporter
|
|
{
|
|
public const MAX_COUNT = 50;
|
|
|
|
/**
|
|
* @return array{added:int,skipped:int}
|
|
*/
|
|
public static function import(int $count, int $days, bool $allow_repeat): array
|
|
{
|
|
$count = max(1, min(self::MAX_COUNT, $count));
|
|
$args = [
|
|
'post_type' => 'flamingo_inbound',
|
|
'post_status' => 'flamingo-spam',
|
|
'orderby' => 'date',
|
|
'order' => 'DESC',
|
|
'posts_per_page' => $count,
|
|
];
|
|
if ($days > 0) {
|
|
$args['date_query'] = [[
|
|
'after' => gmdate('Y-m-d H:i:s', time() - $days * 86400),
|
|
'inclusive' => true,
|
|
]];
|
|
}
|
|
$posts = get_posts($args);
|
|
|
|
$added = 0; $skipped = 0;
|
|
foreach ($posts as $post) {
|
|
if (!$allow_repeat && Queue::exists_for_flamingo((int)$post->ID, true)) {
|
|
$skipped++;
|
|
continue;
|
|
}
|
|
$fields = FlamingoHelper::extract_fields($post);
|
|
$reason = FlamingoHelper::extract_reason($post);
|
|
$classification = Classifier::classify($fields, ['reason' => $reason]);
|
|
|
|
$payload = MessageFormatter::build([
|
|
'fields' => $fields,
|
|
'classification' => $classification,
|
|
'site_title' => Settings::get_site_title(),
|
|
'form_title' => (string)get_post_meta($post->ID, '_subject', true),
|
|
'submitted_at' => wp_date('d.m.Y H:i', (int)get_post_time('U', true, $post)),
|
|
'reason' => $reason,
|
|
'ip' => (string)get_post_meta($post->ID, '_meta_remote_ip', true),
|
|
'user_agent' => (string)get_post_meta($post->ID, '_meta_user_agent', true),
|
|
'is_retro' => true,
|
|
]);
|
|
|
|
Queue::enqueue([
|
|
'flamingo_post_id' => (int)$post->ID,
|
|
'form_id' => null,
|
|
'source_key' => 'cf7',
|
|
'payload_json' => wp_json_encode($payload),
|
|
'label' => $classification['label'],
|
|
'is_retro' => 1,
|
|
]);
|
|
$added++;
|
|
}
|
|
|
|
return compact('added', 'skipped');
|
|
}
|
|
}
|