/*
 * Copyright (c) People Technologies Co., Ltd. 2019-2022. All rights reserved.
 */

package com.wd.layoutdataimpl.model;


import android.text.TextUtils;


import com.people.room.ChannelDbHelper;
import com.wd.base.log.Logger;
import com.wd.capability.layout.ui.channel.vm.IChannelDataListener;
import com.wd.capability.network.BaseObserver;
import com.wd.capability.network.bean.MetaBean;
import com.wd.capability.network.cachedata.CacheData;
import com.wd.common.api.RequestApi;
import com.wd.capability.network.response.BaseResponse;
import com.wd.foundation.bean.response.ChannelBean;
import com.wd.foundation.wdkitcore.constant.BaseConstants;
import com.wd.foundation.bean.custom.SimpleTabBean;
import com.wd.foundation.bean.custom.comp.PageBean;
import com.wd.foundation.bean.response.PageTopNavBean;
import com.wd.capability.network.fetcher.BaseDataFetcher;
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.AppContext;
import com.wd.foundation.wdkitcore.tools.ArrayUtils;
import com.wd.foundation.wdkitcore.tools.JsonUtils;
import com.wd.foundation.wdkitcore.tools.StringUtils;

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

import io.reactivex.Observable;

/**
 * 频道数据的抓取器<BR>
 * 对接新的接口，结构调整了，较之前的改动大<BR>
 * 结果回调统一走onPageDataSuccess，不走onPartialDataSuccess了。只有page接口和group接口都回来才能刷UI
 *
 * @author zhangbo
 * @version [V1.0.0, 2022/4/12]
 * @since V1.0.0
 */
public class ChannelDataFetcherNews extends BaseDataFetcher<RequestApi> {

    private static final String TAG = "ChannelDataFetcherNews";


    private final IChannelDataListener mListener;


    /**
     * 构造器
     *
     * @param listener 监听回调
     */
    public ChannelDataFetcherNews(IChannelDataListener listener) {
        this.mListener = listener;
    }


    /**
     * 取消任务
     */
    public void cancel() {
    }


    /**
     * 获取顶部菜单导航栏数据（底部导航栏接口里返回的）
     *
     * @param id
     * @param isNewsChannel 非新闻tab传的false
     */
    public void getPageTopNavData(String id, boolean isNewsChannel) {
        int firstLocation = SpUtils.getFirstLocation();

        // 读取缓存数据
        int dataType = loadLocalCacheData(id, isNewsChannel);
        // 启动接口优化，点击底部导航tab
        //有缓存
//        Logger.e("newsTabMd5 ==dataType="+dataType+",isNewsChannel=="+isNewsChannel);
//        Logger.e("newsTabMd5 ==BaseConstants.newsTabMd5="+BaseConstants.newsTabMd5);
        if (2 == dataType) {
            //新闻tab
            if (isNewsChannel) {
                String newsTabGroupMd5 = SpUtils.getBottomNavGroupDetailMd5();
                //有数据，保存的md5不为空，并且和接口给的md5一致，不用再调接口
                if (StringUtils.isBlank(BaseConstants.newsTabMd5)) {
//                    Logger.e("newsTabMd5空的==不会调用");
                    return;
                }
//                Logger.e("newsTabMd5 调用== firstLocation="+firstLocation);
//                Logger.e("newsTabMd5 ==newsTabGroupMd5=="+newsTabGroupMd5);
                if (1 != firstLocation && StringUtils.isNotBlank(newsTabGroupMd5)
                        && newsTabGroupMd5.equals(BaseConstants.newsTabMd5)) {
//                    Logger.e("newsTabMd5不变==不会调用");
                    return;
                }
                SpUtils.saveBottomNavGroupDetailMd5(BaseConstants.newsTabMd5);
            } else {
                //如果不是新闻tab并且有缓存数据，不再进行接口请求
                return;
            }
        }
//        Logger.e("newsTabMd5正常调用==");

        Map<String, Object> map = new HashMap<>();
        map.put("id", id);

        if (0 == firstLocation || 1 == firstLocation){
            map.put("firstLocation", firstLocation);
        }

        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());
        }

        if (isNewsChannel && dataType != 1) {
            List<com.people.room.entity.ChannelBean> channelBeans = ChannelDbHelper.getInstance(AppContext.getContext()).searchAllSelectChannel();
            List<ChannelBean> myChannelBeans = convertBeanList(channelBeans);
            StringBuilder builder = new StringBuilder();
            int index = -1;
            if (myChannelBeans != null && myChannelBeans.size() > 0) {
                int size = myChannelBeans.size();
                for (ChannelBean myChannelBean : myChannelBeans) {
                    index = index + 1;
                    builder.append(myChannelBean.getChannelId());
                    if (index != size - 1) {
                        builder.append(",");
                    }
                }
                //获取我的频道
                map.put("channelIds", builder.toString());
            }
        }

        Observable<BaseResponse<PageTopNavBean>> groupDataObservable = getRetrofit().getTopNavDetail(map);

        request(groupDataObservable, new BaseObserver<PageTopNavBean>() {

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

            @Override
            protected void onSuccess(PageTopNavBean bean) {

            }

            @Override
            protected void onSuccess(PageTopNavBean pageTopNavBean, MetaBean metaBean, String msg, int code) {
                if (pageTopNavBean == null) {
                    mListener.onPageDataFailed(" no data");
                    return;
                }
                if (1 == firstLocation){
                    //定位到数据首次请求拿到了地市频道->保存为2
                    SpUtils.saveFirstLocation(2);
                }else if (0 == firstLocation){
                    //拒绝授权首次请求->保存为3
                    SpUtils.saveFirstLocation(3);
                }

                CacheData localCacheData = CacheData.getLocalCacheDataNoClear(CacheData.channelCacheDataKey + id);
                //没缓存数据进行刷新
                boolean needRefresh = false;

                if (localCacheData == null) {
                    needRefresh = true;
                }

                String dataMd5 = "";
                if (metaBean != null) {
                    dataMd5 = metaBean.getMd5();
                }
                //代码规范提示if里不要有复杂计算
                if (localCacheData != null && localCacheData.needRefreshByMd5(dataMd5)) {
                    needRefresh = true;
                }
                if (needRefresh) {

                    if (isNewsChannel) {
                        //  2023/5/18 更新本地栏目数据
                        updateLocalColumnSubscriptionDb(pageTopNavBean, "3");
                    } else {
                        onTopNavDataSuccess(pageTopNavBean, isNewsChannel);
                    }

                }
                if (pageTopNavBean.getTopNavChannelList() != null &&
                        pageTopNavBean.getTopNavChannelList().size() > 0) {
                    // 缓存到本地
                    CacheData.saveDataToPreferenceNoClear(CacheData.channelCacheDataKey + id, pageTopNavBean, dataMd5);
                }

            }

            @Override
            protected void _onError(String message) {
                super._onError(message);
                ToastNightUtil.showShort(message);
                if (mListener != null) {
                    mListener.onPageDataFailed(message);
                }

            }
        });

    }

    /**
     * 读取缓存数据-频道数据
     *
     * @param id
     * @param isNewsChannel
     * @return 0:无数据；1：预置数据；2：接口缓存数据
     */
    private int loadLocalCacheData(String id, boolean isNewsChannel) {
        CacheData pageTopNavData = CacheData.getLocalCacheDataNoClear(CacheData.channelCacheDataKey + id);
        if (pageTopNavData != null && !StringUtils.isBlank(pageTopNavData.getNetWorkData())) {
            // 缓存数据
            String netWorkData = pageTopNavData.getNetWorkData();
            PageTopNavBean pageTopNavBean = GsonUtils.fromJson(netWorkData, PageTopNavBean.class);
            // 更新频道选择页面数据
            if (isNewsChannel) {
                updateLocalColumnSubscriptionDb(pageTopNavBean, "2");
            } else {
                onTopNavDataSuccess(pageTopNavBean, isNewsChannel);
            }
            return 2;
        } else {
            // 预置的数据
            String pageTopNavPresetsData = CacheData.getChannelPresetsData(id);
            if (!StringUtils.isBlank(pageTopNavPresetsData)) {
                PageTopNavBean pageTopNavBean = GsonUtils.fromJson(pageTopNavPresetsData, PageTopNavBean.class);
                if (isNewsChannel) {
                    //  2023/5/18 本地无栏目数据则更新本地栏目数据
                    updateLocalColumnSubscriptionDb(pageTopNavBean, "1");
                } else {
                    onTopNavDataSuccess(pageTopNavBean, isNewsChannel);
                }
                return 1;
            }
        }
        return 0;
    }

    /**
     * 处理频道数据
     *
     * @param bean
     */
    private void onTopNavDataSuccess(PageTopNavBean bean, boolean isUseCache) {
        if (bean == null) {
            return;
        }

        SimpleTabBean simpleTabBean = new SimpleTabBean();
        if (isUseCache) {
            List<com.people.room.entity.ChannelBean> channelList = ChannelDbHelper.getInstance(AppContext.getContext()).searchAllSelectChannel();
            List<ChannelBean> myChannelList = convertBeanList(channelList);
            if (!myChannelList.isEmpty()) {
                simpleTabBean.setTopNavChannelList(myChannelList);
            } else {
                simpleTabBean.setTopNavChannelList(bean.getTopNavChannelList());
            }
        } else {
            simpleTabBean.setTopNavChannelList(bean.getTopNavChannelList());
        }

        mListener.onPageDataSuccess(simpleTabBean);
    }

    /**
     * 调用pageinfor 接口
     *
     * @param pageId
     */
    public void getPageInfor(String pageId) {


        CacheData localCacheData = loadLocalPageInforCacheData(pageId);

        Map<String, Object> map = new HashMap<>();
        map.put("pageId", pageId);
        Observable<BaseResponse<PageBean>> pageDataObservable = getRetrofit().getPageData(map);
        request(pageDataObservable, new BaseObserver<PageBean>() {

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

            @Override
            protected void onSuccess(PageBean pageBean) {

            }

            @Override
            protected void onSuccess(PageBean pageBean, MetaBean metaBean, String msg, int code) {
                if (pageBean == null) {
                    if (mListener != null) {
                        mListener.onPageDataFailed("pageinfor is not exist");
                    }
                    return;
                }

                //没缓存数据进行刷新
                boolean needRefresh = false;
                if (localCacheData == null) {
                    needRefresh = true;
                }

                String dataMd5 = "";
                if (metaBean != null) {
                    dataMd5 = metaBean.getMd5();
                }
                //代码规范提示if里不要有复杂计算
                if (localCacheData != null && localCacheData.needRefreshByMd5(dataMd5)) {
                    needRefresh = true;
                }
                if (needRefresh) {
                    if (mListener != null) {
                        mListener.onPageDataSuccess(null, pageBean);
                    }
                }

                if (needRefresh) {
                    // 缓存到本地
                    CacheData.saveDataToPreference(CacheData.comPageInfoCacheKey + pageId, pageBean, dataMd5);
                }

            }

            @Override
            protected void _onError(String e) {
                ToastNightUtil.showShort(e);
                if (mListener != null) {
                    mListener.onPageDataFailed(e);
                }
            }
        });
    }



    /**
     * 获取本地pageInfor数据
     *
     * @param pageId
     */
    public CacheData loadLocalPageInforCacheData(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())) {
                return null;
            }
            pageBean.isLocalCache = true;
            if (mListener != null) {
                mListener.onPageDataSuccess(null, pageBean);
            }
            return pageCacheData;
        } else {
            return null;
        }
    }

    /**
     * 根据首次预置或者有变化的接口数据更新栏目订阅所需数据库数据
     * 1预置数据、2本地数据、3接口数据
     */
    private synchronized void updateLocalColumnSubscriptionDb(PageTopNavBean bean, String type) {
        //使用本地数据
        if ("2".equals(type)) {
            //无需变化，优先首页逻辑
            onTopNavDataSuccess(bean, true);
        }
        //无数据
        if (bean == null || bean.getTopNavChannelList() == null || bean.getTopNavChannelList().size() == 0) {
            onTopNavDataSuccess(bean, false);
            return;
        }
        //获取本地数据库
        ChannelDbHelper helper = ChannelDbHelper.getInstance(AppContext.getContext());
        //预置数据 如果数据库已经有数据，则无需更新，数据库的数据和预置的一样
        if ("1".equals(type) && helper.hasData()) {
            onTopNavDataSuccess(bean, true);
            return;
        }
        List<ChannelBean> topNavChannelList = bean.getTopNavChannelList();
        List<com.people.room.entity.ChannelBean> copyList = convertRoomList(topNavChannelList);
        //本地数据直接获取
        if ("2".equals(type)) {
            if (!helper.hasData()) {
                helper.save(copyList);
            }
        } else {
            //清除本地数据
            helper.deleteAll();
            //4.保存数据到数据库
            helper.save(copyList);

            onTopNavDataSuccess(bean, true);
        }
    }

    private List<com.people.room.entity.ChannelBean> convertRoomList(List<ChannelBean> topNavChannelList) {
        List<com.people.room.entity.ChannelBean> retList;
        try {
            String objectToJson = JsonUtils.convertObjectToJson(topNavChannelList);
            retList = JsonUtils.convertJsonArrayToObjList(objectToJson,com.people.room.entity.ChannelBean.class);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
        return retList;
    }

    private List<ChannelBean> convertBeanList(List<com.people.room.entity.ChannelBean> channelList) {
        List<ChannelBean> retList;
        try {
            String objectToJson = JsonUtils.convertObjectToJson(channelList);
            retList = JsonUtils.convertJsonArrayToObjList(objectToJson,ChannelBean.class);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
        return retList;
    }


}