30 lines
695 B
Python
30 lines
695 B
Python
import json
|
|
import os
|
|
|
|
from appPublic.worker import awaitify
|
|
from appPublic.jsonConfig import getConfig
|
|
from ahserver.serverenv import ServerEnv
|
|
from sqlor.dbpools import DBPools
|
|
from ahserver.webapp import webapp
|
|
from downloadchannels import load_url_iptv
|
|
from time import time
|
|
|
|
async def get_channel_by_id(id):
|
|
db = DBPools()
|
|
async with db.sqlorContext('iptvdb') as sor:
|
|
sql = "select * from iptvchannels where id=${id}$"
|
|
recs = await sor.sqlExe(sql, {'id':id})
|
|
if len(recs) < 1:
|
|
return None
|
|
return recs[0]
|
|
return None
|
|
|
|
def init_func():
|
|
g = ServerEnv()
|
|
g.load_url_iptv = load_url_iptv
|
|
g.get_channel_by_id = get_channel_by_id
|
|
|
|
if __name__ == '__main__':
|
|
webapp(init_func)
|
|
|