/
OpenEPG.pl
697 lines (600 loc) · 33.4 KB
/
OpenEPG.pl
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
#!/usr/bin/perl
use strict;
use warnings;
use Getopt::Std;
use DVB::Epg;
use DVB::Carousel;
use Carp;
use DBD::Firebird;
use Encode;
use utf8;
use POSIX qw(ceil);
use POSIX qw(strftime);
use POSIX qw(floor);
use Time::HiRes qw(usleep time);
use Time::HiRes qw(gettimeofday);
use Config::INI::Reader;
use Cwd;
use threads;
use Socket;
use IO::File;
use Digest::CRC qw(crc);
use FindBin qw($Bin);
use Time::Local;
use Time::gmtime;
use Digest::CRC qw(crc);
# Вынесем констаны
use constant {
TOT_max_interval => 10, # TOT/TDT table interval
TOT_regions_cnt => 9, # Count regions in TOT
CHUNK_TIME => 30, # calculate the chunk for X seconds
MPEG_SIZE => 188, # MPEG ts packet size
TS_IN_UDP_PACKET => 7 # TS packets in a typical UDP packet. 7 recommended, because 7*188 = 1316 < max UDP packet size (1432))
};
$| = 1; # добавляет возможность перенаправлять вывод в файл. пример > openepg.log
my %epg_config = ();
#Ищем OpenEPG.ini файл в каталоге со скриптом
my $ini_file = $Bin.'/OpenEPG.ini';
$epg_config{"DB_USER"} = 'SYSDBA'; # пользователь Firebird
$epg_config{"DB_NAME"} = 'localhost:epg'; # База Firebird A4on.TV
$epg_config{"DB_PSWD"} = 'masterkey'; # пароль пользователя Firebird
$epg_config{"DEBUG"} = 0; # Вывод отладки в консоль
$epg_config{"BIND_IP"} = '0.0.0.0'; # через какой сетевой интерфейс передаем UDP
$epg_config{"TS_NAME"} = ''; # Будем хранить TSID
$epg_config{"DAYS"} = 7; # На сколько дней формировать EIT
$epg_config{"TMP"} = cwd; # Куда сохранять времменые файлы
$epg_config{"USEMEMORY"} = 0; # создавать файлы базы в памяти
$epg_config{"EXPORT_TS"} = '0'; # Экспортировать TS в файл
$epg_config{"DVBN_ID"} = ''; # ИД сети в которую передаем
$epg_config{"NETWORK_ID"} = ''; # NID сети с которой работает генератор
$epg_config{"ONID"} = ''; # ONID сети с которой работает генератор
$epg_config{"READ_EPG"} = 5; # Через сколько минут будем проверять данные в базе A4on.TV и если изменились перечитывать
$epg_config{"DESC_LEN"} = 500; # Количество символов в описании
$epg_config{"RUS_PAGE"} = 1; # Как кодировать язык. согласно EN 300 468, ISO/IEC 8859-5 [27] Latin/Cyrillic alphabe может быть 1 = \0x01 (Table A.3) , а может быть 2 = \0x10\0x00\0x5 (Table A.4)
$epg_config{"TEXT_IN_UTF"} = 0; # Передавать текст событий в UTF8 а не в ISO
$epg_config{"LONGREADLEN"} = 0; # Если возникает ошибка LongReadLen, снимите комментарий. 1000 можно уменьшить.
$epg_config{"TOT_TDT"} = 0; # Формировать таблицу TOT и TDT
$epg_config{"REGION_ID"} = 0; # С какого Region_ID генерировать 8-мь регионов для TOT
$epg_config{"PF_ONLY"} = 1; # Для не текущего TS создавать только таблица текущая/следующая программа present/following
$epg_config{"DESC_FORMAT"} = ''; # Формат описания AGE, DESC, GENR, YEAR, ACTR, DRCT, CNTR
$epg_config{"TTL"} = 5; # TTL пакетов (время жизни)
# Проверим, если ini файл с сигнатурой BOM, то удалим ее
my $fh = new IO::File "< $ini_file" or die "Cannot open $ini_file : $!";
binmode($fh);
my $buf;
my $bom = "\xef\xbb\xbf";
my $len = length($bom);
my $buflen = 3;
read($fh, $buf, $len);
if (substr($buf, 0, 3) eq substr($bom, 0, 3)) {
my $fw = new IO::File "> $ini_file.new" or die "Cannot open $ini_file.new : $!";
binmode($fw);
my $buflen = (stat($fh))[7];
while (read($fh, $buf, $buflen)) {
print $fw $buf or die "Write to $ini_file failed: $!";
}
close($fw) or die "Error closing $ini_file.new : $!";
close($fh) or die "Error closing $ini_file : $!";
unlink($ini_file);
rename "$ini_file.new", "$ini_file";
}
else {
close($fh) or die "Error closing $ini_file : $!";
}
# Прочитаем EPG.INI и заменим дефолтные настройки значениями с INI файла, раздел "EPG"
my $ini = Config::INI::Reader->read_file($ini_file);
if (exists $ini->{'EPG'}) {
%epg_config = (%epg_config, %{$ini->{'EPG'}});
}
if ($epg_config{"RUS_PAGE"} == 2) {
$epg_config{"RUS_HEX"} = "\0x10\0x00\0x05";
}
else {
$epg_config{"RUS_HEX"} = "\x01";
}
if ($epg_config{"DESC_LEN"} !~ /^\d+$/) {
print "Wrong description length parameter. Set length = 500 \n";
$epg_config{"DESC_LEN"} = 500;
}
# проверим темповый каталог и создадим его
if ((substr($epg_config{"TMP"}, -1) ne '/') and (substr($epg_config{"TMP"}, -1) ne '\\')) {
$epg_config{"TMP"} = $epg_config{"TMP"}."/"; # добавим закрывающий слэш
}
mkdir $epg_config{"TMP"};
my $fbDb;
# прочитаем настройки сети DVB из базы A4on.TV
do {
$fbDb = DBI->connect("dbi:Firebird:db=".$epg_config{"DB_NAME"}.";ib_charset=UTF8",
$epg_config{"DB_USER"},
$epg_config{"DB_PSWD"},
{ RaiseError => 0, PrintError => 0, AutoCommit => 1, ib_enable_utf8 => 1 } );
if (!$fbDb) {
printf("%s Error connect to Firebird db %s, will try again in %.0f minutes\n", (scalar localtime(time())), $epg_config{"DB_NAME"}, $epg_config{'READ_EPG'});
usleep( $epg_config{'READ_EPG'} * 60 * 1000000 ); # подождем и попробуем переподключиться через READ_EPG минут
}
} until($fbDb);
if ($epg_config{"LONGREADLEN"} > 0) { $fbDb->{LongReadLen}=$epg_config{"LONGREADLEN"}; }
$fbDb->func(
-access_mode => 'read_only',
-lock_resolution => 'no_wait',
'ib_set_tx_param'
);
my $sel_q = "select s.Dvbs_Id, coalesce(s.Aostrm, 0), lower(n.Country), s.Es_Ip UDPhost, s.Es_Port UDPport, coalesce(n.Descriptors,'') desc,
coalesce((select list(distinct c.Tsid) from Dvb_Stream_Channels c where c.Dvbs_Id = s.Dvbs_Id),
coalesce(s.Tsid,'no TSID')) tsname, coalesce(n.Pids, '') pids, coalesce(n.timeoffset, 180) tz, coalesce(n.COUNTRY, 'RUS') country_code
from Dvb_Network n inner join Dvb_Streams s on (s.Dvbn_Id = n.Dvbn_Id)
where (not n.ONID is null) and (not n.NID is null) and (coalesce(s.Es_Ip,'') <> '') ";
if ($epg_config{"NETWORK_ID"} ne '') {
$sel_q = $sel_q." and n.NID = ".$epg_config{"NETWORK_ID"};
}
if ($epg_config{"ONID"} ne '') {
$sel_q = $sel_q." and n.ONID = ".$epg_config{"ONID"};
}
if ($epg_config{"DVBN_ID"} ne '') {
$sel_q = $sel_q." and n.DVBN_Id = ".$epg_config{"DVBN_ID"};
}
#$sel_q = $sel_q." and s.Tsid = 1001 "; # for debug ########################################################### DEBUG only
my $sth_s = $fbDb->prepare($sel_q);
$sth_s->execute or die "ERROR: Failed execute SQL Dvb_Network !";
# создадим thread для каждого транспортного потока и запустим его
my @threads;
while (my ($dvbs_id, $aostrm, $country, $UDPhost, $UDPport, $desc, $tsname, $tot, $tz, $country_code) = $sth_s->fetchrow_array()) {
$epg_config{"ACTUAL_OTHER"} = $aostrm; # Передавать ли текущий/следующий поток в одном UDP потоке
$epg_config{"COUNTRY"} = $country; # язык по-умолчанию
$epg_config{"DVBS_ID"} = $dvbs_id;
$epg_config{"UDPhost"} = $UDPhost;
$epg_config{"UDPport"} = $UDPport;
$epg_config{"TS_NAME"} = $tsname;
$epg_config{"TOT_TDT"} = 0; # Формировать таблицу TOT и TDT
$epg_config{"SHOW_EXT"} = 0; # Передавать расш. описание
$epg_config{"SHOW_AGE"} = 0; # Передавать возраст
$epg_config{"SHOW_GNR"} = 0; # Передавать жанр
if (index($desc, 'ExtendedEventDescriptor') >= 0) { $epg_config{"SHOW_EXT"} = "1"; }
if (index($desc, 'ParentalRatingDescriptor') >= 0) { $epg_config{"SHOW_AGE"} = "1"; }
if (index($desc, 'ContentDescriptor') >= 0) { $epg_config{"SHOW_GNR"} = "1"; }
if (index($tot, 'TDT')>=0) { $epg_config{"TOT_TDT"} = "1"; }
if (index($tot, 'TOT')>=0) { $epg_config{"TOT_TDT"} = "1"; }
if ($epg_config{"TOT_TDT"} eq "1") { # сформируем таблицу TOT для дальнейшего использования, она для всех одинакова
my $sgn = 1;
if ($tz < 0) {$sgn = -1;}
$tz = $sgn * $tz;
my $toh = floor( $tz / 60 ); # Часы
my $thh = floor( $toh / 10 ); # десятки часов (12 - 1)
my $thl = $toh % 10 ; # единицы часов (12 - 2)
my $tom = $tz % 60; # минуты
my $tmh = floor( $tom / 10 ); # десятки минут (45 - 4)
my $tml = $tom % 10 ; # единицы минут (45 - 5)
my $offset = chr(($thh << 4) + $thl).chr(($tmh << 4) + $tml); # сдвиг времени
my $TOT = "";
if ($sgn > 0) {$sgn = 2;} # часов пояс + к UTC
else {$sgn = 3;} # часов пояс - к UTC
for(my $i=$epg_config{"REGION_ID"};$i<($epg_config{"REGION_ID"} + TOT_regions_cnt);$i++) { # Сделаем таблицу из 10 регионов с одинаковым смещением. Зачем эти регионы, непонятно.
$TOT.= $country_code # country_code
. chr(($i << 2) + $sgn) # сдвиг UTC в начале первый байт 6 бит код региона, 1 бит резервный, 1 бит + или - сдвига.
. $offset # сдвиг времени сразу, это текущий сдвиг на данный момент. Сдвиг 3 часа 30 минут Должно передаваться как 0330
. "\xD9\x5E\x00\x00\x00" # время следующего сдвига 1995, те в прошлом
. $offset; # сдвиг который предполагается после даты, сделаем такой же сдвиг
}
$epg_config{"TOT"} = "\xF0".chr(2+(13*TOT_regions_cnt))
. "\x58".chr(TOT_regions_cnt*13) # TOT дескриптора и его длина по 13 байт. и длина всего вместе в начале
. $TOT; # TOT дескриптор
}
push @threads, threads->create(\&RunThread, %epg_config);
#RunThread(%epg_config); #for debug run without threads
}
$fbDb->disconnect();
# Приосединимся к потокам. Не дадим завершиться программе, пока работают все потоки
foreach my $thread (@threads) {
$thread->join();
}
# Основная процедура формирования EPG для транспортного потка. читаем / обновляем и передаем EPG
sub RunThread {
my %cfg = @_;
my $dvbsid = $cfg{"DVBS_ID"};
my $eitDb = $cfg{"TMP"}.'eit'.$dvbsid.'.sqlite';
my $carouselDb = $cfg{"TMP"}.'carousel'.$dvbsid.'.sqlite';
if ($cfg{"USEMEMORY"}) {
$eitDb = 'memory';
$carouselDb = 'memory';
}
$cfg{"tsEpg"} = DVB::Epg->new( $eitDb ) || die( "Error opening EIT database [$eitDb]: $!");
$cfg{"tsCarousel"} = DVB::Carousel->new( $carouselDb ) || die( "Error opening carousel database [$carouselDb]: $!");
my $continuityCounter = 0;
my $lasTOTime = gettimeofday;
my $ContinuityTDT = 0;
my $tail_packets;
for(my $i=0;$i<5;$i++) { $tail_packets .= "\x47\x1f\xff\x10"."\xff" x (MPEG_SIZE-4); } #делаем пачку из 7 нулевых пакетов
socket( my $tsSocket, PF_INET, SOCK_DGRAM, getprotobyname('udp')) or die( "Error opening udp socket: $!");
setsockopt($tsSocket, SOL_SOCKET, SO_REUSEADDR, 1);
if (($cfg{"TTL"}+0) > 1) {
setsockopt($tsSocket, getprotobyname('ip'), 10, ($cfg{"TTL"}+0)); #IP_MULTICAST_TTL
}
if ($cfg{"BIND_IP"} ne '0.0.0.0') {
bind( $tsSocket, pack_sockaddr_in($cfg{"UDPport"}, inet_aton($cfg{"BIND_IP"}))) or die "Can't bind to port!\n";
}
my $ipaddr = inet_aton( $cfg{"UDPhost"});
my $portaddr = sockaddr_in( $cfg{"UDPport"}, $ipaddr);
my $lastCheckEPG = '';
my $threadSendUDP;
my $buildTime = CHUNK_TIME;
my $start = gettimeofday;
my $TimeToReload = 0;
while (1) {
my $StartWhileTime = time(); # Время начала выполнения цикла. нужно для отслеживания времени перезагрузки расписания
# пришло ли время проверять данные в базе A4on.TV
if ($TimeToReload <= 0) {
my $DebugTime = gettimeofday;
my $tsDb;
if ($tsDb=DBI->connect("dbi:Firebird:db=".$cfg{"DB_NAME"}.";ib_charset=UTF8", $cfg{"DB_USER"}, $cfg{"DB_PSWD"}, { RaiseError => 0, PrintError => 0, AutoCommit => 1, ib_enable_utf8 => 1 } )) {
$tsDb->func(
-access_mode => 'read_only',
-lock_resolution => 'no_wait',
'ib_set_tx_param'
);
if ($cfg{"LONGREADLEN"} > 0) {
$tsDb->{LongReadLen}=$epg_config{"LONGREADLEN"};
}
# Время в формате 26.02.2015 23:50:00
my $attr = {
ib_timestampformat => '%d.%m.%Y %H:%M:%S',
ib_dateformat => '%d.%m.%Y',
ib_timeformat => '%H:%M:%S',
};
# Прочитаем последнее изменение в БД
my $sel_DVBs = "select Coalesce(s.EPG_UPDATED, current_timestamp) from Dvb_Streams s where s.Dvbs_Id = $dvbsid";
my $sth_s = $tsDb->prepare($sel_DVBs, $attr);
$sth_s->execute or die "ERROR: Failed execute SQL Dvb_Streams !";
my ($EPGupdateON) = $sth_s->fetchrow_array();
$sth_s->finish();
# проверим совпадает ли с тем что мы уже проверили
if ($lastCheckEPG ne $EPGupdateON) {
InitEitDb($tsDb, %cfg);
ReadEpgData( $tsDb, %cfg );
printf( "TSID %s\tupdated %s\t(%s done in %.3f)\n", $cfg{"TS_NAME"}, $EPGupdateON, (scalar localtime(time())), (gettimeofday - $DebugTime));
$lastCheckEPG = $EPGupdateON;
$buildTime = CHUNK_TIME; # Если обновили EIT, то не будем ждать перед обновлением EPG
}
$tsDb->disconnect();
$TimeToReload = $cfg{'READ_EPG'};
if ($cfg{"DEBUG"}) { printf( "DEBUG\t%s\t%s\tCheck EPG\t%.3f\n", $cfg{"TS_NAME"}, (scalar localtime(time())), (gettimeofday - $DebugTime)); }
}
else {
printf( "TSID %s\t%s\tCan't connect to %s, will try again in %.0f minutes\n", $cfg{"TS_NAME"}, (scalar localtime(time())), $cfg{"DB_NAME"}, $cfg{'READ_EPG'} );
usleep( $cfg{'READ_EPG'} * 60 * 1000000 ); # подождем и попробуем переподключиться через READ_EPG минут
}
}
# сделано, чтоб получить свежее расписание перед запуском потока
$buildTime = ((CHUNK_TIME - $buildTime) / 2);
if ($buildTime > 5) {
if ($cfg{"DEBUG"}) { printf( "DEBUG\t%s\t%s\tsleep for\t%.3f\n", $cfg{"TS_NAME"}, (scalar localtime(time())), $buildTime); }
usleep( $buildTime * 1000000 ); # сократим врмя ожидания до минимума
}
$buildTime = BuildEPG( %cfg );
if ($cfg{"DEBUG"}) { printf( "DEBUG\t%s\t%s\tbuild for\t%.3f\n", $cfg{"TS_NAME"}, (scalar localtime(time())), $buildTime); }
# get all data for the EIT
my $Time18 = gettimeofday;
my $meta = $cfg{"tsCarousel"}->getMts( 18 );
if ($cfg{"DEBUG"}) { printf( "DEBUG\t%s\t%s\t18 read \t%.3f\n", $cfg{"TS_NAME"}, (scalar localtime(time())), (gettimeofday - $Time18)); }
$buildTime = $buildTime + (gettimeofday - $Time18);
if (defined $meta) {
if (defined $threadSendUDP) {
# подождем пока закончится поток с пересылкой по UDP с учетом времени формирования
my $Time18 = gettimeofday;
( $lasTOTime, $ContinuityTDT ) = $threadSendUDP->join();
undef $threadSendUDP;
if ($cfg{"DEBUG"}) { printf( "DEBUG\t%s\t%s\twait thrd\t%.3f\n", $cfg{"TS_NAME"}, (scalar localtime(time())), (gettimeofday - $Time18)); }
}
if ($cfg{"DEBUG"}) { printf( "DEBUG\t%s\t%s\tUDP start\n", $cfg{"TS_NAME"}, (scalar localtime(time()))); }
my $mts = $$meta[2];
# correct continuity counter
for (my $j = 3; $j < length( $mts ); $j += MPEG_SIZE) {
substr( $mts, $j, 1, chr( 0b00010000 | $continuityCounter ) );
$continuityCounter += 1;
if ( $continuityCounter > 0x0f ) { $continuityCounter = 0; }
}
$threadSendUDP = threads->create({'context' => 'list'}, 'SendUDP', ( $tsSocket, $portaddr, $lasTOTime, $ContinuityTDT, $tail_packets, $$meta[1], $mts, %cfg));
}
else { printf( "TSID %s EPG data not found\n", $cfg{"TS_NAME"}); }
# Если нужно, сохраним в файл
if ($cfg{"EXPORT_TS"} eq '1') {
my $pes = $cfg{"tsEpg"}->getEit( 18, CHUNK_TIME );
open( my $ts, ">", $epg_config{"TMP"}."eit$dvbsid.ts" ) || die "Error exporting TS chunk";
binmode( $ts);
print( $ts $pes );
close( $ts );
}
# Уменьшим счетчик времени при 0 или минусе будем заново формировать БД
$TimeToReload = $TimeToReload - (time() - $StartWhileTime);
}
}
# процедура инициаизации баз sqlite EPG
sub InitEitDb {
my ($tsDb, %cfg) = @_;
$cfg{"tsEpg"}->initdb() || die( "Initialization of EIT database failed");
my $dvbsid = $cfg{"DVBS_ID"};
my $number_of_segments = $cfg{"DAYS"} * 8;
my $sel_q = " select sc.Sid, coalesce(sc.CONID, n.Onid), coalesce(sc.Tsid, s.Tsid) Tsid, coalesce(sc.CNID, n.Nid), sc.Ch_Id, iif(s.Dvbs_Id = $dvbsid, 1, 0) as isactual
from Dvb_Network n
inner join Dvb_Streams s on (n.Dvbn_Id = s.Dvbn_Id)
inner join Dvb_Stream_Channels sc on (s.Dvbs_Id = sc.Dvbs_Id)
where (not sc.Sid is null) ";
# Будем ли передавать данные другого потока
if ($cfg{"ACTUAL_OTHER"} == 1) {
$sel_q = $sel_q." and n.Dvbn_Id in (select a.Dvbn_Id from Dvb_Streams a where a.Dvbs_Id = $dvbsid) ";
}
else {
$sel_q = $sel_q." and s.Dvbs_Id = $dvbsid ";
}
my $sth_s = $tsDb->prepare($sel_q);
$sth_s->execute or die "ERROR: Failed execute SQL Dvb_Stream_Channels !";
while ( my ($sid, $onid, $tsid, $nid, $chid, $isactual) = $sth_s->fetchrow_array()) {
$cfg{"tsEpg"}->addEit( 18, $sid, $onid, $tsid, $chid, $number_of_segments, $isactual, '');
}
$cfg{"tsCarousel"}->initdb() || die( "Initialization of carousel database failed");
}
# Заполняем таблицы EIT данными
sub ReadEpgData {
my ( $tsDb, %cfg ) = @_;
my $dvbsid = $cfg{"DVBS_ID"};
# Время в формате 26.02.2015 23:50:00
my $attr = {
ib_timestampformat => '%d.%m.%Y %H:%M:%S',
ib_dateformat => '%d.%m.%Y',
ib_timeformat => '%H:%M:%S',
};
my $sel_q = "select ch_id, date_start, date_stop, title, left(description, ".$cfg{"DESC_LEN"}.") description, minage, lower(lang), dvbgenres
from Get_Epg($dvbsid, current_date, dateadd(day, ".$cfg{"DAYS"}.", current_date), ".$cfg{"ACTUAL_OTHER"}.", '".$cfg{"DESC_FORMAT"}."')";
my $sth_s = $tsDb->prepare($sel_q, $attr);
$sth_s->execute or die "ERROR: Failed execute SQL Get_Epg !";
while (my ($program, $start, $stop, $title, $synopsis, $minage, $lang, $dvbgenres, $genres) = $sth_s->fetchrow_array()) {
#lang codes http://en.wikipedia.org/wiki/List_of_ISO_639-2_codes
if (!defined $lang) {
$lang = $cfg{"COUNTRY"}
}
my $event;
if ($start =~ /^(\d+).(\d+).(\d+)\s+(\d+):(\d+):(\d+)$/) {
my @t = ( $6, $5, $4, $1, $2 - 1, $3);
$event->{start} = timegm(@t);
}
else {
die( "Incorrect start time [$start]");
}
if ($stop =~ /^(\d+).(\d+).(\d+)\s+(\d+):(\d+):(\d+)$/) {
my @t = ( $6, $5, $4, $1, $2 - 1, $3);
$event->{stop} = timegm(@t);
}
else {
die( "Incorrect start time [$start]");
}
$event->{uid} = $program;
$event->{service_id} = $program;
my ($to_code_page, $lang_prefix, $title_ISO, $synopsis_ISO);
# iso codes http://en.wikipedia.org/wiki/ISO/IEC_8859
#
# define codepage according to Annex.2 of EN 300 468
# 0x10 0x00 0x01 ISO/IEC 8859-1 [23] West European
# 0x10 0x00 0x02 ISO/IEC 8859-2 [24] East European
# 0x10 0x00 0x03 ISO/IEC 8859-3 [25] South European
# 0x10 0x00 0x04 ISO/IEC 8859-4 [26] North and North-East European
# 0x10 0x00 0x05 ISO/IEC 8859-5 [27] Latin/Cyrillic A.2
# 0x10 0x00 0x06 ISO/IEC 8859-6 [28] Latin/Arabic A.3
# 0x10 0x00 0x07 ISO/IEC 8859-7 [29] Latin/Greek A.4
# 0x10 0x00 0x08 ISO/IEC 8859-8 [30] Latin/Hebrew A.5
# 0x10 0x00 0x09 ISO/IEC 8859-9 [31] West European & Turkish A.6
# 0x10 0x00 0x0A ISO/IEC 8859-10 [32] North European A.7
# 0x10 0x00 0x0B ISO/IEC 8859-11 [33] Thai A.8
# 0x10 0x00 0x0D ISO/IEC 8859-13 [34] Baltic A.9
# 0x10 0x00 0x0E ISO/IEC 8859-14 [35] Celtic A.10
# 0x10 0x00 0x0F ISO/IEC 8859-15 [36] West European A.11
if ($cfg{"TEXT_IN_UTF"} ne '1') {
$title = CorrectISO($title);
$synopsis = CorrectISO($synopsis);
if (
($lang eq 'rus') # Russian
|| ($lang eq 'bel') # Belarusian
|| ($lang eq 'ukr') # Ukrainian
|| ($lang eq 'bul') # Bulgarian
)
{
$title_ISO = encode("iso-8859-5", $title);
$synopsis_ISO = encode("iso-8859-5", $synopsis);
$lang_prefix = $cfg{"RUS_HEX"};
}
elsif (
($lang eq 'lav') # Latvian
|| ($lang eq 'lit') # Lithuanian
|| ($lang eq 'est') # Estonian
)
{
$title_ISO = encode("iso-8859-4", $title);
$synopsis_ISO = encode("iso-8859-4", $synopsis);
$lang_prefix = "\x10\x00\x4";
}
elsif (
($lang eq 'pol') # Polish
|| ($lang eq 'srp') # Serbian
)
{
$title_ISO = encode("iso-8859-2", $title);
$synopsis_ISO = encode("iso-8859-2", $synopsis);
$lang_prefix = "\x10\x00\x2";
}
#elsif ($lang eq 'kaz') # kaz kk kazakh не нашел таблицу iso-8859 для казахского
#{
# $title_ISO = encode("ptcp154", $title);
# $synopsis_ISO = encode("ptcp154", $synopsis);
# $lang_prefix = "\x10\x00\x2";
#}
elsif (
($lang eq 'arm') # Armenia - Հայաստան код может быть и hye https://en.wikipedia.org/wiki/Armenian_language
)
{
#$title_ISO = encode("iso-8859-9", $title);
#$synopsis_ISO = encode("iso-8859-9", $synopsis);
#$lang_prefix = "\x10\x00\x9";
# UTF8
$title_ISO = $title;
$synopsis_ISO = $synopsis;
$lang_prefix = "\x15";
}
else {
# English German French
$title_ISO = encode("iso-8859-1", $title);
$synopsis_ISO = encode("iso-8859-1", $synopsis);
$lang_prefix = "\x10\x00\x1";
}
}
else {
$title_ISO = $title;
$synopsis_ISO = $synopsis;
$lang_prefix = "\x15";
}
my @descriptors;
my $short_descriptor;
$short_descriptor->{descriptor_tag} = 0x4d; # short event descriptor
$short_descriptor->{language_code} = $lang; # language code from ISO 639-2 lowercase
$short_descriptor->{codepage_prefix} = $lang_prefix;
$short_descriptor->{event_name} = $title_ISO;
$short_descriptor->{text} = "";
push( @descriptors, $short_descriptor);
if ($cfg{"SHOW_EXT"} eq '1') {
if (defined $synopsis_ISO){
my $extended_descriptor;
$extended_descriptor->{descriptor_tag} = 0x4e; # extended event descriptor
$extended_descriptor->{language_code} = $lang;
$extended_descriptor->{codepage_prefix} = $lang_prefix;
$extended_descriptor->{text} = $synopsis_ISO;
push( @descriptors, $extended_descriptor);
}
}
if ($cfg{"SHOW_AGE"} eq '1') {
if (defined $minage) {
if ($minage >= 3) {
my $parental_descriptor;
$parental_descriptor->{descriptor_tag} = 0x55; # parental rating descriptor
my $rate;
$rate->{country_code} = $lang;
$rate->{rating} = $minage - 3; # rating = age limitation - 3
push( @{$parental_descriptor->{list}}, $rate);
push( @descriptors, $parental_descriptor);
}
}
}
if ($cfg{"SHOW_GNR"} eq '1') {
if (defined $dvbgenres) {
my $dvbgenres_descriptor;
$dvbgenres_descriptor->{descriptor_tag} = 0x54; # dvb genre descriptor
my @values = split(',', $dvbgenres);
foreach my $val (@values) {
my $genre;
$genre->{dvb} = $val;
push( @{$dvbgenres_descriptor->{list}}, $genre);
}
push( @descriptors, $dvbgenres_descriptor);
}
}
$event->{descriptors} = \@descriptors;
$cfg{"tsEpg"}->addEvent( $event);
}
return 1;
}
# проверяем нужно ли пересоздавать текущий / следующий для EPG, если нужно пересоздаем
sub BuildEPG {
my ( %cfg ) = @_;
my $pid = 18;
my $SendTime = gettimeofday;
if ($cfg{"tsEpg"}->updateEit( $pid, $cfg{"PF_ONLY"} )) {
# Extract the snippet
my $pes = $cfg{"tsEpg"}->getEit( $pid, CHUNK_TIME );
$cfg{"tsCarousel"}->addMts( $pid, \$pes, CHUNK_TIME * 1000 );
printf( "TSID %s bitrate %.3f kbps (%s buld time %.3f)\n", $cfg{"TS_NAME"}, ( length( $pes ) * 8 / CHUNK_TIME / 1000 ), (scalar localtime(time())), (gettimeofday - $SendTime));
}
return (gettimeofday - $SendTime);
}
sub SendUDP {
my ($multicast, $portaddr, $lasTOTime, $ContinuityTDT, $tail_packets, $interval, $mts, %cfg) = @_;
my $mtsCount = length( $mts ) / MPEG_SIZE;
my $packetCounter = 0;
# correct continuity counter
#for (my $j = 3; $j < length( $mts ); $j += MPEG_SIZE) {
# substr( $mts, $j, 1, chr( 0b00010000 | ( $continuityCounter & 0x0f ) ) );
# $continuityCounter += 1;
#}
# add stuffing packets to have a multiple of 7 packets in the buffer
# Why 7 packets?
# 7 x 188 = 1316
# Because 7 TS packets fit in a typical UDP packet.
my $i = $mtsCount % 7;
while ( $i > 0 && $i < 7) {
$mts .= "\x47\x1f\xff\x10"."\xff" x (MPEG_SIZE-4); # stuffing packet
$i += 1;
}
# correct the count of packets
$mtsCount = length( $mts ) / MPEG_SIZE;
# calculate the waiting time between playing chunks of 7 packets in micro seconds
my $gap = ceil( $interval / $mtsCount * 7 * 1000);
# play packets of 7 x 188bytes
while ($packetCounter < $mtsCount) {
my $chunkCount = $mtsCount - $packetCounter;
$chunkCount = 7 if $chunkCount > 7;
send( $multicast, substr( $mts, $packetCounter * MPEG_SIZE, $chunkCount * MPEG_SIZE), 0, $portaddr);
$packetCounter += $chunkCount;
if ($cfg{'TOT_TDT'} eq '1') {
if ((gettimeofday - $lasTOTime) > TOT_max_interval) {
# print "TOT ".(gettimeofday - $playTime)."\n";
# TOD TDT
my $epoch = time; #берем текущее время
my $tm = gmtime($epoch); # Время по UTC
#получаем дату по модифицированному юлианскому календарю.
my $mon = $tm->mon();
my $year = $tm->year();
my $mday = $tm->mday();
++$mon;
my $l = $mon == 1 || $mon == 2 ? 1 : 0;
my $jmd = 14956 + $mday + int( ( $year - $l ) * 365.25 ) + int( ( $mon + 1 + $l * 12 ) * 30.6001 );
my $h = pack("C", ($tm->hour()/10) <<4 | ($tm->hour() % 10)); # 59 минут в Hex должны выглядеть как 59 а не 3b
my $m = pack("C", ($tm->min()/10) <<4 | ($tm->min() % 10));
my $s = pack("C", ($tm->sec()/10) <<4 | ($tm->sec() % 10));
my $hex_time = pack('n',$jmd).$h.$m.$s;
my $tot_packet = "\x47\x40\x14" # MPEG TS заголовок
. chr(16 + $ContinuityTDT)."\x00" # Счётчик Непрерывности + без поля адаптации + Не зашифрованный пакет.
. "\x73\x70".chr(13+(13*TOT_regions_cnt)) # TOT длина заголовока тоже сразу укзана 1a = 26 байт
. $hex_time # Время
. $cfg{'TOT'} # description
. pack('N',crc( "\x73\x70".chr(13+(13*TOT_regions_cnt)).$hex_time.$cfg{'TOT'}, 32, 0xffffffff, 0x00000000, 0, 0x04C11DB7, 0, 0)); # mpeg2 crc
$tot_packet .= "\xff" x (MPEG_SIZE-length($tot_packet)); # дополним нулевыми пакетами
if ($ContinuityTDT < 15 ) { $ContinuityTDT++; } else {$ContinuityTDT = 0; }
my $tdt_packet = "\x47\x40\x14" # MPEG TS заголовок
. chr(16 + $ContinuityTDT)."\x00" # Счётчик Непрерывности + без поля адаптации + Не зашифрованный пакет.
. "\x70\x70\x05" # TDT заголовок и длина пакета 5 байт
. $hex_time; # 2 байта дата в MJD и 3 байта время как есть.
$tdt_packet.="\xff" x (MPEG_SIZE-length($tdt_packet)); # дополним нулевыми пакетами
if ($ContinuityTDT < 15 ) { $ContinuityTDT++; } else {$ContinuityTDT = 0; }
send( $multicast, $tot_packet.$tdt_packet.$tail_packets, 0, $portaddr);
$lasTOTime = gettimeofday;
}
}
usleep( $gap );
}
return ( $lasTOTime, $ContinuityTDT);
}
# заменим симо=волы, которые некорректно отборажаються на ТВ
sub CorrectISO {
my ($string) = @_;
$string = ReplaceChar($string, '«', '"');
$string = ReplaceChar($string, '»', '"');
$string = ReplaceChar($string, '—', '-'); #UTF E2 80 94
$string = ReplaceChar($string, '–', '-'); #UTF E2 80 93
return($string);
}
sub ReplaceChar {
my ($string, $find, $replace) = @_;
my $pos = index($string, $find);
my $length = 0;
while ( $pos > -1 ) {
substr( $string, $pos, 1, $replace );
$pos = index( $string, $find, $pos + 1);
}
return($string);
}
# end of file