275 lines
10 KiB
C#
275 lines
10 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using Windows.Devices.Bluetooth;
|
||
using Windows.Devices.Bluetooth.Advertisement;
|
||
using Windows.Devices.Bluetooth.GenericAttributeProfile;
|
||
using Windows.Devices.Enumeration;
|
||
using Windows.Foundation;
|
||
using Windows.Storage.Streams;
|
||
using WpfBleApp.Model;
|
||
using WpfBleApp.Utils;
|
||
using CharacteristicDictionary = System.Collections.Generic.Dictionary<string, System.Collections.Generic.Dictionary<string, Windows.Devices.Bluetooth.GenericAttributeProfile.GattCharacteristic>>;
|
||
|
||
//线程安全的版本，考虑到连接后不会更改。还是使用性能更好的 Dictionary
|
||
//using ConcurrentGattDictionary = System.Collections.Concurrent.ConcurrentDictionary<string, System.Collections.Concurrent.ConcurrentDictionary<string, Windows.Devices.Bluetooth.GenericAttributeProfile.GattCharacteristic>>;
|
||
|
||
namespace WpfBleApp.Ble
|
||
{
|
||
public class BleDevice : ObservableObject
|
||
{
|
||
private readonly DeviceInformation _deviceInfo;
|
||
private BluetoothLEDevice _device;
|
||
private GattCharacteristic CharacteristicWrite;
|
||
private GattCharacteristic CharacteristicNotify;
|
||
private string _mac;
|
||
private string _name;
|
||
private byte[] _mfrData;
|
||
private int _rssi;
|
||
|
||
private readonly List<GattDeviceService> GattServices = new List<GattDeviceService>();
|
||
private readonly CharacteristicDictionary GattCharacteristics = new CharacteristicDictionary();
|
||
|
||
public event TypedEventHandler<GattCharacteristic, byte[]> CharacteristicValueChanged;
|
||
public event TypedEventHandler<BleDevice, bool> ConnectionStateChanged;
|
||
|
||
public BleDevice() { }
|
||
|
||
public BleDevice(DeviceInformation deviceInfo)
|
||
{
|
||
_deviceInfo = deviceInfo;
|
||
_mac = deviceInfo.Mac();
|
||
_name = deviceInfo.Name;
|
||
|
||
Log.Info("################# BleDevice #################");
|
||
foreach (KeyValuePair<string, object> item in deviceInfo.Properties)
|
||
{
|
||
Log.Info($"{item.Key}={item.Value}");
|
||
}
|
||
}
|
||
|
||
public void Update(BleDevice other)
|
||
{
|
||
Name = other.Name;
|
||
MfrData = other.MfrData;
|
||
RSSI = other.RSSI;
|
||
}
|
||
|
||
public void Update(BluetoothLEAdvertisementReceivedEventArgs args)
|
||
{
|
||
//通过方法属性更新是为了通知UI刷新
|
||
string localName = args.LocalName();
|
||
//有可能是广播回应包，不带LocalName，防止显示不出真实的名称
|
||
if (!string.IsNullOrEmpty(localName))
|
||
{
|
||
Name = localName;
|
||
}
|
||
|
||
byte[] mfrData = args.MfrData();
|
||
if (mfrData != null)
|
||
{
|
||
MfrData = args.MfrData();
|
||
}
|
||
RSSI = args.RawSignalStrengthInDBm;
|
||
}
|
||
|
||
public byte[] MfrData
|
||
{
|
||
get => _mfrData;
|
||
set
|
||
{
|
||
Set(ref _mfrData, value);
|
||
OnPropertyChanged(nameof(MfrDataHex));
|
||
}
|
||
}
|
||
|
||
public string MfrDataHex => _mfrData?.ToHex();
|
||
|
||
public int RSSI
|
||
{
|
||
get => -_rssi;
|
||
set => Set(ref _rssi, value);
|
||
}
|
||
|
||
public string Name
|
||
{
|
||
get => string.IsNullOrEmpty(_name) ? "Unknown Device" : _name;
|
||
set => Set(ref _name, value);
|
||
}
|
||
|
||
//System.Devices.Aep.DeviceAddress
|
||
public string Mac => _mac;
|
||
|
||
public string Id => _deviceInfo.Id;
|
||
|
||
public bool IsConnected => _device != null && _device.ConnectionStatus == BluetoothConnectionStatus.Connected;
|
||
|
||
/// <summary>
|
||
/// 连接设备
|
||
/// </summary>
|
||
public async void Connect()
|
||
{
|
||
//下面一行是官方文档的写法，貌似版本低所以报错
|
||
//BluetoothLEDevice bluetoothLEDevice = await BluetoothLEDevice.FromIdAsync(Id);
|
||
|
||
//使用自定义的拓展方法 GetResultAsync()
|
||
_device = await BluetoothLEDevice.FromIdAsync(Id).GetResultAsync();
|
||
//监听连接状态
|
||
_device.ConnectionStatusChanged += _device_ConnectionStatusChanged;
|
||
Log.Info($"{DateTime.Now:HH:mm:ss.fff} - 开始连接: " + _device);
|
||
DiscoverServices();
|
||
}
|
||
|
||
private void _device_ConnectionStatusChanged(BluetoothLEDevice sender, object args)
|
||
{
|
||
Log.Info("_device_ConnectionStatusChanged() - ConnectionStatus=" + sender.ConnectionStatus);
|
||
if (sender.ConnectionStatus == BluetoothConnectionStatus.Connected)
|
||
{
|
||
}
|
||
else
|
||
{
|
||
ConnectionStateChanged?.Invoke(this, false);
|
||
}
|
||
}
|
||
|
||
private async void DiscoverServices()
|
||
{
|
||
GattServices.Clear();
|
||
GattCharacteristics.Clear();
|
||
|
||
GattDeviceServicesResult servicesResult = await _device.GetGattServicesAsync().GetResultAsync();
|
||
if (servicesResult.Status == GattCommunicationStatus.Success)
|
||
{
|
||
foreach (GattDeviceService service in servicesResult.Services)
|
||
{
|
||
//存储该服务下的特征值
|
||
Dictionary<string, GattCharacteristic> characteristics = new Dictionary<string, GattCharacteristic>();
|
||
|
||
string serviceUuid = service.Uuid.ToString();
|
||
Log.Info($"Gatt Service: {serviceUuid}");
|
||
GattCharacteristicsResult characteristicsResult = await service.GetCharacteristicsAsync().GetResultAsync();
|
||
if (characteristicsResult.Status == GattCommunicationStatus.Success)
|
||
{
|
||
foreach (GattCharacteristic characteristic in characteristicsResult.Characteristics)
|
||
{
|
||
//存储该特征值
|
||
characteristics[characteristic.Uuid.ToString()] = characteristic;
|
||
|
||
string characteristicUuid = characteristic.Uuid.ToString();
|
||
Log.Info($"\tGatt Characteristic: {characteristicUuid}");
|
||
if (serviceUuid == Uuids.SERVICE)
|
||
{
|
||
if (characteristicUuid == Uuids.WRITE)
|
||
{
|
||
CharacteristicWrite = characteristic;
|
||
}
|
||
else if (characteristicUuid == Uuids.NOTIFY)
|
||
{
|
||
CharacteristicNotify = characteristic;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
GattCharacteristics[service.Uuid.ToString()] = characteristics;
|
||
GattServices.Add(service);
|
||
}
|
||
//订阅通知
|
||
if (CharacteristicNotify != null)
|
||
{
|
||
//需得用一个全局变量保持对 ValueChanged 回调函数的引用，不然收不到数据
|
||
CharacteristicNotify.ValueChanged += CharacteristicNotify_ValueChanged;
|
||
bool enabled = await EnableNotification(CharacteristicNotify);
|
||
if (enabled)
|
||
{
|
||
Log.Info("订阅通知成功！" + CharacteristicNotify.Uuid);
|
||
}
|
||
}
|
||
ConnectionStateChanged?.Invoke(this, true);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 收到数据
|
||
/// </summary>
|
||
/// <param name="sender"></param>
|
||
/// <param name="args"></param>
|
||
private void CharacteristicNotify_ValueChanged(GattCharacteristic sender, GattValueChangedEventArgs args)
|
||
{
|
||
byte[] data = args.CharacteristicValue.ToBytes();//十进制
|
||
Log.Info($"收到数据 <<< {data.ToHex()}");
|
||
Console.WriteLine(data.ToHex());//转十六进制
|
||
CharacteristicValueChanged?.Invoke(sender, data);
|
||
//for (int i = 0; i < data.Length; i++)
|
||
//{
|
||
// Log.Info(data[i].ToString("X2"));
|
||
//}
|
||
}
|
||
|
||
private async Task<bool> EnableNotification(GattCharacteristic characteristic)
|
||
{
|
||
GattCommunicationStatus result = await characteristic
|
||
.WriteClientCharacteristicConfigurationDescriptorAsync(
|
||
GattClientCharacteristicConfigurationDescriptorValue.Notify
|
||
).GetResultAsync();
|
||
return result == GattCommunicationStatus.Success;
|
||
}
|
||
|
||
public async Task<bool> Write(byte[] data)
|
||
{
|
||
if (CharacteristicWrite == null)
|
||
{
|
||
return false;
|
||
}
|
||
DataWriter writer = new DataWriter();
|
||
writer.WriteBytes(data);
|
||
GattCommunicationStatus result = await CharacteristicWrite
|
||
.WriteValueAsync(writer.DetachBuffer(), GattWriteOption.WriteWithoutResponse)
|
||
.GetResultAsync();
|
||
return result == GattCommunicationStatus.Success;
|
||
}
|
||
|
||
public async Task<byte[]> Read(string serviceUuid, string characteristicUuid)
|
||
{
|
||
GattCharacteristic characteristic = GattCharacteristics[serviceUuid]?[characteristicUuid];
|
||
if (characteristic != null)
|
||
{
|
||
GattReadResult result = await characteristic.ReadValueAsync().GetResultAsync();
|
||
if (result.Status == GattCommunicationStatus.Success)
|
||
{
|
||
byte[] data = result.Value.ToBytes();
|
||
Log.Info($"读取数据 <<< {data.ToHex()} / {Encoding.UTF8.GetString(data)}");
|
||
return data;
|
||
}
|
||
}
|
||
else
|
||
{
|
||
Log.Info($"未发现该特征: {serviceUuid} / {characteristicUuid}");
|
||
}
|
||
return null;
|
||
}
|
||
|
||
|
||
public void Disconnect()
|
||
{
|
||
Log.Info("Disconnect()");
|
||
|
||
//必须释放服务才能断开连接
|
||
foreach (GattDeviceService service in GattServices)
|
||
{
|
||
service.Dispose();
|
||
}
|
||
|
||
_device?.Dispose();
|
||
//_device = null;//赋值为 null 会导致收不到断线的通知
|
||
//ConnectionStateChanged?.Invoke(this, false);
|
||
}
|
||
|
||
public override string ToString()
|
||
{
|
||
return Name + "\r\n" + Mac;
|
||
}
|
||
}
|
||
}
|