lun_admin/lunBackServer
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

,,,,,

Browse Source
This commit is contained in:
lunaticbum 2025-03-06 17:59:12 +09:00
parent 8c16275c01
commit 50f43c063f
1 changed files with 1 additions and 61 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
src/main/kotlin/kr/lunaticbum/back/lun/controllers/Telegram.kt
View File

@ -331,67 +331,7 @@ class Telegram {
} else if (req.reqMsg?.contains("검색") == true) {
var originalQuery = req.reqMsg
val gSearch = "https://www.google.com/search?q=${originalQuery?.replace("오늘", SimpleDateFormat("yyyMMdd").format(Date()))}&tbs=qdr%3Am"
println("gSearch >>> ${gSearch}")
WebClient.create().get()
.uri(gSearch)
.retrieve()
.bodyToMono(String::class.java).timeout(Duration.ofMinutes(20L)).block()?.let { gsResult ->
println("gsearch result ==> ${Gson().toJson(gsResult)}")
var additionalInfo = StringBuffer()
// gsResult.items?.forEach {
// additionalInfo.append("- 정보 출처 :").append(it.link).append("\n")
// try {
// Jsoup.connect(it.link).get().body().text().let {
// if (it.length > 1000) {
// additionalInfo.append("- 정보 내용 :").append(it.chunked(500).first()).append("\n")
// } else {
// additionalInfo.append("- 정보 내용 :").append(it).append("\n")
// }
// }
// } catch (e : Exception) {
// additionalInfo.append("- 정보 타이틀 : ").append(it.title).append("\n")
// additionalInfo.append("- 정보 요약 :").append(it.snippet).append("\n")
// println(it.link)
// e.printStackTrace()
// }
// additionalInfo.append("\n")
// }
println("additionalInfo >>> ${additionalInfo.toString()}")
req.reqMsg = "질문 : " + originalQuery + "\n\n추가정보:" + "\n${additionalInfo.toString()} 위의 질문과 추가 정보를 고려하여 답변해주세요."
val client = WebClient.create()
client.post()
.uri(lamaGenerated)
.body(BodyInserters.fromValue(Gson().toJson(req)))
.retrieve()
.bodyToMono(String::class.java).timeout(Duration.ofMinutes(20L)).block()?.let { result ->
println("generate Result ==> ${result}")
Gson().fromJson(result, BumlamaResp::class.java)?.let { sss ->
var toalmsg = "${originalQuery}의 대답이 도착했어요.\n" + "\n" + "${sss.response}"
println(Gson().toJson(sss))
if (toalmsg.length > 200) {
toalmsg.chunked(120).forEach {
val fullUrl =
"https://api.telegram.org/${globalEvv.telegramBotKey}/sendMessage?chat_id=${globalEvv.telegramMyId}&text=${it}"
WebClient.create().get()
.uri(fullUrl)
.retrieve()
.bodyToMono(String::class.java).block() ?: "FAIL"
}
} else {
val fullUrl =
"https://api.telegram.org/${globalEvv.telegramBotKey}/sendMessage?chat_id=${globalEvv.telegramMyId}&text=${req.reqMsg}의 대답이 도착했어요.\n\n${sss.response}"
logService.log("fullUrl >>> ${fullUrl}")
WebClient.create().get()
.uri(fullUrl)
.retrieve()
.bodyToMono(String::class.java).block() ?: "FAIL"
}
}
}
}
lama.generateResponse(originalQuery,msg.from?.id.toString())
} else {
val client = WebClient.create()
client.post()