Протокол приема платежей "Delta Key SA-1"

CREATE TABLE `pay_deltakey` (
  `id` bigint(20) unsigned NOT NULL auto_increment,
  `transact` varchar(100) NOT NULL default '',
  `summ` varchar(100) NOT NULL default '',

  `date` varchar(100) NOT NULL default '',
  `kod` int(11) NOT NULL default '0',
  `lc` int(11) NOT NULL default '0',
  PRIMARY KEY  (`id`)
) TYPE=MyISAM; 

CREATE TABLE `accounts` (
  `lc` int(10) unsigned NOT NULL auto_increment,
  `short_name` varchar(255) default 'Test',
  `money` varchar(255) default '0',
  PRIMARY KEY  (`lc`)
) TYPE=MyISAM; 

CREATE TABLE `money_logs` (
  `Id` int(6) unsigned NOT NULL auto_increment,
  `lc` varchar(255) default NULL,
  `operator` varchar(10) default NULL,
  `money` varchar(255) default NULL,
  `comments` varchar(255) default NULL,
  `old_money` varchar(255) default NULL,
  `data` datetime default NULL,
  PRIMARY KEY  (`Id`)
) TYPE=MyISAM; 

# Ключ шифрования данных для цифровой подписи (Сгенерируйте сами)
# Пример: $key = 'agj34kjfkJGKLFJdbkjfgskj43JKfjkd5KJas';
$key = '';

# Путь к файлу логов
$patch_logfile = 'delta-key.log';

# Параметры доступа к базе данных MySql

$db_host = '127.0.0.1';
$db_login = 'login';
$db_pass = 'password';
$db_name = 'billing';

#!/usr/bin/perl

############################################################
#                                                          #
#   Perl Script for Online Pay System 'Delta-Key' v1.0     #
#                                                          #
#         author: Andrey Neasov company: RamNet.ru         #
#                                                          #
#           icq: 674522  e-mail: [email protected]          #
#                                                          #
############################################################

# Преобразуем вредоносные символы
sub urldecode{
    local($val)=@_;
    $val=~tr/+/ /;

    $val=~s/%([a-fA-F0-9][a-fA-F0-9])/pack("C",hex($1))/eg;
    $val=~s/%00//g;
    $val=~s/</&lt;/g;
    $val=~s/>/&gt;/g;  
    $val=~s/"/&quot;/g;  

    $val=~s/~!/ ~!/g;  
    $val=~s/\r//g;  
    $val=~s/\n//g;  
    $val=~s/ +/ /g;
    return $val;
}

# Получаем данные любым методом
if ($ENV{'REQUEST_METHOD'} eq 'POST') {
    read(STDIN,$buffer,$ENV{'CONTENT_LENGTH'});
} elsif ($ENV{'REQUEST_METHOD'} eq 'GET') {
    $buffer=$ENV{'QUERY_STRING'};
}

# Поиск конкретных параметров и передача данных переменным
@formfields=split(/&/,$buffer);

foreach(@formfields){
    # обработка данных первоначальный авторизации
    if(/^command=(.*)/) {$command=urldecode($1);}
    if(/^transact=(.*)/) {$transact=urldecode($1);}
    if(/^form=(.*)/) {$form=urldecode($1);}
    if(/^identified=(.*)/) {$identified=urldecode($1);}

    if(/^summ=(.*)/) {$summ=urldecode($1);}
    if(/^curr=(.*)/) {$curr=urldecode($1);}
    if(/^out_date=(.*)/) {$out_date=urldecode($1);}
    if(/^keyt=(.*)/) {$keyt=urldecode($1);}
    if(/^18=(.*)/) {$pay_fio=urldecode($1);}
    if(/^198=(.*)/) {$pay_lc=urldecode($1);}
    if(/^36=(.*)/) {$pay_email=urldecode($1);}
    if(/^sign=(.*)/) {$sign=urldecode($1);}
}

# Подгружаем конфигурационный файл
require "delta-key.conf";

# Разбиваем полученное время по переменным
$year = substr($out_date,0,4);
$mon = substr($out_date,4,2);
$mday = substr($out_date,6,2);
$hour = substr($out_date,8,2);
$min = substr($out_date,10,2);
$sec = substr($out_date,12,2);

# Подгружаем нужные модули для PERL
use DBI; 
use Digest::HMAC_MD5 qw(hmac_md5 hmac_md5_hex);

# Соединяемся в базу данных MYSQL
my $dbh = DBI->connect("DBI:mysql:database=$db_name;host=$db_host", "$db_login", "$db_pass"); # Коннектимся

# Записываем в лог полученный буфер данных от платёжной системы
open(FILE, ">>$patch_logfile");
print FILE $ENV{'REMOTE_ADDR'}." -> ".$buffer."\n";
close(FILE);

# Передаём тип документа браузеру (XML документ)
print "content-type: text/xml\n\n";

# Условие обработки проверки ЛС абонента в системе
if ($command eq "check") {

    # Склеиваем полученные данные для проверки sign подписи
    $data = $command.$transact.$summ.$pay_lc;

    # Генерируем подпись с ключём
    $digest = hmac_md5_hex($data, $key);

    # Проверяем созданную нами и полученную подписи SIGN
    if ($digest eq $sign) {
        $varify="yes";
        
        # Проверяем в базе данных полученный номер аккаунта
        my $result = $dbh->prepare("SELECT * FROM accounts WHERE lc = '$pay_lc'"); #
        $result->execute(); # выполнение подготовленного запроса
        
        while (my $ln = $result->fetchrow_hashref()) {
            $searchaccount="yes";
        }

        # Условие найден ли номер аккаунта в базе данных
        if ($searchaccount eq "yes") {
            # Выводим ответ на страницу при удачном поиске
            print ('<?xml version="1.0" encoding="UTF-8"?>
            <response>
            <transact>'.$transact.'</transact>
            <result>0</result>
            <comment>Seaching Account Complite!</comment>

            </response>');
        } else {

            # Выводим ответ на страницу при не удачном поиске
            print ('<?xml version="1.0" encoding="UTF-8"?>
            <response>

            <transact>'.$transact.'</transact>
            <result>18</result>
            <comment>No search account number!</comment>
            </response>');
        }

    } else {

        # Выводим ответ на страницу при не удачной проверке подписи SIGN
        print ('<?xml version="1.0" encoding="UTF-8"?>
        <response>

        <transact>'.$transact.'</transact>
        <result>18</result>
        <comment>Bad Sign!</comment>
        </response>');

    }
}

# Условие проводка платежа
elsif ($command eq "pay") {

    $data = $command.$transact.$out_date.$summ.$pay_lc;
    $digest = hmac_md5_hex($data, $key);

    if ($digest eq $sign) {

        $varify="yes";

        # Проверка в базе данных на существование дублирующего платежа
        my $result = $dbh->prepare("SELECT * FROM pay_deltakey WHERE transact = '$transact'"); #
        $result->execute(); # выполнение подготовленного запроса

        while (my $ln = $result->fetchrow_hashref()) {

            # Присваиваем переменным параметры уже проведённого платежа
            # если таковой уже имеется (тоесть платёж уже проводился)

            $search2pay = "yes";
            # Внутренная транзакция оператора

            $idpay=$ln->{'id'};
            # Код ответа платёжной системе
            $kod=$ln->{'kod'};

        }

        # Условие: Дубликат платежа не найден приступаем к проводке
        if ($search2pay ne "yes") {

            # Поиск аккаунта в базе
            my $result = $dbh->prepare("SELECT * FROM accounts WHERE lc = '$pay_lc'"); #
            $result->execute(); # выполнение подготовленного запроса


            while (my $ln = $result->fetchrow_hashref()) {
                $searchaccount="yes";

                # Получаем денежные средства на счету пользователя
                $money=$ln->{'money'};
            }

            # Условие: найден ли номер аккаунта
            if ($searchaccount eq "yes") {

                # Записываем в базу данных парраметры проводки платежа
                my $result = $dbh->prepare("INSERT pay_deltakey SET transact = '$transact', lc = '$pay_lc', 
					summ = '$summ', date = '$year-$mon$mday $hour:$min:$sec', kod = '0'"); #
                $result->execute(); # выполнение подготовленного запроса

                # Запрашиваем внутренний номер проводки оператором
                my $result = $dbh->prepare("SELECT * FROM pay_deltakey LIMIT TO 0,1"); #

                $result->execute(); # выполнение подготовленного запроса

                while (my $ln = $result->fetchrow_hashref()) {
                    # Получаем из базы номер проводки
                    $idpay = $ln->{'id'};
                }

                # Суммируем денежные средства имеющиеся и полученные
                $newmoney = $money + $summ;

                # Обновляем в базе показание поля денежных средств на новое значение

                my $result = $dbh->prepare("UPDATE accounts SET money = '$newmoney' WHERE lc = '$AccountNr'"); #
                $result->execute(); # выполнение подготовленного запроса

                # Записывае в финансовую историю пользователя строчку о платеже
                my $result = $dbh->prepare("INSERT money_logs SET lc = '$pay_lc', money = '+$summ', 
					old_money = '".$money."', data = '$year-$mon$mday $hour:$min:$sec', 
					comments = 'Оплата через терминал<br>Delta Key<br>$transact'"); #

                $result->execute(); # выполнение подготовленного запроса

                # Выводим ответ системе платежей с параметрами удачного платежа
                print ('<?xml version="1.0" encoding="UTF-8"?>
                <response>
                <command>pay</command>

                <transact>'.$transact.'</transact>
                <ext_transact>'.$idpay.'</ext_transact>
                <summ>'.$summ.'</summ>
                <status>2</status>
                <result>0</result>

                <comment>Pay Complite!</comment>
                </response>');

            } else {

                # Записываем в базу данных парраметры проводки платежа
                
                my $result = $dbh->prepare("INSERT pay_deltakey SET transact = '$transact', 
					lc = '$pay_lc', summ = '$summ', 
					date = '$year-$mon$mday $hour:$min:$sec', kod = '22'"); #
                $result->execute(); # выполнение подготовленного запроса
                
                # Выводим ответ системе платежей с параметрами не удачного платежа
                # так как номер аккаунта не найден
                print ('<?xml version="1.0" encoding="UTF-8"?>
                
                <response>
                <command>pay</command>
                <transact>'.$transact.'</transact>
                <ext_transact>'.$idpay.'</ext_transact>
                <summ>'.$summ.'</summ>
                
                <status>2</status>
                <result>22</result>
                <comment>Bad Account Number!</comment>
                </response>');
            }

        } else {

            # Выводим ответ системе платежей с параметрами не удачного платежа
            # так как платёж уже проводился
            print ('<?xml version="1.0" encoding="UTF-8"?>
            
            <response>
            <command>pay</command>
            <transact>'.$transact.'</transact>
            <ext_transact>'.$idpay.'</ext_transact>
            <summ>'.$summ.'</summ>
            
            <status>2</status>
            <result>'.$kod.'</result>
            <comment>Dublicate Transact Number!</comment>
            </response>');
            
        }

    } else {

        # Выводим ответ системе платежей с параметрами не удачного платежа
        # неверная подпись данных SIGN
        print ('<?xml version="1.0" encoding="UTF-8"?>
        <response>

        <command>pay</command>
        <transact>'.$transact.'</transact>
        <ext_transact>'.$idpay.'</ext_transact>
        <summ>'.$summ.'</summ>
        <status>2</status>

        <result>22</result>
        <comment>Bad Sign!</comment>
        </response>');
    }

} elsif ($command eq "status") {

    $data = $command.$transact.$out_date.$summ.$pay_lc;
    $digest = hmac_md5_hex($data, $key);

    if ($digest eq $sign) {
    
        $varify="yes";
        
        my $result = $dbh->prepare("SELECT * FROM pay_deltakey WHERE transact = '$transact'"); #
        $result->execute(); # выполнение подготовленного запроса
        
        while (my $ln = $result->fetchrow_hashref()) {
            $search2pay = "yes";
            $idpay=$ln->{'id'};
            $kod=$ln->{'kod'};
        }
        
        if ($search2pay eq "yes") {
        
            # Выводим ответ системе платежей с параметрами платежа
            # возвращаем код операции
            print ('<?xml version="1.0" encoding="UTF-8"?>
            <response>
            <command>status</command>
            <transact>'.$transact.'</transact>
            
            <ext_transact>'.$idpay.'</ext_transact>
            <summ>'.$summ.'</summ>
            <status>2</status>
            <result>'.$kod.'</result>
            <comment></comment>
            
            </response>');
        
        } else {

            # Выводим ответ системе платежей с параметрами платежа
            # платёж не проводился
            print ('<?xml version="1.0" encoding="UTF-8"?>
            <response>
            <command>status</command>

            <transact>'.$transact.'</transact>
            <ext_transact>'.$idpay.'</ext_transact>
            <summ>'.$summ.'</summ>
            <status>2</status>
            <result>66</result>

            <comment></comment>
            </response>');
        }

    } else {

        # Выводим ответ системе платежей с параметрами не удачного платежа

        # неверная подпись данных SIGN
        print ('<?xml version="1.0" encoding="UTF-8"?>
        <response>
        <command>pay</command>
        <transact>'.$transact.'</transact>
        <ext_transact>'.$idpay.'</ext_transact>

        <summ>'.$summ.'</summ>
        <status>2</status>
        <result>22</result>
        <comment>Bad Sign!</comment>
        </response>');

    }
}
exit;