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

update service log

Browse Source
master
李光春 2 years ago
parent f8a7120529
commit faef1d74e0
14 changed files with 87 additions and 104 deletions
Show Stats Download Patch File Download Diff File

15
service/dingdanxia/app.go
Unescape View File

@ -2,14 +2,15 @@ package dingdanxia
import ( import (
"errors" "errors"
"fmt"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
"net/http" "net/http"
) )
type App struct { type App struct {
ApiKey string ApiKey string
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
func (app *App) request(url string, params map[string]interface{}, method string) ([]byte, error) { func (app *App) request(url string, params map[string]interface{}, method string) ([]byte, error) {
@ -20,18 +21,16 @@ 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.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "dingdanxia.log" app.ZapLog.Sugar().Info(fmt.Sprintf("%s", get.Body))
app.ZapLog.Logger.Sugar().Info(get)
} }
return get.Body, err return get.Body, err
case http.MethodPost: case http.MethodPost:
// 请求 // 请求
postJson, err := gohttp.PostForm(url, params) postJson, err := gohttp.PostForm(url, params)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "dingdanxia.log" app.ZapLog.Sugar().Info(fmt.Sprintf("%s", postJson.Body))
app.ZapLog.Logger.Sugar().Info(postJson)
} }
return postJson.Body, err return postJson.Body, err
default: default:

14
service/eastiot/app.go
Unescape View File

@ -2,8 +2,8 @@ package eastiot
import ( import (
"errors" "errors"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
"net/http" "net/http"
"time" "time"
) )
@ -11,7 +11,7 @@ import (
type App struct { type App struct {
AppID string AppID string
ApiKey string ApiKey string
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
func (app *App) request(url string, params map[string]interface{}, method string) ([]byte, error) { func (app *App) request(url string, params map[string]interface{}, method string) ([]byte, error) {
@ -25,18 +25,16 @@ 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.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "eastiot.log" app.ZapLog.Sugar().Info(get)
app.ZapLog.Logger.Sugar().Info(get)
} }
return get.Body, err return get.Body, err
case http.MethodPost: case http.MethodPost:
// 请求 // 请求
postJson, err := gohttp.PostForm(url, params) postJson, err := gohttp.PostForm(url, params)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "eastiot.log" app.ZapLog.Sugar().Info(postJson)
app.ZapLog.Logger.Sugar().Info(postJson)
} }
return postJson.Body, err return postJson.Body, err
default: default:

14
service/ejiaofei/app.go
Unescape View File

@ -3,8 +3,8 @@ package ejiaofei
import ( import (
"errors" "errors"
"fmt" "fmt"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
"gopkg.in/dtapps/go-library.v3/utils/gomd5" "gopkg.in/dtapps/go-library.v3/utils/gomd5"
"net/http" "net/http"
) )
@ -14,7 +14,7 @@ type App struct {
Pwd string Pwd string
Key string Key string
signStr string signStr string
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
func (app *App) request(url string, params map[string]interface{}, method string) ([]byte, error) { func (app *App) request(url string, params map[string]interface{}, method string) ([]byte, error) {
@ -28,18 +28,16 @@ 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.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "ejiaofei.log" app.ZapLog.Sugar().Info(get)
app.ZapLog.Logger.Sugar().Info(get)
} }
return get.Body, err return get.Body, err
case http.MethodPost: case http.MethodPost:
// 请求 // 请求
postJson, err := gohttp.PostForm(url, params) postJson, err := gohttp.PostForm(url, params)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "ejiaofei.log" app.ZapLog.Sugar().Info(postJson)
app.ZapLog.Logger.Sugar().Info(postJson)
} }
return postJson.Body, err return postJson.Body, err
default: default:

13
service/jd/app.go
Unescape View File

@ -2,14 +2,14 @@ package jd
import ( import (
"encoding/json" "encoding/json"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
) )
type App struct { type App struct {
AppKey string // 应用Key AppKey string // 应用Key
SecretKey string // 密钥 SecretKey string // 密钥
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
type ErrResp struct { type ErrResp struct {
@ -24,9 +24,8 @@ func (app *App) request(params map[string]interface{}) (resp []byte, err error)
// 发送请求 // 发送请求
httpGet, err := gohttp.PostForm("https://api.jd.com/routerjson", params) httpGet, err := gohttp.PostForm("https://api.jd.com/routerjson", params)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "jd.log" app.ZapLog.Sugar().Info(httpGet)
app.ZapLog.Logger.Sugar().Info(httpGet)
} }
// 检查错误 // 检查错误
var errResp ErrResp var errResp ErrResp

13
service/kashangwl/app.go
Unescape View File

@ -2,16 +2,16 @@ package kashangwl
import ( import (
"encoding/json" "encoding/json"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
"time" "time"
) )
// App 卡商网服务 // App 卡商网服务
type App struct { type App struct {
CustomerId int // 商家编号 CustomerId int // 商家编号
CustomerKey string // 商家密钥 CustomerKey string // 商家密钥
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
func (app *App) request(url string, params map[string]interface{}) ([]byte, error) { func (app *App) request(url string, params map[string]interface{}) ([]byte, error) {
@ -25,9 +25,8 @@ 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.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "kashangwl.log" app.ZapLog.Sugar().Info(postJson.Body)
app.ZapLog.Logger.Sugar().Info(postJson.Body)
} }
return postJson.Body, err return postJson.Body, err
} }

18
service/meituan/app.go
Unescape View File

@ -3,16 +3,16 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
"errors" "errors"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
"net/http" "net/http"
) )
// App 美团联盟 // App 美团联盟
type App struct { type App struct {
Secret string // 秘钥 Secret string // 秘钥
AppKey string // 渠道标记 AppKey string // 渠道标记
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
func (app *App) request(url string, params map[string]interface{}, method string) (resp []byte, err error) { func (app *App) request(url string, params map[string]interface{}, method string) (resp []byte, err error) {
@ -21,9 +21,8 @@ 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.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "meituan.log" app.ZapLog.Sugar().Info(get)
app.ZapLog.Logger.Sugar().Info(get)
} }
return get.Body, err return get.Body, err
case http.MethodPost: case http.MethodPost:
@ -31,9 +30,8 @@ func (app *App) request(url string, params map[string]interface{}, method string
paramsStr, err := json.Marshal(params) paramsStr, err := json.Marshal(params)
postJson, err := gohttp.PostJson(url, paramsStr) postJson, err := gohttp.PostJson(url, paramsStr)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "meituan.log" app.ZapLog.Sugar().Info(postJson)
app.ZapLog.Logger.Sugar().Info(postJson)
} }
return postJson.Body, err return postJson.Body, err
default: default:

15
service/pinduoduo/app.go
Unescape View File

@ -3,8 +3,8 @@ package pinduoduo
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
"gopkg.in/dtapps/go-library.v3/utils/gostring" "gopkg.in/dtapps/go-library.v3/utils/gostring"
"regexp" "regexp"
"strconv" "strconv"
@ -13,10 +13,10 @@ import (
// App 公共请求参数 // App 公共请求参数
type App struct { type App struct {
ClientId string // POP分配给应用的client_id ClientId string // POP分配给应用的client_id
ClientSecret string // POP分配给应用的client_secret ClientSecret string // POP分配给应用的client_secret
Pid string // 推广位 Pid string // 推广位
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
type ErrResp struct { type ErrResp struct {
@ -40,9 +40,8 @@ func (app *App) request(params map[string]interface{}) (resp []byte, err error)
// 发送请求 // 发送请求
httpGet, err := gohttp.Get("https://gw-api.pinduoduo.com/api/router", params) httpGet, err := gohttp.Get("https://gw-api.pinduoduo.com/api/router", params)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "pinduoduo.log" app.ZapLog.Sugar().Info(httpGet)
app.ZapLog.Logger.Sugar().Info(httpGet)
} }
// 检查错误 // 检查错误
var errResp ErrResp var errResp ErrResp

9
service/pintoto/app.go
Unescape View File

@ -4,7 +4,7 @@ import (
"encoding/json" "encoding/json"
"errors" "errors"
"fmt" "fmt"
"gopkg.in/dtapps/go-library.v3/utils/golog" "go.uber.org/zap"
"io/ioutil" "io/ioutil"
"math" "math"
"net/http" "net/http"
@ -17,7 +17,7 @@ import (
type App struct { type App struct {
AppKey string AppKey string
AppSecret string AppSecret string
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
type ErrResp struct { type ErrResp struct {
@ -55,9 +55,8 @@ func (app *App) request(url string, params map[string]interface{}) ([]byte, erro
body, err := ioutil.ReadAll(response.Body) body, err := ioutil.ReadAll(response.Body)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "pintoto.log" app.ZapLog.Sugar().Info(response.Body)
app.ZapLog.Logger.Sugar().Info(response.Body)
} }
// 检查错误 // 检查错误

13
service/taobao/app.go
Unescape View File

@ -3,8 +3,8 @@ package taobao
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
"gopkg.in/dtapps/go-library.v3/utils/gostring" "gopkg.in/dtapps/go-library.v3/utils/gostring"
"regexp" "regexp"
"strconv" "strconv"
@ -12,9 +12,9 @@ import (
// App 公共请求参数 // App 公共请求参数
type App struct { type App struct {
AppKey string // 应用Key AppKey string // 应用Key
AppSecret string // 密钥 AppSecret string // 密钥
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
type ErrResp struct { type ErrResp struct {
ErrorResponse struct { ErrorResponse struct {
@ -32,9 +32,8 @@ func (app *App) request(params map[string]interface{}) (resp []byte, err error)
// 发送请求 // 发送请求
httpGet, err := gohttp.Get("https://eco.taobao.com/router/rest", params) httpGet, err := gohttp.Get("https://eco.taobao.com/router/rest", params)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "taobao.log" app.ZapLog.Sugar().Info(httpGet)
app.ZapLog.Logger.Sugar().Info(httpGet)
} }
// 检查错误 // 检查错误
var errResp ErrResp var errResp ErrResp

17
service/wechatmp/app.go
Unescape View File

@ -3,18 +3,18 @@ package wechatmp
import ( import (
"bytes" "bytes"
"encoding/json" "encoding/json"
"gopkg.in/dtapps/go-library.v3/utils/golog" "go.uber.org/zap"
"io/ioutil" "io/ioutil"
"net/http" "net/http"
) )
// App 微信小程序服务 // App 微信小程序服务
type App struct { type App struct {
AppId string // 小程序唯一凭证，即 AppID AppId string // 小程序唯一凭证，即 AppID
AppSecret string // 小程序唯一凭证密钥，即 AppSecret AppSecret string // 小程序唯一凭证密钥，即 AppSecret
AccessToken string // 接口调用凭证 AccessToken string // 接口调用凭证
JsapiTicket string // 签名凭证 JsapiTicket string // 签名凭证
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
func (app *App) request(url string, params map[string]interface{}, method string) (resp []byte, err error) { func (app *App) request(url string, params map[string]interface{}, method string) (resp []byte, err error) {
@ -39,9 +39,8 @@ func (app *App) request(url string, params map[string]interface{}, method string
resp, err = ioutil.ReadAll(response.Body) resp, err = ioutil.ReadAll(response.Body)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "wechatmp.log" app.ZapLog.Sugar().Info(response.Body)
app.ZapLog.Logger.Sugar().Info(response.Body)
} }
// 检查请求错误 // 检查请求错误

13
service/wechatpayapiv3/app.go
Unescape View File

@ -3,7 +3,7 @@ package wechatpayapiv3
import ( import (
"bytes" "bytes"
"encoding/json" "encoding/json"
"gopkg.in/dtapps/go-library.v3/utils/golog" "go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gorequest" "gopkg.in/dtapps/go-library.v3/utils/gorequest"
"io/ioutil" "io/ioutil"
"net/http" "net/http"
@ -16,9 +16,9 @@ type App struct {
MchId string // 微信支付的商户id MchId string // 微信支付的商户id
AesKey string AesKey string
ApiV3 string ApiV3 string
PrivateSerialNo string // 私钥证书号 PrivateSerialNo string // 私钥证书号
MchPrivateKey string // 商户私有证书内容 apiclient_key.pem MchPrivateKey string // 商户私有证书内容 apiclient_key.pem
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
// ErrResp 错误返回 // ErrResp 错误返回
@ -72,9 +72,8 @@ func (app *App) request(url string, params map[string]interface{}, method string
} }
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "wechatpayapiv3.log" app.ZapLog.Sugar().Info(result)
app.ZapLog.Logger.Sugar().Info(result)
} }
// 检查请求错误 // 检查请求错误

9
service/wechatqy/app.go
Unescape View File

@ -2,13 +2,13 @@ package wechatqy
import ( import (
"encoding/json" "encoding/json"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
) )
type App struct { type App struct {
Key string Key string
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
func (app *App) request(url string, params map[string]interface{}) (body []byte, err error) { func (app *App) request(url string, params map[string]interface{}) (body []byte, err error) {
@ -17,9 +17,8 @@ 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.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "wechatqy.log" app.ZapLog.Sugar().Info(postJson)
app.ZapLog.Logger.Sugar().Info(postJson)
} }
return postJson.Body, err return postJson.Body, err
} }

19
service/wechatunion/app.go
Unescape View File

@ -2,24 +2,24 @@ package wechatunion
import ( import (
"encoding/json" "encoding/json"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
"net/http" "net/http"
) )
type App struct { type App struct {
AppId string // 小程序唯一凭证，即 AppID AppId string // 小程序唯一凭证，即 AppID
AppSecret string // 小程序唯一凭证密钥，即 AppSecret AppSecret string // 小程序唯一凭证密钥，即 AppSecret
AccessToken string // 接口调用凭证 AccessToken string // 接口调用凭证
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
func (app *App) request(url string, params map[string]interface{}, method string) (resp []byte, err error) { func (app *App) request(url string, params map[string]interface{}, method string) (resp []byte, err error) {
if method == http.MethodGet { if method == http.MethodGet {
get, err := gohttp.Get(url, params) get, err := gohttp.Get(url, params)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.Logger.Sugar().Info(get) app.ZapLog.Sugar().Info(get)
} }
return get.Body, err return get.Body, err
} else { } else {
@ -27,9 +27,8 @@ func (app *App) request(url string, params map[string]interface{}, method string
paramsStr, err := json.Marshal(params) paramsStr, err := json.Marshal(params)
postJson, err := gohttp.PostJson(url, paramsStr) postJson, err := gohttp.PostJson(url, paramsStr)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "wechatunion.log" app.ZapLog.Sugar().Info(postJson)
app.ZapLog.Logger.Sugar().Info(postJson)
} }
return postJson.Body, err return postJson.Body, err
} }

9
service/wikeyun/app.go
Unescape View File

@ -2,8 +2,8 @@ package wikeyun
import ( import (
"fmt" "fmt"
"go.uber.org/zap"
"gopkg.in/dtapps/go-library.v3/utils/gohttp" "gopkg.in/dtapps/go-library.v3/utils/gohttp"
"gopkg.in/dtapps/go-library.v3/utils/golog"
) )
type App struct { type App struct {
@ -11,7 +11,7 @@ type App struct {
AppKey int AppKey int
AppSecret string AppSecret string
ClientIP string ClientIP string
ZapLog golog.App // 日志服务 ZapLog *zap.Logger // 日志服务
} }
func (app *App) request(url string, params map[string]interface{}) (resp []byte, err error) { func (app *App) request(url string, params map[string]interface{}) (resp []byte, err error) {
@ -21,9 +21,8 @@ func (app *App) request(url string, params map[string]interface{}) (resp []byte,
requestUrl := fmt.Sprintf("%s?app_key=%d&timestamp=%s&client=%s&format=%s&v=%s&sign=%s", url, app.AppKey, sign.Timestamp, sign.Client, sign.Format, sign.V, sign.Sign) requestUrl := fmt.Sprintf("%s?app_key=%d&timestamp=%s&client=%s&format=%s&v=%s&sign=%s", url, app.AppKey, sign.Timestamp, sign.Client, sign.Format, sign.V, sign.Sign)
postForm, err := gohttp.PostForm(requestUrl, params) postForm, err := gohttp.PostForm(requestUrl, params)
// 日志 // 日志
if app.ZapLog.Logger != nil { if app.ZapLog != nil {
app.ZapLog.LogName = "wikeyun.log" app.ZapLog.Sugar().Info(postForm)
app.ZapLog.Logger.Sugar().Info(postForm)
} }
return postForm.Body, err return postForm.Body, err
} }

Write Preview
Loading…
Cancel
Save