diff --git a/lib/pages/device_managment/curtain_module/bloc/batch/curtain_module_batch_bloc.dart b/lib/pages/device_managment/curtain_module/bloc/batch/curtain_module_batch_bloc.dart
new file mode 100644
index 00000000..87dd53f7
--- /dev/null
+++ b/lib/pages/device_managment/curtain_module/bloc/batch/curtain_module_batch_bloc.dart
@@ -0,0 +1,45 @@
+import 'dart:async';
+
+import 'package:bloc/bloc.dart';
+import 'package:equatable/equatable.dart';
+import 'package:firebase_database/firebase_database.dart';
+import 'package:syncrow_web/pages/device_managment/curtain_module/models/curtain_module_model.dart';
+import 'package:syncrow_web/services/control_device_service.dart';
+import 'package:syncrow_web/services/devices_mang_api.dart';
+
+part 'curtain_module_batch_event.dart';
+part 'curtain_module_batch_state.dart';
+
+class CurtainModuleBatchBloc
+    extends Bloc<CurtainModuleBatchEvent, CurtainModuleBatchState> {
+  final ControlDeviceService controlDeviceService;
+  StreamSubscription<DatabaseEvent>? _firebaseSubscription;
+
+  CurtainModuleBatchBloc(this.controlDeviceService)
+      : super(CurtainModuleBatchInitial()) {
+    on<CutrainModuleFetchBatchStatusEvent>(_onFetchAcBatchStatus);
+  }
+
+  Future<void> _onFetchAcBatchStatus(
+    CutrainModuleFetchBatchStatusEvent event,
+    Emitter<CurtainModuleBatchState> emit,
+  ) async {
+    emit(CurtainModuleBatchLoadingState());
+    try {
+      final status =
+          await DevicesManagementApi().getBatchStatus(event.devicesIds);
+      status.status.forEach(
+        (element) => print(
+            'this is code ${element.code} - this is value ${element.value}'),
+      );
+
+      emit(
+        CurtainModuleBatchLoadedState(
+          curtainModuleStatusModel: CurtainModuleStatusModel.fromJson({}),
+        ),
+      );
+    } catch (e) {
+      emit(CurtainModuleBatchFailedState(error: e.toString()));
+    }
+  }
+}
diff --git a/lib/pages/device_managment/curtain_module/bloc/curtain_module_bloc.dart b/lib/pages/device_managment/curtain_module/bloc/curtain_module_bloc.dart
new file mode 100644
index 00000000..d79380cf
--- /dev/null
+++ b/lib/pages/device_managment/curtain_module/bloc/curtain_module_bloc.dart
@@ -0,0 +1,232 @@
+import 'dart:async';
+import 'package:bloc/bloc.dart';
+import 'package:equatable/equatable.dart';
+import 'package:firebase_database/firebase_database.dart';
+import 'package:syncrow_web/pages/device_managment/all_devices/models/device_status.dart';
+import 'package:syncrow_web/pages/device_managment/curtain_module/models/curtain_module_model.dart';
+import 'package:syncrow_web/services/control_device_service.dart';
+import 'package:syncrow_web/services/devices_mang_api.dart';
+
+part 'curtain_module_event.dart';
+part 'curtain_module_state.dart';
+
+class CurtainModuleBloc extends Bloc<CurtainModuleEvent, CurtainModuleState> {
+  final ControlDeviceService controlDeviceService;
+  StreamSubscription<DatabaseEvent>? _firebaseSubscription;
+
+  CurtainModuleBloc(this.controlDeviceService) : super(CurtainModuleInitial()) {
+    on<FetchCurtainModuleStatusEvent>(_onFetchCurtainModuleStatusEvent);
+    on<SendCurtainPercentToApiEvent>(_onSendCurtainPercentToApiEvent);
+    on<OpenCurtainEvent>(_onOpenCurtainEvent);
+    on<CloseCurtainEvent>(_onCloseCurtainEvent);
+    on<StopCurtainEvent>(_onStopCurtainEvent);
+    on<ChangeTimerControlEvent>(_onChangeTimerControlEvent);
+    on<CurCalibrationEvent>(_onChageCurCalibrationEvent);
+    on<ChangeElecMachineryModeEvent>(_onChangeElecMachineryModeEvent);
+    on<ChangeControlBackEvent>(_onChangeControlBackEvent);
+    on<ChangeControlBackModeEvent>(_onChangeControlBackModeEvent);
+    on<ChangeCurtainModuleStatusEvent>(_onChangeCurtainModuleStatusEvent);
+  }
+
+  Future<void> _onFetchCurtainModuleStatusEvent(
+    FetchCurtainModuleStatusEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    emit(CurtainModuleLoading());
+    final status = await DevicesManagementApi().getDeviceStatus(event.deviceId);
+    final result = Map.fromEntries(
+      status.status.map((element) => MapEntry(element.code, element.value)),
+    );
+
+    emit(CurtainModuleStatusLoaded(
+      curtainModuleStatus: CurtainModuleStatusModel.fromJson(result),
+    ));
+    Map<String, dynamic> statusMap = {};
+    final ref =
+        FirebaseDatabase.instance.ref('device-status/${event.deviceId}');
+    final stream = ref.onValue;
+
+    stream.listen((DatabaseEvent DatabaseEvent) async {
+      if (DatabaseEvent.snapshot.value == null) return;
+
+      Map<dynamic, dynamic> usersMap =
+          DatabaseEvent.snapshot.value as Map<dynamic, dynamic>;
+
+      List<Status> statusList = [];
+
+      usersMap['status'].forEach((element) {
+        statusList.add(Status(code: element['code'], value: element['value']));
+      });
+
+      statusMap = {
+        for (final element in statusList) element.code: element.value,
+      };
+      if (!isClosed) {
+        add(
+          ChangeCurtainModuleStatusEvent(
+            deviceId: event.deviceId,
+            status: CurtainModuleStatusModel.fromJson(statusMap),
+          ),
+        );
+      }
+    });
+  }
+
+  Future<void> _onChangeCurtainModuleStatusEvent(
+    ChangeCurtainModuleStatusEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    emit(CurtainModuleLoading());
+    emit(CurtainModuleStatusLoaded(curtainModuleStatus: event.status));
+  }
+
+  Future<void> _onSendCurtainPercentToApiEvent(
+    SendCurtainPercentToApiEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    try {
+      await controlDeviceService.controlDevice(
+        deviceUuid: event.deviceId,
+        status: event.status,
+      );
+    } catch (e) {
+      emit(CurtainModuleError(message: 'Failed to send control command: $e'));
+    }
+  }
+
+  Future<void> _onOpenCurtainEvent(
+    OpenCurtainEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    try {
+      await controlDeviceService.controlDevice(
+        deviceUuid: event.deviceId,
+        status: Status(code: 'control', value: 'open'),
+      );
+    } catch (e) {
+      emit(CurtainModuleError(message: 'Failed to open curtain: $e'));
+    }
+  }
+
+  Future<void> _onCloseCurtainEvent(
+    CloseCurtainEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    try {
+      await controlDeviceService.controlDevice(
+        deviceUuid: event.deviceId,
+        status: Status(code: 'control', value: 'close'),
+      );
+    } catch (e) {
+      emit(CurtainModuleError(message: 'Failed to close curtain: $e'));
+    }
+  }
+
+  Future<void> _onStopCurtainEvent(
+    StopCurtainEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    try {
+      await controlDeviceService.controlDevice(
+        deviceUuid: event.deviceId,
+        status: Status(code: 'control', value: 'stop'),
+      );
+    } catch (e) {
+      emit(CurtainModuleError(message: 'Failed to stop curtain: $e'));
+    }
+  }
+
+  Future<void> _onChangeTimerControlEvent(
+    ChangeTimerControlEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    try {
+      if (event.timControl < 10 || event.timControl > 120) {
+        emit(const CurtainModuleError(
+            message: 'Timer control value must be between 10 and 120'));
+        return;
+      }
+      await controlDeviceService.controlDevice(
+        deviceUuid: event.deviceId,
+        status: Status(
+          code: 'tr_timecon',
+          value: event.timControl,
+        ),
+      );
+    } catch (e) {
+      emit(CurtainModuleError(message: 'Failed to change timer control: $e'));
+    }
+  }
+
+  Future<void> _onChageCurCalibrationEvent(
+    CurCalibrationEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    try {
+      await controlDeviceService.controlDevice(
+        deviceUuid: event.deviceId,
+        status: Status(code: 'cur_calibration', value: 'start'),
+      );
+    } catch (e) {
+      emit(CurtainModuleError(message: 'Failed to start calibration: $e'));
+    }
+  }
+
+  Future<void> _onChangeElecMachineryModeEvent(
+    ChangeElecMachineryModeEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    try {
+      await controlDeviceService.controlDevice(
+        deviceUuid: event.deviceId,
+        status: Status(
+          code: 'elec_machinery_mode',
+          value: event.elecMachineryMode,
+        ),
+      );
+    } catch (e) {
+      emit(CurtainModuleError(message: 'Failed to change mode: $e'));
+    }
+  }
+
+  Future<void> _onChangeControlBackEvent(
+    ChangeControlBackEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    try {
+      await controlDeviceService.controlDevice(
+        deviceUuid: event.deviceId,
+        status: Status(
+          code: 'control_back',
+          value: event.controlBack,
+        ),
+      );
+    } catch (e) {
+      emit(CurtainModuleError(message: 'Failed to change control back: $e'));
+    }
+  }
+
+  Future<void> _onChangeControlBackModeEvent(
+    ChangeControlBackModeEvent event,
+    Emitter<CurtainModuleState> emit,
+  ) async {
+    try {
+      await controlDeviceService.controlDevice(
+        deviceUuid: event.deviceId,
+        status: Status(
+          code: 'control_back_mode',
+          value: event.controlBackMode,
+        ),
+      );
+    } catch (e) {
+      emit(CurtainModuleError(
+          message: 'Failed to change control back mode: $e'));
+    }
+  }
+
+  @override
+  Future<void> close() async {
+    await _firebaseSubscription?.cancel();
+    return super.close();
+  }
+}