add queue

src/api/api-models.ts

@@ -62,6 +62,7 @@ export interface UserSetting {
   sendEmail: Setting_SendEmail
   questionBox: Setting_QuestionBox
   songRequest: Setting_SongRequest
+  queue: Setting_Queue
   enableFunctions: FunctionTypes[]
 
   indexTemplate: string | null
@@ -89,11 +90,55 @@ export interface Setting_SongRequest {
   tiduCooldownSecond: number
   jianzhangCooldownSecond: number
 }
+export interface Setting_Queue {
+  keyword: string
+  matchType: KeywordMatchType
+  sortType?: QueueSortType
+  queueMaxSize: number
+
+  allowAllDanmaku: boolean
+  allowFromWeb: boolean
+  needJianzhang: boolean
+  needTidu: boolean
+  needZongdu: boolean
+  fanMedalMinLevel?: number
+
+  allowGift: boolean
+  giftNames?: string[]
+  minGiftPrice?: number
+  giftFilterType: QueueGiftFilterType
+  allowIncreasePaymentBySendGift: boolean
+  allowIncreaseByAnyPayment: boolean
+
+  enableCooldown: boolean
+  cooldownSecond: number
+  zongduCooldownSecond: number
+  tiduCooldownSecond: number
+  jianzhangCooldownSecond: number
+}
+
+export enum KeywordMatchType {
+  Full,
+  Contains,
+  Regex,
+}
+
+export enum QueueSortType {
+  GuardFirst,
+  PaymentFist,
+  TimeFirst,
+}
+
+export enum QueueGiftFilterType {
+  Or,
+  And,
+}
 export enum FunctionTypes {
   SongList,
   QuestionBox,
   Schedule,
   SongRequest,
+  Queue,
 }
 export interface SongAuthorInfo {
   name: string
@@ -120,12 +165,12 @@ export interface SongsInfo {
   //paidSong: boolean
   options?: SongRequestOption
 }
-export interface SongRequestOption{
+export interface SongRequestOption {
-  needJianzhang: boolean;
+  needJianzhang: boolean
-  needTidu: boolean;
+  needTidu: boolean
-  needZongdu: boolean;
+  needZongdu: boolean
-  scMinPrice?: number;
+  scMinPrice?: number
-  fanMedalMinLevel?: number;
+  fanMedalMinLevel?: number
 }
 export enum SongLanguage {
   Chinese, // 中文
@@ -295,12 +340,12 @@ export interface SongRequestInfo {
   status: SongRequestStatus
   from: SongRequestFrom
   scPrice?: number
-  user?: SongRequestUserInfo
+  user?: DanmakuUserInfo
   createAt: number
   finishAt?: number
   isInLocal?: boolean
 }
-export interface SongRequestUserInfo {
+export interface DanmakuUserInfo {
   name: string
   uid: number
   guard_level: number
@@ -315,6 +360,12 @@ export enum SongRequestFrom {
   SC,
   Web,
 }
+export enum QueueFrom {
+  Manual,
+  Danmaku,
+  Gift,
+  Web,
+}
 
 export enum SongRequestStatus {
   Waiting,
@@ -322,6 +373,12 @@ export enum SongRequestStatus {
   Finish,
   Cancel,
 }
+export enum QueueStatus {
+  Waiting,
+  Progressing,
+  Finish,
+  Cancel,
+}
 export interface EventModel {
   type: EventDataTypes
   name: string
@@ -342,3 +399,13 @@ export enum EventDataTypes {
   Gift,
   Message,
 }
+export interface ResponseQueueModel {
+  id: number
+  status: QueueStatus
+  from: QueueFrom
+  giftPrice?: number
+  user?: DanmakuUserInfo
+  createAt: number
+  finishAt?: number | null
+  isInLocal?: boolean
+}

src/data/constants.ts

@@ -24,6 +24,7 @@ export const SCHEDULE_API_URL = `${BASE_API}schedule/`
 export const VIDEO_COLLECT_API_URL = `${BASE_API}video-collect/`
 export const OPEN_LIVE_API_URL = `${BASE_API}open-live/`
 export const SONG_REQUEST_API_URL = `${BASE_API}song-request/`
+export const QUEUE_API_URL = `${BASE_API}queue/`
 export const EVENT_API_URL = `${BASE_API}event/`
 
 export const ScheduleTemplateMap = {

src/router/index.ts

@@ -200,6 +200,16 @@ const routes: Array<RouteRecordRaw> = [
           danmaku: true,
         },
       },
+      {
+        path: 'queue',
+        name: 'manage-liveQueue',
+        component: () => import('@/views/open_live/OpenQueue.vue'),
+        meta: {
+          title: '弹幕排队',
+          keepAlive: true,
+          danmaku: true,
+        },
+      },
     ],
   },
   {
@@ -230,6 +240,14 @@ const routes: Array<RouteRecordRaw> = [
           title: '点歌',
         },
       },
+      {
+        path: 'queue',
+        name: 'open-live-queue',
+        component: () => import('@/views/open_live/OpenQueue.vue'),
+        meta: {
+          title: '排队',
+        },
+      },
     ],
   },
   {
@@ -252,6 +270,14 @@ const routes: Array<RouteRecordRaw> = [
           title: '弹幕点歌',
         },
       },
+      {
+        path: 'queue',
+        name: 'obs-queue',
+        component: () => import('@/views/obs/QueueOBS.vue'),
+        meta: {
+          title: '弹幕排队',
+        },
+      },
     ],
   },
   {

src/views/AboutView.vue

@@ -33,6 +33,9 @@ import { NButton, NCard, NDivider, NLayoutContent, NSpace, NText, NTimeline, NTi
           </NSpace>
           <NDivider title-placement="left"> 更新日志 </NDivider>
           <NTimeline>
+            <NTimelineItem type="success" title="功能添加" content="排队" time="2023-11-25" />
+            <NTimelineItem type="success" title="功能添加" content="点歌" time="2023-11-20" />
+            <NTimelineItem type="success" title="上架幻星平台" content="如题" time="2023-11-4" />
             <NTimelineItem type="success" title="功能添加" content="视频征集" time="2023-10-30" />
             <NTimelineItem type="info" title="功能更新" content="日程表添加 '粉粉' 模板" time="2023-10-27" />
             <NTimelineItem type="info" title="功能更新" content="提问箱新增公开选项" time="2023-10-26" />

src/views/IndexView.vue

@@ -43,6 +43,11 @@ const functions = [
     desc: '可以让弹幕进行点歌!',
     icon: ListCircle,
   },
+  {
+    name: '弹幕排队',
+    desc: '通过发送弹幕和礼物加入队列, 允许设置多种条件',
+    icon: ListCircle,
+  },
   {
     name: '视频征集',
     desc: '创建用来收集视频链接的页面, 可以从动态爬取, 也可以提前对视频进行筛选',

src/views/ManageLayout.vue

@@ -22,7 +22,7 @@ import {
 } from 'naive-ui'
 import { h, onMounted, ref } from 'vue'
 import { BrowsersOutline, Chatbox, Moon, MusicalNote, Sunny, AnalyticsSharp } from '@vicons/ionicons5'
-import { CalendarClock24Filled, Chat24Filled, Info24Filled, Lottery24Filled, VehicleShip24Filled, VideoAdd20Filled } from '@vicons/fluent'
+import { CalendarClock24Filled, Chat24Filled, Info24Filled, Lottery24Filled, PeopleQueue24Filled, VehicleShip24Filled, VideoAdd20Filled } from '@vicons/fluent'
 import { isLoadingAccount, useAccount } from '@/api/account'
 import RegisterAndLogin from '@/components/RegisterAndLogin.vue'
 import { RouterLink, useRoute } from 'vue-router'
@@ -229,7 +229,7 @@ const menuOptions = [
                 name: 'manage-liveLottery',
               },
             },
-            { default: () => '直播抽奖' }
+            { default: () => '抽奖' }
           ),
         key: 'manage-liveLottery',
         icon: renderIcon(Lottery24Filled),
@@ -249,6 +249,20 @@ const menuOptions = [
         key: 'manage-songRequest',
         icon: renderIcon(MusicalNote),
         //disabled: accountInfo.value?.isEmailVerified == false,
+      },{
+        label: () =>
+          h(
+            RouterLink,
+            {
+              to: {
+                name: 'manage-liveQueue',
+              },
+            },
+            { default: () => '排队' }
+          ),
+        key: 'manage-liveQueue',
+        icon: renderIcon(PeopleQueue24Filled),
+        //disabled: accountInfo.value?.isEmailVerified == false,
       },
     ],
   },

src/views/OpenLiveLayout.vue

@@ -2,7 +2,7 @@
 import { isDarkMode } from '@/Utils'
 import { OpenLiveInfo, ThemeType } from '@/api/api-models'
 import DanmakuClient, { AuthInfo } from '@/data/DanmakuClient'
-import { Lottery24Filled } from '@vicons/fluent'
+import { Lottery24Filled, PeopleQueue24Filled } from '@vicons/fluent'
 import { Moon, MusicalNote, Sunny } from '@vicons/ionicons5'
 import { useElementSize, useStorage } from '@vueuse/core'
 import {
@@ -74,6 +74,20 @@ const menuOptions = [
       ),
     key: 'open-live-song-request',
     icon: renderIcon(MusicalNote),
+  },{
+    label: () =>
+      h(
+        RouterLink,
+        {
+          to: {
+            name: 'open-live-queue',
+            query: route.query,
+          },
+        },
+        { default: () => '排队' }
+      ),
+    key: 'open-live-queue',
+    icon: renderIcon(PeopleQueue24Filled),
   },
 ]
 

src/views/manage/SettingsManageView.vue

@@ -284,6 +284,8 @@ onMounted(async () => {
             <NCheckbox :value="FunctionTypes.SongList"> 歌单 </NCheckbox>
             <NCheckbox :value="FunctionTypes.QuestionBox"> 提问箱(棉花糖 </NCheckbox>
             <NCheckbox :value="FunctionTypes.Schedule"> 日程 </NCheckbox>
+            <NCheckbox :value="FunctionTypes.SongRequest"> 点歌 </NCheckbox>
+            <NCheckbox :value="FunctionTypes.Queue"> 排队 </NCheckbox>
           </NCheckboxGroup>
           <NDivider> 通知 </NDivider>
           <NSpace>

src/views/obs/QueueOBS.vue

@@ -0,0 +1,368 @@
+<script setup lang="ts">
+import { QueueFrom, QueueSortType, ResponseQueueModel, Setting_Queue, Setting_SongRequest, SongRequestFrom, SongRequestInfo, QueueStatus } from '@/api/api-models'
+import { QueryGetAPI } from '@/api/query'
+import { AVATAR_URL, QUEUE_API_URL, SONG_REQUEST_API_URL } from '@/data/constants'
+import { useElementSize } from '@vueuse/core'
+import { computed, onMounted, onUnmounted, ref } from 'vue'
+import { useRoute } from 'vue-router'
+import { Vue3Marquee } from 'vue3-marquee'
+import { NCard, NDivider, NEmpty, NSpace, NText, useMessage } from 'naive-ui'
+import { List } from 'linqts'
+
+const props = defineProps<{
+  id?: number
+}>()
+
+const message = useMessage()
+const route = useRoute()
+const currentId = computed(() => {
+  return props.id ?? route.query.id
+})
+
+const listContainerRef = ref()
+const footerRef = ref()
+const footerListRef = ref()
+const { height, width } = useElementSize(listContainerRef)
+const footerSize = useElementSize(footerRef)
+const footerListSize = useElementSize(footerListRef)
+const itemHeight = 40
+
+const key = ref(Date.now())
+
+const queue = ref<ResponseQueueModel[]>([])
+const settings = ref<Setting_Queue>({} as Setting_Queue)
+const progressing = computed(() => {
+  return queue.value.find((s) => s.status == QueueStatus.Progressing)
+})
+const activeItems = computed(() => {
+  let list = new List(queue.value).Where((q) => q?.status == QueueStatus.Waiting).OrderByDescending((q) => q.from == QueueFrom.Manual)
+  switch (settings.value.sortType) {
+    case QueueSortType.TimeFirst: {
+      list = list.OrderByDescending((q) => q.createAt)
+      break
+    }
+    case QueueSortType.GuardFirst: {
+      list = list.OrderBy((q) => q.user?.guard_level).ThenByDescending((q) => q.createAt)
+      break
+    }
+    case QueueSortType.PaymentFist: {
+      list = list.OrderByDescending((q) => q.giftPrice ?? 0).ThenByDescending((q) => q.createAt)
+    }
+  }
+  return list.ToArray()
+})
+
+async function get() {
+  try {
+    const data = await QueryGetAPI<{ queue: ResponseQueueModel[]; setting: Setting_Queue }>(QUEUE_API_URL + 'get-active-and-settings', {
+      id: currentId.value,
+    })
+    if (data.code == 200) {
+      return data.data
+    }
+  } catch (err) {
+    console.error(err)
+  }
+  return {} as { queue: ResponseQueueModel[]; setting: Setting_Queue }
+}
+const isMoreThanContainer = computed(() => {
+  return queue.value.length * itemHeight > height.value
+})
+const allowGuardTypes = computed(() => {
+  const types = []
+  if (settings.value.needTidu) {
+    types.push('提督')
+  }
+  if (settings.value.needZongdu) {
+    types.push('总督')
+  }
+  if (settings.value.needJianzhang) {
+    types.push('舰长')
+  }
+  return types
+})
+async function update() {
+  const r = await get()
+  if (r) {
+    queue.value = r.queue.sort((a, b) => {
+      return b.createAt - a.createAt
+    })
+    settings.value = r.setting
+  }
+}
+
+let timer: any
+onMounted(() => {
+  update()
+  timer = setInterval(update, 2000)
+})
+onUnmounted(() => {
+  clearInterval(timer)
+})
+</script>
+
+<template>
+  <div class="queue-background" v-bind="$attrs">
+    <p class="queue-header">排队</p>
+    <NDivider class="queue-divider">
+      <p class="queue-header-count">已有 {{ activeItems.length ?? 0 }} 人</p>
+    </NDivider>
+    <div class="queue-singing-container" :singing="queue.findIndex((s) => s.status == QueueStatus.Progressing) > -1" :from="(progressing?.from as number)" :status="(progressing?.status as number)">
+      <div class="queue-singing-prefix"></div>
+      <template v-if="progressing">
+        <img class="queue-singing-avatar" :src="AVATAR_URL + progressing?.user?.uid" referrerpolicy="no-referrer" />
+        <p class="queue-singing-name">{{ progressing?.user?.name }}</p>
+      </template>
+      <div v-else class="queue-singing-empty">空闲中</div>
+      <div class="queue-singing-suffix"></div>
+    </div>
+    <div class="queue-content" ref="listContainerRef">
+      <template v-if="activeItems.length > 0">
+        <Vue3Marquee class="queue-list" :key="key" vertical :pause="!isMoreThanContainer" :duration="20" :style="`height: ${height}px;width: ${width}px;`">
+          <span class="queue-list-item" :from="(item.from as number)" :status="(item.status as number)" :payment="item.giftPrice ?? 0" v-for="item in activeItems" :key="item.id" :style="`height: ${itemHeight}px`">
+            <div class="queue-list-item-level" :has-level="(item.user?.fans_medal_level ?? 0) > 0">
+              {{ item.user?.fans_medal_level }}
+            </div>
+            <div class="queue-list-item-user-name">
+              {{ item.user?.name }}
+            </div>
+            <p class="queue-list-item-payment">{{ item.from == QueueFrom.Manual ? '主播添加' : item.giftPrice == undefined ? '无' : '¥ ' + item.giftPrice }}</p>
+          </span>
+        </Vue3Marquee>
+      </template>
+      <div v-else style="position: relative; top: 20%">
+        <NEmpty class="queue-empty" description="暂无人排队" />
+      </div>
+    </div>
+    <div class="queue-footer" ref="footerRef">
+      <Vue3Marquee :key="key" ref="footerListRef" class="queue-footer-marquee" :pause="footerSize.width < footerListSize.width" :duration="20">
+        <span class="queue-tag" type="prefix">
+          <div class="queue-tag-key">关键词</div>
+          <div class="queue-tag-value">
+            {{ settings.keyword }}
+          </div>
+        </span>
+        <span class="queue-tag" type="prefix">
+          <div class="queue-tag-key">允许</div>
+          <div class="queue-tag-value">
+            {{ settings.allowAllDanmaku ? '所有弹幕' : allowGuardTypes.length > 0 ? allowGuardTypes.join(',') : '无' }}
+          </div>
+        </span>
+        <span class="queue-tag" type="gift">
+          <div class="queue-tag-key">通过礼物</div>
+          <div class="queue-tag-value">
+            {{ settings.allowGift ? '允许' : '不允许' }}
+          </div>
+        </span>
+        <span class="queue-tag" type="gift-price">
+          <div class="queue-tag-key">最低价格</div>
+          <div class="queue-tag-value">
+            {{ settings.minGiftPrice ? '> ¥' + settings.minGiftPrice : '任意' }}
+          </div>
+        </span>
+        <span class="queue-tag" type="gift-type">
+          <div class="queue-tag-key">礼物名</div>
+          <div class="queue-tag-value">
+            {{ settings.giftNames ? settings.giftNames.join(', ') : '无' }}
+          </div>
+        </span>
+        <span class="queue-tag" type="fan-madel">
+          <div class="queue-tag-key">粉丝牌</div>
+          <div class="queue-tag-value">
+            {{ settings.fanMedalMinLevel != undefined && !settings.allowAllDanmaku ? (settings.fanMedalMinLevel > 0 ? '> ' + settings.fanMedalMinLevel : '佩戴') : '无需' }}
+          </div>
+        </span></Vue3Marquee
+      >
+    </div>
+  </div>
+</template>
+
+<style scoped>
+.queue-background {
+  display: flex;
+  flex-direction: column;
+  height: 100%;
+  width: 100%;
+  min-height: 100px;
+  min-width: 100px;
+  background-color: #0f0f0f48;
+  border-radius: 10px;
+  color: white;
+}
+.queue-header {
+  margin: 0;
+  color: #fff;
+  text-align: center;
+  font-size: 20px;
+  font-weight: bold;
+  text-shadow: 0 0 10px #ca7b7b6e, 0 0 20px #ffffff8e, 0 0 30px #61606086, 0 0 40px rgba(64, 156, 179, 0.555);
+}
+.queue-header-count {
+  color: #ffffffbd;
+  text-align: center;
+  font-size: 14px;
+}
+.queue-divider {
+  margin: 0 auto;
+  margin-top: -15px;
+  margin-bottom: -15px;
+  width: 90%;
+}
+.queue-singing-container {
+  height: 35px;
+  margin: 0 10px 0 10px;
+  display: flex;
+  align-items: center;
+  gap: 10px;
+}
+.queue-singing-empty {
+  font-weight: bold;
+  font-style: italic;
+  color: #ffffffbe;
+}
+.queue-singing-prefix {
+  border: 2px solid rgb(231, 231, 231);
+  height: 30px;
+  width: 10px;
+  border-radius: 10px;
+}
+.queue-singing-container[singing='true'] .queue-singing-prefix {
+  background-color: #75c37f;
+  animation: animated-border 3s linear infinite;
+}
+.queue-singing-container[singing='false'] .queue-singing-prefix {
+  background-color: #c37575;
+}
+.queue-singing-avatar {
+  height: 30px;
+  border-radius: 50%;
+  /* 添加无限旋转动画 */
+  animation: rotate 20s linear infinite;
+}
+/* 网页点歌 */
+.queue-singing-container[from='3'] .queue-singing-avatar {
+  display: none;
+}
+.queue-singing-name {
+  font-size: large;
+  font-weight: bold;
+  text-overflow: ellipsis;
+  white-space: nowrap;
+  max-width: 80%;
+}
+@keyframes rotate {
+  0% {
+    transform: rotate(0);
+  }
+  100% {
+    transform: rotate(360deg);
+  }
+}
+.n-divider__line {
+  background-color: #ffffffd5;
+}
+.queue-content {
+  background-color: #0f0f0f4f;
+  margin: 10px;
+  padding: 10px;
+  height: 100%;
+  border-radius: 10px;
+  overflow-x: hidden;
+}
+.marquee {
+  justify-items: left;
+}
+.queue-list-item {
+  display: flex;
+  width: 100%;
+  align-self: flex-start;
+  position: relative;
+  align-items: center;
+  justify-content: left;
+  gap: 10px;
+}
+.queue-list-item-user-name {
+  font-size: 18px;
+  font-weight: bold;
+  overflow: hidden;
+  text-overflow: ellipsis;
+  white-space: nowrap;
+  max-width: 80%;
+}
+
+/* 手动添加 */
+.queue-list-item[from='0'] .queue-list-item-payment {
+  font-style: italic;
+  font-weight: bold;
+  color: #d2d8d6;
+  font-size: 12px;
+}
+.queue-list-item[from='0'] .queue-list-item-avatar {
+  display: none;
+}
+
+/* 弹幕点歌 */
+.queue-list-item[payment='0']  .queue-list-item-payment{
+  display: none;
+}
+
+.queue-list-item-payment {
+  font-style: italic;
+  font-size: 12px;
+  color: rgba(233, 165, 165, 0.993);
+  text-overflow: ellipsis;
+  white-space: nowrap;
+
+  margin-left: auto;
+}
+.queue-list-item-level {
+  text-align: center;
+  height: 18px;
+  padding: 2px;
+  min-width: 15px;
+  border-radius: 5px;
+  background-color: #0f0f0f48;
+  color: rgba(204, 204, 204, 0.993);
+  font-size: 12px;
+}
+.queue-list-item-level[has-level='false'] {
+  display: none;
+}
+.queue-footer {
+  margin: 0 5px 5px 5px;
+  height: 60px;
+  border-radius: 5px;
+  background-color: #0f0f0f4f;
+  display: flex;
+  align-items: center;
+}
+.queue-tag {
+  display: flex;
+  margin: 5px 0 5px 5px;
+  height: 40px;
+  border-radius: 3px;
+  background-color: #0f0f0f4f;
+  padding: 4px;
+  padding-right: 6px;
+  display: flex;
+  flex-direction: column;
+  justify-content: left;
+}
+.queue-tag-key {
+  font-style: italic;
+  color: rgb(211, 211, 211);
+  font-size: 12px;
+}
+.queue-tag-value {
+  font-size: 14px;
+}
+@keyframes animated-border {
+  0% {
+    box-shadow: 0 0 0px #589580;
+  }
+
+  100% {
+    box-shadow: 0 0 0 6px rgba(255, 255, 255, 0);
+  }
+}
+</style>

src/views/open_live/MusicRequest.vue

@@ -10,7 +10,7 @@ import {
   SongRequestFrom,
   SongRequestInfo,
   SongRequestStatus,
-  SongRequestUserInfo,
+  DanmakuUserInfo,
   SongsInfo,
 } from '@/api/api-models'
 import { QueryGetAPI, QueryPostAPI, QueryPostAPIWithParams } from '@/api/query'
@@ -241,7 +241,7 @@ async function addSong(danmaku: EventModel) {
         fans_medal_name: danmaku.fans_medal_name,
         fans_medal_wearing_status: danmaku.fans_medal_wearing_status,
         guard_level: danmaku.guard_level,
-      } as SongRequestUserInfo,
+      } as DanmakuUserInfo,
       createAt: Date.now(),
       isInLocal: true,
       id: songs.value.length == 0 ? 1 : new List(songs.value).Max((s) => s.id) + 1,

src/views/open_live/OpenLiveIndex.vue

@@ -27,6 +27,12 @@ const accountInfo = useAccount()
         <NButton @click="$router.push({ name: 'open-live-song-request', query: $route.query })" type="primary"> 前往使用 </NButton>
       </template>
     </NCard>
+    <NCard hoverable embedded size="small" title="弹幕排队" style="width: 300px">
+      通过发送弹幕或者礼物进行排队, 允许设置多种条件
+      <template #footer>
+        <NButton @click="$router.push({ name: 'open-live-queue', query: $route.query })" type="primary"> 前往使用 </NButton>
+      </template>
+    </NCard>
   </NSpace>
   <br />
   <NAlert v-if="accountInfo?.eventFetcherOnline != true" type="warning" title="可用性警告" style="max-width: 600px; margin: 0 auto">