package com.dayu.pipirrapp.fragment; import static com.dayu.pipirrapp.net.Constants.BASE_URL; import android.content.Context; import android.content.Intent; import android.content.res.Resources; import android.os.Bundle; import android.text.TextUtils; import android.util.Log; import android.view.LayoutInflater; import android.view.View; import android.view.ViewGroup; import android.webkit.ValueCallback; import android.webkit.WebResourceError; import android.webkit.WebResourceRequest; import android.webkit.WebResourceResponse; import android.webkit.WebView; import android.webkit.WebViewClient; import androidx.annotation.NonNull; import androidx.annotation.Nullable; import androidx.lifecycle.Observer; import com.dayu.pipirrapp.MyApplication; import com.dayu.pipirrapp.R; import com.dayu.pipirrapp.activity.AddIssueActivity; import com.dayu.pipirrapp.bean.db.CenterPointBean; import com.dayu.pipirrapp.bean.db.DivideBean; import com.dayu.pipirrapp.bean.db.InspectionBean; 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.PipeNetworkBean; import com.dayu.pipirrapp.bean.net.CenterPointResult; import com.dayu.pipirrapp.bean.net.DivideListResult; import com.dayu.pipirrapp.bean.net.DivideResult; import com.dayu.pipirrapp.bean.net.InsectionResult; 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; import com.dayu.pipirrapp.net.ApiManager; import com.dayu.pipirrapp.net.BaseResponse; import com.dayu.pipirrapp.net.Constants; import com.dayu.pipirrapp.net.subscribers.SubscriberListener; import com.dayu.pipirrapp.observer.MapFragmenObserver; import com.dayu.pipirrapp.tool.InspectionUtils; import com.dayu.pipirrapp.tool.MarkerUtils; import com.dayu.pipirrapp.tool.MyWebViewInterface; import com.dayu.pipirrapp.utils.CommonData; import com.dayu.pipirrapp.utils.CommonKeyName; import com.dayu.pipirrapp.utils.DateUtils; import com.dayu.pipirrapp.utils.MapJpgUtils; import com.dayu.pipirrapp.utils.MyLog; import com.dayu.pipirrapp.utils.ServiceUtils; import com.dayu.pipirrapp.utils.SharedPreferencesHelper; import com.dayu.pipirrapp.utils.ToastUtil; import com.dayu.pipirrapp.utils.WebViewUtils; import com.dayu.pipirrapp.view.ConfirmDialog; import com.dayu.pipirrapp.view.TipUtil; import com.hjq.permissions.OnPermissionCallback; import com.hjq.permissions.Permission; import com.hjq.permissions.XXPermissions; import com.jeremyliao.liveeventbus.LiveEventBus; import com.tencent.bugly.crashreport.CrashReport; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers; import io.reactivex.rxjava3.schedulers.Schedulers; /** * author: zuo * Date: 2023/12/20 * Time: 10:16 * 备注：地图页 */ public class MapFragment extends BaseFragment { static String TAG = "MapFragment"; FragmentMapBinding binding; WebView mWebView; CenterPointBean centerPointBean; //当前巡检状态 int mInspectionState; MapFragmenObserver mapFragmenObserver; //当前巡检记录的相关信息 public InspectionBean mInspectionBean; //最后一次定位的坐标 LatLonBean lastLatLonBean; //web是否加载完成 volatile boolean webViewIsFinished = false; List aginShowlocationBeans; //web加载时网页还没加载完时的数据 List webNoFinishMarkerData = new ArrayList<>(); List webNoFinishDivideData = new ArrayList<>(); //所有的Marker数据键为marker的Id Map markerBeanSet = new HashMap<>(); //所有分水房 Map divideBeanMap = new HashMap<>(); //中心点坐标 public double centerLng; public double centerLat; MarkerBean mMarkerBean; @Override public void onAttach(@NonNull Context context) { super.onAttach(context); Log.i(TAG, "onAttach"); mapFragmenObserver = new MapFragmenObserver(); requireActivity().getLifecycle().addObserver(mapFragmenObserver); } @Override public void onCreate(@Nullable Bundle savedInstanceState) { super.onCreate(savedInstanceState); setRetainInstance(true); Log.i(TAG, "onCreate"); mInspectionState = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.inspectionState, 0); } @Override public void onStart() { super.onStart(); Log.i(TAG, "onStart"); } @Nullable @Override public View onCreateView(@NonNull LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState) { binding = FragmentMapBinding.inflate(inflater, container, false); mapFragmenObserver.setmWebView(binding.webView); Log.i("MapFragment", "onCreateView"); mWebView = binding.webView; mWebView = WebViewUtils.initWebView(mWebView); MyWebViewInterface myWebViewInterface = new MyWebViewInterface(MapFragment.this); mWebView.addJavascriptInterface(myWebViewInterface, "Android"); mWebView.loadUrl("file:///android_asset/index.html"); getCenterPoint(); initView(); initWeb(); getMarkerData(); getDivideList(); chageInspecState(mInspectionState); return binding.getRoot(); } private void initWeb() { mWebView.setWebViewClient(new WebViewClient() { @Override public WebResourceResponse shouldInterceptRequest(WebView view, WebResourceRequest request) { String url = request.getUrl().toString(); //判断当前是否为加载瓦片 if (MapJpgUtils.getInsatance().isTianDiTuTileRequest(url)) { String androidUrl = url.replace(CommonData.webKey, CommonData.androidKey); // 检查本地缓存 File cachedTile = MapJpgUtils.getInsatance().getCachedTile(androidUrl); if (cachedTile != null && cachedTile.exists()) { // Log.d(TAG, "本地缓存>>>" + androidUrl); // if (MapJpgUtils.getInsatance().validateImageFile(androidUrl,request.)) // 判断缓存是否过期 // if (!MapJpgUtils.getInsatance(MapFragment.this.getContext()).isCacheExpired(cachedTile)) { try { // 从缓存加载瓦片 return new WebResourceResponse("image/jpg", "utf-8", new FileInputStream(cachedTile)); } catch (FileNotFoundException e) { e.printStackTrace(); } // } } else { //下载瓦片 ApiManager.getInstance().donwLoadTile(MapFragment.this.getContext(), androidUrl); } } return super.shouldInterceptRequest(view, request); } @Override public void onReceivedError(WebView view, WebResourceRequest request, WebResourceError error) { super.onReceivedError(view, request, error); // 捕获加载过程中发生的错误 int errorCode = error.getErrorCode(); String description = error.getDescription().toString(); String failingUrl = request.getUrl().toString(); Log.e("setWebViewClient", "errorCode:" + errorCode + ">>>>description:" + description + ">>>>failingUrl:" + failingUrl); // 处理错误，例如显示错误页面或提示用户 } @Override public void onReceivedHttpError(WebView view, WebResourceRequest request, WebResourceResponse errorResponse) { super.onReceivedHttpError(view, request, errorResponse); // 捕获HTTP错误（如404, 500等） int statusCode = errorResponse.getStatusCode(); String description = errorResponse.getReasonPhrase(); Log.e("setWebViewClient", "statusCode:" + statusCode + ">>>>description:" + description); // 根据HTTP状态码处理错误 } @Override public void onPageFinished(WebView view, String url) { super.onPageFinished(view, url); //页面加载完成 webViewIsFinished = true; webFinishInitLocalData(); aginShowLocation(null); } }); } /** * web加载完初始化本地数据 */ public void webFinishInitLocalData() { //跳转中心点 centerPointBean = DaoSingleton.getInstance(MapFragment.this.getContext()).centerPointDao().findFirst(); jumpCenterPoint(); //添加因webview没有加载完成导致没有添加的地图标注 if (!webNoFinishMarkerData.isEmpty()) { for (MarkerBean bean : webNoFinishMarkerData) { setMapMarker(bean); } } if (!webNoFinishDivideData.isEmpty()) { for (DivideBean bean : webNoFinishDivideData) { setMapDivide(bean); } } //显示所有取水口 MarkerUtils.showLocoMarks(MapFragment.this); //显示巡检状态并且显示因意外关闭的历史数据 switch (mInspectionState) { case InspectionUtils.STAT_INSPECTION: case InspectionUtils.PAUSE_INSPECTION: InspectionUtils.aginShowLocation(MapFragment.this); } } /** * 获取取水口列表 */ private void getMarkerData() { ApiManager.getInstance().requestGetHideLoading(this.getContext(), Constants.BASE_URL + "/project/intake/all", MarkerListResult.class, null, new SubscriberListener>() { @Override public void onNext(BaseResponse t) { if (t.isSuccess()) { if (t.getContent().getObj() != null && !t.getContent().getObj().isEmpty()) { List markerBeans = t.getContent().getObj().stream() .map(result -> { MarkerBean markerBean = new MarkerBean(); markerBean.setId(result.getId()); markerBean.setLng(result.getLng()); markerBean.setLat(result.getLat()); markerBean.setBlockId(result.getBlockId()); markerBean.setName(result.getName()); markerBean.setRemarks(result.getRemarks()); markerBean.setTownId(result.getTownId()); markerBean.setVillageId(result.getVillageId()); markerBean.setCountyId(result.getCountyId()); markerBean.setAddress(result.getAddress()); markerBean.setBlockName(result.getBlockName()); markerBean.setDivideId(result.getDivideId()); setMapMarker(markerBean); return markerBean; }) .collect(Collectors.toList()); DaoSingleton.getInstance(MapFragment.this.getContext()).markerDao().deleteAll(); // 使用 RxJava 异步插入数据 DaoSingleton.getAsynchInstance(MapFragment.this.getContext()).markerDao().insertAll(markerBeans) .subscribeOn(Schedulers.io()) // 在 IO 线程上执行 .observeOn(AndroidSchedulers.mainThread()) // 在主线程上观察 .subscribe(() -> { // 插入成功 Log.i("mWebView", "数据插入成功"); }, throwable -> { // 插入失败 Log.e("mWebView", "数据插入失败: " + throwable.getMessage()); }); } } else { ToastUtil.showToast(MapFragment.this.getContext(), t.getMsg()); } } }); } void initView() { //巡检按钮 binding.inspectButton.setOnClickListener(v -> { if (XXPermissions.isGranted(MapFragment.this.getContext(), Permission.ACCESS_BACKGROUND_LOCATION)) { new ConfirmDialog(MapFragment.this.getActivity(), (confirmDialog, v1) -> { chageInspecState(InspectionUtils.STAT_INSPECTION_ONCLICK); confirmDialog.dismiss(); }).show(); } else { TipUtil.show(MapFragment.this.getActivity(), "巡检定位需要您选择\"始终允许\"定位信息，否则无法巡检。", new TipUtil.TipListener() { @Override public void onCancle() { getPermissions(); } }); } }); //暂停巡检 binding.inspectPause.setOnClickListener(v -> { if (mInspectionState == InspectionUtils.STAT_INSPECTION) { chageInspecState(InspectionUtils.PAUSE_INSPECTION); } else { chageInspecState(InspectionUtils.STAT_INSPECTION); } }); //停止巡检 binding.inspectClose.setOnClickListener(v -> { chageInspecState(InspectionUtils.STOP_INSPECTION); }); //上报问题 binding.putButton.setOnClickListener(v -> { Intent issue = new Intent(MapFragment.this.getActivity(), AddIssueActivity.class); MapFragment.this.getActivity().startActivity(issue); }); } /** * 显示取水口详情 * * @param data */ public void showWaterIntakeDetail(String data) { MyLog.i(data); MarkerBean markerBean = markerBeanSet.get(data); if (markerBean != null) { getInstakeDetail(markerBean); } } /** * 显示分水房详情 * * @param data */ public void showDivideDetail(String data) { MyLog.i(data); DivideBean markerBean = divideBeanMap.get(data); if (markerBean != null) { binding.bottomLL.setVisibility(View.GONE); getDivideDetail(markerBean); } } /** * 获取地图中心点 */ private void getCenterPoint() { ApiManager.getInstance().requestGetHideLoading(this.getContext(), Constants.BASE_URL + "/base/dict_item/map_center", CenterPointResult.class, null, new SubscriberListener>() { @Override public void onNext(BaseResponse t) { if (t.isSuccess()) { if (centerPointBean == null) { centerPointBean = new CenterPointBean(); } centerPointBean.setLat(t.getContent().getLat()); centerPointBean.setLng(t.getContent().getLng()); centerPointBean.setZoomMp(t.getContent().getZoomMp()); DaoSingleton.getInstance(MapFragment.this.getContext()).centerPointDao().insert(centerPointBean); jumpCenterPoint(); } else { ToastUtil.showToast(MapFragment.this.getContext(), t.getMsg()); } } }); } public void closeWaterIntakeDetail() { binding.bottomLL.setVisibility(View.GONE); } /** * 上报巡检记录 */ private void pushLocationData(InspectionLocationBean inspectionLocationBean) { InspectionRequest inspectionRequest = InspectionRequest.getInstance(); inspectionRequest.setInspectId(inspectionLocationBean.getInspectId()); inspectionRequest.setInspectorId(mInspectionBean.getInspectorId()); if (mInspectionBean != null) { inspectionRequest.setStartTime(mInspectionBean.getStartTime()); if (!TextUtils.isEmpty(mInspectionBean.getStopTime())) { inspectionRequest.setStopTime(mInspectionBean.getStopTime()); } } InspectionRequest.Track track = new InspectionRequest.Track(); track.setLat(inspectionLocationBean.getLat()); track.setLng(inspectionLocationBean.getLng()); track.setLocateTime(inspectionLocationBean.getLocateTime()); inspectionRequest.addTracks(track); ApiManager.getInstance().requestPostHideLoading(MapFragment.this.getContext(), BASE_URL + "/app/inspect/save", InsectionResult.class, inspectionRequest.toMap(inspectionRequest), new SubscriberListener>>() { @Override public void onNext(BaseResponse> t) { try { if (t.isSuccess()) { if (t.getContent() != null) { MyLog.d("InspectId:" + String.valueOf(t.getContent().get(0).getInspectId())); mInspectionBean.setInspectId(String.valueOf(t.getContent().get(0).getInspectId())); InspectionUtils.upataInspectionData(MapFragment.this.getContext(), mInspectionBean); } inspectionLocationBean.setPost(true); InspectionUtils.updateInspectionLocationData(MapFragment.this.getContext(), inspectionLocationBean); } else { } } catch (Exception e) { e.printStackTrace(); CrashReport.postCatchedException(e); } } }); } /** * 定位监听 */ private Observer locationObserver = new Observer() { @Override public void onChanged(Object o) { if (mInspectionBean != null) { LatLonBean latLonBean = (LatLonBean) o; if (InspectionUtils.isThanMinMeters(lastLatLonBean, latLonBean)) { //大于最小距离 lastLatLonBean = latLonBean; Log.i("chageInspecState", "lat:" + latLonBean.getLatitude() + ",log:" + latLonBean.getLongitude()); InspectionLocationBean inspectionLocationBean = InspectionUtils.createInspectionLocation(latLonBean, mInspectionBean); //添加巡检记录坐标 InspectionUtils.addInspectionLocationData(MapFragment.this.getContext(), inspectionLocationBean); //更新到地图 mWebView.evaluateJavascript("javascript:updateInspectionLocation(\"" + latLonBean.getLongitude() + "\",\"" + latLonBean.getLatitude() + "\")", value -> { }); mWebView.evaluateJavascript("javascript:updateLocation(\"" + latLonBean.getLongitude() + "\",\"" + latLonBean.getLatitude() + "\")", value -> { }); //上传坐标 pushLocationData(inspectionLocationBean); } else { Log.d(TAG, "isThanMinMeters>>>false"); } } } }; /** * 修改巡检状态 * * @param inspectionState */ private void chageInspecState(int inspectionState) { //0没有开始，1开始，2暂停,3关闭 switch (inspectionState) { case InspectionUtils.NO_INSPECTION: binding.inspectButton.setVisibility(View.VISIBLE); binding.inspectRL.setVisibility(View.GONE); binding.inspectButton.setText("巡"); LiveEventBus.get(CommonKeyName.locationData).removeObserver(locationObserver); //关闭定位 ServiceUtils.stopLocationService(MapFragment.this.getContext()); break; case InspectionUtils.STAT_INSPECTION_ONCLICK: //添加新的巡检记录 mInspectionBean = InspectionUtils.startInspection(this.getContext()); startLocation(); break; case InspectionUtils.STAT_INSPECTION://1开始 startLocation(); break; case InspectionUtils.PAUSE_INSPECTION://暂停 try { //关闭定位 ServiceUtils.stopLocationService(MapFragment.this.getContext()); binding.stateText.setText("已暂停巡检"); binding.inspectPause.setText("继续"); binding.inspectRL.setBackgroundColor(this.getContext().getResources().getColor(R.color.inspect_rl_bg_color)); SharedPreferencesHelper.getInstance(this.getContext()).put(CommonKeyName.inspectionState, InspectionUtils.PAUSE_INSPECTION); //清除地图巡检轨迹 mWebView.evaluateJavascript("javascript:cleanLoclLay()", value -> { }); } catch (Resources.NotFoundException e) { e.printStackTrace(); } break; case InspectionUtils.STOP_INSPECTION://关闭 ConfirmDialog confirmDialog = new ConfirmDialog(MapFragment.this.getActivity(), "提示", "确认关闭巡检吗？", new ConfirmDialog.ConfirmOnClickListener() { @Override public void onClick(ConfirmDialog confirmDialog, View v) { confirmDialog.dismiss(); chageInspecState(InspectionUtils.NO_INSPECTION); SharedPreferencesHelper.getInstance(MapFragment.this.getContext()).put(CommonKeyName.inspectionState, InspectionUtils.NO_INSPECTION); //有可能还没获取到定位信息就结束巡检了 if (lastLatLonBean != null) { //更新本地数据库结束时间 mInspectionBean.setStopTime(DateUtils.getNowDateStr()); InspectionUtils.upataInspectionData(MapFragment.this.getContext(), mInspectionBean); //上报结束时间 InspectionLocationBean inspectionLocationBean = InspectionUtils.createInspectionLocation(lastLatLonBean, mInspectionBean); InspectionUtils.addInspectionLocationData(MapFragment.this.getContext(), inspectionLocationBean); pushLocationData(inspectionLocationBean); mInspectionBean = new InspectionBean(); //清除地图巡检轨迹 mWebView.evaluateJavascript("javascript:cleanLocationLay()", value -> { }); lastLatLonBean = null; } } }); confirmDialog.show(); break; default: } mInspectionState = inspectionState; } /** * 意外退出后继续显示之前的坐标 */ public void aginShowLocation(List locationBeans) { if (locationBeans != null) { aginShowlocationBeans = locationBeans; } if (webViewIsFinished) { if (aginShowlocationBeans != null) { for (InspectionLocationBean inspectionLocationBean : aginShowlocationBeans) { Log.i("mWebView", "aginShowLocation" + inspectionLocationBean.getLng() + "\",\"" + inspectionLocationBean.getLat()); mWebView.evaluateJavascript("javascript:aginShowLocation(\"" + inspectionLocationBean.getLng() + "\",\"" + inspectionLocationBean.getLat() + "\")", value -> { }); } // 向 WebView 注入数据 aginShowlocationBeans.clear(); } } } /** * 跳转地图中心点 */ public void jumpCenterPoint() { if (webViewIsFinished) { if (centerPointBean != null) { Log.d(TAG, "jumpCenterPoint>>>>>>>>>>>>>>>>>>>" + centerPointBean.getLng() + "\",\"" + centerPointBean.getLat()); mWebView.evaluateJavascript("javascript:setCenterAndZoom(\"" + centerPointBean.getLng() + "\",\"" + centerPointBean.getLat() + "\",\"" + centerPointBean.getZoomMp() + "\")", value -> { }); } } } /** * 添加标注点 */ 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() { @Override public void onReceiveValue(String value) { } }); markerBeanSet.put(markerBean.getId(), markerBean); } else { MyLog.d("setMapMarker>" + markerBean.getName() + "经纬度为空"); } } else { webNoFinishMarkerData.add(markerBean); } } } /** * 添加取水口标注 */ 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() { @Override public void onReceiveValue(String value) { } }); divideBeanMap.put(divide.getId(), divide); } else { MyLog.d("setMapDivide>" + divide.getDivideName() + "经纬度为空"); } } else { webNoFinishDivideData.add(divide); } } } /** * 添加取水口标注 */ 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() { // @Override // public void onReceiveValue(String value) { // } // }); // divideBeanMap.put(divide.getId(), divide); // } else { // MyLog.d("setMapDivide>" + divide.getDivideName() + "经纬度为空"); // } // } else { // webNoFinishDivideData.add(divide); // } // } } /** * 开始巡检的相关逻辑 * * @param */ private void startLocation() { //获取定位服务传过来的坐标点 LiveEventBus.get(CommonKeyName.locationData).observe(this, locationObserver); binding.inspectRL.setVisibility(View.VISIBLE); binding.inspectButton.setVisibility(View.GONE); binding.inspectPause.setText("暂停"); binding.stateText.setText("已开启巡检"); binding.inspectRL.setBackgroundColor(this.getContext().getResources().getColor(R.color.base_blue)); SharedPreferencesHelper.getInstance(this.getContext()).put(CommonKeyName.inspectionState, InspectionUtils.STAT_INSPECTION); ServiceUtils.startLocationService(MapFragment.this.getContext(), false); } /** * 申请后台定位权限 */ private void getPermissions() { try { XXPermissions.with(MapFragment.this.getContext()) // 申请多个权限 .permission(Permission.ACCESS_BACKGROUND_LOCATION) .request(new OnPermissionCallback() { @Override public void onGranted(@NonNull List permissions, boolean allGranted) { if (allGranted) { chageInspecState(InspectionUtils.STAT_INSPECTION_ONCLICK); } } @Override public void onDenied(@NonNull List permissions, boolean doNotAskAgain) { if (doNotAskAgain) { // 如果是被永久拒绝就跳转到应用权限系统设置页面 TipUtil.show(MapFragment.this.getActivity(), "被永久拒绝授权，请手动授予定位始终允许权限!选择“权限”-->“位置信息”-->“始终允许”,然后返回应用。", new TipUtil.TipListener() { @Override public void onCancle() { XXPermissions.startPermissionActivity(MapFragment.this.getContext(), permissions); } }); } else { ToastUtil.showToastLong(MapFragment.this.getContext(), "获取定位始终允许权限失败"); } } }); } catch (Throwable e) { e.printStackTrace(); } } /** * 接收js传来的中心点坐标 * * @param lng * @param lat */ public void refreshCenterPoint(double lng, double lat) { centerLng = lng; centerLat = lat; binding.pointText.setText(centerLng + "，" + centerLat); } /** * 修改经纬度 * * @param markerBean */ private void updataInstake(MarkerBean markerBean) { String lng = String.valueOf(centerLng); String lat = String.valueOf(centerLat); Map params = new HashMap<>(); params.put("id", markerBean.getId()); params.put("lng", lng); params.put("lat", lat); params.put("operator", MyApplication.myApplication.userId); ApiManager.getInstance().requestPost(MapFragment.this.getContext(), BASE_URL + "/project/intake/updateIntakeLngLat", Boolean.class, params, new SubscriberListener>() { @Override public void onNext(BaseResponse t) { try { if (t.isSuccess()) { mWebView.evaluateJavascript("javascript:refreshMarker(\"" + markerBean.getId() + "\",\"" + centerLng + "\",\"" + centerLat + "\",\"" + markerBean.getName() + "\")", new ValueCallback() { @Override public void onReceiveValue(String value) { } }); binding.pointCenterImg.setVisibility(View.GONE); binding.pointRL.setVisibility(View.GONE); mMarkerBean.setLat(lat); mMarkerBean.setLng(lng); binding.lng.setText(lng); binding.lat.setText(lat); mWebView.evaluateJavascript("javascript:cancelPin()", value -> { }); ToastUtil.showToastLong(MapFragment.this.getContext(), "修改成功！"); } else { ToastUtil.showToastLong(MapFragment.this.getContext(), t.getMsg()); } } catch (Exception e) { e.printStackTrace(); CrashReport.postCatchedException(e); } } }); } /** * 获取取水口详情 * * @param markerBean */ private void getInstakeDetail(MarkerBean markerBean) { Map params = new HashMap<>(); params.put("id", markerBean.getId()); ApiManager.getInstance().requestGet(this.getContext(), Constants.BASE_URL + "/project/intake/one", MarkerResult.class, params, new SubscriberListener>() { @Override public void onNext(BaseResponse t) { if (t.isSuccess()) { MarkerResult result = t.getContent(); mMarkerBean = new MarkerBean(); mMarkerBean.setId(result.getId()); mMarkerBean.setLng(result.getLng()); mMarkerBean.setLat(result.getLat()); mMarkerBean.setBlockId(result.getBlockId()); mMarkerBean.setName(result.getName()); mMarkerBean.setRemarks(result.getRemarks()); mMarkerBean.setTownId(result.getTownId()); mMarkerBean.setVillageId(result.getVillageId()); mMarkerBean.setCountyId(result.getCountyId()); mMarkerBean.setAddress(result.getAddress()); mMarkerBean.setBlockName(result.getBlockName()); mMarkerBean.setDivideId(result.getDivideId()); showMarker(mMarkerBean); } else { ToastUtil.showToast(MapFragment.this.getContext(), t.getMsg()); } } }); } /** * 显示取水口详情 */ private void getDivideDetail(DivideBean divideBean) { ApiManager.getInstance().requestGet(this.getContext(), Constants.BASE_URL + "/project/divide/getone/" + divideBean.getDivideId(), DivideResult.class, null, new SubscriberListener>() { @Override public void onNext(BaseResponse t) { if (t.isSuccess()) { DivideBean divideBean = getDivideBean(t.getContent()); showDivideMarker(divideBean); } else { ToastUtil.showToast(MapFragment.this.getContext(), t.getMsg()); } } }); } /** * 显示取水口详情 */ private void showMarker(MarkerBean markerBean) { binding.bottomLL.setVisibility(View.VISIBLE); binding.phoneLL.setVisibility(View.GONE); binding.headerLL.setVisibility(View.GONE); binding.editePoint.setVisibility(View.VISIBLE); binding.markerAddress.setText(markerBean.getAddress()); binding.markerName.setText(markerBean.getName()); binding.markerBlockName.setText(markerBean.getBlockName()); binding.lat.setText(markerBean.getLat()); binding.lng.setText(markerBean.getLng()); //修改经纬度 binding.editePoint.setOnClickListener(v -> { mWebView.evaluateJavascript("javascript:showPin(\"" + markerBean.getLng() + "\",\"" + markerBean.getLat() + "\")", value -> { binding.pointRL.setVisibility(View.VISIBLE); binding.pointCenterImg.setVisibility(View.VISIBLE); MyLog.d("showPin>>" + value); }); }); //取消修改经纬度 binding.pointCancel.setOnClickListener(v -> { binding.pointCenterImg.setVisibility(View.GONE); binding.pointRL.setVisibility(View.GONE); mWebView.evaluateJavascript("javascript:cancelPin()", value -> { }); } ); //确认修改经纬度 binding.pointEdt.setOnClickListener(v -> { ConfirmDialog confirmDialog = new ConfirmDialog(MapFragment.this.getActivity(), "确认修改到该位置吗？", (confirmDialog1, v1) -> { confirmDialog1.dismiss(); updataInstake(markerBean); }); confirmDialog.show(); }); } /** * 显示分水房详情 * * @param divideBean */ private void showDivideMarker(DivideBean divideBean) { binding.bottomLL.setVisibility(View.VISIBLE); binding.phoneLL.setVisibility(View.VISIBLE); binding.headerLL.setVisibility(View.VISIBLE); binding.editePoint.setVisibility(View.GONE); binding.markerAddress.setText(divideBean.getAddress()); binding.markerName.setText(divideBean.getDivideName()); binding.markerBlockName.setText(divideBean.getBlockName()); binding.phone.setText(divideBean.getPhone()); binding.header.setText(divideBean.getHeader()); binding.lat.setText(divideBean.getLat()); binding.lng.setText(divideBean.getLng()); //修改经纬度 binding.editePoint.setOnClickListener(v -> { mWebView.evaluateJavascript("javascript:showPin(\"" + divideBean.getLng() + "\",\"" + divideBean.getLat() + "\")", value -> { binding.pointRL.setVisibility(View.VISIBLE); binding.pointCenterImg.setVisibility(View.VISIBLE); MyLog.d("showPin>>" + value); }); }); //取消修改经纬度 binding.pointCancel.setOnClickListener(v -> { binding.pointCenterImg.setVisibility(View.GONE); binding.pointRL.setVisibility(View.GONE); mWebView.evaluateJavascript("javascript:cancelPin()", value -> { }); } ); //确认修改经纬度 binding.pointEdt.setOnClickListener(v -> { ConfirmDialog confirmDialog = new ConfirmDialog(MapFragment.this.getActivity(), "确认修改到该位置吗？", (confirmDialog1, v1) -> { confirmDialog1.dismiss(); // updataInstake(markerBean); }); confirmDialog.show(); }); } /** * 获取分水房 */ private void getDivideList() { ApiManager.getInstance().requestGetHideLoading(MapFragment.this.getContext(), BASE_URL + "/project/divide/getDivides", DivideListResult.class, null, new SubscriberListener>() { @Override public void onNext(BaseResponse t) { try { if (t.isSuccess()) { if (t.getContent().getObj() != null && !t.getContent().getObj().isEmpty()) { List divideBeans = new ArrayList<>(); for (DivideResult divideResult : t.getContent().getObj()) { DivideBean divideBean = getDivideBean(divideResult); setMapDivide(divideBean); divideBeans.add(divideBean); } // 使用 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()); }); } } else { ToastUtil.showToastLong(MapFragment.this.getContext(), t.getMsg()); } } catch (Exception e) { e.printStackTrace(); CrashReport.postCatchedException(e); } } }); } /** * 获取管网 */ private void getPipeNetworkList() { ApiManager.getInstance().requestGetHideLoading(MapFragment.this.getContext(), BASE_URL + "/project/network/all", PipeNetworkListResult.class, null, new SubscriberListener>() { @Override public void onNext(BaseResponse t) { try { if (t.isSuccess()) { if (t.getContent().getObj() != null && !t.getContent().getObj().isEmpty()) { List divideBeans = new ArrayList<>(); for (PipeNetworkResult divideResult : t.getContent().getObj()) { PipeNetworkBean divideBean = getPipeNetworkBean(divideResult); setMapDivide(divideBean); // divideBeans.add(divideBean); } // 使用 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()); }); } } else { ToastUtil.showToastLong(MapFragment.this.getContext(), t.getMsg()); } } catch (Exception e) { e.printStackTrace(); CrashReport.postCatchedException(e); } } }); } /** * @param divideResult * @return */ private static @NonNull DivideBean getDivideBean(DivideResult divideResult) { DivideBean divideBean = new DivideBean(); divideBean.setAddress(divideResult.getAddress()); divideBean.setBlockId(divideResult.getBlockId()); divideBean.setBlockName(divideResult.getBlockName()); divideBean.setDivideId(divideResult.getDivideId()); if (!TextUtils.isEmpty(divideResult.getDivideName())) { divideBean.setDivideName(divideResult.getDivideName()); } else { divideBean.setDivideName(divideResult.getName()); } divideBean.setHeader(divideResult.getHeader()); divideBean.setId(divideResult.getId()); divideBean.setLat(divideResult.getLat()); divideBean.setLng(divideResult.getLng()); divideBean.setOperateDt(divideResult.getOperateDt()); divideBean.setOperator(divideResult.getOperator()); divideBean.setPhone(divideResult.getPhone()); divideBean.setRemarks(divideResult.getRemarks()); divideBean.setVillages(divideResult.getVillages()); divideBean.setArea(divideResult.getArea()); return divideBean; } private static @NonNull PipeNetworkBean getPipeNetworkBean(PipeNetworkResult divideResult) { PipeNetworkBean pipeNetworkBean = new PipeNetworkBean(); return pipeNetworkBean; } @Override public void onDestroy() { super.onDestroy(); LiveEventBus.get(CommonKeyName.locationData).removeObserver(locationObserver); if (mWebView != null) { mWebView.destroy(); } } @Override public void onResume() { super.onResume(); mWebView.onResume(); mWebView.resumeTimers(); } @Override public void onPause() { super.onPause(); mWebView.onPause(); mWebView.pauseTimers(); } @Override public void onSaveInstanceState(@NonNull Bundle outState) { super.onSaveInstanceState(outState); mWebView.saveState(outState); } @Override public void onViewStateRestored(@Nullable Bundle savedInstanceState) { super.onViewStateRestored(savedInstanceState); if (savedInstanceState != null) { mWebView.restoreState(savedInstanceState); } } }