1.7

13693261870

2023-01-07 3372ad6e59c7da5abf28e65447c7b428e5793326

1.7

 data/db_tab.sql

@@ -1100,7 +1100,7 @@
select * from lf.sys_flow;
----------------------------------------------------------------------------------------------------- 16.元数据表-New
-- DROP TABLE IF EXISTS lf.sys_meta; DROP TABLE IF EXISTS lf.sys_meta_file;
create table lf.sys_meta (
create table lf.sys_meta_new (
  id serial primary key,
  eventid varchar(38) default new_guid(),
  metaid integer default 0,
@@ -1124,7 +1124,7 @@
  geom geometry(MultiPolygon, 4490)
);
-- drop index index_sys_meta_geom;
create index index_sys_meta_geom on lf.sys_meta using GIST (geom);
create index index_sys_meta_geom on lf.sys_meta_new using GIST (geom);
comment on table lf.sys_meta is '元数据表';
comment on column lf.sys_meta.id is '主键ID';
comment on column lf.sys_meta.eventid is 'GUID';
@@ -1149,7 +1149,7 @@
comment on column lf.sys_meta.geom is '空间位置';
-- insert into lf.sys_meta(dirid,depid,geom,sizes,name,path) values (1,1,ST_PolygonFromText('MultiPolygon (((100 0,120 0,120 20,100 20,100 0)))', 4490),0.001,'a.jpg','c:\a.jpg');

select * from lf.sys_meta; select a.*,st_astext(geom) from lf.sys_meta a;
select * from lf.sys_meta_new; select a.*,st_astext(geom) from lf.sys_meta a;
----------------------------------------------------------------------------------------------------- å…ƒæ•°æ®æµ‹è¯•è¡¨ *
-- drop table if exists md.md_zxcg;
create table md.md_zxcg(

 data/ts.sql

@@ -142,14 +142,35 @@
delete from lf.sys_meta where id > 150;
delete from lf.sys_meta_file where metaid > 150;

select * from lf.sys_dir;








select * from lf.sys_meta_new;
insert into lf.sys_meta_new (name,dirid) value ('项目WBS导出.xlsx',57,'file');
insert into lf.sys_meta_new (name,dirid) value ('00116BT02-CR001#ESV-DW-0001 å°é¢.pdf',63);
insert into lf.sys_meta_new (name,dirid) value ('00116BT02-CR001#ESV-DW-0001（大河沿河穿越地形图）.pdf',63);
insert into lf.sys_meta_new (name,dirid) value ('00116BT02-CR001#ESV-IN-0001（资料图纸目录）.pdf',63);
insert into lf.sys_meta_new (name,dirid) value ('1ç±».gdb.zip',74);
insert into lf.sys_meta_new (name,dirid) value ('2ç±».gdb.zip',74);
insert into lf.sys_meta_new (name,dirid) value ('易燃易爆.gdb.zip',74);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);
insert into lf.sys_meta_new (name,dirid) value ('',63);




 src/main/java/com/lf/server/controller/data/upload/CheckController.java

@@ -3,6 +3,7 @@
import com.lf.server.annotation.SysLog;
import com.lf.server.controller.all.BaseController;
import com.lf.server.entity.all.ResponseMsg;
import com.lf.server.entity.ctrl.FmeReqEntity;
import com.lf.server.helper.StringHelper;
import com.lf.server.service.data.FmeService;
import io.swagger.annotations.ApiOperation;
@@ -20,17 +21,42 @@
    protected FmeService fmeService;

    @SysLog()
    @ApiOperation(value = "查询数据有效性")
    @GetMapping(value = "/selectDataValid")
    public ResponseMsg<Object> selectDataValid(HttpServletRequest req) {
    @ApiOperation(value = "查询数学基础检查")
    @GetMapping(value = "/selectCheckMath")
    public ResponseMsg<Object> selectCheckMath(HttpServletRequest req) {
        try {
            String taskGuid = StringHelper.getGuid();
            String xmmc = "西气东输四线天然气管道工程（吐鲁番-中卫）（00116BT02）";
            // æµ‹é‡ä¸“业|勘察专业|地灾专业|洞库专业
            String sjzy = "测量专业";
            String filePath = "D:\\Project\\Data\\LF\\temp\\20230106135746\\数学基础检查.zip";
            FmeReqEntity fme = new FmeReqEntity();
            fme.name = StringHelper.getGuid();
            fme.xmmc = "西气东输四线天然气管道工程（吐鲁番-中卫）（00116BT02）";
            fme.sjzy = "测量专业";
            fme.zipPath = "D:\\Project\\Data\\LF\\temp\\20230106135746\\数学基础检查.zip";

            String rs = fmeService.checkMath(taskGuid, xmmc, sjzy, filePath, req);
            String rs = fmeService.checkMath(fme, req);
            if (StringHelper.isEmpty(rs)) {
                return fail("检查失败");
            }

            return success(rs);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }

    @SysLog()
    @ApiOperation(value = "查询入库质检总")
    @GetMapping(value = "/selectCheckMain")
    public ResponseMsg<Object> selectCheckMain(HttpServletRequest req) {
        try {
            FmeReqEntity fme = new FmeReqEntity();
            fme.name = StringHelper.getGuid();
            fme.xmmc = "西气东输四线天然气管道工程（吐鲁番-中卫）（00116BT02）";
            fme.sjzy = "测量专业";
            fme.zipPath = "D:\\Project\\Data\\LF\\temp\\20230106135746\\西气东输四线天然气管道工程（吐鲁番-中卫）（00116BT02）.7z";
            fme.wbsPath = "D:\\Project\\Data\\LF\\temp\\20230106135746\\项目WBS导出.xlsx";
            fme.isDiZai = "NO";
            fme.diZaiType = "NO";

            String rs = fmeService.checkMain(fme, req);
            if (StringHelper.isEmpty(rs)) {
                return fail("检查失败");
            }

 src/main/java/com/lf/server/entity/ctrl/FmeReqEntity.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,45 @@
package com.lf.server.entity.ctrl;

/**
 * FME请求实体类
 * @author WWW
 */
public class FmeReqEntity {
    public FmeReqEntity() {
    }

    /**
     * ä»»åŠ¡åç§°
     */
    public String name;

    /**
     * é¡¹ç›®åç§°
     */
    public String xmmc;

    /**
     * æ•°æ®ä¸“业：测量专业 | å‹˜å¯Ÿä¸“业 | åœ°ç¾ä¸“业 | æ´žåº“专业
     */
    public String sjzy;

    /**
     * å¾…检压缩包
     */
    public String zipPath;

    /**
     * WBS表格
     */
    public String wbsPath;

    /**
     * æ˜¯/否为地灾数据：YES|NO
     */
    public String isDiZai;

    /**
     * åœ°ç¾æ•°æ®ç±»åž‹ï¼šå´©å¡Œæ²»ç† | ä¸ç¨³å®šæ–œå¡æ²»ç† | åœ°é¢å¡Œé™·æ²»ç† | é«˜é™¡è¾¹å¡æ²»ç† | æ³¥çŸ³æµæ²»ç† | æ°´æ¯æ²»ç† | æ»‘坡治理 | NO
     */
    public String diZaiType;
}

 src/main/java/com/lf/server/service/data/FmeService.java

@@ -1,5 +1,6 @@
package com.lf.server.service.data;

import com.lf.server.entity.ctrl.FmeReqEntity;
import com.lf.server.entity.ctrl.NameValueEntity;
import com.lf.server.helper.RestHelper;
import com.lf.server.helper.WebHelper;
@@ -85,13 +86,13 @@
    /**
     * 10.数学基础检查：.shp, .gdb, *元数据*.xls/.xlsx
     */
    public String checkMath(String taskGuid, String xmmc, String sjzy, String filePath, HttpServletRequest req) {
    public String checkMath(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B1入库质检_数学基础检查", req);

        List<NameValueEntity> list = getKeyValues(taskGuid);
        list.add(new NameValueEntity("XMMC", xmmc));
        list.add(new NameValueEntity("SJZY", sjzy));
        list.add(new NameValueEntity("GCXMYSB", filePath));
        List<NameValueEntity> list = getKeyValues(fme.name);
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("SJZY", fme.sjzy));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));

        return RestHelper.postForRest(url, list);
    }
@@ -100,7 +101,24 @@
     * 11.元数据检查：*元数据*.xls/.xlsx
     */
    public void checkMeta() {
        
    }

    /**
     * 12.入库质检总：.zip/.7z + .xls/.xlsx
     */
    public String checkMain(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B0入库质检__总", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("SJZY", fme.sjzy));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
        list.add(new NameValueEntity("S_WBSBG", fme.wbsPath));
        list.add(new NameValueEntity("S_DZDK", fme.isDiZai));
        list.add(new NameValueEntity("DZ_ZLLX", fme.diZaiType));

        return RestHelper.postForRest(url, list);
    }

    /**
@@ -114,12 +132,10 @@

    /**
     * èŽ·å–名称值对集合
     *
     * @return åç§°å€¼å¯¹é›†åˆ
     */
    public List<NameValueEntity> getKeyValues(String taskGuid) {
    public List<NameValueEntity> getKeyValues(String guid) {
        List<NameValueEntity> list = new ArrayList<>();
        list.add(new NameValueEntity("_name", taskGuid));
        list.add(new NameValueEntity("_name", guid));
        list.add(new NameValueEntity("_priority", 100));
        list.add(new NameValueEntity("_terminate_on_error", true));
        list.add(new NameValueEntity("IID", ""));