Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改查询

Browse Source
This commit is contained in:
hzj
2025-04-01 09:36:38 +08:00
parent 85cfbe0cb5
commit 21df04eb6d
2 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbPqsCommunicateImpl.java
View File

@@ -12,6 +12,7 @@ import com.njcn.device.pq.api.DeviceFeignClient;
import com.njcn.device.pq.pojo.dto.DevComFlagDTO; import com.njcn.device.pq.pojo.dto.DevComFlagDTO;
import com.njcn.influx.query.InfluxQueryWrapper; import com.njcn.influx.query.InfluxQueryWrapper;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -35,6 +36,7 @@ import java.util.Objects;
*/ */
@Service("InfluxdbPqsCommunicateImpl") @Service("InfluxdbPqsCommunicateImpl")
@RequiredArgsConstructor @RequiredArgsConstructor
@Slf4j
public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate { public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate {
@Resource @Resource
@@ -108,6 +110,7 @@ public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate {
@Override @Override
public void insertion(PqsCommunicateDto pqsCommunicateDto) { public void insertion(PqsCommunicateDto pqsCommunicateDto) {
log.info("进出Influxdb实现类");
//获取最新一条数据 //获取最新一条数据
PqsCommunicate dto = new PqsCommunicate(); PqsCommunicate dto = new PqsCommunicate();
InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(PqsCommunicate.class); InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(PqsCommunicate.class);

4
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationPqsCommunicateImpl.java
View File

@@ -4,6 +4,7 @@ import com.njcn.dataProcess.param.LineCountEvaluateParam;
import com.njcn.dataProcess.pojo.dto.PqsCommunicateDto; import com.njcn.dataProcess.pojo.dto.PqsCommunicateDto;
import com.njcn.dataProcess.service.IPqsCommunicate; import com.njcn.dataProcess.service.IPqsCommunicate;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.Collections; import java.util.Collections;
@@ -16,6 +17,7 @@ import java.util.List;
*/ */
@Service("RelationPqsCommunicateImpl") @Service("RelationPqsCommunicateImpl")
@RequiredArgsConstructor @RequiredArgsConstructor
@Slf4j
public class RelationPqsCommunicateImpl implements IPqsCommunicate { public class RelationPqsCommunicateImpl implements IPqsCommunicate {
@@ -36,6 +38,6 @@ public class RelationPqsCommunicateImpl implements IPqsCommunicate {
@Override @Override
public void insertion(PqsCommunicateDto pqsCommunicateDto) { public void insertion(PqsCommunicateDto pqsCommunicateDto) {
log.info("进出Relation实现类");
} }
} }