PageDataFetcher.java 28.1 KB
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797
/*
 * Copyright (c) People Technologies Co., Ltd. 2019-2022. All rights reserved.
 */

package com.wd.layoutdataimpl.model;

import android.text.TextUtils;

import androidx.annotation.NonNull;


import com.wd.capability.layout.R;
import com.wd.capability.layout.comp.layoutdata.AbsGroup;
import com.wd.capability.layout.comp.layoutdata.AbsSection;
import com.wd.capability.layout.comp.layoutdata.Page;
import com.wd.capability.layout.comp.parser.ChannelSectionParser;
import com.wd.capability.layout.page.model.CompLogicDataBean;
import com.wd.capability.layout.page.vm.IPageDataListener;
import com.wd.capability.network.BaseObserver;
import com.wd.capability.network.bean.MetaBean;
import com.wd.capability.network.cachedata.CacheData;
import com.wd.capability.network.response.BaseResponse;
import com.wd.common.api.RequestApi;
import com.wd.foundation.bean.custom.comp.ChannelInfoBean;
import com.wd.foundation.bean.custom.comp.CompBean;
import com.wd.foundation.bean.custom.comp.GroupBean;
import com.wd.foundation.bean.custom.comp.PageBean;
import com.wd.foundation.bean.custom.comp.TopicInfoBean;
import com.wd.foundation.wdkit.json.GsonUtils;
import com.wd.foundation.wdkit.utils.SpUtils;
import com.wd.foundation.wdkit.utils.ToastNightUtil;
import com.wd.foundation.wdkitcore.tools.ArrayUtils;
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 java.util.concurrent.TimeUnit;

import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;

/**
 * 信息流页面
 * 频道数据的抓取器<BR>
 * 对接新的接口,结构调整了,较之前的改动大<BR>
 * 结果回调统一走onPageDataSuccess,不走onPartialDataSuccess了。只有page接口和group接口都回来才能刷UI
 *
 * @author zhangbo
 * @version [V1.0.0, 2022/4/12]
 * @since V1.0.0
 */
public class PageDataFetcher extends PageCompDataFactory<RequestApi> {
    private static final String TAG = "PageDataFetcherNews";
    private boolean isCanceled = false;

    /**
     * 页面已经展示的第一页数据
     */
    private List<CompBean> firstPageCompList;

    /**
     * 构造器
     *
     * @param listener 监听回调
     */
    public PageDataFetcher(IPageDataListener listener) {
        mListener = listener;
        initPage();
    }

    public IPageDataListener getmListener() {
        return mListener;
    }

    /**
     * 获取当前页面楼层排序信息
     *
     * @param useCache          缓存标记
     * @param compLogicDataBean
     */
    public void getPageData(boolean useCache, CompLogicDataBean compLogicDataBean) {

        this.compLogicDataBean = compLogicDataBean;

        // 已经获取到了 pageinfor对象,无需使用接口重新获取
        if (compLogicDataBean.pageInforBean != null) {

            PageBean pageInfoBean = compLogicDataBean.pageInforBean;
            pageInfoBean.isLocalCache = useCache;

            if (mListener != null) {
                mListener.onPageInforSuccess(pageInfoBean);
            }
            if (useCache) {
                // 楼层数据
                callback(pageInfoBean, useCache);
            } else {
                //专题页面
                if (compLogicDataBean.isSubjectPage() && pageData != null) {
                    pageData.voteShowFlag = true;
                }
                //使用多楼层处理模式
                useMoreLayerModel(useCache);
            }

        } else {
            // 缓存组件的数据
            if (useCache) {
                loadLocalPageCacheData(compLogicDataBean.pageId);
                return;
            }
            //页面上的pageInfo 接口,特殊的接口使用合并接口pageInfo/v2
            Map<String, Object> map = new HashMap<>();
            map.put("pageId", compLogicDataBean.pageId);
            Observable<BaseResponse<PageBean>> pageDataObservable;
            //我是判断 如果首页启动默认选中的那个频道 是时间线频道 就掉v2接口
            if (compLogicDataBean.useV2){
                pageDataObservable = getRetrofit().getPageDataV2(map);
            }else {
                pageDataObservable = getRetrofit().getPageData(map);
            }
            request(pageDataObservable, new BaseObserver<PageBean>() {

                @Override
                protected void dealSpecialCode(int code, String message) {
                    mListener.onPageDataFailed(0,message);
                }

                @Override
                protected void onSuccess(PageBean pageBean) {

                }

                @Override
                protected void onSuccess(PageBean pageBean, MetaBean metaBean, String msg, int code) {
                    if (pageBean == null) {
                        mListener.onPageDataFailed(0,msg);
                        return;
                    }else  {
                        //在这里处理,如果使用v2,compInfo为空或者compList是空不用进行下去了
                        if (compLogicDataBean.useV2){
                            GroupBean compInfo = pageBean.getCompInfo();
                            if (null == compInfo || ArrayUtils.isEmpty(compInfo.getComps())){
                                mListener.onPageDataFailed(0,msg);
                                return;
                            }
                        }
                    }
                    mListener.onPageInforSuccess(pageBean);
                    if (ArrayUtils.isEmpty(pageBean.getGroups())) {
                        mListener.onPageDataSuccess(null, pageBean);
                        return;
                    }
                    pageData = pageBean;

                    CacheData localCacheData = CacheData.getLocalCacheData(CacheData.comPageInfoCacheKey + compLogicDataBean.pageId);
                    // 新旧数据md5值对比
                    String dataMd5 = chacheDataAndNewDataContrastByMd5ToComp(localCacheData, metaBean, 0, true);
                    // 保存缓存
                    CacheData.saveDataToPreference(CacheData.comPageInfoCacheKey + compLogicDataBean.pageId, pageBean, dataMd5);
                    // 楼层数据
                    callback(pageBean, false);
                }

                @Override
                protected void _onError(String e) {
                    // 专题和频道二级页面无需提示,会在页面中提示
                    if (compLogicDataBean != null && compLogicDataBean.tipFlag) {
                        ToastNightUtil.showShort(e);
                    }
                    if(pageData != null){
                        pageData.isLocalCache = useCache;
                    }

                    mListener.onPageDataFailed(1,e);
                }
            });

        }

    }


    /**
     * 初始化页面数据
     */
    private void initPage() {
        mPage = new Page();
        mPage.setSectionParser(new ChannelSectionParser());
    }

    /**
     * @param pageBean
     */
    private void callback(PageBean pageBean, boolean useCache) {
        if (isCanceled) {
            return;
        }
        pageData = pageBean;
        compLogicDataBean.setRefreshTime(pageBean.getRefreshTime());
        // 解析page数据,转换为group列表
        mPage.createGroup(pageBean);
        mPage.setPage(pageBean);
        parseData(useCache);
    }

    /**
     * 取消任务
     */
    public void cancel() {
        isCanceled = true;
    }

    public boolean isCanceled() {
        return isCanceled;
    }

    /**
     * 解析数据,并发二次请求去获取楼层组件数据
     */
    public void parseData(boolean useCache) {
        if (mPage == null) {
            return;
        }
        // 检查页面数据可收集了 楼层信息
        if (ArrayUtils.isEmpty(mPage.getGroups())) {
            return;
        }
        // 设置频道参数
        ChannelInfoBean channelInfoBean = pageData.getChannelInfo();
        if (channelInfoBean != null) {
            compLogicDataBean.channelId = channelInfoBean.getChannelId();
            compLogicDataBean.channelType = channelInfoBean.getChannelType();
        }
        // 设置专题参数
        TopicInfoBean topicInfoBean = pageData.getTopicInfo();
        if (topicInfoBean != null) {
            compLogicDataBean.topicId = topicInfoBean.getTopicId();
            compLogicDataBean.topicType = topicInfoBean.getTopicType();
            if (compLogicDataBean.isSubjectPage() && pageData.isNewsSubjectInfor()) {
                pageData.setBaselineShow("1");
                pageData.setBaselineCopywriting(ResUtils.getString(R.string.res_show_end));
                pageData.setBaselineColor("#FFFFFF");
            }
        }

        //使用多楼层处理模式
        useMoreLayerModel(useCache);

    }


    /**
     * 使用多楼层处理模式 (含一个楼层)
     * 多个楼层,第一次完成获取所有楼层的第一笔业务数据,再完成ui绘制
     *
     * @param useCache
     */
    private void useMoreLayerModel(boolean useCache) {
        // 初始化监听器
        initRequestConditionTask();

        // 楼层支持翻页,单个楼层翻页
        List<AbsGroup> groupsList = mPage.getGroups();
        int groupSize = groupsList.size();
        if (groupSize > 0) {
            // 清理页面的请求得到的楼层组件数据
            pageData.clearRequestLayerCompList();
            // 刷新时,清理页面已展示稿件信息
            pageData.clearPageAllShowCompList();

            // 收集楼层信息
            for (int i = 0; i < groupSize; i++) {
                AbsGroup group = groupsList.get(i);
                if (group == null) {
                    continue;
                }
                group.setLayerIndex(i);
                group.setPageNum(1);
                group.setShowBlock(true);
                // 记录最后一个楼层
                if (i == groupSize - 1) {
                    compLogicDataBean.groupId = group.getId();
                    compLogicDataBean.group = group;
                    mPage.setGroupIndex(i);
                    group.setLastLayer(true);
                } else {
                    group.setLastLayer(false);
                }
                // 解析group数据,并进行二次请求
                loadGroupData(group, useCache);
            }
        }
    }

    /**
     * 加载更多组件数据
     *
     * @param group
     */
    public void loadMoreCompData(@NonNull AbsGroup group) {

        // 楼层组件可加载更多数据
        initRequestConditionTask();
        // 普通楼层支持加载更多数据
        if (group.getSupportLoadMoreDataComp() == null) {
            //加载更多
            loadGroupData(group, false);
        } else {
            // 添加页数
            group.setPageNum(compLogicDataBean.requestTime);
            accessCompRequest(group);
        }
    }

    /**
     * 请求compInfo需要的参数
     * @param group
     * @return
     */
    private Map<String, Object> getCompParams(@NonNull AbsGroup group){
        //不使用缓存
        Map<String, Object> map = new HashMap<>();

        if(compLogicDataBean.requestTime == 1){
            group.setSearchValue("");
        }else {
            //请求下一页compInfo的时候,要把上一页返回的searchValue作为参数传给后端
            if(group != null && StringUtils.isNotEmpty(group.getSearchValue())){
                map.put("searchValue",group.getSearchValue());
            }
        }

        // 必须参数
        map.put("groupId", compLogicDataBean.loadMore ? compLogicDataBean.groupId : group.getId());

        map.put("pageNum", compLogicDataBean.requestTime);

        map.put("pageId", compLogicDataBean.pageId);

        map.put("loadStrategy", compLogicDataBean.loadStrategy);

        map.put("refreshTime", compLogicDataBean.refreshTime);

        // 非必须参数
        if (!TextUtils.isEmpty(compLogicDataBean.channelId)) {
            map.put("channelId", compLogicDataBean.channelId);
        }

        if (!TextUtils.isEmpty(compLogicDataBean.channelType)) {
            map.put("channelType", compLogicDataBean.channelType);
        }

        if (!TextUtils.isEmpty(group.getGroupStrategy())) {
            map.put("channelStrategy", group.getGroupStrategy());
            if ("1".equals(group.getGroupStrategy())) {
                map.put("pageSize", 10);
            } else {
                map.put("pageSize", 20);
            }

        } else {
            map.put("pageSize", 20);
        }

        if (!TextUtils.isEmpty(compLogicDataBean.topicId)) {
            map.put("topicId", compLogicDataBean.topicId);
            map.put("topicType", compLogicDataBean.topicType);
        }

        // 本地问政频道地理信息特殊处理
        if ("2062".equals(compLogicDataBean.channelId)) {

            String areaCode = SpUtils.getWenZhenChannelAreaCode();

            if (TextUtils.isEmpty(areaCode)) {
                if (!TextUtils.isEmpty(SpUtils.getProvinceCode())) {
                    map.put("provinceCode", SpUtils.getProvinceCode());
                }

                if (!TextUtils.isEmpty(SpUtils.getCityCode())) {
                    map.put("cityCode", SpUtils.getCityCode());
                }
                if (!TextUtils.isEmpty(SpUtils.getDistrictCode())) {
                    map.put("districtCode", SpUtils.getDistrictCode());
                }
            } else {

                String[] areaArray = areaCode.split("#");
                if (areaArray != null) {
                    String provinceCode = "";
                    String cityCode = "";
                    String districtCode = "";
                    int size = areaArray.length;
                    if (size > 0) {
                        provinceCode = areaArray[0];
                    }
                    if (size > 1) {
                        cityCode = areaArray[1];
                    }
                    if (size > 2) {
                        districtCode = areaArray[2];
                    }
                    if (!TextUtils.isEmpty(provinceCode)) {
                        map.put("provinceCode", provinceCode);
                    }

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

            }
        } else {
            if (!TextUtils.isEmpty(SpUtils.getProvinceCode())) {
                map.put("provinceCode", SpUtils.getProvinceCode());
            } else {
//                  map.put("provinceCode", 340000);
            }

            if (!TextUtils.isEmpty(SpUtils.getCityCode())) {
                map.put("cityCode", SpUtils.getCityCode());
            } else {
//                 map.put("cityCode", 340100);
            }
            if (!TextUtils.isEmpty(SpUtils.getDistrictCode())) {
                map.put("districtCode", SpUtils.getDistrictCode());
            } else {
//                map.put("districtCode", 340103);
            }
        }
        return map;
    }


    /**
     * 获取页面楼层信息和关于楼层的信息流
     *
     * @param group
     */
    private void loadGroupData(@NonNull AbsGroup group, boolean useCache) {

        //使用缓存
        if (useCache) {
            loadLocalCompCacheData(group, group.getId());
            return;
        }
        if (compLogicDataBean.loadMore) {
            pageData.needRefresh = false;
            pageData.isLocalCache = false;
            pageData.pageInforRefresh = false;
        }
        mGetDataFinishTask.registerCondition(group);

        Map<String, Object> compParams = getCompParams(group);
        // 0:默认非推荐数据源;1:推荐楼层数据源
        int sourceInterfaceVale = 0;
        Observable<BaseResponse<GroupBean>> groupDataObservable;
        if (!TextUtils.isEmpty(group.getGroupStrategy()) && "1".equals(group.getGroupStrategy())) {
            //推荐
            sourceInterfaceVale = 1;
            groupDataObservable = getRetrofit().getRecGroupData(compParams);
        } else {
            //时间线
            groupDataObservable = getRetrofit().getGroupData(compParams);
        }
        // 0:默认非推荐数据源;1:推荐楼层数据源
        int finalSourceInterfaceVale = sourceInterfaceVale;
        //如果是v2接口已经合并了compInfo
        if (compLogicDataBean.useV2 ){
            if (null != pageData){
                GroupBean compInfo = pageData.getCompInfo();
                String md5 = pageData.getMd5();
                String fmd5 = pageData.getFmd5();
                MetaBean metaBean = new MetaBean();
                metaBean.setMd5(md5);
                metaBean.setFmd5(fmd5);
                /**
                 * 处理compInfo接口数据
                 */
                dealCompInfoDataSuccess(group, compInfo, metaBean, finalSourceInterfaceVale);
            }else {
                if (mListener != null) {
                    mListener.onPageDataFailed(0,"pageInfo is error");
                }
            }
            return;
        }
        request(groupDataObservable, new BaseObserver<GroupBean>() {

            @Override
            protected void dealSpecialCode(int code, String message) {

                if (mListener != null) {
                    mListener.onPageDataFailed(0,"compInfo is error");
                }

            }

            @Override
            protected void onSuccess(GroupBean groupBean) {

            }

            @Override
            protected void onSuccess(GroupBean groupBean, MetaBean metaBean, String msg, int code) {
                /**
                 * 处理compInfo接口数据
                 */
                dealCompInfoDataSuccess(group,groupBean,metaBean,finalSourceInterfaceVale);
            }


            @Override
            protected void _onError(String e) {

                dealCompInfoDataFail(e);
            }
        });
    }


    /**
     *处理compInfo接口数据
     */
    private void dealCompInfoDataSuccess(@NonNull AbsGroup group, GroupBean groupBean, MetaBean metaBean,int sourceInterfaceVale) {
        if (groupBean == null) {
            if (compLogicDataBean.loadMore) {
                pageData.totalCompSize = 0;
            } else {
                pageData.totalCompSize = pageData.totalCompSize + 0;
            }
            // 通知页面刷新
            if (group != null) {
                mGetDataFinishTask.onGetPartialDataFinish(group);
            }
            return;
        }
        //不是加载更多,首次,下拉,做降级处理
        if (!compLogicDataBean.loadMore){
            if (ArrayUtils.isEmpty(groupBean.getComps())){
                pageData.totalCompSize = pageData.totalCompSize + 0;
                // 通知页面刷新
                if (group != null) {
                    mGetDataFinishTask.onGetPartialDataFinish(group);
                }
                return;
            }
        }
        // 设置楼层接口来自哪个接口
        groupBean.setSourceInterfaceVal(sourceInterfaceVale);
        if (!compLogicDataBean.loadMore) {
            CacheData localCacheData = CacheData.getLocalCacheData(CacheData.compGroupInfoDataCacheKey + compLogicDataBean.pageId + group.getId());
            // 新旧数据md5值对比
            String dataMd5 = chacheDataAndNewDataContrastByMd5ToComp(localCacheData, metaBean, 0, false);
            // 保存缓存
            CacheData.saveDataToPreference(CacheData.compGroupInfoDataCacheKey + compLogicDataBean.pageId + group.getId(), groupBean, dataMd5);
        }

        if (group != null) {

            pageData.moreRefresh = compLogicDataBean.loadMore;
            // 整合comp对象
            groupCompDataParse(groupBean, group);
            // 通知完成数据请求
            mGetDataFinishTask.onGetPartialDataFinish(group);

        } else {
            mGetDataFinishTask.onGetPartialDataFinish(group);
        }
    }
    /**
     *处理compInfo接口数据失败的
     */
    private void dealCompInfoDataFail(String msg){
        // 专题和频道二级页面无需提示,会在页面中提示
        if (compLogicDataBean != null && compLogicDataBean.tipFlag) {
            ToastNightUtil.showShort(msg);
        }
        if (mListener != null) {
            mListener.onPageDataFailed(1,"compInfo is error");
        }
    }


    /**
     * 读取页面组件缓存数据-页面数据
     */
    public void loadLocalPageCacheData(String pageId) {
        CacheData pageCacheData = CacheData.getLocalCacheData(CacheData.comPageInfoCacheKey + pageId);
        if (pageCacheData != null && !StringUtils.isBlank(pageCacheData.getNetWorkData())) {
            String netWorkData = pageCacheData.getNetWorkData();
            PageBean pageBean = GsonUtils.fromJson(netWorkData, PageBean.class);
            if (pageBean == null || ArrayUtils.isEmpty(pageBean.getGroups())) {
                //没有缓存请求新数据
                getPageData(false, compLogicDataBean);
                return;
            }
            if (mListener != null) {
                mListener.onPageInforSuccess(pageBean);
            }
            pageBean.isLocalCache = true;
            callback(pageBean, true);
        } else {
            //没有缓存请求新数据
            getPageData(false, compLogicDataBean);
        }
    }


    /**
     * 楼层的组件卡缓存数据-卡片数据
     * compInfo 缓存数据
     */
    private void loadLocalCompCacheData(AbsGroup group, String groupId) {

        CacheData groupCacheData = CacheData.getLocalCacheData(CacheData.compGroupInfoDataCacheKey + compLogicDataBean.pageId + groupId);
        if (groupCacheData != null && !StringUtils.isBlank(groupCacheData.getNetWorkData())) {
            String netWorkData = groupCacheData.getNetWorkData();
            GroupBean groupBean = GsonUtils.fromJson(netWorkData, GroupBean.class);
            if (groupBean == null) {
                // 无缓存 compinfor信息直接调用接口
                loadGroupData(group, false);
                return;
            }
            mGetDataFinishTask.registerCondition(group);
            List<AbsGroup> groupsList = mPage.getGroups();
            int groupSize = groupsList.size();
            if (groupSize > 1) {
                // 读取缓存数据(组件可能配置动态接口,没有延迟机制无法获取到组件中存储的数据)
                Observable.timer(10, TimeUnit.MILLISECONDS)
                        .subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread())
                        .subscribe(a -> {

                            groupCompDataParse(groupBean, group);
                            // 通知页面刷新
                            mGetDataFinishTask.onGetPartialDataFinish(group);
                        });
            } else {

                groupCompDataParse(groupBean, group);
                // 通知页面刷新
                mGetDataFinishTask.onGetPartialDataFinish(group);
            }

        } else {
            // 无缓存 compinfor信息直接调用接口
            loadGroupData(group, false);
        }

    }


    /**
     * 初始化二次请求完成的监听器
     */
    private void initRequestConditionTask() {
        // 这里直接new
        mGetDataFinishTask = new PageDataFinishTask(1);
        mGetDataFinishTask.setPageDataFetcher(this);
    }

    /**
     * 检索所有一次页面请求获取的所有楼层的稿件和组件
     */
    public void retrieveAllGroupOfComp() {

        // 收集所有稿件compbean
        List<CompBean> compList = pageData.getRequestLayerCompList();
        if (ArrayUtils.isNotEmpty(compList)){
            int size = compList.size();
            if (size > 0) {

                CompBean preCompBean = null;// 上一个数据
                CompBean lastCompBean = pageData.getLastCompBean();// 上一次请求的最后一个组件或者稿件数据
                preCompBean = lastCompBean;

                for (int a = 0; a < size; a++) {
                    CompBean compBean = compList.get(a);
                    compBean.preCompBean = preCompBean;
                    int b = a + 1;
                    if (b < size) {
                        compBean.nextCompBean = compList.get(b);
                    }
                    preCompBean = compBean;
                }
                //Log.e("DDDDSSS", "retrieveAllGroupOfComp size=" + size);
                //记录页面已经展示的稿件和组件信息
                pageData.addNewPageCompData(compList);
            }
        }
    }

    /**
     * 处理所有楼层中compbean数据用来批查
     */
    protected void handlerAllCompDataBetchData() {
        if(pageData == null){
            return;
        }
        //1、第一次使用缓存进行批查;2、需要刷新进行批查
        if (pageData.moreRefresh || pageData.needRefresh || pageData.isLocalCache) {
            // 收集所有稿件compbean
            List<CompBean> compList = pageData.getRequestLayerCompList();
            if(ArrayUtils.isEmpty(compList)){
                return;
            }
            if(pageData.needRefresh || pageData.isLocalCache){
                setFirstPageCompList(compList);
            }
            if (compList != null && compList.size() > 0) {
                // 批查稿件相关参数
                betchQueryItemDy(compList, PageDataFetcher.this);
            }
        }else if(CompLogicDataBean.PULL_DOWN.equals(compLogicDataBean.loadStrategy)){
            List<CompBean> compList = getFirstPageCompList();
            if (compList != null && compList.size() > 0) {
                // 批查稿件相关参数
                betchQueryItemDy(compList, PageDataFetcher.this);
            }
        }

    }

    /**
     * 重置Page数据
     */
    protected void resetPage() {
        if (mPage == null) {
            return;
        }
        int groupIndex = -1;
        int sectionIndex = -1;
        for (int i = 0; i < mPage.getGroups().size(); i++) {
            AbsGroup group = mPage.getGroups().get(i);
            if (group == null) {
                continue;
            }
            for (int j = 0; j < group.getSections().size(); j++) {
                AbsSection section = group.getSections().get(j);
                if (section == null) {
                    continue;
                }
                // 专题tab分栏 PROGRAM_TAB_COL & Program_Tab_Col-01
                if (StringUtils.isEqual("Program_Tab_Col-01", section.getCompStyle())) {
                    groupIndex = i;
                    sectionIndex = j;
                    break;
                }
            }
        }
        if (sectionIndex == -1) {
            // 没有特殊样式
            return;
        }
        List<AbsGroup> tempGroups = mPage.getGroups();
        mPage.setGroups(new ArrayList<>());
        for (int i = 0; i < groupIndex; i++) {
            mPage.getGroups().add(tempGroups.get(i));
        }
        AbsGroup specialGroup = tempGroups.get(groupIndex);
        AbsSection specialSection = specialGroup.getSections().get(sectionIndex);
        for (int i = 0; i < sectionIndex; i++) {
            AbsGroup lastGroup = ArrayUtils.getListElement(mPage.getGroups(), groupIndex - 1);
            if (lastGroup == null) {
                break;
            }
            // 将同一个group里,特殊样式前面的样式,添加到前一个group里
            lastGroup.getSections().add(specialGroup.getSections().get(i));
        }
        // 特殊样式group里,只保留特殊样式,并塞值给特殊楼层字段
        specialGroup.getSections().clear();
        specialGroup.getSections().add(specialSection);
        mPage.setSpecialGroup(specialGroup);
    }

    private List<CompBean> getFirstPageCompList() {
        return firstPageCompList;
    }

    private void setFirstPageCompList(List<CompBean> firstPageCompList) {
        if(ArrayUtils.isEmpty(this.firstPageCompList)){
            this.firstPageCompList = new ArrayList<>();
        }else {
            this.firstPageCompList.clear();
        }
        this.firstPageCompList.addAll(firstPageCompList);
    }
}