Main.cs 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763
  1. using System;
  2. using System.Data;
  3. using System.Text;
  4. using System.Collections.Generic;
  5. using System.Drawing;
  6. using System.Threading;
  7. using System.Windows.Forms;
  8. using DevExpress.XtraBars;
  9. using DevExpress.XtraGrid.Views.Grid;
  10. using DevExpress.XtraBars.Ribbon;
  11. using DevExpress.XtraEditors.Controls;
  12. using DevExpress.XtraEditors;
  13. using UAS_DeviceMonitor.DataOperate;
  14. using UAS_DeviceMonitor.Entity;
  15. using UAS_DeviceMonitor.PublicMethod;
  16. using UAS_DeviceMonitor.CustomerControl.PictureEditWithText;
  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. //用于设备主档资料查询界面SQL查看
  26. StringBuilder DeviceListQuerySQL = new StringBuilder();
  27. DataHelper dh = SystemInf.dh;
  28. ModeBusTCPServer mbt = new ModeBusTCPServer();
  29. List<string> SQL = new List<string>();
  30. #region 初始化代码
  31. public Main()
  32. {
  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 0 CHECKEDCOLUMN,DE_ID,DE_CODE,DE_NAME,DE_SPEC,DE_INDATE,DE_RUNSTATUS,DE_ADDRESS,DE_INMAN,DE_LINECODE,DE_WCCODE,DE_VENDCODE,DE_VENDNAME,DE_STEPCODE,DE_STEPNAME FROM DEVICE ORDER BY DE_CODE".ToUpper();
  76. GridDeviceList.TableName = "device";
  77. GridDeviceList.ID = "de_id";
  78. GridDeviceList.InsertSQL = "INSERT INTO DEVICE(DE_ID,DE_CODE,DE_NAME,DE_SPEC,DE_INDATE,DE_RUNSTATUS,DE_ADDRESS,DE_INMAN,DE_LINECODE,DE_WCCODE,DE_VENDCODE,DE_VENDNAME,DE_STEPCODE,DE_STEPNAME) VALUES(DEVICE_SEQ.NEXTVAL,:DE_CODE,:DE_NAME,:DE_SPEC,:DE_INDATE,:DE_RUNSTATUS,:DE_ADDRESS,:DE_INMAN,:DE_LINECODE,:DE_WCCODE,:DE_VENDCODE,:DE_VENDNAME,:DE_STEPCODE,:DE_STEPNAME)";
  79. ButtonAddDevice.Grid = GridDeviceList;
  80. ButtonSaveDevice.Grid = GridDeviceList;
  81. ButtonDeleteDevice.Grid = GridDeviceList;
  82. //ToolPageControlDeviceList.Gridcontrol = GridDeviceList;
  83. //轮询业务
  84. //GridPolling.GetDataSQL = "select 0 CHECKEDCOLUMN,pl_id,pl_code,pl_name,pl_type,pl_dccode,pl_remark from polling".ToUpper();
  85. //GridPolling.ID = "pl_id";
  86. //GridPolling.TableName = "polling";
  87. //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)";
  88. //ButtonDeletePolling.Grid = GridPolling;
  89. //ButtonSavePolling.Grid = GridPolling;
  90. //ButtonAddPolling.Grid = GridPolling;
  91. //轮询配置界面
  92. GridPollingSetting.GetDataSQL = "SELECT '' POLLSETTINGSTATUSCOLUMN,0 CHECKEDCOLUMN,DPC_MAN,DPC_ID,DPC_DECODE ,DPC_INTERVAL ,DPC_DCCODE ,DPC_FUNCTION , nvl(DPC_ENABLE,0)DPC_ENABLE,DPC_STATUS,DPC_REMARK,EM_NAME FROM DEVICEPOLLINGCONFIG left join EMPLOYEE on em_code=dpc_man WHERE DPC_MAN='" + User.UserCode + "' ORDER BY DPC_ID";
  93. GridPollingSetting.ID = "DPC_ID";
  94. GridPollingSetting.TableName = "DEVICEPOLLINGCONFIG";
  95. GridPollingSetting.InsertSQL = "insert into DEVICEPOLLINGCONFIG(DPC_ID,DPC_DECODE ,DPC_INTERVAL ,DPC_DCCODE ,DPC_FUNCTION , DPC_ENABLE,DPC_STATUS ,DPC_REMARK,DPC_MAN) values(DEVICEPOLLINGCONFIG_seq.nextval,:DPC_DECODE ,:DPC_INTERVAL ,:DPC_DCCODE ,:DPC_FUNCTION , :DPC_ENABLE,:DPC_STATUS ,:DPC_REMARK,'" + User.UserCode + "')";
  96. ButtonSaveCommandSet.Grid = GridPollingSetting;
  97. ButtonNewCommandSet.Grid = GridPollingSetting;
  98. ButtonDeleteCommandSet.Grid = GridPollingSetting;
  99. //指令设置界面
  100. GridCommandSetting.GetDataSQL = "select 0 CHECKEDCOLUMN,dc_id,dc_code,dc_name,dc_type,dc_value,dc_sendcoding,dc_receivecoding,db_name,dc_man,to_char(dc_date,'YYYY-MM-DD HH:mi:ss')dc_date from devicecommand left join devicebrand on db_code=dc_debrand".ToUpper();
  101. GridCommandSetting.TableName = "devicecommand";
  102. GridCommandSetting.ID = "dc_id";
  103. GridCommandSetting.InsertSQL = "insert into devicecommand(dc_id,dc_code,dc_name,dc_value,dc_debrand,dc_sendcoding,dc_receivecoding,dc_man,dc_date) values(devicecommand_seq.nextval,:dc_code,:dc_name,:dc_value,'" + BaseUtil.GetComboxEditValue(Brand) + "',:dc_sendcoding,:dc_receivecoding,'" + User.UserName + "',sysdate)";
  104. ButtonSaveCommand.Grid = GridCommandSetting;
  105. ButtonDeleteCommand.Grid = GridCommandSetting;
  106. ButtonNewCommand.Grid = GridCommandSetting;
  107. //设备联网配置界面
  108. 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";
  109. GridDeviceNetSetting.ID = "dnc_id";
  110. GridDeviceNetSetting.TableName = "DEVICENETCONFIG";
  111. 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)";
  112. ButtonDeleteNetConfig.Grid = GridDeviceNetSetting;
  113. ButtonAddNetConfig.Grid = GridDeviceNetSetting;
  114. ButtonSaveNetConfig.Grid = GridDeviceNetSetting;
  115. Ptime = new Dictionary<int, PollingTimer>();
  116. }
  117. /// <summary>
  118. /// 关闭前将所有设备离线,状态更新为离线
  119. /// </summary>
  120. /// <param name="sender"></param>
  121. /// <param name="e"></param>
  122. private void Main_FormClosing(object sender, FormClosingEventArgs e)
  123. {
  124. dh.ExecuteSql("update devicepollingconfig set dpc_status='Stop' where dpc_status='Running'", "update");
  125. dh.ExecuteSql("update devicepollinglog set dpg_status='Stop' where dpg_status='Running'", "update");
  126. }
  127. #endregion
  128. #region 设备列表界面
  129. private void GridViewDeviceList_RowCellClick(object sender, RowCellClickEventArgs e)
  130. {
  131. string de_code = GridViewDeviceList.GetRowCellValue(e.RowHandle, "DE_CODE").ToString();
  132. DeviceDetailInfo ddi = new DeviceDetailInfo(de_code);
  133. ddi.StartPosition = FormStartPosition.CenterScreen;
  134. ddi.ShowDialog();
  135. }
  136. private void PageDeviceList_VisibleChanged(object sender, EventArgs e)
  137. {
  138. if (PageDeviceList.PageVisible)
  139. {
  140. DataTable dt;
  141. //填充人员资料,工作中心,线别下拉框
  142. ComBoxDeviceListMan.Properties.DataSource = (DataTable)dh.ExecuteSql("select em_code,em_name from employee ", "select");
  143. dt = (DataTable)dh.ExecuteSql("select wc_code,wc_name from workcenter", "select");
  144. BaseUtil.FillComBoxEditWidthDataTable(ComboxDeviceListWC, "wc_name", "wc_code", dt, true);
  145. }
  146. }
  147. private void ButtonSaveDevice_Click(object sender, EventArgs e)
  148. {
  149. ButtonSaveDevice.DoSaveAfterHandler();
  150. sql.Clear();
  151. sql.Append("update device set de_inman='" + User.UserName + "' where de_id=:de_id");
  152. dh.BatchInsert(sql.ToString(), new string[] { "de_id" }, ButtonSaveDevice.LastSaveID);
  153. GridDeviceList.RefreshData();
  154. }
  155. private void ComboxDeviceListWC_SelectedIndexChanged(object sender, EventArgs e)
  156. {
  157. DeviceListQuerySQL.Clear();
  158. string WC = BaseUtil.GetComboxEditValue(ComboxDeviceListWC);
  159. DeviceListQuerySQL.Append("select 0 CHECKEDCOLUMN,de_id,de_code,de_name,de_spec,de_indate,de_runstatus,de_address,de_wccode,de_inman,de_linecode");
  160. DeviceListQuerySQL.Append("de_vendcode,de_vendname,de_stepcode,de_stepname from device where de_wccode='" + WC + "' order by de_code");
  161. sql.Clear();
  162. if (WC == "全部")
  163. sql.Append("select li_code,li_name from line");
  164. else
  165. sql.Append("select li_code,li_name from line where li_wccode='" + WC + "'");
  166. DataTable dt = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
  167. BaseUtil.FillComBoxEditWidthDataTable(ComboxDeviceListLC, "li_code", "li_name", dt, true);
  168. RefreshDeviceData();
  169. }
  170. private void ComboxDeviceListLC_SelectedIndexChanged(object sender, EventArgs e)
  171. {
  172. DeviceListQuerySQL.Clear();
  173. string WC = BaseUtil.GetComboxEditValue(ComboxDeviceListWC);
  174. string LC = BaseUtil.GetComboxEditValue(ComboxDeviceListLC);
  175. DeviceListQuerySQL.Append("select 0 CHECKEDCOLUMN,de_id,de_code,de_name,de_spec,de_indate,de_runstatus,de_address,de_wccode, ");
  176. DeviceListQuerySQL.Append("de_vendcode,de_vendname,de_inman,de_linecode,de_stepcode,de_stepname from device ");
  177. if (WC != "全部" && LC != "全部")
  178. DeviceListQuerySQL.Append(" where de_wccode='" + WC + "' and de_linecode='" + LC + "' ");
  179. if (WC == "全部" && LC != "全部")
  180. DeviceListQuerySQL.Append(" where de_linecode='" + LC + "' ");
  181. if (WC != "全部" && LC == "全部")
  182. DeviceListQuerySQL.Append(" where de_wccode='" + WC + "' ");
  183. DeviceListQuerySQL.Append("order by de_code");
  184. RefreshDeviceData();
  185. }
  186. private void ComBoxDeviceListMan_EditValueChanged(object sender, EventArgs e)
  187. {
  188. }
  189. private void RefreshDeviceData()
  190. {
  191. GridDeviceList.GetDataSQL = DeviceListQuerySQL.ToString();
  192. GridDeviceList.RefreshData();
  193. }
  194. #endregion
  195. #region 界面通用事件
  196. /// <summary>
  197. /// 选项卡切换不同XPage
  198. /// </summary>
  199. /// <param name="sender"></param>
  200. /// <param name="e"></param>
  201. private void ButtonItem_ItemClick(object sender, ItemClickEventArgs e)
  202. {
  203. HideXPage(e.Item.Tag.ToString());
  204. }
  205. /// <summary>
  206. /// 根据点击按钮的Tag显示对应的XPage
  207. /// </summary>
  208. /// <param name="PageName"></param>
  209. private void HideXPage(string PageName)
  210. {
  211. for (int i = 0; i < MainTabControl.TabPages.Count; i++)
  212. {
  213. if (MainTabControl.TabPages[i].Name == PageName)
  214. MainTabControl.TabPages[i].PageVisible = true;
  215. else
  216. MainTabControl.TabPages[i].PageVisible = false;
  217. }
  218. }
  219. /// <summary>
  220. /// 勾选Grid的CheckBox
  221. /// </summary>
  222. /// <param name="sender"></param>
  223. /// <param name="e"></param>
  224. private void CheckedEdit_QueryCheckStateByValue(object sender, DevExpress.XtraEditors.Controls.QueryCheckStateByValueEventArgs e)
  225. {
  226. string val = "";
  227. if (e.Value != null)
  228. {
  229. val = e.Value.ToString();
  230. }
  231. else
  232. {
  233. val = "FALSE";//默认为不选
  234. }
  235. switch (val.ToUpper())
  236. {
  237. case "TRUE":
  238. case "YES":
  239. case "1":
  240. e.CheckState = CheckState.Checked;
  241. break;
  242. case "FALSE":
  243. case "NO":
  244. case "0":
  245. e.CheckState = CheckState.Unchecked;
  246. break;
  247. default:
  248. e.CheckState = CheckState.Checked;
  249. break;
  250. }
  251. e.Handled = true;
  252. }
  253. #endregion
  254. #region PageCommandSet业务代码(指令设置)
  255. /// <summary>
  256. /// 判断指令编号不能重复
  257. /// </summary>
  258. /// <param name="sender"></param>
  259. /// <param name="e"></param>
  260. private void ButtonSaveCommand_Click(object sender, EventArgs e)
  261. {
  262. GridCommandSetting.InsertSQL = "insert into devicecommand(dc_id,dc_code,dc_name,dc_value,dc_debrand,dc_sendcoding,dc_receivecoding,dc_man,dc_date) values(devicecommand_seq.nextval,:dc_code,:dc_name,:dc_value,'" + BaseUtil.GetComboxEditValue(Brand) + "',:dc_sendcoding,:dc_receivecoding,'" + User.UserName + "',sysdate)";
  263. ButtonSaveCommand.DoSaveAfterHandler();
  264. sql.Clear();
  265. sql.Append("update devicecommand set dc_man='" + User.UserName + "',dc_date=sysdate where dc_id=:dc_id");
  266. dh.BatchInsert(sql.ToString(), new string[] { "dc_id" }, ButtonSaveCommand.LastSaveID);
  267. GridCommandSetting.RefreshData();
  268. }
  269. /// <summary>
  270. /// 加载ComBox品牌数据
  271. /// </summary>
  272. /// <param name="sender"></param>
  273. /// <param name="e"></param>
  274. private void PageCommandSet_VisibleChanged(object sender, EventArgs e)
  275. {
  276. if (PageCommandSet.PageVisible)
  277. {
  278. DataTable dt = (DataTable)SystemInf.dh.ExecuteSql("select * from devicebrand", "select");
  279. BaseUtil.FillComBoxEditWidthDataTable(Brand, "db_name", "db_code", dt);
  280. GridCommandSetting.Condition = " where dc_debrand='" + BaseUtil.GetComboxEditValue(Brand) + "' order by dc_id";
  281. }
  282. }
  283. private void Brand_SelectedIndexChanged(object sender, EventArgs e)
  284. {
  285. GridCommandSetting.Condition = " where dc_debrand='" + BaseUtil.GetComboxEditValue(Brand) + "' order by dc_id";
  286. GridCommandSetting.RefreshData();
  287. }
  288. #endregion
  289. #region PagePollingSetting业务代码(轮询配置)
  290. PollingTask pt = new PollingTask();
  291. /// <summary>
  292. /// 绘制轮询配置状态栏
  293. /// </summary>
  294. List<int> PollSettingPaintRowIndex = new List<int>();
  295. private void ButtonStartPolling_Click(object sender, EventArgs e)
  296. {
  297. GridView grid = GridViewPollSetting;
  298. for (int i = 0; i < GridPollingSetting.RowCount; i++)
  299. {
  300. Polling pl = new Polling();
  301. pl.Id = int.Parse(GridViewPollSetting.GetRowCellValue(i, "DPC_ID").ToString());
  302. pl.DeviceCode = GridViewPollSetting.GetRowCellValue(i, "DPC_DECODE").ToString();
  303. pl.CommandCode = GridViewPollSetting.GetRowCellValue(i, "DPC_DCCODE").ToString();
  304. pl.Interval = int.Parse(GridViewPollSetting.GetRowCellValue(i, "DPC_INTERVAL").ToString());
  305. pl.Enable = GridViewPollSetting.GetRowCellValue(i, "DPC_ENABLE").ToString() != "0";
  306. pl.Dh = new DataHelper();
  307. if (pl.Enable)
  308. {
  309. //插入轮询日志
  310. sql.Clear();
  311. sql.Append("insert into DEVICEPOLLINGLOG(dpg_id,dpg_decode,dpg_starttime,dpg_interval)values");
  312. sql.Append("(DEVICEPOLLINGLOG_seq.nextval,'" + pl.DeviceCode + "',sysdate,'" + pl.Interval + "')");
  313. dh.ExecuteSql(sql.ToString(), "insert");
  314. pt.AddTask(RunTask, pl);
  315. //添加到状态为运行的行
  316. PollSettingPaintRowIndex.Add(i);
  317. GridPollingSetting.Focus();
  318. }
  319. }
  320. }
  321. /// <summary>
  322. /// 绘制轮询状态
  323. /// </summary>
  324. /// <param name="sender"></param>
  325. /// <param name="e"></param>
  326. private void GridViewPollSetting_RowCellStyle(object sender, RowCellStyleEventArgs e)
  327. {
  328. if (e.Column.Name.ToUpper() == "POLLSETTINGSTATUSCOLUMN" && PollSettingPaintRowIndex.Contains(e.RowHandle))
  329. {
  330. e.Appearance.BackColor = Color.Green;
  331. }
  332. }
  333. Dictionary<int, PollingTimer> Ptime;
  334. private void RunTask(object i)
  335. {
  336. PollingTimer timer = new PollingTimer();
  337. Polling pl = (Polling)i;
  338. timer.Polling = i;
  339. timer.Interval = pl.Interval * 1000;
  340. timer.Elapsed += Timer_Tick;
  341. timer.Start();
  342. try
  343. {
  344. if (!Ptime.ContainsKey(pl.Id))
  345. Ptime.Add(pl.Id, timer);
  346. }
  347. catch (Exception)
  348. {
  349. if (!Ptime.ContainsKey(pl.Id))
  350. Ptime.Add(pl.Id, timer);
  351. }
  352. }
  353. /// <summary>
  354. /// 轮询执行的业务
  355. /// </summary>
  356. /// <param name="sender"></param>
  357. /// <param name="e"></param>
  358. private void Timer_Tick(object sender, EventArgs e)
  359. {
  360. PollingTimer timer = (PollingTimer)sender;
  361. Polling pl = (Polling)timer.Polling;
  362. DataHelper dh = pl.Dh;
  363. string Decode = pl.DeviceCode;
  364. string Dccode = pl.CommandCode;
  365. DataTable dt = (DataTable)dh.ExecuteSql("select dnc_ip,dnc_port from DEVICENETCONFIG where dnc_decode='" + Decode + "'", "select");
  366. DataTable dt1 = (DataTable)dh.ExecuteSql("select dc_sendcoding,dc_value,dc_receivecoding from devicecommand where dc_code='" + Dccode + "'", "select");
  367. if (dt.Rows.Count > 0)
  368. {
  369. string IP = dt.Rows[0]["dnc_ip"].ToString() + ":" + dt.Rows[0]["dnc_port"].ToString();
  370. string SendCoding = "";
  371. string ReceiveCoding = "";
  372. string Command = "";
  373. int SendCommandByteSize = 0;
  374. if (dt1.Rows.Count > 0)
  375. {
  376. SendCoding = dt1.Rows[0]["dc_sendcoding"].ToString();
  377. ReceiveCoding = dt1.Rows[0]["dc_receivecoding"].ToString();
  378. Command = dt1.Rows[0]["dc_value"].ToString();
  379. SendCommandByteSize = Encoding.Default.GetBytes(Command.ToCharArray()).Length;
  380. }
  381. mbt.Send(IP, SendCoding, ReceiveCoding, Command);
  382. //处理2秒之内返回的指令
  383. Thread.Sleep(1000);
  384. if (mbt.Returnvalue.ContainsKey(IP))
  385. {
  386. int ReceiveCommandByteSize = Encoding.Default.GetBytes(mbt.Returnvalue[IP].ToCharArray()).Length;
  387. mbt.Returnvalue.Remove(IP);
  388. SQL.Clear();
  389. //更新轮询状态
  390. sql.Clear();
  391. sql.Append("update DEVICEPOLLINGCONFIG set dpc_status='Running' where dpc_decode='" + Decode + "' and dpc_dccode='" + Dccode + "'");
  392. dh.ExecuteSql(sql.ToString(), "update");
  393. //SQL.Add(sql.ToString());
  394. //更新轮询日志状态
  395. sql.Clear();
  396. sql.Append("update DEVICEPOLLINGLOG set dpg_status='Running',dpg_senddatasize=nvl(dpg_senddatasize,0)+" + SendCommandByteSize);
  397. sql.Append(",dpg_receivedatasize=nvl(dpg_receivedatasize,0)+" + ReceiveCommandByteSize + ",dpg_count=nvl(dpg_count,0)+1 ");
  398. sql.Append(" where dpg_id=(select max(dpg_id) from DEVICEPOLLINGLOG where dpg_decode='" + Decode + "')");
  399. //SQL.Add(sql.ToString());
  400. dh.ExecuteSql(sql.ToString(), "update");
  401. //dh.ExecuteSQLTran(SQL.ToArray());
  402. }
  403. else
  404. {
  405. SQL.Clear();
  406. //更新轮询状态
  407. sql.Clear();
  408. sql.Append("update DEVICEPOLLINGCONFIG set dpc_status='Stop' where dpc_decode='" + Decode + "' and dpc_dccode='" + Dccode + "'");
  409. //SQL.Add(sql.ToString());
  410. dh.ExecuteSql(sql.ToString(), "update");
  411. //更新轮询日志状态
  412. sql.Clear();
  413. sql.Append("update DEVICEPOLLINGLOG set dpg_status='Running',dpg_senddatasize=nvl(dpg_senddatasize,0)+");
  414. sql.Append(SendCommandByteSize + ",dpg_count=nvl(dpg_count,0)+1 ");
  415. sql.Append("where dpg_id=(select max(dpg_id) from DEVICEPOLLINGLOG where dpg_decode='" + Decode + "')");
  416. //SQL.Add(sql.ToString());
  417. dh.ExecuteSql(sql.ToString(), "update");
  418. //dh.ExecuteSQLTran(SQL.ToArray());
  419. }
  420. }
  421. }
  422. /// <summary>
  423. /// 停止全部轮询
  424. /// </summary>
  425. /// <param name="sender"></param>
  426. /// <param name="e"></param>
  427. private void ButtonPausePolling_Click(object sender, EventArgs e)
  428. {
  429. foreach (var item in Ptime)
  430. {
  431. item.Value.Stop();
  432. }
  433. PollSettingPaintRowIndex.Clear();
  434. GridPollingSetting.Focus();
  435. Ptime.Clear();
  436. }
  437. private void GridViewPollSetting_CellValueChanging(object sender, DevExpress.XtraGrid.Views.Base.CellValueChangedEventArgs e)
  438. {
  439. if (e.Column.Name.ToUpper() == "DPC_ENABLE")
  440. {
  441. GridViewPollSetting.SetRowCellValue(e.RowHandle, e.Column, e.Value);
  442. if (GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ENABLE").ToString() == "0")
  443. {
  444. //DialogResult cancel = XtraMessageBox.Show("确认禁用该轮询?", "提示", MessageBoxButtons.YesNo, MessageBoxIcon.Question);
  445. //if (cancel.ToString() == "Yes")
  446. //{
  447. int id = int.Parse(GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ID").ToString());
  448. if (Ptime.ContainsKey(id))
  449. {
  450. Ptime[id].Stop();
  451. Ptime.Remove(id);
  452. PollSettingPaintRowIndex.Remove(e.RowHandle);
  453. }
  454. //}
  455. //else
  456. //{
  457. // Cancel = false;
  458. // GridViewPollSetting.SetRowCellValue(e.RowHandle, e.Column, -1);
  459. //}
  460. }
  461. else
  462. {
  463. Polling pl = new Polling();
  464. pl.Id = int.Parse(GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ID").ToString());
  465. pl.DeviceCode = GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_DECODE").ToString();
  466. pl.Interval = int.Parse(GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_INTERVAL").ToString());
  467. pl.CommandCode = GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_DCCODE").ToString();
  468. pl.Enable = GridViewPollSetting.GetRowCellValue(e.RowHandle, "DPC_ENABLE").ToString() != "0";
  469. pl.Dh = new DataHelper();
  470. if (pl.Enable)
  471. pt.AddTask(RunTask, pl);
  472. PollSettingPaintRowIndex.Add(e.RowHandle);
  473. }
  474. }
  475. }
  476. private void GridViewPollSetting_CellValueChanged(object sender, DevExpress.XtraGrid.Views.Base.CellValueChangedEventArgs e)
  477. {
  478. }
  479. private void ButtonSaveCommandSet_Click(object sender, EventArgs e)
  480. {
  481. ButtonSaveCommandSet.DoSaveAfterHandler();
  482. sql.Clear();
  483. sql.Append("update DEVICEPOLLINGCONFIG set dpc_man='" + User.UserCode + "' where dpc_id=:dpc_id");
  484. dh.BatchInsert(sql.ToString(), new string[] { "dpc_id" }, ButtonSaveCommandSet.LastSaveID);
  485. GridPollingSetting.RefreshData();
  486. }
  487. /// <summary>
  488. /// 设置GridView多选放大镜
  489. /// </summary>
  490. /// <param name="sender"></param>
  491. /// <param name="e"></param>
  492. private void PagePollingSetting_VisibleChanged(object sender, EventArgs e)
  493. {
  494. if (PagePollingSetting.PageVisible)
  495. {
  496. //如果未开启则进行开启
  497. if (!mbt.IsOpen)
  498. mbt.Open();
  499. DataTable dt = (DataTable)SystemInf.dh.ExecuteSql("SELECT DC_CODE,DC_NAME,DC_REMARK FROM DEVICECOMMAND", "select");
  500. PollSettingItemSearchLookUpEdit.DataSource = dt;
  501. PollSettingItemSearchLookUpEdit.DisplayMember = "DC_CODE";
  502. PollSettingItemSearchLookUpEdit.ValueMember = "DC_CODE";
  503. }
  504. }
  505. #endregion
  506. #region 设备查看界面
  507. private void PageDeviceStatus_VisibleChanged(object sender, EventArgs e)
  508. {
  509. if (PageDeviceStatus.PageVisible)
  510. {
  511. DeviceStatusQuerySQL.Clear();
  512. 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");
  513. PaintDeviceStatusControl(DeviceStatusQuerySQL.ToString());
  514. //填充筛选条件,车间和线体
  515. DataTable dt = (DataTable)dh.ExecuteSql("select wc_code,wc_name from workcenter", "select");
  516. BaseUtil.FillComBoxEditWidthDataTable(ComboxDeviceStatusWC, "wc_name", "wc_code", dt, true);
  517. }
  518. }
  519. private void CheckEditDeviceStatusEnable_CheckedChanged(object sender, EventArgs e)
  520. {
  521. DeviceStatusQuerySQL.Clear();
  522. if (CheckEditDeviceStatusEnable.Checked)
  523. {
  524. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join DEVICEPOLLINGCONFIG ");
  525. DeviceStatusQuerySQL.Append("on dpc_decode=de_code where nvl(dpc_enable,0)<>0 order by de_code");
  526. }
  527. else
  528. {
  529. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join DEVICEPOLLINGCONFIG ");
  530. DeviceStatusQuerySQL.Append("on dpc_decode=de_code order by de_code");
  531. }
  532. PaintDeviceStatusControl(DeviceStatusQuerySQL.ToString());
  533. }
  534. private void ComboxDeviceStatusWC_SelectedIndexChanged(object sender, EventArgs e)
  535. {
  536. DeviceStatusQuerySQL.Clear();
  537. string WC = BaseUtil.GetComboxEditValue(ComboxDeviceStatusWC);
  538. if (CheckEditDeviceStatusEnable.Checked)
  539. {
  540. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join DEVICEPOLLINGCONFIG ");
  541. DeviceStatusQuerySQL.Append("on dpc_decode=de_code where nvl(dpc_enable,0)<>0 and de_wccode='" + WC + "' order by de_code");
  542. }
  543. else
  544. {
  545. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join DEVICEPOLLINGCONFIG ");
  546. DeviceStatusQuerySQL.Append("on dpc_decode=de_code where de_wccode='" + WC + "' order by de_code");
  547. }
  548. PaintDeviceStatusControl(DeviceStatusQuerySQL.ToString());
  549. sql.Clear();
  550. if (WC == "全部")
  551. sql.Append("select li_code,li_name from line");
  552. else
  553. sql.Append("select li_code,li_name from line where li_wccode='" + WC + "'");
  554. DataTable dt = (DataTable)dh.ExecuteSql(sql.ToString(), "select");
  555. BaseUtil.FillComBoxEditWidthDataTable(ComboxDeviceStatusLC, "li_code", "li_name", dt, true);
  556. }
  557. private void ComboxDeviceStatusLC_SelectedIndexChanged(object sender, EventArgs e)
  558. {
  559. DeviceStatusQuerySQL.Clear();
  560. string WC = BaseUtil.GetComboxEditValue(ComboxDeviceStatusWC);
  561. string LC = BaseUtil.GetComboxEditValue(ComboxDeviceStatusLC);
  562. if (CheckEditDeviceStatusEnable.Checked)
  563. {
  564. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join ");
  565. DeviceStatusQuerySQL.Append("DEVICEPOLLINGCONFIG on dpc_decode=de_code where nvl(dpc_enable,0)<>0");
  566. if (WC != "全部")
  567. DeviceStatusQuerySQL.Append(" and de_wccode='" + WC + "' ");
  568. if (LC != "全部")
  569. DeviceStatusQuerySQL.Append(" and de_linecode='" + LC + "' ");
  570. DeviceStatusQuerySQL.Append(" order by de_code");
  571. }
  572. else
  573. {
  574. DeviceStatusQuerySQL.Append("select distinct de_code,de_name,dpc_status,dpc_id from device left join ");
  575. DeviceStatusQuerySQL.Append("DEVICEPOLLINGCONFIG on dpc_decode=de_code ");
  576. if (WC != "全部" && LC != "全部")
  577. DeviceStatusQuerySQL.Append(" where de_wccode='" + WC + "' and de_linecode='" + LC + "' ");
  578. if (WC == "全部" && LC != "全部")
  579. DeviceStatusQuerySQL.Append(" where de_linecode='" + LC + "' ");
  580. if (WC != "全部" && LC == "全部")
  581. DeviceStatusQuerySQL.Append(" where de_wccode='" + WC + "' ");
  582. DeviceStatusQuerySQL.Append("order by de_code");
  583. }
  584. PaintDeviceStatusControl(DeviceStatusQuerySQL.ToString());
  585. }
  586. private void PaintDeviceStatusControl(string SQL)
  587. {
  588. DataTable dt = (DataTable)dh.ExecuteSql(SQL, "select");
  589. //界面重新展示时如过数量不一致则重新绘制
  590. if (PanelDeviceStatus.Controls.Count != dt.Rows.Count)
  591. {
  592. PanelDeviceStatus.Controls.Clear();
  593. int CountPerRow = PanelDeviceStatus.Width / 110;
  594. int RightPadding = PanelDeviceStatus.Width % 110;
  595. int Count = dt.Rows.Count;
  596. int RowCount = Count % CountPerRow == 0 ? Count / CountPerRow : Count / CountPerRow + 1;
  597. int LastRowCount = 0;
  598. for (int i = 0; i < PanelDeviceStatus.Controls.Count; i++)
  599. {
  600. PanelDeviceStatus.Controls[i].Dispose();
  601. }
  602. ContextMenu ContextMenu = new ContextMenu();
  603. for (int j = 0; j < RowCount; j++)
  604. {
  605. //如果是最后一行则循环尾数
  606. if (j == RowCount - 1)
  607. {
  608. LastRowCount = Count % CountPerRow;
  609. }
  610. for (int i = 0; i < (j == RowCount - 1 ? LastRowCount : CountPerRow); i++)
  611. {
  612. PictureEditWithText pic = new PictureEditWithText();
  613. pic.DeviceName = dt.Rows[j * CountPerRow + i]["de_name"].ToString();
  614. pic.Picedit.ToolTipController = CommonTipController;
  615. pic.Picedit.ContextMenu = ContextMenu;
  616. pic.Picedit.Click += Pic_Click;
  617. pic.Name = dt.Rows[j * CountPerRow + i]["de_code"].ToString() + i + j;
  618. pic.Anchor = AnchorStyles.Left;
  619. pic.Anchor = AnchorStyles.Top;
  620. pic.Picedit.Name = dt.Rows[j * CountPerRow + i]["de_code"].ToString();
  621. pic.Picedit.MouseHover += Pic_MouseHover;
  622. pic.Picedit.Properties.SizeMode = PictureSizeMode.Squeeze;
  623. if (dt.Rows[j * CountPerRow + i]["dpc_status"].ToString() != "Running")
  624. {
  625. pic.Picedit.Image = Properties.Resources.network_offline;
  626. }
  627. else
  628. {
  629. pic.Picedit.Image = Properties.Resources.net_connected;
  630. }
  631. pic.Text = dt.Rows[j * CountPerRow + i]["de_code"].ToString();
  632. pic.Picedit.BorderStyle = BorderStyles.HotFlat;
  633. pic.Location = new Point((10 + RightPadding) / 2 + 110 * i, 10 + j * 150);
  634. PanelDeviceStatus.Controls.Add(pic);
  635. }
  636. }
  637. BaseUtil.CleanMemory();
  638. TimerDeviceStatus.Start();
  639. }
  640. }
  641. private void Pic_Click(object sender, EventArgs e)
  642. {
  643. PictureEdit pic = sender as PictureEdit;
  644. DeviceStatusInfo dsi = new DeviceStatusInfo(pic.Name);
  645. dsi.StartPosition = FormStartPosition.CenterScreen;
  646. dsi.ShowDialog();
  647. }
  648. private void Pic_MouseHover(object sender, EventArgs e)
  649. {
  650. //使用Tip显示轮询数据
  651. PictureEdit pic = sender as PictureEdit;
  652. DataTable dt = (DataTable)dh.ExecuteSql("select * from DEVICEPOLLINGLOG where dpg_id=(select max(dpg_id) from DEVICEPOLLINGLOG where dpg_decode='" + pic.Name + "')", "select");
  653. if (dt.Rows.Count > 0)
  654. {
  655. sql.Clear();
  656. sql.Append("开始时间" + dt.Rows[0]["dpg_starttime"].ToString() + "\n");
  657. sql.Append("发送数据大小" + dt.Rows[0]["dpg_senddatasize"].ToString() + "字节\n");
  658. sql.Append("接收数据大小" + dt.Rows[0]["dpg_receivedatasize"].ToString() + "字节\n");
  659. sql.Append("轮询次数" + dt.Rows[0]["dpg_count"].ToString() + "次\n");
  660. CommonTipController.ShowHint(sql.ToString(), pic.Name);
  661. }
  662. else
  663. {
  664. CommonTipController.ShowHint("暂无信息", pic.Name);
  665. }
  666. }
  667. //重新展示设备图像界面
  668. private void ShowDeviceStatus()
  669. {
  670. DataTable dt = (DataTable)dh.ExecuteSql(DeviceStatusQuerySQL.ToString(), "select");
  671. int CountPerRow = PanelDeviceStatus.Width / 110;
  672. int RightPadding = PanelDeviceStatus.Width % 110;
  673. int Count = dt.Rows.Count;
  674. int RowCount = Count % CountPerRow == 0 ? Count / CountPerRow : Count / CountPerRow + 1;
  675. int LastRowCount = 0;
  676. //只更换现有控件的图片,不必重新绘制控件
  677. for (int j = 0; j < RowCount; j++)
  678. {
  679. //如果是最后一行则循环尾数
  680. if (j == RowCount - 1)
  681. {
  682. LastRowCount = Count % CountPerRow;
  683. }
  684. for (int i = 0; i < (j == RowCount - 1 ? LastRowCount : CountPerRow); i++)
  685. {
  686. if (dt.Rows[j * CountPerRow + i]["dpc_status"].ToString() != "Running")
  687. {
  688. (PanelDeviceStatus.Controls[dt.Rows[j * CountPerRow + i]["de_code"].ToString() + i + j] as PictureEditWithText).Picedit.Image = Properties.Resources.network_offline;
  689. }
  690. else
  691. {
  692. (PanelDeviceStatus.Controls[dt.Rows[j * CountPerRow + i]["de_code"].ToString() + i + j] as PictureEditWithText).Picedit.Image = Properties.Resources.net_connected;
  693. }
  694. }
  695. }
  696. BaseUtil.CleanMemory();
  697. }
  698. //刷新界面
  699. private void TimerDeviceStatus_Tick(object sender, EventArgs e)
  700. {
  701. if (PageDeviceStatus.PageVisible)
  702. {
  703. ShowDeviceStatus();
  704. }
  705. }
  706. private void PanelDeviceStatus_SizeChanged(object sender, EventArgs e)
  707. {
  708. if (PageDeviceStatus.PageVisible)
  709. {
  710. ShowDeviceStatus();
  711. TimerDeviceStatus.Start();
  712. }
  713. }
  714. #endregion
  715. }
  716. }