第一个版本的客户端
This commit is contained in:
288
app/src/main/java/com/example/flomo_ai/MainActivity.kt
Normal file
288
app/src/main/java/com/example/flomo_ai/MainActivity.kt
Normal file
@@ -0,0 +1,288 @@
|
||||
package com.example.flomo_ai
|
||||
|
||||
import android.content.Intent
|
||||
import android.os.Bundle
|
||||
import android.view.Gravity
|
||||
import android.widget.Button
|
||||
import android.widget.EditText
|
||||
import android.widget.TextView
|
||||
|
||||
import androidx.appcompat.app.AppCompatActivity
|
||||
import com.google.android.material.tabs.TabLayout
|
||||
import com.google.gson.Gson
|
||||
import kotlinx.coroutines.CoroutineScope
|
||||
import kotlinx.coroutines.Dispatchers
|
||||
import kotlinx.coroutines.launch
|
||||
import kotlinx.coroutines.withContext
|
||||
|
||||
import okhttp3.Interceptor
|
||||
import okhttp3.OkHttpClient
|
||||
import okhttp3.Request
|
||||
import okhttp3.Response
|
||||
import okhttp3.RequestBody.Companion.toRequestBody
|
||||
import com.google.gson.JsonObject
|
||||
import okhttp3.MediaType.Companion.toMediaType
|
||||
|
||||
import com.google.gson.reflect.TypeToken
|
||||
import android.util.Log
|
||||
import java.io.IOException
|
||||
import java.net.UnknownHostException
|
||||
import org.json.JSONObject
|
||||
|
||||
import com.squareup.moshi.Moshi
|
||||
import com.squareup.moshi.kotlin.reflect.KotlinJsonAdapterFactory
|
||||
|
||||
// 定义请求体数据类
|
||||
data class ChatRequest(
|
||||
val model: String,
|
||||
val messages: List<Message>
|
||||
)
|
||||
|
||||
data class Message(
|
||||
val role: String,
|
||||
val content: String
|
||||
)
|
||||
|
||||
|
||||
// 从返回的 JSON 响应中提取标签列表
|
||||
fun extractLabels(responseBody: String): List<String>? {
|
||||
try {
|
||||
// 假设 responseBody 中包含一个完整的 JSON 对象，我们需要先提取出其中的 content 部分
|
||||
val fullJsonObject = Gson().fromJson(responseBody, JsonObject::class.java)
|
||||
val choicesArray = fullJsonObject.getAsJsonArray("choices")
|
||||
if (choicesArray.size() > 0) {
|
||||
val firstChoice = choicesArray.get(0).asJsonObject
|
||||
val messageObject = firstChoice.get("message").asJsonObject
|
||||
val content = messageObject.get("content").asString
|
||||
// 从 content 中提取出 labels
|
||||
val startIndex = content.indexOf("\"labels\": [") + "\"labels\": [".length
|
||||
val endIndex = content.indexOf("]", startIndex)
|
||||
val labelsStr = content.substring(startIndex, endIndex)
|
||||
// 处理引号
|
||||
//val processedLabelsStr = labelsStr.replace("\"", "")
|
||||
val labels = labelsStr.split("\", \"")
|
||||
val processedLabels = mutableListOf<String>()
|
||||
for (label in labels) {
|
||||
// 假设 label 是原始字符串
|
||||
var processedLabel = label
|
||||
// 去掉单引号和双引号
|
||||
if (label.contains("'")) {
|
||||
processedLabel = processedLabel.replace("'", "")
|
||||
}
|
||||
if (label.contains("\"")) {
|
||||
processedLabel = processedLabel.replace("\"", "")
|
||||
}
|
||||
// 去掉所有空格
|
||||
processedLabel = processedLabel.replace(" ", "")
|
||||
processedLabels.add(processedLabel)
|
||||
}
|
||||
return processedLabels
|
||||
}
|
||||
} catch (e: Exception) {
|
||||
e.printStackTrace()
|
||||
Log.e("ExtractLabels", "Error during extraction: ${e.message}")
|
||||
}
|
||||
return null
|
||||
}
|
||||
|
||||
class MainActivity : AppCompatActivity() {
|
||||
|
||||
private lateinit var inputEditText: EditText
|
||||
private lateinit var configButton: Button
|
||||
private lateinit var submitToAIButton: Button
|
||||
private lateinit var tabLayout: TabLayout
|
||||
private lateinit var submitToServerButton: Button
|
||||
|
||||
override fun onCreate(savedInstanceState: Bundle?) {
|
||||
super.onCreate(savedInstanceState)
|
||||
setContentView(R.layout.activity_main)
|
||||
|
||||
inputEditText = findViewById(R.id.inputEditText)
|
||||
inputEditText.gravity = Gravity.START or Gravity.TOP
|
||||
|
||||
configButton = findViewById(R.id.configButton)
|
||||
|
||||
submitToAIButton = findViewById(R.id.submitToAIButton)
|
||||
|
||||
submitToAIButton.setOnClickListener {
|
||||
// 创建 OkHttpClient，点击智谱AI分析返回标签
|
||||
val client = OkHttpClient.Builder()
|
||||
.addInterceptor(object : Interceptor {
|
||||
override fun intercept(chain: Interceptor.Chain): okhttp3.Response {
|
||||
val originalRequest = chain.request()
|
||||
val newRequest = originalRequest.newBuilder().build()
|
||||
return chain.proceed(newRequest)
|
||||
}
|
||||
})
|
||||
.build()
|
||||
// 假设这是一个 EditText 元素
|
||||
val inputEditText = findViewById<EditText>(R.id.inputEditText)
|
||||
|
||||
// 获取 EditText 中的文本内容，创建request的body
|
||||
val textFromEditText = inputEditText.text.toString()
|
||||
val combinedText =
|
||||
"$textFromEditText。请为以上文章分析并给出 4 个最合理的标签，没有其他内容。以 JSON 格式输出，格式为 labels: [标签 1, 标签 2, 标签 3, 标签 4]"
|
||||
|
||||
val moshi = Moshi.Builder().add(KotlinJsonAdapterFactory()).build()
|
||||
val jsonAdapter = moshi.adapter(ChatRequest::class.java)
|
||||
|
||||
val requestBody = ChatRequest(
|
||||
model = "glm-4-flash",
|
||||
messages = listOf(Message(role = "user", content = combinedText))
|
||||
)
|
||||
|
||||
val requestBodyJson = jsonAdapter.toJson(requestBody)
|
||||
val mediaType = "application/json; charset=utf-8".toMediaType()
|
||||
val body = requestBodyJson.toRequestBody(mediaType)
|
||||
|
||||
// 从配置中读取 api_key
|
||||
val sharedPrefs = getSharedPreferences("APIConfigs", MODE_PRIVATE)
|
||||
val allConfigsJson = sharedPrefs.getString("configs", null)
|
||||
var api_key = ""
|
||||
var api_url = ""
|
||||
if (allConfigsJson != null) {
|
||||
val type = object : TypeToken<List<APIConfig>>() {}.type
|
||||
val allConfigs = Gson().fromJson<List<APIConfig>>(allConfigsJson, type)
|
||||
val zhipuConfig = allConfigs.find { it.name == "zhipu" }
|
||||
|
||||
if (zhipuConfig != null) {
|
||||
api_key = zhipuConfig.key
|
||||
api_url = zhipuConfig.url
|
||||
}
|
||||
}
|
||||
|
||||
// 创建请求
|
||||
val request = Request.Builder()
|
||||
.url("$api_url")
|
||||
.post(body)
|
||||
.header("Authorization", "Bearer $api_key")
|
||||
.header("Content-Type", "application/json")
|
||||
.build()
|
||||
|
||||
// 使用协程在后台线程中发送请求
|
||||
CoroutineScope(Dispatchers.Main).launch {
|
||||
try {
|
||||
// 模拟可能出现异常的网络操作，这里需要替换为你的实际网络请求相关代码
|
||||
// 比如使用 OkHttp 或者其他网络库进行请求
|
||||
val response = withContext(Dispatchers.IO) {
|
||||
client.newCall(request).execute()
|
||||
}
|
||||
if (response.isSuccessful) {
|
||||
val responseBody = response.body?.string() // 将响应体转换为字符串
|
||||
responseBody?.let {
|
||||
// 处理响应 JSON 数据
|
||||
print("return message is $responseBody")
|
||||
val labels = extractLabels(responseBody)
|
||||
labels?.let {
|
||||
if (labels != null && labels.size == 4) {
|
||||
for (i in 0 until 4) {
|
||||
val tab = tabLayout.getTabAt(i)
|
||||
if (tab != null) {
|
||||
tab.text = labels[i]
|
||||
tab.view.setOnClickListener {
|
||||
val currentText =
|
||||
findViewById<EditText>(R.id.inputEditText).text.toString()
|
||||
val buttonText = tab.text.toString()
|
||||
findViewById<EditText>(R.id.inputEditText).setText("$currentText\n#$buttonText")
|
||||
}
|
||||
}
|
||||
}
|
||||
findViewById<TextView>(R.id.statusTextView).text = "标签已经获取并更新"
|
||||
}
|
||||
} ?: run {
|
||||
findViewById<TextView>(R.id.statusTextView).text = "没有更新"
|
||||
}
|
||||
}
|
||||
} else {
|
||||
findViewById<TextView>(R.id.statusTextView).text = "没有响应，没有更新"
|
||||
}
|
||||
} catch (e: UnknownHostException) {
|
||||
findViewById<TextView>(R.id.statusTextView).text ="UnknownHostException: ${e.message}"
|
||||
} catch (e: IOException) {
|
||||
findViewById<TextView>(R.id.statusTextView).text = "IOException: ${e.message}"
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
tabLayout = findViewById(R.id.tabLayout)
|
||||
submitToServerButton = findViewById(R.id.submitToServerButton)
|
||||
|
||||
configButton.setOnClickListener {
|
||||
val intent = Intent(this, SecondActivity::class.java)
|
||||
startActivity(intent)
|
||||
}
|
||||
|
||||
submitToServerButton = findViewById(R.id.submitToServerButton)
|
||||
inputEditText = findViewById(R.id.inputEditText)
|
||||
|
||||
submitToServerButton.setOnClickListener {
|
||||
val textFromEditText = inputEditText.text.toString()
|
||||
submitToServer(textFromEditText)
|
||||
}
|
||||
|
||||
|
||||
// Setup TabLayout using a loop
|
||||
val tabLayout = findViewById<TabLayout>(R.id.tabLayout)
|
||||
// 维持原来的创建标签按钮的代码
|
||||
(1..4).forEach { tabIndex ->
|
||||
val tabButton = tabLayout.newTab().apply {
|
||||
text = "标签示例$tabIndex"
|
||||
tabLayout.addTab(this)
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
private fun submitToServer(content: String) {
|
||||
val statusTextView = findViewById<TextView>(R.id.statusTextView)
|
||||
|
||||
CoroutineScope(Dispatchers.Main).launch {
|
||||
statusTextView.text = "提交到flomo服务器..."
|
||||
|
||||
val result = withContext(Dispatchers.IO) {
|
||||
postDataToServer(content)
|
||||
}
|
||||
when (result) {
|
||||
is Result.Success -> {
|
||||
findViewById<EditText>(R.id.inputEditText).setText("")
|
||||
statusTextView.text = "提交成功!"
|
||||
}
|
||||
is Result.Error -> {
|
||||
statusTextView.text = "提交失误: ${result.exception.message}"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 提交到笔记服务器，flomo服务器
|
||||
private suspend fun postDataToServer(content: String): Result {
|
||||
return try {
|
||||
val client = OkHttpClient()
|
||||
val mediaType = "application/json".toMediaType()
|
||||
val json = JSONObject().apply {
|
||||
put("content", content)
|
||||
}.toString()
|
||||
val body = json.toRequestBody(mediaType)
|
||||
val request = Request.Builder()
|
||||
.url("https://flomoapp.com/iwh/MTY5NTQy/b671d4930ecd1eae63e50cc0cb8ca4ae/")
|
||||
.post(body)
|
||||
.build()
|
||||
val response = client.newCall(request).execute()
|
||||
if (response.isSuccessful) {
|
||||
Result.Success(response)
|
||||
} else {
|
||||
Result.Error(Exception("服务器返回错误： ${response.code}"))
|
||||
}
|
||||
} catch (e: Exception) {
|
||||
Result.Error(e)
|
||||
}
|
||||
}
|
||||
|
||||
sealed class Result {
|
||||
data class Success(val response: Response) : Result()
|
||||
data class Error(val exception: Exception) : Result()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user