From 335cdb14f290947646af12534050477e5b5fcde4 Mon Sep 17 00:00:00 2001 From: snoop Date: Thu, 8 Jun 2017 10:46:29 +0900 Subject: [PATCH] added createlist --- proxy/service.go | 2 +- proxy/target/target_service.go | 33 +++++++++++++++++------------ proxy/target/target_service_test.go | 2 +- 3 files changed, 22 insertions(+), 15 deletions(-) diff --git a/proxy/service.go b/proxy/service.go index e798998..8d89028 100644 --- a/proxy/service.go +++ b/proxy/service.go @@ -15,7 +15,7 @@ func InvokeDB(targetDb, methodName string, param map[string]string) (string) { in.Method = methodName in.Param = param - conn, err := grpc.Dial("192.168.1.103:50006", grpc.WithInsecure()) + conn, err := grpc.Dial(":50006", grpc.WithInsecure()) if err != nil { log.Fatal("Rpc Error: ", err) diff --git a/proxy/target/target_service.go b/proxy/target/target_service.go index c2ec311..33da572 100644 --- a/proxy/target/target_service.go +++ b/proxy/target/target_service.go @@ -6,6 +6,7 @@ import ( "git.loafle.net/overflow/overflow_proxy_service/proxy/member" "git.loafle.net/overflow/overflow_proxy_service/proxy" + "fmt" ) type Target struct { @@ -74,19 +75,7 @@ func (t *TargetService)Create(tm *Target) string { func (t *TargetService)CreateList(tmlist *[]*Target) string { - //bytes, err := json.Marshal(tmlist) - // - //if err != nil { - // return "" - //} - // - //m := make(map[string]string) - //m["java.util.List"] = string(bytes) - // - //out := proxy.InvokeDB("target", "createAll", m) - // - // - //return out; + outlist := make([]string, 0) for _, ttt := range *tmlist { @@ -102,4 +91,22 @@ func (t *TargetService)CreateList(tmlist *[]*Target) string { return string(bytes) +} + +func (t *TargetService)CreateListTT(tmlist *[]*Target) string { + bytes, err := json.Marshal(tmlist) + + if err != nil { + return "" + } + + m := make(map[string]string) + m["java.util.List"] = string(bytes) + + fmt.Println(string(bytes)) + out := proxy.InvokeDB("target", "createAll", m) + // + // + return out; + //return "" } \ No newline at end of file diff --git a/proxy/target/target_service_test.go b/proxy/target/target_service_test.go index 17b881b..a2df2f3 100644 --- a/proxy/target/target_service_test.go +++ b/proxy/target/target_service_test.go @@ -108,7 +108,7 @@ func TestCreateAll(t *testing.T) { ts := NewTargetService() - ts.CreateList(&tl) + ts.CreateListTT(&tl) }