final push till demo

faiz_dev_new
FaizHashmiCS22 3 years ago
parent 14f1268f66
commit e82f908885

@ -60,6 +60,9 @@ class _MyHomePageState extends State<MyHomePage> {
return ""; return "";
} }
final AudioPlayer audioPlayer = AudioPlayer();
@override @override
void initState() { void initState() {
listenNetworkConnectivity(); listenNetworkConnectivity();
@ -76,7 +79,6 @@ class _MyHomePageState extends State<MyHomePage> {
@override @override
Widget build(BuildContext context) { Widget build(BuildContext context) {
final AudioPlayer audioPlayer = AudioPlayer();
audioPlayer.playerStateStream.listen((playerState) { audioPlayer.playerStateStream.listen((playerState) {
if (playerState.processingState == ProcessingState.completed) { if (playerState.processingState == ProcessingState.completed) {
isCallingInProgress = false; isCallingInProgress = false;
@ -255,14 +257,34 @@ class _MyHomePageState extends State<MyHomePage> {
} }
} }
onUpdateAvailable(data, audioPlayer) async { onUpdateAvailable(data) async {
// if (isQueuePatients.isNotEmpty && callFlag == 0) { // if (isQueuePatients.isNotEmpty && callFlag == 0) {
// callFlag = 1; // callFlag = 1;
// return; // return;
// } // }
print("hereValues: ${isCallingInProgress || voiceCaller != null}"); if (waitings.isNotEmpty) {
if ((isCallingInProgress || voiceCaller != null) && waitings.isNotEmpty) { if ((waitings.first.isToneReq && isCallingInProgress) || (waitings.first.isVoiceReq && voiceCaller != null)) {
Timer(Duration(milliseconds: int.parse(waitings.first.queueDuration)), () { // if (true) {
print("I will wait with $isCallingInProgress ");
Timer(Duration(milliseconds: int.parse(waitings.first.queueDuration)), () {
// Timer(Duration(milliseconds: 0), () {
waitings.clear();
API.getCallRequestInfoByClinicInfo(deviceIPGlobal, onSuccess: (waitingCalls, isQueuePatientsCalls) {
setState(() {
waitings = waitingCalls;
isQueuePatients = isQueuePatientsCalls;
// currents = currentInClinic;
});
log("--------------------");
log("waiting: $waitings");
log("isQueuePatients: $isQueuePatients");
log("--------------------");
updateTickets();
}, onFailure: (error) {});
});
} else {
waitings.clear(); waitings.clear();
API.getCallRequestInfoByClinicInfo(deviceIPGlobal, onSuccess: (waitingCalls, isQueuePatientsCalls) { API.getCallRequestInfoByClinicInfo(deviceIPGlobal, onSuccess: (waitingCalls, isQueuePatientsCalls) {
setState(() { setState(() {
@ -278,7 +300,7 @@ class _MyHomePageState extends State<MyHomePage> {
updateTickets(); updateTickets();
}, onFailure: (error) {}); }, onFailure: (error) {});
}); }
} else { } else {
waitings.clear(); waitings.clear();
API.getCallRequestInfoByClinicInfo(deviceIPGlobal, onSuccess: (waitingCalls, isQueuePatientsCalls) { API.getCallRequestInfoByClinicInfo(deviceIPGlobal, onSuccess: (waitingCalls, isQueuePatientsCalls) {
@ -337,3 +359,21 @@ class _MyHomePageState extends State<MyHomePage> {
}); });
} }
} }
// if (isQueuePatients.length > 1) {
// Timer(Duration(milliseconds: int.parse(waitings.first.queueDuration)), () {
// Tickets calledTicket = Tickets();
// if (isQueuePatients.isNotEmpty) {
// calledTicket = isQueuePatients.elementAt(0);
// isQueuePatients.removeAt(0);
// }
// if (waitings.isNotEmpty) {
// // Tickets ticket = waitings.elementAt(0);
// // waitings.removeAt(0);
// // waitings.add(ticket);
// }
// if (isQueuePatients.isNotEmpty) {
// // setState(() {});
// }
// });
// }

@ -2,7 +2,6 @@ import 'dart:io';
import 'package:flutter/material.dart'; import 'package:flutter/material.dart';
import 'package:http/io_client.dart'; import 'package:http/io_client.dart';
import 'package:just_audio/just_audio.dart';
import 'package:signalr_core/signalr_core.dart'; import 'package:signalr_core/signalr_core.dart';
/* /*
@ -27,7 +26,7 @@ class SignalRHelper {
HubConnection connection; HubConnection connection;
startSignalRConnection(String deviceIp, startSignalRConnection(String deviceIp,
{@required Function(dynamic, dynamic) onUpdateAvailable, @required VoidCallback onConnect, @required Function(dynamic) onDisconnect, @required VoidCallback onConnecting}) async { {@required Function(dynamic) onUpdateAvailable, @required VoidCallback onConnect, @required Function(dynamic) onDisconnect, @required VoidCallback onConnecting}) async {
// Hardcoded IP For Testing // Hardcoded IP For Testing
// deviceIp = "10.10.14.11"; // deviceIp = "10.10.14.11";
print("Connecting Signal R with: $deviceIp"); print("Connecting Signal R with: $deviceIp");
@ -51,7 +50,7 @@ class SignalRHelper {
connection.onreconnected((connectionId) => onConnect()); connection.onreconnected((connectionId) => onConnect());
connection.on('addChatMessage', (message) { connection.on('addChatMessage', (message) {
onUpdateAvailable(message, AudioPlayer()); onUpdateAvailable(message);
}); });
// try { // try {

Loading…
Cancel
Save