265 lines
9.5 KiB
Dart
265 lines
9.5 KiB
Dart
import 'dart:io';
|
||
import 'dart:convert';
|
||
import 'package:crypto/crypto.dart';
|
||
import 'package:hive_flutter/hive_flutter.dart';
|
||
import 'package:flutter/foundation.dart';
|
||
import 'gemini_service.dart';
|
||
|
||
/// 画像ハッシュベースのAI解析キャッシュサービス
|
||
///
|
||
/// 目的:
|
||
/// - 同じ日本酒を複数回撮影してもAPI呼び出しは1回のみ
|
||
/// - Gemini API制限（1日20回）の節約
|
||
///
|
||
/// 仕組み:
|
||
/// 1. 画像のSHA-256ハッシュを計算
|
||
/// 2. Hiveに{hash: 解析結果}を保存
|
||
/// 3. 同じハッシュの画像は即座にキャッシュから返す
|
||
class AnalysisCacheService {
|
||
static const String _cacheBoxName = 'analysis_cache_v1';
|
||
static const String _brandIndexBoxName = 'brand_index_v1'; // 銘柄名→ハッシュのインデックス
|
||
static Box<String>? _box;
|
||
static Box<String>? _brandIndexBox;
|
||
|
||
/// キャッシュボックスの初期化
|
||
static Future<void> init() async {
|
||
if (_box != null && _brandIndexBox != null) return; // 既に初期化済み
|
||
|
||
try {
|
||
_box = await Hive.openBox<String>(_cacheBoxName);
|
||
_brandIndexBox = await Hive.openBox<String>(_brandIndexBoxName);
|
||
debugPrint('✅ Analysis Cache initialized (${_box!.length} entries, ${_brandIndexBox!.length} brands)');
|
||
} catch (e) {
|
||
debugPrint('⚠️ Failed to open cache box: $e');
|
||
}
|
||
}
|
||
|
||
/// 画像のSHA-256ハッシュを計算
|
||
///
|
||
/// 同じ写真は同じハッシュになる（ビット完全一致）
|
||
/// 例: "abc123..." (64文字の16進数文字列)
|
||
static Future<String> computeImageHash(String imagePath) async {
|
||
try {
|
||
final bytes = await File(imagePath).readAsBytes();
|
||
final digest = sha256.convert(bytes);
|
||
return digest.toString();
|
||
} catch (e) {
|
||
debugPrint('⚠️ Hash computation failed: $e');
|
||
// ハッシュ計算失敗時はパスをそのまま使用（キャッシュなし）
|
||
return imagePath;
|
||
}
|
||
}
|
||
|
||
/// 複数画像の結合ハッシュを計算
|
||
///
|
||
/// 複数枚の写真を組み合わせた場合、順序も考慮してハッシュ化
|
||
/// 例: ["image1.jpg", "image2.jpg"] → "combined_hash_abc123..."
|
||
static Future<String> computeCombinedHash(List<String> imagePaths) async {
|
||
if (imagePaths.isEmpty) return '';
|
||
if (imagePaths.length == 1) return computeImageHash(imagePaths.first);
|
||
|
||
// 各画像のハッシュを連結してから再ハッシュ
|
||
final hashes = await Future.wait(
|
||
imagePaths.map((path) => computeImageHash(path)),
|
||
);
|
||
final combined = hashes.join('_');
|
||
return sha256.convert(utf8.encode(combined)).toString();
|
||
}
|
||
|
||
/// キャッシュから取得
|
||
///
|
||
/// 戻り値: キャッシュがあれば解析結果、なければ null
|
||
/// タイムスタンプ付き新形式と旧形式（直接 JSON）の両方に対応
|
||
static Future<SakeAnalysisResult?> getCached(String imageHash) async {
|
||
await init();
|
||
if (_box == null) return null;
|
||
|
||
try {
|
||
final jsonString = _box!.get(imageHash);
|
||
if (jsonString == null) {
|
||
debugPrint('Cache MISS: $imageHash');
|
||
return null;
|
||
}
|
||
|
||
final decoded = jsonDecode(jsonString) as Map<String, dynamic>;
|
||
|
||
// 新形式: { data: {...}, savedAt: "..." }
|
||
if (decoded.containsKey('data') && decoded.containsKey('savedAt')) {
|
||
debugPrint('Cache HIT: ${decoded['data']['name'] ?? 'Unknown'}');
|
||
return SakeAnalysisResult.fromJson(decoded['data'] as Map<String, dynamic>);
|
||
}
|
||
|
||
// 旧形式（後方互換）: 直接 SakeAnalysisResult の JSON
|
||
debugPrint('Cache HIT (legacy): ${decoded['name'] ?? 'Unknown'}');
|
||
return SakeAnalysisResult.fromJson(decoded);
|
||
} catch (e) {
|
||
debugPrint('Cache read error: $e');
|
||
return null;
|
||
}
|
||
}
|
||
|
||
/// キャッシュに保存
|
||
///
|
||
/// 解析結果を JSON 化してタイムスタンプ付きで Hive に永続化
|
||
static Future<void> saveCache(String imageHash, SakeAnalysisResult result) async {
|
||
await init();
|
||
if (_box == null) return;
|
||
|
||
try {
|
||
final entry = {
|
||
'data': result.toJson(),
|
||
'savedAt': DateTime.now().toIso8601String(),
|
||
};
|
||
await _box!.put(imageHash, jsonEncode(entry));
|
||
debugPrint('Cache saved: ${result.name ?? 'Unknown'}');
|
||
} catch (e) {
|
||
debugPrint('Cache save error: $e');
|
||
}
|
||
}
|
||
|
||
/// キャッシュをクリア（デバッグ用）
|
||
static Future<void> clearAll() async {
|
||
await init();
|
||
if (_box == null) return;
|
||
|
||
final count = _box!.length;
|
||
await _box!.clear();
|
||
debugPrint('🗑️ Cache cleared ($count entries deleted)');
|
||
}
|
||
|
||
/// キャッシュサイズを取得（統計用）
|
||
static Future<int> getCacheSize() async {
|
||
await init();
|
||
return _box?.length ?? 0;
|
||
}
|
||
|
||
/// 30日以上経過したキャッシュエントリを削除
|
||
///
|
||
/// アプリ起動時またはバックグラウンドで呼び出す。
|
||
/// 旧形式エントリ（タイムスタンプなし）は対象外として保持する。
|
||
/// _brandIndexBox の孤立エントリ（削除されたハッシュを参照するもの）も合わせて削除する。
|
||
static Future<void> cleanupExpired({int ttlDays = 30}) async {
|
||
await init();
|
||
if (_box == null) return;
|
||
|
||
final cutoff = DateTime.now().subtract(Duration(days: ttlDays));
|
||
final keysToDelete = <String>[];
|
||
|
||
for (final key in _box!.keys) {
|
||
try {
|
||
final jsonString = _box!.get(key as String);
|
||
if (jsonString == null) continue;
|
||
final decoded = jsonDecode(jsonString) as Map<String, dynamic>;
|
||
if (!decoded.containsKey('savedAt')) continue; // 旧形式は対象外
|
||
|
||
final savedAt = DateTime.tryParse(decoded['savedAt'] as String? ?? '');
|
||
if (savedAt != null && savedAt.isBefore(cutoff)) {
|
||
keysToDelete.add(key);
|
||
}
|
||
} catch (_) {
|
||
// 読み込みエラーのエントリは無視
|
||
}
|
||
}
|
||
|
||
if (keysToDelete.isNotEmpty) {
|
||
await _box!.deleteAll(keysToDelete);
|
||
debugPrint('Cache cleanup: ${keysToDelete.length} expired entries removed');
|
||
|
||
// 削除したハッシュを参照している _brandIndexBox の孤立エントリも削除する
|
||
if (_brandIndexBox != null) {
|
||
final deletedHashes = keysToDelete.toSet();
|
||
final brandKeysToDelete = <String>[];
|
||
for (final brandKey in _brandIndexBox!.keys) {
|
||
final hash = _brandIndexBox!.get(brandKey as String);
|
||
if (hash != null && deletedHashes.contains(hash)) {
|
||
brandKeysToDelete.add(brandKey);
|
||
}
|
||
}
|
||
if (brandKeysToDelete.isNotEmpty) {
|
||
await _brandIndexBox!.deleteAll(brandKeysToDelete);
|
||
debugPrint('Cache cleanup: ${brandKeysToDelete.length} orphaned brand index entries removed');
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// ============================================
|
||
// 銘柄名ベースキャッシュ機能（v1.0.15追加）
|
||
// ============================================
|
||
|
||
/// 銘柄名でキャッシュを検索
|
||
///
|
||
/// 異なる写真でも同じ銘柄なら、以前の解析結果を返す
|
||
/// これによりチャート（tasteStats）の一貫性を保証
|
||
static Future<SakeAnalysisResult?> getCachedByBrand(String? brandName) async {
|
||
if (brandName == null || brandName.isEmpty) return null;
|
||
await init();
|
||
if (_brandIndexBox == null) return null;
|
||
|
||
try {
|
||
final normalized = _normalizeBrandName(brandName);
|
||
final imageHash = _brandIndexBox!.get(normalized);
|
||
if (imageHash == null) {
|
||
debugPrint('🔍 Brand Index MISS: $brandName');
|
||
return null;
|
||
}
|
||
|
||
debugPrint('✅ Brand Index HIT: $brandName → $imageHash');
|
||
return getCached(imageHash);
|
||
} catch (e) {
|
||
debugPrint('⚠️ Brand index lookup error: $e');
|
||
return null;
|
||
}
|
||
}
|
||
|
||
/// 銘柄名をインデックスに登録
|
||
///
|
||
/// [forceUpdate] = true のとき（再解析など）は既存エントリを上書きする。
|
||
/// false のときは最初の結果を優先し、上書きしない。
|
||
static Future<void> registerBrandIndex(
|
||
String? brandName,
|
||
String imageHash, {
|
||
bool forceUpdate = false,
|
||
}) async {
|
||
if (brandName == null || brandName.isEmpty) return;
|
||
await init();
|
||
if (_brandIndexBox == null) return;
|
||
|
||
try {
|
||
final normalized = _normalizeBrandName(brandName);
|
||
final exists = _brandIndexBox!.containsKey(normalized);
|
||
|
||
if (!exists || forceUpdate) {
|
||
await _brandIndexBox!.put(normalized, imageHash);
|
||
debugPrint('Brand index ${exists ? "updated" : "registered"}: $brandName');
|
||
} else {
|
||
debugPrint('Brand index already exists: $brandName (skipped)');
|
||
}
|
||
} catch (e) {
|
||
debugPrint('Brand index registration error: $e');
|
||
}
|
||
}
|
||
|
||
/// 銘柄名の正規化
|
||
///
|
||
/// 全角・半角スペースを除去し、ASCII文字を小文字に統一する。
|
||
/// 例: "獺祭 純米大吟醸" → "獺祭純米大吟醸"
|
||
/// 例: "DASSAI" → "dassai"
|
||
/// 日本語文字には大文字・小文字の区別がないため、.toLowerCase() は ASCII のみに作用する。
|
||
static String _normalizeBrandName(String name) {
|
||
return name
|
||
.replaceAll(RegExp(r'\s+'), '') // 全角・半角スペース除去
|
||
.toLowerCase(); // ASCII ローマ字の表記ゆれを吸収（日本語には無効）
|
||
}
|
||
|
||
/// 銘柄名インデックスをクリア（デバッグ用）
|
||
static Future<void> clearBrandIndex() async {
|
||
await init();
|
||
if (_brandIndexBox == null) return;
|
||
|
||
final count = _brandIndexBox!.length;
|
||
await _brandIndexBox!.clear();
|
||
debugPrint('🗑️ Brand index cleared ($count entries deleted)');
|
||
}
|
||
}
|