| | |
|---|
| | | package com.billion.main.plc; |
|---|
| | | |
|---|
| | | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; |
|---|
| | | import com.billion.main.da.service.IDaParamCollectionService; |
|---|
| | | import com.billion.main.da.service.IDaStationCollectionService; |
|---|
| | | import com.billion.main.plc.constant.Constants; |
|---|
| | | import com.billion.main.plc.sub.OPCUaSubscription; |
|---|
| | | import com.billion.main.sc.domain.ScOpcConf; |
|---|
| | | import com.billion.main.sc.service.IScCollectionParamConfService; |
|---|
| | | import com.billion.main.sc.service.IScOpcConfService; |
|---|
| | | import com.kangaroohy.milo.service.MiloService; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.boot.ApplicationArguments; |
|---|
| | | import org.springframework.boot.ApplicationRunner; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | @Component |
|---|
| | | public class CustomRunner implements ApplicationRunner { |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private MiloService miloService; |
|---|
| | | @Autowired |
|---|
| | | private IScOpcConfService opcConfService; |
|---|
| | | @Autowired |
|---|
| | | private IScCollectionParamConfService collectionParamConfService; |
|---|
| | | @Autowired |
|---|
| | | private IDaParamCollectionService paramCollectionService; |
|---|
| | | @Autowired |
|---|
| | | private IDaStationCollectionService stationCollectionService; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void run(ApplicationArguments args) throws Exception { |
|---|
| | | |
|---|
| | | OPCUaSubscription opcUaSubscription = new OPCUaSubscription( |
|---|
| | | miloService, |
|---|
| | | collectionParamConfService, |
|---|
| | | paramCollectionService, |
|---|
| | | stationCollectionService); |
|---|
| | | |
|---|
| | | List<String> lists = getSubList(); |
|---|
| | | System.out.println("订阅内容："+lists); |
|---|
| | | miloService.subscriptionFromOpcUa(lists,50,opcUaSubscription); |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 订阅内容 |
|---|
| | | */ |
|---|
| | | public List<String> getSubList(){ |
|---|
| | | List<String> lists = opcConfService.list(new LambdaQueryWrapper<ScOpcConf>() |
|---|
| | | .eq(ScOpcConf::getSubscribe,Constants.YES)) |
|---|
| | | .stream().map(ScOpcConf::getNode).collect(Collectors.toList()); |
|---|
| | | return lists; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | //package com.billion.main.plc; |
|---|
| | | // |
|---|
| | | // |
|---|
| | | //import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | //import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; |
|---|
| | | //import com.billion.main.da.service.IDaParamCollectionService; |
|---|
| | | //import com.billion.main.da.service.IDaStationCollectionService; |
|---|
| | | //import com.billion.main.plc.constant.Constants; |
|---|
| | | //import com.billion.main.plc.sub.OPCUaSubscription; |
|---|
| | | //import com.billion.main.sc.domain.ScOpcConf; |
|---|
| | | //import com.billion.main.sc.service.IScCollectionParamConfService; |
|---|
| | | //import com.billion.main.sc.service.IScOpcConfService; |
|---|
| | | //import com.kangaroohy.milo.service.MiloService; |
|---|
| | | //import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | //import org.springframework.boot.ApplicationArguments; |
|---|
| | | //import org.springframework.boot.ApplicationRunner; |
|---|
| | | //import org.springframework.stereotype.Component; |
|---|
| | | // |
|---|
| | | //import java.util.List; |
|---|
| | | //import java.util.stream.Collectors; |
|---|
| | | // |
|---|
| | | //@Component |
|---|
| | | //public class CustomRunner implements ApplicationRunner { |
|---|
| | | // |
|---|
| | | // @Autowired |
|---|
| | | // private MiloService miloService; |
|---|
| | | // @Autowired |
|---|
| | | // private IScOpcConfService opcConfService; |
|---|
| | | // @Autowired |
|---|
| | | // private IScCollectionParamConfService collectionParamConfService; |
|---|
| | | // @Autowired |
|---|
| | | // private IDaParamCollectionService paramCollectionService; |
|---|
| | | // @Autowired |
|---|
| | | // private IDaStationCollectionService stationCollectionService; |
|---|
| | | // |
|---|
| | | // @Override |
|---|
| | | // public void run(ApplicationArguments args) throws Exception { |
|---|
| | | // |
|---|
| | | // OPCUaSubscription opcUaSubscription = new OPCUaSubscription( |
|---|
| | | // miloService, |
|---|
| | | // collectionParamConfService, |
|---|
| | | // paramCollectionService, |
|---|
| | | // stationCollectionService); |
|---|
| | | // |
|---|
| | | // List<String> lists = getSubList(); |
|---|
| | | // System.out.println("订阅内容："+lists); |
|---|
| | | // miloService.subscriptionFromOpcUa(lists,50,opcUaSubscription); |
|---|
| | | // |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // /** |
|---|
| | | // * 订阅内容 |
|---|
| | | // */ |
|---|
| | | // public List<String> getSubList(){ |
|---|
| | | // List<String> lists = opcConfService.list(new LambdaQueryWrapper<ScOpcConf>() |
|---|
| | | // .eq(ScOpcConf::getSubscribe,Constants.YES)) |
|---|
| | | // .stream().map(ScOpcConf::getNode).collect(Collectors.toList()); |
|---|
| | | // return lists; |
|---|
| | | // } |
|---|
| | | //} |
|---|
| | | // |
|---|
