diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDataSetMapper.xml b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDataSetMapper.xml index 51da42c..7582f82 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDataSetMapper.xml +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/mapper/mapping/CsDataSetMapper.xml @@ -12,7 +12,9 @@ from cs_data_set where - pid = #{modelId} and cl_dev = #{clDev} + pid = #{modelId} + and cl_dev = #{clDev} + and data_type in ('Stat',NULL) order by type,cl_dev diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDataSetServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDataSetServiceImpl.java index 3996262..dacea3a 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDataSetServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDataSetServiceImpl.java @@ -8,7 +8,6 @@ import com.njcn.csdevice.service.ICsDataSetService; import org.springframework.stereotype.Service; import java.util.Arrays; -import java.util.Collections; import java.util.List; /** @@ -24,12 +23,22 @@ public class CsDataSetServiceImpl extends ServiceImpl findDataSetByModelId(String modelId, Integer clDev) { - return this.lambdaQuery().eq(CsDataSet::getPid,modelId).eq(CsDataSet::getClDev,clDev).list(); + return this.lambdaQuery() + .eq(CsDataSet::getPid,modelId) + .eq(CsDataSet::getClDev,clDev) + .and(i->i.eq(CsDataSet::getDataType,"Stat").or().isNull(CsDataSet::getDataType)) + .list(); } @Override public List findDataSetByModelId(String modelId) { - return this.lambdaQuery().eq(CsDataSet::getPid,modelId).in(CsDataSet::getType, Arrays.asList(0,2)).orderByAsc(CsDataSet::getType,CsDataSet::getClDev).list(); + return this.lambdaQuery() + .eq(CsDataSet::getPid,modelId) + .in(CsDataSet::getType, Arrays.asList(0,2)) + .eq(CsDataSet::getStoreFlag,1) + .and(i->i.eq(CsDataSet::getDataType,"Stat").or().isNull(CsDataSet::getDataType)) + .orderByAsc(CsDataSet::getType,CsDataSet::getClDev) + .list(); } @Override diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/OfflineDataUploadServiceImpl.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/OfflineDataUploadServiceImpl.java index 149a3b8..8f50c79 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/OfflineDataUploadServiceImpl.java +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/OfflineDataUploadServiceImpl.java @@ -182,7 +182,7 @@ public class OfflineDataUploadServiceImpl implements OfflineDataUploadService { if (Objects.equals("dir",fileType)) { DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); askProjectInfo(null,nDid, Integer.parseInt(TypeEnum.TYPE_8.getCode()),path,"DevFileCmd"); - Thread.sleep(2000); + Thread.sleep(5000); String key = AppRedisKey.PROJECT_INFO + nDid; Object object = redisUtil.getObjectByKey(key); if (!Objects.isNull(object)) { @@ -262,6 +262,7 @@ public class OfflineDataUploadServiceImpl implements OfflineDataUploadService { } } if (CollectionUtil.isNotEmpty(map)) { + System.out.println("map==:" + map); map.forEach((k,v)->{ String proName = k.replace("/bd0/cmn/",OssPath.DEV_MAKE_UP_PATH + param.getNDid() + "/"); String key = AppRedisKey.PROJECT_INFO + param.getNDid();