package com.whyc.service;
|
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.whyc.dto.*;
|
import com.whyc.factory.ThreadPoolExecutorFactory;
|
import com.whyc.mapper.DevActmTestparamMapper;
|
import com.whyc.mapper.DevInfMapper;
|
import com.whyc.pojo.db_lithium_ram_db.DevActmTestparam;
|
import com.whyc.pojo.db_lithium_ram_db.DevInf;
|
import com.whyc.util.ActionUtil;
|
import com.whyc.util.TestparamHttpUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.LinkedMultiValueMap;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.annotation.Resource;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.CountDownLatch;
|
import java.util.concurrent.ThreadPoolExecutor;
|
import java.util.concurrent.TimeUnit;
|
|
|
@Service
|
public class DevActmTestparamService {
|
@Autowired(required = false)
|
private DevActmTestparamMapper mapper;
|
|
@Autowired(required = false)
|
private DevInfMapper dinfMapper;
|
|
@Resource
|
private RestTemplate restTemplate;
|
|
//读取Actm一体机参数
|
public Object getActmParam(int devId,int index) {
|
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/getTestParameter";
|
//将请求头部和参数合成一个请求
|
MultiValueMap<String, Object> paramMap = new LinkedMultiValueMap<>();
|
paramMap.add("batteryStorageIndex",index);
|
ResultActmDto dto= (ResultActmDto) TestparamHttpUtil.postforform_dataActm(restTemplate,url,paramMap);
|
if(dto.getCode().equals("200")){
|
DevActmTestparam actmParam=new DevActmTestparam();
|
copyActmDTO(dto.getData(),actmParam);
|
actmParam.setDevId(devId);
|
UpdateWrapper updateWrapper=new UpdateWrapper();
|
updateWrapper.eq("dev_id",devId);
|
mapper.update(actmParam,updateWrapper);
|
}
|
return dto;
|
}
|
|
|
//设置Actm均衡仪参数
|
public Object setActmParam(ActmResDto param) {
|
QueryWrapper wrapper=new QueryWrapper();
|
wrapper.eq("dev_id",param.getDevId());
|
wrapper.last("limit 1");
|
DevInf dinf=dinfMapper.selectOne(wrapper);
|
String url="http://"+dinf.getDevIp()+":8080/webService/setTestParameter";
|
//将请求头部和参数合成一个请求
|
MultiValueMap<String, Object> paramMap = new LinkedMultiValueMap<>();
|
String paramJson= JSONObject.toJSONString(param);
|
paramMap.add("testParameter",paramJson);
|
ResultActmDto dto= (ResultActmDto) TestparamHttpUtil.postforform_dataActm(restTemplate,url,paramMap);
|
return dto;
|
}
|
|
//批量设置Actm均衡仪参数
|
public Object setActmParamPl(ActmResDto 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()) {
|
poolExecutor.execute(() -> {
|
param.setDevId(devId);
|
ResultA200Dto dto= (ResultA200Dto) setActmParam(param);
|
map.put(param.getDevId(),dto);
|
latch.countDown();
|
});
|
}
|
latch.await(10, TimeUnit.MINUTES);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
return new Response().setII(1,true,map,"批量设置Actm均衡仪参数");
|
}
|
|
|
//启动,暂停,继续,停止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";
|
//将请求头部和参数合成一个请求
|
MultiValueMap<String, Object> paramMap = new LinkedMultiValueMap<>();
|
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_dataActm(restTemplate,url,paramMap);
|
return dto;
|
}
|
|
|
//批量控制Actm均衡仪
|
public Response controllActmParamPl(List<ActmPlContDto> actmPlContDtos) {
|
Map<Integer,Object> map=new HashMap<>();
|
try {
|
ThreadPoolExecutor poolExecutor = ThreadPoolExecutorFactory.getPoolExecutor();
|
CountDownLatch latch = new CountDownLatch(actmPlContDtos.size());
|
for (ActmPlContDto actmPlContDto:actmPlContDtos) {
|
poolExecutor.execute(() -> {
|
ResultActmDto dto= (ResultActmDto) controllerActmParam(actmPlContDto.getDevId(),actmPlContDto.getIndex(),actmPlContDto.getType());
|
map.put(actmPlContDto.getDevId(),dto);
|
latch.countDown();
|
});
|
}
|
latch.await(10, TimeUnit.MINUTES);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
return new Response().set(1,true,"批量设置Actm均衡仪参数");
|
}
|
|
//将dto拷贝至param
|
private void copyActmDTO(Object data, DevActmTestparam actmParam) {
|
ActmResDto dto= (ActmResDto) data;
|
actmParam.setBatteryStorageIndex(dto.getBatteryStorageIndex());
|
actmParam.setModuleCode(dto.getModuleCode());
|
actmParam.setWorkMode(dto.getWorkMode());
|
actmParam.setBatteryType(dto.getBatteryType());
|
actmParam.setBatteryNumber(dto.getBatteryNumber());
|
actmParam.setNtcCount(dto.getNtcCount());
|
actmParam.setTestBatteryArray(dto.getTestBatteryArray());
|
actmParam.setVoltage(dto.getVoltage());
|
actmParam.setCurrent(dto.getCurrent());
|
actmParam.setMaxBatteryNumber(dto.getMaxBatteryNumber());
|
actmParam.setMaxNtcCount(dto.getMaxNtcCount());
|
}
|
|
}
|
