管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2022-11-19 2bfc1f7d89030434546832de57b31fec6943702e
1
已修改8个文件
125 ■■■■■ 文件已修改
data/db_fn.sql 11 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/db_tab.sql 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/data/DataUploadController.java 67 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/sys/DepController.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/mapper/data/DirMapper.java 9 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/mapper/data/VerMapper.java 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/VerService.java 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/data/VerMapper.xml 13 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/db_fn.sql
@@ -290,6 +290,17 @@
select distinct ns,tab,fn_get_entity(tab) entity,tab_desc,tabletype from lf.sys_dict order by tab;
select Distinct  ns,tab,tab_desc from lf.sys_dict
select * from lf.sys_meta;
select * from lf.sys_meta_file;
delete from lf.sys_meta;
delete from lf.sys_meta_file;
select * from lf.sys_ver order by id;
data/db_tab.sql
@@ -82,8 +82,9 @@
comment on column lf.sys_dep.update_user is '更新人ID';
comment on column lf.sys_dep.update_time is '更新时间';
comment on column lf.sys_dep.bak is '备注';
--alter sequence lf.sys_dep_id_seq restart with 45;
--alter table lf.sys_dep rename short to sname; alter table lf.sys_dep alter column bak type varchar(1024);
-- alter sequence lf.sys_dep_id_seq restart with 45;
-- alter table lf.sys_dep rename short to sname; alter table lf.sys_dep alter column bak type varchar(1024);
-- update lf.sys_dep set name='中国xxx工程有限公司' where name='中国石油天然气管道工程有限公司';
select * from lf.sys_dep order by id;
----------------------------------------------------------------------------------------------------- 3.目录表
@@ -668,9 +669,10 @@
comment on column lf.sys_ver.create_time is '创建时间';
comment on column lf.sys_ver.update_user is '更新人ID';
comment on column lf.sys_ver.update_time is '更新时间';
insert into lf.sys_ver (id,dirid,name) values (0,0,'默认');
--insert into lf.sys_ver (dirid,name) values (1003,'2020-02-01');
select * from lf.sys_ver;
select * from lf.sys_ver order by id;
----------------------------------------------------------------------------------------------------- 20.数据字典表
-- DROP TABLE IF EXISTS lf.sys_dict;
create table lf.sys_dict(
src/main/java/com/lf/server/controller/data/DataUploadController.java
@@ -4,12 +4,18 @@
import com.lf.server.controller.all.BaseController;
import com.lf.server.entity.all.ResponseMsg;
import com.lf.server.entity.ctrl.UploadEntity;
import com.lf.server.entity.data.DirEntity;
import com.lf.server.entity.data.MetaEntity;
import com.lf.server.entity.data.MetaFileEntity;
import com.lf.server.entity.data.VerEntity;
import com.lf.server.entity.sys.DepEntity;
import com.lf.server.entity.sys.UserEntity;
import com.lf.server.helper.StringHelper;
import com.lf.server.helper.WebHelper;
import com.lf.server.service.data.DataUploadService;
import com.lf.server.service.data.DirService;
import com.lf.server.service.data.VerService;
import com.lf.server.service.sys.DepService;
import com.lf.server.service.sys.TokenService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
@@ -20,6 +26,7 @@
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -32,13 +39,71 @@
@RequestMapping("/dataUpload")
public class DataUploadController extends BaseController {
    @Autowired
    DepService depService;
    @Autowired
    DirService dirService;
    @Autowired
    VerService verService;
    @Autowired
    TokenService tokenService;
    @Autowired
    DataUploadService dataUploadService;
    @SysLog()
    @ApiOperation(value = "查询目录")
    @ApiOperation(value = "查询所有单位")
    @GetMapping(value = "/selectDepAll")
    public ResponseMsg<List<DepEntity>> selectDepAll() {
        try {
            List<DepEntity> list = depService.selectDepAll();
            return success(list);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }
    @SysLog()
    @ApiOperation(value = "查询所有目录")
    @GetMapping(value = "/selectDirAll")
    public ResponseMsg<List<DirEntity>> selectDirAll() {
        try {
            List<DirEntity> list = dirService.selectDirAll();
            return success(list);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }
    @SysLog()
    @ApiOperation(value = "根据目录ID查询版本列表")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "dirid", value = "目录ID", dataType = "Integer", paramType = "query")
    })
    @GetMapping(value = "/selectVerByDirid")
    public ResponseMsg<List<VerEntity>> selectVerByDirid(Integer dirid) {
        try {
            if (null == dirid || dirid < 0) {
                dirid = 0;
            }
            List<VerEntity> list = verService.selectByDirid(dirid);
            if (null == list || list.isEmpty()) {
                list = verService.selectByDirid(0);
            }
            return success(list);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }
    @SysLog()
    @ApiOperation(value = "查询路径")
    @GetMapping(value = "/selectPath")
    public ResponseMsg<String> selectPath() {
        try {
src/main/java/com/lf/server/controller/sys/DepController.java
@@ -189,13 +189,13 @@
    @SysLog()
    @ApiOperation(value = "递归查询")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "name", value = "单位名称", dataType = "String", paramType = "query", required = false, example = "中国石油天然气管道工程有限公司")
            @ApiImplicitParam(name = "name", value = "单位名称", dataType = "String", paramType = "query", required = false, example = "中国xxx工程有限公司")
    })
    @GetMapping(value = "/selectDepRecursive")
    public ResponseMsg<List<DepEntity>> selectDepRecursive(String name) {
        try {
            if (StringHelper.isEmpty(name)) {
                name = "中国石油天然气管道工程有限公司";
                name = "中国xxx工程有限公司";
            }
            List<DepEntity> list = depService.selectDepRecursive(name);
src/main/java/com/lf/server/mapper/data/DirMapper.java
@@ -17,6 +17,7 @@
public interface DirMapper {
    /**
     * 插入一条
     *
     * @param dirEntity
     * @return
     */
@@ -24,6 +25,7 @@
    /**
     * 插入多条
     *
     * @param list
     * @return
     */
@@ -31,6 +33,7 @@
    /**
     * 删除一条
     *
     * @param id
     * @return
     */
@@ -38,6 +41,7 @@
    /**
     * 删除多条
     *
     * @param ids
     * @return
     */
@@ -45,6 +49,7 @@
    /**
     * 更新一条
     *
     * @param dirEntity
     * @return
     */
@@ -52,6 +57,7 @@
    /**
     * 更新多条
     *
     * @param list
     * @return
     */
@@ -59,6 +65,7 @@
    /**
     * 查询单条数据
     *
     * @param id
     * @return
     */
@@ -66,12 +73,14 @@
    /**
     * 查询多条数据
     *
     * @return
     */
    public List<DirEntity> selectDirAll();
    /**
     * 递归查询
     *
     * @param name
     * @return
     */
src/main/java/com/lf/server/mapper/data/VerMapper.java
@@ -35,6 +35,14 @@
    public List<VerEntity> selectByPage(String name, String depName, Integer limit, Integer offset);
    /**
     * 根据目录ID查询版本列表
     *
     * @param dirid
     * @return
     */
    public List<VerEntity> selectByDirid(Integer dirid);
    /**
     * 插入一条
     *
     * @param verEntity
src/main/java/com/lf/server/service/data/VerService.java
@@ -28,6 +28,11 @@
    }
    @Override
    public List<VerEntity> selectByDirid(Integer dirid) {
        return verMapper.selectByDirid(dirid);
    }
    @Override
    public Integer insertVersion(VerEntity verEntity) {
        return verMapper.insertVersion(verEntity);
    }
src/main/resources/mapper/data/VerMapper.xml
@@ -37,7 +37,6 @@
        limit #{limit} offset #{offset}
    </select>
    <select id="selectVersionAll" resultType="com.lf.server.entity.data.VerEntity">
        select * from lf.sys_ver order by id;
    </select>
@@ -46,14 +45,18 @@
        select * from lf.sys_ver where id = #{id}
    </select>
    <insert id="insertVersion"   parameterType="com.lf.server.entity.data.VerEntity">
    <select id="selectByDirid" resultType="com.lf.server.entity.data.VerEntity">
        select * from lf.sys_ver where dirid = #{dirid}
    </select>
    <insert id="insertVersion" parameterType="com.lf.server.entity.data.VerEntity">
       insert into lf.sys_ver
       (dirid,name,descr,create_user,create_time)
       values
       (#{dirid},#{name},#{descr},#{createUser},now());
    </insert>
    <insert id="insertVersions"   >
    <insert id="insertVersions">
       insert into lf.sys_ver
        (dirid,name,descr,create_user,create_time)
       values
@@ -62,11 +65,11 @@
        </foreach>
    </insert>
    <delete id="deleteVersion"  >
    <delete id="deleteVersion">
        delete from lf.sys_ver where id = #{id}
    </delete>
    <delete id="deleteVersions"  >
    <delete id="deleteVersions">
        delete from lf.sys_ver where id in
        <foreach item="id" collection="ids" index="index" open="(" separator="," close=")">
            #{id}