actm

whyclxw

2024-09-03 d3b87a5ef334af3497d33f90d954517184449ac3

actm

 src/main/java/com/whyc/controller/DevActmTestparamController.java

@@ -30,16 +30,10 @@
        return service.setActmParam(param,devId);
    }

    @ApiOperation(value = "启动actm均衡仪放电/充电")
    @GetMapping("startActmParam")
    public Object startActmParam(@RequestParam int devId,@RequestParam int type){
        return service.startActmParam(devId,type);
    }

    @ApiOperation(value = "停止actm均衡仪放电/充电")
    @GetMapping("stopActmParam")
    public Object stopActmParam(@RequestParam int devId){
        return service.stopActmParam(devId);
    @ApiOperation(value = "启动,暂停,继续,停止actm均衡仪")
    @GetMapping("controllerActmParam")
    public Object controllerActmParam(@RequestParam int devId,@RequestParam int index,@RequestParam int type){
        return service.controllerActmParam(devId,index,type);
    }

    @ApiOperation(value = "批量控制actm均衡仪")

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

@@ -46,7 +46,6 @@
            DevActmTestparam actmParam=new DevActmTestparam();
            copyActmDTO(dto.getData(),actmParam);
            actmParam.setDevId(devId);
            //actmParam.setReturnCode(Integer.parseInt(dto.getCode()));
            UpdateWrapper updateWrapper=new UpdateWrapper();
            updateWrapper.eq("dev_id",devId);
            mapper.update(actmParam,updateWrapper);
@@ -70,30 +69,26 @@
        return dto;
    }

    //启动Actm均衡仪放电/充电
    public Object startActmParam(int devId,int type) {
    //启动,暂停,继续,停止actm均衡仪
    public Object controllerActmParam(int devId,int index,int type) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("dev_id",devId);
        wrapper.last("limit 1");
        DevInf dinf=dinfMapper.selectOne(wrapper);
        String url="http://"+dinf.getDevIp()+":8080/webService/startTest";
        String url="http://"+dinf.getDevIp()+":8080/webService";
        //将请求头部和参数合成一个请求
        MultiValueMap<String, Object> paramMap = new LinkedMultiValueMap<>();
        paramMap.add("testType",type);
        switch (type){
            case 1:url=url+"/startTest";break;        //启动
            case 2:url=url+"/pauseTest";break;        //暂停
            case 3:url=url+"/continueTest";break;     //继续
            case 4:url=url+"/stopTest";break;         //停止
        }
        paramMap.add("batteryStorageIndex",index);
        ResultActmDto dto= (ResultActmDto) TestparamHttpUtil.postforform_data(restTemplate,url,paramMap);
        return dto;
    }
    //停止Actm均衡仪放电/充电
    public Object stopActmParam(int devId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("dev_id",devId);
        wrapper.last("limit 1");
        DevInf dinf=dinfMapper.selectOne(wrapper);
        String url="http://"+dinf.getDevIp()+":8080/webService/stopTest";
        String results = restTemplate.postForObject(url, null, String.class);
        ResultActmDto dto= ActionUtil.getGson().fromJson(results, ResultActmDto.class);
        return dto;
    }


    //批量控制Actm均衡仪
    public Response controllActmParamPl(List<Integer> devIds) {