1

Update sendNotify.js

.github/ISSUE_TEMPLATE/bug_report.yml

@@ -1,18 +0,0 @@
-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

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

.github/ISSUE_TEMPLATE/feature_request.yml

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

README.md

@@ -1,43 +1,59 @@
 
 ## 6dy
 
-声明: 此库所有内容仅用于个人学习！！！
+声明: 此库所有内容仅用于测试学习，测试完后请自行删除！！！
 
-### [TG CHANEL](https://t.me/dylan_jdpro)
+### [TG频道](https://t.me/dylan_jdpro)
 
 
-国内机（带加速，也不太稳）：
+## 拉库
+
+
+
+国内机（带代理）：
 
 ```
-ql repo https://js.googo.win/https://github.com/6dylan6/jdpro.git "jd_|jx_|jddj_" "backUp" "^jd[^_]|USER|JD|function|sendNotify|utils"
+ql repo https://js.jdpro.site/https://github.com/6dylan6/jdpro.git "jd_|jx_|jddj_" "backUp" "^jd[^_]|USER|JD|function|sendNotify"
+
+```
+默认代理拉不了，自行找可用代理
+
+国外机：
+
+```
+ql repo https://github.com/6dylan6/jdpro.git "jd_|jx_|jddj_" "backUp" "^jd[^_]|USER|JD|function|sendNotify"
 
 ```
 
 
-国外机（国外ip有限制可能有些任务不能正常运行）：
-
-```
-ql repo https://github.com/6dylan6/jdpro.git "jd_|jx_|jddj_" "backUp" "^jd[^_]|USER|JD|function|sendNotify|utils"
-
-```
+定时随意，不要设置为每秒或每分钟
 
 
+线报监控类脚本，[入口](https://github.com/6dylan6/jdm.git)
 
-## 使用
+带图自动评价（需PC版CK，本库也有简化版可用）[入口](https://github.com/6dylan6/auto_comment.git)
 
-1、部署青龙登陆，版本不用追新，稳定才好，推荐部署到内网（不要外网访问，2.20.2以下版本面板会被免密登录偷家，如果必须外网就用最新版本吧）。
 
-2、到订阅管理创建订阅并运行；正确配置[参考](https://github.com/6dylan6/jdpro/issues/22)
+## 简要流程
 
-3、订阅执行完，到定时任务搜索依赖安装（jd_indeps)任务执行；
+1、部署青龙并登陆。
 
-4、到环境变量，创建变量，名称: JD_COOKIE,值：抓的CK（要安全就手抓），多个每行建一个，不要全写在一个；
+2、到配置管理config.sh修改，差不多在17行（特别注意，没有修改此配置，sh类型任务拉不下来）；
+
+RepoFileExtensions="js py"修改为 RepoFileExtensions="js py sh" 保存；
+
+3、到订阅管理创建订阅并运行；正确配置[参考](https://github.com/6dylan6/jdpro/issues/22)
+
+4、订阅运行完毕，到定时任务搜索依赖安装任务执行；
+
+4、到环境变量，创建变量，名称: JD_COOKIE,值：抓的CK，多个依次创建；
+
+5，配置通知，通知的key填写到配置管理config.sh文件；
 
-5、配置通知，通知的key填写到配置管理config.sh文件；
 
 
 <details>
-<summary>笔记</summary>
+<summary>进阶</summary>
 <pre><code>
 
 1、任务并发和分组
@@ -68,52 +84,38 @@ export NOTIFY_SHOWNAMETYPE="4"    效果是 :  账号名称：备注
 
 3、因为青龙有随机延时（可以在配置文件设置为0，默认300秒），所以涉及准点运行的任务，最后加now，如果是desi或conc不用加也会准时跑。
 
-4、脚本的通知，需把通知key变量在config.sh文件配置。
+4、青龙系统通知（新增删除任务、登录等通知），需把通知变量写到config.sh文件，在环境变量里只发脚本运行通知哈。
 
-5、建议调整任务运行超时时间，青龙默认1小时有些跑不完就被强制结束，config.sh里配置。CommandTimeoutTime="3h"  即改为3小时，根据自己ck数量调整。
+5、如果通知文件发现和库里的不一致，那是被青龙自带的覆盖了，手动拷贝一份到deps目录下。
 
-6、ck掉线，不是常用地ip，短时间内连续获得豆可能就会会触发风控掉线
-
-
-## 通用环境变量（到配置管理-config.sh里添加变量,export xxx='xxx'格式)
-
-AUTOCFG='true' 自动配置sendNotify文件到deps目录 
-
-代理API模式（API代理是通过url接得到随机可用代理ip，格式是：xxx.xxx.xxx.xxx:xxxx）
-
-DY_PROXY='URL1#URL2' 多个#分割
-
-PERMIT_API='test' 需要走API代理的js关键词，多个&分割，可不设置，支持的js都会走
-
-DY_PROXY_RENUM='5'  获取IP失败重试次数
-
-DY_PROXY_REDELAY='3' 获取失败重试间隔 单位秒
+6、建议调整任务运行超时时间，青龙默认1小时有些跑不完就被强制结束，config.sh里配置。CommandTimeoutTime="3h"  即改为3小时，根据自己ck数量调整。
+</code></pre>
+</details>
 
 
 
-代理池模式（就是一个代理服务器的地址）
+如需禁止某些CK参加所有活动或某些活动功能，实现重组CK顺序功能，包括随机、优先、轮换、组队、分段等功能，把[task_before](./docker/task_before.sh)文件内容复制到配置管理task_before.sh保存
 
-DP_POOL='http://xxx' 代理池url
+常用变量举例：
 
-PERMIT_JS='farm&plant&opencard' 需要走代理池的js关键词，多个&分割（可不设置，如果不设置就是所有的js都会走）
+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个
 
-BANPIN 禁止某pin执行任务
+其他用法具体参考[文档](https://docs.qq.com/doc/DTXh6QUVjRXJ1TFdN)
 
-ALLOWPIN 只执行某pin执行任务
+## 通用变量
 
-多个任务同pin：任务1|任务2@pin1,pin2  
+自定义sign  export SIGN_URL='url'
 
-多个任务不同pin：任务1@pin,pin2&任务2@pin2,pin3
+代理API export DY_PROXY='url'（部分js支持，看日志说明）
 
-不指定任务只写pin：全部任务
+代理池 export DP_POOL='url'（全部js支持）
 
-示例 
+使用代理池白名单（js文件名关键字如fruit），如fruit export PERMIT_JS='fruit'
 
-export BANPIN='draw@pin1,pin2'
-
-export ALLOWPIN='draw@pin1,pin2'
 
 ## 支持的通知方式
 

docker/docker-compose.yml

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

docker/ql1key.sh

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

docker/task_before.sh

@@ -1,13 +1,13 @@
 #!/usr/bin/env bash
 
 ## Build 20220831-001-test
-## 6dylan6_20240905
+## 6dylan6_1029
 
 name_js=(
   jd_farm_help
-  jd_farmnew_code_help
+  jd_farm_help_new
   #jd_pet
-  jd_plantBean_help
+  #jd_plantBean
   #jd_dreamFactory
   #jd_jdfactory
   #jd_crazy_joy
@@ -18,7 +18,6 @@ name_js=(
   #jd_sgmh
   #jd_cfd
   jd_health
-  jd_farmshare
   #jd_carnivalcity
   #jd_city
   #jd_moneyTree
@@ -28,7 +27,7 @@ name_config=(
   Fruit
   Fruit_new
   #Pet
-  Bean
+  #Bean
   #DreamFactory
   #JdFactory
   #Joy
@@ -39,7 +38,6 @@ name_config=(
   #Sgmh
   #Cfd
   Health
-  Fruit_new
   #Carni
   #City
   #MoneyTree
@@ -49,7 +47,7 @@ name_chinese=(
   东东农场
   新农场助力
   #东东萌宠
-  种豆得豆助力
+  #京东种豆得豆
   #京喜工厂
   #东东工厂
   #crazyJoy任务
@@ -60,7 +58,6 @@ name_chinese=(
   #闪购盲盒
   #京喜财富岛
   东东健康社区
-  农场小程序助力
   #京东手机狂欢城
   #城城领现金
   #摇钱树
@@ -70,7 +67,7 @@ env_name=(
   FRUITSHARECODES                     ## 1、东东农场互助码
   NEWFRUITSHARECODES                  ## 1、新东东农场互助码  
   #PETSHARECODES                       ## 2、东东萌宠互助码
-  PLANT_BEAN_SHARECODES               ## 3、种豆得豆互助码
+  #PLANT_BEAN_SHARECODES               ## 3、种豆得豆互助码
   #DREAM_FACTORY_SHARE_CODES           ## 4、京喜工厂互助码
   #DDFACTORY_SHARECODES                ## 5、东东工厂互助码
   #JDJOY_SHARECODES                    ## 6、疯狂的JOY互助码
@@ -81,7 +78,6 @@ env_name=(
   #JDSGMH_SHARECODES                   ## 11、闪购盲盒互助码
   #JDCFD_SHARECODES                    ## 12、京喜财富岛互助码
   JDHEALTH_SHARECODES                 ## 13、东东健康社区互助码
-  NEWFRUITSHARECODES                  ## 14、新农场小程序 
   #JD818_SHARECODES                    ## 14、京东手机狂欢城互助码
   #CITY_SHARECODES                     ## 15、城城领现金互助码
   #MONEYTREE_SHARECODES                ## 16、摇钱树
@@ -91,7 +87,7 @@ var_name=(
   ForOtherFruit                       ## 1、东东农场互助规则
   ForOtherFruit_new                       ## 1、东东农场互助规则  
   #ForOtherPet                         ## 2、东东萌宠互助规则
-  ForOtherBean                        ## 3、种豆得豆互助规则
+  #ForOtherBean                        ## 3、种豆得豆互助规则
   #ForOtherDreamFactory                ## 4、京喜工厂互助规则
   #ForOtherJdFactory                   ## 5、东东工厂互助规则
   #ForOtherJoy                         ## 6、疯狂的JOY互助规则
@@ -102,7 +98,6 @@ var_name=(
   #ForOtherSgmh                        ## 11、闪购盲盒互助规则
   #ForOtherCfd                         ## 12、京喜财富岛互助规则
   ForOtherHealth                      ## 13、东东健康社区互助规则
-  ForOtherFruit_new                       ## 新农场小程序
   #ForOtherCarni                       ## 14、京东手机狂欢城互助规则
   #ForOtherCity                        ## 15、城城领现金互助规则
   #ForOtherMoneyTree                   ## 16、摇钱树

function/getH5st3_0.js

@@ -1 +0,0 @@
-var iｉl='jsjiami.com.v7';const lIIl11l1=IIii1IlI;(function(IiilIlil,llIi1iii,lIIiiIil,ll1IiiII,illIli1l,l1liIliI,iI1li1I){return IiilIlil=IiilIlil>>0x8,l1liIliI='hs',iI1li1I='hs',function(lliii1I,liIIillI,lIl1i1li,iI1i1iIl,I1IIIlll){const i1lIll1i=IIii1IlI;iI1i1iIl='tfi',l1liIliI=iI1i1iIl+l1liIliI,I1IIIlll='up',iI1li1I+=I1IIIlll,l1liIliI=lIl1i1li(l1liIliI),iI1li1I=lIl1i1li(iI1li1I),lIl1i1li=0x0;const ii1iII1l=lliii1I();while(!![]&&--ll1IiiII+liIIillI){try{iI1i1iIl=parseInt(i1lIll1i(0xb2,'5C4['))/0x1+parseInt(i1lIll1i(0xb4,'UgCK'))/0x2+-parseInt(i1lIll1i(0xa0,'Mtzj'))/0x3*(parseInt(i1lIll1i(0xa6,'Kx83'))/0x4)+parseInt(i1lIll1i(0xb0,'MU[H'))/0x5*(parseInt(i1lIll1i(0xae,'rJx$'))/0x6)+parseInt(i1lIll1i(0xa1,'A#cN'))/0x7*(parseInt(i1lIll1i(0xac,'Elur'))/0x8)+parseInt(i1lIll1i(0xad,'Ud90'))/0x9+-parseInt(i1lIll1i(0xa9,')SXP'))/0xa;}catch(II1liIl1){iI1i1iIl=lIl1i1li;}finally{I1IIIlll=ii1iII1l[l1liIliI]();if(IiilIlil<=ll1IiiII)lIl1i1li?illIli1l?iI1i1iIl=I1IIIlll:illIli1l=I1IIIlll:lIl1i1li=I1IIIlll;else{if(lIl1i1li==illIli1l['replace'](/[UKJAISyMDurRdTQqCEWV=]/g,'')){if(iI1i1iIl===liIIillI){ii1iII1l['un'+l1liIliI](I1IIIlll);break;}ii1iII1l[iI1li1I](I1IIIlll);}}}}}(lIIiiIil,llIi1iii,function(IiIli1lI,ilII1l,IIIIil1,IIIi111i,l1III1Il,l1iiIII,IiiliIl){return ilII1l='\x73\x70\x6c\x69\x74',IiIli1lI=arguments[0x0],IiIli1lI=IiIli1lI[ilII1l](''),IIIIil1=`\x72\x65\x76\x65\x72\x73\x65`,IiIli1lI=IiIli1lI[IIIIil1]('\x76'),IIIi111i=`\x6a\x6f\x69\x6e`,(0x15b906,IiIli1lI[IIIi111i](''));});}(0xbe00,0x4f0f2,iIIIlil1,0xc0),iIIIlil1)&&(iｉl=0x230e);function IIii1IlI(_0x1ec280,_0x300e6e){const _0x5c54c9=iIIIlil1();return IIii1IlI=function(_0x725f54,_0x41e333){_0x725f54=_0x725f54-0x9c;let _0x1fc311=_0x5c54c9[_0x725f54];if(IIii1IlI['YUFSvd']===undefined){var _0x5a0984=function(_0x50c1b0){const _0x19ff44='abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789+/=';let _0x2f2a33='',_0x3542ef='';for(let _0x12300f=0x0,_0x51fe7d,_0x5b7af0,_0x4ee540=0x0;_0x5b7af0=_0x50c1b0['charAt'](_0x4ee540++);~_0x5b7af0&&(_0x51fe7d=_0x12300f%0x4?_0x51fe7d*0x40+_0x5b7af0:_0x5b7af0,_0x12300f++%0x4)?_0x2f2a33+=String['fromCharCode'](0xff&_0x51fe7d>>(-0x2*_0x12300f&0x6)):0x0){_0x5b7af0=_0x19ff44['indexOf'](_0x5b7af0);}for(let _0x15def8=0x0,_0x7998fd=_0x2f2a33['length'];_0x15def8<_0x7998fd;_0x15def8++){_0x3542ef+='%'+('00'+_0x2f2a33['charCodeAt'](_0x15def8)['toString'](0x10))['slice'](-0x2);}return decodeURIComponent(_0x3542ef);};const _0x2907f7=function(_0xda0c54,_0x28f503){let _0x14a5ba=[],_0x17b980=0x0,_0x43a8c6,_0x4d4762='';_0xda0c54=_0x5a0984(_0xda0c54);let _0x23c696;for(_0x23c696=0x0;_0x23c696<0x100;_0x23c696++){_0x14a5ba[_0x23c696]=_0x23c696;}for(_0x23c696=0x0;_0x23c696<0x100;_0x23c696++){_0x17b980=(_0x17b980+_0x14a5ba[_0x23c696]+_0x28f503['charCodeAt'](_0x23c696%_0x28f503['length']))%0x100,_0x43a8c6=_0x14a5ba[_0x23c696],_0x14a5ba[_0x23c696]=_0x14a5ba[_0x17b980],_0x14a5ba[_0x17b980]=_0x43a8c6;}_0x23c696=0x0,_0x17b980=0x0;for(let _0x3711a3=0x0;_0x3711a3<_0xda0c54['length'];_0x3711a3++){_0x23c696=(_0x23c696+0x1)%0x100,_0x17b980=(_0x17b980+_0x14a5ba[_0x23c696])%0x100,_0x43a8c6=_0x14a5ba[_0x23c696],_0x14a5ba[_0x23c696]=_0x14a5ba[_0x17b980],_0x14a5ba[_0x17b980]=_0x43a8c6,_0x4d4762+=String['fromCharCode'](_0xda0c54['charCodeAt'](_0x3711a3)^_0x14a5ba[(_0x14a5ba[_0x23c696]+_0x14a5ba[_0x17b980])%0x100]);}return _0x4d4762;};IIii1IlI['vnCAfj']=_0x2907f7,_0x1ec280=arguments,IIii1IlI['YUFSvd']=!![];}const _0x3baa53=_0x5c54c9[0x0],_0x17bc77=_0x725f54+_0x3baa53,_0x490163=_0x1ec280[_0x17bc77];return!_0x490163?(IIii1IlI['bnDExB']===undefined&&(IIii1IlI['bnDExB']=!![]),_0x1fc311=IIii1IlI['vnCAfj'](_0x1fc311,_0x41e333),_0x1ec280[_0x17bc77]=_0x1fc311):_0x1fc311=_0x490163,_0x1fc311;},IIii1IlI(_0x1ec280,_0x300e6e);}function iIIIlil1(){const iIilli11=(function(){return[...[iｉl,'RUKjrsjViDaCdmSiAd.qcQMouCumIqD.TvJ7WJEy==','FmopWRZcKSkxsde','WPi9qve8jCoazLxdPq','WPNdN8kjW4lcJ8kHW4etWQhcN8kfcGy','WPhcQaNcJ1RcQGe','rxldIG','WPNdMmkmW4tcISkLWPajWQNcP8kxaG','gq7cNtFdTSk8WRS+WQekmmoYW7u','qq0+W6W'],...(function(){return[...['WPNdNmkjW4FcISolWOWjWPpcS8kO','mG7cLXOGeqm','W58ZWPXVo8oonv8gW7f7W7RcOG','WQeTW6hdOSozWPxdJ39UWPdcLa','eSk7W4hcMbVcGaG','AmkkW7GowSozWR0yW5a','xez/W4yhnG','W75GWPpdM2ZcS8oGmNxdMMX2','xafwbeRcUJ1RWRxdO8oBWOlcKa','W7m9W77dHSo3zZZcQmk8pXPW'],...(function(){return['dam8WP1sBxT9pSkbfmk8wG','WP3cS8kuwCkmpCkx','FSk/W7ddSSkhWRdcMG','W43dJCorW5dcNCohW4D1na','WPBdTNBcICowBCkvWRxcUfm2xq','bWVdRZZcQh9PFtaYnmkctW','oSkmvMBcRCktWQP9fxCudW'];}())];}())];}());iIIIlil1=function(){return iIilli11;};return iIIIlil1();};const {H5st}=require(lIIl11l1(0xa4,'wwG^'));async function getH5st(iIiIl1i1,iIIIi111,Il1l1ili=lIIl11l1(0xa7,'J*Zq')){const iIIi1i11=lIIl11l1,l11lilI=Object[iIIi1i11(0xb1,'edxX')]({'appId':iIiIl1i1,'version':Il1l1ili},iIIIi111),l1lllil1=await H5st[iIIi1i11(0x9e,'Nkmp')](l11lilI);return l1lllil1?.[iIIi1i11(0xaa,'FHZ3')];}module[lIIl11l1(0xaf,'8byO')]=getH5st;var version_ = 'jsjiami.com.v7';

function/h5st.ts

@@ -0,0 +1,72 @@
+import axios from "axios"
+import {format} from "date-fns"
+import * as CryptoJS from 'crypto-js'
+
+class H5ST {
+  tk: string;
+  timestamp: string;
+  rd: string;
+  appId: string;
+  fp: string;
+  time: number;
+  ua: string
+  enc: string;
+
+  constructor(appId: string, ua: string, fp: string) {
+    this.appId = appId
+    this.ua = ua
+    this.fp = fp || this.__genFp()
+  }
+
+  __genFp() {
+    let e = "0123456789";
+    let a = 13;
+    let i = '';
+    for (; a--;)
+      i += e[Math.random() * e.length | 0];
+    return (i + Date.now()).slice(0, 16)
+  }
+
+  async __genAlgo() {
+    this.time = Date.now()
+    this.timestamp = format(this.time, "yyyyMMddHHmmssSSS")
+    let {data} = await axios.post(`https://cactus.jd.com/request_algo?g_ty=ajax`, {
+      'version': '3.0',
+      'fp': this.fp,
+      'appId': this.appId.toString(),
+      'timestamp': this.time,
+      'platform': 'web',
+      'expandParams': ''
+    }, {
+      headers: {
+        'Host': 'cactus.jd.com',
+        'accept': 'application/json',
+        'content-type': 'application/json',
+        'user-agent': this.ua,
+      }
+    })
+    this.tk = data.data.result.tk
+    this.rd = data.data.result.algo.match(/rd='(.*)'/)[1]
+    this.enc = data.data.result.algo.match(/algo\.(.*)\(/)[1]
+  }
+
+  __genKey(tk: string, fp: string, ts: string, ai: string, algo: object) {
+    let str = `${tk}${fp}${ts}${ai}${this.rd}`;
+    return algo[this.enc](str, tk)
+  }
+
+  __genH5st(body: object) {
+    let y = this.__genKey(this.tk, this.fp, this.timestamp, this.appId, CryptoJS).toString(CryptoJS.enc.Hex)
+    let s = ''
+    for (let key of Object.keys(body)) {
+      key === 'body' ? s += `${key}:${CryptoJS.SHA256(body[key]).toString(CryptoJS.enc.Hex)}&` : s += `${key}:${body[key]}&`
+    }
+    s = s.slice(0, -1)
+    s = CryptoJS.HmacSHA256(s, y).toString(CryptoJS.enc.Hex)
+    return encodeURIComponent(`${this.timestamp};${this.fp};${this.appId.toString()};${this.tk};${s};3.0;${this.time.toString()}`)
+  }
+}
+
+export {
+  H5ST
+}

function/ql.js

@@ -4,40 +4,27 @@ const got = require('got');
 require('dotenv').config();
 const { readFile } = require('fs/promises');
 const path = require('path');
+
+const qlDir = '/ql';
 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 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;
-    for (const file of files) {
-        try {
-            const stats = fs.statSync(file);
-            const mtime = stats.mtimeMs;
-            if (mtime > latestMtime) {
-                latestMtime = mtime;
-                latestFile = file;
-            }
-        } catch (e) {
-        }
-    }
-    return latestFile;
-}
+let Fileexists = fs.existsSync('/ql/data/config/auth.json');
+let authFile="";
+if (Fileexists) 
+	authFile="/ql/data/config/auth.json"
+else
+	authFile="/ql/config/auth.json"
+//const authFile = path.join(qlDir, 'config/auth.json');
+
+const api = got.extend({
+  prefixUrl: 'http://127.0.0.1:5600',
+  retry: { limit: 0 },
+});
+
 async function getToken() {
-    const authConfig = await readFile(authFile);
-    // console.log(authConfig.toString().match(/"token":"(.*?)",/)[1])
-    return authConfig.toString().match(/"token":"([^"]*)"(?!.*"token":)/)[1];
+  const authConfig = JSON.parse(await readFile(authFile));
+  return authConfig.token;
 }
-// getToken()
+
 module.exports.getEnvs = async () => {  
   const token = await getToken();
   const body = await api({
@@ -153,7 +140,7 @@ module.exports.EnableCk = async (eid) => {
   return body;
 };
 
-module.exports.getstatus = async (eid) => {
+module.exports.getstatus = async(eid) => {
     const envs = await this.getEnvs();
     var tempid = 0;
     for (let i = 0; i < envs.length; i++) {
@@ -171,7 +158,7 @@ module.exports.getstatus = async (eid) => {
     return 99;
 };
 
-module.exports.getEnvById = async (eid) => {
+module.exports.getEnvById = async(eid) => {
     const envs = await this.getEnvs();
     var tempid = 0;
     for (let i = 0; i < envs.length; i++) {
@@ -193,7 +180,7 @@ module.exports.getEnvByPtPin = async (Ptpin) => {
   const envs = await this.getEnvs();
   for (let i = 0; i < envs.length; i++) {	
 	var tempptpin = decodeURIComponent(envs[i].value.match(/pt_pin=([^; ]+)(?=;?)/) && envs[i].value.match(/pt_pin=([^; ]+)(?=;?)/)[1]);
-        if (tempptpin == Ptpin) {
+	if(tempptpin==Ptpin){		 
 		 return envs[i]; 
 	  }
   }  

jdCookie.js

@@ -17,13 +17,13 @@ if (process.env.JD_COOKIE) {
     CookieJDs = [process.env.JD_COOKIE];
   }
 }
-//if (JSON.stringify(process.env).indexOf('GITHUB') > -1) {
-//    console.log(`请勿使用github action运行此脚本,无论你是从你自己的私库还是其他哪里拉取的源代码，都会导致我被封号\n`);
-//    !(async () => {
-//        await require('./sendNotify').sendNotify('提醒', `请勿使用github action、滥用github资源会封我仓库以及账号`)
-//        await process.exit(0);
-//    })()
-//}
+if (JSON.stringify(process.env).indexOf('GITHUB') > -1) {
+  console.log(`请勿使用github action运行此脚本,无论你是从你自己的私库还是其他哪里拉取的源代码，都会导致我被封号\n`);
+  !(async () => {
+    await require('./sendNotify').sendNotify('提醒', `请勿使用github action、滥用github资源会封我仓库以及账号`)
+    await process.exit(0);
+  })()
+}
 //!(async () => {
 //	IP = await getIP();
 //    try {
@@ -33,71 +33,9 @@ if (process.env.JD_COOKIE) {
 //})()
 CookieJDs = [...new Set(CookieJDs.filter(item => !!item))]
 if (process.env.JD_DEBUG && process.env.JD_DEBUG === 'false') console.log = () => { };
-if (process.env.BANPIN) {
-    try {
-        let banpin = process.env.BANPIN;
-        if (banpin.includes('@')) {
-            const arr = banpin.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);
-                        CookieJDs = CookieJDs.filter(x => !x.includes(encodeURIComponent(j)));
-                    }
-
-                }
-            }
-
-        } else {
-            let pinarr = banpin.split(',');
-            console.log(`\n❗已配置全部任务不执行pin: ${JSON.stringify(pinarr)}`);
-            for (let i of pinarr) {
-                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：‼️青龙2.20.2以下版本不要外网访问，已被爆破可任意登录！必须要外网的就全新安装新版吧，升级不行\n`);
-
+console.log('>>>>>>>>>>>>6Dy提醒您：有问题先更新不行在反馈>>>>>>>>>>>>>\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`);
   CookieJDs[i] = CookieJDs[i].replace(/[\u4e00-\u9fa5]/g, (str) => encodeURI(str));
@@ -111,7 +49,6 @@ if (process.env.DP_POOL) {
     try {
       require("global-agent/bootstrap");
       global.GLOBAL_AGENT.HTTP_PROXY = process.env.DP_POOL;
-            global.GLOBAL_AGENT.NO_PROXY = process.env.NO_PROXY || '127.0.0.1,localhost';
       console.log(`\n---------------使用代理池模式---------------\n`);
     } catch {
       throw new Error(`请安装global-agent依赖，才能启用代理！`);

jd_bean_info.js

@@ -114,10 +114,7 @@ async function bean() {
           }
         }
       } else {
-        // 完全无数据时才抛出异常，否则返回之前统计出来的数据
-        if (!todayArr.length && !yesterdayArr.length) {
         $.errorMsg = `数据异常`;
-        }
         // $.msg($.name, ``, `账号${$.index}：${$.nickName}\n${$.errorMsg}`);
         t = 1;
       }

jd_beans_7days.py

@@ -1,19 +1,18 @@
 # !/usr/bin/env python3
 # -*- coding: utf-8 -*-
-# Modify : 2024/4/21
+# Modify : 2022/9/30
 # 京豆近7天输出表格统计
 # 用不着每天跑,定时自行设置吧，配合desi可指定账号
 # https://raw.githubusercontent.com/6dylan6/jdpro/main/jd_beans_7days.py
 '''
 new Env('豆子7天统计');
-8 8 29 2 * jd_beans_7days.py
+8 8 30 9 * jd_beans_7days.py
 '''
 
 import requests
 import datetime
-import random
 import os,re,sys,json,time
-from urllib.parse import unquote,quote
+from urllib.parse import unquote
 from datetime import timedelta
 from datetime import timezone
 
@@ -32,23 +31,7 @@ session = requests.session()
 session.keep_alive = False
 
 url = "https://api.m.jd.com/api"
-def getua():
-    global uuid,addressid,iosVer,iosV,clientVersion,iPhone,area,ADID,lng,lat
-    uuid=''.join(random.sample(['a','b','c','d','e','f','g','h','i','j','k','l','m','n','o','p','q','r','s','t','u','v','w','x','y','z','0','1','2','3','4','5','6','7','8','9','a','b','c','z'], 40))
-    addressid = ''.join(random.sample('1234567898647', 10))
-    iosVer = ''.join(random.sample(["15.1.1","14.5.1", "14.4", "14.3", "14.2", "14.1", "14.0.1"], 1))
-    iosV = iosVer.replace('.', '_')
-    clientVersion=''.join(random.sample(["10.3.0", "10.2.7", "10.2.4"], 1))
-    iPhone = ''.join(random.sample(["8", "9", "10", "11", "12", "13"], 1))
-    area=''.join(random.sample('0123456789', 2)) + '_' + ''.join(random.sample('0123456789', 4)) + '_' + ''.join(random.sample('0123456789', 5)) + '_' + ''.join(random.sample('0123456789', 4))
-    ADID = ''.join(random.sample('0987654321ABCDEF', 8)) + '-' + ''.join(random.sample('0987654321ABCDEF', 4)) + '-' + ''.join(random.sample('0987654321ABCDEF', 4)) + '-' + ''.join(random.sample('0987654321ABCDEF', 4)) + '-' + ''.join(random.sample('0987654321ABCDEF', 12))
-    lng='119.31991256596'+str(random.randint(100,999))
-    lat='26.1187118976'+str(random.randint(100,999))
-    UserAgent=''
-    if not UserAgent:
-        return f'jdapp;iPhone;10.0.4;{iosVer};{uuid};network/wifi;ADID/{ADID};model/iPhone{iPhone},1;addressid/{addressid};appBuild/167707;jdSupportDarkMode/0;Mozilla/5.0 (iPhone; CPU iPhone OS {iosV} like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/null;supportJDSHWK/1'
-    else:
-        return UserAgent
+
 def gen_body(page):
     body = {
         "beginDate": datetime.datetime.utcnow().replace(tzinfo=timezone.utc).astimezone(SHA_TZ).strftime("%Y-%m-%d %H:%M:%S"),
@@ -187,8 +170,8 @@ def get_beans_7days(ck):
         day_7 = True
         page = 0
         headers = {
-            "Host": "bean.m.jd.com",
-            "User-Agent": getua(),
+            "Host": "api.m.jd.com",
+            "User-Agent": "Mozilla/5.0 (Linux; Android 10; MI 9 Build/QKQ1.190825.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/78.0.3904.62 XWEB/2797 MMWEBSDK/201201 Mobile Safari/537.36 MMWEBID/7986 MicroMessenger/8.0.1840(0x2800003B) Process/appbrand4 WeChat/arm64 Weixin NetType/4G Language/zh_CN ABI/arm64 MiniProgramEnv/android",
             "Content-Type": "application/x-www-form-urlencoded;",
             "Cookie": ck,
         }
@@ -199,13 +182,11 @@ def get_beans_7days(ck):
         beans_out = {key: 0 for key in days}
         while day_7:
             page = page + 1
-            url="https://bean.m.jd.com/beanDetail/detail.json?page="+str(page)
-            data='body='+quote(str({"pageSize":"20","page":str(page)}))+'&appid=ld'
-            resp = session.post(url, headers=headers, data=data ,timeout=1000).text
-
+            url="https://api.m.jd.com/client.action?functionId=getJingBeanBalanceDetail&body=%7B%22pageSize%22%3A%2220%22%2C%22page%22%3A%22"+str(page)+"%22%7D&appid=ld"
+            resp = session.get(url, headers=headers, timeout=1000).text
             res = json.loads(resp)
             if res['code'] == '0' :
-                for i in res['jingDetailList']:
+                for i in res['detailList']:
                     for date in days:
                         if str(date) in i['date'] and int(i['amount']) > 0:
                             beans_in[str(date)] = beans_in[str(date)] + int(i['amount'])
@@ -218,7 +199,6 @@ def get_beans_7days(ck):
             else:
                 print("未获取到数据，原因未知！！\n")
                 return {'code': 400, 'data': res}
-            #print(beans_in, beans_out, days)
         return {'code': 200, 'data': [beans_in, beans_out, days]}
     except Exception as e:
         print(str(e))
@@ -228,17 +208,16 @@ def get_beans_7days(ck):
 def get_total_beans(ck):
     try:
         headers = {
-            "Host": "me-api.jd.com",
-            "User-Agent": getua(),
+            "Host": "wq.jd.com",
+            "User-Agent": "jdapp;iPhone;9.4.4;14.3;network/4g;Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
             "Content-Type": "application/x-www-form-urlencoded;",
             "Cookie": ck,
-            #"Referer": 'https://wqs.jd.com/my/jingdou/my.shtml?sceneval=2'
+            "Referer": 'https://wqs.jd.com/my/jingdou/my.shtml?sceneval=2'
         }
-        jurl = "https://me-api.jd.com/user_new/info/GetJDUserInfoUnion"
-        resp = requests.get(jurl, headers=headers).text
+        jurl = "https://wq.jd.com/user/info/QueryJDUserInfo?sceneval=2"
+        resp = requests.post(jurl, headers=headers).text
         res = json.loads(resp)
-        #print(res)
-        return res['data']['assetInfo']['beanNum']
+        return res['base']['jdNum']
     except Exception as e:
         printf(str(e))
 

jd_indeps.sh

@@ -0,0 +1,38 @@
+#!/usr/bin/env bash
+#依赖安装，运行一次就好
+#0 8 5 5 * jd_indeps.sh
+#new Env('依赖安装');
+#
+
+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.npm.taobao.org
+pnpm install -g
+pnpm install -g ds
+pnpm install -g png-js
+pnpm install -g date-fns
+pnpm install -g axios@0.27.2
+pnpm install -g crypto-js
+pnpm install -g ts-md5
+pnpm install -g tslib
+pnpm install -g @types/node
+pnpm install -g request
+pnpm install -g jsdom
+pnpm install -g moment
+pnpm install -g cheerio
+pnpm install -g tough-cookie
+pnpm install -g https-proxy-agent
+pip3 install -i https://pypi.tuna.tsinghua.edu.cn/simple/ jieba
+pip3 install -i https://pypi.tuna.tsinghua.edu.cn/simple/ requests
+rm -rf /usr/local/pnpm-global/5/node_modules/.pnpm/canvas*
+rm -rf /root/.local/share/pnpm/global/5/.pnpm/canvas*
+echo -e "\n所需依赖安装完成，请检查有没有报错，可尝试再次运行"

jd_kuaid.js

@@ -0,0 +1,178 @@
+/*
+京东快递
+@Leaf
+
+*/
+const $ = new Env('京东快递');
+const got = require('got');
+
+const envSplitor = ['&','\n','@']
+const ckNames = ['JD_COOKIE']
+
+const MAX_THREAD = parseInt(process.env['jd_jdkd_thread']) || 5
+const DEFAULT_TIMEOUT=8000, DEFAULT_RETRY=3;
+
+const default_UA = 'Mozilla/5.0 (iPhone; CPU iPhone OS 15_0 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 MicroMessenger/8.0.31(0x18001f2f) NetType/WIFI Language/zh_CN miniProgram/wx73247c7819d61796'
+const Referer = 'https://jingcai-h5.jd.com/'
+const Origin = 'https://jingcai-h5.jd.com'
+
+const client = got.extend({
+    headers:{
+        Connection:'keep-alive',
+        'User-Agent': default_UA,
+        Referer,
+        Origin,
+        AppParams: JSON.stringify({"appid":158,"ticket_type":"m"}),
+        ClientInfo: JSON.stringify({"appName":"jingcai","client":"m"}),
+        'LOP-DN': 'jingcai.jd.com',
+        'X-Requested-With': 'XMLHttpRequest',
+    },
+    retry: {limit:0},
+    timeout: DEFAULT_TIMEOUT,
+    followRedirect: false,
+})
+
+class BasicClass{constructor(){this.index=$.userIdx++;this.name='';} log(msg,opt={}){var m='',n=$.userCount.toString().length;;if(this.index)m+=`账号[${$.padStr(this.index,n)}]`;if(this.name)m+=`[${this.name}]`;$.log(m+msg,opt);} async request(opt){var resp=null,count=0;var fn=opt.fn||opt.url;opt.method=opt?.method?.toUpperCase()||'GET';while(count++<DEFAULT_RETRY){try{await client(opt).then(t=>{resp=t},e=>{resp=e.response});if(((resp?.statusCode/100)|0)<=4)break;}catch(e){if(e.name=='TimeoutError'){this.log(`[${fn}]请求超时，重试第${count}次`);}else{this.log(`[${fn}]请求错误(${e.message})，重试第${count}次`);}};} if(resp==null)return Promise.resolve({statusCode:-1,headers:null,result:null});let{statusCode,headers,body}=resp;if(body)try{body=JSON.parse(body);}catch{};return Promise.resolve({statusCode,headers,result:body})}}
+let http = new BasicClass();
+
+class UserClass extends BasicClass {
+    constructor(ck) {
+        super()
+        this.cookie = ck
+        this.pt_pin = ck.match(/pin=([\w\-\%]+)/) ? ck.match(/pin=([\w\-\%]+)/)[1] : ''
+        this.name = decodeURIComponent(this.pt_pin)
+    }
+    
+    async queryTaskList() {
+        try {
+            let options = {
+                fn: 'queryTaskList',
+                method: 'post',
+                url: 'https://lop-proxy.jd.com/ESGApi/queryTaskList',
+                headers: {Cookie:this.cookie,'event-id':$.randomPattern('xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxxx')},
+                json: [{"pin":"$cooMrdGatewayUid$"}],
+            }
+            let {result} = await this.request(options)
+            let code = result?.code
+            if(code == 1) {
+                for(let task of (result?.content?.taskInfoList||[]).filter(x => x.taskReachNum < x.taskNeedReachNum && x.triggerType==1)) {
+                    await this.reachTaskInfo(task);
+					await $.wait(1000);
+                    break;
+                }
+            } else {
+                let errCode = code || result?.error_response?.code
+                let errMsg = result?.msg || result?.error_response?.zh_desc
+                this.log(`查询任务列表出错[${errCode}]: ${errMsg}`)
+            }
+        } catch (e) {
+            $.log(e)
+        } finally {
+            return Promise.resolve()
+        }
+    }
+    
+    async reachTaskInfo(task) {
+        try {
+            let options = {
+                fn: 'reachTaskInfo',
+                method: 'post',
+                url: 'https://lop-proxy.jd.com/ESGApi/reachTaskInfo',
+                headers: {Cookie:this.cookie,'event-id':$.randomPattern('xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxxx')},
+                json: [{
+                    taskNo: task.taskNo,
+                    childTaskId: task.childTaskId,
+                    pin: "$cooMrdGatewayUid$",
+                }],
+            }
+            let {result} = await this.request(options)
+            let code = result?.code
+            if(code == 1) {
+                this.log(`完成任务[${task.taskTitle}]成功`);
+				await $.wait(1000);
+                await this.queryTaskList();
+            } else {
+                let errCode = code || result?.error_response?.code
+                let errMsg = result?.msg || result?.error_response?.zh_desc
+                this.log(`完成任务[${task.taskTitle}]失败[${errCode}]: ${errMsg}`)
+            }
+        } catch (e) {
+            $.log(e)
+        } finally {
+            return Promise.resolve()
+        }
+    }
+    
+    async queryCanGetRewardTaskList() {
+        try {
+            let options = {
+                fn: 'queryCanGetRewardTaskList',
+                method: 'post',
+                url: 'https://lop-proxy.jd.com/ESGApi/queryCanGetRewardTaskList',
+                headers: {Cookie:this.cookie,'event-id':$.randomPattern('xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxxx')},
+                json: [{"pin":"$cooMrdGatewayUid$"}],
+            }
+            let {result} = await this.request(options)
+            let code = result?.code
+            if(code == 1) {
+                for(let item of (result?.content?.personalCarbonRewardRespDtoList||[])) {
+                    await this.operationPersonalCarbonIntegral(item)
+                }
+            } else {
+                let errCode = code || result?.error_response?.code
+                let errMsg = result?.msg || result?.error_response?.zh_desc
+                this.log(`查询可领取奖励出错[${errCode}]: ${errMsg}`)
+            }
+        } catch (e) {
+            $.log(e)
+        } finally {
+            return Promise.resolve()
+        }
+    }
+    
+    async operationPersonalCarbonIntegral(item) {
+        try {
+            let options = {
+                fn: 'operationPersonalCarbonIntegral',
+                method: 'post',
+                url: 'https://lop-proxy.jd.com/ESGApi/operationPersonalCarbonIntegral',
+                headers: {Cookie:this.cookie,'event-id':$.randomPattern('xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxxx')},
+                json: [{
+                    type: 2,
+                    operationType: 1,
+                    rewardNo: item.rewardNo,
+                    taskNo: item.taskNo,
+                    pin: "$cooMrdGatewayUid$",
+                }],
+            }
+            let {result} = await this.request(options)
+            let code = result?.code
+            if(code == 1) {
+                this.log(`收取[${item.taskTitle}]奖励成功, 现在有${result?.content?.carbonIntegral}g能量`)
+            } else {
+                let errCode = code || result?.error_response?.code
+                let errMsg = result?.msg || result?.error_response?.zh_desc
+                this.log(`收取[${item.taskTitle}]奖励失败[${errCode}]: ${errMsg}`)
+            }
+        } catch (e) {
+            $.log(e)
+        } finally {
+            return Promise.resolve()
+        }
+    }
+    
+    async userTask() {
+        await this.queryTaskList();
+        await this.queryCanGetRewardTaskList();
+    }
+}
+
+!(async () => {
+    $.read_env(UserClass);
+    
+    await $.threadTask('userTask',MAX_THREAD)
+})()
+.catch((e) => $.log(e))
+.finally(() => $.exitNow())
+
+function Env(name){return new class{constructor(name){this.name=name;this.startTime=Date.now();this.log(`[${this.name}]开始运行\n`,{time:true});this.notifyStr=[];this.notifyFlag=true;this.userIdx=0;this.userList=[];this.userCount=0;} log(msg,options={}){let opt={console:true};Object.assign(opt,options);if(opt.time){let fmt=opt.fmt||'hh:mm:ss';msg=`[${this.time(fmt)}]`+msg;} if(opt.notify)this.notifyStr.push(msg);if(opt.console)console.log(msg);} read_env(Class){let envStrList=ckNames.map(x=>process.env[x]);for(let env_str of envStrList.filter(x=>!!x)){let sp=envSplitor.filter(x=>env_str.includes(x));let splitor=sp.length>0?sp[0]:envSplitor[0];for(let ck of env_str.split(splitor).filter(x=>!!x)){this.userList.push(new Class(ck));}} this.userCount=this.userList.length;if(!this.userCount){this.log(`未找到变量，请检查变量${ckNames.map(x => '['+x+']').join('或')}`,{notify:true});return false;} this.log(`共找到${this.userCount}个账号`);return true;} async threads(taskName,conf,opt={}){while(conf.idx<$.userList.length){let user=$.userList[conf.idx++];await user[taskName](opt);}} async threadTask(taskName,thread){let taskAll=[];let taskConf={idx:0};while(thread--)taskAll.push(this.threads(taskName,taskConf));await Promise.all(taskAll);} time(t,x=null){let xt=x?new Date(x):new Date;let e={"M+":xt.getMonth()+1,"d+":xt.getDate(),"h+":xt.getHours(),"m+":xt.getMinutes(),"s+":xt.getSeconds(),"q+":Math.floor((xt.getMonth()+3)/3),S:this.padStr(xt.getMilliseconds(),3)};/(y+)/.test(t)&&(t=t.replace(RegExp.$1,(xt.getFullYear()+"").substr(4-RegExp.$1.length)));for(let s in e)new RegExp("("+s+")").test(t)&&(t=t.replace(RegExp.$1,1==RegExp.$1.length?e[s]:("00"+e[s]).substr((""+e[s]).length)));return t;} async showmsg(){if(!this.notifyFlag)return;if(!this.notifyStr.length)return;var notify=require('./sendNotify');this.log('\n============== 推送 ==============');await notify.sendNotify(this.name,this.notifyStr.join('\n'));} padStr(num,length,opt={}){let padding=opt.padding||'0';let mode=opt.mode||'l';let numStr=String(num);let numPad=(length>numStr.length)?(length-numStr.length):0;let pads='';for(let i=0;i<numPad;i++){pads+=padding;} if(mode=='r'){numStr=numStr+pads;}else{numStr=pads+numStr;} return numStr;} json2str(obj,c,encode=false){let ret=[];for(let keys of Object.keys(obj).sort()){let v=obj[keys];if(v&&encode)v=encodeURIComponent(v);ret.push(keys+'='+v);} return ret.join(c);} str2json(str,decode=false){let ret={};for(let item of str.split('&')){if(!item)continue;let idx=item.indexOf('=');if(idx==-1)continue;let k=item.substr(0,idx);let v=item.substr(idx+1);if(decode)v=decodeURIComponent(v);ret[k]=v;} return ret;} randomPattern(pattern,charset='abcdef0123456789'){let str='';for(let chars of pattern){if(chars=='x'){str+=charset.charAt(Math.floor(Math.random()*charset.length));}else if(chars=='X'){str+=charset.charAt(Math.floor(Math.random()*charset.length)).toUpperCase();}else{str+=chars;}} return str;} randomString(len,charset='abcdef0123456789'){let str='';for(let i=0;i<len;i++){str+=charset.charAt(Math.floor(Math.random()*charset.length));} return str;} randomList(a){let idx=Math.floor(Math.random()*a.length);return a[idx];} wait(t){return new Promise(e=>setTimeout(e,t));} async exitNow(){await this.showmsg();let e=Date.now();let s=(e-this.startTime)/1000;this.log('');this.log(`[${this.name}]运行结束，共运行了${s}秒`,{time:true});process.exit(0);}} (name)}