From e44c211aab8da89e89657426460d44285de6959c Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期五, 09 五月 2025 00:36:16 +0800
Subject: [PATCH] 整理代码
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/ProcessParameterHelperService.java | 37 +------------------------------------
1 files changed, 1 insertions(+), 36 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/ProcessParameterHelperService.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/ProcessParameterHelperService.java
index 618c106..d4ea3f9 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/ProcessParameterHelperService.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/ProcessParameterHelperService.java
@@ -24,15 +24,7 @@
@DS("iotdb")
public ProcessParameterVO queryLastParameterLessThenTime(long workstationId,String item,Long time) {
- /**
- *tdengine瀹炵幇锛歰ldFirstStatue
- * select last(ts) as realTime,
- last(v) as value_collect
- from iot_data.super_collect_data
- where n = #{item}
- and ts < #{startTime}
- and workstation_id = #{workstationId}
- */
+
ProcessParameterVO vo = null;
String sql ="select max_time(n) as ts,last_value(n) as n,last_value(v) as v,last_value(workstation_id) as workstationId from root.f2.process_param_"+workstationId+"_"+item+" where time<"+time+" limit 1 align by device";
List<ProcessParameterVO> list = jdbcTemplate.query(sql, new RowMapper<ProcessParameterVO>() {
@@ -64,34 +56,7 @@
*/
@DS("iotdb")
public ProcessParameterVO getLastParameterGreaterThenTime(long workstationId,String item,Long time) {
- /*
- oldLastStatue
- select last(ts) as realTime,
- last(v) as value_collect
- from iot_data.super_collect_data
- where n = #{item}
- and ts > #{endTime}
- and workstation_id = #{workstationId}
- * */
- /*
- LastProcessParam lp = this.parameterMapper.lastParameterGreaterThanTime(workstationId,item,time);
- if(lp == null) {
- return null;
- }
- ProcessParameterVO vo = new ProcessParameterVO();
- //瑙ｆ瀽json涓哄璞″垪琛�
- JSONObject paramsObj = JSONObject.parseObject(lp.getParamJson());
- if(paramsObj.containsKey(item)) {
- JSONObject itemObj = paramsObj.getJSONObject(item);
-
- Long lastTime = itemObj.getLong("time");
- vo.setTime(new Timestamp(lastTime));
- vo.setRealTime(lastTime);
- vo.setValueCollect(itemObj.getString("value"));
- }
-
- return vo;*/
ProcessParameterVO vo = null;
String sql ="select max_time(n) as ts,last_value(n) as n,last_value(v) as v,last_value(workstation_id) as workstationId from root.f2.process_param_"+workstationId+"_"+item+" where time>"+time+" limit 1 align by device";
--
Gitblit v1.9.3