Queue + new parser

2011-04-01 10:37:23 +04:00
parent 78da6e4f11
commit 3bca154729
6 changed files with 77 additions and 6 deletions
@@ -0,0 +1,35 @@
+#!/opt/local/bin/php
+<?php
+
+chdir('..');
+require_once 'common.php';
+Config::loadFile('app', 'config/app.ini');
+
+$db = Db::getInstance();
+$vk = new Vkontakte();
+
+$continue = true;
+while ($continue) {
+	$queue = $db->getRows($db->q("SELECT * FROM beathaven.queue WHERE status=0 LIMIT 100"));
+	if (!$queue || count($queue) == 0) {
+		$continue = false;
+	} else {
+		foreach ($queue as $t) {
+			echo "#{$t['track_id']} {$t['track_title']}\n";
+			echo "Loading file list: ";
+			$vk->parse($t['track_title']);
+			$files = $vk->getFiles();
+			if ($files && count($files) > 0) {
+				echo "OK (".count($files).")\n";
+				$tmp = explode(' - ', $t['track_title']); $artist_name = $tmp[0]; unset($tmp[0]); $track_name = implode(' - ', $tmp);
+				$files = VkontakteMP3::check($files, $artist_name, $track_name, $t['track_length']);
+				BeatDB::set($t['track_id'], $files);
+				echo "Good files: ". count($files) ."\n\n";
+				$db->q("UPDATE beathaven.queue SET status=1 WHERE track_id=". $t['track_id']);
+			} else {
+				echo "FAILED\n\n";
+				$db->q("UPDATE beathaven.queue SET status=2 WHERE track_id=". $t['track_id']);
+			}
+		}
+	}
+}