fix: 错误日志上报没有clientId

app/src/main/java/com/emato/ich/MainActivity.java

@@ -309,7 +309,7 @@ public class MainActivity extends AppCompatActivity  {
         });
 
         // TODO 监听shell命令脚本
-        ichPublishClient.subscribe(ICHTopic.EXECUTE_SHELL_SCRIPT, (msgId, msg) -> {
+        ichPublishClient.subscribe(String.format(ICHTopic.EXECUTE_SHELL_SCRIPT, BaseUtils.getClientId()), (msgId, msg) -> {
             if (msg != null) {
                 try {
                     ShellVo shellVo = JacksonUtils.objectmapper.readValue(msg.getPayload(), ShellVo.class);
@@ -323,7 +323,7 @@ public class MainActivity extends AppCompatActivity  {
                     MqttMessage mqttMessage = new MqttMessage();
                     mqttMessage.setQos(1);
                     mqttMessage.setPayload(JacksonUtils.objectmapper.writeValueAsString(result).getBytes());
-                    ichPublishClient.publish(ICHTopic.EXECUTE_SHELL_SCRIPT_RESPONSE, mqttMessage);
+                    ichPublishClient.publish(String.format(ICHTopic.EXECUTE_SHELL_SCRIPT_RESPONSE, BaseUtils.getClientId()), mqttMessage);
                 } catch (Exception e) {
                     Log.e(TAG, "onCreate: 发送执行脚本结果失败! ", e);
                 }

app/src/main/java/com/emato/ich/crash/UncaughtExceptionHandlerImpl.java

@@ -17,6 +17,7 @@ import com.emato.ich.MainActivity;
 
 import com.emato.ich.message.ICHPublishClient;
 import com.emato.ich.message.ICHTopic;
+import com.emato.ich.utils.BaseUtils;
 
 import org.eclipse.paho.client.mqttv3.MqttMessage;
 
@@ -81,7 +82,7 @@ public class UncaughtExceptionHandlerImpl implements Thread.UncaughtExceptionHan
         MqttMessage mqttMessage = new MqttMessage();
         mqttMessage.setQos(1);
         mqttMessage.setPayload(getStackTrace(ex).toByteArray());
-        ICHPublishClient.getInstance().publish(ICHTopic.ERROR_LOG_REPORT, mqttMessage);
+        ICHPublishClient.getInstance().publish(String.format(ICHTopic.ERROR_LOG_REPORT, BaseUtils.getClientId()), mqttMessage);
 
         if (!this.handleException(ex) && this.mDefaultHandler != null) {
             this.mDefaultHandler.uncaughtException(thread, ex);
@@ -91,7 +92,7 @@ public class UncaughtExceptionHandlerImpl implements Thread.UncaughtExceptionHan
             } catch (InterruptedException var6) {
                 Log.e(TAG, "error 出现未知异常: ", var6);
                 mqttMessage.setPayload(getStackTrace(var6).toByteArray());
-                ICHPublishClient.getInstance().publish(ICHTopic.ERROR_LOG_REPORT, mqttMessage);
+                ICHPublishClient.getInstance().publish(String.format(ICHTopic.ERROR_LOG_REPORT, BaseUtils.getClientId()), mqttMessage);
             }
 
             if (this.mIsRestartApp) {