core.py:moveFailedFolder() just the same action as in ADC_function.py
This commit is contained in:
@@ -120,12 +120,13 @@ def create_data_and_move(file_path: str, c: config.Config, debug):
|
|||||||
else:
|
else:
|
||||||
try:
|
try:
|
||||||
print("[-]Move [{}] to failed folder".format(file_path))
|
print("[-]Move [{}] to failed folder".format(file_path))
|
||||||
shutil.move(file_path, conf.failed_folder() + "/")
|
shutil.move(file_path, conf.failed_folder() + "/" + file_name)
|
||||||
except Exception as err:
|
except Exception as err:
|
||||||
print('[!]', err)
|
print('[!]', err)
|
||||||
|
|
||||||
|
|
||||||
def create_data_and_move_with_custom_number(file_path: str, c: config.Config, custom_number):
|
def create_data_and_move_with_custom_number(file_path: str, c: config.Config, custom_number):
|
||||||
|
file_name = os.path.basename(file_path)
|
||||||
try:
|
try:
|
||||||
print("[!]Making Data for [{}], the number is [{}]".format(file_path, custom_number))
|
print("[!]Making Data for [{}], the number is [{}]".format(file_path, custom_number))
|
||||||
core_main(file_path, custom_number, c)
|
core_main(file_path, custom_number, c)
|
||||||
@@ -136,11 +137,11 @@ def create_data_and_move_with_custom_number(file_path: str, c: config.Config, cu
|
|||||||
|
|
||||||
if c.soft_link():
|
if c.soft_link():
|
||||||
print("[-]Link {} to failed folder".format(file_path))
|
print("[-]Link {} to failed folder".format(file_path))
|
||||||
os.symlink(file_path, conf.failed_folder() + "/")
|
os.symlink(file_path, conf.failed_folder() + "/" + file_name)
|
||||||
else:
|
else:
|
||||||
try:
|
try:
|
||||||
print("[-]Move [{}] to failed folder".format(file_path))
|
print("[-]Move [{}] to failed folder".format(file_path))
|
||||||
shutil.move(file_path, conf.failed_folder() + "/")
|
shutil.move(file_path, conf.failed_folder() + "/" + file_name)
|
||||||
except Exception as err:
|
except Exception as err:
|
||||||
print('[!]', err)
|
print('[!]', err)
|
||||||
|
|
||||||
|
|||||||
27
core.py
27
core.py
@@ -35,17 +35,16 @@ def escape_path(path, escape_literals: str): # Remove escape literals
|
|||||||
return path
|
return path
|
||||||
|
|
||||||
|
|
||||||
def moveFailedFolder(filepath, failed_folder):
|
def moveFailedFolder(filepath):
|
||||||
if config.Config().failed_move():
|
if config.Config().failed_move():
|
||||||
root_path = str(pathlib.Path(filepath).parent)
|
failed_folder = config.Config().failed_folder()
|
||||||
file_name = pathlib.Path(filepath).name
|
file_name = os.path.basename(filepath)
|
||||||
destination_path = root_path + '/' + failed_folder + '/'
|
|
||||||
if config.Config().soft_link():
|
if config.Config().soft_link():
|
||||||
print('[-]Create symlink to Failed output folder')
|
print('[-]Create symlink to Failed output folder')
|
||||||
os.symlink(filepath, destination_path + '/' + file_name)
|
os.symlink(filepath, failed_folder + '/' + file_name)
|
||||||
else:
|
else:
|
||||||
print('[-]Move to Failed output folder')
|
print('[-]Move to Failed output folder')
|
||||||
shutil.move(filepath, destination_path)
|
shutil.move(filepath, failed_folder + '/' + file_name)
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
||||||
@@ -130,7 +129,7 @@ def get_data_from_json(file_number, filepath, conf: config.Config): # 从JSON
|
|||||||
# Return if data not found in all sources
|
# Return if data not found in all sources
|
||||||
if not json_data:
|
if not json_data:
|
||||||
print('[-]Movie Data not found!')
|
print('[-]Movie Data not found!')
|
||||||
moveFailedFolder(filepath, conf.failed_folder())
|
moveFailedFolder(filepath)
|
||||||
return
|
return
|
||||||
|
|
||||||
# ================================================网站规则添加结束================================================
|
# ================================================网站规则添加结束================================================
|
||||||
@@ -169,7 +168,7 @@ def get_data_from_json(file_number, filepath, conf: config.Config): # 从JSON
|
|||||||
|
|
||||||
if title == '' or number == '':
|
if title == '' or number == '':
|
||||||
print('[-]Movie Data not found!')
|
print('[-]Movie Data not found!')
|
||||||
moveFailedFolder(filepath, conf.failed_folder())
|
moveFailedFolder(filepath)
|
||||||
return
|
return
|
||||||
|
|
||||||
# if imagecut == '3':
|
# if imagecut == '3':
|
||||||
@@ -395,7 +394,7 @@ def download_file_with_filename(url, filename, path, conf: config.Config, filepa
|
|||||||
i += 1
|
i += 1
|
||||||
print('[-]Image Download : Connect retry ' + str(i) + '/' + str(configProxy.retry))
|
print('[-]Image Download : Connect retry ' + str(i) + '/' + str(configProxy.retry))
|
||||||
print('[-]Connect Failed! Please check your Proxy or Network!')
|
print('[-]Connect Failed! Please check your Proxy or Network!')
|
||||||
moveFailedFolder(filepath, failed_folder)
|
moveFailedFolder(filepath)
|
||||||
return
|
return
|
||||||
|
|
||||||
def trailer_download(trailer, leak_word, c_word, number, path, filepath, conf: config.Config, failed_folder):
|
def trailer_download(trailer, leak_word, c_word, number, path, filepath, conf: config.Config, failed_folder):
|
||||||
@@ -419,7 +418,7 @@ def extrafanart_download(data, path, conf: config.Config, filepath, failed_folde
|
|||||||
path = path + '/' + conf.get_extrafanart()
|
path = path + '/' + conf.get_extrafanart()
|
||||||
for url in data:
|
for url in data:
|
||||||
if download_file_with_filename(url, '/extrafanart-' + str(j)+'.jpg', path, conf, filepath, failed_folder) == 'failed':
|
if download_file_with_filename(url, '/extrafanart-' + str(j)+'.jpg', path, conf, filepath, failed_folder) == 'failed':
|
||||||
moveFailedFolder(filepath, failed_folder)
|
moveFailedFolder(filepath)
|
||||||
return
|
return
|
||||||
configProxy = conf.proxy()
|
configProxy = conf.proxy()
|
||||||
for i in range(configProxy.retry):
|
for i in range(configProxy.retry):
|
||||||
@@ -440,7 +439,7 @@ def extrafanart_download(data, path, conf: config.Config, filepath, failed_folde
|
|||||||
# 封面是否下载成功,否则移动到failed
|
# 封面是否下载成功,否则移动到failed
|
||||||
def image_download(cover, number, leak_word, c_word, path, conf: config.Config, filepath, failed_folder):
|
def image_download(cover, number, leak_word, c_word, path, conf: config.Config, filepath, failed_folder):
|
||||||
if download_file_with_filename(cover, number + leak_word + c_word + '-fanart.jpg', path, conf, filepath, failed_folder) == 'failed':
|
if download_file_with_filename(cover, number + leak_word + c_word + '-fanart.jpg', path, conf, filepath, failed_folder) == 'failed':
|
||||||
moveFailedFolder(filepath, failed_folder)
|
moveFailedFolder(filepath)
|
||||||
return
|
return
|
||||||
|
|
||||||
configProxy = conf.proxy()
|
configProxy = conf.proxy()
|
||||||
@@ -522,12 +521,12 @@ def print_files(path, leak_word, c_word, naming_rule, part, cn_sub, json_data, f
|
|||||||
except IOError as e:
|
except IOError as e:
|
||||||
print("[-]Write Failed!")
|
print("[-]Write Failed!")
|
||||||
print(e)
|
print(e)
|
||||||
moveFailedFolder(filepath, failed_folder)
|
moveFailedFolder(filepath)
|
||||||
return
|
return
|
||||||
except Exception as e1:
|
except Exception as e1:
|
||||||
print(e1)
|
print(e1)
|
||||||
print("[-]Write Failed!")
|
print("[-]Write Failed!")
|
||||||
moveFailedFolder(filepath, failed_folder)
|
moveFailedFolder(filepath)
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
||||||
@@ -704,7 +703,7 @@ def get_part(filepath, failed_folder):
|
|||||||
return re.findall('-cd\d+', filepath)[0]
|
return re.findall('-cd\d+', filepath)[0]
|
||||||
except:
|
except:
|
||||||
print("[-]failed!Please rename the filename again!")
|
print("[-]failed!Please rename the filename again!")
|
||||||
moveFailedFolder(filepath, failed_folder)
|
moveFailedFolder(filepath)
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user