houhuan/faker2
1
0
Fork 0
mirror of https://github.com/shufflewzc/faker2.git synced 2025-04-23 02:48:44 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update jd_identical.py

Browse Source
This commit is contained in:
Hans155922 2022-08-11 07:37:08 +08:00 committed by GitHub
parent 4bb8c56963
commit b1efee82c4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 23 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
jd_identical.py
View File

@ -10,6 +10,7 @@ import os
import sys
import time
import traceback
import requests
logger = logging.getLogger(name=None) # 创建一个日志对象
@ -82,6 +83,17 @@ def get_index(lst: list, item: str) -> list:
return [index for (index, value) in enumerate(lst) if value == item]
def getversion():
url = f"http://{ipport}/api/system"
response = requests.get(url=url)
data = json.loads(response.content.decode("utf-8"))
version = data.get("data").get("version")
if int(version.split('.')[0]) >= 2:
if int(version.split('.')[1]) >= 12:
return 1
return 0
def get_duplicate_list(tasklist: list) -> tuple:
logger.info("\n=== 第一轮初筛开始 ===")
@ -89,6 +101,13 @@ def get_duplicate_list(tasklist: list) -> tuple:
names = []
cmds = []
for task in tasklist:
url = f"http://{ipport}/api/system"
response = requests.get(url=url)
data = json.loads(response.content.decode("utf-8"))
version = data.get("data").get("version")
if getversion() == 1:
ids.append(task.get("id"))
else:
ids.append(task.get("_id"))
names.append(task.get("name"))
cmds.append(task.get("command"))
@ -154,20 +173,12 @@ def disable_duplicate_tasks(ids: list) -> None:
def get_token() -> str or None:
try:
url = f"http://{ipport}/api/system"
response = requests.get(url=url)
data = json.loads(response.content.decode("utf-8"))
version=data.get("data").get("version")
if int(version.split('.')[0])>=2:
if int(version.split('.')[1])>=12:
if getversion() == 1:
with open("/ql/data/config/auth.json", "r", encoding="utf-8") as f:
data = json.load(f)
else:
with open("/ql/config/auth.json", "r", encoding="utf-8") as f:
data = json.load(f)
else:
with open("/ql/config/auth.json", "r", encoding="utf-8") as f:
data = json.load(f)
except Exception:
logger.info(f"❌无法获取 token!!!\n{traceback.format_exc()}")
send("💔禁用重复任务失败", "无法获取 token!!!")