refactor: 检测是否已经发送过随机动态(#71)

* 优化随机动态发送逻辑
* 修复随机动态的部分bug

lib/helper/randomDynamic.js

@@ -8,32 +8,36 @@ const utils = require("../utils");
  * @returns
  */
 async function randomDynamic(num) {
-    const { create_dy_type, dy_contents, random_dynamic_wait } = config;
+    let dynamics = []
+    const
+        { create_dy_type, dy_contents, random_dynamic_wait } = config,
+        hasShareVideo = create_dy_type === -1 || create_dy_type === 1,
+        hasRandomCreate = create_dy_type === -1 || create_dy_type === 0 || typeof create_dy_type === 'undefined';
 
-    if (create_dy_type === -1 || create_dy_type === 0 || typeof create_dy_type === 'undefined') {
+    if (hasShareVideo) {
+        dynamics = await bili.getTopRcmd()
+        for (let index = 0; dynamics.length < num; index++) {
+            dynamics.push(...await bili.getTopRcmd())
+        }
+    }
+
+    if (hasRandomCreate) {
         for (let index = 0; index < num; index++) {
-            await bili.createDynamic(utils.getRandomOne(dy_contents));
-            await utils.delay(random_dynamic_wait);
+            dynamics.push(utils.getRandomOne(dy_contents))
         }
     }
 
-    if (create_dy_type === -1 || create_dy_type === 1) {
-        let videos = await bili.getTopRcmd()
-        for (let index = 0; videos.length < num; index++) {
-            videos.push(...await bili.getTopRcmd())
-        }
-
-        await utils.try_for_each(videos, async ([uid, aid]) => {
-            if (num--) {
-                await bili.shareVideo(uid, aid)
-                await utils.delay(random_dynamic_wait)
-                return false
+    await utils.try_for_each(
+        utils.shuffle(dynamics).slice(0, num),
+        async (dynamic) => {
+            await utils.delay(random_dynamic_wait)
+            if (dynamic instanceof Array && dynamic.length === 2 && typeof dynamic[0] === "number") {
+                return await bili.shareVideo(...dynamic)
             } else {
-                return true
+                return await bili.createDynamic(utils.getRandomOne(dy_contents))
             }
-        })
-    }
+        }
+    )
 }
 
-
 module.exports = { randomDynamic }

lib/lottery.js

@@ -10,8 +10,10 @@ const { log } = utils;
 async function createRandomDynamic(num) {
     if (config.create_dy) {
         log.info('随机动态', `准备创建${num}条随机动态`);
-        const Dynamic = await Searcher.checkAllDynamic(global_var.get("myUID"), 1);
-        if ((Dynamic.allModifyDynamicResArray[0] || { type: 0 }).type === 1) {
+        const
+            { allModifyDynamicResArray } = await Searcher.checkAllDynamic(global_var.get("myUID"), 1),
+            { type, orig_type } = allModifyDynamicResArray[0] || {};
+        if (type === 1 && orig_type !== 8) {
             await randomDynamic(num)
         } else {
             log.info('随机动态', '已有非抽奖动态故无需创建');

lib/net/bili.js

@@ -760,7 +760,7 @@ const bili_client = {
      * @property {number} img_height
      * 发布一条动态
      * @param { string | Picture[] } content
-     * @return {Promise<void>}
+     * @return {Promise<boolean>} isError true
      */
     async createDynamic(content) {
         let
@@ -790,8 +790,10 @@ const bili_client = {
         });
         if (/^{"code":0/.test(responseText)) {
             log.info('发布动态', `成功创建一条随机内容的动态\n${JSON.stringify(content)}\n`);
+            return false
         } else {
             log.error('发布动态', `发布动态失败\n${JSON.stringify(content)}\n${responseText}`);
+            return true
         }
     },
     /**
@@ -820,6 +822,7 @@ const bili_client = {
      * 分享视频
      * @param {number} uid
      * @param {number} aid
+     * @return {boolean} isError true
      */
     async shareVideo(uid, aid) {
         const responseText = await post({
@@ -836,8 +839,10 @@ const bili_client = {
         });
         if (/^{"code":0/.test(responseText)) {
             log.info('转发视频', `成功转发视频(av${aid})`);
+            return false
         } else {
             log.error('转发视频', `转发失败\n${responseText}`);
+            return true
         }
     },
     /**