package com.iailab.module.data.feign;
|
|
import com.alibaba.cloud.commons.lang.StringUtils;
|
import com.iailab.module.data.api.IFeignDataApi;
|
import com.iailab.framework.common.util.date.DateUtils;
|
import com.iailab.framework.common.util.object.BeanUtils;
|
import com.iailab.module.data.common.enums.DataTypeEnum;
|
import com.iailab.module.data.dto.*;
|
import com.iailab.module.data.http.entity.HttpApiEntity;
|
import com.iailab.module.data.influxdb.pojo.InfluxPointValuePOJO;
|
import com.iailab.module.data.point.collection.PointCollector;
|
import com.iailab.module.data.point.dto.DaPointDTO;
|
import com.iailab.module.data.point.dto.DaPointWriteValueDTO;
|
import com.iailab.module.data.point.service.DaPointService;
|
import com.iailab.module.data.http.service.HttpApiService;
|
import com.iailab.module.data.ind.collection.IndItemCollector;
|
import com.iailab.module.data.ind.dto.IndItemValueDTO;
|
import com.iailab.module.data.influxdb.service.InfluxDBService;
|
import javax.annotation.Resource;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
|
/**
|
* @author PanZhibao
|
* @Description
|
* @createTime 2023年06月28日 08:53:00
|
*/
|
@RestController
|
public class FeignDataImpl implements IFeignDataApi {
|
@Resource
|
private InfluxDBService influxDBService;
|
|
@Resource
|
DaPointService daPointService;
|
|
@Resource
|
private HttpApiService httpApiService;
|
|
@Resource
|
private IndItemCollector indItemCollector;
|
|
@Resource
|
private PointCollector pointCollector;
|
|
@Override
|
public List<ApiDataDTO> queryPointValues(FeignQueryPointDTO dto) {
|
DaPointDTO daPointDTO = daPointService.getByNo(dto.getPointCode());
|
InfluxPointValuePOJO pojo = new InfluxPointValuePOJO();
|
pojo.setPoint(dto.getPointCode());
|
pojo.setType(daPointDTO.getDataType());
|
Date startTime = dto.getStartTime();
|
Date endTime = dto.getEndTime();
|
List<Map<String, Object>> list = influxDBService.queryPointValues(pojo, startTime, endTime);
|
List<ApiDataDTO> dataEntityList = new ArrayList<>();
|
for (int i = 0; list.size() - i >= 1; i++) {
|
ApiDataDTO dataEntity = new ApiDataDTO();
|
dataEntity.setDataValue(Double.parseDouble(list.get(i).get("value").toString()));
|
dataEntity.setTimeStamp((Date)(list.get(i).get("time")));
|
dataEntityList.add(dataEntity);
|
}
|
return dataEntityList;
|
}
|
|
@Override
|
public List<ApiDataDTO> querySimTagValues(FeignQueryPointDTO dto) {
|
|
InfluxPointValuePOJO pojo = new InfluxPointValuePOJO();
|
pojo.setPoint(dto.getPointCode());
|
pojo.setType(DataTypeEnum.FLOAT.getCode());
|
Date startTime = dto.getStartTime();
|
Date endTime = dto.getEndTime();
|
List<Map<String, Object>> list = influxDBService.queryPointValues(pojo, startTime, endTime);
|
List<ApiDataDTO> dataEntityList = new ArrayList<>();
|
for (int i = 0; list.size() - i >= 1; i++) {
|
ApiDataDTO dataEntity = new ApiDataDTO();
|
dataEntity.setDataValue(Double.parseDouble(list.get(i).get("value").toString()));
|
dataEntity.setTimeStamp((Date)(list.get(i).get("time")));
|
dataEntityList.add(dataEntity);
|
}
|
return dataEntityList;
|
}
|
|
@Override
|
public Map<String, Object> getCurrentValue(List<String> pointNos) {
|
return pointCollector.getCurrentValue(pointNos);
|
}
|
|
@Override
|
public ApiDataPointDTO getPoint(String pointNo) {
|
DaPointDTO daPointDTO = daPointService.getByNo(pointNo);
|
return BeanUtils.toBean(daPointDTO, ApiDataPointDTO.class);
|
|
}
|
|
@Override
|
public FeignHttpApiDTO getHttpApi(String code) {
|
HttpApiEntity entity = httpApiService.getByCode(code);
|
return BeanUtils.toBean(entity, FeignHttpApiDTO.class);
|
|
}
|
|
@Override
|
public List<ApiDataDTO> queryIndItemValues(FeignQueryPointDTO dto) {
|
List<ApiDataDTO> result = new ArrayList<>();
|
List<String> itemNos = new ArrayList<>();
|
itemNos.add(dto.getPointCode());
|
Map<String, List<IndItemValueDTO>> data = indItemCollector.getValueList(itemNos);
|
List<IndItemValueDTO> list = data.get(dto.getPointCode());
|
if (CollectionUtils.isEmpty(list)) {
|
return result;
|
}
|
list.forEach(item -> {
|
BigDecimal dv = null;
|
ApiDataDTO entity = new ApiDataDTO();
|
entity.setDataTime(item.getDataTime());
|
entity.setDataValue(item.getDataValue() == null ? 0 : item.getDataValue().doubleValue());
|
result.add(entity);
|
});
|
return result;
|
}
|
|
@Override
|
public List<ApiIndValueDTO> getIndItemValues(FeignQueryPointDTO dto) {
|
List<ApiIndValueDTO> result = new ArrayList<>();
|
List<String> itemNos = new ArrayList<>();
|
itemNos.add(dto.getPointCode());
|
Map<String, List<IndItemValueDTO>> data = indItemCollector.getValueList(itemNos);
|
List<IndItemValueDTO> list = data.get(dto.getPointCode());
|
if (CollectionUtils.isEmpty(list)) {
|
return result;
|
}
|
list.forEach(item -> {
|
BigDecimal dv = null;
|
ApiIndValueDTO entity = new ApiIndValueDTO();
|
entity.setDataTime(item.getDataTime());
|
entity.setDataValue(item.getDataValue());
|
result.add(entity);
|
});
|
return result;
|
}
|
|
@Override
|
public List<ApiIndValueDTO> queryIndItemValuesRange(FeignQueryPointDTO dto) {
|
List<ApiIndValueDTO> result = new ArrayList<>();
|
List<String> itemNos = new ArrayList<>();
|
itemNos.add(dto.getPointCode());
|
Map<String, List<IndItemValueDTO>> data = new HashMap<>();
|
if (StringUtils.isBlank(dto.getStartDate()) && StringUtils.isBlank(dto.getEndDate())) {
|
data = indItemCollector.getValueList(itemNos);
|
} else {
|
if (dto.getStartDate() == null) {
|
dto.setStartDate(DateUtils.format(new Date()));
|
}
|
if (dto.getEndDate() == null) {
|
dto.setEndDate(DateUtils.format(new Date()));
|
}
|
data = indItemCollector.getValueListRange(itemNos, dto.getStartDate(), dto.getEndDate());
|
}
|
List<IndItemValueDTO> list = data.get(dto.getPointCode());
|
if (CollectionUtils.isEmpty(list)) {
|
return result;
|
}
|
list.forEach(item -> {
|
BigDecimal dv = null;
|
ApiIndValueDTO entity = new ApiIndValueDTO();
|
entity.setDataTime(item.getDataTime());
|
entity.setDataValue(item.getDataValue());
|
result.add(entity);
|
});
|
return result;
|
}
|
|
@Override
|
public FeignResultDTO setPointValue(FeignWritePointValueDTO writePointValue) {
|
FeignResultDTO result = new FeignResultDTO();
|
try {
|
DaPointWriteValueDTO wr = new DaPointWriteValueDTO();
|
wr.setPointNo(writePointValue.getPointCode());
|
wr.setPointValue(writePointValue.getPointValue());
|
pointCollector.setValue(wr);
|
result.setCode(0);
|
result.setMsg("");
|
} catch (Exception ex) {
|
result.setCode(-1);
|
result.setMsg(ex.getMessage());
|
}
|
return result;
|
}
|
}
|
