批量新增设备bug修改

cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDataSetMapper.xml

@@ -14,7 +14,7 @@
         where
             pid = #{modelId}
           and cl_dev = #{clDev}
-          and data_type in ('Stat',NULL)
+          and (data_type = 'Stat' or data_type IS NULL)
         order by type,cl_dev
     </select>
 

cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java

@@ -554,6 +554,7 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
                     csEquipmentDeliveryPO.setRunStatus(1);
                     csEquipmentDeliveryPO.setStatus(1);
                     csEquipmentDeliveryPO.setProcess(2);
+                    csEquipmentDeliveryPO.setSort(100);
 
                     CsEquipmentProcessPO csEquipmentProcess = new CsEquipmentProcessPO();
                     csEquipmentProcess.setDevId(csEquipmentDeliveryPO.getNdid());

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

@@ -36,6 +36,7 @@ import lombok.RequiredArgsConstructor;
 import org.influxdb.dto.QueryResult;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
 
 import java.text.DecimalFormat;
 import java.time.ZoneId;
@@ -273,7 +274,11 @@ public class StableDataServiceImpl implements StableDataService {
             List<CsLinePO> finalCsLinePOList = csLinePOList;
             data.forEach(epdPqd->{
             String frequency = Optional.ofNullable(commonStatisticalQueryParam.getFrequency()).orElse("");
-
+            if(StringUtils.isEmpty(commonStatisticalQueryParam.getFrequency())){
+                frequency ="";
+            }else {
+                frequency = "_"+commonStatisticalQueryParam.getFrequency();
+            }
             String finalFrequency1 = frequency;
             List<CommonQueryParam> commonQueryParams = csLinePOList1.stream().map(temp -> {
                 CommonQueryParam commonQueryParam = new CommonQueryParam();