diff --git a/src/main/java/com/xydl/cac/service/DataService.java b/src/main/java/com/xydl/cac/service/DataService.java index 5820210..51d8fba 100644 --- a/src/main/java/com/xydl/cac/service/DataService.java +++ b/src/main/java/com/xydl/cac/service/DataService.java @@ -14,6 +14,8 @@ public interface DataService { List getDataTableColumns(String tableName); + String getFieldType(String tableName, String field); + OnePage> getData(String tableName, Integer devId, List points, ConditionModel model) throws Exception; void clearAllBind(); diff --git a/src/main/java/com/xydl/cac/service/impl/DataServiceImpl.java b/src/main/java/com/xydl/cac/service/impl/DataServiceImpl.java index 223979f..dd241ad 100644 --- a/src/main/java/com/xydl/cac/service/impl/DataServiceImpl.java +++ b/src/main/java/com/xydl/cac/service/impl/DataServiceImpl.java @@ -235,8 +235,7 @@ public class DataServiceImpl implements DataService { String sqlSelect = "SELECT DATE_FORMAT(" + timeField + ", '%Y-%m-%d %H:%i:%s') as acquisitionTime"; for (ModevTypePoint point : points) { if (StringUtils.isNotBlank(point.getField())) { - String type = this.getFieldType(tableName, point.getField()); - if (Constants.DateTime.equalsIgnoreCase(type)) { + if (Constants.DateTime.equalsIgnoreCase(point.getType())) { sqlSelect = sqlSelect + ", " + "DATE_FORMAT(" + point.getField() + ", '%Y-%m-%d %H:%i:%s') as " + point.getField(); } else { sqlSelect = sqlSelect + ", " + point.getField(); diff --git a/src/main/java/com/xydl/cac/task/I2syncTask.java b/src/main/java/com/xydl/cac/task/I2syncTask.java index 7e20204..b7e890d 100644 --- a/src/main/java/com/xydl/cac/task/I2syncTask.java +++ b/src/main/java/com/xydl/cac/task/I2syncTask.java @@ -89,6 +89,8 @@ public class I2syncTask { for (I2syncField field : fieldList) { ModevTypePoint point = new ModevTypePoint(); point.setField(field.getFieldName()); + String type = dataService.getFieldType(config.getTableName(), point.getField()); + point.setType(type); points.add(point); } List list = sensorRepository.findByTypeId(config.getModevtypeId());