sharee.bike/copri4/main/src/Mod/Shareework.pm

904 lines
31 KiB
Perl
Raw Normal View History

2021-12-30 12:05:56 +01:00
package Shareework;
#
# SPDX-License-Identifier: AGPL-3.0-or-later
# Copyright (c) Rainer Gümpelein, TeilRad GmbH
#
#disable for syntax check
#use lib qw(/var/www/copri-bike/shareeapp-primary/src);
2021-12-30 12:05:56 +01:00
use strict;
use warnings;
use POSIX;
use CGI; # only for debugging
use Mod::Libenzdb;
use Mod::Libenz;
use Mod::DBtank;
use Mod::Buttons;
use Lib::Config;
use Mod::APIfunc;
use Digest::MD5 qw(md5 md5_hex);
2023-04-05 07:41:11 +02:00
use Digest::SHA qw(sha1_base64 sha256_base64);
2021-12-30 12:05:56 +01:00
use Scalar::Util qw(looks_like_number);
2022-01-14 19:41:45 +01:00
use URI::Encode;
2021-12-30 12:05:56 +01:00
use Mod::Prelib;
use Mod::Basework;
use Mod::Payment;
#use Mod::MailTransport;
use Mod::SMSTransport;
use Data::Dumper;
my $cf = new Config;
my $but = new Buttons;
my $db = new Libenzdb;
my $lb = new Libenz;
my $dbt = new DBtank;
my $apif = new APIfunc;
my $pl = new Prelib;
my $bw = new Basework;
my $payone = new Payment;
#my $mailtrans = new MailTransport;
my $smstrans = new SMSTransport;
my $q = new CGI;
2022-01-14 19:41:45 +01:00
my $uri_encode = URI::Encode->new( { encode_reserved => 1 } );
2021-12-30 12:05:56 +01:00
sub new {
my $class = shift;
my $self = {};
bless($self,$class);
return $self;
}
my $i_rows=0;
my $u_rows=0;
my $d_rows=0;
#
#also done in src/Tpl/Anmelden.pm!?
sub delete_account {
my $self = shift;
my $c_id = shift;
my $owner = shift;
my $now_dt = strftime "%Y-%m-%d %H:%M:%S", localtime;
my %varenv = $cf->envonline();
my $debug=1;
my $dbh = "";
$bw->log("delete_account",$c_id,"");
open(FILE,">>$varenv{logdir}/delete_account.log") if($debug);
my $dbh_primary = $dbt->dbconnect_extern($dbt->{primary}->{sharee_primary}->{database}->{dbname});
2021-12-30 12:05:56 +01:00
my $authref = {
table => "contentadr",
fetch => "one",
template_id => "202",
c_id => "$c_id",
};
my $ctadr = $dbt->fetch_record($dbh_primary,$authref);
print FILE "\n*-->DB $varenv{dbname} $now_dt| owner: $owner | c_id: $c_id \n" if($debug);
#First on operator DMS delete and then second on primary delete txt17 operator DB
if($varenv{dbname} ne $dbt->{primary}->{sharee_primary}->{database}->{dbname}){
2021-12-30 12:05:56 +01:00
$d_rows += $dbt->delete_content($dbh,"contentadr",$c_id);
my $update_primary = {
table => "contentadr",
mtime => "now()",
owner => "$owner",
c_id => "$c_id",
};
my @operators = ("$ctadr->{txt17}");
@operators = split(/\s+/,$ctadr->{txt17}) if($ctadr->{txt17} =~ /\w\s\w/);
my @new_operators = ();
foreach(@operators){
push(@new_operators,$_) if($_ =~ /sharee_\w+/ && $_ !~ /$varenv{dbname}/);
}
print FILE "delete operator dbname: $varenv{dbname} | update_primary txt17='@new_operators'\n";
$u_rows = $dbt->update_one($dbh_primary,$update_primary,"txt17='@new_operators'");
$u_rows = $dbt->update_one($dbh_primary,$update_primary,"txt19=null");
}else{
print FILE "delete on all by operatorsloop by primary\n";
$dbt->update_operatorsloop($varenv{dbname},$ctadr->{c_id},"delete");
$d_rows += $dbt->delete_content($dbh,"contentadr",$c_id);
}
close(FILE) if($debug);
return "$i_rows-$u_rows-$d_rows";
}
#create_account is alwas done on primary first
sub create_account(){
my $self = shift;
my $owner = shift;
my $table = "contentadr";
my $c_idnew = $db->insert_content($table);
$db->updater("$table","c_id",$c_idnew,"ct_name","$c_idnew","$owner");
$db->updater("$table","c_id",$c_idnew,"barcode","$c_idnew","$owner");
$db->updater("$table","c_id",$c_idnew,"int20","$owner","$owner");
my $rel_idnew = $db->insert_relationlist($table,"200011","de",$c_idnew,"202","ca_id");
return $c_idnew;
}
#sharee save_account is always done on primary first
sub save_account(){
my $self = shift;
2023-03-05 20:01:47 +01:00
my $q = shift;
2021-12-30 12:05:56 +01:00
my $c_id = shift;
2022-01-16 12:17:11 +01:00
my $varmerch = shift || "";
2021-12-30 12:05:56 +01:00
my $owner = shift || 0;
my $table = "contentadr";
$q->import_names('R');
my @keywords = $q->param;
my $feedb = {
u_rows => 0,
prepaid_id => 0,
message => "",
};
2021-12-30 12:05:56 +01:00
my $now_dt = strftime "%Y-%m-%d %H:%M:%S", localtime;
my %varenv = $cf->envonline();
2022-01-16 12:17:11 +01:00
2023-04-27 15:09:16 +02:00
$bw->log("save_account by merchant_id $varmerch->{merchant_id}, project_id $varmerch->{project_id} on dbname $varenv{dbname}",$q,"");
2021-12-30 12:05:56 +01:00
my $debug=1;
my $dbh = "";#keep in mind, empty dbh defaults to local copri-instance dbname
open(FILE,">>$varenv{logdir}/save_account.log") if($debug);
#Always on sharee_primary
if($varenv{dbname} ne $dbt->{primary}->{sharee_primary}->{database}->{dbname}){
$dbh = $dbt->dbconnect_extern($dbt->{primary}->{sharee_primary}->{database}->{dbname});
print FILE "\n*-->If no-primary connect DB $dbt->{primary}->{sharee_primary}->{database}->{dbname} (mvar: $varmerch->{merchant_id}|$varmerch->{dbname}|$varenv{dbname}) $now_dt| c_id: $c_id| owner: $owner\n" if($debug);
2021-12-30 12:05:56 +01:00
}else{
#keep in mind, should be only done by web-app user Formular (primary)
2022-01-16 12:17:11 +01:00
print FILE "\n*-->Else take local copri-Instance DB $varenv{dbname} (mvar: $varmerch->{merchant_id}|$varmerch->{dbname}) $now_dt| c_id: $c_id| owner: $owner\n" if($debug);
2021-12-30 12:05:56 +01:00
}
my $authref = {
table => "contentadr",
fetch => "one",
template_id => "202",
c_id => "$c_id",
};
my $ctadr = { c_id => 0 };
$ctadr = $dbt->fetch_record($dbh,$authref) if($c_id > 0);
2021-12-30 12:05:56 +01:00
my $update_adr = {
2021-12-30 12:05:56 +01:00
table => "contentadr",
mtime => "now()",
owner => "$owner",
c_id => "$c_id",
};
my $ret = "";
my $ret_conflict = "";
my $fkeys = "";
my $pw_dummy = "";
@keywords = grep {!/txt31/} @keywords;
2022-11-28 18:28:06 +01:00
#print FILE Dumper($q) if($debug);
2021-12-30 12:05:56 +01:00
foreach(@keywords){
$fkeys .= "$_,";
my $val = $q->param("$_");
my $valxx = $q->escapeHTML("$val");
$valxx =~ s/^\s+//;
$valxx =~ s/\s+$//;
2022-11-28 18:28:06 +01:00
if($debug){
if($_ !~ /txt04/){
print FILE "$_:$valxx \n";
}else{
print FILE "$_:is not logged\n";
}
}
2021-12-30 12:05:56 +01:00
if($_ =~ /^int|barcode/){
$valxx =~ s/,/./g;
if(looks_like_number($valxx)){
$valxx = $valxx;
}else{
$valxx = "null"
}
}
2023-04-27 15:09:16 +02:00
if($_ =~ /^txt\d+|^int\d+|ct_name/){
2021-12-30 12:05:56 +01:00
#PW
if($_ =~ /^txt04/){
if($valxx eq "xxxxxxxx"){
$pw_dummy = "1";
}elsif(length($valxx) >= 8){
my $pwmd5 = md5_hex($valxx) || "";
my $pwsha256=sha256_base64($pwmd5) || "";
$update_adr->{txt04} = "$pwsha256" if(length($pwsha256) > 20);
2021-12-30 12:05:56 +01:00
}
}
#operators, only if saved by operator DMS
elsif($_ eq "txt17"){
my %txt17 = ();
if($ctadr->{txt17} =~ /\w\s\w/){
%txt17 = map { $_ => 1 } split(/\s+/,$ctadr->{txt17});
}else{
$txt17{$ctadr->{txt17}} = 1;
}
my $txt19 = $q->escapeHTML($q->param('txt19')) || "";
if($txt19 && $dbt->{operator}{$txt19}->{database}->{dbname}){
$txt17{$dbt->{operator}{$txt19}->{database}->{dbname}} = 1;
}
my @operators = ();
foreach my $keys (keys %txt17) {
push(@operators,$keys);
}
$update_adr->{txt17} = "@operators";
2021-12-30 12:05:56 +01:00
}
#Rabatt|payone cron-intervall|Ilockit-Admin|miniq
elsif($_ =~ /int07|int16|int19|int23/){
$update_adr->{$_} = $valxx;
2021-12-30 12:05:56 +01:00
}
#Text Sonstiges
elsif($_ =~ /txt29/){
$update_adr->{$_} = "$valxx";
2021-12-30 12:05:56 +01:00
}
2023-04-27 15:09:16 +02:00
#txt15=Bonus- oder Freischalcode (falls vorhanden)=15
2021-12-30 12:05:56 +01:00
#only check bonusnr and add operators dbname.
#bonustarif will be set after operator insert
elsif($_ eq "txt15"){
print FILE "Bonusnr request $_: $valxx\n" if($debug);
2023-03-10 11:35:56 +01:00
#--> Only done by App web iframe Anmelde-Registration formular
if($varenv{dbname} eq $dbt->{primary}->{sharee_primary}->{database}->{dbname}){
2021-12-30 12:05:56 +01:00
my %txt17 = ();
if($ctadr->{txt17} =~ /\w\s\w/){
%txt17 = map { $_ => 1 } split(/\s+/,$ctadr->{txt17});
}else{
$txt17{$ctadr->{txt17}} = 1;
}
2023-04-27 15:09:16 +02:00
#accept KN codes without prefix
if($valxx && $varmerch->{project_id} && $varmerch->{project_id} eq "Konstanz"){
2022-01-16 12:17:11 +01:00
my $valappend = $valxx;
$valxx = "KN-$valappend";
2023-04-27 15:09:16 +02:00
print FILE "Prepare KN Bonusnr by prefix $valxx" . "\n" if($debug);
2022-01-16 12:17:11 +01:00
}
2023-04-27 15:09:16 +02:00
#accept BVB codes also without prefix
elsif($valxx && $valxx !~ /-/ && $varmerch->{project_id} && $varmerch->{project_id} eq "Freiburg"){
my $operator_conf = "";
$operator_conf = $dbt->get_operator_conf("BVB");
if(ref($operator_conf) eq "HASH" && ref($operator_conf->{subproject}) eq "HASH" && $R::txt06 =~ /$varmerch->{project_id}/i){
my $valappend = $valxx;
foreach my $sub (keys %{ $operator_conf->{subproject} }){
if($operator_conf->{subproject}->{$sub} && $R::txt03 =~ /$operator_conf->{subproject}->{$sub}/i){
$valxx = "BVB-$sub-$valappend";
}
}
print FILE "Prepare BVB Bonusnr by prefix $valxx" . "\n" if($debug);
}
}
2022-06-02 10:34:03 +02:00
#Freischaltcode format can be "CA-Li-hsze789k" or "CA1234567"
2022-07-20 06:54:17 +02:00
if($valxx && ($valxx =~ /^(\w{2,3})-([\w\-]+)/i || $valxx =~ /^(\w{2,3})(\d+)/i)){
2021-12-30 12:05:56 +01:00
$valxx =~ s/\s//g;
my $bonus_prefix = uc($1),
my $bonusnr = $2;
my $operator_conf = $dbt->get_operator_conf($bonus_prefix);
2022-01-16 12:17:11 +01:00
my @txt30_op = ();
2021-12-30 12:05:56 +01:00
if(ref($operator_conf) eq "HASH" && $operator_conf->{oprefix} && $operator_conf->{database}->{dbname}){
2022-05-19 06:35:50 +02:00
print FILE "Bonus- oder Freischaltcode $valxx : " . $operator_conf->{oprefix} . " " . $operator_conf->{database}->{dbname} . "\n" if($debug);
2021-12-30 12:05:56 +01:00
my $dbh_operator = $dbt->dbconnect_extern($operator_conf->{database}->{dbname});
#to get operator bonusnr
my $pref_bo = {
table => "content",
fetch => "one",
template_id => "228",
int03 => ">::0",
2022-07-05 11:44:00 +02:00
ct_name => "ilike::$bonusnr",
2021-12-30 12:05:56 +01:00
};
2023-03-10 11:35:56 +01:00
my $bonus_record = { c_id => 0, ct_name => "" };
$bonus_record = $dbt->fetch_record($dbh_operator,$pref_bo) if($bonusnr);
2022-01-16 12:17:11 +01:00
my $bonus_collect = {};#will be hash on matchin SWK bonus
#also if SWK file matches
2022-01-14 19:41:45 +01:00
if(!$bonus_record->{c_id} && $operator_conf->{database}->{dbname} eq "sharee_kn"){
2022-01-16 12:17:11 +01:00
$bonus_record->{ct_name} = $lb->grep_filecontent("$dbt->{copri_conf}->{basedir}/$operator_conf->{dir_app}/ftp/SWK_codes/got_last.csv","$bonusnr");
if($bonus_record->{ct_name}){
$bonus_record->{c_id} = 1;
$bonus_record->{int21} = 3429;#Stadtrad source Tarif
$bonus_record->{int22} = 3430;#Stadtrad target Tarif
$bonus_collect->{1}->{ct_name} = $bonus_record->{ct_name};
$bonus_collect->{1}->{int21} = 3429;
$bonus_collect->{1}->{int22} = 3430;
$bonus_collect->{2}->{ct_name} = $bonus_record->{ct_name};
$bonus_collect->{2}->{int21} = 3428;
$bonus_collect->{2}->{int22} = 3432;
2022-07-25 18:01:01 +02:00
$bonus_collect->{3}->{ct_name} = $bonus_record->{ct_name};
$bonus_collect->{3}->{int21} = 3433;
$bonus_collect->{3}->{int22} = 3434;
@txt30_op = ("$bonus_collect->{1}->{int22}","$bonus_collect->{2}->{int22}","$bonus_collect->{3}->{int22}");
2022-01-16 12:17:11 +01:00
}
print FILE "SWK bonus_collect:\n" . Dumper($bonus_collect) . "\n";
2022-01-14 19:41:45 +01:00
}
2021-12-30 12:05:56 +01:00
#add operators dbname only if Bonusnr matches
2022-01-16 12:17:11 +01:00
print FILE "txt15=$bonusnr requested on web Bonustarif on: $operator_conf->{database}->{dbname} --> Bonusnt:$bonus_record->{ct_name} --> int21:$bonus_record->{int21} --> int22:$bonus_record->{int22}\n" if($debug);
2021-12-30 12:05:56 +01:00
if($bonus_record->{c_id}){
$txt17{$operator_conf->{database}->{dbname}} = 1;
my @operators = ();
foreach my $keys (keys %txt17) {
push(@operators,$keys) if($keys =~/sharee_/);
}
print FILE "txt17 saving operators on primary: @operators\n" if($debug);
$update_adr->{txt17} = "@operators";
2021-12-30 12:05:56 +01:00
2022-01-16 12:17:11 +01:00
#collect operator addr with existing tariff setting
2021-12-30 12:05:56 +01:00
my $ctadr_operator = $dbt->fetch_record($dbh_operator,$authref);
@txt30_op = ("$ctadr_operator->{txt30}") if($ctadr_operator->{txt30});
@txt30_op = split(/\s+/,$ctadr_operator->{txt30}) if($ctadr_operator->{txt30} =~ /\w\s+\w/);
2022-01-16 12:17:11 +01:00
#operator request by Bonusnr.
#insert adr to operator if it doesn't exist before set operator bonustarif
2021-12-30 12:05:56 +01:00
if(!$ctadr_operator->{c_id}){
print FILE "Bonus oprefix address INSERT adr from record_primary to operator $operator_conf->{database}->{dbname} , c_id:$ctadr->{c_id}\n";
my $insert_op = {
%$ctadr,
table => "contentadr",
mtime => 'now()',
owner => "198",
};
my $c_id_op = $dbt->insert_contentoid($dbh_operator,$insert_op,"reset_adropkeys");
2022-07-25 18:01:01 +02:00
if($bonus_collect->{1}->{int22} && $bonus_collect->{2}->{int22} && $bonus_collect->{3}->{int22}){
@txt30_op = ("$bonus_collect->{1}->{int22}","$bonus_collect->{2}->{int22}","$bonus_collect->{3}->{int22}");
print FILE "SWK bonus_collect on adr insert:\n" . Dumper($bonus_collect) . "\n";
}elsif($bonus_record->{int22}){
@txt30_op = ("$bonus_record->{int22}");
2022-07-25 18:01:01 +02:00
print FILE "bonus_record on adr insert:\n" . Dumper($bonus_record) . "\n";
}
2021-12-30 12:05:56 +01:00
}
2022-07-25 18:01:01 +02:00
2022-01-16 12:17:11 +01:00
#address hash wit bonusnr
2021-12-30 12:05:56 +01:00
my $adr_bonus = {
table => "contentadr",
mtime => "now()",
c_id => $c_id,
txt15 => $bonusnr,
txt30_array => \@txt30_op,
owner => $owner,
ret => $ret,
};
2022-10-14 08:28:51 +02:00
$ctadr_operator = $dbt->fetch_record($dbh_operator,$authref);
2023-03-10 11:35:56 +01:00
print FILE "Bonusnr set_usertarif done by primary:\n" . Dumper($adr_bonus) . "\n";
2022-01-16 12:17:11 +01:00
$ret = $pl->set_usertarif($dbh,$operator_conf->{database}->{dbname},$adr_bonus,$bonus_collect);
2022-10-14 08:28:51 +02:00
#count down only if not file greped with static kn c_id and not still used
print FILE "bonus_record update_content4comp by: $bonus_record->{c_id} > 3 && $bonus_record->{int03} > 0 && (!$ctadr_operator->{txt15} || $bonus_record->{ct_name} !~ /$ctadr_operator->{txt15}/i)\n";
if($bonus_record->{c_id} > 3 && $bonus_record->{int03} > 0 && (!$ctadr_operator->{txt15} || $bonus_record->{ct_name} !~ /$ctadr_operator->{txt15}/i)){
$dbt->update_content4comp($dbh_operator,$bonus_record->{c_id},"-","1");
}
2022-02-16 15:56:45 +01:00
}else{
$ret = "failure::txt15#top7";
2021-12-30 12:05:56 +01:00
}
}else{
$ret = "failure::txt15#top5";
}
}elsif($valxx && $valxx =~ /\w+/){
$ret = "failure::txt15#top6";
}
}
}
#sharee txt30=Tarif (multible) and Bonusnummer txt15 automatic
elsif($_ eq "txt30"){
2023-03-10 11:35:56 +01:00
#--> Only done by Operator DMS
if($varenv{dbname} ne $dbt->{primary}->{sharee_primary}->{database}->{dbname}){
2021-12-30 12:05:56 +01:00
my @txt30 = $q->param('txt30');#multiple select sharee Tarif
@txt30 = grep {!/null/} @txt30;
my $bonusnr = $q->escapeHTML("$R::txt15");#on Operator DMS without oprefix-
2023-03-10 11:35:56 +01:00
my $adr_bonus = {
2021-12-30 12:05:56 +01:00
table => "contentadr",
mtime => "now()",
c_id => $c_id,
txt15 => $bonusnr,
txt30_array => \@txt30,
owner => $owner,
ret => $ret,
};
2023-03-10 11:35:56 +01:00
print FILE "Bonusnr set_usertarif done by operator:\n" . Dumper($adr_bonus) . "\n";
$ret = $pl->set_usertarif($dbh,$varenv{dbname},$adr_bonus,"");
2021-12-30 12:05:56 +01:00
}
#phonenr
}elsif($_ eq "txt07"){
$valxx =~ s/[\s\-\/]//g;
my $email = "";
my $phone = "";
$phone = $1 if($valxx =~ /([+0-9]+)/);
if(length($phone) < 9 || length($phone) > 16){
2021-12-30 12:05:56 +01:00
$ret = "failure::$_#top";
}else{
#smsAck reset
if($phone ne $ctadr->{txt07}){
$update_adr->{int13} = 0;
2021-12-30 12:05:56 +01:00
}
$update_adr->{$_} = "$phone";
$email = $q->escapeHTML("$R::txt08");
2021-12-30 12:05:56 +01:00
$email =~ s/\s//g;
my $confirm_digest = sha1_base64($email . $phone);
2023-01-11 06:55:55 +01:00
$confirm_digest =~ s/[I1LO0]//ig;
$update_adr->{txt34} = "$confirm_digest";
2021-12-30 12:05:56 +01:00
}
print FILE "confirm_digest input after substitution: $email . $phone\n" if($debug);
2021-12-30 12:05:56 +01:00
#user alias email
}elsif($_ eq "txt08"){
$valxx =~ s/\s//g;
if($valxx !~ /\w\@\w/){
$ret = "failure::$_#top";
}else{
my $pref_ac = {
table => "contentadr",
fetch => "one",
txt08 => "ilike::$valxx",
c_id => "!=::$c_id",
order => "mtime",
};
my $account_check = $dbt->fetch_tablerecord($dbh,$pref_ac);
print FILE "account_check email:$valxx, c_id:$account_check->{c_id} && $account_check->{c_id} != $c_id\n" if($debug);
2021-12-30 12:05:56 +01:00
if($account_check->{c_id} && $account_check->{c_id} != $c_id){
2022-01-14 19:41:45 +01:00
my $encoded_val = $uri_encode->encode($valxx);
$ret_conflict = "failure::conflict_$_=$encoded_val#top";
2021-12-30 12:05:56 +01:00
}
#mailAck reset
if($valxx ne $ctadr->{txt08}){
$update_adr->{int04} = 0;
2021-12-30 12:05:56 +01:00
}
$update_adr->{$_} = "$valxx";
2021-12-30 12:05:56 +01:00
}
}elsif($_ eq "int05"){#Web-login
$update_adr->{$_} = $valxx;
$update_adr->{txt05} = "" if($valxx != 1);#delete also cookies
}elsif($_ eq "int12" && $varenv{dbname} ne $dbt->{primary}->{sharee_primary}->{database}->{dbname}){
2022-02-23 20:30:12 +01:00
my $vde_on_fail = 0;
$vde_on_fail = 2 if($valxx && $valxx == 1);
$update_adr->{$_} = $vde_on_fail;
2021-12-30 12:05:56 +01:00
}elsif($_ =~ /^int|barcode/){
$update_adr->{$_} = $valxx;
2021-12-30 12:05:56 +01:00
}elsif($_ eq "ct_name" && $R::base_edit){
$update_adr->{$_} = "$valxx";
2022-12-10 15:47:22 +01:00
}elsif($_ =~ /txt22|txt23/){
$valxx =~ s/\s//g;
$update_adr->{$_} = "$valxx";
2021-12-30 12:05:56 +01:00
}elsif($_ !~ /ct_name|txt15/){
$update_adr->{$_} = "$valxx";
2021-12-30 12:05:56 +01:00
}
#Additionals after default updater
#on IBAN/BIC change set override Mandantsreferenz to c_id to trigger payone
if(($_ eq "txt22" && $valxx ne $ctadr->{txt22}) || ($_ eq "txt23" && $valxx ne $ctadr->{txt23})){
$update_adr->{ct_name} = "$c_id";
2021-12-30 12:05:56 +01:00
}
print FILE "-----> $_: $valxx\n" if($debug);
$ret = "failure::$_#top" if(($_ =~ /int14/) && ($valxx eq "null" || !$valxx));#sharee AGB
#Zahlungsart
$ret = "failure::$_#top" if(($_ =~ /int03/) && ($valxx eq "null" || !$valxx));
$ret = "failure::$_#top" if($_ =~ /txt01/ && $valxx !~ /[a-zäöü]+\s+[a-zäöü]+/i);
$ret = "failure::$_#top" if($_ =~ /txt03/ && ($valxx !~ /[\w|\.]+\s+\d+/ && $valxx !~ /\d+\s+[\w|\.]+/));
if($_ =~ /txt04/ && !$pw_dummy){
my $alphacount = 0;
my $alphafail = 0;
$alphacount = () = $valxx =~ /[a-z]/gi;
$alphafail = length($valxx) - $alphacount;
if(!$valxx || length($valxx) < 8 || $alphafail < 2){
$ret = "failure::$_#top";
}
}
$ret = "failure::$_#top" if($_ =~ /txt06/ && $valxx !~ /\d+\s+[a-zäöü]+/i);
$ret = "failure::$_#top" if($_ =~ /txt08/ && $valxx !~ /\w\@\w/);
$ret = "failure::$_#top" if($R::sharee_edit && $_ =~ /txt22/ && $valxx !~ /\w/);
$ret = "failure::$_#top" if($R::sharee_edit && $_ =~ /txt23/ && $valxx !~ /\w/);
}
print FILE "ret: $ret | ret_conflict: $ret_conflict\n" if($debug && ($ret || $ret_conflict));
}#end foreach keyword
$u_rows = 0;
#reread after update
if($ctadr->{c_id} > 0){
$u_rows = $dbt->update_record($dbh,$update_adr,$ctadr);
$ctadr = $dbt->fetch_record($dbh,$authref);
}
2021-12-30 12:05:56 +01:00
#payone only if SEPA Mandat checked
#Testbuchhung mit 1 € preauthorization and 0 € capture
#print FILE "+++ $R::request && $ctadr->{int03} == 1 && $ctadr->{ct_name} eq $ctadr->{c_id} \n" if($debug);
#if($R::request eq "managemandate" && $ctadr->{int03} == 1 && $ctadr->{ct_name} eq $ctadr->{c_id})
2022-09-29 17:27:02 +02:00
#fraud workaround
my $iban = $ctadr->{txt22} || "";
$iban =~ s/\s//g;
my $iban_reject = 0;
$iban_reject = 1 if($iban =~ /DE33700202700000091600/i);
if($R::request eq "managemandate" && $ctadr->{int03} == 1 && !$iban_reject){
2022-09-29 17:27:02 +02:00
2021-12-30 12:05:56 +01:00
my $vde_on_fail = $ctadr->{int12} || 3;#keep last or set 3
#check if iban from another user has Vde
my $pref_ac = {
table => "contentadr",
fetch => "one",
txt22 => "$iban",
int12 => ">=::1",
c_id => "!=::$c_id",
order => "mtime",
};
my $account_check = $dbt->fetch_tablerecord($dbh,$pref_ac);
print FILE "account_check iban:$iban, c_id:$account_check->{c_id} && $account_check->{c_id} != $c_id\n" if($debug);
if($account_check->{c_id} && $account_check->{c_id} != $c_id){
my $encoded_val = $uri_encode->encode($iban);
$ret_conflict = "failure::conflict_txt22=$encoded_val#top";
}
2021-12-30 12:05:56 +01:00
my $payone_mival = $payone->managemandate_main(\%varenv,$ctadr,"",$owner);
if($payone_mival && $payone_mival =~ /\w{2}-\d+/){
#define fictiv invoice to get 1 € test
my $epoche = time();
my $ctt = {
c_id => 1,
int01 => 0,
int15 => 1,
txt16 => "",
reference => "$ctadr->{c_id}_$epoche",
2022-02-22 08:31:35 +01:00
payone_reset => ''
2021-12-30 12:05:56 +01:00
};
2022-01-16 12:17:11 +01:00
2021-12-30 12:05:56 +01:00
my $payone_txid = "";
2022-01-16 12:17:11 +01:00
##preauthorization and/or capture needs to much time, must be done async!
#$payone_txid = $payone->preauthorizationSEPA_main(\%varenv,$ctadr,$ctt,$owner);
#if($payone_txid)
if(1==1){
2021-12-30 12:05:56 +01:00
$ctt->{txt16} = "$payone_txid";
$vde_on_fail = 0 if($vde_on_fail != 2);
$u_rows = $dbt->update_one($dbh,$update_adr,"int12=$vde_on_fail");#Vde
2022-01-16 12:17:11 +01:00
#$payone_txid = $payone->captureSEPA_main(\%varenv,$ctadr,$ctt,$owner);
#int12=0 should be set after capture success in payment module
2021-12-30 12:05:56 +01:00
}else{
$u_rows = $dbt->update_one($dbh,$update_adr,"int12=$vde_on_fail");#Vde
2021-12-30 12:05:56 +01:00
}
}else{
$u_rows = $dbt->update_one($dbh,$update_adr,"int12=$vde_on_fail");#Vde
2021-12-30 12:05:56 +01:00
}
}
#prepaid
elsif($ctadr->{int03} == 3){
$feedb = $pl->prepaid_request($dbh,$ctadr,$owner);
$u_rows = $dbt->update_one($dbh,$update_adr,"ct_name='Prepay-$feedb->{prepaid_account}'");#Vde
2021-12-30 12:05:56 +01:00
}
if($R::txt04 && $R::confirm_txt04 && $R::txt04 ne $R::confirm_txt04){
$ret = "failure::confirm_txt04#top";
}
if($ret =~ /failure::(\w+)/ && $ret !~ /txt15|txt16/){#persistent failure without Bonus or Gutschein
my $rval = $1;
#$rval =~ s/pwlazy_//g;#obsolet, all done in pw template description
$rval =~ s/confirm_//g;#PW confirm
$rval =~ s/conflict_//g;#conflict
print FILE "ret: $ret | rval: $rval\n" if($debug);
$dbt->update_one($dbh,$update_adr,"txt31='$rval'");
2021-12-30 12:05:56 +01:00
}elsif($fkeys =~ /$ctadr->{txt31}/){
print FILE " No failure and empty txt31 (fkeys: $fkeys =~ /$ctadr->{txt31}/) \n" if($debug);
$u_rows = $dbt->update_one($dbh,$update_adr,"txt31=''");
2021-12-30 12:05:56 +01:00
}
$ret = $ret_conflict if($ret_conflict);
print FILE "final ret: $ret \n" if($debug);
#update operator with primary data after COPRI address edit
$dbt->update_operatorsloop($varenv{dbname},$ctadr->{c_id},"update");
2023-01-17 20:43:36 +01:00
$feedb->{u_rows} = $u_rows;
print FILE Dumper($feedb) . "\n" if($debug);
close(FILE) if($debug);
return ($ret,$feedb);
}#end save_account
2021-12-30 12:05:56 +01:00
#coupon alias Gutschein
sub save_transact(){
my $self = shift;
2023-03-05 20:01:47 +01:00
my $q = shift;
my $c_id = shift || "";
my $coo = shift || "";
my $owner = shift || "";
2021-12-30 12:05:56 +01:00
$q->import_names('R');
my @keywords = $q->param;
my $now_dt = strftime "%Y-%m-%d %H:%M:%S", localtime;
my %varenv = $cf->envonline();
$bw->log("save_transact",$q,"");
my $debug=1;
my $dbh = "";#keep in mind, empty dbh defaults to local copri-instance dbname
open(FILE,">>$varenv{logdir}/save_account.log") if($debug);
print FILE "\n*-->local copri-Instance DB $varenv{dbname} $now_dt| c_id: $c_id \n" if($debug);
my $authref = {
table => "contentadr",
fetch => "one",
template_id => "202",
c_id => "$c_id",
};
my $ctadr = $dbt->fetch_record($dbh,$authref);
my $pos_id="";
my $ret;
my $fkeys;
foreach(@keywords){
$fkeys .= "$_,";
my $val = $q->param($_);
my $valxx = $q->escapeHTML("$val");
#print "|$_: $valxx";
$valxx =~ s/^\s+//;
$valxx =~ s/\s+$//;
#Gutschein
if($_ eq "txt16"){
#forgotten prefix workaround
$valxx = "SX-" . $valxx if($valxx =~ /sigoinpassau|EMW2022/i && $valxx !~ /^SX-/i);
2021-12-30 12:05:56 +01:00
print FILE "Gutschein request $_: $valxx\n" if($debug);
if($valxx && $valxx =~ /^(\w{2,3})-(\w+)/){
2021-12-30 12:05:56 +01:00
$valxx =~ s/\s//g;
my $coupon_prefix = uc($1),
my $coupon_nr = $2;
my $operator_conf = $dbt->get_operator_conf($coupon_prefix);
if(ref($operator_conf) eq "HASH" && $operator_conf->{oprefix} && $operator_conf->{database}->{dbname}){
print FILE "Gutschein $valxx : " . $operator_conf->{oprefix} . " " . $operator_conf->{database}->{dbname} . "\n" if($debug);
my $dbh_operator = $dbt->dbconnect_extern($operator_conf->{database}->{dbname});
#to get operator coupon_nr
my $pref_co = {
table => "content",
fetch => "one",
template_id => "224",
int03 => ">::0",
2022-02-10 16:45:22 +01:00
ct_name => "ilike::$coupon_nr",
2021-12-30 12:05:56 +01:00
};
my $ct = { c_id => 0 };
$ct = $dbt->fetch_record($dbh_operator,$pref_co);
$ct->{int02} *= -1 if($ct->{int02} > 0);#coupon price must be negate
print FILE "txt16=$coupon_nr, unit_price $ct->{int02} --> requested on web on: $operator_conf->{database}->{dbname} --> barcode:$ct->{barcode}\n" if($debug);
if($ct->{c_id}){
my $ctadr_operator = { c_id => 0 };
$ctadr_operator = $dbt->fetch_record($dbh_operator,$authref);
if(!$ctadr_operator->{c_id}){
2022-05-17 06:13:53 +02:00
my %operator_hash = ();
if($ctadr->{txt17} && $ctadr->{txt17} =~ /\w\s\w/){#append DB's
%operator_hash = map { $_ => 1 } split(/\s+/,$ctadr->{txt17});
}elsif($ctadr->{txt17}){
$operator_hash{$ctadr->{txt17}} = 1;
}
$operator_hash{$operator_conf->{database}->{dbname}} = 1;
my @operator_array = keys %operator_hash;
$bw->log("save_transact update operator keys by array: @operator_array",\%operator_hash,"");
print FILE "save_transact update operator keys by array: @operator_array | pri $ctadr->{c_id}\n" if($debug);
my $update_primary = {
table => "contentadr",
txt17 => "@operator_array",#operator ids
txt19 => "$operator_conf->{database}->{dbname}",
atime => "now()",
owner => "198",#update initiated by primary
};
my $rows = $dbt->update_record($dbh,$update_primary,$ctadr);
2021-12-30 12:05:56 +01:00
print FILE "Gutschein oprefix address INSERT adr from record_primary to operator $operator_conf->{database}->{dbname} , c_id:$ctadr->{c_id}\n";
my $insert_op = {
%$ctadr,
table => "contentadr",
mtime => 'now()',
owner => "198",
};
my $c_id_op = $dbt->insert_contentoid($dbh_operator,$insert_op,"reset_adropkeys");
}
$ctadr_operator = $dbt->fetch_record($dbh_operator,$authref);
if($ctadr_operator->{c_id} > 0){
my $pref = {
table => "contenttrans",
fetch => "one",
main_id => 300008,
2021-12-30 12:05:56 +01:00
template_id => 218,
ca_id => "$ctadr_operator->{c_id}",
#int10 => "$ctadr_operator->{c_id}",#deprecated
2021-12-30 12:05:56 +01:00
state => "is::null",
close_time => "is::null",
};
my $ctt = { c_id => 0 };
$ctt = $dbt->fetch_record($dbh_operator,$pref);
2022-05-11 19:01:13 +02:00
my $posref = {
table => "contenttrans",
table_pos => "contenttranspos",
fetch => "one",
keyfield => "c_id",
ca_id => "$ctadr->{c_id}",
ct_name => "ilike::$valxx",
};
my $cttpos = { c_id => 0 };
$cttpos = $dbt->collect_post($dbh_operator,$posref);
#check if user has still coupon used
if(!$cttpos->{c_id}){
2022-05-11 19:01:13 +02:00
if($ctt->{c_id} > 0){
$pos_id = $dbt->insert_pos($dbh_operator,$ctt->{c_id},$ct,"",$ctadr_operator,"","",$valxx,"0",$owner,"");
2022-05-11 19:01:13 +02:00
}else{
my $ct_id = {c_id => 0};
$ct_id = $dbt->insert_contenttrans($dbh_operator,$ctadr_operator,"300008","218","----",$owner);
2023-04-27 15:09:16 +02:00
$pos_id = $dbt->insert_pos($dbh_operator,$ct_id,$ct,"",$ctadr_operator,"","",$valxx,"0",$owner);
2022-05-11 19:01:13 +02:00
}
}else{
$ret = "failure::conflict_txt16#top";
}
2021-12-30 12:05:56 +01:00
if($pos_id){
$ret = "success::txt16";
$dbt->update_content4comp($dbh_operator,$ct->{c_id},"-","1");
}
}else{
$ret = "failure::txt16#top";
}
}else{
$ret = "failure::txt16#top";
}
}
}elsif($valxx && $valxx =~ /\w+/){
$ret = "failure::txt16#top";
}
}
}
print FILE "save_transact ret: $ret \n" if($debug);
close(FILE) if($debug);
return $ret;
}#end save_transact
#Send sms after payable check and !int13
sub smsack {
2021-12-30 12:05:56 +01:00
my $self = shift;
my $ctadr = shift;
$smstrans->sms_ack_digest($ctadr);
return;
2021-12-30 12:05:56 +01:00
}
#Send email after payable check and !int04
sub emailack {
2021-12-30 12:05:56 +01:00
my $self = shift;
my $varenv = shift;
my $adr_id = shift || "";
system("$dbt->{copri_conf}->{basedir}/$varenv->{syshost}/src/scripts/mailTransportcms.pl '$varenv->{syshost}' 'send_emailack' '$adr_id' ''");
return;
2021-12-30 12:05:56 +01:00
}
#Password forgotten send email
sub send_password {
2021-12-30 12:05:56 +01:00
my $self = shift;
my $varenv = shift;
my $email = shift || "";
my $coo = shift || "";
my $owner = shift || "";
my $dbh = "";
2021-12-30 12:05:56 +01:00
$email = $q->escapeHTML($email);
$email =~ s/\s//g;
my $pwmd5 = md5_hex($coo) || "";
2021-12-30 12:05:56 +01:00
2022-11-21 12:21:39 +01:00
if($email && $email =~ /\w\@\w/ && $pwmd5 && length($pwmd5) > 20 && $email !~ /$dbt->{copri_conf}->{test_accounts}/i){
my $pwsha256=sha256_base64($pwmd5) || "";
my $authref = {
table => "contentadr",
fetch => "one",
template_id => "202",
txt08 => "ilike::" . $q->escapeHTML($email),
int05 => "1",
};
my $ctadr = { c_id => 0 };
$ctadr = $dbt->fetch_record($dbh,$authref);
my $c_id = $ctadr->{c_id};
2022-03-12 08:21:41 +01:00
my $update_primary = {
table => "contentadr",
mtime => "now()",
owner => "$owner",
txt04 => "$pwsha256",
};
$dbt->update_record($dbh,$update_primary,$ctadr) if($c_id > 0);
system("$dbt->{copri_conf}->{basedir}/$varenv->{syshost}/src/scripts/mailTransportcms.pl '$varenv->{syshost}' 'send_password' '$c_id' '' '$coo'");
}
return;
2021-12-30 12:05:56 +01:00
}
2022-05-11 08:05:35 +02:00
#sigbike just like caching and not realy used by app
sub sigbike_cupdate {
2022-04-04 14:57:43 +02:00
my $self = shift;
2022-05-11 08:05:35 +02:00
my $record_sig = shift;
2022-04-04 14:57:43 +02:00
my $dbh = "";
my $rows = 0;
2022-05-11 08:05:35 +02:00
foreach my $bid (keys (%$record_sig)){
2022-04-04 14:57:43 +02:00
my $update = {
2022-05-11 08:05:35 +02:00
%{$record_sig->{$bid}},
2022-04-04 14:57:43 +02:00
table => "content",
template_id => "205",
2022-08-06 10:47:06 +02:00
#main_id => "300102",#set by APIsigclient
2022-04-04 14:57:43 +02:00
mtime => "now()",
owner => "169",
};
2022-05-11 08:05:35 +02:00
$rows = $dbt->update_record($dbh,$update,$record_sig->{$bid});
2022-07-27 14:38:06 +02:00
$bw->log("rows: $rows | sigbike_cupdate content from record_sig with bike nr:",$update,"");
2022-04-04 14:57:43 +02:00
if($rows != 1){
my $c_id = "";
2022-04-05 12:29:58 +02:00
$update->{itime} = "now()";
2022-05-11 08:05:35 +02:00
$bw->log("INSERT content from record_sig with bike nr:",$update,"");
2022-04-05 12:29:58 +02:00
$c_id = $dbt->insert_contentoid($dbh,$update,"");
$rows = 1 if($c_id);
}
}
return $rows;
}
2022-05-11 08:05:35 +02:00
#sigstation just like caching and not realy used by app
sub sigstation_cupdate {
2022-04-05 12:29:58 +02:00
my $self = shift;
2022-05-11 08:05:35 +02:00
my $record_sig = shift;
2022-04-05 12:29:58 +02:00
my $dbh = "";
my $rows = 0;
2022-05-11 08:05:35 +02:00
foreach my $sid (keys (%$record_sig)){
2022-04-05 12:29:58 +02:00
my $update = {
2022-05-11 08:05:35 +02:00
%{$record_sig->{$sid}},
2022-04-05 12:29:58 +02:00
table => "content",
template_id => "225",
main_id => "300016",
mtime => "now()",
owner => "169",
};
2022-05-11 08:05:35 +02:00
$rows = $dbt->update_record($dbh,$update,$record_sig->{$sid});
2022-07-27 14:38:06 +02:00
$bw->log("rows: $rows | sigstation_cupdate content from record_sig with bike nr:",$update,"");
2022-04-05 12:29:58 +02:00
if($rows != 1){
my $c_id = "";
$update->{itime} = "now()";
2022-05-11 08:05:35 +02:00
$bw->log("INSERT content from record_sig with bike nr:",$update,"");
2022-04-05 12:29:58 +02:00
$c_id = $dbt->insert_contentoid($dbh,$update,"");
2022-04-04 14:57:43 +02:00
$rows = 1 if($c_id);
}
}
return $rows;
}
2021-12-30 12:05:56 +01:00
1;