管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-01-07 1b5179ade02f483bda7cae00e4242d6218bd6cba
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;
@@ -20,88 +21,111 @@
    private String fmeUrl;
    /**
     * OSGB检查:.osgb + *倾斜摄影*.xls/.xlsx
     * 1.OSGB检查:.osgb + *倾斜摄影*.xls/.xlsx
     */
    public void checkOsgb(String path) {
    }
    /**
     * 表格数据检查:.xls/.xlsx(排除元数据)
     * 2.表格数据检查:.xls/.xlsx(排除元数据)
     */
    public void checkXls() {
    }
    /**
     * 点云检查:.laz + *激光点云*.xls/.xlsx
     * 3.点云检查:.laz + *激光点云*.xls/.xlsx
     */
    public void checkLaz() {
    }
    /**
     * 高程检查:.tif/.prj/.tfw/.tif.ovr + *地形图*.dwg
     * 4.高程检查:.tif/.prj/.tfw/.tif.ovr + *地形图*.dwg
     */
    public void checkDem() {
    }
    /**
     * 属性检查:*dlg*.gdb + *地形图*.dwg
     * 5.属性检查:*dlg*.gdb + *地形图*.dwg
     */
    public void checkAttrs() {
    }
    /**
     * 拓扑检查:*地形图*.dwg
     * 6.拓扑检查:*地形图*.dwg
     */
    public void checkTopology() {
    }
    /**
     * 图面整饰检查:.dwg
     * 7.图面整饰检查:.dwg
     */
    public void checkDecorate() {
    }
    /**
     * 原点检查:*剖面图*.dwg
     * 8.原点检查:*剖面图*.dwg
     */
    public void checkOrigin() {
    }
    /**
     * 栅格检查:.tif/.prj/.tfw/.tif.ovr + .xls/.xlsx
     * 9.栅格检查:.tif/.prj/.tfw/.tif.ovr + .xls/.xlsx
     */
    public void checkDom() {
    }
    /**
     * 数学基础检查:.shp, .gdb, *元数据*.xls/.xlsx
     * 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 = getKeyVals();
        list.add(new NameValueEntity("_name", 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);
    }
    /**
     * 元数据检查:*元数据*.xls/.xlsx
     * 11.元数据检查:*元数据*.xls/.xlsx
     */
    public void checkMeta() {
    public String checkMeta(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B5入库质检_元数据检查", 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);
    }
    /**
     * 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);
    }
    /**
@@ -115,13 +139,17 @@
    /**
     * 获取名称值对集合
     *
     * @return 名称值对集合
     */
    public List<NameValueEntity> getKeyVals() {
    public List<NameValueEntity> getKeyValues(String guid) {
        List<NameValueEntity> list = new ArrayList<>();
        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", ""));
        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"));
        return list;
    }