|
@@ -1,6 +1,5 @@
|
|
package com.example.opc_da.service.impl;
|
|
package com.example.opc_da.service.impl;
|
|
|
|
|
|
-import com.alibaba.fastjson.JSON;
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.example.opc_common.entity.*;
|
|
import com.example.opc_common.entity.*;
|
|
import com.example.opc_common.enums.ResultEnum;
|
|
import com.example.opc_common.enums.ResultEnum;
|
|
@@ -24,8 +23,6 @@ import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.web.client.RestTemplate;
|
|
import org.springframework.web.client.RestTemplate;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
import javax.annotation.Resource;
|
|
-import java.math.BigDecimal;
|
|
|
|
-import java.math.RoundingMode;
|
|
|
|
import java.util.*;
|
|
import java.util.*;
|
|
|
|
|
|
@Service
|
|
@Service
|
|
@@ -99,17 +96,17 @@ public class ReportTableServiceImpl implements ReportTableService {
|
|
return Result.no(ResultEnum.SERVER_ERROR.getRespCode(), "添加报表模板失败");
|
|
return Result.no(ResultEnum.SERVER_ERROR.getRespCode(), "添加报表模板失败");
|
|
}
|
|
}
|
|
Integer id = tableTemplate.getId();
|
|
Integer id = tableTemplate.getId();
|
|
- List<TableTemplateItem> tableTemplateItemList = tableTemplate.getTableTemplateItemList();
|
|
|
|
|
|
+ List<TableTemplateTableItem> tableTemplateItemList = tableTemplate.getTableTemplateItemList();
|
|
if (Blank.isNotEmpty(tableTemplateItemList)) {
|
|
if (Blank.isNotEmpty(tableTemplateItemList)) {
|
|
if (templateType.equals(ConstantStr.MANUAL_REPORT)) {
|
|
if (templateType.equals(ConstantStr.MANUAL_REPORT)) {
|
|
- for (TableTemplateItem t : tableTemplateItemList) {
|
|
|
|
|
|
+ for (TableTemplateTableItem t : tableTemplateItemList) {
|
|
t.setTableTemplateId(id);
|
|
t.setTableTemplateId(id);
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis())) {
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis())) {
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标都不能为空");
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标都不能为空");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else if (templateType.equals(ConstantStr.AUTOMATIC_REPORT)) {
|
|
} else if (templateType.equals(ConstantStr.AUTOMATIC_REPORT)) {
|
|
- for (TableTemplateItem t : tableTemplateItemList) {
|
|
|
|
|
|
+ for (TableTemplateTableItem t : tableTemplateItemList) {
|
|
t.setTableTemplateId(id);
|
|
t.setTableTemplateId(id);
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis(), t.getValueTakingMode(), t.getBucketType(), t.getBucketValue())) {
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis(), t.getValueTakingMode(), t.getBucketType(), t.getBucketValue())) {
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标、取值模式、时段类型、值都不能为空");
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标、取值模式、时段类型、值都不能为空");
|
|
@@ -120,7 +117,7 @@ public class ReportTableServiceImpl implements ReportTableService {
|
|
if (Blank.isEmpty(eventNum)) {
|
|
if (Blank.isEmpty(eventNum)) {
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "事件驱动显示数量设置不能为空");
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "事件驱动显示数量设置不能为空");
|
|
}
|
|
}
|
|
- for (TableTemplateItem t : tableTemplateItemList) {
|
|
|
|
|
|
+ for (TableTemplateTableItem t : tableTemplateItemList) {
|
|
t.setTableTemplateId(id);
|
|
t.setTableTemplateId(id);
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis())) {
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis())) {
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标都不能为空");
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标都不能为空");
|
|
@@ -158,11 +155,11 @@ public class ReportTableServiceImpl implements ReportTableService {
|
|
if (reportTableDao.updateTableTemplate(tableTemplate) <= 0) {
|
|
if (reportTableDao.updateTableTemplate(tableTemplate) <= 0) {
|
|
return Result.no(ResultEnum.SERVER_ERROR.getRespCode(), "修改报表模板失败");
|
|
return Result.no(ResultEnum.SERVER_ERROR.getRespCode(), "修改报表模板失败");
|
|
}
|
|
}
|
|
- List<TableTemplateItem> tableTemplateItemList = tableTemplate.getTableTemplateItemList();
|
|
|
|
|
|
+ List<TableTemplateTableItem> tableTemplateItemList = tableTemplate.getTableTemplateItemList();
|
|
reportTableDao.delTtiByTtId(id);
|
|
reportTableDao.delTtiByTtId(id);
|
|
if (Blank.isNotEmpty(tableTemplateItemList)) {
|
|
if (Blank.isNotEmpty(tableTemplateItemList)) {
|
|
if (templateType.equals(ConstantStr.MANUAL_REPORT)) {
|
|
if (templateType.equals(ConstantStr.MANUAL_REPORT)) {
|
|
- for (TableTemplateItem t : tableTemplateItemList) {
|
|
|
|
|
|
+ for (TableTemplateTableItem t : tableTemplateItemList) {
|
|
t.setTableTemplateId(id);
|
|
t.setTableTemplateId(id);
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis(), t.getValueTakingMode(), t.getBucketType(),
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis(), t.getValueTakingMode(), t.getBucketType(),
|
|
t.getBucketValue(), t.getStartTime(), t.getEndTime())) {
|
|
t.getBucketValue(), t.getStartTime(), t.getEndTime())) {
|
|
@@ -170,7 +167,7 @@ public class ReportTableServiceImpl implements ReportTableService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else if (templateType.equals(ConstantStr.AUTOMATIC_REPORT)) {
|
|
} else if (templateType.equals(ConstantStr.AUTOMATIC_REPORT)) {
|
|
- for (TableTemplateItem t : tableTemplateItemList) {
|
|
|
|
|
|
+ for (TableTemplateTableItem t : tableTemplateItemList) {
|
|
t.setTableTemplateId(id);
|
|
t.setTableTemplateId(id);
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis(), t.getValueTakingMode(), t.getBucketType(), t.getBucketValue())) {
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis(), t.getValueTakingMode(), t.getBucketType(), t.getBucketValue())) {
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标、取值模式、时段类型、值都不能为空");
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标、取值模式、时段类型、值都不能为空");
|
|
@@ -181,7 +178,7 @@ public class ReportTableServiceImpl implements ReportTableService {
|
|
if (Blank.isEmpty(eventNum)) {
|
|
if (Blank.isEmpty(eventNum)) {
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "显示数量不能为空");
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "显示数量不能为空");
|
|
}
|
|
}
|
|
- for (TableTemplateItem t : tableTemplateItemList) {
|
|
|
|
|
|
+ for (TableTemplateTableItem t : tableTemplateItemList) {
|
|
t.setTableTemplateId(id);
|
|
t.setTableTemplateId(id);
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis())) {
|
|
if (Blank.isEmpty(t.getItemId(), t.getPlaceHolder(), t.getXaxis(), t.getYaxis())) {
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标都不能为空");
|
|
throw new CustomException(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "数据项、占位符、横、纵坐标都不能为空");
|
|
@@ -234,7 +231,7 @@ public class ReportTableServiceImpl implements ReportTableService {
|
|
@Override
|
|
@Override
|
|
public Result getTableTemplateById(Integer id) {
|
|
public Result getTableTemplateById(Integer id) {
|
|
TableTemplate tableTemplate = reportTableDao.getTableTemplateById(id);
|
|
TableTemplate tableTemplate = reportTableDao.getTableTemplateById(id);
|
|
- List<TableTemplateItem> tableItemList = reportTableDao.getTtiByTemplateId(id);
|
|
|
|
|
|
+ List<TableTemplateTableItem> tableItemList = reportTableDao.getTtiByTemplateId(id);
|
|
tableTemplate.setTableTemplateItemList(tableItemList);
|
|
tableTemplate.setTableTemplateItemList(tableItemList);
|
|
return Result.ok(tableTemplate);
|
|
return Result.ok(tableTemplate);
|
|
}
|
|
}
|
|
@@ -254,7 +251,7 @@ public class ReportTableServiceImpl implements ReportTableService {
|
|
Integer reportTableType = reportTable.getReportTableType();
|
|
Integer reportTableType = reportTable.getReportTableType();
|
|
Integer tableTemplateId = reportTable.getTableTemplateId();
|
|
Integer tableTemplateId = reportTable.getTableTemplateId();
|
|
TableTemplate tableTemplate = reportTableDao.getTableTemplateById(tableTemplateId);
|
|
TableTemplate tableTemplate = reportTableDao.getTableTemplateById(tableTemplateId);
|
|
- List<TableTemplateItem> tableTemplateItemList = reportTableDao.getTtiDataByTemplateId(tableTemplateId);
|
|
|
|
|
|
+ List<TableTemplateTableItem> tableTemplateItemList = reportTableDao.getTtiDataByTemplateId(tableTemplateId);
|
|
if (Blank.isEmpty(tableTemplate)) {
|
|
if (Blank.isEmpty(tableTemplate)) {
|
|
return Result.no(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "此报表模板不存在");
|
|
return Result.no(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "此报表模板不存在");
|
|
}
|
|
}
|
|
@@ -454,13 +451,13 @@ public class ReportTableServiceImpl implements ReportTableService {
|
|
if (Blank.isEmpty(tableTemplate)) {
|
|
if (Blank.isEmpty(tableTemplate)) {
|
|
return Result.no(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "模板不存在");
|
|
return Result.no(ResultEnum.REQUEST_WRONGPARAMS.getRespCode(), "模板不存在");
|
|
}
|
|
}
|
|
- List<TableTemplateItem> tableTemplateItemList = reportTableDao.getTtiDataByTemplateId(tableTemplateId);
|
|
|
|
|
|
+ List<TableTemplateTableItem> tableTemplateItemList = reportTableDao.getTtiDataByTemplateId(tableTemplateId);
|
|
String cron = reportTable.getCron();
|
|
String cron = reportTable.getCron();
|
|
Date startTime = CronUtil.mappingTime(cron, reportTable.getStartTime());
|
|
Date startTime = CronUtil.mappingTime(cron, reportTable.getStartTime());
|
|
Date endTime = CronUtil.mappingTime(cron, reportTable.getEndTime());
|
|
Date endTime = CronUtil.mappingTime(cron, reportTable.getEndTime());
|
|
List<ReportTableItem> reportTableItemList = new ArrayList<>();
|
|
List<ReportTableItem> reportTableItemList = new ArrayList<>();
|
|
if (Blank.isNotEmpty(tableTemplateItemList)) {
|
|
if (Blank.isNotEmpty(tableTemplateItemList)) {
|
|
- for (TableTemplateItem t : tableTemplateItemList) {
|
|
|
|
|
|
+ for (TableTemplateTableItem t : tableTemplateItemList) {
|
|
Integer itemGroupId = t.getItemGroupId();
|
|
Integer itemGroupId = t.getItemGroupId();
|
|
if (Blank.isEmpty(itemGroupId)) {
|
|
if (Blank.isEmpty(itemGroupId)) {
|
|
continue;
|
|
continue;
|
|
@@ -562,9 +559,9 @@ public class ReportTableServiceImpl implements ReportTableService {
|
|
}
|
|
}
|
|
if (reportTableType.equals(ConstantStr.EVENT_DRIVEN_REPORT)) {
|
|
if (reportTableType.equals(ConstantStr.EVENT_DRIVEN_REPORT)) {
|
|
Integer tableTemplateId = reportTable.getTableTemplateId();
|
|
Integer tableTemplateId = reportTable.getTableTemplateId();
|
|
- List<TableTemplateItem> tableTemplateItemList = reportTableDao.getTtiDataByTemplateId(tableTemplateId);
|
|
|
|
|
|
+ List<TableTemplateTableItem> tableTemplateItemList = reportTableDao.getTtiDataByTemplateId(tableTemplateId);
|
|
if (Blank.isNotEmpty(tableTemplateItemList)) {
|
|
if (Blank.isNotEmpty(tableTemplateItemList)) {
|
|
- TableTemplateItem tableTemplateItem = tableTemplateItemList.get(0);
|
|
|
|
|
|
+ TableTemplateTableItem tableTemplateItem = tableTemplateItemList.get(0);
|
|
ItemGroup itemGroup = itemGroupDao.getItemGroupById(tableTemplateItem.getItemGroupId());
|
|
ItemGroup itemGroup = itemGroupDao.getItemGroupById(tableTemplateItem.getItemGroupId());
|
|
if (Blank.isNotEmpty(itemGroup)) {
|
|
if (Blank.isNotEmpty(itemGroup)) {
|
|
if (itemGroup.getRunState().equals(ConstantStr.START_UP)) {
|
|
if (itemGroup.getRunState().equals(ConstantStr.START_UP)) {
|