Kegerator Utama

Kode

• Keg Kelas
• Kelas Skala
• Kelas Kegerator

Keg KelasC#

menggunakan LagoVista.Common.Commanding;menggunakan Sistem;menggunakan System.Collections.Generic;menggunakan System.Linq;menggunakan System.Text;menggunakan Sistem .Threading.Tasks;menggunakan Windows.UI.Xaml;namespace LagoVista.IoT.Common.Kegerator.Models{ public class Keg :DeviceBase { int _idx; TimeSpan _updateInterval; Timbangan pribadi.Skala _skala; tong publik(int idx, Scales.Scale scale, TimeSpan updateInterval) { _idx =idx; _updateInterval =UpdateInterval; _skala =skala; } public override TimeSpan UpdateInterval { get { return _updateInterval; } } public override void Refresh() { LastUpdated =DateTime.Now; LagoVista.Common.PlatformSupport.Services.DispatcherServices.Invoke(() => { ContentsWeight =Scale.Weight - ContainerWeightLb; if (FullContentsWeightLb> 0) PercentFull =Convert.ToInt32((ContentsWeight / (FullContentsWeightLb - ContainerWeightLb)) * 100); else PercentFull =0; PercentFull =Math.Min(PercentFull, 100); if (GlassSizeOz> 0) QtyRemaining =Convert.ToInt32((ContentsWeight * 16)/ GlassSizeOz); else QtyRemaining =0; RaisePropertyChanged("PercentFullHeight"); RaisePropertyChanged ("PercentFullDisplay"); }); } Timbangan Publik. Skala Skala { get { return _scale; } } #region Properti yang Dihitung private int _qtyRemaining; public int QtyRemaining { dapatkan { return _qtyRemaining; } set { Set(ref _qtyRemaining, nilai); } } DateTime pribadi? _installDate; DateTime publik? InstallDate { dapatkan { return _installDate; } set { Set(ref _installDate, nilai); } } private int _percentFull; public int PercentFull { dapatkan { return _percentFull; } set { Set(ref _percentFull, nilai); } } public String PercentFullDisplay { get { return String.Format("{0}%", Convert.ToInt32(PercentFull)); } } public double PercentFullHeight { dapatkan { return Convert.ToDouble(_percentFull * 2); } } public int KegIndex { dapatkan { return _idx; } } #endregion #region Memasuki Properti private bool _isEmpty; public bool IsEmpty { dapatkan { return _isEmpty; } set { _isEmpty =nilai; RaisePropertyChanged(); } } pribadi ganda _glassSize; GlassSizeOz ganda publik { dapatkan { return _glassSize; } set { Set(ref _glassSize, nilai); } } DateTime pribadi? _tanggal lahir; DateTime publik? Tanggal Lahir { dapatkan { return _bornDate; } set { Set(ref _bornDate, nilai); } } ganda _containerWeight; public double ContainerWeightLb { dapatkan { return _containerWeight; } set { Set(ref _containerWeight, nilai); } } ganda _contentsWeight; public double ContentsWeight { dapatkan { return _contentsWeight; } set { Set(ref _contentsWeight, nilai); } } ganda _fullContentsWeight; public double FullContentsWeightLb { dapatkan { return _fullContentsWeight; } set { Set(ref _fullContentsWeight, nilai); } } String pribadi _contentsName; public String ContentsName { dapatkan { return _contentsName; } set { Set(ref _contentsName, nilai); } } #endregion public void Simpan() { LagoVista.Common.PlatformSupport.Services.BindingHelper.RefreshBindings(); PutSetting(String.Format("KEG{0}_CONTENTS", _idx), ContentsName); PutSetting(String.Format("KEG{0}_IS_EMPTY", _idx), IsEmpty.ToString()); PutSetting(String.Format("KEG{0}_CONTAINER_WEIGHT", _idx), String.Format("{0:0.00}", ContainerWeightLb)); PutSetting(String.Format("KEG{0}_GLASS_SIZE", _idx), String.Format("{0:0.00}", GlassSizeOz)); PutSetting(String.Format("KEG{0}_FULL_CONTENTS_WEIGHT", _idx), String.Format("{0:0.00}", FullContentsWeightLb)); if (BornDate.HasValue) PutSetting(String.Format("KEG{0}_BORN_DATE", _idx), BornDate.Value.ToString()); else RemoveSetting(String.Format("KEG{0}_BORN_DATE", _idx)); if(InstallDate.HasValue) PutSetting(String.Format("KEG{0}_INSTALL_DATE", _idx), InstallDate.Value.ToString()); else RemoveSetting(String.Format("KEG{0}_INSTALL_DATE", _idx)); } public void Load() { ContentsName =GetSetting(String.Format("KEG{0}_CONTENTS", _idx), "?"); ContainerWeightLb =Convert.ToDouble(GetSetting(String.Format("KEG{0}_CONTAINER_WEIGHT", _idx), "10.0")); GlassSizeOz =Convert.ToDouble(GetSetting(String.Format("KEG{0}_GLASS_SIZE", _idx), "12.0")); FullContentsWeightLb =Convert.ToDouble(GetSetting(String.Format("KEG{0}_FULL_CONTENTS_WEIGHT", _idx), "0.0")); IsEmpty =Convert.ToBoolean(GetSetting(String.Format("KEG{0}_IS_EMPTY", _idx), "True")); var bornDate =GetSetting("KEG{0}_BORN_DATE", String.Empty); if (!String.IsNullOrEmpty(bornDate)) BornDate =DateTime.Parse(bornDate); lain Tanggal Lahir =null; var installDate =GetSetting("KEG{0}_INSTALL_DATE", String.Empty); if (!String.IsNullOrEmpty(installDate)) InstallDate =DateTime.Parse(installDate); lain InstallDate =null; } asinkron publik batal SaveFullWeight() { FullContentsWeightLb =menunggu Scale.GetAverageWeight(); Menyimpan(); } public RelayCommand SaveFullWeightCommand { get { return new RelayCommand(() => SaveFullWeight()); } } }}

Kelas SkalaC#

menggunakan LagoVista.Common.Commanding;using System;using System.Collections.Generic;using System.Diagnostics;using System.Linq;using System .Teks;menggunakan System.Threading.Tasks;menggunakan Windows.Devices.I2c;namespace LagoVista.IoT.Common.Kegerator.Scales{ public class Scale :DeviceBase { Windows.Devices.I2c.I2cDevice _scaleI2CChannel; int _countOffset; dobel? _calibrationFactor =nol; pribadi TimeSpan _updateInterval; byte _alamat; Skala publik(alamat byte) { _alamat =alamat; } private void WriteValue(alamat byte, nilai int) { if (!IsDemoMode) { var offsetBuffer =byte baru[5]; offsetBuffer[0] =alamat; offsetBuffer[1] =(byte)(nilai>> 24); offsetBuffer[2] =(byte)(nilai>> 16); offsetBuffer[3] =(byte)(nilai>> 8); offsetBuffer[4] =(byte)(nilai); _scaleI2CChannel.Write(offsetBuffer); } } public async Task Init(String i2cDeviceId, TimeSpan updateInterval) { var settings =new I2cConnectionSettings(_address) { BusSpeed ​​=I2cBusSpeed.StandardMode, SharingMode =I2cSharingMode.Shared }; _updateInterval =updateInterval; IsDemoMode =String.IsNullOrEmpty(i2cDeviceId); if (!IsDemoMode) { _scaleI2CChannel =menunggu Windows.Devices.I2c.I2cDevice.FromIdAsync(i2cDeviceId, pengaturan); if (Windows.Storage.ApplicationData.Current.LocalSettings.Values.ContainsKey(String.Format("{0:X}.OFFSET", _address))) { _countOffset =Convert.ToInt32(Windows.Storage.ApplicationData.Current.LocalSettings .Nilai[String.Format("{0:X}.OFFSET", _address)]); coba { WriteValue((byte)'O', _countOffset); } catch (Pengecualian ex) { Debug.WriteLine("Skala offline "); } } if (Windows.Storage.ApplicationData.Current.LocalSettings.Values.ContainsKey(String.Format("{0:X}.CALIBRATION", _address))) { _calibrationFactor =Convert.ToDouble(Windows.Storage.ApplicationData.Current .LocalSettings.Values[String.Format("{0:X}.CALIBRATION", _address)]); LagoVista.Common.PlatformSupport.Services.DispatcherServices.Invoke(() => { Status ="Siap"; }); } } else { LagoVista.Common.PlatformSupport.Services.DispatcherServices.Invoke(() => { Status ="Siap"; }); } } dalam? _lastRaw =nol; private int GetRaw() { try { var inbuffer =byte baru[4]; _scaleI2CChannel.Write(byte baru[] { (byte)0x11 }); _scaleI2CChannel.Read(inbuffer); /* Perhatikan skalanya, ini panjang (64 bit) ini int (64 bit) */ var thisRaw =(int)(inbuffer[0] <<24 | inbuffer[1] <<16 | inbuffer[ 2] <<8 | inbuffer[3]); if (_lastRaw.HasValue) { if (Math.Abs(_lastRaw.Value - thisRaw)> 0xFFFF) mengembalikan _lastRaw.Value; } else _lastRaw =thisRaw; kembalikan ini Mentah; } catch (Pengecualian) { return -1; } } public override void Refresh() { LastUpdated =DateTime.Now; int hasil mentah =0; var isOnline =benar; coba { var inbuffer =byte baru[4]; var statusBuffer =byte baru[1]; if (!IsDemoMode) { _scaleI2CChannel.Write(byte baru[] { (byte)0x0A }); _scaleI2CChannel.Read(statusBuffer); rawResult =GetRaw(); } if (_calibrationFactor.HasValue) { Berat =(rawResult - _countOffset) * _calibrationFactor.Value; Debug.WriteLine(String.Format("0x{0:X} BERAT NILAI => {1:0.00} lbs", _address, Weight)); } else if (_countOffset> 0) Debug.WriteLine(String.Format("0x{0:X} NILAI NOL => {1}", _address, rawResult - _countOffset)); else Debug.WriteLine(String.Format("0x{0:X} RAW NILAI => 0x{1:X}", _address, rawResult)); } catch (Pengecualian ex) { rawResult =-1; isOnline =salah; Debug.WriteLine(mis.Pesan); } LagoVista.Common.PlatformSupport.Services.DispatcherServices.Invoke(() => { Raw =rawResult; IsOnline =isOnline; if (!IsOnline) { Status ="Offline"; WeightDisplay ="?"; } else { if (_calibrationFactor .HasValue) { Status ="Siap"; WeightDisplay =String.Format("{0}lb {1:00}oz", Math.Truncate(Weight), ((Weight % 1.0) * 16.0)); } else { WeightDisplay ="?"; Status ="Tidak Dikalibrasi"; } } RaisePropertyChanged("LastUpdateDisplay"); }); } const int CALIBRATION_COUNT =10; public async void StoreOffset() { LagoVista.Common.PlatformSupport.Services.DispatcherServices.Invoke(() => { Status ="Zeroing"; }); Debug.WriteLine("Memulai Proses Nol"); panjang nolJumlah =0; for (var idx =0; idx  { Status ="Nol"; }); } asinkron publik batal Kalibrasi() { Status ="Kalibrasi"; LagoVista.Common.PlatformSupport.Services.BindingHelper.RefreshBindings(); jumlah panjangJumlah =0; for (var idx =0; idx  GetAverageWeight(int pointCount =5) { var weightSum =0.0; for(var idx =0; idx  StoreOffset()); } } public RelayCommand CalibrationCommand { get { return new RelayCommand(() => Calibrate()); } } }}

Kelas KegeratorC#

menggunakan LagoVista.Common.Commanding;using System;using System.Collections.Generic;using System.Collections.ObjectModel;using System.ComponentModel; menggunakan System.Linq;menggunakan System.Runtime.CompilerServices;menggunakan System.Text;menggunakan System.Threading.Tasks;menggunakan Windows.Devices.Enumeration;menggunakan Windows.Devices.I2c;namespace LagoVista.IoT.Common.Kegerator{ public class Kegerator :INotifyPropertyChanged { acara publik PropertyChangedEventHandler PropertyChanged; Model pribadi.Keg _keg1; Model pribadi.Keg _keg2; Model pribadi.Keg _keg3; Model pribadi.Keg _keg4; CO2.CO2Tank pribadi _co2Tank; private Kegerator() { } Public List _devices =new List(); private void RaisePropertyChanged([CallerMemberName] string propertyName =null) { var eventHandler =this.PropertyChanged; if (eventHandler !=null) { eventHandler(ini, new PropertyChangedEventArgs(propertyName)); } } private bool Set(ref T penyimpanan, nilai T, string columnName =null, [CallerMemberName] string propertyName =null) { if (object.Equals(storage, value)) return false; penyimpanan =nilai; this.RaisePropertyChanged(namaproperti); kembali benar; } byte[] _scalesAddresses ={ 0x43, 0x41, 0x40, 0x42 }; string const pribadi I2C_CONTROLLER_NAME ="I2C1"; pribadi Thermo.Temperatures _temperatures; pribadi Thermo.Controller _tempController; Timbangan pribadi.Skala _co2Scale; Kamus pribadi _kegScales; pribadi CO2.PressureSensor _pressureSensor; pribadi LED.LEDManager _ledManager; private REST.KegeratorServices _kegServices; private static Kegerator _kegerator =new Kegerator(); public static Kegerator Instance { get { return _kegerator; } } CloudServices.EventHubClient _eventHubClient pribadi; System.Threading.Timer _timer; private bool _initialized =false; public async Task Init() { if (!_initialized) { _initialized =true; var pemilih =I2cDevice.GetDeviceSelector(I2C_CONTROLLER_NAME); /* Temukan string pemilih untuk pengontrol bus I2C */ var deviceInfo =(menunggu DeviceInformation.FindAllAsync(selector)).FirstOrDefault(); /* Temukan perangkat pengontrol bus I2C dengan string pemilih kami */ var deviceId =deviceInfo ==null ? (string)null :deviceInfo.Id; _temperatures =baru Thermo.Temperatures (0x48); menunggu _temperatures.Init(deviceId); _devices.Add(_temperatures); _tempController =baru Thermo.Controller(); _tempController.Init(_temperatures); _devices.Add(_tempController); _pressureSensor =CO2 baru.PressureSensor(); menunggu _pressureSensor.Init(deviceId, TimeSpan.FromSeconds(1)); _devices.Add(_pressureSensor); _co2Scale =Scales.Scale baru (0x44); menunggu _co2Scale.Init(deviceId, TimeSpan.FromSeconds(1)); _devices.Add(_co2Scale); _co2Tank =CO2.CO2Tank baru(_co2Scale, TimeSpan.FromSeconds(2)); _co2Tank.Load(); _devices.Add(_co2Tank); _kegScales =Kamus baru(); _eventHubClient =CloudServices.EventHubClient baru (ini, TimeSpan.FromSeconds(2)); _devices.Add(_eventHubClient); for (var idx =0; idx <4; ++idx) { var scale =new Scales.Scale(_scalesAddresses[idx]); menunggu scale.Init(deviceId, TimeSpan.FromMilliseconds(500)); _kegScales.Add(idx, scale); _devices.Add(skala); } _keg1 =new Models.Keg(1, _kegScales[0], TimeSpan.FromMilliseconds(500)); _keg1.Load(); _devices.Add(_keg1); _keg2 =Models.Keg baru(2, _kegScales[1], TimeSpan.FromMilliseconds(500)); _keg2.Muat(); _devices.Add(_keg2); _keg3 =Models.Keg baru(3, _kegScales[2], TimeSpan.FromMilliseconds(500)); _keg3.Load(); _devices.Add(_keg3); _keg4 =Models.Keg baru(4, _kegScales[3], TimeSpan.FromMilliseconds(500)); _keg4.Load(); _devices.Add(_keg4); DateInitialized =DateTime.Now.ToString(); Web.WebServer.Instance.StartServer(); _kegServices =new REST.KegeratorServices() { Port =9500 }; _kegServices.EventContent +=_kegServices_EventContent; _kegServices.StartServer(); _timer =new System.Threading.Timer((state) => { Refresh(); }, null, 0, 250); } } private void _kegServices_EventContent(pengirim objek, string e) { var parts =e.Split('/'); if (parts.Count()> 0) { switch (parts[1]) { case "nol":{ var scaleIndex =Convert.ToInt32(parts[2]); _kegScales[scaleIndex].StoreOffset(); } merusak; case "cal":{ var scaleIndex =Convert.ToInt32(parts[2]); _kegScales[scaleIndex].CalibrationWeight =Convert.ToDouble(bagian[3]); _kegScales[scaleIndex].Calibrate(); } merusak; } } } public void Refresh() { foreach (perangkat var di _devices) { if (DateTime.Now> (device.LastUpdated + device.UpdateInterval)) device.Refresh(); } LagoVista.Common.PlatformSupport.Services.DispatcherServices.Invoke(() => { CurrentTimeDisplay =DateTime.Now.ToString(); RaisePropertyChanged("CurrentTimeDisplay"); }); } Suhu Thermo.Temperatures publik { get { return _temperatures; } } Thermo.Controller TemperatureController publik { dapatkan { return _tempController; } } String pribadi _statusMessage; public String StatusMessage { dapatkan { return _statusMessage; } set { Set(ref _statusMessage, nilai); } } public List KegScales { get { return _kegScales.Values.ToList(); } } public void ToggleCompressor() { if (_tempController.IsCompressorOn) _tempController.CompressorOff(); lain _tempController.CompressorOn(); } public String DateInitialized { get; mengatur; } publik String CurrentTimeDisplay { dapatkan; mengatur; } Public Scales.Scale CO2Scale { get { return _co2Scale; } } public CO2.PressureSensor PressureSensor { dapatkan { return _pressureSensor; } } public Models.Keg Keg1 { get { return _keg1; } } public Models.Keg Keg2 { get { return _keg2; } } public Models.Keg Keg3 { get { return _keg3; } } public Models.Keg Keg4 { get { return _keg4; } } CO2.CO2Tank CO2Tank publik { dapatkan { return _co2Tank; } } public RelayCommand ToggleCompressorCommand { get { return new RelayCommand(ToggleCompressor); } } }}