-
Notifications
You must be signed in to change notification settings - Fork 8
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'add_new_stats' into main2add_new_stats
- Loading branch information
Showing
13 changed files
with
441 additions
and
247 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,126 @@ | ||
| import 'dart:math' as math; | ||
|
|
||
| import 'package:ml_linalg/linalg.dart'; | ||
| import 'package:ml_linalg/vector.dart'; | ||
|
|
||
| import 'package:trale/core/interpolation.dart'; | ||
| import 'package:trale/core/measurement.dart'; | ||
| import 'package:trale/core/measurementDatabase.dart'; | ||
| import 'package:trale/core/measurementInterpolation.dart'; | ||
| import 'package:trale/core/preferences.dart'; | ||
|
|
||
|
|
||
| /// class providing an API to handle interpolation of measurements | ||
| class MeasurementStats { | ||
| /// singleton constructor | ||
| factory MeasurementStats() => _instance; | ||
|
|
||
| /// single instance creation | ||
| MeasurementStats._internal(); | ||
|
|
||
| /// singleton instance | ||
| static final MeasurementStats _instance = MeasurementStats._internal(); | ||
|
|
||
| /// get measurements | ||
| MeasurementDatabase get db => MeasurementDatabase(); | ||
|
|
||
| /// get interpolation | ||
| MeasurementInterpolation get ip => MeasurementInterpolation(); | ||
|
|
||
| /// re initialize database | ||
| void reinit() { | ||
| _streakList = null; | ||
| // recalculate all vectors | ||
| init(); | ||
| } | ||
|
|
||
| /// initialize database | ||
| void init() {} | ||
|
|
||
|
|
||
| /// return difference of Gaussian smoothed weights | ||
| double? deltaWeightLastNDays (int nDays) { | ||
| if (ip.measuredTimeSpan < nDays) { | ||
| return null; | ||
| } | ||
| return ip.weightsGaussianExtrapol[ip.idxLast] - | ||
| ip.weightsGaussianExtrapol[ip.idxLast - nDays]; | ||
| } | ||
|
|
||
| /// get max weight | ||
| double? get maxWeight => ip.weights_measured.max(); | ||
|
|
||
| /// get min weight | ||
| double? get minWeight => ip.weights_measured.min(); | ||
|
|
||
| /// get min weight | ||
| double? get meanWeight => ip.weights_measured.mean(); | ||
|
|
||
| /// get number of measurements | ||
| int get nMeasurements => ip.NMeasurements; | ||
|
|
||
| /// get current streak | ||
| int get currentStreak => streakList.last.round(); | ||
|
|
||
| /// get max streak | ||
| int get maxStreak => streakList.max().round(); | ||
|
|
||
| Vector? _streakList; | ||
| /// get list of all streaks | ||
| Vector get streakList => _streakList ??= _estimateStreakList(); | ||
| Vector _estimateStreakList() { | ||
| int streak = 0; | ||
| final List<int> streakList = <int>[]; | ||
| for ( | ||
| final bool isMS in ip.isMeasurement.toList().map((e) => e.round() == 1) | ||
| ) { | ||
| streak++; | ||
| if (!isMS){ | ||
| streakList.add(streak - 1); | ||
| streak = 0; | ||
| } | ||
| } | ||
| return Vector.fromList(streakList); | ||
| } | ||
|
|
||
| /// get weight change [kg] within last month from last measurement | ||
| double? get deltaWeightLastYear => deltaWeightLastNDays(365); | ||
|
|
||
| /// get weight change [kg] within last month from last measurement | ||
| double? get deltaWeightLastMonth => deltaWeightLastNDays(30); | ||
|
|
||
| /// get weight change [kg] within last week from last measurement | ||
| double? get deltaWeightLastWeek => deltaWeightLastNDays(7); | ||
|
|
||
| /// get time of reaching target weight in kg | ||
| Duration? timeOfTargetWeight(double? targetWeight) { | ||
| if ((targetWeight == null) || (db.nMeasurements < 2)){ | ||
| return null; | ||
| } | ||
| final double slope = ip.finalSlope; | ||
|
|
||
| // Crossing is in the past | ||
| if (slope * (ip.weightsDisplay[ip.idxLastDisplay] - targetWeight) >= 0) { | ||
| return null; | ||
| } | ||
|
|
||
| // in ms from last measurement | ||
| final int remainingTime = ( | ||
| (targetWeight - ip.weightsDisplay[ip.idxLastDisplay]) / slope | ||
| ).round(); | ||
|
|
||
| final DateTime timeOfReachingTargetWeight = | ||
| DateTime.fromMillisecondsSinceEpoch( | ||
| ip.times_measured.last.round() + remainingTime | ||
| ); | ||
|
|
||
| final int dayUntilReachingTargetWeight = | ||
| timeOfReachingTargetWeight.day - DateTime.now().day; | ||
|
|
||
| if (dayUntilReachingTargetWeight > 0){ | ||
| return Duration(days: dayUntilReachingTargetWeight); | ||
| } | ||
| return null; | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.