dtapps
/
go-library
1
0
Fork 0
Code Issues Pull Requests Projects Releases 40 Wiki Activity

update service log

Browse Source
master
李光春 3 years ago
parent faef1d74e0
commit 8be19c69a5
13 changed files with 32 additions and 24 deletions
Show Stats Download Patch File Download Diff File

5
service/eastiot/app.go
Unescape View File

@ -2,6 +2,7 @@ package eastiot
import ( import (
"errors" "errors"
"fmt"
"go.uber.org/zap" "go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"net/http" "net/http"
@ -26,7 +27,7 @@ func (app *App) request(url string, params map[string]interface{}, method string
get, err := gohttp.Get(url, params) get, err := gohttp.Get(url, params)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(get) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", get.Body))
} }
return get.Body, err return get.Body, err
case http.MethodPost: case http.MethodPost:
@ -34,7 +35,7 @@ func (app *App) request(url string, params map[string]interface{}, method string
postJson, err := gohttp.PostForm(url, params) postJson, err := gohttp.PostForm(url, params)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(postJson) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", postJson.Body))
} }
return postJson.Body, err return postJson.Body, err
default: default:

4
service/ejiaofei/app.go
Unescape View File

@ -29,7 +29,7 @@ func (app *App) request(url string, params map[string]interface{}, method string
get, err := gohttp.Get(url, params) get, err := gohttp.Get(url, params)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(get) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", get.Body))
} }
return get.Body, err return get.Body, err
case http.MethodPost: case http.MethodPost:
@ -37,7 +37,7 @@ func (app *App) request(url string, params map[string]interface{}, method string
postJson, err := gohttp.PostForm(url, params) postJson, err := gohttp.PostForm(url, params)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(postJson) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", postJson.Body))
} }
return postJson.Body, err return postJson.Body, err
default: default:

9
service/jd/app.go
Unescape View File

@ -2,6 +2,7 @@ package jd
import ( import (
"encoding/json" "encoding/json"
"fmt"
"go.uber.org/zap" "go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
) )
@ -22,15 +23,15 @@ func (app *App) request(params map[string]interface{}) (resp []byte, err error)
// 签名 // 签名
app.Sign(params) app.Sign(params)
// 发送请求 // 发送请求
httpGet, err := gohttp.PostForm("https://api.jd.com/routerjson", params) get, err := gohttp.PostForm("https://api.jd.com/routerjson", params)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(httpGet) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", get.Body))
} }
// 检查错误 // 检查错误
var errResp ErrResp var errResp ErrResp
_ = json.Unmarshal(httpGet.Body, &errResp) _ = json.Unmarshal(get.Body, &errResp)
return httpGet.Body, err return get.Body, err
} }
// GoodsPriceToInt64 商品券后价 // GoodsPriceToInt64 商品券后价

3
service/kashangwl/app.go
Unescape View File

@ -2,6 +2,7 @@ package kashangwl
import ( import (
"encoding/json" "encoding/json"
"fmt"
"go.uber.org/zap" "go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"time" "time"
@ -26,7 +27,7 @@ func (app *App) request(url string, params map[string]interface{}) ([]byte, erro
postJson, err := gohttp.PostJson(url, paramsStr) postJson, err := gohttp.PostJson(url, paramsStr)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(postJson.Body) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", postJson.Body))
} }
return postJson.Body, err return postJson.Body, err
} }

3
service/meituan/app.go
Unescape View File

@ -3,6 +3,7 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
"errors" "errors"
"fmt"
"go.uber.org/zap" "go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"net/http" "net/http"
@ -31,7 +32,7 @@ func (app *App) request(url string, params map[string]interface{}, method string
postJson, err := gohttp.PostJson(url, paramsStr) postJson, err := gohttp.PostJson(url, paramsStr)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(postJson) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", postJson.Body))
} }
return postJson.Body, err return postJson.Body, err
default: default:

8
service/pinduoduo/app.go
Unescape View File

@ -38,15 +38,15 @@ func (app *App) request(params map[string]interface{}) (resp []byte, err error)
// 签名 // 签名
app.Sign(params) app.Sign(params)
// 发送请求 // 发送请求
httpGet, err := gohttp.Get("https://gw-api.pinduoduo.com/api/router", params) get, err := gohttp.Get("https://gw-api.pinduoduo.com/api/router", params)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(httpGet) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", get.Body))
} }
// 检查错误 // 检查错误
var errResp ErrResp var errResp ErrResp
_ = json.Unmarshal(httpGet.Body, &errResp) _ = json.Unmarshal(get.Body, &errResp)
return httpGet.Body, err return get.Body, err
} }
func (app *App) SalesTipParseInt64(salesTip string) int64 { func (app *App) SalesTipParseInt64(salesTip string) int64 {

2
service/pintoto/app.go
Unescape View File

@ -56,7 +56,7 @@ func (app *App) request(url string, params map[string]interface{}) ([]byte, erro
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(response.Body) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", body))
} }
// 检查错误 // 检查错误

8
service/taobao/app.go
Unescape View File

@ -30,15 +30,15 @@ func (app *App) request(params map[string]interface{}) (resp []byte, err error)
// 签名 // 签名
app.Sign(params) app.Sign(params)
// 发送请求 // 发送请求
httpGet, err := gohttp.Get("https://eco.taobao.com/router/rest", params) get, err := gohttp.Get("https://eco.taobao.com/router/rest", params)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(httpGet) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", get.Body))
} }
// 检查错误 // 检查错误
var errResp ErrResp var errResp ErrResp
_ = json.Unmarshal(httpGet.Body, &errResp) _ = json.Unmarshal(get.Body, &errResp)
return httpGet.Body, err return get.Body, err
} }
func (app *App) ZkFinalPriceParseInt64(ZkFinalPrice string) int64 { func (app *App) ZkFinalPriceParseInt64(ZkFinalPrice string) int64 {

3
service/wechatmp/app.go
Unescape View File

@ -3,6 +3,7 @@ package wechatmp
import ( import (
"bytes" "bytes"
"encoding/json" "encoding/json"
"fmt"
"go.uber.org/zap" "go.uber.org/zap"
"io/ioutil" "io/ioutil"
"net/http" "net/http"
@ -40,7 +41,7 @@ func (app *App) request(url string, params map[string]interface{}, method string
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(response.Body) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", resp))
} }
// 检查请求错误 // 检查请求错误

3
service/wechatpayapiv3/app.go
Unescape View File

@ -3,6 +3,7 @@ package wechatpayapiv3
import ( import (
"bytes" "bytes"
"encoding/json" "encoding/json"
"fmt"
"go.uber.org/zap" "go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gorequest" "gopkg.in/dtapps/go-library.v3/utils/gorequest"
"io/ioutil" "io/ioutil"
@ -73,7 +74,7 @@ func (app *App) request(url string, params map[string]interface{}, method string
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(result) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", resp))
} }
// 检查请求错误 // 检查请求错误

3
service/wechatqy/app.go
Unescape View File

@ -2,6 +2,7 @@ package wechatqy
import ( import (
"encoding/json" "encoding/json"
"fmt"
"go.uber.org/zap" "go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
) )
@ -18,7 +19,7 @@ func (app *App) request(url string, params map[string]interface{}) (body []byte,
postJson, err := gohttp.PostJson(url, paramsStr) postJson, err := gohttp.PostJson(url, paramsStr)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(postJson) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", postJson.Body))
} }
return postJson.Body, err return postJson.Body, err
} }

3
service/wechatunion/app.go
Unescape View File

@ -2,6 +2,7 @@ package wechatunion
import ( import (
"encoding/json" "encoding/json"
"fmt"
"go.uber.org/zap" "go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"net/http" "net/http"
@ -28,7 +29,7 @@ func (app *App) request(url string, params map[string]interface{}, method string
postJson, err := gohttp.PostJson(url, paramsStr) postJson, err := gohttp.PostJson(url, paramsStr)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(postJson) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", postJson.Body))
} }
return postJson.Body, err return postJson.Body, err
} }

2
service/wikeyun/app.go
Unescape View File

@ -22,7 +22,7 @@ func (app *App) request(url string, params map[string]interface{}) (resp []byte,
postForm, err := gohttp.PostForm(requestUrl, params) postForm, err := gohttp.PostForm(requestUrl, params)
// 日志 // 日志
if app.ZapLog != nil { if app.ZapLog != nil {
app.ZapLog.Sugar().Info(postForm) app.ZapLog.Sugar().Info(fmt.Sprintf("%s", postForm.Body))
} }
return postForm.Body, err return postForm.Body, err
} }

Write Preview
Loading…
Cancel
Save