abonbot/modules/inspect_cdata.pm

use Modern::Perl;
use utf8;

use telnet;

sub extract_onu_info {
    my @lines = @_;

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

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

async inspect_cdata => 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");
  
#    say Dumper @lines;
#    say Dumper @lines[2];

    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 = extract_onu_info(@lines);

#    say Dumper @onu_info;

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

    my @offline_onu = grep { @$_[5] =~ "offline" }  @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;
};

1;