管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-01-09 97dfbeaea4939c669c9fddacf2c9b090a8989d21
1
已修改4个文件
42 ■■■■ 文件已修改
src/main/java/com/lf/server/controller/data/upload/CheckController.java 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/data/upload/UploadController.java 15 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/ctrl/TabMapperEntity.java 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/all/BaseUploadService.java 16 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/data/upload/CheckController.java
@@ -14,6 +14,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseBody;
import javax.servlet.http.HttpServletRequest;
@@ -76,7 +77,7 @@
    })
    @ResponseBody
    @PostMapping(value = "/uploadChecks")
    public ResponseMsg<Object> uploadChecks(FmeReqEntity entity, HttpServletRequest req) {
    public ResponseMsg<Object> uploadChecks(@RequestBody FmeReqEntity entity, HttpServletRequest req) {
        try {
            if (StringHelper.isEmpty(entity.names)) {
                return fail("任务名称不能为空");
src/main/java/com/lf/server/controller/data/upload/UploadController.java
@@ -5,6 +5,7 @@
import com.lf.server.entity.all.StaticData;
import com.lf.server.entity.data.DirEntity;
import com.lf.server.entity.data.MetaFileEntity;
import com.lf.server.entity.data.VerEntity;
import com.lf.server.entity.sys.UserEntity;
import com.lf.server.helper.StringHelper;
import com.lf.server.service.data.UploadService;
@@ -109,13 +110,14 @@
    @ApiImplicitParams({
            @ApiImplicitParam(name = "path", value = "路径", dataType = "String", paramType = "query", example = "20230109010101"),
            @ApiImplicitParam(name = "dirid", value = "目录ID", dataType = "Integer", paramType = "query", example = "1"),
            @ApiImplicitParam(name = "verid", value = "版本ID", dataType = "Integer", paramType = "query", example = "0"),
            @ApiImplicitParam(name = "epsgCode", value = "坐标编码", dataType = "String", paramType = "query", example = "EPSG:4490")
    })
    @GetMapping(value = "/selectMappers")
    public ResponseMsg<Object> selectMappers(String path, Integer dirid, String epsgCode) {
    public ResponseMsg<Object> selectMappers(String path, Integer dirid, Integer verid, String epsgCode, HttpServletRequest req) {
        try {
            if (StringHelper.isEmpty(path) || StringHelper.isEmpty(epsgCode) || null == dirid) {
                return fail("路径、目录ID和坐标编码不能为空");
            if (StringHelper.isEmpty(path) || StringHelper.isEmpty(epsgCode) || null == dirid || null == verid) {
                return fail("路径、目录ID、版本ID和坐标编码不能为空");
            }
            if (1 > uploadService.selectCount4Coord(epsgCode)) {
                return fail("坐标编码" + epsgCode + "不存在");
@@ -124,13 +126,18 @@
            if (null == dir) {
                return fail("目录ID=" + dirid + "不存在");
            }
            VerEntity ver = verService.selectVersion(verid);
            if (null == ver) {
                return fail("版本ID=" + verid + "不存在");
            }
            List<MetaFileEntity> metas = uploadService.selectFiles(path, StaticData.ALL_EXTENSION);
            if (null == metas || metas.isEmpty()) {
                return fail("目录" + path + "下查无文件");
            }
            List<MetaFileEntity> list = uploadService.selectMappers(metas, dir, epsgCode);
            UserEntity ue = tokenService.getCurrentUser(req);
            List<MetaFileEntity> list = uploadService.selectMappers(ue, metas, dir, ver, epsgCode);
            return success(list);
        } catch (Exception ex) {
src/main/java/com/lf/server/entity/ctrl/TabMapperEntity.java
@@ -15,6 +15,14 @@
        this.subPath = subPath;
    }
    private String eventid;
    private int dirid;
    private int depid;
    private int verid;
    private String fileName;
    private String extName;
src/main/java/com/lf/server/service/all/BaseUploadService.java
@@ -1,7 +1,10 @@
package com.lf.server.service.all;
import com.lf.server.entity.all.StaticData;
import com.lf.server.entity.data.DirEntity;
import com.lf.server.entity.data.MetaFileEntity;
import com.lf.server.entity.data.VerEntity;
import com.lf.server.entity.sys.UserEntity;
import com.lf.server.helper.*;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -190,10 +193,19 @@
    /**
     * 查询映射
     */
    public List<MetaFileEntity> selectMappers(List<MetaFileEntity> metas, DirEntity dir, String epsgCode) {
    public List<MetaFileEntity> selectMappers(UserEntity ue, List<MetaFileEntity> metas, DirEntity dir, VerEntity ver, String epsgCode) {
        List<MetaFileEntity> list = new ArrayList<>();
        for (MetaFileEntity meta : metas) {
            //
            meta.setEventid(StringHelper.getGuid());
            meta.setDirid(dir.getId());
            meta.setDepid(ue.getDepid());
            meta.setVerid(ver.getId());
            meta.setCreateUser(ue.getId());
            meta.setEpsgCode(epsgCode);
            if (StaticData.ZIP.equals(meta.getExtName())) {
                //
            }
        }
        return list;