mirror of
https://gitlab.com/t6353/sharee.bike.git
synced 2024-05-18 14:56:35 +02:00
439 lines
12 KiB
Perl
Executable file
439 lines
12 KiB
Perl
Executable file
#!/usr/bin/perl
|
|
#
|
|
# SPDX-License-Identifier: AGPL-3.0-or-later
|
|
# Copyright (c) Rainer Gümpelein, TeilRad GmbH
|
|
#
|
|
#managed text by operator cms
|
|
#
|
|
#Example
|
|
#./src/scripts/mailTransportcms.pl 'shareedms-operator' 'send_alarm2hotline' '[user.c_id]' '[contenttxxxx.c_id]'
|
|
#
|
|
#
|
|
#
|
|
use vars qw($syshost);
|
|
|
|
BEGIN {
|
|
$syshost = $ARGV[0] || die 'syshost not defined';
|
|
}
|
|
|
|
use lib "/var/www/copri-bike/$syshost/src";
|
|
|
|
use strict;
|
|
use warnings;
|
|
use utf8;
|
|
use Encode;
|
|
use POSIX;
|
|
use DateTime;
|
|
use DateTime::Format::Pg;
|
|
use Scalar::Util qw(looks_like_number);
|
|
use Lib::Config;
|
|
use Mod::DBtank;
|
|
use Mod::MailTransport;
|
|
use Data::Dumper;
|
|
my $cf = new Config;
|
|
my %varenv = $cf->envonline();
|
|
|
|
my $dbt = new DBtank;
|
|
my $mailtrans = new MailTransport;
|
|
my $now_dt = strftime "%Y.%m.%d %H:%M:%S", localtime;
|
|
|
|
#one contentadr.c_id OR email on command
|
|
my $todo = $ARGV[1] || "";
|
|
my $adr_id = $ARGV[2] || "";
|
|
my $ct_id = $ARGV[3] || "";
|
|
my $temppw = $ARGV[4] || "";
|
|
|
|
open(EMA, ">> $dbt->{copri_conf}->{logdir}/mailTransportcms.log");
|
|
print EMA "\n$now_dt, start mailTransportcms.pl syshost: $syshost, todo:$todo, adr_id:$adr_id, ct_id:$ct_id, temppw:$temppw\n";
|
|
|
|
|
|
#mailxcfg is shareeconf/mailx.cfg <block> selection!
|
|
#hash data to send
|
|
my $sendref = {
|
|
mailxcfg => "mailx_default",
|
|
#mailxcfg => "mailx_admin",#just for tests
|
|
syshost => "$syshost",
|
|
mail_to => "",
|
|
c_id => 0,
|
|
subject => "",
|
|
message => "",
|
|
signature => "",
|
|
attachment => "",
|
|
};
|
|
|
|
my $oprefix = $dbt->{operator}->{$varenv{dbname}}->{oprefix} || "";
|
|
my $sendmail = {};
|
|
|
|
#user-account must be exist to send user message
|
|
my $ctadr = { c_id => 0 };
|
|
if(looks_like_number($adr_id)){
|
|
my $dbh_primary = $dbt->dbconnect_extern($dbt->{primary}->{sharee_primary}->{database}->{dbname},"iso-8859-1");
|
|
my $pref_adr = {
|
|
table => "contentadr",
|
|
fetch => "one",
|
|
c_id => "$adr_id",
|
|
};
|
|
$ctadr = $dbt->fetch_tablerecord($dbh_primary,$pref_adr);
|
|
|
|
#send_invoice
|
|
if($todo eq "send_invoice" && looks_like_number($ct_id)){
|
|
$sendref->{mailxcfg} = "mailx_rechnung";
|
|
$sendmail = send_invoice($todo,$sendref,$ctadr,$ct_id);
|
|
}
|
|
|
|
#send_emailack
|
|
if($todo eq "send_emailack"){
|
|
$sendmail = send_emailack($todo,$sendref,$ctadr);
|
|
}
|
|
|
|
#send_password
|
|
if($todo eq "send_password"){
|
|
$sendmail = send_password($todo,$sendref,$ctadr,$temppw);
|
|
}
|
|
|
|
#send_cpdate_message, done by cronjob cpdate_check.pl
|
|
if(($todo eq "send_cpupdate_message" || $todo eq "send_proactive_cpupdate_message")){
|
|
$sendmail = send_cpupdate_message($todo,$sendref,$ctadr);
|
|
}
|
|
}#end user-account message
|
|
|
|
#send_alarm2hotline, done by Ilockit_cloud.pl
|
|
if($todo eq "send_alarm2hotline" && looks_like_number($ct_id)){
|
|
$sendmail = send_alarm2hotline($sendref,$ct_id);
|
|
}
|
|
|
|
#send_occupied2hotline 78h, done by cronjob
|
|
if($todo eq "send_occupied2hotline"){
|
|
$sendmail = send_occupied2hotline($sendref);
|
|
}
|
|
|
|
if($sendmail->{c_id}){
|
|
sendmailjob($sendmail);
|
|
}else{
|
|
print EMA "Error, can not sendmailjob without c_id\n";
|
|
}
|
|
|
|
#send_invoice
|
|
sub send_invoice {
|
|
my $todo = shift;
|
|
my $sendref = shift;
|
|
my $ctadr = shift;
|
|
my $ct_id = shift;
|
|
|
|
my $project = $dbt->{operator}->{$varenv{dbname}}->{project} || "";
|
|
my $dbh_primary = $dbt->dbconnect_extern($dbt->{primary}->{sharee_primary}->{database}->{dbname},"iso-8859-1");
|
|
my $pref_ctu = {
|
|
table => "contentuser",
|
|
fetch => "one",
|
|
c_id => "1",#primary hotline#TODO change to Kunden-Fakture, check tablefields
|
|
};
|
|
my $uadr = { c_id => 0 };
|
|
$uadr = $dbt->fetch_tablerecord($dbh_primary,$pref_ctu);
|
|
|
|
$varenv{cms} = $dbt->fetch_cms($dbh_primary,{ lang => $ctadr->{txt10} });
|
|
my $cms_message_key = "email-invoice";
|
|
|
|
my $dbh = $dbt->dbconnect_extern($dbt->{operator}->{$varenv{dbname}}->{database}->{dbname},"iso-8859-1");
|
|
my $fetchctt = {
|
|
table => "contenttrans",
|
|
fetch => "one",
|
|
c_id => "=::$ct_id",
|
|
};
|
|
my $ctt = { c_id => 0 };
|
|
$ctt = $dbt->fetch_tablerecord($dbh,$fetchctt);
|
|
|
|
$sendref = prepare_content($sendref,$ctadr,$uadr,$ctt,$varenv{cms}->{$cms_message_key}->{txt});
|
|
|
|
my $updatectt = {
|
|
table => "contenttrans",
|
|
c_id => "$ct_id",
|
|
};
|
|
$dbt->update_one($dbh,$updatectt,"txt30='$now_dt, $ctt->{txt00} per eMail versandt'");
|
|
|
|
return $sendref;
|
|
}#end send_invoice
|
|
|
|
|
|
#send_emailack
|
|
sub send_emailack {
|
|
my $todo = shift;
|
|
my $sendref = shift;
|
|
my $ctadr = shift;
|
|
|
|
my $dbh_primary = $dbt->dbconnect_extern($dbt->{primary}->{sharee_primary}->{database}->{dbname},"iso-8859-1");
|
|
my $pref_ctu = {
|
|
table => "contentuser",
|
|
fetch => "one",
|
|
c_id => "1",#primary hotline
|
|
};
|
|
my $uadr = { c_id => 0 };
|
|
$uadr = $dbt->fetch_tablerecord($dbh_primary,$pref_ctu);
|
|
|
|
$varenv{cms} = $dbt->fetch_cms($dbh_primary,{ lang => $ctadr->{txt10} });
|
|
my $cms_message_key = "email-emailack";
|
|
|
|
#Ack digest
|
|
if($ctadr->{txt34} =~ /^(.{5})/){
|
|
$ctadr->{txt34} = $1;
|
|
}else{
|
|
$ctadr->{txt34} = "";
|
|
}
|
|
|
|
$sendref = prepare_content($sendref,$ctadr,$uadr,"",$varenv{cms}->{$cms_message_key}->{txt});
|
|
|
|
return $sendref;
|
|
}#end send_emailack
|
|
|
|
#send_password
|
|
sub send_password {
|
|
my $todo = shift;
|
|
my $sendref = shift;
|
|
my $ctadr = shift;
|
|
my $temppw = shift;
|
|
|
|
my $dbh_primary = $dbt->dbconnect_extern($dbt->{primary}->{sharee_primary}->{database}->{dbname},"iso-8859-1");
|
|
my $pref_ctu = {
|
|
table => "contentuser",
|
|
fetch => "one",
|
|
c_id => "1",#primary hotline
|
|
};
|
|
my $uadr = { c_id => 0 };
|
|
$uadr = $dbt->fetch_tablerecord($dbh_primary,$pref_ctu);
|
|
|
|
$varenv{cms} = $dbt->fetch_cms($dbh_primary,{ lang => $ctadr->{txt10} });
|
|
my $cms_message_key = "email-temppassword";
|
|
|
|
#temp pw
|
|
if($temppw){
|
|
$ctadr->{txt04} = $temppw;
|
|
}else{
|
|
$ctadr->{txt04} = "";
|
|
}
|
|
|
|
$sendref = prepare_content($sendref,$ctadr,$uadr,"",$varenv{cms}->{$cms_message_key}->{txt});
|
|
|
|
return $sendref;
|
|
}#end send_password
|
|
|
|
#send_cpupdate_message
|
|
sub send_cpupdate_message {
|
|
my $todo = shift;
|
|
my $sendref = shift;
|
|
my $ctadr = shift || {};
|
|
|
|
my $dbh_primary = $dbt->dbconnect_extern($dbt->{primary}->{sharee_primary}->{database}->{dbname},"iso-8859-1");
|
|
|
|
my $pref_ctu = {
|
|
table => "contentuser",
|
|
fetch => "one",
|
|
c_id => "1",#primary hotline
|
|
};
|
|
my $uadr = { c_id => 0 };
|
|
$uadr = $dbt->fetch_tablerecord($dbh_primary,$pref_ctu);
|
|
|
|
$varenv{cms} = $dbt->fetch_cms($dbh_primary,{ lang => $ctadr->{txt10} });
|
|
my $cms_message_key = "email-cpupdate-message";
|
|
$cms_message_key = "email-proactive-cpupdate-message" if($todo eq "send_proactive_cpupdate_message");
|
|
$sendref = prepare_content($sendref,$ctadr,$uadr,"",$varenv{cms}->{$cms_message_key}->{txt});
|
|
|
|
return $sendref;
|
|
}#end send_cpupdate_message
|
|
|
|
|
|
#send_alarm2hotline
|
|
sub send_alarm2hotline {
|
|
my $sendref = shift;
|
|
my $ct_id = shift || "";
|
|
|
|
my $dbh = $dbt->dbconnect_extern($dbt->{operator}->{$varenv{dbname}}->{database}->{dbname},"iso-8859-1");
|
|
my $pref_ctu = {
|
|
table => "contentuser",
|
|
fetch => "one",
|
|
c_id => "1",#primary hotline
|
|
};
|
|
my $uadr = { c_id => 0 };
|
|
$uadr = $dbt->fetch_tablerecord($dbh,$pref_ctu);
|
|
$sendref->{mail_to} = $uadr->{txt08};
|
|
|
|
#without cms
|
|
my $cms_prim = { c_id => 0, txt01 => 'Folgendes Mietrad hat einen Diebstahlalarm ausgelöst' };
|
|
|
|
my $pref_ct = {
|
|
table => "contenttheftpos",
|
|
fetch => "one",
|
|
c_id => $ct_id,
|
|
};
|
|
|
|
my $ct = { c_id => 0 };
|
|
$ct = $dbt->fetch_tablerecord($dbh,$pref_ct);
|
|
|
|
$sendref->{c_id} = $ct->{c_id};
|
|
$sendref->{subject} = "Diebstahlalarm $oprefix$ct->{barcode}";
|
|
|
|
$sendref->{message} = <<EOF
|
|
$cms_prim->{txt01}
|
|
|
|
Bike: $oprefix$ct->{barcode}
|
|
Speed: $ct->{int07}
|
|
Meter: $ct->{int08}
|
|
GPS: $ct->{txt06}
|
|
Timestamp: $ct->{start_time}
|
|
|
|
Öffne das Alarmjournal für weitere Informationen:
|
|
<a href='$dbt->{operator}->{$varenv{dbname}}->{operatorDMS}/DMS/Alarmjournal'>$dbt->{operator}->{$varenv{dbname}}->{operatorDMS}/DMS/Alarmjournal</a>
|
|
|
|
Freundliche Grüße,
|
|
--
|
|
$uadr->{txt01}
|
|
$uadr->{txt03}
|
|
$uadr->{txt06}
|
|
|
|
$uadr->{txt84}
|
|
|
|
EOF
|
|
;
|
|
|
|
$sendref->{message} =~ s/\n/\<br \/\>/g;
|
|
return $sendref;
|
|
}#end send_alarm2hotline
|
|
|
|
#send_occupied2hotline
|
|
sub send_occupied2hotline {
|
|
my $sendref = shift;
|
|
my $ct_id = shift || "";
|
|
|
|
my $dbh = "";
|
|
my $pref_ctu = {
|
|
table => "contentuser",
|
|
fetch => "one",
|
|
c_id => "1",#primary hotline
|
|
};
|
|
my $uadr = { c_id => 0 };
|
|
$uadr = $dbt->fetch_tablerecord($dbh,$pref_ctu);
|
|
$sendref->{mail_to} = $uadr->{txt08};
|
|
|
|
my $search = {
|
|
table => "contenttranspos",
|
|
int10 => 3,
|
|
#int33 => 3,#marker for sending 3. SMS
|
|
int34 => "null",#not staff
|
|
start_time_interval => "(now() - interval '78 hour')",
|
|
};
|
|
|
|
my $cttpos = { c_id => 0 };
|
|
$cttpos = $dbt->collect_transpos($dbh,$search);
|
|
|
|
my $bike = "";
|
|
foreach my $pid (sort { $cttpos->{$b}->{end_time} cmp $cttpos->{$a}->{end_time} } keys(%$cttpos)){
|
|
|
|
$bike .= $oprefix . $cttpos->{$pid}->{barcode} . "\n";
|
|
$sendref->{c_id} = $cttpos->{$pid}->{cc_id};#just one
|
|
print "$bike $sendref->{c_id}";
|
|
|
|
}
|
|
|
|
if($bike){
|
|
$bike =~ s/,$//;
|
|
$sendref->{subject} = "konrad über 78 Stunden occupied";
|
|
|
|
$sendref->{message} = <<EOF
|
|
Hallo,
|
|
|
|
folgende konräder sind seit über 3 Tagen gemietet:
|
|
$bike
|
|
Bitte MieterInnen kontaktieren und den verbleib klären.
|
|
|
|
Grüße vom cron
|
|
|
|
EOF
|
|
;
|
|
|
|
$sendref->{message} =~ s/\n/\<br \/\>/g;
|
|
return $sendref;
|
|
}
|
|
return;
|
|
}
|
|
|
|
#prepare email by cms markup
|
|
sub prepare_content {
|
|
my $sendref = shift;
|
|
my $ctadr = shift;
|
|
my $uadr = shift;
|
|
my $ctt = shift || {};
|
|
my $cms_prim = shift;
|
|
|
|
my $globalconf_file = "/var/www/copri4/shareeconf/global.cfg";
|
|
my $conf = Config::General->new($globalconf_file);
|
|
my %globalconf = $conf->getall;
|
|
|
|
my $app_name = "Mietrad App";
|
|
#while (my ($key, $merchant) = each %{ $globalconf{merchant_ids} }) {
|
|
# $app_name =~ s/$app_name/$merchant->{app_name}/ if($merchant->{app_name} && $ctadr->{int15} && $ctadr->{int15} == $merchant->{id});
|
|
#}
|
|
$app_name = $dbt->{operator}->{$varenv{dbname}}->{app_name};
|
|
my $invoice_name = "$ctt->{txt00}-$varenv{dbname}-$ctt->{ct_name}.pdf";
|
|
$sendref->{attachment} = "$invoice_name";
|
|
|
|
my $subject = "TeilRad Mietradsystem";#default
|
|
$subject = $1 if($cms_prim =~ /--subject--(.*)--subject--/);
|
|
$cms_prim =~ s/--subject--$subject--subject--//;
|
|
$cms_prim =~ s/\n//;
|
|
$cms_prim =~ s/\n//;
|
|
|
|
my $signature = <<EOF
|
|
--
|
|
$uadr->{txt01}
|
|
$uadr->{txt03}
|
|
$uadr->{txt06}
|
|
$uadr->{txt07}
|
|
$uadr->{txt08}
|
|
|
|
$uadr->{txt84}
|
|
|
|
EOF
|
|
;
|
|
|
|
$sendref->{mail_to} = $ctadr->{txt08};
|
|
$sendref->{c_id} = $ctadr->{c_id};
|
|
$sendref->{subject} = $subject;
|
|
$sendref->{subject} =~ s/::app_name::/$app_name/;
|
|
$sendref->{subject} =~ s/Mein // if($sendref->{subject} =~ /^Mein/);
|
|
|
|
$sendref->{message} = $cms_prim;
|
|
$sendref->{message} =~ s/::user_name::/$ctadr->{txt01}/;
|
|
$sendref->{message} =~ s/::app_name::/$app_name/g;
|
|
$sendref->{message} =~ s/::invoice_name::/$invoice_name/;
|
|
$sendref->{message} =~ s/::txid::/$ctt->{txt16}/;
|
|
$sendref->{message} =~ s/::email_temppassword::/\<b\>$ctadr->{txt04}\<\/b\>/g;
|
|
$sendref->{message} =~ s/::email_ack_digest::/\<b\>$ctadr->{txt34}\<\/b\>/g;
|
|
$sendref->{message} =~ s/::signature::/$signature/;
|
|
$sendref->{message} =~ s/\n/\<br \/\>/g;
|
|
|
|
return $sendref;
|
|
}#end prepare_content
|
|
|
|
|
|
#sending mail job
|
|
sub sendmailjob {
|
|
my $sendref = shift || "";
|
|
my $dbh = "";
|
|
|
|
#at first connect mailxchanger by mailx.cfg config
|
|
my ($smtp,$mailxconf) = $mailtrans->mail_connect($sendref);
|
|
|
|
#one mailing with mail address on command
|
|
if($sendref->{mail_to} =~ /\w\@\w/ && $sendref->{subject} && $sendref->{message}){
|
|
my $ret = "";
|
|
$ret = $mailtrans->mail_transport($smtp,$mailxconf,$sendref);
|
|
|
|
print EMA "done mailing with state to $sendref->{mail_to}: $ret\n";
|
|
print EMA Dumper($sendref);
|
|
}else{
|
|
print EMA "Error, no or false email:\n$sendref->{mail_to}\n$sendref->{subject}\n$sendref->{message}, exit\n";
|
|
}
|
|
}
|
|
|
|
print EMA "\n\n";
|
|
close EMA;
|
|
|