Update

更新算法

Coca.py

@@ -1,6 +1,37 @@
-#可口可乐吧小程序,抓包authorization,填入环境变量Coca中,多账号换行或@隔开
-import json,os,random,time,requests as r
+# -*- encoding: utf-8 -*-
+# @Time       :  18:57
+# @Author     : yuxian
+# @Email      : 1503889663@qq.com
+# @File       : Coca.py
+# @SoftWare   : PyCharm
+# 可口可乐吧小程序,抓包authorization(全部内容 copy即可),填入环境变量Coca中,多账号换行或@隔开
+import json, os, hashlib, random, time, requests as r
+
+
 def UF(): return f"Mozilla/5.0 (iPhone; CPU iPhone OS {f'{random.randint(12, 15)}.{random.randint(0, 6)}.{random.randint(0, 9)}'} like Mac OS X) AppleWebKit/{f'{random.randint(600, 700)}.{random.randint(1, 4)}.{random.randint(1, 5)}'} (KHTML, like Gecko) Mobile/15E148 MicroMessenger/7.0.20(0x16001422) NetType/WIFI Language/zh_CN"
+
+
+def generate_random_string_and_timestamp():
+    T = ''.join(random.choices('0123456789abcdefghijklmnopqrstuvwxyz', k=8))
+    d = str(int(time.time() * 1000))
+    return T, d
+
+
+def sha256_encrypt(data):
+    hash_object = hashlib.sha256()
+    hash_object.update(data.encode('utf-8'))
+    hex_dig = hash_object.hexdigest()
+    return hex_dig
+
+
+def get_header(url1):
+    T, d = generate_random_string_and_timestamp()
+    message = url1.replace("https://koplus.icoke.cn/cre-bff", "")
+    encrypted_data = sha256_encrypt(message + T + d + "apyuc3#7%m4*")
+    headers = {"x-sg-id": T, "x-sg-timestamp": d, "x-sg-signature": encrypted_data}
+    return headers
+
+
 U = "https://koplus.icoke.cn/cre-bff/wechat/"
 P = os.environ.get("Coca")
 if P and P != "":
@@ -8,8 +39,24 @@ if P and P!="":
     A = 1
     for B in C:
         try:
-            H={"Host":"koplus.icoke.cn","authorization":B,"referer":"https://servicewechat.com/wxa5811e0426a94686/307/page-frame.html","xweb_xhr":"1","user-agent":UF(),"content-type":"application/json","accept":"*/*","sec-fetch-site":"cross-site","sec-fetch-mode":"cors","sec-fetch-dest":"empty","accept-language":"zh-CN,zh"}
-            signReq=r.post(url=f"{U}checkin",headers=H)
+            H = {
+                "Host": "koplus.icoke.cn",
+                "Connection": "keep-alive",
+                "xweb_xhr": "1",
+                "Authorization": B,
+                "User-Agent": UF(),
+                "Content-Type": "application/json",
+                "Accept": "*/*",
+                "Accept-Language": "*",
+                "Sec-Fetch-Site": "cross-site",
+                "Sec-Fetch-Mode": "cors",
+                "Sec-Fetch-Dest": "empty",
+                "Referer": "https://servicewechat.com/wxa5811e0426a94686/364/page-frame.html",
+                "Accept-Encoding": "gzip, deflate, br"
+            }
+            url = f"{U}checkin"
+            H.update(get_header(url))
+            signReq = r.post(url=url, headers=H)
             signResp = json.loads(signReq.text)
             print(f"🎉开始签到账号：{A}🎉")
             A += 1
@@ -20,7 +67,9 @@ if P and P!="":
             else:
                 print("❌出现未知错误，签到失败❌")
             time.sleep(3)
-            qReq=r.get(url=f"{U}profile",headers=H)
+            url = f"{U}profile"
+            H.update(get_header(url))
+            qReq = r.get(url=url, headers=H)
             qResp = json.loads(qReq.text)
             print(f"🎉开始查询账号积分🎉")
             if qResp["data"]: