FHEM/fhem-mirror
2
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-03-03 16:56:54 +00:00
Code Issues Releases Wiki Activity

93_DbRep: contrib 8.50.0

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@26311 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
nasseeder1 2022-08-11 20:18:11 +00:00
parent d872ed2197
commit ed2de77208
1 changed files with 103 additions and 63 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

140
fhem/contrib/DS_Starter/93_DbRep.pm
View File

@ -9286,14 +9286,16 @@ sub _DbRep_rl_deleteDayRows {
$sth_del->execute(($delRow->[1], $delRow->[3], $delRow->[0], $delRow->[4]));
$i++;
if($i == $th) {
my $prog = $k * $i;
my $params = {
name => $name,
logtxt => "deletion",
iref => \$i,
kref => \$k,
th => $th,
processingDay => $processingDay
};
Log3 ($name, 3, "DbRep $name - reduceLog deletion progress of day: $processingDay is: $prog");
$i = 0;
$k++;
}
_DbRep_logProgress ($params);
#}
}
1;
@ -9354,8 +9356,9 @@ sub _DbRep_rl_updateHour {
Log3 ($name, 3, "DbRep $name - reduceLog (hourly-$mstr) updating $c records of day: $processingDay") if($c);
my $sum = 0;
my $max;
my $params;
my $sum = 0;
my $i = 0;
my $k = 1;
my $th = _DbRep_rl_logThreshold ($c);
@ -9394,14 +9397,16 @@ sub _DbRep_rl_updateHour {
$i++;
if($i == $th) {
my $prog = $k * $i;
$params = {
name => $name,
logtxt => "(hourly-$mstr) updating",
iref => \$i,
kref => \$k,
th => $th,
processingDay => $processingDay
};
Log3 ($name, 3, "DbRep $name - reduceLog (hourly-$mstr) updating progress of day: $processingDay is: $prog");
$i = 0;
$k++;
}
_DbRep_logProgress ($params);
if ($mode =~ /=day/i) { # timestamp, event, value, device, reading, Date
push(@$updateDayref, ["$updDate $updHour:$minutes", $event, $value, $hourHash->{$hourKey}->[1], $hourHash->{$hourKey}->[3], $updDate]);
@ -9434,14 +9439,16 @@ sub _DbRep_rl_updateHour {
$i++;
if($i == $th) {
my $prog = $k * $i;
$params = {
name => $name,
logtxt => "(hourly-$mstr) updating",
iref => \$i,
kref => \$k,
th => $th,
processingDay => $processingDay
};
Log3 ($name, 3, "DbRep $name - reduceLog (hourly-$mstr) updating progress of day: $processingDay is: $prog");
$i = 0;
$k++;
}
_DbRep_logProgress ($params);
if ($mode =~ /=day/i) { # timestamp, event, value, device, reading, Date
push(@$updateDayref, ["$updDate $updHour:$minutes", $event, $value, $hourHash->{$hourKey}->[1], $hourHash->{$hourKey}->[3], $updDate]);
@ -9526,6 +9533,7 @@ sub _DbRep_rl_updateDay {
${$deletedCountref} += $c;
${$updateCountref} += keys %updateHash;
my $params;
my ($id,$iu) = (0,0);
my ($kd,$ku) = (1,1);
my $thd = _DbRep_rl_logThreshold ($c);
@ -9554,14 +9562,16 @@ sub _DbRep_rl_updateDay {
$id++;
if($id == $thd) {
my $prog = $kd * $id;
$params = {
name => $name,
logtxt => "(daily-$mstr) deleting",
iref => \$id,
kref => \$kd,
th => $thd,
processingDay => $processingDay
};
Log3 ($name, 3, "DbRep $name - reduceLog (daily-$mstr) deleting progress of day: $processingDay is: $prog");
$id = 0;
$kd++;
}
_DbRep_logProgress ($params);
}
Log3 ($name, 4, "DbRep $name - UPDATE $table SET TIMESTAMP=$updateHash{$uhk}->{date} $time, EVENT=$event, VALUE=$value WHERE (DEVICE=$lastUpdH->[2]) AND (READING=$lastUpdH->[3]) AND (TIMESTAMP=$lastUpdH->[0])");
@ -9570,14 +9580,16 @@ sub _DbRep_rl_updateDay {
$iu++;
if($iu == $thu) {
my $prog = $ku * $id;
$params = {
name => $name,
logtxt => "(daily-$mstr) updating",
iref => \$iu,
kref => \$ku,
th => $thu,
processingDay => $processingDay
};
Log3 ($name, 3, "DbRep $name - reduceLog (daily-$mstr) updating progress of day: $processingDay is: $prog");
$iu = 0;
$ku++;
}
_DbRep_logProgress ($params);
}
}
elsif ($mstr eq 'max') { # Update Max
@ -9592,14 +9604,16 @@ sub _DbRep_rl_updateDay {
$id++;
if($id == $thd) {
my $prog = $kd * $id;
$params = {
name => $name,
logtxt => "(daily-$mstr) deleting",
iref => \$id,
kref => \$kd,
th => $thd,
processingDay => $processingDay
};
Log3 ($name, 3, "DbRep $name - reduceLog (daily-$mstr) deleting progress of day: $processingDay is: $prog");
$id = 0;
$kd++;
}
_DbRep_logProgress ($params);
}
Log3 ($name, 4, "DbRep $name - UPDATE $table SET TIMESTAMP=$updateHash{$uhk}->{date} 23:59:59, EVENT=$event, VALUE=$value WHERE (DEVICE=$lastUpdH->[2]) AND (READING=$lastUpdH->[3]) AND (TIMESTAMP=$lastUpdH->[0])");
@ -9608,14 +9622,16 @@ sub _DbRep_rl_updateDay {
$iu++;
if($iu == $thu) {
my $prog = $ku * $id;
$params = {
name => $name,
logtxt => "(daily-$mstr) updating",
iref => \$iu,
kref => \$ku,
th => $thu,
processingDay => $processingDay
};
Log3 ($name, 3, "DbRep $name - reduceLog (daily-$mstr) updating progress of day: $processingDay is: $prog");
$iu = 0;
$ku++;
}
_DbRep_logProgress ($params);
}
}
1;
@ -9647,6 +9663,30 @@ sub _DbRep_rl_logThreshold {
return $th;
}
################################################################
# Logausgabe Fortschritt reduceLog
################################################################
sub _DbRep_logProgress {
my $paref = shift;
my $name = $paref->{name};
my $logtxt = $paref->{logtxt};
my $iref = $paref->{iref};
my $kref = $paref->{kref};
my $th = $paref->{th};
my $processingDay = $paref->{processingDay};
if(${$iref} == $th) {
my $prog = ${$kref} * ${$iref};
Log3 ($name, 3, "DbRep $name - reduceLog $logtxt progress of day: $processingDay is: $prog");
${$iref} = 0;
${$kref}++;
}
return;
}
####################################################################################################
# reduceLog non-blocking Rückkehrfunktion
####################################################################################################