Erweiterungen

lib/content_views/assigned_jobs_page.dart

@@ -1,4 +1,3 @@
-
 import 'package:expandable/expandable.dart';
 import 'package:flutter/material.dart';
 import 'package:isar/isar.dart';
@@ -177,7 +176,7 @@ class _AssignedJobsPageState extends State<AssignedJobsPage> {
     return entries;
   }
 
-  _sendAnswer(Job job, int item) {
+  _sendAnswer(Job job, int item) async {
     var message = AcceptJobMessage();
     message.reaction = Reaction();
     message.reaction.id = job.id.toString();
@@ -191,4 +190,12 @@ class _AssignedJobsPageState extends State<AssignedJobsPage> {
     message.reaction.track.pos.acc = 1;
 
     MqttCore.instance.publishPayloadMessage("job", message.toJson());
-  }}
+
+    job.state = 9;
+    MyApp.isarInstance.writeTxnSync(() => {MyApp.isarInstance.jobs.putSync(job)});
+
+    _entries = await _createListEntries();
+
+    setState(() {});
+  }
+}

lib/content_views/main_page.dart

@@ -256,9 +256,9 @@ class _MainPageState extends State<MainPage> {
       widget.sidValueNotifier.value = statusInfoUpdateMessage.status.sid;
     });
 
-    /*BroadcastReceiver().subscribe<JobReceivedMessage>(Constants.messageTopicJobReceived, (JobReceivedMessage jobReceivedMessage) {
+    BroadcastReceiver().subscribe<JobReceivedMessage>(Constants.messageTopicJobReceived, (JobReceivedMessage jobReceivedMessage) {
       _jobReceived(jobReceivedMessage.job);
-    });*/
+    });
   }
 
   void _exitMessages() {

lib/popups/accept_jobs_popup.dart

@@ -151,4 +151,9 @@ _sendAnswer(Job job, int item) {
   message.reaction.track.pos.acc = currentPosition != null ? currentPosition.accuracy : 0.0;
 
   MqttCore.instance.publishPayloadMessage("job", message.toJson());
+
+  job.state = 9;
+  MyApp.isarInstance.writeTxnSync(() => {
+    MyApp.isarInstance.jobs.putSync(job)
+  });
 }