管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-01-20 70031587ce6b3f99bb20e49ca9c0b4761860cbde
1
已添加3个文件
已修改5个文件
269 ■■■■■ 文件已修改
data/db_tab.sql 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/日报.txt 42 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/all/FloatServerController.java 29 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/all/StaticData.java 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/ctrl/SdkDecryptDataEntity.java 82 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/ctrl/SdkDecryptEntity.java 48 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/ctrl/SdkSecretEntity.java 43 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/application.yml 14 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/db_tab.sql
@@ -1072,7 +1072,8 @@
  pg_ns varchar(10),
  tcmc varchar(150),
  tcdm varchar(50),
  count integer default 0
  count integer default 0,
  create_time timestamp(6) without time zone default now()
);
comment on table lf.sys_fme_log is 'FME日志表';
comment on column lf.sys_fme_log.id is '主键ID';
@@ -1082,8 +1083,9 @@
comment on column lf.sys_fme_log.tcmc is '图层名称';
comment on column lf.sys_fme_log.tcdm is '表名';
comment on column lf.sys_fme_log.count is '行数';
comment on column lf.sys_fme_log.create_time is '创建时间';
select * from lf.sys_fme_log;
select * from lf.sys_fme_log; -- delete from lf.sys_fme_log;
----------------------------------------------------------------------------------------------------- å…ƒæ•°æ®æµ‹è¯•表 *
-- drop table if exists md.md_zxcg;
create table md.md_zxcg(
data/ÈÕ±¨.txt
@@ -411,4 +411,46 @@
3.系统发布:
在公网环境下部署系统
部署SG的打包、下载环境
=========================================2023-01-17
本周:
1 Web开发:
1)综合展示:
1.8 è§£å†³ç®¡é“分析的下载功能异常
1.9 ä¿®æ”¹åœ¨çº¿å‡ºå›¾åŠŸèƒ½
2)数据管理
1.10 ç»Ÿä¸€æ•°æ®è´¨æ£€æŽ¥å£è°ƒç”¨é€»è¾‘
1.11 è§£å†³è´¨æ£€æŠ¥å‘Šä¸‹è½½å‡ºé”™
1.12 è§£å†³æ•°æ®æ£€ç´¢éƒ¨åˆ†é¡µé¢è¿è¡ŒæŠ¥é”™
1.13 ä¿®æ”¹å…ƒæ•°æ®ç®¡ç†é¡µé¢
2 æœåŠ¡å¼€å‘ï¼š
2.1 ä¿®æ”¹æ•°æ®å¯¼å‡ºGDB库的接口
2.2 ä¿®æ”¹æ•°æ®å…¥åº“的业务逻辑
2.3 ä¸ŽFME对接Excel数据入库功能
2.4 å¼€å‘Excel数据同步的触发器
2.5 å°†ä¸šåŠ¡æŽ§åˆ¶å­—æ®µä¿¡æ¯å†™å…¥FME接口
2.6 ä¿®æ”¹æ•°æ®è´¨æ£€æŽ¥å£çš„调用
2.7 ç»Ÿä¸€ä¿®æ”¹FME调用的接口规范
2.8 ä¿®æ”¹GDAL初始化时的环境变量设定
3 ç³»ç»Ÿå‘布:
3.1 åœ¨å…¬ç½‘环境下部署系统
3.2 éƒ¨ç½²SG的打包、下载环境
3.3 è§£å†³QGIS出图出错
3.4 è§£å†³åº”用程序启动出错
3.5 è§£å†³GDAL类库运行异常
下周:
1 Web开发:
统一修改各页面样式
修改数据上传功能
修改数据检索功能
修改权限管理及授权功能
2 æœåŠ¡å¼€å‘ï¼š
修改元数据打包功能
修改数据申请功能
修改数据检索接口
=========================================
src/main/java/com/lf/server/controller/all/FloatServerController.java
@@ -1,15 +1,18 @@
package com.lf.server.controller.all;
import com.alibaba.fastjson.JSON;
import com.lf.server.controller.all.BaseController;
import com.lf.server.entity.ctrl.SdkDecryptEntity;
import com.lf.server.entity.ctrl.SdkSecretEntity;
import com.lf.server.entity.other.FloatServerResponse;
import com.lf.server.entity.other.ReqParamFloatServer;
import com.lf.server.helper.HttpHelper;
import com.lf.server.helper.LicHelper;
import com.lf.server.helper.WebHelper;
import io.swagger.annotations.Api;
import org.apache.http.HttpEntity;
import org.apache.http.entity.InputStreamEntity;
import org.apache.http.util.EntityUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@@ -27,12 +30,12 @@
public class FloatServerController extends BaseController {
    private static LicHelper licHelper;
    private static boolean isRedirect = false;
    private final static boolean IS_REDIRECT = false;
    @PostMapping({"/checkout/license"})
    public void license(HttpServletRequest req, HttpServletResponse res) {
        try {
            if (isRedirect) {
            if (IS_REDIRECT) {
                HttpHelper httpHelper = new HttpHelper();
                httpHelper.service(req, res, "http://192.168.20.43:38080/floatserver/checkout/license", null);
                return;
@@ -109,4 +112,24 @@
            System.out.println(ex.getStackTrace());
        }
    }
    @GetMapping({"/licenseEncryption/getLicenseSecret"})
    public void getLicenseSecret(HttpServletResponse res) {
        try {
            String json = JSON.toJSONString(new SdkSecretEntity());
            WebHelper.write2Page(res, json);
        } catch (Exception ex) {
            // http://127.0.0.1:12316/server/floatserver/licenseEncryption/getLicenseSecret
        }
    }
    @GetMapping({"/licenseEncryption/getLicenseDecrypt"})
    public void getLicenseDecrypt(HttpServletResponse res) {
        try {
            String json = JSON.toJSONString(new SdkDecryptEntity());
            WebHelper.write2Page(res, json);
        } catch (Exception ex) {
            // http://127.0.0.1:12316/server/floatserver/licenseEncryption/getLicenseDecrypt
        }
    }
}
src/main/java/com/lf/server/entity/all/StaticData.java
@@ -35,6 +35,11 @@
    public final static int SIXTEEN = 16;
    /**
     * æ•°å€¼ï¼š100
     */
    public final static int ONE_HUNDRED = 100;
    /**
     * æ•°å€¼ï¼š200
     */
    public final static int TWO_HUNDRED = 200;
src/main/java/com/lf/server/entity/ctrl/SdkDecryptDataEntity.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
package com.lf.server.entity.ctrl;
import com.alibaba.fastjson.annotation.JSONField;
import com.lf.server.entity.all.StaticData;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
/**
 * SDK解密数据类
 * @author WWW
 */
public class SdkDecryptDataEntity implements Serializable {
    private static final long serialVersionUID = 4119527512820258035L;
    private static List<Integer> registeredModules = new ArrayList<>();
    static {
        for (int i = 1; i <= StaticData.ONE_HUNDRED; i++) {
            registeredModules.add(i);
        }
    }
    public SdkDecryptDataEntity() {
        machineId = "e7dd8a96913fb5fe62df6b5a7fd503f4";
        // registeredModules = new int[] { 1, 3, 9, 12, 13, 17, 25, 30, 33, 37 }
        message = "OK";
        success = true;
        Calendar calendar = Calendar.getInstance();
        calendar.set(2050, 12, 31);
        expireDate = calendar.getTime();
    }
    private String machineId;
    private String message;
    private boolean success;
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    private Date expireDate;
    public String getMachineId() {
        return machineId;
    }
    public void setMachineId(String machineId) {
        this.machineId = machineId;
    }
    public List<Integer> getRegisteredModules() {
        return registeredModules;
    }
    public String getMessage() {
        return message;
    }
    public void setMessage(String message) {
        this.message = message;
    }
    public boolean isSuccess() {
        return success;
    }
    public void setSuccess(boolean success) {
        this.success = success;
    }
    public Date getExpireDate() {
        return expireDate;
    }
    public void setExpireDate(Date expireDate) {
        this.expireDate = expireDate;
    }
}
src/main/java/com/lf/server/entity/ctrl/SdkDecryptEntity.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
package com.lf.server.entity.ctrl;
import java.io.Serializable;
/**
 * SDK解密类
 * @author WWW
 */
public class SdkDecryptEntity implements Serializable {
    private static final long serialVersionUID = 853291437502721609L;
    private int code;
    private String msg;
    private SdkDecryptDataEntity data;
    public SdkDecryptEntity() {
        code = 200;
        msg = null;
        data = new SdkDecryptDataEntity();
    }
    public int getCode() {
        return code;
    }
    public void setCode(int code) {
        this.code = code;
    }
    public String getMsg() {
        return msg;
    }
    public void setMsg(String msg) {
        this.msg = msg;
    }
    public SdkDecryptDataEntity getData() {
        return data;
    }
    public void setData(SdkDecryptDataEntity data) {
        this.data = data;
    }
}
src/main/java/com/lf/server/entity/ctrl/SdkSecretEntity.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,43 @@
package com.lf.server.entity.ctrl;
/**
 * SDK加密类
 * @author WWW
 */
public class SdkSecretEntity {
    private int code;
    private String msg;
    private String data;
    public SdkSecretEntity() {
        code = 200;
        msg = null;
        data = "1052f106aed368e0c29b4eec89e03a91e352059a24624d0b4fab38e57943a47a0c81e9c843d9e3b11eaed1e7853b09ad7c603d4f854f0351fa9397fe4a06e0c161ca142d0665289510535743fd11e3c47e5648a031d1240536de3640ef94808fec77d15bfea9e6f3faca2f19d15f89b1fcfe23fa7b2b4f433ba22a7484992f63766cb68a81120288e1638a16b126139833b6f1c35876932a4d730ef68fbfecc4";
    }
    public int getCode() {
        return code;
    }
    public void setCode(int code) {
        this.code = code;
    }
    public String getMsg() {
        return msg;
    }
    public void setMsg(String msg) {
        this.msg = msg;
    }
    public String getData() {
        return data;
    }
    public void setData(String data) {
        this.data = data;
    }
}
src/main/resources/application.yml
@@ -12,8 +12,8 @@
  # redis
  redis:
    database: 0
    host: 192.168.20.205
    port: 6369
    host: 127.0.0.1
    port: 6379
    password: rediS_5L#F4_Server
    timeout: 6000  # è¿žæŽ¥è¶…时时长(毫秒)
    pool:
@@ -41,11 +41,11 @@
  datasource:
    name: prod
    # JDBC åŸºæœ¬é…ç½® &currentSchema=public
    url: jdbc:postgresql://192.168.20.205:5433/langfang?useAffectedRows=true
    url: jdbc:postgresql://127.0.0.1:5433/langfang?useAffectedRows=true
    #url: jdbc:postgresql://pipe.cppe.com:5433/langfang?useAffectedRows=true
    username : postgres
    password: Postgres!_14_Lf
    #password: postgres
    #password: Postgres!_14_Lf
    password: postgres
    driver-class-name: org.postgresql.Driver
    paltform: POSTGRESQL
    type: com.alibaba.druid.pool.DruidDataSource
@@ -144,9 +144,9 @@
# ç³»ç»Ÿé…ç½®
sys:
  # FME服务地址
  fmeUrl: http://192.168.20.205:88/
  fmeUrl: http://127.0.0.1:88/
  # å‡ºå›¾æœåŠ¡
  exportServer: http://192.168.20.205/ExportMap
  exportServer: http://127.0.0.1/ExportMap
  # Gdal驱动目录
  gdal_path: E:\terrait\TianJin\Zip\release-1928-x64-dev\release-1928-x64\bin
  path: