提交代码，工程，设备权限，设备数据

cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/DeviceDataTrendService.java

@@ -0,0 +1,17 @@
+package com.njcn.csharmonic.service;
+
+import com.njcn.csharmonic.param.DevicDataTrendQueryParam;
+import com.njcn.csharmonic.pojo.vo.ThdDataVO;
+
+import java.util.List;
+
+/**
+ * Description:
+ * Date: 2023/6/26  9:14【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public interface DeviceDataTrendService {
+    List<List<ThdDataVO>> queryDataTrend(DevicDataTrendQueryParam devicDataTrendQueryParam);
+}

cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DeviceDataTrendServiceImpl.java

@@ -0,0 +1,80 @@
+package com.njcn.csharmonic.service.impl;
+
+import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.csdevice.api.DataArrayFeignClient;
+import com.njcn.csdevice.enums.AlgorithmResponseEnum;
+import com.njcn.csdevice.pojo.po.CsDataArray;
+import com.njcn.csdevice.pojo.po.CsLinePO;
+import com.njcn.csharmonic.param.DevicDataTrendQueryParam;
+import com.njcn.csharmonic.pojo.vo.ThdDataVO;
+import com.njcn.csharmonic.service.DeviceDataTrendService;
+import com.njcn.influx.pojo.dto.StatisticalDataDTO;
+import com.njcn.influx.service.CommonService;
+import com.njcn.system.api.EpdFeignClient;
+import com.njcn.system.pojo.po.EleEpdPqd;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.time.ZoneId;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+import java.util.Optional;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+/**
+ * Description:
+ * Date: 2023/6/26  9:14【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Service
+@RequiredArgsConstructor
+public class DeviceDataTrendServiceImpl implements DeviceDataTrendService {
+    private final EpdFeignClient epdFeignClient;
+    private final CommonService commonService;
+    private final DataArrayFeignClient dataArrayFeignClient;
+    @Override
+    public List<List<ThdDataVO>> queryDataTrend(DevicDataTrendQueryParam devicDataTrendQueryParam) {
+        List<List<ThdDataVO>> result = new ArrayList<>();
+
+        if(CollectionUtils.isEmpty(devicDataTrendQueryParam.getStatisticalParams())){
+            return result;
+        }
+
+
+        devicDataTrendQueryParam.getStatisticalParams().forEach(temp->{
+
+            List<StatisticalDataDTO> deviceRtData = commonService.getDeviceRtDataByTime(Stream.of(devicDataTrendQueryParam.getLineId()).collect(Collectors.toList()),
+                    temp.getClassId(),
+                    temp.getName(), temp.getPhase(),
+                    temp.getStatMethod(),
+                    devicDataTrendQueryParam.getStartTime(),
+                    devicDataTrendQueryParam.getEndTime());
+            List<ThdDataVO> collect1 = deviceRtData.stream().map(statisticalDataDTO -> {
+                ThdDataVO vo = new ThdDataVO();
+                vo.setLineId(statisticalDataDTO.getLineId());
+                vo.setPhase(statisticalDataDTO.getPhaseType());
+
+                vo.setTime(statisticalDataDTO.getTime().atZone(ZoneId.systemDefault()).toLocalDateTime());
+                vo.setStatMethod(statisticalDataDTO.getValueType());
+                vo.setStatisticalData(BigDecimal.valueOf(statisticalDataDTO.getValue()).setScale(4, RoundingMode.UP).doubleValue());
+                vo.setStatisticalIndex(temp.getDataId());
+                vo.setStatisticalName(temp.getName());
+                vo.setUnit(temp.getUnit());
+                vo.setAnotherName(temp.getAnotherName());
+                return vo;
+            }).collect(Collectors.toList());
+            result.add(collect1);
+        });
+
+
+
+        return result;
+    }
+}