From caa7198e8a0d384df1c24c3e2d616e086d4eadfa Mon Sep 17 00:00:00 2001 From: YunaiV Date: Thu, 19 Dec 2024 21:02:36 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90=E4=BB=A3=E7=A0=81=E8=AF=84=E5=AE=A1?= =?UTF-8?q?=E3=80=91IoT=EF=BC=9A=E8=AF=84=E5=AE=A1=20ThingModel=20?= =?UTF-8?q?=E7=9A=84=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iot/dal/dataobject/tdengine/FieldParser.java | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/FieldParser.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/FieldParser.java index 637b2228be..9157920e0c 100644 --- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/FieldParser.java +++ b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/dataobject/tdengine/FieldParser.java @@ -34,11 +34,9 @@ public class FieldParser { * @return TdField对象 */ public static TdFieldDO parse(ThingModelProperty property) { + // 将物模型字段类型映射为 td 字段类型 String fieldName = property.getIdentifier().toLowerCase(); - - // 将物模型字段类型映射为td字段类型 String fType = TYPE_MAPPING.get(property.getDataType().toUpperCase()); - // 如果字段类型为NCHAR，默认长度为64 int dataLength = 0; if ("NCHAR".equals(fType)) { @@ -54,6 +52,7 @@ public class FieldParser { * @return 字段列表 */ public static List parse(ThingModelRespVO thingModel) { + // TODO @puhui999：是不是使用 convertList return thingModel.getModel().getProperties().stream() .map(FieldParser::parse) .collect(Collectors.toList()); @@ -66,14 +65,12 @@ public class FieldParser { * @return 转换后的 TDengine 字段对象列表 */ public static List parse(List> rows) { + // TODO @puhui999：是不是使用 convertList return rows.stream().map(row -> { String type = row.get(1).toString().toUpperCase(); + // TODO @puhui999："NCHAR" 最好枚举下 int dataLength = "NCHAR".equals(type) ? Integer.parseInt(row.get(2).toString()) : -1; - return new TdFieldDO( - row.get(0).toString(), - type, - dataLength - ); + return new TdFieldDO(row.get(0).toString(), type, dataLength); }).collect(Collectors.toList()); }