Learing how to use Broadcast

Author: iamwjun

android/app/src/main/AndroidManifest.xml

@@ -33,5 +33,13 @@
                 <category android:name="android.intent.category.LAUNCHER"/>
             </intent-filter>
         </activity>
+        <receiver
+            android:name=".MyReceiver"
+            android:enabled="true"
+            android:exported="true">
+            <intent-filter>
+                <action android:name="net.deniro.android.MY_BROADCAST"/>
+            </intent-filter>
+        </receiver>
     </application>
 </manifest>

android/app/src/main/java/com/example/example/MainActivity.java

@@ -1,6 +1,7 @@
 package com.example.example;
 
 import java.util.Map;
+import java.util.HashMap;
 
 import com.alipay.sdk.app.EnvUtils;
 import com.alipay.sdk.app.PayTask;
@@ -37,15 +38,21 @@
 public class MainActivity extends FlutterActivity {
   private static final String CHANNEL = "examples.flutter.dev/battery";
   private static final String CHARGING_CHANNEL = "samples.flutter.io/charging";
+  private PayEventSink eventSink = new PayEventSink();
 
   private static final int SDK_PAY_FLAG = 1;
   private static final int SDK_AUTH_FLAG = 2;
+  private String payResult = "none";
 
   @SuppressLint("HandlerLeak")
   private Handler mHandler = new Handler() {
     @SuppressWarnings("unused")
-    public void handleMessage(Message msg) {
+    public void handleMessage(Message msg, final Result result) {
       System.out.println("here");
+      result.success("回调成功");
+//      Map<String, Object> event = new HashMap<>();
+//      event.put("event", "completed");
+//      eventSink.success(event);
     };
 
 //    public void sendBroadcast(String msg) {
@@ -68,10 +75,8 @@ protected void onCreate(Bundle savedInstanceState) {
           private BroadcastReceiver changeStream;
           @Override
           public void onListen(Object arguments, EventSink events) {
-            chargingStateChangeReceiver = createChargingStateChangeReceiver(events);
-            registerReceiver(chargingStateChangeReceiver, new IntentFilter(Intent.ACTION_BATTERY_CHANGED));
             changeStream = createSetStream(events);
-            registerReceiver(changeStream, new IntentFilter(Intent.ACTION_BATTERY_CHANGED));
+            registerReceiver(changeStream, new Intent("net.deniro.android.MY_BROADCAST"));
           }
 
           @Override
@@ -136,7 +141,7 @@ private BroadcastReceiver createSetStream(final EventSink events) {
     return new BroadcastReceiver() {
       @Override
       public void onReceive(Context context, Intent intent) {
-        events.success("发送广播");
+        //events.success("发送广播");
       }
     };
   }
@@ -199,10 +204,10 @@ public void run() {
           Log.i("msp", result.toString());
           System.out.println("success");
 
-//          Message msg = new Message();
-//          msg.what = SDK_PAY_FLAG;
-//          msg.obj = result;
-//          mHandler.handleMessage(msg);
+          Message msg = new Message();
+          msg.what = SDK_PAY_FLAG;
+          msg.obj = result;
+          mHandler.handleMessage(msg);
         } catch (Exception e) {
           // response.error("error", "支付发起错误", null);
           System.out.println("error");
@@ -224,6 +229,11 @@ public void run() {
         try{
           final String text = "异步返回数据!";
           System.out.println("正常");
+
+          Message msg = new Message();
+          msg.what = SDK_PAY_FLAG;
+          msg.obj = "支付结果";
+          mHandler.handleMessage(msg);
         } catch (Exception e){
           System.out.println(e.toString());
           //response.error("error", "支付发生错误", null);

android/app/src/main/java/com/example/example/MyReceiver.java

@@ -0,0 +1,15 @@
+package com.example.example;
+
+import android.content.BroadcastReceiver;
+import android.content.Intent;
+import android.content.Context;
+
+public class MyReceiver extends BroadcastReceiver {
+    public MyReceiver() {
+    }
+
+    @Override
+    public void onReceive(Context context, Intent intent) {
+        System.out.println("广播开始");
+    }
+}

android/app/src/main/java/com/example/example/PayEventSink.java

@@ -0,0 +1,72 @@
+package com.example.example;
+
+import io.flutter.plugin.common.EventChannel;
+import java.util.ArrayList;
+
+final class PayEventSink implements EventChannel.EventSink {
+    private EventChannel.EventSink delegate;
+    private ArrayList<Object> eventQueue = new ArrayList<>();
+    private boolean done = false;
+
+    public void setDelegate(EventChannel.EventSink delegate) {
+        this.delegate = delegate;
+        maybeFlush();
+    }
+
+    @Override
+    public void endOfStream() {
+        enqueue(new EndOfStreamEvent());
+        maybeFlush();
+        done = true;
+    }
+
+    @Override
+    public void error(String code, String message, Object details) {
+        enqueue(new ErrorEvent(code, message, details));
+        maybeFlush();
+    }
+
+    @Override
+    public void success(Object event) {
+        enqueue(event);
+        maybeFlush();
+    }
+
+    private void enqueue(Object event) {
+        if (done) {
+            return;
+        }
+        eventQueue.add(event);
+    }
+
+    private void maybeFlush() {
+        if (delegate == null) {
+            return;
+        }
+        for (Object event : eventQueue) {
+            if (event instanceof EndOfStreamEvent) {
+                delegate.endOfStream();
+            } else if (event instanceof ErrorEvent) {
+                ErrorEvent errorEvent = (ErrorEvent) event;
+                delegate.error(errorEvent.code, errorEvent.message, errorEvent.details);
+            } else {
+                delegate.success(event);
+            }
+        }
+        eventQueue.clear();
+    }
+
+    private static class EndOfStreamEvent {}
+
+    private static class ErrorEvent {
+        String code;
+        String message;
+        Object details;
+
+        ErrorEvent(String code, String message, Object details) {
+            this.code = code;
+            this.message = message;
+            this.details = details;
+        }
+    }
+}

lib/base/Alipay.dart

@@ -130,10 +130,8 @@ class _AlipayDemoState extends State<AlipayDemo> {
   }
 
   void _onEvent(Object event) {
-    print('返回: $event.toString()');
     setState(() {
-      _chargingStatus =
-          "支付结果: ${event == 'charging' ? '' : 'dis'}charging.";
+      _chargingStatus = "支付结果: ${event == 'charging' ? '' : 'dis'}charging.";
     });
   }