jd_fcwb.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
'''
cron: 35 15 * * *
new Env('发财挖宝');
活动入口: 京东极速版>我的>发财挖宝
脚本功能为: 挖宝，提现，没有助力功能! 
当血量剩余 1 时停止挖宝，领取奖励并提现
'''
import os,json,random,time,re,string,functools,asyncio
import sys
sys.path.append('../../tmp')
print('\n运行本脚本之前请手动进入游戏点击一个方块\n')
print('\n挖的如果都是0.01红包就是黑了，别挣扎了！\n')
print('\n默认自动领取奖励，关闭请在代码383行加上#号注释即可\n')
try:
    import requests
except Exception as e:
    print(str(e) + "\n缺少requests模块, 请执行命令：pip3 install requests\n")
requests.packages.urllib3.disable_warnings()


linkId="pTTvJeSTrpthgk9ASBVGsw"


# 获取pin
cookie_findall=re.compile(r'pt_pin=(.+?);')
def get_pin(cookie):
    try:
        return cookie_findall.findall(cookie)[0]
    except:
        print('ck格式不正确，请检查')

# 读取环境变量
def get_env(env):
    try:
        if env in os.environ:
            a=os.environ[env]
        elif '/ql' in os.path.abspath(os.path.dirname(__file__)):
            try:
                a=v4_env(env,'/ql/config/config.sh')
            except:
                a=eval(env)
        elif '/jd' in os.path.abspath(os.path.dirname(__file__)):
            try:
                a=v4_env(env,'/jd/config/config.sh')
            except:
                a=eval(env)
        else:
            a=eval(env)
    except:
        a=''
    return a

# v4
def v4_env(env,paths):
    b=re.compile(r'(?:export )?'+env+r' ?= ?[\"\'](.*?)[\"\']', re.I)
    with open(paths, 'r') as f:
        for line in f.readlines():
            try:
                c=b.match(line).group(1)
                break
            except:
                pass
    return c 


# 随机ua
def ua():
    sys.path.append(os.path.abspath('.'))
    try:
        from jdEnv import USER_AGENTS as a
    except:
        a='jdpingou;android;5.5.0;11;network/wifi;model/M2102K1C;appBuild/18299;partner/lcjx11;session/110;pap/JA2019_3111789;brand/Xiaomi;Mozilla/5.0 (Linux; Android 11; M2102K1C Build/RKQ1.201112.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/92.0.4515.159 Mobile Safari/537.36'
    return a

# 13位时间戳
def gettimestamp():
    return str(int(time.time() * 1000))

## 获取cooie
class Judge_env(object):
    def main_run(self):
        if '/jd' in os.path.abspath(os.path.dirname(__file__)):
            cookie_list=self.v4_cookie()
        else:
            cookie_list=os.environ["JD_COOKIE"].split('&')       # 获取cookie_list的合集
        if len(cookie_list)<1:
            print('请填写环境变量JD_COOKIE\n')    
        return cookie_list

    def v4_cookie(self):
        a=[]
        b=re.compile(r'Cookie'+'.*?=\"(.*?)\"', re.I)
        with open('/jd/config/config.sh', 'r') as f:
            for line in f.readlines():
                try:
                    regular=b.match(line).group(1)
                    a.append(regular)
                except:
                    pass
        return a
cookie_list=Judge_env().main_run()   


def taskGetUrl(functionId, body, cookie):
    url=f'https://api.m.jd.com/?functionId={functionId}&body={json.dumps(body)}&t={gettimestamp()}&appid=activities_platform&client=H5&clientVersion=1.0.0'
    headers={
        'Cookie': cookie,
        'Host': 'api.m.jd.com',
        'Connection': 'keep-alive',
        'origin': 'https://bnzf.jd.com',
        'Content-Type': 'application/x-www-form-urlencoded',
        'accept': 'application/json, text/plain, */*',
        "User-Agent": ua(),
        'Accept-Language': 'zh-cn',
        'Accept-Encoding': 'gzip, deflate, br',
    }
    for n in range(3):
        try:
            res=requests.get(url,headers=headers, timeout=10).json()
            return res
        except:
            if n==2:
                print('API请求失败，请检查网路重试❗\n')   


# 剩余血量
def xueliang(cookie):
    body={"linkId":linkId}
    res=taskGetUrl("happyDigHome", body, cookie)
    if not res:
        return
    if res['code']==0:
        if res['success']:
            curRound=res['data']['curRound']                        # 未知
            blood=res['data']['blood']                              # 剩余血量
            return blood      

def jinge(cookie,i):
    body={"linkId":linkId}
    res=taskGetUrl("happyDigHome", body, cookie)
    if not res:
        return
    if res['code']==0:
        if res['success']:
            curRound=res['data']['curRound']                        # 未知
            blood=res['data']['blood']                              # 剩余血量
            roundList=res['data']['roundList']                      # 3个总池子
            roundList_n=roundList[0]
            redAmount=roundList_n['redAmount']                  # 当前池已得京东红包
            cashAmount=roundList_n['cashAmount']                # 当前池已得微信红包

            return [blood,redAmount,cashAmount]   

# 页面数据
def happyDigHome(cookie):
    body={"linkId":linkId}
    res=taskGetUrl("happyDigHome", body, cookie)
    if not res:
        return
    if res['code']==0:
        if res['success']:
            curRound=res['data']['curRound']                        # 未知
            incep_blood=res['data']['blood']                              # 剩余血量
            roundList=res['data']['roundList']                      # 3个总池子
            for e,roundList_n in enumerate(roundList):                           # 迭代每个池子
                roundid=roundList_n['round']                        # 池序号
                state=roundList_n['state'] 
                rows=roundList_n['rows']                            # 池规模，rows*rows
                redAmount=roundList_n['redAmount']                  # 当前池已得京东红包
                cashAmount=roundList_n['cashAmount']                # 当前池已得微信红包
                leftAmount=roundList_n['leftAmount']                # 剩余红包？
                chunks=roundList_n['chunks']                        # 当前池详情list

                a=jinge(cookie,roundid)
                print(f'当前池序号为 {roundid} \n当前池规模为 {rows}*{rows}')
                print(f'剩余血量 {a[0]}')
                print(f'当前池已得京东红包 {a[2]}\n当前池已得微信红包 {a[1]}\n')
                _blood=xueliang(cookie)
                if _blood>1  or incep_blood>=21:
                    happyDigDo(cookie,roundid,0,0)
                    if e==0 or e==1:
                        roundid_n=4
                    else:
                        roundid_n=5
                    for n in range(roundid_n):
                        for i in range(roundid_n):
                            _blood=xueliang(cookie)
                            if _blood>1  or incep_blood>=21:
                                print(f'当前血量为 {_blood} 健康，继续挖宝')
                                print(f'本次挖取坐标为 ({n},{i})')
                                happyDigDo(cookie,roundid,n,i)
                            else:
                                a=jinge(cookie,roundid)
                                print(f'当前血量为 {_blood} 不健康，结束该池挖宝')
                                print(f'当前池已得京东红包 {a[2]}\n当前池已得微信红包 {a[1]}\n')
                                break
        else:
            print(f'获取数据失败\n{res}\n')
    else:
        print(f'获取数据失败\n{res}\n')


 # 玩一玩
def apDoTask(cookie):
     print('开始 玩一玩')
     body={"linkId":linkId,"taskType":"BROWSE_CHANNEL","taskId":454,"channel":4,"itemId":"https%3A%2F%2Fsignfree.jd.com%2F%3FactivityId%3DPiuLvM8vamONsWzC0wqBGQ","checkVersion":False}
     res=taskGetUrl('apDoTask', body, cookie)
     if not res:
         return
     try:    
         if res['success']:
             print('任务完成，获得血量 1\n')
         else:
             print(f"{res['errMsg']}\n")
     except:
         print(f"错误\n{res}\n")
    

# 挖宝
def happyDigDo(cookie,roundid,rowIdx,colIdx):
    body={"round":roundid,"rowIdx":rowIdx,"colIdx":colIdx,"linkId":linkId}
    res=taskGetUrl("happyDigDo", body, cookie)
    if not res:
        return
    if res['code']==0:
        if res['success']:
            typeid=res['data']['chunk']['type']
            if typeid==2:
                print(f"挖到京东红包 {res['data']['chunk']['value']}\n")
            elif typeid==3:
                print(f"挖到微信红包 {res['data']['chunk']['value']}\n")
            elif typeid==4:
                print(f"挖到炸弹\n")
            elif typeid==1:
                print(f"挖到优惠券\n")
            else:
                print(f'挖到外星物品\n')
        else:
            print(f'挖取失败\n{res}\n')
    else:
        print(f'挖取失败\n{res}\n')

# # 助力码
# def inviteCode(cookie):
#     global inviteCode_1_list,inviteCode_2_list
#     body={"linkId":linkId}
#     res=taskGetUrl("happyDigHome", body, cookie)
#     if not res:
#         return
#     try:
#         if res['success']:
#             print(f"账号{get_pin(cookie)}助力码为{res['data']['inviteCode']}")
#             inviteCode_1_list.append(res['data']['inviteCode'])
#             print(f"账号{get_pin(cookie)}助力码为{res['data']['markedPin']}")
#             inviteCode_2_list.append(res['data']['markedPin'])
#         else:
#             print('快去买买买吧')
#     except:
#         print(f"错误\n{res}\n")

# # 助力
# def happyDigHelp(cookie,fcwbinviter,fcwbinviteCode):
#     print(f"账号 {get_pin(cookie)} 去助力{fcwbinviteCode}")
#     xueliang(cookie)
#     body={"linkId":linkId,"inviter":fcwbinviter,"inviteCode":fcwbinviteCode}
#     res=taskGetUrl("happyDigHelp", body, cookie)
#     if res['success']:
#         print('助力成功')
#     else:
#         print(res['errMsg'])

# 领取奖励
def happyDigExchange(cookie):
    for n in range(0,4):
        xueliang(cookie)
        
        print('开始领取奖励')
        body={"round":n,"linkId":linkId}
        res=taskGetUrl("happyDigExchange", body, cookie)
        if not res:
            return
        if res['code']==0:
            if res['success']:
                try:
                    print(f"领取到微信红包 {res['data']['wxValue']}")
                except:
                    pass
                try:
                    print(f"领取到京东红包 {res['data']['redValue']}\n")
                except:
                    print('')
            else:
                print(res['errMsg']+'\n')
        else:
            print(res['errMsg']+'\n')



# 微信现金id
def spring_reward_list(cookie):
    happyDigExchange(cookie)
    xueliang(cookie)
    
    body={"linkId":linkId,"pageNum":1,"pageSize":6}
    res=taskGetUrl("spring_reward_list", body, cookie)
    
    if res['code']==0:
        if res['success']:
            items=res['data']['items']
            for _items in items:
                amount=_items['amount']         # 金额
                prizeDesc=_items['prizeDesc']   # 金额备注
                amountid=_items['id']           # 金额id
                poolBaseId=_items['poolBaseId']
                prizeGroupId=_items['prizeGroupId']
                prizeBaseId=_items['prizeBaseId']
                if '红包' not in prizeDesc:
                    print('尝试微信提现')
                    time.sleep(3.2)
                    wecat(cookie,amountid,poolBaseId,prizeGroupId,prizeBaseId)
        else:
            print(f'获取数据失败\n{res}\n')
    else:
        print(f'获取数据失败\n{res}\n')                     

# 微信提现
def wecat(cookie,amountid,poolBaseId,prizeGroupId,prizeBaseId):
    xueliang(cookie)
    
    url='https://api.m.jd.com'
    headers={
        'Cookie': cookie,
        'Host': 'api.m.jd.com',
        'Connection': 'keep-alive',
        'origin': 'https://bnzf.jd.com',
        'Content-Type': 'application/x-www-form-urlencoded',
        "User-Agent": ua(),
        'Accept-Language': 'zh-cn',
        'Accept-Encoding': 'gzip, deflate, br',
    }
    body={"businessSource":"happyDiggerH5Cash","base":{"id":amountid,"business":"happyDigger","poolBaseId":poolBaseId,"prizeGroupId":prizeGroupId,"prizeBaseId":prizeBaseId,"prizeType":4},"linkId":linkId}
    data=f"functionId=apCashWithDraw&body={json.dumps(body)}&t=1635596380119&appid=activities_platform&client=H5&clientVersion=1.0.0"
    for n in range(3):
        try:
            res=requests.post(url,headers=headers,data=data,timeout=10).json()
            break
        except:
            if n==2:
                print('API请求失败，请检查网路重试❗\n') 
    try:
        if res['code']==0:
            if res['success']:
                print(res['data']['message']+'\n')
    except:
        print(res)
        print('')
    

def main():
    print('🔔发财挖宝，开始！\n')

    # print('获取助力码\n')
    # global inviteCode_1_list,inviteCode_2_list
    # inviteCode_1_list=list()
    # inviteCode_2_list=list()
    # for cookie in cookie_list:
    #    inviteCode(cookie) 

    # print('互助\n')
    # inviteCode_2_list=inviteCode_2_list[:2]
    # for e,fcwbinviter in enumerate(inviteCode_2_list):
    #     fcwbinviteCode=inviteCode_1_list[e]
    #     for cookie in cookie_list:
    #         happyDigHelp(cookie,fcwbinviter,fcwbinviteCode)

    print(f'====================共{len(cookie_list)}京东个账号Cookie=========\n')

    for e,cookie in enumerate(cookie_list,start=1):
        print(f'******开始【账号 {e}】 {get_pin(cookie)} *********\n')
        apDoTask(cookie)
        happyDigHome(cookie)
        spring_reward_list(cookie)


if __name__ == '__main__':
    main()