| | |
|---|
| | | for (Integer devId:param.getDevIds()) { |
|---|
| | | poolExecutor.execute(() -> { |
|---|
| | | param.setDevId(devId); |
|---|
| | | ResultA200Dto dto= (ResultA200Dto) setActmParam(param); |
|---|
| | | ResultActmDto dto= (ResultActmDto) setActmParam(param); |
|---|
| | | map.put(devId,dto); |
|---|
| | | latch.countDown(); |
|---|
| | | }); |
|---|
| | |
|---|
| | | Map<Integer,Object> map=new HashMap<>(); |
|---|
| | | for (Integer devId:devIds) { |
|---|
| | | ResultActmDto dto= (ResultActmDto) controllerActmParam(devId,index,type); |
|---|
| | | if(dto.getCode().equals("200")&&type==1){ |
|---|
| | | if(type==1){ |
|---|
| | | UpdateWrapper wrapper=new UpdateWrapper(); |
|---|
| | | wrapper.eq("dev_id",devId); |
|---|
| | | wrapper.set("batch_state",1); |
|---|
