requestIdsMap = new ConcurrentHashMap<>();
- //超时时间
- private static int timeOut = 30;
- // 缓存文件最大限制大小20M
- private static long cacheSize = 1024 * 1024 * 64;
-
- public static final String HTTP_KEY = "YTM3YTAxNTJmMmZmNzkyM2E2YzIwZjlhZTc0NzNmMGI=";
- public static final String CUSTOM_REPEAT_REQ_PROTOCOL = "MY_CUSTOM_REPEAT_REQ_PROTOCOL";
-
- private NetInterfaceManager(Context context) {
- this.mContext = context;
- this.mCacheHelper = new CacheHelper(context);
- if (okHttpClient == null) {
-
- //如果无法生存缓存文件目录，检测权限使用已经加上，检测手机是否把文件读写权限禁止了
- OkHttpClient.Builder builder = new OkHttpClient.Builder();
- builder.connectTimeout(timeOut, TimeUnit.SECONDS); // 设置连接超时时间
- builder.writeTimeout(timeOut, TimeUnit.SECONDS);// 设置写入超时时间
- builder.readTimeout(timeOut, TimeUnit.SECONDS);// 设置读取数据超时时间
- builder.retryOnConnectionFailure(true);// 设置进行连接失败重试
- builder.addInterceptor(new RepeatRequestInterceptor());
-
- // 设置缓存文件路径
- String cacheDirectory = mContext.getExternalCacheDir().getAbsolutePath() + "/OkHttpCache";
- Cache cache = new Cache(new File(cacheDirectory), cacheSize);
- builder.cache(cache);// 设置缓存
- okHttpClient = builder.build();
- }
-
- if (mRetrofit == null) {
- mRetrofit = new Retrofit.Builder()
- .client(okHttpClient)
- .baseUrl(URLAddress.ROOT_URL)
- .addConverterFactory(GsonConverterFactory.create())
- .addCallAdapterFactory(RxJava3CallAdapterFactory.create())
- .build();
- }
- }
-
- /**
- * 打印全局统一拦截添加的Http Headers
- *
- * 全局拦截的http 没法在配置中直接打印处理，因为先http 请求然后打印然后拦截添加的
- *
- * @param request
- */
- private static void logRequestHeaders(Request request) {
- Log.e("OKhttp ", " 开始打印HTTP请求 Headers \n");
- Headers headers = request.headers();
- for (int i = 0, count = headers.size(); i < count; i++) {
- String name = headers.name(i);
- // Skip headers from the request body as they are explicitly logged above.
- if (!"Content-Type".equalsIgnoreCase(name) && !"Content-Length".equalsIgnoreCase(name)) {
- Log.e("OKhttp: " + i + " ", name + ": " + headers.value(i));
- }
- }
- Log.e("OKhttp ", " 打印HTTP请求完成 Headers \n");
- }
-
- public static void init(Context context) {
- if (INSTANCE == null) {
- INSTANCE = new NetInterfaceManager(context);
- }
- }
-
- public static NetInterfaceManager getInstance() {
- if (INSTANCE == null) {
- throw new IllegalStateException("You must be init NetworkManager first");
- }
- return INSTANCE;
- }
-
- public OkHttpClient getOkHttpClient() {
- return okHttpClient;
- }
-
- /**
- * 通过sn获取设备的信息
- *
- * @return
- */
- public Observable> getsnInfoControl() {
- return mRetrofit.create(SNInfoApi.class)
- .getsninfo(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable> getUserAvatarInfoControl() {
- return mRetrofit.create(UserInfoControl.class)
- .getUserAvatarInfo(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable>> getAlarmClockObservable() {
- return mRetrofit
- .create(AlarmClockApi.class)
- .getAlarmClock(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable getRunningAppObservable(String json) {
- return mRetrofit.create(RunNewApp.class)
- .sendRunningInfo(Utils.getSerial(), json)
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable> getsettingControl() {
- return mRetrofit.create(Setting.class)
- .getSetting(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable getSOSRecordObservable(String longitude, String latitude, String address) {
- return mRetrofit.create(SOSRecordApi.class)
- .sendSOSRecord(Utils.getSerial(), longitude, latitude, address)
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable getUpdateAlarmObservable(int id) {
- return mRetrofit.create(UpdateAlarmClockApi.class)
- .updateAlarm(Utils.getSerial(), id)
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable getUpdateDesktopObservable(String jsonArray) {
- return mRetrofit.create(UpdateDesktopApi.class)
- .updateLayout(Utils.getSerial(), jsonArray)
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable>> getDesktopLayoutObservable() {
- return mRetrofit.create(GetDesktopApi.class)
- .getDesktopLayout(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable>> getGoodsListObservable() {
- return mRetrofit.create(GoodsListApi.class)
- .getGoodsList(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable>> getArticleListObservable() {
- return mRetrofit.create(ArticleListApi.class)
- .getArticleList(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable>> getContactListObservable() {
- return mRetrofit.create(GetMailList.class)
- .getContact(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable getAdminSnSettingObservable() {
- return mRetrofit.create(GetAdminSnSettingApi.class)
- .getAdminSnSetting(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable getSnIsActivationObservable() {
- return mRetrofit.create(SnIsActivationApi.class)
- .getSnIsActivation(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public Observable getUpdateAppIconObservable(String pkg, String label, int type) {
- return mRetrofit.create(UpdateAppIconApi.class)
- .appIconUpdate(Utils.getSerial(), pkg, type, label)
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
-
- public interface onCompleteCallback {
- void onComplete();
- }
-
- public Observable> getUserIDObservable() {
- return mRetrofit.create(GetUserIDApi.class)
- .getUserID(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public void getUserID(BehaviorSubject lifecycle, onCompleteCallback callback) {
- getUserIDObservable()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, ActivityEvent.DESTROY))
- .subscribe(getUserIDObserver(callback));
- }
-
- public void getUserID(onCompleteCallback callback) {
- getUserIDObservable()
- .subscribe(getUserIDObserver(callback));
- }
-
- public void getUserID() {
- getUserIDObservable()
- .subscribe(getUserIDObserver(null));
- }
-
- public int getUserId() {
- int userId = mMMKV.decodeInt("USER_ID", -1);
- if (userId == -1) {
- getUserID();
- }
- return userId;
- }
-
- public Observer getUserIDObserver(onCompleteCallback callback) {
- return new Observer>() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getUserID", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse userIdBaseResponse) {
- Log.e("getUserID", "onNext: " + userIdBaseResponse);
- if (userIdBaseResponse.code == 200) {
- UserId userId = userIdBaseResponse.data;
- mCacheHelper.put(URLAddress.GET_USER_ID, GsonUtils.toJsonString(userId));
- mMMKV.encode("USER_ID", userId.getUser_id());
- } else {
- mCacheHelper.put(URLAddress.GET_USER_ID, -1);
- }
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getUserID", "onError: " + e.getMessage());
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getUserID", "onComplete: ");
- if (callback != null) {
- callback.onComplete();
- }
- }
- };
- }
-
-
- public Observable>> getActivityListObservable() {
- return mRetrofit.create(ActivityListApi.class)
- .getActivityList(Utils.getSerial(), 1, 1, getUserId())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public interface ActivitiesListCallback {
- void setActivitiesList(List activityBeans);
-
- void noData();
-
- void onError();
-
- void onComplete();
- }
-
- public void getActivityList(boolean refresh, BehaviorSubject lifecycle, ActivitiesListCallback callback) {
- ConnectMode connectMode = ConnectMode.ONE_MINUTE;
- if (refresh) {
- connectMode = ConnectMode.DEFAULT;
- }
- if (ConnectManager.getInstance().isNeedConnect(URLAddress.GET_ACTIVITY_LIST, connectMode)) {
- getActivityList(lifecycle, callback);
- } else {
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_ACTIVITY_LIST);
- //为 "" 是已经请求成功的
- if (jsonString == null) {
- getActivityList(lifecycle, callback);
- } else {
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List activityBeans = gson.fromJson(jsonString, type);
- if (activityBeans == null || activityBeans.size() == 0) {
- if (callback != null) callback.noData();
- } else {
- if (callback != null) callback.setActivitiesList(activityBeans);
- }
- if (callback != null) callback.onComplete();
- }
- }
- }
-
- public void getActivityList(BehaviorSubject lifecycle, ActivitiesListCallback callback) {
- getActivityListObservable()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, FragmentEvent.DESTROY))
- .subscribe(getActivityListObserver(callback));
- }
-
- public void getActivityList(ActivitiesListCallback callback) {
- getActivityListObservable()
- .subscribe(getActivityListObserver(callback));
- }
-
- public void getActivityList() {
- getActivityListObservable()
- .subscribe(getActivityListObserver(null));
- }
-
- public Observer>> getActivityListObserver(ActivitiesListCallback callback) {
- return new Observer>>() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getActivityListObserver", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse> listBaseResponse) {
- Log.e("getActivityListObserver", "onNext: ");
- if (listBaseResponse.code == 200) {
- List activityBeans = listBaseResponse.data;
- if (activityBeans == null || activityBeans.size() == 0) {
- mCacheHelper.put(URLAddress.GET_ACTIVITY_LIST, "");
- if (callback != null) callback.noData();
- } else {
- mCacheHelper.put(URLAddress.GET_ACTIVITY_LIST, GsonUtils.toJsonString(activityBeans));
- if (callback != null) callback.setActivitiesList(activityBeans);
- }
- } else {
- mCacheHelper.put(URLAddress.GET_ACTIVITY_LIST, "");
- if (callback != null) callback.noData();
- }
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getActivityListObserver", "onError: " + e.getMessage());
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_ACTIVITY_LIST);
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List activityBeans = gson.fromJson(jsonString, type);
- if (activityBeans == null || activityBeans.size() == 0) {
- if (callback != null) callback.noData();
- } else {
- if (callback != null) callback.setActivitiesList(activityBeans);
- }
- if (callback != null) callback.onError();
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getActivityListObserver", "onComplete: ");
- }
- };
- }
-
-
- public Observable>> getDemandListObservable() {
- return mRetrofit.create(DemandListApi.class)
- .getDemandList(Utils.getSerial(), 1, 1, getUserId())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public interface DemandListCallback {
- void setDemandList(List demandBeans);
-
- void noData();
-
- void onError();
-
- void onComplete();
- }
-
- public void getDemandList(boolean refresh, BehaviorSubject lifecycle, DemandListCallback callback) {
- ConnectMode connectMode = ConnectMode.ONE_MINUTE;
- if (refresh) {
- connectMode = ConnectMode.DEFAULT;
- }
- if (ConnectManager.getInstance().isNeedConnect(URLAddress.GET_DEMAND_LIST, connectMode)) {
- getDemandList(lifecycle, callback);
- } else {
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_DEMAND_LIST);
- //为 "" 是已经请求成功的
- if (jsonString == null) {
- getDemandList(lifecycle, callback);
- } else {
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List demandBeans = gson.fromJson(jsonString, type);
- if (demandBeans == null || demandBeans.size() == 0) {
- if (callback != null) callback.noData();
- } else {
- if (callback != null) callback.setDemandList(demandBeans);
- }
- if (callback != null) callback.onComplete();
- }
- }
- }
-
- public void getDemandList(BehaviorSubject lifecycle, DemandListCallback callback) {
- getDemandListObservable()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, FragmentEvent.DESTROY))
- .subscribe(getDemandListObserver(callback));
- }
-
- public void getDemandList(DemandListCallback callback) {
- getDemandListObservable()
- .subscribe(getDemandListObserver(callback));
- }
-
- public void getDemandList() {
- getDemandListObservable()
- .subscribe(getDemandListObserver(null));
- }
-
- public Observer>> getDemandListObserver(DemandListCallback callback) {
- return new Observer>>() {
-
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getDemandListObserver", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse> listBaseResponse) {
- Log.e("getDemandListObserver", "onNext: ");
- if (listBaseResponse.code == 200) {
- List demandBeans = listBaseResponse.data;
- if (demandBeans == null || demandBeans.size() == 0) {
- mCacheHelper.put(URLAddress.GET_DEMAND_LIST, "");
- if (callback != null) callback.noData();
- } else {
- mCacheHelper.put(URLAddress.GET_DEMAND_LIST, GsonUtils.toJsonString(demandBeans));
- if (callback != null) callback.setDemandList(demandBeans);
- }
- } else {
- mCacheHelper.put(URLAddress.GET_DEMAND_LIST, "");
- if (callback != null) callback.noData();
- }
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getDemandListObserver", "onError: " + e.getMessage());
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_DEMAND_LIST);
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List demandBeans = gson.fromJson(jsonString, type);
- if (demandBeans == null || demandBeans.size() == 0) {
- if (callback != null) callback.noData();
- } else {
- if (callback != null) callback.setDemandList(demandBeans);
- }
- if (callback != null) callback.onError();
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getDemandListObserver", "onComplete: ");
- if (callback != null) callback.onComplete();
- }
- };
- }
-
-
- public AppUsageRecordApi getAppUsageRecordControl() {
- return mRetrofit.create(AppUsageRecordApi.class);
- }
-
- public SendScreenshotApi getScreenshotApi() {
- return mRetrofit.create(SendScreenshotApi.class);
- }
-
- public Observable>> getHealthCodeObservable() {
- return mRetrofit.create(HealthCodeApi.class)
- .getArticleDetails(Utils.getSerial())
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public interface HealthCodeCallback {
- void setHealthCode(List healthCode);
-
- void noData();
-
- void onError();
- }
-
- public void getHealthCode(boolean refresh, BehaviorSubject lifecycle, HealthCodeCallback callback) {
- ConnectMode connectMode = ConnectMode.ONE_MINUTE;
- if (refresh) {
- connectMode = ConnectMode.DEFAULT;
- }
- if (ConnectManager.getInstance().isNeedConnect(URLAddress.GET_HEALTH_CODE, connectMode)) {
- getHealthCode(lifecycle, callback);
- } else {
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_HEALTH_CODE);
- //为 "" 是已经请求成功的
- if (jsonString == null) {
- getHealthCode(lifecycle, callback);
- } else {
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List healthCodeList = gson.fromJson(jsonString, type);
- if (healthCodeList == null || healthCodeList.size() == 0) {
- callback.noData();
- } else {
- callback.setHealthCode(healthCodeList);
- }
- }
- }
- }
-
- private void getHealthCodeCache(HealthCodeCallback callback) {
-
- }
-
-
- public void getHealthCode(BehaviorSubject lifecycle, HealthCodeCallback callback) {
- getHealthCodeObservable()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, ActivityEvent.DESTROY))
- .subscribe(getHealthCodeObserver(callback));
- }
-
- public void getHealthCode(HealthCodeCallback callback) {
- getHealthCodeObservable()
- .subscribe(getHealthCodeObserver(callback));
- }
-
- public void getHealthCode() {
- getHealthCodeObservable()
- .subscribe(getHealthCodeObserver(null));
- }
-
-
- public Observer>> getHealthCodeObserver(HealthCodeCallback callback) {
- return new Observer>>() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getHealthCode", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse> listBaseResponse) {
- Log.e("getHealthCode", "onNext: " + listBaseResponse);
- if (listBaseResponse.code == 200) {
- List healthCodeList = listBaseResponse.data;
- mCacheHelper.put(URLAddress.GET_HEALTH_CODE, GsonUtils.toJsonString(healthCodeList));
- callback.setHealthCode(healthCodeList);
- } else {
- mCacheHelper.put(URLAddress.GET_HEALTH_CODE, "");
- callback.noData();
- }
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getHealthCode", "onError: ");
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_HEALTH_CODE);
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List healthCodeList = gson.fromJson(jsonString, type);
- if (healthCodeList == null || healthCodeList.size() == 0) {
- callback.noData();
- } else {
- callback.setHealthCode(healthCodeList);
- }
- callback.onError();
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getHealthCode", "onComplete: ");
- }
- };
- }
-
-
- public interface AlarmClockCallback {
- void setAlarmClock(List alarmClockList);
-
- void setAlarmClockEmpty();
-
- void onError();
- }
-
- public void getAlarmClock(boolean refresh, BehaviorSubject lifecycle, AlarmClockCallback callback) {
-// ConnectMode connectMode = ConnectMode.DEFAULT;
-// if (refresh) {
-// connectMode = ConnectMode.DEFAULT;
-// }
-// if (ConnectManager.getInstance().isNeedConnect(URLAddress.GET_ALARM_CLOCK, connectMode)) {
- getAlarmClock(lifecycle, callback);
-// } else {
-// getAlarmClockCache(lifecycle, callback);
-// }
- }
-
- public void getAlarmClockCache(BehaviorSubject lifecycle, AlarmClockCallback callback) {
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_ALARM_CLOCK);
- //为 "" 是已经请求成功的
- if (jsonString == null) {
- getAlarmClock(lifecycle, callback);
- } else {
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List list = gson.fromJson(jsonString, type);
- if (list == null || list.size() == 0) {
- callback.setAlarmClockEmpty();
- } else {
- callback.setAlarmClock(list);
- }
- }
- }
-
- public void getAlarmClock(BehaviorSubject lifecycle, AlarmClockCallback callback) {
- getAlarmClockObservable()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, ActivityEvent.DESTROY))
- .subscribe(getAlarmClockObserver(callback));
- }
-
- public void getAlarmClockFragment(BehaviorSubject lifecycle, AlarmClockCallback callback) {
- getAlarmClockObservable()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, FragmentEvent.DESTROY))
- .subscribe(getAlarmClockObserver(callback));
- }
-
- public void getAlarmClock(AlarmClockCallback callback) {
- getAlarmClockObservable()
- .subscribe(getAlarmClockObserver(callback));
- }
-
- public void getAlarmClock() {
- getAlarmClockObservable()
- .subscribe(getAlarmClockObserver(null));
- }
-
- public Observer>> getAlarmClockObserver(AlarmClockCallback callback) {
- return new Observer>>() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getAlarmClockObserver", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse> listBaseResponse) {
- Log.e("getAlarmClockObserver", "onNext: ");
- if (listBaseResponse.code == 200) {
- List alarmClockData = listBaseResponse.data;
- if (alarmClockData != null && alarmClockData.size() != 0) {
- AlarmUtils.getInstance().setAlarmClockData(alarmClockData);
- if (callback != null) callback.setAlarmClock(alarmClockData);
- } else {
- AlarmUtils.getInstance().deleteAllAlarmClock();
- AlarmUtils.getInstance().setAlarmClockData(null);
- if (callback != null) callback.setAlarmClockEmpty();
- }
- mCacheHelper.put(URLAddress.GET_ALARM_CLOCK, GsonUtils.toJsonString(alarmClockData));
- } else {
- AlarmUtils.getInstance().deleteAllAlarmClock();
- AlarmUtils.getInstance().setAlarmClockData(null);
- mCacheHelper.put(URLAddress.GET_ALARM_CLOCK, "");
- if (callback != null) callback.setAlarmClockEmpty();
- }
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getAlarmClockObserver", "onError: " + e.getMessage());
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_ALARM_CLOCK);
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List list = gson.fromJson(jsonString, type);
- if (list == null || list.size() == 0) {
- if (callback != null) callback.setAlarmClockEmpty();
- } else {
- if (callback != null) callback.setAlarmClock(list);
- }
- if (callback != null) callback.onError();
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getAlarmClockObserver", "onComplete: ");
- }
- };
- }
-
- public interface SnInfoCallback {
- void setSnInfo(SnInfo snInfo);
- }
-
- public void getSnInfo(BehaviorSubject lifecycle, SnInfoCallback callback) {
- getsnInfoControl()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, FragmentEvent.DESTROY))
- .subscribe(new Observer>() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getSnInfo", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse snInfoBaseResponse) {
- Log.e("getSnInfo", "onNext: ");
- callback.setSnInfo(snInfoBaseResponse.data);
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getSnInfo", "onError: ");
- callback.setSnInfo(null);
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getSnInfo", "onComplete: ");
- }
- });
- }
-
- public interface ContactCallback {
- void setContact(List contactList);
-
- void setEmergencyContact(List emergencyContact);
-
- void setEmpty();
-
- void onComplete();
- }
-
- public void getSystemSettings(boolean refresh, BehaviorSubject lifecycle, ContactCallback callback) {
- ConnectMode connectMode = ConnectMode.ONE_MINUTE;
- if (refresh) {
- connectMode = ConnectMode.DEFAULT;
- }
- if (ConnectManager.getInstance().isNeedConnect(URLAddress.GET_SETTINGS, connectMode)) {
- getSystemSettings(lifecycle, callback);
- } else {
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_SETTINGS);
- //为 "" 是已经请求成功的
- if (jsonString == null) {
- getSystemSettings(lifecycle, callback);
- } else {
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List setting_sos = gson.fromJson(jsonString, type);
- if (setting_sos == null || setting_sos.size() == 0) {
- if (callback != null) callback.setEmpty();
- } else {
- if (callback != null) callback.setContact(setting_sos);
- }
- if (callback != null) callback.onComplete();
- }
- }
- }
-
- public void getSystemSettings(BehaviorSubject lifecycle, ContactCallback callback) {
- getsettingControl()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, ActivityEvent.DESTROY))
- .subscribe(getSystemSettingsObserver(callback));
- }
-
- public void getSystemSettings(ContactCallback callback) {
- getsettingControl()
- .subscribe(getSystemSettingsObserver(callback));
- }
-
- public void getSystemSettings() {
- getsettingControl()
- .subscribe(getSystemSettingsObserver(null));
- }
-
- public Observer> getSystemSettingsObserver(ContactCallback callback) {
- return new Observer>() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getSystemSettings", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse settingsBaseResponse) {
- Log.e("getSystemSettings", "onNext: " + settingsBaseResponse);
- if (settingsBaseResponse.code == 200) {
- SystemSettings systemSettings = settingsBaseResponse.data;
- mMMKV.encode("is_health", systemSettings.getIs_health());
- mMMKV.encode("is_shopping", systemSettings.getIs_shopping());
- mMMKV.encode("is_info", systemSettings.getIs_info());
- List setting_sos = systemSettings.getSetting_sos();
- if (setting_sos == null || setting_sos.size() == 0) {
- mCacheHelper.put(URLAddress.GET_SETTINGS, "");
- if (callback != null) callback.setEmpty();
- } else {
- List emergencyContact = setting_sos.stream().filter(contact -> contact.getIs_urgent() == 1).collect(Collectors.toList());
- mCacheHelper.put(URLAddress.GET_SETTINGS, GsonUtils.toJsonString(setting_sos));
- if (callback != null) {
- callback.setContact(setting_sos);
- callback.setEmergencyContact(emergencyContact);
- }
- }
- } else {
- mCacheHelper.put(URLAddress.GET_SETTINGS, "");
- if (callback != null) callback.setEmpty();
- }
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getSystemSettings", "onError: " + e.getMessage());
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_SETTINGS);
- //为 "" 是已经请求成功的
- if (jsonString == null) {
- if (callback != null) callback.setEmpty();
- } else {
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List setting_sos = gson.fromJson(jsonString, type);
- if (setting_sos == null || setting_sos.size() == 0) {
- if (callback != null) callback.setEmpty();
- } else {
- if (callback != null) callback.setContact(setting_sos);
- }
- }
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getSystemSettings", "onComplete: ");
- if (callback != null) callback.onComplete();
- }
- };
- }
-
-
- public void getContactList(boolean refresh, BehaviorSubject lifecycle, ContactCallback callback) {
- ConnectMode connectMode = ConnectMode.ONE_MINUTE;
- if (refresh) {
- connectMode = ConnectMode.DEFAULT;
- }
- if (ConnectManager.getInstance().isNeedConnect(URLAddress.GET_MAIL_LIST, connectMode)) {
- getContactList(lifecycle, callback);
- } else {
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_MAIL_LIST);
- //为 "" 是已经请求成功的
- if (jsonString == null) {
- getContactList(lifecycle, callback);
- } else {
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List setting_sos = gson.fromJson(jsonString, type);
- if (setting_sos == null || setting_sos.size() == 0) {
- if (callback != null) callback.setEmpty();
- } else {
- if (callback != null) callback.setContact(setting_sos);
- }
- if (callback != null) callback.onComplete();
- }
- }
- }
-
- public void getContactList(BehaviorSubject lifecycle, ContactCallback callback) {
- getContactListObservable()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, ActivityEvent.DESTROY))
- .subscribe(getContactListObserver(callback));
- }
-
- public void getContactList(ContactCallback callback) {
- getContactListObservable()
- .subscribe(getContactListObserver(callback));
- }
-
- public void getContactList() {
- getContactListObservable()
- .subscribe(getContactListObserver(null));
- }
-
- public Observer>> getContactListObserver(ContactCallback callback) {
- return new Observer>>() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getContactList", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse> listBaseResponse) {
- Log.e("getContactList", "onNext: " + listBaseResponse);
- if (listBaseResponse.code == 200) {
- List contactList = listBaseResponse.data;
- if (contactList == null || contactList.size() == 0) {
- mCacheHelper.put(URLAddress.GET_MAIL_LIST, "");
- if (callback != null) callback.setEmpty();
- } else {
- mCacheHelper.put(URLAddress.GET_MAIL_LIST, GsonUtils.toJsonString(contactList));
- List emergencyContact = contactList.stream().filter(contact -> contact.getIs_urgent() == 1).collect(Collectors.toList());
- if (callback != null) {
- callback.setContact(contactList);
- callback.setEmergencyContact(emergencyContact);
- }
- }
- } else {
- mCacheHelper.put(URLAddress.GET_MAIL_LIST, "");
- if (callback != null) callback.setEmpty();
- }
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getContactList", "onError: " + e.getMessage());
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getContactList", "onComplete: ");
- if (callback != null) callback.onComplete();
- }
-
- };
- }
-
- public void getAdminSnSetting(boolean refresh, BehaviorSubject lifecycle, onCompleteCallback callback) {
- ConnectMode connectMode = ConnectMode.ONE_MINUTE;
- if (refresh) {
- connectMode = ConnectMode.DEFAULT;
- }
- if (ConnectManager.getInstance().isNeedConnect(URLAddress.GET_ADMIN_SN_SETTING, connectMode)) {
- getAdminSnSetting(lifecycle, callback);
- } else {
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_ADMIN_SN_SETTING);
- //为 "" 是已经请求成功的
- if (jsonString == null) {
- getAdminSnSetting(lifecycle, callback);
- } else {
- Gson gson = new Gson();
- Type type = new TypeToken>() {
- }.getType();
- List setting_sos = gson.fromJson(jsonString, type);
-
- }
- }
- }
-
- public void getAdminSnSetting(BehaviorSubject lifecycle, onCompleteCallback callback) {
- getAdminSnSettingObservable()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, ActivityEvent.DESTROY))
- .subscribe(getAdminSnSettingObserver(callback));
- }
-
- public void getAdminSnSetting(onCompleteCallback callback) {
- getAdminSnSettingObservable()
- .subscribe(getAdminSnSettingObserver(callback));
- }
-
-
- public void getAdminSnSetting() {
- getAdminSnSettingObservable()
- .subscribe(getAdminSnSettingObserver(null));
- }
-
- public Observer getAdminSnSettingObserver(onCompleteCallback callback) {
- return new Observer() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getAdminSnSettingObserver", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse baseResponse) {
- Log.e("getAdminSnSettingObserver", "onNext: " + baseResponse);
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getAdminSnSettingObserver", "onError: ");
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getAdminSnSettingObserver", "onComplete: ");
- }
- };
- }
-
- public void getUserAvatarInfo(boolean refresh, BehaviorSubject lifecycle, onCompleteCallback callback) {
- ConnectMode connectMode = ConnectMode.ONE_MINUTE;
- if (refresh) {
- connectMode = ConnectMode.DEFAULT;
- }
- if (ConnectManager.getInstance().isNeedConnect(URLAddress.GET_ADMIN_SN_SETTING, connectMode)) {
- getUserAvatarInfo(lifecycle, callback);
- } else {
- String jsonString = mCacheHelper.getAsString(URLAddress.GET_ADMIN_SN_SETTING);
- //为 "" 是已经请求成功的
- if (jsonString == null) {
- getUserAvatarInfo(lifecycle, callback);
- } else {
- Gson gson = new Gson();
- Type type = new TypeToken() {
- }.getType();
- UserAvatarInfo userAvatarInfo = gson.fromJson(jsonString, type);
- if (callback != null) {
- callback.onComplete();
- }
- }
- }
- }
-
- public void getUserAvatarInfo(BehaviorSubject lifecycle, onCompleteCallback callback) {
- NetInterfaceManager.getInstance()
- .getUserAvatarInfoControl()
- .compose(RxLifecycle.bindUntilEvent(lifecycle, FragmentEvent.DESTROY))
- .subscribe(getUserAvatarInfoObserver(callback));
- }
-
- public void getUserAvatarInfo(onCompleteCallback callback) {
- NetInterfaceManager.getInstance()
- .getUserAvatarInfoControl()
- .subscribe(getUserAvatarInfoObserver(callback));
- }
-
- public void getUserAvatarInfo() {
- NetInterfaceManager.getInstance()
- .getUserAvatarInfoControl()
- .subscribe(getUserAvatarInfoObserver(null));
- }
-
- public Observer> getUserAvatarInfoObserver(onCompleteCallback callback) {
- return new Observer>() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("getUserAvatarInfoControl", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse userAvatarInfoBaseResponse) {
- Log.e("getUserAvatarInfoControl", "onNext: " + userAvatarInfoBaseResponse);
-
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("getUserAvatarInfoControl", "onError: " + e.getMessage());
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("getUserAvatarInfoControl", "onComplete: ");
- if (callback != null) {
- callback.onComplete();
- }
- }
- };
- }
-}
diff --git a/app/src/main/java/com/uiui/aios/network/URLAddress.java b/app/src/main/java/com/uiui/aios/network/URLAddress.java
deleted file mode 100644
index d5d655c..0000000
--- a/app/src/main/java/com/uiui/aios/network/URLAddress.java
+++ /dev/null
@@ -1,53 +0,0 @@
-package com.uiui.aios.network;
-
-public class URLAddress {
- public static final String ROOT_URL = "https://led.zuoyepad.com/android/";
-
- /*获取设备是否激活*/
- public static final String GET_SN_IS_ACTIVATION = "sn/getSnIsActivation";
- /*设备信息接口*/
- public static final String SNINFO = "sn/getSnInfo";
- /*获取用户头像和信息*/
- public static final String GET_USER_AVATAR_INFO = "sn/getUserAvatarInfo";
- /*获取闹钟*/
- public static final String GET_ALARM_CLOCK = "getAlarmClock";
- /*应用使用记录*/
- public static final String APP_USAGE_RECORD = "appUsageRecord";
- /*正在运行的应用*/
- public static final String RUN_NEW_APP = "app/runNewApp";
- /*上传截图*/
- public static final String SEND_SCREENSHOT = "sn/uploadScreenshot";
- /*获取系统设置*/
- public final static String GET_SETTINGS = "control/getSetting";
- /*sos记录*/
- public static final String SOS_RECORD = "sosRecord";
- /*爱心提醒通知成功*/
- public static final String UPDATE_ALARM_CLOCK = "updateAlarmClock";
- /*更新桌面布局*/
- public static final String UPDATE_DESKTOP_LAYOUT = "updateDesktopLayout";
- /*获取桌面布局*/
- public static final String GET_DESKTOP_LAYOUT = "getDesktopLayout";
- /*获取抢购列表*/
- public static final String GET_GOODS_LIST = "getGoodsList";
- /*获取资讯列表*/
- public static final String GET_ARTICLE_LIST = "getArticleList";
- /*获取抢购详情*/
- public static final String GET_GOODS_DETAILS = "getGoodsDetails";
- /*获取资讯详情*/
- public static final String GET_ARTICLE_DETAILS = "getArticleDetails";
- /*同城活动列表*/
- public static final String GET_ACTIVITY_LIST = "activityList";
- /*同城需求列表*/
- public static final String GET_DEMAND_LIST = "demandList";
- /*获取健康吗*/
- public static final String GET_HEALTH_CODE = "getHealthCode";
- /*获取联系人*/
- public static final String GET_MAIL_LIST = "Control/getMailList";
- /*获取负二屏开关*/
- public static final String GET_ADMIN_SN_SETTING = "getAdminSnSetting";
- /*更新app隐藏或者显示状态*/
- public static final String APP_ICON_UPDATE = "Control/appIconUpdate";
-
-
- public static final String GET_USER_ID = "getUserId";
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/ActivityListApi.java b/app/src/main/java/com/uiui/aios/network/api/ActivityListApi.java
deleted file mode 100644
index 29ac4df..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/ActivityListApi.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.ActivityBean;
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import java.util.List;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface ActivityListApi {
- @GET(URLAddress.GET_ACTIVITY_LIST)
- Observable>> getActivityList(
- @Query("sn") String sn,
- @Query("startSize") int startSize,
- @Query("pageSize") int pageSize,
- @Query("user_id") int user_id
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/AlarmClockApi.java b/app/src/main/java/com/uiui/aios/network/api/AlarmClockApi.java
deleted file mode 100644
index 71543fc..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/AlarmClockApi.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.AlarmClockData;
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import java.util.List;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface AlarmClockApi {
- @GET(URLAddress.GET_ALARM_CLOCK)
- Observable>> getAlarmClock(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/AppUsageRecordApi.java b/app/src/main/java/com/uiui/aios/network/api/AppUsageRecordApi.java
deleted file mode 100644
index ed1e2a3..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/AppUsageRecordApi.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.Field;
-import retrofit2.http.FormUrlEncoded;
-import retrofit2.http.POST;
-
-public interface AppUsageRecordApi {
- @FormUrlEncoded
- @POST(URLAddress.APP_USAGE_RECORD)
- Observable sendappUsageRecord(
- @Field("sn") String sn,
- @Field("app_name") String app_name,
- @Field("app_package") String app_package,
- @Field("open_time") long open_time,
- @Field("close_time") long close_time
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/ArticleDetailsApi.java b/app/src/main/java/com/uiui/aios/network/api/ArticleDetailsApi.java
deleted file mode 100644
index 71b2145..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/ArticleDetailsApi.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.ArticleDetails;
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface ArticleDetailsApi {
- @GET(URLAddress.GET_ARTICLE_DETAILS)
- Observable> getArticleDetails(
- @Query("id") int id
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/ArticleListApi.java b/app/src/main/java/com/uiui/aios/network/api/ArticleListApi.java
deleted file mode 100644
index 532e68b..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/ArticleListApi.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.ArticleInfo;
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import java.util.List;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface ArticleListApi {
- @GET(URLAddress.GET_ARTICLE_LIST)
- Observable>> getArticleList(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/DemandListApi.java b/app/src/main/java/com/uiui/aios/network/api/DemandListApi.java
deleted file mode 100644
index c65674f..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/DemandListApi.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.DemandBean;
-import com.uiui.aios.network.URLAddress;
-
-import java.util.List;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface DemandListApi {
- @GET(URLAddress.GET_DEMAND_LIST)
- Observable>> getDemandList(
- @Query("sn") String sn,
- @Query("startSize") int startSize,
- @Query("pageSize") int pageSize,
- @Query("user_id") int user_id
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/GetAdminSnSettingApi.java b/app/src/main/java/com/uiui/aios/network/api/GetAdminSnSettingApi.java
deleted file mode 100644
index 604fccc..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/GetAdminSnSettingApi.java
+++ /dev/null
@@ -1,15 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface GetAdminSnSettingApi {
- @GET(URLAddress.GET_ADMIN_SN_SETTING)
- Observable getAdminSnSetting(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/GetDesktopApi.java b/app/src/main/java/com/uiui/aios/network/api/GetDesktopApi.java
deleted file mode 100644
index 0b4b6b6..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/GetDesktopApi.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.NetDesktopIcon;
-import com.uiui.aios.network.URLAddress;
-
-import java.util.List;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface GetDesktopApi {
- @GET(URLAddress.GET_DESKTOP_LAYOUT)
- Observable>> getDesktopLayout(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/GetMailList.java b/app/src/main/java/com/uiui/aios/network/api/GetMailList.java
deleted file mode 100644
index d24d4a6..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/GetMailList.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.Contact;
-import com.uiui.aios.network.URLAddress;
-
-import java.util.List;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface GetMailList {
- @GET(URLAddress.GET_MAIL_LIST)
- Observable>> getContact(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/GetUserIDApi.java b/app/src/main/java/com/uiui/aios/network/api/GetUserIDApi.java
deleted file mode 100644
index cf8340c..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/GetUserIDApi.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.UserId;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface GetUserIDApi {
- @GET(URLAddress.GET_USER_ID)
- Observable> getUserID(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/GoodsDetailsApi.java b/app/src/main/java/com/uiui/aios/network/api/GoodsDetailsApi.java
deleted file mode 100644
index 3a0db76..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/GoodsDetailsApi.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.GoodsDetails;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface GoodsDetailsApi {
- @GET(URLAddress.GET_GOODS_DETAILS)
- Observable> getGoodsDetails(
- @Query("id") int id
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/GoodsListApi.java b/app/src/main/java/com/uiui/aios/network/api/GoodsListApi.java
deleted file mode 100644
index fe7a5d7..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/GoodsListApi.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.GoodsInfo;
-import com.uiui.aios.network.URLAddress;
-
-import java.util.List;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface GoodsListApi {
- @GET(URLAddress.GET_GOODS_LIST)
- Observable>> getGoodsList(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/HealthCodeApi.java b/app/src/main/java/com/uiui/aios/network/api/HealthCodeApi.java
deleted file mode 100644
index db5b1e3..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/HealthCodeApi.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.HealthCode;
-import com.uiui.aios.network.URLAddress;
-
-import java.util.List;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface HealthCodeApi {
- @GET(URLAddress.GET_HEALTH_CODE)
- Observable>> getArticleDetails(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/RunNewApp.java b/app/src/main/java/com/uiui/aios/network/api/RunNewApp.java
deleted file mode 100644
index 1bd4534..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/RunNewApp.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.Field;
-import retrofit2.http.FormUrlEncoded;
-import retrofit2.http.POST;
-
-public interface RunNewApp {
- @FormUrlEncoded
- @POST(URLAddress.RUN_NEW_APP)
- Observable sendRunningInfo(
- @Field("sn") String sn,
- @Field("app") String app
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/SNInfoApi.java b/app/src/main/java/com/uiui/aios/network/api/SNInfoApi.java
deleted file mode 100644
index 60cf13e..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/SNInfoApi.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.SnInfo;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface SNInfoApi {
- @GET(URLAddress.SNINFO)
- Observable> getsninfo(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/SOSRecordApi.java b/app/src/main/java/com/uiui/aios/network/api/SOSRecordApi.java
deleted file mode 100644
index c82454d..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/SOSRecordApi.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.Field;
-import retrofit2.http.FormUrlEncoded;
-import retrofit2.http.POST;
-
-public interface SOSRecordApi {
- @FormUrlEncoded
- @POST(URLAddress.SOS_RECORD)
- Observable sendSOSRecord(
- @Field("sn") String sn,
- @Field("longitude") String longitude,
- @Field("latitude") String latitude,
- @Field("address") String address
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/SendScreenshotApi.java b/app/src/main/java/com/uiui/aios/network/api/SendScreenshotApi.java
deleted file mode 100644
index 774d008..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/SendScreenshotApi.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package com.uiui.aios.network.api;
-
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import okhttp3.MultipartBody;
-import retrofit2.http.Multipart;
-import retrofit2.http.POST;
-import retrofit2.http.Part;
-import retrofit2.http.Query;
-
-public interface SendScreenshotApi {
- @Multipart
- @POST(URLAddress.SEND_SCREENSHOT)
- Observable sendScreenshot(
- @Query("sn") String sn,
- @Part MultipartBody.Part file
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/Setting.java b/app/src/main/java/com/uiui/aios/network/api/Setting.java
deleted file mode 100644
index 41e4cde..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/Setting.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.SystemSettings;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface Setting {
- @GET(URLAddress.GET_SETTINGS)
- Observable> getSetting(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/SnIsActivationApi.java b/app/src/main/java/com/uiui/aios/network/api/SnIsActivationApi.java
deleted file mode 100644
index 3790547..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/SnIsActivationApi.java
+++ /dev/null
@@ -1,15 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.GET;
-import retrofit2.http.Query;
-
-public interface SnIsActivationApi {
- @GET(URLAddress.GET_SN_IS_ACTIVATION)
- Observable getSnIsActivation(
- @Query("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/UpdateAlarmClockApi.java b/app/src/main/java/com/uiui/aios/network/api/UpdateAlarmClockApi.java
deleted file mode 100644
index 3ffe26c..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/UpdateAlarmClockApi.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.Field;
-import retrofit2.http.FormUrlEncoded;
-import retrofit2.http.POST;
-
-public interface UpdateAlarmClockApi {
- @FormUrlEncoded
- @POST(URLAddress.UPDATE_ALARM_CLOCK)
- Observable updateAlarm(
- @Field("sn") String sn,
- @Field("id") int id
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/UpdateAppIconApi.java b/app/src/main/java/com/uiui/aios/network/api/UpdateAppIconApi.java
deleted file mode 100644
index 53ed84d..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/UpdateAppIconApi.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.Field;
-import retrofit2.http.FormUrlEncoded;
-import retrofit2.http.POST;
-
-public interface UpdateAppIconApi {
- @FormUrlEncoded
- @POST(URLAddress.APP_ICON_UPDATE)
- Observable appIconUpdate(
- @Field("sn") String sn,
- @Field("app_package") String app_package,
- @Field("type") int type,//类型 1显示 0隐藏
- @Field("app_name") String app_name
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/UpdateDesktopApi.java b/app/src/main/java/com/uiui/aios/network/api/UpdateDesktopApi.java
deleted file mode 100644
index 034e387..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/UpdateDesktopApi.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.uiui.aios.network.api;
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.Field;
-import retrofit2.http.FormUrlEncoded;
-import retrofit2.http.POST;
-
-public interface UpdateDesktopApi {
- @FormUrlEncoded
- @POST(URLAddress.UPDATE_DESKTOP_LAYOUT)
- Observable updateLayout(
- @Field("sn") String sn,
- @Field("app") String app
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/network/api/UserInfoControl.java b/app/src/main/java/com/uiui/aios/network/api/UserInfoControl.java
deleted file mode 100644
index 316594e..0000000
--- a/app/src/main/java/com/uiui/aios/network/api/UserInfoControl.java
+++ /dev/null
@@ -1,19 +0,0 @@
-package com.uiui.aios.network.api;
-
-
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.bean.UserAvatarInfo;
-import com.uiui.aios.network.URLAddress;
-
-import io.reactivex.rxjava3.core.Observable;
-import retrofit2.http.Field;
-import retrofit2.http.FormUrlEncoded;
-import retrofit2.http.POST;
-
-public interface UserInfoControl {
- @FormUrlEncoded
- @POST(URLAddress.GET_USER_AVATAR_INFO)
- Observable> getUserAvatarInfo(
- @Field("sn") String sn
- );
-}
diff --git a/app/src/main/java/com/uiui/aios/service/main/MainSContact.java b/app/src/main/java/com/uiui/aios/service/main/MainSContact.java
deleted file mode 100644
index 9632b5a..0000000
--- a/app/src/main/java/com/uiui/aios/service/main/MainSContact.java
+++ /dev/null
@@ -1,19 +0,0 @@
-package com.uiui.aios.service.main;
-
-import com.uiui.aios.base.BasePresenter;
-import com.uiui.aios.base.BaseView;
-import com.uiui.aios.bean.AlarmClockData;
-
-import java.util.List;
-
-public class MainSContact {
- public interface Presenter extends BasePresenter {
- //设置所有信息
- void getAlarmClock();
- }
-
- public interface MainSView extends BaseView {
- //获取所有信息
- void setAlarmClock(List dataList);
- }
-}
diff --git a/app/src/main/java/com/uiui/aios/service/main/MainService.java b/app/src/main/java/com/uiui/aios/service/main/MainService.java
deleted file mode 100644
index ce72fcc..0000000
--- a/app/src/main/java/com/uiui/aios/service/main/MainService.java
+++ /dev/null
@@ -1,433 +0,0 @@
-package com.uiui.aios.service.main;
-
-import android.annotation.SuppressLint;
-import android.content.BroadcastReceiver;
-import android.content.Context;
-import android.content.Intent;
-import android.content.IntentFilter;
-import android.os.IBinder;
-import android.os.PowerManager;
-import android.text.TextUtils;
-import android.text.format.Formatter;
-import android.util.Log;
-
-import com.arialyy.annotations.Download;
-import com.arialyy.aria.core.Aria;
-import com.arialyy.aria.core.task.DownloadTask;
-import com.blankj.utilcode.util.NetworkUtils;
-import com.uiui.aios.BuildConfig;
-import com.uiui.aios.activity.NoticeActivity;
-import com.uiui.aios.alarm.AlarmUtils;
-import com.uiui.aios.base.BaseService;
-import com.uiui.aios.bean.AlarmClockData;
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.NetInterfaceManager;
-import com.uiui.aios.utils.ApkUtils;
-import com.uiui.aios.utils.CmdUtil;
-import com.uiui.aios.utils.ForegroundAppUtil;
-import com.uiui.aios.utils.AppUsedTimeUtils;
-import com.uiui.aios.utils.ToastUtil;
-import com.uiui.aios.utils.Utils;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.util.Calendar;
-import java.util.HashMap;
-import java.util.List;
-
-import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
-import io.reactivex.rxjava3.core.Observable;
-import io.reactivex.rxjava3.core.ObservableEmitter;
-import io.reactivex.rxjava3.core.ObservableOnSubscribe;
-import io.reactivex.rxjava3.core.ObservableSource;
-import io.reactivex.rxjava3.core.Observer;
-import io.reactivex.rxjava3.disposables.Disposable;
-import io.reactivex.rxjava3.functions.Function;
-import io.reactivex.rxjava3.schedulers.Schedulers;
-import okhttp3.MediaType;
-import okhttp3.MultipartBody;
-import okhttp3.RequestBody;
-
-public class MainService extends BaseService implements MainSContact.MainSView, NetworkUtils.OnNetworkStatusChangedListener {
- private static final String TAG = MainService.class.getSimpleName();
- public MainSPresenter mPresenter;
-
- public MainService() {
-
- }
-
- @Override
- public void onDisconnected() {
-
- }
-
- @Override
- public void onConnected(NetworkUtils.NetworkType networkType) {
- if (isScreenOn()) {
- mPresenter.getAlarmClock();
- }
- }
-
- @Override
- public IBinder onBind(Intent intent) {
- Log.e(TAG, "onBind: ");
- return null;
- }
-
- @Override
- public void onCreate() {
- super.onCreate();
- Log.e(TAG, "onCreate: ");
-// ApkUtils.UninstallAPP(this, "com.joytv.live");
-// ApkUtils.UninstallAPP(this, "com.tencent.android.qqdownloader");
-
- Aria.init(this);
- Aria.download(this).register();
- mPresenter = new MainSPresenter(this);
- mPresenter.attachView(this);
- mPresenter.setLifecycle(lifecycleSubject);
- NetworkUtils.registerNetworkStatusChangedListener(this);
- mPresenter.getAlarmClock();
- registerAlarmReceiver();
- registerTimeReceiver();
- registerLockScreenReceiver();
- }
-
- @Override
- public int onStartCommand(Intent intent, int flags, int startId) {
- Log.e(TAG, "onStartCommand: ");
- return START_STICKY;
- }
-
- @Override
- public void onDestroy() {
- super.onDestroy();
- mPresenter.detachView();
- NetworkUtils.unregisterNetworkStatusChangedListener(this);
- if (alarmReceiver != null) {
- unregisterReceiver(alarmReceiver);
- }
- if (mTimeChangedReceiver != null) {
- unregisterReceiver(mTimeChangedReceiver);
- }
- }
-
- @Override
- public void setAlarmClock(List dataList) {
-
- }
-
- public boolean isScreenOn() {
- PowerManager powerManager = (PowerManager) getSystemService(Context.POWER_SERVICE);
- //true为打开，false为关闭
- return powerManager.isInteractive();
- }
-
- public static final String ALARMWAKEUP = "ALARM_WAKEUP";
-
- private void registerAlarmReceiver() {
- if (alarmReceiver == null) {
- alarmReceiver = new AlarmReceiver();
- }
- IntentFilter filter = new IntentFilter();
- filter.setPriority(IntentFilter.SYSTEM_HIGH_PRIORITY);
- filter.addAction(ALARMWAKEUP);
- registerReceiver(alarmReceiver, filter);
- }
-
- private AlarmReceiver alarmReceiver = new AlarmReceiver();
-
- private class AlarmReceiver extends BroadcastReceiver {
- @Override
- public void onReceive(Context context, Intent intent) {
- Log.e(TAG, "onReceive: " + System.currentTimeMillis());
- String action = intent.getAction();
- if (TextUtils.isEmpty(action)) return;
- Log.e(TAG, "onReceive: " + action);
- String title = intent.getStringExtra("title");
- int code = intent.getIntExtra("id", -1);
- Log.e(TAG, "onReceive: title = " + title);
- setNextAlarm(code);
- if (ALARMWAKEUP.equals(action)) {
- Intent noticeIntent = new Intent();
- noticeIntent.putExtra("id", code);
- noticeIntent.setClass(MainService.this, NoticeActivity.class);
- noticeIntent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
- startActivity(noticeIntent);
- }
- }
- }
-
- public void setNextAlarm(int code) {
- HashMap clockDataHashMap = AlarmUtils.getInstance().getOldData();
- AlarmClockData alarmClockData = clockDataHashMap.get(code);
- Log.e(TAG, "setNextAlarm: " + alarmClockData);
- if (alarmClockData != null) {
- Calendar calendar = Calendar.getInstance();
- int day_of_week = calendar.get(Calendar.DAY_OF_WEEK) - 1;
- Log.e(TAG, "setNextAlarm: " + day_of_week);
- switch (alarmClockData.getType()) {
- case AlarmUtils.ONCE:
- break;
- case AlarmUtils.LOOP:
- AlarmUtils.getInstance().setDayLoopAlarm(MainService.ALARMWAKEUP, alarmClockData.getTitle(), alarmClockData.getId(), alarmClockData.getTime());
- break;
- case AlarmUtils.WORKING_DAY:
- if (day_of_week < 5 || day_of_week == 7) {
- AlarmUtils.getInstance().setWorkDayAlarm(MainService.ALARMWAKEUP, alarmClockData.getTitle(), alarmClockData.getId(), alarmClockData.getTime());
- }
- break;
- case AlarmUtils.OFF_DAY:
- AlarmUtils.getInstance().setOffDayAlarm(MainService.ALARMWAKEUP, alarmClockData.getTitle(), alarmClockData.getId(), alarmClockData.getTime());
- default:
- }
- }
- }
-
- //监听时间和日期变化
- public void registerTimeReceiver() {
- mTimeChangedReceiver = new TimeChangedReceiver();
- IntentFilter filter = new IntentFilter();
- filter.setPriority(IntentFilter.SYSTEM_HIGH_PRIORITY);
- filter.addAction(Intent.ACTION_DATE_CHANGED);
- filter.addAction(Intent.ACTION_TIME_CHANGED);
- filter.addAction(Intent.ACTION_TIMEZONE_CHANGED);
- filter.addAction(Intent.ACTION_TIME_TICK);
- registerReceiver(mTimeChangedReceiver, filter);
- }
-
- private TimeChangedReceiver mTimeChangedReceiver;
-
- private class TimeChangedReceiver extends BroadcastReceiver {
-
- @Override
- public void onReceive(Context context, Intent intent) {
- if (Intent.ACTION_DATE_CHANGED.equals(intent.getAction())) {
- Log.e(TAG, "TimeChangedReceiver:" + "data changed");
- } else if (Intent.ACTION_TIME_CHANGED.equals(intent.getAction())) {
- Log.e(TAG, "TimeChangedReceiver:" + "time changed");
- } else if (Intent.ACTION_TIMEZONE_CHANGED.equals(intent.getAction())) {
- Log.e(TAG, "TimeChangedReceiver:" + "timezone changed");
- } else if (Intent.ACTION_TIME_TICK.equals(intent.getAction())) {
- Log.e(TAG, "TimeChangedReceiver:" + "time tick");
-// isScreenshot();
- }
- }
- }
-
- private final static long ONE_HOURS_TIME = 60 * 60 * 1000;
- private final static long TEN_MINUTES_TIME = 60 * 10 * 1000;
-
- private void isScreenshot() {
- //1、检测应用使用情况，如果设备长时间运行一个应用，超过1小时，启动截屏一次。
- //2、检测设备在非正常时间使用时，使用第三方应用，在运行10分钟后，启动截屏功能一次
- //屏幕未点亮时不用截图
- // TODO: 2021/12/20 计算当前app打开时间
- String topPackageName = ForegroundAppUtil.getForegroundPackageName(MainService.this);
- Log.e(TAG, "isScreenshot: " + topPackageName);
- String pkg = AppUsedTimeUtils.getInstance().getAppPackageName();
- if (TextUtils.isEmpty(pkg) || BuildConfig.APPLICATION_ID.equals(pkg)) {
- return;
- }
-
- PowerManager powerManager = (PowerManager) getSystemService(Context.POWER_SERVICE);
- //true为打开，false为关闭
- boolean screenOn = powerManager.isInteractive();
- Log.e(TAG, "isScreenshot: screenOn = " + screenOn);
- if (!screenOn) return;
-
- long startTime = AppUsedTimeUtils.getInstance().getStartTime();
- if (AppUsedTimeUtils.getInstance().isNormalTime()) {//正常时间段
- if (System.currentTimeMillis() - startTime >= ONE_HOURS_TIME) {
- Log.e(TAG, "isScreenshot: " + "截图");
- doscreenshot(this);
- }
- } else {//非正常时间段
- if (System.currentTimeMillis() - startTime >= TEN_MINUTES_TIME) {
- Log.e(TAG, "isScreenshot: " + "截图");
- doscreenshot(this);
- }
- }
- }
-
- private static Observable getScreenshot(Context context, String filePath) {
- Observable screenshotObservable = Observable.create(new ObservableOnSubscribe() {
- @Override
- public void subscribe(ObservableEmitter e) {
- int code = CmdUtil.execute("screencap -p " + filePath).code;
- e.onNext(code);
- e.onComplete();
- }
- }).subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- return screenshotObservable;
- }
-
- private static Observable getSendFile(String path, MultipartBody.Part body) {
- return NetInterfaceManager.getInstance()
- .getScreenshotApi()
- .sendScreenshot(Utils.getSerial(), body)
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread());
- }
-
- public static void doscreenshot(Context context) {
- long time = System.currentTimeMillis();
- String path = context.getExternalFilesDir("db").getAbsolutePath();
- String filePath = path + File.separator + time + ".png";
- getScreenshot(context, filePath).concatMap(new Function>() {
- @Override
- public ObservableSource apply(Integer integer) throws Exception {
- if (integer != 0) {
- throw new FileNotFoundException();
- }
- File file = new File(filePath);
- if (!file.exists()) {
- throw new FileNotFoundException(filePath);
- }
-// Bitmap bitmap = BitmapFactory.decodeFile(filePath);
-// if (bitmap.getWidth() < bitmap.getHeight()) {
-// bitmap = ImageUtils.rotate(bitmap, -90, bitmap.getWidth(), bitmap.getHeight());
-// }
-// ByteArrayOutputStream baos = new ByteArrayOutputStream();
-// bitmap.compress(Bitmap.CompressFormat.JPEG, 100, baos);
-// file.createNewFile();
-// FileOutputStream fos = new FileOutputStream(file);
-// InputStream is = new ByteArrayInputStream(baos.toByteArray());
-// int x;
-// byte[] b = new byte[1024 * 100];
-// while ((x = is.read(b)) != -1) {
-// fos.write(b, 0, x);
-// }
-// fos.close();
- RequestBody requestFile = RequestBody.create(MediaType.parse("multipart/form-data"), file);
- MultipartBody.Part body = MultipartBody.Part.createFormData("file", file.getName(), requestFile);
- return getSendFile(filePath, body);
- }
- }).subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread())
- .subscribe(new Observer() {
- @Override
- public void onSubscribe(Disposable d) {
- Log.e("screenshot", "onSubscribe: ");
- }
-
- @Override
- public void onNext(BaseResponse baseResponse) {
- Log.e("screenshot", "onNext: " + baseResponse);
- }
-
- @Override
- public void onError(Throwable e) {
- Log.e("screenshot", "onError: " + e.getMessage());
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("screenshot", "onComplete: ");
- }
- });
- }
-
-
- private LockScreenReceiver lockScreenReceiver;
-
- private void registerLockScreenReceiver() {
- if (lockScreenReceiver == null) {
- lockScreenReceiver = new LockScreenReceiver();
- }
- IntentFilter filter = new IntentFilter();
- filter.setPriority(IntentFilter.SYSTEM_HIGH_PRIORITY);
- filter.addAction(Intent.ACTION_USER_PRESENT);
- filter.addAction(Intent.ACTION_SCREEN_ON);
- filter.addAction(Intent.ACTION_SCREEN_OFF);
- registerReceiver(lockScreenReceiver, filter);
- }
-
- static class LockScreenReceiver extends BroadcastReceiver {
- @Override
- public void onReceive(Context context, Intent intent) {
- String action = intent.getAction();
- if (TextUtils.isEmpty(action)) return;
- Log.e(TAG, "onReceive: " + action);
- switch (action) {
- default:
- break;
- case Intent.ACTION_USER_PRESENT:
- resetStartTime(context);
- break;
- case Intent.ACTION_SCREEN_ON:
-
- break;
- case Intent.ACTION_SCREEN_OFF:
- //关闭屏幕上传数据
- sendAppUsed(context);
- break;
- }
- }
- }
-
- private static void resetStartTime(Context context) {
- String topPackageName = ForegroundAppUtil.getForegroundPackageName(context);
- Log.e(TAG, "resetStartTime: " + topPackageName);
- AppUsedTimeUtils.getInstance().setAppPackageName(topPackageName);
- AppUsedTimeUtils.getInstance().setStartTime(System.currentTimeMillis());
- }
-
- private static void sendAppUsed(Context context) {
- String packagename = AppUsedTimeUtils.getInstance().getAppPackageName();
- Log.e(TAG, "onResume packagename == " + packagename);
-// AppUsedTimeUtils.getInstance().setEndTime(System.currentTimeMillis());
- if (!TextUtils.isEmpty(packagename)) {
- NetInterfaceManager.getInstance().getAppUsageRecordControl()
- .sendappUsageRecord(Utils.getSerial(),
- ApkUtils.getAppNameByPackage(context, packagename),
- packagename,
- AppUsedTimeUtils.getInstance().getStartTime() / 1000,
- AppUsedTimeUtils.getInstance().getEndTime() / 1000)
- .subscribe(new Observer() {
- @Override
- public void onSubscribe(Disposable d) {
- Log.e("sendAppUsed", "onSubscribe: ");
- }
-
- @Override
- public void onNext(BaseResponse baseResponse) {
- Log.e("sendAppUsed", "onNext: " + baseResponse);
- }
-
- @Override
- public void onError(Throwable e) {
- Log.e("sendAppUsed", "onError: " + e.getMessage());
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("sendAppUsed", "onComplete: ");
- }
- });
- } else {
- Log.e("fht", "app = null" + packagename);
- }
- }
-
- //在这里处理任务执行中的状态，如进度进度条的刷新
- @Download.onTaskRunning
- protected void running(DownloadTask task) {
- Log.e("aria", "正在下载:" + task.getPercent() + ":" + task.getExtendField());
-// ToastUtil.show("正在下载:" + task.getPercent() + "%" + "\t" + Formatter.formatFileSize(MainService.this, task.getSpeed()) + "/s");
- }
-
- @Download.onTaskComplete
- void taskComplete(DownloadTask task) {
- //在这里处理任务完成的状态
- Log.e(TAG, "taskComplete: " + task.getFilePath());
- }
-
- @Download.onTaskFail
- void taskFail(DownloadTask task, Exception e) {
-
- }
-}
diff --git a/app/src/main/java/com/uiui/aios/activity/NoticeActivity.java b/app/src/main/java/com/uiui/zyos/activity/NoticeActivity.java
similarity index 82%
rename from app/src/main/java/com/uiui/aios/activity/NoticeActivity.java
rename to app/src/main/java/com/uiui/zyos/activity/NoticeActivity.java
index 80b9947..3df3e5d 100644
--- a/app/src/main/java/com/uiui/aios/activity/NoticeActivity.java
+++ b/app/src/main/java/com/uiui/zyos/activity/NoticeActivity.java
@@ -1,10 +1,9 @@
-package com.uiui.aios.activity;
+package com.uiui.zyos.activity;
import android.content.Context;
import android.content.Intent;
import android.media.AudioManager;
import android.media.MediaPlayer;
-import android.net.Uri;
import android.os.Bundle;
import android.os.PowerManager;
import android.os.Vibrator;
@@ -22,16 +21,14 @@ import com.blankj.utilcode.util.FileUtils;
import com.bumptech.glide.Glide;
import com.bumptech.glide.load.resource.bitmap.RoundedCorners;
import com.bumptech.glide.request.RequestOptions;
-import com.uiui.aios.R;
-import com.uiui.aios.alarm.AlarmUtils;
-import com.uiui.aios.bean.AlarmClockData;
-import com.uiui.aios.bean.BaseResponse;
-import com.uiui.aios.network.NetInterfaceManager;
-import com.uiui.aios.utils.FileUtil;
-import com.uiui.aios.utils.ScreenUtils;
-import com.uiui.aios.utils.Utils;
-import com.uiui.aios.utils.WakeUpUtils;
-import com.uiui.aios.view.JzvdStdAssert;
+import com.uiui.zyos.R;
+import com.uiui.zyos.alarm.AlarmUtils;
+import com.uiui.zyos.bean.AlarmClockData;
+import com.uiui.zyos.utils.FileUtil;
+import com.uiui.zyos.utils.ScreenUtils;
+import com.uiui.zyos.utils.Utils;
+import com.uiui.zyos.utils.WakeUpUtils;
+import com.uiui.zyos.view.JzvdStdAssert;
import java.io.File;
import java.io.FileInputStream;
@@ -114,32 +111,6 @@ public class NoticeActivity extends AppCompatActivity {
alarm.setFinished(true);
AlarmUtils.getInstance().updateAlarmFinished(alarm);
}
- NetInterfaceManager.getInstance()
- .getUpdateAlarmObservable(alarmClockData.getId())
- .subscribe(new Observer() {
- @Override
- public void onSubscribe(@NonNull Disposable d) {
- Log.e("showData", "onSubscribe: ");
- }
-
- @Override
- public void onNext(@NonNull BaseResponse baseResponse) {
- Log.e("showData", "onNext: " + baseResponse);
- }
-
- @Override
- public void onError(@NonNull Throwable e) {
- Log.e("showData", "onError: " + e.getMessage());
- onComplete();
- }
-
- @Override
- public void onComplete() {
- Log.e("showData", "onComplete: ");
- finish();
- }
- });
-
}
});
String voiceUrl = alarmClockData.getVoice();
diff --git a/app/src/main/java/com/uiui/aios/activity/PolicyActivity.java b/app/src/main/java/com/uiui/zyos/activity/PolicyActivity.java
similarity index 97%
rename from app/src/main/java/com/uiui/aios/activity/PolicyActivity.java
rename to app/src/main/java/com/uiui/zyos/activity/PolicyActivity.java
index 8c02769..d61fec5 100644
--- a/app/src/main/java/com/uiui/aios/activity/PolicyActivity.java
+++ b/app/src/main/java/com/uiui/zyos/activity/PolicyActivity.java
@@ -1,4 +1,4 @@
-package com.uiui.aios.activity;
+package com.uiui.zyos.activity;
import android.content.Intent;
import android.os.Bundle;
@@ -6,7 +6,7 @@ import android.widget.TextView;
import androidx.appcompat.app.AppCompatActivity;
-import com.uiui.aios.R;
+import com.uiui.zyos.R;
import java.io.BufferedReader;
import java.io.IOException;
diff --git a/app/src/main/java/com/uiui/aios/activity/main/MainActivity.java b/app/src/main/java/com/uiui/zyos/activity/main/MainActivity.java
similarity index 68%
rename from app/src/main/java/com/uiui/aios/activity/main/MainActivity.java
rename to app/src/main/java/com/uiui/zyos/activity/main/MainActivity.java
index e30459a..ea1e7df 100644
--- a/app/src/main/java/com/uiui/aios/activity/main/MainActivity.java
+++ b/app/src/main/java/com/uiui/zyos/activity/main/MainActivity.java
@@ -1,4 +1,4 @@
-package com.uiui.aios.activity.main;
+package com.uiui.zyos.activity.main;
import android.content.ActivityNotFoundException;
import android.content.BroadcastReceiver;
@@ -12,14 +12,10 @@ import android.content.res.Configuration;
import android.graphics.Color;
import android.os.Bundle;
import android.os.IBinder;
-import android.os.PersistableBundle;
-import android.os.RemoteException;
import android.provider.Settings;
import android.text.TextUtils;
import android.util.Log;
-import android.view.Gravity;
import android.view.KeyEvent;
-import android.view.WindowManager;
import androidx.annotation.NonNull;
import androidx.fragment.app.Fragment;
@@ -27,34 +23,25 @@ import androidx.fragment.app.FragmentManager;
import androidx.viewpager.widget.ViewPager;
import com.alarmclock.uiui.IAlarmAidlInterface;
-import com.google.gson.Gson;
-import com.google.gson.reflect.TypeToken;
+import com.flyco.tablayout.SlidingTabLayout;
import com.tencent.mmkv.MMKV;
-import com.uiui.aios.BuildConfig;
-import com.uiui.aios.R;
-import com.uiui.aios.base.BaseActivity;
-import com.uiui.aios.base.BaseFragmentPagerAdapter;
-import com.uiui.aios.bean.AlarmItem;
-import com.uiui.aios.bean.DesktopIcon;
-import com.uiui.aios.config.CommonConfig;
-import com.uiui.aios.dialog.PasswordDialog;
-import com.uiui.aios.dialog.PrivacyPolicyDialog;
-import com.uiui.aios.fragment.AppListFragment;
-import com.uiui.aios.fragment.ControlFragment;
-import com.uiui.aios.fragment.SecondFragment;
-import com.uiui.aios.fragment.custom.CustomFragment;
-import com.uiui.aios.service.NotificationService;
-import com.uiui.aios.utils.ApkUtils;
-import com.uiui.aios.utils.AppUsedTimeUtils;
-import com.uiui.aios.utils.HomeWatcher;
-import com.uiui.aios.utils.LauncherUtils;
-import com.uiui.aios.utils.ToastUtil;
-import com.uiui.aios.view.ScaleCircleNavigator;
+import com.uiui.zyos.BuildConfig;
+import com.uiui.zyos.R;
+import com.uiui.zyos.base.BaseActivity;
+import com.uiui.zyos.base.BaseFragmentPagerAdapter;
+import com.uiui.zyos.config.CommonConfig;
+import com.uiui.zyos.dialog.PrivacyPolicyDialog;
+import com.uiui.zyos.fragment.custom.CustomFragment;
+import com.uiui.zyos.service.NotificationService;
+import com.uiui.zyos.utils.AppUsedTimeUtils;
+import com.uiui.zyos.utils.HomeWatcher;
+import com.uiui.zyos.utils.LauncherUtils;
+import com.uiui.zyos.utils.ToastUtil;
+import com.uiui.zyos.view.ScaleCircleNavigator;
import net.lucode.hackware.magicindicator.MagicIndicator;
import net.lucode.hackware.magicindicator.ViewPagerHelper;
-import java.lang.reflect.Type;
import java.util.ArrayList;
import java.util.List;
@@ -63,13 +50,16 @@ import butterknife.ButterKnife;
public class MainActivity extends BaseActivity implements MainContact.MainView {
private static final String TAG = MainActivity.class.getSimpleName();
- private MainPresenter mMainPresenter;
+ @BindView(R.id.main_sliding_tab_layout)
+ SlidingTabLayout main_sliding_tab_layout;
@BindView(R.id.viewPager)
ViewPager mViewPager;
@BindView(R.id.magicIndicator)
MagicIndicator mMagicIndicator;
+ private MainPresenter mMainPresenter;
+
private ScaleCircleNavigator scaleCircleNavigator;
private FragmentManager mFragmentManager;
@@ -77,13 +67,9 @@ public class MainActivity extends BaseActivity implements MainContact.MainView {
private BaseFragmentPagerAdapter mBaseFragmentPagerAdapter;
private List