管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-01-07 47c0f2c756b93d111135cc88ea15143084c08341
1
已修改3个文件
91 ■■■■ 文件已修改
data/update.sql 21 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/data/upload/CheckController.java 46 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/FmeService.java 24 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/update.sql
@@ -5,18 +5,19 @@
select * from lf.sys_user; -- Admin@1234_lf
-- update lf.sys_user set pwd = 'd4d25475a81ef4db4b28ce4034500f896169f15c0c68da5d';
-- update lf.sys_menu set url = 'http://172.16.200.14:88/dataxdi/#/schema/list?tags=入库质检&embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '入库质检';
-- update lf.sys_menu set url = 'http://172.16.200.14:88/dataxdi/#/schema/list?tags=成果质检&embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '成果质检';
-- update lf.sys_menu set url = 'http://172.16.200.14:88/dataxdi/#/task/list?embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '任务状态' and id = 69;
select * from lf.sys_menu order by id;
update lf.sys_menu set url = 'http://pipe.cppe.com:88/dataxdi/#/schema/list?tags=入库质检&embed=true&token=' where cn_name = '入库质检';
update lf.sys_menu set url = 'http://pipe.cppe.com:88/dataxdi/#/schema/list?tags=成果质检&embed=true&token=' where cn_name = '成果质检';
update lf.sys_menu set url = 'http://pipe.cppe.com:88/dataxdi/#/task/list?embed=true&token=' where cn_name = '任务状态' and id = 69;
-- update lf.sys_menu set url = 'http://172.16.200.14:88/dataxdi/#/schema/list?tags=数据交换&embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '格式转换';
-- update lf.sys_menu set url = 'http://172.16.200.14:88/dataxdi/#/schema/list?tags=坐标转换&embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '坐标转换';
-- update lf.sys_menu set url = 'http://172.16.200.14:88/dataxdi/#/schema/list?tags=数据分发&embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '数据分发';
-- update lf.sys_menu set url = 'http://172.16.200.14:88/dataxdi/#/schema/list?tags=数据治理&embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '数据治理';
-- update lf.sys_menu set url = 'http://172.16.200.14:88/dataxdi/#/task/list?embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '任务状态' and id = 74;
update lf.sys_menu set url = 'http://pipe.cppe.com:88/dataxdi/#/schema/list?tags=数据交换&embed=true&token=' where cn_name = '格式转换';
update lf.sys_menu set url = 'http://pipe.cppe.com:88/dataxdi/#/schema/list?tags=坐标转换&embed=true&token=' where cn_name = '坐标转换';
update lf.sys_menu set url = 'http://pipe.cppe.com:88/dataxdi/#/schema/list?tags=数据分发&embed=true&token=' where cn_name = '数据分发';
update lf.sys_menu set url = 'http://pipe.cppe.com:88/dataxdi/#/schema/list?tags=数据治理&embed=true&token=' where cn_name = '数据治理';
update lf.sys_menu set url = 'http://pipe.cppe.com:88/dataxdi/#/task/list?embed=true&token=' where cn_name = '任务状态' and id = 74;
-- update lf.sys_menu set url = 'http://172.16.200.14:88/resm/#/resourceManage?embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '我的资源';
-- update lf.sys_menu set url = 'http://172.16.200.14:88/resm/#/resapproval?embed=true&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1aWQiOiI1YmJjMGI2MC02NmU1LTRlYmMtOTU1OS02NDNmYjQ2MDMyMDAiLCJleHAiOjE2NzA0ODg4NTgsImFjY291bnQiOiJhZG1pbiJ9.kUq7hVIagV6n5ShdVb4IIT5tR-2Xn2xvgaf_yQOqUwY' where cn_name = '资源审核';
update lf.sys_menu set url = 'http://pipe.cppe.com:88/resm/#/resourceManage?embed=true&token=' where cn_name = '我的资源';
update lf.sys_menu set url = 'http://pipe.cppe.com:88/resm/#/resapproval?embed=true&token=' where cn_name = '资源审核';
------------------------------------------------------ FME_数据质检
select * from lf.sys_menu where cn_name = '入库质检';
update lf.sys_menu set url = 'http://10.7.0.186:88/dataxdi/#/schema/list?tags=入库质检&embed=true&token=' where cn_name = '入库质检';
src/main/java/com/lf/server/controller/data/upload/CheckController.java
@@ -21,6 +21,50 @@
    protected FmeService fmeService;
    @SysLog()
    @ApiOperation(value = "查询OSGB检查")
    @GetMapping(value = "/selectCheckOsgb")
    public ResponseMsg<Object> selectCheckOsgb(HttpServletRequest req) {
        try {
            FmeReqEntity fme = new FmeReqEntity();
            fme.name = StringHelper.getGuid();
            fme.xmmc = "西气东输四线天然气管道工程(吐鲁番-中卫)(00116BT02)";
            fme.zipPath = "D:\\Project\\Data\\LF\\temp\\20230107010101\\OSGB检查.zip";
            fme.imgResolution = 0.2;
            String rs = fmeService.checkOsgb(fme, req);
            if (StringHelper.isEmpty(rs)) {
                return fail("检查失败");
            }
            return success(rs);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }
    @SysLog()
    @ApiOperation(value = "查询表格数据检查")
    @GetMapping(value = "/selectCheckXls")
    public ResponseMsg<Object> selectCheckXls(HttpServletRequest req) {
        try {
            FmeReqEntity fme = new FmeReqEntity();
            fme.name = StringHelper.getGuid();
            fme.xmmc = "西气东输四线天然气管道工程(吐鲁番-中卫)(00116BT02)";
            fme.sjzy = "测量专业";
            fme.zipPath = "D:\\Project\\Data\\LF\\temp\\20230107010101\\表格数据检查.zip";
            String rs = fmeService.checkXls(fme, req);
            if (StringHelper.isEmpty(rs)) {
                return fail("检查失败");
            }
            return success(rs);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }
    @SysLog()
    @ApiOperation(value = "查询点云检查")
    @GetMapping(value = "/selectCheckLaz")
    public ResponseMsg<Object> selectCheckLaz(HttpServletRequest req) {
@@ -28,7 +72,7 @@
            FmeReqEntity fme = new FmeReqEntity();
            fme.name = StringHelper.getGuid();
            fme.xmmc = "西气东输四线天然气管道工程(吐鲁番-中卫)(00116BT02)";
            fme.zipPath = "D:\\Project\\Data\\LF\\temp\\20230107010101\\高程检查.zip";
            fme.zipPath = "D:\\Project\\Data\\LF\\temp\\20230107010101\\点云检查.zip";
            fme.lazDensity = 1;
            String rs = fmeService.checkLaz(fme, req);
src/main/java/com/lf/server/service/data/FmeService.java
@@ -23,15 +23,29 @@
    /**
     * 1.OSGB检查:.osgb + *倾斜摄影*.xls/.xlsx
     */
    public void checkOsgb(FmeReqEntity fme, HttpServletRequest req) {
    public String checkOsgb(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A8成果质检_OSGB检查", req);
        List<NameValueEntity> list = getKeyValues(fme.name);
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
        list.add(new NameValueEntity("DMYX_FBL", fme.imgResolution));
        return RestHelper.postForRest(url, list);
    }
    /**
     * 2.表格数据检查:.xls/.xlsx(排除元数据)
     */
    public void checkXls(FmeReqEntity fme, HttpServletRequest req) {
    public String checkXls(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A3成果质检_表格数据检查", 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));
        return RestHelper.postForRest(url, list);
    }
    /**
@@ -205,9 +219,9 @@
        list.add(new NameValueEntity("_terminate_on_error", false));
        list.add(new NameValueEntity("IID", ""));
        list.add(new NameValueEntity("FANOUT_DIR", "$(OrgResultStorage)"));
        list.add(new NameValueEntity("IID_JL", "$(OrgUserStorage)\\质检配置文件\\IID记录表.xlsx"));
        list.add(new NameValueEntity("S_ZJXZ", "$(OrgUserStorage)\\质检配置文件\\质检细则总.xlsx"));
        list.add(new NameValueEntity("S_BZPZB", "$(OrgUserStorage)\\质检配置文件\\质检配置表总.xlsx"));
        list.add(new NameValueEntity("IID_JL", "$(ZJPZWJ)\\IID记录表.xlsx"));
        list.add(new NameValueEntity("S_ZJXZ", "$(ZJPZWJ)\\质检细则总.xlsx"));
        list.add(new NameValueEntity("S_BZPZB", "$(ZJPZWJ)\\质检配置表总.xlsx"));
        return list;
    }