[FEAT] 适配-快速课程

Author: 11273

ZJYMain/look_video.py

@@ -9,6 +9,7 @@
 import logging
 import random
 import time
+from datetime import timedelta, datetime
 from urllib.parse import quote
 
 from Crypto.Cipher import AES
@@ -27,18 +28,25 @@
 # 获取学习课程列表
 GET_LEARNNING_COURSE_LIST = BASE_URL + '/spoc/courseInfoStudent/myCourseList'
 
+# 获取内容资源列表 fast
+GET_STUDENT_TEACH_DATE_FAST = BASE_URL + '/spoc/courseFaceTeachActivity/getStudentTeachDate'
+
 # 获取一级目录
 GET_PROCESS_LIST = BASE_URL + '/spoc/courseDesign/study/record'
+GET_PROCESS_LIST_FAST = BASE_URL + '/spoc/courseFaceTeachInfo/fast/student/info'
 
 # 刷课记录时长
 STU_PROCESS_CELL_LOG = BASE_URL + '/spoc/studyRecord/update'
+STU_PROCESS_CELL_LOG_FAST = BASE_URL + '/spoc/fast/course/study'
 
 # PPT类型获取总页数
 GET_URL_PNGS = BASE_URL + '/spoc/oss/getUrlPngs'
 
 # 视频获取时长
 GET_VIDEO_TIME = 'https://upload.icve.com.cn/{}/status'
 
+is_fast = False
+
 
 # 1.获取所有课程
 def get_learnning_course_list(session):
@@ -50,17 +58,51 @@ def get_learnning_course_list(session):
     return result.json()
 
 
-# 2.得到一级目录
-def get_process_list(session, course_id, course_info_id, open_class_id, parent_id, level):
+# 2.得到资源列表 fast
+def get_process_list_fast(session, course_id, course_info_id, open_class_id):
+    # 获取结束时间（今天+1天）
+    end_date = datetime.now() + timedelta(days=1)
+    # 获取开始时间（结束时间-365天）
+    start_date = end_date - timedelta(days=365)
     data = {
-        'courseId': course_id,
-        'courseInfoId': course_info_id,
-        'parentId': parent_id,
-        "level": level,
-        "classId": open_class_id
+        "courseId": course_id,
+        "courseInfoId": course_info_id,
+        "classId": open_class_id,
+        "startDate": start_date.strftime("%Y-%m-%d"),
+        "endDate": end_date.strftime("%Y-%m-%d"),
+        "pageNum": 1,
+        "pageSize": 1000,
+        "teachType": 1
     }
 
-    result = session.get(url=GET_PROCESS_LIST, params=data, headers=headers)
+    result = session.get(url=GET_STUDENT_TEACH_DATE_FAST, params=data, headers=headers)
+    return result.json()
+
+
+# 2.得到一级目录
+def get_process_list(session, course_id, course_info_id, open_class_id, parent_id, level, start_date=''):
+    if is_fast:
+        data = {
+            "courseId": course_id,
+            "courseInfoId": course_info_id,
+            "classId": open_class_id,
+            "teachType": "1",
+            "startDate": start_date,
+            "EndDate": start_date,
+            "requireType": "2"
+        }
+
+        result = session.get(url=GET_PROCESS_LIST_FAST, params=data, headers=headers)
+    else:
+        data = {
+            'courseId': course_id,
+            'courseInfoId': course_info_id,
+            'parentId': parent_id,
+            "level": level,
+            "classId": open_class_id
+        }
+
+        result = session.get(url=GET_PROCESS_LIST, params=data, headers=headers)
     return result.json()
 
 
@@ -75,6 +117,8 @@ def stu_process_cell_log(session, course_info_id, class_id, study_time, source_i
         "actualNum": total_num,
         "lastNum": total_num,
     }
+    if is_fast:
+        data['type'] = 1
 
     def encrypt_data(_data):
         access_token = session.access_token
@@ -86,7 +130,10 @@ def encrypt_data(_data):
         return base64.b64encode(encrypted_data).decode()
 
     param = {"param": quote(encrypt_data(data))}
-    result = session.post(url=STU_PROCESS_CELL_LOG, json=param, headers=headers)
+    if is_fast:
+        result = session.post(url=STU_PROCESS_CELL_LOG_FAST, json=param, headers=headers)
+    else:
+        result = session.post(url=STU_PROCESS_CELL_LOG, json=param, headers=headers)
     try:
         return result.json()['msg']
     except Exception as e:
@@ -109,9 +156,9 @@ def get_video_time(session, file_url):
 def study_record(session, info, class_id):
     sleep_randint = random.randint(5, 10)
     time.sleep(sleep_randint)
-    name = info['name']
+    name = info.get('name') or info.get('title')
     file_type = info['fileType']
-    course_id = info['id']
+    course_id = info.get('id') or info.get('activityId')
     course_info_id = info['courseInfoId']
     file_url = json.loads(info['fileUrl'])['url']
     if file_type in ["img", "图文"]:
@@ -126,6 +173,12 @@ def study_record(session, info, class_id):
         sleep_randint = random.randint(5, 10)
         logging.info('\t\t\t\t\t\t学习课件中... 课程: %s 延时: %s 结果: %s', name, sleep_randint, resp_result)
         time.sleep(sleep_randint)
+    # elif file_type == "audio":
+    #     audio_time = content_audio(session, course_id, course_id)
+    #     audio_time_sec = time_to_seconds(audio_time)
+    #     resp_result = stu_process_cell_log(session, course_info_id, class_id, audio_time_sec, course_id, audio_time)
+    #     logging.info('\t\t\t\t\t\t学习课件中... 课程: %s 延时: %s 结果: %s', name, sleep_randint, resp_result)
+    #     time.sleep(sleep_randint)
     elif file_type == "video":
         video_time = get_video_time(session, file_url)['args']['duration']
         total_seconds = int(sum(float(x) * 60 ** i for i, x in enumerate(reversed(video_time.split(':')))))
@@ -138,7 +191,85 @@ def study_record(session, info, class_id):
         logging.info("\t\t\t\t\t\t文件类型不支持请提交反馈进行适配: %s, 课程: %s", file_type, name)
 
 
+def process_standard_course(session, i):
+    """处理标准课程"""
+    # 一级目录
+    moduleList1 = get_process_list(session, i['courseId'], i['courseInfoId'], i['classId'], 0, 1)
+
+    for j in moduleList1:
+        time.sleep(random.uniform(0.5, 1))
+        if j['speed'] == 100:
+            logging.info("\t%s 课程已刷进度 100", j['name'])
+            continue
+        logging.info("\t%s", j['name'])
+        # 二级目录
+        moduleList2 = get_process_list(session, i['courseId'], i['courseInfoId'], i['classId'], j['id'], 2)
+        for k in moduleList2:
+            # time.sleep(random.uniform(0.5, 1))
+            logging.info("\t\t%s", k['name'])
+            # 三级目录
+            moduleList3 = get_process_list(session, i['courseId'], i['courseInfoId'], i['classId'], k['id'], 3)
+            for m in moduleList3:
+                # time.sleep(random.uniform(0.5, 1))
+                if m['speed'] == 100:
+                    logging.info("\t\t\t%s 课程已刷进度 100", m['name'])
+                    continue
+                logging.info("\t\t\t\t%s", m['name'])
+                # 如果只有三级目录
+                if not m.get('children') or not len(m.get('children', [])):
+                    # 如果课程完成-不刷课
+                    if m['speed'] == 100:
+                        logging.info("\t\t\t\t\t%s 课程已刷进度 100%", m['name'])
+                        continue
+                    # 将信息拿去刷课
+                    try:
+                        study_record(session, m, i['classId'])
+                    except Exception as e:
+                        logging.error("错误跳过: %s", e)
+                        # 四级目录(最终)
+                else:
+                    for n in m.get('children', []):
+                        # time.sleep(random.uniform(1, 1.5))
+                        # 如果课程完成-不刷课
+                        if n['speed'] == 100:
+                            logging.info("\t\t\t\t\t%s 课程已刷进度 100", n['name'])
+                            continue
+                        # 将信息拿去刷课
+
+                        try:
+                            study_record(session, n, i['classId'])
+                        except Exception as e:
+                            logging.error("错误跳过: %s", e)
+
+
+def process_fast_course(session, i):
+    """处理快速课程"""
+    moduleList1 = get_process_list_fast(session, i['courseId'], i['courseInfoId'], i['classId'])
+    for k in moduleList1.get('rows', []):
+        # time.sleep(random.uniform(0.5, 1))
+        logging.info("\t\t%s %s 活动: %s", k['dateStr'], k['name'], k['num'])
+        # 进入级目录
+        moduleList2 = get_process_list(session, i['courseId'], i['courseInfoId'], i['classId'], k.get('id'), 3,
+                                       k['dateStr'])
+        for m in moduleList2.get('data', []):
+            # time.sleep(random.uniform(0.5, 1))
+            if m['speed'] == 100:
+                logging.info("\t\t\t%s 课程已刷进度 100", m['title'])
+                continue
+            logging.info("\t\t\t\t%s", m['title'])
+            # 如果课程完成-不刷课
+            if m['speed'] == 100:
+                logging.info("\t\t\t\t\t%s 课程已刷进度 100%", m['title'])
+                continue
+            # 将信息拿去刷课
+            try:
+                study_record(session, m, i['classId'])
+            except Exception as e:
+                logging.error("错误跳过: %s", e)
+
+
 def start(session, jump_content):
+    global is_fast
     separator = "*" * 40
     logger.info(separator)
     logger.info(f"运行信息")
@@ -169,50 +300,11 @@ def start(session, jump_content):
             logger.info("\t匹配到过滤条件: %s - 跳过", i['courseName'])
             continue
         time.sleep(random.uniform(1, 1.5))
-        # 一级目录
-        moduleList1 = get_process_list(session, i['courseId'], i['courseInfoId'], i['classId'], 0, 1)
-
-        for j in moduleList1:
-            time.sleep(random.uniform(0.5, 1))
-            if j['speed'] == 100:
-                logging.info("\t%s 课程已刷进度 100", j['name'])
-                continue
-            logging.info("\t%s", j['name'])
-            # 二级目录
-            moduleList2 = get_process_list(session, i['courseId'], i['courseInfoId'], i['classId'], j['id'], 2)
-            for k in moduleList2:
-                # time.sleep(random.uniform(0.5, 1))
-                logging.info("\t\t%s", k['name'])
-                # 三级目录
-                moduleList3 = get_process_list(session, i['courseId'], i['courseInfoId'], i['classId'], k['id'], 3)
-                for m in moduleList3:
-                    # time.sleep(random.uniform(0.5, 1))
-                    if m['speed'] == 100:
-                        logging.info("\t\t\t%s 课程已刷进度 100", m['name'])
-                        continue
-                    logging.info("\t\t\t\t%s", m['name'])
-                    # 如果只有三级目录
-                    if not m.get('children') or not len(m.get('children', [])):
-                        # 如果课程完成-不刷课
-                        if m['speed'] == 100:
-                            logging.info("\t\t\t\t\t%s 课程已刷进度 100%", m['name'])
-                            continue
-                        # 将信息拿去刷课
-                        try:
-                            study_record(session, m, i['classId'])
-                        except Exception as e:
-                            logging.error("错误跳过: %s", e)
-                            # 四级目录(最终)
-                    else:
-                        for n in m.get('children', []):
-                            # time.sleep(random.uniform(1, 1.5))
-                            # 如果课程完成-不刷课
-                            if n['speed'] == 100:
-                                logging.info("\t\t\t\t\t%s 课程已刷进度 100", n['name'])
-                                continue
-                            # 将信息拿去刷课
-
-                            try:
-                                study_record(session, n, i['classId'])
-                            except Exception as e:
-                                logging.error("错误跳过: %s", e)
+        if i['isCriteria'] == 0:
+            # 快速课程
+            is_fast = True
+            process_fast_course(session, i)
+        else:
+            # 标准课程
+            is_fast = False
+            process_standard_course(session, i)