Main.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648
  1. using System;
  2. using DevExpress.XtraBars;
  3. using UAS_DeviceMonitor.DataOperate;
  4. using System.Data;
  5. using System.Text;
  6. using UAS_DeviceMonitor.Entity;
  7. using UAS_DeviceMonitor.PublicMethod;
  8. using DevExpress.XtraGrid.Views.Grid;
  9. using System.Collections.Generic;
  10. using System.Drawing;
  11. using DevExpress.XtraBars.Ribbon;
  12. using System.Threading;
  13. using UAS_DeviceMonitor.CustomerControl.PictureEditWithText;
  14. using System.Windows.Forms;
  15. using DevExpress.XtraEditors.Controls;
  16. using DevExpress.XtraEditors;
  17. using UAS_DeviceMonitor.Device.Infomation;
  18. namespace UAS_DeviceMonitor
  19. {
  20. public partial class Main : RibbonForm
  21. {
  22. StringBuilder sql = new StringBuilder();
  23. //用于设备状态查询界面SQL查看
  24. StringBuilder DeviceStatusQuerySQL = new StringBuilder();
  25. DataHelper dh;
  26. ModeBusTCPServer mbt = new ModeBusTCPServer();
  27. List<string> SQL = new List<string>();
  28. #region 初始化代码
  29. public Main()
  30. {
  31. dh = new DataHelper();
  32. SystemInf.dh = dh;
  33. InitializeComponent();
  34. dpc_enableCheckEdit.QueryCheckStateByValue += CheckedEdit_QueryCheckStateByValue;
  35. CommandSetRepositoryItemComboBox1.ParseEditValue += CommandSetRepositoryItemComboBox1_ParseEditValue;
  36. CheckEditCommandSet.QueryCheckStateByValue += CheckedEdit_QueryCheckStateByValue;
  37. PollSettingItemSearchLookUpEdit.ParseEditValue += PollSettingItemSearchLookUpEdit_ParseEditValue;
  38. GridViewPollSetting.RowCellStyle += GridViewPollSetting_RowCellStyle;
  39. #region 添加发送接收编码规则的静态值
  40. ComboBoxData cbd = new ComboBoxData();
  41. cbd.Text = "UTF-8";
  42. cbd.Value = "UTF-8";
  43. ComboBoxData cbd1 = new ComboBoxData();
  44. cbd1.Text = "Hexadecimal";
  45. cbd1.Value = "Hexadecimal";
  46. ComboBoxData cbd2 = new ComboBoxData();
  47. cbd2.Text = "ASCII";
  48. cbd2.Value = "ASCII";
  49. CommandSetRepositoryItemComboBox1.Items.Add(cbd);
  50. CommandSetRepositoryItemComboBox1.Items.Add(cbd1);
  51. CommandSetRepositoryItemComboBox1.Items.Add(cbd2);
  52. #endregion
  53. }
  54. private void CommandSetRepositoryItemComboBox1_ParseEditValue(object sender, ConvertEditValueEventArgs e)
  55. {
  56. string val = "";
  57. if (e.Value != null)
  58. {
  59. val = e.Value.ToString();
  60. }
  61. else
  62. {
  63. val = "FALSE";//默认为不选
  64. }
  65. e.Value = val;
  66. e.Handled = true;
  67. }
  68. private void PollSettingItemSearchLookUpEdit_ParseEditValue(object sender, ConvertEditValueEventArgs e)
  69. {
  70. e.Handled = true;
  71. }
  72. private void Main_Load(object sender, EventArgs e)
  73. {
  74. //设备列表
  75. GridDeviceList.GetDataSQL = "select de_id,de_code,de_name,de_spec,de_indate,de_runstatus,de_address,de_wccode,de_vendcode,de_vendname from device order by de_code".ToUpper();
  76. ToolPageControlDeviceList.Gridcontrol = GridDeviceList;
  77. //轮询业务
  78. //GridPolling.GetDataSQL = "select 0 CHECKEDCOLUMN,pl_id,pl_code,pl_name,pl_type,pl_dccode,pl_remark from polling".ToUpper();
  79. //GridPolling.ID = "pl_id";
  80. //GridPolling.TableName = "polling";
  81. //GridPolling.InsertSQL = "insert into polling(pl_id,pl_code,pl_name,pl_type,pl_dccode,pl_remark) values(polling_seq.nextval,:pl_code,:pl_name,:pl_type,:pl_dccode,:pl_remark)";
  82. //ButtonDeletePolling.Grid = GridPolling;
  83. //ButtonSavePolling.Grid = GridPolling;
  84. //ButtonAddPolling.Grid = GridPolling;
  85. //轮询配置界面
  86. GridPollingSetting.GetDataSQL = "SELECT '' POLLSETTINGSTATUSCOLUMN,0 CHECKEDCOLUMN,DPC_ID,DPC_DECODE ,DPC_INTERVAL ,DPC_DCCODE ,DPC_FUNCTION , nvl(DPC_ENABLE,0)DPC_ENABLE,DPC_STATUS ,DPC_REMARK FROM DEVICEPOLLINGCONFIG ORDER BY DPC_ID";
  87. GridPollingSetting.ID = "DPC_ID";
  88. GridPollingSetting.TableName = "DEVICEPOLLINGCONFIG";
  89. GridPollingSetting.InsertSQL = "insert into DEVICEPOLLINGCONFIG(DPC_ID,DPC_DECODE ,DPC_INTERVAL ,DPC_DCCODE ,DPC_FUNCTION , DPC_ENABLE,DPC_STATUS ,DPC_REMARK) values(DEVICEPOLLINGCONFIG_seq.nextval,:DPC_DECODE ,:DPC_INTERVAL ,:DPC_DCCODE ,:DPC_FUNCTION , :DPC_ENABLE,:DPC_STATUS ,:DPC_REMARK)";
  90. ButtonSaveCommandSet.Grid = GridPollingSetting;
  91. ButtonNewCommandSet.Grid = GridPollingSetting;
  92. ButtonDeleteCommandSet.Grid = GridPollingSetting;
  93. //指令设置界面
  94. GridCommandSetting.GetDataSQL = "select 0 CHECKEDCOLUMN,dc_id,dc_code,dc_name,dc_value,dc_sendcoding,dc_receivecoding from devicecommand ".ToUpper();
  95. GridCommandSetting.TableName = "devicecommand";
  96. GridCommandSetting.ID = "dc_id";
  97. GridCommandSetting.InsertSQL = "insert into devicecommand(dc_id,dc_code,dc_name,dc_value,dc_debrand,dc_sendcoding,dc_receivecoding) values(devicecommand_seq.nextval,:dc_code,:dc_name,:dc_value,'" + BaseUtil.GetComboxEditValue(Brand) + "',:dc_sendcoding,:dc_receivecoding)";
  98. ButtonSaveCommand.Grid = GridCommandSetting;
  99. ButtonDeleteCommand.Grid = GridCommandSetting;
  100. ButtonNewCommand.Grid = GridCommandSetting;
  101. //设备联网配置界面
  102. GridDeviceNetSetting.GetDataSQL = "SELECT 0 CHECKEDCOLUMN,DNC_ID,DNC_DECODE,DNC_GATEWAY,DNC_UPPERIP,DNC_PORT,DNC_MAC,DNC_IP,DNC_TYPE FROM DEVICENETCONFIG order by DNC_ID";
  103. GridDeviceNetSetting.ID = "dnc_id";
  104. GridDeviceNetSetting.TableName = "DEVICENETCONFIG";
  105. GridDeviceNetSetting.InsertSQL = "insert into DEVICENETCONFIG(DNC_ID,DNC_DECODE,DNC_GATEWAY,DNC_UPPERIP,DNC_PORT,DNC_MAC,DNC_IP,DNC_TYPE) values(DEVICENETCONFIG_SEQ.NEXTVAL,:DNC_DECODE,:DNC_GATEWAY,:DNC_UPPERIP,:DNC_PORT,:DNC_MAC,:DNC_IP,:DNC_TYPE)";
  106. ButtonDeleteNetConfig.Grid = GridDeviceNetSetting;
  107. ButtonAddNetConfig.Grid = GridDeviceNetSetting;
  108. ButtonSaveNetConfig.Grid = GridDeviceNetSetting;
  109. Ptime = new Dictionary<int, PollingTimer>();
  110. }
  111. #endregion
  112. #region 设备列表界面
  113. private void GridViewDeviceList_RowCellClick(object sender, RowCellClickEventArgs e)
  114. {
  115. string de_code = GridViewDeviceList.GetRowCellValue(e.RowHandle, "DE_CODE").ToString();
  116. DeviceDetailInfo ddi = new DeviceDetailInfo(de_code);
  117. ddi.StartPosition = FormStartPosition.CenterScreen;
  118. ddi.ShowDialog();
  119. }
  120. #endregion
  121. #region 界面通用事件
  122. /// <summary>
  123. /// 选项卡切换不同XPage
  124. /// </summary>
  125. /// <param name="sender"></param>
  126. /// <param name="e"></param>
  127. private void ButtonItem_ItemClick(object sender, ItemClickEventArgs e)
  128. {
  129. HideXPage(e.Item.Tag.ToString());
  130. }
  131. /// <summary>
  132. /// 根据点击按钮的Tag显示对应的XPage
  133. /// </summary>
  134. /// <param name="PageName"></param>
  135. private void HideXPage(string PageName)
  136. {
  137. for (int i = 0; i < MainTabControl.TabPages.Count; i++)
  138. {
  139. if (MainTabControl.TabPages[i].Name == PageName)
  140. MainTabControl.TabPages[i].PageVisible = true;
  141. else
  142. MainTabControl.TabPages[i].PageVisible = false;
  143. }
  144. }
  145. /// <summary>
  146. /// 勾选Grid的CheckBox
  147. /// </summary>
  148. /// <param name="sender"></param>
  149. /// <param name="e"></param>
  150. private void CheckedEdit_QueryCheckStateByValue(object sender, DevExpress.XtraEditors.Controls.QueryCheckStateByValueEventArgs e)
  151. {
  152. string val = "";
  153. if (e.Value != null)
  154. {
  155. val = e.Value.ToString();
  156. }
  157. else
  158. {
  159. val = "FALSE";//默认为不选
  160. }
  161. switch (val.ToUpper())
  162. {
  163. case "TRUE":
  164. case "YES":
  165. case "1":
  166. e.CheckState = System.Windows.Forms.CheckState.Checked;
  167. break;
  168. case "FALSE":
  169. case "NO":
  170. case "0":
  171. e.CheckState = System.Windows.Forms.CheckState.Unchecked;
  172. break;
  173. default:
  174. e.CheckState = System.Windows.Forms.CheckState.Checked;
  175. break;
  176. }
  177. e.Handled = true;
  178. }
  179. #endregion
  180. #region PageCommandSet业务代码(指令设置)
  181. /// <summary>
  182. /// 判断指令编号不能重复
  183. /// </summary>
  184. /// <param name="sender"></param>
  185. /// <param name="e"></param>
  186. private void ButtonSaveCommand_Click(object sender, EventArgs e)
  187. {
  188. GridCommandSetting.InsertSQL = "insert into devicecommand(dc_id,dc_code,dc_name,dc_value,dc_debrand,dc_sendcoding,dc_receivecoding) values(devicecommand_seq.nextval,:dc_code,:dc_name,:dc_value,'" + BaseUtil.GetComboxEditValue(Brand) + "',:dc_sendcoding,:dc_receivecoding)";
  189. ButtonSaveCommand.DoSave();
  190. }
  191. /// <summary>
  192. /// 加载ComBox品牌数据
  193. /// </summary>
  194. /// <param name="sender"></param>
  195. /// <param name="e"></param>
  196. private void PageCommandSet_VisibleChanged(object sender, EventArgs e)
  197. {
  198. if (PageCommandSet.PageVisible)
  199. {
  200. DataTable dt = (DataTable)SystemInf.dh.ExecuteSql("select * from devicebrand", "select");
  201. BaseUtil.FillComBoxEditWidthDataTable(Brand, "db_name", "db_code", dt);
  202. GridCommandSetting.Condition = " where dc_debrand='" + BaseUtil.GetComboxEditValue(Brand) + "' order by dc_id";
  203. }
  204. }
  205. private void Brand_SelectedIndexChanged(object sender, EventArgs e)
  206. {
  207. GridCommandSetting.Condition = " where dc_debrand='" + BaseUtil.GetComboxEditValue(Brand) + "' order by dc_id";
  208. GridCommandSetting.RefreshData();
  209. }
  210. #endregion
  211. #region PagePollingSetting业务代码(轮询配置)
  212. PollingTask pt = new PollingTask();
  213. /// <summary>
  214. /// 绘制轮询配置状态栏
  215. /// </summary>
  216. List<int> PollSettingPaintRowIndex = new List<int>();
  217. private void ButtonStartPolling_Click(object sender, EventArgs e)
  218. {
  219. GridView grid = GridViewPollSetting;
  220. mbt.Open();
  221. for (int i = 0; i < GridPollingSetting.RowCount; i++)
  222. {
  223. Polling pl = new Polling();
  224. pl.Id = int.Parse(GridViewPollSetting.GetRowCellValue(i, "DPC_ID").ToString());
  225. pl.DeviceCode = GridViewPollSetting.GetRowCellValue(i, "DPC_DECODE").ToString();
  226. pl.CommandCode = GridViewPollSetting.GetRowCellValue(i, "DPC_DCCODE").ToString();
  227. pl.Interval = int.Parse(GridViewPollSetting.GetRowCellValue(i, "DPC_INTERVAL").ToString());
  228. pl.SendRadix = GridViewPollSetting.GetRowCellValue(i, "DPC_INTERVAL").ToString();
  229. pl.Enable = GridViewPollSetting.GetRowCellValue(i, "DPC_ENABLE").ToString() != "0";
  230. pl.Dh = new DataHelper();
  231. if (pl.Enable)
  232. {
  233. //插入轮询日志
  234. sql.Clear();
  235. sql.Append("insert into DEVICEPOLLINGLOG(dpg_id,dpg_decode,dpg_starttime,dpg_interval)values");
  236. sql.Append("(DEVICEPOLLINGLOG_seq.nextval,'" + pl.DeviceCode + "',sysdate,'" + pl.Interval + "')");
  237. dh.ExecuteSql(sql.ToString(), "insert");
  238. pt.AddTask(RunTask, pl);
  239. //添加到状态为运行的行
  240. PollSettingPaintRowIndex.Add(i);
  241. GridPollingSetting.Focus();
  242. }
  243. }
  244. }
  245. /// <summary>
  246. /// 绘制轮询状态
  247. /// </summary>
  248. /// <param name="sender"></param>
  249. /// <param name="e"></param>
  250. private void GridViewPollSetting_RowCellStyle(object sender, RowCellStyleEventArgs e)
  251. {
  252. if (e.Column.Name.ToUpper() == "POLLSETTINGSTATUSCOLUMN" && PollSettingPaintRowIndex.Contains(e.RowHandle))
  253. {
  254. e.Appearance.BackColor = Color.Green;
  255. }
  256. }
  257. Dictionary<int, PollingTimer> Ptime;
  258. private void RunTask(object i)
  259. {
  260. PollingTimer timer = new PollingTimer();
  261. Polling pl = (Polling)i;
  262. timer.Polling = i;
  263. timer.Interval = pl.Interval * 5000;
  264. timer.Elapsed += Timer_Tick;
  265. timer.Start();
  266. try
  267. {
  268. if (!Ptime.ContainsKey(pl.Id))
  269. Ptime.Add(pl.Id, timer);
  270. }
  271. catch (Exception)
  272. {
  273. if (!Ptime.ContainsKey(pl.Id))
  274. Ptime.Add(pl.Id, timer);
  275. }
  276. }
  277. /// <summary>
  278. /// 轮询执行的业务
  279. /// </summary>
  280. /// <param name="sender"></param>
  281. /// <param name="e"></param>
  282. private void Timer_Tick(object sender, EventArgs e)
  283. {
  284. PollingTimer timer = (PollingTimer)sender;
  285. Polling pl = (Polling)timer.Polling;
  286. DataHelper dh = pl.Dh;
  287. string Decode = pl.DeviceCode;
  288. string Dccode = pl.CommandCode;
  289. DataTable dt = (DataTable)dh.ExecuteSql("select dnc_ip,dnc_port from DEVICENETCONFIG where dnc_decode='" + Decode + "'", "select");
  290. DataTable dt1 = (DataTable)dh.ExecuteSql("select dc_sendcoding,dc_value,dc_receivecoding from devicecommand where dc_code='" + Dccode + "'", "select");
  291. if (dt.Rows.Count > 0)
  292. {
  293. string IP = dt.Rows[0]["dnc_ip"].ToString() + ":" + dt.Rows[0]["dnc_port"].ToString();
  294. string SendCoding = "";
  295. string ReceiveCoding = "";
  296. string Command = "";
  297. int SendCommandByteSize = 0;
  298. if (dt1.Rows.Count > 0)
  299. {
  300. SendCoding = dt1.Rows[0]["dc_sendcoding"].ToString();
  301. ReceiveCoding = dt1.Rows[0]["dc_receivecoding"].ToString();
  302. Command = dt1.Rows[0]["dc_value"].ToString();
  303. SendCommandByteSize = Encoding.Default.GetBytes(Command.ToCharArray()).Length;
  304. }
  305. mbt.Send(IP, SendCoding, ReceiveCoding, Command);
  306. //处理2秒之内返回的指令
  307. Thread.Sleep(1000);
  308. if (mbt.Returnvalue.ContainsKey(IP))
  309. {
  310. int ReceiveCommandByteSize = Encoding.Default.GetBytes(mbt.Returnvalue[IP].ToCharArray()).Length;
  311. mbt.Returnvalue.Remove(IP);
  312. SQL.Clear();
  313. //更新轮询状态
  314. sql.Clear();
  315. sql.Append("update DEVICEPOLLINGCONFIG set dpc_status='Running' where dpc_decode='" + Decode + "' and dpc_dccode='" + Dccode + "'");
  316. SQL.Add(sql.ToString());
  317. //更新轮询日志状态
  318. sql.Clear();
  319. sql.Append("update DEVICEPOLLINGLOG set dpg_status='Running',dpg_senddatasize=nvl(dpg_senddatasize,0)+" + SendCommandByteSize);
  320. sql.Append(",dpg_receivedatasize=nvl(dpg_receivedatasize,0)+" + ReceiveCommandByteSize + ",dpg_count=nvl(dpg_count,0)+1 ");
  321. sql.Append(" where dpg_id=(select max(dpg_id) from DEVICEPOLLINGLOG where dpg_decode='" + Decode + "')");
  322. SQL.Add(sql.ToString());
  323. dh.ExecuteSQLTran(SQL.ToArray());
  324. }
  325. else
  326. {
  327. SQL.Clear();
  328. //更新轮询状态
  329. sql.Clear();
  330. sql.Append("update DEVICEPOLLINGCONFIG set dpc_status='Stop' where dpc_decode='" + Decode + "' and dpc_dccode='" + Dccode + "'");
  331. SQL.Add(sql.ToString());
  332. //更新轮询日志状态
  333. sql.Clear();
  334. sql.Append("update DEVICEPOLLINGLOG set dpg_status='Running',dpg_senddatasize=nvl(dpg_senddatasize,0)+");
  335. sql.Append(SendCommandByteSize + ",dpg_count=nvl(dpg_count,0)+1 ");
  336. sql.Append("where dpg_id=(select max(dpg_id) from DEVICEPOLLINGLOG where dpg_decode='" + Decode + "')");
  337. SQL.Add(sql.ToString());
  338. dh.ExecuteSQLTran(SQL.ToArray());
  339. }
  340. }
  341. }
  342. /// <summary>
  343. /// 停止全部轮询
  344. /// </summary>
  345. /// <param name="sender"></param>
  346. /// <param name="e"></param>
  347. private void ButtonPausePolling_Click(object sender, EventArgs e)
  348. {
  349. foreach (var item in Ptime)
  350. {
  351. item.Value.Stop();
  352. }
  353. PollSettingPaintRowIndex.Clear();
  354. GridPollingSetting.Focus();
  355. Ptime.Clear();
  356. }
  357. private void GridViewPollSetting_CellValueChanging(object sender, DevExpress.XtraGrid.Views.Base.CellValueChangedEventArgs e)
  358. {
  359. GridViewPollSetting.SetRowCellValue(e.RowHandle, e.Column, e.Value);
  360. if (e.Column.Name.ToUpper() == "DPC_ENABLE")
  361. {
  362. if (GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ENABLE").ToString() == "0")
  363. {
  364. int id = int.Parse(GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ID").ToString());
  365. if (Ptime.ContainsKey(id))
  366. {
  367. Ptime[id].Stop();
  368. Ptime.Remove(id);
  369. PollSettingPaintRowIndex.Remove(e.RowHandle);
  370. }
  371. }
  372. else
  373. {
  374. Polling pl = new Polling();
  375. pl.Id = int.Parse(GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ID").ToString());
  376. pl.DeviceCode = GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_DECODE").ToString();
  377. pl.Interval = int.Parse(GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_INTERVAL").ToString());
  378. pl.Enable = GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ENABLE").ToString() != "0";
  379. pl.Dh = new DataHelper();
  380. if (pl.Enable)
  381. pt.AddTask(RunTask, pl);
  382. PollSettingPaintRowIndex.Add(e.RowHandle);
  383. }
  384. }
  385. }
  386. /// <summary>
  387. /// 设置GridView多选放大镜
  388. /// </summary>
  389. /// <param name="sender"></param>
  390. /// <param name="e"></param>
  391. private void PagePollingSetting_VisibleChanged(object sender, EventArgs e)
  392. {
  393. if (PagePollingSetting.PageVisible)
  394. {
  395. DataTable dt = (DataTable)SystemInf.dh.ExecuteSql("SELECT DC_CODE,DC_NAME,DC_REMARK FROM DEVICECOMMAND", "select");
  396. PollSettingItemSearchLookUpEdit.DataSource = dt;
  397. PollSettingItemSearchLookUpEdit.DisplayMember = "DC_CODE";
  398. PollSettingItemSearchLookUpEdit.ValueMember = "DC_CODE";
  399. }
  400. }
  401. #endregion
  402. #region 设备查看界面
  403. private void PageDeviceStatus_VisibleChanged(object sender, EventArgs e)
  404. {
  405. if (PageDeviceStatus.PageVisible)
  406. {
  407. DeviceStatusQuerySQL.Clear();
  408. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join DEVICEPOLLINGCONFIG on dpc_decode=de_code order by de_code");
  409. PaintDeviceStatusControl(DeviceStatusQuerySQL.ToString());
  410. //填充筛选条件,车间和线体
  411. DataTable dt = (DataTable)dh.ExecuteSql("select wc_code,wc_name from workcenter", "select");
  412. BaseUtil.FillComBoxEditWidthDataTable(ComboxDeviceStatusWC, "wc_name", "wc_code", dt, true);
  413. }
  414. }
  415. private void CheckEditDeviceStatusEnable_CheckedChanged(object sender, EventArgs e)
  416. {
  417. DeviceStatusQuerySQL.Clear();
  418. if (CheckEditDeviceStatusEnable.Checked)
  419. {
  420. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join DEVICEPOLLINGCONFIG ");
  421. DeviceStatusQuerySQL.Append("on dpc_decode=de_code where nvl(dpc_enable,0)<>0 order by de_code");
  422. }
  423. else
  424. {
  425. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join DEVICEPOLLINGCONFIG ");
  426. DeviceStatusQuerySQL.Append("on dpc_decode=de_code order by de_code");
  427. }
  428. PaintDeviceStatusControl(DeviceStatusQuerySQL.ToString());
  429. }
  430. private void ComboxDeviceStatusWC_SelectedIndexChanged(object sender, EventArgs e)
  431. {
  432. DeviceStatusQuerySQL.Clear();
  433. string WC = BaseUtil.GetComboxEditValue(ComboxDeviceStatusWC);
  434. if (CheckEditDeviceStatusEnable.Checked)
  435. {
  436. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join DEVICEPOLLINGCONFIG ");
  437. DeviceStatusQuerySQL.Append("on dpc_decode=de_code where nvl(dpc_enable,0)<>0 and de_wccode='" + WC + "' order by de_code");
  438. }
  439. else
  440. {
  441. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join DEVICEPOLLINGCONFIG ");
  442. DeviceStatusQuerySQL.Append("on dpc_decode=de_code where de_wccode='" + WC + "' order by de_code");
  443. }
  444. PaintDeviceStatusControl(DeviceStatusQuerySQL.ToString());
  445. sql.Clear();
  446. if (WC == "全部")
  447. sql.Append("select li_code,li_name from line");
  448. else
  449. sql.Append("select li_code,li_name from line where li_wccode='" + WC + "'");
  450. DataTable dt = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
  451. BaseUtil.FillComBoxEditWidthDataTable(ComboxDeviceStatusLC, "li_code", "li_name", dt, true);
  452. }
  453. private void ComboxDeviceStatusLC_SelectedIndexChanged(object sender, EventArgs e)
  454. {
  455. DeviceStatusQuerySQL.Clear();
  456. string WC = BaseUtil.GetComboxEditValue(ComboxDeviceStatusWC);
  457. string LC = BaseUtil.GetComboxEditValue(ComboxDeviceStatusLC);
  458. if (CheckEditDeviceStatusEnable.Checked)
  459. {
  460. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join ");
  461. DeviceStatusQuerySQL.Append("DEVICEPOLLINGCONFIG on dpc_decode=de_code where nvl(dpc_enable,0)<>0");
  462. if (WC != "全部")
  463. DeviceStatusQuerySQL.Append(" and de_wccode='" + WC + "' ");
  464. if (LC != "全部")
  465. DeviceStatusQuerySQL.Append(" and de_linecode='" + LC + "' ");
  466. DeviceStatusQuerySQL.Append(" order by de_code");
  467. }
  468. else
  469. {
  470. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join ");
  471. DeviceStatusQuerySQL.Append("DEVICEPOLLINGCONFIG on dpc_decode=de_code ");
  472. if (WC != "全部" && LC != "全部")
  473. DeviceStatusQuerySQL.Append(" where de_wccode='" + WC + "' and de_linecode='" + LC + "' ");
  474. if (WC == "全部" && LC != "全部")
  475. DeviceStatusQuerySQL.Append(" where de_linecode='" + LC + "' ");
  476. if (WC != "全部" && LC == "全部")
  477. DeviceStatusQuerySQL.Append(" where de_wccode='" + WC + "' ");
  478. DeviceStatusQuerySQL.Append("order by de_code");
  479. }
  480. PaintDeviceStatusControl(DeviceStatusQuerySQL.ToString());
  481. }
  482. private void PaintDeviceStatusControl(string SQL)
  483. {
  484. DataTable dt = (DataTable)dh.ExecuteSql(SQL, "select");
  485. //界面重新展示时如过数量不一致则重新绘制
  486. if (PanelDeviceStatus.Controls.Count != dt.Rows.Count)
  487. {
  488. PanelDeviceStatus.Controls.Clear();
  489. int CountPerRow = PanelDeviceStatus.Width / 110;
  490. int RightPadding = PanelDeviceStatus.Width % 110;
  491. int Count = dt.Rows.Count;
  492. int RowCount = Count % CountPerRow == 0 ? Count / CountPerRow : Count / CountPerRow + 1;
  493. int LastRowCount = 0;
  494. for (int i = 0; i < PanelDeviceStatus.Controls.Count; i++)
  495. {
  496. PanelDeviceStatus.Controls[i].Dispose();
  497. }
  498. for (int j = 0; j < RowCount; j++)
  499. {
  500. //如果是最后一行则循环尾数
  501. if (j == RowCount - 1)
  502. {
  503. LastRowCount = Count % CountPerRow;
  504. }
  505. for (int i = 0; i < (j == RowCount - 1 ? LastRowCount : CountPerRow); i++)
  506. {
  507. PictureEditWithText pic = new PictureEditWithText();
  508. pic.DeviceName = dt.Rows[j * CountPerRow + i]["de_name"].ToString();
  509. pic.Picedit.ToolTipController = CommonTipController;
  510. pic.Picedit.Click += Pic_Click;
  511. pic.Name = dt.Rows[j * CountPerRow + i]["de_code"].ToString() + i + j;
  512. pic.Anchor = AnchorStyles.Left;
  513. pic.Anchor = AnchorStyles.Top;
  514. pic.Picedit.Name = dt.Rows[j * CountPerRow + i]["de_code"].ToString();
  515. pic.Picedit.MouseHover += Pic_MouseHover;
  516. pic.Picedit.Properties.SizeMode = PictureSizeMode.Squeeze;
  517. if (dt.Rows[j * CountPerRow + i]["dpc_status"].ToString() != "Running")
  518. {
  519. pic.Picedit.Image = Properties.Resources.network_offline;
  520. }
  521. else
  522. {
  523. pic.Picedit.Image = Properties.Resources.net_connected;
  524. }
  525. pic.Text = dt.Rows[j * CountPerRow + i]["de_code"].ToString();
  526. pic.Picedit.BorderStyle = BorderStyles.HotFlat;
  527. pic.Location = new Point((10 + RightPadding) / 2 + 110 * i, 10 + j * 150);
  528. PanelDeviceStatus.Controls.Add(pic);
  529. }
  530. }
  531. BaseUtil.CleanMemory();
  532. TimerDeviceStatus.Start();
  533. }
  534. }
  535. private void Pic_Click(object sender, EventArgs e)
  536. {
  537. PictureEdit pic = sender as PictureEdit;
  538. DeviceStatusInfo dsi = new DeviceStatusInfo(pic.Name);
  539. dsi.StartPosition = FormStartPosition.CenterScreen;
  540. dsi.ShowDialog();
  541. }
  542. private void Pic_MouseHover(object sender, EventArgs e)
  543. {
  544. //使用Tip显示轮询数据
  545. PictureEdit pic = sender as PictureEdit;
  546. DataTable dt = (DataTable)dh.ExecuteSql("select * from DEVICEPOLLINGLOG where dpg_id=(select max(dpg_id) from DEVICEPOLLINGLOG where dpg_decode='" + pic.Name + "')", "select");
  547. if (dt.Rows.Count > 0)
  548. {
  549. sql.Clear();
  550. sql.Append("开始时间" + dt.Rows[0]["dpg_starttime"].ToString() + "\n");
  551. sql.Append("发送数据大小" + dt.Rows[0]["dpg_senddatasize"].ToString() + "字节\n");
  552. sql.Append("接收数据大小" + dt.Rows[0]["dpg_receivedatasize"].ToString() + "字节\n");
  553. sql.Append("轮询次数" + dt.Rows[0]["dpg_count"].ToString() + "次\n");
  554. CommonTipController.ShowHint(sql.ToString(), pic.Name);
  555. }
  556. else
  557. {
  558. CommonTipController.ShowHint("暂无信息", pic.Name);
  559. }
  560. }
  561. //重新展示设备图像界面
  562. private void ShowDeviceStatus()
  563. {
  564. DataTable dt = (DataTable)dh.ExecuteSql(DeviceStatusQuerySQL.ToString(), "select");
  565. int CountPerRow = PanelDeviceStatus.Width / 110;
  566. int RightPadding = PanelDeviceStatus.Width % 110;
  567. int Count = dt.Rows.Count;
  568. int RowCount = Count % CountPerRow == 0 ? Count / CountPerRow : Count / CountPerRow + 1;
  569. int LastRowCount = 0;
  570. //只更换现有控件的图片,不必重新绘制控件
  571. for (int j = 0; j < RowCount; j++)
  572. {
  573. //如果是最后一行则循环尾数
  574. if (j == RowCount - 1)
  575. {
  576. LastRowCount = Count % CountPerRow;
  577. }
  578. for (int i = 0; i < (j == RowCount - 1 ? LastRowCount : CountPerRow); i++)
  579. {
  580. if (dt.Rows[j * CountPerRow + i]["dpc_status"].ToString() != "Running")
  581. {
  582. (PanelDeviceStatus.Controls[dt.Rows[j * CountPerRow + i]["de_code"].ToString() + i + j] as PictureEditWithText).Picedit.Image = Properties.Resources.network_offline;
  583. }
  584. else
  585. {
  586. (PanelDeviceStatus.Controls[dt.Rows[j * CountPerRow + i]["de_code"].ToString() + i + j] as PictureEditWithText).Picedit.Image = Properties.Resources.net_connected;
  587. }
  588. }
  589. }
  590. BaseUtil.CleanMemory();
  591. }
  592. //刷新界面
  593. private void TimerDeviceStatus_Tick(object sender, EventArgs e)
  594. {
  595. if (PageDeviceStatus.PageVisible)
  596. {
  597. ShowDeviceStatus();
  598. }
  599. }
  600. private void PanelDeviceStatus_SizeChanged(object sender, EventArgs e)
  601. {
  602. if (PageDeviceStatus.PageVisible)
  603. {
  604. ShowDeviceStatus();
  605. TimerDeviceStatus.Start();
  606. }
  607. }
  608. #endregion
  609. }
  610. }