From 43fdc41b97982e062b10840bc89baf16e86576d2 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期二, 03 九月 2024 13:56:10 +0800
Subject: [PATCH] 批量设置参数修改
---
src/main/java/com/whyc/service/DevA200TestparamService.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/whyc/service/DevA200TestparamService.java b/src/main/java/com/whyc/service/DevA200TestparamService.java
index cdf3c3e..6bf4b99 100644
--- a/src/main/java/com/whyc/service/DevA200TestparamService.java
+++ b/src/main/java/com/whyc/service/DevA200TestparamService.java
@@ -77,13 +77,15 @@
}
//鎵归噺璁剧疆a200鍧囪 浠弬鏁�
- public Object setA200ParamPl(List<A200ResDto> params) {
+ public Object setA200ParamPl(A200ResDto param) {
Map<Integer,Object> map=new HashMap<>();
+ int size=param.getDevIds().size();
try {
ThreadPoolExecutor poolExecutor = ThreadPoolExecutorFactory.getPoolExecutor();
- CountDownLatch latch = new CountDownLatch(params.size());
- for (A200ResDto param:params) {
+ CountDownLatch latch = new CountDownLatch(size);
+ for (Integer devId:param.getDevIds()) {
poolExecutor.execute(() -> {
+ param.setDevId(devId);
ResultA200Dto dto= (ResultA200Dto) setA200Param(param);
map.put(param.getDevId(),dto);
latch.countDown();
@@ -93,7 +95,7 @@
} catch (InterruptedException e) {
e.printStackTrace();
}
- return new Response().set(1,true,"鎵归噺璁剧疆a200鍧囪 浠弬鏁�");
+ return new Response().setII(1,true,map,"鎵归噺璁剧疆a200鍧囪 浠弬鏁�");
}
//鍚姩a200鍧囪 浠斁鐢�/鍏呯數
--
Gitblit v1.9.1