package com.people.comment.commonpage;

import android.content.Context;
import android.text.TextUtils;

import com.people.comment.fragment.TemplateFragment;
import com.people.room.SubscribeLivingHelper;
import com.people.room.entity.SubscribeLivingModel;
import com.wd.capability.layout.R;
import com.wd.capability.network.BaseObserver;
import com.wd.capability.network.constant.ParameterConstant;
import com.wd.capability.network.response.BaseResponse;
import com.wd.common.api.RequestApi;
import com.wd.foundation.wdkit.constant.PageNameConstants;
import com.wd.common.utils.CommonNetUtils;
import com.wd.foundation.wdkit.utils.PDUtils;
import com.wd.common.utils.WorksDataHelper;
import com.wd.foundation.bean.RecListBean;
import com.wd.foundation.bean.analytics.LiveTypeConstants;
import com.wd.foundation.bean.comment.CommentListBean;
import com.wd.foundation.bean.comment.CommentStatusBean;
import com.wd.foundation.bean.convenience.AskBean;
import com.wd.foundation.bean.convenience.AskItemBean;
import com.wd.foundation.bean.convenience.MoreItemBean;
import com.wd.foundation.bean.custom.MenuBean;
import com.wd.foundation.bean.custom.act.ActivityList;
import com.wd.foundation.bean.custom.act.BaseActivityBean;
import com.wd.foundation.bean.custom.comp.CompBean;
import com.wd.foundation.bean.custom.comp.CompDataSourceBean;
import com.wd.foundation.bean.custom.comp.GoldenPositionExtraBean;
import com.wd.foundation.bean.custom.comp.PageBean;
import com.wd.foundation.bean.custom.content.CommentItem;
import com.wd.foundation.bean.custom.content.ContentBean;
import com.wd.foundation.bean.custom.content.ContentTypeConstant;
import com.wd.foundation.bean.custom.content.ManuscriptImageBean;
import com.wd.foundation.bean.custom.content.PeopleMasterBean;
import com.wd.foundation.bean.response.LiveSubscribeBean;
import com.wd.foundation.bean.mail.LiveInfo;
import com.wd.foundation.bean.response.BaseSearchTempIndexBean;
import com.wd.foundation.bean.response.ContentPageListBean;
import com.wd.foundation.bean.response.InteractBean;
import com.wd.foundation.bean.response.LiveSubscribeObj;
import com.wd.foundation.bean.response.SearchCommonDataBean;
import com.wd.foundation.bean.response.SearchResultBean;
import com.wd.foundation.bean.utils.TimeUtil;
import com.wd.foundation.wdkit.constant.Constants;
import com.wd.foundation.wdkit.constant.IntentConstants;
import com.wd.foundation.wdkit.json.GsonUtils;
import com.wd.foundation.wdkit.utils.CommonUtil;
import com.wd.foundation.wdkit.utils.SpUtils;
import com.wd.foundation.wdkitcore.tools.ArrayUtils;
import com.wd.foundation.wdkitcore.tools.HostUtil;
import com.wd.foundation.wdkitcore.tools.ResUtils;
import com.wd.foundation.wdkitcore.tools.StringUtils;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import io.reactivex.Observable;

/**
 * @Description: 依据不同业务类型获取不同的业务数据, 转换成稿件对象, 即页面展现数据
 * @Author: Li Yubing
 * @Email: liyubing@wondert.com.cn
 * @CreateDate: 2023/8/21 13:52
 * @Version: 1.0
 */
public class TemplatePageDataFetcher extends TemplatePageFactory<RequestApi> {

    private static final String TAG = "TemplatePageFetcher";

    private String channelId;

    private RecListBean recListBean;

    public TemplatePageDataFetcher(TemplatePageDataListener templatePageDataListener) {
        this.templatePageDataListener = templatePageDataListener;
    }

    public void setTemplatePageDataListener(TemplatePageDataListener templatePageDataListener) {
        this.templatePageDataListener = templatePageDataListener;
    }

    public void setChannelId(String channelId) {
        this.channelId = channelId;
    }

    public void setRecListBean(RecListBean recListBean) {
        this.recListBean = recListBean;
    }

    /**
     * 创建自定义普通页面，设置不同业务类型的数据请求
     *
     * @param pageNum
     * @param pageSize
     * @param menuBean
     */
    public void createCommonPage(Context context, int pageNum, int pageSize, int position, MenuBean menuBean, int textLength) {

        if (pageNum == 1) {
            initPage();
            PageBean pageBean = new PageBean();
            pageBean.needRefresh = true;
//            if (CompDataSourceBean.LOCAL_ACTIVITY_CHANNEL_PAGE.equals(menuBean.dataSourceType)) {
//                pageBean.setBaselineShow("0");
//            } else {
            pageBean.setBaselineShow("1");
            //      }

            pageBean.setBaselineHint(ResUtils.getString(R.string.res_show_end));
            createDefGroupData(pageBean);
        } else {
            if (pageBean != null) {
                pageBean.needRefresh = false;
            }
        }

        setPageDataSourceByType(context, pageNum, pageSize, position, menuBean,textLength);

    }

    /**
     * 对指定位置position 插入 展现稿件数据
     *
     * @param moreList
     * @param position 插入位置
     */
    public void contentDataInsertToPositionPage(List<ContentBean> moreList, int position) {
        if (moreList != null) {
            // 设置相关参数
            pageBean.insertPosition = position;
            pageBean.insertTotalNum = moreList.size();

            pageBean.setName(PageNameConstants.PageSearchPage);
            pageBean.setId(PageNameConstants.PageSearchPage);

            isBatchDyNum = true;
            isBatchMasterInfo = true;
            isBatchUserLevel = true;
            isBatchMasterCareState = true;
            isBatchFollowAndZan = true;
            isLastPageData = true;
            // 创建楼层组件信息
            collectCompData(moreList, true);

            //
//            GroupBean groupBean = pageBean.getGroups().get(0);
//            List<CompBean> compList = groupBean.getComps();
//
//            int size = compList.size();
//            for(int i = 0 ;i < size ;i++){
//                compList.get(i);
//                if (i == size - 1) {
//                    compBean.setSpecTagVal(2);
//                } else if (i == 0) {
//                    compBean.setSpecTagVal(0);
//                } else {
//                    compBean.setSpecTagVal(1);
//                }
//            }


            if (templatePageDataListener != null) {
                templatePageDataListener.onInsertDataToPage();
            }
            isLastPageData = false;
            // 批查稿件相关参数
            betchQueryAllDyData(moreList,2);
        }

    }


    /**
     * 设置普通页面需要数据的请求接口
     *
     * @param pageNum
     * @param pageSize
     * @param menuBean
     */
    private void setPageDataSourceByType(Context context, int pageNum, int pageSize, int position,
                                         MenuBean menuBean,int textLength) {
        pageBean.setWeakNet(false);
        if (CompDataSourceBean.LIVE_HORIZONTAL_CARD.equals(menuBean.dataSourceType)) {
            // 直播列表页
            isBatchDyNum = true;
            isBatchMasterCareState = true;
            isBatchFollowAndZan = true;

            needRead = false;
            showPublishData = true;
            getLiveChannelList(pageNum, pageSize, 1);

        } else if (CompDataSourceBean.LIVE_RESERVATION.equals(menuBean.dataSourceType)) {
            // 直播预约
            pageBean.setName(PageNameConstants.PageSubLiveList);
            pageBean.setId(PageNameConstants.PageSubLiveList);

            isLiveAppointment = true;
            specificCompStyle = "CompBigImage01";
            specificCompTyle = compDefType;
            showPublishData = true;
            getLiveChannelList(pageNum, pageSize, 2);
        } else if (CompDataSourceBean.LOCAL_MY_SUBSCRIBE.equals(menuBean.dataSourceType)) {
            // 我的预约列表
            pageBean.setName(PageNameConstants.PageMySubLiveList);
            pageBean.setId(PageNameConstants.PageMySubLiveList);

            specificCompStyle = "CompBigImage01";
            specificCompTyle = compDefType;
            showPublishData = true;
            sendBookingliveListRequest(context, pageNum, pageSize, PageNameConstants.PageMySubLiveList);
        } else if (CompDataSourceBean.RECOMMEND_LIST.equals(menuBean.dataSourceType)) {
            //图文页
            isBatchDyNum = true;

            pageBean.setName(PageNameConstants.ARTICLE_DETAIL_PAGE);
            pageBean.setId(PageNameConstants.ARTICLE_DETAIL_PAGE);

            needRead = false;
            if (recListBean != null && !ArrayUtils.isEmpty(recListBean.getList())) {
                isLastPageData = true;
                List<ContentBean> contentBeanList = recListBean.getList();
                // 人民号稿件（非动态人民号稿件）需要转换成对应的普通稿件
                for (ContentBean contentBean : contentBeanList) {
                    int appStyle = Integer.parseInt(contentBean.getAppStyle());
                    String style = String.valueOf(WorksDataHelper.changeCommon(appStyle));
                    contentBean.setAppStyle(style);
                }

                // 创建楼层组件信息
                collectCompData(contentBeanList, pageNum > 1);
                // 批查稿件相关参数
                betchQueryItemDy(contentBeanList);
            }
        }
        //问政-我的问政-我的提问-我的留言列表
        else if (IntentConstants.PAGETYPE_MYLEVEWORD.equals(channelId)) {
            pageBean.setName(PageNameConstants.MY_ASK_PAGE);
            pageBean.setId(PageNameConstants.MY_ASK_PAGE);
            showPublishData = true;
            sendMyLeaveWordListRequest(pageNum, pageSize);
        } else if (CompDataSourceBean.LOCAL_MESSAGE_BOARD.equals(menuBean.dataSourceType)) {
            showPublishData = true;
            needRead = false;
            // 留言板数据
            specificCompStyle = String.valueOf(ContentTypeConstant.MANUSCRIPT_STYLE_TWENTY_THREE);
            specificCompTyle = manuscriptType;
            askList(pageNum, pageSize, position, menuBean);
        }
        //问政-我的问政-我的提问-关注留言列表
        else if (IntentConstants.PAGETYPECARELEVEWORD.equals(channelId)) {
            pageBean.setName(PageNameConstants.MY_FOLLOW_ASK_PAGE);
            pageBean.setId(PageNameConstants.MY_FOLLOW_ASK_PAGE);
            showPublishData = true;
            sendCareLeaveWordListRequest(pageNum, pageSize);
        } else if (CompDataSourceBean.LOCAL_HIGHQUALITYCOMMENTSPAGECARD.equals(menuBean.dataSourceType)) {
            //优质评价页-请求接口数据
            specificCompStyle = "HighQualityCommentsPageCard";
            specificCompTyle = compDefType;
            sendHighQualityCommentsPageRequest(pageNum, pageSize);
        } else if (CompDataSourceBean.GOLDEN_TWO_PAGE.equals(menuBean.dataSourceType)) {
            // 金刚卡位聚合页面接口
            pageBean.setName(PageNameConstants.PageDiamondDetailPage);
            pageBean.setId(PageNameConstants.PageDiamondDetailPage);
            isBatchDyNum = true;
            isBatchMasterCareState = true;
            isBatchFollowAndZan = true;

            showPublishData = true;
            needRead = false;
            if (compLeaderList == null) {
                String extra = menuBean.getExtra();
                compLeaderList = GsonUtils.fromJson(extra, GoldenPositionExtraBean.class);
            }

            if (!TextUtils.isEmpty(menuBean.getExtra())) {

                compLeaderList.pageNum = pageNum;
                compLeaderList.pageSize = pageSize;
                getQueryGoldenThemeList(pageNum, GsonUtils.objectToJson(compLeaderList));
            } else {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, "extra拓展字段中参数有误");
                }
            }
        } else if (CompDataSourceBean.RECOMMEND_LIST_SEARCH.equals(menuBean.dataSourceType)) {
            //查询关注状态
            isBatchMasterCareState = true;
            //查询数字信息
            isBatchDyNum = true;
            //头像
            isBatchMasterInfo = false;
            isBatchFollowAndZan = true;
            //搜索推荐数据
            pageBean.setName(PageNameConstants.PageSearchPage);
            pageBean.setId(PageNameConstants.PageSearchPage);
            needRead = false;
            showPublishData = true;
            getSearchRecommendList(pageNum);
        } else if (CompDataSourceBean.LOCAL_SEARCHRESULTTAB.equals(menuBean.dataSourceType)) {
            //搜索tab数据
            pageBean.setName(PageNameConstants.PageSearchPage);
            pageBean.setId(PageNameConstants.PageSearchPage);
            needRead = false;
            showPublishData = true;
            searchListData(pageNum, pageSize, mChannelBean.getPageId(), mChannelBean.myChannel, mChannelBean.sameIds,textLength);
        } else if (CompDataSourceBean.LOCAL_SEARCHRESULTPAGE.equals(menuBean.dataSourceType)) {
            //搜索结果页
            String keyword = menuBean.getSummary();
            String searchType = menuBean.getExtra();
            pageBean.setName(PageNameConstants.PageSearchPage);
            pageBean.setId(PageNameConstants.PageSearchPage);
            needRead = false;
            showPublishData = true;
            searchListData(pageNum, pageSize, keyword, searchType, null,textLength);
        } else if (CompDataSourceBean.LOCAL_ACTIVITY_CHANNEL_PAGE.equals(menuBean.dataSourceType)) {
            // 活动频道页面信息流
            pageBean.setName(PageNameConstants.PageActivityChannel);
            pageBean.setId(PageNameConstants.PageActivityChannel);
            specificCompStyle = ContentTypeConstant.LOCAL_SEARCHRESULT_COMPALLRESULTCOMPACTIVITY01;
            specificCompTyle = compDefType;
            getActivityChannelList(pageNum);

        } else if (CompDataSourceBean.LOCAL_PUSH_MSG_LIST.equals(menuBean.dataSourceType)) {
            isBatchDyNum = true;
            isBatchMasterCareState = true;
            isBatchFollowAndZan = true;
            showPublishData = true;
            needRead = false;
            isStreamComp = true;

            pageBean.setName(PageNameConstants.MY_NOTIFICATION_PAGE);
            pageBean.setId(PageNameConstants.MY_NOTIFICATION_PAGE);
            getPushHistoryList(pageNum);
        }
    }


    /**
     * 获取活动频道页面数据
     */
    private void getActivityChannelList(int pageNum) {
        // 活动频道页面,一页数据,有多少加载多少
        if (pageNum > 1) {
            // 创建楼层组件信息
            collectCompData(null, pageNum > 1);

            templatePageDataListener.onPageDataSuccess(mPage, pageBean);
            return;
        }
        Map<String, Object> map = new HashMap<>();
        Observable<BaseResponse<ActivityList>> codeData = getRetrofit().queryActivityList(map);
        request(codeData, new BaseObserver<ActivityList>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            public void onSuccess(ActivityList activityList) {
                if (templatePageDataListener != null) {
                    List<ContentBean> contentBeanList = new ArrayList<>();
                    if (activityList == null || activityList.getList() == null) {

                    } else {

                        List<BaseActivityBean> list = activityList.getList();
                        for (BaseActivityBean bean : list) {
                            ContentBean contentBean = new ContentBean();
                            contentBean.setObjectType(String.valueOf(ContentTypeConstant.URL_TYPE_THREE));
                            contentBean.itemActivity = bean;
                            contentBeanList.add(contentBean);
                        }

                    }
                    // 创建楼层组件信息
                    collectCompData(contentBeanList, pageNum > 1);

                    templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                }

            }

            @Override
            public void _onError(String e) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, e);
                }
            }
        });

    }

    /**
     * 查询直播频道直播列表
     *
     * @param pageNum
     * @param pageSize
     * @param type     1：正在直播，2：预告
     */
    private void getLiveChannelList(int pageNum, int pageSize, int type) {

        Map<String, Object> map = new HashMap<>();
        map.put("type", type);
        map.put("pageNum", pageNum);
        map.put("pageSize", pageSize);
        Observable<BaseResponse<ContentPageListBean>> codeData = getRetrofit().queryLiveChannelList(map);
        request(codeData, new BaseObserver<ContentPageListBean>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            public void onSuccess(ContentPageListBean list) {
                if (templatePageDataListener != null) {
                    List<ContentBean> contentBeanList;
                    if (list == null) {
                        contentBeanList = new ArrayList<>();
                    } else {
                        contentBeanList = list.getList();
                        if (contentBeanList == null) {
                            contentBeanList = new ArrayList<>();
                        }
                    }
                    // 创建楼层组件信息
                    collectCompData(contentBeanList, pageNum > 1);

                    // 批查稿件相关参数
                    betchQueryItemDy(contentBeanList);
                }

            }

            @Override
            public void _onError(String e) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, e);
                }
            }
        });
    }


    /**
     * 搜索所有
     */
    private void searchListData(int pageNum, int pageSize, String keyword, String searchType, String[] sameIds,int textLength) {
        HashMap<String, Object> queryMap = new HashMap<>();
        queryMap.put(ParameterConstant.KEYWORD, keyword);
        queryMap.put("searchType", searchType);
        queryMap.put(ParameterConstant.PAGENUM, pageNum);
        queryMap.put(ParameterConstant.PAGESIZE, pageSize);
        if (textLength != 0){
            queryMap.put("textLength", textLength);
        }
        if (sameIds != null && sameIds.length > 0 && pageNum != 1) {
            String ids = "";
            for(int i = 0; i < sameIds.length;i++){
                ids = ids+sameIds[i];
                if(i != sameIds.length-1){
                    ids = ids+",";
                }
            }
            queryMap.put(ParameterConstant.SAMEIDS, ids);
        }
        Observable<BaseResponse<BaseSearchTempIndexBean>> register = getRetrofit().executeSearch(queryMap);
        request(register, new BaseObserver<BaseSearchTempIndexBean>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            public void onSuccess(BaseSearchTempIndexBean mData) {
                handleSearchData(mData, searchType, keyword, pageNum);
            }

            @Override
            public void _onError(String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, message);
                }
            }
        });
    }

    /**
     * 处理搜索数据
     *
     * @param mData
     */
    private void handleSearchData(BaseSearchTempIndexBean mData, String searchType, String keyWord, int pageNum) {
        if (mData == null) {
            if (templatePageDataListener != null) {
                dealCompData(null, pageNum > 1);
                templatePageDataListener.onPageDataSuccess(mPage, pageBean);
            }
            return;
        }
        if (mChannelBean != null && mData.sameIds != null && mData.sameIds.length>0) {
            mChannelBean.sameIds = mData.sameIds;
        }
        //需要批量查询的ContentBean
        List<ContentBean> contentBeanList = new ArrayList<>();
        List<SearchCommonDataBean> mTempList = mData.getList();
        if (!CommonUtil.isEmpty(mTempList)) {
//            BaseSearchIndexBean mSearchListIndexBean = new BaseSearchIndexBean();
            for (SearchCommonDataBean bean : mTempList) {
                if (bean == null) {
                    continue;
                }
                bean.localSearchTabType = searchType;
//                bean.setSearchType(searchType);
                if (Constants.SEARCH_ONLYRMH.equals(searchType)) {
                    //人民号号主类型用于 更多人民号-搜索结果页人民号卡
                    if (bean.getData() != null) {
                        // 类型不对,强制设置成人民号卡
                        bean.getData().setAppStyle(ContentTypeConstant.LOCAL_SEARCHRESULT_COMPALLRESULTPEOPLESACCOUNT);
                    }
                    SearchResultHelper.dealSearchResultCommonData(bean.getData(), keyWord, contentBeanList, searchType);
                } else if (Constants.SEARCH_MESSAGE_BOARD.equals(searchType)) {
                    //留言卡类型用于 更多留言卡-搜索结果页留言卡
                    if (bean.getData() != null) {
                        // 类型不对,强制设置成留言板类型
                        bean.getData().setAppStyle(ContentTypeConstant.MANUSCRIPT_STYLE_TWENTY_THREE + "");
                    }
                    SearchResultHelper.dealSearchResultCommonData(bean.getData(), keyWord, contentBeanList, searchType);
                } else if (Constants.CONTRIBUTION_TYPE_ACTIVITY.equals(searchType)) {
                    //更多活动卡
                    if (bean.getData() != null) {
                        // 类型不对,强制设置
                        bean.getData().setAppStyle(ContentTypeConstant.LOCAL_SEARCHRESULT_COMPALLRESULTCOMPACTIVITY01 + "");
                    }
                    SearchResultHelper.dealSearchResultCommonData(bean.getData(), keyWord, contentBeanList, searchType);
                } else {
                    //迭代5.5新增，命中逻辑处理
                    if (bean.getData() != null && (StringUtils.isNotBlank(bean.getData().getShoulderTitle()) ||
                            StringUtils.isNotBlank(bean.getData().getSubTitle()))){
                        //肩标题或副标题命中卡
                        bean.getData().setAppStyle(ContentTypeConstant.LOCAL_SEARCH_COMP_SHOULDER_SUBTITLE);
                        SearchResultHelper.dealSearchResultCommonData(bean.getData(), keyWord, contentBeanList, searchType);
                    }else if (bean.getData() != null &&
                            (StringUtils.isNotBlank(bean.getData().introduction) ||
                                    StringUtils.isNotBlank(bean.getData().getZhDescription()) ||
                                    StringUtils.isNotBlank(bean.getData().contentText))) {
                        //强制转换成命中卡类型,肩标题、副标题都未命中的情况下，简介>摘要>正文，都是正文样式
                        bean.getData().setAppStyle(ContentTypeConstant.LOCAL_SEARCHCOMPHITTHEMAINTEXT);
                        SearchResultHelper.dealSearchResultCommonData(bean.getData(), keyWord, contentBeanList, searchType);
                    } else if ("rmh".equals(bean.getResultType())) {
                        //返回数据类型 rmh:号主数据 message:留言板数据 common:其他数据 组件数据：多条 activity活动类型
                        //最大个数，留言板最大5，人民号最大10
                        int maxSize = 0;
                        //有数据
                        if (bean.getDataList() != null && bean.getDataList().size() > 0) {
                            //判断数量，数量只有一个的时候展示单个样式
                            if (bean.getDataList().size() == 1) {
                                SearchResultBean data = bean.getDataList().get(0);
                                ContentBean contentBean = SearchResultHelper.setCommonInfo(data);
                                contentBean.setKeyWord(keyWord);
                                contentBean.setAppStyle(ContentTypeConstant.LOCAL_SEARCHRESULT_COMPALLRESULTPEOPLESACCOUNT);
                                contentBean.localFieldCommon = searchType;
                                SearchResultHelper.setVideoOrLiveOrNewsContentBeanByObjectType(data, contentBean);
                                SearchResultHelper.setContentBeanByAppStyle(data, contentBean);
                                contentBeanList.add(contentBean);
                            } else {
                                ContentBean contentBean = new ContentBean();
                                contentBean.setAppStyle("CompAllSearchPeoplesAccount");
                                if (bean.getDataList().size() < 10) {
                                    maxSize = bean.getDataList().size();
                                } else {
                                    maxSize = 10;
                                }
                                List<ContentBean> contentList = new ArrayList<>();
                                //只设置规定范围内的数据 处理子控件列表
                                for (int k = 0; k < maxSize; k++) {
                                    SearchResultBean data = bean.getDataList().get(k);
                                    ContentBean subContentBean = SearchResultHelper.setCommonInfo(data);
                                    subContentBean.setKeyWord(keyWord);
                                    subContentBean.localFieldCommon = searchType;
                                    SearchResultHelper.setVideoOrLiveOrNewsContentBeanByObjectType(data, subContentBean);
                                    SearchResultHelper.setContentBeanByAppStyle(data, subContentBean);
                                    contentList.add(subContentBean);
                                }
                                contentBean.contentBeans = contentList;
                                contentBeanList.add(contentBean);
                            }
                        }
                    } else if ("message".equals(bean.getResultType())) {
                        //强制转换成留言版类型
                        bean.getData().setAppStyle(ContentTypeConstant.MANUSCRIPT_STYLE_TWENTY_THREE + "");
                        SearchResultHelper.dealSearchResultCommonData(bean.getData(), keyWord, contentBeanList, searchType);
                    } else {
                        SearchResultHelper.dealSearchResultCommonData(bean.getData(), keyWord, contentBeanList, searchType);
                    }

                    //迭代5.5新增，追加相似数据组件
                    if (bean.getData() != null && bean.getData().sameContentList != null && bean.getData().sameContentList.size() > 0) {
                        //设置成更多相似卡类型
                        bean.getData().setAppStyle(ContentTypeConstant.LOCAL_SEARCHCOMPBESIMILARMORE);
                        SearchResultHelper.dealSearchResultCommonData(bean.getData(), keyWord, contentBeanList, searchType);
                    }
                }
            }

            if (CommonUtil.isEmpty(contentBeanList)) {
                if (templatePageDataListener != null) {
                    collectCompData(contentBeanList, pageNum > 1);
                    templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                }
                return;
            }
            if (templatePageDataListener != null) {
                // 创建楼层组件信息
                collectCompData(contentBeanList, pageNum > 1);
                //搜索-更多人民号，需要批查询关注信息
                if (Constants.SEARCH_ONLYRMH.equals(searchType)) {
                    //查询关注状态
                    isBatchMasterCareState = true;
                    //查询号主信息
                    isBatchMasterInfo = false;
                    // 批查稿件相关参数
                    betchQueryItemDy(contentBeanList);
                } else if (!Constants.SEARCH_MESSAGE_BOARD.equals(searchType) && !Constants.CONTRIBUTION_TYPE_ACTIVITY.equals(searchType)) {
                    //查询关注状态
                    isBatchMasterCareState = true;
                    //查询数字信息
                    isBatchDyNum = true;
                    //头像
                    isBatchMasterInfo = false;
                    isBatchFollowAndZan = true;
                    List<ContentBean> betchQueryContentBeans = new ArrayList<>();
                    //另外加的相似卡底部组件，不参与批查，在此过滤
                    for(int i = 0; i < contentBeanList.size();i++){
                        if(contentBeanList.get(i).getAppStyle().equals(ContentTypeConstant.LOCAL_SEARCHCOMPBESIMILARMORE)){
                            continue;
                        }
                        //加的粗线卡也不参与
                        if(contentBeanList.get(i).getAppStyle().equals(ContentTypeConstant.CompSubjectLine02)){
                            continue;
                        }
                        betchQueryContentBeans.add(contentBeanList.get(i));
                    }

                    // 批查稿件相关参数
                    betchQueryItemDy(betchQueryContentBeans);
                } else {
                    templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                }

            }
        } else {
            if (templatePageDataListener != null) {
                collectCompData(contentBeanList, pageNum > 1);
                templatePageDataListener.onPageDataSuccess(mPage, pageBean);
            }
        }

    }

    /**
     * 获取搜索推荐数据
     */
    private void getSearchRecommendList(int pageNum) {
        CommonNetUtils.getInstance().getRecList("", "", "", 2, new BaseObserver<List<ContentBean>>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            protected void onSuccess(List<ContentBean> contentBeans) {
                //添加头部数据
                if (pageNum == 1 && contentBeans != null && contentBeans.size() > 0) {
                    ContentBean contentBean = new ContentBean();
                    contentBean.setAppStyle("SearchRrecommendationsTop");
                    contentBeans.add(0, contentBean);
                }
                // 创建楼层组件信息，视频走推荐
                collectCompData(contentBeans, pageNum > 1, 1);
//                collectCompData(contentBeans, false);
                if (templatePageDataListener != null) {
                    templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                }
            }

            @Override
            protected void _onError(String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, message);
                }
            }
        });

    }

    /**
     * 问政-查询留言列表
     *
     * @param pageNum
     * @param pageSize
     */
    private void askList(int pageNum, int pageSize, int position, MenuBean menuBean) {

        Map<String, Object> map = new HashMap<>();
        map.put("pageNum", pageNum);
        map.put("pageSize", pageSize);
        // 留言级别 0地方 1部委；默认0，前端若不传则默认是地方留言查询
        map.put("position", position);
        if (pageNum == 1) {
            tempTime = HostUtil.serverTime;
            map.put("refreshTime", HostUtil.serverTime);
        } else {
            map.put("refreshTime", tempTime);
        }


        if (!TextUtils.isEmpty(menuBean.proCode)) {
            map.put("provinceCode", menuBean.proCode);
        }
        if (!TextUtils.isEmpty(menuBean.cityCode)) {
            map.put("cityCode", menuBean.cityCode);
        }
        if (!TextUtils.isEmpty(menuBean.districtCode)) {
            map.put("districtCode", menuBean.districtCode);
        }


        if (!TextUtils.isEmpty(menuBean.fid)) {
            map.put("fid", menuBean.fid);
        }
        if (menuBean.moreSelectList != null && menuBean.getPosition() == TemplateFragment.LOCAL) {
            for (MoreItemBean bean : menuBean.moreSelectList) {

                int type = bean.classType;
                if (type == 1) {
                    if ("-1".equals(bean.getItemId())) {

                    } else {
                        map.put("typeId", bean.getItemId());
                    }
                } else if (type == 2) {
                    if ("-1".equals(bean.getItemId())) {

                    } else {
                        map.put("domainId", bean.getItemId());
                    }
                } else if (type == 3) {
                    if ("-1".equals(bean.getItemId())) {

                    } else {
                        map.put("replyStatus", bean.getItemId());
                    }

                }
            }
        }

        Observable<BaseResponse<AskBean>> codeData = getRetrofit().askList(map);
        request(codeData, new BaseObserver<AskBean>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            public void onSuccess(AskBean list) {
                if (templatePageDataListener != null) {

                    List<ContentBean> contentBeanList = new ArrayList<>();
                    if (list != null) {
                        int total = (int) list.totalCount;
                        List<AskItemBean> askList = list.list;
                        if (askList != null) {
                            int size = askList.size();
                            if (pageNum > 1) {
                                pageBean.pageCompNum = pageBean.pageCompNum + size;
                            } else {
                                pageBean.pageCompNum = size;
                            }

                            // 是否是最后一页的数据
                            isLastPageData = pageBean.pageCompNum == total;

                            for (AskItemBean bean : askList) {
                                ContentBean contentBean = new ContentBean();
                                contentBean.compLineType = 1;
                                contentBean.setObjectType(String.valueOf(ContentTypeConstant.URL_TYPE_SIXTEEN));
                                contentBean.askInfo = bean;
                                //  contentBean.setFromPage(CompDataSourceBean.LOCAL_MESSAGE_BOARD);
                                contentBeanList.add(contentBean);
                            }
                        }

                    }
                    // 创建楼层组件信息
                    collectCompData(contentBeanList, pageNum > 1);

                    // 批查稿件相关参数
                    betchQueryItemDy(contentBeanList);
                }

            }

            @Override
            public void _onError(String e) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, e);
                }
            }
        });
    }


    /**
     * 金刚位聚合页接口
     *
     * @param pageNum
     * @param parameterStr
     */
    private void getQueryGoldenThemeList(int pageNum, String parameterStr) {


        Observable<BaseResponse<ContentPageListBean>> codeData = getRetrofit().queryThemeList(getBody(parameterStr));
        request(codeData, new BaseObserver<ContentPageListBean>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            public void onSuccess(ContentPageListBean list) {
                if (templatePageDataListener != null) {
                    List<ContentBean> contentBeanList;
                    if (list == null) {
                        contentBeanList = new ArrayList<>();
                    } else {
                        contentBeanList = list.getList();
                        if (contentBeanList == null) {
                            contentBeanList = new ArrayList<>();
                        }
                    }
                    // 创建楼层组件信息
                    collectCompData(contentBeanList, pageNum > 1);

                    // 批查稿件相关参数
                    betchQueryItemDy(contentBeanList);
                }

            }

            @Override
            public void _onError(String e) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, e);
                }
            }
        });
    }

    /**
     * 获取预约直播列表
     */
    private void sendBookingliveListRequest(Context context, int pageNum, int pageSize, String pageName) {

        //远程数据
        Map<String, Object> map = new HashMap<>();
        map.put("pageNum", pageNum);
        map.put("pageSize", pageSize);
        Observable<BaseResponse<LiveSubscribeObj>> codeData = getRetrofit().getLiveSubscribeList(map);
        request(codeData, new BaseObserver<LiveSubscribeObj>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            public void onSuccess(LiveSubscribeObj list) {
                if (templatePageDataListener != null) {
                    List<ContentBean> contentBeanList = null;
                    if (list == null) {
                        contentBeanList = new ArrayList<>();
                    } else {

                        if (list.list != null) {
                            contentBeanList = new ArrayList<>();
                            for (LiveSubscribeBean liveSubscribeBean : list.list) {
                                List<ManuscriptImageBean> manuscriptImageBeans = new ArrayList<>();
                                ManuscriptImageBean manuscriptImageBean = new ManuscriptImageBean();
                                manuscriptImageBean.url = (liveSubscribeBean.imageUrl == null || liveSubscribeBean.imageUrl.length == 0) ? "" : liveSubscribeBean.imageUrl[0];
                                manuscriptImageBeans.add(manuscriptImageBean);
                                LiveInfo liveInfo = new LiveInfo();
                                liveInfo.setLiveState(liveSubscribeBean.status);
                                liveInfo.liveStartTime = liveSubscribeBean.planStartTime;
                                ContentBean contentBean = new ContentBean();
                                contentBean.setObjectType(String.valueOf(ContentTypeConstant.URL_TYPE_TWO));
                                contentBean.setNewsTitle(liveSubscribeBean.title);
                                contentBean.setRelId(liveSubscribeBean.relId);
                                contentBean.setRelType(liveSubscribeBean.relType);
                                contentBean.setLiveInfo(liveInfo);
                                contentBean.setShowDialog(true);
                                contentBean.setSubscribe(true);
                                contentBean.setFromPage(pageName);
                                contentBean.setFullColumnImgUrls(manuscriptImageBeans);
                                contentBean.setObjectId(liveSubscribeBean.liveId);
                                contentBeanList.add(contentBean);
                                if (!StringUtils.isEmpty(liveSubscribeBean.liveId) &&
                                        StringUtils.isEqual(LiveTypeConstants.RUNNING,
                                                liveSubscribeBean.status)) {
                                    //直播中
                                    SubscribeLivingModel subscribeLivingModel = new SubscribeLivingModel();
                                    subscribeLivingModel.userId = SpUtils.getUserId();
                                    subscribeLivingModel.liveId = liveSubscribeBean.liveId;
                                    subscribeLivingModel.relationId = liveSubscribeBean.relId;
                                    subscribeLivingModel.keys = SpUtils.getUserId() + "_" +
                                            liveSubscribeBean.liveId + "_" + liveSubscribeBean.relId;
                                    SubscribeLivingHelper.getInstance(context).insert(subscribeLivingModel);
                                }
                            }

                        }


                        if (contentBeanList == null) {
                            contentBeanList = new ArrayList<>();
                        }
                    }
                    // 创建楼层组件信息
                    collectCompData(contentBeanList, pageNum > 1);

                    if (templatePageDataListener != null) {
                        templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                    }
                }

            }

            @Override
            public void _onError(String e) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, e);
                }
            }
        });
    }

    /**
     * 获取我的问政-我的留言列表
     */
    private void sendMyLeaveWordListRequest(int pageNum, int pageSize) {
        List<CompBean> contentBeanList = new ArrayList<>();
//        if (pageNum == 1) {
//            CompBean compBean = new CompBean();
//            //组件类型
//            compBean.setCompStyle("Zh_Single_Column-08");
//            //组件类别
//            compBean.setCompType("ZH_SINGLE_COLUMN");
//            //组件内容列表
//            List<ContentBean> compContents = new ArrayList<>();
//            //组件内容
//            ContentBean contentBean = new ContentBean();
//            //内容来源
//            contentBean.setFromPage(CompDataSourceBean.LOCAL_POLITICS_LEAVEWORD);
//            compContents.add(contentBean);
//            compBean.setOperDataList(compContents);
//            contentBeanList.add(compBean);
//
//        }
        //远程数据
        Map<String, Object> map = new HashMap<>();
        map.put("pageNum", pageNum);
        map.put("pageSize", pageSize);
        Observable<BaseResponse<AskBean>> codeData = getRetrofit().getLeaveWordList(map);
        request(codeData, new BaseObserver<AskBean>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (pageNum == 1) {
//                    addDefaultView(contentBeanList);
                    pageBean.setBaselineShow("0");
                    // 创建楼层组件信息
                    dealCompData(contentBeanList, pageNum > 1);
                    if (templatePageDataListener != null) {
                        templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                    }
                } else {
                    pageBean.setBaselineShow("1");
                    if (templatePageDataListener != null) {
                        templatePageDataListener.onGetFailed(code, message);
                    }
                }
            }

            @Override
            public void onSuccess(AskBean list) {
                if (templatePageDataListener != null) {
                    if (list == null || list.list == null || list.list.size() == 0) {
                        if (pageNum == 1) {
//                            addDefaultView(contentBeanList);
                            pageBean.setBaselineShow("0");
                        }
                    } else {
                        pageBean.setBaselineShow("1");
                        String pageId = pageBean.getId();
                        String pageName = pageBean.getName();
                        for (AskItemBean askItemBean : list.list) {
                            askItemBean.localMyWord = true;
                            CompBean compBean = new CompBean();

                            compBean.setPageName(pageName);
                            compBean.setCompInforPageId(pageId);
                            compBean.setTrackPageName(pageName);

                            compBean.isStreamComp = false;
                            //组件类型
                            compBean.setCompStyle(ContentTypeConstant.MANUSCRIPT_STYLE_TWENTY_THREE + "");
                            //组件类别
                            compBean.setCompType(manuscriptType);
                            //组件内容列表
                            List<ContentBean> compContents = new ArrayList<>();
                            //组件内容
                            ContentBean contentBean = new ContentBean();
                            //内容来源
                            contentBean.setFromPage(CompDataSourceBean.LOCAL_POLITICS_LEAVEWORD);
                            contentBean.askInfo = askItemBean;
                            contentBean.showPublishData = true;
                            contentBean.compLineType = 1;
                            contentBean.askInfo.firstPublishTime = contentBean.askInfo.publishTime;
                            contentBean.setObjectType(String.valueOf(ContentTypeConstant.URL_TYPE_SIXTEEN));
                            compContents.add(contentBean);
                            compBean.setOperDataList(compContents);
                            contentBeanList.add(compBean);
                        }

                    }
                    // 创建楼层组件信息
                    dealCompData(contentBeanList, pageNum > 1);
                    if (templatePageDataListener != null) {
                        templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                    }
                }

            }

            @Override
            public void _onError(String e) {
                if (pageNum == 1) {
//                  addDefaultView(contentBeanList);
                    pageBean.setBaselineShow("0");
                    pageBean.setWeakNet(true);
                    // 创建楼层组件信息
                    dealCompData(contentBeanList, false);
                    if (templatePageDataListener != null) {
                        templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                    }
                } else {
                    pageBean.setBaselineShow("1");
                    if (templatePageDataListener != null) {
                        templatePageDataListener.onGetFailed(-1, e);
                    }
                }
            }
        });
    }

    /**
     * 获取我的问政-关注留言列表
     */
    private void sendCareLeaveWordListRequest(int pageNum, int pageSize) {
        //远程数据
        Map<String, Object> map = new HashMap<>();
        map.put("pageNum", pageNum);
        map.put("pageSize", pageSize);
        Observable<BaseResponse<AskBean>> codeData = getRetrofit().getCareLeaveWordList(map);
        request(codeData, new BaseObserver<AskBean>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            public void onSuccess(AskBean list) {
                if (templatePageDataListener != null) {
                    List<CompBean> contentBeanList = new ArrayList<>();
                    if (list == null || list.list == null || list.list.size() == 0) {
                    } else {

                        String pageId = pageBean.getId();
                        String pageName = pageBean.getName();

                        for (AskItemBean askItemBean : list.list) {
                            CompBean compBean = new CompBean();
                            compBean.isStreamComp = false;

                            compBean.setPageName(pageName);
                            compBean.setCompInforPageId(pageId);
                            compBean.setTrackPageName(pageName);
                            //组件类型
                            compBean.setCompStyle(ContentTypeConstant.MANUSCRIPT_STYLE_TWENTY_THREE + "");
                            //组件类别
                            compBean.setCompType(manuscriptType);
                            //组件内容列表
                            List<ContentBean> compContents = new ArrayList<>();
                            //组件内容
                            ContentBean contentBean = new ContentBean();
                            //内容来源
                            contentBean.setFromPage(CompDataSourceBean.LOCAL_POLITICS_LEAVEWORD);
                            contentBean.setObjectType(String.valueOf(ContentTypeConstant.URL_TYPE_SIXTEEN));
                            contentBean.compLineType = 1;
                            //                            //最后一个标识
//                            contentBean.setLocalFieldReadState("-100");
                            contentBean.askInfo = askItemBean;
                            contentBean.askInfo.firstPublishTime = contentBean.askInfo.publishTime;
                            contentBean.showPublishData = true;
                            compContents.add(contentBean);
                            compBean.setOperDataList(compContents);
                            contentBeanList.add(compBean);
                        }

                    }
                    // 创建楼层组件信息
                    dealCompData(contentBeanList, pageNum > 1);

                    if (templatePageDataListener != null) {
                        templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                    }
                }

            }

            @Override
            public void _onError(String e) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, e);
                }
            }
        });
    }

    /**
     * 查询72小时内优质评论
     * {"hasNext":0,"list":[
     * {"authorLike":0,"checkStatus":2,"childCommentNum":0,"childComments":[],"commentContent":"测试一下11","commentContentSensitive":"","commentLevel":1,"commentPics":"","commentSensitive":"","commentType":"2","contentAuthor":0,"createTime":"2023-09-23 14:43:19","creatorFlag":1,"fromCreatorId":"3004082","fromUserHeader":"https://sitcontentjdcdn.aikan.pdnews.cn/vod/content/202308/202308Fr170326554/LUa.png","fromUserId":"356667482566405","fromUserName":"Xman99","fromUserType":2,"id":302497,"likeNum":1,"mySelf":0,"parentId":-1,"region":"安徽","replyNum":0,"rootCommentId":302497,"sensitiveExist":null,"sensitiveShow":1,"toUserContentAuthor":0,"toUserName":"","topFlag":0,"uuid":"a594907d-bc71-42e3-917f-9f939743ecae"}
     * ],"pageNum":0,"pageSize":10,"totalCommentNum":1,"totalCount":1}
     */
    private void sendHighQualityCommentsPageRequest(int pageNum, int pageSize) {
        //远程数据
        Map<String, Object> map = new HashMap<>();
        map.put("pageNum", pageNum);
        map.put("pageSize", pageSize);
        Observable<BaseResponse<CommentListBean>> codeData = getRetrofit().getHighQualityList(map);
        request(codeData, new BaseObserver<CommentListBean>() {
            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            public void onSuccess(CommentListBean list) {
                if (templatePageDataListener != null) {
                    List<CompBean> contentBeanList = new ArrayList<>();
                    if (list == null || list.getList() == null || list.getList().size() == 0) {
                        // 创建楼层组件信息
                        dealCompData(contentBeanList, pageNum > 1);
                        templatePageDataListener.onPageDataSuccess(mPage, pageBean);
                    } else {
                        //批量查询是否点赞了
                        if (PDUtils.isLogin()) {
                            List<Integer> ids = new ArrayList<>();
                            for (int i = 0; i < list.getList().size(); i++) {
                                ids.add(list.getList().get(i).getId());
                            }
                            CommonNetUtils.getInstance().getCommentStatusList(new BaseObserver<List<CommentStatusBean>>() {
                                @Override
                                protected void dealSpecialCode(int code, String message) {
                                    dealHighQualityCommentsPageData(list, contentBeanList, pageNum);
                                }

                                @Override
                                protected void onSuccess(List<CommentStatusBean> interactResponseDataBeans) {
                                    if (interactResponseDataBeans != null && interactResponseDataBeans.size() == list.getList().size()) {
                                        for (int i = 0; i < list.getList().size(); i++) {
                                            //更新点赞数量
                                            list.getList().get(i).setLikeStatus(interactResponseDataBeans.get(i).getStatus());
                                        }
                                    }
                                    dealHighQualityCommentsPageData(list, contentBeanList, pageNum);
                                }

                                @Override
                                public void onError(Throwable e) {
                                    dealHighQualityCommentsPageData(list, contentBeanList, pageNum);
                                }
                            }, ids);
                        } else {
                            dealHighQualityCommentsPageData(list, contentBeanList, pageNum);
                        }
                    }

                }

            }

            @Override
            public void _onError(String e) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, e);
                }
            }
        });
    }

    private void dealHighQualityCommentsPageData(CommentListBean list, List<CompBean> compBeanList, int pageNum) {
        List<ContentBean> contentBeanList = new ArrayList<>();
        for (CommentItem covertCommentBean : list.getList()) {
            CompBean compBean = new CompBean();
            compBean.isStreamComp = false;
            //组件类型
            compBean.setCompStyle(specificCompStyle);
            //组件类别
            compBean.setCompType(specificCompTyle);
            //组件内容列表
            List<ContentBean> compContents = new ArrayList<>();
            //组件内容
            ContentBean contentBean = new ContentBean();

            //设置优质评论内容，以及查询评论点赞数相关
            contentBean.setLikeStatus(covertCommentBean.getLikeStatus() + "");
            contentBean.setObjectId(covertCommentBean.getTargetId());
            contentBean.setRelId(covertCommentBean.getTargetRelId());
            contentBean.setRelType(TextUtils.isEmpty(covertCommentBean.getTargetRelType()) ? 0 : Integer.parseInt(covertCommentBean.getTargetRelType()));
            contentBean.setObjectType(covertCommentBean.getTargetType());
            contentBean.setNewsTitle(covertCommentBean.getTargetTitle());
            contentBean.setPublishTime(covertCommentBean.getCreateTime());
            contentBean.setKeyArticle(covertCommentBean.getKeyArticle());
            contentBean.setLeaderArticle(covertCommentBean.getLeaderArticle());
            contentBean.setContentRelId(covertCommentBean.getTargetRelObjectId());
            contentBean.setLinkUrl(covertCommentBean.getH5Url());
            //人民号
            PeopleMasterBean rmhInfo = new PeopleMasterBean();
            rmhInfo.setRmhId(covertCommentBean.getFromCreatorId());
            rmhInfo.setCnMainControl(covertCommentBean.mainControl);
            rmhInfo.setUserId(covertCommentBean.getFromUserId());
            rmhInfo.setUserType(covertCommentBean.getFromUserType());
            rmhInfo.setRmhName(covertCommentBean.getFromUserName());
            rmhInfo.setRmhHeadUrl(covertCommentBean.getFromUserHeader());

            contentBean.setRmhInfo(rmhInfo);
            contentBean.setCommentInfo(covertCommentBean);
            if ((ContentTypeConstant.URL_TYPE_FIVE + "").equals(contentBean.getObjectType())) {
                contentBean.setPageId(covertCommentBean.pageId);
                contentBean.setObjectLevel(covertCommentBean.getTopicType() + "");
            }
            contentBeanList.add(contentBean);
            compContents.add(contentBean);
            compBean.setOperDataList(compContents);
            compBeanList.add(compBean);
        }
        // 创建楼层组件信息
        dealCompData(compBeanList, pageNum > 1);
        //批查号主信息
        isBatchMasterInfo = true;
        //批查评论点赞数-评论列表中有点赞数，不需要批查
        isBatchCommentLikes = false;
        //批查用户等级信息
        isBatchUserLevel = true;
        // 批查稿件相关参数
        betchQueryItemDy(contentBeanList);


    }

    private List<String> pushPageDataList = null;

    /**
     * 查询历史推送消息
     *
     * @param pageNum
     */
    public void getPushHistoryList(int pageNum) {
        //不使用缓存
        Map<String, Object> map = new HashMap<>();

        map.put("pageNum", pageNum);

        map.put("pageSize", 20);

        if (pushPageDataList == null) {
            pushPageDataList = new ArrayList<>();
        }
        if (pageNum == 1) {
            pushPageDataList.clear();
        }
        Observable<BaseResponse<InteractBean>> groupDataObservable = getRetrofit().getPushList(map);
        request(groupDataObservable, new BaseObserver<InteractBean>() {

            @Override
            protected void dealSpecialCode(int code, String message) {
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(code, message);
                }
            }

            @Override
            protected void onSuccess(InteractBean interactBean) {
                if (templatePageDataListener != null) {
                    List<ContentBean> contentBeanList;
                    if (interactBean == null) {
                        contentBeanList = new ArrayList<>();
                    } else {
                        contentBeanList = interactBean.list;
                        if (contentBeanList == null) {
                            contentBeanList = new ArrayList<>();
                        }
                        //  1、对appStyle= null，设置成3，成为无图卡
                        // 2、收集推送日期 yyyy-mm-dd
                        // 3、 时间轴稿件和专题稿件缩小
                        List<String> dataList = new ArrayList<>();

                        for (ContentBean contentBean : contentBeanList) {

                            String style = contentBean.getAppStyle();
                            if (TextUtils.isEmpty(style)) {
                                contentBean.setAppStyle(String.valueOf(ContentTypeConstant.MANUSCRIPT_STYLE_THREE));
                            }
                            // 时间轴
                            if (String.valueOf(ContentTypeConstant.MANUSCRIPT_STYLE_NINE).equals(style)) {
                                contentBean.mappingType = 1;
                            }
                            // 大专题
                            if (String.valueOf(ContentTypeConstant.MANUSCRIPT_STYLE_TEN).equals(style)) {
                                contentBean.mappingType = 1;
                            }

                            String contentPushData = TimeUtil.getDay(contentBean.getPushTime());
                            if (!dataList.contains(contentPushData)) {
                                dataList.add(contentPushData);
                            }

                        }

                        // 按推送的日期 分类内容信息
                        if (contentBeanList.size() > 0) {

                            List<ContentBean> newsContentBeanList = new ArrayList<>();
                            for (int i = 0; i < dataList.size(); i++) {
                                String dataStr = dataList.get(i);
                                if (pushPageDataList.contains(dataStr)) {

                                } else {
                                    // 加标题
                                    ContentBean titleCompBean = new ContentBean();
                                    titleCompBean.setNewsTitle(dataStr);
                                    titleCompBean.setAppStyle(CompSubjectTile01);
                                    newsContentBeanList.add(titleCompBean);
                                }

                                for (ContentBean contentBean : contentBeanList) {
                                    if (contentBean != null && contentBean.getPushTime() != 0) {
                                        if (TimeUtil.getDay(contentBean.getPushTime()).equals(dataStr)) {
                                            newsContentBeanList.add(contentBean);
                                        }
                                    }
                                }
                            }

                            contentBeanList = newsContentBeanList;

                            pushPageDataList.addAll(dataList);
                        }


                    }
                    // 创建楼层组件信息
                    collectCompData(contentBeanList, pageNum > 1);

                    // 批查稿件相关参数
                    betchQueryItemDy(contentBeanList);
                }
            }

            @Override
            protected void _onError(String message) {
                super._onError(message);
                if (templatePageDataListener != null) {
                    templatePageDataListener.onGetFailed(-1, message);
                }
            }
        });
    }

}