基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：78630559

本次赞助数额为： 3 元　

支付宝支付

微信支付

   源码介绍

---

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.IO;
using System.Net;
using System.IO.Ports;
using System.Net.Sockets;
using System.Threading;

namespace SFCS_DEMO_NEW_TOOL
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
            CheckForIllegalCrossThreadCalls = false;
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            functionBoxListen();
        }


        string serverIp = "10.30.5.222";
        IPAddress functionBoxIP;
        string serverPort = "20000";
        int functionBoxLocalPort;
        Socket functionBoxNewSocket, functionBoxSocket;
        IPEndPoint functionBoxLocalEP;
        Thread threadTestSocket, threadfunctionBoxRcv;
        string unitIP_1 = "10.30.5.180";
        public int FunctionBoxSetPort
        {
            get { return functionBoxLocalPort; }
            set { functionBoxLocalPort = value; }
        }
        /// <summary>
        /// 服务器侦听打开
        /// </summary>
        public void functionBoxListen()
        {
            IPAddress[] functionBoxIpAddress = Dns.GetHostAddresses(serverIp);
            functionBoxIP = functionBoxIpAddress[0];
            FunctionBoxSetPort = int.Parse((serverPort).Trim());
            functionBoxNewSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            functionBoxLocalEP = new IPEndPoint(functionBoxIP, FunctionBoxSetPort);
            try
            {
                functionBoxNewSocket.Bind(functionBoxLocalEP);
                functionBoxNewSocket.Listen(20);
                threadTestSocket = new Thread(TestSocket);
                threadTestSocket.IsBackground = true;
                threadTestSocket.Start();
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message, "Server Not Client");
            }
        }

        /// <summary>
        /// 分配连接
        /// </summary>
        private void TestSocket()
        {
            while (true)
            {
                Socket socketTemp = functionBoxNewSocket.Accept();
                string ipTemp = socketTemp.RemoteEndPoint.ToString();
                int cy = ipTemp.IndexOf(":");
                string strip = ipTemp.Substring(0, cy).Replace(" ", "");
                if (strip.Contains(unitIP_1) & strip.Length == unitIP_1.Length)
                {
                    threadfunctionBoxRcv = new Thread(FunctionBoxRcv_1);
                    FunctionRcvThreadOpen(socketTemp);
                }
                else
                {
                    MessageBox.Show("IP Address"   ipTemp   "未在客户端注册，禁止连接", "Error Code 10000");
                }
                socketTemp = null;
            }
        }

        private void FunctionRcvThreadOpen(Socket socketTemp)
        {
            try
            {
                functionBoxSocket = socketTemp;
                threadfunctionBoxRcv.IsBackground = true;
                threadfunctionBoxRcv.Start();
                lab_ShowConnected.BackColor = Color.Green;
                lab_ShowConnected.Text = "Connected："   functionBoxSocket.RemoteEndPoint.ToString()   "   OK";
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message, "Function Box "   " Error Code 12000");
            }
        }

        private void FunctionBoxRcv_1()
        {
            int intRcvDataCount;
            while (true)
            {
                try
                {
                    byte[] byteRcvData = new byte[1024];
                    intRcvDataCount = functionBoxSocket.Receive(byteRcvData);
                    if (intRcvDataCount == 0)
                    {
                        byteRcvData = null;
                        FunctionRcvNotData();
                    }
                    else
                    {
                        FunctionBoxRcvData(byteRcvData, intRcvDataCount);
                        byteRcvData = null;
                    }
                }
                catch
                {
                    FunctionRcvNotData();
                }
            }
        }

        /// <summary>
        /// Socket返回值显示断线时处理，关闭socket、thrread
        /// </summary>
        /// <param name="index"></param>
        private void FunctionRcvNotData()
        {
            functionBoxSocket.Close();
            lab_ShowConnected.BackColor = Color.Transparent;
            lab_ShowConnected.Text = "Not Connected";
            threadfunctionBoxRcv.Abort();
        }

        /// <summary>
        /// 解析测试站返回的数据
        /// </summary>
        /// <param name="index"></param>
        /// <param name="byteRcvData"></param>
        /// <param name="intRcvDataCount"></param>
        /// <returns></returns>
        private bool FunctionBoxRcvData(byte[] byteRcvData, int intRcvDataCount)
        {
            string strtempRcvData = Encoding.ASCII.GetString(byteRcvData, 0, intRcvDataCount);
            if (lab_ShowConnected.BackColor == Color.Green)
            {
                textBox1.Text = strtempRcvData;
                label2.Text = "Rcv Msg "   strtempRcvData.Length.ToString();
                label1.Text = comboBox1.Text.ToUpper();
                switch (comboBox1.Text.ToUpper())
                {
                    case "运行时间":
                        textBox2.Text = Convert32bitToInt(strtempRcvData, 3600.0);
                        break;
                    case "停止时间":
                        textBox2.Text = Convert32bitToInt(strtempRcvData, 3600.0);
                        break;
                    case "故障时间":
                        textBox2.Text = Convert32bitToInt(strtempRcvData, 3600.0);
                        break;
                    case "投入数量":
                        textBox2.Text = Convert32bitToInt(strtempRcvData, 1.0);
                        break;
                    case "良品数量":
                        textBox2.Text = Convert32bitToInt(strtempRcvData, 1.0);
                        break;
                    case "故障次数":
                        textBox2.Text = Convert32bitToInt(strtempRcvData, 1.0);
                        break;
                    case "C/T":
                        textBox2.Text = Convert32bitToInt(strtempRcvData, 10.0);
                        break;
                    case "设备状态":
                        textBox2.Text = Convert16bitToStatus(strtempRcvData);
                        break;
                    default:
                        break;
                }
            }
            return true;
        }

        private string Convert32bitToInt(string str, double res)
        {
            string num = "";
            List<string> temp = new List<string>();
            if (str.Contains("%01$RD"))
            {
                string temp1 = str.Substring(6, 8);
                temp.Add(temp1.Substring(0, 2));
                temp.Add(temp1.Substring(2, 2));
                temp.Add(temp1.Substring(4, 2));
                temp.Add(temp1.Substring(6, 2));

                string temp_2 = temp[3]   temp[2]   temp[1]   temp[0];
                int temp_5 = Int32.Parse(temp_2, System.Globalization.NumberStyles.HexNumber);

                num = ((double)temp_5 / res).ToString();
            }
            return num;
        }

        private string Convert16bitToStatus(string str)
        {
            string num = "";
            List<string> temp = new List<string>();
            if (str.Contains("%01$RD"))
            {
                string temp1 = str.Substring(6, 4);
                temp.Add(temp1.Substring(0, 2));
                temp.Add(temp1.Substring(2, 2));
                string temp_2 = temp[1]   temp[0];
                int temp_5 = Int32.Parse(temp_2, System.Globalization.NumberStyles.HexNumber);
                switch(temp_5)
                {
                    case 1:
                        num = "Status:Run";
                        break;
                    case 2:
                        num = "Status:Standby";
                        break;
                    case 3:
                        num = "Status:Alarm";
                        break;
                }
            }
            return num;
        }

        private void button1_Click(object sender, EventArgs e)
        {
            string cmd = "<01#RDD"   GetCommand()   "**";

            FunctionBoxSend(cmd   "\r\n");
        }

        private string GetCommand()
        {
            string cmd = "";
            switch(comboBox1.Text.ToUpper())
            {
                case "运行时间":
                    cmd = "3200032001";
                    break;
                case "停止时间":
                    cmd = "3200232003";
                    break;
                case "故障时间":
                    cmd = "3200432005";
                    break;
                case "投入数量":
                    cmd = "3200632007";
                    break;
                case "良品数量":
                    cmd = "3200832009";
                    break;
                case "故障次数":
                    cmd = "3201232013";
                    break;
                case "C/T":
                    cmd = "3201432015";
                    break;
                case "设备状态":
                    cmd = "3203032030";
                    break;
                default:
                    cmd = "3200032065";
                    break;
            }
            return cmd;
        }

        /// <summary>
        /// 发送数据到测试站
        /// </summary>
        /// <param name="index"></param>s
        /// <param name="sendData"></param>
        private void FunctionBoxSend(string sendData)
        {
            int sendDataLen = sendData.Length;
            byte[] byteSendData = new byte[sendDataLen];
            if (sendDataLen > 0)
            {
                byteSendData = Encoding.UTF8.GetBytes(sendData);
                if (lab_ShowConnected.BackColor == Color.Green)
                {
                    if (functionBoxSocket != null)
                    {
                        if (functionBoxSocket.Connected)
                        {
                            try
                            {
                                functionBoxSocket.Send(byteSendData);
                            }
                            catch
                            {

                            }
                        }

                    }
                }
            }
        }
    }
}