import {
  ContentDetailDTO,
  GetPullAddressBean,
  LiveDetailsBean,
  LiveRoomBean,
  LiveRoomDataBean,
  LiveRoomItemBean,
  ValueType
} from 'wdBean/Index'
import { LiveMessageIsHistoryMessage, LiveMessageOptType } from 'wdBean/src/main/ets/bean/live/LiveRoomBean'
import { SpConstants } from 'wdConstant'
import { ContentDetailRequest } from 'wdDetailPlayApi/Index'
import { DateTimeUtils, LazyDataSource, Logger, SPHelper } from 'wdKit/Index'
import { ToastUtils } from 'wdKit/src/main/ets/utils/ToastUtils'
import { HttpUtils, ResponseDTO } from 'wdNetwork/Index'
import { LiveModel } from './LiveModel'
import { ArrayList } from '@kit.ArkTS'

const TAG = "LiveViewModel"

export class LiveViewModel {
  liveModel: LiveModel

  constructor() {
    this.liveModel = new LiveModel()
  }

  // 视频信息
  getContentDetail(contentId: string, relId: string, relType: string) {
    return new Promise<Array<ContentDetailDTO>>((success, fail) => {
      this.liveModel.getContentDetail(contentId, relId, relType).then((data) => {
        //console.error("XXXXZZZZ", '---getContentDetail---1------------')
        success(data)
      }).catch((message: string) => {
        // console.error("XXXXZZZZ", '----getContentDetail--2------------')
        fail(message)
      })
    })

  }

  /**
   *  获取直播间的拉流地址
   * @param vliveId
   * @returns
   */
  async getLiveRoomPullAddress(vliveId: string): Promise<GetPullAddressBean | null> {

    return new Promise<GetPullAddressBean | null>((success, fail) => {
      ContentDetailRequest.getLiveRoomPullStream(vliveId)
        .then(async (resDTO: ResponseDTO<GetPullAddressBean>) => {
          console.log(TAG, 'getContentDetail:', JSON.stringify(resDTO.data))
          if (resDTO.data) {
            success(resDTO.data)
          } else {
            success(null)
          }
        })
        .catch(() => {
          success(null)
        })

    })

  }

  //直播详情
  getLiveDetails(contentId: string, relId: string, relType: string) {
    return new Promise<Array<LiveDetailsBean>>((success, fail) => {
      this.liveModel.getLiveDetails(contentId, relId, relType).then((data) => {
        success(data)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  //直播详情直播间数据列表
  getLiveList(pageNum: number, mLiveId: string, liveId: string, pageSize: number) {
    return new Promise<LiveRoomBean>((success, fail) => {
      this.liveModel.getLiveList(pageNum, mLiveId, liveId, pageSize).then((data) => {
        success(data)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  //直播详情大家聊数据列表
  getLiveChatList(pageNum: number, mLiveId: string, liveId: string, pageSize: number) {
    return new Promise<LiveRoomBean>((success, fail) => {
      this.liveModel.getLiveChatList(pageNum, mLiveId, liveId, pageSize).then((data) => {
        success(data)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  //C端评论列表  竖屏直播间
  getLiveCommentList(pageNum: number, mLiveId: string, liveId: string, pageSize: number) {
    return new Promise<LiveRoomBean>((success, fail) => {
      this.liveModel.getLiveCommentList(pageNum, mLiveId, liveId, pageSize).then((data) => {
        success(data)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  //直播详情直播间数据
  getLiveRoomData(liveId: string) {
    return new Promise<LiveRoomDataBean>((success, fail) => {
      this.liveModel.getLiveRoomData(liveId).then((data) => {
        success(data)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  // 直播详情-C端点赞接口
  getLiveRoomNumberLike(liveId: string, number: number, deviceId: string | number) {
    return new Promise<number>((success, fail) => {
      this.liveModel.getLiveRoomNumberLike(liveId, number, deviceId).then((data) => {
        success(data)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  // 直播详情-查询是否点赞接口
  getLiveLike(liveId: string, userId: ValueType, deviceId: string | number) {
    return new Promise<boolean>((success, fail) => {
      this.liveModel.getLiveLike(liveId, userId, deviceId).then((data) => {
        success(data)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  //直播预约状态查询
  getLiveAppointmentStatus(relationId: string, liveId: string) {
    return new Promise<boolean>((success, fail) => {
      this.liveModel.getLiveAppointmentStatus(relationId, liveId).then((data) => {
        success(data)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  //直播预约/取消预约
  liveAppointment(relationId: string, liveId: string, isSubscribe: boolean) {
    return new Promise<ResponseDTO<string>>((success, fail) => {
      this.liveModel.liveAppointment(relationId, liveId, isSubscribe).then((data) => {
        success(data)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  // 发送评论
  sendComment(comment: string, content: ContentDetailDTO) {
    return new Promise<LiveRoomItemBean | undefined>((success, fail) => {
      this.liveModel.liveSendComment(comment, content).then((data) => {
        Logger.debug(TAG, "发送评论结果: " + JSON.stringify(data))
        if (data.preDisplay) {
          success(data.commentItem)
        } else {
          success(undefined)
        }
        ToastUtils.showToast(data.tipMessage, 3000)
      }).catch((message: string) => {
        fail(message)
      })
    })
  }

  deepCopyLiveRoomItem(item: LiveRoomItemBean) {
    return item
    let retItem: LiveRoomItemBean = {} as LiveRoomItemBean
    retItem.text = item.text
    retItem.senderUserAvatarUrl = item.senderUserAvatarUrl
    retItem.senderUserName = item.senderUserName
    retItem.pictureUrls = item.pictureUrls
    retItem.time = item.time
    retItem.isWall = item.isWall
    retItem.isTop = item.isTop
    retItem.dataType = item.dataType
    retItem.transcodeImageUrl = item.transcodeImageUrl
    retItem.videoUrl = item.videoUrl
    retItem.pictureResolutions = item.pictureResolutions
    retItem.duration = item.duration
    retItem.audioUrl = item.audioUrl
    retItem.fullColumnImgUrlDto = item.fullColumnImgUrlDto
    return retItem
  }

  filterMySelfCommentNoPreDisplay(comment: LiveRoomItemBean, openPreDisplay:boolean) {
    let mySelf = false
    const userId = HttpUtils.getUserId()
    const deviceId = HttpUtils.getDeviceId()
    if (comment.senderUserId && comment.senderUserId == userId) {
      mySelf = true
    } else if (comment.deviceId && comment.deviceId == deviceId) {
      mySelf = true
    }
    let optionType = comment.optionType != undefined ? comment.optionType : comment.dataType

    if (mySelf
      && openPreDisplay
      && comment.customFormIM === true
      && LiveMessageIsHistoryMessage(optionType)
    ) {
      return true
    }
    return false
  }

  isMySelfComment(comment: LiveRoomItemBean) {
    let mySelf = false
    const userId = HttpUtils.getUserId()
    const deviceId = HttpUtils.getDeviceId()
    if (comment.senderUserId && comment.senderUserId == userId) {
      mySelf = true
    } else if (comment.deviceId && comment.deviceId == deviceId) {
      mySelf = true
    }
    return mySelf
  }

  getLiveRoomItemBeanIndex(liveRoomItemBean:LiveRoomItemBean, dataSource:LazyDataSource<LiveRoomItemBean>):number {
    let index = 0
    for (let i = dataSource.totalCount() - 1; i >= 0; i--) {
      const  currentLiveRoomBean = dataSource.get(i);
      if (currentLiveRoomBean.id == liveRoomItemBean.id) {
        index = i
      }
    }
    return index
  }
  ///处理置顶/取消置顶消息
  sortLiveRoomItemBean(liveRoomItemBean:LiveRoomItemBean, dataSource:LazyDataSource<LiveRoomItemBean>):LazyDataSource<LiveRoomItemBean> {
    if (liveRoomItemBean.optionType == LiveMessageOptType.ZH_TOP_MSG || liveRoomItemBean.optionType == LiveMessageOptType.ZH_UN_TOP_MSG) {
      const index = this.getLiveRoomItemBeanIndex(liveRoomItemBean, dataSource);
      const currentLiveRoomItemBean = dataSource.get(index)
      currentLiveRoomItemBean.isTop = liveRoomItemBean.isTop
      dataSource.deleteItem(index)
      dataSource.addFirstItem(currentLiveRoomItemBean)
    }else {
      if (LiveMessageIsHistoryMessage(liveRoomItemBean.optionType != undefined ? liveRoomItemBean.optionType :
                                                                                liveRoomItemBean.dataType)) {
        dataSource.addItem(liveRoomItemBean)
      }
    }
    let resultMessageList: LazyDataSource<LiveRoomItemBean> = new LazyDataSource()
    let topMessageList: LazyDataSource<LiveRoomItemBean> = new LazyDataSource()
    let unTopMessageList: LazyDataSource<LiveRoomItemBean> = new LazyDataSource()
    for (let itemBean of dataSource.getDataArray()) {
      if (itemBean.isTop == 1) {
        topMessageList.push(itemBean)
      } else {
        unTopMessageList.push(itemBean)
      }
    }
    topMessageList.sort((item: LiveRoomItemBean, item2: LiveRoomItemBean) => {
      let timeStamp1 = DateTimeUtils.parseDate(item.time, DateTimeUtils.PATTERN_DATE_TIME_HYPHEN)
      let timeStamp2 = DateTimeUtils.parseDate(item2.time, DateTimeUtils.PATTERN_DATE_TIME_HYPHEN)
      return timeStamp2 - timeStamp1
    })
    unTopMessageList.sort((item: LiveRoomItemBean, item2: LiveRoomItemBean) => {
      let timeStamp1 = DateTimeUtils.parseDate(item.time, DateTimeUtils.PATTERN_DATE_TIME_HYPHEN)
      let timeStamp2 = DateTimeUtils.parseDate(item2.time, DateTimeUtils.PATTERN_DATE_TIME_HYPHEN)
      return timeStamp2 - timeStamp1
    })
    resultMessageList.addItems(topMessageList.getDataArray())
    resultMessageList.addItems(unTopMessageList.getDataArray())
    return resultMessageList
  }
}