using log4net; using Prism.Commands; using Prism.Events; using Prism.Mvvm; using Prism.Regions; using SqlSugar; using System; using System.Collections.Generic; using System.Configuration; using System.Linq; using System.Speech.Synthesis; using System.Text; using System.Threading; using System.Threading.Tasks; using System.Windows; using System.Windows.Threading; using DM_Weight.Models; using DM_Weight.msg; using DM_Weight.Port; using DM_Weight.util; using Newtonsoft.Json; using System.Text.RegularExpressions; using System.Windows.Controls; using DM_Weight.Common; namespace DM_Weight.ViewModels { public class DrawerTakeDrugWindowViewModel : BindableBase, IConfirmNavigationRequest, IRegionMemberLifetime { private readonly ILog logger = LogManager.GetLogger(typeof(DrawerTakeDrugWindowViewModel)); private List _channelStocks = new List(); public List ChannelStocks { get => _channelStocks; set => SetProperty(ref _channelStocks, value); } private static readonly DateTime Jan1st1970 = new DateTime (1970, 1, 1, 0, 0, 0, DateTimeKind.Utc); private PortUtil _portUtil; IEventAggregator _eventAggregator; public DrawerTakeDrugWindowViewModel(PortUtil portUtil, IEventAggregator eventAggregator) { _portUtil = portUtil; _eventAggregator = eventAggregator; } void DoMyPrismEvent(DeviceMsg msg) { if (msg.WindowName == "DrawerTakeDrugWindow") { switch (msg.EventType) { // 抽屉打开 case EventType.DRAWEROPEN: if (Status == 1) { Status = 2; } //是冰箱抽屉则开冰箱抽屉时发送延迟报警指令 CheckIsFridgeOpen(); break; // 抽屉关闭 case EventType.DRAWERCLOSE: if (Status == 2) { Status = 3; } //是冰箱抽屉则开冰箱抽屉时发送延迟报警指令 CheckIsFridgeClose(); break; // 数量变化 case EventType.UPDATEQUANTITY: if (Status == 2) { ChannelStocks.ForEach(it => it.TakeQuantity = msg.Quantitys[it.ColNo - 1]); } break; // 打开失败 case EventType.OPENERROR: AlertMsg alertMsg = new AlertMsg { Message = msg.Message, Type = MsgType.ERROR, }; _eventAggregator.GetEvent().Publish(alertMsg); Status = 0; break; } } } private int _status; public int Status { get => _status; set => SetProperty(ref _status, value); } private int _drawerNo = 1; public int DrawerNo { get => _drawerNo; set => SetProperty(ref _drawerNo, value); } private bool _is8Drawer = true; public bool Is8Drawer { get => _is8Drawer; set => SetProperty(ref _is8Drawer, value); } private bool _is16Drawer = false; public bool Is16Drawer { get => _is16Drawer; set => SetProperty(ref _is16Drawer, value); } private bool _is17Drawer = false; public bool Is17Drawer { get => _is17Drawer; set => SetProperty(ref _is17Drawer, value); } public DelegateCommand UpdateDrawerNo { get => new DelegateCommand((DrawerNo) => { this.DrawerNo = Convert.ToInt32(DrawerNo); RequestData(); }, (DrawerNo) => Status == 0 ); } public DelegateCommand OpenDrawer { get => new DelegateCommand(() => { if (Status == 0) { Status = 1; _portUtil.SpeakAsync("正在打开" + DrawerNo + "号抽屉"); List singleChannels = ChannelStocks.FindAll(it => it.BoardType != (Int32)BoardTypeEnum.separation); _portUtil.WindowName = "DrawerTakeDrugWindow"; _portUtil.BoardType = singleChannels.Count > 0 ? singleChannels[0].BoardType : (Int32)BoardTypeEnum.separation; _portUtil.ColNos = singleChannels.Select(it => it.ColNo).ToArray(); _portUtil.DrawerNo = DrawerNo; Dispatcher.CurrentDispatcher.BeginInvoke(DispatcherPriority.Normal, () => _portUtil.Start()) ; } }); } private bool _isFinishClick = false; // 完成按钮 public DelegateCommand TakeFinish { get => new DelegateCommand(() => { if (!_isFinishClick) { _isFinishClick = true; List record = ChannelStocks.FindAll(it => it.TakeQuantity != 0).ToList(); logger.Info("点击完成按钮，库位数据：" + JsonConvert.SerializeObject(record)); if (record.Count > 0) { string InvoiceId = "DRAWER_" + CurrentTimeMillis(); var f = SqlSugarHelper.Db.UseTran(() => { for (int i = 0; i < record.Count; i++) { ChannelStock it = record[i]; // 更新数据 库存信息 SqlSugarHelper.Db.Updateable(new ChannelStock() { Quantity = it.Quantity - it.TakeQuantity, ManuNo = it.ManuNo, EffDate = it.EffDate, Id = it.Id, }).UpdateColumns(it => new { it.Quantity, it.ManuNo, it.EffDate }).ExecuteCommand(); // 获取更新完库存后的药品库存 List nowChannels = SqlSugarHelper.Db.Queryable() .Where(cs => cs.MachineId.Equals(it.MachineId)) .Where(cs => cs.DrugId.Equals(it.DrugId)) .Where(cs => cs.DrawerType == (Int32)DrawerTypeEnum.drawerTypeOne) .ToList(); // 保存数据 出库记录 SqlSugarHelper.Db.Insertable(new MachineRecord() { MachineId = it.MachineId, DrawerNo = it.DrawerNo, ColNo = it.ColNo, DrugId = it.DrugId, ManuNo = it.ManuNo, EffDate = !String.IsNullOrEmpty(it.EffDate) ? DateTime.ParseExact(it.EffDate, "yyyy-MM-dd", System.Globalization.CultureInfo.CurrentCulture) : null, Operator = HomeWindowViewModel.Operator?.Id, Reviewer = HomeWindowViewModel.Reviewer?.Id, OperationTime = DateTime.Now, Quantity = it.TakeQuantity, Type = 2, InvoiceId = InvoiceId, StockQuantity = nowChannels.Sum(it => it.Quantity) }).ExecuteCommand(); logger.Info($"抽屉取药保存->库位【{it.DrawerNo}-{it.ColNo}】取出药品【{it.DrugInfo.DrugName}】个数【{it.TakeQuantity}】，取药前库存【{it.Quantity}】"); } return true; }); if (f.Data) { // 更新屏显库存 List singleChannels = record.FindAll(it => it.BoardType != 1); if ((singleChannels.Count > 0 ? singleChannels[0].BoardType : 1) == (Int32)BoardTypeEnum.smart|| (singleChannels.Count > 0 ? singleChannels[0].BoardType : 1) == (Int32)BoardTypeEnum.weighSmartBox) { singleChannels.ForEach(it => { _portUtil.WriteQuantity(it.DrawerNo, it.ColNo, it.Quantity - it.TakeQuantity); }); } RequestData(); AlertMsg alertMsg = new AlertMsg { Message = "抽屉取药完成，库存已更新", Type = MsgType.SUCCESS, }; _eventAggregator.GetEvent().Publish(alertMsg); } if (!f.IsSuccess) { AlertMsg alertMsg = new AlertMsg { Message = "抽屉取药完成，库存更新失败！", Type = MsgType.ERROR, }; _eventAggregator.GetEvent().Publish(alertMsg); } Status = 0; _isFinishClick = false; } else { _isFinishClick = false; AlertMsg alertMsg = new AlertMsg { Message = "没有填写取药数量", Type = MsgType.ERROR }; _eventAggregator.GetEvent().Publish(alertMsg); } } }); } // 取消按钮 public DelegateCommand CancleTake { get => new DelegateCommand(() => { _portUtil.ResetData(); Status = 0; }); } //检查是否是冰箱抽屉（冰箱抽屉打开时需要发送冰箱延迟报警的指令） public async Task CheckIsFridgeOpen() { if(ChannelStocks!=null&& ChannelStocks.Count>0) { if (_portUtil.BoardType==(Int32)BoardTypeEnum.fridge) { _portUtil.FridgeOperate = true; //发送冰箱延迟报警的指令 await _portUtil.FridgeDelayWarm(); _portUtil.FridgeOperate = false; } } } //检查是否是冰箱抽屉（冰箱抽屉关闭时需要查询冰箱温度如温度不在范围则发送冰箱延迟报警的指令） public async Task CheckIsFridgeClose() { if (ChannelStocks != null && ChannelStocks.Count > 0) { if (_portUtil.BoardType== (Int32)BoardTypeEnum.fridge) { string[] iTempertureRange = ConfigurationManager.AppSettings["temperatureRange"].Split('-'); //发送查询冰箱温度的指令 float retT= await _portUtil.GetFridgeTemperature(); if (retT > Convert.ToSingle(iTempertureRange[0]) && retT < Convert.ToSingle(iTempertureRange[1])) { _portUtil.FridgeOperate = true; //发送冰箱延迟报警的指令 await _portUtil.FridgeDelayWarm(); _portUtil.FridgeOperate = false; } } } } public long CurrentTimeMillis() { return (long)(DateTime.UtcNow - Jan1st1970).TotalMilliseconds; } public bool KeepAlive => false; public void FindDrawerCount() { int count = 0; if (ConfigurationManager.AppSettings["MultiBatch"].ToString().Equals("1")) { count = SqlSugarHelper.Db.Queryable().Where(cs => cs.DrawerType != (Int32)DrawerTypeEnum.recyle) .Where(cs => cs.MachineId.Equals(ConfigurationManager.AppSettings["machineId"] ?? "DM1")).GroupBy(cs => cs.DrawerNo).Select(cs => SqlFunc.AggregateCount(cs.DrawerNo)).Count(); } else { count = SqlSugarHelper.Db.Queryable().Where(cs => cs.DrawerType != (Int32)DrawerTypeEnum.recyle) .Where(cs => cs.MachineId.Equals(ConfigurationManager.AppSettings["machineId"] ?? "DM1")).GroupBy(cs => cs.DrawerNo).Select(cs => SqlFunc.AggregateCount(cs.DrawerNo)).Count(); } Is8Drawer = count < 9; Is16Drawer = count >= 16; Is17Drawer = count > 16; } //这个方法用于拦截请求,continuationCallback(true)就是不拦截，continuationCallback(false)拦截本次操作 public void ConfirmNavigationRequest(NavigationContext navigationContext, Action continuationCallback) { continuationCallback(true); } public void RequestData() { List queryData = SqlSugarHelper.Db.Queryable() .Includes(cs => cs.DrugInfo) .Where(cs => cs.DrawerNo == DrawerNo) .Where(cs => cs.DrugId != null) .Where(cs => cs.MachineId.Equals(ConfigurationManager.AppSettings["machineId"] ?? "DM1")) .Where(cs => cs.DrawerType == (Int32)DrawerTypeEnum.drawerTypeOne) .Where(cs => cs.Quantity > 0) .OrderBy(cs => cs.ColNo) .ToList(); ChannelStocks = queryData; } //接收导航传过来的参数 现在是在此处初始化了表格数据 public void OnNavigatedTo(NavigationContext navigationContext) { _eventAggregator.GetEvent().Subscribe(DoMyPrismEvent); FindDrawerCount(); RequestData(); } //每次导航的时候，该实列用不用重新创建，true是不重新创建,false是重新创建 public bool IsNavigationTarget(NavigationContext navigationContext) { return true; } //这个方法用于拦截请求, 不让走 public void OnNavigatedFrom(NavigationContext navigationContext) { // 取消消息订阅 _eventAggregator.GetEvent().Unsubscribe(DoMyPrismEvent); } } }