mirror of
https://github.com/dataease/dataease.git
synced 2026-06-16 11:21:44 +08:00
refactor: 仪表板外部参数改造 (#17014)
This commit is contained in:
@@ -31,12 +31,12 @@ public class SnapshotVisualizationLinkJumpTargetViewInfo {
|
||||
@Size(max = 50)
|
||||
@Comment("目标图表ID")
|
||||
@Column(name = "target_view_id", length = 50)
|
||||
private String targetViewId;
|
||||
private Long targetViewId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("目标字段ID")
|
||||
@Column(name = "target_field_id", length = 50)
|
||||
private String targetFieldId;
|
||||
private Long targetFieldId;
|
||||
|
||||
@Comment("复制来源")
|
||||
@Column(name = "copy_from")
|
||||
|
||||
@@ -17,13 +17,13 @@ public class SnapshotVisualizationOuterParams {
|
||||
@Id
|
||||
@Size(max = 50)
|
||||
@Comment("主键")
|
||||
@Column(name = "params_id", nullable = false, length = 50)
|
||||
private String paramsId;
|
||||
@Column(name = "params_id", nullable = false)
|
||||
private Long paramsId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("可视化资源ID")
|
||||
@Column(name = "visualization_id", length = 50)
|
||||
private String visualizationId;
|
||||
@Column(name = "visualization_id")
|
||||
private Long visualizationId;
|
||||
|
||||
@Comment("是否启用外部参数标识(1-是,0-否)")
|
||||
@Column(name = "checked")
|
||||
|
||||
@@ -18,13 +18,13 @@ public class SnapshotVisualizationOuterParamsInfo {
|
||||
@Id
|
||||
@Size(max = 50)
|
||||
@Comment("主键")
|
||||
@Column(name = "params_info_id", nullable = false, length = 50)
|
||||
private String paramsInfoId;
|
||||
@Column(name = "params_info_id", nullable = false)
|
||||
private Long paramsInfoId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("visualization_outer_params 表的 ID")
|
||||
@Column(name = "params_id", length = 50)
|
||||
private String paramsId;
|
||||
@Column(name = "params_id")
|
||||
private Long paramsId;
|
||||
|
||||
@Size(max = 255)
|
||||
@Comment("参数名")
|
||||
|
||||
@@ -17,23 +17,23 @@ public class SnapshotVisualizationOuterParamsTargetViewInfo {
|
||||
@Id
|
||||
@Size(max = 50)
|
||||
@Comment("主键")
|
||||
@Column(name = "target_id", nullable = false, length = 50)
|
||||
private String targetId;
|
||||
@Column(name = "target_id", nullable = false)
|
||||
private Long targetId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("visualization_outer_params_info 表的 ID")
|
||||
@Column(name = "params_info_id", length = 50)
|
||||
private String paramsInfoId;
|
||||
@Column(name = "params_info_id")
|
||||
private Long paramsInfoId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("联动视图ID/联动过滤项ID")
|
||||
@Column(name = "target_view_id", length = 50)
|
||||
private String targetViewId;
|
||||
@Column(name = "target_view_id")
|
||||
private Long targetViewId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("联动字段ID")
|
||||
@Column(name = "target_field_id", length = 50)
|
||||
private String targetFieldId;
|
||||
@Column(name = "target_field_id")
|
||||
private Long targetFieldId;
|
||||
|
||||
@Size(max = 255)
|
||||
@Comment("复制来源")
|
||||
|
||||
@@ -32,12 +32,12 @@ public class VisualizationLinkJumpTargetViewInfo {
|
||||
@Size(max = 50)
|
||||
@Comment("目标图表ID")
|
||||
@Column(name = "target_view_id", length = 50)
|
||||
private String targetViewId;
|
||||
private Long targetViewId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("目标字段ID")
|
||||
@Column(name = "target_field_id", length = 50)
|
||||
private String targetFieldId;
|
||||
private Long targetFieldId;
|
||||
|
||||
@Comment("复制来源")
|
||||
@Column(name = "copy_from")
|
||||
|
||||
@@ -18,13 +18,13 @@ public class VisualizationOuterParams {
|
||||
@Id
|
||||
@Size(max = 50)
|
||||
@Comment("主键")
|
||||
@Column(name = "params_id", nullable = false, length = 50)
|
||||
private String paramsId;
|
||||
@Column(name = "params_id", nullable = false)
|
||||
private Long paramsId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("可视化资源ID")
|
||||
@Column(name = "visualization_id", length = 50)
|
||||
private String visualizationId;
|
||||
@Column(name = "visualization_id")
|
||||
private Long visualizationId;
|
||||
|
||||
@Comment("是否启用外部参数标识(1-是,0-否)")
|
||||
@Column(name = "checked")
|
||||
|
||||
@@ -16,13 +16,13 @@ public class VisualizationOuterParamsInfo {
|
||||
@Id
|
||||
@Size(max = 50)
|
||||
@Comment("主键")
|
||||
@Column(name = "params_info_id", nullable = false, length = 50)
|
||||
private String paramsInfoId;
|
||||
@Column(name = "params_info_id", nullable = false)
|
||||
private Long paramsInfoId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("visualization_outer_params 表的 ID")
|
||||
@Column(name = "params_id", length = 50)
|
||||
private String paramsId;
|
||||
@Column(name = "params_id")
|
||||
private Long paramsId;
|
||||
|
||||
@Size(max = 255)
|
||||
@Comment("参数名")
|
||||
|
||||
@@ -18,23 +18,23 @@ public class VisualizationOuterParamsTargetViewInfo {
|
||||
@Id
|
||||
@Size(max = 50)
|
||||
@Comment("主键")
|
||||
@Column(name = "target_id", nullable = false, length = 50)
|
||||
private String targetId;
|
||||
@Column(name = "target_id", nullable = false)
|
||||
private Long targetId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("visualization_outer_params_info 表的 ID")
|
||||
@Column(name = "params_info_id", length = 50)
|
||||
private String paramsInfoId;
|
||||
@Column(name = "params_info_id")
|
||||
private Long paramsInfoId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("联动视图ID/联动过滤项ID")
|
||||
@Column(name = "target_view_id", length = 50)
|
||||
private String targetViewId;
|
||||
@Column(name = "target_view_id")
|
||||
private Long targetViewId;
|
||||
|
||||
@Size(max = 50)
|
||||
@Comment("联动字段ID")
|
||||
@Column(name = "target_field_id", length = 50)
|
||||
private String targetFieldId;
|
||||
@Column(name = "target_field_id")
|
||||
private Long targetFieldId;
|
||||
|
||||
@Size(max = 255)
|
||||
@Comment("复制来源")
|
||||
|
||||
@@ -13,7 +13,7 @@ import java.util.List;
|
||||
public interface SnapshotVisualizationOuterParamsInfoRepository extends JpaRepository<SnapshotVisualizationOuterParamsInfo, Long>, JpaSpecificationExecutor<SnapshotVisualizationOuterParamsInfo> {
|
||||
|
||||
@Transactional
|
||||
default void deleteByParamsIds(List<String> paramsIds) {
|
||||
default void deleteByParamsIds(List<Long> paramsIds) {
|
||||
Specification<SnapshotVisualizationOuterParamsInfo> spec = (root, query, cb) ->
|
||||
cb.and(cb.in(root.get("paramsId")).value(paramsIds));
|
||||
List<SnapshotVisualizationOuterParamsInfo> entities = findAll(spec);
|
||||
|
||||
@@ -13,7 +13,7 @@ import java.util.List;
|
||||
public interface SnapshotVisualizationOuterParamsRepository extends JpaRepository<SnapshotVisualizationOuterParams, Long>, JpaSpecificationExecutor<SnapshotVisualizationOuterParams> {
|
||||
|
||||
@Transactional
|
||||
default void deleteByVisualizationId(String visualizationId) {
|
||||
default void deleteByVisualizationId(Long visualizationId) {
|
||||
Specification<SnapshotVisualizationOuterParams> spec = (root, query, cb) ->
|
||||
cb.equal(root.get("visualizationId"), visualizationId);
|
||||
List<SnapshotVisualizationOuterParams> list = findAll(spec);
|
||||
|
||||
@@ -14,7 +14,7 @@ public interface SnapshotVisualizationOuterParamsTargetViewInfoRepository extend
|
||||
|
||||
|
||||
@Transactional
|
||||
default void deleteByParamsInfoIds(List<String> paramsInfoIds) {
|
||||
default void deleteByParamsInfoIds(List<Long> paramsInfoIds) {
|
||||
Specification<SnapshotVisualizationOuterParamsTargetViewInfo> spec = (root, query, cb) ->
|
||||
cb.and(root.get("paramsInfoId").in(paramsInfoIds));
|
||||
List<SnapshotVisualizationOuterParamsTargetViewInfo> entities = findAll(spec);
|
||||
|
||||
@@ -13,7 +13,7 @@ public interface VisualizationOuterParamsInfoRepository extends JpaRepository<Vi
|
||||
|
||||
|
||||
@Transactional
|
||||
default void deleteByParamsIds(List<String> paramsIds) {
|
||||
default void deleteByParamsIds(List<Long> paramsIds) {
|
||||
Specification<VisualizationOuterParamsInfo> spec = (root, query, cb) ->
|
||||
cb.and(root.get("paramsId").in(paramsIds));
|
||||
List<VisualizationOuterParamsInfo> entities = findAll(spec);
|
||||
|
||||
@@ -12,10 +12,10 @@ import java.util.List;
|
||||
public interface VisualizationOuterParamsRepository extends JpaRepository<VisualizationOuterParams, Long>, JpaSpecificationExecutor<VisualizationOuterParams> {
|
||||
|
||||
|
||||
List<VisualizationOuterParams> findByVisualizationId(String visualizationId);
|
||||
List<VisualizationOuterParams> findByVisualizationId(Long visualizationId);
|
||||
|
||||
@Transactional
|
||||
default void deleteByVisualizationId(String visualizationId) {
|
||||
default void deleteByVisualizationId(Long visualizationId) {
|
||||
Specification<VisualizationOuterParams> spec = (root, query, cb) ->
|
||||
cb.equal(root.get("visualizationId"), visualizationId);
|
||||
List<VisualizationOuterParams> paramsList = findAll(spec);
|
||||
|
||||
@@ -329,23 +329,23 @@ public class CoreVisualizationManage {
|
||||
QSnapshotVisualizationOuterParamsInfo snapshotVisualizationOuterParamsInfo = QSnapshotVisualizationOuterParamsInfo.snapshotVisualizationOuterParamsInfo;
|
||||
QSnapshotVisualizationOuterParams snapshotVisualizationOuterParams = QSnapshotVisualizationOuterParams.snapshotVisualizationOuterParams;
|
||||
QSnapshotVisualizationOuterParamsTargetViewInfo snapshotVisualizationOuterParamsTargetViewInfo = QSnapshotVisualizationOuterParamsTargetViewInfo.snapshotVisualizationOuterParamsTargetViewInfo;
|
||||
List<String> paramsInfoIds = queryFactory.select(snapshotVisualizationOuterParamsTargetViewInfo.targetId).from(snapshotVisualizationOuterParamsTargetViewInfo)
|
||||
List<Long> paramsInfoIds = queryFactory.select(snapshotVisualizationOuterParamsTargetViewInfo.targetId).from(snapshotVisualizationOuterParamsTargetViewInfo)
|
||||
.innerJoin(snapshotVisualizationOuterParamsInfo).on(snapshotVisualizationOuterParamsTargetViewInfo.paramsInfoId.eq(snapshotVisualizationOuterParamsInfo.paramsInfoId))
|
||||
.innerJoin(snapshotVisualizationOuterParams).on(snapshotVisualizationOuterParamsInfo.paramsId.eq(snapshotVisualizationOuterParams.paramsId))
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId.toString())).fetch();
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId)).fetch();
|
||||
|
||||
if (CollectionUtils.isNotEmpty(paramsInfoIds)) {
|
||||
snapshotVisualizationOuterParamsTargetViewInfoRepository.deleteByParamsInfoIds(paramsInfoIds);
|
||||
}
|
||||
|
||||
List<String> paramsIds = queryFactory.select(snapshotVisualizationOuterParamsInfo.paramsId).from(snapshotVisualizationOuterParamsInfo)
|
||||
List<Long> paramsIds = queryFactory.select(snapshotVisualizationOuterParamsInfo.paramsId).from(snapshotVisualizationOuterParamsInfo)
|
||||
.innerJoin(snapshotVisualizationOuterParams).on(snapshotVisualizationOuterParamsInfo.paramsId.eq(snapshotVisualizationOuterParams.paramsId))
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId.toString()))
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId))
|
||||
.fetch();
|
||||
if (CollectionUtils.isNotEmpty(paramsIds)) {
|
||||
snapshotVisualizationOuterParamsInfoRepository.deleteByParamsIds(paramsIds);
|
||||
}
|
||||
snapshotVisualizationOuterParamsRepository.deleteByVisualizationId(dvId.toString());
|
||||
snapshotVisualizationOuterParamsRepository.deleteByVisualizationId(dvId);
|
||||
//xpack 阈值告警
|
||||
chartViewManege.removeThreshold(dvId, CommonConstants.RESOURCE_TABLE.SNAPSHOT);
|
||||
|
||||
@@ -431,25 +431,25 @@ public class CoreVisualizationManage {
|
||||
QSnapshotVisualizationOuterParamsInfo snapshotVisualizationOuterParamsInfo = QSnapshotVisualizationOuterParamsInfo.snapshotVisualizationOuterParamsInfo;
|
||||
QSnapshotVisualizationOuterParams snapshotVisualizationOuterParams = QSnapshotVisualizationOuterParams.snapshotVisualizationOuterParams;
|
||||
|
||||
List<String> paramsInfoIds = queryFactory.select(snapshotVisualizationOuterParamsTargetViewInfo.targetId)
|
||||
List<Long> paramsInfoIds = queryFactory.select(snapshotVisualizationOuterParamsTargetViewInfo.targetId)
|
||||
.from(snapshotVisualizationOuterParamsTargetViewInfo)
|
||||
.innerJoin(snapshotVisualizationOuterParamsInfo).on(snapshotVisualizationOuterParamsTargetViewInfo.paramsInfoId.eq(snapshotVisualizationOuterParamsInfo.paramsInfoId))
|
||||
.innerJoin(snapshotVisualizationOuterParams).on(snapshotVisualizationOuterParamsInfo.paramsId.eq(snapshotVisualizationOuterParams.paramsId))
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId.toString())).fetch();
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId)).fetch();
|
||||
if (CollectionUtils.isNotEmpty(paramsInfoIds)) {
|
||||
snapshotVisualizationOuterParamsTargetViewInfoRepository.deleteByParamsInfoIds(paramsInfoIds);
|
||||
}
|
||||
|
||||
QVisualizationOuterParamsInfo visualizationOuterParamsInfo = QVisualizationOuterParamsInfo.visualizationOuterParamsInfo;
|
||||
QVisualizationOuterParams visualizationOuterParams = QVisualizationOuterParams.visualizationOuterParams;
|
||||
List<String> paramsIds = queryFactory.select(visualizationOuterParamsInfo.paramsId).from(visualizationOuterParamsInfo)
|
||||
List<Long> paramsIds = queryFactory.select(visualizationOuterParamsInfo.paramsId).from(visualizationOuterParamsInfo)
|
||||
.leftJoin(visualizationOuterParams).on(visualizationOuterParamsInfo.paramsId.eq(visualizationOuterParams.paramsId))
|
||||
.where(visualizationOuterParams.visualizationId.eq(dvId.toString())).fetch();
|
||||
.where(visualizationOuterParams.visualizationId.eq(dvId)).fetch();
|
||||
|
||||
if (CollectionUtils.isNotEmpty(paramsIds)) {
|
||||
visualizationOuterParamsInfoRepository.deleteByParamsIds(paramsIds);
|
||||
}
|
||||
visualizationOuterParamsRepository.deleteByVisualizationId(dvId.toString());
|
||||
visualizationOuterParamsRepository.deleteByVisualizationId(dvId);
|
||||
//xpack 阈值告警
|
||||
chartViewManege.removeThreshold(dvId, CommonConstants.RESOURCE_TABLE.CORE);
|
||||
}
|
||||
@@ -560,7 +560,7 @@ public class CoreVisualizationManage {
|
||||
)).from(visualizationOuterParamsTargetViewInfo)
|
||||
.leftJoin(visualizationOuterParamsInfo).on(visualizationOuterParamsTargetViewInfo.paramsInfoId.eq(visualizationOuterParamsInfo.paramsInfoId))
|
||||
.leftJoin(visualizationOuterParams).on(visualizationOuterParams.paramsId.eq(visualizationOuterParamsInfo.paramsId))
|
||||
.where(visualizationOuterParams.visualizationId.eq(dvId.toString())).fetch().forEach(item -> {
|
||||
.where(visualizationOuterParams.visualizationId.eq(dvId)).fetch().forEach(item -> {
|
||||
SnapshotVisualizationOuterParamsTargetViewInfo snapshotVisualizationOuterParamsTargetViewInfo = new SnapshotVisualizationOuterParamsTargetViewInfo();
|
||||
BeanUtils.copyBean(snapshotVisualizationOuterParamsTargetViewInfo, item);
|
||||
snapshotVisualizationOuterParamsTargetViewInfoRepository.saveAndFlush(snapshotVisualizationOuterParamsTargetViewInfo);
|
||||
@@ -578,13 +578,13 @@ public class CoreVisualizationManage {
|
||||
visualizationOuterParamsInfo.enabledDefault
|
||||
)).from(visualizationOuterParamsInfo)
|
||||
.leftJoin(visualizationOuterParams).on(visualizationOuterParams.paramsId.eq(visualizationOuterParamsInfo.paramsId))
|
||||
.where(visualizationOuterParams.visualizationId.eq(dvId.toString())).fetch().forEach(item -> {
|
||||
.where(visualizationOuterParams.visualizationId.eq(dvId)).fetch().forEach(item -> {
|
||||
SnapshotVisualizationOuterParamsInfo snapshotVisualizationOuterParamsInfo = new SnapshotVisualizationOuterParamsInfo();
|
||||
BeanUtils.copyBean(snapshotVisualizationOuterParamsInfo, item);
|
||||
snapshotVisualizationOuterParamsInfoRepository.saveAndFlush(snapshotVisualizationOuterParamsInfo);
|
||||
});
|
||||
|
||||
visualizationOuterParamsRepository.findByVisualizationId(dvId.toString()).forEach(item -> {
|
||||
visualizationOuterParamsRepository.findByVisualizationId(dvId).forEach(item -> {
|
||||
SnapshotVisualizationOuterParams snapshotVisualizationOuterParams = new SnapshotVisualizationOuterParams();
|
||||
BeanUtils.copyBean(snapshotVisualizationOuterParams, item);
|
||||
snapshotVisualizationOuterParamsRepository.saveAndFlush(snapshotVisualizationOuterParams);
|
||||
@@ -717,7 +717,7 @@ public class CoreVisualizationManage {
|
||||
)).from(snapshotVisualizationOuterParamsTargetViewInfo)
|
||||
.leftJoin(snapshotVisualizationOuterParamsInfo).on(snapshotVisualizationOuterParamsTargetViewInfo.paramsInfoId.eq(snapshotVisualizationOuterParamsInfo.paramsInfoId))
|
||||
.leftJoin(snapshotVisualizationOuterParams).on(snapshotVisualizationOuterParams.paramsId.eq(snapshotVisualizationOuterParamsInfo.paramsId))
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId.toString())).fetch().forEach(item -> {
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId)).fetch().forEach(item -> {
|
||||
VisualizationOuterParamsTargetViewInfo visualizationOuterParamsTargetViewInfo = new VisualizationOuterParamsTargetViewInfo();
|
||||
BeanUtils.copyBean(visualizationOuterParamsTargetViewInfo, item);
|
||||
visualizationOuterParamsTargetViewInfoRepository.saveAndFlush(visualizationOuterParamsTargetViewInfo);
|
||||
@@ -736,7 +736,7 @@ public class CoreVisualizationManage {
|
||||
snapshotVisualizationOuterParamsInfo.enabledDefault
|
||||
)).from(snapshotVisualizationOuterParamsInfo)
|
||||
.leftJoin(snapshotVisualizationOuterParams).on(snapshotVisualizationOuterParamsInfo.paramsId.eq(snapshotVisualizationOuterParams.paramsId))
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId.toString())).fetch().forEach(item -> {
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(dvId)).fetch().forEach(item -> {
|
||||
VisualizationOuterParamsInfo visualizationOuterParamsInfo = new VisualizationOuterParamsInfo();
|
||||
BeanUtils.copyBean(visualizationOuterParamsInfo, item);
|
||||
visualizationOuterParamsInfoRepository.saveAndFlush(visualizationOuterParamsInfo);
|
||||
@@ -750,7 +750,7 @@ public class CoreVisualizationManage {
|
||||
snapshotVisualizationOuterParams.remark,
|
||||
snapshotVisualizationOuterParams.copyFrom,
|
||||
snapshotVisualizationOuterParams.copyId
|
||||
)).from(snapshotVisualizationOuterParams).where(snapshotVisualizationOuterParams.visualizationId.eq(dvId.toString())).fetch().forEach(item -> {
|
||||
)).from(snapshotVisualizationOuterParams).where(snapshotVisualizationOuterParams.visualizationId.eq(dvId)).fetch().forEach(item -> {
|
||||
VisualizationOuterParams outerParams = new VisualizationOuterParams();
|
||||
BeanUtils.copyBean(outerParams, item);
|
||||
visualizationOuterParamsRepository.saveAndFlush(outerParams);
|
||||
|
||||
@@ -289,7 +289,7 @@ public class VisualizationLinkJumpService implements VisualizationLinkJumpApi {
|
||||
visualizationOuterParamsInfo.paramName.as("title")
|
||||
)).from(visualizationOuterParamsInfo)
|
||||
.leftJoin(visualizationOuterParams).on(visualizationOuterParamsInfo.paramsId.eq(visualizationOuterParams.paramsId))
|
||||
.where(visualizationOuterParams.visualizationId.eq(dvId.toString())).fetch().forEach(outParamsJumpVO -> {
|
||||
.where(visualizationOuterParams.visualizationId.eq(dvId)).fetch().forEach(outParamsJumpVO -> {
|
||||
outParamsJumpVO.setType("outerParams");
|
||||
outParamsJumpInfos.add(outParamsJumpVO);
|
||||
});
|
||||
|
||||
@@ -14,10 +14,10 @@ import io.dataease.constant.CommonConstants;
|
||||
import io.dataease.dao.auto.entity.CoreDatasetTable;
|
||||
import io.dataease.dao.auto.entity.QCoreDatasetGroup;
|
||||
import io.dataease.dataset.dao.auto.mapper.CoreDatasetTableRepository;
|
||||
import io.dataease.constant.DeTypeConstants;
|
||||
import io.dataease.dataset.utils.FieldUtils;
|
||||
import io.dataease.extensions.view.dto.SqlVariableDetails;
|
||||
import io.dataease.utils.BeanUtils;
|
||||
import io.dataease.utils.IDUtils;
|
||||
import io.dataease.utils.JsonUtil;
|
||||
import io.dataease.visualization.dao.auto.entity.*;
|
||||
import io.dataease.visualization.dao.auto.mapper.*;
|
||||
@@ -55,15 +55,15 @@ public class VisualizationOuterParamsService implements VisualizationOuterParams
|
||||
|
||||
|
||||
@Override
|
||||
public VisualizationOuterParamsDTO queryWithVisualizationId(String visualizationId) {
|
||||
public VisualizationOuterParamsDTO queryWithVisualizationId(Long visualizationId) {
|
||||
QSnapshotDataVisualizationInfo qSnapshotDataVisualizationInfo = QSnapshotDataVisualizationInfo.snapshotDataVisualizationInfo;
|
||||
QSnapshotVisualizationOuterParams qSnapshotVisualizationOuterParams = QSnapshotVisualizationOuterParams.snapshotVisualizationOuterParams;
|
||||
VisualizationOuterParamsDTO visualizationOuterParamsDTO = queryFactory.select(Projections.fields(VisualizationOuterParamsDTO.class,
|
||||
qSnapshotDataVisualizationInfo.id.as("visualizationId"),
|
||||
qSnapshotVisualizationOuterParams.checked.as("checked")
|
||||
)).from(qSnapshotDataVisualizationInfo)
|
||||
.leftJoin(qSnapshotVisualizationOuterParams).on(qSnapshotDataVisualizationInfo.id.stringValue().eq(qSnapshotVisualizationOuterParams.visualizationId))
|
||||
.where(qSnapshotDataVisualizationInfo.id.stringValue().eq(visualizationId)).fetchFirst();
|
||||
.leftJoin(qSnapshotVisualizationOuterParams).on(qSnapshotDataVisualizationInfo.id.eq(qSnapshotVisualizationOuterParams.visualizationId))
|
||||
.where(qSnapshotDataVisualizationInfo.id.eq(visualizationId)).fetchFirst();
|
||||
if (visualizationOuterParamsDTO != null && visualizationOuterParamsDTO.getChecked() == null) {
|
||||
visualizationOuterParamsDTO.setChecked(false);
|
||||
}
|
||||
@@ -72,9 +72,9 @@ public class VisualizationOuterParamsService implements VisualizationOuterParams
|
||||
|
||||
@Override
|
||||
public void updateOuterParamsSet(VisualizationOuterParamsDTO outerParamsDTO) {
|
||||
String visualizationId = outerParamsDTO.getVisualizationId();
|
||||
Long visualizationId = outerParamsDTO.getVisualizationId();
|
||||
Assert.notNull(visualizationId, "visualizationId cannot be null");
|
||||
Map<String, String> paramsInfoNameIdMap = new HashMap<>();
|
||||
Map<String, Long> paramsInfoNameIdMap = new HashMap<>();
|
||||
QSnapshotVisualizationOuterParamsInfo qSnapshotVisualizationOuterParamsInfo = QSnapshotVisualizationOuterParamsInfo.snapshotVisualizationOuterParamsInfo;
|
||||
QSnapshotVisualizationOuterParams qSnapshotVisualizationOuterParams = QSnapshotVisualizationOuterParams.snapshotVisualizationOuterParams;
|
||||
List<SnapshotVisualizationOuterParamsInfo> paramsInfoNameIdList = queryFactory.select(Projections.fields(SnapshotVisualizationOuterParamsInfo.class,
|
||||
@@ -91,7 +91,7 @@ public class VisualizationOuterParamsService implements VisualizationOuterParams
|
||||
QSnapshotVisualizationOuterParamsInfo snapshotVisualizationOuterParamsInfo = QSnapshotVisualizationOuterParamsInfo.snapshotVisualizationOuterParamsInfo;
|
||||
QSnapshotVisualizationOuterParams snapshotVisualizationOuterParams = QSnapshotVisualizationOuterParams.snapshotVisualizationOuterParams;
|
||||
QSnapshotVisualizationOuterParamsTargetViewInfo snapshotVisualizationOuterParamsTargetViewInfo = QSnapshotVisualizationOuterParamsTargetViewInfo.snapshotVisualizationOuterParamsTargetViewInfo;
|
||||
List<String> paramsInfoIds = queryFactory.select(snapshotVisualizationOuterParamsTargetViewInfo.targetId).from(snapshotVisualizationOuterParamsTargetViewInfo)
|
||||
List<Long> paramsInfoIds = queryFactory.select(snapshotVisualizationOuterParamsTargetViewInfo.targetId).from(snapshotVisualizationOuterParamsTargetViewInfo)
|
||||
.innerJoin(snapshotVisualizationOuterParamsInfo).on(snapshotVisualizationOuterParamsTargetViewInfo.paramsInfoId.eq(snapshotVisualizationOuterParamsInfo.paramsInfoId))
|
||||
.innerJoin(snapshotVisualizationOuterParams).on(snapshotVisualizationOuterParamsInfo.paramsId.eq(snapshotVisualizationOuterParams.paramsId))
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(visualizationId)).fetch();
|
||||
@@ -100,7 +100,7 @@ public class VisualizationOuterParamsService implements VisualizationOuterParams
|
||||
snapshotVisualizationOuterParamsTargetViewInfoRepository.deleteByParamsInfoIds(paramsInfoIds);
|
||||
}
|
||||
|
||||
List<String> paramsIds = queryFactory.select(snapshotVisualizationOuterParamsInfo.paramsId).from(snapshotVisualizationOuterParamsInfo)
|
||||
List<Long> paramsIds = queryFactory.select(snapshotVisualizationOuterParamsInfo.paramsId).from(snapshotVisualizationOuterParamsInfo)
|
||||
.innerJoin(snapshotVisualizationOuterParams).on(snapshotVisualizationOuterParamsInfo.paramsId.eq(snapshotVisualizationOuterParams.paramsId))
|
||||
.where(snapshotVisualizationOuterParams.visualizationId.eq(visualizationId))
|
||||
.fetch();
|
||||
@@ -112,25 +112,25 @@ public class VisualizationOuterParamsService implements VisualizationOuterParams
|
||||
return;
|
||||
}
|
||||
// 插入新的数据
|
||||
String paramsId = UUID.randomUUID().toString();
|
||||
Long paramsId = IDUtils.snowID();
|
||||
outerParamsDTO.setParamsId(paramsId);
|
||||
SnapshotVisualizationOuterParams newOuterParams = new SnapshotVisualizationOuterParams();
|
||||
BeanUtils.copyBean(newOuterParams, outerParamsDTO);
|
||||
snapshotVisualizationOuterParamsRepository.saveAndFlush(newOuterParams);
|
||||
Map<String, String> finalParamsInfoNameIdMap = paramsInfoNameIdMap;
|
||||
Map<String, Long> finalParamsInfoNameIdMap = paramsInfoNameIdMap;
|
||||
Optional.ofNullable(outerParamsDTO.getOuterParamsInfoArray()).orElse(new ArrayList<>()).forEach(outerParamsInfo -> {
|
||||
String paramsInfoId = finalParamsInfoNameIdMap.get(outerParamsInfo.getParamName());
|
||||
if (StringUtils.isEmpty(paramsInfoId)) {
|
||||
paramsInfoId = UUID.randomUUID().toString();
|
||||
Long paramsInfoId = finalParamsInfoNameIdMap.get(outerParamsInfo.getParamName());
|
||||
if (paramsInfoId != null) {
|
||||
paramsInfoId = IDUtils.snowID();
|
||||
}
|
||||
outerParamsInfo.setParamsInfoId(paramsInfoId);
|
||||
outerParamsInfo.setParamsId(paramsId);
|
||||
SnapshotVisualizationOuterParamsInfo newOuterParamsInfo = new SnapshotVisualizationOuterParamsInfo();
|
||||
BeanUtils.copyBean(newOuterParamsInfo, outerParamsInfo);
|
||||
snapshotVisualizationOuterParamsInfoRepository.saveAndFlush(newOuterParamsInfo);
|
||||
String finalParamsInfoId = paramsInfoId;
|
||||
Long finalParamsInfoId = paramsInfoId;
|
||||
Optional.ofNullable(outerParamsInfo.getTargetViewInfoList()).orElse(new ArrayList<>()).forEach(targetViewInfo -> {
|
||||
String targetViewInfoId = UUID.randomUUID().toString();
|
||||
Long targetViewInfoId = IDUtils.snowID();
|
||||
targetViewInfo.setTargetId(targetViewInfoId);
|
||||
targetViewInfo.setParamsInfoId(finalParamsInfoId);
|
||||
SnapshotVisualizationOuterParamsTargetViewInfo newOuterParamsTargetViewInfo = new SnapshotVisualizationOuterParamsTargetViewInfo();
|
||||
@@ -143,7 +143,7 @@ public class VisualizationOuterParamsService implements VisualizationOuterParams
|
||||
|
||||
@DeLinkPermit
|
||||
@Override
|
||||
public VisualizationOuterParamsBaseResponse getOuterParamsInfo(String visualizationId) {
|
||||
public VisualizationOuterParamsBaseResponse getOuterParamsInfo(Long visualizationId) {
|
||||
|
||||
QVisualizationOuterParams qVisualizationOuterParams = QVisualizationOuterParams.visualizationOuterParams;
|
||||
QVisualizationOuterParamsInfo qVisualizationOuterParamsInfo = QVisualizationOuterParamsInfo.visualizationOuterParamsInfo;
|
||||
@@ -154,7 +154,7 @@ public class VisualizationOuterParamsService implements VisualizationOuterParams
|
||||
qVisualizationOuterParamsInfo.required,
|
||||
qVisualizationOuterParamsInfo.defaultValue,
|
||||
qVisualizationOuterParamsInfo.enabledDefault,
|
||||
visualizationOuterParamsTargetViewInfo.targetViewId.concat("#").concat(visualizationOuterParamsTargetViewInfo.targetViewId).as("targetInfo"))).from(qVisualizationOuterParams)
|
||||
visualizationOuterParamsTargetViewInfo.targetViewId.stringValue().concat("#").concat(visualizationOuterParamsTargetViewInfo.targetViewId.stringValue()).as("targetInfo"))).from(qVisualizationOuterParams)
|
||||
.leftJoin(qVisualizationOuterParamsInfo).on(qVisualizationOuterParamsInfo.paramsId.eq(qVisualizationOuterParams.paramsId))
|
||||
.leftJoin(visualizationOuterParamsTargetViewInfo).on(visualizationOuterParamsTargetViewInfo.paramsInfoId.eq(qVisualizationOuterParamsInfo.paramsInfoId))
|
||||
.fetch();
|
||||
@@ -164,7 +164,7 @@ public class VisualizationOuterParamsService implements VisualizationOuterParams
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<CoreDatasetGroupVO> queryDsWithVisualizationId(String visualizationId) {
|
||||
public List<CoreDatasetGroupVO> queryDsWithVisualizationId(Long visualizationId) {
|
||||
|
||||
QCoreDatasetGroup qCoreDatasetGroup = QCoreDatasetGroup.coreDatasetGroup;
|
||||
QSnapshotCoreChartView qSnapshotCoreChartView = QSnapshotCoreChartView.snapshotCoreChartView;
|
||||
@@ -186,12 +186,12 @@ public class VisualizationOuterParamsService implements VisualizationOuterParams
|
||||
qCoreDatasetGroup.lastUpdateTime
|
||||
)).from(qCoreDatasetGroup)
|
||||
.innerJoin(qSnapshotCoreChartView).on(qCoreDatasetGroup.id.eq(qSnapshotCoreChartView.tableId).and(qSnapshotCoreChartView.type.ne("VQuery")))
|
||||
.innerJoin(qSnapshotDataVisualizationInfo).on(qSnapshotCoreChartView.sceneId.eq(Long.valueOf(qSnapshotDataVisualizationInfo.id.toString())))
|
||||
.where(qSnapshotCoreChartView.sceneId.eq(Long.valueOf(visualizationId)).and(qSnapshotDataVisualizationInfo.id.stringValue().eq(visualizationId)))
|
||||
.innerJoin(qSnapshotDataVisualizationInfo).on(qSnapshotCoreChartView.sceneId.eq(qSnapshotDataVisualizationInfo.id))
|
||||
.where(qSnapshotCoreChartView.sceneId.eq(visualizationId).and(qSnapshotDataVisualizationInfo.id.eq(visualizationId)))
|
||||
.where(qSnapshotDataVisualizationInfo.componentData.like("%" + qSnapshotCoreChartView.id + "%"))
|
||||
.fetch();
|
||||
if (!CollectionUtils.isEmpty(result)) {
|
||||
List<Long> activeViewIds = dataVisualizationServer.getEnabledViewIds(Long.valueOf(visualizationId), CommonConstants.RESOURCE_TABLE.SNAPSHOT);
|
||||
List<Long> activeViewIds = dataVisualizationServer.getEnabledViewIds(visualizationId, CommonConstants.RESOURCE_TABLE.SNAPSHOT);
|
||||
result.forEach(coreDatasetGroupVO -> {
|
||||
// 过滤已删除的图表
|
||||
if (!CollectionUtils.isEmpty(coreDatasetGroupVO.getDatasetViews())) {
|
||||
|
||||
@@ -15,7 +15,7 @@ public interface VisualizationOuterParamsApi {
|
||||
|
||||
@GetMapping("/queryWithVisualizationId/{dvId}")
|
||||
@Operation(summary = "查询")
|
||||
VisualizationOuterParamsDTO queryWithVisualizationId(@PathVariable("dvId") String dvId);
|
||||
VisualizationOuterParamsDTO queryWithVisualizationId(@PathVariable("dvId") Long dvId);
|
||||
|
||||
@PostMapping("/updateOuterParamsSet")
|
||||
@Operation(summary = "更新")
|
||||
@@ -23,9 +23,9 @@ public interface VisualizationOuterParamsApi {
|
||||
|
||||
@GetMapping("/getOuterParamsInfo/{dvId}")
|
||||
@Operation(summary = "查询基础信息")
|
||||
VisualizationOuterParamsBaseResponse getOuterParamsInfo(@PathVariable("dvId") String dvId);
|
||||
VisualizationOuterParamsBaseResponse getOuterParamsInfo(@PathVariable("dvId") Long dvId);
|
||||
|
||||
@GetMapping("/queryDsWithVisualizationId/{dvId}")
|
||||
@Operation(summary = "查询涉及数据集基础信息")
|
||||
List<CoreDatasetGroupVO> queryDsWithVisualizationId(@PathVariable("dvId") String dvId);
|
||||
List<CoreDatasetGroupVO> queryDsWithVisualizationId(@PathVariable("dvId") Long dvId);
|
||||
}
|
||||
|
||||
@@ -1,11 +1,14 @@
|
||||
package io.dataease.api.visualization.vo;
|
||||
|
||||
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
|
||||
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class VisualizationOutParamsJumpVO {
|
||||
|
||||
private String id;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long id;
|
||||
|
||||
private String type;
|
||||
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
package io.dataease.api.visualization.vo;
|
||||
|
||||
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
|
||||
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
@@ -10,7 +12,8 @@ public class VisualizationOuterParamsDsInfoVO {
|
||||
|
||||
private String dsName;
|
||||
|
||||
private String dsId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long dsId;
|
||||
|
||||
private List targetFieldInfo;
|
||||
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
package io.dataease.api.visualization.vo;
|
||||
|
||||
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
|
||||
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
@@ -8,8 +10,10 @@ import java.util.Map;
|
||||
@Data
|
||||
public class VisualizationOuterParamsFilterInfoVO {
|
||||
|
||||
private String filterComponentId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long filterComponentId;
|
||||
|
||||
private String filterId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long filterId;
|
||||
|
||||
}
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
package io.dataease.api.visualization.vo;
|
||||
|
||||
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
|
||||
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
@@ -20,12 +22,14 @@ public class VisualizationOuterParamsInfoVO implements Serializable {
|
||||
/**
|
||||
* 主键
|
||||
*/
|
||||
private String paramsInfoId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long paramsInfoId;
|
||||
|
||||
/**
|
||||
* visualization_outer_params 表的 ID
|
||||
*/
|
||||
private String paramsId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long paramsId;
|
||||
|
||||
/**
|
||||
* 参数名
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
package io.dataease.api.visualization.vo;
|
||||
|
||||
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
|
||||
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
@@ -20,27 +22,32 @@ public class VisualizationOuterParamsTargetViewInfoVO implements Serializable {
|
||||
/**
|
||||
* 主键
|
||||
*/
|
||||
private String targetId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long targetId;
|
||||
|
||||
/**
|
||||
* visualization_outer_params_info 表的 ID
|
||||
*/
|
||||
private String paramsInfoId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long paramsInfoId;
|
||||
|
||||
/**
|
||||
* 联动视图ID
|
||||
*/
|
||||
private String targetViewId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long targetViewId;
|
||||
|
||||
/**
|
||||
* 联动数据集id/联动过滤组件id
|
||||
*/
|
||||
private String targetDsId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long targetDsId;
|
||||
|
||||
/**
|
||||
* 联动字段ID
|
||||
*/
|
||||
private String targetFieldId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long targetFieldId;
|
||||
|
||||
/**
|
||||
* 复制来源
|
||||
|
||||
@@ -1,6 +1,9 @@
|
||||
package io.dataease.api.visualization.vo;
|
||||
|
||||
|
||||
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
|
||||
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
@@ -18,12 +21,14 @@ public class VisualizationOuterParamsVO implements Serializable {
|
||||
/**
|
||||
* 主键
|
||||
*/
|
||||
private String paramsId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long paramsId;
|
||||
|
||||
/**
|
||||
* 可视化资源ID
|
||||
*/
|
||||
private String visualizationId;
|
||||
@JsonSerialize(using = ToStringSerializer.class)
|
||||
private Long visualizationId;
|
||||
|
||||
/**
|
||||
* 是否启用外部参数标识(1-是,0-否)
|
||||
@@ -56,19 +61,19 @@ public class VisualizationOuterParamsVO implements Serializable {
|
||||
private String defaultValue;
|
||||
|
||||
|
||||
public String getParamsId() {
|
||||
public Long getParamsId() {
|
||||
return paramsId;
|
||||
}
|
||||
|
||||
public void setParamsId(String paramsId) {
|
||||
public void setParamsId(Long paramsId) {
|
||||
this.paramsId = paramsId;
|
||||
}
|
||||
|
||||
public String getVisualizationId() {
|
||||
public Long getVisualizationId() {
|
||||
return visualizationId;
|
||||
}
|
||||
|
||||
public void setVisualizationId(String visualizationId) {
|
||||
public void setVisualizationId(Long visualizationId) {
|
||||
this.visualizationId = visualizationId;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user