Middleware/influxdb-springboot-starter
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

influxORM代码调整

Browse Source
This commit is contained in:
hongawen
2023-04-28 16:27:04 +08:00
parent b29104cfe2
commit 2fb7d70bbc
2 changed files with 19 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/com/njcn/influx/core/InfluxExecutor.java
View File

@@ -1,6 +1,7 @@
package com.njcn.influx.core; package com.njcn.influx.core;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.text.StrPool;
import com.njcn.influx.constant.InfluxDbSqlConstant; import com.njcn.influx.constant.InfluxDbSqlConstant;
import com.njcn.influx.utils.InstantUtil; import com.njcn.influx.utils.InstantUtil;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@@ -57,12 +58,23 @@ public class InfluxExecutor {
for (List<Object> columnValue : values) { for (List<Object> columnValue : values) {
Object obj = domainClass.newInstance(); Object obj = domainClass.newInstance();
for (int i = 0; i < columnValue.size(); i++) { for (int i = 0; i < columnValue.size(); i++) {
Method value = domainClass.getMethod("setValue", BigDecimal.class); String columnName = columns.get(i);
Method time = domainClass.getMethod("setTime", Instant.class); columnName = columnName.replaceAll(StrPool.UNDERLINE, "");
if (columns.get(i).equals("value")) { Field[] declaredFields = domainClass.getDeclaredFields();
value.invoke(obj, BigDecimal.valueOf(Double.parseDouble(columnValue.get(i).toString()))); for (Field declaredField : declaredFields) {
} else if (columns.get(i).equals("time")) { if(columnName.equalsIgnoreCase(declaredField.getName())){
time.invoke(obj, InstantUtil.stringToInstant(columnValue.get(i).toString().replace("+08:00", "Z"))); //获取属性定义的类型
declaredField.setAccessible(true);
if(declaredField.getType() == Instant.class){
declaredField.set(obj,InstantUtil.stringToInstant(columnValue.get(i).toString().replace("+08:00", "Z")));
}else if(declaredField.getType() == String.class){
declaredField.set(obj,columnValue.get(i).toString());
}else if(declaredField.getType() == Double.class){
declaredField.set(obj,Double.parseDouble(columnValue.get(i).toString()));
}else if(declaredField.getType() == Integer.class){
declaredField.set(obj,Integer.parseInt(columnValue.get(i).toString()));
}
}
} }
} }
results.add((E) obj); results.add((E) obj);

2
src/main/java/com/njcn/influx/pojo/StatisticsResult.java
View File

@@ -22,7 +22,7 @@ public class StatisticsResult implements Serializable {
/*** /***
* 统计值 * 统计值
*/ */
private BigDecimal value; private Double value;