android/pipIrrApp.git

			@@ -5,11 +5,9 @@
			import android.content.Context;
			import android.content.Intent;
			import android.content.res.Resources;
			import android.graphics.drawable.Drawable;
			import android.os.Bundle;
			import android.text.TextUtils;
			import android.util.Log;
			import android.util.Pair;
			import android.view.LayoutInflater;
			import android.view.View;
			import android.view.ViewGroup;
			@@ -34,7 +32,9 @@
			import com.dayu.pipirrapp.bean.db.InspectionLocationBean;
			import com.dayu.pipirrapp.bean.db.LatLonBean;
			import com.dayu.pipirrapp.bean.db.MarkerBean;
			import com.dayu.pipirrapp.bean.db.PipeNetWorkDataBean;
			import com.dayu.pipirrapp.bean.db.PipeNetworkBean;
			import com.dayu.pipirrapp.bean.db.PipeNetworkDataCoordinateBean;
			import com.dayu.pipirrapp.bean.net.CenterPointResult;
			import com.dayu.pipirrapp.bean.net.DivideListResult;
			import com.dayu.pipirrapp.bean.net.DivideResult;
			@@ -42,7 +42,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;
			@@ -64,6 +63,7 @@
			import com.dayu.pipirrapp.utils.ToastUtil;
			import com.dayu.pipirrapp.utils.WebViewUtils;
			import com.dayu.pipirrapp.view.ConfirmDialog;
			import com.dayu.pipirrapp.view.SearchResultDialog;
			import com.dayu.pipirrapp.view.TipUtil;
			import com.example.expand_button.ExpandButton;
			import com.hjq.permissions.OnPermissionCallback;
			@@ -84,7 +84,6 @@
			import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
			import io.reactivex.rxjava3.disposables.CompositeDisposable;
			import io.reactivex.rxjava3.schedulers.Schedulers;
			import kotlin.Triple;

			/**
			* author: zuo
			@@ -112,6 +111,7 @@
			//web加载时网页还没加载完时的数据
			List<MarkerBean> webNoFinishMarkerData = new ArrayList<>();
			List<DivideBean> webNoFinishDivideData = new ArrayList<>();
			List<PipeNetworkBean> webNoFinishPipeNetworkData = new ArrayList<>();
			//所有的Marker数据键为marker的Id
			Map<String, MarkerBean> markerBeanSet = new HashMap<>();
			//所有分水房
			@@ -121,6 +121,9 @@
			public double centerLat;

			MarkerBean mMarkerBean;

			//是否显示Marker
			boolean isShowMarker, isShowPipeNetwork, isShowDivide;

			// 添加CompositeDisposable来管理所有订阅
			private CompositeDisposable compositeDisposable = new CompositeDisposable();
			@@ -145,6 +148,7 @@
			getCenterPoint();
			getMarkerData();
			getDivideList();
			getPipeNetworkList();
			});
			}

			@@ -181,6 +185,8 @@
			* 异步加载本地数据
			*/
			private void loadLocalData() {


			// 异步加载中心点数据
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(this.getContext()).centerPointDao().findFirst()
			@@ -201,7 +207,7 @@
			getCenterPoint();
			})
			);

			isShowMarker = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.markerKeyIsShow, true);
			// 异步加载取水口数据
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(this.getContext()).markerDao().getAll()
			@@ -224,7 +230,7 @@
			getMarkerData();
			})
			);

			isShowDivide = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.divideIsShow, true);
			// 异步加载分水房数据
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(this.getContext()).divideDao().getAll()
			@@ -245,6 +251,29 @@
			}, () -> {
			// 当Maybe为空时调用
			getDivideList();
			})
			);

			isShowPipeNetwork = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.pipeNetworkIsShow, true);
			//异步加载管网数据
			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) {
			setMapPipe(pipeNetworkBean);
			}
			}
			}, throwable -> {
			Log.e(TAG, "Load PipeNetworkBean error: " + throwable.getMessage());
			getPipeNetworkList();
			}, () -> {
			// 当Maybe为空时调用
			getPipeNetworkList();
			})
			);
			}
			@@ -334,6 +363,12 @@
			setMapDivide(bean);
			}
			}
			if (!webNoFinishPipeNetworkData.isEmpty()) {
			for (PipeNetworkBean bean : webNoFinishPipeNetworkData) {
			setMapPipe(bean);
			}
			}

			//显示所有取水口
			MarkerUtils.showLocoMarks(MapFragment.this);
			//显示巡检状态并且显示因意外关闭的历史数据
			@@ -372,7 +407,7 @@
			return markerBean;
			})
			.collect(Collectors.toList());

			DaoSingleton.getInstance(MapFragment.this.getContext()).markerDao().deleteAll();
			// 使用 CompositeDisposable 管理数据库插入操作
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).markerDao().insertAll(markerBeans)
			@@ -405,7 +440,7 @@
			//巡检按钮
			binding.inspectButton.setOnClickListener(v -> {
			if (XXPermissions.isGranted(MapFragment.this.getContext(), Permission.ACCESS_BACKGROUND_LOCATION)) {
			new ConfirmDialog(MapFragment.this.getActivity(), (confirmDialog, v1) -> {
			new ConfirmDialog(MapFragment.this.getActivity(), "确认开始巡检吗？",(confirmDialog, v1) -> {
			chageInspecState(InspectionUtils.STAT_INSPECTION_ONCLICK);
			confirmDialog.dismiss();
			}).show();
			@@ -437,28 +472,88 @@
			Intent issue = new Intent(MapFragment.this.getActivity(), AddIssueActivity.class);
			MapFragment.this.getActivity().startActivity(issue);
			});
			binding.expandButton.setLegendsArray(new Triple<>(
			binding.expandButton.setLegendsArray(new ExpandButton.Quadruple(
			ContextCompat.getDrawable(requireContext(), R.drawable.marker_blue),
			ContextCompat.getDrawable(requireContext(), R.drawable.marker_unselected),
			"取水口"
			"取水口", isShowMarker
			),
			new Triple<>(
			new ExpandButton.Quadruple(
			ContextCompat.getDrawable(requireContext(), R.drawable.divide_home_blue),
			ContextCompat.getDrawable(requireContext(), R.drawable.divide_home_unselected),
			"分水房"
			));
			"分水房", isShowDivide
			),
			new ExpandButton.Quadruple(
			ContextCompat.getDrawable(requireContext(), R.drawable.ic_pipenetwork_line),
			ContextCompat.getDrawable(requireContext(), R.drawable.ic_pipenetwork_line_unselected),
			"管网", isShowPipeNetwork
			)
			);
			binding.expandButton.setOnLegendItemClickListener((position, isSelected) -> {
			switch (position) {
			case 0:
			showMarkers(isSelected);
			SharedPreferencesHelper.getInstance(this.getContext()).put(CommonKeyName.markerKeyIsShow, isSelected);
			break;
			case 1:
			showDivideMarkers(isSelected);
			SharedPreferencesHelper.getInstance(this.getContext()).put(CommonKeyName.divideIsShow, isSelected);
			break;
			case 2:
			showPipeLine(isSelected);
			SharedPreferencesHelper.getInstance(this.getContext()).put(CommonKeyName.pipeNetworkIsShow, isSelected);
			break;

			}
			});
			binding.searchButton.setOnSearchClickListener(s -> {
			if (s != null && !s.isEmpty()) {
			SearchResultDialog searchDialog = new SearchResultDialog(requireContext());
			searchDialog.setOnItemClickListener(item -> {
			// 根据类型处理点击事件
			// if ("marker".equals(item.getType())) {
			// MarkerBean markerBean = new MarkerBean();
			// markerBean.setId(item.getId());
			// getInstakeDetail(markerBean);
			// } else {
			// DivideBean divideBean = new DivideBean();
			// divideBean.setDivideId(item.getId());
			// getDivideDetail(divideBean);
			// }
			// 跳转到选择的位置
			mWebView.evaluateJavascript(
			String.format("javascript:setCenterAndZoom(\"%s\",\"%s\",\"17\")",
			item.getLng(),
			item.getLat()),
			null
			);
			});

			// 执行搜索
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(requireContext())
			.divideDao()
			.searchAllByKeyword(s)
			.subscribeOn(Schedulers.io())
			.observeOn(AndroidSchedulers.mainThread())
			.subscribe(
			results -> {
			if (results != null && !results.isEmpty()) {
			searchDialog.setData(results);
			searchDialog.show();
			} else {
			ToastUtil.showToast(requireContext(), "未找到相关结果");
			}
			},
			throwable -> {
			ToastUtil.showToast(requireContext(), "搜索失败：" + throwable.getMessage());
			}
			)
			);
			}
			return null;
			});
			}


			/**
			* 显示取水口详情
			@@ -503,6 +598,7 @@
			centerPointBean.setLat(t.getContent().getLat());
			centerPointBean.setLng(t.getContent().getLng());
			centerPointBean.setZoomMp(t.getContent().getZoomMp());
			DaoSingleton.getInstance(MapFragment.this.getContext()).centerPointDao().deleteAll();
			DaoSingleton.getInstance(MapFragment.this.getContext()).centerPointDao().insert(centerPointBean);
			jumpCenterPoint();
			} else {
			@@ -696,13 +792,13 @@
			}

			/**
			* 添加标注点
			* 添加取水口
			*/
			public void setMapMarker(MarkerBean markerBean) {
			if (markerBean != null) {
			if (webViewIsFinished) {
			if (!TextUtils.isEmpty(markerBean.getLng()) && !TextUtils.isEmpty(markerBean.getLat())) {
			mWebView.evaluateJavascript("javascript:addMarker(\"" + markerBean.getId() + "\",\"" + markerBean.getLng() + "\",\"" + markerBean.getLat() + "\",\"" + markerBean.getName() + "\")", new ValueCallback<String>() {
			mWebView.evaluateJavascript("javascript:addMarker(\"" + markerBean.getId() + "\",\"" + markerBean.getLng() + "\",\"" + markerBean.getLat() + "\",\"" + markerBean.getName() + "\",\"" + isShowMarker + "\")", new ValueCallback<String>() {
			@Override
			public void onReceiveValue(String value) {
			}
			@@ -718,13 +814,13 @@
			}

			/**
			* 添加取水口标注
			* 添加分水房
			*/
			public void setMapDivide(DivideBean divide) {
			if (divide != null) {
			if (webViewIsFinished) {
			if (!TextUtils.isEmpty(divide.getLng()) && !TextUtils.isEmpty(divide.getLat())) {
			mWebView.evaluateJavascript("javascript:addDivide(\"" + divide.getId() + "\",\"" + divide.getLng() + "\",\"" + divide.getLat() + "\",\"" + divide.getDivideName() + "\")", new ValueCallback<String>() {
			mWebView.evaluateJavascript("javascript:addDivide(\"" + divide.getId() + "\",\"" + divide.getLng() + "\",\"" + divide.getLat() + "\",\"" + divide.getDivideName() + "\",\"" + isShowDivide + "\")", new ValueCallback<String>() {
			@Override
			public void onReceiveValue(String value) {
			}
			@@ -742,24 +838,24 @@
			/**
			* 添加管网标注
			*/
			public void setMapDivide(PipeNetworkBean pipeNetworkBean) {
			// if (divide != null) {
			// if (webViewIsFinished) {
			// for ()
			// if (!TextUtils.isEmpty(divide.getLng()) && !TextUtils.isEmpty(divide.getLat())) {
			// mWebView.evaluateJavascript("javascript:addDivide(\"" + divide.getId() + "\",\"" + divide.getLng() + "\",\"" + divide.getLat() + "\",\"" + divide.getDivideName() + "\")", new ValueCallback<String>() {
			// @Override
			// public void onReceiveValue(String value) {
			// }
			// });
			// divideBeanMap.put(divide.getId(), divide);
			// } else {
			// MyLog.d("setMapDivide>" + divide.getDivideName() + "经纬度为空");
			// }
			// } else {
			// webNoFinishDivideData.add(divide);
			// }
			// }
			public void setMapPipe(PipeNetworkBean pipeNetworkBean) {
			if (pipeNetworkBean != null) {
			if (webViewIsFinished) {
			boolean isfrist = true;
			for (PipeNetworkDataCoordinateBean data : pipeNetworkBean.getData().getCoordinates()) {
			if (!TextUtils.isEmpty(data.getLat()) && !TextUtils.isEmpty(data.getLng())) {
			mWebView.evaluateJavascript("javascript:addPipeNetwork(\"" + data.getLng() + "\",\"" + data.getLat() + "\",\"" + isfrist + "\",\"" + isShowPipeNetwork +"\")", new ValueCallback<String>() {
			@Override
			public void onReceiveValue(String value) {
			}
			});
			isfrist = false;
			}
			}
			} else {
			webNoFinishPipeNetworkData.add(pipeNetworkBean);
			}
			}
			}

			/**
			@@ -1034,7 +1130,7 @@
			setMapDivide(divideBean);
			divideBeans.add(divideBean);
			}

			DaoSingleton.getInstance(MapFragment.this.getContext()).divideDao().deleteAll();
			// 使用 CompositeDisposable 管理数据库插入操作
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).divideDao().insertAll(divideBeans)
			@@ -1067,30 +1163,48 @@
			* 获取管网
			*/
			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<>();

			for (PipeNetworkResult pipeNetworkResult : t.getContent()) {
			PipeNetworkBean pipeNetBean = new PipeNetworkBean();
			pipeNetBean.setNetworkId(pipeNetworkResult.getNetworkId());
			pipeNetBean.setType(pipeNetworkResult.getType());
			PipeNetWorkDataBean data = new PipeNetWorkDataBean();
			data.setType(pipeNetworkResult.getData().getType());
			List<PipeNetworkDataCoordinateBean> coordinates = new ArrayList<>();
			for (PipeNetworkResult.Data.Coordinate dataBean : pipeNetworkResult.getData().getCoordinates()) {
			PipeNetworkDataCoordinateBean coordinate = new PipeNetworkDataCoordinateBean();
			coordinate.setLat(dataBean.getLat());
			coordinate.setLng(dataBean.getLng());
			coordinates.add(coordinate);
			}
			data.setCoordinates(coordinates);
			pipeNetBean.setData(data);
			setMapPipe(pipeNetBean);
			pipeNetBeans.add(pipeNetBean);
			}

			DaoSingleton.getInstance(MapFragment.this.getContext()).pipeNetDao().deleteAll();
			// 使用 RxJava 异步插入数据
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).divideDao().insertAll(divideBeans)
			.subscribeOn(Schedulers.io()) // 在 IO 线程上执行
			.observeOn(AndroidSchedulers.mainThread()) // 在主线程上观察
			.subscribe(() -> {
			// 插入成功
			Log.i("mWebView", "数据插入成功");
			}, throwable -> {
			// 插入失败
			Log.e("mWebView", "数据插入失败: " + throwable.getMessage());
			});
			compositeDisposable.add(
			DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).pipeNetDao().insertAll(pipeNetBeans)
			.subscribeOn(Schedulers.io()) // 在 IO 线程上执行
			.observeOn(AndroidSchedulers.mainThread()) // 在主线程上观察
			.subscribe(() -> {
			// 插入成功
			Log.i("mWebView", "数据插入成功");
			}, throwable -> {
			// 插入失败
			Log.e("mWebView", "数据插入失败: " + throwable.getMessage());
			})
			);
			}


			@@ -1213,4 +1327,14 @@
			}
			}

			private void showPipeLine(boolean isSelected) {
			if (isSelected) {
			mWebView.evaluateJavascript("javascript:showAllPipeLines()", value -> {
			});
			} else {
			mWebView.evaluateJavascript("javascript:hideAllPipeLines()", value -> {
			});
			}
			}

			}