overflow_backup_2018_0455/overflow_proxy_service
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added

Browse Source 
createlist
This commit is contained in:
snoop 2017-06-08 10:46:29 +09:00
parent 6f23666d99
commit 335cdb14f2
3 changed files with 22 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
proxy/service.go
View File

@ -15,7 +15,7 @@ func InvokeDB(targetDb, methodName string, param map[string]string) (string) {
in.Method = methodName in.Method = methodName
in.Param = param in.Param = param
conn, err := grpc.Dial("192.168.1.103:50006", grpc.WithInsecure()) conn, err := grpc.Dial(":50006", grpc.WithInsecure())
if err != nil { if err != nil {
log.Fatal("Rpc Error: ", err) log.Fatal("Rpc Error: ", err)

33
proxy/target/target_service.go
View File

@ -6,6 +6,7 @@ import (
"git.loafle.net/overflow/overflow_proxy_service/proxy/member" "git.loafle.net/overflow/overflow_proxy_service/proxy/member"
"git.loafle.net/overflow/overflow_proxy_service/proxy" "git.loafle.net/overflow/overflow_proxy_service/proxy"
"fmt"
) )
type Target struct { type Target struct {
@ -74,19 +75,7 @@ func (t *TargetService)Create(tm *Target) string {
func (t *TargetService)CreateList(tmlist *[]*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) outlist := make([]string, 0)
for _, ttt := range *tmlist { for _, ttt := range *tmlist {
@ -102,4 +91,22 @@ func (t *TargetService)CreateList(tmlist *[]*Target) string {
return string(bytes) 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 ""
} }

2
proxy/target/target_service_test.go
View File

@ -108,7 +108,7 @@ func TestCreateAll(t *testing.T) {
ts := NewTargetService() ts := NewTargetService()
ts.CreateList(&tl) ts.CreateListTT(&tl)
} }