102 lines
3.7 KiB
Dart
102 lines
3.7 KiB
Dart
import 'dart:convert';
|
|
import 'dart:io';
|
|
|
|
import 'package:EasyDartModule/EasyDartModule.dart';
|
|
import 'package:EasyDartModule/base/logger/Logger.dart';
|
|
import 'package:EasyDartModule/base/redis/redis.dart';
|
|
import 'package:EasyDartModule/base/websocket/WebSocket.dart';
|
|
|
|
import './controller/AreaController.dart';
|
|
import './controller/BedController.dart';
|
|
import './controller/BedTypeController.dart';
|
|
import './controller/DiseaseTypeController.dart';
|
|
import './controller/PersonController.dart';
|
|
import './controller/PersonTypeController.dart';
|
|
import './controller/RoomController.dart';
|
|
import './controller/RoomTypeController.dart';
|
|
// import './controller/StatisticsController.dart';
|
|
// import './service/AlarmRuleService.dart';
|
|
import './controller/FileUploadController.dart';
|
|
|
|
import 'const/ServiceConstant.dart';
|
|
// import 'service/DailyTaskService.dart';
|
|
|
|
import './const/CommonVariables.dart';
|
|
|
|
void main(List<String> args) async {
|
|
initEasyDartModule();
|
|
}
|
|
|
|
Future<void> initEasyDartModule() async {
|
|
try {
|
|
String? web = Platform.environment["web_port"] ?? "9200";
|
|
List<String> redis =
|
|
(Platform.environment["redis"] ?? "127.0.0.1:6379").split(":");
|
|
if (redis.length == 1) {
|
|
redis.add("6379");
|
|
}
|
|
EasyDartModule.init(
|
|
loggerConfig: LoggerConfig(
|
|
host: ServiceConstant.logService, serviceName: "快检报告服务"),
|
|
redisConfig: RedisConfig(host: redis[0], port: int.parse(redis[1])),
|
|
webSocketConfig:
|
|
WebSocketConfig(ServiceConstant.webSocketService, (data) {
|
|
// 接收到服务消息
|
|
var json = jsonDecode(data);
|
|
// ef.log("[websokcet]:${json}");
|
|
EasyDartModule.logger.info("[websokcet数据]:${json}");
|
|
if (json['wsId'] != null) {
|
|
// ef.kvRoot.websocketId = json['wsId'];
|
|
}
|
|
if (json['code'] != null && json['code'] != 200) {
|
|
EasyDartModule.logger
|
|
.error("[websokcet数据]:websocket连接失败--》" + json['msg']);
|
|
}
|
|
if (json["path"] != null) {
|
|
var call = CommonVariables.callMap[json["path"]];
|
|
if (call != null) {
|
|
try {
|
|
if (json['path'] != "/smartbed/connect") {
|
|
call(json["data"]);
|
|
} else {
|
|
call(json);
|
|
}
|
|
} catch (e) {
|
|
print(e);
|
|
}
|
|
} else {
|
|
print("未找到当前路径: ${json["path"]} 回调函数");
|
|
EasyDartModule.logger.error("未找到当前路径: ${json["path"]} 回调函数");
|
|
}
|
|
}
|
|
// print(data);
|
|
}, onOpen: () {
|
|
// 连接建立完毕
|
|
// EasyDartModule.websocket
|
|
// .sendData(jsonEncode({"path": "/aa/bb", "type": 1}));
|
|
print("object");
|
|
}));
|
|
|
|
while (!EasyDartModule.redis.isConnected()) {
|
|
await Future.delayed(Duration(seconds: 1));
|
|
}
|
|
|
|
EasyDartModule.webServer.addHandler(RoomController());
|
|
EasyDartModule.webServer.addHandler(RoomTypeController());
|
|
EasyDartModule.webServer.addHandler(BedTypeController());
|
|
EasyDartModule.webServer.addHandler(BedController());
|
|
EasyDartModule.webServer.addHandler(DiseaseTypeController());
|
|
EasyDartModule.webServer.addHandler(PersonController());
|
|
EasyDartModule.webServer.addHandler(PersonTypeController());
|
|
// EasyDartModule.webServer.addHandler(StatisticsController());
|
|
EasyDartModule.webServer.addHandler(AreaController());
|
|
EasyDartModule.webServer.addHandler(FileUploadController());
|
|
EasyDartModule.webServer.start(
|
|
int.parse(web),
|
|
);
|
|
} catch (e) {
|
|
print(e);
|
|
EasyDartModule.logger.error("websocket连接失败--》:$e");
|
|
}
|
|
}
|