import { CompDTO, ContentDTO, InteractDataDTO, LiveReviewDTO, PageDTO, PageInfoDTO } from 'wdBean';
import { CompStyle, ViewType } from 'wdConstant/Index';
import { CollectionUtils, DateTimeUtils, LazyDataSource, Logger, NetworkUtil, StringUtils } from 'wdKit';
import { closeRefresh } from '../utils/PullDownRefresh';
import PageModel from './PageModel';
import PageViewModel from './PageViewModel';
import { promptAction } from '@kit.ArkUI';
import { CompAdvBean } from 'wdBean/src/main/ets/bean/adv/AdvsRuleBean';
import PageAdModel from './PageAdvModel';
import { ArrayList } from '@kit.ArkTS';
import { WDViewDefaultType } from '../components/view/EmptyComponent';
import { CompAdvMatInfoBean } from 'wdBean/src/main/ets/bean/adv/CompAdvInfoBean';
import { BaseDTO } from 'wdBean/src/main/ets/bean/component/BaseDTO';
import { viewBlogInsightIntentShare, ActionMode } from '../utils/InsightIntentShare'
import { common } from '@kit.AbilityKit';
import { CacheData } from 'wdNetwork/Index';

const TAG = 'PageHelper';

/**
 * 处理返回后的数据
 */
export class PageHelper {
  /**
   * 刷新数据
   */
  async refreshUI(pageModel: PageModel, pageAdvModel: PageAdModel) {
    pageModel.loadStrategy = 2
    pageModel.pageTotalCompSize = 0;
    // TODO 下拉刷新，是否加载缓存
    this.getPageInfo(pageModel, pageAdvModel)
  }

  /**
   * 分页加载
   */
  async loadMore(pageModel: PageModel) {
    pageModel.loadStrategy = 3
    // 暂只支持comp分页加载，节目分页加载的得完善框架（如直播回看节目数据分页）
    this.compLoadMore(pageModel)
  }

  /**
   * 进页面请求数据
   */
  async getInitCacheData(pageModel: PageModel, pageAdvModel: PageAdModel) {
    Logger.error('zzzz','getInitCacheData')
    PageViewModel.getPageInfoCache(pageModel.pageId).then(pageInfo => {
      if (pageInfo == null) {
        return;
      }
      pageModel.pageInfo = pageInfo;
      //解析页面挂角广告资源
      pageAdvModel.analysisAdvSource(pageInfo);
      this.parseCacheGroup(pageModel)
    })
  }

  async parseCacheGroup(pageModel: PageModel) {
    Logger.error('zzzz','parseCacheGroup')
    let pageInfo: PageInfoDTO = pageModel.pageInfo
    pageModel.groupList = []
    pageInfo.pageAdList = []
    pageInfo.oneRequestPageGroupCompList = new ArrayList()
    pageModel.groupList.push(...pageInfo.groups)
    Logger.error("ZZZXXXXX", 'parseCacheGroup----1-----');
    for (const group of pageInfo.groups) {
      pageModel.groupId = group.id;
      pageModel.groupData = group
      Logger.error("ZZZXXXXX", '楼层id-start--》' + pageModel.groupId);
      // await，确保groups接口顺序执行
      let pageDto = await PageViewModel.getPageGroupCacheData(pageModel.bizCopy()) as PageDTO
      let index = pageInfo.groups.indexOf(group)
      if (index == 0) {
        // 清空comp列表
        pageModel.compList.clear()
      }
      this.analysisPageGroupCompData(pageModel,pageDto, pageInfo, index == pageInfo.groups.length - 1)
      Logger.error("ZZZXXXXX", '楼层id-end--》' + pageModel.groupId + '  楼层 comp数量=' + pageDto.compList.length);
    }

    // 收集页面所有楼层的组件信息，同步完成广告投放计算，异步完成稿件批查,

    pageModel.pageTotalCompSize = pageInfo.oneRequestPageGroupCompList.length + pageModel.pageTotalCompSize
    // 处理页面广告数据，投放到页面的位置
    // TODO 缓存数据不加载广告
    // this.handlePageCompAdvPostion(pageInfo.oneRequestPageGroupCompList, pageModel, pageInfo.pageAdList);

    //遍历所有组件和稿件数据 push到页面
    for (let element of pageInfo.oneRequestPageGroupCompList) {
      pageModel.compList.push(CompDTO.createNewsBean(element))
    }
    Logger.error('zzzz', 'parseCacheGroup count: ' + pageModel.compList.totalCount())
    pageModel.currentPage++
    pageModel.viewType = ViewType.LOADED
    closeRefresh(pageModel, true)

    Logger.error("ZZZXXXXX", 'parseGroup----3----->' + pageInfo.oneRequestPageGroupCompList.length);
  }

  /**
   * 进页面请求数据
   */
  async getInitData(pageModel: PageModel, pageAdvModel: PageAdModel) {
    pageModel.loadStrategy = 1
    let netStatus = NetworkUtil.isNetConnected()
    if (netStatus) {
      this.getPageInfo(pageModel, pageAdvModel)
    } else if (pageModel.compList.size() > 0) {
      // 加载缓存数据了，不用无网络提示
    } else {
      pageModel.viewType = ViewType.EMPTY;
      pageModel.emptyType = WDViewDefaultType.WDViewDefaultType_NoNetwork;
    }
  }

  getPageInfo(pageModel: PageModel, pageAdvModel: PageAdModel) {
    pageModel.currentPage = 1;
    if (pageModel.pageType == 1) {
      PageViewModel.postThemeList(pageModel.currentPage, pageModel.pageSize, pageModel.extra).then((liveReviewDTO) => {
        if (liveReviewDTO == null || liveReviewDTO.list == null || liveReviewDTO.list.length == 0) {
          pageModel.viewType = ViewType.EMPTY;
          pageModel.emptyType = WDViewDefaultType.WDViewDefaultType_NoContent1;
          return;
        } else {
          //更新数据
          pageModel.compList.addItems(liveReviewDTO.list);
          closeRefresh(pageModel, true);
        }
      }).catch((err: string | Resource) => {
        promptAction.showToast({ message: err });
      })
    } else {
      PageViewModel.getPageInfo(pageModel.pageId).then(pageInfo => {
        if (pageInfo == null) {
          pageModel.viewType = ViewType.EMPTY;
          pageModel.emptyType = WDViewDefaultType.WDViewDefaultType_NoContent1;
          return;
        }
        pageModel.pageInfo = pageInfo;
        //解析页面挂角广告资源
        pageAdvModel.analysisAdvSource(pageInfo);
        this.parseGroup(pageModel)
        // if (pageModel.currentPage == 1) {
        //   // 保存缓存
        //   CacheData.saveCacheData(CacheData.comPageInfoCacheKey + pageModel.pageId, pageInfo, pageInfo.md5)
        // }
      }).catch(() => {
        pageModel.viewType = ViewType.EMPTY;
        pageModel.emptyType = WDViewDefaultType.WDViewDefaultType_ContentFailed;
      })
    }
  }


  /**
   * 解析信息流页面楼层数据
   * @param pageModel
   */
  async parseGroup(pageModel: PageModel) {
    let pageInfo: PageInfoDTO = pageModel.pageInfo
    pageModel.groupList = []
    pageInfo.pageAdList = []
    pageInfo.oneRequestPageGroupCompList = new ArrayList()
    pageModel.groupList.push(...pageInfo.groups)
    Logger.error("ZZZXXXXX", 'parseGroup----1-----');
    for (const group of pageInfo.groups) {
      pageModel.isRecGroup = group.groupStrategy === 1;
      pageModel.groupId = group.id;
      if (pageModel.isRecGroup) {
        pageModel.pageSize = 10
      } else {
        pageModel.pageSize = 20
      }
      pageModel.groupData = group

      Logger.error("ZZZXXXXX", '楼层id-start--》' + pageModel.groupId);
      // await，确保groups接口顺序执行
      let pageDto = await PageViewModel.getPageGroupCompData(pageModel.bizCopy()) as PageDTO
      let index = pageInfo.groups.indexOf(group)
      if (index == 0) {
        // 清空comp列表
        pageModel.compList.clear()
        // // 保存缓存
        // CacheData.saveCacheData(CacheData.compGroupInfoDataCacheKey + pageModel.pageId + pageModel.groupId, pageDto,
        //   pageDto.md5)
      }
      this.analysisPageGroupCompData(pageModel,pageDto, pageInfo, index == pageInfo.groups.length - 1)
      Logger.error("ZZZXXXXX", '楼层id-end--》' + pageModel.groupId + '  楼层 comp数量=' + pageDto.compList.length);
    }

    /*
         收集页面所有楼层的组件信息，同步完成广告投放计算，异步完成稿件批查,
     */
    pageModel.pageTotalCompSize = pageInfo.oneRequestPageGroupCompList.length + pageModel.pageTotalCompSize
    // 处理页面广告数据，投放到页面的位置
    this.handlePageCompAdvPostion(pageInfo.oneRequestPageGroupCompList, pageModel, pageInfo.pageAdList);

    //遍历所有组件和稿件数据 push到页面
    for (let element of pageInfo.oneRequestPageGroupCompList) {
      pageModel.compList.push(CompDTO.createNewsBean(element))
    }

    // 批查互动数据
    this.allCompBatchRequest(pageInfo.oneRequestPageGroupCompList.convertToArray(), pageModel)

    //
    pageModel.currentPage++
    pageModel.viewType = ViewType.LOADED
    closeRefresh(pageModel, true)

    Logger.error("ZZZXXXXX", 'parseGroup----3----->' + pageInfo.oneRequestPageGroupCompList.length);
    if (pageModel.compList.isEmpty()) {
      // 没数据，展示空页面
      Logger.debug(TAG, 'aboutToAppear, data response page ' + pageModel.pageId + ', comp list is empty.');
      pageModel.viewType = ViewType.EMPTY;
      pageModel.emptyType = WDViewDefaultType.WDViewDefaultType_NoContent1;

    }
  }

  /**
   *  解析页面的楼层数据
   * @param pageDto  楼层的组件信息
   * @param pageInfo 信息流页面信息
   * @param isLastGroup  pageDto信息是不是最后一个楼层
   */
  private async analysisPageGroupCompData(pageModel: PageModel,pageDto: PageDTO, pageInfo: PageInfoDTO, isLastGroup: boolean) {

    if (pageDto && pageDto.compList && pageDto.compList.length > 0) {

      let pageCompList: ArrayList<CompDTO> = new ArrayList() // 收集楼层组件、稿件和本地组件容器
      // 遍历楼层的组件数据
      pageDto.compList.forEach((element: CompDTO) => {
        let contentInfo: ContentDTO = CollectionUtils.getElement(element.operDataList, 0);
        //移除音频 和 活动
        if (contentInfo && (contentInfo.objectType === '13' || contentInfo.objectType === '3')) {
          Logger.debug(TAG, 'getGroupData 移除音频 和 活动');
        } else {
          // 暂时屏蔽活动和音频详情入口
          if (element.operDataList[0]?.objectType === '3' || element.operDataList[0]?.objectType === '13') {
          } else {
            pageCompList.add(element)
          }
        }
      })

      // pageInfor 记录
      pageCompList.forEach((comp: CompDTO) => {
        pageInfo.oneRequestPageGroupCompList.add(comp)
      })

      // pageInfor 记录广告
      if (pageDto.compAdList != null) {
        pageInfo.pageAdList.push(...pageDto.compAdList)
      }

      // 检测最后一个楼层是否有一行两图卡
      if (isLastGroup) {
        // 最后一个楼层，特殊处理
        // 检测楼层最后一个组件业务数据是否需要通过访问接口获取
        let comp: CompDTO = pageDto.compList[pageDto.compList.length - 1]
        // 直播回放，需要二次请求数据
        if ( comp.compStyle == CompStyle.Zh_Grid_Layout_02) {
          // 这个comp，数据自己二次请求，自己分页处理，这里加flag，将page层滑动及loadmore ui去掉
          pageModel.contentNeedScroll = true

          //this.getLiveReviewData(pageInfo,comp)
        }
      }
    }

  }


  /**
   * comp加载更多，分页加载
   */
  private compLoadMore(pageModel: PageModel) {
    //聚合页
    if (pageModel.pageType == 1) {
      PageViewModel.postThemeList(pageModel.currentPage, pageModel.pageSize, pageModel.extra).then((liveReviewDTO) => {
        if (liveReviewDTO == null || liveReviewDTO.list == null || liveReviewDTO.list.length == 0) {
          pageModel.hasMore = false;
          return;
        } else {
          //更新数据
          pageModel.compList.addItems(liveReviewDTO.list);
          // 直接认为有分页，一直加载分页。直到没有数据，再停止
          pageModel.currentPage++;
          pageModel.hasMore = true;
          pageModel.pageTotalCompSize = liveReviewDTO.list.length + pageModel.pageTotalCompSize
        }
      }).catch((err: string | Resource) => {
        promptAction.showToast({ message: err });
      })
    } else {
      PageViewModel.getPageGroupCompData(pageModel.bizCopy())
        .then((data: PageDTO) => {
          if (data == null || data.compList == null || data.compList.length == 0) {
            pageModel.hasMore = false;
          } else {
            // 直接认为有分页，一直加载分页。直到没有数据，再停止
            pageModel.currentPage++;
            pageModel.hasMore = true;

            //移除音频 和 活动
            this.loadMorePageComp(pageModel, data)
            // 参与批查
            this.allCompBatchRequest(data.compList, pageModel)
          }
        }).catch((err: string | Resource) => {
        promptAction.showToast({ message: err });
      })
    }
  }


  /**
   * 加载更多页面组件和稿件信息
   */
  private loadMorePageComp(pageModel: PageModel, pageDto: PageDTO) {

    let pageCompList: ArrayList<CompDTO> = new ArrayList() // 收集页面组件、稿件和本地组件容器

    pageDto.compList.forEach((element: CompDTO) => {
      let contentInfo: ContentDTO = CollectionUtils.getElement(element.operDataList, 0);
      //移除音频 和 活动
      if (contentInfo && (contentInfo.objectType === '13' || contentInfo.objectType === '3')) {
        Logger.debug(TAG, 'getGroupData 移除音频 和 活动');
      } else {
        // 暂时屏蔽活动和音频详情入口
        if (element.operDataList[0]?.objectType === '3' || element.operDataList[0]?.objectType === '13') {
        } else {
          pageCompList.add(element)
        }
      }

    })

    // 记录
    pageModel.pageTotalCompSize = pageCompList.length + pageModel.pageTotalCompSize
    // 处理页面广告数据，投放到页面的位置
    this.handlePageCompAdvPostion(pageCompList, pageModel, pageDto.compAdList);

    //遍历所有组件和稿件数据 push到页面
    for (let element of pageCompList) {
      pageModel.compList.push(CompDTO.createNewsBean(element))
    }

  }

  /**
   *  信息流页面，所有稿件需要参与批查，如 批查评论、批查关注状态等接口
   * @param compList
   * @param pageModel
   */
  private allCompBatchRequest(compList: CompDTO[], pageModel: PageModel) {
    PageViewModel.getInteractData(compList).then((data: InteractDataDTO[]) => {
      // 刷新，替换所有数据
      this.resetInteract(data, pageModel.compList)
      if (pageModel?.channelId === '2001' || pageModel?.channelId === '2002') {
        //早晚报意图上报
        let context = getContext(this) as common.UIAbilityContext;
        viewBlogInsightIntentShare(context, pageModel?.channelId, compList, ActionMode.EXPECTED)
      }
    })

    // 测试数据
    // setTimeout(() => {
    //   let index = 1
    //   let comp = pageModel.compList.getData(index) as CompDTO
    //   comp.hasMore = 0
    //   //comp.operDataList[0].newsTitle = '测试111'
    //   let con :InteractDataDTO = new InteractDataDTO;
    //   con.commentNum=1000
    //   comp.operDataList[0].interactData = con
    //   Logger.debug("ZZZXXXXX",
    //     "-----setTimeout--------->"  + comp.hasMore)
    // }, 4 * 1000)
  }

  /**
   * 刷新互动数据到compList
   * @param interact 批查互动数据结果
   * @param compList comp list
   */
  private resetInteract(interact: InteractDataDTO[], compList: LazyDataSource<BaseDTO>) {
    if (interact == null || interact.length == 0) {
      return
    }
    let time = DateTimeUtils.getTimeStamp().toString()
    interact.forEach((interactData) => {
      let id = interactData.contentId;
      outer: for (let i = 0; i < compList.totalCount(); i++) {
        let comp = compList.getData(i) as CompDTO;
        if (comp == null || comp.operDataList == null || comp.operDataList.length == 0) {
          continue;
        }
        for (let j = 0; j < comp.operDataList.length; j++) {
          let content = comp.operDataList[j];
          if (content == null) {
            continue;
          }
          if (id == content.objectId) {
            content.interactData = interactData;
            comp.timestamp = time
            break outer;
          }
        }
      }
    })
  }


  /**
   *   处理页面中的广告组件信息
   * @param pageDto
   */
  private handlePageCompAdvPostion(pageCompList: ArrayList<CompDTO>, pageModel: PageModel, compAdList: CompAdvBean[]) {

    let compAdvList = compAdList

    let flag = true;
    if (compAdvList == null) {
      flag = false
    }
    if (compAdvList.length == 0) {
      flag = false
    }

    let pageCompSize = pageCompList.length // 信息流组件业务数量
    //  console.error("ZZZXXXXX", " start--->" + pageCompSize);
    if (pageCompSize == 0) {
      flag = false
    }

    if (flag) {
      let bannerAdvIndex = 0; // banner组件展示数据投放
      let layoutAdvIndex = 0; //稿件投放统计
      // 升序排序
      compAdvList.sort((a: CompAdvBean, b: CompAdvBean) => a.slotInfo.position - b.slotInfo.position)
      //  console.error("ZZZXXXXX", " 排序后的广告--->" + JSON.stringify(compAdvList));
      //当前日期
      let serverTimeLong: number = DateTimeUtils.getTimeStamp();
      for (let advBean of compAdvList) {
        let slotInfo = advBean.slotInfo

        if (slotInfo != null) {
          // 广告有效日期
          let startLong = advBean.startTime;
          let endLong = advBean.endTime;
          //符合开始时间和结束时间要求
          if (serverTimeLong >= startLong && serverTimeLong <= endLong) {

            let matInfo = advBean.matInfo
            if (matInfo == null) {
              continue
            }

            let advSubType = matInfo.advSubType

            // 插入轮播组件的广告
            if (4 == advSubType) {

              let position = slotInfo.position - 1;
              // 检测newCompList 集合中是否有轮播组件资源
              let adCompId = slotInfo.compId;
              if (!StringUtils.isEmpty(adCompId)) {
                for (let compBean of pageCompList) {
                  if (StringUtils.isEmpty(compBean.id)) {
                    continue
                  }
                  let compId = compBean.id.toString();
                  //匹配组件
                  if (adCompId == compId) {
                    // 运营位数据
                    let dataList = compBean.operDataList;
                    if (dataList != null) {

                      // 数组转成 ArrayList
                      let changeArrayList = (dataList: ContentDTO[]) => {
                        let compOperData: ArrayList<ContentDTO> = new ArrayList()
                        for (let dataListBean of dataList) {
                          compOperData.add(dataListBean)
                        }
                        return compOperData
                      }

                      let compOperData = changeArrayList(dataList)

                      // 轮播组件广告数据转 业务信息
                      let changeContentDTO = (matInfo: CompAdvMatInfoBean) => {
                        let advContentBean: ContentDTO = new ContentDTO();
                        advContentBean.newsTitle = matInfo.advTitle
                        advContentBean.objectType = matInfo.advType == "0" ? matInfo.advType.toString() : "4"
                        advContentBean.coverUrl = matInfo.matImageUrl[0]
                        advContentBean.linkUrl = matInfo.linkUrl
                        advContentBean.openType = matInfo.linkType
                        advContentBean.corner = ''
                        return advContentBean
                      }
                      let advContentBean = changeContentDTO(matInfo)

                      let dataListSize = dataList.length;
                      if (position < dataListSize) {
                        //dataList.add(position + bannerAdvIndex, advContentBean);
                        compOperData.insert(advContentBean, position + bannerAdvIndex)
                      } else {
                        compOperData.add(advContentBean);
                      }
                      bannerAdvIndex = bannerAdvIndex + 1;

                      // ArrayList转成 数组
                      compBean.operDataList = compOperData.convertToArray()
                    }
                  }
                }
              }

            } else {


              let advPosition = slotInfo.position //广告位置,从1开始
              // 页面的comp总数 - 这次请求的comp总数 = 剩余comp总数
              advPosition = advPosition - 1

              let a = pageModel.pageTotalCompSize - pageCompSize
              if (advPosition <= pageModel.pageTotalCompSize && advPosition >= a) {

                let b = advPosition - a;
                //  console.error('ZZZXXXXX', matInfo.advSubType + '-------------' + matInfo.advTitle + "  " + advPosition + "  " + a + "  " + b)
                if (b <= pageCompSize && b >= 0) {
                  // 创建广告稿件
                  let advComp: CompDTO = new CompDTO;
                  advComp.compStyle = CompStyle.Card_Comp_Adv
                  advComp.matInfo = matInfo

                  if (pageCompSize == slotInfo.position) {
                    pageCompList.add(advComp)
                  } else {
                    pageCompList.insert(advComp, b + layoutAdvIndex)
                  }
                  matInfo.originalPostion = pageCompList.getIndexOf(advComp)

                  layoutAdvIndex = layoutAdvIndex + 1;

                }
              }
            }
          }
        }
      }

    }
    // console.error("ZZZXXXXX", " end--->" + pageCompList.length);
  }


  /**
   * 获取直播回看数据
   */
  private async getLiveReviewData(pageInfo: PageInfoDTO,comp: CompDTO) {

    let currentPage = 1
    let pageSize = 20
    let listReviewDtoBean =  await PageViewModel.getLiveReviewUrl(currentPage, pageSize) as LiveReviewDTO
    Logger.error("ZZZXXXXX", 'getLiveReviewData---------'+listReviewDtoBean.list.length);

  }
}


let pageHelper = new PageHelper();

export default pageHelper as PageHelper;