warlock/TaskTracker
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Basic Functions done

Browse Source
This commit is contained in:
warlock
2022-02-27 16:46:13 +05:30
parent d4dd0864fa
commit 8c7ea9b86e
10 changed files with 421 additions and 160 deletions
Download Patch File Download Diff File Expand all files Collapse all files

235
lib/User.dart
View File

@@ -1,6 +1,10 @@
import 'dart:async';
import 'dart:io';
import 'package:flutter/cupertino.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'main.dart';
import 'package:http/http.dart' as http;
import 'dart:convert';
import 'Data.dart';
@@ -8,7 +12,8 @@ import 'package:sqflite/sqflite.dart';
import 'package:path_provider/path_provider.dart';
import 'package:device_info_plus/device_info_plus.dart';
import 'package:sn_progress_dialog/sn_progress_dialog.dart';
import 'Tasks.dart';
late ProgressDialog? progressDialog;
late http.Response loginResponse;
late Database cacheDb;
@@ -17,8 +22,10 @@ List<Category> categories = [];
List<TaskType> taskTypes = [];
List<Activity> activities=[];
bool offline = true;
bool registered = false;
Future<http.Response> login(String _username, String password) async {
final prefs = await SharedPreferences.getInstance();
username = _username;
var device_id = await Settings.UUID();
try {
@@ -27,12 +34,18 @@ Future<http.Response> login(String _username, String password) async {
body: <String, String>{
"username": _username,
"password": password,
"device_id": device_id ?? 'n/a'
"device_id": device_id
}));
if (loginResponse.body.toLowerCase().contains("success")) {
offline = false;
username = _username;
registered =loginResponse.body.toLowerCase().contains("register");
print("registered : $registered");
if(registered){
prefs.setBool("registered", true);
}
}
}catch(e){
offline=true;
@@ -42,35 +55,50 @@ Future<http.Response> login(String _username, String password) async {
Future<void> initUserData() async {
await initCacheDatabase();
await UpdateCategoriesFromServer();
await UpdateTaskTypesFromServer();
await GetCategories(true);
await GetTaskTypes(true);
await refreshUserData();
print('Initializing UserData...');
if (offline) {
print('Going offline mode.');
}
}
Future<void> refreshUserData() async{
ShowProgress("Loading data");
// categories= await GetCategories(true);
// taskTypes= await GetTaskTypes(true);
// activities= await GetActivities(true);
await updateCatsList();
await updateTasksList();
await updateActList();
HideProgress();
}
Future<bool> cacheDbExist() async{
Directory directory = await getApplicationDocumentsDirectory();
return databaseFactory.databaseExists(directory.path + 'cache.db');
}
Future<void> updateCatsList() async{
print('Updating with localCache');
categories = await GetCategories(true);
//print('Updating with localCache');
// categories = await GetCategories(true);
print('Checking if can refresh');
categories = await GetCategories(false);
}
Future<void> updateTasksList() async{
print('Updating with localCache');
taskTypes = await GetTaskTypes(true);
// print('Updating with localCache');
// taskTypes = await GetTaskTypes(true);
print('Checking if can refresh');
taskTypes = await GetTaskTypes(false);
}
Future<void> updateActList() async{
//print('Updating with localCache');
//activities = await GetActivities(true);
print('Checking if can refresh');
activities = await GetActivities(false);
}
Future<void> initCacheDatabase() async {
Directory directory = await getApplicationDocumentsDirectory();
@@ -102,13 +130,18 @@ void onCacheDatabaseCreate(Database db, int newVersion) async {
String QueriesTableSQL = 'CREATE TABLE Queries(id INTEGER PRIMARY KEY AUTOINCREMENT, ${Queries.colLink} TEXT,${Queries.colData} TEXT)';
// print(QueriesTableSQL);
await db.execute(QueriesTableSQL);
final prefs = await SharedPreferences.getInstance();
addInitialDataToCache();
if(prefs.getBool("registered") ?? false) {
addInitialDataToCache();
prefs.setBool("registered", false);
}
// GetCategories();
}
Future<void> addInitialDataToCache() async{
ShowProgress("Initializing User Data");
print("adding init data");
await Future.delayed(const Duration(seconds: 1));
//Insert Initial Entries
@@ -124,9 +157,9 @@ Future<void> addInitialDataToCache() async{
// };
// await cacheDb.insert('TaskTypes', data);
}
UserOperations.executeQueries();
HideProgress();
await UserOperations.executeQueries();
await refreshUserData();
}
void onCacheDatabaseUpgrade(Database db, int oldVersion, int newVersion) async {
@@ -150,7 +183,7 @@ Future<List<Category>> GetCategories(bool forceOffline) async{
try{
http.Response update_response = (await http.post(
Uri.parse('http://161.97.127.136/task_tracker/check_update.php'),
body: <String, String>{"username": username, "device_id":android_id??'n/a'}));
body: <String, String>{"username": username, "device_id":android_id}));
final data = update_response.body.split(',');
catsUpdated = data[0] == '1';
}catch(e){
@@ -160,9 +193,9 @@ Future<List<Category>> GetCategories(bool forceOffline) async{
print("Need to update : ${!catsUpdated}");
//Update CacheDB
if(!catsUpdated){
//if(!catsUpdated){
await UpdateCategoriesFromServer();
}
// }
}
List<Map> cats = await cacheDb.query('Categories');
@@ -184,25 +217,27 @@ Future<List<Category>> GetCategories(bool forceOffline) async{
}
Future<void> UpdateCategoriesFromServer() async{
print("Updating Categories");
print("Updating Categories as $username");
try {
http.Response response = (await http.post(
Uri.parse('http://161.97.127.136/task_tracker/get_categories.php'),
body: <String, String>{
"username": username,
"device_id": await Settings.UUID() ?? 'n/a'
"device_id": await Settings.UUID()
}));
print(response.body);
List<String> data = response.body.split("<td>");
data.forEach((value) async {
// await cacheDb.delete("Categories");
for (var value in data) {
Map<String, dynamic> cat = jsonDecode(value);
//print(catData);
await cacheDb.rawInsert(
"INSERT OR REPLACE INTO Categories (${Category.colCatId},${Category
.colName},${Category.colProductive},${Category.colColor}) "
"VALUES ('${cat['category_id']}','${cat['name']}',${cat['productive']},'${cat['color']}') ");
});
}
}catch(e){
offline=true;
}
@@ -222,7 +257,7 @@ Future<List<TaskType>> GetTaskTypes(bool forceOffline) async{
//Validate device_id to check updates
http.Response update_response = (await http.post(
Uri.parse('http://161.97.127.136/task_tracker/check_update.php'),
body: <String, String>{"username": username, "device_id":android_id??'n/a'}));
body: <String, String>{"username": username, "device_id":android_id}));
final data = update_response.body.split(',');
updated = data[1] == '1';
}catch(e){
@@ -232,11 +267,13 @@ Future<List<TaskType>> GetTaskTypes(bool forceOffline) async{
print("Need to update : ${!updated}");
//Update CacheDB
if(!updated){
// if(!updated){
await UpdateTaskTypesFromServer();
}
// }
}
await Future.delayed(Duration(seconds: 1));
List<Map> cats = await cacheDb.query('TaskTypes');
print(cats.length);
for(Map element in cats){
@@ -257,31 +294,37 @@ Future<List<TaskType>> GetTaskTypes(bool forceOffline) async{
}
Future<void> UpdateTaskTypesFromServer() async{
print("Updating TaskTypes");
// await GetCategories(true);
print("Updating TaskTypes as $username");
try {
http.Response response = (await http.post(
Uri.parse('http://161.97.127.136/task_tracker/get_taskTypes.php'),
body: <String, String>{
"username": username,
"device_id": await Settings.UUID() ?? 'n/a'
"device_id": await Settings.UUID()
}));
print(response.body);
List<String> data = response.body.split("<td>");
data.forEach((value) async {
await cacheDb.delete("TaskTypes");
for (var value in data) {
Map<String, dynamic> cat = jsonDecode(value);
//print(catData);
print(cat);
await cacheDb.rawInsert(
"INSERT OR REPLACE INTO TaskTypes (${TaskType.colId},${TaskType
.colName},${TaskType.colCategory}) "
"VALUES ('${cat['id']}','${cat['name']}',${cat['category']}) ");
});
"VALUES ('${cat['task_id']}','${cat['name']}','${cat['category_id']}') ");
print(await cacheDb.query("TaskTypes"));
}
}catch(e){
offline=true;
}
}
Future<List<TaskType>> GetActivities(bool forceOffline) async{
Future<List<Activity>> GetActivities(bool forceOffline) async{
List<Activity> _activities = [];
if(offline || forceOffline){
//Retreive from cacheDB
@@ -295,7 +338,7 @@ Future<List<TaskType>> GetActivities(bool forceOffline) async{
//Validate device_id to check updates
http.Response update_response = (await http.post(
Uri.parse('http://161.97.127.136/task_tracker/check_update.php'),
body: <String, String>{"username": username, "device_id":android_id??'n/a'}));
body: <String, String>{"username": username, "device_id":android_id}));
final data = update_response.body.split(',');
updated = data[2] == '1';
}catch(e){
@@ -305,17 +348,17 @@ Future<List<TaskType>> GetActivities(bool forceOffline) async{
print("Need to update activities : ${!updated}");
//Update CacheDB
if(!updated){
//if(!updated){
await UpdateActivitiesFromServer();
}
//}
}
List<Map> cats = await cacheDb.query('Activities');
List<Map> cats = await cacheDb.rawQuery('SELECT * FROM Activities ORDER BY ${Activity.colStartTime} DESC');
print(cats.length);
for(Map element in cats){
String? type = element[Activity.colType].toString();
String? startTime = element[Activity.colStartTime].toString();
String? endTime = element[Activity.colStartTime].toString();
String? endTime = element[Activity.colEndTime].toString();
TaskType? taskType = await getTaskFromId(type);
if(type==null || startTime==null || endTime==null || taskType==null){
print("Something is null!");
@@ -326,29 +369,40 @@ Future<List<TaskType>> GetActivities(bool forceOffline) async{
_activities.add(Activity(taskType, DateTime.parse(startTime), DateTime.parse(endTime)));
}
activities = _activities;
return taskTypes;
return activities;
}
Future<void> UpdateActivitiesFromServer() async{
print("Updating TaskTypes");
print("Updating Activities as $username");
try {
http.Response response = (await http.post(
Uri.parse('http://161.97.127.136/task_tracker/get_activities.php'),
body: <String, String>{
"username": username,
"device_id": await Settings.UUID() ?? 'n/a'
"device_id": await Settings.UUID()
}));
print(response.body);
await cacheDb.rawDelete("DELETE FROM Activities");
print('Truncate Activity Table before');
print("Activity response: ${response.body}");
if(response.body.contains("{")){
List<String> data = response.body.split("<td>");
data.forEach((value) async {
for (var value in data){
Map<String, dynamic> cat = jsonDecode(value);
//print(catData);
print(cat);
await cacheDb.rawInsert(
"INSERT OR REPLACE INTO Activities (${Activity.colType}, ${Activity.colStartTime}, ${Activity.colEndTime}) "
"VALUES ('${cat['type']}', '${cat['sTime']}','${cat['eTime']}') ");
});
"VALUES ('${cat['task_id']}', '${cat['sTime']}','${cat['eTime']}') ");
}
}else{
print("No activities for now");
}
}catch(e){
print("Error : $e @ updating activities");
offline=true;
}
}
@@ -402,7 +456,7 @@ class UserOperations{
static Future<void> addCategory(String name, String color, bool productive, {bool bulk = false}) async{
Map<String,String> queryBody= <String,String>{
'username': username,
'device_id': await Settings.UUID() ?? 'n/a',
'device_id': await Settings.UUID(),
'name' : name,
'color':color,
'productive': productive ? '1':'0'
@@ -437,7 +491,7 @@ class UserOperations{
Map<String,String> queryBody= <String,String>{
'id':username+name,
'username': username,
'device_id': await Settings.UUID() ?? 'n/a',
'device_id': await Settings.UUID(),
'name' : name,
'category': username + category
};
@@ -465,11 +519,51 @@ class UserOperations{
}
}
static Future<void> addActivity(String type, String sTime,String eTime, {bool bulk = false, Function(int)? onOverlap}) async{
//Check for timeoverlapse
activities= await GetActivities(true);
int? overlapCount = Sqflite.firstIntValue(await cacheDb.rawQuery("SELECT COUNT(*) FROM Activities WHERE (((${Activity.colStartTime} < datetime('$sTime')) AND ((${Activity.colEndTime} > datetime('$eTime')) OR (${Activity.colEndTime} < datetime('$eTime') AND ${Activity.colEndTime} > datetime('$sTime')))) OR (${Activity.colStartTime} > datetime('$sTime') AND ${Activity.colStartTime} < datetime('$eTime')) OR (${Activity.colStartTime}=datetime('$sTime') AND ${Activity.colEndTime}=datetime('$eTime')))"));
print("ActivityOverlaps: $overlapCount");
if(overlapCount! > 0){
onOverlap!(overlapCount);
}
Map<String,String> queryBody= <String,String>{
'username': username,
'device_id': await Settings.UUID(),
'type' : username+type,
'sTime': sTime,
'eTime':eTime
};
//Add Query
Map<String,Object> query = {
Queries.colLink: 'add_activity',
Queries.colData: jsonEncode(queryBody)
};
print("adding new query ${query[Queries.colLink]} : ${jsonEncode(queryBody)}");
await cacheDb.insert('Queries', query);
//update Cache
Map<String,Object> data = {
Activity.colType: type,
Activity.colStartTime: sTime,
Activity.colEndTime: eTime
};
await cacheDb.insert('Activities', data);
await GetActivities(true);
if(!bulk){
//Add to server and refresh Cache
await executeQueries();
}
}
static Future<void> deleteTask(String name,{bulk=false}) async{
Map<String,String> queryBody= <String,String>{
'id':username+name,
'username': username,
'device_id': await Settings.UUID() ?? 'n/a',
'device_id': await Settings.UUID(),
};
//Add Query
Map<String,Object> query = {
@@ -499,7 +593,7 @@ class UserOperations{
Map<String,String> queryBody= <String,String>{
'id':username+name,
'username': username,
'device_id': await Settings.UUID() ?? 'n/a',
'device_id': await Settings.UUID() ,
};
//Add Query
Map<String,Object> query = {
@@ -525,13 +619,43 @@ class UserOperations{
}
}
static Future<void> deleteActivity(Activity activity,{bulk=false}) async{
Map<String,String> queryBody= <String,String>{
'username': username,
'device_id': await Settings.UUID(),
'sTime': activity.startTime.toString(),
'eTime':activity.endTime.toString(),
};
//Add Query
Map<String,Object> query = {
Queries.colLink: 'delete_activity',
Queries.colData: jsonEncode(queryBody)
};
print("adding new query ${query[Queries.colLink]} : ${jsonEncode(queryBody)}");
await cacheDb.insert('Queries', query);
//update Cache
// Map<String,Object> data = {
// TaskType.colId: username+name,
// Category.colName: name,
// };
// await cacheDb.rawDelete("DELETE FROM Categories WHERE ${Category.colCatId}='${username+name}'");
await GetCategories(true);
//Add to server and refresh Cache
if(!bulk) {
await executeQueries();
}
}
static Future<void> executeQueries() async{
if(offline){
print("Cannot executre queries, Offline!");
return;
}
ShowProgress("Syncing");
List<Map<String,Object?>> queries = await cacheDb.query('Queries');
for(Map<String,Object?> element in queries){
@@ -559,6 +683,15 @@ class UserOperations{
offline=true;
}
}
HideProgress();
}
}
void ShowProgress(msg){
try{progressDialog?.show(max: 100, msg: msg);}catch(e){}
}
void HideProgress(){
try{progressDialog?.update(value: 100);}catch(e){}
}