app-starlock/star_lock/lib/main/lockDetail/lcokSet/configuringWifi/configuringWifi_logic.dart

import 'dart:async';

import 'package:flutter_reactive_ble/flutter_reactive_ble.dart';
import 'package:network_info_plus/network_info_plus.dart';
import 'package:permission_handler/permission_handler.dart';
import 'package:star_lock/tools/baseGetXController.dart';

import '../../../../blue/blue_manage.dart';
import '../../../../blue/io_protocol/io_configuringWifi.dart';
import '../../../../blue/io_reply.dart';
import '../../../../blue/io_tool/io_manager.dart';
import '../../../../blue/io_tool/io_tool.dart';
import '../../../../blue/io_tool/manager_event_bus.dart';
import '../../../../blue/sender_manage.dart';
import '../../../../network/api_repository.dart';
import '../../../../tools/storage.dart';
import 'configuringWifi_state.dart';

class ConfiguringWifiLogic extends BaseGetXController{
  final ConfiguringWifiState state = ConfiguringWifiState();

  Future<void> getWifiLockServiceIpAndPort() async {
    var entity = await ApiRepository.to.getWifiLockServiceIpAndPort();
    if(entity.errorCode! == 0){
      state.configuringWifiEntity.value = entity;
    }
  }

  // 监听设备返回的数据
  late StreamSubscription<Reply> _replySubscription;
  void _initReplySubscription() {
    _replySubscription = EventBusManager().eventBus!.on<Reply>().listen((reply) async {
      // 配置wifi
      if(reply is SenderConfiguringWifiReply) {
        _replySenderConfiguringWifi(reply);
      }
    });
  }

  // 开门数据解析
  Future<void> _replySenderConfiguringWifi(Reply reply) async {
    var privateKey = await Storage.getStringList(saveBluePrivateKey);
    List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);

    var signKey = await Storage.getStringList(saveBlueSignKey);
    List<int> signKeyDataList = changeStringListToIntList(signKey!);

    var tokenData = reply.data.sublist(2, 6);
    var saveStrList = changeIntListToStringList(tokenData);
    print("openDoorToken:$tokenData");
    Storage.setStringList(saveBlueToken, saveStrList);

    int status = reply.data[6];
    print("status:$status");

    switch(status){
      case 0x00:
      //成功
        print("${reply.commandType}数据解析成功");

        break;
      case 0x06:
      //无权限
        print("${reply.commandType}需要鉴权");

        IoSenderManage.senderOpenLock(
          keyID: "1",
          userID: await Storage.getUid(),
          openMode: 1,
          openTime: DateTime.now().millisecondsSinceEpoch,
          token: tokenData,
          needAuthor: 1,
          signKey: signKeyDataList,
          privateKey: getPrivateKeyList,
        );

        break;
      case 0x07:
      //无权限
        print("${reply.commandType}用户无权限");

        break;
      case 0x09:
      // 权限校验错误
        print("${reply.commandType}校验错误");

        break;
      default:
      //失败
        print("${reply.commandType}失败");

        break;
    }
  }

  // 点击配置wifi
  Future<void> senderConfiguringWifiAction() async {
    BlueManage().judgeReconnect(BlueManage().connectDeviceMacAddress, BlueManage().connectDeviceName, (DeviceConnectionState connectionState) async {
      if (connectionState == DeviceConnectionState.connected){
        var privateKey = await Storage.getStringList(saveBluePrivateKey);
        List<int> getPrivateKeyList = changeStringListToIntList(privateKey!);

        var publicKey = await Storage.getStringList(saveBluePublicKey);
        List<int> publicKeyDataList = changeStringListToIntList(publicKey!);

        var token = await Storage.getStringList(saveBlueToken);
        List<int> getTokenList = changeStringListToIntList(token!);
        print("openDoorTokenPubToken:$getTokenList");

        print("millisecondsSinceEpoch/1000:${DateTime.now().millisecondsSinceEpoch~/1000}");
        IoSenderManage.senderConfiguringWifiCommand(
          keyID: "1",
          userID: await Storage.getUid(),
          ssid: state.wifiNameController.text,
          password: state.wifiPWDController.text,
          numberOfServers: state.configuringWifiEntity.value.data!.serviceNum,
          listOfServers: 0,
          token: getTokenList,
          needAuthor: 1,
          publicKey: publicKeyDataList,
          privateKey: getPrivateKeyList,
        );
      }
    });
  }

  final _networkInfo = NetworkInfo();
  Future<String> getWifiName() async {
    // if(!(await checkLocationPermission())) {
    //   print("未获取定位权限");
    //   return '';
    // }
    var ssid = '';
    ssid = (await _networkInfo.getWifiName())!;
    ssid = ssid ?? '';
    ssid = ssid.replaceAll(r'"', '');
    print("ssid:$ssid");
    return ssid ?? '';
  }

  ///定位权限
  Future<bool> checkLocationPermission() async {
    PermissionStatus value = await locationPermission();
    bool allow = value != PermissionStatus.permanentlyDenied && value != PermissionStatus.denied;
    return allow;
  }

  Future<PermissionStatus> locationPermission() async => Permission.location.request();

  @override
  void onReady() {
    // TODO: implement onReady
    super.onReady();

    getWifiName().then((value) {
      print("wifiName:$value");
      state.wifiNameController.text = value;
    });

    getWifiLockServiceIpAndPort();
    _initReplySubscription();
  }

  @override
  void onInit() {
    // TODO: implement onInit
    super.onInit();
  }

  @override
  void onClose() {
    // TODO: implement onClose
  }
}