root/trunk/install/perl/recwrap.pl

#!/usr/bin/perl
#usage recwrap.pl ch length(sec) [bitrate(5)] [TID] [NO] [PID] [stationid] [digitalflag] [digitalband] [digitalch] 
#
# Anime recording system foltia
# http://www.dcc-jpl.com/soft/foltia/
#
#
#レコーディングラッパ
#atから呼び出され、tvrecordingを呼び出し録画
#そのあとMPEG4トラコンを呼び出す
#
# DCC-JPL Japan/foltia project
#

use DBI;
use DBD::Pg;
use DBD::SQLite;
use Schedule::At;
use Time::Local;
use Jcode;

$path = $0;
$path =~ s/recwrap.pl$//i;
if ($path ne "./"){
push( @INC, "$path");
}

require "foltialib.pl";
#引き数がアルか?
$recch = $ARGV[0] ;
if ($recch eq "" ){
        #引き数なしで実行されたら、終了
        print "usage recwrap.pl  ch length(sec) [bitrate(5)] [TID] [NO] [PID]\n";
        exit;
}

$recch = $ARGV[0] ;
$reclength = $ARGV[1] ;
$bitrate  = $ARGV[2] ;
$tid  = $ARGV[3] ;
$countno  = $ARGV[4] ;
$pid = $ARGV[5] ;
$stationid = $ARGV[6] ;
$usedigital = $ARGV[7] ;
$digitalstationband = $ARGV[8] ;
$digitalch= $ARGV[9] ;

#DB初期化
$dbh = DBI->connect($DSN,$DBUser,$DBPass) ||die $DBI::error;;


if ($usedigital == 1){
        $extension = ".m2t";#TSの拡張子
}else{
        $extension = ".m2p";#MPEG2の拡張子
}
if ($recch == -2 ){ #ラジオ局
        $extension = ".aac";#MPEG2の拡張子
}

$outputfile = strftime("%Y%m%d-%H%M", localtime(time + 60));
chomp($outputfile);

if ($tid == 0){
        if ($usedigital == 1){
                $outputfilename = "0--".$outputfile."-".$digitalch.$extension;
                $mp4newstylefilename = "-0--".$outputfile."-".$digitalch;
        }else{
                $outputfilename = "0--".$outputfile."-".$recch.$extension;
                $mp4newstylefilename = "-0--".$outputfile."-".$recch;
        }
}else{
        if ($countno == 0){
                $outputfilename = $tid ."--".$outputfile.$extension;
                $mp4newstylefilename = "-" . $tid ."--".$outputfile;
        }else{
                $outputfilename = $tid ."-".$countno."-".$outputfile.$extension;
                $mp4newstylefilename = "-" . $tid ."-".$countno."-".$outputfile;
        }
}

if ($recch == -2 ){ #ラジオ局
# stationIDからradiko識別子を取得
$sth = $dbh->prepare($stmt{'recwrap.8'});
$sth->execute($stationid);
 @stationline= $sth->fetchrow_array;
$radikostationname = $stationline[3];
my $starttime = time();
my $endepochtime = time() + $reclength;
#録音
$oserr = system("$toolpath/perl/digitalradiorecording.pl $radikostationname $reclength $outputfilename");
$oserr = $oserr / 256;
&writelog("recwrap DEBUG radiko rec finished. $oserr");
#サーバビジーで即死してないか検出
$now = time();
if ($now < $endepochtime){ #終了予定より前に録音プロセスが戻ってきたなら
&writelog("recwrap radiko rec failed,will be retry. NOW:$now PlanedEnd:$endepochtime");

my $retrycounter = 0;
my $waitsecsbase = 10; 
my $waitsec ;
my $waitsecsrand ;
my $recfilepath;
        while($now < $endepochtime){
                if($retrycounter >= 15){
                        &writelog("recwrap radiko rec failed,Giving up.Max retry counter over.");
                        last;
                }
        $waitsecsrand = int(rand($waitsecsbase/2));
        $waitsec = $waitsecsbase + $waitsecsrand ;
        &writelog("recwrap DEBUG radiko rec retry waiting. $waitsec ($waitsecsbase + $waitsecsrand)");
        sleep($waitsec);
        &writelog("recwrap DEBUG retry start.");
        $recfilepath = "$recfolderpath"."/"."$outputfilename";
        if (-e $recfilepath ){
                unlink("$recfilepath");
                &writelog("recwrap DEBUG delete $recfilepath");
        }
        #録音
        $oserr = system("$toolpath/perl/digitalradiorecording.pl $radikostationname $reclength $outputfilename N");#起動waitなしで
        $oserr = $oserr / 256;
        &writelog("recwrap DEBUG radiko rec retry finished. $oserr");

        $retrycounter++;
        if ($waitsecsbase < 600 ){ 
                $waitsecsbase = $waitsecsbase * 2;
        }
        $now = time();
        }# while
} # if 


# aacファイル名をfoltia_subtitlePIDレコードに書き込み
$sth = $dbh->prepare($stmt{'recwrap.1'});
$sth->execute($outputfilename, $pid);
&writelog("recwrap DEBUG UPDATEDB $stmt{'recwrap.1'}");
&changefilestatus($pid,$FILESTATUSTRANSCODEMP4BOX);

# aacファイル名をfoltia_m2pfilesPIDレコードに書き込み
$sth = $dbh->prepare($stmt{'recwrap.2'});
$sth->execute($outputfilename);
&writelog("recwrap DEBUG UPDATEDB $stmt{'recwrap.2'}");


}else{#非ラジオ局なら

if ($usedigital == 1){
#デジタルなら
&writelog("recwrap RECSTART DIGITAL $digitalstationband $digitalch $reclength $stationid 0 $outputfilename $tid $countno friio");
#録画
    $starttime = time();
$oserr = system("$toolpath/perl/digitaltvrecording.pl $digitalstationband $digitalch $reclength $stationid 0 $outputfilename $tid $countno friio");
$oserr = $oserr / 256;

if ($oserr == 1){
        &writelog("recwrap ABORT recfile exist. [$outputfilename] $digitalstationband $digitalch $reclength $stationid 0  $outputfilename $tid $countno");
        exit;
}elsif ($oserr == 2){
        &writelog("recwrap ERR 2:Device busy;retry.");
        &continuousrecordingcheck;#もうすぐ終わる番組をkill
        sleep(2);
        $oserr = system("$toolpath/perl/digitaltvrecording.pl $digitalstationband $digitalch $reclength $stationid N $outputfilename $tid $countno friio");
        $oserr = $oserr / 256;
        if ($oserr == 2){
        &writelog("recwrap ERR 2:Device busy;Giving up digital recording.");
                if ($recunits > 0 ){
                }else{
                        exit;
                }
        }
}elsif ($oserr == 3){
&writelog("recwrap ABORT:ERR 3");
exit ;
}
}else{ # NOT $usedigital == 1
        if ($recunits > 0 ){
        #リモコン操作
        # $haveirdaunit = 1;リモコンつないでるかどうか確認
        if ($haveirdaunit == 1){
        # 録画チャンネルが0なら
                if ($recch == 0){
        # &つけて非同期でchangestbch.pl呼び出し
                &writelog("recwrap Call Change STB CH :$pid");
                system ("$toolpath/perl/changestbch.pl $pid &");
                }#end if
        }#end if
        
        if($recch == -10){
        #非受信局なら
                &writelog("recwrap Not recordable channel;exit:PID $pid");
                exit;
                }#end if
        # アナログ録画
        &writelog("recwrap RECSTART $recch $reclength 0 $outputfilename $bitrate $tid $countno $pid $usedigital $digitalstationband $digitalch");
        
        #録画
        #system("$toolpath/perl/tvrecording.pl $recch $reclength 0 $outputfile $bitrate $tid $countno");
                $starttime = time();
        
        $oserr = system("$toolpath/perl/tvrecording.pl $recch $reclength 0 $outputfilename $bitrate $tid $countno");
        $oserr = $oserr / 256;
        if ($oserr == 1){
                &writelog("recwrap ABORT recfile exist. [$outputfilename] $recch $reclength 0 0 $bitrate $tid $countno $pid");
                exit;
        }
#デバイスビジーで即死してないか検出
$now = time();
        if ($now < $starttime + 100){ #録画プロセス起動してから100秒以内に戻ってきてたら
    $retrycounter = 0;
                while($now < $starttime + 100){
                        if($retrycounter >= 5){
                                &writelog("recwrap WARNING  Giving up recording.");
                                last;
                        }
                &writelog("recwrap retry recording $now $starttime");
                #アナログ録画
        $starttime = time();
if($outputfilename =~ /.m2t$/){
        $outputfilename =~ s/.m2t$/.m2p/;
}
$oserr = system("$toolpath/perl/tvrecording.pl $recch $reclength N $outputfilename $bitrate $tid $countno");
        $now = time();
$oserr = $oserr / 256;
                        if ($oserr == 1){
                                &writelog("recwrap ABORT recfile exist. in resume process.[$outputfilename] $recch $reclength 0 0 $bitrate $tid $countno $pid");
                                exit;
                        }# if
                $retrycounter++;
                }# while
        } # if 

        &writelog("recwrap RECEND [$outputfilename] $recch $reclength 0 0 $bitrate $tid $countno $pid");

        }#end if $recunits > 0
}#endif #デジタル優先フラグ


# m2pファイル名をPIDレコードに書き込み
$sth = $dbh->prepare($stmt{'recwrap.1'});
$sth->execute($outputfilename, $pid);
&writelog("recwrap DEBUG UPDATEDB $stmt{'recwrap.1'}");
&changefilestatus($pid,$FILESTATUSRECEND);

# m2pファイル名をPIDレコードに書き込み
$sth = $dbh->prepare($stmt{'recwrap.2'});
$sth->execute($outputfilename);
&writelog("recwrap DEBUG UPDATEDB $stmt{'recwrap.2'}");

# Starlight breaker向けキャプチャ画像作成
if (-e "$toolpath/perl/captureimagemaker.pl"){
        &writelog("recwrap Call captureimagemaker $outputfilename");
&changefilestatus($pid,$FILESTATUSCAPTURE);
        system ("$toolpath/perl/captureimagemaker.pl $outputfilename");
&changefilestatus($pid,$FILESTATUSCAPEND);
}
}#非ラジオ局

# MPEG4 ------------------------------------------------------
#MPEG4トラコン必要かどうか
$sth = $dbh->prepare($stmt{'recwrap.3'});
$sth->execute($tid);
 @psptrcn= $sth->fetchrow_array;
if ($psptrcn[0]  == 1 ){#トラコン番組
        &writelog("recwrap Launch ipodtranscode.pl");
        exec ("$toolpath/perl/ipodtranscode.pl");
        exit;
}#PSPトラコンあり

sub continuousrecordingcheck(){
    my $now = time() + 60 * 2;
&writelog("recwrap DEBUG continuousrecordingcheck() now $now");
my @processes =`ps ax | grep -e recpt1 -e recfriio`; #foltiaBBS もうすぐ終了する番組のプロセスをkill 投稿日 2010年08月05日03時19分33秒 投稿者 Nis 

my $psline = "";
my @processline = "";
my $pid = "";
my @pid;
my $sth;
foreach (@processes){
        if (/recpt1|friiodetect/) {
                if (/^.[0-9]*\s/){
                        push(@pid, $&);
                }#if
        }#if
}#foreach

if (@pid > 0){
my @filenameparts;
my $tid = "";
my $startdate = "";
my $starttime = "";
my $startdatetime = "";
my @recfile;
my $endtime = "";
my $endtimeepoch = "";
foreach $pid (@pid){
#print "DEBUG  PID $pid\n";
&writelog("recwrap DEBUG continuousrecordingcheck() PID $pid");

        my @lsofoutput = `/usr/sbin/lsof -p $pid`;
        my $filename = "";
        #print "recfolferpath $recfolderpath\n";
        foreach (@lsofoutput){
                if (/m2t/){
                @processline = split(/\s+/,$_);
                $filename = $processline[8];
                $filename =~ s/$recfolderpath\///;
                &writelog("recwrap DEBUG continuousrecordingcheck()  FILENAME $filename");
                # 1520-9-20081201-0230.m2t
                @filenameparts = split(/-/,$filename);
                $tid = $filenameparts[0];
                $startdate = $filenameparts[2];
                $starttime = $filenameparts[3];
                @filenameparts = split(/\./,$starttime);
                $startdatetime = $startdate.$filenameparts[0];
                #DBから録画中番組のデータ探す
                    &writelog("recwrap DEBUG continuousrecordingcheck() $stmt{'recwrap.7'}");
                    $sth = $dbh->prepare($stmt{'recwrap.7'});
        &writelog("recwrap DEBUG continuousrecordingcheck() prepare");
                    $sth->execute($tid, $startdatetime);
        &writelog("recwrap DEBUG continuousrecordingcheck() execute");
        @recfile = $sth->fetchrow_array;
        &writelog("recwrap DEBUG continuousrecordingcheck() @recfile  $recfile[0] $recfile[1] $recfile[2] $recfile[3] $recfile[4] $recfile[5] $recfile[6] $recfile[7] $recfile[8] $recfile[9] ");
        #終了時刻
        $endtime = $recfile[4];
        $endtimeepoch = &foldate2epoch($endtime);
        &writelog("recwrap DEBUG continuousrecordingcheck() $recfile[0] $recfile[1] $recfile[2] $recfile[3] $recfile[4] $recfile[5] endtimeepoch $endtimeepoch");
        if ($endtimeepoch < $now){#まもなく終わる番組なら
                #kill
                system("kill $pid");
                &writelog("recwrap recording process killed $pid/$endtimeepoch/$now");
        }else{
                &writelog("recwrap No processes killed: $endtimeepoch/$now");
        }
                }#endif m2t
        }#foreach lsofoutput
}#foreach
}else{
#print "DEBUG fecfriio NO PID\n";
&writelog("recwrap No recording process killed.");
}
}#endsub