Slot Data Service に関するサービス層・業務処理を担当します。

15Fields
1Constructors
24Methods
441Lines
Package
com.example.rankingplugin.slot
Source
slot/SlotDataService.java
Kind
class
Roles
非同期 / スケジューラ初期化 / ブートストラップサービス層
このクラスにも章立て解説を追加しています。 自動抽出の一覧だけでなく、下の『重点クラスの詳細解説』で読む順番・内部サブシステム・変更時の注意点まで追えます。 全クラス章立てガイドを見る

クラス説明

クラス直前の Javadoc は見つかりませんでした。ソースとメソッド構成から責務を補完しています。

責務と見どころ

重点クラスの詳細解説

Slot Data Service に関するサービス層・業務処理を担当します。slot パッケージの中でも 441 行規模の中核クラスで、永続化境界・スケジューラが一か所に集まっています。中規模クラス群の中では変更影響が広く、章立てで読む価値が高いため重点解説へ追加しています。

最初に追う読む順番

  1. SlotDataService
    依存オブジェクトと初期状態を束ね、このクラスが担当するランタイムの前提を固めます。
  2. ensureLoadedAsync
    不足テーブル・設定・内部状態を先に揃える入口です。変更を入れる前提条件の確認地点になります。
  3. loadOrCreate
    実体や対象状態を作る段階で、後続フローがどのデータを前提に動くかを掴めます。
  4. loadFromDb
    実体や対象状態を作る段階で、後続フローがどのデータを前提に動くかを掴めます。
  5. loadRecentJackpotSpins
    実体や対象状態を作る段階で、後続フローがどのデータを前提に動くかを掴めます。
  6. recordJackpotSpinAsync
    結果を反映・永続化する境界です。表示だけ直って保存が壊れる系の切り分けに向きます。
  7. recordJackpotSpin
    結果を反映・永続化する境界です。表示だけ直って保存が壊れる系の切り分けに向きます。
  8. applyLoaded
    結果を反映・永続化する境界です。表示だけ直って保存が壊れる系の切り分けに向きます。
  9. saveBatch
    結果を反映・永続化する境界です。表示だけ直って保存が壊れる系の切り分けに向きます。

内部サブシステムの地図

起動・前提準備

初期テーブル、依存状態、定期処理の点灯など、このクラスが動き始める前提をまとめています。

主なフィールド

代表フロー詳解

反映・保存・終了の流れ

  1. saveBatch
  2. applyLoaded
  3. setSpins
  4. setSlots
  5. setProbabilityMode
  6. save

結果を保持し、必要なら永続化し、最後に掃除まで行う出口です。画面更新だけ合って保存が壊れるケースや残骸が残るケースの確認に向きます。

変更時の注意点

外部接点

主な永続化テーブル

SQL 文字列から抽出できた主要テーブルです。スキーマ変更時の確認用です。

slot_dataslot_win_historyinit

フィールド

VisibilityTypeName役割
privateJavaPluginpluginプラグイン本体参照です。
privateDataSourcedsDB 接続元を保持します。
privateintserverIdserverId の状態を保持します。
privateMap<UUID, SlotData>cacheキャッシュまたは直近計算結果を保持します。
privateSet<UUID>loadedloaded の状態を保持します。
privateSet<UUID>loadingloading の状態を保持します。
privateSet<UUID>dirtydirty の状態を保持します。
privateMap<UUID, Integer>pendingKillsDeltapendingKillsDelta の状態を保持します。
privateSet<UUID>pendingResetKillspendingResetKills の状態を保持します。
privateMap<UUID, Integer>pendingSpinsDeltapendingSpinsDelta の状態を保持します。
privateMap<UUID, Integer>pendingSetSpinspendingSetSpins の状態を保持します。
privateMap<UUID, Integer>pendingSetKillspendingSetKills の状態を保持します。
privateMap<UUID, int[]>pendingSlotspendingSlots の状態を保持します。
privateMap<UUID, SlotProbabilityMode>pendingSetModespendingSetModes の状態を保持します。
privateBukkitTaskflushTask非同期処理やスケジューラ制御に使うハンドルです。

コンストラクタ / 初期化

Signature説明主要呼び出し
public SlotDataService(JavaPlugin plugin, DataSource ds)依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。getServer → getPort → getConnection → createStatement → executeUpdate → slot_data

メソッド索引

NameVisibilityKind説明
SlotDataServicepublicコンストラクタ依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
flushDirtyTickprivateメソッドflushDirtyTick の主要処理を担当します。
saveBatchprivateメソッド状態を永続化または更新し、最新状態へ反映します。
preloadpublicメソッドpreload の主要処理を担当します。
isLoadedpublicメソッド条件判定を行い、後続処理の分岐に使える真偽値を返します。
getOrCreateCachedpublicメソッド必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
loadOrCreatepublicメソッド必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
ensureLoadedAsyncprivateメソッド必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。
loadFromDbprivateメソッド必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
applyLoadedprivateメソッドapplyLoaded の主要処理を担当します。
markDirtyprivateメソッドmarkDirty の主要処理を担当します。
incrementKillspublicメソッドincrementKills の主要処理を担当します。
resetKillspublicメソッドresetKills の主要処理を担当します。
incrementSpinspublicメソッドincrementSpins の主要処理を担当します。
getSpinspublicメソッド必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
setSpinspublicメソッドsetSpins の主要処理を担当します。
setSlotspublicメソッドsetSlots の主要処理を担当します。
getProbabilityModepublicメソッド必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
setProbabilityModepublicメソッドsetProbabilityMode の主要処理を担当します。
savepublicメソッド状態を永続化または更新し、最新状態へ反映します。
recordJackpotSpinAsyncpublicメソッドrecordJackpotSpinAsync の主要処理を担当します。
recordJackpotSpinpublicメソッドDB への問い合わせまたは更新処理を担当します。
loadRecentJackpotSpinspublicメソッド必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
shutdownpublicメソッド動作中の処理やリソースを安全に停止・解放します。

メソッド詳細

SlotDataService

コンストラクタpublic
public SlotDataService(JavaPlugin plugin, DataSource ds)

依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。

引数

throws

なし

主要な呼び出し順

getServergetPortgetConnectioncreateStatementexecuteUpdateslot_dataslot_win_historyidx_slot_win_history_player

flushDirtyTick

メソッドprivate
private void flushDirtyTick()

flushDirtyTick の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

isEmptycontainsremovegetSlot1getSlot2getSlot3getKillsgetSpins

saveBatch

メソッドprivate
private void saveBatch(List<SlotDataSnapshot> snaps)

状態を永続化または更新し、最新状態へ反映します。

引数

throws

なし

主要な呼び出し順

slot_datagetConnectionprepareStatementsetIntsetStringtoStringkeyaddBatch

preload

メソッドpublic
public void preload(UUID playerId)

preload の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

ensureLoadedAsync

isLoaded

メソッドpublic
public boolean isLoaded(UUID playerId)

条件判定を行い、後続処理の分岐に使える真偽値を返します。

引数

throws

なし

主要な呼び出し順

contains

getOrCreateCached

メソッドpublic
public SlotData getOrCreateCached(UUID playerId)

必要な状態を取得し、呼び出し側で利用しやすい形へ返します。

引数

throws

なし

主要な呼び出し順

computeIfAbsentensureLoadedAsync

loadOrCreate

メソッドpublic
public SlotData loadOrCreate(UUID playerId)

必要な状態を取得し、呼び出し側で利用しやすい形へ返します。

引数

throws

なし

主要な呼び出し順

getOrCreateCached

ensureLoadedAsync

メソッドprivate
private void ensureLoadedAsync(UUID playerId)

必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。

引数

throws

なし

主要な呼び出し順

containsgetSchedulerrunTaskAsynchronouslyloadFromDbrunTaskapplyLoadedremove

loadFromDb

メソッドprivate
private SlotData loadFromDb(UUID playerId)

必要な状態を取得し、呼び出し側で利用しやすい形へ返します。

引数

throws

なし

主要な呼び出し順

getConnectionprepareStatementsetIntsetStringtoStringexecuteQuerynextgetInt

applyLoaded

メソッドprivate
private void applyLoaded(UUID playerId, SlotData base)

applyLoaded の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

computeIfAbsentgetSlot1getSlot2getSlot3getKillsgetSpinsgetProbabilityModeremove

markDirty

メソッドprivate
private void markDirty(UUID playerId)

markDirty の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

目立つ内部呼び出しは抽出されませんでした。

incrementKills

メソッドpublic
public int incrementKills(UUID playerId, int delta)

incrementKills の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

getOrCreateCachedsetKillsgetKillscontainsmergemarkDirty

resetKills

メソッドpublic
public void resetKills(UUID playerId)

resetKills の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

getOrCreateCachedsetKillscontainsremovemarkDirty

incrementSpins

メソッドpublic
public int incrementSpins(UUID playerId, int delta)

incrementSpins の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

getOrCreateCachedsetSpinsgetSpinscontainsmergemarkDirty

getSpins

メソッドpublic
public int getSpins(UUID playerId)

必要な状態を取得し、呼び出し側で利用しやすい形へ返します。

引数

throws

なし

主要な呼び出し順

getOrCreateCached

setSpins

メソッドpublic
public void setSpins(UUID playerId, int spins)

setSpins の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

getOrCreateCachedcontainsremovemarkDirty

setSlots

メソッドpublic
public void setSlots(UUID playerId, int s1, int s2, int s3)

setSlots の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

getOrCreateCachedcontainsmarkDirty

getProbabilityMode

メソッドpublic
public SlotProbabilityMode getProbabilityMode(UUID playerId)

必要な状態を取得し、呼び出し側で利用しやすい形へ返します。

引数

throws

なし

主要な呼び出し順

getOrCreateCached

setProbabilityMode

メソッドpublic
public void setProbabilityMode(UUID playerId, SlotProbabilityMode mode)

setProbabilityMode の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

getOrCreateCachedcontainsgetProbabilityModemarkDirty

save

メソッドpublic
public void save(SlotData data)

状態を永続化または更新し、最新状態へ反映します。

引数

throws

なし

主要な呼び出し順

getOrCreateCachedgetPlayerIdsetSlotsgetSlot1getSlot2getSlot3setKillsgetKills

recordJackpotSpinAsync

メソッドpublic
public void recordJackpotSpinAsync(UUID playerId, int spins, SlotProbabilityMode mode)

recordJackpotSpinAsync の主要処理を担当します。

引数

throws

なし

主要な呼び出し順

getSchedulerrunTaskAsynchronouslyrecordJackpotSpin

recordJackpotSpin

メソッドpublic
public void recordJackpotSpin(UUID playerId, int spins, SlotProbabilityMode mode)

DB への問い合わせまたは更新処理を担当します。

引数

throws

なし

主要な呼び出し順

slot_win_historygetConnectionprepareStatementsetIntsetStringtoStringkeysetTimestamp

loadRecentJackpotSpins

メソッドpublic
public List<String> loadRecentJackpotSpins(int limit)

必要な状態を取得し、呼び出し側で利用しやすい形へ返します。

引数

throws

なし

主要な呼び出し順

getConnectionprepareStatementsetIntexecuteQuerynextgetStringgetIntfromStorage

shutdown

メソッドpublic
public void shutdown()

動作中の処理やリソースを安全に停止・解放します。

引数

throws

なし

主要な呼び出し順

cancelflushDirtyTick

代表的な処理フロー

  1. 初期化フロー
    SlotDataService → getServer → getPort → getConnection → createStatement → executeUpdate
    依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
  2. loadFromDb フロー
    loadFromDb → getConnection → prepareStatement → setInt → setString → toString
    必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
  3. loadRecentJackpotSpins フロー
    loadRecentJackpotSpins → getConnection → prepareStatement → setInt → executeQuery → next
    必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
  4. save フロー
    save → getOrCreateCached → getPlayerId → setSlots → getSlot1 → getSlot2
    状態を永続化または更新し、最新状態へ反映します。
  5. saveBatch フロー
    saveBatch → slot_data → getConnection → prepareStatement → setInt → setString
    状態を永続化または更新し、最新状態へ反映します。
  6. ensureLoadedAsync フロー
    ensureLoadedAsync → contains → getScheduler → runTaskAsynchronously → loadFromDb → runTask
    必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。

外部との接点

Web ルート

このクラス内に目立つ Web ルート定義は見つかりませんでした。

SQL / テーブル

slot_dataCURRENT_TIMESTAMPslot_win_historyinit

関連クラス

補足