管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-02-09 5844344ae1650cf6212ce89cce49b1ceed9cf0cd
1
已修改5个文件
62 ■■■■■ 文件已修改
data/ts.sql 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/all/SignController.java 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/show/DataLibController.java 24 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/show/DataLibService.java 21 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/templates/login.html 4 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/ts.sql
@@ -107,6 +107,7 @@
select * from lf.sys_user where id in (47,48,49);
select * from lf.sys_download;
----------------------------------------------------------------------- 
-- alter sequence lf.sys_dict_id_seq restart with 11118;
select * from bs.m_marker where parentid is not null; -- delete from bs.m_marker; createtime
select * from bs.m_hydraulic_protection;
@@ -126,8 +127,6 @@
select * from lf.sys_menu where position('http:' in url)>0;
select * from bd.b_hydrogeology_attach limit 1;
select * from bd.b_pac_hydrogeology limit 1;
src/main/java/com/lf/server/controller/all/SignController.java
@@ -138,11 +138,6 @@
                return fail("密码不正确", null);
            }
            int onlineUser = scheduleService.countOnlineUsers();
            if (onlineUser >= SettingData.MAX_USER_LOGIN) {
                return fail("达到用户访问量上限,拒绝登录", null);
            }
            LoginEntity le = loginService.getNewLogin(ue.getId(), 1, 1, 1, req);
            Integer rows = loginService.insertLogin(le);
            if (rows == 0) {
@@ -157,7 +152,10 @@
            tokenService.saveToken(ue, te, req, res);
            return success(te);
            int onlineUser = scheduleService.countOnlineUsers();
            String msg = onlineUser >= SettingData.MAX_USER_LOGIN ? "警告:系统已经到达用户访问量的上限!" : "";
            return success(msg, te);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
src/main/java/com/lf/server/controller/show/DataLibController.java
@@ -308,26 +308,28 @@
    @ApiImplicitParams({
            @ApiImplicitParam(name = "name", value = "映射名称", dataType = "String", paramType = "query", example = "dlgagnp"),
            @ApiImplicitParam(name = "filter", value = "过滤条件", dataType = "String", paramType = "query", example = "gid >= 50 and name like '县' and objectid < 5000.0"),
            @ApiImplicitParam(name = "wkt", value = "WKT(著名文本)", dataType = "String", paramType = "query", example = "")
            @ApiImplicitParam(name = "pwd", value = "密码", dataType = "String", paramType = "query", example = "")
    })
    @GetMapping(value = "/downloadEntityReq")
    public ResponseMsg<Object> downloadEntityReq(String name, String filter, String wkt, HttpServletRequest req, HttpServletResponse res) {
    public ResponseMsg<Object> downloadEntityReq(String name, String filter, String pwd, HttpServletRequest req, HttpServletResponse res) {
        try {
            if (StringHelper.isEmpty(pwd)) {
                return fail("密码不能为空");
            }
            pwd = RsaHelper.decrypt(pwd);
            if (StringHelper.isPwdInvalid(pwd)) {
                return fail("密码不符合要求");
            }
            BasicMapper baseMapper = ClassHelper.getBasicMapper(name);
            if (baseMapper == null) {
                return fail("查询对象不存在", null);
            }
            QueryWrapper wrapper = new QueryWrapper();
            baseQueryService.addFilterWrapper(wrapper, filter);
            baseQueryService.addGeomWrapper(baseMapper, wrapper, wkt);
            UserEntity ue = tokenService.getCurrentUser(req);
            String guid = dataLibService.zipDbData(ue, baseMapper, filter, pwd);
            List<?> list = baseMapper.selectList(wrapper);
            if (null == list || list.size() == 0) {
                return fail("查询无数据", null);
            }
            return success(null);
            return success(guid);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
src/main/java/com/lf/server/service/show/DataLibService.java
@@ -4,6 +4,7 @@
import com.lf.server.entity.data.DownloadEntity;
import com.lf.server.entity.sys.UserEntity;
import com.lf.server.helper.*;
import com.lf.server.mapper.all.BasicMapper;
import com.lf.server.mapper.all.GeomBaseMapper;
import com.lf.server.mapper.data.DownloadMapper;
import com.lf.server.service.all.BaseQueryService;
@@ -202,4 +203,24 @@
        return de;
    }
    /**
     * 打包DB数据
     */
    public String zipDbData(UserEntity ue, BasicMapper baseMapper, String filter, String pwd) {
        boolean flag = baseMapper instanceof GeomBaseMapper;
        QueryWrapper wrapper = new QueryWrapper();
        baseQueryService.addFilterWrapper(wrapper, filter);
        if (flag) {
            wrapper.select("ST_AsText(geom) as geom, *");
        }
        List<?> list = baseMapper.selectList(wrapper);
        if (null == list || 0 == list.size()) {
            return null;
        }
        return null;
    }
}
src/main/resources/templates/login.html
@@ -294,13 +294,15 @@
        success: function (rs) {
          isBusy = false;
          if (!rs || rs.code != 200) {
          if (!rs || rs.code !== 200) {
            createCode();
            var msg = rs && rs.msg ? rs.msg : "登录失败!";
            $("#eMsg").html(msg);
            return;
          }
          if (rs.msg) alert(rs.msg);
          var service = getQueryStr("service");
          if (service) {
            service += (service.indexOf("?") > -1 ? "&" : "?") + "token=" + rs.result.token;