272 lines
8.3 KiB
Dart
272 lines
8.3 KiB
Dart
import 'package:flutter/foundation.dart';
|
||
import 'package:hive_flutter/hive_flutter.dart';
|
||
import 'package:uuid/uuid.dart';
|
||
import '../models/sake_item.dart';
|
||
import 'gemini_service.dart';
|
||
|
||
/// Draft（解析待ちアイテム）管理サービス
|
||
///
|
||
/// Phase 1緊急対応: オフライン時に撮影した写真を一時保存し、
|
||
/// オンライン復帰時に自動解析する機能を提供します。
|
||
///
|
||
/// 使用フロー:
|
||
/// 1. オフライン時: saveDraft() で写真を一時保存
|
||
/// 2. オンライン復帰時: getPendingDrafts() で一覧取得
|
||
/// 3. analyzeDraft() で個別解析、または analyzeAllDrafts() で一括解析
|
||
class DraftService {
|
||
static const _uuid = Uuid();
|
||
|
||
/// Draft（解析待ち）アイテムを保存
|
||
///
|
||
/// オフライン時にカメラで撮影した写真を一時保存します。
|
||
/// 写真パスはそのまま保持され、後でAI解析時に使用されます。
|
||
///
|
||
/// [photoPaths] 保存した写真の絶対パスリスト（ギャラリーに既に保存済みであること）
|
||
///
|
||
/// Returns: 作成されたDraft SakeItemのkey
|
||
///
|
||
/// Usage:
|
||
/// ```dart
|
||
/// final draftKey = await DraftService.saveDraft([imagePath1, imagePath2]);
|
||
/// ```
|
||
static Future<String> saveDraft(List<String> photoPaths) async {
|
||
try {
|
||
final box = Hive.box<SakeItem>('sake_items');
|
||
|
||
// 🔧 FIX: 最初の画像をdraftPhotoPathに、全画像をimagePathsに保存
|
||
final firstPhotoPath = photoPaths.isNotEmpty ? photoPaths.first : '';
|
||
|
||
// Draft用の仮データを作成
|
||
final draftItem = SakeItem(
|
||
id: _uuid.v4(),
|
||
isPendingAnalysis: true,
|
||
draftPhotoPath: firstPhotoPath,
|
||
displayData: DisplayData(
|
||
name: '解析待ち',
|
||
brewery: '---',
|
||
prefecture: '---',
|
||
imagePaths: photoPaths, // 🔧 FIX: すべての画像を保存
|
||
rating: null,
|
||
),
|
||
hiddenSpecs: HiddenSpecs(
|
||
description: 'オフライン時に撮影された写真です。オンライン復帰後に自動解析されます。',
|
||
tasteStats: {},
|
||
flavorTags: [],
|
||
),
|
||
userData: UserData(
|
||
isFavorite: false,
|
||
isUserEdited: false,
|
||
markup: 3.0,
|
||
),
|
||
gamification: Gamification(ponPoints: 0),
|
||
metadata: Metadata(
|
||
createdAt: DateTime.now(),
|
||
aiConfidence: null,
|
||
),
|
||
);
|
||
|
||
await box.add(draftItem);
|
||
debugPrint('📝 Draft saved: ${draftItem.id}');
|
||
return draftItem.id;
|
||
} catch (e) {
|
||
debugPrint('⚠️ Draft save error: $e');
|
||
rethrow;
|
||
}
|
||
}
|
||
|
||
/// すべての解析待ちDraftを取得
|
||
///
|
||
/// Returns: 解析待ちアイテムのリスト
|
||
///
|
||
/// Usage:
|
||
/// ```dart
|
||
/// final drafts = await DraftService.getPendingDrafts();
|
||
/// print('未解析: ${drafts.length}件');
|
||
/// ```
|
||
static Future<List<SakeItem>> getPendingDrafts() async {
|
||
try {
|
||
final box = Hive.box<SakeItem>('sake_items');
|
||
final allItems = box.values.toList();
|
||
final pendingDrafts = allItems.where((item) => item.isPendingAnalysis).toList();
|
||
|
||
debugPrint('📋 Pending drafts: ${pendingDrafts.length}件');
|
||
return pendingDrafts;
|
||
} catch (e) {
|
||
debugPrint('⚠️ Get pending drafts error: $e');
|
||
return [];
|
||
}
|
||
}
|
||
|
||
/// 解析待ちDraftの件数を取得
|
||
///
|
||
/// Returns: 解析待ちアイテム数
|
||
static Future<int> getPendingCount() async {
|
||
final drafts = await getPendingDrafts();
|
||
return drafts.length;
|
||
}
|
||
|
||
/// 特定のDraftを解析し、正式なSakeItemに変換
|
||
///
|
||
/// [itemKey] DraftアイテムのHive key
|
||
///
|
||
/// Returns: 解析結果のSakeAnalysisResult
|
||
///
|
||
/// Throws: AI解析エラー、ネットワークエラーなど
|
||
///
|
||
/// Usage:
|
||
/// ```dart
|
||
/// try {
|
||
/// final result = await DraftService.analyzeDraft(itemKey);
|
||
/// print('解析完了: ${result.name}');
|
||
/// } catch (e) {
|
||
/// print('解析失敗: $e');
|
||
/// }
|
||
/// ```
|
||
static Future<SakeAnalysisResult> analyzeDraft(dynamic itemKey) async {
|
||
final box = Hive.box<SakeItem>('sake_items');
|
||
final item = box.get(itemKey);
|
||
|
||
if (item == null) {
|
||
throw Exception('Draft item not found: $itemKey');
|
||
}
|
||
|
||
if (!item.isPendingAnalysis) {
|
||
throw Exception('Item is not a draft: $itemKey');
|
||
}
|
||
|
||
final photoPath = item.draftPhotoPath;
|
||
if (photoPath == null || photoPath.isEmpty) {
|
||
throw Exception('Draft has no photo path: $itemKey');
|
||
}
|
||
|
||
debugPrint('🔍 Analyzing draft: $itemKey (${item.displayData.displayName})');
|
||
|
||
// 🔧 FIX: 複数画像がある場合はすべて使用
|
||
final imagePaths = item.displayData.imagePaths;
|
||
final pathsToAnalyze = imagePaths.isNotEmpty ? imagePaths : [photoPath];
|
||
|
||
// Gemini Vision API呼び出し
|
||
final geminiService = GeminiService();
|
||
final result = await geminiService.analyzeSakeLabel(pathsToAnalyze);
|
||
|
||
debugPrint('✅ Analysis completed: ${result.name}');
|
||
|
||
// Draftを正式なアイテムに更新
|
||
final updatedItem = item.copyWith(
|
||
name: result.name,
|
||
brand: result.brand,
|
||
prefecture: result.prefecture,
|
||
description: result.description,
|
||
catchCopy: result.catchCopy,
|
||
flavorTags: result.flavorTags,
|
||
tasteStats: result.tasteStats,
|
||
confidenceScore: result.confidenceScore,
|
||
// 新規フィールド
|
||
specificDesignation: result.type,
|
||
alcoholContent: result.alcoholContent,
|
||
polishingRatio: result.polishingRatio,
|
||
sakeMeterValue: result.sakeMeterValue,
|
||
riceVariety: result.riceVariety,
|
||
yeast: result.yeast,
|
||
manufacturingYearMonth: result.manufacturingYearMonth,
|
||
// Draft状態を解除
|
||
isPendingAnalysis: false,
|
||
draftPhotoPath: null,
|
||
);
|
||
|
||
// await updatedItem.save(); // Error: This object is currently not in a box.
|
||
await box.put(itemKey, updatedItem);
|
||
debugPrint('💾 Draft updated to normal item: $itemKey');
|
||
|
||
return result;
|
||
}
|
||
|
||
/// すべての解析待ちDraftを一括解析
|
||
///
|
||
/// Returns: {成功件数, 失敗件数, エラーメッセージリスト}
|
||
///
|
||
/// Usage:
|
||
/// ```dart
|
||
/// final result = await DraftService.analyzeAllDrafts((progress, total) {
|
||
/// print('進捗: $progress / $total');
|
||
/// });
|
||
/// print('成功: ${result['success']}, 失敗: ${result['failed']}');
|
||
/// ```
|
||
static Future<Map<String, dynamic>> analyzeAllDrafts({
|
||
Function(int progress, int total)? onProgress,
|
||
}) async {
|
||
final drafts = await getPendingDrafts();
|
||
final total = drafts.length;
|
||
|
||
if (total == 0) {
|
||
debugPrint('📭 No pending drafts to analyze');
|
||
return {'success': 0, 'failed': 0, 'errors': []};
|
||
}
|
||
|
||
int successCount = 0;
|
||
int failedCount = 0;
|
||
final List<String> errors = [];
|
||
|
||
debugPrint('🚀 Analyzing $total drafts...');
|
||
|
||
for (int i = 0; i < total; i++) {
|
||
final draft = drafts[i];
|
||
final itemKey = draft.key;
|
||
|
||
try {
|
||
onProgress?.call(i + 1, total);
|
||
await analyzeDraft(itemKey);
|
||
successCount++;
|
||
debugPrint('✅ [$i+1/$total] Success: ${draft.displayData.displayName}');
|
||
} catch (e) {
|
||
failedCount++;
|
||
final errorMsg = '[$i+1/$total] ${draft.displayData.displayName}: $e';
|
||
errors.add(errorMsg);
|
||
debugPrint('❌ $errorMsg');
|
||
// 失敗してもループは継続（他のDraftを解析）
|
||
}
|
||
}
|
||
|
||
debugPrint('🎉 Batch analysis completed: $successCount成功, $failedCount失敗');
|
||
|
||
return {
|
||
'success': successCount,
|
||
'failed': failedCount,
|
||
'errors': errors,
|
||
};
|
||
}
|
||
|
||
/// Draft を削除（解析を諦める場合）
|
||
///
|
||
/// [itemKey] DraftアイテムのHive key
|
||
///
|
||
/// Usage:
|
||
/// ```dart
|
||
/// await DraftService.deleteDraft(itemKey);
|
||
/// ```
|
||
static Future<void> deleteDraft(dynamic itemKey) async {
|
||
final box = Hive.box<SakeItem>('sake_items');
|
||
final item = box.get(itemKey);
|
||
|
||
if (item != null && item.isPendingAnalysis) {
|
||
await box.delete(itemKey);
|
||
debugPrint('🗑️ Draft deleted: $itemKey');
|
||
}
|
||
}
|
||
|
||
/// すべてのDraftを削除
|
||
///
|
||
/// Returns: 削除件数
|
||
static Future<int> deleteAllDrafts() async {
|
||
final drafts = await getPendingDrafts();
|
||
final count = drafts.length;
|
||
|
||
for (final draft in drafts) {
|
||
await deleteDraft(draft.key);
|
||
}
|
||
|
||
debugPrint('🗑️ All drafts deleted: $count件');
|
||
return count;
|
||
}
|
||
}
|