iaun 5 éve
szülő
commit
695f8c43e2
2 módosított fájl, 166 hozzáadás és 0 törlés
  1. 165 0
      .~c9_invoke_loMac1.py
  2. 1 0
      kaoqin.py

+ 165 - 0
.~c9_invoke_loMac1.py

@@ -0,0 +1,165 @@
+import requests
+import urllib.parse
+import json
+import random
+import time
+import datetime
+import sys
+
+import para
+import config
+
+TODAY = None
+TODAY_SUCCESS = False
+TODAY_EXEC_TIME = None
+
+# d_start_time = None
+# d_end_time = None
+
+def getHeader():
+    return {
+        "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/77.0.3865.120 MQQBrowser/6.2 TBS/045511 Mobile Safari/537.36 MMWEBID/1122 MicroMessenger/7.0.20.1781(0x27001439) Process/toolsmp WeChat/arm64 NetType/4G Language/zh_CN ABI/arm64"
+    }
+
+def getObj(sxid, xssxglid, lat, lng, title):
+    obj = {}
+    obj['cnz022'] = sxid
+    obj['cnz058'] = xssxglid
+    obj['cne640'] = lat
+    obj['cne641'] = lng
+    obj['cne642'] = title
+    return json.dumps(obj,separators=(',',':'), ensure_ascii=False)
+
+
+def getTime():
+    return int(round(time.time()*1000))
+
+
+def f_login(session):
+    p = para.get()
+    try:
+        r = session.get("https://hrsspub.sz.gov.cn/jgxxfw/jgfw/sooLogin", params = {
+            "para": p,
+            "type": 1,
+            "_": getTime()
+        }, headers=getHeader())
+        if r.text.find('"status":200') == -1:
+            if r.text.find('系统异常'):
+                print("[%s] %s" % (TODAY, '登录无效,请检查para'))
+            else:
+                print("[%s] %s" % (TODAY, '未知错误'))
+            return False
+    except Exception as e:
+        print("[%s] %s" % (TODAY, e))
+        return False
+    else:
+        return True
+    
+def f_getKq(session):
+    try:
+        r = session.post("https://hrsspub.sz.gov.cn/jgxxfw/jgfw/ydfw/student/getKqdd", headers=getHeader())
+        if r.text.find('"status":200') == -1:
+            print("[%s] %s" % (TODAY, r.text))
+            return False
+        else:
+            data = json.loads(r.text)
+            if 'result' in data and 'xssxglid' in data['result'] and 'sxid' in data['result'] and 'data' in data['result'] and  len(data['result']['data'])!= 0 and 'cnz080' in data['result']['data'][0] and 'cnz058' in data['result']['data'][0] and 'lat' in data['result']['data'][0] and 'lng' in data['result']['data'][0] and 'title' in data['result']['data'][0]:
+                return f_submitKq(session, getObj(data['result']['sxid'], data['result']['xssxglid'], data['result']['data'][0]['lat'], data['result']['data'][0]['lng'], data['result']['data'][0]['title']))
+            else:
+                print("[%s] %s" % (TODAY, data))
+                print("[%s] %s" % (TODAY, '缺少部分信息,无法进行打卡'))
+                return False
+    except Exception as e:
+        print("[%s] %s" % (TODAY, e))
+        return False
+
+def f_submitKq(session, data):
+    try:
+        r = session.get('https://hrsspub.sz.gov.cn/jgxxfw/jgfw/ydfw/student/addKqjl', params = {
+            "xskqjlxxDTO": data,
+            "_": getTime()
+        }, headers=getHeader())
+        print("[%s] 服务端数据:%s" % (TODAY, r.text))
+        d = json.loads(r.text)
+        if 'status' in d:
+            if d['status'] == 200 or d['status'] == 300:
+                return True
+
+    except Exception as e:
+        print("[%s] %s" % (TODAY, e))
+        return False
+    return False
+
+def getToday():
+    return str(datetime.datetime.now().date())
+
+def getRandomTime():
+    d_start_time = datetime.datetime.strptime(TODAY+" %d:%d:00" % (config.START_TIME[0], config.START_TIME[1]), '%Y-%m-%d %H:%M:%S')
+    d_end_time = datetime.datetime.strptime(TODAY+" %d:%d:59" % (config.END_TIME[0], config.END_TIME[1]), '%Y-%m-%d %H:%M:%S')
+    i_start_time = int(time.mktime(d_start_time.timetuple()))
+    i_end_time = int(time.mktime(d_end_time.timetuple()))
+    return datetime.datetime.fromtimestamp(random.randint(i_start_time, i_end_time))
+    
+
+def f_start():
+    global TODAY_SUCCESS
+    session = requests.session()
+    success = f_login(session)
+    if not success:
+        return False
+    TODAY_SUCCESS = f_getKq(session)
+    print("[%s] %s %s" % (TODAY, ("成功" if TODAY_SUCCESS else "失败"), datetime.datetime.now()))
+    return TODAY_SUCCESS
+
+def f_loop():
+    global TODAY, TODAY_SUCCESS, TODAY_EXEC_TIME
+    while True:
+        if not config.check_rule():
+            time.sleep(5)
+            continue
+        now = datetime.datetime.now()
+        if TODAY_EXEC_TIME is None: # 首次运行
+            TODAY_SUCCESS = False
+            TODAY_EXEC_TIME = datetime.datetime.strptime(TODAY+" %d:%d:00" % (config.END_TIME[0], config.END_TIME[1]), '%Y-%m-%d %H:%M:%S')
+            if TODAY_EXEC_TIME < now:
+                print("[%s] 今日超过设置时间,将不打卡" % TODAY)
+                TODAY_SUCCESS = True
+                time.sleep(5)
+                continue
+            else:
+                print("[%s] 开始打卡时间:现在" % TODAY)
+                succ = f_start()
+                if not succ: # 失败等待1分钟后重试
+                    TODAY_EXEC_TIME = None
+                    time.sleep(60)
+                else:
+                    time.sleep(5)
+                continue
+        
+        if not TODAY == getToday():
+            TODAY = getToday()
+            TODAY_SUCCESS = False
+            TODAY_EXEC_TIME = getRandomTime()
+            print()
+            print("[%s] 开始打卡时间:%s" % (TODAY, TODAY_EXEC_TIME))
+
+        if now >= TODAY_EXEC_TIME and not TODAY_SUCCESS:
+            succ = f_start()
+            if not succ: # 失败等待1分钟后重试
+                time.sleep(60)
+            else:
+                time.sleep(5)
+            continue
+        
+        time.sleep(5)
+
+
+if __name__ == '__main__':
+    TODAY = getToday()
+    d_start_time = datetime.datetime.strptime(TODAY+" %d:%d:00" % (config.START_TIME[0], config.START_TIME[1]), '%Y-%m-%d %H:%M:%S')
+    d_end_time = datetime.datetime.strptime(TODAY+" %d:%d:59" % (config.END_TIME[0], config.END_TIME[1]), '%Y-%m-%d %H:%M:%S')
+    if not d_start_time <= d_end_time:
+        print("[%s] %s" % (TODAY, 'config.py 时间区间错误'))
+        sys.exit()
+    f_loop()
+    

+ 1 - 0
kaoqin.py

@@ -102,6 +102,7 @@ def getRandomTime():
     
 
 def f_start():
+    global TODAY_SUCCESS
     session = requests.session()
     success = f_login(session)
     if not success: