From 986648a7fc5d377d5c100ba41350e6313dcf6e5b Mon Sep 17 00:00:00 2001
From: zuoxiao <470321431@qq.com>
Date: 星期五, 21 二月 2025 17:04:29 +0800
Subject: [PATCH] 1.优化我的界面的更新本地数据功能添加loding 2.优化巡检详情页面增大放大级别 3.优化我的界面的更新本地数据功能所有接口都结束后显示数据更新成功

---
 app/src/main/java/com/dayu/pipirrapp/fragment/MapFragment.java | 1389 +++++++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 1,187 insertions(+), 202 deletions(-)

diff --git a/app/src/main/java/com/dayu/pipirrapp/fragment/MapFragment.java b/app/src/main/java/com/dayu/pipirrapp/fragment/MapFragment.java
index ebc3cd1..31e8b08 100644
--- a/app/src/main/java/com/dayu/pipirrapp/fragment/MapFragment.java
+++ b/app/src/main/java/com/dayu/pipirrapp/fragment/MapFragment.java
@@ -1,10 +1,12 @@
 package com.dayu.pipirrapp.fragment;
 
+import static com.dayu.pipirrapp.net.Constants.BASE_URL;
+
 import android.content.Context;
 import android.content.Intent;
-import android.location.LocationManager;
-import android.os.Build;
+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;
@@ -18,41 +20,72 @@
 
 import androidx.annotation.NonNull;
 import androidx.annotation.Nullable;
+import androidx.core.content.ContextCompat;
 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.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;
+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.PipeNetworkResult;
 import com.dayu.pipirrapp.dao.DaoSingleton;
 import com.dayu.pipirrapp.databinding.FragmentMapBinding;
-import com.dayu.pipirrapp.js.MyWebViewInterface;
 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.service.MyLocationService;
+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.SearchResultDialog;
+import com.dayu.pipirrapp.view.TipUtil;
+import com.example.expand_button.ExpandButton;
+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.Random;
+import java.util.Map;
+import java.util.stream.Collectors;
 
 import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
+import io.reactivex.rxjava3.disposables.CompositeDisposable;
 import io.reactivex.rxjava3.schedulers.Schedulers;
+import io.reactivex.rxjava3.core.Single;
 
 /**
  * author: zuo
@@ -64,14 +97,38 @@
     static String TAG = "MapFragment";
 
     FragmentMapBinding binding;
-    //瀹氫綅鐩稿叧
-    LocationManager locationManager;
 
     WebView mWebView;
     CenterPointBean centerPointBean;
-    String strMarkerJson;
-    boolean isStartInspec = false;
+    //褰撳墠宸℃鐘舵��
+    int mInspectionState;
     MapFragmenObserver mapFragmenObserver;
+    //褰撳墠宸℃璁板綍鐨勭浉鍏充俊鎭�
+    public InspectionBean mInspectionBean;
+    //鏈�鍚庝竴娆″畾浣嶇殑鍧愭爣
+    LatLonBean lastLatLonBean;
+    //web鏄惁鍔犺浇瀹屾垚
+    volatile boolean webViewIsFinished = false;
+    List<InspectionLocationBean> aginShowlocationBeans;
+    //web鍔犺浇鏃剁綉椤佃繕娌″姞杞藉畬鏃剁殑鏁版嵁
+    List<MarkerBean> webNoFinishMarkerData = new ArrayList<>();
+    List<DivideBean> webNoFinishDivideData = new ArrayList<>();
+    List<PipeNetworkBean> webNoFinishPipeNetworkData = new ArrayList<>();
+    //鎵�鏈夌殑Marker鏁版嵁閿负marker鐨処d
+    Map<String, MarkerBean> markerBeanSet = new HashMap<>();
+    //鎵�鏈夊垎姘存埧
+    Map<String, DivideBean> divideBeanMap = new HashMap<>();
+    //涓績鐐瑰潗鏍�
+    public double centerLng;
+    public double centerLat;
+
+    MarkerBean mMarkerBean;
+
+    //鏄惁鏄剧ずMarker
+    boolean isShowMarker, isShowPipeNetwork, isShowDivide;
+
+    // 娣诲姞CompositeDisposable鏉ョ鐞嗘墍鏈夎闃�
+    private CompositeDisposable compositeDisposable = new CompositeDisposable();
 
     @Override
     public void onAttach(@NonNull Context context) {
@@ -84,9 +141,62 @@
     @Override
     public void onCreate(@Nullable Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
+        setRetainInstance(true);
         Log.i(TAG, "onCreate");
-        isStartInspec = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.isStartInspec, false);
+        mInspectionState = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.inspectionState, 0);
 
+        // 娣诲姞鍒锋柊鏁版嵁鐨勭洃鍚�
+        LiveEventBus.get(CommonKeyName.refreshData).observe(this, o -> {
+            // 鏄剧ず鍔犺浇鍔ㄧ敾
+            TipUtil.showLoading(MapFragment.this.getActivity(), "姝e湪鏇存柊鏁版嵁...");
+            
+            // 鍒涘缓澶氫釜Single瀵硅薄鏉ヨ〃绀烘瘡涓綉缁滆姹�
+            Single<Boolean> centerPointSingle = Single.create(emitter -> {
+                getCenterPoint();
+                emitter.onSuccess(true);
+            });
+
+            Single<Boolean> markerDataSingle = Single.create(emitter -> {
+                getMarkerData();
+                emitter.onSuccess(true);
+            });
+
+            Single<Boolean> divideListSingle = Single.create(emitter -> {
+                getDivideList();
+                emitter.onSuccess(true);
+            });
+
+            Single<Boolean> pipeNetworkListSingle = Single.create(emitter -> {
+                getPipeNetworkList();
+                emitter.onSuccess(true);
+            });
+
+            // 缁勫悎鎵�鏈塖ingle
+            compositeDisposable.add(
+                Single.zip(
+                    centerPointSingle,
+                    markerDataSingle, 
+                    divideListSingle,
+                    pipeNetworkListSingle,
+                    (centerPoint, marker, divide, pipe) -> true
+                )
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread())
+                .doFinally(() -> {
+                    // 鏃犺鎴愬姛杩樻槸澶辫触锛岄兘闇�瑕侀殣钘忓姞杞藉姩鐢�
+                    TipUtil.dismissLoading();
+                })
+                .subscribe(
+                    result -> {
+                        ToastUtil.showToast(MapFragment.this.getContext(), "鏁版嵁鏇存柊瀹屾垚");
+                    },
+                    throwable -> {
+                        Log.e(TAG, "鏁版嵁鏇存柊澶辫触: " + throwable.getMessage());
+                        ToastUtil.showToast(MapFragment.this.getContext(), "鏁版嵁鏇存柊澶辫触");
+                    }
+                )
+            );
+        });
     }
 
     @Override
@@ -95,44 +205,10 @@
         Log.i(TAG, "onStart");
     }
 
-    /**
-     * 淇敼宸℃鐘舵��
-     */
-    private void chageInspecState() {
-        Intent location = new Intent(this.getActivity(), MyLocationService.class);
-        location.putExtra("isSingle", false);
-        if (isStartInspec) {
-            //鑾峰彇瀹氫綅鏈嶅姟浼犺繃鏉ョ殑鍧愭爣鐐�
-            LiveEventBus.get(CommonKeyName.locationData).observeForever(new Observer<Object>() {
-                @Override
-                public void onChanged(Object o) {
-                    LatLonBean latLonBean = (LatLonBean) o;
-                    mWebView.evaluateJavascript("javascript:updateLocation(\"" +  latLonBean.getLatitude()+ "\",\"" +  latLonBean.getLongitude()+ "\")", value -> {
-                    });
-                }
-            });
-            binding.stateText.setVisibility(View.VISIBLE);
-            binding.inspectButton.setText("缁�");
-            //寮�鍚畾浣�
-            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
-                this.getActivity().startForegroundService(location);
-            } else {
-                this.getActivity().startService(location);
-            }
-        } else {
-            binding.stateText.setVisibility(View.GONE);
-            binding.inspectButton.setText("宸�");
-            //鍏抽棴瀹氫綅
-            this.getActivity().stopService(location);
-
-        }
-    }
-
 
     @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");
@@ -141,166 +217,126 @@
         MyWebViewInterface myWebViewInterface = new MyWebViewInterface(MapFragment.this);
         mWebView.addJavascriptInterface(myWebViewInterface, "Android");
         mWebView.loadUrl("file:///android_asset/index.html");
-        getCenterPoint();
+
+        // 寮傛鍔犺浇鏈湴鏁版嵁
+        loadLocalData();
+
         initView();
-        initLocalData();
-        getMarkerData();
-        //鏄剧ず宸℃鐘舵��
-        chageInspecState();
+        initWeb();
+
+        chageInspecState(mInspectionState);
         return binding.getRoot();
     }
 
-
     /**
-     * 鍒濆鍖栧悇涓姸鎬�
+     * 寮傛鍔犺浇鏈湴鏁版嵁
      */
-    private void initState() {
-        //寮�鍚畾浣�
-
-    }
-
-    /**
-     * 鍒濆鍖栨湰鍦版暟鎹�
-     */
-    public void initLocalData() {
-        centerPointBean = DaoSingleton.getInstance(MapFragment.this.getContext()).centerPointDao().findFirst();
-        List<MarkerBean> markerBeans = DaoSingleton.getInstance(MapFragment.this.getContext()).markerDao().findAll();
-        strMarkerJson = WebViewUtils.beanToJson(markerBeans);
-        jumpCenterPoint();
-        setMapMarker();
-    }
+    private void loadLocalData() {
 
 
-    /**
-     * 璺宠浆鍦板浘涓績鐐�
-     */
-    public void jumpCenterPoint() {
-        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() {
-        Log.i("mWebView", "addMarker????????????" + strMarkerJson);
-        mWebView.evaluateJavascript("javascript:addMarker(\"" + strMarkerJson + "\")", new ValueCallback<String>() {
-            @Override
-            public void onReceiveValue(String value) {
-                Log.i("mWebView", "addMarker锛侊紒锛侊紒锛侊紒锛侊紒锛�" + value);
-            }
-        });
-    }
-
-
-    /**
-     * 鑾峰彇鍙栨按鍙e垪琛�
-     */
-    private void getMarkerData() {
-        ApiManager.getInstance().requestGetHideLoading(this.getContext(), Constants.BASE_URL + ":8085/project/intake/all", MarkerResult.class, null, new SubscriberListener<BaseResponse<MarkerResult>>() {
-            @Override
-            public void onNext(BaseResponse<MarkerResult> t) {
-                if (t.isSuccess()) {
-                    if (t.isSuccess()) {
-                        if (t.getContent().getObj() != null && !t.getContent().getObj().isEmpty()) {
-                            List<MarkerBean> markerBeans = new ArrayList<>();
-                            for (int i = 0; i < t.getContent().getObj().size(); i++) {
-                                MarkerResult.Obj result = t.getContent().getObj().get(i);
-                                //淇濆瓨鏁版嵁
-                                MarkerBean markerBean = new MarkerBean();
-                                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());
-                                markerBeans.add(markerBean);
+        // 寮傛鍔犺浇涓績鐐规暟鎹�
+        compositeDisposable.add(
+                DaoSingleton.getAsynchInstance(this.getContext()).centerPointDao().findFirst()
+                        .subscribeOn(Schedulers.io())
+                        .observeOn(AndroidSchedulers.mainThread())
+                        .subscribe(result -> {
+                            centerPointBean = result;
+                            if (centerPointBean == null) {
+                                getCenterPoint();
+                            } else {
+                                jumpCenterPoint();
                             }
-                            strMarkerJson = WebViewUtils.beanToJson(markerBeans);
-                            setMapMarker();
-                            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());
-                }
-            }
+                        }, throwable -> {
+                            Log.e(TAG, "Load centerPoint error: " + throwable);
+                            getCenterPoint();
+                        }, () -> {
+                            // 褰揗aybe涓虹┖鏃惰皟鐢�
+                            getCenterPoint();
+                        })
+        );
+        isShowMarker = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.markerKeyIsShow, true);
+        // 寮傛鍔犺浇鍙栨按鍙f暟鎹�
+        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();
+                        }, () -> {
+                            // 褰揗aybe涓虹┖鏃惰皟鐢�
+                            getMarkerData();
+                        })
+        );
+        isShowDivide = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.divideIsShow, true);
+        // 寮傛鍔犺浇鍒嗘按鎴挎暟鎹�
+        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();
+                        }, () -> {
+                            // 褰揗aybe涓虹┖鏃惰皟鐢�
+                            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();
+                        }, () -> {
+                            // 褰揗aybe涓虹┖鏃惰皟鐢�
+                            getPipeNetworkList();
+                        })
+        );
     }
 
-
-    /**
-     * 娣诲姞鏍囨敞鐐�
-     */
-    public void addMarker() {
-        Random random = new Random();
-        StringBuilder stringBuilder = new StringBuilder();
-        stringBuilder.append("[");
-
-        // 涓浗缁忕含搴﹁寖鍥�
-        double minLongitude = 73.43;
-        double maxLongitude = 135.05;
-        double minLatitude = 3.52;
-        double maxLatitude = 53.57;
-
-        for (int i = 0; i < 1000; i++) {
-            stringBuilder.append("[");
-            // 鐢熸垚闅忔満缁忓害
-            double longitude = minLongitude + (maxLongitude - minLongitude) * random.nextDouble();
-            stringBuilder.append(longitude);
-            stringBuilder.append(",");
-            // 鐢熸垚闅忔満绾害
-            double latitude = minLatitude + (maxLatitude - minLatitude) * random.nextDouble();
-            stringBuilder.append(latitude);
-            stringBuilder.append(",\"237鍙栨按鍙"],");
-        }
-        stringBuilder.append("[116.417854,39.921988,\"235鍙栨按鍙"]]");
-        String jsonData = stringBuilder.toString().replace("\\", "\\\\").replace("\"", "\\\"");
-        Log.i("mWebView", "addMarker????????????" + jsonData);
-        mWebView.evaluateJavascript("javascript:addMarker(\"" + jsonData + "\")", new ValueCallback<String>() {
-            @Override
-            public void onReceiveValue(String value) {
-                Log.i("mWebView", "addMarker锛侊紒锛侊紒锛侊紒锛侊紒锛�" + value);
-            }
-        });
-    }
-
-
-    void initView() {
-        //璺宠浆鍒版寚瀹氫綅缃�
-        binding.flyBtn.setOnClickListener(v -> {
-            mWebView.evaluateJavascript("javascript:locationOverLay(116.399565,39.89432)", value -> {
-            });
-        });
+    private void initWeb() {
         mWebView.setWebViewClient(new WebViewClient() {
             @Override
             public WebResourceResponse shouldInterceptRequest(WebView view, WebResourceRequest request) {
                 String url = request.getUrl().toString();
-                Log.i(TAG, "鍔犺浇鍦板潃>>>" + url);
                 //鍒ゆ柇褰撳墠鏄惁涓哄姞杞界摝鐗�
                 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.i(TAG, "鏈湴缂撳瓨>>>" + androidUrl);
+//                        Log.d(TAG, "鏈湴缂撳瓨>>>" + androidUrl);
 //                        if (MapJpgUtils.getInsatance().validateImageFile(androidUrl,request.))
                         // 鍒ゆ柇缂撳瓨鏄惁杩囨湡
 //                    if (!MapJpgUtils.getInsatance(MapFragment.this.getContext()).isCacheExpired(cachedTile)) {
@@ -313,9 +349,9 @@
 //                    }
                     } else {
                         //涓嬭浇鐡︾墖
-                        ApiManager.getInstance().donwLoadTile(androidUrl);
+                        ApiManager.getInstance().donwLoadTile(MapFragment.this.getContext(), androidUrl);
                     }
-                    Log.i(TAG, "鍦ㄧ嚎鍔犺浇>>>" + url);
+
                 }
 
 
@@ -331,7 +367,6 @@
                 String failingUrl = request.getUrl().toString();
                 Log.e("setWebViewClient", "errorCode:" + errorCode + ">>>>description:" + description + ">>>>failingUrl:" + failingUrl);
                 // 澶勭悊閿欒锛屼緥濡傛樉绀洪敊璇〉闈㈡垨鎻愮ず鐢ㄦ埛
-                // view.loadUrl("file:///android_asset/error.html");
             }
 
             @Override
@@ -343,38 +378,264 @@
                 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);
+
+            }
         });
-        //宸℃鎸夐挳
-        binding.inspectButton.setOnClickListener(v -> {
-            if (isStartInspec){
-                ConfirmDialog confirmDialog=new ConfirmDialog(MapFragment.this.getActivity(), "鎻愮ず", "纭鍏抽棴宸℃鍚楋紵", new View.OnClickListener() {
-                    @Override
-                    public void onClick(View v) {
-                        isStartInspec = !isStartInspec;
-                        chageInspecState();
+    }
+
+    /**
+     * web鍔犺浇瀹屽垵濮嬪寲鏈湴鏁版嵁
+     */
+    public void webFinishInitLocalData() {
+        // 鍙湪鏈湴娌℃湁鏁版嵁鏃惰幏鍙栦腑蹇冪偣
+        if (centerPointBean != null) {
+            jumpCenterPoint();
+        }
+        //娣诲姞鍥爓ebview娌℃湁鍔犺浇瀹屾垚瀵艰嚧娌℃湁娣诲姞鐨勫湴鍥炬爣娉�
+        if (!webNoFinishMarkerData.isEmpty()) {
+            for (MarkerBean bean : webNoFinishMarkerData) {
+                setMapMarker(bean);
+            }
+        }
+        if (!webNoFinishDivideData.isEmpty()) {
+            for (DivideBean bean : webNoFinishDivideData) {
+                setMapDivide(bean);
+            }
+        }
+        if (!webNoFinishPipeNetworkData.isEmpty()) {
+            for (PipeNetworkBean bean : webNoFinishPipeNetworkData) {
+                setMapPipe(bean);
+            }
+        }
+
+        //鏄剧ず鎵�鏈夊彇姘村彛
+        MarkerUtils.showLocoMarks(MapFragment.this);
+        //鏄剧ず宸℃鐘舵�佸苟涓旀樉绀哄洜鎰忓鍏抽棴鐨勫巻鍙叉暟鎹�
+        switch (mInspectionState) {
+            case InspectionUtils.STAT_INSPECTION:
+            case InspectionUtils.PAUSE_INSPECTION:
+                InspectionUtils.aginShowLocation(MapFragment.this);
+        }
+    }
+
+    /**
+     * 鑾峰彇鍙栨按鍙e垪琛�
+     */
+    private void getMarkerData() {
+        ApiManager.getInstance().requestGetHideLoading(this.getContext(), Constants.BASE_URL + "/project/intake/all", MarkerListResult.class, null, new SubscriberListener<BaseResponse<MarkerListResult>>() {
+            @Override
+            public void onNext(BaseResponse<MarkerListResult> t) {
+                if (t.isSuccess()) {
+                    if (t.getContent().getObj() != null && !t.getContent().getObj().isEmpty()) {
+                        List<MarkerBean> 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();
+                        // 浣跨敤 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());
+                                                }
+                                        )
+                        );
                     }
-                });
-            }else {
-                isStartInspec = !isStartInspec;
-                chageInspecState();
+
+                } else {
+                    ToastUtil.showToast(MapFragment.this.getContext(), t.getMsg());
+                }
             }
 
         });
     }
 
 
-    public void showWaterIntakeDetail(String data) {
-        MyLog.i(data);
-        binding.bottomLL.setVisibility(View.VISIBLE);
+    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);
+        });
+        binding.expandButton.setLegendsArray(new ExpandButton.Quadruple(
+                        ContextCompat.getDrawable(requireContext(), R.drawable.marker_blue),
+                        ContextCompat.getDrawable(requireContext(), R.drawable.marker_unselected),
+                        "鍙栨按鍙�", isShowMarker
+                ),
+                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;
+        });
     }
 
+
+    /**
+     * 鏄剧ず鍙栨按鍙h鎯�
+     *
+     * @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().requestGet(this.getContext(), Constants.BASE_URL + ":8080/base/dict_item/map_center", CenterPointResult.class, null, new SubscriberListener<BaseResponse<CenterPointResult>>() {
+        ApiManager.getInstance().requestGetHideLoading(this.getContext(), Constants.BASE_URL + "/base/dict_item/map_center", CenterPointResult.class, null, new SubscriberListener<BaseResponse<CenterPointResult>>() {
             @Override
             public void onNext(BaseResponse<CenterPointResult> t) {
                 if (t.isSuccess()) {
@@ -384,6 +645,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 {
@@ -398,5 +660,728 @@
         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<BaseResponse<List<InsectionResult>>>() {
+            @Override
+            public void onNext(BaseResponse<List<InsectionResult>> 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<Object> locationObserver = new Observer<Object>() {
+        @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<InspectionLocationBean> 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() + "\",\"" + isShowMarker + "\")", new ValueCallback<String>() {
+                        @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() + "\",\"" + isShowDivide + "\")", 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);
+            }
+        }
+    }
+
+    /**
+     * 寮�濮嬪贰妫�鐨勭浉鍏抽�昏緫
+     *
+     * @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<String> permissions, boolean allGranted) {
+                            if (allGranted) {
+                                chageInspecState(InspectionUtils.STAT_INSPECTION_ONCLICK);
+                            }
+                        }
+
+                        @Override
+                        public void onDenied(@NonNull List<String> 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<String, Object> 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<BaseResponse<Boolean>>() {
+            @Override
+            public void onNext(BaseResponse<Boolean> t) {
+                try {
+                    if (t.isSuccess()) {
+                        mWebView.evaluateJavascript("javascript:refreshMarker(\"" + markerBean.getId() + "\",\"" + centerLng + "\",\"" + centerLat + "\",\"" + markerBean.getName() + "\")", new ValueCallback<String>() {
+                            @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);
+                }
+
+            }
+        });
+    }
+
+    /**
+     * 鑾峰彇鍙栨按鍙h鎯�
+     *
+     * @param markerBean
+     */
+    private void getInstakeDetail(MarkerBean markerBean) {
+        Map<String, Object> params = new HashMap<>();
+        params.put("id", markerBean.getId());
+        ApiManager.getInstance().requestGet(this.getContext(), Constants.BASE_URL + "/project/intake/one", MarkerResult.class, params, new SubscriberListener<BaseResponse<MarkerResult>>() {
+            @Override
+            public void onNext(BaseResponse<MarkerResult> 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());
+                }
+            }
+
+        });
+    }
+
+    /**
+     * 鏄剧ず鍙栨按鍙h鎯�
+     */
+    private void getDivideDetail(DivideBean divideBean) {
+        ApiManager.getInstance().requestGet(this.getContext(), Constants.BASE_URL + "/project/divide/getone/" + divideBean.getDivideId(), DivideResult.class, null, new SubscriberListener<BaseResponse<DivideResult>>() {
+            @Override
+            public void onNext(BaseResponse<DivideResult> t) {
+                if (t.isSuccess()) {
+                    DivideBean divideBean = getDivideBean(t.getContent());
+                    showDivideMarker(divideBean);
+                } else {
+                    ToastUtil.showToast(MapFragment.this.getContext(), t.getMsg());
+                }
+            }
+
+        });
+    }
+
+    /**
+     * 鏄剧ず鍙栨按鍙h鎯�
+     */
+    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<BaseResponse<DivideListResult>>() {
+            @Override
+            public void onNext(BaseResponse<DivideListResult> t) {
+                try {
+                    if (t.isSuccess()) {
+                        if (t.getContent().getObj() != null && !t.getContent().getObj().isEmpty()) {
+                            List<DivideBean> divideBeans = new ArrayList<>();
+                            for (DivideResult divideResult : t.getContent().getObj()) {
+                                DivideBean divideBean = getDivideBean(divideResult);
+                                setMapDivide(divideBean);
+                                divideBeans.add(divideBean);
+                            }
+                            DaoSingleton.getInstance(MapFragment.this.getContext()).divideDao().deleteAll();
+                            // 浣跨敤 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());
+                                                    }
+                                            )
+                            );
+                        }
+                    } 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", PipeNetworkResult.class, null, new SubscriberListener<BaseResponse<List<PipeNetworkResult>>>() {
+            @Override
+            public void onNext(BaseResponse<List<PipeNetworkResult>> t) {
+                try {
+                    if (t.isSuccess()) {
+                        if (t.getContent() != null && t.getContent().size() > 0) {
+
+                            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 寮傛鎻掑叆鏁版嵁
+                            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());
+                                            })
+                            );
+                        }
+
+
+                    } 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();
+        // 娓呯悊鎵�鏈夎闃�
+        if (compositeDisposable != null && !compositeDisposable.isDisposed()) {
+            compositeDisposable.dispose();
+        }
+        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);
+        }
+    }
+
+    /**
+     * 鏄剧ず鎴栭殣钘忓湴鍥句笂鐨勫彇姘村彛
+     *
+     * @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 -> {
+            });
+        }
+    }
+
+    private void showPipeLine(boolean isSelected) {
+        if (isSelected) {
+            mWebView.evaluateJavascript("javascript:showAllPipeLines()", value -> {
+            });
+        } else {
+            mWebView.evaluateJavascript("javascript:hideAllPipeLines()", value -> {
+            });
+        }
+    }
 
 }

--
Gitblit v1.8.0