本文的代码是博主自己写的一个Demo,用来记录EPPlues的{%label 简单使用 blue %}
读写高级版本的xlsx不要用NPOI, 建议使用EPPLUS
如果是网站生成数据格式,供用户下载,NPOI没有问题,如果是反复读写的场景,甚至还有用户修改这个excle文件的话,比如电脑端NPOI对这个文件读写,用户在手机端修改同一个文件,建议用EPPLUS
{%label 代码中所有的库文件在NuGet中都可以下载,这里不做演示 %},下面是代码:
using OfficeOpenXml;
using System;
using System.Data;
using System.Data.SqlClient;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
namespace 自动导出报表
{
public partial class Main : Form
{
//存放报表生成的路径:bin/Debug/Files
private string path = Environment.CurrentDirectory + "\\Files\\";
//日志
private static readonly NLog.Logger Logger = NLog.LogManager.GetCurrentClassLogger();
public Main()
{
InitializeComponent();
}
private void Main_Load(object sender, EventArgs e)
{
}
/// <summary>
/// 开始计时
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void button1_Click(object sender, EventArgs e)
{
//开始计时,每隔 86400000 毫秒(24小时)执行一次
this.AutomaticExport.Start();
//执行方法
Export();
}
/// <summary>
/// 停止计时器
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void button2_Click(object sender, EventArgs e)
{
//停止计时器
this.AutomaticExport.Stop();
}
/// <summary>
/// 查看按钮
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void button3_Click(object sender, EventArgs e)
{
//获取当前月
int Month = DateTime.Now.Month;
//获取昨天对应的年份
int Year = DateTime.Now.AddDays(-1).Year;
string yearPath = path + Year + "\\";
//获取本地存放的文件
string filePath = yearPath + $"{Month}月报表.xlsx";
if (File.Exists(filePath))
{
try
{
System.Diagnostics.Process.Start(filePath);
Logger.Trace($"查看报表:{Month}月,成功!");
}
catch (Exception ex)
{
Logger.Warn(ex.Message);
MessageBox.Show(ex.ToString());
}
}
else
{
Logger.Trace($"查看报表:暂无{Month}月的报表!");
MessageBox.Show($"暂无{Month}月的报表!");
}
}
private void AutomaticExport_Tick(object sender, EventArgs e)
{
//计时器调用方法
Export();
}
/// <summary>
/// 导出报表
/// </summary>
public void Export()
{
//获取昨天的日期,格式为:2021-12-12
string YesterDay = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
//获取昨天对应的年份(用于创建存放报表的文件夹)
int Year = DateTime.Now.AddDays(-1).Year;
//获取昨天对应的月份(用于创建每个月对应的报表)
int Month = DateTime.Now.AddDays(-1).Month;
//获取昨天的初始时间(用于SQL语句中当筛选条件)2021-12-12 00:00:00.000
string YesterDayBegin = YesterDay + " 00:00:00.000";
//获取昨天的结束时间(用于SQL语句中当筛选条件)2021-12-12 24:00:00.000
string YesterDayEnd = YesterDay + " 24:00:00.000";
//表示个人权限,非商用(不加上这一句会提示没有权限)
ExcelPackage.LicenseContext = LicenseContext.NonCommercial;
String sql = "select top 140000* from FlowRecords";
//参数化传值防止SQL注入(需要传递参数时使用)
//String sql = "select top 14000* from FlowRecords where Id = @Id";
/*SqlParameter[] pms = new SqlParameter[]
{
//@Id:对应上面sql语句的@Id,SqlDbType.Int设置这个参数的类型,4:设置参数的长度,Value:设置参数的值
new SqlParameter("@Id",SqlDbType.Int,4){ Value = 111},
};*/
DataTable db = SqlHelper.ExecuteDataTable(sql);
Logger.Trace($"共查询到{db.Rows.Count}条数据。");
string yearPath = path + Year + "\\";
//创建一个文件夹用来存放一年的报表
if (!Directory.Exists(path + Year))
{
Directory.CreateDirectory(path + Year);
}
string excelFilePath = yearPath + $@"{Month}月报表.xlsx";
if (!System.IO.File.Exists(excelFilePath))//不存在则创建
{
FileInfo newFile = new FileInfo(excelFilePath);
using (ExcelPackage package = new ExcelPackage(newFile))
{
//添加工作表
ExcelWorksheet worksheet = package.Workbook.Worksheets.Add($"{Month}月");
//添加标题
worksheet.Cells[1, 1].Value = "标题1";
worksheet.Cells[1, 2].Value = "标题2";
worksheet.Cells[1, 3].Value = "标题3";
worksheet.Cells[1, 4].Value = "标题4";
worksheet.Cells[1, 5].Value = "标题5";
worksheet.Cells[1, 6].Value = "标题6";
worksheet.Cells[1, 7].Value = "标题7";
worksheet.Cells[1, 8].Value = "标题8";
worksheet.Cells[1, 9].Value = "标题9";
worksheet.Cells[1, 10].Value = "标题10";
worksheet.Cells[1, 11].Value = "标题11";
worksheet.Cells[1, 12].Value = "标题12";
worksheet.Cells[1, 13].Value = "标题13";
worksheet.Cells[1, 14].Value = "标题14";
package.Save();
Logger.Trace($@"【{Month}月报表.xlsx】创建成功!");
}//using end
}//if end
if (System.IO.File.Exists(excelFilePath)) //如果文件存在则往下执行
{
FileInfo newFile = new FileInfo(excelFilePath);
using (ExcelPackage package = new ExcelPackage(newFile))
{
//获取工作表
ExcelWorksheet worksheet = package.Workbook.Worksheets[0];
//拿到最后一行,这里其实获取的是总行数,追加数据需要+1
int lastRow = worksheet.Dimension.End.Row;
for (int i = 1; i < db.Rows.Count + 1; i++)
{
worksheet.Cells[lastRow + i, 1].Value = db.Rows[i - 1]["Id"];
worksheet.Cells[lastRow + i, 2].Value = db.Rows[i - 1]["WorkOrderId"];
worksheet.Cells[lastRow + i, 3].Value = db.Rows[i - 1]["CreatedAt"];
worksheet.Cells[lastRow + i, 4].Value = db.Rows[i - 1]["UpdatedAt"];
worksheet.Cells[lastRow + i, 5].Value = db.Rows[i - 1]["MaterialId"];
worksheet.Cells[lastRow + i, 6].Value = db.Rows[i - 1]["Batch"];
worksheet.Cells[lastRow + i, 7].Value = db.Rows[i - 1]["QCStatus"];
worksheet.Cells[lastRow + i, 8].Value = db.Rows[i - 1]["Account"];
worksheet.Cells[lastRow + i, 9].Value = db.Rows[i - 1]["SO"];
worksheet.Cells[lastRow + i, 10].Value = db.Rows[i - 1]["SOLine"];
worksheet.Cells[lastRow + i, 11].Value = db.Rows[i - 1]["xNumber"];
worksheet.Cells[lastRow + i, 12].Value = db.Rows[i - 1]["Unit"];
worksheet.Cells[lastRow + i, 13].Value = db.Rows[i - 1]["RelatedParty"];
worksheet.Cells[lastRow + i, 14].Value = db.Rows[i - 1]["BusinessTypeId"];
}//for end
package.Save();
Logger.Trace($@"【{Month}月报表.xlsx】数据添加成功!");
}//using end
}//if end
}//Export end
}
}
SqlHelper 代码:
using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Collections;
using System.Data.SqlClient;
/// <summary>
/// 数据库的通用访问代码
/// 此类为抽象类,不允许实例化,在应用时直接调用即可
/// </summary>
public abstract class SqlHelper
{
// 获取数据库连接字符串,其属于静态变量且只读,项目中所有文档可以直接使用,但不能修改
public static readonly string ConnectionStringLocalTransaction = "数据库连接字段";
// 哈希表用来存储缓存的参数信息,哈希表可以存储任意类型的参数。
private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());
public static SqlTransaction BeginTransaction(string con)
{
SqlConnection connection = new SqlConnection(con);
connection.Open();
SqlTransaction tran = connection.BeginTransaction();
return tran;
}
/// <summary>
/// 执行一个不需要返回值的SqlCommand命令,通过指定专用的连接字符串。
/// 使用参数数组形式提供参数列表
/// </summary>
/// <remarks>
/// 使用示例:
/// int result = ExecuteNonQuery(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="connectionString"> 一个有效的数据库连接字符串 </param>
/// <param name="commandType"> SqlCommand命令类型 (存储过程, T-SQL语句, 等等。) </param>
/// <param name="commandText"> 存储过程的名字或者 T-SQL 语句 </param>
/// <param name="commandParameters"> 以数组形式提供SqlCommand命令中用到的参数列表 </param>
/// <returns> 返回一个数值表示此SqlCommand命令执行后影响的行数 </returns>
public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(connectionString))
{
int val = 0;
try
{
// 通过PrePareCommand方法将参数逐个加入到SqlCommand的参数集合中
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
val = cmd.ExecuteNonQuery();
// 清空SqlCommand中的参数列表
cmd.Parameters.Clear();
}
catch
{
val = 0;
}
finally
{
conn.Close();
conn.Dispose();
}
return val;
}
}
/// <summary>
/// 执行一条不返回结果的SqlCommand,通过一个已经存在的数据库连接
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例:
/// int result = ExecuteNonQuery(conn, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="conn"> 一个现有的数据库连接 </param>
/// <param name="commandType"> SqlCommand命令类型 (存储过程, T-SQL语句, 等等。) </param>
/// <param name="commandText"> 存储过程的名字或者 T-SQL 语句 </param>
/// <param name="commandParameters"> 以数组形式提供SqlCommand命令中用到的参数列表 </param>
/// <returns> 返回一个数值表示此SqlCommand命令执行后影响的行数 </returns>
public static int ExecuteNonQuery(SqlConnection connection, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
int val = 0;
try
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
}
catch
{
val = -1;
}
finally
{
connection.Close();
connection.Dispose();
}
return val;
}
/// <summary>
/// 执行一条不返回结果的SqlCommand,通过一个已经存在的数据库事物处理
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例:
/// int result = ExecuteNonQuery(trans, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="trans"> 一个存在的 sql 事物处理 </param>
/// <param name="commandType"> SqlCommand命令类型 (存储过程, T-SQL语句, 等等。) </param>
/// <param name="commandText"> 存储过程的名字或者 T-SQL 语句 </param>
/// <param name="commandParameters"> 以数组形式提供SqlCommand命令中用到的参数列表 </param>
/// <returns> 返回一个数值表示此SqlCommand命令执行后影响的行数 </returns>
public static int ExecuteNonQuery(SqlTransaction trans, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
int val = 0;
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, commandParameters);
val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return val;
}
/// <summary>
/// 执行一条返回结果集的SqlCommand命令,通过专用的连接字符串。
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例:
/// SqlDataReader r = ExecuteReader(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="connectionString"> 一个有效的数据库连接字符串 </param>
/// <param name="commandType"> SqlCommand命令类型 (存储过程, T-SQL语句, 等等。) </param>
/// <param name="commandText"> 存储过程的名字或者 T-SQL 语句 </param>
/// <param name="commandParameters"> 以数组形式提供SqlCommand命令中用到的参数列表 </param>
/// <returns> 返回一个包含结果的SqlDataReader </returns>
public static SqlDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
SqlConnection conn = new SqlConnection(connectionString);
SqlDataReader rdr = null;
// 在这里使用try/catch处理是因为如果方法出现异常,则SqlDataReader就不存在,
// CommandBehavior.CloseConnection的语句就不会执行,触发的异常由catch捕获。
// 关闭数据库连接,并通过throw再次引发捕捉到的异常。
try
{
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
cmd.Parameters.Clear();
}
catch
{
throw;
}
finally
{
conn.Close();
conn.Dispose();
}
return rdr;
}
/// <summary>
/// 执行一条返回结果集的SqlCommand命令,通过专用的连接字符串。
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例:
/// DateSet ds = ExecuteDataSet(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="connectionString"> 一个有效的数据库连接字符串 </param>
/// <param name="cmdType"> SqlCommand命令类型 (存储过程, T-SQL语句, 等等。) </param>
/// <param name="cmdText"> 存储过程的名字或者 T-SQL 语句 </param>
/// <param name="commandParameters"> 以数组形式提供SqlCommand命令中用到的参数列表 </param>
/// <returns> 返回一个包含结果的DataSet </returns>
public static DataSet ExecuteDataSet(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
SqlConnection conn = new SqlConnection(connectionString);
try
{
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
SqlDataAdapter adapter = new SqlDataAdapter(cmd);
DataSet ds = new DataSet();
adapter.Fill(ds);
return ds;
}
catch
{
throw;
}
finally
{
conn.Close();
conn.Dispose();
}
}
/// <summary>
/// 执行一条返回第一条记录第一列的SqlCommand命令,通过专用的连接字符串。
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例:
/// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="connectionString"> 一个有效的数据库连接字符串 </param>
/// <param name="commandType"> SqlCommand命令类型 (存储过程, T-SQL语句, 等等。) </param>
/// <param name="commandText"> 存储过程的名字或者 T-SQL 语句 </param>
/// <param name="commandParameters"> 以数组形式提供SqlCommand命令中用到的参数列表 </param>
/// <returns> 返回一个object类型的数据,可以通过 Convert.To{Type}方法转换类型 </returns>
public static object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
using (SqlConnection connection = new SqlConnection(connectionString))
{
PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
object val = cmd.ExecuteScalar();
cmd.Parameters.Clear();
return val;
}
}
/// <summary>
/// 执行一条返回第一条记录第一列的SqlCommand命令,通过已经存在的数据库连接。
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例:
/// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="conn"> 一个已经存在的数据库连接 </param>
/// <param name="commandType"> SqlCommand命令类型 (存储过程, T-SQL语句, 等等。) </param>
/// <param name="commandText"> 存储过程的名字或者 T-SQL 语句 </param>
/// <param name="commandParameters"> 以数组形式提供SqlCommand命令中用到的参数列表 </param>
/// <returns> 返回一个object类型的数据,可以通过 Convert.To{Type}方法转换类型 </returns>
public static object ExecuteScalar(SqlConnection connection, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
object val = cmd.ExecuteScalar();
cmd.Parameters.Clear();
return val;
}
/// <summary>
/// 缓存参数数组
/// </summary>
/// <param name="cacheKey"> 参数缓存的键值 </param>
/// <param name="cmdParms"> 被缓存的参数列表 </param>
public static void CacheParameters(string cacheKey, params SqlParameter[] commandParameters)
{
parmCache[cacheKey] = commandParameters;
}
/// <summary>
/// 获取被缓存的参数
/// </summary>
/// <param name="cacheKey"> 用于查找参数的KEY值 </param>
/// <returns> 返回缓存的参数数组 </returns>
public static SqlParameter[] GetCachedParameters(string cacheKey)
{
SqlParameter[] cachedParms = (SqlParameter[])parmCache[cacheKey];
if (cachedParms == null)
return null;
// 新建一个参数的克隆列表
SqlParameter[] clonedParms = new SqlParameter[cachedParms.Length];
// 通过循环为克隆参数列表赋值
for (int i = 0, j = cachedParms.Length; i < j; i++)
// 使用clone方法复制参数列表中的参数
clonedParms[i] = (SqlParameter)((ICloneable)cachedParms[i]).Clone();
return clonedParms;
}
/// <summary>
/// 为执行命令准备参数
/// </summary>
/// <param name="cmd"> SqlCommand 命令 </param>
/// <param name="conn"> 已经存在的数据库连接 </param>
/// <param name="trans"> 数据库事物处理 </param>
/// <param name="cmdType"> SqlCommand命令类型 (存储过程, T-SQL语句, 等等。) </param>
/// <param name="cmdText"> Command text,T-SQL语句 例如 Select * from Products </param>
/// <param name="cmdParms"> 返回带参数的命令 </param>
private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter[] cmdParms)
{
// 判断数据库连接状态
if (conn.State != ConnectionState.Open)
conn.Open();
cmd.Connection = conn;
cmd.CommandText = cmdText;
// 判断是否需要事物处理
if (trans != null)
cmd.Transaction = trans;
cmd.CommandType = cmdType;
if (cmdParms != null)
{
// foreach (SqlParameter parm in cmdParms)
cmd.Parameters.AddRange(cmdParms);
}
}
//1.执行增、删、改的方法:ExecuteNonQuery
public static int ExecuteNonQuery(string sql, params SqlParameter[] pms)
{
using (SqlConnection con = new SqlConnection(ConnectionStringLocalTransaction))
{
using (SqlCommand cmd = new SqlCommand(sql, con))
{
if (pms != null)
{
cmd.Parameters.AddRange(pms);
}
con.Open();
return cmd.ExecuteNonQuery();
}
}
}
//2.封装一个执行返回单个对象的方法:ExecuteScalar()
public static object ExecuteScalar(string sql, params SqlParameter[] pms)
{
using (SqlConnection con = new SqlConnection(ConnectionStringLocalTransaction))
{
using (SqlCommand cmd = new SqlCommand(sql, con))
{
if (pms != null)
{
cmd.Parameters.AddRange(pms);
}
con.Open();
return cmd.ExecuteScalar();
}
}
}
//3.执行查询多行多列的数据的方法:ExecuteReader
public static SqlDataReader ExecuteReader(string sql, params SqlParameter[] pms)
{
SqlConnection con = new SqlConnection(ConnectionStringLocalTransaction);
using (SqlCommand cmd = new SqlCommand(sql, con))
{
if (pms != null)
{
cmd.Parameters.AddRange(pms);
}
try
{
con.Open();
return cmd.ExecuteReader(CommandBehavior.CloseConnection);
}
catch (Exception)
{
con.Close();
con.Dispose();
throw;
}
}
}
//4.执行返回DataTable的方法
public static DataTable ExecuteDataTable(string sql, params SqlParameter[] pms)
{
DataTable dt = new DataTable();
using (SqlDataAdapter adapter = new SqlDataAdapter(sql, ConnectionStringLocalTransaction))
{
if (pms != null)
{
adapter.SelectCommand.Parameters.AddRange(pms);
}
adapter.Fill(dt);
}
return dt;
}
}
1 条评论
建议提出分阶段实施路径,增强可行性。