2

13693261870

2023-01-09 c61573b7222a99a69ff381fac53f4af831030830

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

@@ -2,15 +2,16 @@

import com.lf.server.entity.ctrl.FmeReqEntity;
import com.lf.server.entity.ctrl.NameValueEntity;
import com.lf.server.entity.data.MetaFileEntity;
import com.lf.server.helper.RestHelper;
import com.lf.server.helper.StringHelper;
import com.lf.server.helper.WebHelper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
@@ -23,12 +24,28 @@
    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);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("OSGB检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
        list.add(new NameValueEntity("DMYX_FBL", fme.imgResolution));
@@ -42,7 +59,7 @@
    public String checkXls(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A3成果质检_表格数据检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("表格数据检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("SJZY", fme.sjzy));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
@@ -56,7 +73,7 @@
    public String checkLaz(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A9成果质检_点云检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("点云检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
        list.add(new NameValueEntity("LAZ_MD", fme.lazDensity));
@@ -70,7 +87,7 @@
    public String checkDem(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A6成果质检_高程检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("高程检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
        list.add(new NameValueEntity("GCZWC", fme.demTolerance));
@@ -85,7 +102,7 @@
    public String checkAttrs(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A5成果质检_属性检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("属性检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("SJZY", fme.sjzy));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
@@ -99,7 +116,7 @@
    public String checkTopology(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A4成果质检_拓扑检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        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));
@@ -119,11 +136,11 @@
    public String checkDecorate(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A10成果质检_图面整饰检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("图面整饰检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
        list.add(new NameValueEntity("S_XLS2", fme.xlsList));
        list.add(new NameValueEntity("S_XLS", "$(OrgUserStorage)\\质检配置文件\\质检配置表总.xlsx"));
        list.add(new NameValueEntity("S_XLS", "$(ZJPZWJ)\\质检配置表总.xlsx"));
        list.add(new NameValueEntity("S_XLS2", "D:\\Project\\Data\\LF\\temp\\20230107010101\\文件清单.xlsx"));

        return RestHelper.postForRest(url, list);
    }
@@ -134,7 +151,7 @@
    public String checkOrigin(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A11成果质检_原点检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("原点检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));

@@ -147,7 +164,7 @@
    public String checkDom(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/A7成果质检_栅格检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("栅格检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("SJZY", fme.sjzy));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
@@ -163,7 +180,7 @@
    public String checkMath(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B1入库质检_数学基础检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("数学基础检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("SJZY", fme.sjzy));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
@@ -177,7 +194,7 @@
    public String checkMeta(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B5入库质检_元数据检查", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("元数据检查");
        list.add(new NameValueEntity("XMMC", fme.xmmc));
        list.add(new NameValueEntity("SJZY", fme.sjzy));
        list.add(new NameValueEntity("GCXMYSB", fme.zipPath));
@@ -191,13 +208,32 @@
    public String checkMain(FmeReqEntity fme, HttpServletRequest req) {
        String url = getUrl("datax/task/run/B0入库质检__总", req);

        List<NameValueEntity> list = getKeyValues(fme.name);
        List<NameValueEntity> list = getKeyValues("总质检");
        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);
    }

    /**
     * 13.表格入库
     */
    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.getCs()));
        list.add(new NameValueEntity("dirid", meta.getDirid()));
        list.add(new NameValueEntity("depid", meta.getDepid()));
        list.add(new NameValueEntity("verid", meta.getVerid()));
        list.add(new NameValueEntity("createuser", meta.getCreateUser()));
        list.add(new NameValueEntity("parentid", meta.getEventid()));

        return RestHelper.postForRest(url, list);
    }
@@ -214,9 +250,9 @@
    /**
     * 获取名称值对集合
     */
    public List<NameValueEntity> getKeyValues(String guid) {
    public List<NameValueEntity> getKeyValues(String name) {
        List<NameValueEntity> list = new ArrayList<>();
        list.add(new NameValueEntity("_name", guid));
        list.add(new NameValueEntity("_name", String.format("%s_%s", name, StringHelper.YMDHMS2_FORMAT.format(new Date()))));
        list.add(new NameValueEntity("_priority", 100));
        list.add(new NameValueEntity("_terminate_on_error", false));
        list.add(new NameValueEntity("IID", ""));