patrick.xu
2021-05-24 f13235bee2e25d091ba13dc3732b83f905565f80
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
using System;
using System.Collections.Generic;
using System.Drawing.Text;
using System.Linq;
using System.Net;
using System.Text;
using System.Net.Sockets;
using System.Threading;
using System.Windows.Forms.VisualStyles;
using HalconDotNet;
 
namespace M423project
{
    public class ProductDeltaPosition
    {
        public string[] deltaloadRowStr = new string[2];
        public string[] deltaloadColumnStr = new string[2];
        public string[] deltaloadAngleStr = new string[2];
        public double[] deltaloadRow = new double[2];
        public double[] deltaloadColumn = new double[2];
        public double[] deltaloadAngle = new double[2];
    }
 
    //上料检测类
    public class UpLoadDetection
    {
        #region 上料检测相关私有成员
        private ConfigStruct opcConfig;
        private TcpListener robotServer;
        private ImageProcess ipImage;
        private Thread loadProcesser;
        private VisionDetect vd = new VisionDetect();
        #endregion
        /// <summary>
        /// 上料检类构造函数
        /// </summary>
        /// <param name="_opcConfig">OPC配置对象引用</param>
        /// <param name="_ipImage">图象处理对象引用</param>
        public UpLoadDetection(ConfigStruct _opcConfig, ImageProcess _ipImage)
        {
            opcConfig = _opcConfig;
            ipImage = _ipImage;
            robotServer = new TcpListener(IPAddress.Parse(opcConfig.loadRobotConfig.localIpAddress), opcConfig.loadRobotConfig.port);
        }
 
        /// <summary>
        /// 启动检测线程
        /// </summary>
        public void Start()
        {
            loadProcesser = new Thread(Execute);
            loadProcesser.Start();
        }
 
        public void Stop()
        {
            if (loadProcesser != null && loadProcesser.IsAlive)
            {
                loadProcesser.Abort();
                loadProcesser.Join();
            }
            loadProcesser = null;
        }
 
        /// <summary>
        /// 启动对机械手臂监听
        /// </summary>
        /// <returns>是否正常启动</returns>
        public bool OpenListener()
        {
            try
            {
                robotServer.Start();
                CommonUtil.WriteLog(LogType.Inf, string.Format("上料机械手臂监听服务已启动,绑定地址:{0},端口:{1}", opcConfig.loadRobotConfig.localIpAddress,
                    opcConfig.loadRobotConfig.port));
                return true;
            }
            catch (Exception e)
            {
                CommonUtil.WriteLog(LogType.Exc, string.Format("上料机械手臂监听服务启动失败:{0}", e.Message));
                return false;
            }
        }
 
        public void CloseListener()
        {
            robotServer.Stop();
            CommonUtil.WriteLog(LogType.Inf, string.Format("上料机械手臂机械手臂监听服务已关闭"));
        }
 
        /// <summary>
        /// 执行和机械手臂会话,处理上料检测结果。
        /// 连结是否需要多次建立还 是只建立一次?
        /// </summary>
        public void Execute()
        {
            TcpClient robortClient = null;
            NetworkStream netStream = null;
            byte[] recvBuf = new byte[1024];
            byte[] sendBuf;            
            //
            //int batteryStatus = 10;
            //int batteryNumber = 0;
            InitPosition initPosition = default(InitPosition);
            HObject imageIntrest = new HObject();
            ProductDeltaPosition productDeltaPosition = new ProductDeltaPosition();
            HTuple ScoreTriRects = new HTuple(), ScoreTriAngles = new HTuple();
            //
            while (true)
            {
                try
                {
                    while (!robotServer.Pending())
                       Thread.Sleep(10);
                
                    robortClient = robotServer.AcceptTcpClient();
                    string timeStr = DateTime.Now.ToString("hh:mm:ss fff");
                    CommonUtil.WriteLog(LogType.Inf, string.Format("上料机械手臂已连接:{0}, {1}, {2}", robortClient.Client.RemoteEndPoint, timeStr,
                        CommonUtil.StepControl.ToString()));                   
                    netStream = robortClient.GetStream();
 
                    while ( robortClient.Connected && !netStream.DataAvailable)
                        Thread.Sleep(10);
 
                    if (!robortClient.Connected)
                        continue;
 
                    //每次一个,完成断开 
                    int n = 0;
                    n = netStream.Read(recvBuf, 0, 1024);
                    while (n > 0)
                    {
                        #region 接收处理
                        string receivedMsg = System.Text.Encoding.ASCII.GetString(recvBuf, 0, n);
                        string sendMsg = string.Empty;
                        // 处理接收到的数据。
                        if (receivedMsg.Contains("slgrab"))
                        {
                    
                            sendMsg = "ok";
                        }
                        if (receivedMsg.Contains("num"))
                        {
                            sendMsg = "2";//batteryStatus.ToString();
 
                        }
                        if (receivedMsg.Contains("slrate"))
                        {
                            sendMsg = opcConfig.loadRbtSpeed.ToString();
                        }
 
                        if (receivedMsg.Contains("sldata"))
                        {
                            sendMsg = productDeltaPosition.deltaloadColumnStr[0] + "," + productDeltaPosition.deltaloadRowStr[0] + "," + "+000.000"
                                + "," + productDeltaPosition.deltaloadColumnStr[1] + "," + productDeltaPosition.deltaloadRowStr[1] + "," + "+000.000";
                            sendMsg = "+000.000,+000.000,+000.000,+000.000,+000.000,+000.000";
                        }
 
                        if (receivedMsg.Contains("1"))
                        {
                            initPosition.x1 = opcConfig.loadPosition11.x;
                            initPosition.y1 = opcConfig.loadPosition11.y;
                            initPosition.a1 = opcConfig.loadPosition11.angle;
                            initPosition.x2 = opcConfig.loadPosition12.x;
                            initPosition.y2 = opcConfig.loadPosition12.y;
                            initPosition.a2 = opcConfig.loadPosition12.angle;
                            sendMsg = "1";
                        }
                        if (receivedMsg.Contains("2"))
                        {
                            initPosition.x1 = opcConfig.loadPosition21.x;
                            initPosition.y1 = opcConfig.loadPosition21.y;
                            initPosition.a1 = opcConfig.loadPosition21.angle;
                            initPosition.x2 = opcConfig.loadPosition22.x;
                            initPosition.y2 = opcConfig.loadPosition22.y;
                            initPosition.a2 = opcConfig.loadPosition22.angle;
                            sendMsg = "2";
                        }
                        if (receivedMsg.Contains("3"))
                        {
                            initPosition.x1 = opcConfig.loadPosition31.x;
                            initPosition.y1 = opcConfig.loadPosition31.y;
                            initPosition.a1 = opcConfig.loadPosition31.angle;
                            initPosition.x2 = opcConfig.loadPosition32.x;
                            initPosition.y2 = opcConfig.loadPosition32.y;
                            initPosition.a2 = opcConfig.loadPosition32.angle;
                            sendMsg = "3";
                        }
                        if (receivedMsg.Contains("4"))
                        {
                            initPosition.x1 = opcConfig.loadPosition41.x;
                            initPosition.y1 = opcConfig.loadPosition41.y;
                            initPosition.a1 = opcConfig.loadPosition41.angle;
                            initPosition.x2 = opcConfig.loadPosition42.x;
                            initPosition.y2 = opcConfig.loadPosition42.y;
                            initPosition.a2 = opcConfig.loadPosition42.angle;
                            sendMsg = "4";
                        }
                        if (receivedMsg.Contains("5"))
                        {
                            initPosition.x1 = opcConfig.loadPosition51.x;
                            initPosition.y1 = opcConfig.loadPosition51.y;
                            initPosition.a1 = opcConfig.loadPosition51.angle;
                            initPosition.x2 = opcConfig.loadPosition52.x;
                            initPosition.y2 = opcConfig.loadPosition52.y;
                            initPosition.a2 = opcConfig.loadPosition52.angle;
                            sendMsg = "5";
                        }
                        if (receivedMsg.Contains("6"))
                        {
                            initPosition.x1 = opcConfig.loadPosition61.x;
                            initPosition.y1 = opcConfig.loadPosition61.y;
                            initPosition.a1 = opcConfig.loadPosition61.angle;
                            initPosition.x2 = opcConfig.loadPosition62.x;
                            initPosition.y2 = opcConfig.loadPosition62.y;
                            initPosition.a2 = opcConfig.loadPosition62.angle;
                            sendMsg = "6";
                        }
                        if (receivedMsg.Contains("7"))
                        {
                            initPosition.x1 = opcConfig.loadPosition71.x;
                            initPosition.y1 = opcConfig.loadPosition71.y;
                            initPosition.a1 = opcConfig.loadPosition71.angle;
                            initPosition.x2 = opcConfig.loadPosition72.x;
                            initPosition.y2 = opcConfig.loadPosition72.y;
                            initPosition.a2 = opcConfig.loadPosition72.angle;
                            sendMsg = "7";
                        }
                        if (receivedMsg.Contains("8"))
                        {
                            initPosition.x1 = opcConfig.loadPosition81.x;
                            initPosition.y1 = opcConfig.loadPosition81.y;
                            initPosition.a1 = opcConfig.loadPosition81.angle;
                            initPosition.x2 = opcConfig.loadPosition82.x;
                            initPosition.y2 = opcConfig.loadPosition82.y;
                            initPosition.a2 = opcConfig.loadPosition82.angle;
                            sendMsg = "8";
                        }
                        if (receivedMsg.Contains("9"))
                        {
                            initPosition.x1 = opcConfig.loadPosition91.x;
                            initPosition.y1 = opcConfig.loadPosition91.y;
                            initPosition.a1 = opcConfig.loadPosition91.angle;
                            initPosition.x2 = opcConfig.loadPosition92.x;
                            initPosition.y2 = opcConfig.loadPosition92.y;
                            initPosition.a2 = opcConfig.loadPosition92.angle;
                            sendMsg = "9";
                        }
                        if (receivedMsg.Contains("10"))
                        {
                            initPosition.x1 = opcConfig.loadPosition101.x;
                            initPosition.y1 = opcConfig.loadPosition101.y;
                            initPosition.a1 = opcConfig.loadPosition101.angle;
                            initPosition.x2 = opcConfig.loadPosition102.x;
                            initPosition.y2 = opcConfig.loadPosition102.y;
                            initPosition.a2 = opcConfig.loadPosition102.angle;
                            sendMsg = "10";
                        }//  结束
 
                        if (sendMsg != string.Empty)
                        {
                            sendBuf = System.Text.Encoding.ASCII.GetBytes(sendMsg);
                            netStream.Write(sendBuf, 0, sendBuf.Length);
                        }
                        Thread.Sleep(20);
                        n = netStream.Read(recvBuf, 0, 1024);
                        #endregion
                    }
                     
                    Thread.Sleep(10);
                }
                catch (Exception)
                {                    
                   break;
                }
                finally
                {
                    if (netStream != null)
                        netStream.Close();
 
                    if (robortClient != null)
                        robortClient.Close();
                }
                Thread.Sleep(10);
            }
 
            CommonUtil.WriteLog(LogType.Inf, "上料检测退出");
        }
    }
}