1

新增 NTFY 通知支持

.github/ISSUE_TEMPLATE/bug_report.yml

@@ -0,0 +1,18 @@
+name: 问题反馈 🐞 
+description: 有问题先更新订阅，不行才提
+body:
+  - type: input
+    id: version
+    attributes:
+      label: 青龙版本
+    validations:
+      required: true
+
+  - type: textarea
+    id: description
+    attributes:
+      label: 问题描述
+      description: 尽量详细描述问题，附上错误日志或截图。
+      placeholder: 请描述
+    validations:
+      required: true

.github/ISSUE_TEMPLATE/config.yml

@@ -0,0 +1,5 @@
+blank_issues_enabled: false
+contact_links:
+  - name: TG Chat
+    url: https://t.me/dylan_jdpro
+    about: 关注tg不迷路

.github/ISSUE_TEMPLATE/feature_request.yml

@@ -0,0 +1,9 @@
+name: "💡功能建议"
+description: 为项目提想法
+labels: ["pending","feature"]
+body:
+  - type: textarea
+    id: require
+    attributes:
+      label: 需求描述
+      placeholder: 请描述

README.md

@@ -6,15 +6,15 @@
 ### [TG CHANEL](https://t.me/dylan_jdpro)
 
 
-国内机（带代理）：
+国内机（带加速，也不太稳）：
 
 ```
-ql repo https://js.okyago.com/https://github.com/6dylan6/jdpro.git "jd_|jx_|jddj_" "backUp" "^jd[^_]|USER|JD|function|sendNotify|utils"
+ql repo https://js.googo.win/https://github.com/6dylan6/jdpro.git "jd_|jx_|jddj_" "backUp" "^jd[^_]|USER|JD|function|sendNotify|utils"
 
 ```
 
 
-国外机：
+国外机（国外ip有限制可能有些任务不能正常运行）：
 
 ```
 ql repo https://github.com/6dylan6/jdpro.git "jd_|jx_|jddj_" "backUp" "^jd[^_]|USER|JD|function|sendNotify|utils"
@@ -22,17 +22,14 @@ ql repo https://github.com/6dylan6/jdpro.git "jd_|jx_|jddj_" "backUp" "^jd[^_]|U
 ```
 
 
-线报监控类，[入口](https://github.com/6dylan6/jdm.git)
 
+## 使用
 
-
-## 简要流程
-
-1、部署青龙并登陆，版本不用追新，稳定才好，推荐whyour/qinglong:2.17.9镜像部署。
+1、部署青龙登陆，版本不用追新，稳定才好，推荐部署到内网（不要外网访问，2.20.2以下版本面板会被免密登录偷家，如果必须外网就用最新版本吧）。
 
 2、到订阅管理创建订阅并运行；正确配置[参考](https://github.com/6dylan6/jdpro/issues/22)
 
-3、订阅执行完，到定时任务搜索依赖安装（jd_indeps.sh)任务执行；
+3、订阅执行完，到定时任务搜索依赖安装（jd_indeps)任务执行；
 
 4、到环境变量，创建变量，名称: JD_COOKIE,值：抓的CK（要安全就手抓），多个每行建一个，不要全写在一个；
 
@@ -71,32 +68,20 @@ export NOTIFY_SHOWNAMETYPE="4"    效果是 :  账号名称：备注
 
 3、因为青龙有随机延时（可以在配置文件设置为0，默认300秒），所以涉及准点运行的任务，最后加now，如果是desi或conc不用加也会准时跑。
 
-4、青龙系统通知（新增删除任务、登录等通知），需把通知变量写到config.sh文件，在环境变量里只发脚本运行通知哈。
+4、脚本的通知，需把通知key变量在config.sh文件配置。
 
 5、建议调整任务运行超时时间，青龙默认1小时有些跑不完就被强制结束，config.sh里配置。CommandTimeoutTime="3h"  即改为3小时，根据自己ck数量调整。
 
-6、如需禁止某些CK参加所有活动或某些活动功能，实现重组CK顺序功能，包括随机、优先、轮换、组队、分段等功能，把[task_before](./docker/task_before.sh)文件内容复制到配置管理task_before.sh保存
-
-常用变量举例：
-
-Recombin_CK_Mode="1"  全部顺序随机
-
-Recombin_CK_Mode="2" Recombin_CK_ARG1="15" 假设有100个CK，前15个CK按正常顺序靠前，其余CK随机乱序
-
-Recombin_CK_Mode="3" Recombin_CK_ARG1="5" Recombin_CK_ARG2="5"  假设有100个CK，希望前5个账号始终保持在前部，剩余95个账号按照轮换模式每天轮换5个
-
-其他用法具体参考[文档](https://docs.qq.com/doc/DTXh6QUVjRXJ1TFdN)
-</code></pre>
-</details>
+6、ck掉线，不是常用地ip，短时间内连续获得豆可能就会会触发风控掉线
 
 
 ## 通用环境变量（到配置管理-config.sh里添加变量,export xxx='xxx'格式)
 
 AUTOCFG='true' 自动配置sendNotify文件到deps目录 
 
-代理API模式部分支持
+代理API模式（API代理是通过url接得到随机可用代理ip，格式是：xxx.xxx.xxx.xxx:xxxx）
 
-DY_PROXY='URL1@URL2' 多个@分割
+DY_PROXY='URL1#URL2' 多个#分割
 
 PERMIT_API='test' 需要走API代理的js关键词，多个&分割，可不设置，支持的js都会走
 
@@ -104,20 +89,31 @@ DY_PROXY_RENUM='5'  获取IP失败重试次数
 
 DY_PROXY_REDELAY='3' 获取失败重试间隔 单位秒
 
-代理池模式支持全部js脚
+
+
+代理池模式（就是一个代理服务器的地址）
 
 DP_POOL='http://xxx' 代理池url
 
-PERMIT_JS='farm&plant&opencard' 需要走代理池的js关键词，多个&分割，必须设置
+PERMIT_JS='farm&plant&opencard' 需要走代理池的js关键词，多个&分割（可不设置，如果不设置就是所有的js都会走）
 
-禁止指定的pin执行任务：
 
-多个任务同pin：BANPIN='任务1|任务2@pin1,pin2'
 
-多个任务不同pin：BANPIN='任务1@pin,pin2&任务2@pin2,pin3'
+BANPIN 禁止某pin执行任务
 
-不指定任务只写pin  全部任务都不执行该pin：BANPIN='pin1,pin2'
+ALLOWPIN 只执行某pin执行任务
 
+多个任务同pin：任务1|任务2@pin1,pin2  
+
+多个任务不同pin：任务1@pin,pin2&任务2@pin2,pin3
+
+不指定任务只写pin：全部任务
+
+示例 
+
+export BANPIN='draw@pin1,pin2'
+
+export ALLOWPIN='draw@pin1,pin2'
 
 ## 支持的通知方式
 

docker/docker-compose.yml

@@ -1,17 +1,12 @@
 version: '2'
 services:
   ql_web:
-    image: whyour/qinglong:2.11.3
+    image: whyour/qinglong:2.17.9
     container_name: ql
     volumes:
-      - ./data/config:/ql/config
-      - ./data/log:/ql/log
-      - ./data/db:/ql/db
-      - ./data/scripts:/ql/scripts
-      - ./data/repo:/ql/repo
+      - ./qinglong/data:/ql/data
+      - ./qinglong/deps/pnpm:/root/.local/share/pnpm
+      - ./qinglong/deps/pip3:/usr/local/lib/python3.11/site-packages
     ports:
-      - "0.0.0.0:5700:5700"
-    environment:
-      - ENABLE_HANGUP=true
-      - ENABLE_WEB_PANEL=true
-    restart: always
+      - "5700:5700"
+    restart: unless-stopped

docker/ql1key.sh

@@ -46,25 +46,16 @@ cd $ql_path
 cat > docker-compose.yml <<EOF
 version: '2'
 services:
-  qinglong:
-    image: whyour/qinglong:2.11.3
-    container_name: qinglong
+  ql_web:
+    image: whyour/qinglong:2.17.9
+    container_name: ql
     volumes:
-      - ./data/config:/ql/config
-      - ./data/log:/ql/log
-      - ./data/db:/ql/db
-      - ./data/scripts:/ql/scripts
-      - ./data/repo:/ql/repo
+      - ./qinglong/data:/ql/data
+      - ./qinglong/deps/pnpm:/root/.local/share/pnpm
+      - ./qinglong/deps/pip3:/usr/local/lib/python3.11/site-packages
     ports:
-      - "0.0.0.0:5500:5700"
-    networks:
-      - net
-    environment:
-      - ENABLE_HANGUP=true
-      - ENABLE_WEB_PANEL=true
-    restart: always
-networks:
-    net:
+      - "5700:5700"
+    restart: unless-stopped
 EOF
     docker-compose up -d 
     if [ $? -ne 0 ] ; then

function/ql.js

@@ -7,10 +7,15 @@ const path = require('path');
 const fs = require('fs');
 const tokenFileList = ['/ql/data/db/keyv.sqlite', '/ql/data/config/auth.json', '/ql/config/auth.json'];
 let authFile = getLatestFile(tokenFileList);
-const api = got.extend({
-    prefixUrl: 'http://127.0.0.1:5600',
-    retry: { limit: 0 },
-});
+const HOSTS = ['http://127.0.0.1:5600','http://127.0.0.1:5700'];
+function api(options){
+  const req = got.extend({prefixUrl: HOSTS[0],retry:{limit:0},timeout:{request:5000}})(options);
+  ['json','text','buffer'].forEach(m=>{
+    const orig=req[m].bind(req);
+    req[m]=()=>orig().catch(e=>['ECONNREFUSED','ETIMEDOUT'].includes(e.code)?got.extend({prefixUrl:HOSTS[1],retry:{limit:0},timeout:{request:5000}})(options)[m]():Promise.reject(e));
+  });
+  return req;
+}
 function getLatestFile(files) {
     let latestFile = null;
     let latestMtime = 0;

jdCookie.js

@@ -42,7 +42,7 @@ if (process.env.BANPIN) {
                 //if (process.mainModule.filename.includes(i.split('^')[0])) {
                 if (i.split('@')[0].split('|').filter(x => process.argv[1].includes(x)).length != 0) {
                     let pinarr = i.split('@')[1].split(',');
-                    console.log(`已配置该任务不执行pin: ${JSON.stringify(pinarr)}`);
+                    console.log(`\n❗已配置该任务不执行pin: ${JSON.stringify(pinarr)}`);
                     for (let j of pinarr) {
                         j = decodeURIComponent(j);
                         CookieJDs = CookieJDs.filter(x => !x.includes(encodeURIComponent(j)));
@@ -53,18 +53,50 @@ if (process.env.BANPIN) {
 
         } else {
             let pinarr = banpin.split(',');
-            console.log(`已配置全局不执行pin: ${JSON.stringify(pinarr)}`);
+            console.log(`\n❗已配置全部任务不执行pin: ${JSON.stringify(pinarr)}`);
             for (let i of pinarr) {
-                //j = decodeURIComponent(j);
+                i = decodeURIComponent(i);
                 CookieJDs = CookieJDs.filter(x => !x.includes(encodeURIComponent(i)));
             }
         }
     } catch { }
 }
+if (process.env.ALLOWPIN) {
+    try {
+        const pin = process.env.ALLOWPIN;
+        const runck = [];
+        if (pin.includes('@')) {
+            const arr = pin.split('&');
+
+            for (let i of arr) {
+                //if (process.mainModule.filename.includes(i.split('^')[0])) {
+                if (i.split('@')[0].split('|').filter(x => process.argv[1].includes(x)).length != 0) {
+                    let pinarr = i.split('@')[1].split(',');
+                    console.log(`\n❗已配置该任务只执行pin: ${JSON.stringify(pinarr)}`);
+                    for (let j of pinarr) {
+                        j = decodeURIComponent(j);
+                        runck.push(...CookieJDs.filter(x => x.includes(encodeURIComponent(j))));
+                    }
+
+                }
+            }
+        } else {
+            let pinarr = pin.split(',');
+            console.log(`\n❗已配置全部任务只执行pin: ${JSON.stringify(pinarr)}`);
+            for (let i of pinarr) {
+                i = decodeURIComponent(i);
+                runck.push(...CookieJDs.filter(x => x.includes(encodeURIComponent(i))));
+            }
+        }
+        if (runck.length > 0) {
+            CookieJDs = runck
+        }
+    } catch { }
+}
 console.log(`\n====================共${CookieJDs.length}个京东账号Cookie=================`);
 console.log(`===========脚本执行时间：${formatdate(new Date(new Date().getTime() + new Date().getTimezoneOffset() * 60 * 1000 + 8 * 60 * 60 * 1000))}============`);
 console.log('>>>>>>>>>>>>6dylan6提醒您：有问题先更新不行在反馈>>>>>>>>>>>>>\n');
-console.log(`Tips：到客户服务-在线客服发'火爆'，如出滑块就拼一下会解除一些活动火爆\n`);
+console.log(`Tips：‼️青龙2.20.2以下版本不要外网访问，已被爆破可任意登录！必须要外网的就全新安装新版吧，升级不行\n`);
 
 for (let i = 0; i < CookieJDs.length; i++) {
     if (!CookieJDs[i].match(/pt_pin=(.+?);/) || !CookieJDs[i].match(/pt_key=(.+?);/)) console.log(`\n提示:京东cookie 【${CookieJDs[i]}】填写不规范,可能会影响部分脚本正常使用。正确格式为: pt_key=xxx;pt_pin=xxx;（分号;不可少）\n`);

jd_indeps.sh

@@ -1,64 +0,0 @@
-#!/usr/bin/env bash
-#依赖安装
-#0 8 5 5 * jd_indeps.sh
-#new Env('依赖安装');
-#updatedate:20240903
-#
-
-DIR="$( pwd )"
-dir_root=/ql
-dir_repo=$dir_root/repo
-dir_deps=$dir_root/deps
-
-if [[ $AUTOCFG == 'true' ]];then
-    if [[ -z "$(echo "$DIR"|grep 'main')" ]];then
-        dir_code=$dir_log/6dylan6_jdpro_jd_sharecode
-        repo='6dylan6_jdpro' 
-    else
-        dir_code=$dir_log/6dylan6_jdpro_main_jd_sharecode
-        repo='6dylan6_jdpro_main' 
-    fi
-    [[ -d $dir_root/data ]] && dir_data=$dir_root/data
-    [[ -d $dir_data/repo ]] && dir_repo=$dir_data/repo
-    [[ -d $dir_data/deps ]] && dir_deps=$dir_data/deps
-    cp $dir_repo/${repo}/sendNotify.js $dir_deps/ > /dev/null 2>&1
-    echo -e "\n已配置sendNotify.js文件到deps目录下，再次执行订阅生效\n"
-else
-    echo -e "\n如需自动配置sendNotify.js文件到desp目录下，请配置变量AUTOCFG='true'\n"
-fi
-
-npm_ver=`pnpm -v|awk -F. '{print $1}'`
-if [[ $npm_ver -ge 7 ]];then
-    export PNPM_HOME="/root/.local/share/pnpm"
-    export PATH="$PNPM_HOME:$PATH"
-fi
-
-echo -e "安装本库所需依赖，不一定一次全部安装成功，完成请检查\n"
-echo -e "开始安装............\n"
-
-#apk add g++ make pixman-dev pango-dev cairo-dev pkgconf --no-cache
-#apk add g++ make --no-cache
-pnpm config set registry https://registry.npmmirror.com
-pnpm install -g
-pnpm i -g tough-cookie
-pnpm i -g ds@2.0.2
-pnpm i -g png-js@1.0.0
-pnpm i -g date-fns@3.6.0
-pnpm i -g axios@1.7.4
-pnpm i -g crypto-js@4.2.0
-# pnpm install -g ts-md5@1.3.1
-# pnpm install -g tslib@2.6.3
-# pnpm install -g @types/node@22.4.0
-pnpm i -g request@2.88.2
-pnpm i -g jsdom@24.1.1
-pnpm i -g moment@2.30.1
-pnpm i -g cheerio@1.0.0
-pnpm i -g tunnel
-# pnpm install -g tough-cookie@4.1.4
-pnpm i -g https-proxy-agent@7.0.5
-pip3 install -i https://pypi.doubanio.com/simple/ jieba
-pip3 install -i https://pypi.doubanio.com/simple/ requests
-rm -rf /usr/local/pnpm-global/5/node_modules/.pnpm/canvas*
-rm -rf /root/.local/share/pnpm/global/5/.pnpm/canvas*
-pnpm i -g sharp@0.32.0
-echo -e "\n所需依赖安装完成，请检查有没有报错，可尝试再次运行"

jd_wsck.py

@@ -42,8 +42,29 @@ def randomuserAgent():
 
 
 def get_proxy_api(proxy_url, max_retries=5, timeout=60, retry_delay=1):
+    session = requests.Session()
     for retry in range(max_retries):
-        res = get(url=proxy_url)
+        if '@' in proxy_url:
+            # 解析认证信息
+            auth_part, url_part = proxy_url.split('@')
+            protocol = auth_part.split('://')[0]
+            auth_part = auth_part.split('://')[1]
+            host = url_part
+            
+            # 处理只有 token 的情况
+            if ':' in auth_part:
+                username, password = auth_part.split(':')
+                session.auth = (username, password)
+            else:
+                # 只有 token 的情况，需要 base64 编码
+                token = auth_part
+                token_b64 = base64.b64encode(token.encode()).decode()
+                session.headers.update({'Authorization': f'Basic {token_b64}'})
+            
+            res = session.get(f"{protocol}://{host}", verify=False, timeout=timeout)
+        else:
+            res = session.get(proxy_url, verify=False, timeout=timeout)
+            
         printf(f"本次获取到的代理：{res.text}")
         proxy_ip_port = res.text.strip()
         proxy_address = f"http://{proxy_ip_port}"
@@ -242,7 +263,7 @@ def get_sign_diy(pin):
     
 def getcookie_wskey(key):
     proxys = proxy_url
-    if os.environ.get("WSKEY_PROXY_URL") is not None:
+    if os.environ.get("DY_PROXY") is not None:
         proxys = get_proxy_api(proxy_url)
 
     body = "body=%7B%22to%22%3A%22https%3A//plogin.m.jd.com/jd-mlogin/static/html/appjmp_blank.html%22%7D"
@@ -270,7 +291,7 @@ def getcookie_wskey(key):
                 printf(f"【错误】{unquote(pin)}在获取token时：\n{error}")
                 return pin, "False"
             randomuserAgent()
-            if os.environ.get("WSKEY_PROXY_URL") is not None:
+            if os.environ.get("DY_PROXY") is not None:
                 proxys = get_proxy_api(proxy_url)
             continue
 
@@ -280,7 +301,7 @@ def getcookie_wskey(key):
             printf(f"【警告】{unquote(pin)}在获取token时失败，等待5秒后重试")
             time.sleep(5)
             randomuserAgent()
-            if os.environ.get("WSKEY_PROXY_URL") is not None:
+            if os.environ.get("DY_PROXY") is not None:
                 proxys = get_proxy_api(proxy_url)
             
     if token=="xxx":
@@ -307,7 +328,7 @@ def getcookie_wskey(key):
                 printf(f"【错误】{unquote(pin)}在获取cookie时：\n{error}")
                 return "Error"
             randomuserAgent()
-            if os.environ.get("WSKEY_PROXY_URL") is not None:
+            if os.environ.get("DY_PROXY") is not None:
                 proxys = get_proxy_api(proxy_url)
             continue
         
@@ -442,13 +463,13 @@ def main():
     printf("版本: 20230602")
     printf("说明: 如果用Wxpusher通知需配置WP_APP_TOKEN_ONE和WP_APP_MAIN_UID，其中WP_APP_MAIN_UID是你的Wxpusher UID")
     printf("隧道型代理池接口:export WSKEY_PROXY_TUNNRL='http://127.0.0.1:123456'")
-    printf("拉取型代理API接口(数据格式:txt;提取数量:每次一个):export WSKEY_PROXY_URL='http://xxx.com/apiUrl'")
+    printf("拉取型代理API接口(数据格式:txt;提取数量:每次一个):export DY_PROXY='http://xxx.com/apiUrl'")
     printf("没有代理可以自行注册，比如携趣，巨量，每日免费1000IP，完全够用")
     printf("====================================")
     config=""
     envtype=""
     global proxy_url
-    proxy_url=os.environ.get("WSKEY_PROXY_URL") or os.environ.get("WSKEY_PROXY_TUNNRL") or None
+    proxy_url=os.environ.get("DY_PROXY") or os.environ.get("WSKEY_PROXY_TUNNRL") or None
     iswxpusher=False
     counttime=0
 
@@ -479,7 +500,7 @@ def main():
         iswxpusher=False
                 
     if proxy_url is None:
-        printf("没有配置代理，无法使用代理!\n请配置环境变量WSKEY_PROXY_TUNNRL或WSKEY_PROXY_URL\n")
+        printf("没有配置代理，无法使用代理!\n请配置环境变量WSKEY_PROXY_TUNNRL或DY_PROXY\n")
         printf("====================================")
     else:
         printf(f"已配置代理: {proxy_url}\n")