The controller is now working, triggering the play state of the scheduled episodes. Currently alot todo to add movies, commercials and options to disable / use certain features.

2026-01-02 16:23:15 +00:00 · 2017-07-15 09:19:26 -07:00
parent 58a0513056
commit 4fa22eda2b
4 changed files with 174 additions and 29 deletions
--- a/pseudo-tv.db
+++ b/pseudo-tv.db
--- a/pseudo_generate_daily_scheduledb.py
+++ b/pseudo_generate_daily_scheduledb.py
@@ -29,15 +29,15 @@ def create_table():

 	c.execute('DROP TABLE IF EXISTS daily_schedule')

-	c.execute('CREATE TABLE daily_schedule(id INTEGER PRIMARY KEY AUTOINCREMENT, unix INTEGER, mediaID INTEGER, title TEXT, episodeNumber INTEGER, seasonNumber INTEGER, showTitle TEXT, duration INTEGER, startTime INTEGER, endTime INTEGER, dayOfWeek TEXT)')
+	c.execute('CREATE TABLE daily_schedule(id INTEGER PRIMARY KEY AUTOINCREMENT, unix INTEGER, mediaID INTEGER, title TEXT, episodeNumber INTEGER, seasonNumber INTEGER, showTitle TEXT, duration INTEGER, startTime INTEGER, endTime INTEGER, dayOfWeek TEXT, startTimeUnix INTEGER)')

-def add_daily_schedule_to_db(mediaID, title, episodeNumber, seasonNumber, showTitle, duration, startTime, endTime, dayOfWeek):
+def add_daily_schedule_to_db(mediaID, title, episodeNumber, seasonNumber, showTitle, duration, startTime, endTime, dayOfWeek, startTimeUnix):

 	unix = int(time.time())

 	try:

-		c.execute("INSERT OR REPLACE INTO daily_schedule (unix, mediaID, title, episodeNumber, seasonNumber, showTitle, duration, startTime, endTime, dayOfWeek) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", (unix, mediaID, title, episodeNumber, seasonNumber, showTitle, duration, startTime, endTime, dayOfWeek))
+		c.execute("INSERT OR REPLACE INTO daily_schedule (unix, mediaID, title, episodeNumber, seasonNumber, showTitle, duration, startTime, endTime, dayOfWeek, startTimeUnix) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", (unix, mediaID, title, episodeNumber, seasonNumber, showTitle, duration, startTime, endTime, dayOfWeek, startTimeUnix))

 		conn.commit()

@@ -63,8 +63,8 @@ def time_diff(time1,time2):
 	* Getting the offest by comparing both times from the unix epoch time and getting the difference.
 	*
 	'''
-	timeA = datetime.datetime.strptime(time1, "%H:%M")
-	timeB = datetime.datetime.strptime(time2, "%H:%M")
+	timeA = datetime.datetime.strptime(time1, "%I:%M %p")
+	timeB = datetime.datetime.strptime(time2, "%I:%M %p")
 	
 	timeAEpoch = calendar.timegm(timeA.timetuple())
 	timeBEpoch = calendar.timegm(timeB.timetuple())
@@ -73,6 +73,11 @@ def time_diff(time1,time2):

 	return int(tdelta/60)

+
+def adjust_start_time_if_duration_is_too_short(duration):
+
+	print("")
+
 '''
 *
 * Passing in the endtime from the prev episode and desired start time of this episode, calculate the best start time 
@@ -80,45 +85,58 @@ def time_diff(time1,time2):
 * Returns time - for new start time
 *
 '''
-def calculate_start_time_offset_from_prev_episode_endtime(prevEndTime, intendedStartTime):
+def calculate_start_time_offset_from_prev_episode_endtime(prevEndTime, intendedStartTime, duration, prevEpDuration):

-	time1 = prevEndTime.strftime('%H:%M')
+	time1 = prevEndTime.strftime('%I:%M %p')

-	# time2 = intendedStartTime.strftime('%H:%M')
-
-	timeB = datetime.datetime.strptime(intendedStartTime, '%Y-%m-%d %H:%M:%S').strftime('%H:%M')
-
-	print(timeB)
+	timeB = datetime.datetime.strptime(intendedStartTime, '%Y-%m-%d %H:%M:%S').strftime('%I:%M %p')

 	timeDiff = time_diff(time1, timeB)

 	print("timeDiff "+ str(timeDiff))
+	print("startTimeUNIX: "+ str(intendedStartTime))
+
+	newTimeObj = datetime.datetime.strptime(intendedStartTime, "%Y-%m-%d %H:%M:%S")
+
+	newStartTime = datetime.datetime.strptime(intendedStartTime, '%Y-%m-%d %H:%M:%S')

 	'''
 	*
 	* If time difference is negative, then we know there is overlap
 	*
 	'''
-	if timeDiff < 0:
+	if timeDiff <= 0:

 		print("There is overlap ")

-	elif timeDiff > 10:
+
+		'''
+		*
+		* If timeDiff is not more than 15 minutes, or 30 minutes just adjust by 15 or 30. If more than adjust by the exact difference
+		*
+		'''
+		newStartTime = newTimeObj + datetime.timedelta(minutes=abs(timeDiff + 5))
+
+	elif timeDiff <= 5:
+
+		print("timeDiff is less than or equal to 5 minutes")
+
+	elif timeDiff > 5:

 		print("Time gap is more than ten, let's start next media earlier than inended")

-	elif timeDiff > 20:
+		# if prevEpDuration < 10

-		print("Time gap is more than 20 minutes, let's start next media earlier than inended")
-
-	elif timeDiff > 30:
-
-		print("Time gap is more than 30 minutes, let's start next media earlier than inended")
+		newStartTime = newTimeObj - datetime.timedelta(minutes=timeDiff-5)

 	else:

 		print("Not sure what to do here")

+		
+
+	return newStartTime.strftime('%I:%M %p')
+
 '''
 *
 * Using datetime to figure out when the media item will end based on the scheduled start time or the offset 
@@ -191,6 +209,8 @@ def generate_daily_schedule():
 	*
 	'''
 	prevEpisodeEndTime = None
+
+	prevEpDuration = None
 	'''
 	*
 	* Everytime this function is run it drops the previous "scheduled_shows" & table recreates it
@@ -247,12 +267,21 @@ def generate_daily_schedule():
 			'''
 			endTime = get_end_time_from_duration(row[5], first_episode[4]);

-			print("End time: " + str(endTime)); 
+			if prevEpisodeEndTime != None:
+
+				newStartTime = calculate_start_time_offset_from_prev_episode_endtime(prevEpisodeEndTime, row[8], first_episode[4], prevEpDuration)
+
+			else:
+
+				prevEpisodeEndTime = endTime
+
+				prevEpDuration = first_episode[4]
+
 			print("prevEpisodeEndTime: " + str(prevEpisodeEndTime)); 

-			add_daily_schedule_to_db(0, first_episode_title, first_episode[5], first_episode[6], row[3], 0, row[5], endTime, row[7])
+			startTimeUnix = datetime.datetime.strptime(newStartTime, '%I:%M %p')

-			prevEpisodeEndTime = endTime
+			add_daily_schedule_to_db(0, first_episode[3], first_episode[5], first_episode[6], row[3], first_episode[4], newStartTime, endTime, row[7], startTimeUnix)
 		
 		else:
 			'''
@@ -300,22 +329,28 @@ def generate_daily_schedule():
 					*
 					'''

-					newStartTime = ''
+					newStartTime = row[5]

 					if prevEpisodeEndTime != None:

-						calculate_start_time_offset_from_prev_episode_endtime(prevEpisodeEndTime, row[8])
+						newStartTime = calculate_start_time_offset_from_prev_episode_endtime(prevEpisodeEndTime, row[8], next_episode[4], prevEpDuration)

 					else:

 						prevEpisodeEndTime = endTime

+						prevEpDuration = first_episode[4]
+
 					print("prevEpisodeEndTime: " + str(prevEpisodeEndTime)); 

-					add_daily_schedule_to_db(0, next_episode[3], next_episode[5], next_episode[6], row[3], 0, row[5], endTime, row[7])
+					startTimeUnix = datetime.datetime.strptime(newStartTime, '%I:%M %p')
+
+					add_daily_schedule_to_db(0, next_episode[3], next_episode[5], next_episode[6], row[3], next_episode[4], newStartTime, endTime, row[7], startTimeUnix)

 					prevEpisodeEndTime = endTime

+					prevEpDuration = next_episode[4]
+
 				else:

 					print("Not grabbing next episode for some reason")
@@ -344,19 +379,29 @@ def generate_daily_schedule():

 				print("End time: " + str(endTime)); 

+				newStartTime = row[5]
+
 				if prevEpisodeEndTime != None:

-					calculate_start_time_offset_from_prev_episode_endtime(prevEpisodeEndTime, row[8])
+					newStartTime = calculate_start_time_offset_from_prev_episode_endtime(prevEpisodeEndTime, row[8], first_episode[4], prevEpDuration)

 				else:

 					prevEpisodeEndTime = endTime

+					prevEpDuration = next_episode[4]
+
+				print("prevEpisodeEndTime: " + str(prevEpisodeEndTime)); 
+
+				startTimeUnix = datetime.datetime.strptime(newStartTime, '%I:%M %p')
+
+				add_daily_schedule_to_db(0, first_episode[3], first_episode[5], first_episode[6], row[3], first_episode[4], newStartTime, endTime, row[7], startTimeUnix)

-				add_daily_schedule_to_db(0, first_episode_title, first_episode[5], first_episode[6], row[3], 0, row[5], endTime, row[7])

 				prevEpisodeEndTime = endTime

+				prevEpDuration = next_episode[4]
+
 			    # raise e


--- a/pseudo_tv_controller.py
+++ b/pseudo_tv_controller.py
@@ -0,0 +1,94 @@
+#!/usr/bin/python
+
+from plexapi.server import PlexServer
+from datetime import datetime
+import sqlite3
+
+import logging
+import logging.handlers
+
+from pseudo_config import *
+
+plex = PlexServer(baseurl, token)
+
+conn = sqlite3.connect('pseudo-tv.db', timeout=10)
+c = conn.cursor()
+
+my_logger = logging.getLogger('MyLogger')
+my_logger.setLevel(logging.DEBUG)
+
+handler = logging.handlers.SysLogHandler(address = '/dev/log')
+
+my_logger.addHandler(handler)
+
+def showConnectedClients():
+	for client in plex.clients():
+    		print(client.title)
+
+def playMovie():
+	cars = plex.library.section('Movies').get('Dumb and Dumber')
+	client = plex.client("RasPlex")
+	print(cars)
+	client.playMedia(cars)
+'''
+*
+* Play Media
+*
+'''
+def play_media(mediaType, mediaParentTitle, mediaTitle):
+	media = plex.library.section(mediaType).get(mediaParentTitle).episodes()
+	client = plex.client("RasPlex")
+	last_episode = plex.library.section('TV Shows')
+	for part in media:
+		# print(part.title)
+		if part.title == mediaTitle:
+			client.playMedia(part)
+			break
+
+'''
+*
+* Check DB / current time. If that matches a scheduled shows startTime then trigger play via Plex API
+*
+'''
+def tv_controller():
+
+	currentTime = datetime.now()
+
+	sql = """SELECT *
+			FROM scheduled_shows
+			WHERE datetime(startTimeUnix) = ? AND
+			      datetime(startTimeUnix) = ? """
+			      
+
+	c.execute("SELECT * FROM daily_schedule ORDER BY datetime(startTimeUnix) ASC")
+
+	datalist = list(c.fetchall())
+
+	my_logger.debug('TV Controller')
+
+	for row in datalist:
+
+		timeB = datetime.strptime(row[8], '%I:%M %p')
+
+		if currentTime.hour == timeB.hour:
+
+			if currentTime.minute == timeB.minute:
+
+				print("Starting Epsisode: " + row[3])
+				print(row)
+
+				play_media("TV Shows", row[6], row[3])
+
+				my_logger.debug('Trying to play: ' + row[3])
+
+				break
+
+
+
+
+tv_controller()
+
+#showConnectedClients()
+
+#playMovie()
+#play_media("TV Shows", "The Office (US)", "Garage Sale")
--- a/schedule.sh
+++ b/schedule.sh
@@ -30,4 +30,10 @@ python pseudo_channel.py -a "shows" -n "the office (us)" -t "4:30 PM" -d "weekda

 python pseudo_channel.py -a "shows" -n "friends" -t "5:00 PM" -d "weekdays"
 python pseudo_channel.py -a "shows" -n "friends" -t "5:30 PM" -d "weekdays"
-python pseudo_channel.py -a "shows" -n "friends" -t "5:40 PM" -d "weekdays"
+python pseudo_channel.py -a "shows" -n "friends" -t "5:31 PM" -d "weekdays"
+
+python pseudo_channel.py -a "shows" -n "friends" -t "6:30 PM" -d "weekdays"
+python pseudo_channel.py -a "shows" -n "friends" -t "8:34 PM" -d "weekdays"
+python pseudo_channel.py -a "shows" -n "friends" -t "8:50 PM" -d "weekdays"
+python pseudo_channel.py -a "shows" -n "friends" -t "9:00 PM" -d "weekdays"
+python pseudo_channel.py -a "shows" -n "the it crowd" -t "9:30 PM" -d "weekdays"