实战精要：构建企业级 Flutter + OpenHarmony 工业物联网（IIoT）监控平台

// lib/models/device_state.dart
import 'package:isar/isar.dart';

@Collection()
class DeviceState {
  Id id;
  String deviceId;
  double temperature;
  bool isRunning;
  DateTime lastUpdated;

  DeviceState({
    this.id = Isar.autoIncrement,
    required this.deviceId,
    required this.temperature,
    required this.isRunning,
    required this.lastUpdated,
  });
}

@Collection()
class OperationLog {
  Id id;
  String operator;
  String action; // "START", "STOP", "ACK_ALARM"
  String deviceId;
  DateTime timestamp;
  bool syncedToCloud = false; // 标记是否已同步
}

class OfflineOperationQueue {
  final Isar _isar = Isar.getInstance();

  Future<void> enqueue(OperationLog log) async {
    await _isar.writeTxn(() async {
      await _isar.operationLogs.put(log);
    });
  }

  Stream<List<OperationLog>> get unsyncedOperations =>
      _isar.operationLogs.filter().syncedToCloudEqualTo(false).watch();

  Future<void> markAsSynced(Id logId) async {
    await _isar.writeTxn(() async {
      final log = await _isar.operationLogs.get(logId);
      if (log != null) {
        await _isar.operationLogs.put(log.copyWith(syncedToCloud: true));
      }
    });
  }
}

class CloudSyncService {
  final OfflineOperationQueue _queue = OfflineOperationQueue();

  void startSync() {
    _queue.unsyncedOperations.listen((logs) {
      if (FMLPlatform.isNetworkAvailable() && logs.isNotEmpty) {
        _uploadBatch(logs).then((success) {
          if (success) {
            for (final log in logs) {
              _queue.markAsSynced(log.id);
            }
          }
        });
      }
    });
  }
}

// 使用 ohos.security.gm 插件
final encrypted = await GmCrypto.sm4Encrypt(
  plaintext: jsonEncode(data),
  key: await _getDeviceKey(), // 从 TEE 安全存储读取
);

final signature = await GmCrypto.sm2Sign(
  data: encrypted,
  privateKey: await _getPrivateKey(),
);

// 从 TEE 读取密钥
String _deviceKey = await SecureStorage.get('sm4_key');

// 加密日志
final cipherLog = GmCrypto.sm4Encrypt(
  plaintext: jsonEncode(logEntry),
  key: _deviceKey,
);
await File('/data/logs/secure.log').writeAsString(cipherLog);

abstract class IndustrialProtocol {
  Future<Map<String, dynamic>> readRegisters(
    String deviceId,
    int startAddress,
    int count,
  );

  Future<bool> writeRegister(
    String deviceId,
    int address,
    int value,
  );
}

// native/modbus_client.cpp
extern "C" __attribute__((visibility("default")))
void modbus_read_registers(const char* ip, int port, int unit_id,
                           int addr, int count, Callback callback) {
  modbus_t* ctx = modbus_new_tcp(ip, port);
  modbus_set_slave(ctx, unit_id);
  uint16_t* tab_reg = (uint16_t*)malloc(count * sizeof(uint16_t));
  int rc = modbus_read_registers(ctx, addr, count, tab_reg);
  if (rc == -1) {
    callback(nullptr, 0);
  } else {
    callback(tab_reg, count);
  }
  modbus_close(ctx);
  modbus_free(ctx);
}

// lib/services/modbus_service.dart
class ModbusService implements IndustrialProtocol {
  @override
  Future<Map<String, dynamic>> readRegisters(String deviceId, int start, int count) async {
    final device = await _getDeviceConfig(deviceId);
    final result = await FMLPlatform.invokeMethod('modbus_read', {
      'ip': device.ip,
      'port': device.port,
      'unitId': device.unitId,
      'address': start,
      'count': count,
    });
    return _parseResult(result);
  }
}

enum TerminalType { explosionProofTablet, handheldInspector, wallMountedPanel }

class TerminalContext {
  static late final TerminalType type;
  static late final bool hasBarcodeScanner;
  static late final bool supportsNfc;

  static Future<void> initialize() async {
    final model = await FMLPlatform.getDeviceModel();
    if (model.contains('EX-Tablet')) {
      type = TerminalType.explosionProofTablet;
      hasBarcodeScanner = true;
    } else if (model.contains('Handheld-X3')) {
      type = TerminalType.handheldInspector;
      supportsNfc = true;
    }
  }
}

Widget build(BuildContext context) {
  switch (TerminalContext.type) {
    case TerminalType.handheldInspector:
      return Scaffold(
        body: Column(
          children: [
            BigButton(icon: Icons.qr_code_scanner, label: '扫码巡检'),
            BigButton(icon: Icons.mic, label: '语音记录'),
          ],
        ),
      );
    default:
      return StandardMonitorView();
  }
}

# fml.config.yaml
build:
  targets:
    - industrial_tablet
    - handheld_inspector
  signing:
    profile: industrial_secure
    algorithm: sm2
  assets:
    exclude:
      - "**/*.mp4"   # 移除视频资源
      - "debug_fonts/" # 移除调试字体