cyf
519 lines
20 KiB
C#
519 lines
20 KiB
C#
using Lskj.Business;
|
|
using Lskj.Business.Impl;
|
|
using Lskj.Control;
|
|
using Lskj.Control.Model;
|
|
using Lskj.Core;
|
|
using Lskj.Data;
|
|
using Lskj.Model;
|
|
using Lskj.Util;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel;
|
|
using System.Data;
|
|
using System.Diagnostics;
|
|
using System.Drawing;
|
|
using System.Drawing.Printing;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using System.Windows.Forms;
|
|
|
|
namespace Lskj.PubPrint
|
|
{
|
|
public partial class Form1 : DevExpress.XtraEditors.XtraForm
|
|
{
|
|
public Form1()
|
|
{
|
|
if (DBConfig.Instance.CreateConnection())
|
|
{
|
|
InitializeComponent();
|
|
if (DelphiHelper.Delphi_Init(new StringBuilder(DBConfig.Instance.GetDelphiConnection())) == 0)
|
|
{
|
|
MessageUtil.Show(ResourceKeys.UnConnectServer + "[By Delphi]");
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
private object _objLock = new object();
|
|
/// <summary>
|
|
/// 日志队列
|
|
/// </summary>
|
|
private Queue<DataRow> _logQueue = new Queue<DataRow>();
|
|
/// <summary>
|
|
/// 日志队列锁
|
|
/// </summary>
|
|
private object _queueLock = new object();
|
|
/// <summary>
|
|
/// 用于判断是否加载完成就刷新
|
|
/// </summary>
|
|
int Count = 0;
|
|
/// <summary>
|
|
/// 用于判断是否加载完成就刷新
|
|
/// </summary>
|
|
bool flog = false;
|
|
/// <summary>
|
|
/// 设置刷新时间
|
|
/// </summary>
|
|
private string Timer;
|
|
/// <summary>
|
|
/// 设置sql表格数据
|
|
/// </summary>
|
|
private string Sql;
|
|
/// <summary>
|
|
/// 创建ini文件
|
|
/// </summary>
|
|
IniFiles ini = new IniFiles(Application.StartupPath + @"\MyConfig.INI");
|
|
/// <summary>
|
|
/// 临时表
|
|
/// </summary>
|
|
DataTable copydt = new DataTable();
|
|
/// <summary>
|
|
/// 查询条件
|
|
/// </summary>
|
|
public string condition;
|
|
/// <summary>
|
|
/// 多打印机筛选
|
|
/// </summary>
|
|
public string PrintScreen = string.Empty;
|
|
/// <summary>
|
|
/// 打印机列表
|
|
/// </summary>
|
|
List<string> PrinList = new List<string>();
|
|
/// <summary>
|
|
/// 查询条件
|
|
/// </summary>
|
|
public string SortField = string.Empty;
|
|
|
|
|
|
/// <summary>
|
|
/// 初始化程序
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void Form1_Load(object sender, EventArgs e)
|
|
{
|
|
try
|
|
{
|
|
Initialization();
|
|
InitialGridFormat();
|
|
//// 创建后台线程
|
|
//Thread backThread = new Thread(ObtainPrint);
|
|
//backThread.IsBackground = true;
|
|
//backThread.Start();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string Message = ErrorMessage.PromptErrorMessage(ex);
|
|
MessageUtil.Show(Message, ex.Message);
|
|
}
|
|
finally
|
|
{
|
|
Lskj.Control.Model.AutoSizeChange.ControllInitializeSize(this);
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 打印成功判断
|
|
/// </summary>
|
|
public int PrintFlag;
|
|
/// <summary>
|
|
/// 设置表格名称
|
|
/// </summary>
|
|
private void InitialGridFormat()
|
|
{
|
|
this.gridView1.OptionsView.ColumnAutoWidth = false;
|
|
this.gridView2.OptionsView.ColumnAutoWidth = false;
|
|
Afterprint.DataSource = SqlHelper.ExecuteDataTable(string.Format("{0} {1} printFlag = 1 {2} {3}", Sql, condition, PrintScreen, SortField));
|
|
}
|
|
/// <summary>
|
|
/// 获取需要打印表格
|
|
/// </summary>
|
|
public void ObtainPrint()
|
|
{
|
|
this.Invoke(new EventHandler(delegate
|
|
{
|
|
DataTable DT = SqlHelper.ExecuteDataTable(string.Format("{0} {1} printFlag = 0 {2} {3}", Sql, condition, PrintScreen, SortField));
|
|
copydt = DT.Copy();
|
|
flog = false;
|
|
this.timer1.Enabled = false;
|
|
Dictionary<DataRow, List<Task<DataTable>>> sqlSourceDic = new Dictionary<DataRow, List<Task<DataTable>>>();
|
|
foreach (DataRow item in DT.Rows)
|
|
{
|
|
string printSQL = ReplaceHelper.ReplaceRowParam(item, item["printSQL"] + "");
|
|
string dllName = item["libaryName"] + "";
|
|
List<Task<DataTable>> dataTableTasks = new List<Task<DataTable>>();
|
|
if (dllName.Equals("Lskj.FastReportDesign.dll", StringComparison.CurrentCultureIgnoreCase))//匹配frx调用打印
|
|
{
|
|
List<string> tmpSqls = printSQL.Split(';').ToList();
|
|
foreach (string sql in tmpSqls)
|
|
{
|
|
Task<DataTable> task = new Task<DataTable>(() =>
|
|
{
|
|
DataTable dataTable = new DataTable();
|
|
string index = tmpSqls.IndexOf(sql) + "";
|
|
if (!string.IsNullOrEmpty(sql))
|
|
{
|
|
dataTable = BaseImpl.GetDataTableResult(sql).Copy();
|
|
dataTable.TableName = "temp" + index;
|
|
}
|
|
return dataTable;
|
|
});
|
|
task.Start();
|
|
dataTableTasks.Add(task);
|
|
}
|
|
}
|
|
sqlSourceDic.Add(item, dataTableTasks);
|
|
}
|
|
foreach (DataRow item in DT.Rows)
|
|
{
|
|
PrintFlag = 0;
|
|
try
|
|
{
|
|
bool over = false;
|
|
string msg = "";
|
|
Thread t = new Thread(() =>
|
|
{
|
|
KeyValuePair<DataRow, List<Task<DataTable>>> keyValuePair = sqlSourceDic.Where(n => n.Key == item).FirstOrDefault();
|
|
StartPrint(keyValuePair, out msg);
|
|
over = true;
|
|
});
|
|
t.SetApartmentState(ApartmentState.STA);
|
|
t.Start();
|
|
t.Join();
|
|
while (!over)
|
|
{
|
|
Thread.Sleep(500);
|
|
}
|
|
if (PrintFlag == 1)
|
|
{
|
|
RefreshLogUIThread(msg + "\r\n" + DateTime.Now + "模块" + item["id"].ToString() + "打印失败!\r\n");
|
|
string sqlValue = string.Format("update p_SystemPrintTaskTab set printFlag = 1,printTime='{1}',msg='{2}' where id='{0}'", item["id"], DateTime.Now.ToString(), "打印机条件出错！");
|
|
SqlHelper.ExecuteNonQuery(sqlValue);
|
|
}
|
|
else
|
|
{
|
|
RefreshLogUIThread(DateTime.Now + "" + "模块" + item["id"] + "打印成功!" + "\r\n");
|
|
string sqlValue = string.Format("update p_SystemPrintTaskTab set printFlag = 1,printTime='{1}' where id='{0}'", item["id"], DateTime.Now.ToString());
|
|
SqlHelper.ExecuteNonQuery(sqlValue);
|
|
}
|
|
if (copydt.Rows.Count > 0)
|
|
{
|
|
copydt.Rows.RemoveAt(0);
|
|
}
|
|
Afterprint.DataSource = SqlHelper.ExecuteDataTable(string.Format("{0} {1} printFlag=1 {2} {3}", Sql, condition, PrintScreen, SortField));
|
|
this.PrintTable.DataSource = copydt;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
RefreshLog(DateTime.Now + "打印失败.\r\n" + ex);
|
|
}
|
|
}
|
|
}));
|
|
}
|
|
/// <summary>
|
|
/// 开始打印
|
|
/// </summary>
|
|
public void StartPrint(KeyValuePair<DataRow, List<Task<DataTable>>> keyValuePair, out string msg)
|
|
{
|
|
DataRow item = keyValuePair.Key;
|
|
List<Task<DataTable>> dataTableTasks = keyValuePair.Value;
|
|
//DataTable dt=SqlHelper.ExecuteDataTable(string.Format("select PrintAddress from p_systemComputerTab where PrintName='{0}'", item["printerName"]));
|
|
//String PrintAddress=dt.Rows.Count>0?dt.Rows[0]["PrintAddress"]+"":string.Empty;
|
|
//if (!PrinList.Contains(PrintAddress)) {
|
|
// PrintFlag = 1;
|
|
// return;
|
|
//}
|
|
try
|
|
{
|
|
msg = "";
|
|
string printSQL = ReplaceHelper.ReplaceRowParam(item, item["printSQL"] + "");
|
|
string printSQL1 = ReplaceHelper.ReplaceRowParam(item, item["printSQL1"] + "");//Delphi打印，把printSQL1和printSQL2一起传入进去 2025-06-17
|
|
string printSQL2 = ReplaceHelper.ReplaceRowParam(item, item["printSQL2"] + "");
|
|
|
|
int num = int.Parse(item["PrintCount"] + "");
|
|
string dllName = item["libaryName"] + "";
|
|
string printerName = item["printerName"] + "";
|
|
if (dllName.Equals("Lskj.FastReportDesign.dll", StringComparison.CurrentCultureIgnoreCase))//匹配frx调用打印
|
|
{
|
|
List<string> tmpSqls = printSQL.Split(';').ToList();
|
|
PrintUtil.FastReportPrint(tmpSqls, item["printModuleName"] + "", true, printerName, dataTableTasks);
|
|
}
|
|
else
|
|
{
|
|
if (num > 1)
|
|
{
|
|
//DelphiHelper.LoadDelphiDll(PubUtil.AbsolutelyPath + "Lib\\" + item["libaryName"], item["libaryName"] + "", item["printModuleName"] + "", item["printSQL"] + "", printSQL, Convert.ToInt32(3), item["printSQL"] + "");
|
|
DelphiHelper.LoadDelphiDll(PubUtil.AbsolutelyPath + "Lib\\" + item["libaryName"], item["libaryName"] + "", item["printModuleName"] + "", printSQL, printSQL1, Convert.ToInt32(3), printSQL2);
|
|
item["PrintCount"] = num - 1;
|
|
StartPrint(keyValuePair, out msg);
|
|
}
|
|
else
|
|
{
|
|
//DelphiHelper.LoadDelphiDll(PubUtil.AbsolutelyPath + "Lib\\" + item["libaryName"], item["libaryName"] + "", item["printModuleName"] + "", item["printSQL"] + "", printSQL, Convert.ToInt32(3), item["printSQL"] + "");
|
|
DelphiHelper.LoadDelphiDll(PubUtil.AbsolutelyPath + "Lib\\" + item["libaryName"], item["libaryName"] + "", item["printModuleName"] + "", printSQL, printSQL1, Convert.ToInt32(3), printSQL2);
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
msg = ex.Message;
|
|
PrintFlag = 1;
|
|
}
|
|
}
|
|
public void Initialization()
|
|
{
|
|
try
|
|
{
|
|
|
|
RefreshLog(DateTime.Now + "正在初始化平台.\r\n");
|
|
|
|
//判断当前程序是否已经有在允许的，有就关闭当前程序
|
|
Process[] processes = Process.GetProcessesByName("Lskj.PubPrint");
|
|
if (processes.Length > 1)
|
|
{
|
|
//MessageUtil.Show("已有打开的当前程序");
|
|
System.Environment.Exit(0);
|
|
}
|
|
|
|
|
|
if (DBConfig.Instance.CreateConnection())
|
|
{
|
|
string ip = string.Empty;
|
|
//得到本机名
|
|
//ERPInfo.Instance.WindowName "SERVER-T"
|
|
string hostname = ERPInfo.Instance.WindowName;
|
|
//解析主机名称或IP地址的system.net.iphostentry实例。
|
|
//IPHostEntry localhost = Dns.GetHostEntry(hostname);
|
|
ip = ERPInfo.Instance.LoginIP;
|
|
//hostname = "PC-20210908GGIV";
|
|
DataTable dt = SqlHelper.ExecuteDataTable(string.Format("select * from p_systemComputerTab where ComputerName='{0}'", hostname));
|
|
|
|
//foreach (string ss in PrinterSettings.InstalledPrinters)
|
|
//{
|
|
// ///在列表框中列出所有的打印机,
|
|
// PrinList.Add(ss);
|
|
//}
|
|
if (dt.Rows.Count == 0)
|
|
{
|
|
MessageUtil.Show("未配置权限，请联系朗速工作人员!");
|
|
// 关闭所有的线程
|
|
System.Environment.Exit(0);
|
|
}
|
|
RefreshLog(DateTime.Now + "初始化平台成功.\r\n");
|
|
string print = dt.Rows[0]["PrintName"].ToString();
|
|
PrintScreen = print != null ? string.Format("and printerName='{0}'", print) : null;
|
|
|
|
if (dt.Columns.Contains("SortField"))
|
|
{
|
|
SortField = dt.Rows[0]["SortField"].ToString();
|
|
}
|
|
|
|
|
|
//获取ini配置的值
|
|
string time = ini.IniReadValue("刷新时间", "Timer");
|
|
Timer = string.IsNullOrWhiteSpace(time) ? "1000" : time;
|
|
string sql = ini.IniReadValue("刷新时间", "Sql");
|
|
Sql = !string.IsNullOrWhiteSpace(sql) ? ini.IniReadValue("刷新时间", "Sql") : "select * from p_SystemPrintTaskTab with(nolock)";
|
|
condition = Sql.Contains("where") ? "and" : "where";
|
|
string sqlValue = string.Format("update p_systemComputerTab set ipAddress ='{0}' where ComputerName='{1}'", ip, hostname);
|
|
SqlHelper.ExecuteNonQuery(sqlValue);
|
|
this.timer1.Start();
|
|
this.timer1.Interval = int.Parse(Timer) * 1000;
|
|
this.timer2.Interval = 100;
|
|
this.timer2.Start();
|
|
if (ini.ExistINIFile())
|
|
{
|
|
txt_timer.Text = ini.IniReadValue("刷新时间", "Timer");
|
|
lab_Sql.EditText = ini.IniReadValue("刷新时间", "Sql");
|
|
}
|
|
|
|
}
|
|
else
|
|
{
|
|
RefreshLog(DateTime.Now + " 初始化平台失败.\r\n");
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
RefreshLog(DateTime.Now + string.Format("初始化失败.原因:{0}.\r\n", ex.Message));
|
|
}
|
|
}
|
|
#region 设置后台线程
|
|
/// <summary>
|
|
/// 主线程刷新数据
|
|
/// </summary>
|
|
/// <param name="msg"></param>
|
|
public void RefreshLog(string msg)
|
|
{
|
|
txtLog.Text += msg;
|
|
txtLog.Select(txtLog.TextLength, 0);
|
|
txtLog.ScrollToCaret();
|
|
}
|
|
/// <summary>
|
|
/// 后台线程刷新数据
|
|
/// </summary>
|
|
/// <param name="msg"></param>
|
|
public void RefreshLogUIThread(string msg)
|
|
{
|
|
Invoke((EventHandler)delegate
|
|
{
|
|
txtLog.Text += msg;
|
|
txtLog.Select(txtLog.TextLength, 0);
|
|
txtLog.ScrollToCaret();
|
|
});
|
|
}
|
|
private void FileViewer(string fileName)
|
|
{
|
|
try
|
|
{
|
|
System.Diagnostics.Process.Start(fileName);
|
|
}
|
|
catch { }
|
|
}
|
|
#endregion
|
|
|
|
private void timer1_Tick(object sender, EventArgs e)
|
|
{
|
|
try
|
|
{
|
|
ObtainPrint();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string Message = ErrorMessage.PromptErrorMessage(ex);
|
|
MessageUtil.Show(Message, ex.Message);
|
|
}
|
|
}
|
|
private void timer2_Tick(object sender, EventArgs e)
|
|
{
|
|
try
|
|
{
|
|
if (copydt != null)
|
|
{
|
|
if (copydt.Rows.Count == 0)
|
|
{
|
|
this.timer1.Enabled = true;
|
|
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string Message = ErrorMessage.PromptErrorMessage(ex);
|
|
MessageUtil.Show(Message, ex.Message);
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 更改刷新时间
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void simpleButton1_Click(object sender, EventArgs e)
|
|
{
|
|
try
|
|
{
|
|
//将ini文件清空
|
|
ini.IniWriteValue(null, null, null);
|
|
ini.IniWriteValue("刷新时间", "Timer", txt_timer.Text);
|
|
ini.IniWriteValue("刷新时间", "Sql", lab_Sql.EditText);
|
|
Initialization();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string Message = ErrorMessage.PromptErrorMessage(ex);
|
|
MessageUtil.Show(Message, ex.Message);
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 添加双击托盘图标事件（双击显示窗口）
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void notifyIcon1_MouseDoubleClick(object sender, MouseEventArgs e)
|
|
{
|
|
try
|
|
{
|
|
if (WindowState == FormWindowState.Minimized)
|
|
{
|
|
//还原窗体显示
|
|
WindowState = FormWindowState.Normal;
|
|
//激活窗体并给予它焦点
|
|
this.Activate();
|
|
//任务栏区显示图标
|
|
this.ShowInTaskbar = true;
|
|
//托盘区图标隐藏
|
|
notifyIcon1.Visible = false;
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string Message = ErrorMessage.PromptErrorMessage(ex);
|
|
MessageUtil.Show(Message, ex.Message);
|
|
}
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 判断是否最小化,然后显示托盘
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void F_Main_SizeChanged(object sender, EventArgs e)
|
|
{
|
|
try
|
|
{
|
|
//判断是否选择的是最小化按钮
|
|
if (WindowState == FormWindowState.Minimized)
|
|
{
|
|
//隐藏任务栏区图标
|
|
this.ShowInTaskbar = false;
|
|
//图标显示在托盘区
|
|
notifyIcon1.Visible = true;
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string Message = ErrorMessage.PromptErrorMessage(ex);
|
|
MessageUtil.Show(Message, ex.Message);
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 确认是否退出
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void F_Main_FormClosing(object sender, FormClosingEventArgs e)
|
|
{
|
|
try
|
|
{
|
|
if (MessageBox.Show("是否确认退出程序？", "退出", MessageBoxButtons.OKCancel, MessageBoxIcon.Question) == DialogResult.OK)
|
|
{
|
|
// 关闭所有的线程
|
|
this.Dispose();
|
|
this.Close();
|
|
}
|
|
else
|
|
{
|
|
e.Cancel = true;
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string Message = ErrorMessage.PromptErrorMessage(ex);
|
|
MessageUtil.Show(Message, ex.Message);
|
|
}
|
|
}
|
|
|
|
private void 打印查看ToolStripMenuItem_Click(object sender, EventArgs e)
|
|
{
|
|
try
|
|
{
|
|
DataRow item = this.gridView2.GetFocusedDataRow();
|
|
string printSQL = ReplaceHelper.ReplaceRowParam(item, item["printSQL2"] + "");
|
|
DelphiHelper.LoadDelphiDll(PubUtil.AbsolutelyPath + "Lib\\" + item["libaryName"], item["libaryName"] + "", item["printModuleName"] + "", item["printSQL"] + "", printSQL, Convert.ToInt32(4), item["printSQL"] + "");
|
|
RefreshLogUIThread(DateTime.Now + " 正在查看打印格式.\r\n");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
|