kalipso/racalmas
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactoring

Browse Source 
optimize imports
reformat source code
remove unused cpu and memory log functionality
This commit is contained in:
Milan
2018-08-29 00:10:15 +02:00
parent c37c71f29e
commit 05b1251c1a
81 changed files with 9242 additions and 9962 deletions
Download Patch File Download Diff File Expand all files Collapse all files

495
lib/calcms/playout.pm
View File

@@ -1,95 +1,95 @@
#!/bin/perl
package playout;
package playout;
use warnings "all";
use strict;
use Data::Dumper;
use Date::Calc;
use db;
use time;
use series_events;
use Date::Calc();
use db();
use time();
use series_events();
require Exporter;
our @ISA = qw(Exporter);
our @EXPORT_OK = qw(get_columns get sync);
our %EXPORT_TAGS = ( 'all' => [ @EXPORT_OK ] );
our @ISA = qw(Exporter);
our @EXPORT_OK = qw(get_columns get sync);
our %EXPORT_TAGS = ( 'all' => [@EXPORT_OK] );
sub debug;
sub get_columns{
my $config=shift;
sub get_columns {
my $config = shift;
my $dbh=db::connect($config);
my $cols=db::get_columns($dbh, 'calcms_playout');
my $columns={};
for my $col (@$cols){
$columns->{$col}=1;
my $dbh = db::connect($config);
my $cols = db::get_columns( $dbh, 'calcms_playout' );
my $columns = {};
for my $col (@$cols) {
$columns->{$col} = 1;
}
return $columns;
}
# get playout entries
sub get{
my $config=shift;
my $condition=shift;
# get playout entries
sub get {
my $config = shift;
my $condition = shift;
return undef unless defined $condition->{studio_id};
return undef unless defined $condition->{studio_id};
my $date_range_include=0;
$date_range_include=1 if (defined $condition->{date_range_include}) && ($condition->{date_range_include}==1);
my $date_range_include = 0;
$date_range_include = 1 if ( defined $condition->{date_range_include} ) && ( $condition->{date_range_include} == 1 );
my $dbh=db::connect($config);
my $dbh = db::connect($config);
my @conditions=();
my @bind_values=();
my @conditions = ();
my @bind_values = ();
if ((defined $condition->{project_id}) && ($condition->{project_id} ne '')){
push @conditions, 'project_id=?';
if ( ( defined $condition->{project_id} ) && ( $condition->{project_id} ne '' ) ) {
push @conditions, 'project_id=?';
push @bind_values, $condition->{project_id};
}
if ((defined $condition->{studio_id}) && ($condition->{studio_id} ne '')){
push @conditions, 'studio_id=?';
if ( ( defined $condition->{studio_id} ) && ( $condition->{studio_id} ne '' ) ) {
push @conditions, 'studio_id=?';
push @bind_values, $condition->{studio_id};
}
if ((defined $condition->{start_at}) && ($condition->{start_at} ne '')){
push @conditions, 'start=?';
if ( ( defined $condition->{start_at} ) && ( $condition->{start_at} ne '' ) ) {
push @conditions, 'start=?';
push @bind_values, $condition->{start_at};
}
if ((defined $condition->{from}) && ($condition->{from} ne '')){
if ($date_range_include==1){
push @conditions, 'end_date>=?';
push @bind_values, $condition->{from};
}else{
push @conditions, 'start_date>=?';
push @bind_values, $condition->{from};
}
if ( ( defined $condition->{from} ) && ( $condition->{from} ne '' ) ) {
if ( $date_range_include == 1 ) {
push @conditions, 'end_date>=?';
push @bind_values, $condition->{from};
} else {
push @conditions, 'start_date>=?';
push @bind_values, $condition->{from};
}
}
if ((defined $condition->{till}) && ($condition->{till} ne '')){
if ($date_range_include==1){
push @conditions, 'start_date<=?';
push @bind_values, $condition->{till};
}else{
push @conditions, 'end_date<=?';
push @bind_values, $condition->{till};
}
if ( ( defined $condition->{till} ) && ( $condition->{till} ne '' ) ) {
if ( $date_range_include == 1 ) {
push @conditions, 'start_date<=?';
push @bind_values, $condition->{till};
} else {
push @conditions, 'end_date<=?';
push @bind_values, $condition->{till};
}
}
my $limit='';
if ((defined $condition->{limit}) && ($condition->{limit} ne '')){
$limit= 'limit '.$condition->{limit};
}
my $limit = '';
if ( ( defined $condition->{limit} ) && ( $condition->{limit} ne '' ) ) {
$limit = 'limit ' . $condition->{limit};
}
my $conditions='';
$conditions=" where ".join(" and ",@conditions) if (@conditions>0);
my $order='start';
$order=$condition->{order} if (defined $condition->{order} ) && ($condition->{order} ne'');
my $conditions = '';
$conditions = " where " . join( " and ", @conditions ) if ( @conditions > 0 );
my $query=qq{
my $order = 'start';
$order = $condition->{order} if ( defined $condition->{order} ) && ( $condition->{order} ne '' );
my $query = qq{
select date(start) start_date
,date(end) end_date
,dayname(start) weekday
@@ -122,43 +122,42 @@ sub get{
$limit
};
#print STDERR Dumper($query).Dumper(\@bind_values);
my $entries=db::get($dbh, $query, \@bind_values);
#print STDERR Dumper($query).Dumper(\@bind_values);
my $entries = db::get( $dbh, $query, \@bind_values );
return $entries;
}
# update playout entries for a given date span
# insert, update and delete entries
sub sync{
my $config=shift;
my $options=shift;
sub sync {
my $config = shift;
my $options = shift;
#print STDERR Dumper($config);
print STDERR "upload ".Dumper($options);
return undef unless defined $options->{project_id} ;
return undef unless defined $options->{studio_id} ;
return undef unless defined $options->{from} ;
return undef unless defined $options->{till} ;
return undef unless defined $options->{events} ;
#print STDERR Dumper($config);
print STDERR "upload " . Dumper($options);
return undef unless defined $options->{project_id};
return undef unless defined $options->{studio_id};
return undef unless defined $options->{from};
return undef unless defined $options->{till};
return undef unless defined $options->{events};
my $project_id = $options->{project_id};
my $studio_id = $options->{studio_id};
my $updates = $options->{events};
#print STDERR "sync\n";
#print STDERR Dumper($updates);
# get new entries by date
my $update_by_date={};
for my $entry (@$updates){
$update_by_date->{$entry->{start}}=$entry;
my $project_id = $options->{project_id};
my $studio_id = $options->{studio_id};
my $updates = $options->{events};
#print STDERR "sync\n";
#print STDERR Dumper($updates);
# get new entries by date
my $update_by_date = {};
for my $entry (@$updates) {
$update_by_date->{ $entry->{start} } = $entry;
}
# get database entries
my $bind_values=[
$options->{project_id}, $options->{studio_id}, $options->{from}, $options->{till}
];
my $query=qq{
# get database entries
my $bind_values = [ $options->{project_id}, $options->{studio_id}, $options->{from}, $options->{till} ];
my $query = qq{
select *
from calcms_playout
where project_id=?
@@ -168,110 +167,131 @@ sub sync{
order by start
};
print STDERR "from:$options->{from} till:$options->{till}\n";
my $dbh=db::connect($config);
my $entries=db::get($dbh, $query, $bind_values);
#print STDERR "entries:".Dumper($entries);
my $dbh = db::connect($config);
my $entries = db::get( $dbh, $query, $bind_values );
# get database entries by date
my $entries_by_date={};
for my $entry (@$entries){
# store entry by date
my $start=$entry->{start};
$entries_by_date->{$start}=$entry;
#print STDERR "entries:".Dumper($entries);
# remove outdated entries
unless (defined $update_by_date->{$start}){
print STDERR "delete:".Dumper($entry);
playout::delete($config, $dbh, $entry);
my $result=series_events::set_playout_status($config, {
project_id => $project_id,
studio_id => $studio_id,
start => $entry->{start},
playout => 0,
});
print STDERR "delete playout_status result=".$result."\n";
next;
}
# update existing entries
if (defined $update_by_date->{$start}){
next if has_changed($entry, $update_by_date->{$start})==0;
print STDERR "update:".Dumper($entry);
playout::update($config, $dbh, $entry, $update_by_date->{$start});
my $result=series_events::set_playout_status($config, {
project_id => $project_id,
studio_id => $studio_id,
start => $entry->{start},
playout => 1,
});
print STDERR "update playout_status result=".$result."\n";
next;
}
}
# get database entries by date
my $entries_by_date = {};
for my $entry (@$entries) {
# insert new entries
for my $entry (@$updates){
my $start=$entry->{start};
unless (defined $entries_by_date->{$start}){
$entry->{project_id} = $project_id;
$entry->{studio_id} = $studio_id;
print STDERR "insert:".Dumper($entry);
playout::insert($config, $dbh, $entry);
my $result=series_events::set_playout_status($config, {
project_id => $project_id,
studio_id => $studio_id,
start => $entry->{start},
playout => 1,
});
print STDERR "insert playout_status result=".$result."\n";
}
# store entry by date
my $start = $entry->{start};
$entries_by_date->{$start} = $entry;
# remove outdated entries
unless ( defined $update_by_date->{$start} ) {
print STDERR "delete:" . Dumper($entry);
playout::delete( $config, $dbh, $entry );
my $result = series_events::set_playout_status(
$config,
{
project_id => $project_id,
studio_id => $studio_id,
start => $entry->{start},
playout => 0,
}
);
print STDERR "delete playout_status result=" . $result . "\n";
next;
}
# update existing entries
if ( defined $update_by_date->{$start} ) {
next if has_changed( $entry, $update_by_date->{$start} ) == 0;
print STDERR "update:" . Dumper($entry);
playout::update( $config, $dbh, $entry, $update_by_date->{$start} );
my $result = series_events::set_playout_status(
$config,
{
project_id => $project_id,
studio_id => $studio_id,
start => $entry->{start},
playout => 1,
}
);
print STDERR "update playout_status result=" . $result . "\n";
next;
}
}
# insert new entries
for my $entry (@$updates) {
my $start = $entry->{start};
unless ( defined $entries_by_date->{$start} ) {
$entry->{project_id} = $project_id;
$entry->{studio_id} = $studio_id;
print STDERR "insert:" . Dumper($entry);
playout::insert( $config, $dbh, $entry );
my $result = series_events::set_playout_status(
$config,
{
project_id => $project_id,
studio_id => $studio_id,
start => $entry->{start},
playout => 1,
}
);
print STDERR "insert playout_status result=" . $result . "\n";
}
}
return 1;
}
sub has_changed{
my $oldEntry=shift;
my $newEntry=shift;
sub has_changed {
my $oldEntry = shift;
my $newEntry = shift;
my $update=0;
for my $key ('duration', 'errors', 'file', 'channels', 'format', 'format_version', 'format_profile', 'format_settings', 'stream_size', 'bitrate', 'bitrate_mode', 'sampling_rate', 'writing_library', 'modified_at'){
return 1 if ($oldEntry->{$key}||'') ne ($newEntry->{$key}||'');
}
return 0;
my $update = 0;
for my $key (
'duration', 'errors', 'file', 'channels', 'format', 'format_version',
'format_profile', 'format_settings', 'stream_size', 'bitrate', 'bitrate_mode', 'sampling_rate',
'writing_library', 'modified_at'
)
{
return 1 if ( $oldEntry->{$key} || '' ) ne ( $newEntry->{$key} || '' );
}
return 0;
}
# update playout entry if differs to old values
sub update{
my $config=shift;
my $dbh=shift;
my $oldEntry=shift;
my $newEntry=shift;
return if has_changed($oldEntry, $newEntry)==0;
for my $key ('duration', 'errors', 'file', 'channels', 'format', 'format_version', 'format_profile', 'format_settings', 'stream_size', 'bitrate', 'bitrate_mode', 'sampling_rate', 'writing_library', 'rms_left', 'rms_right', 'rms_image', 'replay_gain', 'modified_at'){
if (($oldEntry->{$key}||'') ne ($newEntry->{$key}||'')){
$oldEntry->{$key}=$newEntry->{$key};
}
}
sub update {
my $config = shift;
my $dbh = shift;
my $oldEntry = shift;
my $newEntry = shift;
my $entry=$oldEntry;
print STDERR "update:".Dumper($entry);
return if has_changed( $oldEntry, $newEntry ) == 0;
my $day_start=$config->{date}->{day_starting_hour};
$entry->{end} = playout::getEnd($entry->{start}, $entry->{duration});
$entry->{start_date} = time::add_hours_to_datetime($entry->{start}, -$day_start);
$entry->{end_date} = time::add_hours_to_datetime($entry->{end}, -$day_start);
for my $key (
'duration', 'errors', 'file', 'channels', 'format', 'format_version',
'format_profile', 'format_settings', 'stream_size', 'bitrate', 'bitrate_mode', 'sampling_rate',
'writing_library', 'rms_left', 'rms_right', 'rms_image', 'replay_gain', 'modified_at'
)
{
if ( ( $oldEntry->{$key} || '' ) ne ( $newEntry->{$key} || '' ) ) {
$oldEntry->{$key} = $newEntry->{$key};
}
}
my $bind_values=[
$entry->{end}, $entry->{duration}, $entry->{file}, $entry->{errors},
$entry->{start_date}, $entry->{end_date},
$entry->{channels}, $entry->{'format'}, $entry->{format_version}, $entry->{format_profile}, $entry->{format_settings}, $entry->{stream_size},
$entry->{bitrate}, $entry->{bitrate_mode}, $entry->{sampling_rate}, $entry->{writing_library},
$entry->{rms_left}, $entry->{rms_right}, $entry->{rms_image},
$entry->{replay_gain}, $entry->{modified_at},
$entry->{project_id}, $entry->{studio_id}, $entry->{start}
];
my $query=qq{
my $entry = $oldEntry;
print STDERR "update:" . Dumper($entry);
my $day_start = $config->{date}->{day_starting_hour};
$entry->{end} = playout::getEnd( $entry->{start}, $entry->{duration} );
$entry->{start_date} = time::add_hours_to_datetime( $entry->{start}, -$day_start );
$entry->{end_date} = time::add_hours_to_datetime( $entry->{end}, -$day_start );
my $bind_values = [
$entry->{end}, $entry->{duration}, $entry->{file}, $entry->{errors},
$entry->{start_date}, $entry->{end_date}, $entry->{channels}, $entry->{'format'},
$entry->{format_version}, $entry->{format_profile}, $entry->{format_settings}, $entry->{stream_size},
$entry->{bitrate}, $entry->{bitrate_mode}, $entry->{sampling_rate}, $entry->{writing_library},
$entry->{rms_left}, $entry->{rms_right}, $entry->{rms_image}, $entry->{replay_gain},
$entry->{modified_at}, $entry->{project_id}, $entry->{studio_id}, $entry->{start}
];
my $query = qq{
update calcms_playout
set end=?, duration=?, file=?, errors=?,
start_date=?, end_date=?,
@@ -281,14 +301,14 @@ sub update{
replay_gain=?, modified_at=?
where project_id=? and studio_id=? and start=?
};
return db::put($dbh, $query, $bind_values);
return db::put( $dbh, $query, $bind_values );
}
# insert playout entry
sub insert{
my $config=shift;
my $dbh=shift;
my $entry=shift;
sub insert {
my $config = shift;
my $dbh = shift;
my $entry = shift;
return undef unless defined $entry->{project_id};
return undef unless defined $entry->{studio_id};
@@ -296,77 +316,84 @@ sub insert{
return undef unless defined $entry->{duration};
return undef unless defined $entry->{file};
my $day_start=$config->{date}->{day_starting_hour};
$entry->{end} = playout::getEnd($entry->{start}, $entry->{duration});
$entry->{start_date} = time::add_hours_to_datetime($entry->{start}, -$day_start);
$entry->{end_date} = time::add_hours_to_datetime($entry->{end}, -$day_start);
return db::insert($dbh, 'calcms_playout', {
project_id => $entry->{project_id},
studio_id => $entry->{studio_id},
start => $entry->{start},
end => $entry->{end},
start_date => $entry->{start_date},
end_date => $entry->{end_date},
duration => $entry->{duration},
rms_left => $entry->{rms_left},
rms_right => $entry->{rms_right},
rms_image => $entry->{rms_image},
replay_gain => $entry->{replay_gain},
file => $entry->{file},
errors => $entry->{errors},
channels => $entry->{channels},
"format" => $entry->{"format"},
format_version => $entry->{format_version},
format_profile => $entry->{format_profile},
format_settings => $entry->{format_settings},
stream_size => $entry->{stream_size},
bitrate => $entry->{bitrate},
bitrate_mode => $entry->{bitrate_mode},
sampling_rate => $entry->{sampling_rate},
writing_library => $entry->{writing_library},
modified_at => $entry->{modified_at}
});
my $day_start = $config->{date}->{day_starting_hour};
$entry->{end} = playout::getEnd( $entry->{start}, $entry->{duration} );
$entry->{start_date} = time::add_hours_to_datetime( $entry->{start}, -$day_start );
$entry->{end_date} = time::add_hours_to_datetime( $entry->{end}, -$day_start );
return db::insert(
$dbh,
'calcms_playout',
{
project_id => $entry->{project_id},
studio_id => $entry->{studio_id},
start => $entry->{start},
end => $entry->{end},
start_date => $entry->{start_date},
end_date => $entry->{end_date},
duration => $entry->{duration},
rms_left => $entry->{rms_left},
rms_right => $entry->{rms_right},
rms_image => $entry->{rms_image},
replay_gain => $entry->{replay_gain},
file => $entry->{file},
errors => $entry->{errors},
channels => $entry->{channels},
"format" => $entry->{"format"},
format_version => $entry->{format_version},
format_profile => $entry->{format_profile},
format_settings => $entry->{format_settings},
stream_size => $entry->{stream_size},
bitrate => $entry->{bitrate},
bitrate_mode => $entry->{bitrate_mode},
sampling_rate => $entry->{sampling_rate},
writing_library => $entry->{writing_library},
modified_at => $entry->{modified_at}
}
);
}
# delete playout entry
sub delete{
my $config=shift;
my $dbh=shift;
my $entry=shift;
sub delete {
my $config = shift;
my $dbh = shift;
my $entry = shift;
return undef unless defined $entry->{project_id};
return undef unless defined $entry->{studio_id};
return undef unless defined $entry->{start};
my $query=qq{
my $query = qq{
delete
from calcms_playout
where project_id=? and studio_id=? and start=?
};
my $bind_values=[$entry->{project_id}, $entry->{studio_id}, $entry->{start}];
return db::put($dbh, $query, $bind_values);
my $bind_values = [ $entry->{project_id}, $entry->{studio_id}, $entry->{start} ];
return db::put( $dbh, $query, $bind_values );
}
sub getEnd{
my $start=shift;
my $duration=shift;
# calculate end from start + duration
my @start = @{time::datetime_to_array($start)};
next unless @start>=6;
#print STDERR Dumper(\@start);
sub getEnd {
my $start = shift;
my $duration = shift;
# calculate end from start + duration
my @start = @{ time::datetime_to_array($start) };
next unless @start >= 6;
#print STDERR Dumper(\@start);
my @end_datetime = Date::Calc::Add_Delta_DHMS(
$start[0], $start[1], $start[2], # start date
$start[3], $start[4], $start[5], # start time
0, 0, 0, int($duration) # delta days, hours, minutes, seconds
$start[0], $start[1], $start[2], # start date
$start[3], $start[4], $start[5], # start time
0, 0, 0, int($duration) # delta days, hours, minutes, seconds
);
#print STDERR Dumper(\@end_datetime);
return time::array_to_datetime(\@end_datetime);
#print STDERR Dumper(\@end_datetime);
return time::array_to_datetime( \@end_datetime );
}
sub error{
my $msg=shift;
sub error {
my $msg = shift;
print "ERROR: $msg<br/>\n";
}