maqiao
/
HKC_Blazor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
HKC_Blazor/MasaBlazorApp3/DataAccess/Impl/OrderInfoDao.cs

1034 lines
48 KiB
C#
Raw Normal View History

中部战区修改更新
2025-08-27 08:38:00 +08:00
using Google.Protobuf;
using LinqToDB;
添加项目文件。
2025-04-18 11:01:56 +08:00
using LinqToDB.SqlQuery;
using log4net;
更新提交
2025-06-24 08:55:34 +08:00
using log4net.Util;
添加项目文件。
2025-04-18 11:01:56 +08:00
using MasaBlazorApp3.DataAccess.Dao;
using MasaBlazorApp3.Pages;
using MasaBlazorApp3.Pojo;
using MasaBlazorApp3.Pojo.Config;
using MasaBlazorApp3.Pojo.Vo;
using MasaBlazorApp3.Port;
using Microsoft.Extensions.Options;
using Mysqlx.Crud;
中部战区修改更新
2025-08-27 08:38:00 +08:00
using Radzen;
添加项目文件。
2025-04-18 11:01:56 +08:00
using Radzen.Blazor.Rendering;
using System;
using System.Collections;
using System.Collections.Generic;
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
using System.Data;
添加项目文件。
2025-04-18 11:01:56 +08:00
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace MasaBlazorApp3.DataAccess.Impl
{
public class OrderInfoDao : IOrderInfoDao
{
private readonly SettingConfig _setting;
private AppDataConnection _connection;
private GlobalStateService _globalStateService;
private readonly ILog logger = LogManager.GetLogger(typeof(OrderInfoDao));
private readonly PortUtil _portUtil;
中部战区修改更新
2025-08-27 08:38:00 +08:00
NotificationService _message;
public OrderInfoDao(AppDataConnection connection, IOptions<SettingConfig> setting, GlobalStateService globalStateService, PortUtil portUtil, NotificationService message)
添加项目文件。
2025-04-18 11:01:56 +08:00
{
_connection = connection;
_setting = setting.Value;
_globalStateService = globalStateService;
_portUtil = portUtil;
中部战区修改更新
2025-08-27 08:38:00 +08:00
_message = message;
添加项目文件。
2025-04-18 11:01:56 +08:00
}
public async Task<PageData<OrderInfo>> GetAllOrderInfo(string OrderrNo, DateTime OrderDate, int? take, int? skip)
{
修改提交
2025-08-30 08:54:40 +08:00
添加项目文件。
2025-04-18 11:01:56 +08:00
//var query = _connection.OrderInfo.AsQueryable();
//query.InnerJoin<OrderDetail>((oi, od) => oi.OrderNo == od.OrderNo);
var query2 = from od in _connection.OrderDetail
from cl in _connection.ChannelStock.Where(c => c.MachineId == _setting.machineId).InnerJoin(c => c.DrugId == od.DrugId)
group od by od.OrderNo into temp
select new { temp.Key };
var query = from oi in _connection.OrderInfo
from od in query2.InnerJoin(od => od.Key == oi.OrderNo)
select oi;
if (!String.IsNullOrEmpty(OrderrNo))
{
query = query.Where(oi => oi.OrderNo.Equals(OrderrNo));
}
更新提交
2025-06-24 08:55:34 +08:00
if (OrderDate != null && OrderDate != DateTime.MinValue)
添加项目文件。
2025-04-18 11:01:56 +08:00
{
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
query = query.Where(oi => oi.ChargeDate.Date.Equals(OrderDate.Date));
添加项目文件。
2025-04-18 11:01:56 +08:00
}
query = query.Where(oi => oi.Status == 0);
query = query.Where(oi => oi.HisDispFlag == 0);
query = query.Where(oi => oi.CancelFlag == 0);
int pagedData = await query.CountAsync();
List<OrderInfo> list = await query
更新提交
2025-06-27 09:54:42 +08:00
//.LoadWith(oi => oi.Detail)
//.LoadWith(oi => oi.Detail.Drug)
添加项目文件。
2025-04-18 11:01:56 +08:00
.OrderBy((oi) => oi.RecvDate)
.ThenBy((oi => oi.OrderNo))
.Skip((int)skip)
.Take((int)take)
.ToListAsync();
return new PageData<OrderInfo>()
{
TotalDesserts = pagedData,
Desserts = list
};
}
public async Task<List<OrderDetail>> getDetailByOrderNo(string OrderrNo)
{
var query2 = from cl in _connection.ChannelStock
where cl.MachineId == _setting.machineId
group cl by cl.DrugId into temp
select new { temp.Key };
;
var query = from od in _connection.OrderDetail.Where(od => od.OrderNo == OrderrNo)
from cl in query2.InnerJoin(c => c.Key == od.DrugId)
orderby od.DrugId
select od;
query = query.LoadWith(od => od.Drug);
return await query.ToListAsync();
}
public async Task<List<ChannelStock>> GetChannelStockByDrugId(string DrugId, String ManuNo, int quantity = 0)
{
var query = _connection.ChannelStock.AsQueryable();
query = query.Where(cs => cs.MachineId.Equals(_setting.machineId)).Where(cs => cs.DrawerType == 1)
.Where(cs => cs.Quantity > 0)
.Where(cs => cs.DrugId.Equals(DrugId));
if (quantity > 0)
{
if (!String.IsNullOrEmpty(ManuNo))
{
query = query.Where(cs => cs.ManuNo.Equals(ManuNo));
}
更新提交
2025-06-24 08:55:34 +08:00
}
else
添加项目文件。
2025-04-18 11:01:56 +08:00
{
if (!String.IsNullOrEmpty(ManuNo))
{
query = query.Where(cs => cs.ManuNo.Equals(ManuNo) || cs.Quantity == 0);
}
}
更新提交
2025-06-24 08:55:34 +08:00
添加项目文件。
2025-04-18 11:01:56 +08:00
return await query.OrderBy((cs) => cs.EffDate)
.ThenBy((cs) => cs.DrawerNo)
.ThenBy((cs) => cs.ColNo)
.ToListAsync();
}
public async Task<List<OrderTakeVo>> getTakeInfoByOrderNo(string OrderrNo)
{
List<OrderTakeVo> tempData = new();
List<OrderTakeVo> tempData2 = new();
List<OrderDetail> details = await this.getDetailByOrderNo(OrderrNo);
var flag = true;
for (var i = 0; i < details.Count; i++)
{
//List<IDictionary<string, object>> tempData = new();
OrderDetail detail = details[i];
// 当前detail取药数量
var Quantity = detail.Quantity;
List<ChannelStock> stockList = await this.GetChannelStockByDrugId(detail.DrugId, detail.SetManuNo, Quantity);
// 当前药品的库存总量
var total = stockList.Sum(current => current.Quantity);
tempData2.Add(new OrderTakeVo()
{
Drug = detail.Drug,
OrderDetail = detail,
StockQuantity = total,
Quantity = Quantity
});
if (flag)
{
// 盘点库存是否足够
if (total > Quantity)
{
for (var j = 0; Quantity > 0; j++)
{
ChannelStock stock = stockList[j];
if (Quantity > stock.Quantity)
{
// 取药数量大于库存
tempData.Add(new OrderTakeVo()
{
Drug = detail.Drug,
OrderDetail = detail,
ChannelStock = stock,
StockQuantity = total,
Quantity = stock.Quantity,
});
Quantity -= stock.Quantity;
}
else
{
//取药数量小于库存
tempData.Add(new OrderTakeVo()
{
Drug = detail.Drug,
OrderDetail = detail,
ChannelStock = stock,
StockQuantity = total,
Quantity = Quantity,
});
Quantity = 0;
}
}
}
else
{
// 库存不足
flag = false;
}
}
}
if (flag)
{
return tempData;
}
else
{
return tempData2;
}
}
public async Task<bool> OrderTakeFinish(List<OrderTakeVo> datas)
{
try
{
_connection.BeginTransaction();
var flag = true;
// 更新处方状态
更新提交
2025-06-24 08:55:34 +08:00
int r1 = _connection.OrderInfo.Where(oi => oi.OrderNo == datas.First().OrderDetail.OrderNo)
添加项目文件。
2025-04-18 11:01:56 +08:00
.Set(oi => oi.Status, 1)
.Update();
if (!(r1 > 0))
{
flag = false;
logger.Error("处方取药完成更新处方状态失败");
_connection.RollbackTransaction();
return flag;
}
for (var i = 0; i < datas.Count; i++)
{
var orderTakeVo = datas[i];
首次提交，整体修改
2025-05-20 11:17:07 +08:00
var EffDate = orderTakeVo.ChannelStock.EffDate;
if (!DateTime.TryParse(orderTakeVo.ChannelStock.EffDate, out DateTime dEffDate))
{
//效期转换出错
if (orderTakeVo.ChannelStock.EffDate != null)
{
string[] idate = orderTakeVo.ChannelStock.EffDate.Split('/');
foreach (string iS in idate)
{
if (!string.IsNullOrEmpty(iS.Trim()))
{
switch (iS.Trim().Length)
{
case 4:
EffDate = iS.Trim();
break;
case 2:
EffDate += "-" + iS.Trim();
break;
case 1:
EffDate += "-0" + iS.Trim();
break;
}
}
}
}
}
else
{
EffDate = dEffDate.ToString("yyyy-MM-dd");
}
添加项目文件。
2025-04-18 11:01:56 +08:00
// 出库记录
int mid = _connection.InsertWithInt32Identity(new MachineRecord()
{
MachineId = _setting.machineId,
DrawerNo = orderTakeVo.ChannelStock.DrawerNo,
ColNo = orderTakeVo.ChannelStock.ColNo,
DrugId = orderTakeVo.ChannelStock.DrugId,
ManuNo = orderTakeVo.ChannelStock.ManuNo,
首次提交，整体修改
2025-05-20 11:17:07 +08:00
EffDate = !String.IsNullOrEmpty(EffDate) ? DateTime.ParseExact(EffDate, "yyyy-MM-dd", System.Globalization.CultureInfo.CurrentCulture) : null,
添加项目文件。
2025-04-18 11:01:56 +08:00
OperationTime = DateTime.Now,
Type = 2,
Quantity = orderTakeVo.GetQuantity,
Operator = _globalStateService.Operator.Id,
Reviewer = _globalStateService.Reviewer?.Id ?? _globalStateService.Operator.Id,
InvoiceId = orderTakeVo.OrderDetail.Id.ToString(),
});
// 更新库存
int r = _connection.ChannelStock.Where(cs => cs.Id == orderTakeVo.ChannelStock.Id)
.Set(cs => cs.Quantity, orderTakeVo.ChannelStock.Quantity - orderTakeVo.GetQuantity)
.Update();
// 获取更新完库存之后的药品库存
List<ChannelStock> list = await _connection.ChannelStock.AsQueryable()
.InnerJoin(
_connection.ChannelList.Where(cl => cl.MachineId.Equals(_setting.machineId)).Where(cl => cl.DrawerType == 1),
(cs, cl) => cs.ListId == cl.Id,
(cs, cl) => cs
)
.Where(cs => cs.DrugId.Equals(orderTakeVo.ChannelStock.DrugId))
.ToListAsync();
// 保存账册
int acid = _connection.InsertWithInt32Identity(new AccountBook()
{
MachineId = _setting.machineId,
DrugId = orderTakeVo.ChannelStock.DrugId,
ManuNo = orderTakeVo.ChannelStock.ManuNo,
首次提交，整体修改
2025-05-20 11:17:07 +08:00
EffDate = !String.IsNullOrEmpty(EffDate) ? DateTime.ParseExact(EffDate, "yyyy-MM-dd", System.Globalization.CultureInfo.CurrentCulture) : null,
添加项目文件。
2025-04-18 11:01:56 +08:00
OperationTime = DateTime.Now,
Type = 2,
OutQuantity = orderTakeVo.GetQuantity,
AddQuantity = 0,
Operator = _globalStateService.Operator.Id,
Reviewer = _globalStateService.Reviewer?.Id ?? _globalStateService.Operator.Id,
ManuStock = list.Where(it => it.ManuNo == orderTakeVo.ChannelStock.ManuNo).Sum(it => it.Quantity),
TotalStock = list.Sum(it => it.Quantity),
InvoiceId = orderTakeVo.OrderDetail.Id.ToString()
});
if (mid > 0 && r > 0 && acid > 0)
{
if (orderTakeVo.ChannelStock.BoardType.ToString().Contains("5"))
{
await _portUtil.WriteQuantityMethod(orderTakeVo.ChannelStock.Quantity - orderTakeVo.GetQuantity, orderTakeVo.ChannelStock.DrawerNo, orderTakeVo.ChannelStock.ColNo);
}
}
else
{
flag = false;
break;
}
}
if (flag)
{
_connection.CommitTransaction();
}
else
{
_connection.RollbackTransaction();
}
return flag;
}
catch (Exception ex)
{
logger.Error("处方取药完成保存数据库失败，错误：" + ex.Message);
_connection.RollbackTransaction();
return false;
}
}
public async Task<PageData<OrderInfo>> GetAllCanReturnOrderInfo(string OrderrNo, DateTime OrderDate, int? take, int? skip)
{
var query2 = from od in _connection.OrderDetail
from cl in _connection.ChannelStock.Where(c => c.MachineId == _setting.machineId).InnerJoin(c => c.DrugId == od.DrugId)
group od by od.OrderNo into temp
select new { temp.Key };
var query = from oi in _connection.OrderInfo
from od in query2.InnerJoin(od => od.Key == oi.OrderNo)
select oi;
if (!String.IsNullOrEmpty(OrderrNo))
{
query = query.Where(oi => oi.OrderNo.Equals(OrderrNo));
}
if (OrderDate != null && OrderDate != DateTime.MinValue)
{
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
query = query.Where(oi => oi.ChargeDate.Date.Equals(OrderDate.Date));
添加项目文件。
2025-04-18 11:01:56 +08:00
}
query = query.Where(oi => oi.Status == 1);
query = query.Where(oi => oi.CancelFlag == 1);
int pagedData = await query.CountAsync();
List<OrderInfo> list = await query
.OrderBy((oi) => oi.RecvDate)
.ThenBy((oi => oi.OrderNo))
.Skip((int)skip)
.Take((int)take)
.ToListAsync();
return new PageData<OrderInfo>()
{
TotalDesserts = pagedData,
Desserts = list
};
}
public async Task<List<MachineRecord>> GetMachineRecordByOrderNo(string OrderrNo)
{
var query = _connection.MachineRecord.AsQueryable();
query = query.InnerJoin(
_connection.OrderDetail.Where(od => od.OrderNo.Equals(OrderrNo)),
(mr, od) => mr.InvoiceId.Equals(od.Id),
(mr, od) => mr
)
.Where(md => md.Type == 2)
.LoadWith(md => md.Drug)
;
return await query.ToListAsync();
}
public async Task<List<OperationVo<MachineRecord>>> getReturnInfoByOrderNo(string OrderrNo)
{
List<OperationVo<MachineRecord>> tempData = new();
List<MachineRecord> details = await this.GetMachineRecordByOrderNo(OrderrNo);
for (var i = 0; i < details.Count; i++)
{
//List<IDictionary<string, object>> tempData = new();
MachineRecord detail = details[i];
List<ChannelStock> stockList = await this.GetChannelStockByDrugId(detail.DrugId, detail.ManuNo);
// 当前药品的库存总量
var total = stockList.Sum(current => current.Quantity);
// 当前detail出库数量
var Quantity = detail.Quantity;
stockList.First().AddQuantity = Quantity;
tempData.Add(new OperationVo<MachineRecord>()
{
Drug = detail.Drug,
data = detail,
StockQuantity = total,
Quantity = Quantity,
ChannelStocks = stockList,
});
}
return tempData;
}
public async Task<DrugManuNo> GetDrugManuNo(string drugId, string manuNo)
{
var query = _connection.DrugManuNo.AsQueryable();
return await query.Where(m => m.DrugId.Equals(drugId))
.Where(m => m.ManuNo.Equals(manuNo))
.FirstAsync();
}
public async Task<bool> OrderReturnFinish(List<OperationVo<MachineRecord>> datas, string OrderNo)
{
try
{
_connection.BeginTransaction();
var flag = true;
// 更新处方状态
int r1 = _connection.OrderInfo.Where(oi => oi.OrderNo == OrderNo)
.Set(oi => oi.Status, 0)
.Update();
if (!(r1 > 0))
{
flag = false;
logger.Error("处方取药完成更新处方状态失败");
_connection.RollbackTransaction();
return flag;
}
for (var i = 0; i < datas.Count; i++)
{
var operationVo = datas[i];
List<ChannelStock> stocks = operationVo.ChannelStocks.Where(cs => cs.ReturnQuantity > 0).ToList();
// 更新取出记录状态
var r2 = _connection.MachineRecord.Where(cs => cs.Id == operationVo.data.Id)
.Set(cs => cs.Status, 2)
.Set(cs => cs.ReturnQuantity1, operationVo.data.Quantity).Update();
更新提交
2025-06-24 08:55:34 +08:00
if (r2 > 0)
添加项目文件。
2025-04-18 11:01:56 +08:00
{
更新提交
2025-06-24 08:55:34 +08:00
}
else
添加项目文件。
2025-04-18 11:01:56 +08:00
{
flag = false;
break;
}
for (var j = 0; j < stocks.Count; j++)
{
var channelStock = stocks[j];
// 更新库存
var q = _connection.ChannelStock.Where(cs => cs.Id == channelStock.Id)
.Set(cs => cs.Quantity, channelStock.Quantity + channelStock.ReturnQuantity);
if (String.IsNullOrEmpty(channelStock.ManuNo) || (channelStock.Quantity == 0 && !channelStock.ManuNo.Equals(operationVo.data.ManuNo)))
{
DrugManuNo drugManuNo = await GetDrugManuNo(channelStock.DrugId, operationVo.data.ManuNo);
channelStock.Dmnguid = drugManuNo.Id;
channelStock.ManuNo = drugManuNo.ManuNo;
channelStock.EffDate = drugManuNo.EffDate.ToString();
q = q.Set(cs => cs.Dmnguid, drugManuNo.Id)
.Set(cs => cs.ManuNo, drugManuNo.ManuNo)
.Set(cs => cs.EffDate, drugManuNo.EffDate.ToString());
}
int r = q.Update();
// 退回记录
int mid = _connection.InsertWithInt32Identity(new MachineRecord()
{
MachineId = _setting.machineId,
DrawerNo = channelStock.DrawerNo,
ColNo = channelStock.ColNo,
DrugId = channelStock.DrugId,
ManuNo = channelStock.ManuNo,
EffDate = !String.IsNullOrEmpty(channelStock.EffDate) ? DateTime.ParseExact(channelStock.EffDate, "yyyy-MM-dd", System.Globalization.CultureInfo.CurrentCulture) : null,
OperationTime = DateTime.Now,
Type = 31,
Quantity = channelStock.ReturnQuantity,
Operator = _globalStateService.Operator.Id,
Reviewer = _globalStateService.Reviewer?.Id ?? _globalStateService.Operator.Id,
InvoiceId = operationVo.data.InvoiceId.ToString(),
GetId = operationVo.data.Id
});
更新提交
2025-06-24 08:55:34 +08:00
添加项目文件。
2025-04-18 11:01:56 +08:00
// 获取更新完库存之后的药品库存
List<ChannelStock> list = await _connection.ChannelStock.AsQueryable()
.InnerJoin(
_connection.ChannelList.Where(cl => cl.MachineId.Equals(_setting.machineId)).Where(cl => cl.DrawerType == 1),
(cs, cl) => cs.ListId == cl.Id,
(cs, cl) => cs
)
.Where(cs => cs.DrugId.Equals(channelStock.DrugId))
.ToListAsync();
// 保存账册
int acid = _connection.InsertWithInt32Identity(new AccountBook()
{
MachineId = _setting.machineId,
DrugId = channelStock.DrugId,
ManuNo = channelStock.ManuNo,
EffDate = !String.IsNullOrEmpty(channelStock.EffDate) ? DateTime.ParseExact(channelStock.EffDate, "yyyy-MM-dd", System.Globalization.CultureInfo.CurrentCulture) : null,
OperationTime = DateTime.Now,
Type = 2,
OutQuantity = channelStock.ReturnQuantity,
AddQuantity = 0,
Operator = _globalStateService.Operator.Id,
Reviewer = _globalStateService.Reviewer?.Id ?? _globalStateService.Operator.Id,
ManuStock = list.Where(it => it.ManuNo == channelStock.ManuNo).Sum(it => it.Quantity),
TotalStock = list.Sum(it => it.Quantity),
InvoiceId = operationVo.data.InvoiceId
});
if (mid > 0 && r > 0 && acid > 0)
{
更新提交
2025-06-24 08:55:34 +08:00
if (channelStock.BoardType.ToString().Contains("5"))
添加项目文件。
2025-04-18 11:01:56 +08:00
{
await _portUtil.WriteQuantityMethod(channelStock.Quantity - channelStock.ReturnQuantity, channelStock.DrawerNo, channelStock.ColNo);
}
}
else
{
flag = false;
break;
}
}
更新提交
2025-06-24 08:55:34 +08:00
添加项目文件。
2025-04-18 11:01:56 +08:00
}
if (flag)
{
_connection.CommitTransaction();
}
else
{
_connection.RollbackTransaction();
}
return flag;
}
catch (Exception ex)
{
logger.Error("处方取药完成保存数据库失败，错误：" + ex.Message);
_connection.RollbackTransaction();
return false;
}
}
更新提交
2025-06-24 08:55:34 +08:00
/// <summary>
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
/// 获取药盒中的用药信息
更新提交
2025-06-24 08:55:34 +08:00
/// </summary>
/// <param name="OrderrNo"></param>
/// <param name="OrderDate"></param>
/// <param name="take"></param>
/// <param name="skip"></param>
/// <returns></returns>
public async Task<PageData<OrderInfo>> GetAllOrderInfoByBox(int box, string OrderrNo, DateTime OrderDate, int? take, int? skip)
{
var query2 = from od in _connection.OrderDetail
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
from cl in _connection.ChannelStock.Where(c => c.MachineId == _setting.boxMachineId).InnerJoin(c => c.DrugId == od.DrugId)
更新提交
2025-06-24 08:55:34 +08:00
group od by od.OrderNo into temp
select new { temp.Key };
var query = from oi in _connection.OrderInfo
中部战区修改更新
2025-08-27 08:38:00 +08:00
from od in query2.InnerJoin(od => od.Key == oi.OrderNo)
where oi.Pharmacy == _setting.storage
更新提交
2025-06-24 08:55:34 +08:00
select oi;
if (!String.IsNullOrEmpty(OrderrNo))
{
query = query.Where(oi => oi.OrderNo.Equals(OrderrNo));
}
if (OrderDate != null && OrderDate != DateTime.MinValue)
{
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
query = query.Where(oi => oi.ChargeDate.Date.Equals(OrderDate.Date));
更新提交
2025-06-24 08:55:34 +08:00
}
query = query.Where(oi => oi.Status == 0);
query = query.Where(oi => oi.HisDispFlag == 0);
query = query.Where(oi => oi.CancelFlag == 0);
//query = query.Where(oi => oi.DoctorCode == box);
int pagedData = await query.CountAsync();
List<OrderInfo> list = await query
中部战区修改更新
2025-08-27 08:38:00 +08:00
.LoadWith(oi => oi.DetailInfo)
更新提交
2025-06-24 08:55:34 +08:00
.OrderBy((oi) => oi.RecvDate)
.ThenBy((oi => oi.OrderNo))
.Skip((int)skip)
.Take((int)take)
.ToListAsync();
if (list != null && list.Count > 0)
{
for (int i = 0; i < list.Count; i++)
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
//for (int j = 0; j < list[i].DetailList.Count; j++)
//{
if (list[i].DetailInfo != null && list[i].DetailInfo.Id > 0)
修改更新
2025-07-05 10:07:33 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
list[i].DetailInfo.Drug = await _connection.DrugInfo.AsQueryable().Where(d => d.DrugId == list[i].DetailInfo.DrugId).FirstOrDefaultAsync();
if (list[i].DetailInfo.Drug != null)
{
list[i].DetailInfo.Drug.Manus = await _connection.DrugManuNo.AsQueryable().Where(m => m.DrugId == list[i].DetailInfo.DrugId).ToListAsync();
}
修改更新
2025-07-05 10:07:33 +08:00
}
中部战区修改更新
2025-08-27 08:38:00 +08:00
//}
更新提交
2025-06-24 08:55:34 +08:00
}
}
修改更新
2025-07-05 10:07:33 +08:00
//var query2 = from od in _connection.OrderDetail
// from cl in _connection.ChannelStock.Where(c => c.MachineId == _setting.machineId).InnerJoin(c => c.DrugId == od.DrugId)
// group od by od.OrderNo into temp
// select new { temp.Key };
//var query = from oi in _connection.OrderInfo
// from od in query2.InnerJoin(od => od.Key == oi.OrderNo)
// select oi;
//if (!String.IsNullOrEmpty(OrderrNo))
//{
// query = query.Where(oi => oi.OrderNo.Equals(OrderrNo));
//}
//if (OrderDate != null && OrderDate != DateTime.MinValue)
//{
// query = query.Where(oi => oi.OrderDate.Date.Equals(OrderDate.Date));
//}
//query = query.Where(oi => oi.Status == 0);
//query = query.Where(oi => oi.HisDispFlag == 0);
//query = query.Where(oi => oi.CancelFlag == 0);
////query = query.Where(oi => oi.DoctorCode == box);
//int pagedData = await query.CountAsync();
//List<OrderInfo> list = await query
// .LoadWith(oi => oi.Detail)
// .LoadWith(oi => oi.Detail.Drug)
// .OrderBy((oi) => oi.RecvDate)
// .ThenBy((oi => oi.OrderNo))
// .Skip((int)skip)
// .Take((int)take)
// .ToListAsync();
//if (list != null && list.Count > 0)
//{
// for (int i = 0; i < list.Count; i++)
// {
// //list[i].Detail = await _connection.OrderDetail.AsQueryable()
// // .Where(od => od.OrderNo == list[i].OrderNo)
// // .LoadWith(od => od.Drug)
// // .ToListAsync();
// }
//}
更新提交
2025-06-24 08:55:34 +08:00
return new PageData<OrderInfo>()
{
TotalDesserts = pagedData,
Desserts = list
};
}
/// <summary>
中部战区修改更新
2025-08-27 08:38:00 +08:00
/// 获取待处理处方中的麻醉师
/// </summary>
/// <param name="OrderrNo"></param>
/// <param name="OrderDate"></param>
/// <param name="take"></param>
/// <param name="skip"></param>
/// <returns></returns>
public async Task<PageData<OrderInfo>> GetAllOrderInfo(string Name, string OrderrNo, DateTime? OrderDate, int? take, int? skip)
{
var query2 = from od in _connection.OrderDetail
from cl in _connection.ChannelStock.Where(c => c.MachineId == _setting.boxMachineId).InnerJoin(c => c.DrugId == od.DrugId)
group od by od.OrderNo into temp
select new { temp.Key };
var query = from oi in _connection.OrderInfo
from od in query2.InnerJoin(od => od.Key == oi.OrderNo)
where oi.Pharmacy == _setting.storage
select oi;
if (!string.IsNullOrEmpty(Name))
{
query = query.Where(oi => oi.anaesthetistName == Name);
}
if (!String.IsNullOrEmpty(OrderrNo))
{
query = query.Where(oi => oi.OrderNo.Equals(OrderrNo));
}
if (OrderDate != null && OrderDate != DateTime.MinValue)
{
query = query.Where(oi => oi.ChargeDate.Date.Equals(((DateTime)OrderDate).Date));
}
query = query.Where(oi => oi.Status == 0);
query = query.Where(oi => oi.HisDispFlag == 0);
query = query.Where(oi => oi.CancelFlag == 0);
int pagedData = await query.CountAsync();
List<OrderInfo> list = await query
.LoadWith(oi => oi.DetailInfo)
.OrderBy((oi) => oi.RecvDate)
.ThenBy((oi => oi.OrderNo))
//.Skip((int)skip)
//.Take((int)take)
.ToListAsync();
if (list != null && list.Count > 0)
{
for (int i = 0; i < list.Count; i++)
{
if (list[i].DetailInfo != null && list[i].DetailInfo.Id > 0)
{
list[i].DetailInfo.Drug = await _connection.DrugInfo.AsQueryable().Where(d => d.DrugId == list[i].DetailInfo.DrugId).FirstOrDefaultAsync();
if (list[i].DetailInfo.Drug != null)
{
list[i].DetailInfo.Drug.Manus = await _connection.DrugManuNo.AsQueryable().Where(m => m.DrugId == list[i].DetailInfo.DrugId).ToListAsync();
}
}
}
}
return new PageData<OrderInfo>()
{
TotalDesserts = pagedData,
Desserts = list
};
}
/// <summary>
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
/// 获取所有药盒号
更新提交
2025-06-24 08:55:34 +08:00
/// </summary>
/// <param name="machineId"></param>
/// <returns></returns>
修改提交
2025-08-30 08:54:40 +08:00
public async Task<List<ChannelStock>> GetDrawerNum(string machineId)
{
List<ChannelStock> stockList = _connection.ChannelStock
.Where(cs => cs.MachineId == machineId)
.GroupBy(cs => new { cs.DrawerNo, cs.ColNo })
.Select(g => new ChannelStock
{
DrawerNo = g.Key.DrawerNo,
ColNo = g.Key.ColNo,
})
.ToList();
return stockList;
}
/// <summary>
/// 获取指定药盒号
/// </summary>
/// <param name="machineId"></param>
/// <returns></returns>
public async Task<List<BoxModel>> GetDrawerNumByOperationNum(string machineId,List<int> operationNum)
更新提交
2025-06-24 08:55:34 +08:00
{
修改提交
2025-08-30 08:54:40 +08:00
List<BoxModel> boxModelList = new List<BoxModel>();
boxModelList =await _connection.ChannelStock
.Where(cs => cs.MachineId == machineId&& operationNum.Contains(cs.DrawerNo))
.Select(cs => new BoxModel { BoxName = cs.DrawerNo.ToString(), BoxNo = Convert.ToInt32(cs.ColNo) }).ToListAsync();
return boxModelList;
更新提交
2025-06-24 08:55:34 +08:00
}
//核对处方
修改更新
2025-07-05 10:07:33 +08:00
public async Task<bool> CheckOrderInfo(IList<OrderInfo> selectedOrderInfos, int DrawerNo)
更新提交
2025-06-24 08:55:34 +08:00
{
try
{
_connection.BeginTransaction();
bool bFlag = true;
logger.Info($"管理员{_globalStateService.Operator.NickName}开始确认手麻单");
string empChannelStock = string.Empty;
for (int i = 0; i < selectedOrderInfos.Count; i++)
{
OrderInfo oi = selectedOrderInfos[i];
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
修改更新
2025-07-05 10:07:33 +08:00
int drawerNo = DrawerNo;
中部战区修改更新
2025-08-27 08:38:00 +08:00
if (oi.DetailInfo != null && oi.DetailInfo.Id > 0)
更新提交
2025-06-24 08:55:34 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
//ChannelStock? cs = _connection.ChannelStock.AsQueryable()
// .Where(cs => cs.DrugId == oi.DetailList[j].DrugId
// // && cs.ManuNo == oi.DetailList[j].SetManuNo
// // && cs.EffDate == oi._OrderDetail.SetEffDate
// && cs.MachineId.Equals(_setting.boxMachineId)
// && cs.DrawerNo == drawerNo
// && cs.Quantity >= oi.DetailList[j].Quantity).FirstOrDefault();
List<ChannelStock> cs = _connection.ChannelStock.AsQueryable()
.Where(cs => cs.DrugId == oi.DetailInfo.DrugId
&& cs.ManuNo == oi.DetailInfo.drugManuNo.ManuNo
&& cs.EffDate == ((DateTime)oi.DetailInfo.drugManuNo.EffDate).ToString("yyyy-MM-dd")
&& cs.MachineId.Equals(_setting.boxMachineId)
&& cs.DrawerNo == drawerNo).OrderBy(cs => cs.EffDate).ToList();
if (cs.Count <= 0)
{
logger.Info($"处方{oi.OrderNo}中药品{oi.DetailInfo.DrugId}在{drawerNo}号药盒无库存");
empChannelStock += $"处方{oi.OrderNo}中药品{oi.DetailInfo.DrugId}在{drawerNo}号药盒无库存 ";
continue;
}
int csQuantity = cs.Sum(cs => cs.Quantity);
if (csQuantity < oi.DetailInfo.Quantity)
更新提交
2025-06-24 08:55:34 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
logger.Info($"处方{oi.OrderNo}中药品{oi.DetailInfo.DrugId}在{drawerNo}号库存不足，需要核对数{oi.DetailInfo.Quantity}，库存总数{csQuantity}");
empChannelStock += $"处方{oi.OrderNo}中药品{oi.DetailInfo.DrugId}在{drawerNo}号库存不足，需要核对数{oi.DetailInfo.Quantity}，库存总数{csQuantity} ";
continue;
}
//更新处方状态
if (oi.Status == 0)
{
int iUpdate = _connection.OrderInfo.Where(o => o.OrderNo == oi.OrderNo).Set(o => o.Status, 2).Update();
_connection.Insert(new OrderFinish()
更新提交
2025-06-24 08:55:34 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
OrderNo = oi.OrderNo,
PatientId = oi.PatientId,
Pharmacy = oi.Pharmacy,
State = 1,
//WinNo = DrawerNo + 1 + "号手术间",
Operator = _globalStateService.Operator.NickName,
});
}
int Break = 0;
for (int k = 0; (k < cs.Count && Break == 0); k++)
{
int oldQuantity = cs[k].Quantity;
int useQuantity = 0; //实际使用数量
if (cs[k].Quantity >= oi.DetailInfo.Quantity)
{
cs[k].Quantity = cs[k].Quantity - oi.DetailInfo.Quantity;
Break = 1;//药品够取跳出循环
useQuantity = oi.DetailInfo.Quantity;
更新提交
2025-06-24 08:55:34 +08:00
}
中部战区修改更新
2025-08-27 08:38:00 +08:00
else
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
oi.DetailInfo.Quantity = oi.DetailInfo.Quantity - cs[k].Quantity;
useQuantity = cs[k].Quantity;
cs[k].Quantity = 0;
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
}
中部战区修改更新
2025-08-27 08:38:00 +08:00
//cs.NeedNum = cs.NeedNum > 0 ? cs.NeedNum + oi._OrderDetail.Quantity : oi._OrderDetail.Quantity;
logger.Info($"更新药盒{cs[k].DrawerNo}药品{cs[k].DrugId}批次{cs[k].ManuNo}库存为{oldQuantity}，处方用药数量为{oi.DetailInfo.Quantity}");
// 更新数据 库存信息
_connection.Update(cs[k]);
//更新ChannelList对应的总库存
ChannelList? channelList = _connection.ChannelList.AsQueryable().Where(cl => cl.MachineId.Equals(cs[k].MachineId) && cl.Id.Equals(cs[k].ListId) && cl.DrawerNo.Equals(cs[k].DrawerNo)).FirstOrDefault();
if (channelList != null)
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
channelList.TotalQuantity = channelList.TotalQuantity - useQuantity;// oi.DetailList[j].Quantity;
_connection.Update(channelList);
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
}
中部战区修改更新
2025-08-27 08:38:00 +08:00
// 获取更新完库存后的药品库存
List<ChannelStock> nowChannels = _connection.ChannelStock.AsQueryable()
.Where(it => it.MachineId.Equals(cs[k].MachineId) || it.MachineId.Equals(_setting.machineId))
.Where(it => it.DrugId.Equals(cs[k].DrugId))
.Where(it => it.ManuNo.Equals(cs[k].ManuNo))
.Where(it => it.DrawerType == 1)
.ToList();
_connection.Insert(new MachineRecord()
更新提交
2025-06-24 08:55:34 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
MachineId = _setting.machineId,
DrawerNo = cs[k].DrawerNo,
ColNo = cs[k].ColNo,
DrugId = cs[k].DrugId,
ManuNo = cs[k].ManuNo,
EffDate = !String.IsNullOrEmpty(cs[k].EffDate) ? DateTime.ParseExact(cs[k].EffDate, "yyyy-MM-dd", System.Globalization.CultureInfo.CurrentCulture) : null,
Operator = _globalStateService.Operator?.Id,
Reviewer = _globalStateService.Reviewer?.Id,
OperationTime = DateTime.Now,
Quantity = useQuantity,// oi.DetailList[j].Quantity,
Type = 2,
InvoiceId = oi.OrderNo
//, StockQuantity = nowChannels.Sum(it => it.Quantity)
});
//查询上一条账册中的空瓶数
AccountBookG2? accountBookEmpty = _connection.AccountBookG2.AsQueryable()
.Where(ab => ab.MachineId.Equals(_setting.machineId))
.Where(ab => ab.Type == 1 || ab.Type == 2)
.Where(ab => ab.DrugId == oi.DetailInfo.DrugId)
.Where(ab => ab.ManuNo == cs[k].ManuNo).OrderByDescending(ab => ab.Id).FirstOrDefault();
//保存账册
int iInsertResult = _connection.Insert(new AccountBookG2()
{
DrugId = oi.DetailInfo.DrugId,
Type = 2,
Department = oi.DeptName,
OrderNo = oi.OrderNo,
ManuNo = cs[k].ManuNo,
EffDate = cs[k].EffDate,
OutQuantity = useQuantity,// oi.DetailList[j].Quantity,
UserId1 = _globalStateService.Operator?.Id,
UserId2 = _globalStateService.Reviewer?.Id,
MachineId = _setting.machineId,
CreateDate = DateTime.Now.ToString("yyyy-MM-dd"),
CreateTime = DateTime.Now,
InvoiceNo = oi.OrderNo,
ManuStock = nowChannels.Sum(it => it.Quantity),
TotalStock = (accountBookEmpty != null ? (accountBookEmpty.TotalStock > 0 ? accountBookEmpty.TotalStock : 0) : 0) + oi.DetailInfo.Quantity,
ShoushuJian = drawerNo.ToString()
});
//修改凌晨生成的日结存与总结存数据
AccountBookG2? accountBookG2Day = _connection.AccountBookG2.AsQueryable()
.Where(ab => ab.MachineId.Equals(_setting.machineId))
.Where(ab => ab.Type == 3)
.Where(ab => ab.DrugId == oi.DetailInfo.DrugId)
.Where(ab => ab.ManuNo == cs[k].ManuNo)
.Where(ab => ab.CreateDate == DateTime.Now.ToString("yyyy-MM-dd")).FirstOrDefault();
if (accountBookG2Day != null)
{
accountBookG2Day.ManuStock = accountBookG2Day.ManuStock - useQuantity;// oi.DetailList[j].Quantity;
_connection.Update(accountBookG2Day);
}
else
{
//生成日结存时可能没有该库位的绑定信息，需要写入日结存
int iDayResult = _connection.Insert(new AccountBookG2()
修改更新
2025-07-05 10:07:33 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
DrugId = oi.DetailInfo.DrugId,
Type = 3,
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
ManuNo = cs[k].ManuNo,
EffDate = cs[k].EffDate,
中部战区修改更新
2025-08-27 08:38:00 +08:00
YQuantity = 0,
ManuStock = useQuantity,// oi.DetailList[j].Quantity,
TotalStock = useQuantity,// oi.DetailList[j].Quantity,
修改更新
2025-07-05 10:07:33 +08:00
UserId1 = _globalStateService.Operator?.Id,
UserId2 = _globalStateService.Reviewer?.Id,
MachineId = _setting.machineId,
CreateDate = DateTime.Now.ToString("yyyy-MM-dd"),
中部战区修改更新
2025-08-27 08:38:00 +08:00
InvoiceNo = "日结存"
修改更新
2025-07-05 10:07:33 +08:00
});
中部战区修改更新
2025-08-27 08:38:00 +08:00
if (iDayResult <= 0)
修改更新
2025-07-05 10:07:33 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
logger.Info($"未写入日结存数据{oi.DetailInfo.DrugId}-{cs[k].ManuNo}-{cs[k].EffDate}-{useQuantity}");
empChannelStock += $"未写入日结存数据{oi.DetailInfo.DrugId}-{cs[k].ManuNo}-{cs[k].EffDate}-{useQuantity} ";
修改更新
2025-07-05 10:07:33 +08:00
}
中部战区修改更新
2025-08-27 08:38:00 +08:00
}
//修改凌晨生成的日结存与总结存数据
AccountBookG2? accountBookG2Total = _connection.AccountBookG2.AsQueryable()
.Where(ab => ab.MachineId.Equals(_setting.machineId))
.Where(ab => ab.Type == 4)
.Where(ab => ab.DrugId == oi.DetailInfo.DrugId)
.Where(ab => ab.CreateDate == DateTime.Now.ToString("yyyy-MM-dd")).FirstOrDefault();
if (accountBookG2Total != null)
{
accountBookG2Total.TotalStock = accountBookG2Total.TotalStock - useQuantity;// oi.DetailList[j].Quantity;
_connection.Update(accountBookG2Total);
}
else
{
//生成总结存时可能没有该库位的绑定信息，需要写入总结存
int iTotalResult = _connection.Insert(new AccountBookG2()
修改更新
2025-07-05 10:07:33 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
DrugId = oi.DetailInfo.DrugId,
Type = 4,
YQuantity = 0,
ManuStock = useQuantity,//oi.DetailList[j].Quantity,
TotalStock = useQuantity,// oi.DetailList[j].Quantity,
UserId1 = _globalStateService.Operator?.Id,
UserId2 = _globalStateService.Reviewer?.Id,
MachineId = _setting.machineId,
CreateDate = DateTime.Now.ToString("yyyy-MM-dd"),
InvoiceNo = "总结存"
});
if (iTotalResult <= 0)
修改更新
2025-07-05 10:07:33 +08:00
{
中部战区修改更新
2025-08-27 08:38:00 +08:00
logger.Info($"未写入总结存数据{oi.DetailInfo.DrugId}-{useQuantity}");
empChannelStock += $"未写入总结存数据{oi.DetailInfo.DrugId}-{useQuantity} ";
修改更新
2025-07-05 10:07:33 +08:00
}
更新提交
2025-06-24 08:55:34 +08:00
}
修改更新
2025-07-05 10:07:33 +08:00
}
中部战区修改更新
2025-08-27 08:38:00 +08:00
更新提交
2025-06-24 08:55:34 +08:00
}
}
logger.Info($"管理员{_globalStateService.Operator.NickName}结束确认手麻单");
中部战区修改更新
2025-08-27 08:38:00 +08:00
if(!string.IsNullOrEmpty(empChannelStock))
{
_message.Notify(
new NotificationMessage { Severity = NotificationSeverity.Error, Summary = "提示", Detail = $"有未核对处方：{empChannelStock}", Duration = 4000 }
);
}
更新提交
2025-06-24 08:55:34 +08:00
if (bFlag)
{
_connection.CommitTransaction();
return true;
}
中部战区项目提交修改
2025-08-21 18:25:23 +08:00
else
{
_connection.RollbackTransaction();
logger.Info($"管理员{_globalStateService.Operator.NickName}确认手麻单失败");
return false;
}
更新提交
2025-06-24 08:55:34 +08:00
}
catch (Exception ex)
{
_connection.RollbackTransaction();
logger.Info($"核对处方异常{ex.Message}");
return false;
}
}
添加项目文件。
2025-04-18 11:01:56 +08:00
}
}