接口调整

This commit is contained in:
2023-08-14 21:35:27 +08:00
parent a0e1bb0225
commit 17d1104509
4 changed files with 33 additions and 4 deletions

View File

@@ -19,4 +19,10 @@ public class EpdDTO {
@ApiModelProperty("inflxuDB表名") @ApiModelProperty("inflxuDB表名")
private String tableName; private String tableName;
@ApiModelProperty("起始次数")
private Integer harmStart;
@ApiModelProperty("结束次数")
private Integer harmEnd;
} }

View File

@@ -196,7 +196,7 @@ public class EleEpdPqdController extends BaseController {
@PostMapping("/findAll") @PostMapping("/findAll")
@OperateInfo(info = LogEnum.BUSINESS_COMMON) @OperateInfo(info = LogEnum.BUSINESS_COMMON)
@ApiOperation("查询所有字典数据") @ApiOperation("查询所有字典数据")
@ApiIgnore // @ApiIgnore
public HttpResult<List<EpdDTO>> findAll(){ public HttpResult<List<EpdDTO>> findAll(){
String methodDescribe = getMethodDescribe("findAll"); String methodDescribe = getMethodDescribe("findAll");
List<EpdDTO> list = eleEpdPqdService.findAll(); List<EpdDTO> list = eleEpdPqdService.findAll();

View File

@@ -47,12 +47,14 @@
<select id="findAll" resultType="EpdDTO"> <select id="findAll" resultType="EpdDTO">
select select
t0.Name dictName, t0.Name dictName,
t1.Name tableName t1.Name tableName,
t0.Harm_Start harmStart,
t0.Harm_End harmEnd
from from
ele_epd_pqd t0 ele_epd_pqd t0
left join sys_dict_data t1 on left join sys_dict_data t1 on
t0.Class_Id = t1.Id t0.Class_Id = t1.Id
where t0.status = 1 where t0.status = 1
group by t0.Name,t1.Name group by t0.Name,t1.Name,t0.Harm_Start,t0.Harm_End
</select> </select>
</mapper> </mapper>

View File

@@ -209,7 +209,28 @@ public class EleEpdPqdServiceImpl extends ServiceImpl<EleEpdPqdMapper, EleEpdPqd
@Override @Override
public List<EpdDTO> findAll() { public List<EpdDTO> findAll() {
return this.baseMapper.findAll(); List<EpdDTO> removeList = new ArrayList<>(),addList = new ArrayList<>();
List<EpdDTO> list = this.baseMapper.findAll();
if (CollectionUtil.isNotEmpty(list)){
list.forEach(item->{
if (!Objects.isNull(item.getHarmStart()) && !Objects.isNull(item.getHarmEnd())){
removeList.add(item);
for (int i = item.getHarmStart(); i <= item.getHarmEnd(); i++) {
EpdDTO epdDTO = new EpdDTO();
epdDTO.setDictName(item.getDictName() + "_" + i);
epdDTO.setTableName(item.getTableName());
addList.add(epdDTO);
}
}
});
if (CollectionUtil.isNotEmpty(removeList)){
list.removeAll(removeList);
}
if (CollectionUtil.isNotEmpty(addList)){
list.addAll(addList);
}
}
return list;
} }
/** /**