using LinqToDB; using log4net; using MasaBlazorApp3.DataAccess.Dao; using MasaBlazorApp3.Pojo; using MasaBlazorApp3.Pojo.Config; using Microsoft.Extensions.Options; using Mysqlx.Crud; using System; using System.Collections.Generic; using System.Data.Common; using System.Linq; using System.Text; using System.Threading.Tasks; namespace MasaBlazorApp3.DataAccess.Impl { public class ReportDataDao : IReportDataDao { private AppDataConnection _connection; private readonly SettingConfig _setting; private readonly ILog logger = LogManager.GetLogger(typeof(ReportDataDao)); public ReportDataDao(AppDataConnection connection, IOptions setting) { _connection = connection; _setting = setting.Value; } //获取库存导出数据 public async Task> GetStockExportData(string drugName) { try { List reportStockList = new List(); int pagedData = 0; string SQL = $@"SELECT cl.drug_id AS DrugId,di.`drug_name` AS DrugName,di.drug_type AS DrugType,di.drug_spec AS DrugSpec,di.manufactory AS Manufactory, di.pack_unit AS pack_unit,di.py_code AS PyCode,null AS Stocks,NULL AS Manus,db.baseQuantity AS BaseQuantity,CONCAT(cl.row_no,cl.col_no) as location, cl.manu_no as ManuNo,cl.eff_date as EffDate,cl.Quantity AS Quantity,cl.manu_no,cl.eff_date FROM channel_stock cl INNER JOIN drug_info di ON di.`drug_id` = cl.`drug_id` LEFT JOIN drug_base db ON db.drugid=di.drug_id and db.machine_id= '{_setting.machineId}' WHERE cl.`machine_id` = '{_setting.machineId}' AND cl.`drawer_type` = 1 "; if (!string.IsNullOrEmpty(drugName)) { SQL += $" and (di.drug_name like '%{drugName}%'|| di.py_code like '%{drugName}%'||di.drug_id like '%{drugName}%')"; } SQL += " ORDER BY cl.`drug_id`"; // 加载模板文件 //Report.LoadFromFile(new FileInfo(AppDomain.CurrentDomain.BaseDirectory) + "ReportTemp//" + "stock_template.grf"); var reportList = _connection.FromSql(SQL); if (reportList != null) { foreach (var report in reportList) { reportStockList.Add(report); } pagedData = await reportList.CountAsync(); } return new PageData() { TotalDesserts = pagedData, Desserts = reportStockList }; } catch (Exception ex) { logger.Info($"获取库存导出数据异常:{ex.Message}"); return null; } } //中部战区总医院麻醉药品、第一类精神药品进出专用账册 public async Task> GetAccountExportData(DateTime? startDate, DateTime? endDate, string drugName) { List accountList = new List(); int pagedData = 0; DateTime? p_startDate = startDate ?? Convert.ToDateTime("2010-1-1"); DateTime? p_endDate = endDate ?? DateTime.Now.AddDays(1); string SQL = $@"SELECT ab.`create_time` AS `OperationTime`,ab.manu_no AS ManuNo,ab.eff_date as EffDate, ab.add_quantity AS `inQuantity`, ab.out_quantity AS `outQuantity`,ab.manu_quantity as ManuQuantity,ab.total_quantity as StockQuantity, u1.`user_name` AS `operatorName`, u2.`user_name` AS `reviewerName`, ab.`drug_id` AS `drugId`,di.`drug_name` AS `drugName`,di.`drug_spec` AS `drugSpec`, di.`pack_unit` AS `BigUnit`, di.`dosage` AS `dosage`, di.`manufactory` AS `manufactory`, ab.`invoice_id` AS `invoiceId`, ab.department as department,'' as Remarks FROM account_book ab LEFT JOIN drug_info di ON ab.`drug_id` = di.`drug_id` LEFT JOIN user_list u1 ON ab.`operator` = u1.`id` LEFT JOIN user_list u2 ON ab.`reviewer` = u2.`id` WHERE ab.`machine_id` = '{_setting.machineId}' AND ab.type in(1,2,31) DATE_FORMAT(ab.`create_time`,'%Y-%m-%d') > '{p_startDate}' AND DATE_FORMAT(ab.`create_time`,'%Y-%m-%d') < '{p_endDate}'"; if (!string.IsNullOrEmpty(drugName)) { SQL += $" AND (di.drug_name like '%{drugName}%' or di.drug_id like '%{drugName}%' or di.py_code like '%{drugName}%')"; } SQL += " ORDER BY ab.`create_time`, ab.`drug_id`"; var reportList = _connection.FromSql(SQL); if (reportList != null) { foreach (var report in reportList) { accountList.Add(report); } pagedData = await reportList.CountAsync(); } return new PageData() { TotalDesserts = pagedData, Desserts = accountList }; } //手术室患者麻醉药品使用登记本 public async Task> GetOrderInfoData(DateTime? searchDate) { List accountList = new List(); int pagedData = 0; string SQL = $@"SELECT oi.charge_Date as portdate, od.drug_id as DrugId,1 as ShouShuJian,'' as ZhuMa,'' as FuMa,oi.patient_id as IDNumber,oi.p_name as PName,oi.disease as Diagnose, CONCAT(di.drug_name,' ',di.drug_spec) as DrugName,od.set_manu_No as ManuNo,od.use_dosage as UsageDosage,'' as CanYeLiang,'' as CanYeChuZhi,'' as UseUserName,'' as CheckUserName from order_info oi inner join order_detail od on oi.order_no=od.order_no inner join drug_info di on od.drug_id=di.drug_id WHERE DATE_FORMAT(oi.charge_Date,'%Y-%m-%d')='{searchDate?.ToString("yyyy-MM-dd")}' and oi.dm_status=2 and oi.cancel_flag=0 and oi.his_disp_flag=0 and di.pack_h=1"; var reportList = _connection.FromSql(SQL); if (reportList != null) { foreach (var report in reportList) { accountList.Add(report); } pagedData = await reportList.CountAsync(); } return new PageData() { TotalDesserts = pagedData, Desserts = accountList }; } //麻醉科毒麻药品请领登记表 public async Task> GetApplyInfoDate(DateTime searchDate) { List accountList = new List(); int pagedData = 0; string SQL = $@"SELECT Drawerno as BoxNum,Create_date AS applyinfo,userfirst,usersecond,drugid,doctor,manager from applyinfo ap inner join drug_info di on ap.drugid=di.drug_id WHERE machine_id='{_setting.boxMachineId}' and DATE_FORMAT(ap.Create_date,'%Y-%m-%d')='{searchDate.ToString("yyyy-MM-dd")}' "; var reportList = _connection.FromSql(SQL); if (reportList != null&& reportList.Count()>0) { foreach (var report in reportList) { accountList.Add(report); } pagedData = await reportList.CountAsync(); } return new PageData() { TotalDesserts = pagedData, Desserts = accountList }; } } }