增加轨迹存储业务

app/src/main/java/com/navinfo/omqs/db/TraceDataBase.java

@@ -94,10 +94,7 @@ public abstract class TraceDataBase extends RoomDatabase {
      */
     private static class PopulateDbAsync extends AsyncTask<Void, Void, Void> {
 
-        private final ILayerManagerDao mLayerDao;
-
         PopulateDbAsync(TraceDataBase db) {
-            mLayerDao = db.getLayerManagerDao();
         }
 
         @Override

app/src/main/java/com/navinfo/omqs/ui/activity/map/MainActivity.kt

@@ -1,6 +1,7 @@
 package com.navinfo.omqs.ui.activity.map
 
 import android.os.Bundle
+import android.util.Log
 import androidx.activity.viewModels
 import androidx.core.view.WindowCompat
 import androidx.databinding.DataBindingUtil
@@ -9,6 +10,7 @@ import androidx.lifecycle.lifecycleScope
 import androidx.lifecycle.viewModelScope
 import androidx.navigation.findNavController
 import com.navinfo.collect.library.map.NIMapController
+import com.navinfo.collect.library.map.handler.NiLocationListener
 import com.navinfo.omqs.Constant
 import com.navinfo.omqs.R
 import com.navinfo.omqs.databinding.ActivityMainBinding
@@ -55,8 +57,6 @@ class MainActivity : BaseActivity() {
         binding.viewModel = viewModel
 //        lifecycle.addObserver(viewModel)
         lifecycleScope
-        //初始化轨迹文件
-        TraceDataBase.getDatabase(this,Constant.DATA_PATH+SystemConstant.USER_ID+"/trace.sqlite")
     }
 
     override fun onStart() {
@@ -64,6 +64,13 @@ class MainActivity : BaseActivity() {
 
         //开启定位
         mapController.locationLayerHandler.startLocation()
+        //启动轨迹存储
+        mapController.locationLayerHandler.setNiLocationListener(NiLocationListener {
+            binding!!.viewModel!!.addSaveTrace(it)
+            binding!!.viewModel!!.startSaveTraceThread(this)
+        })
+        //显示轨迹图层
+        mapController.layerManagerHandler.showNiLocationLayer(Constant.DATA_PATH+ SystemConstant.USER_ID+"/trace.sqlite")
     }
 
     override fun onPause() {

app/src/main/java/com/navinfo/omqs/ui/activity/map/MainViewModel.kt

@@ -3,15 +3,22 @@ package com.navinfo.omqs.ui.activity.map
 import android.content.Context
 import android.content.DialogInterface
 import android.util.Log
-import android.view.View
 import androidx.lifecycle.ViewModel
 import com.blankj.utilcode.util.ToastUtils
+import com.navinfo.collect.library.data.entity.NiLocation
 import com.navinfo.collect.library.map.NIMapController
-import org.videolan.libvlc.LibVlcUtil
+import com.navinfo.collect.library.utils.GeometryTools
+import com.navinfo.collect.library.utils.GeometryToolsKt
+import com.navinfo.omqs.Constant
 import com.navinfo.omqs.R
+import com.navinfo.omqs.db.TraceDataBase
+import com.navinfo.omqs.system.SystemConstant
 import com.navinfo.omqs.ui.dialog.CommonDialog
 import com.navinfo.omqs.ui.manager.TakePhotoManager
 import dagger.hilt.android.lifecycle.HiltViewModel
+import io.realm.RealmSet
+import org.videolan.libvlc.LibVlcUtil
+import java.util.*
 import javax.inject.Inject
 
 /**
@@ -24,6 +31,8 @@ class MainViewModel @Inject constructor(
 
     private var mCameraDialog: CommonDialog? = null
 
+    private var niLocationList:MutableList<NiLocation> = ArrayList<NiLocation>()
+
     /**
      * 点击我的位置，回到我的位置
      */
@@ -66,4 +75,49 @@ class MainViewModel @Inject constructor(
             }
         })
     }
+
+    fun startSaveTraceThread(context: Context){
+        Thread(Runnable {
+            try {
+                while (true){
+
+                    if(niLocationList!=null&&niLocationList.size>0){
+
+                        var niLocation = niLocationList[0]
+                        var doubleArray = doubleArrayOf()
+                        doubleArray[0] = niLocation.longitude
+                        doubleArray[1] = niLocation.latitude
+                        val geometry = GeometryTools.createGeometry(doubleArray)
+                        val tileX = RealmSet<Int>()
+                        GeometryToolsKt.getTileXByGeometry(geometry.toString(), tileX)
+                        val tileY = RealmSet<Int>()
+                        GeometryToolsKt.getTileYByGeometry(geometry.toString(), tileY)
+
+                        //遍历存储tile对应的x与y的值
+                        tileX.forEach { x ->
+                            tileY.forEach { y ->
+                                niLocation.tilex = x
+                                niLocation.tiley = y
+                            }
+                        }
+
+                        TraceDataBase.getDatabase(context, Constant.DATA_PATH+ SystemConstant.USER_ID+"/trace.sqlite").niLocationDao.insert(niLocation)
+                        niLocationList.removeAt(0)
+                        Log.e("qj","saveTrace")
+                    }
+                    Thread.sleep(30)
+                }
+            } catch (e: InterruptedException) {
+                e.printStackTrace()
+                Log.e("qj","异常==${e.message}")
+            }
+        }).start()
+    }
+
+    //增加轨迹存储
+    fun addSaveTrace(niLocation: NiLocation){
+        if(niLocation!=null&&niLocationList!=null){
+            niLocationList.add(niLocation)
+        }
+    }
 }