android/pipIrrApp.git

			@@ -1,10 +1,17 @@
			package com.dayu.pipirrapp.net;

			import android.content.Context;
			import android.net.ConnectivityManager;
			import android.net.NetworkCapabilities;
			import android.net.NetworkInfo;
			import android.os.Build;
			import android.util.Log;

			import com.dayu.pipirrapp.bean.WeatherResponse;
			import com.dayu.pipirrapp.MyApplication;
			import com.dayu.pipirrapp.bean.net.CodeResult;
			import com.dayu.pipirrapp.bean.net.WeatherResponse;
			import com.dayu.pipirrapp.net.subscribers.BaseProgressSubscriber;
			import com.dayu.pipirrapp.net.subscribers.CodeListener;
			import com.dayu.pipirrapp.net.subscribers.ProgressSubscriber;
			import com.dayu.pipirrapp.net.subscribers.SubscriberListener;
			import com.dayu.pipirrapp.utils.MapJpgUtils;
			@@ -72,6 +79,13 @@
			request(context, false, path, false, tClass, params, listener);
			}

			public <T> void requestGet(final Context context, final String path, final Class<T> tClass, final Map<String, Object> params, final SubscriberListener listener) {
			request(context, false, path, true, tClass, params, listener);
			}
			public <T> void requestGetHideLoading(final Context context, final String path, final Class<T> tClass, final Map<String, Object> params, final SubscriberListener listener) {
			request(context, true, path, true, tClass, params, listener);
			}

			/**
			* 发送请求
			*
			@@ -91,10 +105,9 @@

			if (isGet) {
			if (params == null) {
			observable = apiService.requestGet(path);
			observable = apiService.requestGet(path, MyApplication.myApplication.token);
			} else {

			observable = apiService.requestGet(path, params);
			observable = apiService.requestGet(path, params, MyApplication.myApplication.token);
			}
			} else {
			observable = apiService.requestPost(path, params);
			@@ -111,33 +124,16 @@
			response.setCode(tem.getCode());
			response.setMsg(tem.getMsg());

			if (tClass != null && tem.getContent() instanceof Map) {
			try {
			// response.setData(MyJsonParser.getBeanFromMap((Map<String, Object>) tem.getData(), tClass));
			String jsonData = MyJsonParser.getJsontoMap((Map) tem.getContent());
			response.setContent(MyJsonParser.getBeanFromJson(jsonData, tClass));
			} catch (Exception e) {
			e.printStackTrace();
			}
			} else if (tClass != null && tem.getContent() instanceof List) {
			try {
			response.setContent((T) MyJsonParser.getListByJson(MyJsonParser.getJsonbyList((List) tem.getContent()), tClass));
			} catch (Exception e) {
			e.printStackTrace();
			}
			} else if (tClass != null && tem.getContent() instanceof Integer) {
			response.setContent((T) tem.getContent());
			}
			if (tClass != null && tClass.getName() instanceof String && tem.getContent() instanceof String) {
			try {
			if (tClass != null) {
			if (tem.getContent() instanceof Map) {
			response.setContent(parseMapContent(tem.getContent(), tClass));
			} else if (tem.getContent() instanceof List) {
			response.setContent(parseListContent(tem.getContent(), tClass));
			} else if (tem.getContent() instanceof Integer \|\| tem.getContent() instanceof String) {
			response.setContent((T) tem.getContent());
			} catch (Exception e) {
			e.printStackTrace();
			}
			}
			return response;


			}

			return null;
			@@ -149,6 +145,28 @@

			}


			// 解析 Map 类型的数据
			private <T> T parseMapContent(Object content, Class<T> tClass) {
			try {
			String jsonData = MyJsonParser.getJsontoMap((Map<String, Object>) content);
			return MyJsonParser.getBeanFromJson(jsonData, tClass);
			} catch (Exception e) {
			Log.e(TAG, "Error parsing map content", e);
			return null;
			}
			}

			// 解析 List 类型的数据
			private <T> T parseListContent(Object content, Class<T> tClass) {
			try {
			String jsonData = MyJsonParser.getJsonbyList((List<?>) content);
			return (T) MyJsonParser.getListByJson(jsonData, tClass);
			} catch (Exception e) {
			Log.e(TAG, "Error parsing list content", e);
			return null;
			}
			}

			/**
			* 获取天气
			@@ -169,30 +187,62 @@
			}


			public void donwLoadTile(Context context, String urlPath) {
			/**
			* 获取验证码
			*
			* @param params
			* @param listener
			* @param <T>
			*/
			public <T> void getCode(Map<String, Object> params, CodeListener listener) {
			if (isNetworkAvailable(MyApplication.myApplication)) {
			Observable observable;
			observable = apiService.getCode(params);
			observable.subscribeOn(Schedulers.io())
			.unsubscribeOn(Schedulers.newThread())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(responseBody -> {
			listener.onNext((CodeResult) responseBody);
			}, throwable -> {
			listener.error((Throwable) throwable);
			});
			} else {
			listener.onNext(null);
			}

			}


			/**
			* 下载地图瓦片
			*
			* @param urlPath
			*/
			public void donwLoadTile(String urlPath) {
			Observable<ResponseBody> observable;
			observable = apiService.downloadTile(urlPath);


			compositeDisposable.add(
			observable
			.subscribeOn(Schedulers.io()) // 网络请求在 I/O 线程中进行
			.observeOn(Schedulers.io()) // 回调处理也在 I/O 线程
			.subscribe(
			responseBody -> {
			boolean success = false;
			if (!MapJpgUtils.getInsatance(context).isHasFiles(urlPath)) {
			success = MapJpgUtils.getInsatance(context).saveTileToCache(urlPath, responseBody);
			}
			if (success) {
			Log.d(TAG, "Download success for tile: " + urlPath);
			} else {
			Log.e(TAG, "Failed to save tile to disk: " + urlPath);
			}
			},
			throwable -> Log.e(TAG, "Download failed for tile: " + urlPath)
			)
			);
			// compositeDisposable.add(
			observable
			.subscribeOn(Schedulers.io()) // 网络请求在 I/O 线程中进行
			.observeOn(Schedulers.io()) // 回调处理也在 I/O 线程
			.subscribe(
			responseBody -> {

			boolean success = false;
			if (!MapJpgUtils.getInsatance().isHasFiles(urlPath)) {
			success = MapJpgUtils.getInsatance().saveTileToCache(urlPath, responseBody);
			}
			if (success) {
			Log.d(TAG, "Download success for tile: " + urlPath);
			} else {
			Log.e(TAG, "Failed to save tile to disk: " + urlPath);
			}
			},
			throwable -> Log.e(TAG, "Download failed for tile: " + urlPath)
			);
			// );


			}
			@@ -204,4 +254,35 @@
			}
			}

			/**
			* 判断当前是否有网络
			*
			* @param context
			* @return
			*/
			public boolean isNetworkAvailable(Context context) {
			ConnectivityManager connectivityManager = (ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE);

			if (connectivityManager != null) {
			// 对于 Android 版本大于等于 Android Q (API level 29)
			if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {
			NetworkCapabilities capabilities = connectivityManager.getNetworkCapabilities(connectivityManager.getActiveNetwork());
			if (capabilities != null) {
			// 检查网络是否有传输能力（包括 Wi-Fi 和移动数据）
			if (capabilities.hasTransport(NetworkCapabilities.TRANSPORT_WIFI) \|\| capabilities.hasTransport(NetworkCapabilities.TRANSPORT_CELLULAR)) {
			return true;
			}
			}
			} else {
			// 对于 Android Q 以下版本
			NetworkInfo activeNetworkInfo = connectivityManager.getActiveNetworkInfo();
			if (activeNetworkInfo != null && activeNetworkInfo.isConnected()) {
			return true;
			}
			}
			}

			return false; // 无网络连接
			}

			}