天津康师傅调度系统
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 

1495 lines
55 KiB

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net;
using DotNetSAPI;
using System.ServiceModel;
using System.ServiceModel.Channels;
using System.Runtime.Serialization;
using CommonLib;
namespace wcfControlMonitorClient
{
public partial class FrmClient : Form,WcfControlMonitor.IControlMonitorCallback
{
//protected override CreateParams CreateParams
//{
// get
// {
// CreateParams cp = base.CreateParams;
// cp.ExStyle |= 0x02000000;//WS_CLIPCHILDREN 两个窗体叠加时,重叠部分不重绘
// return cp;
// }
//}
int timersum = 0;//20150103增加断网恢复
Model.MDevice devinfo;
FrmDeviceStatus _deviceStatus = new FrmDeviceStatus();
FrmWorkstationStatus _worstation = new FrmWorkstationStatus();
StringBuilder sql = new StringBuilder();
DBFactory.DBOperator dbo = CStaticClass.dbo;
DBFactory.DBOperator dbo1 = new DBFactory.DBOperator();
SpeechVoiceSpeakFlags SpFlags = SpeechVoiceSpeakFlags.SVSFlagsAsync;
public SpVoice Voice;// = new SpVoice();
public Model.MDevice[] devlist;
public int devsn = 0;
private static FrmClient _formInstance;
public static FrmClient FormInstance
{
get
{
if (_formInstance == null)
{
_formInstance = new FrmClient();
}
return _formInstance;
}
set { _formInstance = value; }
}
FrmTaskList Frmlist;
public FrmClient()
{
CommonClassLib.CCarryConvert.WriteDarkCasket("Login", "操作日志", "FrmClient()", "", "");
InitializeComponent();
try
{
//初始化管理和调度交互状态
Model.CGetInfo.AddIOControlStatus();
Model.CGetInfo.AddDeviceKindInfo();
Model.CGetInfo.AddDeviceInfo();
Model.CGetInfo.AddDeviceErrors();
devlist = Model.CGetInfo.DeviceInfo.Values.ToArray<Model.MDevice>();
CStaticClass.SystemName = CommonClassLib.AppSettings.GetValue("SystemName");
this.notifyIcon1.Text = CStaticClass.SystemName;
this.Text = CStaticClass.SystemName;
OPCClient.CCommonOPCClient.Hostname = CommonClassLib.AppSettings.GetValue("HostName");
OPCClient.CCommonOPCClient.ProgID = CommonClassLib.AppSettings.GetValue("OPCProgID");
#region 客户端订阅初始化20120428
//DataView dvx;
//DataView dv = dbo.ExceSQL("SELECT F_ReadSubscription, F_DeviceIndex, F_DBW2Address, F_DBWGetLength, F_S7Connection, F_SplitByte FROM T_Base_Device WHERE (F_ReadSubscription IS NOT NULL) AND (F_ReadSubscription =F_DeviceIndex) ORDER BY F_ReadSubscription").Tables[0].DefaultView;
//for (int i = 0; i < dv.Count; i++)
//{
// dvx = dbo.ExceSQL(string.Format("SELECT (MAX(F_DBW2Address) + F_DBWGetLength) AS maxdbw2 FROM T_Base_Device WHERE (F_ReadSubscription = '{0}') GROUP BY F_DBWGetLength ORDER BY maxdbw2 DESC", dv[i]["F_ReadSubscription"])).Tables[0].DefaultView;
// if (dvx.Count > 0)
// {
// if (CStaticClass.MutiReadSubscriptionDeviceStateReturns.ContainsKey(dv[i]["F_ReadSubscription"].ToString()) == false)
// {
// CStaticClass.MutiReadSubscriptionDeviceStateReturns.Add(dv[i]["F_ReadSubscription"].ToString(), new int[Convert.ToInt32(dvx[0]["maxdbw2"]) - Convert.ToInt32(dv[i]["F_DBW2Address"])]);
// }
// }
//}
#endregion
}
catch (Exception ex)
{
CommonClassLib.CCarryConvert.WriteDarkCasket("Login", "操作日志", "FrmClient()-catch", ex.StackTrace, ex.Message);
throw ex;
}
#region WeifenLuo
FrmControlMonitor.FormInstance.Show(this.dockPanel1);
FrmControlMonitor.FormInstance.DockTo(this.dockPanel1, DockStyle.Fill);
FrmControlMonitor.FormInstance.AutoScroll = true;
Frmlist = new FrmTaskList();
Frmlist.Show(this.dockPanel1);
Frmlist.DockTo(this.dockPanel1, DockStyle.Bottom);
Frmlist.DockState = WeifenLuo.WinFormsUI.Docking.DockState.DockBottomAutoHide;
//Frmlist.AutoHidePortion = 0.125;// (double)Frmlist.Height / (double)this.dockPanel1.Height;
Frmlist.CloseButton = false;
//Added by DingXiaoxu on 20110104
FrmErrorMessage frmErrorMessage = new FrmErrorMessage();
frmErrorMessage.Show(this.dockPanel1);
frmErrorMessage.DockTo(this.dockPanel1, DockStyle.Bottom);
frmErrorMessage.DockState = WeifenLuo.WinFormsUI.Docking.DockState.DockBottomAutoHide;
//Frmlist.AutoHidePortion = 0.125;// (double)Frmlist.Height / (double)this.dockPanel1.Height;
frmErrorMessage.CloseButton = false;
FrmHelp frmHelp = new FrmHelp();
frmHelp.Show(this.dockPanel1);
frmHelp.DockTo(this.dockPanel1, DockStyle.Bottom);
frmHelp.DockState = WeifenLuo.WinFormsUI.Docking.DockState.DockBottomAutoHide;
//Frmlist.AutoHidePortion = 0.125;// (double)Frmlist.Height / (double)this.dockPanel1.Height;
frmHelp.CloseButton = false;
#endregion
}
/// <summary>
/// 客户端事件响应20120428
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
void CCommon_UpdateDB(object sender, CUpdateDBChangeEventArgs e)
{
if ( !CStaticClass.client.IsDisposed)
{
string errtext = string.Empty;
this.BeginInvoke(new MethodInvoker(delegate()
{ DealWithDeviceState(out errtext, e.Deviceindex, e.SplitbyteValue, e.Devicestates); }));
}
}
/// <summary>
/// 客户端事件响应处理函数20120428
/// zcy 重写,客户端使用 snap7 直连 PLC
/// </summary>
/// <param name="errtext"></param>
/// <param name="deviceindex">设备索引</param>
/// <param name="splitbyteValue">未用到</param>
/// <param name="devicestates">改设备的DB2,没有订阅组的概念</param>
/// <returns></returns>
bool DealWithDeviceState(out string errtext, int deviceindex, byte[] splitbyteValue, byte[] devicestates)
{//deviceindex设备组代表的订阅,首先把设备组按照F_DBW2Address由小到大排序,拆分到具体每个设备
if ( devicestates == null)
{
errtext = Snap7Client.CCommonSnap7Client.Snap7Error;
SendMessage(string.Format("tsStatus@FrmClient.DealWithDeviceState时,订阅组:{0}发生异常,{1}!", deviceindex, errtext));
return false;
}
errtext = string.Empty; DataView dv = new DataView(); DataView dvsp = new DataView(); DataView dvbc = new DataView();
try
{
StringBuilder sql = new StringBuilder(string.Format("SELECT F_DeviceIndex, F_DBW2Address, F_DBWGetLength, F_SplitByte,F_S7Connection,F_ManTaskReserve FROM T_Base_Device WHERE (F_DeviceIndex = '{0}') AND (F_DBW2Address IS NOT NULL) ORDER BY F_DBW2Address", deviceindex));
dv = dbo1.ExceSQL(sql.ToString()).Tables[0].DefaultView;
if (dv.Count < 0)
{
errtext = string.Format("FrmClient.DealWithDeviceState时,订阅组:{0}对应的设备索引不存在!", deviceindex);
SendMessage(string.Format("tsStatus@FrmClient.DealWithDeviceState时,订阅组:{0}对应的设备索引不存在!", deviceindex));
return false;
}
if (devicestates != null)
{
{
int devidx = deviceindex;
devinfo = Model.CGetInfo.GetDeviceInfo(devidx);
int taskindex= 0;
int state = 0;
if (devinfo.Dbw2Getlength > 3)
{
taskindex = (devicestates[2] << 8) + devicestates[3];
if (devinfo.Dbw2Getlength > 1)
{
state = devicestates[1];
}
}
else
{
#region 特殊类型设备在这里,DB2长度小于3,无任务但有交互的设备
if (devinfo.DeviceKind == 9||devinfo.DeviceKind == 38)
{
//if (devicestates[ 0] != 1) continue;
devinfo.SplitByte_0 = (devicestates[0] & 1) == 1 ? 1 : 0;
}
#endregion
}
#region 光电重写 zcy 。如果有新设备类型,增加 if 条件;如果光电位置发生变化,改变 splitLocat 的值
int splitLocat = 0;
if (devinfo.DeviceKind == 2)
{
splitLocat = 4; //输送线光电位
}
else if (devinfo.DeviceKind == 1)
{
splitLocat = 13; //堆垛机光电位
}
else if (devinfo.DeviceKind == 4)
{
splitLocat = 8; //穿梭车光电位
}
if (splitLocat > 0)
{
devinfo.SplitByte_0 = (devicestates[splitLocat] & 1) == 1 ? 1 : 0;
devinfo.SplitByte_1 = (devicestates[splitLocat] & 2) == 2 ? 1 : 0;
devinfo.SplitByte_2 = (devicestates[splitLocat] & 4) == 4 ? 1 : 0;
devinfo.SplitByte_3 = (devicestates[splitLocat] & 8) == 8 ? 1 : 0;
devinfo.SplitByte_4 = (devicestates[splitLocat] & 16) == 16 ? 1 : 0;
devinfo.SplitByte_5 = (devicestates[splitLocat] & 32) == 32 ? 1 : 0;
devinfo.SplitByte_6 = (devicestates[splitLocat] & 64) == 64 ? 1 : 0;
devinfo.SplitByte_7 = (devicestates[splitLocat] & 128) == 128 ? 1 : 0;
}
#endregion
int devkind = devinfo.DeviceKind;
if (state >= 30)
{
devinfo.ErrorCode = state;
devinfo.RunState = 2;
}
else
{//0,1,2
if (state == 2)
{
devinfo.RunState = 5;
}
else
{
devinfo.RunState = state;
}
devinfo.ErrorCode = state;
}
devinfo.TaskNo = taskindex;
#region 堆垛机和穿梭车的坐标
if (devinfo.DeviceKind == 1)
{
devinfo.ControlMode = Convert.ToInt32(dv[0]["F_ManTaskReserve"]) ;//借用控制模式
if (devinfo.DeviceKind == 1)
{
devinfo.XCoor = devicestates[7] + (devicestates[ 6] << 8) + (devicestates[5] << 16) + (devicestates[4] << 24);//X坐标
devinfo.YCoor = devicestates[11] + (devicestates[10] << 8) + (devicestates[9] << 16) + (devicestates[8] << 32);//Y坐标
devinfo.ZCoor = devicestates[12];//Z相对坐标(1或2)
}
}
if (devinfo.DeviceKind == 4)
{
//X相对坐标
devinfo.XCoor = devicestates[7] + (devicestates[6] << 8) + (devicestates[5] << 16) + (devicestates[4] << 32);//X坐标
}
#endregion
Model.CGetInfo.SetDeviceInfo(devinfo);
}
}
return true;
}
catch (Exception ex)
{
SendMessage(string.Format("tsStatus@FrmClient.DealWithDeviceState时{0}", ex.StackTrace+ex.Message));
errtext = string.Format("tsStatus@FrmClient.DealWithDeviceState时{0}", ex.StackTrace + ex.Message);
return false;
}
finally
{
dv.Dispose();
dvbc.Dispose();
dvsp.Dispose();
}
}
#region wcf回调
public void SendDeviceInfo(Model.MDevice devinfo)
{
try
{
if (CStaticClass.WCFOK == false) return;
if (this.IsDisposed) return;
Model.CGetInfo.SetDeviceInfo(devinfo);
}
catch (Exception ex)
{
throw ex;
}
}
public IAsyncResult BeginSendDeviceInfo(Model.MDevice devinfo, AsyncCallback acb, object state)
{
return state as IAsyncResult;
}
public void EndSendDeviceInfo(IAsyncResult ar)
{
}
public IAsyncResult BeginSendMessage(string message, AsyncCallback acb, object state)
{
return state as IAsyncResult;
}
public void EndSendMessage(IAsyncResult ar)
{
}
public void SendMessage(string message)
{
char[] cc = new char[1] { '@' };
string[] strsplit = message.Split(cc);
if (strsplit.GetLength(0) > 1)
{//更新指定控件
if (strsplit[0] == "tsStatus")
{
if (FrmControlMonitor.FormInstance.GetObjectText("tsStatus").IndexOf(strsplit[1]) < 0)
{
FrmControlMonitor.FormInstance.FlashPanit("tsStatus", strsplit[1], true);
}
//tsStatus.Text = strsplit[1];
}
else if (strsplit[0] == "notifyIcon1")
{
this.BeginInvoke(new MethodInvoker(delegate()
{
notifyIcon1.BalloonTipText = strsplit[1];
notifyIcon1.ShowBalloonTip(10000, "警告:", strsplit[1],ToolTipIcon.Warning);
}));
}
}
//else
//{//刷新数据显示
// this.dgvManager.BeginInvoke(new MethodInvoker(delegate()
// {
// sql.Remove(0, sql.Length);
// sql.Append("select * from V_Manage_Task where ").Append(CStaticClass.Manstatus);
// this.dgvManager.DataSource = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
// }));
// this.dgvMonitor.BeginInvoke(new MethodInvoker(delegate()
// {
// sql.Remove(0, sql.Length);
// sql.Append("select * from V_Monitor_Task where ").Append(CStaticClass.Monstatus).Append(" order by 设备指令索引 asc ");
// this.dgvMonitor.DataSource = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
// }));
//}
}
//20140824richard
public void SendOrderMessage(Model.MonitorInfo mi)
{
this.BeginInvoke(new MethodInvoker(delegate()
{
try
{
if (CStaticClass.UserID.ToUpper() == "SA")
{
CStaticClass.Order = mi.Orderturnon;
CStaticClass.ObtainManageTask = mi.Obtaintask;
if (CStaticClass.Order == true)
{
ClickOrderTurnOn();
}
else
{
ClickOrderTurnOff();
}
if (CStaticClass.ObtainManageTask == true)
{
ClickObtainTask();
}
else
{
ClickStopObtainTask();
}
}
}
catch (Exception ex)
{
if (FrmControlMonitor.FormInstance.GetObjectText("tsStatus").IndexOf("接收【获取任务和命令开关】广播时:" + ex.Message) < 0)
{
FrmControlMonitor.FormInstance.FlashPanit("tsStatus", "接收【获取任务和命令开关】广播时:" + ex.Message, true);
}
//if (tsStatus.Text.IndexOf("接收【获取任务和命令开关】广播时:" + ex.Message) < 0)
//{
// tsStatus.ForeColor = Color.Red;
// this.tsStatus.Text += "接收【获取任务和命令开关】广播时:" + ex.Message;
//}
}
}));
}
public IAsyncResult BeginSendOrderMessage(Model.MonitorInfo mi, AsyncCallback callBack, object state)
{
return state as IAsyncResult;
}
public void EndSendOrderMessage(IAsyncResult ar)
{
}
//20140824richard
#endregion
private void Client_FormClosing(object sender, FormClosingEventArgs e)
{
if (MessageBox.Show("您确认要关闭"+CStaticClass.SystemName+"吗?", "操作提示:", MessageBoxButtons.OKCancel, MessageBoxIcon.Warning) != DialogResult.OK)
{
e.Cancel = true;
return;
}
try
{
ClientLogout();
//OPCClient.CCommonOPCClient.DisConnectOPCServer();//20120428
}
catch (Exception ex)
{
}
finally
{
FrmLogin.FormInstance.Close();
}
}
void LogCallBack(IAsyncResult ar)
{
try
{
string strErr = string.Empty;
if (CStaticClass.WcfControl.EndLogoutClient(out strErr, ar) == true)
{
//if (ar.AsyncState.ToString() == "RegisterClientCallBack")
//{
// CStaticClass.WcfControl.BeginRegisterClient(CStaticClass.UserID, "客户端:" + CStaticClass.ClientID + ",用户名:" + CStaticClass.UserID, new AsyncCallback(RegisterClientCallBack), null);
// return;
//}
}
CStaticClass.WCFOK = false;
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "操作提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
public void ClientLogout()
{
try
{
string errtext = string.Empty;
CStaticClass.WcfControl.BeginLogoutClient("客户端:" + CStaticClass.ClientID + ",用户名:" + CStaticClass.UserID,new AsyncCallback(LogCallBack),"" );
}
catch (Exception ex)
{
//MessageBox.Show(ex.Message, "操作提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
private void toolStripMenuItem1_Click(object sender, EventArgs e)
{
FrmHandCommand.FormInstance.Show();
}
private void toolStripMenuItem2_Click(object sender, EventArgs e)
{
FrmHandAssociateCommand.FormInstance.Show();
}
private void MIManageShow_Click(object sender, EventArgs e)
{
FrmAutoCommand.FormInstance.Show();
}
private void MIAltMonitor_Click(object sender, EventArgs e)
{
FrmModifyMonitor.FormInstance.Show();
}
private void MIAltManange_Click(object sender, EventArgs e)
{
//FrmModifyManage.FormInstance.ShowDialog();
FrmModifyManage.FormInstance.Show();
}
private void notifyIcon1_BalloonTipShown(object sender, EventArgs e)
{
try
{
if (null == Voice)
{
Voice = new SpVoice();
}
Voice.Speak(notifyIcon1.BalloonTipText, SpFlags);
}
catch
{
}
}
private void notifyIcon1_MouseDoubleClick(object sender, MouseEventArgs e)
{
if (CStaticClass.WCFOK == true)
{
this.TopMost = true;
this.Visible = true;
this.TopMost = false;
this.WindowState = FormWindowState.Maximized;
}
}
private void tsStatus_TextChanged(object sender, EventArgs e)
{
}
void BuildHandTaskCallBack(IAsyncResult ar)
{
string errtext = string.Empty;
if (CStaticClass.WcfControl.EndBuildHandTask(out errtext, ar) == false)
{
//MessageBox.Show(errtext, "操作提示:", MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
private void Client_Load(object sender, EventArgs e)
{
try
{
CommonClassLib.CCarryConvert.WriteDarkCasket("Login", "操作日志", "FrmClient()-准备InitAllClientSnap7", "", "");
#region 客户端使用 Snap7 协议
Snap7Client.CCommonSnap7Client.InitAllClientSnap7();
Snap7Client.CCommonSnap7Client.UpdateDB += new CUpdateDBEventHandler(CCommon_UpdateDB);
if (Snap7Client.CCommonSnap7Client.Snap7Error != null)
{
MessageBox.Show(Snap7Client.CCommonSnap7Client.Snap7Error);
}
#endregion
}
catch (Exception ex)
{
throw (ex);
}
}
private void MIDeviceState_Click(object sender, EventArgs e)
{
FrmDeviceInfoEdit.FormInstance.Show();
}
private void MIRouteInfo_Click(object sender, EventArgs e)
{
FrmRouteEdit.FormInstance.Show();
}
private void MIWaitTime_Click(object sender, EventArgs e)
{
FrmWaitTime.FormInstance.Show();
}
private void MIMonitorConnectInfo_Click(object sender, EventArgs e)
{
FrmConnectDB.FormInstance.ConnectType = "Monitor";
FrmConnectDB.FormInstance.Show();
}
private void MIIOStation_Click(object sender, EventArgs e)
{
FrmIOStation.FormInstance.Show();
}
private void timer1_Tick(object sender, EventArgs e)
{
//if (CStaticClass.WCFOK == false) return;
try
{
if(CStaticClass.WcfControl!=null)
{
if (CStaticClass.WcfControl.State == CommunicationState.Faulted)
{
MMServerStatus.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMServerStatus.ToolTipText = "与服务端连接失败";
CStaticClass.WCFOK = false;
ReConnectAndRegisterClient();//20160115添加断线重连功能
}
else
{
MMServerStatus.Image = wcfControlMonitorClient.Properties.Resources.linkok;
//MMServerStatus.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMServerStatus.ToolTipText = "与服务端连接成功";
CStaticClass.WcfControl.BeginHeartbeat(new AsyncCallback(CallBackHeartbeat), null);
}
}
}
catch (Exception ex)
{
if (FrmControlMonitor.FormInstance.GetObjectText("tsStatus").IndexOf("BeginHeartbeat时:" + ex.Message) < 0)
{
FrmControlMonitor.FormInstance.FlashPanit("tsStatus", "BeginHeartbeat时:" + ex.Message, true);
}
MMServerStatus.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
CStaticClass.WCFOK = false;
ReConnectAndRegisterClient();//20160115添加断线重连功能
}
}
public void SendAllDeviceStatesCallback(IAsyncResult ar)
{
try
{
Model.MDevice dev;
dev = CStaticClass.WcfControl.EndSendAllDeviceStates(ar);
if (dev != null)
{
Model.CGetInfo.SetDeviceInfo(dev);
}
devsn++;
if (devsn < devlist.Count())
{
CStaticClass.WcfControl.BeginSendAllDeviceStates(devlist[devsn].DeviceIndex, new AsyncCallback(SendAllDeviceStatesCallback), null);
}
}
catch (Exception ex)
{
this.BeginInvoke(new MethodInvoker(delegate()
{
if (FrmControlMonitor.FormInstance.GetObjectText("tsStatus").IndexOf("SendAllDeviceStatesCallback时:" + ex.Message) < 0)
{
FrmControlMonitor.FormInstance.FlashPanit("tsStatus", "SendAllDeviceStatesCallback时:" + ex.Message, true);
}
}));
ReRegisterClient();
}
}
private void MITransportTimeout_Click(object sender, EventArgs e)
{
FrmTransportTimeout.FormInstance.Show();
}
private void MISeeDarket_Click(object sender, EventArgs e)
{
FrmBrowseDarkCasket.FormInstance.Show();
}
private void MIDarketFileSet_Click(object sender, EventArgs e)
{
FrmDarkCasket.FormInstance.Show();
}
private void MIAutoTaskHistory_Click(object sender, EventArgs e)
{
FrmBrowseAotoTaskLog.FormInstance.Show();
}
private void MIUserInfoManage_Click(object sender, EventArgs e)
{
FrmUsers.FormInstance.Show();
}
private void MIAltPassword_Click(object sender, EventArgs e)
{
FrmPassword.FormInstance.Show();
}
private void MMExitSystem_Click(object sender, EventArgs e)
{
this.Close();
}
private void toolStripMenuItem10_Click(object sender, EventArgs e)
{
this.Visible = false;
}
private void toolStripMenuItem8_Click(object sender, EventArgs e)
{
this.Visible = true;
this.WindowState = FormWindowState.Maximized;
}
private void toolStripMenuItem9_Click(object sender, EventArgs e)
{
this.Close();
}
private void ctrl_Click(object sender, EventArgs e)
{
Button btn = (Button)sender;
_deviceStatus.DeviceIndex = Convert.ToInt32(btn.Tag);
_deviceStatus.ShowDialog();
}
private void ctrl_ClickTxt(object sender, EventArgs e)
{
TextBox txt = (TextBox)sender;
_worstation.DeviceIndex = Convert.ToInt32(txt.Tag);
_worstation.ShowDialog();
}
private void ctrl_ClickPic(object sender, EventArgs e)
{
PictureBox btn = (PictureBox)sender;
_deviceStatus.DeviceIndex = Convert.ToInt32(btn.Tag);
_deviceStatus.ShowDialog();
}
void ReConnectAndRegisterClient()
{
try
{
CStaticClass.ClientID = Dns.GetHostName();
var ctx = new InstanceContext(CStaticClass.client);
CStaticClass.WcfControl = new WcfControlMonitor.ControlMonitorClient(ctx);
string errtext = string.Empty;
CommonClassLib.CCarryConvert.WriteDarkCasket("Login", "UserID:" + CStaticClass.UserID + "的操作日志", "尝试重新连接", "", "");
CStaticClass.WcfControl.BeginRegisterClient(CStaticClass.UserID, "客户端:" + CStaticClass.ClientID + ",用户名:" + CStaticClass.UserID, new AsyncCallback(ReConnectAndRegisterClientCallBack), null);
}
catch(Exception ex)
{
throw ex;
}
}
void ReConnectAndRegisterClientCallBack(IAsyncResult ar)
{
try
{
string ErrText = string.Empty;
if (false == CStaticClass.WcfControl.EndRegisterClient(out ErrText, ar))
{
//MessageBox.Show(ErrText, "登陆错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
CStaticClass.WCFOK = false;
return;
}
CommonClassLib.CCarryConvert.WriteDarkCasket("Login", "UserID:" + CStaticClass.UserID + "的操作日志", "重连**成功登录系统", "", "");
//CStaticClass.WcfControl.BeginSendAllDeviceStates(CStaticClass.client.devlist[0].DeviceIndex, new AsyncCallback(CStaticClass.client.SendAllDeviceStatesCallback), null);
CStaticClass.WCFOK = true;
}
catch (Exception ex)
{
//MessageBox.Show(ex.Message, "登陆错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
CStaticClass.WCFOK = false;
return;
}
}
void ReRegisterClient()
{
//CStaticClass.ClientID = Dns.GetHostName();
//var ctx = new InstanceContext(CStaticClass.client);
//CStaticClass.WcfControl = new WcfControlMonitor.ControlMonitorClient(ctx);
//string errtext = string.Empty;
//CStaticClass.WcfControl.BeginRegisterClient(CStaticClass.UserID, "客户端:" + CStaticClass.ClientID + ",用户名:" + CStaticClass.UserID, new AsyncCallback(RegisterClientCallBack), null);
}
void RegisterClientCallBack(IAsyncResult ar)
{
try
{
string ErrText;
if (CStaticClass.WcfControl.EndRegisterClient(out ErrText, ar) == true)
{
CStaticClass.WCFOK = true;
devsn++;
if (devsn < devlist.Count())
{
CStaticClass.WcfControl.BeginSendAllDeviceStates(devlist[devsn].DeviceIndex, new AsyncCallback(SendAllDeviceStatesCallback), null);
}
else
{
devsn = 0;
CStaticClass.WcfControl.BeginSendAllDeviceStates(devlist[devsn].DeviceIndex, new AsyncCallback(SendAllDeviceStatesCallback), null);
}
}
else
{
CStaticClass.WcfControl.BeginLogoutClient("客户端:" + CStaticClass.ClientID + ",用户名:" + CStaticClass.UserID, new AsyncCallback(LogCallBack), "RegisterClientCallBack");
this.BeginInvoke(new MethodInvoker(delegate()
{
if (FrmControlMonitor.FormInstance.GetObjectText("tsStatus").IndexOf("EndRegisterClient时:" + ErrText) < 0)
{
FrmControlMonitor.FormInstance.FlashPanit("tsStatus", "EndRegisterClient时:" + ErrText, true);
}
//if (tsStatus.Text.IndexOf("EndRegisterClient时:" + ErrText) < 0)
// {
// tsStatus.ForeColor = Color.Red;
// this.tsStatus.Text += "EndRegisterClient时:" + ErrText;
// }
}));
}
}
catch (Exception ex)
{
this.BeginInvoke(new MethodInvoker(delegate()
{
if (FrmControlMonitor.FormInstance.GetObjectText("tsStatus").IndexOf("EndRegisterClient时:" + ex.Message) < 0)
{
FrmControlMonitor.FormInstance.FlashPanit("tsStatus", "EndRegisterClient时:" + ex.Message, true);
}
// if (tsStatus.Text.IndexOf("EndRegisterClient时:" + ex.Message) < 0)
//{
// tsStatus.ForeColor = Color.Red;
// this.tsStatus.Text += "EndRegisterClient时:" + ex.Message;
//}
}));
}
}
private void MIStartRetrieveTask_Click(object sender, EventArgs e)
{
try
{
ClickObtainTask();
CStaticClass.WcfControl.BeginObtainTask("", "UPDATE", new AsyncCallback(CallbackObtainTask), null);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
private void MIStopRetrieveTask_Click(object sender, EventArgs e)
{
try
{
ClickStopObtainTask();
CStaticClass.WcfControl.BeginStopObtainTask(new AsyncCallback(CallbackStopObtainTask), null);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
private void MITurnOn_Click(object sender, EventArgs e)
{
try
{
ClickOrderTurnOn();
CStaticClass.WcfControl.BeginOrderTurnOn(new AsyncCallback(CallbackTurnOn), null);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
private void MITurnOff_Click(object sender, EventArgs e)
{
if (MessageBox.Show("您确认要“关闭命令开关”吗?如果“关闭命令开关”将导致调度计算机与所有设备通讯中断!", "操作提示:", MessageBoxButtons.OKCancel, MessageBoxIcon.Warning) != DialogResult.OK)
{
return;
}
try
{
ClickOrderTurnOff();
CStaticClass.WcfControl.BeginOrderTurnOff(new AsyncCallback(CallbackTurnOff), null);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "提示", MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
private void MISystemInit_Click(object sender, EventArgs e)
{
FrmSystemInit.FormInstance.Show();
}
void CallbackObtainTask(IAsyncResult ar)
{
CStaticClass.WcfControl.EndObtainTask(ar);
}
void CallbackStopObtainTask(IAsyncResult ar)
{
CStaticClass.WcfControl.EndStopObtainTask(ar);
}
void CallbackTurnOn(IAsyncResult ar)
{
CStaticClass.WcfControl.EndOrderTurnOn(ar);
}
void CallbackTurnOff(IAsyncResult ar)
{
CStaticClass.WcfControl.EndOrderTurnOff(ar);
}
void CallBackHeartbeat(IAsyncResult ar)
{
this.BeginInvoke(new MethodInvoker(delegate()
{
try
{
string errtext = string.Empty;
Model.MonitorInfo mi;
CStaticClass.WcfControl.EndHeartbeat(out mi, ar);
if (CStaticClass.UserID.ToUpper() == "SA")
{
CStaticClass.Order =mi.Orderturnon ;
CStaticClass.ObtainManageTask = mi.Obtaintask;
if (mi.Orderturnon == true)
{
ClickOrderTurnOn();
}
else
{
ClickOrderTurnOff();
}
if (mi.Obtaintask == true)
{
ClickObtainTask();
}
else
{
ClickStopObtainTask();
}
}
if (mi.S7connectOnline.Count > 0)
{
if (mi.S7connectOnline.ContainsKey("S7 connection_1") && mi.S7connectOnline["S7 connection_1"] == 0 && mi.Orderturnon == true)
{
MMPLCStatus1.Image = wcfControlMonitorClient.Properties.Resources.linkok;
MMPLCStatus1.ToolTipText = "与PLC连接成功";
}
else
{
if (mi.S7connectOnline.ContainsKey("@LOCALSERVER") && mi.S7connectOnline["@LOCALSERVER"] == 0 && mi.Orderturnon == true)
{
MMPLCStatus1.Image = wcfControlMonitorClient.Properties.Resources.linkok;
MMPLCStatus1.ToolTipText = "与PLC连接成功";
}
else
{
MMPLCStatus1.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMPLCStatus1.ToolTipText = "与PLC连接失败";
}
}
if (mi.S7connectOnline.ContainsKey("S7 connection_2") && mi.S7connectOnline["S7 connection_2"] == 0)
{
MMPLCStatus2.Image = wcfControlMonitorClient.Properties.Resources.linkok;
MMPLCStatus2.ToolTipText = "与PLC连接成功";
}
else
{
MMPLCStatus2.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMPLCStatus2.ToolTipText = "与PLC连接失败";
}
if (mi.S7connectOnline.ContainsKey("S7 connection_3") && mi.S7connectOnline["S7 connection_3"] == 0)
{
MMPLCStatus3.Image = wcfControlMonitorClient.Properties.Resources.linkok;
MMPLCStatus3.ToolTipText = "与PLC连接成功";
}
else
{
MMPLCStatus3.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMPLCStatus3.ToolTipText = "与PLC连接失败";
}
if (mi.S7connectOnline.ContainsKey("S7 connection_4") && mi.S7connectOnline["S7 connection_4"] == 0)
{
MMPLCStatus4.Image = wcfControlMonitorClient.Properties.Resources.linkok;
MMPLCStatus4.ToolTipText = "与PLC连接成功";
}
else
{
MMPLCStatus4.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMPLCStatus4.ToolTipText = "与PLC连接失败";
}
}
else
{
MMPLCStatus1.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMPLCStatus1.ToolTipText = "与PLC连接失败";
MMPLCStatus2.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMPLCStatus2.ToolTipText = "与PLC连接失败";
MMPLCStatus3.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMPLCStatus3.ToolTipText = "与PLC连接失败";
MMPLCStatus4.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
MMPLCStatus4.ToolTipText = "与PLC连接失败";
}
foreach (string ip in mi.TcpIPInitCount.Keys.ToArray())
{
int deviceindex = 0;
StringBuilder sql = new StringBuilder();
sql.Append("select f_deviceindex from T_Base_device where F_remoteip = '").Append(ip).Append("'");
DataView dv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
if (dv.Count > 0)
{
deviceindex = Convert.ToInt32(dv[0]["f_deviceindex"]);
}
if (mi.TcpIPInitCount[ip] == 0)
{
if (deviceindex == 1001)
{
MMAGVStatus1.Image = wcfControlMonitorClient.Properties.Resources.linkok;
}
else if (deviceindex == 1002)
{
MMAGVStatus2.Image = wcfControlMonitorClient.Properties.Resources.linkok;
}
}
else
{
if (deviceindex == 1001)
{
MMAGVStatus1.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
}
else if (deviceindex == 1002)
{
MMAGVStatus2.Image = wcfControlMonitorClient.Properties.Resources.linkerror;
}
}
}
}
catch (Exception ex)
{
if (FrmControlMonitor.FormInstance.GetObjectText("tsStatus").IndexOf("CallBackHeartbeat时:" + ex.Message) < 0)
{
FrmControlMonitor.FormInstance.FlashPanit("tsStatus", "CallBackHeartbeat时:" + ex.Message, true);
}
//if (tsStatus.Text.IndexOf("CallBackHeartbeat时:" + ex.Message) < 0)
//{
// tsStatus.ForeColor = Color.Red;
// this.tsStatus.Text += "CallBackHeartbeat时:" + ex.Message;
//}
ReRegisterClient();
}
}));
}
void ClickObtainTask()
{
if (MITurnOn.Checked == true)
{
if (this.Text != CStaticClass.SystemName + "【开始获取任务!】" + "【正在执行自动命令!】")
{
this.Text = CStaticClass.SystemName + "【开始获取任务!】" + "【正在执行自动命令!】";
}
}
else
{
if (this.Text != CStaticClass.SystemName + "【开始获取任务!】")
{
this.Text = CStaticClass.SystemName + "【开始获取任务!】";
}
}
MIStartRetrieveTask.Checked = true;
MIStartRetrieveTask.Enabled = false;
MIStopRetrieveTask.Checked = false;
MIStopRetrieveTask.Enabled = true;
}
void ClickStopObtainTask()
{
if (MITurnOn.Checked == true)
{
if (this.Text != CStaticClass.SystemName + "【正在执行自动命令!】")
{
this.Text = CStaticClass.SystemName + "【正在执行自动命令!】";
}
}
else
{
if (this.Text != CStaticClass.SystemName)
{
this.Text = CStaticClass.SystemName;
}
}
MIStartRetrieveTask.Checked = false;
MIStartRetrieveTask.Enabled = true;
MIStopRetrieveTask.Enabled = false;
MIStopRetrieveTask.Checked = true;
}
void ClickOrderTurnOn()
{
if (MIStartRetrieveTask.Checked == true)
{
if (this.Text != CStaticClass.SystemName + "【开始获取任务!】" + "【正在执行自动命令!】")
{
this.Text = CStaticClass.SystemName + "【开始获取任务!】" + "【正在执行自动命令!】";
}
}
else
{
if (this.Text != CStaticClass.SystemName + "【正在执行自动命令!】")
{
this.Text = CStaticClass.SystemName + "【正在执行自动命令!】";
}
}
MITurnOff.Enabled = true;
MITurnOn.Enabled = false;
MITurnOff.Checked = false;
MITurnOn.Checked = true;
}
void ClickOrderTurnOff()
{
if (MIStartRetrieveTask.Checked == true)
{
if (this.Text != CStaticClass.SystemName + "【开始获取任务!】")
{
this.Text = CStaticClass.SystemName + "【开始获取任务!】";
}
}
else
{
if (this.Text != CStaticClass.SystemName)
{
this.Text = CStaticClass.SystemName;
}
}
MITurnOff.Enabled = false;
MITurnOn.Enabled = true;
MITurnOn.Checked = false;
MITurnOff.Checked = true;
}
private void MISystemInit2_Click(object sender, EventArgs e)
{
FrmSystemInit.FormInstance.Show();
}
private void MIManageConnectInfo_Click(object sender, EventArgs e)
{
FrmConnectDB.FormInstance.ConnectType = "Manage";
FrmConnectDB.FormInstance.Show();
}
public bool IsEquals(Array array1, Array array2, int arraylength)
{//20090902新增加arraylength
//比较类型是否一样
if ((array1 == null) || (array2 == null)) return false;
if (!Object.ReferenceEquals(array1.GetType(), array2.GetType()))
{
return false;
}
//比较长度是否一样
if (array1.GetLength(0) != array2.GetLength(0))
{
return false;
}
//比较成员是否对应相等
ValueType v1, v2;
for (int i = 0; i < arraylength; i++)
{
v1 = (ValueType)array1.GetValue(i);
v2 = (ValueType)array2.GetValue(i);
if (!v1.Equals(v2))
{
return false;
}
}
return true;
}
string GetBarcodeFromMonitorIndex(int taskindex)
{
DataView dvb = new DataView(); StringBuilder sss = new StringBuilder("");
try
{
sss.Append("SELECT F_TxtParam FROM T_Monitor_Task WHERE (F_MonitorIndex = ").Append(taskindex).Append(")");
dvb = dbo.ExceSQL(sss.ToString()).Tables[0].DefaultView;
if (dvb.Count > 0)
{
return dvb[0]["F_TxtParam"].ToString();
}
else
{
return "-";
}
}
catch (Exception ex)
{
throw ex;
}
finally
{
dvb.Dispose();
}
}
int GetMonitorRunTaskIndexFromBarCode(StringBuilder BarCode)
{//20110216
DataView dv = new DataView();
try
{
string bc = BarCode.ToString();
dv = dbo1.ExceSQL(string.Format("SELECT T_Monitor_Task.F_MonitorIndex FROM T_Base_Device,T_Monitor_Task WHERE T_Base_Device.F_DeviceIndex = T_Monitor_Task.F_DeviceIndex and ((T_Base_Device.F_DeviceKindIndex = 13) OR (T_Base_Device.F_DeviceKindIndex = 31)) and (F_TxtParam = '{0}') and F_Status>0 order by F_MonitorIndex asc", bc)).Tables[0].DefaultView;
if (dv.Count > 0)
{
return Convert.ToInt32(dv[0]["F_MonitorIndex"]);
}
else
{
return -1;
}
}
catch (Exception ex)
{
throw ex;
}
finally
{
dv.Dispose();
}
}
int GetMonitorAskTaskIndexFromBarCode(StringBuilder BarCode)
{//20110216
DataView dv = new DataView();
try
{
string bc = BarCode.ToString();
dv = dbo.ExceSQL(string.Format("SELECT T_Monitor_Task.F_MonitorIndex FROM T_Base_Device,T_Monitor_Task WHERE T_Base_Device.F_DeviceIndex = T_Monitor_Task.F_DeviceIndex and ((T_Base_Device.F_DeviceKindIndex = 13) OR (T_Base_Device.F_DeviceKindIndex = 31)) and (F_TxtParam = '{0}') and ((F_Status>0) or (F_SendFlag=2 and F_Status=0)) and F_DeviceCommandIndex=6 order by F_MonitorIndex asc", bc)).Tables[0].DefaultView;
if (dv.Count > 0)
{
return Convert.ToInt32(dv[0]["F_MonitorIndex"]);
}
else
{
return -1;
}
}
catch (Exception ex)
{
throw ex;
}
finally
{
dv.Dispose();
}
}
int GetMonitorTaskIndexFromBarCode(StringBuilder BarCode, Model.MDevice devinf)
{//20110216
DataView dv = new DataView();
try
{
string bc = BarCode.ToString();
dv = dbo.ExceSQL(string.Format("SELECT T_Monitor_Task.F_MonitorIndex FROM T_Base_Device,T_Monitor_Task WHERE T_Base_Device.F_DeviceIndex = T_Monitor_Task.F_DeviceIndex and ((T_Base_Device.F_DeviceKindIndex = 13) OR (T_Base_Device.F_DeviceKindIndex = 31)) and (F_TxtParam = '{0}') and (F_NumParam4 = {1} or F_NumParam4 = {2}) and F_Status>0 order by F_MonitorIndex asc", bc, devinf.DeviceIndex, devinf.DeviceVisual)).Tables[0].DefaultView;
if (dv.Count > 0)
{
return Convert.ToInt32(dv[0]["F_MonitorIndex"]);
}
else
{
//dv = dbo.ExceSQL(string.Format("SELECT T_Monitor_Task.F_MonitorIndex FROM T_Base_Device,T_Monitor_Task WHERE T_Base_Device.F_DeviceIndex = T_Monitor_Task.F_DeviceIndex and ((T_Base_Device.F_DeviceKindIndex = 13) OR (T_Base_Device.F_DeviceKindIndex = 31)) and (F_TxtParam = '{0}') and F_Status>0 order by F_MonitorIndex asc", bc)).Tables[0].DefaultView;
//if (dv.Count > 0)
//{
// return Convert.ToInt32(dv[0]["F_MonitorIndex"]);
//}
//else
//{
return -1;
//}
}
}
catch (Exception ex)
{
throw ex;
}
finally
{
dv.Dispose();
}
}
string GetMonitorTaskStartTime(int taskindex, out int order)
{//20110216
DataView dv = new DataView();
try
{
dv = dbo.ExceSQL(string.Format("SELECT F_StartTime,F_DeviceCommandIndex FROM T_Monitor_Task WHERE F_MonitorIndex={0}", taskindex)).Tables[0].DefaultView;
if (dv.Count > 0)
{
order = Convert.ToInt32(dv[0]["F_DeviceCommandIndex"]);
return dv[0]["F_StartTime"].ToString();
}
else
{
order = -1;
return "-";
}
}
catch (Exception ex)
{
throw ex;
}
finally
{
dv.Dispose();
}
}
private void MIZCKSetIO_Click(object sender, EventArgs e)
{
FrmZCKSetIOStation.FormInstance.Show();
}
private void MIErrorSolutions_Click(object sender, EventArgs e)
{//20151120
FrmDeviceErrorSolutions.FormInstance.Show();
}
private void MITaskCount_Click(object sender, EventArgs e)
{//20151120
FrmTaskManage.FormInstance.Show();
}
private void MIErrorRecord_Click(object sender, EventArgs e)
{
FrmDeviceErrorLog.FormInstance.Show();
}
private void MIBrowseInterface_Click(object sender, EventArgs e)
{
FrmBrowseInterFace.FormInstance.Show();
}
private void MIBrowseActivation_Click(object sender, EventArgs e)
{
FrmBrowseActivation.FormInstance.Show();
}
private void button1_Click(object sender, EventArgs e)
{
//label1.Text = CStaticClass.WcfControl.State.ToString();
////if (CStaticClass.WcfControl.State == CommunicationState.Faulted)
////{
////}
}
private void MIActivation_Click(object sender, EventArgs e)
{
FrmBrowseActivation.FormInstance.Show();
}
private void MIDarketFileSet1_Click(object sender, EventArgs e)
{
FrmDarkCasket.FormInstance.Show();
}
private void MIErrorSolutions_Click_1(object sender, EventArgs e)
{
FrmDeviceErrorSolutions.FormInstance.Show();
}
private void MIApplyHistory_Click(object sender, EventArgs e)
{
FrmBrowseApplyLog.FormInstance.Show();
}
private void MIBrowseRGVInterface_Click(object sender, EventArgs e)
{
FrmBrowseRGVInterFace.FormInstance.Show();
}
private void MIPalletCacheSetting_Click(object sender, EventArgs e)
{
FrmPalletKindSetting.FormInstance.Show();
}
}
}