From e7ce397261805a4a28dea0771ab3e5ca3d6834d0 Mon Sep 17 00:00:00 2001 From: lishuai Date: Thu, 16 Jan 2025 19:51:15 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=87=8D=E6=95=B0=E6=8D=AE=202025?= =?UTF-8?q?=E5=B9=B41=E6=9C=8816=E6=97=A519:30:11?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/thing/common/tskv/service/TsKvNativeSQL.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/common/tskv/src/main/java/com/thing/common/tskv/service/TsKvNativeSQL.java b/common/tskv/src/main/java/com/thing/common/tskv/service/TsKvNativeSQL.java index 470520b..250f41a 100644 --- a/common/tskv/src/main/java/com/thing/common/tskv/service/TsKvNativeSQL.java +++ b/common/tskv/src/main/java/com/thing/common/tskv/service/TsKvNativeSQL.java @@ -121,14 +121,10 @@ public class TsKvNativeSQL { } public static String sqlSaveProtoTsKv(List protoList, DatabaseType dataType) { - - // 使用Stream API和Collectors.toMap来去重 List distinctStudentFile = protoList.stream() .collect(Collectors.collectingAndThen( Collectors.toCollection(() -> - new TreeSet<>(Comparator.comparing(o -> o.getTskvProto().getThingCode() + ";" + o.getTskvProto().getKey()+ ";" + o.getTskvProto().getVal()+ ";" + o.getTskvProto().getTs()))), ArrayList::new)); - - + new TreeSet<>(Comparator.comparing(o -> o.getTskvProto().getThingCode() + ";" + o.getTskvProto().getKey()+ ";" + Double.valueOf(o.getTskvProto().getVal())+ ";" + o.getTskvProto().getTs()))), ArrayList::new)); StringBuilder sql = new StringBuilder(" INSERT INTO ") .append(TS_KV).append(" (") .append(THING_CODE)