工业互联网-基于OPC 的简单数采系统设计之二

public static class LineBuilder
    {
        //1)创建产线
        //2)创建各个站点
        //3)创建站点属性
        //4)创建站点脚本
        //5)创建站点脚本规则
        //6)装配好产线、站点、属性、脚本

        public static Engine engine;
        //private static List properties = new List();
        //private static List allStations = new List();

        public static Line Build(int line_id)
        {
            DateTime now = DateTime.Now;
            engine = Engine.CreateInstance();
            engine.Init();
            mes_ent_info ent = engine.conmetMesService.GetEntInfoByIdName(line_id, null,  null);
            Line line2 = new Line(Guid.NewGuid().ToString(), ent.ent_name, ent.ent_description);
            line2.LineId = ent.ent_id;
            line2.Continer = engine;
            
            engine.Line = line2;

            buildAllStation(line2);
            
            //var op20Cup = buildStation("192.168.1.20", Guid.NewGuid().ToString(), "AssyL2OP20CUP", "OP20CUP", line2);
            //buildProperty("stp_partNum1", "AssyL2OP20CUP.AssyL2OP20CUP.stp_partNum1", op20Cup, TagType.Trigger, DataType.String);
            //var op20Cup_stp_partSerial1Prop = buildProperty("stp_partSerial1", "AssyL2OP20CUP.AssyL2OP20CUP.stp_partSerial1", op20Cup, TagType.Trigger, DataType.String);
            //var op20Cup_PartStatus1Prop = buildProperty("stp_partStatus1", "AssyL2OP20CUP.AssyL2OP20CUP.stp_partStatus1", op20Cup, TagType.Trigger, DataType.Int);
            //buildProperty("stp_prod1Arrive", "AssyL2OP20CUP.AssyL2OP20CUP.stp_prod1Arrive", op20Cup, TagType.Trigger, DataType.Bool);
            //buildProperty("stp_prod1Start", "AssyL2OP20CUP.AssyL2OP20CUP.stp_prod1Start", op20Cup, TagType.Trigger, DataType.Bool);
            //buildProperty("stp_prod1Finish", "AssyL2OP20CUP.AssyL2OP20CUP.stp_prod1Finish", op20Cup, TagType.Trigger, DataType.Bool);
            //buildProperty("stp_prod1Leave", "AssyL2OP20CUP.AssyL2OP20CUP.stp_prod1Start", op20Cup, TagType.Trigger, DataType.Bool);
            //buildProperty("stp_workOrder1", "AssyL2OP20CUP.AssyL2OP20CUP.stp_workOrder1", op20Cup, TagType.Trigger, DataType.String);

            //buildProperty("stp_upFinalPre", "AssyL2OP20CUP.AssyL2OP20CUP.stp_upFinalPre", op20Cup, TagType.Normal, DataType.Float);
            //buildProperty("rec_downPreHeadDwelltime", "AssyL2OP20CUP.AssyL2OP20CUP.rec_downPreHeadDwelltime", op20Cup, TagType.Normal, DataType.Float);
            //buildProperty("rec_downPreHeadPre", "AssyL2OP20CUP.AssyL2OP20CUP.rec_downPreHeadPre", op20Cup, TagType.Normal, DataType.Float);
            //buildProperty("rec_downPreHeadPreHiLimit", "AssyL2OP20CUP.AssyL2OP20CUP.rec_downPreHeadPreHiLimit", op20Cup, TagType.Normal, DataType.Float);
            //buildProperty("rec_downPreHeadPreLoLimit", "AssyL2OP20CUP.AssyL2OP20CUP.rec_downPreHeadPreLoLimit", op20Cup, TagType.Normal, DataType.Float);
            //buildProperty("rec_upPreHeadPre", "AssyL2OP20CUP.AssyL2OP20CUP.rec_upPreHeadPre", op20Cup, TagType.Normal, DataType.Float);
            //buildProperty("rec_upPreHeadPreHiLimit", "AssyL2OP20CUP.AssyL2OP20CUP.rec_upPreHeadPreHiLimit", op20Cup, TagType.Normal, DataType.Float);
            //buildProperty("rec_upPreHeadPreLoLimit", "AssyL2OP20CUP.AssyL2OP20CUP.rec_upPreHeadPreLoLimit", op20Cup, TagType.Normal, DataType.Float);
            //buildProperty("stp_downFinalPre", "AssyL2OP20CUP.AssyL2OP20CUP.stp_downFinalPre", op20Cup, TagType.Normal, DataType.Float);


            //Script_partSerialChange op20partSerialChange = new Script_partSerialChange(op20Cup);
            //Script_stp_partStatus1Change op20partStatus1Change = new Script_stp_partStatus1Change(op20Cup);
            //Script_onTrueTest op20OnTrueTest = new Script_onTrueTest(op20Cup);
            //Script_WhileTrueTest op20WhileTrueTest = new Script_WhileTrueTest(op20Cup);
            //op20Cup.Scripts.AddRange(new List() { op20partSerialChange, op20partStatus1Change, op20OnTrueTest, op20WhileTrueTest });

            //line2.Stations.AddRange(new List() { op20Cup });

            return null;
        }

        private static Station buildStation(string ip, string sid, string name, string des, Line line)
        {
            var station = new Station(sid, name, des);
            station.Adress = ip;
            station.Continer = line;
            station.CurrState = State.Idle;
            station.Enable = true;
            return station;
        }

        
        private static void buildAllStation(Line line)
        {
            List entList = engine.co服务器托管网nmetMesService.GetEntInfoByParentId(line.LineId);
            
            foreach (var ent in entList)
            {
                var station = buildStation("", ent.ent_id.ToString(), ent.ent_name, ent.ent_description, line);
                //allStations.Add(station);
                line.Stations.Add(station);
                buildAllPropertys(station);
                
            }
            if (System.IO.File.Exists("Conmet.MES.Scripts.dll") == false)
            {
                engine.messageQueue.Enqueue($"Error:Class:LineBuilder,Method:buildAllStation-buildAllScript,Param:[{line.Name}],Msg:Not Find 'Conmet.MES.Scripts.dll'");
                return;
            }
            Assembly asm = Assembly.Load("Conmet.MES.Scripts");//.GetExecutingAssembly();
            foreach (var station in line.Stations)
            {
                buildAllScript(asm, station);
            }
        }

        public static void buildAllScript(Assembly asm, Station station)
        {
            var ent_scripts = engine.conmetMesService.GetEntScriptByEntId(int.Parse(station.SID), null, 1, null, 1);
            foreach(var script in ent_scripts)
            {
                //engine.messageQueue.Enqueue($"Info:Class:LineBuilder,Method:buildAllSc服务器托管网ript,NeedAdd:{ script.class_path}");
                object[] parameters = new object[1];
                parameters[0] = station;
                Object obj = asm.CreateInstance(script.class_path, true, BindingFlags.Default, null, parameters, null, null);
                if(obj is Script)
                {
                    Script sc = obj as Script;
                    sc.Name = script.name;
                    station.Scripts.Add(sc);
                    engine.messageQueue.Enqueue($"Info:Class:LineBuilder,Method:buildAllScript,Add:{ sc.Name}");
                }
                //script.class_path;
            }
        }

        public static List buildAllPropertys(Station station)
        {
            var ent_propertys = engine.conmetMesService.GetPropertys(int.Parse(station.SID), null, null, 1);
            var ent_tags = engine.opcservice.GetOpcTagByEntAndNo(int.Parse(station.SID), null);
            List properties = new List();
            foreach(var property in ent_propertys)
            {
                string adress = "";
                TagType tagType = 0;
                if(property.is_tag > 0)
                {
                    mes_opc_tag tag = ent_tags.Where(s => s.property_id == property.id).FirstOrDefault();
                    if(tag != null)
                    {
                        adress = tag.tag_adress;
                        tagType = (tag.attribute == "1" ? TagType.Trigger : TagType.Normal);
                    }
                    else
                    {
                        engine.messageQueue.Enqueue($"Error:Class:LineBuilder,Method:buildAllPropertys,Param:{property.property_name},Msg:Not Find Match OpcTag");
                    }
                }
                //DataType dataType;

                var pro = buildProperty(property.property_name, adress, station, tagType, (DataType)property.data_type);
                properties.Add(pro);

            }

            return properties;
        }

        private static Property buildProperty(string propertyName, string adress, Station station, TagType tagType, DataType dataType)
        {
            Property prop = new Property();
            prop.CurrDataType = dataType;
            prop.Container = station;
            prop.Name = propertyName;
            prop.OldValue = "";
            prop.Value = "";
            OpcTag tag = new OpcTag(Guid.NewGuid().ToString(), propertyName, "", adress, prop, true, tagType);
            prop.Tag = tag;
            station.Properties.Add(prop);
            return prop;
        }
    }