ammar/syncrow-web
1
0
Fork 0
mirror of https://github.com/SyncrowIOT/web.git synced 2025-07-10 07:07:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

finished AC

Browse Source
This commit is contained in:
ashrafzarkanisala
2024-08-26 19:32:11 +03:00
parent afee0eb5b1
commit 2777dc1a5f
14 changed files with 445 additions and 446 deletions
Download Patch File Download Diff File Expand all files Collapse all files

153
lib/pages/device_managment/ac/bloc/ac_bloc.dart
View File

@ -1,31 +1,21 @@
import 'dart:async';
import 'package:bloc/bloc.dart';
import 'package:dio/dio.dart';
import 'package:flutter/material.dart';
import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:syncrow_web/pages/device_managment/all_devices/models/device_status.dart';
import 'package:syncrow_web/pages/device_managment/ac/bloc/ac_event.dart';
import 'package:syncrow_web/pages/device_managment/ac/bloc/ac_state.dart';
import 'package:syncrow_web/pages/device_managment/ac/model/ac_model.dart';
import 'package:syncrow_web/pages/device_managment/all_devices/models/device_status.dart';
import 'package:syncrow_web/services/devices_mang_api.dart';
class AcBloc extends Bloc<AcsEvent, AcsState> {
AcStatusModel deviceStatus = AcStatusModel(
uuid: '',
acSwitch: true,
modeString: 'hot',
tempSet: 300,
currentTemp: 315,
fanSpeedsString: 'low',
childLock: false,
);
late AcStatusModel deviceStatus;
final String deviceId;
Timer? _timer;
AcBloc() : super(AcsInitialState()) {
AcBloc({required this.deviceId}) : super(AcsInitialState()) {
on<AcFetchDeviceStatus>(_onFetchAcStatus);
on<AcControl>(_onAcControl);
on<AcSwitch>(_changeAcSwitch);
on<IncreaseCoolToTemp>(_increaseCoolTo);
on<DecreaseCoolToTemp>(_decreaseCoolTo);
on<ChangeLock>(_changeLockValue);
on<ChangeAcMode>(_changeAcMode);
on<ChangeFanSpeed>(_changeFanSpeed);
}
FutureOr<void> _onFetchAcStatus(
@ -34,7 +24,7 @@ class AcBloc extends Bloc<AcsEvent, AcsState> {
try {
final status =
await DevicesManagementApi().getDeviceStatus(event.deviceId);
deviceStatus = AcStatusModel.fromJson(status.productUuid, status.status);
deviceStatus = AcStatusModel.fromJson(event.deviceId, status.status);
emit(ACStatusLoaded(deviceStatus));
} catch (e) {
emit(AcsFailedState(error: e.toString()));
@ -45,47 +35,86 @@ class AcBloc extends Bloc<AcsEvent, AcsState> {
final oldValue = _getValueByCode(event.code);
_updateLocalValue(event.code, event.value);
emit(ACStatusLoaded(deviceStatus));
try {
final status = Status(code: event.code, value: event.value);
final response =
await DevicesManagementApi().deviceControl(event.deviceId, status);
await _runDebounce(
deviceId: event.deviceId,
code: event.code,
value: event.value,
oldValue: oldValue,
emit: emit,
);
}
if (!response) {
_updateLocalValue(event.code, oldValue);
emit(ACStatusLoaded(deviceStatus));
emit(AcsFailedState(error: 'Failed to control the device.'));
}
} catch (e) {
_updateLocalValue(event.code, oldValue);
emit(ACStatusLoaded(deviceStatus));
emit(AcsFailedState(error: 'Error controlling the device: $e'));
Future<void> _runDebounce({
required String deviceId,
required String code,
required dynamic value,
required dynamic oldValue,
required Emitter<AcsState> emit,
}) async {
if (_timer != null) {
_timer!.cancel();
}
_timer = Timer(const Duration(seconds: 1), () async {
try {
final response = await DevicesManagementApi()
.deviceControl(deviceId, Status(code: code, value: value));
if (!response) {
_revertValueAndEmit(deviceId, code, oldValue, emit);
}
} catch (e) {
if (e is DioException && e.response != null) {
debugPrint('Error response: ${e.response?.data}');
}
_revertValueAndEmit(deviceId, code, oldValue, emit);
}
});
}
void _revertValueAndEmit(
String deviceId, String code, dynamic oldValue, Emitter<AcsState> emit) {
_updateLocalValue(code, oldValue);
emit(ACStatusLoaded(deviceStatus));
emit(const AcsFailedState(error: 'Failed to control the device.'));
}
void _updateLocalValue(String code, dynamic value) {
switch (code) {
case 'switch':
deviceStatus.acSwitch = value;
if (value is bool) {
deviceStatus = deviceStatus.copyWith(acSwitch: value);
}
break;
case 'temp_set':
deviceStatus.tempSet = value;
if (value is int) {
deviceStatus = deviceStatus.copyWith(tempSet: value);
}
break;
case 'mode':
deviceStatus.modeString = value;
deviceStatus.acMode = AcStatusModel.getACMode(value);
if (value is String) {
deviceStatus = deviceStatus.copyWith(
modeString: value,
);
}
break;
case 'level':
deviceStatus.fanSpeedsString = value;
deviceStatus.acFanSpeed = AcStatusModel.getFanSpeed(value);
if (value is String) {
deviceStatus = deviceStatus.copyWith(
fanSpeedsString: value,
);
}
break;
case 'child_lock':
deviceStatus.childLock = value;
if (value is bool) {
deviceStatus = deviceStatus.copyWith(childLock: value);
}
break;
default:
break;
}
emit(ACStatusLoaded(deviceStatus));
}
dynamic _getValueByCode(String code) {
@ -104,50 +133,4 @@ class AcBloc extends Bloc<AcsEvent, AcsState> {
return null;
}
}
FutureOr<void> _changeAcSwitch(AcSwitch event, Emitter<AcsState> emit) async {
final newValue = !event.acSwitch;
add(AcControl(deviceId: event.deviceId, code: 'switch', value: newValue));
}
FutureOr<void> _increaseCoolTo(
IncreaseCoolToTemp event, Emitter<AcsState> emit) async {
final newValue = (event.value * 10).toInt() + 5;
if (_isValidTemperature(newValue)) {
add(AcControl(
deviceId: event.deviceId, code: 'temp_set', value: newValue));
}
}
FutureOr<void> _decreaseCoolTo(
DecreaseCoolToTemp event, Emitter<AcsState> emit) async {
final newValue = (event.value * 10).toInt() - 5;
if (_isValidTemperature(newValue)) {
add(AcControl(
deviceId: event.deviceId, code: 'temp_set', value: newValue));
}
}
FutureOr<void> _changeLockValue(
ChangeLock event, Emitter<AcsState> emit) async {
final newValue = !event.lockBool;
add(AcControl(
deviceId: event.deviceId, code: 'child_lock', value: newValue));
}
FutureOr<void> _changeAcMode(
ChangeAcMode event, Emitter<AcsState> emit) async {
final newValue = AcStatusModel.getACMode(event.tempModes.name);
add(AcControl(deviceId: event.deviceId, code: 'mode', value: newValue));
}
FutureOr<void> _changeFanSpeed(
ChangeFanSpeed event, Emitter<AcsState> emit) async {
final newValue = AcStatusModel.getFanSpeed(event.fanSpeeds.name);
add(AcControl(deviceId: event.deviceId, code: 'level', value: newValue));
}
bool _isValidTemperature(int value) {
return value >= 200 && value <= 300;
}
}

61
lib/pages/device_managment/ac/bloc/ac_event.dart
View File

@ -1,5 +1,4 @@
import 'package:equatable/equatable.dart';
import 'package:syncrow_web/pages/device_managment/ac/model/ac_model.dart';
sealed class AcsEvent extends Equatable {
const AcsEvent();
@ -31,63 +30,3 @@ class AcControl extends AcsEvent {
@override
List<Object> get props => [deviceId, code, value];
}
class AcSwitch extends AcsEvent {
final bool acSwitch;
final String deviceId;
const AcSwitch({required this.acSwitch, required this.deviceId});
@override
List<Object> get props => [acSwitch, deviceId];
}
class IncreaseCoolToTemp extends AcsEvent {
final double value;
final String deviceId;
const IncreaseCoolToTemp({required this.value, required this.deviceId});
@override
List<Object> get props => [value, deviceId];
}
class DecreaseCoolToTemp extends AcsEvent {
final double value;
final String deviceId;
const DecreaseCoolToTemp({required this.value, required this.deviceId});
@override
List<Object> get props => [value, deviceId];
}
class ChangeLock extends AcsEvent {
final bool lockBool;
final String deviceId;
const ChangeLock({required this.lockBool, required this.deviceId});
@override
List<Object> get props => [lockBool, deviceId];
}
class ChangeAcMode extends AcsEvent {
final TempModes tempModes;
final String deviceId;
const ChangeAcMode({required this.tempModes, required this.deviceId});
@override
List<Object> get props => [tempModes, deviceId];
}
class ChangeFanSpeed extends AcsEvent {
final FanSpeeds fanSpeeds;
final String deviceId;
const ChangeFanSpeed({required this.fanSpeeds, required this.deviceId});
@override
List<Object> get props => [fanSpeeds, deviceId];
}

50
lib/pages/device_managment/ac/bloc/ac_state.dart
View File

@ -14,56 +14,12 @@ class AcsLoadingState extends AcsState {}
class ACStatusLoaded extends AcsState {
final AcStatusModel status;
final DateTime timestamp;
const ACStatusLoaded(this.status);
ACStatusLoaded(this.status) : timestamp = DateTime.now();
@override
List<Object> get props => [status];
}
class AcSwitchChanged extends AcsState {
final bool acSwitch;
const AcSwitchChanged(this.acSwitch);
@override
List<Object> get props => [acSwitch];
}
class AcTempChanged extends AcsState {
final double tempSet;
const AcTempChanged(this.tempSet);
@override
List<Object> get props => [tempSet];
}
class AcModeChanged extends AcsState {
final TempModes mode;
const AcModeChanged(this.mode);
@override
List<Object> get props => [mode];
}
class AcFanSpeedChanged extends AcsState {
final FanSpeeds fanSpeed;
const AcFanSpeedChanged(this.fanSpeed);
@override
List<Object> get props => [fanSpeed];
}
class AcLockChanged extends AcsState {
final bool lock;
const AcLockChanged(this.lock);
@override
List<Object> get props => [lock];
List<Object> get props => [status, timestamp];
}
class AcsFailedState extends AcsState {