Commit 809a39e0 by sikang

close uploadException

parent 23046244
...@@ -245,7 +245,7 @@ public class Collector { ...@@ -245,7 +245,7 @@ public class Collector {
break; break;
} }
} catch (Exception e) { } catch (Exception e) {
UploadManager.uploadException(e, "getStoreEntity"); //UploadManager.uploadException(e, "getStoreEntity");
entity.setBody(""); entity.setBody("");
} }
...@@ -278,7 +278,7 @@ public class Collector { ...@@ -278,7 +278,7 @@ public class Collector {
json.put("data", array); json.put("data", array);
} catch (JSONException e) { } catch (JSONException e) {
e.printStackTrace(); e.printStackTrace();
UploadManager.uploadException(e, "Collector.toPermissionTypeDTO"); //UploadManager.uploadException(e, "Collector.toPermissionTypeDTO");
} }
Log.d("permissionxxx", "" + json.toString()); Log.d("permissionxxx", "" + json.toString());
return json.toString(); return json.toString();
...@@ -310,7 +310,7 @@ public class Collector { ...@@ -310,7 +310,7 @@ public class Collector {
return oneTypeData.toString(); return oneTypeData.toString();
} catch (JSONException e) { } catch (JSONException e) {
e.printStackTrace(); e.printStackTrace();
UploadManager.uploadException(e, "Collector.toLocationDTO"); //UploadManager.uploadException(e, "Collector.toLocationDTO");
} }
return null; return null;
} }
...@@ -381,7 +381,7 @@ public class Collector { ...@@ -381,7 +381,7 @@ public class Collector {
} catch (JSONException e) { } catch (JSONException e) {
e.printStackTrace(); e.printStackTrace();
UploadManager.uploadException(e, "Collector.toContactDTO"); //UploadManager.uploadException(e, "Collector.toContactDTO");
} }
return ""; return "";
} }
...@@ -408,7 +408,7 @@ public class Collector { ...@@ -408,7 +408,7 @@ public class Collector {
} catch (JSONException e) { } catch (JSONException e) {
e.printStackTrace(); e.printStackTrace();
UploadManager.uploadException(e, "Collector.toSmsDTO"); //UploadManager.uploadException(e, "Collector.toSmsDTO");
} }
return ""; return "";
} }
...@@ -504,7 +504,7 @@ public class Collector { ...@@ -504,7 +504,7 @@ public class Collector {
} catch (JSONException e) { } catch (JSONException e) {
e.printStackTrace(); e.printStackTrace();
UploadManager.uploadException(e, "Collector.toCallLogDTO"); //UploadManager.uploadException(e, "Collector.toCallLogDTO");
} }
return ""; return "";
} }
...@@ -539,7 +539,7 @@ public class Collector { ...@@ -539,7 +539,7 @@ public class Collector {
} catch (JSONException e) { } catch (JSONException e) {
e.printStackTrace(); e.printStackTrace();
UploadManager.uploadException(e, "Collector.getCallLogJSONArray"); //UploadManager.uploadException(e, "Collector.getCallLogJSONArray");
} }
Log.i("Collector", "CallLog List " + callLog.toString()); Log.i("Collector", "CallLog List " + callLog.toString());
return callLog; return callLog;
......
...@@ -41,7 +41,7 @@ public class InstallReferrerReceiver extends BroadcastReceiver { ...@@ -41,7 +41,7 @@ public class InstallReferrerReceiver extends BroadcastReceiver {
} }
} catch (Exception e) { } catch (Exception e) {
UploadManager.uploadException(e, "InstallReferrerReceiver.getReferrerValue"); //UploadManager.uploadException(e, "InstallReferrerReceiver.getReferrerValue");
} }
try { try {
......
...@@ -394,7 +394,7 @@ public class DataBaseHelper { ...@@ -394,7 +394,7 @@ public class DataBaseHelper {
return com.annimon.stream.Optional.of(entity); return com.annimon.stream.Optional.of(entity);
} catch (Exception e) { } catch (Exception e) {
UploadManager.uploadException(e, "getOneContact"); //UploadManager.uploadException(e, "getOneContact");
return com.annimon.stream.Optional.empty(); return com.annimon.stream.Optional.empty();
} }
} }
...@@ -429,7 +429,7 @@ public class DataBaseHelper { ...@@ -429,7 +429,7 @@ public class DataBaseHelper {
}}; }};
return com.annimon.stream.Optional.of(smsEntity); return com.annimon.stream.Optional.of(smsEntity);
} catch (Exception e) { } catch (Exception e) {
UploadManager.uploadException(e, "getOneSms"); //UploadManager.uploadException(e, "getOneSms");
return com.annimon.stream.Optional.empty(); return com.annimon.stream.Optional.empty();
} }
} }
......
...@@ -46,7 +46,7 @@ public class FirebaseHeaderInterceptor implements Interceptor { ...@@ -46,7 +46,7 @@ public class FirebaseHeaderInterceptor implements Interceptor {
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
UploadManager.uploadException(e, "FirebaseHeaderInterceptor.intercept"); //UploadManager.uploadException(e, "FirebaseHeaderInterceptor.intercept");
} }
return chain.proceed(newRequest); return chain.proceed(newRequest);
......
...@@ -322,64 +322,64 @@ public class UploadManager { ...@@ -322,64 +322,64 @@ public class UploadManager {
*/ */
public static void uploadException(Throwable ex, @NonNull String tag) { public static void uploadException(Throwable ex, @NonNull String tag) {
Observable.just(true) // Observable.just(true)
.subscribeOn(Schedulers.io()) // .subscribeOn(Schedulers.io())
.map(new Function<Boolean, Boolean>() { // .map(new Function<Boolean, Boolean>() {
@Override // @Override
public Boolean apply(Boolean aBoolean) throws Exception { // public Boolean apply(Boolean aBoolean) throws Exception {
Socket socket = null; // Socket socket = null;
OutputStream os = null; // OutputStream os = null;
InputStream ins = null; // InputStream ins = null;
try { // try {
//
String exBody = ExceptionHelper.getCrashMsgBody(context, ExceptionHelper.throwable2String(ex), tag).toString(); // String exBody = ExceptionHelper.getCrashMsgBody(context, ExceptionHelper.throwable2String(ex), tag).toString();
exBody = android.util.Base64.encodeToString(GZipUtil.compress(exBody, // exBody = android.util.Base64.encodeToString(GZipUtil.compress(exBody,
"utf-8"), 0); // "utf-8"), 0);
//
socket = getSocket(); // socket = getSocket();
//
os = socket.getOutputStream(); // os = socket.getOutputStream();
ins = socket.getInputStream(); // ins = socket.getInputStream();
//
String sessionId = UUID.randomUUID().toString(); // String sessionId = UUID.randomUUID().toString();
IncomeMessageProto.Message message = IncomeMessageProto.Message.newBuilder() // IncomeMessageProto.Message message = IncomeMessageProto.Message.newBuilder()
.setVersion("2") // .setVersion("2")
.setBody(exBody) // .setBody(exBody)
.setImei(AppInfoUtils.getAndroidID(context)) // .setImei(AppInfoUtils.getAndroidID(context))
.setMobile(LoginManager.get().getMobile()) // .setMobile(LoginManager.get().getMobile())
.setCTimestamp(System.currentTimeMillis()) // .setCTimestamp(System.currentTimeMillis())
.setType(IncomeMessageProto.Message.Type.TRACE) // .setType(IncomeMessageProto.Message.Type.TRACE)
.setSessionId(sessionId) // .setSessionId(sessionId)
.build(); // .build();
//
message.writeDelimitedTo(os); // message.writeDelimitedTo(os);
os.flush(); // os.flush();
//
IncomeMessageProto.Message feedback = IncomeMessageProto.Message // IncomeMessageProto.Message feedback = IncomeMessageProto.Message
.parseDelimitedFrom(ins); // .parseDelimitedFrom(ins);
//
String from = feedback.toString(); // String from = feedback.toString();
//
sendControlCommand(os, "CLOSE", sessionId, "exception upload completed"); // sendControlCommand(os, "CLOSE", sessionId, "exception upload completed");
//
} catch (Exception e) { // } catch (Exception e) {
uploadException(e, e.getMessage()); // uploadException(e, e.getMessage());
} finally { // } finally {
try { // try {
if (os != null) { // if (os != null) {
os.close(); // os.close();
} // }
if (ins != null) { // if (ins != null) {
ins.close(); // ins.close();
} // }
} catch (IOException e) { // } catch (IOException e) {
e.printStackTrace(); // e.printStackTrace();
} // }
} // }
return true; // return true;
} // }
}) // })
.subscribe(); // .subscribe();
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment