更改为sql server的方式并且补充缺失的类

tjx

2025-11-10 187f40fe0c37872a982890c89621da3200b8c21b

更改为sql server的方式并且补充缺失的类

 MES_SIMPLE_CREATE_TABLE.sql

@@ -29,7 +29,10 @@
    spread INT NULL,
    
    -- èŠ‚点是否为展示 (0为展示，1为不展示)
    disabled INT NULL
    disabled INT NULL,

    -- è½®æ’­æ—¶é—´
    lbtime INT NULL
);

-- æ·»åŠ è¡¨æ³¨é‡Šï¼ˆSQL Server使用扩展属性）
@@ -122,10 +125,15 @@
    @level2type=N'COLUMN',
    @level2name=N'disabled';

-- åˆ›å»ºå¤–键约束（自关联）
ALTER TABLE dbo.MES_SIMPLE 
ADD CONSTRAINT FK_MES_SIMPLE_FID 
FOREIGN KEY (fid) REFERENCES dbo.MES_SIMPLE(id);
EXEC sys.sp_addextendedproperty
    @name=N'MS_Description',
    @value=N'轮播时间',
    @level0type=N'SCHEMA',
    @level0name=N'dbo',
    @level1type=N'TABLE',
    @level1name=N'MES_SIMPLE',
    @level2type=N'COLUMN',
    @level2name=N'lbtime';

-- åˆ›å»ºç´¢å¼•æé«˜æŸ¥è¯¢æ€§èƒ½
CREATE INDEX IX_MES_SIMPLE_FID ON dbo.MES_SIMPLE(fid);
@@ -133,13 +141,13 @@
CREATE INDEX IX_MES_SIMPLE_DISABLED ON dbo.MES_SIMPLE(disabled);

-- æ’入示例数据
INSERT INTO dbo.MES_SIMPLE (is_top, fid, title, field, href, spread, disabled) VALUES
(0, NULL, '系统管理', 'system', '#', 1, 0),
(1, 1, '菜单管理', 'menu', '/menu/list', 0, 0),
(1, 1, '用户管理', 'user', '/user/list', 0, 0),
(0, NULL, '数据管理', 'data', '#', 0, 0),
(1, 4, '数据导入', 'import', '/data/import', 0, 0),
(1, 4, '数据导出', 'export', '/data/export', 0, 0);
INSERT INTO dbo.MES_SIMPLE (is_top, fid, title, field, href, spread, disabled, lbtime) VALUES
(0, NULL, '系统管理', 'system', '#', 1, 0, NULL),
(1, 1, '菜单管理', 'menu', '/menu/list', 0, 0, NULL),
(1, 1, '用户管理', 'user', '/user/list', 0, 0, NULL),
(0, NULL, '数据管理', 'data', '#', 0, 0, NULL),
(1, 4, '数据导入', 'import', '/data/import', 0, 0, NULL),
(1, 4, '数据导出', 'export', '/data/export', 0, 0, NULL);

-- æŸ¥çœ‹åˆ›å»ºç»“æžœ
SELECT 
@@ -150,6 +158,7 @@
    field,
    href,
    spread,
    disabled
    disabled,
    lbtime
FROM dbo.MES_SIMPLE
ORDER BY id;

 src/main/java/com/gs/simple/controller/SimpleController.java

@@ -1,15 +1,12 @@
package com.gs.simple.controller;


import com.gs.simple.common.ResultDto;
import com.gs.simple.domain.BiView;
import com.gs.simple.domain.MesSimplesimple;
import com.gs.simple.domain.TreeView;
import com.gs.simple.service.MesSimpleService;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@@ -21,15 +18,18 @@

    private final MesSimpleService simpleService;


    @PostMapping("/getTree")
    public ResultDto<List<TreeView>> getTree() {
        return simpleService.getTree();
    }


    @PostMapping("list")
    @PostMapping("/list")
    public ResultDto<List<MesSimplesimple>> getList() {
        return simpleService.getMenuList();
    }

    @GetMapping("/listByMenuId/{menuId}")
    public ResultDto<List<BiView>> getBiViews(@PathVariable Integer menuId) {
        return simpleService.getBiViewsByMenuId(menuId);
    }
}

 src/main/java/com/gs/simple/domain/MesSimplesimple.java

@@ -9,6 +9,7 @@

import java.io.Serial;
import java.io.Serializable;
import java.util.List;

/**
 * èœå•ç»´æŠ¤è¡¨
@@ -56,4 +57,11 @@
     * èŠ‚点是否为展示 0为展示，1为不展示
     */
    private Integer disabled;

    /*
    * è½®æ’­æ—¶é—´
    * */
    private Integer lbtime;


}

 src/main/java/com/gs/simple/mapper/BiViewMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,20 @@
package com.gs.simple.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.gs.simple.domain.BiView;
import com.gs.simple.domain.MesSimplesimple;

import java.util.List;

/**
 * @author 28567
 * @description é’ˆå¯¹è¡¨ã€MES_SIMPLE(菜单维护表)】的数据库操作Mapper
 * @createDate 2023-11-08 14:19:52
 * @Entity com.gs.simple.domain.MesSimplesimple
 */
public interface BiViewMapper extends BaseMapper<BiView> {
}





 src/main/java/com/gs/simple/service/BiViewService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,29 @@
package com.gs.simple.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.gs.simple.common.ResultDto;
import com.gs.simple.domain.BiView;

import java.util.List;

/**
 * @author 28567
 * @description é’ˆå¯¹è¡¨ã€MES_SIMPLE_CCB(BiView表)】的数据库操作Service
 * @createDate 2023-11-08 14:19:52
 */
public interface BiViewService extends IService<BiView> {

    /**
     * æ ¹æ®çˆ¶èŠ‚点ID获取BiView列表
     * @param pid çˆ¶èŠ‚点ID
     * @return BiView列表
     */
    ResultDto<List<BiView>> getListByPid(Integer pid);

    /**
     * æ ¹æ®çˆ¶èŠ‚点ID获取有href的BiView列表
     * @param pid çˆ¶èŠ‚点ID
     * @return BiView列表
     */
    ResultDto<List<BiView>> getListByPidWithHref(Integer pid);
}

 src/main/java/com/gs/simple/service/MesSimpleService.java

@@ -2,22 +2,16 @@

import com.baomidou.mybatisplus.extension.service.IService;
import com.gs.simple.common.ResultDto;
import com.gs.simple.domain.BiView;
import com.gs.simple.domain.MesSimplesimple;
import com.gs.simple.domain.TreeView;

import java.util.List;

/**
 * @author 28567
 * @description é’ˆå¯¹è¡¨ã€MES_SIMPLE(菜单维护表)】的数据库操作Service
 * @createDate 2023-11-08 14:19:52
 */
public interface MesSimpleService extends IService<MesSimplesimple> {


    ResultDto<List<TreeView>> getTree();

    List<TreeView> toTree();

    ResultDto<List<MesSimplesimple>> getMenuList();

    ResultDto<List<BiView>> getBiViewsByMenuId(Integer menuId);
}

 src/main/java/com/gs/simple/service/impl/BiViewServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,41 @@
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.BiView;
import com.gs.simple.mapper.BiViewMapper;
import com.gs.simple.service.BiViewService;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * @author 28567
 * @description é’ˆå¯¹è¡¨ã€MES_SIMPLE_CCB(BiView表)】的数据库操作Service实现
 * @createDate 2023-11-08 14:19:52
 */
@Service
@Transactional(rollbackFor = Exception.class)
@RequiredArgsConstructor
public class BiViewServiceImpl extends ServiceImpl<BiViewMapper, BiView> implements BiViewService {

    @Override
    public ResultDto<List<BiView>> getListByPid(Integer pid) {
        LambdaQueryWrapper<BiView> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(BiView::getPid, pid);
        List<BiView> list = list(wrapper);
        return ResultDto.ok(list, list.size());
    }

    @Override
    public ResultDto<List<BiView>> getListByPidWithHref(Integer pid) {
        LambdaQueryWrapper<BiView> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(BiView::getPid, pid)
                .isNotNull(BiView::getHref);
        List<BiView> list = list(wrapper);
        return ResultDto.ok(list, list.size());
    }
}

 src/main/java/com/gs/simple/service/impl/MesSimpleServiceImpl.java

@@ -3,14 +3,14 @@
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.Children;
import com.gs.simple.domain.MesSimplesimple;
import com.gs.simple.domain.TreeView;
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;
@@ -19,20 +19,12 @@
import java.util.concurrent.Executors;
import java.util.stream.Collectors;

/**
 * @author 28567
 * @description é’ˆå¯¹è¡¨ã€MES_SIMPLE(菜单维护表)】的数据库操作Service实现
 * @createDate 2023-11-08 14:19:52
 */
@Service
@Transactional(rollbackFor = Exception.class)
@RequiredArgsConstructor
public class MesSimpleServiceImpl extends ServiceImpl<MesSimpleMapper, MesSimplesimple> implements MesSimpleService {


    // åˆ›å»ºä¸€ä¸ªåŒ…含10个线程的线程池，用于数据库操作
    private final BiViewMapper biViewMapper;
    private final Executor dbExecutor = Executors.newFixedThreadPool(10);

    @Override
    public ResultDto<List<TreeView>> getTree() {
        List<TreeView> tree = toTree();
@@ -44,42 +36,67 @@
        return convertToTreeViewList(getTopList());
    }

    //GetTree树形
    @Override
    public ResultDto<List<MesSimplesimple>> getMenuList() {
    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());
    }

    /**
     * <p>
     * èŽ·å–根节点
     * </p>
     *
     * @return java.util.List<com.gs.simple.domain.MesSimplesimple>
     * @author tjx
     * @date 2023/11/8 14:39
     */
    //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);
    }

    // å°†MesSimplesimple列表转换为TreeView列表
    private List<TreeView> convertToTreeViewList(List<MesSimplesimple> mesSimplesimpleList) {
        // ä½¿ç”¨CompletableFuture异步处理每个MesSimplesimple对象，并收集为一个CompletableFuture列表
        List<CompletableFuture<TreeView>> treeViewFutures = mesSimplesimpleList.stream().map(mesSimplesimple -> convertToTreeViewAsync(mesSimplesimple, dbExecutor)).toList();
        List<CompletableFuture<TreeView>> treeViewFutures = mesSimplesimpleList.stream()
                .map(mesSimplesimple -> convertToTreeViewAsync(mesSimplesimple, dbExecutor))
                .toList();

        // åˆ›å»ºä¸€ä¸ªCompletableFuture，等待所有异步任务完成
        CompletableFuture<Void> allFutures = CompletableFuture.allOf(treeViewFutures.toArray(new CompletableFuture[0]));

        // åœ¨æ‰€æœ‰å¼‚步任务完成后，将结果收集为一个TreeView列表
        return allFutures.thenApply(v -> treeViewFutures.stream().map(CompletableFuture::join).collect(Collectors.toList())).join();
        return allFutures.thenApply(v -> treeViewFutures.stream()
                        .map(CompletableFuture::join)
                        .collect(Collectors.toList()))
                .join();
    }

    // å°†MesSimplesimple对象转换为TreeView对象，并使用自定义线程池执行异步任务
    private CompletableFuture<TreeView> convertToTreeViewAsync(MesSimplesimple mesSimplesimple, Executor executor) {
        return CompletableFuture.supplyAsync(() -> convertToTreeView(mesSimplesimple), executor);
    }
@@ -91,7 +108,6 @@
        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);
@@ -102,7 +118,11 @@
            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);
@@ -110,7 +130,3 @@
        return treeView;
    }
}





 src/main/resources/application.yml

@@ -62,9 +62,9 @@
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    # æ˜¯å¦å¼€å¯è‡ªåŠ¨é©¼å³°å‘½åè§„则映射:从数据库列名到Java属性驼峰命名的类似映射
    map-underscore-to-camel-case: true
    # è§£å†³SQL Server更新数据为null时无法转换报错
    # è§£å†³oracle更新数据为null时无法转换报错，mysql不会出现此情况
    jdbc-type-for-null: 'null'
  #实体类所在包
  type-aliases-package: com.gs.simple.domain.*
  type-aliases-package: com.gs.mes.entity.*
  # xml扫描，多个目录用逗号或者分号分隔（告诉 Mapper æ‰€å¯¹åº”çš„ XML æ–‡ä»¶ä½ç½®ï¼‰
  mapper-locations: classpath:mapper/*.xml

 src/main/resources/mapper/BiViewMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.gs.simple.mapper.BiViewMapper">



</mapper>