From c583e5683bac5d11750be01b8a3c4147e8f16026 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期三, 06 十一月 2024 23:21:53 +0800
Subject: [PATCH] 1、opc订阅服务为阻塞模式,配置需要开启多线程 2、新增订阅回调函数,用于执行任务,完成任务时调用 3、目前测试效果来看,一个定时任务只能有一个订阅任务,可订阅多个节点,当某个节点发生变化时,回调任务仅获取变化节点的信息

---
 hangzhoumesParent/moduleService/GlassStorageModule/src/test/java/mes/GlassStorageModuleApplicationTest.java |   52 ++++++++++++++++++++++++++--------------------------
 1 files changed, 26 insertions(+), 26 deletions(-)

diff --git a/hangzhoumesParent/moduleService/GlassStorageModule/src/test/java/mes/GlassStorageModuleApplicationTest.java b/hangzhoumesParent/moduleService/GlassStorageModule/src/test/java/mes/GlassStorageModuleApplicationTest.java
index dd22447..5905cdc 100644
--- a/hangzhoumesParent/moduleService/GlassStorageModule/src/test/java/mes/GlassStorageModuleApplicationTest.java
+++ b/hangzhoumesParent/moduleService/GlassStorageModule/src/test/java/mes/GlassStorageModuleApplicationTest.java
@@ -75,36 +75,36 @@
     /**
      * 娴嬭瘯
      */
-    @Test
-    public void testWebSocket() {
-        List<RawGlassStorageTask> list=rawGlassStorageTaskService.findAll();
-        log.info("杩斿洖鍐呭锛歿}",list);
-    }
+//    @Test
+//    public void testWebSocket() {
+//        List<RawGlassStorageTask> list=rawGlassStorageTaskService.findAll();
+//        log.info("杩斿洖鍐呭锛歿}",list);
+//    }
 
     /**
      * 娴嬭瘯淇敼WebSocket  鍙傛暟
      */
-    @Test
-    public void testWebSocketArgument() {
-        RawGlassTaskRequest request=new RawGlassTaskRequest();
-        //璁剧疆鍙傛暟锛�
-        DateFormat df = new SimpleDateFormat("yyyy-MM-dd");
-        Date startDate=null;
-        Date endDate=null;
-        try {
-            startDate= df.parse("2022-01-01");
-            endDate= df.parse("2025-01-01");
-        }catch (ParseException e){
-            e.printStackTrace();
-
-        request.setCreateTime(startDate);//
-        request.setPatternQuantity(endDate);
-        request.setEnableState(new ArrayList<Integer>());
-        request.setEnableType(new ArrayList<Integer>());
-        String list=rawGlassStorageTaskService.setRawGlassTaskRequest(request);
-        log.info("杩斿洖鍐呭锛歿}",list);
-    }
-    }
+//    @Test
+//    public void testWebSocketArgument() {
+//        RawGlassTaskRequest request=new RawGlassTaskRequest();
+//        //璁剧疆鍙傛暟锛�
+//        DateFormat df = new SimpleDateFormat("yyyy-MM-dd");
+//        Date startDate=null;
+//        Date endDate=null;
+//        try {
+//            startDate= df.parse("2022-01-01");
+//            endDate= df.parse("2025-01-01");
+//        }catch (ParseException e){
+//            e.printStackTrace();
+//
+//        request.setCreateTime(startDate);//
+//        request.setPatternQuantity(endDate);
+//        request.setEnableState(new ArrayList<Integer>());
+//        request.setEnableType(new ArrayList<Integer>());
+//        String list=rawGlassStorageTaskService.setRawGlassTaskRequest(request);
+//        log.info("杩斿洖鍐呭锛歿}",list);
+//    }
+//    }
 
 
 

--
Gitblit v1.8.0