管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2024-11-22 d23b2ce1ae45c192aed067041da8de748b97d405
src/main/java/com/lf/server/service/data/FmeService.java
@@ -7,6 +7,8 @@
import com.lf.server.helper.RestHelper;
import com.lf.server.helper.StringHelper;
import com.lf.server.helper.WebHelper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
@@ -23,6 +25,11 @@
public class FmeService {
    @Value("${sys.fmeUrl}")
    private String fmeUrl;
    @Value("${sys.fmeToken}")
    private String fmeToken;
    private final static Log log = LogFactory.getLog(FmeService.class);
    /**
     * 获取任务状态
@@ -300,11 +307,15 @@
     * d.服务申请
     */
    public void serverApply(String id, Integer pubid, HttpServletRequest req) {
        String url = getUrl("resource/res/request", req) + "&resourceid=" + id;
        try {
            String url = getUrl("resource/res/request", req) + "&resourceid=" + id;
        RegisterEntity entity = new RegisterEntity(pubid);
            RegisterEntity entity = new RegisterEntity(pubid);
        RestHelper.postForRest(url, entity);
            RestHelper.postForRest(url, entity);
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }
    }
    /**
@@ -317,6 +328,23 @@
    }
    /**
     * f.计算面积
     */
    public String calcArea(String sjfl, String id, String wjlj) {
        String url = getUrl("datax/task/run/数据占地面积计算");
        List<NameValueEntity> list = new ArrayList<>();
        list.add(new NameValueEntity("_name", String.format("%s_%s", "数据占地面积计算", StringHelper.YMDHMS2_FORMAT.format(new Date()))));
        list.add(new NameValueEntity("_terminate_on_error", false));
        list.add(new NameValueEntity("_priority", 100));
        list.add(new NameValueEntity("SJFL", sjfl));
        list.add(new NameValueEntity("ID", id));
        list.add(new NameValueEntity("WJLJ", wjlj));
        return RestHelper.postForRest(url, list);
    }
    /**
     * 获取Url
     */
    public String getUrl(String subUrl, HttpServletRequest req) {
@@ -326,6 +354,13 @@
    }
    /**
     * 获取Url
     */
    public String getUrl(String subUrl) {
        return fmeUrl + subUrl + "?token=" + fmeToken;
    }
    /**
     * 获取名称值对集合
     */
    public List<NameValueEntity> getKeyValues(String name) {