Update api.py

api.py

@@ -12,7 +12,8 @@ import subprocess
 from fastapi import BackgroundTasks
 import time
 from bilibili_api import sync, video_uploader, Credential,user#bili上传部分和用户信息获取部分
-import asyncio #保证后台任务的先后
+from bilibili_api import comment#评论
+import asyncio #保证后台任务的先后 ，同时适当sleep在评论的时候
 import json #对bili_meta_data进行dumps ->str和loads—>dict
 import bilibili_api
 import random #随机获取cover
@@ -252,7 +253,14 @@ async def upload_with_random_cover(bili_meta_data:dict):
     async def ev(data):
         print(data)
 
-    await uploader.start()
+    if (await bili_status()) is True:
+        #账号登录状态才能发
+        print("当前账号登录状态:true,允许发送和评论")
+        await uploader.start()
+        await send_ad_to_comment("jm uc,简介下崽")
+        
+    else:
+        print("当前账号未登录,停止操作")
 
 
 
@@ -309,3 +317,100 @@ async def get_userInfo()->dict:
 #查看账号信息
 
 
+
+async def send_ad_to_comment(ad_comment:str):
+    try:
+        await asyncio.sleep(900)#睡15分钟左右等待投稿完成
+         credential = Credential(sessdata=sessdata,
+                            bili_jct=bili_jct,
+                            buvid3=buvid3)
+        selfUserInfo = await user.get_self_info(credential=credential)
+        selfUserName = selfUserInfo[
+            "name"
+        ]
+        selfUid = await user.name2uid_sync(selfUserName)
+        self_uid_int = selfUid['uid_list'][0]['uid']
+        print('当前uid是',self_uid_int)
+        selfUserClass = user.User(uid=self_uid_int)
+        selfVideos = await selfUserClass.get_media_list()
+        bvid_no_ad = []#记录没有写广告评论的video的bvid
+        for v in selfVideos['media_list']:
+            if (await has_ad(await get_comments(v['id']),selfUserName)) is False:
+                print("发现未广告评论的video",v,"予以记录")
+                bvid_no_ad.append(v['id'])
+        print("未广告的video bvid",bvid_no_ad)
+        for bvid in bvid_no_ad:
+            send_ad_result = await send_comment_ad(ad_comment=ad_comment,bvid=bvid,credential=credential)
+            await asyncio.sleep(10)
+            print(send_ad_result)
+    except Exception as e:
+        print("自动评论系统失败,原因是:",e)
+
+
+
+
+async def has_ad(comments:list,selfUserName:str)->bool:
+    # 打印评论
+    for cmt in comments:
+        # print(f"{cmt['member']['uname']}: {cmt['content']['message']}")
+        if cmt['member']['uname'] is selfUserName:
+            return True
+        await asyncio.sleep(10)
+        all_sub_comment = await get_sub_comments(bvid=cmt['oid'],commentID=cmt['rpid'])
+        #用str进行模糊匹配.不然直接in dict不能判断子项
+        if selfUserName in str(all_sub_comment):
+            return True
+    return False
+
+
+
+
+#根据video bvid获取评论list
+async def get_comments(bvid:int)->list:
+    # 存储评论
+    comments = []
+    # 页码
+    page = 1
+    # 当前已获取数量
+    count = 0
+    while True:
+        # 获取评论
+        c = await comment.get_comments(bvid, comment.CommentResourceType.VIDEO, page)
+        # 存储评论
+        comments.extend(c['replies'])
+        # 增加已获取数量
+        count += c['page']['size']
+        # 增加页码
+        page += 1
+        await asyncio.sleep(10)
+
+        if count >= c['page']['count']:
+            # 当前已获取数量已达到评论总数，跳出循环
+            break
+
+
+    return comments #
+
+
+#根据video bvid获取评论子评论list
+async def get_sub_comments(bvid:int,commentID:int,credential=None)->dict:
+    cmt = comment.Comment(
+        oid=bvid,
+        type_=comment.CommentResourceType.VIDEO,
+        rpid=commentID,
+        credential=credential,
+    )
+    return await cmt.get_sub_comments()
+
+
+
+#评论
+async def send_comment_ad(ad_comment:str,bvid:int,credential):
+    print("测试只回复视频而不是子评论")
+    result = await comment.send_comment(
+        ad_comment,
+        oid=bvid,
+        type_=comment.CommentResourceType.VIDEO,
+        credential=credential,
+    )
+    return result