Main.cs 30 KB

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