From 24b1b15ac0869e063796cf79064eb43d90201193 Mon Sep 17 00:00:00 2001
From: scq <1139040563@qq.com>
Date: Tue, 11 Jul 2023 22:57:57 +0800
Subject: [PATCH] all interface refactor

---
 backend/yjs/ControlProxy.yjs       | 70 ++++++++++-----------
 backend/yjs/ShanxiAuditPRoxy.yjs   |  8 +++
 backend/yjs/ShanxiDataRepo.yjs     | 41 +++++++++++++
 backend/yjs/ShanxiGlobalRouter.yjs | 98 ++++++++++++++++++++++++++++++
 backend/yjs/ShanxiRegistry.yjs     | 65 ++++++++++++++++++++
 backend/yjs/audit.yjs              |  2 +-
 6 files changed, 248 insertions(+), 36 deletions(-)
 create mode 100644 backend/yjs/ShanxiAuditPRoxy.yjs
 create mode 100644 backend/yjs/ShanxiDataRepo.yjs
 create mode 100644 backend/yjs/ShanxiGlobalRouter.yjs
 create mode 100644 backend/yjs/ShanxiRegistry.yjs

diff --git a/backend/yjs/ControlProxy.yjs b/backend/yjs/ControlProxy.yjs
index 7fde766..17d4236 100755
--- a/backend/yjs/ControlProxy.yjs
+++ b/backend/yjs/ControlProxy.yjs
@@ -1,9 +1,9 @@
-import "repodetail.yjs";
-import "search.yjs";
-import "audit.yjs";
-import "networking.yjs";
 import "DAC.yjs";
 import "union.yjs";
+import "ShanxiAuditPRoxy.yjs";
+import "ShanxiDataRepo.yjs";
+import "ShanxiGlobalRouter.yjs";
+import "ShanxiRegistry";
 //网关为Gateway
 //路由器改名为Resolver，中文名为标识解析系统
 //搜索引擎改名为为Registry，中文名为注册表系统
@@ -54,14 +54,14 @@ contract ControlProxy {
         };
     }
 //网关需新增的接口
-    @Description("参数为，{\"doId\":\"bdware.ss/Repox\"}")
-    export function pingRepo(arg) {
-        arg = convertArgToJson(arg);
-        if (arg.doId ==undefined ){
-            return {
-            "msg":"missing arguments repoId ", "code":1
-            };
-        }
+    //@Description("参数为，{\"doId\":\"bdware.ss/Repox\"}")
+    //export function pingRepo(arg) {
+        //arg = convertArgToJson(arg);
+        //if (arg.doId ==undefined ){
+        //    return {
+        //    "msg":"missing arguments repoId ", "code":1
+        //    };
+        //}
         // var ret = executeContract("Gateway", "pingRepo", arg.doId);
         // ret = ret.result;
         // if (ret.rrt > 0)
@@ -70,8 +70,8 @@ contract ControlProxy {
         //     }; else return {
         // "msg":"repo is unconnected", "code":1
         // };
-        return org.bdware.sc.controlproxy.RepoProxy.pingRepo(arg.doId);
-    }
+        //return org.bdware.sc.controlproxy.RepoProxy.pingRepo(arg.doId);
+    //}
 
     @Description("shanxi/TestLocal shanxi/Repository")
     export function testPingRepo(arg) {
@@ -83,14 +83,14 @@ contract ControlProxy {
         return org.bdware.sc.controlproxy.RepoProxy.getRepoStatistics(arg);
     }
 //网关的接口
-    @Description("无参数")
-    export function getRepoList(arg) {
+    //@Description("无参数")
+    //export function getRepoList(arg) {
     //use configed  arg.routerId;
-        ret = executeContract(Global.router, "listRepo", "");
+    //    ret = executeContract(Global.router, "listRepo", "");
         //ret=executeContract("Gateway","listLocalRepo","");
         //var list = ret.result
-        return ret.result;
-    }
+    //    return ret.result;
+    //}
 //网关的接口
     @Description("参数为 {\"doId\":\"bdware.ss/Repox\"}")
     export function deleteRepo(arg) {
@@ -106,17 +106,17 @@ contract ControlProxy {
         };
     }
 //网关的接口 需新增
-    @Description("参数为 [{\"doId\":\"bdware.ss/Repox\"},{\"doId\":\"bdware.ss/Repoy\"}]")
-    export function deleteRepoList(arg) {
-        arg = convertArgToJson(arg);
-        var ret = [];
-        for (var i = 0;
-        i<arg.length;
-        i++){
-            ret.push(deleteRepo(arg[i]));
-        }
-        return ret;
-    }
+    //@Description("参数为 [{\"doId\":\"bdware.ss/Repox\"},{\"doId\":\"bdware.ss/Repoy\"}]")
+    //export function deleteRepoList(arg) {
+    //    arg = convertArgToJson(arg);
+    //    var ret = [];
+    //    for (var i = 0;
+    //    i<arg.length;
+    //    i++){
+    //        ret.push(deleteRepo(arg[i]));
+    //    }
+    //    return ret;
+    //}
 //网关的接口
     @Description("参数为 {\"doId\":..., \"address\":..., \"owner\":..., }")
     export function updateRepo(arg) {
@@ -136,11 +136,11 @@ contract ControlProxy {
         return org.bdware.sc.controlproxy.TopologyCollector.getLevelTopology(arg/1.0);
     }
 
-    export function getAllTopology(arg) {
-        if (arg==null|| arg.length==0) {
-            return org.bdware.sc.controlproxy.TopologyCollector.getLevelTopology(2);
-        } else return org.bdware.sc.controlproxy.TopologyCollector.getLevelTopology(arg/1.0);
-    }
+    //export function getAllTopology(arg) {
+    //    if (arg==null|| arg.length==0) {
+    //        return org.bdware.sc.controlproxy.TopologyCollector.getLevelTopology(2);
+    //    } else return org.bdware.sc.controlproxy.TopologyCollector.getLevelTopology(arg/1.0);
+    //}
 //总体拓扑图
 //@范博
     export function setTopologyLevel(arg) {
diff --git a/backend/yjs/ShanxiAuditPRoxy.yjs b/backend/yjs/ShanxiAuditPRoxy.yjs
new file mode 100644
index 0000000..71f603b
--- /dev/null
+++ b/backend/yjs/ShanxiAuditPRoxy.yjs
@@ -0,0 +1,8 @@
+module ShanxiAuditPRoxy{
+    export function countDOIPRecordByDate() {
+        return executeContract("AuditProxy","countDOIPRecordByDate",arg).result;
+    }
+    export function getDOIPStatistic() {
+        return executeContract("AuditProxy","getDOIPStatistic",arg).result;
+    }
+}
\ No newline at end of file
diff --git a/backend/yjs/ShanxiDataRepo.yjs b/backend/yjs/ShanxiDataRepo.yjs
new file mode 100644
index 0000000..77a0b6b
--- /dev/null
+++ b/backend/yjs/ShanxiDataRepo.yjs
@@ -0,0 +1,41 @@
+module ShanxiDataRepo{
+    export function getDataDoList() {
+        return executeContract("DataRepo","getDataDoList",arg).result;
+    }
+    export function deleteDataDO() {
+        return executeContract("DataRepo","deleteDataDO",arg).result;
+    }
+    export function createDataDO() {
+        return executeContract("DataRepo","createDataDO",arg).result;
+    }
+    export function retrieveDataDO() {
+        return executeContract("DataRepo","retrieveDataDO",arg).result;
+    }
+    export function createViewDO() {
+        return executeContract("DataRepo","createViewDO",arg).result;
+    }
+    export function updateViewDO() {
+        return executeContract("DataRepo","updateViewDO",arg).result;
+    }
+    export function getViewDOList() {
+        return executeContract("DataRepo","getViewDOList",arg).result;
+    }
+    export function deleteViewDO() {
+        return executeContract("DataRepo","deleteViewDO",arg).result;
+    }
+    export function retrieveViewDO() {
+        return executeContract("DataRepo","retrieveViewDO",arg).result;
+    }
+    export function addAuthedUser() {
+        return executeContract("DataRepo","addAuthedUser",arg).result;
+    }
+    export function deleteAuthedUser() {
+        return executeContract("DataRepo","deleteAuthedUser",arg).result;
+    }
+    export function addAuthedNode() {
+        return executeContract("DataRepo","addAuthedNode",arg).result;
+    }
+    export function deleteAuthedNode() {
+        return executeContract("DataRepo","deleteAuthedNode",arg).result;
+    }
+}
\ No newline at end of file
diff --git a/backend/yjs/ShanxiGlobalRouter.yjs b/backend/yjs/ShanxiGlobalRouter.yjs
new file mode 100644
index 0000000..1f136b9
--- /dev/null
+++ b/backend/yjs/ShanxiGlobalRouter.yjs
@@ -0,0 +1,98 @@
+module ShanxiGlobalRouter{
+    export function getAllTopology() {
+        return executeContract("GlobalRouter","getAllTopology",arg).result;
+    }
+    export function getRouterInfo(arg){
+        if (!checkPermission(requester)) {
+            YancloudUtil.exceptionReturn({"msg":"no permission","code":1});
+        }
+        var ret=executeContract(Global.router,"getRouterInfo",arg);
+        var obj = ret.result;
+        if (obj.result=="success" || obj.result == undefined) {
+            obj.result=undefined;
+            obj.code=0;
+        } else {
+            YancloudUtil.exceptionReturn({"msg":obj.data,"code":1});
+        }
+        return obj;
+    }
+    export function listLRS(arg){
+        if (!checkPermission(requester)) {
+            YancloudUtil.exceptionReturn({"msg":"no permission","code":1});
+        }
+        var ret=executeContract(Global.router,"listLRS","");
+        var obj = ret.result;
+        if (obj.result=="success" || obj.result == undefined) {
+            obj.result=undefined;
+            obj.code=0;
+        } else {
+            YancloudUtil.exceptionReturn({"msg":obj.data,"code":1});
+        }
+        return obj;
+    }
+    @Descripton("参数为，{\"date\": 1642467459759,\"oldName\": \"路由器\",\"oldDoId\": \"bdwaretest.loccall.next0\",\"name\": \"next路由器\",\"doId\": \"bdwaretest.loccall.next1\",\"version\": \"2.1\",\"address\": \"127.0.0.1:2222\",\"status\": \"已审核\",\"protocol\": \"IRP\",\"pubKey\": \"04d1924329f72ced148f6f333fb985ccbaa31b1e3aacf10be5f43d4a4ff5ad88899a005e79e37fc06993e1d66ada8cf8b711cb36f59538bb7d3e39e70fa9360ddd\"}")
+    @ArgSchema({"!date": "number","!oldName": "string","!oldDoId": "string","!name": "string","!doId": "string","!version":"string","!address": "string","status": "string","!protocol": "string","!pubKey": "string"})
+    export function updateLRS(arg){
+        if (!checkPermission(requester)) {
+            YancloudUtil.exceptionReturn({"msg":"no permission","code":1});
+        }
+        var ret=executeContract(Global.router,"updateLRS",arg);
+        var obj = ret.result;
+        if (obj.result=="success" || obj.result == undefined) {
+            obj.result=undefined;
+            obj.code=0;
+        } else {
+            YancloudUtil.exceptionReturn({"msg":obj.data,"code":1});
+        }
+        return obj;
+    }
+    export function listRepository(arg){
+        if (!checkPermission(requester)) {
+            YancloudUtil.exceptionReturn({"msg":"no permission","code":1});
+        }
+        var ret=executeContract("GlobalRouter","listRepository","");
+        var obj = ret.result;
+        if (obj.result=="success" || obj.result == undefined) {
+            obj.result=undefined;
+            obj.code=0;
+        } else {
+            YancloudUtil.exceptionReturn({"msg":obj.data,"code":1});
+        }
+        return obj;
+    }
+    @Descripton("参数为，{\"date\": 1642467459759,\"name\": \"Repo1\",\"doId\": \"bdwaretest.loccall/Repo1\",\"version\": \"2.1\"，\"address\": \"tcp://127.0.0.1:21042\",\"status\": \"已审核\",\"protocol\": \"DOIP\",\"pubKey\": \"04d1924329f72ced148f6f333fb985ccbaa31b1e3aacf10be5f43d4a4ff5ad88899a005e79e37fc06993e1d66ada8cf8b711cb36f59538bb7d3e39e70fa9360ddd\"}")
+    @ArgSchema({"!date": "number","!name": "string","!doId": "string","!version":"string","!address": "string","status": "string","!protocol": "string","!pubKey": "string"})
+    export function createRepository(arg){
+        if (!checkPermission(requester)) {
+            YancloudUtil.exceptionReturn({"msg":"no permission","code":1});
+        }
+        var ret=executeContract("GlobalRouter","createRepository",arg);
+        var obj = ret.result;
+        if (obj.result=="success" || obj.result == undefined) {
+            obj.result=undefined;
+            obj.code=0;
+        } else {
+            YancloudUtil.exceptionReturn({"msg":obj.data,"code":1});
+        }
+        return obj;
+    }
+    @Descripton("参数为，{\"date\": 1642467459759,\"oldName\": \"Repo0\",\"oldDoId\": \"bdwaretest.loccall/Repo0\",\"name\": \"Repo1\",\"doId\": \"bdwaretest.loccall/Repo1\",\"version\": \"2.1\"，\"address\": \"tcp://127.0.0.1:21042\",\"status\": \"已审核\",\"protocol\": \"DOIP\",\"pubKey\": \"04d1924329f72ced148f6f333fb985ccbaa31b1e3aacf10be5f43d4a4ff5ad88899a005e79e37fc06993e1d66ada8cf8b711cb36f59538bb7d3e39e70fa9360ddd\"}")
+    @ArgSchema({"!date": "number","!oldName": "string","!oldDoId": "string","!name": "string","!doId": "string","!version":"string","!address": "string","status": "string","!protocol": "string","!pubKey": "string"})
+    export function updateRepository(arg){
+        if (!checkPermission(requester)) {
+            YancloudUtil.exceptionReturn({"msg":"no permission","code":1});
+        }
+        var ret=executeContract("GlobalRouter","updateRepository",arg);
+        var obj = ret.result;
+        if (obj.result=="success" || obj.result == undefined) {
+            obj.result=undefined;
+            obj.code=0;
+        } else {
+            YancloudUtil.exceptionReturn({"msg":obj.data,"code":1});
+        }
+        return obj;
+    }
+    export function getUpperRouterInfo() {
+        return executeContract("GlobalRouter","getUpperRouterInfo",arg).result;
+    }
+}
\ No newline at end of file
diff --git a/backend/yjs/ShanxiRegistry.yjs b/backend/yjs/ShanxiRegistry.yjs
new file mode 100644
index 0000000..20b4865
--- /dev/null
+++ b/backend/yjs/ShanxiRegistry.yjs
@@ -0,0 +1,65 @@
+module ShanxiRegistry{
+    export function getAllRepoCount() {
+        return executeContract("Registry","getAllRepoCount",arg).result;
+    }
+    export function getAllDoCount() {
+        return executeContract("Registry","getAllDoCount",arg).result;
+    }
+    export function getAllSearchCount() {
+        return executeContract("Registry","getAllSearchCount",arg).result;
+    }
+    export function getIndexStatistics() {
+        return executeContract("Registry","getIndexStatistics",arg).result;
+    }
+    export function getRepoList() {
+        return executeContract("Registry","getRepoList",arg).result;
+    }
+    export function pingRepo() {
+        return executeContract("Registry","pingRepo",arg).result;
+    }
+    export function addRepoToRegistry() {
+        return executeContract("Registry","addRepoToRegistry",arg).result;
+    }
+    export function deleteRepoList() {
+        return executeContract("ControlProxy","deleteRepoList",arg).result;
+    }
+    export function listDataRequirements() {
+        return executeContract("Registry","listDataRequirements",arg).result;
+    }
+    export function createDataRequirements() {
+        return executeContract("Registry","createDataRequirements",arg).result;
+    }
+    export function issueDataRequirement() {
+        return executeContract("Registry","issueDataRequirement",arg).result;
+    }
+    export function updateDataRequirements() {
+        return executeContract("Registry","updateDataRequirements",arg).result;
+    }
+    export function getDataRequirement() {
+        return executeContract("Registry","getDataRequirement",arg).result;
+    }
+    export function deleteDataRequirements() {
+        return executeContract("Registry","deleteDataRequirements",arg).result;
+    }
+    export function getDoCount() {
+        return executeContract("Registry","getDoCount",arg).result;
+    }
+    export function addSubRegistry() {
+        return executeContract("Registry","addSubRegistry",arg).result;
+    }
+    export function deleteSubRegistry() {
+        return executeContract("Registry","deleteSubRegistry",arg).result;
+    }
+    export function listSubRegistry() {
+        return executeContract("Registry","listSubRegistry",arg).result;
+    }
+    export function getRelationInfo() {
+        return executeContract("Registry","getRelationInfo",arg).result;
+    }
+    @ArgSchema({"!params":[{"!type":"string","!keyword":"integer"}],"count":"integer","offset":"integer"})
+    export function search(arg){
+        arg = convertArgToJson(arg);
+        var res=executeContract("Registry","search",arg);
+        return res.result;
+    }
+}
\ No newline at end of file
diff --git a/backend/yjs/audit.yjs b/backend/yjs/audit.yjs
index 095b5ca..cec1642 100755
--- a/backend/yjs/audit.yjs
+++ b/backend/yjs/audit.yjs
@@ -1,7 +1,7 @@
 module Audit{
   export function getDoipAction(){
     return [
-            { value: 0, name: '0.DOIP/Op.Hello' },
+            { value: 0, name: '0.DOIP/Op.Hello' },niz
             { value: 1, name: '0.DOIP/Op.ListOperations' },
             { value: 2, name: '0.DOIP/Op.Retrieve' },
             { value: 3, name: '0.DOIP/Op.Create' },