1

13693261870

2024-11-17 796b44ea813a1133beae4f3a67f1c0263510c0c7

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

@@ -15,34 +15,22 @@
import java.util.Date;
import java.util.List;

/**
 * FME服务类
 * @author WWW
 */
@Service
@SuppressWarnings("ALL")
public class FmeService {
    @Value("${sys.fmeUrl}")
    private String fmeUrl;

    /**
     * 获取任务状态
     */
    public Object getTaskStatus(String id, HttpServletRequest req) {
        String url = getUrl("datax/task/get", req) + "&id=" + id;

        return RestHelper.getForRest(url, Object.class);
    }

    /**
     * 下载质检错误结果
     */
    public String getDownloadUrl(String id, HttpServletRequest req) {
        return getUrl("datax/task/downloadResult", req) + "&id=" + id;
    }

    /**
     * 1.OSGB检查：.osgb + *倾斜摄影*.xls/.xlsx
     */
    public String checkOsgb(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A8成果质检_OSGB检查", req);

@@ -54,9 +42,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 2.表格数据检查：.xls/.xlsx（排除元数据）
     */
    public String checkXls(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A3成果质检_表格数据检查", req);

@@ -68,9 +53,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 3.点云检查：.laz + *激光点云*.xls/.xlsx
     */
    public String checkLaz(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A9成果质检_点云检查", req);

@@ -82,9 +64,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 4.高程检查：.tif/.prj/.tfw/.tif.ovr + *地形图*.dwg
     */
    public String checkDem(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A6成果质检_高程检查", req);

@@ -97,9 +76,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 5.属性检查：*dlg*.gdb + *地形图*.dwg
     */
    public String checkAttrs(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A5成果质检_属性检查", req);

@@ -111,9 +87,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 6.拓扑检查：*地形图*.dwg
     */
    public String checkTopology(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A4成果质检_拓扑检查", req);

@@ -131,9 +104,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 7.图面整饰检查：.dwg
     */
    public String checkDecorate(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A10成果质检_图面整饰检查", req);

@@ -146,9 +116,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 8.原点检查：*剖面图*.dwg
     */
    public String checkOrigin(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A11成果质检_原点检查", req);

@@ -159,9 +126,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 9.栅格检查：.tif/.prj/.tfw/.tif.ovr + .xls/.xlsx
     */
    public String checkDom(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A7成果质检_栅格检查", req);

@@ -175,9 +139,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 10.数学基础检查：.shp, .gdb, *元数据*.xls/.xlsx
     */
    public String checkMath(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B1入库质检_数学基础检查", req);

@@ -189,9 +150,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 11.元数据检查：*元数据*.xls/.xlsx
     */
    public String checkMeta(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B5入库质检_元数据检查", req);

@@ -203,9 +161,6 @@
        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);

@@ -220,9 +175,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 13.逻辑一致性检查：.dwg/.xls/.xlsx
     */
    public String checkLogical(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B3入库质检_逻辑一致性检查", req);

@@ -234,9 +186,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * 14.单项成果完整性检查：.*
     */
    public String checkSingleIntegrity(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B6入库质检_单项成果完整性检查", req);

@@ -249,9 +198,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * a.表格入库：S_RKBG、dirid、parentid，多个以英文逗号隔开
     */
    public String excelLoader(MetaFileEntity meta, HttpServletRequest req) {
        String url = getUrl("datax/task/run/表格入库", req);

@@ -267,9 +213,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * b.CRDS平台交付
     */
    public String crdsPackaging(String dirCode, String major, String isCut, HttpServletRequest req) {
        // datax/task/run/CRDS平台交付_测试
        String url = getUrl("datax/task/run/CRDS平台交付_code测试", req);
@@ -282,9 +225,6 @@
        return RestHelper.postForRest(url, list);
    }

    /**
     * c.服务注册
     */
    public RegisterEntity serverRegister(String name, String serverUri, String type, HttpServletRequest req) {
        String url = getUrl("resource/res/item", req);

@@ -296,9 +236,6 @@
        return entity;
    }

    /**
     * d.服务申请
     */
    public void serverApply(String id, Integer pubid, HttpServletRequest req) {
        String url = getUrl("resource/res/request", req) + "&resourceid=" + id;

@@ -307,27 +244,18 @@
        RestHelper.postForRest(url, entity);
    }

    /**
     * e.删除资源
     */
    public void deleteRes(String id, HttpServletRequest req) {
        String url = getUrl("resource/res/hashid", req) + "&hashid=" + id;

        RestHelper.deleteForRest(url);
    }

    /**
     * 获取Url
     */
    public String getUrl(String subUrl, HttpServletRequest req) {
        String token = WebHelper.getToken(req);

        return fmeUrl + subUrl + "?token=" + token;
    }

    /**
     * 获取名称值对集合
     */
    public List<NameValueEntity> getKeyValues(String name) {
        List<NameValueEntity> list = new ArrayList<>();
        list.add(new NameValueEntity("_name", String.format("%s_%s", name, StringHelper.YMDHMS2_FORMAT.format(new Date()))));