135 lines
4.5 KiB
Dart
135 lines
4.5 KiB
Dart
import 'dart:developer' as dev;
|
|
import '../services/database_service.dart';
|
|
import '../logic/capacity_extractor.dart';
|
|
import '../models/saf_permission_state.dart';
|
|
import '../services/saf_storage_service.dart';
|
|
|
|
/// 电池数据服务：扫描日志、更新数据库
|
|
class BatteryDataService {
|
|
final SafStorageService _safService = SafStorageService();
|
|
final DatabaseService _dbService = DatabaseService();
|
|
|
|
/// 🟢 1.7.0 容量有效性校验（入库专用）
|
|
int? _validateCapacityForDB(int? capacity, int designCap) {
|
|
if (capacity == null) return null;
|
|
|
|
// 容量必须大于 0
|
|
if (capacity <= 0) {
|
|
dev.log('⚠️ [DB校验] 容量异常：<= 0，已拒绝入库', name: 'BatteryDataService');
|
|
return null;
|
|
}
|
|
|
|
// 容量不能低于设计容量的 60%
|
|
if (capacity < designCap * 0.6) {
|
|
dev.log(
|
|
'⚠️ [DB校验] 容量异常：低于设计容量 60%（$capacity < ${designCap * 0.6}），已拒绝入库',
|
|
name: 'BatteryDataService',
|
|
);
|
|
return null;
|
|
}
|
|
|
|
// 容量不能超过设计容量的 115%
|
|
if (capacity > designCap * 1.15) {
|
|
dev.log(
|
|
'⚠️ [DB校验] 容量异常：高于设计容量 115%（$capacity > ${designCap * 1.15}），已拒绝入库',
|
|
name: 'BatteryDataService',
|
|
);
|
|
return null;
|
|
}
|
|
|
|
return capacity;
|
|
}
|
|
|
|
/// 扫描所有日志文件并更新数据库
|
|
/// 🟢 1.7.0 增加 designCap 参数，用于入库前校验
|
|
Future<void> scanAndUpdateDB({int? designCap}) async {
|
|
dev.log('🔵 scanAndUpdateDB 开始', name: 'BatteryHealth');
|
|
|
|
final state = await _safService.getPermissionState();
|
|
if (state != SafPermissionState.authorized) {
|
|
dev.log('🔵 scanAndUpdateDB: 未授权', name: 'BatteryHealth');
|
|
return;
|
|
}
|
|
|
|
try {
|
|
final files = await _safService.listFiles();
|
|
final filePattern = RegExp(r'mbattery_charger_log_(\d{4}_\d{2}_\d{2})$');
|
|
|
|
for (String fileName in files) {
|
|
final match = filePattern.firstMatch(fileName);
|
|
if (match == null) continue;
|
|
|
|
final dateStr = match.group(1)!.replaceAll('_', '-');
|
|
dev.log('🔵 处理文件: $fileName, 日期: $dateStr', name: 'BatteryHealth');
|
|
|
|
try {
|
|
final lines = await _safService.readLogFile(fileName);
|
|
if (lines.isEmpty) continue;
|
|
|
|
// 使用 CapacityExtractor 提取容量
|
|
final cap = CapacityExtractor.extractCapacity(lines);
|
|
|
|
// 🟢 1.7.0 如果 designCap 传入，则进行入库前校验
|
|
int? validatedCap = cap;
|
|
if (designCap != null && designCap > 0) {
|
|
validatedCap = _validateCapacityForDB(cap, designCap);
|
|
}
|
|
|
|
if (validatedCap == null) {
|
|
if (cap != null) {
|
|
dev.log(
|
|
'🔵 日期 $dateStr 容量校验未通过 ($cap)，跳过入库',
|
|
name: 'BatteryHealth',
|
|
);
|
|
} else {
|
|
dev.log('🔵 日期 $dateStr 无有效容量数据，跳过入库', name: 'BatteryHealth');
|
|
}
|
|
continue;
|
|
}
|
|
|
|
// 提取电压极值
|
|
final voltReg = RegExp(r'vbat=(\d+)');
|
|
double? maxVolt, minVolt;
|
|
for (String line in lines) {
|
|
if (!line.contains('tbat=')) continue;
|
|
final match = voltReg.firstMatch(line);
|
|
if (match != null) {
|
|
final v = int.parse(match.group(1)!) / 1000000;
|
|
if (maxVolt == null || v > maxVolt) maxVolt = v;
|
|
if (minVolt == null || v < minVolt) minVolt = v;
|
|
}
|
|
}
|
|
if (maxVolt == null || minVolt == null) continue;
|
|
|
|
await _dbService.insertOrUpdate(
|
|
dateStr,
|
|
validatedCap,
|
|
maxVolt,
|
|
minVolt,
|
|
);
|
|
dev.log(
|
|
'🔵 插入数据库: $dateStr, cap=$validatedCap',
|
|
name: 'BatteryHealth',
|
|
);
|
|
} catch (e) {
|
|
dev.log('🔵 处理文件 $fileName 异常: $e', name: 'BatteryHealth');
|
|
}
|
|
}
|
|
} catch (e) {
|
|
dev.log('🔵 scanAndUpdateDB 异常: $e', name: 'BatteryHealth');
|
|
}
|
|
}
|
|
|
|
/// 获取趋势数据（最近 N 天）
|
|
Future<List<Map<String, dynamic>>> getTrendData(int days) async {
|
|
return await _dbService.queryRecentData(days);
|
|
}
|
|
|
|
/// 获取最近一条数据
|
|
Future<Map<String, dynamic>?> getLatestData() async {
|
|
final data = await _dbService.queryRecentData(1);
|
|
if (data.isNotEmpty) return data.first;
|
|
return null;
|
|
}
|
|
}
|