[pull] main from Mashiro2000:main

BattleForHeyTap.py → Backup/BattleForHeyTap.py

@@ -212,6 +212,26 @@ def runBattleTask(self):
                 elif each['t_status'] == 2:
                     notify(f"[{each['title']}]\t任务完成")
 
+    # 获取积分数量(只找到这个，找不到昨天积分数据)
+    def getIntegral(self):
+        url = 'https://store.oppo.com/cn/oapi/credits/web/credits/show'
+        headers = {
+            'Host': 'store.oppo.com',
+            'Connection': 'keep-alive',
+            'source_type': '501',
+            'clientPackage': 'com.oppo.store',
+            'Accept': 'application/json, text/plain, */*',
+            'Accept-Encoding': 'gzip, deflate',
+            'Accept-Language': 'zh-CN,en-US;q=0.9',
+            'X-Requested-With': 'com.oppo.store',
+            'Referer': 'https://store.oppo.com/cn/app/taskCenter/index?us=gerenzhongxin&um=hudongleyuan&uc=renwuzhongxin'
+        }
+        response = self.sess.get(url=url,headers=headers).json()
+        if response['code'] == 200:
+            return f"{self.dic['user']}\t总积分:{response['data']['userCredits']}"
+        else:
+            return f"{self.dic['user']}\t错误原因:{response}"
+
     # 执行欢太商城实例对象
     def start(self):
         self.sess.headers.update({
@@ -223,7 +243,7 @@ def start(self):
         if self.login() == True:
             if self.getBattleList() == True:              # 获取任务中心数据，判断CK是否正确(登录可能成功，但无法跑任务)
                 self.runBattleTask()                        # 运行任务中心
-            notify('*' * 40 + '\n')
+                notify(self.getIntegral())
 
 # 检测CK是否存在必备参数
 def checkHT(dic):
@@ -243,7 +263,7 @@ def checkHT(dic):
 def main_handler(event, context):
     global lists
     for each in lists:
-        if all(each.values()):
+        if each['CK']!='' and each['UA'] != '':
             if checkHT(each):
                 battleForHeyTap = BattleForHeyTap(each)
                 for count in range(3):
@@ -258,6 +278,11 @@ def main_handler(event, context):
                 else:
                     notify(f"账号: {battleForHeyTap.dic['user']}\n状态: 取消登录\n原因: 多次登录失败")
                     break
+        elif not all(each.values()):
+            notify("账号:空账户\t状态:跳过")
+        else:
+            notify(f"账号: {each['user']}\n状态: 取消登录\n原因: json数据不齐全")
+        notify('*' * 40 + '\n')
     if not os.path.basename(__file__).split('_')[-1][:-3] in notifyBlackList:
         send('欢太积分大乱斗',allMess)
 

ChockInEarly.py → Backup/ChockInEarly.py

@@ -108,6 +108,26 @@ def early(self):
         elif response['code'] == 1000005:
             notify(f"{self.dic['user']}\t{response['errorMessage']}")
 
+    # 获取积分数量(只找到这个，找不到昨天积分数据)
+    def getIntegral(self):
+        url = 'https://store.oppo.com/cn/oapi/credits/web/credits/show'
+        headers = {
+            'Host': 'store.oppo.com',
+            'Connection': 'keep-alive',
+            'source_type': '501',
+            'clientPackage': 'com.oppo.store',
+            'Accept': 'application/json, text/plain, */*',
+            'Accept-Encoding': 'gzip, deflate',
+            'Accept-Language': 'zh-CN,en-US;q=0.9',
+            'X-Requested-With': 'com.oppo.store',
+            'Referer': 'https://store.oppo.com/cn/app/taskCenter/index?us=gerenzhongxin&um=hudongleyuan&uc=renwuzhongxin'
+        }
+        response = self.sess.get(url=url,headers=headers).json()
+        if response['code'] == 200:
+            return f"{self.dic['user']}\t总积分:{response['data']['userCredits']}"
+        else:
+            return f"{self.dic['user']}\t错误原因:{response}"
+
     # 执行欢太商城实例对象
     def start(self):
         self.sess.headers.update({
@@ -118,7 +138,7 @@ def start(self):
         })
         if self.login() == True:
             self.early()
-        notify('*' * 40 + '\n')
+            notify(self.getIntegral())
 
 # 检测CK是否存在必备参数
 def checkHT(dic):
@@ -138,7 +158,7 @@ def checkHT(dic):
 def main_handler(event, context):
     global lists
     for each in lists:
-        if all(each.values()):
+        if each['CK']!='' and each['UA'] != '':
             if checkHT(each):
                 checkInEarly = CheckInEarly(each)
                 for count in range(3):
@@ -153,6 +173,11 @@ def main_handler(event, context):
                 else:
                     notify(f"账号: {checkInEarly.dic['user']}\n状态: 取消登录\n原因: 多次登录失败")
                     break
+        elif not all(each.values()):
+            notify("账号:空账户\t状态:跳过")
+        else:
+            notify(f"账号: {each['user']}\n状态: 取消登录\n原因: json数据不齐全")
+        notify('*' * 40 + '\n')
     if not os.path.basename(__file__).split('_')[-1][:-3] in notifyBlackList:
         send('欢太早睡打卡',allMess)
 

Backup/CollectionCard.py

@@ -278,6 +278,10 @@ def main_handler(event, context):
                 else:
                     notify(f"账号: {collectionCard.dic['user']}\n状态: 取消登录\n原因: 多次登录失败")
                     break
+        elif not all(each.values()):
+            notify("账号:空账户\t状态:跳过")
+        else:
+            notify(f"账号: {each['user']}\n状态: 取消登录\n原因: json数据不齐全")
     if not os.path.basename(__file__).split('_')[-1][:-3] in notifyBlackList:
         send('集卡赢套票',allMess)
 

Backup/Community.py

@@ -0,0 +1,236 @@
+# !/usr/bin/env python
+# -*- coding: utf-8 -*-
+# @Time    : 2021/11/14
+# @Author  : MashiroF
+# @File    : Community.py
+# @Software: PyCharm
+
+'''
+cron:  30 6,12 * * * Community.py
+new Env('OPPO社区签到、早起打卡');
+'''
+
+import os
+import re
+import sys
+import time
+import random
+import requests
+
+# 配置文件
+try:
+    from HT_config import downFlag,notifyBlackList,logger
+except Exception as error:
+    logger.info(f'失败原因:{error}')
+    sys.exit(0)
+
+# 判断是否发生下载行为
+if downFlag == True:
+    logger.info('发生下载行为,应退出程序，编辑配置文件')
+    sys.exit(0)
+
+# 配信文件
+try:
+    from sendNotify import send
+except Exception as error:
+    logger.info('推送文件有误')
+    logger.info(f'失败原因:{error}')
+    sys.exit(0)
+
+# 导入账户
+try:
+    from HT_account import accounts
+    lists = accounts
+except Exception as error:
+    logger.info(f'失败原因:{error}')
+    lists = []
+
+# 配信内容格式
+allMess = ''
+def notify(content=None):
+    global allMess
+    allMess = allMess + content + '\n'
+    logger.info(content)
+
+# 日志录入时间
+notify(f"任务:OPPO社区签到、早起打卡\n时间:{time.strftime('%Y-%m-%d %H:%M:%S',time.localtime())}")
+
+class Community:
+    def __init__(self,dic):
+        self.sess = requests.session()
+        self.dic = dic
+        self.ID = 453509395675611143
+
+    def login(self):
+        url = 'https://i-user.oppo.cn/member/v3/index/get.pb'
+        headers = {
+            "Accept-Encoding": "gzip",
+            "Connection": "Keep-Alive",
+            "Host": "i-user.oppo.cn",
+            "TAP-GSLB": "0,0",
+            "User-Agent": "okhttp/3.12.12.217",
+            'Accept': 'application/json, text/plain, */*'
+        }
+        response = self.sess.get(url=url,headers=headers).json()
+        if response['message']['code'] == 200:
+            self.loginMess = response
+            notify(f"{self.dic['user']}\t登录成功")
+            return True
+        else:
+            notify(f"{self.dic['user']}\t登录失败")
+            return False
+
+    # def computerValue(self,c,d):
+    #     r = int(d + (random.random() % 10) * 16) % 16 | 0
+    #     d = math.floor(d / 16)
+    #     return d,hex(r if c == 'x' else (r & 0x3 | 0x8))[-1]
+    #
+    # def generateUUID(self):
+    #     d = round(time.time() * 1000)
+    #     oldStr = 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'
+    #     newStr = ''
+    #     for i in oldStr:
+    #         if i == 'x' or i == 'y':
+    #             d,v = self.computerValue(i,d)
+    #             newStr += v
+    #         else:
+    #             newStr += i
+    #     return newStr
+
+    def ClockIn(self):
+        url = 'https://i-api.oppo.cn/sign/v1/index/create.pb'
+        headers = {
+            "Accept-Encoding": "gzip",
+            "Connection": "Keep-Alive",
+            "Host": "i-api.oppo.cn",
+            "TAP-GSLB": "0,0",
+            "User-Agent": "okhttp/3.12.12.217",
+            'Accept': 'application/json, text/plain, */*'
+        }
+        response = self.sess.get(url=url,headers=headers).json()
+        if response['message']['code'] == 200 and response['message']['msg'] == '操作成功':
+            notify(f"[每日签到]\t签到成功")
+        elif response['message']['code'] == 200 and response['message']['msg'] == 'SUCCESS':
+            notify(f"[每日签到]\t已签到")
+        else:
+            notify(f"[每日签到]\t签到失败\t失败原因:{response}")
+
+    def SignUp(self):
+        url = 'https://hdapi.oppo.cn/user/attendance/signUp'
+        headers = {
+            "Accept": "*/*",
+            "Accept-Encoding": "gzip, deflate",
+            "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7",
+            "Cache-Control": "no-cache",
+            "Connection": "keep-alive",
+            "Content-Type": "application/x-www-form-urlencoded;charset=UTF-8",
+            "Host": "hdapi.oppo.cn",
+            "Origin": "https://hdpage.oppo.cn",
+            "Pragma": "no-cache",
+            "Referer": f"https://hdpage.oppo.cn/rglpdu/index.html?id={self.ID}",
+            "X-Requested-With": "XMLHttpRequest"
+        }
+        data = {
+            'attendanceId':self.ID,
+            'nickName':self.loginMess['nickname']
+        }
+        response = self.sess.post(url=url,headers=headers,data=data).json()
+        if response['code'] == 200:
+            notify(f"[早起打卡]\t报名成功")
+        else:
+            notify(f"[早起打卡]\t{response['msg']}")
+
+
+    def SignIn(self):
+        url = 'https://hdapi.oppo.cn/user/attendance/signIn'
+        headers = {
+            "Accept": "*/*",
+            "Accept-Encoding": "gzip, deflate",
+            "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7",
+            "Cache-Control": "no-cache",
+            "Connection": "keep-alive",
+            "Content-Type": "application/x-www-form-urlencoded;charset=UTF-8",
+            "Host": "hdapi.oppo.cn",
+            "Origin": "https://hdpage.oppo.cn",
+            "Pragma": "no-cache",
+            "Referer": f"https://hdpage.oppo.cn/rglpdu/index.html?id={self.ID}",
+            "X-Requested-With": "XMLHttpRequest"
+        }
+        data = {
+            'attendanceId':self.ID
+        }
+        response = self.sess.post(url=url,headers=headers,data=data).json()
+        if response['code'] == 200:
+            notify(f"[早起打卡]\t打卡成功")
+        else:
+            notify(f"[早起打卡]\t{response['msg']}")
+
+    def getTime(self):
+        now = time.time()
+        TZ = time.strftime("%Z", time.localtime(now))
+        if TZ == 'UTC' or TZ == '协调世界时':
+            return time.strftime('%H:%M:%S',time.localtime(now+ 8*3600))
+        elif TZ == 'CST' or TZ == '中国标准时间':
+            return time.strftime('%H:%M:%S',time.localtime(now))
+        else:
+            notify(f"时区设置错误,当前时区:{TZ}\t预期时区:CST")
+            return False
+
+    def earlyBed(self):
+        now = self.getTime()
+        if now != False:
+            if now > '09:30:00' and now < '23:59:00':
+                self.SignUp()
+            elif now > '05:30:00' and now < '09:00:00':
+                self.SignIn()
+            else:
+                notify(f"[早起打卡]\t打卡报名时间段外，取消后续操作")
+
+
+    def start(self):
+        token = re.findall(r'TOKENSID=(TOKEN.*?;)',self.dic['CK'],re.S)
+        if token !=[]:
+            self.sess.headers.update({
+                "User-Agent":self.dic['UA']
+            })
+            self.sess.cookies.update({
+                "Cookie": ';token=' + token[0]
+            })
+            if self.login() == True:
+                self.ClockIn()
+                self.earlyBed ()
+
+def checkHT(dic):
+    if len(re.findall(r'TOKENSID=.*?;',dic['CK'])) == 0:
+        notify(f"{dic['user']}\tCK格式有误:可能缺少`TOKENSID`字段")
+        return False
+    return True
+
+# 兼容云函数
+def main_handler(event, context):
+    global lists
+    for each in lists:
+        if each['CK']!='' and each['UA'] != '':
+            if checkHT(each):
+                community = Community(each)
+                for count in range(3):
+                    try:
+                        time.sleep(random.randint(2,5))    # 随机延时
+                        community.start()
+                        break
+                    except requests.exceptions.ConnectionError:
+                        notify(f"{community.dic['user']}\t请求失败，随机延迟后再次访问")
+                        time.sleep(random.randint(2,5))
+                        continue
+                else:
+                    notify(f"账号: {community.dic['user']}\n状态: 取消登录\n原因: 多次登录失败")
+        elif not all(each.values()):
+            notify("账号:空账户\t状态:跳过")
+        else:
+            notify(f"账号: {each['user']}\n状态: 取消登录\n原因: json数据不齐全")
+        notify('*' * 40 + '\n')
+    if not os.path.basename(__file__).split('_')[-1][:-3] in notifyBlackList:
+        send('OPPO社区签到、早起打卡',allMess)
+
+if __name__ == '__main__':
+    main_handler(None,None)