blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
cl
2024-07-05 8e3998d3a3b55eb493a290df869187110b47fe78 
 jcdm-main/src/main/java/com/jcdm/main/plcserver/CustomRunner.java


@@ -1,12 +1,15 @@


package com.jcdm.main.plcserver;






import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.jcdm.main.constant.Constants;


import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService;


import com.jcdm.main.da.opcuaconfig.domain.DaOpcuaConfig;


import com.jcdm.main.da.opcuaconfig.service.IDaOpcuaConfigService;


import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService;


import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService;


import com.jcdm.main.da.testDeviceInterface.service.IDaTestDeviceInterfaceService;


import com.jcdm.main.da.testDeviceInterfaceTemp.service.IDaTestDeviceInterfaceTempService;


import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService;


import com.jcdm.main.plcserver.conf.OPCElement;


import com.jcdm.main.plcserver.sub.OPCUaSubscription;


import com.kangaroohy.milo.service.MiloService;


import org.springframework.beans.factory.annotation.Autowired;


@@ -14,8 +17,8 @@


import org.springframework.boot.ApplicationRunner;


import org.springframework.stereotype.Component;




import java.util.ArrayList;


import java.util.List;


import java.util.stream.Collectors;




@Component


public class CustomRunner implements ApplicationRunner {


@@ -32,17 +35,26 @@


    @Autowired


    private IDaParamCollectionService daParamCollectionService;




    @Autowired


    private IDaCollectionParamConfService daCollectionParamConfService;




    @Autowired


    private IOmProductionOrdeInfoService omProductionOrdeInfoService;






    @Autowired


    private IDaTestDeviceInterfaceService daTestDeviceInterfaceService;


    private IDaOpcuaConfigService daOpcuaConfigService;




    @Autowired


    private IDaTestDeviceInterfaceTempService daTestDeviceInterfaceTempService;




    @Override


    public void run(ApplicationArguments args) throws Exception {


        //分段010-065段


        Constants.OP020_OP090.add(Constants.OP020);


        Constants.OP020_OP090.add(Constants.OP030);


        Constants.OP020_OP090.add(Constants.OP040);


        Constants.OP020_OP090.add(Constants.OP050);


        Constants.OP020_OP090.add(Constants.OP060);


        Constants.OP020_OP090.add(Constants.OP090);




        OPCUaSubscription opcUaSubscription = new OPCUaSubscription(


                miloService,


@@ -50,70 +62,21 @@


                collectionParamConfService,


                daParamCollectionService,


                omProductionOrdeInfoService,


                daTestDeviceInterfaceService);


                daTestDeviceInterfaceTempService);




        List<String> lists = getSubList();


        System.out.println("订阅内容："+lists);


        miloService.subscriptionFromOpcUa(lists,50,opcUaSubscription);




    }




    /**


     * 订阅内容


     */


    public List<String> getSubList(){


        List<String> lists = new ArrayList<>();


        lists.add(OPCElement.PACK_OP230_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP240_RecordData);//请求记录数据.


//        lists.add(OPCElement.PACK_OP240_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP2501_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP2502_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP2503_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP260_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP260_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP270_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP270_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP290_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP290_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP300A_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP300B_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP310A_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP310B_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP330_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP380_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP380_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP400_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP400_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP410_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP410_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP4301_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP4302_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP4303_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP4304_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP440_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP450_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP450_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP460_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP460_AngleResult);//请求记录数据


//        lists.add(OPCElement.PACK_OP4801_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP4802_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP4803_RecordData);//请求记录数据


//


//        lists.add(OPCElement.PACK_OP500_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP500_AngleResult);//请求记录数据


////


//        lists.add(OPCElement.PACK_OP280_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP320A_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP320B_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP340A_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP340B_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP350A_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP350B_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP360_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP365_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP370_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP390_RecordData);//请求记录数据


//        lists.add(OPCElement.PACK_OP470_RecordData);//请求记录数据




        List<String> lists = daOpcuaConfigService.list(new LambdaQueryWrapper<DaOpcuaConfig>()


                        .eq(DaOpcuaConfig::getState, Constants.USE_ING))


                .stream().map(DaOpcuaConfig::getNode).collect(Collectors.toList());


        return lists;


    }


}