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

...

Browse Source
This commit is contained in:
lunaticbum 2026-06-02 15:30:17 +09:00
parent 83d671bece
commit d26eb34f1d
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/kotlin/service/AutoTradingManager.kt
View File

@ -398,6 +398,11 @@ object AutoTradingManager {
// 1. 기존 Watchdog이 있다면 제거 후 새로 시작 // 1. 기존 Watchdog이 있다면 제거 후 새로 시작
watchdogJob?.cancel() watchdogJob?.cancel()
watchdogJob = scope.launch { watchdogJob = scope.launch {
val activeTrades = DatabaseFactory.findAllMonitoringTrades()
var now = LocalTime.now(ZoneId.of("Asia/Seoul"))
if (activeTrades.isNotEmpty() && KisSession.isAvailBuyTime(now) == false) {
executeClosingLiquidation(activeTrades)
}
while (isActive) { while (isActive) {
delay(WATCHDOG_CHECK_INTERVAL) delay(WATCHDOG_CHECK_INTERVAL)
val now = System.currentTimeMillis() val now = System.currentTimeMillis()
@ -770,7 +775,7 @@ object AutoTradingManager {
withTimeout(CYCLE_TIMEOUT) { withTimeout(CYCLE_TIMEOUT) {
println("⏱️ [Cycle Start] ${LocalTime.now()}") println("⏱️ [Cycle Start] ${LocalTime.now()}")
val activeTrades = DatabaseFactory.findAllMonitoringTrades() val activeTrades = DatabaseFactory.findAllMonitoringTrades()
if (now.isAfter(LocalTime.of(15, 30)) && activeTrades.isNotEmpty()) { if (now.isAfter(KisSession.endBuyTime()) && activeTrades.isNotEmpty()) {
executeClosingLiquidation(activeTrades) executeClosingLiquidation(activeTrades)
} else { } else {
executeMarketLoop() executeMarketLoop()
@ -817,7 +822,7 @@ object AutoTradingManager {
} }
} }
var loadedTops = mutableListOf<Pair<String, String>>() var loadedTops = mutableListOf<Pair<String, String>>()
var defaultStockCount = 150 var defaultStockCount = 100
fun poll100Stocks(): List<Pair<String, String>> { fun poll100Stocks(): List<Pair<String, String>> {
loadedTops.shuffle() loadedTops.shuffle()
val count = minOf(loadedTops.size, defaultStockCount) val count = minOf(loadedTops.size, defaultStockCount)
@ -1073,6 +1078,9 @@ object AutoTradingManager {
print("-> 기업명을 못찾아서 제외 | ") print("-> 기업명을 못찾아서 제외 | ")
return@withTimeout return@withTimeout
} }
if(currentBalance?.getHoldings()?.any { it.code.equals(stock.code) && it.quantity.toInt() > 2} == true) {
println("물타기 대상 분석")
}
callback(TradingDecision().apply { callback(TradingDecision().apply {
this.stockCode = stock.code this.stockCode = stock.code
this.confidence = -1.0 this.confidence = -1.0
@ -1183,7 +1191,7 @@ object AutoTradingManager {
} catch (e: Exception) { } catch (e: Exception) {
println("⚠️ [마감 에러] ${trade.name}: ${e.message}") println("⚠️ [마감 에러] ${trade.name}: ${e.message}")
} }
delay(200) delay(5)
} }
} }