From a9d6ea06bc8e12fa9f9c78e8c7ce5538b83c6373 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期二, 03 九月 2024 16:08:49 +0800
Subject: [PATCH] 批量操作
---
src/main/java/com/whyc/service/DevA200TestparamService.java | 49 +++++++++++++++++++++++++++++++++++++++++--------
1 files changed, 41 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/whyc/service/DevA200TestparamService.java b/src/main/java/com/whyc/service/DevA200TestparamService.java
index ddc8de2..c81ac73 100644
--- a/src/main/java/com/whyc/service/DevA200TestparamService.java
+++ b/src/main/java/com/whyc/service/DevA200TestparamService.java
@@ -77,23 +77,37 @@
}
//鎵归噺璁剧疆a200鍧囪 浠弬鏁�
- public Object setA200ParamPl(A200ResDto param) {
+ public Object setA200ParamPl2(A200ResDto param) {
Map<Integer,Object> map=new HashMap<>();
int size=param.getDevIds().size();
try {
ThreadPoolExecutor poolExecutor = ThreadPoolExecutorFactory.getPoolExecutor();
CountDownLatch latch = new CountDownLatch(size);
- for (Integer devId:param.getDevIds()) {
+ for (int i=0;i<size;i++) {
+ int finaldevId=param.getDevIds().get(i);
poolExecutor.execute(() -> {
- param.setDevId(devId);
+ int finalIIdevId=finaldevId;
+ param.setDevId(finalIIdevId);
ResultA200Dto dto= (ResultA200Dto) setA200Param(param);
- map.put(param.getDevId(),dto);
+ map.put(finalIIdevId,dto);
latch.countDown();
});
}
- latch.await(10, TimeUnit.MINUTES);
+ latch.await(4, TimeUnit.MINUTES);
} catch (InterruptedException e) {
e.printStackTrace();
+ }
+ return new Response().setII(1,true,map,"鎵归噺璁剧疆a200鍧囪 浠弬鏁�");
+ }
+ //鎵归噺璁剧疆a200鍧囪 浠弬鏁�
+ public Object setA200ParamPl(A200ResDto param) {
+ Map<Integer,Object> map=new HashMap<>();
+ int size=param.getDevIds().size();
+ for (int i=0;i<size;i++) {
+ int finaldevId=param.getDevIds().get(i);
+ param.setDevId(finaldevId);
+ ResultA200Dto dto= (ResultA200Dto) setA200Param(param);
+ map.put(finaldevId,dto);
}
return new Response().setII(1,true,map,"鎵归噺璁剧疆a200鍧囪 浠弬鏁�");
}
@@ -124,7 +138,7 @@
}
//鎵归噺鍚姩a200鍧囪 浠�
- public Response startA200ParamPl(List<Integer> devIds,int type) {
+ public Response startA200ParamPl2(List<Integer> devIds,int type) {
Map<Integer,Object> map=new HashMap<>();
try {
ThreadPoolExecutor poolExecutor = ThreadPoolExecutorFactory.getPoolExecutor();
@@ -144,7 +158,17 @@
}
//鎵归噺鍚姩a200鍧囪 浠�
- public Response stopA200ParamPl(List<Integer> devIds) {
+ public Response startA200ParamPl(List<Integer> devIds,int type) {
+ Map<Integer,Object> map=new HashMap<>();
+ for (int devId:devIds) {
+ ResultA200Dto dto= (ResultA200Dto) startA200Param(devId,type);
+ map.put(devId,dto);
+ }
+ return new Response().set(1,true,"鎵归噺鎺у埗a200鍧囪 浠�");
+ }
+
+ //鎵归噺鍋滄a200鍧囪 浠�
+ public Response stopA200ParamPl2(List<Integer> devIds) {
Map<Integer,Object> map=new HashMap<>();
try {
ThreadPoolExecutor poolExecutor = ThreadPoolExecutorFactory.getPoolExecutor();
@@ -160,7 +184,16 @@
} catch (InterruptedException e) {
e.printStackTrace();
}
- return new Response().set(1,true,"鎵归噺鎺у埗a200鍧囪 浠�");
+ return new Response().set(1,true,"鎵归噺鍋滄a200鍧囪 浠�");
+ }
+ //鎵归噺鍋滄a200鍧囪 浠�
+ public Response stopA200ParamPl(List<Integer> devIds) {
+ Map<Integer,Object> map=new HashMap<>();
+ for (int devId:devIds) {
+ ResultA200Dto dto= (ResultA200Dto) stopA200Param(devId);
+ map.put(devId,dto);
+ }
+ return new Response().set(1,true,"鎵归噺鍋滄a200鍧囪 浠�");
}
//灏哾to鎷疯礉鑷硃aram
--
Gitblit v1.9.1