|
|
[mw_shl_code=java,true]package com.baidu.tieba.myCollection.baseEditMark;
import com.baidu.adp.lib.asyncTask.BdAsyncTask;
import com.baidu.adp.lib.util.BdLog;
import com.baidu.tbadk.TbConfig;
import com.baidu.tbadk.baseEditMark.MarkData;
import com.baidu.tbadk.core.TbadkCoreApplication;
import com.baidu.tbadk.core.atomData.PhotoLiveActivityConfig;
import com.baidu.tbadk.core.sharedPref.b;
import com.baidu.tbadk.core.util.a.c;
import com.baidu.tbadk.core.util.aa;
import com.baidu.tbadk.core.util.x;
import com.baidu.tieba.tbadkCore.util.m;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;
import org.json.JSONArray;
import org.json.JSONObject;
public class a
{
private b cFg = null;
private c cFh = null;
private a cFi = null;
private ArrayList<MarkData> cFj = new ArrayList();
private int cFk = 0;
private int cFl = 0;
protected com.baidu.tieba.myCollection.o cFm = null;
private boolean mIsFirst = false;
private void SR()
{
if (this.cFj == null) {}
for (;;)
{
return;
HashSet localHashSet = new HashSet();
Iterator localIterator = this.cFj.iterator();
while (localIterator.hasNext())
{
MarkData localMarkData = (MarkData)localIterator.next();
String str = localMarkData.getId();
int i = localMarkData.getReplyNum();
if (!localHashSet.add(str))
{
ad(str, i);
localIterator.remove();
}
}
}
}
private void ad(String paramString, int paramInt)
{
if ((this.cFj == null) || (x.o(this.cFj) <= 0)) {}
for (;;)
{
return;
Iterator localIterator = this.cFj.iterator();
while (localIterator.hasNext())
{
MarkData localMarkData = (MarkData)localIterator.next();
if ((localMarkData != null) && (localMarkData.getId().equals(paramString))) {
localMarkData.setReplyNum(paramInt);
}
}
}
}
private ArrayList<MarkData> kl(String paramString)
{
MarkData localMarkData = null;
ArrayList localArrayList = new ArrayList();
try
{
JSONObject localJSONObject = new org/json/JSONObject;
localJSONObject.<init>(paramString);
if (!localJSONObject.optJSONObject("error").optString("errno").equals("0")) {}
for (paramString = localMarkData;; paramString = localArrayList)
{
return paramString;
paramString = localJSONObject.optJSONArray("store_thread");
i = 0;
if (i < paramString.length()) {
break;
}
}
}
catch (Exception paramString)
{
for (;;)
{
int i;
BdLog.e(paramString.toString());
paramString = null;
}
}
localMarkData = new com/baidu/tbadk/baseEditMark/MarkData;
localMarkData.<init>();
localMarkData.paserJson(paramString.getJSONObject(i));
if (!localMarkData.isPhotoLiveThread()) {
localArrayList.add(localMarkData);
}
for (;;)
{
i++;
break;
if (TbadkCoreApplication.getInst().appResponseToIntentClass(PhotoLiveActivityConfig.class)) {
localArrayList.add(localMarkData);
}
}
}
public void T(ArrayList<MarkData> paramArrayList)
{
this.cFj = paramArrayList;
}
public void U(ArrayList<MarkData> paramArrayList)
{
if ((this.cFj != null) && (paramArrayList != null))
{
this.cFj.addAll(paramArrayList);
SR();
}
}
public void a(com.baidu.tieba.myCollection.o paramo)
{
this.cFm = paramo;
}
public void a(Boolean paramBoolean, boolean paramBoolean1)
{
if (this.cFg != null) {
this.cFg.cancel();
}
this.cFg = new b(getOffset());
this.cFg.setPriority(3);
this.cFg.execute(new Boolean[] { paramBoolean, Boolean.valueOf(paramBoolean1) });
}
public String aL(int paramInt1, int paramInt2)
{
if (this.cFj == null)
{
localObject = null;
return (String)localObject;
}
int i = paramInt1;
int j = paramInt2;
if (paramInt1 >= this.cFj.size())
{
j = paramInt2 - (paramInt1 - this.cFj.size() - 1);
i = this.cFj.size() - 1;
}
Object localObject = new JSONArray();
paramInt1 = 0;
paramInt2 = i;
if (paramInt2 >= 0) {
if (paramInt2 > i - j) {}
}
for (;;)
{
label79:
if (localObject == null)
{
localObject = null;
break;
}
label165:
for (;;)
{
try
{
JSONObject localJSONObject = ((MarkData)this.cFj.get(paramInt2)).toJson();
if ((localJSONObject == null) || (paramInt1 < 0)) {
break label165;
}
int k = paramInt1 + 1;
((JSONArray)localObject).put(paramInt1, localJSONObject);
paramInt1 = k;
paramInt2--;
}
catch (Exception localException)
{
BdLog.e(localException.toString());
str = null;
}
break label79;
String str = str.toString();
break;
}
}
}
public int anq()
{
return this.cFl;
}
public ArrayList<MarkData> anr()
{
return this.cFj;
}
public int ans()
{
return this.cFk;
}
public void ant()
{
ArrayList localArrayList = m.aNt();
if (localArrayList != null) {
T(localArrayList);
}
}
public int anu()
{
return b.uO().getInt("uploac_mark_offset", 399);
}
public void b(MarkData paramMarkData)
{
this.cFj.add(paramMarkData);
}
public void f(Boolean paramBoolean)
{
a(paramBoolean, true);
}
public int getCount()
{
if (this.cFj == null) {}
for (int i = 0;; i = this.cFj.size()) {
return i;
}
}
public int getOffset()
{
if (this.cFj == null) {}
for (int i = 0;; i = this.cFj.size()) {
return i;
}
}
public boolean hasMore()
{
if (this.cFk < 20) {}
for (boolean bool = false;; bool = true) {
return bool;
}
}
public boolean isFirst()
{
return this.mIsFirst;
}
public void kB(int paramInt)
{
this.cFl = paramInt;
}
public boolean kC(int paramInt)
{
if (this.cFi != null) {
this.cFi.cancel();
}
if ((paramInt < this.cFj.size()) && (this.cFj.get(paramInt) != null) && (((MarkData)this.cFj.get(paramInt)).getId() != null))
{
this.cFi = new a(((MarkData)this.cFj.get(paramInt)).getId(), paramInt);
this.cFi.setPriority(2);
this.cFi.execute(new Boolean[0]);
}
for (boolean bool = true;; bool = false) {
return bool;
}
}
public void kD(int paramInt)
{
b.uO().putInt("uploac_mark_offset", paramInt);
}
public void kk(String paramString)
{
try
{
JSONObject localJSONObject = new org/json/JSONObject;
localJSONObject.<init>(paramString);
paserJson(localJSONObject);
return;
}
catch (Exception paramString)
{
for (;;)
{
BdLog.e(paramString.toString());
}
}
}
public void onDestroy()
{
if (this.cFg != null) {
this.cFg.cancel();
}
if (this.cFh != null) {
this.cFh.cancel();
}
if (this.cFi != null) {
this.cFi.cancel();
}
}
public void paserJson(JSONObject paramJSONObject)
{
try
{
if (!paramJSONObject.optJSONObject("error").optString("errno").equals("0")) {
return;
}
paramJSONObject = paramJSONObject.optJSONArray("store_thread");
int i = 0;
label29:
MarkData localMarkData;
if (i < paramJSONObject.length())
{
localMarkData = new com/baidu/tbadk/baseEditMark/MarkData;
localMarkData.<init>();
localMarkData.paserJson(paramJSONObject.getJSONObject(i));
if (localMarkData.isPhotoLiveThread()) {
break label76;
}
this.cFj.add(localMarkData);
}
for (;;)
{
i++;
break label29;
break;
label76:
if (TbadkCoreApplication.getInst().appResponseToIntentClass(PhotoLiveActivityConfig.class)) {
this.cFj.add(localMarkData);
}
}
}
catch (Exception paramJSONObject)
{
for (;;)
{
BdLog.e(paramJSONObject.toString());
}
}
}
public void reset()
{
this.cFl = 0;
this.cFk = 0;
this.mIsFirst = true;
}
public void startSync()
{
if (this.cFh != null) {
this.cFh.cancel();
}
this.cFh = new c(null);
this.cFh.setPriority(2);
this.cFh.execute(new a[0]);
}
private class a
extends BdAsyncTask<Boolean, Integer, Boolean>
{
private aa Ty = null;
private e cFn = null;
private int pos = 0;
private String tid = null;
public a(String paramString, int paramInt)
{
this.tid = paramString;
this.pos = paramInt;
this.cFn = new e();
}
protected Boolean b(Boolean... paramVarArgs)
{
this.Ty = new aa(TbConfig.SERVER_ADDRESS + "c/c/post/rmstore");
this.Ty.p("user_id", TbadkCoreApplication.getCurrentAccount());
this.Ty.p("tid", this.tid);
paramVarArgs = this.Ty.uZ();
this.cFn.parserJson(paramVarArgs);
if ((this.Ty.vB().ww().rl()) && (this.cFn.getErrorCode() == 0)) {}
for (paramVarArgs = Boolean.valueOf(true);; paramVarArgs = Boolean.valueOf(false)) {
return paramVarArgs;
}
}
protected void b(Boolean paramBoolean)
{
Object localObject2 = null;
a.a(a.this, null);
Object localObject1;
if (paramBoolean.booleanValue())
{
localObject1 = localObject2;
if (this.pos < a.a(a.this).size())
{
a.a(a.this).remove(this.pos);
localObject1 = a.this;
a.b((a)localObject1, a.c((a)localObject1) - 1);
localObject1 = localObject2;
}
}
for (;;)
{
if (a.this.cFm != null) {
a.this.cFm.callback(new Object[] { Integer.valueOf(2), paramBoolean, localObject1 });
}
return;
if (this.Ty.vB().ww().rl()) {
localObject1 = this.cFn.getErrorString();
} else {
localObject1 = this.Ty.getErrorString();
}
}
}
public void cancel()
{
super.cancel(true);
if (this.Ty != null) {
this.Ty.gT();
}
a.a(a.this, null);
if (a.this.cFm != null) {
a.this.cFm.callback(new Object[] { Integer.valueOf(2), Boolean.valueOf(false), null });
}
}
}
private class b
extends BdAsyncTask<Boolean, String, a>
{
private aa Ty = null;
private e cFn = null;
Boolean cFp = Boolean.valueOf(false);
private String data = null;
private int offset = 0;
public b(int paramInt)
{
this.offset = paramInt;
this.cFn = new e();
}
private void hi(String paramString)
{
String str = TbadkCoreApplication.getCurrentAccount();
if (str == null) {}
for (;;)
{
return;
com.baidu.adp.lib.cache.o localo = com.baidu.tbadk.core.b.a.ug().cB("tb.my_bookmarks");
if (localo != null) {
localo.a(str, paramString, 604800000L);
}
}
}
protected a c(Boolean... paramVarArgs)
{
this.cFp = paramVarArgs[0];
if ((paramVarArgs.length >= 2) && (paramVarArgs[1] != null)) {}
for (boolean bool = paramVarArgs[1].booleanValue();; bool = true)
{
paramVarArgs = new a();
if ((this.cFp.booleanValue()) && (bool))
{
com.baidu.adp.lib.cache.o localo = com.baidu.tbadk.core.b.a.ug().cB("tb.my_bookmarks");
if (localo != null) {
publishProgress(new String[] { (String)localo.get(TbadkCoreApplication.getCurrentAccount()) });
}
if (a.a(a.this) == null)
{
a.a(a.this, new ArrayList());
a.a(a.this, 0);
}
}
else
{
this.Ty = new aa(TbConfig.SERVER_ADDRESS + "c/f/post/threadstore");
this.Ty.p("user_id", TbadkCoreApplication.getCurrentAccount());
if (!a.b(a.this)) {
break label315;
}
this.Ty.p("offset", String.valueOf(0));
label183:
this.Ty.p("rn", String.valueOf(20));
this.data = this.Ty.uZ();
this.cFn.parserJson(this.data);
if (this.Ty.vB().ww().rl())
{
paramVarArgs.kk(this.data);
if (this.offset == 0)
{
if (a.a(a.this) != null) {
break label334;
}
a.a(a.this, new ArrayList());
}
}
}
for (;;)
{
a.a(a.this, 0);
if (this.cFp.booleanValue()) {
hi(this.data);
}
return paramVarArgs;
a.a(a.this).clear();
break;
label315:
this.Ty.p("offset", String.valueOf(this.offset));
break label183;
label334:
a.a(a.this).clear();
}
}
}
public void cancel()
{
super.cancel(true);
if (this.Ty != null) {
this.Ty.gT();
}
a.a(a.this, null);
}
protected void d(a parama)
{
a locala = parama;
if (parama == null) {
locala = new a();
}
a.a(a.this, null);
a.a(a.this, locala.getCount());
parama = locala.anr();
int i;
if (this.cFp.booleanValue())
{
if ((parama != null) && (parama.size() != 0)) {
a.this.T(parama);
}
parama = parama.iterator();
i = 0;
label74:
if (parama.hasNext()) {
break label179;
}
if (a.this.cFm != null)
{
if (!this.Ty.vB().ww().rl()) {
break label208;
}
if (this.cFn.getErrorCode() == 0) {
break label244;
}
}
}
label179:
label208:
label244:
for (parama = this.cFn.getErrorString();; parama = null)
{
a.this.cFm.callback(new Object[] { Integer.valueOf(0), parama, Boolean.valueOf(false) });
for (;;)
{
a.b(a.this, false);
return;
a.this.U(parama);
break;
if (((MarkData)parama.next()).getNewCounts() <= 0) {
break label74;
}
i++;
a.this.kB(i);
break label74;
parama = this.Ty.getErrorString();
a.this.cFm.callback(new Object[] { Integer.valueOf(3), parama });
}
}
}
protected void onPreExecute() {}
protected void u(String... paramVarArgs)
{
super.onProgressUpdate(paramVarArgs);
paramVarArgs = paramVarArgs[0];
ArrayList localArrayList = new ArrayList();
if (paramVarArgs != null)
{
paramVarArgs = a.a(a.this, paramVarArgs);
if (this.cFp.booleanValue()) {
a.this.T(paramVarArgs);
}
}
for (;;)
{
a.this.cFm.callback(new Object[] { Integer.valueOf(0), null, Boolean.valueOf(true) });
return;
a.this.U(paramVarArgs);
continue;
a.this.T(localArrayList);
}
}
}
private class c
extends BdAsyncTask<a, Integer, Boolean>
{
private aa Ty = null;
private e cFn = null;
private c() {}
protected Boolean a(a... paramVarArgs)
{
paramVarArgs = new a();
for (;;)
{
try
{
paramVarArgs.ant();
localObject1 = new com/baidu/tbadk/core/util/aa;
((aa)localObject1).<init>();
this.Ty = ((aa)localObject1);
localObject1 = this.Ty;
localObject2 = new java/lang/StringBuilder;
((StringBuilder)localObject2).<init>(String.valueOf(TbConfig.SERVER_ADDRESS));
((aa)localObject1).setUrl("c/c/post/addstore");
i = a.this.anu();
if (paramVarArgs.getCount() - 1 <= i) {
continue;
}
if (i >= 0) {
continue;
}
a.this.kD(i);
if (i < 0) {
continue;
}
paramVarArgs = Boolean.valueOf(false);
}
catch (Exception paramVarArgs)
{
Object localObject1;
Object localObject2;
int i;
String str;
BdLog.e(paramVarArgs.getMessage());
paramVarArgs = Boolean.valueOf(false);
continue;
}
return paramVarArgs;
i = paramVarArgs.getCount() - 1;
continue;
str = paramVarArgs.aL(i, 20);
localObject2 = this.Ty;
localObject1 = new java/util/ArrayList;
((ArrayList)localObject1).<init>();
((aa)localObject2).n((ArrayList)localObject1);
this.Ty.p("data", str);
localObject1 = this.Ty.uZ();
this.cFn.parserJson((String)localObject1);
if ((this.Ty.vB().ww().rl()) && (this.cFn.getErrorCode() == 0))
{
i -= 20;
continue;
paramVarArgs = Boolean.valueOf(true);
}
}
}
protected void b(Boolean paramBoolean)
{
a.a(a.this, null);
String str;
boolean bool;
if (paramBoolean.booleanValue())
{
a.a(a.this).clear();
str = null;
bool = false;
}
for (;;)
{
if (a.this.cFm != null) {
a.this.cFm.callback(new Object[] { Integer.valueOf(1), paramBoolean, str, Boolean.valueOf(bool) });
}
return;
if (this.Ty.vB().ww().rl())
{
str = this.cFn.getErrorString();
bool = false;
}
else
{
str = null;
bool = true;
}
}
}
public void cancel()
{
super.cancel(true);
if (this.Ty != null) {
this.Ty.gT();
}
a.a(a.this, null);
if (a.this.cFm != null) {
a.this.cFm.callback(new Object[] { Integer.valueOf(1), Boolean.valueOf(false), null, Boolean.valueOf(false) });
}
}
protected void onPreExecute()
{
this.cFn = new e();
}
}
}
[/mw_shl_code]回复本帖查看 接口分析
上一篇：2016年3月21日签到记录贴
下一篇：贴吧客户端群组强制拉人+强制加好友 教程 |
|
发表于 2016-3-21 08:43:54
发表于 2016-6-5 07:26:11
