From 45a4bd098340badbd21f402ad105b89297b350ff Mon Sep 17 00:00:00 2001 From: huangzj <826100833@qq.com> Date: Tue, 20 Jun 2023 08:52:51 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=BC=95=E7=94=A8=E4=BC=A0?= =?UTF-8?q?=E9=80=92=E5=AF=BC=E8=87=B4=E6=9F=A5=E8=AF=A2=E5=A4=9A=E6=9D=A1?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=88=90=E4=B8=80=E6=9D=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/njcn/influx/core/InfluxExecutor.java | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/njcn/influx/core/InfluxExecutor.java b/src/main/java/com/njcn/influx/core/InfluxExecutor.java index 04c8a8c..fd4c556 100644 --- a/src/main/java/com/njcn/influx/core/InfluxExecutor.java +++ b/src/main/java/com/njcn/influx/core/InfluxExecutor.java @@ -98,9 +98,8 @@ public class InfluxExecutor { List columns = series.getColumns(); List> values = series.getValues(); for (List columnValue : values) { - if(ObjectUtil.isNull(obj)){ - obj = domainClass.newInstance(); - } + Object object = domainClass.newInstance(); + for (int i = 0; i < columnValue.size(); i++) { String columnName = columns.get(i); //属性名有下划线的替换掉 @@ -110,24 +109,24 @@ public class InfluxExecutor { declaredField.setAccessible(true); //时间格式 if (declaredField.getType() == Instant.class) { - declaredField.set(obj, InstantUtil.stringToInstant(columnValue.get(i).toString().replace("+08:00", "Z"))); + declaredField.set(object, InstantUtil.stringToInstant(columnValue.get(i).toString().replace("+08:00", "Z"))); //字符串 } else if (declaredField.getType() == String.class) { - declaredField.set(obj, columnValue.get(i).toString()); + declaredField.set(object, columnValue.get(i).toString()); //浮点双精度 } else if (declaredField.getType() == Double.class) { - declaredField.set(obj, Double.parseDouble(columnValue.get(i).toString())); + declaredField.set(object, Double.parseDouble(columnValue.get(i).toString())); //浮点 } else if (declaredField.getType() == Float.class) { - declaredField.set(obj, Float.parseFloat(columnValue.get(i).toString())); + declaredField.set(object, Float.parseFloat(columnValue.get(i).toString())); //整型 } else if (declaredField.getType() == Integer.class) { - declaredField.set(obj, Integer.parseInt(columnValue.get(i).toString())); + declaredField.set(object, Integer.parseInt(columnValue.get(i).toString())); } } } } - results.add((E) obj); + results.add((E) object); } } }