projectdx/anime-downloader
Template
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Compare commits

base: projectdx:9fe73045003412de91c20bb3f9385e515e3ef43f
Branches Tags
projectdx:master
..
compare: projectdx:ec6b5570b7c630e5651a07816e02adde08a349db
Branches Tags
projectdx:master

2 Commits
9fe7304500 ... ec6b5570b7

Author SHA1 Message Date
projectdx
ec6b5570b7 anime-downloader bug fix 10. 2022-04-06 23:45:15 +09:00
projectdx
32ff102fec anime-downloader bug fix 8. 2022-03-28 19:29:26 +09:00
4 changed files with 695 additions and 273 deletions
Expand all files Collapse all files

663
logic_ohli24.py
View File

@@ -10,21 +10,23 @@ import os, sys, traceback, re, json, threading
from datetime import datetime from datetime import datetime
import copy import copy
import hashlib import hashlib
# third-party # third-party
import requests import requests
from lxml import html from lxml import html
from urllib import parse from urllib import parse
# third-party # third-party
from flask import request, render_template, jsonify from flask import request, render_template, jsonify
from sqlalchemy import or_, and_, func, not_, desc from sqlalchemy import or_, and_, func, not_, desc
from pip._internal import main from pip._internal import main
pkgs = ['beautifulsoup4', 'jsbeautifier'] pkgs = ["beautifulsoup4", "jsbeautifier"]
for pkg in pkgs: for pkg in pkgs:
try: try:
import pkg import pkg
except ImportError: except ImportError:
main(['install', pkg]) main(["install", pkg])
from bs4 import BeautifulSoup from bs4 import BeautifulSoup
import jsbeautifier import jsbeautifier
@@ -33,8 +35,14 @@ import jsbeautifier
from framework import db, scheduler, path_data, socketio from framework import db, scheduler, path_data, socketio
from framework.util import Util from framework.util import Util
from framework.common.util import headers from framework.common.util import headers
from plugin import LogicModuleBase, FfmpegQueueEntity, FfmpegQueue, default_route_socketio from plugin import (
LogicModuleBase,
FfmpegQueueEntity,
FfmpegQueue,
default_route_socketio,
)
from tool_base import d from tool_base import d
# 패키지 # 패키지
from .plugin import P from .plugin import P
@@ -46,40 +54,42 @@ logger = P.logger
class LogicOhli24(LogicModuleBase): class LogicOhli24(LogicModuleBase):
db_default = { db_default = {
'ohli24_db_version': '1', "ohli24_db_version": "1",
'ohli24_url': 'https://ohli24.net', "ohli24_url": "https://ohli24.net",
'ohli24_download_path': os.path.join(path_data, P.package_name, 'ohli24'), "ohli24_download_path": os.path.join(path_data, P.package_name, "ohli24"),
'ohli24_auto_make_folder': 'True', "ohli24_auto_make_folder": "True",
'ohli24_auto_make_season_folder': 'True', "ohli24_auto_make_season_folder": "True",
'ohli24_finished_insert': u'[완결]', "ohli24_finished_insert": "[완결]",
'ohli24_max_ffmpeg_process_count': '1', "ohli24_max_ffmpeg_process_count": "1",
'ohli24_order_desc': 'False', "ohli24_order_desc": "False",
'ohli24_auto_start': 'False', "ohli24_auto_start": "False",
'ohli24_interval': '* 5 * * *', "ohli24_interval": "* 5 * * *",
'ohli24_auto_mode_all': 'False', "ohli24_auto_mode_all": "False",
'ohli24_auto_code_list': 'all', "ohli24_auto_code_list": "all",
'ohli24_current_code': '', "ohli24_current_code": "",
'ohli24_uncompleted_auto_enqueue': 'False', "ohli24_uncompleted_auto_enqueue": "False",
'ohli24_image_url_prefix_series': 'https://www.jetcloud.cc/series/', "ohli24_image_url_prefix_series": "https://www.jetcloud.cc/series/",
'ohli24_image_url_prefix_episode': 'https://www.jetcloud-list.cc/thumbnail/', "ohli24_image_url_prefix_episode": "https://www.jetcloud-list.cc/thumbnail/",
} }
current_headers = None current_headers = None
current_data = None current_data = None
session = requests.Session() session = requests.Session()
headers = { headers = {
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) ' "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) "
'Chrome/71.0.3578.98 Safari/537.36', "Chrome/71.0.3578.98 Safari/537.36",
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8', "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8",
'Accept-Language': 'ko-KR,ko;q=0.9,en-US;q=0.8,en;q=0.7', "Accept-Language": "ko-KR,ko;q=0.9,en-US;q=0.8,en;q=0.7",
'Referer': '' "Referer": "",
}
useragent = {
"User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, "
"like Gecko) Chrome/96.0.4664.110 Whale/3.12.129.46 Safari/537.36"
} }
useragent = {'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, '
'like Gecko) Chrome/96.0.4664.110 Whale/3.12.129.46 Safari/537.36'}
def __init__(self, P): def __init__(self, P):
super(LogicOhli24, self).__init__(P, 'setting', scheduler_desc='ani365 자동 다운로드') super(LogicOhli24, self).__init__(P, "setting", scheduler_desc="ani365 자동 다운로드")
self.name = 'ohli24' self.name = "ohli24"
self.queue = None self.queue = None
default_route_socketio(P, self) default_route_socketio(P, self)
@@ -97,80 +107,109 @@ class LogicOhli24(LogicModuleBase):
def process_menu(self, sub, req): def process_menu(self, sub, req):
arg = P.ModelSetting.to_dict() arg = P.ModelSetting.to_dict()
arg['sub'] = self.name arg["sub"] = self.name
if sub in ['setting', 'queue', 'list', 'request']: if sub in ["setting", "queue", "list", "category", "request"]:
if sub == 'request' and req.args.get('content_code') is not None: if sub == "request" and req.args.get("content_code") is not None:
arg['ohli24_current_code'] = req.args.get('content_code') arg["ohli24_current_code"] = req.args.get("content_code")
if sub == 'setting': if sub == "setting":
job_id = '%s_%s' % (self.P.package_name, self.name) job_id = "%s_%s" % (self.P.package_name, self.name)
arg['scheduler'] = str(scheduler.is_include(job_id)) arg["scheduler"] = str(scheduler.is_include(job_id))
arg['is_running'] = str(scheduler.is_running(job_id)) arg["is_running"] = str(scheduler.is_running(job_id))
return render_template( return render_template(
'{package_name}_{module_name}_{sub}.html'.format(package_name=P.package_name, module_name=self.name, "{package_name}_{module_name}_{sub}.html".format(
sub=sub), arg=arg) package_name=P.package_name, module_name=self.name, sub=sub
return render_template('sample.html', title='%s - %s' % (P.package_name, sub)) ),
arg=arg,
)
return render_template("sample.html", title="%s - %s" % (P.package_name, sub))
# @staticmethod # @staticmethod
def process_ajax(self, sub, req): def process_ajax(self, sub, req):
try: try:
if sub == 'analysis': if sub == "analysis":
# code = req.form['code'] # code = req.form['code']
code = request.form['code'] code = request.form["code"]
data = [] data = []
# print(code) # print(code)
# logger.info("code::: %s", code) # logger.info("code::: %s", code)
P.ModelSetting.set('ohli24_current_code', code) P.ModelSetting.set("ohli24_current_code", code)
data = self.get_series_info(code) data = self.get_series_info(code)
self.current_data = data self.current_data = data
return jsonify({'ret': 'success', 'data': data, 'code': code}) return jsonify({"ret": "success", "data": data, "code": code})
elif sub == 'add_queue': elif sub == "anime_list":
data = []
cate = request.form["type"]
page = request.form["page"]
data = self.get_anime_info(cate, page)
# self.current_data = data
return jsonify(
{"ret": "success", "cate": cate, "page": page, "data": data}
)
elif sub == "add_queue":
ret = {} ret = {}
info = json.loads(request.form['data']) info = json.loads(request.form["data"])
logger.info('info:: %s', info) logger.info("info:: %s", info)
ret['ret'] = self.add(info) ret["ret"] = self.add(info)
return jsonify(ret) return jsonify(ret)
elif sub == 'entity_list': elif sub == "entity_list":
return jsonify(self.queue.get_entity_list()) return jsonify(self.queue.get_entity_list())
elif sub == 'queue_command': elif sub == "queue_command":
ret = self.queue.command(req.form['command'], int(req.form['entity_id'])) ret = self.queue.command(
req.form["command"], int(req.form["entity_id"])
)
return jsonify(ret) return jsonify(ret)
elif sub == 'add_queue_checked_list': elif sub == "add_queue_checked_list":
data = json.loads(request.form['data']) data = json.loads(request.form["data"])
def func(): def func():
count = 0 count = 0
for tmp in data: for tmp in data:
add_ret = self.add(tmp) add_ret = self.add(tmp)
if add_ret.startswith('enqueue'): if add_ret.startswith("enqueue"):
self.socketio_callback('list_refresh', '') self.socketio_callback("list_refresh", "")
count += 1 count += 1
notify = {'type': 'success', 'msg': u'%s 개의 에피소드를 큐에 추가 하였습니다.' % count} notify = {
socketio.emit("notify", notify, namespace='/framework', broadcast=True) "type": "success",
"msg": "%s 개의 에피소드를 큐에 추가 하였습니다." % count,
}
socketio.emit(
"notify", notify, namespace="/framework", broadcast=True
)
thread = threading.Thread(target=func, args=()) thread = threading.Thread(target=func, args=())
thread.daemon = True thread.daemon = True
thread.start() thread.start()
return jsonify('') return jsonify("")
elif sub == 'web_list': elif sub == "web_list":
return jsonify(ModelOhli24Item.web_list(request)) return jsonify(ModelOhli24Item.web_list(request))
elif sub == 'db_remove': elif sub == "db_remove":
return jsonify(ModelOhli24Item.delete_by_id(req.form['id'])) return jsonify(ModelOhli24Item.delete_by_id(req.form["id"]))
except Exception as e: except Exception as e:
P.logger.error('Exception:%s', e) P.logger.error("Exception:%s", e)
P.logger.error(traceback.format_exc()) P.logger.error(traceback.format_exc())
def setting_save_after(self): def setting_save_after(self):
if self.queue.get_max_ffmpeg_count() != P.ModelSetting.get_int('ohli24_max_ffmpeg_process_count'): if self.queue.get_max_ffmpeg_count() != P.ModelSetting.get_int(
self.queue.set_max_ffmpeg_count(P.ModelSetting.get_int('ohli24_max_ffmpeg_process_count')) "ohli24_max_ffmpeg_process_count"
):
self.queue.set_max_ffmpeg_count(
P.ModelSetting.get_int("ohli24_max_ffmpeg_process_count")
)
def get_series_info(self, code): def get_series_info(self, code):
code_type = 'c' code_type = "c"
# _code = None # _code = None
try: try:
if self.current_data is not None and 'code' in self.current_data and self.current_data['code'] == code: if (
self.current_data is not None
and "code" in self.current_data
and self.current_data["code"] == code
):
return self.current_data return self.current_data
if code.startswith('http'): if code.startswith("http"):
# if code.split('c/')[1] is not None: # if code.split('c/')[1] is not None:
# code = code.split('c/')[1] # code = code.split('c/')[1]
@@ -178,22 +217,22 @@ class LogicOhli24(LogicModuleBase):
# elif code.split('e/')[1] is not None: # elif code.split('e/')[1] is not None:
# code_type = 'e' # code_type = 'e'
# code = code.split('e/')[1] # code = code.split('e/')[1]
if '/c/' in code: if "/c/" in code:
code = code.split('c/')[1] code = code.split("c/")[1]
code_type = 'c' code_type = "c"
elif '/e/' in code: elif "/e/" in code:
code = code.split('e/')[1] code = code.split("e/")[1]
code_type = 'e' code_type = "e"
logger.info(f'code:::: {code}') logger.info(f"code:::: {code}")
if code_type == 'c': if code_type == "c":
url = P.ModelSetting.get('ohli24_url') + '/c/' + code url = P.ModelSetting.get("ohli24_url") + "/c/" + code
elif code_type == 'e': elif code_type == "e":
url = P.ModelSetting.get('ohli24_url') + '/e/' + code url = P.ModelSetting.get("ohli24_url") + "/e/" + code
else: else:
url = P.ModelSetting.get('ohli24_url') + '/e/' + code url = P.ModelSetting.get("ohli24_url") + "/e/" + code
logger.debug('url:::> %s', url) logger.debug("url:::> %s", url)
# self.current_headers = { 'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) # self.current_headers = { 'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7)
# AppleWebKit/537.36 (KHTML, like Gecko) ' 'Chrome/96.0.4664.110 Whale/3.12.129.46 Safari/537.36', # AppleWebKit/537.36 (KHTML, like Gecko) ' 'Chrome/96.0.4664.110 Whale/3.12.129.46 Safari/537.36',
# 'Referer': url } # 'Referer': url }
@@ -203,25 +242,35 @@ class LogicOhli24(LogicModuleBase):
title = tree.xpath('//div[@class="view-title"]/h1/text()')[0] title = tree.xpath('//div[@class="view-title"]/h1/text()')[0]
# image = tree.xpath('//div[@class="view-info"]/div[@class="image"]/div/img')[0]['src'] # image = tree.xpath('//div[@class="view-info"]/div[@class="image"]/div/img')[0]['src']
image = tree.xpath('//div[@class="image"]/div/img/@src')[0] image = tree.xpath('//div[@class="image"]/div/img/@src')[0]
image = image.replace('..', P.ModelSetting.get('ohli24_url')) image = image.replace("..", P.ModelSetting.get("ohli24_url"))
des_items = tree.xpath('//div[@class="list"]/p') des_items = tree.xpath('//div[@class="list"]/p')
des = {} des = {}
des_key = ['_otit', '_dir', '_pub', '_tag', '_classifi', '_country', '_grade', '_total_chapter', '_show_time'] des_key = [
"_otit",
"_dir",
"_pub",
"_tag",
"_classifi",
"_country",
"_grade",
"_total_chapter",
"_show_time",
]
description_dict = { description_dict = {
'원제': '_otit', "원제": "_otit",
'원작': '_org', "원작": "_org",
'감독': '_dir', "감독": "_dir",
'각본': '_scr', "각본": "_scr",
'캐릭터 디자인': '_character_design', "캐릭터 디자인": "_character_design",
'음악': '_sound', "음악": "_sound",
'제작사': '_pub', "제작사": "_pub",
'장르': '_tag', "장르": "_tag",
'분류': '_classifi', "분류": "_classifi",
'제작국가': '_country', "제작국가": "_country",
'방영일': '_date', "방영일": "_date",
'등급': '_grade', "등급": "_grade",
'총화수': '_total_chapter', "총화수": "_total_chapter",
'상영시간': '_show_time' "상영시간": "_show_time",
} }
list_body_li = tree.xpath('//ul[@class="list-body"]/li') list_body_li = tree.xpath('//ul[@class="list-body"]/li')
@@ -229,82 +278,143 @@ class LogicOhli24(LogicModuleBase):
episodes = [] episodes = []
vi = None vi = None
for li in list_body_li: for li in list_body_li:
title = li.xpath('.//a/text()')[0].strip() title = li.xpath(".//a/text()")[0].strip()
thumbnail = image thumbnail = image
logger.info(li.xpath('//a[@class="item-subject"]/@href')) logger.info(li.xpath('//a[@class="item-subject"]/@href'))
link = P.ModelSetting.get('ohli24_url') + li.xpath('//a[@class="item-subject"]/@href')[0] link = (
P.ModelSetting.get("ohli24_url")
+ li.xpath('//a[@class="item-subject"]/@href')[0]
)
date = li.xpath('.//div[@class="wr-date"]/text()')[0] date = li.xpath('.//div[@class="wr-date"]/text()')[0]
m = hashlib.md5(title.encode('utf-8')) m = hashlib.md5(title.encode("utf-8"))
# _vi = hashlib.md5(title.encode('utf-8').hexdigest()) # _vi = hashlib.md5(title.encode('utf-8').hexdigest())
logger.info(m.hexdigest()) logger.info(m.hexdigest())
_vi = m.hexdigest() _vi = m.hexdigest()
episodes.append({ episodes.append(
'title': title, {
'link': link, "title": title,
'thumbnail': image, "link": link,
'date': date, "thumbnail": image,
'day': date, "date": date,
'_id': title, "day": date,
'va': link, "_id": title,
'_vi': _vi, "va": link,
'content_code': code, "_vi": _vi,
}) "content_code": code,
}
)
logger.info('des_items length:: %s', len(des_items)) logger.info("des_items length:: %s", len(des_items))
for idx, item in enumerate(des_items): for idx, item in enumerate(des_items):
# key = des_key[idx] # key = des_key[idx]
span = item.xpath('.//span//text()') span = item.xpath(".//span//text()")
logger.info(span) logger.info(span)
key = description_dict[span[0]] key = description_dict[span[0]]
des[key] = item.xpath('.//span/text()')[1] des[key] = item.xpath(".//span/text()")[1]
logger.info(f'des::>> {des}') logger.info(f"des::>> {des}")
image = image.replace('..', P.ModelSetting.get('ohli24_url')) image = image.replace("..", P.ModelSetting.get("ohli24_url"))
logger.info('images:: %s', image) logger.info("images:: %s", image)
logger.info('title:: %s', title) logger.info("title:: %s", title)
ser_description = tree.xpath('//div[@class="view-stocon"]/div[@class="c"]/text()') ser_description = tree.xpath(
'//div[@class="view-stocon"]/div[@class="c"]/text()'
)
data = { data = {
'title': title, "title": title,
'image': image, "image": image,
'date': '2022.01.11 00:30 (화)', "date": "2022.01.11 00:30 (화)",
'ser_description': ser_description, "ser_description": ser_description,
'des': des, "des": des,
'episode': episodes "episode": episodes,
} }
if P.ModelSetting.get_bool('ohli24_order_desc'): if P.ModelSetting.get_bool("ohli24_order_desc"):
data['episode'] = list(reversed(data['episode'])) data["episode"] = list(reversed(data["episode"]))
data['list_order'] = 'desc' data["list_order"] = "desc"
return data return data
# logger.info(response_text) # logger.info(response_text)
except Exception as e: except Exception as e:
P.logger.error('Exception:%s', e) P.logger.error("Exception:%s", e)
P.logger.error(traceback.format_exc()) P.logger.error(traceback.format_exc())
return {'ret': 'exception', 'log': str(e)} return {"ret": "exception", "log": str(e)}
def get_anime_info(self, cate, page):
try:
if cate == "ing":
url = (
P.ModelSetting.get("ohli24_url")
+ "/bbs/board.php?bo_table="
+ cate
+ "&page="
+ page
)
elif cate == "movie":
url = (
P.ModelSetting.get("ohli24_url")
+ "/bbs/board.php?bo_table="
+ cate
+ "&page="
+ page
)
else:
url = (
P.ModelSetting.get("ohli24_url")
+ "/bbs/board.php?bo_table="
+ cate
+ "&page="
+ page
)
# cate == "complete":
logger.info("url:::> %s", url)
data = {}
response_data = LogicOhli24.get_html(url, timeout=10)
tree = html.fromstring(response_data)
tmp_items = tree.xpath('//div[@class="list-row"]')
data["anime_count"] = len(tmp_items)
data["anime_list"] = []
for item in tmp_items:
entity = {}
entity["link"] = item.xpath(".//a/@href")[0]
entity["code"] = entity["link"].split("/")[-1]
entity["title"] = item.xpath(".//div[@class='post-title']/text()")[0]
entity["image_link"] = item.xpath(".//div[@class='img-item']/img/@src")[
0
].replace("..", P.ModelSetting.get("ohli24_url"))
data["ret"] = "success"
data["anime_list"].append(entity)
return data
except Exception as e:
P.logger.error("Exception:%s", e)
P.logger.error(traceback.format_exc())
return {"ret": "exception", "log": str(e)}
# @staticmethod # @staticmethod
def plugin_load(self): def plugin_load(self):
try: try:
logger.debug('%s plugin_load', P.package_name) logger.debug("%s plugin_load", P.package_name)
self.queue = FfmpegQueue(P, P.ModelSetting.get_int('ohli24_max_ffmpeg_process_count')) self.queue = FfmpegQueue(
P, P.ModelSetting.get_int("ohli24_max_ffmpeg_process_count")
)
self.current_data = None self.current_data = None
self.queue.queue_start() self.queue.queue_start()
except Exception as e: except Exception as e:
logger.error('Exception:%s', e) logger.error("Exception:%s", e)
logger.error(traceback.format_exc()) logger.error(traceback.format_exc())
@staticmethod @staticmethod
def plugin_unload(): def plugin_unload():
try: try:
logger.debug('%s plugin_unload', P.package_name) logger.debug("%s plugin_unload", P.package_name)
scheduler.remove_job('%s_recent' % P.package_name) scheduler.remove_job("%s_recent" % P.package_name)
except Exception as e: except Exception as e:
logger.error('Exception:%s', e) logger.error("Exception:%s", e)
logger.error(traceback.format_exc()) logger.error(traceback.format_exc())
@staticmethod @staticmethod
@@ -315,47 +425,49 @@ class LogicOhli24(LogicModuleBase):
@staticmethod @staticmethod
def get_html(url, referer=None, stream=False, timeout=5): def get_html(url, referer=None, stream=False, timeout=5):
data = '' data = ""
try: try:
if LogicOhli24.session is None: if LogicOhli24.session is None:
LogicOhli24.session = requests.session() LogicOhli24.session = requests.session()
# logger.debug('get_html :%s', url) # logger.debug('get_html :%s', url)
headers['Referer'] = '' if referer is None else referer headers["Referer"] = "" if referer is None else referer
page_content = LogicOhli24.session.get(url, headers=headers, timeout=timeout) page_content = LogicOhli24.session.get(
url, headers=headers, timeout=timeout
)
data = page_content.text data = page_content.text
except Exception as e: except Exception as e:
logger.error('Exception:%s', e) logger.error("Exception:%s", e)
logger.error(traceback.format_exc()) logger.error(traceback.format_exc())
return data return data
######################################################### #########################################################
def add(self, episode_info): def add(self, episode_info):
if self.is_exist(episode_info): if self.is_exist(episode_info):
return 'queue_exist' return "queue_exist"
else: else:
db_entity = ModelOhli24Item.get_by_ohli24_id(episode_info['_id']) db_entity = ModelOhli24Item.get_by_ohli24_id(episode_info["_id"])
logger.debug('db_entity:::> %s', db_entity) logger.debug("db_entity:::> %s", db_entity)
if db_entity is None: if db_entity is None:
entity = Ohli24QueueEntity(P, self, episode_info) entity = Ohli24QueueEntity(P, self, episode_info)
logger.debug('entity:::> %s', entity.as_dict()) logger.debug("entity:::> %s", entity.as_dict())
ModelOhli24Item.append(entity.as_dict()) ModelOhli24Item.append(entity.as_dict())
logger.debug('entity:: type >> %s', type(entity)) logger.debug("entity:: type >> %s", type(entity))
self.queue.add_queue(entity) self.queue.add_queue(entity)
return 'enqueue_db_append' return "enqueue_db_append"
elif db_entity.status != 'completed': elif db_entity.status != "completed":
entity = Ohli24QueueEntity(P, self, episode_info) entity = Ohli24QueueEntity(P, self, episode_info)
self.queue.add_queue(entity) self.queue.add_queue(entity)
return 'enqueue_db_exist' return "enqueue_db_exist"
else: else:
return 'db_completed' return "db_completed"
def is_exist(self, info): def is_exist(self, info):
for e in self.queue.entity_list: for e in self.queue.entity_list:
if e.info['_id'] == info['_id']: if e.info["_id"] == info["_id"]:
return True return True
return False return False
@@ -379,23 +491,23 @@ class Ohli24QueueEntity(FfmpegQueueEntity):
self.make_episode_info() self.make_episode_info()
def refresh_status(self): def refresh_status(self):
self.module_logic.socketio_callback('status', self.as_dict()) self.module_logic.socketio_callback("status", self.as_dict())
def info_dict(self, tmp): def info_dict(self, tmp):
# logger.debug('self.info::> %s', self.info) # logger.debug('self.info::> %s', self.info)
for key, value in self.info.items(): for key, value in self.info.items():
tmp[key] = value tmp[key] = value
tmp['vtt'] = self.vtt tmp["vtt"] = self.vtt
tmp['season'] = self.season tmp["season"] = self.season
tmp['content_title'] = self.content_title tmp["content_title"] = self.content_title
tmp['ohli24_info'] = self.info tmp["ohli24_info"] = self.info
tmp['epi_queue'] = self.epi_queue tmp["epi_queue"] = self.epi_queue
return tmp return tmp
def donwload_completed(self): def donwload_completed(self):
db_entity = ModelOhli24Item.get_by_ohli24_id(self.info['_id']) db_entity = ModelOhli24Item.get_by_ohli24_id(self.info["_id"])
if db_entity is not None: if db_entity is not None:
db_entity.status = 'completed' db_entity.status = "completed"
db_entity.complated_time = datetime.now() db_entity.complated_time = datetime.now()
db_entity.save() db_entity.save()
@@ -403,47 +515,49 @@ class Ohli24QueueEntity(FfmpegQueueEntity):
def make_episode_info(self): def make_episode_info(self):
try: try:
# url = 'https://ohli24.net/e/' + self.info['va'] # url = 'https://ohli24.net/e/' + self.info['va']
base_url = 'https://ohli24.net' base_url = "https://ohli24.net"
iframe_url = '' iframe_url = ""
# https://ohli24.net/e/%EB%85%B9%EC%9D%84%20%EB%A8%B9%EB%8A%94%20%EB%B9%84%EC%8A%A4%EC%BD%94%206%ED%99%94 # https://ohli24.net/e/%EB%85%B9%EC%9D%84%20%EB%A8%B9%EB%8A%94%20%EB%B9%84%EC%8A%A4%EC%BD%94%206%ED%99%94
url = self.info['va'] url = self.info["va"]
ourls = parse.urlparse(url) ourls = parse.urlparse(url)
headers = { headers = {
'referer': f'{ourls.scheme}://{ourls.netloc}', "referer": f"{ourls.scheme}://{ourls.netloc}",
'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.110 Whale/3.12.129.46 Safari/537.36' "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.110 Whale/3.12.129.46 Safari/537.36",
} }
logger.debug('url:::> %s', url) logger.debug("url:::> %s", url)
logger.info('self.info:::> %s', self.info) logger.info("self.info:::> %s", self.info)
text = requests.get(url, headers=headers).text text = requests.get(url, headers=headers).text
# logger.debug(text) # logger.debug(text)
soup1 = BeautifulSoup(text, "lxml") soup1 = BeautifulSoup(text, "lxml")
pattern = re.compile(r'url : \"\.\.(.*)\"') pattern = re.compile(r"url : \"\.\.(.*)\"")
script = soup1.find("script", text=pattern) script = soup1.find("script", text=pattern)
if script: if script:
match = pattern.search(script.text) match = pattern.search(script.text)
if match: if match:
iframe_url = match.group(1) iframe_url = match.group(1)
logger.info('iframe_url::> %s', iframe_url) logger.info("iframe_url::> %s", iframe_url)
resp = requests.get(base_url + iframe_url, headers=headers, timeout=20).text resp = requests.get(base_url + iframe_url, headers=headers, timeout=20).text
soup2 = BeautifulSoup(resp, 'lxml') soup2 = BeautifulSoup(resp, "lxml")
iframe_src = soup2.find('iframe')['src'] iframe_src = soup2.find("iframe")["src"]
# print(resp1) # print(resp1)
logger.debug('iframe_src:::> %s', iframe_src) logger.debug("iframe_src:::> %s", iframe_src)
resp1 = requests.get(iframe_src, headers=headers, timeout=600).text resp1 = requests.get(iframe_src, headers=headers, timeout=600).text
# logger.info('resp1::>> %s', resp1) # logger.info('resp1::>> %s', resp1)
soup3 = BeautifulSoup(resp1, "lxml") soup3 = BeautifulSoup(resp1, "lxml")
# packed_pattern = re.compile(r'\\{*(eval.+)*\\}', re.MULTILINE | re.DOTALL) # packed_pattern = re.compile(r'\\{*(eval.+)*\\}', re.MULTILINE | re.DOTALL)
s_pattern = re.compile(r'(eval.+)', re.MULTILINE | re.DOTALL) s_pattern = re.compile(r"(eval.+)", re.MULTILINE | re.DOTALL)
packed_pattern = re.compile(r'if?.([^{}]+)\{.*(eval.+)\}.+else?.{.(eval.+)\}', re.DOTALL) packed_pattern = re.compile(
packed_script = soup3.find('script', text=s_pattern) r"if?.([^{}]+)\{.*(eval.+)\}.+else?.{.(eval.+)\}", re.DOTALL
)
packed_script = soup3.find("script", text=s_pattern)
# packed_script = soup3.find('script') # packed_script = soup3.find('script')
# logger.info('packed_script>>> %s', packed_script.text) # logger.info('packed_script>>> %s', packed_script.text)
unpack_script = None unpack_script = None
@@ -459,107 +573,127 @@ class Ohli24QueueEntity(FfmpegQueueEntity):
# print('packed_script==>', packed_script) # print('packed_script==>', packed_script)
logger.debug(unpack_script) logger.debug(unpack_script)
p1 = re.compile(r'(\"tracks\".*\])\,\"captions\"', re.MULTILINE | re.DOTALL) p1 = re.compile(r"(\"tracks\".*\])\,\"captions\"", re.MULTILINE | re.DOTALL)
m2 = re.search(r'(\"tracks\".*\]).*\"captions\"', unpack_script, flags=re.MULTILINE | re.DOTALL) m2 = re.search(
r"(\"tracks\".*\]).*\"captions\"",
unpack_script,
flags=re.MULTILINE | re.DOTALL,
)
# print(m2.group(1)) # print(m2.group(1))
dict_string = '{' + m2.group(1) + '}' dict_string = "{" + m2.group(1) + "}"
logger.info('dict_string::> %s', dict_string) logger.info("dict_string::> %s", dict_string)
tracks = json.loads(dict_string) tracks = json.loads(dict_string)
self.srt_url = tracks['tracks'][0]['file'] self.srt_url = tracks["tracks"][0]["file"]
logger.debug('srt_url::: %s', tracks['tracks'][0]['file']) logger.debug("srt_url::: %s", tracks["tracks"][0]["file"])
video_hash = iframe_src.split('/') video_hash = iframe_src.split("/")
video_hashcode = re.sub(r'index\.php\?data=', '', video_hash[-1]) video_hashcode = re.sub(r"index\.php\?data=", "", video_hash[-1])
self._vi = video_hashcode self._vi = video_hashcode
video_info_url = f'{video_hash[0]}//{video_hash[2]}/player/index.php?data={video_hashcode}&do=getVideo' video_info_url = f"{video_hash[0]}//{video_hash[2]}/player/index.php?data={video_hashcode}&do=getVideo"
# print('hash:::', video_hash) # print('hash:::', video_hash)
logger.debug('video_info_url::: %s', video_info_url) logger.debug("video_info_url::: %s", video_info_url)
headers = { headers = {
'referer': f'{iframe_src}', "referer": f"{iframe_src}",
'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) ' "user-agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) "
'Chrome/96.0.4664.110 Whale/3.12.129.46 Safari/537.36''Mozilla/5.0 (Macintosh; Intel ' "Chrome/96.0.4664.110 Whale/3.12.129.46 Safari/537.36"
'Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.110 ' "Mozilla/5.0 (Macintosh; Intel "
'Whale/3.12.129.46 Safari/537.36', "Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.110 "
"X-Requested-With": 'XMLHttpRequest' "Whale/3.12.129.46 Safari/537.36",
"X-Requested-With": "XMLHttpRequest",
} }
# print(headers) # print(headers)
payload = { payload = {
"hash": video_hash[-1], "hash": video_hash[-1],
} }
resp2 = requests.post(video_info_url, headers=headers, data=payload, timeout=20).json() resp2 = requests.post(
video_info_url, headers=headers, data=payload, timeout=20
).json()
logger.debug('resp2::> %s', resp2) logger.debug("resp2::> %s", resp2)
hls_url = resp2['videoSource'] hls_url = resp2["videoSource"]
logger.debug('video_url::> %s', hls_url) logger.debug("video_url::> %s", hls_url)
resp3 = requests.get(hls_url, headers=headers).text resp3 = requests.get(hls_url, headers=headers).text
# logger.debug(resp3) # logger.debug(resp3)
# stream_url = hls_url.split('\n')[-1].strip() # stream_url = hls_url.split('\n')[-1].strip()
stream_info = resp3.split('\n')[-2:] stream_info = resp3.split("\n")[-2:]
# logger.debug('stream_url:: %s', stream_url) # logger.debug('stream_url:: %s', stream_url)
logger.debug('stream_info:: %s', stream_info) logger.debug("stream_info:: %s", stream_info)
self.headers = { self.headers = {
'user-agent': "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) " "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) "
"Chrome/71.0.3554.0 Safari/537.36Mozilla/5.0 (Windows NT 10.0; Win64; x64) " "Chrome/71.0.3554.0 Safari/537.36Mozilla/5.0 (Windows NT 10.0; Win64; x64) "
"AppleWebKit/537.36 (KHTML, like Gecko) Chrome/71.0.3554.0 Safari/537.36", "AppleWebKit/537.36 (KHTML, like Gecko) Chrome/71.0.3554.0 Safari/537.36",
'Referer': 'https://ndoodle.xyz/video/03a3655fff3e9bdea48de9f49e938e32', "Referer": "https://ndoodle.xyz/video/03a3655fff3e9bdea48de9f49e938e32",
} }
self.url = stream_info[1].strip() self.url = stream_info[1].strip()
match = re.compile(r'NAME="(?P<quality>.*?)"').search(stream_info[0]) match = re.compile(r'NAME="(?P<quality>.*?)"').search(stream_info[0])
self.quality = match.group('quality') self.quality = match.group("quality")
logger.info(self.quality) logger.info(self.quality)
match = re.compile(r'(?P<title>.*?)\s*((?P<season>\d+)%s)?\s*((?P<epi_no>\d+)%s)' % (u'기', u'화')).search( match = re.compile(
self.info['title']) r"(?P<title>.*?)\s*((?P<season>\d+)%s)?\s*((?P<epi_no>\d+)%s)"
% ("기", "화")
).search(self.info["title"])
# epi_no 초기값 # epi_no 초기값
epi_no = 1 epi_no = 1
if match: if match:
self.content_title = match.group('title').strip() self.content_title = match.group("title").strip()
if 'season' in match.groupdict() and match.group('season') is not None: if "season" in match.groupdict() and match.group("season") is not None:
self.season = int(match.group('season')) self.season = int(match.group("season"))
# epi_no = 1 # epi_no = 1
epi_no = int(match.group('epi_no')) epi_no = int(match.group("epi_no"))
ret = '%s.S%sE%s.%s-OHNI24.mp4' % ( ret = "%s.S%sE%s.%s-OHNI24.mp4" % (
self.content_title, '0%s' % self.season if self.season < 10 else self.season, self.content_title,
'0%s' % epi_no if epi_no < 10 else epi_no, self.quality) "0%s" % self.season if self.season < 10 else self.season,
"0%s" % epi_no if epi_no < 10 else epi_no,
self.quality,
)
else: else:
self.content_title = self.info['title'] self.content_title = self.info["title"]
P.logger.debug('NOT MATCH') P.logger.debug("NOT MATCH")
ret = '%s.720p-OHNI24.mp4' % self.info['title'] ret = "%s.720p-OHNI24.mp4" % self.info["title"]
# logger.info('self.content_title:: %s', self.content_title) # logger.info('self.content_title:: %s', self.content_title)
self.epi_queue = epi_no self.epi_queue = epi_no
self.filename = Util.change_text_for_use_filename(ret) self.filename = Util.change_text_for_use_filename(ret)
logger.info('self.filename::> %s', self.filename) logger.info("self.filename::> %s", self.filename)
self.savepath = P.ModelSetting.get('ohli24_download_path') self.savepath = P.ModelSetting.get("ohli24_download_path")
logger.info('self.savepath::> %s', self.savepath) logger.info("self.savepath::> %s", self.savepath)
# TODO: 완결 처리 # TODO: 완결 처리
if P.ModelSetting.get_bool('ohli24_auto_make_folder'): if P.ModelSetting.get_bool("ohli24_auto_make_folder"):
if self.info['day'].find(u'완결') != -1: if self.info["day"].find("완결") != -1:
folder_name = '%s %s' % (P.ModelSetting.get('ohli24_finished_insert'), self.content_title) folder_name = "%s %s" % (
P.ModelSetting.get("ohli24_finished_insert"),
self.content_title,
)
else: else:
folder_name = self.content_title folder_name = self.content_title
folder_name = Util.change_text_for_use_filename(folder_name.strip()) folder_name = Util.change_text_for_use_filename(folder_name.strip())
self.savepath = os.path.join(self.savepath, folder_name) self.savepath = os.path.join(self.savepath, folder_name)
if P.ModelSetting.get_bool('ohli24_auto_make_season_folder'): if P.ModelSetting.get_bool("ohli24_auto_make_season_folder"):
self.savepath = os.path.join(self.savepath, 'Season %s' % int(self.season)) self.savepath = os.path.join(
self.savepath, "Season %s" % int(self.season)
)
self.filepath = os.path.join(self.savepath, self.filename) self.filepath = os.path.join(self.savepath, self.filename)
if not os.path.exists(self.savepath): if not os.path.exists(self.savepath):
os.makedirs(self.savepath) os.makedirs(self.savepath)
from framework.common.util import write_file, convert_vtt_to_srt from framework.common.util import write_file, convert_vtt_to_srt
srt_filepath = os.path.join(self.savepath, self.filename.replace('.mp4', '.ko.srt'))
srt_filepath = os.path.join(
self.savepath, self.filename.replace(".mp4", ".ko.srt")
)
if self.srt_url is not None and not os.path.exists(srt_filepath): if self.srt_url is not None and not os.path.exists(srt_filepath):
# vtt_data = requests.get(self.vtt, headers=headers).text # vtt_data = requests.get(self.vtt, headers=headers).text
@@ -569,14 +703,14 @@ class Ohli24QueueEntity(FfmpegQueueEntity):
write_file(srt_data, srt_filepath) write_file(srt_data, srt_filepath)
except Exception as e: except Exception as e:
P.logger.error('Exception:%s', e) P.logger.error("Exception:%s", e)
P.logger.error(traceback.format_exc()) P.logger.error(traceback.format_exc())
pass pass
class ModelOhli24Item(db.Model): class ModelOhli24Item(db.Model):
__tablename__ = '{package_name}_ohli24_item'.format(package_name=P.package_name) __tablename__ = "{package_name}_ohli24_item".format(package_name=P.package_name)
__table_args__ = {'mysql_collate': 'utf8_general_ci'} __table_args__ = {"mysql_collate": "utf8_general_ci"}
__bind_key__ = P.package_name __bind_key__ = P.package_name
id = db.Column(db.Integer, primary_key=True) id = db.Column(db.Integer, primary_key=True)
created_time = db.Column(db.DateTime) created_time = db.Column(db.DateTime)
@@ -608,9 +742,12 @@ class ModelOhli24Item(db.Model):
def as_dict(self): def as_dict(self):
ret = {x.name: getattr(self, x.name) for x in self.__table__.columns} ret = {x.name: getattr(self, x.name) for x in self.__table__.columns}
ret['created_time'] = self.created_time.strftime('%Y-%m-%d %H:%M:%S') ret["created_time"] = self.created_time.strftime("%Y-%m-%d %H:%M:%S")
ret['completed_time'] = self.completed_time.strftime( ret["completed_time"] = (
'%Y-%m-%d %H:%M:%S') if self.completed_time is not None else None self.completed_time.strftime("%Y-%m-%d %H:%M:%S")
if self.completed_time is not None
else None
)
return ret return ret
def save(self): def save(self):
@@ -634,66 +771,68 @@ class ModelOhli24Item(db.Model):
@classmethod @classmethod
def web_list(cls, req): def web_list(cls, req):
ret = {} ret = {}
page = int(req.form['page']) if 'page' in req.form else 1 page = int(req.form["page"]) if "page" in req.form else 1
page_size = 30 page_size = 30
job_id = '' job_id = ""
search = req.form['search_word'] if 'search_word' in req.form else '' search = req.form["search_word"] if "search_word" in req.form else ""
option = req.form['option'] if 'option' in req.form else 'all' option = req.form["option"] if "option" in req.form else "all"
order = req.form['order'] if 'order' in req.form else 'desc' order = req.form["order"] if "order" in req.form else "desc"
query = cls.make_query(search=search, order=order, option=option) query = cls.make_query(search=search, order=order, option=option)
count = query.count() count = query.count()
query = query.limit(page_size).offset((page - 1) * page_size) query = query.limit(page_size).offset((page - 1) * page_size)
lists = query.all() lists = query.all()
ret['list'] = [item.as_dict() for item in lists] ret["list"] = [item.as_dict() for item in lists]
ret['paging'] = Util.get_paging_info(count, page, page_size) ret["paging"] = Util.get_paging_info(count, page, page_size)
return ret return ret
@classmethod @classmethod
def make_query(cls, search='', order='desc', option='all'): def make_query(cls, search="", order="desc", option="all"):
query = db.session.query(cls) query = db.session.query(cls)
if search is not None and search != '': if search is not None and search != "":
if search.find('|') != -1: if search.find("|") != -1:
tmp = search.split('|') tmp = search.split("|")
conditions = [] conditions = []
for tt in tmp: for tt in tmp:
if tt != '': if tt != "":
conditions.append(cls.filename.like('%' + tt.strip() + '%')) conditions.append(cls.filename.like("%" + tt.strip() + "%"))
query = query.filter(or_(*conditions)) query = query.filter(or_(*conditions))
elif search.find(',') != -1: elif search.find(",") != -1:
tmp = search.split(',') tmp = search.split(",")
for tt in tmp: for tt in tmp:
if tt != '': if tt != "":
query = query.filter(cls.filename.like('%' + tt.strip() + '%')) query = query.filter(cls.filename.like("%" + tt.strip() + "%"))
else: else:
query = query.filter(cls.filename.like('%' + search + '%')) query = query.filter(cls.filename.like("%" + search + "%"))
if option == 'completed': if option == "completed":
query = query.filter(cls.status == 'completed') query = query.filter(cls.status == "completed")
query = query.order_by(desc(cls.id)) if order == 'desc' else query.order_by(cls.id) query = (
query.order_by(desc(cls.id)) if order == "desc" else query.order_by(cls.id)
)
return query return query
@classmethod @classmethod
def get_list_uncompleted(cls): def get_list_uncompleted(cls):
return db.session.query(cls).filter(cls.status != 'completed').all() return db.session.query(cls).filter(cls.status != "completed").all()
@classmethod @classmethod
def append(cls, q): def append(cls, q):
item = ModelOhli24Item() item = ModelOhli24Item()
item.content_code = q['content_code'] item.content_code = q["content_code"]
item.season = q['season'] item.season = q["season"]
item.episode_no = q['epi_queue'] item.episode_no = q["epi_queue"]
item.title = q['content_title'] item.title = q["content_title"]
item.episode_title = q['title'] item.episode_title = q["title"]
item.ohli24_va = q['va'] item.ohli24_va = q["va"]
item.ohli24_vi = q['_vi'] item.ohli24_vi = q["_vi"]
item.ohli24_id = q['_id'] item.ohli24_id = q["_id"]
item.quality = q['quality'] item.quality = q["quality"]
item.filepath = q['filepath'] item.filepath = q["filepath"]
item.filename = q['filename'] item.filename = q["filename"]
item.savepath = q['savepath'] item.savepath = q["savepath"]
item.video_url = q['url'] item.video_url = q["url"]
item.vtt_url = q['vtt'] item.vtt_url = q["vtt"]
item.thumbnail = q['thumbnail'] item.thumbnail = q["thumbnail"]
item.status = 'wait' item.status = "wait"
item.ohli24_info = q['ohli24_info'] item.ohli24_info = q["ohli24_info"]
item.save() item.save()

2
plugin.py
View File

@@ -30,7 +30,7 @@ class P(object):
'category': 'vod', 'category': 'vod',
'sub2': { 'sub2': {
'ohli24': [ 'ohli24': [
['setting', u'설정'], ['request', u'요청'], ['queue', u'큐'], ['list', u'목록'] ['setting', u'설정'], ['request', u'요청'], ['queue', u'큐'], ['category', u'분류'], ['list', u'목록']
], ],
'linkkf': [ 'linkkf': [
['setting', u'설정'], ['request', u'요청'], ['queue', u'큐'], ['list', u'목록'] ['setting', u'설정'], ['request', u'요청'], ['queue', u'큐'], ['list', u'목록']

271
templates/anime_downloader_ohli24_category.html Normal file
View File

@@ -0,0 +1,271 @@
{% extends "base.html" %}
{% block content %}
{#<div>#}
{# <form id='program_list'>#}
{# {{ macros.setting_input_text_and_buttons('code', '작품 Code', [['analysis_btn', '분석'], ['go_ohli24_btn', 'Go OHLI24']], desc='예) "https://ohli24.net/c/녹을 먹는 비스코" 이나 "녹을 먹는 비스코"') }}#}
{# </form>#}
{# <form id="program_auto_form">#}
{# <div id='episode_list'></div>#}
{# </form>#}
{#</div> <!--전체-->#}
<div>
<div id="anime_category" class="btn-group" role="group" aria-label="Basic example">
<button id="ing" type="button" class="btn btn-success">방영중</button>
<button id="movie" type="button" class="btn btn-primary">극장판</button>
<button id="complete_anilist" type="button" class="btn btn-dark">완결</button>
</div>
<form id="airing_list_form">
<div id="airing_list"></div>
</form>
<form id="screen_movie_list_form">
<div id="screen_movie_list" class="container">
</div>
</form>
<div class="text-center">
<div id="spinner" class="spinner-border" role="status">
<span class="sr-only">Loading...</span>
</div>
</div>
<form id="program_auto_form">
<div id='episode_list'></div>
</form>
</div> <!--전체-->
<script type="text/javascript">
const package_name = "{{arg['package_name'] }}";
const sub = "{{arg['sub'] }}";
const ohli24_url = "{{arg['ohli24_url']}}";
let current_data = null;
const get_anime_list = (type, page) => {
console.log(`type: ${type}, page: ${page}`)
let url = ''
let data = {"page": page, "type": type}
switch (type) {
case 'ing':
url = '/' + package_name + '/ajax/'+sub+'/anime_list'
break;
case 'movie':
url = '/' + package_name + '/ajax/'+sub+'screen_movie_list'
break;
case 'complete':
url = '/' + package_name + '/ajax/'+sub+'screen_movie_list'
break
default:
break;
}
$.ajax({
url: url,
type: "POST",
data: data,
cache: false,
dataType: "json",
success: (ret) => {
current_screen_movie_data = ret
console.log('ret::>', ret)
if (current_screen_movie_data !== '') {
if (type === "ing") {
make_airing_list(ret.data, page)
} else {
make_screen_movie_list(ret, page)
}
div_visible = true
console.log(div_visible)
}
next_page = page + 1
}
})
}
function make_airing_list(data, page) {
let str = ''
let tmp = ''
{#str += "<d"#}
{#str += m_hr_black();#}
{#str += m_row_start(0);#}
{##}
{#str += m_row_end();#}
{#str += m_hr_black();#}
str += '<div>';
str += '<button type="button" class="btn btn-info">Page <span class="badge bg-warning">' + page + '</span></button>';
str += '</div>';
str += '<div id="inner_screen_movie" class="row infinite-scroll">';
for (let i in data.anime_list) {
tmp = '<div class="col-sm-4">';
tmp += '<div class="card">';
tmp += '<img class="card-img-top" src="' + data.anime_list[i].image_link + '" />';
tmp += '<div class="card-body">'
{#tmp += '<button id="code_button" data-code="' + data.episode[i].code + '" type="button" class="btn btn-primary code-button bootstrap-tooltip" data-toggle="button" data-tooltip="true" aria-pressed="true" autocomplete="off" data-placement="top">' +#}
{# '<span data-tooltip-text="'+data.episode[i].title+'">' + data.episode[i].code + '</span></button></div>';#}
tmp += '<h5 class="card-title">' + data.anime_list[i].title + '</h5>';
tmp += '<p class="card-text">' + data.anime_list[i].code + '</p>';
tmp += '<a href="./request?code=' + data.anime_list[i].code + '" class="btn btn-primary cut-text">' + data.anime_list[i].title + '</a>';
tmp += '</div>';
tmp += '</div>';
tmp += '</div>';
str += tmp
}
str += '</div>';
str += m_hr_black();
if (page > 1) {
const temp = document.createElement('div')
temp.innerHTML = str;
while (temp.firstChild) {
document.getElementById("screen_movie_list").appendChild(temp.firstChild);
}
page++
} else {
document.getElementById("screen_movie_list").innerHTML = str;
}
}
function make_screen_movie_list(data, page) {
let str = ''
let tmp = ''
{#str += "<d"#}
{#str += m_hr_black();#}
{#str += m_row_start(0);#}
{##}
{#str += m_row_end();#}
{#str += m_hr_black();#}
str += '<div>';
str += '<button type="button" class="btn btn-info">Page <span class="badge bg-warning">' + page + '</span></button>';
str += '</div>';
str += '<div id="inner_screen_movie" class="row infinite-scroll">';
for (let i in data.anime_list) {
tmp = '<div class="col-sm-4">';
tmp += '<div class="card">';
tmp += '<img class="card-img-top" src="' + data.anime_list[i].image_link + '" />';
tmp += '<div class="card-body">'
{#tmp += '<button id="code_button" data-code="' + data.episode[i].code + '" type="button" class="btn btn-primary code-button bootstrap-tooltip" data-toggle="button" data-tooltip="true" aria-pressed="true" autocomplete="off" data-placement="top">' +#}
{# '<span data-tooltip-text="'+data.episode[i].title+'">' + data.episode[i].code + '</span></button></div>';#}
tmp += '<h5 class="card-title">' + data.anime_list[i].title + '</h5>';
tmp += '<p class="card-text">' + data.anime_list[i].code + '</p>';
tmp += '<a href="./request?code=' + data.anime_list[i].code + '" class="btn btn-primary cut-text">' + data.episode[i].title + '</a>';
tmp += '</div>';
tmp += '</div>';
tmp += '</div>';
str += tmp
}
str += '</div>';
str += m_hr_black();
if (page > 1) {
const temp = document.createElement('div')
temp.innerHTML = str;
while (temp.firstChild) {
document.getElementById("screen_movie_list").appendChild(temp.firstChild);
}
page++
} else {
document.getElementById("screen_movie_list").innerHTML = str;
}
}
$(document).ready(function(){
{#if ( "{{arg['ohli24_current_code']}}" !== "" ) {#}
{# document.getElementById("code").value = "{{arg['ohli24_current_code']}}";#}
{# // 값이 공백이 아니면 분석 버튼 계속 누름#}
{#document.getElementById("analysis_btn").click();#}
{#}#}
$('#anime_category #ing').on("click", function() {
{#console.log(this.id)#}
let spinner = document.getElementById('spinner');
spinner.style.visibility = 'visible';
get_anime_list("ing", 1)
})
// 분석 버튼 클릭시 호출
$("body").on('click', '#analysis_btn', function(e){
e.preventDefault();
const code = document.getElementById("code").value
console.log(code)
$.ajax({
url: '/' + package_name + '/ajax/' + sub + '/analysis',
type: "POST",
cache: false,
data: {code:code},
dataType: "json",
success: function (ret) {
if (ret.ret === 'success' && ret.data != null) {
{#console.log(ret.code)#}
console.log(ret.data)
make_program(ret.data)
} else {
$.notify('<strong>분석 실패</strong><br>' + ret.log, {type: 'warning'});
}
}
});
$("body").on('click', '#go_ohli24_btn', function(e){
e.preventDefault();
window.open("{{arg['ohli24_url']}}", "_blank");
});
$("body").on('click', '#all_check_on_btn', function(e){
e.preventDefault();
$('input[id^="checkbox_"]').bootstrapToggle('on')
});
$("body").on('click', '#all_check_off_btn', function(e){
e.preventDefault();
$('input[id^="checkbox_"]').bootstrapToggle('off')
});
$("body").on('click', '#add_queue_btn', function(e){
e.preventDefault();
data = current_data.episode[$(this).data('idx')];
console.log('data:::>', data)
$.ajax({
url: '/' + package_name + '/ajax/' + sub + '/add_queue',
type: "POST",
cache: false,
data: {data:JSON.stringify(data)},
dataType: "json",
success: function (data) {
if (data.ret == 'enqueue_db_append' || data.ret == 'enqueue_db_exist') {
$.notify('<strong>다운로드 작업을 추가 하였습니다.</strong>', {type: 'success'});
} else if (data.ret == 'queue_exist') {
$.notify('<strong>이미 큐에 있습니다. 삭제 후 추가하세요.</strong>', {type: 'warning'});
} else if (data.ret == 'db_completed') {
$.notify('<strong>DB에 완료 기록이 있습니다.</strong>', {type: 'warning'});
} else {
$.notify('<strong>추가 실패</strong><br>' + ret.log, {type: 'warning'});
}
}
});
});
});
});
</script>
{% endblock %}

16
templates/anime_downloader_ohli24_request.html
View File

@@ -16,14 +16,26 @@
const ohli24_url = "{{arg['ohli24_url']}}"; const ohli24_url = "{{arg['ohli24_url']}}";
let current_data = null; let current_data = null;
const params = new Proxy(new URLSearchParams(window.location.search), {
get: (searchParams, prop) => searchParams.get(prop),
})
$(document).ready(function(){ $(document).ready(function(){
if (params.code === '') {
} else {
document.getElementById("code").value = params.code
{#document.getElementById("analysis_btn").click();#}
}
if ( "{{arg['ohli24_current_code']}}" !== "" ) { if ( "{{arg['ohli24_current_code']}}" !== "" ) {
document.getElementById("code").value = "{{arg['ohli24_current_code']}}"; document.getElementById("code").value = "{{arg['ohli24_current_code']}}";
// 값이 공백이 아니면 분석 버튼 계속 누름 // 값이 공백이 아니면 분석 버튼 계속 누름
{#document.getElementById("analysis_btn").click();#} {#document.getElementById("analysis_btn").click();#}
} }
// 분석 버튼 클릭시 호출 // 분석 버튼 클릭시 호출
$("body").on('click', '#analysis_btn', function(e){ $("body").on('click', '#analysis_btn', function(e){
e.preventDefault(); e.preventDefault();
@@ -79,8 +91,8 @@
tmp += m_row_start(2) + m_col(3, '분류', 'right') + m_col(9, data.des._classifi) + m_row_end(); tmp += m_row_start(2) + m_col(3, '분류', 'right') + m_col(9, data.des._classifi) + m_row_end();
tmp += m_row_start(2) + m_col(3, '방영일', 'right') + m_col(9, data.date+'('+data.day+')') + m_row_end(); tmp += m_row_start(2) + m_col(3, '방영일', 'right') + m_col(9, data.date+'('+data.day+')') + m_row_end();
tmp += m_row_start(2) + m_col(3, '등급', 'right') + m_col(9, data.des._grade) + m_row_end(); tmp += m_row_start(2) + m_col(3, '등급', 'right') + m_col(9, data.des._grade) + m_row_end();
tmp += m_row_start(2) + m_col(3, '총화수', 'right') + m_col(9, data._total_chapter) + m_row_end(); tmp += m_row_start(2) + m_col(3, '총화수', 'right') + m_col(9, data.des._total_chapter) + m_row_end();
tmp += m_row_start(2) + m_col(3, '상영시간', 'right') + m_col(9, data._show_time) + m_row_end(); tmp += m_row_start(2) + m_col(3, '상영시간', 'right') + m_col(9, data.des._show_time) + m_row_end();
tmp += m_row_start(2) + m_col(3, '줄거리', 'right') + m_col(9, data.ser_description) + m_row_end(); tmp += m_row_start(2) + m_col(3, '줄거리', 'right') + m_col(9, data.ser_description) + m_row_end();
str += m_col(9, tmp) str += m_col(9, tmp)
str += m_row_end(); str += m_row_end();