[3.3.0][日志] 添加全量日志功能

core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/DevaToolsProvider.kt

@@ -20,6 +20,7 @@ import com.mogo.eagle.core.function.api.devatools.IDevaToolsProvider
 import com.mogo.eagle.core.function.api.devatools.apm.*
 import com.mogo.eagle.core.function.api.devatools.strict.*
 import com.mogo.eagle.core.function.api.devatools.download.*
+import com.mogo.eagle.core.function.api.devatools.logcat.*
 import com.mogo.eagle.core.function.api.devatools.mofang.*
 import com.mogo.eagle.core.function.api.lookaround.*
 import com.mogo.eagle.core.utilcode.mogo.logger.CallerLogger
@@ -43,6 +44,7 @@ import com.zhjt.mogo_core_function_devatools.env.EnvChangeManager
 import com.zhjt.mogo_core_function_devatools.funcconfig.FuncConfigCenter.Companion.bizConfigCenter
 import com.zhjt.mogo_core_function_devatools.funcconfig.FuncConfigImpl
 import com.zhjt.mogo_core_function_devatools.koom.KoomInitTask
+import com.zhjt.mogo_core_function_devatools.logcat.*
 import com.zhjt.mogo_core_function_devatools.logcatch.MogoLogCatchManager
 import com.zhjt.mogo_core_function_devatools.lookaround.*
 import com.zhjt.mogo_core_function_devatools.matrix.DynamicConfigImpl
@@ -79,6 +81,8 @@ class DevaToolsProvider : IDevaToolsProvider {
 
     private val mofangProvider by lazy { MoGoMoFangProviderImpl() }
 
+    private val logRecordProvider by lazy { MoGoLogRecordProviderImpl() }
+
     @Volatile
     private var mDockerVersion: String? = null
 
@@ -113,6 +117,11 @@ class DevaToolsProvider : IDevaToolsProvider {
         (mContext as? Application)?.also {
             mofangProvider.init(it)
         }
+
+        mContext?.also {
+            logRecordProvider.init(it)
+            logRecordProvider.start()
+        }
     }
 
     override fun checkMonitorDb() {
@@ -366,4 +375,6 @@ class DevaToolsProvider : IDevaToolsProvider {
     override fun lookAroundDataProvider(): IMoGoLookAroundProvider = lookAroundDataProvider
 
     override fun mofang(): IMoGoMoFangProvider = mofangProvider
+
+    override fun logRecord(): IMoGoLogRecordProvider = logRecordProvider
 }

core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/logcat/MoGoLogRecordProviderImpl.kt

@@ -0,0 +1,54 @@
+package com.zhjt.mogo_core_function_devatools.logcat
+
+import android.content.*
+import android.os.Process
+import android.util.*
+import com.mogo.core.log.record.*
+import com.mogo.core.log.record.config.*
+import com.mogo.eagle.core.function.api.devatools.logcat.*
+import com.mogo.eagle.core.utilcode.util.*
+import com.zhjt.mogo_core_function_devatools.logcat.uploader.*
+import kotlinx.coroutines.*
+import java.io.*
+import java.util.concurrent.TimeUnit.MINUTES
+import java.util.concurrent.atomic.AtomicBoolean
+
+internal class MoGoLogRecordProviderImpl: IMoGoLogRecordProvider {
+
+    private val flag by lazy { AtomicBoolean(false) }
+
+    private val scope by lazy { CoroutineScope(Dispatchers.IO + SupervisorJob()) }
+
+    override fun init(context: Context) {
+        LogcatManager.init(LogcatConfig.Builder().context(context)
+            .recordPeriod(MINUTES.toMillis(3))
+            .maxSizeInLogDir((1 * 1024 * 1024 * 1024).toLong()) //1G的最大容量
+            .recordDir(File(context.getExternalFilesDir(null), "logcat"))
+            .pid(Process.myPid())
+            .uploader(LogRecordUploader()))
+    }
+
+
+    override fun start() {
+        if (flag.get()) {
+            return
+        }
+        flag.set(true)
+        LogcatManager.start()
+    }
+
+    override fun stop() {
+        if (!flag.get()) {
+            return
+        }
+        flag.set(false)
+        LogcatManager.stop()
+    }
+
+    override fun upload(startTime: Long, endTime: Long) {
+        scope.launch {
+            val result = LogcatManager.upload(startTime, endTime)
+            Log.d(TAG, "上传日志:[startTime:$startTime, endTime: $endTime], 结果: $result")
+        }
+    }
+}

core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/logcat/uploader/LogRecordUploader.kt

@@ -0,0 +1,11 @@
+package com.zhjt.mogo_core_function_devatools.logcat.uploader
+
+import com.mogo.core.log.record.config.uploader.*
+import com.mogo.core.log.record.model.*
+
+internal class LogRecordUploader: ILogcatUploader {
+
+    override suspend fun upload(startTime: Long, endTime: Long, generatedZipPath: String): UploadState {
+        throw AssertionError("Not Implementation")
+    }
+}