管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-03-23 835d7bc6b421ec998f2c7d04f528b36c52035c90
src/main/java/com/lf/server/service/data/FmeService.java
@@ -2,7 +2,8 @@
import com.lf.server.entity.ctrl.FmeReqEntity;
import com.lf.server.entity.ctrl.NameValueEntity;
import com.lf.server.entity.data.MetaEntity;
import com.lf.server.entity.data.MetaFileEntity;
import com.lf.server.entity.data.PublishEntity;
import com.lf.server.helper.RestHelper;
import com.lf.server.helper.StringHelper;
import com.lf.server.helper.WebHelper;
@@ -119,9 +120,9 @@
        List<NameValueEntity> list = getKeyValues("拓扑检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
        list.add(new NameValueEntity("S_MCDRC", fme.polyTolerance));
        list.add(new NameValueEntity("S_XCDRC", fme.lineTolerance));
        list.add(new NameValueEntity("S_DCDRC", fme.pointTolerance));
        list.add(new NameValueEntity("S_MCDRC", fme.tolerance));
        list.add(new NameValueEntity("S_XCDRC", fme.tolerance));
        list.add(new NameValueEntity("S_DCDRC", fme.tolerance));
        list.add(new NameValueEntity("OFFSET_GCD", fme.gcdOffset));
        list.add(new NameValueEntity("OFFSET_KZD", fme.kzdOffset));
        list.add(new NameValueEntity("Range_OFFSET", fme.rangeOffset));
@@ -220,17 +221,16 @@
    }
    /**
     * 13.表格入库
     * 13.表格入库:S_RKBG、dirid、parentid,多个以英文逗号隔开
     */
    public String excelLoader(MetaEntity meta, HttpServletRequest req) {
    public String excelLoader(MetaFileEntity meta, HttpServletRequest req) {
        String url = getUrl("datax/task/run/表格入库", req);
        // S_RKBG:为入库表格的完整路径,多个以英文逗号隔开
        List<NameValueEntity> list = getKeyValues("表格入库");
        list.add(new NameValueEntity("S_RKBG", meta.getPath()));
        list.add(new NameValueEntity("COORDSYS", meta.getGeom()));
        list.add(new NameValueEntity("dirid", meta.getDirid()));
        list.add(new NameValueEntity("depid", meta.getDepid()));
        list.add(new NameValueEntity("COORDSYS", meta.getEpsgCode()));
        list.add(new NameValueEntity("dirid", meta.getName()));
        list.add(new NameValueEntity("depid", meta.getDepcode()));
        list.add(new NameValueEntity("verid", meta.getVerid()));
        list.add(new NameValueEntity("createuser", meta.getCreateUser()));
        list.add(new NameValueEntity("parentid", meta.getEventid()));
@@ -239,6 +239,61 @@
    }
    /**
     * 14.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);
        List<NameValueEntity> list = getKeyValues("CRDS平台交付");
        list.add(new NameValueEntity("S_FFXMMC", dirCode));
        list.add(new NameValueEntity("MBZY", major));
        list.add(new NameValueEntity("P_WBFW", isCut));
        return RestHelper.postForRest(url, list);
    }
    /**
     * 15.服务注册
     */
    public String serverRegister(String name, String serverUri, String type, HttpServletRequest req) {
        String url = getUrl("resource/res/item", req);
        List<NameValueEntity> list = new ArrayList<>();
        list.add(new NameValueEntity("tags", new String[]{name}));
        list.add(new NameValueEntity("name", name));
        list.add(new NameValueEntity("address", serverUri));
        list.add(new NameValueEntity("detailUrl", serverUri));
        list.add(new NameValueEntity("type", type));
        list.add(new NameValueEntity("description", name));
        list.add(new NameValueEntity("isrequest", true));
        return RestHelper.postForRest(url, list);
    }
    /**
     * 16.服务申请
     */
    public String serverApply(String id, Integer pubid, HttpServletRequest req) {
        String url = getUrl("resource/res/request", req) + "&resourceid=" + id;
        List<NameValueEntity> list = new ArrayList<>();
        list.add(new NameValueEntity("reason", "注册"));
        list.add(new NameValueEntity("serialnum", pubid.toString()));
        return RestHelper.postForRest(url, list);
    }
    /**
     * 17.删除资源
     */
    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) {