From 3eceb59d2e062d3ea65972849f1ae88bc8bf497b Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期五, 06 一月 2023 21:01:45 +0800
Subject: [PATCH] 1

---
 src/main/java/com/lf/server/service/data/FmeService.java |   93 +++++++++++++++++++++++++++++++++-------------
 1 files changed, 67 insertions(+), 26 deletions(-)

diff --git a/src/main/java/com/lf/server/service/data/FmeService.java b/src/main/java/com/lf/server/service/data/FmeService.java
index 7057092..69f9df0 100644
--- a/src/main/java/com/lf/server/service/data/FmeService.java
+++ b/src/main/java/com/lf/server/service/data/FmeService.java
@@ -1,8 +1,14 @@
 package com.lf.server.service.data;
 
-import com.lf.server.config.PropertiesConfig;
-import org.springframework.beans.factory.annotation.Autowired;
+import com.lf.server.entity.ctrl.NameValueEntity;
+import com.lf.server.helper.RestHelper;
+import com.lf.server.helper.WebHelper;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * FME鏈嶅姟绫�
@@ -10,83 +16,118 @@
  */
 @Service
 public class FmeService {
-    @Autowired
-    PropertiesConfig propertiesConfig;
+    @Value("${sys.fmeUrl}")
+    private String fmeUrl;
 
     /**
-     * OSGB妫�鏌ワ細.osgb + .xls/.xlsx
+     * 1.OSGB妫�鏌ワ細.osgb + *鍊炬枩鎽勫奖*.xls/.xlsx
      */
-    public void checkOsgb(){
+    public void checkOsgb(String path) {
 
     }
 
     /**
-     * 琛ㄦ牸鏁版嵁妫�鏌ワ細.xls/.xlsx
+     * 2.琛ㄦ牸鏁版嵁妫�鏌ワ細.xls/.xlsx锛堟帓闄ゅ厓鏁版嵁锛�
      */
-    public void checkXls(){
+    public void checkXls() {
 
     }
 
     /**
-     * 鐐逛簯妫�鏌ワ細.laz + .xls/.xlsx
+     * 3.鐐逛簯妫�鏌ワ細.laz + *婵�鍏夌偣浜�*.xls/.xlsx
      */
-    public void checkLaz(){
+    public void checkLaz() {
 
     }
 
     /**
-     * 楂樼▼妫�鏌ワ細.tif/.tfw/.tif.ovr + .dwg
+     * 4.楂樼▼妫�鏌ワ細.tif/.prj/.tfw/.tif.ovr + *鍦板舰鍥�*.dwg
      */
-    public void checkDem(){
+    public void checkDem() {
 
     }
 
     /**
-     * 灞炴�ф鏌ワ細.dwg, *dlg.gdb
+     * 5.灞炴�ф鏌ワ細*dlg*.gdb + *鍦板舰鍥�*.dwg
      */
-    public void checkAttrs(){
+    public void checkAttrs() {
 
     }
 
     /**
-     * 鎷撴墤妫�鏌ワ細*鍦板舰鍥�.dwg
+     * 6.鎷撴墤妫�鏌ワ細*鍦板舰鍥�*.dwg
      */
-    public void checkTopology(){
+    public void checkTopology() {
 
     }
 
     /**
-     * 鍥鹃潰鏁撮グ妫�鏌ワ細.dwg
+     * 7.鍥鹃潰鏁撮グ妫�鏌ワ細.dwg
      */
-    public void checkDecorate(){
+    public void checkDecorate() {
 
     }
 
     /**
-     * 鍘熺偣妫�鏌ワ細鍓栭潰鍥�.dwg
+     * 8.鍘熺偣妫�鏌ワ細*鍓栭潰鍥�*.dwg
      */
-    public void checkOrigin(){
+    public void checkOrigin() {
 
     }
 
     /**
-     * 鏍呮牸妫�鏌ワ細.tif/.tfw/.tif.ovr + .xls/.xlsx
+     * 9.鏍呮牸妫�鏌ワ細.tif/.prj/.tfw/.tif.ovr + .xls/.xlsx
      */
-    public void checkDom(){
+    public void checkDom() {
 
     }
 
     /**
-     * 鏁板鍩虹妫�鏌ワ細.shp, .gdb, .xls/.xlsx
+     * 10.鏁板鍩虹妫�鏌ワ細.shp, .gdb, *鍏冩暟鎹�*.xls/.xlsx
      */
-    public void checkMath(){
+    public String checkMath(String taskGuid, String xmmc, String sjzy, String filePath, HttpServletRequest req) {
+        String url = getUrl("datax/task/run/B1鍏ュ簱璐ㄦ_鏁板鍩虹妫�鏌�", req);
+
+        List<NameValueEntity> list = getKeyValues(taskGuid);
+        list.add(new NameValueEntity("XMMC", xmmc));
+        list.add(new NameValueEntity("SJZY", sjzy));
+        list.add(new NameValueEntity("GCXMYSB", filePath));
+
+        return RestHelper.postForRest(url, list);
+    }
+
+    /**
+     * 11.鍏冩暟鎹鏌ワ細*鍏冩暟鎹�*.xls/.xlsx
+     */
+    public void checkMeta() {
 
     }
 
     /**
-     * 鍏冩暟鎹鏌ワ細.xls/.xlsx
+     * 鑾峰彇Url
      */
-    public void checkMeta(){
+    public String getUrl(String subUrl, HttpServletRequest req) {
+        String token = WebHelper.getToken(req);
 
+        return fmeUrl + subUrl + "?token=" + token;
+    }
+
+    /**
+     * 鑾峰彇鍚嶇О鍊煎闆嗗悎
+     *
+     * @return 鍚嶇О鍊煎闆嗗悎
+     */
+    public List<NameValueEntity> getKeyValues(String taskGuid) {
+        List<NameValueEntity> list = new ArrayList<>();
+        list.add(new NameValueEntity("_name", taskGuid));
+        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;
     }
 }

--
Gitblit v1.9.3