Merge branch 'zhou_dev'

* zhou_dev:
  去掉abiFilters
  abiFilters 添加 x86_64
  fix bug:  java.lang.UnsatisfiedLinkError: JNI_ERR returned from JNI_OnLoad in "/data/app/~~fQ1ReUB9uBx0IyUovshiQg==/com.szls.lszlgl-ozYAHLRC0AkdtBf_BeOaZg==/lib/arm64/libLabelPrinterSDK.so"
  支持精臣型号A8开头的打印机
  将连接的蓝牙设备信息传给服务器
  创建本地数据库并写入信息
  打印机对接完成
  集成数据库和打印机(未完结)
  添加数据库drift
  打印机打印的图片尺寸调整成适合70*80
  fix： 解决冲突缺少的括号
  蓝牙打印完成
  配对、连接、以及对应loading添加完成
  打印机蓝牙权限、搜索、连接功能
  开始扫描
  flutter使用的版本是3.19.4，对应升级gradle配置

# Conflicts:
#	lib/config/pics.dart

android/app/build.gradle

@@ -32,6 +32,12 @@ android {
         targetCompatibility JavaVersion.VERSION_1_8
     }
 
+    sourceSets {
+        main {
+            jniLibs.srcDirs = ['jniLibs']
+        }
+    }
+
     defaultConfig {
         applicationId "com.szls.lszlgl"
         // You can update the following values to match your application needs.
@@ -42,6 +48,8 @@ android {
         versionName flutterVersionName
     }
 
+    println "targetSdkVersion: ${flutter.targetSdkVersion}"
+
     // 签名配置
     signingConfigs {
         release {
@@ -60,11 +68,15 @@ android {
             proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
             signingConfig signingConfigs.release
             manifestPlaceholders = [APP_NAME: "国粮质检"]
+            shrinkResources false // 重要，打印机有so库，fix bug: https://github.com/flutter/flutter/issues/47527
+            minifyEnabled false // 重要，打印机有so库，fix bug: https://github.com/flutter/flutter/issues/47527
         }
         profile {
             signingConfig signingConfigs.release
             manifestPlaceholders = [APP_NAME: "国粮质检-测试"]
             applicationIdSuffix ".debug"
+            shrinkResources false // 重要，打印机有so库，fix bug: https://github.com/flutter/flutter/issues/47527
+            minifyEnabled false // 重要，打印机有so库，fix bug: https://github.com/flutter/flutter/issues/47527
         }
         debug {
             signingConfig signingConfigs.release
@@ -86,6 +98,18 @@ android {
     dependencies {
         implementation fileTree(include: ['*.jar'], dir: 'libs')
         implementation 'com.amap.api:location:5.6.0'
+
+        //打印库
+        implementation files('libs/3.2.2-release.aar')
+        //接⼊机型包含B50/B50W/B11/T6/T7/T8系列打印机需要引⼊该包，如不包含则可以不引⼊
+        implementation files('libs/LPAPI-2019-11-20-R.jar')
+        implementation files('libs/image-1.8.4.6.aar')
+
+        // btp打印机库
+        implementation files('libs/LabelPrinterJavaSDK.jar')
+
+        //权限库
+        implementation 'com.guolindev.permissionx:permissionx:1.7.1'
     }
 }
 

android/app/src/main/AndroidManifest.xml

@@ -1,4 +1,5 @@
-<manifest xmlns:android="http://schemas.android.com/apk/res/android">
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:tools="http://schemas.android.com/tools">
     <!--允许访问网络，必选权限-->
     <uses-permission android:name="android.permission.INTERNET" />
 
@@ -38,8 +39,22 @@
     <!--允许安装应用-->
     <uses-permission android:name="android.permission.REQUEST_INSTALL_PACKAGES" />
 
+    <!-- 蓝⽛打印机权限 -->
+    <!-- 蓝⽛权限 -->
+    <uses-permission android:name="android.permission.BLUETOOTH" />
+    <uses-permission android:name="android.permission.BLUETOOTH_ADMIN" />
+    <!-- android 5以上 android 12以下，蓝⽛搜索需要位置权限 -->
+    <uses-permission android:name="android.permission.ACCESS_FINE_LOCATION" />
+    <uses-permission android:name="android.permission.ACCESS_COARSE_LOCATION"
+        />
+    <!--android 12 需要申请蓝⽛搜索权限、连接权限 ⽆需申请位置权限 -->
+    <uses-permission android:name="android.permission.BLUETOOTH_CONNECT" />
+    <uses-permission android:name="android.permission.BLUETOOTH_SCAN" android:usesPermissionFlags="neverForLocation" tools:targetApi="s" />
+
+
+
     <application
-        android:name="${applicationName}"
+        android:name=".app.MyApplication"
         android:icon="@drawable/ic_launcher"
         android:label="${APP_NAME}"
         android:requestLegacyExternalStorage="true">

android/app/src/main/java/com/szls/lszlgl/MainActivity.java

@@ -1,6 +1,27 @@
 package com.szls.lszlgl;
 
+import android.util.Log;
+
+import androidx.annotation.NonNull;
+
 import io.flutter.embedding.android.FlutterActivity;
+import io.flutter.embedding.engine.FlutterEngine;
+import io.flutter.embedding.engine.plugins.util.GeneratedPluginRegister;
+import io.flutter.plugins.BluetoothPlugin;
 
 public class MainActivity extends FlutterActivity {
+
+    static {
+        System.loadLibrary("LabelPrinterSDK");
+    }
+    @Override
+    public void configureFlutterEngine(@NonNull FlutterEngine flutterEngine) {
+        super.configureFlutterEngine(flutterEngine);
+
+        Log.e("AAAA", ">>> configureFlutterEngine");
+        GeneratedPluginRegister.registerGeneratedPlugins(flutterEngine);
+
+        //插件实例的注册,就是自己写个类，然后实现Flutter提供的FlutterPlugin接口
+        flutterEngine.getPlugins().add(new BluetoothPlugin(this));
+    }
 }

android/app/src/main/java/com/szls/lszlgl/app/MyApplication.java

@@ -0,0 +1,24 @@
+package com.szls.lszlgl.app;
+
+import android.app.Application;
+import android.content.Context;
+
+/**
+ * 自定义Application
+ *
+ * @author zhangbin
+ */
+public class MyApplication extends Application {
+    private static MyApplication instance;
+
+    @Override
+    public void onCreate() {
+
+        super.onCreate();
+        instance = this;
+    }
+
+    public static MyApplication getInstance() {
+        return instance;
+    }
+}

android/app/src/main/java/io/flutter/plugins/BluetoothPlugin.java

@@ -0,0 +1,472 @@
+package io.flutter.plugins;
+
+import android.Manifest;
+import android.annotation.SuppressLint;
+import android.bluetooth.BluetoothAdapter;
+import android.bluetooth.BluetoothDevice;
+import android.content.BroadcastReceiver;
+import android.content.Context;
+import android.content.Intent;
+import android.content.IntentFilter;
+import android.content.SharedPreferences;
+import android.content.pm.PackageManager;
+import android.graphics.Bitmap;
+import android.graphics.BitmapFactory;
+import android.location.LocationManager;
+import android.os.Build;
+import android.text.TextUtils;
+import android.util.Log;
+import android.view.View;
+import android.widget.Toast;
+
+import androidx.annotation.NonNull;
+import androidx.core.app.ActivityCompat;
+import androidx.fragment.app.FragmentActivity;
+
+import com.gengcon.www.jcprintersdk.callback.PrintCallback;
+import com.permissionx.guolindev.PermissionX;
+import com.szls.lszlgl.MainActivity;
+
+import java.io.ByteArrayOutputStream;
+import java.nio.ByteBuffer;
+import java.security.Permission;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.LinkedBlockingDeque;
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+import dev.fluttercommunity.plus.androidintent.IntentSender;
+import dev.fluttercommunity.plus.androidintent.MethodCallHandlerImpl;
+import io.flutter.embedding.engine.plugins.FlutterPlugin;
+import io.flutter.embedding.engine.plugins.activity.ActivityAware;
+import io.flutter.embedding.engine.plugins.activity.ActivityPluginBinding;
+import io.flutter.plugin.common.BinaryMessenger;
+import io.flutter.plugin.common.EventChannel;
+import io.flutter.plugin.common.MethodCall;
+import io.flutter.plugin.common.MethodChannel;
+
+import io.flutter.plugin.common.EventChannel.EventSink;
+import io.flutter.plugin.common.EventChannel.StreamHandler;
+import io.flutter.plugins.bean.BlueDeviceInfo;
+import io.flutter.plugins.utils.BTPPrintUtil;
+import io.flutter.plugins.utils.BluetoothUtils;
+import io.flutter.plugins.utils.PrintUtil;
+
+public class BluetoothPlugin implements FlutterPlugin, MethodChannel.MethodCallHandler {
+
+    private String methodChannelName = "io.flutter.plugins/bluetooth";
+    private MethodChannel methodChannel;
+
+    private ExecutorService executorService;
+
+    private static final String USER_DEFINED = "自定义";
+    private static final String delimiterStr = "_NIMBOT_";
+
+    private String printNameStart = "";
+
+    OnDiscoveryDeviceStreamHandler onDiscoveryDeviceStreamHandler;
+    private EventChannel onReceiveDeviceChannel;
+
+    OnDeviceStateStreamHandler onDeviceStateStreamHandler;
+    private EventChannel onDeviceStateChannel;
+
+    private BlueDeviceInfo itemPosition;
+
+    Context _applicationContext;
+    private BluetoothAdapter mBluetoothAdapter;
+
+
+    public BluetoothPlugin(MainActivity activity) {
+        mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();
+//        _mainActivity = activity;
+
+        //注册广播
+        IntentFilter intentFilter = new IntentFilter();
+        intentFilter.addAction(BluetoothDevice.ACTION_FOUND);
+        intentFilter.addAction(BluetoothAdapter.ACTION_DISCOVERY_STARTED);
+        intentFilter.addAction(BluetoothAdapter.ACTION_DISCOVERY_FINISHED);
+        intentFilter.addAction(BluetoothDevice.ACTION_BOND_STATE_CHANGED);
+        intentFilter.addAction(BluetoothDevice.ACTION_ACL_CONNECTED);
+        intentFilter.addAction(BluetoothDevice.ACTION_ACL_DISCONNECTED);
+        intentFilter.addAction(BluetoothDevice.ACTION_PAIRING_REQUEST);
+        Log.d("ble", "初始化:注册广播 ");
+        activity.registerReceiver(receiver, intentFilter);
+        Log.d("ble", "初始化: 注册完成");
+
+        //注册线程池
+        ThreadFactory threadFactory = runnable -> {
+            Thread thread = new Thread(runnable);
+            thread.setName("connect_activity_pool_%d");
+            return thread;
+        };
+        executorService = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingDeque<>(1024), threadFactory, new ThreadPoolExecutor.AbortPolicy());
+
+
+    }
+
+    @Override
+    public void onAttachedToEngine(@NonNull FlutterPluginBinding flutterPluginBinding) {
+        setupChannels(flutterPluginBinding.getBinaryMessenger(), flutterPluginBinding.getApplicationContext());
+    }
+
+    private void setupChannels(BinaryMessenger binaryMessenger, Context applicationContext) {
+
+        _applicationContext = applicationContext.getApplicationContext();
+
+        methodChannel = new MethodChannel(binaryMessenger, methodChannelName + "/methods");
+        methodChannel.setMethodCallHandler(this);
+
+        onReceiveDeviceChannel = new EventChannel(binaryMessenger, methodChannelName + "/onDiscoveryDevice");
+        onDiscoveryDeviceStreamHandler = new OnDiscoveryDeviceStreamHandler();
+        onReceiveDeviceChannel.setStreamHandler(onDiscoveryDeviceStreamHandler);
+
+        onDeviceStateChannel = new EventChannel(binaryMessenger, methodChannelName + "/onDeviceState");
+        onDeviceStateStreamHandler = new OnDeviceStateStreamHandler();
+        onDeviceStateChannel.setStreamHandler(onDeviceStateStreamHandler);
+    }
+
+    @Override
+    public void onDetachedFromEngine(@NonNull FlutterPluginBinding flutterPluginBinding) {
+        teardownChannels();
+    }
+
+    @Override
+    public void onMethodCall(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+        switch (methodCall.method) {
+
+            case "isBleOpen":
+                Log.d("ble", "isSupportBle");
+                result.success(mBluetoothAdapter.isEnabled());
+                break;
+            case "isSDKIntGreaterOrEqual":
+                Log.d("ble", "isSDKIntGreaterOrEqual");
+                result.success(Build.VERSION.SDK_INT >= Build.VERSION_CODES.S);
+                break;
+            case "startBluetoothDiscovery":
+                Log.d("ble", "startBluetoothDiscovery");
+                startBluetoothDiscovery(result);
+                break;
+            case "startBluetoothPair":
+                Log.d("ble", "startBluetoothPair");
+                startBluetoothPair(methodCall, result);
+                break;
+            case "startBluetoothConnect":
+                Log.d("ble", "startBluetoothConnect :" + methodCall.arguments);
+                startBluetoothConnect(methodCall, result);
+                break;
+            case "endBluetoothConnect":
+                Log.d("ble", "endBluetoothConnect :" + methodCall.arguments);
+                endBluetoothConnect(methodCall, result);
+                break;
+            case "hasBluetoothConnectDevice":
+                Log.d("ble", "hasBluetoothConnectDevice :" + methodCall.arguments);
+                hasBluetoothConnectDevice(methodCall, result);
+                break;
+            case "startBluetoothPrintBitMap":
+                Log.d("ble", "startBluetoothPrint :" + methodCall.arguments);
+                startBluetoothPrintBitMap(methodCall, result);
+                break;
+            case "startBluetoothPrintBarCode":
+                Log.d("ble", "startBluetoothPrintBarCode :" + methodCall.arguments);
+                startBluetoothPrintBarCode(methodCall, result);
+                break;
+
+
+            case "autoLogin":
+
+                break;
+            case "isLogined":
+
+                break;
+            case "currentAccount":
+                break;
+            case "logout":
+                break;
+            case "markAllMessagesRead":
+                break;
+            default: {
+                result.notImplemented();
+                break;
+            }
+        }
+    }
+
+    private void teardownChannels() {
+        methodChannel.setMethodCallHandler(null);
+        methodChannel = null;
+//        // 注销广播接收器
+//        if (mBluetoothAdapter != null && mBluetoothAdapter.isDiscovering()) {
+//            mBluetoothAdapter.cancelDiscovery();
+//        }
+//        requireActivity().unregisterReceiver(receiver);
+    }
+
+    void startBluetoothDiscovery(@NonNull MethodChannel.Result result) {
+
+        if (ActivityCompat.checkSelfPermission(_applicationContext, Manifest.permission.BLUETOOTH_SCAN) != PackageManager.PERMISSION_GRANTED) {
+
+            Log.d("ble", "checkSelfPermission false");
+            return;
+        }
+
+        if (mBluetoothAdapter.isDiscovering()) {
+
+            if (mBluetoothAdapter.cancelDiscovery()) {
+                executorService.execute(() -> {
+                    try {
+                        //取消后等待1s后再次搜索
+                        Thread.sleep(1000);
+                        mBluetoothAdapter.startDiscovery();
+                        Log.d("ble", "测试:开始搜索7");
+                    } catch (InterruptedException e) {
+                        Log.d("ble", "测试:开始搜索8");
+                        e.printStackTrace();
+                    }
+                });
+
+
+            }
+        } else {
+            Log.d("ble", "测试:开始搜索9");
+            mBluetoothAdapter.startDiscovery();
+            Log.d("ble", "测试:开始搜索10");
+        }
+    }
+
+    void startBluetoothPair(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+
+        if (ActivityCompat.checkSelfPermission(_applicationContext, Manifest.permission.BLUETOOTH_SCAN) != PackageManager.PERMISSION_GRANTED) {
+            return;
+        }
+        if (mBluetoothAdapter.isDiscovering()) {
+            mBluetoothAdapter.cancelDiscovery();
+        }
+
+        String deviceInfo = methodCall.arguments.toString();
+        String[] deviceInfoList = deviceInfo.split(delimiterStr);
+        for (int i = 0; i < deviceInfoList.length; i++) {
+            Log.d("ble", i + ":" + deviceInfoList[i]);
+        }
+        Log.d("ble", "startBluetoothPair : ---" + deviceInfo + "----0:" + deviceInfoList[0]);
+        itemPosition = new BlueDeviceInfo(deviceInfoList[0], deviceInfoList[1], Integer.parseInt(deviceInfoList[2]));
+        BluetoothDevice bluetoothDevice = mBluetoothAdapter.getRemoteDevice(itemPosition.getDeviceHardwareAddress());
+
+        executorService.submit(() -> {
+            Log.d("ble", "配对: 开始");
+            boolean returnValue = false;
+            try {
+                returnValue = BluetoothUtils.createBond(bluetoothDevice);
+            } catch (Exception e) {
+                Log.d("ble", "闪退日志" + e.getMessage());
+            }
+            Log.d("ble", "配对: 进行中:" + returnValue);
+        });
+    }
+
+    void startBluetoothConnect(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+
+        if (ActivityCompat.checkSelfPermission(_applicationContext, Manifest.permission.BLUETOOTH_SCAN) != PackageManager.PERMISSION_GRANTED) {
+            return;
+        }
+        if (mBluetoothAdapter.isDiscovering()) {
+            mBluetoothAdapter.cancelDiscovery();
+        }
+
+        String deviceInfo = methodCall.arguments.toString();
+        String[] deviceInfoList = deviceInfo.split(delimiterStr);
+        for (int i = 0; i < deviceInfoList.length; i++) {
+            Log.d("ble", i + ":" + deviceInfoList[i]);
+        }
+        Log.d("ble", "startBluetoothConnect : ---" + deviceInfo + "----0:" + deviceInfoList[0]);
+        itemPosition = new BlueDeviceInfo(deviceInfoList[0], deviceInfoList[1], Integer.parseInt(deviceInfoList[2]));
+        BluetoothDevice bluetoothDevice = mBluetoothAdapter.getRemoteDevice(itemPosition.getDeviceHardwareAddress());
+
+        executorService.submit(() -> {
+            BlueDeviceInfo blueDeviceInfo = new BlueDeviceInfo(bluetoothDevice.getName(), bluetoothDevice.getAddress(), itemPosition.getConnectState());
+            PrintUtil.setConnectedType(-1);
+            int connectResult = 1;
+            if (blueDeviceInfo.getDeviceName().contains("BTP")) {
+                connectResult = BTPPrintUtil.connectBluetoothPrinter(blueDeviceInfo.getDeviceHardwareAddress());
+            } else {
+                connectResult = PrintUtil.connectBluetoothPrinter(blueDeviceInfo.getDeviceHardwareAddress());
+            }
+            Log.d("ble", "测试：连接结果 " + connectResult); // 0是成功
+            result.success(connectResult);
+        });
+    }
+
+    void endBluetoothConnect(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+        PrintUtil.close();
+        result.success(0);
+    }
+
+    void hasBluetoothConnectDevice(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+        if (PrintUtil.isConnection() == 0 && PrintUtil.getConnectedType() == 0) {
+            Log.d("ble", "测试:配对状态改变:判断连接状态 2");
+            result.success(true);
+        } else {
+            Log.d("ble", "测试:配对状态改变:判断连接状态4 ");
+            result.success(false);
+        }
+    }
+
+    void startBluetoothPrintBitMap(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+
+        byte[] imageByte = (byte[]) methodCall.arguments;
+
+        Log.d("ble", "imageByte:" + imageByte);
+        Bitmap bitmap = Bytes2Bimap(imageByte);
+
+        BluetoothDevice bluetoothDevice = mBluetoothAdapter.getRemoteDevice(itemPosition.getDeviceHardwareAddress());
+        if (ActivityCompat.checkSelfPermission(_applicationContext, Manifest.permission.BLUETOOTH_CONNECT) != PackageManager.PERMISSION_GRANTED) {
+            return;
+        }
+        BlueDeviceInfo blueDeviceInfo = new BlueDeviceInfo(bluetoothDevice.getName(), bluetoothDevice.getAddress(), itemPosition.getConnectState());
+        if(blueDeviceInfo.getDeviceName().contains("BTP")) {
+            BTPPrintUtil.printBitMap(bitmap, blueDeviceInfo.getDeviceName(), result);
+        } else {
+            PrintUtil.printBitMap(bitmap, result);
+        }
+    }
+
+    void startBluetoothPrintBarCode(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+
+        byte[] imageByte = (byte[]) methodCall.arguments;
+
+        Log.d("ble", "imageByte:" + imageByte);
+        Bitmap bitmap = Bytes2Bimap(imageByte);
+
+        BluetoothDevice bluetoothDevice = mBluetoothAdapter.getRemoteDevice(itemPosition.getDeviceHardwareAddress());
+        if (ActivityCompat.checkSelfPermission(_applicationContext, Manifest.permission.BLUETOOTH_CONNECT) != PackageManager.PERMISSION_GRANTED) {
+            return;
+        }
+        BlueDeviceInfo blueDeviceInfo = new BlueDeviceInfo(bluetoothDevice.getName(), bluetoothDevice.getAddress(), itemPosition.getConnectState());
+        if(blueDeviceInfo.getDeviceName().contains("BTP")) {
+            BTPPrintUtil.printBitMap(bitmap, blueDeviceInfo.getDeviceName(), result);
+        } else {
+            PrintUtil.printBitMap(bitmap, result);
+        }
+    }
+
+    public Bitmap Bytes2Bimap(byte[] b) {
+        if (b.length != 0) {
+            return BitmapFactory.decodeByteArray(b, 0, b.length);
+        } else {
+            return null;
+        }
+    }
+
+    private final BroadcastReceiver receiver = new BroadcastReceiver() {
+
+        @SuppressLint("MissingPermission")
+        @Override
+        public void onReceive(Context context, Intent intent) {
+            String action = intent.getAction();
+            //蓝牙发现
+            if (BluetoothDevice.ACTION_FOUND.equals(action)) {
+                Log.v("ble", "测试:搜索中");
+                BluetoothDevice device = intent.getParcelableExtra(BluetoothDevice.EXTRA_DEVICE);
+
+                if (device != null) {
+                    @SuppressLint("MissingPermission") String deviceName = device.getName();
+                    String deviceHardwareAddress = device.getAddress();
+                    @SuppressLint("MissingPermission") int deviceStatus = device.getBondState();
+
+
+                    @SuppressLint("MissingPermission") boolean supportBluetoothType = device.getType() == BluetoothDevice.DEVICE_TYPE_CLASSIC || device.getType() == BluetoothDevice.DEVICE_TYPE_DUAL;
+                    boolean supportPrintName;
+
+
+                    if (USER_DEFINED.equals(printNameStart)) {
+                        printNameStart = "";
+                    }
+
+                    if (TextUtils.isEmpty(printNameStart)) {
+                        supportPrintName = deviceName != null;
+                    } else {
+                        supportPrintName = deviceName != null && deviceName.startsWith(printNameStart);
+                    }
+
+                    if (supportBluetoothType && supportPrintName) {
+
+                        Log.d("ble", "测试:打印机名称- " + deviceName + "，设备地址:" + deviceHardwareAddress + "，设备类型:" + device.getType() + ", 设备状态："+deviceStatus);
+                        Log.d("ble",  ":" + "onDiscoveryDeviceStreamHandler" +  (onDiscoveryDeviceStreamHandler != null) + "onDiscoveryDeviceStreamHandler.sink != null:" + (onDiscoveryDeviceStreamHandler.sink));
+                        if (onDiscoveryDeviceStreamHandler != null && onDiscoveryDeviceStreamHandler.sink != null) {
+                            onDiscoveryDeviceStreamHandler.sink.success(deviceName+delimiterStr+deviceHardwareAddress+delimiterStr+deviceStatus);
+                        }
+                    }
+                }
+            } else if (BluetoothAdapter.ACTION_DISCOVERY_STARTED.equals(action)) {
+                Log.v("ble", "测试:开始搜索");
+                Log.d("ble",  ":" + "onDeviceStateStreamHandler" +  (onDeviceStateStreamHandler != null) + "onDeviceStateStreamHandler.sink != null:" + (onDeviceStateStreamHandler.sink));
+                if (onDeviceStateStreamHandler != null && onDeviceStateStreamHandler.sink != null) {
+                    onDeviceStateStreamHandler.sink.success("scanStart");
+                }
+            } else if (BluetoothAdapter.ACTION_DISCOVERY_FINISHED.equals(action)) {
+                Log.v("ble", "测试:搜索结束");
+//                bind.spinKit.setVisibility(View.GONE);
+                Log.d("ble",  ":" + "onDeviceStateStreamHandler" +  (onDeviceStateStreamHandler != null) + "onDeviceStateStreamHandler.sink != null:" + (onDeviceStateStreamHandler.sink));
+                if (onDeviceStateStreamHandler != null && onDeviceStateStreamHandler.sink != null) {
+                    onDeviceStateStreamHandler.sink.success("scanEnd");
+                }
+            } else if (BluetoothDevice.ACTION_BOND_STATE_CHANGED.equals(action)) {
+                int state = intent.getIntExtra(BluetoothDevice.EXTRA_BOND_STATE, -1);
+                Log.d("ble", "测试:配对状态改变:0 " + state);
+                if(itemPosition != null) {
+                    itemPosition.setConnectState(state);
+                    if (onDiscoveryDeviceStreamHandler != null && onDiscoveryDeviceStreamHandler.sink != null) {
+                        onDiscoveryDeviceStreamHandler.sink.success(itemPosition.getDeviceName()+delimiterStr+itemPosition.getDeviceHardwareAddress()+delimiterStr+itemPosition.getConnectState());
+                    }
+                }
+            } else if (BluetoothDevice.ACTION_PAIRING_REQUEST.equals(action)) {
+
+                if (onDeviceStateStreamHandler != null && onDeviceStateStreamHandler.sink != null) {
+                    onDeviceStateStreamHandler.sink.success("pairEnd");
+                }
+            }
+        }
+    };
+
+
+}
+
+
+class OnDiscoveryDeviceStreamHandler implements EventChannel.StreamHandler {
+
+    public EventChannel.EventSink sink;
+
+    @Override
+    public void onListen(Object o, EventChannel.EventSink eventSink) {
+
+        Log.d("ble", "OnDiscoveryDeviceStreamHandler: onListen");
+        sink = eventSink;
+    }
+    @Override
+    public void onCancel(Object o) {
+
+        Log.e("zhousuhua","OnReceiveDataStreamHandler=== onCancel");
+        sink = null;
+    }
+}
+
+class OnDeviceStateStreamHandler implements EventChannel.StreamHandler {
+
+    public EventChannel.EventSink sink;
+
+    @Override
+    public void onListen(Object o, EventChannel.EventSink eventSink) {
+
+        Log.d("ble", "OnDeviceStateStreamHandler: onListen");
+        sink = eventSink;
+    }
+    @Override
+    public void onCancel(Object o) {
+
+        Log.e("zhousuhua","OnReceiveDataStreamHandler=== onCancel");
+        sink = null;
+    }
+}

android/app/src/main/java/io/flutter/plugins/bean/BlueDeviceInfo.java

@@ -0,0 +1,58 @@
+package io.flutter.plugins.bean;
+
+import androidx.annotation.Nullable;
+
+public class BlueDeviceInfo {
+
+
+    String deviceName;
+    String deviceHardwareAddress;
+    int connectState;
+
+    public BlueDeviceInfo(String deviceName, String deviceHardwareAddress, int connectState) {
+        this.deviceName = deviceName;
+        this.deviceHardwareAddress = deviceHardwareAddress;
+        this.connectState = connectState;
+    }
+
+    public String getDeviceName() {
+        return deviceName;
+    }
+
+    public void setDeviceName(String deviceName) {
+        this.deviceName = deviceName;
+    }
+
+    public String getDeviceHardwareAddress() {
+        return deviceHardwareAddress;
+    }
+
+    public void setDeviceHardwareAddress(String deviceHardwareAddress) {
+        this.deviceHardwareAddress = deviceHardwareAddress;
+    }
+
+    public int getConnectState() {
+        return connectState;
+    }
+
+    public void setConnectState(int connectState) {
+        this.connectState = connectState;
+    }
+
+
+    @Override
+    public int hashCode() {
+        return deviceName.hashCode();
+    }
+
+    @Override
+    public boolean equals(@Nullable Object obj) {
+        BlueDeviceInfo blueDeviceInfo = (BlueDeviceInfo) obj;
+        if (blueDeviceInfo != null) {
+            return deviceName.equals(blueDeviceInfo.deviceName);
+        }
+
+        return false;
+
+    }
+}

android/app/src/main/java/io/flutter/plugins/utils/BTPPrintUtil.java

@@ -0,0 +1,85 @@
+package io.flutter.plugins.utils;
+
+import android.graphics.Bitmap;
+import android.graphics.BitmapFactory;
+import android.util.Log;
+
+import androidx.annotation.NonNull;
+
+import com.snbc.sdk.LabelPrinter;
+
+import java.io.ByteArrayOutputStream;
+import java.nio.ByteBuffer;
+
+import io.flutter.plugin.common.MethodChannel;
+
+public class BTPPrintUtil {
+
+
+    /**
+     * 单例实例，使用 volatile 保证多线程可见性和有序性
+     */
+    private static volatile LabelPrinter labelPrinter;
+
+    private static int nLang = 2;
+
+    /**
+     * 获取 LabelPrinter 单例实例
+     *
+     * @return LabelPrinter 实例
+     */
+    public static LabelPrinter getInstance() {
+        // 双重检查锁定以确保只初始化一次实例
+        if (labelPrinter == null) {
+            synchronized (BTPPrintUtil.class) {
+                if (labelPrinter == null) {
+                    labelPrinter = new LabelPrinter();
+                }
+            }
+        }
+
+        return labelPrinter;
+    }
+
+    /**
+     * 通过打印机mac地址进行蓝牙连接开启打印机（同步）
+     *
+     * @param address 打印机地址
+     * @return 成功与否
+     */
+    public static int connectBluetoothPrinter(String address) {
+//        return 1;
+        // 获取单例实例以确保线程安全
+        return getInstance().ConnectPrinter(7, address, 4);
+    }
+
+    public static void printBitMap(Bitmap bitmap, String deviceName, @NonNull MethodChannel.Result result) {
+
+        int x = 0;
+        if(deviceName.contains("BTP-UP321")) {
+            x = 0;
+        } else if(deviceName.contains("BTP-P398PLUS")) {
+            x = 40;
+        }
+        int bytes = bitmap.getByteCount();
+        ByteBuffer buf = ByteBuffer.allocate(bytes);
+        bitmap.copyPixelsToBuffer(buf);
+        ByteArrayOutputStream LionData=new ByteArrayOutputStream();
+        bitmap.compress(Bitmap.CompressFormat.PNG, 100, LionData);
+
+        getInstance().SetLabelSize(560,640);
+        int code = getInstance().PrintImageData(x, 0, LionData.toByteArray());
+        getInstance().PrintLabel(1,1);
+        result.success(code == 0 ? true : false);
+    }
+
+    public  static void printBarCodeWithText(String barCode, String text, @NonNull MethodChannel.Result result) {
+
+        getInstance().SetLabelSize(560,640);
+        labelPrinter.PrintBarcodeQR(80, 20,  0, "SHXM2024007404", 'H', 18, 2);
+        labelPrinter.PrintText(100, 500, "8", "SHXM2024007404", 0, 7, 3, 0);
+        int code = getInstance().PrintLabel(1,1);
+        result.success(code == 0 ? true : false);
+    }
+
+}

android/app/src/main/java/io/flutter/plugins/utils/BluetoothUtils.java

@@ -0,0 +1,31 @@
+package io.flutter.plugins.utils;
+
+import android.bluetooth.BluetoothDevice;
+
+import java.lang.reflect.Method;
+
+/**
+ * 蓝牙工具类，用于处理蓝牙设备配对等操作。
+ * @author zhangbin
+ */
+public class BluetoothUtils {
+
+    /**
+     * 与设备配对
+     *
+     * @param btDevice 要配对的蓝牙设备
+     * @return 配对是否成功
+     * @throws Exception 反射调用可能引发异常
+     */
+    public static boolean createBond(BluetoothDevice btDevice) throws Exception {
+        // 获取 BluetoothDevice 类的类对象
+        Class<?> btClass = BluetoothDevice.class;
+
+        // 获取 createBond 方法的引用
+        Method createBondMethod = btClass.getMethod("createBond");
+        // 调用 createBond 方法，返回配对结果
+        return (Boolean) createBondMethod.invoke(btDevice);
+    }
+
+
+}

android/app/src/main/java/io/flutter/plugins/utils/PrintUtil.java

@@ -0,0 +1,300 @@
+package io.flutter.plugins.utils;
+
+
+import android.app.Application;
+import android.content.res.AssetManager;
+import android.graphics.Bitmap;
+import android.graphics.BitmapFactory;
+import android.graphics.Canvas;
+import android.graphics.Color;
+import android.graphics.Paint;
+import android.util.Log;
+import android.widget.Toast;
+
+import androidx.annotation.NonNull;
+
+import com.gengcon.www.jcprintersdk.JCPrintApi;
+import com.gengcon.www.jcprintersdk.callback.Callback;
+import com.gengcon.www.jcprintersdk.callback.PrintCallback;
+import com.szls.lszlgl.app.MyApplication;
+
+import java.io.File;
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+import io.flutter.plugin.common.MethodChannel;
+
+/**
+ * 打印工具类
+ *
+ * @author zhangbin
+ */
+public class PrintUtil {
+    private static final String TAG = "PrintUtil";
+    private static int mConnectedType = -1;
+    /**
+     * 单例实例，使用 volatile 保证多线程可见性和有序性
+     */
+    private static volatile JCPrintApi api;
+
+    /**
+     * 回调接口，用于处理打印机状态变化事件
+     */
+    private static final Callback CALLBACK = new Callback() {
+        private static final String TAG = "PrintUtil";
+
+        /**
+         * 连接成功回调
+         *
+         * @param address 设备地址，蓝牙为蓝牙 MAC 地址，WIFI 为 IP 地址
+         * @param type   连接类型，0 表示蓝牙连接，1 表示 WIFI 连接
+         */
+        @Override
+        public void onConnectSuccess(String address, int type) {
+            mConnectedType = type;
+        }
+
+        /**
+         * 断开连接回调
+         * 当设备断开连接时，将调用此方法。
+         */
+        @Override
+        public void onDisConnect() {
+            mConnectedType = -1;
+        }
+
+        /**
+         * 电量变化回调
+         * 当设备电量发生变化时，将调用此方法。
+         *
+         * @param powerLevel 电量等级，取值范围为 1 到 4，代表有 1 到 4 格电，满电是 4 格
+         */
+        @Override
+        public void onElectricityChange(int powerLevel) {
+
+        }
+
+        /**
+         * 监测上盖状态变化回调
+         * 当上盖状态发生变化时，将调用此方法。目前该回调仅支持 H10/D101/D110/D11/B21/B16/B32/Z401/B3S/B203/B1/B18 系列打印机。
+         *
+         * @param coverStatus 上盖状态，0 表示上盖打开，1 表示上盖关闭
+         */
+        @Override
+        public void onCoverStatus(int coverStatus) {
+
+        }
+
+        /**
+         * 监测纸张状态变化
+         * 当纸张状态发生变化时，将调用此方法。目前该回调仅支持H10/D101/D110/D11/B21/B16/B32/Z401/B203/B1/B18 系列打印机。
+         *
+         * @param paperStatus 0为不缺纸 1为缺纸
+         */
+        @Override
+        public void onPaperStatus(int paperStatus) {
+
+        }
+
+        /**
+         * 监测标签rfid读取状态变化
+         * 当标签rfid读取状态发生变化时，将调用此方法。
+         *
+         * @param rfidReadStatus 0为未读取到标签RFID 1为成功读取到标签RFID 目前该回调仅支持H10/D101/D110/D11/B21/B16/B32/Z401/B203/B1/B18 系列打印机。
+         */
+        @Override
+        public void onRfidReadStatus(int rfidReadStatus) {
+
+        }
+
+
+        /**
+         * 监测碳带rfid读取状态变化
+         * 当碳带rfid读取状态发生变化时，将调用此方法。
+         *
+         * @param ribbonRfidReadStatus 0为未读取到碳带RFID 1为成功读取到碳带RFID 目前该回调仅支持B18/B32/Z401/P1/P1S 系列打印机。
+         */
+        @Override
+        public void onRibbonRfidReadStatus(int ribbonRfidReadStatus) {
+
+        }
+
+        /**
+         * 监测碳带状态变化
+         * 当纸张状态发生变化时，将调用此方法
+         *
+         * @param ribbonStatus 0为无碳带 1为有碳带 目前该回调仅支持B18/B32/Z401/P1/P1S系列打印机。
+         */
+        @Override
+        public void onRibbonStatus(int ribbonStatus) {
+
+        }
+
+
+        /**
+         * 固件异常回调，需要升级
+         * 当设备连接成功但出现固件异常时，将调用此方法，表示需要进行固件升级。
+         */
+        @Override
+        public void onFirmErrors() {
+
+        }
+    };
+
+
+    /**
+     * 获取 JCPrintApi 单例实例
+     *
+     * @return JCPrintApi 实例
+     */
+    public static JCPrintApi getInstance() {
+        // 双重检查锁定以确保只初始化一次实例
+        if (api == null) {
+            synchronized (PrintUtil.class) {
+                if (api == null) {
+                    api = JCPrintApi.getInstance(CALLBACK);
+                    //api.init已废弃，使用initSdk替代，方法名含义更准确
+
+                    api.initSdk(MyApplication.getInstance());
+                    //获取内置目录路径
+                    File directory = MyApplication.getInstance().getFilesDir();
+                    //获取自定义字体路径
+                    File customFontDirectory = new File(directory, "custom_font");
+                    api.initDefaultImageLibrarySettings(customFontDirectory.getAbsolutePath(), "");
+
+                }
+            }
+        }
+
+        return api;
+
+    }
+
+
+    /**
+     * 通过打印机mac地址进行蓝牙连接开启打印机（同步）
+     *
+     * @param address 打印机地址
+     * @return 成功与否
+     */
+    public static int connectBluetoothPrinter(String address) {
+        // 获取单例实例以确保线程安全
+        JCPrintApi localApi = getInstance();
+        //api.openPrinterByAddress(address)，使用connectBluetoothPrinter替代，方法名含义更准确
+        return localApi.connectBluetoothPrinter(address);
+    }
+
+    /**
+     * 关闭打印机
+     */
+    public static void close() {
+        // 获取单例实例以确保线程安全
+        JCPrintApi localApi = getInstance();
+        localApi.close();
+    }
+
+
+    public static int getConnectedType() {
+        return mConnectedType;
+    }
+
+    public static void setConnectedType(int connectedType) {
+        mConnectedType = connectedType;
+    }
+
+    /**
+     * 检查打印机是否连接
+     *
+     * @return 连接状态代码
+     */
+    public static int isConnection() {
+        // 获取单例实例以确保线程安全
+        JCPrintApi localApi = getInstance();
+        return localApi.isConnection();
+    }
+
+    public static void printBitMap(Bitmap bitmap, @NonNull MethodChannel.Result result) {
+        if (PrintUtil.isConnection() != 0) {
+//            handler.post(() -> Toast.makeText(MyApplication.getInstance(), "未连接打印机", Toast.LENGTH_SHORT).show());
+            result.success(false);
+            return;
+        }
+
+        //重置错误状态变量
+        final boolean[] isError = {false};
+        //重置取消打印状态变量
+        final boolean[] isCancel = {false};
+
+        final int[] orientation = {0};
+
+        int pageCount = 1;
+        int quantity = 1;
+        int printMultiple = 8;
+        final int[] generatedPrintDataPageCount = {0};
+        int totalQuantity = pageCount * quantity;
+
+        //setTotalQuantityOfPrints已废弃，使用方法含义更明确的setTotalPrintQuantity
+        PrintUtil.getInstance().setTotalPrintQuantity(totalQuantity);
+        /*
+         * 参数1：打印浓度 ，参数2:纸张类型 参数3:打印模式
+         * 打印浓度 B50/B50W/T6/T7/T8 建议设置6或8，Z401/B32建议设置8，B3S/B21/B203/B1建议设置3
+         */
+        PrintUtil.getInstance().startPrintJob(3, 3, 1, new PrintCallback() {
+            @Override
+            public void onProgress(int pageIndex, int quantityIndex, HashMap<String, Object> hashMap) {
+//                handler.post(() -> fragment.setStateStr("打印进度:已打印到第" + pageIndex + "页,第" + quantityIndex + "份"));
+                Log.d("ble", "测试：打印进度:已打印到第: " + pageIndex);
+                //打印进度回调
+                if (pageIndex == pageCount && quantityIndex == quantity) {
+                    Log.d("ble", "测试:onProgress: 结束打印");
+                    //endJob已废弃，使用方法含义更明确的endPrintJob
+                    if (PrintUtil.getInstance().endPrintJob()) {
+                        Log.d("ble", "结束打印成功");
+                    } else {
+                        Log.d("ble", "结束打印失败");
+                    }
+                    result.success(true);
+                }
+            }
+
+            @Override
+            public void onError(int i) {
+
+            }
+
+
+            @Override
+            public void onError(int errorCode, int printState) {
+                Log.d("ble", "测试:onError");
+                isError[0] = true;
+                result.success(false);
+            }
+
+            @Override
+            public void onCancelJob(boolean isSuccess) {
+                //取消打印成功回调
+                isCancel[0] = true;
+            }
+
+            @Override
+            public void onBufferFree(int pageIndex, int bufferSize) {
+                if (isError[0] || isCancel[0] || pageIndex > pageCount) {
+                    Log.d("ble", "测试:onBufferFree error");
+                    return;
+                }
+
+                if (generatedPrintDataPageCount[0] < pageCount) {
+
+                    int bitmapWidth = bitmap.getWidth();
+                    int bitmapHeight = bitmap.getHeight();
+                    Log.d("ble", "bitmapWidth："+bitmapWidth+",bitmapHeight:"+bitmapHeight);
+                    PrintUtil.getInstance().commitImageData(orientation[0], bitmap, (int) (bitmapWidth / printMultiple), (int) (bitmapHeight / printMultiple), 1, 0, 0, 0, 0, "");
+                }
+            }
+        });
+    }
+
+
+}

android/build.gradle

@@ -1,16 +1,3 @@
-buildscript {
-    ext.kotlin_version = '1.8.22'
-    repositories {
-        google()
-        mavenCentral()
-    }
-
-    dependencies {
-        classpath 'com.android.tools.build:gradle:7.3.0'
-        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
-    }
-}
-
 allprojects {
     repositories {
         google()

android/settings.gradle

@@ -10,11 +10,17 @@ pluginManagement {
 
     includeBuild("${settings.ext.flutterSdkPath}/packages/flutter_tools/gradle")
 
-    plugins {
-        id "dev.flutter.flutter-gradle-plugin" version "1.0.0" apply false
+    repositories {
+        google()
+        mavenCentral()
+        gradlePluginPortal()
     }
 }
 
-include ":app"
+plugins {
+    id "dev.flutter.flutter-plugin-loader" version "1.0.0"
+    id "com.android.application" version "7.3.0" apply false
+    id "org.jetbrains.kotlin.android" version "1.7.10" apply false
+}
 
-apply from: "${settings.ext.flutterSdkPath}/packages/flutter_tools/gradle/app_plugin_loader.gradle"
+include ":app"

lib/config/pics.dart

@@ -41,4 +41,10 @@ const String imgScanBack = 'assets/images/scan_back.webp';
 // 扫一扫 闪光灯
 const String imgScanFlash= 'assets/images/scan_flash.webp';
 // 扫一扫 扫描中
-const String imgScanScanning= 'assets/images/scan_scanning.webp';
+const String imgScanScanning= 'assets/images/scan_scanning.webp';
+
+// 搜索图标
+const String imgBleSearch = 'assets/images/search_ble.png';
+// 打印图标
+const String imgBlePrint = 'assets/images/print_ble.png';
+

lib/drfit/dao/device_info_table_dao.dart

@@ -0,0 +1,27 @@
+import 'package:drift/drift.dart';
+import 'package:lszlgl/drfit/database.dart';
+import 'package:lszlgl/drfit/device_info_table.dart';
+import 'package:lszlgl/service/user_service.dart';
+
+part 'device_info_table_dao.g.dart';
+
+@DriftAccessor(tables: [DeviceInfoTable])
+class DeviceInfoTableDao extends DatabaseAccessor<MyDatabase> {
+  DeviceInfoTableDao(MyDatabase db) : super(db);
+
+  Future<int> addOneDeviceComp(DeviceInfoTableCompanion deviceInfoTableCompanion) async {
+    return into(db.deviceInfoTable).insert(deviceInfoTableCompanion, mode: InsertMode.insertOrReplace);
+  }
+
+  Future<List<DeviceInfo>> queryAllDeviceInfo() async {
+
+    int deviceInfoTableTime = UserService.get().getDeviceInfoTableTime();
+    return (select(db.deviceInfoTable)
+      ..where((tbl) => tbl.createdAt.isBiggerThanValue(deviceInfoTableTime))
+      ..orderBy([(row) => OrderingTerm.asc(row.createdAt)])).get();
+  }
+
+
+
+
+}

lib/drfit/dao/device_info_table_dao.g.dart

@@ -0,0 +1,8 @@
+// GENERATED CODE - DO NOT MODIFY BY HAND
+
+part of 'device_info_table_dao.dart';
+
+// ignore_for_file: type=lint
+mixin _$DeviceInfoTableDaoMixin on DatabaseAccessor<MyDatabase> {
+  $DeviceInfoTableTable get deviceInfoTable => attachedDatabase.deviceInfoTable;
+}

lib/drfit/database.dart

@@ -0,0 +1,63 @@
+import 'dart:io';
+
+import 'package:dio/dio.dart';
+import 'package:drift/drift.dart';
+import 'package:drift/native.dart';
+import 'package:lszlgl/main.dart';
+import 'package:lszlgl/model/req/device_req.dart';
+import 'package:path_provider/path_provider.dart';
+import 'package:path/path.dart' as p;
+
+import '../network/my_api.dart';
+import '../service/user_service.dart';
+import 'dao/device_info_table_dao.dart';
+import 'device_info_table.dart';
+
+
+part 'database.g.dart';
+
+@DriftDatabase(tables: [DeviceInfoTable], daos: [DeviceInfoTableDao])
+class MyDatabase extends _$MyDatabase {
+  MyDatabase() : super(_openConnection());
+  // MyDatabase(super.e);
+
+
+  @override
+  int get schemaVersion => 1;
+
+
+  /// 同步数据到服务器
+  Future<void> savaBleDataToServer() async {
+    List<DeviceInfo> deviceInfos = await database.deviceInfoTableDao.queryAllDeviceInfo();
+
+    List<DeviceReq> deviceRes = [];
+    for(DeviceInfo device in deviceInfos) {
+      deviceRes.add(DeviceReq.fromJson(device.toJson()));
+    }
+    if(deviceRes.isEmpty) {
+      return;
+    }
+    try {
+      // 获取用户数据
+      var user = await MyApi.get().postDeviceInfos(deviceRes);
+      logger.d('====user:$user');
+      // 记录末次同步id
+      UserService.get().saveDeviceInfoTableTime(deviceInfos.last.createdAt);
+    } on DioException catch (_) {
+    } on Exception catch (a, _) {
+    }
+
+  }
+
+}
+
+LazyDatabase _openConnection() {
+
+  return LazyDatabase(() async {
+
+    final documentsDir = await getApplicationDocumentsDirectory();
+    final file = File(p.join(documentsDir.path, 'myDatabase.db'));
+
+    return NativeDatabase.createInBackground(file);
+  });
+}

lib/drfit/database.g.dart

@@ -0,0 +1,657 @@
+// GENERATED CODE - DO NOT MODIFY BY HAND
+
+part of 'database.dart';
+
+// ignore_for_file: type=lint
+class $DeviceInfoTableTable extends DeviceInfoTable
+    with TableInfo<$DeviceInfoTableTable, DeviceInfo> {
+  @override
+  final GeneratedDatabase attachedDatabase;
+  final String? _alias;
+  $DeviceInfoTableTable(this.attachedDatabase, [this._alias]);
+  static const VerificationMeta _usernameMeta =
+      const VerificationMeta('username');
+  @override
+  late final GeneratedColumn<String> username = GeneratedColumn<String>(
+      'username', aliasedName, false,
+      type: DriftSqlType.string, requiredDuringInsert: true);
+  static const VerificationMeta _phoneBrandMeta =
+      const VerificationMeta('phoneBrand');
+  @override
+  late final GeneratedColumn<String> phoneBrand = GeneratedColumn<String>(
+      'phone_brand', aliasedName, false,
+      type: DriftSqlType.string, requiredDuringInsert: true);
+  static const VerificationMeta _phoneModelMeta =
+      const VerificationMeta('phoneModel');
+  @override
+  late final GeneratedColumn<String> phoneModel = GeneratedColumn<String>(
+      'phone_model', aliasedName, false,
+      type: DriftSqlType.string, requiredDuringInsert: true);
+  static const VerificationMeta _phoneReleaseMeta =
+      const VerificationMeta('phoneRelease');
+  @override
+  late final GeneratedColumn<String> phoneRelease = GeneratedColumn<String>(
+      'phone_release', aliasedName, false,
+      type: DriftSqlType.string, requiredDuringInsert: true);
+  static const VerificationMeta _phoneAddressMeta =
+      const VerificationMeta('phoneAddress');
+  @override
+  late final GeneratedColumn<String> phoneAddress = GeneratedColumn<String>(
+      'phone_address', aliasedName, false,
+      type: DriftSqlType.string, requiredDuringInsert: true);
+  static const VerificationMeta _bleMacMeta = const VerificationMeta('bleMac');
+  @override
+  late final GeneratedColumn<String> bleMac = GeneratedColumn<String>(
+      'ble_mac', aliasedName, false,
+      type: DriftSqlType.string, requiredDuringInsert: true);
+  static const VerificationMeta _bleNameMeta =
+      const VerificationMeta('bleName');
+  @override
+  late final GeneratedColumn<String> bleName = GeneratedColumn<String>(
+      'ble_name', aliasedName, false,
+      type: DriftSqlType.string, requiredDuringInsert: true);
+  static const VerificationMeta _createdAtMeta =
+      const VerificationMeta('createdAt');
+  @override
+  late final GeneratedColumn<int> createdAt = GeneratedColumn<int>(
+      'created_at', aliasedName, false,
+      type: DriftSqlType.int, requiredDuringInsert: true);
+  @override
+  List<GeneratedColumn> get $columns => [
+        username,
+        phoneBrand,
+        phoneModel,
+        phoneRelease,
+        phoneAddress,
+        bleMac,
+        bleName,
+        createdAt
+      ];
+  @override
+  String get aliasedName => _alias ?? actualTableName;
+  @override
+  String get actualTableName => $name;
+  static const String $name = 'device_info_table';
+  @override
+  VerificationContext validateIntegrity(Insertable<DeviceInfo> instance,
+      {bool isInserting = false}) {
+    final context = VerificationContext();
+    final data = instance.toColumns(true);
+    if (data.containsKey('username')) {
+      context.handle(_usernameMeta,
+          username.isAcceptableOrUnknown(data['username']!, _usernameMeta));
+    } else if (isInserting) {
+      context.missing(_usernameMeta);
+    }
+    if (data.containsKey('phone_brand')) {
+      context.handle(
+          _phoneBrandMeta,
+          phoneBrand.isAcceptableOrUnknown(
+              data['phone_brand']!, _phoneBrandMeta));
+    } else if (isInserting) {
+      context.missing(_phoneBrandMeta);
+    }
+    if (data.containsKey('phone_model')) {
+      context.handle(
+          _phoneModelMeta,
+          phoneModel.isAcceptableOrUnknown(
+              data['phone_model']!, _phoneModelMeta));
+    } else if (isInserting) {
+      context.missing(_phoneModelMeta);
+    }
+    if (data.containsKey('phone_release')) {
+      context.handle(
+          _phoneReleaseMeta,
+          phoneRelease.isAcceptableOrUnknown(
+              data['phone_release']!, _phoneReleaseMeta));
+    } else if (isInserting) {
+      context.missing(_phoneReleaseMeta);
+    }
+    if (data.containsKey('phone_address')) {
+      context.handle(
+          _phoneAddressMeta,
+          phoneAddress.isAcceptableOrUnknown(
+              data['phone_address']!, _phoneAddressMeta));
+    } else if (isInserting) {
+      context.missing(_phoneAddressMeta);
+    }
+    if (data.containsKey('ble_mac')) {
+      context.handle(_bleMacMeta,
+          bleMac.isAcceptableOrUnknown(data['ble_mac']!, _bleMacMeta));
+    } else if (isInserting) {
+      context.missing(_bleMacMeta);
+    }
+    if (data.containsKey('ble_name')) {
+      context.handle(_bleNameMeta,
+          bleName.isAcceptableOrUnknown(data['ble_name']!, _bleNameMeta));
+    } else if (isInserting) {
+      context.missing(_bleNameMeta);
+    }
+    if (data.containsKey('created_at')) {
+      context.handle(_createdAtMeta,
+          createdAt.isAcceptableOrUnknown(data['created_at']!, _createdAtMeta));
+    } else if (isInserting) {
+      context.missing(_createdAtMeta);
+    }
+    return context;
+  }
+
+  @override
+  Set<GeneratedColumn> get $primaryKey => {bleMac, username};
+  @override
+  DeviceInfo map(Map<String, dynamic> data, {String? tablePrefix}) {
+    final effectivePrefix = tablePrefix != null ? '$tablePrefix.' : '';
+    return DeviceInfo(
+      username: attachedDatabase.typeMapping
+          .read(DriftSqlType.string, data['${effectivePrefix}username'])!,
+      phoneBrand: attachedDatabase.typeMapping
+          .read(DriftSqlType.string, data['${effectivePrefix}phone_brand'])!,
+      phoneModel: attachedDatabase.typeMapping
+          .read(DriftSqlType.string, data['${effectivePrefix}phone_model'])!,
+      phoneRelease: attachedDatabase.typeMapping
+          .read(DriftSqlType.string, data['${effectivePrefix}phone_release'])!,
+      phoneAddress: attachedDatabase.typeMapping
+          .read(DriftSqlType.string, data['${effectivePrefix}phone_address'])!,
+      bleMac: attachedDatabase.typeMapping
+          .read(DriftSqlType.string, data['${effectivePrefix}ble_mac'])!,
+      bleName: attachedDatabase.typeMapping
+          .read(DriftSqlType.string, data['${effectivePrefix}ble_name'])!,
+      createdAt: attachedDatabase.typeMapping
+          .read(DriftSqlType.int, data['${effectivePrefix}created_at'])!,
+    );
+  }
+
+  @override
+  $DeviceInfoTableTable createAlias(String alias) {
+    return $DeviceInfoTableTable(attachedDatabase, alias);
+  }
+}
+
+class DeviceInfo extends DataClass implements Insertable<DeviceInfo> {
+  /// 登录用户名
+  final String username;
+
+  /// 登录手机品牌，如Redmi
+  final String phoneBrand;
+
+  /// 登录手机认证型号，如22120RN86C
+  final String phoneModel;
+
+  /// 登录手机版本，如14
+  final String phoneRelease;
+
+  /// 登录手机所在地址，如"北京市西城区月坛北街18号靠近物资大院"
+  final String phoneAddress;
+
+  /// 登录蓝牙mac地址
+  final String bleMac;
+
+  /// 登录蓝牙名称
+  final String bleName;
+
+  /// 日期
+  final int createdAt;
+  const DeviceInfo(
+      {required this.username,
+      required this.phoneBrand,
+      required this.phoneModel,
+      required this.phoneRelease,
+      required this.phoneAddress,
+      required this.bleMac,
+      required this.bleName,
+      required this.createdAt});
+  @override
+  Map<String, Expression> toColumns(bool nullToAbsent) {
+    final map = <String, Expression>{};
+    map['username'] = Variable<String>(username);
+    map['phone_brand'] = Variable<String>(phoneBrand);
+    map['phone_model'] = Variable<String>(phoneModel);
+    map['phone_release'] = Variable<String>(phoneRelease);
+    map['phone_address'] = Variable<String>(phoneAddress);
+    map['ble_mac'] = Variable<String>(bleMac);
+    map['ble_name'] = Variable<String>(bleName);
+    map['created_at'] = Variable<int>(createdAt);
+    return map;
+  }
+
+  DeviceInfoTableCompanion toCompanion(bool nullToAbsent) {
+    return DeviceInfoTableCompanion(
+      username: Value(username),
+      phoneBrand: Value(phoneBrand),
+      phoneModel: Value(phoneModel),
+      phoneRelease: Value(phoneRelease),
+      phoneAddress: Value(phoneAddress),
+      bleMac: Value(bleMac),
+      bleName: Value(bleName),
+      createdAt: Value(createdAt),
+    );
+  }
+
+  factory DeviceInfo.fromJson(Map<String, dynamic> json,
+      {ValueSerializer? serializer}) {
+    serializer ??= driftRuntimeOptions.defaultSerializer;
+    return DeviceInfo(
+      username: serializer.fromJson<String>(json['username']),
+      phoneBrand: serializer.fromJson<String>(json['phoneBrand']),
+      phoneModel: serializer.fromJson<String>(json['phoneModel']),
+      phoneRelease: serializer.fromJson<String>(json['phoneRelease']),
+      phoneAddress: serializer.fromJson<String>(json['phoneAddress']),
+      bleMac: serializer.fromJson<String>(json['bleMac']),
+      bleName: serializer.fromJson<String>(json['bleName']),
+      createdAt: serializer.fromJson<int>(json['createdAt']),
+    );
+  }
+  @override
+  Map<String, dynamic> toJson({ValueSerializer? serializer}) {
+    serializer ??= driftRuntimeOptions.defaultSerializer;
+    return <String, dynamic>{
+      'username': serializer.toJson<String>(username),
+      'phoneBrand': serializer.toJson<String>(phoneBrand),
+      'phoneModel': serializer.toJson<String>(phoneModel),
+      'phoneRelease': serializer.toJson<String>(phoneRelease),
+      'phoneAddress': serializer.toJson<String>(phoneAddress),
+      'bleMac': serializer.toJson<String>(bleMac),
+      'bleName': serializer.toJson<String>(bleName),
+      'createdAt': serializer.toJson<int>(createdAt),
+    };
+  }
+
+  DeviceInfo copyWith(
+          {String? username,
+          String? phoneBrand,
+          String? phoneModel,
+          String? phoneRelease,
+          String? phoneAddress,
+          String? bleMac,
+          String? bleName,
+          int? createdAt}) =>
+      DeviceInfo(
+        username: username ?? this.username,
+        phoneBrand: phoneBrand ?? this.phoneBrand,
+        phoneModel: phoneModel ?? this.phoneModel,
+        phoneRelease: phoneRelease ?? this.phoneRelease,
+        phoneAddress: phoneAddress ?? this.phoneAddress,
+        bleMac: bleMac ?? this.bleMac,
+        bleName: bleName ?? this.bleName,
+        createdAt: createdAt ?? this.createdAt,
+      );
+  @override
+  String toString() {
+    return (StringBuffer('DeviceInfo(')
+          ..write('username: $username, ')
+          ..write('phoneBrand: $phoneBrand, ')
+          ..write('phoneModel: $phoneModel, ')
+          ..write('phoneRelease: $phoneRelease, ')
+          ..write('phoneAddress: $phoneAddress, ')
+          ..write('bleMac: $bleMac, ')
+          ..write('bleName: $bleName, ')
+          ..write('createdAt: $createdAt')
+          ..write(')'))
+        .toString();
+  }
+
+  @override
+  int get hashCode => Object.hash(username, phoneBrand, phoneModel,
+      phoneRelease, phoneAddress, bleMac, bleName, createdAt);
+  @override
+  bool operator ==(Object other) =>
+      identical(this, other) ||
+      (other is DeviceInfo &&
+          other.username == this.username &&
+          other.phoneBrand == this.phoneBrand &&
+          other.phoneModel == this.phoneModel &&
+          other.phoneRelease == this.phoneRelease &&
+          other.phoneAddress == this.phoneAddress &&
+          other.bleMac == this.bleMac &&
+          other.bleName == this.bleName &&
+          other.createdAt == this.createdAt);
+}
+
+class DeviceInfoTableCompanion extends UpdateCompanion<DeviceInfo> {
+  final Value<String> username;
+  final Value<String> phoneBrand;
+  final Value<String> phoneModel;
+  final Value<String> phoneRelease;
+  final Value<String> phoneAddress;
+  final Value<String> bleMac;
+  final Value<String> bleName;
+  final Value<int> createdAt;
+  final Value<int> rowid;
+  const DeviceInfoTableCompanion({
+    this.username = const Value.absent(),
+    this.phoneBrand = const Value.absent(),
+    this.phoneModel = const Value.absent(),
+    this.phoneRelease = const Value.absent(),
+    this.phoneAddress = const Value.absent(),
+    this.bleMac = const Value.absent(),
+    this.bleName = const Value.absent(),
+    this.createdAt = const Value.absent(),
+    this.rowid = const Value.absent(),
+  });
+  DeviceInfoTableCompanion.insert({
+    required String username,
+    required String phoneBrand,
+    required String phoneModel,
+    required String phoneRelease,
+    required String phoneAddress,
+    required String bleMac,
+    required String bleName,
+    required int createdAt,
+    this.rowid = const Value.absent(),
+  })  : username = Value(username),
+        phoneBrand = Value(phoneBrand),
+        phoneModel = Value(phoneModel),
+        phoneRelease = Value(phoneRelease),
+        phoneAddress = Value(phoneAddress),
+        bleMac = Value(bleMac),
+        bleName = Value(bleName),
+        createdAt = Value(createdAt);
+  static Insertable<DeviceInfo> custom({
+    Expression<String>? username,
+    Expression<String>? phoneBrand,
+    Expression<String>? phoneModel,
+    Expression<String>? phoneRelease,
+    Expression<String>? phoneAddress,
+    Expression<String>? bleMac,
+    Expression<String>? bleName,
+    Expression<int>? createdAt,
+    Expression<int>? rowid,
+  }) {
+    return RawValuesInsertable({
+      if (username != null) 'username': username,
+      if (phoneBrand != null) 'phone_brand': phoneBrand,
+      if (phoneModel != null) 'phone_model': phoneModel,
+      if (phoneRelease != null) 'phone_release': phoneRelease,
+      if (phoneAddress != null) 'phone_address': phoneAddress,
+      if (bleMac != null) 'ble_mac': bleMac,
+      if (bleName != null) 'ble_name': bleName,
+      if (createdAt != null) 'created_at': createdAt,
+      if (rowid != null) 'rowid': rowid,
+    });
+  }
+
+  DeviceInfoTableCompanion copyWith(
+      {Value<String>? username,
+      Value<String>? phoneBrand,
+      Value<String>? phoneModel,
+      Value<String>? phoneRelease,
+      Value<String>? phoneAddress,
+      Value<String>? bleMac,
+      Value<String>? bleName,
+      Value<int>? createdAt,
+      Value<int>? rowid}) {
+    return DeviceInfoTableCompanion(
+      username: username ?? this.username,
+      phoneBrand: phoneBrand ?? this.phoneBrand,
+      phoneModel: phoneModel ?? this.phoneModel,
+      phoneRelease: phoneRelease ?? this.phoneRelease,
+      phoneAddress: phoneAddress ?? this.phoneAddress,
+      bleMac: bleMac ?? this.bleMac,
+      bleName: bleName ?? this.bleName,
+      createdAt: createdAt ?? this.createdAt,
+      rowid: rowid ?? this.rowid,
+    );
+  }
+
+  @override
+  Map<String, Expression> toColumns(bool nullToAbsent) {
+    final map = <String, Expression>{};
+    if (username.present) {
+      map['username'] = Variable<String>(username.value);
+    }
+    if (phoneBrand.present) {
+      map['phone_brand'] = Variable<String>(phoneBrand.value);
+    }
+    if (phoneModel.present) {
+      map['phone_model'] = Variable<String>(phoneModel.value);
+    }
+    if (phoneRelease.present) {
+      map['phone_release'] = Variable<String>(phoneRelease.value);
+    }
+    if (phoneAddress.present) {
+      map['phone_address'] = Variable<String>(phoneAddress.value);
+    }
+    if (bleMac.present) {
+      map['ble_mac'] = Variable<String>(bleMac.value);
+    }
+    if (bleName.present) {
+      map['ble_name'] = Variable<String>(bleName.value);
+    }
+    if (createdAt.present) {
+      map['created_at'] = Variable<int>(createdAt.value);
+    }
+    if (rowid.present) {
+      map['rowid'] = Variable<int>(rowid.value);
+    }
+    return map;
+  }
+
+  @override
+  String toString() {
+    return (StringBuffer('DeviceInfoTableCompanion(')
+          ..write('username: $username, ')
+          ..write('phoneBrand: $phoneBrand, ')
+          ..write('phoneModel: $phoneModel, ')
+          ..write('phoneRelease: $phoneRelease, ')
+          ..write('phoneAddress: $phoneAddress, ')
+          ..write('bleMac: $bleMac, ')
+          ..write('bleName: $bleName, ')
+          ..write('createdAt: $createdAt, ')
+          ..write('rowid: $rowid')
+          ..write(')'))
+        .toString();
+  }
+}
+
+abstract class _$MyDatabase extends GeneratedDatabase {
+  _$MyDatabase(QueryExecutor e) : super(e);
+  _$MyDatabaseManager get managers => _$MyDatabaseManager(this);
+  late final $DeviceInfoTableTable deviceInfoTable =
+      $DeviceInfoTableTable(this);
+  late final DeviceInfoTableDao deviceInfoTableDao =
+      DeviceInfoTableDao(this as MyDatabase);
+  @override
+  Iterable<TableInfo<Table, Object?>> get allTables =>
+      allSchemaEntities.whereType<TableInfo<Table, Object?>>();
+  @override
+  List<DatabaseSchemaEntity> get allSchemaEntities => [deviceInfoTable];
+}
+
+typedef $$DeviceInfoTableTableInsertCompanionBuilder = DeviceInfoTableCompanion
+    Function({
+  required String username,
+  required String phoneBrand,
+  required String phoneModel,
+  required String phoneRelease,
+  required String phoneAddress,
+  required String bleMac,
+  required String bleName,
+  required int createdAt,
+  Value<int> rowid,
+});
+typedef $$DeviceInfoTableTableUpdateCompanionBuilder = DeviceInfoTableCompanion
+    Function({
+  Value<String> username,
+  Value<String> phoneBrand,
+  Value<String> phoneModel,
+  Value<String> phoneRelease,
+  Value<String> phoneAddress,
+  Value<String> bleMac,
+  Value<String> bleName,
+  Value<int> createdAt,
+  Value<int> rowid,
+});
+
+class $$DeviceInfoTableTableTableManager extends RootTableManager<
+    _$MyDatabase,
+    $DeviceInfoTableTable,
+    DeviceInfo,
+    $$DeviceInfoTableTableFilterComposer,
+    $$DeviceInfoTableTableOrderingComposer,
+    $$DeviceInfoTableTableProcessedTableManager,
+    $$DeviceInfoTableTableInsertCompanionBuilder,
+    $$DeviceInfoTableTableUpdateCompanionBuilder> {
+  $$DeviceInfoTableTableTableManager(
+      _$MyDatabase db, $DeviceInfoTableTable table)
+      : super(TableManagerState(
+          db: db,
+          table: table,
+          filteringComposer:
+              $$DeviceInfoTableTableFilterComposer(ComposerState(db, table)),
+          orderingComposer:
+              $$DeviceInfoTableTableOrderingComposer(ComposerState(db, table)),
+          getChildManagerBuilder: (p) =>
+              $$DeviceInfoTableTableProcessedTableManager(p),
+          getUpdateCompanionBuilder: ({
+            Value<String> username = const Value.absent(),
+            Value<String> phoneBrand = const Value.absent(),
+            Value<String> phoneModel = const Value.absent(),
+            Value<String> phoneRelease = const Value.absent(),
+            Value<String> phoneAddress = const Value.absent(),
+            Value<String> bleMac = const Value.absent(),
+            Value<String> bleName = const Value.absent(),
+            Value<int> createdAt = const Value.absent(),
+            Value<int> rowid = const Value.absent(),
+          }) =>
+              DeviceInfoTableCompanion(
+            username: username,
+            phoneBrand: phoneBrand,
+            phoneModel: phoneModel,
+            phoneRelease: phoneRelease,
+            phoneAddress: phoneAddress,
+            bleMac: bleMac,
+            bleName: bleName,
+            createdAt: createdAt,
+            rowid: rowid,
+          ),
+          getInsertCompanionBuilder: ({
+            required String username,
+            required String phoneBrand,
+            required String phoneModel,
+            required String phoneRelease,
+            required String phoneAddress,
+            required String bleMac,
+            required String bleName,
+            required int createdAt,
+            Value<int> rowid = const Value.absent(),
+          }) =>
+              DeviceInfoTableCompanion.insert(
+            username: username,
+            phoneBrand: phoneBrand,
+            phoneModel: phoneModel,
+            phoneRelease: phoneRelease,
+            phoneAddress: phoneAddress,
+            bleMac: bleMac,
+            bleName: bleName,
+            createdAt: createdAt,
+            rowid: rowid,
+          ),
+        ));
+}
+
+class $$DeviceInfoTableTableProcessedTableManager extends ProcessedTableManager<
+    _$MyDatabase,
+    $DeviceInfoTableTable,
+    DeviceInfo,
+    $$DeviceInfoTableTableFilterComposer,
+    $$DeviceInfoTableTableOrderingComposer,
+    $$DeviceInfoTableTableProcessedTableManager,
+    $$DeviceInfoTableTableInsertCompanionBuilder,
+    $$DeviceInfoTableTableUpdateCompanionBuilder> {
+  $$DeviceInfoTableTableProcessedTableManager(super.$state);
+}
+
+class $$DeviceInfoTableTableFilterComposer
+    extends FilterComposer<_$MyDatabase, $DeviceInfoTableTable> {
+  $$DeviceInfoTableTableFilterComposer(super.$state);
+  ColumnFilters<String> get username => $state.composableBuilder(
+      column: $state.table.username,
+      builder: (column, joinBuilders) =>
+          ColumnFilters(column, joinBuilders: joinBuilders));
+
+  ColumnFilters<String> get phoneBrand => $state.composableBuilder(
+      column: $state.table.phoneBrand,
+      builder: (column, joinBuilders) =>
+          ColumnFilters(column, joinBuilders: joinBuilders));
+
+  ColumnFilters<String> get phoneModel => $state.composableBuilder(
+      column: $state.table.phoneModel,
+      builder: (column, joinBuilders) =>
+          ColumnFilters(column, joinBuilders: joinBuilders));
+
+  ColumnFilters<String> get phoneRelease => $state.composableBuilder(
+      column: $state.table.phoneRelease,
+      builder: (column, joinBuilders) =>
+          ColumnFilters(column, joinBuilders: joinBuilders));
+
+  ColumnFilters<String> get phoneAddress => $state.composableBuilder(
+      column: $state.table.phoneAddress,
+      builder: (column, joinBuilders) =>
+          ColumnFilters(column, joinBuilders: joinBuilders));
+
+  ColumnFilters<String> get bleMac => $state.composableBuilder(
+      column: $state.table.bleMac,
+      builder: (column, joinBuilders) =>
+          ColumnFilters(column, joinBuilders: joinBuilders));
+
+  ColumnFilters<String> get bleName => $state.composableBuilder(
+      column: $state.table.bleName,
+      builder: (column, joinBuilders) =>
+          ColumnFilters(column, joinBuilders: joinBuilders));
+
+  ColumnFilters<int> get createdAt => $state.composableBuilder(
+      column: $state.table.createdAt,
+      builder: (column, joinBuilders) =>
+          ColumnFilters(column, joinBuilders: joinBuilders));
+}
+
+class $$DeviceInfoTableTableOrderingComposer
+    extends OrderingComposer<_$MyDatabase, $DeviceInfoTableTable> {
+  $$DeviceInfoTableTableOrderingComposer(super.$state);
+  ColumnOrderings<String> get username => $state.composableBuilder(
+      column: $state.table.username,
+      builder: (column, joinBuilders) =>
+          ColumnOrderings(column, joinBuilders: joinBuilders));
+
+  ColumnOrderings<String> get phoneBrand => $state.composableBuilder(
+      column: $state.table.phoneBrand,
+      builder: (column, joinBuilders) =>
+          ColumnOrderings(column, joinBuilders: joinBuilders));
+
+  ColumnOrderings<String> get phoneModel => $state.composableBuilder(
+      column: $state.table.phoneModel,
+      builder: (column, joinBuilders) =>
+          ColumnOrderings(column, joinBuilders: joinBuilders));
+
+  ColumnOrderings<String> get phoneRelease => $state.composableBuilder(
+      column: $state.table.phoneRelease,
+      builder: (column, joinBuilders) =>
+          ColumnOrderings(column, joinBuilders: joinBuilders));
+
+  ColumnOrderings<String> get phoneAddress => $state.composableBuilder(
+      column: $state.table.phoneAddress,
+      builder: (column, joinBuilders) =>
+          ColumnOrderings(column, joinBuilders: joinBuilders));
+
+  ColumnOrderings<String> get bleMac => $state.composableBuilder(
+      column: $state.table.bleMac,
+      builder: (column, joinBuilders) =>
+          ColumnOrderings(column, joinBuilders: joinBuilders));
+
+  ColumnOrderings<String> get bleName => $state.composableBuilder(
+      column: $state.table.bleName,
+      builder: (column, joinBuilders) =>
+          ColumnOrderings(column, joinBuilders: joinBuilders));
+
+  ColumnOrderings<int> get createdAt => $state.composableBuilder(
+      column: $state.table.createdAt,
+      builder: (column, joinBuilders) =>
+          ColumnOrderings(column, joinBuilders: joinBuilders));
+}
+
+class _$MyDatabaseManager {
+  final _$MyDatabase _db;
+  _$MyDatabaseManager(this._db);
+  $$DeviceInfoTableTableTableManager get deviceInfoTable =>
+      $$DeviceInfoTableTableTableManager(_db, _db.deviceInfoTable);
+}

lib/drfit/device_info_table.dart

@@ -0,0 +1,26 @@
+import 'package:drift/drift.dart';
+
+
+@DataClassName('DeviceInfo')
+class DeviceInfoTable extends Table {
+
+  /// 登录用户名
+  TextColumn get username => text()();
+  /// 登录手机品牌，如Redmi
+  TextColumn get phoneBrand => text()();
+  /// 登录手机认证型号，如22120RN86C
+  TextColumn get phoneModel=> text()();
+  /// 登录手机版本，如14
+  TextColumn get phoneRelease => text()();
+  /// 登录手机所在地址，如"北京市西城区月坛北街18号靠近物资大院"
+  TextColumn get phoneAddress => text()();
+  /// 登录蓝牙mac地址
+  TextColumn get bleMac => text()();
+  /// 登录蓝牙名称
+  TextColumn get bleName => text()();
+  /// 日期
+  IntColumn get createdAt => integer()();
+
+  @override
+  Set<Column<Object>>? get primaryKey => {bleMac, username};
+}

lib/drfit/model_factory.dart

@@ -0,0 +1,28 @@
+
+
+import 'package:device_info_plus/device_info_plus.dart';
+import 'package:drift/drift.dart';
+import 'package:lszlgl/drfit/database.dart';
+import 'package:lszlgl/service/print_service.dart';
+
+import '../model/rsp/user_rsp.dart';
+import '../service/user_service.dart';
+
+class ModelFactory {
+  static Future<DeviceInfoTableCompanion> convertToTSlideComp(String bleMac, String bleName, String phoneAddress) async {
+    UserRsp? userRsp =  UserService.get().getUser();
+    AndroidDeviceInfo? androidDeviceInfo = await PrintService.getDeviceInfo();
+    var tsc = DeviceInfoTableCompanion(
+      username: Value.absentIfNull(userRsp?.username),
+      phoneBrand: Value.absentIfNull(androidDeviceInfo?.board),
+      phoneModel: Value.absentIfNull(androidDeviceInfo?.model),
+      phoneRelease: Value.absentIfNull(androidDeviceInfo?.version.release),
+      phoneAddress: Value(phoneAddress),
+      bleMac: Value(bleMac),
+      bleName: Value(bleName),
+      createdAt: Value(DateTime.now().millisecondsSinceEpoch)
+    );
+    return tsc;
+  }
+
+}

lib/main.dart

@@ -1,4 +1,7 @@
 import 'dart:async';
+import 'dart:io';
+import 'package:drift/drift.dart' as drift;
+import 'package:drift/native.dart';
 import 'package:flutter/foundation.dart';
 import 'package:flutter/material.dart';
 import 'package:flutter/services.dart';
@@ -6,19 +9,24 @@ import 'package:flutter_localizations/flutter_localizations.dart';
 import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
 import 'package:logger/logger.dart';
 import 'package:lszlgl/config/colors.dart';
+import 'package:lszlgl/drfit/database.dart';
 import 'package:lszlgl/router/my_navigator.dart';
 
 late Logger logger;
+late MyDatabase database;
 
 void main() async {
   logger = Logger(printer: PrettyPrinter(methodCount: 0));
+
   initReportException(() async {
     SystemChrome.setSystemUIOverlayStyle(SystemUiOverlayStyle.light.copyWith(statusBarColor: Colors.transparent));
     SystemChrome.setPreferredOrientations([
       DeviceOrientation.portraitUp,
       DeviceOrientation.portraitDown,
     ]);
+
     runApp(const MyApp());
+    database = MyDatabase();
   });
 }
 

lib/model/req/device_req.dart

@@ -0,0 +1,42 @@
+
+import 'package:json_annotation/json_annotation.dart';
+
+part 'device_req.g.dart';
+
+@JsonSerializable()
+class DeviceReq {
+
+  /// 登录用户名
+  final String username;
+
+  /// 登录手机品牌，如Redmi
+  final String phoneBrand;
+
+  /// 登录手机认证型号，如22120RN86C
+  final String phoneModel;
+
+  /// 登录手机版本，如14
+  final String phoneRelease;
+
+  /// 登录手机所在地址，如"北京市西城区月坛北街18号靠近物资大院"
+  final String phoneAddress;
+
+  /// 登录蓝牙mac地址
+  final String bleMac;
+
+  /// 登录蓝牙名称
+  final String bleName;
+  const DeviceReq(
+      {required this.username,
+        required this.phoneBrand,
+        required this.phoneModel,
+        required this.phoneRelease,
+        required this.phoneAddress,
+        required this.bleMac,
+        required this.bleName});
+
+
+  factory DeviceReq.fromJson(Map<String, dynamic> json) => _$DeviceReqFromJson(json);
+
+  Map<String, dynamic> toJson() => _$DeviceReqToJson(this);
+}

lib/model/req/device_req.g.dart

@@ -0,0 +1,27 @@
+// GENERATED CODE - DO NOT MODIFY BY HAND
+
+part of 'device_req.dart';
+
+// **************************************************************************
+// JsonSerializableGenerator
+// **************************************************************************
+
+DeviceReq _$DeviceReqFromJson(Map<String, dynamic> json) => DeviceReq(
+      username: json['username'] as String,
+      phoneBrand: json['phoneBrand'] as String,
+      phoneModel: json['phoneModel'] as String,
+      phoneRelease: json['phoneRelease'] as String,
+      phoneAddress: json['phoneAddress'] as String,
+      bleMac: json['bleMac'] as String,
+      bleName: json['bleName'] as String,
+    );
+
+Map<String, dynamic> _$DeviceReqToJson(DeviceReq instance) => <String, dynamic>{
+      'username': instance.username,
+      'phoneBrand': instance.phoneBrand,
+      'phoneModel': instance.phoneModel,
+      'phoneRelease': instance.phoneRelease,
+      'phoneAddress': instance.phoneAddress,
+      'bleMac': instance.bleMac,
+      'bleName': instance.bleName,
+    };

lib/model/req/login_req.g.dart

@@ -9,7 +9,7 @@ part of 'login_req.dart';
 LoginReq _$LoginReqFromJson(Map<String, dynamic> json) => LoginReq(
       username: json['username'] as String?,
       password: json['password'] as String?,
-      platform: json['platform'] as int? ?? 1,
+      platform: (json['platform'] as num?)?.toInt() ?? 1,
     );
 
 Map<String, dynamic> _$LoginReqToJson(LoginReq instance) => <String, dynamic>{

lib/model/req/sample_task_list_req.g.dart

@@ -8,13 +8,13 @@ part of 'sample_task_list_req.dart';
 
 SampleTaskListReq _$SampleTaskListReqFromJson(Map<String, dynamic> json) =>
     SampleTaskListReq(
-      pageNo: json['pageNo'] as int? ?? 1,
-      pageSize: json['pageSize'] as int? ?? 10,
-      deliveryStatus: json['deliveryStatus'] as int?,
-      rwlx: json['rwlx'] as int?,
+      pageNo: (json['pageNo'] as num?)?.toInt() ?? 1,
+      pageSize: (json['pageSize'] as num?)?.toInt() ?? 10,
+      deliveryStatus: (json['deliveryStatus'] as num?)?.toInt(),
+      rwlx: (json['rwlx'] as num?)?.toInt(),
       cypzName: json['cypzName'] as String?,
       jyzb: json['jyzb'] as String?,
-      ypdj: json['ypdj'] as int?,
+      ypdj: (json['ypdj'] as num?)?.toInt(),
       qydq: json['qydq'] as String?,
     );
 

lib/network/api.dart

@@ -10,6 +10,8 @@ import 'package:lszlgl/model/rsp/user_rsp.dart';
 import 'package:lszlgl/network/base_dio.dart';
 import 'package:retrofit/retrofit.dart';
 
+import '../drfit/database.dart';
+import '../model/req/device_req.dart';
 import '../model/rsp/district_rsp.dart';
 
 part 'api.g.dart';
@@ -83,4 +85,9 @@ abstract class Api {
   /// 上传图片
   @POST('/admin-api/infra/file/upload')
   Future<ApiRsp<String?>> upload(@Part(name: 'file') File file);
+
+  /// 提交设备绑定信息
+  @POST('/admin-api/zj/base-device/createBatch')
+  Future<ApiRsp> postDeviceInfos(@Body() List<DeviceReq> req);
+
 }

lib/network/api.g.dart

@@ -513,6 +513,36 @@ class _Api implements Api {
     return value;
   }
 
+  @override
+  Future<ApiRsp<dynamic>> postDeviceInfos(List<DeviceReq> req) async {
+    const _extra = <String, dynamic>{};
+    final queryParameters = <String, dynamic>{};
+    final _headers = <String, dynamic>{};
+    final _data = req.map((e) => e.toJson()).toList();
+    final _result = await _dio
+        .fetch<Map<String, dynamic>>(_setStreamType<ApiRsp<dynamic>>(Options(
+      method: 'POST',
+      headers: _headers,
+      extra: _extra,
+    )
+            .compose(
+              _dio.options,
+              '/admin-api/zj/base-device/createBatch',
+              queryParameters: queryParameters,
+              data: _data,
+            )
+            .copyWith(
+                baseUrl: _combineBaseUrls(
+              _dio.options.baseUrl,
+              baseUrl,
+            ))));
+    final value = ApiRsp<dynamic>.fromJson(
+      _result.data!,
+      (json) => json as dynamic,
+    );
+    return value;
+  }
+
   RequestOptions _setStreamType<T>(RequestOptions requestOptions) {
     if (T != dynamic &&
         !(requestOptions.responseType == ResponseType.bytes ||

lib/network/my_api.dart

@@ -10,6 +10,7 @@ class MyApi {
   static String testUrl = 'http://121.36.17.6:19090';
 
   static Api get({Dio? dio, String? baseUrl}) {
+
     if (kReleaseMode) {
       baseUrl ??= productUrl;
     } else {

lib/page/home/home_page.dart

@@ -4,6 +4,8 @@ import 'package:flutter/material.dart';
 import 'package:lszlgl/base/base_state.dart';
 import 'package:lszlgl/page/sample_task/sample_task_list_tab_page.dart';
 
+import '../print/print_page.dart';
+
 /// 首页
 class HomePage extends StatefulWidget {
   const HomePage({Key? key}) : super(key: key);

lib/page/login/login_page.dart

@@ -12,9 +12,13 @@ import 'package:lszlgl/service/user_service.dart';
 import 'package:lszlgl/widget/button.dart';
 
 import '../../config/reresh_config.dart';
+import '../../drfit/database.dart';
 import '../../network/base_dio.dart';
 import '../../utils/location_utils.dart';
 import '../../utils/sp_utils.dart';
+import 'package:lszlgl/service/print_service.dart';
+import 'package:path_provider/path_provider.dart';
+import 'package:path/path.dart' as p;
 
 /// 登录页面
 class LoginPage extends StatefulWidget {
@@ -83,7 +87,7 @@ class _LoginPageState extends BaseLifecycleState<LoginPage> {
 
   @override
   void onFirstShow(Duration timeStamp) async {
-    MyNavigator.showLoading();
+    // MyNavigator.showLoading();
 
     /// 初始化基础库 start
     BaseDio.get().init();
@@ -92,6 +96,10 @@ class _LoginPageState extends BaseLifecycleState<LoginPage> {
     LocationUtils.updatePrivacyShow(true, true);
     LocationUtils.updatePrivacyAgree(true);
     LocationUtils.setApiKey(kReleaseMode ? '2c783509376e267b24d63b21681686fa' : '7d0c033909f84adc14a0e60a835f044f', '');
+    /// 获取手机设备信息
+    PrintService.getDeviceInfo();
+    /// 同步数据库里的蓝牙设备信息到服务器
+    database.savaBleDataToServer();
 
     /// 初始化基础库 end
     MyNavigator.dismissLoading();

lib/page/print/connect_print_page.dart

@@ -0,0 +1,95 @@
+import 'package:flutter/material.dart';
+import 'package:flutter/services.dart';
+import 'package:lszlgl/base/base_lifecycle_state.dart';
+import 'package:lszlgl/drfit/model_factory.dart';
+import 'package:lszlgl/main.dart';
+import 'package:lszlgl/service/print_service.dart';
+import 'package:lszlgl/widget/loading_widget.dart';
+import 'package:lszlgl/widget/page_widget.dart';
+import 'package:signature/signature.dart';
+import 'package:lszlgl/widget/button.dart';
+
+import '../../drfit/database.dart';
+import '../../plugin/bluetooth_plugin.dart';
+import '../home/home_page.dart';
+
+class ConnectPrintPageArgs {
+  int count;
+
+  ConnectPrintPageArgs({this.count = 1});
+
+  @override
+  String toString() {
+    return {'count': count}.toString();
+  }
+}
+
+/// 电子签名
+class ConnectPrintPage extends StatefulWidget {
+  final ConnectPrintPageArgs args;
+
+  const ConnectPrintPage({
+    super.key,
+    required this.args,
+  });
+
+  @override
+  State<ConnectPrintPage> createState() => _ConnectPrintPageState();
+}
+
+class _ConnectPrintPageState extends BaseLifecycleState<ConnectPrintPage> {
+
+
+  
+
+  @override
+  Widget build(BuildContext context) {
+    return myScaffold(
+      child: Column(
+        children: [
+          myAppBar(title: '连接打印机'),
+          const SizedBox(height: 18),
+          // ...List.generate(
+          //   serviceList.length,
+          //       (index) => buildServiceItem(serviceList[index]),
+          // ).toList(),
+          
+        ],
+      ),
+    );
+  }
+
+  // Widget buildServiceItem(ServiceModel service) {
+  //   return GestureDetector(
+  //     onTap: service.onTap,
+  //     child: Container(
+  //       margin: const EdgeInsets.only(left: 12, right: 12, bottom: 22),
+  //       padding: const EdgeInsets.symmetric(vertical: 20, horizontal: 40),
+  //       clipBehavior: Clip.hardEdge,
+  //       decoration: BoxDecoration(
+  //         borderRadius: const BorderRadius.all(Radius.circular(12)),
+  //         boxShadow: [BoxShadow(color: Colors.black.withOpacity(0.1), offset: const Offset(0, 5), blurRadius: 4)],
+  //         image: const DecorationImage(image: AssetImage(imgHomeListBg), fit: BoxFit.fill),
+  //       ),
+  //       child: Row(
+  //         children: [
+  //           Image.asset(service.icon, height: 64),
+  //           const SizedBox(width: 12),
+  //           Expanded(
+  //             child: Column(
+  //               mainAxisSize: MainAxisSize.min,
+  //               children: [
+  //                 Text(
+  //                   "${service.name}${scanDeviceState == DeviceState.scanStart ? "中..." : ""}",
+  //                   textAlign: TextAlign.center,
+  //                   style: const TextStyle(color: Color(0xFF333333), fontSize: 20, fontWeight: FontWeight.w500),
+  //                 ),
+  //               ],
+  //             ),
+  //           ),
+  //         ],
+  //       ),
+  //     ),
+  //   );
+  // }
+}

lib/page/print/print_page.dart

@@ -0,0 +1,322 @@
+import 'dart:async';
+import 'dart:convert';
+
+import 'package:amap_flutter_location/amap_location_option.dart';
+import 'package:flutter/material.dart';
+import 'package:flutter/services.dart';
+import 'package:lszlgl/base/base_lifecycle_state.dart';
+import 'package:lszlgl/page/print/connect_print_page.dart';
+import 'package:signature/signature.dart';
+import 'package:lszlgl/widget/button.dart';
+
+import '../../drfit/database.dart';
+import '../../drfit/model_factory.dart';
+import '../../main.dart';
+import '../../plugin/bluetooth_plugin.dart';
+import '../../service/print_service.dart';
+import '../../utils/location_utils.dart';
+import '../home/home_page.dart';
+import 'dart:ui' as ui;
+
+class PrintPageArgs {
+  /// 二维码数据
+  Uint8List? bytes;
+
+  PrintPageArgs({this.bytes});
+
+  @override
+  String toString() {
+    return {'bytes': bytes}.toString();
+  }
+}
+
+/// 电子签名
+class PrintPage extends StatefulWidget {
+  final PrintPageArgs args;
+
+  const PrintPage({
+    super.key,
+    required this.args,
+  });
+
+  @override
+  State<PrintPage> createState() => _PrintPageState();
+}
+
+class _PrintPageState extends BaseLifecycleState<PrintPage> {
+
+  late List<ServiceModel> serviceList;
+
+  late List<BlueDeviceInfo> deviceList;
+  late List<String> deviceMacList;
+
+  String scanDeviceState = '';
+
+  StreamSubscription? locationListener;
+  StreamSubscription? onReceiveDataStreamListener;
+  StreamSubscription? onDeviceStateStreamListener;
+  String phoneAddress = '';
+
+
+  @override
+  void initState() {
+    super.initState();
+    serviceList = [
+      ServiceModel(name: '搜索', icon: imgBleSearch, onTap: () => startScan()),
+      ServiceModel(name: '打印', icon: imgBlePrint, onTap: () => startPrint()),
+    ];
+    deviceList = [];
+    deviceMacList = [];
+
+    PrintService.hasBluetoothConnectDevice().then((result) {
+      if(result == false) {
+        PrintService.connectedDeviceList = [];
+        PrintService.connectedDeviceMacList = [];
+      }
+    });
+
+    getLocation();
+  }
+
+  /// 去打印
+  Future<void> startPrint() async {
+
+    int targetWidth = 560;
+    if(PrintService.connectedDeviceList.last.deviceName.contains("BTP-UP321")) {
+      targetWidth = 500;
+    }
+
+    final codec = await ui.instantiateImageCodec(
+      widget.args.bytes!,
+      targetHeight: 590,  // 640
+      targetWidth: targetWidth, // 560
+    );
+
+    final smallImage = (await codec.getNextFrame()).image;
+    ByteData? smallBytes = await smallImage.toByteData(format: ui.ImageByteFormat.png);
+    Uint8List? smallUint8List = smallBytes?.buffer.asUint8List();
+
+
+    MyNavigator.showLoading(msg: '打印中...');
+    await PrintService.startBluetoothPrintBitMap(smallUint8List!);
+    MyNavigator.dismiss();
+    MyNavigator.showToast('打印成功');
+  }
+
+  /// 去搜索
+  Future<void> startScan() async {
+
+    setState(() {
+      deviceList = [];
+      deviceMacList = [];
+    });
+    await PrintService.startBluetoothDiscovery();
+  }
+
+  Future<int> savaToSqlite(BlueDeviceInfo deviceInfo) async {
+    DeviceInfoTableCompanion tableCompanion = await ModelFactory.convertToTSlideComp(deviceInfo.deviceMac, deviceInfo.deviceName, phoneAddress);
+    return await database.deviceInfoTableDao.addOneDeviceComp(tableCompanion);
+  }
+
+  /// 去连接
+  Future<void> startConnect(BlueDeviceInfo deviceInfo) async {
+    if(deviceInfo.connectStateStr.contains('未配对')) {
+      MyNavigator.showLoading(msg: '配对中...');
+      await PrintService.startBluetoothPair(deviceInfo);
+    } else if(deviceInfo.connectStateStr.contains('已配对')) {
+      MyNavigator.showLoading(msg: '连接中...');
+      int connectResult =  await PrintService.startBluetoothConnect(deviceInfo);
+      if(connectResult == 0) { // 连接成功
+        MyNavigator.dismiss();
+        MyNavigator.showToast('连接成功');
+        deviceInfo.connectSuccess();
+        //addOneSlideComp
+
+        if(deviceMacList.contains(deviceInfo.deviceMac)) {
+          setState(() {
+            deviceMacList.removeWhere((element) => element == deviceInfo.deviceMac);
+            deviceList.removeWhere((element) => element.deviceMac == deviceInfo.deviceMac);
+          });
+        }
+        setState(() {
+          PrintService.connectedDeviceMacList.add(deviceInfo.deviceMac);
+          PrintService.connectedDeviceList.add(deviceInfo);
+        });
+        await savaToSqlite(deviceInfo); // 保存记录到数据库
+        database.savaBleDataToServer(); // 同步记录到服务器
+      } else {
+        MyNavigator.dismiss();
+        MyNavigator.showToast('连接失败');
+      }
+    } else if(deviceInfo.connectStateStr.contains('断开')) {
+      int connectResult =  await PrintService.endBluetoothConnect(deviceInfo);
+      if(connectResult == 0) {  // 断开成功
+        deviceInfo.disConnectSuccess();
+        if(PrintService.connectedDeviceMacList.contains(deviceInfo.deviceMac)) {
+          setState(() {
+            PrintService.connectedDeviceMacList.removeWhere((element) => element == deviceInfo.deviceMac);
+            PrintService.connectedDeviceList.removeWhere((element) => element.deviceMac == deviceInfo.deviceMac);
+          });
+        }
+        setState(() {
+          deviceMacList.add(deviceInfo.deviceMac);
+          deviceList.add(deviceInfo);
+        });
+      }
+    }
+  }
+
+  void getLocation() async {
+    bool granted = await LocationUtils.requestLocationPermission();
+    if (!granted) {
+      MyNavigator.showToast('请打开APP的定位权限');
+      return;
+    }
+    LocationUtils.setLocationOption(AMapLocationOption(onceLocation: true));
+    LocationUtils.startLocation();
+  }
+
+  void initLocation() {
+    locationListener = LocationUtils.onLocationChanged().listen((value) async {
+
+      phoneAddress = value['address'] as String;
+    });
+  }
+
+  @override
+  void onInit() {
+
+    onReceiveDataStreamListener = BluetoothPlugin.instance.onReceiveDataStream.listen((deviceInfo) {
+      if(deviceInfo != null) {
+        if(deviceMacList.contains(deviceInfo.deviceMac)) {
+          setState(() {
+            deviceMacList.removeWhere((element) => element == deviceInfo.deviceMac);
+            deviceList.removeWhere((element) => element.deviceMac == deviceInfo.deviceMac);
+          });
+        }
+        setState(() {
+          // 只显示支持的打印机
+          if(deviceInfo.deviceName.contains('BTP') || deviceInfo.deviceName.contains('B3S') || deviceInfo.deviceName.contains('A8')) {
+            deviceMacList.add(deviceInfo.deviceMac);
+            deviceList.add(deviceInfo);
+          }
+        });
+      }
+    });
+
+    onDeviceStateStreamListener = BluetoothPlugin.instance.onDeviceStateStream.listen((deviceState) {
+      if(deviceState == DeviceState.pairEnd) {
+        MyNavigator.dismiss();
+      }
+      setState(() {
+        scanDeviceState = deviceState ?? "";
+      });
+    });
+
+    initLocation();
+  }
+
+  @override
+  void onDestroy() {
+    LocationUtils.stopLocation();
+    LocationUtils.destroy();
+    locationListener?.cancel();
+    onDeviceStateStreamListener?.cancel();
+    onReceiveDataStreamListener?.cancel();
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return myScaffold(
+      child: Column(
+        children: [
+          myAppBar(title: '打印二维码'),
+          const SizedBox(height: 18),
+          buildServiceItem(serviceList[0]),
+          const Text('已连接打印机'),
+          ...List.generate(
+            PrintService.connectedDeviceList.length,
+                (index) => buildDeviceItem(PrintService.connectedDeviceList[index]),
+          ).toList(),
+          const Text('可用打印机'),
+          ...List.generate(
+            deviceList.length,
+                (index) => buildDeviceItem(deviceList[index]),
+          ).toList(),
+          Offstage(
+            offstage: PrintService.connectedDeviceList.isEmpty,
+            child: buildServiceItem(serviceList[1]),
+          )
+        ],
+      ),
+    );
+  }
+
+  Widget buildServiceItem(ServiceModel service) {
+    return GestureDetector(
+      onTap: service.onTap,
+      child: Container(
+        margin: const EdgeInsets.only(left: 12, right: 12, bottom: 22),
+        padding: const EdgeInsets.symmetric(vertical: 20, horizontal: 40),
+        clipBehavior: Clip.hardEdge,
+        decoration: BoxDecoration(
+          borderRadius: const BorderRadius.all(Radius.circular(12)),
+          boxShadow: [BoxShadow(color: Colors.black.withOpacity(0.1), offset: const Offset(0, 5), blurRadius: 4)],
+          image: const DecorationImage(image: AssetImage(imgHomeListBg), fit: BoxFit.fill),
+        ),
+        child: Row(
+          children: [
+            Image.asset(service.icon, height: 64),
+            const SizedBox(width: 12),
+            Expanded(
+              child: Column(
+                mainAxisSize: MainAxisSize.min,
+                children: [
+                  Text(
+                    "${service.name}${(service.name.contains('搜索')&&scanDeviceState == DeviceState.scanStart) ? "中..." : ""}",
+                    textAlign: TextAlign.center,
+                    style: const TextStyle(color: Color(0xFF333333), fontSize: 20, fontWeight: FontWeight.w500),
+                  ),
+                ],
+              ),
+            ),
+          ],
+        ),
+      ),
+    );
+  }
+
+  Widget buildDeviceItem(BlueDeviceInfo deviceInfo) {
+    return GestureDetector(
+      onTap: () {
+        // 连接
+        startConnect(deviceInfo);
+      },
+      child: Container(
+        margin: const EdgeInsets.only(left: 12, right: 12, bottom: 22),
+        padding: const EdgeInsets.symmetric(vertical: 10),
+        clipBehavior: Clip.hardEdge,
+        decoration: BoxDecoration(
+          borderRadius: const BorderRadius.all(Radius.circular(12)),
+          boxShadow: [BoxShadow(color: Colors.black.withOpacity(0.1), offset: const Offset(0, 5), blurRadius: 4)],
+          image: const DecorationImage(image: AssetImage(imgHomeListBg), fit: BoxFit.fill),
+        ),
+        child: Row(
+          mainAxisAlignment: MainAxisAlignment.spaceAround,
+          children: [
+            Text(
+              deviceInfo.deviceName,
+              textAlign: TextAlign.center,
+              style: const TextStyle(color: Color(0xFF333333), fontSize: 15, fontWeight: FontWeight.w500),
+            ),
+            Text(
+              deviceInfo.connectStateStr,
+              textAlign: TextAlign.center,
+              style: const TextStyle(color: Color(0xFF333333), fontSize: 15, fontWeight: FontWeight.w500),
+            ),
+          ],
+        ),
+      ),
+    );
+  }
+}

lib/page/sample_task/reap_sample_detail/reap_sample_task_page.dart

@@ -8,6 +8,7 @@ import 'package:image_gallery_saver/image_gallery_saver.dart';
 import 'package:lszlgl/base/base_lifecycle_state.dart';
 import 'package:lszlgl/config/colors.dart';
 import 'package:lszlgl/model/rsp/sample_task_rsp.dart';
+import 'package:lszlgl/page/print/print_page.dart';
 import 'package:lszlgl/page/sample_task/reap_sample_detail/reap_sample_basic_detail_page.dart';
 import 'package:lszlgl/page/sample_task/reap_sample_detail/reap_sample_disaster_detail_page.dart';
 import 'package:lszlgl/page/sample_task/reap_sample_detail/reap_sample_medicine_detail_page.dart';
@@ -18,9 +19,11 @@ import 'package:lszlgl/page/signature/signature_page.dart';
 import '../../../base/base_vm.dart';
 import '../../../main.dart';
 import '../../../network/my_api.dart';
+import '../../../plugin/bluetooth_plugin.dart';
 import '../../../utils/file_utils.dart';
 import '../../../widget/button.dart';
 import '../../../widget/page_widget.dart';
+import 'dart:ui' as ui;
 
 class ReapSampleTaskPageArgs {
   final bool detail;
@@ -189,7 +192,7 @@ class _ReapSampleTaskPageState extends BaseLifecycleState<ReapSampleTaskPage> wi
             ),
             Row(
               children: [
-                const Expanded(child: MyButton('打印')),
+                Expanded(child: MyButton('打印', onTap: () => printPic(picInfo.name))),
                 const SizedBox(width: 16),
                 Expanded(child: MyButton('保存图片', onTap: () => savePic(picInfo.name))),
               ],
@@ -200,6 +203,14 @@ class _ReapSampleTaskPageState extends BaseLifecycleState<ReapSampleTaskPage> wi
     );
   }
 
+  Future<void> printPic(String? name) async {
+
+    Uint8List? bytes = await FileUtils.getBitmapFromContext(ewmKey.currentContext);
+
+    var args = PrintPageArgs(bytes: bytes);
+    await MyRouter.startPrint(args: args);
+  }
+
   void savePic(String? name) async {
     MyNavigator.showLoading(msg: '保存中...');
     Uint8List? bytes = await FileUtils.getBitmapFromContext(ewmKey.currentContext);

lib/plugin/bluetooth_plugin.dart

@@ -0,0 +1,183 @@
+import 'dart:io';
+
+import 'package:flutter/services.dart';
+import 'package:logger/logger.dart';
+
+import '../main.dart';
+import '../router/my_navigator.dart';
+
+class BluetoothPlugin {
+  factory BluetoothPlugin() => _instance;
+  BluetoothPlugin._();
+  static final BluetoothPlugin _instance = BluetoothPlugin._();
+  static BluetoothPlugin get instance => _instance;
+
+   final String delimiterStr = "_NIMBOT_";
+  final MethodChannel _channel = const MethodChannel("io.flutter.plugins/bluetooth/methods");
+  final EventChannel _onReceiveDataStream = const EventChannel('io.flutter.plugins/bluetooth/onDiscoveryDevice');
+  final EventChannel _onDeviceStateStream = const EventChannel('io.flutter.plugins/bluetooth/onDeviceState');
+
+
+  //是否打开蓝牙
+  Future<bool> isBleOpen() async {
+    if (Platform.isIOS) {
+      return true;
+    }
+    return _channel.invokeMethod('isBleOpen').then<bool>((d) => d);
+  }
+
+  //安卓版本是否大于等于31
+  Future<bool> isSDKIntGreaterOrEqual31() async {
+    if (Platform.isIOS) {
+      return true;
+    }
+    return _channel.invokeMethod('isSDKIntGreaterOrEqual').then<bool>((d) => d);
+  }
+
+  //开始扫描
+  Future<int> startBluetoothDiscovery() async {
+    if (Platform.isIOS) {
+      return 0;
+    }
+    return _channel.invokeMethod('startBluetoothDiscovery').then<int>((d) => d);
+  }
+
+  //开始配对
+  Future<int> startBluetoothPair(BlueDeviceInfo deviceInfo) async {
+    if (Platform.isIOS) {
+      return 0;
+    }
+    String deviceInfoStr = deviceInfo.deviceName+delimiterStr+deviceInfo.deviceMac+delimiterStr+deviceInfo.connectState;
+    return _channel.invokeMethod('startBluetoothPair', deviceInfoStr).then<int>((d) => d);
+  }
+
+  //开始连接
+  Future<int> startBluetoothConnect(BlueDeviceInfo deviceInfo) async {
+
+    if (Platform.isIOS) {
+      return 0;
+    }
+    String deviceInfoStr = deviceInfo.deviceName+delimiterStr+deviceInfo.deviceMac+delimiterStr+deviceInfo.connectState;
+    return _channel.invokeMethod('startBluetoothConnect', deviceInfoStr).then<int>((d) => d);
+  }
+
+  //断开连接
+  Future<int> endBluetoothConnect(BlueDeviceInfo deviceInfo) async {
+
+    if (Platform.isIOS) {
+      return 0;
+    }
+    String deviceInfoStr = deviceInfo.deviceName+delimiterStr+deviceInfo.deviceMac+delimiterStr+deviceInfo.connectState;
+    return _channel.invokeMethod('endBluetoothConnect', deviceInfoStr).then<int>((d) => d);
+  }
+
+  //断开连接
+  Future<bool> hasBluetoothConnectDevice() async {
+
+    if (Platform.isIOS) {
+      return false;
+    }
+    return _channel.invokeMethod('hasBluetoothConnectDevice').then<bool>((d) => d);
+  }
+
+
+  //开始打印
+  Future<bool> startBluetoothPrintBitMap(Uint8List bytes) async {
+
+    if (Platform.isIOS) {
+      return false;
+    }
+    return _channel.invokeMethod('startBluetoothPrintBitMap', bytes).then<bool>((d) => d);
+  }
+
+  //开始打印
+  Future<bool> startBluetoothPrintBarCodeWithText(String barCode, String text) async {
+
+    if (Platform.isIOS) {
+      return false;
+    }
+    return _channel.invokeMethod('startBluetoothPrintBarCodeWithText', {"barCode": barCode, "text": text}).then<bool>((d) => d);
+  }
+
+
+
+  /// 接收数据监听
+  Stream<BlueDeviceInfo?> get onReceiveDataStream async* {
+
+    yield* _onReceiveDataStream
+        .receiveBroadcastStream()
+        .map((buffer) {
+
+      String str = buffer;
+      List<String> strList = str.split(delimiterStr);
+
+      if(strList.length == 3) {
+        BlueDeviceInfo deviceInfo = BlueDeviceInfo(deviceName: strList[0], deviceMac: strList[1], connectState: strList[2]);
+        return deviceInfo;
+      }
+      return null;
+    });
+  }
+
+  /// 接收数据监听
+  Stream<String?> get onDeviceStateStream async* {
+
+    yield* _onDeviceStateStream
+        .receiveBroadcastStream()
+        .map((buffer) {
+
+      return buffer.toString();
+    });
+  }
+}
+
+
+class DeviceState {
+
+  static String scanStart = "scanStart";
+
+  static String scanEnd = "scanEnd";
+
+  static String pairEnd = "pairEnd";
+}
+
+class BlueDeviceInfo {
+
+  String deviceName;
+  String deviceMac;
+  String connectState;
+
+  String? _connectStateStr;
+
+  BlueDeviceInfo({required this.deviceName, required this.deviceMac, required this.connectState});
+
+  String get connectStateStr {
+
+    if(connectState == '10') {
+      _connectStateStr = "未配对(点击进行配对)";
+    }
+    if(connectState == '11') {
+      _connectStateStr = "配对中";
+    }
+    if(connectState == '12') {
+      _connectStateStr = "已配对(点击进行连接)";
+    }
+    if(connectState == '13') {
+      _connectStateStr = "断开(点击断开连接）";
+    }
+    return _connectStateStr ?? "未知";
+  }
+
+  void connectSuccess() {
+    connectState = '13';
+  }
+
+  void disConnectSuccess() {
+    connectState = '12';
+  }
+
+  @override
+  String toString() {
+    return {'deviceName:': deviceName, "mac:": deviceMac, "state:": connectState}.toString();
+  }
+}

lib/router/my_router.dart

@@ -1,6 +1,8 @@
 import 'package:lszlgl/base/base_lifecycle_state.dart';
 import 'package:lszlgl/page/login/login_page.dart';
 import 'package:lszlgl/page/main_tab_page.dart';
+import 'package:lszlgl/page/print/connect_print_page.dart';
+import 'package:lszlgl/page/print/print_page.dart';
 import 'package:lszlgl/page/sample_task/reap_sample_detail/reap_sample_task_page.dart';
 import 'package:lszlgl/page/sample_task/sample_task_list_tab_page.dart';
 import 'package:lszlgl/page/user_center/account_manage_page.dart';
@@ -30,6 +32,10 @@ const rReapSampleTaskPage = '/ReapSampleTaskPage';
 const rStockSampleTaskPage = '/StockSampleTaskPage';
 // 电子签名
 const rSignaturePage = '/SignaturePage';
+// 打印
+const rPrintPage = '/PrintPage';
+// 连接
+const rConnectPrintPage = '/ConnectPrintPage';
 // 扫一扫
 const rQrCodeScanPage = '/QrCodeScanPage';
 
@@ -44,6 +50,8 @@ final Map<String, MyNavigatorBuilder> rRouteMap = {
   rReapSampleTaskPage: (context, args) => ReapSampleTaskPage(args: args as ReapSampleTaskPageArgs),
   rStockSampleTaskPage: (context, args) => StockSampleTaskPage(args: args as StockSampleTaskPageArgs),
   rSignaturePage: (context, args) => SignaturePage(args: args as SignaturePageArgs),
+  rPrintPage: (context, args) => PrintPage(args: args as PrintPageArgs),
+  rConnectPrintPage: (context, args) => ConnectPrintPage(args: args as ConnectPrintPageArgs),
   rQrCodeScanPage: (context, args) => const QrCodeScanPage(),
 };
 
@@ -108,6 +116,17 @@ class MyRouter {
     return MyNavigator.push(rSignaturePage, args: args ?? SignaturePageArgs());
   }
 
+  /// 打印任务
+  static Future<dynamic> startPrint({PrintPageArgs? args}) {
+    return MyNavigator.push(rPrintPage, args: args ?? PrintPageArgs());
+  }
+
+  /// 打印任务
+  static Future<dynamic> startConnectPrint({ConnectPrintPageArgs? args}) {
+    return MyNavigator.push(
+        rConnectPrintPage, args: args ?? ConnectPrintPageArgs());
+  }
+  
   /// 扫一扫
   static Future<dynamic> startQrCodeScan() {
     return MyNavigator.push(rQrCodeScanPage);

lib/service/print_service.dart

@@ -0,0 +1,166 @@
+
+
+import 'dart:ffi';
+import 'dart:io';
+import 'package:device_info_plus/device_info_plus.dart';
+import 'package:lszlgl/utils/permission_utils.dart';
+import 'package:permission_handler/permission_handler.dart';
+
+import '../plugin/bluetooth_plugin.dart';
+import '../router/my_navigator.dart';
+import 'package:flutter/material.dart';
+import 'package:flutter/services.dart';
+
+class PrintService {
+  PrintService._();
+
+  static final DeviceInfoPlugin deviceInfoPlugin = DeviceInfoPlugin();
+
+  static List<BlueDeviceInfo> connectedDeviceList = [];
+  static List<String> connectedDeviceMacList = [];
+
+  static AndroidDeviceInfo? deviceInfo;
+
+  static Future<AndroidDeviceInfo?> getDeviceInfo() async {
+    if (Platform.isIOS) {
+
+    } else if(Platform.isAndroid) {
+      if(deviceInfo != null) {
+        deviceInfo;
+      }
+      AndroidDeviceInfo androidInfo = await deviceInfoPlugin.androidInfo;
+      deviceInfo = androidInfo;
+      return deviceInfo;
+    }
+  }
+
+  //是否打开蓝牙
+  static Future<bool> isBleOpen() async {
+    return await BluetoothPlugin.instance.isBleOpen();
+  }
+
+  //安卓版本是否大于等于31
+  static Future<bool> isSDKIntGreaterOrEqual() async {
+    return await BluetoothPlugin.instance.isSDKIntGreaterOrEqual31();
+  }
+
+  //是否支持蓝牙操作
+  static Future<bool> canExecAction() async {
+    if (await isBleOpen()) {
+
+      bool allGranted = false;
+      String permissionName = '';
+      // permissionRequest
+     if(await isSDKIntGreaterOrEqual()) {
+
+       if (await PermissionHandler.handleWith(Permission.bluetoothScan)) {
+         allGranted = true;
+       } else {
+         permissionName = Permission.bluetoothScan.toString();
+         allGranted = false;
+       }
+       if(await PermissionHandler.handleWith(Permission.bluetoothConnect)) {
+         allGranted = true;
+       } else {
+         permissionName = '$permissionName ${Permission.bluetoothConnect}';
+         allGranted = false;
+       }
+     }
+      //所有权限申请通过
+      if (await PermissionHandler.handleWith(Permission.location)) {
+        allGranted = true;
+      } else {
+        permissionName = Permission.location.toString();
+        allGranted = false;
+      }
+     if(allGranted) {
+       return true;
+     } else {
+       MyNavigator.showToast('权限打开失败:$permissionName');
+       return false;
+     }
+    } else {
+      // 蓝牙未开启
+      MyNavigator.showToast('蓝牙未开启');
+      return false;
+    }
+  }
+
+  //开始扫描
+  static Future<int> startBluetoothDiscovery() async {
+
+    if(await canExecAction()) {
+      return await BluetoothPlugin.instance.startBluetoothDiscovery();
+    } else {
+      return 0;
+    }
+  }
+
+  //开始配对
+  static Future<int> startBluetoothPair(BlueDeviceInfo deviceInfo) async {
+
+    if(await canExecAction()) {
+      return await BluetoothPlugin.instance.startBluetoothPair(deviceInfo);
+    } else {
+      return 0;
+    }
+  }
+
+  //开始连接
+  static Future<int> startBluetoothConnect(BlueDeviceInfo deviceInfo) async {
+
+    if(await canExecAction()) {
+      return await BluetoothPlugin.instance.startBluetoothConnect(deviceInfo);
+    } else {
+      return 0;
+    }
+  }
+
+  //断开连接
+  static Future<int> endBluetoothConnect(BlueDeviceInfo deviceInfo) async {
+
+    if(await canExecAction()) {
+      return await BluetoothPlugin.instance.endBluetoothConnect(deviceInfo);
+    } else {
+      return 0;
+    }
+  }
+
+  //是否有连接中的设备
+  static Future<bool> hasBluetoothConnectDevice() async {
+
+    if(await canExecAction()) {
+      return await BluetoothPlugin.instance.hasBluetoothConnectDevice();
+    } else {
+      return false;
+    }
+  }
+
+  //开始打印图片
+  static Future<bool> startBluetoothPrintBitMap(Uint8List bytes) async {
+
+    if(await canExecAction()) {
+       return await BluetoothPlugin.instance.startBluetoothPrintBitMap(bytes);
+    } else {
+      return false;
+    }
+  }
+
+  //开始打印二维码和文本
+  static Future<bool> startBluetoothPrintBarCodeWithText(String barCode, String text) async {
+
+    if(await canExecAction()) {
+      return await BluetoothPlugin.instance.startBluetoothPrintBarCodeWithText(barCode, text);
+    } else {
+      return false;
+    }
+  }
+
+
+
+
+
+
+}
+
+

lib/service/user_service.dart

@@ -54,4 +54,16 @@ class UserService {
     if (user == null) return null;
     return UserRsp.fromJson(jsonDecode(user));
   }
+
+  /// 存储数据库DeviceInfoTable表的id号，用于记录同步的位置
+  Future<void> saveDeviceInfoTableTime(int timeId) async {
+
+    await SPUtils.getInstance().saveInt('DeviceInfoTableTimeInt', timeId);
+  }
+
+  /// 获取登录信息
+  int getDeviceInfoTableTime() {
+    return SPUtils.getInstance().getInt('DeviceInfoTableTimeInt') ?? -1;
+  }
+
 }

lib/utils/file_utils.dart

@@ -4,6 +4,7 @@ import 'dart:ui' as ui;
 
 import 'package:flutter/cupertino.dart';
 import 'package:flutter/rendering.dart';
+import 'package:lszlgl/main.dart';
 import 'package:path_provider/path_provider.dart';
 
 class FileUtils {

lib/utils/permission_utils.dart

@@ -0,0 +1,75 @@
+import 'package:flutter/material.dart';
+import 'package:permission_handler/permission_handler.dart';
+
+import '../router/my_navigator.dart';
+
+
+class PermissionHandler {
+  static Future<bool> handleWith(Permission permission,
+      {bool showTip = true}) async {
+    if (await permission.request().isGranted ||
+        await permission.request().isLimited) {
+      return true;
+    }
+
+    if (await permission.isPermanentlyDenied ||
+        await permission.isRestricted ||
+        await permission.isDenied) {
+      if (showTip) {
+
+        MyNavigator.showDialog(
+          builder: (_) => PermissionAlertDialog(permission: permission),
+        );
+      }
+    }
+    return false;
+  }
+}
+
+class PermissionAlertDialog extends StatelessWidget {
+  final Permission permission;
+
+  const PermissionAlertDialog({Key? key, required this.permission}) : super(key: key);
+
+  @override
+  Widget build(BuildContext context) {
+    String content = '';
+    if (this.permission is PermissionWithService) {
+      if (this.permission == Permission.location) {
+        content = '请前往系统设置打开定位权限';
+      }
+    }
+
+    if (this.permission is Permission) {
+      if (this.permission == Permission.photos) {
+        content = '请前往系统设置打开相册权限';
+      } else if (this.permission == Permission.camera) {
+        content = '请前往系统设置打开相机权限';
+      } else if (this.permission == Permission.microphone) {
+        content = '请前往系统设置打开麦克风权限';
+      } else if (this.permission == Permission.storage) {
+        content = '请前往系统设置打开存储权限';
+      } else if (this.permission == Permission.bluetoothScan) {
+        content = '请前往系统设置打开蓝牙权限';
+      } else {
+        content = '请前往系统设置打开该权限';
+      }
+    }
+
+    return AlertDialog(
+      title: Text('提示'),
+      content: Text(content),
+      backgroundColor: Colors.white,
+      elevation: 24,
+      shape: RoundedRectangleBorder(borderRadius: BorderRadius.circular(8)),
+      actions: <Widget>[
+        TextButton(
+          child: Text('知道了'),
+          onPressed: () {
+            // XRouter.pop(context);
+          },
+        ),
+      ],
+    );
+  }
+}

pubspec.yaml

@@ -89,6 +89,10 @@ dependencies:
   flutter_spinkit: ^5.2.1
   # 保存到相册
   image_gallery_saver: ^2.0.3
+  # 数据库
+  drift: ^2.18.0
+  #
+  sqlite3_flutter_libs: ^0.5.0
 
 dev_dependencies:
   flutter_test:
@@ -105,6 +109,7 @@ dev_dependencies:
   build_runner: '>=2.3.0 <4.0.0'
   # JSON转实体类
   json_serializable: ^6.6.2
+  drift_dev: ^2.2.0
 
 # For information on the generic Dart part of this file, see the
 # following page: https://dart.dev/tools/pub/pubspec