批量操作

whyclxw

2024-09-03 a9d6ea06bc8e12fa9f9c78e8c7ce5538b83c6373

 src/main/java/com/whyc/service/DevActmTestparamService.java

@@ -69,14 +69,21 @@
        String url="http://"+dinf.getDevIp()+":8080/webService/setTestParameter";
        //将请求头部和参数合成一个请求
        MultiValueMap<String, Object> paramMap = new LinkedMultiValueMap<>();
        String paramJson= JSONObject.toJSONString(param);
        paramMap.add("testParameter",paramJson);
        paramMap.add("batteryStorageIndex",param.getBatteryStorageIndex());
        paramMap.add("moduleCode",param.getModuleCode());
        paramMap.add("workMode",param.getWorkMode());
        paramMap.add("batteryType",param.getBatteryType());
        paramMap.add("batteryNumber",param.getBatteryNumber());
        paramMap.add("ntcCount",param.getNtcCount());
        paramMap.add("testBatteryArray",param.getTestBatteryArray());
        paramMap.add("voltage",param.getVoltage());
        paramMap.add("current",param.getCurrent());
        ResultActmDto dto= (ResultActmDto) TestparamHttpUtil.postforform_dataActm(restTemplate,url,paramMap);
        return dto;
    }

    //批量设置Actm均衡仪参数
    public Object setActmParamPl(ActmResDto param) {
    public Object setActmParamPl2(ActmResDto param) {
        Map<Integer,Object> map=new HashMap<>();
        int size=param.getDevIds().size();
        try {
@@ -86,13 +93,25 @@
                poolExecutor.execute(() -> {
                    param.setDevId(devId);
                    ResultA200Dto dto= (ResultA200Dto) setActmParam(param);
                    map.put(param.getDevId(),dto);
                    map.put(devId,dto);
                    latch.countDown();
                });
            }
            latch.await(10, TimeUnit.MINUTES);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return new Response().setII(1,true,map,"批量设置Actm均衡仪参数");
    }

    //批量设置Actm均衡仪参数
    public Object setActmParamPl(ActmResDto param) {
        Map<Integer,Object> map=new HashMap<>();
        int size=param.getDevIds().size();
        for (Integer devId:param.getDevIds()) {
            param.setDevId(devId);
            ResultA200Dto dto= (ResultA200Dto) setActmParam(param);
            map.put(devId,dto);
        }
        return new Response().setII(1,true,map,"批量设置Actm均衡仪参数");
    }
@@ -120,7 +139,7 @@


    //批量控制Actm均衡仪
    public Response controllActmParamPl(List<ActmPlContDto> actmPlContDtos) {
    public Response controllActmParamPl2(List<ActmPlContDto> actmPlContDtos) {
        Map<Integer,Object> map=new HashMap<>();
        try {
            ThreadPoolExecutor poolExecutor = ThreadPoolExecutorFactory.getPoolExecutor();
@@ -139,6 +158,16 @@
        return new Response().set(1,true,"批量设置Actm均衡仪参数");
    }

    //批量控制Actm均衡仪
    public Response controllActmParamPl(List<ActmPlContDto> actmPlContDtos) {
        Map<Integer,Object> map=new HashMap<>();
        for (ActmPlContDto actmPlContDto:actmPlContDtos) {
                ResultActmDto dto= (ResultActmDto) controllerActmParam(actmPlContDto.getDevId(),actmPlContDto.getIndex(),actmPlContDto.getType());
                map.put(actmPlContDto.getDevId(),dto);
        }
        return new Response().set(1,true,"批量设置Actm均衡仪参数");
    }

    //将dto拷贝至param
    private void copyActmDTO(Object data, DevActmTestparam actmParam) {
        ActmResDto dto= (ActmResDto) data;