package com.gs.simple.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gs.simple.common.ResultDto;
|
import com.gs.simple.domain.*;
|
import com.gs.simple.mapper.BiViewMapper;
|
import com.gs.simple.mapper.MesSimpleMapper;
|
import com.gs.simple.service.MesSimpleService;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import com.gs.simple.domain.BiView;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.concurrent.CompletableFuture;
|
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executors;
|
import java.util.stream.Collectors;
|
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
@RequiredArgsConstructor
|
public class MesSimpleServiceImpl extends ServiceImpl<MesSimpleMapper, MesSimplesimple> implements MesSimpleService {
|
private final BiViewMapper biViewMapper;
|
private final Executor dbExecutor = Executors.newFixedThreadPool(10);
|
@Override
|
public ResultDto<List<TreeView>> getTree() {
|
List<TreeView> tree = toTree();
|
return ResultDto.ok(tree, tree.size());
|
}
|
|
@Override
|
public List<TreeView> toTree() {
|
return convertToTreeViewList(getTopList());
|
}
|
|
//GetTree树形
|
@Override
|
public ResultDto getMenuList() {
|
LambdaQueryWrapper<MesSimplesimple> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(MesSimplesimple::getDisabled, 0).gt(MesSimplesimple::getIsTop, 0);
|
List<MesSimplesimple> list = list(wrapper);
|
return ResultDto.ok(list, list.size());
|
}
|
|
//List列表
|
// @Override
|
// public ResultDto<List<MesSimplesimple>> getMenuList() {
|
// LambdaQueryWrapper<MesSimplesimple> wrapper = new LambdaQueryWrapper<>();
|
// wrapper.eq(MesSimplesimple::getDisabled, 0)
|
// .gt(MesSimplesimple::getIsTop, 0)
|
// .orderByAsc(MesSimplesimple::getIsTop);
|
//
|
// List<MesSimplesimple> list = list(wrapper);
|
//
|
//
|
// return ResultDto.ok(list, list.size());
|
// }
|
|
|
@Override
|
public ResultDto<List<BiView>> getBiViewsByMenuId(Integer menuId) {
|
|
LambdaQueryWrapper<BiView> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(BiView::getPid, menuId)
|
.isNotNull(BiView::getHref);
|
List<BiView> list = biViewMapper.selectList(wrapper);
|
|
if (!list.isEmpty()) {
|
LambdaQueryWrapper<MesSimplesimple> simpleWrapper = new LambdaQueryWrapper<>();
|
simpleWrapper.eq(MesSimplesimple::getId, menuId);
|
MesSimplesimple simple = getOne(simpleWrapper);
|
if (simple != null) {
|
list.forEach(biView -> biView.setLbtime(simple.getLbtime()));
|
}
|
}
|
return ResultDto.ok(list, list.size());
|
}
|
|
private List<MesSimplesimple> getTopList() {
|
LambdaQueryWrapper<MesSimplesimple> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(MesSimplesimple::getIsTop, 0).eq(MesSimplesimple::getDisabled, 0);
|
return list(queryWrapper);
|
}
|
|
private List<TreeView> convertToTreeViewList(List<MesSimplesimple> mesSimplesimpleList) {
|
List<CompletableFuture<TreeView>> treeViewFutures = mesSimplesimpleList.stream()
|
.map(mesSimplesimple -> convertToTreeViewAsync(mesSimplesimple, dbExecutor))
|
.toList();
|
|
CompletableFuture<Void> allFutures = CompletableFuture.allOf(treeViewFutures.toArray(new CompletableFuture[0]));
|
return allFutures.thenApply(v -> treeViewFutures.stream()
|
.map(CompletableFuture::join)
|
.collect(Collectors.toList()))
|
.join();
|
}
|
|
private CompletableFuture<TreeView> convertToTreeViewAsync(MesSimplesimple mesSimplesimple, Executor executor) {
|
return CompletableFuture.supplyAsync(() -> convertToTreeView(mesSimplesimple), executor);
|
}
|
|
private TreeView convertToTreeView(MesSimplesimple mesSimplesimple) {
|
TreeView treeView = new TreeView();
|
treeView.setId(mesSimplesimple.getId());
|
treeView.setTitle(mesSimplesimple.getTitle());
|
treeView.setField(mesSimplesimple.getField());
|
treeView.setSpread(mesSimplesimple.getSpread() == 1);
|
|
LambdaQueryWrapper<MesSimplesimple> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(MesSimplesimple::getDisabled, 0).eq(MesSimplesimple::getFid, mesSimplesimple.getId());
|
List<MesSimplesimple> list = list(wrapper);
|
|
List<Children> childrenList = new ArrayList<>();
|
list.forEach(s -> {
|
Children children = new Children();
|
children.setId(s.getId());
|
children.setTitle(s.getTitle());
|
children.setField(s.getField());
|
if ("轮播".equals(s.getHref())) {
|
children.setHref("bi_view.html?menuId=" + s.getId() + "&lbsj=" + s.getLbtime()); // 跳转到中间页面
|
} else {
|
children.setHref(s.getHref());
|
}
|
childrenList.add(children);
|
});
|
treeView.setChildren(childrenList);
|
|
return treeView;
|
}
|
}
|
