552 lines
19 KiB
Dart
552 lines
19 KiB
Dart
import 'dart:async';
|
||
import 'dart:convert';
|
||
|
||
import 'package:EasyDartModule/EasyDartModule.dart' as edm;
|
||
import 'package:easydevice/easydevice.dart';
|
||
import 'package:easyweb/base/easyws.dart';
|
||
import 'package:easyweb/base/minisdk.dart';
|
||
import 'package:easyweb/easyweb.dart';
|
||
import 'package:ef/ef.dart';
|
||
import 'package:flutter/material.dart';
|
||
import 'package:vbvs_app/common/color/ServiceConstant.dart';
|
||
import 'package:vbvs_app/common/util/FitTool.dart';
|
||
import 'package:vbvs_app/common/util/MyUtils.dart';
|
||
import 'package:vbvs_app/common/util/requestWithLog.dart';
|
||
import 'package:vbvs_app/controller/user_info_controller.dart';
|
||
import 'package:vbvs_app/model/WebSocketMessage.dart';
|
||
import 'package:vbvs_app/pages/mh_page/device/controller/mht_bluetooth_controller.dart';
|
||
import 'package:vbvs_app/pages/mh_page/homepage/controller/mht_home_controller.dart';
|
||
|
||
class WebviewTestModel {
|
||
WebviewTestModel();
|
||
|
||
//EasyFlutter Start[Model]
|
||
|
||
//EasyFlutter End
|
||
}
|
||
|
||
class WebviewTestController extends GetControllerEx<WebviewTestModel> {
|
||
var selectDevice = {};
|
||
var lastSelectDevice = {};
|
||
var bluetooth = 0;
|
||
List personList = [];
|
||
List instantData = [];
|
||
RxBool initFlag = false.obs;
|
||
Timer? _resourceLoadTimer;
|
||
Widget webviewWidget = Container();
|
||
|
||
WebviewTestController() : super(WebviewTestModel()) {
|
||
web = WebviewHelper(
|
||
isheadless: false,
|
||
jsbridge: buildsdk(
|
||
// father: this,
|
||
// clientId: '494641114',
|
||
// dbgserverUrl: 'ws://192.168.1.2:9001',
|
||
),
|
||
settings: buildsettings(),
|
||
params: PlatformHeadlessInAppWebViewCreationParams(
|
||
onLoadStop: (controller, url) {
|
||
setState(() {
|
||
ready.value = true;
|
||
});
|
||
},
|
||
onLoadResource: (controller, resource) {
|
||
sourceTime = web.requestTimestamp;
|
||
ef.log("[请求资源时间]${web.requestTimestamp}");
|
||
_startMonitoringIfNeeded();
|
||
},
|
||
),
|
||
);
|
||
try {
|
||
web.jsbridge!.bind((bridge) {
|
||
var minible = Minibleapp(bridge: bridge);
|
||
// ef.kvroot.devicelist.listen((x) {});
|
||
bridge.sdk.updateDeviceRoute((args) async {
|
||
ef.log('updateDeviceRoute: $args');
|
||
selectDevice['blueToothStatus'] = bluetooth;
|
||
Get.toNamed("${args[0]}", arguments: selectDevice);
|
||
return true;
|
||
});
|
||
bridge.sdk.selectDevice((args) async {
|
||
try {
|
||
ef.log('selectDevice: $args');
|
||
selectDevice = args[0];
|
||
await queryPersonInfoByMac();
|
||
if (selectDevice != null &&
|
||
selectDevice.isNotEmpty &&
|
||
selectDevice['mac'.tr] != null &&
|
||
(selectDevice['mac'.tr] != args[0]['mac'.tr])) {
|
||
lastSelectDevice = selectDevice;
|
||
}
|
||
edm.EasyDartModule.websocket.sendData(jsonEncode(
|
||
WebSocketMessage(path: "/smartbed/connect", type: 5, data: {
|
||
'mac'.tr: selectDevice['mac'.tr],
|
||
})));
|
||
dealInstantData(selectDevice);
|
||
} catch (e) {
|
||
ef.log("[切换设备失败]$e");
|
||
}
|
||
//查询人员信息
|
||
return true;
|
||
});
|
||
bridge.sdk.updateBlueToothStatus((args) async {
|
||
ef.log('updateBlueToothStatus: $args');
|
||
bluetooth = args[0];
|
||
selectDevice['blueToothStatus'] = bluetooth;
|
||
return true;
|
||
});
|
||
//sdk定义接口
|
||
bridge.sdk.querySelectDevice((args) async {
|
||
ef.log('querySelectDevice: $args');
|
||
// bluetooth = args[0];
|
||
MHTHomeController deviceController = Get.find();
|
||
await deviceController.getDeviceList(group: 'room');
|
||
final allDevices = deviceController.deviceList.values
|
||
.expand((list) => list)
|
||
.toList();
|
||
return allDevices;
|
||
});
|
||
//请求token信息
|
||
bridge.sdk.queryUserToken((args) async {
|
||
ef.log('queryUserToken: $args');
|
||
// bluetooth = args[0];
|
||
return edm.EasyDartModule.dio.token;
|
||
});
|
||
//请求设备人员信息
|
||
bridge.sdk.queryPersonInfo((args) async {
|
||
ef.log('queryPersonInfo: $args');
|
||
// bluetooth = args[0];
|
||
return personList;
|
||
});
|
||
//请求实时体征数据
|
||
bridge.sdk.queryInstantData((args) async {
|
||
ef.log('queryInstantData: $args');
|
||
// bluetooth = args[0];
|
||
return instantData;
|
||
});
|
||
bridge.sdk.startTimer((args) async {
|
||
ef.log('queryInstantData: $args');
|
||
MHTHomeController homeController = Get.find();
|
||
homeController.startTimer(args);
|
||
return true;
|
||
});
|
||
bridge.sdk.cancelTimer((args) async {
|
||
ef.log('queryInstantData: $args');
|
||
MHTHomeController homeController = Get.find();
|
||
homeController.cancelTimer(args);
|
||
return true;
|
||
});
|
||
bridge.sdk.restoreTimer((args) async {
|
||
ef.log('更新定时: $args[0]');
|
||
ef.log('queryInstantData: $args');
|
||
MHTHomeController homeController = Get.find();
|
||
var data = await homeController.restoreTimer(args);
|
||
return data;
|
||
});
|
||
bridge.sdk.toBindDevice((args) async {
|
||
ef.log('queryInstantData: $args');
|
||
Get.toNamed("/mHTDeviceTypePage");
|
||
return true;
|
||
});
|
||
bridge.sdk.saveSleepHabit((args) async {
|
||
ef.log('更新睡眠习惯: $args[0]');
|
||
try {
|
||
MHTBlueToothController blueToothController = Get.find();
|
||
await blueToothController.saveHabitData(args[0]);
|
||
} catch (e) {
|
||
ef.log("[更新睡眠习惯失败]:$e");
|
||
}
|
||
return true;
|
||
});
|
||
bridge.sdk.loadSleepHabit((args) async {
|
||
ef.log('查询睡眠习惯: $args[0]');
|
||
try {
|
||
MHTBlueToothController blueToothController = Get.find();
|
||
var sleepData = await blueToothController.loadHabitDataApi(args[0]);
|
||
return sleepData['data'];
|
||
} catch (e) {
|
||
ef.log("[查询睡眠习惯失败]:$e");
|
||
}
|
||
return true;
|
||
});
|
||
//--
|
||
bridge.sdk.saveMattressTimeData((args) async {
|
||
ef.log('更新睡眠习惯: $args[0]');
|
||
try {
|
||
MHTBlueToothController blueToothController = Get.find();
|
||
await blueToothController.saveMattressTimeData(args[0]);
|
||
} catch (e) {
|
||
ef.log("[更新睡眠习惯失败]:$e");
|
||
}
|
||
return true;
|
||
});
|
||
bridge.sdk.loadMattressTimeData((args) async {
|
||
ef.log('查询睡眠习惯: $args[0]');
|
||
try {
|
||
MHTBlueToothController blueToothController = Get.find();
|
||
var sleepData =
|
||
await blueToothController.loadMattressTimeData(args[0]);
|
||
return sleepData['data'];
|
||
} catch (e) {
|
||
ef.log("[查询睡眠习惯失败]:$e");
|
||
}
|
||
return true;
|
||
});
|
||
bridge.sdk.saveMemory((args) async {
|
||
ef.log('更新记忆: $args[0]');
|
||
try {
|
||
MHTBlueToothController blueToothController = Get.find();
|
||
// await blueToothController.saveHabitData(args[0]);
|
||
await blueToothController.saveJiYiData(args[0]);
|
||
} catch (e) {
|
||
ef.log("[更新记忆失败]:$e");
|
||
}
|
||
return true;
|
||
});
|
||
bridge.sdk.loadMemory((args) async {
|
||
try {
|
||
ef.log('查询记忆: $args[0]');
|
||
MHTBlueToothController blueToothController = Get.find();
|
||
var sleepData = await blueToothController.loadJiYiData(args[0]);
|
||
return sleepData['data'];
|
||
} catch (e) {
|
||
ef.log("[查询记忆失败]:$e");
|
||
}
|
||
return true;
|
||
});
|
||
bridge.sdk.webPageBuild((args) async {
|
||
ef.log('网页加载完成: $args[0]');
|
||
try {
|
||
initFlag.value = true;
|
||
return true;
|
||
} catch (e) {
|
||
ef.log("[网页加载失败]:$e");
|
||
}
|
||
return true;
|
||
});
|
||
// bridge.sdk.bluetoothConnect((args) async {
|
||
// ef.log('[蓝牙连接失败]: $args[0]');
|
||
// try {
|
||
// selectDevice['blueToothStatus'] = 2;
|
||
// return true;
|
||
// } catch (e) {
|
||
// ef.log("[蓝牙连接失败]:$e");
|
||
// }
|
||
// return true;
|
||
// });
|
||
});
|
||
} catch (e, s) {
|
||
ef.log('$e,$s');
|
||
}
|
||
}
|
||
late WebviewHelper web;
|
||
var ready = false.obs;
|
||
var cnt = 0.obs;
|
||
var loadRecource = false.obs;
|
||
int sourceTime = 0;
|
||
|
||
Future<void> queryPersonInfoByMac() async {
|
||
UserInfoController userInfoController = Get.find();
|
||
String serviceAddress = ServiceConstant.service_address;
|
||
String serviceName = ServiceConstant.server_service;
|
||
String serviceApi = ServiceConstant.person_info;
|
||
String queryUrl =
|
||
"${serviceAddress}${serviceName}${serviceApi}?mac=${selectDevice['mac']}";
|
||
try {
|
||
final res = await requestWithLog(
|
||
logTitle: "查询设备绑定人员列表".tr,
|
||
method: MyHttpMethod.get,
|
||
queryUrl: queryUrl,
|
||
onSuccess: (res) {
|
||
personList = res.data;
|
||
});
|
||
} catch (e) {
|
||
print("查询设备绑定列表失败: $e");
|
||
}
|
||
}
|
||
|
||
void dealInstantData(selectDevice) {
|
||
//处理实时数据
|
||
// edm.EasyDartModule.websocket.sendData(
|
||
// jsonEncode(WebSocketMessage(path: "/vsbs/web/rt/marttress", type: 2)));
|
||
lastSelectDevice;
|
||
var ws;
|
||
ws = Easyws(
|
||
url: ServiceConstant.webSocketService,
|
||
onData: (data) {
|
||
ef.log("ws recv =>$data");
|
||
try {
|
||
var tmp;
|
||
if (data is String) {
|
||
tmp = jsonDecode(data);
|
||
} else if (data is Map<String, dynamic>) {
|
||
tmp = data; // 直接用
|
||
} else {
|
||
print("未知数据格式".tr);
|
||
}
|
||
if (tmp['data'] != null && tmp['data'] is Map) {
|
||
var newData = tmp['data'];
|
||
var mac = newData['mac'.tr];
|
||
if (mac != null) {
|
||
// 删除已有的同 mac 项
|
||
instantData.removeWhere((element) => element['mac'.tr] == mac);
|
||
// 添加新的数据
|
||
instantData.add(newData);
|
||
}
|
||
}
|
||
} catch (e) {
|
||
ef.log("ws error =>$e");
|
||
}
|
||
},
|
||
onStateChange: (x) {
|
||
ef.log("ws =>$x");
|
||
if (x == EasywsState.connected) {
|
||
try {
|
||
if (lastSelectDevice != null && lastSelectDevice.isNotEmpty) {
|
||
List<String?> oldMacList = [
|
||
lastSelectDevice['bind_mac_a'],
|
||
lastSelectDevice['bind_mac_b'],
|
||
];
|
||
for (String? mac in oldMacList) {
|
||
if (mac != null && mac.isNotEmpty) {
|
||
bool success = ws.send({
|
||
"type": 2,
|
||
"path": "/vsbs/web/rt/marttress",
|
||
"data": {"mac".tr: mac},
|
||
});
|
||
if (success) {
|
||
ef.log("✅ 已取消监听：$mac");
|
||
}
|
||
}
|
||
}
|
||
}
|
||
} catch (e) {
|
||
ef.log("❌ 取消旧设备监听失败: $e");
|
||
}
|
||
try {
|
||
// 2. 开始监听新设备（A/B 都监听）
|
||
if (selectDevice != null && selectDevice.isNotEmpty) {
|
||
List<String?> newMacList = [
|
||
selectDevice['bind_mac_a'],
|
||
selectDevice['bind_mac_b'],
|
||
];
|
||
for (String? mac in newMacList) {
|
||
if (mac != null && mac.isNotEmpty) {
|
||
bool success = ws.send({
|
||
"type": 1,
|
||
"path": "/vsbs/web/rt/marttress",
|
||
"data": {"mac".tr: mac},
|
||
});
|
||
if (success) {
|
||
ef.log("✅ 开始监听新设备：$mac");
|
||
}
|
||
}
|
||
}
|
||
|
||
// 更新记录
|
||
lastSelectDevice = selectDevice;
|
||
}
|
||
} catch (e) {
|
||
ef.log("❌ 监听新设备失败: $e");
|
||
}
|
||
}
|
||
},
|
||
);
|
||
ws.connect();
|
||
}
|
||
//EasyFlutter End
|
||
|
||
@override
|
||
void onInit() {
|
||
ef.log("webview test init =>${DateTime.now()}");
|
||
super.onInit();
|
||
try {
|
||
web.runApp('mhtControl').then((x) {
|
||
ready.value = true;
|
||
});
|
||
// web
|
||
// .network('https://wyf.it.real.he-info.cn:94/goods-front/index.html')
|
||
// .then((x) {
|
||
// ready.value = true;
|
||
// });
|
||
} catch (e, s) {
|
||
ef.log('$e,$s');
|
||
}
|
||
}
|
||
|
||
void _startMonitoringIfNeeded() {
|
||
// 如果定时器已启动，则无需重新启动
|
||
if (_resourceLoadTimer != null) return;
|
||
|
||
_resourceLoadTimer = Timer.periodic(Duration(seconds: 1), (timer) {
|
||
int now = DateTime.now().millisecondsSinceEpoch;
|
||
|
||
if (sourceTime == 0) return; // 还未加载任何资源
|
||
|
||
if (now - sourceTime > 3000) {
|
||
ef.log("[资源加载完成] 当前时间: $now, 上次请求时间: $sourceTime");
|
||
_resourceLoadTimer?.cancel();
|
||
_resourceLoadTimer = null;
|
||
loadRecource.value = true;
|
||
updateAll();
|
||
}
|
||
});
|
||
}
|
||
}
|
||
|
||
class WebviewTestView extends GetComponent<WebviewTestController> {
|
||
WebviewTestView({super.key, super.oncreate});
|
||
|
||
@override
|
||
WebviewTestController newinstance() {
|
||
if (ef.kvRoot.WebviewTestController == null) {
|
||
ef.kvRoot.WebviewTestController = WebviewTestController();
|
||
if (Get.isRegistered<WebviewTestController>() == false) {
|
||
Get.put<WebviewTestController>(ef.kvRoot.WebviewTestController);
|
||
WebviewTestController webviewTestController = Get.find();
|
||
webviewTestController.global = true;
|
||
return webviewTestController;
|
||
}
|
||
}
|
||
return ef.kvRoot.WebviewTestController;
|
||
}
|
||
|
||
@override
|
||
Widget build(BuildContext context) {
|
||
// controller.webviewWidget = controller.web.build();
|
||
return Obx(() {
|
||
UserInfoController userInfoController = Get.find();
|
||
MHTHomeController deviceController = Get.find();
|
||
final isLoggedIn = userInfoController.model.login == 1;
|
||
final hasDevice = deviceController.deviceList.values.isNotEmpty;
|
||
|
||
final showWeb = isLoggedIn && hasDevice;
|
||
final mainAxisAlignment =
|
||
showWeb ? MainAxisAlignment.start : MainAxisAlignment.center;
|
||
|
||
return Scaffold(
|
||
backgroundColor: Colors.transparent,
|
||
body: Column(
|
||
crossAxisAlignment: CrossAxisAlignment.center,
|
||
mainAxisSize: MainAxisSize.max,
|
||
mainAxisAlignment: mainAxisAlignment,
|
||
children: [
|
||
// 未登录提示
|
||
if (!isLoggedIn)
|
||
Center(
|
||
child: InkWell(
|
||
onTap: () => Get.toNamed("/loginPage"),
|
||
child: RichText(
|
||
text: TextSpan(
|
||
children: [
|
||
TextSpan(
|
||
text: "请先".tr,
|
||
style: TextStyle(
|
||
color: Colors.white,
|
||
fontSize: 30.rpx,
|
||
),
|
||
),
|
||
WidgetSpan(
|
||
child: Stack(
|
||
children: [
|
||
Text(
|
||
"登录".tr,
|
||
style: TextStyle(
|
||
color: stringToColor("#84F5FF"),
|
||
fontSize: 30.rpx,
|
||
),
|
||
),
|
||
Positioned(
|
||
bottom: 0,
|
||
left: 0,
|
||
right: 0,
|
||
child: Container(
|
||
height: 1,
|
||
color: stringToColor("#84F5FF"),
|
||
),
|
||
),
|
||
],
|
||
),
|
||
),
|
||
TextSpan(
|
||
text: "后，再进行设备控制".tr,
|
||
style: TextStyle(
|
||
color: Colors.white,
|
||
fontSize: 30.rpx,
|
||
),
|
||
),
|
||
],
|
||
),
|
||
),
|
||
),
|
||
),
|
||
|
||
// 已登录但无设备提示
|
||
if (isLoggedIn && !hasDevice)
|
||
Center(
|
||
child: InkWell(
|
||
onTap: () => Get.toNamed("/mHTDeviceTypePage"),
|
||
child: RichText(
|
||
text: TextSpan(
|
||
children: [
|
||
TextSpan(
|
||
text: "请先".tr,
|
||
style: TextStyle(
|
||
color: Colors.white,
|
||
fontSize: 30.rpx,
|
||
),
|
||
),
|
||
WidgetSpan(
|
||
child: Stack(
|
||
children: [
|
||
Text(
|
||
"绑定设备".tr,
|
||
style: TextStyle(
|
||
color: stringToColor("#84F5FF"),
|
||
fontSize: 30.rpx,
|
||
),
|
||
),
|
||
Positioned(
|
||
bottom: 0,
|
||
left: 0,
|
||
right: 0,
|
||
child: Container(
|
||
height: 1,
|
||
color: stringToColor("#84F5FF"),
|
||
),
|
||
),
|
||
],
|
||
),
|
||
),
|
||
TextSpan(
|
||
text: "后，再进行设备控制".tr,
|
||
style: TextStyle(
|
||
color: Colors.white,
|
||
fontSize: 30.rpx,
|
||
),
|
||
),
|
||
],
|
||
),
|
||
),
|
||
),
|
||
),
|
||
|
||
// 显示 WebView
|
||
if (showWeb)
|
||
Expanded(
|
||
child: Align(
|
||
alignment: Alignment.topLeft,
|
||
child: Obx(() {
|
||
return (controller.ready.value)
|
||
?controller.web.build()
|
||
: Center(child: CircularProgressIndicator());
|
||
}),
|
||
),
|
||
),
|
||
],
|
||
),
|
||
);
|
||
});
|
||
}
|
||
}
|