Merge branch 'master' of http://bore.pub:10439/r/HangZhouMes

ZengTao

2024-10-24 22fb46f2db1714a6b450b353669d26908884653f

 hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/opccallback/CacheGlassSubscriptionCallback.java

@@ -1,8 +1,5 @@
package com.mes.opccallback;

import com.mes.milo.model.ReadWriteEntity;
import com.mes.milo.runner.subscription.SubscriptionCallback;
import com.mes.milo.service.MiloService;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.milo.opcua.sdk.client.subscriptions.ManagedDataItem;
import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
@@ -16,20 +13,20 @@
 */
@Service
@Slf4j
public class CacheGlassSubscriptionCallback implements SubscriptionCallback {
public class CacheGlassSubscriptionCallback  {

    @Autowired
    MiloService miloService;

    @Override
    public void onSubscribe(ManagedDataItem dataItem, DataValue value) {
        try {
            log.info("{}___________{}" + dataItem, value);
            ReadWriteEntity readWriteEntity = miloService.readFromOpcUa("my.device.x1");
            log.info("{}___________{}" + readWriteEntity);
        } catch (Exception e) {

        }

    }
//    @Autowired
//    MiloService miloService;
//
//    @Override
//    public void onSubscribe(ManagedDataItem dataItem, DataValue value) {
//        try {
//            log.info("{}___________{}" + dataItem, value);
//            ReadWriteEntity readWriteEntity = miloService.readFromOpcUa("my.device.x1");
//            log.info("{}___________{}" + readWriteEntity);
//        } catch (Exception e) {
//
//        }
//
//    }
}