Биллинговая система Nodeny

my $db = Db->sql(
        "SELECT v.id, v.uid, s.price, u.balance, d._adr_telefon, ".
                "DATE(FROM_UNIXTIME(v.tm_end)) AS date ".
            "FROM users_services v ".
            "JOIN users u ON v.uid=u.id ".
            "JOIN services s ON v.next_service_id=s.service_id ".
            "JOIN data0 d ON v.uid=d.uid ".
        "WHERE v.tm_end>0 ".                            # услуга имеет срок действия,
            "AND v.tm_end<(UNIX_TIMESTAMP()+?) ".       # скоро заканчивается,
            "AND v.next_service_id>0 ".                 # установлена следующая,
            "AND s.price>0 ".                           # ее стоимость > 0 (т.е не бонус, а снятие),
            "AND u.balance<s.price*(1-u.discount/100) ".# баланс меньше стоимости следующей услуги,
            "AND block_if_limit>0 ".                    # включена блокировка при балансе ниже лимита,
            "AND u.state='on' ".                        # в данный момент доступ включен,
            "AND d._adr_telefon<>'' ".                  # у клиента есть телефон,
            "AND v.tags NOT LIKE '%,expire_sms,%' ".    # нет тега expire_sms (означает, что sms уже отсылалось)
           "AND NOT EXISTS (SELECT id FROM v_services WHERE uid=u.id AND price<0) ". # не подключена бонусная услуга
           "AND NOT EXISTS (SELECT id FROM pays WHERE mid=u.id AND category=202 AND reason='turbosms')", # нет блокировки отсылки sms
        3*24*3600
    );

sub phone_extract
{
    my($phone) = @_;                # ' +38(067)-123-44-55, 7888080'
    $phone =~ s/^\s*//;             # удаляем стартовые пробелы      '+38(067)-123-44-55, 7888080'
    $phone =~ s/^\+//;              # удаляем стартовый +            '38(067)-123-44-55, 7888080'
    $phone =~ s/[^\d\-\(\)].*$//;   # удаляем 2й телефон             '38(067)-123-44-55'
    $phone =~ s/\D//g;              # удаляем не цифры               '380671234455'
#    $phone =~ s/^3?8//g;            # удаляем 3 или 38               '0671234455'
#    length($phone) == 10 or return '';
#   $phone =~ /^0/ or return '';    # если начинается не с 0, скорее всего телефон некорректен
#   return '+38'.$phone;            # возвращаем 380671234455
}

sub phone_extract
{
    my($phone) = @_;                # ' +38(067)-123-44-55, 7888080'
    $phone =~ s/^\s*//;             # удаляем стартовые пробелы      '+38(067)-123-44-55, 7888080'
    $phone =~ s/^\+//;              # удаляем стартовый +            '38(067)-123-44-55, 7888080'
    $phone =~ s/[^\d\-\(\)].*$//;   # удаляем 2й телефон             '38(067)-123-44-55'
    $phone =~ s/\D//g;              # удаляем не цифры               '380671234455'
    if ($phone =~ /^7/)
    {
	$phone =~ s/^7//g;    #' +7(903)-797-44-55, 7888080'  условие что телефон для россии начинается или 7 или +7
	length($phone) == 10 or return '';
	return '+7'.$phone;
    }else{
    	$phone =~ s/^3?8//g;            # удаляем 3 или 38               '0671234455'
    	length($phone) == 10 or return '';
    	$phone =~ /^0/ or return '';    # если начинается не с 0, скорее всего телефон некорректен
    	return '+38'.$phone;            # возвращаем 380671234455
    }
}

#<ACTION> file=>'web/ajUserMenu.pl',hook=>'finish'

    {   # --- sms с логином/паролем ---
        Adm->chk_privil('Admin') or last;
        my %p = Db->line("SELECT name, AES_DECRYPT(passwd,?) AS pass FROM users WHERE id=?", $cfg::Passwd_Key, $uid);
        %p or last;
        my $message = "login: $p{name} pass: $p{pass}";
        my $phone = $info->{dopdata}{_adr_telefon} or last;
        $phone = $phone->show;
        $phone =~ s/^\s*//;
        $phone =~ s/^\+//;              # удаляем стартовый +
        $phone =~ s/[^\d\-\(\)].*$//;   # удаляем 2й телефон
        $phone =~ s/\D//g;              # удаляем не цифры
        $phone =~ s/^3?8//g;            # удаляем 3 или 38
        length($phone) == 10 or last;
        $phone =~ /^0/ or last;         # если начинается не с 0, скорее всего телефон некорректен
        $phone = '+38'.$phone;
        $menu[1] .= ' '.$url->a('sms с паролем', a=>'ajTurboSms', its_pass=>$uid, message=>$message, phone=>$phone, -ajax=>1);
    }

#<ACTION> file=>'web/ajUserMenu.pl',hook=>'finish'

    {   # --- sms с логином/паролем ---
        Adm->chk_privil('Admin') or last;
        my %p = Db->line("SELECT name, AES_DECRYPT(passwd,?) AS pass FROM users WHERE id=?", $cfg::Passwd_Key, $uid);
        %p or last;
        my $message = "login: $p{name} pass: $p{pass}";
        my $phone = $info->{dopdata}{_adr_telefon} or last;
        $phone = $phone->show;
        $phone =~ s/^\s*//;
        $phone =~ s/^\+//;              # удаляем стартовый +
        $phone =~ s/[^\d\-\(\)].*$//;   # удаляем 2й телефон
        $phone =~ s/\D//g;              # удаляем не цифры
        if ($phone =~ /^7/)
          {
	      $phone =~ s/^7//g;    #' +7(903)-797-44-55, 7888080'  условие что телефон для россии начинается или 7 или +7
	      length($phone) == 10 or last '';
	      return '+7'.$phone;
          }else{    
             $phone =~ s/^3?8//g;            # удаляем 3 или 38
             length($phone) == 10 or last;
             $phone =~ /^0/ or last;         # если начинается не с 0, скорее всего телефон некорректен
            $phone = '+38'.$phone;
        }

        $menu[1] .= ' '.$url->a('sms с паролем', a=>'ajTurboSms', its_pass=>$uid, message=>$message, phone=>$phone, -ajax=>1);
    }

if ($phone =~ /^7/)
     {
          $phone =~ s/^7//g;    #' +7(903)-797-44-55, 7888080'  условие что телефон для россии начинается или 7 или +7
          length($phone) == 10 or last;
          $phone = '+7'.$phone;
    }else{....
         $phone =~ s/^3?8//g;            # удаляем 3 или 38
      length($phone) == 10 or last;
       $phone =~ /^0/ or last;         # если начинается не с 0, скорее всего телефон некорректен
       $phone = '+38'.$phone;
   }

cat create.nod.turbosms.pm
#<ACTION> file=>'nod/turbosms.pm',hook=>'new'
package nod::turbosms;

# Извлечение телефона из текстовой строки, которая может содержать несколько телефонов, не цифры и т.д.
# Например, на вход может быть подано: 8067-7778899 / 0501234567 / +38(063)5544332

sub phone_extract
{
    my($phone) = @_;                # ' +38(067)-123-44-55, 7888080'
    $phone =~ s/^\s*//;             # удаляем стартовые пробелы      '+38(067)-123-44-55, 7888080'
    $phone =~ s/^\+//;              # удаляем стартовый +            '38(067)-123-44-55, 7888080'
    $phone =~ s/[^\d\-\(\)].*$//;   # удаляем 2й телефон             '38(067)-123-44-55'
    $phone =~ s/\D//g;              # удаляем не цифры               '380671234455'
    if ($phone =~ /^7/)
    {
        $phone =~ s/^7//g;    #' +7(907)-797-44-55, 7888080'  условие что телефон для россии начинается или 7 или +7
        length($phone) == 10 or return;
        $phone = '+7'.$phone;
    }else{
        $phone =~ s/^3?8//g;            # удаляем 3 или 38               '0671234455'
        length($phone) == 10 or return;
        $phone =~ /^0/ or return;    # если начинается не с 0, скорее всего телефон некорректен
        return '+38'.$phone;            # возвращаем 380671234455
    }
}

 cat patch.ajUserMenu.pl
#<ACTION> file=>'web/ajUserMenu.pl',hook=>'finish'

    {   # --- sms с логином/паролем ---

        Adm->chk_privil('Admin') or last;
        my %p = Db->line("SELECT name, AES_DECRYPT(passwd,?) AS pass FROM users WHERE id=?", $cfg::Passwd_Key, $uid);
        %p or last;
        my $message = "login: $p{name} pass: $p{pass}";
        my $phone = $info->{dopdata}{_adr_telefon} or last;
        $phone = $phone->show;
        $phone =~ s/^\s*//;
        $phone =~ s/^\+//;              # удаляем стартовый +
        $phone =~ s/[^\d\-\(\)].*$//;   # удаляем 2й телефон
        $phone =~ s/\D//g;              # удаляем не цифры
        if ($phone =~ /^7/)
          {
              $phone =~ s/^7//g;    #' +7(903)-797-44-55, 7888080'  условие что телефон для россии начинается или 7 или +7
              length($phone) == 10 or last;
              $phone = '+7'.$phone;
          }else{
             $phone =~ s/^3?8//g;            # удаляем 3 или 38
             length($phone) == 10 or last;
             $phone =~ /^0/ or last;         # если начинается не с 0, скорее всего телефон некорректен
            $phone = '+38'.$phone;
        }

        $menu[1] .= ' '.$url->a('sms с паролем', a=>'ajTurboSms', its_pass=>$uid, message=>$message, phone=>$phone, -ajax=>1);
    }

Global symbol "%p" requires explicit package name at /usr/local/nodeny/web/_ajUserMenu.pl line 85.
Global symbol "%p" requires explicit package name at /usr/local/nodeny/web/_ajUserMenu.pl line 86.
Global symbol "%p" requires explicit package name at /usr/local/nodeny/web/_ajUserMenu.pl line 86.
Compilation failed in require at /usr/local/nodeny/web/calls.pm line 1224.
Compilation failed in require at /usr/local/nodeny/web/calls.pm line 1224.

 #Adm->chk_privil('Admin')  or last;        my %p = Db->line("SELECT name, AES_DECRYPT(passwd,?) AS pass FROM users WHERE id=?", $cfg::Passwd_Key, $uid);
        %p or last;
        my $message = "login: $p{name} pass: $p{pass}";
        my $phone = $info->{dopdata}{_adr_telefon} or last;
        $phone = $phone->show;
        $phone =~ s/^\s*//;
 

bash-4.3# cat _turbosms.cfg
# Отправляет клиенту через http://turbosms.ua sms о том, что в ближайшее время
# будет произведено списание за услуги и его счет может быть заблокирован,
# если он его не пополнит. Условия отсылки:
#   стоимость подключаемой в будущем услуги > 0 (т.е не бонус, а снятие),
#   текущий баланс меньше стоимости следующей услуги,
#   включена блокировка при балансе ниже лимита,
#   в данный момент доступ включен,
#   не подключена бонусная услуга, которая могла бы увеличить баланс

run => 0,

sms => '{{date}} списание за услуги интернет. Пополните счет.',

# Минимальный и максимальный час суток, в которые можно отправлять смс:
# ночью не беспокоим людей, посылаем утром - даем возможность пополнить счет по пути на работу

min_hour => 8,
max_hour => 11,

turbosms.cfg параметр run => 0

Клиенту не будут отсылаться sms с напоминаниями пополнения счета

Login: {{login}}
Password: {{password}}

Login: {{login}}. Password: {{password}}

# cat kernel/_remindsms.cfg
# Отправляет клиенту sms о том, что в ближайшее время будет произведено списание за услуги
# и его счет может быть заблокирован, если он его не пополнит.
# Условия отсылки:
#   стоимость подключаемой в будущем услуги > 0 (т.е не бонус, а снятие),
#   текущий баланс меньше стоимости следующей услуги,
#   включена блокировка при балансе ниже лимита,
#   в данный момент доступ включен,
#   не подключена бонусная услуга, которая могла бы увеличить баланс

run => 1,

# Sms модуль. Варианты: TurboSms, LifeSms

smsmod => 'TurboSms',

# Шаблон смс
# {{date}} - дата cписания
# {{price}} - сумма списания за услугу
# {{balance}} - текущий баланс
# {{final_balance}} = balance - price
# {{actual_transfer}} = сумма для погашения задолженности ( -{{final_balance}} )

#sms => '{{date}} снятие за интернет {{price}} грн. Пополните счет.',
sms => 'Napominaem {{date}} budet snjata abonplata za internet {{price}} grn. Popolnite pozhalujsta svoj schet vo izbezhanii blokirovki dostupa k seti.',
# sms => '{{date}} будет списано {{price}} грн. Пополните счет на {{actual_transfer}} грн.',

# Минимальный и максимальный час суток, в которые можно отправлять смс:
# ночью не беспокоим людей, посылаем утром - даем возможность пополнить счет по пути на работу

min_hour => 8,
max_hour => 17,

No DB connection, DBI:mysql:database=users;host=94.249.146.189;port=3306;mysql_connect_timeout=3 : Can't connect to MySQL server on '94.249.146.189' (13)

forum.nodeny.com.ua/index.php?topic=2163.30

No DB connection, DBI:mysql:database=users;host=94.249.146.189;port=3306;mysql_connect_timeout=30 : Can't connect to MySQL server on '94.249.146.189' (13)

 
    my %dopsignes = ();
    my $dopfield = exists $db_params->{dopfield} ? $db_params->{dopfield} : '';

    $sql_where = $sql_where. " AND u.grp in (9,37,38)";

    $sql_where = $sql_where. " AND u.grp not in (2,3,4)";

/usr/bin/perl /usr/local/nodeny/nokernel.pl -m=turbosms -v
Start. Flag -h for help

loading /usr/local/nodeny/sat.cfg

Connecting to DBI:mysql:database=nodeny;host=localhost;port=3306;mysql_connect_timeout=5 : 0.013818 sec

SELECT * FROM config ORDER BY time DESC LIMIT 1
Строк: 1. Время выполнения sql: 0.0004 сек

/usr/local/nodeny/kernel/turbosms.cfg not found at /usr/local/nodeny/nokernel.pl line 102.

grep phone_prefix /usr/local/nodeny/web/ajSms.pl

grep phone_prefix /usr/local/nodeny/web/ajSms.pl
    my $phone = ses::input('phone') || nod::sms::phone_prefix();

Подпись в sms. Необходима обязательная

# perl nokernel.pl -m=remindsms -v

Start. Flag -h for help

loading /usr/local/nodeny/sat.cfg

Connecting to DBI:mysql:database=nodeny;host=localhost;port=3306;mysql_connect_timeout=5 : 0.023665 sec

SELECT * FROM config ORDER BY time DESC LIMIT 1
Строк: 1. Время выполнения sql: 0.0013 сек

loading kernel::remindsms.pm

Start

Connecting to DBI:mysql:database=users;host=94.249.146.189;port=3306;mysql_connect_timeout=3 : 0.097049 sec

SELECT v.id, v.uid, s.price, u.balance, u.discount, d._adr_telefon, s.param AS srv_param, DATE(FROM_UNIXTIME(v.tm_end)) AS date  FROM users_services v JOIN users u ON v.uid=u.id JOIN services s ON v.next_service_id=s.service_id JOIN data0 d ON v.uid=d.uid WHERE v.tm_end>0 AND v.tm_end<(UNIX_TIMESTAMP()+'172800') AND v.next_service_id>0 AND s.price>0 AND u.balance<s.price*(1-u.discount/100) AND block_if_limit>0 AND u.state='on' AND d._adr_telefon<>'' AND v.tags NOT LIKE '%,expire_sms,%' AND NOT EXISTS (SELECT id FROM v_services WHERE uid=u.id AND price<0) AND NOT EXISTS (SELECT id FROM pays WHERE mid=u.id AND category=202 AND reason='turbosms') AND EXISTS (SELECT 1 FROM users_services WHERE uid=u.id AND tags LIKE '%,remindsms,%')
Строк: 0. Время выполнения sql: 0.0013 сек

end

SELECT uid FROM users_services WHERE tags LIKE '%,remindsms,%'

mysql> SELECT uid FROM users_services WHERE tags LIKE '%,remindsms,%';

    $tbl->add('*',[
        [ '',        L('Подпись'),         $p{sign}           ],
        [ '',        L('Телефон'),         $link           ],
        [ '',        L('Сообщение'),       $p{message}     ],
        [ 'h_right', L('Стоимость'),       $p{cost}        ],
        [ '',        L('Создано'),         $p{added}       ],
        [ '',        L('Отправлено'),      $sended         ],
        [ '',        L('Статус'),          $status         ],
        [ '',        L('Статус код'),      $p{error_code}  ],
        [ 'h_right', L('Остаток'),         $p{balance}     ],
    ]);
 }