Merge branch 'sync_page_data'

app/src/main/java/com/gh/base/fragment/BaseFragment.java

@@ -19,6 +19,9 @@ import androidx.fragment.app.FragmentTransaction;
 import com.gh.base.OnListClickListener;
 import com.gh.base.OnRequestCallBackListener;
 import com.gh.common.constant.Constants;
+import com.gh.common.syncpage.ISyncAdapterHandler;
+import com.gh.common.syncpage.SyncDataEntity;
+import com.gh.common.syncpage.SyncPageRepository;
 import com.gh.gamecenter.BuildConfig;
 import com.gh.gamecenter.eventbus.EBMiPush;
 import com.lightgame.OnTitleClickListener;
@@ -32,10 +35,18 @@ import org.greenrobot.eventbus.ThreadMode;
 import java.lang.ref.WeakReference;
 import java.util.List;
 
+import androidx.annotation.LayoutRes;
+import androidx.annotation.NonNull;
+import androidx.annotation.Nullable;
+import androidx.annotation.StringRes;
+import androidx.fragment.app.Fragment;
+import androidx.fragment.app.FragmentTransaction;
+import androidx.recyclerview.widget.RecyclerView;
 import butterknife.ButterKnife;
 import io.reactivex.Observable;
 import io.reactivex.android.schedulers.AndroidSchedulers;
 import io.reactivex.schedulers.Schedulers;
+import kotlin.Pair;
 
 import static com.gh.common.util.EntranceUtils.KEY_ENTRANCE;
 
@@ -142,6 +153,36 @@ public abstract class BaseFragment<T> extends Fragment implements OnRequestCallB
         ButterKnife.bind(this, mCachedView);
 
         initView(mCachedView);
+
+        if (addSyncPageObserver()) {
+            initSyncPageObserver();
+        }
+    }
+
+    private void initSyncPageObserver() {
+        SyncPageRepository.INSTANCE.getSyncPageLiveData().observe(this, syncDataEntities -> {
+            try {
+                if (syncDataEntities == null || syncDataEntities.isEmpty()) return;
+                RecyclerView.Adapter adapter = provideSyncAdapter();
+                if (!(adapter instanceof ISyncAdapterHandler)) return;
+                for (int i = 0; i < adapter.getItemCount(); i++) {
+                    Pair<String, Object> syncKey = ((ISyncAdapterHandler) adapter).getSyncData(i);
+                    if (syncKey == null) return;
+                    for (SyncDataEntity syncDataEntity : syncDataEntities) {
+                        if (syncDataEntity.getSyncId().equals(syncKey.getFirst())) {
+                            boolean isSuccess = SyncPageRepository.INSTANCE.handleSyncData(syncKey.getSecond(), syncDataEntity);
+                            if (isSuccess) adapter.notifyItemChanged(i);
+                        }
+                    }
+                }
+            } catch (Exception e) {
+                if (BuildConfig.DEBUG) {
+                    throw e;
+                } else {
+                    e.printStackTrace();
+                }
+            }
+        });
     }
 
     // 必须的有subscribe才能register
@@ -252,4 +293,12 @@ public abstract class BaseFragment<T> extends Fragment implements OnRequestCallB
         return this;
     }
 
+    @Nullable
+    protected RecyclerView.Adapter provideSyncAdapter() {
+        return null;
+    }
+
+    protected boolean addSyncPageObserver() {
+        return false;
+    }
 }