using DM_Weight.Models; using DM_Weight.msg; using DM_Weight.Port; using DM_Weight.select; using DM_Weight.util; using log4net; using MaterialDesignThemes.Wpf; using Prism.Commands; using Prism.Events; using Prism.Mvvm; using Prism.Regions; using Prism.Services.Dialogs; using SqlSugar; using System; using System.Collections.Generic; using System.Configuration; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace DM_Weight.ViewModels { public class OrderTakeAllDrugDialogViewModel : BindableBase, IDialogAware, IRegionMemberLifetime { private readonly ILog logger = LogManager.GetLogger(typeof(OrderTakeDialogViewModel)); public string Title => "处方取药"; public event Action RequestClose; private static readonly DateTime Jan1st1970 = new DateTime (1970, 1, 1, 0, 0, 0, DateTimeKind.Utc); private PortUtil _portUtil; IEventAggregator _eventAggregator; IDialogService _dialogService; public OrderTakeAllDrugDialogViewModel(PortUtil portUtil, IEventAggregator eventAggregator, IDialogService DialogService) { _dialogService = DialogService; _portUtil = portUtil; _eventAggregator = eventAggregator; } void DoMyPrismEvent(DeviceMsg msg) { if (msg.WindowName == "OrderTakeDrugWindow") { IGrouping grouping = enumerator.Current; int DrawerNo = grouping.Key; List channelStocks = grouping.ToList(); switch (msg.EventType) { // 抽屉打开 case EventType.DRAWEROPEN: if (Status == 1) { if (channelStocks[0].process == 1) { channelStocks.ForEach(it => it.process = 2); } } break; // 抽屉关闭 case EventType.DRAWERCLOSE: if (Status == 1) { if (channelStocks[0].process == 2) { channelStocks.ForEach(it => it.process = 3); } IGrouping groupingBefore = enumerator.Current; int DrawerNoBefore = groupingBefore.Key; if (enumerator.MoveNext()) { IGrouping groupingAfter = enumerator.Current; int DrawerNoAfter = groupingAfter.Key; if (DrawerNoBefore < 9 && DrawerNoAfter > 8) { Thread.Sleep(50); } OpenOneByOne(); } // 已经全部取出 else { Status = 3; } } break; // 数量变化 case EventType.UPDATEQUANTITY: if (Status == 1) { logger.Info($"抽屉【{DrawerNo}】库位取药数量【{msg.Quantitys}】"); } break; // 打开失败 case EventType.OPENERROR: AlertMsg alertMsg = new AlertMsg { Message = msg.Message, Type = MsgType.ERROR, }; _eventAggregator.GetEvent().Publish(alertMsg); Status = 0; break; } } } private int _status = 0; public int Status { get => _status; set => SetProperty(ref _status, value); } private OrderInfo? _orderInfo; public OrderInfo? OrderInfo { get => _orderInfo; set => SetProperty(ref _orderInfo, value); } private List orderDetails { get; set; } private List orderInfos { get; set; } private List _channelStocks; public List ChannelStocks { get => _channelStocks; set => SetProperty(ref _channelStocks, value); } private IEnumerable> enumerable; private IEnumerator> enumerator; public bool CanCloseDialog() { return Status == 0; } public void OnDialogClosed() { // 取消消息订阅 _eventAggregator.GetEvent().Unsubscribe(DoMyPrismEvent); } string orderDate; OrderTakeSelect selectedItem; string? searchValue; public void OnDialogOpened(IDialogParameters parameters) { _eventAggregator.GetEvent().Subscribe(DoMyPrismEvent); orderDate = parameters.GetValue("OrderDate"); selectedItem = parameters.GetValue("SelectedItem"); searchValue = parameters.GetValue("SearchValue"); //OrderInfo = o; RequestData(); } public async void RequestData() { try { orderDetails = SqlSugarHelper.Db.Queryable() .InnerJoin((od, oi) => oi.DmStatus == 0 && oi.HisDispFlag == 0 && oi.CancelFlag == 0 && od.OrderNo == oi.OrderNo) .InnerJoin(SqlSugarHelper.Db.Queryable().Where(cs => cs.DrawerType == 1).Where(cs => cs.MachineId.Equals(ConfigurationManager.AppSettings["machineId"] ?? "DM1")).GroupBy(cs => cs.DrugId), (od, oi, t) => od.DrugId == t.DrugId) .WhereIF(orderDate != null, (od, oi) => oi.OrderDate.ToString("yyyy-MM-dd") == orderDate) .WhereIF(!String.IsNullOrEmpty(searchValue) && selectedItem.Code.Equals("OrderNo"), (od, oi) => oi.OrderNo == searchValue) .WhereIF(!String.IsNullOrEmpty(searchValue) && selectedItem.Code.Equals("PatientId"), (od, oi) => oi.PatientId == searchValue) .WhereIF(!String.IsNullOrEmpty(ConfigurationManager.AppSettings["storage"]), (od, oi) => oi.Pharmacy == ConfigurationManager.AppSettings["storage"]) .Includes(od => od.DrugInfo) .ToList(); if (orderDetails == null || orderDetails.Count <= 0) { AlertMsg alertMsg = new AlertMsg { Message = "没有处方数据", Type = MsgType.ERROR }; _eventAggregator.GetEvent().Publish(alertMsg); return; } IEnumerable> groupOrderDetails = orderDetails.GroupBy(it => it.DrugId); List channelStocks = new List(); List msg = new List(); foreach (var orderGroup in groupOrderDetails) { int quantity = orderGroup.Sum(it => it.Quantity); foreach (var orderDetail in orderGroup) { List HasQChannels = SqlSugarHelper.Db.Queryable() .Includes(cs => cs.DrugInfo) .Where(cs => cs.Quantity > 0) .Where(cs => cs.DrawerType == 1) .Where(cs => cs.MachineId.Equals(ConfigurationManager.AppSettings["machineId"] ?? "DM3")) .WhereIF(!string.IsNullOrEmpty(orderDetail.SetEffDate), cs => cs.EffDate.Equals(orderDetail.SetEffDate)) .WhereIF(!string.IsNullOrEmpty(orderDetail.SetManuNo), cs => cs.ManuNo.Equals(orderDetail.SetManuNo)) .Where(cs => cs.DrugId == orderDetail.DrugId) .OrderBy(cs => cs.EffDate) .OrderBy(cs => cs.DrawerNo) .ToList(); int total = HasQChannels.Sum(it => it.Quantity); int TakeQ = quantity; // 说明数量足够 if (total >= TakeQ) { for (int j = 0; TakeQ > 0; j++) { ChannelStock stock = HasQChannels[j]; if (TakeQ > stock.Quantity) { stock.TakeQuantity = stock.Quantity; channelStocks.Add(stock); TakeQ -= stock.Quantity; orderDetail.DrawerNo += stock.DrawerNo + ","; orderDetail.ColNo += stock.ColNo + ","; orderDetail.SetManuNo += stock.ManuNo + ","; orderDetail.SetEffDate += stock.EffDate + ","; } else { stock.TakeQuantity = TakeQ; channelStocks.Add(stock); TakeQ = 0; orderDetail.DrawerNo += stock.DrawerNo + ","; orderDetail.ColNo += stock.ColNo + ","; orderDetail.SetManuNo += stock.ManuNo + ","; orderDetail.SetEffDate += stock.EffDate + ","; } } break; } else { msg.Add($"药品【{orderDetail.DrugInfo.DrugName}】库存不足，应取【{TakeQ}】库存【{total}】"); } } } if (msg.Count > 0) { RequestClose?.Invoke(new DialogResult(ButtonResult.Cancel)); //MessageBox.Show(string.Join("\n", msg)); DialogParameters dialogParameters = new DialogParameters(); dialogParameters.Add("msgInfo", msg); DialogServiceExtensions.ShowDialogHost(_dialogService, "ShowMessageDialog", dialogParameters, "RootDialog"); } else { channelStocks.Sort((a, b) => { if ((a.DrawerNo - b.DrawerNo) == 0) { return a.ColNo - b.ColNo; } return a.DrawerNo - b.DrawerNo; }); ChannelStocks = channelStocks; } } catch (Exception ex) { logger.Info($"处方取药异常：{ex.Message}"); } } public DelegateCommand OpenDrawer { get => new DelegateCommand(async () => { if (Status == 0) { enumerable = ChannelStocks.GroupBy(cs => cs.DrawerNo, cs => cs); enumerator = enumerable.GetEnumerator(); enumerator.MoveNext(); Status = 1; OpenOneByOne(); } }); } private void OpenOneByOne() { IGrouping grouping = enumerator.Current; int DrawerNo = grouping.Key; List channelStocks = grouping.ToList(); channelStocks.ForEach(it => it.process = 1); IEnumerable strDrugName = channelStocks.Select(cs => cs.DrugInfo.DrugName); string strNames = string.Empty; foreach (string name in strDrugName) { if (!strNames.Contains(name)) { strNames += name + ";"; } } int sumQuantity = channelStocks.Sum(cs => cs.TakeQuantity); _portUtil.SpeakAsync($"正在打开 {DrawerNo} 号抽屉,请取药 {strNames} ，数量共计 {sumQuantity}"); List singleChannels = channelStocks.FindAll(it => it.BoardType != 1); // 发送取药数量 singleChannels.ForEach(it => { try { _portUtil.TakeQuantity(DrawerNo, it.ColNo, it.TakeQuantity, it.Quantity - it.TakeQuantity); } catch (Exception ex) { AlertMsg alertMsg = new AlertMsg { Message = $"打开抽屉异常{ex.Message}", Type = MsgType.ERROR, }; _eventAggregator.GetEvent().Publish(alertMsg); } }); _portUtil.WindowName = "OrderTakeDrugWindow"; _portUtil.BoardType = singleChannels.Count > 0 ? singleChannels[0].BoardType : 1; _portUtil.ColNos = singleChannels.Select(it => it.ColNo).ToArray(); _portUtil.DrawerNo = DrawerNo; _portUtil.Start(); } private bool _isFinishClick = false; // 完成按钮 public DelegateCommand TakeFinish { get => new DelegateCommand(() => { if (!_isFinishClick) { _isFinishClick = true; if (orderDetails == null || orderDetails.Count <= 0) { AlertMsg alertMsg = new AlertMsg { Message = "没有处方数据", Type = MsgType.ERROR }; _eventAggregator.GetEvent().Publish(alertMsg); return; } IEnumerable> enumerableOrderDetails = orderDetails.GroupBy(it => it.OrderNo); var f = SqlSugarHelper.Db.UseTran(() => { for (int i = 0; i < ChannelStocks.Count; i++) { ChannelStock it = ChannelStocks[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(); } foreach (var orderGroup in enumerableOrderDetails) { int iQuantity = 0; foreach (var orderDetail in orderGroup) { OrderInfo orderInfo = SqlSugarHelper.Db.Queryable().Where(oi => oi.OrderNo == orderDetail.OrderNo).First(); SqlSugarHelper.Db.Updateable(new OrderInfo() { DmStatus = 1, OrderNo = orderDetail.OrderNo }).UpdateColumns(it => new { it.DmStatus }).WhereColumns(it => new { it.OrderNo }).ExecuteCommand(); SqlSugarHelper.Db.Insertable(new OrderFinish() { OrderNo = orderDetail.OrderNo, PatientId = orderDetail.PatientId, Pharmacy = orderInfo.Pharmacy, State = 1, Operator = HomeWindowViewModel.Operator?.Nickname, }); //查询药品对应库存表的库位及批次、效期信息 List stockList= ChannelStocks.Where(cs => cs.DrugId == orderDetail.DrugId).OrderBy(cs=>cs.EffDate).ToList(); int iOrderDetailQuantity = -1; string manuNo = string.Empty; string effDate = string.Empty; int drawerNo = 0; int colNo = 0; if (stockList.Count> 1) { iOrderDetailQuantity = orderDetail.Quantity; for (int i = 0; i < stockList.Count; i++) { if (iOrderDetailQuantity>0&&stockList[i].Quantity- iOrderDetailQuantity > 0) { stockList[i].Quantity = stockList[i].Quantity - iOrderDetailQuantity; break; } else { iOrderDetailQuantity = iOrderDetailQuantity - stockList[i].Quantity; stockList[i].Quantity = 0; if(iOrderDetailQuantity==0) { manuNo = stockList[i].ManuNo; effDate = stockList[i].EffDate; drawerNo = stockList[i].DrawerNo; colNo= stockList[i].ColNo; break; } } } } ChannelStock cs = null; if (iOrderDetailQuantity==0) { cs = ChannelStocks.Where(cs => cs.DrugId == orderDetail.DrugId && cs.ManuNo == manuNo&&cs.EffDate==effDate&&cs.DrawerNo==drawerNo&&cs.ColNo==colNo).OrderBy(cs => cs.EffDate).FirstOrDefault(); } else { cs = ChannelStocks.Where(cs => cs.DrugId == orderDetail.DrugId && cs.Quantity > 0).OrderBy(cs => cs.EffDate).FirstOrDefault(); } if (cs != null) { SqlSugarHelper.Db.Insertable(new MachineRecord() { MachineId = ConfigurationManager.AppSettings["machineId"].ToString(), DrawerNo = cs.DrawerNo, ColNo = cs.ColNo, DrugId = cs.DrugId, ManuNo = cs.ManuNo, EffDate = !String.IsNullOrEmpty(cs.EffDate) ? DateTime.ParseExact(cs.EffDate, "yyyy-MM-dd", System.Globalization.CultureInfo.CurrentCulture) : null, Operator = HomeWindowViewModel.Operator?.Id, Reviewer = HomeWindowViewModel.Reviewer?.Id, OperationTime = DateTime.Now, Quantity = orderDetail.Quantity, Type = 2, InvoiceId = orderDetail.OrderNo //, StockQuantity = nowChannels.Sum(it => it.Quantity) }).ExecuteCommand(); } //保存账册 int iInsertResult = SqlSugarHelper.Db.Insertable(new AccountBookG2() { DrugId = Convert.ToInt32(orderDetail.DrugId), Type = 2, Department = orderInfo.DeptName, OrderNo = orderDetail.OrderNo, ManuNo = cs.ManuNo, EffDate = cs.EffDate, OutQuantity = orderDetail.Quantity, UserId1 = HomeWindowViewModel.Operator?.Id, UserId2 = HomeWindowViewModel.Reviewer?.Id, MachineId = ConfigurationManager.AppSettings["machineId"].ToString(), CreateDate = DateTime.Now.ToString("yyyy-MM-dd"), CreateTime = DateTime.Now, InvoiceNo = orderDetail.OrderNo }).ExecuteCommand(); //修改凌晨生成的日结存与总结存数据 AccountBookG2 accountBookG2Day = SqlSugarHelper.Db.Queryable() .Where(ab => ab.MachineId.Equals(ConfigurationManager.AppSettings["machineId"].ToString())) .Where(ab => ab.Type == 3) .Where(ab => ab.DrugId == Convert.ToInt32(orderDetail.DrugId)) .Where(ab => ab.ManuNo == cs.ManuNo) .Where(ab => ab.CreateDate == DateTime.Now.ToString("yyyy-MM-dd")).First(); if (accountBookG2Day != null) { accountBookG2Day.ManuStock = accountBookG2Day.ManuStock - orderDetail.Quantity; SqlSugarHelper.Db.Updateable(accountBookG2Day).ExecuteCommand(); } else { //生成日结存时可能没有该库位的绑定信息，需要写入日结存 int iDayResult = SqlSugarHelper.Db.Insertable(new AccountBookG2() { DrugId = Convert.ToInt32(orderDetail.DrugId), Type = 3, ManuNo = cs.ManuNo, EffDate = cs.EffDate, YQuantity = 0, ManuStock = orderDetail.Quantity, TotalStock = orderDetail.Quantity, UserId1 = HomeWindowViewModel.Operator?.Id, UserId2 = HomeWindowViewModel.Reviewer?.Id, MachineId = ConfigurationManager.AppSettings["machineId"].ToString(), CreateDate = DateTime.Now.ToString("yyyy-MM-dd"), InvoiceNo = "日结存" }).ExecuteCommand(); if (iDayResult <= 0) { logger.Info($"未写入日结存数据{orderDetail.DrugId}-{cs.ManuNo}-{cs.EffDate}-{cs.Quantity}"); } } //修改凌晨生成的日结存与总结存数据 AccountBookG2 accountBookG2Total = SqlSugarHelper.Db.Queryable() .Where(ab => ab.MachineId.Equals(ConfigurationManager.AppSettings["machineId"].ToString())) .Where(ab => ab.Type == 4) .Where(ab => ab.DrugId == Convert.ToInt32(orderDetail.DrugId)) .Where(ab => ab.CreateDate == DateTime.Now.ToString("yyyy-MM-dd")).First(); if (accountBookG2Total != null) { accountBookG2Total.TotalStock = accountBookG2Total.TotalStock - orderDetail.Quantity; SqlSugarHelper.Db.Updateable(accountBookG2Total).ExecuteCommand(); } else { //生成总结存时可能没有该库位的绑定信息，需要写入总结存 int iTotalResult = SqlSugarHelper.Db.Insertable(new AccountBookG2() { DrugId = Convert.ToInt32(orderDetail.DrugId), Type = 4, YQuantity = 0, ManuStock = orderDetail.Quantity, TotalStock = orderDetail.Quantity, UserId1 = HomeWindowViewModel.Operator?.Id, UserId2 = HomeWindowViewModel.Reviewer?.Id, MachineId = ConfigurationManager.AppSettings["machineId"].ToString(), CreateDate = DateTime.Now.ToString("yyyy-MM-dd"), InvoiceNo = "总结存" }).ExecuteCommand(); if (iTotalResult <= 0) { logger.Info($"未写入总结存数据{orderDetail.DrugId}-{orderDetail.Quantity}"); } } } } return true; }); if (f.Data) { // 更新屏显库存 List singleChannels = ChannelStocks.FindAll(it => it.BoardType == 5); if ((singleChannels.Count > 0 ? singleChannels[0].BoardType : 1) == 5) { singleChannels.ForEach(it => { _portUtil.WriteQuantity(it.DrawerNo, it.ColNo, it.Quantity - it.TakeQuantity); }); } 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; //RequestClose?.Invoke(new DialogResult(ButtonResult.Cancel)); RequestClose?.Invoke(new DialogResult(ButtonResult.OK)); } else { _isFinishClick = false; AlertMsg alertMsg = new AlertMsg { Message = "正在操作，请稍后", Type = MsgType.ERROR }; _eventAggregator.GetEvent().Publish(alertMsg); } }); } public long CurrentTimeMillis() { return (long)(DateTime.UtcNow - Jan1st1970).TotalMilliseconds; } // 取消按钮 public DelegateCommand CancleTake { get => new DelegateCommand(() => { _portUtil.ResetData(); Status = 0; }); } public DelegateCommand BtnCloseCommand { get => new DelegateCommand(() => { if (Status != 0) { _portUtil.ResetData(); Status = 0; } //DialogParameters parameters = new DialogParameters(); //parameters.Add("",); // 关闭当前窗口 RequestClose?.Invoke(new DialogResult(ButtonResult.Cancel)); }); } public bool KeepAlive => false; } }