abonbot/modules/cdata.pm

use Modern::Perl;
use utf8;

use telnet;

use Mojo::AsyncAwait;
use Data::Dumper;

sub cdata_extract_onu_info {
    my @lines = @_;

    my @onu_info = @lines[6..@lines-5];

    return map([ split(' ', $_) ], @onu_info );
};

async cdata_inspect => sub
{
    my $ip = shift;
    my $login = shift;
    my $password = shift;
    my $tree = shift;

    my $t = new telnet($ip);
#    $t->debug(1);

    await $t->connect;

    await $t->reply(qr/User name:/, $login);
    await $t->reply(qr/User password:/, $password);

    $t->print("enable");
    await $t->waitfor("#");
    $t->prompt(qr/#\s?$/);

    await $t->cmd("config");
    await $t->cmd("vty output show-all");

    $t->print("interface epon 0/0");
    $t->prompt(qr/#\s?$/);
    my @lines = await $t->cmd("show ont info $tree all");

    my $onu_count_line = @lines[@lines-3];


    $onu_count_line =~ m|Total: (\d+), online (\d+)|;
    my $total_onu_cnt   = $1;
    my $online_onu_cnt  = $2;
    my $offline_onu_cnt = $total_onu_cnt - $online_onu_cnt;

    $t->close;

    if ($lines[2] =~ /Error/) {
        $total_onu_cnt   = 0;
        $online_onu_cnt  = 0;
        $offline_onu_cnt = 0;
    }

    my @onu_info = cdata_extract_onu_info(@lines);

    my @online_onu = grep { @$_[5] =~ "online" }  @onu_info;
    @online_onu = map join(' ', @$_[2,3]), @online_onu;

    my @offline_onu = grep { @$_[5] =~ "offline|powerdown" }  @onu_info;
    @offline_onu = map join(' ', @$_[2,3]), @offline_onu;

    my $res = "Всего: $total_onu_cnt
Количество активных ONU: $online_onu_cnt
Количество неактивных ONU: $offline_onu_cnt
\n";

    $res = $res . "Неактивные ONU:\n" . join("\n", @offline_onu) . "\n\n" if $offline_onu_cnt;

    $res = $res . "Активные ONU:\n" . join("\n", @online_onu) if $online_onu_cnt;

    return $res;
};

async cdata_onu => sub
{
    my $ip = shift;
    my $login = shift;
    my $password = shift;
    my $tree = shift;

    my $t = new telnet($ip);
#    $t->debug(1);

    await $t->connect;

    await $t->reply(qr/User name:/, $login);
    await $t->reply(qr/User password:/, $password);

    $t->print("enable");
    await $t->waitfor("#");
    $t->prompt(qr/#\s?$/);

    await $t->cmd("config");
    await $t->cmd("vty output show-all");

    $t->print("interface epon 0/0");
    $t->prompt(qr/#\s?$/);
    my @lines = await $t->cmd("show ont info $tree all");

    my $onu_count_line = @lines[@lines-3];

    $onu_count_line =~ m|Total: (\d+), online (\d+)|;
    my $total_onu_cnt   = $1;
    my $online_onu_cnt  = $2;
    my $offline_onu_cnt = $total_onu_cnt - $online_onu_cnt;

    $t->close;

    if ($lines[2] =~ /Error/) {
        $total_onu_cnt   = 0;
        $online_onu_cnt  = 0;
        $offline_onu_cnt = 0;
    }

    my $res = "Всего: $total_onu_cnt
Количество активных ONU: $online_onu_cnt
Количество неактивных ONU: $offline_onu_cnt
\n";

    return $res;
};


async cdata_purge => sub
{
    my $ip = shift;
    my $login = shift;
    my $password = shift;
    my $tree = shift;

    my $t = new telnet($ip);
#    $t->debug(1);

    await $t->connect;

    await $t->reply(qr/User name:/, $login);
    await $t->reply(qr/User password:/, $password);

    $t->print("enable");
    await $t->waitfor("#");
    $t->prompt(qr/#\s?$/);

    await $t->cmd("config");
    await $t->cmd("vty output show-all");

    $t->print("interface epon 0/0");
    $t->prompt(qr/#\s?$/);
    my @lines = await $t->cmd("show ont info $tree all");

    my $onu_count_line = @lines[@lines-3];

    $onu_count_line =~ m|Total: (\d+), online (\d+)|;
    my $total_onu_cnt   = $1;
    my $online_onu_cnt  = $2;
    my $offline_onu_cnt = $total_onu_cnt - $online_onu_cnt;

    if ($lines[2] =~ /Error/) {
        $total_onu_cnt   = 0;
        $online_onu_cnt  = 0;
        $offline_onu_cnt = 0;
    }

    if ($offline_onu_cnt == 0) {
        $t->close;
        return "Нечего чистить.";
    }

    my @onu_info = cdata_extract_onu_info(@lines);

    my @offline_onu = grep { @$_[5] =~ "offline|powerdown" }  @onu_info;

    foreach my $i (@offline_onu) {
        my $onu_num = @$i[2];
        my @tmp = await $t->cmd("ont delete $tree $onu_num");
    }

    my @deleted_onu = map join(' ', @$_[2,3]), @offline_onu;

    @lines = await $t->cmd("show ont info $tree all");
    $onu_count_line = @lines[@lines-3];

    $onu_count_line =~ m|Total: (\d+), online (\d+)|;
    $total_onu_cnt   = $1;
    $online_onu_cnt  = $2;
    $offline_onu_cnt = $total_onu_cnt - $online_onu_cnt;

    if ($lines[2] =~ /Error/) {
        $total_onu_cnt   = 0;
        $online_onu_cnt  = 0;
        $offline_onu_cnt = 0;
    }

    my $res = "После чистки осталось ONU: $total_onu_cnt
Количество активных ONU: $online_onu_cnt
Количество неактивных ONU: $offline_onu_cnt
\n";

    $res = $res . "Удалённые ONU:\n" . join("\n", @deleted_onu) if @deleted_onu > 0;

    await $t->cmd("exit");

    await $t->cmd("save");

    $t->close;

    return $res;
};

1;