Commit 180202b1 authored by linruibiao's avatar linruibiao

接口编写

parent c3259963
Pipeline #9229 passed with stages
in 1 minute 59 seconds
...@@ -8,6 +8,7 @@ import com.syc.slm.slmbi.vo.InstrumentPanelConfigVo; ...@@ -8,6 +8,7 @@ import com.syc.slm.slmbi.vo.InstrumentPanelConfigVo;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set;
/** /**
* slm-bi * slm-bi
...@@ -90,4 +91,12 @@ public interface InstrumentPanelConfigService extends IService<InstrumentPanelCo ...@@ -90,4 +91,12 @@ public interface InstrumentPanelConfigService extends IService<InstrumentPanelCo
* @param panelId * @param panelId
*/ */
Map<String,String> getAssemblyConfig(@NotNull String panelId); Map<String,String> getAssemblyConfig(@NotNull String panelId);
/**
* 根据仪表板id获取对应已发布配置
* @param ids
* @return
*/
Set<String> getConfigByPanelIds(@NotNull Set<String> ids);
} }
...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.toolkit.IdWorker; ...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.toolkit.IdWorker;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import com.google.common.collect.Sets;
import com.syc.slm.common.core.constant.SlmConstants; import com.syc.slm.common.core.constant.SlmConstants;
import com.syc.slm.slmbi.dao.InstrumentPanelConfigMapper; import com.syc.slm.slmbi.dao.InstrumentPanelConfigMapper;
import com.syc.slm.slmbi.dto.InstrumentPanelConfigDTO; import com.syc.slm.slmbi.dto.InstrumentPanelConfigDTO;
...@@ -30,6 +31,7 @@ import java.net.URLEncoder; ...@@ -30,6 +31,7 @@ import java.net.URLEncoder;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
...@@ -361,6 +363,21 @@ public class InstrumentPanelConfigServiceImpl extends ServiceImpl<InstrumentPane ...@@ -361,6 +363,21 @@ public class InstrumentPanelConfigServiceImpl extends ServiceImpl<InstrumentPane
return maps; return maps;
} }
@Override
@Transactional
public Set<String> getConfigByPanelIds(@NotNull Set<String> ids) {
LambdaQueryWrapper<InstrumentPanelConfig> where = new LambdaQueryWrapper<>();
where.eq(BaseEntity::getRecordStatus, SlmConstants.DATA_VALID);
where.in(InstrumentPanelConfig::getPanelId, ids);
where.eq(InstrumentPanelConfig::getPublished, PublishedStatus.WAIT_PUBLISHED.value);
List<InstrumentPanelConfig> configs = baseMapper.selectList(where);
if(CollectionUtils.isNotEmpty(configs)){
return configs.stream().map(InstrumentPanelConfig::getPanelId).collect(Collectors.toSet());
}
return Sets.newHashSet();
}
private InstrumentPanelConfigVo getInstrumentPanelConfigVo(String instrumentPanelId, PublishedStatus published) { private InstrumentPanelConfigVo getInstrumentPanelConfigVo(String instrumentPanelId, PublishedStatus published) {
LambdaQueryWrapper<InstrumentPanelConfig> where = new LambdaQueryWrapper<>(); LambdaQueryWrapper<InstrumentPanelConfig> where = new LambdaQueryWrapper<>();
......
...@@ -99,11 +99,10 @@ public class InstrumentPanelServiceImpl extends ServiceImpl<InstrumentPanelMappe ...@@ -99,11 +99,10 @@ public class InstrumentPanelServiceImpl extends ServiceImpl<InstrumentPanelMappe
.map(BaseEntity::getId) .map(BaseEntity::getId)
.collect(Collectors.toSet()); .collect(Collectors.toSet());
if(CollectionUtils.isNotEmpty(ids)){ if(CollectionUtils.isNotEmpty(ids)){
List<InstrumentPanelDraft> drafts = draftService.getByIds(ids); Set<String> waitIds = configService.getConfigByPanelIds(ids);
if(CollectionUtils.isNotEmpty(drafts)){ if(CollectionUtils.isNotEmpty(waitIds)){
Set<String> draftIds = drafts.stream().map(InstrumentPanelDraft::getPanelId).collect(Collectors.toSet());
response.getRecords().forEach(x->{ response.getRecords().forEach(x->{
if(draftIds.contains(x.getId())){ if(waitIds.contains(x.getId())){
x.setHasWaitPublish("有未发布版本"); x.setHasWaitPublish("有未发布版本");
} }
}); });
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment