diff --git a/.idea/codeStyles/Project.xml b/.idea/codeStyles/Project.xml new file mode 100644 index 0000000..919ce1f --- /dev/null +++ b/.idea/codeStyles/Project.xml @@ -0,0 +1,7 @@ + + + + + + \ No newline at end of file diff --git a/.idea/codeStyles/codeStyleConfig.xml b/.idea/codeStyles/codeStyleConfig.xml new file mode 100644 index 0000000..a55e7a1 --- /dev/null +++ b/.idea/codeStyles/codeStyleConfig.xml @@ -0,0 +1,5 @@ + + + + \ No newline at end of file diff --git a/.idea/git_toolbox_prj.xml b/.idea/git_toolbox_prj.xml new file mode 100644 index 0000000..02b915b --- /dev/null +++ b/.idea/git_toolbox_prj.xml @@ -0,0 +1,15 @@ + + + + + + + \ No newline at end of file diff --git a/src/main/java/com/tytsyw/bip/common/OnlineTransfer.java b/src/main/java/com/tytsyw/bip/common/OnlineTransfer.java index 0cce426..b46c4cb 100644 --- a/src/main/java/com/tytsyw/bip/common/OnlineTransfer.java +++ b/src/main/java/com/tytsyw/bip/common/OnlineTransfer.java @@ -39,8 +39,9 @@ public class OnlineTransfer implements IOnlineTransfer { log.info("onlineTransfer " + map); JSONObject onlineTransfer = MainUtil.getMockDataJson("onlineTransfer_rsp_01.json"); - Map reqSvcHeader = (Map)map.get(MainUtil.ReqSvcHeader); - Map svcBody = (Map)map.get(MainUtil.SvcBody); + Map reqSvcHeader = (Map) map.get(MainUtil.ReqSvcHeader); + Map svcBody = (Map) map.get(MainUtil.SvcBody); + log.info("转账 " + svcBody.get("preLogno") + ":" + svcBody.get("trotAccno") + "->" + svcBody.get("amt") + "->" + svcBody.get("trinAccno")); MainUtil.copyMap(reqSvcHeader, onlineTransfer.getJSONObject(MainUtil.RspSvcHeader), svcHeaderMapping); MainUtil.copyMap(svcBody, onlineTransfer.getJSONObject(MainUtil.SvcBody), svcBodyMapping); diff --git a/src/main/java/com/tytsyw/bip/tools/CopyBipMetadata.java b/src/main/java/com/tytsyw/bip/tools/CopyBipMetadata.java index dd12722..a318cc0 100644 --- a/src/main/java/com/tytsyw/bip/tools/CopyBipMetadata.java +++ b/src/main/java/com/tytsyw/bip/tools/CopyBipMetadata.java @@ -15,9 +15,9 @@ public class CopyBipMetadata { //公共模块,后台系统 File common = new File(bipDir, "com.tytsyw.dsc.common\\src\\com"); - //服务定义和服务引用 + //服务定义,服务引用 File service = new File(bipDir, "com.tytsyw.dsc.service\\src\\com"); - //组合服务和服务接口 + //组合服务,服务接口 File scene = new File(bipDir, "com.tytsyw.dsc.scene\\src\\com"); File outPutDir = new File(metadataDir, "tenantBusinessManager"); diff --git a/src/main/java/com/tytsyw/bip/tools/ZooKeeperServiceDiscovery.java b/src/main/java/com/tytsyw/bip/tools/ZooKeeperServiceDiscovery.java new file mode 100644 index 0000000..354e6f5 --- /dev/null +++ b/src/main/java/com/tytsyw/bip/tools/ZooKeeperServiceDiscovery.java @@ -0,0 +1,53 @@ +package com.tytsyw.bip.tools; + +import org.apache.zookeeper.KeeperException; +import org.apache.zookeeper.Watcher; +import org.apache.zookeeper.ZooKeeper; + +import java.io.IOException; +import java.util.List; + +public class ZooKeeperServiceDiscovery { + + private static final String ZK_ADDRESS = "localhost:2181"; + + public static void main(String[] args) throws IOException, InterruptedException, KeeperException { + ZooKeeper zk = new ZooKeeper(ZK_ADDRESS, 5000, event -> { + if (event.getState() == Watcher.Event.KeeperState.SyncConnected) { + System.out.println("Connected to ZooKeeper"); + } + }); + + // 等待连接建立 + Thread.sleep(2000); + + // 获取服务列表 + List services = zk.getChildren("/", false); + System.out.println("Services: " + services); + + //排序 + services.sort(String::compareTo); + + for (String service : services) { + System.out.println("Service: " + service); + List children = zk.getChildren("/" + service, false); + children.sort(String::compareTo); + for (String child : children) { + List children1 = zk.getChildren("/" + service + "/" + child, false); + System.out.println(" child: " + child + " children: " + children1); + for (String child1 : children1) { + if ("providers".equals(child1)) { + byte[] data = zk.getData("/" + service + "/" + child + "/" + child1, false, null); + if (data != null) { + System.out.println(" providers: " + new String(data)); + } + break; + } + } + } + + } + + zk.close(); + } +} \ No newline at end of file diff --git a/src/main/resources/mockData/commonValidate_rsp_LC233100.json b/src/main/resources/mockData/commonValidate_rsp_LC233100.json index 8a8cb3f..3a7d977 100644 --- a/src/main/resources/mockData/commonValidate_rsp_LC233100.json +++ b/src/main/resources/mockData/commonValidate_rsp_LC233100.json @@ -101,6 +101,10 @@ { "attrValue": "DetailIsFile", "attrName": "DetailStyle" + }, + { + "attrValue": "SEQ:18", + "attrName": "serviceSerialNo" } ] },