Jefry
/
Asset-App
1
0
Förgrening 0
Kod Ärenden 0 Pull-förfrågningar 0 Släpp 0 Wiki Aktiviteter
Flutter app for Asset Management
Du kan inte välja fler än 25 ämnen Ämnen måste starta med en bokstav eller siffra, kan innehålla bindestreck ('-') och vara max 35 tecken långa.
23 Incheckningar
1 Gren
1.1 MiB
 
 
 
 
Träd: b5bf339085
Grenar Taggar
${ item.name }
Skapa branchen ${ searchTerm }
från 'b5bf339085'
${ noResults }
Asset-App/lib/util/dbHandler.dart

374 rader
14 KiB
Rå Blame Historik 

  1. import 'dart:typed_data';

  2. 

  3. import 'package:assetstock/util/Models.dart';

  4. import 'package:sqflite/sqflite.dart';

  5. import 'package:path_provider/path_provider.dart';

  6. import 'prefsKey.dart';

  7. import 'dart:io';

  8. import 'dart:async';

  9. import 'package:path/path.dart';

  10. import 'package:intl/intl.dart';

  11. import 'package:assetstock/main.dart';

  12. import 'package:permission_handler/permission_handler.dart' as pHandler;

  13. 

  14. 

  15. 

  16. class DBHelper{

  17.   DBHelper._();

  18. 

  19.   static final DBHelper database = DBHelper._();

  20.   Database _db;

  21. 

  22.   Future<Database> get db async {

  23.     if (_db != null) return _db;

  24.     _db = await initDb();

  25.     return _db;

  26.   }

  27. 

  28.   backupDb(context) async{

  29.     var result = {"STATUS":0,"MSG":"Backup gagal!"};

  30.     var stock_id = prefs.getString(keyClass.dbName)??'';

  31.     if(stock_id != ''){

  32.       await util.permissionCheck(context,pHandler.Permission.storage,()async{

  33.         try{

  34.           // if(dbPath == null || dbPath == ''){

  35.           final database = await db;

  36.           var dbPath = database.path;

  37.           await DBHelper.database.closeDb();

  38.           // }

  39.           await prefs.remove(keyClass.backup_stock_id);

  40.           if(stock_id !='' && stock_id != null ) await prefs.setString(keyClass.backup_stock_id,stock_id);

  41.           //backupDatabase

  42.           print(["aaaaaa",dbPath]);

  43.           String backupPath = join(dbPath.substring(0,dbPath.indexOf("/Android"))+"/Download", "${prefs.getString(keyClass.backup_stock_id)}_assets.db");

  44.           print("bbbbbb");

  45.           File backupFile = new File(backupPath);

  46.           File dbFile = File(dbPath);

  47.           if(dbFile.existsSync()){

  48.             // dbFile.copySync(backupPath);

  49.             Uint8List byte = dbFile.readAsBytesSync();

  50.             backupFile.writeAsBytesSync(byte);

  51.             result = {"STATUS":1,"MSG":"Backup Berhasil!"};

  52.           }

  53.           else{

  54.             result = {"STATUS":0,"MSG":"Backup gagal data unit tidak ditemukan!"};

  55.             print('file backup dont exist tho');

  56.           }

  57.         }

  58.         catch(e){

  59.           print("backup gagal $e");

  60.           result = {"STATUS":0,"MSG":"Backup gagal!"};

  61.         }

  62.       },customMessage: " untuk menyimpan data backup");

  63.     }

  64.     else{

  65.       result = {"STATUS":0,"MSG":"Backup gagal data unit tidak ditemukan!"};

  66.     }

  67. 

  68.     return result;

  69.   }

  70.   restoreDb(context)async{

  71.     var result = {"STATUS":0,"MSG":"File Backup tidak ditemukan!"};

  72.     if(prefs.getString(keyClass.backup_stock_id)!=null){

  73.       await util.permissionCheck(context,pHandler.Permission.storage,()async{

  74.         Directory documentsDirectory = await getExternalStorageDirectory();

  75.         String backupPath = join(documentsDirectory.path.substring(0,documentsDirectory.path.indexOf("/Android"))+"/Download", "${prefs.getString(keyClass.backup_stock_id)}_assets.db");

  76.         File backupdbFile = File(backupPath);

  77.         if(backupdbFile.existsSync()){

  78.           File dbFile = new File(join(documentsDirectory.path, "assets.db"));

  79.           Uint8List byte = backupdbFile.readAsBytesSync();

  80.           dbFile.writeAsBytesSync(byte);

  81.           result =  {"STATUS":1,"MSG":"File Back up successfull"};

  82.           await DBHelper.database.closeDb();

  83.         }

  84.         else result =  {"STATUS":0,"MSG":"File Backup tidak ditemukan!"};

  85.       },customMessage: " untuk menyimpan data backup");

  86.     }

  87.     return result;

  88.   }

  89. 

  90.   initDb() async {

  91.     Directory documentsDirectory = await getExternalStorageDirectory();

  92.     String path = join(documentsDirectory.path, "assets.db");

  93.     var theDb = await openDatabase(path, version: 1,onCreate: _onCreate);

  94.     return theDb;

  95.   }

  96.   closeDb() async {

  97.     if(_db!=null){

  98.       final database = await db;

  99.       await database.close();

  100.       _db = null;

  101.     }

  102.   }

  103. 

  104.   void _onCreate(Database db, int version) async {

  105.     Directory documentsDirectory = await getExternalStorageDirectory();

  106.     String path = join(documentsDirectory.path, "assets.db");

  107.     File file = File(path);

  108.     print('Database created, ${file.lengthSync()}');

  109.   }

  110. 

  111.   insertAsset(Asset newAsset) async{

  112.     try{

  113.       final database = await db;

  114.       await database.rawInsert("Insert into ${tableName.insert} (${columnName.tag_number},${columnName.blob},${columnName.keterangan}) VALUES(?,?,?)", [newAsset.tag_number,newAsset.blob,newAsset.keterangan]);

  115.       await database.rawQuery("UPDATE ${tableName.ref} SET ${columnName.flag} = 'TRUE' WHERE ${columnName.tag_number} = '${newAsset.tag_number}'");

  116.       return true;

  117.     }

  118.     catch(e){

  119.       print(e);

  120.       return null;

  121.     }

  122.   }

  123. 

  124.   updateAsset(Asset newAsset) async{

  125.     try{

  126.       final database = await db;

  127.       await database.rawUpdate("Update ${tableName.insert} SET  ${columnName.blob} = ?, ${columnName.tag_number} = ?, ${columnName.keterangan} = ? WHERE ${columnName.no} = ?", [newAsset.blob,newAsset.tag_number,newAsset.keterangan,newAsset.no]);

  128.       return true;

  129.     }

  130.     catch(e){

  131.       print(e);

  132.       return null;

  133.     }

  134.   }

  135. 

  136.   getBlobbyTag(tag) async{

  137.     try{

  138.       final database = await db;

  139.       var res = await database.query(tableName.insert,where: "${columnName.tag_number} = ?",whereArgs: [tag]);

  140. //      var a = await database.rawQuery("select length(${columnName.blob}) / 1024 from ${tableName.insert} where ${columnName.no} = $no");

  141. //      print(a);

  142.       return res.isNotEmpty ? Asset.fromJson(res.first): null;

  143.     }

  144.     catch(e){

  145.       print(e);

  146.       return null;

  147.     }

  148.   }

  149.   

  150.   getBlobbyNo(no) async{

  151.     try{

  152.       final database = await db;

  153.       var res = await database.query(tableName.insert,where: "${columnName.no} = ?",whereArgs: [no]);

  154. //      var a = await database.rawQuery("select length(${columnName.blob}) / 1024 from ${tableName.insert} where ${columnName.no} = $no");

  155. //      print(a);

  156.       return res.isNotEmpty ? Asset.fromJson(res.first): null;

  157.     }

  158.     catch(e){

  159.       print(e);

  160.       return null;

  161.     }

  162.   }

  163.   // getRefBlob(tagNumber)async{

  164.   //   try{

  165.   //     final database = await db;

  166.   //     var res = await database.query(tableName.insert,where: "${columnName.tag_number} = ?",whereArgs: [tagNumber]);

  167.   //    // var a = await database.rawQuery("select count(*) from ${tableName.insert}");

  168.   //    // print(a);

  169.   //     return res.isNotEmpty ? Asset.fromJson(res.first): null;

  170.   //   }

  171.   //   catch(e){

  172.   //     print(e);

  173.   //     return null;

  174.   //   }

  175.   // }

  176.   searchbyTagNumber(tagNumber) async{

  177.     try{

  178.       final database = await db;

  179.       var exist = await database.query(tableName.insert,where: "${columnName.tag_number} = ?",whereArgs: [tagNumber]);

  180.       var res = await database.query(tableName.ref,where: "${columnName.tag_number} = ?",whereArgs: [tagNumber]);

  181.       if(res.isEmpty&&exist.isNotEmpty){

  182.         var appendAsset = new Asset();

  183.         appendAsset.tag_number=tagNumber;

  184.         return {"EXIST":exist.isNotEmpty?true:false,"DATA":appendAsset};

  185.       }

  186.       else return {"EXIST":exist.isNotEmpty?true:false,"DATA":res.isNotEmpty ? Asset.fromJson(res.first): null};

  187.     }

  188.     catch(e){

  189.       print(e);

  190.       return null;

  191.     }

  192.   }

  193. 

  194.   getAllKategori() async{

  195.     try{

  196.       final database = await db;

  197.       var res = await database.rawQuery("SELECT Distinct UPPER(${columnName.kategori}) ${columnName.kategori} from ${tableName.ref} ORDER BY UPPER(${columnName.kategori})");

  198.       List<Asset> list =

  199.             res.isNotEmpty ? res.map((c) => Asset.fromJson(c)).toList().reversed.toList() : [];

  200.       return list;

  201.     }

  202.     catch(e){

  203.       print(e);

  204.       return null;

  205.     }

  206.   }

  207. 

  208.   getAllLocation() async{

  209.     try{

  210.       final database = await db;

  211.       var res = await database.rawQuery("SELECT Distinct UPPER(${columnName.lantai}) ${columnName.lantai} from ${tableName.ref} ORDER BY UPPER(${columnName.lantai})");

  212.       List<Asset> list =

  213.       res.isNotEmpty ? res.map((c) => Asset.fromJson(c)).toList().reversed.toList() : [];

  214.       return list;

  215.     }

  216.     catch(e){

  217.       print(e);

  218.       return null;

  219.     }

  220.   }

  221.   getAllRuangan() async{

  222.     try{

  223.       final database = await db;

  224.       var res = await database.rawQuery("SELECT Distinct UPPER(${columnName.ruang}) ${columnName.ruang} from ${tableName.ref} ORDER BY UPPER(${columnName.ruang})");

  225.       List<Asset> list =

  226.       res.isNotEmpty ? res.map((c) => Asset.fromJson(c)).toList().reversed.toList() : [];

  227.       return list;

  228.     }

  229.     catch(e){

  230.       print(e);

  231.       return null;

  232.     }

  233.   }

  234. 

  235.   getLantaiRuangan(lantai) async{

  236.     try{

  237.       final database = await db;

  238.       var res = await database.rawQuery("SELECT Distinct UPPER(${columnName.ruang}) ${columnName.ruang} from ${tableName.ref} WHERE UPPER(${columnName.lantai}) = UPPER('$lantai') ORDER BY UPPER(${columnName.ruang})");

  239.       List<Asset> list =

  240.       res.isNotEmpty ? res.map((c) => Asset.fromJson(c)).toList().reversed.toList() : [];

  241.       return list;

  242.     }

  243.     catch(e){

  244.       print(e);

  245.       return null;

  246.     }

  247.   }

  248. 

  249. 

  250.   getAllAsset() async {

  251.     try{

  252.       final database = await db;

  253.       var res = await database.rawQuery("SELECT a.${columnName.tag_number}, a.${columnName.asset_desc},a.${columnName.kategori}, a.${columnName.ruang}, a.${columnName.lantai}, a.${columnName.gedung}, a.${columnName.flag}, b.${columnName.blob} from ${tableName.ref} a LEFT JOIN ${tableName.insert} b on a.${columnName.tag_number} = b.${columnName.tag_number} ORDER BY a.${columnName.flag},a.${columnName.ruang}");

  254.       List<Asset> list =

  255.       res.isNotEmpty ? res.map((c) => Asset.fromJson(c)).toList() : [];

  256.       return list;

  257.     }

  258.     catch(e){

  259.       print(e);

  260.       return null;

  261.     }

  262.   }

  263. 

  264.   filterAllAsset(search) async {

  265.     try{

  266.       final database = await db;

  267.       var res = await database.rawQuery("SELECT * FROM (SELECT a.${columnName.tag_number}, a.${columnName.asset_desc},a.${columnName.kategori}, a.${columnName.ruang}, a.${columnName.lantai}, a.${columnName.gedung}, a.${columnName.flag}, b.${columnName.blob} from ${tableName.ref} a LEFT JOIN ${tableName.insert} b on a.${columnName.tag_number} = b.${columnName.tag_number}) WHERE UPPER(${columnName.tag_number}) Like '%$search%' ORDER BY ${columnName.flag},${columnName.ruang}");

  268.       List<Asset> list =

  269.       res.isNotEmpty ? res.map((c) => Asset.fromJson(c)).toList() : [];

  270.       return list;

  271.     }

  272.     catch(e){

  273.       print(e);

  274.       return null;

  275.     }

  276.   }

  277. 

  278.   getAllInsertAsset() async {

  279.     try{

  280.       final database = await db;

  281.       // var res = await database.rawQuery("SELECT a.*, b.${columnName.asset_desc}, b.${columnName.gedung}, b.${columnName.lantai}, b.${columnName.ruang} FROM ${tableName.insert} a, ${tableName.ref} b WHERE a.${columnName.tag_number} = b.${columnName.tag_number}");

  282.       var res = await database.rawQuery("select a.*, b.${columnName.asset_desc}, b.${columnName.gedung}, b.${columnName.lantai}, b.${columnName.ruang} from ${tableName.insert} a LEFT JOIN ${tableName.ref} b ON a.${columnName.tag_number} = b.${columnName.tag_number}");

  283. 

  284.       List<Asset> list =

  285.       res.isNotEmpty ? res.map((c) => Asset.fromJson(c)).toList() : [];

  286.       return list;

  287.     }

  288.     catch(e){

  289.       print(e);

  290.       return null;

  291.     }

  292.   }

  293.   

  294.   deleteInsertAsset(no) async{

  295.     try{

  296.       final database = await db;

  297.       // await database.rawUpdate("Update ${tableName.insert} SET  ${columnName.blob} = ?, ${columnName.tag_number} = ?, ${columnName.keterangan} = ? WHERE ${columnName.no} = ?", [newAsset.blob,newAsset.tag_number,newAsset.keterangan,newAsset.no]);

  298.       await database.delete(tableName.insert,where: "${columnName.no} = ?",whereArgs: [no]);

  299.       return true;

  300.     }

  301.     catch(e){

  302.       print(e);

  303.       return null;

  304.     }

  305.   }

  306. 

  307.   filterAllInsertAsset(search) async {

  308.     try{

  309.       final database = await db;

  310.       // var res = await database.rawQuery("SELECT * FROM (SELECT a.${columnName.no},a.${columnName.keterangan},a.${columnName.tag_number},a.${columnName.blob}, b.${columnName.asset_desc}, b.${columnName.gedung}, b.${columnName.lantai}, b.${columnName.ruang} FROM ${tableName.insert} a, ${tableName.ref} b WHERE a.${columnName.tag_number} = b.${columnName.tag_number}) WHERE UPPER(${columnName.tag_number}) Like '%$search%'");

  311.       var res = await database.rawQuery("SELECT * FROM (select a.*, b.${columnName.asset_desc}, b.${columnName.gedung}, b.${columnName.lantai}, b.${columnName.ruang} from ${tableName.insert} a LEFT JOIN ${tableName.ref} b ON a.${columnName.tag_number} = b.${columnName.tag_number}) WHERE UPPER(${columnName.tag_number}) Like '%$search%'");

  312. 

  313.       List<Asset> list =

  314.       res.isNotEmpty ? res.map((c) => Asset.fromJson(c)).toList() : [];

  315.       return list;

  316.     }

  317.     catch(e){

  318.       print(e);

  319.       return null;

  320.     }

  321.   }

  322.   countRows(tableName)async{

  323.     try{

  324.       final database = await db;

  325.       var res = await database.rawQuery("SELECT Count(*) Count FROM $tableName");

  326.       return res.isEmpty?0:Count.fromJson(res.first).count;

  327.     }

  328.     catch(e){

  329.       print(e);

  330.       return null;

  331.     }

  332.   }

  333.   getDbName()async{

  334.     try{

  335.       final database = await db;

  336.       var res = await database.rawQuery("SELECT ${columnName.value} FROM ${tableName.key} where ${columnName.key} = 'DB_MASTER_NAME'");

  337.       return res.isEmpty?null:res.first[columnName.value];

  338.     }

  339.     catch(e){

  340.       print(e);

  341.       return null;

  342.     }

  343.   }

  344.   getBUnit()async{

  345.     try{

  346.       final database = await db;

  347.       var res = await database.rawQuery("SELECT ${columnName.value} FROM ${tableName.key} where ${columnName.key} = 'BUSINESS_UNIT'");

  348.       return res.isEmpty?null:res.first[columnName.value];

  349.     }

  350.     catch(e){

  351.       print(e);

  352.       return null;

  353.     }

  354.   }

  355.   setOpenState()async{

  356.     try{

  357.       final database = await db;

  358.       var check_KEY = await database.rawQuery("SELECT 1 FROM ${tableName.key} where ${columnName.key} = 'STATE'");

  359.       if (check_KEY.length<=0){

  360.         await database.insert(tableName.key, {columnName.key:"STATE",columnName.value:"OPEN"});

  361.       }

  362.       else{

  363.         await database.update(tableName.key, {columnName.value:"OPEN"},where: "${columnName.key} = ?",whereArgs: ['STATE']);

  364.       }

  365.       await database.update(tableName.key, {columnName.value:DateFormat("YYYY-MM-DD HH:mm:ss").format(DateTime.now())},where: "${columnName.key} = ?",whereArgs: ['START_DATE']);

  366.     }

  367.     catch(e){

  368.       print(e);

  369.       return null;

  370.     }

  371.   }

  372. 

  373. }