|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Linq;
|
|
|
using System.Text;
|
|
|
using Mesnac.Basic;
|
|
|
using Mesnac.Codd.Session;
|
|
|
using System.Data;
|
|
|
using Mesnac.Compressor.Entity;
|
|
|
using Mesnac.Compressor.Unity;
|
|
|
using System.Windows.Forms;
|
|
|
|
|
|
namespace Mesnac.Compressor.Data
|
|
|
{
|
|
|
public class DbHandler
|
|
|
{
|
|
|
public DbHelper dbHelper;
|
|
|
public DataBHandler localDB = new DataBHandler();
|
|
|
private DataSourceFactory dsFactory=DataSourceFactory.Instance;
|
|
|
public DbHandler()
|
|
|
{
|
|
|
if (Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
//网络服务器
|
|
|
dbHelper = dsFactory.GetDbHelper("DataSource1");
|
|
|
}
|
|
|
catch
|
|
|
{
|
|
|
ConnectShow();
|
|
|
throw;
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
private void ConnectShow()
|
|
|
{
|
|
|
Common.Instance.ServerConnect = false;
|
|
|
FrmConnnectFlag frm = new FrmConnnectFlag();
|
|
|
frm.ShowDialog();
|
|
|
}
|
|
|
|
|
|
public void ExecSql(string sql)
|
|
|
{
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
localDB.ExecSql(sql);
|
|
|
return;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.CommandText = sql;
|
|
|
dbHelper.ExecuteNonQuery();
|
|
|
}
|
|
|
catch (Exception e)
|
|
|
{
|
|
|
|
|
|
ICSharpCode.Core.LoggingService.Error("Insert语句错误：" + e.ToString());
|
|
|
ICSharpCode.Core.LoggingService.Error("Insert语句错误：" + sql);
|
|
|
//ConnectShow();
|
|
|
localDB.ExecSql(sql);
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
public string GetLastMainBarcode(string code)
|
|
|
{
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
return localDB.GetLastMainBarcode(code);
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
sb.Append("EXEC SP_Pro_GetNewMainBarcode '");
|
|
|
sb.Append(code).Append("'");
|
|
|
dbHelper.CommandText = sb.ToString();
|
|
|
return dbHelper.ToScalar().ToString();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
ConnectShow();
|
|
|
return localDB.GetLastMainBarcode(code);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public string GetLastSemiBarcode(string code,string lineID)
|
|
|
{
|
|
|
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
return localDB.GetLastSemiBarcode(code);
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
sb.Append("EXEC SP_Pro_GetNewSemiBarcode '");
|
|
|
sb.Append(code).Append("','").Append(lineID).Append("'");
|
|
|
dbHelper.CommandText = sb.ToString();
|
|
|
return dbHelper.ToScalar().ToString();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("网络服务器连接错误");
|
|
|
ConnectShow();
|
|
|
return localDB.GetLastSemiBarcode(code);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
public void InsertTrace(string barcode, string SemiACode, string machineID)
|
|
|
{
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
localDB.InsertTrace(barcode, SemiACode,0);
|
|
|
return;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
|
|
|
string sql = "EXEC SP_Pro_InsertTraceStation @semiBarcode,@mainBarcode,@MachineID";
|
|
|
dbHelper.AddParameter("@semiBarcode", SemiACode);
|
|
|
dbHelper.AddParameter("@mainBarcode", barcode);
|
|
|
dbHelper.AddParameter("@MachineID", machineID);
|
|
|
dbHelper.CommandText = sql;
|
|
|
dbHelper.ExecuteNonQuery();
|
|
|
//localDB.InsertTrace(barcode, SemiACode, 1);
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
localDB.InsertTrace(barcode, SemiACode, 0);
|
|
|
ConnectShow();
|
|
|
return;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取当前机种信息
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public string GetCurrentMachineInfo()
|
|
|
{
|
|
|
//MachineInfo Minfo = new MachineInfo();
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
return "";
|
|
|
//return Minfo;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
string sql = "Exec SP_Pro_ChangeProduct";
|
|
|
dbHelper.CommandText = sql;
|
|
|
return dbHelper.ToScalar().ToString();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
return "";
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 插入报警信息
|
|
|
/// </summary>
|
|
|
/// <param name="WorkName">电脑名字</param>
|
|
|
/// <param name="info"></param>
|
|
|
public void InsertAlarmInfo(string WorkName,AlarmInfo info)
|
|
|
{
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
sb.Append("INSERT INTO dbo.T_BD_UniteAlarmInfo(ComputerName,UniteID,AlarmInfo,AlarmIndex,RecordTime )VALUES ('");
|
|
|
sb.Append(WorkName).Append("','");
|
|
|
sb.Append(info.AlarmUnit.ToString()).Append("','");
|
|
|
sb.Append(info.AlarmString).Append("','");
|
|
|
sb.Append(info.AlarmIndex.ToString()).Append("',");
|
|
|
sb.Append("GETDATE()").Append(")");
|
|
|
dbHelper.CommandText = sb.ToString();
|
|
|
dbHelper.ExecuteNonQuery();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
return;
|
|
|
}
|
|
|
}
|
|
|
#region ActionDb
|
|
|
public DataTable SelectAlarmInfo(string ComputerName)
|
|
|
{
|
|
|
if (dbHelper == null)
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
sb.Append("select 序号 = row_number() over(order by RecordTime desc),AlarmIndex as '报警单元',AlarmInfo as '报警信息 （一小时）' ,RecordTime as '报警时间' from dbo.T_BD_UniteAlarmInfo where ComputerName= '");
|
|
|
sb.Append(ComputerName).Append("'");
|
|
|
sb.Append(" AND RecordTime>=DATEADD(HH,-1,GETDATE())");
|
|
|
dbHelper.CommandText = sb.ToString();
|
|
|
DataTable dt= dbHelper.ToDataTable();
|
|
|
return dt;
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
return null;
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
//工作完成
|
|
|
public void WorkFinish(string RFID,string bigcode,string serialnum)
|
|
|
{
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
localDB.WorkFinish(RFID, bigcode, serialnum,0);
|
|
|
return;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
sb.Append("Exec SP_Pro_ProductionInfo '").Append(RFID).Append("','");
|
|
|
sb.Append(bigcode).Append("','");
|
|
|
sb.Append(serialnum).Append("'");
|
|
|
dbHelper.CommandText = sb.ToString();
|
|
|
ICSharpCode.Core.LoggingService.Info(string.Format(sb.ToString()));
|
|
|
dbHelper.ExecuteNonQuery();
|
|
|
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
ConnectShow();
|
|
|
localDB.WorkFinish(RFID, bigcode, serialnum, 0);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取最新交接班信息
|
|
|
/// </summary>
|
|
|
/// <param name="key"></param>
|
|
|
/// <returns></returns>
|
|
|
public ShiftInfo GetShiftInfo()
|
|
|
{
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
return localDB.GetShiftInfo();
|
|
|
//return null;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
string sql = "SELECT TOP(1)ShiftNo,GroupID,a.ShiftID, b.ShiftName,a.CarryTime FROM dbo.T_RP_ShiftInfo a LEFT JOIN dbo.T_HR_Shift b ON a.ShiftID=b.ShiftID ORDER BY CarryTime DESC ";
|
|
|
dbHelper.CommandText = sql;
|
|
|
DataTable dt= dbHelper.ToDataTable();
|
|
|
|
|
|
ShiftInfo shift = new ShiftInfo();
|
|
|
shift.carryTime = dt.Rows[0]["CarryTime"].ToString();
|
|
|
shift.shiftNo = dt.Rows[0]["ShiftNo"].ToString();
|
|
|
shift.shiftID = dt.Rows[0]["ShiftID"].ToString();
|
|
|
shift.groupID = dt.Rows[0]["GroupID"].ToString();
|
|
|
shift.shiftName = dt.Rows[0]["ShiftName"].ToString();
|
|
|
return shift;
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
return localDB.GetShiftInfo();
|
|
|
//return null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public int GetCurrentMachine()
|
|
|
{
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
return localDB.GetCurrentMachine();
|
|
|
//return 0;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
string sql = "SELECT TOP(1) ProductChangingID FROM dbo.T_RP_ProductChangeLog ORDER BY ChangeTime DESC ";
|
|
|
dbHelper.CommandText = sql;
|
|
|
return Convert.ToInt32(dbHelper.ToScalar());
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
ConnectShow();
|
|
|
return localDB.GetCurrentMachine();
|
|
|
//return 0;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取当前机种
|
|
|
/// </summary>
|
|
|
/// <param name="MachineID"></param>
|
|
|
/// <returns></returns>
|
|
|
public DataTable GetCurrentMachine(int MachineID)
|
|
|
{
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
return localDB.GetCurrentMachine(MachineID);
|
|
|
//return null;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
string sql = " SELECT * FROM dbo.T_BD_ProductInfo WHERE ProductID='" + MachineID.ToString()+"'";
|
|
|
dbHelper.CommandText = sql;
|
|
|
return dbHelper.ToDataTable();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
ConnectShow();
|
|
|
return localDB.GetCurrentMachine(MachineID);
|
|
|
//return null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取当前产品的投产时间
|
|
|
/// </summary>
|
|
|
/// <param name=""></param>
|
|
|
/// <returns></returns>
|
|
|
public string GetProductBeginTime(string mainbarcode)
|
|
|
{
|
|
|
if (dbHelper == null || Common.Instance.ReadLocalDB)
|
|
|
{
|
|
|
localDB.GetProductBeginTime(mainbarcode);
|
|
|
return null;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
string sql = " SELECT top(1) BeginTime FROM dbo.T_SY_TraceState WHERE Barcode='" + mainbarcode + "'";
|
|
|
dbHelper.CommandText = sql;
|
|
|
return dbHelper.ToScalar().ToString();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
ConnectShow();
|
|
|
localDB.GetProductBeginTime(mainbarcode);
|
|
|
return null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
public object GetStationData(string stationID)
|
|
|
{
|
|
|
if (dbHelper == null)
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
sb.Append("Exec SP_Pro_StationDataNew '").Append(stationID).Append("','");
|
|
|
sb.Append(DateTime.Now.ToString("yyyy-MM-dd")).Append("','");
|
|
|
sb.Append(DateTime.Now.AddDays(1).ToString("yyyy-MM-dd")).Append("'");
|
|
|
dbHelper.CommandText = sb.ToString();
|
|
|
//ICSharpCode.Core.LoggingService.Info(string.Format(sb.ToString()));
|
|
|
return dbHelper.ToDataSet();
|
|
|
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(ex.ToString()));
|
|
|
return null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取产品是否合格
|
|
|
/// </summary>
|
|
|
/// <param name="Rfid"></param>
|
|
|
/// <returns></returns>
|
|
|
public WorkTray GetProductQuality(string Rfid)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Fatal("查询本地数据库");
|
|
|
WorkTray tray = new WorkTray();
|
|
|
try
|
|
|
{
|
|
|
if (dbHelper == null)
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
dbHelper.ClearParameter();
|
|
|
dbHelper.CommandType = CommandType.Text;
|
|
|
dbHelper.CommandText = "";
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
sb.Append("select * from T_RP_WorkTrayRealTimeInfo where RFIDNum='").Append(Rfid).Append("'");
|
|
|
//ICSharpCode.Core.LoggingService.Debug("sql语句："+sb.ToString());
|
|
|
dbHelper.CommandText = sb.ToString();
|
|
|
DataTable dt = dbHelper.ToDataTable();
|
|
|
|
|
|
if (dt != null && dt.Rows.Count > 0)
|
|
|
{
|
|
|
tray.RfidNum = dt.Rows[0]["RFIDNum"].ToString();
|
|
|
tray.MainBarcode = dt.Rows[0]["barCode"].ToString();
|
|
|
tray.SemiBarcode = dt.Rows[0]["SemiBarcode"].ToString();
|
|
|
string Okng = dt.Rows[0]["State"].ToString();
|
|
|
tray.InsertTime = dt.Rows[0]["updateTime"].ToString();
|
|
|
int outvalue = 0;
|
|
|
//调试用
|
|
|
//ICSharpCode.Core.LoggingService.Debug(dt.Rows[0]["RFIDNum"].ToString() + " barcode:" + dt.Rows[0]["barcode"].ToString() + " SemiBarcode:" + dt.Rows[0]["SemiBarcode"].ToString() + " State:" + dt.Rows[0]["State"].ToString() + " CurrentStation:" + dt.Rows[0]["CurrentStation"].ToString());
|
|
|
//调试完成
|
|
|
if (int.TryParse(Okng.Trim(), out outvalue))
|
|
|
{
|
|
|
tray.OKNG = outvalue;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
//质量转换错误，默认为1
|
|
|
ICSharpCode.Core.LoggingService.Info("质量转换错误，默认为1");
|
|
|
tray.OKNG = 1;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
}
|
|
|
catch (Exception e)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(string.Format(e.ToString()));
|
|
|
ConnectShow();
|
|
|
}
|
|
|
return tray;
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
}
|