diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..24476c5
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,44 @@
+# Miscellaneous
+*.class
+*.log
+*.pyc
+*.swp
+.DS_Store
+.atom/
+.buildlog/
+.history
+.svn/
+migrate_working_dir/
+
+# IntelliJ related
+*.iml
+*.ipr
+*.iws
+.idea/
+
+# The .vscode folder contains launch configuration and tasks you configure in
+# VS Code which you may wish to be included in version control, so this line
+# is commented out by default.
+#.vscode/
+
+# Flutter/Dart/Pub related
+**/doc/api/
+**/ios/Flutter/.last_build_id
+.dart_tool/
+.flutter-plugins
+.flutter-plugins-dependencies
+.packages
+.pub-cache/
+.pub/
+/build/
+
+# Symbolication related
+app.*.symbols
+
+# Obfuscation related
+app.*.map.json
+
+# Android Studio will place build artifacts here
+/android/app/debug
+/android/app/profile
+/android/app/release
diff --git a/.metadata b/.metadata
new file mode 100644
index 0000000..2e239db
--- /dev/null
+++ b/.metadata
@@ -0,0 +1,45 @@
+# This file tracks properties of this Flutter project.
+# Used by Flutter tool to assess capabilities and perform upgrades etc.
+#
+# This file should be version controlled.
+
+version:
+ revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ channel: stable
+
+project_type: app
+
+# Tracks metadata for the flutter migrate command
+migration:
+ platforms:
+ - platform: root
+ create_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ base_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ - platform: android
+ create_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ base_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ - platform: ios
+ create_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ base_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ - platform: linux
+ create_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ base_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ - platform: macos
+ create_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ base_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ - platform: web
+ create_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ base_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ - platform: windows
+ create_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+ base_revision: d3d8effc686d73e0114d71abdcccef63fa1f25d2
+
+ # User provided section
+
+ # List of Local paths (relative to this file) that should be
+ # ignored by the migrate tool.
+ #
+ # Files that are not part of the templates will be ignored by default.
+ unmanaged_files:
+ - 'lib/main.dart'
+ - 'ios/Runner.xcodeproj/project.pbxproj'
diff --git a/analysis_options.yaml b/analysis_options.yaml
new file mode 100644
index 0000000..61b6c4d
--- /dev/null
+++ b/analysis_options.yaml
@@ -0,0 +1,29 @@
+# This file configures the analyzer, which statically analyzes Dart code to
+# check for errors, warnings, and lints.
+#
+# The issues identified by the analyzer are surfaced in the UI of Dart-enabled
+# IDEs (https://dart.dev/tools#ides-and-editors). The analyzer can also be
+# invoked from the command line by running `flutter analyze`.
+
+# The following line activates a set of recommended lints for Flutter apps,
+# packages, and plugins designed to encourage good coding practices.
+include: package:flutter_lints/flutter.yaml
+
+linter:
+ # The lint rules applied to this project can be customized in the
+ # section below to disable rules from the `package:flutter_lints/flutter.yaml`
+ # included above or to enable additional rules. A list of all available lints
+ # and their documentation is published at
+ # https://dart-lang.github.io/linter/lints/index.html.
+ #
+ # Instead of disabling a lint rule for the entire project in the
+ # section below, it can also be suppressed for a single line of code
+ # or a specific dart file by using the `// ignore: name_of_lint` and
+ # `// ignore_for_file: name_of_lint` syntax on the line or in the file
+ # producing the lint.
+ rules:
+ # avoid_print: false # Uncomment to disable the `avoid_print` rule
+ # prefer_single_quotes: true # Uncomment to enable the `prefer_single_quotes` rule
+
+# Additional information about this file can be found at
+# https://dart.dev/guides/language/analysis-options
diff --git a/android/.gitignore b/android/.gitignore
new file mode 100644
index 0000000..6f56801
--- /dev/null
+++ b/android/.gitignore
@@ -0,0 +1,13 @@
+gradle-wrapper.jar
+/.gradle
+/captures/
+/gradlew
+/gradlew.bat
+/local.properties
+GeneratedPluginRegistrant.java
+
+# Remember to never publicly share your keystore.
+# See https://flutter.dev/docs/deployment/android#reference-the-keystore-from-the-app
+key.properties
+**/*.keystore
+**/*.jks
diff --git a/android/app/build.gradle b/android/app/build.gradle
new file mode 100644
index 0000000..fd80708
--- /dev/null
+++ b/android/app/build.gradle
@@ -0,0 +1,84 @@
+def localProperties = new Properties()
+def localPropertiesFile = rootProject.file('local.properties')
+if (localPropertiesFile.exists()) {
+ localPropertiesFile.withReader('UTF-8') { reader ->
+ localProperties.load(reader)
+ }
+}
+
+def flutterRoot = localProperties.getProperty('flutter.sdk')
+if (flutterRoot == null) {
+ // throw new GradleException("Flutter SDK not found. Define location with flutter.sdk in the local.properties file.")
+}
+
+def flutterVersionCode = localProperties.getProperty('flutter.versionCode')
+if (flutterVersionCode == null) {
+ flutterVersionCode = '1'
+}
+
+def flutterVersionName = localProperties.getProperty('flutter.versionName')
+if (flutterVersionName == null) {
+ flutterVersionName = '1.0'
+}
+
+apply plugin: 'com.android.application'
+// START: FlutterFire Configuration
+apply plugin: 'com.google.gms.google-services'
+// END: FlutterFire Configuration
+apply plugin: 'kotlin-android'
+apply from: "$flutterRoot/packages/flutter_tools/gradle/flutter.gradle"
+
+android {
+ namespace "com.example.sfm_app"
+ compileSdkVersion 34
+ ndkVersion flutter.ndkVersion
+
+ compileOptions {
+ // Flag to enable support for the new language APIs
+ coreLibraryDesugaringEnabled true
+ sourceCompatibility JavaVersion.VERSION_1_8
+ targetCompatibility JavaVersion.VERSION_1_8
+ }
+
+ kotlinOptions {
+ jvmTarget = '1.8'
+ }
+
+ sourceSets {
+ main.java.srcDirs += 'src/main/kotlin'
+ }
+
+ defaultConfig {
+ // START: Flutter Local Notifications
+ multiDexEnabled true
+ // END: Flutter Local Notifications
+ // TODO: Specify your own unique Application ID (https://developer.android.com/studio/build/application-id.html).
+ applicationId "com.example.sfm_app"
+ // You can update the following values to match your application needs.
+ // For more information, see: https://docs.flutter.dev/deployment/android#reviewing-the-gradle-build-configuration.
+ minSdkVersion 23
+ targetSdkVersion 33
+ versionCode flutterVersionCode.toInteger()
+ versionName flutterVersionName
+ }
+
+ buildTypes {
+ release {
+ // TODO: Add your own signing config for the release build.
+ // Signing with the debug keys for now, so `flutter run --release` works.
+ signingConfig signingConfigs.debug
+ }
+ }
+}
+
+flutter {
+ source '../..'
+}
+
+dependencies {
+ implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
+ implementation 'com.google.firebase:firebase-messaging-directboot:20.2.0'
+ coreLibraryDesugaring 'com.android.tools:desugar_jdk_libs:1.2.2'
+ implementation 'androidx.window:window:1.0.0'
+ implementation 'androidx.window:window-java:1.0.0'
+}
diff --git a/android/app/google-services.json b/android/app/google-services.json
new file mode 100644
index 0000000..7b35503
--- /dev/null
+++ b/android/app/google-services.json
@@ -0,0 +1,29 @@
+{
+ "project_info": {
+ "project_number": "910110439150",
+ "project_id": "sfm-notification",
+ "storage_bucket": "sfm-notification.firebasestorage.app"
+ },
+ "client": [
+ {
+ "client_info": {
+ "mobilesdk_app_id": "1:910110439150:android:c3dbc3b4a85d7cb75b65ff",
+ "android_client_info": {
+ "package_name": "com.example.sfm_app"
+ }
+ },
+ "oauth_client": [],
+ "api_key": [
+ {
+ "current_key": "AIzaSyADdZ66_q4HALlb0-yEGgeyGnsbwmlvDsA"
+ }
+ ],
+ "services": {
+ "appinvite_service": {
+ "other_platform_oauth_client": []
+ }
+ }
+ }
+ ],
+ "configuration_version": "1"
+}
\ No newline at end of file
diff --git a/android/app/src/debug/AndroidManifest.xml b/android/app/src/debug/AndroidManifest.xml
new file mode 100644
index 0000000..399f698
--- /dev/null
+++ b/android/app/src/debug/AndroidManifest.xml
@@ -0,0 +1,7 @@
+
+
+
+
diff --git a/android/app/src/main/AndroidManifest.xml b/android/app/src/main/AndroidManifest.xml
new file mode 100644
index 0000000..c8e16ef
--- /dev/null
+++ b/android/app/src/main/AndroidManifest.xml
@@ -0,0 +1,76 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/android/app/src/main/kotlin/com/example/sfm_app/MainActivity.kt b/android/app/src/main/kotlin/com/example/sfm_app/MainActivity.kt
new file mode 100644
index 0000000..495c626
--- /dev/null
+++ b/android/app/src/main/kotlin/com/example/sfm_app/MainActivity.kt
@@ -0,0 +1,6 @@
+package com.example.sfm_app
+
+import io.flutter.embedding.android.FlutterActivity
+
+class MainActivity: FlutterActivity() {
+}
diff --git a/android/app/src/main/res/drawable-v21/launch_background.xml b/android/app/src/main/res/drawable-v21/launch_background.xml
new file mode 100644
index 0000000..f74085f
--- /dev/null
+++ b/android/app/src/main/res/drawable-v21/launch_background.xml
@@ -0,0 +1,12 @@
+
+
+
+ - ? items;
+
+// Device({
+// this.offset,
+// this.items,
+// });
+// Device.fromJson(Map json) {
+// offset = json['offset'];
+// if (json['items'] != null) {
+// items = [];
+// json['items'].forEach((v) {
+// items!.add(Item.fromJson(v));
+// });
+// }
+// }
+// }
+
+class Device with ClusterItem {
+ String? extId;
+ String? thingId;
+ String? thingKey;
+ List? channels;
+ String? areaPath;
+ String? fvers;
+ String? name;
+ HardwareInfo? hardwareInfo;
+ Settings? settings;
+ Status? status;
+ DateTime? connectionTime;
+ int? state;
+ String? visibility;
+ DateTime? createdAt;
+ DateTime? updatedAt;
+
+ Device({
+ this.extId,
+ this.thingId,
+ this.thingKey,
+ this.channels,
+ this.areaPath,
+ this.fvers,
+ this.name,
+ this.hardwareInfo,
+ this.settings,
+ this.status,
+ this.connectionTime,
+ this.state,
+ this.visibility,
+ this.createdAt,
+ this.updatedAt,
+ });
+ Device.fromJson(Map json) {
+ extId = json['ext_id'];
+ thingId = json['thing_id'];
+ thingKey = json['thing_key'];
+ if (json['channels'] != null) {
+ channels = [];
+ json['channels'].forEach((v) {
+ channels!.add(v);
+ });
+ }
+ areaPath = json['area_path'];
+ fvers = json['fvers'];
+ name = json['name'];
+ hardwareInfo = json['hardware_info'] != null
+ ? HardwareInfo.fromJson(json['hardware_info'])
+ : null;
+ settings =
+ json['settings'] != null ? Settings.fromJson(json['settings']) : null;
+ status = json['status'] != null ? Status.fromJson(json['status']) : null;
+ connectionTime = DateTime.parse(json['connection_time']);
+ state = json['state'];
+ visibility = json['visibility'];
+ createdAt = DateTime.parse(json['created_at']);
+ updatedAt = DateTime.parse(json['updated_at']);
+ }
+
+ static List fromJsonDynamicList(List list) {
+ return list.map((e) => Device.fromJson(e)).toList();
+ }
+
+ @override
+ LatLng get location {
+ double latitude = double.tryParse(settings?.latitude ?? '') ?? 34.639971;
+ double longitude = double.tryParse(settings?.longitude ?? '') ?? -39.664027;
+ return LatLng(latitude, longitude);
+ }
+}
+
+class HardwareInfo {
+ String? gsm;
+ String? imei;
+ String? imsi;
+ String? phone;
+ DateTime? updatedAt;
+
+ HardwareInfo({
+ this.gsm,
+ this.imei,
+ this.imsi,
+ this.phone,
+ this.updatedAt,
+ });
+ HardwareInfo.fromJson(Map json) {
+ gsm = json['gsm'];
+ imei = json['imei'];
+ imsi = json['imsi'];
+ phone = json['phone'];
+ updatedAt = DateTime.parse(json['updated_at']);
+ }
+}
+
+class Settings {
+ String? latitude;
+ String? longitude;
+ DateTime? updatedAt;
+
+ Settings({
+ this.latitude,
+ this.longitude,
+ this.updatedAt,
+ });
+ Settings.fromJson(Map json) {
+ latitude = json['latitude'];
+ longitude = json['longitude'];
+ updatedAt = DateTime.parse(json['updated_at']);
+ }
+}
+
+class Status {
+ int? readOffset;
+ List? sensors;
+ DateTime? updatedAt;
+
+ Status({
+ this.readOffset,
+ this.sensors,
+ this.updatedAt,
+ });
+
+ Status.fromJson(Map json) {
+ readOffset = json['read_offset'];
+ if (json['sensors'] != null) {
+ sensors = [];
+ json['sensors'].forEach((v) {
+ sensors!.add(Sensor.fromJson(v));
+ });
+ }
+ updatedAt = DateTime.parse(json['updated_at']);
+ }
+}
+
+class Sensor {
+ String? name;
+ int? value;
+ int? time;
+ dynamic x;
+
+ Sensor({this.name, this.value, this.time, this.x});
+ Sensor.fromJson(Map json) {
+ name = json['n'];
+ value = json['v'];
+ time = json['t'];
+ x = json['x'];
+ }
+}
diff --git a/lib/feature/devices/device_update/device_update_bloc.dart b/lib/feature/devices/device_update/device_update_bloc.dart
new file mode 100644
index 0000000..c01fc87
--- /dev/null
+++ b/lib/feature/devices/device_update/device_update_bloc.dart
@@ -0,0 +1,255 @@
+// ignore_for_file: use_build_context_synchronously
+
+import 'dart:async';
+import 'dart:convert';
+
+import 'package:flutter/material.dart';
+import 'package:google_maps_flutter/google_maps_flutter.dart';
+import 'package:intl/intl.dart';
+import '../../../product/services/api_services.dart';
+import '../../../product/services/language_services.dart';
+import '../../../product/shared/model/ward_model.dart';
+import '../../../product/utils/response_status_utils.dart';
+
+import '../../../product/shared/model/district_model.dart';
+import '../../../product/shared/model/province_model.dart';
+import '../device_model.dart';
+import '../../../product/base/bloc/base_bloc.dart';
+
+class DeviceUpdateBloc extends BlocBase {
+ APIServices apiServices = APIServices();
+
+ final deviceInfo = StreamController.broadcast();
+ StreamSink get sinkDeviceInfo => deviceInfo.sink;
+ Stream get streamDeviceInfo => deviceInfo.stream;
+
+ // DeviceUpdateScreen
+ final isChanged = StreamController.broadcast();
+ StreamSink get sinkIsChanged => isChanged.sink;
+ Stream get streamIsChanged => isChanged.stream;
+
+ final provinceData = StreamController>.broadcast();
+ StreamSink> get sinkProvinceData => provinceData.sink;
+ Stream> get streamProvinceData => provinceData.stream;
+
+ final listProvinces =
+ StreamController>>.broadcast();
+ StreamSink>> get sinkListProvinces =>
+ listProvinces.sink;
+ Stream>> get streamListProvinces =>
+ listProvinces.stream;
+
+ final districtData = StreamController>.broadcast();
+ StreamSink> get sinkDistrictData => districtData.sink;
+ Stream> get streamDistrictData => districtData.stream;
+
+ final listDistricts =
+ StreamController>>.broadcast();
+ StreamSink>> get sinkListDistricts =>
+ listDistricts.sink;
+ Stream>> get streamListDistricts =>
+ listDistricts.stream;
+
+ final wardData = StreamController>.broadcast();
+ StreamSink> get sinkWardData => wardData.sink;
+ Stream> get streamWardData => wardData.stream;
+
+ final listWards = StreamController>>.broadcast();
+ StreamSink>> get sinkListWards => listWards.sink;
+ Stream>> get streamListWards => listWards.stream;
+
+ // Show Maps in DeviceUpdateScreen
+
+ final markers = StreamController>.broadcast();
+ StreamSink> get sinkMarkers => markers.sink;
+ Stream> get streamMarkers => markers.stream;
+
+ final searchLocation = StreamController.broadcast();
+ StreamSink get sinkSearchLocation =>
+ searchLocation.sink;
+ Stream get streamSearchLocation =>
+ searchLocation.stream;
+
+ @override
+ void dispose() {
+ // deviceInfo.done;
+ }
+
+ Future getAllProvinces() async {
+ List> provincesData = [];
+ provincesData.clear();
+ sinkListProvinces.add(provincesData);
+ final body = await apiServices.getAllProvinces();
+ final data = jsonDecode(body);
+ List items = data["items"];
+
+ final provinces = Province.fromJsonDynamicList(items);
+ for (var province in provinces) {
+ provincesData.add(
+ DropdownMenuItem(value: province, child: Text(province.fullName!)));
+ }
+ sinkListProvinces.add(provincesData);
+ }
+
+ Future getAllDistricts(String provinceID) async {
+ List> districtsData = [];
+ districtsData.clear();
+ sinkListDistricts.add(districtsData);
+ final body = await apiServices.getAllDistricts(provinceID);
+ final data = jsonDecode(body);
+ List items = data["items"];
+ final districts = District.fromJsonDynamicList(items);
+ for (var district in districts) {
+ districtsData.add(
+ DropdownMenuItem(value: district, child: Text(district.fullName!)));
+ }
+ sinkListDistricts.add(districtsData);
+ }
+
+ Future getAllWards(String districtID) async {
+ List> wardsData = [];
+ wardsData.clear();
+ sinkListWards.add(wardsData);
+ final body = await apiServices.getAllWards(districtID);
+ final data = jsonDecode(body);
+ List items = data["items"];
+ final wards = Ward.fromJsonDynamicList(items);
+ for (var ward in wards) {
+ wardsData.add(DropdownMenuItem(value: ward, child: Text(ward.fullName!)));
+ }
+ sinkListWards.add(wardsData);
+ }
+
+ Future getDeviceInfomation(
+ String thingID,
+ List> districtsData,
+ List> wardsData,
+ TextEditingController deviceNameController,
+ TextEditingController latitudeController,
+ TextEditingController longitudeController) async {
+ String body = await apiServices.getDeviceInfomation(thingID);
+ final data = jsonDecode(body);
+ Device device = Device.fromJson(data);
+ sinkDeviceInfo.add(device);
+ deviceNameController.text = device.name ?? "";
+ latitudeController.text = device.settings!.latitude ?? "";
+ longitudeController.text = device.settings!.longitude ?? "";
+ if (device.areaPath != "") {
+ List areaPath = device.areaPath!.split('_');
+ String provinceCode = areaPath[0];
+ String districtCode = areaPath[1];
+ String wardCode = areaPath[2];
+ getAllDistricts(provinceCode);
+ getAllWards(districtCode);
+ final provinceResponse = await apiServices.getProvinceByID(provinceCode);
+ final provincesData = jsonDecode(provinceResponse);
+ Province province = Province.fromJson(provincesData['data']);
+ final districtResponse = await apiServices.getDistrictByID(districtCode);
+ final districtData = jsonDecode(districtResponse);
+ District district = District.fromJson(districtData['data']);
+ final wardResponse = await apiServices.getWardByID(wardCode);
+ final wardData = jsonDecode(wardResponse);
+ Ward ward = Ward.fromJson(wardData['data']);
+ Map provinceData = {
+ "name": province.fullName!,
+ "code": province.code!
+ };
+ sinkProvinceData.add(provinceData);
+ Map districData = {
+ "name": district.fullName!,
+ "code": district.code!,
+ };
+ sinkDistrictData.add(districData);
+ Map wardMap = {
+ "name": ward.fullName!,
+ "code": ward.code!,
+ };
+ sinkWardData.add(wardMap);
+ }
+ }
+
+ Future getProvinceByName(String name) async {
+ final response = await apiServices.getProvincesByName(name);
+ final data = jsonDecode(response);
+ if (data != null &&
+ data.containsKey('items') &&
+ data['items'] != null &&
+ data['items'].isNotEmpty) {
+ List items = data['items'];
+ List provinces = Province.fromJsonDynamicList(items);
+ if (provinces.isNotEmpty) {
+ return provinces[0];
+ }
+ }
+ return Province(name: "null");
+ }
+
+ Future getDistrictByName(String name, String provinceCode) async {
+ final response = await apiServices.getDistrictsByName(name);
+ if (response != "") {
+ final data = jsonDecode(response);
+ List items = data['items'];
+ if (items.isNotEmpty) {
+ List districts = District.fromJsonDynamicList(items);
+ if (districts.isNotEmpty) {
+ for (var district in districts) {
+ if (district.provinceCode == provinceCode) {
+ return district;
+ }
+ }
+ }
+ }
+ }
+ return District(name: "null");
+ }
+
+ Future getWardByName(String name, String districtCode) async {
+ final response = await apiServices.getWarsdByName(name);
+ final data = jsonDecode(response);
+ if (data != null && data['items'] != null) {
+ List items = data['items'];
+ if (items.isNotEmpty) {
+ List wards = Ward.fromJsonDynamicList(items);
+ if (wards.isNotEmpty) {
+ for (var ward in wards) {
+ if (ward.districtCode == districtCode) {
+ return ward;
+ }
+ }
+ }
+ }
+ }
+ return Ward(name: "null");
+ }
+
+ Future updateDevice(
+ BuildContext context,
+ String thingID,
+ String name,
+ String latitude,
+ String longitude,
+ String provinceCode,
+ String districtCode,
+ String wardCode,
+ ) async {
+ DateTime dateTime = DateTime.now();
+ String formattedDateTime =
+ DateFormat('yyyy-MM-dd HH:mm:ss').format(dateTime);
+ Map body = {
+ "name": name,
+ "area_province": provinceCode,
+ "area_district": districtCode,
+ "area_ward": wardCode,
+ "latitude": latitude,
+ "longitude": longitude,
+ "note": "User updated device infomation at $formattedDateTime",
+ };
+ int statusCode = await apiServices.updateOwnerDevice(thingID, body);
+ showSnackBarResponseByStatusCodeNoIcon(
+ context,
+ statusCode,
+ appLocalization(context).notification_update_device_success,
+ appLocalization(context).notification_update_device_failed,
+ );
+ }
+}
diff --git a/lib/feature/devices/device_update/device_update_screen.dart b/lib/feature/devices/device_update/device_update_screen.dart
new file mode 100644
index 0000000..2d8ffbb
--- /dev/null
+++ b/lib/feature/devices/device_update/device_update_screen.dart
@@ -0,0 +1,515 @@
+import 'package:flutter/material.dart';
+import 'package:search_choices/search_choices.dart';
+
+import '../device_model.dart';
+import 'device_update_bloc.dart';
+import 'map_dialog.dart';
+import '../../../product/base/bloc/base_bloc.dart';
+import '../../../product/extention/context_extention.dart';
+import '../../../product/services/api_services.dart';
+import '../../../product/services/language_services.dart';
+
+import '../../../product/shared/model/district_model.dart';
+import '../../../product/shared/model/province_model.dart';
+import '../../../product/shared/model/ward_model.dart';
+
+class DeviceUpdateScreen extends StatefulWidget {
+ const DeviceUpdateScreen({super.key, required this.thingID});
+ final String thingID;
+ @override
+ State createState() => _DeviceUpdateScreenState();
+}
+
+class _DeviceUpdateScreenState extends State {
+ late DeviceUpdateBloc deviceUpdateBloc;
+ APIServices apiServices = APIServices();
+ Device device = Device();
+ bool isChanged = false;
+ TextEditingController deviceNameController = TextEditingController();
+ TextEditingController deviceLatitudeController = TextEditingController();
+ TextEditingController deviceLongitudeController = TextEditingController();
+ List> provincesData = [];
+ String? selectedProvince = "";
+ List> districtsData = [];
+ String? selectedDistrict = "";
+ List> wardsData = [];
+ String? selectedWard = "";
+
+ // static String provinceCode = "";
+ // static String districtCode = "";
+ // static String wardCode = "";
+
+ Map provinceData = {};
+ Map districtData = {};
+ Map wardData = {};
+
+ @override
+ void initState() {
+ super.initState();
+ deviceUpdateBloc = BlocProvider.of(context);
+ deviceUpdateBloc.getAllProvinces();
+ }
+
+ @override
+ Widget build(BuildContext context) {
+ return Scaffold(
+ appBar: AppBar(
+ centerTitle: true,
+ title: Text(appLocalization(context).device_update_title),
+ ),
+ body: StreamBuilder>(
+ stream: deviceUpdateBloc.streamProvinceData,
+ builder: (context, provinceNameSnapshot) {
+ return StreamBuilder>(
+ stream: deviceUpdateBloc.streamDistrictData,
+ builder: (context, districtNameSnapshot) {
+ return StreamBuilder>(
+ stream: deviceUpdateBloc.streamWardData,
+ builder: (context, wardNameSnapshot) {
+ return SafeArea(
+ child: StreamBuilder(
+ stream: deviceUpdateBloc.streamDeviceInfo,
+ initialData: device,
+ builder: (context, deviceInfoSnapshot) {
+ if (deviceInfoSnapshot.data!.thingId == null) {
+ deviceUpdateBloc.getDeviceInfomation(
+ widget.thingID,
+ districtsData,
+ wardsData,
+ deviceNameController,
+ deviceLatitudeController,
+ deviceLongitudeController);
+ return const Center(
+ child: CircularProgressIndicator(),
+ );
+ } else {
+ return StreamBuilder(
+ stream: deviceUpdateBloc.streamIsChanged,
+ initialData: isChanged,
+ builder: (context, isChangedSnapshot) {
+ return SingleChildScrollView(
+ child: Padding(
+ padding: context.paddingLow,
+ child: Column(
+ mainAxisAlignment:
+ MainAxisAlignment.start,
+ crossAxisAlignment:
+ CrossAxisAlignment.start,
+ children: [
+ Text(
+ "${appLocalization(context).input_name_device_device}:",
+ style: context
+ .titleMediumTextStyle),
+ Padding(
+ padding:
+ context.paddingLowVertical,
+ child: TextField(
+ onChanged: (value) {
+ isChangedListener();
+ },
+ textInputAction:
+ TextInputAction.next,
+ controller:
+ deviceNameController,
+ decoration: InputDecoration(
+ hintText: appLocalization(
+ context)
+ .input_name_device_hintText,
+ ),
+ ),
+ ),
+ Text(
+ "${appLocalization(context).device_update_location}:",
+ style: context
+ .titleMediumTextStyle),
+ Padding(
+ padding:
+ context.paddingLowVertical,
+ child: Row(
+ mainAxisAlignment:
+ MainAxisAlignment
+ .spaceBetween,
+ children: [
+ SizedBox(
+ width: context
+ .dynamicWidth(0.6),
+ child: Column(
+ children: [
+ SizedBox(
+ child: TextField(
+ onChanged: (value) {
+ isChangedListener();
+ },
+ textInputAction:
+ TextInputAction
+ .next,
+ controller:
+ deviceLatitudeController,
+ decoration:
+ InputDecoration(
+ label: Text(
+ "${appLocalization(context).update_device_dialog_location_longitude}:"),
+ hintText: appLocalization(
+ context)
+ .update_device_dialog_location_longitude_hintText,
+ ),
+ ),
+ ),
+ Padding(
+ padding: context
+ .paddingLowVertical,
+ child: SizedBox(
+ child: TextField(
+ onChanged:
+ (value) {
+ isChangedListener();
+ },
+ controller:
+ deviceLongitudeController,
+ textInputAction:
+ TextInputAction
+ .next,
+ decoration:
+ InputDecoration(
+ label: Text(
+ "${appLocalization(context).update_device_dialog_location_latitude}:"),
+ hintText: appLocalization(
+ context)
+ .update_device_dialog_location_latitude_hintText,
+ ),
+ ),
+ ),
+ ),
+ ],
+ ),
+ ),
+ Center(
+ child: IconButton.filled(
+ style: const ButtonStyle(
+ backgroundColor:
+ MaterialStatePropertyAll(
+ Colors
+ .lightGreen)),
+ // iconSize: 24,
+ onPressed: () async {
+ showMapDialog(
+ context,
+ deviceUpdateBloc,
+ deviceLatitudeController,
+ deviceLongitudeController);
+ },
+ icon: const Icon(
+ Icons.map_outlined,
+ ),
+ ),
+ ),
+ SizedBox(
+ width: context.lowValue),
+ ],
+ ),
+ ),
+ Text(
+ "${appLocalization(context).device_update_province}:",
+ style: context
+ .titleMediumTextStyle),
+ Padding(
+ padding:
+ context.paddingLowVertical,
+ child: StreamBuilder<
+ List<
+ DropdownMenuItem<
+ Province>>>(
+ stream: deviceUpdateBloc
+ .streamListProvinces,
+ builder: (dialogContext,
+ listProvinces) {
+ return Container(
+ decoration: BoxDecoration(
+ borderRadius:
+ const BorderRadius
+ .all(
+ Radius.circular(20),
+ ),
+ border: Border.all(),
+ ),
+ child: SearchChoices.single(
+ items:
+ listProvinces.data ??
+ provincesData,
+ hint: provinceNameSnapshot
+ .data !=
+ null
+ ? Text(
+ provinceNameSnapshot
+ .data![
+ 'name'] ??
+ "",
+ )
+ : appLocalization(
+ context)
+ .update_device_dialog_location_province_hintText,
+ searchHint: appLocalization(
+ context)
+ .update_device_dialog_location_province_searchHint,
+ displayClearIcon: false,
+ onChanged: (value) {
+ isChangedListener();
+ // provinceCode =
+ // value.code;
+ selectedProvince =
+ value.fullName;
+ provinceData['name'] =
+ value.fullName;
+ provinceData['code'] =
+ value.code;
+ deviceUpdateBloc
+ .sinkProvinceData
+ .add(provinceData);
+ deviceUpdateBloc
+ .getAllDistricts(
+ value.code);
+ selectedDistrict = "";
+ districtData['name'] =
+ selectedDistrict!;
+ // deviceUpdateBloc.sinkDistrictName
+ // .add(selectedDistrict);
+ deviceUpdateBloc
+ .sinkDistrictData
+ .add(districtData);
+ selectedWard = "";
+ wardData['name'] =
+ selectedWard!;
+ deviceUpdateBloc
+ .sinkWardData
+ .add(wardData);
+ },
+ isExpanded: true,
+ ),
+ );
+ },
+ ),
+ ),
+ Text(
+ "${appLocalization(context).device_update_district}:",
+ style: context
+ .titleMediumTextStyle),
+ Padding(
+ padding:
+ context.paddingLowVertical,
+ child: StreamBuilder<
+ List<
+ DropdownMenuItem<
+ District>>>(
+ stream: deviceUpdateBloc
+ .streamListDistricts,
+ builder: (dialogContext,
+ listDistricts) {
+ return Container(
+ decoration: BoxDecoration(
+ borderRadius:
+ const BorderRadius
+ .all(
+ Radius.circular(20),
+ ),
+ border: Border.all(),
+ ),
+ child: SearchChoices.single(
+ items:
+ listDistricts.data ??
+ districtsData,
+ hint: districtNameSnapshot
+ .data !=
+ null
+ ? Text(
+ districtNameSnapshot
+ .data![
+ 'name'] ??
+ selectedDistrict!,
+ )
+ : appLocalization(
+ context)
+ .update_device_dialog_location_district_hintText,
+ searchHint: appLocalization(
+ context)
+ .update_device_dialog_location_district_searchHint,
+ displayClearIcon: false,
+ onChanged: (value) {
+ isChangedListener();
+ // districtCode =
+ // value.code;
+ selectedDistrict =
+ value.fullName;
+ districtData['name'] =
+ value.fullName!;
+ districtData['code'] =
+ value.code;
+ deviceUpdateBloc
+ .sinkDistrictData
+ .add(districtData);
+ deviceUpdateBloc
+ .getAllWards(
+ value.code);
+ selectedWard = "";
+ wardData['name'] =
+ selectedWard!;
+ deviceUpdateBloc
+ .sinkWardData
+ .add(wardData);
+ },
+ isExpanded: true,
+ ),
+ );
+ },
+ ),
+ ),
+ Text(
+ "${appLocalization(context).device_update_ward}:",
+ style: context
+ .titleMediumTextStyle),
+ Padding(
+ padding:
+ context.paddingLowVertical,
+ child: StreamBuilder<
+ List>>(
+ stream: deviceUpdateBloc
+ .streamListWards,
+ builder:
+ (dialogContext, listWards) {
+ return Container(
+ decoration: BoxDecoration(
+ borderRadius:
+ const BorderRadius
+ .all(
+ Radius.circular(
+ 20)),
+ border: Border.all()),
+ child: SearchChoices.single(
+ items: listWards.data ??
+ wardsData,
+ hint: wardNameSnapshot
+ .data !=
+ null
+ ? Text(
+ wardNameSnapshot
+ .data![
+ 'name'] ??
+ selectedWard!,
+ )
+ : appLocalization(
+ context)
+ .update_device_dialog_location_ward_hintText,
+ searchHint: appLocalization(
+ context)
+ .update_device_dialog_location_ward_searchHint,
+ displayClearIcon: false,
+ onChanged: (value) {
+ isChangedListener();
+ // wardCode = value.code;
+ selectedWard =
+ value.fullName;
+ wardData['name'] =
+ value.fullName!;
+ wardData['code'] =
+ value.code!;
+ deviceUpdateBloc
+ .sinkWardData
+ .add(wardData);
+ },
+ isExpanded: true,
+ ),
+ );
+ },
+ ),
+ ),
+ if (isChangedSnapshot.data == true)
+ Center(
+ child: SizedBox(
+ width:
+ context.dynamicWidth(0.6),
+ child: TextButton(
+ style: ButtonStyle(
+ foregroundColor:
+ MaterialStateProperty
+ .all(Colors
+ .white),
+ backgroundColor:
+ MaterialStateProperty
+ .all(Colors
+ .blue)),
+ onPressed: () async {
+ String provinceCode =
+ provinceNameSnapshot
+ .data![
+ "code"] ??
+ "";
+ String districtCode =
+ districtNameSnapshot
+ .data![
+ "code"] ??
+ "";
+ String wardCode =
+ wardNameSnapshot
+ .data![
+ "code"] ??
+ "";
+ String latitude =
+ deviceLatitudeController
+ .value.text;
+ String longitude =
+ deviceLongitudeController
+ .value.text;
+ String deviceName =
+ deviceNameController
+ .value.text;
+ // log("ProvinceCode: $provinceCode");
+ // log("DistrictCode: $districtCode");
+ // log("WardCode: $wardCode");
+ // log("Latitude: $latitude");
+ // log("Longitude: $longitude");
+ // log("Device Name: $deviceName");
+ await deviceUpdateBloc
+ .updateDevice(
+ context,
+ deviceInfoSnapshot
+ .data!.thingId!,
+ deviceName,
+ latitude,
+ longitude,
+ provinceCode,
+ districtCode,
+ wardCode,
+ );
+ Future.delayed(
+ // ignore: use_build_context_synchronously
+ context.lowDuration,
+ () {
+ Navigator.pop(
+ context);
+ });
+ },
+ child: Text(appLocalization(
+ context)
+ .update_button_content)),
+ ),
+ ),
+ ],
+ ),
+ ),
+ );
+ },
+ );
+ }
+ },
+ ),
+ );
+ });
+ });
+ }),
+ );
+ }
+
+ void isChangedListener() {
+ isChanged = true;
+ deviceUpdateBloc.sinkIsChanged.add(isChanged);
+ }
+}
diff --git a/lib/feature/devices/device_update/geocode_model.dart b/lib/feature/devices/device_update/geocode_model.dart
new file mode 100644
index 0000000..55eae98
--- /dev/null
+++ b/lib/feature/devices/device_update/geocode_model.dart
@@ -0,0 +1,47 @@
+class Geocode {
+ List? addressComponents;
+ String? formattedAddress;
+ Geocode({
+ this.addressComponents,
+ this.formattedAddress,
+ });
+
+ Geocode.fromJson(Map json) {
+ formattedAddress = json['formatted_address'];
+ if (json['address_components'] != null) {
+ addressComponents = [];
+ json['address_components'].forEach((v) {
+ addressComponents!.add(AddressComponent.fromJson(v));
+ });
+ }
+ }
+ Map toJson() {
+ final Map data = {};
+ data['formatted_address'] = formattedAddress;
+ if (addressComponents != null) {
+ data['address_components'] =
+ addressComponents!.map((e) => e.toJson()).toList();
+ }
+ return data;
+ }
+}
+
+class AddressComponent {
+ String? longName;
+ String? shortName;
+ List? types;
+ AddressComponent({this.longName, this.shortName, this.types});
+
+ AddressComponent.fromJson(Map json) {
+ longName = json['long_name'];
+ shortName = json['short_name'];
+ types = json['types'].cast();
+ }
+ Map toJson() {
+ final Map data = {};
+ data['long_name'] = longName;
+ data['short_name'] = shortName;
+ data['type'] = types;
+ return data;
+ }
+}
diff --git a/lib/feature/devices/device_update/map_dialog.dart b/lib/feature/devices/device_update/map_dialog.dart
new file mode 100644
index 0000000..5c31ead
--- /dev/null
+++ b/lib/feature/devices/device_update/map_dialog.dart
@@ -0,0 +1,298 @@
+import 'dart:async';
+import 'dart:convert';
+import 'dart:developer';
+import 'package:http/http.dart' as http;
+
+import 'package:flutter/material.dart';
+import 'package:google_maps_flutter/google_maps_flutter.dart';
+import 'device_update_bloc.dart';
+import '../../../product/constant/app/app_constants.dart';
+import '../../../product/extention/context_extention.dart';
+import '../../../product/services/language_services.dart';
+import '../../../product/shared/find_location_maps/shared_map_search_location.dart';
+
+import '../../../product/shared/find_location_maps/model/prediction_model.dart';
+import '../../../product/shared/shared_transition.dart';
+import 'geocode_model.dart';
+
+showMapDialog(
+ BuildContext context,
+ DeviceUpdateBloc deviceUpdateBloc,
+ TextEditingController latitudeController,
+ TextEditingController longitudeController) async {
+ const CameraPosition defaultPosition = CameraPosition(
+ target: LatLng(20.985424, 105.738354),
+ zoom: 12,
+ );
+ TextEditingController searchLocationController = TextEditingController();
+ TextEditingController mapDialogLatitudeController = TextEditingController();
+ TextEditingController mapDialogLongitudeController = TextEditingController();
+ Completer ggmapController = Completer();
+ final streamController = StreamController.broadcast();
+ showGeneralDialog(
+ barrierDismissible: false,
+ transitionDuration: context.normalDuration,
+ transitionBuilder: transitionsLeftToRight,
+ context: context,
+ pageBuilder: (context, animation, secondaryAnimation) {
+ return StreamBuilder>(
+ stream: deviceUpdateBloc.streamMarkers,
+ builder: (context, markerSnapshot) {
+ if (!markerSnapshot.hasData) {
+ if (latitudeController.value.text != "" &&
+ longitudeController.value.text != "") {
+ double latitude = double.parse(latitudeController.text);
+ double longitude = double.parse(longitudeController.text);
+ addMarker(
+ LatLng(latitude, longitude),
+ ggmapController,
+ deviceUpdateBloc,
+ mapDialogLatitudeController,
+ mapDialogLongitudeController,
+ );
+ }
+ }
+ return Scaffold(
+ appBar: AppBar(
+ title: Text(appLocalization(context)
+ .update_device_dialog_maps_dialog_title),
+ centerTitle: true,
+ actions: [
+ IconButton(
+ onPressed: () async {
+ String latitude = mapDialogLatitudeController.text;
+ String longitude = mapDialogLongitudeController.text;
+ log("Finish -- Latitude: $latitude, longitude: $longitude --");
+ getDataFromApi(latitude, longitude, deviceUpdateBloc);
+ latitudeController.text =
+ mapDialogLatitudeController.text;
+ longitudeController.text =
+ mapDialogLongitudeController.text;
+ bool isChange = true;
+ deviceUpdateBloc.sinkIsChanged.add(isChange);
+ Navigator.of(context).pop();
+ },
+ icon: const Icon(Icons.check))
+ ],
+ ),
+ body: Stack(
+ children: [
+ GoogleMap(
+ onTap: (location) async {
+ addMarker(
+ location,
+ ggmapController,
+ deviceUpdateBloc,
+ mapDialogLatitudeController,
+ mapDialogLongitudeController,
+ );
+ },
+ markers: markerSnapshot.data ?? {},
+ onMapCreated: (GoogleMapController mapController) {
+ ggmapController.complete(mapController);
+ streamController.add(mapController);
+ },
+ initialCameraPosition: defaultPosition,
+ ),
+ Container(
+ // color: Colors.white,
+ height: 80,
+ alignment: Alignment.topCenter,
+ padding: const EdgeInsets.all(10),
+ child: StreamBuilder(
+ stream: deviceUpdateBloc.streamSearchLocation,
+ builder: (context, searchLocation) {
+ return NearBySearchSFM(
+ textInputAction: TextInputAction.done,
+ textEditingController:
+ searchLocation.data ?? searchLocationController,
+ googleAPIKey: ApplicationConstants.MAP_KEY,
+ locationLatitude: 20.985424,
+ locationLongitude: 105.738354,
+ radius: 50000,
+ inputDecoration: InputDecoration(
+ hintText: appLocalization(context)
+ .update_device_dialog_search_location_hint,
+ border: InputBorder.none),
+ debounceTime: 600,
+ isLatLngRequired: true,
+ getPlaceDetailWithLatLng: (Prediction prediction) {
+ FocusScope.of(context).unfocus();
+ addMarker(
+ LatLng(double.parse(prediction.lat!),
+ double.parse(prediction.lng!)),
+ ggmapController,
+ deviceUpdateBloc,
+ mapDialogLatitudeController,
+ mapDialogLongitudeController);
+ },
+ itemClick: (Prediction prediction) {
+ searchLocationController.text =
+ prediction.structuredFormatting!.mainText!;
+ deviceUpdateBloc.sinkSearchLocation
+ .add(searchLocationController);
+ searchLocationController.selection =
+ TextSelection.fromPosition(TextPosition(
+ offset: prediction.structuredFormatting!
+ .mainText!.length));
+ },
+ boxDecoration: BoxDecoration(
+ color: Colors.white,
+ border: Border.all(
+ color: Colors.grey,
+ width: 0.5,
+ ),
+ borderRadius: const BorderRadius.all(
+ Radius.circular(20))),
+ );
+ }),
+ )
+ ],
+ ),
+ );
+ });
+ },
+ );
+}
+
+addMarker(
+ LatLng position,
+ Completer mapController,
+ DeviceUpdateBloc deviceUpdateBloc,
+ TextEditingController mapDialogLatitudeController,
+ TextEditingController mapDialogLongitudeController,
+) async {
+ log("AddMarker -- Latitude: ${position.latitude}, longitude: ${position.longitude} --");
+
+ Set marker = {};
+ deviceUpdateBloc.sinkMarkers.add(marker);
+ Marker newMarker = Marker(
+ markerId: const MarkerId('value'),
+ position: LatLng(position.latitude, position.longitude),
+ icon: BitmapDescriptor.defaultMarkerWithHue(BitmapDescriptor.hueGreen),
+ draggable: true,
+ onDragEnd: (position) {
+ mapDialogLatitudeController.text = position.latitude.toString();
+ mapDialogLongitudeController.text = position.longitude.toString();
+ },
+ );
+ marker.add(newMarker);
+ deviceUpdateBloc.sinkMarkers.add(marker);
+ mapDialogLatitudeController.text = position.latitude.toString();
+ mapDialogLongitudeController.text = position.longitude.toString();
+ updateCameraPosition(position, 14, mapController);
+}
+
+void getDataFromApi(String latitude, String longitude,
+ DeviceUpdateBloc deviceUpdateBloc) async {
+ String path =
+ "maps/api/geocode/json?latlng=$latitude,$longitude&language=vi&result_type=political&key=${ApplicationConstants.MAP_KEY}";
+ var url = Uri.parse('https://maps.googleapis.com/$path');
+
+ final response = await http.get(url);
+
+ if (response.statusCode != 200) {
+ log("Loi: ${response.statusCode}");
+ return;
+ }
+
+ Map data = jsonDecode(response.body);
+ if (!data.containsKey('results') || data['results'].isEmpty) {
+ log("Khong co result");
+ return;
+ }
+
+ List results = data['results'];
+ List geocodes =
+ results.map((result) => Geocode.fromJson(result)).toList();
+
+ Map locations =
+ _extractLocationComponents(geocodes[0].addressComponents!);
+
+ // In ra thông tin của các location
+ locations.forEach((key, value) {
+ log("$key: $value");
+ });
+
+ await _processLocations(locations, deviceUpdateBloc);
+}
+
+Map _extractLocationComponents(
+ List addressComponents) {
+ Map locations = {};
+
+ for (var addressComponent in addressComponents) {
+ String longName = addressComponent.longName ?? "";
+ if (addressComponent.types!.contains('administrative_area_level_3') ||
+ addressComponent.types!.contains('sublocality_level_1')) {
+ locations['wardkey'] = longName;
+ } else if (addressComponent.types!
+ .contains('administrative_area_level_2') ||
+ addressComponent.types!.contains('sublocality_level_2') ||
+ addressComponent.types!.contains('locality')) {
+ locations['districtkey'] = longName;
+ } else if (addressComponent.types!
+ .contains('administrative_area_level_1')) {
+ locations['provincekey'] = longName;
+ }
+ }
+
+ return locations;
+}
+
+Future _processLocations(
+ Map locations, DeviceUpdateBloc deviceUpdateBloc) async {
+ String provinceNameFromAPI = locations['provincekey'] ?? "";
+ String districtNameFromAPI = locations['districtkey'] ?? "";
+ String wardNameFromAPI = locations['wardkey'] ?? "";
+
+ final province =
+ await deviceUpdateBloc.getProvinceByName(provinceNameFromAPI);
+ if (province.name != "null") {
+ log("Province: ${province.fullName}, ProvinceCode: ${province.code}");
+ deviceUpdateBloc.sinkProvinceData
+ .add({"code": province.code!, "name": province.fullName!});
+ deviceUpdateBloc.getAllProvinces();
+
+ final district = await deviceUpdateBloc.getDistrictByName(
+ districtNameFromAPI, province.code!);
+ log("Districtname: ${district.fullName}, districtCode: ${district.code}");
+ deviceUpdateBloc.getAllDistricts(province.code!);
+ if (district.name != "null") {
+ deviceUpdateBloc.sinkDistrictData
+ .add({"code": district.code!, "name": district.fullName!});
+ final ward =
+ await deviceUpdateBloc.getWardByName(wardNameFromAPI, district.code!);
+ log("Wardname: ${ward.fullName}, WardCode: ${ward.code}");
+ deviceUpdateBloc.getAllWards(district.code!);
+ if (ward.name != "null") {
+ log("Xac dinh duoc het thong tin tu toa do");
+ deviceUpdateBloc.sinkWardData
+ .add({"code": ward.code!, "name": ward.fullName!});
+ } else {
+ deviceUpdateBloc.sinkWardData.add({});
+ }
+ } else {
+ deviceUpdateBloc.sinkDistrictData.add({});
+ }
+ } else {
+ deviceUpdateBloc.sinkProvinceData.add({});
+ }
+}
+
+Future updateCameraPosition(LatLng location, double zoom,
+ Completer mapController) async {
+ final CameraPosition cameraPosition = CameraPosition(
+ target: LatLng(
+ location.latitude,
+ location.longitude,
+ ),
+ zoom: zoom,
+ );
+ final GoogleMapController mapControllerNew = await mapController.future;
+ mapControllerNew.animateCamera(
+ CameraUpdate.newCameraPosition(
+ cameraPosition,
+ ),
+ );
+}
diff --git a/lib/feature/devices/devices_manager_bloc.dart b/lib/feature/devices/devices_manager_bloc.dart
new file mode 100644
index 0000000..f265938
--- /dev/null
+++ b/lib/feature/devices/devices_manager_bloc.dart
@@ -0,0 +1,35 @@
+import 'dart:async';
+import 'dart:convert';
+
+import 'device_model.dart';
+import '../../product/base/bloc/base_bloc.dart';
+import '../../product/services/api_services.dart';
+
+import '../../product/utils/device_utils.dart';
+
+class DevicesManagerBloc extends BlocBase {
+ APIServices apiServices = APIServices();
+
+ final userRole = StreamController.broadcast();
+ StreamSink get sinkUserRole => userRole.sink;
+ Stream get streamUserRole => userRole.stream;
+
+ final allDevices = StreamController>.broadcast();
+ StreamSink> get sinkAllDevices => allDevices.sink;
+ Stream> get streamAllDevices => allDevices.stream;
+
+ @override
+ void dispose() {}
+
+ void getDevice() async {
+ String body = await apiServices.getOwnerDevices();
+ if (body != "") {
+ final data = jsonDecode(body);
+ List items = data['items'];
+ List originalDevices = Device.fromJsonDynamicList(items);
+ List devices =
+ DeviceUtils.instance.sortDeviceByState(originalDevices);
+ sinkAllDevices.add(devices);
+ }
+ }
+}
diff --git a/lib/feature/devices/devices_manager_screen.dart b/lib/feature/devices/devices_manager_screen.dart
new file mode 100644
index 0000000..bc76489
--- /dev/null
+++ b/lib/feature/devices/devices_manager_screen.dart
@@ -0,0 +1,274 @@
+import 'dart:async';
+
+import 'package:flutter/material.dart';
+import 'package:go_router/go_router.dart';
+import 'add_new_device_widget.dart';
+import 'delete_device_widget.dart';
+import 'device_model.dart';
+import 'devices_manager_bloc.dart';
+import '../../product/base/bloc/base_bloc.dart';
+import '../../product/constant/enums/app_route_enums.dart';
+import '../../product/constant/enums/role_enums.dart';
+import '../../product/constant/icon/icon_constants.dart';
+import '../../product/extention/context_extention.dart';
+import '../../product/services/api_services.dart';
+import '../../product/services/language_services.dart';
+import '../../product/utils/device_utils.dart';
+
+class DevicesManagerScreen extends StatefulWidget {
+ const DevicesManagerScreen({super.key});
+
+ @override
+ State createState() => _DevicesManagerScreenState();
+}
+
+class _DevicesManagerScreenState extends State {
+ late DevicesManagerBloc devicesManagerBloc;
+ String role = "Undefine";
+ APIServices apiServices = APIServices();
+ List devices = [];
+ Timer? getAllDevicesTimer;
+
+ @override
+ void initState() {
+ super.initState();
+ devicesManagerBloc = BlocProvider.of(context);
+ getUserRole();
+ // devicesManagerBloc.getDevice();
+ // getAllOwnerDevices();
+ // const duration = Duration(seconds: 10);
+ // getAllDevicesTimer =
+ // Timer.periodic(duration, (Timer t) => devicesManagerBloc.getDevice());
+ }
+
+ @override
+ void dispose() {
+ getAllDevicesTimer?.cancel();
+ super.dispose();
+ }
+
+ @override
+ Widget build(BuildContext context) {
+ return SafeArea(
+ child: StreamBuilder>(
+ stream: devicesManagerBloc.streamAllDevices,
+ initialData: devices,
+ builder: (context, allDeviceSnapshot) {
+ if (allDeviceSnapshot.data?.isEmpty ?? devices.isEmpty) {
+ devicesManagerBloc.getDevice();
+ return const Center(child: CircularProgressIndicator());
+ } else {
+ return SingleChildScrollView(
+ child: Column(
+ mainAxisSize: MainAxisSize.min,
+ children: [
+ StreamBuilder(
+ stream: devicesManagerBloc.streamUserRole,
+ initialData: role,
+ builder: (context, roleSnapshot) {
+ return PaginatedDataTable(
+ header: Center(
+ child: Text(
+ appLocalization(context)
+ .paginated_data_table_title,
+ style: context.titleLargeTextStyle,
+ ),
+ ),
+ columns: [
+ if (roleSnapshot.data == RoleEnums.ADMIN.name ||
+ roleSnapshot.data == RoleEnums.USER.name)
+ DataColumn(
+ label: Center(
+ child: Text(appLocalization(context)
+ .paginated_data_table_column_action))),
+ DataColumn(
+ label: Center(
+ child: Text(appLocalization(context)
+ .paginated_data_table_column_deviceName))),
+ DataColumn(
+ label: Center(
+ child: Text(appLocalization(context)
+ .paginated_data_table_column_deviceStatus))),
+ DataColumn(
+ label: Center(
+ child: Text(appLocalization(context)
+ .paginated_data_table_column_deviceBaterry))),
+ DataColumn(
+ label: Center(
+ child: Text(appLocalization(context)
+ .paginated_data_table_column_deviceSignal))),
+ DataColumn(
+ label: Center(
+ child: Text(appLocalization(context)
+ .paginated_data_table_column_deviceTemperature))),
+ DataColumn(
+ label: Center(
+ child: Text(appLocalization(context)
+ .paginated_data_table_column_deviceHump))),
+ DataColumn(
+ label: Center(
+ child: Text(appLocalization(context)
+ .paginated_data_table_column_devicePower))),
+ ],
+ onPageChanged: (int pageIndex) {
+ // log('Chuyen page: $pageIndex');
+ },
+ rowsPerPage: 5,
+ actions: [
+ if (roleSnapshot.data == RoleEnums.USER.name ||
+ roleSnapshot.data == RoleEnums.ADMIN.name)
+ IconButton(
+ style: ButtonStyle(
+ backgroundColor:
+ MaterialStateProperty.all(
+ Colors.green),
+ iconColor:
+ MaterialStateProperty.all(
+ Colors.white)),
+ onPressed: () {
+ ScaffoldMessenger.of(context)
+ .clearSnackBars();
+ addNewDevice(
+ context, roleSnapshot.data ?? role);
+ },
+ icon: IconConstants.instance
+ .getMaterialIcon(Icons.add))
+ ],
+ source: DeviceSource(
+ devices: allDeviceSnapshot.data ?? devices,
+ context: context,
+ devicesBloc: devicesManagerBloc,
+ role: role));
+ })
+ ],
+ ),
+ );
+ }
+ }),
+ );
+ }
+
+ void getUserRole() async {
+ role = await apiServices.getUserRole();
+ devicesManagerBloc.sinkUserRole.add(role);
+ }
+}
+
+class DeviceSource extends DataTableSource {
+ String role;
+ APIServices apiServices = APIServices();
+ List devices;
+ final DevicesManagerBloc devicesBloc;
+ final BuildContext context;
+ DeviceSource(
+ {required this.devices,
+ required this.context,
+ required this.devicesBloc,
+ required this.role});
+ @override
+ DataRow? getRow(int index) {
+ if (index >= devices.length) {
+ return null;
+ }
+ final device = devices[index];
+ Map sensorMap = DeviceUtils.instance
+ .getDeviceSensors(context, device.status?.sensors ?? []);
+ String deviceState =
+ DeviceUtils.instance.checkStateDevice(context, device.state!);
+ return DataRow.byIndex(
+ // color: getTableRowColor(device.state!),
+ index: index,
+ cells: [
+ if (role == RoleEnums.USER.name || role == RoleEnums.ADMIN.name)
+ DataCell(
+ Center(
+ child: Row(
+ children: [
+ IconButton(
+ // style: ButtonStyle(),
+ hoverColor: Colors.black,
+ onPressed: () {
+ context.pushNamed(AppRoutes.DEVICE_UPDATE.name,
+ pathParameters: {'thingID': device.thingId!});
+ },
+ icon: const Icon(Icons.build, color: Colors.blue)),
+ IconButton(
+ onPressed: () async {
+ handleDeleteDevice(context, device.thingId!, role);
+ },
+ icon: const Icon(Icons.delete, color: Colors.red)),
+ ],
+ ),
+ ),
+ ),
+ DataCell(
+ Text(device.name!,
+ style: TextStyle(
+ color: DeviceUtils.instance
+ .getTableRowColor(device.state!))), onTap: () {
+ // log(device.thingId.toString());
+ context.pushNamed(AppRoutes.DEVICE_DETAIL.name,
+ pathParameters: {'thingID': device.thingId!});
+ }),
+ DataCell(
+ Center(
+ child: Text(deviceState,
+ style: TextStyle(
+ color: DeviceUtils.instance
+ .getTableRowColor(device.state!)))), onTap: () {
+ // log(device.thingId.toString());
+ context.pushNamed(AppRoutes.DEVICE_DETAIL.name,
+ pathParameters: {'thingID': device.thingId!});
+ }),
+ DataCell(
+ Center(
+ child: Center(
+ child: Text(sensorMap['sensorBattery'] + "%",
+ style: TextStyle(
+ color: DeviceUtils.instance
+ .getTableRowColor(device.state!))))),
+ onTap: () => context.pushNamed(AppRoutes.DEVICE_DETAIL.name,
+ pathParameters: {'thingID': device.thingId!}),
+ ),
+ DataCell(
+ Center(
+ child: Center(
+ child: Text(sensorMap['sensorCsq'],
+ style: TextStyle(
+ color: DeviceUtils.instance
+ .getTableRowColor(device.state!))))),
+ ),
+ DataCell(
+ Center(
+ child: Text(sensorMap['sensorTemp'],
+ style: TextStyle(
+ color: DeviceUtils.instance
+ .getTableRowColor(device.state!)))),
+ ),
+ DataCell(
+ Center(
+ child: Text(sensorMap['sensorHum'],
+ style: TextStyle(
+ color: DeviceUtils.instance
+ .getTableRowColor(device.state!)))),
+ ),
+ DataCell(
+ Center(
+ child: Text(sensorMap['sensorVolt'],
+ style: TextStyle(
+ color: DeviceUtils.instance
+ .getTableRowColor(device.state!)))),
+ ),
+ ],
+ );
+ }
+
+ @override
+ int get rowCount => devices.length;
+
+ @override
+ bool get isRowCountApproximate => false;
+
+ @override
+ int get selectedRowCount => 0;
+}
diff --git a/lib/feature/error/not_found_screen.dart b/lib/feature/error/not_found_screen.dart
new file mode 100644
index 0000000..e62ee83
--- /dev/null
+++ b/lib/feature/error/not_found_screen.dart
@@ -0,0 +1,36 @@
+import 'package:flutter/material.dart';
+import 'package:go_router/go_router.dart';
+import 'package:sfm_app/product/constant/enums/app_route_enums.dart';
+import 'package:sfm_app/product/constant/image/image_constants.dart';
+
+class NotFoundScreen extends StatelessWidget {
+ const NotFoundScreen({super.key});
+
+ @override
+ Widget build(BuildContext context) {
+ return Scaffold(
+ body: Stack(
+ fit: StackFit.expand,
+ children: [
+ Image.asset(
+ ImageConstants.instance.getImage('error_page'),
+ fit: BoxFit.cover,
+ ),
+ Positioned(
+ bottom: MediaQuery.of(context).size.height * 0.15,
+ left: MediaQuery.of(context).size.width * 0.3,
+ right: MediaQuery.of(context).size.width * 0.3,
+ child: TextButton(
+ onPressed: () {
+ context.goNamed(AppRoutes.LOGIN.name);
+ },
+ child: Text(
+ "Go Home".toUpperCase(),
+ ),
+ ),
+ )
+ ],
+ ),
+ );
+ }
+}
diff --git a/lib/feature/home/device_alias_model.dart b/lib/feature/home/device_alias_model.dart
new file mode 100644
index 0000000..e2ca4b7
--- /dev/null
+++ b/lib/feature/home/device_alias_model.dart
@@ -0,0 +1,79 @@
+
+import '../devices/device_model.dart';
+
+class DeviceWithAlias {
+ String? extId;
+ String? thingId;
+ String? thingKey;
+ List? channels;
+ String? areaPath;
+ String? fvers;
+ String? name;
+ HardwareInfo? hardwareInfo;
+ Settings? settings;
+ Status? status;
+ DateTime? connectionTime;
+ int? state;
+ String? visibility;
+ DateTime? createdAt;
+ DateTime? updatedAt;
+ bool? isOwner;
+ String? ownerId;
+ String? ownerName;
+ String? alias;
+
+ DeviceWithAlias({
+ this.extId,
+ this.thingId,
+ this.thingKey,
+ this.channels,
+ this.areaPath,
+ this.fvers,
+ this.name,
+ this.hardwareInfo,
+ this.settings,
+ this.status,
+ this.connectionTime,
+ this.state,
+ this.visibility,
+ this.createdAt,
+ this.updatedAt,
+ this.isOwner,
+ this.ownerId,
+ this.ownerName,
+ this.alias,
+ });
+
+ DeviceWithAlias.fromJson(Map json) {
+ extId = json['ext_id'];
+ thingId = json['thing_id'];
+ thingKey = json['thing_key'];
+ if (json['channels'] != null) {
+ channels = [];
+ json['channels'].forEach((v) {
+ channels!.add(v);
+ });
+ }
+ areaPath = json['area_path'];
+ fvers = json['fvers'];
+ name = json['name'];
+ hardwareInfo = json['hardware_info'] != null
+ ? HardwareInfo.fromJson(json['hardware_info'])
+ : null;
+ settings =
+ json['settings'] != null ? Settings.fromJson(json['settings']) : null;
+ status = json['status'] != null ? Status.fromJson(json['status']) : null;
+ connectionTime = DateTime.parse(json['connection_time']);
+ state = json['state'];
+ visibility = json['visibility'];
+ createdAt = DateTime.parse(json['created_at']);
+ updatedAt = DateTime.parse(json['updated_at']);
+ isOwner = json['is_owner'];
+ ownerId = json['owner_id'];
+ ownerName = json['owner_name'];
+ alias = json['alias'];
+ }
+ static List fromJsonDynamicList(List list) {
+ return list.map((e) => DeviceWithAlias.fromJson(e)).toList();
+ }
+}
diff --git a/lib/feature/home/home_bloc.dart b/lib/feature/home/home_bloc.dart
new file mode 100644
index 0000000..e4f7f21
--- /dev/null
+++ b/lib/feature/home/home_bloc.dart
@@ -0,0 +1,92 @@
+import 'dart:async';
+
+import 'device_alias_model.dart';
+
+import '../../product/base/bloc/base_bloc.dart';
+
+class HomeBloc extends BlocBase {
+
+ final allDevicesAlias = StreamController>.broadcast();
+ StreamSink> get sinkAllDevicesAlias =>
+ allDevicesAlias.sink;
+ Stream> get streamAllDevicesAlias =>
+ allDevicesAlias.stream;
+
+ final onlineDevicesAlias =
+ StreamController>.broadcast();
+ StreamSink> get sinkOnlineDevicesAlias =>
+ onlineDevicesAlias.sink;
+ Stream> get streamOnlineDevicesAlias =>
+ onlineDevicesAlias.stream;
+
+ final offlineDevicesAlias =
+ StreamController>.broadcast();
+ StreamSink> get sinkOfflineDevicesAlias =>
+ offlineDevicesAlias.sink;
+ Stream> get streamOfflineDevicesAlias =>
+ offlineDevicesAlias.stream;
+
+ final warningDevicesAlias =
+ StreamController>.broadcast();
+ StreamSink> get sinkWarningDevicesAlias =>
+ warningDevicesAlias.sink;
+ Stream> get streamWarningDevicesAlias =>
+ warningDevicesAlias.stream;
+
+ final notUseDevicesAlias =
+ StreamController>.broadcast();
+ StreamSink> get sinkNotUseDevicesAlias =>
+ notUseDevicesAlias.sink;
+ Stream> get streamNotUseDevicesAlias =>
+ notUseDevicesAlias.stream;
+
+ final allDevicesAliasJoined =
+ StreamController>.broadcast();
+ StreamSink> get sinkAllDevicesAliasJoined =>
+ allDevicesAliasJoined.sink;
+ Stream> get streamAllDevicesAliasJoined =>
+ allDevicesAliasJoined.stream;
+
+ final onlineDevicesAliasJoined =
+ StreamController>.broadcast();
+ StreamSink> get sinkOnlineDevicesAliasJoined =>
+ onlineDevicesAliasJoined.sink;
+ Stream> get streamOnlineDevicesAliasJoined =>
+ onlineDevicesAliasJoined.stream;
+
+ final offlineDevicesAliasJoined =
+ StreamController>.broadcast();
+ StreamSink> get sinkOfflineDevicesAliasJoined =>
+ offlineDevicesAliasJoined.sink;
+ Stream> get streamOfflineDevicesAliasJoined =>
+ offlineDevicesAliasJoined.stream;
+
+ final warningDevicesAliasJoined =
+ StreamController>.broadcast();
+ StreamSink> get sinkWarningDevicesAliasJoined =>
+ warningDevicesAliasJoined.sink;
+ Stream> get streamWarningDevicesAliasJoined =>
+ warningDevicesAliasJoined.stream;
+
+ final notUseDevicesAliasJoined =
+ StreamController>.broadcast();
+ StreamSink> get sinkNotUseDevicesAliasJoined =>
+ notUseDevicesAliasJoined.sink;
+ Stream> get streamNotUseDevicesAliasJoined =>
+ notUseDevicesAliasJoined.stream;
+
+ final countNotitication = StreamController.broadcast();
+ StreamSink get sinkCountNotitication => countNotitication.sink;
+ Stream get streamCountNotitication => countNotitication.stream;
+
+ final ownerDevicesStatus =
+ StreamController>>.broadcast();
+ StreamSink>>
+ get sinkOwnerDevicesStatus => ownerDevicesStatus.sink;
+ Stream>> get streamOwnerDevicesStatus =>
+ ownerDevicesStatus.stream;
+
+
+ @override
+ void dispose() {}
+}
diff --git a/lib/feature/home/home_screen.dart b/lib/feature/home/home_screen.dart
new file mode 100644
index 0000000..38d8aae
--- /dev/null
+++ b/lib/feature/home/home_screen.dart
@@ -0,0 +1,411 @@
+import 'dart:async';
+import 'dart:convert';
+import 'dart:developer';
+
+import 'package:flutter/material.dart';
+import 'shared/alert_card.dart';
+import 'shared/warning_card.dart';
+import '../../product/utils/device_utils.dart';
+import 'device_alias_model.dart';
+import 'shared/overview_card.dart';
+import '../settings/device_notification_settings/device_notification_settings_model.dart';
+import '../../product/extention/context_extention.dart';
+import '../../product/services/api_services.dart';
+import '../../product/services/language_services.dart';
+import 'home_bloc.dart';
+import '../../product/base/bloc/base_bloc.dart';
+
+class HomeScreen extends StatefulWidget {
+ const HomeScreen({super.key});
+
+ @override
+ State