songchunqiao/ControlProxy
1
0
Fork 0
forked from iod/ControlProxy
Code Pull Requests Activity

all interface refactor

Browse Source
This commit is contained in:
scq 2023-07-11 22:57:57 +08:00
parent e425d2108a
commit 24b1b15ac0
6 changed files with 248 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
backend/yjs/ControlProxy.yjs
View File

@ -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) {

8
backend/yjs/ShanxiAuditPRoxy.yjs Normal file
View File

@ -0,0 +1,8 @@
module ShanxiAuditPRoxy{
export function countDOIPRecordByDate() {
return executeContract("AuditProxy","countDOIPRecordByDate",arg).result;
}
export function getDOIPStatistic() {
return executeContract("AuditProxy","getDOIPStatistic",arg).result;
}
}

41
backend/yjs/ShanxiDataRepo.yjs Normal file
View File

@ -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;
}
}

98
backend/yjs/ShanxiGlobalRouter.yjs Normal file
View File

@ -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;
}
}

65
backend/yjs/ShanxiRegistry.yjs Normal file
View File

@ -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;
}
}

2
backend/yjs/audit.yjs
View File

@ -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' },