android/pipIrrApp.git

			@@ -20,6 +20,7 @@

			import androidx.annotation.NonNull;
			import androidx.annotation.Nullable;
			import androidx.core.content.ContextCompat;
			import androidx.lifecycle.Observer;

			import com.dayu.pipirrapp.MyApplication;
			@@ -39,7 +40,6 @@
			import com.dayu.pipirrapp.bean.net.InspectionRequest;
			import com.dayu.pipirrapp.bean.net.MarkerListResult;
			import com.dayu.pipirrapp.bean.net.MarkerResult;
			import com.dayu.pipirrapp.bean.net.PipeNetworkListResult;
			import com.dayu.pipirrapp.bean.net.PipeNetworkResult;
			import com.dayu.pipirrapp.dao.DaoSingleton;
			import com.dayu.pipirrapp.databinding.FragmentMapBinding;
			@@ -80,6 +80,7 @@
			import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
			import io.reactivex.rxjava3.disposables.CompositeDisposable;
			import io.reactivex.rxjava3.schedulers.Schedulers;
			import kotlin.Triple;

			/**
			* author: zuo
			@@ -140,6 +141,7 @@
			getCenterPoint();
			getMarkerData();
			getDivideList();
			getPipeNetworkList();
			});
			}

			@@ -178,69 +180,91 @@
			private void loadLocalData() {
			// 异步加载中心点数据
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(this.getContext()).centerPointDao().findFirst()
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(result -> {
			centerPointBean = result;
			if (centerPointBean == null) {
			getCenterPoint();
			} else {
			jumpCenterPoint();
			}
			}, throwable -> {
			Log.e(TAG, "Load centerPoint error: " + throwable);
			getCenterPoint();
			}, () -> {
			// 当Maybe为空时调用
			getCenterPoint();
			})
			DaoSingleton.getAsynchInstance(this.getContext()).centerPointDao().findFirst()
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(result -> {
			centerPointBean = result;
			if (centerPointBean == null) {
			getCenterPoint();
			} else {
			jumpCenterPoint();
			}
			}, throwable -> {
			Log.e(TAG, "Load centerPoint error: " + throwable);
			getCenterPoint();
			}, () -> {
			// 当Maybe为空时调用
			getCenterPoint();
			})
			);

			// 异步加载取水口数据
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(this.getContext()).markerDao().getAll()
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(markers -> {
			if (markers == null \|\| markers.isEmpty()) {
			getMarkerData();
			} else {
			for (MarkerBean marker : markers) {
			markerBeanSet.put(marker.getId(), marker);
			setMapMarker(marker);
			}
			}
			}, throwable -> {
			Log.e(TAG, "Load markers error: " + throwable.getMessage());
			getMarkerData();
			}, () -> {
			// 当Maybe为空时调用
			getMarkerData();
			})
			DaoSingleton.getAsynchInstance(this.getContext()).markerDao().getAll()
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(markers -> {
			if (markers == null \|\| markers.isEmpty()) {
			getMarkerData();
			} else {
			for (MarkerBean marker : markers) {
			markerBeanSet.put(marker.getId(), marker);
			setMapMarker(marker);
			}
			}
			}, throwable -> {
			Log.e(TAG, "Load markers error: " + throwable.getMessage());
			getMarkerData();
			}, () -> {
			// 当Maybe为空时调用
			getMarkerData();
			})
			);

			// 异步加载分水房数据
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(this.getContext()).divideDao().getAll()
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(divides -> {
			if (divides == null \|\| divides.isEmpty()) {
			getDivideList();
			} else {
			for (DivideBean divide : divides) {
			divideBeanMap.put(divide.getId(), divide);
			setMapDivide(divide);
			}
			}
			}, throwable -> {
			Log.e(TAG, "Load divides error: " + throwable.getMessage());
			getDivideList();
			}, () -> {
			// 当Maybe为空时调用
			getDivideList();
			})
			DaoSingleton.getAsynchInstance(this.getContext()).divideDao().getAll()
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(divides -> {
			if (divides == null \|\| divides.isEmpty()) {
			getDivideList();
			} else {
			for (DivideBean divide : divides) {
			divideBeanMap.put(divide.getId(), divide);
			setMapDivide(divide);
			}
			}
			}, throwable -> {
			Log.e(TAG, "Load divides error: " + throwable.getMessage());
			getDivideList();
			}, () -> {
			// 当Maybe为空时调用
			getDivideList();
			})
			);
			//异步加载管网数据
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(this.getContext()).pipeNetDao().getAll()
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(pipeNetworkBeans -> {
			if (pipeNetworkBeans == null \|\| pipeNetworkBeans.isEmpty()) {
			getPipeNetworkList();
			} else {
			for (PipeNetworkBean pipeNetworkBean : pipeNetworkBeans) {


			}
			}
			}, throwable -> {
			Log.e(TAG, "Load divides error: " + throwable.getMessage());
			getDivideList();
			}, () -> {
			// 当Maybe为空时调用
			getDivideList();
			})
			);
			}

			@@ -370,19 +394,19 @@

			// 使用 CompositeDisposable 管理数据库插入操作
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).markerDao().insertAll(markerBeans)
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(
			() -> {
			// 插入成功
			Log.i("mWebView", "数据插入成功");
			},
			throwable -> {
			// 插入失败
			Log.e("mWebView", "数据插入失败: " + throwable.getMessage());
			}
			)
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).markerDao().insertAll(markerBeans)
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(
			() -> {
			// 插入成功
			Log.i("mWebView", "数据插入成功");
			},
			throwable -> {
			// 插入失败
			Log.e("mWebView", "数据插入失败: " + throwable.getMessage());
			}
			)
			);
			}

			@@ -432,8 +456,27 @@
			Intent issue = new Intent(MapFragment.this.getActivity(), AddIssueActivity.class);
			MapFragment.this.getActivity().startActivity(issue);
			});
			binding.expandButton.setLegendsArray(new Triple<>(
			ContextCompat.getDrawable(requireContext(), R.drawable.marker_blue),
			ContextCompat.getDrawable(requireContext(), R.drawable.marker_unselected),
			"取水口"
			),
			new Triple<>(
			ContextCompat.getDrawable(requireContext(), R.drawable.divide_home_blue),
			ContextCompat.getDrawable(requireContext(), R.drawable.divide_home_unselected),
			"分水房"
			));
			binding.expandButton.setOnLegendItemClickListener((position, isSelected) -> {
			switch (position) {
			case 0:
			showMarkers(isSelected);
			break;
			case 1:
			showDivideMarkers(isSelected);
			break;


			}
			});
			}

			/**
			@@ -1010,22 +1053,22 @@
			setMapDivide(divideBean);
			divideBeans.add(divideBean);
			}


			// 使用 CompositeDisposable 管理数据库插入操作
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).divideDao().insertAll(divideBeans)
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(
			() -> {
			// 插入成功
			Log.i("mWebView", "数据插入成功");
			},
			throwable -> {
			// 插入失败
			Log.e("mWebView", "数据插入失败: " + throwable.getMessage());
			}
			)
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).divideDao().insertAll(divideBeans)
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(
			() -> {
			// 插入成功
			Log.i("mWebView", "数据插入成功");
			},
			throwable -> {
			// 插入失败
			Log.e("mWebView", "数据插入失败: " + throwable.getMessage());
			}
			)
			);
			}
			} else {
			@@ -1043,21 +1086,22 @@
			* 获取管网
			*/
			private void getPipeNetworkList() {
			ApiManager.getInstance().requestGetHideLoading(MapFragment.this.getContext(), BASE_URL + "/project/network/all", PipeNetworkListResult.class, null, new SubscriberListener<BaseResponse<PipeNetworkListResult>>() {
			ApiManager.getInstance().requestGetHideLoading(MapFragment.this.getContext(), BASE_URL + "/project/network/all", PipeNetworkResult.class, null, new SubscriberListener<BaseResponse<List<PipeNetworkResult>>>() {
			@Override
			public void onNext(BaseResponse<PipeNetworkListResult> t) {
			public void onNext(BaseResponse<List<PipeNetworkResult>> t) {
			try {
			if (t.isSuccess()) {
			if (t.getContent().getObj() != null && !t.getContent().getObj().isEmpty()) {
			if (t.getContent() != null && t.getContent().size() > 0) {

			List<DivideBean> divideBeans = new ArrayList<>();
			for (PipeNetworkResult divideResult : t.getContent().getObj()) {
			PipeNetworkBean divideBean = getPipeNetworkBean(divideResult);
			setMapDivide(divideBean);
			// divideBeans.add(divideBean);
			List<PipeNetworkBean> pipeNetBeans = new ArrayList<>();
			PipeNetworkBean pipeNetBean = new PipeNetworkBean();
			for (PipeNetworkResult pipeNetworkResult : t.getContent()) {
			pipeNetBean.setNetworkId(pipeNetworkResult.getNetworkId());
			pipeNetBean.setType(pipeNetworkResult.getType());
			pipeNetBean.setData(pipeNetworkResult.getData());
			}
			// 使用 RxJava 异步插入数据
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).divideDao().insertAll(divideBeans)
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).pipeNetDao().insertAll(pipeNetBeans)
			.subscribeOn(Schedulers.io()) // 在 IO 线程上执行
			.observeOn(AndroidSchedulers.mainThread()) // 在主线程上观察
			.subscribe(() -> {
			@@ -1157,4 +1201,36 @@
			mWebView.restoreState(savedInstanceState);
			}
			}

			/**
			* 显示或隐藏地图上的取水口
			*
			* @param isShow
			*/
			private void showMarkers(boolean isShow) {
			if (isShow) {
			mWebView.evaluateJavascript("javascript:showAllWaterIntakes()", value -> {
			});
			} else {
			mWebView.evaluateJavascript("javascript:hideAllWaterIntakes()", value -> {
			});
			}

			}

			/**
			* 显示或隐藏地图上的分水房
			*
			* @param isShow
			*/
			private void showDivideMarkers(boolean isShow) {
			if (isShow) {
			mWebView.evaluateJavascript("javascript:showAllDivides()", value -> {
			});
			} else {
			mWebView.evaluateJavascript("javascript:hideAllDivides()", value -> {
			});
			}
			}

			}