瀏覽代碼

***********************WX*****************************
关系调整

张维新 4 年之前
父節點
當前提交
92faf1526d

+ 1 - 1
datasyn/src/main/kotlin/com/persagy/server/syn/controllers/obj/ObjectFromToControllers.kt

@@ -60,7 +60,7 @@ import org.springframework.web.bind.annotation.RestController
  */
 @Tag(name = "0003、对象-中台到数据中心")
 @RestController
-@RequestMapping("/sync-rwd")
+@RequestMapping("/rwd/object")
 class ObjectFromToControllers {
     companion object {
         // 日志

+ 44 - 0
datasyn/src/main/kotlin/com/persagy/server/syn/controllers/obj/RelFromToControllers.kt

@@ -0,0 +1,44 @@
+package com.persagy.server.syn.controllers.obj
+
+import com.persagy.database.SFilter
+import com.persagy.mybatis.SMybatisDao
+import com.persagy.server.datacenter.models.entities.dictnew.DictProject
+import com.persagy.server.datacenter.models.entities.rel.REq2Sp
+import com.persagy.server.syn.models.api.obj.EquipApi
+import com.persagy.service.SBaseService
+import io.swagger.v3.oas.annotations.tags.Tag
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RestController
+
+/**
+ * 数据中台关系导入数据中心
+ */
+@Tag(name = "0004、关系-中台到数据中心")
+@RestController
+@RequestMapping("/rwd/rel")
+class RelFromToControllers {
+
+    /** 字典项目服务 */
+    private val dictProjectService = SBaseService(SMybatisDao(DictProject::class.java))
+    private val rEq2SpService = SBaseService(SMybatisDao(REq2Sp::class.java))
+    /**
+     * 设备所在的业务空间
+     */
+    fun eq2SpIn(projectId: String){
+        val dictProject = dictProjectService.select(SFilter.eq("id", projectId)).entity()
+        if (dictProject!=null) {
+            val relList = EquipApi.getRel(dictProject.groupCode!!, projectId, "", "")
+            if (!relList.isNullOrEmpty()){
+                for ( rel in relList){
+                    val fromId = rel["objFrom"].toString()
+                    val toId = rel["objTo"].toString()
+                }
+            }
+        }
+
+
+    }
+
+
+
+}

+ 20 - 0
datasyn/src/main/kotlin/com/persagy/server/syn/models/api/obj/EquipApi.kt

@@ -219,6 +219,26 @@ object EquipApi {
     }
 
 
+    /**
+     * 获取关系
+     *
+     * @param projectId     项目 id
+     * @param equipId       设备 id
+     * @return 返回结果
+     */
+    fun getRel(groupCode: String,projectId: String,graphCode: String,relCode: String): ArrayList<HashMap<String, Any?>> {
+        val url = "${opts.dataPlatform}/rwd/instance/relation/query?groupCode=$groupCode&projectId=${projectId}"
+        val jsonObject = JSONObject()
+        val jsonObject2 =  JSONObject()
+        jsonObject2["graphCode"] = graphCode
+        jsonObject2["relCode"] = relCode
+        jsonObject["criteria"] = jsonObject2
+        val postObject = SHttpUtil.postObject<MiddleGroundDataRespose>(url, jsonObject)
+        if (postObject.result == "success"&&!postObject.data.isNullOrEmpty()) {
+            return postObject.data!!
+        }
+        return ArrayList<HashMap<String, Any?>>()
+    }