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.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.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.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.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 kotlin.Triple;
|
import kotlin.Unit;
|
import kotlin.jvm.functions.Function1;
|
|
/**
|
* 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<InspectionLocationBean> aginShowlocationBeans;
|
//web加载时网页还没加载完时的数据
|
List<MarkerBean> webNoFinishMarkerData = new ArrayList<>();
|
List<DivideBean> webNoFinishDivideData = new ArrayList<>();
|
List<PipeNetworkBean> webNoFinishPipeNetworkData = new ArrayList<>();
|
//所有的Marker数据键为marker的Id
|
Map<String, MarkerBean> markerBeanSet = new HashMap<>();
|
//所有分水房
|
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) {
|
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);
|
|
// 添加刷新数据的监听
|
LiveEventBus.get(CommonKeyName.refreshData).observe(this, o -> {
|
getCenterPoint();
|
getMarkerData();
|
getDivideList();
|
getPipeNetworkList();
|
});
|
}
|
|
@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");
|
|
// 异步加载本地数据
|
loadLocalData();
|
|
initView();
|
initWeb();
|
|
chageInspecState(mInspectionState);
|
return binding.getRoot();
|
}
|
|
/**
|
* 异步加载本地数据
|
*/
|
private void loadLocalData() {
|
|
|
// 异步加载中心点数据
|
compositeDisposable.add(
|
DaoSingleton.getAsynchInstance(this.getContext()).centerPointDao().findFirst()
|
.subscribeOn(Schedulers.io())
|
.observeOn(AndroidSchedulers.mainThread())
|
.subscribe(result -> {
|
centerPointBean = result;
|
if (centerPointBean == null) {
|
getCenterPoint();
|
} else {
|
jumpCenterPoint();
|
}
|
}, throwable -> {
|
Log.e(TAG, "Load centerPoint error: " + throwable);
|
getCenterPoint();
|
}, () -> {
|
// 当Maybe为空时调用
|
getCenterPoint();
|
})
|
);
|
isShowMarker = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.markerKeyIsShow, true);
|
// 异步加载取水口数据
|
compositeDisposable.add(
|
DaoSingleton.getAsynchInstance(this.getContext()).markerDao().getAll()
|
.subscribeOn(Schedulers.io())
|
.observeOn(AndroidSchedulers.mainThread())
|
.subscribe(markers -> {
|
if (markers == null || markers.isEmpty()) {
|
getMarkerData();
|
} else {
|
for (MarkerBean marker : markers) {
|
markerBeanSet.put(marker.getId(), marker);
|
setMapMarker(marker);
|
}
|
}
|
}, throwable -> {
|
Log.e(TAG, "Load markers error: " + throwable.getMessage());
|
getMarkerData();
|
}, () -> {
|
// 当Maybe为空时调用
|
getMarkerData();
|
})
|
);
|
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();
|
}, () -> {
|
// 当Maybe为空时调用
|
getDivideList();
|
})
|
);
|
|
isShowPipeNetwork = SharedPreferencesHelper.getInstance(this.getContext()).get(CommonKeyName.pipeNetworkIsShow, true);
|
//异步加载管网数据
|
compositeDisposable.add(
|
DaoSingleton.getAsynchInstance(this.getContext()).pipeNetDao().getAll()
|
.subscribeOn(Schedulers.io())
|
.observeOn(AndroidSchedulers.mainThread())
|
.subscribe(pipeNetworkBeans -> {
|
if (pipeNetworkBeans == null || pipeNetworkBeans.isEmpty()) {
|
getPipeNetworkList();
|
} else {
|
for (PipeNetworkBean pipeNetworkBean : pipeNetworkBeans) {
|
setMapPipe(pipeNetworkBean);
|
}
|
}
|
}, throwable -> {
|
Log.e(TAG, "Load PipeNetworkBean error: " + throwable.getMessage());
|
getPipeNetworkList();
|
}, () -> {
|
// 当Maybe为空时调用
|
getPipeNetworkList();
|
})
|
);
|
}
|
|
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() {
|
// 只在本地没有数据时获取中心点
|
if (centerPointBean != null) {
|
jumpCenterPoint();
|
}
|
//添加因webview没有加载完成导致没有添加的地图标注
|
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);
|
}
|
}
|
|
/**
|
* 获取取水口列表
|
*/
|
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 {
|
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);
|
});
|
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;
|
});
|
}
|
|
|
/**
|
* 显示取水口详情
|
*
|
* @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<BaseResponse<CenterPointResult>>() {
|
@Override
|
public void onNext(BaseResponse<CenterPointResult> 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().deleteAll();
|
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<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);
|
}
|
|
}
|
});
|
}
|
|
/**
|
* 获取取水口详情
|
*
|
* @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());
|
}
|
}
|
|
});
|
}
|
|
/**
|
* 显示取水口详情
|
*/
|
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());
|
}
|
}
|
|
});
|
}
|
|
/**
|
* 显示取水口详情
|
*/
|
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 -> {
|
});
|
}
|
}
|
|
}
|
