Spaces:

Bread-F
/

Intelligent-Medical-Guidance-Large-Model

Sleeping

Intelligent-Medical-Guidance-Large-Model / frontend /src /api /streamingRoom.ts

FAYO

model

77b0e0f almost 2 years ago

6.47 kB

import { request_handler, type ResultPackage } from '@/api/base'
import type { StreamerInfo, ProductItem } from '@/api/product'
import { header_authorization } from '@/api/user'

interface StreamingRoomProductList {
  product_id: number
  product_info: ProductItem
  start_time: string
  sales_doc: string
  start_video: string
  selected: boolean
}

interface messageItem {
  role: string
  userId: number
  userName: string
  avatar: string
  message: string
  send_time: string
}

interface StreamingRoomStatusItem {
  streamerInfo: StreamerInfo
  conversation: messageItem[]
  currentProductInfo: ProductItem
  currentStreamerVideo: string
  currentProductIndex: number
  start_time: string
  currentPoductStartTime: string
  finalProduct: boolean
  live_status: number
}

interface StreamingRoomInfo {
  room_id: number
  room_poster: string
  name: string
  streamer_id: number
  background_image: string
  prohibited_words_id: number
  product_list: StreamingRoomProductList[]
  streamer_info: StreamerInfo
  status: StreamingRoomStatusItem
}

interface RoomProductData {
  currentPage: number
  pageSize: number
  totalSize: number
  product_list: StreamingRoomProductList[]
}

interface RoomProductItem {
  name: string
  id: number
  image_path: string
  sales_doc: string
  start_video: string
  start_time: string
  selected: boolean
  heighlights: string
  selling_price: number
}

interface RoomDetailItem {
  currentPage: number
  pageSize: number
  totalSize: number
  product_list: StreamingRoomProductList[]
  streamer_info: StreamerInfo
  room_id: number
  name: string
  room_poster: string
  streamer_id: number
  background_image: string
  prohibited_words_id: number
  status: StreamingRoomStatusItem
}

// 获取后端主播信息
const streamerRoomListRequest = () => {
  return request_handler<ResultPackage<StreamingRoomInfo[]>>({
    method: 'GET',
    url: '/streaming-room/list',
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 获取特定直播间的详情
const roomDetailRequest = (roomId_: string, currentPage_: number, pageSize_: number) => {
  return request_handler<ResultPackage<RoomDetailItem>>({
    method: 'GET',
    url: `/streaming-room/info/${roomId_}`,
    params: { currentPage: currentPage_, pageSize: pageSize_ },
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 添加商品的时候，获取所有商品，内含选中商品
const roomPorductAddListRequest = (roomId_: number, currentPage_: number, pageSize_: number) => {
  return request_handler<ResultPackage<RoomProductData>>({
    method: 'GET',
    url: `/streaming-room/product-edit-list/${roomId_}`,
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 添加或者更新直播间接口
const RoomCreadeOrEditRequest = async (params: RoomDetailItem) => {
  if (params.room_id === 0) {
    // 新建
    return request_handler<ResultPackage<number>>({
      method: 'POST',
      url: '/streaming-room/create',
      data: params,
      headers: {
        Authorization: header_authorization.value
      }
    })
  } else {
    // 编辑
    return request_handler<ResultPackage<number>>({
      method: 'PUT',
      url: `/streaming-room/edit/${params.room_id}`,
      data: params,
      headers: {
        Authorization: header_authorization.value
      }
    })
  }
}

// 获取直播间实时信息：主播目前的视频地址，目前讲述的商品信息，聊天信息
const onAirRoomStartRequest = (roomId_: number) => {
  return request_handler<ResultPackage<StreamingRoomStatusItem>>({
    method: 'POST',
    url: `/streaming-room/online/${roomId_}`,
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 获取直播间实时信息：主播目前的视频地址，目前讲述的商品信息，聊天信息
const onAirRoomInfoRequest = (roomId: number) => {
  return request_handler<ResultPackage<StreamingRoomStatusItem>>({
    method: 'GET',
    url: `/streaming-room/live-info/${roomId}`,
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 用户发起对话
const onAirRoomChatRequest = async (roomId_: number, message_: string) => {
  return request_handler<ResultPackage<messageItem>>({
    method: 'PUT',
    url: '/streaming-room/chat',
    data: { roomId: roomId_, message: message_ },
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 下一个商品
const onAirRoomNextProductRequest = async (roomId_: number) => {
  return request_handler<ResultPackage<StreamingRoomStatusItem>>({
    method: 'POST',
    url: `/streaming-room/next-product/${roomId_}`,
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 删除特定直播间信息
const deleteStreamingRoomByIdRequest = (roomId: number) => {
  return request_handler<ResultPackage<string>>({
    method: 'DELETE',
    url: `/streaming-room/delete/${roomId}`,
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 发送浏览器录音音频文件到服务器，用于 ASR
const sendAudioToServer = async (blob: Blob) => {
  const formData = new FormData()
  formData.append('file', blob, 'recording.webm')

  return request_handler<ResultPackage<string>>({
    method: 'POST',
    url: '/upload/file',
    data: formData,
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 获取 ASR 结果
const genAsrResult = async (roomId_: number, asrFileUrl_: string) => {
  return request_handler<ResultPackage<string>>({
    method: 'POST',
    url: '/streaming-room/asr',
    data: { roomId: roomId_, asrFileUrl: asrFileUrl_ },
    headers: {
      Authorization: header_authorization.value
    }
  })
}

// 下播
const streamRoomOffline = (roomId_: number) => {
  return request_handler<ResultPackage<string>>({
    method: 'PUT',
    url: `/streaming-room/offline/${roomId_}`,
    headers: {
      Authorization: header_authorization.value
    }
  })
}

export {
  type StreamingRoomInfo,
  type RoomProductItem,
  type RoomProductData,
  type RoomDetailItem,
  type StreamingRoomStatusItem,
  type StreamingRoomProductList,
  streamerRoomListRequest,
  roomDetailRequest,
  roomPorductAddListRequest,
  RoomCreadeOrEditRequest,
  onAirRoomInfoRequest,
  onAirRoomChatRequest,
  onAirRoomNextProductRequest,
  deleteStreamingRoomByIdRequest,
  sendAudioToServer,
  streamRoomOffline,
  genAsrResult,
  onAirRoomStartRequest
}

	import { request_handler, type ResultPackage } from '@/api/base'
	import type { StreamerInfo, ProductItem } from '@/api/product'
	import { header_authorization } from '@/api/user'

	interface StreamingRoomProductList {
	product_id: number
	product_info: ProductItem
	start_time: string
	sales_doc: string
	start_video: string
	selected: boolean
	}

	interface messageItem {
	role: string
	userId: number
	userName: string
	avatar: string
	message: string
	send_time: string
	}

	interface StreamingRoomStatusItem {
	streamerInfo: StreamerInfo
	conversation: messageItem[]
	currentProductInfo: ProductItem
	currentStreamerVideo: string
	currentProductIndex: number
	start_time: string
	currentPoductStartTime: string
	finalProduct: boolean
	live_status: number
	}

	interface StreamingRoomInfo {
	room_id: number
	room_poster: string
	name: string
	streamer_id: number
	background_image: string
	prohibited_words_id: number
	product_list: StreamingRoomProductList[]
	streamer_info: StreamerInfo
	status: StreamingRoomStatusItem
	}

	interface RoomProductData {
	currentPage: number
	pageSize: number
	totalSize: number
	product_list: StreamingRoomProductList[]
	}

	interface RoomProductItem {
	name: string
	id: number
	image_path: string
	sales_doc: string
	start_video: string
	start_time: string
	selected: boolean
	heighlights: string
	selling_price: number
	}

	interface RoomDetailItem {
	currentPage: number
	pageSize: number
	totalSize: number
	product_list: StreamingRoomProductList[]
	streamer_info: StreamerInfo
	room_id: number
	name: string
	room_poster: string
	streamer_id: number
	background_image: string
	prohibited_words_id: number
	status: StreamingRoomStatusItem
	}

	// 获取后端主播信息
	const streamerRoomListRequest = () => {
	return request_handler<ResultPackage<StreamingRoomInfo[]>>({
	method: 'GET',
	url: '/streaming-room/list',
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 获取特定直播间的详情
	const roomDetailRequest = (roomId_: string, currentPage_: number, pageSize_: number) => {
	return request_handler<ResultPackage<RoomDetailItem>>({
	method: 'GET',
	url: `/streaming-room/info/${roomId_}`,
	params: { currentPage: currentPage_, pageSize: pageSize_ },
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 添加商品的时候，获取所有商品，内含选中商品
	const roomPorductAddListRequest = (roomId_: number, currentPage_: number, pageSize_: number) => {
	return request_handler<ResultPackage<RoomProductData>>({
	method: 'GET',
	url: `/streaming-room/product-edit-list/${roomId_}`,
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 添加或者更新直播间接口
	const RoomCreadeOrEditRequest = async (params: RoomDetailItem) => {
	if (params.room_id === 0) {
	// 新建
	return request_handler<ResultPackage<number>>({
	method: 'POST',
	url: '/streaming-room/create',
	data: params,
	headers: {
	Authorization: header_authorization.value
	}
	})
	} else {
	// 编辑
	return request_handler<ResultPackage<number>>({
	method: 'PUT',
	url: `/streaming-room/edit/${params.room_id}`,
	data: params,
	headers: {
	Authorization: header_authorization.value
	}
	})
	}
	}

	// 获取直播间实时信息：主播目前的视频地址，目前讲述的商品信息，聊天信息
	const onAirRoomStartRequest = (roomId_: number) => {
	return request_handler<ResultPackage<StreamingRoomStatusItem>>({
	method: 'POST',
	url: `/streaming-room/online/${roomId_}`,
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 获取直播间实时信息：主播目前的视频地址，目前讲述的商品信息，聊天信息
	const onAirRoomInfoRequest = (roomId: number) => {
	return request_handler<ResultPackage<StreamingRoomStatusItem>>({
	method: 'GET',
	url: `/streaming-room/live-info/${roomId}`,
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 用户发起对话
	const onAirRoomChatRequest = async (roomId_: number, message_: string) => {
	return request_handler<ResultPackage<messageItem>>({
	method: 'PUT',
	url: '/streaming-room/chat',
	data: { roomId: roomId_, message: message_ },
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 下一个商品
	const onAirRoomNextProductRequest = async (roomId_: number) => {
	return request_handler<ResultPackage<StreamingRoomStatusItem>>({
	method: 'POST',
	url: `/streaming-room/next-product/${roomId_}`,
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 删除特定直播间信息
	const deleteStreamingRoomByIdRequest = (roomId: number) => {
	return request_handler<ResultPackage<string>>({
	method: 'DELETE',
	url: `/streaming-room/delete/${roomId}`,
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 发送浏览器录音音频文件到服务器，用于 ASR
	const sendAudioToServer = async (blob: Blob) => {
	const formData = new FormData()
	formData.append('file', blob, 'recording.webm')

	return request_handler<ResultPackage<string>>({
	method: 'POST',
	url: '/upload/file',
	data: formData,
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 获取 ASR 结果
	const genAsrResult = async (roomId_: number, asrFileUrl_: string) => {
	return request_handler<ResultPackage<string>>({
	method: 'POST',
	url: '/streaming-room/asr',
	data: { roomId: roomId_, asrFileUrl: asrFileUrl_ },
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	// 下播
	const streamRoomOffline = (roomId_: number) => {
	return request_handler<ResultPackage<string>>({
	method: 'PUT',
	url: `/streaming-room/offline/${roomId_}`,
	headers: {
	Authorization: header_authorization.value
	}
	})
	}

	export {
	type StreamingRoomInfo,
	type RoomProductItem,
	type RoomProductData,
	type RoomDetailItem,
	type StreamingRoomStatusItem,
	type StreamingRoomProductList,
	streamerRoomListRequest,
	roomDetailRequest,
	roomPorductAddListRequest,
	RoomCreadeOrEditRequest,
	onAirRoomInfoRequest,
	onAirRoomChatRequest,
	onAirRoomNextProductRequest,
	deleteStreamingRoomByIdRequest,
	sendAudioToServer,
	streamRoomOffline,
	genAsrResult,
	onAirRoomStartRequest
	}