Procházet zdrojové kódy

Merge branch 'master' of http://git.shengws.com/csx/gdyb

csx před 3 roky
rodič
revize
68d388bcd8
1 změnil soubory, kde provedl 34 přidání a 36 odebrání
  1. 34 36
      service/jsyb_service.go

+ 34 - 36
service/jsyb_service.go Zobrazit soubor

1
 package service
1
 package service
2
 
2
 
3
 import (
3
 import (
4
-	"bytes"
5
 	"crypto/hmac"
4
 	"crypto/hmac"
6
 	"crypto/sha1"
5
 	"crypto/sha1"
7
 	"encoding/base64"
6
 	"encoding/base64"
8
 	"encoding/json"
7
 	"encoding/json"
9
 	"fmt"
8
 	"fmt"
10
 	"gdyb/utils/csbhttp"
9
 	"gdyb/utils/csbhttp"
11
-	"io/ioutil"
12
-	"net/http"
13
 	"strconv"
10
 	"strconv"
14
 	"time"
11
 	"time"
15
 )
12
 )
53
 	input["data"] = inputData
50
 	input["data"] = inputData
54
 	inputMessage["input"] = input //交易输入
51
 	inputMessage["input"] = input //交易输入
55
 
52
 
56
-	var inputLog string
53
+	//var inputLog string
57
 	bytesData, _ := json.Marshal(inputMessage)
54
 	bytesData, _ := json.Marshal(inputMessage)
58
-	inputLog = string(bytesData)
55
+	//inputLog = string(bytesData)
59
 	fmt.Println(string(bytesData))
56
 	fmt.Println(string(bytesData))
60
 	if err != nil {
57
 	if err != nil {
61
 		fmt.Println(err.Error())
58
 		fmt.Println(err.Error())
62
 		return err.Error(), ""
59
 		return err.Error(), ""
63
 	}
60
 	}
64
-	reader := bytes.NewReader(bytesData)
65
-
66
-	request, err := http.NewRequest("POST", "http://10.72.3.87:8086/CSB/1101", reader)
67
-	if err != nil {
68
-		fmt.Println(err.Error())
69
-		return err.Error(), ""
70
-	}
71
-	key := "_api_access_key=" + access_key + "&_api_name=" + "hssServives" + "&_api_timestamp=" + strconv.FormatInt(timestamp, 10) + "&_api_version=" + "1.0.0"
72
-
73
-	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
74
-	request.Header.Set("_api_timestamp", strconv.FormatInt(timestamp, 10))
75
-	request.Header.Set("_api_name", "hssServives")
76
-	request.Header.Set("_api_version", "1.0.0")
77
-	request.Header.Set("_api_access_key", access_key)
78
-	request.Header.Set("_api_signature", hmacsha1(key, secret_key))
79
-
80
-	client := http.Client{}
81
-	resp, err := client.Do(request)
82
-	if err != nil {
83
-		fmt.Println(err.Error())
84
-		return err.Error(), ""
85
-	}
86
-	respBytes, err := ioutil.ReadAll(resp.Body)
87
-	if err != nil {
88
-		fmt.Println(err.Error())
89
-		return err.Error(), ""
90
-	}
91
-	fmt.Println(string(respBytes))
92
-	str := string(respBytes)
93
-	return str, inputLog
94
-	//return HttpRequest(request_url, access_key, secret_key, timestamp, bytesData, string(bytesData)), ""
61
+	//reader := bytes.NewReader(bytesData)
62
+	//
63
+	//request, err := http.NewRequest("POST", "http://10.72.3.87:8086/CSB/1101", reader)
64
+	//if err != nil {
65
+	//	fmt.Println(err.Error())
66
+	//	return err.Error(), ""
67
+	//}
68
+	//key := "_api_access_key=" + access_key + "&_api_name=" + "hssServives" + "&_api_timestamp=" + strconv.FormatInt(timestamp, 10) + "&_api_version=" + "1.0.0"
69
+	//
70
+	//request.Header.Set("Content-Type", "application/json;charset=UTF-8")
71
+	//request.Header.Set("_api_timestamp", strconv.FormatInt(timestamp, 10))
72
+	//request.Header.Set("_api_name", "hssServives")
73
+	//request.Header.Set("_api_version", "1.0.0")
74
+	//request.Header.Set("_api_access_key", access_key)
75
+	//request.Header.Set("_api_signature", hmacsha1(key, secret_key))
76
+	//
77
+	//client := http.Client{}
78
+	//resp, err := client.Do(request)
79
+	//if err != nil {
80
+	//	fmt.Println(err.Error())
81
+	//	return err.Error(), ""
82
+	//}
83
+	//respBytes, err := ioutil.ReadAll(resp.Body)
84
+	//if err != nil {
85
+	//	fmt.Println(err.Error())
86
+	//	return err.Error(), ""
87
+	//}
88
+	//fmt.Println(string(respBytes))
89
+	//str := string(respBytes)
90
+	//return str, inputLog
91
+	request_url = "http://10.72.3.87:8086/CSB/1101"
92
+	return HttpRequest(request_url, access_key, secret_key, timestamp, bytesData, string(bytesData)), ""
95
 }
93
 }
96
 func HttpRequest(url string, ak string, sk string, timestamp int64, requestByte []byte, json string) string {
94
 func HttpRequest(url string, ak string, sk string, timestamp int64, requestByte []byte, json string) string {
97
 	fmt.Println(url)
95
 	fmt.Println(url)