2
schangxiang@126.com
2024-06-12 e1ab660bbe63db8c5382550a2f49247d3aa51c3a
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
using System;
using System.Collections.Generic;
using iWare_SCADA_Model;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using iWare_SCADA_BusinessLogical.Utils;
using System.Threading;
using iWare_SCADA_BusinessLogical.BLL;
 
namespace iWare_SCADA_BusinessLogical
{
    /// <summary>
    /// 工件推出标记,确认工件是否被推出(不合格)
    /// </summary>
    public class DataCaptureHandler_OP0503 : DataCaptureHandler
    {
        public static readonly DataCaptureHandler_OP0503 Instance = new DataCaptureHandler_OP0503();
 
        public DataCaptureHandler_OP0503()
        {
        }
        public override string WorkingProcedure
        {
            get { return _dataCaptureConfig.WorkingProcedure; }
        }
 
        public override string DataCapturePointCode
        {
            get { return _dataCaptureConfig.DataCapturePointCode; }
        }
        public override string DataCapturePointCname
        {
            get { return _dataCaptureConfig.DataCapturePointCname; }
        }
        public override void RefreshDataList(List<DataCaptureConfig> dataCaptureConfig)
        {
 
        }
        public override void DataCaptureStart()
        {
            if (IsCaptureflag)
            {
                var plcService = PLCManger.GetSinglePLCService(_dataCaptureConfig);
                if (plcService == null)
                {
                    SystemValue.lbl_Alert_OP0503 = $"{RandomHelper.GenerateRandomCode(4)} 没有找到{_dataCaptureConfig.WorkingProcedure}的PLC设备";
                    return;
                }
                if (plcService != null && !plcService.IsConnected)
                {
                    plcService.Close();
                    plcService.OpenService();
                }
                while (true)
                {
                    try
                    {
                        if (plcService == null || !plcService.IsConnected)
                        {
                            SystemValue.lbl_Alert_OP0503 = $" {RandomHelper.GenerateRandomCode(4)} {_dataCaptureConfig.WorkingProcedure} PLC连接已断开,正在尝试打开!";
                            plcService.Close();
                            plcService.OpenService();
                            Thread.Sleep(100);
                            continue;
                        }
                        else
                        {
                            object value = plcService.ReadValuePoint(_dataCaptureConfig.DbNumber, _dataCaptureConfig.Offset, PLCManger.GetTypeForString(_dataCaptureConfig.DataCaptureColumnType));
 
                            if (SystemValue.value_OP0503.Equals("0") && value.ToString().Equals("1"))
                            {
                                string WorkPieceID = "";
                                string HowToExit = "";
 
                                foreach (var col in colConfig.Where(o => o.DataCapturePointCode == DataCapturePointCode))
                                {
                                    switch (col.DataCaptureColumnTabelName)
                                    {
                                        case "WorkPieceID":
                                            WorkPieceID = plcService.ReadValuePoint(col.DbNumber, col.Offset, PLCManger.GetTypeForString(col.DataCaptureColumnType)).ToString();
                                            break;
                                        case "HowToExit":
                                            HowToExit = plcService.WriteValuePoint(col.DbNumber, col.Offset, PLCManger.GetTypeForString(col.DataCaptureColumnType)).ToString();
                                            break;
                                        default:
                                            break;
                                    }
                                }
 
                                if (WorkPieceID.Length != 22)
                                {
                                    SystemValue.lbl_Alert_OP0503 = $"工件推出标记,确认工件号:【" + WorkPieceID + "】长度异常,长度不等于22位";
                                    Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"工件推出标记,确认工件号:【" + WorkPieceID + "】长度异常,长度不等于22位");
                                }
                                else
                                {
                                    WorkPieceLog wplog = new WorkPieceLog();
                                    wplog.Id = Yitter.IdGenerator.YitIdHelper.NextId();
                                    wplog.WorkPieceID = WorkPieceID;
                                    wplog.WorkingProcedure = WorkingProcedure;
                                    wplog.EquipmentID = WorkingProcedure;
                                    wplog.Remarks = WorkingProcedure;
                                    wplog.MonitoringPoint = DataCapturePointCode;
                                    wplog.CreatedTime = DateTimeHelper.GetDateTime();
                                    wplog.CreatedUserName = DataCapturePointCode;
                                    wplog.IsDeleted = false;
 
                                    if ("NOOK".Equals(HowToExit))
                                    {
                                        // NOOK退出
                                        //更新WorkPieceInfo表以及插入WorkPieceLog表和WorkPieceInfoLog表
                                        WorkPieceInfoManager.WorkPiecePushOff(wplog, PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure));
                                    }
                                    else if("SPC".Equals(HowToExit))
                                    {
                                        
                                        //更新WorkPieceInfo表以及插入WorkPieceLog表和WorkPieceInfoLog表
                                        WorkPieceInfoManager.WorkPieceSPCPushOff(wplog, PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure));
                                    }
                                }
                            }
 
                            SystemValue.value_OP0503 = value.ToString();
                        }
                    }
                    catch (Exception ex)
                    {
                        SystemValue.lbl_Alert_OP0503 = $"读取{WorkingProcedure}工序工件推出标记,确认工件是否被推出监控,出现异常,请查看日志!";
                        Log4NetHelper.WriteErrorLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"读取{WorkingProcedure}工序工件推出标记,确认工件是否被推出监控,数据时异常:", ex);
                    }
 
                    //线程多久执行一次(不包含业务处理时间)
                    if (!_dataCaptureConfig.DataCaptureFrequency.HasValue || _dataCaptureConfig.DataCaptureFrequency < 10)
                    {
                        Thread.Sleep(5000);
                    }
                    else
                    {
                        Thread.Sleep(_dataCaptureConfig.DataCaptureFrequency.Value);
                    }
                }
            }
            else
            {
                SystemValue.lbl_Alert_OP0503 = $"读取{WorkingProcedure}工序工件推出标记,确认工件是否被推出监控,请确认配置信息!";
                Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"读取{WorkingProcedure}工序工件推出标记,确认工件是否被推出监控,请确认是否配置异常");
            }
        }
    }
}